*

lsh

2025-03-14 2a4f0f4a65d2850e5ef819cd7296e6ad3b894aae

*

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

@@ -529,7 +529,7 @@
                    continue;
                }

                if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isPakMk() && staProtocol.getWorkNo()==0 && !staProtocol.isOutEnable() && staProtocol.isInEnable()) {
                if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isPakMk() && staProtocol.getWorkNo()==0 && !staProtocol.isOutEnable()) {//&& staProtocol.isInEnable()
                    WrkMast wrkMast = wrkMastMapper.selectPakInStep4(staProtocol.getSiteId(),"3");

                    if (wrkMast == null) {
@@ -572,12 +572,12 @@
                                    .doPost();
                        } catch(Exception e){
                            log.error("入库作业站"+pickSta.getStaNo()+"盘点再入库任务请求WMS===>>参数：" + param);
                            log.error("stnToCrnStnPick2===>>盘点查库位入库接口失败", e);
                            e.printStackTrace();
//                            log.error("stnToCrnStnPick2===>>盘点查库位入库接口失败", e);
//                            e.printStackTrace();
                            continue;
                        }
                        log.info("入库作业站"+pickSta.getStaNo()+"盘点再入库任务请求WMS===>>参数：" + param);
                        log.info("入库作业站"+pickSta.getStaNo()+"下发盘点再入库任务请求WMS返回结果===>>" + response);
//                        log.info("入库作业站"+pickSta.getStaNo()+"盘点再入库任务请求WMS===>>参数：" + param);
//                        log.info("入库作业站"+pickSta.getStaNo()+"下发盘点再入库任务请求WMS返回结果===>>" + response);
                        if(response.equals("")) {
                            continue;
                        }
@@ -585,35 +585,35 @@
//                        LedThread ledThread = (LedThread) SlaveConnection.get(SlaveType.Led, pickSta.getLed());
                        Integer code = jsonObject.getInteger("code");
                        if (code == 200) {
                            StartupDto dto = jsonObject.getObject("data", StartupDto.class);
                            if (Cools.isEmpty(dto) || Cools.isEmpty(dto.getStaNo())) {
                                log.error("任务号"+wrkMast.getWrkNo()+"盘点再入库查询库位失败===>>" + jsonObject.toJSONString());
                            } else {
//                            StartupDto dto = jsonObject.getObject("data", StartupDto.class);
//                            if (Cools.isEmpty(dto) || Cools.isEmpty(dto.getStaNo())) {
//                                log.error("任务号"+wrkMast.getWrkNo()+"盘点再入库查询库位失败===>>" + jsonObject.toJSONString());
//                            } else {
                                log.info("任务号"+wrkMast.getWrkNo()+"盘点再入库查询库位成功===>>" + jsonObject.toJSONString());
                                try {
                                    // 更新站点信息 且 下发plc命令
                                    staProtocol.setWorkNo(wrkMast.getWrkNo());
                                    staProtocol.setStaNo(dto.getStaNo());
                                    devpThread.setPakMk(staProtocol.getSiteId(), false);
//                                    ledThread.errorReset();
                                    boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                                    if (!result) {
                                        log.error("发布命令至输送线队列失败！！！ [plc编号：{}]", devp.getId());
                                    }
                                    log.info("任务号"+wrkMast.getWrkNo()+"盘点/拣料再入库任务下发成功===>>" + staProtocol);
                                } catch (Exception e) {
                                    log.error("盘点再入库失败===>>" + e);
                                    e.printStackTrace();
                                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                                }
                            }
//                                try {
//                                    // 更新站点信息 且 下发plc命令
//                                    staProtocol.setWorkNo(wrkMast.getWrkNo());
//                                    staProtocol.setStaNo(dto.getStaNo());
//                                    devpThread.setPakMk(staProtocol.getSiteId(), false);
////                                    ledThread.errorReset();
//                                    boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
//                                    if (!result) {
//                                        log.error("发布命令至输送线队列失败！！！ [plc编号：{}]", devp.getId());
//                                    }
//                                    log.info("任务号"+wrkMast.getWrkNo()+"盘点/拣料再入库任务下发成功===>>" + staProtocol);
//                                } catch (Exception e) {
//                                    log.error("盘点再入库失败===>>" + e);
//                                    e.printStackTrace();
//                                    TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
//                                }
//                            }
                        } else {
                            log.error("请求接口失败！！！url：{}；request：{}；response：{}", wmsUrl + "/rpc/pakin2/loc/v1", JSON.toJSONString(param), response);
                        }
                    } catch (Exception e) {
                        log.error("stnToCrnStnPick2===>>fail", e);
                        e.printStackTrace();
                        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
//                        e.printStackTrace();
//                        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                    }

//                    // 获取目标站
@@ -862,7 +862,7 @@
                    continue;
                }

                if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isPakMk() && staProtocol.getWorkNo()==0 && !staProtocol.isOutEnable() && staProtocol.isInEnable()) {
                if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isPakMk() && staProtocol.getWorkNo()==0 && !staProtocol.isOutEnable()) {
                    WrkMast wrkMast = wrkMastMapper.selectPakInStep4(staProtocol.getSiteId(),"3");
                    if (wrkMast == null) {
                        WrkMast wrkMast1 = wrkMastMapper.selectPakInStep5(staProtocol.getSiteId(),"3");
@@ -3151,7 +3151,7 @@
    }

    /**
     * 其他  ===>> 码垛完成驱动托盘进入下一步
     * 其他  ===>> 码垛完成驱动托盘进入下一步  2===》3
     */
    public synchronized void stackingCompletionDriveTrayOk2() {
        for (DevpSlave devp : slaveProperties.getDevp()) {
@@ -3167,7 +3167,7 @@
                    staProtocol = staProtocol.clone();
                }

                if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isPakMk()  && staProtocol.getWorkNo()!=0 && staProtocol.isOutEnable()) {//
                if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isPakMk()  && staProtocol.getWorkNo()!=0) {//
                    WrkMast wrkMast = wrkMastMapper.selectPakInStep3(staProtocol.getWorkNo());

                    if (wrkMast == null) {
@@ -3189,17 +3189,17 @@
                            continue;
                        }
                        //任务完成
                        boolean result1 = MessageQueue.offer(SlaveType.Devp, devpThread.getSlave().getId(), new Task(3, staProtocol));
//                        boolean result1 = MessageQueue.offer(SlaveType.Devp, devpThread.getSlave().getId(), new Task(3, staProtocol));
                        wrkMast.setSheetNo("3");
                        wrkMastMapper.updateById(wrkMast);

                        try{
                            Thread.sleep(100);
                        }catch (Exception e){
//                        try{
//                            Thread.sleep(100);
//                        }catch (Exception e){
//
//                        }

                        }

                        boolean result2 = MessageQueue.offer(SlaveType.Devp, devpThread.getSlave().getId(), new Task(4, staProtocol));
//                        boolean result2 = MessageQueue.offer(SlaveType.Devp, devpThread.getSlave().getId(), new Task(4, staProtocol));

                    }
                }
@@ -3484,7 +3484,7 @@
                            log.error("未查到小车执行任务或者执行任务状态不符合！"+wrkMastSta);
                            continue;
                        }
                        WrkMast wrkMast = wrkMastMapper.selectPakInStep3(wrkMastSta.getWrkNo().intValue());
                       /* WrkMast wrkMast = wrkMastMapper.selectPakInStep3(wrkMastSta.getWrkNo().intValue());
                        if (!Cools.isEmpty(wrkMast) && wrkMastSta.getWrkType()!=5){
                            Thread.sleep(200);
                            SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 1);
@@ -3520,7 +3520,7 @@
//                            }catch (Exception e){
//
//                            }
                        }
                        }*/
                        boolean rgvComplete = rgvComplete(rgvProtocol.getRgvNo());
                        if (!rgvComplete){
                            log.error("小车复位失败，小车号{}！",rgvProtocol.getRgvNo());
@@ -3547,7 +3547,7 @@
                            log.error("未查到小车执行任务或者执行任务状态不符合！"+wrkMastSta);
                            continue;
                        }
                        WrkMast wrkMast = wrkMastMapper.selectPakInStep3(wrkMastSta.getWrkNo().intValue());
                        /*WrkMast wrkMast = wrkMastMapper.selectPakInStep3(wrkMastSta.getWrkNo().intValue());
                        if (!Cools.isEmpty(wrkMast)  && wrkMastSta.getWrkType()!=5){
                            Thread.sleep(200);
                            DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 1);
@@ -3578,7 +3578,7 @@
//                            }catch (Exception e){
//
//                            }
                        }
                        }*/
                        boolean rgvComplete = rgvComplete(rgvProtocol.getRgvNo());
                        if (!rgvComplete){
                            log.error("小车复位失败，小车号{}！",rgvProtocol.getRgvNo());

 src/main/java/com/zy/asrs/task/ReportToDismantleTheStackScheduler.java

@@ -18,7 +18,7 @@
    @Autowired
    private ReportToDismantleTheStackHandler reportToDismantleTheStackHandler;

    @Scheduled(cron = "0/3 * * * * ? ")
    @Scheduled(cron = "0/1 * * * * ? ")
    private void execute(){//拆垛信息上传
        int[] staNos =new int[]{118,120,121};
        for (int staNo : staNos){

 src/main/resources/application.yml

@@ -11,6 +11,9 @@
    url: jdbc:sqlserver://192.168.18.4:49977;databasename=srjtasrs
    username: sa
    password: sa@123
#    url: jdbc:sqlserver://192.168.4.191:50948;databasename=srjtasrs
#    username: sa
#    password: sa@123
#    url: jdbc:sqlserver://127.0.0.1:50948;databasename=srjtasrs
#    username: sa
#    password: sa@123
@@ -361,13 +364,13 @@
    emptyInSta2[0]:
      staNo: 118
    # 拆垛叠盘口2
    emptyInSta2[1]:
      staNo: 119
#    emptyInSta2[1]:
#      staNo: 119
    # 拆垛叠盘口3
    emptyInSta2[2]:
    emptyInSta2[1]:
      staNo: 120
    # 拆垛叠盘口4
    emptyInSta2[3]:
    emptyInSta2[2]:
      staNo: 121
    # 出库口1
    outSta[0]:
@@ -375,14 +378,14 @@
    # 拣料入库口1
    pickSta2[0]:
      staNo: 118
#    # 拣料入库口1
#    pickSta2[1]:
#      staNo: 119
    # 拣料入库口1
    pickSta2[1]:
      staNo: 119
    # 拣料入库口1
    pickSta2[2]:
      staNo: 120
    # 拣料入库口1
    pickSta2[3]:
    pickSta2[2]:
      staNo: 121
    # 拣料入库口1
    pickSta[0]:
@@ -411,14 +414,14 @@
    # Rgv入库口1
    inRgvSta[0]:
      staNo: 118
#    # Rgv入库口1
#    inRgvSta[1]:
#      staNo: 119
    # Rgv入库口1
    inRgvSta[1]:
      staNo: 119
    # Rgv入库口1
    inRgvSta[2]:
      staNo: 120
    # Rgv入库口1
    inRgvSta[3]:
    inRgvSta[2]:
      staNo: 121
    # Rgv入库口1
    inRgvSta[4]: