article.go 27 KB

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