|
@@ -176,7 +176,15 @@ func (l *GetSearchListLogic) GetSearchList(in *bxcore.SearchReq) (*bxcore.Search
|
|
if err != nil {
|
|
if err != nil {
|
|
log.Println("nsq队列写入失败-->", err, "lottery_draw_task", TaskIdSearch, in.UserId)
|
|
log.Println("nsq队列写入失败-->", err, "lottery_draw_task", TaskIdSearch, in.UserId)
|
|
} else {
|
|
} else {
|
|
- log.Println("nsq队列写入成功-->", "lottery_draw_task", TaskIdSearch, in.UserId)
|
|
|
|
|
|
+ log.Println("nsq队列写入成功-->", "lottery_draw_task", TaskIdSearch, in.UserId, map[string]interface{}{
|
|
|
|
+ "phone": in.Phone,
|
|
|
|
+ "userId": in.UserId,
|
|
|
|
+ "mgoUserId": in.MgoUserId,
|
|
|
|
+ "positionId": in.PositionId,
|
|
|
|
+ "activeId": TaskActiveId,
|
|
|
|
+ "taskInfoId": TaskIdSearch,
|
|
|
|
+ "nickName": in.UserName,
|
|
|
|
+ })
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|