diff --git a/src/main/java/kr/gmtc/gw/elastic/parser/ElasticMessageParser.java b/src/main/java/kr/gmtc/gw/elastic/parser/ElasticMessageParser.java new file mode 100644 index 0000000..5962899 --- /dev/null +++ b/src/main/java/kr/gmtc/gw/elastic/parser/ElasticMessageParser.java @@ -0,0 +1,5 @@ +package kr.gmtc.gw.elastic.parser; + +public class ElasticMessageParser { + +} diff --git a/src/main/java/kr/gmtc/gw/elastic/parser/logingIndex/ParserAade.java b/src/main/java/kr/gmtc/gw/elastic/parser/logingIndex/ParserAade.java index 75af437..09d6313 100644 --- a/src/main/java/kr/gmtc/gw/elastic/parser/logingIndex/ParserAade.java +++ b/src/main/java/kr/gmtc/gw/elastic/parser/logingIndex/ParserAade.java @@ -10,8 +10,8 @@ import kr.gmtc.gw.elastic.vo.ElasticMsgHeader; import kr.gmtc.gw.elastic.vo.ElasticResultMsgVO; import kr.gmtc.gw.elastic.vo.LogMsgParserVO; import kr.gmtc.gw.elastic.vo.ReplayLog.AsdeVO; -import kr.gmtc.gw.elastic.vo.ReplayLog.StandRouteVO; -import kr.gmtc.gw.elastic.vo.ReplayLog.StandRouteVO.RoutePoints; +import kr.gmtc.gw.elastic.vo.ReplayLog.StandardRouteVO; +import kr.gmtc.gw.elastic.vo.ReplayLog.StandardRouteVO.RoutePoints; public class ParserAade { @@ -58,8 +58,16 @@ public class ParserAade { logVO.setHeader(logHeader); /*** 메시지 Header 변환 END ***/ - /*** 메시지 data(body) 변환 START ***/ - String sDatas = split_Div[1]; + String sDatas = null; + + try { + /*** 메시지 data(body) 변환 START ***/ + sDatas = split_Div[1]; + } catch (Exception e) { + // continue; + } + + if( sDatas == null ) continue; String[] split_Data = null; diff --git a/src/main/java/kr/gmtc/gw/elastic/parser/logingIndex/ParserRadar.java b/src/main/java/kr/gmtc/gw/elastic/parser/logingIndex/ParserRadar.java new file mode 100644 index 0000000..794765b --- /dev/null +++ b/src/main/java/kr/gmtc/gw/elastic/parser/logingIndex/ParserRadar.java @@ -0,0 +1,121 @@ +package kr.gmtc.gw.elastic.parser.logingIndex; + +import java.util.ArrayList; +import java.util.List; +import java.util.Queue; +import java.util.concurrent.LinkedBlockingQueue; + +import kr.gmtc.gw.elastic.utils.LogMsgParserUtile; +import kr.gmtc.gw.elastic.vo.ElasticMsgHeader; +import kr.gmtc.gw.elastic.vo.ElasticResultMsgVO; +import kr.gmtc.gw.elastic.vo.LogMsgParserVO; +import kr.gmtc.gw.elastic.vo.ReplayLog.RadarVO; +import kr.gmtc.gw.elastic.vo.ReplayLog.StandardRouteVO; +import kr.gmtc.gw.elastic.vo.ReplayLog.StandardRouteVO.RoutePoints; + +public class ParserRadar { + + private List logMsgs; + + Queue parserAiLocQ = new LinkedBlockingQueue(); + + LogMsgParserUtile pUtile; + + public ParserRadar(){ + + pUtile = new LogMsgParserUtile(); + + } + + public void logParser(List recvMsgs){ + + this.logMsgs = recvMsgs; + + List parserList = new ArrayList(); + RadarVO parserVO; + + LogMsgParserVO logVO; + ElasticMsgHeader logHeader; + + for( ElasticResultMsgVO mv : logMsgs){ + + String sMsg = mv.getMessage(); + + logVO = new LogMsgParserVO(); + + /*** 메시지 Pipe(|) 구분 ***/ + String[] split_Div = pUtile.splitString(sMsg, pUtile.DIV_PIPE); + + /*** 메시지 Header 변환 START ***/ + String[] split_Header = pUtile.splitString(split_Div[0], pUtile.DIV_COMMA); + + logHeader = new ElasticMsgHeader(); + logHeader.setLog_dt(split_Header[0]); + logHeader.setLog_se(split_Header[1]); + logHeader.setSw_se(split_Header[2]); + logHeader.setServer_se(split_Header[3]); + + logVO.setHeader(logHeader); + /*** 메시지 Header 변환 END ***/ + + String sDatas = null; + + try { + /*** 메시지 data(body) 변환 START ***/ + sDatas = split_Div[1]; + } catch (Exception e) { + // continue; + } + + if( sDatas == null ) continue; + + String[] split_Data = null; + + //Data부 여러줄 인지 확인(^) + int iDivCnt_Datas = pUtile.countDivInMsg(sDatas, pUtile.DIV_CARET); + + // Data부 여러줄인경우 분리(^) + if(iDivCnt_Datas > 0){ + split_Data = pUtile.splitString(sDatas, pUtile.DIV_CARET); + }else{ + split_Data = new String[1]; + split_Data[0] = sDatas; + } + + /**** Data부 한줄씩 처리 START ****/ + for(String loop1Data : split_Data){ + + parserVO = new RadarVO(); + + // 일반 필드 분리(,) + String[] split_Field = pUtile.splitString(loop1Data, pUtile.DIV_COMMA); + + parserVO.setTrgt_id(split_Field[0]); + parserVO.setRecptn_dt(split_Field[1]); + parserVO.setLat(split_Field[2]); + parserVO.setLon(split_Field[3]); + parserVO.setSpd(split_Field[4]); + parserVO.setCos(split_Field[5]); + parserVO.setDetct_cnt(split_Field[6]); + parserVO.setUndetct_cnt(split_Field[7]); + + parserList.add(parserVO); + } + /**** Data부 한줄씩 처리 END ****/ + + logVO.setData(parserList); + /*** 메시지 data(body) 변환 END ***/ + + // Que에 파싱 데이터 담기 + parserAiLocQ.offer(logVO) ; + + } // for( ElasticResultMsgVO mv : logMsgs){... END + + + + } + + + + +} diff --git a/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserAILocation.java b/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserAILocation.java index e859586..704c609 100644 --- a/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserAILocation.java +++ b/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserAILocation.java @@ -10,8 +10,6 @@ import kr.gmtc.gw.elastic.vo.ElasticMsgHeader; import kr.gmtc.gw.elastic.vo.ElasticResultMsgVO; import kr.gmtc.gw.elastic.vo.LogMsgParserVO; import kr.gmtc.gw.elastic.vo.ReplayLog.AiLocationVO; -import kr.gmtc.gw.elastic.vo.ReplayLog.StandRouteVO; -import kr.gmtc.gw.elastic.vo.ReplayLog.StandRouteVO.RoutePoints; public class ParserAILocation { diff --git a/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserAna.java b/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserAna.java new file mode 100644 index 0000000..9c1822b --- /dev/null +++ b/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserAna.java @@ -0,0 +1,146 @@ +package kr.gmtc.gw.elastic.parser.replayLog; + +import java.util.ArrayList; +import java.util.List; +import java.util.Queue; +import java.util.concurrent.LinkedBlockingQueue; + +import kr.gmtc.gw.elastic.utils.LogMsgParserUtile; +import kr.gmtc.gw.elastic.vo.ElasticMsgHeader; +import kr.gmtc.gw.elastic.vo.ElasticResultMsgVO; +import kr.gmtc.gw.elastic.vo.LogMsgParserVO; +import kr.gmtc.gw.elastic.vo.ReplayLog.AnaVO; +import kr.gmtc.gw.elastic.vo.ReplayLog.AnaVO.Area; +import kr.gmtc.gw.elastic.vo.ReplayLog.AnaVO.Target; + +public class ParserAna { + + private List logMsgs; + + Queue parserAiLocQ = new LinkedBlockingQueue(); + + LogMsgParserUtile pUtile; + + public ParserAna(){ + + pUtile = new LogMsgParserUtile(); + + } + + public void logParser(List recvMsgs){ + + this.logMsgs = recvMsgs; + + List parserList = new ArrayList(); + + AnaVO parserVO; + Area area; + Target trgt; + + LogMsgParserVO logVO; + ElasticMsgHeader logHeader; + + for( ElasticResultMsgVO mv : logMsgs){ + + String sMsg = mv.getMessage(); + + logVO = new LogMsgParserVO(); + + /*** 메시지 Pipe(|) 구분 ***/ + String[] split_Div = pUtile.splitString(sMsg, pUtile.DIV_PIPE); + + /*** 메시지 Header 변환 START ***/ + String[] split_Header = pUtile.splitString(split_Div[0], pUtile.DIV_COMMA); + + logHeader = new ElasticMsgHeader(); + logHeader.setLog_dt(split_Header[0]); + logHeader.setLog_se(split_Header[1]); + logHeader.setSw_se(split_Header[2]); + logHeader.setServer_se(split_Header[3]); + + logVO.setHeader(logHeader); + /*** 메시지 Header 변환 END ***/ + + /*** 메시지 data(body) 변환 START ***/ + String sDatas = split_Div[1]; + + String[] split_Data = null; + + //Data부 여러줄 인지 확인(^) + int iDivCnt_Datas = pUtile.countDivInMsg(sDatas, pUtile.DIV_CARET); + + // Data부 여러줄인경우 분리(^) + if(iDivCnt_Datas > 0){ + split_Data = pUtile.splitString(sDatas, pUtile.DIV_CARET); + }else{ + split_Data = new String[1]; + split_Data[0] = sDatas; + } + + /**** Data부 한줄씩 처리 START ****/ + for(String loop1Data : split_Data){ + + parserVO = new AnaVO(); + + area = new Area(); + + + // 일반 필드 분리(,) + String[] split_Field = pUtile.splitString(loop1Data, pUtile.DIV_COMMA); + + parserVO.setAnals_id(split_Field[0]); + parserVO.setAnals_dt(split_Field[1]); + parserVO.setAnals_ty(split_Field[2]); + // parserVO.setArea(pUtile.splitString(split_Field[3], pUtile.DIV_AT)); + // parserVO.setTarget1(pUtile.splitString(split_Field[4], pUtile.DIV_AT)); + // parserVO.setTarget2(pUtile.splitString(split_Field[5], pUtile.DIV_AT)); + + String[] split_Array = null; + + split_Array = pUtile.splitString(split_Field[3], pUtile.DIV_AT); + + area.setArea_id(split_Array[0]); + area.setArea_type(split_Array[1]); + + parserVO.setArea(area); + + trgt = new Target(); + split_Array = pUtile.splitString(split_Field[3], pUtile.DIV_AT); + + trgt.setTrgt_id(split_Array[0]); + trgt.setTrgt_ty(split_Array[1]); + + parserVO.setTarget1(trgt); + + trgt = new Target(); + split_Array = pUtile.splitString(split_Field[3], pUtile.DIV_AT); + + area.setArea_id(split_Array[0]); + area.setArea_type(split_Array[1]); + + parserVO.setTarget2(trgt); + + parserVO.setAnals_msg(split_Field[6]); + parserVO.setAnalsMsg(split_Field[7]); + parserVO.setRls_ty(split_Field[8]); + + parserList.add(parserVO); + } + /**** Data부 한줄씩 처리 END ****/ + + logVO.setData(parserList); + /*** 메시지 data(body) 변환 END ***/ + + // Que에 파싱 데이터 담기 + parserAiLocQ.offer(logVO) ; + + } // for( ElasticResultMsgVO mv : logMsgs){... END + + + + } + + + + +} diff --git a/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserFusion.java b/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserFusion.java new file mode 100644 index 0000000..45ee5ae --- /dev/null +++ b/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserFusion.java @@ -0,0 +1,145 @@ +package kr.gmtc.gw.elastic.parser.replayLog; + +import java.util.ArrayList; +import java.util.List; +import java.util.Queue; +import java.util.concurrent.LinkedBlockingQueue; + +import kr.gmtc.gw.elastic.utils.LogMsgParserUtile; +import kr.gmtc.gw.elastic.vo.ElasticMsgHeader; +import kr.gmtc.gw.elastic.vo.ElasticResultMsgVO; +import kr.gmtc.gw.elastic.vo.LogMsgParserVO; +import kr.gmtc.gw.elastic.vo.ReplayLog.FusionVO; +import kr.gmtc.gw.elastic.vo.ReplayLog.FusionVO.BoundingBox; + + +public class ParserFusion { + + private List logMsgs; + + Queue parserAiLocQ = new LinkedBlockingQueue(); + + LogMsgParserUtile pUtile; + + public ParserFusion(){ + + pUtile = new LogMsgParserUtile(); + + } + + public void logParser(List recvMsgs){ + + this.logMsgs = recvMsgs; + + List parserList = new ArrayList(); + + FusionVO parserVO; + BoundingBox bBox; + + LogMsgParserVO logVO; + ElasticMsgHeader logHeader; + + for( ElasticResultMsgVO mv : logMsgs){ + + String sMsg = mv.getMessage(); + + logVO = new LogMsgParserVO(); + + /*** 메시지 Pipe(|) 구분 ***/ + String[] split_Div = pUtile.splitString(sMsg, pUtile.DIV_PIPE); + + /*** 메시지 Header 변환 START ***/ + String[] split_Header = pUtile.splitString(split_Div[0], pUtile.DIV_COMMA); + + logHeader = new ElasticMsgHeader(); + logHeader.setLog_dt(split_Header[0]); + logHeader.setLog_se(split_Header[1]); + logHeader.setSw_se(split_Header[2]); + logHeader.setServer_se(split_Header[3]); + + logVO.setHeader(logHeader); + /*** 메시지 Header 변환 END ***/ + + /*** 메시지 data(body) 변환 START ***/ + String sDatas = split_Div[1]; + + String[] split_Data = null; + + //Data부 여러줄 인지 확인(^) + int iDivCnt_Datas = pUtile.countDivInMsg(sDatas, pUtile.DIV_CARET); + + // Data부 여러줄인경우 분리(^) + if(iDivCnt_Datas > 0){ + split_Data = pUtile.splitString(sDatas, pUtile.DIV_CARET); + }else{ + split_Data = new String[1]; + split_Data[0] = sDatas; + } + + /**** Data부 한줄씩 처리 START ****/ + for(String loop1Data : split_Data){ + + parserVO = new FusionVO(); + + // 일반 필드 분리(,) + String[] split_Field = pUtile.splitString(loop1Data, pUtile.DIV_COMMA); + + parserVO.setTrgt_id(split_Field[0]); + parserVO.setRecptn_dt(split_Field[1]); + parserVO.setLat(split_Field[2]); + parserVO.setLon(split_Field[3]); + parserVO.setSpd(split_Field[4]); + parserVO.setCos(split_Field[5]); + parserVO.setAlt(split_Field[6]); + parserVO.setTrgt_ty(split_Field[7]); + parserVO.setSchdul_id(split_Field[8]); + parserVO.setMode_s_cd(split_Field[9]); + parserVO.setSsr_cd(split_Field[10]); + parserVO.setClsgn(split_Field[11]); + parserVO.setTail_no(split_Field[12]); + parserVO.setCrrct_lat(split_Field[13]); + parserVO.setCrrct_lon(split_Field[14]); + parserVO.setIs_cntrlzone(split_Field[15]); + + parserVO.setBbox(new ArrayList()); + + // bbox 담기 + String[] split_List = pUtile.splitString(split_Field[17], pUtile.DIV_DOLLAR); + + for(String loopList : split_List){ + + bBox = new BoundingBox(); + + String[] split_Array = pUtile.splitString(loopList, pUtile.DIV_AT); + + bBox.setLt_x(split_Array[0]); + bBox.setLt_y(split_Array[1]); + bBox.setRb_x(split_Array[2]); + bBox.setRb_y(split_Array[3]); + bBox.setPx(split_Array[4]); + bBox.setPy(split_Array[5]); + + parserVO.getBbox().add(bBox); + + } + + parserList.add(parserVO); + } + /**** Data부 한줄씩 처리 END ****/ + + logVO.setData(parserList); + /*** 메시지 data(body) 변환 END ***/ + + // Que에 파싱 데이터 담기 + parserAiLocQ.offer(logVO) ; + + } // for( ElasticResultMsgVO mv : logMsgs){... END + + + + } + + + + +} diff --git a/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserRoute.java b/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserRoute.java index ea7ed6e..e092f59 100644 --- a/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserRoute.java +++ b/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserRoute.java @@ -9,8 +9,8 @@ import kr.gmtc.gw.elastic.utils.LogMsgParserUtile; import kr.gmtc.gw.elastic.vo.ElasticMsgHeader; import kr.gmtc.gw.elastic.vo.ElasticResultMsgVO; import kr.gmtc.gw.elastic.vo.LogMsgParserVO; -import kr.gmtc.gw.elastic.vo.ReplayLog.StandRouteVO; -import kr.gmtc.gw.elastic.vo.ReplayLog.StandRouteVO.RoutePoints; +import kr.gmtc.gw.elastic.vo.ReplayLog.StandardRouteVO; +import kr.gmtc.gw.elastic.vo.ReplayLog.StandardRouteVO.RoutePoints; public class ParserRoute { @@ -30,10 +30,10 @@ public class ParserRoute { this.logMsgs = recvMsgs; - StandRouteVO routeVO; + StandardRouteVO routeVO; RoutePoints routePoints; - List routeList = new ArrayList(); + List routeList = new ArrayList(); LogMsgParserVO logVO; ElasticMsgHeader logHeader; @@ -77,7 +77,7 @@ public class ParserRoute { /**** Data부 한줄씩 처리 START ****/ for(String loop1Data : split_Data){ - routeVO = new StandRouteVO(); + routeVO = new StandardRouteVO(); // 일반 필드 분리(,) String[] split_Field = pUtile.splitString(loop1Data, pUtile.DIV_COMMA); diff --git a/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserStandStatus.java b/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserStandStatus.java new file mode 100644 index 0000000..f8b75f2 --- /dev/null +++ b/src/main/java/kr/gmtc/gw/elastic/parser/replayLog/ParserStandStatus.java @@ -0,0 +1,126 @@ +package kr.gmtc.gw.elastic.parser.replayLog; + +import java.util.ArrayList; +import java.util.List; +import java.util.Queue; +import java.util.concurrent.LinkedBlockingQueue; + +import kr.gmtc.gw.elastic.utils.LogMsgParserUtile; +import kr.gmtc.gw.elastic.vo.ElasticMsgHeader; +import kr.gmtc.gw.elastic.vo.ElasticResultMsgVO; +import kr.gmtc.gw.elastic.vo.LogMsgParserVO; +import kr.gmtc.gw.elastic.vo.ReplayLog.StandStatusVO; +import kr.gmtc.gw.elastic.vo.ReplayLog.StandStatusVO.StandSttusTy; +import kr.gmtc.gw.elastic.vo.ReplayLog.StandardRouteVO.RoutePoints; + +public class ParserStandStatus { + + private List logMsgs; + + Queue parserAiLocQ = new LinkedBlockingQueue(); + + LogMsgParserUtile pUtile; + + public ParserStandStatus(){ + + pUtile = new LogMsgParserUtile(); + + } + + public void logParser(List recvMsgs){ + + this.logMsgs = recvMsgs; + + List parserList = new ArrayList(); + + StandStatusVO parserVO; + StandSttusTy aistandsts; + + LogMsgParserVO logVO; + ElasticMsgHeader logHeader; + + for( ElasticResultMsgVO mv : logMsgs){ + + String sMsg = mv.getMessage(); + + logVO = new LogMsgParserVO(); + + /*** 메시지 Pipe(|) 구분 ***/ + String[] split_Div = pUtile.splitString(sMsg, pUtile.DIV_PIPE); + + /*** 메시지 Header 변환 START ***/ + String[] split_Header = pUtile.splitString(split_Div[0], pUtile.DIV_COMMA); + + logHeader = new ElasticMsgHeader(); + logHeader.setLog_dt(split_Header[0]); + logHeader.setLog_se(split_Header[1]); + logHeader.setSw_se(split_Header[2]); + logHeader.setServer_se(split_Header[3]); + + logVO.setHeader(logHeader); + /*** 메시지 Header 변환 END ***/ + + /*** 메시지 data(body) 변환 START ***/ + String sDatas = split_Div[1]; + + String[] split_Data = null; + + //Data부 여러줄 인지 확인(^) + int iDivCnt_Datas = pUtile.countDivInMsg(sDatas, pUtile.DIV_CARET); + + // Data부 여러줄인경우 분리(^) + if(iDivCnt_Datas > 0){ + split_Data = pUtile.splitString(sDatas, pUtile.DIV_CARET); + }else{ + split_Data = new String[1]; + split_Data[0] = sDatas; + } + + /**** Data부 한줄씩 처리 START ****/ + for(String loop1Data : split_Data){ + + parserVO = new StandStatusVO(); + + // 일반 필드 분리(,) + String[] split_Field = pUtile.splitString(loop1Data, pUtile.DIV_COMMA); + + parserVO.setStand_no(split_Field[0]); + //parserVO.setStand_sttus_ty(pUtile.splitString(split_Field[1], pUtile.DIV_AT)); + + aistandsts = new StandSttusTy(); + + String[] split_Array = pUtile.splitString(split_Field[1], pUtile.DIV_AT); + + aistandsts.setArcft_stand(split_Array[0]); + aistandsts.setBrdg_cnnctd(split_Array[1]); + aistandsts.setCrg_dr_opnd(split_Array[2]); + aistandsts.setPad_clear(split_Array[3]); + aistandsts.setTwng_cr_cnnctd(split_Array[4]); + + parserVO.setStand_sttus_ty(aistandsts); + + parserVO.setAircraft_sttus_ty(split_Field[2]); + parserVO.setClsgn(split_Field[3]); + parserVO.setSchdul_id(split_Field[4]); + parserVO.setAc_reg_no(split_Field[5]); + + parserList.add(parserVO); + } + /**** Data부 한줄씩 처리 END ****/ + + logVO.setData(parserList); + /*** 메시지 data(body) 변환 END ***/ + + // Que에 파싱 데이터 담기 + parserAiLocQ.offer(logVO) ; + + } // for( ElasticResultMsgVO mv : logMsgs){... END + + + + } + + + + +} diff --git a/src/main/java/kr/gmtc/gw/elastic/services/ElkSearchService.java b/src/main/java/kr/gmtc/gw/elastic/services/ElkSearchService.java index 32ab271..4569cdf 100644 --- a/src/main/java/kr/gmtc/gw/elastic/services/ElkSearchService.java +++ b/src/main/java/kr/gmtc/gw/elastic/services/ElkSearchService.java @@ -18,6 +18,8 @@ import org.springframework.stereotype.Service; import kr.gmtc.gw.elastic.parser.logingIndex.ParserAade; import kr.gmtc.gw.elastic.parser.replayLog.ParserAILocation; +import kr.gmtc.gw.elastic.parser.replayLog.ParserAna; +import kr.gmtc.gw.elastic.parser.replayLog.ParserFusion; import kr.gmtc.gw.elastic.parser.replayLog.ParserRoute; import kr.gmtc.gw.elastic.vo.ElasticResultMsgVO; @@ -32,14 +34,14 @@ public class ElkSearchService { private List logMsgMatches; - private ParserAade logParser; + private ParserFusion logParser; public ElkSearchService(ElasticsearchOperations elasticsearchOperations){ this.elasticsearchOperations = elasticsearchOperations; logMsgMatches = new ArrayList(); //logParser = new ReplayLogParser_Route(); - logParser = new ParserAade(); + logParser = new ParserFusion(); } public String elkSearch_replay_log(String sLogType, String sStartDt, String sEndDt) { diff --git a/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/AnaVO.java b/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/AnaVO.java new file mode 100644 index 0000000..3c284e5 --- /dev/null +++ b/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/AnaVO.java @@ -0,0 +1,33 @@ +package kr.gmtc.gw.elastic.vo.ReplayLog; + +import lombok.Getter; +import lombok.Setter; + +@Setter +@Getter +public class AnaVO { + + private String anals_id; + private String anals_dt; + private String anals_ty; + private Area area; + private Target target1; + private Target target2; + private String anals_msg; + private String analsMsg; + private String rls_ty; + + @Setter + @Getter + public static class Area { + private String area_type; + private String area_id; + } + + @Setter + @Getter + public static class Target { + private String trgt_ty; + private String trgt_id; + } +} diff --git a/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/AsdeVO.java b/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/AsdeVO.java index 47d43da..23b74eb 100644 --- a/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/AsdeVO.java +++ b/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/AsdeVO.java @@ -1,5 +1,10 @@ package kr.gmtc.gw.elastic.vo.ReplayLog; +import lombok.Getter; +import lombok.Setter; + +@Getter +@Setter public class AsdeVO { private String trgt_id; @@ -16,89 +21,4 @@ public class AsdeVO { private String cos; private String trgt_ty; - - public String getTrgt_id() { - return trgt_id; - } - public void setTrgt_id(String trgt_id) { - this.trgt_id = trgt_id; - } - public String getMode_s_cd() { - return mode_s_cd; - } - public void setMode_s_cd(String mode_s_cd) { - this.mode_s_cd = mode_s_cd; - } - public String getSsr_cd() { - return ssr_cd; - } - public void setSsr_cd(String ssr_cd) { - this.ssr_cd = ssr_cd; - } - public String getClsgn() { - return clsgn; - } - public void setClsgn(String clsgn) { - this.clsgn = clsgn; - } - public String getTail_no() { - return tail_no; - } - public void setTail_no(String tail_no) { - this.tail_no = tail_no; - } - public String getTrack_no() { - return track_no; - } - public void setTrack_no(String track_no) { - this.track_no = track_no; - } - public String getRecptn_dt() { - return recptn_dt; - } - public void setRecptn_dt(String recptn_dt) { - this.recptn_dt = recptn_dt; - } - public String getCat_ty() { - return cat_ty; - } - public void setCat_ty(String cat_ty) { - this.cat_ty = cat_ty; - } - public String getLat() { - return lat; - } - public void setLat(String lat) { - this.lat = lat; - } - public String getLon() { - return lon; - } - public void setLon(String lon) { - this.lon = lon; - } - public String getSpd() { - return spd; - } - public void setSpd(String spd) { - this.spd = spd; - } - public String getCos() { - return cos; - } - public void setCos(String cos) { - this.cos = cos; - } - public String getTrgt_ty() { - return trgt_ty; - } - public void setTrgt_ty(String trgt_ty) { - this.trgt_ty = trgt_ty; - } - - - - - - } diff --git a/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/FusionVO.java b/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/FusionVO.java new file mode 100644 index 0000000..f977509 --- /dev/null +++ b/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/FusionVO.java @@ -0,0 +1,44 @@ +package kr.gmtc.gw.elastic.vo.ReplayLog; + +import java.util.List; + +import lombok.Getter; +import lombok.Setter; + +@Getter +@Setter + +public class FusionVO { + + private String trgt_id; + private String recptn_dt; + private String lat; + private String lon; + private String spd; + private String cos; + private String alt; + private String trgt_ty; + private String schdul_id; + private String mode_s_cd; + private String ssr_cd; + private String clsgn; + private String tail_no; + private String crrct_lat; + private String crrct_lon; + private String is_cntrlzone; + + private List bbox; + + @Setter + @Getter + public static class BoundingBox{ + private String cctv_id; + private String lt_x; + private String lt_y; + private String rb_x; + private String rb_y; + private String px; + private String py; + } + +} diff --git a/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/RadarVO.java b/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/RadarVO.java new file mode 100644 index 0000000..33c8ec0 --- /dev/null +++ b/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/RadarVO.java @@ -0,0 +1,19 @@ +package kr.gmtc.gw.elastic.vo.ReplayLog; + +import lombok.Getter; +import lombok.Setter; + +@Getter +@Setter +public class RadarVO { + + private String trgt_id; + private String recptn_dt; + private String lat; + private String lon; + private String spd; + private String cos; + private String detct_cnt; + private String undetct_cnt; + +} diff --git a/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/StandStatusVO.java b/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/StandStatusVO.java new file mode 100644 index 0000000..83c1797 --- /dev/null +++ b/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/StandStatusVO.java @@ -0,0 +1,29 @@ +package kr.gmtc.gw.elastic.vo.ReplayLog; + +import lombok.Getter; +import lombok.Setter; + +@Getter +@Setter +public class StandStatusVO { + + private String stand_no; + private StandSttusTy stand_sttus_ty; + private String aircraft_sttus_ty; + private String clsgn; + private String schdul_id; + private String ac_reg_no; + + @Getter + @Setter + public static class StandSttusTy{ + + private String arcft_stand; + private String brdg_cnnctd; + private String crg_dr_opnd; + private String pad_clear; + private String twng_cr_cnnctd; + + } + +} diff --git a/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/StandRouteVO.java b/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/StandardRouteVO.java similarity index 93% rename from src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/StandRouteVO.java rename to src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/StandardRouteVO.java index efdf0bd..662c205 100644 --- a/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/StandRouteVO.java +++ b/src/main/java/kr/gmtc/gw/elastic/vo/ReplayLog/StandardRouteVO.java @@ -7,7 +7,7 @@ import lombok.Setter; @Setter @Getter -public class StandRouteVO { +public class StandardRouteVO { private String mv_id; private String trgt_id;