From e7dd8396e19f538e5f51ced927e2f62e1f75fa63 Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期五, 29 三月 2024 10:29:54 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   52 ++++++++++++++++++++++++++++++++++------------------
 1 files changed, 34 insertions(+), 18 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index 6b12b1a..679348b 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -4,6 +4,7 @@
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.core.common.Cools;
+import com.core.common.R;
 import com.core.exception.CoolException;
 import com.zy.asrs.controller.CrnController;
 import com.zy.asrs.controller.OpenController;
@@ -270,6 +271,7 @@
                                     if (staNoCrnNo==0){
                                         basDevp.setStaErr(1);
                                         basDevpService.updateById(basDevp);
+                                        log.error("绔欑偣鍙峰紓甯�"+inSta.getStaNo());
                                         throw new CoolException("绔欑偣鍙峰紓甯�"+inSta.getStaNo());
                                     }else {
                                         LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
@@ -278,6 +280,7 @@
                                         if (Cools.isEmpty(locMast)){
                                             basDevp.setStaErr(1);
                                             basDevpService.updateById(basDevp);
+                                            log.error("绔欑偣鍙峰紓甯�"+inSta.getStaNo());
                                             throw new CoolException("绔欑偣鍙峰紓甯�"+inSta.getStaNo());
                                         }
                                     }
@@ -285,6 +288,7 @@
 //                                    log.error("鎵爜妫�娴嬬▼搴忓紓甯�"+inSta.getStaNo()+"寮傚父淇℃伅"+e);
                                     // 閫�鍥�
                                     log.error("鎵爜妫�娴嬬▼搴忓紓甯�"+inSta.getStaNo()+errMsg);
+                                    log.error("鎵爜妫�娴嬬▼搴忓紓甯�,寮傚父淇℃伅"+e);
 
                                     staProtocol.setWorkNo((short)9999);
                                     staProtocol.setStaNo(inSta.getStaNo().shortValue());
@@ -327,7 +331,7 @@
                                         );
                                     }catch (Exception e){
                                         log.error("wcs娲惧彂搴撲綅涓嶄负绌轰笂鎶ms", getWmsDto.getWrkNo());
-                                        throw new CoolException("wcs娲惧彂鍏ュ簱浠诲姟涓婃姤wms澶辫触");
+                                        throw new CoolException("wcs娲惧彂鍏ュ簱浠诲姟涓婃姤wms澶辫触锛屽紓甯镐俊鎭細"+e);
                                     }
                                 }
 
@@ -386,24 +390,36 @@
             for (CrnSlave.CrnStn crnStn : crnSlave.getCrnOutStn()) {
                 List<StaDesc> staDescs = staDescMapper.selectList(new EntityWrapper<StaDesc>().eq("crn_no", crnSlave.getId()).eq("crn_stn", crnStn.getStaNo()));
                 for (StaDesc staDesc : staDescs){
-                    // 鑾峰彇鍫嗗灈鏈哄嚭搴撶珯淇℃伅
-                    DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, crnStn.getDevpPlcId());
-                    StaProtocol staProtocol = devpThread.getStation().get(crnStn.getStaNo());
-                    if (staProtocol == null) {
-                        continue;
-                    } else {
-                        staProtocol = staProtocol.clone();
-                    }
-                    if (staProtocol.isAutoing() && staProtocol.isLoading() && (staProtocol.getWorkNo() == 0 || staProtocol.getStaNo() == 0)) {
-                        // 鏌ヨ宸ヤ綔妗�
-                        TaskWrk taskWrk = taskWrkMapper.selectCrnStaWorking(crnSlave.getId(), staDesc.getStnNo().toString());
-                        if (taskWrk == null) {
+                    try{
+                        // 鑾峰彇鍫嗗灈鏈哄嚭搴撶珯淇℃伅
+                        DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, crnStn.getDevpPlcId());
+                        StaProtocol staProtocol = devpThread.getStation().get(crnStn.getStaNo());
+                        if (staProtocol == null) {
                             continue;
+                        } else {
+                            staProtocol = staProtocol.clone();
                         }
-                        siteController.siteDetlUpdate(Integer.valueOf(taskWrk.getTargetPoint()),taskWrk.getWrkNo().shortValue(),(short)0,"Y",false,false);
-                        taskWrk.setStatus(5);
-                        taskWrk.setWrkSts(14);
-                        taskWrkService.updateById(taskWrk);
+                        if (staProtocol.isAutoing() && staProtocol.isLoading() && (staProtocol.getWorkNo() == 0 || staProtocol.getStaNo() == 0)) {
+                            // 鏌ヨ宸ヤ綔妗�
+                            TaskWrk taskWrk = taskWrkMapper.selectCrnStaWorking(crnSlave.getId(), staDesc.getStnNo().toString());
+                            if (taskWrk == null) {
+                                continue;
+                            }
+                            log.info("涓嬪彂杈撻�佺嚎浠诲姟锛歵askWrk:"+JSON.toJSONString(taskWrk));
+                            R r = siteController.siteDetlUpdate(Integer.valueOf(taskWrk.getTargetPoint()), taskWrk.getWrkNo().shortValue(), (short) 0, "Y", false, false);
+                            JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(r));
+                            if (jsonObject.getInteger("code").equals(200)){
+                                log.info("涓嬪彂杈撻�佺嚎浠诲姟鎴愬姛锛歵askWrk:"+JSON.toJSONString(taskWrk));
+                                taskWrk.setStatus(5);
+                                taskWrk.setWrkSts(14);
+                                taskWrkService.updateById(taskWrk);
+                            }else {
+                                log.error("涓嬪彂杈撻�佺嚎浠诲姟澶辫触锛歵askWrk:"+JSON.toJSONString(taskWrk));
+                                log.error("涓嬪彂杈撻�佺嚎浠诲姟澶辫触锛氬紓甯镐俊鎭�:"+JSON.toJSONString(r));
+                            }
+                        }
+                    }catch (Exception e){
+                        log.error("鍑哄簱鍒板嚭搴撶珯寮傚父:寮傚父淇℃伅锛�"+e);
                     }
                 }
 
@@ -934,7 +950,7 @@
 
                 crnController.crnTaskComplete(crnOperatorParam);
                 if(!Cools.isEmpty(taskWrk)){
-                    if(taskWrk.getIoType()==1&&taskWrk.getWrkSts()==3){
+                    if(taskWrk.getIoType()==1 && taskWrk.getWrkSts()==3){
                         taskWrk.setWrkSts(4);//鍏ュ簱瀹屾垚
                         taskWrk.setStatus(5);//瀹岀粨
                         //鏇存柊搴撲綅鐘舵��

--
Gitblit v1.9.1