Fix Deserialize Java Json Notification

Author: yunomix2834

notification-service/src/main/java/com/codecampus/notification/configuration/config/JacksonConfig.java

@@ -0,0 +1,25 @@
+package com.codecampus.notification.configuration.config;
+
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+
+@Configuration
+public class JacksonConfig {
+
+  @Bean
+  @Primary
+  public ObjectMapper objectMapper() {
+    ObjectMapper mapper = new ObjectMapper();
+    mapper.registerModule(new JavaTimeModule());
+    // serialize Instant/LocalDateTime theo ISO-8601 thay vì epoch timestamp
+    mapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
+    // không tự ý đổi timezone khi parse
+    mapper.disable(DeserializationFeature.ADJUST_DATES_TO_CONTEXT_TIME_ZONE);
+    return mapper;
+  }
+}

notification-service/src/main/java/com/codecampus/notification/repository/client/IdentityClient.java

@@ -1,6 +1,5 @@
 package com.codecampus.notification.repository.client;
 
-import com.codecampus.notification.configuration.feign.AuthenticationRequestInterceptor;
 import com.codecampus.notification.configuration.feign.FeignConfigForm;
 import com.codecampus.notification.dto.common.ApiResponse;
 import com.codecampus.notification.dto.request.IntrospectRequest;
@@ -13,8 +12,7 @@
     name = "identity-client",
     url = "${app.services.identity}",
     path = "/auth",
-    configuration = {AuthenticationRequestInterceptor.class,
-        FeignConfigForm.class}
+    configuration = FeignConfigForm.class
 )
 public interface IdentityClient {
   @PostMapping(

notification-service/src/main/java/com/codecampus/notification/service/NotificationStatusService.java

@@ -4,6 +4,7 @@
 import com.codecampus.notification.repository.NotificationRepository;
 import com.mongodb.client.result.UpdateResult;
 import java.time.Instant;
+import java.util.Map;
 import java.util.Set;
 import lombok.AccessLevel;
 import lombok.RequiredArgsConstructor;
@@ -44,10 +45,10 @@ public long markRead(
 
     // push realtime để UI cập nhật
     socketPushService.pushToUserEvent(recipient, "notification-status",
-        java.util.Map.of(
+        Map.of(
             "action", "READ",
             "ids", ids,
-            "at", ts
+            "at", ts.toEpochMilli()
         )
     );
 
@@ -72,7 +73,7 @@ public long markUnread(String recipient, Set<String> ids) {
         mongoTemplate.updateMulti(q, u, NotificationDocument.class);
 
     socketPushService.pushToUserEvent(recipient, "notification-status",
-        java.util.Map.of(
+        Map.of(
             "action", "UNREAD",
             "ids", ids
         )
@@ -100,7 +101,7 @@ public long markAllRead(String recipient, Instant before, Instant at) {
         mongoTemplate.updateMulti(q, u, NotificationDocument.class);
 
     socketPushService.pushToUserEvent(recipient, "notification-status",
-        java.util.Map.of(
+        Map.of(
             "action", "READ_ALL",
             "before", before,
             "at", ts

notification-service/src/main/java/com/codecampus/notification/service/kafka/NotificationEventListener.java

@@ -57,7 +57,8 @@ public void onNotificationEvent(String raw) {
       payload.put("subject", doc.getSubject());
       payload.put("body", doc.getBody());
       payload.put("param", doc.getParam());
-      payload.put("createdAt", doc.getCreatedAt());
+      payload.put("createdAt", doc.getCreatedAt() == null ? null :
+          doc.getCreatedAt().toEpochMilli());
       payload.put("readStatus", doc.getReadStatus());
 
       // 3) Gửi đúng kênh

submission-service/src/main/java/com/codecampus/submission/configuration/config/JacksonConfig.java

@@ -0,0 +1,25 @@
+package com.codecampus.submission.configuration.config;
+
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
+import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+
+@Configuration
+public class JacksonConfig {
+
+  @Bean
+  @Primary
+  public ObjectMapper objectMapper() {
+    ObjectMapper mapper = new ObjectMapper();
+    mapper.registerModule(new JavaTimeModule());
+    // serialize Instant/LocalDateTime theo ISO-8601 thay vì epoch timestamp
+    mapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
+    // không tự ý đổi timezone khi parse
+    mapper.disable(DeserializationFeature.ADJUST_DATES_TO_CONTEXT_TIME_ZONE);
+    return mapper;
+  }
+}