新增删除微信看课链接定时任务

fs-admin/src/main/java/com/fs/task/FsCompanyTask.java

@@ -1,13 +1,18 @@
 package com.fs.task;
 
+import com.fs.common.core.redis.RedisCache;
+import com.fs.common.utils.StringUtils;
 import com.fs.company.service.ICompanyService;
 import com.fs.company.vo.RedPacketMoneyVO;
 import com.fs.course.mapper.FsCourseRedPacketLogMapper;
 import lombok.AllArgsConstructor;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Component;
 
 import java.time.LocalDateTime;
 import java.util.List;
+import java.util.Set;
 
 @AllArgsConstructor
 @Component("companyTask")
@@ -16,6 +21,10 @@ public class FsCompanyTask {
     private FsCourseRedPacketLogMapper fsCourseRedPacketLogMapper;
     private ICompanyService companyService;
 
+    @Autowired
+    private StringRedisTemplate redisTemplate;
+    private static final String WX_URL_REDIS_PREFIX = "wx:link:";
+
     public void refreshCompanyMoney() {
         LocalDateTime now = LocalDateTime.now();
         // 获取上一个小时的开始时间
@@ -31,4 +40,17 @@ public class FsCompanyTask {
             companyService.subtractCompanyMoneyHourse(redPacketMoneyVO.getMoney(), redPacketMoneyVO.getCompanyId(), startTime.toLocalTime(), endTime.toLocalTime());
         }
     }
+
+
+    /**
+     * 重置redis中的微信看客跳转链接
+     */
+    public void clearWxUrlCache() {
+        Set<String> keys = redisTemplate.keys(WX_URL_REDIS_PREFIX + "*");
+        if (StringUtils.isNotEmpty(keys)) {
+            assert keys != null;
+            redisTemplate.delete(keys);
+        }
+    }
+
 }