111

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

@@ -76,6 +76,12 @@ public class PlatformMsgService {
		return 1;
	}
	@Get
	@Path("/unread")
	public int unreadSum(@JdbcConn Connection con, String provider)throws SQLException {
		return this.platformMsgDao.unreadSum(con, provider);
	}
	@Post
	@Path("/frecv")
	public void frecv(@JdbcConn(true) Connection con, String provider, String pid, String requestor, String cnt, String time)

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

@@ -1,5 +1,7 @@
package com.ekexiu.portal.platform.msg;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.orm.annotation.dao.Column;
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;
@@ -8,12 +10,14 @@ 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.QueryVal;
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;
import org.jfw.apt.orm.core.defaultImpl.IntHandler;
import java.sql.Connection;
import java.sql.SQLException;
@@ -70,5 +74,11 @@ public interface PlatformMsgDao {
	@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;
	@QueryVal
	@From(PlatformMsgIdx.class)
	@DefaultValue("0")
	@Column(value="SUM(UNREAD)",handlerClass= IntHandler.class)
	int unreadSum(Connection con,String provider) throws SQLException;
	
}