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 }