初版 用户信息管理、文章管理

src/main/java/com/ekexiu/console/system/dao/ArticleDao.java

@@ -10,6 +10,7 @@ import org.jfw.apt.orm.annotation.dao.method.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.Where;
import org.jfw.apt.orm.annotation.dao.method.operator.PageQuery;
import org.jfw.apt.orm.annotation.dao.method.operator.QueryVal;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.*;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
import org.jfw.util.PageQueryResult;
@@ -38,4 +39,8 @@ public interface ArticleDao {
    @OrderBy(" ORDER BY page_views DESC NULLS LAST")
    @Where("status='1'")
    PageQueryResult<ArticleInfo> queryByPV(Connection con, @Nullable @Like String articleTitle, @SqlColumn(value = {"(p.name is null or p.name like ?)", "(o.name is null or o.name like ?)"}, handlerClass = StringHandler.class) String name, @Nullable @GtEq @Alias("publishTime") String bt, @Nullable @Alias("publishTime") @LtEq String et, int pageSize, int pageNo) throws SQLException;
    @UpdateWith
    @From(Article.class)
    int updateStatus(Connection con,String articleId,@Set String status) throws SQLException;
}

src/main/java/com/ekexiu/console/system/dao/ProfessorDao.java

@@ -2,6 +2,7 @@ package com.ekexiu.console.system.dao;
import com.ekexiu.console.system.po.Professor;
import com.ekexiu.console.system.pojo.ProfessorInfo;
import com.ekexiu.console.system.pojo.UserDetail;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.Batch;
import org.jfw.apt.orm.annotation.dao.Column;
@@ -79,4 +80,12 @@ public interface ProfessorDao {
    @Column(handlerClass = StringHandler.class, value = "name")
    @From(Professor.class)
    String queryById(Connection con, String id) throws SQLException;
    @PageQuery
    @OrderBy("ORDER BY create_time DESC NULLS LAST")
    PageQueryResult<UserDetail> pageQueryUserDetail(Connection con, @Nullable @Like String name,@Nullable @Alias("createTime") @GtEq String bt, @Nullable @Alias("createTime") @LtEq String et, int pageSize, int pageNo) throws SQLException;
    @UpdateWith
    @From(Professor.class)
    int updateBusinessData(Connection con,String id,@Set int authentication,@Set int authStatus,@Set int authStatusExpert ,@Set int sortFirst)throws SQLException;
}

src/main/java/com/ekexiu/console/system/pojo/UserDetail.java

@@ -0,0 +1,66 @@
package com.ekexiu.console.system.pojo;
import com.ekexiu.console.system.po.Professor;
import org.jfw.apt.orm.annotation.entry.CalcColumn;
import org.jfw.apt.orm.annotation.entry.ExtendView;
import org.jfw.apt.orm.core.defaultImpl.IntHandler;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
/**
 * Created by TT on 2017/8/3.
 */
@ExtendView(fromSentence = "professor p RIGHT JOIN (select luser.id,luser.email,luser.mobile_phone,luser.invite_code,luser.send_mail_status,(case when luser.active_time is not null then '1' else '0' end )active_status from luser)l on l.id = p.id LEFT JOIN organization o on o.id = p.org_id ",tableAlias = "p")
public class UserDetail extends Professor {
    private String orgName;
    private String loginPhone;
    private String loginEmail;
    private String activeStatus;
    private int sendMailStatus;
    @CalcColumn(handlerClass = StringHandler.class, column = "o.name")
    public String getOrgName() {
        return orgName;
    }
    public void setOrgName(String orgName) {
        this.orgName = orgName;
    }
    @CalcColumn(handlerClass = StringHandler.class, column = "l.mobile_phone")
    public String getLoginPhone() {
        return loginPhone;
    }
    public void setLoginPhone(String loginPhone) {
        this.loginPhone = loginPhone;
    }
    @CalcColumn(handlerClass = StringHandler.class, column = "l.email")
    public String getLoginEmail() {
        return loginEmail;
    }
    public void setLoginEmail(String loginEmail) {
        this.loginEmail = loginEmail;
    }
    @CalcColumn(handlerClass = StringHandler.class, column = "l.active_status")
    public String getActiveStatus() {
        return activeStatus;
    }
    public void setActiveStatus(String activeStatus) {
        this.activeStatus = activeStatus;
    }
    @CalcColumn(handlerClass = IntHandler.class, column = "l.send_mail_status")
    public int getSendMailStatus() {
        return sendMailStatus;
    }
    public void setSendMailStatus(int sendMailStatus) {
        this.sendMailStatus = sendMailStatus;
    }
}

src/main/java/com/ekexiu/console/system/service/ArticleService.java

@@ -0,0 +1,51 @@
package com.ekexiu.console.system.service;
import com.ekexiu.console.system.dao.ArticleDao;
import com.ekexiu.console.system.pojo.ArticleInfo;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.annotation.Nullable;
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.PageQueryResult;
import java.sql.Connection;
import java.sql.SQLException;
/**
 * Created by TT on 2017/8/3.
 */
@Path("/article")
public class ArticleService {
    @Autowrie
    private ArticleDao articleDao;
    public ArticleDao getArticleDao() {
        return articleDao;
    }
    public void setArticleDao(ArticleDao articleDao) {
        this.articleDao = articleDao;
    }
    @Path("/pq")
    @Get
    public PageQueryResult<ArticleInfo> pageQueryResult(@JdbcConn Connection con, @Nullable String title, @Nullable String name, int orderBy, @Nullable String bt, @Nullable String et, @DefaultValue("1") int pageNo, @DefaultValue("10") int pageSize)throws SQLException {
        if (orderBy == 1) {
            return this.articleDao.queryByTime(con, title == null ? null : "%" + title + "%",  name == null ? "%" : "%" + name + "%", bt == null ? null : bt + "000000", et == null ? null : et + "235959", pageSize, pageNo);
        }
        if (orderBy == 2) {
            return this.articleDao.queryByPV(con, title == null ? null : "%" + title + "%",  name == null ? "%" : "%" + name + "%", bt == null ? null : bt + "000000", et == null ? null : et + "235959", pageSize, pageNo);
        }
        return null;
    }
    @Post
    @Path("/deleteArticle")
    public void deleteArticle(@JdbcConn(true) Connection con,String articleId) throws SQLException{
        //修改文章状态为删除
        this.articleDao.updateStatus(con, articleId, "3");
    }
}

src/main/java/com/ekexiu/console/system/service/ProfessorService.java

@@ -4,6 +4,7 @@ import com.ekexiu.console.system.dao.OrgDao;
import com.ekexiu.console.system.dao.ProfessorDao;
import com.ekexiu.console.system.po.Professor;
import com.ekexiu.console.system.pojo.ProfessorInfo;
import com.ekexiu.console.system.pojo.UserDetail;
import com.ekexiu.console.system.vo.ConsoleAuthUser;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
@@ -106,7 +107,7 @@ public class ProfessorService {
    @Get
    @Path("/id/{id}")
    public ProfessorInfo sortFirst(@JdbcConn Connection con,@PathVar String id) throws SQLException {
    public ProfessorInfo query(@JdbcConn Connection con,@PathVar String id) throws SQLException {
        return this.professorDao.query(con, id);
    }
@@ -147,4 +148,16 @@ public class ProfessorService {
    public String getName(@JdbcConn Connection con,@PathVar String id) throws SQLException {
        return this.professorDao.queryById(con, id);
    }
    @Get
    @Path("/pqUserDetail")
    public PageQueryResult<UserDetail> userDetailPageQueryResult(@JdbcConn Connection con, @Nullable String name, @Nullable String bt, @Nullable String et, @DefaultValue("10") int pageSize, @DefaultValue("1") int pageNo)throws SQLException {
        return this.professorDao.pageQueryUserDetail(con, name == null ? null : "%" + name + "%", bt, et, pageSize, pageNo);
    }
    @Post
    @Path("/updateBusinessData")
    public void updateBusinessData(@JdbcConn(true) Connection con,String id,@Nullable int authentication,@Nullable int authStatus,@Nullable int authStatusExpert,int sortFirst)throws SQLException{
        this.professorDao.updateBusinessData(con, id, authentication, authStatus, authStatusExpert, sortFirst);
    }
}

src/main/resources/database.sql

@@ -51,4 +51,9 @@ COMMENT ON COLUMN feedback.operator IS '处理人ID';
ALTER TABLE feedback ADD COLUMN operate_time  TEXT;
COMMENT ON COLUMN feedback.operate_time IS '处理时间';
ALTER TABLE feedback ADD COLUMN operate_descp TEXT;
COMMENT ON COLUMN feedback.operate_descp IS '处理备注';
COMMENT ON COLUMN feedback.operate_descp IS '处理备注';
-----begin version 1.9.1------------------------
ALTER TABLE article ADD COLUMN sort_num  int8 default 0 not null;
COMMENT ON COLUMN article.sort_num IS '排序字段，人工权重';