留言模块。

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

@@ -0,0 +1,118 @@
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.Messages;
import com.ekexiu.portal.po.Professor;
@DAO
public abstract class MessagesDao {
	@Insert
	public abstract int insert(Connection con, Messages messages) throws SQLException;
	
	public Messages query(Connection con, String messageId) throws SQLException{
        int _m_1 = 1;
        String sql = "SELECT MESSAGE_ID,MESSAGES.OPERATION_ID,MESSAGES.PROFESSOR_ID,LEAVE_WORD,MESSAGES.CREATE_TIME,PROFESSOR.NAME FROM MESSAGES LEFT JOIN PROFESSOR ON MESSAGES.PROFESSOR_ID = PROFESSOR.ID WHERE MESSAGE_ID = ?";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,messageId);
            ResultSet rs = ps.executeQuery();
            try{
                if(rs.next()){
                    Messages _result = new Messages();
                    _result.setMessageId(rs.getString(1));
                    _result.setOperationId(rs.getString(2));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(3));
                    _result.setLeaveWord(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 List<Messages> queryOper(Connection con, String operationId) throws SQLException{
        int _m_1 = 1;
        String sql = "SELECT MESSAGE_ID,MESSAGES.OPERATION_ID,MESSAGES.PROFESSOR_ID,LEAVE_WORD,MESSAGES.CREATE_TIME,PROFESSOR.NAME FROM MESSAGES LEFT JOIN PROFESSOR ON MESSAGES.PROFESSOR_ID = PROFESSOR.ID WHERE MESSAGES.OPERATION_ID = ?";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
            ps.setString(_m_1++,operationId);
            ResultSet rs = ps.executeQuery();
            try{
                List<Messages> _result = new ArrayList<Messages>();
                while(rs.next()){
                    Messages _obj =  new Messages();
                    _obj.setMessageId(rs.getString(1));
                    _obj.setOperationId(rs.getString(2));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(3));
                    _obj.setLeaveWord(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){}
        }
    }
	
	public List<Messages> quetyPro(Connection con,String operationId, String professorId) throws SQLException{
        int _m_1 = 1;
        String sql = "SELECT MESSAGE_ID,MESSAGES.OPERATION_ID,MESSAGES.PROFESSOR_ID,LEAVE_WORD,MESSAGES.CREATE_TIME,PROFESSOR.NAME FROM MESSAGES LEFT JOIN PROFESSOR ON MESSAGES.PROFESSOR_ID = PROFESSOR.ID WHERE MESSAGES.OPERATION_ID = ? AND MESSAGES.PROFESSOR_ID = ?";
        PreparedStatement ps = con.prepareStatement(sql);
        try{
        	ps.setString(_m_1++, operationId);
            ps.setString(_m_1++,professorId);
            ResultSet rs = ps.executeQuery();
            try{
                List<Messages> _result = new ArrayList<Messages>();
                while(rs.next()){
                    Messages _obj =  new Messages();
                    _obj.setMessageId(rs.getString(1));
                    _obj.setOperationId(rs.getString(2));
                    Professor professor = new Professor();
                    professor.setId(rs.getString(3));
                    _obj.setLeaveWord(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){}
        }
    }
	
	@DeleteWith
	@From(Messages.class)
	public abstract int delete(Connection con, String messageId) throws SQLException;
	
}

src/main/java/com/ekexiu/portal/po/Messages.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;
import com.ekexiu.portal.basepo.CreateTimeSupported;
@PrimaryKey("messageId")
@Table
public class Messages implements CreateTimeSupported {
	private String messageId; //留言ID
	private String operationId; //订单ID
	private String professorId; //留言者ID
	private String leaveWord; //留言
	private String createTime; //留言时间
	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 getMessageId() {
		return messageId;
	}
	public void setMessageId(String messageId) {
		this.messageId = messageId;
	}
	
	@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;
	}
	
	@Column(handlerClass=StringHandler.class,dbType="TEXT",insertable=true,nullable=false,renewable=false,queryable=true)
	public String getLeaveWord() {
		return leaveWord;
	}
	public void setLeaveWord(String leaveWord) {
		this.leaveWord = leaveWord;
	}
	
	public String getCreateTime() {
		return createTime;
	}
	public void setCreateTime(String createTime) {
		this.createTime = createTime;
	}
}

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

@@ -0,0 +1,64 @@
package com.ekexiu.portal.service;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Delete;
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.MessagesDao;
import com.ekexiu.portal.po.Messages;
@Path("/messages")
public class MessageService {
	@Autowrie
	private MessagesDao messagesDao;
	public MessagesDao getMessagesDao() {
		return messagesDao;
	}
	public void setMessagesDao(MessagesDao messagesDao) {
		this.messagesDao = messagesDao;
	}
	
	@Post
	@Path
	public String insert(@JdbcConn(true) Connection con, Messages messages) throws SQLException {
		messages.setMessageId(StringUtil.buildUUID());
		this.messagesDao.insert(con, messages);
		return messages.getMessageId();
	}
	
	@Get
	@Path("/{messageId}")
	public Messages query(@JdbcConn Connection con, @PathVar String messageId) throws SQLException {
		return this.messagesDao.query(con, messageId);
	}
	
	@Get
	@Path("/qaoper")
	public List<Messages> queryOper(@JdbcConn Connection con, String operationId) throws SQLException {
		return this.messagesDao.queryOper(con, operationId);
	}
	
	@Get
	@Path("/qapro")
	public List<Messages> queryPro(@JdbcConn Connection con, String operationId, String professorId) throws SQLException {
		return this.messagesDao.quetyPro(con, operationId, professorId);
	}
	
	@Delete
	@Path("/{messageId}")
	public void delete(@JdbcConn(true) Connection con, @PathVar String messageId) throws SQLException {
		this.messagesDao.delete(con, messageId);
	}
	
}