1

zhang

2026-01-24 87f8618e3bb8bcc769884225238fb1d4d02afb43

 zy-acs-cv/src/main/java/com/zy/asrs/service/impl/CtuMainServiceImpl.java

@@ -278,11 +278,7 @@
                        Job job = jobMapper.getJobByJobNo(staProtocol.getWorkNo());
                        if (job != null && job.getJobSts() == 4) {
                            job.setJobSts(5);
                            job.setRcsTime(new Date());
                            jobMapper.updateById(job);
                            if (!fakeWms(staProtocol)) {
                                throw new CoolException("任务发送给RCS失败," + job.getSeqNum() + " - " + job.getSeqNum());
                            }
                        }
                    }
                }
@@ -293,21 +289,36 @@
        }
    }

    public boolean fakeWms(StaProtocol staProtocol) {
        OpenBusSubmitParam openBusSubmitParam = new OpenBusSubmitParam();
        openBusSubmitParam.setBatch(DateUtils.convert(new Date()));
        List<TaskDto> taskList = new ArrayList<>();
        TaskDto taskDto = new TaskDto();
        taskDto.setSeqNum("SSX-RK" + staProtocol.getWorkNo());
        taskDto.setOriSta("1007");
        taskDto.setPriority(9527);
        taskList.add(taskDto);
        openBusSubmitParam.setTaskList(taskList);
        return sendTask(openBusSubmitParam, staProtocol);


    @Transactional
    public synchronized void fakeWms(Integer mark) {
        List<Job> jobs = jobMapper.listJobByJobSts(5);
        for (Job job : jobs) {
            OpenBusSubmitParam openBusSubmitParam = new OpenBusSubmitParam();
            openBusSubmitParam.setBatch(DateUtils.convert(new Date()));
            List<TaskDto> taskList = new ArrayList<>();
            TaskDto taskDto = new TaskDto();
            taskDto.setSeqNum("SSX-RK" + job.getJobNo());
            taskDto.setOriSta("1007");
            taskDto.setPriority(9527);
            taskList.add(taskDto);
            openBusSubmitParam.setTaskList(taskList);
            boolean b = sendTask(openBusSubmitParam);
            if (b){
                job.setJobSts(6);
                job.setRcsTime(new Date());
                jobMapper.updateById(job);
                log.info("任务发送给RCS成功," + job.getSeqNum() + " - " + job.getJobNo());
            }else {
                log.info("任务发送给RCS失败," + job.getSeqNum() + " - " + job.getJobNo());
            }
        }

    }

    @Transactional
    public boolean sendTask(OpenBusSubmitParam openBusSubmitParam, StaProtocol staProtocol) {
    public boolean sendTask(OpenBusSubmitParam openBusSubmitParam) {
        String response = "";
        try {
            response = new HttpHandler.Builder()
@@ -356,7 +367,7 @@
                for (StationStatus object : stationStatuses) {
                    if (object.getStaNo().equals(staNo + "")) {
                        if (object.getConveyable()) {
                            return object.getSeqNum() == null ? System.currentTimeMillis() + "" : object.getSeqNum();
                            return object.getTaskNo();
                        } else {
                            log.info("站点：{}状态不对", staNo);
                            return null;