hongze_clpt/models/report.go

package models

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

type IndustrialManagementList struct {
	Paging *paging.PagingItem
	List   []*IndustrialManagement
}

type IndustrialManagement struct {
	IndustrialManagementId int                  `orm:"column(industrial_management_id);pk" description:"产业id"`
	IndustryName           string               `description:"产业名称"`
	ChartPermissionId      int                  `description:"权限id"`
	ChartPermissionName    string               `description:"权限名称"`
	LayoutTime             string               `description:"布局时间"`
	UpdateTime             string               `description:"更新时间"`
	IsRed                  bool                 `description:"是否标记红点"`
	IsHot                  bool                 `description:"是否是热门"`
	IsFollow               bool                 `description:"是否关注"`
	IsNew                  bool                 `description:"是否展示 NEW 标签"`
	IsShowRoadshow         bool                 `description:"是否展示 微路演 标签"`
	ArticleReadNum         int                  `description:"文章阅读数量"`
	ArticleId              int                  `description:"文章id"`
	Source                 int                  `description:"来源 1:弘则资源包（报告）、2：研选主题（报告）"`
	IndustrialSubjectList  []*IndustrialSubject `description:"标的列表"`
	MinReportTime          string               `description:"报告最早发布时间"`
	IndustryVideo          *MicroVideoSimpleInfo
	AuthInfo               *UserPermissionAuthInfo
}

type MicroVideoSimpleInfo struct {
	Id                  int    `description:"视频ID"`
	Title               string `description:"标题"`
	ResourceUrl         string `description:"链接"`
	BackgroundImg       string `description:"背景图"`
	PlaySeconds         int    `description:"音视频时长"`
	DetailImgUrl        string `description:"产业详情页背景图"`
	ChartPermissionId   int    `description:"行业ID"`
	ChartPermissionName string `description:"行业名称"`
}

type TacticsListResp struct {
	Paging           *paging.PagingItem
	MatchTypeName    string `description:"匹配类型"`
	CategoryImgUrlPc string `description:"图片"`
	List             []*HomeArticle
}

// 报告搜索start
type ReoprtSearchResp struct {
	Paging *paging.PagingItem
	ListHz []*ArticleResearchResp `description:"弘则报告"`
	ListYx []*ArticleResearchResp `description:"研选报告"`
}

// 搜索资源包 start
type SearchResourceResp struct {
	ListHz []*IndustrialManagement `description:"弘则"`
	ListYx []*IndustrialManagement `description:"研选"`
}

// 获取列表数量
func GetReoprtSearchCount(condition string) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			COUNT( 1 ) AS count 
		FROM
			cygx_article AS a 
		WHERE
			1 = 1 
			AND a.article_id < 1000000 `
	if condition != "" {
		sql += condition
	}
	err = o.Raw(sql).QueryRow(&count)
	return
}

func GetReoprtSearchCountYx(condition string) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			COUNT( 1 ) AS count 
		FROM
			cygx_article AS a 
			INNER JOIN cygx_industrial_article_group_management AS mg ON mg.article_id = a.article_id
			INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = mg.industrial_management_id
			INNER JOIN cygx_article_department AS d ON d.department_id = a.department_id 
		WHERE
			1 = 1`
	if condition != "" {
		sql += condition
	}
	err = o.Raw(sql).QueryRow(&count)
	return
}

func GetReoprtSearchCountHz(condition string) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			COUNT( 1 ) AS count 
		FROM
			cygx_article AS a 
			INNER JOIN cygx_industrial_article_group_management AS mg ON mg.article_id = a.article_id
			INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = mg.industrial_management_id
		WHERE
			1 = 1`
	if condition != "" {
		sql += condition
	}
	err = o.Raw(sql).QueryRow(&count)
	return
}

// 列表
func GetReoprtSearchList(condition string, userId, startSize, pageSize int) (items []*ArticleCollectionResp, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			a.article_id,
			a.title,
			a.body,
			a.abstract,
			a.annotation,
			a.category_id,
			a.category_name,
			date_format( a.publish_date, '%Y-%m-%d' ) AS publish_date,
			m.industry_name,
			m.industrial_management_id,
			( SELECT count( 1 ) FROM cygx_article_history_record_newpv AS h WHERE h.article_id = a.article_id ) AS pv,
			( SELECT count( 1 ) FROM cygx_article_collect AS ac WHERE ac.article_id = a.article_id ) AS collect_num,
			( SELECT count( 1 ) FROM cygx_article_collect AS ac WHERE ac.article_id = a.article_id  AND user_id = ?) AS my_collect_num
		FROM
			cygx_article AS a
			LEFT JOIN cygx_industrial_article_group_management AS mg ON mg.article_id = a.article_id
			LEFT JOIN cygx_industrial_management AS m ON m.industrial_management_id = mg.industrial_management_id
		WHERE
			1 = 1 `
	if condition != "" {
		sql += condition
	}
	sql += ` GROUP BY  a.article_id  ORDER BY a.publish_date DESC  LIMIT ?,? `
	_, err = o.Raw(sql, userId, startSize, pageSize).QueryRows(&items)
	return
} //end

// 列表
func GetSearchResourceList(condition string) (items []*IndustrialManagement, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			m.industry_name,
			m.chart_permission_id,
			m.industrial_management_id,
 			MAX( a.publish_date ) as publish_date_order,
			MIN( a.publish_date ) AS min_report_time,
			date_format( MAX( a.publish_date ), '%Y-%m-%d' ) AS publish_date 
		FROM
			cygx_industrial_management AS m
			INNER JOIN cygx_industrial_article_group_management AS mg ON mg.industrial_management_id = m.industrial_management_id
			INNER JOIN cygx_article AS a ON a.article_id = mg.article_id  AND  a.article_type != 'lyjh'
		WHERE
			1 = 1
			AND publish_status = 1 ` + condition + `  GROUP BY m.industrial_management_id  ORDER BY publish_date_order DESC `
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// 标的列表
func GetThemeHeatSubjectList(condition string) (items []*IndustrialSubject, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			m.subject_name,
			m.industrial_management_id,
			m.industrial_subject_id 
		FROM
			cygx_article AS a
			INNER JOIN cygx_industrial_article_group_subject AS mg ON mg.article_id = a.article_id
			INNER JOIN cygx_industrial_subject AS m ON m.industrial_subject_id = mg.industrial_subject_id 
		WHERE
			1 = 1`
	if condition != "" {
		sql += condition
	}
	sql += ` AND publish_status = 1 
		GROUP BY
			m.industrial_subject_id 
		ORDER BY
			publish_date DESC`
	_, err = o.Raw(sql).QueryRows(&items)
	return
} //end

// 产业下所关联的文章分类列表
func IndustrialToArticleCategory(industrialManagementId, chartPermissionId int) (items []*IndustrialToArticleCategoryRep, err error) {
	o := orm.NewOrm()
	sql := `SELECT map.match_type_name,map.category_id
    FROM cygx_report_mapping AS map
	INNER JOIN cygx_article AS art ON art.category_id = map.category_id
	INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.article_id = art.article_id
	WHERE map.report_type = 2
	AND map.is_report = 1
    AND art.is_report = 1
    AND art.publish_status = 1
	AND man_g.industrial_management_id =?
	AND map.chart_permission_id = ?
	GROUP BY map.match_type_name`
	_, err = o.Raw(sql, industrialManagementId, chartPermissionId).QueryRows(&items)
	return
}

// 判断用户是否阅读该产业下，某一分类的文章
func IndustrialUserRecordArticleCount(userId, industrialManagementId, categoryId int) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT
	COUNT(1) count
FROM
	cygx_article_history_record 
WHERE
	article_id = ( SELECT article_id FROM cygx_article WHERE article_id IN (SELECT article_id FROM cygx_industrial_article_group_management WHERE industrial_management_id = ? ) AND category_id  IN (SELECT
	category_id 
FROM
	cygx_report_mapping 
WHERE
	chart_permission_id = any( SELECT chart_permission_id FROM cygx_report_mapping WHERE category_id = ? ) 
	AND match_type_name = any( SELECT match_type_name FROM cygx_report_mapping WHERE category_id = ? ) ) ORDER BY publish_date DESC LIMIT 0, 1 ) 
	AND user_id = ? `
	err = o.Raw(sql, industrialManagementId, categoryId, categoryId, userId).QueryRow(&count)
	return
}

// 获取最新文章
func GetNewIndustrialUserRecordArticle(industrialManagementId, categoryId int) (item *ArticleDetail, err error) {
	o := orm.NewOrm()
	sql := ` SELECT * FROM cygx_article WHERE article_id IN (SELECT article_id FROM cygx_industrial_article_group_management WHERE industrial_management_id = ? ) AND category_id  IN (SELECT
	category_id 
FROM
	cygx_report_mapping 
WHERE
	chart_permission_id = any( SELECT chart_permission_id FROM cygx_report_mapping WHERE category_id = ? ) 
	AND match_type_name = any( SELECT match_type_name FROM cygx_report_mapping WHERE category_id = ? ) ) ORDER BY publish_date DESC LIMIT 0, 1`
	err = o.Raw(sql, industrialManagementId, categoryId, categoryId).QueryRow(&item)
	return
}

// 列表
func GetReoprtSearchListHz(condition string, userId int) (items []*ArticleCollectionResp, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			a.article_id,
			a.title,
			a.annotation,
			date_format( a.publish_date, '%Y-%m-%d' ) AS publish_date,
			m.industry_name,
			m.industrial_management_id,
			( SELECT count( 1 ) FROM cygx_article_history_record_newpv AS h WHERE h.article_id = a.article_id ) AS pv,
			( SELECT count( 1 ) FROM cygx_article_collect AS ac WHERE ac.article_id = a.article_id ) AS collect_num,
			( SELECT count( 1 ) FROM cygx_article_collect AS ac WHERE ac.article_id = a.article_id  AND user_id = ?) AS my_collect_num
		FROM
			cygx_article AS a
			LEFT JOIN cygx_industrial_article_group_management AS mg ON mg.article_id = a.article_id
			LEFT JOIN cygx_industrial_management AS m ON m.industrial_management_id = mg.industrial_management_id
		WHERE
			1 = 1 `
	if condition != "" {
		sql += condition
	}
	_, err = o.Raw(sql, userId).QueryRows(&items)
	return
} //end

// 产业列表
func GetSearchResourceListHz(condition string, startSize, pageSize int) (items []*IndustrialManagementHotResp, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			m.industry_name,
			m.industrial_management_id,
 			MAX( a.publish_date ) as publish_date_order,
			date_format( MAX( a.publish_date ), '%Y-%m-%d' ) AS publish_date 
		FROM
			cygx_industrial_management AS m
			INNER JOIN cygx_industrial_article_group_management AS mg ON mg.industrial_management_id = m.industrial_management_id
			INNER JOIN cygx_article AS a ON a.article_id = mg.article_id  AND  a.article_type != 'lyjh'
		WHERE
			1 = 1
			AND publish_status = 1 ` + condition + `  GROUP BY m.industrial_management_id  ORDER BY publish_date_order DESC `

	if startSize > 0 || pageSize > 0 {
		sql += ` LIMIT ` + strconv.Itoa(startSize) + "," + strconv.Itoa(pageSize)
	}
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// 用户收藏榜start
type IndustrialManagementHotResp struct {
	IndustrialManagementId int                  `orm:"column(industrial_management_id);pk" description:"产业id"`
	IndustryName           string               `description:"产业名称"`
	IsFollow               bool                 `description:"是否关注"`
	FllowNum               int                  `description:"关注数量"`
	IsNew                  bool                 `description:"是否新标签"`
	IsHot                  bool                 `description:"是否新标签"`
	PublishDate            string               `description:"发布时间"`
	ArticleReadNum         int                  `description:"文章阅读数量"`
	Source                 int                  `description:"来源 1:弘则资源包（报告）、2：研选主题（报告）"`
	MinReportTime          string               `description:"报告最早发布时间"`
	IndustrialSubjectList  []*IndustrialSubject `description:"标的列表"`
}

// 搜索资源包 start
type SearchReportAndResourceResp struct {
	ListHzResource []*IndustrialManagement  `description:"弘则资源包"`
	ListHzReport   []*ArticleCollectionResp `description:"弘则报告"`
	Paging         *paging.PagingItem       `description:"弘则报告分页"`
}

// 报告收藏榜单列表
func GetReportCollectionBillboardList(limit int, pars []interface{}, condition string) (items []*ArticleListResp, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			ac.id,
			a.article_id,
			a.category_id,
			a.title,
			a.annotation,
			a.publish_date,
			m.chart_permission_name,
			COUNT(ac.id) AS collection_num
		FROM
			cygx_article AS a
			INNER JOIN cygx_report_mapping AS m ON m.category_id = a.category_id_two
			INNER JOIN cygx_article_collect AS ac ON ac.article_id = a.article_id 
		WHERE
			1 = 1 
			AND a.publish_status = 1 `
	if condition != "" {
		sql += condition
	}
	sql += ` GROUP BY a.article_id ORDER BY collection_num DESC, ac.id DESC, a.publish_date DESC`
	sql += ` LIMIT ?`
	_, err = o.Raw(sql, pars, limit).QueryRows(&items)
	return
}

// 研选报告收藏榜单列表
func GetReportCollectionBillboardListYx(limit int, pars []interface{}, condition string) (items []*ArticleListResp, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			ac.id,
			a.category_id,
			'买方研选' as chart_permission_name,
			a.article_id,
			a.title,
			a.body,
			a.annotation,
			a.abstract,
			a.publish_date,
			a.article_type_id,
			d.nick_name,
			d.department_id,
			( SELECT count( 1 ) FROM cygx_article_history_record_newpv AS h WHERE h.article_id = a.article_id ) AS pv,
			( SELECT count( 1 ) FROM cygx_article_collect AS ac  INNER JOIN wx_user as u ON  u.user_id = ac.user_id  WHERE ac.article_id = a.article_id  ) AS collect_num, 
			( SELECT count( 1 ) FROM cygx_article_collect AS ac  INNER JOIN wx_user as u ON  u.user_id = ac.user_id  WHERE ac.article_id = a.article_id AND DATE_SUB( CURDATE(), INTERVAL 30 DAY ) <= date( ac.create_time )  ) AS collection_num
		FROM
			cygx_article AS a
			INNER JOIN cygx_article_collect AS ac ON ac.article_id = a.article_id 
			INNER JOIN cygx_industrial_article_group_management AS mg ON mg.article_id = a.article_id
			INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = mg.industrial_management_id
			INNER JOIN cygx_article_department AS d ON d.department_id = a.department_id 
		WHERE
			1 = 1 
			AND a.publish_status = 1  `
	if condition != "" {
		sql += condition
	}
	sql += ` GROUP BY a.article_id ORDER BY collection_num DESC,  a.publish_date DESC`
	sql += ` LIMIT ?`
	_, err = o.Raw(sql, pars, limit).QueryRows(&items)
	return
}

// 获取产业报告+晨会点评列表
func GetTimeLineReportIndustrialList(industrialManagementId, startSize, pageSize int) (items []*HomeArticle, total int, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			a.id,
			a.article_id,
			a.title,
			a.publish_date 
		FROM
			cygx_article AS a
			INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.article_id = a.article_id 
		WHERE
			a.publish_status = 1 
			AND a.is_class = 1 
			AND man_g.industrial_management_id = ?  GROUP BY a.article_id  UNION ALL
		SELECT
			mmc.id,
			0,
			mmc.content AS title,
			mm.meeting_time AS publish_data 
		FROM
			cygx_morning_meeting_review_chapter AS mmc
			INNER JOIN cygx_morning_meeting_reviews AS mm 
		WHERE
			mm.id = mmc.meeting_id 
			AND mm.STATUS = 1 
			AND mmc.industry_id = ? `
	totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z `
	err = o.Raw(totalSql, industrialManagementId, industrialManagementId).QueryRow(&total)
	sql += ` ORDER BY publish_date DESC  LIMIT ?,? `
	_, err = o.Raw(sql, industrialManagementId, industrialManagementId, startSize, pageSize).QueryRows(&items)
	return
}

type TimeLineReportItem struct {
	Id              int    `description:"文章或晨报点评id"`
	Title           string `description:"标题"`
	PublishTime     string `description:"发布时间"`
	Content         string `description:"内容"`
	VideoUrl        string `description:"视频链接"`
	IsHaveVideo     bool   `description:"是否包含视频"`
	ImgUrlPc        string `description:"pc图片"`
	SubCategoryName string `description:"二级分类"`
	IsRed           bool   `description:"是否标红"`
	Readnum         int    `description:"阅读数量"`
}

// 获取产业报告+晨会点评列表
func GetTimeLineReportIndustrialListRed(userId, industrialManagementId, startSize, pageSize int) (items []*TimeLineReportItem, err error) {
	o := orm.NewOrm()
	sql := `SELECT
	* 
FROM
	(
		SELECT
		a.article_id AS id,
		a.title,
		a.publish_date AS publish_time,
		a.video_url,
		a.sub_category_name,
		'' AS content,
		( SELECT COUNT( 1 ) FROM cygx_article_history_record AS rec WHERE rec.user_id = ` + strconv.Itoa(userId) + ` AND rec.article_id = a.article_id ) AS readnum 
	FROM
		cygx_article AS a
		INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.article_id = a.article_id 
	WHERE
		a.publish_status = 1 
		AND a.is_class = 1 
		AND man_g.industrial_management_id = ? GROUP BY id UNION ALL
	SELECT
		mmc.id,
		'' AS title,
		mm.publish_time AS publish_time,
		'' AS video_url,
		'时间线' AS sub_category_name,
		mmc.content,
		0  AS readnum 
	FROM
		cygx_morning_meeting_review_chapter AS mmc
		INNER JOIN cygx_morning_meeting_reviews AS mm 
	WHERE
		mm.id = mmc.meeting_id 
		AND mm.STATUS = 1 
		AND mmc.industry_id = ? 
	) AS t 
`
	sql += ` ORDER BY 
	t.publish_time DESC LIMIT ?,? `
	_, err = o.Raw(sql, industrialManagementId, industrialManagementId, startSize, pageSize).QueryRows(&items)
	return
}

type IndustrialPublishdate struct {
	PublishDate            string `description:"发布时间"`
	IndustrialManagementId int    `description:"产业D"`
}

// 标的列表
func GetTimeLineReportIndustrialPublishdateList(industrialIdArr []int) (items []*IndustrialPublishdate, err error) {
	o := orm.NewOrm()
	sql := `SELECT	
			mmc.id,
			0,
			mmc.industry_id AS industrial_management_id,			
			mmc.content AS title,
			MAX( mm.meeting_time ) AS publish_date 
		FROM
			cygx_morning_meeting_review_chapter AS mmc
			INNER JOIN cygx_morning_meeting_reviews AS mm 
		WHERE
			mm.id = mmc.meeting_id 
			AND mm.STATUS = 1 
			AND mmc.industry_id IN (` + utils.GetOrmInReplace(len(industrialIdArr)) + `)
		GROUP BY industrial_management_id ORDER BY publish_date DESC  `
	_, err = o.Raw(sql, industrialIdArr).QueryRows(&items)
	return
}

// 报告榜单start
type ArticleReportBillboardResp struct {
	ArticleId      int    `description:"文章id"`
	Title          string `description:"标题"`
	PublishDate    string `description:"发布时间"`
	PermissionName string `description:"行业名称"`
	DepartmentId   int    `description:"作者Id"`
	NickName       string `description:"作者昵称"`
	IsCollect      bool   `description:"本人是否收藏"`
	Pv             int    `description:"PV"`
	CollectNum     int    `description:"收藏人数"`
	Source         int    `description:"来源 1:弘则资源包（报告）、2：研选主题（报告）"`
	List           []*IndustrialManagementIdInt
}

type ArticleReportBillboardLIstPageResp struct {
	List   []*ArticleReportBillboardResp
	Paging *paging.PagingItem
}

type ArticleResearchListResp struct {
	Paging *paging.PagingItem
	List   []*ArticleResearchResp
}

type ArticleResearchResp struct {
	ArticleId       int                          `description:"文章id"`
	Title           string                       `description:"标题"`
	Annotation      string                       `description:"核心观点"`
	Abstract        string                       `description:"摘要"`
	PublishDate     string                       `description:"发布时间"`
	DepartmentId    int                          `description:"作者Id"`
	NickName        string                       `description:"作者昵称"`
	IsCollect       bool                         `description:"本人是否收藏"`
	Pv              int                          `description:"PV"`
	CollectNum      int                          `description:"收藏人数"`
	Source          int                          `description:"来源 1:弘则资源包（报告）、2：研选主题（报告）"`
	ArticleTypeId   int                          `description:"文章类型ID"`
	ArticleTypeName string                       `description:"类型名称"`
	ButtonStyle     string                       `description:"按钮展示样式"`
	ImgUrlPc        string                       `description:"图片链接"`
	List            []*IndustrialManagementIdInt `description:"产业列表"`
	ListSubject     []*IndustrialSubject         `description:"标的列表"`
}

// 获取数量
func GetArticleResearchCount(condition string, pars []interface{}) (count int, err error) {
	o := orm.NewOrm()
	sqlCount := `SELECT COUNT( 1 ) AS count FROM
			cygx_article AS a
		WHERE
			1 = 1  AND a.publish_status = 1` + condition
	err = o.Raw(sqlCount, pars).QueryRow(&count)
	return
}

func GetArticleResearchList(condition string, pars []interface{}, startSize, pageSize, userId int) (items []*ArticleListResp, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			a.article_id,
			a.title,
			a.body,
			a.annotation,
			a.abstract,
			a.publish_date,
			a.article_type_id,
			d.nick_name,
			d.department_id,
			( SELECT count( 1 ) FROM cygx_article_history_record_newpv AS h WHERE h.article_id = a.article_id ) AS pv,
			( SELECT count( 1 ) FROM cygx_article_collect AS ac  INNER JOIN wx_user as u ON  u.user_id = ac.user_id  WHERE ac.article_id = a.article_id  ) AS collect_num, 
			( SELECT count( 1 ) FROM cygx_article_collect AS ac  INNER JOIN wx_user as u ON  u.user_id = ac.user_id  WHERE ac.article_id = a.article_id AND DATE_SUB( CURDATE(), INTERVAL 30 DAY ) <= date( ac.create_time )  ) AS collect_num_order, 
			( SELECT count( 1 ) FROM cygx_article_collect AS ac WHERE ac.article_id = a.article_id  AND user_id = ? ) AS my_collect_num
		FROM
			cygx_article AS a
			INNER JOIN cygx_industrial_article_group_management AS mg ON mg.article_id = a.article_id
			INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = mg.industrial_management_id
			INNER JOIN cygx_article_department AS d ON d.department_id = a.department_id 
		WHERE
			1 = 1  AND a.publish_status = 1  `
	if condition != "" {
		sql += condition
	}
	sql += ` GROUP BY a.article_id ORDER  BY   a.publish_date DESC  LIMIT ?,? `
	_, err = o.Raw(sql, userId, pars, startSize, pageSize).QueryRows(&items)
	return
}

func GetArticleResearchListHz(condition string, pars []interface{}, startSize, pageSize, userId int) (items []*ArticleListResp, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			a.article_id,
			a.title,
			a.body,
			a.annotation,
			a.abstract,
			a.publish_date,
			a.category_id,
			a.article_type_id,
			( SELECT count( 1 ) FROM cygx_article_history_record_newpv AS h WHERE h.article_id = a.article_id ) AS pv,
			( SELECT count( 1 ) FROM cygx_article_collect AS ac  INNER JOIN wx_user as u ON  u.user_id = ac.user_id  WHERE ac.article_id = a.article_id  ) AS collect_num, 
			( SELECT count( 1 ) FROM cygx_article_collect AS ac  INNER JOIN wx_user as u ON  u.user_id = ac.user_id  WHERE ac.article_id = a.article_id AND DATE_SUB( CURDATE(), INTERVAL 30 DAY ) <= date( ac.create_time )  ) AS collect_num_order, 
			( SELECT count( 1 ) FROM cygx_article_collect AS ac WHERE ac.article_id = a.article_id  AND user_id = ? ) AS my_collect_num
		FROM
			cygx_article AS a
			INNER JOIN cygx_industrial_article_group_management AS mg ON mg.article_id = a.article_id
			INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = mg.industrial_management_id
		WHERE
			1 = 1  AND a.publish_status = 1  `
	if condition != "" {
		sql += condition
	}
	sql += ` GROUP BY a.article_id ORDER  BY   a.publish_date DESC  LIMIT ?,? `
	_, err = o.Raw(sql, userId, pars, startSize, pageSize).QueryRows(&items)
	return
}

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

// 获取数量
func GetThemeHeatListCount(condition string) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT   COUNT( DISTINCT m.industrial_management_id ) FROM
			cygx_industrial_management AS m
			LEFT JOIN cygx_industrial_article_group_management AS mg ON mg.industrial_management_id = m.industrial_management_id
			LEFT JOIN cygx_article AS a ON a.article_id = mg.article_id 
			LEFT JOIN cygx_industrial_activity_group_management as ag ON ag.industrial_management_id = mg.industrial_management_id
		WHERE
			1 = 1 AND a.publish_status = 1  ` + condition
	err = o.Raw(sql).QueryRow(&count)
	return
}

// 产业列表
func GetThemeHeatList(userId int, condition, conditionOrder string, startSize, pageSize int) (items []*IndustrialManagementHotResp, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			m.industry_name,
			m.industrial_management_id,
			m.article_read_num,
          	MAX( a.publish_date ) AS publish_date,
			MIN(a.publish_date) AS min_report_time,
			( SELECT count( 1 ) FROM cygx_industry_fllow AS f  WHERE f.industrial_management_id = m.industrial_management_id  AND user_id =? AND f.type = 1  ) AS fllow_num,
			( SELECT count( 1 ) FROM cygx_industry_fllow AS f  WHERE f.industrial_management_id = m.industrial_management_id  AND f.type = 1  ) AS sum_num
		FROM
			cygx_industrial_management AS m
			LEFT JOIN cygx_industrial_article_group_management AS mg ON mg.industrial_management_id = m.industrial_management_id
			LEFT JOIN cygx_article AS a ON a.article_id = mg.article_id 
			LEFT JOIN cygx_industrial_activity_group_management as ag ON ag.industrial_management_id = mg.industrial_management_id
		WHERE
			1 = 1
			AND publish_status = 1  ` + condition + `  GROUP BY m.industrial_management_id ` + conditionOrder + ` , last_updated_time  DESC LIMIT ?,?`
	_, err = o.Raw(sql, userId, startSize, pageSize).QueryRows(&items)
	return
}

type GetThemeAericleListResp struct {
	ArticleId           int    `description:"文章id"`
	Title               string `description:"标题"`
	PublishDate         string `description:"发布时间"`
	SubjectName         string `description:"标的名称"`
	IndustrialSubjectId int    `description:"标的ID"`
	DepartmentId        int    `description:"作者Id"`
	NickName            string `description:"作者昵称"`
	Pv                  int    `description:"PV"`
	CollectNum          int    `description:"收藏人数"`
	FllowNum            int    `description:"关注数量"`
	MyCollectNum        int    `description:"本人是否收藏"`
	IsCollect           bool   `description:"本人是否收藏"`
}

// 主题详情start
type GetThemeDetailResp struct {
	IndustrialManagementId int                  `description:"产业Id"`
	IndustryName           string               `description:"产业名称"`
	IsFollow               bool                 `description:"是否关注"`
	ListSubject            []*IndustrialSubject `description:"标的列表"`
	List                   []*ArticleResearchResp
}

// 主题详情start
type GetThemeDetailListResp struct {
	ArticleId              int    `description:"文章id"`
	Title                  string `description:"标题"`
	PublishDate            string `description:"发布时间"`
	SubjectName            string `description:"标的名称"`
	IndustrialSubjectId    int    `description:"标的id"`
	DepartmentId           int    `description:"作者Id"`
	NickName               string `description:"作者昵称"`
	Pv                     int    `description:"PV"`
	CollectNum             int    `description:"收藏人数"`
	IndustrialManagementId int    `description:"产业Id"`
	IndustryName           string `description:"产业名称"`
	FllowNum               int    `description:"关注数量"`
	MyCollectNum           int    `description:"本人是否收藏"`
	IsCollect              bool   `description:"本人是否收藏"`
}

type GetThemeAericleListBuSubjectResp struct {
	SubjectName string `description:"标的名称"`
	List        []*GetThemeAericleListResp
}

// 列表
func GetThemeDetail(userId, industrialManagementId int, condition string) (items []*ArticleListResp, err error) {
	o := orm.NewOrm()
	sql := `SELECT
			a.article_id,
			a.title,
			a.body,
			a.annotation,
			a.abstract,
			a.publish_date,
			a.article_type_id,
			d.nick_name,
			d.department_id,
			( SELECT count( 1 ) FROM cygx_article_history_record_newpv AS h WHERE h.article_id = a.article_id ) AS pv,
			( SELECT count( 1 ) FROM cygx_article_collect AS ac WHERE ac.article_id = a.article_id ) AS collect_num,
			( SELECT count( 1 ) FROM cygx_article_collect AS ac WHERE ac.article_id = a.article_id and user_id = ? ) AS my_collect_num
		FROM
			cygx_article AS a
			INNER JOIN cygx_industrial_article_group_management AS mg ON mg.article_id = a.article_id
			INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = mg.industrial_management_id
			INNER JOIN cygx_article_department AS d ON d.department_id = a.department_id
		WHERE
			1 = 1
			AND m.industrial_management_id = ? 
			AND publish_status = 1 ` + condition + `
		ORDER BY
			publish_date DESC`
	_, err = o.Raw(sql, userId, industrialManagementId).QueryRows(&items)
	return
} //end

func GetDepartmentlistCount(condition string) (count int, err error) {
	o := orm.NewOrm()
	sql := `SELECT
	count(*) AS count 
FROM
	(
	SELECT
		COUNT( 1 ) AS count 
	FROM
		cygx_article_department AS d
		INNER JOIN cygx_article AS a ON d.department_id = a.department_id 
	WHERE
		1 = 1 
		AND a.article_type_id > 0 
		AND publish_status = 1 
	GROUP BY
	d.department_id 
	) c `
	err = o.Raw(sql).QueryRow(&count)
	return
}

type IndustrialReadNum struct {
	IndustrialManagementId int `description:"产业id"`
	Readnum                int `description:"阅读次数"`
}

// 获取该产业下文章的用户阅读次数-小红点用
func GetReportIndustrialReadNumList(userId int, industrialIds string, createtime time.Time) (items []*IndustrialReadNum, err error) {
	o := orm.NewOrm()
	sql := `SELECT a.industrial_management_id, MIN(a.readnum) AS readnum FROM (
SELECT man_g.industrial_management_id,( SELECT COUNT( 1 ) FROM cygx_article_history_record AS rec WHERE rec.user_id = ` + strconv.Itoa(userId) + ` AND rec.article_id = a.article_id ) AS readnum 
FROM
	cygx_article AS a 
	INNER JOIN cygx_industrial_article_group_management as man_g ON man_g.article_id = a.article_id
WHERE
	a.publish_status = 1 
	AND a.is_class = 1
	AND man_g.industrial_management_id IN (` + industrialIds + `)  
	AND a.publish_date > ? 
GROUP BY a.article_id ORDER BY publish_date DESC
) AS a GROUP BY industrial_management_id`
	_, err = o.Raw(sql, createtime).QueryRows(&items)
	return
}