pang.jiabao
2025-02-24 fd0c2bb794afd7b241d1d46b43d0611fa0f79362
106出库优先
2个文件已修改
36 ■■■■■ 已修改文件
src/main/java/com/zy/core/MainProcess.java 9 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/service/impl/MainServiceImpl.java 27 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/core/MainProcess.java
@@ -42,6 +42,9 @@
                        continue;
                    }
                    // 106生成转移任务
                    mainService.autoMoveLoc();
                    // 演示
//                    mainService.crnDemoOfLocMove1();
                    //刷新RGV地图
@@ -78,15 +81,15 @@
                    mainService.outOfDevp(11);
                    // 106生成转移任务
                    mainService.autoMoveLoc();
                    // 给plc写开门信号
                    mainService.writePlc305();
                    // 305入库调用底座到305
                    mainService.invokingBase();
                    // 出库转入库任务
//                    mainService.inOutSwap();
//                    if (i>10){
//                        //空托盘自动出库
//                        mainService.autoEmptyOut();
src/main/java/com/zy/service/impl/MainServiceImpl.java
@@ -3152,4 +3152,31 @@
//        }
    }
    public synchronized void inOutSwap() {
        SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 1);
        StaProtocol staProtocol = devpThread.getStation().get(305);
        if (staProtocol == null) {
            return;
        } else {
            staProtocol = staProtocol.clone();
        }
        if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.getWorkNo() > 6000 && staProtocol.getWorkNo() <= 9000) {
            List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("wrk_sts", 1L).eq("io_type", 1)
                    .eq("source_sta_no", 305).orderBy("appe_time", true));
            for (WrkMast wrkMast : wrkMasts) {
                wrkMast.setWhsType(3);
                wrkMastService.updateById(wrkMast);
                staProtocol.setWorkNo(wrkMast.getWrkNo());
                staProtocol.setStaNo((short) 0);
                devpThread.setPakMk(staProtocol.getSiteId(), false);
                MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol));
                log.info("出库任务完成转入库,任务号:{},目标站:{}-----", wrkMast.getWrkNo(), wrkMast.getStaNo());
                break;
            }
        }
    }
}