#请求入库任务提示优化

Junjie

1 天以前 40dcac7c694867a4b66a9c8567cd2fe6959a25df

#请求入库任务提示优化

 src/main/java/com/zy/core/plugin/GslProcess.java

@@ -39,9 +39,9 @@

    @Override
    public void run() {
        //检测入库站是否有任务生成，并按站点 lane 异步启动入库
        //启动入库
        stationOperateProcessUtils.submitStationEnableInTasks(DISPATCH_INTERVAL_MS);
        //请求生成入库任务，保留按站点 lane 串行提交
        //请求生成入库任务
        generateStoreWrkFile();

        // 执行堆垛机任务

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

@@ -17,10 +17,7 @@
import com.zy.core.cache.SlaveConnection;
import com.zy.core.dispatch.StationCommandDispatchResult;
import com.zy.core.dispatch.StationCommandDispatcher;
import com.zy.core.enums.RedisKeyType;
import com.zy.core.enums.SlaveType;
import com.zy.core.enums.StationCommandType;
import com.zy.core.enums.WrkIoType;
import com.zy.core.enums.*;
import com.zy.core.model.StationObjModel;
import com.zy.core.model.command.StationCommand;
import com.zy.core.model.protocol.StationProtocol;
@@ -159,10 +156,20 @@
        }

        String barcode = context.getStationProtocol().getBarcode();
        long count = wrkMastService.count(new QueryWrapper<WrkMast>().eq("barcode", barcode));
        if (count > 0) {
        List<WrkMast> wrkMastList = wrkMastService.list(new QueryWrapper<WrkMast>()
                .eq("barcode", barcode)
        );
        if (wrkMastList.size() > 0) {
            boolean showTips = true;
            for (WrkMast wrkMast : wrkMastList) {
                if (wrkMast.getWrkSts().equals(WrkStsType.NEW_INBOUND.sts)) {
                    showTips = false;
                    break;
                }
            }

            Object tipsLimit = redisUtil.get(RedisKeyType.GENERATE_IN_TASK_SUCCESS_REPEAT_WARNING_TIPS_LIMIT.key + barcode);
            if (tipsLimit == null) {
            if (tipsLimit == null && showTips) {
                policy.setSystemWarning(context, "系统任务已存在");
            }
            return;