package com.fzzy.push.gd2020.v2;

import com.fzzy.api.data.AuthToken;
import com.fzzy.api.entity.Api1103;
import com.fzzy.api.entity.Api1304;
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 GrainConditionCheckGasWebservice {

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


    public String xml_webservice = "<?xml version=\"1.0\" encoding=\"utf8\"?><root><row id=\"lqjc_qt\"><kddm desc=\"库点代码\" type=\"varchar\" length=\"50\" requir=\"必填\">{kddm}</kddm><cfmc desc=\"仓房名称\" type=\"varchar\" length=\"50\" requir=\"必填\">{cfmc}</cfmc><qtndjcdh desc=\"气体浓度检测单号\" type=\"varchar\" length=\"42\" requir=\"必填\">{qtndjcdh}</qtndjcdh><czbz desc=\"操作标志\" type=\"varchar\" length=\"1\" requir=\"必填\">{czbz}</czbz><zhgxsj desc=\"最后更新时间\" type=\"varchar\" length=\"50\" requir=\"必填\">{zhgxsj}</zhgxsj><cjsj desc=\"采集时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{cjsj}</cjsj><hwdm desc=\"货位编码\" type=\"varchar\" length=\"50\" requir=\"必填\">{hwdm}</hwdm><cnyyht desc=\"一氧化碳含量值集合\" type=\"varchar\" length=\"8000\" requir=\"可选\">{cnyyht}</cnyyht><cnlxf desc=\"硫酰氟浓度值集合\" type=\"varchar\" length=\"8000\" requir=\"可选\">{cnlxf}</cnlxf><cnyq desc=\"仓内氧气含量\" type=\"varchar\" length=\"8000\" requir=\"可选\">{cnyq}</cnyq><cneyht desc=\"仓内二氧化碳含量\" type=\"varchar\" length=\"8000\" requir=\"可选\">{cneyht}</cneyht><cnlhq desc=\"仓内磷化氢气体含量\" type=\"varchar\" length=\"8000\" requir=\"可选\">{cnlhq}</cnlhq><cnyyhd desc=\"一氧化氮含量值集合\" type=\"varchar\" length=\"8000\" requir=\"可选\">{cnyyhd}</cnyyhd></row></root>";


    public InvokeResult webservice(AuthToken authToken, ApiConfs conf, Api1304 data, Api1103 api1103) {
        InvokeResult invokeResult = new InvokeResult();

        ClassLoader cl = Thread.currentThread().getContextClassLoader();


        String url = conf.getApiUrl() + "/grainConditionCheckGasWebservice?wsdl"; // 填写调用气体数据接口服务
        String method = "grainConditionCheckGasSaveRecordBase"; // 填写气体数据方法名

        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 = webserviceXml(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 webserviceXml(Api1304 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("{cnyq}", GDUtils.formatStr(data.getYqhlzjh()));//氧气含量值集合
        xmlStr = xmlStr.replace("{cneyht}", GDUtils.formatStr(data.getEyhthlzjh()));//二氧化碳含量值集合
        xmlStr = xmlStr.replace("{cnlhq}", GDUtils.formatStr(data.getLhqndzjh()));//磷化氢浓度值集合
        xmlStr = xmlStr.replace("{cnlhq}", GDUtils.formatStr(data.getLxfndzjh()));//硫酰氟浓度值集合
        xmlStr = xmlStr.replace("{cnyyhd}", GDUtils.formatStr(data.getYyhdhlzjh()));//一氧化氮含量值集合
        xmlStr = xmlStr.replace("{cnyyht}", GDUtils.formatStr(data.getYyhthlzjh()));//一氧化碳含量值集合
        xmlStr = xmlStr.replace("{qtndjcdh}", GDUtils.formatStr(data.getQtndjcdh()));//气体浓度检测单号
        xmlStr = xmlStr.replace("{cjsj}", GDUtils.formatDate(data.getJcsj(), "yyyy-MM-dd HH:mm:ss"));//采集时间
        xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//操作标志
        xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));//最后更新时间
        return xmlStr;
    }
}