增加移动电子秤

huimv-admin/src/main/java/com/huimv/guowei/admin/mqtt/moveScale/DataBack.java

@@ -62,6 +62,22 @@ public class DataBack implements MqttCallback {
             System.out.println(bg);
             System.out.println("数据处理完成！");
         }
+        if (s1.equals("865328063440043")) {
+            IEnvMoveCallService iEnvMoveCallService = SpringUtil.getBean(IEnvMoveCallService.class);
+            System.out.println(s1);
+            String s2 = split[1];
+            String substring = s2.substring(0, 9);
+            BigDecimal bg = new BigDecimal(substring);
+            EnvMoveCall envMoveCall = new EnvMoveCall();
+            envMoveCall.setCallDate(date);
+            envMoveCall.setCallCode(s1);
+            envMoveCall.setCallName("移动电子秤2");
+            envMoveCall.setDuckWeight(bg);
+            envMoveCall.setFarmId(21);
+            iEnvMoveCallService.save(envMoveCall);
+            System.out.println(bg);
+            System.out.println("数据处理完成！");
+        }
 
     }
 

huimv-admin/src/main/java/com/huimv/guowei/admin/mqtt/moveScale/ReceiveData.java

@@ -52,6 +52,10 @@ public class ReceiveData extends Thread {
                     //订阅消息
                     client.subscribe("huimv_GW_down",0);
                 }
+                if (topic.equals("865328063440043")) {
+                    //订阅消息
+                    client.subscribe("huimv_GW_down",0);
+                }
             }
         } catch (Exception e) {
             e.printStackTrace();