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 수신한다. */