咨询聊天接口。

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

@@ -0,0 +1,49 @@
package com.ekexiu.portal.dao;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
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.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.Update;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.Set;
import com.ekexiu.portal.po.Consult;
@DAO
public abstract class ConsultDao {
	@Insert
	public abstract int insert(Connection con, Consult consult) throws SQLException;
	
	@Update
	public abstract int update(Connection con, Consult consult) throws SQLException;
	
	@UpdateWith
	@From(Consult.class)
	public abstract int updateFinishTime(Connection con, String consultId, @Set String finishTime) throws SQLException;
	
	@UpdateWith
	@From(Consult.class)
	public abstract int updateRevoveryTime(Connection con, String consultId, @Set String revoveryTime) throws SQLException;
	
	@SelectOne
	@Nullable
	public abstract Consult query(Connection con, String consultId) throws SQLException;
	
	@SelectList
	@OrderBy(" ORDER BY CONSULT.CREATE_TIME DESC ")
	public abstract List<Consult> queryPro(Connection con, String professorId) throws SQLException;
	
	@SelectList
	@OrderBy(" ORDER BY CONSULT.CREATE_TIME DESC ")
	public abstract List<Consult> queryCon(Connection con, String consultantId) throws SQLException;
	
	
}

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

@@ -0,0 +1,77 @@
package com.ekexiu.portal.dao;
import java.sql.Connection;
import java.sql.SQLException;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.operator.Insert;
import com.ekexiu.portal.po.Professor;
import com.ekexiu.portal.po.Tidings;
@DAO
public abstract class TidingsDao {
	@Insert
	public abstract int insert(Connection con, Tidings tidings) throws SQLException;
	
	public com.ekexiu.portal.po.Tidings query(java.sql.Connection con,java.lang.String tidingsId) throws java.sql.SQLException{
        int _m_1 = 1;
        String sql = "SELECT TIDINGS_ID,TIDINGS_CONTANT,SENDER_ID,CONSULT_ID,TIDINGS.CREATE_TIME,PROFESSOR.NAME FROM TIDINGS LEFT JOIN PROFESSOR ON SENDER_ID = PROFESSOR.ID WHERE TIDINGS_ID = ?";
        java.sql.PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,tidingsId);
            java.sql.ResultSet rs = ps.executeQuery();
            try{
                if(rs.next()){
                    com.ekexiu.portal.po.Tidings _result = new com.ekexiu.portal.po.Tidings();
                    _result.setTidingsId(rs.getString(1));
                    _result.setTidingsContant(rs.getString(2));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(3));
                    _result.setConsultId(rs.getString(4));
                    _result.setCreateTime(rs.getString(5));
                    professor.setName(rs.getString(6));
                    _result.setProfessor(professor);
                    return _result;
                }else{
                    return null;
                }
            }finally{
                try{rs.close();}catch(Exception _m_2){}
            }
        }finally{
            try{ps.close();}catch(Exception _m_3){}
        }
    }
	
	public java.util.List<com.ekexiu.portal.po.Tidings> queryCon(java.sql.Connection con,java.lang.String consultId) throws java.sql.SQLException{
        int _m_1 = 1;
        String sql = "SELECT TIDINGS_ID,TIDINGS_CONTANT,SENDER_ID,TIDINGS.CONSULT_ID,TIDINGS.CREATE_TIME,PROFESSOR.NAME FROM TIDINGS LEFT JOIN PROFESSOR ON SENDER_ID = PROFESSOR.ID WHERE TIDINGS.CONSULT_ID = ?";
        java.sql.PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,consultId);
            java.sql.ResultSet rs = ps.executeQuery();
            try{
                java.util.List<com.ekexiu.portal.po.Tidings> _result = new java.util.ArrayList<com.ekexiu.portal.po.Tidings>();
                while(rs.next()){
                    com.ekexiu.portal.po.Tidings _obj =  new com.ekexiu.portal.po.Tidings();
                    _obj.setTidingsId(rs.getString(1));
                    _obj.setTidingsContant(rs.getString(2));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(3));
                    _obj.setConsultId(rs.getString(4));
                    _obj.setCreateTime(rs.getString(5));
                    professor.setName(rs.getString(6));
                    _obj.setProfessor(professor);
                    _result.add(_obj);
                }
                return _result;
            }finally{
                try{rs.close();}catch(Exception _m_2){}
            }
        }finally{
            try{ps.close();}catch(Exception _m_3){}
        }
    }
	
}

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

@@ -0,0 +1,177 @@
package com.ekexiu.portal.po;
import java.math.BigDecimal;
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.IntHandler;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
import org.jfw.apt.orm.core.enums.DE;
@PrimaryKey("consultId")
@Table
public class Consult {
	private String consultId;
	private String consultType;
	private String consultTitle;
	private String consultContant;
	private String createTime;
	private String professorId;
	private String consultantId;
	private int consultStatus;
	private String finishTime;
	private int assessStatus;
	private int assessStar;
	private String assessContant;
	private String assessTime;
	private int thanksStatus;
	private BigDecimal thanksMoney;
	private String thanksTime;
	private String revoveryTime;
	private Professor professor;
	
	public Professor getProfessor() {
		return professor;
	}
	public void setProfessor(Professor professor) {
		this.professor = professor;
	}
	
	@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;
	}
	
	@Column(handlerClass=StringHandler.class,dbType="VARCHAR",nullable=false,insertable=false,renewable=false,queryable=true)
	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=IntHandler.class,dbType="INT",nullable=true,insertable=true,renewable=true,queryable=true)
	public int getConsultStatus() {
		return consultStatus;
	}
	public void setConsultStatus(int consultStatus) {
		this.consultStatus = consultStatus;
	}
	
	@Column(handlerClass=StringHandler.class,dbType="VARCHAR",nullable=true,insertable=false,renewable=true,queryable=true)
	public String getFinishTime() {
		return finishTime;
	}
	public void setFinishTime(String finishTime) {
		this.finishTime = finishTime;
	}
	
	@Column(handlerClass=IntHandler.class,dbType="INT",nullable=true,insertable=true,renewable=true,queryable=true)
	public int getAssessStatus() {
		return assessStatus;
	}
	public void setAssessStatus(int assessStatus) {
		this.assessStatus = assessStatus;
	}
	
	@Column(handlerClass=IntHandler.class,dbType="INT",nullable=true,insertable=false,renewable=true,queryable=true)
	public int getAssessStar() {
		return assessStar;
	}
	public void setAssessStar(int 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=StringHandler.class,dbType="VARCHAR", nullable=true,insertable=false,renewable=false,queryable=true)
	public String getAssessTime() {
		return assessTime;
	}
	public void setAssessTime(String assessTime) {
		this.assessTime = assessTime;
	}
	
	@Column(handlerClass=IntHandler.class,dbType="INT",nullable=true,insertable=true,renewable=true,queryable=true)
	public int getThanksStatus() {
		return thanksStatus;
	}
	public void setThanksStatus(int thanksStatus) {
		this.thanksStatus = thanksStatus;
	}
	
	@Column(DE.BigDecmimal_de)
	public BigDecimal getThanksMoney() {
		return thanksMoney;
	}
	public void setThanksMoney(BigDecimal thanksMoney) {
		this.thanksMoney = thanksMoney;
	}
	
	@Column(handlerClass=StringHandler.class,dbType="VARCHAR", nullable=true,insertable=false,renewable=true,queryable=true)
	public String getThanksTime() {
		return thanksTime;
	}
	public void setThanksTime(String thanksTime) {
		this.thanksTime = thanksTime;
	}
	
	@Column(handlerClass=StringHandler.class,dbType="VARCHAR", nullable=false,insertable=true,renewable=true,queryable=true)
	public String getRevoveryTime() {
		return revoveryTime;
	}
	public void setRevoveryTime(String revoveryTime) {
		this.revoveryTime = revoveryTime;
	}
	
}

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

@@ -106,7 +106,7 @@ public class Operation {
		this.detailDemand = detailDemand;
	}
	
	@Column(handlerClass = FixLenStringHandler.class, dbType = "CHAR(8)", fixSqlValueWithInsert = "TO_CHAR(NOW(),'YYYYMMDD')", fixSqlValueWithUpdate = "TO_CHAR(NOW(),'YYYYMMDD')", insertable = true, nullable = false, queryable = true, renewable = true)
	@Column(handlerClass = FixLenStringHandler.class, dbType = "CHAR(8)", insertable = true, nullable = false, queryable = true, renewable = true)
	public String getDeliverTime() {
		return deliverTime;
	}
@@ -130,7 +130,7 @@ public class Operation {
		this.dealPrice = dealPrice;
	}
	
	@Column(handlerClass = FixLenStringHandler.class, dbType = "CHAR(14)", fixSqlValueWithInsert = "TO_CHAR(NOW(),'YYYYMMDDHH24MISS')", insertable = true, nullable = false, queryable = true, renewable = false)
	@Column(handlerClass = FixLenStringHandler.class, dbType = "CHAR(14)", fixSqlValueWithUpdate = "TO_CHAR(NOW(),'YYYYMMDDHH24MISS')", insertable = false, nullable = true, queryable = true, renewable = true)
	public String getDealTime() {
		return dealTime;
	}

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

@@ -0,0 +1,74 @@
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.defaultImpl.StringHandler;
import org.jfw.apt.orm.core.enums.DE;
@PrimaryKey("tidingsId")
@Table
public class Tidings {
	private String tidingsId;
	private String tidingsContant;
	private String senderId;
	private String consultId;
	private String createTime;
	private Professor professor;
	private Consult consult;
	
	public Professor getProfessor() {
		return professor;
	}
	public void setProfessor(Professor professor) {
		this.professor = professor;
	}
	
	public Consult getConsult() {
		return consult;
	}
	public void setConsult(Consult consult) {
		this.consult = consult;
	}
	
	@Column(DE.id_32)
	public String getTidingsId() {
		return tidingsId;
	}
	public void setTidingsId(String tidingsId) {
		this.tidingsId = tidingsId;
	}
	
	@Column(handlerClass=StringHandler.class,dbType="TEXT",nullable=false,insertable=true,renewable=false,queryable=true)
	public String getTidingsContant() {
		return tidingsContant;
	}
	public void setTidingsContant(String tidingsContant) {
		this.tidingsContant = tidingsContant;
	}
	
	@Column(DE.id_32)
	public String getSenderId() {
		return senderId;
	}
	public void setSenderId(String senderId) {
		this.senderId = senderId;
	}
	
	@Column(DE.id_32)
	public String getConsultId() {
		return consultId;
	}
	public void setConsultId(String consultId) {
		this.consultId = consultId;
	}
	
	@Column(handlerClass=StringHandler.class,dbType="VARCHAR",nullable=false,insertable=false,renewable=false,queryable=true)
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
	
}

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

@@ -0,0 +1,75 @@
package com.ekexiu.portal.service;
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.operate.Put;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.PathVar;
import org.jfw.util.StringUtil;
import com.ekexiu.portal.dao.ConsultDao;
import com.ekexiu.portal.po.Consult;
@Path("/consult")
public class ConsultService {
	@Autowrie
	private ConsultDao consultDao;
	public ConsultDao getConsultDao() {
		return consultDao;
	}
	public void setConsultDao(ConsultDao consultDao) {
		this.consultDao = consultDao;
	}
	
	@Post
	@Path
	public String insert(@JdbcConn(true) Connection con, Consult consult) throws SQLException {
		String consultId = StringUtil.buildUUID();
		consult.setConsultId(consultId);
		String revoveryTime = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
		consult.setRevoveryTime(revoveryTime);
		this.consultDao.insert(con, consult);
		return consultId;
	}
	
	@Put
	@Path
	public void update(@JdbcConn(true) Connection con, Consult consult) throws SQLException {
		this.consultDao.update(con, consult);
	}
	
	@Post
	@Path("/finishTime")
	public void updateFinishTime(@JdbcConn(true) Connection con, String consultId, int consultStatus) throws SQLException {
		if(5 == consultStatus) {
			String finishTime = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
			this.consultDao.updateFinishTime(con, consultId, finishTime);
		}
	}
	
	@Get
	@Path("/{consultId}")
	public Consult query(@JdbcConn Connection con, @PathVar String consultId) throws SQLException {
		return this.consultDao.query(con, consultId);
	}
	
	@Get
	@Path("/qapro")
	public List<Consult> queryPro(@JdbcConn Connection con, String professorId) throws SQLException {
		return this.consultDao.queryPro(con, professorId);
	}
	
	@Get
	@Path("/qacon")
	public List<Consult> queryCon(@JdbcConn Connection con, String consultantId) throws SQLException {
		return this.consultDao.queryCon(con, consultantId);
	}
}

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

@@ -0,0 +1,64 @@
package com.ekexiu.portal.service;
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.apt.web.annotation.param.PathVar;
import org.jfw.util.StringUtil;
import com.ekexiu.portal.dao.ConsultDao;
import com.ekexiu.portal.dao.TidingsDao;
import com.ekexiu.portal.po.Tidings;
@Path("/tidings")
public class TidingsService {
	@Autowrie
	private TidingsDao tidingsDao;
	@Autowrie
	private ConsultDao consultDao;
	
	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;
	}
	
	@Post
	@Path
	public String insert(@JdbcConn(true) Connection con, Tidings tidings) throws SQLException {
		String tidingsId = StringUtil.buildUUID();
		tidings.setTidingsId(tidingsId);
		this.tidingsDao.insert(con, tidings);
		String consultId = tidings.getConsultId();
		String revoveryTime = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
		this.consultDao.updateRevoveryTime(con, consultId, revoveryTime);
		return tidingsId;
	}
	
	@Get
	@Path("/{tidingsId}")
	public Tidings query(@JdbcConn Connection con, @PathVar String tidingsId) throws SQLException {
		return this.tidingsDao.query(con, tidingsId);
	}
	
	@Get
	@Path("/qacon")
	public List<Tidings> queryCon(@JdbcConn Connection con, String consultId) throws SQLException {
		return this.tidingsDao.queryCon(con, consultId);
	}
}