SwordFish_Interface_Service/manage/user/user.go

package user

import (
	"encoding/json"
	"github.com/gin-gonic/gin"
	"go.uber.org/zap"
	"io/ioutil"
	"log"
	"sfbase/global"
	sutils "sfbase/utils"
	"sfis/model"
	"sfis/model/response"
	"sfis/service"
	"sfis/utils"
	"time"
)

func DevUserManageRegister(router *gin.Engine) {
	userGroup := router.Group("/manage/user/")
	userGroup.Use()
	{
		userGroup.POST("/create", userCreate)
		userGroup.POST("/userProductChoose", userProductChoose)
		userGroup.POST("/userProductList", userProductList)
		userGroup.POST("/moneyRecharge", moneyRecharge)
		userGroup.POST("/productRecharge", productRecharge)
	}
}

// 创建用户
func userCreate(c *gin.Context) {
	var user model.User
	if err := c.ShouldBind(&user); err != nil {
		response.FailWithMessage("参数错误", c)
		return
	}
	global.Logger.Info("manage userCreate接口参数：", zap.Any("param", user))
	t := time.Now()
	appId := utils.GetAppID(t.Unix())
	key := sutils.GetComplexRandom(8, 3, 5)
	user.SecretKey = key
	user.AppID = appId
	// 创建用户
	userData, err := service.CreateUser(user)
	if err != nil {
		response.FailWithMessage(err.Error(), c)
	} else {
		response.OkWithData(userData, c)
	}
}

func userProductChoose(c *gin.Context) {
	bs, err := ioutil.ReadAll(c.Request.Body)
	if err != nil {
		panic(err)
		response.FailWithMessage("读取参数出错", c)
		return
	}
	var dataMap map[string]interface{}
	json.Unmarshal([]byte(bs), &dataMap)
	log.Println("获取前端参数：", dataMap)
	appId := sutils.ObjToString(dataMap["appId"])
	buyType := sutils.IntAll(dataMap["buyType"])
	products := dataMap["products"]
	productArr := make([]map[string]interface{}, 0)
	if _products, ok := products.([]interface{}); ok {
		productArr = sutils.ObjArrToMapArr(_products)
		log.Println(productArr)
	}
	//log.Println(len(productArr), appId)
	if appId != "" && len(productArr) > 0 {
		status, haveProductId, err := service.CreateUserProduct(appId, productArr, buyType)
		if status == 1 && err == nil {
			if haveProductId != "" {
				response.OkWithMessage("用户已购买过"+haveProductId+"产品，请去充值", c)
			} else {
				response.Ok(c)
			}
		} else {
			response.Fail(c)
		}
	} else {
		response.FailWithMessage("缺少参数", c)
	}
}

func userProductList(c *gin.Context) {
	appId := c.PostForm("appId")
	global.Logger.Info("manage userProductList接口参数：", zap.Any("appId", appId))
	service.UserProductList(appId, c)
}