浏览代码

场景计算统计定时任务

dsx 2 年之前
父节点
当前提交
994f165edb
共有 1 个文件被更改,包括 3 次插入3 次删除
  1. 3 3
      src/main/java/com/fdkankan/job/job/SceneCallCountHandler.java

+ 3 - 3
src/main/java/com/fdkankan/job/job/SceneCallCountHandler.java

@@ -72,7 +72,7 @@ public class SceneCallCountHandler {
         }
         //v3场景
         int v3Count = 0; int v3success = 0; int v3Fail = 0; int v3Waiting = 0;
-        List<ScenePro> scenePros = Db.use(db1).query(sql, ScenePro.class, "A", dateStart, dateEnd);
+        List<ScenePro> scenePros = Db.use(db1).query(sql, ScenePro.class, dateStart, dateEnd);
         if(CollUtil.isNotEmpty(scenePros)){
             v3Count = scenePros.size();
             v3success = (int) scenePros.stream().filter(plus -> plus.getStatus() == 1 || plus.getStatus() == -2).count();
@@ -84,7 +84,7 @@ public class SceneCallCountHandler {
 //        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);
+//        List<ScenePlus> scenePluses4Eur = Db.use(dbEur).query(sql, ScenePlus.class, dateStart, dateEnd);
 //        if(CollUtil.isNotEmpty(scenePluses4Eur)){
 //            v4CountEur = scenePluses4Eur.size();
 //            v4successEur = (int) scenePluses4Eur.stream().filter(plus -> plus.getSceneStatus() == 1 || plus.getSceneStatus() == -2).count();
@@ -96,7 +96,7 @@ public class SceneCallCountHandler {
 //        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);
+//        List<ScenePro> sceneProsJp = Db.use(dbJp).query(proSql, ScenePro.class, dateStart, dateEnd);
 //        if(CollUtil.isNotEmpty(sceneProsJp)){
 //            v4CountJp = sceneProsJp.size();
 //            v4successJp = (int) sceneProsJp.stream().filter(plus -> plus.getStatus() == 1 || plus.getStatus() == -2).count();