package api import ( "net/http" "strconv" jwt "github.com/appleboy/gin-jwt/v2" "github.com/gin-gonic/gin" "go.uber.org/zap" "joylink.club/bj-rtsts-server/dto" "joylink.club/bj-rtsts-server/middleware" "joylink.club/bj-rtsts-server/service" ) func InitProjectRouter(api *gin.RouterGroup, authMiddleware *jwt.GinJWTMiddleware) { authed := api.Group("/v1/project").Use(authMiddleware.MiddlewareFunc()) authed.GET("/paging", pageQueryProject) authed.GET("/list", listQueryProject) authed.POST("", createProject) authed.GET("/:id", queryProjectInfo) authed.PUT("/:id", updateProjectInfo) authed.DELETE("/:id", deleteProject) } // 分页查询项目信息 // // @Summary 分页查询项目信息 // // @Security JwtAuth // // @Description 可以通过项目名称过滤,分页查询项目信息 // @Tags 项目信息Api // @Accept json // @Produce json // @Param PageProjectReqDto query dto.PageProjectReqDto true "项目查询条件带分页信息" // @Success 200 {object} dto.PageDto // @Failure 401 {object} dto.ErrorDto // @Failure 404 {object} dto.ErrorDto // @Failure 500 {object} dto.ErrorDto // @Router /api/v1/Project/paging [get] func pageQueryProject(c *gin.Context) { req := dto.PageProjectReqDto{} if err := c.ShouldBind(&req); err != nil { zap.S().Warn("分页查询参数绑定错误,使用默认参数", err) req.Default() } zap.S().Debug("分页查项目参数", req) page, err := service.PageProjectQuery(&req) if err != nil { c.JSON(http.StatusInternalServerError, err.Error()) return } c.JSON(http.StatusOK, page) } // 查询项目信息列表 // // @Summary 查询项目信息列表 // // @Security JwtAuth // // @Description 可以通过项目名称过滤,查询项目信息列表 // @Tags 项目信息Api // @Accept json // @Produce json // @Param ProjectReqDto query dto.ProjectReqDto true "项目查询条件" // @Success 200 {object} dto.PageDto // @Failure 401 {object} dto.ErrorDto // @Failure 404 {object} dto.ErrorDto // @Failure 500 {object} dto.ErrorDto // @Router /api/v1/Project/list [get] func listQueryProject(c *gin.Context) { req := dto.ProjectReqDto{} if err := c.ShouldBind(&req); err != nil { zap.S().Warn("查询参数绑定错误,使用默认参数", err) } zap.S().Debug("查项目参数", req) page, err := service.ListProjectQuery(&req) if err != nil { c.JSON(http.StatusInternalServerError, err.Error()) return } c.JSON(http.StatusOK, page) } // 创建项目信息 // // @Summary 创建项目信息 // // @Security JwtAuth // // @Description 创建项目数据 // @Tags 项目信息Api // @Accept json // @Produce json // @Param ProjectDto query dto.ProjectDto true "创建的项目信息" // @Success 200 {object} nil // @Failure 401 {object} dto.ErrorDto // @Failure 404 {object} dto.ErrorDto // @Failure 500 {object} dto.ErrorDto // @Router /api/v1/Project [post] func createProject(c *gin.Context) { req := dto.ProjectDto{} if err := c.ShouldBind(&req); err != nil { c.JSON(http.StatusBadRequest, "传入参数错误") return } zap.S().Debug("保存数据", req) data, err := service.CreateProject(&req) if err != nil { c.JSON(http.StatusInternalServerError, err.Error()) return } c.JSON(http.StatusOK, data) } // 查询项目信息 // // @Summary 查询项目信息 // // @Security JwtAuth // // @Description 查询项目信息 // @Tags 项目信息Api // @Accept json // @Produce json // @Param id path int true "项目ID" // @Success 200 {object} model.Project // @Failure 401 {object} dto.ErrorDto // @Failure 404 {object} dto.ErrorDto // @Failure 500 {object} dto.ErrorDto // @Router /api/v1/Project/{id} [get] func queryProjectInfo(c *gin.Context) { id, exist := c.Params.Get("id") if !exist { c.JSON(http.StatusBadRequest, "必要参数id不存在") return } zap.S().Debug("传入参数id为" + id) int64Id, _ := strconv.ParseInt(id, 10, 64) c.JSON(http.StatusOK, service.QueryProject(int32(int64Id))) } // 修改项目信息 // // @Summary 修改项目信息 // // @Security JwtAuth // // @Description 修改项目信息 // @Tags 项目信息Api // @Accept json // @Produce json // @Param id path int true "项目信息ID" // @Param ProjectDto query dto.ProjectDto true "修改的项目信息" // @Success 200 {object} nil // @Failure 401 {object} dto.ErrorDto // @Failure 404 {object} dto.ErrorDto // @Failure 500 {object} dto.ErrorDto // @Router /api/v1/Project/{id} [put] func updateProjectInfo(c *gin.Context) { id, exist := c.Params.Get("id") if !exist { c.JSON(http.StatusBadRequest, "必要参数id不存在") return } zap.S().Debug("传入参数id为" + id) req := dto.ProjectDto{} if err := c.ShouldBind(&req); err != nil { c.JSON(http.StatusBadRequest, "保存参数出错") return } int64Id, _ := strconv.ParseInt(id, 10, 64) result := service.UpdateProject(int32(int64Id), &req) if !result { c.JSON(http.StatusInternalServerError, "保存参数出错") return } c.JSON(http.StatusOK, result) } // 删除项目信息 // // @Summary 删除项目信息 // // @Security JwtAuth // // @Description 删除项目信息 // @Tags 项目信息Api // @Accept json // @Produce json // @Param id path int true "项目信息ID" // @Success 200 {object} nil // @Failure 401 {object} dto.ErrorDto // @Failure 404 {object} dto.ErrorDto // @Failure 500 {object} dto.ErrorDto // @Router /api/v1/Project/{id} [delete] func deleteProject(c *gin.Context) { user, _ := c.Get(middleware.IdentityKey) zap.S().Debug("id删除草稿的图形数据", user) idStr := c.Param("id") id, err := strconv.Atoi(idStr) if err != nil { c.JSON(http.StatusBadRequest, "id参数解析错误") return } zap.S().Debug("id查询草稿的图形数据", id) service.DeleteProjectById(id) c.JSON(http.StatusOK, true) }