状态时间接口-状态时间分析、状态转换分析

power-fitting-JN/src/main/java/com.gyee.power.fitting/controller/gf/PhotovoltaicAnalysisController.java

@@ -7,7 +7,11 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.gyee.power.fitting.common.result.JsonResult;
 import com.gyee.power.fitting.common.result.ResultCode;
 import com.gyee.power.fitting.model.PhotovoltaicAnalysis;
+import com.gyee.power.fitting.model.ProBasicEquipment;
+import com.gyee.power.fitting.model.StateCause;
+import com.gyee.power.fitting.model.vo.PageMap;
 import com.gyee.power.fitting.service.IPhotovoltaicAnalysisService;
+import com.gyee.power.fitting.service.IStateCauseService;
 import com.gyee.power.fitting.service.ProBasicEquipmentService;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -15,7 +19,9 @@ import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
+import java.util.Collections;
 import java.util.Date;
+import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 
@@ -35,6 +41,53 @@ public class PhotovoltaicAnalysisController {
     private IPhotovoltaicAnalysisService photovoltaicAnalysisService;
     @Resource
     private ProBasicEquipmentService proBasicEquipmentService;
+    @Resource
+    private IStateCauseService stateCauseService;
+
+    //状态转换
+    @GetMapping("/state_transition")
+    public JSONObject stateTransition(
+            @RequestParam("stationId") String stationId,
+            @RequestParam("startTime") Long startTime,
+            @RequestParam("endTime") Long endTime,
+            @RequestParam("type") String type,
+            @RequestParam("pageNum") int pageNum,
+            @RequestParam("pageSize") int pageSize) {
+
+        List<ProBasicEquipment> equipments = proBasicEquipmentService.getStationMap(type).get(stationId);
+        QueryWrapper<StateCause> scWrapper = new QueryWrapper<>();
+        Page<StateCause> page = new Page<>(pageNum, pageSize);
+        scWrapper.in("equipment_id", equipments).gt("start_time", startTime).lt("end_time", endTime);
+        PageMap<StateCause> stateCauses = (PageMap<StateCause>) stateCauseService.page(page, scWrapper);
+
+        stateCauses.setRecordMap(stateCauses.getRecords().stream().collect(Collectors.groupingBy(StateCause::getEquipmentId)));
+        stateCauses.setRecords(Collections.emptyList());
+        return JsonResult.successData(ResultCode.SUCCESS, stateCauses);
+    }
+
+    //状态时间
+    @GetMapping("/state_time")
+    public JSONObject stateTime(
+            @RequestParam("stationId") String stationId,
+            @RequestParam("startTime") Long startTime,
+            @RequestParam("endTime") Long endTime,
+            @RequestParam("type") String type,
+            @RequestParam("pageNum") int pageNum,
+            @RequestParam("pageSize") int pageSize) {
+
+        List<ProBasicEquipment> equipments = proBasicEquipmentService.getStationMap(type).get(stationId);
+        QueryWrapper<StateCause> scWrapper = new QueryWrapper<>();
+        Page<StateCause> page = new Page<>(pageNum, pageSize);
+        scWrapper.in("equipment_id", equipments).gt("start_time", startTime).lt("end_time", endTime);
+        PageMap<StateCause> stateCauses = (PageMap<StateCause>) stateCauseService.page(page, scWrapper);
+
+        Map<String, Map<Short, Double>> collect = stateCauses.getRecords().stream().collect(Collectors.groupingBy(StateCause::getEquipmentId,
+                Collectors.groupingBy(StateCause::getEvent, Collectors.summingDouble(t -> t.getTime() / (60 * 24.0)))));
+
+        stateCauses.setRecordMap(collect);
+        stateCauses.setRecords(Collections.emptyList());
+        return JsonResult.successData(ResultCode.SUCCESS, stateCauses);
+    }
 
     @GetMapping("/analysis")
     public JSONObject photovoltaicAnalysis(
@@ -68,7 +121,7 @@ public class PhotovoltaicAnalysisController {
         Page<PhotovoltaicAnalysis> page = new Page<>(pageNum, pageSize);
         Page<PhotovoltaicAnalysis> list = photovoltaicAnalysisService.page(page, wrapper);
 
-        Map<String, String> collect = proBasicEquipmentService.getStationMap("IN");
+        Map<String, String> collect = proBasicEquipmentService.getWtNcMap("IN");
 
         list.setRecords(list.getRecords().stream().peek(pa -> pa.setEquipmentId(collect.get(pa.getEquipmentId()))).collect(Collectors.toList()));
         return JsonResult.successData(ResultCode.SUCCESS, list);

power-fitting-JN/src/main/java/com.gyee.power.fitting/dispersionanalysis/CalculateTask.java

@@ -35,7 +35,7 @@ public class CalculateTask {
     //秒 分 时 日 月 周
     @Scheduled(cron = "0 0 2 * * ?")
     public void doTask() {
-        List<ProBasicEquipment> equipmentList = proBasicEquipmentService.getCacheList();
+        List<ProBasicEquipment> equipmentList = proBasicEquipmentService.getCacheList(null);
         Map<String, ProBasicEquipmentPoint> sbztMap = proBasicEquipmentPointService.getEquipmentMapByUniformcode("SBZT");
         Map<String, ProBasicEquipmentPoint> mxztMap = proBasicEquipmentPointService.getEquipmentMapByUniformcode("MXZT");
         //获取最新更新时间
@@ -165,7 +165,7 @@ public class CalculateTask {
     //秒 分 时 日 月 周
 //    @Scheduled(cron = "0 11 10 * * ?")
     public void creatStables() {
-        List<ProBasicEquipment> equipmentList = proBasicEquipmentService.getCacheList();
+        List<ProBasicEquipment> equipmentList = proBasicEquipmentService.getCacheList(null);
 
         String equipmentId, tbName;
         List<StateCause> stateCauseList = new ArrayList<>();

power-fitting-JN/src/main/java/com.gyee.power.fitting/model/vo/PageMap.java

@@ -0,0 +1,18 @@
+package com.gyee.power.fitting.model.vo;
+
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class PageMap<T> extends Page<T> {
+    protected Map recordMap = new HashMap<>();
+
+    public Map getRecordMap() {
+        return recordMap;
+    }
+
+    public void setRecordMap(Map recordMap) {
+        this.recordMap = recordMap;
+    }
+}

power-fitting-JN/src/main/java/com.gyee.power.fitting/service/ProBasicEquipmentService.java

@@ -21,7 +21,9 @@ public interface ProBasicEquipmentService extends IService<ProBasicEquipment> {
 
     List<ProBasicEquipment> selectList(String station);
 
-    Map<String, String> getStationMap(String type);
+    Map<String, String> getWtNcMap(String type);
 
-    List<ProBasicEquipment> getCacheList();
+    Map<String, List<ProBasicEquipment>> getStationMap(String type);
+
+    List<ProBasicEquipment> getCacheList(String type);
 }

power-fitting-JN/src/main/java/com.gyee.power.fitting/service/impl/ProBasicEquipmentServiceImpl.java

@@ -1,5 +1,6 @@
 package com.gyee.power.fitting.service.impl;
 
+import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.gyee.power.fitting.common.base.ExcludeQueryWrapper;
@@ -49,19 +50,31 @@ public class ProBasicEquipmentServiceImpl extends ServiceImpl<ProBasicEquipmentM
         return list;
     }
 
-    @Cacheable("getStationMap")
-    public Map<String, String> getStationMap(String type) {
-        QueryWrapper<ProBasicEquipment> eWrapper = new QueryWrapper<>();
-        eWrapper.eq("spare1", type);
-        List<ProBasicEquipment> eList = baseMapper.selectList(eWrapper);
+    @Cacheable("getWtNcMap")
+    public Map<String, String> getWtNcMap(String type) {
+        QueryWrapper<ProBasicEquipment> wrapper = new QueryWrapper<>();
+        wrapper.eq(StrUtil.isNotBlank(type), "spare1", type);
+        wrapper.orderByAsc("nem_code");
+        List<ProBasicEquipment> eList = baseMapper.selectList(wrapper);
         Map<String, String> collect = eList.stream().collect(Collectors.toMap(ProBasicEquipment::getId, ProBasicEquipment::getNemCode));
         return collect;
     }
 
+    @Cacheable("getStationMap")
+    public Map<String, List<ProBasicEquipment>> getStationMap(String type) {
+        QueryWrapper<ProBasicEquipment> wrapper = new QueryWrapper<>();
+        wrapper.eq(StrUtil.isNotBlank(type), "spare1", type);
+        wrapper.orderByAsc("nem_code");
+        List<ProBasicEquipment> eList = baseMapper.selectList(wrapper);
+        Map<String, List<ProBasicEquipment>> collect = eList.stream().collect(Collectors.groupingBy(ProBasicEquipment::getWindpowerstationId));
+        return collect;
+    }
+
     @Cacheable("getCacheList")
-    public List<ProBasicEquipment> getCacheList() {
+    public List<ProBasicEquipment> getCacheList(String type) {
         QueryWrapper<ProBasicEquipment> wrapper = new QueryWrapper<>();
-        wrapper.orderByAsc("id");
+        wrapper.eq(StrUtil.isNotBlank(type), "spare1", type);
+        wrapper.orderByAsc("nem_code");
         return baseMapper.selectList(wrapper);
     }
 }