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 e71e8fa..c7adba8 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 @@ -56,7 +56,8 @@ public class ShipLastPositionSyncRepositoryImpl implements ShipLastPositionSyncR cargo_ton = ?, add_info = ?, sts_yn = ?, - ancrg_yn = ? + ancrg_yn = ?, + mmsi_no = ? WHERE imo_no = ? """.formatted(getTableName()); } @@ -77,7 +78,8 @@ public class ShipLastPositionSyncRepositoryImpl implements ShipLastPositionSyncR tonnes_cargo = ?, extra_info = ?, in_sts = ?, - on_berth = ? + on_berth = ?, + mmsi = ? WHERE lrno = ?; """; } @@ -172,7 +174,12 @@ public class ShipLastPositionSyncRepositoryImpl implements ShipLastPositionSyncR // ancrg_yn ← onBerth (Boolean, null-safe) ps.setObject(idx++, entity.getOnBerth(), Types.BOOLEAN); + // mmsi_no ← mmsi (Long → 9자리 zero-padded String) + ps.setString(idx++, entity.getMmsi() != null + ? String.format("%09d", entity.getMmsi()) : null); + // WHERE imo_no ← imoVerified (String) ps.setString(idx++, entity.getImoVerified()); + } }