src/main/java/com/zy/asrs/controller/SiteController.java

@@ -88,10 +88,10 @@
//            vo.setLocType1(staProtocol.isHigh() != staProtocol.isLow() && staProtocol.isLow() ? "低" : "高");     //高低库位
            //vo.setLocType1(staProtocol.getWeight() == 1 ? "重" : "轻");
            vo.setFinishWorkNo(staProtocol.getFinishWorkNo());
            if (staProtocol.getSiteId() == 1031 || staProtocol.getSiteId() == 1032) {
                vo.setOutInModel((staProtocol.getOutInModel() != null && staProtocol.getOutInModel() == 1) ? "出" : "入");

            }
//            if (staProtocol.getSiteId() == 1031 || staProtocol.getSiteId() == 1032) {
//                vo.setOutInModel((staProtocol.getOutInModel() != null && staProtocol.getOutInModel() == 1) ? "出" : "入");
//
//            }
        }
        return R.ok().add(list);
    }

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

@@ -877,7 +877,7 @@
            short staNo = 1012;
            if (wrkMast.getSourceStaNo() == 1022) {
                staNo = 1023;
            } else if (wrkMast.getSourceStaNo() == 1032) {
            } else if (wrkMast.getSourceStaNo() == 1031) {
                staNo = 1032;
            }

@@ -945,6 +945,8 @@
            Integer sourceStaNo = wrkMast.getSourceStaNo();
            if (wrkMast.getSourceStaNo() == 1022) {
                sourceStaNo = 1023;
            } else if (wrkMast.getSourceStaNo() == 1031) {
                sourceStaNo = 1032;
            }

            StaProtocol staProtocol = station.get(sourceStaNo);
@@ -972,7 +974,7 @@
                    return false;
                }
            } else if (sourceStaNo == 1032) {
                if (staProtocol.getWorkNo().intValue() != wrkMast.getWrkNo()) {
                if (staProtocol.getFinishWorkNo().intValue() != wrkMast.getWrkNo()) {
                    News.info("{}任务，{}站点，任务号不一致", wrkMast.getWrkNo(), staProtocol.getSiteId());
                    return false;
                }
@@ -1121,11 +1123,10 @@
                return false;
            }
            if (wrkMast.getStaNo() == 1031) {
                //TODO
                if (staProtocol.getOutInModel() != 1) {
                    News.info("{}任务，{}站点，没有可出信号", wrkMast.getWrkNo(), staProtocol.getSiteId());
                    return false;
                }
//                if (staProtocol.getOutInModel() != 1) {
//                    News.info("{}任务，{}站点，没有可出信号", wrkMast.getWrkNo(), staProtocol.getSiteId());
//                    return false;
//                }
            } else {
                if (!isOutEnable(devpThread, wrkMast.getStaNo())) {
                    News.info("{}任务，{}站点，没有可出信号", wrkMast.getWrkNo(), staProtocol.getSiteId());
@@ -1628,7 +1629,7 @@
            Map<Integer, StaProtocol> station = devpThread.getStation();
            WrkMast wrkMast = null;
            for (StaProtocol staProtocol : station.values()) {
                if (staProtocol.getSiteId() == 1013 || staProtocol.getSiteId() == 1024) {
                if ((staProtocol.getSiteId() == 1013 || staProtocol.getSiteId() == 1024) && staProtocol.isLoading()) {
                    wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", staProtocol.getFinishWorkNo()).eq("wrk_sts", WrkStsType.OUTBOUND_DEVP_RUN.sts));
                    if (wrkMast != null) {
                        wrkMast.setWrkSts(WrkStsType.COMPLETE_OUTBOUND.sts);
@@ -1639,9 +1640,13 @@
                            News.error("输送线已确认且任务完成状态,复位失败，但未找到工作档。输送线号={}，完结工作号={}", staProtocol.getSiteId(), staProtocol.getFinishWorkNo());
                        }
                    }
                } else if (staProtocol.getSiteId() == 1031) {
                } else if (staProtocol.getSiteId() == 1031 && staProtocol.isLoading()) {
                    wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", staProtocol.getFinishWorkNo()).eq("wrk_sts", WrkStsType.OUTBOUND_DEVP_RUN_2.sts));
                    if (wrkMast != null) {
                        staProtocol.setWorkNo(Short.parseShort(String.valueOf(wrkMast.getWrkNo())));
                        staProtocol.setStaNo(Short.parseShort(String.valueOf(1135)));
                        MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol));
                        News.info("输送线入库命令下发，任务数据={}", JSON.toJSON(wrkMast));
                        wrkMast.setWrkSts(WrkStsType.COMPLETE_OUTBOUND.sts);
                        wrkMast.setModiTime(new Date());
                        if (wrkMastService.updateById(wrkMast)) {
@@ -2150,9 +2155,15 @@
    }

    private void shuttleMoveExecuteTransportLift(WrkMast wrkMast) {
        LiftThread liftThread = LiftUtils.getRecentLift(wrkMast.getLocNo());
        if (liftThread == null) {
            return;
        WrkMast wrkMast1 = wrkMastService.selectByWorkNo(wrkMast.getMainWrkNo());
        LiftThread liftThread;
        if (wrkMast1 != null && wrkMast1.getLiftNo() != null) {
            liftThread = (LiftThread) SlaveConnection.get(SlaveType.Lift, 1);
        } else {
            liftThread = LiftUtils.getRecentLift(wrkMast.getLocNo());
            if (liftThread == null) {
                return;
            }
        }
        //liftThread = (LiftThread) SlaveConnection.get(SlaveType.Lift, wrkMast1.getLiftNo());
        String liftLocNo = liftThread.getLiftLocNo(Utils.getLev(wrkMast.getLocNo()));