From f6141eae93a6b4e82595859a7013cd7f8f8e45b6 Mon Sep 17 00:00:00 2001
From: 18516761980 <tqsxp@163.com>
Date: 星期六, 08 十月 2022 14:38:19 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java |   92 ++++++++++++++++++++++++----------------------
 1 files changed, 48 insertions(+), 44 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
index 7ef3992..9d3cea4 100644
--- a/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MobileServiceImpl.java
@@ -86,12 +86,17 @@
 
     @Value("${mes.url}")
     private String mesUrl;
+    @Value("${ren.url}")
+    private String renUrl;
 
-    @Value("${mes.startUpTestPACK}")
+    @Value("${ren.startUpTestPACK}")
     private String startUpTestPACK;
 
-    @Value("${mes.startUpTestPACK}")
+    @Value("${ren.startUpTestPACK}")
     private String suspendTestPACK;
+
+    @Value("${mes.inPath}")
+    private String inpath;
 
 
 
@@ -210,10 +215,10 @@
     @Override
     public void onSale(CombParam param) {
         // 鑾峰彇搴撲綅鍙�
-        String locno = param.getLocno();
-        Node node = nodeService.selectByUuid(locno);
+        String locNo = param.getLocNo();
+        Node node = nodeService.selectByUuid(locNo);
         if (Cools.isEmpty(node)) {
-            throw new CoolException(param.getLocno() + ":搴撲綅涓嶅瓨鍦�");
+            throw new CoolException(param.getLocNo() + ":搴撲綅涓嶅瓨鍦�");
         }
 
         // 鑾峰彇鍟嗗搧鍒楄〃
@@ -229,7 +234,7 @@
                 throw new CoolException(combMat.getMatnr() + ":鍟嗗搧鎵瑰彿鏈夎锛�");
             }
             ManLocDetl manLocDetl = new ManLocDetl();
-            manLocDetl.setLocNo(locno);
+            manLocDetl.setLocNo(locNo);
             manLocDetl.setNodeId(node.getId());
             manLocDetl.setMatnr(combMat.getMatnr());
             manLocDetl.setBatch(combMat.getBatch());
@@ -618,26 +623,38 @@
     @Transactional
     public void startUpTestPACK(TestMast testMast) {
 
-        //鍚姩娴嬭瘯璇锋眰
-//        ReturnT<String> result=startUpTestPACK1(testMast);
-//        if (!result.isSuccess()) {
-//            log.error("娴嬭瘯鐢宠澶辫触", testMast.getBarcode());
-//            throw new CoolException("娴嬭瘯鐢宠澶辫触");
-//        }
-        LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", testMast.getLocNo()));
+        LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
+                .eq("loc_no", testMast.getLocNo())
+        );
         if (Cools.isEmpty(locMast)) {
             throw new CoolException(BaseRes.PARAM);
         }
-
         Date now = new Date();
         testMast.setStatus(1);
+        testMast.setChannel(locMast.getChannel());
         testMast.setModiTime(now);
         testMast.setAppeTime(now);
+
+//        鍚姩娴嬭瘯璇锋眰
+        ReturnT<String> result=startUpTestPACK1(testMast);
+        if (!result.isSuccess()) {
+            log.error("娴嬭瘯鐢宠澶辫触", testMast.getBarcode());
+            throw new CoolException("娴嬭瘯鐢宠澶辫触");
+        }
+
         if (!testMastService.insert(testMast)){
             throw new CoolException("娣诲姞testMast澶辫触");
         }
         locMast.setPackStatus(1);
         locMast.setModiTime(now);
+
+        CombParam combParam = new CombParam();
+        combParam.setPackNo(locMast.getBarcode());
+        combParam.setLocNo(locMast.getLocNo());
+        combParam.setPackSts(1);
+        combParam.setRequestTime(DateUtils.convert(new Date()));
+        postMesData(mesUrl,inpath,combParam);
+
         if (!locMastService.update(locMast,new EntityWrapper<LocMast>().eq("loc_no", testMast.getLocNo()))){
             throw new CoolException("鐢宠娴嬭瘯澶辫触");
         }
@@ -653,12 +670,12 @@
     @Transactional
     public ReturnT<String> startUpTestPACK1(TestMast testMast){
         try {
-            CombParam combParam = new CombParam();
-            combParam.setPackNo(testMast.getLocNo());
-            combParam.setPackName(testMast.getUserId());
-            combParam.setLocno(testMast.getBarcode());
-            combParam.setRequestTime(DateUtils.convert(new Date()));
-            return postMesData(startUpTestPACK,combParam);
+            Review review=new Review();
+            review.setLocNo(testMast.getLocNo());
+            review.setUserId(testMast.getUserId());
+            review.setBarcode(testMast.getBarcode());
+            review.setRequestTime(DateUtils.convert(new Date()));
+            return postMesData(renUrl,startUpTestPACK,review);
         }catch (Exception e) {
             log.error("fail", e);
             e.printStackTrace();
@@ -672,7 +689,7 @@
             Review review=new Review();
             review.setPause(true);
             review.setRequestTime(DateUtils.convert(new Date()));
-            return postMesData(suspendTestPACK,review);
+            return postMesData(renUrl,suspendTestPACK,review);
         }catch (Exception e) {
             log.error("fail", e);
             e.printStackTrace();
@@ -681,16 +698,17 @@
         }
     }
 
-    private ReturnT<String> postMesData(String mesPath,Object combParam){
+    private ReturnT<String> postMesData(String URL,String Path,Object combParam){
         if(combParam != null){
             String response = "";
             boolean success = false;
             try {
-                Map<String, Object> map = new HashMap<>();
-                map.put("appkey","ea1f0459efc02a79f046f982767939ae");
-                response = new HttpHandler.Builder().setHeaders(map)
-                        .setUri(mesUrl)
-                        .setPath(mesPath)
+//                Map<String, Object> map = new HashMap<>();
+//                map.put("appkey","ea1f0459efc02a79f046f982767939ae");
+                response = new HttpHandler.Builder()
+//                        .setHeaders(map)
+                        .setUri(URL)
+                        .setPath(Path)
                         .setJson(JSON.toJSONString(combParam))
                         .build()
                         .doPost();
@@ -701,11 +719,11 @@
                     }else if (jsonObject.getDate("isComplete").equals(false)){
                         success = false;
                     }else {
-                        log.error("杩斿洖鍊煎嚭閿�!!!url锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PAKIN_URL, JSON.toJSONString(combParam), response);
+                        log.error("杩斿洖鍊煎嚭閿�!!!url锛歿}锛況equest锛歿}锛況esponse锛歿}", URL+Path, JSON.toJSONString(combParam), response);
                         throw new CoolException("杩斿洖鍊煎嚭閿�");
                     }
                 } else {
-                    log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.URL+MesConstant.PAKIN_URL, JSON.toJSONString(combParam), response);
+                    log.error("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", URL+Path, JSON.toJSONString(combParam), response);
                     throw new CoolException("涓婃姤mes绯荤粺澶辫触");
                 }
             } catch (Exception e) {
@@ -717,7 +735,7 @@
                     // 淇濆瓨鎺ュ彛鏃ュ織
                     apiLogService.save(
                             "鎴愬搧搴撳叆搴撲笂鎶�",
-                            MesConstant.URL + MesConstant.PAKIN_URL,
+                            URL + Path,
                             null,
                             "127.0.0.1",
                             JSON.toJSONString(combParam),
@@ -728,20 +746,6 @@
             }
         }
         return SUCCESS;
-    }
-    @Transactional
-    public void transplant(Review review){
-        //绉诲簱寮�濮嬶紝鏌ヨ鐩爣搴撲綅
-        LocMast targetLocNo = locMastService.selectOne(new EntityWrapper<LocMast>()
-                .eq("row1",2)
-                .eq("loc_sts","O")
-                .eq("fire_status", 0)
-                .eq("pack_status",0));
-        if (targetLocNo != null){
-            workService.locMove(review.getLocNo(),targetLocNo.getLocNo(),(long)Integer.parseInt(review.getUserId()));
-        }else {
-            throw new CoolException("娌℃湁绌哄簱浣�");
-        }
     }
     /*...........................璧e窞鏂板..............浠ヤ笂.............璧e窞鏂板...........................*/
 }

--
Gitblit v1.9.1