额定风速存数据库

ruoyi-admin/src/test/java/com/ruoyi/JavaFunctionJobHandler.java

@@ -1166,9 +1166,31 @@ public class JavaFunctionJobHandler extends IJobHandler {
                 }
                 agValue = agValue / listDouble.size();
             }
-
             System.out.println("wtId:" + wtId + "agValue平均额定风速:"+agValue );
 
+
+            //存入数据库
+            System.out.println(wtId + " " + start);
+            QueryWrapper<TurbineInfoDay> turbineInfoDayQueryWrapper = new QueryWrapper<>();
+            turbineInfoDayQueryWrapper.eq("turbine_id", wtId);
+            turbineInfoDayQueryWrapper.eq("record_date", start);
+            TurbineInfoDay one = turbineInfoDayService.getOne(turbineInfoDayQueryWrapper);
+            System.out.println(one);
+            if (one == null) {
+                TurbineInfoDay turbineInfoDay = new TurbineInfoDay();
+                turbineInfoDay.setTurbineId(wtId);
+                turbineInfoDay.setRecordDate(start);
+                turbineInfoDay.setEdfs(agValue);
+                System.out.println(turbineInfoDay);
+                turbineInfoDayService.save(turbineInfoDay);
+            } else {
+                one.setEdfs(agValue);
+                System.out.println(one);
+                turbineInfoDayService.updateById(one);
+            }
+
+
+
         }
 
 //        stringRedisTemplate.opsForValue().set("glqxnh", JSON.toJSONString(fitMap));

ruoyi-admin/src/test/java/com/ruoyi/ZhiBiaoCalculation.java

@@ -45,8 +45,7 @@ public class ZhiBiaoCalculation {
     @Resource
     private TurbineInfoDayServiceImpl turbineInfoDayService;
 
-    @Resource
-    private StringRedisTemplate stringRedisTemplate;
+
 
 
     //切入切出风速
@@ -227,13 +226,6 @@ public class ZhiBiaoCalculation {
         javaFunctionJobHandler.calcGlqxnh_edfs(timeBegin.toJdkDate(), timeNow.toJdkDate());
 
 
-/*        //从redis取
-        Set<String> keys = stringRedisTemplate.keys("glqxnh:5:*");
-        for (String key : keys) {
-            String yc = stringRedisTemplate.opsForValue().get(key);
-            ConcurrentHashMap<Double, Double> wtyc = JSON.parseObject(yc, new TypeReference<ConcurrentHashMap<Double, Double>>() {}.getType());
-            CalcCache.fitcoef.put(key.replaceFirst("glqxnh:5:",""),wtyc);
-        }*/
 
 
     }