添加先删后入的redisKey逻辑

data-service/src/main/java/com/zksy/data/controller/TestController.java

@@ -13,6 +13,8 @@ import com.zksy.data.utils.RedisService;
 import com.zksy.data.utils.XhRequestUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
@@ -229,6 +231,9 @@ public class TestController {
     private XcrMajorMembersService xcrMajorMembersService;
     @Autowired
     private XcrAnSfcBranchinfoService xcrAnSfcBranchinfoService;
+    @Autowired
+    private RedisTemplate redisTemplate;
+
     @GetMapping("/a")
     public String hello(){
         executeServiceCall(() -> xcrCompanyInvestmentService.saveDataByUniCode("gateway/api/1/getGdjczxgxxByUniscid"), "gateway/api/1/getGdjczxgxxByUniscid");
@@ -423,8 +428,10 @@ public class TestController {
         }
         List<XcrEBaseinfo> xcrEBaseinfos = BeanUtil.copyToList(baseinfoAll.getData(), XcrEBaseinfo.class);
         List<String> list = xcrEBaseinfos.stream().map(XcrEBaseinfo::getUniscid).filter(StrUtil::isNotBlank).collect(Collectors.toList());
+        redisTemplate.delete("creditCodes");
         redisService.saveList("creditCodes",list);
         List<String> list2 = xcrEBaseinfos.stream().map(XcrEBaseinfo::getEntname).filter(StrUtil::isNotBlank).collect(Collectors.toList());
+        redisTemplate.delete("creditNames");
         redisService.saveList("creditNames",list2);
         return "成功";
     }

data-service/src/main/java/com/zksy/data/schedule/PrepareCreditKeySchedule.java

@@ -8,6 +8,7 @@ import com.zksy.common.domain.Result;
 import com.zksy.data.domain.po.XcrEBaseinfo;
 import com.zksy.data.utils.RedisService;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
@@ -23,6 +24,8 @@ public class PrepareCreditKeySchedule {
     private RedisService redisService;
     @Autowired
     private TableDataClient tableDataClient;
+    @Autowired
+    private RedisTemplate redisTemplate;
     //一天一次
     @Scheduled(cron = "0 0 0 * * ?")
     public void prepareCreditKey() {
@@ -32,8 +35,10 @@ public class PrepareCreditKeySchedule {
         }
         List<XcrEBaseinfo> xcrEBaseinfos = BeanUtil.copyToList(baseinfoAll.getData(), XcrEBaseinfo.class);
         List<String> list = xcrEBaseinfos.stream().map(XcrEBaseinfo::getUniscid).filter(StrUtil::isNotBlank).collect(Collectors.toList());
+        redisTemplate.delete("creditCodes");
         redisService.saveList("creditCodes",list);
         List<String> list2 = xcrEBaseinfos.stream().map(XcrEBaseinfo::getEntname).filter(StrUtil::isNotBlank).collect(Collectors.toList());
+        redisTemplate.delete("creditNames");
         redisService.saveList("creditNames",list2);
     }
 }