feat:p718 bxcore

jyBXCore/rpc/internal/logic/getsearchlistlogic.go

@@ -163,6 +163,7 @@ func (l *GetSearchListLogic) GetSearchList(in *bxcore.SearchReq) (*bxcore.Search
 				} else if in.Platform == "APP" || in.Platform == "H5" {
 					nsqNode = jy.Jyapp_node1
 				}
+				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{}{
 					"phone":      in.Phone,
 					"userId":     in.UserId,
@@ -174,6 +175,8 @@ func (l *GetSearchListLogic) GetSearchList(in *bxcore.SearchReq) (*bxcore.Search
 				})
 				if err != nil {
 					log.Println("nsq队列写入失败-->", err, "lottery_draw_task", TaskIdSearch, in.UserId)
+				} else {
+					log.Println("nsq队列写入成功-->", "lottery_draw_task", TaskIdSearch, in.UserId)
 				}
 			}
 		}