JIWOO
2025-08-14
이지우 - 환불 스케줄러 소스 정리 및 스케줄러 임시 차단
@80b97b167a83c1223a7a0ee419a025bcc4710f40
--- src/main/java/itn/let/kakao/user/kakaoAt/service/KakaoAlimTalkService.java
+++ src/main/java/itn/let/kakao/user/kakaoAt/service/KakaoAlimTalkService.java
... | ... | @@ -23,16 +23,7 @@ |
| 23 | 23 |
//카카오 친구톡 발신 |
| 24 | 24 |
public MjonMsgReturnVO insertKakaoFtSendAjax(KakaoVO kakaoVO) throws Exception; |
| 25 | 25 |
|
| 26 |
- //카카오 알림톡 전송 실패 환불리스트 조회 |
|
| 27 |
- public void selectKakaoAtSentRefundList() throws Exception; |
|
| 28 |
- |
|
| 29 |
- //카카오 친구톡 전송 실패 환불리스트 조회 |
|
| 30 |
- public void selectKakaoFtSentRefundList() throws Exception; |
|
| 31 |
- |
|
| 32 | 26 |
StatusResponse insertKakaoAtSandAjax_advc(KakaoVO kakaoVO, HttpServletRequest request) throws Exception; |
| 33 |
- |
|
| 34 |
- //카카오(알림톡, 친구톡 통합) 전송 실패 환불리스트 조회 |
|
| 35 |
- public void selectKakaoSentRefundList() throws Exception; |
|
| 36 | 27 |
|
| 37 | 28 |
//카카오(알림톡, 친구톡 통합) 전송 실패 환불리스트 조회 |
| 38 | 29 |
public List<KakaoVO> selectKakaoSentRefundListForSingle() throws Exception; |
--- src/main/java/itn/let/kakao/user/kakaoAt/service/impl/KakaoAlimTalkDAO.java
+++ src/main/java/itn/let/kakao/user/kakaoAt/service/impl/KakaoAlimTalkDAO.java
... | ... | @@ -49,16 +49,6 @@ |
| 49 | 49 |
} |
| 50 | 50 |
|
| 51 | 51 |
@SuppressWarnings("unchecked")
|
| 52 |
- public List<KakaoVO> selectKakaoAtSentRefundList() throws Exception{
|
|
| 53 |
- return (List<KakaoVO>) list("kakaoAlimTalkDAO.selectKakaoAtSentRefundList");
|
|
| 54 |
- } |
|
| 55 |
- |
|
| 56 |
- @SuppressWarnings("unchecked")
|
|
| 57 |
- public List<KakaoVO> selectKakaoFtSentRefundList() throws Exception{
|
|
| 58 |
- return (List<KakaoVO>) list("kakaoAlimTalkDAO.selectKakaoFtSentRefundList");
|
|
| 59 |
- } |
|
| 60 |
- |
|
| 61 |
- @SuppressWarnings("unchecked")
|
|
| 62 | 52 |
public List<KakaoVO> selectKakaoSentRefundList() throws Exception{
|
| 63 | 53 |
return (List<KakaoVO>) list("kakaoAlimTalkDAO.selectKakaoSentRefundList");
|
| 64 | 54 |
} |
--- src/main/java/itn/let/kakao/user/kakaoAt/service/impl/KakaoAlimTalkServiceImpl.java
+++ src/main/java/itn/let/kakao/user/kakaoAt/service/impl/KakaoAlimTalkServiceImpl.java
... | ... | @@ -792,94 +792,6 @@ |
| 792 | 792 |
return returnVO; |
| 793 | 793 |
} |
| 794 | 794 |
|
| 795 |
- |
|
| 796 |
- /* |
|
| 797 |
- * 카카오 알림톡 발송 실패에 따른 금액 환불 처리 |
|
| 798 |
- * |
|
| 799 |
- * */ |
|
| 800 |
- @Override |
|
| 801 |
- public void selectKakaoAtSentRefundList() throws Exception {
|
|
| 802 |
- |
|
| 803 |
- /** |
|
| 804 |
- * 1. 카카오 AT 전송성공 확인 |
|
| 805 |
- * 2. 카카오 AT 전송실패, 대채문자 전송확인 |
|
| 806 |
- * 3. 카카오 AT 전송 실패 확인 |
|
| 807 |
- */ |
|
| 808 |
- List<KakaoVO> kakaoAtSentRefundList = kakaoAlimTalkDAO.selectKakaoAtSentRefundList(); |
|
| 809 |
- |
|
| 810 |
- for(KakaoVO kakaoVO : kakaoAtSentRefundList) {
|
|
| 811 |
- |
|
| 812 |
- if(KAKAO_SUCCESS_CODE.equals(kakaoVO.getRsltCode())) {//알림톡 발송 성공시
|
|
| 813 |
- |
|
| 814 |
- processKakaoSendCharge(kakaoVO); |
|
| 815 |
- |
|
| 816 |
- }else if(RESEND_YN_YES.equals(kakaoVO.getSubMsgSendYn())) {
|
|
| 817 |
- //알림톡 발송 실패 했고 , 대체문자 발송 했을 경우 |
|
| 818 |
- handleAlternativeMessageScenario(kakaoVO); |
|
| 819 |
- }else {
|
|
| 820 |
- handleRefund(kakaoVO, "카카오 알림톡 전송 실패로 인한 결제 금액 환불"); |
|
| 821 |
- } |
|
| 822 |
- |
|
| 823 |
- } |
|
| 824 |
- } |
|
| 825 |
- |
|
| 826 |
- |
|
| 827 |
- /** |
|
| 828 |
- * @ 카카오 친구톡 환불 |
|
| 829 |
- */ |
|
| 830 |
- @Override |
|
| 831 |
- public void selectKakaoFtSentRefundList() throws Exception {
|
|
| 832 |
- |
|
| 833 |
- List<KakaoVO> kakaoFtSentRefundList = kakaoAlimTalkDAO.selectKakaoFtSentRefundList(); |
|
| 834 |
- |
|
| 835 |
- for(KakaoVO kakaoVO : kakaoFtSentRefundList) {
|
|
| 836 |
- System.out.println(kakaoVO.getMsgGroupId() +"________결과 : " +kakaoVO.getRsltCode() +" 대체문자 전송 : "+kakaoVO.getSubMsgSendYn()); |
|
| 837 |
- |
|
| 838 |
- if(KAKAO_SUCCESS_CODE.equals(kakaoVO.getRsltCode())) {//친구톡 발송 성공시
|
|
| 839 |
- |
|
| 840 |
- processKakaoSendCharge(kakaoVO); |
|
| 841 |
- |
|
| 842 |
- }else if(RESEND_YN_YES.equals(kakaoVO.getSubMsgSendYn())) {
|
|
| 843 |
- //친구톡 발송 실패 했고, 대체문자 발송 했을 경우 |
|
| 844 |
- handleAlternativeMessageScenario(kakaoVO); |
|
| 845 |
- |
|
| 846 |
- }else {
|
|
| 847 |
- handleRefund(kakaoVO, "카카오 친구톡 전송 실패로 인한 결제 금액 환불"); |
|
| 848 |
- } |
|
| 849 |
- } |
|
| 850 |
- } |
|
| 851 |
- |
|
| 852 |
- /** |
|
| 853 |
- * @ 카카오 알림톡, 친구톡 통합 환불 |
|
| 854 |
- */ |
|
| 855 |
- @Override |
|
| 856 |
- public void selectKakaoSentRefundList() throws Exception {
|
|
| 857 |
- |
|
| 858 |
- List<KakaoVO> kakaoFtSentRefundList = kakaoAlimTalkDAO.selectKakaoSentRefundList(); |
|
| 859 |
- |
|
| 860 |
- for(KakaoVO kakaoVO : kakaoFtSentRefundList) {
|
|
| 861 |
- System.out.println(kakaoVO.getMsgGroupId() +"________결과 : " +kakaoVO.getRsltCode() +" 대체문자 전송 : "+kakaoVO.getSubMsgSendYn()); |
|
| 862 |
- kakaoVO.setMsgTypeTxt(AT_MSG_TYPE.equals(kakaoVO.getMsgType()) ? "알림톡" : "친구톡"); |
|
| 863 |
- |
|
| 864 |
- if(KAKAO_SUCCESS_CODE.equals(kakaoVO.getRsltCode())) {
|
|
| 865 |
- //1.카카오톡 발송 성공 |
|
| 866 |
- processKakaoSendCharge(kakaoVO); |
|
| 867 |
- |
|
| 868 |
- }else if(RESEND_YN_YES.equals(kakaoVO.getSubMsgSendYn())) {//카카오톡 발송 실패, 대체문자 발송 신청 O
|
|
| 869 |
- //2.카카오톡 발송 실패 + 대체문자 신청 O |
|
| 870 |
- handleAlternativeMessageScenario(kakaoVO); |
|
| 871 |
- |
|
| 872 |
- }else {
|
|
| 873 |
- //3.카카오톡 발송 실패 + 대체문자 신청 X : 전액 환불 |
|
| 874 |
- handleRefund(kakaoVO, "카카오 " + kakaoVO.getMsgTypeTxt() + " 전송 실패로 인한 결제 금액 환불"); |
|
| 875 |
- } |
|
| 876 |
- |
|
| 877 |
- //모든 유형 환불 완료 처리 |
|
| 878 |
- mjonMsgDAO.updateRefundY(kakaoVO); |
|
| 879 |
- } |
|
| 880 |
- } |
|
| 881 |
- |
|
| 882 |
- |
|
| 883 | 795 |
private void processKakaoSendCharge(KakaoVO kakaoVO) throws Exception {
|
| 884 | 796 |
|
| 885 | 797 |
//1-1.카카오톡 발송 성공 + 대체문자 신청 O : 대체문자 금액 환불 |
--- src/main/java/itn/let/schdlr/service/SchdlrManageService.java
+++ src/main/java/itn/let/schdlr/service/SchdlrManageService.java
... | ... | @@ -47,9 +47,6 @@ |
| 47 | 47 |
//전용계좌 자동 충전 배치 |
| 48 | 48 |
public void vacsAutoCharge() throws Exception; |
| 49 | 49 |
|
| 50 |
- //문자온 카카오톡 실패 건수 환불 배치 |
|
| 51 |
- public void kakaoFailPayBack() throws Exception; |
|
| 52 |
- |
|
| 53 | 50 |
//문자온 문자전송 실패 건수 환불 배치 |
| 54 | 51 |
public void payBack(String type, int limitCout) throws Exception; |
| 55 | 52 |
|
--- src/main/java/itn/let/schdlr/service/SchedulerUtil.java
+++ src/main/java/itn/let/schdlr/service/SchedulerUtil.java
... | ... | @@ -479,10 +479,11 @@ |
| 479 | 479 |
return new JdbcTemplateLockProvider(dataSource); |
| 480 | 480 |
} |
| 481 | 481 |
|
| 482 |
- @Scheduled(cron = "0 0/3 * * * ?") // 3분마다 실행 |
|
| 483 |
- @SchedulerLock(name = "runKakaoOneTime", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) |
|
| 482 |
+ //@Scheduled(cron = "0 0/3 * * * ?") // 3분마다 실행 |
|
| 483 |
+ //@SchedulerLock(name = "runKakaoOneTime", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) |
|
| 484 | 484 |
public void runKakaoOneTime() throws Exception {
|
| 485 | 485 |
|
| 486 |
+ /* 회원 money 업데이트 처리 트랜잭션 분리를 위하여 impl이 아닌 현재 위치에서 반복문 실행 */ |
|
| 486 | 487 |
System.out.println("=============SchedulerUtil=====runKakaoOneTime =============>");
|
| 487 | 488 |
List<KakaoVO> kakaoRefundList = kakaoAlimTalkService.selectKakaoSentRefundListForSingle(); |
| 488 | 489 |
Set<String> targetIdSet = new HashSet<>(); |
--- src/main/java/itn/let/schdlr/service/impl/SchdlrManageServiceImpl.java
+++ src/main/java/itn/let/schdlr/service/impl/SchdlrManageServiceImpl.java
... | ... | @@ -437,20 +437,6 @@ |
| 437 | 437 |
|
| 438 | 438 |
} |
| 439 | 439 |
|
| 440 |
- // 카카오 환불 처리 리스트 |
|
| 441 |
- public void kakaoFailPayBack() throws Exception {
|
|
| 442 |
- |
|
| 443 |
- // 카카오 알림톡 환불 처리 |
|
| 444 |
- //kakaoAlimTalkService.selectKakaoAtSentRefundList(); |
|
| 445 |
- |
|
| 446 |
- // 카카오 친구톡 환불 처리 |
|
| 447 |
- //kakaoAlimTalkService.selectKakaoFtSentRefundList(); |
|
| 448 |
- |
|
| 449 |
- // 카카오 알림톡, 친구톡 통합 환불 처리 |
|
| 450 |
- kakaoAlimTalkService.selectKakaoSentRefundList(); |
|
| 451 |
- |
|
| 452 |
- } |
|
| 453 |
- |
|
| 454 | 440 |
@Override |
| 455 | 441 |
public void payBack(String type, int limitCout) throws Exception {
|
| 456 | 442 |
// 문자 환불 |
--- src/main/resources/egovframework/sqlmap/let/mjo/kakao/Kakao_AT_SQL_Mysql.xml
+++ src/main/resources/egovframework/sqlmap/let/mjo/kakao/Kakao_AT_SQL_Mysql.xml
... | ... | @@ -238,70 +238,6 @@ |
| 238 | 238 |
ORDER BY MMD.USER_ID ASC |
| 239 | 239 |
</select> |
| 240 | 240 |
|
| 241 |
- <select id="kakaoAlimTalkDAO.selectKakaoAtSentRefundList" resultClass="kakaoVO"> |
|
| 242 |
- SELECT |
|
| 243 |
- MMD.USER_ID AS userId |
|
| 244 |
- , MMD.MSG_GROUP_ID AS msgGroupId |
|
| 245 |
- , MMD.MSG_SEQ AS msgSeq |
|
| 246 |
- , MMGD.BIZ_KAKAO_IMAGE_TYPE AS bizKakaoImageType |
|
| 247 |
- , MMGD.EACH_PRICE AS eachPrice |
|
| 248 |
- , MMD.USERDATA AS userData |
|
| 249 |
- , MMD.REFUND_YN AS refundYn |
|
| 250 |
- , MMD.RSLT_CODE AS rsltCode |
|
| 251 |
- , MMD.RSLT_CODE2 AS rsltCode2 |
|
| 252 |
- , MMD.AGENT_CODE AS agentCode |
|
| 253 |
- , DATE_FORMAT(MMD.SENT_DATE,'%Y-%m-%d %T') AS sentDate |
|
| 254 |
- , DATE_FORMAT(MMD.RSLT_DATE,'%Y-%m-%d %T') AS rsltDate |
|
| 255 |
- , MMD.BIZ_KAKAO_RESEND_YN AS subMsgSendYn |
|
| 256 |
- , MMD.BIZ_KAKAO_RESEND_TYPE AS subMsgType |
|
| 257 |
- , MMD.FILE_CNT AS fileCnt |
|
| 258 |
- , MMD.BIZ_UMID AS bizUmid |
|
| 259 |
- , MMD.MSG_TYPE AS msgType |
|
| 260 |
- FROM |
|
| 261 |
- MJ_MSG_DATA MMD |
|
| 262 |
- INNER JOIN LETTNGNRLMBER MB |
|
| 263 |
- ON MMD.USER_ID = MB.MBER_ID |
|
| 264 |
- INNER JOIN mj_msg_group_data MMGD |
|
| 265 |
- on MMD.MSG_GROUP_ID = MMGD.MSG_GROUP_ID |
|
| 266 |
- WHERE 1=1 |
|
| 267 |
- AND MMD.CUR_STATE = '3' |
|
| 268 |
- AND MMD.REFUND_YN = 'N' |
|
| 269 |
- AND MMD.RESERVE_C_YN = 'N' |
|
| 270 |
- AND MMD.MSG_TYPE = 8 |
|
| 271 |
- </select> |
|
| 272 |
- |
|
| 273 |
- <select id="kakaoAlimTalkDAO.selectKakaoFtSentRefundList" resultClass="kakaoVO"> |
|
| 274 |
- SELECT |
|
| 275 |
- MMD.USER_ID AS userId |
|
| 276 |
- , MMD.MSG_GROUP_ID AS msgGroupId |
|
| 277 |
- , MMD.MSG_SEQ AS msgSeq |
|
| 278 |
- , MMGD.BIZ_KAKAO_IMAGE_TYPE AS bizKakaoImageType |
|
| 279 |
- , MMGD.EACH_PRICE AS eachPrice |
|
| 280 |
- , MMD.USERDATA AS userData |
|
| 281 |
- , MMD.REFUND_YN AS refundYn |
|
| 282 |
- , MMD.RSLT_CODE AS rsltCode |
|
| 283 |
- , MMD.RSLT_CODE2 AS rsltCode2 |
|
| 284 |
- , MMD.AGENT_CODE AS agentCode |
|
| 285 |
- , DATE_FORMAT(MMD.SENT_DATE,'%Y-%m-%d %T') AS sentDate |
|
| 286 |
- , DATE_FORMAT(MMD.RSLT_DATE,'%Y-%m-%d %T') AS rsltDate |
|
| 287 |
- , MMD.BIZ_KAKAO_RESEND_YN AS subMsgSendYn |
|
| 288 |
- , MMD.BIZ_KAKAO_RESEND_TYPE AS subMsgType |
|
| 289 |
- , MMD.FILE_CNT AS fileCnt |
|
| 290 |
- , MMD.BIZ_UMID AS bizUmid |
|
| 291 |
- , MMD.MSG_TYPE AS msgType |
|
| 292 |
- FROM |
|
| 293 |
- MJ_MSG_DATA MMD |
|
| 294 |
- INNER JOIN LETTNGNRLMBER MB |
|
| 295 |
- ON MMD.USER_ID = MB.MBER_ID |
|
| 296 |
- INNER JOIN mj_msg_group_data MMGD |
|
| 297 |
- on MMD.MSG_GROUP_ID = MMGD.MSG_GROUP_ID |
|
| 298 |
- WHERE 1=1 |
|
| 299 |
- AND MMD.CUR_STATE = '3' |
|
| 300 |
- AND MMD.REFUND_YN = 'N' |
|
| 301 |
- AND MMD.RESERVE_C_YN = 'N' |
|
| 302 |
- AND MMD.MSG_TYPE = 9 |
|
| 303 |
- </select> |
|
| 304 |
- |
|
| 305 | 241 |
<select id="kakaoAlimTalkDAO.selectKakaoAtUmid" resultClass="kakaoVO" parameterClass="kakaoVO"> |
| 306 | 242 |
SELECT |
| 307 | 243 |
BIZ_UMID AS bizUmid |
Add a comment
Delete comment
Once you delete this comment, you won't be able to recover it. Are you sure you want to delete this comment?