bug修改

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/TestController.java

@@ -13,11 +13,13 @@ import com.yeejoin.amos.boot.module.jxiop.biz.tdengine.FanHealthIndex;
 import com.yeejoin.amos.boot.module.jxiop.biz.tdmapper.IndicatorDataMapper;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
+import org.apache.ibatis.annotations.Param;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 import org.typroject.tyboot.core.foundation.enumeration.UserType;
 import org.typroject.tyboot.core.restful.doc.TycloudOperation;
 
+import java.text.ParseException;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -46,11 +48,11 @@ public class TestController extends BaseController {
     @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
     @ApiOperation(httpMethod = "GET", value = "test2", notes = "test1")
     @GetMapping("/test2")
-    public void test2 () {
-
+    public void test2 (@RequestParam(value = "startTime") String startTime, @Param("recDate") String recDate) {
+//        List<FanHealthIndex> infoListByGroupByCD = fanHealthIndexMapper.getInfoListByGroupByCdFan(startTime, recDate);
 //        commonService.healthWarningMinuteByFJ();
-        commonService.healthWarningMinuteByPv();
-
+//        commonService.healthWarningMinuteByPv();
+//        return infoListByGroupByCD;
     }
 
     @Autowired
@@ -64,7 +66,6 @@ public class TestController extends BaseController {
     @PostMapping("/saveTest")
     public void saveTest () {
 
-        tdengineTimeService.insertHourData();
 //        QueryWrapper<FanHealthIndex> fanHealthIndexQueryWrapper = new QueryWrapper<>();
 //        List<FanHealthIndex> fanHealthIndices = fanHealthIndexMapper.selectList(fanHealthIndexQueryWrapper);
 //

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/CommonServiceImpl.java

@@ -152,6 +152,10 @@ public class CommonServiceImpl {
     @Autowired
     private PvHealthIndexMapper pvHealthIndexMapper;
 
+
+    @Autowired
+    private TdengineTimeServiceImpl tdengineTimeService;
+
     /**
      * @return
      * @deprecated 获取工况变量列表风机
@@ -1688,17 +1692,9 @@ public class CommonServiceImpl {
                 }
             }
             idxBizFanHealthIndexService.saveBatch(idxBizFanHealthIndexs);
+            // 按时刻相关数据插入TDEngine 【异步】
+            insertFanDataTDEngine(fanHealthIndices1, format);
 
-            ArrayList<FanHealthIndex> newList = new ArrayList<>();
-            for (int i = 0; i < fanHealthIndices1.size(); i++) {
-                //分批次处理
-                newList.add(fanHealthIndices1.get(i));//循环将数据填入载体list
-                if (500 == newList.size() || i == fanHealthIndices1.size() - 1) {  //载体list达到要求,进行批量操作
-                    //调用批量插入
-                    fanHealthIndexMapper.saveBatchHealthIndexList(newList, "fan_health_index_moment");
-                    newList.clear();//每次批量操作后,清空载体list,等待下次的数据填入
-                }
-            }
         }
 
         try {
@@ -1715,6 +1711,33 @@ public class CommonServiceImpl {
     }
 
 
+
+    /**
+     * 风电按时刻相关数据插入
+     * @param fanHealthIndices
+     */
+    @Async
+    public void insertFanDataTDEngine(ArrayList<FanHealthIndex> fanHealthIndices, String recDate) {
+        // 按时刻 - 测点插入
+        ArrayList<FanHealthIndex> newList = new ArrayList<>();
+        for (int i = 0; i < fanHealthIndices.size(); i++) {
+            //分批次处理
+            newList.add(fanHealthIndices.get(i));//循环将数据填入载体list
+            if (500 == newList.size() || i == fanHealthIndices.size() - 1) {  //载体list达到要求,进行批量操作
+                //调用批量插入
+                fanHealthIndexMapper.saveBatchHealthIndexList(newList, "fan_health_index_moment");
+                newList.clear();//每次批量操作后,清空载体list,等待下次的数据填入
+            }
+        }
+        // 按时刻 子系统、设备、场站、区域   插入数据
+        try {
+            tdengineTimeService.insertMomentData(recDate);
+        } catch (ParseException e) {
+            e.printStackTrace();
+        }
+    }
+
+
     //    @Scheduled(cron = "0 0/10 * * * ?")
     @Async("async")
     public void healthWarningMinuteByPv() {
@@ -1927,16 +1950,8 @@ public class CommonServiceImpl {
                 }
             }
             idxBizPvHealthIndexService.saveBatch(idxBizPvHealthIndexs);
-            ArrayList<PvHealthIndex> newList = new ArrayList<>();
-            for (int i = 0; i < fanHealthIndices1.size(); i++) {
-                //分批次处理
-                newList.add(fanHealthIndices1.get(i));//循环将数据填入载体list
-                if (500 == newList.size() || i == fanHealthIndices1.size() - 1) {  //载体list达到要求,进行批量操作
-                    //调用批量插入
-                    pvHealthIndexMapper.saveBatchHealthIndexList(newList, "pv_health_index_moment");
-                    newList.clear();//每次批量操作后,清空载体list,等待下次的数据填入
-                }
-            }
+            //按时刻 - 相关数据插入
+            insertPvDataTDEngine(fanHealthIndices1, format);
         }
         try {
             logger.info("--------------------response： " + response);
@@ -1948,4 +1963,31 @@ public class CommonServiceImpl {
     }
 
 
+
+    /**
+     * 光伏按时刻相关数据插入
+     * @param pvHealthIndices
+     */
+    @Async
+    public void insertPvDataTDEngine(ArrayList<PvHealthIndex> pvHealthIndices, String recDate) {
+        // 按时刻 - 测点插入
+        ArrayList<PvHealthIndex> newList = new ArrayList<>();
+        for (int i = 0; i < pvHealthIndices.size(); i++) {
+            //分批次处理
+            newList.add(pvHealthIndices.get(i));//循环将数据填入载体list
+            if (500 == newList.size() || i == pvHealthIndices.size() - 1) {  //载体list达到要求,进行批量操作
+                //调用批量插入
+                pvHealthIndexMapper.saveBatchHealthIndexList(newList, "pv_health_index_moment");
+                newList.clear();//每次批量操作后,清空载体list,等待下次的数据填入
+            }
+        }
+        // 按时刻 设备、子阵、场站、区域   插入数据
+        try {
+            tdengineTimeService.insertMomentDataPv(recDate);
+        } catch (ParseException e) {
+            e.printStackTrace();
+        }
+    }
+
+
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/TdengineTimeServiceImpl.java

 package com.yeejoin.amos.boot.module.jxiop.biz.service.impl;
 
 import cn.hutool.core.date.DateUtil;
-import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.yeejoin.amos.boot.biz.common.utils.DateUtils;
-import com.yeejoin.amos.boot.module.jxiop.api.dto.BizMessage;
-import com.yeejoin.amos.boot.module.jxiop.api.dto.RiskBizInfoVo;
-import com.yeejoin.amos.boot.module.jxiop.api.dto.RiskDynamicDetailsVo;
-import com.yeejoin.amos.boot.module.jxiop.api.entity.StationBasic;
-import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFanWarningRecord;
-import com.yeejoin.amos.boot.module.jxiop.biz.tdMapper2.FanHealthIndexMomentMapper;
+import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFanHealthLevel;
+import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizPvHealthLevel;
+import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizFanHealthLevelMapper;
+import com.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizPvHealthLevelMapper;
+import com.yeejoin.amos.boot.module.jxiop.biz.tdMapper2.FanHealthIndexMapper;
+import com.yeejoin.amos.boot.module.jxiop.biz.tdMapper2.PvHealthIndexMapper;
 import com.yeejoin.amos.boot.module.jxiop.biz.tdengine.FanHealthIndex;
-import com.yeejoin.amos.boot.module.jxiop.biz.tdengine.FanHealthIndexMoment;
+import com.yeejoin.amos.boot.module.jxiop.biz.tdengine.PvHealthIndex;
 import lombok.extern.slf4j.Slf4j;
-import org.eclipse.paho.client.mqttv3.MqttException;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 
-import java.nio.charset.StandardCharsets;
+import java.text.ParseException;
 import java.util.ArrayList;
 import java.util.Date;
-import java.util.HashMap;
 import java.util.List;
 
 
@@ -33,23 +30,249 @@ import java.util.List;
 public class TdengineTimeServiceImpl {
 
     @Autowired
-    private FanHealthIndexMomentMapper fanHealthIndexMomentMapper;
+    private FanHealthIndexMapper fanHealthIndexMapper;
+
+    @Autowired
+    private PvHealthIndexMapper pvHealthIndexMapper;
+
+    @Autowired
+    private IdxBizFanHealthLevelMapper idxBizFanHealthLevelMapper;
+
+    @Autowired
+    private IdxBizPvHealthLevelMapper idxBizPvHealthLevelMapper;
+
+
+
     /**
-     * 风电 - 按小时生成测点数据
+     * 风电 - 按时刻生成子系统、设备、场站、区域 数据
      */
-    @Async
-    public void insertHourData() {
-        QueryWrapper<FanHealthIndexMoment> fanHealthLambda = new QueryWrapper<>();
-        fanHealthLambda.select("*, FORMAT(AVG(HEALTH_INDEX),2) as avgHealthIndex");
-        fanHealthLambda.lambda().ge(FanHealthIndexMoment::getRecDate, DateUtils.dateAddHours(new Date(), -1));
-        fanHealthLambda.lambda().eq(FanHealthIndexMoment::getAnalysisObjType, "测点");
-        fanHealthLambda.lambda().groupBy
-                (FanHealthIndexMoment::getGatewayId,
-                        FanHealthIndexMoment::getIndexAddress
-                );
-        List<FanHealthIndexMoment> fanHealthIndexMoments = fanHealthIndexMomentMapper.selectList(fanHealthLambda);
-        fanHealthIndexMoments.forEach(item -> {
-
-        });
+    public void insertMomentData(String recDate) throws ParseException {
+        //s 489分钟 为  8小时  +  19分钟
+        String startTime = DateUtils.dateFormat(DateUtils.dateAddMinutes(new Date(), -489), DateUtils.DATE_TIME_PATTERN);
+        // 子系统
+        List<IdxBizFanHealthLevel> levelListZxt = idxBizFanHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizFanHealthLevel>().eq(IdxBizFanHealthLevel::getAnalysisObjType, "子系统").last("limit 4"));
+        List<FanHealthIndex> fanHealthIndicesZxt = fanHealthIndexMapper.getInfoListByGroupByZxtFan(startTime, "fan_health_index_moment", "测点");
+        saveBatchFan(fanHealthIndicesZxt, "fan_health_index_moment", recDate, "按时刻", levelListZxt);
+        // 设备
+        List<IdxBizFanHealthLevel> levelListSb = idxBizFanHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizFanHealthLevel>().eq(IdxBizFanHealthLevel::getAnalysisObjType, "设备").last("limit 4"));
+        List<FanHealthIndex> fanHealthIndicesSb = fanHealthIndexMapper.getInfoListByGroupBySbFan(startTime, "fan_health_index_moment", "子系统");
+        saveBatchFan(fanHealthIndicesSb, "fan_health_index_moment", recDate, "按时刻", levelListSb);
+        // 场站
+        List<IdxBizFanHealthLevel> levelListCz = idxBizFanHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizFanHealthLevel>().eq(IdxBizFanHealthLevel::getAnalysisObjType, "场站").last("limit 4"));
+        List<FanHealthIndex> fanHealthIndicesCz = fanHealthIndexMapper.getInfoListByGroupByCzFan(startTime, "fan_health_index_moment", "设备");
+        saveBatchFan(fanHealthIndicesCz, "fan_health_index_moment", recDate, "按时刻", levelListCz);
+        // 区域
+        List<IdxBizFanHealthLevel> levelListQy = idxBizFanHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizFanHealthLevel>().eq(IdxBizFanHealthLevel::getAnalysisObjType, "片区").last("limit 4"));
+        List<FanHealthIndex> fanHealthIndicesQy = fanHealthIndexMapper.getInfoListByGroupByQyFan(startTime, "fan_health_index_moment", "场站");
+        saveBatchFan(fanHealthIndicesQy, "fan_health_index_moment", recDate, "按时刻", levelListQy);
+    }
+
+
+    /**
+     * 风电 - 按小时生成测点、子系统、设备、场站、区域 数据
+     */
+    @Scheduled(cron = "0 0 0/1 * * ? ")
+    public void insertHourData() throws ParseException {
+        String recDate = DateUtil.format(new Date(), "yyyy-MM-dd HH:00:00");
+        // 8小时 + 59分钟
+        String startTime = DateUtils.dateFormat(DateUtils.dateAddMinutes(new Date(), -541), DateUtils.DATE_TIME_PATTERN);
+        // 测点
+        List<IdxBizFanHealthLevel> levelList = idxBizFanHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizFanHealthLevel>().eq(IdxBizFanHealthLevel::getAnalysisObjType, "测点").last("limit 4"));
+        List<FanHealthIndex> fanHealthIndices = fanHealthIndexMapper.getInfoListByGroupByCdFan(startTime, "fan_health_index_moment", "测点");
+        saveBatchFan(fanHealthIndices, "fan_health_index_hour", recDate, "按小时", levelList);
+        // 子系统
+        List<IdxBizFanHealthLevel> levelListZxt = idxBizFanHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizFanHealthLevel>().eq(IdxBizFanHealthLevel::getAnalysisObjType, "子系统").last("limit 4"));
+        List<FanHealthIndex> fanHealthIndicesZxt = fanHealthIndexMapper.getInfoListByGroupByZxtFan(startTime, "fan_health_index_moment", "测点");
+        saveBatchFan(fanHealthIndicesZxt, "fan_health_index_hour", recDate, "按小时", levelListZxt);
+        // 设备
+        List<IdxBizFanHealthLevel> levelListSb = idxBizFanHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizFanHealthLevel>().eq(IdxBizFanHealthLevel::getAnalysisObjType, "设备").last("limit 4"));
+        List<FanHealthIndex> fanHealthIndicesSb = fanHealthIndexMapper.getInfoListByGroupBySbFan(startTime, "fan_health_index_moment", "子系统");
+        saveBatchFan(fanHealthIndicesSb, "fan_health_index_hour", recDate, "按小时", levelListSb);
+        // 场站
+        List<IdxBizFanHealthLevel> levelListCz = idxBizFanHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizFanHealthLevel>().eq(IdxBizFanHealthLevel::getAnalysisObjType, "场站").last("limit 4"));
+        List<FanHealthIndex> fanHealthIndicesCz = fanHealthIndexMapper.getInfoListByGroupByCzFan(startTime, "fan_health_index_moment", "设备");
+        saveBatchFan(fanHealthIndicesCz, "fan_health_index_hour", recDate, "按小时", levelListCz);
+        // 区域
+        List<IdxBizFanHealthLevel> levelListQy = idxBizFanHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizFanHealthLevel>().eq(IdxBizFanHealthLevel::getAnalysisObjType, "片区").last("limit 4"));
+        List<FanHealthIndex> fanHealthIndicesQy = fanHealthIndexMapper.getInfoListByGroupByQyFan(startTime, "fan_health_index_moment", "场站");
+        saveBatchFan(fanHealthIndicesQy, "fan_health_index_hour", recDate, "按小时", levelListQy);
+    }
+
+    /**
+     * 风电 - 按天生成测点、子系统、设备、场站、区域 数据
+     */
+    @Scheduled(cron = "0 0 0 1/1 * ? ")
+    public void insertDayData() throws ParseException {
+        String recDate = DateUtil.format(new Date(), "yyyy-MM-dd 00:00:00");
+        String startTime = DateUtils.dateFormat(DateUtils.dateAddHours(new Date(), -32), DateUtils.DATE_TIME_PATTERN);
+        List<IdxBizFanHealthLevel> levelList = idxBizFanHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizFanHealthLevel>().eq(IdxBizFanHealthLevel::getAnalysisObjType, "测点").last("limit 4"));
+        List<FanHealthIndex> fanHealthIndices = fanHealthIndexMapper.getInfoListByGroupByCdFan(startTime, "fan_health_index_hour", "测点");
+        saveBatchFan(fanHealthIndices, "fan_health_index_day", recDate, "按天", levelList);
+
+        // 子系统
+        List<IdxBizFanHealthLevel> levelListZxt = idxBizFanHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizFanHealthLevel>().eq(IdxBizFanHealthLevel::getAnalysisObjType, "子系统").last("limit 4"));
+        List<FanHealthIndex> fanHealthIndicesZxt = fanHealthIndexMapper.getInfoListByGroupByZxtFan(startTime, "fan_health_index_hour", "测点");
+        saveBatchFan(fanHealthIndicesZxt, "fan_health_index_day", recDate, "按天", levelListZxt);
+        // 设备
+        List<IdxBizFanHealthLevel> levelListSb = idxBizFanHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizFanHealthLevel>().eq(IdxBizFanHealthLevel::getAnalysisObjType, "设备").last("limit 4"));
+        List<FanHealthIndex> fanHealthIndicesSb = fanHealthIndexMapper.getInfoListByGroupBySbFan(startTime, "fan_health_index_hour", "子系统");
+        saveBatchFan(fanHealthIndicesSb, "fan_health_index_day", recDate, "按天", levelListSb);
+        // 场站
+        List<IdxBizFanHealthLevel> levelListCz = idxBizFanHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizFanHealthLevel>().eq(IdxBizFanHealthLevel::getAnalysisObjType, "场站").last("limit 4"));
+        List<FanHealthIndex> fanHealthIndicesCz = fanHealthIndexMapper.getInfoListByGroupByCzFan(startTime, "fan_health_index_hour", "设备");
+        saveBatchFan(fanHealthIndicesCz, "fan_health_index_day", recDate, "按天", levelListCz);
+        // 区域
+        List<IdxBizFanHealthLevel> levelListQy = idxBizFanHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizFanHealthLevel>().eq(IdxBizFanHealthLevel::getAnalysisObjType, "片区").last("limit 4"));
+        List<FanHealthIndex> fanHealthIndicesQy = fanHealthIndexMapper.getInfoListByGroupByQyFan(startTime, "fan_health_index_hour", "场站");
+        saveBatchFan(fanHealthIndicesQy, "fan_health_index_day", recDate, "按天", levelListQy);
+    }
+
+
+    private String getHealthLevelByScore(List<IdxBizFanHealthLevel> levelList, Double healthIndex) {
+        String levelDesc = "安全";
+        for (IdxBizFanHealthLevel item : levelList) {
+            if (item.getGroupUpperLimit() >= healthIndex && item.getGroupLowerLimit() < healthIndex) {
+                levelDesc = item.getHealthLevel();
+                break;
+            }
+        }
+        return levelDesc;
+    }
+
+    private void saveBatchFan(List<FanHealthIndex> fanHealthIndices,
+                              String tableName,
+                              String recDate,
+                              String analysisType,
+                              List<IdxBizFanHealthLevel> levelList) {
+        ArrayList<FanHealthIndex> newList = new ArrayList<>();
+        for (int i = 0; i < fanHealthIndices.size(); i++) {
+            FanHealthIndex fanHealthIndex = fanHealthIndices.get(i);
+            fanHealthIndex.setRecDate(recDate);
+            fanHealthIndex.setAnalysisTime(recDate);
+            fanHealthIndex.setAnalysisType(analysisType);
+            fanHealthIndex.setHealthLevel(getHealthLevelByScore(levelList, fanHealthIndex.getHealthIndex()));
+            //分批次处理
+            newList.add(fanHealthIndex);//循环将数据填入载体list
+            if (500 == newList.size() || i == fanHealthIndices.size() - 1) {  //载体list达到要求,进行批量操作
+                //调用批量插入
+                fanHealthIndexMapper.saveBatchHealthIndexList(newList, tableName);
+                newList.clear();//每次批量操作后,清空载体list,等待下次的数据填入
+            }
+        }
+    }
+
+    /**
+     * 光伏 -  按时刻生成设备、子阵、场站和片区数据
+     */
+    public void insertMomentDataPv(String recDate) throws ParseException {
+        String startTime = DateUtils.dateFormat(DateUtils.dateAddMinutes(new Date(), -489), DateUtils.DATE_TIME_PATTERN);
+        // 设备
+        List<IdxBizPvHealthLevel> levelListSb = idxBizPvHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizPvHealthLevel>().eq(IdxBizPvHealthLevel::getAnalysisObjType, "设备").last("limit 4"));
+        List<PvHealthIndex> fanHealthIndicesSb = pvHealthIndexMapper.getInfoListByGroupBySbPv(startTime, "pv_health_index_moment", "测点");
+        saveBatchPv(fanHealthIndicesSb, "pv_health_index_moment", recDate, "按时刻", levelListSb);
+        // 子阵
+        List<IdxBizPvHealthLevel> levelListZz = idxBizPvHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizPvHealthLevel>().eq(IdxBizPvHealthLevel::getAnalysisObjType, "子阵").last("limit 4"));
+        List<PvHealthIndex> fanHealthIndicesZz = pvHealthIndexMapper.getInfoListByGroupByZzPv(startTime, "pv_health_index_moment", "设备");
+        saveBatchPv(fanHealthIndicesZz, "pv_health_index_moment", recDate, "按时刻", levelListZz);
+        // 场站
+        List<IdxBizPvHealthLevel> levelListCz = idxBizPvHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizPvHealthLevel>().eq(IdxBizPvHealthLevel::getAnalysisObjType, "场站").last("limit 4"));
+        List<PvHealthIndex> fanHealthIndicesCz = pvHealthIndexMapper.getInfoListByGroupByCzPv(startTime, "pv_health_index_moment", "子阵");
+        saveBatchPv(fanHealthIndicesCz, "pv_health_index_moment", recDate, "按时刻", levelListCz);
+        // 片区
+        List<IdxBizPvHealthLevel> levelListQy = idxBizPvHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizPvHealthLevel>().eq(IdxBizPvHealthLevel::getAnalysisObjType, "片区").last("limit 4"));
+        List<PvHealthIndex> fanHealthIndicesQy = pvHealthIndexMapper.getInfoListByGroupByQyPv(startTime, "pv_health_index_moment", "场站");
+        saveBatchPv(fanHealthIndicesQy, "pv_health_index_moment", recDate, "按时刻", levelListQy);
+    }
+
+    /**
+     * 光伏 -  按小时生成 测点、设备、子阵、场站和片区数据
+     */
+    @Scheduled(cron = "0 0 0/1 * * ? ")
+    public void insertHourDataPv() throws ParseException {
+        String recDate = DateUtil.format(new Date(), "yyyy-MM-dd HH:00:00");
+        // 8小时 + 59分钟
+        String startTime = DateUtils.dateFormat(DateUtils.dateAddMinutes(new Date(), -541), DateUtils.DATE_TIME_PATTERN);
+        // 测点
+        List<IdxBizPvHealthLevel> levelList = idxBizPvHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizPvHealthLevel>().eq(IdxBizPvHealthLevel::getAnalysisObjType, "测点").last("limit 4"));
+        List<PvHealthIndex> fanHealthIndices = pvHealthIndexMapper.getInfoListByGroupByCdPv(startTime, "pv_health_index_moment", "测点");
+        saveBatchPv(fanHealthIndices, "pv_health_index_hour", recDate, "按小时", levelList);
+        // 设备
+        List<IdxBizPvHealthLevel> levelListSb = idxBizPvHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizPvHealthLevel>().eq(IdxBizPvHealthLevel::getAnalysisObjType, "设备").last("limit 4"));
+        List<PvHealthIndex> fanHealthIndicesSb = pvHealthIndexMapper.getInfoListByGroupBySbPv(startTime, "pv_health_index_moment", "测点");
+        saveBatchPv(fanHealthIndicesSb, "pv_health_index_hour", recDate, "按小时", levelListSb);
+        // 子阵
+        List<IdxBizPvHealthLevel> levelListZz = idxBizPvHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizPvHealthLevel>().eq(IdxBizPvHealthLevel::getAnalysisObjType, "子阵").last("limit 4"));
+        List<PvHealthIndex> fanHealthIndicesZz = pvHealthIndexMapper.getInfoListByGroupByZzPv(startTime, "pv_health_index_moment", "设备");
+        saveBatchPv(fanHealthIndicesZz, "pv_health_index_hour", recDate, "按小时", levelListZz);
+        // 场站
+        List<IdxBizPvHealthLevel> levelListCz = idxBizPvHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizPvHealthLevel>().eq(IdxBizPvHealthLevel::getAnalysisObjType, "场站").last("limit 4"));
+        List<PvHealthIndex> fanHealthIndicesCz = pvHealthIndexMapper.getInfoListByGroupByCzPv(startTime, "pv_health_index_moment", "子阵");
+        saveBatchPv(fanHealthIndicesCz, "pv_health_index_hour", recDate, "按小时", levelListCz);
+        // 片区
+        List<IdxBizPvHealthLevel> levelListQy = idxBizPvHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizPvHealthLevel>().eq(IdxBizPvHealthLevel::getAnalysisObjType, "片区").last("limit 4"));
+        List<PvHealthIndex> fanHealthIndicesQy = pvHealthIndexMapper.getInfoListByGroupByQyPv(startTime, "pv_health_index_moment", "场站");
+        saveBatchPv(fanHealthIndicesQy, "pv_health_index_hour", recDate, "按小时", levelListQy);
+    }
+
+    /**
+     * 光伏  -  按天生成 测点、设备、子阵、场站和片区数据
+     */
+    @Scheduled(cron = "0 0 0 1/1 * ? ")
+    public void insertDayDataPv() throws ParseException {
+        String recDate = DateUtil.format(new Date(), "yyyy-MM-dd 00:00:00");
+        List<IdxBizPvHealthLevel> levelList = idxBizPvHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizPvHealthLevel>().eq(IdxBizPvHealthLevel::getAnalysisObjType, "测点").last("limit 4"));
+        String startTime = DateUtils.dateFormat(DateUtils.dateAddHours(new Date(), -32), DateUtils.DATE_TIME_PATTERN);
+        List<PvHealthIndex> fanHealthIndices = pvHealthIndexMapper.getInfoListByGroupByCdPv(startTime, "pv_health_index_hour", "测点");
+        saveBatchPv(fanHealthIndices, "pv_health_index_day", recDate, "按天", levelList);
+        // 设备
+        List<IdxBizPvHealthLevel> levelListSb = idxBizPvHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizPvHealthLevel>().eq(IdxBizPvHealthLevel::getAnalysisObjType, "设备").last("limit 4"));
+        List<PvHealthIndex> fanHealthIndicesSb = pvHealthIndexMapper.getInfoListByGroupBySbPv(startTime, "pv_health_index_hour", "测点");
+        saveBatchPv(fanHealthIndicesSb, "pv_health_index_hour", recDate, "按天", levelListSb);
+        // 子阵
+        List<IdxBizPvHealthLevel> levelListZz = idxBizPvHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizPvHealthLevel>().eq(IdxBizPvHealthLevel::getAnalysisObjType, "子阵").last("limit 4"));
+        List<PvHealthIndex> fanHealthIndicesZz = pvHealthIndexMapper.getInfoListByGroupByZzPv(startTime, "pv_health_index_hour", "设备");
+        saveBatchPv(fanHealthIndicesZz, "pv_health_index_hour", recDate, "按天", levelListZz);
+        // 场站
+        List<IdxBizPvHealthLevel> levelListCz = idxBizPvHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizPvHealthLevel>().eq(IdxBizPvHealthLevel::getAnalysisObjType, "场站").last("limit 4"));
+        List<PvHealthIndex> fanHealthIndicesCz = pvHealthIndexMapper.getInfoListByGroupByCzPv(startTime, "pv_health_index_hour", "子阵");
+        saveBatchPv(fanHealthIndicesCz, "pv_health_index_hour", recDate, "按天", levelListCz);
+        // 片区
+        List<IdxBizPvHealthLevel> levelListQy = idxBizPvHealthLevelMapper.selectList(new LambdaQueryWrapper<IdxBizPvHealthLevel>().eq(IdxBizPvHealthLevel::getAnalysisObjType, "片区").last("limit 4"));
+        List<PvHealthIndex> fanHealthIndicesQy = pvHealthIndexMapper.getInfoListByGroupByQyPv(startTime, "pv_health_index_hour", "场站");
+        saveBatchPv(fanHealthIndicesQy, "pv_health_index_hour", recDate, "按天", levelListQy);
+    }
+
+
+    private String getHealthLevelByScorePv(List<IdxBizPvHealthLevel> levelList, Double healthIndex) {
+        String levelDesc = "安全";
+        for (IdxBizPvHealthLevel item : levelList) {
+            if (item.getGroupUpperLimit() >= healthIndex && item.getGroupLowerLimit() < healthIndex) {
+                levelDesc = item.getHealthLevel();
+                break;
+            }
+        }
+        return levelDesc;
+    }
+
+    private void saveBatchPv(List<PvHealthIndex> pvHealthIndices,
+                             String tableName,
+                             String recDate,
+                             String analysisType,
+                             List<IdxBizPvHealthLevel> levelList) {
+        ArrayList<PvHealthIndex> newList = new ArrayList<>();
+        for (int i = 0; i < pvHealthIndices.size(); i++) {
+            PvHealthIndex item = pvHealthIndices.get(i);
+            item.setRecDate(recDate);
+            item.setAnalysisTime(recDate);
+            item.setAnalysisType(analysisType);
+            item.setHealthLevel(getHealthLevelByScorePv(levelList, item.getHealthIndex()));
+            //分批次处理
+            newList.add(item);//循环将数据填入载体list
+            if (500 == newList.size() || i == pvHealthIndices.size() - 1) {  //载体list达到要求,进行批量操作
+                //调用批量插入
+                pvHealthIndexMapper.saveBatchHealthIndexList(newList, tableName);
+                newList.clear();//每次批量操作后,清空载体list,等待下次的数据填入
+            }
+        }
     }
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/tdMapper2/FanHealthIndexMapper.java

@@ -25,4 +25,41 @@ public interface FanHealthIndexMapper extends BaseMapper<FanHealthIndex> {
     List<FanHealthIndexDay> selectData(@Param("healthLevel")String healthLevel, @Param("area")String area, @Param("equipmentName")String equipmentName, @Param("subSystem")String subSystem, @Param("analysisType")String analysisType, @Param("analysisObjType")String analysisObjType, @Param("station")String station, @Param("pointName")String pointName, @Param("indexAddress")String indexAddress, @Param("startTimeTop") String startTimeTop, @Param("endTimeTop")String endTimeTop);
 
     int saveBatchHealthIndexList(@Param("list") List<FanHealthIndex> list, @Param("tableName") String tableName);
+
+    /**
+     * 测点
+     *
+     * @return
+     */
+    List<FanHealthIndex> getInfoListByGroupByCdFan(@Param("startTime") String startTime,
+                                                   @Param("tableName") String tableName,
+                                                   @Param("analysisObjectType") String analysisObjectType);
+
+    /**
+     * 子系统
+     */
+    List<FanHealthIndex> getInfoListByGroupByZxtFan(@Param("startTime") String startTime,
+                                                    @Param("tableName") String tableName,
+                                                    @Param("analysisObjectType") String analysisObjectType);
+
+    /**
+     * 设备
+     */
+    List<FanHealthIndex> getInfoListByGroupBySbFan(@Param("startTime") String startTime,
+                                                   @Param("tableName") String tableName,
+                                                   @Param("analysisObjectType") String analysisObjectType);
+
+    /**
+     * 场站
+     */
+    List<FanHealthIndex> getInfoListByGroupByCzFan(@Param("startTime") String startTime,
+                                                   @Param("tableName") String tableName,
+                                                   @Param("analysisObjectType") String analysisObjectType);
+
+    /**
+     * 区域
+     */
+    List<FanHealthIndex> getInfoListByGroupByQyFan(@Param("startTime") String startTime,
+                                                   @Param("tableName") String tableName,
+                                                   @Param("analysisObjectType") String analysisObjectType);
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/tdMapper2/PvHealthIndexMapper.java

@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.jxiop.biz.tdMapper2;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFanHealthIndex;
 import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizPvHealthIndex;
+import com.yeejoin.amos.boot.module.jxiop.biz.tdengine.FanHealthIndex;
 import com.yeejoin.amos.boot.module.jxiop.biz.tdengine.FanHealthIndexDay;
 import com.yeejoin.amos.boot.module.jxiop.biz.tdengine.PvHealthIndex;
 import org.apache.ibatis.annotations.Param;
@@ -28,4 +29,23 @@ public interface PvHealthIndexMapper extends BaseMapper<PvHealthIndex> {
 
     int saveBatchHealthIndexList(@Param("list") List<PvHealthIndex> list, @Param("tableName") String tableName);
 
+    List<PvHealthIndex> getInfoListByGroupByCdPv(@Param("startTime") String startTime,
+                                                 @Param("tableName") String tableName,
+                                                 @Param("analysisObjectType") String analysisObjectType);
+
+    List<PvHealthIndex> getInfoListByGroupBySbPv(@Param("startTime") String startTime,
+                                                 @Param("tableName") String tableName,
+                                                 @Param("analysisObjectType") String analysisObjectType);
+
+    List<PvHealthIndex> getInfoListByGroupByZzPv(@Param("startTime") String startTime,
+                                                 @Param("tableName") String tableName,
+                                                 @Param("analysisObjectType") String analysisObjectType);
+
+    List<PvHealthIndex> getInfoListByGroupByCzPv(@Param("startTime") String startTime,
+                                                 @Param("tableName") String tableName,
+                                                 @Param("analysisObjectType") String analysisObjectType);
+
+    List<PvHealthIndex> getInfoListByGroupByQyPv(@Param("startTime") String startTime,
+                                                 @Param("tableName") String tableName,
+                                                 @Param("analysisObjectType") String analysisObjectType);
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/resources/mapper/tdengine2/FanHealthIndex.xml

@@ -32,4 +32,124 @@
         )
     </foreach>
     </insert>
+
+<select id="getInfoListByGroupByCdFan" resultType="com.yeejoin.amos.boot.module.jxiop.biz.tdengine.FanHealthIndex">
+    select
+        index_address,
+        gateway_id ,
+        station,
+        analysis_obj_type,
+        analysis_obj_seq,
+        weight,
+        area,
+        sub_system,
+        number,
+        equipment_name,
+        avg(anomaly) as anomaly,
+        point_name,
+        kks,
+        AVG(health_index) as health_index
+    from
+        #{tableName}
+    where
+        analysis_obj_type = #{analysisObjectType}
+      and ts > #{startTime}
+    group by
+        gateway_id,
+        index_address,
+        station,
+        analysis_obj_type,
+        analysis_obj_seq,
+        weight,
+        area,
+        sub_system,
+        number,
+        equipment_name,
+        point_name,
+        kks
+    </select>
+
+<select id="getInfoListByGroupByZxtFan" resultType="com.yeejoin.amos.boot.module.jxiop.biz.tdengine.FanHealthIndex">
+    select
+        gateway_id ,
+        station,
+        '子系统' as analysis_obj_type,
+        area,
+        sub_system,
+        equipment_name,
+        avg(anomaly) as anomaly,
+        AVG(health_index) as health_index
+    from
+        #{tableName}
+    where
+        analysis_obj_type = #{analysisObjectType}
+      and ts > #{startTime}
+    group by
+        gateway_id,
+        station,
+        analysis_obj_type,
+        area,
+        sub_system,
+        equipment_name
+    </select>
+
+<select id="getInfoListByGroupBySbFan" resultType="com.yeejoin.amos.boot.module.jxiop.biz.tdengine.FanHealthIndex">
+    select
+        gateway_id ,
+        station,
+        '设备' as analysis_obj_type,
+        area,
+        number,
+        equipment_name,
+        avg(anomaly) as anomaly,
+        AVG(health_index) as health_index
+    from
+        #{tableName}
+    where
+        analysis_obj_type = #{analysisObjectType}
+      and ts > #{startTime}
+    group by
+        gateway_id,
+        station,
+        analysis_obj_type,
+        area,
+        number,
+        equipment_name
+    </select>
+
+<select id="getInfoListByGroupByCzFan" resultType="com.yeejoin.amos.boot.module.jxiop.biz.tdengine.FanHealthIndex">
+    select
+        gateway_id,
+        station,
+        '场站' as analysis_obj_type,
+        area,
+        avg(anomaly) as anomaly,
+        AVG(health_index) as health_index
+    from
+        #{tableName}
+    where
+        analysis_obj_type = #{analysisObjectType}
+      and ts > #{startTime}
+    group by
+        gateway_id,
+        station,
+        analysis_obj_type,
+        area
+    </select>
+
+<select id="getInfoListByGroupByQyFan" resultType="com.yeejoin.amos.boot.module.jxiop.biz.tdengine.FanHealthIndex">
+    select
+        '片区' as analysis_obj_type,
+        area,
+        avg(anomaly) as anomaly,
+        AVG(health_index) as health_index
+    from
+        #{tableName}
+    where
+        analysis_obj_type = #{analysisObjectType}
+      and ts > #{startTime}
+    group by
+        analysis_obj_type,
+        area
+    </select>
 </mapper>

amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/resources/mapper/tdengine2/PvHealthIndex.xml

@@ -66,4 +66,124 @@
             )
         </foreach>
     </insert>
+
+    <select id="getInfoListByGroupByCdPv" resultType="com.yeejoin.amos.boot.module.jxiop.biz.tdengine.PvHealthIndex">
+        select
+            index_address,
+            gateway_id ,
+            station,
+            '测点' as analysis_obj_type,
+            analysis_obj_seq,
+            weight,
+            area,
+            subarray,
+            manufacturer,
+            equipment_name,
+            avg(anomaly) as anomaly,
+            point_name,
+            device_type,
+            kks,
+            AVG(health_index) as health_index
+        from
+            #{tableName}
+        where
+            analysis_obj_type = #{analysisObjectType}
+          and ts > #{startTime}
+        group by
+            gateway_id,
+            index_address,
+            station,
+            analysis_obj_type,
+            analysis_obj_seq,
+            weight,
+            area,
+            subarray,
+            manufacturer,
+            equipment_name,
+            point_name,
+            device_type,
+            kks
+    </select>
+
+    <select id="getInfoListByGroupBySbPv" resultType="com.yeejoin.amos.boot.module.jxiop.biz.tdengine.PvHealthIndex">
+        select
+            gateway_id ,
+            station,
+            '设备' as analysis_obj_type,
+            area,
+            subarray,
+            equipment_name,
+            avg(anomaly) as anomaly,
+            AVG(health_index) as health_index
+        from
+            #{tableName}
+        where
+            analysis_obj_type = #{analysisObjectType}
+          and ts > #{startTime}
+        group by
+            gateway_id,
+            station,
+            analysis_obj_type,
+            area,
+            subarray,
+            equipment_name
+    </select>
+
+    <select id="getInfoListByGroupByZzPv" resultType="com.yeejoin.amos.boot.module.jxiop.biz.tdengine.PvHealthIndex">
+        select
+            gateway_id ,
+            station,
+            '子阵' as analysis_obj_type,
+            area,
+            subarray,
+            avg(anomaly) as anomaly,
+            AVG(health_index) as health_index
+        from
+            #{tableName}
+        where
+            analysis_obj_type = #{analysisObjectType}
+          and ts > #{startTime}
+        group by
+            gateway_id,
+            station,
+            analysis_obj_type,
+            area,
+            subarray
+    </select>
+
+    <select id="getInfoListByGroupByCzPv" resultType="com.yeejoin.amos.boot.module.jxiop.biz.tdengine.PvHealthIndex">
+        select
+            gateway_id ,
+            station,
+            '场站' as analysis_obj_type,
+            area,
+            avg(anomaly) as anomaly,
+            AVG(health_index) as health_index
+        from
+            #{tableName}
+        where
+            analysis_obj_type = #{analysisObjectType}
+          and ts > #{startTime}
+        group by
+            gateway_id,
+            station,
+            analysis_obj_type,
+            area
+    </select>
+
+    <select id="getInfoListByGroupByQyPv" resultType="com.yeejoin.amos.boot.module.jxiop.biz.tdengine.PvHealthIndex">
+        select
+            '片区' as analysis_obj_type,
+            area,
+            avg(anomaly) as anomaly,
+            AVG(health_index) as health_index
+        from
+            #{tableName}
+        where
+            analysis_obj_type = #{analysisObjectType}
+          and ts > #{startTime}
+        group by
+            analysis_obj_type,
+            area
+    </select>
 </mapper>