czt
2024-11-26 e35480aba8cda53d68486ce45b49b0268a901614
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
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 = "<?xml version=\"1.0\" encoding=\"utf8\"?><root><row id=\"lqjc_ch\"><czbz desc=\"操作标志\" type=\"varchar\" length=\"3\" requir=\"必填\">{czbz}</czbz><zhgxsj desc=\"最后更新时间\" type=\"varchar\" length=\"3\" requir=\"必填\">{zhgxsj}</zhgxsj><hwdm desc=\"货位编码\" type=\"varchar\" length=\"30\" requir=\"必填\">{hwdm}</hwdm><lyzl desc=\"粮食与油料种类\" type=\"integer\" length=\"12\" requir=\"必填\">{lyzl}</lyzl><cjd desc=\"害虫检测单号\" type=\"varchar\" length=\"42\" requir=\"必填\">{cjd}</cjd><kddm desc=\"库点代码\" type=\"varchar\" length=\"50\" requir=\"必填\">{kddm}</kddm><cfmc desc=\"仓房名称\" type=\"varchar\" length=\"50\" requir=\"必填\">{cfmc}</cfmc><chmd desc=\"虫口密度值集合\" type=\"varchar\" length=\"8000\" requir=\"必填\">{chmd}</chmd><cjsj desc=\"检测时间\" type=\"datetime\" length=\"12\" requir=\"必填\">{cjsj}</cjsj><hczl desc=\"害虫种类\" type=\"varchar\" length=\"128\" requir=\"必填\">{hczl}</hczl><jchcff desc=\"检查害虫方法\" type=\"varchar\" length=\"1\" requir=\"必填\">{jchcff}</jchcff><cldjpd desc=\"虫粮等级判定\" type=\"varchar\" length=\"3\" requir=\"可选\">{cldjpd}</cldjpd><hckyxfx desc=\"害虫抗药分析\" type=\"varchar\" length=\"128\" requir=\"可选\">{hckyxfx}</hckyxfx><fsbw desc=\"发生部位\" type=\"varchar\" length=\"3\" requir=\"可选\">{fsbw}</fsbw></row></root>" ;
 
 
    /**
     * @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;
    }
 
}