[KW-658] refactor: 출입 로그 grpc 레디스 스트림에 저장하도록 수정

src/main/java/com/doubleo/logservice/domain/log/consumer/AreaEnterLogConsumer.java

@@ -40,7 +40,7 @@ public void initGroup() {
         }
     }
 
-    @Scheduled(fixedDelay = 300000)
+    @Scheduled(fixedDelay = 10000)
     public void consumeMessages() {
         List<MapRecord<String, Object, Object>> messages =
                 redisTemplate

src/main/java/com/doubleo/logservice/domain/log/consumer/BuildingEnterLogConsumer.java

@@ -41,7 +41,7 @@ public void initGroup() {
         }
     }
 
-    @Scheduled(fixedDelay = 300000)
+    @Scheduled(fixedDelay = 10000)
     public void consumeMessages() {
         List<MapRecord<String, Object, Object>> messages =
                 redisTemplate

src/main/java/com/doubleo/logservice/domain/log/consumer/RetainedCountConsumer.java

@@ -34,7 +34,7 @@ public void createGroup() {
         }
     }
 
-    @Scheduled(fixedDelay = 300000)
+    @Scheduled(fixedDelay = 10000)
     public void consume() {
         List<MapRecord<String, Object, Object>> records =
                 redisTemplate

src/main/java/com/doubleo/logservice/domain/log/dto/request/CreateAreaEnterLogRequest.java

@@ -1,4 +1,11 @@
 package com.doubleo.logservice.domain.log.dto.request;
 
+import com.doubleo.logservice.global.enums.VisitCategory;
+
 public record CreateAreaEnterLogRequest(
-        String tenantId, Long areaId, Long memberId, String memberName, Long passId) {}
+        String tenantId,
+        Long areaId,
+        Long memberId,
+        String memberName,
+        Long passId,
+        VisitCategory visitCategory) {}

src/main/java/com/doubleo/logservice/domain/log/producer/AreaEnterLogStreamProducer.java

@@ -21,6 +21,7 @@ public void sendAreaEnterLogToStream(CreateAreaEnterLogRequest request) {
         message.put("memberId", request.memberId().toString());
         message.put("memberName", request.memberName());
         message.put("passId", request.passId().toString());
+        message.put("visitCategory", request.visitCategory().name());
         message.put("timestamp", LocalDateTime.now().toString());
 
         redisTemplate.opsForStream().add("area:enter:stream", message);

src/main/java/com/doubleo/logservice/grpc/server/LogGrpcServiceImpl.java

@@ -1,6 +1,8 @@
 package com.doubleo.logservice.grpc.server;
 
 import com.doubleo.logservice.domain.log.domain.*;
+import com.doubleo.logservice.domain.log.producer.AreaEnterLogStreamProducer;
+import com.doubleo.logservice.domain.log.producer.BuildingEnterLogStreamProducer;
 import com.doubleo.logservice.domain.log.repository.BuildingEnterLogRepository;
 import com.doubleo.logservice.domain.log.repository.EnterLogRepository;
 import com.doubleo.logservice.domain.log.repository.IssuedLogAreaRepository;
@@ -18,16 +20,23 @@ public class LogGrpcServiceImpl extends LogServiceGrpc.LogServiceImplBase {
     private final IssuedLogAreaRepository issuedLogAreaRepository;
     private final EnterLogRepository enterLogRepository;
     private final BuildingEnterLogRepository buildingEnterLogRepository;
+    private final AreaEnterLogStreamProducer areaEnterLogProducer;
+    private final BuildingEnterLogStreamProducer buildingEnterLogProducer;
 
     public LogGrpcServiceImpl(
             IssuedLogRepository issuedLogRepository,
             IssuedLogAreaRepository issuedLogAreaRepository,
             EnterLogRepository enterLogRepository,
-            BuildingEnterLogRepository buildingEnterLogRepository) {
+            BuildingEnterLogRepository buildingEnterLogRepository,
+            AreaEnterLogStreamProducer areaProducer,
+            BuildingEnterLogStreamProducer buildingEnterLogProducer) {
         this.issuedLogRepository = issuedLogRepository;
         this.issuedLogAreaRepository = issuedLogAreaRepository;
         this.enterLogRepository = enterLogRepository;
         this.buildingEnterLogRepository = buildingEnterLogRepository;
+        this.areaEnterLogProducer = areaProducer;
+
+        this.buildingEnterLogProducer = buildingEnterLogProducer;
     }
 
     @Override
@@ -62,38 +71,35 @@ public void createIssuedLog(
     public void createEnterLog(
             CreateEnterLogRequest request,
             StreamObserver<CreateEnterLogResponse> responseObserver) {
-        EnterLog enterLog =
-                enterLogRepository.save(
-                        EnterLog.createEnterLog(
-                                request.getTenantId(),
-                                request.getAreaId(),
-                                request.getMemberId(),
-                                request.getMemberName(),
-                                request.getPassId(),
-                                VisitCategory.valueOf(request.getVisitCategory())));
-        responseObserver.onNext(
-                CreateEnterLogResponse.newBuilder().setEnterLogId(enterLog.getId()).build());
+        areaEnterLogProducer.sendAreaEnterLogToStream(
+                new com.doubleo.logservice.domain.log.dto.request.CreateAreaEnterLogRequest(
+                        request.getTenantId(),
+                        request.getAreaId(),
+                        request.getMemberId(),
+                        request.getMemberName(),
+                        request.getPassId(),
+                        VisitCategory.valueOf(request.getVisitCategory())));
+
+        responseObserver.onNext(CreateEnterLogResponse.newBuilder().setEnterLogId(1L).build());
         responseObserver.onCompleted();
     }
 
     @Override
     public void createBuildingEnterLog(
             CreateBuildingEnterLogRequest request,
             StreamObserver<CreateBuildingEnterLogResponse> responseObserver) {
-        BuildingEnterLog buildingEnterLog =
-                buildingEnterLogRepository.save(
-                        BuildingEnterLog.createBuildingEnterLog(
-                                request.getTenantId(),
-                                request.getBuildingId(),
-                                request.getMemberId(),
-                                request.getMemberName(),
-                                request.getPassId(),
-                                Direction.valueOf(request.getDirection()),
-                                VisitCategory.valueOf(request.getVisitCategory())));
+        buildingEnterLogProducer.sendBuildingEnterLogToStream(
+                new com.doubleo.logservice.domain.log.dto.request.CreateBuildingEnterLogRequest(
+                        request.getTenantId(),
+                        request.getBuildingId(),
+                        request.getMemberId(),
+                        request.getMemberName(),
+                        request.getPassId(),
+                        Direction.valueOf(request.getDirection()),
+                        VisitCategory.valueOf(request.getVisitCategory())));
+
         responseObserver.onNext(
-                CreateBuildingEnterLogResponse.newBuilder()
-                        .setBuildingEnterLogId(buildingEnterLog.getId())
-                        .build());
+                CreateBuildingEnterLogResponse.newBuilder().setBuildingEnterLogId(1L).build());
         responseObserver.onCompleted();
     }
 }