#

lsh

2024-07-18 0cb4a12a3e344e0729cf9637d68937476e398e10

#

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

@@ -3737,6 +3737,40 @@
                } else {
                    staProtocol = staProtocol.clone();
                }
                if (emptyInSta.getStaNo()==607 && staProtocol.getStaNo()==607 && staProtocol.getWorkNo()>20000){
                    try {
                        LocTypeDto locTypeDto = new LocTypeDto(staProtocol);

                        SearchLocParam param = new SearchLocParam();
                        param.setIoType(10);
                        param.setSourceStaNo(emptyInSta.getStaNo());
                        param.setLocType1(locTypeDto.getLocType1());
                        String response = new HttpHandler.Builder()
                                .setUri(wmsUrl)
                                .setPath("/rpc/pakin/loc/v1")
                                .setJson(JSON.toJSONString(param))
                                .build()
                                .doPost();
                        JSONObject jsonObject = JSON.parseObject(response);
                        if (jsonObject.getInteger("code").equals(200)) {
                            StartupDto dto = jsonObject.getObject("data", StartupDto.class);

                            // 更新站点信息 且 下发plc命令
                            staProtocol.setWorkNo(dto.getWorkNo());
                            staProtocol.setStaNo(607);
                            devpThread.setPakMk(staProtocol.getSiteId(), false);
                            boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(5, staProtocol));
                            if (!result) {
                                throw new CoolException("更新plc站点信息失败");
                            }
                        } else {
                            log.error("请求接口失败！！！url：{}；request：{}；response：{}", wmsUrl + "/rpc/pakin/loc/v1", JSON.toJSONString(param), response);
                        }
                    } catch (Exception e) {
                        e.printStackTrace();
                        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                    }
                }

                // 站点条件判断
                if (staProtocol.isAutoing() && staProtocol.isLoading() && staProtocol.isInEnable()
@@ -8024,10 +8058,12 @@
        if (staNo1!=0){
            SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, 2);
            StaProtocol staProtocol607 = devpThread.getStation().get(607);
            if (staProtocol607.getWorkNo()<9001){
            staProtocol607.setStaNo(staNo1);
            boolean result2 = MessageQueue.offer(SlaveType.Devp, 2, new Task(5, staProtocol607));
        }
    }
    }
    public synchronized Integer jarGetStartStaNo(Integer staNo) {
        try {
            int[] jarNos=new int[]{1,2,3,4};//(607分配硫化罐)

 src/main/java/com/zy/core/MainProcess.java

@@ -69,7 +69,6 @@
                    mainService.generateStoreWrkFileSingle(); // 组托  双工位单伸   小料箱
                    mainService.generateStoreWrkFileLarge(); // 组托  双工位单伸   大料箱
//                    mainService.generateStoreWrkFile0(); // WMS入库
                    mainService.stackingCompletionDriveTray();//分配硫化罐

                    // 出库  ===>>  堆垛机出库站到出库站
                    mainService.crnStnToOutStn();
@@ -104,6 +103,8 @@
                    mainService.ledReset();

                    /************************************JAR调度************************************/
                    mainService.stackingCompletionDriveTray();//分配硫化罐

                    //Jar充电任务完成
                    mainService.jarChargeComplete();
                    //JarWrkMastExecute任务完成

 src/main/resources/application.yml

@@ -300,6 +300,9 @@
    # 空板入库口1(临时)
    emptyInSta[2]:
      staNo: 536
    # 空板入库口1(临时)
    emptyInSta[3]:
      staNo: 607
    # 入库口1
    inSta[0]:
      staNo: 460