🗃️ Last Postion Update 대상 스키마 변경

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(){

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 = ?;
              """;
     }