106出库优先

pang.jiabao

2025-02-24 fd0c2bb794afd7b241d1d46b43d0611fa0f79362

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

@@ -689,6 +689,7 @@
                        if (wrkMast.getSourceStaNo() == 106 && wrkMast.getWrkSts() == 12L) {
                            wrkMast.setWrkSts(16L);
                            wrkMast.setCrnNo(1);
                            wrkMast.setIoPri(14D); // 优先级提升
                            if (wrkMast.getStaNo() == 107) {
                                wrkMast.setSourceStaNo(107);
                            } else if(wrkMast.getStaNo()==104) {
@@ -697,11 +698,7 @@
                            staProtocol.setStaNo((short) 106);

                            log.info("----------106移库标识---------");
                        }else if(wrkMast.getSourceStaNo() == 105 && wrkMast.getWrkSts() == 16L) {
                            staProtocol.setStaNo(wrkMast.getStaNo().shortValue());
                            log.info("106移库完成，输送线发送105到104，源站为：" + staProtocol.getSiteId());
                            wrkMast.setWrkSts(14L);
                        }else {
                        } else {
                            staProtocol.setStaNo(wrkMast.getStaNo().shortValue());
                            wrkMast.setWrkSts(14L);
                        }
@@ -1882,7 +1879,7 @@
            LocMast loc = null;
            for (Integer row : rows) {
                if (Utils.isDeepLoc(slaveProperties, row)) {
                    loc = locMastService.queryFreeLocMast(row, shallowLoc.getLocType1());
                    loc = locMastService.queryFreeLocMast(row, shallowLoc.getLocType2());

                    if (loc != null) {
                        if (Utils.isDeepLoc(slaveProperties, loc.getLocNo())) {
@@ -3095,11 +3092,11 @@
        crnCommand.setTraySize(true);     //库位类型
        if (!MessageQueue.offer(SlaveType.Crn, 1, new Task(2, crnCommand))) {
            News.error("106移库1号堆垛机命令下发失败，堆垛机号={}，任务数据={}", wrkMast.getCrnNo(), JSON.toJSON(crnCommand));
        } else {
            wrkMast.setWrkSts(12L);
            wrkMastMapper.updateById(wrkMast);
            log.info("1号堆垛机转运106推送到命令队列成功");
        }
//        else {
//            wrkMast.setCrnNo(2);
//            wrkMastMapper.updateById(wrkMast);
//        }
        News.infoNoLog("106移库给1号堆垛机下发完成");
    }

@@ -3125,28 +3122,60 @@
    }

    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;
            }
            SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 1);
            StaProtocol staProtocol= devpThread.getStation().get(wrkMast.getStaNo());
            if (staProtocol == null) {
                return;
            } else {
                staProtocol = staProtocol.clone();
            }
            if(staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.getWorkNo() == 0) {
//        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) {
                   return;
               } else {
                   staProtocol = staProtocol.clone();
               }
               if(staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.getWorkNo() == 0) {
                   staProtocol.setWorkNo(wrkMast.getWrkNo());
                   staProtocol.setStaNo(wrkMast.getSourceStaNo().shortValue());
                   devpThread.setPakMk(staProtocol.getSiteId(), false);
                   MessageQueue.offer(SlaveType.Devp,1, new Task(2, staProtocol));
                   log.info("入库请求底座-,任务号：{}，目标站：{}-----", wrkMast.getWrkNo(), wrkMast.getStaNo());
               }
           }

//        }
    }

    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(wrkMast.getSourceStaNo().shortValue());
                staProtocol.setStaNo((short) 0);
                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());
                break;
            }
        }
    }