From 73734f096b25cb3c350ddceec46e47f4de004b7d Mon Sep 17 00:00:00 2001
From: dbs <email0099@163.com>
Date: 星期一, 23 十二月 2024 16:34:16 +0800
Subject: [PATCH] 新增MES接口的解析处理。
---
src/main/java/com/itstyle/mdm/utils/MdmUtils.java | 37 ++++++++++++++++++++++++++++---------
1 files changed, 28 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/itstyle/mdm/utils/MdmUtils.java b/src/main/java/com/itstyle/mdm/utils/MdmUtils.java
index 6330f79..1bcceaa 100644
--- a/src/main/java/com/itstyle/mdm/utils/MdmUtils.java
+++ b/src/main/java/com/itstyle/mdm/utils/MdmUtils.java
@@ -50,25 +50,32 @@
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,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,name);
}
@@ -113,7 +120,6 @@
"}");
//杩斿洖json鏍煎紡鍙傛暟
String toString = returnJson.toString();
- System.out.println(toString);
//鍒嗗彂澧為噺鏁版嵁鑷冲紓鏋勭郴缁�
distributeDataToSys(toString,name);
}
@@ -139,9 +145,22 @@
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();
+ if("MES绯荤粺".equals(sysName)){
+ content = MdmApiUtils.getMesResponseJson(content);
+ }
int code = httpClientResult.getCode();
if(200 == code){
//鎴愬姛
@@ -152,7 +171,7 @@
}
} catch (Exception e) {
e.printStackTrace();
- this.saveInterfaceLog(uuid,interfaceName,address,jsonParam,"{\"batchId\":\""+uuid+"\",\"msg\":\" 鎺ュ彛璋冪敤缃戠粶寮傚父锛侊紒锛� \"}");
+ this.saveInterfaceLog(uuid,interfaceName,address,jsonParam,"{\"batchId\":\""+uuid+"\",\"msg\":\" 鎺ュ彛璋冪敤缃戠粶寮傚父锛侊紒锛�/"+e.getMessage()+"/ \"}");
}
}
--
Gitblit v1.8.0