package Api import ( "github.com/aarongao/tools" "github.com/gin-gonic/gin" "go.mongodb.org/mongo-driver/bson" "letu/DB" "letu/Lib/Auth" "letu/Lib/LeYouTu" "time" ) // @Title 标签列表 // @Description 标签 - 所有标签 // @Accept json // @Produce json // @Param ScenicId 5dfb03070a9ac17ac7a82054 string true "景区id" // @Success 200 {object} tools.ResponseSeccess "{"errcode":0,"result":[{"Type":"menu","Name":"服务设施"},{"Type":"normal","Name":"不错"},{"Type":"thrilling","Name":"刺激"},{"Type":"recommend","Name":"必玩"}]}" // @Failure 500 {object} tools.ResponseError "{"errcode":1,"errmsg":"错误原因"}" // @Router /AllTag? [get] func AllTag(c *gin.Context) { c.Header("Access-Control-Allow-Origin", c.Request.Header.Get("Origin")) c.Header("Access-Control-Allow-Credentials", "true") ScenicId, err := LeYouTu.GetScenicId(c) if err != nil { c.JSON(200, tools.ResponseError{ 1, "景区id不能为空", }) return } var Stags []DB.STag cur, err := DB.CTags.Find(tools.GetContext(), bson.M{"ScenicId": ScenicId}) defer cur.Close(tools.GetContext()) if err == nil { for cur.Next(tools.GetContext()) { var e DB.STag cur.Decode(&e) Stags = append(Stags,e) } } if Stags == nil { Stags = []DB.STag{} } c.JSON(200, tools.ResponseSeccess{ 0, Stags, }) } // @Title 标签列表 // @Description 标签 - 按照标签分组查看所有标签 // @Accept json // @Produce json // @Param ScenicId 5dfb03070a9ac17ac7a82054 string true "景区id" // @Success 200 {object} tools.ResponseSeccess "{"errcode":0,"result":[{"Tags":["儿童","成人","青少年"],"Type":"age"}]}" // @Failure 500 {object} tools.ResponseError "{"errcode":1,"errmsg":"错误原因"}" // @Router /AllTagGroup? [get] func AllTagGroup(c *gin.Context) { c.Header("Access-Control-Allow-Origin", c.Request.Header.Get("Origin")) c.Header("Access-Control-Allow-Credentials", "true") ScenicId, err := LeYouTu.GetScenicId(c) if err != nil { c.JSON(200, tools.ResponseError{ 1, "景区id不能为空", }) return } // cache cache := DB.Redis.Get("Tags_" + ScenicId) if cache != nil { c.JSON(200, tools.ResponseSeccess{ 0, cache, }) println("读取缓存Tags", cache) return } var Stags []DB.STag cur, err := DB.CTags.Find(tools.GetContext(), bson.M{"ScenicId": ScenicId}) defer cur.Close(tools.GetContext()) if err == nil { for cur.Next(tools.GetContext()) { var e DB.STag cur.Decode(&e) Stags = append(Stags,e) } } if Stags == nil { Stags = []DB.STag{} } Group := make(map[string][]string) // 去重 for _, v := range Stags { Group[v.Type] = append(Group[v.Type], v.Name) } // 转为数组 aGroup := []Tag{} for k, v := range Group { aGroup = append(aGroup, Tag{k, v}) } DB.Redis.Set("Tags_"+ScenicId, aGroup, time.Second*3600*24) c.JSON(200, tools.ResponseSeccess{ 0, aGroup, }) } // @Title 标签 // @Description 标签 - 增加标签 // @Accept json // @Produce json // @Param ScenicId 5dfb03070a9ac17ac7a82054 string true "景区id" // @Param Token wgergejfwe string true "用户token" // @Param TagName 广场 string true "标签名称" // @Param TagGroup location string true "群组名称" // @Success 200 {object} tools.ResponseSeccess "{"errcode":0,"result":"ok"}" // @Failure 500 {object} tools.ResponseError "{"errcode":1,"errmsg":"错误原因"}" // @Router /Tag/Create? [post] func CreateTag(c *gin.Context) { c.Header("Access-Control-Allow-Origin", c.Request.Header.Get("Origin")) c.Header("Access-Control-Allow-Credentials", "true") _user, _ := c.Get("UserInfo") user := _user.(*DB.SMember) err := Auth.CheckScenicAuth(c.PostForm("ScenicId"), user) if err != nil { c.JSON(200, tools.ResponseError{ 401, "没有权限", }) return } if c.PostForm("TagName") == "" { c.JSON(200, tools.ResponseError{ 1, "标签名称不能为空", }) return } if c.PostForm("TagGroup") == "" { c.JSON(200, tools.ResponseError{ 1, "群组名称不能为空", }) return } if c.PostForm("TagGroup") == "type" { c.JSON(200, tools.ResponseError{ 1, "此类型只能加不能加", }) return } DB.CTags.InsertOne(tools.GetContext(),DB.STag{ c.PostForm("ScenicId"), c.PostForm("TagGroup"), c.PostForm("TagName"), }) DB.Redis.Delete("Tags_" + c.PostForm("ScenicId")) println("清楚缓存Tags") c.JSON(200, tools.ResponseSeccess{ 0, "ok", }) } // @Title 标签 // @Description 标签 - 删除标签 // @Accept json // @Produce json // @Param ScenicId 5dfb03070a9ac17ac7a82054 string true "景区id" // @Param Token wgergejfwe string true "用户token" // @Param TagName 广场 string true "标签名称" // @Param TagGroup location string true "群组名称" // @Success 200 {object} tools.ResponseSeccess "{"errcode":0,"result":"ok"}" // @Failure 500 {object} tools.ResponseError "{"errcode":1,"errmsg":"错误原因"}" // @Router /Tag/Remove? [post] func RemoveTag(c *gin.Context) { c.Header("Access-Control-Allow-Origin", c.Request.Header.Get("Origin")) c.Header("Access-Control-Allow-Credentials", "true") _user, _ := c.Get("UserInfo") user := _user.(*DB.SMember) err := Auth.CheckScenicAuth(c.PostForm("ScenicId"), user) if err != nil { c.JSON(200, tools.ResponseError{ 401, "没有权限", }) return } if c.PostForm("TagName") == "" { c.JSON(200, tools.ResponseError{ 1, "标签名称不能为空", }) return } if c.PostForm("TagGroup") == "" { c.JSON(200, tools.ResponseError{ 1, "群组名称不能为空", }) return } if c.PostForm("TagGroup") == "type" { c.JSON(200, tools.ResponseError{ 1, "此类型只能加不能删", }) return } DB.CTags.DeleteOne(tools.GetContext(), bson.M{"ScenicId": c.PostForm("ScenicId"),"Name":c.PostForm("TagName"),"Type":c.PostForm("TagGroup")}) DB.Redis.Delete("Tags_" + c.PostForm("ScenicId")) println("清楚缓存Tags") c.JSON(200, tools.ResponseSeccess{ 0, "ok", }) } type Tag struct { Type string Tags []string }