This commit is contained in:
苏尹岚
2020-12-08 11:22:35 +08:00
parent e1aa2ec029
commit e6e3afcca7

View File

@@ -666,6 +666,14 @@ func UpdateUser(ctx *jxcontext.Context, payload map[string]interface{}) (err err
dao.Commit(db)
}
if payload["popUser"] != nil {
// InvestMemberAndUpdate := func(user *model.User) (err error) {
// if _, err = InvestMember(ctx, 1, user.UserID, true); err == nil {
// }
// user.PopFlag = model.YES
// _, err = dao.UpdateEntity(db, user, "PopFlag")
// return err
// }
user2, err2 := dao.GetUserByID(db, "user_id", payload["popUser"].(string))
err = err2
if user2 != nil {
@@ -684,7 +692,7 @@ func UpdateUser(ctx *jxcontext.Context, payload map[string]interface{}) (err err
}
} else {
//邀请过4人直接开通一个月会员并创建群组
if user2.PopCount%1 == 0 && user2.PopFlag == model.NO {
if user2.PopCount%4 == 0 && user2.PopFlag == model.NO {
_, err = InvestMember(ctx, 1, user2.UserID, true)
user2.PopFlag = model.YES
dao.UpdateEntity(db, user2, "PopFlag")