场景计算统计定时任务

src/main/java/com/fdkankan/job/job/SceneCallCountHandler.java

@@ -80,34 +80,36 @@ public class SceneCallCountHandler {
             v3Waiting = (int)scenePros.stream().filter(plus -> plus.getStatus() == 0).count();
         }
 
-        //国际环境
-        DataSource dbEur = DSFactory.get("group_gj");
-        //v4场景
-        int v4CountEur = 0; int v4successEur; int v4FailEur = 0; int v4WaitingEur = 0;
-        List<ScenePlus> scenePluses4Eur = Db.use(dbEur).query(sql, ScenePlus.class, "A", dateStart, dateEnd);
-        if(CollUtil.isNotEmpty(scenePluses4Eur)){
-            v4CountEur = scenePluses4Eur.size();
-            v4successEur = (int) scenePluses4Eur.stream().filter(plus -> plus.getSceneStatus() == 1 || plus.getSceneStatus() == -2).count();
-            v4FailEur = (int)scenePluses4Eur.stream().filter(plus -> plus.getSceneStatus() == -1).count();
-            v4WaitingEur = (int)scenePluses4Eur.stream().filter(plus -> plus.getSceneStatus() == 0).count();
-        }
-
-        //日本环境
-        DataSource dbJp = DSFactory.get("group_jp");
-        //v4场景
-        int v4CountJp = 0; int v4successJp = 0; int v4FailJp = 0; int v4WaitingJp = 0;
-        List<ScenePro> sceneProsJp = Db.use(dbJp).query(proSql, ScenePro.class, "A", dateStart, dateEnd);
-        if(CollUtil.isNotEmpty(sceneProsJp)){
-            v4CountJp = sceneProsJp.size();
-            v4successJp = (int) sceneProsJp.stream().filter(plus -> plus.getStatus() == 1 || plus.getStatus() == -2).count();
-            v4FailJp = (int)sceneProsJp.stream().filter(plus -> plus.getStatus() == -1).count();
-            v4WaitingJp = (int)sceneProsJp.stream().filter(plus -> plus.getStatus() == 0).count();
-        }
+//        //国际环境
+//        DataSource dbEur = DSFactory.get("group_gj");
+//        //v4场景
+//        int v4CountEur = 0; int v4successEur; int v4FailEur = 0; int v4WaitingEur = 0;
+//        List<ScenePlus> scenePluses4Eur = Db.use(dbEur).query(sql, ScenePlus.class, "A", dateStart, dateEnd);
+//        if(CollUtil.isNotEmpty(scenePluses4Eur)){
+//            v4CountEur = scenePluses4Eur.size();
+//            v4successEur = (int) scenePluses4Eur.stream().filter(plus -> plus.getSceneStatus() == 1 || plus.getSceneStatus() == -2).count();
+//            v4FailEur = (int)scenePluses4Eur.stream().filter(plus -> plus.getSceneStatus() == -1).count();
+//            v4WaitingEur = (int)scenePluses4Eur.stream().filter(plus -> plus.getSceneStatus() == 0).count();
+//        }
+//
+//        //日本环境
+//        DataSource dbJp = DSFactory.get("group_jp");
+//        //v4场景
+//        int v4CountJp = 0; int v4successJp = 0; int v4FailJp = 0; int v4WaitingJp = 0;
+//        List<ScenePro> sceneProsJp = Db.use(dbJp).query(proSql, ScenePro.class, "A", dateStart, dateEnd);
+//        if(CollUtil.isNotEmpty(sceneProsJp)){
+//            v4CountJp = sceneProsJp.size();
+//            v4successJp = (int) sceneProsJp.stream().filter(plus -> plus.getStatus() == 1 || plus.getStatus() == -2).count();
+//            v4FailJp = (int)sceneProsJp.stream().filter(plus -> plus.getStatus() == -1).count();
+//            v4WaitingJp = (int)sceneProsJp.stream().filter(plus -> plus.getStatus() == 0).count();
+//        }
 
         String ddMsg = String.format(DINGTALK_MSG_PATTERN, DateExtUtil.format(time, DateExtUtil.dateStyle4),
                 v3Count, v3success, v3Fail, v3Waiting,
-                v4Count, v4success, v4Fail, v4Waiting,
-                v4CountJp, v4successJp, v4FailJp, v4WaitingJp);
+                v4Count, v4success, v4Fail, v4Waiting
+//                ,
+//                v4CountJp, v4successJp, v4FailJp, v4WaitingJp
+        );
 
         XxlJobHelper.log(ddMsg);
         XxlJobHelper.log("sceneCallCountHandler end.....");

src/main/resources/db.setting

@@ -1,5 +1,5 @@
 [group_gn]
-url = jdbc:mysql://rm-wz90w10465iiwwv098o.mysql.rds.aliyuncs.com:3306/4dkankan_v4_prod
+url = jdbc:mysql://120.24.144.164:3306/4dkankan_v4
 username = root
 password = D2719bd0cae1a005