package service

import (
	"database/sql"
	"fmt"
	"log"
	"strconv"
	"strings"
	"sync"
	"time"

	quitl "app.yhyue.com/moapp/jybase/common"
	"app.yhyue.com/moapp/jybase/date"
	"app.yhyue.com/moapp/jybase/encrypt"
	util "bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/entity"
	IC "bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/init"
	"bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter"
	"github.com/gogf/gf/v2/util/gconv"
)

type MessaggeService struct{}

// 未读消息查询
func (b MessaggeService) Count(newUserId, userType, entUserId int64, isClean bool) (count int, last map[string]interface{}, err error) {
	log.Printf("用户id：%d,userType：%d,entUserId:%d,isClean:%v", newUserId, userType, entUserId, isClean)
	v := make([]interface{}, 0)
	sqlStr := ""
	if userType == 1 {
		//查询缓存里边是否有数据
		pc_a, err := util.GetData(userType, entUserId)
		if err == nil && pc_a != nil {
			// 缓存有值
			if !isClean {
				return pc_a.Count, pc_a.Data, err
			}
		}
		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.iswithdraw = 0  "+
			"AND  b.isread=0  "+
			"AND own_type = 1 "+
			"order by create_time", util.SOCIALIZE_CHAT_SESSION, util.SOCIALIZE_MESSAGE_MAILBOX, entUserId)

	} else {
		pc_a, err := util.GetData(userType, newUserId)
		if err == nil && pc_a != nil {
			if !isClean {
				return pc_a.Count, pc_a.Data, err
			}
		}
		sqlStr = fmt.Sprintf("select  count(b.id) from    %s  b "+
			"where   b.send_user_id != %d    "+
			"AND   b.own_id=%d "+
			"AND b.iswithdraw = 0  "+
			"AND  b.isread=0 "+
			"AND own_type = 2 "+
			"order by create_time", util.SOCIALIZE_MESSAGE_MAILBOX, newUserId, newUserId)

	}
	log.Println(sqlStr, v)
	rs := IC.BaseMysql.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.iswithdraw = 0  "+
		"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 := IC.BaseMysql.SelectBySql(sqlStr)
	if len(*lastData) > 0 {
		last = (*lastData)[0]
		if userType == 1 {
			util.SetData(userType, entUserId, map[string]interface{}{"data": last, "count": count}, IC.SurvivalTime)
		} else {
			util.SetData(userType, newUserId, map[string]interface{}{"data": last, "count": count}, IC.SurvivalTime)
		}
	} else {
		if userType == 1 {
			util.SetData(userType, entUserId, map[string]interface{}{"data": map[string]interface{}{}, "count": count}, IC.SurvivalTime)
		} else {
			util.SetData(userType, newUserId, map[string]interface{}{"data": map[string]interface{}{}, "count": count}, IC.SurvivalTime)
		}
	}
	return
}

// 用户列表查询
func (b MessaggeService) UserList(in *messagecenter.UserReq) (data *[]map[string]interface{}, count int64, err error) {
	sqlStr := ""
	tm := time.Now()
	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.iswithdraw = 0  "+
			"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 = IC.BaseMysql.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.iswithdraw = 0 "+
			"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 = IC.BaseMysql.SelectBySql(customerSql)
		customerMessageId := util.Inhandle(data)
		//用户的列表
		sqlStr = fmt.Sprintf("SELECT "+
			"(  CASE        WHEN SUBSTR( b.nickname, 1, 3 ) = 'JY_' THEN    CONCAT( SUBSTR( b.phone, 1, 3 ), '****', SUBSTR( b.phone, 8, 11 ) )     WHEN b.nickname = '' or b.nickname is null THEN    CONCAT( SUBSTR( b.phone, 1, 3 ), '****', SUBSTR( b.phone, 8, 11 ) ) ELSE b.nickname    END    )"+
			"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 AND h.iswithdraw = 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, a.send_user_id, a.receive_user_id ) = b.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 {
		idSql := fmt.Sprintf(" (a.customer_service_id = %d OR a.customer_service_id = 0) ", in.EntUserId)
		if in.IsArtificial == 1 {
			idSql = fmt.Sprintf(" a.customer_service_id = %d ", in.EntUserId)
		} else if in.IsArtificial == 2 {
			idSql = " a.customer_service_id = 0 "
		}
		if in.StartTime != "" {
			idSql += " AND  DATE_FORMAT(a.update_time,'%Y-%m-%d') >= '" + in.StartTime + "' "
		}
		if in.EndTime != "" {
			idSql += "AND DATE_FORMAT(a.update_time,'%Y-%m-%d') <= '" + in.EndTime + "' "
		}
		if in.Phone != "" {
			idSql += " AND  b.phone like '%" + in.Phone + "%'"
		}
		if in.FiltrationId != "" {
			var ids []string
			for _, v := range strings.Split(in.FiltrationId, ",") {
				ids = append(ids, encrypt.SE.Decode4Hex(v))
			}
			idSql += fmt.Sprintf(" AND  b.id not in (%s)", strings.Join(ids, ","))
		}
		if in.Page <= 0 {
			in.Page = 1
		}
		if in.Size <= 0 || in.Size > 100 {
			in.Size = 50
		}
		sqlStr = fmt.Sprintf(`SELECT(
			 CASE
            	WHEN SUBSTR( b.nickname, 1, 3 ) = 'JY_' THEN
            	CONCAT( SUBSTR( b.phone, 1, 3 ), '****', SUBSTR( b.phone, 8, 11 ) ) 
            	WHEN b.nickname = '' 
            	OR b.nickname IS NULL THEN
            	CONCAT( SUBSTR( b.phone, 1, 3 ), '****', SUBSTR( b.phone, 8, 11 ) ) ELSE b.nickname 
            	END 
            ) AS name,
			b.id,
			e.title,
			b.headimg,
			e.type,
			e.link,
			e.content,
			a.update_time as create_time,
			(
			SELECT
				count( h.id ) 
			FROM
				 %s h
				LEFT JOIN  %s i ON h.own_id = i.id 
			WHERE
				h.own_type = 1 
				AND i.ent_id = a.ent_id 
				AND i.user_id = a.user_id 
				AND h.isread = 0 
				AND h.iswithdraw = 0 
				AND i.customer_service_id = %d 
			) AS number 
		FROM
			%s a
			INNER JOIN %s b ON  a.ent_id = %d and %s 
			AND a.user_id = b.id
			LEFT JOIN  %s e ON e.id = a.message_id 
	ORDER BY
	a.update_time DESC`, util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_CHAT_SESSION, in.EntUserId, util.User_message_list, util.BASE_USER, in.EntId, idSql, util.SOCIALIZE_MESSAGE)
	}
	dataSize := []map[string]interface{}{}
	if sqlStr != "" {
		log.Println("查询列表sql:", sqlStr)
		data = IC.BaseMysql.SelectBySql(sqlStr)
		if data != nil && len(*data) > 0 {
			count = quitl.Int64All(len(*data))
			log.Println("查询列表耗时2:", time.Since(tm), count)
			if in.UserType != 2 {
				if in.Page*in.Size >= count {
					dataSize = (*data)[(in.Page-1)*in.Size:]
				} else {
					dataSize = (*data)[(in.Page-1)*in.Size : in.Page*in.Size]
				}
				return &dataSize, count, err
			}
		}
	}
	return
}

// 客服会话列表
func (b MessaggeService) ConversationList(in *messagecenter.ConversationReq) (data *[]map[string]interface{}, count int64, err error) {
	sqlStr := ""
	tm := time.Now()
	if in.UserType == 1 && in.FiltrationId != "" {
		var ids []string
		for _, v := range strings.Split(in.FiltrationId, ",") {
			ids = append(ids, encrypt.SE.Decode4Hex(v))
		}
		idSql := fmt.Sprintf("a.customer_service_id = %d AND  b.id  in (%s) ", in.EntUserId, strings.Join(ids, ","))
		sqlStr = fmt.Sprintf(`SELECT(
			CASE
            	WHEN SUBSTR( b.nickname, 1, 3 ) = 'JY_' THEN
            	CONCAT( SUBSTR( b.phone, 1, 3 ), '****', SUBSTR( b.phone, 8, 11 ) ) 
            	WHEN b.nickname = '' 
            	OR b.nickname IS NULL THEN
            	CONCAT( SUBSTR( b.phone, 1, 3 ), '****', SUBSTR( b.phone, 8, 11 ) ) ELSE b.nickname 
            	END 
            ) AS name,
			b.id,
			e.title,
			b.headimg,
			e.type,
			e.link,
			e.content,
			a.update_time as create_time,
			(
			SELECT
				count( h.id ) 
			FROM
				 %s h
				LEFT JOIN  %s i ON h.own_id = i.id 
			WHERE
				h.own_type = 1 
				AND i.ent_id = a.ent_id 
				AND i.user_id = a.user_id 
				AND h.isread = 0 
				AND h.iswithdraw = 0 
				AND i.customer_service_id = %d 
			) AS number 
		FROM
			%s a
			INNER JOIN %s b ON  %s 
			AND a.user_id = b.id
			LEFT JOIN  %s e ON e.id = a.message_id`,
			util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_CHAT_SESSION, in.EntUserId, util.User_message_list, util.BASE_USER, idSql, util.SOCIALIZE_MESSAGE)
	}

	if sqlStr != "" {
		log.Println("查询列表sql:", sqlStr)
		data = IC.BaseMysql.SelectBySql(sqlStr)
		log.Println("查询耗时2:", time.Since(tm), count)
	}
	return
}

// 消息保存
func (b MessaggeService) SaveMessage(in *messagecenter.MessageEntity) (fool bool, errorMsg string, content string, messageId, nowInt int64) {
	//先插入信息表
	//判断会话标识是否属于本人
	var customer_service_id, userid, entid, message_id int64
	nowForm := time.Now().Local()
	create_time := nowForm.Format(util.Date_Full_Layout)
	if in.ItemType != 2 {
		userId := int64(0)
		sessionId := int64(0)
		switch in.ItemType {
		case 4, 5, 8:
			if in.OwnType == 1 {
				sessionId = in.ReceiveId
				userId = in.NewUserId
			} else {
				sessionId = in.SendId
				userId = in.ReceiveId
				if in.ItemType == 4 || in.ItemType == 8 {
					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 := IC.BaseMysql.FindOne(util.SOCIALIZE_CHAT_SESSION, map[string]interface{}{"id": sessionId}, "user_id,ent_id,customer_service_id", "")
		if chatJson == nil {
			return false, "会话标识不存在", "", 0, nowForm.Unix()
		} else {
			if userId != quitl.Int64All((*chatJson)["user_id"]) {
				return false, "会话标识不属于此用户", "", 0, nowForm.Unix()
			}
		}
		customer_service_id = quitl.Int64All((*chatJson)["customer_service_id"])
		entid = quitl.Int64All((*chatJson)["ent_id"])
		userid = userId
	}
	fool = IC.BaseMysql.ExecTx("聊天信息保存", func(tx *sql.Tx) bool {
		//先插入信息表
		userType := int64(1)
		userId := int64(0)
		message := map[string]interface{}{
			"appid":         in.Appid,
			"title":         in.Title,
			"content":       in.Content,
			"item":          in.Item,
			"type":          in.Type,
			"link":          in.Link,
			"create_time":   create_time,
			"create_person": in.SendId,
		}
		data := map[string]interface{}{
			"item":        in.Item,
			"type":        in.Type,
			"create_time": create_time,
			"content":     in.Content,
		}
		ok := IC.BaseMysql.InsertByTx(tx, util.SOCIALIZE_MESSAGE, message)
		receiveOk := int64(0)
		messageId, message_id = ok, ok
		data["id"] = 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 = IC.BaseMysql.InsertByTx(tx, util.SOCIALIZE_MESSAGE_MAILBOX, messageMailBox)
			return ok > 1 && receiveOk > 1
		}
		if in.ItemType == 4 || in.ItemType == 8 || 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
				userType = 1
				userId = 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
				userId = in.ReceiveId
				if in.ItemType == 4 || in.ItemType == 8 {
					messageMailBox["receive_user_id"] = in.NewUserId
					userId = in.NewUserId
					messageMailBox["own_id"] = in.NewUserId
					messageMailBox["isread"] = 1
					messageMailBox["read_time"] = nowForm.Format(util.Date_Full_Layout)
				}
				userType = 2

			}
		} 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
			userType = 2
			userId = in.ReceiveId
		}
		receiveOk = IC.BaseMysql.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 == 8 || 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 || in.ItemType == 8 {
					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 = IC.BaseMysql.InsertByTx(tx, util.SOCIALIZE_MESSAGE_MAILBOX, messageMailBox)
		if ok > 1 && receiveOk > 1 {
			pc_a, err := util.GetData(userType, userId)
			count := 1
			if err == nil && pc_a != nil {
				count += pc_a.Count
			}
			util.SetData(userType, userId, map[string]interface{}{"data": data, "count": count}, IC.SurvivalTime)
		}
		return ok > 1 && receiveOk > 1
	})
	if fool && in.ItemType != 2 && in.ItemType != 3 {
		go UserSynchronousList(customer_service_id, userid, entid, message_id, create_time)
	}
	return fool, "", in.Content, messageId, nowForm.Unix()
}

var rwLock = new(sync.RWMutex)

// 客服 用户聊天消息列表同步
func UserSynchronousList(customerServiceId, userId, entId, messageId int64, createTime string) {
	log.Printf("同步最后消息参数customerServiceId:%d,userId:%d,entId%d,messageId:%d", customerServiceId, userId, entId, messageId)
	rwLock.Lock()
	defer rwLock.Unlock()
	if IC.BaseMysql.Count(util.User_message_list, map[string]interface{}{"user_id": userId, "ent_id": entId}) > 0 {
		upData := map[string]interface{}{
			"message_id":  messageId,
			"update_time": createTime,
		}
		//判断是否机器人聊天
		if customerServiceId > 0 && IC.BaseMysql.Count(util.User_message_list, map[string]interface{}{"user_id": userId, "ent_id": entId, "customer_service_id": 0}) > 0 {
			//将机器人列表更新成用户
			upData["customer_service_id"] = customerServiceId
			//转人工 机器人聊天类型修改
			upData["type"] = 1
		}
		//已于人工客服联系过 只同步最后消息
		IC.BaseMysql.Update(util.User_message_list, map[string]interface{}{"user_id": userId, "ent_id": entId}, upData)
		return
	}
	//不存在消息列表 创建
	IC.BaseMysql.Insert(util.User_message_list, map[string]interface{}{
		"ent_id":              entId,
		"user_id":             userId,
		"message_id":          messageId,
		"update_time":         createTime,
		"customer_service_id": customerServiceId,
		"type":                quitl.If(customerServiceId == 0, 0, 1),
	})
}

// 历史信息查询
func (b MessaggeService) FindMessage(in *messagecenter.MessageReq) *[]map[string]interface{} {
	sqlStr := ""
	lastStr := ""
	positionStr := ""
	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.iswithdraw = 0"+
			"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 3: //群聊天

		sqlStr = fmt.Sprintf("SELECT a.messag_id AS messageId,b.*,"+
			"IF ( a.own_id = a.send_user_id, 1, 2 ) AS fool,"+
			"IF ( a.own_id = a.send_user_id, 0, a.send_user_id ) AS send_position_id,"+
			"a.send_user_type,a.type AS itemType FROM %s a "+
			"LEFT JOIN %s b ON a.messag_id = b.id "+
			"WHERE a.own_type = 1 AND a.own_id = %d "+
			"AND chat_group_id = %d AND a.type IN ( 3, 6 ) "+
			"ORDER BY a.create_time desc,a.id DESC "+
			"LIMIT 0, %d",
			util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_MESSAGE, in.SendId,
			in.ChatGroupId, in.PageSize)
	case 4, 5, 6, 7: //客服聊天
		//查询用户所有的职位id
		sqlPosition := fmt.Sprintf("SELECT b.id FROM %s a LEFT JOIN %s b ON a.id = b.user_id "+
			"WHERE a.phone = (SELECT a.phone FROM %s a LEFT JOIN %s b ON a.id = b.user_id "+
			"WHERE b.id = %d)",
			util.BASE_USER, util.BASE_POSITION, util.BASE_USER, util.BASE_POSITION, in.NewUserId)
		positionArr := IC.BaseMysql.SelectBySql(sqlPosition)
		for k, val := range *positionArr {
			if k < len(*positionArr)-1 {
				positionStr += quitl.ObjToString(val["id"]) + ","
			} else {
				positionStr += quitl.ObjToString(val["id"])
			}
		}

		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.iswithdraw = 0  "+
				"AND (a.type = 5 or a.type=4 or a.type=6 or  a.type=7 or a.type=8 )   "+
				"AND c.ent_id =   %d "+
				"AND c.user_id in (%s)  %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, positionStr, lastStr, in.PageSize)
		} else {
			//用户聊天记录查看
			sqlStr = fmt.Sprintf("SELECT a.messag_id as messageId,e.appraise as appraise, 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, a.send_user_id, a.receive_user_id ) = c.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 in  (%s) "+
				"AND  c.ent_id = %d "+
				"AND c.user_id in  (%s) "+
				"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,
				positionStr, in.SendId, positionStr, lastStr, in.PageSize)
		}
		break
	}
	log.Println(sqlStr)
	data := IC.BaseMysql.SelectBySql(sqlStr)
	//查询非自己发送消息得发送人名字
	//自己头像处理
	if in.UserType == 2 {
		userData := IC.BaseMysql.FindOne(util.BASE_USER, map[string]interface{}{"id": in.NewUserId}, "headimg", "")
		if userData != nil {
			for key := range *data {
				(*data)[key]["ownImg"] = (*userData)["headimg"]
			}
		}

	}
	if in.MsgType == 3 && data != nil && len(*data) > 0 {
		_, _, positionData := EntPerson(in.EntId, true)
		for _, v := range *data {
			positionId := quitl.IntAll(v["send_user_id"])
			if positionId != 0 {
				v["userName"] = positionData[positionId]
			}
		}
	}
	go func() {
		updateMap := map[string]interface{}{}
		if len(*data) > 0 && data != nil {
			//if true {
			//未读信息修改
			switch in.MsgType {
			case 2: //点对点聊天
				updateMap = map[string]interface{}{
					"own_type":     2,
					"own_id":       in.NewUserId,
					"send_user_id": in.SendId,
					"type":         2,
					"isread":       0,
				}
				IC.BaseMysql.Update(util.SOCIALIZE_MESSAGE_MAILBOX, updateMap, map[string]interface{}{"isread": 1, "read_time": time.Now().Local().Format(util.Date_Full_Layout)})
				break
			case 3: //群聊天
				sqlStr = fmt.Sprintf("UPDATE %s a  SET a.isread = 1, a.read_time = now( ) "+
					"WHERE a.own_type = 1 "+
					"AND a.type IN (3,6) "+
					"AND a.isread = 0 "+
					"AND a.own_id = %d AND a.chat_group_id = %d",
					util.SOCIALIZE_MESSAGE_MAILBOX, in.SendId, in.ChatGroupId)
			case 4, 5: //UserType 2用户1客服
				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.iswithdraw = 0 "+
						"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 in (%s) )",
						util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_CHAT_SESSION, in.EntUserId, positionStr)
				} else {
					sqlStr = fmt.Sprintf("UPDATE %s a  SET a.isread = 1,    a.read_time = now( )  "+
						"WHERE    a.own_type = 2 and a.iswithdraw = 0 "+
						"AND a.type IN ( 4,5,6,7 )  "+
						"AND a.isread = 0    "+
						"AND a.own_id  in (%s) ", util.SOCIALIZE_MESSAGE_MAILBOX, positionStr)
				}
				IC.BaseMysql.UpdateOrDeleteBySql(sqlStr)
				break
			}
			//redis缓存处理
			//b.Count(in.NewUserId, in.UserType, in.EntUserId, true)
		}
	}()
	return data
}

// 创建会话
func (b MessaggeService) CreateChatSession(in *messagecenter.ChatSessionReq) (fool bool, sessionId int64) {
	fool = IC.BaseMysql.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 := IC.BaseMysql.SelectBySql(sqlStr)
			if len(*customerList) > 0 {
				customerserviceName = quitl.InterfaceToStr((*customerList)[0]["customer_service_name"])
			}
		}
		//查询企业是否存在
		count := IC.BaseMysql.Count(util.SOCIALIZE_TENANT_ROBOT, map[string]interface{}{
			"ent_id": in.EntId,
		})
		if count < 1 {
			return false
		}
		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 = IC.BaseMysql.InsertByTx(tx, util.SOCIALIZE_CHAT_SESSION, chatMession)
		return sessionId > 0
	})
	return
}

// 结束会话
func (b MessaggeService) CloseChatSession(in *messagecenter.CloseSessionReq) bool {
	fool := IC.BaseMysql.ExecTx("关闭会话", func(tx *sql.Tx) bool {
		updateMap := map[string]interface{}{
			"id": in.SessionId,
		}
		fool := IC.BaseMysql.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) {
	var customer_service_id, userid, entid, message_id int64
	messageId := int64(0)
	ok1 := IC.BaseMysql.ExecTx("保存自动回复消息", func(tx *sql.Tx) bool {
		entUserName := ""
		if entUserId > 0 {
			list := IC.BaseMysql.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 = IC.BaseMysql.InsertBySqlByTx(tx, `insert into socialize_message (appid,content,item,type,create_time,create_person) values (?,?,?,?,?,?)`, appId, content, 8, 1, nowFormat, "admin")
		sessionId := IC.BaseMysql.InsertBySqlByTx(tx, `insert into socialize_chat_session (appid,type,ent_id,customer_service_id,customer_service_name,user_id,start_time,end_time) values (?,?,?,?,?,?,?,?)`, appId, 1, entId, entUserId, entUserName, userId, nowFormat, nowFormat)
		ok := false
		if userType == 0 {
			ok1 := IC.BaseMysql.InsertBySqlByTx(tx, `insert into socialize_message_mailbox (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 (?,?,?,?,?,?,?,?,?,?,?,?)`, appId, messageId, 7, sessionId, 1, userId, 2, sessionId, 1, nowFormat, 1, nowFormat) > 0
			ok2 := IC.BaseMysql.InsertBySqlByTx(tx, `insert into socialize_message_mailbox (appid,messag_id,type,send_user_id,send_user_type,receive_user_id,receive_user_type,own_id,own_type,create_time) values (?,?,?,?,?,?,?,?,?,?)`, appId, messageId, 7, sessionId, 1, userId, 2, userId, 2, nowFormat) > 0
			ok = ok1 && ok2
		} else if userType == 1 {
			ok = IC.BaseMysql.InsertBySqlByTx(tx, `insert into socialize_message_mailbox (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 (?,?,?,?,?,?,?,?,?,?,?,?)`, appId, messageId, 7, sessionId, 1, userId, 2, sessionId, 1, nowFormat, 1, nowFormat) > 0
		} else if userType == 2 {
			ok = IC.BaseMysql.InsertBySqlByTx(tx, `insert into socialize_message_mailbox (appid,messag_id,type,send_user_id,send_user_type,receive_user_id,receive_user_type,own_id,own_type,create_time) values (?,?,?,?,?,?,?,?,?,?)`, appId, messageId, 7, sessionId, 1, userId, 2, userId, 2, nowFormat) > 0
		}
		message_id = messageId
		return messageId > 0 && sessionId > 0 && ok
	})
	if ok1 {
		customer_service_id = entUserId
		userid = userId
		entid = entId
		go UserSynchronousList(customer_service_id, userid, entid, message_id, nowFormat)
	}
	return ok1, messageId
}

// 修改未读状态
func (b MessaggeService) UpdateReadById(in *messagecenter.ReadStateReq) bool {
	fool := IC.BaseMysql.ExecTx("已读状态修改", func(tx *sql.Tx) bool {
		updateMap := map[string]interface{}{
			"messag_id": in.MessageId,
			"isread":    0,
		}
		fool := IC.BaseMysql.Update(util.SOCIALIZE_MESSAGE_MAILBOX, updateMap, map[string]interface{}{"read_time": time.Now().Local().Format(util.Date_Full_Layout), "isread": 1})
		if fool {
			//查询此条信息拥有者
			data := IC.BaseMysql.FindOne(util.SOCIALIZE_MESSAGE_MAILBOX, updateMap, "receive_user_type", "")
			if data != nil {
				userType := int64(1)
				userId := int64(0)
				if (*data)["receive_user_type"] == 2 {
					userType = 2
					userId = in.EntUserId
				} else {
					userType = 1
					userId = in.NewUserId
				}
				pc_a, err := util.GetData(userType, userId)
				if fool {
					if err == nil && pc_a != nil {
						//id一致
						if in.MessageId == pc_a.Data["id"] {
							util.SetData(userType, userId, map[string]interface{}{"data": map[string]interface{}{}, "count": pc_a.Count - 1}, IC.SurvivalTime)
						} else {
							util.SetData(userType, userId, map[string]interface{}{"data": data, "count": pc_a.Count - 1}, IC.SurvivalTime)
						}
					}
				}

			}
		}
		return fool
	})
	return fool
}

// WithdrawMessage 撤回消息
func (b MessaggeService) WithdrawMessage(in *messagecenter.ReadWithdrawReq) bool {
	messageId := encrypt.SE.Decode4Hex(in.MessageId)
	newUserId, entUserId := NewEndId(quitl.Int64All(messageId), in.UserType)
	msg := IC.BaseMysql.FindOne(util.SOCIALIZE_MESSAGE, map[string]interface{}{"id": messageId}, "create_time", "")
	if msg == nil || len(*msg) <= 0 {
		log.Println("查询消息id失败")
		return false
	}
	createTime, _ := time.Parse(util.Date_Full_Layout, quitl.InterfaceToStr((*msg)["create_time"]))
	if createTime.Unix()+60*2 < time.Now().Unix() {
		log.Println("消息已超过2分钟,撤回失败")
		return false
	}
	nowForm := time.Now().Local()
	m := IC.BaseMysql.Update(util.SOCIALIZE_MESSAGE_MAILBOX,
		map[string]interface{}{"messag_id": messageId}, map[string]interface{}{"iswithdraw": 1, "withdraw_time": nowForm.Format(util.Date_Full_Layout)})
	if m {
		//消息撤回 更新对方私信
		in.UserType = quitl.Int64All(quitl.If(in.UserType == 1, 2, 1))
		b.Count(newUserId, in.UserType, entUserId, true)
	}
	return m
}

// AppraiseMessage 消息评价
func (b MessaggeService) AppraiseMessage(in *messagecenter.AppraiseReq) error {
	messageId := encrypt.SE.Decode4Hex(in.MessageId)
	//查询此条消息是否是当前用户的
	if IC.BaseMysql.Count(util.SOCIALIZE_MESSAGE_MAILBOX, map[string]interface{}{
		"messag_id":         messageId,
		"receive_user_id":   in.NewUserId,
		"receive_user_type": 2,
		"type":              8,
	}) == 0 {
		return fmt.Errorf("未查询到信息")
	}
	if IC.BaseMysql.Count(util.SOCIALIZE_APPRAISE, map[string]interface{}{
		"appid":     in.Appid,
		"messag_id": messageId,
	}) > 0 {
		return fmt.Errorf("请勿重复评价")
	}
	//插入评价
	if IC.BaseMysql.Insert(util.SOCIALIZE_APPRAISE, map[string]interface{}{
		"appid":       in.Appid,
		"messag_id":   messageId,
		"create_time": time.Now().Local().Format(util.Date_Full_Layout),
		"appraise":    in.Appraise,
	}) > 0 {
		return nil
	}
	return fmt.Errorf("评价消息异常")
}

// NewEndId 消息撤回 获取对方userid
func NewEndId(messageId, iType int64) (newUserId, entUserId int64) {
	data := IC.BaseMysql.FindOne(util.SOCIALIZE_MESSAGE_MAILBOX, map[string]interface{}{"messag_id": messageId, "own_type": iType}, "", "")
	if data != nil && len(*data) > 0 {
		if iType == 1 { //客服撤回消息 获取客服id与用户id
			entUserId = quitl.Int64All((*data)["send_user_id"])
			newUserId = quitl.Int64All((*data)["receive_user_id"])
		} else {
			//用户撤回消息 获取客服id与用户id
			newUserId = quitl.Int64All((*data)["send_user_id"])
			entUserId = quitl.Int64All((*data)["receive_user_id"])
		}
	}
	return
}

// 聊天
// 包含 1v1 ，群聊，群发
/*
入参 appid,title,content,sendid,link,item,messagetype,receiverIds,groupIds
*/
func (this *MessaggeService) Chat(in *messagecenter.MessageSaveReq) bool {
	return IC.BaseMysql.ExecTx("消息存储", func(tx *sql.Tx) bool {
		nowTime := time.Now().Format(date.Date_Full_Layout)
		isGroup := len(in.GroupIds) > 0
		isOneToOne := len(in.ReceiverIds) > 0
		createperson := strconv.Itoa(int(in.SendId))
		messageId := MessageAdd(tx, in.Appid, in.Title, in.Content, createperson, in.Link, in.Item, in.MessageType)
		//是否客服介入
		isCustomerServiceAccess := 0

		//群聊
		if isGroup {
			fieids := []string{"appid", "messag_id", "type", "send_user_id", "send_user_type", "receive_user_id", "receive_user_type", "own_type", "own_id", "create_time", "chat_group_id", "isread"}
			for _, v := range in.GroupIds {
				args := []interface{}{}
				summaryArgs := []interface{}{}
				args = append(args, in.Appid, messageId, in.Type, in.SendId, 2, in.SendId, 2, 2, in.SendId, nowTime, v, 1)
				groupUser := GetUserByGroupId(tx, v, in.SendId)
				for _, vv := range groupUser {
					log.Println("获取到群组下员工:", vv)
					args = append(args, in.Appid, messageId, in.Type, in.SendId, 2, vv, 2, 2, vv, nowTime, v, 0)
				}
				summaryArgs = append(summaryArgs, in.SendId, nil, nil, v, messageId, nil, isCustomerServiceAccess, nowTime)
				MessageMailBoxAdd(tx, fieids, args)
				//最后一次聊天
				SocializeSummaryAdd(tx, summaryArgs)
				//更新未读消息
				GroupUserUnReadUpdate(tx, groupUser)
			}
		}
		//1v1
		if isOneToOne {
			fieids := []string{"appid", "messag_id", "type", "send_user_id", "send_user_type", "receive_user_id", "receive_user_type", "own_type", "own_id", "create_time", "isread"}
			args := []interface{}{}
			summaryArgs := []interface{}{}
			args = append(args, in.Appid, messageId, in.Type, in.SendId, 2, in.SendId, 2, 2, in.SendId, nowTime, 1)
			for _, v := range in.ReceiverIds {
				args = append(args, in.Appid, messageId, in.Type, in.SendId, 2, v, 2, 2, v, nowTime, 0)
				//发送方，未读消息应该是0
				summaryArgs = append(summaryArgs, in.SendId, v, nil, nil, messageId, 0, isCustomerServiceAccess, nowTime)
				//接收方，未读消息应该是1
				summaryArgs = append(summaryArgs, v, in.SendId, nil, nil, messageId, 1, isCustomerServiceAccess, nowTime)
			}
			MessageMailBoxAdd(tx, fieids, args)
			//最后一次聊天
			SocializeSummaryAdd(tx, summaryArgs)
		}
		return true
	})
}

// 消息存储
func MessageAdd(tx *sql.Tx, appid, title, content, createperson, link string, item, messageType int64) int64 {
	nowTime := time.Now()
	message := map[string]interface{}{
		"appid":         appid,
		"title":         title,
		"content":       content,
		"item":          item,
		"type":          messageType,
		"link":          link,
		"create_time":   nowTime.Format(date.Date_Full_Layout),
		"create_person": createperson, //系统消息时，创建人是群聊id或接收人id
	}
	return IC.BaseMysql.InsertByTx(tx, util.SOCIALIZE_MESSAGE, message)
}

// 消息信息箱存储
// types 2:点对点 3:群消息
func MessageMailBoxAdd(tx *sql.Tx, fieids []string, args []interface{}) (int64, int64) {
	length, lastId := IC.BaseMysql.InsertBatchByTx(tx, util.SOCIALIZE_MESSAGE_MAILBOX, fieids, args)
	log.Println("MessageMailBoxAdd length:", length, "MessageMailBoxAdd lastId:", lastId)
	return length, lastId
}

// 获取除发送人以外的群成员
func GetUserByGroupId(tx *sql.Tx, groupId, sendId int64) []int64 {
	arr := []int64{}
	data := IC.BaseMysql.SelectBySqlByTx(tx, "select position_id from "+util.SOCIALIZE_CHAT_GROUP_PERSON+" where status = 1 and chat_group_id = ? AND position_id != ? ", groupId, sendId)
	log.Println("~~~~", data)
	if data == nil || len(*data) <= 0 {
		return arr
	}
	for _, v := range *data {
		position_id := quitl.Int64All(v["position_id"])
		if position_id == 0 {
			continue
		}
		arr = append(arr, position_id)
	}
	return arr
}

//最后一次聊天存储
func SocializeSummaryAdd(tx *sql.Tx, args []interface{}) (int64, int64) {
	fieids := []string{"my_position_id", "your_position_id", "ent_id", "chat_group_id", "message_id", "unread", "customer_service_access", "timestamp"}

	length, lastId := IC.BaseMysql.InsertBatchByTx(tx, util.SOCIALIZE_SUMMARY, fieids, args)

	log.Println("SocializeSummaryAdd length:", length, "SocializeSummaryAdd lastId:", lastId)

	return length, lastId
}

//群组人员未读消息更新
func GroupUserUnReadUpdate(tx *sql.Tx, ids []int64) bool {
	whs := []string{}
	for i := 0; i < len(ids); i++ {
		whs = append(whs, "?")
	}
	wh := strings.Join(whs, ",")
	interfaces := gconv.Interfaces(ids)
	count := IC.BaseMysql.UpdateOrDeleteBySql(`UPDATE `+util.SOCIALIZE_CHAT_GROUP_PERSON+` SET unread = unread + 1 WHERE id in (`+wh+`)`, interfaces...)
	if count > 0 {
		return true
	}
	return true
}