解析json 模板比你且複製，還差變量替換

mqttservice/src/main/java/com/jln/system/web/action/mqtt/Base64decrypt.java

@@ -2,7 +2,6 @@ package com.jln.system.web.action.mqtt;
 
 import com.alibaba.fastjson.JSONObject;
 import com.jln.common.utils.EmptyUtil;
-import com.jln.system.web.action.mqtt.pojo.dto.*;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -11,7 +10,6 @@ import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.stereotype.Component;
 import org.springframework.util.ObjectUtils;
-import java.lang.reflect.Field;
 import java.time.LocalDate;
 import java.time.format.DateTimeFormatter;
 import java.util.*;
@@ -146,7 +144,7 @@ public class Base64decrypt {
         mongoMap.putAll(objectMap);
         mongoMap.remove("_id");
         mongoMap.remove("time");
-
+         millis = Calendar.getInstance().getTimeInMillis();
         //处理实体类在每个字段加上时间
         List<Map<String, Object>> allDto = new ArrayList<>();
         for (Map.Entry<String,Object> entry : mongoMap.entrySet()) {
@@ -154,13 +152,13 @@ public class Base64decrypt {
 
             try {
                 sites.put(entry.getKey(), entry.getValue());
-                sites.put("ts", String.valueOf(millis));
+                sites.put("ts", millis);
                 allDto.add(sites);
             } catch (Exception e) {
                 System.out.println(e);
                 Map<String, Object> site = new HashMap<>();
                 site.put("Status", "2");
-                site.put("ts", String.valueOf(millis));
+                site.put("ts", millis);
                 allDto.add(site);
                 reportDto.put("reported", allDto);
                 reportDto.put("edgeTime", millis);

mqttservice/src/main/java/com/jln/system/web/action/mqtt/MqttStartClient.java

@@ -158,7 +158,8 @@ public class MqttStartClient {
      */
     public void jqr( JsonDataDto jsonDataDto, XBMqttDataUtil xbMqttDataUtil) {
         try {
-            long millis = Calendar.getInstance().getTimeInMillis();
+
+            long millis = System.currentTimeMillis() / 1000;
             //解析sk证书信息
             Integer version= resolveSk(jsonDataDto.getSkurl());
             //reportDto.put("productKey", "PaintRobot");

mqttservice/src/main/java/com/jln/system/web/action/mqtt/init/InitHander.java

@@ -43,7 +43,7 @@ public class InitHander implements CommandLineRunner {
                 List<JSONObject> mongdbTableList= JSONObject.parseObject(j.getJSONObject("reported").getJSONArray("singleField").toString(), List.class);
                 jsonDataDto.setCmdId(j.get("cmdId").toString());
                 jsonDataDto.setMongdbTableb(j.get("mongdbTableb").toString());
-                jsonDataDto.setSequenceId(j.get("sequenceId").toString());
+                jsonDataDto.setSequenceId(Integer.parseInt(j.get("sequenceId").toString()));
                 jsonDataDto.setProductKey(j.get("productKey").toString());
                 jsonDataDto.setSkurl(j.get("skurl").toString());
                 jsonDataDto.setTxtFileUrl(j.get("txtFileUrl").toString());

mqttservice/src/main/java/com/jln/system/web/action/mqtt/pojo/dto/JsonDataDto.java

@@ -36,7 +36,7 @@ public class JsonDataDto {
     private String productKey;
 
     @JsonProperty("sequenceId")
-    private String sequenceId;
+    private Integer sequenceId;
 
     @JsonProperty("clientUuid")
     private String clientUuid;