From 31262f5dda062451d22a4907f85d2eab0257c904 Mon Sep 17 00:00:00 2001 From: hyojin kim Date: Wed, 31 Dec 2025 13:59:23 +0900 Subject: [PATCH] =?UTF-8?q?:mute:=20=EB=A1=9C=EA=B7=B8=20=EB=B2=94?= =?UTF-8?q?=EC=9C=84=20=EB=B3=80=EA=B2=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../processor/ShipDetailDataProcessor.java | 2 +- .../repository/ShipDetailRepositoryImpl.java | 52 ++--- .../batch/writer/ShipDetailDataWriter.java | 180 +++++++++--------- 3 files changed, 117 insertions(+), 117 deletions(-) diff --git a/src/main/java/com/snp/batch/jobs/shipdetail/batch/processor/ShipDetailDataProcessor.java b/src/main/java/com/snp/batch/jobs/shipdetail/batch/processor/ShipDetailDataProcessor.java index c4080bc..8f6647c 100644 --- a/src/main/java/com/snp/batch/jobs/shipdetail/batch/processor/ShipDetailDataProcessor.java +++ b/src/main/java/com/snp/batch/jobs/shipdetail/batch/processor/ShipDetailDataProcessor.java @@ -28,7 +28,7 @@ public class ShipDetailDataProcessor extends BaseProcessor toInsert = entities.stream() @@ -547,7 +547,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -571,7 +571,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -595,7 +595,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -619,7 +619,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -643,7 +643,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -667,7 +667,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -691,7 +691,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -715,7 +715,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -739,7 +739,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -763,7 +763,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -787,7 +787,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -811,7 +811,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -835,7 +835,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -859,7 +859,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -883,7 +883,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -907,7 +907,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -931,7 +931,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -955,7 +955,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -979,7 +979,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -1003,7 +1003,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -1027,7 +1027,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -1051,7 +1051,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -1075,7 +1075,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -1100,7 +1100,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { @@ -1124,7 +1124,7 @@ public class ShipDetailRepositoryImpl extends BaseJdbcRepository { diff --git a/src/main/java/com/snp/batch/jobs/shipdetail/batch/writer/ShipDetailDataWriter.java b/src/main/java/com/snp/batch/jobs/shipdetail/batch/writer/ShipDetailDataWriter.java index c9033c8..cf39058 100644 --- a/src/main/java/com/snp/batch/jobs/shipdetail/batch/writer/ShipDetailDataWriter.java +++ b/src/main/java/com/snp/batch/jobs/shipdetail/batch/writer/ShipDetailDataWriter.java @@ -33,7 +33,7 @@ public class ShipDetailDataWriter extends BaseWriter { if (items.isEmpty()) { return; } - log.info("선박 상세 정보 데이터 저장: {} 건", items.size()); +// log.info("선박 상세 정보 데이터 저장: {} 건", items.size()); // 1. List -> 3가지 List 형태로 가공 // 1-1. List (Core20 데이터 처리용) @@ -78,95 +78,95 @@ public class ShipDetailDataWriter extends BaseWriter { // ✅ 2-1. ShipDetailRepository (Core20 데이터) log.debug("Core20 데이터 저장 시작: {} 건", coreEntities.size()); shipDetailRepository.saveAllCoreData(coreEntities); -// -// // ✅ 2-2. 추가적인 Array/List 데이터 -// // OwnerHistory 저장 -// log.debug("OwnerHistory 데이터 저장 시작: {} 건", ownerHistoriyListEntities.size()); -// shipDetailRepository.saveAllOwnerHistoryData(ownerHistoriyListEntities); -// -// // CrewList 저장 -// log.debug("CrewList 데이터 저장 시작: {} 건", crewListEntities.size()); -// shipDetailRepository.saveAllCrewListData(crewListEntities); -// -// // StowageCommodity 저장 -// log.debug("StowageCommodity 저장 시작: {} 건", stowageCommodityListEntities.size()); -// shipDetailRepository.saveAllStowageCommodityData(stowageCommodityListEntities); -// -// // GroupBeneficialOwnerHistory 저장 -// log.debug("GroupBeneficialOwnerHistory 저장 시작: {} 건", groupBeneficialOwnerHistoryListEntities.size()); -// shipDetailRepository.saveAllGroupBeneficialOwnerHistoryData(groupBeneficialOwnerHistoryListEntities); -// -// // ShipManagerHistory 저장 -// log.debug("ShipManagerHistory 저장 시작: {} 건", shipManagerHistoryListEntities.size()); -// shipDetailRepository.saveAllShipManagerHistoryData(shipManagerHistoryListEntities); -// -// // OperatorHistory 저장 -// log.debug("OperatorHistory 저장 시작: {} 건", operatorHistoryListEntities.size()); -// shipDetailRepository.saveAllOperatorHistoryData(operatorHistoryListEntities); -// -// // TechnicalManagerHistory 저장 -// log.debug("TechnicalManagerHistory 저장 시작: {} 건", technicalManagerHistoryListEntities.size()); -// shipDetailRepository.saveAllTechnicalManagerHistoryData(technicalManagerHistoryListEntities); -// -// // BareBoatCharterHistory 저장 -// log.debug("BareBoatCharterHistory 저장 시작: {} 건", bareBoatCharterHistoryListEntities.size()); -// shipDetailRepository.saveAllBareBoatCharterHistoryData(bareBoatCharterHistoryListEntities); -// -// // NameHistory 저장 -// log.debug("NameHistory 저장 시작: {} 건", nameHistoryListEntities.size()); -// shipDetailRepository.saveAllNameHistoryData(nameHistoryListEntities); -// -// // FlagHistory 저장 -// log.debug("FlagHistory 저장 시작: {} 건", flagHistoryListEntities.size()); -// shipDetailRepository.saveAllFlagHistoryData(flagHistoryListEntities); -// -// // AdditionalInformation 저장 -// log.debug("AdditionalInformation 저장 시작: {} 건", additionalInformationListEntities.size()); -// shipDetailRepository.saveAllAdditionalInformationData(additionalInformationListEntities); -// -// // PandIHistory 저장 -// log.debug("PandIHistory 저장 시작: {} 건", pandIHistoryListEntities.size()); -// shipDetailRepository.saveAllPandIHistoryData(pandIHistoryListEntities); -// -// // CallSignAndMmsiHistory 저장 -// log.debug("CallSignAndMmsiHistory 저장 시작: {} 건", callSignAndMmsiHistoryListEntities.size()); -// shipDetailRepository.saveAllCallSignAndMmsiHistoryData(callSignAndMmsiHistoryListEntities); -// -// // IceClass 저장 -// log.debug("IceClass 저장 시작: {} 건", iceClassListEntities.size()); -// shipDetailRepository.saveAllIceClassData(iceClassListEntities); -// -// // SafetyManagementCertificateHistory 저장 -// log.debug("SafetyManagementCertificateHistory 저장 시작: {} 건", safetyManagementCertificateHistoryListEntities.size()); -// shipDetailRepository.saveAllSafetyManagementCertificateHistoryData(safetyManagementCertificateHistoryListEntities); -// -// // ClassHistory 저장 -// log.debug("ClassHistory 저장 시작: {} 건", classHistoryListEntities.size()); -// shipDetailRepository.saveAllClassHistoryData(classHistoryListEntities); -// -// // SurveyDatesHistory 저장 -// log.debug("SurveyDatesHistory 저장 시작: {} 건", surveyDatesHistoryListEntities.size()); -// shipDetailRepository.saveAllSurveyDatesHistoryData(surveyDatesHistoryListEntities); -// -// // SurveyDatesHistoryUnique 저장 -// log.debug("SurveyDatesHistoryUnique 저장 시작: {} 건", surveyDatesHistoryUniqueListEntities.size()); -// shipDetailRepository.saveAllSurveyDatesHistoryUniqueData(surveyDatesHistoryUniqueListEntities); -// -// // SisterShipLinks 저장 -// log.debug("SisterShipLinks 저장 시작: {} 건", sisterShipLinksListEntities.size()); -// shipDetailRepository.saveAllSisterShipLinksData(sisterShipLinksListEntities); -// -// // StatusHistory 저장 -// log.debug("StatusHistory 저장 시작: {} 건", statusHistoryListEntities.size()); -// shipDetailRepository.saveAllStatusHistoryData(statusHistoryListEntities); -// -// // SpecialFeature 저장 -// log.debug("SpecialFeature 저장 시작: {} 건", specialFeatureListEntities.size()); -// shipDetailRepository.saveAllSpecialFeatureData(specialFeatureListEntities); -// -// // Thrusters 저장 -// log.debug("Thrusters 저장 시작: {} 건", thrustersListEntities.size()); -// shipDetailRepository.saveAllThrustersData(thrustersListEntities); + + // ✅ 2-2. 추가적인 Array/List 데이터 + // OwnerHistory 저장 + log.debug("OwnerHistory 데이터 저장 시작: {} 건", ownerHistoriyListEntities.size()); + shipDetailRepository.saveAllOwnerHistoryData(ownerHistoriyListEntities); + + // CrewList 저장 + log.debug("CrewList 데이터 저장 시작: {} 건", crewListEntities.size()); + shipDetailRepository.saveAllCrewListData(crewListEntities); + + // StowageCommodity 저장 + log.debug("StowageCommodity 저장 시작: {} 건", stowageCommodityListEntities.size()); + shipDetailRepository.saveAllStowageCommodityData(stowageCommodityListEntities); + + // GroupBeneficialOwnerHistory 저장 + log.debug("GroupBeneficialOwnerHistory 저장 시작: {} 건", groupBeneficialOwnerHistoryListEntities.size()); + shipDetailRepository.saveAllGroupBeneficialOwnerHistoryData(groupBeneficialOwnerHistoryListEntities); + + // ShipManagerHistory 저장 + log.debug("ShipManagerHistory 저장 시작: {} 건", shipManagerHistoryListEntities.size()); + shipDetailRepository.saveAllShipManagerHistoryData(shipManagerHistoryListEntities); + + // OperatorHistory 저장 + log.debug("OperatorHistory 저장 시작: {} 건", operatorHistoryListEntities.size()); + shipDetailRepository.saveAllOperatorHistoryData(operatorHistoryListEntities); + + // TechnicalManagerHistory 저장 + log.debug("TechnicalManagerHistory 저장 시작: {} 건", technicalManagerHistoryListEntities.size()); + shipDetailRepository.saveAllTechnicalManagerHistoryData(technicalManagerHistoryListEntities); + + // BareBoatCharterHistory 저장 + log.debug("BareBoatCharterHistory 저장 시작: {} 건", bareBoatCharterHistoryListEntities.size()); + shipDetailRepository.saveAllBareBoatCharterHistoryData(bareBoatCharterHistoryListEntities); + + // NameHistory 저장 + log.debug("NameHistory 저장 시작: {} 건", nameHistoryListEntities.size()); + shipDetailRepository.saveAllNameHistoryData(nameHistoryListEntities); + + // FlagHistory 저장 + log.debug("FlagHistory 저장 시작: {} 건", flagHistoryListEntities.size()); + shipDetailRepository.saveAllFlagHistoryData(flagHistoryListEntities); + + // AdditionalInformation 저장 + log.debug("AdditionalInformation 저장 시작: {} 건", additionalInformationListEntities.size()); + shipDetailRepository.saveAllAdditionalInformationData(additionalInformationListEntities); + + // PandIHistory 저장 + log.debug("PandIHistory 저장 시작: {} 건", pandIHistoryListEntities.size()); + shipDetailRepository.saveAllPandIHistoryData(pandIHistoryListEntities); + + // CallSignAndMmsiHistory 저장 + log.debug("CallSignAndMmsiHistory 저장 시작: {} 건", callSignAndMmsiHistoryListEntities.size()); + shipDetailRepository.saveAllCallSignAndMmsiHistoryData(callSignAndMmsiHistoryListEntities); + + // IceClass 저장 + log.debug("IceClass 저장 시작: {} 건", iceClassListEntities.size()); + shipDetailRepository.saveAllIceClassData(iceClassListEntities); + + // SafetyManagementCertificateHistory 저장 + log.debug("SafetyManagementCertificateHistory 저장 시작: {} 건", safetyManagementCertificateHistoryListEntities.size()); + shipDetailRepository.saveAllSafetyManagementCertificateHistoryData(safetyManagementCertificateHistoryListEntities); + + // ClassHistory 저장 + log.debug("ClassHistory 저장 시작: {} 건", classHistoryListEntities.size()); + shipDetailRepository.saveAllClassHistoryData(classHistoryListEntities); + + // SurveyDatesHistory 저장 + log.debug("SurveyDatesHistory 저장 시작: {} 건", surveyDatesHistoryListEntities.size()); + shipDetailRepository.saveAllSurveyDatesHistoryData(surveyDatesHistoryListEntities); + + // SurveyDatesHistoryUnique 저장 + log.debug("SurveyDatesHistoryUnique 저장 시작: {} 건", surveyDatesHistoryUniqueListEntities.size()); + shipDetailRepository.saveAllSurveyDatesHistoryUniqueData(surveyDatesHistoryUniqueListEntities); + + // SisterShipLinks 저장 + log.debug("SisterShipLinks 저장 시작: {} 건", sisterShipLinksListEntities.size()); + shipDetailRepository.saveAllSisterShipLinksData(sisterShipLinksListEntities); + + // StatusHistory 저장 + log.debug("StatusHistory 저장 시작: {} 건", statusHistoryListEntities.size()); + shipDetailRepository.saveAllStatusHistoryData(statusHistoryListEntities); + + // SpecialFeature 저장 + log.debug("SpecialFeature 저장 시작: {} 건", specialFeatureListEntities.size()); + shipDetailRepository.saveAllSpecialFeatureData(specialFeatureListEntities); + + // Thrusters 저장 + log.debug("Thrusters 저장 시작: {} 건", thrustersListEntities.size()); + shipDetailRepository.saveAllThrustersData(thrustersListEntities); // DarkActivityConfirmed 저장 log.debug("DarkActivityConfirmed 저장 시작: {} 건", darkActivityConfirmedEntities.size());