升级

rule/user_upgrade.go

@@ -11,20 +11,20 @@ import (
 	"xorm.io/xorm"
 )
 
-func UserUpgradeInsert(uid, level int) error {
-	userDb := implement.NewUserDb(db.Db)
+func UserUpgradeInsert(eg *xorm.Engine, uid, level int) error {
+	userDb := implement.NewUserDb(eg)
 	user, _ := userDb.GetUser(int64(uid))
 	if level == user.Level {
 		return errors.New("等级相同")
 	}
-	task, err := UserUpgradeTask(db.Db, int(user.Id), level)
+	task, err := UserUpgradeTask(eg, int(user.Id), level)
 	if err != nil {
 		return err
 	}
 	//升级
 	oldLevel := user.Level
 	user.Level = level
-	_, err = db.Db.Where("id=?", user.Id).Cols("level").Update(user)
+	_, err = eg.Where("id=?", user.Id).Cols("level").Update(user)
 	if err != nil {
 		return err
 	}
@@ -35,7 +35,7 @@ func UserUpgradeInsert(uid, level int) error {
 		CreateTime: time.Now(),
 		Task:       utils.SerializeStr(task),
 	}
-	db.Db.Insert(&tmp)
+	eg.Insert(&tmp)
 	return nil
 
 }