package models

import (
	"eta_gn/eta_api/global"
	"eta_gn/eta_api/utils"
	"strings"
	"time"

	"github.com/rdlucklib/rdluck_tools/paging"
)

type EnglishVideo struct {
	Id                 int       `gorm:"column:id;primaryKey;auto_increment:true" description:"路演视频Id"`
	ClassifyIdFirst    int       `gorm:"column:classify_id_first" description:"一级分类id"`
	ClassifyNameFirst  string    `gorm:"column:classify_name_first" description:"一级分类名称"`
	ClassifyIdSecond   int       `gorm:"column:classify_id_second" description:"二级分类id"`
	ClassifyNameSecond string    `gorm:"column:classify_name_second" description:"二级分类名称"`
	Title              string    `gorm:"column:title" description:"标题"`
	Abstract           string    `gorm:"column:abstract" description:"摘要"`
	Author             string    `gorm:"column:author" description:"作者"`
	CreateTime         time.Time `gorm:"column:create_time" description:"创建时间"`
	ModifyTime         time.Time `gorm:"column:modify_time" description:"修改时间"`
	State              int       `gorm:"column:state" description:"1:未发布，2:已发布"`
	PublishTime        time.Time `gorm:"column:publish_time" description:"发布时间"`
	VideoUrl           string    `gorm:"column:video_url" description:"视频文件URL"`
	VideoCoverUrl      string    `gorm:"column:video_cover_url" description:"视频文件封面地址"`
	VideoSeconds       string    `gorm:"column:video_seconds" description:"视频时长"`
	VideoCode          string    `gorm:"column:video_code" description:"报告唯一编码"`
	Pv                 int       `gorm:"column:pv" description:"Pv"`
	PvEmail            int       `gorm:"column:pv_email" description:"邮箱PV"`
	UvEmail            int       `gorm:"column:uv_email" description:"邮箱UV"`
	EmailState         int       `gorm:"column:email_state" description:"群发邮件状态: 0-未发送; 1-已发送"`
	Overview           string    `gorm:"column:overview" description:"英文概述部分"`
	AdminId            int       `gorm:"column:admin_id" description:"上传视频的管理员账号"`
	AdminRealName      string    `gorm:"column:admin_real_name" description:"上传视频的管理员姓名"`
}

func AddEnglishVideo(item *EnglishVideo) (err error) {
	err = global.DmSQL["rddp"].Create(item).Error
	return
}

func ModifyEnglishVideoCode(id int, VideoCode string) (err error) {
	sql := `UPDATE english_video SET video_code=? WHERE id=? `
	err = global.DmSQL["rddp"].Exec(sql, VideoCode, id).Error
	return
}

type SaveEnglishVideoReq struct {
	Id               int    `description:"路演视频ID"`
	ClassifyIdFirst  int    `description:"一级分类id"`
	ClassifyIdSecond int    `description:"二级分类id"`
	Title            string `description:"标题"`
	Abstract         string `description:"摘要"`
	Author           string `description:"作者"`
	State            int    `description:"状态：1:未发布，2:已发布"`
	VideoUrl         string `description:"视频文件URL"`
	VideoCoverUrl    string `description:"视频文件封面地址"`
	VideoSeconds     string `description:"视频时长"`
	Overview         string `description:"英文概述部分"`
}

type SaveEnglishVideoResp struct {
	Id        int    `description:"路演视频ID"`
	VideoCode string `description:"报告code"`
}

type ElasticEnglishVideoDetail struct {
	Id                 int    `description:"路演视频ID"`
	ClassifyIdFirst    int    `description:"一级分类id"`
	ClassifyNameFirst  string `description:"一级分类名称"`
	ClassifyIdSecond   int    `description:"二级分类id"`
	ClassifyNameSecond string `description:"二级分类名称"`
	StageStr           string `description:"报告期数"`
	Title              string `description:"标题"`
	Abstract           string `description:"摘要"`
	Author             string `description:"作者"`
	Frequency          string `description:"频度"`
	PublishState       int    `description:"状态：1:未发布，2:已发布"`
	BodyContent        string `description:"内容"`
	ContentSub         string `description:"前两段内容"`
	CreateTime         string `description:"创建时间"`
	PublishTime        string `description:"发布时间"`
	VideoCode          string `description:"报告唯一编码"`
	Overview           string `description:"英文概述部分"`
}

func EditEnglishVideo(item *EnglishVideo, Id int) (err error) {
	sql := `UPDATE english_video
			SET
			  classify_id_first =?,
			  classify_name_first = ?,
			  classify_id_second = ?,
			  classify_name_second = ?,
			  title = ?,
			  abstract = ?,
			  state = ?,
			  modify_time = ?,
			  overview = ?,
              video_url = ?,
              video_cover_url = ?,
              video_seconds = ?
			WHERE id = ? `
	err = global.DmSQL["rddp"].Exec(sql, item.ClassifyIdFirst, item.ClassifyNameFirst, item.ClassifyIdSecond, item.ClassifyNameSecond, item.Title,
		item.Abstract, item.State, time.Now(), item.Overview, item.VideoUrl, item.VideoCoverUrl, item.VideoSeconds, Id).Error
	return
}

type EnglishVideoDetail struct {
	Id                 int    `description:"路演视频ID"`
	ClassifyIdFirst    int    `description:"一级分类id"`
	ClassifyNameFirst  string `description:"一级分类名称"`
	ClassifyIdSecond   int    `description:"二级分类id"`
	ClassifyNameSecond string `description:"二级分类名称"`
	Title              string `description:"标题"`
	Abstract           string `description:"摘要"`
	Author             string `description:"作者"`
	CreateTime         string `description:"创建时间"`
	ModifyTime         string `description:"修改时间"`
	State              int    `description:"1:未发布，2:已发布"`
	PublishTime        string `description:"发布时间"`
	MsgIsSend          int    `description:"消息是否已发送，0:否，1:是"`
	VideoCode          string `description:"报告唯一编码"`
	VideoUrl           string `description:"视频文件URL"`
	VideoCoverUrl      string `description:"视频文件封面地址"`
	VideoSeconds       string `description:"视频时长"`
	Pv                 int    `description:"Pv"`
	Overview           string `description:"英文概述部分"`
}

func GetEnglishVideoById(Id int) (item *EnglishVideoDetail, err error) {
	sql := `SELECT * FROM english_video WHERE id=?`
	err = global.DmSQL["rddp"].Raw(sql, Id).First(&item).Error
	return
}

func GetEnglishVideoItemById(Id int) (item *EnglishVideo, err error) {
	sql := `SELECT * FROM english_video WHERE id = ? LIMIT 1`
	err = global.DmSQL["rddp"].Raw(sql, Id).First(&item).Error
	return
}

type EnglishVideoList struct {
	Id                 int    `description:"id"`
	ClassifyIdFirst    int    `description:"一级分类id"`
	ClassifyNameFirst  string `description:"一级分类名称"`
	ClassifyIdSecond   int    `description:"二级分类id"`
	ClassifyNameSecond string `description:"二级分类名称"`
	Title              string `description:"标题"`
	Abstract           string `description:"摘要"`
	CreateTime         string `description:"创建时间"`
	ModifyTime         string `description:"修改时间"`
	State              int    `description:"1:未发布，2:已发布"`
	PublishTime        string `description:"发布时间"`
	VideoUrl           string `description:"视频文件URL"`
	VideoCoverUrl      string `description:"视频文件封面地址"`
	VideoSeconds       string `description:"视频时长"`
	VideoCode          string `description:"报告唯一编码"`
	Pv                 int    `description:"Pv"`
	ShareUrl           string `description:"分享url"`
	PvEmail            int    `description:"邮箱PV"`
	UvEmail            int    `description:"邮箱UV"`
	EmailState         int    `description:"群发邮件状态: 0-未发送; 1-已发送"`
	EmailAuth          bool   `description:"是否有权限群发邮件"`
	EmailHasFail       bool   `description:"是否存在邮件发送失败的记录"`
	Overview           string `description:"英文概述部分"`
	AdminId            int    `description:"上传视频的管理员账号"`
	AdminRealName      string `description:"上传视频的管理员姓名"`
}

type EnglishVideoListResp struct {
	List   []*EnglishVideoList
	Paging *paging.PagingItem `description:"分页数据"`
}

type EnglishVideoReq struct {
	Id int `description:"路演视频id"`
}

func GetEnglishVideoListCount(condition string, pars []interface{}) (count int, err error) {
	//产品权限
	sql := `SELECT COUNT(1) AS count  FROM english_video WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	err = global.DmSQL["rddp"].Raw(sql, pars...).Scan(&count).Error
	return
}

func GetEnglishVideoList(condition string, pars []interface{}, startSize, pageSize int) (items []*EnglishVideoList, err error) {
	sql := `SELECT * 
        FROM english_video WHERE 1=1  `
	if condition != "" {
		sql += condition
	}
	sql += `ORDER BY  modify_time DESC LIMIT ?,?`
	pars = append(pars, startSize)
	pars = append(pars, pageSize)
	err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error
	return
}

func GetEnglishVideoByCondition(condition string, pars []interface{}) (items []*EnglishVideo, err error) {
	sql := `SELECT * 
        FROM english_video WHERE 1=1  `
	if condition != "" {
		sql += condition
	}
	err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error
	return
}

// 发布报告
func PublishEnglishVideoById(Id int) (err error) {
	sql := `UPDATE english_video SET state=2,publish_time=now(),modify_time=NOW() WHERE id = ? `
	err = global.DmSQL["rddp"].Exec(sql, Id).Error
	return
}

// 取消发布报告
func PublishCancelEnglishVideo(Ids int) (err error) {
	sql := ` UPDATE english_video SET state=1,publish_time=null WHERE id =?  `
	err = global.DmSQL["rddp"].Exec(sql, Ids).Error
	return
}

// DeleteEnglishVideo 删除路演视频
func DeleteEnglishVideo(Id int) (err error) {
	sql := ` DELETE FROM english_video WHERE id=? `
	err = global.DmSQL["rddp"].Exec(sql, Id).Error
	return
}

func UpdateEnglishVideoClassifyByFirstSecondClassifyId(classifyId, parentId int) (err error) {
	// 更新相关联的二级分类的parentId,和classify_name_second
	sql := `update english_video r
LEFT JOIN english_classify c ON r.classify_id_second = c.id
SET r.classify_id_first=c.parent_id, r.classify_name_second=c.classify_name
where (r.classify_id_first != c.parent_id or r.classify_name_second != c.classify_name) and r.classify_id_second =?`
	err = global.DmSQL["rddp"].Exec(sql, classifyId).Error
	if err != nil {
		return
	}
	//更新一级分类名
	sql = `update english_video r
    LEFT JOIN english_classify c ON r.classify_id_first = c.id
    SET r.classify_name_first=c.classify_name
where r.classify_name_first	!= c.classify_name and r.classify_id_first=?`
	err = global.DmSQL["rddp"].Exec(sql, parentId).Error
	if err != nil {
		return
	}
	//更新一级分类名
	sql = `update english_video r
    LEFT JOIN english_classify c ON r.classify_id_first = c.id
    SET r.classify_name_first=c.classify_name
where r.classify_name_first	!= c.classify_name and r.classify_id_first=?`
	err = global.DmSQL["rddp"].Exec(sql, classifyId).Error
	return
}

// Update 更新
func (item *EnglishVideo) Update(cols []string) (err error) {
	err = global.DmSQL["rddp"].Select(cols).Updates(item).Error
	return
}

func GetEnglishVideoCounts(classifyId, parentId int) (count int, err error) {
	sql := ``
	if parentId == 0 {
		sql = `SELECT COUNT(1) AS count FROM english_video WHERE classify_id_first=? `
	} else {
		sql = `SELECT COUNT(1) AS count FROM english_video WHERE classify_id_second=? `
	}
	err = global.DmSQL["rddp"].Raw(sql, classifyId).Scan(&count).Error
	return
}

// GetEnglishVideoByIds 根据IDs获取英文报告列表
func GetEnglishVideoByIds(Ids []int, fieldArr []string) (list []*EnglishVideo, err error) {
	listLen := len(Ids)
	if listLen == 0 {
		return
	}
	fields := ` * `
	if len(fieldArr) > 0 {
		fields = strings.Join(fieldArr, ",")
	}
	sql := `SELECT ` + fields + ` FROM english_video WHERE id IN (` + utils.GetOrmInReplace(listLen) + `)`
	err = global.DmSQL["rddp"].Raw(sql, Ids).Find(&list).Error
	return
}