package com.ycl.timer;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.ycl.common.dingding.DingCommon;
import com.ycl.entity.message.DingMessage;
import com.ycl.mapper.message.DingMessageMapper;
import com.ycl.service.message.IDingMessageService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.ApplicationRunner;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.Date;
import java.util.List;

@Slf4j
@Component
public class SendDingMsg implements ApplicationListener<ContextRefreshedEvent> {
    @Autowired
    private DingMessageMapper dingMessageMapper;
    @Autowired
    private DingCommon dingCommon;
    @Autowired
    private IDingMessageService dingMessageService;
    @Value("${spring.profiles.active}")
    private String env;

    public final static Short STATE_READY = 0;
    public final static Short STATE_SUCCESS = 1;
    public final static Short STATE_FAILURE = 2;
    public final static Short SCAN_READY = 0;
    public final static Short SCAN_FINISH = 1;

    @Scheduled(cron = "0 0/2 * * * ?")
    public void runAction() {
        if ("online".equals(env)) {
            QueryWrapper<DingMessage> wrapper = new QueryWrapper<>();
            wrapper.eq("state", STATE_READY);
            wrapper.eq("if_scan", SCAN_READY);
            List<DingMessage> dingMessages = dingMessageMapper.selectList(wrapper);
            if (CollectionUtils.isNotEmpty(dingMessages)) {
                int size = dingMessages.size();
                log.info("有待发送消息{}条", size);
                for (DingMessage dingMessage : dingMessages) {
                    String baseCaseCode = dingMessage.getBaseCaseCode();
                    Long accountId = dingMessage.getAccountId();
                    Long messageId = dingMessage.getId();
                    String text = "遂昌云执法：有待处理的任务\n" +
                            "·您有1条待处理事件。事件编号:\n" +
                            baseCaseCode;
                    String title = "您有一条工作通知";
                    try {
                        dingMessage.setIfScan(SCAN_FINISH);
                        dingMessage.setSendTime(new Date());
                        dingCommon.sendDingMsgStr(accountId + "", text);
                        log.info("发送一条工作通知，消息id{}", messageId);
                        dingMessage.setState(STATE_SUCCESS);
                    } catch (Exception e) {
                        log.error("发送钉钉消息出现异常,消息id{}", messageId, e);
                        dingMessage.setState(STATE_FAILURE);
                        size--;
                    }
                }
                dingMessageService.updateBatchById(dingMessages);
                log.info("发送成功{}条，失败{}条", size, dingMessages.size() - size);
            }
        }
    }


    @Override
    public void onApplicationEvent(ContextRefreshedEvent contextRefreshedEvent) {
        if (contextRefreshedEvent.getApplicationContext().getParent() == null) {
//            runAction();
        }
    }
}