1111

src/main/java/com/ekexiu/project/hdfs/HdfsService.java

@@ -6,6 +6,8 @@ import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
import org.apache.hadoop.hdfs.DistributedFileSystem;
import org.jfw.apt.annotation.Bean;
@Bean
public class HdfsService {
	private Configuration configuration = new Configuration();
	private DistributedFileSystem dfs;

src/main/java/com/ekexiu/project/storage/diacrisis/AiCleanTask.java

@@ -51,6 +51,9 @@ public class AiCleanTask implements Runnable{
							ret = ret.trim();
							if (ret.equals("1")) {
								aiTaskService.updateTaskState(taskId, 399, null, new AiStrengthenTask(taskId, taskType, aiTaskService));
								file = new File(aiTaskService.getDstPath(), taskId);
								file = new File(file,"data_desen");
								aiTaskService.uploadToHdfs(taskId,file);
								return;
							}
						}

src/main/java/com/ekexiu/project/storage/diacrisis/AiTaskService.java

@@ -25,6 +25,7 @@ import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.log.LogFactory;
import org.jfw.util.log.Logger;
import com.ekexiu.project.hdfs.HdfsService;
import com.ekexiu.project.storage.system.SessionUser;
@Path("/task")
@@ -33,12 +34,24 @@ public class AiTaskService {
	private static Logger LOG = LogFactory.getLog(AiTaskService.class);
	private long delayTime = 2000;
	
	@Autowrie
	private HdfsService hdfsService;
	@Autowrie
	private AiTaskDao aiTaskDao;
	private File srcPath = new File("/ekexiu/storage_asd/src");
	private File dstPath = new File("/ekexiu/storage_asd/dst");
	
	public HdfsService getHdfsService() {
		return hdfsService;
	}
	public void setHdfsService(HdfsService hdfsService) {
		this.hdfsService = hdfsService;
	}
	public File getSrcPath() {
		return srcPath;
	}
@@ -63,6 +76,17 @@ public class AiTaskService {
		this.aiTaskDao = aiTaskDao;
	}
	public void uploadToHdfs(final String dst,final File src){
		JfwAppContext.getScheduledExecutorService().submit(new Runnable() {
			@Override
			public void run() {
			    try{
			    	hdfsService.upload(dst, src);
			    }catch(Throwable tr){
			    }
			}
		});
	}
	public boolean copyFile(File src, File dst) {
		try {
			if (src.exists() && (!dst.exists())) {

src/main/java/com/ekexiu/project/storage/diacrisis/AiTransferTask.java

@@ -27,30 +27,16 @@ public class AiTransferTask implements Runnable {
		} else {
				file = new File(file,"data");
				if (file.mkdirs()) {
					if (taskType == 1) {
						for (int i = 1; i < 7; ++i) {
							File src = new File(aiTaskService.getSrcPath(), "IM_" + String.format("%04d.DICOM", i));
							File dst = new File(file, "IM_" + String.format("%04d.DICOM", i));
					for(String fn:aiTaskService.getSrcPath().list()){
						if(fn.length()>6 &&  fn.substring(fn.length()-6).equalsIgnoreCase(".DICOM")){
							File src = new File(aiTaskService.getSrcPath(), fn);
							File dst = new File(file, fn);
							if (!aiTaskService.copyFile(src, dst)) {
								LOG.error("copy File[" + src.getAbsolutePath() + "] error");
								aiTaskService.updateTaskState(taskId, 250, "ERR0199", null);
								return;
							}
						}
					} else if (taskType == 2) {
						for (int i = 7; i < 14; ++i) {
							File src = new File(aiTaskService.getSrcPath(), "IM_" + String.format("%04d.DICOM", i));
							File dst = new File(file, "IM_" + String.format("%04d.DICOM", i));
							if (!aiTaskService.copyFile(src, dst)) {
								LOG.error("copy File[" + src.getAbsolutePath() + "] error");
								aiTaskService.updateTaskState(taskId, 250, "ERR0199", null);
								return;
							}
						}
					} else {
						LOG.error("err task type[" + taskType + "]");
						aiTaskService.updateTaskState(taskId, 250, "ERR0199", null);
						return;
					}
					aiTaskService.updateTaskState(taskId, 299, null, new AiCleanTask(taskId, taskType, aiTaskService));
				} else {

src/main/resources/project.properties

@@ -32,4 +32,5 @@ dataSource.maxPoolPreparedStatementPerConnectionSize::int=20
#Ĭ�ϵ�SQL����Զ��ύ״̬(������ر�)���������ӳر�������(false�����ӳض�)
dataSource.defaultAutoCommit::boolean=false
com_ekexiu_project_storage_resource_service_StorageService.filePath::java.io.File=/ekexiu/storage/data
com_ekexiu_project_storage_resource_service_StorageService.filePath::java.io.File=/ekexiu/storage/data
com_ekexiu_project_hdfs_HdfsService.remoteUrl=hdfs://39.97.161.48:9000