Browse Source

[관제] 비정상 로직 수정

feature/auth
노승철 2 years ago
parent
commit
bb65258c75
  1. 8
      src/main/java/com/palnet/biz/api/ctr/cntrl/controller/CtrCntrlController.java
  2. 16
      src/main/java/com/palnet/biz/api/ctr/cntrl/service/CtrCntrlService.java
  3. 4
      src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java
  4. 24
      src/main/java/com/palnet/biz/message/service/impl/MessageServiceImpl.java
  5. 4
      src/main/resources/application.yml

8
src/main/java/com/palnet/biz/api/ctr/cntrl/controller/CtrCntrlController.java

@ -199,11 +199,13 @@ public class CtrCntrlController {
return ResponseEntity.ok().body(new SuccessResponse(rs)); return ResponseEntity.ok().body(new SuccessResponse(rs));
} }
@GetMapping("/id/{id}") @GetMapping("/id/{id}/{lat}/{lon}")
public ResponseEntity<? extends BasicResponse> getId(@PathVariable String id) { public ResponseEntity<? extends BasicResponse> getId(@PathVariable String id,
@PathVariable Double lat,
@PathVariable Double lon) {
Map<String, String> result; Map<String, String> result;
try { try {
result = service.getId(id); result = service.getId(id, lat, lon);
} catch (Exception e) { } catch (Exception e) {
log.error("IGNORE : {}", e); log.error("IGNORE : {}", e);
return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR) return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR)

16
src/main/java/com/palnet/biz/api/ctr/cntrl/service/CtrCntrlService.java

@ -380,7 +380,7 @@ public class CtrCntrlService {
} }
public Map<String, String> getId(String id) { public Map<String, String> getId(String id, Double lat, Double lon) {
Map<String, String> result = new HashMap<>(); Map<String, String> result = new HashMap<>();
/* 식별번호의 가장 최근 이력 불러오기 */ /* 식별번호의 가장 최근 이력 불러오기 */
@ -418,6 +418,20 @@ public class CtrCntrlService {
// 기체 식별번호의 관제 ID 저장 (single ton) // 기체 식별번호의 관제 ID 저장 (single ton)
shareContext.putIdntfKey(id, controlID); shareContext.putIdntfKey(id, controlID);
} }
List<BasFlightPlanModel> planList = this.getFlightPlan(id);
if(planList != null && !planList.isEmpty()) {
CtrCntrlPlanContainsRq containsRq = new CtrCntrlPlanContainsRq();
containsRq.setIdntfNum(id);
containsRq.setLat(lat);
containsRq.setLon(lon);
containsRq.setPlanList(planList);
CtrCntrlPlanContainsRs ctrCntrlPlanContainsRs = this.checkPlanContains(containsRq);
result.put("controlWarnCd", ctrCntrlPlanContainsRs.isWarning() ? "Y" : "N");
}
return result; return result;
} }
} }

4
src/main/java/com/palnet/biz/message/consumer/MessageConsumer.java

@ -36,9 +36,9 @@ public class MessageConsumer {
e.printStackTrace(); e.printStackTrace();
} }
GPModel mapper = messageService.mapper(model); // GPModel mapper = messageService.mapper(model);
messageService.insert(mapper); // GPS 정보 DB 동기화 처리 messageService.insert(model); // GPS 정보 DB 동기화 처리
/* Websocket Model 메세지 서버로 위임 */ /* Websocket Model 메세지 서버로 위임 */
// messageService.sendToMessage(mapper); // messageService.sendToMessage(mapper);

24
src/main/java/com/palnet/biz/message/service/impl/MessageServiceImpl.java

@ -130,18 +130,18 @@ public class MessageServiceImpl implements MessageService {
// } // }
// 비행구역 Contains Check // 비행구역 Contains Check
List<BasFlightPlanModel> planList = ctrCntrlService.getFlightPlan(model.getObjectId()); // List<BasFlightPlanModel> planList = ctrCntrlService.getFlightPlan(model.getObjectId());
//
if(planList != null && !planList.isEmpty()) { // if(planList != null && !planList.isEmpty()) {
CtrCntrlPlanContainsRq containsRq = new CtrCntrlPlanContainsRq(); // CtrCntrlPlanContainsRq containsRq = new CtrCntrlPlanContainsRq();
containsRq.setIdntfNum(model.getObjectId()); // containsRq.setIdntfNum(model.getObjectId());
containsRq.setLat(model.getLat()); // containsRq.setLat(model.getLat());
containsRq.setLon(model.getLng()); // containsRq.setLon(model.getLng());
containsRq.setPlanList(planList); // containsRq.setPlanList(planList);
//
CtrCntrlPlanContainsRs ctrCntrlPlanContainsRs = ctrCntrlService.checkPlanContains(containsRq); // CtrCntrlPlanContainsRs ctrCntrlPlanContainsRs = ctrCntrlService.checkPlanContains(containsRq);
model.setControlWarnCd(ctrCntrlPlanContainsRs.isWarning()); // model.setControlWarnCd(ctrCntrlPlanContainsRs.isWarning());
} // }
return model; return model;
} }

4
src/main/resources/application.yml

@ -47,8 +47,8 @@ spring:
hibernate: hibernate:
# use_sql_comments: true # use_sql_comments: true
# use_sql_comments: false # use_sql_comments: false
show_sql: true # show_sql: true
format_sql: true # format_sql: true
rabbitmq: rabbitmq:
host: 192.168.0.24 host: 192.168.0.24
port: 5672 port: 5672

Loading…
Cancel
Save