| package com.fzzy.push.gd2020.v2; | 
|   | 
| import com.fzzy.api.data.AuthToken; | 
| import com.fzzy.api.entity.Api1201; | 
| 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; | 
|   | 
| @Slf4j | 
| public class ContractWebService { | 
|     public static ContractWebService newInstance() { | 
|         return new ContractWebService(); | 
|     } | 
|   | 
|   | 
|     public String xml_webService = "<?xml version=\"1.0\" encoding=\"utf8\"?><root><row id=\"lhjh_contract\"><khmc desc=\"客户名称\" type=\"varchar\" length=\"128\" requir=\"必填\">{khmc}</khmc><qdrq desc=\"签订日期\" type=\"varchar\" length=\"10\" requir=\"必填\">{qdrq}</qdrq><qddd desc=\"签订地点\" type=\"varchar\" length=\"128\" requir=\"必填\">{qddd}</qddd><htdj desc=\"合同单价\" type=\"decimal\" length=\"20\" requir=\"必填\">{htdj}</htdj><htzje desc=\"合同总金额\" type=\"decimal\" length=\"20\" requir=\"必填\">{htzje}</htzje><htbh desc=\"合同编号\" type=\"varchar\" length=\"64\" requir=\"必填\">{htbh}</htbh><htmc desc=\"合同名称\" type=\"varchar\" length=\"64\" requir=\"必填\">{htmc}</htmc><kddm desc=\"库点代码\" type=\"varchar\" length=\"30\" requir=\"必填\">{kddm}</kddm><htssdwdm desc=\"合同所属单位代码\" type=\"varchar\" length=\"18\" requir=\"必填\">{htssdwdm}</htssdwdm><ywlx desc=\"业务类别\" type=\"varchar\" length=\"1\" requir=\"必填\">{ywlx}</ywlx><khlx desc=\"客户类型\" type=\"varchar\" length=\"1\" requir=\"必填\">{khlx}</khlx><bfkhh desc=\"本方开户行\" type=\"varchar\" length=\"3\" requir=\"必填\">{bfkhh}</bfkhh><bfzh desc=\"本方账号\" type=\"varchar\" length=\"30\" requir=\"必填\">{bfzh}</bfzh><bfqyr desc=\"本方签约人\" type=\"varchar\" length=\"30\" requir=\"必填\">{bfqyr}</bfqyr><czbz desc=\"操作标志\" type=\"varchar\" length=\"1\" requir=\"必填\">{czbz}</czbz><zhgxsj desc=\"最后更新时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{zhgxsj}</zhgxsj><shr desc=\"审批人\" type=\"varchar\" length=\"30\" requir=\"可选\">{shr}</shr><shsj desc=\"审批时间\" type=\"varchar\" length=\"19\" requir=\"可选\">{shsj}</shsj><khtyshxydm desc=\"客户统一社会信用代码\" type=\"varchar\" length=\"18\" requir=\"可选\">{khtyshxydm}</khtyshxydm><lybzj desc=\"履约保证金\" type=\"decimal\" length=\"20\" requir=\"可选\">{lybzj}</lybzj><khfkhh desc=\"客户方开户行\" type=\"varchar\" length=\"3\" requir=\"可选\">{khfkhh}</khfkhh><khfzh desc=\"客户方账号\" type=\"varchar\" length=\"30\" requir=\"可选\">{khfzh}</khfzh><khqyr desc=\"客户签约人 \" type=\"varchar\" length=\"20\" requir=\"可选\">{khqyr}</khqyr><fddbr desc=\"法定代表人\" type=\"varchar\" length=\"50\" requir=\"可选\">{fddbr}</fddbr><txdz desc=\"通讯地址\" type=\"varchar\" length=\"256\" requir=\"可选\">{txdz}</txdz><yzbm desc=\"邮政编码\" type=\"varchar\" length=\"6\" requir=\"可选\">{yzbm}</yzbm><lxrxm desc=\"联系人姓名\" type=\"varchar\" length=\"20\" requir=\"可选\">{lxrxm}</lxrxm><lxrdh desc=\"联系电话\" type=\"varchar\" length=\"20\" requir=\"可选\">{lxrdh}</lxrdh><sfzh desc=\"身份证号\" type=\"varchar\" length=\"18\" requir=\"可选\">{sfzh}</sfzh><dzyx desc=\"电子信箱\" type=\"varchar\" length=\"32\" requir=\"可选\">{dzyx}</dzyx></row></root>\n"; | 
|   | 
|     private String wsdl = "/companyWebService?wsdl";//填写调用库点信息接口服务 | 
|     private String method = "companySaveRecordDetail";// 填写数据方法名 | 
|     private String nameSpace = "http://service.sljt.com";// 填写调用省平台命名空间 | 
|   | 
|   | 
|     public InvokeResult webService(AuthToken authToken, ApiConfs conf, Api1201 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(Api1201 data) { | 
|         String xmlStr = xml_webService; | 
|         xmlStr = xmlStr.replace("{htbh}", GDUtils.formatStr(data.getHth()));//合同编号 | 
|         xmlStr = xmlStr.replace("{htmc}", GDUtils.formatStr(data.getHtmc()));//合同名称 | 
|         xmlStr = xmlStr.replace("{kddm}", GDUtils.formatStr(data.getKqdm()));//上报库点代码 | 
|   | 
|         String dwdm = data.getKqdm().substring(0, 18); | 
|         xmlStr = xmlStr.replace("{htssdwdm}", dwdm);//合同所属单位代码 | 
|         xmlStr = xmlStr.replace("{ywlx}", GDUtils.formatStr(data.getYwlx()));//业务类别 | 
|         xmlStr = xmlStr.replace("{khlx}", GDUtils.formatStr(data.getKhlx()));//客户类型 | 
|         xmlStr = xmlStr.replace("{khtyshxydm}", GDUtils.formatStr(data.getKhtyshxydm()));//客户统一社会信用代码 | 
|         xmlStr = xmlStr.replace("{fddbr}", GDUtils.formatStr(data.getFddbr()));//客户类型 | 
|         xmlStr = xmlStr.replace("{txdz}", GDUtils.formatStr(data.getTxdz()));//通讯地址 | 
|         xmlStr = xmlStr.replace("{yzbm}", GDUtils.formatStr(data.getYzbm()));//邮政编码 | 
|         xmlStr = xmlStr.replace("{lxrxm}", GDUtils.formatStr(data.getLxrxm()));//联系人姓名 | 
|         xmlStr = xmlStr.replace("{lxrdh}", GDUtils.formatStr(data.getLxrdh()));//联系电话 | 
|         xmlStr = xmlStr.replace("{lxrdh}", GDUtils.formatStr(data.getLxrdh()));//身份证号 | 
|         xmlStr = xmlStr.replace("{dzyx}", GDUtils.formatStr(data.getDzyx()));//电子信箱 | 
|         xmlStr = xmlStr.replace("{qddd}", GDUtils.formatStr(data.getQddd()));//签订地点 | 
|         xmlStr = xmlStr.replace("{htdj}", GDUtils.formatNum(data.getHtdj()));//合同单价 | 
|         xmlStr = xmlStr.replace("{htzje}", GDUtils.formatNum(data.getHtzje()));//合同总金额 | 
|         xmlStr = xmlStr.replace("{lybzj}", GDUtils.formatNum(data.getLybzj()));//履约保证金 | 
|         xmlStr = xmlStr.replace("{khfkhh}", GDUtils.formatStr(data.getKhfkhh()));//客户方开户行 | 
|         xmlStr = xmlStr.replace("{khfzh}", GDUtils.formatStr(data.getKhfzh()));//客户方账号 | 
|         xmlStr = xmlStr.replace("{khqyr}", GDUtils.formatStr(data.getKhqyr()));//客户签约人 | 
|         xmlStr = xmlStr.replace("{bfkhh}", GDUtils.formatStr(data.getBfkhh()));//本方开户行 | 
|         xmlStr = xmlStr.replace("{bfqyr}", GDUtils.formatStr(data.getBfqyr()));//本方签约人 | 
|         xmlStr = xmlStr.replace("{bfzh}", GDUtils.formatStr(data.getBfzh()));//本方账号 | 
|         xmlStr = xmlStr.replace("{Qdrq}", GDUtils.formatDate(data.getQdrq(), "yyyy-MM-dd"));//签订日期 | 
|         xmlStr = xmlStr.replace("{Shsj}", GDUtils.formatDate(data.getShsj(), "yyyy-MM-dd HH:mm:ss"));//审批时间 | 
|         xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//操作标志 | 
|         xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));//最后更新时间 | 
|         return xmlStr; | 
|     } | 
| } |