package com.fzzy.push.gd2020.v2; import com.fzzy.api.data.AuthToken; import com.fzzy.api.entity.Api1105; import com.fzzy.api.entity.Api1210; 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/16 */ @Slf4j public class TransferNatureWebservice { public static TransferNatureWebservice newInstance() { return new TransferNatureWebservice(); } public String xml_webservice = "{xzzbdbh}{cfbh}{hwbm}{lssl}{hzsl}{bzwh}{lspz}{ykcxz}{zrxz}{hzsj}{kddm}{ccshr}{zjshr}{tjshr}{kjshr}{ldshr}{bz}{czbz}{zhgxsj}"; private String method = "transferNatureSaveRecordDetail";// 填写数据方法名 private String wsdl = "/transferNatureWebservice?wsdl";//填写调用库点信息接口服务 private String nameSpace = "http://service.sljt.com";// 填写调用省平台命名空间 public InvokeResult webService(AuthToken authToken,ApiConfs conf, Api1210 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(Api1210 data) { String xmlStr = xml_webservice; //根据货位代码截取 --具体需要根据广东省货位编码配置规则而定 String cfbh = data.getHwdm().substring(0, data.getHwdm().length() - 3); xmlStr = xmlStr.replace("{xzzbdbh}", GDUtils.formatStr(data.getLsxzzbdh()));//性质转变单编号 xmlStr = xmlStr.replace("{kddm}", GDUtils.formatStr(data.getKqdm()));//库点代码 xmlStr = xmlStr.replace("{cfbh}", GDUtils.formatStr(cfbh));//仓房编码 xmlStr = xmlStr.replace("{hwbm}", GDUtils.formatStr(data.getHwdm()));//货位编码 xmlStr = xmlStr.replace("{lssl}", GDUtils.formatNum(data.getLssl()));//粮食数量 xmlStr = xmlStr.replace("{hzsl}", GDUtils.formatNum(data.getHzsl()));//划转数量 xmlStr = xmlStr.replace("{bzwh}", GDUtils.formatStr(data.getBzwh()));//批准文号 xmlStr = xmlStr.replace("{lspz}", GDUtils.formatStr(data.getLspzdm()));//粮食品种 xmlStr = xmlStr.replace("{zrxz}", GDUtils.formatStr(data.getHzqlsxzdm()));//原库存性质 xmlStr = xmlStr.replace("{zrxz}", GDUtils.formatStr(data.getHzhlsxzdm()));//转入性质 xmlStr = xmlStr.replace("{qylxr}", GDUtils.formatDate(data.getHzrq(), "yyyy-MM-dd"));//划转时间 xmlStr = xmlStr.replace("{ccshr}", GDUtils.formatStr(data.getCcshr()));//仓储审核人 xmlStr = xmlStr.replace("{zjshr}", GDUtils.formatStr(data.getZjshr()));//质检审核人 xmlStr = xmlStr.replace("{tjshr}", GDUtils.formatStr(data.getTjshr()));//统计审核人 xmlStr = xmlStr.replace("{kjshr}", GDUtils.formatStr(data.getKjshr()));//会计审核人 xmlStr = xmlStr.replace("{ldshr}", GDUtils.formatStr(data.getLdshr()));//领导审核人 xmlStr = xmlStr.replace("{bz}", GDUtils.formatStr(data.getBz()));//备注 xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//操作标志 xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));//最后更新时间 return xmlStr; } }