|
@@ -738,9 +738,9 @@ func (s *subscribePush) DefaultDatas(spqp *SubPushQueryParam) (hasNextPage bool,
|
|
|
now := time.Now()
|
|
now := time.Now()
|
|
|
for _, v := range *list {
|
|
for _, v := range *list {
|
|
|
redisKey := fmt.Sprintf("pushinfo_%s_%s", spqp.UserId, common.ObjToString(v["_id"]))
|
|
redisKey := fmt.Sprintf("pushinfo_%s_%s", spqp.UserId, common.ObjToString(v["_id"]))
|
|
|
- if isExists, _ := redis.Exists("pushcache_2_a", redisKey); isExists {
|
|
|
|
|
- continue
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ //if isExists, _ := redis.Exists("pushcache_2_a", redisKey); isExists {
|
|
|
|
|
+ // continue
|
|
|
|
|
+ //}
|
|
|
title := strings.Replace(common.ObjToString(v["title"]), "\n", "", -1)
|
|
title := strings.Replace(common.ObjToString(v["title"]), "\n", "", -1)
|
|
|
var myInsert = make(map[string]interface{})
|
|
var myInsert = make(map[string]interface{})
|
|
|
myInsert["userid"] = spqp.UserId
|
|
myInsert["userid"] = spqp.UserId
|
