Browse Source

导入本地路径修改

wangliang 4 năm trước cách đây
mục cha
commit
6348cdab0a

+ 3 - 3
themis-business/src/main/java/com/qmth/themis/business/templete/TaskImportCommon.java

@@ -101,12 +101,12 @@ public class TaskImportCommon {
      */
     public File getUploadFile() {
         File file = null;
+        StringJoiner localPath = new StringJoiner("").add(SystemConstant.FILES_DIR).add(File.separator)
+                .add(this.path);
         if (Objects.nonNull(this.type) && Objects.equals(this.type, SystemConstant.LOCAL)) {
-            StringJoiner localPath = new StringJoiner("").add(SystemConstant.FILES_DIR).add(File.separator)
-                    .add(this.path);
             file = new File(localPath.toString());
         } else {
-            file = this.ossUtil.download(false, this.path, this.path);
+            file = this.ossUtil.download(false, this.path, localPath.toString());
         }
         return file;
     }

+ 2 - 0
themis-task/src/main/java/com/qmth/themis/task/start/StartRunning.java

@@ -1,6 +1,7 @@
 package com.qmth.themis.task.start;
 
 import com.qmth.themis.business.constant.SpringContextHolder;
+import com.qmth.themis.business.constant.SystemConstant;
 import com.qmth.themis.business.enums.MqGroupEnum;
 import com.qmth.themis.business.enums.MqTagEnum;
 import com.qmth.themis.mq.listener.RocketMessageConsumer;
@@ -110,6 +111,7 @@ public class StartRunning implements CommandLineRunner {
         //考试断点
         rocketMessageConsumer.setRocketMQConsumer(nameServer, dictionaryConfig.mqConfigDomain().getMap().get(MqGroupEnum.EXAM_BREAK_GROUP.name()), dictionaryConfig.mqConfigDomain().getTopic(), MqTagEnum.EXAM_BREAK.name(), MessageModel.CLUSTERING, SpringContextHolder.getBean(ExamBreakConcurrentlyImpl.class));
         rocketMessageConsumer.setRocketMQConsumer(nameServer, dictionaryConfig.mqConfigDomain().getMap().get(MqGroupEnum.EXAM_BREAK_DELAY_GROUP.name()), dictionaryConfig.mqConfigDomain().getTopic(), MqTagEnum.EXAM_BREAK_DELAY.name(), MessageModel.CLUSTERING, SpringContextHolder.getBean(ExamBreakDelayConcurrentlyImpl.class));
+        SystemConstant.initTempFiles();
         log.info("服务器启动时执行 end");
     }
 }