package com.fzzy.push.gd2020.v2;


import com.fzzy.api.data.AuthToken;
import com.fzzy.api.entity.Api1209;
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/16
 */
@Slf4j
public class IncomeStatementWebservice {

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

    public String xml_webservice = "<?xml version=\"1.0\" encoding=\"utf8\"?><root><row id=\"income_statement\"><cksl desc=\"出库数量\" type=\"decimal\" length=\"9\" requir=\"必填\">{}</cksl><rksj desc=\"入库时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{}</rksj><sydbh desc=\"损溢单编号\" type=\"varchar\" length=\"32\" requir=\"必填\">{}</sydbh><hwbm desc=\"货位编码\" type=\"varchar\" length=\"30\" requir=\"必填\">{}</hwbm><rksl desc=\"入库数量\" type=\"decimal\" length=\"9\" requir=\"必填\">{}</rksl><cksj desc=\"出库时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{}</cksj><sysl desc=\"损溢数量\" type=\"decimal\" length=\"9\" requir=\"必填\">{}</sysl><syyy desc=\"损溢原因\" type=\"varchar\" length=\"200\" requir=\"必填\">{}</syyy><czbz desc=\"操作标志\" type=\"varchar\" length=\"1\" requir=\"必填\">{}</czbz><ywrq desc=\"业务日期\" type=\"varchar\" length=\"10\" requir=\"必填\">{}</ywrq><zhgxsj desc=\"最后更新时间\" type=\"varchar\" length=\"19\" requir=\"必填\">{}</zhgxsj><kddm desc=\"库点代码\" type=\"varchar\" length=\"32\" requir=\"必填\">{}</kddm><ccshr desc=\"仓储审核人\" type=\"varchar\" length=\"32\" requir=\"可选\">{}</ccshr><zjshr desc=\"质检审核人\" type=\"varchar\" length=\"32\" requir=\"可选\">{}</zjshr><tjshr desc=\"统计审核人\" type=\"varchar\" length=\"32\" requir=\"可选\">{}</tjshr><kjshr desc=\"会计审核人\" type=\"varchar\" length=\"32\" requir=\"可选\">{}</kjshr><ldshr desc=\"领导审核人\" type=\"varchar\" length=\"32\" requir=\"可选\">{}</ldshr><bz desc=\"备注\" type=\"varchar\" length=\"200\" requir=\"可选\">{}</bz><ckzz desc=\"出库杂质\" type=\"decimal\" length=\"9\" requir=\"可选\">{}</ckzz><rksf desc=\"入库水分\" type=\"decimal\" length=\"9\" requir=\"可选\">{}</rksf><rkzz desc=\"入库杂质\" type=\"decimal\" length=\"9\" requir=\"可选\">{}</rkzz><cksf desc=\"出库水分\" type=\"decimal\" length=\"9\" requir=\"可选\">{}</cksf></row></root>";

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


    /**
     * @Desc: 损溢单-数据接口
     */
    public InvokeResult webService(AuthToken authToken,ApiConfs conf, Api1209 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(Api1209 data) {
        String xmlStr = xml_webservice;
        xmlStr = xmlStr.replace("{sydbh}", GDUtils.formatStr(data.getSydh()));//损溢单编号
        xmlStr = xmlStr.replace("{kddm}", GDUtils.formatStr(data.getKqdm()));//库点代码
        xmlStr = xmlStr.replace("{hwbm}", GDUtils.formatStr(data.getHwdm()));//货位编码
        xmlStr = xmlStr.replace("{ywrq}", GDUtils.formatDate(data.getYwrq(), "yyyy-MM-dd"));//业务日期
        xmlStr = xmlStr.replace("{rksl}", GDUtils.formatNum(data.getRkjz()));//入库数量
        xmlStr = xmlStr.replace("{rksj}", GDUtils.formatDate(data.getRksj(), "yyyy-MM-dd HH:mm:ss"));//入库时间
        xmlStr = xmlStr.replace("{rksf}", GDUtils.formatNum(data.getRksf()));//入库水分
        xmlStr = xmlStr.replace("{rkzz}", GDUtils.formatNum(data.getRkzz()));//入库杂质
        xmlStr = xmlStr.replace("{cksl}", GDUtils.formatNum(data.getCkjz()));//出库数量
        xmlStr = xmlStr.replace("{cksj}", GDUtils.formatDate(data.getCksj(), "yyyy-MM-dd HH:mm:ss"));//出库时间
        xmlStr = xmlStr.replace("{ckzz}", GDUtils.formatNum(data.getCkzz()));//出库杂质
        xmlStr = xmlStr.replace("{sysl}", GDUtils.formatNum(data.getJzsysl()));//损溢数量
        xmlStr = xmlStr.replace("{syyy}", GDUtils.formatStr(data.getSyyy()));//损溢原因
        xmlStr = xmlStr.replace("{ccshr}", GDUtils.formatStr(data.getCcshr()));//仓储审核人
        xmlStr = xmlStr.replace("{zjshr}", GDUtils.formatStr(data.getZjshr()));//质检审核人
        xmlStr = xmlStr.replace("{tjshr}", GDUtils.formatStr(data.getTjshr()));//统计审核人
        xmlStr = xmlStr.replace("{ldshr}", GDUtils.formatStr(data.getLdshr()));//领导审核人
        xmlStr = xmlStr.replace("{bz}", GDUtils.formatStr(data.getBz()));//备注

        xmlStr = xmlStr.replace("{czbz}", GDUtils.formatStr(data.getCzbz()));//操作标志
        xmlStr = xmlStr.replace("{zhgxsj}", GDUtils.formatDate(data.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));//最后更新时间

        return xmlStr;

    }
}