비행 이력 관계 매핑 작업 수정

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

@@ -6,6 +6,7 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 import com.palnet.biz.api.bas.flight.model.BasFlightPlanArcrftModel;
 import com.palnet.biz.api.bas.flight.model.BasFlightPlanModel;
 import com.palnet.biz.jpa.entity.*;
+import com.palnet.biz.jpa.repository.com.ComArcrftBasRepository;
 import com.palnet.biz.jpa.repository.com.ComIdntBasRepository;
 import com.palnet.biz.jpa.repository.ctr.CtrCntrlBasRepository;
 import com.palnet.biz.jpa.repository.ctr.CtrCntrlHstryRepository;
@@ -29,10 +30,7 @@ import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.Date;
-import java.util.List;
-import java.util.Objects;
-import java.util.UUID;
+import java.util.*;
 
 @Service
 @Slf4j
@@ -42,6 +40,7 @@ public class MessageServiceImpl implements MessageService {
     private final CtrCntrlBasRepository ctrCntrlBasRepository;
     private final CtrCntrlHstryRepository ctrCntrlHstryRepository;
     private final PtyDronQueryRepository ptyDronQueryRepository;
+    private final ComArcrftBasRepository arcrftBasRepository;
     private final ComIdntBasRepository idntBasRepository;
     private final FltPlanQueryRepository fltPlanQueryRepository;
     private final FltPlanCtrCntrlRelRepository ctrCntrlRelRepository;
@@ -54,6 +53,7 @@ public class MessageServiceImpl implements MessageService {
                               CtrCntrlBasRepository ctrCntrlBasRepository,
                               CtrCntrlHstryRepository ctrCntrlHstryRepository,
                               PtyDronQueryRepository ptyDronQueryRepository,
+                              ComArcrftBasRepository arcrftBasRepository,
                               ComIdntBasRepository idntBasRepository,
                               FltPlanQueryRepository fltPlanQueryRepository,
                               FltPlanCtrCntrlRelRepository ctrCntrlRelRepository,
@@ -65,6 +65,7 @@ public class MessageServiceImpl implements MessageService {
         this.ctrCntrlBasRepository = ctrCntrlBasRepository;
         this.ctrCntrlHstryRepository = ctrCntrlHstryRepository;
         this.ptyDronQueryRepository = ptyDronQueryRepository;
+        this.arcrftBasRepository = arcrftBasRepository;
         this.idntBasRepository = idntBasRepository;
         this.fltPlanQueryRepository = fltPlanQueryRepository;
         this.ctrCntrlRelRepository = ctrCntrlRelRepository;
@@ -142,10 +143,14 @@ public class MessageServiceImpl implements MessageService {
                 // 1. 식별 번호의 소유자 정보 저장.
                 ComIdntfBas idntfBas = idntBasRepository.findById(model.getObjectId()).orElse(null);
 
-                if (idntfBas != null) {
+                // 1-1. 식별 번호의 모델 정보 조회
+                ComArcrftBas arcrftBas = arcrftBasRepository.findById(idntfBas.getArcrftSno()).orElse(null);
+
+                if (idntfBas != null && arcrftBas != null) {
                     fltPlanCtrCntrlRel.setCntrlId(ctrCntrlBas.getCntrlId());
                     fltPlanCtrCntrlRel.setIdntfNum(ctrCntrlBas.getIdntfNum());
                     fltPlanCtrCntrlRel.setIdntfCstmrSno(idntfBas.getCstmrSno());
+                    fltPlanCtrCntrlRel.setGroupId(arcrftBas.getGroupId());
                 }
 
                 // 2. 해당 되는 비행계획서 정보 저장.
@@ -155,7 +160,6 @@ public class MessageServiceImpl implements MessageService {
                 if (!planArcrft.isEmpty()) {
                     for (FltPlanBas plan : planArcrft) {
                         fltPlanCtrCntrlRel.setPlanSno(plan.getPlanSno());
-                        fltPlanCtrCntrlRel.setGroupId(plan.getGroupId());
                     }
                 }