1
This commit is contained in:
@@ -224,6 +224,8 @@ func SetMessageDetail(req *JXMsg, vendorID int, elmAppID string) error {
|
|||||||
|
|
||||||
data, _ := json.Marshal(req)
|
data, _ := json.Marshal(req)
|
||||||
err := rdb.RPush(msgID, string(data))
|
err := rdb.RPush(msgID, string(data))
|
||||||
|
globals.SugarLogger.Debugf("im rdb =%v", rdb)
|
||||||
|
globals.SugarLogger.Debugf("im SetUserList err=%v", err)
|
||||||
ok, err := rdb.ExpireResult(msgID, ExpireTimeDay)
|
ok, err := rdb.ExpireResult(msgID, ExpireTimeDay)
|
||||||
if err != nil || !ok {
|
if err != nil || !ok {
|
||||||
return err
|
return err
|
||||||
@@ -247,6 +249,7 @@ func SetUserList(jxMsg *JXMsg, userList *UserMessageList, vendorID int, elmAppID
|
|||||||
//存储当前数据
|
//存储当前数据
|
||||||
data, _ := json.Marshal(userList)
|
data, _ := json.Marshal(userList)
|
||||||
err = rdb.RPush(msgID, string(data))
|
err = rdb.RPush(msgID, string(data))
|
||||||
|
globals.SugarLogger.Debugf("im SetUserList err=%v", err)
|
||||||
|
|
||||||
ok, err := rdb.ExpireResult(msgID, ExpireTimeDay)
|
ok, err := rdb.ExpireResult(msgID, ExpireTimeDay)
|
||||||
if err != nil || !ok {
|
if err != nil || !ok {
|
||||||
|
|||||||
@@ -63,7 +63,7 @@ func (c *IMController) StartWebSocket() {
|
|||||||
func (c *IMController) GetIMUserList() {
|
func (c *IMController) GetIMUserList() {
|
||||||
c.callGetIMUserList(func(params *tImGetIMUserListParams) (retVal interface{}, errCode string, err error) {
|
c.callGetIMUserList(func(params *tImGetIMUserListParams) (retVal interface{}, errCode string, err error) {
|
||||||
var relInfo []im.RelInfo
|
var relInfo []im.RelInfo
|
||||||
if err = json.Unmarshal([]byte(params.PayLoad), &relInfo); err != nil {
|
if err = json.Unmarshal([]byte(params.PayLoad), &relInfo); err == nil {
|
||||||
retVal, err = im.GetImUserList(relInfo)
|
retVal, err = im.GetImUserList(relInfo)
|
||||||
}
|
}
|
||||||
return retVal, "", err
|
return retVal, "", err
|
||||||
|
|||||||
Reference in New Issue
Block a user