|
|
@@ -172,8 +172,7 @@ func (m *MiniProgram) BindPhone() error {
|
|
|
if err := jy.Publish(public.Mgo_Log, nsqPath, nsq_topic, jy.Jyapp_phone_register, mgoUserId, jy.Jyapp_node1, nil); err != nil {
|
|
|
log.Println("nsq队列写入失败-->", err, jy.Jyapp_phone_register, mgoUserId)
|
|
|
}
|
|
|
- }
|
|
|
- if createRes == 2 {
|
|
|
+ } else if createRes == 2 {
|
|
|
if err := jy.Publish(public.Mgo_Log, nsqPath, nsq_topic, "task", mgoUserId, jy.Jyweb_node2, map[string]interface{}{
|
|
|
"code": 1007,
|
|
|
"types": "bindPhone",
|
