diff --git a/mens-batch/src/main/java/kr/xit/biz/ens/mapper/IEnsBatchMapper.java b/mens-batch/src/main/java/kr/xit/biz/ens/mapper/IEnsBatchMapper.java index 44bf4e6..943e2dc 100644 --- a/mens-batch/src/main/java/kr/xit/biz/ens/mapper/IEnsBatchMapper.java +++ b/mens-batch/src/main/java/kr/xit/biz/ens/mapper/IEnsBatchMapper.java @@ -97,52 +97,74 @@ public interface IEnsBatchMapper { List selectMakeTgts(final T t); /** + * 
      * 2차 발송 대상 건수 조회
+     * - tb_ens_sndng_mastr, tb_ens_kakao_my_doc
+     * - (NOT (tekmd.doc_box_status = 'READ' AND tekmd.error_code IS NULL)
+     *    OR (tekmd.doc_box_status IS NULL and tekmd.error_code IS NULL))
      * @param t T
      * @return int
+     *
*/ int selectSendOkTgts(final T t); /** + * 
      * 발송마스터 생성
+     * - tb_ens_sndng_mastr
      * @param t status
      * @return int
+     *
*/ int insertSndngMst(final T t); /** + * 
      * 카카오페이 내문서함 생성
-     * @param t
+     * - tb_ens_kakao_my_doc
+     * @param t T
      * @return int
+     *
*/ int insertKakaoMyDocs(final T t); /** + * 
      * 모바일페이지 관리 생성
-     * @param t
+     * - tb_ens_mobile_page_manage
+     * @param t T
      * @return int
+     *
*/ int insertMobilePageManage(final T t); /** + * 
      * 문자발송 데이터 생성
-     * @param t
+     * - tb_ens_sms_sndng
+     * @param t T
      * @return int
+     *
*/ int insertSmsSndng(final T t); /** + * 
      * 우편발송 데이터 생성
-     * @param t
+     * - tb_ens_post_sndng
+     * @param t T
      * @return int
+     *
*/ int insertPostSndng(final T t); /** + * 
      * 통합발송마스터 상태 변경
      * - tb_ens_unity_sndng_mastr : sndng_process_sttus
      * @param t status, newStatus
      * @return int
+     *
*/ int updateProcessSttusUnitySndngMst(final T t); //---------------------------------------------------------------------- @@ -152,6 +174,17 @@ public interface IEnsBatchMapper { //---------------------------------------------------------------------- // close //---------------------------------------------------------------------- + + /** + * 
+     * close 대상 조회
+     * - tb_cntc_sndng_mastr
+     * - sndng_process_sttus IN ('send-ok', 'sending1', 'sending2')
+     * - clos_dt < date_format(adddate(now(), -1), '%Y%m%d%H%i%S')
+     * @param sndngPprocessSttus
+     * @return List
+     *
+ */ List selectCloseTgts(final String sndngPprocessSttus); //---------------------------------------------------------------------- // close @@ -172,45 +205,64 @@ public interface IEnsBatchMapper { List selectSendBulkTgts(final T t); /** + * 
      * 카카오페이 문서요청 대상 목록 조회
+     * - tb_ens_sndng_mastr, tb_ens_kakao_my_doc, tb_ens_ci
      * @param t status
      * @return List
+     *
*/ List selectKakaoSendTgts(final T t); /** + * 
      * E-GREEN 우편발송 대상 목록 조회
+     * - tb_ens_sndng_mastr, tb_ens_post_sndng
      * @param t status
      * @return List
+     *
*/ List selectPostTgts(final T t); /** + * 
      * SMS 발송 대상 목록 조회
+     * - tb_ens_sndng_mastr, tb_ens_sms_sndng
      * @param t status
      * @return List
+     *
*/ List selectSmsSendTgts(final T t); /** + * 
      * 발송상태 조회 : 발송후 발송 연계 마스터의 발송상태 변경값 조회
-     * @param t
+     * - tb_ens_sndng_mastr, tb_ens_unity_sndng_mastr
+     * @param t T
      * @return EnsDTO.SndngMssageParam
+     *
*/ Optional selectSndProcessStatus(final T t); + /** + * 
      * 카카오페이 문서요청 결과 반영
+     * - tb_ens_kakao_my_doc
      * @param t 문서ID, 에러코드, 에러메세지, 외부문서ID
      * @return int
+     *
*/ int updateKakaoSendBulksResult(final T t); /** + * 
      * 발송마스터 상태 변경
+     * - tb_ens_sndng_mastr
      * @param t status, newStatus
      * @return int
+     *
*/ int updateProcessSttusSndngMst(final T t); //---------------------------------------------------------------------- @@ -222,9 +274,12 @@ public interface IEnsBatchMapper { //---------------------------------------------------------------------- /** + * 
      * 발송마스터 상태 다건 변경
+     * - tb_ens_sndng_mastr
      * @param t status, newStatus
      * @return int
+     *
*/ int updateProcessSttusBulkSndngMst(final T t); //---------------------------------------------------------------------- @@ -236,18 +291,23 @@ public interface IEnsBatchMapper { //---------------------------------------------------------------------- /** + * 
      * 카카오 문서 상태 조회 대상 목록 조회
+     * - tb_ens_sndng_mastr, tb_ens_kakao_my_doc
      * @param sndngPprocessSttus
      * @return List
+     *
*/ List selectKakaoStatusTgts(final String sndngPprocessSttus); /** + * 
      * 카카오 문서 상태 조회 결과 반영
+     * - tb_ens_kakao_my_doc
      * @param dto EnsDTO.KakaoMyDoc
      * @return int
+     *
*/ - //int updateKakaoStatusInfo(final EnsDTO.KakaoMyDoc dto); int updateKakaoStatusInfo(final BulkStatus dto); //---------------------------------------------------------------------- // status @@ -261,16 +321,41 @@ public interface IEnsBatchMapper { /** * 
      * 연계발송결과 반영
+     * - tb_cntc_sndng_result, tb_ens_unity_sndng_detail
      * @param dto 발송구분코드, 발송결과 상태, 송신(요청)/수신(조회)/최초열람 일시, 에러내용
      * @return int
      *
*/ int insertCntcSndngResult(final CntcDTO.SndngResult dto); - int updateCntcSndngResult(final CntcDTO.SndngResult dto); + + /** + * 연계발송결과반영 - 카카오 + * - tb_cntc_sndng_result, tb_ens_kakao_my_doc + * @param dto + * @return + */ + int updateCntcSndngResultByKkoMyDoc(final CntcDTO.SndngResult dto); //---------------------------------------------------------------------- // result //---------------------------------------------------------------------- + /** + * 
+     * 템플릿 정보 조회
+     * - tb_ens_tmplat_manage
+     * @param tmplatId String
+     * @return Optional
+     *
+ */ Optional selectTmplat(final String tmplatId); - EnsDTO.MobilePageManage selectMobilePage(final OneTimeToken dto); + + /** + * 
+     * 카카오 모바일페이지콘텐트조회
+     * - tb_ens_kakao_my_doc, tb_ens_mobile_page_manage
+     * @param dto OneTimeToken
+     * @return EnsDTO.MobilePageManage
+     *
+ */ + EnsDTO.MobilePageManage selectKkoMobilePage(final OneTimeToken dto); } diff --git a/mens-batch/src/main/java/kr/xit/biz/ens/service/EnsBatchService.java b/mens-batch/src/main/java/kr/xit/biz/ens/service/EnsBatchService.java index d49b2f1..6ab18e3 100644 --- a/mens-batch/src/main/java/kr/xit/biz/ens/service/EnsBatchService.java +++ b/mens-batch/src/main/java/kr/xit/biz/ens/service/EnsBatchService.java @@ -363,7 +363,7 @@ public class EnsBatchService extends EgovAbstractServiceImpl implements IEnsBatc resList.forEach(o -> o.getDocuments().forEach(t -> { mapper.updateKakaoStatusInfo(t); - mapper.updateCntcSndngResult(CntcDTO.SndngResult.builder() + mapper.updateCntcSndngResultByKkoMyDoc(CntcDTO.SndngResult.builder() .documentBinderUuid(t.getDocument_binder_uuid()) .sndngResultSttus(StringUtils.defaultString(String.valueOf(t.getStatus_data().getDoc_box_status()), "FAIL")) .requstDt(Checks.isEmpty(t.getStatus_data().getDoc_box_sent_at())? null: t.getStatus_data().getDoc_box_sent_at().toString()) 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 ae48f81..d0c9790 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 @@ -401,7 +401,7 @@ SELECT unity_sndng_mastr_id FROM tb_cntc_sndng_mastr WHERE sndng_process_sttus IN ('send-ok', 'sending1', 'sending2') - AND clos_dt date_format(adddate(now(), -1), '%Y%m%d%H%i%S') + AND clos_dt < date_format(adddate(now(), -1), '%Y%m%d%H%i%S') @@ -619,8 +619,8 @@ , updt_dt = now() , updusr = 'batch' WHERE unity_sndng_detail_id = (SELECT tekmd.unity_sndng_detail_id - FROM tb_ens_kakao_my_doc tekmd - WHERE tekmd.document_binder_uuid = #{document_binder_uuid}) + FROM tb_ens_kakao_my_doc tekmd + WHERE tekmd.document_binder_uuid = #{document_binder_uuid}) @@ -635,32 +635,32 @@ INSERT INTO tb_cntc_sndng_result ( unity_sndng_detail_id, /* 통합 발송 상세 ID*/ - sndng_se_code, /* 발송구분코드 */ - signgu_code, /* 시군구코드 */ - ffnlg_code, /* 과태료코드 */ + sndng_se_code, /* 발송구분코드 */ + signgu_code, /* 시군구코드 */ + ffnlg_code, /* 과태료코드 */ sndng_result_sttus, - requst_dt, /* 송신(요청) 일시 */ - inqire_dt, /* 수신(조회) 일시 */ - readng_dt, /* 최초열람일시 */ - error_cn, /* 에러내용 */ + requst_dt, /* 송신(요청) 일시 */ + inqire_dt, /* 수신(조회) 일시 */ + readng_dt, /* 최초열람일시 */ + error_cn, /* 에러내용 */ regist_dt, register - ) SELECT unity_sndng_detail_id /* 통합 발송 상세 ID*/ - , #{sndngSeCode} /* 발송구분코드 - KAKAO-MY-DOC */ - , signgu_code /* 시군구코드 */ - , ffnlg_code /* 과태료코드 */ + ) SELECT unity_sndng_detail_id/* 통합 발송 상세 ID*/ + , #{sndngSeCode} /* 발송구분코드 - KAKAO-MY-DOC */ + , signgu_code /* 시군구코드 */ + , ffnlg_code /* 과태료코드 */ , #{sndngResultSttus} , from_unixtime(#{requstDt}, '%Y%m%d%H%i%s') /* 송신(요청) 일시 */ , from_unixtime(#{inqireDt}, '%Y%m%d%H%i%s') /* 수신(조회) 일시 */ , from_unixtime(#{readngDt}, '%Y%m%d%H%i%s') /* 최초열람일시 */ - , #{errorCn} /* 에러내용 */ + , #{errorCn} /* 에러내용 */ , now() , 'batch' - FROM tb_ens_unity_sndng_detail + FROM tb_ens_unity_sndng_detail WHERE unity_sndng_detail_id = #{unitySndngDetailId} - + /** ens-mysql-mapper|updateCntcSndngResult-연계발송결과반영|julim */ UPDATE tb_cntc_sndng_result SET sndng_result_sttus = #{sndngResultSttus} @@ -678,7 +678,7 @@ - /** ens-mysql-mapper|selectMobilePage-모바일페이지콘텐트조회|julim */ SELECT tempm.sndng_detail_id , tempm.sndng_se_code