activity_video.go 6.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198
  1. package cygx
  2. import (
  3. "github.com/beego/beego/v2/client/orm"
  4. "github.com/rdlucklib/rdluck_tools/paging"
  5. "time"
  6. )
  7. type CygxActivityVideo struct {
  8. VideoId int `orm:"column(video_id);pk"description:"视频id"`
  9. VideoName string `description:"视频名称"`
  10. ActivityId int ` description:"活动ID"`
  11. ModifyDate string `description:"更新时间"`
  12. VideoDuration string `description:"视频时长"`
  13. VideoCounts int `description:"播放量"`
  14. VideoUrl string `description:"视频地址"`
  15. BackgroundImg string `description:"封面图片"`
  16. ShareImg string `description:"分享图片"`
  17. CreateTime string `description:"创建时间"`
  18. }
  19. type CygxActivityVideoReq struct {
  20. VideoName string `description:"视频名称"`
  21. VideoDuration string `description:"视频时长"`
  22. VideoUrl string `description:"视频地址"`
  23. BackgroundImg string `description:"封面图片"`
  24. ShareImg string `description:"分享图片"`
  25. }
  26. // 活动详情
  27. type CygxActivityVideoListResp struct {
  28. ActivityId int `orm:"column(activity_id);pk";description:"活动ID 等于0新增活动,大于0修改活动"`
  29. ActivityTypeId int `description:"活动类型id"`
  30. ActivityName string `description:"活动名称"`
  31. ActivityTimeText string `description:"活动时间"`
  32. ActivityTypeName string `description:"活动类型名称"`
  33. ChartPermissionId int `description:"行业id"`
  34. ChartPermissionName string `description:"行业名称"`
  35. ChartPermissionNames string `description:"行业名称辅助字段,区分研选子分类"`
  36. Label string `description:"标签"`
  37. TemporaryLabel string `description:"临时标签"`
  38. VideoId int `orm:"column(video_id);pk"description:"视频id"`
  39. VideoName string `description:"视频名称"`
  40. VideoCounts int `description:"播放量"`
  41. VideoDuration string `description:"视频时长"`
  42. CommentNum int `description:"留言总数"`
  43. }
  44. type CygxActivityVideoListRep struct {
  45. Paging *paging.PagingItem `description:"分页数据"`
  46. List []*CygxActivityVideoListResp
  47. }
  48. // 添加
  49. func AddCygxActivityVideo(item *CygxActivityVideo) (newId int64, err error) {
  50. o := orm.NewOrmUsingDB("hz_cygx")
  51. newId, err = o.Insert(item)
  52. return
  53. }
  54. // 修改
  55. func UpdateCygxActivityVideo(item *CygxActivityVideo) (err error) {
  56. to := orm.NewOrmUsingDB("hz_cygx")
  57. updateParams := make(map[string]interface{})
  58. updateParams["VideoName"] = item.VideoName
  59. updateParams["VideoDuration"] = item.VideoDuration
  60. updateParams["VideoUrl"] = item.VideoUrl
  61. updateParams["BackgroundImg"] = item.BackgroundImg
  62. updateParams["ShareImg"] = item.ShareImg
  63. updateParams["ModifyDate"] = time.Now()
  64. ptrStructOrTableName := "cygx_activity_video"
  65. whereParam := map[string]interface{}{"activity_id": item.ActivityId}
  66. qs := to.QueryTable(ptrStructOrTableName)
  67. for expr, exprV := range whereParam {
  68. qs = qs.Filter(expr, exprV)
  69. }
  70. _, err = qs.Update(updateParams)
  71. return
  72. }
  73. // 获取数量
  74. func GetActivityVideoCount(condition string, pars []interface{}) (count int, err error) {
  75. sqlCount := ` SELECT
  76. COUNT( 1 ) AS count
  77. FROM
  78. cygx_activity AS art
  79. INNER JOIN cygx_activity_video AS v ON v.activity_id = art.activity_id
  80. WHERE
  81. 1 = 1 `
  82. if condition != "" {
  83. sqlCount += condition
  84. }
  85. o := orm.NewOrmUsingDB("hz_cygx")
  86. err = o.Raw(sqlCount, pars).QueryRow(&count)
  87. return
  88. }
  89. // 列表
  90. func GetActivityVideoListAll(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxActivityVideoListResp, err error) {
  91. o := orm.NewOrmUsingDB("hz_cygx")
  92. sql := `SELECT art.*,v.video_id,v.video_name,v.video_counts,video_duration,
  93. (SELECT COUNT(1) FROM cygx_article_comment AS h WHERE h.activity_id=art.activity_id AND h.industry_id = 0 AND h.activity_voice_id = 0) AS comment_num
  94. FROM cygx_activity as art INNER JOIN cygx_activity_video AS v ON v.activity_id = art.activity_id WHERE 1= 1 `
  95. if condition != "" {
  96. sql += condition
  97. }
  98. sql += ` LIMIT ?,?`
  99. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  100. return
  101. }
  102. // 历史记录
  103. func GetActivityVideoHistoryById(condition string, pars []interface{}) (item []*CygxMicroRoadshowVoiceHistory, err error) {
  104. o := orm.NewOrmUsingDB("hz_cygx")
  105. sql := ` SELECT
  106. h.*
  107. FROM
  108. cygx_activity_video_history AS h
  109. INNER JOIN cygx_activity_video AS v
  110. WHERE
  111. 1 = 1
  112. AND v.video_id = h.video_id `
  113. if condition != "" {
  114. sql += condition
  115. }
  116. sql += ` ORDER BY h.create_time DESC `
  117. _, err = o.Raw(sql, pars).QueryRows(&item)
  118. return
  119. }
  120. // 详情
  121. func GetCygxActivityVideoReqDetail(activityId int) (item *CygxActivityVideo, err error) {
  122. o := orm.NewOrmUsingDB("hz_cygx")
  123. sql := `SELECT * FROM cygx_activity_video WHERE activity_id= ? `
  124. err = o.Raw(sql, activityId).QueryRow(&item)
  125. return
  126. }
  127. // 列表
  128. func GetCygxActivityVideoReqDetailByVideoId(videoId int) (item *CygxActivityVideo, err error) {
  129. o := orm.NewOrmUsingDB("hz_cygx")
  130. sql := `SELECT * FROM cygx_activity_video WHERE video_id= ? `
  131. err = o.Raw(sql, videoId).QueryRow(&item)
  132. return
  133. }
  134. // 列表
  135. func GetActivityVideoList(condition string, pars []interface{}) (items []*CygxActivityVideoListResp, err error) {
  136. o := orm.NewOrmUsingDB("hz_cygx")
  137. sql := ` SELECT * FROM cygx_activity_video WHERE 1=1 `
  138. if condition != "" {
  139. sql += condition
  140. }
  141. _, err = o.Raw(sql, pars).QueryRows(&items)
  142. return
  143. }
  144. // MicroRoadShowDefaultImgList 微路演行业默认背景图列表
  145. type MicroRoadShowDefaultImgList struct {
  146. Audio []*MicroRoadShowDefaultImg `description:"音频"`
  147. Video []*MicroRoadShowDefaultImg `description:"视频"`
  148. }
  149. // MicroRoadShowDefaultImg 微路演行业默认背景图
  150. type MicroRoadShowDefaultImg struct {
  151. ChartPermissionId int `description:"行业ID"`
  152. ChartPermissionName string `description:"行业名称"`
  153. ImgUrl string `description:"背景图"`
  154. ShareImg string `description:"分享图"`
  155. }
  156. // MicroRoadShowDefaultImgList 微路演行业默认背景图列表
  157. type ActivityVideoDefaultImgList struct {
  158. Audio []*ActivityVideoDefaultImg `description:"音频"`
  159. Video []*ActivityVideoDefaultImg `description:"视频"`
  160. }
  161. type ActivityVideoDefaultImg struct {
  162. ChartPermissionId int `description:"行业ID"`
  163. List []*MicroRoadShowDefaultImg
  164. }
  165. type ActivityVideoDefaultImgListResp struct {
  166. List []*MicroRoadShowDefaultImg
  167. }
  168. type ActivityVideoDefaultImgResp struct {
  169. BackgroundImg string `description:"封面图片"`
  170. ShareImg string `description:"分享图"`
  171. }
  172. // 删除数据
  173. func DeleteCygxActivityVideo(activityId int) (err error) {
  174. o := orm.NewOrmUsingDB("hz_cygx")
  175. sql := ` DELETE FROM cygx_activity_video WHERE activity_id= ? `
  176. _, err = o.Raw(sql, activityId).Exec()
  177. return
  178. }