修复文件状态读取问题

yangys

2025-09-23 72e6bac02526caebc3797a7c2934d12896805708

 blade-service/blade-mdm/src/main/java/org/springblade/mdm/task/ReceiveDirMoveTask.java

@@ -38,7 +38,8 @@
    */
   private static final int DEFAULT_HOUR = 0;

   @Scheduled(cron = "${task.cron.machine_rec_move:0 3 * * * ?}")
   //@Scheduled(cron = "${task.cron.machine_rec_move:0 3 * * * ?}")
   /*
   public void execute() {
      String networkType = paramService.getParamValue(ParamService.NETWORK_TYPE,ParamService.NETWORK_TYPE_SHEMI);

@@ -49,17 +50,13 @@

   }

   /**
    * 扫描数据库记录，超时则移动文件
    */

   public void moveValidateFiles() {
      List<Machine> machines = machineService.getEnableMachines();
      LocalDateTime now = LocalDateTime.now();
      for (Machine machine : machines) {
         int remainHours = machine.getReceiveDirExpiryHours() != null ?machine.getReceiveDirExpiryHours():DEFAULT_HOUR;
         /*if(remainHours == 0){
            continue;
         }*/

         //LocalDateTime earlyTime = now.minusHours(remainHours);
         List<MachineFile> pendingFiles = this.machineFileService.lambdaQuery()
            .eq(MachineFile::getDirType,MachineFile.DIR_TYPE_REC)
@@ -79,10 +76,6 @@

   }

   /**
    * 文件移动到temp
    * @param overTimeFile
    */
   private void moveFileToTemp(MachineFile overTimeFile,Machine machine) throws IOException {
      String srcFilepath = MachineFileService.getBasePath(machine,overTimeFile.getDirType())+ File.separator+overTimeFile.getName();
      Path source = Paths.get(srcFilepath);
@@ -100,4 +93,5 @@
      // 使用 REPLACE_EXISTING 选项来覆盖已存在的文件
      Files.move(source, target, StandardCopyOption.REPLACE_EXISTING);
   }
   */
}