package com.ld.igds.warn.service;

import com.ld.igds.constant.RedisConst;
import com.ld.igds.constant.WarnLevel;
import com.ld.igds.constant.WarnType;
import com.ld.igds.data.ConfigData;
import com.ld.igds.inout.dto.InoutData;
import com.ld.igds.models.MWarnConf;
import com.ld.igds.util.ContextUtil;
import com.ld.igds.util.RedisUtil;
import com.ld.igds.warn.WarnUtils;
import com.ld.igds.warn.data.MsgRequest;
import com.ld.igds.warn.data.MsgResponse;
import com.ld.igds.warn.data.WarnData;
import com.ld.igds.warn.data.WarnParam;
import com.ld.igds.warn.mapper.WarnMapper;
import com.ld.igds.work.dto.ApplyOrderParam;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.time.DateFormatUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;

import java.util.Date;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;

/**
 * @author chen
 */
@Slf4j
@Component
public class CoreWarnServiceImpl implements CoreWarnService {

    @Autowired
    private ConfigData configData;
    @Autowired
    private RestTemplate restTemplate;
    @Autowired
    private WarnMapper warnMapper;
    @Autowired
    private RedisUtil redisUtil;
    @Autowired
    private WarnUtils warnUtils;

    @Override
    public List<WarnData> queryWarn(WarnParam param) {
        return warnMapper.queryWarn(param);
    }

    @Override
    public void addWarn(WarnData param) {
        warnMapper.saveWarn(param);
    }

    @Override
    public String addWarnAndNotice(WarnData param) {

        if (null == param) {
            return "警告信息为空，执行失败";
        }

        if (null == param.getCompanyId()) {
            return "参数组织编码为空，执行失败";
        }

        //启动子任务执行通知
        FutureTask<String> futureTask = new FutureTask<>(new WarnNoticeTask(this, param, WarnUtils.WECHAT_WARN_1008, param.getBizType(), warnUtils));
        ExecutorService executorService = Executors.newCachedThreadPool();
        executorService.submit(futureTask);
        executorService.shutdown();

        return null;
    }

    @Override
    public String noticeTestWarn(String phone, String warnType, String warnLevel, String bizType) {
        if (StringUtils.isEmpty(phone)) {
            return "手机号为空，请输入手机号！";
        }
        String msg = "微信推送失败！";
        try {
            //设置警告信息
            WarnData warn = new WarnData();
            warn.setPhone(phone);
            warn.setCompanyId(ContextUtil.getCompanyId());

            if (StringUtils.isEmpty(warnType)) {
                warnType = WarnType.TYPE_01.getCode();
            }
            warn.setType(warnType);

            warn.setInfo("您好，此为测试警告信息！");

            if (StringUtils.isEmpty(warnLevel)) {
                warnLevel = WarnLevel.LEVEL_01.getCode();
            }
            warn.setLevel(warnLevel);
            warn.setBizType(bizType);
            warn.setName("测试警告");
            warn.setDepotName("测试仓库");

            sendByWeChat(warn, WarnUtils.WECHAT_WARN_1008, warn.getCompanyId());

            return "微信推送成功";

        } catch (Exception e) {
            log.error("-----后台异常:{}-----", e);
            return msg;
        }
    }

    @Override
    public String noticeInout(InoutData inout) {
        if (null == inout) {
            return "警告信息为空，不推送！";
        }

        try {

            //推送到微信平台
            return sendByWeChat(inout, WarnUtils.WECHAT_WARN_1007, inout.getCompanyId());

        } catch (Exception e) {

            log.error("-----后台异常:{}-----", e);
            return null;
        }
    }

    @Override
    public String noticeOrder(ApplyOrderParam order) {
        try {

            if (StringUtils.isEmpty(order.getPhone())) {
                return "微信推送失败！";
            }

            return sendByWeChat(order, WarnUtils.WECHAT_WARN_1011, order.getCompanyId());

        } catch (Exception e) {

            log.error("-----后台异常:{}-----", e);
            return null;
        }
    }


    @Override
    public void setCacheWarnConf(List<MWarnConf> list) {
        if (null == list) {
            return;
        }
        String key;
        for (MWarnConf warnConf : list) {
            key = RedisConst.buildKey(warnConf.getCompanyId(), warnConf.getDeptId(), RedisConst.KEY_WARN_CONF);
            redisUtil.set(key, warnConf);
        }
    }

    @Override
    public MWarnConf getCacheWarnConf(String companyId, String deptId) {
        if (StringUtils.isEmpty(deptId)) {
            return null;
        }
        if (StringUtils.isEmpty(companyId)) {
            companyId = ContextUtil.getCompanyId();
        }
        String key = RedisConst.buildKey(companyId, deptId, RedisConst.KEY_WARN_CONF);

        MWarnConf warnConf = (MWarnConf) redisUtil.get(key);
        //若缓存获取为空，则从数据库获取
        if (null == warnConf) {
            warnConf = warnMapper.getWarnConf(companyId, deptId);
            redisUtil.set(key, warnConf);
        }
        return warnConf;
    }

    /**
     * 推送信息到微信平台
     *
     * @param data
     * @param interfaceId
     * @param companyId
     * @return
     */
    public String sendByWeChat(Object data, String interfaceId, String companyId) {

        MsgRequest<Object> param = new MsgRequest<>();

        param.setInterfaceId(interfaceId);
        param.setSign(companyId);
        param.setOutId(companyId);
        param.setReqDateTime(DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm:ss"));
        param.setData(data);

        MsgResponse msgResponse = restTemplate.postForObject(configData.getWarnPath(), param, MsgResponse.class);

        return msgResponse.getMsg();
    }

}