From 7a3227174bde55918aef6f411489d0dd24c3b129 Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期六, 21 十二月 2024 14:09:46 +0800
Subject: [PATCH] 工作历史档可搜索返修品

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |  123 ++++++++++++++++++++++++++++++++++++----
 1 files changed, 109 insertions(+), 14 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
index 35514a2..9114323 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -1,5 +1,6 @@
 package com.zy.asrs.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.baomidou.mybatisplus.mapper.Wrapper;
@@ -1243,6 +1244,7 @@
         // 鐢熸垚宸ヤ綔妗�
         WrkMast wrkMast = new WrkMast();
         wrkMast.setWrkNo(workNo);
+        wrkMast.setWhsType(iotype == 1 && param.getPalletizingNo() == 2051 ? 1 : 0); // 杩斾慨鍏ュ簱鏍囪
         wrkMast.setIoTime(new Date());
         wrkMast.setWrkSts(1L); // 宸ヤ綔鐘舵�侊細璁惧涓婅蛋
         wrkMast.setIoType(iotype); // 鍏ュ嚭搴撶姸鎬侊細1.鍏ュ簱
@@ -1305,14 +1307,14 @@
                     }
 
                     // 鐗╂枡琛ㄥ浠戒竴浠�
-                    Mat mat = new Mat();
-                    mat.sync(wrkDetl);
-                    mat.setTagId(6L);
-                    mat.setCreateTime(now);
-                    mat.setUpdateTime(now);
-                    if (!matService.insert(mat)) {
-                        throw new CoolException("澶囦唤鐗╂枡琛ㄥけ璐�");
-                    }
+//                    Mat mat = new Mat();
+//                    mat.sync(wrkDetl);
+//                    mat.setTagId(6L);
+//                    mat.setCreateTime(now);
+//                    mat.setUpdateTime(now);
+//                    if (!matService.insert(mat)) {
+//                        throw new CoolException("澶囦唤鐗╂枡琛ㄥけ璐�");
+//                    }
 
                 });
             }
@@ -1372,6 +1374,9 @@
         }
 
         DocType docType = docTypeService.selectOrAdd(param.getOrderType(), Boolean.FALSE);
+        if (docType == null) {
+            return R.parse("鍗曟嵁绫诲瀷涓嶅瓨鍦紝璇锋鏌ワ細" + param.getOrderType());
+        }
         Date now = new Date();
 
         // 鍗曟嵁涓绘。
@@ -1483,7 +1488,97 @@
             wrkMastService.updateById(wrkMast);
         }
 
+        // 鍑哄簱涓婃姤鎺ㄩ�乵es璁板綍
+        ckjgsbPushMes(wrkMast,wrkDetls);
+
         return "鍑哄簱缁撴灉涓婃姤鎴愬姛";
+    }
+
+    private void ckjgsbPushMes(WrkMast wrkMast, List<WrkDetl> wrkDetls) {
+        GwmsGenerateInventoryDto gwmsGenerateInventoryDto = new GwmsGenerateInventoryDto();
+        gwmsGenerateInventoryDto.setBarcode(wrkMast.getBarcode());
+        gwmsGenerateInventoryDto.setPalletizingNo(wrkMast.getStaNo());
+        List<GwmsGenerateInventoryDto.MatList> matLists = new ArrayList<>();
+        for (WrkDetl wrkDetl:wrkDetls) {
+            boolean flag = true;
+            for (GwmsGenerateInventoryDto.MatList matList : matLists) {
+                if (matList.getPackageGroupNo().equals(wrkDetl.getBrand())) {
+                    matList.getRolls().add(new GwmsGenerateInventoryDto.Rolls(wrkDetl.getModel(),
+                                    wrkDetl.getUnit(),wrkDetl.getMaktx(),wrkDetl.getLength(),
+                                    Integer.parseInt(wrkDetl.getSpecs()),wrkDetl.getWeight(),wrkDetl.getVolume(),
+                                    wrkDetl.getManuDate()));
+                    flag = false;
+                    break;
+                }
+            }
+            if (flag) {
+                GwmsGenerateInventoryDto.MatList matList = new GwmsGenerateInventoryDto.MatList();
+                matList.setBoxPos(wrkDetl.getOrigin());
+                matList.setPackageGroupNo(wrkDetl.getBrand());
+                matList.setOutOrIn("out");
+                matList.setStockType(wrkMast.getStaNo() == 2041 ? "杩斾慨鍑哄簱" : "鎴愬搧鍑哄簱");
+                matList.setBoxType(wrkDetl.getColor());
+                matList.setRollType(wrkDetl.getManu());
+                matList.setWideInWidth(wrkDetl.getSku());
+                matList.setThickness(wrkDetl.getItemNum());
+                List<GwmsGenerateInventoryDto.Rolls> rollsList = new ArrayList<>();
+                GwmsGenerateInventoryDto.Rolls roll = new GwmsGenerateInventoryDto.Rolls(wrkDetl.getModel(),
+                        wrkDetl.getUnit(),wrkDetl.getMaktx(),wrkDetl.getLength(),
+                        Integer.parseInt(wrkDetl.getSpecs()),wrkDetl.getWeight(),wrkDetl.getVolume(),
+                        wrkDetl.getManuDate());
+                rollsList.add(roll);
+                matList.setRolls(rollsList);
+                matLists.add(matList);
+            }
+        }
+       gwmsGenerateInventoryDto.setMatList(matLists);
+
+
+
+        boolean success = false;
+        // 鑾峰彇璇锋眰澶�
+        Map<String,Object> headers = new HashMap<>();
+        headers.put("Content-Type","application/json;charset=UTF-8");
+
+        // 鏋勯�犺姹備綋
+        String body = JSON.toJSONString(gwmsGenerateInventoryDto);
+        String response = "";
+        try {
+            response = new HttpHandler.Builder()
+                    .setUri(MesConstant.MES_CC_IP_PORT)
+                    .setPath(MesConstant.MES_CC_FXRK_URL)
+                    .setHeaders(headers)
+                    .setJson(body)
+                    .build()
+                    .doPost();
+            if (!Cools.isEmpty(response)) {
+                JSONObject jsonObject1 = JSONObject.parseObject(response);
+                int code = (int) jsonObject1.get("code");
+                boolean state  = jsonObject1.getBoolean("state");
+                if (code == 200 && state) {
+                    success = true;
+                }
+            } else {
+                log.error("鍑哄簱涓婃姤鎺ㄩ�乵es璁板綍澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.MES_CC_IP_PORT + MesConstant.MES_CC_FXRK_URL, body, response);
+            }
+        } catch (Exception e) {
+            log.error("鍑哄簱涓婃姤鎺ㄩ�乵es璁板綍寮傚父锛歿}", e.getMessage());
+        } finally {
+            try {
+                // 淇濆瓨鎺ュ彛鏃ュ織
+                apiLogService.save(
+                        "鍑哄簱涓婃姤鎺ㄩ�乵es璁板綍",
+                        MesConstant.MES_CC_IP_PORT + MesConstant.MES_CC_FXRK_URL,
+                        null,
+                        "127.0.0.1",
+                        body,
+                        response,
+                        success
+                );
+            } catch (Exception e) {
+                log.error("", e);
+            }
+        }
     }
 
     @Autowired
@@ -1694,14 +1789,14 @@
             wrkMast.setWrkSts(52L); // 宸ヤ綔鐘舵��42->52.璁惧涓婅蛋锛堟媶鍨涘畬鎴愶級
             wrkMast.setSourceStaNo(param.getSourceStaNo());
             wrkMast.setStaNo(oneFloorIn[wrkMast.getCrnNo()]);
+            // 婧愬簱浣�
+            LocMast staLocMast = locMastService.selectById(wrkMast.getSourceLocNo());
             // 鐩爣搴撲綅=婧愬簱浣�
             wrkMast.setLocNo(wrkMast.getSourceLocNo());
             // 婧愬簱浣嶆竻闄�
             wrkMast.setSourceLocNo("");
             wrkMast.setModiTime(new Date());
 
-            // 鏇存柊搴撲綅鐘舵��
-            LocMast staLocMast = locMastService.selectById(wrkMast.getSourceLocNo());
             // 鏇存柊鏂板簱浣嶇姸鎬� Q
             staLocMast.setLocSts("Q");
             staLocMast.setModiTime(new Date());
@@ -1726,7 +1821,7 @@
     @Override
     public R kxlhCdwc(KxlhcdwcParam param) {
 
-        if (Cools.isEmpty(param.getWorkNo(),param.getSourceStaNo(),param.getSite())) {
+        if (Cools.isEmpty(param.getWorkNo(),param.getSourceStaNo(),param.getSite(),param.getBarcode())) {
             return R.parse("鍙傛暟涓嶈兘涓虹┖锛岃妫�鏌ュ叆鍙�");
         }
         WrkMast wrkMast = wrkMastService.selectById(param.getWorkNo());
@@ -1831,7 +1926,7 @@
             zphjcdwcVo.setWorkNo(wrkMast1.getWrkNo());
             zphjcdwcVo.setStaNo(wrkMast1.getStaNo());
             zphjcdwcVo.setSourceStaNo(site);
-            zphjcdwcVo.setBarcode(site == 3046 ? "T1046" : "T1042");
+            zphjcdwcVo.setBarcode(param.getBarcode());
             zphjcdwcVos.add(zphjcdwcVo);
         }
 
@@ -1934,7 +2029,7 @@
         try {
             response = new HttpHandler.Builder()
                     .setUri(MesConstant.GWCS_IP_PORT)
-                    .setPath(MesConstant.GWCS_IP_PORT)
+                    .setPath(MesConstant.GWCS_FPKW_URL)
                     .setHeaders(headers)
                     .setJson(body)
                     .build()
@@ -1942,7 +2037,7 @@
             if (!Cools.isEmpty(response)) {
                 success = true;
             } else {
-                log.error(message + "澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.GWCS_IP_PORT + MesConstant.GWCS_IP_PORT, body, response);
+                log.error(message + "澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", MesConstant.GWCS_IP_PORT + MesConstant.GWCS_FPKW_URL, body, response);
             }
         } catch (Exception e) {
             log.error(message + "寮傚父锛歿}", e);

--
Gitblit v1.9.1