diff --git a/src/app/pages/basic-data/airport/airport.component.html b/src/app/pages/basic-data/airport/airport.component.html index 06b1f14..7d32320 100644 --- a/src/app/pages/basic-data/airport/airport.component.html +++ b/src/app/pages/basic-data/airport/airport.component.html @@ -1,3 +1,69 @@ -

- airport works! -

+
+
+
+
+
+ + + + +
+
+ + +
+
+ +
+
+ + +
+
+ + +
+
+
+ +
+
+ + + + + + + + + + + + + +
序号{{airline_col.COL_CN}}
{{i+1}}{{airline_row['renderFlight'][airline_col.COL_CODE]}}
+
+
+
+
\ No newline at end of file diff --git a/src/app/pages/basic-data/airport/airport.component.scss b/src/app/pages/basic-data/airport/airport.component.scss index e69de29..cf17098 100644 --- a/src/app/pages/basic-data/airport/airport.component.scss +++ b/src/app/pages/basic-data/airport/airport.component.scss @@ -0,0 +1,63 @@ +.main-page { + width: 100%; + height: calc(100% - 66px); + padding: 15px 10px; + background-color: #fff; + .page-content { + border: 1px solid #ccc; + padding: 10px 20px; + .search-filter { + padding: 0 15px; + .first-condition { + .line-operator-right { + text-align: right; + padding: 0; + .btn-info { + background-color: rgb(122, 156, 204); + border-color: rgb(122, 156, 204); + } + } + } + .input-container { + padding: 0; + > .form-control { + width: 180px; + display: inline-block; + } + } + } + .airline-table{ + .table-container{ + // border: 1px solid #ccc; + width: 100%; + height: 700px; + overflow: scroll; + table{ + width: max-content; + tr{ + cursor: pointer; + &.active{ + background: rgb(181, 215, 255); + } + } + th,td{ + // border: none; + text-align: center; + } + } + } + } + } +} + +@media screen and (max-width: 991px) { + .line-operator-right { + text-align: left !important; + } +} + +// @media screen and (min-width: 1200px){ +// .line-operator-right{ +// text-align: left; +// } +// } diff --git a/src/app/pages/basic-data/airport/airport.component.ts b/src/app/pages/basic-data/airport/airport.component.ts index 9f1f2a1..c6d1dd6 100644 --- a/src/app/pages/basic-data/airport/airport.component.ts +++ b/src/app/pages/basic-data/airport/airport.component.ts @@ -1,5 +1,7 @@ import { Component, OnInit } from '@angular/core'; - +import { ChangeDetectorRef } from '@angular/core'; +import { HttpClientService } from '../../../services/http-client.service'; +import dateFormatter from '../../../utils/data-formatter'; @Component({ selector: 'app-airport', templateUrl: './airport.component.html', @@ -7,9 +9,458 @@ import { Component, OnInit } from '@angular/core'; }) export class AirportComponent implements OnInit { - constructor() { } + constructor( + private httpCilent: HttpClientService, + private changeDetectorRef: ChangeDetectorRef +) { } - ngOnInit() { +public raw_data: Array = []; //原始数据，即航班计划 + +public combined_data: Array = []; //组合数据，即链接航班，显示信息等组合好之后的数据 + +public render_data: Array = []; //显示数据，即需要显示的数据 + +public airport_lists: Array; //列数据 + +public row_state: number; + + +public TOP_1 = 1000000000000; +public TOP_2 = 2000000000000; +public TOP_3 = 3000000000000; +public TOP_4 = 4000000000000; +public TOP_5 = 5000000000000; +public TOP_6 = 6000000000000; +public TOP_7 = 7000000000000; +public TOP_8 = 8000000000000; +public TOP_9 = 9000000000000; +public TOP_10 = 10000000000000; +public TOP_11 = 11000000000000; +public TOP_12 = 12000000000000; +public TOP_13 = 13000000000000; +public TOP_14 = 14000000000000; + +public filterItems = { + SEARCH: '', //手动输入条件 + FLT_POS: 1, //过滤还是定位 + /* ALCD: '', //航空公司 + FLIN: '', //航线类别 + FLTY: '', //航班类别 + MVIN: '', //到达/出发 + TRML: '', //航站楼 + FHAG: '', //机坪代理 + MHAG: '', //维护代理 + PHAG: '', //旅客代理 */ +} + +public formatter = { + 'MVIN': { + 'A': '到达', + 'D': '出发', + 'DF': '其他' + }, + 'FLIN': { + 'D': '国内', + 'I': '国际', + 'M': '混合', + 'R': '地区', + 'DF': '其他' + }, + 'SODT': dateFormatter, + 'ESTT': dateFormatter, + 'ACTT': dateFormatter +} + + +selectRow($event, i) { + this.row_state = i; + alert(i) +} + +getColor(col_CODE) { + if (col_CODE === 'SODT') { + return 'skyblue' + } else { + return null + } +} + +ngOnInit() { + this.changeDetectorRef.detach(); + /* 获取显示列 */ + this.httpCilent.get('/assets/mock-data/airport-code.json').subscribe( + data => { + data.sort(function (a, b) { + return (a['COL_ORDER'] - b['COL_ORDER']); + }) + this.airport_lists = data; + } + ) + /* 获取机场信息 */ + this.httpCilent.get('/assets/mock-data/airport-data.json').subscribe( + data => { + //解析数据 + data.forEach(element => { + this.raw_data.push(JSON.parse(element.value)); + }); + + let combined_linked_data = this.raw_data + + combined_linked_data.forEach(element => { + let row_flights = {}; + let render_flight = {}; + let render_pre_flight = {}; + let render_rea_flight = {}; + row_flights['preFlight'] = element; + + for (let i = 0; i < this.airport_lists.length; i++) { + let key = this.airport_lists[i]['COL_CODE'] + render_flight[key] = typeof (this.formatter[key]) === 'function' ? this.formatter[key](row_flights['preFlight'][key], 1) : this.formatter[key] ? this.formatter[key][row_flights['preFlight'][key]] : row_flights['preFlight'][key]; + } + row_flights['renderFlight'] = render_flight;if (element['isLinked']) { + row_flights['preFlight'] = element['linkFlight']; + delete element['linkFlight']; + delete element['isLinked']; + row_flights['reaFlight'] = element; + + for (let i = 0; i < this.airport_lists.length; i++) { + let key = this.airport_lists[i]['COL_CODE'] + if (this.formatter.hasOwnProperty(key)) { + if (typeof (this.formatter[key]) === 'function') { + render_flight[key] = this.formatter[key](row_flights['preFlight'][key], 1) + '/' + this.formatter[key](row_flights['reaFlight'][key], 1); + render_pre_flight[key] = this.formatter[key](row_flights['preFlight'][key], 1); + render_rea_flight[key] = this.formatter[key](row_flights['reaFlight'][key], 1); + } else { + render_flight[key] = this.formatter[key][row_flights['preFlight'][key]] + '/' + this.formatter[key][row_flights['reaFlight'][key]]; + render_pre_flight[key] = this.formatter[key][row_flights['preFlight'][key]]; + render_rea_flight[key] = this.formatter[key][row_flights['reaFlight'][key]]; + } + } else { + render_flight[key] = row_flights['preFlight'][key] + '/' + row_flights['reaFlight'][key]; + render_pre_flight[key] = row_flights['preFlight'][key]; + render_rea_flight[key] = row_flights['reaFlight'][key]; + } + } + row_flights['renderFlight'] = render_flight; + row_flights['renderPreFlight'] = render_pre_flight; + row_flights['renderReaFlight'] = render_rea_flight; + } + this.combined_data.push(row_flights) + }) + + //排序 + this.combined_data.forEach(element => { + element['ORDER'] = this.sequence(element) + // element['ORDER'] = '+' + element['order'] + }) + + this.combined_data.sort(function (a, b) { + return (a['ORDER'] - b['ORDER']); + }) + + this.render_data = this.combined_data + + this.changeDetectorRef.detectChanges(); + } + ) +} + +public sequence(flight) { + let dateTag: number = 10; + let dateToCompare = new Date().getTime(); + if (!this.isCancled(flight) && !this.isDone(flight) && this.isDelayed(flight)) { + if (this.isLinked(flight)) { + if (this.getActualDatetime(flight['preFlight']) && !this.getActualDatetime(flight['reaFlight'])) { + dateToCompare = new Date(dateFormatter(this.getActualDatetime(flight['preFlight']))).getTime(); + dateTag = this.TOP_1; + } + else { + dateToCompare = new Date(dateFormatter(this.getScheduledDatetime(flight['reaFlight']))).getTime(); + dateTag = this.TOP_2; + } + } + else { + dateToCompare = new Date(dateFormatter(this.getScheduledDatetime(flight['reaFlight']))).getTime(); + dateTag = this.TOP_3; + } + return dateToCompare + dateTag; + } + if (!this.isCancled(flight) && !this.isDone(flight) && this.isBoading(flight)) { + dateToCompare = new Date(dateFormatter(this.getScheduledDatetime(flight['reaFlight']))).getTime(); + dateTag = this.TOP_4; + return dateToCompare + dateTag; + } + if (!this.isCancled(flight) && !this.isDone(flight) && this.isFlying(flight) && !this.getActualDatetime(flight['preFlight'])) { + if (this.getEstimatedDatetime(flight['preFlight'])) { + dateToCompare = new Date(dateFormatter(this.getEstimatedDatetime(flight['preFlight']))).getTime(); + } else { + dateToCompare = new Date(dateFormatter(this.getScheduledDatetime(flight['preFlight']))).getTime(); + } + dateTag = this.TOP_5; + return dateToCompare + dateTag; + } + if (!this.isCancled(flight) && !this.isDone(flight) && this.isLinked(flight) && this.getActualDatetime(flight['preFlight']) && !this.getActualDatetime(flight['reaFlight'])) { + dateToCompare = new Date(dateFormatter(this.getActualDatetime(flight['preFlight']))).getTime(); + dateTag = this.TOP_6; + return dateToCompare + dateTag; + } + if (!this.isCancled(flight) && !this.isDone(flight) && this.isDeptFlight(flight) && !this.startBoading(flight)) { + dateToCompare = new Date(dateFormatter(this.getScheduledDatetime(flight['reaFlight']))).getTime(); + dateTag = this.TOP_7; + return dateToCompare + dateTag; + } + if (!this.isCancled(flight) && this.isArriFlight(flight) && this.isDone(flight)) { + dateToCompare = new Date(dateFormatter(this.getActualDatetime(flight['preFlight']))).getTime(); + dateTag = this.TOP_8; + return dateToCompare + dateTag; + } + if (!this.isCancled(flight) && !this.isDone(flight) && this.isOverBoading(flight)) { + dateToCompare = new Date(dateFormatter(this.getScheduledDatetime(flight['reaFlight']))).getTime(); + dateTag = this.TOP_9; + return dateToCompare + dateTag; + } + if (!this.isCancled(flight) && !this.isDone(flight) && !this.isFlying(flight)) { + if (this.isLinked(flight)) { + dateToCompare = new Date(dateFormatter(this.getScheduledDatetime(flight['reaFlight']))).getTime(); + dateTag = this.TOP_10; + } else if (this.isArriFlight(flight)) { + dateToCompare = new Date(dateFormatter(this.getScheduledDatetime(flight['preFlight']))).getTime(); + dateTag = this.TOP_11; + } + return dateToCompare + dateTag; + } + if (!this.isCancled(flight) && this.isDone(flight) && (this.isLinked(flight) || this.isDeptFlight(flight))) { + dateToCompare = new Date(dateFormatter(this.getActualDatetime(flight['reaFlight']))).getTime(); + dateTag = this.TOP_12; + return dateToCompare + dateTag; + } + if (this.isCancled(flight)) { + if (this.isDeptFlight(flight)) { + dateToCompare = new Date(dateFormatter(this.getScheduledDatetime(flight['reaFlight']))).getTime(); + } else { + dateToCompare = new Date(dateFormatter(this.getScheduledDatetime(flight['preFlight']))).getTime(); + } + + dateTag = this.TOP_13; + return dateToCompare + dateTag; + } + return this.TOP_14 +} + +/** + * 过滤机定位 + * @param filterItems + * @return + */ + +fliter(filterItems, render_data) { + if(filterItems.FLT_POS===1){ + //过滤 + }else{ + //定位 + } +} +/** + * 获取航班实际时间 + * @param flight + * @return + */ + public getActualDatetime(flight) { + return flight['ACTT']; } + /** + * 获取航班预计时间 + * @param flight + * @return + */ + public getEstimatedDatetime(flight) { + return flight['ESTT'] + } + + /** + * 获取航班计划时间 + * @param flight + * @return + */ + public getScheduledDatetime(flight) { + return flight['SODT'] + } + + + /** + * 判断航班是否是链接航班 + * @param flight + * @return + */ + public isLinked(flight) { + if (flight['preFlight'] && flight['reaFlight']) { + return true + } else { + return false + } + } + + /** + * 判断航班是否是纯离港航班 + * @param flight + * @return + */ + public isDeptFlight(flight) { + if (!flight['preFlight'] && flight['reaFlight']) { + return true + } else { + return false + } + + } + + /** + * 判断航班是否是纯到港航班 + * @param flight + * @return + */ + public isArriFlight(flight) { + if (flight['preFlight'] && !flight['reaFlight']) { + return true; + } else { + return false; + } + } + + /** + * 判断航班是否已经前站起飞 + * @param flight + * @return + */ + public isFlying(flight) { + if (this.isArriFlight(flight) || this.isLinked(flight)) { + if (flight['preFlight']['PADT']) { + return true; + } else { + return false; + } + } else { + return false; + } + } + + + /** + * 判断航班是否取消 + * @param flight + * @return + */ + public isCancled(flight) { + if (this.isArriFlight(flight)) { + if (flight['preFlight']['CNCL']) { + return true; + } else { + return false; + } + } else if (this.isDeptFlight(flight)) { + if (flight['reaFlight']['CNCL']) { + return true; + } else { + return false; + } + } else { + return false; + } + } + + /** + * 判断航班是否延误(只针对纯离港航班或链接航班中的离港航班) + * @param flight + * @return + */ + public isDelayed(flight) { + if (this.isDeptFlight(flight) || this.isLinked(flight)) { + if (flight['reaFlight']['DELY']) { + return true + } else { + return false + } + } else { + return false; + } + } + + /** + * 判断航班是否已经执行完成 + * @param flight + * @return + */ + public isDone(flight) { + if (this.isLinked(flight) || this.isDeptFlight(flight)) { + if (!this.getActualDatetime(flight['reaFlight'])) { + return false; + } else { + return true; + } + } else if (this.isArriFlight(flight)) { + if (!this.getActualDatetime(flight['preFlight'])) { + return false; + } else { + return true; + } + } else { + return false; + } + } + + /** + * 判断航班是否开始登机 + * @param flight + * @return + */ + public startBoading(flight) { + if (this.isLinked(flight) || this.isDeptFlight(flight)) { + if (!flight['reaFlight']['BOTM']) { + return false; + } else { + return true; + } + } else { + return false; + } + + } + + /** + * 判断航班是否正在登机中 + * @param flight + * @return + */ + public isBoading(flight) { + if (this.isLinked(flight) || this.isDeptFlight(flight)) { + if (flight['reaFlight']['BOTM'] && !flight['reaFlight']['GCTM']) { + return true; + } else { + return false; + } + } else { + return false; + } + } + + + /** + * 判断航班是否登机结束 + * @param flight + * @return + */ + public isOverBoading(flight) { + if (this.isLinked(flight) || this.isDeptFlight(flight)) { + if (!flight['GCTM']) { + return false; + } else { + return true; + } + } else { + return false; + } + } + + } diff --git a/src/assets/mock-data/airport-code.json b/src/assets/mock-data/airport-code.json new file mode 100644 index 0000000..970ff97 --- /dev/null +++ b/src/assets/mock-data/airport-code.json @@ -0,0 +1,52 @@ +[ + { + "COL_CODE":"FLNO", + "COL_CN":"机场代码", + "COL_ORDER":"1" + }, + { + "COL_CODE":"ALCD", + "COL_CN":"机场中文名", + "COL_ORDER":"2" + }, + { + "COL_CODE":"HZ", + "COL_CN":"中文简称", + "COL_ORDER":"3" + }, + { + "COL_CODE":"ZY", + "COL_CN":"机场英文名", + "COL_ORDER":"4" + }, + { + "COL_CODE":"YW", + "COL_CN":"英文简称", + "COL_ORDER":"5" + }, + { + "COL_CODE":"IATA", + "COL_CN":"IATA码", + "COL_ORDER":"6" + }, + { + "COL_CODE":"CAA", + "COL_CN":"CAA码", + "COL_ORDER":"7" + }, + { + "COL_CODE":"ICAO", + "COL_CN":"ICAO码", + "COL_ORDER":"8" + }, + { + "COL_CODE":"JT", + "COL_CN":"机场集团", + "COL_ORDER":"9" + }, + { + "COL_CODE":"CS", + "COL_CN":"所在城市", + "COL_ORDER":"10" + } +] \ No newline at end of file diff --git a/src/assets/mock-data/airport-data.json b/src/assets/mock-data/airport-data.json new file mode 100644 index 0000000..ee980be --- /dev/null +++ b/src/assets/mock-data/airport-data.json @@ -0,0 +1,171 @@ +[ + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1988, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083618" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + }, + { + "topic": "schd", + "value": "{\"ALCD\": \"广州\", \"FLNO\": \"HAV\", \"HZ\": \"广州\", \"ZY\": \"GZ\", \"YW\": \"GZ\", \"IATA\": \"IATA\", \"CAA\": \"CAA\",\"ICAO\": \"ICAO\",\"JT\": \"机场集团\", \"CS\": \"广州\"}", + "offset": 1989, + "partition": 0, + "highWaterOffset": 3975, + "key": "11083248" + } + +] \ No newline at end of file