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
+                UPDATE %s
-                 SET lastseen = ?::timestamptz,
+                   SET last_cptr_hr_utc = ?::timestamptz,
-                     lastport = ?,
+                       last_port = ?,
-                     position_latitude = ?,
+                       now_position_lat = ?,
-                     position_longitude = ?,
+                       now_position_lon = ?,
-                     destination = ?,
+                       ship_dest = ?,
-                     eta = ?::timestamptz,
+                       arvl_prnmnt_hr = ?::timestamptz,
-                     heading = ?,
+                       bow_drctn = ?,
-                     cog = ?,
+                       cog = ?,
-                     speedservice = ?,
+                       sog = ?,
-                     navstat = ?,
+                       ship_nav_status = ?,
-                     tonnes_cargo = ?,
+                       cargo_ton = ?,
-                     extra_info = ?,
+                       add_info = ?,
-                     in_sts = ?,
+                       in_sts = ?,
-                     on_berth = ?
+                       ancrg_yn = ?
-                 WHERE lrno = ?;
+                 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

src/main/resources/application-dev.yml

@@ -142,8 +142,8 @@ app:
 
     # Core20 캐시 테이블 설정 (환경별로 테이블/컬럼명이 다를 수 있음)
     core20:
-      schema: t_std_snp_data    # 스키마명
+      schema: t_std_snp_svc    # 스키마명
-      table: tb_ship_info_mst   # 테이블명
+      table: tb_ship_main_info   # 테이블명
       imo-column: imo_no        # IMO/LRNO 컬럼명 (PK, NOT NULL)
       mmsi-column: mmsi_no      # MMSI 컬럼명 (NULLABLE)
 

src/main/resources/application-prod.yml

@@ -144,10 +144,10 @@ app:
 
     # Core20 캐시 테이블 설정 (환경별로 테이블/컬럼명이 다를 수 있음)
     core20:
-      schema: new_snp    # 스키마명
+      schema: t_std_snp_svc    # 스키마명
-      table: core20   # 테이블명
+      table: tb_ship_main_info   # 테이블명
-      imo-column: lrno        # IMO/LRNO 컬럼명 (PK, NOT NULL)
+      imo-column: imo_no        # IMO/LRNO 컬럼명 (PK, NOT NULL)
-      mmsi-column: mmsi      # MMSI 컬럼명 (NULLABLE)
+      mmsi-column: mmsi_no      # MMSI 컬럼명 (NULLABLE)
 
     # 파티션 관리 설정
     partition:

src/main/resources/application.yml

@@ -212,8 +212,8 @@ app:
 
     # Core20 캐시 테이블 설정 (환경별로 테이블/컬럼명이 다를 수 있음)
     core20:
-      schema: t_std_snp_data    # 스키마명
+      schema: t_std_snp_svc    # 스키마명
-      table: tb_ship_info_mst   # 테이블명
+      table: tb_ship_main_info   # 테이블명
       imo-column: imo_no        # IMO/LRNO 컬럼명 (PK, NOT NULL)
       mmsi-column: mmsi_no      # MMSI 컬럼명 (NULLABLE)