全量更新

huzhou/src/main/java/com/easy/admin/modules/huzhou/controller/ExportController.java

@@ -6,6 +6,7 @@ import com.alibaba.excel.write.metadata.style.WriteCellStyle;
 import com.alibaba.excel.write.style.HorizontalCellStyleStrategy;
 import com.alibaba.excel.write.style.column.LongestMatchColumnWidthStyleStrategy;
 import com.easy.admin.common.api.vo.Result;
+import com.easy.admin.modules.huzhou.dao.ProjectScoreMapper;
 import com.easy.admin.modules.huzhou.dto.ProjectTimeOutInfoExportDTO;
 import com.easy.admin.modules.huzhou.dto.ProjectInfoExportDTO;
 import com.easy.admin.modules.huzhou.dto.ProjectResultExportDTO;
@@ -54,6 +55,8 @@ public class ExportController {
     @Resource
     private ProjectScoreService projectScoreService;
 
+    @Resource
+    private ProjectScoreMapper projectScoreMapper;
 
     @PostMapping("/upload")
     public void upload(MultipartFile file, HttpServletResponse response) throws IOException {
@@ -230,8 +233,8 @@ public class ExportController {
 
     @PostMapping("/uploadProjectScore")
     public void uploadProjectScore(MultipartFile file, HttpServletResponse response) throws IOException {
+        projectScoreMapper.delete(null);
         long t1 = System.currentTimeMillis();
-
         EasyExcel.read(file.getInputStream(), ProjectScore.class, new ProjectScoreListener(projectScoreService)).sheet().doRead();
 
         response.setContentType("text/html;charset=utf8");
@@ -239,4 +242,7 @@ public class ExportController {
         response.getWriter().println("导入数据成功!，共用时："+(t2-t1));
         log.info("导入项目评分数据成功! 共用时:{}ms",(t2-t1));
     }
+
+
+
 }

huzhou/src/main/java/com/easy/admin/modules/huzhou/controller/HuzhouProjectController.java

@@ -3,6 +3,7 @@ package com.easy.admin.modules.huzhou.controller;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 
+import com.easy.admin.common.constant.CommonConstant;
 import com.easy.admin.common.core.annotation.ResponseResult;
 import com.easy.admin.modules.huzhou.dto.ProjectResultExportDTO;
 import com.easy.admin.modules.huzhou.vo.*;
@@ -12,19 +13,23 @@ import com.easy.admin.common.api.vo.Result;
 import com.easy.admin.modules.huzhou.entity.*;
 import com.easy.admin.modules.huzhou.service.*;
 
+import lombok.extern.slf4j.Slf4j;
+import org.apache.shiro.util.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 
 
+import javax.annotation.Resource;
 import javax.servlet.http.HttpServletResponse;
 import java.io.IOException;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Objects;
 
-
+@Slf4j
 @RestController
 @RequestMapping("/huzhouProject")
 public class HuzhouProjectController {
@@ -492,4 +497,32 @@ public class HuzhouProjectController {
         List<ProjectContactShouYeOV> result = projectinfoService.projectContactShouYe();
         return Result.ok(result);
     }
+
+
+    @Resource
+    private StringRedisTemplate stringRedisTemplate;
+
+    /**
+     * 删除指定的 Redis Key
+     */
+    @DeleteMapping("/deleteRedisKey")
+    public Result<String> deleteRedisKey() {
+        String redisKey = CommonConstant.REDIS_KEY_PROJECT_BOARD_INFO;
+        if (StringUtils.hasText(redisKey)) {
+            Boolean isDeleted = stringRedisTemplate.delete(redisKey);
+            if (Boolean.TRUE.equals(isDeleted)) {
+                long startTime = System.currentTimeMillis();
+                String result = "Key [" + redisKey + "] 删除成功";
+                projectinfoService.queryBoardInfo();
+                long endTime = System.currentTimeMillis();
+                log.info("{},同步数据耗时{}ms",result,endTime-startTime);
+                return Result.ok("删除缓存成功,并更新最新数据!");
+            } else {
+                String result = "Key [" + redisKey + "] 不存在或删除失败";
+                return Result.error(result);
+            }
+        }
+        String result ="Key 不能为空";
+        return Result.ok(result);
+    }
 }