Ver Fonte

dcm文件后缀

zhangzhanping há 6 anos atrás
pai
commit
0aaa06076f

+ 4 - 4
src/main/java/com/zskk/dicom/monitor/monitors/NowFileChangeProc.java

@@ -35,7 +35,7 @@ public class NowFileChangeProc {
 //							if(file.renameTo(file)) {
 //								msg += "\r\n add to queue";
                             String absolutePath = file.getAbsolutePath();
-                          //  if(absolutePath.endsWith("txt")) {
+                            if(absolutePath.endsWith("dcm")) {
                                 Timer timer = new Timer();
                                 timer.schedule(new TimerTask() {
 
@@ -45,7 +45,7 @@ public class NowFileChangeProc {
                                         UploadsQueue.addCurrent(new File(absolutePath));
                                     }
                                 }, 1000);
-                        //   }
+                           }
                             Configs.sysLog.info(msg+"---------监听新文件夹创建");
                         }
 
@@ -59,7 +59,7 @@ public class NowFileChangeProc {
                         public void modify(File file) {
                             String msg = "File update \t" + file.getAbsolutePath();
                             String absolutePath = file.getAbsolutePath();
-                           // if(absolutePath.endsWith("txt")) {
+                            if(absolutePath.endsWith("dcm")) {
                                 Timer timer = new Timer();
                                 timer.schedule(new TimerTask() {
 
@@ -69,7 +69,7 @@ public class NowFileChangeProc {
                                         UploadsQueue.addCurrent(new File(absolutePath));
                                     }
                                 }, 1000);
-                        //  }
+                            }
                             Configs.sysLog.info(msg+"---------监听新文件夹移动");
                         }
                     });

+ 4 - 4
src/main/java/com/zskk/dicom/monitor/monitors/OldFileChangeProc.java

@@ -44,7 +44,7 @@ public class OldFileChangeProc{
 //								msg += "\r\n add to queue";
                             String absolutePath = file.getAbsolutePath();
                             //dcm 后缀
-                          //  if(absolutePath.endsWith("txt")) {
+                            if(absolutePath.endsWith("dcm")) {
                                 //定时器
                                 Timer timer = new Timer();
                                 timer.schedule(new TimerTask() {
@@ -55,7 +55,7 @@ public class OldFileChangeProc{
                                         UploadsQueue.addFail(new File(absolutePath));
                                     }
                                 }, 1000);
-                         //   }
+                            }
                             Configs.sysLog.info(msg+"---------监听重试文件夹创建");
                         }
 
@@ -69,7 +69,7 @@ public class OldFileChangeProc{
                         public void modify(File file) {
                             String msg = "File update \t" + file.getAbsolutePath();
                             String absolutePath = file.getAbsolutePath();
-                          //  if(absolutePath.endsWith("txt")) {
+                            if(absolutePath.endsWith("dcm")) {
                                 Timer timer = new Timer();
                                 timer.schedule(new TimerTask() {
 
@@ -79,7 +79,7 @@ public class OldFileChangeProc{
                                         UploadsQueue.addFail(new File(absolutePath));
                                     }
                                 }, 1000);
-                        //    }
+                            }
                             Configs.sysLog.info(msg+"---------监听重试文件夹移动");
                         }
                     });

+ 2 - 2
src/main/java/com/zskk/dicom/monitor/uploader/HistoryFileQuenuRunner.java

@@ -20,7 +20,7 @@ public class HistoryFileQuenuRunner implements Runnable {
     public void run() {
         //读取监控文件夹
         File dir = new File(Configs.monitorDir);
-        Iterator<File> its = FileUtils.iterateFiles(dir, new String[]{"txt"}, true);
+        Iterator<File> its = FileUtils.iterateFiles(dir, new String[]{"dcm"}, true);
         while(its.hasNext()){
             File file = its.next();
             if(file.exists() && file.isFile()) {
@@ -29,7 +29,7 @@ public class HistoryFileQuenuRunner implements Runnable {
         }
         //读取重试监控文件夹
         File dirRetry = new File(Configs.monitorRetryDir);
-        Iterator<File> itsRetry = FileUtils.iterateFiles(dirRetry, new String[]{"txt"}, true);
+        Iterator<File> itsRetry = FileUtils.iterateFiles(dirRetry, new String[]{"dcm"}, true);
         while(itsRetry.hasNext()){
             File file = itsRetry.next();
             if(file.exists() && file.isFile()) {

BIN
target/classes/com/zskk/dicom/monitor/monitors/NowFileChangeProc$1$1.class


BIN
target/classes/com/zskk/dicom/monitor/monitors/OldFileChangeProc$1$1.class


BIN
target/classes/com/zskk/dicom/monitor/uploader/HistoryFileQuenuRunner.class