package com.fzzy.push.gd2020.v2;
|
|
import com.fzzy.api.data.AuthToken;
|
import com.fzzy.api.entity.Api1101;
|
import com.fzzy.api.entity.Api1107;
|
import com.fzzy.api.entity.ApiConfs;
|
import com.fzzy.push.gd2020.GDResult;
|
import com.fzzy.push.gd2020.GDUtils;
|
import com.fzzy.push.gd2020.InvokeResult;
|
import com.fzzy.push.gd2020.JaxbUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.cxf.endpoint.Client;
|
import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory;
|
|
import javax.xml.namespace.QName;
|
|
/**
|
* @Desc: 设备信息接口
|
* @author: Andy
|
* @update-time: 2022/10/16
|
*/
|
@Slf4j
|
public class DeviceWebService {
|
|
|
public static DeviceWebService newInstance() {
|
return new DeviceWebService();
|
}
|
|
|
public String xml_WebService = "<?xml version=\"1.0\" encoding=\"utf8\"?><root><row id=\"cfgl_device\"><kddm desc=\"库点代码\" type=\"varchar\" length=\"50\" requir=\"必填\">{kddm}</kddm><sbbh desc=\"设备编号\" type=\"varchar\" length=\"30\" requir=\"必填\">{sbbh}</sbbh><sbyqmc desc=\"设备仪器名称\" type=\"varchar\" length=\"64\" requir=\"必填\">{sbyqmc}</sbyqmc><sbggxh desc=\"设备规格型号\" type=\"varchar\" length=\"64\" requir=\"可选\">{sbggxh}</sbggxh><sbms desc=\"设备描述\" type=\"varchar\" length=\"500\" requir=\"可选\">{sbms}</sbms><sbzt desc=\"设备状态\" type=\"varchar\" length=\"50\" requir=\"可选\">{sbzt}</sbzt><sblx desc=\"设备类型\" type=\"varchar\" length=\"64\" requir=\"可选\">{sblx}</sblx><scrq desc=\"生产日期\" type=\"varchar\" length=\"10\" requir=\"可选\">{scrq}</scrq><sccj desc=\"生产厂家\" type=\"varchar\" length=\"64\" requir=\"可选\">{sccj}</sccj></row></root>";
|
|
|
private String method = "deviceSaveRecordDetail";// 填写数据方法名
|
private String wsdl = "/deviceWebService?wsdl";//填写调用库点信息接口服务
|
private String nameSpace = "http://service.sljt.com";// 填写调用省平台命名空间
|
|
|
public InvokeResult webService(AuthToken authToken,ApiConfs conf, Api1107 data) {
|
InvokeResult invokeResult = new InvokeResult();
|
|
ClassLoader cl = Thread.currentThread().getContextClassLoader();
|
|
String url = conf.getApiUrl() + wsdl; // 填写调用设备信息接口服务
|
|
Thread.currentThread().setContextClassLoader(cl);
|
JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
|
Client client = dcf.createClient(url);
|
QName name = new QName(nameSpace, method);
|
Object[] objects;
|
try {
|
|
String xmlStr = webServiceXml(data);// 获取接口的输入报文，根据需要填写相应的报文
|
|
log.debug("------xmlStr--{}", xmlStr);
|
|
|
objects = client.invoke(name, new Object[]{authToken.getToken(), xmlStr});
|
|
log.debug("-----------返回信息---{}", objects[0].toString());
|
|
invokeResult = JaxbUtil.converyToJavaBean(objects[0].toString(), InvokeResult.class);
|
|
} catch (Exception e) {
|
log.error("----执行异常----{}", e);
|
invokeResult.setCode(GDResult.CODE_500.getCode());
|
invokeResult.setData("后端服务执行异常：+" + e.getMessage());
|
return invokeResult;
|
}
|
|
return invokeResult;
|
}
|
|
private String webServiceXml(Api1107 data) {
|
String xmlStr = xml_WebService;
|
xmlStr = xmlStr.replace("{kddm}", GDUtils.formatStr(data.getKqdm()));//库点代码
|
xmlStr = xmlStr.replace("{sbbh}", GDUtils.formatStr(data.getSbbh()));//设备编号
|
xmlStr = xmlStr.replace("{sbyqmc}", GDUtils.formatStr(data.getSbyqmc()));//设备仪器名称
|
xmlStr = xmlStr.replace("{sbggxh}", GDUtils.formatStr(data.getSbggxh()));//设备规格型号
|
xmlStr = xmlStr.replace("{sbms}", GDUtils.formatStr(data.getSbms()));//设备描述
|
xmlStr = xmlStr.replace("{sbzt}", GDUtils.formatStr(data.getSbzt()));//设备状态
|
xmlStr = xmlStr.replace("{sblx}", "");//设备类型
|
xmlStr = xmlStr.replace("{scrq}", GDUtils.formatDate(data.getScrq(), "yyyy-MM-dd"));//生产日期
|
xmlStr = xmlStr.replace("{sccj}", GDUtils.formatStr(data.getSccj()));//生产厂家
|
return xmlStr;
|
}
|
|
}
|
