ddd

pom.xml

@@ -65,6 +65,16 @@
            <artifactId>mail</artifactId>
            <version>1.4</version>
        </dependency>
        <dependency>
        	<groupId>com.ekexiu</groupId>
        	<artifactId>decamino_nonames</artifactId>
        	<version>0.0.1</version>
        </dependency>
                <dependency>
        	<groupId>com.ekexiu</groupId>
        	<artifactId>decamino_nonames_rt</artifactId>
        	<version>0.0.1</version>
        </dependency>
    </dependencies>
    <build>
        <plugins>

src/main/java/com/ekexiu/project/log/SystemLogFactory.java

@@ -0,0 +1,13 @@
package com.ekexiu.project.log;
import org.jfw.util.log.LogFactory;
import org.jfw.util.log.Logger;
public class SystemLogFactory extends LogFactory {
	private static SystemLogger log = new SystemLogger();
	@Override
	public Logger getLogger(Class<?> clazz) {
		return log;
	}
}

src/main/java/com/ekexiu/project/log/SystemLogger.java

@@ -0,0 +1,93 @@
package com.ekexiu.project.log;
import org.jfw.util.log.Logger;
public class SystemLogger implements Logger {
	@Override
	public boolean isEnableTrace() {
		return true;
	}
	@Override
	public void trace(String message) {
		System.out.println(message);
	}
	@Override
	public void trace(String message, Throwable t) {
		System.err.println(message);
		t.printStackTrace(System.err);
	}
	@Override
	public boolean isEnableDebug() {
		return true;
	}
	@Override
	public void debug(String message) {
		System.err.println(message);
	}
	@Override
	public void debug(String message, Throwable t) {
		System.err.println(message);
		t.printStackTrace(System.err);
	}
	@Override
	public boolean isEnableInfo() {
		return true;
	}
	@Override
	public void info(String message) {
		System.err.println(message);
	}
	@Override
	public void info(String message, Throwable t) {
		System.err.println(message);
		t.printStackTrace(System.err);
	}
	@Override
	public boolean isEnableWarn() {
		return true;
	}
	@Override
	public void warn(String message) {
		System.err.println(message);
	}
	@Override
	public void warn(String message, Throwable t) {
		System.err.println(message);
		t.printStackTrace(System.err);
	}
	@Override
	public void error(String message) {
		System.err.println(message);
	}
	@Override
	public void error(String message, Throwable t) {
		System.err.println(message);
		t.printStackTrace(System.err);
	}
	@Override
	public void fatal(String message) {
		System.err.println(message);
	}
	@Override
	public void fatal(String message, Throwable t) {
		System.err.println(message);
		t.printStackTrace(System.err);
	}
}

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

@@ -0,0 +1,26 @@
package com.ekexiu.project.storage.diacrisis;
import org.jfw.util.log.LogFactory;
import org.jfw.util.log.Logger;
public class AiCleanTask implements Runnable{
	private static Logger LOG = LogFactory.getLog(AiCleanTask.class);
	private String taskId;
	private int taskType;
	private AiTaskService aiTaskService;
	
	
	public AiCleanTask(String taskId,int taskType,AiTaskService aiTaskService){
		this.taskId = taskId;
		this.taskType = taskType;
		this.aiTaskService = aiTaskService;
	}
	
	@Override
	public void run() {
		aiTaskService.updateTaskState(taskId, 399, null, new AiStrengthenTask(taskId, taskType, aiTaskService));
	}
}

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

@@ -0,0 +1,99 @@
package com.ekexiu.project.storage.diacrisis;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.InputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.LinkedList;
import java.util.concurrent.TimeUnit;
import org.jfw.util.ConstData;
import org.jfw.util.context.JfwAppContext;
import org.jfw.util.io.IoUtil;
import org.jfw.util.log.LogFactory;
import org.jfw.util.log.Logger;
public class AiDiacrisisTask implements Runnable {
	private static Logger LOG = LogFactory.getLog(AiDiacrisisTask.class);
	private static int processing = 2;
	private String urlPrefix = "http://192.168.3.114:5000/test?pi=";
	private static LinkedList<AiDiacrisisTask> queue = new LinkedList<AiDiacrisisTask>();
	private String taskId;
	private int taskType;
	private AiTaskService aiTaskService;
	public AiDiacrisisTask(String taskId, int taskType, AiTaskService aiTaskService) {
		this.taskId = taskId;
		this.taskType = taskType;
		this.aiTaskService = aiTaskService;
	}
	@Override
	public void run() {
		synchronized (AiDiacrisisTask.class) {
			if (AiDiacrisisTask.processing > 0) {
				AiDiacrisisTask.processing--;
			} else {
				AiDiacrisisTask.queue.add(this);
				return;
			}
		}
		aiTaskService.updateTaskState(taskId, 600, null, null);
		this.doRun();
		synchronized (AiDiacrisisTask.class) {
			AiDiacrisisTask.processing++;
			if (AiDiacrisisTask.queue.size() > 0) {
				AiDiacrisisTask next = AiDiacrisisTask.queue.pollLast();
				JfwAppContext.getScheduledExecutorService().schedule(next, 50, TimeUnit.MILLISECONDS);
			}
		}
	}
	private void doRun() {
		int nextState = 650;
		String nextStateCode = "ERR0599";
		File file = new File(aiTaskService.getDstPath(), taskId);
		if (file.exists() && file.isDirectory()) {
			try {
				URL u = new URL(urlPrefix + file.getAbsolutePath());
				HttpURLConnection httpURLConnection = (HttpURLConnection) u.openConnection();
				if (httpURLConnection.getResponseCode() == 200) {
					InputStream in = httpURLConnection.getInputStream();
					try {
						ByteArrayOutputStream out = new ByteArrayOutputStream();
						byte[] buf = new byte[128];
						int len = 0;
						while ((len = in.read(buf)) != -1) {
							if (len > 0) {
								out.write(buf, 0, len);
							}
						}
						buf = out.toByteArray();
						if (buf.length > 0) {
							String ret = new String(buf, ConstData.UTF8);
							ret = ret.trim();
							if (ret.equals("1")) {
								nextState = 699;
								nextStateCode = null;
							}
						}
					} catch (Exception e) {
					} finally {
						IoUtil.close(in);
					}
				} else {
					nextStateCode = "ERR0502";
				}
			} catch (Exception ee) {
			}
		}
		aiTaskService.updateTaskState(taskId, nextState, nextStateCode, null);
	}
}

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

@@ -0,0 +1,116 @@
package com.ekexiu.project.storage.diacrisis;
import java.awt.image.BufferedImage;
import java.io.File;
import java.io.IOException;
import javax.imageio.ImageIO;
import javax.imageio.ImageReader;
import javax.imageio.ImageWriter;
import javax.imageio.event.IIOReadWarningListener;
import javax.imageio.event.IIOWriteWarningListener;
import org.jfw.util.log.LogFactory;
import org.jfw.util.log.Logger;
import fr.apteryx.imageio.dicom.DicomReader;
public class AiFormatTask implements Runnable {
	private static Logger LOG = LogFactory.getLog(AiFormatTask.class);
	private String taskId;
	private int taskType;
	private AiTaskService aiTaskService;
	public AiFormatTask(String taskId, int taskType, AiTaskService aiTaskService) {
		this.taskId = taskId;
		this.taskType = taskType;
		this.aiTaskService = aiTaskService;
	}
	@Override
	public void run() {
		File file = new File(aiTaskService.getDstPath(), taskId);
		if (!file.exists()) {
			LOG.error("Path[" + file.getAbsolutePath() + "] not exists");
			aiTaskService.updateTaskState(taskId, 552, "ERR0403", null);
		} else {
			int begin, end;
			if (taskType == 1) {
				begin = 1;
				end = 7;
			} else if (taskType == 2) {
				begin = 7;
				end = 14;
			} else {
				LOG.error("err task type[" + taskType + "]");
				aiTaskService.updateTaskState(taskId, 552, "ERR0403", null);
				return;
			}
			for (int i = begin; i < end; ++i) {
				File src = new File(file, "IM_" + String.format("%04d.DICOM", i));
				if (!src.exists()) {
					LOG.error("Path[" + src.getAbsolutePath() + "] not exists");
					aiTaskService.updateTaskState(taskId, 552, "ERR0403", null);
					return;
				}
				File dst = new File(file, "ASD_" + String.format("%02d", i));
				if (dst.exists()) {
					LOG.error("Path[" + dst.getAbsolutePath() + "]  exists");
					aiTaskService.updateTaskState(taskId, 552, "ERR0403", null);
					return;
				}
				if (dst.mkdir()) {
					try {
						DicomReader reader = new DicomReader();
						reader.addIIOReadWarningListener(new WarningListener());
						reader.setInput(src);
						int nf = reader.getNumImages(true);
						if (nf <= 0) {
							LOG.error("file [" + src.getAbsolutePath() + "] invalid");
							aiTaskService.updateTaskState(taskId, 551, "ERR0402", null);
							return;
						}
						for (int k = 0; k < nf; ++k) {
							BufferedImage bi = reader.read(i);
							if (bi == null) {
								LOG.error("file [" + src.getAbsolutePath() + "] invalid");
								aiTaskService.updateTaskState(taskId, 551, "ERR0402", null);
								return;
							}
							File jpg = new File(dst, String.format("ASD_%02d_%03d.JPG", i, k));
							if (jpg.exists()) {
								LOG.error("file[" + jpg.getAbsolutePath() + "]  exists");
								aiTaskService.updateTaskState(taskId, 552, "ERR0403", null);
								return;
							}
							ImageIO.write(bi, "JPG", jpg);
						}
					} catch (Exception e) {
						aiTaskService.updateTaskState(taskId, 552, "ERR0403", null);
						return;
					}
				} else {
					LOG.error("makdir [" + dst.getAbsolutePath() + "] error");
					aiTaskService.updateTaskState(taskId, 552, "ERR0403", null);
					return;
				}
			}
		}
		aiTaskService.updateTaskState(taskId, 599, null, new AiDiacrisisTask(taskId, taskType, aiTaskService));
	}
}
class WarningListener implements IIOReadWarningListener, IIOWriteWarningListener {
	public void warningOccurred(ImageReader source, String warning) {
		System.err.println("READ WARNING: " + warning);
	}
	public void warningOccurred(ImageWriter source, int idx, String warning) {
		System.err.println("WRITE WARNING (image " + idx + "): " + warning);
	}
}

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

@@ -0,0 +1,26 @@
package com.ekexiu.project.storage.diacrisis;
import org.jfw.util.log.LogFactory;
import org.jfw.util.log.Logger;
public class AiStrengthenTask implements Runnable{
	private static Logger LOG = LogFactory.getLog(AiStrengthenTask.class);
	private String taskId;
	private int taskType;
	private AiTaskService aiTaskService;
	
	
	public AiStrengthenTask(String taskId,int taskType,AiTaskService aiTaskService){
		this.taskId = taskId;
		this.taskType = taskType;
		this.aiTaskService = aiTaskService;
	}
	
	@Override
	public void run() {
		aiTaskService.updateTaskState(taskId, 499, null, new AiFormatTask(taskId, taskType, aiTaskService));
	}
}

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

@@ -0,0 +1,110 @@
package com.ekexiu.project.storage.diacrisis;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.PrimaryKey;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.defaultImpl.FixLenStringHandler;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.project.storage.base.po.CreateTimeSupported;
@PrimaryKey("id")
@Table
public class AiTask implements CreateTimeSupported {
	private String id;
	private String dataNum;
	private String createTime;
	private int  taskType;
	private int  state;
	private String stateCode;
	private String uid;
	private String modifyTime;
	
	@Column(DE.id_32)
	public String getId() {
		return id;
	}
	public void setId(String id) {
		this.id = id;
	}
	@Column(value=DE.text_de,renewable=false)
	public String getDataNum() {
		return dataNum;
	}
	public void setDataNum(String dataNum) {
		this.dataNum = dataNum;
	}
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	@Column(value=DE.int_de,renewable=false)
	public int getTaskType() {
		return taskType;
	}
	public void setTaskType(int taskType) {
		this.taskType = taskType;
	}
	/**
	 *  100 submit  wait transfer queue
	 *  
	 *  200 transfering     
	 *  250 transfer error
	 *  299  transfer ok  wait 脱敏 queue
	 *  
	 *   300 脱敏ing
	 *   350  脱敏  error
	 *   399 脱敏ed    wait 增强 queue
	 *   
	 *   400 增强ing
	 *   450 增强 error
	 *   499 增强ed  wait 格式转换 queue
	 *   
	 *   500 格式转换ing
	 *   551 格式转换 error  with  invalid format
	 *   552 格式转换 error  with  IO
	 *   599 格式转换ed  wait 智能诊断  queue
	 *   
	 *   600  智能诊断ing
	 *   650   智能诊断 error
	 *   699   智能诊断ed
	 *  
	 *  
	 *  
	 *  
	 * @return
	 */
	@Column(value=DE.int_de)
	public int getState() {
		return state;
	}
	public void setState(int state) {
		this.state = state;
	}
	public String getStateCode() {
		return stateCode;
	}
	@Column(DE.Text_de)
	public void setStateCode(String stateCode) {
		this.stateCode = stateCode;
	}
	@Column(DE.refid_32)
	public String getUid() {
		return uid;
	}
	public void setUid(String uid) {
		this.uid = uid;
	}
	@Column(handlerClass = FixLenStringHandler.class, dbType = "CHAR(14)",fixSqlValueWithUpdate = "TO_CHAR(NOW(),'YYYYMMDDHH24MISS')", fixSqlValueWithInsert = "TO_CHAR(NOW(),'YYYYMMDDHH24MISS')", insertable = true, nullable = false, queryable = true, renewable = true)
	public String getModifyTime() {
		return modifyTime;
	}
	public void setModifyTime(String modifyTime) {
		this.modifyTime = modifyTime;
	}
	
	
	
}

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

@@ -0,0 +1,47 @@
package com.ekexiu.project.storage.diacrisis;
import java.sql.Connection;
import java.sql.SQLException;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.IncludeFixSet;
import org.jfw.apt.orm.annotation.dao.method.Or;
import org.jfw.apt.orm.annotation.dao.method.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.PageSelect;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.Set;
import org.jfw.util.PageQueryResult;
@DAO
public interface AiTaskDao {
	
	
	@Insert
	int insert(Connection con,AiTask task)throws SQLException;
	
	@IncludeFixSet
	@UpdateWith
	@SetSentence("STATE_CODE = NULL")
	@From(AiTask.class)
	int update(Connection con,String id,@Set int state) throws SQLException;
	
	@UpdateWith
	@From(AiTask.class)
	@IncludeFixSet
	int update(Connection con,String id,@Set int state,@Set String stateCode) throws SQLException;
	
	@PageSelect
	@OrderBy("ORDER BY CREATE_TIME DESC,ID DESC")
	PageQueryResult<AiTask> pageQuery(Connection con,String uid,@Nullable String dataNum,@Nullable Integer taskType,int pageSize,int pageNo)throws SQLException;
	
	@SelectOne
	@Nullable
	AiTask query(Connection con,String id)throws SQLException;
	
}

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

@@ -0,0 +1,164 @@
package com.ekexiu.project.storage.diacrisis;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.concurrent.TimeUnit;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.web.annotation.LoginUser;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.PathVar;
import org.jfw.util.PageQueryResult;
import org.jfw.util.StringUtil;
import org.jfw.util.context.JfwAppContext;
import org.jfw.util.io.IoUtil;
import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.log.LogFactory;
import org.jfw.util.log.Logger;
import com.ekexiu.project.storage.system.SessionUser;
@Path("/task")
public class AiTaskService {
	private static Logger LOG = LogFactory.getLog(AiTaskService.class);
	private long delayTime = 2000;
	@Autowrie
	private AiTaskDao aiTaskDao;
	private File srcPath = new File("/ekexiu/storage_asd/src");
	private File dstPath = new File("/ekexiu/storage_asd/dst");
	public File getSrcPath() {
		return srcPath;
	}
	public void setSrcPath(File srcPath) {
		this.srcPath = srcPath;
	}
	public File getDstPath() {
		return dstPath;
	}
	public void setDstPath(File dstPath) {
		this.dstPath = dstPath;
	}
	public AiTaskDao getAiTaskDao() {
		return aiTaskDao;
	}
	public void setAiTaskDao(AiTaskDao aiTaskDao) {
		this.aiTaskDao = aiTaskDao;
	}
	public boolean copyFile(File src, File dst) {
		try {
			if (src.exists() && (!dst.exists())) {
				InputStream in = null;
				OutputStream out = null;
				try {
					in = new FileInputStream(src);
					out = new FileOutputStream(dst);
					byte[] buf = new byte[4096];
					IoUtil.copy(in, out, buf);
					out.flush();
				} finally {
					if (in != null) {
						IoUtil.close(in);
					}
					if (out != null) {
						IoUtil.close(out);
					}
				}
				return true;
			}
		} catch (Exception e) {
		}
		return false;
	}
	public void updateTaskState(String id, int state, String stateCode, final Runnable runnable) {
		Connection con;
		try {
			con = JfwAppContext.getDataSource().getConnection();
			try {
				if (stateCode != null) {
					aiTaskDao.update(con, id, state, stateCode);
				} else {
					aiTaskDao.update(con, id, state);
				}
				con.commit();
				if (runnable != null) {
					JfwAppContext.getScheduledExecutorService().schedule(runnable, this.delayTime, TimeUnit.MILLISECONDS);
				}
			} catch (Exception e) {
				JdbcUtil.rollback(con);
			} finally {
				con.close();
			}
		} catch (Exception e1) {
		}
	}
	
   @Path("/add")
   @Get
   @Post
	public String insert(@JdbcConn(true) Connection con, @LoginUser SessionUser user, final String dataNum, final int taskType) throws SQLException {
		final String id = StringUtil.buildUUID();
		AiTask task = new AiTask();
		task.setDataNum(dataNum);
		task.setTaskType(taskType);
		task.setState(100);
		task.setStateCode(null);
		task.setId(id);
		task.setUid(user.getId());
		aiTaskDao.insert(con, task);
		
		JfwAppContext.getScheduledExecutorService().schedule(new Runnable() {
			@Override
			public void run() {
				updateTaskState(id, 200, null, new AiTransferTask(id, taskType,AiTaskService.this));
			}
		},this.delayTime,TimeUnit.MILLISECONDS);
		return id;
	}
   
   private static final String EMPTY_STRING_ARRAY[] = new String[0];
   @Get
   @Path("/pq")
   public PageQueryResult<AiTask> pageQuery(@JdbcConn Connection con,@LoginUser SessionUser user,@Nullable String dataNum,@Nullable Integer taskType,int pageSize,int pageNo) throws SQLException{
	   return aiTaskDao.pageQuery(con, user.getId(), dataNum, taskType, pageSize, pageNo);
   }
   @Get
   @Path("/result/{taskid}")
   public String[] getResult(@PathVar String taskid){
	   File path = new File(dstPath,taskid);
	   if(path.exists() && path.isDirectory()){
		   path = new File(path,"ASD_RESULT");
		   if(path.exists() && path.isDirectory()){
			   return path.list();
		   }
	   }
	   return EMPTY_STRING_ARRAY;
   }
   @Get
   @Path("/qo")
   public AiTask query(@JdbcConn Connection con,String id)throws SQLException{
	   return aiTaskDao.query(con, id);
   }
}

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

@@ -0,0 +1,62 @@
package com.ekexiu.project.storage.diacrisis;
import java.io.File;
import org.jfw.util.log.LogFactory;
import org.jfw.util.log.Logger;
public class AiTransferTask implements Runnable {
	private static Logger LOG = LogFactory.getLog(AiTransferTask.class);
	private String taskId;
	private int taskType;
	private AiTaskService aiTaskService;
	public AiTransferTask(String taskId, int taskType, AiTaskService aiTaskService) {
		this.taskId = taskId;
		this.taskType = taskType;
		this.aiTaskService = aiTaskService;
	}
	@Override
	public void run() {
		File file = new File(aiTaskService.getDstPath(), taskId);
		if (file.exists()) {
			LOG.error("Path[" + file.getAbsolutePath() + "] exists");
			aiTaskService.updateTaskState(taskId, 250, "ERR0199", null);
		} else {
			if (file.mkdir()) {
				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));
						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 {
				LOG.error("mkdir File[" + file.getAbsolutePath() + "] error");
				aiTaskService.updateTaskState(taskId, 250, "ERR0199", null);
			}
		}
	}
}

src/main/java/com/ekexiu/project/storage/servlet/StartupServlet.java

@@ -0,0 +1,17 @@
package com.ekexiu.project.storage.servlet;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import fr.apteryx.imageio.dicom.Plugin;
public class StartupServlet extends HttpServlet {
	private static final long serialVersionUID = 1L;
	@Override
	public void init() throws ServletException {
		super.init();
		 System.loadLibrary("decamino");
		Plugin.setLicenseKey("1758D1W8YEYL81675OA9ABHD");
	}
}

src/main/java/com/ekexiu/project/util/ScheduledExecutorServiceFactory.java

@@ -0,0 +1,23 @@
package com.ekexiu.project.util;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import org.jfw.apt.annotation.Bean;
@Bean
public class ScheduledExecutorServiceFactory {
	private int corePoolSize =10 ;
	public int getCorePoolSize() {
		return corePoolSize;
	}
	public void setCorePoolSize(int corePoolSize) {
		this.corePoolSize = corePoolSize;
	}
	
	public ScheduledExecutorService create(){
		return Executors.newScheduledThreadPool(this.corePoolSize);
	}
}

src/main/resources/META-INF/services/org.jfw.util.log.LogFactory

@@ -0,0 +1 @@
com.ekexiu.project.log.SystemLogFactory

src/main/resources/project.properties

@@ -1,33 +1,35 @@
scheduledExecutorService::factory=com_ekexiu_project_util_ScheduledExecutorServiceFactory
scheduledExecutorService.factory-method=create
dataSource=com.alibaba.druid.pool.DruidDataSource
#数据库连接地址、名称、密码
dataSource.url=jdbc:postgresql://192.168.3.233:5432/storage
#锟斤拷菘锟斤拷锟斤拷拥锟街凤拷锟斤拷锟狡★拷锟斤拷锟斤拷
dataSource.url=jdbc:postgresql://127.0.0.1:5432/storage
dataSource.username=postgres
dataSource.password=postgres
#连接池启动时的初始值（初始化连接）
#锟斤拷锟接筹拷锟斤拷锟斤拷时锟侥筹拷始值锟斤拷锟斤拷始锟斤拷锟斤拷锟接ｏ拷
dataSource.initialSize::int=1
#最小空闲连接值
#锟斤拷小锟斤拷锟斤拷锟斤拷锟斤拷值
dataSource.minIdle::int=1 
#连接池的最大值（最大连接数量）
#锟斤拷锟接池碉拷锟斤拷锟街碉拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷锟斤拷
dataSource.maxActive::int=1
#超时等待时间（maxWait代表当Connection用尽了，多久之后进行回收丢失连接）
#锟斤拷时锟饺达拷时锟戒（maxWait锟斤拷?Connection锟矫撅拷锟剿ｏ拷锟斤拷锟街�拷锟斤拷锟叫伙拷锟秸讹拷失锟斤拷锟接ｏ拷
dataSource.maxWait::long=60000
#连接超时任务的时间间隔
#���ӳ�ʱ�����ʱ����
dataSource.timeBetweenEvictionRunsMillis::long=60000
#连接的超时时间
#锟斤拷锟接的筹拷时时锟斤拷
dataSource.minEvictableIdleTimeMillis::long=300000  
#用来验证从连接池取出的连接
#锟斤拷锟斤拷锟斤拷证锟斤拷锟斤拷锟接筹拷取锟斤拷锟斤拷锟斤拷锟斤拷
dataSource.validationQuery=SELECT 1  
#指明连接是否被空闲连接回收器(如果有)进行检验.如果检测失败则连接将被从池中去除
#ָ�������Ƿ񱻿������ӻ�����(�����)���м���.�����ʧ�������ӽ����ӳ���ȥ��
dataSource.testWhileIdle::boolean=true
#在从池中取出连接前进行检验,如果检验失败则从池中去除连接并尝试取出另一个
#�ڴӳ���ȡ������ǰ���м���,������ʧ����ӳ���ȥ�����Ӳ�����ȡ����һ��
dataSource.testOnBorrow::boolean=true
#指明是否在归还到池中前进行检验
#指锟斤拷锟角凤拷锟节归还锟斤拷锟斤拷锟斤拷前锟斤拷锟叫硷拷锟斤拷
dataSource.testOnReturn::boolean=true   
#开启池的prepared statement 池功能
#锟斤拷锟斤拷锟截碉拷prepared statement 锟截癸拷锟斤拷
dataSource.poolPreparedStatements::boolean=true 
#statement池能够同时分配的打开的statements的最大数量
#statement���ܹ�ͬʱ����Ĵ򿪵�statements���������
dataSource.maxPoolPreparedStatementPerConnectionSize::int=20
#默认的SQL语句自动提交状态(开启或关闭)设置由连接池本身设置(false由连接池定)
#Ĭ�ϵ�SQL����Զ��ύ״̬(������ر�)���������ӳر�������(false�����ӳض�)
dataSource.defaultAutoCommit::boolean=false
com_ekexiu_project_storage_resource_service_StorageService.filePath::java.io.File=/kexiu/storage/data
com_ekexiu_project_storage_resource_service_StorageService.filePath::java.io.File=/ekexiu/storage/data

src/main/webapp/WEB-INF/web.xml

@@ -1,27 +1,29 @@
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
                      http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"
         version="3.0" metadata-complete="true">
    <servlet>
        <servlet-name>ajax</servlet-name>
        <servlet-class>org.jfw.web.servlet.core.FilenameConfigServlet</servlet-class>
        <init-param>
            <param-name>prefixLen</param-name>
            <param-value>14</param-value>
        </init-param>
        <init-param>
            <param-name>viewType</param-name>
            <param-value>1</param-value>
        </init-param>
        <init-param>
            <param-name>configFileName</param-name>
            <param-value>beanConfig.properties,project.properties</param-value>
        </init-param>
        <load-on-startup>1</load-on-startup>
    </servlet>
    <servlet-mapping>
        <servlet-name>ajax</servlet-name>
        <url-pattern>/ajax/*</url-pattern>
    </servlet-mapping>
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" metadata-complete="true" version="3.0">
  <servlet>
    <servlet-name>ajax</servlet-name>
    <servlet-class>org.jfw.web.servlet.core.FilenameConfigServlet</servlet-class>
    <init-param>
      <param-name>prefixLen</param-name>
      <param-value>14</param-value>
    </init-param>
    <init-param>
      <param-name>viewType</param-name>
      <param-value>1</param-value>
    </init-param>
    <init-param>
      <param-name>configFileName</param-name>
      <param-value>beanConfig.properties,project.properties</param-value>
    </init-param>
    <load-on-startup>1</load-on-startup>
  </servlet>
  <servlet>
  	<servlet-name>startupServlet</servlet-name>
  	<servlet-class>com.ekexiu.project.storage.servlet.StartupServlet</servlet-class>
  	<load-on-startup>2</load-on-startup>
  </servlet>
  <servlet-mapping>
    <servlet-name>ajax</servlet-name>
    <url-pattern>/ajax/*</url-pattern>
  </servlet-mapping>
</web-app>