对话列表

src/main/java/com/ekexiu/console/system/dao/WebMsgDao.java

@@ -0,0 +1,34 @@
package com.ekexiu.console.system.dao;
import com.ekexiu.console.system.po.WebMsgCnt;
import com.ekexiu.console.system.pojo.WebMsgIdxInfo;
import org.jfw.apt.annotation.Nullable;
import org.jfw.apt.orm.annotation.dao.DAO;
import org.jfw.apt.orm.annotation.dao.method.Exclude;
import org.jfw.apt.orm.annotation.dao.method.OrderBy;
import org.jfw.apt.orm.annotation.dao.method.operator.PageQuery;
import org.jfw.apt.orm.annotation.dao.method.operator.SelectList;
import org.jfw.apt.orm.annotation.dao.param.GroupSqlColumn;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
import org.jfw.util.PageQueryResult;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
/**
 * Created by TT on 2017/9/30.
 */
@DAO
public interface WebMsgDao {
    @Exclude({"showOfOwner", "showOfActor"})
    @PageQuery
    @OrderBy("ORDER BY LAST_TIME DESC,OWNER ASC")
    PageQueryResult<WebMsgIdxInfo> query(Connection con, @Nullable @GroupSqlColumn(handlerClass = StringHandler.class,value = {"own.name like ?","actor.name like ?"},isAnd = false)String name, int pageSize, int pageNo) throws SQLException;
    @SelectList
    @OrderBy("ORDER BY SEND_TIME asc")
    List<WebMsgCnt> queryAll(Connection con, @GroupSqlColumn(handlerClass = StringHandler.class, value = {"SENDER=?", "RECIVER=?"}, isAnd = false) String actor1, @GroupSqlColumn(handlerClass = StringHandler.class, value = {"SENDER=?", "RECIVER=?"}, isAnd = false) String actor2) throws SQLException;
}

src/main/java/com/ekexiu/console/system/po/WebMsgCnt.java

@@ -0,0 +1,75 @@
package com.ekexiu.console.system.po;
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;
/**
 * Created by TT on 2017/9/30.
 */
@PrimaryKey({"sender", "reciver", "sendTime"})
@Table
public class WebMsgCnt {
    private String cnt;
    private String sendTime;
    private String sender;
    private String reciver;
    private boolean readed;
    /**
     * 消息内容
     * @return
     */
    @Column(DE.text_de)
    public String getCnt() {
        return cnt;
    }
    public void setCnt(String cnt) {
        this.cnt = cnt;
    }
    @Column(DE.text_de)
    public String getSendTime() {
        return sendTime;
    }
    public void setSendTime(String sendTime) {
        this.sendTime = sendTime;
    }
    @Column(DE.text_de)
    public String getSender() {
        return sender;
    }
    public void setSender(String sender) {
        this.sender = sender;
    }
    @Column(DE.text_de)
    public String getReciver() {
        return reciver;
    }
    public void setReciver(String reciver) {
        this.reciver = reciver;
    }
    /**
     * 是否已读
     * @return
     */
    @Column(DE.boolean_de)
    public boolean isReaded() {
        return readed;
    }
    public void setReaded(boolean readed) {
        this.readed = readed;
    }
}

src/main/java/com/ekexiu/console/system/po/WebMsgIdx.java

@@ -0,0 +1,130 @@
package com.ekexiu.console.system.po;
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;
/**
 * Created by TT on 2017/9/30.
 */
@PrimaryKey({"owner", "actor"})
@Table
public class WebMsgIdx {
    private String owner;
    private String actor;
    private long lastTime;
    private int numOfOwner;
    private int numOfActor;
    private String lastCnt;
    private boolean showOfOwner;
    private boolean showOfActor;
    /**
     * 所有者(两个ID相比小的是Owner)
     * @return
     */
    @Column(DE.text_de)
    public String getOwner() {
        return owner;
    }
    public void setOwner(String owner) {
        this.owner = owner;
    }
    /**
     * 参与者
     * @return
     */
    @Column(DE.text_de)
    public String getActor() {
        return actor;
    }
    public void setActor(String actor) {
        this.actor = actor;
    }
    /**
     * 最后发送时间
     * @return
     */
    @Column(DE.long_de)
    public long getLastTime() {
        return lastTime;
    }
    public void setLastTime(long lastTime) {
        this.lastTime = lastTime;
    }
    /**
     * 未读信息数(所有者)
     * @return
     */
    @Column(DE.int_de)
    public int getNumOfOwner() {
        return numOfOwner;
    }
    public void setNumOfOwner(int num) {
        this.numOfOwner = num;
    }
    /**
     * 未读信息数(参有者)
     * @return
     */
    @Column(DE.int_de)
    public int getNumOfActor() {
        return numOfActor;
    }
    public void setNumOfActor(int numOfActor) {
        this.numOfActor = numOfActor;
    }
    /**
     * 最后信息内容
     * @return
     */
    @Column(DE.text_de)
    public String getLastCnt() {
        return lastCnt;
    }
    public void setLastCnt(String lastCnt) {
        this.lastCnt = lastCnt;
    }
    /**
     * 所有者是否显示（会话在所有者的列表中未被删除）
     * @return
     */
    @Column(DE.boolean_de)
    public boolean isShowOfOwner() {
        return showOfOwner;
    }
    public void setShowOfOwner(boolean showOfOwner) {
        this.showOfOwner = showOfOwner;
    }
    /**
     * 参与者是否显示（会话在参与者的列表中未被删除）
     * @return
     */
    @Column(DE.boolean_de)
    public boolean isShowOfActor() {
        return showOfActor;
    }
    public void setShowOfActor(boolean showOfActor) {
        this.showOfActor = showOfActor;
    }
}

src/main/java/com/ekexiu/console/system/pojo/WebMsgIdxInfo.java

@@ -0,0 +1,33 @@
package com.ekexiu.console.system.pojo;
import com.ekexiu.console.system.po.WebMsgIdx;
import org.jfw.apt.orm.annotation.entry.CalcColumn;
import org.jfw.apt.orm.annotation.entry.ExtendView;
import org.jfw.apt.orm.core.defaultImpl.StringHandler;
/**
 * Created by TT on 2017/10/9.
 */
@ExtendView(fromSentence = "web_msg_idx msg LEFT JOIN professor own on own.id = msg.owner LEFT JOIN professor actor on actor.id = msg.actor",tableAlias = "msg")
public class WebMsgIdxInfo extends WebMsgIdx{
    private String ownerName;
    private String actorName;
    @CalcColumn(handlerClass = StringHandler.class, column = "own.name")
    public String getOwnerName() {
        return ownerName;
    }
    public void setOwnerName(String ownerName) {
        this.ownerName = ownerName;
    }
    @CalcColumn(handlerClass = StringHandler.class, column = "actor.name")
    public String getActorName() {
        return actorName;
    }
    public void setActorName(String actorName) {
        this.actorName = actorName;
    }
}

src/main/java/com/ekexiu/console/system/service/WebMsgService.java

@@ -0,0 +1,48 @@
package com.ekexiu.console.system.service;
import com.ekexiu.console.system.dao.WebMsgDao;
import com.ekexiu.console.system.po.WebMsgCnt;
import com.ekexiu.console.system.pojo.WebMsgIdxInfo;
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.param.JdbcConn;
import org.jfw.util.PageQueryResult;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
/**
 * Created by TT on 2017/9/30.
 */
@Path("/Msg")
public class WebMsgService {
    @Autowrie
    WebMsgDao webMsgDao;
    public WebMsgDao getWebMsgDao() {
        return webMsgDao;
    }
    public void setWebMsgDao(WebMsgDao webMsgDao) {
        this.webMsgDao = webMsgDao;
    }
    @Path("/qa")
    @Get
    public PageQueryResult<WebMsgIdxInfo> query(@JdbcConn Connection con, @Nullable String name,@DefaultValue("1") int pageNo, @DefaultValue("10") int pageSize)throws SQLException{
        if (name != null) {
            name =  "%" + name + "%";
        }
        return webMsgDao.query(con,name,pageSize, pageNo);
    }
    @Path("/cnt")
    @Get
    public List<WebMsgCnt> queryCnt(@JdbcConn Connection con, String actor1, String actor2)throws SQLException {
        return webMsgDao.queryAll(con, actor1, actor2);
    }
}