package service

import (
        quitl "app.yhyue.com/moapp/jybase/common"
        util "bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/entity"
        "bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter"
        "database/sql"
        "fmt"
        "log"
        "time"
)

type MessaggeService struct{}

//未读消息查询
func (b MessaggeService) Count(newUserId, userType, entUserId int64) (count int, last map[string]interface{}, err error) {
        v := make([]interface{}, 0)
        sqlStr := ""
        if userType == 1 {
                sqlStr = fmt.Sprintf("select  count(b.id) from   %s a  "+
                        "LEFT  JOIN  %s  b ON a.id=b.own_id "+
                        "where  b.type=5 "+
                        "AND   a.customer_service_id=%d   "+
                        "AND  b.isread=0  "+
                        "AND own_type = 1 "+
                        "order by create_time", util.SOCIALIZE_CHAT_SESSION, util.SOCIALIZE_MESSAGE_MAILBOX, entUserId)

        } else {
                sqlStr = fmt.Sprintf("select  count(b.id) from    %s  b "+
                        "where   b.send_user_id != %d    "+
                        "AND   b.own_id=%d  "+
                        "AND  b.isread=0 "+
                        "AND own_type = 2 "+
                        "order by create_time", util.SOCIALIZE_MESSAGE_MAILBOX, newUserId, newUserId)

        }
        log.Println(sqlStr, v)
        rs := util.Mysql.CountBySql(sqlStr, v...)
        log.Println(rs)
        count = int(rs)
        //最后一条信息查询
        sqlStr=fmt.Sprintf("SELECT  c.* FROM %s  b   "+
                "LEFT join %s c on  b.messag_id=c.id "+
                "WHERE  b.send_user_id != %d   "+
                "AND b.own_id = %d  "+
                "AND   b.isread=0  "+
                "AND own_type = 2  "+
                "ORDER BY  create_time DESC   "+
                "LIMIT 0,1",util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_MESSAGE,
                newUserId, newUserId)
        lastData := util.Mysql.SelectBySql(sqlStr)
        if len(*lastData) > 0 {
                last = (*lastData)[0]
        }
        return
}

//用户列表查询
func (b MessaggeService) UserList(in *messagecenter.UserReq) (data *[]map[string]interface{}, err error) {
        sqlStr := ""
        if in.UserType == 2 {
                //用户最后一次信息查询
                userSql := fmt.Sprintf("SELECT  MAX( c.id )   as messageId  FROM  socialize_message_mailbox c "+
                        "WHERE  c.own_id = %d   "+
                        "AND c.type = 2   "+
                        "AND c.own_type = 2 "+
                        "GROUP BY  (  CASE  WHEN c.send_user_id > c.receive_user_id "+
                        "THEN    CONCAT( c.send_user_id, c.receive_user_id )  "+
                        "WHEN c.send_user_id < c.receive_user_id "+
                        "THEN  CONCAT( c.receive_user_id, c.send_user_id )  END  ) ", in.NewUserId,
                )
                data = util.Mysql.SelectBySql(userSql)
                userMessageId := util.Inhandle(data)
                //客服最后一次信息查询
                customerSql := fmt.Sprintf("SELECT   max( c.id )   as messageId  FROM   %s c "+
                        "LEFT JOIN %s d ON  IF   ( c.send_user_type = 1, d.id = c.send_user_id, d.id = c.receive_user_id ) "+
                        "WHERE   c.own_id = %d  "+
                        "AND ( c.type = 4 OR c.type = 5  or c.type=6 or  c.type=7 ) "+
                        "AND c.own_type = 2 "+
                        "AND   d.user_id=c.own_id "+
                        "GROUP BY   d.ent_id  ", util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_CHAT_SESSION, in.NewUserId)
                data = util.Mysql.SelectBySql(customerSql)
                customerMessageId := util.Inhandle(data)
                //用户的列表
                sqlStr = fmt.Sprintf("SELECT IF ( b.nickname = '', CONCAT(SUBSTR( b.phone, 1, 3 ),'****',SUBSTR( b.phone, 8, 11)), b.nickname ) AS name, b.id, e.title, b.headimg, e.type, e.link, e.content, 2 AS userType, a.create_time, a.type AS itemType, "+
                        "( SELECT  count( h.id )  FROM  %s h  "+
                        "WHERE  h.type = 2  "+
                        "AND h.own_id = %d  "+
                        "AND h.own_type = 2  "+
                        "AND   h.send_user_id=b.id   "+
                        "AND h.isread = 0  ) AS number  FROM  %s a "+
                        "LEFT JOIN  %s b ON  b.id = a.receive_user_id or  b.id = a.send_user_id  "+
                        "LEFT JOIN  %s e ON e.id = a.messag_id  "+
                        "WHERE a.id IN ( %s )  AND b.id != %d "+
                        "UNION ALL "+
                        "SELECT  f.nickname AS name,    b.ent_id AS id,  e.title,f.headimage AS headimg,  e.type,  e.link,  e.content,  1 AS userType,  a.create_time,  a.type AS itemType, "+
                        "(  SELECT   count( h.id )   FROM    %s h   WHERE   ( h.type = 4 OR h.type = 5  )    AND h.own_id = %d    AND h.own_type = 2   AND  h.send_user_type = 1 AND  h.receive_user_id = %d    AND h.isread = 0   ) AS number "+
                        "FROM  %s a  "+
                        "LEFT JOIN %s b ON IF  ( a.send_user_type = 1, b.id = a.send_user_id, b.id = a.receive_user_id )  "+
                        "LEFT JOIN %s e ON e.id = a.messag_id  "+
                        "LEFT join %s  f on f.ent_id=b.ent_id   "+
                        "WHERE  a.id IN (  %s )  "+
                        "ORDER BY create_time DESC",
                        util.SOCIALIZE_MESSAGE_MAILBOX,
                        in.NewUserId,
                        util.SOCIALIZE_MESSAGE_MAILBOX,
                        util.BASE_USER,
                        util.SOCIALIZE_MESSAGE,
                        userMessageId,
                        in.NewUserId,
                        util.SOCIALIZE_MESSAGE_MAILBOX,
                        in.NewUserId,
                        in.NewUserId,
                        util.SOCIALIZE_MESSAGE_MAILBOX,
                        util.SOCIALIZE_CHAT_SESSION,
                        util.SOCIALIZE_MESSAGE,
                        util.SOCIALIZE_TENANT_ROBOT,
                        customerMessageId)
        } else {
                phoneSql := ""
                if in.Phone != "" {
                        phoneSql = "AND  b.phone like '% " + in.Phone + "%'"
                }
                startTimeSql := ""
                if in.StartTime != "" {
                        startTimeSql = "AND  DATE_FORMAT(c.create_time,'%Y-%m-%d') >= ' " + in.StartTime + "' "
                }
                endTimeSql := ""
                if in.EndTime != "" {
                        endTimeSql = "AND DATE_FORMAT(c.create_time,'%Y-%m-%d') <= ' " + in.EndTime + "' "
                }
                //先获取每个用户最后聊天记录
                userSql := fmt.Sprintf("SELECT   MAX( c.id ) as messageId   FROM  %s c   "+
                        "LEFT JOIN %s d ON   c.own_type=1 AND  c.own_id=d.id   "+
                        "WHERE   c.own_type = 1    "+
                        "AND d.customer_service_id = %d   "+
                        "AND ( c.type = 4 OR c.type = 5 or  c.type=6 or  c.type=7 )   "+
                        "AND d.customer_service_id !=0   %s %s  "+
                        "GROUP BY   (   CASE  WHEN  c.send_user_type =2 THEN  CONCAT( c.send_user_id )   WHEN c.send_user_type =1 THEN  CONCAT( c.receive_user_id )  END  ) ",
                        util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_CHAT_SESSION,
                        in.EntUserId, startTimeSql, endTimeSql)
                data = util.Mysql.SelectBySql(userSql)
                if data != nil {
                        customerMessageId := util.Inhandle(data)
                        //客服的用户列表
                        sqlStr = fmt.Sprintf("SELECT  IF  ( b.nickname = '', CONCAT(SUBSTR( b.phone, 1, 3 ),'****',SUBSTR( b.phone, 8, 11)), b.nickname ) AS name,  b.id,  e.title,  b.headimg,  e.type,  e.link,  e.content,  a.create_time,  "+
                                "(  SELECT   count( h.id )   FROM   %s h   "+
                                "LEFT JOIN %s i ON h.own_type = 1 AND h.own_id = i.id     "+
                                "WHERE  h.own_type = 1  "+
                                "AND i.ent_id=f.ent_id "+
                                "AND  i.user_id=f.user_id    "+
                                "AND h.isread = 0    "+
                                "AND  i.customer_service_id= %d "+
                                "FROM  %s a  "+
                                "LEFT JOIN %s b ON if (a.send_user_type=1 ,a.receive_user_id=b.id,a.send_user_id=b.id)  "+
                                "LEFT JOIN %s e ON e.id = a.messag_id  "+
                                "LEFT JOIN %s f ON a.own_type=1 AND  a.own_id=f.id   "+
                                "WHERE  a.id IN  ( %s) %s ORDER BY  a.create_time DESC",
                                util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_CHAT_SESSION,
                                in.EntUserId, util.SOCIALIZE_MESSAGE_MAILBOX, util.BASE_USER, util.SOCIALIZE_MESSAGE, util.SOCIALIZE_CHAT_SESSION, customerMessageId, phoneSql)
                }
        }
        if sqlStr != "" {
                log.Println(sqlStr)
                data = util.Mysql.SelectBySql(sqlStr)
        }
        return
}

//消息保存
func (b MessaggeService) SaveMessage(in *messagecenter.MessageEntity) (fool bool, errorMsg string, content string, messageId, nowInt int64) {
        //先插入信息表
        //判断会话标识是否属于本人
        nowForm := time.Now().Local()
        if in.ItemType != 2 {
                userId := int64(0)
                sessionId := int64(0)
                switch in.ItemType {
                case 4, 5:
                        if in.OwnType == 1 {
                                sessionId = in.ReceiveId
                                userId = in.NewUserId
                        } else {
                                sessionId = in.SendId
                                userId = in.ReceiveId
                                if in.ItemType == 4 {
                                        userId = in.NewUserId
                                }
                        }
                        break
                case 6:
                        if in.OwnType == 1 {
                                sessionId = in.ReceiveId
                                userId = in.NewUserId
                        } else if in.OwnType == 2 {
                                sessionId = in.SendId
                                userId = in.ReceiveId
                        } else {
                                sessionId = in.ReceiveId
                                userId = in.NewUserId
                        }
                        break
                }
                //查找会话信息
                chatJson := util.Mysql.FindOne(util.SOCIALIZE_CHAT_SESSION, map[string]interface{}{"id": sessionId}, "user_id", "")
                if chatJson == nil {
                        return false, "会话标识不存在", "", 0, nowForm.Unix()
                } else {
                        if userId != quitl.Int64All((*chatJson)["user_id"]) {
                                return false, "会话标识不属于此用户", "", 0, nowForm.Unix()
                        }
                }
        }
        fool = util.Mysql.ExecTx("聊天信息保存", func(tx *sql.Tx) bool {
                //先插入信息表
                message := map[string]interface{}{
                        "appid":         in.Appid,
                        "title":         in.Title,
                        "content":       in.Content,
                        "item":          in.Item,
                        "type":          in.Type,
                        "link":          in.Link,
                        "create_time":   nowForm.Format(util.Date_Full_Layout),
                        "create_person": in.SendId,
                }
                ok := util.Mysql.InsertByTx(tx, util.SOCIALIZE_MESSAGE, message)
                receiveOk := int64(0)
                messageId = ok
                //在插入邮箱表socialize_message_mailbox
                messageMailBox := map[string]interface{}{
                        "appid":         in.Appid,
                        "messag_id":     ok,
                        "type":          in.ItemType,
                        "create_time":   nowForm.Format(util.Date_Full_Layout),
                        "isread":        0,
                        "send_isdel":    0,
                        "receive_isdel": 0,
                        "iswithdraw":    0,
                }
                //系统信息处理
                if in.ItemType == 6 {
                        messageMailBox = map[string]interface{}{
                                "appid":         in.Appid,
                                "messag_id":     ok,
                                "type":          in.ItemType,
                                "create_time":   nowForm.Format(util.Date_Full_Layout),
                                "read_time":     nowForm.Format(util.Date_Full_Layout),
                                "isread":        1,
                                "send_isdel":    0,
                                "receive_isdel": 0,
                                "iswithdraw":    0,
                        }
                        if in.OwnType == 1 {
                                //用户接受系统信息
                                messageMailBox["own_type"] = 2
                                messageMailBox["send_user_type"] = 1
                                messageMailBox["receive_user_type"] = 2
                                messageMailBox["own_id"] = in.NewUserId
                                messageMailBox["send_user_id"] = in.ReceiveId
                                messageMailBox["receive_user_id"] = in.NewUserId
                        } else if in.OwnType == 2 {
                                //客服接受系统信息
                                messageMailBox["own_type"] = 1
                                messageMailBox["send_user_type"] = 2
                                messageMailBox["receive_user_type"] = 1
                                messageMailBox["own_id"] = in.SendId
                                messageMailBox["send_user_id"] = in.ReceiveId
                                messageMailBox["receive_user_id"] = in.SendId

                        } else {
                                //客服接受系统信息
                                messageMailBox["own_type"] = 1
                                messageMailBox["send_user_type"] = 2
                                messageMailBox["receive_user_type"] = 1
                                messageMailBox["own_id"] = in.ReceiveId
                                messageMailBox["send_user_id"] = in.NewUserId
                                messageMailBox["receive_user_id"] = in.ReceiveId
                        }
                        receiveOk = util.Mysql.InsertByTx(tx, util.SOCIALIZE_MESSAGE_MAILBOX, messageMailBox)
                        return ok > 1 && receiveOk > 1
                }
                if in.ItemType == 4 || in.ItemType == 5 {
                        //客服或者机器人聊天
                        if in.OwnType == 1 {
                                // (用户发送)客服接受
                                messageMailBox["own_type"] = 1
                                messageMailBox["send_user_type"] = 2
                                messageMailBox["receive_user_type"] = 1
                                messageMailBox["own_id"] = in.ReceiveId
                                messageMailBox["send_user_id"] = in.NewUserId
                                messageMailBox["receive_user_id"] = in.ReceiveId
                        } else {
                                //客服发送(用户接收信息)
                                messageMailBox["own_type"] = 2
                                messageMailBox["send_user_type"] = 1
                                messageMailBox["receive_user_type"] = 2
                                messageMailBox["own_id"] = in.ReceiveId
                                messageMailBox["send_user_id"] = in.SendId
                                messageMailBox["receive_user_id"] = in.ReceiveId
                                if in.ItemType == 4 {
                                        messageMailBox["receive_user_id"] = in.NewUserId
                                        messageMailBox["own_id"] = in.NewUserId
                                        messageMailBox["isread"] = 1
                                        messageMailBox["read_time"] = nowForm.Format(util.Date_Full_Layout)
                                }
                        }
                } else {
                        messageMailBox["own_type"] = 2
                        messageMailBox["send_user_type"] = 2
                        messageMailBox["receive_user_type"] = 2
                        messageMailBox["own_id"] = in.ReceiveId
                        messageMailBox["send_user_id"] = in.NewUserId
                        messageMailBox["receive_user_id"] = in.ReceiveId
                }
                receiveOk = util.Mysql.InsertByTx(tx, util.SOCIALIZE_MESSAGE_MAILBOX, messageMailBox)
                messageMailBox = map[string]interface{}{
                        "appid":         in.Appid,
                        "messag_id":     ok,
                        "type":          in.ItemType,
                        "create_time":   nowForm.Format(util.Date_Full_Layout),
                        "read_time":     nowForm.Format(util.Date_Full_Layout),
                        "isread":        1,
                        "send_isdel":    0,
                        "receive_isdel": 0,
                        "iswithdraw":    0,
                }
                if in.ItemType == 4 || in.ItemType == 5 {
                        //客服或者机器人聊天
                        if in.OwnType == 1 {
                                //用户发送(用户接受)
                                messageMailBox["own_type"] = 2
                                messageMailBox["send_user_type"] = 2
                                messageMailBox["receive_user_type"] = 1
                                messageMailBox["own_id"] = in.NewUserId
                                messageMailBox["send_user_id"] = in.NewUserId
                                messageMailBox["receive_user_id"] = in.ReceiveId

                        } else {
                                //客服发送信息(用户接受)
                                messageMailBox["own_type"] = 1
                                messageMailBox["send_user_type"] = 1
                                messageMailBox["receive_user_type"] = 2
                                messageMailBox["own_id"] = in.SendId
                                messageMailBox["send_user_id"] = in.SendId
                                messageMailBox["receive_user_id"] = in.ReceiveId
                                if in.ItemType == 4 {
                                        messageMailBox["receive_user_id"] = in.NewUserId
                                }
                        }
                } else {
                        messageMailBox["own_type"] = 2
                        messageMailBox["send_user_type"] = 2
                        messageMailBox["receive_user_type"] = 2
                        messageMailBox["own_id"] = in.NewUserId
                        messageMailBox["send_user_id"] = in.NewUserId
                        messageMailBox["receive_user_id"] = in.ReceiveId
                }
                receiveOk = util.Mysql.InsertByTx(tx, util.SOCIALIZE_MESSAGE_MAILBOX, messageMailBox)
                return ok > 1 && receiveOk > 1
        })
        return fool, "", in.Content, messageId, nowForm.Unix()
}

//历史信息查询
func (b MessaggeService) FindMessage(in *messagecenter.MessageReq) *[]map[string]interface{} {
        sqlStr := ""
        lastStr := ""
        if in.LastId > 0 {
                if in.Sort == "asc" {
                        lastStr = fmt.Sprintf("AND  a.messag_id > %d ", in.LastId)
                } else {
                        lastStr = fmt.Sprintf("AND  a.messag_id < %d ", in.LastId)
                }
        }
        switch in.MsgType {
        case 2: //点对点聊天
                sqlStr = fmt.Sprintf("SELECT  a.messag_id as messageId,b.* ,if(a.own_id = a.send_user_id,1,2) as fool  "+
                        "FROM  %s a  "+
                        "LEFT JOIN %s b on  a.messag_id=b.id  "+
                        "LEFT  JOIN  %s c on  c.id=a.send_user_id   "+
                        "LEFT JOIN  %s d on  d.id=a.receive_user_id  "+
                        "where  a.own_id=  %d "+
                        "AND ((a.send_user_id=   %d AND   a.receive_user_id=   %d) or (a.send_user_id=  %d AND  a.receive_user_id=  %d)) "+
                        "AND  a.type=2  %s "+
                        "ORDER BY a.create_time desc ,a.id   asc "+
                        "limit 0 ,  %d ",
                        util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_MESSAGE, util.BASE_USER, util.BASE_USER,
                        in.NewUserId, in.NewUserId, in.SendId, in.SendId, in.NewUserId, lastStr, in.PageSize)
                break
        case 4, 5, 6, 7: //客服聊天
                if in.UserType == 1 {
                        //客服聊天记录查看
                        sqlStr = fmt.Sprintf("SELECT   a.messag_id as messageId,b.*,   IF   ( a.own_id = a.send_user_id, 1, 2 ) AS fool,   a.send_user_type,   a.type AS itemType,   '' AS robotName,   '' AS robotImg,   c.customer_service_name AS setName ,   c.user_id   "+
                                "FROM   %s a   "+
                                "LEFT JOIN %s b ON a.messag_id = b.id   "+
                                "LEFT JOIN %s c ON   a.own_type = 1  AND  a.own_id=c.id    "+
                                "WHERE   a.own_type = 1   "+
                                "AND (a.type = 5 or a.type=4 or  a.type=6 or  a.type=7)   "+
                                "AND c.ent_id =   %d "+
                                "AND c.user_id =   %d  %s "+
                                "ORDER BY a.create_time desc ,a.id   asc "+
                                "limit 0 ,  %d ",
                                util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_MESSAGE, util.SOCIALIZE_CHAT_SESSION,
                                in.EntId, in.SendId, lastStr, in.PageSize)
                } else {
                        //用户聊天记录查看
                        sqlStr = fmt.Sprintf("SELECT a.messag_id as messageId,  b.*,   IF   ( a.own_id = a.send_user_id, 1, 2 ) AS fool ,   a.send_user_type,   a.type as  itemType,   d.nickname as  robotName,   d.headimage as  robotImg,   c.customer_service_name as  setName   "+
                                "FROM   %s a   "+
                                "LEFT JOIN %s b ON a.messag_id = b.id   "+
                                "LEFT JOIN %s c ON   IF   ( a.send_user_type = 1, c.id = a.send_user_id, c.id = a.receive_user_id ) AND  c.ent_id = %d AND c.user_id = %d "+
                                "LEFT JOIN  %s d on  c.ent_id=d.ent_id    "+
                                "WHERE   a.own_type = 2    "+
                                "AND a.own_id =  %d "+
                                "AND  c.ent_id = %d "+
                                "AND c.user_id =  %d "+
                                "AND ( a.type = 4 OR a.type = 5 or a.type=6 or  a.type=7)  %s "+
                                "ORDER BY a.create_time desc ,a.id   asc "+
                                "limit 0 ,   %d ",
                                util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_MESSAGE, util.SOCIALIZE_CHAT_SESSION, in.SendId, in.NewUserId, util.SOCIALIZE_TENANT_ROBOT,
                                in.NewUserId, in.SendId, in.NewUserId, lastStr, in.PageSize)
                }
                break
        }
        log.Println(sqlStr)
        data := util.Mysql.SelectBySql(sqlStr)
        //自己头像处理
        if in.UserType == 2 {
                userData := util.Mysql.FindOne(util.BASE_USER, map[string]interface{}{"id": in.NewUserId}, "headimg", "")
                if userData != nil {
                        for key := range *data {
                                (*data)[key]["ownImg"] = (*userData)["headimg"]
                        }
                }

        }
        go func() {
                updateMap := map[string]interface{}{}
                if len(*data) > 0 {
                        //未读信息修改
                        switch in.MsgType {
                        case 2: //点对点聊天
                                updateMap = map[string]interface{}{
                                        "own_type": 2,
                                        "own_id":   in.NewUserId,
                                        "type":     2,
                                        "isread":   0,
                                }
                                util.Mysql.Update(util.SOCIALIZE_MESSAGE_MAILBOX, updateMap, map[string]interface{}{"isread": 1, "read_time": time.Now().Local().Format(util.Date_Full_Layout)})
                                break
                        case 4, 5:
                                sqlStr := ""
                                if in.UserType == 1 {
                                        sqlStr = fmt.Sprintf("UPDATE %s a  SET a.isread = 1,    a.read_time = now( )  "+
                                                "WHERE    a.own_type = 1  "+
                                                "AND a.type IN ( 4,5,6,7)  "+
                                                "AND a.isread = 0    "+
                                                "AND a.own_id IN ( SELECT b.id FROM %s b WHERE   b.customer_service_id=%d AND    b.user_id=%d  )",
                                                util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_CHAT_SESSION, in.EntUserId, in.SendId)
                                } else {
                                        sqlStr = fmt.Sprintf("UPDATE %s a  SET a.isread = 1,    a.read_time = now( )  "+
                                                "WHERE    a.own_type = 2  "+
                                                "AND a.type IN ( 4,5,6,7 )  "+
                                                "AND a.isread = 0    "+
                                                "AND a.own_id =%d ", util.SOCIALIZE_MESSAGE_MAILBOX, in.NewUserId)
                                }
                                util.Mysql.UpdateOrDeleteBySql(sqlStr)
                                break
                        }
                }
        }()
        return data
}

//创建会话
func (b MessaggeService) CreateChatSession(in *messagecenter.ChatSessionReq) (fool bool, sessionId int64) {
        fool = util.Mysql.ExecTx("会话新建", func(tx *sql.Tx) bool {
                customerserviceName := in.CustomerserviceName
                if in.CustomerServiceId != 0 {
                        sqlStr:=fmt.Sprintf("select  customer_service_name from  %s "+
                                "where  ent_id= %d "+
                                "AND customer_service_id= %d ",
                                util.SOCIALIZE_CHAT_SESSION, in.EntId, in.CustomerServiceId)
                        customerList := util.Mysql.SelectBySql(sqlStr)
                        if len(*customerList) > 0 {
                                customerserviceName = quitl.InterfaceToStr((*customerList)[0]["customer_service_name"])
                        }
                }
                chatMession := map[string]interface{}{
                        "handle_status":         0,
                        "start_time":            time.Now().Local().Format(util.Date_Full_Layout),
                        "appid":                 in.AppId,
                        "ent_id":                in.EntId,
                        "customer_service_id":   in.CustomerServiceId,
                        "user_id":               in.UserId,
                        "customer_service_name": customerserviceName,
                }
                sessionId = util.Mysql.InsertByTx(tx, util.SOCIALIZE_CHAT_SESSION, chatMession)
                return sessionId > 0
        })
        return fool, sessionId
}

//结束会话
func (b MessaggeService) CloseChatSession(in *messagecenter.CloseSessionReq) bool {
        fool := util.Mysql.ExecTx("关闭会话", func(tx *sql.Tx) bool {
                updateMap := map[string]interface{}{
                        "id": in.SessionId,
                }
                fool := util.Mysql.Update(util.SOCIALIZE_CHAT_SESSION, updateMap, map[string]interface{}{"start_time": time.Now().Local().Format(util.Date_Full_Layout)})
                return fool
        })
        return fool
}

//创建会话并保存信息
func (b *MessaggeService) SaveAutoReplyMsg(userType, entId, entUserId, userId int64, content, appId, nowFormat string) (bool, int64) {
        messageId := int64(0)
        return util.Mysql.ExecTx("保存自动回复消息", func(tx *sql.Tx) bool {
                entUserName := ""
                if entUserId > 0 {
                        list := util.Mysql.SelectBySql(`select ? from socialize_tenant_seat where appid=? AND ent_id=? AND customer_service_id=?`, util.SOCIALIZE_CHAT_SESSION, appId, entId, entUserId)
                        if list != nil && len(*list) > 0 {
                                entUserName, _ = (*list)[0]["customer_service_name"].(string)
                        }
                }
                messageId = util.Mysql.InsertBySqlByTx(tx, `insert into ? (appid,content,item,type,create_time,create_person) values (?,?,?,?,?,?)`, util.SOCIALIZE_MESSAGE, appId, content, 8, 1, nowFormat, "admin")
                sessionId := util.Mysql.InsertBySqlByTx(tx, `insert into ? (appid,type,ent_id,customer_service_id,customer_service_name,user_id,start_time,end_time) values (?,?,?,?,?,?,?,?)`, util.SOCIALIZE_CHAT_SESSION, appId, 1, entId, entUserId, entUserName, userId, nowFormat, nowFormat)
                ok := false
                if userType == 0 {
                        ok1 := util.Mysql.InsertBySqlByTx(tx, `insert into ? (appid,messag_id,type,send_user_id,send_user_type,receive_user_id,receive_user_type,own_id,own_type,create_time,isread,read_time) values (?,?,?,?,?,?,?,?,?,?,?,?)`, util.SOCIALIZE_MESSAGE_MAILBOX, appId, messageId, 7, sessionId, 1, userId, 2, sessionId, 1, nowFormat, 1, nowFormat) > 0
                        ok2 := util.Mysql.InsertBySqlByTx(tx, `insert into ? (appid,messag_id,type,send_user_id,send_user_type,receive_user_id,receive_user_type,own_id,own_type,create_time) values (?,?,?,?,?,?,?,?,?,?)`, util.SOCIALIZE_MESSAGE_MAILBOX, appId, messageId, 7, sessionId, 1, userId, 2, userId, 2, nowFormat) > 0
                        ok = ok1 && ok2
                } else if userType == 1 {
                        ok = util.Mysql.InsertBySqlByTx(tx, `insert into ? (appid,messag_id,type,send_user_id,send_user_type,receive_user_id,receive_user_type,own_id,own_type,create_time,isread,read_time) values (?,?,?,?,?,?,?,?,?,?,?,?)`, util.SOCIALIZE_MESSAGE_MAILBOX, appId, messageId, 7, sessionId, 1, userId, 2, sessionId, 1, nowFormat, 1, nowFormat) > 0
                } else if userType == 2 {
                        ok = util.Mysql.InsertBySqlByTx(tx, `insert into ? (appid,messag_id,type,send_user_id,send_user_type,receive_user_id,receive_user_type,own_id,own_type,create_time) values (?,?,?,?,?,?,?,?,?,?)`, util.SOCIALIZE_MESSAGE_MAILBOX, appId, messageId, 7, sessionId, 1, userId, 2, userId, 2, nowFormat) > 0
                }
                return messageId > 0 && sessionId > 0 && ok
        }), messageId
}

//修改未读状态
func (b MessaggeService) UpdateReadById(in *messagecenter.ReadStateReq) bool {
        fool := util.Mysql.ExecTx("已读状态修改", func(tx *sql.Tx) bool {
                updateMap := map[string]interface{}{
                        "messag_id": in.MessageId,
                        "isread":    0,
                }
                fool := util.Mysql.Update(util.SOCIALIZE_MESSAGE_MAILBOX, updateMap, map[string]interface{}{"read_time": time.Now().Local().Format(util.Date_Full_Layout), "isread": 1})
                return fool
        })
        return fool
}