hongze_yb/controller/activity/activity.go

package activity

import (
	"fmt"
	"github.com/gin-gonic/gin"
	"hongze/hongze_yb/controller/response"
	"hongze/hongze_yb/models/tables/yb_activity"
	"hongze/hongze_yb/services/activity"
	"hongze/hongze_yb/services/user"
	"hongze/hongze_yb/utils"
	"io/ioutil"
	"os"
	"strconv"
	"time"
)

// GetPageList 活动列表
// @Tags 活动模块
// @Summary  活动列表
// @Description 获取活动列表
// @Security ApiKeyAuth
// @Param Authorization	header string true "Bearer 31a165baebe6dec616b1f8f3207b4273"
// @Accept  json
// @Product json
// @Param title query string false "活动类别/标题"
// @Param active_state query int false "活动状态 1-本周预告 2-进行中 3-已结束"
// @Param activity_type query int false "活动类型 1-线上会议 3-线下沙龙"
// @Param has_permission query int false "是否查看仅有权限的 0-否 1-是"
// @Param page query int false "当前页码"
// @Param limit query int false "每页数量"
// @Success 200 {object} []yb_activity.ActivityItem
// @failure 400 {string} string "活动获取失败"
// @Router /activity/getPageList [get]
func GetPageList(c *gin.Context) {
	page, _ := strconv.Atoi(c.Query("page"))
	limit, _ := strconv.Atoi(c.Query("limit"))
	userInfo := user.GetInfoByClaims(c)
	condition, pars, order := _handleListQuery(c, userInfo)
	listData, err := activity.PageList(condition, pars, page, limit, order, userInfo)
	if err != nil {
		response.Fail("活动获取失败", c)
		return
	}
	response.OkData("获取成功", listData, c)
}

func _handleListQuery(c *gin.Context, userInfo user.UserInfo) (string, []interface{}, string) {
	condition := "is_delete = 0 AND publish_status = 1"
	pars := make([]interface{}, 0)
	// 活动类别/标题
	reqTitle := c.DefaultQuery("title", "")
	if reqTitle != "" {
		condition += ` AND (activity_type_name LIKE ? OR activity_name LIKE ?)`
		pars = append(pars, "%" + reqTitle + "%")
		pars = append(pars, "%" + reqTitle + "%")
	}
	order := ""
	reqState := c.DefaultQuery("active_state", "0")
	if reqState != "0" {
		state, _ := strconv.Atoi(reqState)
		nowTime := time.Now().Format(utils.FormatDateTime)
		switch state {
		case 1:
			condition += ` AND start_time > ?`
			pars = append(pars, nowTime)
		case 2:
			condition += ` AND start_time <= ?`
			pars = append(pars, nowTime)
			condition += ` AND end_time > ?`
			pars = append(pars, nowTime)
		case 3:
			condition += ` AND end_time < ?`
			pars = append(pars, nowTime)
			order = "start_time desc"
		}
	}
	reqType := c.DefaultQuery("activity_type", "0")
	if reqType != "0" {
		activityTypeId, _ := strconv.Atoi(reqType)
		condition += ` AND first_activity_type_id = ?`
		pars = append(pars, activityTypeId)
	}
	// 是否仅查看有权限的
	reqHasPermission := c.DefaultQuery("has_permission", "0")
	if reqHasPermission != "0" {
		activityIds, _ := activity.GetUserAuthActivityIds(userInfo)
		condition += ` AND activity_id IN (?)`
		pars = append(pars, activityIds)
	}

	return condition, pars, order
}

// GetActivityDetail 获取活动详情
// @Tags 活动模块
// @Summary  获取活动详情
// @Description 获取活动详情
// @Security ApiKeyAuth
// @Param Authorization	header string true "Bearer 31a165baebe6dec616b1f8f3207b4273"
// @Accept  json
// @Product json
// @Param activity_id query int true "活动ID"
// @Success 200 {object} yb_activity.ActivityDetail
// @failure 400 {string} string "获取失败"
// @Router /activity/getActivityDetail [get]
func GetActivityDetail(c *gin.Context) {
	reqActivityId := c.DefaultQuery("activity_id", "0")
	if reqActivityId == "0" {
		response.Fail("参数异常", c)
		return
	}
	activityId, _ := strconv.Atoi(reqActivityId)
	userInfo := user.GetInfoByClaims(c)
	ok, permissionCheckInfo, err := activity.CheckActivityPermission(userInfo, activityId)
	if !ok {
		response.AuthError(permissionCheckInfo, "暂无权限", c)
		return
	}
	data, err := activity.GetActivityDetail(activityId, int(userInfo.UserID))
	if err != nil {
		response.Fail("未找到记录", c)
		return
	}
	response.OkData("获取成功", data, c)
}

// GetActivityVoices 获取活动录音
// @Tags 活动模块
// @Summary  获取活动录音
// @Description 获取活动录音
// @Security ApiKeyAuth
// @Param Authorization	header string true "Bearer 31a165baebe6dec616b1f8f3207b4273"
// @Accept  json
// @Product json
// @Param activity_id query int true "活动ID"
// @Success 200 {object} []yb_activity_voice.YbActivityVoice
// @failure 400 {string} string "获取失败"
// @Router /activity/getActivityVoices [get]
func GetActivityVoices(c *gin.Context) {
	reqActivityId := c.DefaultQuery("activity_id", "0")
	if reqActivityId == "0" {
		response.Fail("参数异常", c)
		return
	}
	activityId, _ := strconv.Atoi(reqActivityId)
	listData, err := activity.GetVoicesByActivity(activityId)
	if err != nil {
		response.Fail("录音获取失败", c)
		return
	}
	response.OkData("获取成功", listData, c)
}

// GetActivityShareImg 生成活动分享图片
// @Tags 活动模块
// @Summary  生成活动分享图片
// @Description 生成活动分享图片
// @Security ApiKeyAuth
// @Param Authorization	header string true "Bearer 31a165baebe6dec616b1f8f3207b4273"
// @Accept  json
// @Product json
// @Param activity_id query int true "活动ID"
// @Success 200 {object} string "获取成功"
// @failure 400 {string} string "获取失败"
// @Router /activity/getActivityShareImg [get]
func GetActivityShareImg(c *gin.Context)  {
	reqActivityId := c.DefaultQuery("activity_id", "0")
	if reqActivityId == "0" {
		response.Fail("参数异常", c)
		return
	}
	activityId, _ := strconv.Atoi(reqActivityId)
	activityInfo, err := yb_activity.GetDetailById(activityId)
	if err != nil {
		if err == utils.ErrNoRow {
			response.Fail("获取活动信息失败", c)
			return
		}
	}
	// 获取原分享图
	originShareUrl := "static/img/reportdetail_share.png"
	fp, err := os.OpenFile(originShareUrl, os.O_CREATE|os.O_APPEND, 6)
	if err != nil {
		response.Fail("读取封面图失败", c)
		return
	}
	defer fp.Close()
	bytes, err := ioutil.ReadAll(fp)
	if err != nil {
		response.Fail("读取封面图失败", c)
		return
	}
	// 时间处理
	activityDate := activityInfo.StartTime.Format("2006-01-02")
	activityStart := activityInfo.StartTime.Format("15:04")
	activityEnd := activityInfo.EndTime.Format("15:04")
	activityWeek := activityInfo.StartTime.Weekday().String()
	week := utils.StrDateTimeToWeek(activityWeek)
	timeFormat := activityDate + " " + activityStart + "-" + activityEnd + " " + week
	// 生成新分享图
	var drawText []*utils.DrawTextInfo
	text := &utils.DrawTextInfo{
		Text: timeFormat,
		X: 60,
		Y: 250,
	}
	drawText = append(drawText, text)
	var colorRGBA = utils.FontRGBA{
		R: 223,
		G: 197,
		B: 143,
		A: 255,
	}
	picByte, err := utils.DrawStringOnImage(bytes, drawText, colorRGBA)
	if err != nil {
		response.Fail("生成新封面图失败", c)
		return
	}

	c.Header("Content-Type", "image/png")
	c.Header("Content-Disposition", fmt.Sprintf("inline; filename=\"%s\"", "图片地址"))
	c.Writer.WriteString(picByte.String())
}