xiugai

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

@@ -470,26 +470,28 @@ func (l *Login) Register() error {
 				}
 				if saveSuccess && saveid != "" {
 					addr := config.Sysconfig["nsq"].(string)
-					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)
+					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)
+								}
 							}
-							err = jy.Publish(public.Mgo_Log, addr, jy.Jywx_subscribe_invited, saveid, jy.Jyapp_node1)
+						} else {
+							err := jy.Publish(public.Mgo_Log, addr, jy.Jyapp_phone_register, saveid, jy.Jyapp_node1)
 							if err != nil {
-								log.Println("nsq队列写入失败-->", err, jy.Jywx_subscribe_invited, saveid)
+								log.Println("nsq队列写入失败-->", err, jy.Jyapp_phone_register, 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)