industrial_management.go 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300
  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. }
  18. type IndustrialManagementCount struct {
  19. IndustrialManagementId int `orm:"column(industrial_management_id);pk" description:"产业id"`
  20. }
  21. type IndustrialManagementIdInt struct {
  22. IndustrialManagementId int `description:"产业Id"`
  23. IndustryName string `description:"产业名称"`
  24. SubjectName string `description:"标的名称"`
  25. ArticleId int `description:"文章ID"`
  26. IsResearch bool `description:"是否属于研选"`
  27. ChartPermissionId int `description:"权限id"`
  28. }
  29. type IndustrialManagementIdInts struct {
  30. IndustrialManagementId int `description:"产业Id"`
  31. IndustryName string `description:"产业名称"`
  32. SubjectNames string `description:"标的名称"`
  33. ArticleId int `description:"文章ID"`
  34. IndustrialAndSubjectIds string `description:"关联标的以及产业ID"`
  35. }
  36. type IndustrialManagementIdName struct {
  37. DepartmentId int `description:"作者ID"`
  38. ArticleId int `description:"文章id"`
  39. IndustryName string `description:"产业名称"`
  40. SubjectName string `description:"标的名称"`
  41. IsReport string `description:"1观点,0纪要"`
  42. }
  43. type IndustrialSubject struct {
  44. IndustrialSubjectId int `orm:"column(industrial_subject_id);pk" description:"标的id"`
  45. IndustrialManagementId int `description:"产业id"`
  46. SubjectName string `description:"标的名称"`
  47. IndustryName string `description:"产业名称"`
  48. }
  49. type IndustrialSubjectResp struct {
  50. IndustrialSubjectId int `orm:"column(industrial_subject_id);pk" description:"标的id"`
  51. SubjectName string `description:"标的名称"`
  52. }
  53. type IndustrialManagementArticle struct {
  54. IndustrialManagementId int `description:"产业Id"`
  55. IndustryName string `description:"产业名称"`
  56. ArticleId int `description:"文章ID"`
  57. PublishDate string `description:"发布时间"`
  58. }
  59. type IndustrialManagementResp struct {
  60. IndustrialManagementId int `description:"产业Id"`
  61. IndustryName string `description:"产业名称"`
  62. ChartPermissionId int `description:"权限id"`
  63. }
  64. // IndustryArtCount 产业文章数
  65. type IndustryArtCount struct {
  66. ArtNum int `json:"art_num" description:"文章数"`
  67. IndustrialManagementId int `json:"industrial_management_id" description:"产业ID"`
  68. }
  69. //产业列表
  70. func GetIndustrialManagementAllCount(condition string) (count int, err error) {
  71. o := orm.NewOrm()
  72. sql := `SELECT
  73. COUNT(*) as count
  74. FROM
  75. (SELECT
  76. COUNT(*)
  77. FROM
  78. cygx_industrial_management AS man
  79. INNER JOIN cygx_report_mapping AS re ON re.chart_permission_id = man.chart_permission_id
  80. INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
  81. INNER JOIN cygx_article AS art ON art.article_id = man_g.article_id
  82. WHERE
  83. 1 = 1
  84. AND re.report_type = 2
  85. AND art.is_report = 1
  86. AND art.is_class = 1 ` + condition + ` GROUP BY man.industrial_management_id) AS num `
  87. err = o.Raw(sql).QueryRow(&count)
  88. return
  89. }
  90. //获取产业下阅读数量第三的产业详情
  91. func GetIndustrialManagementHot3(chartPermissionId int) (item *IndustrialManagementRep, err error) {
  92. o := orm.NewOrm()
  93. sql := `SELECT * FROM cygx_industrial_management WHERE chart_permission_id = ? ORDER BY article_read_num DESC LIMIT 2,1`
  94. err = o.Raw(sql, chartPermissionId).QueryRow(&item)
  95. return
  96. }
  97. //产业列表
  98. func GetIndustrialManagementAll(uid int, condition, orderSrt string, startSize, pageSize int, isBillboard bool) (items []*IndustrialManagement, err error) {
  99. o := orm.NewOrm()
  100. var conditionBillboard string
  101. if isBillboard {
  102. var startTime string
  103. startTime = time.Now().AddDate(0, 0, -30).Format(utils.FormatDate)
  104. 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, `
  105. }
  106. sql := `SELECT
  107. man.*,
  108. re.chart_permission_name,
  109. MAX( art.publish_date ) AS update_time ,
  110. MIN(art.publish_date) AS min_report_time,` + conditionBillboard + `
  111. (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
  112. FROM
  113. cygx_industrial_management AS man
  114. INNER JOIN cygx_report_mapping AS re ON re.chart_permission_id = man.chart_permission_id
  115. INNER JOIN cygx_industrial_article_group_management AS man_g ON man_g.industrial_management_id = man.industrial_management_id
  116. INNER JOIN cygx_article AS art ON art.article_id = man_g.article_id
  117. WHERE 1= 1
  118. AND re.report_type = 2
  119. AND art.is_report = 1
  120. AND art.is_class = 1 ` + condition + `
  121. GROUP BY
  122. man.industry_name
  123. ORDER BY ` + orderSrt + ` LIMIT ?,?`
  124. _, err = o.Raw(sql, startSize, pageSize).QueryRows(&items)
  125. return
  126. }
  127. //标的列表
  128. func GetIndustrialSubjectAll(IndustrialManagementId int) (items []*IndustrialSubject, err error) {
  129. o := orm.NewOrm()
  130. sql := `SELECT * FROM cygx_industrial_subject WHERE industrial_management_id = ? `
  131. _, err = o.Raw(sql, IndustrialManagementId).QueryRows(&items)
  132. return
  133. }
  134. //获取该产业下最新的文章详情
  135. func GetIndustrialNewArticleDetail(industrialManagementId int) (item *ArticleDetail, err error) {
  136. o := orm.NewOrm()
  137. sql := `SELECT
  138. *
  139. FROM
  140. cygx_article
  141. WHERE
  142. article_id IN ( SELECT article_id FROM cygx_industrial_article_group_management WHERE industrial_management_id = ? )
  143. ORDER BY
  144. is_report DESC,
  145. publish_date DESC
  146. LIMIT 0,1`
  147. err = o.Raw(sql, industrialManagementId).QueryRow(&item)
  148. return
  149. }
  150. //获取该产业下最新的文章详情
  151. func GetNewArticleDetailByIndustrialIds(industrialIdArr []int) (items []*IndustrialManagementArticle, err error) {
  152. arrLen := len(industrialIdArr)
  153. if arrLen == 0 {
  154. return
  155. }
  156. o := orm.NewOrm()
  157. sql := `SELECT
  158. mg.industrial_management_id,
  159. MAX( a.article_id ) AS article_id,
  160. a.title,
  161. MAX( a.publish_date ) AS publish_date
  162. FROM
  163. cygx_industrial_article_group_management AS mg
  164. INNER JOIN cygx_article AS a ON mg.article_id = a.article_id
  165. WHERE
  166. 1 = 1
  167. AND a.article_id < ?
  168. AND a.is_report = 1
  169. AND a.is_class = 1
  170. AND mg.industrial_management_id IN(` + utils.GetOrmInReplace(len(industrialIdArr)) + `)
  171. GROUP BY
  172. mg.industrial_management_id `
  173. _, err = o.Raw(sql, utils.SummaryArticleId, industrialIdArr).QueryRows(&items)
  174. return
  175. }
  176. //获取产业数量
  177. func GetIndustrialManagementCount(IndustrialManagementId int) (count int, err error) {
  178. sqlCount := ` SELECT COUNT(1) AS count FROM cygx_industrial_management WHERE industrial_management_id=? `
  179. o := orm.NewOrm()
  180. err = o.Raw(sqlCount, IndustrialManagementId).QueryRow(&count)
  181. return
  182. }
  183. //获取关注数量
  184. func GetCountCygxIndustryFllow(industrialManagementId int, mobile, condition string) (count int, err error) {
  185. sql := `SELECT COUNT(1) AS count FROM cygx_industry_fllow WHERE mobile=? AND industrial_management_id=? ` + condition
  186. err = orm.NewOrm().Raw(sql, mobile, industrialManagementId).QueryRow(&count)
  187. return
  188. }
  189. func GetIndustrialManagementDetail(industrialManagementId int) (items *IndustrialManagementRep, err error) {
  190. o := orm.NewOrm()
  191. sql := `SELECT * FROM cygx_industrial_management WHERE industrial_management_id = ?`
  192. err = o.Raw(sql, industrialManagementId).QueryRow(&items)
  193. return
  194. }
  195. //获取所有的产业
  196. func GetindustrialManagement() (items []*IndustrialManagementRep, err error) {
  197. o := orm.NewOrm()
  198. sql := `SELECT
  199. i.*
  200. FROM
  201. cygx_industrial_management AS i
  202. INNER JOIN cygx_industrial_article_group_management AS m ON m.industrial_management_id = i.industrial_management_id
  203. GROUP BY
  204. i.industrial_management_id `
  205. _, err = o.Raw(sql).QueryRows(&items)
  206. return
  207. }
  208. //标的列表
  209. func GetIndustrialSubjectAllByIndustrialId(industrialIdArr []int) (items []*IndustrialSubject, err error) {
  210. o := orm.NewOrm()
  211. sql := `SELECT * FROM cygx_industrial_subject WHERE industrial_management_id IN (` + utils.GetOrmInReplace(len(industrialIdArr)) + `) `
  212. _, err = o.Raw(sql, industrialIdArr).QueryRows(&items)
  213. return
  214. }
  215. //获取标的列表
  216. func GetIndustrialListByarticleId(pars []interface{}, condition string) (items []*IndustrialManagementIdInt, err error) {
  217. o := orm.NewOrm()
  218. sql := `SELECT
  219. mg.article_id,
  220. m.industry_name,
  221. m.chart_permission_id,
  222. mg.industrial_management_id
  223. FROM
  224. cygx_industrial_management AS m
  225. INNER JOIN cygx_industrial_article_group_management AS mg ON mg.industrial_management_id = m.industrial_management_id
  226. WHERE
  227. 1 = 1 ` + condition + ` GROUP BY mg.article_id, mg.industrial_management_id `
  228. _, err = o.Raw(sql, pars).QueryRows(&items)
  229. return
  230. }
  231. // GetIndustryArtCountByCondition 获取产业文章关联的文章数
  232. func GetIndustryArtCountByCondition(condition string, pars []interface{}) (list []*IndustryArtCount, err error) {
  233. sql := `SELECT
  234. COUNT(1) AS art_num,
  235. agm.industrial_management_id
  236. FROM
  237. cygx_industrial_article_group_management AS agm
  238. JOIN cygx_industrial_management AS man ON man.industrial_management_id = agm.industrial_management_id
  239. WHERE
  240. 1 = 1 `
  241. if condition != "" {
  242. sql += condition
  243. }
  244. sql += ` GROUP BY agm.industrial_management_id`
  245. _, err = orm.NewOrm().Raw(sql, pars).QueryRows(&list)
  246. return
  247. }
  248. type IndustrialArticleGroupManagementResp struct {
  249. IndustrialManagementId int `description:"产业Id"`
  250. ArticleId int `description:"文章ID"`
  251. }
  252. // GetIndustrialArticleGroupManagementByIndustrialManagementId 获取产业文章关联的文章ID
  253. func GetIndustrialArticleGroupManagementByIndustrialManagementId(industrialManagementId int) (list []*IndustrialArticleGroupManagementResp, err error) {
  254. sql := `SELECT
  255. *
  256. FROM
  257. cygx_industrial_article_group_management
  258. WHERE
  259. industrial_management_id = ? `
  260. _, err = orm.NewOrm().Raw(sql, industrialManagementId).QueryRows(&list)
  261. return
  262. }
  263. // GetTopOneMonthArtReadNumIndustry 获取近一个月报告阅读数量最多的产业信息
  264. func GetTopOneMonthArtReadNumIndustry(condition string, pars []interface{}) (item *IndustrialManagement, err error) {
  265. sql := `SELECT * FROM cygx_industrial_management WHERE 1 = 1 `
  266. if condition != `` {
  267. sql += condition
  268. }
  269. sql += ` ORDER BY article_read_num DESC LIMIT 1`
  270. err = orm.NewOrm().Raw(sql, pars).QueryRow(&item)
  271. return
  272. }