update

consume/init.go

@@ -17,7 +17,7 @@ func Init() {
 
 // 增加消费任务队列
 func initConsumes() {
-	jobs[consumeMd.UserRegisterConsumeForMyFansFunName] = UserRegisterConsumeForMyFans
+	//jobs[consumeMd.UserRegisterConsumeForMyFansFunName] = UserRegisterConsumeForMyFans
 	//jobs[consumeMd.UserRegisterConsumeForMyRecommenderFunName] = UserRegisterConsumeForMyRecommender
 	jobs[consumeMd.UserRegisterConsumeForOfficialFunName] = UserRegisterConsumeForOfficial
 }

consume/user_register_for_my_my_fans.go

@@ -103,7 +103,7 @@ func handleUserRegisterConsumeForMyFans(msgData []byte) error {
 		}
 
 		gimUserId, err := db2.UserInsert(db.DbIm, &model2.User{
-			PhoneNumber:        strconv.FormatInt(msg.Phone, 10),
+			PhoneNumber:        user.Phone,
 			Nickname:           user.Nickname,
 			AvatarUrl:          user.Avatar,
 			Sex:                user.Sex,

consume/user_register_for_my_my_recommender.go

@@ -102,9 +102,11 @@ func handleUserRegisterConsumeForMyRecommender(msgData []byte) error {
 		if err != nil {
 			return err
 		}
-
+		if user.Nickname == "将军" {
+			fmt.Println(user)
+		}
 		gimUserId, err := db2.UserInsert(db.DbIm, &model.User{
-			PhoneNumber:        strconv.FormatInt(msg.Phone, 10),
+			PhoneNumber:        user.Phone,
 			Nickname:           user.Nickname,
 			AvatarUrl:          user.Avatar,
 			Sex:                user.Sex,

consume/user_register_for_official_consume.go

@@ -104,7 +104,7 @@ func handleUserRegisterConsumeForOfficial(msgData []byte) error {
 			return nil
 		}
 		gimUserId, err := gim.UserInsert(db.DbIm, &imModel.User{
-			PhoneNumber:        strconv.FormatInt(msg.Phone, 10),
+			PhoneNumber:        user.Phone,
 			Nickname:           user.Nickname,
 			AvatarUrl:          user.Avatar,
 			Sex:                user.Sex,