|
|
@@ -664,6 +664,7 @@ func (s *subscribePush) getDatasFromMysql(spqp *SubPushQueryParam, starttime, en
|
|
|
if spqp.NotReturnCount == 0 {
|
|
|
count = spqp.BaseServiceMysql.CountBySql(countSql)
|
|
|
}
|
|
|
+ log.Println("数据总数查询", count)
|
|
|
}
|
|
|
if isLimit {
|
|
|
findSql += fmt.Sprintf(" limit %d,%d", (spqp.PageNum-1)*size, size)
|
|
|
@@ -815,6 +816,7 @@ func (s *subscribePush) GetJyPushs(datas []map[string]interface{}) (pushCas []*P
|
|
|
|
|
|
// 查看全部列表缓存
|
|
|
func (s *subscribePush) PutAllCache(userId, userType string, datas *SubPush) {
|
|
|
+ log.Println("pushcache_2_a", s.allKey(userId, userType), datas, oneDay)
|
|
|
redis.Put("pushcache_2_a", s.allKey(userId, userType), datas, oneDay)
|
|
|
}
|
|
|
|
WH01243