lift

Junjie

2023-06-26 7cd8c743cb1f377a3102d9a154669fb2bc10535c

lift

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

@@ -684,13 +684,17 @@
                                //状态8，等待命令进行入库搬运动作

                                //判断提升机是否空闲
                                if (!liftProtocol.isIdle()) {
                                if (!liftProtocol.isIdleNoTask()) {
                                    try {
                                        Thread.sleep(1000);//休眠1s
                                    } catch (InterruptedException e) {
                                        throw new RuntimeException(e);
                                    }
                                    continue;//提升机忙
                                }
                                //判断提升机任务号和当前工作档任务号是否一致
                                if (liftProtocol.getTaskNo().intValue() != 0 && liftProtocol.getTaskNo().intValue() != wrkMast.getWrkNo()) {
                                    continue;
                                }

                                //判断提升机楼层是否到位，判断站点是否给出提升机到位信号
@@ -986,13 +990,17 @@
                    }else if(wrkMast.getWrkSts() == 25) {//状态25，需要向小车下发命令从提升机移动出去，需要判断提升机状是否空闲、提升机是否到达目标楼层、目标楼层站点是否存在、目标楼层站点是否给出提升机到位信号

                        //判断提升机是否空闲
                        if (!liftProtocol.isIdle()) {
                        if (!liftProtocol.isIdleNoTask()) {
                            try {
                                Thread.sleep(1000);//休眠1s
                            } catch (InterruptedException e) {
                                throw new RuntimeException(e);
                            }
                            continue;//提升机忙
                        }
                        //判断提升机任务号和当前工作档任务号是否一致
                        if (liftProtocol.getTaskNo().intValue() != 0 && liftProtocol.getTaskNo().intValue() != wrkMast.getWrkNo()) {
                            continue;
                        }

                        //判断提升机楼层是否到位，判断站点是否给出提升机到位信号
@@ -1071,7 +1079,7 @@
                            BasDevp basDevp = basDevpService.queryByLocNo(liftSiteLocNo);
                            Short endStartCode = Short.parseShort(basDevp.getQrCodeValue());//站点二维码

                            String disLocNo = "190020" + Utils.getLev(liftSiteLocNo);//避让位置
                            String disLocNo = "2000202" + Utils.getLev(liftSiteLocNo);//避让位置
                            LocMast locMast1 = locMastService.queryByLoc(disLocNo);
                            if (locMast1 == null) {
                                continue;//找不到库位
@@ -1158,6 +1166,21 @@
                        ShuttleCommand moveCommand = shuttleThread.getMoveCommand(startCode, distCode, 1400, commands.get(0).getRunDirection(), startCode, 1400, 500);
                        commands.add(0, moveCommand);//将该指令添加到队头

                        //获取当前小车所在楼层的站点信息
                        BasDevp basDevp = basDevpService.queryByLocNo(liftSiteLocNo);
                        Short endStartCode = Short.parseShort(basDevp.getQrCodeValue());//站点二维码

                        String disLocNo = "2000202" + Utils.getLev(liftSiteLocNo);//避让位置
                        LocMast locMast1 = locMastService.queryByLoc(disLocNo);
                        if (locMast1 == null) {
                            continue;//找不到库位
                        }
                        short disCode = Short.parseShort(locMast1.getQrCodeValue());
                        //任务执行完后，小车进入移开提升机口站点位置，以免坠落
                        ShuttleCommand moveCommand2 = shuttleThread.getMoveCommand(endStartCode, disCode, 1400, ShuttleRunDirection.BOTTOM.id, endStartCode, 1400, 500);
                        commands.add(moveCommand2);


                        //分配目标库位
                        shuttleProtocol.setLocNo(wrkMast.getSourceLocNo());
                        //分配任务号
@@ -1197,7 +1220,7 @@
            //获取四向穿梭车线程
            ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, shuttle.getId());
            ShuttleProtocol shuttleProtocol = shuttleThread.getShuttleProtocol();
            if (shuttleProtocol == null) {
            if (shuttleProtocol == null || shuttleProtocol.getShuttleNo() == null) {
                continue;
            }
            if (!shuttleProtocol.isIdle()) {
@@ -1411,8 +1434,13 @@
                continue;
            }

            //判断提升机是否处于空闲状态
            if (!liftProtocol.isIdle()) {

//            if (!liftProtocol.isIdle()) {
//                continue;
//            }

            //判断提升机是否处于空闲状态，没有判断任务号，可能提升机处于空闲，但是还有任务未完成
            if (!liftProtocol.isIdleNoTask()) {
                continue;
            }

@@ -1434,6 +1462,15 @@
            }

            if (wrkMast.getWrkSts() == 2) {//2.设备上走
                if (liftProtocol.getTaskNo().intValue() != 0) {
                    //存在未完成任务号
                    continue;
                }
                if (liftProtocol.getPlatShuttleCheck()) {
                    //提升机此时有四向车，可能有未完成的任务，禁止分配新任务
                    continue;
                }

                //工作档目标库位号
                String wrkMastLocNo = wrkMast.getLocNo();
                //工作档目标库位楼层
@@ -1478,6 +1515,10 @@

                wrkMast.setWrkSts(3L);//3.提升机搬运中
            } else if (wrkMast.getWrkSts() == 6) {//6.迁移小车至提升机口完成 => 7.提升机迁移小车中
                if (liftProtocol.getTaskNo().intValue() != 0 && liftProtocol.getTaskNo().intValue() != wrkMast.getWrkNo()) {
                    //提升机存在未完成任务，且提升机任务号和当前工作档任务号不一致
                    continue;
                }
                liftProtocol.setShuttleNo(wrkMast.getShuttleNo().shortValue());//设置四向穿梭车号

                //判断小车是否在提升机内，且处于空闲状态
@@ -1494,6 +1535,10 @@
                }
                if (shuttleProtocol.getCurrentCode().intValue() != liftProtocol.getBarcode().intValue()) {
                    continue;//小车当前二维码和提升机内部二维码不一致，不允许执行
                }
                if (!liftProtocol.getPlatShuttleCheck()) {
                    //提升机未检测到小车，禁止执行
                    continue;
                }

                //工作档目标库位号
@@ -1514,6 +1559,10 @@

                wrkMast.setWrkSts(7L);//6.迁移小车至提升机口完成 => 7.提升机迁移小车中
            } else if(wrkMast.getWrkSts() == 23) {//23.迁移小车至提升机口完成 => 24.提升机迁移小车中
                if (liftProtocol.getTaskNo().intValue() != 0 && liftProtocol.getTaskNo().intValue() != wrkMast.getWrkNo()) {
                    //提升机存在未完成任务，且提升机任务号和当前工作档任务号不一致
                    continue;
                }
                liftProtocol.setShuttleNo(wrkMast.getShuttleNo().shortValue());//设置四向穿梭车号

                //判断小车是否在提升机内，且处于空闲状态
@@ -1531,6 +1580,10 @@
                }
                if (shuttleProtocol.getCurrentCode().intValue() != liftProtocol.getBarcode().intValue()) {
                    continue;//小车当前二维码和提升机内部二维码不一致，不允许执行
                }
                if (!liftProtocol.getPlatShuttleCheck()) {
                    //提升机未检测到小车，禁止执行
                    continue;
                }

                //工作档目标库位号
@@ -1551,6 +1604,15 @@

                wrkMast.setWrkSts(24L);//23.迁移小车至提升机口完成 => 24.提升机迁移小车中
            } else if (wrkMast.getWrkSts() == 27) {//27.小车出库搬运完成
                if (liftProtocol.getTaskNo().intValue() != 0 && liftProtocol.getTaskNo().intValue() != wrkMast.getWrkNo()) {
                    //提升机存在未完成任务，且提升机任务号和当前工作档任务号不一致
                    continue;
                }
                if (liftProtocol.getPlatShuttleCheck()) {
                    //提升机此时有四向车，可能有未完成的任务，禁止分配新任务
                    continue;
                }

                //工作档源库位号
                String wrkMastLocNo = wrkMast.getSourceLocNo();
                //工作档源库位楼层
@@ -1632,6 +1694,9 @@
                    && !liftProtocol.getRunning()
            ) {

                //标记复位
                liftProtocol.setPakMk(true);

                DevpThread devpThread = null;
                Integer devpId = null;
                for (DevpSlave devp : slaveProperties.getDevp()){
@@ -1664,6 +1729,8 @@
                        case 28://28.提升机搬运中 ==> 29.提升机搬运完成
                            wrkMast.setWrkSts(29L);
                            wrkMast.setWrkSts(34L);//34.出库完成，暂时先直接完成出库工作档，后续需要根据输送线给出的状态来确定34.出库完成状态
                            //任务号清零
                            liftProtocol.setTaskNo((short) 0);
                            break;
                        default:
                    }
@@ -1671,13 +1738,9 @@
                    if (wrkMastMapper.updateById(wrkMast) > 0) {
                        //设置提升机为空闲状态
                        liftProtocol.setProtocolStatus(LiftProtocolStatusType.IDLE);
                        //任务号清零
                        liftProtocol.setTaskNo((short) 0);
                        //标记复位
                        liftProtocol.setPakMk(true);
                        //任务指令清零
                        liftProtocol.setAssignCommand(null);
                        News.info("提升机已确认且任务完成状态,复位。提升机号={}", liftProtocol.getLiftNo());
                        News.info("提升机已确认且任务完成状态。提升机号={}", liftProtocol.getLiftNo());
                    } else {
                        News.error("提升机已确认且任务完成状态,复位失败，但未找到工作档。提升机号={}，工作号={}", liftProtocol.getLiftNo(), liftProtocol.getTaskNo());
                    }

 src/main/java/com/zy/core/model/protocol/LiftProtocol.java

@@ -268,6 +268,28 @@
        return res;
    }

    // 是否处于空闲待命状态，不判断任务号
    public Boolean isIdleNoTask() {
        if(this.taskNo == null
                || this.liftLock == null
                || this.ready == null
                || this.running == null
                || this.mode == null
                || this.pakMk == null
        ){
            return false;
        }

        boolean res = !this.liftLock
//                && this.ready
                && !this.running
                && this.mode
                && this.pakMk
                && !this.securityMk
                ;
        return res;
    }

    public void setPositionArrivalFeedback(Short position) {
        Short lev = null;
        switch (position) {

 src/main/java/com/zy/core/thread/LiftThread.java

@@ -363,9 +363,6 @@
            return false;
        }

        //将标记置为false(防止重发)
        liftProtocol.setPakMk(false);

        Object o = redisUtil.get("lift_wrk_no_" + wrkNo);
        if (o == null) {
            return false;
@@ -408,6 +405,9 @@
            News.info("提升机命令下发成功，提升机号={}，任务数据={}", command.getLiftNo(), JSON.toJSON(command));
            liftProtocol.setWrkTime(new Date());//更新工作时间

            //将标记置为false(防止重发)
            liftProtocol.setPakMk(false);

            //保存数据到数据库做流水
            BasLiftOptService liftOptService = SpringUtils.getBean(BasLiftOptService.class);
            if (liftOptService != null) {