udpate

pom.xml

@@ -35,6 +35,11 @@
       <scope>runtime</scope>
       <optional>true</optional>
     </dependency>
+    <dependency>
+      <groupId>com.fasterxml.jackson.datatype</groupId>
+      <artifactId>jackson-datatype-jsr310</artifactId>
+      <version>2.13.4</version>
+    </dependency>
     <!-- 安全,防御,加密 -->
     <dependency>
       <groupId>org.springframework.boot</groupId>

src/main/java/com/free/controller/TestController.java

@@ -28,22 +28,27 @@ public class TestController {
   @Autowired
   private TestService testService;
 
-
   @Autowired
   MqService mqService;
-  
+
   @PassToken
-  @GetMapping("/mq/send") 
+  @GetMapping("/mq/send")
   public Object mqSendTest() throws JsonProcessingException {
     String messageId = String.valueOf(UUID.randomUUID());
     String messageData = "message: M A N ";
     String createTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
     Map<String, Object> manMap = new HashMap<>();
-    manMap.put("messageId", messageId);
+    manMap.put("messageId", null);
     manMap.put("messageData", messageData);
     manMap.put("createTime", createTime);
+    Map data = new HashMap();
+    data.put("value","tesF");
+    data.put("create_time", LocalDateTime.now());
+    Long l = null;
+    data.put("l", l);
+    manMap.put("data", data);
     mqService.sendMsg(MqListeners.userExName, MqListeners.userQueue + ".1", manMap);
-    return ResponseFormat.success();
+    return ResponseFormat.success(data);
   }
 
   /**

src/main/java/com/free/mq/MqService.java

@@ -9,10 +9,12 @@ import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import com.fasterxml.jackson.annotation.JsonInclude.Include;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
 import com.free.entity.TransferApply;
-import com.free.service.system.CustomerService;
+import com.free.utils.FormatJavaTimeModule;
 import com.free.utils.Utils;
 
 @Service
@@ -33,6 +35,9 @@ public class MqService {
   public void sendMsg(String ex, String queue, Map msg) throws JsonProcessingException {
     String strMsg = null;
     ObjectMapper mapper = new ObjectMapper();
+    mapper.setSerializationInclusion(Include.NON_NULL);
+    JavaTimeModule jtmf = FormatJavaTimeModule.init();
+    mapper.registerModule(jtmf);
     strMsg = mapper.writeValueAsString(msg);
     rabbitTemplate.convertAndSend(ex, queue, strMsg);
   }

src/main/java/com/free/utils/FormatJavaTimeModule.java

@@ -0,0 +1,19 @@
+package com.free.utils;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
+import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateTimeDeserializer;
+import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;
+
+public class FormatJavaTimeModule {
+  public static JavaTimeModule init() {
+    JavaTimeModule javaTimeModule = new JavaTimeModule();
+    javaTimeModule.addSerializer(LocalDateTime.class,
+        new LocalDateTimeSerializer(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+    javaTimeModule.addDeserializer(LocalDateTime.class,
+        new LocalDateTimeDeserializer(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
+    return javaTimeModule;
+  }
+}

src/main/resources/application.yml

@@ -39,6 +39,7 @@ spring:
     #设置空如何序列化
     default-property-inclusion: non_null
     serialization:
+      WRITE_DATES_AS_TIMESTAMPS: false
       #格式化输出
       indent_output: true
       #忽略无法转换的对象