Commit @573a019b4b8bfde98d7aee64833819bf4b91ec09

JIWOO 2025-08-18

이지우 - 카카오 환불 오류 시 슬랙 알림 추가

@573a019b4b8bfde98d7aee64833819bf4b91ec09

91a2e68

573a019

src/main/java/itn/let/kakao/user/kakaoAt/web/KakaoAlimTalkSendController.java

--- src/main/java/itn/let/kakao/user/kakaoAt/web/KakaoAlimTalkSendController.java

+++ src/main/java/itn/let/kakao/user/kakaoAt/web/KakaoAlimTalkSendController.java


 	public void kakaoRefundSingleTransaction() throws Exception{
 		System.out.println("=============카카오 환불 싱글 트랜잭션 수행 =============");
 		
+		/* 회원 money 업데이트 처리 트랜잭션 분리를 위하여 impl이 아닌 현재 위치에서 반복문 실행 */
+		System.out.println("=============SchedulerUtil=====runKakaoOneTime =============>");
 		List<KakaoVO> kakaoRefundList = kakaoAlimTalkService.selectKakaoSentRefundListForSingle();
 		Set<String> targetIdSet = new HashSet<>();
 		
 		for(KakaoVO kakaoVO : kakaoRefundList) {
-			kakaoAlimTalkService.kakaoSingleRefund(kakaoVO);
-			targetIdSet.add(kakaoVO.getUserId());
+			try {
+				kakaoAlimTalkService.kakaoSingleRefund(kakaoVO);
+				targetIdSet.add(kakaoVO.getUserId());
+			} catch (Exception e) {
+				String msg = "[문자온] 환불 실패 - " + kakaoVO.getMsgId() +"("+ kakaoVO.getUserId() + ")";
+				mjonCommon.sendSimpleSlackMsg(msg);;
+			}
 		}
 		
 		MjonPayVO mjonPayVO = new MjonPayVO();
 		for(String userId : targetIdSet) {
+			try {
 			mjonPayVO.setUserId(userId);
 			mjonPayService.updateMemberCash(mjonPayVO); //회원정보 업데이트
+			} catch(Exception e) {
+				String msg = "[문자온] 환불 후 잔액 갱신 실패 - " + userId;
+				mjonCommon.sendSimpleSlackMsg(msg);;
+			}
 		}
 		
 	}

91a2e68

573a019

src/main/java/itn/let/schdlr/service/SchedulerUtil.java

--- src/main/java/itn/let/schdlr/service/SchedulerUtil.java

+++ src/main/java/itn/let/schdlr/service/SchedulerUtil.java


 package itn.let.schdlr.service;
 
 import java.text.SimpleDateFormat;
-import java.util.ArrayList;
 import java.util.Date;
 import java.util.HashSet;
 import java.util.List;

 import javax.annotation.Resource;
 import javax.sql.DataSource;
 
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Profile;

 import itn.let.kakao.user.kakaoAt.service.KakaoAlimTalkService;
 import itn.let.lett.service.LetterService;
 import itn.let.mail.service.MailTemplateService;
+import itn.let.mjo.mjocommon.MjonCommon;
 import itn.let.mjo.msg.service.MjonMsgService;
 import itn.let.mjo.msg.service.MjonMsgStatVO;
 import itn.let.mjo.msgdata.service.impl.MjonMsgDataDAO;
+import itn.let.mjo.pay.service.MjonPayService;
 import itn.let.mjo.pay.service.MjonPayVO;
-import itn.let.mjo.pay.service.impl.MjonPayDAO;
 import itn.let.sts.com.StatsVO;
 import itn.let.sts.cst.service.EgovConectStatsService;
 import itn.let.uss.umt.service.EgovUserManageService;

 	@Resource(name="kakaoAlimTalkService")
 	private KakaoAlimTalkService kakaoAlimTalkService;
 	
-	@Autowired
-	private MjonPayDAO mjonPayDAO;
+	@Resource(name="MjonCommon")
+	private MjonCommon mjonCommon;
+
+	@Resource(name = "mjonPayService")
+    private MjonPayService mjonPayService;
 	
     /** 설정값 가져오기 */
 	@Value("#{globalSettings['Globals.Env']}")

 			Set<String> targetIdSet = new HashSet<>();
 			
 			for(KakaoVO kakaoVO : kakaoRefundList) {
-				kakaoAlimTalkService.kakaoSingleRefund(kakaoVO);
-				targetIdSet.add(kakaoVO.getUserId());
+				try {
+					kakaoAlimTalkService.kakaoSingleRefund(kakaoVO);
+					targetIdSet.add(kakaoVO.getUserId());
+				} catch (Exception e) {
+					String msg = "[문자온] 환불 실패 - " + kakaoVO.getMsgId() +"("+ kakaoVO.getUserId() + ")";
+					mjonCommon.sendSimpleSlackMsg(msg);;
+				}
 			}
 			
 			MjonPayVO mjonPayVO = new MjonPayVO();
 			for(String userId : targetIdSet) {
+				try {
 				mjonPayVO.setUserId(userId);
-				mjonPayDAO.updateMemberCash(mjonPayVO); //회원정보 업데이트
+				mjonPayService.updateMemberCash(mjonPayVO); //회원정보 업데이트
+				} catch(Exception e) {
+					String msg = "[문자온] 환불 후 잔액 갱신 실패 - " + userId;
+					mjonCommon.sendSimpleSlackMsg(msg);;
+				}
 			}
 			
 	}

91a2e68

573a019

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

+++ src/main/resources/egovframework/sqlmap/let/mjo/kakao/Kakao_AT_SQL_Mysql.xml


 		SELECT
 			MMD.USER_ID									AS userId
 			, MMD.MSG_GROUP_ID							AS msgGroupId
+			, MMD.MSG_ID								AS msgId
 			, MMD.MSG_SEQ								AS msgSeq
 			, MMGD.BIZ_KAKAO_IMAGE_TYPE 				AS bizKakaoImageType
 			, MMGD.EACH_PRICE			 				AS eachPrice

Add a comment

Open 0
Closed 0

List

...	...	@@ -1557,18 +1557,30 @@
1557	1557	public void kakaoRefundSingleTransaction() throws Exception{
1558	1558	System.out.println("=============카카오 환불 싱글 트랜잭션 수행 =============");
1559	1559
	1560	+ /* 회원 money 업데이트 처리 트랜잭션 분리를 위하여 impl이 아닌 현재 위치에서 반복문 실행 */
	1561	+ System.out.println("=============SchedulerUtil=====runKakaoOneTime =============>");
1560	1562	List<KakaoVO> kakaoRefundList = kakaoAlimTalkService.selectKakaoSentRefundListForSingle();
1561	1563	Set<String> targetIdSet = new HashSet<>();
1562	1564
1563	1565	for(KakaoVO kakaoVO : kakaoRefundList) {
1564		- kakaoAlimTalkService.kakaoSingleRefund(kakaoVO);
1565		- targetIdSet.add(kakaoVO.getUserId());
	1566	+ try {
	1567	+ kakaoAlimTalkService.kakaoSingleRefund(kakaoVO);
	1568	+ targetIdSet.add(kakaoVO.getUserId());
	1569	+ } catch (Exception e) {
	1570	+ String msg = "[문자온] 환불 실패 - " + kakaoVO.getMsgId() +"("+ kakaoVO.getUserId() + ")";
	1571	+ mjonCommon.sendSimpleSlackMsg(msg);;
	1572	+ }
1566	1573	}
1567	1574
1568	1575	MjonPayVO mjonPayVO = new MjonPayVO();
1569	1576	for(String userId : targetIdSet) {
	1577	+ try {
1570	1578	mjonPayVO.setUserId(userId);
1571	1579	mjonPayService.updateMemberCash(mjonPayVO); //회원정보 업데이트
	1580	+ } catch(Exception e) {
	1581	+ String msg = "[문자온] 환불 후 잔액 갱신 실패 - " + userId;
	1582	+ mjonCommon.sendSimpleSlackMsg(msg);;
	1583	+ }
1572	1584	}
1573	1585
1574	1586	}

...	...	@@ -1,7 +1,6 @@
1	1	package itn.let.schdlr.service;
2	2
3	3	import java.text.SimpleDateFormat;
4		-import java.util.ArrayList;
5	4	import java.util.Date;
6	5	import java.util.HashSet;
7	6	import java.util.List;
...	...	@@ -10,7 +9,6 @@
10	9	import javax.annotation.Resource;
11	10	import javax.sql.DataSource;
12	11
13		-import org.springframework.beans.factory.annotation.Autowired;
14	12	import org.springframework.beans.factory.annotation.Value;
15	13	import org.springframework.context.annotation.Bean;
16	14	import org.springframework.context.annotation.Profile;
...	...	@@ -32,11 +30,12 @@
32	30	import itn.let.kakao.user.kakaoAt.service.KakaoAlimTalkService;
33	31	import itn.let.lett.service.LetterService;
34	32	import itn.let.mail.service.MailTemplateService;
	33	+import itn.let.mjo.mjocommon.MjonCommon;
35	34	import itn.let.mjo.msg.service.MjonMsgService;
36	35	import itn.let.mjo.msg.service.MjonMsgStatVO;
37	36	import itn.let.mjo.msgdata.service.impl.MjonMsgDataDAO;
	37	+import itn.let.mjo.pay.service.MjonPayService;
38	38	import itn.let.mjo.pay.service.MjonPayVO;
39		-import itn.let.mjo.pay.service.impl.MjonPayDAO;
40	39	import itn.let.sts.com.StatsVO;
41	40	import itn.let.sts.cst.service.EgovConectStatsService;
42	41	import itn.let.uss.umt.service.EgovUserManageService;
...	...	@@ -92,8 +91,11 @@
92	91	@Resource(name="kakaoAlimTalkService")
93	92	private KakaoAlimTalkService kakaoAlimTalkService;
94	93
95		- @Autowired
96		- private MjonPayDAO mjonPayDAO;
	94	+ @Resource(name="MjonCommon")
	95	+ private MjonCommon mjonCommon;
	96	+
	97	+ @Resource(name = "mjonPayService")
	98	+ private MjonPayService mjonPayService;
97	99
98	100	/** 설정값 가져오기 */
99	101	@Value("#{globalSettings['Globals.Env']}")
...	...	@@ -489,14 +491,24 @@
489	491	Set<String> targetIdSet = new HashSet<>();
490	492
491	493	for(KakaoVO kakaoVO : kakaoRefundList) {
492		- kakaoAlimTalkService.kakaoSingleRefund(kakaoVO);
493		- targetIdSet.add(kakaoVO.getUserId());
	494	+ try {
	495	+ kakaoAlimTalkService.kakaoSingleRefund(kakaoVO);
	496	+ targetIdSet.add(kakaoVO.getUserId());
	497	+ } catch (Exception e) {
	498	+ String msg = "[문자온] 환불 실패 - " + kakaoVO.getMsgId() +"("+ kakaoVO.getUserId() + ")";
	499	+ mjonCommon.sendSimpleSlackMsg(msg);;
	500	+ }
494	501	}
495	502
496	503	MjonPayVO mjonPayVO = new MjonPayVO();
497	504	for(String userId : targetIdSet) {
	505	+ try {
498	506	mjonPayVO.setUserId(userId);
499		- mjonPayDAO.updateMemberCash(mjonPayVO); //회원정보 업데이트
	507	+ mjonPayService.updateMemberCash(mjonPayVO); //회원정보 업데이트
	508	+ } catch(Exception e) {
	509	+ String msg = "[문자온] 환불 후 잔액 갱신 실패 - " + userId;
	510	+ mjonCommon.sendSimpleSlackMsg(msg);;
	511	+ }
500	512	}
501	513
502	514	}

...	...	@@ -209,6 +209,7 @@
209	209	SELECT
210	210	MMD.USER_ID AS userId
211	211	, MMD.MSG_GROUP_ID AS msgGroupId
	212	+ , MMD.MSG_ID AS msgId
212	213	, MMD.MSG_SEQ AS msgSeq
213	214	, MMGD.BIZ_KAKAO_IMAGE_TYPE AS bizKakaoImageType
214	215	, MMGD.EACH_PRICE AS eachPrice

Delete comment