|
@@ -37,6 +37,7 @@ const (
|
|
|
TaskActiveId = 16
|
|
|
TaskActivityCacheKey = "activity_day_task_%v_%v_%v"
|
|
|
TaskActivityCacheTimeout = 60 * 60 * 3
|
|
|
+ TaskIdSearch = 3
|
|
|
)
|
|
|
|
|
|
// GetSearchList 标讯搜索结果列表数据
|
|
@@ -151,7 +152,7 @@ func (l *GetSearchListLogic) GetSearchList(in *bxcore.SearchReq) (*bxcore.Search
|
|
|
}, nil
|
|
|
} else {
|
|
|
if in.UserId != "" {
|
|
|
- key := fmt.Sprintf(TaskActivityCacheKey, in.PositionId, TaskActiveId, 3)
|
|
|
+ key := fmt.Sprintf(TaskActivityCacheKey, in.PositionId, TaskActiveId, TaskIdSearch)
|
|
|
if exist, _ := redis.Exists("other", key); !exist {
|
|
|
redis.Put("other", key, 1, TaskActivityCacheTimeout)
|
|
|
nsqNode := jy.Jyweb_node2
|
|
@@ -166,10 +167,10 @@ func (l *GetSearchListLogic) GetSearchList(in *bxcore.SearchReq) (*bxcore.Search
|
|
|
"mgoUserId": in.MgoUserId,
|
|
|
"positionId": in.PositionId,
|
|
|
"activeId": TaskActiveId,
|
|
|
- "taskInfoId": 3,
|
|
|
+ "taskInfoId": TaskIdSearch,
|
|
|
})
|
|
|
if err != nil {
|
|
|
- log.Println("nsq队列写入失败-->", err, "lottery_draw_task", 3, in.UserId)
|
|
|
+ log.Println("nsq队列写入失败-->", err, "lottery_draw_task", TaskIdSearch, in.UserId)
|
|
|
}
|
|
|
}
|
|
|
}
|