MTP20_IF/controllers/common/news.go

package common

import (
	"mtp2_if/global/app"
	"mtp2_if/global/e"
	"mtp2_if/logger"
	"mtp2_if/models"
	"net/http"
	"strings"

	"github.com/gin-gonic/gin"
)

// QueryNewTitles 取资讯标题列表
// @Summary 取资讯标题列表
// @Produce json
// @Param   columnid query    int false "所属栏目"
// @Param   page     query    int false "页码"
// @Param   pagesize query    int false "每页条数"
// @Success 200      {object} models.QueryNewTitlesRsp
// @Failure 500   {object} app.Response
// @Router  /Common/QueryNewTitles [get]
// @Tags    通用服务
func QueryNewTitles(c *gin.Context) {
	appG := app.Gin{C: c}

	// 获取请求参数
	var req models.QueryNewTitlesReq
	if err := appG.C.ShouldBindQuery(&req); err != nil {
		logger.GetLogger().Errorf("QueryErrorInfos failed: %s", err.Error())
		appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil)
		return
	}

	rsp, totel, err := models.GetNewTitles(req)
	if err != nil {
		// 查询失败
		logger.GetLogger().Errorf("QueryErrorInfos failed: %s", err.Error())
		appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil)
		return
	}

	// 查询成功
	appG.ResponseByPage(http.StatusOK, e.SUCCESS, rsp, app.PageInfo{Page: req.Page, PageSize: req.PageSize, Total: int(totel)})
}

// QueryNewContentsReq 获取资讯内容请求参数
type QueryNewContentsReq struct {
	IDS string `form:"ids"` // 资讯ID列表，格式 1,2,3
}

// QueryNewContents 获取资讯内容
// @Summary 获取资讯内容
// @Produce json
// @Param   ids query    string false "资讯ID列表，格式 1,2,3"
// @Success 200 {object} models.QueryNewContentsRsp
// @Failure 500 {object} app.Response
// @Router  /Common/QueryNewContents [get]
// @Tags    通用服务
func QueryNewContents(c *gin.Context) {
	appG := app.Gin{C: c}

	// 获取请求参数
	var req QueryNewContentsReq
	if err := appG.C.ShouldBindQuery(&req); err != nil {
		logger.GetLogger().Errorf("QueryErrorInfos failed: %s", err.Error())
		appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil)
		return
	}

	ids := make([]string, 0)
	if req.IDS != "" {
		ids = strings.Split(req.IDS, ",")
	}
	rsp, err := models.GetNewContents(ids)
	if err != nil {
		// 查询失败
		logger.GetLogger().Errorf("QueryErrorInfos failed: %s", err.Error())
		appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil)
		return
	}

	// 查询成功
	appG.Response(http.StatusOK, e.SUCCESS, rsp)
}

type GetJ10NewsReq struct {
	Limit int `form:"limit"` // 获取最新limit条内容
}

// GetJ10News 获取金10资讯内容
// @Summary 获取金10资讯内容
// @Produce json
// @Param   limit query    int false "获取最新limit条内容"
// @Success 200   {array}  models.GetJ10NewsRsp
// @Failure 500      {object} app.Response
// @Router  /Common/GetJ10News [get]
// @Tags    通用服务
func GetJ10News(c *gin.Context) {
	appG := app.Gin{C: c}

	// 获取请求参数
	var req GetJ10NewsReq
	if err := appG.C.ShouldBindQuery(&req); err != nil {
		logger.GetLogger().Errorf("GetJ10News failed: %s", err.Error())
		appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil)
		return
	}

	rsp, err := models.GetJ10News(req.Limit)
	if err != nil {
		// 查询失败
		logger.GetLogger().Errorf("GetJ10News failed: %s", err.Error())
		appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil)
		return
	}

	// 查询成功
	appG.Response(http.StatusOK, e.SUCCESS, rsp)
}