|
|
@@ -10,7 +10,6 @@ import (
|
|
|
"log"
|
|
|
"strconv"
|
|
|
"strings"
|
|
|
- "sync"
|
|
|
"time"
|
|
|
|
|
|
"app.yhyue.com/moapp/jybase/common"
|
|
|
@@ -820,6 +819,7 @@ func (s *subscribePush) DefaultDatas(spqp *SubPushQueryParam) (hasNextPage bool,
|
|
|
// 保存推送表
|
|
|
func (s *subscribePush) listManager(spqp *SubPushQueryParam, list []map[string]interface{}, keyword []ViewKeyWord) (resultList []*bxsubscribe.SubscribeInfo) {
|
|
|
t2 := time.Now()
|
|
|
+ now := time.Now()
|
|
|
var pushInsert = []interface{}{}
|
|
|
for _, v := range list {
|
|
|
title := strings.Replace(common.ObjToString(v["title"]), "\n", "", -1)
|
|
|
@@ -858,7 +858,7 @@ func (s *subscribePush) listManager(spqp *SubPushQueryParam, list []map[string]i
|
|
|
_, id = spqp.BaseServiceMysql.InsertIgnoreBatch(aboutDbMsg[s.ModuleFlag].MysqlTable, subscribeInsertCollKey, pushInsert)
|
|
|
}
|
|
|
for i := 0; i < len(resultList); i++ {
|
|
|
- resultList[i].Index = id
|
|
|
+ resultList[i].CaIndex = id
|
|
|
id--
|
|
|
}
|
|
|
log.Println("数据处理耗时：", time.Since(t2))
|
WH01243