1
This commit is contained in:
@@ -221,10 +221,12 @@ func PushMsgByCid(vendorStoreID string, vendorID int) error {
|
||||
func SetMessageDetail(req *JXMsg, vendorID int, elmAppID string) error {
|
||||
//生成京西消息ID detail
|
||||
msgID := GenMsgDetailID(req, vendorID, elmAppID)
|
||||
|
||||
err := rdb.Set("test", "可以插入数据sjdfoiqaj", ExpireTimeDay)
|
||||
if err != nil {
|
||||
globals.SugarLogger.Debugf("测试插入err:%v", err)
|
||||
}
|
||||
data, _ := json.Marshal(req)
|
||||
err := rdb.RPush(msgID, string(data))
|
||||
globals.SugarLogger.Debugf("im rdb =%v", utils.Format4Output(rdb, false))
|
||||
err = rdb.RPush(msgID, string(data))
|
||||
globals.SugarLogger.Debugf("im SetUserList err=%v", err)
|
||||
ok, err := rdb.ExpireResult(msgID, ExpireTimeDay)
|
||||
if err != nil || !ok {
|
||||
@@ -315,6 +317,7 @@ func GetImUserList(req []RelInfo) (retVal []interface{}, err error) {
|
||||
if len(req) == 0 {
|
||||
return nil, errors.New("msgID不允许为空")
|
||||
}
|
||||
fmt.Printf("测试测试%s", rdb.Get("test"))
|
||||
var keys []string
|
||||
for _, i := range req {
|
||||
key := i.AppID + ":" + i.VendorStoreID + ":" + i.VendorID
|
||||
|
||||
Reference in New Issue
Block a user