资源模块附件上传功能。

src/main/java/com/ekexiu/portal/dao/AccessoryDao.java

@@ -0,0 +1,97 @@
package com.ekexiu.portal.dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
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.operator.DeleteWith;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import com.ekexiu.portal.po.Accessory;
import com.ekexiu.portal.po.Professor;
@DAO
public abstract class AccessoryDao {
	@Insert
	public abstract int insert(Connection con, Accessory accessory) throws SQLException;
	
	public List<Accessory> queryOper(Connection con, String operationId) throws SQLException {
        int _m_1 = 1;
        String sql = "SELECT ACCESSORY_ID,ACCESSORY_SRC,ACCESSORY.OPERATION_ID,ACCESSORY.PROFESSOR_ID,ACCESSORY_NAME,ACCESSORY.CREATE_TIME,PROFESSOR.NAME FROM ACCESSORY LEFT JOIN PROFESSOR ON ACCESSORY.PROFESSOR_ID = PROFESSOR.ID WHERE ACCESSORY.OPERATION_ID = ? ORDER BY ACCESSORY.CREATE_TIME";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,operationId);
            ResultSet rs = ps.executeQuery();
            try{
                List<Accessory> _result = new ArrayList<Accessory>();
                while(rs.next()){
                    Accessory _obj =  new Accessory();
                    _obj.setAccessoryId(rs.getString(1));
                    _obj.setAccessorySrc(rs.getString(2));
                    _obj.setOperationId(rs.getString(3));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(4));
                    String _m_2 = rs.getString(5);
                    if(rs.wasNull()){
                        _m_2 = null;
                    }
                    _obj.setAccessoryName(_m_2);
                    _obj.setCreateTime(rs.getString(6));
                    professor.setName(rs.getString(7));
                    _obj.setProfessor(professor);
                    _result.add(_obj);
                }
                return _result;
            }finally{
                try{rs.close();}catch(Exception _m_3){}
            }
        }finally{
            try{ps.close();}catch(Exception _m_4){}
        }
    }
	
	public List<Accessory> queryPro(Connection con, String professorId) throws SQLException {
        int _m_1 = 1;
        String sql = "SELECT ACCESSORY_ID,ACCESSORY_SRC,ACCESSORY.OPERATION_ID,ACCESSORY.PROFESSOR_ID,ACCESSORY_NAME,ACCESSORY.CREATE_TIME,PROFESSOR.NAME FROM ACCESSORY LEFT JOIN PROFESSOR ON ACCESSORY.PROFESSOR_ID = PROFESSOR.ID WHERE ACCESSORY.PROFESSOR_ID = ? ORDER BY ACCESSORY.CREATE_TIME";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,professorId);
            ResultSet rs = ps.executeQuery();
            try{
                List<Accessory> _result = new ArrayList<Accessory>();
                while(rs.next()){
                    Accessory _obj =  new Accessory();
                    _obj.setAccessoryId(rs.getString(1));
                    _obj.setAccessorySrc(rs.getString(2));
                    _obj.setOperationId(rs.getString(3));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(4));
                    String _m_2 = rs.getString(5);
                    if(rs.wasNull()){
                        _m_2 = null;
                    }
                    _obj.setAccessoryName(_m_2);
                    _obj.setCreateTime(rs.getString(6));
                    professor.setName(rs.getString(7));
                    _obj.setProfessor(professor);
                    _result.add(_obj);
                }
                return _result;
            }finally{
                try{rs.close();}catch(Exception _m_3){}
            }
        }finally{
            try{ps.close();}catch(Exception _m_4){}
        }
    }
	
	@DeleteWith
	@From(Accessory.class)
	public abstract int delete(Connection con, String accessoryId) throws SQLException;
}

src/main/java/com/ekexiu/portal/po/Accessory.java

@@ -0,0 +1,83 @@
package com.ekexiu.portal.po;
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.enums.DE;
import com.ekexiu.portal.basepo.CreateTimeSupported;
@PrimaryKey("accessoryId")
@Table
public class Accessory implements CreateTimeSupported {
	private String accessoryId;
	private String accessorySrc;
	private String operationId;
	private String professorId;
	private String createTime; 
	private String accessoryName;
	private Operation operation;
	private Professor professor;
	
	public Operation getOperation() {
		return operation;
	}
	public void setOperation(Operation operation) {
		this.operation = operation;
	}
	
	public Professor getProfessor() {
		return professor;
	}
	public void setProfessor(Professor professor) {
		this.professor = professor;
	}
	
	@Column(DE.id_32)
	public String getAccessoryId() {
		return accessoryId;
	}
	public void setAccessoryId(String accessoryId) {
		this.accessoryId = accessoryId;
	}
	
	@Column(DE.string_de)
	public String getAccessorySrc() {
		return accessorySrc;
	}
	public void setAccessorySrc(String accessorySrc) {
		this.accessorySrc = accessorySrc;
	}
	
	@Column(DE.id_32)
	public String getOperationId() {
		return operationId;
	}
	public void setOperationId(String operationId) {
		this.operationId = operationId;
	}
	
	@Column(DE.id_32)
	public String getProfessorId() {
		return professorId;
	}
	public void setProfessorId(String professorId) {
		this.professorId = professorId;
	}
	
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	
	@Column(DE.String_de)
	public String getAccessoryName() {
		return accessoryName;
	}
	public void setAccessoryName(String accessoryName) {
		this.accessoryName = accessoryName;
	}
	
}

src/main/java/com/ekexiu/portal/service/AccessoryService.java

@@ -0,0 +1,122 @@
package com.ekexiu.portal.service;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import org.jfw.apt.annotation.Autowrie;
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.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.io.IoUtil;
import com.ekexiu.portal.dao.AccessoryDao;
import com.ekexiu.portal.po.Accessory;
@Path("/accessory")
public class AccessoryService {
	private File tmpPath;
	private File accessoryPath;
	@Autowrie
	private AccessoryDao accessoryDao;
	public AccessoryDao getAccessoryDao() {
		return accessoryDao;
	}
	public void setAccessoryDao(AccessoryDao accessoryDao) {
		this.accessoryDao = accessoryDao;
	}
	
	
	public File getTmpPath() {
		return tmpPath;
	}
	public void setTmpPath(File tmpPath) {
		this.tmpPath = tmpPath;
	}
	public File getAccessoryPath() {
		return accessoryPath;
	}
	public void setAccessoryPath(File accessoryPath) {
		this.accessoryPath = accessoryPath;
	}
	
//	/**
//	 * 保存附件功能
//	 * @param fn 临时文件名
//	 * @param operationId 资源申请ID
//	 * @param fileName 文件名
//	 * @throws IOException
//	 * @throws JfwBaseException
//	 */
//	public void saveAccessory(String fn, String operationId, String fileName) throws IOException, JfwBaseException {
//		InputStream in = new FileInputStream(new File(this.tmpPath, fn));
//		//以月为单位创建时间目录
//		SimpleDateFormat df = new SimpleDateFormat("yyyy-MM");
//		String date = df.format(new Date());
//		String datePath = this.accessoryPath.getPath() + "/" +  date;
//		File dateFile = new File(datePath);
//		if (!datePath.exists()) {
//			// 创建日期目录
//			datePath.mkdir();
//		}
//		try {
//			IoUtil.copy(in, new FileOutputStream(new File(datePath, operationId + fileName)), false, true);
//		} finally {
//			in.close();
//		}
//	}
	@Post
	@Path("/save")
	public String insert(@JdbcConn(true) Connection con, String operationId, String professorId,  String fileName, 
			String fn) throws SQLException, IOException, JfwBaseException {
		InputStream in = new FileInputStream(new File(this.tmpPath, fn));
		SimpleDateFormat df = new SimpleDateFormat("yyyy-MM");
		String date = df.format(new Date());
		String datePath = this.accessoryPath + "/" +  date;
		String realFileName = operationId + "-" +fileName;
		File dateFile = new File(datePath);
		if (!dateFile.exists()) {
			// 创建日期目录
			dateFile.mkdir();
		}
		try {
			IoUtil.copy(in, new FileOutputStream(new File(dateFile, realFileName)), false, true);
		} finally {
			in.close();
		}
		String accessorySrc = datePath + "/" + realFileName;
		Accessory accessory = new Accessory();
		accessory.setAccessoryId(StringUtil.buildUUID());
		accessory.setAccessorySrc(accessorySrc);
		accessory.setOperationId(operationId);
		accessory.setProfessorId(professorId);
		accessory.setAccessoryName(fileName);
		this.accessoryDao.insert(con, accessory);
		return accessory.getAccessoryId();
	}
	
	@Get
	@Path("/qaoper")
	public List<Accessory> queryOper(@JdbcConn Connection con, String operationId) throws SQLException {
		return this.accessoryDao.queryOper(con, operationId);
	}
	
	@Get
	@Path("/qapro")
	public List<Accessory> quetyPro(@JdbcConn Connection con, String professorId) throws SQLException {
		return this.accessoryDao.queryPro(con, professorId);
	}
}