ddd

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

@@ -0,0 +1,135 @@
package com.ekexiu.portal.platform;
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.Get;
import org.jfw.apt.web.annotation.operate.Post;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.util.DateUtil;
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;
@Path("/platform/msg")
public class PlatformMsgService {
	@Autowrie
	private PlatformMsgDao platformMsgDao;
	public PlatformMsgDao getPlatformMsgDao() {
		return platformMsgDao;
	}
	public void setPlatformMsgDao(PlatformMsgDao platformMsgDao) {
		this.platformMsgDao = platformMsgDao;
	}
	@Get
	@Path("/idx")
	public List<PlatformMsgIdx> query(@JdbcConn Connection con, String provider) throws SQLException {
		return this.platformMsgDao.query(con, provider);
	}
	@Get
	@Path("/rec")
	public List<PlatformMsgRec> query(@JdbcConn Connection con, String provider, String pid, String requestor) throws SQLException {
		return this.platformMsgDao.query(con, provider, pid, requestor);
	}
	@Post
	@Path("/readed")
	public int readed(@JdbcConn(true) Connection con, String provider, String pid, String requestor) throws SQLException {
		return this.platformMsgDao.readed(con, provider, pid, requestor);
	}
	@Post
	@Path("/delete")
	public int delete(@JdbcConn(true) Connection con, String provider, String pid, String requestor) throws SQLException {
		return this.platformMsgDao.delete(con, provider, pid, requestor);
	}
	@Post
	@Path("/send")
	public int send(@JdbcConn(true) Connection con, String provider, String pid, String requestor, String cnt) throws SQLException, JfwBaseException {
		String time = DateUtil.formatDateTime(System.currentTimeMillis());
		PlatformMsgRec mr = new PlatformMsgRec();
		mr.setCnt(cnt);
		mr.setOpTime(time);
		mr.setPid(pid);
		mr.setProvider(provider);
		mr.setRequestor(requestor);
		try {
			this.platformMsgDao.insert(con, mr);
		} catch (SQLException ee) {
			if ("23505".equals(ee.getSQLState())) {
				throw new JfwBaseException(-60001, "interval to small");
			}
		}
		this.platformMsgDao.updateActivedIdx(con, requestor, provider, pid, time, cnt, time);
		return 1;
	}
	@Post
	@Path("/frecv")
	public void frecv(@JdbcConn(true) Connection con, String provider, String pid, String requestor, String cnt, String time)
			throws SQLException, JfwBaseException {
		PlatformMsgRec mr = new PlatformMsgRec();
		mr.setCnt(cnt);
		mr.setOpTime(time);
		mr.setPid(pid);
		mr.setProvider(provider);
		mr.setRequestor(requestor);
		this.platformMsgDao.insert(con, mr);
		PlatformMsgIdx mi = new PlatformMsgIdx();
		mi.setActived(true);
		mi.setCnt(cnt);
		mi.setOpTime(time);
		mi.setPid(pid);
		mi.setProvider(provider);
		mi.setRequestor(requestor);
		mi.setUnread(1);
		this.platformMsgDao.insert(con, mi);
	}
	@Post
	@Path("/recv")
	public void recv(@JdbcConn Connection con, String provider, String pid, String requestor, String cnt, String time) throws SQLException, JfwBaseException {
		try {
			PlatformMsgRec mr = new PlatformMsgRec();
			mr.setCnt(cnt);
			mr.setOpTime(time);
			mr.setPid(pid);
			mr.setProvider(provider);
			mr.setRequestor(requestor);
			try {
				this.platformMsgDao.insert(con, mr);
			} catch (SQLException ee) {
				if ("23505".equals(ee.getSQLState())) {
					JdbcUtil.rollback(con);
					return;
				}
			}
			if (this.platformMsgDao.updateIdxFlag(con, provider, pid, requestor, time) == 0) {
				this.platformMsgDao.updateIdxFull(con, provider, pid, requestor, time, cnt, time);
			}
			con.commit();
		} catch (SQLException e) {
			JdbcUtil.rollback(con);
		} finally {
			JdbcUtil.close(con);
		}
	}
	
	@Get
	@Path("/sync")
	public List<PlatformMsgRec> syncData(@JdbcConn Connection con,String pid,String requestor,String provider,String opTime,int rows)throws SQLException{
		return this.platformMsgDao.queryOld(con, pid, opTime, provider, requestor, rows);
	}
}

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

@@ -0,0 +1,74 @@
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.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.LimitSelect;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.Alias;
import org.jfw.apt.orm.annotation.dao.param.GtEq;
import org.jfw.apt.orm.annotation.dao.param.LessThan;
import org.jfw.apt.orm.annotation.dao.param.Set;
@DAO
public interface PlatformMsgDao {
	
	@SelectList
	@OrderBy("ORDER BY OP_TIME DESC")
	@Where("ACTIVED ='1'")
	List<PlatformMsgIdx> query(Connection con,String provider)throws SQLException;
	
	@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 = "")
	List<PlatformMsgRec> queryOld(Connection con,String pid,String opTime,String provider,String requestor,int rows)throws SQLException;
	
	@Insert
	int insert(Connection con,PlatformMsgRec mr)throws SQLException;
	@Insert
	int insert(Connection con,PlatformMsgIdx mi)throws SQLException;
	
	@UpdateWith
	@From(PlatformMsgIdx.class)
	@SetSentence("UNREAD=0")
	int readed(Connection con,String provider,String pid,String requestor)throws SQLException;
	@UpdateWith
	@From(PlatformMsgIdx.class)
	@SetSentence("ACTIVED='0' ,UNREAD=0")
	int delete(Connection con,String provider,String pid,String requestor)throws SQLException;
	
	
	
	@UpdateWith
	@From(PlatformMsgIdx.class)
	int updateActivedIdx(Connection con,String requestor,String provider,String pid, @LessThan @Alias("opTime") String time ,@Set String cnt,@Set String opTime  )throws SQLException;
	
	
	@UpdateWith
	@From(PlatformMsgIdx.class)
	@SetSentence("ACTIVED='1' ,UNREAD=UNREAD+1")
	int updateIdxFlag(Connection con,String provider,String pid,String requestor,@GtEq String opTime)throws SQLException;
	
	@UpdateWith
	@From(PlatformMsgIdx.class)
	@SetSentence("ACTIVED='1' ,UNREAD=UNREAD+1")
	int updateIdxFull(Connection con,String provider,String pid,String requestor, @LessThan @Alias("opTime") String time,@Set String cnt,@Set String opTime)throws SQLException;
	
}

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

@@ -0,0 +1,72 @@
package com.ekexiu.portal.platform.msg;
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.enums.DE;
@PrimaryKey({"pid","requestor","provider"})
@Table
public class PlatformMsgIdx {
	private String pid;
	private String requestor;
	private String provider;
	private String cnt;
	private String  opTime;
	private int unread;
	private boolean actived;
	
	@Column(DE.text_de)
	public String getPid() {
		return pid;
	}
	public void setPid(String pid) {
		this.pid = pid;
	}
	@Column(DE.text_de)
	public String getRequestor() {
		return requestor;
	}
	public void setRequestor(String requestor) {
		this.requestor = requestor;
	}
	@Column(DE.text_de)
	public String getProvider() {
		return provider;
	}
	public void setProvider(String provider) {
		this.provider = provider;
	}
	@Column(DE.text_de)
	public String getCnt() {
		return cnt;
	}
	public void setCnt(String cnt) {
		this.cnt = cnt;
	}
	@Column(DE.text_de)
	public String getOpTime() {
		return opTime;
	}
	public void setOpTime(String opTime) {
		this.opTime = opTime;
	}
	@Column(DE.int_de)
	public int getUnread() {
		return unread;
	}
	public void setUnread(int unread) {
		this.unread = unread;
	}
	@Column(DE.boolean_de)
	public boolean isActived() {
		return actived;
	}
	public void setActived(boolean actived) {
		this.actived = actived;
	}
	
	
	
	
}

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

@@ -0,0 +1,50 @@
package com.ekexiu.portal.platform.msg;
import org.jfw.apt.orm.annotation.entry.Column;
import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
@Table
public class PlatformMsgRec {
	private String pid;
	private String requestor;
	private String provider;
	private String cnt;
	private String  opTime;
	
	@Column(DE.text_de)
	public String getPid() {
		return pid;
	}
	public void setPid(String pid) {
		this.pid = pid;
	}
	@Column(DE.text_de)
	public String getRequestor() {
		return requestor;
	}
	public void setRequestor(String requestor) {
		this.requestor = requestor;
	}
	@Column(DE.text_de)
	public String getProvider() {
		return provider;
	}
	public void setProvider(String provider) {
		this.provider = provider;
	}
	@Column(DE.text_de)
	public String getCnt() {
		return cnt;
	}
	public void setCnt(String cnt) {
		this.cnt = cnt;
	}
	@Column(DE.text_de)
	public String getOpTime() {
		return opTime;
	}
	public void setOpTime(String opTime) {
		this.opTime = opTime;
	}
}