咨询管理

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

@@ -0,0 +1,252 @@
package com.ekexiu.console.system.dao;
import com.ekexiu.console.system.pojo.ConsultInfo;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.operator.QueryList;
import org.jfw.apt.orm.annotation.dao.method.operator.QueryOne;
import org.jfw.util.PageQueryResult;
import java.math.BigDecimal;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
/**
 * Created by TT on 2017/5/3.
 */
@DAO
public abstract class ConsultDao {
    @QueryList
    @OrderBy("ORDER BY CREATE_TIME DESC")
    public abstract List<ConsultInfo> query(Connection con) throws SQLException;
    public PageQueryResult<ConsultInfo> pageQuery(Connection con, String consultantName, String professorName, String consultTitle, Integer consultStatus, int pageSize, int pageNo) throws SQLException {
        int index = 0;
        PageQueryResult<ConsultInfo> queryResult = new PageQueryResult<ConsultInfo>();
        int paramIndex = 1;
        boolean b1 = null == consultStatus;
        StringBuilder sql = new StringBuilder();
        sql.append(" WHERE consultant_name LIKE ? AND professor_name LIKE ? AND consult_title LIKE ? ");
        if (!b1) {
            sql.append(" AND consult_status = ?");
        }
        StringBuilder sbql = sql;
        sql = new StringBuilder();
        sql.append(" select count(1) from (SELECT p.name as professor_name,o.name as professor_org,pp.name as consultant_name,oo.name as consultant_org,c.CONSULT_ID,c.CONSULT_TYPE,c.CONSULT_TITLE,c.CONSULT_CONTANT,c.PROFESSOR_ID,c.CONSULTANT_ID,c.CONSULT_STATUS,c.FINISH_TIME,c.ASSESS_STATUS,c.ASSESS_STAR,c.ASSESS_CONTANT,c.ASSESS_TIME,c.THANKS_STATUS,c.THANKS_MONEY,c.THANKS_TIME,c.REVOVERY_TIME,c.READ_STATUS,c.DEMAND_ID,c.CREATE_TIME FROM consult c LEFT JOIN professor p on c.professor_id = p.id LEFT JOIN professor pp on c.consultant_id = pp.id LEFT JOIN organization o on o.id = p.org_id LEFT JOIN organization oo on oo.id = pp.org_id ORDER BY CREATE_TIME DESC)as view_consult ");
        sql.append(sbql);
        PreparedStatement ps = con.prepareStatement(sql.toString());
        try {
            ps.setString(paramIndex++, consultantName);
            ps.setString(paramIndex++, professorName);
            ps.setString(paramIndex++, consultTitle);
            if (!b1) {
                ps.setInt(paramIndex++, consultStatus);
            }
            queryResult.setPageSize(pageSize);
            ResultSet resultSet = ps.executeQuery();
            try {
                resultSet.next();
                index = resultSet.getInt(1);
            } finally {
                try {
                    resultSet.close();
                } catch (Exception e) {
                }
            }
        } finally {
            try {
                ps.close();
            } catch (Exception e) {
            }
        }
        queryResult.setTotal(index);
        if (0 == index) {
            queryResult.setPageNo(1);
            queryResult.setData(Collections.<ConsultInfo>emptyList());
            return queryResult;
        }
        paramIndex = 1;
        boolean b2 = (1 == pageNo);
        if (b2) {
            queryResult.setPageNo(1);
            sql = new StringBuilder();
            sql.append(" WHERE pp.name LIKE ? AND p.name LIKE ? AND c.consult_title LIKE ? ");
            if (!b1) {
                sql.append(" AND c.consult_status = ?");
            }
            StringBuilder stringBuilder = sql;
            sql = new StringBuilder();
            sql.append(" SELECT p.name as professor_name,o.name as professor_Org,pp.name as consultant_Name,oo.name as consultant_Org,c.CONSULT_ID,c.CONSULT_TYPE,c.CONSULT_TITLE,c.CONSULT_CONTANT,c.PROFESSOR_ID,c.CONSULTANT_ID,c.CONSULT_STATUS,c.FINISH_TIME,c.ASSESS_STATUS,c.ASSESS_STAR,c.ASSESS_CONTANT,c.ASSESS_TIME,c.THANKS_STATUS,c.THANKS_MONEY,c.THANKS_TIME,c.REVOVERY_TIME,c.READ_STATUS,c.DEMAND_ID,c.CREATE_TIME FROM consult c LEFT JOIN professor p on c.professor_id = p.id LEFT JOIN professor pp on c.consultant_id = pp.id LEFT JOIN organization o on o.id = p.org_id LEFT JOIN organization oo on oo.id = pp.org_id ");
            sql.append(stringBuilder);
            sql.append(" ORDER BY CREATE_TIME DESC ");
            sql.append(" LIMIT ").append(pageSize);
        } else {
            int pno = index / pageSize;
            if (index % pageSize != 0) {
                ++pno;
            }
            if (pageNo > pno) {
                pageNo = pno;
            }
            queryResult.setPageNo(pageNo);
            --pageNo;
            int offset = (pageNo * pageSize);
            sql = new StringBuilder();
            sql.append(" WHERE pp.name LIKE ? AND p.name LIKE ? AND c.consult_title LIKE ? ");
            if (!b1) {
                sql.append(" AND c.consult_status = ?");
            }
            StringBuilder stringBuilder = sql;
            sql = new StringBuilder();
            sql.append(" SELECT p.name as professor_name,o.name as professor_Org,pp.name as consultant_Name,oo.name as consultant_Org,c.CONSULT_ID,c.CONSULT_TYPE,c.CONSULT_TITLE,c.CONSULT_CONTANT,c.PROFESSOR_ID,c.CONSULTANT_ID,c.CONSULT_STATUS,c.FINISH_TIME,c.ASSESS_STATUS,c.ASSESS_STAR,c.ASSESS_CONTANT,c.ASSESS_TIME,c.THANKS_STATUS,c.THANKS_MONEY,c.THANKS_TIME,c.REVOVERY_TIME,c.READ_STATUS,c.DEMAND_ID,c.CREATE_TIME FROM consult c LEFT JOIN professor p on c.professor_id = p.id LEFT JOIN professor pp on c.consultant_id = pp.id LEFT JOIN organization o on o.id = p.org_id LEFT JOIN organization oo on oo.id = pp.org_id ");
            sql.append(stringBuilder);
            sql.append(" ORDER BY CREATE_TIME DESC ");
            sql.append(" LIMIT ").append(pageSize).append(" OFFSET ").append(offset);
        }
        ps = con.prepareStatement(sql.toString());
        try {
            ps.setString(paramIndex++, consultantName);
            ps.setString(paramIndex++, professorName);
            ps.setString(paramIndex++, consultTitle);
            if (!b1) {
                ps.setInt(paramIndex++, consultStatus);
            }
            ResultSet rs = ps.executeQuery();
            try {
                List<ConsultInfo> consultInfos = new ArrayList<ConsultInfo>();
                queryResult.setData(consultInfos);
                int indx = 0;
                while ((indx < pageSize) && rs.next()) {
                    ++indx;
                    ConsultInfo consultInfo = new ConsultInfo();
                    String pName = rs.getString(1);
                    if (rs.wasNull()) {
                        pName = null;
                    }
                    consultInfo.setProfessorName(pName);
                    String pOrg = rs.getString(2);
                    if (rs.wasNull()) {
                        pOrg = null;
                    }
                    consultInfo.setProfessorOrg(pOrg);
                    String cName = rs.getString(3);
                    if (rs.wasNull()) {
                        cName = null;
                    }
                    consultInfo.setConsultantName(cName);
                    String cOrg = rs.getString(4);
                    if (rs.wasNull()) {
                        cOrg = null;
                    }
                    consultInfo.setConsultantOrg(cOrg);
                    String cId = rs.getString(5);
                    if (rs.wasNull()) {
                        cId = null;
                    }
                    consultInfo.setConsultId(cId);
                    String consultType = rs.getString(6);
                    if (rs.wasNull()) {
                        consultType = null;
                    }
                    consultInfo.setConsultType(consultType);
                    String cTitle = rs.getString(7);
                    if (rs.wasNull()) {
                        cTitle = null;
                    }
                    consultInfo.setConsultTitle(cTitle);
                    String consultContant = rs.getString(8);
                    if (rs.wasNull()) {
                        consultContant = null;
                    }
                    consultInfo.setConsultContant(consultContant);
                    String pId = rs.getString(9);
                    if (rs.wasNull()) {
                        pId = null;
                    }
                    consultInfo.setProfessorId(pId);
                    String consultantId = rs.getString(10);
                    if (rs.wasNull()) {
                        consultantId = null;
                    }
                    consultInfo.setConsultantId(consultantId);
                    Integer cStatus = rs.getInt(11);
                    if (rs.wasNull()) {
                        cStatus = null;
                    }
                    consultInfo.setConsultStatus(cStatus);
                    String finishTime = rs.getString(12);
                    if (rs.wasNull()) {
                        finishTime = null;
                    }
                    consultInfo.setFinishTime(finishTime);
                    Integer assessStatus = rs.getInt(13);
                    if (rs.wasNull()) {
                        assessStatus = null;
                    }
                    consultInfo.setAssessStatus(assessStatus);
                    Integer assessStar = rs.getInt(14);
                    if (rs.wasNull()) {
                        assessStar = null;
                    }
                    consultInfo.setAssessStar(assessStar);
                    String assessContant = rs.getString(15);
                    if (rs.wasNull()) {
                        assessContant = null;
                    }
                    consultInfo.setAssessContant(assessContant);
                    String assessTime = rs.getString(16);
                    if (rs.wasNull()) {
                        assessTime = null;
                    }
                    consultInfo.setAssessTime(assessTime);
                    Integer thanksStatus = rs.getInt(17);
                    if (rs.wasNull()) {
                        thanksStatus = null;
                    }
                    consultInfo.setThanksStatus(thanksStatus);
                    BigDecimal thanksMoney = rs.getBigDecimal(18);
                    if (rs.wasNull()) {
                        thanksMoney = null;
                    }
                    consultInfo.setThanksMoney(thanksMoney);
                    String thanksTime = rs.getString(19);
                    if (rs.wasNull()) {
                        thanksTime = null;
                    }
                    consultInfo.setThanksTime(thanksTime);
                    consultInfo.setRevoveryTime(rs.getString(20));
                    consultInfo.setReadStatus(rs.getInt(21));
                    String demandId = rs.getString(22);
                    if (rs.wasNull()) {
                        demandId = null;
                    }
                    consultInfo.setDemandId(demandId);
                    consultInfo.setCreateTime(rs.getString(23));
                    consultInfos.add(consultInfo);
                }
                return queryResult;
            } finally {
                try {
                    rs.close();
                } catch (Exception e) {
                }
            }
        } finally {
            try {
                ps.close();
            } catch (Exception e) {
            }
        }
    }
    @Nullable
    @QueryOne
    public abstract ConsultInfo query(Connection con, String consultId) throws SQLException;
}

src/main/java/com/ekexiu/console/system/po/Consult.java

@@ -0,0 +1,202 @@
package com.ekexiu.console.system.po;
import com.ekexiu.console.basepo.CreateTimeSupported;
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.defaultImpl.StringHandler;
import org.jfw.apt.orm.core.defaultImpl.WIntHandler;
import org.jfw.apt.orm.core.enums.DE;
import java.math.BigDecimal;
import java.util.List;
/**
 * Created by TT on 2017/5/3.
 */
@PrimaryKey("consultId")
@Table
public class Consult implements CreateTimeSupported {
    private String consultId;
    private String consultType;
    private String consultTitle;
    private String consultContant;
    private String createTime;
    private String professorId;
    private String consultantId;
    private Integer consultStatus;
    private String finishTime;
    private Integer assessStatus;
    private Integer assessStar;
    private String assessContant;
    private String assessTime;
    private Integer thanksStatus;
    private BigDecimal thanksMoney;
    private String thanksTime;
    private String revoveryTime;
    private Integer readStatus;
    private String demandId;
    private List<Tidings> tidings;
    public List<Tidings> getTidings() {
        return tidings;
    }
    public void setTidings(List<Tidings> tidings) {
        this.tidings = tidings;
    }
    @Column(DE.id_32)
    public String getConsultId() {
        return consultId;
    }
    public void setConsultId(String consultId) {
        this.consultId = consultId;
    }
    @Column(DE.string_de)
    public String getConsultType() {
        return consultType;
    }
    public void setConsultType(String consultType) {
        this.consultType = consultType;
    }
    @Column(DE.string_de)
    public String getConsultTitle() {
        return consultTitle;
    }
    public void setConsultTitle(String consultTitle) {
        this.consultTitle = consultTitle;
    }
    @Column(handlerClass=StringHandler.class,dbType="TEXT",nullable=false,insertable=true,renewable=false,queryable=true)
    public String getConsultContant() {
        return consultContant;
    }
    public void setConsultContant(String consultContant) {
        this.consultContant = consultContant;
    }
    public String getCreateTime() {
        return createTime;
    }
    public void setCreateTime(String createTime) {
        this.createTime = createTime;
    }
    @Column(DE.id_32)
    public String getProfessorId() {
        return professorId;
    }
    public void setProfessorId(String professorId) {
        this.professorId = professorId;
    }
    @Column(DE.id_32)
    public String getConsultantId() {
        return consultantId;
    }
    public void setConsultantId(String consultantId) {
        this.consultantId = consultantId;
    }
    @Column(handlerClass=WIntHandler.class,dbType="INT",nullable=true,insertable=true,renewable=true,queryable=true)
    public Integer getConsultStatus() {
        return consultStatus;
    }
    public void setConsultStatus(Integer consultStatus) {
        this.consultStatus = consultStatus;
    }
    @Column(handlerClass = FixLenStringHandler.class, dbType = "CHAR(14)", insertable = false, nullable = true, queryable = true, renewable = true)
    public String getFinishTime() {
        return finishTime;
    }
    public void setFinishTime(String finishTime) {
        this.finishTime = finishTime;
    }
    @Column(handlerClass=WIntHandler.class,dbType="INT",nullable=true,insertable=true,renewable=true,queryable=true)
    public Integer getAssessStatus() {
        return assessStatus;
    }
    public void setAssessStatus(Integer assessStatus) {
        this.assessStatus = assessStatus;
    }
    @Column(handlerClass=WIntHandler.class,dbType="INT",nullable=true,insertable=false,renewable=true,queryable=true)
    public Integer getAssessStar() {
        return assessStar;
    }
    public void setAssessStar(Integer assessStar) {
        this.assessStar = assessStar;
    }
    @Column(handlerClass=StringHandler.class,dbType="TEXT",nullable=true,insertable=false,renewable=true,queryable=true)
    public String getAssessContant() {
        return assessContant;
    }
    public void setAssessContant(String assessContant) {
        this.assessContant = assessContant;
    }
    @Column(handlerClass = FixLenStringHandler.class, dbType = "CHAR(14)", insertable = false, nullable = true, queryable = true, renewable = true)
    public String getAssessTime() {
        return assessTime;
    }
    public void setAssessTime(String assessTime) {
        this.assessTime = assessTime;
    }
    @Column(handlerClass=WIntHandler.class,dbType="INT",nullable=true,insertable=true,renewable=true,queryable=true)
    public Integer getThanksStatus() {
        return thanksStatus;
    }
    public void setThanksStatus(Integer thanksStatus) {
        this.thanksStatus = thanksStatus;
    }
    @Column(DE.BigDecmimal_de)
    public BigDecimal getThanksMoney() {
        return thanksMoney;
    }
    public void setThanksMoney(BigDecimal thanksMoney) {
        this.thanksMoney = thanksMoney;
    }
    @Column(handlerClass=FixLenStringHandler.class,dbType="CHAR(14)",insertable=false,nullable=true,queryable=true,renewable=true)
    public String getThanksTime() {
        return thanksTime;
    }
    public void setThanksTime(String thanksTime) {
        this.thanksTime = thanksTime;
    }
    @Column(handlerClass=FixLenStringHandler.class,dbType="CHAR(14)",fixSqlValueWithInsert="TO_CHAR(NOW(),'YYYYMMDDHH24MISS')",
            fixSqlValueWithUpdate="TO_CHAR(NOW(),'YYYYMMDDHH24MISS')",insertable=true,nullable=true,queryable=true,renewable=true)
    public String getRevoveryTime() {
        return revoveryTime;
    }
    public void setRevoveryTime(String revoveryTime) {
        this.revoveryTime = revoveryTime;
    }
    @Column(handlerClass=WIntHandler.class,dbType="INT",nullable=false,insertable=true,renewable=true,queryable=true)
    public Integer getReadStatus() {
        return readStatus;
    }
    public void setReadStatus(Integer readStatus) {
        this.readStatus = readStatus;
    }
    @Column(value= DE.id_32,nullable=true)
    public String getDemandId() {
        return demandId;
    }
    public void setDemandId(String demandId) {
        this.demandId = demandId;
    }
}

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

@@ -0,0 +1,93 @@
package com.ekexiu.console.system.pojo;
import com.ekexiu.console.system.po.Consult;
import org.jfw.apt.orm.annotation.entry.CalcColumn;
import org.jfw.apt.orm.annotation.entry.ExtendView;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
/**
 * Created by TT on 2017/5/3.
 */
@ExtendView(fromSentence = "consult c LEFT JOIN professor p on c.professor_id = p.id LEFT JOIN professor pp on c.consultant_id = pp.id LEFT JOIN organization o on o.id = p.org_id LEFT JOIN organization oo on oo.id = pp.org_id ", tableAlias = "c")
public class ConsultInfo extends Consult {
    private String professorName;
    private String professorOrg;
    private String professorPhone;
    private String professorEmail;
    private String consultantName;
    private String consultantOrg;
    private String consultantPhone;
    private String consultantEmail;
    @CalcColumn(handlerClass = StringHandler.class,column = "p.phone")
    public String getProfessorPhone() {
        return professorPhone;
    }
    public void setProfessorPhone(String professorPhone) {
        this.professorPhone = professorPhone;
    }
    @CalcColumn(handlerClass = StringHandler.class,column = "p.email")
    public String getProfessorEmail() {
        return professorEmail;
    }
    public void setProfessorEmail(String professorEmail) {
        this.professorEmail = professorEmail;
    }
    @CalcColumn(handlerClass = StringHandler.class,column = "pp.phone")
    public String getConsultantPhone() {
        return consultantPhone;
    }
    public void setConsultantPhone(String consultantPhone) {
        this.consultantPhone = consultantPhone;
    }
    @CalcColumn(handlerClass = StringHandler.class,column = "pp.email")
    public String getConsultantEmail() {
        return consultantEmail;
    }
    public void setConsultantEmail(String consultantEmail) {
        this.consultantEmail = consultantEmail;
    }
    @CalcColumn(handlerClass = StringHandler.class,column = "p.name")
    public String getProfessorName() {
        return professorName;
    }
    public void setProfessorName(String professorName) {
        this.professorName = professorName;
    }
    @CalcColumn(handlerClass = StringHandler.class,column = "o.name")
    public String getProfessorOrg() {
        return professorOrg;
    }
    public void setProfessorOrg(String professorOrg) {
        this.professorOrg = professorOrg;
    }
    @CalcColumn(handlerClass = StringHandler.class,column = "pp.name")
    public String getConsultantName() {
        return consultantName;
    }
    public void setConsultantName(String consultantName) {
        this.consultantName = consultantName;
    }
    @CalcColumn(handlerClass = StringHandler.class,column = "oo.name")
    public String getConsultantOrg() {
        return consultantOrg;
    }
    public void setConsultantOrg(String consultantOrg) {
        this.consultantOrg = consultantOrg;
    }
}

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

@@ -0,0 +1,73 @@
package com.ekexiu.console.system.service;
import com.ekexiu.console.system.dao.ConsultDao;
import com.ekexiu.console.system.dao.TidingsDao;
import com.ekexiu.console.system.pojo.ConsultInfo;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.param.Like;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.PathVar;
import org.jfw.util.PageQueryResult;
import java.sql.Connection;
import java.sql.SQLException;
/**
 * Created by TT on 2017/5/3.
 */
@Path("/consult")
public class ConsultService {
    @Autowrie
    private ConsultDao consultDao;
    @Autowrie
    private TidingsDao tidingsDao;
    public TidingsDao getTidingsDao() {
        return tidingsDao;
    }
    public void setTidingsDao(TidingsDao tidingsDao) {
        this.tidingsDao = tidingsDao;
    }
    public ConsultDao getConsultDao() {
        return consultDao;
    }
    public void setConsultDao(ConsultDao consultDao) {
        this.consultDao = consultDao;
    }
    @Get
    @Path("/qa")
    public PageQueryResult<ConsultInfo> query(@JdbcConn Connection con, @Nullable @Like String consultantName, @Nullable @Like String professorName, @Nullable @Like String consultTitle, @Nullable @Like Integer consultStatus, @DefaultValue("1") int pageSize, @DefaultValue("10") int pageNo) throws SQLException {
        String cName ="%";
        if(consultantName!=null)
        {
            cName="%"+consultantName+"%";
        }
        String pName ="%";
        if(professorName!=null)
        {
            pName="%"+professorName+"%";
        }
        String cTitle ="%";
        if(consultTitle!=null)
        {
            cTitle="%"+consultTitle+"%";
        }
        return this.consultDao.pageQuery(con,cName,pName,cTitle,consultStatus,pageSize,pageNo);
    }
    @Get
    @Path("/id/{id}")
    public ConsultInfo query(@JdbcConn Connection con, @PathVar String id)throws SQLException {
        return this.consultDao.query(con, id);
    }
}