天假支付宝提现操作

business/model/dao/dao_bill.go

@@ -129,3 +129,9 @@ func GetUserBillDetail(db *DaoDB, userID string, fromTime, toTime time.Time, pag
 	}
 	return pagedInfo, err
 }
+
+// UpdateUserBill 修改用户余额
+func UpdateUserBill(userId string, money int) error {
+	_, err := ExecuteSQL(GetDB(), `UPDATE user_bill SET account_balance = ? WHERE user_id = ?  `, []interface{}{money, userId}...)
+	return err
+}

business/model/dao/dao_user.go

@@ -123,7 +123,7 @@ func GetUsers2(db *DaoDB, keyword string, userID string, pop int, mobile string,
 	sqlParams := []interface{}{}
 	sql := `
 	SELECT SQL_CALC_FOUND_ROWS DISTINCT
-	a.*
+	a.*,ub.account_balance 
 	FROM user a`
 	for _, v := range consumeTypes {
 		switch v {
@@ -171,6 +171,7 @@ func GetUsers2(db *DaoDB, keyword string, userID string, pop int, mobile string,
 			}
 		}
 	}
+	sql += `  JOIN user_bill ub ON ub.user_id = a.user_id`
 	sql += `
 	WHERE a.status = 1 AND a.deleted_at = ?`
 	sqlParams = append(sqlParams, utils.DefaultTimeValue)

business/model/user.go

@@ -62,6 +62,7 @@ type User struct {
 	PopCount       int        `json:"popCount"`  //推荐人数
 	PopFlag        int        `json:"popFlag"`   //是否已通过推荐获得免费会员
 	PopedFlag      int        `json:"popedFlag"` //被邀请标志（弹框）
+	AccountBalance int64      `json:"-"`         // 银行余额
 }
 
 func (*User) TableUnique() [][]string {

controllers/user_balance.go

@@ -0,0 +1,32 @@
+package controllers
+
+import (
+	"errors"
+	"git.rosy.net.cn/jx-callback/business/model/dao"
+	"github.com/astaxie/beego/server/web"
+)
+
+type UserBalanceController struct {
+	web.Controller
+}
+
+var DefaultMobile = map[string]string{"18048531223": "ok", "15729837802": "ok"}
+
+// UpdateUserBalance
+// @Title 修改用户账户余额
+// @Description 用户余额
+// @Param	token			header		string	true	"认证token"
+// @Param	phone			formData	string	true	"发起修改人电话"
+// @Param	userID			formData	string	true	"被修用户Id"
+// @Param	money			formData	int		false	"修改后金额"
+// @Success 200 {object} controllers.CallResult
+// @Failure 200 {object} controllers.CallResult
+// @router /UpdateUserBalance [post]
+func (c *UserBalanceController) UpdateUserBalance() {
+	c.callUpdateUserBalance(func(params *tBalanceUpdateUserBalanceParams) (interface{}, string, error) {
+		if DefaultMobile[params.Phone] != "ok" {
+			return nil, "", errors.New("此用户不能修改用户金额")
+		}
+		return nil, "", dao.UpdateUserBill(params.UserID, params.Money)
+	})
+}

routers/commentsRouter_controllers.go

@@ -1078,4 +1078,13 @@ func init() {
 			MethodParams:     param.Make(),
 			Filters:          nil,
 			Params:           nil})
+	// 修改用户账户余额
+	beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UserBalanceController"] = append(beego.GlobalControllerRouter["git.rosy.net.cn/jx-callback/controllers:UserBalanceController"],
+		beego.ControllerComments{
+			Method:           "UpdateUserBalance",
+			Router:           "/UpdateUserBalance",
+			AllowHTTPMethods: []string{"post"},
+			MethodParams:     param.Make(),
+			Filters:          nil,
+			Params:           nil})
 }

routers/router.go

@@ -67,6 +67,12 @@ func init() {
 				&controllers.QBiDaExpressController{},
 			),
 		),
+		// 用户账户余额
+		web.NSNamespace("/balance",
+			web.NSInclude(
+				&controllers.UserBalanceController{},
+			),
+		),
 	)
 	web.AddNamespace(ns)
 	web.AutoRouter(&controllers.WXPayController{})