update table user

src/dao/user_wallet_dao.go

@@ -4,4 +4,5 @@ import "code.fnuoos.com/EggPlanet/egg_models.git/src/model"
 
 type UserWalletDao interface {
 	GetUserVirtualWallet(uid int64) (*model.UserWallet, error)
+	FindUserWalletByParams(params map[string]interface{}) (*[]model.UserWallet, error)
 }

src/implement/user_wallet_implement.go

@@ -3,6 +3,10 @@
 import (
 	"code.fnuoos.com/EggPlanet/egg_models.git/src/dao"
 	"code.fnuoos.com/EggPlanet/egg_models.git/src/model"
+	zhios_order_relate_utils "code.fnuoos.com/EggPlanet/egg_models.git/utils"
+	zhios_order_relate_logx "code.fnuoos.com/EggPlanet/egg_models.git/utils/logx"
+	"fmt"
+	"reflect"
 	"xorm.io/xorm"
 )
 
@@ -32,3 +36,20 @@ func (u UserWalletDb) GetUserVirtualWallet(uid int64) (*model.UserWallet, error)
 		return &userWallet, nil
 	}
 }
+
+func (u UserWalletDb) FindUserWalletByParams(params map[string]interface{}) (*[]model.UserWallet, error) {
+	var m []model.UserWallet
+	if reflect.TypeOf(params["value"]).Kind() == reflect.Slice {
+		//指定In查询
+		if err := u.Db.In(zhios_order_relate_utils.AnyToString(params["key"]), params["value"]).Find(&m); err != nil {
+			return nil, zhios_order_relate_logx.Warn(err)
+		}
+	} else {
+		var query = fmt.Sprintf("%s =?", params["key"])
+		err := u.Db.Where(query, params["value"]).Find(&m)
+		if err != nil {
+			return nil, zhios_order_relate_logx.Error(err)
+		}
+	}
+	return &m, nil
+}