From dadeff7f68d36c6a369c8d2d30cbe210d1be9a6c Mon Sep 17 00:00:00 2001
From: YYC <1833023622@qq.com>
Date: 星期一, 06 十一月 2023 22:06:30 +0800
Subject: [PATCH] 同步入库信息和库存

---
 src/main/java/com/fzzy/push/whhpjl/WhjlApiRemoteService.java |  110 ++++++++++++++++++++++++++++++++++++++++---------------
 1 files changed, 80 insertions(+), 30 deletions(-)

diff --git a/src/main/java/com/fzzy/push/whhpjl/WhjlApiRemoteService.java b/src/main/java/com/fzzy/push/whhpjl/WhjlApiRemoteService.java
index 01e6be7..eef3e64 100644
--- a/src/main/java/com/fzzy/push/whhpjl/WhjlApiRemoteService.java
+++ b/src/main/java/com/fzzy/push/whhpjl/WhjlApiRemoteService.java
@@ -1,6 +1,7 @@
 package com.fzzy.push.whhpjl;
 
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.fzzy.api.data.ApiParam;
 import com.fzzy.api.data.PushProtocol;
 import com.fzzy.api.dto.ResponseDto;
@@ -16,6 +17,7 @@
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.StringUtils;
+import org.codehaus.jackson.map.ObjectMapper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import java.util.*;
@@ -110,14 +112,22 @@
             log.info("韬唤绛惧悕锛�" + accessToken);
             reqData.setAccesstoken(MyMD5Util.encrypt(accessToken));
             //鏁版嵁鎬绘潯鏁�
-            List<Object> list  = (List<Object>)data;
-            reqData.setDatalength(list.size());
+            reqData.setDatalength(1);
             //鏁版嵁涓讳綋锛岃繘琛孲M4鍔犲瘑
             reqData.setData(SM4Util.encryptEcb(conf.getPublicKey(), jsonData));
             //鎽樿锛屾暟鎹富浣撶殑MD5鍊�
             reqData.setDigest(MyMD5Util.encrypt(jsonData));
             //鎿嶄綔绫诲瀷
-            reqData.setOperator("insert");
+            JSONObject jsonObject = JSONObject.parseObject(JSON.toJSONString(data));
+            String czbz = jsonObject.getString("czbz");
+            if("u".equals(czbz)){
+                czbz = "update";
+            }else if("d".equals(czbz)){
+                czbz = "delete";
+            }else {
+                czbz = "insert";
+            }
+            reqData.setOperator(czbz);
 
             WhjlRespDto responseDto = whjl2023HttpClientUtil.postPushData(conf.getApiUrl() + inteId, reqData);
             apiLog.setStatus(responseDto.getCode() == 200 ? 0 : responseDto.getCode());
@@ -160,22 +170,26 @@
             case "1105":
                 return WhjlConstant.API_CODE_CFXX;
             case "1106":
-                return WhjlConstant.API_CODE_AJXX;
+                return WhjlConstant.API_CODE_YGXX;
             case "1107":
-                return WhjlConstant.API_CODE_HWXX;
+                return WhjlConstant.API_CODE_AJXX;
             case "1108":
-                return WhjlConstant.API_CODE_CCSSDZDA;
+                return WhjlConstant.API_CODE_HWXX;
             case "1109":
-                return WhjlConstant.API_CODE_CCSSWHJL;
+                return WhjlConstant.API_CODE_CCSSDZDA;
             case "1110":
-                return WhjlConstant.API_CODE_CCSSBFJL;
+                return WhjlConstant.API_CODE_CCSSWHJL;
             case "1111":
-                return WhjlConstant.API_CODE_CCSBXX;
+                return WhjlConstant.API_CODE_CCSSBFJL;
             case "1112":
-                return WhjlConstant.API_CODE_CCSBWHJL;
+                return WhjlConstant.API_CODE_CCSBXX;
             case "1113":
-                return WhjlConstant.API_CODE_CCSBWXJL;
+                return WhjlConstant.API_CODE_CCSBWHJL;
             case "1114":
+                return WhjlConstant.API_CODE_CCSBWXJL;
+            case "1115":
+                return WhjlConstant.API_CODE_CCSBBFJL;
+            case "11145":
                 return WhjlConstant.API_CODE_CCSBBFJL;
             case "1201":
                 return WhjlConstant.API_CODE_FSGYSXX;
@@ -186,45 +200,81 @@
             case "1204":
                 return WhjlConstant.API_CODE_KHXX;
             case "1205":
-                return WhjlConstant.API_CODE_CCJL;
-            case "1206":
                 return WhjlConstant.API_CODE_DDXX;
-            case "1207":
+            case "1206":
                 return WhjlConstant.API_CODE_HTXX;
-            case "1208":
+            case "1207":
                 return WhjlConstant.API_CODE_KCTZ;
-            case "1209":
+            case "1208":
                 return WhjlConstant.API_CODE_KCTZPCXX;
-            case "1210":
+            case "1209":
                 return WhjlConstant.API_CODE_KCTZCRJL;
-            case "1211":
+            case "1210":
                 return WhjlConstant.API_CODE_KCPDJL;
-            case "1212":
+            case "1211":
                 return WhjlConstant.API_CODE_KNZCJL;
-            case "1213":
+            case "1212":
                 return WhjlConstant.API_CODE_CRKJL;
-            case "1301":
+            case "1213":
+                return WhjlConstant.API_CODE_CRKJSJL;
+            case "1214":
                 return WhjlConstant.API_CODE_ZJJG;
-            case "1302":
+            case "1215":
+                return WhjlConstant.API_CODE_YPDJXX;
+            case "1216":
                 return WhjlConstant.API_CODE_ZJBG;
+            case "1217":
+                return WhjlConstant.API_CODE_BZQYJGZ;
+            case "1218":
+                return WhjlConstant.API_CODE_BZQYJJL;
+            case "1219":
+                return WhjlConstant.API_CODE_WZKCYJGZ;
+            case "1220":
+                return WhjlConstant.API_CODE_WZKCYJJL;
+            case "1301":
+                return WhjlConstant.API_CODE_WSDJCJL;
+            case "1302":
+                return WhjlConstant.API_CODE_YSHJJCJL;
             case "1303":
-                return WhjlConstant.API_CODE_LQJCJL;
+                return WhjlConstant.API_CODE_WSDGJJL;
             case "1304":
                 return WhjlConstant.API_CODE_NHJL;
+            case "1305":
+                return WhjlConstant.API_CODE_DDPSRW;
+            case "1306":
+                return WhjlConstant.API_CODE_BDWZXX;
+            case "1307":
+                return WhjlConstant.API_CODE_YSRWBDXX;
+            case "1308":
+                return WhjlConstant.API_CODE_SPYJGJ;
+            case "1309":
+                return WhjlConstant.API_CODE_STSJ;
             case "1401":
-                return WhjlConstant.API_CODE_DYQY;
+                return WhjlConstant.API_CODE_SCZLL;
             case "1402":
-                return WhjlConstant.API_CODE_DYXY;
+                return WhjlConstant.API_CODE_KGPJ;
             case "1403":
-                return WhjlConstant.API_CODE_DYNL;
+                return WhjlConstant.API_CODE_DYQY;
             case "1404":
-                return WhjlConstant.API_CODE_DYYJ;
+                return WhjlConstant.API_CODE_DYSP;
             case "1405":
-                return WhjlConstant.API_CODE_SCJGDD;
+                return WhjlConstant.API_CODE_DYXY;
             case "1406":
-                return WhjlConstant.API_CODE_YSLX;
+                return WhjlConstant.API_CODE_DYXYBG;
             case "1407":
-                return WhjlConstant.API_CODE_YJDD;
+                return WhjlConstant.API_CODE_DYXYZXMX;
+            case "1408":
+                return WhjlConstant.API_CODE_DYNL;
+            case "1409":
+                return WhjlConstant.API_CODE_DYYJ;
+            case "1410":
+                return WhjlConstant.API_CODE_SCJGDD;
+            case "1411":
+                return WhjlConstant.API_CODE_CLXX;
+            case "1412":
+                return WhjlConstant.API_CODE_CLYSHJ;
+            case "1413":
+                return WhjlConstant.API_CODE_YSLX;
             default:
                 return inteId;
         }

--
Gitblit v1.9.3