package com.fzzy.push.gd2020.v2;

import com.fzzy.api.data.AuthToken;
import com.fzzy.api.entity.*;
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 GrainConditionCheckTempHumWebService {

    public static GrainConditionCheckTempHumWebService newInstance() {
        return new GrainConditionCheckTempHumWebService();
    }

    public String xml_webservice = "<?xml version=\"1.0\" encoding=\"utf8\"?><root><row id=\"lqjc_tj\"><kddm desc=\"库点代码\" type=\"varchar\" length=\"50\" requir=\"必填\">{kddm}</kddm><cfmc desc=\"仓房名称\" type=\"varchar\" length=\"50\" requir=\"必填\">{cfmc}</cfmc><lqjcbm desc=\"粮情监测编码\" type=\"varchar\" length=\"42\" requir=\"必填\">{lqjcbm}</lqjcbm><jcsj desc=\"监测时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{jcsj}</jcsj><hwbm desc=\"货位编码\" type=\"varchar\" length=\"30\" requir=\"必填\">{hwbm}</hwbm><cfww desc=\"仓房外温\" type=\"decimal\" length=\"9\" requir=\"必填\">{cfww}</cfww><cfws desc=\"仓房外湿\" type=\"decimal\" length=\"9\" requir=\"必填\">{cfws}</cfws><cfnw desc=\"仓房内温\" type=\"decimal\" length=\"9\" requir=\"必填\">{cfnw}</cfnw><cfns desc=\"仓房内湿\" type=\"decimal\" length=\"9\" requir=\"必填\">{cfns}</cfns><zgw desc=\"最高温\" type=\"decimal\" length=\"9\" requir=\"必填\">{zgw}</zgw><zdw desc=\"最低温\" type=\"decimal\" length=\"9\" requir=\"必填\">{zdw}</zdw><pjw desc=\"平均温\" type=\"decimal\" length=\"9\" requir=\"必填\">{pjw}</pjw><lswdzjh desc=\"粮食温度值集合\" type=\"varchar\" length=\"5000\" requir=\"必填\">{lswdzjh}</lswdzjh><zhgxsj desc=\"最后更新时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{zhgxsj}</zhgxsj><czbz desc=\"操作标志\" type=\"varchar\" length=\"1\" requir=\"必填\">{czbz}</czbz><lssdzjh desc=\"粮食湿度值集合\" type=\"varchar\" length=\"2000\" requir=\"可选\">{lssdzjh}</lssdzjh></row></root>";


    private String method = "saveTempHumRecord";// 填写数据方法名
    private String wsdl = "/grainConditionCheckTempHumWebService?wsdl";//填写调用库点信息接口服务
    private String nameSpace = "http://service.sljt.com";// 填写调用省平台命名空间


    public InvokeResult webService(AuthToken authToken,ApiConfs conf, Api1302 data, Api1105 api1105) {
        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, api1105);// 获取接口的输入报文，根据需要填写相应的报文

            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(Api1302 data, Api1105 api1105) {
        String xmlStr = xml_webservice;
        xmlStr = xmlStr.replace("{kddm}", GDUtils.formatStr(data.getKqdm()));//所属库点代码
        xmlStr = xmlStr.replace("{cfmc}", GDUtils.formatStr(api1105.getHwmc()));//仓房名称
        xmlStr = xmlStr.replace("{lqjcbm}", GDUtils.formatStr(data.getWsdjcdh()));//温湿度检测单号
        xmlStr = xmlStr.replace("{jcsj}", GDUtils.formatDate(data.getJcsj(), "yyyy-MM-dd HH:mm:ss"));//监测时间
        xmlStr = xmlStr.replace("{hwbm}", GDUtils.formatStr(data.getHwdm()));//货位编码
        xmlStr = xmlStr.replace("{cfww}", GDUtils.formatNum(data.getCfww()));//仓房外温
        xmlStr = xmlStr.replace("{cfnw}", GDUtils.formatNum(data.getCfnw()));//仓房内温
        xmlStr = xmlStr.replace("{cfns}", GDUtils.formatNum(data.getCfns()));//仓房内湿
        xmlStr = xmlStr.replace("{zgw}", GDUtils.formatNum(data.getLszgw()));//粮食最高温
        xmlStr = xmlStr.replace("{zdw}", GDUtils.formatNum(data.getLszdw()));//粮食最低温
        xmlStr = xmlStr.replace("{pjw}", GDUtils.formatNum(data.getLspjw()));//粮食平均温
        xmlStr = xmlStr.replace("{lswdzjh}", GDUtils.formatStr(data.getLswdzjh()));//粮食温度值集合
        xmlStr = xmlStr.replace("{lssdzjh}", GDUtils.formatStr(data.getLssdzjh()));//粮食湿度值集合
        xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//操作标志
        xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));//最后更新时间
        return xmlStr;
    }


}