监盘接口相关代码提交

amos-boot-system-jxiop/amos-boot-module-jxiop-api/src/main/java/com/yeejoin/amos/boot/module/jxiop/api/mapper/MonitorFanIndicatorMapper.java

@@ -28,4 +28,5 @@ public interface MonitorFanIndicatorMapper extends BaseMapper<MonitorFanIndicato
                                           @Param("frontModule") String frontModule,
                                           @Param("offset") int offset);
    Object getIndicatoralueAvage(String gateway,String indicator);
+   Object getIndicatoralueTotal(String gateway,String indicator);
 }

amos-boot-system-jxiop/amos-boot-module-jxiop-api/src/main/resources/mapper/MonitorFanIndicatorMapper.xml

@@ -72,4 +72,10 @@
         WHERE gateway=#{gateway} and
         indicator like concat('%',#{indicator},'%')
     </select>
+    <select id="getIndicatoralueAvage" resultType="Object">
+        SELECT SUM(indicator_value) total
+        FROM monitor_fan_indicator
+        WHERE gateway=#{gateway} and
+        indicator like concat('%',#{indicator},'%')
+    </select>
 </mapper>

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

@@ -104,5 +104,15 @@ public class MonitorFanIndicatorImpl implements IMonitorFanIndicator {
     public Object getIndicatoralueAvage(String gateway,String indicator){
         return  monitorFanIndicatorregionMapper.getIndicatoralueAvage(gateway,indicator);
     }
+    /**
+     * 根据网关与指标获取指标的平均值
+     * @param gateway
+     * @param indicator
+     * @return
+     */
+    public Object getIndicatoralueTotal(String gateway,String indicator){
+        return  monitorFanIndicatorregionMapper.getIndicatoralueTotal(gateway,indicator);
+    }
+
 }
 

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

@@ -55,6 +55,7 @@ public class MonitoringServiceImpl {
      */
    public List<RegionNationWideDto> getNationWideInfo(String provinceName){
         List<RegionNationWideDto> regionNationWideDtoList= new ArrayList<>();
+        //如果 provinceName 为空则表示当前为全国地图 否则则为省份地图
         if(ObjectUtils.isEmpty(provinceName)||provinceName.equals("")){
             List<Region> regionList  = this.regionMapper.selectList(new QueryWrapper<Region>().eq("level",1));
             for (int i = 0; i < regionList.size(); i++) {
@@ -66,6 +67,9 @@ public class MonitoringServiceImpl {
                 Region region = regionList.get(i);
                 List<StationBasic> list = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().like("belong_area",region.getRegionCode()));
                 list.forEach(stationBasic -> {
+                    if(!ObjectUtils.isEmpty(stationBasic.getGatewayId())&&!ObjectUtils.isEmpty(stationBasic.getStationNumber())){
+                        regionNationWideDto.setJsJoin(true);
+                    }
                     if(stationBasic.getStationType().equals("FDZ")){
                         fengdianMW.set(getStationCaPACITYL(stationBasic.getStationNumber()));
                         fengdian.getAndSet(fengdian.get() + 1);
@@ -88,8 +92,10 @@ public class MonitoringServiceImpl {
                 RegionNationWideDto regionNationWideDto =new RegionNationWideDto();
                 regionNationWideDto.setStaitionName(stationBasic.getStationName());
                 regionNationWideDto.setStaitionType(stationBasic.getStationType());
+                String speendOrirradiate = "";
                 if(stationBasic.getStationType().equals("FDZ")){
-
+                    speendOrirradiate = (String) getIndicatoralueAvage(stationBasic.getGatewayId(),"30秒平均风速");
+                    regionNationWideDto.setSpeendOrirradiate(speendOrirradiate);
                 }else{
                     regionNationWideDto.setSpeendOrirradiate(String.valueOf(Math.random()*1000));
                 }
@@ -112,4 +118,38 @@ public class MonitoringServiceImpl {
     public Double getStationCaPACITYL(String werks){
        return this.SjglZsjZsbtzServiceImpl.getStationCapactityByStationWerks(werks);
     }
+
+    /**
+     * 根据网关id以及指标值 获取同一网关下指标的平均值
+     * @param gateway 网关id
+     * @param indicatorcName 指标名称
+     * @return 同一网关下指标的平均值
+     */
+    public Object getIndicatoralueAvage (String gateway ,String indicatorcName){
+        return this.monitorFanIndicatorImpl.getIndicatoralueAvage(gateway,indicatorcName);
+    }
+    /**
+     * 根据网关id以及指标值 同一网关下指标的值总和
+     * @param gateway 网关id
+     * @param indicatorcName 指标名称
+     * @return 同一网关下指标的值总和
+     */
+    public Object getIndicatoralueTotal (String gateway ,String indicatorcName){
+        return this.monitorFanIndicatorImpl.getIndicatoralueTotal(gateway,indicatorcName);
+    }
+
+    public void  getTotalSocialContribution(){
+        HashMap<String,Double> hashMap = new HashMap<>();
+        AtomicReference<Double> totalSocialContribution = new AtomicReference<>(0.0);
+        //获取所有网关id不为空的数据
+        List<StationBasic> stationBasicList = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("gateway_id"));
+        stationBasicList.forEach(stationBasic -> {
+            totalSocialContribution.updateAndGet(v -> v + (Double) monitorFanIndicatorImpl.getIndicatoralueTotal(stationBasic.getStationNumber(), "年发电量"));
+        });
+        //
+//        hashMap.put("CO2",(totalSocialContribution * 0.3049)/1000000);
+//        hashMap.put("Coal",totalSocialContribution*);
+//        hashMap.put("Toner",totalSocialContribution*);
+//        hashMap.put("S02",totalSocialContribution*);
+    }
 }