180 lines
5.0 KiB
Go
180 lines
5.0 KiB
Go
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 InitTrainModelRouter(api *gin.RouterGroup, authMiddleware *jwt.GinJWTMiddleware) {
|
|
authed := api.Group("/v1/trainModel").Use(authMiddleware.MiddlewareFunc())
|
|
authed.GET("/paging", pageQueryTrainModel)
|
|
authed.POST("", createTrainModel)
|
|
authed.GET("/:id", queryTrainModel)
|
|
authed.PUT("/:id", updateTrainModel)
|
|
authed.DELETE("/:id", deleteTrainModel)
|
|
}
|
|
|
|
// 分页查询列车型号列表
|
|
//
|
|
// @Summary 分页查询列车型号信息列表
|
|
//
|
|
// @Security JwtAuth
|
|
//
|
|
// @Description 可以通过列车型号名称过滤，分页查询列车型号信息列表
|
|
// @Tags 列车型号Api
|
|
// @Accept json
|
|
// @Produce json
|
|
// @Param pageTrainModelReqDto query dto.PageTrainModelReqDto true "列车型号查询条件带分页信息"
|
|
// @Success 200 {object} dto.PageDto
|
|
// @Failure 401 {object} dto.ErrorDto
|
|
// @Failure 404 {object} dto.ErrorDto
|
|
// @Failure 500 {object} dto.ErrorDto
|
|
// @Router /api/v1/trainModel/paging [get]
|
|
func pageQueryTrainModel(c *gin.Context) {
|
|
user, _ := c.Get(middleware.IdentityKey)
|
|
zap.S().Debug("分页查询列车组次", user)
|
|
req := dto.PageTrainModelReqDto{}
|
|
if err := c.ShouldBind(&req); err != nil {
|
|
zap.S().Warn("分页查询参数绑定错误，使用默认参数", err)
|
|
req.Default()
|
|
}
|
|
zap.S().Debug("分页查列车组次参数", req)
|
|
page, err := service.PageTrainModelQuery(&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 trainModelDto query dto.TrainModelDto true "创建的列车型号信息"
|
|
// @Success 200 {object} nil
|
|
// @Failure 401 {object} dto.ErrorDto
|
|
// @Failure 404 {object} dto.ErrorDto
|
|
// @Failure 500 {object} dto.ErrorDto
|
|
// @Router /api/v1/trainModel [post]
|
|
func createTrainModel(c *gin.Context) {
|
|
req := dto.TrainModelDto{}
|
|
if err := c.ShouldBind(&req); err != nil {
|
|
c.JSON(http.StatusBadRequest, "传入参数错误")
|
|
return
|
|
}
|
|
zap.S().Debug("保存数据", req)
|
|
data, err := service.CreateTrainModel(&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.TrainModel
|
|
// @Failure 401 {object} dto.ErrorDto
|
|
// @Failure 404 {object} dto.ErrorDto
|
|
// @Failure 500 {object} dto.ErrorDto
|
|
// @Router /api/v1/trainModel/:id [get]
|
|
func queryTrainModel(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.QueryTrainModel(int32(int64Id)))
|
|
}
|
|
|
|
// 修改列车型号信息
|
|
//
|
|
// @Summary 修改列车型号信息
|
|
//
|
|
// @Security JwtAuth
|
|
//
|
|
// @Description 修改列车型号信息
|
|
// @Tags 列车型号Api
|
|
// @Accept json
|
|
// @Produce json
|
|
// @Param id path int true "列车型号ID"
|
|
// @Param trainModelDto query dto.TrainModelDto true "修改的列车型号信息"
|
|
// @Success 200 {object} nil
|
|
// @Failure 401 {object} dto.ErrorDto
|
|
// @Failure 404 {object} dto.ErrorDto
|
|
// @Failure 500 {object} dto.ErrorDto
|
|
// @Router /api/v1/trainModel/:id [put]
|
|
func updateTrainModel(c *gin.Context) {
|
|
id, exist := c.Params.Get("id")
|
|
if !exist {
|
|
c.JSON(http.StatusBadRequest, "必要参数id不存在")
|
|
return
|
|
}
|
|
zap.S().Debug("传入参数id为" + id)
|
|
req := dto.TrainModelDto{}
|
|
if err := c.ShouldBind(&req); err != nil {
|
|
c.JSON(http.StatusBadRequest, "保存参数出错")
|
|
return
|
|
}
|
|
int64Id, _ := strconv.ParseInt(id, 10, 64)
|
|
result := service.UpdateTrainModel(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/trainModel/:id [delete]
|
|
func deleteTrainModel(c *gin.Context) {
|
|
idStr := c.Param("id")
|
|
id, err := strconv.Atoi(idStr)
|
|
if err != nil {
|
|
c.JSON(http.StatusBadRequest, "id参数解析错误")
|
|
return
|
|
}
|
|
zap.S().Debug("id查询列车型号的图形数据", id)
|
|
service.DeleteTrainModelById(id)
|
|
c.JSON(http.StatusOK, true)
|
|
}
|