package cn.lili.modules.logistics.plugin.shunfeng;

import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import cn.lili.common.enums.ResultCode;
import cn.lili.common.exception.ServiceException;
import cn.lili.common.utils.SpringContextUtil;
import cn.lili.modules.logistics.LogisticsPlugin;
import cn.lili.modules.logistics.entity.dto.LabelOrderDTO;
import cn.lili.modules.logistics.entity.enums.LogisticsEnum;
import cn.lili.modules.order.order.entity.dos.Order;
import cn.lili.modules.order.order.entity.dos.OrderItem;
import cn.lili.modules.order.order.entity.vo.OrderDetailVO;
import cn.lili.modules.store.entity.dto.StoreDeliverGoodsAddressDTO;
import cn.lili.modules.store.service.StoreDetailService;
import cn.lili.modules.system.entity.dos.Logistics;
import cn.lili.modules.system.entity.dto.LogisticsSetting;
import cn.lili.modules.system.entity.vo.Traces;
import com.sf.csim.express.service.CallExpressServiceTools;
import com.sf.csim.express.service.HttpClientUtil;
import com.sf.csim.express.service.IServiceCodeStandard;
import com.sf.csim.express.service.code.ExpressServiceCodeEnum;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import java.io.UnsupportedEncodingException;
import java.util.*;

/**
 * 顺丰插件
 * @author admin
 */
@Slf4j
public class ShunfengPlugin implements LogisticsPlugin {

    /**
     * ExpressServiceCodeEnum 对应速运类-快递APIs
     * POSTServiceCodeEnum 对应速运类-驿站APIs
     * YJTServiceCodeEnum 对应解决方案-医寄通APIs
     * EPSServiceCodeEnum 对应解决方案-快递管家APIs
     * 详情见code目录下枚举类，客户可自行修改引用的该类
     **/
    private LogisticsSetting logisticsSetting;

    public ShunfengPlugin(){}

    public ShunfengPlugin(LogisticsSetting logisticsSetting) {
        this.logisticsSetting = logisticsSetting;
    }

    @Override
    public LogisticsEnum pluginName() {
        return LogisticsEnum.SHUNFENG;
    }

    /**
     * 文档地址：https://open.sf-express.com/Api/ApiDetails?level3=393&interName=%E4%B8%8B%E8%AE%A2%E5%8D%95%E6%8E%A5%E5%8F%A3-EXP_RECE_CREATE_ORDER
     *
     * @param orderDetailVO
     */
    public String createOrder(OrderDetailVO orderDetailVO) {
        StoreDetailService storeService = SpringContextUtil.getBean(StoreDetailService.class);
        StoreDeliverGoodsAddressDTO storeDeliverGoodsAddressDTO = storeService.getStoreDeliverGoodsAddressDto(orderDetailVO.getOrder().getStoreId());
        if(storeDeliverGoodsAddressDTO == null){
            throw new ServiceException(ResultCode.STORE_DELIVER_ADDRESS_EXIST);
        }
        try {
            Order order = orderDetailVO.getOrder();
            Map<String, Object> msgDataMap = new HashMap<String, Object>();
            msgDataMap.put("language", "zh-CN");
            msgDataMap.put("orderId", order.getSn());
            //托寄物信息
            List<Map<String, Object>> cargoDetails = new ArrayList<>();
            for (OrderItem orderItem : orderDetailVO.getOrderItems()) {
                Map<String, Object> map = new HashMap<>();
                map.put("name", orderItem.getGoodsName());
                cargoDetails.add(map);
            }
            msgDataMap.put("cargoDetails", cargoDetails);

            //收寄双方信息
            List<Map<String, Object>> contactInfoList = new ArrayList<>();
            Map<String, Object> storeContactInfoMap = new HashMap<>();
            storeContactInfoMap.put("contactType", 1);
            storeContactInfoMap.put("contact", storeDeliverGoodsAddressDTO.getSalesConsignorName());
            storeContactInfoMap.put("mobile", storeDeliverGoodsAddressDTO.getSalesConsignorMobile());
            //国家或地区2位代码 参照附录
            storeContactInfoMap.put("country", "CN");
            //详细地址，若有四级行政区划，如镇/街道等信息可拼接至此字段，格式样例：镇/街道+详细地址。若province/city 字段的值不传，此字段必须包含省市信息，避免影响原寄地代码识别，如：广东省深圳市福田区新洲十一街万基商务大厦10楼；此字段地址必须详细，否则会影响目的地中转识别；
            storeContactInfoMap.put("address", storeDeliverGoodsAddressDTO.getSalesConsignorAddressPath() + storeDeliverGoodsAddressDTO.getSalesConsignorDetail());
            contactInfoList.add(storeContactInfoMap);

            Map<String, Object> memberContactInfoMap = new HashMap<>();
            memberContactInfoMap.put("contactType", 2);
            memberContactInfoMap.put("contact", order.getConsigneeName());
            memberContactInfoMap.put("mobile", order.getConsigneeMobile());
            //国家或地区2位代码 参照附录
            memberContactInfoMap.put("country", "CN");
            //详细地址，若有四级行政区划，如镇/街道等信息可拼接至此字段，格式样例：镇/街道+详细地址。若province/city 字段的值不传，此字段必须包含省市信息，避免影响原寄地代码识别，如：广东省深圳市福田区新洲十一街万基商务大厦10楼；此字段地址必须详细，否则会影响目的地中转识别；
            memberContactInfoMap.put("address", order.getConsigneeAddressPath() + order.getConsigneeDetail());
            contactInfoList.add(memberContactInfoMap);
            msgDataMap.put("contactInfoList", contactInfoList);

            msgDataMap.put("expressTypeId", 1);
            msgDataMap.put("isReturnRoutelabel", 1);


            String result = sendPost(ExpressServiceCodeEnum.EXP_RECE_CREATE_ORDER, msgDataMap);
            JSONObject resultData = JSONUtil.parseObj(result).getJSONObject("apiResultData");
            if(Boolean.TRUE.toString().equals(resultData.get("success").toString())){
                return resultData.getJSONObject("msgData").getJSONArray("waybillNoInfoList").getJSONObject(0).get("waybillNo").toString();
            }
            throw new ServiceException(resultData.get("errorMsg").toString());
        } catch (UnsupportedEncodingException e) {
            throw new RuntimeException(e);
        }
    }

    /**
     * 文档地址：https://open.sf-express.com/Api/ApiDetails?apiServiceCode=EXP_RECE_SEARCH_ROUTES&category=1&apiClassify=1&interName=%E8%B7%AF%E7%94%B1%E6%9F%A5%E8%AF%A2%E6%8E%A5%E5%8F%A3-EXP_RECE_SEARCH_ROUTES
     *
     * @param logistics 物流公司
     * @param expNo
     * @param phone
     * @return
     */
    @Override
    public Traces pollQuery(Logistics logistics, String expNo, String phone) {
        try {
            Map<String, Object> msgDataMap = new HashMap<String, Object>();
            msgDataMap.put("language", "zh-CN");
            /**
             * 查询号类别:
             * 1:根据顺丰运单号查询,trackingNumber将被当作顺丰运单号处理
             * 2:根据客户订单号查询,trackingNumber将被当作客户订单号处理
             */
            msgDataMap.put("trackingType", 1);
            List<String> trackingNumber = new ArrayList<>();
            trackingNumber.add(expNo);
            msgDataMap.put("trackingNumber", trackingNumber);
            JSONObject result = JSONUtil.parseObj(sendPost(ExpressServiceCodeEnum.EXP_RECE_SEARCH_ROUTES, msgDataMap));
            JSONObject resultData = result.getJSONObject("apiResultData");
            if(Boolean.TRUE.toString().equals(resultData.get("success").toString())){
                JSONArray routesJson = resultData.getJSONObject("msgData").getJSONArray("routeResps").getJSONObject(0).getJSONArray("routes");
                List<Map> routes = routesJson.toList(Map.class);
                return new Traces(logistics.getName(),expNo,routes);
            }
        } catch (UnsupportedEncodingException e) {
            throw new RuntimeException(e);
        }
        return null;
    }

    @Override
    public Traces pollMapTrack(Logistics logistics, String expNo, String phone, String from, String to) {
        return null;
    }

    /**
     * 文档地址：http://open.sf-express.com/Api/ApiDetails?level3=317&interName=%E4%BA%91%E6%89%93%E5%8D%B0%E9%9D%A2%E5%8D%952.0%E6%8E%A5%E5%8F%A3-COM_RECE_CLOUD_PRINT_WAYBILLS
     *
     * @param labelOrderDTO 电子面单DTO
     * @return
     */
    @Override
    public Map<String,Object> labelOrder(LabelOrderDTO labelOrderDTO) {
        try {
            Map<String, Object> msgDataMap = new HashMap<>();
            //模板编码
            //关联云打印接口后，点击查看，可在接口详情页获取模板编码，类似：fm_76130_standard_{partnerId}
            msgDataMap.put("templateCode", logisticsSetting.getTemplateCode());
            //业务数据
            Map<String, Object> documents = new HashMap<>();
            documents.put("masterWaybillNo", labelOrderDTO.getOrder().getLogisticsNo());
            msgDataMap.put("documents",documents);
            msgDataMap.put("sync",true);
            /**
             * 版本号，传固定值:2.0
             */
            msgDataMap.put("version", "2.0");
            JSONObject result = JSONUtil.parseObj(sendPost(ExpressServiceCodeEnum.COM_RECE_CLOUD_PRINT_WAYBILLS, msgDataMap));
            JSONObject resultData = result.getJSONObject("apiResultData");
            if(Boolean.TRUE.toString().equals(resultData.get("success").toString())){
                return resultData.getJSONObject("obj").getJSONArray("files").toList(Map.class).get(0);
            }
            throw new ServiceException(resultData.getJSONArray("errorMessage").get(0).toString());
        } catch (UnsupportedEncodingException e) {
            throw new RuntimeException(e);
        }
    }

    /**
     * 文档地址：https://open.sf-express.com/Api/ApiDetails?level3=409&interName=%E9%A2%84%E8%AE%A1%E6%B4%BE%E9%80%81%E6%97%B6%E9%97%B4%E6%8E%A5%E5%8F%A3-EXP_RECE_SEARCH_PROMITM
     *
     * @param searchNo
     * @param checkNos
     */
    public String searchPromitm(String searchNo, String checkNos) {
        try {
            Map<String, Object> msgDataMap = new HashMap<String, Object>();
            //顺丰运单号
            msgDataMap.put("searchNo", searchNo);
            //校验类型 1，电话号码校验 2，月结卡号校验
            msgDataMap.put("checkType", 1);
            //校验值 当校验类型为1时传电话号码 当校验类型为2时传月结卡号
            List<String> mobileList= new ArrayList<>();
            mobileList.add(checkNos);
            msgDataMap.put("checkNos", mobileList);
            JSONObject result = JSONUtil.parseObj(sendPost(ExpressServiceCodeEnum.EXP_RECE_SEARCH_PROMITM, msgDataMap));
            JSONObject resultData = result.getJSONObject("apiResultData");
            if(Boolean.TRUE.toString().equals(resultData.get("success").toString())){
                return  resultData.getJSONObject("msgData").get("promiseTm").toString();
            }
            throw new ServiceException(resultData.get("errorMsg").toString());
        } catch (UnsupportedEncodingException e) {
            throw new RuntimeException(e);
        }
    }

    private String sendPost(IServiceCodeStandard standardService, Map<String, Object> msgDataMap) throws UnsupportedEncodingException {
        CallExpressServiceTools tools = CallExpressServiceTools.getInstance();
        Map<String, String> params = new HashMap<String, String>();
        String timeStamp = String.valueOf(System.currentTimeMillis());
        // 顾客编码
        params.put("partnerID", logisticsSetting.getClientCode());
        params.put("requestID", UUID.randomUUID().toString().replace("-", ""));
        // 接口服务码
        params.put("serviceCode", standardService.getCode());
        params.put("timestamp", timeStamp);
        params.put("msgData", JSONUtil.toJsonStr(msgDataMap));

        params.put("msgDigest", tools.getMsgDigest(params.get("msgData"), timeStamp, logisticsSetting.getCheckWord()));
        String result = HttpClientUtil.post(logisticsSetting.getCallUrl(), params);

        log.info("===调用地址 ===" + logisticsSetting.getCallUrl());
        log.info("===顾客编码 ===" + logisticsSetting.getClientCode());
        log.info("===返回结果：" + result);

        return result;
    }
}