|
|
|
@ -23,7 +23,7 @@ public class ListenerController {
|
|
|
|
* 에이전트로부터 메시지를 수신한다.
|
|
|
|
* 에이전트로부터 메시지를 수신한다.
|
|
|
|
*
|
|
|
|
*
|
|
|
|
* @param request
|
|
|
|
* @param request
|
|
|
|
* @return
|
|
|
|
* @return ResponseEntity.ok().body(ackDto);
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
@PostMapping(value = "/listen")
|
|
|
|
@PostMapping(value = "/listen")
|
|
|
|
public ResponseEntity<AckDto> listener(HttpServletRequest request) {
|
|
|
|
public ResponseEntity<AckDto> listener(HttpServletRequest request) {
|
|
|
|
@ -37,6 +37,25 @@ public class ListenerController {
|
|
|
|
return ResponseEntity.ok().body(ackDto);
|
|
|
|
return ResponseEntity.ok().body(ackDto);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
|
|
* 에이전트로부터 메시지 처리 결과(AckDto)를 수신한다.
|
|
|
|
|
|
|
|
* TODO AckDto의 결과에 따라서 history 테이블에 있는 메시지 상태 정보를 갱신하여야 한다.
|
|
|
|
|
|
|
|
*
|
|
|
|
|
|
|
|
* @param request
|
|
|
|
|
|
|
|
* @return ResponseEntity.ok().body(ackDto);
|
|
|
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
@PostMapping(value = "/telegram")
|
|
|
|
|
|
|
|
public ResponseEntity<AckDto> 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 수신한다.
|
|
|
|
* 에이전트로부터 상태 점검 등 command 수신한다.
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
|