From 83e0034ab5f729afeb2c25e328d63fda31ff01e1 Mon Sep 17 00:00:00 2001
From: dbs <email0099@163.com>
Date: 星期四, 12 十二月 2024 15:45:57 +0800
Subject: [PATCH] 新增MES处理,分发系统名字特定---》MES系统

---
 src/main/java/com/itstyle/mdm/utils/MdmUtils.java |   48 ++++++++++++++++++++++++++++++++----------------
 1 files changed, 32 insertions(+), 16 deletions(-)

diff --git a/src/main/java/com/itstyle/mdm/utils/MdmUtils.java b/src/main/java/com/itstyle/mdm/utils/MdmUtils.java
index 8e5f4da..4c43192 100644
--- a/src/main/java/com/itstyle/mdm/utils/MdmUtils.java
+++ b/src/main/java/com/itstyle/mdm/utils/MdmUtils.java
@@ -33,14 +33,14 @@
      * MDM灞�鍩熺墿鏂欏悕绉扮紪鐮佹暟鎹幏鍙�
      * @return
      */
-    public String queryMaterial(){
+    public String queryMaterial(String name){
         StringBuffer returnJson = new StringBuffer();
         Map<String,String> params = new HashMap<>();
         params.put("code","1560000581165.1560000576507.a94a779e9e6d3ecbb646e39477dad6ec");//鎺堟潈鐮�
         params.put("current","1");//椤电爜
         params.put("size","1000");//姣忛〉璁板綍鏁�(鏈�澶�1000)
         params.put("queryValue","");//妯$硦鏌ヨ
-        MdmEnum anEnum = MdmEnum.getMdmEnumByAddress("灞�鍩熺墿鏂欏悕绉扮紪鐮佹暟鎹幏鍙�");
+        MdmEnum anEnum = MdmEnum.getMdmEnumByAddress(name);
         String address = anEnum.getAddress();
         try {
             HttpClientResult httpClientResult = MdmApiUtils.doPost(MDM_ADRESS+address, null, params);
@@ -50,27 +50,34 @@
                 String records = httpClientResult.getContent();
                 records = records.replaceAll("\\p{Z}", "");
                 JSONObject jsonObj = JSON.parseObject(records);
+
                 records = jsonObj.getString("records");
+                records = records.replaceAll("attri2","unitName");
+                records = records.replaceAll("brand","supplierName");
+                records = records.replaceAll("jzgg","specification");
+                records = records.replaceAll("model","specificationDisplayName");
+                records = records.replaceAll("namecn","code");
+                records = records.replaceAll("hyflmc","typeCode");
                 JSONArray recordArray = JSON.parseArray(records);//鐗╂枡鏁版嵁淇℃伅
                 //灏嗘暟鎹繚瀛樿嚦鏁版嵁搴�
-                JSONArray newJson = mdmService.saveMdmData(recordArray,"灞�鍩熺墿鏂欏悕绉扮紪鐮佹暟鎹幏鍙�");
+                JSONArray newJson = mdmService.saveMdmData(recordArray,name);
                 if(newJson.size()!=0){
                     //瀹氫箟杩斿洖json鏍煎紡
-                    returnJson.append("{\n" +
+                    /*returnJson.append("{\n" +
                             "    \"current\": 1,\n" +
                             "    \"orders\": [],\n" +
-                            "    \"pages\": 303,");
-                    returnJson.append("\"records\": "+newJson.toJSONString());
-                    returnJson.append(",\n" +
+                            "    \"pages\": 303,");*/
+                    returnJson.append("{\"records\": "+newJson.toJSONString()+"}");
+                    /*returnJson.append(",\n" +
                             "    \"searchCount\": true,\n" +
                             "    \"size\": 1,\n" +
                             "    \"total\": 303\n" +
-                            "}");
+                            "}");*/
                     //杩斿洖json鏍煎紡鍙傛暟
                     String toString = returnJson.toString();
-                    System.out.println(toString);
+                    System.out.println("鍝嶅簲鍙傛暟鍒嗗彂锛�"+toString);
                     //鍒嗗彂澧為噺鏁版嵁鑷冲紓鏋勭郴缁�
-                    distributeDataToSys(toString,"灞�鍩熺墿鏂欏悕绉扮紪鐮佹暟鎹幏鍙�");
+                    distributeDataToSys(toString,name);
                 }
             }
         } catch (Exception e) {
@@ -83,8 +90,8 @@
      * MDM璁¢噺鍗曚綅鏁版嵁鑾峰彇
      * @return
      */
-    public String queryUnit(){
-        MdmEnum anEnum = MdmEnum.getMdmEnumByAddress("璁¢噺鍗曚綅涓氬姟鍩虹鏁版嵁缂栫爜鑾峰彇");
+    public String queryUnit(String name){
+        MdmEnum anEnum = MdmEnum.getMdmEnumByAddress(name);
         StringBuffer returnJson = new StringBuffer();
         Map<String,String> params = new HashMap<>();
         params.put("code","1560000581165.1560000576507.a94a779e9e6d3ecbb646e39477dad6ec");//鎺堟潈鐮�
@@ -101,7 +108,7 @@
                 records = jsonObj.getString("data");
                 JSONArray recordArray = JSON.parseArray(records);//鐗╂枡鏁版嵁淇℃伅
                 //灏嗘暟鎹繚瀛樿嚦鏁版嵁搴�
-                JSONArray newJson = mdmService.saveMdmUnitData(recordArray,"璁¢噺鍗曚綅涓氬姟鍩虹鏁版嵁缂栫爜鑾峰彇");
+                JSONArray newJson = mdmService.saveMdmUnitData(recordArray,name);
                 if(newJson.size()!=0){
                     //瀹氫箟杩斿洖json鏍煎紡
                     returnJson.append("{\n" +
@@ -113,9 +120,8 @@
                             "}");
                     //杩斿洖json鏍煎紡鍙傛暟
                     String toString = returnJson.toString();
-                    System.out.println(toString);
                     //鍒嗗彂澧為噺鏁版嵁鑷冲紓鏋勭郴缁�
-                    distributeDataToSys(toString,"璁¢噺鍗曚綅涓氬姟鍩虹鏁版嵁缂栫爜鑾峰彇");
+                    distributeDataToSys(toString,name);
                 }
             }
         } catch (Exception e) {
@@ -139,7 +145,17 @@
                 String uuid = UUID.randomUUID().toString();
                 try {
                     //鏁版嵁鍒嗗彂
-                    httpClientResult = MdmApiUtils.doPostJson(address, jsonParam);
+                    if("MES绯荤粺".equals(sysName)){
+                        //澶勭悊json涓篗ES绯荤粺鎯宠鐨勬牸寮�
+                        jsonParam=MdmApiUtils.getMesJson(jsonParam);
+                        //鎷兼帴webservice
+                        String xmlStr=MdmApiUtils.getMesSoapBody(jsonParam);
+                        //璇锋眰webservice
+                        httpClientResult = MdmApiUtils.doPostXmlJson(address, xmlStr);
+                    }else{
+                        httpClientResult = MdmApiUtils.doPostJson(address, jsonParam);
+                    }
+
                     //鍝嶅簲缁撴灉
                     String content = httpClientResult.getContent();
                     int code = httpClientResult.getCode();

--
Gitblit v1.8.0