package tqq9.lc123.cloud.app.plugin.utils;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import kd.bos.util.StringUtils;
import tqq9.lc123.cloud.app.eip.iscb.impl.LCLogServiceImpl;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

//北广、通天晓关闭、取消、接口
public class BillCloseCancelUtils {


    /**
     * 通天晓单据取消接口
     *
     * @param orderType     单据类型
     * @param warehouseCode 仓库编号
     * @param billNo        单据编号
     * @param entityType    单据标识
     * @param entityName    单据名称
     * @param label         推送标识
     * @return 取消结果
     */
    public static String wmsCancel(String orderType, String warehouseCode, String billNo, String entityType, String entityName, String label) {
        String method = "order.cancel";
        String message = null;
        Map<String, Object> request = new HashMap<>();
        request.put("warehouseCode", warehouseCode);
        request.put("ownerCode", "LICHI");
        request.put("orderCode", billNo);
        request.put("orderId", "");
        request.put("orderType", orderType);
        request.put("cancelReason", "");
        Map<String, Object> finalMap = new HashMap<>();
        finalMap.put("request", request);
        StringBuilder xmlBuilder = new StringBuilder();
        xmlBuilder.append("<?xml version=\"1.0\" encoding=\"utf-8\"?>\n");
        HttpRequestUtils.buildXml(xmlBuilder, finalMap, 0);
        String ttx_mainUrl = ConfigUtils.getThirdConfigByNumber("Ttx_MainURL");
        String ttx_customerId = ConfigUtils.getThirdConfigByNumber("Ttx_CustomerId");
        ttx_mainUrl = ttx_mainUrl + "?method=" + method + "&v=2.0&format=xml&customerId=" + ttx_customerId;
        Map<String, String> headMap = new HashMap<>();
        try {
            String result = HttpRequestUtils.postXml(ttx_mainUrl, xmlBuilder.toString(), headMap);
            if (StringUtils.isNotEmpty(result)) {
                JSONObject jsonObject = HttpRequestUtils.xmlToJson(result);
                JSONObject response = jsonObject.getJSONObject("response");
                String flag = response.getString("flag");
                String code = response.getString("code");
                message = response.getString("message");

                LCLogServiceImpl lcLogService = new LCLogServiceImpl();
                lcLogService.savelog(entityName, ttx_mainUrl, true, code.equals("200"), xmlBuilder.toString(), result);
                lcLogService.isSuccess(entityType, billNo, "billno", label, code.equals("200"));
            }

        } catch (
                IOException e) {
            throw new RuntimeException(e);
        }


        return message;


    }

    /**
     * 北广 收货通知单关闭（采购订单关闭）
     *
     * @param billNo     单据编号
     * @param url        接口地址，北京还是广州
     * @param entityType 单据标识
     * @param entityName 单据名称
     * @param label      推送标识
     * @return 关闭结果
     */
    public static String BGPurOrderCancel(String billNo, String url, String entityType, String entityName, String label) {
        String message = null;
        String method = "/api/PU/Close_PurOrder";
        Map<String, Object> bj_map = new HashMap<>();
        bj_map.put("cPOCode", billNo);
        String bjjsonBody = JSON.toJSONString(bj_map);
        try {
            String result = HttpRequestUtils.postJson(url + method, bjjsonBody, null);
            ObjectMapper objectMapper = new ObjectMapper();
            JsonNode rootNode = objectMapper.readTree(result);
            if (null != rootNode) {
                message = String.valueOf(rootNode.get("message"));
                String code = String.valueOf(rootNode.get("code"));
                LCLogServiceImpl lcLogService = new LCLogServiceImpl();
                lcLogService.savelog(entityName, url, true, code.equals("0"), bjjsonBody, result);
                lcLogService.isSuccess(entityType, billNo, "billno", label, code.equals("0"));
            }

        } catch (IOException e) {
            throw new RuntimeException(e);
        }
        return message;
    }

    /**
     * 北广 其他入库申请单取消
     *
     * @param billNo     单据编号
     * @param url        接口地址，北京还是广州
     * @param entityType 单据标识
     * @param entityName 单据名称
     * @param label      推送标识
     * @return 关闭结果
     */
    public static String BGCloseOtherVouchIn(String billNo, String url, String entityType, String entityName, String label) {
        String message = null;
        String method = "/api/WMS/Close_OtherVouchIn";
        Map<String, Object> bj_map = new HashMap<>();
        bj_map.put("cOVCode", billNo);
        String bjjsonBody = JSON.toJSONString(bj_map);
        try {
            String result = HttpRequestUtils.postJson(url + method, bjjsonBody, null);
            ObjectMapper objectMapper = new ObjectMapper();
            JsonNode rootNode = objectMapper.readTree(result);
            if (null != rootNode) {
                message = String.valueOf(rootNode.get("message"));
                String code = String.valueOf(rootNode.get("code"));
                LCLogServiceImpl lcLogService = new LCLogServiceImpl();
                lcLogService.savelog(entityName, url, true, code.equals("0"), bjjsonBody, result);
                lcLogService.isSuccess(entityType, billNo, "billno", label, code.equals("0"));
            }

        } catch (IOException e) {
            throw new RuntimeException(e);
        }
        return message;
    }



    /**
     * 北广 其他出库申请单取消
     *
     * @param billNo     单据编号
     * @param url        接口地址，北京还是广州
     * @param entityType 单据标识
     * @param entityName 单据名称
     * @param label      推送标识
     * @param orderType  业务类型
     * @return 关闭结果
     */
    public static String BGCloseOtherVouchOut(String billNo, String url, String entityType, String entityName, String label, String orderType) {
        String message = null;
        Map<String, Object> bj_map = new HashMap<>();
        String method;//其他出库撤销
        if ("DBCK".equals(orderType)) {
            method = "/api/WMS/Cancel_TransVouch";//调拨出库撤销
            bj_map.put("cTVCode",billNo);
        }else {
            method = "/api/WMS/Cancel_OtherVouchOut";
            bj_map.put("cOVCode", billNo);
        }

        String bjjsonBody = JSON.toJSONString(bj_map);
        try {
            String result = HttpRequestUtils.postJson(url + method, bjjsonBody, null);
            ObjectMapper objectMapper = new ObjectMapper();
            JsonNode rootNode = objectMapper.readTree(result);
            if (null != rootNode) {
                message = String.valueOf(rootNode.get("message"));
                String code = String.valueOf(rootNode.get("code"));
                LCLogServiceImpl lcLogService = new LCLogServiceImpl();
                lcLogService.savelog(entityName, url, true, code.equals("0"), bjjsonBody, result);
                lcLogService.isSuccess(entityType, billNo, "billno", label, code.equals("0"));
            }

        } catch (IOException e) {
            throw new RuntimeException(e);
        }
        return message;
    }

    /**
     * 北广 采购退货申请单取消（采购退货拦截）
     *
     * @param billNo     单据编号
     * @param url        接口地址，北京还是广州
     * @param entityType 单据标识
     * @param entityName 单据名称
     * @param label      推送标识
     * @return 关闭结果
     */
    public static String BGPuCancelPurReturn(String billNo, String url, String entityType, String entityName, String label) {
        String message = null;
        String method = "/api/PU/Cancel_PurReturn";
        Map<String, Object> bj_map = new HashMap<>();
        bj_map.put("cPRCode", billNo);
        String bjjsonBody = JSON.toJSONString(bj_map);
        try {
            String result = HttpRequestUtils.postJson(url + method, bjjsonBody, null);
            ObjectMapper objectMapper = new ObjectMapper();
            JsonNode rootNode = objectMapper.readTree(result);
            if (null != rootNode) {
                message = String.valueOf(rootNode.get("message"));
                String code = String.valueOf(rootNode.get("code"));
                LCLogServiceImpl lcLogService = new LCLogServiceImpl();
                lcLogService.savelog(entityName, url, true, code.equals("0"), bjjsonBody, result);
                lcLogService.isSuccess(entityType, billNo, "billno", label, code.equals("0"));
            }

        } catch (IOException e) {
            throw new RuntimeException(e);
        }
        return message;
    }
}