#
Junjie
6 小时以前 27836d1b0bc74a5aa22a8b6c7cf40f2d0068db8a
#
5个文件已修改
19 ■■■■■ 已修改文件
src/main/java/com/zy/asrs/controller/DualCrnController.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/core/network/real/ZyDualCrnRealConnect.java 7 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/core/thread/DualCrnThread.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/core/thread/impl/ZySiemensDualCrnThread.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/core/utils/DualCrnOperateProcessUtils.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/asrs/controller/DualCrnController.java
@@ -177,7 +177,7 @@
        if (crnThread == null) {
            return R.error("线程不存在");
        }
        DualCrnCommand command = crnThread.getResetCommand(crnNo, station);
        DualCrnCommand command = crnThread.getResetCommand(9999, crnNo, station);
        MessageQueue.offer(SlaveType.DualCrn, crnNo, new Task(3, command));
        return R.ok();
    }
src/main/java/com/zy/core/network/real/ZyDualCrnRealConnect.java
@@ -267,8 +267,13 @@
                 confirmAddress = "DB100.34";
             }
             short sendTaskNo = command.getTaskNo().shortValue();
             if(command.getTaskMode().equals(DualCrnTaskModeType.CONFIRM.id)) {
                 sendTaskNo = 0;
             }
             short[] array = new short[9];
             array[0] = command.getTaskNo().shortValue();
             array[0] = sendTaskNo;
             array[1] = command.getTaskMode().shortValue();
             array[2] = command.getSourcePosX().shortValue();
             array[3] = command.getSourcePosY().shortValue();
src/main/java/com/zy/core/thread/DualCrnThread.java
@@ -17,7 +17,7 @@
    DualCrnCommand getMoveCommand(String targetLocNo, Integer taskNo, Integer crnNo);//移动
    DualCrnCommand getResetCommand(Integer crnNo, Integer station);//复位
    DualCrnCommand getResetCommand(Integer taskNo, Integer crnNo, Integer station);//复位
    CommandResponse sendCommand(DualCrnCommand command);//下发命令
src/main/java/com/zy/core/thread/impl/ZySiemensDualCrnThread.java
@@ -491,10 +491,10 @@
    }
    @Override
    public DualCrnCommand getResetCommand(Integer crnNo, Integer station) {
    public DualCrnCommand getResetCommand(Integer taskNo, Integer crnNo, Integer station) {
        DualCrnCommand crnCommand = new DualCrnCommand();
        crnCommand.setCrnNo(crnNo); // 堆垛机编号
        crnCommand.setTaskNo(0); // 工作号
        crnCommand.setTaskNo(taskNo); // 工作号
        crnCommand.setTaskMode(DualCrnTaskModeType.CONFIRM.id); // 任务模式:  确认
        crnCommand.setSourcePosX(0);     // 源库位排
        crnCommand.setSourcePosY(0);     // 源库位列
src/main/java/com/zy/core/utils/DualCrnOperateProcessUtils.java
@@ -759,7 +759,7 @@
                return;
            }
            DualCrnCommand resetCommand = dualCrnThread.getResetCommand(dualCrnProtocol.getCrnNo(), station);
            DualCrnCommand resetCommand = dualCrnThread.getResetCommand(taskNo, dualCrnProtocol.getCrnNo(), station);
            boolean offer = MessageQueue.offer(SlaveType.DualCrn, dualCrnProtocol.getCrnNo(), new Task(3, resetCommand));
            if (offer) {
                wrkMast.setWrkSts(updateWrkSts);
@@ -771,7 +771,7 @@
                redisUtil.set(RedisKeyType.DUAL_CRN_IO_EXECUTE_FINISH_LIMIT.key + basDualCrnp.getCrnNo() + "_" + taskNo, "lock", 10);
            }
        }else {
            DualCrnCommand resetCommand = dualCrnThread.getResetCommand(dualCrnProtocol.getCrnNo(), station);
            DualCrnCommand resetCommand = dualCrnThread.getResetCommand(taskNo, dualCrnProtocol.getCrnNo(), station);
            MessageQueue.offer(SlaveType.DualCrn, dualCrnProtocol.getCrnNo(), new Task(3, resetCommand));
            News.info("双工位堆垛机命令完成确认成功,堆垛机号={},工作号={}", basDualCrnp.getCrnNo(), taskNo);
        }