activity_video.go 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124
  1. package cygx
  2. import (
  3. "github.com/beego/beego/v2/client/orm"
  4. "github.com/rdlucklib/rdluck_tools/paging"
  5. )
  6. type CygxActivityVideo struct {
  7. VideoId int `orm:"column(video_id);pk"description:"视频id"`
  8. VideoName string `description:"视频名称"`
  9. ActivityId int ` description:"活动ID"`
  10. ModifyDate string `description:"更新时间"`
  11. VideoDuration string `description:"视频时长"`
  12. VideoCounts int `description:"播放量"`
  13. VideoUrl string `description:"视频地址"`
  14. CreateTime string `description:"创建时间"`
  15. }
  16. type CygxActivityVideoReq struct {
  17. VideoName string `description:"视频名称"`
  18. VideoDuration string `description:"视频时长"`
  19. VideoUrl string `description:"视频地址"`
  20. }
  21. // 活动详情
  22. type CygxActivityVideoListResp struct {
  23. ActivityId int `orm:"column(activity_id);pk";description:"活动ID 等于0新增活动,大于0修改活动"`
  24. ActivityTypeId int `description:"活动类型id"`
  25. ActivityName string `description:"活动名称"`
  26. ActivityTimeText string `description:"活动时间"`
  27. ActivityTypeName string `description:"活动类型名称"`
  28. ChartPermissionId int `description:"行业id"`
  29. ChartPermissionName string `description:"行业名称"`
  30. ChartPermissionNames string `description:"行业名称辅助字段,区分研选子分类"`
  31. Label string `description:"标签"`
  32. TemporaryLabel string `description:"临时标签"`
  33. VideoId int `orm:"column(video_id);pk"description:"视频id"`
  34. VideoName string `description:"视频名称"`
  35. VideoCounts int `description:"播放量"`
  36. VideoDuration string `description:"视频时长"`
  37. CommentNum int `description:"留言总数"`
  38. }
  39. type CygxActivityVideoListRep struct {
  40. Paging *paging.PagingItem `description:"分页数据"`
  41. List []*CygxActivityVideoListResp
  42. }
  43. // 获取数量
  44. func GetActivityVideoCount(condition string, pars []interface{}) (count int, err error) {
  45. sqlCount := ` SELECT
  46. COUNT( 1 ) AS count
  47. FROM
  48. cygx_activity AS art
  49. INNER JOIN cygx_activity_video AS v ON v.activity_id = art.activity_id
  50. WHERE
  51. 1 = 1 `
  52. if condition != "" {
  53. sqlCount += condition
  54. }
  55. o := orm.NewOrm()
  56. err = o.Raw(sqlCount, pars).QueryRow(&count)
  57. return
  58. }
  59. // 列表
  60. func GetActivityVideoListAll(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxActivityVideoListResp, err error) {
  61. o := orm.NewOrm()
  62. sql := `SELECT art.*,v.video_id,v.video_name,v.video_counts,video_duration,
  63. (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
  64. FROM cygx_activity as art INNER JOIN cygx_activity_video AS v ON v.activity_id = art.activity_id WHERE 1= 1 `
  65. if condition != "" {
  66. sql += condition
  67. }
  68. sql += ` LIMIT ?,?`
  69. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  70. return
  71. }
  72. // 历史记录
  73. func GetActivityVideoHistoryById(condition string, pars []interface{}) (item []*CygxMicroRoadshowVoiceHistory, err error) {
  74. o := orm.NewOrm()
  75. sql := ` SELECT
  76. h.*
  77. FROM
  78. cygx_activity_video_history AS h
  79. INNER JOIN cygx_activity_video AS v
  80. WHERE
  81. 1 = 1
  82. AND v.video_id = h.video_id `
  83. if condition != "" {
  84. sql += condition
  85. }
  86. sql += ` ORDER BY h.create_time DESC `
  87. _, err = o.Raw(sql, pars).QueryRows(&item)
  88. return
  89. }
  90. // 详情
  91. func GetCygxActivityVideoReqDetail(activityId int) (item *CygxActivityVideo, err error) {
  92. o := orm.NewOrm()
  93. sql := `SELECT * FROM cygx_activity_video WHERE activity_id= ? `
  94. err = o.Raw(sql, activityId).QueryRow(&item)
  95. return
  96. }
  97. // 列表
  98. func GetCygxActivityVideoReqDetailByVideoId(videoId int) (item *CygxActivityVideo, err error) {
  99. o := orm.NewOrm()
  100. sql := `SELECT * FROM cygx_activity_video WHERE video_id= ? `
  101. err = o.Raw(sql, videoId).QueryRow(&item)
  102. return
  103. }
  104. // 列表
  105. func GetActivityVideoList(condition string, pars []interface{}) (items []*CygxActivityVideoListResp, err error) {
  106. o := orm.NewOrm()
  107. sql := ` SELECT * FROM cygx_activity_video WHERE 1=1 `
  108. if condition != "" {
  109. sql += condition
  110. }
  111. _, err = o.Raw(sql, pars).QueryRows(&items)
  112. return
  113. }