hongze_cygx/models/micro_roadshow.go

package models

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

// MicroRoadShowListResp 微路演列表响应体
type MicroRoadShowListResp struct {
	Paging *paging.PagingItem
	List   []*MicroRoadShowPageList
}

// MicroRoadShowPageList 微路演列表
type MicroRoadShowPageList struct {
	Id                  int    `description:"音视频ID"`
	Title               string `description:"标题"`
	ResourceUrl         string `description:"链接"`
	Type                int    `description:"类型: 1-音频; 2-视频"`
	PublishTime         string `description:"发布时间"`
	BackgroundImg       string `description:"背景图"`
	ShareImg            string `description:"分享封面图"`
	ChartPermissionId   int    `description:"行业ID"`
	ChartPermissionName string `description:"行业名称"`
	PlaySeconds         string `description:"音视频时长"`
	ActivityId          int    `description:"活动ID"`
	AuthInfo            *UserPermissionAuthInfo
}

// GetMicroRoadShowAudioPageList 获取微路演音频列表-分页
func GetMicroRoadShowAudioPageList(startSize, pageSize int, condition string, pars []interface{}) (total int, list []*MicroRoadShowPageList, err error) {
	o := orm.NewOrm()
	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.img_url AS background_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 condition != `` {
		sql += condition
	}
	sql += ` ORDER BY publish_time DESC`

	//totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z `
	//err = o.Raw(totalSql, pars).QueryRow(&total)
	//if err != nil {
	//	return
	//}

	sql += ` LIMIT ?,?`
	_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&list)
	return
}

// GetMicroRoadShowAudioTotal 获取微路演音频数量
func GetMicroRoadShowAudioTotal(condition string, pars []interface{}) (total int, err error) {
	o := orm.NewOrm()
	sql := `SELECT
				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 condition != `` {
		sql += condition
	}
	totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z `
	err = o.Raw(totalSql, pars).QueryRow(&total)
	if err != nil {
		return
	}
	return
}

// GetMicroRoadShowVideoPageList 获取微路演视频列表-分页
func GetMicroRoadShowVideoPageList(startSize, pageSize int, condition string, pars []interface{}, conditionAct string, parsAct []interface{}) (total int, list []*MicroRoadShowPageList, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			video_id AS id,
			video_name AS title,
			video_url AS resource_url,
			2 AS type,
			publish_date AS publish_time,
			chart_permission_id,
			chart_permission_name,
			video_duration AS play_seconds,
			img_url AS background_img,
			"" as  activity_id
		FROM
			cygx_micro_roadshow_video 
		WHERE
			publish_status = 1 `
	if condition != `` {
		sql += condition
	}
	sql += ` UNION ALL
		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,
			"",
			"",
			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 += ` ORDER BY publish_time DESC`
	//totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z `
	//err = o.Raw(totalSql, pars, parsAct).QueryRow(&total)
	//if err != nil {
	//	return
	//}

	sql += ` LIMIT ?,?`
	_, err = o.Raw(sql, pars, parsAct, startSize, pageSize).QueryRows(&list)
	return
}

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

	if audioId+videoId == 0 {
		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,
			"" AS background_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 {
		sql += `  UNION ALL `
	}

	if videoId+activityVideoId == 0 {
		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.img_url AS background_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)
	if err != nil {
		return
	}
	sql += ` LIMIT ?,?`
	_, err = o.Raw(sql, pars, parsAct, parsAudio, startSize, pageSize).QueryRows(&list)
	return
}

// GetMicroRoadShowVideoTotal 获取微路演视频总量
func GetMicroRoadShowVideoTotal(condition string, pars []interface{}, conditionAct string, parsAct []interface{}) (total int, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			video_id AS id,
			video_name AS title,
			video_url AS resource_url,
			2 AS type,
			publish_date AS publish_time,
			chart_permission_id,
			chart_permission_name,
			video_duration AS play_seconds,
			img_url AS background_img,
			"" as  activity_id
		FROM
			cygx_micro_roadshow_video 
		WHERE
			publish_status = 1 `
	if condition != `` {
		sql += condition
	}
	sql += ` UNION ALL
		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,
			"",
			"",
			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 += ` ORDER BY publish_time DESC`
	totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z `
	err = o.Raw(totalSql, pars, parsAct).QueryRow(&total)
	return
}

type AddVideoHistoryReq struct {
	VideoId     int `description:"视频ID"`
	PlaySeconds int `description:"播放时长"`
	SourceType  int `description:"视频来源: 1-微路演; 2-活动 (不传默认为1)"`
}

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:"视频修改时间"`
}

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
}

// GetHomeNewestListUnionList 首页最新纪要-音频联合查询
func GetHomeNewestListUnionList(condition string, pars []interface{}, startSize, pageSize int) (list []*HomeNewestUnionList, err error) {
	sql := `SELECT
				id, article_id, title, title_en, update_frequency, create_date, publish_date, body, abstract, category_name, sub_category_name, expert_background, category_id, source, annotation,
				(SELECT count(1) FROM cygx_article_history_record_newpv as h WHERE h.article_id = art.article_id ) as pv,
				0 AS home_type, "" AS audio_title, "" AS audio_resource_url, 0 AS audio_type, "" AS audio_publish_time, 0 AS audio_chart_permission_id, "" AS audio_chart_permission_name,
				"" AS audio_play_seconds, "" AS audio_img_url, 0 AS audio_activity_id
			FROM
				cygx_article AS art
			WHERE
				art.publish_status = 1 `
	if condition != `` {
		sql += condition
	}
	sql += ` UNION ALL
			
			SELECT
				a.activity_voice_id, 0, "", "", "", "", b.activity_time, "", "", "", "", "", 0, 0, "",
				0, 1, a.voice_name, a.voice_url, 1, b.activity_time,
				b.chart_permission_id, b.chart_permission_name, a.voice_play_seconds AS audio_play_seconds, a.img_url AS audio_img_url, a.activity_id AS audio_activity_id
			FROM
				cygx_activity_voice AS a
			JOIN cygx_activity AS b ON a.activity_id = b.activity_id`
	sql += ` ORDER BY publish_date DESC`
	sql += ` LIMIT ?,?`
	_, err = orm.NewOrm().Raw(sql, pars, startSize, pageSize).QueryRows(&list)
	return
}

// GetHomeNewestListUnionCount 首页最新纪要-音频联合查询总数
func GetHomeNewestListUnionCount(condition string, pars []interface{}) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT
				COUNT(1) AS count
			FROM
				(
					SELECT
						art.id
					FROM
						cygx_article AS art
					WHERE
						art.publish_status = 1 `
	if condition != `` {
		sql += condition
	}
	sql += ` UNION ALL
				SELECT
					a.activity_voice_id
				FROM
					cygx_activity_voice AS a
				JOIN cygx_activity AS b ON a.activity_id = b.activity_id
			) z `
	err = o.Raw(sql, pars).QueryRow(&count)
	return
}

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:"背景图链接"`
}

// 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(activityId 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, activityId).Exec()
	return
}