diff --git a/huzhou/src/main/java/com/easy/admin/modules/huzhou/controller/ExportController.java b/huzhou/src/main/java/com/easy/admin/modules/huzhou/controller/ExportController.java index 2518923..4730f87 100644 --- a/huzhou/src/main/java/com/easy/admin/modules/huzhou/controller/ExportController.java +++ b/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)); } + + + } diff --git a/huzhou/src/main/java/com/easy/admin/modules/huzhou/controller/HuzhouProjectController.java b/huzhou/src/main/java/com/easy/admin/modules/huzhou/controller/HuzhouProjectController.java index a9d53ed..4dc2501 100644 --- a/huzhou/src/main/java/com/easy/admin/modules/huzhou/controller/HuzhouProjectController.java +++ b/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 result = projectinfoService.projectContactShouYe(); return Result.ok(result); } + + + @Resource + private StringRedisTemplate stringRedisTemplate; + + /** + * 删除指定的 Redis Key + */ + @DeleteMapping("/deleteRedisKey") + public Result 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); + } }