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{} var ( //rwLock = new(sync.RWMutex) InsertLock = new(sync.Mutex) ) // Count 未读消息查询 func (b MessaggeService) Count(newUserId, positionId int64) (last map[string]interface{}, count int) { //导航右上角未读消息总量 1v1聊天+群组消息+客服消息 querySql := fmt.Sprintf("SELECT b.*,(SELECT SUM( a.unread) FROM %s a "+ "LEFT JOIN %s b ON a.message_id = b.id "+ "WHERE a.unread > 0 "+ "AND ( a.my_position_id = %d OR a.user_id = %d )) AS unread "+ "FROM %s a "+ "LEFT JOIN %s b ON a.message_id = b.id "+ "WHERE a.unread > 0 "+ "AND ( a.my_position_id = %d OR a.user_id = %d ) "+ "ORDER BY a.TIMESTAMP DESC LIMIT 0,1", util.SOCIALIZE_SUMMARY, util.SOCIALIZE_MESSAGE, positionId, newUserId, util.SOCIALIZE_SUMMARY, util.SOCIALIZE_MESSAGE, positionId, newUserId) log.Println("查询sql", querySql) data := IC.BaseMysql.SelectBySql(querySql) if data != nil && len(*data) > 0 { return (*data)[0], quitl.IntAll((*data)[0]["unread"]) } else { return nil, 0 } } // 用户列表查询 func (b MessaggeService) UserList(in *messagecenter.UserReq) (data *[]map[string]interface{}, count int64, err error) { sqlStr := "" tm := time.Now() if in.UserType == 2 { var ( allSql, positionIdArr, oneSql, oneNameSql, serviceNameSql string sqlArr []string ) GroupNameSql := `(SELECT *,"" as groupMember FROM socialize_chat_group where isdismiss = 0)` //无搜索群 if in.NameSearch != "" { serviceNameSql = " AND b.nickname like '%" + in.NameSearch + "%'" GroupNameSql = `(SELECT id,name,"" as groupMember FROM socialize_chat_group WHERE isdismiss = 0 AND name like '%` + in.NameSearch + `%')` //默认搜素群名称 positionIdArr = NameToPositionIdp(in.NameSearch, in.EntId) if positionIdArr != "" { oneNameSql = " AND find_in_set(b.id,'" + positionIdArr + "')" //1v1搜索成员id //存在满足成员名时 重新定义搜索sql 并兼容群名称不满足但成员名满足时也展示 并展示部分满足群员名 nameSearch := " or b.name like '%" + in.NameSearch + "%')" name := fmt.Sprintf(" AND (c.position_id IN ( %s ) %s", positionIdArr, nameSearch) GroupNameSql = fmt.Sprintf(` ( SELECT a.chat_group_id as id, GROUP_CONCAT( distinct c.position_id ) as groupMember, GROUP_CONCAT( distinct b.name ) as name FROM socialize_chat_group_person a INNER JOIN socialize_chat_group b ON a.position_id=%d AND a.chat_group_id = b.id AND b.isdismiss = 0 INNER JOIN socialize_chat_group_person c ON a.chat_group_id = c.chat_group_id %s GROUP BY a.chat_group_id)`, in.PositionId, name) //群搜索 } } log.Println("用户列表展示", in.NameSearch, in.EntId, oneNameSql) //1v1 无搜索时 或搜索有结果时 if in.NameSearch == "" || oneNameSql != "" { oneSql = fmt.Sprintf(`(SELECT a.your_position_id AS id, 2 AS userType, c.nickname AS name, c.headimg, d.content, d.type, d.create_time, a.unread as number, a.timestamp, c.phone, "" as groupMember FROM socialize_summary a INNER JOIN base_position b ON ( a.my_position_id = %d %s AND a.your_position_id = b.id) INNER JOIN base_user c ON ( b.user_id = c.id ) LEFT JOIN socialize_message d ON ( a.message_id = d.id ) ORDER BY a.timestamp DESC LIMIT 0,500 )`, in.PositionId, oneNameSql) } //客服列表 serviceSql := fmt.Sprintf(` ( SELECT DISTINCT(a.ent_id) AS id, 1 AS userType, b.nickname AS name, b.headimage as headimg, c.content, c.type, c.create_time, a.unread as number, a.timestamp, "" as phone, "" as groupMember FROM socialize_summary a INNER JOIN socialize_tenant_robot b ON ( a.user_id = %d AND a.ent_id = b.ent_id %s ) LEFT JOIN socialize_message c ON ( a.message_id = c.id ) ORDER BY a.timestamp DESC LIMIT 0,500 ) `, in.NewUserId, serviceNameSql) //群列表 groupSql := fmt.Sprintf(` ( SELECT b.id, 3 AS userType, b.name, '' AS headimg, d.content, d.type, d.create_time, a.unread as number, a.timestamp, "" as phone, b.groupMember FROM socialize_summary a INNER JOIN %s b ON ( a.my_position_id = %d AND a.chat_group_id = b.id) LEFT JOIN socialize_message d ON ( a.message_id = d.id ) ORDER BY a.timestamp DESC LIMIT 0,500 ) `, GroupNameSql, in.PositionId) if oneSql != "" { sqlArr = append(sqlArr, oneSql) } if groupSql != "" { sqlArr = append(sqlArr, groupSql) } switch in.QueryType { case 1: //分享列表 if len(sqlArr) > 1 { allSql = strings.Join(sqlArr, " UNION ALL ") } else { allSql = sqlArr[0] } default: //历史会话列表 if serviceSql != "" { sqlArr = append(sqlArr, serviceSql) } allSql = strings.Join(sqlArr, " UNION ALL ") } var startNum int64 = 1 var pageSize int64 = 500 if in.Size > 0 && in.Size < 500 { if in.Page == 0 { in.Page = 1 } if in.Page*in.Size < 500 { startNum = in.Page pageSize = in.Size } } sqlStr = fmt.Sprintf(`SELECT * FROM( %s ) a ORDER BY a.timestamp DESC LIMIT %d,%d`, allSql, (startNum-1)*pageSize, pageSize) } else { var timeSql, phoneSql, filtrationSql, isTouristSql string if in.StartTime != "" { timeSql += fmt.Sprintf(" AND a.timestamp >= '%s 00:00:00'", in.StartTime) } if in.EndTime != "" { timeSql += fmt.Sprintf(" AND a.timestamp <= '%s 23:59:59'", in.EndTime) } if in.Phone != "" { phoneSql = " AND b.phone like '%" + in.Phone + "%'" } if in.IsTourist == 1 || in.IsTourist == 2 { isTouristSql = " AND b.is_tourist = " + fmt.Sprintf("%d", in.IsTourist) } if in.FiltrationId != "" { var ids []string for _, v := range strings.Split(in.FiltrationId, ",") { ids = append(ids, encrypt.SE.Decode4Hex(v)) } filtrationSql += fmt.Sprintf(" AND b.id not in (%s)", strings.Join(ids, ",")) } aiSql := fmt.Sprintf(`(SELECT a.user_id, a.message_id, a.timestamp, b.nickname, 0 as unread, b.headimg, b.phone, 0 as userType, b.is_tourist FROM socialize_summary a INNER JOIN base_user b ON (a.user_id = b.id AND a.ent_id = %d AND a.customer_service_access = 0) %s %s %s %s)`, in.EntId, timeSql, phoneSql, filtrationSql, isTouristSql) serviceSql := fmt.Sprintf(`(SELECT a.user_id, c.message_id, c.timestamp, b.nickname, a.unread, b.headimg, b.phone, 0 as userType, b.is_tourist FROM socialize_customer_service_user a INNER JOIN base_user b ON ( a.customer_service_id = %d AND a.user_id = b.id %s %s %s) INNER JOIN socialize_summary c ON ( a.ent_id = c.ent_id AND a.user_id = c.user_id %s))`, in.EntUserId, filtrationSql, phoneSql, isTouristSql, strings.ReplaceAll(timeSql, "a.", "c.")) var restrictionSql string switch in.IsArtificial { case 1: restrictionSql = serviceSql case 2: restrictionSql = aiSql default: restrictionSql = aiSql + " UNION ALL " + serviceSql } if in.Page <= 0 { in.Page = 1 } if in.Size <= 0 || in.Size > 100 { in.Size = 50 } sqlStr = fmt.Sprintf(`SELECT ( CASE WHEN SUBSTR( a.nickname, 1, 3 ) = 'JY_' THEN CONCAT( SUBSTR( a.phone, 1, 3 ), '****', SUBSTR( a.phone, 8, 11 ) ) WHEN a.nickname = '' OR a.nickname IS NULL THEN CONCAT( SUBSTR( a.phone, 1, 3 ), '****', SUBSTR( a.phone, 8, 11 ) ) ELSE a.nickname END ) AS name, c.content, c.title, c.type, c.link, c.create_time, a.message_id, a.timestamp, a.unread as number, a.user_id as id, a.headimg, a.phone, a.userType, a.is_tourist FROM (%s) a LEFT JOIN socialize_message c ON ( a.message_id = c.id ) ORDER BY a.timestamp DESC limit %v ,%v`, restrictionSql, (in.Page-1)*in.Size, in.Size) count = IC.BaseMysql.CountBySql(fmt.Sprintf(`SELECT count(1) FROM (%s) a`, restrictionSql)) } if sqlStr != "" { log.Println("查询列表sql:", sqlStr) data = IC.BaseMysql.SelectBySql(sqlStr) if data != nil && len(*data) > 0 { log.Println("查询列表耗时2:", time.Since(tm), in.QueryType, count) switch in.UserType { //客服查询结果分页 case 1: /* 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 data, count, err case 2: //用户查询结果 count = quitl.Int64All(len(*data)) phoneMap, _, positionMap := EntPerson(in.EntId, true) //获取企业架构人员名称 log.Println("查询列表耗时3:", time.Since(tm)) for _, v := range *data { if quitl.IntAll(v["userType"]) == 2 { v["name"] = phoneMap[quitl.InterfaceToStr(v["phone"])] } else if quitl.IntAll(v["userType"]) == 3 { var names []string if quitl.InterfaceToStr(v["groupMember"]) != "" { for _, id := range strings.Split(quitl.InterfaceToStr(v["groupMember"]), ",") { if len(names) > 4 { break } //防止匹配的是群名称 去除不匹配的群成员 if strings.Contains(positionMap[quitl.IntAll(id)], in.NameSearch) { names = append(names, positionMap[quitl.IntAll(id)]) } } } v["groupMember"] = names } } } } } 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)) } filtrationSql := fmt.Sprintf(" AND b.id in (%s)", strings.Join(ids, ",")) aiSql := fmt.Sprintf(`(SELECT a.user_id, a.message_id, a.timestamp, b.nickname, 0 as unread, b.headimg, b.phone, b.is_tourist FROM socialize_summary a INNER JOIN base_user b ON (a.user_id = b.id AND a.ent_id = %d AND a.customer_service_access = 0 %s ))`, in.EntId, filtrationSql) serviceSql := fmt.Sprintf(`(SELECT a.user_id, c.message_id, c.timestamp, b.nickname, a.unread, b.headimg, b.phone, b.is_tourist FROM socialize_customer_service_user a INNER JOIN base_user b ON ( a.customer_service_id = %d AND a.user_id = b.id %s) INNER JOIN socialize_summary c ON ( a.ent_id = c.ent_id AND a.user_id = c.user_id))`, in.EntUserId, filtrationSql) restrictionSql := aiSql + " UNION ALL " + serviceSql sqlStr = fmt.Sprintf(`SELECT ( CASE WHEN SUBSTR( a.nickname, 1, 3 ) = 'JY_' THEN CONCAT( SUBSTR( a.phone, 1, 3 ), '****', SUBSTR( a.phone, 8, 11 ) ) WHEN a.nickname = '' OR a.nickname IS NULL THEN CONCAT( SUBSTR( a.phone, 1, 3 ), '****', SUBSTR( a.phone, 8, 11 ) ) ELSE a.nickname END ) AS name, c.content, c.title, c.type, c.link, c.create_time, a.message_id, a.timestamp, a.unread as number, a.user_id as id, a.headimg, a.phone, a.is_tourist FROM (%s) a LEFT JOIN socialize_message c ON ( a.message_id = c.id ) ORDER BY a.timestamp DESC`, restrictionSql) } if sqlStr != "" { log.Println("ConversationList查询列表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) 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 userType := int64(1) //客服相关信息保存 fool = IC.BaseMysql.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": 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 if in.ItemType == 4 { messageMailBox["isread"] = 1 } } 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, "type": in.ItemType, "create_time": nowForm.Format(util.Date_Full_Layout), "messag_id": ok, "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) return ok > 1 && receiveOk > 1 }) if fool { //go UserSynchronousList(customer_service_id, userid, entid, message_id, create_time, quitl.Int64All(quitl.If(userType == 1, 2, 1)), in.ItemType) } return fool, "", in.Content, messageId, nowForm.Unix() } // 客服 用户聊天消息列表同步 // sendUserType 发送人类型 1客服 2用户 func UserSynchronousList(customerServiceId, userId, entId, messageId int64, createTime string, sendUserType, itemType int64) { InsertLock.Lock() defer InsertLock.Unlock() log.Printf("同步最后消息参数customerServiceId:%d,userId:%d,entId%d,messageId:%d", customerServiceId, userId, entId, messageId) //nowForm := time.Now().Local() //create_time := nowForm.Format(util.Date_Full_Layout) //查看汇总表 IC.BaseMysql.ExecTx("更新汇总表", func(tx *sql.Tx) bool { data := IC.BaseMysql.SelectBySqlByTx(tx, "select customer_service_access from socialize_summary where ent_id=? and user_id=? ", entId, userId) //data := FindOne(util.SOCIALIZE_SUMMARY, map[string]interface{}{"user_id": userId, "ent_id": entId}, "customer_service_access", "") customer_service_access := 0 if data != nil && len(*data) > 0 { if quitl.IntAll((*data)[0]["customer_service_access"]) == 0 && customerServiceId > 0 { customer_service_access = 1 } else { customer_service_access = quitl.IntAll((*data)[0]["customer_service_access"]) } log.Println(customer_service_access, "customer_service_access打印", (*data)[0]["customer_service_access"], customerServiceId, quitl.IntAll((*data)[0]["customer_service_access"]) == 0 && customerServiceId > 0) //更新汇总表 ok := int64(0) if sendUserType == 1 { if itemType == 4 { //机器人消息保存处理 ok = IC.BaseMysql.UpdateOrDeleteBySqlByTx(tx, fmt.Sprintf("UPDATE socialize_summary SET message_id = %d ,timestamp = '%s' WHERE user_id = %d and ent_id= %d", messageId, createTime, userId, entId)) } else { ok = IC.BaseMysql.UpdateOrDeleteBySqlByTx(tx, fmt.Sprintf("UPDATE socialize_summary SET message_id = %d ,timestamp = '%s', unread = unread+1, customer_service_access = %d WHERE user_id = %d and ent_id= %d", messageId, createTime, customer_service_access, userId, entId)) } } else { ok = IC.BaseMysql.UpdateOrDeleteBySqlByTx(tx, fmt.Sprintf("UPDATE socialize_summary SET message_id = %d ,timestamp = '%s', customer_service_access = %d WHERE user_id = %d and ent_id= %d", messageId, createTime, customer_service_access, userId, entId)) } if ok > 0 { if customerServiceId > 0 { //判断客服用户表是否存在 if IC.BaseMysql.Count(util.Socialize_customer_service_user, map[string]interface{}{"user_id": userId, "ent_id": entId, "customer_service_id": customerServiceId}) > 0 { if sendUserType == 2 { IC.BaseMysql.UpdateOrDeleteBySqlByTx(tx, fmt.Sprintf("UPDATE socialize_customer_service_user SET unread = unread+1 WHERE user_id = %d and customer_service_id= %d", userId, customerServiceId)) } } else { IC.BaseMysql.Insert(util.SOCIALIZE_CUSTOMER_SERVICE_USER, map[string]interface{}{ "user_id": userId, "ent_id": entId, "customer_service_id": customerServiceId, "unread": quitl.If(sendUserType == 1, 0, 1), }) } } } } else { //新增汇总表 ok := IC.BaseMysql.InsertByTx(tx, util.SOCIALIZE_SUMMARY, map[string]interface{}{ "user_id": userId, "ent_id": entId, "customer_service_access": quitl.If(customerServiceId > 0, 1, 0), "timestamp": createTime, "unread": quitl.If(sendUserType == 1, 0, 1), "message_id": messageId, }) log.Println(ok, "---", userId, "---", messageId, "---", entId, "------add summary log:") //新增客服用户表 if ok > 0 { if customerServiceId > 0 { if id := IC.BaseMysql.InsertByTx(tx, util.SOCIALIZE_CUSTOMER_SERVICE_USER, map[string]interface{}{ "user_id": userId, "ent_id": entId, "customer_service_id": customerServiceId, "unread": quitl.If(sendUserType == 1, 0, 1), }); id <= 0 { return false } } } else { return false } } return true }) } // 历史信息查询 func (b MessaggeService) FindMessage(in *messagecenter.MessageReq) *[]map[string]interface{} { //log.Println(in.PositionId, in.NewUserId, in.EntId, in.ChatGroupId) 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,a.send_user_type,a.type AS itemType,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 "+ "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 IN ( 2, 6 ) %s "+ "AND a.chat_group_id IS null "+ "AND a.send_user_type = a.receive_user_type "+ "ORDER BY a.id desc "+ "limit 0 , %d ", util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_MESSAGE, util.BASE_USER, util.BASE_USER, in.PositionId, in.PositionId, in.SendId, in.SendId, in.PositionId, lastStr, in.PageSize) break case 3: //群聊天 sqlStr = fmt.Sprintf("SELECT a.messag_id AS messageId,b.*,a.send_user_type,a.type AS itemType,"+ "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 = 2 and a.iswithdraw = 0 AND a.own_id = %d "+ "AND a.chat_group_id = %d AND a.type IN ( 3, 6 ) %s "+ "ORDER BY a.id DESC "+ "LIMIT 0, %d", util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_MESSAGE, in.PositionId, in.ChatGroupId, lastStr, in.PageSize) case 4, 5, 6, 7: //客服聊天 //查询用户所有的职位id positionStr = GetUserAllPosition(in.NewUserId) 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 = %d %s "+ "AND a.send_user_type != a.receive_user_type "+ "ORDER BY a.id desc "+ "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,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 "+ "LEFT JOIN %s e on e.messag_id=b.id "+ "WHERE a.own_type = 2 and a.iswithdraw = 0 "+ "AND a.own_id = %d "+ "AND c.ent_id = %d "+ "AND c.user_id = %d "+ "AND a.send_user_type != a.receive_user_type "+ "AND ( a.type = 4 OR a.type = 5 or a.type=6 or a.type=7 or a.type=8) %s "+ "ORDER BY a.id desc "+ "limit 0 , %d ", util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_MESSAGE, util.SOCIALIZE_CHAT_SESSION, in.SendId, in.NewUserId, util.SOCIALIZE_TENANT_ROBOT, util.SOCIALIZE_APPRAISE, in.NewUserId, in.SendId, in.NewUserId, 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 || in.MsgType == 2) && data != nil && len(*data) > 0 { _, _, positionData := EntPerson(in.EntId, true) for _, v := range *data { positionId := quitl.IntAll(v["send_position_id"]) if positionId != 0 { v["userName"] = positionData[positionId] //log.Println(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.PositionId, "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)}) //更新socialize_summary表未读消息数量 updateQuery := map[string]interface{}{ "my_position_id": in.PositionId, "your_position_id": in.SendId, } IC.BaseMysql.Update(util.SOCIALIZE_SUMMARY, updateQuery, map[string]interface{}{"unread": 0}) 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) IC.BaseMysql.UpdateOrDeleteBySql(sqlStr) //更新socialize_summary表未读消息数量 updateQuery := map[string]interface{}{ "my_position_id": in.PositionId, "chat_group_id": in.ChatGroupId, } IC.BaseMysql.Update(util.SOCIALIZE_SUMMARY, updateQuery, map[string]interface{}{"unread": 0}) case 4, 5: sqlStr := "" unreadSql := "" if in.UserType == 1 { //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 id FROM %s WHERE user_id = %d)", util.SOCIALIZE_MESSAGE_MAILBOX, util.BASE_POSITION, in.NewUserId) unreadSql = fmt.Sprintf("UPDATE %s SET unread = 0 WHERE user_id = %d AND customer_service_id = %d", util.Socialize_customer_service_user, in.SendId, in.EntUserId) } else { //2用户 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) unreadSql = fmt.Sprintf("UPDATE %s SET unread = 0 WHERE user_id = %d AND ent_id = %d", util.SOCIALIZE_SUMMARY, in.NewUserId, in.SendId) } IC.BaseMysql.UpdateOrDeleteBySql(sqlStr) IC.BaseMysql.UpdateOrDeleteBySql(unreadSql) 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 userType = 1 } 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 userType = 2 } 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 userType = 1 } 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, userType, 6) } return ok1, messageId } // 修改未读状态 func (b MessaggeService) UpdateReadById(in *messagecenter.ReadStateReq) { updateMap := map[string]interface{}{} sqlStr := "" log.Println("UpdateReadById", in.PositionId, in.NewUserId, in.SendId, in.EntUserId, in.UserType) switch in.UserType { case 2: //点对点聊天 updateMap = map[string]interface{}{ "own_type": 2, "own_id": in.PositionId, "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)}) //更新socialize_summary表未读消息数量 updateQuery := map[string]interface{}{ "my_position_id": in.PositionId, "your_position_id": in.SendId, } IC.BaseMysql.Update(util.SOCIALIZE_SUMMARY, updateQuery, map[string]interface{}{"unread": 0}) 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.PositionId, in.SendId) IC.BaseMysql.UpdateOrDeleteBySql(sqlStr) //更新socialize_summary表未读消息数量 updateQuery := map[string]interface{}{ "my_position_id": in.PositionId, "chat_group_id": in.SendId, } IC.BaseMysql.Update(util.SOCIALIZE_SUMMARY, updateQuery, map[string]interface{}{"unread": 0}) case 1: // 客服聊天 unreadSql := "" positionStr := GetUserAllPosition(in.NewUserId) if in.SendType == 1 { //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 id FROM %s WHERE user_id = %d)", util.SOCIALIZE_MESSAGE_MAILBOX, util.BASE_POSITION, in.NewUserId) unreadSql = fmt.Sprintf("UPDATE %s SET unread = 0 WHERE user_id = %d AND customer_service_id = %d", util.Socialize_customer_service_user, in.SendId, in.EntUserId) } else { //2用户 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) unreadSql = fmt.Sprintf("UPDATE %s SET unread = 0 WHERE user_id = %d AND ent_id = %d", util.SOCIALIZE_SUMMARY, in.NewUserId, in.SendId) } IC.BaseMysql.UpdateOrDeleteBySql(sqlStr) IC.BaseMysql.UpdateOrDeleteBySql(unreadSql) } //if true { //未读信息修改 //redis缓存处理 //b.Count(in.NewUserId, in.UserType, in.EntUserId, true) } // WithdrawMessage 撤回消息 func (b MessaggeService) WithdrawMessage(in *messagecenter.ReadWithdrawReq) bool { messageId := encrypt.SE.Decode4Hex(in.MessageId) 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 { go SynchronousInfo(in.SenderId, in.RecipientId, in.ConversationType, quitl.Int64All(messageId), in.UserType, in.EntId, in.ChatGroupId) } return m } // 撤回消息同步信息 func SynchronousInfo(sender, recipient, conversationType, messageId, userType, entId, chatGroupId int64) { switch conversationType { case 1: //1v1用户聊天 if IC.BaseMysql.Count(util.SOCIALIZE_MESSAGE_MAILBOX, map[string]interface{}{"messag_id": messageId, "own_id": recipient, "isread": 0}) > 0 { IC.BaseMysql.SelectBySql(fmt.Sprintf("update %s set unread=CASE WHEN unread > 0 and my_position_id = %d and your_position_id = %d THEN unread-1 ELSE 0 END;", util.Socialize_summary, recipient, sender)) } case 2: //用户与客服 if IC.BaseMysql.Count(util.SOCIALIZE_MESSAGE_MAILBOX, map[string]interface{}{"messag_id": messageId, "own_id": recipient, "isread": 0}) > 0 { if userType == 2 { //发送人是用户 //接收人是会话标识 查询客服id data := IC.BaseMysql.FindOne(util.SOCIALIZE_CHAT_SESSION, map[string]interface{}{"id": recipient}, "", "") if data != nil && len(*data) > 0 { IC.BaseMysql.SelectBySql(fmt.Sprintf("update %s set unread=CASE WHEN unread > 0 and user_id = %d and customer_service_id = %d and entId = %d THEN unread-1 ELSE 0 END;", util.Socialize_customer_service_user, sender, quitl.IntAll((*data)["customer_service_id"]), entId)) } } else { //发送人是客服 IC.BaseMysql.SelectBySql(fmt.Sprintf("update %s set unread=CASE WHEN unread > 0 and user_id = %d and ent_id = %d THEN unread-1 ELSE 0 END;", util.Socialize_summary, recipient, entId)) } } case 3: //一对群 data := IC.BaseMysql.Find(util.SOCIALIZE_MESSAGE_MAILBOX, map[string]interface{}{"messag_id": messageId, "chat_group_id": chatGroupId, "isread": 0}, "own_id", "", -1, -1) if data != nil && len(*data) > 0 { var ownIds []string for _, v := range *data { ownIds = append(ownIds, quitl.InterfaceToStr(v["own_id"])) } IC.BaseMysql.SelectBySql(fmt.Sprintf("update %s set unread=CASE WHEN unread > 0 and chat_group_id = %d and my_position_id in (%s) THEN unread-1 ELSE 0 END;", util.Socialize_summary, chatGroupId, strings.Join(ownIds, ","))) } } } // 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("评价消息异常") } // 聊天 // 包含 1v1 ，群聊，群发 /* 类型；1：站内信消息 2：点对点消息 3：群消息 4：机器人消息 5：客服消息 6系统信息 7：客服自动回复 8：评价 9：其它系统消息 （除客服以外的） 10：撤回（自己看到的） 11：撤回（其他人看到的） 群撤回自己看到的和用户看到的不一样 */ func (this *MessaggeService) Chat(in *messagecenter.MessageEntity) (fool bool, errorMsg string, content string, messageId, nowInt int64) { now := time.Now() nowTime := now.Format(date.Date_Full_Layout) messageId = int64(0) fool = IC.BaseMysql.ExecTx("消息存储", func(tx *sql.Tx) bool { isGroup := len(in.GroupIds) > 0 isOneToOne := len(in.ReceiverIds) > 0 isWithdrawByMyself := in.ItemType == 10 isWithdrawByOthers := in.ItemType == 11 createperson := strconv.Itoa(int(in.SendId)) messageId = MessageAdd(tx, in.Appid, in.Title, in.Content, createperson, in.Link, in.Item, in.Type) //是否客服介入 isCustomerServiceAccess := 0 //除客服消息以外的系统消息 if in.ItemType == 9 || in.ItemType == 10 || in.ItemType == 11 { in.ItemType = 6 } //群聊 if isGroup { //修改类型为群聊 if in.ItemType != 6 { in.ItemType = 3 } 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{}{} groupUser := GetUserByGroupId(tx, v, in.SendId) //发送人自己 if !isWithdrawByOthers { args = append(args, in.Appid, messageId, in.ItemType, in.SendId, 2, in.SendId, 2, 2, in.SendId, nowTime, v, 1) //最后一次聊天 SocializeSummaryAddOrUpdate(tx, v, in.SendId, 0, messageId, isCustomerServiceAccess, nowTime, false, in.ItemType) } for _, vv := range groupUser { if !isWithdrawByMyself { log.Println("获取到群组下员工:", vv) //接收人其他用户 args = append(args, in.Appid, messageId, in.ItemType, in.SendId, 2, vv, 2, 2, vv, nowTime, v, 0) //最后一次聊天 SocializeSummaryAddOrUpdate(tx, v, 0, vv, messageId, isCustomerServiceAccess, nowTime, false, in.ItemType) } } MessageMailBoxAdd(tx, fieids, args) } } //1v1 if isOneToOne { //修改类型为个人 if in.ItemType != 6 { in.ItemType = 2 } 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{}{} for _, v := range in.ReceiverIds { if !isWithdrawByOthers { args = append(args, in.Appid, messageId, in.ItemType, in.SendId, 2, v, 2, 2, in.SendId, nowTime, 1) //最后一次聊天 SocializeSummaryAddOrUpdate(tx, 0, in.SendId, v, messageId, isCustomerServiceAccess, nowTime, true, in.ItemType) } if !isWithdrawByMyself { args = append(args, in.Appid, messageId, in.ItemType, in.SendId, 2, v, 2, 2, v, nowTime, 0) //最后一次聊天 SocializeSummaryAddOrUpdate(tx, 0, v, in.SendId, messageId, isCustomerServiceAccess, nowTime, false, in.ItemType) } } MessageMailBoxAdd(tx, fieids, args) } return true }) return fool, "", in.Content, messageId, now.Unix() } // 消息存储 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) 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 } // 最后一次聊天存储 // 1v1是双方的 // 群聊是发送人和其他人的 // send :true发送人 false接收人 用于取分1对1 身份 func SocializeSummaryAddOrUpdate(tx *sql.Tx, groupId, myPositionId, yourPositionId, messageId int64, isCustomerServiceAccess int, timestamp string, send bool, itemType int64) bool { //判断是否存在 if groupId > 0 { isSend := myPositionId != 0 if isSend { if IC.BaseMysql.CountBySql(fmt.Sprintf(`select count(1) from %s where chat_group_id =? and my_position_id =?`, util.SOCIALIZE_SUMMARY), groupId, myPositionId) > 0 { //存在更新 return IC.BaseMysql.UpdateByTx(tx, util.SOCIALIZE_SUMMARY, map[string]interface{}{ "chat_group_id": groupId, "my_position_id": myPositionId, }, map[string]interface{}{ "message_id": messageId, "timestamp": timestamp, }) } else { //新增 return IC.BaseMysql.InsertByTx(tx, util.SOCIALIZE_SUMMARY, map[string]interface{}{ "chat_group_id": groupId, "my_position_id": myPositionId, "message_id": messageId, "timestamp": timestamp, "unread": 0, }) > 0 } } else { if r := IC.BaseMysql.SelectBySql(fmt.Sprintf(`select unread from %s where chat_group_id =? and my_position_id =?`, util.SOCIALIZE_SUMMARY), groupId, yourPositionId); r != nil && len(*r) > 0 { updateMap := map[string]interface{}{ "message_id": messageId, "timestamp": timestamp, } if itemType != 6 { updateMap["unread"] = gconv.Int((*r)[0]["unread"]) + 1 } //存在更新 return IC.BaseMysql.UpdateByTx(tx, util.SOCIALIZE_SUMMARY, map[string]interface{}{ "chat_group_id": groupId, "my_position_id": yourPositionId, }, updateMap) } else { //新增 saveMap := map[string]interface{}{ "chat_group_id": groupId, "my_position_id": yourPositionId, "message_id": messageId, "timestamp": timestamp, } if itemType != 6 { saveMap["unread"] = 1 } return IC.BaseMysql.InsertByTx(tx, util.SOCIALIZE_SUMMARY, saveMap) > 0 } } } else { if yourPositionId > 0 { ok_my := true ok_your := true //发送方 if r := IC.BaseMysql.SelectBySql(fmt.Sprintf(`select id,unread from %s where my_position_id =? and your_position_id =? limit 1`, util.SOCIALIZE_SUMMARY), myPositionId, yourPositionId); r != nil && len(*r) > 0 { //存在更新 updateMap := map[string]interface{}{ "message_id": messageId, "timestamp": timestamp, } if !send && itemType != 6 { updateMap["unread"] = gconv.Int((*r)[0]["unread"]) + 1 } ok_my = IC.BaseMysql.UpdateByTx(tx, util.SOCIALIZE_SUMMARY, map[string]interface{}{ "my_position_id": myPositionId, "your_position_id": yourPositionId, }, updateMap) } else { //新增 saveMap := map[string]interface{}{ "my_position_id": myPositionId, "your_position_id": yourPositionId, "message_id": messageId, "timestamp": timestamp, "unread": 0, "customer_service_access": isCustomerServiceAccess, } if !send && itemType != 6 { saveMap["unread"] = 1 } ok_my = IC.BaseMysql.InsertByTx(tx, util.SOCIALIZE_SUMMARY, saveMap) > 0 } return ok_my && ok_your } } return true } // 群组人员未读消息更新 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 } // GetUserAllPosition 用户下所有职位id func GetUserAllPosition(baseUserId int64) (positionStr string) { //查询用户所有的职位id sqlPosition := fmt.Sprintf("SELECT id FROM %s WHERE user_id = %d", util.BASE_POSITION, baseUserId) positionArr := IC.BaseMysql.SelectBySql(sqlPosition) if positionArr != nil && len(*positionArr) > 0 { for k, val := range *positionArr { if k < len(*positionArr)-1 { positionStr += strconv.Itoa(quitl.IntAll(val["id"])) + "," } else { positionStr += strconv.Itoa(quitl.IntAll(val["id"])) } } } return positionStr } // 1v1首次建立会话 创建汇总表 func OneCreatingSession(in *messagecenter.OneUserConversationReq) string { if in.MyPositionId < 0 || in.YouPositionId < 0 { return "参数异常" } if IC.BaseMysql.Count(util.SOCIALIZE_SUMMARY, map[string]interface{}{"my_position_id": in.MyPositionId, "your_position_id": in.YouPositionId}) > 0 { return "" } if IC.BaseMysql.Insert(util.SOCIALIZE_SUMMARY, map[string]interface{}{ "my_position_id": in.MyPositionId, "your_position_id": in.YouPositionId, "message_id": 0, "timestamp": time.Now().Format(date.Date_Full_Layout), "unread": 0, "customer_service_access": 0, }) > 0 { return "" } return "创建汇总表数据失败" } func GetSenderName(in *messagecenter.GetSenderNameReq) string { var name string switch in.SType { case 1: //客服 data1 := IC.BaseMysql.FindOne("socialize_chat_session", map[string]interface{}{"id": in.Id}, "customer_service_id", "") if data1 != nil && len(*data1) > 0 { data := IC.BaseMysql.FindOne("socialize_tenant_seat", map[string]interface{}{"customer_service_id": quitl.IntAll((*data1)["customer_service_id"])}, "customer_service_name", "") if data != nil && len(*data) > 0 { name = fmt.Sprintf("%s(客服)", quitl.InterfaceToStr((*data)["customer_service_name"])) } } case 2: //用户 position := IC.BaseMysql.SelectBySql(fmt.Sprintf(`SELECT a.ent_id,b.phone FROM base_position a INNER JOIN base_user b on a.id =%d AND a.user_id = b.id `, in.Id)) if position != nil && len(*position) > 0 { phone := (*position)[0]["phone"] entId := (*position)[0]["ent_id"] nameMap := IC.MainMysql.SelectBySql(fmt.Sprintf(`SELECT a.phone,IF(a.name = "我" AND b.role_id = 1 ,"%s",a.name) AS name,b.role_id FROM %s a LEFT JOIN entniche_user_role b on a.id = b.user_id where a.phone = %s and a.ent_id = %d `, util.UserRoleOne, util.ENTNICHE_USER, phone, entId)) if nameMap != nil && len(*nameMap) > 0 { name = fmt.Sprintf("%s(用户)", (*nameMap)[0]["name"]) } } case 3: //群 data := IC.BaseMysql.FindOne(util.SOCIALIZE_CHAT_GROUP, map[string]interface{}{"id": in.Id}, "name", "") if data != nil { name = fmt.Sprintf("%s(群)", quitl.InterfaceToStr((*data)["name"])) } } return name }