Commit @7c5b5889c3a73e421e3a8ea5a759c3faf1a0cf8e

이호영 2025-06-20

문자발송에 api return값 추가

@7c5b5889c3a73e421e3a8ea5a759c3faf1a0cf8e

141d814

7c5b588

src/main/java/itn/let/mail/service/StatusResponse.java

--- src/main/java/itn/let/mail/service/StatusResponse.java

+++ src/main/java/itn/let/mail/service/StatusResponse.java


 	
 	private  Object object;
 	
+	private  Object apiReturn;
+	
 	private  String messageTemp;
 
 	private LocalDateTime timestamp;

 		this.message = message;
 		this.object = object;
 	}
+	public StatusResponse(HttpStatus status, String message
+			, Object object
+			, Object apiReturn
+			) {
+		this.status = status;
+		this.message = message;
+		this.object = object;
+		this.apiReturn = apiReturn;
+	}
 	
  
 	

141d814

7c5b588

src/main/java/itn/let/mjo/msgdata/service/impl/MjonMsgDataServiceImpl.java

--- src/main/java/itn/let/mjo/msgdata/service/impl/MjonMsgDataServiceImpl.java

+++ src/main/java/itn/let/mjo/msgdata/service/impl/MjonMsgDataServiceImpl.java


 	@Override
 	public StatusResponse sendMsgData_advc(MjonMsgVO mjonMsgVO, HttpServletRequest request) throws Exception {
 
-		log.info("mjonMsgVO [{}]", mjonMsgVO.getMjonMsgSendVOList().get(0).getPhone());
+//		log.info("mjonMsgVO [{}]", mjonMsgVO.getMjonMsgSendVOList().get(0).getPhone());
 		log.info(" :: sendMsgData_advc :: ");
 		log.info(" + mjonMsgVO.toString() :: [{}]", mjonMsgVO.toString());
 		
 		Map<String, Object> returnMap = new HashMap<>();
+		Map<String, Object> apiReturnMap = new HashMap<>();
 
-		LoginVO loginVO = EgovUserDetailsHelper.isAuthenticated()
-				? (LoginVO) EgovUserDetailsHelper.getAuthenticatedUser()
-				: null;
-		String userId = loginVO == null ? "" : EgovStringUtil.isNullToString(loginVO.getId());
+		String userId = "";
+		if("A".equals(mjonMsgVO.getSendKind()))
+		{
+			userId = mjonMsgVO.getMberId();
+		}else {
+			
+			LoginVO loginVO = EgovUserDetailsHelper.isAuthenticated()
+					? (LoginVO) EgovUserDetailsHelper.getAuthenticatedUser()
+					: null;
+			userId = loginVO == null ? "" : EgovStringUtil.isNullToString(loginVO.getId());
 
-		if (userId.equals("")) {
-			return new StatusResponse(HttpStatus.BAD_REQUEST, "로그인 후 이용이 가능합니다.");
+			if (userId.equals("")) {
+				return new StatusResponse(HttpStatus.BAD_REQUEST, "로그인 후 이용이 가능합니다.");
+			}
+
 		}
-
-		mjonMsgVO.setUserId(userId);
+		
+		mjonMsgVO.setUserId(userId);	
 
 		// 발신번호가 등록된 유효한 번호인지 확인
 		int sendCallFromCnt = mjonMsgDAO.selectCallFromNumberChk(mjonMsgVO);

 		int deletedCount = initialSize - finalSize;
 		// 수신거부 목록
 		returnMap.put("resultBlockSts", deletedCount);
+		apiReturnMap.put("resultBlockSts", deletedCount);
 
 		if (mjonMsgSendVOList.size() < 1) {
 			return new StatusResponse(HttpStatus.BAD_REQUEST, "수신거부와 매칭되는 번호 제거 후 \n발송 가능한 수신목록이 존재하지 않습니다.");

 		// instTotalCnt : 화면에서 보여줄 총 발송건수
 		int instTotalCnt = 0;
 		// Step 2: 그룹화 된 데이터를 그룹별로 insert 처리
+		String apiMsgGroupId = "";
+		String apiMsgType = "";
 		for (Map.Entry<String, List<MjonMsgSendVO>> entry : priceGroupedMessages.entrySet()) {
 			List<MjonMsgSendVO> groupedMsgList = entry.getValue(); // 해당 가격의 메시지 리스트
 			
 			// msgGroupId 생성
 			String nextMsgGroupId = idgenMjonMsgGroupId.getNextStringId();
 			groupedMsgList.forEach(t -> t.setMsgGroupId(nextMsgGroupId));
-
+			
+			// api 전달 값
+			apiMsgGroupId = StringUtils.isNotEmpty(apiMsgGroupId)
+					? apiMsgGroupId + "," + nextMsgGroupId
+					: nextMsgGroupId;
+			
+			apiMsgType = StringUtils.isNotEmpty(apiMsgType)
+					? apiMsgType + "," + mjonMsgSendVOList.get(0).getMsgType()
+							: mjonMsgSendVOList.get(0).getMsgType();
+			
 			// 발송 데이터 삽입
 			int instCnt = this.insertMsgData_advc(groupedMsgList);
 

 //			returnMap.put("resultSts", instCnt);
 
 			log.debug("가격 [{}]의 총 갯수: [{}]", entry.getKey(), groupedMsgList.size());
+			
 
 		}
+		
 
+		// 그룹 ID
+		apiReturnMap.put("msgGroupId", apiMsgGroupId);
+		// 메세지 타입
+		apiReturnMap.put("msgType", apiMsgType);
+		// 총 발송 건수
+		returnMap.put("resultSts", instTotalCnt);
+		apiReturnMap.put("resultSts", instTotalCnt);
+		
+
+		// db insert 성능 개선중 하나에 방법
 		// 분할 최대건수가 되면 디비에 입력하기
 		// 여러시도 했지만 일단 보류
 		// 무시해도 됨
 //		int instCnt = mjonMsgDataDAO.insertMsgDataInfo_advc(mjonMsgSendVOList);
 //		int instCnt = mjonMsgDataDAO.insertMsgDataInfo_jdbc_advc(mjonMsgSendVOList);
 
-		// 총 발송 건수
-		returnMap.put("resultSts", instTotalCnt);
 		
 		// TEST발송 시 발송 후 캐시가 있어야함.
 		returnMap.put("afterCash", priceAndPoint.getBefCash(userId));

 
 		statusResponse.setStatus(HttpStatus.OK);
 		statusResponse.setObject(returnMap);
+		
+		apiReturnMap.put("result", "success");
+		apiReturnMap.put("message", "문자 전송이 완료되었습니다.");
+		statusResponse.setApiReturn(apiReturnMap);
 		return statusResponse;
 
 	}

Add a comment

Open 0
Closed 0

List

...	...	@@ -57,6 +57,8 @@
57	57
58	58	private Object object;
59	59
	60	+ private Object apiReturn;
	61	+
60	62	private String messageTemp;
61	63
62	64	private LocalDateTime timestamp;
...	...	@@ -97,6 +99,15 @@
97	99	this.message = message;
98	100	this.object = object;
99	101	}
	102	+ public StatusResponse(HttpStatus status, String message
	103	+ , Object object
	104	+ , Object apiReturn
	105	+ ) {
	106	+ this.status = status;
	107	+ this.message = message;
	108	+ this.object = object;
	109	+ this.apiReturn = apiReturn;
	110	+ }
100	111
101	112
102	113

...	...	@@ -3946,22 +3946,31 @@
3946	3946	@Override
3947	3947	public StatusResponse sendMsgData_advc(MjonMsgVO mjonMsgVO, HttpServletRequest request) throws Exception {
3948	3948
3949		- log.info("mjonMsgVO [{}]", mjonMsgVO.getMjonMsgSendVOList().get(0).getPhone());
	3949	+// log.info("mjonMsgVO [{}]", mjonMsgVO.getMjonMsgSendVOList().get(0).getPhone());
3950	3950	log.info(" :: sendMsgData_advc :: ");
3951	3951	log.info(" + mjonMsgVO.toString() :: [{}]", mjonMsgVO.toString());
3952	3952
3953	3953	Map<String, Object> returnMap = new HashMap<>();
	3954	+ Map<String, Object> apiReturnMap = new HashMap<>();
3954	3955
3955		- LoginVO loginVO = EgovUserDetailsHelper.isAuthenticated()
3956		- ? (LoginVO) EgovUserDetailsHelper.getAuthenticatedUser()
3957		- : null;
3958		- String userId = loginVO == null ? "" : EgovStringUtil.isNullToString(loginVO.getId());
	3956	+ String userId = "";
	3957	+ if("A".equals(mjonMsgVO.getSendKind()))
	3958	+ {
	3959	+ userId = mjonMsgVO.getMberId();
	3960	+ }else {
	3961	+
	3962	+ LoginVO loginVO = EgovUserDetailsHelper.isAuthenticated()
	3963	+ ? (LoginVO) EgovUserDetailsHelper.getAuthenticatedUser()
	3964	+ : null;
	3965	+ userId = loginVO == null ? "" : EgovStringUtil.isNullToString(loginVO.getId());
3959	3966
3960		- if (userId.equals("")) {
3961		- return new StatusResponse(HttpStatus.BAD_REQUEST, "로그인 후 이용이 가능합니다.");
	3967	+ if (userId.equals("")) {
	3968	+ return new StatusResponse(HttpStatus.BAD_REQUEST, "로그인 후 이용이 가능합니다.");
	3969	+ }
	3970	+
3962	3971	}
3963		-
3964		- mjonMsgVO.setUserId(userId);
	3972	+
	3973	+ mjonMsgVO.setUserId(userId);
3965	3974
3966	3975	// 발신번호가 등록된 유효한 번호인지 확인
3967	3976	int sendCallFromCnt = mjonMsgDAO.selectCallFromNumberChk(mjonMsgVO);
...	...	@@ -4015,6 +4024,7 @@
4015	4024	int deletedCount = initialSize - finalSize;
4016	4025	// 수신거부 목록
4017	4026	returnMap.put("resultBlockSts", deletedCount);
	4027	+ apiReturnMap.put("resultBlockSts", deletedCount);
4018	4028
4019	4029	if (mjonMsgSendVOList.size() < 1) {
4020	4030	return new StatusResponse(HttpStatus.BAD_REQUEST, "수신거부와 매칭되는 번호 제거 후 \n발송 가능한 수신목록이 존재하지 않습니다.");
...	...	@@ -4139,13 +4149,24 @@
4139	4149	// instTotalCnt : 화면에서 보여줄 총 발송건수
4140	4150	int instTotalCnt = 0;
4141	4151	// Step 2: 그룹화 된 데이터를 그룹별로 insert 처리
	4152	+ String apiMsgGroupId = "";
	4153	+ String apiMsgType = "";
4142	4154	for (Map.Entry<String, List<MjonMsgSendVO>> entry : priceGroupedMessages.entrySet()) {
4143	4155	List<MjonMsgSendVO> groupedMsgList = entry.getValue(); // 해당 가격의 메시지 리스트
4144	4156
4145	4157	// msgGroupId 생성
4146	4158	String nextMsgGroupId = idgenMjonMsgGroupId.getNextStringId();
4147	4159	groupedMsgList.forEach(t -> t.setMsgGroupId(nextMsgGroupId));
4148		-
	4160	+
	4161	+ // api 전달 값
	4162	+ apiMsgGroupId = StringUtils.isNotEmpty(apiMsgGroupId)
	4163	+ ? apiMsgGroupId + "," + nextMsgGroupId
	4164	+ : nextMsgGroupId;
	4165	+
	4166	+ apiMsgType = StringUtils.isNotEmpty(apiMsgType)
	4167	+ ? apiMsgType + "," + mjonMsgSendVOList.get(0).getMsgType()
	4168	+ : mjonMsgSendVOList.get(0).getMsgType();
	4169	+
4149	4170	// 발송 데이터 삽입
4150	4171	int instCnt = this.insertMsgData_advc(groupedMsgList);
4151	4172
...	...	@@ -4176,17 +4197,27 @@
4176	4197	// returnMap.put("resultSts", instCnt);
4177	4198
4178	4199	log.debug("가격 [{}]의 총 갯수: [{}]", entry.getKey(), groupedMsgList.size());
	4200	+
4179	4201
4180	4202	}
	4203	+
4181	4204
	4205	+ // 그룹 ID
	4206	+ apiReturnMap.put("msgGroupId", apiMsgGroupId);
	4207	+ // 메세지 타입
	4208	+ apiReturnMap.put("msgType", apiMsgType);
	4209	+ // 총 발송 건수
	4210	+ returnMap.put("resultSts", instTotalCnt);
	4211	+ apiReturnMap.put("resultSts", instTotalCnt);
	4212	+
	4213	+
	4214	+ // db insert 성능 개선중 하나에 방법
4182	4215	// 분할 최대건수가 되면 디비에 입력하기
4183	4216	// 여러시도 했지만 일단 보류
4184	4217	// 무시해도 됨
4185	4218	// int instCnt = mjonMsgDataDAO.insertMsgDataInfo_advc(mjonMsgSendVOList);
4186	4219	// int instCnt = mjonMsgDataDAO.insertMsgDataInfo_jdbc_advc(mjonMsgSendVOList);
4187	4220
4188		- // 총 발송 건수
4189		- returnMap.put("resultSts", instTotalCnt);
4190	4221
4191	4222	// TEST발송 시 발송 후 캐시가 있어야함.
4192	4223	returnMap.put("afterCash", priceAndPoint.getBefCash(userId));
...	...	@@ -4206,6 +4237,10 @@
4206	4237
4207	4238	statusResponse.setStatus(HttpStatus.OK);
4208	4239	statusResponse.setObject(returnMap);
	4240	+
	4241	+ apiReturnMap.put("result", "success");
	4242	+ apiReturnMap.put("message", "문자 전송이 완료되었습니다.");
	4243	+ statusResponse.setApiReturn(apiReturnMap);
4209	4244	return statusResponse;
4210	4245
4211	4246	}

Delete comment