11

src/main/java/com/ekexiu/project/storage/resource/dao/StorageDao.java

@@ -6,6 +6,7 @@ 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.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.SetSentence;
import org.jfw.apt.orm.annotation.dao.method.operator.DeleteWith;
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.UpdateWith;
@@ -28,6 +29,10 @@ public interface StorageDao {
    @SetSentence("active = '0'")
    int logicDelete(Connection con, String id) throws SQLException;
    @DeleteWith
    @From(Storage.class)
    int delete(Connection con, String id) throws SQLException;
    @PageSelect
    @OrderBy("ORDER BY CREATE_TIME DESC")
     PageQueryResult<Storage> pageQuery(Connection con, @Nullable Boolean active, int pageSize, int pageNo) throws SQLException;

src/main/java/com/ekexiu/project/storage/resource/service/StorageService.java

@@ -51,6 +51,14 @@ public class StorageService {
        this.filePath = filePath;
    }
    /**
     * 文件上传
     * @param con
     * @param user
     * @param it
     * @return
     * @throws Exception
     */
    @Post
    @Path
    public String insert(@JdbcConn(true) Connection con, @LoginUser SessionUser user, @Upload UploadItemIterator it) throws Exception {
@@ -117,14 +125,29 @@ public class StorageService {
        return id;
    }
    /**
     * 文件删除
     * @param con
     * @param id
     * @throws SQLException
     */
    @Get
    @Path("/delete")
    @LoginUser
    public void logicDelete(@JdbcConn(true) Connection con, String id) throws SQLException {
        this.storageDao.logicDelete(con, id);
        this.storageDao.delete(con, id);
    }
    /**
     * 文件分页查询
     * @param con
     * @param active
     * @param pageSize
     * @param pageNo
     * @return
     * @throws SQLException
     */
    @Path("/pq")
    @Get
    @LoginUser

src/main/java/com/ekexiu/project/storage/system/service/SysService.java

@@ -52,6 +52,15 @@ public class SysService {
    }
    /**
     * 用户登录
     * @param con
     * @param account
     * @param pw
     * @return
     * @throws SQLException
     * @throws JfwBaseException
     */
    @SetSession("JFW_SESSION_LOGIN_USER=result")
    @Path("/login")
    @Post
@@ -88,18 +97,33 @@ public class SysService {
        return null;
    }
    /**
     * 当前登录用户信息
     * @param user
     * @return
     */
    @Get
    @Path("/user")
    public SessionUser get(@LoginUser SessionUser user) {
        return user;
    }
    /**
     * 用户退出登录
     */
    @Get
    @Path("/logout")
    @InvalidSession
    public void logout() {
    }
    /**
     * 新增用户
     * @param con
     * @param user
     * @return
     * @throws SQLException
     */
    @Post
    @Path("/insert")
    @LoginUser
@@ -112,6 +136,13 @@ public class SysService {
        return id;
    }
    /**
     * 账户检查是否可用
     * @param con
     * @param account
     * @return
     * @throws SQLException
     */
    @Get
    @Path("/check")
    public int check(@JdbcConn Connection con, String account)throws SQLException {
@@ -125,6 +156,13 @@ public class SysService {
        }
    }
    /**
     * 查询单个用户信息
     * @param con
     * @param id
     * @return
     * @throws SQLException
     */
    @Get
    @Path("/qo")
    @LoginUser
@@ -132,6 +170,12 @@ public class SysService {
        return this.userDao.query(con, id);
    }
    /**
     * 用户信息更新
     * @param con
     * @param user
     * @throws SQLException
     */
    @Post
    @Path("/update")
    @LoginUser
@@ -139,6 +183,12 @@ public class SysService {
        this.userDao.update(con, user);
    }
    /**
     * 禁用用户
     * @param con
     * @param id
     * @throws SQLException
     */
    @Get
    @Path("/ban")
    @LoginUser
@@ -146,6 +196,12 @@ public class SysService {
        this.userDao.ban(con, id);
    }
    /**
     * 重新激活用户
     * @param con
     * @param id
     * @throws SQLException
     */
    @Get
    @Path("/active")
    @LoginUser
@@ -153,6 +209,15 @@ public class SysService {
        this.userDao.active(con, id);
    }
    /**
     * 用户列表分页查询
     * @param con
     * @param active
     * @param pageSize
     * @param pageNo
     * @return
     * @throws SQLException
     */
    @Get
    @Path("/pq")
    @LoginUser
@@ -160,12 +225,26 @@ public class SysService {
        return this.userDao.pageQuery(con, active, pageSize, pageNo);
    }
    /**
     * 用户修改密码
     * @param con
     * @param u
     * @param newPw
     * @throws SQLException
     * @throws JfwBaseException
     */
    @Post
    @Path("/changePw")
    public void changePw(@JdbcConn(true) Connection con, @LoginUser SessionUser u, String newPw) throws SQLException, JfwBaseException {
        this.userDao.changePw(con, StringUtil.md5(newPw), u.getId());
    }
    /**
     * 用户重置密码
     * @param con
     * @param id
     * @throws SQLException
     */
    @Get
    @Path("/resetPw")
    @LoginUser