加入失败报警

src/main/java/com/winhc/task/PersonMergeIncremnetTask.java

@@ -17,6 +17,7 @@ import com.winhc.utils.DingUtils;
 import com.winhc.utils.SchemaInit;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import lombok.val;
 import org.neo4j.driver.Driver;
 import org.neo4j.driver.Session;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -24,12 +25,10 @@ import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
+
 import java.io.IOException;
 import java.io.UnsupportedEncodingException;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeoutException;
 
@@ -151,11 +150,18 @@ public class PersonMergeIncremnetTask {
                     .filter(e -> !(TaskFlowEnum.SUCCESS.equals(e) || TaskFlowEnum.FAILURE.equals(e)))
                     .count();
 
+            long count1 = query.values().stream().filter(TaskFlowEnum.FAILURE::equals).count();
+            if (count1 != 0) {
+                if (!CompanyUtils.isWindows()) {
+                    log.info("startJob job run error : \n" + "回流job失败" + "\n!!!!!!! ");
+                    dingUtils.send("startJob job run error : \n" + "回流job失败" + "\n!!!!!!! ");
+                }
+            }
+
             if (count != 0) {
                 Thread.sleep(10000);
             } else {
-                log.info("startJob | cost:{} | end !", (System.currentTimeMillis() - start));
-                log.info("startJob end !");
+                log.info("startJob end | cost:{} | !", (System.currentTimeMillis() - start));
                 return;
             }
         }

src/main/resources/task.yaml

@@ -7,3 +7,5 @@ job:
         param:
           - _nodeId: 700004102657
             project: winhc_ng
+          - _nodeId: 700004178250
+            project: winhc_ng