From d8804e7c9a8bc5a4b28faa5d762c7118142a0c27 Mon Sep 17 00:00:00 2001 From: "gayoun.park" Date: Thu, 5 Feb 2026 14:58:30 +0900 Subject: [PATCH] =?UTF-8?q?=EA=B5=AD=EC=9C=A0=EC=9D=B8=20API=20=EC=88=98?= =?UTF-8?q?=EC=A0=95=20=EC=B6=94=EA=B0=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../gukyuin/dto/ChngDetectContDto.java | 23 ++++++ .../postgres/core/GukYuinJobCoreService.java | 2 + .../core/GukYuinLabelJobCoreService.java | 2 + .../core/GukYuinPnuJobCoreService.java | 3 + .../core/GukYuinStbltJobCoreService.java | 78 ++++++++++--------- 5 files changed, 71 insertions(+), 37 deletions(-) diff --git a/src/main/java/com/kamco/cd/kamcoback/gukyuin/dto/ChngDetectContDto.java b/src/main/java/com/kamco/cd/kamcoback/gukyuin/dto/ChngDetectContDto.java index 57df8055..128b70eb 100644 --- a/src/main/java/com/kamco/cd/kamcoback/gukyuin/dto/ChngDetectContDto.java +++ b/src/main/java/com/kamco/cd/kamcoback/gukyuin/dto/ChngDetectContDto.java @@ -114,4 +114,27 @@ public class ChngDetectContDto { private List result; private Boolean success; } + + @Schema(name = "ResultLabelDto", description = "ResultLabelDto list 리턴 형태") + @Getter + @Setter + @NoArgsConstructor + @AllArgsConstructor + public static class ResultLabelDto { + + private Integer code; + private String message; + private List result; + private Boolean success; + } + + @Getter + @Setter + @NoArgsConstructor + @AllArgsConstructor + public static class ReqInfo { + + private String reqIp; + private String reqEpno; + } } diff --git a/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinJobCoreService.java b/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinJobCoreService.java index c8dbb139..6d5f2746 100644 --- a/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinJobCoreService.java +++ b/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinJobCoreService.java @@ -5,6 +5,7 @@ import com.kamco.cd.kamcoback.gukyuin.dto.GukYuinStatus; import com.kamco.cd.kamcoback.postgres.repository.gukyuin.GukYuinRepository; import java.util.List; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; @Service public class GukYuinJobCoreService { @@ -15,6 +16,7 @@ public class GukYuinJobCoreService { this.gukYuinRepository = gukYuinRepository; } + @Transactional public void updateGukYuinApplyStateComplete(Long id, GukYuinStatus status) { gukYuinRepository.updateGukYuinApplyStateComplete(id, status); } diff --git a/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinLabelJobCoreService.java b/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinLabelJobCoreService.java index 84bf79b4..6c9ce51c 100644 --- a/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinLabelJobCoreService.java +++ b/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinLabelJobCoreService.java @@ -4,6 +4,7 @@ import com.kamco.cd.kamcoback.gukyuin.dto.GukYuinDto.GeomUidDto; import com.kamco.cd.kamcoback.postgres.repository.gukyuin.GukYuinLabelJobRepository; import java.util.List; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; @Service public class GukYuinLabelJobCoreService { @@ -18,6 +19,7 @@ public class GukYuinLabelJobCoreService { return gukYuinLabelRepository.findYesterdayLabelingCompleteList(); } + @Transactional public void updateAnalDataInferenceGeomSendDttm(Long geoUid) { gukYuinLabelRepository.updateAnalDataInferenceGeomSendDttm(geoUid); } diff --git a/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinPnuJobCoreService.java b/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinPnuJobCoreService.java index 734bd1a0..0d83603a 100644 --- a/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinPnuJobCoreService.java +++ b/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinPnuJobCoreService.java @@ -5,6 +5,7 @@ import com.kamco.cd.kamcoback.gukyuin.dto.GukYuinStatus; import com.kamco.cd.kamcoback.postgres.repository.gukyuin.GukYuinPnuJobRepository; import java.util.List; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; @Service public class GukYuinPnuJobCoreService { @@ -27,6 +28,7 @@ public class GukYuinPnuJobCoreService { return gukYuinPnuRepository.upsertMapSheetDataAnalGeomPnu(chnDtctObjtId, pnuList); } + @Transactional public void updateInferenceGeomDataPnuCnt(String chnDtctObjtId, long pnuCnt) { gukYuinPnuRepository.updateInferenceGeomDataPnuCnt(chnDtctObjtId, pnuCnt); } @@ -35,6 +37,7 @@ public class GukYuinPnuJobCoreService { return gukYuinPnuRepository.findMapSheetAnalDataInferenceGeomUid(chnDtctObjtId); } + @Transactional public void insertGeoUidPnuData(Long geoUid, String[] pnuList, String chnDtctObjtId) { gukYuinPnuRepository.insertGeoUidPnuData(geoUid, pnuList, chnDtctObjtId); } diff --git a/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinStbltJobCoreService.java b/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinStbltJobCoreService.java index ba75df37..0f0614da 100644 --- a/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinStbltJobCoreService.java +++ b/src/main/java/com/kamco/cd/kamcoback/postgres/core/GukYuinStbltJobCoreService.java @@ -7,6 +7,7 @@ import com.kamco.cd.kamcoback.postgres.repository.gukyuin.GukYuinStbltJobReposit import java.time.ZonedDateTime; import java.util.List; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; @Service public class GukYuinStbltJobCoreService { @@ -21,47 +22,50 @@ public class GukYuinStbltJobCoreService { return gukYuinStbltRepository.findGukYuinEligibleForSurveyList(status); } + @Transactional public void updateGukYuinEligibleForSurvey(String resultUid, RlbDtctMastDto stbltDto) { PnuEntity entity = gukYuinStbltRepository.findPnuEntityByResultUid(resultUid, stbltDto.getPnu()); - entity.setPnuDtctId(stbltDto.getPnuDtctId()); - entity.setPnu(stbltDto.getPnu()); - entity.setLrmSyncYmd(stbltDto.getLrmSyncYmd()); - entity.setPnuSyncYmd(stbltDto.getPnuSyncYmd()); - entity.setMpqdNo(stbltDto.getMpqdNo()); - entity.setCprsYr(stbltDto.getCprsYr()); - entity.setCrtrYr(stbltDto.getCrtrYr()); - entity.setChnDtctSno(stbltDto.getChnDtctSno()); - entity.setChnDtctId(stbltDto.getChnDtctId()); - entity.setChnDtctMstId(stbltDto.getChnDtctMstId()); - entity.setChnDtctObjtId(stbltDto.getChnDtctObjtId()); - entity.setChnDtctContId(stbltDto.getChnDtctContId()); - entity.setChnCd(stbltDto.getChnCd()); - entity.setBfClsCd(stbltDto.getBfClsCd()); - entity.setBfClsProb(stbltDto.getBfClsProb()); - entity.setAfClsCd(stbltDto.getAfClsCd()); - entity.setAfClsProb(stbltDto.getAfClsProb()); - entity.setPnuSqms(stbltDto.getPnuSqms()); - entity.setPnuDtctSqms(stbltDto.getPnuDtctSqms()); - entity.setChnDtctSqms(stbltDto.getChnDtctSqms()); - entity.setStbltYn(stbltDto.getStbltYn()); - entity.setIncyCd(stbltDto.getIncyCd()); - entity.setIncyRsnCont(stbltDto.getIncyRsnCont()); - entity.setLockYn(stbltDto.getLockYn()); - entity.setLblYn(stbltDto.getLblYn()); - entity.setChgYn(stbltDto.getChgYn()); - entity.setRsatctNo(stbltDto.getRsatctNo()); - entity.setRmk(stbltDto.getRmk()); - entity.setCrtDt(stbltDto.getCrtDt()); - entity.setCrtEpno(stbltDto.getCrtEpno()); - entity.setCrtIp(stbltDto.getCrtIp()); - entity.setChgDt(stbltDto.getChgDt()); - entity.setChgEpno(stbltDto.getChgEpno()); - entity.setChgIp(stbltDto.getChgIp()); - entity.setDelYn(stbltDto.getDelYn().equals("Y")); + if (entity != null) { - entity.setCreatedDttm(ZonedDateTime.now()); - gukYuinStbltRepository.save(entity); + entity.setPnuDtctId(stbltDto.getPnuDtctId()); + entity.setPnu(stbltDto.getPnu()); + entity.setLrmSyncYmd(stbltDto.getLrmSyncYmd()); + entity.setPnuSyncYmd(stbltDto.getPnuSyncYmd()); + entity.setMpqdNo(stbltDto.getMpqdNo()); + entity.setCprsYr(stbltDto.getCprsYr()); + entity.setCrtrYr(stbltDto.getCrtrYr()); + entity.setChnDtctSno(stbltDto.getChnDtctSno()); + entity.setChnDtctId(stbltDto.getChnDtctId()); + entity.setChnDtctMstId(stbltDto.getChnDtctMstId()); + entity.setChnDtctObjtId(stbltDto.getChnDtctObjtId()); + entity.setChnDtctContId(stbltDto.getChnDtctContId()); + entity.setChnCd(stbltDto.getChnCd()); + entity.setBfClsCd(stbltDto.getBfClsCd()); + entity.setBfClsProb(stbltDto.getBfClsProb()); + entity.setAfClsCd(stbltDto.getAfClsCd()); + entity.setAfClsProb(stbltDto.getAfClsProb()); + entity.setPnuSqms(stbltDto.getPnuSqms()); + entity.setPnuDtctSqms(stbltDto.getPnuDtctSqms()); + entity.setChnDtctSqms(stbltDto.getChnDtctSqms()); + entity.setStbltYn(stbltDto.getStbltYn()); + entity.setIncyCd(stbltDto.getIncyCd()); + entity.setIncyRsnCont(stbltDto.getIncyRsnCont()); + entity.setLockYn(stbltDto.getLockYn()); + entity.setLblYn(stbltDto.getLblYn()); + entity.setChgYn(stbltDto.getChgYn()); + entity.setRsatctNo(stbltDto.getRsatctNo()); + entity.setRmk(stbltDto.getRmk()); + entity.setCrtDt(stbltDto.getCrtDt()); + entity.setCrtEpno(stbltDto.getCrtEpno()); + entity.setCrtIp(stbltDto.getCrtIp()); + entity.setChgDt(stbltDto.getChgDt()); + entity.setChgIp(stbltDto.getChgIp()); + entity.setDelYn(stbltDto.getDelYn().equals("Y")); + + entity.setCreatedDttm(ZonedDateTime.now()); + gukYuinStbltRepository.save(entity); + } } }