article.go 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706
  1. package models
  2. import (
  3. "github.com/beego/beego/v2/client/orm"
  4. "time"
  5. )
  6. type CygxArticle struct {
  7. Id int `orm:"column(id);pk"`
  8. ArticleId int `description:"文章id"`
  9. Title string `description:"标题"`
  10. TitleEn string `description:"英文标题 "`
  11. UpdateFrequency string `description:"更新周期"`
  12. CreateDate string `description:"创建时间"`
  13. PublishDate string `description:"发布时间"`
  14. Body string `description:"内容"`
  15. BodyText string `description:"内容"`
  16. Abstract string `description:"摘要"`
  17. CategoryName string `description:"一级分类"`
  18. SubCategoryName string `description:"二级分类"`
  19. PublishStatus int `description:"发布状态"`
  20. CategoryId int `description:"分类id"`
  21. CategoryIdTwo int `description:"分类id用作修改匹配类型使用"`
  22. ExpertBackground string `description:"专家背景"`
  23. ExpertNumber string `description:"专家编号"`
  24. InterviewDate string `description:"访谈日期"`
  25. Department string `description:"作者"`
  26. ArticleIdMd5 string `description:"ID,md5值"`
  27. IsClass int `description:"是否归类,1是,0否"`
  28. IsSummary int `description:"是否是纪要库,1是,0否"`
  29. IsReport int `description:"是否属于报告,1是,0否"`
  30. ReportType int `description:"报告类型,1行业报告,2产业报告,0无"`
  31. FileLink string `description:"下载预览链接"`
  32. MatchTypeName string `description:"匹配类型"`
  33. Periods string `description:"期数"`
  34. ReportLink string `description:"报告链接"`
  35. ArticleType string `description:"文章类型 文章类型,lyjh:路演精华 "`
  36. HavePublish int `description:"是否发布过,1是 ,0 否"`
  37. Source int `description:"来源 0策略平台同步,1小程序后台添加"`
  38. SellerAndMobile string `description:"销售和手机号"`
  39. VideoUrl string `description:"音频文件URL"`
  40. VideoName string `description:"音频文件名称"`
  41. VideoPlaySeconds string `description:"音频播放时长"`
  42. Stock string `description:"个股标签"`
  43. FieldName string `description:"产业标签"`
  44. Annotation string `description:"核心观点"`
  45. TypeName string `description:"策略平台报告类型"`
  46. ModifyTimeByCl string `description:"策略平台报告更新时间"`
  47. }
  48. type CygxArticleEs struct {
  49. Id int `orm:"column(id);pk"`
  50. ArticleId int `description:"文章id"`
  51. Title string `description:"标题"`
  52. TitleEn string `description:"英文标题 "`
  53. UpdateFrequency string `description:"更新周期"`
  54. CreateDate string `description:"创建时间"`
  55. PublishDate string `description:"发布时间"`
  56. Body string `description:"内容"`
  57. BodyText string `description:"内容"`
  58. Abstract string `description:"摘要"`
  59. CategoryName string `description:"一级分类"`
  60. SubCategoryName string `description:"二级分类"`
  61. PublishStatus int `description:"发布状态"`
  62. CategoryId string `description:"分类id"`
  63. ExpertBackground string `description:"专家背景"`
  64. ExpertNumber string `description:"专家编号"`
  65. InterviewDate string `description:"访谈日期"`
  66. Department string `description:"作者"`
  67. ArticleIdMd5 string `description:"ID,md5值"`
  68. IsClass int `description:"是否归类,1是,0否"`
  69. IsSummary bool `description:"是否是纪要库,1是,0否"`
  70. IsReport bool `description:"是否属于报告,1是,0否"`
  71. ReportType int `description:"报告类型,1行业报告,2产业报告,0无"`
  72. FileLink string `description:"下载预览链接"`
  73. MatchTypeName string `description:"匹配类型"`
  74. }
  75. //新增文章
  76. func AddCygxArticle(item *CygxArticle) (lastId int64, err error) {
  77. o := orm.NewOrm()
  78. lastId, err = o.Insert(item)
  79. return
  80. }
  81. type HomeArticle struct {
  82. ArticleId int `description:"文章id"`
  83. Title string `description:"标题"`
  84. TitleEn string `description:"英文标题 "`
  85. UpdateFrequency string `description:"更新周期"`
  86. CreateDate string `description:"创建时间"`
  87. PublishDate string `description:"发布时间"`
  88. Body string `description:"内容"`
  89. BodyHtml string `description:"内容带有HTML标签"`
  90. Abstract string `description:"摘要"`
  91. CategoryName string `description:"一级分类"`
  92. SubCategoryName string `description:"二级分类"`
  93. ExpertBackground string `description:"专家背景"`
  94. IsResearch bool `description:"是否属于研选"`
  95. Pv int `description:"PV"`
  96. ImgUrlPc string `description:"图片链接"`
  97. CategoryId string `description:"文章分类"`
  98. HttpUrl string `description:"文章链接跳转地址"`
  99. IsNeedJump bool `description:"是否需要跳转链接地址"`
  100. Source int `description:"来源 1:文章, 2:图表"`
  101. Annotation string `description:"核心观点"`
  102. HomeType int `description:"数据类型:0-纪要(默认); 1-微路演音频"`
  103. MicroAudio *MicroAudioUnionList `description:"微路演音频"`
  104. ChartPermissionName string `description:"权限名称"`
  105. ArticleTypeName string `description:"权限名称"`
  106. IsReport int `description:"是否属于报告,1是,0否"`
  107. ArticleResponse int `description:"报告类型 0:啥也不是,1研选报告,2:研选纪要,3:研选沙龙,4;研选观点"`
  108. Readnum int `description:"阅读数量"`
  109. List []*IndustrialManagementIdInt
  110. }
  111. type ArticleDetail struct {
  112. ArticleId int `description:"报告id"`
  113. Title string `description:"标题"`
  114. TitleEn string `description:"英文标题 "`
  115. UpdateFrequency string `description:"更新周期"`
  116. CreateDate string `description:"创建时间"`
  117. PublishDate string `description:"发布时间"`
  118. Body string `description:"内容"`
  119. Abstract string `description:"摘要"`
  120. CategoryName string `description:"一级分类"`
  121. SubCategoryName string `description:"二级分类"`
  122. IsCollect bool `description:"是否收藏:true,已收藏,false:未收藏"`
  123. IsInterviewApply bool `description:"是否申请访谈:true,已申请,false:未申请"`
  124. BodyText string `description:"内容"`
  125. InterviewApplyStatus string `description:"当前访谈申请状态:'待邀请','待访谈','已完成','已取消'"`
  126. InterviewDate string `description:"访谈时间"`
  127. ExpertBackground string `description:"专家背景"`
  128. ExpertNumber string `description:"专家编号"`
  129. Department string `description:"作者"`
  130. SellerMobile string `description:"销售手机号"`
  131. SellerName string `description:"销售名称"`
  132. ArticleIdMd5 string `description:"纪要id"`
  133. IsClass int `description:"是否归类,1是,0否"`
  134. CategoryId int `description:"分类ID"`
  135. IsSummary int `description:"是否是纪要库,1是,0否"`
  136. IsReport int `description:"是否属于报告,1是,0否"`
  137. IsResearch bool `description:"是否属于研选"`
  138. FileLink string `description:"下载预览链接"`
  139. SellerAndMobile string `description:"销售和手机号"`
  140. IsFollow bool `description:"是否关注,1是,0否"`
  141. IsBelongSummary bool `description:"是否属于纪要库"`
  142. IsBelongReport bool `description:"是否属于报告"`
  143. FollowNum int `description:"关注数量"`
  144. CollectionNum int `description:"收藏数量"`
  145. DepartmentId int `description:"作者ID"`
  146. DepartmentImgUrl string `description:"作者头像"`
  147. NickName string `description:"作者昵称"`
  148. SubjectIds string `description:"文章关联标的的ID字符串"`
  149. IndustrialAndSubjectIds string `description:"文章关联产业和标的的ID字符串"`
  150. IndustrialManagementId int `description:"文章关联产业ID"`
  151. SellerList []*SellerRep
  152. HttpUrl string `description:"文章链接跳转地址"`
  153. IsNeedJump bool `description:"是否需要跳转链接地址"`
  154. ReportLink string `description:"报告链接"`
  155. IsShowLinkButton int `description:"这种报告类型是否展示查看报告链接"`
  156. ArticleTypeId int `description:"文章类型ID"`
  157. IsSpecialArticle bool `description:"是否属于专项调研报告"`
  158. Annotation string `description:"核心观点"`
  159. }
  160. type ArticleDetailFileLink struct {
  161. FileLink string `description:"下载预览链接"`
  162. Scene string `description:"资源参数"`
  163. }
  164. type SellerRep struct {
  165. SellerMobile string `description:"销售手机号"`
  166. SellerName string `description:"销售名称"`
  167. }
  168. func GetArticleDetailById(articleId int) (item *ArticleDetail, err error) {
  169. o := orm.NewOrm()
  170. sql := `SELECT * FROM cygx_article WHERE article_id = ? AND publish_status = 1 `
  171. err = o.Raw(sql, articleId).QueryRow(&item)
  172. return
  173. }
  174. func GetSellerList(articleId int) (items []*SellerRep, err error) {
  175. o := orm.NewOrm()
  176. sql := `SELECT
  177. au.mobile as seller_mobile,
  178. au.name as seller_name
  179. FROM
  180. cygx_article_author AS au
  181. WHERE article_id = ?`
  182. _, err = o.Raw(sql, articleId).QueryRows(&items)
  183. return
  184. }
  185. func GetArticleDetailByIdMd5(articleIdMd5 string) (item *ArticleDetail, err error) {
  186. o := orm.NewOrm()
  187. sql := `SELECT * FROM cygx_article WHERE article_id_md5 = ? `
  188. err = o.Raw(sql, articleIdMd5).QueryRow(&item)
  189. return
  190. }
  191. func GetArticleDetailByIdStr(articleIdStr string) (items []*ArticleDetail, err error) {
  192. o := orm.NewOrm()
  193. sql := `SELECT art.*,d.nick_name FROM
  194. cygx_article AS art
  195. LEFT JOIN cygx_article_department AS d ON d.department_id = art.department_id WHERE article_id IN(` + articleIdStr + `) `
  196. _, err = o.Raw(sql).QueryRows(&items)
  197. return
  198. }
  199. func GetArticlePermission(companyId int) (item *ChartPermission, err error) {
  200. o := orm.NewOrm()
  201. sql := `SELECT
  202. b.*
  203. FROM
  204. cygx_report_mapping AS a
  205. INNER JOIN chart_permission AS b ON a.chart_permission_id = b.chart_permission_id
  206. WHERE
  207. a.category_id = ?`
  208. err = o.Raw(sql, companyId).QueryRow(&item)
  209. //_, err = o.Raw(sql, companyId).QueryRows(&item)
  210. return
  211. }
  212. type ArticleDetailResp struct {
  213. Detail *ArticleDetail
  214. HasPermission int `description:"1:有该行业权限,正常展示,2:无该行业权限,不存在权益客户下,3:无该品类权限,已提交过申请,4:无该行业权限,未提交过申请,5:潜在客户,未提交过申请,6:潜在客户,已提交过申请"`
  215. HasFree int `description:"1:已付费(至少包含一个品类的权限),2:未付费(没有任何品类权限)"`
  216. HaveResearch bool `description:"是否有研选权限"`
  217. Mobile string `description:"用户手机号"`
  218. PopupMsg string `description:"权限弹窗信息"`
  219. SellerMobile string `description:"销售电话"`
  220. SellerName string `description:"销售姓名"`
  221. IsSpecialArticle bool `description:"是否属于专项调研报告"`
  222. }
  223. type ArticleDetailHtgjResp struct {
  224. HasPermission int `description:"1:有该行业权限,正常展示,0:试用期已过期"`
  225. CompanyName string `description:"公司名称"`
  226. Detail *ArticleDetail
  227. }
  228. func ModifyArticleExpert(articleId int, expertNumStr, expertContentStr, interviewDateStr, bodyText string) (err error) {
  229. o := orm.NewOrm()
  230. sql := `UPDATE cygx_article SET expert_background=?,expert_number=?,interview_date=?,body_text=? WHERE article_id=? `
  231. _, err = o.Raw(sql, expertContentStr, expertNumStr, interviewDateStr, bodyText, articleId).Exec()
  232. return
  233. }
  234. //更改文章发布状态
  235. func UpdateArticlePublish(articleId, publishStatus int) (err error) {
  236. o := orm.NewOrm()
  237. sql := `UPDATE cygx_article SET publish_status=? WHERE article_id=? `
  238. _, err = o.Raw(sql, publishStatus, articleId).Exec()
  239. return
  240. }
  241. type ArticleDetailTest struct {
  242. ArticleId int `description:"报告id"`
  243. Title string `description:"标题"`
  244. BodyText string `description:"内容"`
  245. Body string `json:"-" description:"内容"`
  246. }
  247. func GetArticleDetailTestById(articleId int) (item *ArticleDetail, err error) {
  248. o := orm.NewOrm()
  249. sql := `SELECT * FROM cygx_article WHERE article_id = ? `
  250. err = o.Raw(sql, articleId).QueryRow(&item)
  251. return
  252. }
  253. func GetArticleAll() (item []*ArticleDetail, err error) {
  254. o := orm.NewOrm()
  255. sql := `SELECT * FROM cygx_article WHERE article_id IN (7667,
  256. 5282,
  257. 5215,
  258. 4615,
  259. 4902) `
  260. _, err = o.Raw(sql).QueryRows(&item)
  261. return
  262. }
  263. func GetArticleAllDate(endDate string) (item []*ArticleDetail, err error) {
  264. o := orm.NewOrm()
  265. sql := `SELECT * FROM cygx_article WHERE is_summary=1 AND publish_date >= ? `
  266. _, err = o.Raw(sql, endDate).QueryRows(&item)
  267. return
  268. }
  269. func GetArticleAll2() (item []*ArticleDetail, err error) {
  270. o := orm.NewOrm()
  271. sql := `SELECT * FROM cygx_article `
  272. _, err = o.Raw(sql).QueryRows(&item)
  273. return
  274. }
  275. //获取文章列表
  276. func GetArticleList(condition string, pars []interface{}) (items []*ArticleDetail, err error) {
  277. o := orm.NewOrm()
  278. sql := `SELECT article_id FROM cygx_article WHERE 1= 1 ` + condition
  279. _, err = o.Raw(sql, pars).QueryRows(&items)
  280. return
  281. }
  282. func ModifyArticleContent(articleId int, content, expertNumStr, expertContentStr, interviewDateStr string) (err error) {
  283. o := orm.NewOrm()
  284. sql := `UPDATE cygx_article SET body=?,expert_background=?,expert_number=?,interview_date=? WHERE article_id=? `
  285. _, err = o.Raw(sql, content, expertContentStr, expertNumStr, interviewDateStr, articleId).Exec()
  286. return
  287. }
  288. type ElasticArticleDetail struct {
  289. ArticleId int `description:"报告id"`
  290. Title string `description:"标题"`
  291. TitleEn string `description:"英文标题 "`
  292. UpdateFrequency string `description:"更新周期"`
  293. CreateDate string `description:"创建时间"`
  294. PublishDate string `description:"发布时间"`
  295. Abstract string `description:"摘要"`
  296. CategoryName string `description:"一级分类"`
  297. SubCategoryName string `description:"二级分类"`
  298. IsCollect bool `description:"是否收藏:true,已收藏,false:未收藏"`
  299. IsInterviewApply bool `description:"是否申请访谈:true,已申请,false:未申请"`
  300. BodyText string `description:"内容"`
  301. InterviewApplyStatus string `description:"当前访谈申请状态:'待邀请','待访谈','已完成','已取消'"`
  302. InterviewDate string `description:"访谈时间"`
  303. ExpertBackground string `description:"专家背景"`
  304. ExpertNumber string `description:"专家编号"`
  305. Department string `description:"作者"`
  306. SellerMobile string `description:"销售手机号"`
  307. SellerName string `description:"销售名称"`
  308. ArticleIdMd5 string `description:"纪要id"`
  309. }
  310. func GetArticleCountById(articleId int) (count int, err error) {
  311. o := orm.NewOrm()
  312. sql := `SELECT COUNT(1) AS count FROM cygx_article WHERE article_id = ? `
  313. err = o.Raw(sql, articleId).QueryRow(&count)
  314. return
  315. }
  316. type CygxArticles struct {
  317. Id int `orm:"column(id);pk"`
  318. ArticleId int `description:"文章id"`
  319. Title string `description:"标题"`
  320. TitleEn string `description:"英文标题 "`
  321. UpdateFrequency string `description:"更新周期"`
  322. CreateDate string `description:"创建时间"`
  323. PublishDate string `description:"发布时间"`
  324. Body string `description:"内容"`
  325. BodyText string `description:"内容"`
  326. Abstract string `description:"摘要"`
  327. CategoryName string `description:"一级分类"`
  328. SubCategoryName string `description:"二级分类"`
  329. PublishStatus int `description:"发布状态"`
  330. CategoryId int `description:"分类id"`
  331. ExpertBackground string `description:"专家背景"`
  332. ExpertNumber string `description:"专家编号"`
  333. InterviewDate string `description:"访谈日期"`
  334. Department string `description:"作者"`
  335. ArticleIdMd5 string `description:"ID,md5值"`
  336. IsClass int `description:"是否归类,1是,0否"`
  337. IsSummary int `description:"是否是纪要库,1是,0否"`
  338. IsReport int `description:"是否属于报告,1是,0否"`
  339. ReportType int `description:"报告类型,1行业报告,2产业报告,0无"`
  340. }
  341. //新增文章
  342. func AddCygxArticles(item *CygxArticle) (lastId int64, err error) {
  343. o := orm.NewOrm()
  344. lastId, err = o.Insert(item)
  345. return
  346. }
  347. func GetPermissionMappingById(categoryId int) (count int, err error) {
  348. o := orm.NewOrm()
  349. sql := `SELECT COUNT(1) AS count FROM cygx_permission_mapping WHERE category_id = ? `
  350. err = o.Raw(sql, categoryId).QueryRow(&count)
  351. return
  352. }
  353. func GetReportMappingById(categoryId int) (count int, err error) {
  354. o := orm.NewOrm()
  355. sql := `SELECT COUNT(1) AS count FROM cygx_report_mapping WHERE category_id = ? `
  356. err = o.Raw(sql, categoryId).QueryRow(&count)
  357. return
  358. }
  359. type ReportArticle struct {
  360. ArticleId int `description:"文章id"`
  361. Title string `description:"标题"`
  362. TitleEn string `description:"英文标题 "`
  363. UpdateFrequency string `description:"更新周期"`
  364. CreateDate string `description:"创建时间"`
  365. PublishDate string `description:"发布时间"`
  366. Body string `description:"内容"`
  367. Abstract string `description:"摘要"`
  368. CategoryName string `description:"一级分类"`
  369. SubCategoryName string `description:"二级分类"`
  370. ExpertBackground string `description:"专家背景"`
  371. IsRed bool `description:"是否标记红点"`
  372. Readnum int `description:"阅读数量"`
  373. VideoUrl string `description:"链接"`
  374. IsHaveVideo bool `description:"是否含有音频文件"`
  375. ImgUrlPc string `description:"图片链接"`
  376. CategoryId string `description:"文章分类"`
  377. Annotation string `description:"核心观点"`
  378. }
  379. func GetReportPermission(categoryName string) (item []*ChartPermission, err error) {
  380. o := orm.NewOrm()
  381. sql := ` SELECT b.* FROM cygx_report_mapping AS a
  382. INNER JOIN chart_permission AS b ON a.chart_permission_id=b.chart_permission_id
  383. WHERE a.sub_category_name=? `
  384. _, err = o.Raw(sql, categoryName).QueryRows(&item)
  385. return
  386. }
  387. type ReportMappingCategoryRep struct {
  388. CategoryId int `description:"文章分类id"`
  389. }
  390. func GetReportMappingCategoryID() (item []*ReportMappingCategoryRep, err error) {
  391. o := orm.NewOrm()
  392. sql := ` SELECT category_id FROM cygx_permission_mapping GROUP BY category_id `
  393. _, err = o.Raw(sql).QueryRows(&item)
  394. return
  395. }
  396. type PermissionMappingCategoryRep struct {
  397. CategoryId int `description:"文章分类id"`
  398. }
  399. func GetPermissionMappingCategoryID() (item []*PermissionMappingCategoryRep, err error) {
  400. o := orm.NewOrm()
  401. sql := ` SELECT category_id FROM cygx_report_mapping GROUP BY category_id `
  402. _, err = o.Raw(sql).QueryRows(&item)
  403. return
  404. }
  405. //检查用户是否阅读某一分类最新文章
  406. func GetUserIsReadThisNewCategoryArticleCount(categoryId, uid int) (count int, err error) {
  407. sqlCount := `SELECT COUNT(1) as count FROM
  408. cygx_article_history_record
  409. WHERE
  410. article_id = ( SELECT article_id FROM cygx_article WHERE category_id = ? ORDER BY publish_date DESC LIMIT 0, 1 )
  411. AND user_id = ?`
  412. o := orm.NewOrm()
  413. err = o.Raw(sqlCount, categoryId, uid).QueryRow(&count)
  414. return
  415. }
  416. type ArticleId struct {
  417. ArticleId int `description:"文章id"`
  418. }
  419. //获取自定义分类的文章ID
  420. func GetCustomArticleId() (item []*ArticleId, err error) {
  421. o := orm.NewOrm()
  422. sql := ` SELECT article_id FROM cygx_article WHERE is_custom = 1 `
  423. _, err = o.Raw(sql).QueryRows(&item)
  424. return
  425. }
  426. type ArticleFollowDetail struct {
  427. DNum int `description:"作者被关注的数量"`
  428. MdNum int `description:"本人是否关注这个作者"`
  429. AcNum int `description:"文章被收藏的数量"`
  430. MacNum int `description:"本人是否收藏这个文章"`
  431. }
  432. //获取文章被关注被收藏的详情
  433. func GetArticleFollowDetail(articleId, uid int) (item *ArticleFollowDetail, err error) {
  434. //d_num 作者被关注的数量 、 md_num 本人是否关注这个作者 、ac_num 文章被收藏的数量 、 mac_num 本人是否收藏这个文章
  435. o := orm.NewOrm()
  436. sql := ` SELECT
  437. ( SELECT count( 1 ) FROM cygx_article_department_follow AS af INNER JOIN wx_user as u ON u.user_id = af.user_id WHERE af.department_id = art.department_id AND af.type = 1 ) AS d_num,
  438. ( SELECT count( 1 ) FROM cygx_article_department_follow AS af WHERE af.department_id = art.department_id AND af.type = 1 AND af.user_id = ? ) AS md_num,
  439. ( SELECT count( 1 ) FROM cygx_article_collect AS ac INNER JOIN wx_user as u ON u.user_id = ac.user_id WHERE ac.article_id = art.article_id ) AS ac_num,
  440. ( SELECT count( 1 ) FROM cygx_article_collect AS ac WHERE ac.article_id = art.article_id AND ac.user_id = ? ) AS mac_num
  441. FROM
  442. cygx_article AS art
  443. LEFT JOIN cygx_article_department_follow AS af ON af.department_id = art.department_id
  444. LEFT JOIN cygx_article_collect AS ac ON ac.article_id = art.article_id
  445. WHERE
  446. art.article_id = ?
  447. GROUP BY art.article_id `
  448. err = o.Raw(sql, uid, uid, articleId).QueryRow(&item)
  449. return
  450. }
  451. //日度点评的数据同步
  452. type ReportDetail struct {
  453. Id int `orm:"column(id)" description:"报告Id"`
  454. AddType int `description:"新增方式:1:新增报告,2:继承报告"`
  455. ClassifyIdFirst int `description:"一级分类id"`
  456. ClassifyNameFirst string `description:"一级分类名称"`
  457. ClassifyIdSecond int `description:"二级分类id"`
  458. ClassifyNameSecond string `description:"二级分类名称"`
  459. Title string `description:"标题"`
  460. Abstract string `description:"摘要"`
  461. Author string `description:"作者"`
  462. Frequency string `description:"频度"`
  463. CreateTime string `description:"创建时间"`
  464. ModifyTime string `description:"修改时间"`
  465. State int `description:"1:未发布,2:已发布"`
  466. PublishTime string `description:"发布时间"`
  467. Stage int `description:"期数"`
  468. MsgIsSend int `description:"消息是否已发送,0:否,1:是"`
  469. Content string `description:"内容"`
  470. VideoUrl string `description:"音频文件URL"`
  471. VideoName string `description:"音频文件名称"`
  472. VideoPlaySeconds string `description:"音频播放时长"`
  473. ContentSub string `description:"内容前两个章节"`
  474. }
  475. func GetReportList() (items []*ReportDetail, err error) {
  476. o := orm.NewOrmUsingDB("rddp")
  477. sql := `SELECT * FROM report WHERE classify_id_second = '57'`
  478. _, err = o.Raw(sql).QueryRows(&items)
  479. return
  480. }
  481. func GetMaxArticleIdInfo() (item *ArticleDetail, err error) {
  482. o := orm.NewOrm()
  483. sql := `SELECT * FROM cygx_article ORDER BY article_id desc LIMIT 1`
  484. err = o.Raw(sql).QueryRow(&item)
  485. return
  486. }
  487. type ArticleResultApi struct {
  488. Data []ArticleResultApidate `json:"data"`
  489. Code int `json:"code"`
  490. Msg string `json:"msg"`
  491. }
  492. type ArticleDetailResultApi struct {
  493. Data ArticleResultApidate `json:"data"`
  494. Code int `json:"code"`
  495. Msg string `json:"msg"`
  496. }
  497. type ArticleResultApidate struct {
  498. ArticleId int `json:"id"`
  499. Title string `json:"title"`
  500. File string `json:"file"`
  501. TitleEn string `json:"title_en"`
  502. Frequency string `json:"frequency"`
  503. CreateDate string `json:"create_date"`
  504. UpdateDate string `json:"update_date"`
  505. PublishDate time.Time `json:"publish_date"`
  506. PublishStatus int `json:"publish_status"`
  507. IndustrId int `json:"industry_id"`
  508. SeriesId int `json:"series_id"`
  509. Series ArticleSeries `json:"series"`
  510. Content ArticleResultApiContent `json:"content"`
  511. Author ArticleResultApiAuthor `json:"author"`
  512. Industry ArticleResultApiIndustry `json:"industry"`
  513. Type ArticleResultApiType `json:"type"`
  514. Stock []string `json:"stock"`
  515. Field ArticleField `json:"field"`
  516. Corpus Corpus `json:"corpus"`
  517. Cover string `json:"cover"`
  518. TypeId int `json:"type_id"`
  519. }
  520. type ArticleField struct {
  521. Id int `json:"id"`
  522. Name string `json:"name"`
  523. Description string `json:"description"`
  524. IndustryId int `json:"industry_id"`
  525. }
  526. type Corpus struct {
  527. Id int `json:"id"`
  528. ArticleId int `json:"article_id"`
  529. Corpus string `json:"corpus"`
  530. }
  531. type ArticleSeries struct {
  532. Name string `json:"name"`
  533. }
  534. type ArticleResultApiContent struct {
  535. ArticleId int `json:"id"`
  536. Body string `json:"body"`
  537. Abstract string `json:"abstract"`
  538. Annotation string `json:"annotation"`
  539. }
  540. type ArticleResultApiAuthor struct {
  541. PhoneNumber string `json:"phone_number"`
  542. Name string `json:"name"`
  543. }
  544. type ArticleResultApiIndustry struct {
  545. Name string `json:"name"`
  546. }
  547. type ArticleResultApiType struct {
  548. Name string `json:"name"`
  549. }
  550. type ArticleIndustryApi struct {
  551. Data []ArticleResultApiIndustrdate `json:"data"`
  552. Code int `json:"code"`
  553. Msg string `json:"msg"`
  554. }
  555. type ArticleResultApiIndustrdate struct {
  556. Id int `json:"id"`
  557. Name string `json:"name"`
  558. Series []ArticleResultApiSeriesdate `json:"series"`
  559. }
  560. type ArticleResultApiSeriesdate struct {
  561. Id int `json:"id"`
  562. Name string `json:"name"`
  563. }
  564. type ArticleApiMap struct {
  565. Id int `description:"新ID"`
  566. OldId int `description:"旧Id"`
  567. IsClass int `description:"是否自动归类,1是,0否"`
  568. IsReport int `description:"是否属于报告,1是,0否"`
  569. IsSummary int `description:"是否属于纪要,1是,0否"`
  570. }
  571. func GetArticleApiMap() (item []*ArticleApiMap, err error) {
  572. o := orm.NewOrm()
  573. sql := ` SELECT * FROM cygx_article_api_map WHERE old_id > 0 AND is_update = 1 ORDER BY old_id ASC `
  574. _, err = o.Raw(sql).QueryRows(&item)
  575. return
  576. }
  577. func GetArticleIdSubjectGroup(keyWord string) (articleid string, err error) {
  578. o := orm.NewOrm()
  579. sql := ` SELECT
  580. GROUP_CONCAT(DISTINCT art.article_id SEPARATOR ',') AS articleid
  581. FROM
  582. cygx_article AS art
  583. INNER JOIN cygx_industrial_article_group_subject AS sg ON sg.article_id = art.article_id
  584. INNER JOIN cygx_industrial_subject AS s ON s.industrial_subject_id = sg.industrial_subject_id
  585. WHERE
  586. s.subject_name LIKE '%` + keyWord + `%' `
  587. err = o.Raw(sql).QueryRow(&articleid)
  588. return
  589. }
  590. func GetArticleIndustrialIdGroup(keyWord string) (articleid string, err error) {
  591. o := orm.NewOrm()
  592. sql := ` SELECT
  593. GROUP_CONCAT(DISTINCT art.article_id SEPARATOR ',') AS article_id
  594. FROM
  595. cygx_article AS art
  596. INNER JOIN cygx_industrial_article_group_management AS mg ON mg.article_id = art.article_id
  597. INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = mg.industrial_management_id
  598. WHERE
  599. m.industry_name LIKE '%` + keyWord + `%' `
  600. err = o.Raw(sql).QueryRow(&articleid)
  601. return
  602. }
  603. //通过文章ID获取文章所关联的标的ID
  604. func GetSubjectIds(articleId int) (subjects string, err error) {
  605. sql := ` SELECT
  606. GROUP_CONCAT( DISTINCT industrial_subject_id ORDER BY id ASC SEPARATOR ',' ) AS subjects
  607. FROM
  608. cygx_industrial_article_group_subject WHERE article_id = ?`
  609. o := orm.NewOrm()
  610. err = o.Raw(sql, articleId).QueryRow(&subjects)
  611. return
  612. }
  613. //修改发布状态
  614. func UpdateIsClassFail(articleId int) (err error) {
  615. sql := `UPDATE cygx_article SET is_class_fail=1 WHERE article_id=? `
  616. o := orm.NewOrm()
  617. _, err = o.Raw(sql, articleId).Exec()
  618. return
  619. }
  620. type SummaryArticleStock struct {
  621. Id int `description:"新ID"`
  622. ArticleId int `description:"文章id"`
  623. Stock string `description:"个股标签"`
  624. }
  625. //综述报告
  626. func GetSummaryArticle(chartPermissionId int) (items []*SummaryArticleStock, err error) {
  627. o := orm.NewOrm()
  628. sql := `SELECT
  629. *
  630. FROM
  631. cygx_article AS c
  632. INNER JOIN cygx_report_mapping AS m
  633. WHERE
  634. c.type_name = '综述报告'
  635. AND m.category_id = c.category_id_two
  636. AND m.chart_permission_id = ? ORDER BY modify_time_by_cl DESC `
  637. _, err = o.Raw(sql, chartPermissionId).QueryRows(&items)
  638. return
  639. }
  640. type SummaryArticleStockResp struct {
  641. List []*SummaryArticleStock
  642. }