修改

huimv-env-device/src/main/java/com/huimv/env/device/service/impl/DataServiceImpl.java

@@ -72,7 +72,13 @@ public class DataServiceImpl implements DataService {
                 paramMap.put("number", energyWater.getChipCode());
                 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                 paramMap.put("date", sdf.format(energyWater.getCreateDate()));
-                paramMap.put("dosage", energyWater.getWaterValue());
+                Double aDouble = Double.valueOf(energyWater.getWaterValue());
+                if (aDouble > 100) {
+                    paramMap.put("dosage", "0");
+                } else {
+                    paramMap.put("dosage", energyWater.getWaterValue());
+                }
+
                 paramMap.put("reading", energyWater.getOther3());
                 paramMap.put("type", "水表");
                 String result = HttpRequest.post("http://wxdj.htpig.cn:9006/index.php/index/hydropower/hydropowerAdd").header(Header.CONTENT_TYPE, "application/json")
@@ -91,7 +97,13 @@ public class DataServiceImpl implements DataService {
                 paramMap.put("number", energyElectricity.getChipCode());
                 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                 paramMap.put("date", sdf.format(energyElectricity.getCreateDate()));
-                paramMap.put("dosage", energyElectricity.getElectricityValue());
+                Double aDouble = Double.valueOf(energyElectricity.getElectricityValue());
+                if (aDouble > 1000) {
+                    paramMap.put("dosage", "0");
+                } else {
+                    paramMap.put("dosage", energyElectricity.getElectricityValue());
+                }
+
                 paramMap.put("reading", energyElectricity.getOther3());
                 paramMap.put("type", "电表");
                 String result = HttpRequest.post("http://wxdj.htpig.cn:9006/index.php/index/hydropower/hydropowerAdd").header(Header.CONTENT_TYPE, "application/json")

huimv-env-device/src/main/resources/application-prod.yml

@@ -27,7 +27,7 @@ spring:
 #    #虚拟host 可以不设置,使用server默认host
 #    virtual-host: /
   rabbitmq:
-    host: 121.36.134.218
+    host: 139.9.172.209
     port: 5672
     username: admin
     password: admin