From d8b8a4031639b29c63a553ab1fece9720901f696 Mon Sep 17 00:00:00 2001
From: hyojin kim <hjkim4@gcsc.co.kr>
Date: Thu, 8 Jan 2026 15:57:46 +0900
Subject: [PATCH] :card_file_box: remove batch_flag of new_snp  schema

---
 .../repository/ComplianceRepositoryImpl.java  |  7 +++--
 .../batch/repository/EventRepositoryImpl.java | 26 +------------------
 .../repository/PortCallsRepositoryImpl.java   |  1 -
 .../batch/repository/RiskRepositoryImpl.java  |  7 +++--
 4 files changed, 7 insertions(+), 34 deletions(-)

diff --git a/src/main/java/com/snp/batch/jobs/compliance/batch/repository/ComplianceRepositoryImpl.java b/src/main/java/com/snp/batch/jobs/compliance/batch/repository/ComplianceRepositoryImpl.java
index 64df157..0df9aec 100644
--- a/src/main/java/com/snp/batch/jobs/compliance/batch/repository/ComplianceRepositoryImpl.java
+++ b/src/main/java/com/snp/batch/jobs/compliance/batch/repository/ComplianceRepositoryImpl.java
@@ -53,10 +53,10 @@ public class ComplianceRepositoryImpl extends BaseJdbcRepository<ComplianceEntit
                       shipownerswisssanctionlist, shipowneruaesanctionlist, shipownerunsanctionlist,
                       shipsanctionedcountryportcalllast12m, shipsanctionedcountryportcalllast3m, shipsanctionedcountryportcalllast6m,
                       shipsecuritylegaldisputeevent, shipstspartnernoncompliancelast12m, shipswisssanctionlist,
-                      shipunsanctionlist, batch_flag
+                      shipunsanctionlist
                   )
                   VALUES (
-                      ?, ?::timestamptz, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 'N'
+                      ?, ?::timestamptz, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?
                   )
                   ON CONFLICT (lrimoshipno, dateamended)
                   DO UPDATE SET
@@ -92,8 +92,7 @@ public class ComplianceRepositoryImpl extends BaseJdbcRepository<ComplianceEntit
                       shipsecuritylegaldisputeevent = EXCLUDED.shipsecuritylegaldisputeevent,
                       shipstspartnernoncompliancelast12m = EXCLUDED.shipstspartnernoncompliancelast12m,
                       shipswisssanctionlist = EXCLUDED.shipswisssanctionlist,
-                      shipunsanctionlist = EXCLUDED.shipunsanctionlist,
-                      batch_flag = 'N';
+                      shipunsanctionlist = EXCLUDED.shipunsanctionlist
                 """;
     }
 
diff --git a/src/main/java/com/snp/batch/jobs/event/batch/repository/EventRepositoryImpl.java b/src/main/java/com/snp/batch/jobs/event/batch/repository/EventRepositoryImpl.java
index 687f56e..813e14a 100644
--- a/src/main/java/com/snp/batch/jobs/event/batch/repository/EventRepositoryImpl.java
+++ b/src/main/java/com/snp/batch/jobs/event/batch/repository/EventRepositoryImpl.java
@@ -46,31 +46,7 @@ public class EventRepositoryImpl extends BaseJdbcRepository<EventDetailEntity, L
 
     @Override
     protected String getUpdateSql() {
-        return """
-                INSERT INTO snp_data.event (
-                    Event_ID, Incident_ID, IHSLRorIMOShipNo, Vessel_Name, Vessel_Type,
-                    Event_Type, Significance, Headline, Location_Name,
-                    Published_Date, Event_Start_Date, Event_End_Date, batch_flag
-                ) VALUES (
-                    ?, ?, ?, ?, ?,
-                    ?, ?, ?, ?,
-                    ?::timestamptz, ?::timestamptz, ?::timestamptz, 'N'
-                ) ON CONFLICT (Event_ID) DO UPDATE
-                SET
-                    Incident_ID = EXCLUDED.Incident_ID,
-                    IHSLRorIMOShipNo = EXCLUDED.IHSLRorIMOShipNo,
-                    Vessel_Name = EXCLUDED.Vessel_Name,
-                    Vessel_Type = EXCLUDED.Vessel_Type,
-                    Event_Type = EXCLUDED.Event_Type,
-                    Significance = EXCLUDED.Significance,
-                    Headline = EXCLUDED.Headline,
-                    Location_Name = EXCLUDED.Location_Name,
-                    Published_Date = EXCLUDED.Published_Date,
-                    Event_Start_Date = EXCLUDED.Event_Start_Date,
-                    Event_End_Date = EXCLUDED.Event_End_Date,
-                    batch_flag = 'N'
-                ;
-                """;
+        return null;
     }
 
     @Override
diff --git a/src/main/java/com/snp/batch/jobs/movement/batch/repository/PortCallsRepositoryImpl.java b/src/main/java/com/snp/batch/jobs/movement/batch/repository/PortCallsRepositoryImpl.java
index af04a13..ee30dce 100644
--- a/src/main/java/com/snp/batch/jobs/movement/batch/repository/PortCallsRepositoryImpl.java
+++ b/src/main/java/com/snp/batch/jobs/movement/batch/repository/PortCallsRepositoryImpl.java
@@ -120,7 +120,6 @@ public class PortCallsRepositoryImpl extends BaseJdbcRepository<PortCallsEntity,
                         teu = ?,
                         speedservice = ?,
                         mainenginetype = ?,
-                        batch_flag = 'N'::character varying,
                         status = ?,
                         operator = ?,
                         flagcode = ?,
diff --git a/src/main/java/com/snp/batch/jobs/risk/batch/repository/RiskRepositoryImpl.java b/src/main/java/com/snp/batch/jobs/risk/batch/repository/RiskRepositoryImpl.java
index b5f5232..8968d12 100644
--- a/src/main/java/com/snp/batch/jobs/risk/batch/repository/RiskRepositoryImpl.java
+++ b/src/main/java/com/snp/batch/jobs/risk/batch/repository/RiskRepositoryImpl.java
@@ -60,10 +60,10 @@ public class RiskRepositoryImpl extends BaseJdbcRepository<RiskEntity, Long> imp
                    singleshipoperation, singleshipoperationnarrative, fleetsafety, fleetsafetynarrative, fleetpsc,
                    fleetpscnarrative, specialsurveyoverdue, specialsurveyoverduenarrative, ownerunknown, ownerunknownnarrative,
                    russianportcall, russianportcallnarrative, russianownerregistration, russianownerregistrationnarrative,
-                   russiansts, russianstsnarrative, batch_flag
+                   russiansts, russianstsnarrative
                )
                VALUES (
-                   ?, ?::timestamptz, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 'N'
+                   ?, ?::timestamptz, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?
                )
                ON CONFLICT (lrno, lastupdated)
                DO UPDATE SET
@@ -148,8 +148,7 @@ public class RiskRepositoryImpl extends BaseJdbcRepository<RiskEntity, Long> imp
                    russianownerregistration = EXCLUDED.russianownerregistration,
                    russianownerregistrationnarrative = EXCLUDED.russianownerregistrationnarrative,
                    russiansts = EXCLUDED.russiansts,
-                   russianstsnarrative = EXCLUDED.russianstsnarrative,
-                   batch_flag = 'N';
+                   russianstsnarrative = EXCLUDED.russianstsnarrative
                 """;
     }