工控网分析程序状态问题修复

yangys

2025-09-18 a3048fa6fa72fa3cc5da2c43c59bd000e00c9599

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

@@ -44,7 +44,7 @@

      if(!ParamService.NETWORK_TYPE_SHEMI.equals(networkType)){
         //非涉密网，才扫描目录文件
         moveOverTimeFiles();
         moveValidateFiles();
      }

   }
@@ -52,25 +52,26 @@
   /**
    * 扫描数据库记录，超时则移动文件
    */
   public void moveOverTimeFiles() {
   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){
         /*if(remainHours == 0){
            continue;
         }
         LocalDateTime earlyTime = now.minusHours(remainHours);
         List<MachineFile> overTimeFiles = this.machineFileService.lambdaQuery().lt(MachineFile::getFileCreateTime,earlyTime)
         }*/
         //LocalDateTime earlyTime = now.minusHours(remainHours);
         List<MachineFile> pendingFiles = this.machineFileService.lambdaQuery()
            .eq(MachineFile::getDirType,MachineFile.DIR_TYPE_REC)
            .eq(MachineFile::getExceptionType,MachineFile.EXCEPTION_OK)
            .eq(MachineFile::getMachineCode,machine.getCode()).list();
//.lt(MachineFile::getFileCreateTime,earlyTime)

         for(MachineFile overTimeFile : overTimeFiles){
         for(MachineFile overTimeFile : pendingFiles){
            try {
               moveFileToTemp(overTimeFile, machine);
            }catch(Exception e){
               log.error("移动rec文件失败:"+overTimeFile.getName(),e);
               log.error("移动rec文件失败:{}",overTimeFile.getName(),e);
            }
         }