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:"布局时间"` PublishDate 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"` Type int `description:"类型: 1-音频; 2-活动视频； 3-产业视频 、 4-系列问答视频"` 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 } type TacticsListTimeResp struct { Paging *paging.PagingItem MatchTypeName string `description:"匹配类型"` CategoryImgUrlPc string `description:"图片"` List []*TimeLineReportItem } // 报告搜索start type ReoprtSearchResp struct { Paging *paging.PagingItem ListHz []*ArticleResearchResp `description:"弘则报告"` ListYx []*ArticleResearchResp `description:"研选报告"` } // 搜索资源包 start type SearchResourceResp struct { ListHz []*IndustrialManagement `description:"弘则"` ListYx []*IndustrialManagement `description:"研选"` } type ArticleIdReq struct { ArticleId int `description:"文章id"` PlaySeconds int `description:"播放时长"` PageRouter string `description:"页面路径"` ReportType int `description:"2本周研究汇总、3上周纪要汇总"` } // 获取列表数量 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 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 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 GetReportAndproductIndustrylList(categoryId, startSize, pageSize int) (items []*HomeArticle, total int, err error) { o := orm.NewOrm() sql := `SELECT art.article_id, art.title, art.publish_date, 1 AS resource FROM cygx_article AS art WHERE art.publish_status = 1 AND art.article_id IN ( SELECT article_id FROM cygx_report_mapping_category_group WHERE id_cygx = ` + strconv.Itoa(categoryId) + ` ) UNION ALL SELECT art.product_interior_id AS article_id, art.title, art.publish_time AS publish_date, 2 AS resource FROM cygx_product_interior AS art WHERE art.STATUS = 1 AND art.visible_range = 1 AND art.match_type_id = ` + strconv.Itoa(categoryId) totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z ` err = o.Raw(totalSql).QueryRow(&total) sql += ` ORDER BY publish_date DESC LIMIT ?,? ` _, err = o.Raw(sql, startSize, pageSize).QueryRows(&items) return } // 获取行业报告列表 func GetReportAndproductIndustrylListimg(categoryId, userId, startSize, pageSize int) (items []*ArticleListResp, total int, err error) { o := orm.NewOrm() sql := `SELECT art.article_id, art.report_id, art.body, art.annotation, art.abstract, art.category_id, art.title, art.publish_date, 1 AS resource , ( SELECT COUNT( 1 ) FROM cygx_article_history_record AS rec WHERE rec.user_id = ` + strconv.Itoa(userId) + ` AND rec.article_id = art.article_id ) AS readnum FROM cygx_article AS art WHERE art.publish_status = 1 AND art.article_id IN ( SELECT article_id FROM cygx_report_mapping_category_group WHERE id_cygx = ` + strconv.Itoa(categoryId) + ` ) UNION ALL SELECT art.product_interior_id AS article_id, 0 AS report_id, art.body, "", art.abstract, 0 as category_id, art.title, art.publish_time AS publish_date, 2 AS resource , ( SELECT COUNT( 1 ) FROM cygx_product_interior_history AS rec WHERE rec.user_id = ` + strconv.Itoa(userId) + ` AND rec.product_interior_id = art.product_interior_id ) AS readnum FROM cygx_product_interior AS art WHERE art.STATUS = 1 AND art.visible_range = 1 AND art.match_type_id = ` + strconv.Itoa(categoryId) totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z ` err = o.Raw(totalSql).QueryRow(&total) sql += ` ORDER BY publish_date DESC LIMIT ?,? ` _, err = o.Raw(sql, startSize, pageSize).QueryRows(&items) return } // 列表 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 } // 产业下所关联的文章、产品内测分类列表 2023-04-14 func IndustrialToArticleAndProductInteriorCategoryNew(industrialManagementId int) (items []*IndustrialToArticleCategoryRep, err error) { o := orm.NewOrm() sql := `SELECT map.match_type_name, map.sort, map.id, map.id AS category_id FROM cygx_report_mapping_cygx AS map INNER JOIN cygx_report_mapping_group AS g ON g.id_cygx = map.id INNER JOIN cygx_report_mapping_celue AS cl ON cl.category_id = g.category_id_celue INNER JOIN cygx_article AS art ON art.category_id = cl.category_id INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.article_id = art.article_id WHERE 1 = 1 AND 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 = ? GROUP BY map.match_type_name UNION ALL SELECT map.match_type_name, map.sort, map.id, map.id AS category_id FROM cygx_report_mapping_cygx AS map INNER JOIN cygx_industrial_management AS im ON im.chart_permission_id = map.chart_permission_id INNER JOIN cygx_product_interior AS art ON art.match_type_id = map.id INNER JOIN cygx_product_interior_industrial_group_management AS man_g ON man_g.product_interior_id = art.product_interior_id WHERE 1 = 1 AND art.STATUS = 1 AND art.visible_range = 1 AND man_g.industrial_management_id = ? GROUP BY map.match_type_name ORDER BY id ASC , sort DESC ` _, err = o.Raw(sql, industrialManagementId, industrialManagementId).QueryRows(&items) return } // 获取产业报告列表 func GetReportAndproductInteriorIndustrialList(pars []interface{}, categoryId, industrialManagementId, userId, startSize, pageSize int) (items []*ArticleListResp, total int, err error) { o := orm.NewOrm() sql := `SELECT art.article_id, art.body, art.annotation, art.abstract, art.category_id, art.title, art.publish_date, ( SELECT COUNT( 1 ) FROM cygx_article_history_record AS rec WHERE rec.user_id = ` + strconv.Itoa(userId) + ` AND rec.article_id = art.article_id ) AS readnum , 1 AS resource FROM cygx_article AS art INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.article_id = art.article_id WHERE art.publish_status = 1 AND art.article_id IN ( SELECT article_id FROM cygx_report_mapping_category_group WHERE id_cygx = ` + strconv.Itoa(categoryId) + ` ) AND art.is_class = 1 AND man_g.industrial_management_id =` + strconv.Itoa(industrialManagementId) + ` GROUP BY art.article_id UNION ALL SELECT art.product_interior_id AS article_id, art.body, "", art.abstract, 0 as category_id, art.title, art.publish_time AS publish_date, ( SELECT COUNT( 1 ) FROM cygx_product_interior_history AS rec WHERE rec.user_id = ` + strconv.Itoa(userId) + ` AND rec.product_interior_id = art.product_interior_id ) AS readnum , 2 AS resource FROM cygx_product_interior AS art INNER JOIN cygx_product_interior_industrial_group_management AS man_g ON man_g.product_interior_id = art.product_interior_id WHERE art.STATUS = 1 AND art.visible_range = 1 AND art.match_type_id = ` + strconv.Itoa(categoryId) + ` AND man_g.industrial_management_id = ` + strconv.Itoa(industrialManagementId) + ` GROUP BY art.product_interior_id ` totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z ` err = o.Raw(totalSql, pars).QueryRow(&total) sql += ` ORDER BY publish_date DESC LIMIT ?,? ` _, err = o.Raw(sql, pars, startSize, pageSize).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 article_id < 1000000 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, a.article_type_id, 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 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 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 []*ArticleListResp, 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"` ArticleId int `description:"文章id"` Title string `description:"标题"` //PublishTime string `description:"发布时间"` PublishDate string `description:"发布时间"` Content string `description:"内容"` VideoUrl string `description:"视频链接"` VoiceUrl string `description:"音频链接"` IsHaveVideo bool `description:"是否包含视频"` ImgUrlPc string `description:"pc图片"` SubCategoryName string `description:"二级分类"` IsRed bool `description:"是否标红"` Readnum int `description:"阅读数量"` Resource int `description:"来源类型，1：文章、2：产品内测、3：晨报点评 4:活动回放视频 5:活动回放音频 "` Type int `description:"类型: 1-音频; 2-活动视频； 3-产业视频 、 4-系列问答视频"` LinkArticleId int `description:"晨会精华报告ID链接"` ListSubject []*CygxIndustrialSubject `description:"标的列表"` } // 获取产业报告+晨会点评列表 func GetTimeLineReportIndustrialListTime(userId, industrialManagementId, startSize, pageSize int) (items []*TimeLineReportItem, total int, err error) { o := orm.NewOrm() sql := `SELECT * FROM ( SELECT a.article_id AS id, a.article_id, a.title, a.publish_date, a.video_url, '' AS mi, a.sub_category_name, '' AS content, 1 AS resource, 0 AS type, ( 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, 0 as article_id, mmc.title, mm.publish_time AS publish_date, '' AS video_url, '' AS voice_url, '时间线' AS sub_category_name, mmc.content, 3 AS resource, 0 AS type, 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 = ? UNION ALL SELECT p.product_interior_id AS id, p.product_interior_id as article_id, p.title, p.publish_time AS publish_date, '' AS video_url, '' AS voice_url, '' AS sub_category_name, '' AS content, 2 AS resource, 0 AS type, 0 AS readnum FROM cygx_product_interior AS p INNER JOIN cygx_product_interior_industrial_group_management AS pm WHERE p.product_interior_id = pm.product_interior_id AND p.visible_range = 1 AND pm.industrial_management_id = ? UNION ALL SELECT cav.video_id AS id, 0 as article_id, cav.video_name AS title, ca.activity_time AS publish_time, cav.video_url AS video_url, '' AS voice_url, '' AS sub_category_name, '' AS content, 4 AS resource, 2 AS type, ( SELECT COUNT( 1 ) FROM cygx_activity_video_history AS rec WHERE rec.user_id = ` + strconv.Itoa(userId) + ` AND rec.activity_id = ca.activity_id ) AS readnum FROM cygx_activity AS ca INNER JOIN cygx_activity_video AS cav ON ca.activity_id = cav.activity_id INNER JOIN cygx_industrial_activity_group_management AS cam ON ca.activity_id=cam.activity_id WHERE cam.industrial_management_id = ? AND cam.source = 1 UNION ALL SELECT ca.activity_id AS id, 0 as article_id, cavo.voice_name AS title, ca.activity_time AS publish_time, '' AS video_url, cavo.voice_url AS voice_url, '' AS sub_category_name, '' AS content, 5 AS resource, 1 AS type, ( SELECT COUNT( 1 ) FROM cygx_activity_voice_history AS rec WHERE rec.user_id = ` + strconv.Itoa(userId) + ` AND rec.activity_id = ca.activity_id ) AS readnum FROM cygx_activity AS ca INNER JOIN cygx_activity_voice AS cavo ON ca.activity_id = cavo.activity_id INNER JOIN cygx_industrial_activity_group_management AS cam ON ca.activity_id=cam.activity_id WHERE cam.industrial_management_id = ? AND cam.source = 1 ) AS t` totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z ` err = o.Raw(totalSql, industrialManagementId, industrialManagementId, industrialManagementId, industrialManagementId, industrialManagementId).QueryRow(&total) sql += ` ORDER BY t.publish_date DESC LIMIT ?,? ` _, err = o.Raw(sql, industrialManagementId, industrialManagementId, industrialManagementId, industrialManagementId, industrialManagementId, startSize, pageSize).QueryRows(&items) return } // 获取产业报告+晨会点评列表 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 , 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_date, '' 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_date 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：研选主题（报告）"` ArticleTypeId int `description:"文章类型ID判断是否是研选使用"` IsResearch bool `description:"是否属于研选"` ArticleTypeName string `description:"文章类型名称"` IsSpecial bool `description:"是否为研选专栏"` IsSpecialInt int `description:"是否为研选专栏"` SpecialTags string `description:"研选专栏标签"` MyCollectNum int `description:"本人是否收藏"` SpecialType int `description:"专栏类型 1:笔记，2:观点"` UserId int `description:"作者id"` IndustryTagStr string `description:"研选专栏行业标签"` CompanyTagsStr string `description:"研选专栏公司标签"` IndustryTags []string `description:"研选专栏行业标签"` CompanyTags []string `description:"研选专栏公司标签"` SpecialColumnId int `description:"专栏栏目id"` 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:"标的列表"` IsSpecial bool `description:"是否为研选专栏"` IndustryTags []string `description:"研选专栏行业标签"` CompanyTags []string `description:"研选专栏公司标签"` SpecialColumnId int `description:"专栏栏目id"` TopTime int `description:"置顶时间"` Resource int `description:"来源类型，1：文章、2：产品内测、3：FICC研报"` ReportId int `description:"FICC研报ID"` } // 获取数量 func GetArticleResearchCount(condition string, pars []interface{}, needYanxuanSpecial bool) (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 if needYanxuanSpecial { sqlCount = `SELECT SUM(count) AS count FROM (` + sqlCount + ` UNION ALL SELECT COUNT( 1 ) AS count FROM cygx_yanxuan_special AS a WHERE 1 = 1 AND a.status = 3) AS c` } err = o.Raw(sqlCount, pars).QueryRow(&count) return } func GetArticleResearchList(condition string, pars []interface{}, startSize, pageSize, userId int, needYanxuanSpecial bool) (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 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, 0 AS is_special, 0 AS special_type, 0 AS special_column_id, '' AS company_tags, '' AS industry_tags, a.top_time 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 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 } if needYanxuanSpecial { sql += `UNION ALL SELECT a.id AS article_id, a.title AS title, '' AS body, a.content AS annotation, '' AS abstract, a.publish_time AS publish_date, -1 AS article_type_id, b.nick_name AS nick_name, 0 AS department_id, ( SELECT count( 1 ) FROM cygx_yanxuan_special_record AS h WHERE h.yanxuan_special_id = a.id ) AS pv, ( SELECT count( 1 ) FROM cygx_yanxuan_special_collect AS ac WHERE ac.yanxuan_special_id = a.id ) AS collect_num, 0 AS collect_num_order, ( SELECT count( 1 ) FROM cygx_yanxuan_special_collect AS ac WHERE ac.yanxuan_special_id = a.id AND user_id = ? ) AS my_collect_num, 1 AS is_special, a.type AS special_type, b.id AS special_column_id, a.company_tags AS company_tags, a.industry_tags AS industry_tags, 0 as top_time FROM cygx_yanxuan_special AS a JOIN cygx_yanxuan_special_author AS b ON a.user_id = b.user_id WHERE 1 = 1 AND a.status = 3 ` sql += ` GROUP BY article_id ORDER BY top_time DESC , publish_date DESC LIMIT ?,? ` _, err = o.Raw(sql, userId, userId, pars, startSize, pageSize).QueryRows(&items) } else { sql += ` GROUP BY a.article_id ORDER BY top_time DESC , a.publish_date DESC LIMIT ?,? ` _, err = o.Raw(sql, userId, pars, startSize, pageSize).QueryRows(&items) } return } func GetArticleResearchListYx(condition string, pars []interface{}, startSize, pageSize, userId int, needYanxuanSpecial bool) (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, 0 AS is_special, 0 as pv, 0 as collect_num, 0 AS special_type, 0 AS special_column_id, '' AS company_tags, '' AS industry_tags, a.top_time FROM cygx_article AS a 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 } if needYanxuanSpecial { sql += `UNION ALL SELECT a.id AS article_id, a.title AS title, '' AS body, a.content AS annotation, '' AS abstract, a.publish_time AS publish_date, -1 AS article_type_id, b.nick_name AS nick_name, 0 AS department_id, 1 AS is_special, a.pv, a.article_collect_num as collect_num, a.type AS special_type, b.id AS special_column_id, a.company_tags AS company_tags, a.industry_tags AS industry_tags, 0 as top_time FROM cygx_yanxuan_special AS a JOIN cygx_yanxuan_special_author AS b ON a.user_id = b.user_id WHERE 1 = 1 AND a.status = 3 ` } sql += ` GROUP BY article_id ORDER BY top_time DESC , publish_date DESC LIMIT ?,? ` _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items) return } func GetArticleResearchAndYxSpecialList(condition, conditionYxSpecial string, pars []interface{}, startSize, pageSize, userId int, needYanxuanSpecial bool) (total 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 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 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, 0 AS is_special, 0 AS special_type, 0 AS special_column_id, '' AS company_tags, '' AS industry_tags 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 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 } if needYanxuanSpecial { sql += `UNION ALL SELECT a.id AS article_id, a.title AS title, '' AS body, a.content AS annotation, '' AS abstract, a.publish_time AS publish_date, -1 AS article_type_id, b.nick_name AS nick_name, 0 AS department_id, ( SELECT count( 1 ) FROM cygx_yanxuan_special_record AS h WHERE h.yanxuan_special_id = a.id ) AS pv, ( SELECT count( 1 ) FROM cygx_yanxuan_special_collect AS ac WHERE ac.yanxuan_special_id = a.id ) AS collect_num, 0 AS collect_num_order, ( SELECT count( 1 ) FROM cygx_yanxuan_special_collect AS ac WHERE ac.yanxuan_special_id = a.id AND user_id = ? ) AS my_collect_num, 1 AS is_special, a.type AS special_type, b.id AS special_column_id, a.company_tags AS company_tags, a.industry_tags AS industry_tags FROM cygx_yanxuan_special AS a JOIN cygx_yanxuan_special_author AS b ON a.user_id = b.user_id WHERE 1 = 1 AND a.status = 3 ` + conditionYxSpecial totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z ` err = o.Raw(totalSql, userId, userId, pars).QueryRow(&total) sql += ` GROUP BY article_id ORDER BY publish_date DESC LIMIT ?,? ` _, err = o.Raw(sql, userId, userId, pars, startSize, pageSize).QueryRows(&items) } else { 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.report_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 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 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 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 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, m.yanxuan_article_read_num + m.activity_num 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 }