| 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 = "<?xml version=\"1.0\" encoding=\"utf8\"?><root><row id=\"cfgl_warehousing_company\"><zhgxsj desc=\"最后更新时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{zhgxsj}</zhgxsj><qylxr desc=\"企业联系人\" type=\"varchar\" length=\"20\" requir=\"必填\">{qylxr}</qylxr><qylx desc=\"企业类型\" type=\"varchar\" length=\"2\" requir=\"必填\">{qylx}</qylx><yzbm desc=\"邮政编码\" type=\"varchar\" length=\"6\" requir=\"必填\">{yzbm}</yzbm><bgdh desc=\"办公电话\" type=\"varchar\" length=\"50\" requir=\"必填\">{bgdh}</bgdh><czbz desc=\"操作标志\" type=\"varchar\" length=\"1\" requir=\"必填\">{czbz}</czbz><kqs desc=\"库区数\" type=\"int\" length=\"12\" requir=\"必填\">{kqs}</kqs><cfs desc=\"仓房数\" type=\"int\" length=\"12\" requir=\"必填\">{cfs}</cfs><ygs desc=\"油罐数\" type=\"int\" length=\"12\" requir=\"必填\">{ygs}</ygs><zcrq desc=\"注册日期\" type=\"varchar\" length=\"10\" requir=\"必填\">{zcrq}</zcrq><qymc desc=\"企业名称\" type=\"varchar\" length=\"50\" requir=\"必填\">{qymc}</qymc><qytyshxydm desc=\"企业统一社会信用代码\" type=\"varchar\" length=\"18\" requir=\"必填\">{qytyshxydm}</qytyshxydm><fddbr desc=\"法定代表人\" type=\"varchar\" length=\"50\" requir=\"必填\">{fddbr}</fddbr><qyjd desc=\"企业经度\" type=\"decimal\" length=\"12\" requir=\"必填\">{qyjd}</qyjd><qywd desc=\"企业纬度\" type=\"decimal\" length=\"12\" requir=\"必填\">{qywd}</qywd><qyxzqymc desc=\"企业行政区域名称\" type=\"varchar\" length=\"50\" requir=\"必填\">{qyxzqymc}</qyxzqymc><qyxzqhdm desc=\"企业行政区划代码\" type=\"int\" length=\"12\" requir=\"必填\">{qyxzqhdm}</qyxzqhdm><qyssqx desc=\"企业所属区县\" type=\"int\" length=\"12\" requir=\"必填\">{qyssqx}</qyssqx><qydm desc=\"企业代码\" type=\"varchar\" length=\"50\" requir=\"必填\">{qydm}</qydm><frsjh desc=\"法人手机号\" type=\"char\" length=\"11\" requir=\"必填\">{frsjh}</frsjh><zczb desc=\"注册资本\" type=\"decimal\" length=\"12\" requir=\"可选\">{zczb}</zczb><zcze desc=\"资产总额\" type=\"decimal\" length=\"12\" requir=\"可选\">{zcze}</zcze><frsfzh desc=\"法人身份证号\" type=\"decimal\" length=\"12\" requir=\"可选\">{frsfzh}</frsfzh><yydz desc=\"注册地址\" type=\"varchar\" length=\"256\" requir=\"可选\">{yydz}</yydz><dzyx desc=\"电子邮箱\" type=\"varchar\" length=\"50\" requir=\"可选\">{dzyx}</dzyx><czhm desc=\"传真号码\" type=\"varchar\" length=\"32\" requir=\"可选\">{czhm}</czhm></row></root>"; | 
|   | 
|   | 
|     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; | 
|     } | 
| } |