From d7c76d52e4e6882f19f6b3b3bf2cc11d119837dd Mon Sep 17 00:00:00 2001 From: xuyang <748613696@qq.com> Date: Wed, 20 Dec 2023 14:48:43 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../timer/tasks/RMpEmissionTaskRunner.java | 47 +++++++++++++++++++ .../timer/tasks/RMpInfluenceTaskRunner.java | 47 +++++++++++++++++++ ...pecialAnalysisIndexOverviewTaskRunner.java | 47 +++++++++++++++++++ 3 files changed, 141 insertions(+) diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpEmissionTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpEmissionTaskRunner.java index 3d3ccd5a4..2eb98d7b1 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpEmissionTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpEmissionTaskRunner.java @@ -1,5 +1,6 @@ package com.njcn.system.timer.tasks; +import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.StrUtil; import com.njcn.common.pojo.constant.BizParamConstant; import com.njcn.prepare.harmonic.api.newalgorithm.RMpEmissionFeignClient; @@ -12,6 +13,7 @@ import org.springframework.stereotype.Component; import java.text.SimpleDateFormat; import java.time.LocalDateTime; import java.util.Calendar; +import java.util.Date; import java.util.Objects; /** @@ -34,6 +36,7 @@ public class RMpEmissionTaskRunner implements TimerTaskRunner { LineParam lineParam = new LineParam(); lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); + this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam); rMpEmissionFeignClient.rMpEmissionMHandler(lineParam); } @@ -63,4 +66,48 @@ public class RMpEmissionTaskRunner implements TimerTaskRunner { return sdf.format(calendar.getTime()); } + /** + * 根据xxl-job的参数，生成一个任务的起始时间和结束时间 + * + * @author cdf + * @date 2023/9/20 + */ + public void commDefineDate(String command, LineParam lineParam) { + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String begin; + String end; + Calendar calendar = Calendar.getInstance(); + calendar.add(Calendar.DAY_OF_MONTH, -1); + Date temDate = calendar.getTime(); + switch (command) { + case BizParamConstant.STAT_BIZ_DAY: + begin = sdf.format(DateUtil.beginOfDay(temDate)); + end = sdf.format(DateUtil.endOfDay(temDate)); + break; + case BizParamConstant.STAT_BIZ_WEEK: + begin = sdf.format(DateUtil.beginOfWeek(temDate)); + end = sdf.format(DateUtil.endOfWeek(temDate)); + break; + case BizParamConstant.STAT_BIZ_MONTH: + begin = sdf.format(DateUtil.beginOfMonth(temDate)); + end = sdf.format(DateUtil.endOfMonth(temDate)); + break; + case BizParamConstant.STAT_BIZ_QUARTER: + begin = sdf.format(DateUtil.beginOfQuarter(temDate)); + end = sdf.format(DateUtil.endOfQuarter(temDate)); + break; + case BizParamConstant.STAT_BIZ_YEAR: + begin = sdf.format(DateUtil.beginOfYear(temDate)); + end = sdf.format(DateUtil.endOfYear(temDate)); + break; + default: + begin = sdf.format(DateUtil.beginOfDay(temDate)); + end = sdf.format(DateUtil.endOfDay(temDate)); + break; + } + lineParam.setBeginTime(begin); + lineParam.setEndTime(end); + lineParam.setDataDate(begin.substring(0, 10)); + } + } diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpInfluenceTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpInfluenceTaskRunner.java index 0f05f1782..0220bffd7 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpInfluenceTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpInfluenceTaskRunner.java @@ -1,5 +1,6 @@ package com.njcn.system.timer.tasks; +import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.StrUtil; import com.njcn.common.pojo.constant.BizParamConstant; import com.njcn.prepare.harmonic.api.newalgorithm.RMpInfluenceFeignClient; @@ -12,6 +13,7 @@ import org.springframework.stereotype.Component; import java.text.SimpleDateFormat; import java.time.LocalDateTime; import java.util.Calendar; +import java.util.Date; import java.util.Objects; /** @@ -34,6 +36,7 @@ public class RMpInfluenceTaskRunner implements TimerTaskRunner { LineParam lineParam = new LineParam(); lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); + this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam); rMpInfluenceFeignClient.rMpInfluenceMHandler(lineParam); } @@ -63,4 +66,48 @@ public class RMpInfluenceTaskRunner implements TimerTaskRunner { return sdf.format(calendar.getTime()); } + /** + * 根据xxl-job的参数，生成一个任务的起始时间和结束时间 + * + * @author cdf + * @date 2023/9/20 + */ + public void commDefineDate(String command, LineParam lineParam) { + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String begin; + String end; + Calendar calendar = Calendar.getInstance(); + calendar.add(Calendar.DAY_OF_MONTH, -1); + Date temDate = calendar.getTime(); + switch (command) { + case BizParamConstant.STAT_BIZ_DAY: + begin = sdf.format(DateUtil.beginOfDay(temDate)); + end = sdf.format(DateUtil.endOfDay(temDate)); + break; + case BizParamConstant.STAT_BIZ_WEEK: + begin = sdf.format(DateUtil.beginOfWeek(temDate)); + end = sdf.format(DateUtil.endOfWeek(temDate)); + break; + case BizParamConstant.STAT_BIZ_MONTH: + begin = sdf.format(DateUtil.beginOfMonth(temDate)); + end = sdf.format(DateUtil.endOfMonth(temDate)); + break; + case BizParamConstant.STAT_BIZ_QUARTER: + begin = sdf.format(DateUtil.beginOfQuarter(temDate)); + end = sdf.format(DateUtil.endOfQuarter(temDate)); + break; + case BizParamConstant.STAT_BIZ_YEAR: + begin = sdf.format(DateUtil.beginOfYear(temDate)); + end = sdf.format(DateUtil.endOfYear(temDate)); + break; + default: + begin = sdf.format(DateUtil.beginOfDay(temDate)); + end = sdf.format(DateUtil.endOfDay(temDate)); + break; + } + lineParam.setBeginTime(begin); + lineParam.setEndTime(end); + lineParam.setDataDate(begin.substring(0, 10)); + } + } diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/specialAnalysisIndexOverviewTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/specialAnalysisIndexOverviewTaskRunner.java index bfa96cb3b..f51749985 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/specialAnalysisIndexOverviewTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/specialAnalysisIndexOverviewTaskRunner.java @@ -1,5 +1,6 @@ package com.njcn.system.timer.tasks; +import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.StrUtil; import com.njcn.common.pojo.constant.BizParamConstant; import com.njcn.prepare.harmonic.api.specialanalysis.SpecialAnalysisFeignClient; @@ -12,6 +13,7 @@ import org.springframework.stereotype.Component; import java.text.SimpleDateFormat; import java.time.LocalDateTime; import java.util.Calendar; +import java.util.Date; import java.util.Objects; /** @@ -34,6 +36,7 @@ public class specialAnalysisIndexOverviewTaskRunner implements TimerTaskRunner { LineParam lineParam = new LineParam(); lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); + this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam); specialAnalysisFeignClient.hanlder(lineParam); } @@ -63,4 +66,48 @@ public class specialAnalysisIndexOverviewTaskRunner implements TimerTaskRunner { return sdf.format(calendar.getTime()); } + /** + * 根据xxl-job的参数，生成一个任务的起始时间和结束时间 + * + * @author cdf + * @date 2023/9/20 + */ + public void commDefineDate(String command, LineParam lineParam) { + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String begin; + String end; + Calendar calendar = Calendar.getInstance(); + calendar.add(Calendar.DAY_OF_MONTH, -1); + Date temDate = calendar.getTime(); + switch (command) { + case BizParamConstant.STAT_BIZ_DAY: + begin = sdf.format(DateUtil.beginOfDay(temDate)); + end = sdf.format(DateUtil.endOfDay(temDate)); + break; + case BizParamConstant.STAT_BIZ_WEEK: + begin = sdf.format(DateUtil.beginOfWeek(temDate)); + end = sdf.format(DateUtil.endOfWeek(temDate)); + break; + case BizParamConstant.STAT_BIZ_MONTH: + begin = sdf.format(DateUtil.beginOfMonth(temDate)); + end = sdf.format(DateUtil.endOfMonth(temDate)); + break; + case BizParamConstant.STAT_BIZ_QUARTER: + begin = sdf.format(DateUtil.beginOfQuarter(temDate)); + end = sdf.format(DateUtil.endOfQuarter(temDate)); + break; + case BizParamConstant.STAT_BIZ_YEAR: + begin = sdf.format(DateUtil.beginOfYear(temDate)); + end = sdf.format(DateUtil.endOfYear(temDate)); + break; + default: + begin = sdf.format(DateUtil.beginOfDay(temDate)); + end = sdf.format(DateUtil.endOfDay(temDate)); + break; + } + lineParam.setBeginTime(begin); + lineParam.setEndTime(end); + lineParam.setDataDate(begin.substring(0, 10)); + } + }