hongze_yb/models/tables/rddp/report_chapter/query.go

package report_chapter

import (
	"hongze/hongze_yb/global"
	"hongze/hongze_yb/utils"
)

func GetLatestChaptersByTypeIdsAndClass(typeIds []int, classifyNameFirst string) (list []*ReportChapter, err error) {
	sql := `SELECT
	DISTINCT report_id
FROM
	report_chapter
WHERE
	type_id IN (?) 
	AND publish_state = 2 
	AND is_edit = 1
	AND report_type = ?
ORDER BY
	publish_time desc, report_chapter_id desc limit 30
`
	err = global.MYSQL["rddp"].Model(ReportChapter{}).Raw(sql, typeIds, classifyNameFirst).Scan(&list).Error
	return
}

// GetListByReportId 根据报告ID获取章节列表
func GetListByReportId(reportId int, classifyNameFirst string) (list []*ReportChapter, err error)  {
	var where string
	if  classifyNameFirst == "周报"{
		where = "report_id = ? AND is_edit = 1 AND publish_state = 2"
	}else{
		where = "report_id = ? AND publish_state = 2"
	}

	err = global.MYSQL["rddp"].Model(ReportChapter{}).
		Select("report_chapter_id, report_id, type_id, type_name, abstract, title, author, publish_time, trend").
		Where(where, reportId).
		Order("sort asc, report_chapter_id asc").
		Scan(&list).Error
	return
}

// GetListByReportIdTypeIds 根据报告ID、章节类型ID获取章节列表
func GetListByReportIdTypeIds(reportId int, typeIds []int, classifyNameFirst string) (list []*ReportChapter, err error)  {
	var where string
	if  classifyNameFirst == "周报"{
		where = "report_id = ? AND type_id in (?) AND is_edit = 1 AND publish_state = 2 "
	}else{
		where = "report_id = ? AND type_id in (?) AND publish_state = 2 "
	}

	err = global.MYSQL["rddp"].Model(ReportChapter{}).
		Select("report_chapter_id, report_id, type_id, type_name, abstract, title, author, publish_time").
		Where(where, reportId, typeIds).
		Order("sort asc, report_chapter_id asc").
		Scan(&list).Error
	return
}

// GetContentById 根据ID获取章节详情
func GetContentById(id int, typeIds []int) (info *ReportChapter, err error)  {
	err = global.MYSQL["rddp"].Model(ReportChapter{}).Select("report_chapter_id, report_id,  is_edit, classify_name_first, classify_id_first, content, trend, type_id, type_name, abstract, title, author, stage, publish_time, content, content_sub, video_url, video_name, video_play_seconds, video_size").
		Where("report_chapter_id = ? and type_id in (?) AND publish_state = 2 ", id, typeIds).
		First(&info).Error
	if err == utils.ErrNoRow {
		err = nil
	}
	return
}

// GetReportIdsByTypeIdsAndClass 根据章节ID获取报告ID
func GetReportIdsByTypeIdsAndClass(typeIds []int, classifyNameFirst string) (reportIds []int, err error) {
	var list []*ReportChapter
	err = global.MYSQL["rddp"].Model(ReportChapter{}).Select("DISTINCT report_id").Where("type_id in (?) and publish_state = 2 AND is_edit = 1 AND classify_name_first= ? ", typeIds, classifyNameFirst).Scan(&list).Error
	if err != nil {
		return
	}
	for _, v := range list {
		reportIds = append(reportIds, v.ReportId)
	}
	return
}

// GetTypeIdById 根据ID获取章节类型
func GetTypeIdById(id int) (info *ReportChapter, err error)  {
	err = global.MYSQL["rddp"].Model(ReportChapter{}).Select("report_chapter_id, type_id").
		Where("report_chapter_id = ? AND publish_state = 2 ", id).
		First(&info).Error
	if err == utils.ErrNoRow {
		err = nil
	}
	return
}


// GetByTypeIdsAndReportIds 根据章节ID和ReportIds查询报告
func GetByTypeIdsAndReportIds(typeIds []int,  reportIds []int, classifyNameFirst string) (list []*ReportChapter, err error) {
	var where string
	if  classifyNameFirst == "周报"{
		where = "report_id in (?) AND type_id in (?) AND is_edit = 1 AND publish_state = 2 "
	}else{
		where = "report_id in (?) AND type_id in (?) AND publish_state = 2 "
	}

	err = global.MYSQL["rddp"].Model(ReportChapter{}).
		Select("report_id, type_id, report_chapter_id, classify_name_first, classify_id_first, video_url, video_name, video_play_seconds, video_size, sort").
		Where(where, reportIds, typeIds).
		Order("sort asc, report_chapter_id asc").
		Scan(&list).Error
	if err != nil {
		return
	}
	for _, v := range list {
		reportIds = append(reportIds, v.ReportId)
	}
	return
}