industrial_management.go 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743
  1. package models
  2. import (
  3. "fmt"
  4. "github.com/beego/beego/v2/client/orm"
  5. "hongze/hongze_cygx/utils"
  6. "strconv"
  7. "strings"
  8. "time"
  9. )
  10. type IndustrialManagementRep struct {
  11. IndustryName string `description:"产业名称"`
  12. IndustrialManagementId int `description:"产业id"`
  13. ChartPermissionId int `description:"权限id"`
  14. RecommendedIndex int `description:"推荐指数"`
  15. LayoutTime string `description:"布局时间"`
  16. ArticleReadNum int `description:"文章阅读数量"`
  17. IsResearch bool `description:"是否属于研选"`
  18. IsJump bool `description:"是否跳转"`
  19. IndustryNewLabel bool `description:"是否产业新标签"`
  20. }
  21. type IndustrialManagementCount struct {
  22. IndustrialManagementId int `orm:"column(industrial_management_id);pk" description:"产业id"`
  23. }
  24. // 获取产业置顶数量分类列表
  25. func GetIndustrialManagemenCountTop(sqlChartPermissionId string, uid int, condition string) (items []*IndustrialManagementCount, err error) {
  26. o := orm.NewOrm()
  27. sql := `SELECT
  28. man_g.industrial_management_id
  29. FROM
  30. cygx_industrial_article_group_management AS man_g
  31. INNER JOIN cygx_industrial_management as man ON man.industrial_management_id = man_g.industrial_management_id
  32. WHERE 1=1 ` + sqlChartPermissionId + `
  33. AND man_g.industrial_management_id IN ( SELECT industrial_management_id FROM cygx_industry_top WHERE user_id = ? ) ` + condition + `
  34. GROUP BY
  35. man_g.industrial_management_id`
  36. _, err = o.Raw(sql, uid).QueryRows(&items)
  37. return
  38. }
  39. // 获取产业不置顶数量
  40. func GetIndustrialManagemenCountNoTop(sqlChartPermissionId string, uid int, condition string) (items []*IndustrialManagementCount, err error) {
  41. o := orm.NewOrm()
  42. sql := `SELECT
  43. man_g.industrial_management_id
  44. FROM
  45. cygx_industrial_article_group_management AS man_g
  46. INNER JOIN cygx_industrial_management as man ON man.industrial_management_id = man_g.industrial_management_id
  47. WHERE 1=1 ` + sqlChartPermissionId + `
  48. AND man_g.industrial_management_id NOT IN ( SELECT industrial_management_id FROM cygx_industry_top WHERE user_id = ? ) ` + condition + `
  49. GROUP BY
  50. man_g.industrial_management_id`
  51. _, err = o.Raw(sql, uid).QueryRows(&items)
  52. return
  53. }
  54. // 产业列表
  55. func GetIndustrialManagementAll(uid int, condition, orderSrt string, startSize, pageSize int) (items []*IndustrialManagement, err error) {
  56. o := orm.NewOrm()
  57. sql := `SELECT
  58. man.*,re.chart_permission_name as permission_name,
  59. MAX(art.article_id ) AS article_id,
  60. man.new_art_publish_date AS update_time , MIN(art.publish_date) AS min_report_time,(
  61. SELECT COUNT( 1 ) FROM cygx_article_history_record AS rec WHERE rec.user_id = ` + strconv.Itoa(uid) + ` AND rec.article_id = art.article_id ) AS readnum ,
  62. (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
  63. FROM
  64. cygx_industrial_management AS man
  65. INNER JOIN cygx_report_mapping AS re ON re.chart_permission_id = man.chart_permission_id
  66. INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
  67. INNER JOIN cygx_article AS art ON art.article_id = man_g.article_id
  68. WHERE 1= 1
  69. AND re.report_type = 2
  70. AND art.is_report = 1
  71. AND art.is_class = 1 ` + condition + `
  72. GROUP BY
  73. man.industry_name
  74. ORDER BY ` + orderSrt + ` LIMIT ?,?`
  75. //AND man.industrial_management_id NOT IN ( SELECT industrial_management_id FROM cygx_industry_top WHERE user_id = ` + strconv.Itoa(uid) + ` )
  76. _, err = o.Raw(sql, startSize, pageSize).QueryRows(&items)
  77. return
  78. }
  79. // 产业列表
  80. func GetIndustrialManagementAllCount(condition string) (count int, err error) {
  81. o := orm.NewOrm()
  82. sql := `SELECT
  83. COUNT(*) as count
  84. FROM
  85. (SELECT
  86. COUNT(*)
  87. FROM
  88. cygx_industrial_management AS man
  89. INNER JOIN cygx_report_mapping AS re ON re.chart_permission_id = man.chart_permission_id
  90. INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
  91. INNER JOIN cygx_article AS art ON art.article_id = man_g.article_id
  92. WHERE
  93. 1 = 1
  94. AND re.report_type = 2
  95. AND art.is_report = 1
  96. AND art.is_class = 1 ` + condition + ` GROUP BY man.industrial_management_id) AS num `
  97. err = o.Raw(sql).QueryRow(&count)
  98. return
  99. }
  100. // 产业列表 -置顶
  101. func GetIndustrialManagementTopAll(uid int, condition string, startSize, pageSize int) (items []*IndustrialManagement, err error) {
  102. o := orm.NewOrm()
  103. sql := `SELECT
  104. man.*
  105. FROM
  106. cygx_industrial_management AS man
  107. INNER JOIN cygx_industry_top as top ON man.industrial_management_id = top.industrial_management_id
  108. INNER JOIN cygx_report_mapping AS re ON re.chart_permission_id = man.chart_permission_id
  109. INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
  110. INNER JOIN cygx_article AS art ON art.article_id = man_g.article_id
  111. WHERE 1=1
  112. AND top.user_id = ` + strconv.Itoa(uid) + `
  113. AND re.report_type = 2
  114. AND art.is_report = 1
  115. AND art.is_class = 1 ` + condition + `
  116. GROUP BY
  117. man.industry_name
  118. ORDER BY
  119. top.create_time DESC LIMIT ?,?`
  120. _, err = o.Raw(sql, startSize, pageSize).QueryRows(&items)
  121. return
  122. }
  123. // 标的列表
  124. func GetIndustrialSubjectAll(IndustrialManagementId int) (items []*IndustrialSubject, err error) {
  125. o := orm.NewOrm()
  126. sql := `SELECT * FROM cygx_industrial_subject WHERE industrial_management_id = ? `
  127. _, err = o.Raw(sql, IndustrialManagementId).QueryRows(&items)
  128. return
  129. }
  130. // 标的列表
  131. func GetIndustrialSubjectAllByIndustrialId(industrialIdArr []int) (items []*IndustrialSubject, err error) {
  132. o := orm.NewOrm()
  133. sql := `SELECT * FROM cygx_industrial_subject WHERE industrial_management_id IN (` + utils.GetOrmInReplace(len(industrialIdArr)) + `) `
  134. _, err = o.Raw(sql, industrialIdArr).QueryRows(&items)
  135. return
  136. }
  137. // GetTopOneMonthArtReadNumIndustry 获取近一个月报告阅读数量最多的产业信息 根据行业分组
  138. func GetTopOneMonthArtReadNumIndustryAll(condition string, pars []interface{}) (items []*IndustrialManagement, err error) {
  139. sql := `SELECT * FROM cygx_industrial_management WHERE 1 = 1 `
  140. if condition != `` {
  141. sql += condition
  142. }
  143. sql += ` ORDER BY article_read_num DESC `
  144. _, err = orm.NewOrm().Raw(sql, pars).QueryRows(&items)
  145. return
  146. }
  147. // 分析师列表
  148. func GetIndustrialAnalystAll(IndustrialManagementId int) (items []*IndustrialAnalyst, err error) {
  149. o := orm.NewOrm()
  150. sql := `SELECT * FROM cygx_industrial_analyst where industrial_management_id = ? `
  151. _, err = o.Raw(sql, IndustrialManagementId).QueryRows(&items)
  152. return
  153. }
  154. // 获取产业数量
  155. func GetIndustrialManagementCount(IndustrialManagementId int) (count int, err error) {
  156. sqlCount := ` SELECT COUNT(1) AS count FROM cygx_industrial_management WHERE industrial_management_id=? `
  157. o := orm.NewOrm()
  158. err = o.Raw(sqlCount, IndustrialManagementId).QueryRow(&count)
  159. return
  160. }
  161. func GetIndustrialManagementDetail(industrialManagementId int) (items *IndustrialManagementRep, err error) {
  162. o := orm.NewOrm()
  163. sql := `SELECT * FROM cygx_industrial_management WHERE industrial_management_id = ?`
  164. err = o.Raw(sql, industrialManagementId).QueryRow(&items)
  165. return
  166. }
  167. // 获取该产业下最新的文章详情
  168. func GetIndustrialNewArticleDetail(industrialManagementId int) (item *ArticleDetail, err error) {
  169. o := orm.NewOrm()
  170. sql := `SELECT
  171. *
  172. FROM
  173. cygx_article
  174. WHERE
  175. article_id IN (
  176. SELECT
  177. article_id
  178. FROM
  179. cygx_industrial_article_group_management
  180. WHERE
  181. industrial_management_id = ?
  182. )
  183. AND is_class = 1 AND is_report = 1
  184. ORDER BY
  185. is_report DESC,
  186. publish_date DESC
  187. LIMIT 0,1`
  188. err = o.Raw(sql, industrialManagementId).QueryRow(&item)
  189. return
  190. }
  191. // 修改产业是否属于新标签
  192. func UpdateIndustrialIsNewLabel() (err error) {
  193. o := orm.NewOrm()
  194. resultTime := time.Now().AddDate(0, -2, 0).Format(utils.FormatDateTime)
  195. var condition string
  196. condition += ` AND is_hand_new_label = 0 AND create_time < ` + "'" + resultTime + "'"
  197. msql := " UPDATE cygx_industrial_management SET is_new_label = 0 WHERE 1 = 1 " + condition
  198. _, err = o.Raw(msql).Exec()
  199. return
  200. }
  201. type IndustrialManagementId struct {
  202. IndustrialManagementId string `description:"产业Id"`
  203. }
  204. // 获取归类产业报告数量大于10的
  205. func GetIndustrialMorethan10() (items []*IndustrialManagementId, err error) {
  206. o := orm.NewOrm()
  207. sql := `SELECT * FROM
  208. ( SELECT industrial_management_id, COUNT( 1 ) AS ca FROM cygx_industrial_article_group_management GROUP BY industrial_management_id ) AS na
  209. WHERE ca > 10 `
  210. _, err = o.Raw(sql).QueryRows(&items)
  211. return
  212. }
  213. // 修改产业是否属于深度标签
  214. func UpdateIndustrialIsDeepLabel(idStr string) (err error) {
  215. o := orm.NewOrm()
  216. msql := `UPDATE cygx_industrial_management
  217. SET is_deep_label = 1
  218. WHERE
  219. industrial_management_id IN (
  220. SELECT
  221. a.industrial_management_id
  222. FROM
  223. cygx_industrial_article_group_management AS a
  224. INNER JOIN cygx_article AS b ON b.id = a.cygx_article_id
  225. WHERE
  226. 1 = 1
  227. AND b.match_type_name = '行业深度'
  228. AND a.industrial_management_id IN ( ` + idStr + `)
  229. GROUP BY
  230. a.industrial_management_id)`
  231. _, err = o.Raw(msql).Exec()
  232. return
  233. }
  234. type IndustrialManagementIdInt struct {
  235. IndustrialManagementId int `description:"产业Id"`
  236. IndustryName string `description:"产业名称"`
  237. SubjectName string `description:"标的名称"`
  238. ArticleId int `description:"文章ID"`
  239. IsResearch bool `description:"是否属于研选"`
  240. ChartPermissionId int `description:"权限id"`
  241. }
  242. type IndustrialManagementIdInts struct {
  243. IndustrialManagementId int `description:"产业Id"`
  244. IndustryName string `description:"产业名称"`
  245. SubjectNames string `description:"标的名称"`
  246. ArticleId int `description:"文章ID"`
  247. IndustrialAndSubjectIds string `description:"关联标的以及产业ID"`
  248. }
  249. type IndustrialManagementIdName struct {
  250. DepartmentId int `description:"作者ID"`
  251. ArticleId int `description:"文章id"`
  252. IndustryName string `description:"产业名称"`
  253. SubjectName string `description:"标的名称"`
  254. IsReport string `description:"1观点,0纪要"`
  255. }
  256. // 获取归类产业报告数量大于10的
  257. func GetIndustrialManagementIds() (items []*IndustrialManagementIdInt, err error) {
  258. o := orm.NewOrm()
  259. //sql := `SELECT a.industrial_management_id FROM
  260. // cygx_industrial_management AS a
  261. // INNER JOIN cygx_industrial_subject as b ON b.industrial_management_id=a.industrial_management_id
  262. // WHERE b.industrial_subject_id > 0
  263. // GROUP BY a.industrial_management_id `
  264. sql := `SELECT industrial_management_id,industry_name FROM cygx_industrial_management `
  265. _, err = o.Raw(sql).QueryRows(&items)
  266. return
  267. }
  268. func GetcygxIndustrialSubject(industrialManagementId int) (items []*IndustrialSubject, err error) {
  269. o := orm.NewOrm()
  270. sql := `SELECT subject_name,industrial_subject_id FROM cygx_industrial_subject WHERE industrial_management_id = ?`
  271. _, err = o.Raw(sql, industrialManagementId).QueryRows(&items)
  272. return
  273. }
  274. // 通过名称获取
  275. func GetcygxIndustrialSubjectByName(name string) (industrial_management_id string, err error) {
  276. o := orm.NewOrm()
  277. sql := ` SELECT industrial_subject_id FROM cygx_industrial_subject WHERE subject_name = ?`
  278. err = o.Raw(sql, name).QueryRow(&industrial_management_id)
  279. return
  280. }
  281. func UpdateIndustrialManagementSubjectNames(nameStr string, industrialManagementId int) (err error) {
  282. o := orm.NewOrm()
  283. sql := `UPDATE cygx_industrial_management SET subject_names = ? WHERE industrial_management_id = ?`
  284. _, err = o.Raw(sql, nameStr, industrialManagementId).Exec()
  285. return
  286. }
  287. // 处理每个产业下所关联的文章的阅读量 start
  288. func IndustrialManagementAll() (items []*IndustrialManagement, err error) {
  289. o := orm.NewOrm()
  290. sql := `SELECT * FROM cygx_industrial_management `
  291. _, err = o.Raw(sql).QueryRows(&items)
  292. return
  293. }
  294. func GetIndustrialManagementArtCount(industrialManagementId int) (count int, err error) {
  295. sqlCount := ` SELECT COUNT(1) AS count
  296. FROM cygx_article_history_record_newpv AS h
  297. INNER JOIN cygx_industrial_article_group_management as mg ON mg.article_id = h.article_id
  298. WHERE mg.industrial_management_id = ? AND DATE_SUB( CURDATE(), INTERVAL 30 DAY ) <= date( h.create_time ) `
  299. o := orm.NewOrm()
  300. err = o.Raw(sqlCount, industrialManagementId).QueryRow(&count)
  301. return
  302. }
  303. func UpdateIndustrialManagementArtReadNum(num, industrialManagementId int) (err error) {
  304. o := orm.NewOrm()
  305. sql := `UPDATE cygx_industrial_management SET article_read_num = ? WHERE industrial_management_id = ?`
  306. _, err = o.Raw(sql, num, industrialManagementId).Exec()
  307. return
  308. }
  309. // 更新产业布局时间
  310. func UpdateIndustrialManagementLayoutTime(layoutTime string, industrialManagementId int) (err error) {
  311. o := orm.NewOrm()
  312. sql := `UPDATE cygx_industrial_management SET layout_time = ? WHERE industrial_management_id = ?`
  313. _, err = o.Raw(sql, layoutTime, industrialManagementId).Exec()
  314. return
  315. }
  316. // 获取产业下阅读数量第三的产业详情
  317. func GetIndustrialManagementHot3(chartPermissionId int) (item *IndustrialManagementRep, err error) {
  318. o := orm.NewOrm()
  319. sql := `SELECT * FROM cygx_industrial_management WHERE chart_permission_id = ? ORDER BY article_read_num DESC LIMIT 2,1`
  320. err = o.Raw(sql, chartPermissionId).QueryRow(&item)
  321. return
  322. }
  323. // 获取产业关联标的的数量
  324. func GetIndustrialManagementSubjectCount(industrialManagementId int) (count int, err error) {
  325. sqlCount := ` SELECT COUNT(1) AS count FROM
  326. cygx_industrial_subject AS s
  327. INNER JOIN cygx_industrial_article_group_subject as sg ON sg.industrial_subject_id = s.industrial_subject_id
  328. INNER JOIN cygx_article as a ON a.article_id = sg.article_id
  329. WHERE a.industrial_management_id = ?
  330. AND a.publish_status = 1`
  331. o := orm.NewOrm()
  332. err = o.Raw(sqlCount, industrialManagementId).QueryRow(&count)
  333. return
  334. }
  335. // 获取产业关联标的列表
  336. func GetIndustrialManagementSubjectList(articleId int) (items []*IndustrialSubject, err error) {
  337. o := orm.NewOrm()
  338. sql := `SELECT
  339. s.subject_name
  340. FROM
  341. cygx_industrial_subject AS s
  342. INNER JOIN cygx_industrial_article_group_subject AS sg ON sg.industrial_subject_id = s.industrial_subject_id
  343. INNER JOIN cygx_article AS a
  344. WHERE
  345. sg.article_id = ?
  346. AND a.publish_status = 1
  347. GROUP BY
  348. s.industrial_subject_id
  349. ORDER BY
  350. sg.id ASC
  351. LIMIT 4`
  352. _, err = o.Raw(sql, articleId).QueryRows(&items)
  353. return
  354. }
  355. type IndustrialManagementNewResp struct {
  356. IndustrialManagementId int `description:"产业Id"`
  357. IndustryName string `description:"产业名称"`
  358. IsHot bool `description:"是否是热门"`
  359. ArticleReadNum int `description:"文章阅读数量"`
  360. }
  361. type IndustrialManagementNewList struct {
  362. List []*IndustrialManagementNewResp
  363. }
  364. // 近期更新主题列表
  365. func GetIndustrialManagementNewList(condition string) (items []*IndustrialManagementNewResp, err error) {
  366. o := orm.NewOrm()
  367. sql := `SELECT
  368. m.industrial_management_id,
  369. m.industry_name,
  370. m.article_read_num,
  371. MAX( a.publish_date ) AS publish_date
  372. FROM
  373. cygx_article AS a
  374. INNER JOIN cygx_industrial_article_group_management AS mg ON mg.article_id = a.article_id
  375. INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = mg.industrial_management_id
  376. WHERE
  377. 1 = 1
  378. AND a.article_type_id > 0
  379. AND publish_status = 1 ` + condition + `
  380. GROUP BY
  381. m.industrial_management_id
  382. ORDER BY
  383. publish_date DESC LIMIT 12`
  384. _, err = o.Raw(sql).QueryRows(&items)
  385. return
  386. }
  387. // 获取产业关联标的列表
  388. func GetIndustrialManagementForSubjecName(subjectName string, chartPermissionId int) (items []*IndustrialSubject, err error) {
  389. o := orm.NewOrm()
  390. sql := `SELECT s.subject_name,s.industrial_subject_id,m.industrial_management_id,m.industry_name,layout_time
  391. FROM cygx_industrial_subject as s
  392. INNER JOIN cygx_industrial_management as m ON m.industrial_management_id = s.industrial_management_id
  393. WHERE subject_name IN (` + subjectName + `) AND m.chart_permission_id = ? `
  394. _, err = o.Raw(sql, chartPermissionId).QueryRows(&items)
  395. return
  396. }
  397. // 报告分类的新增与修改
  398. func ReportArticleClassificationEditNew(reportId int, industrialManagementIdStr string, articleId int, ndustrialSubjectIdStr string) (err error) {
  399. to, err := orm.NewOrm().Begin()
  400. if err != nil {
  401. return
  402. }
  403. defer func() {
  404. fmt.Println(err)
  405. if err == nil {
  406. to.Commit()
  407. } else {
  408. to.Rollback()
  409. }
  410. }()
  411. //修改文章是否过滤字段
  412. sql := `UPDATE cygx_article SET is_filter=0, is_class=1 WHERE article_id=? `
  413. _, err = to.Raw(sql, articleId).Exec()
  414. if err != nil {
  415. return
  416. }
  417. //删除文章关联标的
  418. sql = ` DELETE FROM cygx_industrial_article_group_subject WHERE article_id = ?`
  419. fmt.Println(articleId)
  420. _, err = to.Raw(sql, articleId).Exec()
  421. if err != nil {
  422. return
  423. }
  424. //添加文章关联标的
  425. if ndustrialSubjectIdStr != "0" && ndustrialSubjectIdStr != "" {
  426. strList := strings.Split(ndustrialSubjectIdStr, ",")
  427. for _, v := range strList {
  428. sql := `INSERT INTO cygx_industrial_article_group_subject ( cygx_article_id, article_id, industrial_subject_id, create_time ) VALUES ( ?, ?, ?, ? )`
  429. _, err = to.Raw(sql, reportId, articleId, v, time.Now()).Exec()
  430. if err != nil {
  431. return
  432. }
  433. }
  434. }
  435. //删除文章关联行业 (避免截断表时产生的脏数据,故不用update而是先删除再增加)
  436. sql = ` DELETE FROM cygx_industrial_article_group_management WHERE article_id = ?`
  437. _, err = to.Raw(sql, articleId).Exec()
  438. if err != nil {
  439. return
  440. }
  441. //添加文章关联行业
  442. industrialStrList := strings.Split(industrialManagementIdStr, ",")
  443. for _, v := range industrialStrList {
  444. sql = ` INSERT INTO cygx_industrial_article_group_management ( cygx_article_id, article_id, industrial_management_id, create_time ) VALUES ( ?, ?, ?, ? )`
  445. _, err = to.Raw(sql, reportId, articleId, v, time.Now()).Exec()
  446. if err != nil {
  447. return
  448. }
  449. }
  450. return
  451. }
  452. // 通过标的名称获取相关联的活动ID
  453. func GetActivityIdListBySubjecName(subjectName string) (items []*ActivityIdRep, err error) {
  454. o := orm.NewOrm()
  455. sql := `SELECT * FROM cygx_industrial_activity_group_subject WHERE industrial_subject_id IN (SELECT industrial_subject_id FROM cygx_industrial_subject WHERE subject_name IN(` + subjectName + `) ) GROUP BY activity_id`
  456. _, err = o.Raw(sql).QueryRows(&items)
  457. return
  458. }
  459. // 产业关注榜
  460. func GetIndustrialManagementFllowBillboard(pars []interface{}, condition, orderSrt string, startSize, pageSize int) (items []*IndustrialManagement, err error) {
  461. o := orm.NewOrm()
  462. sql := `SELECT
  463. man.*
  464. FROM
  465. cygx_industrial_management AS man
  466. INNER JOIN cygx_report_mapping AS re ON re.chart_permission_id = man.chart_permission_id
  467. INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
  468. INNER JOIN cygx_article AS art ON art.article_id = man_g.article_id
  469. WHERE
  470. 1 = 1
  471. AND re.report_type = 2
  472. AND art.is_report = 1
  473. AND art.is_class = 1
  474. AND art.publish_status = 1 ` + condition + ` GROUP BY man.industrial_management_id ORDER BY ` + orderSrt + ` LIMIT ?,?`
  475. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  476. return
  477. }
  478. // 获取标的列表
  479. func GetSubjectList(pars []interface{}, condition string) (items []*IndustrialManagementIdInt, err error) {
  480. o := orm.NewOrm()
  481. sql := `SELECT
  482. subject_name,
  483. s.industrial_management_id
  484. FROM
  485. cygx_industrial_subject AS s
  486. INNER JOIN cygx_industrial_article_group_subject AS sg ON sg.industrial_subject_id = s.industrial_subject_id
  487. WHERE
  488. 1 = 1 ` + condition + `
  489. GROUP BY
  490. s.industrial_subject_id`
  491. _, err = o.Raw(sql, pars).QueryRows(&items)
  492. return
  493. }
  494. // 获取标的列表
  495. func GetIndustrialListByarticleId(pars []interface{}, condition string) (items []*IndustrialManagementIdInt, err error) {
  496. o := orm.NewOrm()
  497. sql := `SELECT
  498. mg.article_id,
  499. m.industry_name,
  500. mg.industrial_management_id
  501. FROM
  502. cygx_industrial_management AS m
  503. INNER JOIN cygx_industrial_article_group_management AS mg ON mg.industrial_management_id = m.industrial_management_id
  504. WHERE
  505. 1 = 1 ` + condition + ` GROUP BY mg.article_id, mg.industrial_management_id `
  506. _, err = o.Raw(sql, pars).QueryRows(&items)
  507. return
  508. }
  509. // 修改产业关注数量
  510. func UpdateIndustrialManagementFllowNum(num, industrialManagementId int) (err error) {
  511. o := orm.NewOrm()
  512. sql := `UPDATE cygx_industrial_management SET user_fllow_num = ? WHERE industrial_management_id = ?`
  513. _, err = o.Raw(sql, num, industrialManagementId).Exec()
  514. return
  515. }
  516. // 通过id 获取详情
  517. func GetIndustrialManagemenDetailByAaticleID(articleId int) (items []*IndustrialManagementRep, err error) {
  518. o := orm.NewOrm()
  519. sql := `SELECT
  520. article_id,
  521. m.industrial_management_id,
  522. industry_name
  523. FROM
  524. cygx_industrial_article_group_management AS mg
  525. INNER JOIN cygx_industrial_management AS m ON mg.industrial_management_id = m.industrial_management_id
  526. WHERE
  527. mg.article_id = ? GROUP BY mg.industrial_management_id `
  528. _, err = o.Raw(sql, articleId).QueryRows(&items)
  529. return
  530. }
  531. // 获取所有的产业
  532. func GetindustrialManagement() (items []*IndustrialManagementRep, err error) {
  533. o := orm.NewOrm()
  534. sql := `SELECT
  535. i.*
  536. FROM
  537. cygx_industrial_management AS i
  538. INNER JOIN cygx_industrial_article_group_management AS m ON m.industrial_management_id = i.industrial_management_id
  539. GROUP BY
  540. i.industrial_management_id `
  541. _, err = o.Raw(sql).QueryRows(&items)
  542. return
  543. }
  544. // GetActiveArticleIndustryIds 获取有已归类行业报告的行业IDs
  545. func GetActiveArticleIndustryIds() (ids []int, err error) {
  546. sql := `SELECT
  547. man.industrial_management_id
  548. FROM
  549. cygx_industrial_management AS man
  550. JOIN cygx_report_mapping AS re ON re.chart_permission_id = man.chart_permission_id
  551. JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
  552. JOIN cygx_article AS art ON art.article_id = man_g.article_id
  553. WHERE
  554. 1 = 1 AND re.report_type = 2 AND art.is_report = 1 AND art.is_class = 1 AND art.publish_status = 1
  555. GROUP BY
  556. man.industrial_management_id`
  557. _, err = orm.NewOrm().Raw(sql).QueryRows(&ids)
  558. return
  559. }
  560. // GetTopOneMonthArtReadNumIndustry 获取近一个月报告阅读数量最多的产业信息
  561. func GetTopOneMonthArtReadNumIndustry(condition string, pars []interface{}) (item *IndustrialManagement, err error) {
  562. sql := `SELECT * FROM cygx_industrial_management WHERE 1 = 1 `
  563. if condition != `` {
  564. sql += condition
  565. }
  566. sql += ` ORDER BY article_read_num DESC LIMIT 1`
  567. err = orm.NewOrm().Raw(sql, pars).QueryRow(&item)
  568. return
  569. }
  570. // GetSourceIndustryByName 通过名称获取资源包产业
  571. func GetSourceIndustryByName(industryName string) (item *IndustrialManagement, err error) {
  572. sql := `SELECT
  573. m.industry_name,
  574. m.industrial_management_id,
  575. m.chart_permission_id
  576. FROM
  577. cygx_industrial_management AS m
  578. INNER JOIN cygx_industrial_article_group_management AS mg ON mg.industrial_management_id = m.industrial_management_id
  579. INNER JOIN cygx_article AS a ON a.article_id = mg.article_id AND a.article_type != 'lyjh'
  580. WHERE
  581. 1 = 1 AND m.industry_name = ? AND a.publish_status = 1 AND a.article_id < 1000000
  582. GROUP BY
  583. m.industrial_management_id`
  584. err = orm.NewOrm().Raw(sql, industryName).QueryRow(&item)
  585. return
  586. }
  587. // GetIndustryByName 通过名称获取产业
  588. func GetIndustryByName(industryName string) (item *IndustrialManagement, err error) {
  589. sql := `SELECT * FROM cygx_industrial_management WHERE industry_name = ? LIMIT 1`
  590. err = orm.NewOrm().Raw(sql, industryName).QueryRow(&item)
  591. return
  592. }
  593. type IndustrialManagementArticle struct {
  594. IndustrialManagementId int `description:"产业Id"`
  595. IndustryName string `description:"产业名称"`
  596. ArticleId int `description:"文章ID"`
  597. PublishDate string `description:"发布时间"`
  598. }
  599. // 时间线的更新时间
  600. func GetTimeLineReportIndustrialPublishdateList(industrialIdArr []int) (items []*IndustrialManagementArticle, err error) {
  601. if len(industrialIdArr) == 0 {
  602. return
  603. }
  604. o := orm.NewOrm()
  605. sql := `SELECT
  606. mmc.id,
  607. 0,
  608. mmc.industry_id AS industrial_management_id,
  609. mmc.content AS title,
  610. MAX( mm.meeting_time ) AS publish_date
  611. FROM
  612. cygx_morning_meeting_review_chapter AS mmc
  613. INNER JOIN cygx_morning_meeting_reviews AS mm
  614. WHERE
  615. mm.id = mmc.meeting_id
  616. AND mm.STATUS = 1
  617. AND mmc.industry_id IN (` + utils.GetOrmInReplace(len(industrialIdArr)) + `)
  618. GROUP BY industrial_management_id ORDER BY publish_date DESC `
  619. _, err = o.Raw(sql, industrialIdArr).QueryRows(&items)
  620. return
  621. }
  622. // 获取该产业下最新的文章详情
  623. func GetNewArticleDetailByIndustrialIds(industrialIdArr []int) (items []*IndustrialManagementArticle, err error) {
  624. arrLen := len(industrialIdArr)
  625. if arrLen == 0 {
  626. return
  627. }
  628. o := orm.NewOrm()
  629. sql := `SELECT
  630. mg.industrial_management_id,
  631. MAX( a.article_id ) AS article_id,
  632. a.title,
  633. MAX( a.publish_date ) AS publish_date
  634. FROM
  635. cygx_industrial_article_group_management AS mg
  636. INNER JOIN cygx_article AS a ON mg.article_id = a.article_id
  637. WHERE
  638. 1 = 1
  639. AND a.is_report = 1
  640. AND a.is_class = 1
  641. AND mg.industrial_management_id IN(` + utils.GetOrmInReplace(len(industrialIdArr)) + `)
  642. GROUP BY
  643. mg.industrial_management_id `
  644. _, err = o.Raw(sql, industrialIdArr).QueryRows(&items)
  645. return
  646. }
  647. // GetIndustrialManagementArticleNewPublishData 获取产业关联文章的最新发布时间
  648. func GetIndustrialManagementArticleNewPublishData() (items []*IndustrialManagement, err error) {
  649. o := orm.NewOrm()
  650. sql := `SELECT
  651. man.industrial_management_id,
  652. MAX( art.publish_date ) AS update_time
  653. FROM
  654. cygx_industrial_management AS man
  655. INNER JOIN cygx_report_mapping AS re ON re.chart_permission_id = man.chart_permission_id
  656. INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
  657. INNER JOIN cygx_article AS art ON art.article_id = man_g.article_id
  658. WHERE
  659. 1 = 1
  660. AND re.report_type = 2
  661. AND art.is_report = 1
  662. AND art.is_class = 1
  663. GROUP BY
  664. man.industry_name
  665. ORDER BY
  666. update_time DESC`
  667. _, err = o.Raw(sql).QueryRows(&items)
  668. return
  669. }
  670. // UpdateIndustrialManagementArticleNewPublishData 批量修改获取产业关联文章的最新发布时间
  671. func UpdateIndustrialManagementArticleNewPublishData(items map[int]string) (err error) {
  672. o := orm.NewOrm()
  673. p, err := o.Raw("UPDATE cygx_industrial_management SET new_art_publish_date = ? WHERE industrial_management_id = ?").Prepare()
  674. if err != nil {
  675. return
  676. }
  677. defer func() {
  678. _ = p.Close() // 别忘记关闭 statement
  679. }()
  680. for k, v := range items {
  681. _, err = p.Exec(v, k)
  682. if err != nil {
  683. return
  684. }
  685. }
  686. return
  687. }