| package com.fzzy.push.gd2020.v2; | 
|   | 
| import com.fzzy.api.data.AuthToken; | 
| import com.fzzy.api.entity.Api1203; | 
| 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/30 | 
|  */ | 
| @Slf4j | 
| public class InstoreCheckWebservice { | 
|   | 
|     public static InstoreCheckWebservice newInstance() { | 
|         return new InstoreCheckWebservice(); | 
|     } | 
|   | 
|   | 
|     public String xml_webservice = "<?xml version=\"1.0\" encoding=\"utf8\"?><root><row id=\"storeroom_instore_check\"><qydbh desc=\"检验单编号\" type=\"varchar\" length=\"12\" requir=\"必填\"}>{qydbh}</qydbh><ypbm desc=\"入库单编码\" type=\"varchar\" length=\"12\" requir=\"必填\">{ypbm}</ypbm><qysj desc=\"扦样时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{qysj}</qysj><qyrxm desc=\"扦样人姓名\" type=\"varchar\" length=\"20\" requir=\"必填\">{qyrxm}</qyrxm><jyxm desc=\"检验项目\" type=\"varchar\" length=\"500\" requir=\"必填\">{jyxm}</jyxm><jyjg desc=\"检验结果\" type=\"varchar\" length=\"500\" requir=\"必填\">{jyjg}</jyjg><zkj desc=\"增扣价\" type=\"varchar\" length=\"500\" requir=\"必填\">{zkj}</zkj><zkl desc=\"增扣量\" type=\"varchar\" length=\"500\" requir=\"必填\">{zkl}</zkl><jyrxm desc=\"检验人姓名\" type=\"varchar\" length=\"20\" requir=\"必填\">{jyrxm}</jyrxm><jysj desc=\"检验时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{jysj}</jysj><jyjl desc=\"检验结论\" type=\"varchar\" length=\"1\" requir=\"必填\">{jyjl}</jyjl><pzbm desc=\"粮食品种编码\" type=\"varchar\" length=\"7\" requir=\"必填\">{pzbm}</pzbm><lsdd desc=\"粮食定等\" type=\"varchar\" length=\"2\" requir=\"必填\">{lsdd}</lsdd><czbz desc=\"操作标志\" type=\"varchar\" length=\"1\" requir=\"必填\">{czbz}</czbz><kddm desc=\"库点代码\" type=\"varchar\" length=\"50\" requir=\"必填\">{kddm}</kddm><hwdm desc=\"货位编码\" type=\"varchar\" length=\"30\" requir=\"必填\">{hwdm}</hwdm><zhgxsj desc=\"最后更新时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{zhgxsj}</zhgxsj><qylb desc=\"扦样类别\" type=\"varchar\" length=\"1\" requir=\"可选\">{qylb}</qylb></row></root>"; | 
|   | 
|   | 
|   | 
|     public InvokeResult webservice(AuthToken authToken, ApiConfs conf, Api1203 data) { | 
|         InvokeResult invokeResult = new InvokeResult(); | 
|   | 
|         ClassLoader cl = Thread.currentThread().getContextClassLoader(); | 
|   | 
|         String url = conf.getApiUrl() + "/instoreCheckWebservice?wsdl"; // 填写调用接口服务 | 
|         String method = "instoreCheckSaveRecordDetail"; // 填写方法名 | 
|   | 
|         String nameSpace = "http://service.sljt.com"; // 填写调用省平台命名空间 | 
|         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; | 
|     } | 
|   | 
|   | 
|     /** | 
|      * 报文获取--替换数据 | 
|      * | 
|      * @param data | 
|      * @return | 
|      */ | 
|     public String webServiceXml(Api1203 data) { | 
|         String xmlStr = xml_webservice; | 
|         xmlStr = xmlStr.replace("{qydbh}", GDUtils.formatStr(data.getRkjydh()));//检验单编号 | 
|         xmlStr = xmlStr.replace("{kddm}", GDUtils.formatStr(data.getKqdm()));//库点代码 | 
|         xmlStr = xmlStr.replace("{hwdm}", GDUtils.formatStr(data.getHwdm()));//货位编码 | 
|         xmlStr = xmlStr.replace("{ypbm}", GDUtils.formatStr(data.getRkywdh()));//入库单编码 | 
|         xmlStr = xmlStr.replace("{qysj}", GDUtils.formatDate(data.getQysj(), "yyyy-MM-dd HH:mm:ss"));//扦样时间 | 
|         xmlStr = xmlStr.replace("{qyrxm}", GDUtils.formatStr(data.getQyrxm()));//扦样人姓名 | 
|         xmlStr = xmlStr.replace("{qylb}", GDUtils.formatStr(data.getQyfs()));//扦样类别 | 
|         xmlStr = xmlStr.replace("{jyxm}", GDUtils.formatStr(data.getJyxm()));//检验项目 | 
|         xmlStr = xmlStr.replace("{jyjg}", GDUtils.formatStr(data.getJyz()));//检验结果 | 
|         xmlStr = xmlStr.replace("{zkj}", GDUtils.formatStr(data.getZkj()));//增扣价 | 
|         xmlStr = xmlStr.replace("{zkl}", GDUtils.formatStr(data.getZkl()));//增扣量 | 
|         xmlStr = xmlStr.replace("{jyrxm}", GDUtils.formatStr(data.getJyrxm()));//检验人姓名 | 
|         xmlStr = xmlStr.replace("{jyjl}", GDUtils.formatStr(data.getJyjg()));//检验结论 | 
|         xmlStr = xmlStr.replace("{jysj}", GDUtils.formatDate(data.getJysj(), "yyyy-MM-dd HH:mm:ss"));//检验时间 | 
|         xmlStr = xmlStr.replace("{pzbm}", GDUtils.formatStr(data.getLspzdm()));//粮食品种编码 | 
|         xmlStr = xmlStr.replace("{lsdd}", GDUtils.formatStr(data.getLsdd()));//粮食定等 | 
|         xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//操作标志 | 
|         xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));//最后更新时间 | 
|         return xmlStr; | 
|     } | 
|   | 
|   | 
| } |