11

src/main/java/com/ekexiu/portal/msg/Service.java

import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.util.DateUtil;
import org.jfw.util.PageQueryResult;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.jdbc.JdbcUtil;
import org.jfw.util.jdbc.PreparedStatementConfig;
import org.jfw.util.jdbc.ResultSetExtractor;
	public static final List<ActorItem> EMPTY_ACTORS = Collections.<ActorItem> emptyList();
	public static final int ERROR_OWNER_OR_ACTOR = JfwBaseException.MIN_LOGIC_ERROR_CODE + 1;
	@Autowrie
	private WebMsgDao webMsgDao;
		return ret;
	}
	public static void checkActors(String id, String id2) throws JfwBaseException {
		if (id.compareTo(id2) == 0)
			throw new JfwBaseException(ERROR_OWNER_OR_ACTOR, "消息的参与人不合法");
	}
	@Get
	@Path("/idx/qm")
	public List<ActorItem> query(@JdbcConn Connection con, String id) throws SQLException {
	@Get
	@Path("/idx/qo")
	public ActorItem query(@JdbcConn Connection con, String id, String oid) throws SQLException {
	public ActorItem query(@JdbcConn Connection con, String owner, String actor) throws SQLException, JfwBaseException {
		checkActors(owner, owner);
		WebMsgIdx wmi = null;
		if (id.compareTo(oid) < 0) {
			wmi = webMsgDao.query(con, id, oid);
		if (owner.compareTo(actor) < 0) {
			wmi = webMsgDao.query(con, owner, actor);
		} else {
			wmi = webMsgDao.query(con, oid, id);
			wmi = webMsgDao.query(con, actor, owner);
		}
		SimpleDateFormat sf = new SimpleDateFormat(DateUtil.TIMESTAMP_FORMAT);
		if (wmi != null) {
			return build(wmi, id, sf);
			return build(wmi, owner, sf);
		}
		return null;
	}
	@Get
	@Post
	@Path
	public void send(@JdbcConn Connection con, String sender, String reciver, String cnt) throws SQLException {
	public void send(@JdbcConn Connection con, String sender, String reciver, String cnt) throws SQLException, JfwBaseException {
		checkActors(sender, reciver);
		boolean ownerSend = true;
		String owner = sender;
		String actor = reciver;
		boolean next = true;
		if (sender.compareTo(reciver) < 0) {
		if (sender.compareTo(reciver) > 0) {
			ownerSend = false;
			owner = reciver;
			actor = sender;
	@Post
	@Path("/readed")
	public void readed(@JdbcConn(true) Connection con, String sender, String reciver, String time) throws SQLException {
	public void readed(@JdbcConn(true) Connection con, String sender, String reciver, String time) throws SQLException, JfwBaseException {
		checkActors(sender, reciver);
		int num = webMsgDao.readed(con, sender, reciver, time);
		if (num > 0) {
			String owner = sender;
		}
	}
	@Post
	@Path("/disable/show")
	public void disableShow(@JdbcConn(true) Connection con, String owner, String actor) throws SQLException, JfwBaseException {
		checkActors(owner, actor);
		if (owner.compareTo(actor) < 0) {
			webMsgDao.disableOwnerShow(con, owner, actor);
		} else {
			webMsgDao.disableActorShow(con, actor, owner);
		}
	}
}

src/main/java/com/ekexiu/portal/msg/WebMsgDao.java

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.Where;
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.SelectList;
	@From(WebMsgCnt.class)
	@SetSentence("READED='1'")
	int readed(Connection con,String sender,String reciver,@LtEq String sendTime)throws SQLException;
	
	@UpdateWith
	@From(WebMsgIdx.class)
	@SetSentence("SHOW_OF_OWNER='0'")
	@Where("SHOW_OF_OWNER='1'")
	int disableOwnerShow(Connection con,String owner,String actor) throws SQLException;
	
	@UpdateWith
	@From(WebMsgIdx.class)
	@SetSentence("SHOW_OF_ACTOR='0'")
	@Where("SHOW_OF_ACTOR='1'")
	int disableActorShow(Connection con,String owner,String actor) throws SQLException;
	
}