11

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

		"SELECT ID id,'3' ctype,uid uid,title title,	last_reply_time tm,reply_count num,img img,null col	FROM question where state='1' UNION ALL "+
		"SELECT ARTICLE_ID id,	'1' ctype,professor_id uid,article_title title,publish_time tm,	0 num,article_img img,col_num col FROM article WHERE status = '1' AND article_type = '1' AND article_id <>? UNION ALL "+
		"SELECT ARTICLE_ID id,	'2' ctype,org_id uid,article_title title,publish_time tm,0 num,article_img img,col_num col FROM article WHERE status = '1' AND article_type = '2' AND article_id <>? 	) T "+
        "WHERE T.tm <= ? AND T.id > ? ORDER BY tm DESC LIMIT ?", new PreparedStatementConfig() {
        "WHERE T.tm<? OR (T.tm = ? AND T.id > ?) ORDER BY tm DESC LIMIT ?", new PreparedStatementConfig() {
			@Override
			public void config(PreparedStatement ps) throws SQLException {
				ps.setString(1,ex);
				ps.setString(2, ex);
				ps.setString(3, time);
				ps.setString(4, id);
				ps.setInt(5,rows);
				ps.setString(4, time);
				ps.setString(5, id);
				ps.setInt(6,rows);
			}
		});
	}

src/main/java/com/ekexiu/portal/leavemsg/LeaveMsg.java

import org.jfw.apt.orm.annotation.entry.Table;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.portal.basepo.CreateTimeSupported;
import com.ekexiu.portal.basepo.ModifyTimeSupported;
@PrimaryKey("id")
@Table
public class LeaveMsg implements CreateTimeSupported,ModifyTimeSupported {
public class LeaveMsg implements ModifyTimeSupported {
	private String id;
	private String cnt;
	private String state;
	private long  agreeCount;
	
	private transient String timeDesc;
	
	@Column(DE.text_de)
	public String getTimeDesc() {
		return timeDesc;
	}
	public void setTimeDesc(String timeDesc) {
		this.timeDesc = timeDesc;
	}
	/**
	 * id
	 * @return
	public void setReciver(String reciver) {
		this.reciver = reciver;
	}
	@Column(DE.text_de)
	public String getCreateTime() {
		return createTime;
	}

src/main/java/com/ekexiu/portal/leavemsg/LeaveMsgDao.java

package com.ekexiu.portal.leavemsg;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.Column;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.*;
import org.jfw.apt.orm.annotation.dao.method.operator.*;
import org.jfw.apt.orm.annotation.dao.method.From;
import org.jfw.apt.orm.annotation.dao.method.IncludeFixSet;
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.QueryVal;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.GreaterThan;
import org.jfw.apt.orm.annotation.dao.param.GroupSqlColumn;
import org.jfw.apt.orm.annotation.dao.param.GtEq;
import org.jfw.apt.orm.core.defaultImpl.IntHandler;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
@DAO
public interface LeaveMsgDao {
	@LimitSelect
	@Where("STATE='1'")
	@OrderBy("ORDER BY CREATE_TIME ASC,ID ASC")
	List<LeaveMsg> query(Connection con, String refId, String refType, @GtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
	@OrderBy("ORDER BY TIME_DESC ASC")
	List<LeaveMsg> query(Connection con, String refId, String refType, @GreaterThan String timeDesc, int rows) throws SQLException;
	@Nullable
	@SelectOne
	LeaveMsgAgreeRec queryAgreeRec(Connection con, String id, String uid) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY CREATE_TIME ASC,ID ASC")
	List<LeaveMsg> queryWithParent(Connection con, String parent, @GtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
	@OrderBy("ORDER BY TIME_DESC ASC")
	List<LeaveMsg> queryWithParent(Connection con, String parent, @GreaterThan String timeDesc, int rows) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY CREATE_TIME ASC,ID ASC")
	@OrderBy("ORDER BY TIME_DESC ASC")
	List<LeaveMsg> queryWithTop(Connection con, String top,
			@GroupSqlColumn(handlerClass = StringHandler.class, isAnd = false, value = { "SENDER=?", "RECIVER=?" }, force = true) String sid,
			@GroupSqlColumn(handlerClass = StringHandler.class, isAnd = false, value = { "SENDER=?", "RECIVER=?" }, force = true) String rid,
			@GtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
			 @GreaterThan String timeDesc,int rows) throws SQLException;
	@QueryVal
	@From(LeaveMsg.class)

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

import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.annotation.DefaultValue;
import org.jfw.apt.annotation.Nullable;
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.FieldParam;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.apt.web.annotation.param.RequestParam;
import org.jfw.util.DateUtil;
import org.jfw.util.StringUtil;
import org.jfw.util.exception.JfwBaseException;
import org.jfw.util.jdbc.JdbcUtil;
					@FieldParam(value = "refType", valueClass = String.class), @FieldParam(value = "sender", valueClass = String.class) }) LeaveMsg msg,
			 String uname, @AfterCommit List<Runnable> runs) throws SQLException, JfwBaseException {
		String id = StringUtil.buildUUID();
		String time = DateUtil.formatDate(System.currentTimeMillis());
		msg.setId(id);
		msg.setTop(id);
		msg.setState("1");
		msg.setParent(null);
		msg.setAgreeCount(0);
		msg.setCreateTime(time);
		msg.setTimeDesc(time+id);
		leaveMsgDao.insert(con, msg);
		this.notify(con, msg.getRefType(), msg.getRefId(), null, msg.getSender(), uname, id,false, runs);
		return id;
		msg.setState("1");
		msg.setCnt(cnt);
		msg.setId(nid);
		String time = DateUtil.formatDate(System.currentTimeMillis());
		msg.setCreateTime(time);
		msg.setTimeDesc(time+nid);
		leaveMsgDao.insert(con, msg);
		this.notify(con, msg.getRefType(), msg.getRefId(), msg.getReciver(), uid, uname, id,false, runs);
		return nid;
	@Path("/subject")
	public List<LeaveMsg> query(@JdbcConn Connection con, String stype, String sid, @DefaultValue("\"0\"") String time, @DefaultValue("\"0\"") String id,
			int rows) throws SQLException {
		return leaveMsgDao.query(con, sid, stype, time, id, rows);
		return leaveMsgDao.query(con, sid, stype, time+id, rows);
	}
	@Get
		if (msg == null)
			throw new JfwBaseException(50000, "leave message[id:" + id + "] not found");
		if (msg.getId().equals(msg.getTop())) {
			ret = leaveMsgDao.queryWithParent(con, msg.getId(), "0", "0", Integer.MAX_VALUE);
			ret = leaveMsgDao.queryWithParent(con, msg.getId(), "0", Integer.MAX_VALUE);
			ret.add(0, msg);
		} else {
			ret = leaveMsgDao.queryWithTop(con, msg.getId(), msg.getSender(), msg.getReciver(), "0", "0", Integer.MAX_VALUE);
			ret = leaveMsgDao.queryWithTop(con, msg.getId(), msg.getSender(), msg.getReciver(), "0", Integer.MAX_VALUE);
		}
		return ret;
	}

src/main/java/com/ekexiu/portal/notify/NotifyMsgCnt.java

	private String uid;
	private String createTime;
	private int opType;
	
	private transient String timeDesc;
	@Column(DE.text_de)
	public String getTimeDesc() {
		return timeDesc;
	}
	public void setTimeDesc(String timeDesc) {
		this.timeDesc = timeDesc;
	}
	@Column(DE.id_32)
	public String getId() {
		return id;

src/main/java/com/ekexiu/portal/notify/NotifyMsgDao.java

import org.jfw.apt.orm.annotation.dao.method.operator.LimitSelect;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectOne;
import org.jfw.apt.orm.annotation.dao.method.operator.UpdateWith;
import org.jfw.apt.orm.annotation.dao.param.GreaterThan;
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.LtEq;
import org.jfw.apt.orm.annotation.dao.param.Set;
	
	
	@LimitSelect
	@OrderBy("ORDER BY CREATE_TIME DESC,ID ASC")
	List<NotifyMsgCnt> queryCnt(Connection con,String reciver,@LtEq String createTime,@GreaterThan String id,int rows)throws SQLException;
	@OrderBy("ORDER BY TIME_DESC DESC")
	List<NotifyMsgCnt> queryCnt(Connection con,String reciver,@LessThan String timeDesc,int rows)throws SQLException;
	
	@UpdateWith
	@From(NotifyMsgCnt.class)
	@SetSentence("READED='1'")
	@Where("READED<>'1'")
	int readed(Connection con,String reciver ,@LtEq String createTime,@GtEq String id)throws SQLException; 
	int readed(Connection con,String reciver ,@LtEq String timeDesc)throws SQLException; 
}

src/main/java/com/ekexiu/portal/notify/NotifyService.java

		cnt.setReaded(false);
		cnt.setReciver(rid);
		cnt.setUid(uid);
		cnt.setTimeDesc(time+id);
		notifyMsgDao.insert(con, cnt);
		final NotifyMsgIdx idx = new NotifyMsgIdx();
		idx.setLastCnt(tCnt);
	@Get
	public List<NotifyMsgCnt> query(@JdbcConn Connection con, String uid, @DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String mid,
			@DefaultValue("20") int rows) throws SQLException {
		return notifyMsgDao.queryCnt(con, uid, time, mid, rows);
		return notifyMsgDao.queryCnt(con, uid, time+mid, rows);
	}
	@Post
	@Path("/readed")
	public int read(@JdbcConn(true) Connection con,String uid,String time,String mid)throws SQLException{
		int num = this.notifyMsgDao.readed(con, uid,time, mid);
		int num = this.notifyMsgDao.readed(con, uid,time+mid);
		if(num>0){
			this.notifyMsgDao.decUnRead(con, uid,num);
		}

src/main/java/com/ekexiu/portal/question/Answer.java

import org.jfw.apt.orm.annotation.entry.Uniques;
import org.jfw.apt.orm.core.enums.DE;
import com.ekexiu.portal.basepo.CreateTimeSupported;
import com.ekexiu.portal.basepo.ModifyTimeSupported;
@PrimaryKey("id")
@Uniques({@Unique(clolumns={"qid","uid"},name="UNI_ANSWER_QID_UID")})
@Table
public class Answer  implements CreateTimeSupported,ModifyTimeSupported{
public class Answer  implements ModifyTimeSupported{
	private String id;
	private String qid;
	private String uid;
	private long  ballot;
	private String createTime;
	private String modifyTime;
	private transient String timeDesc;
	
	@Column(DE.text_de)
	public String getTimeDesc() {
		return timeDesc;
	}
	public void setTimeDesc(String timeDesc) {
		this.timeDesc = timeDesc;
	}
	/**
	 * ID
	 * @return
	public void setBallot(long ballot) {
		this.ballot = ballot;
	}
	@Column(DE.text_de)
	public String getCreateTime() {
		return createTime;
	}

src/main/java/com/ekexiu/portal/question/Question.java

@PrimaryKey("id")
@Table
public class Question implements CreateTimeSupported,ModifyTimeSupported{
public class Question implements ModifyTimeSupported{
	
	private String id;
	private String title;
	private String lastReplyTime;
	private long replyCount;
	private String state;
	private transient String timeDesc;
	
	
	@Column(DE.text_de)
	public String getTimeDesc() {
		return timeDesc;
	}
	public void setTimeDesc(String timeDesc) {
		this.timeDesc = timeDesc;
	}
	/**
	 * ID
	 * @return
	public void setImg(String img) {
		this.img = img;
	}
	@Column(DE.text_de)
	public String getCreateTime() {
		return createTime;
	}

src/main/java/com/ekexiu/portal/question/QuestionDao.java

	int[] insert(Connection con, QetKeyWord[] kws) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY CREATE_TIME DESC,ID ASC")
	List<Question> query(Connection con, @Nullable String state, @Nullable String uid, @LtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
	@OrderBy("ORDER BY TIME_DESC DESC")
	List<Question> query(Connection con, @Nullable String state, @Nullable String uid, @LessThan String timeDesc, int rows) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY CREATE_TIME DESC,ID ASC")
	@OrderBy("ORDER BY TIME_DESC DESC")
	@Where(" STATE='1'")
	List<Question> watch(Connection con,
			@SqlColumn(handlerClass = StringHandler.class, value = {
					" ID IN (SELECT WATCH_OBJECT FROM WATCH WHERE WATCH_TYPE='8' AND PROFESSOR_ID=?)" }) String uid,
			@LtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
			@LessThan String timeDesc, int rows) throws SQLException;
	@SelectOne
	@Nullable
	List<Question> query(Connection con, @In String[] id) throws SQLException;
	
	@LimitSelect
	@OrderBy("ORDER BY CREATE_TIME DESC,ID ASC")
	@OrderBy("ORDER BY TIME_DESC DESC")
	@Where("QID IN(SELECT ID FROM QUESTION WHERE STATE='1') AND STATE='1'")
	List<Answer> answer(Connection con,@LtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
	List<Answer> answer(Connection con,@LessThan String timeDesc, int rows) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY CREATE_TIME DESC,ID ASC")
	@OrderBy("ORDER BY TIME_DESC DESC")
	@Where("QID IN(SELECT ID FROM QUESTION WHERE STATE='1') AND STATE='1'")
	List<Answer> answerSelf(Connection con, String uid, @LtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
	List<Answer> answerSelf(Connection con, String uid, @LessThan String timeDesc, int rows) throws SQLException;
	
	@SelectOne
	@Nullable
	Answer answer(Connection con,String uid,String qid)throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY CREATE_TIME DESC,ID ASC")
	@OrderBy("ORDER BY TIME_DESC DESC")
	@Where("QID IN(SELECT ID FROM QUESTION WHERE STATE='1') AND STATE='1'")
	List<Answer> watchAnswer(Connection con,
			@SqlColumn(handlerClass = StringHandler.class, value = {
					" ID IN (SELECT WATCH_OBJECT FROM WATCH WHERE WATCH_TYPE='9' AND PROFESSOR_ID=?)" }) String uid,
			@LtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
			@LessThan String timeDesc, int rows) throws SQLException;
	@LimitSelect
	@OrderBy("ORDER BY CREATE_TIME DESC,ID ASC")
	List<Answer> byQes(Connection con, String qid, @LtEq String createTime, @GreaterThan String id, int rows) throws SQLException;
	@OrderBy("ORDER BY TIME_DESC DESC")
	List<Answer> byQes(Connection con, String qid, @LessThan String timeDesc, int rows) throws SQLException;
	@LimitQuery
	@OrderBy("ORDER BY SCORE DESC,ID ASC")
	List<SortedAnswwer> byQes(Connection con, String qid, @SqlColumn(handlerClass = IntHandler.class, value = { "(10000 * AGREE+1) / (BALLOT+1) <= ?  " }) int score, @GreaterThan String id, int rows) throws SQLException;
	List<SortedAnswwer> byQesScore(Connection con, String qid, @SqlColumn(handlerClass = StringHandler.class, value = { "(TO_CHAR((10000 * (AGREE+1)) / (BALLOT+1),'00009')+ID) < ?  " })  String score, int rows) throws SQLException;
	@Insert
	int insert(Connection con,AnswerAgreeRec aar)throws SQLException;

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

	@Path()
	public List<Question> query(@JdbcConn Connection con, @DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.query(con, "1", null, time, id, rows);
		return questionDao.query(con, "1", null, time+id, rows);
	}
	/**
	@Path("/my")
	public List<Question> querySelf(@JdbcConn Connection con, String uid, @DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.query(con, "1", uid, time, id, rows);
		return questionDao.query(con, "1", uid, time+id, rows);
	}
	/**
	@Path("/watch")
	public List<Question> watch(@JdbcConn Connection con, String uid, @DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.watch(con, uid, time, id, rows);
		return questionDao.watch(con, uid, time+ id, rows);
	}
	/**
	@Path("/answer/bySelf")
	public List<Answer> answerSelf(@JdbcConn Connection con, String uid, @DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.answerSelf(con, uid, time, id, rows);
		return questionDao.answerSelf(con, uid, time+id, rows);
	}
	/**
	@Path("/answer/byWatch")
	public List<Answer> answerWatch(@JdbcConn Connection con, String uid, @DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.watchAnswer(con, uid, time, id, rows);
		return questionDao.watchAnswer(con, uid, time+id, rows);
	}
	
	/**
	@Path("/answer/byTime")
	public List<Answer> answerByTime(@JdbcConn Connection con,@DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.answer(con,  time, id, rows);
		return questionDao.answer(con,  time+ id, rows);
	}
	/**
	 * 指定提问的回答(按最新回答时间，由新到旧排序）
	@Path("/answer/qes/byTime")
	public List<Answer> byQes(@JdbcConn Connection con, String qid, @DefaultValue("\"99999999999999\"") String time, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.byQes(con, qid, time, id, rows);
		return questionDao.byQes(con, qid, time+id, rows);
	}
	/**
	@Path("/answer/qes/byScore")
	public List<SortedAnswwer> byQes(@JdbcConn Connection con, String qid, @DefaultValue("100000") int score, @DefaultValue("\"0\"") String id,
			@DefaultValue("10000000") int rows) throws SQLException {
		return questionDao.byQes(con, qid, score, id, rows);
		String p = "000000"+score;
		p = p.substring(p.length()-5)+id;
		return questionDao.byQesScore(con, qid, p, rows);
	}
	
	

src/main/java/com/ekexiu/portal/question/SortedAnswwer.java

public class SortedAnswwer extends Answer {
	private long score ;
	@CalcColumn(nullable=false,handlerClass=LongHandler.class,column="(10000 * agree+1) / (ballot+1) SCORE")
	@CalcColumn(nullable=false,handlerClass=LongHandler.class,column="(10000 * (agree+1)) / (ballot+1) SCORE")
	public long getScore() {
		return score;
	}

src/main/resources/database.sql

--modify begin at version2.20
CREATE TABLE LEAVE_MSG (ID CHAR(32) NOT NULL,CNT TEXT NOT NULL,REF_ID TEXT NOT NULL,REF_TYPE CHAR(1) NOT NULL,
TOP TEXT NOT NULL,PARENT TEXT,SENDER TEXT NOT NULL,RECIVER TEXT,STATE CHAR(1) NOT NULL,AGREE_COUNT BIGINT NOT NULL,CREATE_TIME CHAR(14) NOT NULL,MODIFY_TIME CHAR(14) NOT NULL);
TOP TEXT NOT NULL,PARENT TEXT,SENDER TEXT NOT NULL,RECIVER TEXT,STATE CHAR(1) NOT NULL,AGREE_COUNT BIGINT NOT NULL,
CREATE_TIME CHAR(14) NOT NULL,MODIFY_TIME CHAR(14) NOT NULL,TIME_DESC TEXT NOT NULL);
ALTER TABLE LEAVE_MSG ADD PRIMARY KEY (ID);
COMMENT ON TABLE LEAVE_MSG is '留言表（新）';
COMMENT ON COLUMN LEAVE_MSG.ID is '留言ID';
CREATE TABLE QUESTION (ID CHAR(32) NOT NULL,TITLE TEXT NOT NULL,
CNT TEXT,IMG TEXT,KEYS TEXT NOT NULL,
UID TEXT NOT NULL,LAST_REPLY_TIME CHAR(14),
REPLY_COUNT BIGINT NOT NULL,STATE CHAR(1) NOT NULL,CREATE_TIME CHAR(14) NOT NULL,MODIFY_TIME CHAR(14) NOT NULL);
REPLY_COUNT BIGINT NOT NULL,STATE CHAR(1) NOT NULL,CREATE_TIME CHAR(14) NOT NULL,
TIME_DESC TEXT NOT NULL,MODIFY_TIME CHAR(14) NOT NULL);
ALTER TABLE QUESTION ADD PRIMARY KEY (ID);
COMMENT ON TABLE QUESTION is '提问表';
COMMENT ON COLUMN QUESTION.ID is '提问ID';
CREATE TABLE ANSWER (ID CHAR(32) NOT NULL,QID TEXT NOT NULL,UID TEXT NOT NULL,STATE CHAR(1) NOT NULL,
CNT TEXT NOT NULL,AGREE BIGINT NOT NULL,BALLOT BIGINT NOT NULL,CREATE_TIME CHAR(14) NOT NULL,MODIFY_TIME CHAR(14) NOT NULL);
CNT TEXT NOT NULL,AGREE BIGINT NOT NULL,BALLOT BIGINT NOT NULL,CREATE_TIME CHAR(14) NOT NULL,
TIME_DESC TEXT NOT NULL,MODIFY_TIME CHAR(14) NOT NULL);
ALTER TABLE ANSWER ADD PRIMARY KEY (ID);
ALTER TABLE ANSWER ADD UNIQUE (QID,UID);
COMMENT ON TABLE ANSWER is '回答表';
COMMENT ON COLUMN NOTIFY_MSG_IDX.UN_READ is '未读通知数';
CREATE TABLE NOTIFY_MSG_CNT (ID CHAR(32) NOT NULL,CNT TEXT NOT NULL,RECIVER TEXT NOT NULL,READED CHAR(1) NOT NULL,
PID TEXT NOT NULL,UID TEXT NOT NULL,CREATE_TIME TEXT NOT NULL,OP_TYPE INTEGER NOT NULL);
PID TEXT NOT NULL,UID TEXT NOT NULL,CREATE_TIME TEXT NOT NULL,OP_TYPE INTEGER NOT NULL,TIME_DESC TEXT NOT NULL);
ALTER TABLE NOTIFY_MSG_CNT ADD PRIMARY KEY (ID);
COMMENT ON TABLE NOTIFY_MSG_CNT is '通知内容表';
COMMENT ON COLUMN NOTIFY_MSG_CNT.ID is '通知ID';