diff --git a/mens-batch/src/main/java/kr/xit/batch/ens/task/SndngMakeTasklet.java b/mens-batch/src/main/java/kr/xit/batch/ens/task/SndngMakeTasklet.java index b01b1b8..cbf0d5c 100644 --- a/mens-batch/src/main/java/kr/xit/batch/ens/task/SndngMakeTasklet.java +++ b/mens-batch/src/main/java/kr/xit/batch/ens/task/SndngMakeTasklet.java @@ -1,7 +1,11 @@ package kr.xit.batch.ens.task; +import java.util.List; +import java.util.Map; import kr.xit.batch.ens.task.cmm.TaskCmmUtils; +import kr.xit.biz.common.ApiConstants; import kr.xit.biz.ens.model.EnsDTO; +import kr.xit.biz.ens.model.cmm.SndngMssageParam; import kr.xit.biz.ens.service.IEnsBatchMakeService; import kr.xit.core.spring.util.error.ErrorParse; import lombok.RequiredArgsConstructor; @@ -37,35 +41,71 @@ public class SndngMakeTasklet implements Tasklet { @JobScope public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) { final String isSlackEnabled = contribution.getStepExecution().getJobParameters().getString("isSlackEnabled"); + boolean isSuccess = false; + final String SNDNG_PROCESS_STTUS = "sndngProcessSttus"; + final String UNITY_SNDNG_MST_ID = "unitySndngMastrId"; + try { - service.make( + Map> tgtMap = service.findMakes( EnsDTO.BatchEnsRequest.builder() .signguCode(contribution.getStepExecution().getJobParameters().getString("signguCode")) .ffnlgCode(contribution.getStepExecution().getJobParameters().getString("ffnlgCode")) .sndngProcessSttus(contribution.getStepExecution().getJobParameters().getString("sndngProcessSttus")) .build() ); - }catch(Exception e){ - String errMsg = ErrorParse.extractError(e).getMessage(); - log.error("SndngMakeTasklet error :: {}", e.getMessage()); - MDC.put("service_error_msg", errMsg); - TaskCmmUtils.taskBatchErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - errMsg, - isSlackEnabled - ); + for(String key :tgtMap.keySet()){ + List tgtList = tgtMap.get(key); - TaskCmmUtils.taskEnsBatchServiceUpdateErrorLog( - contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), - errMsg, - isSlackEnabled - ); - contribution.setExitStatus(ExitStatus.FAILED); + for(SndngMssageParam dto : tgtList) { + + try{ + dto.setProfile(ApiConstants.PROFILE); + + if("tty1".equals(key)) { + MDC.put(UNITY_SNDNG_MST_ID, dto.getUnitySndngMastrId()); + MDC.put(SNDNG_PROCESS_STTUS, "make-fail1"); + dto.setProfile(ApiConstants.PROFILE); + dto.setSndngProcessSttus(contribution.getStepExecution().getJobParameters().getString("sndngProcessSttus")); + dto.setNewSndngProcessSttus(ApiConstants.SndngProcessStatus.MAKE_OK.getCode()); + //FIXME: try1,try2,tr3이 있는 경우 try1 이전에 try2,3이 실행될 수 있는 경우??? + dto.setTrySeq(1); + dto.setSndngCo(dto.getSndngCo()); + dto.setSndngSeCode(dto.getTry1()); + + } + else if("tty2".equals(key)) { + if(!service.makeIsNext(dto)) continue; + } + + service.make(dto); + isSuccess = true; + + }catch(Exception e){ + String errMsg = ErrorParse.extractError(e).getMessage(); + log.error("SndngMakeTasklet error :: {}", e.getMessage()); + MDC.put("service_error_msg", errMsg); + + TaskCmmUtils.taskBatchErrorLog( + contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), + errMsg, + isSlackEnabled + ); + + TaskCmmUtils.taskEnsBatchServiceUpdateErrorLog( + contribution.getStepExecution().getJobExecution().getJobInstance().getJobName(), + errMsg, + isSlackEnabled + ); + } + } + } + + } finally { + if(!isSuccess) contribution.setExitStatus(ExitStatus.FAILED); + else contribution.setExitStatus(ExitStatus.COMPLETED); return RepeatStatus.FINISHED; } - contribution.setExitStatus(ExitStatus.COMPLETED); - return RepeatStatus.FINISHED; } } diff --git a/mens-batch/src/main/java/kr/xit/batch/ens/task/SndngSendBulksTasklet.java b/mens-batch/src/main/java/kr/xit/batch/ens/task/SndngSendBulksTasklet.java index 4c78457..53baa25 100644 --- a/mens-batch/src/main/java/kr/xit/batch/ens/task/SndngSendBulksTasklet.java +++ b/mens-batch/src/main/java/kr/xit/batch/ens/task/SndngSendBulksTasklet.java @@ -44,7 +44,6 @@ public class SndngSendBulksTasklet implements Tasklet { try { MDC.put("request_trace_batch_id", UUID.randomUUID().toString().replace("-", "")); - //MDC.put("uri", "/v1/documents/bulk"); MDC.put("method", "POST"); List tgtList = service.findBulks( @@ -84,24 +83,6 @@ public class SndngSendBulksTasklet implements Tasklet { ); } } -// } catch (Exception e) { -// String errMsg = ErrorParse.extractError(e).getMessage(); -// log.error("SndngSendBulksTasklet error :: {}", e.getMessage()); -// MDC.put("service_error_msg", errMsg); -// -// TaskCmmUtils.taskBatchErrorLog( -// contribution.getStepExecution().getJobExecution().getJobInstance() -// .getJobName(), -// errMsg, -// isSlackEnabled -// ); -// -// TaskCmmUtils.taskEnsBatchServiceUpdateErrorLog( -// contribution.getStepExecution().getJobExecution().getJobInstance() -// .getJobName(), -// errMsg, -// isSlackEnabled -// ); } finally { if(!isSuccess) contribution.setExitStatus(ExitStatus.FAILED); diff --git a/mens-batch/src/main/java/kr/xit/biz/ens/service/EnsBatchMakeService.java b/mens-batch/src/main/java/kr/xit/biz/ens/service/EnsBatchMakeService.java index 133755d..c094db8 100644 --- a/mens-batch/src/main/java/kr/xit/biz/ens/service/EnsBatchMakeService.java +++ b/mens-batch/src/main/java/kr/xit/biz/ens/service/EnsBatchMakeService.java @@ -1,6 +1,8 @@ package kr.xit.biz.ens.service; +import java.util.HashMap; import java.util.List; +import java.util.Map; import kr.xit.biz.common.ApiConstants; import kr.xit.biz.common.ApiConstants.SignguCode; import kr.xit.biz.common.ApiConstants.SndngSeCode; @@ -48,100 +50,73 @@ public class EnsBatchMakeService extends EgovAbstractServiceImpl implements IEns /** * 
-     * make(생성) 처리 - 문서 중개자별 생성
-     * - 통합발송마스터의 발송처리 상태 'accept-ok', 'sending1', 'sending2' 대상
-     * - 발송처리 상태 'sending1,2'이면 발송일시2,3(sndng_dt_2,3)이 현재일 이전 대상
-     * - 처리 완료 : 발송마스터,  발송상세(문서중개자별 상세 테이블) 생성
-     *             연계마스터, 통합발송마스터의 발송처리 상태 'make-ok'
-     * - 실패 : 연계마스터, 통합발송마스터의 발송처리 상태 'make-fail1,2,3'
-     *
      * 1. 통합 발송 생성 대상 조회
      *    - 발송처리상태가 접수(accept-ok)인 데이타
      *    - 발송처리상태가 1차, 2차 전송상태(sending1, sending2)인 데이타
      *    -> {@link IEnsBatchMapper#selectMakeTgts selectMakeTgts}
      *    - tb_ens_unity_sndng_mastr
-     *
-     * 2. 생성 : {@link #makeMstStatusUpdate}
-     *    2-1. 발송마스터 생성 : tb_ens_sndng_mastr
-     *    2-2. 문서 중개자별 발송 상세 생성
-     *    2-3. 연계/통합 발송마스터상태 변경
-     *    - 발송처리상태 - make-ok
-     *      1차 발송 : try_seq - 1,
-     *                발송구분 - 템플릿관리테이블 try1
-     *      2차 발송 : try_seq - 2
-     *                발송구분 - 템플릿관리테이블 try2
-     *                발송건수 - 2차대상발송건수 조회({@link IEnsBatchMapper#selectSendOkTgts selectSendOkTgts})
-     * @param reqDTO BatchEnsRequest
+     * @param reqDTO
+     * @return Map> 'tty1', 'tty2', 'tty3'에 대상 put
      *
*/ + /** + * + * @param reqDTO + * @return + */ @Override - @Transactional(propagation = Propagation.REQUIRES_NEW) - public void make(final EnsDTO.BatchEnsRequest reqDTO) { + @Transactional(readOnly = true) + public Map> findMakes(final EnsDTO.BatchEnsRequest reqDTO) { + final Map> tgtMap = new HashMap<>(); final String sndngProcessSttus2 = ApiConstants.SndngProcessStatus.SENDING1.getCode(); final String sndngProcessSttus3 = ApiConstants.SndngProcessStatus.SENDING2.getCode(); - final List list = mapper.selectMakeTgts(reqDTO); - final List list2 = mapper.selectMakeTgts(sndngProcessSttus2); - - for (SndngMssageParam dto : list) { - MDC.put(UNITY_SNDNG_MST_ID, dto.getUnitySndngMastrId()); - MDC.put(SNDNG_PROCESS_STTUS, "make-fail1"); - - dto.setSignguCode(reqDTO.getSignguCode()); - dto.setFfnlgCode(reqDTO.getFfnlgCode()); - dto.setProfile(ApiConstants.PROFILE); - dto.setSndngProcessSttus(reqDTO.getSndngProcessSttus()); - dto.setNewSndngProcessSttus(ApiConstants.SndngProcessStatus.MAKE_OK.getCode()); - //FIXME: try1,try2,tr3이 있는 경우 try1 이전에 try2,3이 실행될 수 있는 경우??? - dto.setTrySeq(1); - dto.setSndngSeCode(dto.getTry1()); - - makeMstStatusUpdate(dto); - } - - for (SndngMssageParam dto : list2) { - MDC.put(UNITY_SNDNG_MST_ID, dto.getUnitySndngMastrId()); - MDC.put(SNDNG_PROCESS_STTUS, "make-fail2"); + tgtMap.put("tty1", mapper.selectMakeTgts(reqDTO)); + tgtMap.put("tty2", mapper.selectMakeTgts(sndngProcessSttus2)); + //tgtMap.put("tty3", mapper.selectMakeTgts(sndngProcessSttus3)); + return tgtMap; + } - dto.setSignguCode(reqDTO.getSignguCode()); - dto.setFfnlgCode(reqDTO.getFfnlgCode()); - dto.setProfile(ApiConstants.PROFILE); + /** + * 
+     * 2차 or 3차 발송 대상이 있는지 확인하여
+     * 없으면 발송마스터, 통합발송 마스터 send-ok 처리
+     * 2차 or 3차 발송 대상이 있으면 true return
+     * @param dto SndngMssageParam
+     * @return boolean 2차 or 3차 발송 대상이 있으면 true
+     *
+ */ + @Override + @Transactional(propagation = Propagation.REQUIRES_NEW) + public boolean makeIsNext(final SndngMssageParam dto) { + MDC.put(UNITY_SNDNG_MST_ID, dto.getUnitySndngMastrId()); + MDC.put(SNDNG_PROCESS_STTUS, "make-fail2"); + dto.setProfile(ApiConstants.PROFILE); - //try2 발송 대상이 있는지 확인 - final int sendCnt = mapper.selectSendOkTgts(dto); + //try2 발송 대상이 있는지 확인 + final int sendCnt = mapper.selectSendOkTgts(dto); - //없으면 연계 발송 마스터, 통합 발송 마스터 send-ok - if (sendCnt == 0) { - dto.setNewSndngProcessSttus(ApiConstants.SndngProcessStatus.SEND_OK.getCode()); + //없으면 연계 발송 마스터, 통합 발송 마스터 send-ok + if (sendCnt == 0) { + dto.setNewSndngProcessSttus(ApiConstants.SndngProcessStatus.SEND_OK.getCode()); - if (mapper.updateProcessSttusCntcSndngMst(dto) != 1) { - throw BizRuntimeException.create("[make]연계 발송 마스터 상태변경 실패"); - } - if (mapper.updateProcessSttusUnitySndngMst(dto) != 1) { - throw BizRuntimeException.create("[make]통합 발송 마스터 상태변경 실패"); - } - } else { - //있으면 make - dto.setSndngProcessSttus(sndngProcessSttus2); - dto.setNewSndngProcessSttus(ApiConstants.SndngProcessStatus.MAKE_OK.getCode()); - dto.setTrySeq(2); - dto.setSndngCo(sendCnt); - dto.setSndngSeCode(dto.getTry2()); - - makeMstStatusUpdate(dto); + if (mapper.updateProcessSttusCntcSndngMst(dto) != 1) { + throw BizRuntimeException.create("[make]연계 발송 마스터 상태변경 실패"); } + if (mapper.updateProcessSttusUnitySndngMst(dto) != 1) { + throw BizRuntimeException.create("[make]통합 발송 마스터 상태변경 실패"); + } + return false; } - - //TODO:: GS 인증 시험에서 카카오, E-GREEN만 있어서 3단계는 필요 시 구현 + //있으면 make + dto.setSndngProcessSttus(ApiConstants.SndngProcessStatus.SENDING1.getCode()); + dto.setNewSndngProcessSttus(ApiConstants.SndngProcessStatus.MAKE_OK.getCode()); + dto.setTrySeq(2); + dto.setSndngCo(sendCnt); + dto.setSndngSeCode(dto.getTry2()); + return true; } - //************************************************************************* - // private method - //************************************************************************* - - //----------------------------------------------------------------------------------------------------------------- - // make - //----------------------------------------------------------------------------------------------------------------- /** * 
      * make 처리
@@ -159,7 +134,9 @@ public class EnsBatchMakeService extends EgovAbstractServiceImpl implements IEns
      * @param dto SndngMssageParam
      *
*/ - private void makeMstStatusUpdate(SndngMssageParam dto) { + @Override + @Transactional(propagation = Propagation.REQUIRES_NEW) + public void make(SndngMssageParam dto) { // 1. master if (mapper.insertSndngMst(dto) != 1) { throw BizRuntimeException.create("[make]데이타 생성(마스터) 실패"); @@ -182,6 +159,14 @@ public class EnsBatchMakeService extends EgovAbstractServiceImpl implements IEns } } + //************************************************************************* + // private method + //************************************************************************* + + //----------------------------------------------------------------------------------------------------------------- + // make + //----------------------------------------------------------------------------------------------------------------- + /** * 
      * make 상세 데이타 생성 : 문서 중개자별 상세 데이타 생셩
@@ -211,7 +196,10 @@ public class EnsBatchMakeService extends EgovAbstractServiceImpl implements IEns
         final String seCode = tryVal[dto.getTrySeq() - 1];
 
         return  switch (SndngSeCode.compare(seCode)) {
-            case KAKAO -> mapper.insertKakaoMyDocs(dto);
+            case KAKAO -> {
+                if(true) throw BizRuntimeException.create("####make error#######");
+                yield mapper.insertKakaoMyDocs(dto);
+            }
             case E_GREEN -> mapper.insertPostSndng(dto);
             case SMS -> mapper.insertSmsSndng(dto);
             case KT_BC -> {
diff --git a/mens-batch/src/main/java/kr/xit/biz/ens/service/EnsBatchSendService.java b/mens-batch/src/main/java/kr/xit/biz/ens/service/EnsBatchSendService.java
index c2a71d2..a10d82d 100644
--- a/mens-batch/src/main/java/kr/xit/biz/ens/service/EnsBatchSendService.java
+++ b/mens-batch/src/main/java/kr/xit/biz/ens/service/EnsBatchSendService.java
@@ -90,6 +90,11 @@ public class EnsBatchSendService extends EgovAbstractServiceImpl implements IEns
     private final ApiWebClientUtil apiWebClient;
     private final IEnsBatchMapper mapper;
 
+    /**
+     * 발송대상 조회
+     * @param reqDTO BatchEnsRequest
+     * @return List
+     */
     @Override
     @Transactional(readOnly = true)
     public List findBulks(final EnsDTO.BatchEnsRequest reqDTO) {
@@ -97,40 +102,6 @@ public class EnsBatchSendService extends EgovAbstractServiceImpl implements IEns
         // 발송/통합발송 마스터에서 대상 조회
         reqDTO.setBatchPeriod(batchSendPeriod);
         return mapper.selectSendBulkTgts(reqDTO);
-//        for (SndngMssageParam dto : tgtList) {
-//            dto.setSignguCode(reqDTO.getSignguCode());
-//            dto.setFfnlgCode(reqDTO.getFfnlgCode());
-//            dto.setProfile(ApiConstants.PROFILE);
-//
-//            MDC.put(UNITY_SNDNG_MST_ID, dto.getUnitySndngMastrId());
-//            MDC.put("sndngMastrId", dto.getSndngMastrId());
-//            MDC.put(SNDNG_PROCESS_STTUS, "send-fail" + dto.getTrySeq());
-//
-//            final String[] tryVal = {
-//                Checks.checkVal(dto.getTry1(), ""),
-//                Checks.checkVal(dto.getTry2(), ""),
-//                Checks.checkVal(dto.getTry3(), "")
-//            };
-//
-//            // 마스터 상태 변경값을 파라메터에서 받은 상태값으로 set
-//            dto.setNewSndngProcessSttus(reqDTO.getSndngProcessSttus());
-//            final String seCode = tryVal[dto.getTrySeq() - 1];
-//
-//            // 업무 문서 구분에 따른 분기
-//            switch (SndngSeCode.compare(seCode)) {
-//                /*
-//                 * 카카오페이 연계 결과 반영 : tb_ens_kakao_my_doc
-//                 * 모바일 페이지 생성 : tb_ens_mobile_page_manage
-//                 * 연계발송결과 생성 : tb_cntc_sndng_result
-//                 */
-//                case KAKAO -> sendBulkKakaoMyDocs(dto);
-//                case KT_BC -> sendBulkKtBc(dto);
-//                case PPLUS -> sendBulkPplus(dto);
-//                case E_GREEN -> extractService.sendEgreen(dto);
-//                case SMS -> extractService.sendSms(dto);
-//                default -> throw BizRuntimeException.create(String.format("정의 되지 않은 문서 중개자[%s] 입니다", seCode));
-//            }
-//        }
     }
 
     /**
@@ -142,56 +113,47 @@ public class EnsBatchSendService extends EgovAbstractServiceImpl implements IEns
      *            연계마스터, 통합발송마스터, 발송마스터의 발송처리 상태 변경 - 'send-ok'
      * - 실패 : 연계마스터, 통합발송마스터, 발송마스터의 발송처리 상태 'send-fail1,2,3'
      *
-     * 1. 발송 대상 조회 : {@link IEnsBatchMapper#selectSendBulkTgts selectSendBulkTgts}
-     * 2. 문서 중개자별 send 처리
-     *   2-1. 카카오
+     * 문서 중개자별 send 처리
+     *   - 카카오
      *      - 카카오페이 연계 결과 반영 : tb_ens_kakao_my_doc
      *      - 모바일 페이지 생성 : tb_ens_mobile_page_manage
      *      - 연계발송결과 생성 : tb_cntc_sndng_result
-     * @param reqDTO BatchEnsRequest
+     * @param dto SndngMssageParam
      *
*/ @Override @Transactional(propagation = Propagation.REQUIRES_NEW) public void sendBulks(final SndngMssageParam dto) { + dto.setProfile(ApiConstants.PROFILE); - // 발송/통합발송 마스터에서 대상 조회 - //reqDTO.setBatchPeriod(batchSendPeriod); - //final List tgtList = mapper.selectSendBulkTgts(reqDTO); - //for (SndngMssageParam dto : tgtList) { -// dto.setSignguCode(reqDTO.getSignguCode()); -// dto.setFfnlgCode(reqDTO.getFfnlgCode()); - dto.setProfile(ApiConstants.PROFILE); - - MDC.put(UNITY_SNDNG_MST_ID, dto.getUnitySndngMastrId()); - MDC.put("sndngMastrId", dto.getSndngMastrId()); - MDC.put(SNDNG_PROCESS_STTUS, "send-fail" + dto.getTrySeq()); - - final String[] tryVal = { - Checks.checkVal(dto.getTry1(), ""), - Checks.checkVal(dto.getTry2(), ""), - Checks.checkVal(dto.getTry3(), "") - }; - - // 마스터 상태 변경값을 파라메터에서 받은 상태값으로 set - dto.setNewSndngProcessSttus(dto.getSndngProcessSttus()); - final String seCode = tryVal[dto.getTrySeq() - 1]; - - // 업무 문서 구분에 따른 분기 - switch (SndngSeCode.compare(seCode)) { - /* - * 카카오페이 연계 결과 반영 : tb_ens_kakao_my_doc - * 모바일 페이지 생성 : tb_ens_mobile_page_manage - * 연계발송결과 생성 : tb_cntc_sndng_result - */ - case KAKAO -> sendBulkKakaoMyDocs(dto); - case KT_BC -> sendBulkKtBc(dto); - case PPLUS -> sendBulkPplus(dto); - case E_GREEN -> extractService.sendEgreen(dto); - case SMS -> extractService.sendSms(dto); - default -> throw BizRuntimeException.create(String.format("정의 되지 않은 문서 중개자[%s] 입니다", seCode)); - } - //} + MDC.put(UNITY_SNDNG_MST_ID, dto.getUnitySndngMastrId()); + MDC.put("sndngMastrId", dto.getSndngMastrId()); + MDC.put(SNDNG_PROCESS_STTUS, "send-fail" + dto.getTrySeq()); + + final String[] tryVal = { + Checks.checkVal(dto.getTry1(), ""), + Checks.checkVal(dto.getTry2(), ""), + Checks.checkVal(dto.getTry3(), "") + }; + + // 마스터 상태 변경값을 파라메터에서 받은 상태값으로 set + dto.setNewSndngProcessSttus(dto.getSndngProcessSttus()); + final String seCode = tryVal[dto.getTrySeq() - 1]; + + // 업무 문서 구분에 따른 분기 + switch (SndngSeCode.compare(seCode)) { + /* + * 카카오페이 연계 결과 반영 : tb_ens_kakao_my_doc + * 모바일 페이지 생성 : tb_ens_mobile_page_manage + * 연계발송결과 생성 : tb_cntc_sndng_result + */ + case KAKAO -> sendBulkKakaoMyDocs(dto); + case KT_BC -> sendBulkKtBc(dto); + case PPLUS -> sendBulkPplus(dto); + case E_GREEN -> extractService.sendEgreen(dto); + case SMS -> extractService.sendSms(dto); + default -> throw BizRuntimeException.create(String.format("정의 되지 않은 문서 중개자[%s] 입니다", seCode)); + } } //----------------------------------------------------------------------------------------------------------------- @@ -229,7 +191,6 @@ public class EnsBatchSendService extends EgovAbstractServiceImpl implements IEns // validation check try { - if(true)throw BizRuntimeException.create("$$$$$$$$$$$#########"); validatedKkoMyDocSendBulks(bulkList); } catch (Exception e) { extractService.updateSndngMstFailStatus(mstId, SndngSeCode.KAKAO, "", e.getMessage(), "[send]카카오 문서 발송(bulks)요청 실패(파라메터 오류)"); diff --git a/mens-batch/src/main/java/kr/xit/biz/ens/service/IEnsBatchMakeService.java b/mens-batch/src/main/java/kr/xit/biz/ens/service/IEnsBatchMakeService.java index 374a7e9..82db86c 100644 --- a/mens-batch/src/main/java/kr/xit/biz/ens/service/IEnsBatchMakeService.java +++ b/mens-batch/src/main/java/kr/xit/biz/ens/service/IEnsBatchMakeService.java @@ -1,6 +1,9 @@ package kr.xit.biz.ens.service; +import java.util.List; +import java.util.Map; import kr.xit.biz.ens.model.EnsDTO; +import kr.xit.biz.ens.model.cmm.SndngMssageParam; /** * 
@@ -18,5 +21,7 @@ import kr.xit.biz.ens.model.EnsDTO;
  *
*/ public interface IEnsBatchMakeService { - void make(final EnsDTO.BatchEnsRequest reqDTO); + Map> findMakes(final EnsDTO.BatchEnsRequest reqDTO); + boolean makeIsNext(final SndngMssageParam dto); + void make(SndngMssageParam dto); } diff --git a/mens-batch/src/main/java/kr/xit/biz/ens/web/EnsBatchController.java b/mens-batch/src/main/java/kr/xit/biz/ens/web/EnsBatchController.java index a0a6e0b..30efba5 100644 --- a/mens-batch/src/main/java/kr/xit/biz/ens/web/EnsBatchController.java +++ b/mens-batch/src/main/java/kr/xit/biz/ens/web/EnsBatchController.java @@ -5,11 +5,8 @@ import io.swagger.v3.oas.annotations.media.Content; import io.swagger.v3.oas.annotations.media.ExampleObject; import io.swagger.v3.oas.annotations.tags.Tag; import kr.xit.biz.ens.model.EnsDTO; -import kr.xit.biz.ens.model.cmm.SndngMssageParam; import kr.xit.biz.ens.service.IEnsBatchAcceptService; import kr.xit.biz.ens.service.IEnsBatchCloseService; -import kr.xit.biz.ens.service.IEnsBatchMakeService; -import kr.xit.biz.ens.service.IEnsBatchSendService; import kr.xit.biz.ens.service.IEnsBatchStatusService; import kr.xit.core.model.ApiResponseDTO; import kr.xit.core.model.IApiResponse; @@ -35,14 +32,12 @@ import org.springframework.web.bind.annotation.RestController; * * */ -@Tag(name = "EnsBatchController", description = "전자고지 통합발송 연계 서비스(배치) 테스트") +@Tag(name = "EnsBatchController", description = "전자고지 배치 테스트") @RequiredArgsConstructor @RestController @RequestMapping(value = "/batch/ens/v1") public class EnsBatchController { private final IEnsBatchAcceptService acceptService; - private final IEnsBatchMakeService makeService; - private final IEnsBatchSendService sendService; private final IEnsBatchStatusService statusService; private final IEnsBatchCloseService closeService; @@ -65,25 +60,6 @@ public class EnsBatchController { return ApiResponseDTO.success(); } - @Operation(summary = "통합문서 발송 데이타 생성", description = "통합문서 발송데이타 생성") - @io.swagger.v3.oas.annotations.parameters.RequestBody(required = true, content = { - @Content(mediaType = "application/json", examples = { - @ExampleObject(value = """ - { - "signguCode": "88328", - "ffnlgCode": "11", - "sndngProcessSttus": "accept-ok" - } - """ - ) - }) - }) - @PostMapping(value = "/make", produces = MediaType.APPLICATION_JSON_VALUE) - public IApiResponse make(@RequestBody final EnsDTO.BatchEnsRequest reqDTO){ - makeService.make(reqDTO); - return ApiResponseDTO.success(); - } - @Operation(summary = "통합문서 발송 데이타 종료", description = "통합문서 발송 데이타 종료") @io.swagger.v3.oas.annotations.parameters.RequestBody(required = true, content = { @Content(mediaType = "application/json", examples = { @@ -103,28 +79,6 @@ public class EnsBatchController { return ApiResponseDTO.success(); } - @Operation(summary = "통합문서(bulk) 발송 요청", description = "통합문서 발송 요청") - @io.swagger.v3.oas.annotations.parameters.RequestBody(required = true, content = { - @Content(mediaType = "application/json", examples = { - @ExampleObject(value = """ - { - "signguCode": "88328", - "ffnlgCode": "11", - "sndngProcessSttus": "make-ok" - } - """ - ) - }) - }) - @PostMapping(value = "/sendBulks", produces = MediaType.APPLICATION_JSON_VALUE) - public IApiResponse sendBulks(@RequestBody final EnsDTO.BatchEnsRequest reqDTO){ - for(SndngMssageParam bulk : sendService.findBulks(reqDTO)) { - bulk.setSndngProcessSttus(reqDTO.getSndngProcessSttus()); - sendService.sendBulks(bulk); - } - return ApiResponseDTO.success(); - } - @Operation(summary = "통합문서(bulk) 상태 조회", description = "통합문서 상태 조회") @io.swagger.v3.oas.annotations.parameters.RequestBody(required = true, content = { @Content(mediaType = "application/json", examples = { diff --git a/mens-batch/src/main/java/kr/xit/biz/ens/web/EnsCctvFileController.java b/mens-batch/src/main/java/kr/xit/biz/ens/web/EnsCctvFileController.java index cc67e7a..ffbfabd 100644 --- a/mens-batch/src/main/java/kr/xit/biz/ens/web/EnsCctvFileController.java +++ b/mens-batch/src/main/java/kr/xit/biz/ens/web/EnsCctvFileController.java @@ -26,7 +26,7 @@ import org.springframework.web.bind.annotation.RestController; * * */ -@Tag(name = " EnsCctvFileController", description = "전자고지 CCTV 파일 연계 서비스") +@Tag(name = " EnsCctvFileController", description = "전자고지 CCTV 파일 연계 테스트") @RequiredArgsConstructor @RestController @RequestMapping("/batch/ens/v1") diff --git a/mens-batch/src/main/resources/egovframework/mapper/biz/ens-mysql-mapper.xml b/mens-batch/src/main/resources/egovframework/mapper/biz/ens-mysql-mapper.xml index 38a65b6..56291ef 100644 --- a/mens-batch/src/main/resources/egovframework/mapper/biz/ens-mysql-mapper.xml +++ b/mens-batch/src/main/resources/egovframework/mapper/biz/ens-mysql-mapper.xml @@ -148,6 +148,8 @@ , try3 , try_cnt , sndng_process_sttus + , signgu_code + , ffnlg_code FROM tb_ens_unity_sndng_mastr WHERE sndng_process_sttus = #{sndngProcessSttus} AND signgu_code = #{signguCode}