29 lines
962 B
Java
29 lines
962 B
Java
|
package com.zhgd.xmgl.task;
|
||
|
|
|
||
|
|
import lombok.extern.slf4j.Slf4j;
|
||
|
|
import net.javacrumbs.shedlock.core.SchedulerLock;
|
||
|
|
import org.springframework.scheduling.annotation.Scheduled;
|
||
|
|
import org.springframework.stereotype.Component;
|
||
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
||
|
|
import org.springframework.web.bind.annotation.RestController;
|
||
|
|
|
||
|
|
@Slf4j
|
||
|
|
@Component
|
||
|
|
@RestController
|
||
|
|
@RequestMapping("xmgl/task")
|
||
|
|
public class MessageDevRuleTask {
|
||
|
|
/**
|
||
|
|
* 发送通知
|
||
|
|
*/
|
||
|
|
@SchedulerLock(name = "sendMessage", lockAtMostFor = 1000 * 60 * 60, lockAtLeastFor = 1000 * 60 * 5)
|
||
|
|
@Scheduled(cron = "0 0 */1 * * ?")
|
||
|
|
@RequestMapping("sendMessage")
|
||
|
|
public void sendMessage() {
|
||
|
|
// List<EnvironmentAlarm> environmentAlarms;
|
||
|
|
// List<EnableMessageDevRule> ruleList;
|
||
|
|
// Map<String, List<EnableMessageDevRule>> moduleMap = ruleList.stream().collect(Collectors.groupingBy(EnableMessageDevRule::getMonitoringModuleName));
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|