定时任务修改

ruoyi-framework/src/main/java/com/ruoyi/framework/web/service/Task.java

@@ -2,8 +2,10 @@ package com.ruoyi.framework.web.service;
 
 
 import com.ruoyi.common.constant.CommonConstants;
+import com.ruoyi.common.constant.Constants;
 import com.ruoyi.common.core.domain.entity.SysDept;
 import com.ruoyi.common.core.domain.entity.SysUser;
+import com.ruoyi.common.core.redis.RedisCache;
 import com.ruoyi.common.utils.DateUtils;
 import com.ruoyi.common.utils.StringUtils;
 import com.ruoyi.common.utils.jPush.JPushToolUtil;
@@ -33,6 +35,7 @@ import org.springframework.stereotype.Component;
 
 import java.text.ParseException;
 import java.util.*;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 import static com.ruoyi.common.constant.CommonConstants.ONE;
@@ -85,6 +88,9 @@ public class Task {
     @Autowired
     private FgwJdapDwMapper fgwJdapDwMapper;
 
+    @Autowired
+    private RedisCache redisCache;
+
 
     /***
      * 生成督办信息
@@ -902,6 +908,11 @@ public class Task {
             zsyzJzqkTs.setUpdateTime(DateUtils.getNowDate());
             zsyzJzqkTsMapper.insertZsyzJzqkTs(zsyzJzqkTs);
 
+            //存在说明30天内发过短信，则不发
+            String code = redisCache.getCacheObject(String.valueOf(sbbzb.getId()));
+            if(StringUtils.isNotEmpty(code)){
+                continue;
+            }
             //发送短信
             List<SendSmsConfig> sendSmsConfigs = new ArrayList<>();
             List<SysUser> sysUsers = sysUserService.selectUserByDeptId(sbbzb.getCjdId());
@@ -927,6 +938,7 @@ public class Task {
                 }
                 if (sendSmsConfigs.size() > 0) {
                     AsyncManager.me().execute(AsyncFactory.sendSms(sendSmsConfigs, "SMS_272615944"));
+                    redisCache.setCacheObject(String.valueOf(sbbzb.getId()),"1", 30, TimeUnit.DAYS);
                 }
             }