Code - chominsoo4245/mjon

package itn.let.schdlr.service; import java.text.SimpleDateFormat; import java.util.Date; import javax.annotation.Resource; import javax.sql.DataSource; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Profile; import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Service; import com.ibm.icu.util.Calendar; import com.ibm.icu.util.GregorianCalendar; import egovframework.rte.fdl.property.EgovPropertyService; import itn.com.uss.olh.hpc.service.HackIpService; import itn.com.utl.fcc.service.EgovDateUtil; import itn.let.fax.admin.service.FaxAdmService; import itn.let.fax.admin.service.FaxStatVO; import itn.let.kakao.admin.kakaoAt.service.MjonKakaoAtStatVO; import itn.let.kakao.admin.statistics.service.KakaoStatisticsService; import itn.let.mail.service.MailTemplateService; import itn.let.mjo.msg.service.MjonMsgService; import itn.let.mjo.msg.service.MjonMsgStatVO; import itn.let.sts.com.StatsVO; import itn.let.sts.cst.service.EgovConectStatsService; import itn.let.uss.umt.service.EgovUserManageService; import itn.let.utl.user.service.MjonNoticeSendUtil; import net.javacrumbs.shedlock.core.LockProvider; import net.javacrumbs.shedlock.core.SchedulerLock; import net.javacrumbs.shedlock.provider.jdbctemplate.JdbcTemplateLockProvider; import net.javacrumbs.shedlock.spring.annotation.EnableSchedulerLock; @Profile("!local") @Service("SchedulerUtil") @EnableScheduling @EnableSchedulerLock(defaultLockAtMostFor = "PT30S") // Scheduler Lock 사용 가능 설정 (기본 30초동안 Lock) public class SchedulerUtil { @Resource(name = "SchdlrManageService") private SchdlrManageService schdlrManageService; @Resource (name = "MailTemplateService") private MailTemplateService mailTemplateService; @Resource (name = "userManageService") private EgovUserManageService egovUserManageService; @Resource(name = "hackIpService") private HackIpService hackIpService; @Resource(name = "mjonMsgService") private MjonMsgService mjonMsgService; @Resource(name = "KakaoStatisticsService") private KakaoStatisticsService kakaoStatisticsService; @Resource(name = "propertiesService") protected EgovPropertyService propertyService; @Resource(name = "conectStatsService") private EgovConectStatsService conectStatsService; /** 알림전송 Util */ @Resource(name = "mjonNoticeSendUtil") private MjonNoticeSendUtil mjonNoticeSendUtil; @Resource(name = "faxAdmService") private FaxAdmService faxAdmService; /** 설정값 가져오기 */ @Value("#{globalSettings['Globals.Env']}") private String GlobalsEnv; private static final String ONE_MIN = "PT1M"; // 1분동안 LOCK /* * 2분 마다 1주일 데이터에서 환불 대상을 찾아서 환불 한다. * */ // Schdule Lock (2분동안) @Scheduled(cron = "0 0/2 * * * ?") @SchedulerLock(name = "runScenarioOneTime", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void runScenarioOneTime() throws Exception { // do something... try { System.out.println("=============SchedulerUtil=====runScenarioOneTime =============>"); //문자 환불, 팩스 환불 PayBack(""); /* // 문자 환불 schdlrManageService.msgFailPayBack(); * */ // do something... }catch(Exception ex) { ex.printStackTrace(); } } /* * 매일 5시20분에 31일전 데이터에서 환불 대상을 찾아서 환불 한다. * */ @Scheduled(cron = "20 20 5 * * ?") @SchedulerLock(name = "runScenarioOneTimeOneByDay", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void runScenarioOneTimeOneByDay() throws Exception { // do something... try { System.out.println("=============EgovSysLogScheduling=====runScenarioOneTimeOneByDay =============>"); //문자 환불, 팩스 환불 PayBack("ONE"); /* // 문자 환불 schdlrManageService.msgFailPayBack(); * */ }catch(Exception ex) { ex.printStackTrace(); } } // Schdule Lock (2분동안) //세틀뱅크 자동 충전 배치 @Scheduled(cron = "0 0/2 * * * ?") @SchedulerLock(name = "runVacsChargeOneTime", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void runVacsChargeOneTime() throws Exception { System.out.println("=============EgovSysLogScheduling=====runVacsChargeOneTime =============>"); // do something... try { schdlrManageService.vacsAutoCharge(); }catch(Exception ex) { ex.printStackTrace(); } } // 매일 오전 4시마다 실행 ex) 04:00 // 휴면회원으로 지정 @Scheduled(cron = "0 0 4 * * *") @SchedulerLock(name = "runMemberDormantUpdate", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void runMemberDormantUpdate() throws Exception { System.out.println("=============EgovSysLogScheduling=====runMemberDormantUpdate =============>"); try { mailTemplateService.setMemberDormantUpdate(); }catch(Exception ex) { ex.printStackTrace(); } } // 매일 오전 8시마다 실행 ex) 08:00 // 휴면회원 메일발송 @Scheduled(cron = "0 0 8 * * *") @SchedulerLock(name = "runMailSendMemberDormant", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void runMailSendMemberDormant() throws Exception { System.out.println("=============EgovSysLogScheduling=====runMailSendMemberDormant =============>"); try { mailTemplateService.mailSendMemberDormant(); }catch(Exception ex) { ex.printStackTrace(); } } // 매일 오전 10시마다 실행 ex) 10:00 // 휴면회원 SMS발송 @Scheduled(cron = "0 0 10 * * *") @SchedulerLock(name = "runSmsSendMemberDormant", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void runSmsSendMemberDormant() throws Exception { System.out.println("=============EgovSysLogScheduling=====runSmsSendMemberDormant =============>"); try { mailTemplateService.smsSendMemberDormant(); }catch(Exception ex) { ex.printStackTrace(); } } // 매달 1일 0시 10분 실행 // "0 10 0 1 * *" // 매달 3일 6시 40분 실행 // "0 40 18 3 * *" // 매일 오전 1시 1분 0초 // "0 1 1 * * *" // @Scheduled(cron = "0 * * * * *") // 1분마다 실행(TEST) @Scheduled(cron = "0 1 0 1 * *") // 매달 1일 0시 1분 실행 @SchedulerLock(name = "runUserCashByAutoCashUpdate", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void runUserCashByAutoCashUpdate() throws Exception { //System.out.println("AutoCash Start"); // 후불제회원 Cash충전 //egovUserManageService.updateUserCashByAutoCash(); //System.out.println("AutoCash End"); try { System.out.println("AutoCash Start"); // 후불제회원 Cash충전 egovUserManageService.updateUserCashByAutoCash(); }catch(Exception ex) { ex.printStackTrace(); } } // 트래픽 감시 스케줄러 // 매분마다 실행 @Scheduled(cron = "37 * * * * *") @SchedulerLock(name = "highTrafficIgnoreIpInsert", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void highTrafficIgnoreIpInsert() throws Exception { //5분 내 300회 이상 접속로그가 있는 경우 차단아이피 등록 //hackIpService.selectHighTrafficNotIgnoreIp(); try { System.out.println("=============EgovSysLogScheduling=====highTrafficIgnoreIpInsert =============>"); //5분 내 300회 이상 접속로그가 있는 경우 차단아이피 등록 hackIpService.selectHighTrafficNotIgnoreIp(); // do something... }catch(Exception ex) { ex.printStackTrace(); } } // AGENT별 SMS LMS MMS 발송건수 , 카카오 알림톡 발송건수 통계 스케쥴러 // @Scheduled(cron = "0 */10 * * * *") //10분마다 실행(TEST) @Scheduled(cron = "0 10 1 * * *") // 매일 새벽1시 10분 실행 // @Scheduled(cron = "0 */30 * * * *") // 30분마다 실행 @SchedulerLock(name = "insertAgentSmsCountStat", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void agentSmsCountStatInsert() throws Exception { // agent별 sms lms mms 발송건수 통계 데이터 upsert //System.out.println("insertAgentSmsCountStat scheduler RUN (YESTERDAY)"); // int nowDate =EgovDateUtil.nowDateToInt("yyyyMMdd"); //int minusDate =EgovDateUtil.dayMinusToInt("yyyyMMdd", 1); // 전일 문자발송 건 통계 insert //MjonMsgStatVO mjonMsgStatVO = new MjonMsgStatVO(); //mjonMsgStatVO.setStatStartDate(minusDate); //mjonMsgStatVO.setStatEndDate(minusDate); //mjonMsgService.insertAgentSmsCountStat(mjonMsgStatVO); try { System.out.println("=============EgovSysLogScheduling=====insertAgentSmsCountStat scheduler RUN (YESTERDAY) =============>"); // int nowDate =EgovDateUtil.nowDateToInt("yyyyMMdd"); int minusDate =EgovDateUtil.dayMinusToInt("yyyyMMdd", 1); int minusSevenDays =EgovDateUtil.dayMinusToInt("yyyyMMdd", 7); MjonMsgStatVO mjonMsgStatVO = new MjonMsgStatVO(); mjonMsgStatVO.setStatStartDate(minusSevenDays); mjonMsgStatVO.setStatEndDate(minusDate); // 전일 문자발송 건 통계 insert mjonMsgService.insertAgentSmsCountStat(mjonMsgStatVO); //================================================================ //================================================================ MjonKakaoAtStatVO kakaoAtStatVO = new MjonKakaoAtStatVO(); kakaoAtStatVO.setStatStartDate(minusSevenDays); kakaoAtStatVO.setStatEndDate(minusDate); // 전일 알림톡발송 건 통계 insert kakaoStatisticsService.insertKakaoAtCountStat(kakaoAtStatVO); //================================================================ //================================================================ FaxStatVO faxStatVO = new FaxStatVO(); faxStatVO.setStatStartDate(minusSevenDays); faxStatVO.setStatEndDate(minusDate); // 전일 알림톡발송 건 통계 insert faxAdmService.insertFaxCountStat(faxStatVO); // do something... }catch(Exception ex) { ex.printStackTrace(); } } // AGENT별 SMS LMS MMS 발송건수 통계 스케쥴러 // @Scheduled(cron = "0 */10 * * * *") //10분마다 실행(TEST) // @Scheduled(cron = "0 0 1 * * *") // 매일 새벽1시 실행 @Scheduled(cron = "0 */30 * * * *") // 30분마다 실행 @SchedulerLock(name = "insertAgentSmsCountStat", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void agentSmsCountStatInsert2() throws Exception { // agent별 sms lms mms 발송건수 통계 데이터 upsert //System.out.println("insertAgentSmsCountStat scheduler RUN (EVERY 30 MINUTES)"); //int nowDate =EgovDateUtil.nowDateToInt("yyyyMMdd"); // int minusDate =EgovDateUtil.dayMinusToInt("yyyyMMdd", 1); // 당일 문자발송 건 통계 insert //MjonMsgStatVO mjonMsgStatVO = new MjonMsgStatVO(); //mjonMsgStatVO.setStatStartDate(nowDate); //mjonMsgStatVO.setStatEndDate(nowDate); //mjonMsgService.insertAgentSmsCountStat(mjonMsgStatVO); try { System.out.println("=============EgovSysLogScheduling=====agentSmsCountStatInsert2 =============>"); int nowDate =EgovDateUtil.nowDateToInt("yyyyMMdd"); // int minusDate =EgovDateUtil.dayMinusToInt("yyyyMMdd", 1); // 당일 문자발송 건 통계 insert MjonMsgStatVO mjonMsgStatVO = new MjonMsgStatVO(); mjonMsgStatVO.setStatStartDate(nowDate); mjonMsgStatVO.setStatEndDate(nowDate); mjonMsgService.insertAgentSmsCountStat(mjonMsgStatVO); //================================================================ //================================================================ MjonKakaoAtStatVO kakaoAtStatVO = new MjonKakaoAtStatVO(); kakaoAtStatVO.setStatStartDate(nowDate); kakaoAtStatVO.setStatEndDate(nowDate); // 당일 알림톡발송 건 통계 insert kakaoStatisticsService.insertKakaoAtCountStat(kakaoAtStatVO); //================================================================ FaxStatVO faxStatVO = new FaxStatVO(); faxStatVO.setStatStartDate(nowDate); faxStatVO.setStatEndDate(nowDate); // 전일 알림톡발송 건 통계 insert faxAdmService.insertFaxCountStat(faxStatVO); // do something... }catch(Exception ex) { ex.printStackTrace(); } } // 대시보드 어제/오늘 접속현황 & 접속통계 @Scheduled(cron = "0 1 0 * * *") // 매일 새벽0시 1분 실행 @SchedulerLock(name = "insertDashBoardStat", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void dashBoardStatInsert() throws Exception { try { System.out.println("=============EgovSysLogScheduling=====dashBoardStatInsert =============>"); // 어제날짜 Calendar calendar = new GregorianCalendar(); SimpleDateFormat SDF = new SimpleDateFormat("yyyy-MM-dd"); String yesterdayDate = SDF.format(calendar.getTime()); calendar.add(Calendar.DATE, -1); yesterdayDate = SDF.format(calendar.getTime()); StatsVO yesterdayStatsVO = new StatsVO(); yesterdayStatsVO.setStatDate(yesterdayDate); // 대시보드 인서트 Logic conectStatsService.insertDashBoardStatLogic(yesterdayStatsVO); // 대시보드 업데이트 Logic conectStatsService.updateDashBoardStatLogic(yesterdayStatsVO); // 오늘날짜 Date nowDate = new Date(); SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd"); String strNowDate = simpleDateFormat.format(nowDate); StatsVO statsVO = new StatsVO(); statsVO.setStatDate(strNowDate); // 대시보드 인서트 Logic conectStatsService.insertDashBoardStatLogic(statsVO); // 대시보드 업데이트 Logic conectStatsService.updateDashBoardStatLogic(statsVO); }catch(Exception ex) { ex.printStackTrace(); } } // 대시보드 어제/오늘 접속현황 & 접속통계 @Scheduled(cron = "0 */30 * * * *") // 30분마다 실행 @SchedulerLock(name = "updateDashBoardStat", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void DashBoardStatUpdate() throws Exception { try { System.out.println("=============EgovSysLogScheduling=====DashBoardStatUpdate =============>"); // 오늘날짜 Date nowDate = new Date(); SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd"); String strNowDate = simpleDateFormat.format(nowDate); StatsVO statsVO = new StatsVO(); statsVO.setStatDate(strNowDate); // 대시보드 인서트 Logic conectStatsService.insertDashBoardStatLogic(statsVO); // 대시보드 업데이트 Logic conectStatsService.updateDashBoardStatLogic(statsVO); }catch(Exception ex) { ex.printStackTrace(); } } // 이용약관 메일발송 @Scheduled(cron = "0 */10 * * * *") // 10분마다 실행 @SchedulerLock(name = "sendTermsEmail", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void TermsEmailSend() throws Exception { try { System.out.println("=============EgovSysLogScheduling=====TermsEmailSend =============>"); // 이용약관 회원 전체발송 mjonNoticeSendUtil.userAllTermsEmailSend(); }catch(Exception ex) { ex.printStackTrace(); } } @Bean public LockProvider lockProvider(DataSource dataSource) { return new JdbcTemplateLockProvider(dataSource); } @Scheduled(cron = "20 * * * * ?") @SchedulerLock(name = "runKakaoOneTime", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void runKakaoOneTime() throws Exception { // do something... try { System.out.println("=============SchedulerUtil=====runKakaoOneTime =============>"); schdlrManageService.kakaoFailPayBack(); }catch(Exception ex) { ex.printStackTrace(); } } //환불 실행 private void PayBack(String p_type) throws Exception { // 문자 환불 if ("ONE".equals(p_type)) { //하루에 한번만 31일 대상으로 실행 schdlrManageService.msgFailPayBackOneByDay(); }else { //2분 마다는 7일을 대상으로 실행 schdlrManageService.msgFailPayBack(); } System.out.println("==== faxFailPayBack ===="); // 팩스 환불 schdlrManageService.faxFailPayBack(); } }