1

zhang

2026-01-07 5d24f639d62119f4c661e7f04ac7cc5b0f5ce827

 src/main/java/com/zy/asrs/service/impl/CtuMainServiceImpl.java

@@ -6,9 +6,6 @@
import com.core.exception.CoolException;
import com.zy.asrs.domain.param.OpenBusSubmitParam;
import com.zy.asrs.domain.param.TaskDto;
import com.zy.asrs.mapper.WrkMastMapper;
import com.zy.asrs.service.LocMastService;
import com.zy.asrs.service.WrkMastService;
import com.zy.common.utils.HttpHandler;
import com.zy.common.utils.News;
import com.zy.core.cache.MessageQueue;
@@ -56,14 +53,6 @@
    @Autowired
    private SlaveProperties slaveProperties;

    @Autowired
    private WrkMastMapper wrkMastMapper;

    @Autowired
    private LocMastService locMastService;

    @Autowired
    private WrkMastService wrkMastService;

    private boolean flag1001 = false;

@@ -326,13 +315,23 @@
            OpenBusSubmitParam openBusSubmitParam = new OpenBusSubmitParam();
            openBusSubmitParam.setBatch(DateUtils.convert(new Date()));
            List<TaskDto> taskList = new ArrayList<>();
            TaskDto taskDto = new TaskDto();
            Random rand = new Random();
            TaskDto taskDto = new TaskDto();
            taskDto.setSeqNum("SSX-CK" + rand.nextInt() * 10000);
            taskDto.setOriLoc(getFLoc("1001", "16"));
            taskDto.setDestSta("1001");
            taskDto.setPriority(123);
            taskList.add(taskDto);
            String fLoc = getFLoc("1001", "16");
            if (fLoc == taskDto.getOriLoc()) {
                fLoc = getFLoc("1001", "16");
            }
            taskDto = new TaskDto();
            taskDto.setSeqNum("SSX-CK" + rand.nextInt() * 10000);
            taskDto.setOriLoc(fLoc);
            taskDto.setDestSta("1001");
            taskDto.setPriority(123);
            taskList.add(taskDto);
            openBusSubmitParam.setTaskList(taskList);
            sendTask(openBusSubmitParam, staProtocol);
        }