新增算法定时任务

pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/newalgorithm/RMpEmissionFeignClient.java

@@ -0,0 +1,21 @@
+package com.njcn.prepare.harmonic.api.newalgorithm;
+
+
+import com.njcn.common.pojo.constant.ServerInfo;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.prepare.harmonic.api.newalgorithm.fallback.rMpEmissionFallbackFactory;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+@FeignClient(
+        value = ServerInfo.PREPARE_BOOT,
+        path = "/rMpEmissionM",
+        fallbackFactory = rMpEmissionFallbackFactory.class
+)
+public interface RMpEmissionFeignClient {
+
+    @PostMapping("rMpEmissionMHandler")
+    HttpResult<Boolean> rMpEmissionMHandler(@RequestBody LineParam jobParam);
+}

pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/newalgorithm/RMpInfluenceFeignClient.java

@@ -0,0 +1,23 @@
+package com.njcn.prepare.harmonic.api.newalgorithm;
+
+
+import com.njcn.common.pojo.constant.ServerInfo;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.prepare.harmonic.api.newalgorithm.fallback.rMpInfluenceFallbackFactory;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+@FeignClient(
+        value = ServerInfo.PREPARE_BOOT,
+        path = "/rMpInfluenceM",
+        fallbackFactory = rMpInfluenceFallbackFactory.class
+)
+public interface RMpInfluenceFeignClient {
+
+    @ApiOperation("影响特性(r_mp_emission_m表数据)")
+    @PostMapping("rMpInfluenceMHandler")
+    HttpResult<Boolean> rMpInfluenceMHandler(@RequestBody LineParam jobParam);
+}

pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/newalgorithm/fallback/rMpEmissionFallbackFactory.java

@@ -0,0 +1,33 @@
+package com.njcn.prepare.harmonic.api.newalgorithm.fallback;
+
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.exception.BusinessException;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.prepare.harmonic.api.newalgorithm.RMpEmissionFeignClient;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.prepare.harmonic.utils.PrepareEnumUtil;
+import feign.hystrix.FallbackFactory;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class rMpEmissionFallbackFactory implements FallbackFactory<RMpEmissionFeignClient> {
+    @Override
+    public RMpEmissionFeignClient create(Throwable throwable) {
+        Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
+        if (throwable.getCause() instanceof BusinessException) {
+            BusinessException businessException = (BusinessException)throwable.getCause();
+            exceptionEnum = PrepareEnumUtil.getExceptionEnum(businessException.getResult());
+        }
+
+        Enum<?> finalExceptionEnum = exceptionEnum;
+        return new RMpEmissionFeignClient() {
+            @Override
+            public HttpResult<Boolean> rMpEmissionMHandler(LineParam jobParam) {
+                log.error("{}异常，降级处理，异常为：{}", "发射特性:  ", throwable.toString());
+                throw new BusinessException(finalExceptionEnum);
+            }
+        };
+    }
+}

pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/newalgorithm/fallback/rMpInfluenceFallbackFactory.java

@@ -0,0 +1,33 @@
+package com.njcn.prepare.harmonic.api.newalgorithm.fallback;
+
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.exception.BusinessException;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.prepare.harmonic.api.newalgorithm.RMpInfluenceFeignClient;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.prepare.harmonic.utils.PrepareEnumUtil;
+import feign.hystrix.FallbackFactory;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class rMpInfluenceFallbackFactory implements FallbackFactory<RMpInfluenceFeignClient> {
+    @Override
+    public RMpInfluenceFeignClient create(Throwable throwable) {
+        Enum<?> exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK;
+        if (throwable.getCause() instanceof BusinessException) {
+            BusinessException businessException = (BusinessException)throwable.getCause();
+            exceptionEnum = PrepareEnumUtil.getExceptionEnum(businessException.getResult());
+        }
+
+        Enum<?> finalExceptionEnum = exceptionEnum;
+        return new RMpInfluenceFeignClient() {
+            @Override
+            public HttpResult<Boolean> rMpInfluenceMHandler(LineParam jobParam) {
+                log.error("{}异常，降级处理，异常为：{}", "影响特性:  ", throwable.toString());
+                throw new BusinessException(finalExceptionEnum);
+            }
+        };
+    }
+}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpEmissionTaskRunner.java

@@ -0,0 +1,66 @@
+package com.njcn.system.timer.tasks;
+
+import cn.hutool.core.util.StrUtil;
+import com.njcn.common.pojo.constant.BizParamConstant;
+import com.njcn.prepare.harmonic.api.newalgorithm.RMpEmissionFeignClient;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.system.timer.TimerTaskRunner;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.text.SimpleDateFormat;
+import java.time.LocalDateTime;
+import java.util.Calendar;
+import java.util.Objects;
+
+/**
+ * 类的介绍：发射特性定时任务
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/12/20 13:55
+ */
+@Component
+@RequiredArgsConstructor
+@Slf4j
+public class RMpEmissionTaskRunner implements TimerTaskRunner {
+
+    private final RMpEmissionFeignClient rMpEmissionFeignClient;
+
+    @Override
+    public void action() {
+        log.info(LocalDateTime.now()+"发射特性调度开始");
+        LineParam lineParam = new LineParam();
+        lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
+        lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
+        rMpEmissionFeignClient.rMpEmissionMHandler(lineParam);
+    }
+
+    public String prepareTimeDeal(String command) {
+        if (StrUtil.isBlank(command)) {
+            log.error(LocalDateTime.now() + "xxl调度任务参数未设置");
+            return null;
+        }
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        Calendar calendar = Calendar.getInstance();
+        if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) {
+            calendar.add(Calendar.DAY_OF_MONTH, -1);
+        } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) {
+            calendar.set(Calendar.DAY_OF_MONTH, 1);
+        } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) {
+            int nowMonth = calendar.get(Calendar.MONTH);
+            calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3));
+            calendar.set(Calendar.DAY_OF_MONTH, 1);
+            calendar.set(Calendar.HOUR_OF_DAY, 0);
+            calendar.set(Calendar.MINUTE, 0);
+            calendar.set(Calendar.SECOND, 0);
+            calendar.set(Calendar.MILLISECOND, 0);
+        } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) {
+            calendar.set(Calendar.DAY_OF_YEAR, 1);
+        }
+        log.info("job调度时间:" + sdf.format(calendar.getTime()));
+        return sdf.format(calendar.getTime());
+    }
+
+}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpInfluenceTaskRunner.java

@@ -0,0 +1,66 @@
+package com.njcn.system.timer.tasks;
+
+import cn.hutool.core.util.StrUtil;
+import com.njcn.common.pojo.constant.BizParamConstant;
+import com.njcn.prepare.harmonic.api.newalgorithm.RMpInfluenceFeignClient;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.system.timer.TimerTaskRunner;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.text.SimpleDateFormat;
+import java.time.LocalDateTime;
+import java.util.Calendar;
+import java.util.Objects;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/12/20 14:12
+ */
+@Component
+@RequiredArgsConstructor
+@Slf4j
+public class RMpInfluenceTaskRunner implements TimerTaskRunner {
+
+    private final RMpInfluenceFeignClient rMpInfluenceFeignClient;
+
+    @Override
+    public void action() {
+        log.info(LocalDateTime.now()+"影响特性调度开始");
+        LineParam lineParam = new LineParam();
+        lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
+        lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
+        rMpInfluenceFeignClient.rMpInfluenceMHandler(lineParam);
+    }
+
+    public String prepareTimeDeal(String command) {
+        if (StrUtil.isBlank(command)) {
+            log.error(LocalDateTime.now() + "xxl调度任务参数未设置");
+            return null;
+        }
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        Calendar calendar = Calendar.getInstance();
+        if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) {
+            calendar.add(Calendar.DAY_OF_MONTH, -1);
+        } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) {
+            calendar.set(Calendar.DAY_OF_MONTH, 1);
+        } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) {
+            int nowMonth = calendar.get(Calendar.MONTH);
+            calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3));
+            calendar.set(Calendar.DAY_OF_MONTH, 1);
+            calendar.set(Calendar.HOUR_OF_DAY, 0);
+            calendar.set(Calendar.MINUTE, 0);
+            calendar.set(Calendar.SECOND, 0);
+            calendar.set(Calendar.MILLISECOND, 0);
+        } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) {
+            calendar.set(Calendar.DAY_OF_YEAR, 1);
+        }
+        log.info("job调度时间:" + sdf.format(calendar.getTime()));
+        return sdf.format(calendar.getTime());
+    }
+
+}

pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/specialAnalysisIndexOverviewTaskRunner.java

@@ -0,0 +1,66 @@
+package com.njcn.system.timer.tasks;
+
+import cn.hutool.core.util.StrUtil;
+import com.njcn.common.pojo.constant.BizParamConstant;
+import com.njcn.prepare.harmonic.api.specialanalysis.SpecialAnalysisFeignClient;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.system.timer.TimerTaskRunner;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.text.SimpleDateFormat;
+import java.time.LocalDateTime;
+import java.util.Calendar;
+import java.util.Objects;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/12/20 14:15
+ */
+@Component
+@RequiredArgsConstructor
+@Slf4j
+public class specialAnalysisIndexOverviewTaskRunner implements TimerTaskRunner {
+
+    private final SpecialAnalysisFeignClient specialAnalysisFeignClient;
+
+    @Override
+    public void action() {
+        log.info(LocalDateTime.now()+"专项分析-指标总览开始执行");
+        LineParam lineParam = new LineParam();
+        lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
+        lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
+        specialAnalysisFeignClient.hanlder(lineParam);
+    }
+
+    public String prepareTimeDeal(String command) {
+        if (StrUtil.isBlank(command)) {
+            log.error(LocalDateTime.now() + "xxl调度任务参数未设置");
+            return null;
+        }
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        Calendar calendar = Calendar.getInstance();
+        if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) {
+            calendar.add(Calendar.DAY_OF_MONTH, -1);
+        } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) {
+            calendar.set(Calendar.DAY_OF_MONTH, 1);
+        } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) {
+            int nowMonth = calendar.get(Calendar.MONTH);
+            calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3));
+            calendar.set(Calendar.DAY_OF_MONTH, 1);
+            calendar.set(Calendar.HOUR_OF_DAY, 0);
+            calendar.set(Calendar.MINUTE, 0);
+            calendar.set(Calendar.SECOND, 0);
+            calendar.set(Calendar.MILLISECOND, 0);
+        } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) {
+            calendar.set(Calendar.DAY_OF_YEAR, 1);
+        }
+        log.info("job调度时间:" + sdf.format(calendar.getTime()));
+        return sdf.format(calendar.getTime());
+    }
+
+}