package com.itstyle.mdm.utils;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.itstyle.mdm.entity.HttpClientResult;
|
import com.itstyle.quartz.entity.SysConfigEntity;
|
import com.itstyle.mdm.enumwrap.MdmEnum;
|
import com.itstyle.mdm.service.MdmService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.UUID;
|
|
/**
|
* 主数据获取
|
*/
|
@Service("mdmUtils")
|
public class MdmUtils {
|
|
@Value("${MDM_ADRESS}")
|
private String MDM_ADRESS;
|
|
@Autowired
|
private MdmService mdmService;
|
|
|
/**
|
* MDM局域物料名称编码数据获取
|
* @return
|
*/
|
public String queryMaterial(){
|
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("局域物料名称编码数据获取");
|
String address = anEnum.getAddress();
|
try {
|
HttpClientResult httpClientResult = MdmApiUtils.doPost(MDM_ADRESS+address, null, params);
|
int code = httpClientResult.getCode();
|
if(200 == code){
|
//成功
|
String records = httpClientResult.getContent();
|
records = records.replaceAll("\\p{Z}", "");
|
JSONObject jsonObj = JSON.parseObject(records);
|
records = jsonObj.getString("records");
|
JSONArray recordArray = JSON.parseArray(records);//物料数据信息
|
//将数据保存至数据库
|
JSONArray newJson = mdmService.saveMdmData(recordArray,"局域物料名称编码数据获取");
|
if(newJson.size()!=0){
|
//定义返回json格式
|
returnJson.append("{\n" +
|
" \"current\": 1,\n" +
|
" \"orders\": [],\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);
|
//分发增量数据至异构系统
|
distributeDataToSys(toString,"局域物料名称编码数据获取");
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return "";
|
}
|
|
/**
|
* MDM计量单位数据获取
|
* @return
|
*/
|
public String queryUnit(){
|
MdmEnum anEnum = MdmEnum.getMdmEnumByAddress("计量单位业务基础数据编码获取");
|
StringBuffer returnJson = new StringBuffer();
|
Map<String,String> params = new HashMap<>();
|
params.put("code","1560000581165.1560000576507.a94a779e9e6d3ecbb646e39477dad6ec");//授权码
|
params.put("type",anEnum.getType());//类型
|
String address = anEnum.getAddress();
|
try {
|
HttpClientResult httpClientResult = MdmApiUtils.doPost(MDM_ADRESS+address, null, params);
|
int code = httpClientResult.getCode();
|
if(200 == code){
|
//成功
|
String records = httpClientResult.getContent();
|
records = records.replaceAll("\\p{Z}", "");
|
JSONObject jsonObj = JSON.parseObject(records);
|
records = jsonObj.getString("data");
|
JSONArray recordArray = JSON.parseArray(records);//物料数据信息
|
//将数据保存至数据库
|
JSONArray newJson = mdmService.saveMdmUnitData(recordArray,"计量单位业务基础数据编码获取");
|
if(newJson.size()!=0){
|
//定义返回json格式
|
returnJson.append("{\n" +
|
" \"code\": 200,\n" +
|
" \"data\":"+newJson.toJSONString());
|
returnJson.append(",\n" +
|
" \"message\": \"请求成功\",\n" +
|
" \"success\": true\n" +
|
"}");
|
//返回json格式参数
|
String toString = returnJson.toString();
|
System.out.println(toString);
|
//分发增量数据至异构系统
|
distributeDataToSys(toString,"计量单位业务基础数据编码获取");
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return "";
|
}
|
|
/**
|
* 分发主数据数据至异构系统
|
* @param jsonParam
|
*/
|
public void distributeDataToSys(String jsonParam,String interfaceName){
|
List<SysConfigEntity> sysConfigEntities = mdmService.querySysConfigs(interfaceName);
|
if (sysConfigEntities.size()!=0){
|
for (int i = 0; i < sysConfigEntities.size(); i++) {
|
SysConfigEntity sysConfigEntity = sysConfigEntities.get(i);
|
String sysName = sysConfigEntity.getSysName();//系统名称
|
String address = sysConfigEntity.getAddress();//分发地址
|
HttpClientResult httpClientResult = null;
|
String uuid = UUID.randomUUID().toString();
|
try {
|
//数据分发
|
httpClientResult = MdmApiUtils.doPostJson(address, jsonParam);
|
//响应结果
|
String content = httpClientResult.getContent();
|
int code = httpClientResult.getCode();
|
if(200 == code){
|
//成功
|
this.saveInterfaceLog(uuid,interfaceName,address,jsonParam,content);
|
}else {
|
//异常
|
this.saveInterfaceLog(uuid,interfaceName,address,jsonParam,content);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
this.saveInterfaceLog(uuid,interfaceName,address,jsonParam,"{\"batchId\":\""+uuid+"\",\"msg\":\" 接口调用网络异常！！！ \"}");
|
}
|
|
}
|
}
|
}
|
|
/**
|
* 保存接口分发日志
|
* @param interfaceName
|
* @param url
|
* @param param
|
* @param result
|
*/
|
public void saveInterfaceLog(String uuid,String interfaceName,String url,String param,String result){
|
mdmService.saveInterfaceLog(uuid,interfaceName, url, param, result);
|
}
|
}
|
