|
@@ -9,6 +9,7 @@ import (
|
|
|
"bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXCore/rpc/util"
|
|
"bp.jydev.jianyu360.cn/BaseService/jyMicroservices/jyBXCore/rpc/util"
|
|
|
"context"
|
|
"context"
|
|
|
"fmt"
|
|
"fmt"
|
|
|
|
|
+ "strconv"
|
|
|
"strings"
|
|
"strings"
|
|
|
"time"
|
|
"time"
|
|
|
|
|
|
|
@@ -163,12 +164,13 @@ func (l *GetSearchListLogic) GetSearchList(in *bxcore.SearchReq) (*bxcore.Search
|
|
|
} else if in.Platform == "APP" || in.Platform == "H5" {
|
|
} else if in.Platform == "APP" || in.Platform == "H5" {
|
|
|
nsqNode = jy.Jyapp_node1
|
|
nsqNode = jy.Jyapp_node1
|
|
|
}
|
|
}
|
|
|
|
|
+ positionId, _ := strconv.ParseInt(in.PositionId, 10, 64)
|
|
|
log.Println(IC.MgoLog, IC.C.Nsq, IC.C.NsqTopic)
|
|
log.Println(IC.MgoLog, IC.C.Nsq, IC.C.NsqTopic)
|
|
|
err := jy.Publish(IC.MgoLog, IC.C.Nsq, IC.C.NsqTopic, "lottery_draw_task", in.UserId, nsqNode, map[string]interface{}{
|
|
err := jy.Publish(IC.MgoLog, IC.C.Nsq, IC.C.NsqTopic, "lottery_draw_task", in.UserId, nsqNode, map[string]interface{}{
|
|
|
"phone": in.Phone,
|
|
"phone": in.Phone,
|
|
|
"userId": in.UserId,
|
|
"userId": in.UserId,
|
|
|
"mgoUserId": in.MgoUserId,
|
|
"mgoUserId": in.MgoUserId,
|
|
|
- "positionId": in.PositionId,
|
|
|
|
|
|
|
+ "positionId": positionId,
|
|
|
"activeId": TaskActiveId,
|
|
"activeId": TaskActiveId,
|
|
|
"taskInfoId": TaskIdSearch,
|
|
"taskInfoId": TaskIdSearch,
|
|
|
"nickName": in.UserName,
|
|
"nickName": in.UserName,
|
