省份随地图联动修改

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

@@ -150,21 +150,22 @@ public class MonitoringServiceImpl {
                 hashMap.put("lat", Double.valueOf(stationCoordinate.getLaitude()));
                 regionNationWideDto.setPosition(hashMap);
                 regionNationWideDtoList.add(regionNationWideDto);
-                String provinceNameTopic = "";
-                if (provinceName.contains("黑龙江") || provinceName.contains("内蒙古")) {
-                    provinceNameTopic = provinceName.substring(0, 3);
-                } else {
-                    provinceNameTopic = provinceName.substring(0, 2);
-                }
-                try {
-                    emqKeeper.getMqttClient().publish("proviceName_topic", provinceNameTopic.getBytes(StandardCharsets.UTF_8), 1, true);
-                    logger.info("----------------------------------推送省份名称消息成功败--------------------------------");
-                } catch (MqttException e) {
-                    logger.info("----------------------------------推送省份名称消息失败--------------------------------");
-                }
-                getCompletionOfPowerIndicatorsByCurrentData(provinceName);
             }
-
+            String provinceNameTopic = "";
+            if (provinceName.contains("黑龙江") || provinceName.contains("内蒙古")) {
+                provinceNameTopic = provinceName.substring(0, 3);
+            } else {
+                provinceNameTopic = provinceName.substring(0, 2);
+            }
+            HashMap<String,String> stringHashMap =new HashMap<>();
+            stringHashMap.put("title",provinceNameTopic+"区域");
+            try {
+                emqKeeper.getMqttClient().publish("proviceName_topic",JSON.toJSON(stringHashMap).toString().getBytes("UTF-8"), 1, true);
+                logger.info("----------------------------------推送省份名称消息成功败--------------------------------");
+            } catch (Exception e) {
+                logger.info("----------------------------------推送省份名称消息失败--------------------------------");
+            }
+            getCompletionOfPowerIndicatorsByCurrentData(provinceName);
         }
         return regionNationWideDtoList;
     }