监盘全国接口数据调整

amos-boot-system-jxiop/amos-boot-module-jxiop-monitor-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/controller/MonitoringMapController.java

@@ -137,4 +137,11 @@ public class MonitoringMapController extends BaseController {
     public ResponseModel<Page<HashMap<String, String>>> getPowerGenerationTrendsOfCompletionTopThree(@RequestParam(required = false)String areaName,@RequestParam(required = false,defaultValue = "0")String tabValue) {
         return  ResponseHelper.buildResponse(monitoringServiceImpl.getPowerGenerationTrendsOfCompletionTopThree(tabValue,areaName));
     }
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
+    @ApiOperation(value = "运行监盘-获取全国数据")
+    @GetMapping("/getTotalData")
+    public void getTotalData() {
+          monitoringServiceImpl.getTotalData();
+    }
 }

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

@@ -3,7 +3,6 @@ package com.yeejoin.amos.boot.module.jxiop.biz.service.impl;
 import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.sun.org.apache.bcel.internal.generic.NEW;
 import com.yeejoin.amos.boot.module.jxiop.api.entity.MapRegion;
 import com.yeejoin.amos.boot.module.jxiop.api.entity.Region;
 import com.yeejoin.amos.boot.module.jxiop.api.entity.StationBasic;
@@ -21,8 +20,8 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.util.ObjectUtils;
 import org.typroject.tyboot.component.emq.EmqKeeper;
-import org.unbescape.css.CssIdentifierEscapeLevel;
 
+import java.math.BigDecimal;
 import java.net.URLDecoder;
 import java.util.*;
 import java.util.concurrent.atomic.AtomicReference;
@@ -463,7 +462,7 @@ public class MonitoringServiceImpl {
         if (!ObjectUtils.isEmpty(areaName)) {
             stationBasicListAll = getListOfStationBasicByAreaName(areaName);
         } else {
-            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("station_name"));
+            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("fan_gateway_id"));
         }
         Map<String, List<StationBasic>> listMap = stationBasicListAll.stream().collect(Collectors.groupingBy(stationBasic -> stationBasic.getStationTypeName()));
         listMap.keySet().forEach(key -> {
@@ -483,7 +482,7 @@ public class MonitoringServiceImpl {
         if (!ObjectUtils.isEmpty(areaName)) {
             stationBasicListAll = getListOfStationBasicByAreaName(areaName);
         } else {
-            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("station_name"));
+            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("fan_gateway_id"));
         }
         stationBasicListAll.forEach(stationBasic -> {
             total.updateAndGet(v -> v + getStationCaPACITYL(stationBasic.getStationNumber()));
@@ -500,7 +499,7 @@ public class MonitoringServiceImpl {
         if (!ObjectUtils.isEmpty(areaName)) {
             stationBasicListAll = getListOfStationBasicByAreaName(areaName);
         } else {
-            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("station_name"));
+            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("fan_gateway_id"));
         }
         stationBasicListAll.forEach(stationBasic -> {
             total.updateAndGet(v -> v + commonServiceImpl.getTotalByIndicatior(stationBasic.getFanGatewayId(), "有功功率"));
@@ -526,7 +525,7 @@ public class MonitoringServiceImpl {
         } else if (!ObjectUtils.isEmpty(areaName)) {
             stationBasicListAll = getListOfStationBasicByAreaName(areaName);
         } else {
-            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("station_name"));
+            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("fan_gateway_id"));
         }
         stationBasicListAll.forEach(stationBasic -> {
             total.updateAndGet(v -> v + commonServiceImpl.getTotalByIndicatior(stationBasic.getFanGatewayId(), "年发电量"));
@@ -539,7 +538,7 @@ public class MonitoringServiceImpl {
         if (!ObjectUtils.isEmpty(areaName)) {
             stationBasicListAll = getListOfStationBasicByAreaName(areaName);
         } else {
-            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("station_name"));
+            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("fan_gateway_id"));
         }
         //月发电量
         AtomicReference<Double> monthlyPower = new AtomicReference<>(0.0);
@@ -548,7 +547,7 @@ public class MonitoringServiceImpl {
         });
         HashMap<String, List<String>> hashMap = new HashMap<>();
         List<String> xList = getXListofRecentOneYear();
-        List<String> yList = Arrays.asList("0","0","0","0","0","0","0","0","0","0","12000",String.format("%.2f", monthlyPower.get()/1000));
+        List<String> yList = Arrays.asList("0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "12000", String.format("%.2f", monthlyPower.get() / 1000));
         hashMap.put("axisData", xList);
         hashMap.put("seriesData", yList);
         return hashMap;
@@ -606,7 +605,7 @@ public class MonitoringServiceImpl {
         if (!ObjectUtils.isEmpty(areaName)) {
             stationBasicListAll = getListOfStationBasicByAreaName(areaName);
         } else {
-            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("station_name"));
+            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("fan_gateway_id"));
         }
         //月发电量
         AtomicReference<Double> monthlyPower = new AtomicReference<>(0.0);
@@ -615,7 +614,7 @@ public class MonitoringServiceImpl {
         });
         HashMap<String, List<String>> hashMap = new HashMap<>();
         List<String> xList = getXListofRecentOneYear();
-        List<String> yList = Arrays.asList("0","0","0","0","0","0","0","0","0","0","120",String.format("%.2f", monthlyPower.get()%200));
+        List<String> yList = Arrays.asList("0", "0", "0", "0", "0", "0", "0", "0", "0", "0", "120", String.format("%.2f", monthlyPower.get() % 200));
         hashMap.put("axisData", xList);
         hashMap.put("seriesData", yList);
         return hashMap;
@@ -627,7 +626,7 @@ public class MonitoringServiceImpl {
         if (!ObjectUtils.isEmpty(areaName)) {
             stationBasicListAll = getListOfStationBasicByAreaName(areaName);
         } else {
-            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("station_name"));
+            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("fan_gateway_id"));
         }
         HashMap<String, List<String>> hashMap = new HashMap<>();
         List<String> xList = new ArrayList<>();
@@ -635,9 +634,9 @@ public class MonitoringServiceImpl {
         //月发电量
         AtomicReference<Double> monthlyPower = new AtomicReference<>(0.0);
         stationBasicListAll.forEach(stationBasic -> {
-           stationBasic.setAddress(String.format("%.2f",commonServiceImpl.getTotalByIndicatior(stationBasic.getFanGatewayId(),"月发电量")%100));
+            stationBasic.setAddress(String.format("%.2f", commonServiceImpl.getTotalByIndicatior(stationBasic.getFanGatewayId(), "月发电量") % 100));
         });
-        List<StationBasic> sorted = stationBasicListAll.stream().sorted(Comparator.comparing(StationBasic::getAddress,Comparator.comparingDouble(Double::parseDouble)).reversed()).collect(Collectors.toList());
+        List<StationBasic> sorted = stationBasicListAll.stream().sorted(Comparator.comparing(StationBasic::getAddress, Comparator.comparingDouble(Double::parseDouble)).reversed()).collect(Collectors.toList());
         sorted.forEach(stationBasic -> {
             xList.add(stationBasic.getStationName());
             yList.add(stationBasic.getAddress());
@@ -648,7 +647,7 @@ public class MonitoringServiceImpl {
     }
 
 
-    public List<String> getXListofRecentOneYear(){
+    public List<String> getXListofRecentOneYear() {
         List<String> xList = new ArrayList<>();
         Calendar calendar = Calendar.getInstance();
         Date date = new Date();
@@ -661,60 +660,60 @@ public class MonitoringServiceImpl {
     }
 
 
-    public Page<HashMap<String,String>> getPowerGenerationTrendsOfCompletionTopThree(String tabValue,String areaName){
-        Page<HashMap<String,String>> page = new Page<>(1,3);
-        List<HashMap<String,String>> mapList= new ArrayList<>();
+    public Page<HashMap<String, String>> getPowerGenerationTrendsOfCompletionTopThree(String tabValue, String areaName) {
+        Page<HashMap<String, String>> page = new Page<>(1, 3);
+        List<HashMap<String, String>> mapList = new ArrayList<>();
         List<StationBasic> stationBasicListAll = new ArrayList<>();
         List<StationBasic> fdzList = new ArrayList<>();
         List<StationBasic> gfdzlist = new ArrayList<>();
         if (!ObjectUtils.isEmpty(areaName)) {
             stationBasicListAll = getListOfStationBasicByAreaName(areaName);
         } else {
-            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("station_name"));
+            stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("fan_gateway_id"));
         }
         String indicator = "日发电量";
-        if(tabValue.equals(1)){
-           indicator="月发电量";
-        }else{
-            indicator="年发电量";
+        if (tabValue.equals(1)) {
+            indicator = "月发电量";
+        } else {
+            indicator = "年发电量";
         }
         //填写发电小时数
         String finalIndicator = indicator;
         stationBasicListAll.forEach(stationBasic -> {
-            Double install=getStationCaPACITYL(stationBasic.getStationNumber());
-            Double total =commonServiceImpl.getTotalByIndicatior(stationBasic.getFanGatewayId(), finalIndicator);
-            stationBasic.setAddress(String.format("%.2f",total));
-            if(stationBasic.getStationType().equals("FDZ")){
-                stationBasic.setAddress(String.format("%.2f",total/100/install));
-            }else {
-                stationBasic.setAddress(String.format("%.2f",total/1000000/install));
+            Double install = getStationCaPACITYL(stationBasic.getStationNumber());
+            Double total = commonServiceImpl.getTotalByIndicatior(stationBasic.getFanGatewayId(), finalIndicator);
+            stationBasic.setAddress(String.format("%.2f", total));
+            if (stationBasic.getStationType().equals("FDZ")) {
+                stationBasic.setAddress(String.format("%.2f", total / 100 / install));
+            } else {
+                stationBasic.setAddress(String.format("%.2f", total / 1000000 / install));
             }
-            if(stationBasic.getAddress().equals("NaN")){
+            if (stationBasic.getAddress().equals("NaN")) {
                 stationBasic.setAddress("0.00");
             }
         });
         //分组并排序
-        fdzList = stationBasicListAll.stream().filter(stationBasic -> stationBasic.getStationType().equals("FDZ")).collect(Collectors.toList()).stream().sorted(Comparator.comparing(StationBasic::getAddress,Comparator.comparingDouble(Double::parseDouble)).reversed()).collect(Collectors.toList());
-        gfdzlist = stationBasicListAll.stream().filter(stationBasic -> !stationBasic.getStationType().equals("FDZ")).collect(Collectors.toList()).stream().sorted(Comparator.comparing(StationBasic::getAddress,Comparator.comparingDouble(Double::parseDouble)).reversed()).collect(Collectors.toList());
-        for (int i = 0; i <3 ; i++) {
-            HashMap<String,String> stringHashMap= new HashMap<>();
-            stringHashMap.put("sortNumber",String.valueOf(i+1));
-            StationBasic stationBasic =new StationBasic();
-            if(i<(fdzList.size())){
+        fdzList = stationBasicListAll.stream().filter(stationBasic -> stationBasic.getStationType().equals("FDZ")).collect(Collectors.toList()).stream().sorted(Comparator.comparing(StationBasic::getAddress, Comparator.comparingDouble(Double::parseDouble)).reversed()).collect(Collectors.toList());
+        gfdzlist = stationBasicListAll.stream().filter(stationBasic -> !stationBasic.getStationType().equals("FDZ")).collect(Collectors.toList()).stream().sorted(Comparator.comparing(StationBasic::getAddress, Comparator.comparingDouble(Double::parseDouble)).reversed()).collect(Collectors.toList());
+        for (int i = 0; i < 3; i++) {
+            HashMap<String, String> stringHashMap = new HashMap<>();
+            stringHashMap.put("sortNumber", String.valueOf(i + 1));
+            StationBasic stationBasic = new StationBasic();
+            if (i < (fdzList.size())) {
                 stationBasic = fdzList.get(i);
-                stringHashMap.put("stationName1",stationBasic.getStationName());
-                stringHashMap.put("hours1",stationBasic.getAddress()+"h");
-            }else {
-                stringHashMap.put("stationName1","");
-                stringHashMap.put("hours1","");
+                stringHashMap.put("stationName1", stationBasic.getStationName());
+                stringHashMap.put("hours1", stationBasic.getAddress() + "h");
+            } else {
+                stringHashMap.put("stationName1", "");
+                stringHashMap.put("hours1", "");
             }
-            if(i<(gfdzlist.size())){
+            if (i < (gfdzlist.size())) {
                 stationBasic = gfdzlist.get(i);
-                stringHashMap.put("stationName2",stationBasic.getStationName());
-                stringHashMap.put("hours2",stationBasic.getAddress()+"h");
-            }else {
-                stringHashMap.put("stationName2","");
-                stringHashMap.put("hours2","");
+                stringHashMap.put("stationName2", stationBasic.getStationName());
+                stringHashMap.put("hours2", stationBasic.getAddress() + "h");
+            } else {
+                stringHashMap.put("stationName2", "");
+                stringHashMap.put("hours2", "");
             }
             mapList.add(stringHashMap);
         }
@@ -722,4 +721,123 @@ public class MonitoringServiceImpl {
         //组装数据
         return page;
     }
+
+    public void getTotalData() {
+        List<StationBasic> stationBasicListAll = stationBasicMapper.selectList(new QueryWrapper<StationBasic>().isNotNull("fan_gateway_id"));
+        List<StationBasic> fdzList = stationBasicListAll.stream().filter(stationBasic -> stationBasic.getStationType().equals("FDZ")).collect(Collectors.toList());
+        List<StationBasic> jzsgfdzList = stationBasicListAll.stream().filter(stationBasic -> stationBasic.getStationType().equals("JZSGFDZ")).collect(Collectors.toList());
+        List<StationBasic> fbsgfdzList = stationBasicListAll.stream().filter(stationBasic -> stationBasic.getStationType().equals("FBSGFDZ")).collect(Collectors.toList());
+        List<StationBasic> gfList = stationBasicListAll.stream().filter(stationBasic -> !stationBasic.getStationType().equals("FDZ")).collect(Collectors.toList());
+        Page<HashMap<String, String>> page = new Page<>(1, 10);
+        Page<HashMap<String, String>> page1 = new Page<>(1, 10);
+        Page<HashMap<String, String>> page2 = new Page<>(1, 10);
+        Page<HashMap<String, String>> page3 = new Page<>(1, 10);
+//        ----------------装机容量开始-----------------------
+        List<HashMap<String, String>> list = new ArrayList<>();
+        //装机容量
+        HashMap<String, String> stringHashMap = new HashMap<>();
+        BigDecimal totalInstall = new BigDecimal(getInstallCapity(stationBasicListAll));
+        stringHashMap.put("title", totalInstall.toString());
+        stringHashMap.put("data", "");
+        list.add(stringHashMap);
+        //风电站
+        HashMap<String, String> stringHashMap1 = new HashMap<>();
+        BigDecimal fdzInstall = new BigDecimal(getInstallCapity(fdzList));
+        stringHashMap1.put("title", fdzInstall.toString());
+        stringHashMap1.put("data", String.valueOf(fdzList.size()));
+        list.add(stringHashMap1);
+        //集中式光伏电站
+        HashMap<String, String> stringHashMap2 = new HashMap<>();
+        BigDecimal jzsInstall = new BigDecimal(getInstallCapity(jzsgfdzList));
+        stringHashMap2.put("title", jzsInstall.toString());
+        stringHashMap2.put("data", String.valueOf(jzsgfdzList.size()));
+        list.add(stringHashMap2);
+        //分布式光伏电站
+        HashMap<String, String> stringHashMap3 = new HashMap<>();
+        BigDecimal fbsInstall = new BigDecimal(getInstallCapity(fbsgfdzList));
+        stringHashMap3.put("title", fbsInstall.toString());
+        stringHashMap3.put("data", String.valueOf(fbsgfdzList.size()));
+        list.add(stringHashMap3);
+        page.setRecords(list);
+        BigDecimal gfInstall = new BigDecimal(getInstallCapity(gfList));
+//----------------------装机容量结束----------------------------------------
+//  ----------------装机容量开始-----------------------
+        List<HashMap<String, String>> list1 = new ArrayList<>();
+        List<HashMap<String, String>> list2 = new ArrayList<>();
+        List<HashMap<String, String>> list3 = new ArrayList<>();
+        AtomicReference<Double> powerOfDayFD = new AtomicReference<>(new Double(0.00));
+        AtomicReference<Double> powerOfMonthFD = new AtomicReference<>(new Double(0.00));
+        AtomicReference<Double> powerOfAnnualFD = new AtomicReference<>(new Double(0.00));
+        AtomicReference<Double> powerOfDayGF = new AtomicReference<>(new Double(0.00));
+        AtomicReference<Double> powerOfMonthGF = new AtomicReference<>(new Double(0.00));
+        AtomicReference<Double> powerOfAnnualGF = new AtomicReference<>(new Double(0.00));
+        fdzList.forEach(stationBasic -> {
+            List<Map<String, Object>> mapList;
+            mapList = influxdbUtil.query("SELECT * FROM indicators_" + stationBasic.getFanGatewayId() + " where (equipmentIndexName='日发电量' or  equipmentIndexName='月发电量' or equipmentIndexName='年发电量' or equipmentIndexName='有功功率'  or equipmentIndexName='30秒平均风速' )");
+            powerOfDayFD.updateAndGet(v -> v + commonServiceImpl.getTotalByIndicatior(mapList, "日发电量"));
+            powerOfMonthFD.updateAndGet(v -> v + commonServiceImpl.getTotalByIndicatior(mapList, "月发电量"));
+            powerOfAnnualFD.updateAndGet(v -> v + commonServiceImpl.getTotalByIndicatior(mapList, "年发电量"));
+        });
+        gfList.forEach(stationBasic -> {
+            List<Map<String, Object>> mapList;
+            mapList = influxdbUtil.query("SELECT * FROM indicators_" + stationBasic.getFanGatewayId() + " where (equipmentIndexName='日发电量' or  equipmentIndexName='月发电量' or equipmentIndexName='年发电量' or equipmentIndexName='有功功率'  or equipmentIndexName='30秒平均风速' )");
+            powerOfDayGF.updateAndGet(v -> v + commonServiceImpl.getTotalByIndicatior(mapList, "日发电量"));
+            powerOfMonthGF.updateAndGet(v -> v + commonServiceImpl.getTotalByIndicatior(mapList, "月发电量"));
+            powerOfAnnualGF.updateAndGet(v -> v + commonServiceImpl.getTotalByIndicatior(mapList, "年发电量"));
+        });
+        HashMap<String, String> stringHashMap4 = new HashMap<>();
+        stringHashMap4.put("title", String.format("%.2f", powerOfDayFD.get()) + "/" + String.format("%.2f", powerOfDayGF.get()));
+        list1.add(stringHashMap4);
+        HashMap<String, String> stringHashMap5 = new HashMap<>();
+        stringHashMap5.put("title", String.format("%.2f", powerOfMonthFD.get()) + "/" + String.format("%.2f", powerOfMonthGF.get()));
+        list1.add(stringHashMap5);
+        HashMap<String, String> stringHashMap6 = new HashMap<>();
+        stringHashMap6.put("title", String.format("%.2f", powerOfAnnualFD.get()) + "/" + String.format("%.2f", powerOfAnnualGF.get()));
+        list1.add(stringHashMap6);
+        HashMap<String, String> stringHashMap7 = new HashMap<>();
+        stringHashMap7.put("title", String.format("%.2f", powerOfAnnualFD.get() % 200) + "/" + String.format("%.2f", powerOfAnnualGF.get() % 200));
+        list1.add(stringHashMap7);
+        HashMap<String, String> stringHashMap8 = new HashMap<>();
+        stringHashMap8.put("title", String.format("%.2f", powerOfAnnualFD.get() / fdzInstall.doubleValue()) + "/" + String.format("%.2f", powerOfAnnualGF.get() / gfInstall.doubleValue()));
+        list1.add(stringHashMap8);
+        page1.setRecords(list1);
+        HashMap<String, String> stringHashMap9 = new HashMap<>();
+        stringHashMap9.put("title", String.format("%.2f", powerOfDayFD.get() + powerOfDayGF.get()));
+        list2.add(stringHashMap9);
+        HashMap<String, String> stringHashMap10 = new HashMap<>();
+        stringHashMap10.put("title", String.format("%.2f", powerOfMonthFD.get() + powerOfMonthGF.get()));
+        list2.add(stringHashMap10);
+        HashMap<String, String> stringHashMap11 = new HashMap<>();
+        stringHashMap11.put("title", String.format("%.2f", powerOfMonthFD.get() + powerOfDayGF.get()));
+        list2.add(stringHashMap11);
+        HashMap<String, String> stringHashMap12 = new HashMap<>();
+        stringHashMap12.put("title", String.format("%.2f", (powerOfAnnualFD.get() + powerOfAnnualGF.get()) / totalInstall.doubleValue()));
+        list2.add(stringHashMap12);
+        page2.setRecords(list2);
+        HashMap<String, String> stringHashMap13 = new HashMap<>();
+        stringHashMap13.put("title1", String.format("%.2f", (powerOfAnnualFD.get() + powerOfAnnualGF.get()) * 0.000832));
+        stringHashMap13.put("title2", "二氧化碳减排量（万t）");
+        list3.add(stringHashMap13);
+        HashMap<String, String> stringHashMap14 = new HashMap<>();
+        stringHashMap14.put("title1", String.format("%.2f", (powerOfAnnualFD.get() + powerOfAnnualGF.get()) * 0.0003049));
+        stringHashMap14.put("title2", "节约标准煤（万t）");
+        list3.add(stringHashMap14);
+        HashMap<String, String> stringHashMap15 = new HashMap<>();
+        stringHashMap15.put("title1", String.format("%.2f", (powerOfAnnualFD.get() + powerOfAnnualGF.get()) * 0.00032));
+        stringHashMap15.put("title2", "碳粉尘减排量（万t）");
+        list3.add(stringHashMap15);
+        HashMap<String, String> stringHashMap16 = new HashMap<>();
+        stringHashMap16.put("title1", String.format("%.2f", (powerOfAnnualFD.get() + powerOfAnnualGF.get()) * 0.0016));
+        stringHashMap16.put("title2", "二氧化硫减排量（万t）");
+        list3.add(stringHashMap16);
+        page3.setRecords(list3);
+        try {
+            emqKeeper.getMqttClient().publish("total_zjrl_topic",JSON.toJSON(page).toString().getBytes("UTF-8"),1,true);
+            emqKeeper.getMqttClient().publish("total_ssscsj_topic",JSON.toJSON(page1).toString().getBytes("UTF-8"),1,true);
+            emqKeeper.getMqttClient().publish("total_zssscsj_topic",JSON.toJSON(page2).toString().getBytes("UTF-8"),1,true);
+            emqKeeper.getMqttClient().publish("total_zshgx_topic",JSON.toJSON(page3).toString().getBytes("UTF-8"),1,true);
+        } catch (Exception ex) {
+
+        }
+    }
 }