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 = "{qydbh}{ypbm}{qysj}{qyrxm}{jyxm}{jyjg}{zkj}{zkl}{jyrxm}{jysj}{jyjl}{pzbm}{lsdd}{czbz}{kddm}{hwdm}{zhgxsj}{qylb}"; 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; } }