eta_api/models/report.go

package models

import (
	sql2 "database/sql"
	"errors"
	"eta/eta_api/global"
	"eta/eta_api/models/report"
	"eta/eta_api/utils"
	"fmt"
	"github.com/rdlucklib/rdluck_tools/paging"
	"gorm.io/gorm"
	"strings"
	"time"
)

// 报告状态
const (
	ReportStateUnpublished = 1 // 未发布
	ReportStatePublished   = 2 // 已发布
	ReportStateWaitSubmit  = 3 // 待提交
	ReportStateWaitApprove = 4 // 审批中
	ReportStateRefused     = 5 // 已驳回
	ReportStatePass        = 6 // 已通过
)

// 报告操作
const (
	ReportOperateAdd           = 1 // 新增报告
	ReportOperateEdit          = 2 // 编辑报告
	ReportOperatePublish       = 3 // 发布报告
	ReportOperateCancelPublish = 4 // 取消发布报告
	ReportOperateSubmitApprove = 5 // 提交审批
	ReportOperateCancelApprove = 6 // 撤回审批
)

type Report struct {
	Id                  int       `orm:"column(id)" description:"报告Id"`
	AddType             int       `description:"新增方式：1:新增报告，2:继承报告"`
	ClassifyIdFirst     int       `description:"一级分类id"`
	ClassifyNameFirst   string    `description:"一级分类名称"`
	ClassifyIdSecond    int       `description:"二级分类id"`
	ClassifyNameSecond  string    `description:"二级分类名称"`
	Title               string    `description:"标题"`
	Abstract            string    `description:"摘要"`
	Author              string    `description:"作者"`
	Frequency           string    `description:"频度"`
	CreateTime          string    `description:"创建时间"`
	ModifyTime          time.Time `description:"修改时间"`
	State               int       `description:"1:未发布；2:已发布；3-待提交；4-待审批；5-已驳回；6-已通过"`
	PublishTime         time.Time `description:"发布时间"`
	Stage               int       `description:"期数"`
	MsgIsSend           int       `description:"消息是否已发送，0:否，1:是"`
	ThsMsgIsSend        int       `description:"客户群消息是否已发送，0:否，1:是"`
	Content             string    `description:"内容"`
	VideoUrl            string    `description:"音频文件URL"`
	VideoName           string    `description:"音频文件名称"`
	VideoPlaySeconds    string    `description:"音频播放时长"`
	VideoSize           string    `description:"音频文件大小，单位M"`
	ContentSub          string    `description:"内容前两个章节"`
	ReportCode          string    `description:"报告唯一编码"`
	ReportVersion       int       `description:"1:旧版,2:新版"`
	HasChapter          int       `description:"是否有章节 0-否 1-是"`
	ChapterType         string    `description:"章节类型 day-晨报 week-周报"`
	OldReportId         int       `description:"research_report表ID, 大于0则表示该报告为老后台同步过来的"`
	MsgSendTime         time.Time `description:"模版消息发送时间"`
	AdminId             int       `description:"创建者账号"`
	AdminRealName       string    `description:"创建者姓名"`
	ApproveTime         time.Time `description:"审批时间"`
	ApproveId           int       `description:"审批ID"`
	DetailImgUrl        string    `description:"报告详情长图地址"`
	DetailPdfUrl        string    `description:"报告详情PDF地址"`
	DetailImgUrlMobile  string    `description:"报告详情长图地址-手机端"`
	DetailPdfUrlMobile  string    `description:"报告详情PDF地址-手机端"`
	ContentStruct       string    `description:"内容组件"`
	LastModifyAdminId   int       `description:"最后更新人ID"`
	LastModifyAdminName string    `description:"最后更新人姓名"`
	ContentModifyTime   time.Time `description:"内容更新时间"`
	Pv                  int       `description:"pv"`
	Uv                  int       `description:"uv"`
	HeadImg             string    `description:"报告头图地址"`
	EndImg              string    `description:"报告尾图地址"`
	CanvasColor         string    `description:"画布颜色"`
	NeedSplice          int       `description:"是否拼接版头版位的标记，主要是为了兼容历史报告。0-不需要 1-需要"`
	HeadResourceId      int       `description:"版头资源ID"`
	EndResourceId       int       `description:"版尾资源ID"`
	ClassifyIdThird     int       `description:"三级分类id"`
	ClassifyNameThird   string    `description:"三级分类名称"`
	CollaborateType     int8      `description:"协作方式，1：个人，2：多人协作。默认：1"`
	ReportLayout        int8      `description:"报告布局，1：常规布局，2：智能布局。默认：1"`
	IsPublicPublish     int8      `description:"是否公开发布，1：是，2：否"`
	ReportCreateTime    time.Time `description:"报告时间创建时间"`
	InheritReportId     int       `description:"待继承的报告ID"`
	VoiceGenerateType   int       `description:"音频生成方式，0：系统生成，1：人工上传"`
	RaiReportId         int       `description:"RAI报告ID"`
	FreeLayoutConfig    string    `description:"'自由布局配置"`
	MiniShow            int       `description:"是否在C端展示：0-否；1-是"`
	FreeReportRatio     string    `description:"自由布局页面比例：A4; 16:9; 4:3; 10:7"`
}

func (m *Report) AfterFind(db *gorm.DB) (err error) {
	m.CreateTime = utils.GormDateStrToDateTimeStr(m.CreateTime)
	return
}

// ConvertTimeStr
// @Description: 转成需要输出的格式
// @receiver m
func (m *Report) ConvertTimeStr() {
	m.CreateTime = utils.GormDateStrToDateTimeStr(m.CreateTime)
	return
}

type ReportList struct {
	Id                 int                       `gorm:"column:id;primaryKey;autoIncrement" description:"报告Id"`
	AddType            int                       `description:"新增方式：1:新增报告，2:继承报告"`
	ClassifyIdFirst    int                       `description:"一级分类id"`
	ClassifyNameFirst  string                    `description:"一级分类名称"`
	ClassifyIdSecond   int                       `description:"二级分类id"`
	ClassifyNameSecond string                    `description:"二级分类名称"`
	Title              string                    `description:"标题"`
	Abstract           string                    `description:"摘要"`
	Author             string                    `description:"作者"`
	Frequency          string                    `description:"频度"`
	CreateTime         string                    `description:"创建时间"`
	ModifyTime         string                    `description:"修改时间"`
	State              int                       `description:"1:未发布；2:已发布；3-待提交；4-待审批；5-已驳回；6-已通过"`
	PublishTime        string                    `description:"发布时间"`
	PrePublishTime     string                    `description:"预发布时间"`
	Stage              int                       `description:"期数"`
	MsgIsSend          int                       `description:"模板消息是否已发送，0:否，1:是"`
	Content            string                    `description:"内容"`
	VideoUrl           string                    `description:"音频文件URL"`
	VideoName          string                    `description:"音频文件名称"`
	VideoPlaySeconds   string                    `description:"音频播放时长"`
	ContentSub         string                    `description:"内容前两个章节"`
	Pv                 int                       `description:"Pv"`
	Uv                 int                       `description:"Uv"`
	ReportCode         string                    `description:"报告唯一编码"`
	ReportVersion      int                       `description:"1:旧版,2:新版"`
	ThsMsgIsSend       int                       `description:"客户群消息是否已发送，0:否，1:是"`
	NeedThsMsg         int                       `description:"是否需要推送客群消息 0-否 1-是"`
	HasChapter         int                       `description:"是否有章节 0-否 1-是"`
	ChapterType        string                    `description:"章节类型 day-晨报 week-周报"`
	ChapterVideoList   []*ReportChapterVideoList `gorm:"-" description:"章节音频列表"`
	OldReportId        int                       `description:"research_report表ID, 大于0则表示该报告为老后台同步过来的"`
	MsgSendTime        string                    `description:"模版消息发送时间"`
	CanEdit            bool                      `description:"是否可编辑"`
	HasAuth            bool                      `description:"是否可操作"`
	Editor             string                    `description:"编辑人"`
	AdminId            int                       `description:"创建者账号"`
	AdminRealName      string                    `description:"创建者姓名"`
	ApproveTime        string                    `description:"审批时间"`
	DetailImgUrl       string                    `description:"报告详情长图地址"`
	DetailPdfUrl       string                    `description:"报告详情PDF地址"`
	DetailImgUrlMobile string                    `description:"报告详情长图地址-手机端"`
	DetailPdfUrlMobile string                    `description:"报告详情PDF地址-手机端"`

	CollaborateType     int8      `description:"协作方式，1：个人，2：多人协作。默认：1"`
	ReportLayout        int8      `description:"报告布局，1：常规布局，2：智能布局。默认：1"`
	IsPublicPublish     int8      `description:"是否公开发布，1：是，2：否"`
	ReportCreateTime    time.Time `description:"报告时间创建时间"`
	ContentStruct       string    `description:"内容组件"`
	LastModifyAdminId   int       `description:"最后更新人ID"`
	LastModifyAdminName string    `description:"最后更新人姓名"`
	ContentModifyTime   time.Time `description:"内容更新时间"`
	HeadImg             string    `description:"报告头图地址"`
	EndImg              string    `description:"报告尾图地址"`
	CanvasColor         string    `description:"画布颜色"`
	NeedSplice          int       `description:"是否拼接版头版位的标记，主要是为了兼容历史报告。0-不需要 1-需要"`
	HeadResourceId      int       `description:"版头资源ID"`
	EndResourceId       int       `description:"版尾资源ID"`
	ClassifyIdThird     int       `description:"三级分类id"`
	ClassifyNameThird   string    `description:"三级分类名称"`
	InheritReportId     int       `description:"待继承的报告ID"`
	RaiReportId         int       `description:"RAI报告ID"`
	MiniShow            int       `description:"是否在C端展示：0-否；1-是"`
	FreeReportRatio     string    `description:"自由布局页面比例：A4; 16:9; 4:3; 10:7"`
}

func (m *ReportList) AfterFind(db *gorm.DB) (err error) {
	m.ModifyTime = utils.GormDateStrToDateTimeStr(m.ModifyTime)
	m.PublishTime = utils.GormDateStrToDateTimeStr(m.PublishTime)
	m.CreateTime = utils.GormDateStrToDateTimeStr(m.CreateTime)
	m.ApproveTime = utils.GormDateStrToDateTimeStr(m.ApproveTime)
	m.MsgSendTime = utils.GormDateStrToDateTimeStr(m.MsgSendTime)
	m.PrePublishTime = utils.GormDateStrToDateTimeStr(m.PrePublishTime)
	return
}

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

// GetReportListCountV1
// @Description: 获取普通报告列表的报告数量
// @author: Roc
// @datetime 2024-05-30 15:14:43
// @param condition string
// @param pars []interface{}
// @return count int
// @return err error
func GetReportListCountV1(condition string, pars []interface{}) (count int, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT COUNT(DISTINCT a.id) AS count  FROM report as a WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	var countNull sql2.NullInt64
	err = o.Raw(sql, pars...).Scan(&countNull).Error
	if err != nil {
		return
	}
	if countNull.Valid {
		count = int(countNull.Int64)
	}
	return
}

// GetReportListV1
// @Description: 获取普通报告列表的数据
// @author: Roc
// @datetime 2024-05-30 15:14:25
// @param condition string
// @param pars []interface{}
// @param startSize int
// @param pageSize int
// @return items []*ReportList
// @return err error
func GetReportListV1(condition string, pars []interface{}, startSize, pageSize int) (items []*ReportList, err error) {
	o := global.DbMap[utils.DbNameReport]

	sql := `SELECT * FROM report as a WHERE 1=1  `
	if condition != "" {
		sql += condition
	}
	// 排序：1:未发布；2:已发布；3-待提交；4-待审批；5-已驳回；6-已通过
	sql += ` ORDER BY FIELD(state,3,1,4,5,6,2), modify_time DESC LIMIT ?,?`
	pars = append(pars, startSize, pageSize)
	err = o.Raw(sql, pars...).Find(&items).Error
	return
}

// GetReportListByCondition 获取报告列表
func GetReportListByCondition(condition string, pars []interface{}, startSize, pageSize int) (items []*ReportList, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT DISTINCT a.id, a.title, a.author, a.modify_time, a.publish_time,a.classify_id_first,
a.classify_name_first,a.classify_id_second,a.classify_name_second,a.classify_id_third,
a.classify_name_third,a.abstract,a.admin_id,a.admin_real_name,a.last_modify_admin_id,a.last_modify_admin_name,a.report_code FROM report as a WHERE 1=1  `
	if condition != "" {
		sql += condition
	}
	sql += ` LIMIT ?,?`
	pars = append(pars, startSize, pageSize)
	err = o.Raw(sql, pars...).Find(&items).Error
	return
}

type ReportPvUv struct {
	ReportId int
	PvTotal  int
	UvTotal  int
}

func GetReportPvUvByReportIdList(reportIdList []int) (items []ReportPvUv, err error) {
	num := len(reportIdList)
	if num <= 0 {
		return
	}
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT report_id, COUNT(1) as pv_total,COUNT(DISTINCT user_id) as uv_total  FROM report_view_record  WHERE report_id in (` + utils.GetOrmInReplace(num) + `) GROUP BY report_id`
	err = o.Raw(sql, reportIdList).Find(&items).Error
	return
}

// GetReportListCountByGrant
// @Description: 获取共享报告列表的报告数量
// @author: Roc
// @datetime 2024-05-30 15:14:01
// @param condition string
// @param pars []interface{}
// @return count int
// @return err error
func GetReportListCountByGrant(condition string, pars []interface{}) (count int, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT a.id  FROM report as a 
    JOIN report_grant b on a.id=b.report_id 
 WHERE 1=1  `
	if condition != "" {
		sql += condition
	}
	sql += " GROUP BY a.id "
	sql = `SELECT COUNT(1) AS count  FROM (` + sql + `) d`
	var countNull sql2.NullInt64
	err = o.Raw(sql, pars...).Scan(&countNull).Error
	if err != nil {
		return
	}
	if countNull.Valid {
		count = int(countNull.Int64)
	}
	return
}

// GetReportListByGrant
// @Description: 获取共享报告列表的数据
// @author: Roc
// @datetime 2024-05-30 15:15:07
// @param condition string
// @param pars []interface{}
// @param startSize int
// @param pageSize int
// @return items []*ReportList
// @return err error
func GetReportListByGrant(condition string, pars []interface{}, startSize, pageSize int) (items []*ReportList, err error) {
	o := global.DbMap[utils.DbNameReport]

	sql := `SELECT a.* FROM report as a JOIN report_grant b on a.id = b.report_id  WHERE 1=1  `
	if condition != "" {
		sql += condition
	}
	// 排序：1:未发布；2:已发布；3-待提交；4-待审批；5-已驳回；6-已通过
	sql += `  GROUP BY a.id ORDER BY 
    CASE COALESCE(a.state,0)
        WHEN 3 THEN 1
        WHEN 1 THEN 2
        WHEN 4 THEN 3
        WHEN 5 THEN 4
        WHEN 6 THEN 5
        WHEN 2 THEN 6
        ELSE 7
    END, a.modify_time DESC LIMIT ?,?`

	pars = append(pars, startSize, pageSize)
	err = o.Raw(sql, pars...).Find(&items).Error
	return
}

func GetReportListCount(condition string, pars []interface{}) (count int, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT COUNT(1) AS count  FROM report WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	var countNull sql2.NullInt64
	err = o.Raw(sql, pars...).Scan(&countNull).Error
	if err != nil {
		return
	}
	if countNull.Valid {
		count = int(countNull.Int64)
	}
	return
}

//func GetReportList(condition string, pars []interface{}, startSize, pageSize int) (items []*ReportList, err error) {
//	o := global.DbMap[utils.DbNameReport]
//	sql := `SELECT *,
//        (SELECT COUNT(1) FROM report_view_record AS rvr WHERE rvr.report_id=report.id) AS pv,
//        (SELECT COUNT(DISTINCT user_id) FROM report_view_record AS rvr WHERE rvr.report_id=report.id) AS uv
//        FROM report WHERE 1=1  `
//	if condition != "" {
//		sql += condition
//	}
//	// 排序：1:未发布；2:已发布；3-待提交；4-待审批；5-已驳回；6-已通过
//	sql += `ORDER BY FIELD(state,3,1,4,5,6,2), modify_time DESC LIMIT ?,?`
//	err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
//	return
//}

// PublishReport 发布报告
//func PublishReport(reportIds []int) (err error) {
//	if len(reportIds) == 0 {
//		return
//	}
//	o := global.DbMap[utils.DbNameReport]
//	sql := `UPDATE report SET state=2,publish_time=now(),modify_time=NOW() WHERE id IN (` + utils.GetOrmInReplace(len(reportIds)) + `)`
//	err = o.Raw(sql).Error
//	return
//}

// PublishCancelReport 取消发布报告
func PublishCancelReport(reportId, state int, publishTimeNullFlag bool, lastModifyAdminId int, lastModifyAdminName string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	var sql string
	if publishTimeNullFlag {
		sql = ` UPDATE report SET state=?, publish_time=null, pre_publish_time=null, pre_msg_send=0,last_modify_admin_id=?,last_modify_admin_name=?,modify_time = NOW() WHERE id =?`
	} else {
		sql = ` UPDATE report SET state=?, pre_publish_time=null, pre_msg_send=0,last_modify_admin_id=?,last_modify_admin_name=?,modify_time = NOW() WHERE id =?`
	}
	err = o.Exec(sql, state, lastModifyAdminId, lastModifyAdminName, reportId).Error
	return
}

// 删除报告
func DeleteReport(reportIds int) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := ` DELETE FROM report WHERE id =? `
	err = o.Exec(sql, reportIds).Error
	return
}

type ReportDetail struct {
	Id                 int    `gorm:"column:id;primaryKey;autoIncrement" description:"报告Id"`
	AddType            int    `description:"新增方式：1:新增报告，2:继承报告"`
	ClassifyIdFirst    int    `description:"一级分类id"`
	ClassifyNameFirst  string `description:"一级分类名称"`
	ClassifyIdSecond   int    `description:"二级分类id"`
	ClassifyNameSecond string `description:"二级分类名称"`
	Title              string `description:"标题"`
	Abstract           string `description:"摘要"`
	Author             string `description:"作者"`
	Frequency          string `description:"频度"`
	CreateTime         string `description:"创建时间"`
	ModifyTime         string `description:"修改时间"`
	State              int    `description:"1:未发布，2:已发布"`
	PublishTime        string `description:"发布时间"`
	PrePublishTime     string `description:"预发布时间"`
	Stage              int    `description:"期数"`
	MsgIsSend          int    `description:"消息是否已发送，0:否，1:是"`
	PreMsgSend         int    `description:"定时发布成功后是否立即推送模版消息：0否，1是"`
	Content            string `description:"内容"`
	VideoUrl           string `description:"音频文件URL"`
	VideoName          string `description:"音频文件名称"`
	VideoPlaySeconds   string `description:"音频播放时长"`
	ContentSub         string `description:"内容前两个章节"`
	ThsMsgIsSend       int    `description:"客户群消息是否已发送，0:否，1:是"`
	HasChapter         int    `description:"是否有章节 0-否 1-是"`
	ChapterType        string `description:"章节类型 day-晨报 week-周报"`
	AdminId            int    `description:"创建者账号"`
	AdminRealName      string `description:"创建者姓名"`
	ReportCode         string `description:"报告唯一编码"`

	// eta1.8.3（研报改版）相关内容
	ContentStruct       string    `description:"内容组件"`
	LastModifyAdminId   int       `description:"最后更新人ID"`
	LastModifyAdminName string    `description:"最后更新人姓名"`
	ContentModifyTime   time.Time `description:"内容更新时间"`
	Pv                  int       `description:"pv"`
	Uv                  int       `description:"uv"`
	HeadImg             string    `description:"报告头图地址"`
	EndImg              string    `description:"报告尾图地址"`
	HeadStyle           string    `description:"版头样式"`
	EndStyle            string    `description:"版尾样式"`
	CanvasColor         string    `description:"画布颜色"`
	NeedSplice          int       `description:"是否拼接版头版位的标记，主要是为了兼容历史报告。0-不需要 1-需要"`
	HeadResourceId      int       `description:"版头资源ID"`
	EndResourceId       int       `description:"版尾资源ID"`
	ClassifyIdThird     int       `description:"三级分类id"`
	ClassifyNameThird   string    `description:"三级分类名称"`
	CollaborateType     int8      `description:"协作方式，1：个人，2：多人协作。默认：1"`
	ReportLayout        int8      `description:"报告布局，1：常规布局，2：智能布局。默认：1"`
	IsPublicPublish     int8      `description:"是否公开发布，1：是，2：否"`
	ReportCreateTime    time.Time `description:"报告时间创建时间"`
	RaiReportId         int       `description:"RAI报告ID"`
	FreeLayoutConfig    string    `description:"'自由布局配置"`
	MiniShow            int       `description:"是否在C端展示：0-否；1-是"`
	FreeReportRatio     string    `description:"自由布局页面比例：A4; 16:9; 4:3; 10:7"`
}

func (m *ReportDetail) AfterFind(db *gorm.DB) (err error) {
	m.CreateTime = utils.GormDateStrToDateTimeStr(m.CreateTime)
	m.ModifyTime = utils.GormDateStrToDateTimeStr(m.ModifyTime)
	m.PublishTime = utils.GormDateStrToDateTimeStr(m.PublishTime)
	m.PrePublishTime = utils.GormDateStrToDateTimeStr(m.PrePublishTime)

	return
}
func (m *ReportDetail) ConvertTimeStr() {
	m.CreateTime = utils.GormDateStrToDateTimeStr(m.CreateTime)
	m.ModifyTime = utils.GormDateStrToDateTimeStr(m.ModifyTime)
	m.PublishTime = utils.GormDateStrToDateTimeStr(m.PublishTime)
	m.PrePublishTime = utils.GormDateStrToDateTimeStr(m.PrePublishTime)

	return
}

func GetReportById(reportId int) (item *ReportDetail, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT * FROM report WHERE id=?`
	err = o.Raw(sql, reportId).First(&item).Error
	if err != nil {
		return
	}
	item.ConvertTimeStr()
	return
}

func GetReportByIds(reportIds string) (list []*ReportDetail, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT * FROM report WHERE id in ` + reportIds
	err = o.Raw(sql).Find(&list).Error
	return
}

// GetSimpleReportByIds 根据报告ID查询报告基本信息
func GetSimpleReportByIds(reportIds []int) (list []*Report, err error) {
	if len(reportIds) == 0 {
		return
	}
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT id, title, report_code FROM report WHERE id IN (` + utils.GetOrmInReplace(len(reportIds)) + `)`
	err = o.Raw(sql, reportIds).Find(&list).Error
	return
}

// GetReportStage
// @Description: 获取报告的最大期数（每一年的最大期数）
// @author: Roc
// @datetime 2024-06-03 17:44:14
// @param classifyIdFirst int
// @param classifyIdSecond int
// @param classifyIdThird int
// @return count int
// @return err error
func GetReportStage(classifyIdFirst, classifyIdSecond, classifyIdThird int) (count int, err error) {
	o := global.DbMap[utils.DbNameReport]
	classifyId := classifyIdThird
	if classifyId <= 0 {
		classifyId = classifyIdSecond
	}
	if classifyId <= 0 {
		classifyId = classifyIdFirst
	}
	if classifyId <= 0 {
		err = errors.New("错误的分类id")
		return
	}
	yearStart := time.Date(time.Now().Local().Year(), 1, 1, 0, 0, 0, 0, time.Local)

	sql := `SELECT MAX(stage) AS max_stage FROM report WHERE create_time > ? `
	if classifyIdThird > 0 {
		sql += " AND classify_id_third = ? "
	} else if classifyIdSecond > 0 {
		sql += " AND classify_id_second = ? "
	} else {
		sql += " AND classify_id_first = ? "
	}

	var maxNull sql2.NullInt64
	err = o.Raw(sql, yearStart, classifyId).Scan(&maxNull).Error
	if err != nil {
		return
	}
	if maxNull.Valid {
		count = int(maxNull.Int64)
	}
	return
}

// GetReportStageEdit
// @Description: 获取报告的最大期数（每一年的最大期数）
// @author: Roc
// @datetime 2024-06-04 13:50:34
// @param classifyIdFirst int
// @param classifyIdSecond int
// @param classifyIdThird int
// @param reportId int
// @return count int
// @return err error
//func GetReportStageEdit(classifyIdFirst, classifyIdSecond, classifyIdThird, reportId int) (count int, err error) {
//	classifyId := classifyIdThird
//	if classifyId <= 0 {
//		classifyId = classifyIdSecond
//	}
//	if classifyId <= 0 {
//		classifyId = classifyIdFirst
//	}
//	if classifyId <= 0 {
//		err = errors.New("错误的分类id")
//		return
//	}
//	yearStart := time.Date(time.Now().Local().Year(), 1, 1, 0, 0, 0, 0, time.Local)
//
//	sql := `SELECT MAX(stage) AS max_stage FROM report WHERE create_time > ? AND id<>?  `
//	if classifyIdThird > 0 {
//		sql += " AND classify_id_third = ? "
//	} else if classifyIdSecond > 0 {
//		sql += " AND classify_id_second = ? "
//	} else {
//		sql = " AND classify_id_first = ? "
//	}
//
//	o := global.DbMap[utils.DbNameReport]
//	o.Raw(sql, yearStart, reportId, classifyId).QueryRow(&count)
//
//	return
//}

type PublishReq struct {
	ReportIds string `description:"报告id,多个用英文逗号隔开"`
	ReportUrl string `description:"报告Url"`
}

type PublishCancelReq struct {
	ReportIds int `description:"报告id"`
}

type DeleteReq struct {
	ReportIds int `description:"报告id"`
}

type AddReq struct {
	AddType            int    `description:"新增方式：1:新增报告，2:继承报告"`
	ClassifyIdFirst    int    `description:"一级分类id"`
	ClassifyNameFirst  string `description:"一级分类名称"`
	ClassifyIdSecond   int    `description:"二级分类id"`
	ClassifyNameSecond string `description:"二级分类名称"`
	ClassifyIdThird    int    `description:"三级分类id"`
	ClassifyNameThird  string `description:"三级分类名称"`
	Title              string `description:"标题"`
	Abstract           string `description:"摘要"`
	Author             string `description:"作者"`
	Frequency          string `description:"频度"`
	State              int    `description:"状态：1:未发布，2:已发布"`
	Content            string `description:"内容"`
	CreateTime         string `description:"创建时间"`
	ReportVersion      int    `description:"1:旧版,2:新版"`
	ContentStruct      string `description:"内容组件"`
	HeadImg            string `description:"报告头图地址"`
	EndImg             string `description:"报告尾图地址"`
	CanvasColor        string `description:"画布颜色"`
	NeedSplice         int    `description:"是否拼接版头版位的标记，主要是为了兼容历史报告。0-不需要 1-需要"`
	HeadResourceId     int    `description:"版头资源ID"`
	EndResourceId      int    `description:"版尾资源ID"`
	CollaborateType    int8   `description:"协作方式，1：个人，2：多人协作。默认：1"`
	ReportLayout       int8   `description:"报告布局，1：常规布局，2：智能布局,3:自由布局。默认：1"`
	IsPublicPublish    int8   `description:"是否公开发布，1：是，2：否"`
	InheritReportId    int    `description:"待继承的报告ID"`
	GrantAdminIdList   []int  `description:"授权用户id列表"`
	MiniShow           int    `description:"是否在C端展示：0-否；1-是"`
	FreeReportRatio    string `description:"自由布局页面比例：A4; 16:9; 4:3; 10:7"`
}

type PrePublishReq struct {
	ReportId       int    `description:"报告id"`
	PrePublishTime string `description:"预发布时间"`
	PreMsgSend     int    `description:"定时发布成功后是否立即推送模版消息：0否，1是"`
	ReportUrl      string `description:"报告Url"`
}

type AddResp struct {
	ReportId   int64  `description:"报告id"`
	ReportCode string `description:"报告code"`
}

func AddReport(item *Report) (lastId int64, err error) {
	o := global.DbMap[utils.DbNameReport]
	err = o.Create(item).Error
	if err != nil {
		return
	}
	lastId = int64(item.Id)
	return
}

type EditReq struct {
	ReportId           int64  `description:"报告id"`
	ClassifyIdFirst    int    `description:"一级分类id"`
	ClassifyNameFirst  string `description:"一级分类名称"`
	ClassifyIdSecond   int    `description:"二级分类id"`
	ClassifyNameSecond string `description:"二级分类名称"`
	ClassifyIdThird    int    `description:"三级分类id"`
	ClassifyNameThird  string `description:"三级分类名称"`
	Title              string `description:"标题"`
	Abstract           string `description:"摘要"`
	Author             string `description:"作者"`
	Frequency          string `description:"频度"`
	State              int    `description:"状态：1:未发布，2:已发布"`
	Content            string `description:"内容"`
	CreateTime         string `description:"创建时间"`
	ContentStruct      string `description:"内容组件"`
	HeadImg            string `description:"报告头图地址"`
	EndImg             string `description:"报告尾图地址"`
	CanvasColor        string `description:"画布颜色"`
	NeedSplice         int    `description:"是否拼接版头版位的标记，主要是为了兼容历史报告。0-不需要 1-需要"`
	HeadResourceId     int    `description:"版头资源ID"`
	EndResourceId      int    `description:"版尾资源ID"`
	//CollaborateType    int8   `description:"协作方式，1：个人，2：多人协作。默认：1"`
	//ReportLayout       int8   `description:"报告布局，1：常规布局，2：智能布局，3：自由布局。默认：1"`
	IsPublicPublish  int8   `description:"是否公开发布，1：是，2：否"`
	GrantAdminIdList []int  `description:"授权用户id列表"`
	MiniShow         int    `description:"是否在C端展示：0-否；1-是"`
	FreeReportRatio  string `description:"自由布局页面比例：A4; 16:9; 4:3; 10:7"`
}

type EditResp struct {
	ReportId   int64  `description:"报告id"`
	ReportCode string `description:"报告code"`
}

func EditReport(item *Report, reportId int64) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `UPDATE report
			SET
			  classify_id_first =?,
			  classify_name_first = ?,
			  classify_id_second = ?,
			  classify_name_second = ?,
			  title = ?,
			  abstract = ?,
			  author = ?,
			  frequency = ?,
			  state = ?,
			  content = ?,
			  content_sub = ?,
			  stage =?,
			  create_time = ?,
			  modify_time = ?
			WHERE id = ? `
	err = o.Exec(sql, item.ClassifyIdFirst, item.ClassifyNameFirst, item.ClassifyIdSecond, item.ClassifyNameSecond, item.Title,
		item.Abstract, item.Author, item.Frequency, item.State, item.Content, item.ContentSub, item.Stage, item.CreateTime, time.Now(), reportId).Error
	return
}

func (m *Report) Update(cols []string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	err = o.Select(cols).Updates(m).Error
	return
}

type ReportDetailReq struct {
	ReportId int `description:"报告id"`
}

type ClassifyIdDetailReq struct {
	ClassifyIdFirst  int `description:"报告一级分类id"`
	ClassifyIdSecond int `description:"报告二级分类id"`
}

func GetReportDetailByClassifyId(classifyIdFirst, classifyIdSecond int) (item *Report, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := ` SELECT * FROM report WHERE 1=1 `
	if classifyIdSecond > 0 {
		sql = sql + ` AND classify_id_second=?   ORDER BY stage DESC LIMIT 1`
		err = o.Raw(sql, classifyIdSecond).First(&item).Error
	} else {
		sql = sql + ` AND classify_id_first=?   ORDER BY stage DESC LIMIT 1`
		err = o.Raw(sql, classifyIdFirst).First(&item).Error
	}
	if err != nil {
		return
	}
	item.ConvertTimeStr()
	return
}

type SendTemplateMsgReq struct {
	ReportId int `description:"报告id"`
}

// SendTemplateMsgResp
// @Description: 报告推送返回结构体
type SendTemplateMsgResp struct {
	ReportId    int    `description:"报告id"`
	MsgSendTime string `description:"报告推送时间"`
}

func ModifyReportMsgIsSend(reportId int) (err error) {
	o := global.DbMap[utils.DbNameReport]
	report, err := GetReportById(reportId)
	if err != nil {
		return
	}
	if report.MsgIsSend == 0 {
		sql := `UPDATE report SET msg_is_send = 1, msg_send_time=NOW()  WHERE id = ? `
		err = o.Exec(sql, reportId).Error
	}
	return
}

func ModifyReportVideo(reportId int, videoUrl, videoName, videoSize string, playSeconds float64) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `UPDATE report SET video_url=?,video_name=?,video_play_seconds=?,video_size=? WHERE id=? `
	err = o.Exec(sql, videoUrl, videoName, playSeconds, videoSize, reportId).Error
	return
}

// ModifyReportVideoByNoVideo
// @Description: 修改无音频的报告音频信息
// @author: Roc
// @datetime 2024-07-25 18:03:05
// @param reportId int
// @param videoUrl string
// @param videoName string
// @param videoSize string
// @param playSeconds float64
// @return err error
func ModifyReportVideoByNoVideo(reportId int, videoUrl, videoName, videoSize string, playSeconds float64) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `UPDATE report SET video_url=?,video_name=?,video_play_seconds=?,video_size=? WHERE id=? AND video_url=""`
	err = o.Exec(sql, videoUrl, videoName, playSeconds, videoSize, reportId).Error
	return
}

type ReportItem struct {
	Id                 int       `gorm:"column:id;primaryKey;autoIncrement" description:"报告Id"`
	AddType            int       `description:"新增方式：1:新增报告，2:继承报告"`
	ClassifyIdFirst    int       `description:"一级分类id"`
	ClassifyNameFirst  string    `description:"一级分类名称"`
	ClassifyIdSecond   int       `description:"二级分类id"`
	ClassifyNameSecond string    `description:"二级分类名称"`
	Title              string    `description:"标题"`
	Abstract           string    `description:"摘要"`
	Author             string    `description:"作者"`
	Frequency          string    `description:"频度"`
	CreateTime         time.Time `description:"创建时间"`
	ModifyTime         time.Time `description:"修改时间"`
	State              int       `description:"1:未发布，2:已发布"`
	PublishTime        time.Time `description:"发布时间"`
	Stage              int       `description:"期数"`
	MsgIsSend          int       `description:"消息是否已发送，0:否，1:是"`
	Content            string    `description:"内容"`
	VideoUrl           string    `description:"音频文件URL"`
	VideoName          string    `description:"音频文件名称"`
	VideoPlaySeconds   string    `description:"音频播放时长"`
	ContentSub         string    `description:"内容前两个章节"`
}

//func GetReportItemById(reportId int) (item *ReportItem, err error) {
//	o := global.DbMap[utils.DbNameReport]
//	sql := `SELECT * FROM report WHERE id=?`
//	err = o.Raw(sql, reportId).First(&item).Error
//	return
//}

type SaveReportContent struct {
	Content  string `description:"内容"`
	ReportId int    `description:"报告id"`
	NoChange int    `description:"内容是否未改变：1：内容未改变"`
	// 以下是智能研报相关
	ContentStruct  string `description:"内容组件"`
	HeadImg        string `description:"报告头图地址"`
	EndImg         string `description:"报告尾图地址"`
	CanvasColor    string `description:"画布颜色"`
	NeedSplice     int    `description:"是否拼接版头版位的标记，主要是为了兼容历史报告。0-不需要 1-需要"`
	HeadResourceId int    `description:"版头资源ID"`
	EndResourceId  int    `description:"版尾资源ID"`
	//自由布局相关
	FreeLayoutContentPages []report.ContentPage `description:"自由布局页面数据"`
	FreeLayoutConfig       string               `description:"自由布局配置"`
}

//func EditReportContent(reportId int, content, contentSub string) (err error) {
//	o := global.DbMap[utils.DbNameReport]
//	sql := ` UPDATE report SET content=?,content_sub=?,modify_time=NOW() WHERE id=? `
//	err = o.Exec(sql, content, contentSub, reportId).Error
//	return
//}

func AddReportSaveLog(reportId, adminId int, content, contentSub, contentStruct, canvasColor, adminName string, headResourceId, endResourceId int) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := ` INSERT INTO report_save_log(report_id, content,content_sub,content_struct,canvas_color,head_resource_id,end_resource_id,admin_id,admin_name) VALUES (?,?,?,?,?,?,?,?,?) `
	err = o.Exec(sql, reportId, content, contentSub, contentStruct, canvasColor, headResourceId, endResourceId, adminId, adminName).Error
	return
}

func MultiAddReportChaptersSaveLog(items []*ReportChapter, adminId int, adminRealName string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `INSERT INTO report_save_log(report_id, report_chapter_id, content, content_sub,content_struct,admin_id, admin_name) VALUES (?,?,?,?,?,?,?)`
	for _, v := range items {
		err = o.Exec(sql, v.ReportId, v.ReportChapterId, v.Content, v.ContentSub, v.ContentStruct, adminId, adminRealName).Error
		if err != nil {
			return
		}
	}
	return
}

type SaveReportContentResp struct {
	ReportId int `description:"报告id"`
}

func ModifyReportCode(reportId int64, reportCode string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `UPDATE report SET report_code=? WHERE id=? `
	err = o.Exec(sql, reportCode, reportId).Error
	return
}

func ModifyReportThsMsgIsSend(item *ReportDetail) (err error) {
	o := global.DbMap[utils.DbNameReport]
	if item.ThsMsgIsSend == 0 {
		sql := `UPDATE report SET ths_msg_is_send = 1 WHERE id = ? `
		err = o.Exec(sql, item.Id).Error
	}
	return
}

type ThsSendTemplateMsgReq struct {
	ReportId []int `description:"报告id"`
}

type PublishDayWeekReportReq struct {
	ReportId int `description:"报告ID"`
}

// SaveDayWeekReportReq 新增晨报周报请求体
type SaveDayWeekReportReq struct {
	ReportId   int    `description:"报告ID"`
	Title      string `description:"标题"`
	ReportType string `description:"一级分类ID"`
	Author     string `description:"作者"`
	CreateTime string `description:"创建时间"`
}

// GetDayWeekReportStage 获取晨报周报期数
//func GetDayWeekReportStage(classifyIdFirst int, yearStart time.Time) (count int, err error) {
//	o := global.DbMap[utils.DbNameReport]
//	sql := " SELECT MAX(stage) AS max_stage FROM report WHERE classify_id_first = ? AND create_time > ? "
//	o.Raw(sql, classifyIdFirst, yearStart).QueryRow(&count)
//	return
//}

// GetReportByReportId 主键获取报告
func GetReportByReportId(reportId int) (item *Report, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT * FROM report WHERE id = ?`
	err = o.Raw(sql, reportId).First(&item).Error
	if err != nil {
		return
	}
	item.ConvertTimeStr()
	return
}

// GetReportByOldReportId 根据老报告id主键获取报告
func GetReportByOldReportId(reportId int) (item *Report, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT * FROM report WHERE old_report_id = ?`
	err = o.Raw(sql, reportId).First(&item).Error
	if err != nil {
		return
	}
	item.ConvertTimeStr()
	return
}

// DeleteDayWeekReportAndChapter 删除晨周报及章节
func DeleteDayWeekReportAndChapter(reportId int) (err error) {
	to := global.DbMap[utils.DbNameReport].Begin()
	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()

	sql := ` DELETE FROM report WHERE id = ? LIMIT 1 `
	if err = to.Exec(sql, reportId).Error; err != nil {
		return
	}
	sql = ` DELETE FROM report_chapter WHERE report_id = ? `
	if err = to.Exec(sql, reportId).Error; err != nil {
		return
	}
	return
}

// UpdateReport 更新报告
func (reportInfo *Report) UpdateReport(cols []string) (err error) {
	err = global.DbMap[utils.DbNameReport].Select(cols).Updates(reportInfo).Error
	return
}

// ReportDetailView
// @Description: 晨周报详情
type ReportDetailView struct {
	*ReportDetail
	ChapterList            []*ReportChapter
	GrandAdminList         []ReportDetailViewAdmin
	PermissionList         []ReportDetailViewPermission
	FreeLayoutContentPages []*report.ContentPage
}

// ReportDetailViewAdmin
// @Description: 报告里面的授权人
type ReportDetailViewAdmin struct {
	AdminId   int
	AdminName string
}

// ReportDetailViewPermission
// @Description: 报告分类关联的品种权限
type ReportDetailViewPermission struct {
	PermissionId   int
	PermissionName string
}

//func GetUnPublishDayReport(startTime time.Time, endTime time.Time) (item *Report, err error) {
//	o := global.DbMap[utils.DbNameReport]
//	sql := ` SELECT
//				*
//			FROM
//				report AS a
//			WHERE
//				a.has_chapter = 1
//			AND a.chapter_type = "day"
//			AND a.state = 1
//			AND (
//				a.create_time BETWEEN ? AND ?
//			)
//			ORDER BY
//				a.create_time DESC
//			LIMIT 1 `
//	err = o.Raw(sql, startTime, endTime).First(&item).Error
//	return
//}

type ElasticReportDetail struct {
	ReportId           int    `description:"报告ID"`
	ReportChapterId    int    `description:"报告章节ID"`
	Title              string `description:"标题"`
	Abstract           string `description:"摘要"`
	BodyContent        string `description:"内容"`
	PublishTime        string `description:"发布时间"`
	PublishState       int    `description:"发布状态 1-未发布 2-已发布"`
	IsPublicPublish    int8   `description:"是否公开发布，1：是，2：否"`
	Author             string `description:"作者"`
	ClassifyIdFirst    int    `description:"一级分类ID"`
	ClassifyNameFirst  string `description:"一级分类名称"`
	ClassifyIdSecond   int    `description:"二级分类ID"`
	ClassifyNameSecond string `description:"二级分类名称"`
	ClassifyId         int    `description:"最小单元的分类ID"`
	ClassifyName       string `description:"最小单元的分类名称"`
	Categories         string `description:"关联的品种名称(包括品种别名)"`
	StageStr           string `description:"报告期数"`
}

// GetLastPublishDayWeekReport 获取上一篇已发布的晨周报
//func GetLastPublishDayWeekReport(chapterType string) (item *Report, err error) {
//	o := global.DbMap[utils.DbNameReport]
//	sql := ` SELECT * FROM report WHERE has_chapter = 1 AND chapter_type = ? AND state = 2 ORDER BY publish_time DESC LIMIT 1 `
//	err = o.Raw(sql, chapterType).First(&item).Error
//
//	return
//}

// GetNewReportExist
//func GetNewReportExist(oldReportId int) (item *Report, err error) {
//	o := global.DbMap[utils.DbNameReport]
//	sql := ` SELECT id FROM report WHERE old_report_id = ? LIMIT 1 `
//	err = o.Raw(sql, oldReportId).First(&item).Error
//	return
//}

// PublishReportAndChapter 发布报告及章节
func PublishReportAndChapter(reportInfo *Report, isPublishReport bool, cols []string) (err error) {
	to := global.DbMap[utils.DbNameReport].Begin()
	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()
	// 更新报告
	if isPublishReport {
		err = to.Select(cols).Updates(reportInfo).Error
		if err != nil {
			return
		}
	}

	// 发布该报告的所有章节
	sql := ` UPDATE report_chapter SET publish_state = 2, publish_time = ? WHERE report_id = ?  `
	err = to.Exec(sql, reportInfo.PublishTime, reportInfo.Id).Error

	// 发布章节
	//if len(publishIds) > 0 {
	//	sql := ` UPDATE report_chapter SET publish_state = 2, publish_time = ? WHERE report_id = ? AND report_chapter_id IN (` + utils.GetOrmInReplace(len(publishIds)) + `) `
	//	err = to.Raw(sql, reportInfo.PublishTime, reportInfo.Id, publishIds).Error
	//}

	//if len(unPublishIds) > 0 {
	//	sql := ` UPDATE report_chapter SET publish_state = 1, publish_time = NULL, is_edit = 0 WHERE report_id = ? AND report_chapter_id IN (` + utils.GetOrmInReplace(len(unPublishIds)) + `) `
	//	err = to.Raw(sql, reportInfo.Id, unPublishIds).Error
	//}

	return
}

//func GetSyncEmptyVideoReport() (list []*Report, err error) {
//	o := global.DbMap[utils.DbNameReport]
//	sql := ` SELECT id FROM report WHERE old_report_id > 0 AND state = 2 AND chapter_type = "" AND (video_size = "" OR video_play_seconds = "")
//UNION ALL
//SELECT DISTINCT report_id FROM report_chapter WHERE publish_state = 2 AND (video_size = "" OR video_play_seconds = "") `
//	err = o.Raw(sql).Find(&list).Error
//	return
//}

// PublishReportById 发布报告
func PublishReportById(reportId int, publishTime time.Time, lastModifyAdminId int, lastModifyAdminName string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `UPDATE report SET state = 2, publish_time = ?, pre_publish_time=null, pre_msg_send=0, modify_time = NOW(),last_modify_admin_id=?,last_modify_admin_name=? WHERE id = ? `
	err = o.Exec(sql, publishTime, lastModifyAdminId, lastModifyAdminName, reportId).Error
	return
}

// ResetReportById 重置报告状态
func ResetReportById(reportId, state int, lastModifyAdminId int, lastModifyAdminName string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `UPDATE report SET state = ?, pre_publish_time = null, pre_msg_send = 0, modify_time = NOW(),last_modify_admin_id=?,last_modify_admin_name=? WHERE id = ?`
	err = o.Exec(sql, state, lastModifyAdminId, lastModifyAdminName, reportId).Error
	return
}

// GetCommentReportByReportId 查询有留言的报告列表
//func GetCommentReportByReportId(condition string, pars []interface{}, startSize, pageSize int) (list []*Report, err error) {
//	o := global.DbMap[utils.DbNameReport]
//	sql := `SELECT
//	id,
//	create_time,
//	title,
//	classify_name_first,
//	classify_id_first,
//	classify_name_second,
//	classify_id_second,
//	state,
//IF
//	( publish_time, publish_time, create_time ) AS publish_time
//FROM
//	report
//WHERE
//	1=1
//  `
//	if condition != "" {
//		sql += condition
//	}
//	sql += ` ORDER BY  publish_time DESC , title ASC LIMIT ?,?`
//	pars = append(pars, startSize, pageSize)
//	err = o.Raw(sql, pars...).Find(&list).Error
//	return
//}

// GetCommentReportByReportIdOrderBy 查询有留言的报告列表（指定排序）
//func GetCommentReportByReportIdOrderBy(condition string, pars []interface{}, startSize, pageSize int, orderBy string) (list []*Report, err error) {
//	o := global.DbMap[utils.DbNameReport]
//	sql := `SELECT
//	id,
//	create_time,
//	title,
//	classify_name_first,
//	classify_id_first,
//	classify_name_second,
//	classify_id_second,
//	state,
//IF
//	( publish_time, publish_time, create_time ) AS publish_time
//FROM
//	report
//WHERE
//	1=1
//  `
//	if condition != "" {
//		sql += condition
//	}
//	if orderBy == `` {
//		sql += ` ORDER BY  publish_time DESC , title ASC `
//	} else {
//		sql += orderBy
//	}
//	sql += ` LIMIT ?,? `
//	pars = append(pars, startSize, pageSize)
//	err = o.Raw(sql, pars...).Find(&list).Error
//	return
//}

// GetCommentReportTotalByReportId 查询有留言的报告列表总数
//func GetCommentReportTotalByReportId(condition string, pars []interface{}) (total int64, err error) {
//	o := global.DbMap[utils.DbNameReport]
//	sql := `SELECT count(*)
//        FROM report WHERE 1=1`
//	if condition != "" {
//		sql += condition
//	}
//	err = o.Raw(sql, pars...).QueryRow(&total)
//	return
//}

// LikeReportItem 点赞相关的报告列表
type LikeReportItem struct {
	ReportId              int       `description:"报告Id"`
	ReportChapterId       int       `description:"报告章节Id"`
	ClassifyIdFirst       int       `description:"一级分类id"`
	ClassifyNameFirst     string    `description:"一级分类名称"`
	ClassifyIdSecond      int       `description:"二级分类id"`
	ClassifyNameSecond    string    `description:"二级分类名称"`
	ReportChapterTypeId   int       `description:"章节类型"`
	ReportChapterTypeName string    `description:"品种名称"`
	PublishTime           time.Time `description:"发布时间" `
	Title                 string    `description:"标题"`
}

// GetLikeReportByReportIdReportChapterId 获取有被点赞的报告列表
//func GetLikeReportByReportIdReportChapterId(reportIds string, chapterIds string, orderStr string, startSize, pageSize int) (list []*LikeReportItem, err error) {
//	o := global.DbMap[utils.DbNameReport]
//	sql := `( SELECT
//id AS report_id,
//0 AS report_chapter_id,
//classify_id_first,
//classify_id_second,
//classify_name_first,
//classify_name_second,
//0 as report_chapter_type_id,
//"" as report_chapter_type_name,
//publish_time,
//title
//FROM
//	report
//WHERE
//	classify_name_first != "晨报"
//	AND classify_name_first != "周报"
//	AND id in (` + reportIds + `)
//	)
//UNION
//
//( SELECT
//report_id,
//report_chapter_id,
//classify_id_first,
//0 as classify_id_second,
//classify_name_first,
//null as classify_name_second,
//type_id as report_chapter_type_id,
//type_name as report_chapter_type_name,
//publish_time,
//title
//FROM
//	report_chapter
//WHERE
//	 report_chapter_id in (` + chapterIds + `)
//	)`
//	if orderStr != "" {
//		sql += ` ORDER BY FIELD(CONCAT(report_id, "-",report_chapter_id),` + orderStr + `)`
//	} else {
//		sql += ` ORDER BY  publish_time DESC, report_id Desc`
//	}
//	sql += ` LIMIT ?,?`
//	err = o.Raw(sql, startSize, pageSize).QueryRows(&list)
//	return
//}

// GetLikeReportTotalByReportIdReportChapterId 获取有被点赞的报告列表总数
//func GetLikeReportTotalByReportIdReportChapterId(reportIds string, chapterIds string) (total int64, err error) {
//	o := global.DbMap[utils.DbNameReport]
//	sql := `select count(*) from (( SELECT
//id AS report_id,
//0 AS report_chapter_id,
//classify_id_first,
//classify_id_second,
//classify_name_first,
//classify_name_second,
//0 as report_chapter_type_id,
//publish_time,
//title
//FROM
//	report
//WHERE
//	classify_name_first != "晨报"
//	AND classify_name_first != "周报"
//	AND id in (` + reportIds + `)
//	)
//UNION
//
//( SELECT
//report_id,
//report_chapter_id,
//classify_id_first,
//0 as classify_id_second,
//classify_name_first,
//null as classify_name_second,
//type_id as report_chapter_type_id,
//publish_time,
//title
//FROM
//	report_chapter
//WHERE
//report_chapter_id in (` + chapterIds + `)
//	)) r`
//	err = o.Raw(sql).QueryRow(&total)
//	return
//}

// GetPageReportList 分页获取报告列表
//func GetPageReportList(condition string, pars []interface{}, startSize, pageSize int) (total int, items []*ReportList, err error) {
//	o := global.DbMap[utils.DbNameReport]
//	sql := `SELECT * FROM report WHERE 1=1 `
//	sql += condition
//	sql += ` ORDER BY modify_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(&items)
//	return
//}

// SunCodeReq 获取太阳码请求体
type SunCodeReq struct {
	CodePage  string `json:"CodePage" description:"太阳码page"`
	CodeScene string `json:"CodeScene" description:"太阳码scene"`
}

// YbPcSuncode 活动海报表
type YbPcSuncode struct {
	SuncodeID  uint32    `gorm:"column:suncode_id;primaryKey;autoIncrement"`
	Scene      string    `gorm:"column:scene;type:varchar(255);not null;default:0" json:"scene"` // 微信scene
	SceneMd5   string    `gorm:"column:scene_md5;type:varchar(255);not null" json:"sceneMd5"`
	CodePage   string    `gorm:"column:code_page;type:varchar(255);not null;default:''" json:"codePage"`     // 路径
	SuncodeUrl string    `gorm:"column:suncode_url;type:varchar(255);not null;default:''" json:"suncodeUrl"` // 太阳码储存地址
	CreateTime time.Time `gorm:"column:create_time;type:timestamp;default:CURRENT_TIMESTAMP" json:"createTime"`
}

// GetYbPcSunCode 获取太阳码
func GetYbPcSunCode(scene, page string) (item *YbPcSuncode, err error) {
	o := global.DbMap[utils.DbNameWeekly]
	sql := `SELECT * FROM yb_pc_suncode WHERE scene = ? AND code_page = ? `
	err = o.Raw(sql, scene, page).First(&item).Error
	return
}

func AddYbPcSunCode(item *YbPcSuncode) (err error) {
	o := global.DbMap[utils.DbNameWeekly]
	err = o.Create(item).Error
	return
}

// YbSuncodePars 小程序太阳码scene参数
type YbSuncodePars struct {
	ID         uint32    `gorm:"column:id;primaryKey;autoIncrement"`
	Scene      string    `gorm:"column:scene;type:varchar(255);not null;default:''" json:"scene"`        // scene参数
	SceneKey   string    `gorm:"column:scene_key;type:varchar(32);not null;default:''" json:"scene_key"` // MD5值
	CreateTime time.Time `gorm:"column:create_time;type:datetime;default:CURRENT_TIMESTAMP" json:"createTime"`
}

func AddYbSuncodePars(item *YbSuncodePars) (err error) {
	o := global.DbMap[utils.DbNameWeekly]
	err = o.Create(item).Error
	return
}

// UpdateReportSecondClassifyNameByClassifyId 更新报告分类名称字段
func UpdateReportSecondClassifyNameByClassifyId(classifyId int, classifyName string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := " UPDATE report SET classify_name_second = ? WHERE classify_id_second = ? "
	err = o.Exec(sql, classifyName, classifyId).Error
	return
}

// UpdateReportFirstClassifyNameByClassifyId 更新报告分类一级名称字段
func UpdateReportFirstClassifyNameByClassifyId(classifyId int, classifyName string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := " UPDATE report SET classify_name_first = ? WHERE classify_id_first = ? "
	err = o.Exec(sql, classifyName, classifyId).Error
	return
}

// UpdateReportThirdClassifyNameByClassifyId 更新报告的三级分类名称字段
func UpdateReportThirdClassifyNameByClassifyId(classifyId int, classifyName string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := " UPDATE report SET classify_name_third = ? WHERE classify_id_third = ? "
	err = o.Exec(sql, classifyName, classifyId).Error
	return
}

// UpdateReportSecondClassifyFirstNameByClassifyId 更新报告二级分类的一级分类名称和id
//func UpdateReportSecondClassifyFirstNameByClassifyId(classifyId, newClassifyId int, classifyName string) (err error) {
//	o := global.DbMap[utils.DbNameReport]
//	sql := " UPDATE report SET classify_name_first = ?, classify_id_first = ? WHERE classify_id_second = ? "
//	err = o.Exec(sql, classifyName, newClassifyId, classifyId).Error
//	return
//}

// GetEmptyContentSubPPTReport 获取前两章为空的PPT报告
//func GetEmptyContentSubPPTReport() (list []*Report, err error) {
//	sql := `SELECT
//				r.id,
//				r.content,
//				r.content_sub
//			FROM
//				report AS r
//			JOIN ppt_v2 AS p ON r.id = p.report_id
//			WHERE
//				p.report_id > 0 AND r.content_sub = ""`
//	err = orm.NewOrmUsingDB("rddp").Raw(sql).QueryRows(&list)
//	return
//}

// ModifyReportAuthor 更改报告作者
func ModifyReportAuthor(condition string, pars []interface{}, authorName string) (count int, err error) {
	sql := `UPDATE english_report set author = ? WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	res := global.DbMap[utils.DbNameReport].Exec(sql, utils.ForwardPars(pars, authorName)...)
	if res.Error != nil {
		err = res.Error
		return
	}
	count = int(res.RowsAffected)
	return
}

func UpdateReportPublishTime(reportId int, videoNameDate string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql1 := ` UPDATE report SET publish_time = NOW() WHERE id = ?  `
	err = o.Exec(sql1, reportId).Error
	if err != nil {
		return
	}
	if utils.DbDriverName == utils.DbDriverByDm {
		//修改音频标题
		sql2 := ` UPDATE report SET video_name=CONCAT(
        CASE WHEN INSTR(video_name, '(') = 0 THEN video_name 
             ELSE SUBSTR(video_name, 1, INSTR(video_name, '(') - 1) END,
        "` + videoNameDate + `") WHERE id = ? and (video_name !='' and video_name is not null)`
		err = o.Exec(sql2, reportId).Error
	} else {
		//修改音频标题
		sql2 := ` UPDATE report SET video_name=CONCAT(SUBSTRING_INDEX(video_name,"(",1),"` + videoNameDate + `") WHERE id = ? and (video_name !="" and video_name is not null)`
		err = o.Exec(sql2, reportId).Error
	}
	return
}

func UpdateReportChapterPublishTime(reportId int, videoNameDate string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql1 := ` UPDATE report_chapter SET publish_time = NOW() WHERE report_id = ? `
	err = o.Exec(sql1, reportId).Error
	if err != nil {
		return
	}
	//修改音频标题
	sql2 := ` UPDATE report_chapter SET video_name=CONCAT(SUBSTRING_INDEX(video_name,"(",1),"` + videoNameDate + `") WHERE report_id = ? and (video_name !="" and video_name is not null)`
	err = o.Exec(sql2, reportId).Error
	return
}

// MarkEditReport 标记编辑英文研报的请求数据
type MarkEditReport struct {
	ReportId        int `description:"研报id"`
	ReportChapterId int `description:"研报章节id"`
	Status          int `description:"标记状态，1：编辑中，2：查询状态，3：编辑完成"`
}

type MarkReportResp struct {
	Status int    `description:"状态：0:无人编辑, 1：当前有人在编辑"`
	Msg    string `description:"提示信息"`
	Editor string `description:"编辑者姓名"`
}

type MarkReportItem struct {
	AdminId                 int    `description:"编辑者ID"`
	Editor                  string `description:"编辑者姓名"`
	ReportClassifyNameFirst string
}

// GetReportByCondition 获取报告
func GetReportByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string, isPage bool, startSize, pageSize int) (items []*Report, err error) {
	o := global.DbMap[utils.DbNameReport]
	fields := `*`
	if len(fieldArr) > 0 {
		fields = strings.Join(fieldArr, ",")
	}
	sql := `SELECT ` + fields + ` FROM report WHERE 1=1 `
	sql += condition
	order := ` ORDER BY modify_time DESC`
	if orderRule != `` {
		order = orderRule
	}
	sql += order
	if isPage {
		sql += ` LIMIT ?,?`
		pars = append(pars, startSize, pageSize)
		err = o.Raw(sql, pars...).Find(&items).Error
	} else {
		err = o.Raw(sql, pars...).Find(&items).Error
	}
	return
}

// ModifyReportMsgIsSendV2 更新报告消息状态
func ModifyReportMsgIsSendV2(reportId int) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `UPDATE report SET msg_is_send = 1, ths_msg_is_send = 1, msg_send_time = NOW() WHERE id = ? LIMIT 1`
	err = o.Exec(sql, reportId).Error
	return
}

// SetPrePublishReportById 设置定时发布
func SetPrePublishReportById(reportId int, prePublishTime string, preMsgSend int) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `UPDATE report SET pre_publish_time=?, pre_msg_send=? WHERE id = ? and state = 1 `
	err = o.Exec(sql, prePublishTime, preMsgSend, reportId).Error
	return
}

// ReportSubmitApproveReq 提交审批请求体
type ReportSubmitApproveReq struct {
	ReportId int `description:"报告ID"`
}

// ReportCancelApproveReq 撤回审批请求体
type ReportCancelApproveReq struct {
	ReportId int `description:"报告ID"`
}

func (m *Report) GetItemById(id int) (item *Report, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT * FROM report WHERE id = ? LIMIT 1`
	err = o.Raw(sql, id).First(&item).Error
	if err != nil {
		return
	}
	item.ConvertTimeStr()
	return
}

// GetReportStateCount 获取指定状态的报告数量
func GetReportStateCount(state int) (count int, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT COUNT(1) AS count FROM report WHERE state = ?`
	var countNull sql2.NullInt64
	err = o.Raw(sql, state).Scan(&countNull).Error
	if err != nil {
		return
	}
	if countNull.Valid {
		count = int(countNull.Int64)
	}
	return
}

// UpdateReportsStateByCond 批量更新报告状态
func UpdateReportsStateByCond(classifyFirstId, classifySecondId, classifyThirdId, oldState, newState int) (err error) {
	o := global.DbMap[utils.DbNameReport]
	cond := ``
	if classifyFirstId > 0 {
		cond += fmt.Sprintf(` AND classify_id_first = %d`, classifyFirstId)
	}
	if classifySecondId > 0 {
		cond += fmt.Sprintf(` AND classify_id_second = %d`, classifySecondId)
	}
	if classifyThirdId > 0 {
		cond += fmt.Sprintf(` AND classify_id_third = %d`, classifyThirdId)
	}
	sql := fmt.Sprintf(`UPDATE report SET state = ?, pre_publish_time = NULL WHERE state = ? %s`, cond)
	err = o.Exec(sql, newState, oldState).Error
	return
}

// UpdateReportsStateBySecondIds 批量更新二级分类报告状态
func UpdateReportsStateBySecondIds(oldState, newState int, secondIds []int) (err error) {
	if len(secondIds) <= 0 {
		return
	}
	o := global.DbMap[utils.DbNameReport]
	// (有审批流的)未发布->待提交
	sql := fmt.Sprintf(`UPDATE report SET state = ?, pre_publish_time = NULL WHERE state = ? AND classify_id_second IN (%s)`, utils.GetOrmInReplace(len(secondIds)))
	err = o.Exec(sql, newState, oldState, secondIds).Error
	if err != nil {
		return
	}
	// (无审批流的)待提交->未发布
	sql = fmt.Sprintf(`UPDATE report SET state = ?, pre_publish_time = NULL WHERE state = ? AND classify_id_second NOT IN (%s)`, utils.GetOrmInReplace(len(secondIds)))
	err = o.Exec(sql, oldState, newState, secondIds).Error
	return
}

// GetReportPdfUrlReq 获取报告pdf地址请求体
type GetReportPdfUrlReq struct {
	ReportUrl  string `description:"报告Url"`
	ReportCode string `description:"报告Code"`
	Type       int    `description:"类型 1-pdf 2-图片"`
}

func ModifyReportPdfUrl(reportId int, detailPdfUrl string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `UPDATE report SET detail_pdf_url=? WHERE id=? `
	err = o.Exec(sql, detailPdfUrl, reportId).Error
	return
}

func ModifyReportImgUrl(reportId int, detailImgUrl string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `UPDATE report SET detail_img_url=? WHERE id=? `
	err = o.Exec(sql, detailImgUrl, reportId).Error
	return
}

func ModifyReportPdfUrlMobile(reportId int, detailPdfUrlMobile string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `UPDATE report SET detail_pdf_url_mobile=? WHERE id=? `
	err = o.Exec(sql, detailPdfUrlMobile, reportId).Error
	return
}

func ModifyReportImgUrlMobile(reportId int, detailImgUrlMobile string) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `UPDATE report SET detail_img_url_mobile=? WHERE id=? `
	err = o.Exec(sql, detailImgUrlMobile, reportId).Error
	return
}

// UpdatePdfUrlReportById 清空pdf相关字段
func UpdatePdfUrlReportById(reportId int) (err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `UPDATE report SET detail_img_url = '',detail_pdf_url='',modify_time=NOW() WHERE id = ? `
	err = o.Exec(sql, reportId).Error
	return
}

// InsertMultiReport
// @Description: 批量新增报告
// @author: Roc
// @datetime 2024-06-27 15:55:25
// @param items []*Report
// @return err error
func InsertMultiReport(items []*Report) (err error) {
	o := global.DbMap[utils.DbNameReport]
	err = o.CreateInBatches(items, utils.MultiAddNum).Error
	return
}

// ReportLayout
// @Description: 报告布局
type ReportLayout struct {
	Id           int
	ReportLayout int8 `description:"报告布局，1：常规布局，2：智能布局。默认：1"`
}

// GetReportLayoutByReportId
// @Description: 根据报告id获取报告的布局
// @author: Roc
// @datetime 2024-07-15 15:27:05
// @param reportId int
// @return item ReportLayout
// @return err error
func GetReportLayoutByReportId(reportId int) (item ReportLayout, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT id, report_layout  FROM report  WHERE id = ? `
	err = o.Raw(sql, reportId).First(&item).Error
	return
}

func GetReportFieldsByIds(ids []int, fields []string) (items []*Report, err error) {
	if len(ids) == 0 {
		return
	}
	o := global.DbMap[utils.DbNameReport]
	field := " * "
	if len(fields) > 0 {
		field = fmt.Sprintf(" %s ", strings.Join(fields, ","))
	}
	sql := fmt.Sprintf(`SELECT %s FROM report WHERE id IN (%s)`, field, utils.GetOrmInReplace(len(ids)))
	err = o.Raw(sql, ids).Find(&items).Error
	return
}

// GetReportListByClassifyId 根据分类id 获取报告列表
func GetReportListByClassifyId(classifyId int) (items []*Report, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT * FROM report WHERE classify_id_first = ? or classify_id_second = ? or classify_id_third = ?`
	err = o.Raw(sql, classifyId, classifyId, classifyId).Find(&items).Error
	return items, err
}

func GetExistReportClassifyIdByClassifyIds(classifyIds []int) (existClassifyIds []*Report, err error) {
	if len(classifyIds) == 0 {
		return
	}
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT classify_id_first, classify_id_second, classify_id_third FROM report WHERE 1=1 `
	sql += fmt.Sprintf(` AND (classify_id_first IN (%s) OR classify_id_second IN (%s) OR classify_id_third IN (%s))`, utils.GetOrmInReplace(len(classifyIds)), utils.GetOrmInReplace(len(classifyIds)), utils.GetOrmInReplace(len(classifyIds)))
	err = o.Raw(sql, classifyIds, classifyIds, classifyIds).Find(&existClassifyIds).Error
	return
}

// UpdateReportInfo 修改报告
func UpdateReportInfo(reports *Report) (err error) {
	//o := global.DbMap[utils.DbNameReport]
	//err = o.Update(reports)
	//if err != nil {
	//	return err
	//}
	err = global.DbMap[utils.DbNameReport].Updates(reports).Error
	return
}

func FindReportListByCondition(condition string, pars []interface{}) (items []*Report, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT * FROM report WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	err = o.Raw(sql, pars...).Find(&items).Error
	return
}

type ReportShartUrlReq struct {
	Url      string `description:"分享链接"`
	ReportId int    `description:"报告ID"`
}

type ReportShartUrlResp struct {
	UrlToken string `description:"分享链接token"`
}

func GetAllPublishReportId() (items []int, err error) {
	o := global.DbMap[utils.DbNameReport]
	sql := `SELECT  a.id FROM report as a WHERE 1=1 AND state in (2,6) `
	err = o.Raw(sql).Find(&items).Error
	return
}

func InsertOrUpdateReportFreeLayoutContentPage(reportInfo *Report, ormList []*report.ReportFreeLayout) (err error) {
	tx := global.DbMap[utils.DbNameReport].Begin()

	defer func() {
		if err != nil {
			_ = tx.Rollback()
			return
		}
		_ = tx.Commit()
	}()
	reportUpdateCols := []string{"Content", "ContentSub", "ContentStruct", "HeadImg", "EndImg", "CanvasColor", "HeadResourceId", "EndResourceId", "ModifyTime", "ContentModifyTime", "FreeLayoutConfig"}
	err = tx.Model(&reportInfo).Select(reportUpdateCols).Updates(reportInfo).Error
	return report.BatchInsertOrUpdatePages(tx, ormList, false, reportInfo.Id, 0)
}
func UpdateChapterFreeLayoutContentPage(reportInfo *Report, chapterInfo *ReportChapter, updateCols []string, tickerList []*ReportChapterTicker, ormList []*report.ReportFreeLayout) (err error) {
	tx := global.DbMap[utils.DbNameReport].Begin()
	defer func() {
		if err != nil {
			_ = tx.Rollback()
			return
		}
		_ = tx.Commit()
	}()

	if err = tx.Model(&reportInfo).Select([]string{"LastModifyAdminId", "LastModifyAdminName", "ModifyTime", "FreeLayoutConfig"}).Updates(reportInfo).Error; err != nil {
		return
	}
	// 更新章节
	if err = tx.Model(&chapterInfo).Select(updateCols).Updates(chapterInfo).Error; err != nil {
		return
	}
	sql := ` DELETE FROM report_chapter_ticker WHERE report_chapter_id = ? `
	// 清空并新增章节ticker
	if err = tx.Exec(sql, chapterInfo.ReportChapterId).Error; err != nil {
		return
	}
	tickerLen := len(tickerList)
	if tickerLen > 0 {
		err = tx.CreateInBatches(tickerList, len(tickerList)).Error
		if err != nil {
			return
		}
	}
	return report.BatchInsertOrUpdatePages(tx, ormList, true, reportInfo.Id, chapterInfo.ReportChapterId)
}