kkc-go/router/TestRouter.go

package router

import (
	"demo/configs"
	"demo/data/dao"
	"demo/data/dao/manage"
	"demo/data/domain"
	"demo/share"
	"encoding/json"
	"fmt"
	"github.com/gin-gonic/gin"
	"github.com/spf13/cast"
	"net/http"
	"strconv"
)

func TestRouth(engine *gin.RouterGroup) {
	user := engine.Group("/test")
	{
		PushRouter(user, "POST", "/order/pay", OrderSubmit)
		PushRouter(user, "POST", "/test", DataTest)

		PushRouter(user, "GET", "/home", Home)
		PushRouter(user, "GET", "/topic", Topic)
		PushRouter(user, "GET", "/detail", Detail)
	}

}

func OrderSubmit(c *gin.Context) {
	id := GetUserIdByToken(c)
	if id == 0 {
		return
	}
	data := share.GetJsonAnyParam(c)
	orderId, _ := data("orderId")
	err := dao.OrderPaySuccess(cast.ToInt64(orderId), id)
	if err != nil {
		c.JSON(200, CreateResultError(401, err.Error()))
		return
	}
	c.JSON(200, CreateResult())
}

func DataTest(c *gin.Context) {
	body := make(map[string]interface{})
	c.ShouldBindJSON(&body)
	fmt.Println("router:", body)
	fmt.Println("router:", c.Request.Body)
	c.JSON(200, CreateResultData("test"))
}

func Home(c *gin.Context) {
	m := make(map[string]interface{})
	//获取登录信息
	id := GetUserId(c)
	if id != 0 {
		var userInfo = domain.User{}
		_, err := configs.Engine.Table("user").Where("id = ?", id).Get(&userInfo)
		if err != nil {
			c.JSON(200, CreateResultError(401, "用户信息查询失败"))
			return
		}
		userInfoMap := map[string]interface{}{
			"userInfo": userInfo,
		}
		u, err := json.Marshal(userInfoMap)
		if err != nil {
			c.JSON(200, CreateResultError(401, "用户查询失败"))
			return
		}
		json.Unmarshal(u, &m)
	}
	//首页宣传信息
	data, err := dao.GetAdviceData()
	if err != nil {
		c.JSON(200, CreateResultError(401, "advice查询失败"))
		return
	}
	marshal, err := json.Marshal(data)
	if err != nil {
		fmt.Println(err)
		c.JSON(200, CreateResultError(401, err.Error()))
		return
	}
	json.Unmarshal(marshal, &m)

	//首页主题信息
	list, err := dao.GetTopicList()
	if err != nil {
		c.JSON(200, CreateResultError(401, "主题列表查询失败"))
		return
	}
	m2 := map[string]interface{}{
		"list": list,
	}
	//结构体转map
	d2m, err := json.Marshal(m2)
	if err != nil {
		fmt.Println(err)
		c.JSON(200, CreateResultError(401, err.Error()))
		return
	}
	json.Unmarshal(d2m, &m)

	fmt.Println("data:", m)
	c.HTML(http.StatusOK, "index.html", m)
}

func Topic(c *gin.Context) {
	topicId := c.Query("topicId")
	m := make(map[string]interface{})
	//获取登录信息
	id := GetUserId(c)
	if id != 0 {
		var userInfo = domain.User{}
		_, err := configs.Engine.Table("user").Where("id = ?", id).Get(&userInfo)
		if err != nil {
			c.JSON(200, CreateResultError(401, "用户信息查询失败"))
			return
		}
		userInfoMap := map[string]interface{}{
			"userInfo": userInfo,
		}
		u, err := json.Marshal(userInfoMap)
		if err != nil {
			c.JSON(200, CreateResultError(401, "用户查询失败"))
			return
		}
		json.Unmarshal(u, &m)
	}
	list, err := dao.GetTopicPageDataListById(cast.ToInt64(topicId))
	if err != nil {
		c.JSON(200, CreateResultError(401, "主题列表查询失败"))
		return
	}
	dm, err := json.Marshal(list)
	if err != nil {
		fmt.Println(err)
		c.JSON(200, CreateResultError(401, "json转换失败"))
		return
	}
	json.Unmarshal(dm, &m)
	fmt.Println("data:", m)
	c.HTML(http.StatusOK, "topic.html", m)
}
func Detail(c *gin.Context) {
	skuId := c.Query("skuId")
	m := make(map[string]interface{})
	//获取登录信息
	id := GetUserId(c)
	if id != 0 {
		var userInfo = domain.User{}
		_, err := configs.Engine.Table("user").Where("id = ?", id).Get(&userInfo)
		if err != nil {
			c.JSON(200, CreateResultError(401, "用户信息查询失败"))
			return
		}
		userInfoMap := map[string]interface{}{
			"userInfo": userInfo,
		}
		u, err := json.Marshal(userInfoMap)
		if err != nil {
			c.JSON(200, CreateResultError(401, "用户查询失败"))
			return
		}
		json.Unmarshal(u, &m)
	}
	//标签
	tagList, err := manage.GetGoodsTagList(domain.GoodsTag{}, 1, 10000)
	if err != nil {
		c.JSON(200, CreateResultError(401, "文章标签查询失败"))
		return
	}
	tagMap := map[string]interface{}{
		"tags": tagList.List,
	}
	tagString, err := json.Marshal(tagMap)
	if err != nil {
		fmt.Println(err)
		c.JSON(200, CreateResultError(401, "json转换失败"))
		return
	}
	json.Unmarshal(tagString, &m)
	//文章内容
	vo, err := dao.SelectSkuInfoBySkuId(cast.ToInt64(skuId))
	if err != nil {
		c.JSON(200, CreateResultError(401, "文章查询失败"))
		return
	}
	dm, err := json.Marshal(vo)
	if err != nil {
		fmt.Println(err)
		c.JSON(200, CreateResultError(401, "json转换失败"))
		return
	}
	json.Unmarshal(dm, &m)

	fmt.Println("data:", m)
	c.HTML(http.StatusOK, "detail.html", m)
}

func GetUserId(c *gin.Context) int64 {
	header := c.GetHeader("auth-sign")
	if header == "" {
		return 0
	}
	claims, err := share.ParseToken(header)
	if err != nil {
		return 0
	}
	i, err := strconv.ParseInt(claims["iss"].(string), 10, 32)
	return i

}