YYC
2023-08-19 15c542eb3964bc33b5bfd00998f1bcd095bf1dfe
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
package com.fzzy.push.gd2020.v2;
 
import com.fzzy.api.data.AuthToken;
import com.fzzy.api.entity.Api1101;
import com.fzzy.api.entity.Api1106;
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/15
 */
@Slf4j
public class OilTankWebService {
 
    public static OilTankWebService newInstance() {
        return new OilTankWebService();
    }
 
    /**
     * 油罐信息-数据接口 -xml报文
     */
    public String xml_webservice = "<?xml version=\"1.0\" encoding=\"utf8\"?><root><row id=\"cfgl_oil_tank\"><sskd desc=\"所属库点代码\" type=\"varchar\" length=\"50\" requir=\"必填\">{sskd}</sskd><ygmc desc=\"油罐名称\" type=\"varchar\" length=\"20\" requir=\"必填\">{ygmc}</ygmc><ygbh desc=\"油罐编号\" type=\"varchar\" length=\"25\" requir=\"必填\">{ygbh}</ygbh><ygzr desc=\"油罐总容\" type=\"decimal\" length=\"20\" requir=\"必填\">{ygzr}</ygzr><ygzt desc=\"油罐状态\" type=\"varchar\" length=\"1\" requir=\"必填\">{ygzt}</ygzt><jzsj desc=\"建造时间\" type=\"varchar\" length=\"10\" requir=\"必填\">{jzsj}</jzsj><ygjfssssfwh desc=\"油罐及附属设施是否完好\" type=\"varchar\" length=\"1\" requir=\"必填\">{ygjfssssfwh}</ygjfssssfwh><ywjrzz desc=\"有无加热装置 \" type=\"varchar\" length=\"1\" requir=\"必填\">{ywjrzz}</ywjrzz><yglx desc=\"油罐类型\" type=\"varchar\" length=\"1\" requir=\"必填\">{yglx}</yglx><zj desc=\"罐内直径\" type=\"Decimal\" length=\"20\" requir=\"必填\">{zj}</zj><gd desc=\"罐内高度\" type=\"Decimal\" length=\"20\" requir=\"必填\">{gd}</gd><jdfs desc=\"检定方式\" type=\"varchar\" length=\"1\" requir=\"必填\">{jdfs}</jdfs><hjfs desc=\"焊接方式\" type=\"varchar\" length=\"1\" requir=\"必填\">{hjfs}</hjfs><ygsyqk desc=\"油罐使用情况\" type=\"varchar\" length=\"1\" requir=\"必填\">{ygsyqk}</ygsyqk><czbz desc=\"操作标志\" type=\"varchar\" length=\"1\" requir=\"必填\">{czbz}</czbz><zhgxsj desc=\"最后更新时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{zhgxsj}</zhgxsj></row></root>";
 
    private String method = "oilTankSaveRecordDetail";// 填写数据方法名
    private String wsdl = "/oilTankWebService?wsdl";//填写调用库点信息接口服务
    private String nameSpace = "http://service.sljt.com";// 填写调用省平台命名空间
 
 
    public InvokeResult webService(AuthToken authToken,ApiConfs conf, Api1106 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;
 
    }
 
    private String webServiceXml(Api1106 data) {
        String xmlStr = xml_webservice;
        xmlStr = xmlStr.replace("{sskd}", GDUtils.formatStr(data.getKqdm()));//T所属库点代码
        xmlStr = xmlStr.replace("{ygmc}", GDUtils.formatStr(data.getYgmc()));//油罐名称
        xmlStr = xmlStr.replace("{ygbh}", GDUtils.formatStr(data.getYgdm()));//油罐编号
        xmlStr = xmlStr.replace("{ygzr}", GDUtils.formatNum(data.getGr()));//油罐总容
        xmlStr = xmlStr.replace("{ygzt}", GDUtils.formatStr(data.getYgzt()));//油罐状态 1:完好2:需小修 3:需大修 4:待报废 5:待拆除 6:长期闲置9:其他
 
        xmlStr = xmlStr.replace("{jzsj}", GDUtils.formatDate(data.getJzsj(), "yyyy-MM-dd"));//建造时间
        xmlStr = xmlStr.replace("{ygjfssssfwh}", GDUtils.formatStr(data.getYgjfssssfwh()));//油罐及附属设施是否完好
        xmlStr = xmlStr.replace("{ywjrzz}", GDUtils.formatStr(data.getYwjrzz()));//有无加热装置
        xmlStr = xmlStr.replace("{yglx}", GDUtils.formatStr(data.getYglx()));//油罐类型
        xmlStr = xmlStr.replace("{zj}", GDUtils.formatNum(data.getGnzj()));//罐内直径
        xmlStr = xmlStr.replace("{gd}", GDUtils.formatNum(data.getGngd()));//罐内高度
        xmlStr = xmlStr.replace("{jdfs}", GDUtils.formatStr(data.getJdfs()));//检定方式
        xmlStr = xmlStr.replace("{hjfs}", GDUtils.formatStr(data.getHjfs()));//焊接方式
 
        xmlStr = xmlStr.replace("{ygsyqk}", "9");//油罐使用情况 1:空仓2:占用3:满货位4:入库中5:出库中6:维修9:其他
 
        xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//操作标志
        xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));//最后更新时间
 
        return xmlStr;
    }
}