industrial_management.go 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368
  1. package models
  2. import (
  3. "github.com/beego/beego/v2/client/orm"
  4. "hongze/hongze_clpt/utils"
  5. "strconv"
  6. "time"
  7. )
  8. type IndustrialManagementRep struct {
  9. IndustryName string `description:"产业名称"`
  10. IndustrialManagementId int `description:"产业id"`
  11. ChartPermissionId int `description:"权限id"`
  12. RecommendedIndex int `description:"推荐指数"`
  13. LayoutTime string `description:"布局时间"`
  14. ArticleReadNum int `description:"文章阅读数量"`
  15. IsResearch bool `description:"是否属于研选"`
  16. IsJump bool `description:"是否跳转"`
  17. IndustryNewLabel bool `description:"是否产业新标签"`
  18. }
  19. type IndustrialManagementCount struct {
  20. IndustrialManagementId int `orm:"column(industrial_management_id);pk" description:"产业id"`
  21. }
  22. type IndustrialManagementIdInt struct {
  23. IndustrialManagementId int `description:"产业Id"`
  24. IndustryName string `description:"产业名称"`
  25. SubjectName string `description:"标的名称"`
  26. ArticleId int `description:"文章ID"`
  27. IsResearch bool `description:"是否属于研选"`
  28. ChartPermissionId int `description:"权限id"`
  29. }
  30. type IndustrialManagementIdInts struct {
  31. IndustrialManagementId int `description:"产业Id"`
  32. IndustryName string `description:"产业名称"`
  33. SubjectNames string `description:"标的名称"`
  34. ArticleId int `description:"文章ID"`
  35. IndustrialAndSubjectIds string `description:"关联标的以及产业ID"`
  36. }
  37. type IndustrialManagementIdName struct {
  38. DepartmentId int `description:"作者ID"`
  39. ArticleId int `description:"文章id"`
  40. IndustryName string `description:"产业名称"`
  41. SubjectName string `description:"标的名称"`
  42. IsReport string `description:"1观点,0纪要"`
  43. }
  44. type IndustrialSubject struct {
  45. IndustrialSubjectId int `orm:"column(industrial_subject_id);pk" description:"标的id"`
  46. IndustrialManagementId int `description:"产业id"`
  47. SubjectName string `description:"标的名称"`
  48. IndustryName string `description:"产业名称"`
  49. }
  50. type IndustrialSubjectResp struct {
  51. IndustrialSubjectId int `orm:"column(industrial_subject_id);pk" description:"标的id"`
  52. SubjectName string `description:"标的名称"`
  53. }
  54. type IndustrialManagementArticle struct {
  55. IndustrialManagementId int `description:"产业Id"`
  56. IndustryName string `description:"产业名称"`
  57. ArticleId int `description:"文章ID"`
  58. PublishDate string `description:"发布时间"`
  59. }
  60. type IndustrialManagementResp struct {
  61. IndustrialManagementId int `description:"产业Id"`
  62. IndustryName string `description:"产业名称"`
  63. ChartPermissionId int `description:"权限id"`
  64. }
  65. // IndustryArtCount 产业文章数
  66. type IndustryArtCount struct {
  67. ArtNum int `json:"art_num" description:"文章数"`
  68. IndustrialManagementId int `json:"industrial_management_id" description:"产业ID"`
  69. }
  70. type IndustryVideoDetailResp struct {
  71. IndustryVideo *MicroVideoSimpleInfo
  72. AuthInfo *UserPermissionAuthInfo
  73. }
  74. //产业列表
  75. func GetIndustrialManagementAllCount(condition string) (count int, err error) {
  76. o := orm.NewOrm()
  77. sql := `SELECT
  78. COUNT(*) as count
  79. FROM
  80. (SELECT
  81. COUNT(*)
  82. FROM
  83. cygx_industrial_management AS man
  84. INNER JOIN cygx_report_mapping AS re ON re.chart_permission_id = man.chart_permission_id
  85. INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
  86. INNER JOIN cygx_article AS art ON art.article_id = man_g.article_id
  87. WHERE
  88. 1 = 1
  89. AND re.report_type = 2
  90. AND art.is_report = 1
  91. AND art.is_class = 1 ` + condition + ` GROUP BY man.industrial_management_id) AS num `
  92. err = o.Raw(sql).QueryRow(&count)
  93. return
  94. }
  95. //获取产业下阅读数量第三的产业详情
  96. func GetIndustrialManagementHot3(chartPermissionId int) (item *IndustrialManagementRep, err error) {
  97. o := orm.NewOrm()
  98. sql := `SELECT * FROM cygx_industrial_management WHERE chart_permission_id = ? ORDER BY article_read_num DESC LIMIT 2,1`
  99. err = o.Raw(sql, chartPermissionId).QueryRow(&item)
  100. return
  101. }
  102. //产业列表
  103. func GetIndustrialManagementAll(uid int, condition, orderSrt string, startSize, pageSize int, isBillboard bool) (items []*IndustrialManagement, err error) {
  104. o := orm.NewOrm()
  105. var conditionBillboard string
  106. if isBillboard {
  107. var startTime string
  108. startTime = time.Now().AddDate(0, 0, -30).Format(utils.FormatDate)
  109. conditionBillboard = ` ( SELECT COUNT( 1 ) FROM cygx_industry_fllow AS f WHERE f.industrial_management_id = man.industrial_management_id AND f.create_time > '` + startTime + `' ) AS follow_num, `
  110. }
  111. sql := `SELECT
  112. man.*,
  113. re.chart_permission_name,
  114. man.new_art_publish_date AS update_time ,
  115. MIN(art.publish_date) AS min_report_time,` + conditionBillboard + `
  116. (SELECT COUNT( 1 ) FROM cygx_industry_fllow AS f WHERE f.user_id = ` + strconv.Itoa(uid) + ` AND f.industrial_management_id = man.industrial_management_id AND f.type = 1) AS is_follow
  117. FROM
  118. cygx_industrial_management AS man
  119. INNER JOIN cygx_report_mapping AS re ON re.chart_permission_id = man.chart_permission_id
  120. INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
  121. INNER JOIN cygx_article AS art ON art.article_id = man_g.article_id
  122. WHERE 1= 1
  123. AND re.report_type = 2
  124. AND art.is_report = 1
  125. AND art.is_class = 1 ` + condition + `
  126. GROUP BY
  127. man.industry_name
  128. ORDER BY ` + orderSrt + ` LIMIT ?,?`
  129. _, err = o.Raw(sql, startSize, pageSize).QueryRows(&items)
  130. return
  131. }
  132. //标的列表
  133. func GetIndustrialSubjectAll(IndustrialManagementId int) (items []*IndustrialSubject, err error) {
  134. o := orm.NewOrm()
  135. sql := `SELECT * FROM cygx_industrial_subject WHERE industrial_management_id = ? `
  136. _, err = o.Raw(sql, IndustrialManagementId).QueryRows(&items)
  137. return
  138. }
  139. //获取该产业下最新的文章详情
  140. func GetIndustrialNewArticleDetail(industrialManagementId int) (item *ArticleDetail, err error) {
  141. o := orm.NewOrm()
  142. sql := `SELECT
  143. *
  144. FROM
  145. cygx_article
  146. WHERE
  147. article_id IN ( SELECT article_id FROM cygx_industrial_article_group_management WHERE industrial_management_id = ? )
  148. ORDER BY
  149. is_report DESC,
  150. publish_date DESC
  151. LIMIT 0,1`
  152. err = o.Raw(sql, industrialManagementId).QueryRow(&item)
  153. return
  154. }
  155. //获取该产业下最新的文章详情
  156. func GetNewArticleDetailByIndustrialIds(industrialIdArr []int) (items []*IndustrialManagementArticle, err error) {
  157. arrLen := len(industrialIdArr)
  158. if arrLen == 0 {
  159. return
  160. }
  161. o := orm.NewOrm()
  162. sql := `SELECT
  163. mg.industrial_management_id,
  164. MAX( a.article_id ) AS article_id,
  165. a.title,
  166. MAX( a.publish_date ) AS publish_date
  167. FROM
  168. cygx_industrial_article_group_management AS mg
  169. INNER JOIN cygx_article AS a ON mg.article_id = a.article_id
  170. WHERE
  171. 1 = 1
  172. AND a.is_report = 1
  173. AND a.is_class = 1
  174. AND mg.industrial_management_id IN(` + utils.GetOrmInReplace(len(industrialIdArr)) + `)
  175. GROUP BY
  176. mg.industrial_management_id `
  177. _, err = o.Raw(sql, industrialIdArr).QueryRows(&items)
  178. return
  179. }
  180. //获取产业数量
  181. func GetIndustrialManagementCount(IndustrialManagementId int) (count int, err error) {
  182. sqlCount := ` SELECT COUNT(1) AS count FROM cygx_industrial_management WHERE industrial_management_id=? `
  183. o := orm.NewOrm()
  184. err = o.Raw(sqlCount, IndustrialManagementId).QueryRow(&count)
  185. return
  186. }
  187. //获取关注数量
  188. func GetCountCygxIndustryFllow(industrialManagementId, userId int, condition string) (count int, err error) {
  189. sql := `SELECT COUNT(1) AS count FROM cygx_industry_fllow WHERE user_id=? AND industrial_management_id=? ` + condition
  190. err = orm.NewOrm().Raw(sql, userId, industrialManagementId).QueryRow(&count)
  191. return
  192. }
  193. func GetIndustrialManagementDetail(industrialManagementId int) (items *IndustrialManagementRep, err error) {
  194. o := orm.NewOrm()
  195. sql := `SELECT * FROM cygx_industrial_management WHERE industrial_management_id = ?`
  196. err = o.Raw(sql, industrialManagementId).QueryRow(&items)
  197. return
  198. }
  199. //获取所有的产业
  200. func GetindustrialManagement() (items []*IndustrialManagementRep, err error) {
  201. o := orm.NewOrm()
  202. sql := `SELECT
  203. i.*
  204. FROM
  205. cygx_industrial_management AS i
  206. INNER JOIN cygx_industrial_article_group_management AS m ON m.industrial_management_id = i.industrial_management_id
  207. GROUP BY
  208. i.industrial_management_id `
  209. _, err = o.Raw(sql).QueryRows(&items)
  210. return
  211. }
  212. //标的列表
  213. func GetIndustrialSubjectAllByIndustrialId(industrialIdArr []int) (items []*IndustrialSubject, err error) {
  214. o := orm.NewOrm()
  215. sql := `SELECT * FROM cygx_industrial_subject WHERE industrial_management_id IN (` + utils.GetOrmInReplace(len(industrialIdArr)) + `) `
  216. _, err = o.Raw(sql, industrialIdArr).QueryRows(&items)
  217. return
  218. }
  219. //获取标的列表
  220. func GetIndustrialListByarticleId(pars []interface{}, condition string) (items []*IndustrialManagementIdInt, err error) {
  221. o := orm.NewOrm()
  222. sql := `SELECT
  223. mg.article_id,
  224. m.industry_name,
  225. m.chart_permission_id,
  226. mg.industrial_management_id
  227. FROM
  228. cygx_industrial_management AS m
  229. INNER JOIN cygx_industrial_article_group_management AS mg ON mg.industrial_management_id = m.industrial_management_id
  230. WHERE
  231. 1 = 1 ` + condition + ` GROUP BY mg.article_id, mg.industrial_management_id `
  232. _, err = o.Raw(sql, pars).QueryRows(&items)
  233. return
  234. }
  235. // GetIndustryArtCountByCondition 获取产业文章关联的文章数
  236. func GetIndustryArtCountByCondition(condition string, pars []interface{}) (list []*IndustryArtCount, err error) {
  237. sql := `SELECT
  238. COUNT(1) AS art_num,
  239. agm.industrial_management_id
  240. FROM
  241. cygx_industrial_article_group_management AS agm
  242. JOIN cygx_industrial_management AS man ON man.industrial_management_id = agm.industrial_management_id
  243. WHERE
  244. 1 = 1 `
  245. if condition != "" {
  246. sql += condition
  247. }
  248. sql += ` GROUP BY agm.industrial_management_id`
  249. _, err = orm.NewOrm().Raw(sql, pars).QueryRows(&list)
  250. return
  251. }
  252. type IndustrialArticleGroupManagementResp struct {
  253. IndustrialManagementId int `description:"产业Id"`
  254. ArticleId int `description:"文章ID"`
  255. }
  256. // GetIndustrialArticleGroupManagementByIndustrialManagementId 获取产业文章关联的文章ID
  257. func GetIndustrialArticleGroupManagementByIndustrialManagementId(industrialManagementId int) (list []*IndustrialArticleGroupManagementResp, err error) {
  258. sql := `SELECT
  259. *
  260. FROM
  261. cygx_industrial_article_group_management
  262. WHERE
  263. industrial_management_id = ? `
  264. _, err = orm.NewOrm().Raw(sql, industrialManagementId).QueryRows(&list)
  265. return
  266. }
  267. // GetTopOneMonthArtReadNumIndustry 获取近一个月报告阅读数量最多的产业信息
  268. func GetTopOneMonthArtReadNumIndustry(condition string, pars []interface{}) (item *IndustrialManagement, err error) {
  269. sql := `SELECT * FROM cygx_industrial_management WHERE 1 = 1 `
  270. if condition != `` {
  271. sql += condition
  272. }
  273. sql += ` ORDER BY article_read_num DESC LIMIT 1`
  274. err = orm.NewOrm().Raw(sql, pars).QueryRow(&item)
  275. return
  276. }
  277. // GetTopIndustryFollowData 获取关注度最高的产业关注数据
  278. func GetTopIndustryFollowData(startSize, pageSize int, condition string, pars []interface{}) (list []*IndustrialManagement, err error) {
  279. sql := `SELECT
  280. COUNT(1) AS one_month_follow_num,
  281. man.*
  282. FROM
  283. cygx_industry_fllow AS idf
  284. JOIN cygx_industrial_management AS man ON idf.industrial_management_id = man.industrial_management_id
  285. WHERE 1 = 1 `
  286. if condition != "" {
  287. sql += condition
  288. }
  289. sql += ` GROUP BY
  290. idf.industrial_management_id
  291. ORDER BY
  292. one_month_follow_num DESC
  293. LIMIT ?,?`
  294. _, err = orm.NewOrm().Raw(sql, pars, startSize, pageSize).QueryRows(&list)
  295. return
  296. }
  297. // GetActiveArticleIndustryIds 获取有已归类行业报告的行业IDs
  298. func GetActiveArticleIndustryIds() (ids []int, err error) {
  299. sql := `SELECT
  300. man.industrial_management_id
  301. FROM
  302. cygx_industrial_management AS man
  303. JOIN cygx_report_mapping AS re ON re.chart_permission_id = man.chart_permission_id
  304. JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
  305. JOIN cygx_article AS art ON art.article_id = man_g.article_id
  306. WHERE
  307. 1 = 1 AND re.report_type = 2 AND art.is_report = 1 AND art.is_class = 1 AND art.publish_status = 1
  308. GROUP BY
  309. man.industrial_management_id`
  310. _, err = orm.NewOrm().Raw(sql).QueryRows(&ids)
  311. return
  312. }
  313. // GetIndustryByName 通过名称获取产业
  314. func GetIndustryByName(industryName string) (item *IndustrialManagement, err error) {
  315. sql := `SELECT * FROM cygx_industrial_management WHERE industry_name = ? LIMIT 1`
  316. err = orm.NewOrm().Raw(sql, industryName).QueryRow(&item)
  317. return
  318. }
  319. // GetSourceIndustryByName 通过名称获取资源包产业
  320. func GetSourceIndustryByName(industryName string) (item *IndustrialManagement, err error) {
  321. sql := `SELECT
  322. m.industry_name,
  323. m.industrial_management_id,
  324. m.chart_permission_id
  325. FROM
  326. cygx_industrial_management AS m
  327. INNER JOIN cygx_industrial_article_group_management AS mg ON mg.industrial_management_id = m.industrial_management_id
  328. INNER JOIN cygx_article AS a ON a.article_id = mg.article_id AND a.article_type != 'lyjh'
  329. WHERE
  330. 1 = 1 AND m.industry_name = ? AND a.publish_status = 1 AND a.article_id < 1000000
  331. GROUP BY
  332. m.industrial_management_id`
  333. err = orm.NewOrm().Raw(sql, industryName).QueryRow(&item)
  334. return
  335. }