撤回

src/jfw/modules/app/src/app/front/login.go

@@ -470,28 +470,26 @@ func (l *Login) Register() error {
 				}
 				if saveSuccess && saveid != "" {
 					addr := config.Sysconfig["nsq"].(string)
-					go func() {
-						if disWord != "" {
-							redisDis := redis.GetStr("other", "DIS_"+disWord[1:])
-							//邀请新用户 调用队列
-							if redisDisArr := strings.Split(redisDis, "##"); len(redisDisArr) > 1 {
-								fromUserId := redisDisArr[1]
-								err := jy.Publish(public.Mgo_Log, addr, jy.Jywx_subscribe_invite, fromUserId, jy.Jyapp_node1)
-								if err != nil {
-									log.Println("nsq队列写入失败-->", err, jy.Jywx_subscribe_invite, fromUserId)
-								}
-								err = jy.Publish(public.Mgo_Log, addr, jy.Jywx_subscribe_invited, saveid, jy.Jyapp_node1)
-								if err != nil {
-									log.Println("nsq队列写入失败-->", err, jy.Jywx_subscribe_invited, saveid)
-								}
+					if disWord != "" {
+						redisDis := redis.GetStr("other", "DIS_"+disWord[1:])
+						//邀请新用户 调用队列
+						if redisDisArr := strings.Split(redisDis, "##"); len(redisDisArr) > 1 {
+							fromUserId := redisDisArr[1]
+							err := jy.Publish(public.Mgo_Log, addr, jy.Jywx_subscribe_invite, fromUserId, jy.Jyapp_node1)
+							if err != nil {
+								log.Println("nsq队列写入失败-->", err, jy.Jywx_subscribe_invite, fromUserId)
 							}
-						} else {
-							err := jy.Publish(public.Mgo_Log, addr, jy.Jyapp_phone_register, saveid, jy.Jyapp_node1)
+							err = jy.Publish(public.Mgo_Log, addr, jy.Jywx_subscribe_invited, saveid, jy.Jyapp_node1)
 							if err != nil {
-								log.Println("nsq队列写入失败-->", err, jy.Jyapp_phone_register, saveid)
+								log.Println("nsq队列写入失败-->", err, jy.Jywx_subscribe_invited, saveid)
 							}
 						}
-					}()
+					} else {
+						err := jy.Publish(public.Mgo_Log, addr, jy.Jyapp_phone_register, saveid, jy.Jyapp_node1)
+						if err != nil {
+							log.Println("nsq队列写入失败-->", err, jy.Jyapp_phone_register, saveid)
+						}
+					}
 					l.DelSession("registerStep")
 					jy.ClearPhoneIdentSession(l.Session())
 					returnSign = afterLogin(data, l.Session(), rid, oid, phoneType, channel, deviceId, 1, true, l.ResponseWriter)