feat: 선박 AIS 마지막 위치 업데이트 대상 변경 #14
@ -41,42 +41,42 @@ public class ShipLastPositionSyncRepositoryImpl implements ShipLastPositionSyncR
|
||||
}
|
||||
|
||||
private String getUpdateSql() {
|
||||
// return """
|
||||
// UPDATE %s
|
||||
// SET last_cptr_hr_utc = ?::timestamptz,
|
||||
// last_port = ?,
|
||||
// now_position_lat = ?,
|
||||
// now_position_lon = ?,
|
||||
// ship_dest = ?,
|
||||
// arvl_prnmnt_hr = ?::timestamptz,
|
||||
// bow_drctn = ?,
|
||||
// cog = ?,
|
||||
// sog = ?,
|
||||
// ship_nav_status = ?,
|
||||
// cargo_ton = ?,
|
||||
// add_info = ?,
|
||||
// in_sts = ?,
|
||||
// ancrg_yn = ?
|
||||
// WHERE imo_no = ?
|
||||
// """.formatted(getTableName());
|
||||
return """
|
||||
UPDATE new_snp.core20
|
||||
SET lastseen = ?::timestamptz,
|
||||
lastport = ?,
|
||||
position_latitude = ?,
|
||||
position_longitude = ?,
|
||||
destination = ?,
|
||||
eta = ?::timestamptz,
|
||||
heading = ?,
|
||||
cog = ?,
|
||||
speedservice = ?,
|
||||
navstat = ?,
|
||||
tonnes_cargo = ?,
|
||||
extra_info = ?,
|
||||
in_sts = ?,
|
||||
on_berth = ?
|
||||
WHERE lrno = ?;
|
||||
""";
|
||||
UPDATE %s
|
||||
SET last_cptr_hr_utc = ?::timestamptz,
|
||||
last_port = ?,
|
||||
now_position_lat = ?,
|
||||
now_position_lon = ?,
|
||||
ship_dest = ?,
|
||||
arvl_prnmnt_hr = ?::timestamptz,
|
||||
bow_drctn = ?,
|
||||
cog = ?,
|
||||
sog = ?,
|
||||
ship_nav_status = ?,
|
||||
cargo_ton = ?,
|
||||
add_info = ?,
|
||||
in_sts = ?,
|
||||
ancrg_yn = ?
|
||||
WHERE imo_no = ?
|
||||
""".formatted(getTableName());
|
||||
// return """
|
||||
// UPDATE new_snp.core20
|
||||
// SET lastseen = ?::timestamptz,
|
||||
// lastport = ?,
|
||||
// position_latitude = ?,
|
||||
// position_longitude = ?,
|
||||
// destination = ?,
|
||||
// eta = ?::timestamptz,
|
||||
// heading = ?,
|
||||
// cog = ?,
|
||||
// speedservice = ?,
|
||||
// navstat = ?,
|
||||
// tonnes_cargo = ?,
|
||||
// extra_info = ?,
|
||||
// in_sts = ?,
|
||||
// on_berth = ?
|
||||
// WHERE lrno = ?;
|
||||
// """;
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
@ -142,8 +142,8 @@ app:
|
||||
|
||||
# Core20 캐시 테이블 설정 (환경별로 테이블/컬럼명이 다를 수 있음)
|
||||
core20:
|
||||
schema: t_std_snp_data # 스키마명
|
||||
table: tb_ship_info_mst # 테이블명
|
||||
schema: t_std_snp_svc # 스키마명
|
||||
table: tb_ship_main_info # 테이블명
|
||||
imo-column: imo_no # IMO/LRNO 컬럼명 (PK, NOT NULL)
|
||||
mmsi-column: mmsi_no # MMSI 컬럼명 (NULLABLE)
|
||||
|
||||
|
||||
@ -144,10 +144,10 @@ app:
|
||||
|
||||
# Core20 캐시 테이블 설정 (환경별로 테이블/컬럼명이 다를 수 있음)
|
||||
core20:
|
||||
schema: new_snp # 스키마명
|
||||
table: core20 # 테이블명
|
||||
imo-column: lrno # IMO/LRNO 컬럼명 (PK, NOT NULL)
|
||||
mmsi-column: mmsi # MMSI 컬럼명 (NULLABLE)
|
||||
schema: t_std_snp_svc # 스키마명
|
||||
table: tb_ship_main_info # 테이블명
|
||||
imo-column: imo_no # IMO/LRNO 컬럼명 (PK, NOT NULL)
|
||||
mmsi-column: mmsi_no # MMSI 컬럼명 (NULLABLE)
|
||||
|
||||
# 파티션 관리 설정
|
||||
partition:
|
||||
|
||||
@ -212,8 +212,8 @@ app:
|
||||
|
||||
# Core20 캐시 테이블 설정 (환경별로 테이블/컬럼명이 다를 수 있음)
|
||||
core20:
|
||||
schema: t_std_snp_data # 스키마명
|
||||
table: tb_ship_info_mst # 테이블명
|
||||
schema: t_std_snp_svc # 스키마명
|
||||
table: tb_ship_main_info # 테이블명
|
||||
imo-column: imo_no # IMO/LRNO 컬럼명 (PK, NOT NULL)
|
||||
mmsi-column: mmsi_no # MMSI 컬럼명 (NULLABLE)
|
||||
|
||||
|
||||
불러오는 중...
Reference in New Issue
Block a user