diff --git a/src/main/java/com/xydl/cac/task/I2syncTask.java b/src/main/java/com/xydl/cac/task/I2syncTask.java index 3d3d3ca..a419766 100644 --- a/src/main/java/com/xydl/cac/task/I2syncTask.java +++ b/src/main/java/com/xydl/cac/task/I2syncTask.java @@ -8,6 +8,7 @@ import com.xydl.cac.service.DataService; import com.xydl.cac.service.I2syncService; import com.xydl.cac.transform.I2DataTransformer; import com.xydl.cac.util.DateUtil; +import com.xydl.cac.util.DingTalkPushUtil; import com.xydl.cac.util.JSONUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.scheduling.annotation.Scheduled; @@ -32,6 +33,8 @@ public class I2syncTask { DataService dataService; @Resource I2DataTransformer dataTransformer; + @Resource + DingTalkPushUtil dingTalkPushUtil; @Scheduled(initialDelay = 60 * 1000, fixedDelay = 30 * 60 * 1000) public void syncAll() { @@ -45,6 +48,8 @@ public class I2syncTask { log.info("I2syncTask.syncAll 结束."); } catch (Exception e) { log.error("I2syncTask.syncAll error.", e); + String str = "i2同步导出数据异常: " + e.getMessage(); + dingTalkPushUtil.pushText(str); } } } diff --git a/src/main/java/com/xydl/cac/util/DingTalkPushUtil.java b/src/main/java/com/xydl/cac/util/DingTalkPushUtil.java index 3266e2d..17edbe8 100644 --- a/src/main/java/com/xydl/cac/util/DingTalkPushUtil.java +++ b/src/main/java/com/xydl/cac/util/DingTalkPushUtil.java @@ -21,12 +21,12 @@ import java.net.URLEncoder; public class DingTalkPushUtil { @Value("${cac.dingding.send}") - public boolean send; + private boolean send; @Value("${cac.dingding.token}") - public String token; + private String token; @Value("${cac.dingding.secret}") - public String secret; - public String KEY_WORD = "运维告警: "; + private String secret; + private String KEY_WORD = "告警: "; public void pushText(String content) {