package com.fzzy.push.gd2020.v2; import com.fzzy.api.data.AuthToken; import com.fzzy.api.entity.Api1103; import com.fzzy.api.entity.Api1303; 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 GrainConditionCheckWormWebservice { public static GrainConditionCheckWormWebservice newInstance() { return new GrainConditionCheckWormWebservice(); } public String xml_webservice = "{czbz}{zhgxsj}{hwdm}{lyzl}{cjd}{kddm}{cfmc}{chmd}{cjsj}{hczl}{jchcff}{cldjpd}{hckyxfx}{fsbw}" ; /** * @Desc: 虫害-数据接口 */ public InvokeResult webservice(AuthToken authToken,ApiConfs conf, Api1303 data,Api1103 api1103) { InvokeResult invokeResult = new InvokeResult(); ClassLoader cl = Thread.currentThread().getContextClassLoader(); String url = conf.getApiUrl() + "/companyWebService?wsdl"; // 填写调用仓储单位信息接口服务 String method = "companySaveRecordDetail"; // 填写数据方法名 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 = companyWebServiceXml(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; } /** * 报文获取--替换数据 * * @param data * @return */ public String companyWebServiceXml(Api1303 data, Api1103 api1103) { String xmlStr = xml_webservice; xmlStr = xmlStr.replace("{kddm}", GDUtils.formatStr(data.getKqdm()));//库点代码 xmlStr = xmlStr.replace("{cfmc}", GDUtils.formatStr(api1103.getCfmc()));//仓房名称 xmlStr = xmlStr.replace("{hwdm}", GDUtils.formatStr(data.getHwdm()));//货位编码 xmlStr = xmlStr.replace("{lyzl}", "1");//TODO 粮食与油料种类 1:原粮 2:成品粮 xmlStr = xmlStr.replace("{cjd}", GDUtils.formatStr(data.getHcjcdh()));//害虫检测单号 xmlStr = xmlStr.replace("{chmd}", GDUtils.formatStr(data.getCkmdzjh()));//虫口密度值集合 xmlStr = xmlStr.replace("{hczl}", GDUtils.formatStr(data.getHczl()));//害虫种类 xmlStr = xmlStr.replace("{jchcff}", GDUtils.formatStr(data.getJchcff()));//检查害虫方法 xmlStr = xmlStr.replace("{cldjpd}", GDUtils.formatStr(data.getCldjpd()));//虫粮等级判定 xmlStr = xmlStr.replace("{fsbw}", GDUtils.formatStr(data.getFsbw()));//发生部位 xmlStr = xmlStr.replace("{hckyxfx}", GDUtils.formatStr(data.getHckyxfx()));//害虫抗药性分析 xmlStr = xmlStr.replace("{cjsj}", GDUtils.formatDate(data.getJcsj(), "yyyy-MM-dd"));//检测时间 xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//操作标志 xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));//最后更新时间 return xmlStr; } }