diff --git a/src/main/java/com/snp/batch/common/util/JsonChangeDetector.java b/src/main/java/com/snp/batch/common/util/JsonChangeDetector.java index 989adc4..a8630ac 100644 --- a/src/main/java/com/snp/batch/common/util/JsonChangeDetector.java +++ b/src/main/java/com/snp/batch/common/util/JsonChangeDetector.java @@ -24,7 +24,7 @@ public class JsonChangeDetector { Map map = new HashMap<>(); // List 필드명 // 정렬 기준 복합 키 (JSON 필드명, 쉼표로 구분) map.put("OwnerHistory", "OwnerCode,EffectiveDate,Sequence"); - map.put("CrewList", "ID"); + map.put("CrewList", "LRNO,Shipname,Nationality"); map.put("StowageCommodity", "Sequence,CommodityCode,StowageCode"); map.put("GroupBeneficialOwnerHistory", "EffectiveDate,GroupBeneficialOwnerCode,Sequence"); map.put("ShipManagerHistory", "EffectiveDate,ShipManagerCode,Sequence"); diff --git a/src/main/java/com/snp/batch/jobs/shipdetail/batch/repository/ShipDetailSql.java b/src/main/java/com/snp/batch/jobs/shipdetail/batch/repository/ShipDetailSql.java index b86a9b9..30a3d1f 100644 --- a/src/main/java/com/snp/batch/jobs/shipdetail/batch/repository/ShipDetailSql.java +++ b/src/main/java/com/snp/batch/jobs/shipdetail/batch/repository/ShipDetailSql.java @@ -28,12 +28,10 @@ public class ShipDetailSql { )VALUES( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ? ) - ON CONFLICT (id, lrno) + ON CONFLICT (lrno, shipname, nationality) DO UPDATE SET datasetversion = EXCLUDED.datasetversion, - shipname = EXCLUDED.shipname, crewlistdate = EXCLUDED.crewlistdate, - nationality = EXCLUDED.nationality, totalcrew = EXCLUDED.totalcrew, totalratings = EXCLUDED.totalratings, totalofficers = EXCLUDED.totalofficers,