hongze_web_mfyx/models/micro_roadshow.go

package models

import (
	"github.com/beego/beego/v2/client/orm"
	"github.com/rdlucklib/rdluck_tools/paging"
	"hongze/hongze_web_mfyx/utils"
	"time"
)

// MicroRoadShowListResp 微路演列表响应体
type MicroRoadShowListResp struct {
	Paging *paging.PagingItem
	List   []*MicroRoadShowPageList
}
type CygxMicroRoadshowVideo struct {
	VideoId             int       `orm:"column(video_id);pk"description:"微路演视频id"`
	VideoName           string    `description:"视频名称"`
	ChartPermissionId   int       `description:"行业Id"`
	ChartPermissionName string    `description:"行业名称"`
	IndustryId          int       `description:"产业id"`
	IndustryName        string    `description:"产业名称"`
	PublishStatus       int       `description:"发布状态 1发布 0没有"`
	ModifyDate          string    `description:"更新时间"`
	PublishDate         time.Time `description:"发布时间"`
	VideoDuration       string    `description:"视频时长"`
	VideoCounts         int       `description:"播放量"`
	VideoUrl            string    `description:"视频地址"`
	CreateTime          string    `description:"创建时间"`
	ImgUrl              string    `description:"视频封面图"`
	ShareImgUrl         string    `description:"视频分享图"`
	DetailImgUrl        string    `description:"产业详情页背景图"`
	CommentNum          int       `description:"留言总数"`
	IsSendWxMsg         int       `description:"是否推送过微信模板消息，1是，0：否"`
}

// MicroRoadShowPageList 微路演列表
type MicroRoadShowPageList struct {
	Id                     int       `description:"音视频ID"`
	SourceId               int       `description:"资源ID"`
	Title                  string    `description:"标题"`
	ResourceUrl            string    `description:"链接"`
	Type                   int       `description:"类型: 1-音频; 2-活动视频； 3-产业视频 、 4-系列问答视频"`
	LabelType              int       `description:"标签类型: 1-路演回放; 2-调研反馈； 3-产业视频; 4-问答系列"`
	ActivityFileType       int       `description:"活动音视频文件类型: 1-路演回放; 2-调研反馈"`
	PublishTime            string    `description:"发布时间"`
	BackgroundImg          string    `description:"背景图"`
	ShareImg               string    `description:"分享封面图"`
	ChartPermissionId      int       `description:"行业ID"`
	ChartPermissionName    string    `description:"行业名称"`
	IndustryName           string    `description:"产业名称"`
	PlaySeconds            string    `description:"音视频时长"`
	ActivityId             int       `description:"活动ID"`
	IsCollect              bool      `description:"是否收藏"`
	IndustrialManagementId int       `description:"产业ID"`
	IndustryId             int       `description:"产业ID"`
	CreateTime             string    `description:"视频创建时间"`
	CollectTime            time.Time `description:"收藏时间"`
	LabelKeywordImgLink    string    `description:"标签关键词ico"`
	AuthInfo               *UserPermissionAuthInfo
}

func GetMicroRoadshowVideoByVideoId(videoId int) (item *CygxMicroRoadshowVideo, err error) {
	o := orm.NewOrm()
	sql := `SELECT * from cygx_micro_roadshow_video where video_id = ? `
	err = o.Raw(sql, videoId).QueryRow(&item)
	return
}

type AddVideoHistoryReq struct {
	SourceId        int    `description:"资源ID"`
	PlaySeconds     int    `description:"播放时长"`
	SourceType      int    `description:"音视频来源: 1-活动音频; 2-活动视频； 3-产业视频; 4-系列问答"`
	InviteShareCode string `description:"销售账号邀请码"`
}

type CygxMicroRoadshowVideoHistory struct {
	Id               int       `orm:"column(id);pk"description:"微路演视频浏览记录表id"`
	VideoId          int       `description:"微路演视频id"`
	UserId           int       `description:"用户id"`
	Mobile           string    `description:"手机号"`
	Email            string    `description:"邮箱"`
	CompanyId        int       `description:"公司Id"`
	CompanyName      string    `description:"公司名称"`
	RealName         string    `description:"用户实际名称"`
	SellerName       string    `description:"所属销售"`
	PlaySeconds      string    `description:"播放时间 单位s"`
	CreateTime       time.Time `description:"视频创建时间"`
	ModifyTime       time.Time `description:"视频修改时间"`
	RegisterPlatform int       `description:"来源 1小程序，2：网页"`
}

func GetLastCygxMicroRoadshowVideoHistory(videoId, userId int) (item *CygxMicroRoadshowVideoHistory, err error) {
	o := orm.NewOrm()
	sql := ` SELECT * FROM cygx_micro_roadshow_video_history WHERE video_id=? AND user_id=? ORDER BY create_time DESC limit 1 `
	err = o.Raw(sql, videoId, userId).QueryRow(&item)
	return
}

func AddCygxMicroRoadshowVideoHistory(item *CygxMicroRoadshowVideoHistory) (err error) {
	o := orm.NewOrm()
	_, err = o.Insert(item)
	return
}

// MicroAudioUnionList 微路演音频联合列表
type MicroAudioUnionList struct {
	Id                       int    `description:"音视频ID"`
	AudioTitle               string `description:"标题"`
	AudioResourceUrl         string `description:"链接"`
	AudioType                int    `description:"类型: 1-音频; 2-视频"`
	AudioPublishTime         string `description:"发布时间"`
	AudioImgUrl              string `description:"背景图"`
	AudioShareImg            string `description:"分享图"`
	AudioChartPermissionId   int    `description:"行业ID"`
	AudioChartPermissionName string `description:"行业名称"`
	AudioPlaySeconds         string `description:"音视频时长"`
	AudioActivityId          int    `description:"活动ID"`
	AuthInfo                 *UserPermissionAuthInfo
}

// HomeNewestUnionList 首页最新纪要-音频联合查询结果
type HomeNewestUnionList struct {
	ArticleId        int    `description:"文章id"`
	Title            string `description:"标题"`
	TitleEn          string `description:"英文标题 "`
	UpdateFrequency  string `description:"更新周期"`
	CreateDate       string `description:"创建时间"`
	PublishDate      string `description:"发布时间"`
	Body             string `description:"内容"`
	BodyHtml         string `description:"内容带有HTML标签"`
	Abstract         string `description:"摘要"`
	CategoryName     string `description:"一级分类"`
	SubCategoryName  string `description:"二级分类"`
	ExpertBackground string `description:"专家背景"`
	IsResearch       bool   `description:"是否属于研选"`
	Pv               int    `description:"PV"`
	ImgUrlPc         string `description:"图片链接"`
	CategoryId       string `description:"文章分类"`
	HttpUrl          string `description:"文章链接跳转地址"`
	IsNeedJump       bool   `description:"是否需要跳转链接地址"`
	Source           int    `description:"来源  1:文章, 2:图表"`
	Annotation       string `description:"核心观点"`
	HomeType         int    `description:"数据类型：0-纪要(默认); 1-微路演音频"`
	MicroAudioUnionList
}

func UpdateLastCygxActivityVideoHistory(playSeconds string, lastId int) (err error) {
	o := orm.NewOrm()
	sql := ` UPDATE cygx_micro_roadshow_video_history SET play_seconds =? WHERE id=? `
	_, err = o.Raw(sql, playSeconds, lastId).Exec()
	return
}

// MicroRoadshowVideo 微路演视频
type MicroRoadshowVideo struct {
	VideoId             int       `orm:"column(video_id);pk" description:"视频ID"`
	VideoName           string    `description:"视频标题"`
	ChartPermissionId   int       `description:"行业ID"`
	ChartPermissionName string    `description:"行业名称"`
	IndustryId          int       `description:"产业ID"`
	IndustryName        string    `description:"产业名称"`
	PublishStatus       int       `description:"发布状态：0-未发布；1-已发布"`
	ModifyDate          time.Time `description:"更新时间"`
	PublishDate         time.Time `description:"发布时间"`
	VideoCounts         int       `description:"视频播放量"`
	VideoDuration       int       `description:"视频时长"`
	VideoUrl            string    `description:"视频地址"`
	CreateTime          time.Time `description:"创建时间"`
	ImgUrl              string    `description:"背景图链接"`
	DetailImgUrl        string    `description:"产业详情页背景图"`
}

// GetMicroRoadshowVideoById 主键获取微路演视频
func GetMicroRoadshowVideoById(videoId int) (item *MicroRoadshowVideo, err error) {
	sql := `SELECT * FROM cygx_micro_roadshow_video WHERE video_id = ? LIMIT 1`
	err = orm.NewOrm().Raw(sql, videoId).QueryRow(&item)
	return
}

func UpdateCygxActivityVideoCounts(videoId int) (err error) {
	sql := `UPDATE cygx_micro_roadshow_video SET video_counts = video_counts+1 WHERE video_id = ?  `
	o := orm.NewOrm()
	_, err = o.Raw(sql, videoId).Exec()
	return
}

// GetMicroRoadshowVideoByIndustryIds 根据行业ID查询产业视频列表
func GetMicroRoadshowVideoByIndustryIds(industrialIdArr []int) (list []*MicroRoadshowVideo, err error) {
	sql := `SELECT * FROM cygx_micro_roadshow_video WHERE industry_id in (` + utils.GetOrmInReplace(len(industrialIdArr)) + `) `
	_, err = orm.NewOrm().Raw(sql, industrialIdArr).QueryRows(&list)
	return
}

// GetMicroRoadshowVideoListBycondition 根据搜索条件获取搜索列表
func GetMicroRoadshowVideoListBycondition(condition string, pars []interface{}, startSize, pageSize int) (list []*MicroRoadshowVideo, err error) {
	sql := `SELECT * FROM cygx_micro_roadshow_video WHERE  1 =1 `
	if condition != "" {
		sql += condition
	}
	sql += `  LIMIT ?,? `
	_, err = orm.NewOrm().Raw(sql, pars, startSize, pageSize).QueryRows(&list)
	return
}

// GetMicroRoadshowVideoByIndustryId 根据行业ID查询产业视频列表
func GetMicroRoadshowVideoByIndustryId(industryId int) (item *MicroRoadshowVideo, err error) {
	sql := `SELECT * FROM cygx_micro_roadshow_video WHERE industry_id = ? and publish_status = 1`
	err = orm.NewOrm().Raw(sql, industryId).QueryRow(&item)
	return
}

// GetMicroRoadshowVideoByIndustryIdCount  根据行业ID查询产业视频是否存在
func GetMicroRoadshowVideoByIndustryIdCount(industryId int) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT COUNT(1) count
			FROM cygx_micro_roadshow_video WHERE industry_id = ? and publish_status = 1`
	err = o.Raw(sql, industryId).QueryRow(&count)
	return
}

// GetMicroRoadshowVideoByVideoIdCount  根据视频ID查询产业视频是否存在
func GetMicroRoadshowVideoByVideoIdCount(industryId int) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT COUNT(1) count
			FROM cygx_micro_roadshow_video WHERE video_id = ? and publish_status = 1`
	err = o.Raw(sql, industryId).QueryRow(&count)
	return
}

// GetMicroRoadshowVideoList 获取已经发布的微路演视频
func GetMicroRoadshowVideoList() (list []*MicroRoadshowVideo, err error) {
	sql := `SELECT * FROM cygx_micro_roadshow_video WHERE  publish_status = 1`
	_, err = orm.NewOrm().Raw(sql).QueryRows(&list)
	return
}

// GetMicroRoadShowVideoPageList 获取微路演视频列表-分页
func GetMicroRoadShowVideoPageListV8(startSize, pageSize int, condition string, pars []interface{}, conditionAct string, parsAct []interface{}, conditionAudio string, parsAudio []interface{}, audioId, videoId, activityVideoId, filter int) (total int, list []*MicroRoadShowPageList, err error) {
	o := orm.NewOrm()
	var sql string
	//if audioId+activityVideoId == 0 && filter != 2 {
	sql += `SELECT
			video_id AS id,
			video_name AS title,
			video_url AS resource_url,
			3 AS type,
			publish_date AS publish_time,
			chart_permission_id,
			chart_permission_name,
			video_duration AS play_seconds,
			img_url AS background_img,            
			industry_name,

			share_img_url AS share_img,
			industry_id AS industrial_management_id,
			"" as  activity_id
		FROM
			cygx_micro_roadshow_video 
		WHERE
			publish_status = 1 `
	if condition != `` {
		sql += condition
	}
	//}
	//if audioId+videoId+activityVideoId == 0 && filter != 2 {
	sql += `  UNION ALL `
	//}

	//if audioId+videoId == 0 && filter != 2 {
	sql += `
		SELECT
			video_id AS id,
			video_name AS title,
			video_url AS resource_url,
			2 AS type,
		art.activity_time as publish_time,
			art.chart_permission_id,
			art.chart_permission_name,
			"" AS play_seconds,
			v.background_img,
			"" AS industry_name,
			v.share_img,
			0 AS industrial_management_id,
			v.activity_id
		FROM
			cygx_activity_video as v
			INNER JOIN cygx_activity as art on art.activity_id = v.activity_id WHERE 1= 1  `
	if conditionAct != `` {
		sql += conditionAct
	}
	//}
	//if audioId+videoId+activityVideoId == 0 && filter == 0 {
	sql += `  UNION ALL `
	//}

	//if videoId+activityVideoId == 0 && filter != 1 {
	sql += `
			SELECT
			a.activity_voice_id AS id,
			a.voice_name AS title,
			a.voice_url AS resource_url,
			1 AS type,
			b.activity_time AS publish_time,
			b.chart_permission_id,
			b.chart_permission_name,
			a.voice_play_seconds AS play_seconds,
			a.background_img,
			"" AS industry_name,
			a.share_img,
			0 AS industrial_management_id,
			a.activity_id 
		FROM
			cygx_activity_voice AS a
			JOIN cygx_activity AS b ON a.activity_id = b.activity_id  WHERE 1= 1  `
	if conditionAudio != `` {
		sql += conditionAudio
	}
	//}
	sql += ` ORDER BY publish_time DESC`
	totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z `
	err = o.Raw(totalSql, pars, parsAct, parsAudio).QueryRow(&total)
	if err != nil {
		return
	}
	sql += ` LIMIT ?,?`
	_, err = o.Raw(sql, pars, parsAct, parsAudio, startSize, pageSize).QueryRows(&list)
	return
}

// GetMicroRoadShowVideoPageList 获取微路演视频列表-分页
func GetMicroRoadShowVideoPageListV12(startSize, pageSize int, audioAct string, audioActPars []interface{}, videoAct string, videoActPars []interface{}, videoMico string, videoMicoPars []interface{}, conditionAskserie string, askseriePars []interface{}) (total int, list []*MicroRoadShowPageList, err error) {
	o := orm.NewOrm()
	var sql string

	//活动音频1
	sql += `
			SELECT
			a.activity_voice_id AS id,
			a.activity_id AS source_id,
			a.voice_name AS title,
			a.voice_url AS resource_url,
			1 AS type,
			b.activity_time AS publish_time,
			b.chart_permission_id,
			b.chart_permission_name,
			a.voice_play_seconds AS play_seconds,
			a.background_img,
			"" AS industry_name,
			0 AS  industry_id,
			a.share_img,
			a.file_type as activity_file_type,
			a.activity_id 
		FROM
			cygx_activity_voice AS a
			JOIN cygx_activity AS b ON a.activity_id = b.activity_id  WHERE 1= 1  `
	if audioAct != `` {
		sql += audioAct
	}

	//活动视频2
	sql += `  UNION ALL `
	sql += `
		SELECT
			a.video_id AS id,
			a.activity_id AS source_id,
			a.video_name AS title,
			a.video_url AS resource_url,
			2 AS type,
	    	b.activity_time as publish_time,
			b.chart_permission_id,
			b.chart_permission_name,
			a.video_duration AS play_seconds,
			a.background_img,
			"" AS industry_name,
			0 AS  industry_id,
			a.share_img,
			a.file_type as activity_file_type,
			a.activity_id
		FROM
			cygx_activity_video as a
			INNER JOIN cygx_activity as b on a.activity_id = b.activity_id WHERE 1= 1  `
	if videoAct != `` {
		sql += videoAct
	}
	sql += `  UNION ALL `

	// 产业视频3
	sql += `SELECT
			video_id AS id,
			video_id AS source_id,
			video_name AS title,
			video_url AS resource_url,
			3 AS type,
			publish_date AS publish_time,
			chart_permission_id,
			chart_permission_name,
			video_duration AS play_seconds,
			img_url AS background_img,            
			industry_name,
			industry_id,
			share_img_url AS share_img,
			'' as activity_file_type,
			"" as  activity_id
		FROM
			cygx_micro_roadshow_video  as a
		WHERE
			publish_status = 1 `
	if videoMico != `` {
		sql += videoMico
	}

	//系列问答
	sql += `  UNION ALL `
	sql += `
			SELECT
			a.askserie_video_id AS id,
			a.askserie_video_id AS source_id,
			a.video_name AS title,
			a.video_url AS resource_url,
			4 AS type,
			a.publish_date AS publish_time,
			a.chart_permission_id,
			a.chart_permission_name,
			a.video_duration AS play_seconds,
			a.background_img,
			"" AS industry_name,
			0 AS  industry_id,
			a.share_img,
			'' as activity_file_type,
			0  as activity_id 
		FROM
			cygx_askserie_video AS a WHERE 1= 1 `
	if conditionAskserie != `` {
		sql += conditionAskserie
	}

	sql += ` ORDER BY publish_time DESC`
	totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z `
	err = o.Raw(totalSql, audioActPars, videoActPars, videoMicoPars, askseriePars).QueryRow(&total)
	if err != nil {
		return
	}
	sql += ` LIMIT ?,?`
	_, err = o.Raw(sql, audioActPars, videoActPars, videoMicoPars, askseriePars, startSize, pageSize).QueryRows(&list)
	return
}

type MicroList []*MicroRoadShowPageList

func (m MicroList) Len() int {
	return len(m)
}

func (m MicroList) Less(i, j int) bool {
	return m[i].CollectTime.After(m[j].CollectTime)
}

func (m MicroList) Swap(i, j int) {
	m[i], m[j] = m[j], m[i]
}

// CountMicroRoadShowVideoPageList 获取微路演视频数量
func CountMicroRoadShowVideoPageList(condition string, pars []interface{}, conditionAct string, parsAct []interface{}, conditionAudio string, parsAudio []interface{}) (total int, err error) {
	o := orm.NewOrm()
	var sql string
	sql += `SELECT
			video_id AS id,
			video_name AS title,
			video_url AS resource_url,
			3 AS type,
			publish_date AS publish_time,
			chart_permission_id,
			chart_permission_name,
			video_duration AS play_seconds,
			img_url AS background_img,            
			industry_name,
			share_img_url AS share_img,
			"" as  activity_id
		FROM
			cygx_micro_roadshow_video 
		WHERE
			publish_status = 1 `
	if condition != `` {
		sql += condition
	}
	sql += `  UNION ALL `
	sql += `
		SELECT
			video_id AS id,
			video_name AS title,
			video_url AS resource_url,
			2 AS type,
		art.activity_time as publish_time,
			art.chart_permission_id,
			art.chart_permission_name,
			"" AS play_seconds,
			v.background_img,
			"" AS industry_name,
			v.share_img,
			v.activity_id
		FROM
			cygx_activity_video as v
			INNER JOIN cygx_activity as art on art.activity_id = v.activity_id WHERE 1= 1  `
	if conditionAct != `` {
		sql += conditionAct
	}
	sql += `  UNION ALL `
	sql += `
			SELECT
			a.activity_voice_id AS id,
			a.voice_name AS title,
			a.voice_url AS resource_url,
			1 AS type,
			b.activity_time AS publish_time,
			b.chart_permission_id,
			b.chart_permission_name,
			a.voice_play_seconds AS play_seconds,
			a.background_img,
			"" AS industry_name,
			a.share_img,
			a.activity_id 
		FROM
			cygx_activity_voice AS a
			JOIN cygx_activity AS b ON a.activity_id = b.activity_id  WHERE 1= 1  `
	if conditionAudio != `` {
		sql += conditionAudio
	}

	sql += ` ORDER BY publish_time DESC`
	totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z `
	err = o.Raw(totalSql, pars, parsAct, parsAudio).QueryRow(&total)
	return
}

// GetMicroRoadShowVideoPageList 获取微路演视频列表-分页
func GetMicroRoadShowVideoPageListIkWord(startSize, pageSize int, condition string, pars []interface{}, conditionAct string, parsAct []interface{}, conditionAudio string, parsAudio []interface{}, audioId, videoId, activityVideoId, filter int) (list []*MicroRoadShowPageList, err error) {
	o := orm.NewOrm()
	var sql string
	//if audioId+activityVideoId == 0 && filter != 2 {
	sql += `SELECT
			video_id AS id,
			video_name AS title,
			video_url AS resource_url,
			3 AS type,
			publish_date AS publish_time,
			chart_permission_id,
			chart_permission_name,
			video_duration AS play_seconds,
			img_url AS background_img,            
			industry_name,
			industry_id AS industrial_management_id,
			share_img_url AS share_img,
			"" as  activity_id
		FROM
			cygx_micro_roadshow_video 
		WHERE
			publish_status = 1 `
	if condition != `` {
		sql += condition
	}
	//}
	//if audioId+videoId+activityVideoId == 0 && filter != 2 {
	//	sql += `  UNION ALL `
	//}
	sql += `  UNION ALL `
	//if audioId+videoId == 0 && filter != 2 {
	sql += `
		SELECT
			video_id AS id,
			video_name AS title,
			video_url AS resource_url,
			2 AS type,
			art.activity_time as publish_time,
			art.chart_permission_id,
			art.chart_permission_name,
			"" AS play_seconds,
			v.background_img,
			"" AS industry_name,
			0 AS industrial_management_id,
			v.share_img,
			v.activity_id
		FROM
			cygx_activity_video as v
			INNER JOIN cygx_activity as art on art.activity_id = v.activity_id WHERE 1= 1  `
	if conditionAct != `` {
		sql += conditionAct
	}
	//}
	//if audioId+videoId+activityVideoId == 0 && filter == 0 {
	//	sql += `  UNION ALL `
	//}
	sql += `  UNION ALL `
	//if videoId+activityVideoId == 0 && filter != 1 {
	sql += `
			SELECT
			a.activity_voice_id AS id,
			a.voice_name AS title,
			a.voice_url AS resource_url,
			1 AS type,
			b.activity_time AS publish_time,
			b.chart_permission_id,
			b.chart_permission_name,
			a.voice_play_seconds AS play_seconds,
			a.background_img,
			"" AS industry_name,
			0 AS industrial_management_id,
			a.share_img,
			a.activity_id 
		FROM
			cygx_activity_voice AS a
			JOIN cygx_activity AS b ON a.activity_id = b.activity_id  WHERE 1= 1  `
	if conditionAudio != `` {
		sql += conditionAudio
	}
	//}
	sql += ` ORDER BY publish_time DESC`
	sql += ` LIMIT ?,?`
	_, err = o.Raw(sql, pars, parsAct, parsAudio, startSize, pageSize).QueryRows(&list)
	return
}

type AddVideoCommnetReq struct {
	//Id         int    `description:"活动或产业ID"`
	SourceId   int    `description:"资源ID"`
	SourceType int    `description:"视频来源: 1-音频; 2-活动视频; 3-微路演视频 (不传默认为1)"`
	Content    string `description:"内容"`
	Title      string `description:"标题"`
}
type MicroRoadshowCollectReq struct {
	//Id         int `description:"音频或视频ID"`
	SourceId   int `description:"资源ID"`
	SourceType int `description:"视频来源: 1-音频; 2-活动视频; 3-微路演视频 (不传默认为1)"`
}

func GetMicroRoadShowVideoPageListByActivityIds(activityIds []int) (list []*MicroRoadShowPageList, err error) {
	lenArr := len(activityIds)
	if lenArr == 0 {
		return
	}
	o := orm.NewOrm()
	var sql string
	//活动音频1
	sql += `
			SELECT
			a.activity_voice_id AS id,
			a.activity_id AS source_id,
			a.voice_name AS title,
			a.voice_url AS resource_url,
			1 AS type,
			b.activity_time AS publish_time,
			b.chart_permission_id,
			b.chart_permission_name,
			a.voice_play_seconds AS play_seconds,
			a.background_img,
			"" AS industry_name,
			0 AS  industry_id,
			a.share_img,
			a.file_type as activity_file_type,
			a.activity_id 
		FROM
			cygx_activity_voice AS a
			JOIN cygx_activity AS b ON a.activity_id = b.activity_id  WHERE 1= 1   AND a.activity_id IN (` + utils.GetOrmInReplace(lenArr) + `) `

	//活动视频2
	sql += `  UNION ALL `
	sql += `
		SELECT
			a.video_id AS id,
			a.activity_id AS source_id,
			a.video_name AS title,
			a.video_url AS resource_url,
			2 AS type,
	    	b.activity_time as publish_time,
			b.chart_permission_id,
			b.chart_permission_name,
			a.video_duration AS play_seconds,
			a.background_img,
			"" AS industry_name,
			0 AS  industry_id,
			a.share_img,
			a.file_type as activity_file_type,
			a.activity_id
		FROM
			cygx_activity_video as a
			INNER JOIN cygx_activity as b on a.activity_id = b.activity_id WHERE 1= 1   AND a.activity_id IN (` + utils.GetOrmInReplace(lenArr) + `) `
	sql += ` ORDER BY publish_time DESC`
	_, err = o.Raw(sql, activityIds, activityIds).QueryRows(&list)
	return
}