activity.go 6.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214
  1. package activity
  2. import (
  3. "fmt"
  4. "github.com/gin-gonic/gin"
  5. "hongze/hongze_yb/controller/response"
  6. "hongze/hongze_yb/models/tables/yb_activity"
  7. "hongze/hongze_yb/services/activity"
  8. "hongze/hongze_yb/services/user"
  9. "hongze/hongze_yb/utils"
  10. "io/ioutil"
  11. "os"
  12. "strconv"
  13. "time"
  14. )
  15. // GetPageList 活动列表
  16. // @Tags 活动模块
  17. // @Summary 活动列表
  18. // @Description 获取活动列表
  19. // @Security ApiKeyAuth
  20. // @Param Authorization header string true "Bearer 31a165baebe6dec616b1f8f3207b4273"
  21. // @Accept json
  22. // @Product json
  23. // @Param title query string false "活动类别/标题"
  24. // @Param active_state query int false "活动状态 1-本周预告 2-进行中 3-已结束"
  25. // @Param activity_type query int false "活动类型 1-线上会议 3-线下沙龙"
  26. // @Param page query int false "当前页码"
  27. // @Param limit query int false "每页数量"
  28. // @Success 200 {object} []yb_activity.ActivityItem
  29. // @failure 400 {string} string "活动获取失败"
  30. // @Router /activity/getPageList [get]
  31. func GetPageList(c *gin.Context) {
  32. page, _ := strconv.Atoi(c.Query("page"))
  33. limit, _ := strconv.Atoi(c.Query("limit"))
  34. condition, pars, order := _handleListQuery(c)
  35. userInfo := user.GetInfoByClaims(c)
  36. listData, err := activity.PageList(condition, pars, page, limit, order, userInfo)
  37. if err != nil {
  38. response.Fail("活动获取失败", c)
  39. return
  40. }
  41. response.OkData("获取成功", listData, c)
  42. }
  43. func _handleListQuery(c *gin.Context) (string, []interface{}, string) {
  44. condition := "is_delete = 0 AND publish_status = 1"
  45. pars := make([]interface{}, 0)
  46. // 活动类别/标题
  47. reqTitle := c.DefaultQuery("title", "")
  48. if reqTitle != "" {
  49. condition += ` AND (activity_type_name LIKE ? OR activity_name LIKE ?)`
  50. pars = append(pars, "%" + reqTitle + "%")
  51. pars = append(pars, "%" + reqTitle + "%")
  52. }
  53. order := ""
  54. reqState := c.DefaultQuery("active_state", "0")
  55. if reqState != "0" {
  56. state, _ := strconv.Atoi(reqState)
  57. nowTime := time.Now().Format(utils.FormatDateTime)
  58. switch state {
  59. case 1:
  60. condition += ` AND start_time > ?`
  61. pars = append(pars, nowTime)
  62. case 2:
  63. condition += ` AND start_time <= ?`
  64. pars = append(pars, nowTime)
  65. condition += ` AND end_time > ?`
  66. pars = append(pars, nowTime)
  67. case 3:
  68. condition += ` AND end_time < ?`
  69. pars = append(pars, nowTime)
  70. order = "start_time desc"
  71. }
  72. }
  73. reqType := c.DefaultQuery("activity_type", "0")
  74. if reqType != "0" {
  75. activityTypeId, _ := strconv.Atoi(reqType)
  76. condition += ` AND first_activity_type_id = ?`
  77. pars = append(pars, activityTypeId)
  78. }
  79. return condition, pars, order
  80. }
  81. // GetActivityDetail 获取活动详情
  82. // @Tags 活动模块
  83. // @Summary 获取活动详情
  84. // @Description 获取活动详情
  85. // @Security ApiKeyAuth
  86. // @Param Authorization header string true "Bearer 31a165baebe6dec616b1f8f3207b4273"
  87. // @Accept json
  88. // @Product json
  89. // @Param activity_id query int true "活动ID"
  90. // @Success 200 {object} yb_activity.ActivityDetail
  91. // @failure 400 {string} string "获取失败"
  92. // @Router /activity/getActivityDetail [get]
  93. func GetActivityDetail(c *gin.Context) {
  94. reqActivityId := c.DefaultQuery("activity_id", "0")
  95. if reqActivityId == "0" {
  96. response.Fail("参数异常", c)
  97. return
  98. }
  99. activityId, _ := strconv.Atoi(reqActivityId)
  100. userInfo := user.GetInfoByClaims(c)
  101. ok, permissionCheckInfo, err := activity.CheckActivityPermission(userInfo, activityId)
  102. if !ok {
  103. response.AuthError(permissionCheckInfo, "暂无权限", c)
  104. return
  105. }
  106. data, err := activity.GetActivityDetail(activityId, int(userInfo.UserID))
  107. if err != nil {
  108. response.Fail("未找到记录", c)
  109. return
  110. }
  111. response.OkData("获取成功", data, c)
  112. }
  113. // GetActivityVoices 获取活动录音
  114. // @Tags 活动模块
  115. // @Summary 获取活动录音
  116. // @Description 获取活动录音
  117. // @Security ApiKeyAuth
  118. // @Param Authorization header string true "Bearer 31a165baebe6dec616b1f8f3207b4273"
  119. // @Accept json
  120. // @Product json
  121. // @Param activity_id query int true "活动ID"
  122. // @Success 200 {object} []yb_activity_voice.YbActivityVoice
  123. // @failure 400 {string} string "获取失败"
  124. // @Router /activity/getActivityVoices [get]
  125. func GetActivityVoices(c *gin.Context) {
  126. reqActivityId := c.DefaultQuery("activity_id", "0")
  127. if reqActivityId == "0" {
  128. response.Fail("参数异常", c)
  129. return
  130. }
  131. activityId, _ := strconv.Atoi(reqActivityId)
  132. listData, err := activity.GetVoicesByActivity(activityId)
  133. if err != nil {
  134. response.Fail("录音获取失败", c)
  135. return
  136. }
  137. response.OkData("获取成功", listData, c)
  138. }
  139. // GetActivityShareImg 生成活动分享图片
  140. // @Tags 活动模块
  141. // @Summary 生成活动分享图片
  142. // @Description 生成活动分享图片
  143. // @Security ApiKeyAuth
  144. // @Param Authorization header string true "Bearer 31a165baebe6dec616b1f8f3207b4273"
  145. // @Accept json
  146. // @Product json
  147. // @Param activity_id query int true "活动ID"
  148. // @Success 200 {object} string "获取成功"
  149. // @failure 400 {string} string "获取失败"
  150. // @Router /activity/getActivityShareImg [get]
  151. func GetActivityShareImg(c *gin.Context) {
  152. reqActivityId := c.DefaultQuery("activity_id", "0")
  153. if reqActivityId == "0" {
  154. response.Fail("参数异常", c)
  155. return
  156. }
  157. activityId, _ := strconv.Atoi(reqActivityId)
  158. activityInfo, err := yb_activity.GetDetailById(activityId)
  159. if err != nil {
  160. if err == utils.ErrNoRow {
  161. response.Fail("获取活动信息失败", c)
  162. return
  163. }
  164. }
  165. // 获取原分享图
  166. originShareUrl := "static/img/reportdetail_share.png"
  167. fp, err := os.OpenFile(originShareUrl, os.O_CREATE|os.O_APPEND, 6)
  168. if err != nil {
  169. response.Fail("读取封面图失败", c)
  170. return
  171. }
  172. defer fp.Close()
  173. bytes, err := ioutil.ReadAll(fp)
  174. if err != nil {
  175. response.Fail("读取封面图失败", c)
  176. return
  177. }
  178. // 时间处理
  179. activityDate := activityInfo.StartTime.Format("2006-01-02")
  180. activityStart := activityInfo.StartTime.Format("15:04")
  181. activityEnd := activityInfo.EndTime.Format("15:04")
  182. activityWeek := activityInfo.StartTime.Weekday().String()
  183. week := utils.StrDateTimeToWeek(activityWeek)
  184. timeFormat := activityDate + " " + activityStart + "-" + activityEnd + " " + week
  185. // 生成新分享图
  186. var drawText []*utils.DrawTextInfo
  187. text := &utils.DrawTextInfo{
  188. Text: timeFormat,
  189. X: 60,
  190. Y: 250,
  191. }
  192. drawText = append(drawText, text)
  193. var colorRGBA = utils.FontRGBA{
  194. R: 223,
  195. G: 197,
  196. B: 143,
  197. A: 255,
  198. }
  199. picByte, err := utils.DrawStringOnImage(bytes, drawText, colorRGBA)
  200. if err != nil {
  201. response.Fail("生成新封面图失败", c)
  202. return
  203. }
  204. c.Header("Content-Type", "image/png")
  205. c.Header("Content-Disposition", fmt.Sprintf("inline; filename=\"%s\"", "图片地址"))
  206. c.Writer.WriteString(picByte.String())
  207. }