activity_video.go 4.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150
  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. CreateTime string `description:"创建时间"`
  16. }
  17. type CygxActivityVideoReq struct {
  18. VideoName string `description:"视频名称"`
  19. VideoDuration string `description:"视频时长"`
  20. VideoUrl string `description:"视频地址"`
  21. }
  22. // 活动详情
  23. type CygxActivityVideoListResp struct {
  24. ActivityId int `orm:"column(activity_id);pk";description:"活动ID 等于0新增活动,大于0修改活动"`
  25. ActivityTypeId int `description:"活动类型id"`
  26. ActivityName string `description:"活动名称"`
  27. ActivityTimeText string `description:"活动时间"`
  28. ActivityTypeName string `description:"活动类型名称"`
  29. ChartPermissionId int `description:"行业id"`
  30. ChartPermissionName string `description:"行业名称"`
  31. ChartPermissionNames string `description:"行业名称辅助字段,区分研选子分类"`
  32. Label string `description:"标签"`
  33. TemporaryLabel string `description:"临时标签"`
  34. VideoId int `orm:"column(video_id);pk"description:"视频id"`
  35. VideoName string `description:"视频名称"`
  36. VideoCounts int `description:"播放量"`
  37. VideoDuration string `description:"视频时长"`
  38. CommentNum int `description:"留言总数"`
  39. }
  40. type CygxActivityVideoListRep struct {
  41. Paging *paging.PagingItem `description:"分页数据"`
  42. List []*CygxActivityVideoListResp
  43. }
  44. // 添加
  45. func AddCygxActivityVideo(item *CygxActivityVideo) (newId int64, err error) {
  46. o := orm.NewOrm()
  47. newId, err = o.Insert(item)
  48. return
  49. }
  50. // 修改
  51. func UpdateCygxActivityVideo(item *CygxActivityVideo) (err error) {
  52. to := orm.NewOrm()
  53. updateParams := make(map[string]interface{})
  54. updateParams["VideoName"] = item.VideoName
  55. updateParams["VideoDuration"] = item.VideoDuration
  56. updateParams["VideoUrl"] = item.VideoUrl
  57. updateParams["ModifyDate"] = time.Now()
  58. ptrStructOrTableName := "cygx_activity_video"
  59. whereParam := map[string]interface{}{"activity_id": item.ActivityId}
  60. qs := to.QueryTable(ptrStructOrTableName)
  61. for expr, exprV := range whereParam {
  62. qs = qs.Filter(expr, exprV)
  63. }
  64. _, err = qs.Update(updateParams)
  65. return
  66. }
  67. // 获取数量
  68. func GetActivityVideoCount(condition string, pars []interface{}) (count int, err error) {
  69. sqlCount := ` SELECT
  70. COUNT( 1 ) AS count
  71. FROM
  72. cygx_activity AS art
  73. INNER JOIN cygx_activity_video AS v ON v.activity_id = art.activity_id
  74. WHERE
  75. 1 = 1 `
  76. if condition != "" {
  77. sqlCount += condition
  78. }
  79. o := orm.NewOrm()
  80. err = o.Raw(sqlCount, pars).QueryRow(&count)
  81. return
  82. }
  83. // 列表
  84. func GetActivityVideoListAll(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxActivityVideoListResp, err error) {
  85. o := orm.NewOrm()
  86. sql := `SELECT art.*,v.video_id,v.video_name,v.video_counts,video_duration,
  87. (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
  88. FROM cygx_activity as art INNER JOIN cygx_activity_video AS v ON v.activity_id = art.activity_id WHERE 1= 1 `
  89. if condition != "" {
  90. sql += condition
  91. }
  92. sql += ` LIMIT ?,?`
  93. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  94. return
  95. }
  96. // 历史记录
  97. func GetActivityVideoHistoryById(condition string, pars []interface{}) (item []*CygxMicroRoadshowVoiceHistory, err error) {
  98. o := orm.NewOrm()
  99. sql := ` SELECT
  100. h.*
  101. FROM
  102. cygx_activity_video_history AS h
  103. INNER JOIN cygx_activity_video AS v
  104. WHERE
  105. 1 = 1
  106. AND v.video_id = h.video_id `
  107. if condition != "" {
  108. sql += condition
  109. }
  110. sql += ` ORDER BY h.create_time DESC `
  111. _, err = o.Raw(sql, pars).QueryRows(&item)
  112. return
  113. }
  114. // 详情
  115. func GetCygxActivityVideoReqDetail(activityId int) (item *CygxActivityVideo, err error) {
  116. o := orm.NewOrm()
  117. sql := `SELECT * FROM cygx_activity_video WHERE activity_id= ? `
  118. err = o.Raw(sql, activityId).QueryRow(&item)
  119. return
  120. }
  121. // 列表
  122. func GetCygxActivityVideoReqDetailByVideoId(videoId int) (item *CygxActivityVideo, err error) {
  123. o := orm.NewOrm()
  124. sql := `SELECT * FROM cygx_activity_video WHERE video_id= ? `
  125. err = o.Raw(sql, videoId).QueryRow(&item)
  126. return
  127. }
  128. // 列表
  129. func GetActivityVideoList(condition string, pars []interface{}) (items []*CygxActivityVideoListResp, err error) {
  130. o := orm.NewOrm()
  131. sql := ` SELECT * FROM cygx_activity_video WHERE 1=1 `
  132. if condition != "" {
  133. sql += condition
  134. }
  135. _, err = o.Raw(sql, pars).QueryRows(&items)
  136. return
  137. }