22 lines
545 B
Go
22 lines
545 B
Go
package mq
|
|
|
|
// 单聊
|
|
func SingleTalk(tag uint64, ch interface{}, msg []byte) {
|
|
//var data entities.SingTalkReq
|
|
//err := json.Unmarshal(msg, &data)
|
|
//utils.Log(nil, "msg", data)
|
|
//if err == nil {
|
|
// conn := netool.GetConnManagger().GetConnection(data.Msg.To)
|
|
// var sendOk = false
|
|
// if conn != nil && conn.IsActive() {
|
|
// if utils.WriteMsg(msgid.SINGLE_MSG, data, conn) {
|
|
// sendOk = true
|
|
// }
|
|
// }
|
|
// if !sendOk {
|
|
// common.PikaTool.Zadd(utils.GetRealKey(common2.USER_MSG)+data.Msg.To, data, time.Now().Unix())
|
|
// }
|
|
//}
|
|
|
|
}
|