fix: 카카오톡 send bulk시 모든 결과 수신 단위 결과처리 -> bulk단위 별 결과 처리하도록 변경

mens-batch/src/main/java/kr/xit/biz/ens/service/EnsBatchExtractService.java

@@ -97,15 +97,50 @@ public class EnsBatchExtractService extends AbstractService implements
     /**
      * <pre>
      * 카카오문서 요청 결과 반영
-     * 1. 카카오페이 문서요청 결과 반영 : tb_ens_kakao_my_doc
+     * 1. 카카오페이 문서요청 결과 반영 : tb_ens_kakao_d10
+     * 2. 모바일 페이지 생성 : tb_ens_mobile_page_manage
+     * 3. 연계발송결과 생성 : tb_cntc_sndng_result
+     *    -> 성공시 'SENT' 로 코드값 생성
+     * @param resList       List<KkopayDocBulkDTO.BulkSendResponses> 카카오톡 발송요청 결과 목록
+     * </pre>
+     */
+    @Override
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
+    public void saveKkotalkSendResult(final List<KkotalkDTO.BulkSendResponse> resList) {
+        // 결과 반영
+        resList.forEach(o ->
+            o.getEnvelopes().forEach(
+                t -> {
+                    // 카카오톡 전자고지 요청 결과 반영
+                    mapper.updateKakaotalkSendBulksResult(t);
+                    String code = null;
+                    // 모바일 페이지 컨텐트 생성
+                    if (Checks.isNotEmpty(t.getEnvelopeId())) {
+                        mapper.insertKkotalkMobilePageManage(t.getExternalId());
+                    }else{
+                        code = t.getErrorCode();
+                    }
+                    // 연계발송결과 생성
+                    insertCntcSndngResult(SndngSeCode.KAKAO_NEW.getCode(),
+                        t.getExternalId(), code, t.getErrorMessage());
+                })
+        );
+    }
+    
+    /**
+     * <pre>
+     * @Deprecated :: 건별 bulk별 처리로 미사용 -> saveKkotalkSendResult(final List<KkotalkDTO.BulkSendResponse> resList)    
+     * 카카오문서 요청 결과 반영
+     * 1. 카카오톡 문서요청 결과 반영 : tb_ens_kakao_d10
      * 2. 모바일 페이지 생성 : tb_ens_mobile_page_manage
      * 3. 연계발송결과 생성 : tb_cntc_sndng_result
      *    -> 성공시 'SENT' 로 코드값 생성
      * @param mstId         발송마스터 ID
-     * @param resList       List<KkopayDocBulkDTO.BulkSendResponses> 카카오내문서함 발송요청 결과 목록
+     * @param resList       List<KkopayDocBulkDTO.BulkSendResponses> 카카오톡 발송요청 결과 목록
      * @param unitySndMstId String 통합발송 마스터 ID
      * </pre>
      */
+    @Deprecated
     @Override
     @Transactional(propagation = Propagation.REQUIRES_NEW)
     public void saveKkotalkSendResult(final String mstId, String unitySndMstId, final List<KkotalkDTO.BulkSendResponse> resList) {

mens-batch/src/main/java/kr/xit/biz/ens/service/EnsBatchSendService.java

@@ -284,6 +284,9 @@ public class EnsBatchSendService extends AbstractService implements IEnsBatchSen
         for(ApiResponseDTO apiResult : apiResults) {
             if(apiResult.getData() != null) {
                 resList.add(toObjByObj(apiResult.getData(), KkotalkDTO.BulkSendResponse.class));
+                // FIXME:: 카카오톡 bulk send별 결과 처리
+                extractService.saveKkotalkSendResult(resList);
+                resList.clear();
                 isSuccess = true;
                 continue;
             }
@@ -293,7 +296,11 @@ public class EnsBatchSendService extends AbstractService implements IEnsBatchSen
         if(!isSuccess){
             extractService.updateSndngMstFailStatus(mstId, SndngSeCode.KAKAO_NEW, "", errMsg, errMsg);
         }
-        extractService.saveKkotalkSendResult(mstId, dto.getUnitySndngMastrId(), resList);
+        extractService.updateSendSndngMstStatus(mstId, dto.getUnitySndngMastrId(), SndngSeCode.KAKAO_NEW, "카카오톡 전자고지 발송요청 실패(발송마스터 데이타 오류)");
+        
+        // FIXME:: 카카오톡 bulk send별 결과 처리로 변경
+        //extractService.saveKkotalkSendResult(mstId, dto.getUnitySndngMastrId(), resList);
+        /// //////////////////////////////////////////
     }
 
     /**

mens-batch/src/main/java/kr/xit/biz/ens/service/IEnsBatchExtractService.java

@@ -1,13 +1,13 @@
 package kr.xit.biz.ens.service;
 
-import java.util.List;
+import java.util.*;
 
-import kr.xit.biz.common.ApiConstants.SndngSeCode;
-import kr.xit.biz.ens.model.cmm.SndngMssageParam;
-import kr.xit.biz.ens.model.kakao.pay.KkopayDocBulkDTO;
-import kr.xit.biz.ens.model.kakao.talk.KkotalkDTO;
-import kr.xit.biz.ens.model.kt.KtMmsSendDTO.KtMainSendReqData;
-import kr.xit.biz.ens.model.ktgbs.KtGbsDTO;
+import kr.xit.biz.common.ApiConstants.*;
+import kr.xit.biz.ens.model.cmm.*;
+import kr.xit.biz.ens.model.kakao.pay.*;
+import kr.xit.biz.ens.model.kakao.talk.*;
+import kr.xit.biz.ens.model.kt.KtMmsSendDTO.*;
+import kr.xit.biz.ens.model.ktgbs.*;
 
 /**
  * <pre>
@@ -32,6 +32,8 @@ public interface IEnsBatchExtractService {
     // REQUIRES_NEW service method
     //-----------------------------------------------------------------------------------------------------------------
     void saveKkopaySendResult(final String mstId, String unitySndMstId, final List<KkopayDocBulkDTO.BulkSendResponses> resList);
+    void saveKkotalkSendResult(final List<KkotalkDTO.BulkSendResponse> resList);
+    @Deprecated
     void saveKkotalkSendResult(final String mstId, String unitySndMstId, final List<KkotalkDTO.BulkSendResponse> resList);
 
     void saveKtBcResult(final SndngMssageParam dto, final List<KtMainSendReqData> sendReqs);