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.setIf_scan(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();
|
}
|
}
|
}
|
