mqtt修改

business-service/src/main/java/com/ozs/service/entity/vo/UpdateDeviceSn.java

@@ -1,6 +1,7 @@
 package com.ozs.service.entity.vo;
 
 
+import com.fasterxml.jackson.annotation.JsonProperty;
 import lombok.Data;
 
 /**
@@ -13,4 +14,14 @@ public class UpdateDeviceSn {
     private String md5;
     private String url;
     private String sign;
+
+
+    @JsonProperty("Name")
+    public String getName() {
+        return Name;
+    }
+
+    public void setName(String name) {
+        Name = name;
+    }
 }

business-service/src/main/java/com/ozs/service/utils/PublishClient.java

@@ -2,6 +2,8 @@ package com.ozs.service.utils;
 
 import com.alibaba.fastjson2.JSON;
 import com.alibaba.fastjson2.JSONObject;
+import com.alibaba.fastjson2.filter.Filter;
+import com.alibaba.fastjson2.filter.SimplePropertyPreFilter;
 import com.ozs.common.utils.sign.Md5Utils;
 import com.ozs.common.utils.stateSecrets.SM4Utils;
 import com.ozs.common.utils.uuid.IdUtils;
@@ -110,6 +112,20 @@ public class PublishClient {
         publish(getMqttTopic("heart_" + deviceSn), message);
     }
 
+    public static void main(String[] args) {
+        UpdateDeviceSn updateDeviceSn = new UpdateDeviceSn();
+        updateDeviceSn.setName("UpdateRequest");
+        updateDeviceSn.setType(2);
+        updateDeviceSn.setMd5("2");
+        updateDeviceSn.setSign(IdUtils.fastSimpleUUID());
+        updateDeviceSn.setUrl("3");
+
+        String s = JSON.toJSONString(updateDeviceSn);
+
+        System.out.println(s);
+
+    }
+
     public static void updateDeviceSn(BaseCameraVersionVo baseCameraVersionVo) {
         /**
          * 发布客户端