涂布车间入出库优化

pang.jiabao

2025-02-11 b4bf0656bfe363807c3fe407b3f55bb72655cd3d

涂布车间入出库优化

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

@@ -3122,15 +3122,18 @@
    }

    public synchronized void invokingBase() {
        WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_sts", 1L).eq("io_type", 1)
                .eq("source_sta_no", 305));
        if (wrkMast != null) {
            int count = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("wrk_sts", 2L).eq("io_type", 1)
                    .eq("source_sta_no", 305));
            if (count != 0) {
                log.warn("存在305入库任务，状态为设备上走");
                return;
            }
//        WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_sts", 1L).eq("io_type", 1)
//                .eq("source_sta_no", 305));
//        if (wrkMast != null) {
//            int count = wrkMastService.selectCount(new EntityWrapper<WrkMast>().eq("wrk_sts", 2L).eq("io_type", 1)
//                    .eq("source_sta_no", 305));
//            if (count != 0) {
//                log.warn("存在305入库任务，状态为设备上走");
//                return;
//            }
           List<WrkMast> wrkMastList = 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 : wrkMastList) {
            SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 1);
            StaProtocol staProtocol= devpThread.getStation().get(wrkMast.getStaNo());
            if (staProtocol == null) {
@@ -3142,9 +3145,11 @@
                staProtocol.setWorkNo(wrkMast.getWrkNo());
                staProtocol.setStaNo(wrkMast.getSourceStaNo().shortValue());
                devpThread.setPakMk(staProtocol.getSiteId(), false);
                boolean result = MessageQueue.offer(SlaveType.Devp,1, new Task(2, staProtocol));
                log.info("入库请求底座------");
                   MessageQueue.offer(SlaveType.Devp,1, new Task(2, staProtocol));
                   log.info("入库请求底座-,任务号：{}，目标站：{}-----", wrkMast.getWrkNo(), wrkMast.getStaNo());
            }
        }

//        }
    }
}