package com.chinaztt.mes.mould.util;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.fastjson.serializer.SerializeConfig;
|
import com.alibaba.fastjson.serializer.ToStringSerializer;
|
import com.chinaztt.mes.mould.config.MouldConfig;
|
import com.chinaztt.mes.mould.dto.ZttMouldDTO;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.cxf.helpers.IOUtils;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import javax.persistence.Column;
|
import java.io.*;
|
import java.lang.reflect.Method;
|
import java.math.BigDecimal;
|
import java.net.HttpURLConnection;
|
import java.net.URL;
|
import java.util.Arrays;
|
|
/**
|
* @Author: Zero
|
* @Date: 2022/12/2 09:14
|
* @Description:
|
*/
|
@Component
|
@Slf4j
|
public class MouldUtil {
|
@Resource
|
private MouldConfig mouldConfig;
|
|
public JSONObject readTempCollectionRecord(String param) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("success", false);
|
try {
|
String result = getRes("Read_temp_collection_record", JSONObject.parseObject(param, ZttMouldDTO.class));
|
if (StringUtils.equals("no data", result)) {
|
jsonObject.put("message", result);
|
} else {
|
jsonObject.put("success", true);
|
jsonObject.put("data", result);
|
}
|
} catch (Exception e) {
|
log.error(e.getMessage(), e);
|
jsonObject.put("data", StringUtils.EMPTY);
|
}
|
return jsonObject;
|
}
|
|
public Boolean insertTempLifeRecord(String param) {
|
try {
|
SerializeConfig config = SerializeConfig.getGlobalInstance();
|
config.put(BigDecimal.class, ToStringSerializer.instance);
|
String result = getRes("Insert_temp_life_record", JSONObject.parseObject(param, ZttMouldDTO.class));
|
if (StringUtils.equalsIgnoreCase("insert success", result)) {
|
return Boolean.TRUE;
|
} else {
|
return Boolean.FALSE;
|
}
|
} catch (Exception e) {
|
log.error(e.getMessage(), e);
|
return Boolean.FALSE;
|
//throw new RuntimeException(e.getMessage(), e);
|
}
|
}
|
|
|
private String getRes(String methodKey, Object object) throws Exception {
|
String result = getResByXml(getXml(methodKey, object), mouldConfig.getMouldUrl());
|
switch (methodKey) {
|
case "Read_temp_collection_record":
|
result = SoapUtil.parseReadTempCollectionRecordResult(result);
|
break;
|
case "Insert_temp_life_record":
|
result = SoapUtil.parseInsertTempLifeRecordResult(result);
|
break;
|
default:
|
return result;
|
}
|
return result;
|
}
|
|
|
public static String getResByXml(String soapXML, String url1) {
|
StringBuilder sb = new StringBuilder();
|
InputStream is = null;
|
InputStreamReader isr = null;
|
BufferedReader br = null;
|
OutputStream os = null;
|
HttpURLConnection connection = null;
|
String result = StringUtils.EMPTY;
|
try {
|
//第一步：创建服务地址
|
URL url = new URL(url1);
|
//打开链接
|
connection = (HttpURLConnection) url.openConnection();
|
//第三步：设置参数
|
//3.1发送方式设置：POST必须大写
|
connection.setRequestMethod("POST");
|
//3.2设置数据格式：content-type
|
connection.setRequestProperty("Content-Type", "text/xml;charset=utf-8");
|
//3.3设置输入输出，因为默认新创建的connection没有读写权限，
|
connection.setDoInput(true);
|
connection.setDoOutput(true);
|
//第四步：组织SOAP数据，发送请求
|
os = connection.getOutputStream();
|
os.write(soapXML.getBytes("UTF-8"));
|
//第五步：接收服务端响应，打印
|
int responseCode = connection.getResponseCode();
|
if (responseCode == 200) {
|
is = connection.getInputStream();
|
result = IOUtils.toString(is, "utf-8");
|
}
|
} catch (Exception e) {
|
log.error(e.getMessage(), e);
|
} finally {
|
try {
|
if (null != is) {
|
is.close();
|
}
|
if (null != isr) {
|
isr.close();
|
}
|
if (null != br) {
|
br.close();
|
}
|
if (null != os) {
|
os.close();
|
}
|
if (null != connection) {
|
connection.disconnect();
|
}
|
} catch (IOException e) {
|
log.error(e.getMessage(), e);
|
}
|
}
|
return result;
|
}
|
|
private String getXml(String sign, Object object) throws Exception {
|
String xml = "<soap:Envelope xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xmlns:xsd=\"http://www" +
|
".w3.org/2001/XMLSchema\" xmlns:soap=\"http://schemas.xmlsoap.org/soap/envelope/\"><soap:Body><" + sign + " xmlns=\"http://tempuri.org/\">";
|
switch (sign) {
|
case "Insert_collection_record":
|
xml += xmlMaker(new String[]{"MouldCode", "operatorMan", "TeamName", "ShiftsName", "MachineName",
|
"GroupName"}, object);
|
break;
|
case "Insert_temp_life_record":
|
xml += xmlMaker(new String[]{"MouldCode", "SerialNumber", "ProcedureNumber", "MachineNumber",
|
"ProductSpec", "PlateNumber", "LifeValue", "ProductionDate", "BuildMaker"}, object);
|
break;
|
case "Query_group_mould_account":
|
xml += xmlMaker(new String[]{"MouldCode", "MachineName", "GroupName", "MouldSpec", "MouldDrawingNo"},
|
object);
|
break;
|
case "Query_mould_check_record":
|
xml += xmlMaker(new String[]{"MouldCode", "GroupName"}, object);
|
break;
|
case "Read_temp_collection_record":
|
String[] cols = new String[]{"MachineNum", "MouldName"};
|
xml += xmlMaker(cols, object);
|
break;
|
case "Insert_Process_Order":
|
xml += xmlMaker(new String[]{"OrderNo", "GroupName", "MouldList"}, object);
|
break;
|
case "Insert_mould_exception_record":
|
xml += xmlMaker(new String[]{"MouldCode", "ExceptioInfo", "OrderNo", "CommitterName", "OccurrenceTime", "GroupName"}, object);
|
break;
|
}
|
xml += "</" + sign + "></soap:Body></soap:Envelope>";
|
return xml;
|
}
|
|
private String xmlMaker(String[] strings, Object object) throws Exception {
|
String xml = "";
|
Method[] methods = object.getClass().getDeclaredMethods();
|
for (Method method : methods) {
|
if (method.isAnnotationPresent(Column.class)) {
|
//获取注解
|
Column column = method.getAnnotation(Column.class);
|
//获取注解的name 属性 name中存放的 字段名
|
String para = column.name();
|
if (Arrays.asList(strings).contains(para)) {
|
Object value = method.invoke(object);
|
if (value != null) {
|
xml += "<" + para + ">" + value + "</" + para + ">";
|
} else {
|
xml += "<" + para + "></" + para + ">";
|
}
|
}
|
}
|
}
|
return xml;
|
}
|
}
|
