12

zc

7 天以前 29f77fe00441b26d009ab55a9dd05702163cccdd

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

@@ -734,14 +734,14 @@
     */
    public synchronized void toSxk(Integer mark) {

        for (CrnSlave crnSlave : slaveProperties.getCrn()) {
        for (DevpSlave devpSlave : slaveProperties.getDevp()) {
            // 遍历堆垛机出库站
            for (CrnSlave.CrnStn crnStn : crnSlave.getCrnOutStn()) {
                if (crnStn.getStaNo() != 1035) {
            for (DevpSlave.Sta crnStn : devpSlave.getOutSta()) {
                if (crnStn.getStaNo() != 1135) {
                    continue;
                }
                // 获取堆垛机出库站信息
                DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, crnStn.getDevpPlcId());
                DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devpSlave.getId());
                StaProtocol staProtocol = devpThread.getStation().get(crnStn.getStaNo());
                if (staProtocol == null) {
                    continue;
@@ -762,7 +762,7 @@
                    // 下发站点信息
                    staProtocol.setWorkNo(wrkMast.getWrkNo().shortValue());
                    staProtocol.setStaNo(RouteUtils.CrnStaEnd(1031, 1135));
                    if (!MessageQueue.offer(SlaveType.Devp, crnStn.getDevpPlcId(), new Task(2, staProtocol))) {
                    if (!MessageQueue.offer(SlaveType.Devp, devpSlave.getId(), new Task(2, staProtocol))) {
                        log.info(staProtocol.getWorkNo() + "," + staProtocol.getStaNo() + "输送线出库命令下发失败222");
                        continue;
                    } else {