From 4e1e896db9d6b27861046764507d5b2fb1cd6d6a Mon Sep 17 00:00:00 2001 From: "icksishu@gmail.com" Date: Mon, 22 Dec 2025 17:40:57 +0900 Subject: [PATCH] =?UTF-8?q?=EC=88=98=EC=8B=A0=20=EC=99=84=EB=A3=8C=20?= =?UTF-8?q?=EB=A9=94=EC=8B=9C=EC=A7=80=20=EC=88=98=EC=8B=A0=20=ED=9B=84=20?= =?UTF-8?q?=EC=88=98=EC=8B=A0=20=ED=99=95=EC=9D=B8=20=EC=B2=98=EB=A6=AC=20?= =?UTF-8?q?history=20=EC=88=98=EC=A7=91=20=EA=B8=B0=EB=8A=A5=20#5=20=20-?= =?UTF-8?q?=20/telegram=20url=20=EB=A7=8C=20=EC=83=9D=EC=84=B1=ED=95=B4=20?= =?UTF-8?q?=EB=91=94=20=EC=83=81=ED=83=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../app/communicate/ListenerController.java | 21 ++++++++++++++++++- 1 file changed, 20 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/bsmlab/dfx/dfxconsole/app/communicate/ListenerController.java b/src/main/java/com/bsmlab/dfx/dfxconsole/app/communicate/ListenerController.java index 92fceda..ae3cede 100644 --- a/src/main/java/com/bsmlab/dfx/dfxconsole/app/communicate/ListenerController.java +++ b/src/main/java/com/bsmlab/dfx/dfxconsole/app/communicate/ListenerController.java @@ -23,7 +23,7 @@ public class ListenerController { * 에이전트로부터 메시지를 수신한다. * * @param request - * @return + * @return ResponseEntity.ok().body(ackDto); */ @PostMapping(value = "/listen") public ResponseEntity listener(HttpServletRequest request) { @@ -37,6 +37,25 @@ public class ListenerController { return ResponseEntity.ok().body(ackDto); } + /** + * 에이전트로부터 메시지 처리 결과(AckDto)를 수신한다. + * TODO AckDto의 결과에 따라서 history 테이블에 있는 메시지 상태 정보를 갱신하여야 한다. + * + * @param request + * @return ResponseEntity.ok().body(ackDto); + */ + @PostMapping(value = "/telegram") + public ResponseEntity telegram(HttpServletRequest request) { + AckDto ackDto = AckDto.builder().build(); + try { + String bodyString = ServletUtils.getBodyString(request); + ackDto = AckDto.builder().build(); + } catch (IOException e) { + ackDto = AckDto.builder().result(AckDto.ResultType.RECEIVE_FAIL).resultText(e.getLocalizedMessage()).messageUuid("").build(); + } + return ResponseEntity.ok().body(ackDto); + } + /** * 에이전트로부터 상태 점검 등 command 수신한다. */