Просмотр исходного кода

大盘分红定时任务参数判断是否为月份

mac 2 лет назад
Родитель
Сommit
0b3c2f551b

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

@@ -1,5 +1,6 @@
 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.stat.api.feign.RemoteKxsStatService;
@@ -31,6 +32,9 @@ public class StatBeanTask {
      */
     @SneakyThrows
     public String prizePoolSynchronization(String para) {
+        if(!NumberUtil.isNumber(para)){
+            para = "";
+        }
         remoteKxsStatService.shdUserTradeTotalList(para, SecurityConstants.FROM_IN);
         log.info("股东大盘分红积分计算任务:{},输入参数{}", LocalDateTime.now(), para);
         return SkyQuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();

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

@@ -1,5 +1,6 @@
 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.user.api.feign.RemoteKxsUserService;
@@ -57,6 +58,9 @@ public class UserBeanTask {
      */
     @SneakyThrows
     public String prizePoolSynchronization(String para) {
+        if(!NumberUtil.isNumber(para)){
+            para = "";
+        }
         remoteKxsUserService.prizePoolSynchronization(para, SecurityConstants.FROM_IN);
         log.info("股东大盘分红奖池同步交易额:{},输入参数{}", LocalDateTime.now(), para);
         return SkyQuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();