From 32af369f236dff366708f153e407b13e60fcaabc Mon Sep 17 00:00:00 2001
From: hyojin kim <hjkim4@gcsc.co.kr>
Date: Wed, 24 Dec 2025 14:24:17 +0900
Subject: [PATCH] =?UTF-8?q?:card=5Ffile=5Fbox:=20Last=20Postion=20Update?=
 =?UTF-8?q?=20=EB=8C=80=EC=83=81=20=EC=8A=A4=ED=82=A4=EB=A7=88=20=EB=B3=80?=
 =?UTF-8?q?=EA=B2=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../batch/reader/ShipLastPositionDataReader.java           | 4 ++--
 .../batch/repository/ShipLastPositionRepositoryImpl.java   | 7 +++----
 2 files changed, 5 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/snp/batch/jobs/shipdetail/batch/reader/ShipLastPositionDataReader.java b/src/main/java/com/snp/batch/jobs/shipdetail/batch/reader/ShipLastPositionDataReader.java
index b7c24d4..d63cbbb 100644
--- a/src/main/java/com/snp/batch/jobs/shipdetail/batch/reader/ShipLastPositionDataReader.java
+++ b/src/main/java/com/snp/batch/jobs/shipdetail/batch/reader/ShipLastPositionDataReader.java
@@ -45,10 +45,10 @@ public class ShipLastPositionDataReader extends BaseApiReader<TargetEnhancedDto>
     }
 
     private String getTargetTable(){
-        return "snp_data.core20";
+        return "new_snp.core20";
     }
     private String GET_CORE_IMO_LIST =
-            "SELECT ihslrorimoshipno FROM " + getTargetTable() + " ORDER BY ihslrorimoshipno";
+            "SELECT lrno FROM " + getTargetTable() + " ORDER BY lrno";
 
     @Override
     protected  void beforeFetch(){
diff --git a/src/main/java/com/snp/batch/jobs/shipdetail/batch/repository/ShipLastPositionRepositoryImpl.java b/src/main/java/com/snp/batch/jobs/shipdetail/batch/repository/ShipLastPositionRepositoryImpl.java
index d85d4e0..d1d7ffc 100644
--- a/src/main/java/com/snp/batch/jobs/shipdetail/batch/repository/ShipLastPositionRepositoryImpl.java
+++ b/src/main/java/com/snp/batch/jobs/shipdetail/batch/repository/ShipLastPositionRepositoryImpl.java
@@ -41,7 +41,7 @@ public class ShipLastPositionRepositoryImpl extends BaseJdbcRepository<TargetEnh
     @Override
     protected String getUpdateSql() {
         return """
-             UPDATE snp_data.core20
+             UPDATE new_snp.core20
                 SET lastseen = ?::timestamptz,
                     lastport = ?,
                     position_latitude = ?,
@@ -51,9 +51,8 @@ public class ShipLastPositionRepositoryImpl extends BaseJdbcRepository<TargetEnh
                     heading = ?,
                     speedservice = ?,
                     cog = ?,
-                    navstat = ?,
-                    batch_flag = 'N'
-              WHERE ihslrorimoshipno = ?;
+                    navstat = ?
+              WHERE lrno = ?;
              """;
     }