From 8afad77998ebcebbf3be3f1b36f8e5a0f351a1a8 Mon Sep 17 00:00:00 2001 From: wyh Date: Thu, 7 Nov 2024 11:27:50 +0900 Subject: [PATCH 1/6] =?UTF-8?q?=EC=8A=A4=EC=BC=80=EC=A4=84=EB=9F=AC=20?= =?UTF-8?q?=EC=A3=BC=EC=84=9D=20=ED=95=B4=EC=A0=9C=20=EB=B0=8F=20limit=20?= =?UTF-8?q?=ED=95=B4=EC=A0=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/itn/let/schdlr/service/SchedulerUtil.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/src/main/java/itn/let/schdlr/service/SchedulerUtil.java b/src/main/java/itn/let/schdlr/service/SchedulerUtil.java index 3f198b7c..5034a19c 100644 --- a/src/main/java/itn/let/schdlr/service/SchedulerUtil.java +++ b/src/main/java/itn/let/schdlr/service/SchedulerUtil.java @@ -103,7 +103,7 @@ public class SchedulerUtil { //문자 환불, 팩스 환불 - //PayBack(""); + PayBack(""); /* // 문자 환불 @@ -484,9 +484,15 @@ public class SchedulerUtil { }else { //2분 마다는 7일을 대상으로 실행 //어플리케이션 트랜잭션 문제가 있어 Util 단으로 DB 호출을 가져옴 - 2024-03-14 //schdlrManageService.msgFailPayBack(); + + // limit 제한 있음 MjonMsgVO mjonMsgVO = new MjonMsgVO(); mjonMsgVO.setRecordCountPerPage(500); - List msgFailList = mjonMsgDataDAO.selectMsgSentFailSchedulerList(mjonMsgVO); + //List msgFailList = mjonMsgDataDAO.selectMsgSentFailSchedulerList(mjonMsgVO); + + // limit 제한 없음 + List msgFailList = mjonMsgDataDAO.selectMsgSentFailList(); + long forBeforeTime = System.currentTimeMillis(); // 코드 실행 전 시간 int batchSize = 300; int totalSize = msgFailList.size(); From dc23493ed8877bcfc1713f8dd30eca41741a599f Mon Sep 17 00:00:00 2001 From: wyh Date: Thu, 7 Nov 2024 15:06:08 +0900 Subject: [PATCH 2/6] =?UTF-8?q?=ED=99=98=EB=B6=88=EC=8A=A4=EC=BC=80?= =?UTF-8?q?=EC=A4=84=EB=9F=AC=20=EC=9B=90=EB=B3=B5=20=EB=B0=8F=20=EC=A3=BC?= =?UTF-8?q?=EC=84=9D=20=EC=B6=94=EA=B0=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../itn/let/schdlr/service/SchedulerUtil.java | 46 +++++++------------ 1 file changed, 16 insertions(+), 30 deletions(-) diff --git a/src/main/java/itn/let/schdlr/service/SchedulerUtil.java b/src/main/java/itn/let/schdlr/service/SchedulerUtil.java index 5034a19c..fe3765fb 100644 --- a/src/main/java/itn/let/schdlr/service/SchedulerUtil.java +++ b/src/main/java/itn/let/schdlr/service/SchedulerUtil.java @@ -91,8 +91,8 @@ public class SchedulerUtil { /* * 2분 마다 1주일 데이터에서 환불 대상을 찾아서 환불 한다. * */ - // Schdule Lock (5분동안) - @Scheduled(cron = "0 0/5 * * * ?") + // Schdule Lock (10분동안) + @Scheduled(cron = "0 0/10 * * * ?") @SchedulerLock(name = "runScenarioOneTime", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void runScenarioOneTime() throws Exception { @@ -485,37 +485,23 @@ public class SchedulerUtil { //어플리케이션 트랜잭션 문제가 있어 Util 단으로 DB 호출을 가져옴 - 2024-03-14 //schdlrManageService.msgFailPayBack(); - // limit 제한 있음 - MjonMsgVO mjonMsgVO = new MjonMsgVO(); - mjonMsgVO.setRecordCountPerPage(500); - //List msgFailList = mjonMsgDataDAO.selectMsgSentFailSchedulerList(mjonMsgVO); - - // limit 제한 없음 List msgFailList = mjonMsgDataDAO.selectMsgSentFailList(); 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 +"초"); - } + int count = 0; + for(MjonMsgVO vo : msgFailList) { + System.out.println(count + " : "+ msgFailList.size()); + + try { + mjonMsgDataDAO.updateMsgSentFailPayBack(vo); + }catch(Exception ex) { + System.out.println("=============SchedulerUtil=====PayBack Catch =============>"); + System.out.println(vo.getUserId()+" : "+ vo.getMsgGroupId() +" : "+ vo.getUserData()); + ex.printStackTrace(); + } + + count = count + 1; + } long forAfterTime = System.currentTimeMillis(); // 코드 실행 후 시간 long forSecDiffTime = (forAfterTime - forBeforeTime)/1000; // 코드 실행 전후 시간 차이 계산(초 단위) System.out.println("==PayBack for 2 =============> 수량 : "+msgFailList.size()+" ===== " + forSecDiffTime +"초"); From b62c397320de698e8540a0797f22e2dd966d141e Mon Sep 17 00:00:00 2001 From: wyh Date: Thu, 7 Nov 2024 19:05:49 +0900 Subject: [PATCH 3/6] =?UTF-8?q?=EB=A6=AC=EC=8A=A4=ED=8A=B8=20=EC=B9=B4?= =?UTF-8?q?=EC=9A=B4=ED=8A=B8=20=EC=B6=94=EA=B0=80?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/itn/let/schdlr/service/SchedulerUtil.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/java/itn/let/schdlr/service/SchedulerUtil.java b/src/main/java/itn/let/schdlr/service/SchedulerUtil.java index fe3765fb..4c58beb7 100644 --- a/src/main/java/itn/let/schdlr/service/SchedulerUtil.java +++ b/src/main/java/itn/let/schdlr/service/SchedulerUtil.java @@ -92,7 +92,7 @@ public class SchedulerUtil { * 2분 마다 1주일 데이터에서 환불 대상을 찾아서 환불 한다. * */ // Schdule Lock (10분동안) - @Scheduled(cron = "0 0/10 * * * ?") + @Scheduled(cron = "0 0/5 * * * ?") @SchedulerLock(name = "runScenarioOneTime", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void runScenarioOneTime() throws Exception { @@ -489,6 +489,7 @@ public class SchedulerUtil { long forBeforeTime = System.currentTimeMillis(); // 코드 실행 전 시간 int count = 0; + System.out.println("== msgFailList =============> : "+ msgFailList.size()); for(MjonMsgVO vo : msgFailList) { System.out.println(count + " : "+ msgFailList.size()); From d2fa81e3d3f4825a5029bd91aeb43d1ae5d40805 Mon Sep 17 00:00:00 2001 From: wyh Date: Thu, 7 Nov 2024 19:27:44 +0900 Subject: [PATCH 4/6] =?UTF-8?q?=EC=8A=A4=EC=BC=80=EC=A4=84=EB=9F=AC=20?= =?UTF-8?q?=EA=B8=B0=EB=8A=A5=20=EC=88=98=EC=A0=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/itn/let/schdlr/service/SchedulerUtil.java | 2 +- .../egovframework/sqlmap/let/msg/MjonMsgData_SQL_mysql.xml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/itn/let/schdlr/service/SchedulerUtil.java b/src/main/java/itn/let/schdlr/service/SchedulerUtil.java index 4c58beb7..dc42c346 100644 --- a/src/main/java/itn/let/schdlr/service/SchedulerUtil.java +++ b/src/main/java/itn/let/schdlr/service/SchedulerUtil.java @@ -92,7 +92,7 @@ public class SchedulerUtil { * 2분 마다 1주일 데이터에서 환불 대상을 찾아서 환불 한다. * */ // Schdule Lock (10분동안) - @Scheduled(cron = "0 0/5 * * * ?") + @Scheduled(cron = "0 0/10 * * * ?") @SchedulerLock(name = "runScenarioOneTime", lockAtMostForString = ONE_MIN, lockAtLeastForString = ONE_MIN) public void runScenarioOneTime() throws Exception { diff --git a/src/main/resources/egovframework/sqlmap/let/msg/MjonMsgData_SQL_mysql.xml b/src/main/resources/egovframework/sqlmap/let/msg/MjonMsgData_SQL_mysql.xml index 752e51d1..8deaf7af 100644 --- a/src/main/resources/egovframework/sqlmap/let/msg/MjonMsgData_SQL_mysql.xml +++ b/src/main/resources/egovframework/sqlmap/let/msg/MjonMsgData_SQL_mysql.xml @@ -3901,7 +3901,7 @@ - SELECT USER_ID AS userId, MSG_GROUP_ID AS msgGroupId, From 47b7125d34f1d20c643e7afd232ee79dfbd2588d Mon Sep 17 00:00:00 2001 From: rosewiper Date: Mon, 11 Nov 2024 14:26:44 +0900 Subject: [PATCH 5/6] =?UTF-8?q?=EA=B3=A0=ED=8A=B8=EB=9E=98=ED=94=BD=20?= =?UTF-8?q?=EC=95=84=EC=9D=B4=ED=94=BC=20=EC=B0=A8=EB=8B=A8=EC=97=90?= =?UTF-8?q?=EC=84=9C=20API=20=EC=84=9C=EB=B2=84=20=EC=95=84=EC=9D=B4?= =?UTF-8?q?=ED=94=BC=EB=8A=94=20=EC=98=88=EC=99=B8=EB=90=98=EB=8F=84?= =?UTF-8?q?=EB=A1=9D=20=EC=BF=BC=EB=A6=AC=20=EC=88=98=EC=A0=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sqlmap/com/uss/olh/hpc/EgovHpcm_SQL_mysql.xml | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/resources/egovframework/sqlmap/com/uss/olh/hpc/EgovHpcm_SQL_mysql.xml b/src/main/resources/egovframework/sqlmap/com/uss/olh/hpc/EgovHpcm_SQL_mysql.xml index 0e6ec250..d6767fb8 100644 --- a/src/main/resources/egovframework/sqlmap/com/uss/olh/hpc/EgovHpcm_SQL_mysql.xml +++ b/src/main/resources/egovframework/sqlmap/com/uss/olh/hpc/EgovHpcm_SQL_mysql.xml @@ -364,7 +364,8 @@ ON A.IGNORE_IP = M2.CONECT_IP ) M3 WHERE M3.IGNORE_YN = 'N' - AND M3.CONECT_IP!='119.193.215.98' + AND M3.CONECT_IP !='119.193.215.98' + AND M3.CONECT_IP !='139.150.70.79' From 153ae2ad6080183fca329973eef31589872cd7c1 Mon Sep 17 00:00:00 2001 From: rosewiper Date: Mon, 11 Nov 2024 14:34:50 +0900 Subject: [PATCH 6/6] =?UTF-8?q?=EA=B3=A0=ED=8A=B8=EB=9E=98=ED=94=BD=20API?= =?UTF-8?q?=20=EC=84=9C=EB=B2=84=20=EC=95=84=EC=9D=B4=ED=94=BC=20=EC=B0=A8?= =?UTF-8?q?=EB=8B=A8=20=EC=98=88=EC=99=B8=20=EC=B2=98=EB=A6=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sqlmap/com/uss/olh/hpc/EgovHpcm_SQL_mysql.xml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/resources/egovframework/sqlmap/com/uss/olh/hpc/EgovHpcm_SQL_mysql.xml b/src/main/resources/egovframework/sqlmap/com/uss/olh/hpc/EgovHpcm_SQL_mysql.xml index d6767fb8..9145d8bf 100644 --- a/src/main/resources/egovframework/sqlmap/com/uss/olh/hpc/EgovHpcm_SQL_mysql.xml +++ b/src/main/resources/egovframework/sqlmap/com/uss/olh/hpc/EgovHpcm_SQL_mysql.xml @@ -364,8 +364,8 @@ ON A.IGNORE_IP = M2.CONECT_IP ) M3 WHERE M3.IGNORE_YN = 'N' - AND M3.CONECT_IP !='119.193.215.98' - AND M3.CONECT_IP !='139.150.70.79' + AND M3.CONECT_IP != '119.193.215.98' + AND M3.CONECT_IP != '139.150.70.79'