|
|
@@ -10,7 +10,6 @@ import (
|
|
|
"app.yhyue.com/moapp/jybase/redis"
|
|
|
"bp.jydev.jianyu360.cn/BaseService/jyCodeService/rpc/codeservice/codeservice"
|
|
|
"context"
|
|
|
- "database/sql"
|
|
|
"encoding/json"
|
|
|
"fmt"
|
|
|
"github.com/zeromicro/go-zero/core/logx"
|
|
|
@@ -826,7 +825,7 @@ func (s *subscribePush) DefaultDatas(spqp *SubPushQueryParam) (hasNextPage bool,
|
|
|
// 保存推送表
|
|
|
func (s *subscribePush) listManager(spqp *SubPushQueryParam, list []map[string]interface{}, keyword []ViewKeyWord, ccount int) (resultList []*bxsubscribe.SubscribeInfo) {
|
|
|
t2 := time.Now()
|
|
|
- now := time.Now().Unix()
|
|
|
+ //now := time.Now().Unix()
|
|
|
var (
|
|
|
wg = &sync.WaitGroup{}
|
|
|
wc = make(chan bool, ccount)
|
|
|
@@ -839,7 +838,7 @@ func (s *subscribePush) listManager(spqp *SubPushQueryParam, list []map[string]i
|
|
|
wg.Done()
|
|
|
<-wc
|
|
|
}()
|
|
|
- redisKey := fmt.Sprintf("pushinfo_%s_%s", spqp.UserId, common.ObjToString(v["_id"]))
|
|
|
+ /*redisKey := fmt.Sprintf("pushinfo_%s_%s", spqp.UserId, common.ObjToString(v["_id"]))
|
|
|
title := strings.Replace(common.ObjToString(v["title"]), "\n", "", -1)
|
|
|
var pushInsert = []interface{}{}
|
|
|
infoid := common.InterfaceToStr(v["_id"])
|
|
|
@@ -879,7 +878,7 @@ func (s *subscribePush) listManager(spqp *SubPushQueryParam, list []map[string]i
|
|
|
return true
|
|
|
}
|
|
|
return false
|
|
|
- })
|
|
|
+ })*/
|
|
|
}(v)
|
|
|
}
|
|
|
wg.Wait()
|
WH01243