#入库系统任务已存在提示优化

Junjie

2026-04-11 043ce2d1359eecd7ec9611baf8b9fc02756f0fbb

#入库系统任务已存在提示优化

 src/main/java/com/zy/core/enums/RedisKeyType.java

@@ -61,6 +61,7 @@
    STATION_EXECUTE_COMMAND_LOCK("station_execute_command_lock"),
    CLEAR_CRN_TASK_LIMIT("clear_crn_task_limit_"),
    CLEAR_DUAL_CRN_TASK_LIMIT("clear_dual_crn_task_limit_"),
    GENERATE_IN_TASK_SUCCESS_REPEAT_WARNING_TIPS_LIMIT("generate_in_task_success_repeat_warning_tips_limit_"),

    DUAL_CRN_PICK_WAIT_NEXT_TASK("dual_crn_pick_wait_next_task_"),
    DUAL_CRN_OUT_TASK_STATION_INFO("dual_crn_out_task_station_info_"),

 src/main/java/com/zy/core/plugin/store/StoreInTaskGenerationService.java

@@ -135,9 +135,13 @@
            return;
        }

        long count = wrkMastService.count(new QueryWrapper<WrkMast>().eq("barcode", context.getStationProtocol().getBarcode()));
        String barcode = context.getStationProtocol().getBarcode();
        long count = wrkMastService.count(new QueryWrapper<WrkMast>().eq("barcode", barcode));
        if (count > 0) {
            policy.setSystemWarning(context, "系统任务已存在");
            Object tipsLimit = redisUtil.get(RedisKeyType.GENERATE_IN_TASK_SUCCESS_REPEAT_WARNING_TIPS_LIMIT.key + barcode);
            if (tipsLimit == null) {
                policy.setSystemWarning(context, "系统任务已存在");
            }
            return;
        }

@@ -210,6 +214,7 @@
            WrkMast wrkMast = commonService.createInTask(taskParam);
            policy.afterTaskCreated(context, wrkMast);
            policy.clearSystemWarning(context);
            redisUtil.set(RedisKeyType.GENERATE_IN_TASK_SUCCESS_REPEAT_WARNING_TIPS_LIMIT.key + wrkMast.getBarcode(), "lock", 30);
        } catch (Exception e) {
            News.error("处理WMS入库响应异常，barcode={}，stationId={}", request.getBarcode(),
                    request.getSourceStaNo(), e);