| package com.fzzy.push.gd2020.v2; | 
|   | 
| import com.fzzy.api.data.AuthToken; | 
| import com.fzzy.api.entity.Api1103; | 
| import com.fzzy.api.entity.Api1105; | 
| 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/15 | 
|  */ | 
| @Slf4j | 
| public class GoodsAllocationWebService { | 
|   | 
|     public static GoodsAllocationWebService newInstance() { | 
|         return new GoodsAllocationWebService(); | 
|     } | 
|   | 
|   | 
|     public String xml_webservice = "<?xml version=\"1.0\" encoding=\"utf8\"?><root><row id=\"cfgl_goods_allocation\"><sskdbh desc=\"所属库点代码\" type=\"varchar\" length=\"50\" requir=\"必填\">{sskdbh}</sskdbh><cfmc desc=\"仓房名称\" type=\"varchar\" length=\"50\" requir=\"必填\">{cfmc}</cfmc><hwbh desc=\"货位编码\" type=\"varchar\" length=\"30\" requir=\"必填\">{hwbh}</hwbh><ajdm desc=\"廒间代码\" type=\"varchar\" length=\"28\" requir=\"必填\">{ajdm}</ajdm><hwrl desc=\"货位容量\" type=\"decimal\" length=\"20\" requir=\"必填\">{hwrl}</hwrl><hwzt desc=\"货位状态\" type=\"varchar\" length=\"50\" requir=\"必填\">{hwzt}</hwzt><hwqyrq desc=\"货位启用日期\" type=\"varchar\" length=\"14\" requir=\"必填\">{hwqyrq}</hwqyrq><hwmc desc=\"货位名称\" type=\"varchar\" length=\"32\" requir=\"必填\">{hwmc}</hwmc><czbz desc=\"操作标志\" type=\"varchar\" length=\"1\" requir=\"必填\">{czbz}</czbz><zhgxsj desc=\"最后更新时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{zhgxsj}</zhgxsj><bgy desc=\"保管员\" type=\"varchar\" length=\"100\" requir=\"可选\">{bgy}</bgy><bgdw desc=\"保管单位\" type=\"varchar\" length=\"64\" requir=\"可选\">{bgdw}</bgdw></row></root>"; | 
|   | 
|     private String method = "saveGoodsAllocationRecordDetail";// 填写数据方法名 | 
|     private String wsdl = "/goodsAllocationWebService?wsdl";//填写调用库点信息接口服务 | 
|     private String nameSpace = "http://service.sljt.com";// 填写调用省平台命名空间 | 
|   | 
|     public InvokeResult webService(AuthToken authToken,ApiConfs conf, Api1105 data, Api1103 api1103) { | 
|         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, api1103);// 获取接口的输入报文,根据需要填写相应的报文 | 
|   | 
|             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(Api1105 data, Api1103 api1103) { | 
|         String xmlStr = xml_webservice; | 
|         xmlStr = xmlStr.replace("{sskdbh}", GDUtils.formatStr(data.getKqdm()));//所属库点代码 | 
|         xmlStr = xmlStr.replace("{cfmc}", GDUtils.formatStr(api1103.getCfmc()));//仓房名称 | 
|         xmlStr = xmlStr.replace("{hwbh}", GDUtils.formatStr(data.getHwdm()));//货位编码 | 
|         xmlStr = xmlStr.replace("{ajdm}", GDUtils.formatStr(data.getAjdm()));//廒间代码 | 
|         xmlStr = xmlStr.replace("{hwrl}", GDUtils.formatNum(data.getHwrl()));//货位容量 | 
|         xmlStr = xmlStr.replace("{hwzt}", GDUtils.formatStr(api1103.getCfzt()));//货位状态 | 
|         xmlStr = xmlStr.replace("{hwqyrq}", GDUtils.formatDate(data.getHwqyrq(), "yyyy-MM-dd"));//货位启用日期 | 
|         xmlStr = xmlStr.replace("{hwmc}", GDUtils.formatStr(data.getHwmc()));//货位名称 | 
|         xmlStr = xmlStr.replace("{bgy}", GDUtils.formatStr(data.getBgy()));//保管员 | 
|         xmlStr = xmlStr.replace("{bgdw}", GDUtils.formatStr(data.getBgdw()));//保管单位 | 
|   | 
|         xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//操作标志 | 
|         xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));//最后更新时间 | 
|         return xmlStr; | 
|     } | 
|   | 
| } |