From 19ea822c94978daff7d137f9a7fdb85ec9f0554d Mon Sep 17 00:00:00 2001
From: Eunjin3395 <jennyeunjin@khu.ac.kr>
Date: Sun, 13 Oct 2024 19:41:29 +0900
Subject: [PATCH] =?UTF-8?q?:sparkles:=20[Feat]=20socket=20=EC=84=9C?=
 =?UTF-8?q?=EB=B2=84=20=EB=A7=A4=EB=84=88=ED=8F=89=EA=B0=80=20=EB=A9=94?=
 =?UTF-8?q?=EC=8B=9C=EC=A7=80=20=EC=A0=84=EC=86=A1=20API=20=EC=9A=94?=
 =?UTF-8?q?=EC=B2=AD=20=EC=8B=9C=20timestamp=20=EA=B0=92=20=EC=B6=94?=
 =?UTF-8?q?=EA=B0=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/gamegoo/scheduler/SchedulerService.java  | 7 ++++---
 .../java/com/gamegoo/service/socket/SocketService.java     | 4 +++-
 2 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/gamegoo/scheduler/SchedulerService.java b/src/main/java/com/gamegoo/scheduler/SchedulerService.java
index 40327ffd..37827c09 100644
--- a/src/main/java/com/gamegoo/scheduler/SchedulerService.java
+++ b/src/main/java/com/gamegoo/scheduler/SchedulerService.java
@@ -1,5 +1,6 @@
 package com.gamegoo.scheduler;
 
+import com.gamegoo.domain.chat.Chat;
 import com.gamegoo.domain.matching.MatchingRecord;
 import com.gamegoo.domain.matching.MatchingStatus;
 import com.gamegoo.repository.matching.MatchingRecordRepository;
@@ -31,7 +32,7 @@ public class SchedulerService {
      * 매칭 성공 1시간이 경과한 경우, 두 사용자에게 매너평가 시스템 메시지 전송
      */
     @Transactional
-    @Scheduled(fixedRate = 1000 * 60) // 60초 주기로 실행
+    @Scheduled(fixedRate = 5 * 60 * 1000) // 5 * 60초 주기로 실행
     public void mannerSystemMessageRun() {
 //        log.info("scheduler start");
 
@@ -47,7 +48,7 @@ public void mannerSystemMessageRun() {
             ).ifPresentOrElse(
                 chatroom -> {
                     // 시스템 메시지 생성 및 db 저장
-                    chatCommandService.createAndSaveSystemChat(
+                    Chat createdChat = chatCommandService.createAndSaveSystemChat(
                         chatroom, matchingRecord.getMember(), MANNER_SYSTEM_MESSAGE, null, 1);
 
                     // 매너 평가 메시지 전송 여부 업데이트
@@ -55,7 +56,7 @@ public void mannerSystemMessageRun() {
 
                     // socket 서버에게 메시지 전송 API 요청
                     socketService.sendSystemMessage(matchingRecord.getMember().getId(),
-                        chatroom.getUuid(), MANNER_SYSTEM_MESSAGE);
+                        chatroom.getUuid(), MANNER_SYSTEM_MESSAGE, createdChat.getTimestamp());
                 },
                 () -> log.info("Chatroom not found, member ID: {}, target member ID: {}",
                     matchingRecord.getMember().getId(), matchingRecord.getTargetMember().getId()));
diff --git a/src/main/java/com/gamegoo/service/socket/SocketService.java b/src/main/java/com/gamegoo/service/socket/SocketService.java
index 1e40c9d3..ee09a60a 100644
--- a/src/main/java/com/gamegoo/service/socket/SocketService.java
+++ b/src/main/java/com/gamegoo/service/socket/SocketService.java
@@ -54,12 +54,14 @@ public void joinSocketToChatroom(Long memberId, String chatroomUuid) {
         }
     }
 
-    public void sendSystemMessage(Long memberId, String chatroomUuid, String content) {
+    public void sendSystemMessage(Long memberId, String chatroomUuid, String content,
+        Long timestamp) {
         String url = SOCKET_SERVER_URL + "/socket/sysmessage";
         Map<String, Object> requestBody = new HashMap<>();
         requestBody.put("memberId", memberId);
         requestBody.put("chatroomUuid", chatroomUuid);
         requestBody.put("content", content);
+        requestBody.put("timestamp", timestamp);
 
         try {
             ResponseEntity<String> response = restTemplate.postForEntity(url, requestBody,