bwj_server/src/dsb/com/cnd3b/restcontroller/system/im/imdialog/imdialog.java

package com.cnd3b.restcontroller.system.im.imdialog;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.cnd3b.common.Controller;
import com.cnd3b.common.D3bException;
import com.cnd3b.common.data.Row;
import com.cnd3b.common.data.Rows;
import com.cnd3b.common.data.RowsMap;
import com.cnd3b.common.data.SQLFactory;
import p2.pao.PaoRemote;
import p2.pao.PaoSetRemote;
import p2.util.P2Exception;

import java.util.ArrayList;

public class imdialog extends Controller {

    /**
     * 构造函数
     *
     * @param content
     */
    public imdialog(JSONObject content) {
        super(content);
    }

    /**
     * 群对话框列表查询
     *
     * @return
     */
    public String query_imdialogList() {
        /**
         * 过滤条件设置
         */
        StringBuffer where = new StringBuffer(" 1=1 ");
        if (content.containsKey("where")) {
            JSONObject whereObject = content.getJSONObject("where");
            if (whereObject.containsKey("condition") && !"".equals(whereObject.getString("condition"))) {
                where.append(" and(");
                where.append("t1.fimdialogname like'%").append(whereObject.getString("condition")).append("%' ");
                where.append(")");
            }
        }
        SQLFactory timdialogSQL = new SQLFactory(this, "即时通讯普通群列表查询");
        timdialogSQL.addParameter("siteid", siteid);
        timdialogSQL.addParameter("tenterprise_userid", userid);
        timdialogSQL.addParameter_SQL("where", where);
        Rows rows = dbConnect.runSqlQuery(timdialogSQL.getSQL());

        SQLFactory timnewmsgSQL = new SQLFactory(this, "即时通讯普通群最新消息查询");
        timnewmsgSQL.addParameter("siteid", siteid);
        timnewmsgSQL.addParameter_in("timdialogid", rows.toArrayList("timdialogid"));
        RowsMap newmsgmap = timnewmsgSQL.runSqlQuery().toRowsMap("timdialogid");
        for (Row row : rows) {
            row.put("latestnews", newmsgmap.get(row.getString("timdialogid")));//最新消息
        }
        return getSucReturnObject().setData(rows).saveToDataPool().toString();
    }

    /**
     * 群主界面查询
     *
     * @return
     */
    public String query_imdialogMain() {
        long timdialogid = content.getLong("timdialogid");
        SQLFactory timdialogSQL = new SQLFactory(this, "即时通讯群主界面查询");
        timdialogSQL.addParameter("siteid", siteid);
        timdialogSQL.addParameter("tenterprise_userid", userid);
        timdialogSQL.addParameter("timdialogid", timdialogid);

        Rows rows = dbConnect.runSqlQuery(timdialogSQL.getSQL());
        for (Row row : rows) {
            SQLFactory timdialoguserSQL = new SQLFactory(this, "即时通讯群成员列表查询");
            timdialoguserSQL.addParameter("siteid", siteid);
            timdialoguserSQL.addParameter("timdialogid", content.getString("timdialogid"));
            Rows userrows = dbConnect.runSqlQuery(timdialoguserSQL.getSQL());
            row.put("users", userrows);
        }
        return getSucReturnObject().setData(rows).toString();
    }

    /**
     * 群消息查询
     *
     * @return
     */
    public String query_imdialogMessage() {
        long timdialogid = content.getLong("timdialogid");
        /**
         *排序条件设置
         */
        String[] sortfield = {"t1.createdate desc"};
        String sort = getSort(sortfield, "t1.createdate desc");
        SQLFactory timdialogSQL = new SQLFactory(this, "即时通讯群历史消息查询", pageSize, pageNumber, sort);
        timdialogSQL.addParameter("siteid", siteid);
        timdialogSQL.addParameter("timdialogid", timdialogid);
        Rows rows = dbConnect.runSqlQuery(timdialogSQL.getSQL());
        for (Row row : rows) {
            String message = row.getString("message");
            row.put("message", JSONObject.parseObject(message));
        }
        //清除未读消息数
        dbConnect.runSqlUpdate("update timdialogusers set funreadmsgcount=0 where siteid='" + siteid + "' and timdialogid='" + timdialogid + "' and tenterprise_userid='" + userid + "'");
        return getSucReturnObject().setDataByPaging(rows).toString();
    }

    public String restUnReadMsgCount() {
        long timdialogid = content.getLong("timdialogid");
        dbConnect.runSqlUpdate("update timdialogusers set funreadmsgcount=0 where siteid='" + siteid + "' and timdialogid='" + timdialogid + "' and tenterprise_userid='" + userid + "'");
        return getSucReturnObject().toString();
    }


    /**
     * 新建聊天对话框
     *
     * @return
     * @throws D3bException
     * @throws P2Exception
     */
    public String insertOrModify() throws D3bException, P2Exception {
        long timdialogid = content.getLongValue("timdialogid"); //群ID 新增时默认传0
        String fimdialogname = content.getString("fimdialogname", "timdialog.fimdialogname", "群名称");//群名称
        String fimdialogtype = content.getString("fimdialogtype");//对话类型
        String ownertable = content.getString("ownertable");//所有表
        String ownerid = content.getString("ownerid");//所有表ID

        ArrayList<String> sqlList = new ArrayList<>();

        PaoSetRemote timdialogSet = getP2ServerSystemPaoSet("timdialog", "siteid='" + siteid + "' and timdialogid='" + timdialogid + "'");
        PaoRemote timdialog = null;
        if (timdialogid <= 0 || timdialogSet.isEmpty()) {
            /**
             * 创建对话框
             */
            timdialog = timdialogSet.addAtEnd();
            timdialog.setValue("siteid", siteid, 11L);//企业ID
            timdialog.setValue("createby", username, 11L);//创建人
            timdialog.setValue("createdate", sysdate, 11L);//创建时间
            timdialog.setValue("fimdialogtype", fimdialogtype, 11L);//对话框类型
            timdialog.setValue("ownertable", ownertable, 11L);//所有表
            timdialog.setValue("ownerid", ownerid, 11L);//所有表ID
            timdialog.setValue("tenterprise_userid", userid, 11L);//创建账号ID

            timdialogid = timdialog.getUniqueIDValue();
            /**
             * 在初始对话框中添加人员
             */
            ArrayList<String> userlist = new ArrayList<>();

            JSONArray usersArray = content.getJSONArray("users");
            usersArray.add(userid);//默认将创建人员加入群
            for (Object user : usersArray) {
                userlist.add(String.valueOf(user));
            }
            SQLFactory sqlFactory = new SQLFactory(this, "即时通讯群人员添加");
            sqlFactory.addParameter("createby", username);
            sqlFactory.addParameter("timdialogid", timdialogid);
            sqlFactory.addParameter("siteid", siteid);
            sqlFactory.addParameter_in("tenterprise_userid", userlist);
            sqlList.add(sqlFactory.getSQL());
        } else {
            timdialog = timdialogSet.getPao(0);
        }
        timdialog.setValue("fimdialogname", fimdialogname, 11L);//对话框类型
        timdialogSet.save();
        dbConnect.runSqlUpdate(sqlList);
        content.put("timdialogid", timdialogid);
        return query_imdialogMain();
    }
}