package com.fzzy.push.gd2020.v2; import com.fzzy.api.data.AuthToken; import com.fzzy.api.entity.Api1310; 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 ZlglInventoryWebservice { public static ZlglInventoryWebservice newInstance() { return new ZlglInventoryWebservice(); } public String xml_Webservice = "{kddm}{kddm}{hwbm}{varieties}{level}{rkrq}{jylbbm}{jydw}{jyyj}{zblb}{jyxm}{jyxmz}{zlzbjgpd}{shrxm}{czbz}{zhgxsj}{qysj}{qyqy}{qyrxm}{ypsl}{dbsl}{ypdj}{sfzcccnx}{crklx}{pch}{bz}{jdrxm}{ypbh}{qydbh}{qfrq}{bgcjsj}{jyr}{jysj}"; public InvokeResult Webservice(AuthToken authToken, ApiConfs conf, Api1310 data) { InvokeResult invokeResult = new InvokeResult(); ClassLoader cl = Thread.currentThread().getContextClassLoader(); String url = conf.getApiUrl() + "/zlglInventoryWebservice?wsdl"; //填写调用库存质量数据接口服务 String method = "zlglInventorySaveRecordBase"; //填写库存质量数据方法名 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 = zlglInventoryWebserviceXml(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 zlglInventoryWebserviceXml(Api1310 data) { String xmlStr = xml_Webservice; xmlStr = xmlStr.replace("{kddm}", GDUtils.formatStr(data.getKqdm()));//库点代码 xmlStr = xmlStr.replace("{hwbm}", GDUtils.formatStr(data.getHwdm()));//货位编码 xmlStr = xmlStr.replace("{zjbgdbh}", GDUtils.formatStr(data.getZbjgpd()));//质检报告单编码 xmlStr = xmlStr.replace("{varieties}", GDUtils.formatStr(data.getLspzdm()));//粮食品种 xmlStr = xmlStr.replace("{level}", GDUtils.formatStr(data.getLsdjdm()));//粮食等级 xmlStr = xmlStr.replace("{rkrq}", GDUtils.formatDate(data.getRkrq(), "yyyy-MM-dd"));//入库日期 xmlStr = xmlStr.replace("{jysj}", GDUtils.formatDate(data.getJysj(), "yyyy-MM-dd HH:mm:ss"));//检验时间 xmlStr = xmlStr.replace("{qfrq}", GDUtils.formatDate(data.getQfrq(), "yyyy-MM-dd"));//签发时间 xmlStr = xmlStr.replace("{bgcjsj}", GDUtils.formatDate(data.getBgcjsj(), "yyyy-MM-dd HH:mm:ss"));//报告出具时间 xmlStr = xmlStr.replace("{jylbbm}", GDUtils.formatStr(data.getJylb()));//检验类别编码 01:入仓验收 02:出仓检验 xmlStr = xmlStr.replace("{jyr}", GDUtils.formatStr(data.getJyr()));//检验人 xmlStr = xmlStr.replace("{jyyj}", GDUtils.formatStr(data.getJyyj()));//检验依据 xmlStr = xmlStr.replace("{zblb}", GDUtils.formatStr(data.getZblb()));//指标类别 xmlStr = xmlStr.replace("{jyxm}", GDUtils.formatStr(data.getJyxm()));//检验项目 xmlStr = xmlStr.replace("{jyxmz}", GDUtils.formatStr(data.getJyxmz()));//检验项目值 xmlStr = xmlStr.replace("{qyqy}", GDUtils.formatStr(data.getQyqy()));//扦样区域 xmlStr = xmlStr.replace("{qyrxm}", GDUtils.formatStr(data.getQyrxm()));//扦样人姓名 xmlStr = xmlStr.replace("{ypbh}", GDUtils.formatStr(data.getYpbh()));//样品编号 xmlStr = xmlStr.replace("{ypdj}", GDUtils.formatStr(data.getYpdj()));//样品等级 xmlStr = xmlStr.replace("{ypsl}", GDUtils.formatNum(data.getYpsl()));//样品数量 xmlStr = xmlStr.replace("{ybsl}", GDUtils.formatNum(data.getDbsl()));//代表数量 xmlStr = xmlStr.replace("{sfzcccnx}", GDUtils.formatStr(data.getSfzcccnx()));//是否正常存储年限 xmlStr = xmlStr.replace("{bz}", GDUtils.formatStr(data.getBz()));//备注 String ywdh = ""; //出入库类型 0:入库1:出库2:在库 9:其他 if ("01".equals(data.getJylb())) { xmlStr = xmlStr.replace("{crklx}", GDUtils.formatStr("0")); // 出库业务单号-- 由 12 位数字组成,第 1-2 位为业务编码 (14 代表粮食入库),第3-8 位依次为年份的后两位、2 位月份、2 位日期,后四位为顺序码。例如:141605041234 ywdh = "14" + data.getBizId().substring(2); } if ("02".equals(data.getJylb())) { xmlStr = xmlStr.replace("{crklx}", GDUtils.formatStr("1")); // 出库业务单号-- 由 12 位数字组成,第 1-2 位为业务编码 (15 代表粮食出库),第3-8 位依次为年份的后两位、2 位月份、2 位日期,后四位为顺序码。例如:141605041234 ywdh = "15" + data.getBizId().substring(2); } xmlStr = xmlStr.replace("{pch}", GDUtils.formatStr(ywdh));//出入库批次号 xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//操作标志 xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));//最后更新时间 return xmlStr; } }