package com.fzzy.push.gd2020.v2; import com.fzzy.api.data.AuthToken; import com.fzzy.api.entity.Api1101; import com.fzzy.api.entity.ApiConfs; import com.fzzy.push.gd2020.*; 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.jia * @update-time: 2022/10/10 20:46 */ @Slf4j public class CompanyWebService { public static CompanyWebService newInstance() { return new CompanyWebService(); } public String xml_webService = "{zhgxsj}{qylxr}{qylx}{yzbm}{bgdh}{czbz}{kqs}{cfs}{ygs}{zcrq}{qymc}{qytyshxydm}{fddbr}{qyjd}{qywd}{qyxzqymc}{qyxzqhdm}{qyssqx}{qydm}{frsjh}{zczb}{zcze}{frsfzh}{yydz}{dzyx}{czhm}"; private String wsdl = "/companyWebService?wsdl";//填写调用库点信息接口服务 private String method = "companySaveRecordDetail";// 填写数据方法名 private String nameSpace = "http://service.sljt.com";// 填写调用省平台命名空间 public InvokeResult webService(AuthToken authToken, ApiConfs conf, Api1101 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; } public String webServiceXml(Api1101 data) { String xmlStr = xml_webService; xmlStr = xmlStr.replace("{qyssqx}", GDUtils.formatStr(data.getXzqhdm()));//企业所属区县 xmlStr = xmlStr.replace("{qywd}", GDUtils.formatNum(data.getWd()));//企业纬度 xmlStr = xmlStr.replace("{qyjd}", GDUtils.formatNum(data.getJd()));//企业经度 xmlStr = xmlStr.replace("{qylx}", GDUtils.formatStr(data.getDwlx()));//单位类型 xmlStr = xmlStr.replace("{zcrq}", GDUtils.formatDate(data.getZcrq(), "yyyy-MM-dd"));//注册日期 xmlStr = xmlStr.replace("{zczb}", GDUtils.formatNum(data.getZczb()));//注册资本 xmlStr = xmlStr.replace("{zcze}", GDUtils.formatNum(data.getZcze()));//资产总额 xmlStr = xmlStr.replace("{fddbr}", GDUtils.formatStr(data.getFddbr()));//法定代表人 xmlStr = xmlStr.replace("{frsfzh}", GDUtils.formatStr(data.getFrsfzh()));//法人身份证号 xmlStr = xmlStr.replace("{frsjh}", GDUtils.formatStr(data.getFrlxfs()));//法人联系方式 xmlStr = xmlStr.replace("{qylxr}", GDUtils.formatStr(data.getQylxr()));//企业联系人 xmlStr = xmlStr.replace("{bgdh}", GDUtils.formatStr(data.getBgdh()));//办公电话 xmlStr = xmlStr.replace("{yydz}", GDUtils.formatStr(data.getZcdz()));//注册地址 xmlStr = xmlStr.replace("{dzyx}", GDUtils.formatStr(data.getDzyx()));//注册地址 xmlStr = xmlStr.replace("{czhm}", GDUtils.formatStr(data.getCzhm()));//传真号码 xmlStr = xmlStr.replace("{yzbm}", GDUtils.formatStr(data.getYzbm()));//邮政编码 xmlStr = xmlStr.replace("{kqs}", GDUtils.formatNum(data.getKqs()));//库区数 xmlStr = xmlStr.replace("{cfs}", GDUtils.formatNum(data.getKqs()));//仓房数 xmlStr = xmlStr.replace("{ygs}", GDUtils.formatNum(data.getYgs()));//油罐数 xmlStr = xmlStr.replace("{qydm}", GDUtils.formatStr(data.getDwdm()));//企业代码 xmlStr = xmlStr.replace("{qymc}", GDUtils.formatStr(data.getDwmc()));//企业名称 xmlStr = xmlStr.replace("{qyxzqhdm}", GDUtils.formatStr(data.getXzqhdm()));//企业行政区划代码 xmlStr = xmlStr.replace("{qytyshxydm}", GDUtils.formatStr(data.getDwdm()));//企业统一社会信用代码 xmlStr = xmlStr.replace("{qyxzqymc}", GDUtils.formatStr(data.getXzqhmc()));//企业行政区域名称 xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//操作标志 xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));//最后更新时间 return xmlStr; } }