From 7ffb8b70aeb362b59471e8356d4bd444cbedda4b Mon Sep 17 00:00:00 2001 From: hyojin kim Date: Fri, 27 Feb 2026 18:35:50 +0900 Subject: [PATCH] =?UTF-8?q?feat:=20=EC=84=A0=EB=B0=95=20AIS=20=EB=A7=88?= =?UTF-8?q?=EC=A7=80=EB=A7=89=20=EC=9C=84=EC=B9=98=20=EC=97=85=EB=8D=B0?= =?UTF-8?q?=EC=9D=B4=ED=8A=B8=20=EB=8C=80=EC=83=81=20=EB=B3=80=EA=B2=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * new_snp.core20 -> t_std_snp_svc.tb_ship_main_info --- .../ShipLastPositionSyncRepositoryImpl.java | 70 +++++++++---------- src/main/resources/application-dev.yml | 4 +- src/main/resources/application-prod.yml | 8 +-- src/main/resources/application.yml | 4 +- 4 files changed, 43 insertions(+), 43 deletions(-) diff --git a/src/main/java/com/snp/batch/jobs/aistargetdbsync/batch/repository/ShipLastPositionSyncRepositoryImpl.java b/src/main/java/com/snp/batch/jobs/aistargetdbsync/batch/repository/ShipLastPositionSyncRepositoryImpl.java index 57af690..84e3e6c 100644 --- a/src/main/java/com/snp/batch/jobs/aistargetdbsync/batch/repository/ShipLastPositionSyncRepositoryImpl.java +++ b/src/main/java/com/snp/batch/jobs/aistargetdbsync/batch/repository/ShipLastPositionSyncRepositoryImpl.java @@ -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 diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml index 41f23a7..dc657be 100644 --- a/src/main/resources/application-dev.yml +++ b/src/main/resources/application-dev.yml @@ -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) diff --git a/src/main/resources/application-prod.yml b/src/main/resources/application-prod.yml index bdce1c6..b718ed1 100644 --- a/src/main/resources/application-prod.yml +++ b/src/main/resources/application-prod.yml @@ -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: diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index 53f8e62..6180885 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -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)