增加现场编制查询列表

yangys

2025-09-19 270aceade15ec4cb7715131055b53cec4ecb7d4e

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

@@ -37,19 +37,14 @@
    * 文件默认保存小时数，0不限制
    */
   private static final int DEFAULT_HOUR = 0;
   // 每5秒执行一次
   //@Scheduled(fixedRate = 1000000)
   //@Scheduled(cron = "0 1 0 * * ?") // 每天上午0点1分执行
   //@Scheduled(cron = "0 */3 * * * ?")
   //@Scheduled(cron = "0 15 19 * * ?") //test
   //@Scheduled(cron = "${task.cron.machine_file_scan}")

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

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

   }
@@ -57,24 +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);
            }
         }