industrial_management.go 26 KB

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