开发散点图Redis缓存调度程序

realtime/generationXK-service/src/main/java/com/gyee/generation/service/InitialRedisService.java

@@ -27,6 +27,8 @@ public  class InitialRedisService {
 
     public  void initialRedisAll() throws Exception {
 
+
+
         System.out.println("初始化开始！");
         intialWpScatter();
         intialPjScatter();
@@ -41,7 +43,7 @@ public  class InitialRedisService {
 
     public  void intialWpScatter() throws Exception {
 
-
+        redisService.select(9);
 
         Calendar cal = Calendar.getInstance();
         cal.set(Calendar.HOUR_OF_DAY, 0);
@@ -126,7 +128,7 @@ public  class InitialRedisService {
     public  void intialPjScatter() throws Exception {
 
 
-
+        redisService.select(9);
         Calendar cal = Calendar.getInstance();
         cal.set(Calendar.HOUR_OF_DAY, 0);
         cal.set(Calendar.MINUTE, 0);
@@ -208,7 +210,7 @@ public  class InitialRedisService {
 
     public  void intialLnScatter() throws Exception {
 
-
+        redisService.select(9);
 
         Calendar cal = Calendar.getInstance();
         cal.set(Calendar.HOUR_OF_DAY, 0);
@@ -290,7 +292,7 @@ public  class InitialRedisService {
 
     public  void intialWtScatter() throws Exception {
 
-
+        redisService.select(9);
         Calendar cal = Calendar.getInstance();
         cal.set(Calendar.HOUR_OF_DAY, 0);
         cal.set(Calendar.MINUTE, 0);

realtime/generationXK-service/src/test/java/com/gyee/generation/HealthTest.java

@@ -1,8 +1,8 @@
 package com.gyee.generation;
 
 import com.gyee.common.util.DateUtils;
+import com.gyee.generation.service.InitialRedisService;
 import com.gyee.generation.service.InputOrOutPutService;
-import com.gyee.generation.service.ShutdownnewService;
 import com.gyee.generation.util.SpringUtils;
 import org.springframework.boot.SpringApplication;
 
@@ -15,6 +15,8 @@ public class HealthTest {
     public static void main(String[] args) throws Exception {
         SpringApplication.run(GenerationMain.class, args);
         InputOrOutPutService inputOrOutPutService= SpringUtils.getBean("inputOrOutPutService");
+        InitialRedisService initialRedisService= SpringUtils.getBean("initialRedisService");
+
 
 //        inputOrOutPutService.initialInputOrOutputSpeed();
         Calendar c = Calendar.getInstance();
@@ -65,7 +67,17 @@ public class HealthTest {
 //            System.out.println("切入切出状态切换记录调度程序执行结束!。。。。。。");
 //        }
 
-//
+
+        begin=new Date();
+        System.out.println("初始化散点图调度程序执行开始!。。。。。。");
+
+
+        initialRedisService.intialWtScatter();
+        end=new Date();
+        System.out.println("执行用时"+ DateUtils.secondsDiff(begin,end) +"秒");
+        System.out.println("初始化散点图度程序执行结束!。。。。。。");
+
+
 //        begin=new Date();
 //        System.out.println("切入切出统计调度程序执行开始!。。。。。。");
 //
@@ -77,18 +89,18 @@ public class HealthTest {
 //
 //
 //
-        begin=new Date();
-        System.out.println("停机记录调度程序执行开始!。。。。。。");
-        ShutdownnewService shutdownnewService= SpringUtils.getBean("shutdownnewService");
+//        begin=new Date();
+//        System.out.println("停机记录调度程序执行开始!。。。。。。");
+//        ShutdownnewService shutdownnewService= SpringUtils.getBean("shutdownnewService");
 //       List<ProBasicPowerstation> wpls=new ArrayList<>();
 //
 //        ProBasicPowerstation wp=  CacheContext.wpmap.get("SXJ_KGDL_GJY_FDC_STA");
 //       wpls.add(wp);
 //        List<ProBasicEquipment> wtls=CacheContext.wpwtmap.get("SXJ_KGDL_GJY_FDC_STA");
-        shutdownnewService.execShutdown(c.getTime());
-        end=new Date();
-        System.out.println("执行用时"+ DateUtils.secondsDiff(begin,end) +"秒");
-        System.out.println("停机记录调度程序执行结束!。。。。。。");
+//        shutdownnewService.execShutdown(c.getTime());
+//        end=new Date();
+//        System.out.println("执行用时"+ DateUtils.secondsDiff(begin,end) +"秒");
+//        System.out.println("停机记录调度程序执行结束!。。。。。。");
 //
 //
 //        begin=new Date();