111

src/main/java/com/ekexiu/portal/platform/PlatformMsgService.java

package com.ekexiu.portal.platform;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import com.ekexiu.portal.platform.msg.PlatformMsgDao;
import com.ekexiu.portal.platform.msg.PlatformMsgIdx;
import com.ekexiu.portal.platform.msg.PlatformMsgRec;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.jdbc.JdbcUtil;
import com.ekexiu.portal.platform.msg.PlatformMsgDao;
import com.ekexiu.portal.platform.msg.PlatformMsgIdx;
import com.ekexiu.portal.platform.msg.PlatformMsgRec;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
@Path("/platform/msg")
public class PlatformMsgService {
		mr.setPid(pid);
		mr.setProvider(provider);
		mr.setRequestor(requestor);
		mr.setMsgType(1);
		try {
			this.platformMsgDao.insert(con, mr);
		} catch (SQLException ee) {
		mr.setPid(pid);
		mr.setProvider(provider);
		mr.setRequestor(requestor);
		mr.setMsgType(0);
		this.platformMsgDao.insert(con, mr);
		PlatformMsgIdx mi = new PlatformMsgIdx();
		mi.setActived(true);
			mr.setPid(pid);
			mr.setProvider(provider);
			mr.setRequestor(requestor);
			mr.setMsgType(0);
			try {
				this.platformMsgDao.insert(con, mr);
			} catch (SQLException ee) {

src/main/java/com/ekexiu/portal/platform/msg/PlatformMsgDao.java

package com.ekexiu.portal.platform.msg;
import java.sql.Connection;
import java.sql.SQLException;
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.LimitColumn;
import org.jfw.apt.orm.annotation.dao.param.LessThan;
import org.jfw.apt.orm.annotation.dao.param.Set;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
@DAO
public interface PlatformMsgDao {
	
	@SelectList
	@OrderBy("ORDER BY OP_TIME DESC")
	List<PlatformMsgRec> query(Connection con,String provider,String pid,String requestor)throws SQLException;
	
	@LimitSelect
	@OrderBy(cols={ @LimitColumn(value = "opTime", asc = true), 
		@LimitColumn(value = "provider", asc = false),
		@LimitColumn(value = "requestor", asc = false) }, value = "")
	@Where("MSG_TYPE=1")
	List<PlatformMsgRec> queryOld(Connection con,String pid,String opTime,String provider,String requestor,int rows)throws SQLException;
	
	@Insert

src/main/java/com/ekexiu/portal/platform/msg/PlatformMsgRec.java

	private String provider;
	private String cnt;
	private String  opTime;
	private int msgType;// 1： 本地消发出   0：本地接收
	
	@Column(DE.text_de)
	public String getPid() {
	public void setOpTime(String opTime) {
		this.opTime = opTime;
	}
	@Column(DE.int_de)
	public int getMsgType() {
		return msgType;
	}
	public void setMsgType(int msgType) {
		this.msgType = msgType;
	}
}

src/main/resources/database.sql

        REQUESTOR TEXT NOT NULL,
        PROVIDER TEXT NOT NULL,
        CNT TEXT NOT NULL,
        OP_TIME TEXT NOT NULL);
        OP_TIME TEXT NOT NULL,
        MSG_TYPE INTEGER NOT NULL);
CREATE TABLE PLATFORM_MSG_IDX (
        PID TEXT NOT NULL,
        REQUESTOR TEXT NOT NULL,