Merge pull request #36 from Capstone-QuarterBack/feature

Feature

Author: PlusUltraCode

src/main/java/com/example/quaterback/api/domain/txinfo/repository/SpringDataJpaTxInfoRepository.java

@@ -133,4 +133,7 @@ Page<TransactionInfoEntity> findByStationIdAndPeriod(
             @Param("end") LocalDateTime end,
             Pageable pageable
     );
+
+    @Query("SELECT ti.transactionId FROM TransactionInfoEntity ti ORDER BY ti.transactionId DESC")
+    Optional<String> findLatestTransactionId();
 }

src/main/java/com/example/quaterback/websocket/boot/notification/handler/BootNotificationHandler.java

@@ -1,5 +1,6 @@
 package com.example.quaterback.websocket.boot.notification.handler;
 
+import com.example.quaterback.api.domain.txinfo.repository.SpringDataJpaTxInfoRepository;
 import com.example.quaterback.common.annotation.Handler;
 import com.example.quaterback.websocket.MessageUtil;
 import com.example.quaterback.websocket.OcppMessageHandler;
@@ -16,6 +17,7 @@
 
 import java.io.IOException;
 import java.time.LocalDateTime;
+import java.util.Optional;
 
 @Handler
 @RequiredArgsConstructor
@@ -25,6 +27,7 @@ public class BootNotificationHandler implements OcppMessageHandler {
     private final BootNotificationService bootNotificationService;
     private final ObjectMapper objectMapper;
     private final RefreshTimeoutService refreshTimeoutService;
+    private final SpringDataJpaTxInfoRepository springDataJpaTxInfoRepository;
 
     @Override
     public String getAction() {
@@ -53,7 +56,11 @@ public void handle(WebSocketSession session, JsonNode jsonNode) {
             payloadNode.put("interval", 15);
             payloadNode.put("status", "Accepted");
 
-            response.add(payloadNode);
+            ObjectNode customDataNode = mapper.createObjectNode();
+            Optional<String> transactionId = springDataJpaTxInfoRepository.findLatestTransactionId();
+            customDataNode.put("transactionId", transactionId.orElse("tx-000"));
+            // payload에 customData 추가
+            payloadNode.set("customData", customDataNode);
 
             // 메시지 전송
             try {