add

src/main/java/com/winhc/dataworks/flow/touch/Main.java

@@ -73,7 +73,8 @@ public class Main {
         int totalTask = collect.size();
 
         Set<TaskInfo> end = new HashSet<>();
-        TimedCache<TaskInfo, String> timedCache = CacheUtil.newTimedCache(60000);
+        TimedCache<TaskInfo, String> timedCache = CacheUtil.newTimedCache(300 * 1000);
+        int i = 0;
         while (true) {
             int awaitTask = 0;
             int successTask = 0;
@@ -126,9 +127,10 @@ public class Main {
                     Duration duration = Duration.between(start, now);
                     long l = duration.toHours();
                     if (l >= 2) {
-                        if (!timedCache.containsKey(taskInfo)) {
+                        if (!timedCache.containsKey(taskInfo) && i <= 6) {
                             //超两小时
-                            DingMsg error = new DingMsg("任务长时间未结束", taskInfo.getProject(), taskInfo.getFlow(), String.join(",", failure), TaskFlowEnum.RUNNING.getMsg());
+                            i++;
+                            DingMsg error = new DingMsg("【" + i + "】任务长时间未结束", taskInfo.getProject(), taskInfo.getFlow(), String.join(",", failure), TaskFlowEnum.RUNNING.getMsg());
                             dingUtils.send(error);
                             timedCache.put(taskInfo, "1");
                         }