feat: make 처리 반영

mens-batch/src/main/java/kr/xit/biz/ens/mapper/IEnsBatchMapper.java

@@ -158,6 +158,28 @@ public interface IEnsBatchMapper {
      */
     <T> int insertPostSndng(final T t);
 
+    /**
+     * <pre>
+     * Kt 공공알림문자 데이터 생성
+     * - tb_ens_kt_bc
+     * @param t T
+     * @return int
+     * </pre>
+     */
+    <T> int insertKtBc(final T t);
+
+
+    /**
+     * <pre>
+     * Post plus 데이터 생성
+     * -
+     * @param t T
+     * @return int
+     * </pre>
+     */
+    <T> int insertPplus(final T t);
+
+
     /**
      * <pre>
      * 통합발송마스터 상태 변경

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

@@ -639,6 +639,10 @@ public class EnsBatchService extends EgovAbstractServiceImpl implements IEnsBatc
      *         - tb_ens_post_sndng
      * SMS     - {@link IEnsBatchMapper#insertSmsSndng(Object) insertSmsSndng}
      *         - tb_ens_sms_sndng
+     * KT_BC   - {@link IEnsBatchMapper#insertKtBc(Object) insertKtBc}
+     *         - tb_ens_kt_bc FIXME::처리 필요
+     * PPLUS   - {@link IEnsBatchMapper#insertPplus(Object) insertPplus}
+     *         - tb_ens_ FIXME::처리 필요
      * @param dto SndngMssageParam
      * @return int
      * </pre>
@@ -650,18 +654,17 @@ public class EnsBatchService extends EgovAbstractServiceImpl implements IEnsBatc
             Checks.checkVal(dto.getTry3(), "")
         };
         switch (SndngSeCode.compare(tryVal[dto.getTrySeq() - 1])) {
-            case KAKAO:
+            case KAKAO -> mapper.insertKakaoMyDocs(dto);
-                return mapper.insertKakaoMyDocs(dto);
+            case E_GREEN -> mapper.insertPostSndng(dto);
-
+            case SMS -> mapper.insertSmsSndng(dto);
-            case E_GREEN:
+            // FIXME::처리 필요
-                return mapper.insertPostSndng(dto);
+            case KT_BC -> mapper.insertKtBc(dto);
-
+            // FIXME::처리 필요
-            case SMS:
+            case PPLUS -> mapper.insertPplus(dto);
-                return mapper.insertSmsSndng(dto);
-
-            default:
-                return 1;
             }
+        throw BizRuntimeException.create(
+            String.format("정의 되지 않은 문서 중개자[%s] 입니다", tryVal[dto.getTrySeq() - 1])
+        );
     }
     //-----------------------------------------------------------------------------------------------------------------
 

mens-batch/src/main/resources/egovframework/mapper/biz/ens-mysql-mapper.xml

@@ -314,6 +314,7 @@
 	</insert>
 
 	<insert id="insertPostSndng">
+		/** ens-mysql-mapper|insertPostSndng-e_green 데이터 생성|julim  */
 		INSERT
 		  INTO tb_ens_post_sndng (
 				sndng_detail_id,				/* 발송 상세 id */
@@ -367,7 +368,7 @@
 		  LEFT JOIN tb_ens_rlaybsnm_manage term
 		    ON teusm.signgu_code = term.signgu_code AND teusm.ffnlg_code = term.ffnlg_code
 		  LEFT JOIN tb_ens_cntc_data tecd
-		    ON teusd.unity_sndng_detail_id=tecd.unity_sndng_detail_id
+		    ON teusd.unity_sndng_detail_id = tecd.unity_sndng_detail_id
 		 <if test="sndngProcessSttus == 'sending1'">
 		 INNER JOIN tb_ens_kakao_my_doc tekmd
 			  ON teusd.unity_sndng_detail_id = tekmd.unity_sndng_detail_id
@@ -377,6 +378,132 @@
 		   AND teusm.sndng_process_sttus = #{sndngProcessSttus}
 	</insert>
 
+	<insert id="insertKtBc">
+		/** ens-mysql-mapper|insertKtBc-KT 공공 알림문자 데이터 생성|julim  */
+		INSERT
+			INTO tb_ens_kt_bc (
+				sndng_detail_id,				/* 발송상세 id */
+				unity_sndng_detail_id,	/* 통합발송상세 id */
+				sndng_mastr_id,					/* 발송마스터 id */
+				signgu_code,						/* 시군구 코드 */
+				ffnlg_code,							/* 과태료 코드 */
+				service_cd,							/* 서비스 코드 */
+				service_key,						/* 서비스 인증키 */
+<!-- FIXME::확인 적용 필요
+				agency_id,							/* 대행사 코드 */
+				dept_cd,								/* 부서 코드 */
+				msg_cd,									/* 문서 코드 */
+				msg_type,								/* 발송 메세지 타입 */
+				make_dt,								/* 발송 시작 일시 */
+				sndn_ex_time,						/* 발송 마감 시간 */
+				ex_time,								/* 열람 마감 시간 */
+				snd_tel_no,							/* 발송 번호 */
+				m_type,									/* 문서 종류 */
+				brand_id,								/* RCS브렌드 홈 값 */
+				opt_type,								/* 메세지 발송 구분 */
+				tkn_rpmt_yn,						/* 토큰 확인 대체 여부 */
+				rdng_rpmt_yn,						/* 열람확인대체여부 */
+				mms_binary,							/* MMS 바이너리 */
+				file_fmat,							/* MMS 바이너리 파일 포맷 */
+				sndn_tot_cnt,						/* 발송요청총건수 */
+				mktn_rcve_csyn,					/* 마케팅 수신 동의 */
+				snd_plfm_id,						/* 송신자 플랫폼 ID */
+				snd_npost,							/* 송신 공인 전자 주소 */
+				snd_date,								/* 송신일시 */
+				multi_mbl_prc_type,			/* 다회선 사용자 처리 구분 */
+				test_sndn_yn,						/* 테스트 발송 여부 */
+				rcv_rfrl_yn,						/* 수신 거부 해제 여부 */
+				reopen_day,							/* 재열람 일수 */
+				src_key,								/* 관리키 */
+				src_seq,								/* 리스트 순번 */
+				ci,											/* ci */
+				mms_dtl_cnts,						/* MMS 상세 내용 */
+				mms_title,							/* MMS 제목 */
+				rcs_dtl_cnts,						/* RCS 메세지 상세 내용 */
+				url,										/* 연결 URL */
+				doc_hash,								/* 문서 해시 */
+				reqs_mms_binary,				/* 개별 MMS 바이너리 */
+				reqs_file_fmat,					/* 개별 MMS 바이너리 파일 포맷 */
+				mdn,										/* 개인 휴대 전화 번호 */
+				dist_info_crt_yn,				/* 유통 정보 미생성 여부 */
+				info_cfrm_str,					/* 안내문 확인하기 치환 문구 */
+				rcve_rf_str,						/* 수신 거부 치환 문구 */
+				result_cd,							/* 처리결과 코드 */
+				result_dt,							/* 처리일시 */
+				error_msg,							/* 에러 내용 */
+				mms_sndg_rslt_sqno,			/* MMS 발송 결과 상태 순번 */
+				prcs_dt,								/* 처리 일자 */
+				mbl_bzowr_dvcd,					/* 모바일 사업자 구분 */
+				rl_mms_sndg_telno,			/* 실제 발송 번호 */
+				mms_sndg_rslt_dvcd,			/* 발송결과 코드 */
+				mms_sndg_tmst,					/* 발송 타임 스탬프 */
+				mms_rcv_tmst,						/* 수신 타임 스탬프 */
+				mms_rdg_tmst,						/* 열람 타임 스탬프 */
+-->
+				regist_dt,
+				register
+			)
+			SELECT LPAD(NEXTVAL(sndng_detail_id_seq), 20, '0')
+					 , teusd.unity_sndng_detail_id
+					 , #{sndngMastrId}
+					 , teusm.signgu_code
+					 , teusm.ffnlg_code
+					 , term.kt_service_code
+					 , IF(#{profile} = 'prod', term.kt_prod_service_cerf_key, term.kt_dev_service_cerf_key)
+					 <!--
+					 FIXME::필드 적용 필요
+					 -->
+					 , now()
+					 , 'batch'
+				FROM tb_ens_unity_sndng_mastr teusm
+				LEFT JOIN tb_ens_tmplat_manage tetm
+					ON teusm.tmplat_id = tetm.tmplat_id
+				LEFT JOIN tb_ens_unity_sndng_detail teusd
+					ON teusm.unity_sndng_mastr_id = teusd.unity_sndng_mastr_id
+				LEFT JOIN tb_ens_rlaybsnm_manage term
+					ON teusm.signgu_code = term.signgu_code AND teusm.ffnlg_code = term.ffnlg_code
+				LEFT JOIN tb_ens_cntc_data tecd
+					ON teusd.unity_sndng_detail_id = tecd.unity_sndng_detail_id
+			 WHERE teusm.unity_sndng_mastr_id = #{unitySndngMastrId}
+				 AND teusm.sndng_process_sttus = #{sndngProcessSttus}
+	</insert>
+
+	<insert id="insertPplus">
+		/** ens-mysql-mapper|insertPplus Post plus 데이터 생성|julim  */
+		<!-- FIXME::확인 적용 필요-->
+		INSERT
+		  INTO tb_ens_kt_bc (
+				sndng_detail_id,				/* 발송상세 id */
+				unity_sndng_detail_id,	/* 통합발송상세 id */
+				sndng_mastr_id,					/* 발송마스터 id */
+				signgu_code,						/* 시군구 코드 */
+				ffnlg_code,							/* 과태료 코드 */
+				regist_dt,
+				register
+		)
+		SELECT LPAD(NEXTVAL(sndng_detail_id_seq), 20, '0')
+				 , teusd.unity_sndng_detail_id
+				 , #{sndngMastrId}
+				 , teusm.signgu_code
+				 , teusm.ffnlg_code
+				 <!--
+				 FIXME::필드 적용 필요
+				 -->
+				 , now()
+				 , 'batch'
+		  FROM tb_ens_unity_sndng_mastr teusm
+		  LEFT JOIN tb_ens_tmplat_manage tetm
+		    ON teusm.tmplat_id = tetm.tmplat_id
+		  LEFT JOIN tb_ens_unity_sndng_detail teusd
+		    ON teusm.unity_sndng_mastr_id = teusd.unity_sndng_mastr_id
+		  LEFT JOIN tb_ens_rlaybsnm_manage term
+		    ON teusm.signgu_code = term.signgu_code AND teusm.ffnlg_code = term.ffnlg_code
+		  LEFT JOIN tb_ens_cntc_data tecd
+		    ON teusd.unity_sndng_detail_id = tecd.unity_sndng_detail_id
+		 WHERE teusm.unity_sndng_mastr_id = #{unitySndngMastrId}
+		   AND teusm.sndng_process_sttus = #{sndngProcessSttus}
+	</insert>
+
 	<update id="updateProcessSttusUnitySndngMst">
 		/** ens-mysql-mapper|updateProcessSttusUntySndngMst-통합발송마스터 상태 변경|julim  */
 		UPDATE tb_ens_unity_sndng_mastr