From 4116acf0dcd6a9f41e5e78de77b40227201c8504 Mon Sep 17 00:00:00 2001 From: MAC <1162714483@qq.com> Date: Wed, 27 Apr 2022 21:16:35 +0800 Subject: [PATCH] =?UTF-8?q?fix(=E6=96=87=E4=BB=B6=E4=B8=8A=E4=BC=A0):?= =?UTF-8?q?=E6=96=87=E4=BB=B6=E4=B8=8A=E4=BC=A0=E8=B7=AF=E5=BE=84=E6=A0=87?= =?UTF-8?q?=E5=87=86=E5=8C=96=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../file/controller/TaskController.java | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/qiwenshare/file/controller/TaskController.java b/src/main/java/com/qiwenshare/file/controller/TaskController.java index 0354ac9..d3dc8fc 100644 --- a/src/main/java/com/qiwenshare/file/controller/TaskController.java +++ b/src/main/java/com/qiwenshare/file/controller/TaskController.java @@ -1,9 +1,12 @@ package com.qiwenshare.file.controller; import co.elastic.clients.elasticsearch.ElasticsearchClient; +import com.qiwenshare.file.api.IShareFileService; import com.qiwenshare.file.component.FileDealComp; +import com.qiwenshare.file.domain.ShareFile; import com.qiwenshare.file.domain.UserFile; import com.qiwenshare.file.io.QiwenFile; +import com.qiwenshare.file.service.ShareFileService; import com.qiwenshare.file.service.UserFileService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; @@ -21,6 +24,8 @@ public class TaskController { UserFileService userFileService; @Resource FileDealComp fileDealComp; + @Resource + IShareFileService shareFileService; @Autowired private ElasticsearchClient elasticsearchClient; @@ -45,10 +50,19 @@ public class TaskController { public void updateFilePath() { List list = userFileService.list(); for (UserFile userFile : list) { - QiwenFile qiwenFile = new QiwenFile(userFile.getFilePath(), true); String path = QiwenFile.formatPath(userFile.getFilePath()); userFile.setFilePath(path); userFileService.updateById(userFile); } } + + @Scheduled(fixedRate = Long.MAX_VALUE) + public void updateShareFilePath() { + List list = shareFileService.list(); + for (ShareFile shareFile : list) { + String path = QiwenFile.formatPath(shareFile.getShareFilePath()); + shareFile.setShareFilePath(path); + shareFileService.updateById(shareFile); + } + } }