package com.fzzy.push.gd2020.v2; import com.fzzy.api.data.AuthToken; import com.fzzy.api.entity.Api1102; 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: shaoxiang.zheng * @update-time: 2022/10/10 */ @Slf4j public class StoreLocationWebService { public static StoreLocationWebService newInstance() { return new StoreLocationWebService(); } public String xml_StoreLocationWebService = "{kddm}{kqbm}{kdmc}{kdwd}{kdjd}{kdxzqhmc}{kdxzqydm}{cfs}{ygs}{zhgxsj}{kdsjcr}{kqcq}{yxcr}{yxgr}{zdmj}{czbz}{kqdz}{kdssqx}"; private String wsdl = "/storeLocationWebService?wsdl";//填写调用库点信息接口服务 private String method = "storeLocationSaveRecordDetail";// 填写数据方法名 private String nameSpace = "http://service.sljt.com";// 填写调用省平台命名空间 public InvokeResult webService(AuthToken authToken,ApiConfs conf, Api1102 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 = storeLocationWebServiceXml(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; } /** * 报文获取-- 替换数据 * * @param data * @return */ private String storeLocationWebServiceXml(Api1102 data) { String xmlStr = xml_StoreLocationWebService; xmlStr = xmlStr.replace("{kqbm}", GDUtils.formatStr(data.getKqdm()));//库区编码 -- 单位代码 xmlStr = xmlStr.replace("{kddm}", GDUtils.formatStr(data.getKqdm()));//库点代码 xmlStr = xmlStr.replace("{kdmc}", GDUtils.formatStr(data.getKqmc()));//库点名称 xmlStr = xmlStr.replace("{kdwd}", GDUtils.formatNum(data.getWd()));//库点纬度 xmlStr = xmlStr.replace("{kdjd}", GDUtils.formatNum(data.getJd()));//库点经度 xmlStr = xmlStr.replace("{kdxzqhmc}", GDUtils.formatStr(data.getXzqhmc()));// 库点行政区划名称 xmlStr = xmlStr.replace("{kdxzqydm}", GDUtils.formatStr(data.getXzqhdm()));//库点行政区划代码 xmlStr = xmlStr.replace("{kqdz}", GDUtils.formatStr(data.getKqdz()));//库区地址 xmlStr = xmlStr.replace("{kqcq}", GDUtils.formatStr(data.getKqcq()));//库区产权 xmlStr = xmlStr.replace("{kdsjcr}", GDUtils.formatNum(data.getYxcr()));// 库点设计仓容 xmlStr = xmlStr.replace("{yxcr}", GDUtils.formatNum(data.getYxcr()));//有效仓容 xmlStr = xmlStr.replace("{yxgr}", GDUtils.formatNum(data.getYxgr()));//有效罐容 xmlStr = xmlStr.replace("{zdmj}", GDUtils.formatNum(data.getZdmj()));//占地面积 xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//操作标志 xmlStr = xmlStr.replace("{ygs}", GDUtils.formatNum(data.getYgs()));//油罐数 xmlStr = xmlStr.replace("{cfs}", GDUtils.formatNum(data.getCfs()));//仓容数 xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd"));//最后更新时间 xmlStr = xmlStr.replace("{kdssqx}", "");// 库点所属区县 return xmlStr; } }