From 62b68627fc86bbc0705f3c14d19e18b7eacc0059 Mon Sep 17 00:00:00 2001
From: 野心家 <1051256694@qq.com>
Date: 星期六, 24 五月 2025 18:17:36 +0800
Subject: [PATCH] 初始化

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |  127 +++++++++++++++++++++++++----------------
 1 files changed, 77 insertions(+), 50 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 90d7515..540bbb8 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -115,17 +115,24 @@
                     // 鑾峰彇鍏ュ簱绔欎俊鎭�
                     DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
                     StaProtocol staProtocol = devpThread.getStation().get(inSta.getStaNo());
-                    if (staProtocol == null) {
+                    if (staProtocol == null || !staProtocol.isLoading()) {
                         continue;
                     } else {
                         staProtocol = staProtocol.clone();
                     }
                     Integer workNo = staProtocol.getWorkNo();
+                    if (workNo!=9998 && workNo!=9997){
+                        continue;
+                    }
                     Integer stano = staProtocol.getStaNo();
 
                     // 灏哄妫�娴嬪紓甯�
                     boolean back = false;
                     String errMsg = "";
+                    if (staProtocol.getGrossWt()>=600){
+                        errMsg = "瓒呴噸";
+                        back = true;
+                    }
                     if (staProtocol.isFrontErr()) {
                         errMsg = "鍓嶈秴闄�";
                         back = true;
@@ -165,8 +172,9 @@
                         if (!staProtocol.isPakMk()) {
                             continue;
                         }
+                        System.out.println("鎵爜鍏ュ簱澶辫触锛寋"+inSta.getStaNo()+"}鍏ュ簱绔欏洜{"+errMsg+"}寮傚父锛屾墭鐩樺凡琚��鍥�");
 //                        News.warn("鎵爜鍏ュ簱澶辫触锛寋}鍏ュ簱绔欏洜{}寮傚父锛屾墭鐩樺凡琚��鍥�", inSta.getStaNo(), errMsg);
-                        staProtocol.setWorkNo(workNo);
+                        staProtocol.setWorkNo(9999);
                         staProtocol.setStaNo(inSta.getBackSta());
                         devpThread.setPakMk(staProtocol.getSiteId(), false);
                         MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
@@ -181,7 +189,7 @@
                     // 鍒ゆ柇鏄惁婊¤冻鍏ュ簱鏉′欢
                     if (staProtocol.isAutoing() && staProtocol.isLoading()
                             && staProtocol.isInEnable()
-                            && !staProtocol.isEmptyMk() && (workNo == 0 || (workNo>9000 && workNo<10000))
+                            && (workNo == 9998 || workNo == 9997)
                             && staProtocol.isPakMk()
                             && staProtocol.isPakMkWalk()
                     ) {
@@ -191,9 +199,10 @@
                             continue;
                         }
                         String barcode = barcodeThread.getBarcode();
-                        if (!Cools.isEmpty(barcode) && !barcode.equals("99999999")) {
+                        if (!Cools.isEmpty(barcode) && !barcode.equals("99999999") && !barcode.equals("000000")) {
                             // 璇锋眰wms鎺ュ彛锛岃幏鍙栧伐浣滃彿鍜岀洰鏍囧簱浣�
-                            ToWmsDTO toWmsDTO = new ToWmsDTO(staProtocol.getSiteId(),staProtocol.getGrossWt(),barcode, 0);
+                            ToWmsDTO toWmsDTO = new ToWmsDTO(staProtocol.getSiteId(),staProtocol.getGrossWt(),barcode, workNo == 9998? 0 : 1);
+
                             TaskWrk taskWrk1 = taskWrkService.selectOne(new EntityWrapper<TaskWrk>().eq("barcode", barcode));
                             if (!Cools.isEmpty(taskWrk1)) {
                                 log.info("鎵樼洏鐮侊細" + barcode + "浠诲姟妗e瓨鍦�");
@@ -207,6 +216,7 @@
                                     } else {
                                         staProtocol.setWorkNo(taskWrk1.getWrkNo());
                                         staProtocol.setStaNo(staProtocol.getSiteId());
+                                        devpThread.setPakMkWalk(staProtocol.getSiteId(), false);
                                         MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                                     }
                                 }
@@ -241,6 +251,7 @@
                                 staProtocol.setWorkNo(9999);
                                 staProtocol.setStaNo(inSta.getBackSta());
                                 devpThread.setPakMk(staProtocol.getSiteId(), false);
+                                devpThread.setPakMkWalk(staProtocol.getSiteId(), false);
                                 MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
                                 continue;
                             }
@@ -256,7 +267,7 @@
                             );
                             log.info("鍏ュ簱璇锋眰鍙傛暟{}" + JSON.toJSONString(toWmsDTO));
                             log.info("鍏ュ簱璇锋眰杩斿洖鍙傛暟{}" + JSON.toJSONString(response));
-                            if (jsonObject.getInteger("code").equals(200)) {
+                            if (!Cools.isEmpty(jsonObject.getInteger("code")) && jsonObject.getInteger("code").equals(200)) {
                                 try {
                                     devpThread.setPakMk(staProtocol.getSiteId(), false);
                                 } catch (Exception e) {
@@ -306,12 +317,15 @@
                     // 鑾峰彇鍏ュ簱绔欎俊鎭�
                     DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
                     StaProtocol staProtocol = devpThread.getStation().get(inSta.getStaNo());
-                    if (staProtocol == null) {
+                    if (staProtocol == null || !staProtocol.isLoading()) {
                         continue;
                     } else {
                         staProtocol = staProtocol.clone();
                     }
                     Integer workNo = staProtocol.getWorkNo();
+                    if (workNo!=9997){
+                        continue;
+                    }
                     Integer stano = staProtocol.getStaNo();
 
                     // 灏哄妫�娴嬪紓甯�
@@ -352,8 +366,9 @@
                         if (!staProtocol.isPakMk()) {
                             continue;
                         }
+                        System.out.println("鎵爜鍏ュ簱澶辫触锛寋"+inSta.getStaNo()+"}鍏ュ簱绔欏洜{"+errMsg+"}寮傚父锛屾墭鐩樺凡琚��鍥�");
 //                        News.warn("鎵爜鍏ュ簱澶辫触锛寋}鍏ュ簱绔欏洜{}寮傚父锛屾墭鐩樺凡琚��鍥�", inSta.getStaNo(), errMsg);
-                        staProtocol.setWorkNo(workNo);
+                        staProtocol.setWorkNo(9999);
                         staProtocol.setStaNo(inSta.getStaNo());
                         devpThread.setPakMk(staProtocol.getSiteId(), false);
                         MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
@@ -368,13 +383,25 @@
                     // 鍒ゆ柇鏄惁婊¤冻鍏ュ簱鏉′欢
                     if (staProtocol.isAutoing() && staProtocol.isLoading()
                             && staProtocol.isInEnable()
-                            && staProtocol.isEmptyMk() && (workNo == 0 || (workNo>9000 && workNo<10000))
+                            && (workNo == 9997)
                             && staProtocol.isPakMk()
                             && staProtocol.isPakMkWalk()
                     ) {
+                        // 鑾峰彇鏉$爜鎵弿浠俊鎭�
+                        BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, inSta.getBarcode());
+                        if (barcodeThread == null) {
+                            continue;
+                        }
+                        String barcode = barcodeThread.getBarcode();
+                        if (Cools.isEmpty(barcode) || barcode.equals("0")  || barcode.equals("000000")) {
+                            staProtocol.setWorkNo(9999);
+                            staProtocol.setStaNo(inSta.getBackSta());
+                            devpThread.setPakMk(staProtocol.getSiteId(), false);
+                            MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(2, staProtocol));
+                            continue;
+                        }
                         // 璇锋眰wms鎺ュ彛锛岃幏鍙栧伐浣滃彿鍜岀洰鏍囧簱浣�
-                        ToWmsDTO toWmsDTO = new ToWmsDTO("", staProtocol.getSiteId(), 1);
-
+                        ToWmsDTO toWmsDTO = new ToWmsDTO(staProtocol.getSiteId(),staProtocol.getGrossWt(),barcode, 1);
                         HashMap<String, Object> headParam = new HashMap<>();
                         headParam.put("Content-Type", "application/json");
                         String response;
@@ -419,7 +446,7 @@
                         );
                         log.info("鍏ュ簱璇锋眰鍙傛暟{}" + JSON.toJSONString(toWmsDTO));
                         log.info("鍏ュ簱璇锋眰杩斿洖鍙傛暟{}" + JSON.toJSONString(response));
-                        if (jsonObject.getInteger("code").equals(200)) {
+                        if (!Cools.isEmpty(jsonObject.getInteger("code")) && jsonObject.getInteger("code").equals(200)) {
                             try {
                                 devpThread.setPakMk(staProtocol.getSiteId(), false);
                             } catch (Exception e) {
@@ -780,7 +807,7 @@
 //                    //寮�濮嬭繍琛�
 //                    String response = CrnStartRunning(taskWrk);
 //                    JSONObject jsonObject = JSON.parseObject(response);
-//                    if (jsonObject.getInteger("code").equals(200)) {
+//                    if (!Cools.isEmpty(jsonObject.getInteger("code")) && jsonObject.getInteger("code").equals(200)) {
 //
 //                    }else {
 //                        log.error("鍏ュ簱寮�濮嬭繍琛岄�氳澶辫触,"+jsonObject.get("msg"));
@@ -1161,43 +1188,43 @@
                     taskWrkService.updateById(taskWrk);
 
 
-                    try {
-                        HashMap<String, Object> headParam = new HashMap<>();
-                        headParam.put("taskNo",taskWrk.getTaskNo());
-                        headParam.put("taskStatus",taskWrk.getStatusWms());
-                        headParam.put("ioType",taskWrk.getIoTypeWms());
-                        headParam.put("barCode",taskWrk.getBarcode());
-                        headParam.put("reportTime", LocalDateTime.now());
-                        headParam.put("weight",taskWrk.getScWeight().doubleValue());
-
-                        String response;
-                        log.error("wcs瀹岀粨浠诲姟涓婃姤wms==銆�", headParam);
-
-                        response = new HttpHandler.Builder()
-                                // .setHeaders(headParam)
-                                .setUri(wmsUrl)
-                                .setPath(taskStatusFeedbackPath)
-                                .setJson(JSON.toJSONString(headParam))
-                                .build()
-                                .doPost();
-                        log.error("wcs瀹岀粨浠诲姟涓婃姤wms==銆�", response);
-
-//                        JSONObject jsonObject = JSON.parseObject(response);
-//                        log.error("wcs瀹岀粨浠诲姟涓婃姤wms==銆�", jsonObject);
-
-                        apiLogService.save("wcs娲惧彂鍏ュ簱浠诲姟涓婃姤wms"
-                                , wmsUrl + taskStatusFeedbackPath
-                                , null
-                                , "127.0.0.1"
-                                , JSON.toJSONString(headParam)
-                                , response
-                                , true
-                        );
-                    } catch (Exception e) {
-                        log.error("wcs瀹岀粨浠诲姟涓婃姤wms澶辫触", taskWrk);
-                        log.error("wcs瀹岀粨浠诲姟涓婃姤wms澶辫触,鎶ラ敊淇℃伅锛�", e);
-//                        throw new CoolException("wcs娲惧彂鍏ュ簱浠诲姟涓婃姤wms澶辫触");
-                    }
+//                    try {
+//                        HashMap<String, Object> headParam = new HashMap<>();
+//                        headParam.put("taskNo",taskWrk.getTaskNo());
+//                        headParam.put("taskStatus",taskWrk.getStatusWms());
+//                        headParam.put("ioType",taskWrk.getIoTypeWms());
+//                        headParam.put("barCode",taskWrk.getBarcode());
+//                        headParam.put("reportTime", LocalDateTime.now());
+//                        headParam.put("weight",taskWrk.getScWeight().doubleValue());
+//
+//                        String response;
+//                        log.error("wcs瀹岀粨浠诲姟涓婃姤wms==銆�", headParam);
+//
+//                        response = new HttpHandler.Builder()
+//                                // .setHeaders(headParam)
+//                                .setUri(wmsUrl)
+//                                .setPath(taskStatusFeedbackPath)
+//                                .setJson(JSON.toJSONString(headParam))
+//                                .build()
+//                                .doPost();
+//                        log.error("wcs瀹岀粨浠诲姟涓婃姤wms==銆�", response);
+//
+////                        JSONObject jsonObject = JSON.parseObject(response);
+////                        log.error("wcs瀹岀粨浠诲姟涓婃姤wms==銆�", jsonObject);
+//
+//                        apiLogService.save("wcs娲惧彂鍏ュ簱浠诲姟涓婃姤wms"
+//                                , wmsUrl + taskStatusFeedbackPath
+//                                , null
+//                                , "127.0.0.1"
+//                                , JSON.toJSONString(headParam)
+//                                , response
+//                                , true
+//                        );
+//                    } catch (Exception e) {
+//                        log.error("wcs瀹岀粨浠诲姟涓婃姤wms澶辫触", taskWrk);
+//                        log.error("wcs瀹岀粨浠诲姟涓婃姤wms澶辫触,鎶ラ敊淇℃伅锛�", e);
+////                        throw new CoolException("wcs娲惧彂鍏ュ簱浠诲姟涓婃姤wms澶辫触");
+//                    }
                 }
 
             }

--
Gitblit v1.9.1