hz_crm_api/models/cygx/industrial_management.go

package cygx

import (
	"github.com/beego/beego/v2/client/orm"
	"hongze/hz_crm_api/utils"
	"time"
)

type IndustrialManagementAdd struct {
	IndustryName      string `description:"产业名称"`
	PermissionName    string `description:"行业名称"`
	ChartPermissionId int    `description:"权限id"`
	RecommendedIndex  int    `description:"推荐指数"`
	LayoutTime        string `description:"布局时间"`
	IsNewLabel        int    `description:"是否属于新标签，1是，0否"`
	Source            int    `description:"来源,1正常添加，2：通过文章添加，3通过活动添加(默认为1)"`
}

type IndustrialManagementDelte struct {
	IndustrialManagementId int `orm:"column(industrial_management_id);pk" description:"产业id"`
}

type NewId struct {
	NewId             string `description:"新增一条数据产生的新的ID"`
	ChartPermissionId int    `description:"行业ID"`
}

type CygxIndustrialManagement struct {
	IndustrialManagementId int       `orm:"column(industrial_management_id);pk" description:"产业id"`
	IndustryName           string    `description:"产业名称"`
	ChartPermissionId      int       `description:"权限id"`
	RecommendedIndex       int       `description:"推荐指数"`
	CreateTime             time.Time `description:"创建时间"`
	LayoutTime             string    `description:"布局时间"`
	IsNewLabel             int       `description:"是否属于新标签，1是，0否"`
	IsHandNewLabel         int       `description:"是否手动修改新标签，1是，0否"`
	IsDeepLabel            int       `description:"是否属于深度标签，1是，0否"`
	IsHandDeepLabel        int       `description:"是否手动修改深度标签，1是，0否"`
	Source                 int       `description:"来源,1正常添加，2：通过文章添加，3通过活动添加(默认为1)"`
	NewArtPublishDate      string    `description:"关联的最新文章发布时间，排序使用"`
}

type CygxIndustrialManagementEdit struct {
	IndustrialManagementId int       `orm:"column(industrial_management_id);pk" description:"产业id"`
	IndustryName           string    `description:"产业名称"`
	ChartPermissionId      int       `description:"权限id"`
	RecommendedIndex       int       `description:"推荐指数"`
	CreateTime             time.Time `description:"创建时间"`
	LayoutTime             string    `description:"布局时间"`
	IsNewLabel             int       `description:"是否属于新标签，1是，0否"`
	IsDeepLabel            int       `description:"是否属于深度标签，1是，0否"`
}

type CygxIndustrialManagementDetail struct {
	IndustrialManagementId int       `orm:"column(industrial_management_id);pk" description:"产业id"`
	IndustryName           string    `description:"产业名称"`
	ChartPermissionId      int       `description:"权限id"`
	RecommendedIndex       int       `description:"推荐指数"`
	CreateTime             time.Time `description:"创建时间"`
	LayoutTime             string    `description:"布局时间"`
	IsNewLabel             int       `description:"是否属于新标签，1是，0否"`
	IsDeepLabel            int       `description:"是否属于新标签，1是，0否"`
}

type CygxIndustrialManagementDetailRep struct {
	IndustrialManagementId int       `orm:"column(industrial_management_id);pk" description:"产业id"`
	IndustryName           string    `description:"产业名称"`
	ChartPermissionId      int       `description:"权限id"`
	RecommendedIndex       int       `description:"推荐指数"`
	CreateTime             time.Time `description:"创建时间"`
	LayoutTime             string    `description:"布局时间"`
	IsNewLabel             int       `description:"是否属于新标签，1是，0否"`
	IsDeepLabel            int       `description:"是否属于新标签，1是，0否"`
	IsShowNewLabel         bool      `description:"是否展示新标签"`
	IsShowDeepLabel        bool      `description:"是否展示深度标签"`
}

type CygxIndustrialManagementNum struct {
	IndustrialManagementId int       `orm:"column(industrial_management_id);pk" description:"产业id"`
	IndustryName           string    `description:"产业名称"`
	ChartPermissionId      int       `description:"权限id"`
	RecommendedIndex       int       `description:"推荐指数"`
	CreateTime             time.Time `description:"创建时间"`
	LayoutTime             string    `description:"布局时间"`
	ArtNum                 int       `description:"文章数量"`
	ActNum                 int       `description:"活动数量"`
	IsRelevance            bool      `description:"是否存在关联文章"`
	HzCover                bool      `description:"是否弘则覆盖"`
}

type CygxIndustrialManagementNumCheckName struct {
	ChartPermissionId int       `orm:"column(industrial_management_id);pk" description:"产业id"`
	PermissionName    string    `orm:"column(industry_name)" description:"产业名称"`
	RecommendedIndex  int       `description:"推荐指数"`
	CreateTime        time.Time `description:"创建时间"`
	LayoutTime        string    `description:"布局时间"`
	ArtNum            int       `description:"文章数量"`
	IsRelevance       bool      `description:"是否存在关联文章"`
}

type GetIndustrialManagementList struct {
	List []*CygxIndustrialManagementNum
}

type GetCygxIndustrialManagementList struct {
	List []*ArtGroupIndustrialManagementRep
}

// 新增
func AddIndustrialManagement(item *CygxIndustrialManagement) (newId int64, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	newId, err = o.Insert(item)
	return
}

// 列表
func GetIndustrialManagementAll(condition, orderColumn string) (items []*CygxIndustrialManagementNum, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT *,
		( SELECT COUNT( 1 ) FROM cygx_industrial_article_group_management AS man_g WHERE man_g.industrial_management_id = man.industrial_management_id ) AS art_num,
		( SELECT COUNT( 1 ) FROM cygx_industrial_activity_group_management AS a_g  INNER JOIN cygx_activity AS a ON a.activity_id = a_g.activity_id  WHERE a_g.industrial_management_id = man.industrial_management_id AND a.publish_status = 1 ) AS act_num
		FROM
		cygx_industrial_management AS man 
		WHERE 1 =1 `
	if condition != "" {
		sql += condition
	}
	sql += `   ORDER BY ` + orderColumn + ` ASC`
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// 列表
func GetIndustrialManagementAllCheckName(ChartPermissionId int, orderColumn string) (items []*CygxIndustrialManagementNumCheckName, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT *
		FROM
		cygx_industrial_management AS man 
		WHERE
		man.chart_permission_id = ?  ORDER BY ` + orderColumn + ` ASC`
	_, err = o.Raw(sql, ChartPermissionId).QueryRows(&items)
	return
}

func GetIndustrialManagementAllByReportTime(condition, orderSrt string) (items []*CygxIndustrialManagementNum, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
			man.*,art.publish_date,man_g.industrial_management_id as man_gid,
			MAX( art.publish_date ) AS update_time,
			( SELECT COUNT( 1 ) FROM cygx_industrial_article_group_management AS man_g WHERE man_g.industrial_management_id = man.industrial_management_id ) AS art_num ,
			( SELECT COUNT( 1 ) FROM cygx_industrial_activity_group_management AS a_g  INNER JOIN cygx_activity AS a ON a.activity_id = a_g.activity_id  WHERE a_g.industrial_management_id = man.industrial_management_id AND a.publish_status = 1 ) AS act_num
			FROM
			cygx_industrial_management AS man
			LEFT JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id 
			LEFT	JOIN cygx_article AS art ON art.article_id = man_g.article_id
			WHERE 1=1 `
	if condition != "" {
		sql += condition
	}
	sql += ` GROUP BY  industry_name  ORDER BY ` + orderSrt
	//fmt.Println(sql)
	//ORDER BY update_time DESC`
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// 获取产业数量
func GetIndustrialManagementCount(condition string, pars []interface{}) (count int, err error) {
	sqlCount := ` SELECT COUNT(1) AS count  FROM cygx_industrial_management WHERE 1=1 `
	if condition != "" {
		sqlCount += condition
	}
	o := orm.NewOrmUsingDB("hz_cygx")
	err = o.Raw(sqlCount, pars).QueryRow(&count)
	return
}

// 修改
func EditIndustrialManagement(item *CygxIndustrialManagement) (err error) {
	sql := `UPDATE cygx_industrial_management SET chart_permission_id=?, industry_name=?, recommended_index=?, layout_time=?,is_new_label=?,is_deep_label=?,is_hand_new_label=?,is_hand_deep_label=?  WHERE industrial_management_id=? `
	o := orm.NewOrmUsingDB("hz_cygx")
	_, err = o.Raw(sql, item.ChartPermissionId, item.IndustryName, item.RecommendedIndex, item.LayoutTime, item.IsNewLabel, item.IsDeepLabel, item.IsHandNewLabel, item.IsHandDeepLabel, item.IndustrialManagementId).Exec()
	return
}

// 通过活动添加的标签产业添加的时候二次修改
func EditIndustrialManagementFromAct(item *CygxIndustrialManagement) (err error) {
	sql := `UPDATE cygx_industrial_management SET  recommended_index=?, layout_time=?,is_new_label=?,is_deep_label=?,is_hand_new_label=?,is_hand_deep_label=?, source = 1  WHERE industry_name=? AND chart_permission_id=?`
	o := orm.NewOrmUsingDB("hz_cygx")
	_, err = o.Raw(sql, item.RecommendedIndex, item.LayoutTime, item.IsNewLabel, item.IsDeepLabel, item.IsHandNewLabel, item.IsHandDeepLabel, item.IndustryName, item.ChartPermissionId).Exec()
	return
}

// 删除数据
func DeleteIndustrialManagement(industrialManagementId int) (err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	to, err := o.Begin()
	if err != nil {
		return
	}
	defer func() {
		if err != nil {
			_ = to.Rollback()
		} else {
			_ = to.Commit()
		}
	}()
	//删除产业
	sql := ` DELETE FROM cygx_industrial_management WHERE industrial_management_id = ?`
	_, err = to.Raw(sql, industrialManagementId).Exec()
	if err != nil {
		return
	}

	//删除产业关联的活动
	sql = ` DELETE FROM cygx_industrial_activity_group_management WHERE industrial_management_id = ?`
	_, err = to.Raw(sql, industrialManagementId).Exec()

	return
}

// 获取产业数量
func GetIndustrialManagementInfo(industrialManagementId int) (item *CygxIndustrialManagement, err error) {
	sqlCount := ` SELECT *  FROM cygx_industrial_management WHERE industrial_management_id= ? `
	o := orm.NewOrmUsingDB("hz_cygx")
	err = o.Raw(sqlCount, industrialManagementId).QueryRow(&item)
	return
}

// 获取产业关联的文章数量
func GetIndustrialManagementGroupArtCount(industrialManagementId int) (count int, err error) {
	sqlCount := ` SELECT COUNT(1) AS count  FROM cygx_industrial_article_group_management WHERE industrial_management_id=? `
	o := orm.NewOrmUsingDB("hz_cygx")
	err = o.Raw(sqlCount, industrialManagementId).QueryRow(&count)
	return
}

type CygxIndustrialManagementExport struct {
	IndustrialManagementId int    `orm:"column(industrial_management_id);pk" description:"产业id"`
	ChartPermissionName    string `description:"行业"`
	IndustryName           string `description:"产业名称"`
	RecommendedIndex       int    `description:"推荐指数"`
	SubjectName            string `description:"标的名称"`
	AnalystName            string `description:"分析师名称"`
}

func GetChartPermissionExport(chartPermissionId int) (items []*CygxIndustrialManagementExport, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
		mp.chart_permission_name,
		man.industry_name,
		man.industrial_management_id,
		man.recommended_index,
		sub.subject_name,
		ana.analyst_name
		FROM
			cygx_report_mapping AS mp
		LEFT  JOIN cygx_industrial_management as man ON man.chart_permission_id = mp.chart_permission_id
		LEFT JOIN cygx_industrial_subject as sub ON sub.industrial_management_id = man.industrial_management_id
		LEFT JOIN cygx_industrial_analyst as ana ON ana.industrial_management_id = man.industrial_management_id
		WHERE mp.chart_permission_id = 20`
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

type CygxIndustrialManagementIdStr struct {
	ChartPermissionId   int    `description:"行业ID"`
	ChartPermissionName string `description:"行业名称"`
	MatchTypeName       string `description:"匹配类型"`
}

func GetChartPermissionIdStr() (items []*CygxIndustrialManagementIdStr, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT * FROM cygx_report_mapping WHERE report_type = 1 AND chart_permission_id != 23 GROUP BY chart_permission_id  ORDER BY sort DESC `
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

type IndustrialManagementExport struct {
	ChartPermissionName       string `description:"行业"`
	ChartPermissionReportName string `description:"行业报告数量"`
	IndustrialManagementId    int    `orm:"column(industrial_management_id);pk" description:"产业id"`
	IndustryName              string `description:"产业名称"`
	ChartPermissionId         int    `description:"权限id"`
	RecommendedIndex          int    `description:"推荐指数"`
	SubjectName               string `description:"标的名称"`
	AnalystName               string `description:"分析师名称"`
	ReportNum                 string `description:"产业报告数量"`
}

func GetIndustrialManagementIdStr(chartPermissionId int) (items []*IndustrialManagementExport, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT * FROM cygx_industrial_management WHERE chart_permission_id = ?`
	_, err = o.Raw(sql, chartPermissionId).QueryRows(&items)
	return
}

type GetReportNumLIstExport struct {
	MatchTypeName string `description:"权限id"`
	TypeNum       int    `description:"数量"`
}

func GetReportNumLIst(industrialManagementId int) (items []*GetReportNumLIstExport, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
		rep.match_type_name,
		COUNT(match_type_name) type_num 
		FROM
		  cygx_report_mapping AS rep
			LEFT  JOIN cygx_article AS art ON	art.category_id  = rep.category_id
			LEFT JOIN cygx_industrial_article_group_management AS map_g ON map_g.cygx_article_id =art.id 
		WHERE
			map_g.industrial_management_id = ?
			AND art.sub_category_name = rep.sub_category_name
			GROUP BY rep.match_type_name
`
	_, err = o.Raw(sql, industrialManagementId).QueryRows(&items)
	return
}

type GetMatchTypeListRep struct {
	ChartPermissionId int    `description:"行业ID"`
	MatchTypeName     string `description:"匹配类型"`
}

func GetMatchTypeList(chartPermissionId int) (items []*GetMatchTypeListRep, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT * FROM cygx_report_mapping WHERE chart_permission_id = ?  GROUP BY match_type_name `
	_, err = o.Raw(sql, chartPermissionId).QueryRows(&items)
	return
}

// 获取产业关联的文章数量
func GetchartPermissionReportNameCount(industrialManagementId int) (count int, err error) {
	sqlCount := ` SELECT COUNT(1) as count FROM cygx_article  as art 
	INNER JOIN cygx_report_mapping as re ON re.category_id = art.category_id
WHERE
	re.report_type = 1
	AND re.chart_permission_id = ?  `
	o := orm.NewOrmUsingDB("hz_cygx")
	err = o.Raw(sqlCount, industrialManagementId).QueryRow(&count)
	return
}

type IndustrialManagementDetial struct {
	LayoutTime  string `description:"布局时间"`
	ArtTotalNum int    `description:"文章总数量"`
	List        []*IndustrialManagementArtTypeList
}

// 通过产业ID获取详情
func GetindustrialManagemenById(industrialManagementId int) (item *CygxIndustrialManagementNum, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT man.layout_time, art.publish_date as create_time,
			( SELECT COUNT( 1 ) FROM cygx_industrial_article_group_management AS man_g INNER JOIN cygx_article AS art ON art.article_id = man_g.article_id  WHERE man_g.industrial_management_id = man.industrial_management_id AND art.publish_status = 1 ) AS art_num 
			FROM
			cygx_industrial_management AS man 
			LEFT JOIN cygx_industrial_article_group_management as mang ON mang.industrial_management_id = man.industrial_management_id
			LEFT JOIN cygx_article as art ON art.article_id = mang.article_id
			WHERE
			man.industrial_management_id = ?
			ORDER BY art.publish_date ASC LIMIT 1`
	err = o.Raw(sql, industrialManagementId).QueryRow(&item)
	return
}

type IndustrialManagementArtTypeList struct {
	MatchTypeName string `description:"匹配类型"`
	ArtNum        int    `description:"文章数量"`
}

func GetIndustrialManagementArtTypeList(industrialManagementId int) (items []*IndustrialManagementArtTypeList, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
				re.match_type_name,
				COUNT(*) AS art_num
			FROM
				cygx_industrial_management AS man
			INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
			INNER JOIN cygx_article AS art ON art.article_id = man_g.article_id
			INNER JOIN cygx_report_mapping AS re ON re.category_id = art.category_id
			WHERE
				man.industrial_management_id = ? AND re.match_type_name <> '' AND re.report_type = 2 AND art.publish_status = 1
			GROUP BY
				re.match_type_name `
	sql += `  UNION ALL 
				SELECT
			map.match_type_name,
			COUNT(*) AS art_num 
		FROM
			cygx_industrial_management AS im
			INNER JOIN cygx_product_interior_industrial_group_management AS man_g ON man_g.industrial_management_id = im.industrial_management_id
			INNER JOIN cygx_product_interior AS art ON art.product_interior_id = man_g.product_interior_id
			INNER JOIN cygx_report_mapping_cygx AS map ON art.match_type_id = map.id 
		WHERE
			1 = 1 
			AND man_g.industrial_management_id = ? 
		GROUP BY
			map.match_type_name `
	sql += ` UNION ALL
			SELECT
				"研选报告",
				COUNT(*)
			FROM
				cygx_industrial_management AS man
			INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
			INNER JOIN cygx_article AS art ON art.article_id = man_g.article_id
			WHERE
				man.industrial_management_id = ? AND art.publish_status = 1 AND  art.article_type_id IN  (1,2,12)`
	_, err = o.Raw(sql, industrialManagementId, industrialManagementId, industrialManagementId).QueryRows(&items)
	return
}

// 获取研选路演精华的数量
func GetIndustrialManagementArtYxLYJH(industrialManagementId int) (total int, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
			COUNT(*) AS art_num 
		FROM
			cygx_industrial_management AS man
			INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
			INNER JOIN cygx_article AS art ON art.article_id = man_g.article_id 
		WHERE
			man.industrial_management_id = ? 
			AND art.publish_status = 1 
			AND art.article_type_id IN (13)`
	err = o.Raw(sql, industrialManagementId).QueryRow(&total)
	return
}

type ArtGroupIndustrialManagementRep struct {
	IndustryName           string `description:"产业名称"`
	IndustrialManagementId int    `orm:"column(industrial_management_id);pk" description:"产业id"`
}

// 获取文章关联的产业列表
func GetArtGroupIndustrialManagement(reportId int) (item []*ArtGroupIndustrialManagementRep, err error) {
	sql := ` SELECT
		man.industry_name
		FROM
			cygx_industrial_article_group_management AS man_g
			INNER JOIN cygx_industrial_management AS man ON man.industrial_management_id = man_g.industrial_management_id 
		WHERE
			man_g.cygx_article_id = ?`
	o := orm.NewOrmUsingDB("hz_cygx")
	_, err = o.Raw(sql, reportId).QueryRows(&item)
	return
}

// 通过ID获取详情
func GetIndustrialManagemenDetailById(industrialManagementId int) (item *CygxIndustrialManagementDetail, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT * FROM cygx_industrial_management WHERE industrial_management_id = ? `
	err = o.Raw(sql, industrialManagementId).QueryRow(&item)
	return
}

// 通过名称获取详情
func GetIndustrialManagemenDetailByName(industryName string) (item *CygxIndustrialManagementDetail, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT * FROM cygx_industrial_management WHERE industry_name = ? `
	err = o.Raw(sql, industryName).QueryRow(&item)
	return
}

// 获取行业深度，产业关联的文章数量
func GetIndustrialManagementGroupArtCountByDeep(industrialManagementId int) (count int, err error) {
	sqlCount := `SELECT COUNT(1) as conut FROM cygx_industrial_article_group_management AS a
				INNER JOIN cygx_article AS b ON b.id = a.cygx_article_id 
				WHERE
				a.industrial_management_id = ?
				AND b.match_type_name ='行业深度' `
	o := orm.NewOrmUsingDB("hz_cygx")
	err = o.Raw(sqlCount, industrialManagementId).QueryRow(&count)
	return
}

// 列表
func GetIndustrialManagement(condition string) (items []*ArtGroupIndustrialManagementRep, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT * FROM cygx_industrial_management as art WHERE 1= 1 `
	if condition != "" {
		sql += condition
	}
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// 通过多个产业ID获取产业名称
func GetindustrialManagementNames(industrialManagementIds string) (names string, err error) {
	sql := ` SELECT
			GROUP_CONCAT( DISTINCT m.industry_name SEPARATOR '/' ) AS names 
			FROM
			cygx_industrial_management AS m 
			WHERE
			industrial_management_id IN ( ` + industrialManagementIds + `) `
	o := orm.NewOrmUsingDB("hz_cygx")
	err = o.Raw(sql).QueryRow(&names)
	return
}

// 通过多个产业ID获取产业名称
func GetindustrialManagementNamesBySubjectName(subjectnName string, chartPermissionId int) (names string, err error) {
	sql := `SELECT
			GROUP_CONCAT( DISTINCT m.industry_name SEPARATOR ',' ) AS sellerName 
			FROM
			cygx_industrial_management AS m 
			WHERE
			industrial_management_id IN (
			SELECT
			industrial_management_id 
			FROM
			cygx_industrial_subject 
			WHERE
			subject_name = ?) 	AND m.chart_permission_id	= ? `
	o := orm.NewOrmUsingDB("hz_cygx")
	err = o.Raw(sql, subjectnName, chartPermissionId).QueryRow(&names)
	return
}

type ReportMappingCategoryRep struct {
	CategoryId          int    `description:"文章分类id"`
	SubCategoryName     string `description:"产业名称"`
	ChartPermissionName string `description:"行业名称"`
}

func GetPermissionMappingCategoryAll() (item []*ReportMappingCategoryRep, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := ` SELECT * FROM cygx_report_mapping  GROUP BY category_id `
	_, err = o.Raw(sql).QueryRows(&item)
	return
}

type CompanyHistoryRecordNewPvRep struct {
	RealName       string `description:"姓名"`
	Mobile         string `description:"手机号"`
	Email          string `description:"邮箱"`
	Title          string `description:"标题"`
	CategoryId     int    `description:"文章分类id"`
	CreateTime     string `description:"创建时间"`
	StopTime       string `description:"阅读停留时间"`
	IndustryName   string `description:"产业名称"`
	PermissionName string `description:"行业名称"`
	SubjectNameStr string `description:"标的名称"`
	PublishDate    string `description:"发布时间"`
}

func GetCompanyHistoryRecordNewPv(mobiles, emails string) (item []*CompanyHistoryRecordNewPvRep, err error) {
	//var table string
	//table = "cygx_article_history_record_all"
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := ` SELECT
			h.real_name,
			h.mobile,
			h.email,
			a.title,
			a.category_id,
			h.create_time,
			a.publish_date,
			h.stop_time,
			(
			SELECT
				GROUP_CONCAT( DISTINCT s.subject_name SEPARATOR '/' ) 
			FROM
				cygx_industrial_subject AS s 
			WHERE
				s.industrial_subject_id IN ( SELECT industrial_subject_id FROM cygx_industrial_article_group_subject AS sg WHERE sg.article_id = a.article_id ) 
			) AS subject_name_str,
			(
			SELECT
				GROUP_CONCAT( DISTINCT man.industry_name SEPARATOR '/' ) 
			FROM
				cygx_industrial_management AS man 
			WHERE
				man.industrial_management_id IN ( SELECT industrial_management_id FROM cygx_industrial_article_group_management AS man_g WHERE man_g.article_id = a.article_id ) 
			) AS industry_name
		FROM
			cygx_article_history_record_all AS h
			INNER JOIN cygx_article AS a ON a.article_id = h.article_id 
		WHERE
			h.mobile IN (` + mobiles + `) AND h.is_del = 0  OR( h.email IN (` + emails + `) AND h.email <>'' AND h.is_del = 0 )   ORDER BY h.create_time 	DESC `
	_, err = o.Raw(sql).QueryRows(&item)
	return
}

// 通过产业名称获取关联的ID
func GetManagementIdsByName(name string) (industrialManagementIds string, err error) {
	sql := ` SELECT
			GROUP_CONCAT( DISTINCT s.industrial_management_id SEPARATOR ',' ) AS industrial_management_ids 
			FROM
			cygx_industrial_management AS s
			WHERE
			industry_name =? `
	o := orm.NewOrmUsingDB("hz_cygx")
	err = o.Raw(sql, name).QueryRow(&industrialManagementIds)
	return
}

// 通过产业名称获取关联的ID（模糊查询）
func GetManagementIdsByNameLike(name string) (industrialManagementIds string, err error) {
	sql := ` SELECT
			GROUP_CONCAT( DISTINCT s.industrial_management_id SEPARATOR ',' ) AS industrial_management_ids 
			FROM
			cygx_industrial_management AS s
			WHERE
			industry_name LIKE '%` + name + `%'`
	o := orm.NewOrmUsingDB("hz_cygx")
	err = o.Raw(sql).QueryRow(&industrialManagementIds)
	return
}

type CygxReportMappingResp struct {
	CategoryId          int    `description:"行业分类ID"`
	ChartPermissionId   int    `description:"权限id"`
	ChartPermissionName string `description:"权限名称"`
	PermissionType      int    `description:"1主观，2客观"`
	SubCategoryName     string `description:"主题"`
}

// 通过ID获取详情
func GetCygxReportMappingRespByid(categoryId int) (item *CygxReportMappingResp, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT * FROM cygx_report_mapping WHERE category_id = ? LIMIT 1`
	err = o.Raw(sql, categoryId).QueryRow(&item)
	return
}

// IndustryMove 行业移动请求体
type IndustryMove struct {
	IndustrialManagementId int `description:"产业ID"`
	ChartPermissionId      int `description:"权限ID"`
}

// Update 更新产业
func (industryItem *CygxIndustrialManagement) Update(cols []string) (err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	_, err = o.Update(industryItem, cols...)
	return
}

// GetIndustryListByCondition 获取产业列表
func GetIndustryListByCondition(condition string, pars []interface{}) (list []*CygxIndustrialManagement, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT * FROM cygx_industrial_management WHERE 1 = 1 `
	if condition != "" {
		sql += condition
	}
	_, err = o.Raw(sql, pars).QueryRows(&list)
	return
}

// GetIndustryListByCondition 获取产业列表
func GetIndustryListByConditionByIds(industrialManagementIds []int) (list []*CygxIndustrialManagement, err error) {
	lenArr := len(industrialManagementIds)
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT * FROM cygx_industrial_management WHERE  industrial_management_id IN (` + utils.GetOrmInReplace(lenArr) + `) `
	_, err = o.Raw(sql, industrialManagementIds).QueryRows(&list)
	return
}

// IndustriesEarliestLayoutTime 产业布局时间
type IndustriesEarliestLayoutTime struct {
	IndustrialManagementId int       `json:"industrial_management_id" description:"产业ID"`
	LayoutTime             string    `json:"layout_time" description:"布局时间"`
	MinArticleTime         string    `json:"min_article_time" description:"最早报告时间"`
	LayoutTime2            time.Time ` orm:"column(layout_time);"description:"布局时间"`
	MinArticleTime2        time.Time ` orm:"column(min_article_time);"description:"最早报告时间"`
}

// GetIndustriesEarliestLayoutTime 获取产业最早布局时间
func GetIndustriesEarliestLayoutTime(condition string, pars []interface{}) (list []*IndustriesEarliestLayoutTime, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
				idy.industrial_management_id,
				idy.layout_time,
				MIN(art.publish_date) AS min_article_time
			FROM
				cygx_industrial_management AS idy
			LEFT JOIN cygx_industrial_article_group_management AS argm ON idy.industrial_management_id = argm.industrial_management_id
			LEFT JOIN cygx_article AS art ON argm.article_id = art.article_id
			WHERE
				1 = 1 `
	if condition != "" {
		sql += condition
	}
	sql += ` GROUP BY idy.industrial_management_id`
	_, err = o.Raw(sql, pars).QueryRows(&list)
	return
}

// GetIndustriesEarliestLayoutTimeByMorningMeeting 根据晨会精华获取产业最早布局时间
func GetIndustriesEarliestLayoutTimeByMorningMeeting(condition string, pars []interface{}) (list []*IndustriesEarliestLayoutTime, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
			idy.industrial_management_id,
			idy.layout_time,
			MIN( mrc.meeting_time ) AS min_article_time 
		FROM
			cygx_industrial_management AS idy
			LEFT JOIN cygx_morning_meeting_review_chapter AS mrc ON idy.industrial_management_id = mrc.industry_id 
			WHERE
				1 = 1 `
	if condition != "" {
		sql += condition
	}
	sql += ` GROUP BY idy.industrial_management_id`
	_, err = o.Raw(sql, pars).QueryRows(&list)
	return
}

// UpdateIndustryLayoutTime 更新产业布局时间
func UpdateIndustryLayoutTime(industryId int, layoutTime string) (err error) {
	sql := `UPDATE cygx_industrial_management SET layout_time = ? WHERE industrial_management_id = ? LIMIT 1`
	o := orm.NewOrmUsingDB("hz_cygx")
	_, err = o.Raw(sql, layoutTime, industryId).Exec()
	return
}

// GetYxIndustryUseHzIndustryIds 获取研选产业的报告/活动所使用到的非研选产业IDs-即弘则覆盖
func GetYxIndustryUseHzIndustryIds() (ids []int, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT DISTINCT
				a.industrial_management_id
			FROM
				cygx_industrial_activity_group_management AS a
			JOIN cygx_industrial_management AS b ON a.industrial_management_id = b.industrial_management_id
			JOIN cygx_activity AS c ON a.activity_id = c.activity_id
			WHERE
				b.chart_permission_id != 31 AND c.chart_permission_id = 31 AND c.publish_status = 1
			UNION
			SELECT DISTINCT
				a.industrial_management_id
			FROM
				cygx_industrial_article_group_management AS a
			JOIN cygx_industrial_management AS b ON a.industrial_management_id = b.industrial_management_id
			JOIN cygx_article AS c ON a.article_id = c.article_id
			WHERE
				c.article_id > 1000000 AND c.article_type_id IN  (1,2,12) AND b.chart_permission_id != 31 AND c.publish_status = 1`
	_, err = o.Raw(sql).QueryRows(&ids)
	return
}

// GetIndustryListWithHzCover 获取产业列表-带弘则覆盖
func GetIndustryListWithHzCover(condition, conditionCover, orderRule string, isCover bool, pars []interface{}) (items []*CygxIndustrialManagementNum, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
				man.*, art.publish_date,
				man_g.industrial_management_id AS man_gid,
				MAX(art.publish_date) AS update_time,
				(
					SELECT
						COUNT(1)
					FROM
						cygx_industrial_article_group_management AS man_g
					WHERE
						man_g.industrial_management_id = man.industrial_management_id
				) AS art_num,
				(
					SELECT
						COUNT(1)
					FROM
						cygx_industrial_activity_group_management AS a_g
					INNER JOIN cygx_activity AS a ON a.activity_id = a_g.activity_id
					WHERE
						a_g.industrial_management_id = man.industrial_management_id
					AND a.publish_status = 1
				) AS act_num,
				"false" AS hz_cover
			FROM
				cygx_industrial_management AS man
			LEFT JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
			LEFT JOIN cygx_article AS art ON art.article_id = man_g.article_id
			WHERE
				1 = 1 `
	sql += condition
	sql += ` GROUP BY industry_name`
	// 弘则覆盖
	if isCover {
		sql += ` UNION ALL
				SELECT
					man.*, art.publish_date,
					man_g.industrial_management_id AS man_gid,
					MAX(art.publish_date) AS update_time,
					(
						SELECT
							COUNT(1)
						FROM
							cygx_industrial_article_group_management AS man_g
						WHERE
							man_g.industrial_management_id = man.industrial_management_id
					) AS art_num,
					(
						SELECT
							COUNT(1)
						FROM
							cygx_industrial_activity_group_management AS a_g
						INNER JOIN cygx_activity AS a ON a.activity_id = a_g.activity_id
						WHERE
							a_g.industrial_management_id = man.industrial_management_id
						AND a.publish_status = 1
					) AS act_num,
					"true" AS hz_cover
				FROM
					cygx_industrial_management AS man
				LEFT JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
				LEFT JOIN cygx_article AS art ON art.article_id = man_g.article_id
				WHERE
					1 = 1 `
		sql += conditionCover
		sql += ` GROUP BY industry_name`
	}

	if orderRule != "" {
		sql += ` ORDER BY ` + orderRule
	}

	_, err = o.Raw(sql, pars).QueryRows(&items)
	return
}

type IndustrialManagement struct {
	IndustrialManagementId int    `orm:"column(industrial_management_id);pk" description:"产业id"`
	UpdateTime             string `description:"更新时间"`
	PublishDate            string `description:"发布时间"`
	IndustryName           string `description:"产业名称"`
}

// GetIndustrialManagementArticleNewPublishData 获取产业关联文章的最新发布时间
func GetIndustrialManagementArticleNewPublishData() (items []*IndustrialManagement, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
			man.industrial_management_id,
			MAX( art.publish_date ) AS update_time 
		FROM
			cygx_industrial_management AS man
			INNER JOIN cygx_report_mapping AS re ON re.chart_permission_id = man.chart_permission_id
			INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
			INNER JOIN cygx_article AS art ON art.article_id = man_g.article_id 
		WHERE
			1 = 1 
			AND re.report_type = 2 
			AND art.is_report = 1 
			AND art.is_class = 1 
		GROUP BY
			man.industry_name 
		ORDER BY
			update_time DESC`
	_, err = o.Raw(sql).QueryRows(&items)
	return
}

// 时间线的更新时间
func GetTimeLineReportIndustrialPublishdateList(industrialIdArr []int) (items []*IndustrialManagement, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT
			mmc.industry_id AS industrial_management_id,
			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
}

// UpdateIndustrialManagementArticleNewPublishData 批量修改获取产业关联文章的最新发布时间
func UpdateIndustrialManagementArticleNewPublishData(items map[int]string) (err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	p, err := o.Raw("UPDATE cygx_industrial_management SET new_art_publish_date = ? WHERE industrial_management_id = ?").Prepare()
	if err != nil {
		return
	}
	defer func() {
		_ = p.Close() // 别忘记关闭 statement
	}()
	for k, v := range items {
		_, err = p.Exec(v, k)
		if err != nil {
			return
		}
	}
	return
}

// GetTopOneMonthArtReadNumIndustry 获取列表
func GetTopOneMonthArtReadNumIndustryAll(condition string, pars []interface{}) (items []*IndustrialManagement, err error) {
	o := orm.NewOrmUsingDB("hz_cygx")
	sql := `SELECT * FROM cygx_industrial_management WHERE 1 = 1 `
	if condition != `` {
		sql += condition
	}
	sql += ` ORDER BY article_read_num DESC `
	_, err = o.Raw(sql, pars).QueryRows(&items)
	return
}