File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
package itn.let.schdlr.service.impl;
import java.io.File;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;
import javax.annotation.Resource;
import org.jsoup.Jsoup;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import com.fasterxml.jackson.databind.ObjectMapper;
import egovframework.rte.fdl.cmmn.EgovAbstractServiceImpl;
import egovframework.rte.fdl.idgnr.EgovIdGnrService;
import itn.com.cmm.EgovMultiPartEmail;
import itn.com.cmm.service.EgovFileMngService;
import itn.com.cmm.service.impl.FileManageDAO;
import itn.let.fax.user.service.impl.FaxDAO;
import itn.let.kakao.user.kakaoAt.service.KakaoAlimTalkService;
import itn.let.mail.service.StatusResponse;
import itn.let.mjo.mjocommon.MjonCommon;
import itn.let.mjo.msg.service.MjonMsgVO;
import itn.let.mjo.msg.service.RefundDTO;
import itn.let.mjo.msgdata.service.MjonMsgDataService;
import itn.let.mjo.msgdata.service.impl.MjonMsgDataDAO;
import itn.let.mjo.pay.service.MjonPayService;
import itn.let.mjo.pay.service.StVcVO;
import itn.let.mjo.payva.service.VacsAhstService;
import itn.let.mjo.payva.service.VacsAhstVO;
import itn.let.schdlr.service.SchdlrManageService;
import itn.let.schdlr.service.SchdlrVO;
import itn.let.sym.site.service.EgovSiteManagerService;
import itn.let.sym.site.service.JoinSettingVO;
import itn.let.uss.umt.service.EgovUserManageService;
import itn.let.uss.umt.service.UserManageVO;
import itn.let.utl.user.service.MjonNoticeSendUtil;
@Service("SchdlrManageService")
public class SchdlrManageServiceImpl extends EgovAbstractServiceImpl implements SchdlrManageService {
@Resource(name = "egovItsmSchdlrGnrService")
private EgovIdGnrService idgenSchdlrId;
@Resource(name = "egovItsmSchdlrConfigGnrService")
private EgovIdGnrService idgenSchCfgId;
@Resource(name = "egovItsmSchdlrShareIdGnrService")
private EgovIdGnrService idgenSchdlrShareId;
@Resource(name = "SchdlrManageDAO")
private SchdlrManageDAO schdlrManageDAO;
@Resource(name = "FileManageDAO")
private FileManageDAO fileMngDAO;
@Resource(name = "EgovFileMngService")
private EgovFileMngService fileMngService;
@Resource(name = "egovMultiPartEmail")
private EgovMultiPartEmail egovMultiPartEmail;
@Value("#{globalSettings['Globals.mailContentFileFolder']}")
private String MAIL_CONTENT_PATH;
@Value("#{globalSettings['Globals.HOMPAGE_URL']}")
private String HOMPAGE_URL;
@Resource(name = "MjonMsgDataDAO")
private MjonMsgDataDAO mjonMsgDataDAO;
// 문자온 카카오 알림톡 발송 서비스
@Resource(name = "kakaoAlimTalkService")
private KakaoAlimTalkService kakaoAlimTalkService;
// 문자온 문자 발송 서비스
@Resource(name = "MjonMsgDataService")
private MjonMsgDataService mjonMsgDataService;
// 세틀뱅크 입금전문 서비스
@Resource(name = "vacsAhstService")
private VacsAhstService vacsAhstService;
// 문자온 결제 서비스
@Resource(name = "mjonPayService")
private MjonPayService mjonPayService;
/** userManageService */
@Resource(name = "userManageService")
private EgovUserManageService userManageService;
/** 사이트 설정 */
@Resource(name = "egovSiteManagerService")
EgovSiteManagerService egovSiteManagerService;
/** 알림전송 Util */
@Resource(name = "mjonNoticeSendUtil")
private MjonNoticeSendUtil mjonNoticeSendUtil;
@Resource(name = "MjonCommon")
private MjonCommon mjonCommon;
@Resource(name = "faxDAO")
public FaxDAO faxDao;
private static final Logger LOGGER = LoggerFactory.getLogger(SchdlrManageServiceImpl.class);
// 스케줄달력 목록(월별)
public List<SchdlrVO> selectSchdlrList(SchdlrVO schdlrVO) throws Exception {
return schdlrManageDAO.selectSchdlrList(schdlrVO);
}
// 스케줄 등록
public void schdlrInsert(SchdlrVO schdlrVO) throws Exception {
schdlrVO.setSchdlrId(idgenSchdlrId.getNextStringId()); // 신규 키
schdlrManageDAO.schdlrInsert(schdlrVO); // 등록
if (schdlrVO.getSchdlrUserId() != null && schdlrVO.getSchdlrUserId().length() != 0) {
String userId[] = schdlrVO.getSchdlrUserId().split(",");
String userName[] = schdlrVO.getSchdlrUserName().split(",");
for (int i = 0; i < userId.length; i++) {
// System.out.println("@@@@@@@@@@@@@@@@@@@@@@@@@@@ userID : "+userId[i]);
// System.out.println("@@@@@@@@@@@@@@@@@@@@@@@@@@@ userName : "+userName[i]);
schdlrVO.setSchdlrUserId(userId[i]);
schdlrVO.setSchdlrUserName(userName[i]);
schdlrVO.setSchdlrShareId(idgenSchdlrShareId.getNextStringId());
schdlrManageDAO.schdlrShareInsert(schdlrVO);
}
}
}
// 스케줄 수정
public void schdlrUpdate(SchdlrVO schdlrVO) throws Exception {
schdlrManageDAO.schdlrUpdate(schdlrVO);
if (!("").equals(schdlrVO.getSchdlrUserId())) {
String userId[] = schdlrVO.getSchdlrUserId().split(",");
String userName[] = schdlrVO.getSchdlrUserName().split(",");
int schdlrShareCount = schdlrManageDAO.selectSchdlrShareCount(schdlrVO);
if (schdlrShareCount != 0) {
schdlrManageDAO.deleteSchdlrShare(schdlrVO.getSchdlrId());
}
for (int i = 0; i < userId.length; i++) {
// System.out.println("@@@@@@@@@@@@@@@@@@@@@@@@@@@ userID : "+userId[i]);
// System.out.println("@@@@@@@@@@@@@@@@@@@@@@@@@@@ userName : "+userName[i]);
schdlrVO.setSchdlrUserId(userId[i]);
schdlrVO.setSchdlrUserName(userName[i]);
schdlrVO.setSchdlrShareId(idgenSchdlrShareId.getNextStringId());
schdlrManageDAO.schdlrShareInsert(schdlrVO);
}
}
}
// 일정 상세 조회
public SchdlrVO selectSchdlrDetail(SchdlrVO schdlrVO) throws Exception {
return schdlrManageDAO.selectSchdlrDetail(schdlrVO);
}
@Override
public List<SchdlrVO> selectSchdlrShare(SchdlrVO schdlrVO) throws Exception {
return schdlrManageDAO.selectSchdlrShare(schdlrVO);
}
// 일정 목록 조회
public List<SchdlrVO> selectSchList(SchdlrVO schdlrVO) throws Exception {
return schdlrManageDAO.selectSchList(schdlrVO);
}
// 환경설정 등록
public void insertSchConfig(SchdlrVO schdlrVO) throws Exception {
schdlrVO.setSchdlrCfgId(idgenSchCfgId.getNextStringId()); // 신규 키
schdlrManageDAO.insertSchConfig(schdlrVO); // 등록
}
// 환경설정 수정
public void updateSchConfig(SchdlrVO schdlrVO) throws Exception {
schdlrManageDAO.updateSchConfig(schdlrVO);
}
// 환경설정 상세 조회
public SchdlrVO selectSchConfigDetail(SchdlrVO schdlrVO) throws Exception {
SchdlrVO result = schdlrManageDAO.selectSchConfigDetail(schdlrVO);
if (result == null) { // 첫 조회시 기본값 등록
result = new SchdlrVO();
result.setSchdlrCfgId(idgenSchCfgId.getNextStringId());
result.setSchdlrCfgUserId(schdlrVO.getSchdlrCfgUserId());
result.setSchdlrOpenCd("01");
result.setSchdlrWeekBgnCd("01");
result.setSchdlrTimeCd("01");
result.setSchdlrColorUserCd("01");
result.setSchdlrColorShareCd("02");
result.setSchdlrColorPerCd("03");
schdlrManageDAO.insertSchConfig(result);
}
return result;
}
// 일정 알림 메일 전송
public void schMailSend(String bgnDateTime) throws Exception {
List<SchdlrVO> mailList = schdlrManageDAO.selectMailSendList(bgnDateTime);
for (SchdlrVO vo : mailList) {
if (("").equals(vo.getEmailAdres()))
continue;
boolean result = sendMail(vo);
LOGGER.debug("send succ update:", result);
if (result)
schdlrManageDAO.updateMailSend(vo);
}
}
/**
* 일정 알림 메일 전송
*
* @param SchdlrVO schdlrVO
* @return boolean
* @throws Exception
*/
private boolean sendMail(SchdlrVO schdlrVO) throws Exception {
boolean result = false;
try {
String mailSj = "[" + schdlrVO.getSchdlrTitle() + "] N-CMS 스케줄러 일정 메일 알림입니다.";
String alram = "";
// // 알림설정 표시
// if (Pattern.matches("^[0-9]*$", schdlrVO.getSchdlrAlarmCnd())) {
// alram = schdlrVO.getSchdlrAlarmCnd() + " 분전";
// } else if (schdlrVO.getSchdlrAlarmCnd().equals("etc")) {
// alram = schdlrVO.getSchdlrAlarmDatetime();
// }
switch (schdlrVO.getSchdlrAlarmCnd()) {
case "0":
alram = "정시";
break;
case "10":
alram = "십분 전";
break;
case "30":
alram = "삼십분 전";
break;
case "60":
alram = "한시간 전";
break;
case "etc":
alram = schdlrVO.getSchdlrAlarmDatetime();
break;
}
String mailContent = Jsoup
.parse(new File(MAIL_CONTENT_PATH + "/direct/mail_template/sch_alrm_cont.html"), "UTF-8")
.toString();
mailContent = mailContent.replace("#일정명", schdlrVO.getSchdlrTitle());
mailContent = mailContent.replace("#일시",
schdlrVO.getSchdlrBgnDatetime() + " ~ " + schdlrVO.getSchdlrEndDatetime());
mailContent = mailContent.replace("#장소", schdlrVO.getSchdlrPlace());
mailContent = mailContent.replace("#내용", schdlrVO.getSchdlrCn().replaceAll("(\r\n|\r|\n|\n\r)", "<br>"));
mailContent = mailContent.replace("#알림설정", alram);
String resultMsg = egovMultiPartEmail.send(schdlrVO.getEmailAdres(), mailSj, "", mailContent);
// egovMultiPartEmail.send(mailAddres, mailSj", mgs); // Simple Text Mail method
result = true;
LOGGER.debug("mail send resultMsg: ", resultMsg);
} catch (Exception ex) {
LOGGER.error("Sending Mail Exception : {} [unknown Exception]", ex.getCause());
// LOGGER.error(ex.getMessage());
}
return result;
}
// 메인화면 > 전체일정
public List<SchdlrVO> selectMainSchList(SchdlrVO schdlrVO) throws Exception {
return schdlrManageDAO.selectMainSchList(schdlrVO);
}
// 문자온 문자발송 실패 건수 환불 배치(1주 대상)
public void msgFailPayBack() throws Exception {
Date now = new Date();
System.out.println("문자온 실패 건수 환불 스케줄러 실행!!!(1weeks)" + now);
/*
* 문자발송 실패 건수 확인 및 캐시 환불 처리
*/
mjonMsgDataService.selectMsgSentFailList();
/*
* 세틀뱅크 입금 확인 및 캐시 충전 배치 프로세스
*/
/*
* VacsAhstVO vacsAhstVO = new VacsAhstVO(); List<VacsAhstVO>
* resultBeforCashList = vacsAhstService.selectBeforCashList(vacsAhstVO);
*
* if(resultBeforCashList != null) {
*
* for(VacsAhstVO temp : resultBeforCashList) {
*
* StVcVO stvcVO = new StVcVO();
*
* stvcVO.setOrgCd(temp.getOrgCd()); stvcVO.setBankCd(temp.getBankCd());
* stvcVO.setIacctNo(temp.getIacctNo()); stvcVO.setTrNo(temp.getTrNo());
* stvcVO.setTrIl(temp.getTrIl()); stvcVO.setTrAmt(temp.getTrAmt());
* stvcVO.setIacctNm(temp.getIacctNm()); stvcVO.setMberId(temp.getMberId());
*
* //세틀뱅크 입금 내역 자동 충전하기 mjonPayService.insertVcCharge(stvcVO);
*
* //세틀뱅크 입금 내역 원장에 처리 완료 내용 입력해 주기
* vacsAhstService.updateVacsAhstCashComplete(temp);
*
* }
*
* }
*/
}
// 문자온 문자발송 실패 건수 환불 배치(31일)
public void msgFailPayBackOneByDay() throws Exception {
Date now = new Date();
System.out.println("문자온 실패 건수 환불 스케줄러 실행!!!(31days)" + now);
/*
* 문자발송 실패 건수 확인 및 캐시 환불 처리
*/
// mjonMsgDataService.selectMsgSentFailListOneByDay();
}
// 팩스 발송 실패 건수 환불 배치
public void faxFailPayBack() throws Exception {
System.out.println("팩스 실패 건수 환불 스케줄러 실행!!!" + new Date());
// 팩스 발송 실패 건수 확인 및 캐시 환불 처리
faxDao.selectFaxSentFailList();
}
// 전용계좌 자동 충전 배치
public void vacsAutoCharge() throws Exception {
Date now = new Date();
System.out.println("문자온 전용계좌 자동 충전 스케줄러 실행 !!!" + now);
/*
* 문자발송 실패 건수 확인 및 캐시 환불 처리
*/
// mjonMsgDataService.selectMsgSentFailList();
/*
* 세틀뱅크 입금 확인 및 캐시 충전 배치 프로세스
*/
VacsAhstVO vacsAhstVO = new VacsAhstVO();
List<VacsAhstVO> resultBeforCashList = vacsAhstService.selectBeforCashList(vacsAhstVO);
if (resultBeforCashList != null) {
for (VacsAhstVO temp : resultBeforCashList) {
StVcVO stvcVO = new StVcVO();
stvcVO.setOrgCd(temp.getOrgCd());
stvcVO.setBankCd(temp.getBankCd());
stvcVO.setIacctNo(temp.getIacctNo());
stvcVO.setTrNo(temp.getTrNo());
stvcVO.setTrIl(temp.getTrIl());
stvcVO.setTrAmt(temp.getTrAmt());
stvcVO.setIacctNm(temp.getIacctNm());
stvcVO.setMberId(temp.getMberId());
// 세틀뱅크 입금 내역 자동 충전하기
mjonPayService.insertVcCharge(stvcVO);
// 세틀뱅크 입금 내역 원장에 처리 완료 내용 입력해 주기
vacsAhstService.updateVacsAhstCashComplete(temp);
try {
String Userid = temp.getMberId();
String mberNm = "";
// 대상 : 휴대폰결제, 즉시이체, 전용계좌
// Step 1. 스미싱의심 지정 여부
JoinSettingVO joinSettingVO = new JoinSettingVO();
joinSettingVO = egovSiteManagerService.selectAdminNotiDetail();
if (joinSettingVO != null && joinSettingVO.getSmishingNoti().equals("Y")) {
// Step 1. 개인회원 여부 체크
int isPersnalMemberCnt = egovSiteManagerService.selectPersnalMemberCnt(Userid);
if (isPersnalMemberCnt == 1) {
// Step 2. 첫결제 여부 체크
int isFirstPayCnt = egovSiteManagerService.selectFirstPayCnt(Userid);
if (isFirstPayCnt == 1) {
// SMS 체크
if (joinSettingVO != null && joinSettingVO.getSmsNoti().equals("Y")) {
// 스미싱의심 SMS 알림전송
mjonNoticeSendUtil.smishingSmsNoticeSend("스미싱의심/전용계좌 첫결제", Userid, mberNm);
}
// SLACK 체크
if (joinSettingVO != null && joinSettingVO.getSlackNoti().equals("Y")) {
// Slack 메시지 발송(단순본문)
String msg = "[문자온] 스미싱의심/전용계좌 첫결제 - " + mberNm + "(" + Userid + ")";
mjonCommon.sendSimpleSlackMsg(msg);
}
// 스미싱 의심회원으로 변경
UserManageVO userManageVO = new UserManageVO();
userManageVO.setSmishingYn("Y");
userManageVO.setMberId(Userid);
userManageService.updateOneUserSmishingYnNotAlert(userManageVO);
}
}
}
} catch (Exception e) {
System.out.println("#############################################################");
System.out.println("전용계좌 슬랙알림 & 스미싱의심 처리 Error");
System.out.println("전용계좌 TrNo : " + temp.getTrNo());
System.out.println("전용계좌 e.getMessage() : " + e.getMessage());
}
}
}
}
// 카카오 환불 처리 리스트
public void kakaoFailPayBack() throws Exception {
// 카카오 알림톡 환불 처리
kakaoAlimTalkService.selectKakaoAtSentRefundList();
// 카카오 친구톡 환불 처리
// kakaoAlimTalkService.selectKakaoFtSentRefundList();
}
@Override
public void payBack(String type, int limitCout) throws Exception {
// 문자 환불
if ("ONE".equals(type)) { // 하루에 한번만 31일 대상으로 실행
msgFailPayBackOneByDay();
} else { // 2분 마다는 7일을 대상으로 실행
MjonMsgVO mjonMsgVO = new MjonMsgVO();
mjonMsgVO.setRecordCountPerPage(limitCout);
List<MjonMsgVO> msgFailList = mjonMsgDataDAO.selectMsgSentFailSchedulerList(mjonMsgVO);
long forBeforeTime = System.currentTimeMillis(); // 코드 실행 전 시간
int batchSize = 300;
int totalSize = msgFailList.size();
int endj = 0;
for (int i = 0; i < totalSize; i += batchSize) {
int end = Math.min(i + batchSize, totalSize);
long beforeTime = System.currentTimeMillis(); // 코드 실행 전 시간
for (int j = endj; j < end; j++) {
System.out.println(j + " : " + end);
try {
mjonMsgDataDAO.updateMsgSentFailPayBack(msgFailList.get(j));
} catch (Exception ex) {
System.out.println("=============SchedulerUtil=====PayBack Catch =============>");
System.out.println(msgFailList.get(j).getUserId() + " : "
+ msgFailList.get(j).getMsgGroupId() + " : " + msgFailList.get(j).getUserData());
ex.printStackTrace();
}
}
endj = end;
long afterTime = System.currentTimeMillis(); // 코드 실행 후 시간
long secDiffTime = (afterTime - beforeTime) / 1000; // 코드 실행 전후 시간 차이 계산(초 단위)
System.out.println("==PayBack for 1 =============> : " + secDiffTime + "초");
}
long forAfterTime = System.currentTimeMillis(); // 코드 실행 후 시간
long forSecDiffTime = (forAfterTime - forBeforeTime) / 1000; // 코드 실행 전후 시간 차이 계산(초 단위)
System.out.println(
"==PayBack for 2 =============> 수량 : " + msgFailList.size() + " ===== " + forSecDiffTime + "초");
}
}
/**
* @methodName : refundTest
* @author : 이호영
* @date : 2024.12.12
* @description : 환불 데이터
* @param p_type
* @param request
* @param model
* @return
* @throws Exception
*/
@Override
public void payBack_advc(String p_type) throws Exception {
List<MjonMsgVO> msgFailList = new ArrayList<>();
msgFailList = getMsgFailList(p_type);
// 리스트가 비어있는 경우 종료
if (msgFailList == null || msgFailList.isEmpty() || msgFailList.size() < 1) {
System.out.println("No payBack messages empty.");
}else {
try {
// 필요한 필드만 DTO로 매핑
List<RefundDTO> dtoList = msgFailList.stream()
.map(msg ->
new RefundDTO(
msg.getUserId()
, msg.getMsgGroupId()
, msg.getUserData()
, Integer.parseInt(msg.getUserData())
, msg.getEachPrice())
)
.collect(Collectors.toList());
// JSON 변환
ObjectMapper objectMapper = new ObjectMapper();
String msgFailListJson = objectMapper.writeValueAsString(dtoList);
mjonMsgDataDAO.updateMsgSentFailPayBackBatch(msgFailListJson);
} catch (Exception ex) {
ex.printStackTrace();
}
}
// TODO Auto-generated method stub
}
/**
* @methodName : getMsgFailList
* @author : 이호영
* @date : 2024.12.12
* @description : 파라미터에 따라 환불 데이터 가져오기
* @param p_type
* @return
* @throws Exception
*/
private List<MjonMsgVO> getMsgFailList(String p_type) throws Exception {
List<MjonMsgVO> msgFailList = new ArrayList<>();
// 문자 환불
if ("ONE".equals(p_type)) { // 하루에 한번만 31일 대상으로 실행
msgFailList = mjonMsgDataDAO.selectMsgSentFailListOneByDay();
} else {
// 10분 마다 1주일 데이터에서 환불 대상을 찾아서 환불 한다.
// schdlrManageService.msgFailPayBack();
msgFailList = mjonMsgDataDAO.selectMsgSentFailList();
}
return msgFailList;
}
/**
* @methodName : updateKakaoResendResult
* @author : 이지우
* @date : 2025.07.15
* @description : 대체문자 결과 반영
* @param p_type
* @param request
* @param model
* @return
* @throws Exception
*/
@Override
public void updateKakaoResendResult() throws Exception {
long startTime = System.currentTimeMillis();
// 대체문자 대상 조회
List<MjonMsgVO> resendLogList = mjonMsgDataDAO.selectBizResendLogList();
for(MjonMsgVO vo : resendLogList) {
if("4100".equals(vo.getResultCode())
|| "6600".equals(vo.getResultCode())
|| "7000".equals(vo.getResultCode())) {
vo.setMsgResult("40");
}else {
vo.setMsgResult("50");
}
mjonMsgDataDAO.updateResendResult(vo);
mjonMsgDataDAO.deleteBizResendLog(vo);
}
long endTime = System.currentTimeMillis();
long elapsedTime = (endTime - startTime) / 1000; // 초 단위 변환
System.out.println("updateKakaoResendResult 실행 시간: " + elapsedTime + "초 (" + resendLogList.size() + "건 처리)");
}
}