股东大盘分红定时任务打印错误日志

kxs-quartz/src/main/java/com/kxs/daemon/quartz/task/StatBeanTask.java

@@ -25,18 +25,22 @@ public class StatBeanTask {
 
 
     private final RemoteKxsStatService remoteKxsStatService;
+
     /**
      * 股东大盘分红积分计算任务
-     *
-     *
      */
     @SneakyThrows
     public String prizePoolSynchronization(String para) {
-        if(!NumberUtil.isNumber(para)){
-            para = "";
+        try {
+            if (!NumberUtil.isNumber(para)) {
+                para = "";
+            }
+            remoteKxsStatService.shdUserTradeTotalList(para, SecurityConstants.FROM_IN);
+            log.info("股东大盘分红积分计算任务:{}，输入参数{}", LocalDateTime.now(), para);
+            return SkyQuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
+        } catch (Exception e) {
+            log.error("股东大盘分红积分计算任务执行失败，输入参数{}：", para);
         }
-        remoteKxsStatService.shdUserTradeTotalList(para, SecurityConstants.FROM_IN);
-        log.info("股东大盘分红积分计算任务:{}，输入参数{}", LocalDateTime.now(), para);
-        return SkyQuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
+        return SkyQuartzEnum.JOB_LOG_STATUS_FAIL.getType();
     }
 }

kxs-quartz/src/main/java/com/kxs/daemon/quartz/task/UserBeanTask.java

@@ -3,6 +3,7 @@ package com.kxs.daemon.quartz.task;
 import cn.hutool.core.util.NumberUtil;
 import com.kxs.common.core.constant.SecurityConstants;
 import com.kxs.daemon.quartz.constants.SkyQuartzEnum;
+import com.kxs.daemon.quartz.exception.TaskException;
 import com.kxs.stat.api.feign.RemoteKxsStatService;
 import com.kxs.user.api.feign.RemoteKxsUserService;
 import lombok.RequiredArgsConstructor;
@@ -28,7 +29,7 @@ public class UserBeanTask {
     private final RemoteKxsStatService remoteKxsStatService;
 
     /**
-     *  自动表创建收支明细表任务
+     * 自动表创建收支明细表任务
      */
     @SneakyThrows
     public String automaticTableCreationTasks() {
@@ -39,14 +40,14 @@ public class UserBeanTask {
             remoteKxsStatService.autoStatTableCreationTasks(SecurityConstants.FROM_IN);
             return SkyQuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
 
-        }catch (Exception e){
+        } catch (Exception e) {
             log.error(e.getLocalizedMessage());
         }
         return SkyQuartzEnum.JOB_LOG_STATUS_FAIL.getType();
     }
 
     /**
-     *  用户欠款扣除定时任务
+     * 用户欠款扣除定时任务
      * 1.扫创客合伙人可提现额度，若有合伙人可提现额度，则扣除可提现额度，最大扣除金额=欠款总金额，扣除后减少欠款总金额，同时在前端增加扣除记录，备注为「预借款项还款」
      * 2.扫创客盟主可提现余额，若有盟主可提现余额，则扣除可提现余额，最大扣除金额=欠款总金额，扣除后减少欠款总金额，同时在前端增加扣除记录，备注为「预借款项还款」
      */
@@ -56,18 +57,24 @@ public class UserBeanTask {
         log.info("用户欠款扣除定时任务:{}，输入参数{}", LocalDateTime.now(), para);
         return SkyQuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
     }
+
     /**
-     *  奖池同步交易额
-     *  同步老系统交易额汇算奖金池
+     * 奖池同步交易额
+     * 同步老系统交易额汇算奖金池
      */
     @SneakyThrows
     public String prizePoolSynchronization(String para) {
-        if(!NumberUtil.isNumber(para)){
-            para = "";
+        try {
+            if (!NumberUtil.isNumber(para)) {
+                para = "";
+            }
+            remoteKxsUserService.prizePoolSynchronization(para, SecurityConstants.FROM_IN);
+            log.info("股东大盘分红奖池同步交易额:{}，输入参数{}", LocalDateTime.now(), para);
+            return SkyQuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
+        } catch (Exception e) {
+            log.error("定时任务股东大盘分红奖池同步交易额执行失败，输入参数{}：", para);
         }
-        remoteKxsUserService.prizePoolSynchronization(para, SecurityConstants.FROM_IN);
-        log.info("股东大盘分红奖池同步交易额:{}，输入参数{}", LocalDateTime.now(), para);
-        return SkyQuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
+        return SkyQuartzEnum.JOB_LOG_STATUS_FAIL.getType();
     }
 //    /**
 //     *  股东大盘分红职级汇算