report.go 58 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236
  1. package models
  2. import (
  3. "errors"
  4. "eta_gn/eta_api/global"
  5. "eta_gn/eta_api/utils"
  6. "fmt"
  7. "github.com/beego/beego/v2/client/orm"
  8. "github.com/rdlucklib/rdluck_tools/paging"
  9. "gorm.io/gorm"
  10. "strings"
  11. "time"
  12. )
  13. // 报告状态
  14. const (
  15. ReportStateUnpublished = 1 // 未发布
  16. ReportStatePublished = 2 // 已发布
  17. ReportStateWaitSubmit = 3 // 待提交
  18. ReportStateWaitApprove = 4 // 审批中
  19. ReportStateRefused = 5 // 已驳回
  20. ReportStatePass = 6 // 已通过
  21. )
  22. // 报告操作
  23. const (
  24. ReportOperateAdd = 1 // 新增报告
  25. ReportOperateEdit = 2 // 编辑报告
  26. ReportOperatePublish = 3 // 发布报告
  27. ReportOperateCancelPublish = 4 // 取消发布报告
  28. ReportOperateSubmitApprove = 5 // 提交审批
  29. ReportOperateCancelApprove = 6 // 撤回审批
  30. )
  31. type Report struct {
  32. Id int `gorm:"column:id;primaryKey;autoIncrement" description:"报告Id"`
  33. AddType int `gorm:"column:add_type" description:"新增方式:1:新增报告,2:继承报告"`
  34. ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类id"`
  35. ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"`
  36. ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类id"`
  37. ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"`
  38. Title string `gorm:"column:title" description:"标题"`
  39. Abstract string `gorm:"column:abstract" description:"摘要"`
  40. Author string `gorm:"column:author" description:"作者"`
  41. Frequency string `gorm:"column:frequency" description:"频度"`
  42. CreateTime string `gorm:"column:create_time" description:"创建时间"`
  43. ModifyTime time.Time `gorm:"column:modify_time;autoUpdateTime" description:"修改时间"`
  44. State int `gorm:"column:state" description:"1:未发布;2:已发布;3-待提交;4-待审批;5-已驳回;6-已通过"`
  45. PublishTime time.Time `gorm:"column:publish_time" description:"发布时间"`
  46. Stage int `gorm:"column:stage" description:"期数"`
  47. MsgIsSend int `gorm:"column:msg_is_send" description:"消息是否已发送,0:否,1:是"`
  48. ThsMsgIsSend int `gorm:"column:ths_msg_is_send" description:"客户群消息是否已发送,0:否,1:是"`
  49. Content string `gorm:"column:content" description:"内容"`
  50. VideoUrl string `gorm:"column:video_url" description:"音频文件URL"`
  51. VideoName string `gorm:"column:video_name" description:"音频文件名称"`
  52. VideoPlaySeconds string `gorm:"column:video_play_seconds" description:"音频播放时长"`
  53. VideoSize string `gorm:"column:video_size" description:"音频文件大小,单位M"`
  54. ContentSub string `gorm:"column:content_sub" description:"内容前两个章节"`
  55. ReportCode string `gorm:"column:report_code" description:"报告唯一编码"`
  56. ReportVersion int `gorm:"column:report_version" description:"1:旧版,2:新版"`
  57. HasChapter int `gorm:"column:has_chapter" description:"是否有章节 0-否 1-是"`
  58. ChapterType string `gorm:"column:chapter_type" description:"章节类型 day-晨报 week-周报"`
  59. OldReportId int `gorm:"column:old_report_id" description:"research_report表ID, 大于0则表示该报告为老后台同步过来的"`
  60. MsgSendTime time.Time `gorm:"column:msg_send_time" description:"模版消息发送时间"`
  61. AdminId int `gorm:"column:admin_id" description:"创建者账号"`
  62. AdminRealName string `gorm:"column:admin_real_name" description:"创建者姓名"`
  63. ApproveTime time.Time `gorm:"column:approve_time" description:"审批时间"`
  64. ApproveId int `gorm:"column:approve_id" description:"审批ID"`
  65. DetailImgUrl string `gorm:"column:detail_img_url" description:"报告详情长图地址"`
  66. DetailPdfUrl string `gorm:"column:detail_pdf_url" description:"报告详情PDF地址"`
  67. ContentStruct string `gorm:"column:content_struct" description:"内容组件"`
  68. LastModifyAdminId int `gorm:"column:last_modify_admin_id" description:"最后更新人ID"`
  69. LastModifyAdminName string `gorm:"column:last_modify_admin_name" description:"最后更新人姓名"`
  70. ContentModifyTime time.Time `gorm:"column:content_modify_time" description:"内容更新时间"`
  71. Pv int `gorm:"column:pv" description:"pv"`
  72. Uv int `gorm:"column:uv" description:"uv"`
  73. HeadImg string `gorm:"column:head_img" description:"报告头图地址"`
  74. EndImg string `gorm:"column:end_img" description:"报告尾图地址"`
  75. CanvasColor string `gorm:"column:canvas_color" description:"画布颜色"`
  76. NeedSplice int `gorm:"column:need_splice" description:"是否拼接版头版位的标记,主要是为了兼容历史报告。0-不需要 1-需要"`
  77. HeadResourceId int `gorm:"column:head_resource_id" description:"版头资源ID"`
  78. EndResourceId int `gorm:"column:end_resource_id" description:"版尾资源ID"`
  79. ClassifyIdThird int `gorm:"column:classify_id_third" description:"三级分类id"`
  80. ClassifyNameThird string `gorm:"column:classify_name_third" description:"三级分类名称"`
  81. CollaborateType int8 `gorm:"column:collaborate_type" description:"协作方式,1:个人,2:多人协作。默认:1"`
  82. ReportLayout int8 `gorm:"column:report_layout" description:"报告布局,1:常规布局,2:智能布局。默认:1"`
  83. IsPublicPublish int8 `gorm:"column:is_public_publish" description:"是否公开发布,1:是,2:否"`
  84. ReportCreateTime time.Time `gorm:"column:report_create_time" description:"报告时间创建时间"`
  85. InheritReportId int `gorm:"column:inherit_report_id" description:"待继承的报告ID"`
  86. VoiceGenerateType int `gorm:"column:voice_generate_type" description:"音频生成方式,0:系统生成,1:人工上传"`
  87. }
  88. type ReportList struct {
  89. Id int `gorm:"column:id" description:"报告Id"`
  90. AddType int `gorm:"column:add_type" description:"新增方式:1:新增报告,2:继承报告"`
  91. ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类id"`
  92. ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"`
  93. ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类id"`
  94. ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"`
  95. Title string `gorm:"column:title" description:"标题"`
  96. Abstract string `gorm:"column:abstract" description:"摘要"`
  97. Author string `gorm:"column:author" description:"作者"`
  98. Frequency string `gorm:"column:frequency" description:"频度"`
  99. CreateTime string `gorm:"column:create_time" description:"创建时间"`
  100. ModifyTime time.Time `gorm:"column:modify_time;autoUpdateTime" description:"修改时间"`
  101. State int `gorm:"column:state" description:"1:未发布;2:已发布;3-待提交;4-待审批;5-已驳回;6-已通过"`
  102. PublishTime string `gorm:"column:publish_time" description:"发布时间"`
  103. PrePublishTime string `gorm:"column:pre_publish_time" description:"预发布时间"`
  104. Stage int `gorm:"column:stage" description:"期数"`
  105. MsgIsSend int `gorm:"column:msg_is_send" description:"模板消息是否已发送,0:否,1:是"`
  106. Content string `gorm:"column:content" description:"内容"`
  107. VideoUrl string `gorm:"column:video_url" description:"音频文件URL"`
  108. VideoName string `gorm:"column:video_name" description:"音频文件名称"`
  109. VideoPlaySeconds string `gorm:"column:video_play_seconds" description:"音频播放时长"`
  110. ContentSub string `gorm:"column:content_sub" description:"内容前两个章节"`
  111. Pv int `gorm:"column:pv" description:"Pv"`
  112. Uv int `gorm:"column:uv" description:"Uv"`
  113. ReportCode string `gorm:"column:report_code" description:"报告唯一编码"`
  114. ReportVersion int `gorm:"column:report_version" description:"1:旧版,2:新版"`
  115. ThsMsgIsSend int `gorm:"column:ths_msg_is_send" description:"客户群消息是否已发送,0:否,1:是"`
  116. NeedThsMsg int `gorm:"column:need_ths_msg" description:"是否需要推送客群消息 0-否 1-是"`
  117. HasChapter int `gorm:"column:has_chapter" description:"是否有章节 0-否 1-是"`
  118. ChapterType string `gorm:"column:chapter_type" description:"章节类型 day-晨报 week-周报"`
  119. ChapterVideoList []*ReportChapterVideoList `gorm:"-" description:"章节音频列表"` // 不映射到数据库
  120. OldReportId int `gorm:"column:old_report_id" description:"research_report表ID, 大于0则表示该报告为老后台同步过来的"`
  121. MsgSendTime string `gorm:"column:msg_send_time" description:"模版消息发送时间"`
  122. CanEdit bool `gorm:"column:can_edit" description:"是否可编辑"`
  123. HasAuth bool `gorm:"column:has_auth" description:"是否可操作"`
  124. Editor string `gorm:"column:editor" description:"编辑人"`
  125. AdminId int `gorm:"column:admin_id" description:"创建者账号"`
  126. AdminRealName string `gorm:"column:admin_real_name" description:"创建者姓名"`
  127. ApproveTime string `gorm:"column:approve_time" description:"审批时间"`
  128. DetailImgUrl string `gorm:"column:detail_img_url" description:"报告详情长图地址"`
  129. DetailPdfUrl string `gorm:"column:detail_pdf_url" description:"报告详情PDF地址"`
  130. CollaborateType int8 `gorm:"column:collaborate_type" description:"协作方式,1:个人,2:多人协作。默认:1"`
  131. ReportLayout int8 `gorm:"column:report_layout" description:"报告布局,1:常规布局,2:智能布局。默认:1"`
  132. IsPublicPublish int8 `gorm:"column:is_public_publish" description:"是否公开发布,1:是,2:否"`
  133. ReportCreateTime time.Time `gorm:"column:report_create_time" description:"报告时间创建时间"`
  134. ContentStruct string `gorm:"column:content_struct" description:"内容组件"`
  135. LastModifyAdminId int `gorm:"column:last_modify_admin_id" description:"最后更新人ID"`
  136. LastModifyAdminName string `gorm:"column:last_modify_admin_name" description:"最后更新人姓名"`
  137. ContentModifyTime time.Time `gorm:"column:content_modify_time" description:"内容更新时间"`
  138. HeadImg string `gorm:"column:head_img" description:"报告头图地址"`
  139. EndImg string `gorm:"column:end_img" description:"报告尾图地址"`
  140. CanvasColor string `gorm:"column:canvas_color" description:"画布颜色"`
  141. NeedSplice int `gorm:"column:need_splice" description:"是否拼接版头版位的标记,主要是为了兼容历史报告。0-不需要 1-需要"`
  142. HeadResourceId int `gorm:"column:head_resource_id" description:"版头资源ID"`
  143. EndResourceId int `gorm:"column:end_resource_id" description:"版尾资源ID"`
  144. ClassifyIdThird int `gorm:"column:classify_id_third" description:"三级分类id"`
  145. ClassifyNameThird string `gorm:"column:classify_name_third" description:"三级分类名称"`
  146. InheritReportId int `gorm:"column:inherit_report_id" description:"待继承的报告ID"`
  147. }
  148. type ReportListResp struct {
  149. List []*ReportList
  150. Paging *paging.PagingItem `description:"分页数据"`
  151. }
  152. // GetReportListCountV1
  153. // @Description: 获取普通报告列表的报告数量
  154. // @author: Roc
  155. // @datetime 2024-05-30 15:14:43
  156. // @param condition string
  157. // @param pars []interface{}
  158. // @return count int
  159. // @return err error
  160. func GetReportListCountV1(condition string, pars []interface{}) (count int, err error) {
  161. //o := orm.NewOrmUsingDB("rddp")
  162. sql := `SELECT COUNT(1) AS count FROM report as a WHERE 1=1 `
  163. if condition != "" {
  164. sql += condition
  165. }
  166. //err = o.Raw(sql, pars).QueryRow(&count)
  167. err = global.DmSQL["rddp"].Raw(sql, pars...).Scan(&count).Error
  168. return
  169. }
  170. // GetReportListV1
  171. // @Description: 获取普通报告列表的数据
  172. // @author: Roc
  173. // @datetime 2024-05-30 15:14:25
  174. // @param condition string
  175. // @param pars []interface{}
  176. // @param startSize int
  177. // @param pageSize int
  178. // @return items []*ReportList
  179. // @return err error
  180. func GetReportListV1(condition string, pars []interface{}, startSize, pageSize int) (items []*ReportList, err error) {
  181. //o := orm.NewOrmUsingDB("rddp")
  182. sql := `SELECT * FROM report as a WHERE 1=1 `
  183. if condition != "" {
  184. sql += condition
  185. }
  186. // 排序:1:未发布;2:已发布;3-待提交;4-待审批;5-已驳回;6-已通过
  187. sql += `ORDER BY FIELD(state,3,1,4,5,6,2), modify_time DESC LIMIT ?,?`
  188. //_, err = o.Raw(sql, pars...).QueryRows(&items)
  189. pars = append(pars, startSize)
  190. pars = append(pars, pageSize)
  191. err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error
  192. return
  193. }
  194. type ReportPvUv struct {
  195. ReportId int
  196. PvTotal int
  197. UvTotal int
  198. }
  199. func GetReportPvUvByReportIdList(reportIdList []int) (items []ReportPvUv, err error) {
  200. num := len(reportIdList)
  201. if num <= 0 {
  202. return
  203. }
  204. //o := orm.NewOrmUsingDB("rddp")
  205. sql := `SELECT report_id, COUNT(1) as pv_total,COUNT(DISTINCT user_id) as uv_total FROM report_view_record WHERE report_id in (` + utils.GetOrmInReplace(num) + `) GROUP BY report_id`
  206. //_, err = o.Raw(sql, reportIdList).QueryRows(&items)
  207. err = global.DmSQL["rddp"].Raw(sql, reportIdList).Find(&items).Error
  208. return
  209. }
  210. // GetReportListCountByGrant
  211. // @Description: 获取共享报告列表的报告数量
  212. // @author: Roc
  213. // @datetime 2024-05-30 15:14:01
  214. // @param condition string
  215. // @param pars []interface{}
  216. // @return count int
  217. // @return err error
  218. func GetReportListCountByGrant(condition string, pars []interface{}) (count int, err error) {
  219. //o := orm.NewOrmUsingDB("rddp")
  220. sql := `SELECT a.id FROM report as a
  221. JOIN report_grant b on a.id=b.report_id
  222. WHERE 1=1 `
  223. if condition != "" {
  224. sql += condition
  225. }
  226. sql += " GROUP BY a.id "
  227. sql = `SELECT COUNT(1) AS count FROM (` + sql + `) d`
  228. //err = o.Raw(sql, pars).QueryRow(&count)
  229. err = global.DmSQL["rddp"].Raw(sql, pars...).Scan(&count).Error
  230. return
  231. }
  232. // GetReportListByGrant
  233. // @Description: 获取共享报告列表的数据
  234. // @author: Roc
  235. // @datetime 2024-05-30 15:15:07
  236. // @param condition string
  237. // @param pars []interface{}
  238. // @param startSize int
  239. // @param pageSize int
  240. // @return items []*ReportList
  241. // @return err error
  242. func GetReportListByGrant(condition string, pars []interface{}, startSize, pageSize int) (items []*ReportList, err error) {
  243. //o := orm.NewOrmUsingDB("rddp")
  244. sql := `SELECT a.add_type,a.classify_id_first,a.classify_name_first,a.classify_id_second,a.classify_name_second,a.title,a.abstract,a.author,a.frequency,a.create_time,a.modify_time,a.state,a.publish_time,a.pre_publish_time,a.stage,a.msg_is_send,a.pre_msg_send,a.content,a.video_url,a.video_name,a.video_play_seconds,a.content_sub,a.report_code,a.video_size,a.report_version,a.ths_msg_is_send,a.has_chapter,a.chapter_type,a.old_report_id,a.msg_send_time,a.admin_id,a.admin_real_name,a.approve_time,a.approve_id,a.detail_img_url,a.detail_pdf_url,a.content_struct,a.last_modify_admin_id,a.last_modify_admin_name,a.content_modify_time,a.pv,a.uv,a.head_img,a.end_img,a.canvas_color,a.need_splice,a.head_resource_id,a.end_resource_id,a.classify_id_third,a.classify_name_third,a.collaborate_type,a.report_layout,a.is_public_publish,a.report_create_time,a.inherit_report_id,a.voice_generate_type FROM report as a JOIN report_grant b on a.id = b.report_id WHERE 1=1 `
  245. if condition != "" {
  246. sql += condition
  247. }
  248. // 排序:1:未发布;2:已发布;3-待提交;4-待审批;5-已驳回;6-已通过
  249. sql += ` GROUP BY a.id,a.add_type,a.classify_id_first,a.classify_name_first,a.classify_id_second,a.classify_name_second,a.title,a.abstract,a.author,a.frequency,a.create_time,a.modify_time,a.state,a.publish_time,a.pre_publish_time,a.stage,a.msg_is_send,a.pre_msg_send,a.content,a.video_url,a.video_name,a.video_play_seconds,a.content_sub,a.report_code,a.video_size,a.report_version,a.ths_msg_is_send,a.has_chapter,a.chapter_type,a.old_report_id,a.msg_send_time,a.admin_id,a.admin_real_name,a.approve_time,a.approve_id,a.detail_img_url,a.detail_pdf_url,a.content_struct,a.last_modify_admin_id,a.last_modify_admin_name,a.content_modify_time,a.pv,a.uv,a.head_img,a.end_img,a.canvas_color,a.need_splice,a.head_resource_id,a.end_resource_id,a.classify_id_third,a.classify_name_third,a.collaborate_type,a.report_layout,a.is_public_publish,a.report_create_time,a.inherit_report_id,a.voice_generate_type
  250. ORDER BY CASE a."state"
  251. WHEN 3 THEN 1
  252. WHEN 1 THEN 2
  253. WHEN 4 THEN 3
  254. WHEN 5 THEN 4
  255. WHEN 6 THEN 5
  256. ELSE 6
  257. END, a.modify_time DESC LIMIT ?,?`
  258. //_, err = o.Raw(sql, pars...).QueryRows(&items)
  259. pars = append(pars, startSize)
  260. pars = append(pars, pageSize)
  261. err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error
  262. return
  263. }
  264. func GetReportListCount(condition string, pars []interface{}) (count int, err error) {
  265. //oRddp := orm.NewOrmUsingDB("rddp")
  266. sql := `SELECT COUNT(1) AS count FROM report WHERE 1=1 `
  267. if condition != "" {
  268. sql += condition
  269. }
  270. //err = oRddp.Raw(sql, pars).QueryRow(&count)
  271. err = global.DmSQL["rddp"].Raw(sql, pars...).Scan(&count).Error
  272. return
  273. }
  274. // PublishCancelReport 取消发布报告
  275. func PublishCancelReport(reportId, state int, publishTimeNullFlag bool, lastModifyAdminId int, lastModifyAdminName string) (err error) {
  276. //o := orm.NewOrmUsingDB("rddp")
  277. var sql string
  278. if publishTimeNullFlag {
  279. sql = ` UPDATE report SET state=?, publish_time=null, pre_publish_time=null, pre_msg_send=0,last_modify_admin_id=?,last_modify_admin_name=?,modify_time = NOW() WHERE id =?`
  280. } else {
  281. sql = ` UPDATE report SET state=?, pre_publish_time=null, pre_msg_send=0,last_modify_admin_id=?,last_modify_admin_name=?,modify_time = NOW() WHERE id =?`
  282. }
  283. // _, err = o.Raw(sql, state, lastModifyAdminId, lastModifyAdminName, reportId).Exec()
  284. err = global.DmSQL["rddp"].Exec(sql, state, lastModifyAdminId, lastModifyAdminName, reportId).Error
  285. return
  286. }
  287. // 删除报告
  288. func DeleteReport(reportIds int) (err error) {
  289. //o := orm.NewOrmUsingDB("rddp")
  290. sql := ` DELETE FROM report WHERE id =? `
  291. //_, err = o.Raw(sql, reportIds).Exec()
  292. err = global.DmSQL["rddp"].Exec(sql, reportIds).Error
  293. return
  294. }
  295. type ReportDetail struct {
  296. gorm.Model
  297. Id int `gorm:"column:id;primary_key;autoIncrement" description:"报告Id"`
  298. AddType int `gorm:"column:add_type" description:"新增方式:1:新增报告,2:继承报告"`
  299. ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类id"`
  300. ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"`
  301. ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类id"`
  302. ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"`
  303. Title string `gorm:"column:title" description:"标题"`
  304. Abstract string `gorm:"column:abstract" description:"摘要"`
  305. Author string `gorm:"column:author" description:"作者"`
  306. Frequency string `gorm:"column:frequency" description:"频度"`
  307. CreateTime string `gorm:"column:create_time" description:"创建时间"`
  308. ModifyTime string `gorm:"column:modify_time" description:"修改时间"`
  309. State int `gorm:"column:state" description:"1:未发布,2:已发布"`
  310. PublishTime string `gorm:"column:publish_time" description:"发布时间"`
  311. PrePublishTime string `gorm:"column:pre_publish_time" description:"预发布时间"`
  312. Stage int `gorm:"column:stage" description:"期数"`
  313. MsgIsSend int `gorm:"column:msg_is_send" description:"消息是否已发送,0:否,1:是"`
  314. PreMsgSend int `gorm:"column:pre_msg_send" description:"定时发布成功后是否立即推送模版消息:0否,1是"`
  315. Content string `gorm:"column:content" description:"内容"`
  316. VideoUrl string `gorm:"column:video_url" description:"音频文件URL"`
  317. VideoName string `gorm:"column:video_name" description:"音频文件名称"`
  318. VideoPlaySeconds string `gorm:"column:video_play_seconds" description:"音频播放时长"`
  319. ContentSub string `gorm:"column:content_sub" description:"内容前两个章节"`
  320. ThsMsgIsSend int `gorm:"column:ths_msg_is_send" description:"客户群消息是否已发送,0:否,1:是"`
  321. HasChapter int `gorm:"column:has_chapter" description:"是否有章节 0-否 1-是"`
  322. ChapterType string `gorm:"column:chapter_type" description:"章节类型 day-晨报 week-周报"`
  323. AdminId int `gorm:"column:admin_id" description:"创建者账号"`
  324. AdminRealName string `gorm:"column:admin_real_name" description:"创建者姓名"`
  325. ReportCode string `gorm:"column:report_code" description:"报告唯一编码"`
  326. // eta1.8.3(研报改版)相关内容
  327. ContentStruct string `gorm:"column:content_struct" description:"内容组件"`
  328. LastModifyAdminId int `gorm:"column:last_modify_admin_id" description:"最后更新人ID"`
  329. LastModifyAdminName string `gorm:"column:last_modify_admin_name" description:"最后更新人姓名"`
  330. ContentModifyTime time.Time `gorm:"column:content_modify_time" description:"内容更新时间"`
  331. Pv int `gorm:"column:pv" description:"pv"`
  332. Uv int `gorm:"column:uv" description:"uv"`
  333. HeadImg string `gorm:"column:head_img" description:"报告头图地址"`
  334. EndImg string `gorm:"column:end_img" description:"报告尾图地址"`
  335. HeadStyle string `gorm:"column:head_style" description:"版头样式"`
  336. EndStyle string `gorm:"column:end_style" description:"版尾样式"`
  337. CanvasColor string `gorm:"column:canvas_color" description:"画布颜色"`
  338. NeedSplice int `gorm:"column:need_splice" description:"是否拼接版头版位的标记,主要是为了兼容历史报告。0-不需要 1-需要"`
  339. HeadResourceId int `gorm:"column:head_resource_id" description:"版头资源ID"`
  340. EndResourceId int `gorm:"column:end_resource_id" description:"版尾资源ID"`
  341. ClassifyIdThird int `gorm:"column:classify_id_third" description:"三级分类id"`
  342. ClassifyNameThird string `gorm:"column:classify_name_third" description:"三级分类名称"`
  343. CollaborateType int8 `gorm:"column:collaborate_type" description:"协作方式,1:个人,2:多人协作。默认:1"`
  344. ReportLayout int8 `gorm:"column:report_layout" description:"报告布局,1:常规布局,2:智能布局。默认:1"`
  345. IsPublicPublish int8 `gorm:"column:is_public_publish" description:"是否公开发布,1:是,2:否"`
  346. ReportCreateTime time.Time `gorm:"column:report_create_time" description:"报告时间创建时间"`
  347. }
  348. func GetReportById(reportId int) (item *ReportDetail, err error) {
  349. //o := orm.NewOrmUsingDB("rddp")
  350. sql := `SELECT * FROM report WHERE id=?`
  351. //err = o.Raw(sql, reportId).QueryRow(&item)
  352. err = global.DmSQL["rddp"].Raw(sql, reportId).First(&item).Error
  353. return
  354. }
  355. // GetSimpleReportByIds 根据报告ID查询报告基本信息
  356. func GetSimpleReportByIds(reportIds []int) (list []*Report, err error) {
  357. if len(reportIds) == 0 {
  358. return
  359. }
  360. //o := orm.NewOrmUsingDB("rddp")
  361. sql := `SELECT id, title, report_code FROM report WHERE id IN (` + utils.GetOrmInReplace(len(reportIds)) + `)`
  362. //_, err = o.Raw(sql, reportIds).QueryRows(&list)
  363. err = global.DmSQL["rddp"].Raw(sql, reportIds).Find(&list).Error
  364. return
  365. }
  366. // GetReportStage
  367. // @Description: 获取报告的最大期数(每一年的最大期数)
  368. // @author: Roc
  369. // @datetime 2024-06-03 17:44:14
  370. // @param classifyIdFirst int
  371. // @param classifyIdSecond int
  372. // @param classifyIdThird int
  373. // @return count int
  374. // @return err error
  375. func GetReportStage(classifyIdFirst, classifyIdSecond, classifyIdThird int) (count int, err error) {
  376. //o := orm.NewOrmUsingDB("rddp")
  377. classifyId := classifyIdThird
  378. if classifyId <= 0 {
  379. classifyId = classifyIdSecond
  380. }
  381. if classifyId <= 0 {
  382. classifyId = classifyIdFirst
  383. }
  384. if classifyId <= 0 {
  385. err = errors.New("错误的分类id")
  386. return
  387. }
  388. yearStart := time.Date(time.Now().Local().Year(), 1, 1, 0, 0, 0, 0, time.Local)
  389. sql := `SELECT COALESCE(MAX(stage),0) AS count FROM report WHERE create_time > ? `
  390. if classifyIdThird > 0 {
  391. sql += " AND classify_id_third = ? "
  392. } else if classifyIdSecond > 0 {
  393. sql += " AND classify_id_second = ? "
  394. } else {
  395. sql += " AND classify_id_first = ? "
  396. }
  397. //o.Raw(sql, yearStart, classifyId).QueryRow(&count)
  398. err = global.DmSQL["rddp"].Raw(sql, yearStart, classifyId).Scan(&count).Error
  399. return
  400. }
  401. type PublishReq struct {
  402. ReportIds string `description:"报告id,多个用英文逗号隔开"`
  403. ReportUrl string `description:"报告Url"`
  404. }
  405. type PublishCancelReq struct {
  406. ReportIds int `description:"报告id"`
  407. }
  408. type DeleteReq struct {
  409. ReportIds int `description:"报告id"`
  410. }
  411. type AddReq struct {
  412. AddType int `description:"新增方式:1:新增报告,2:继承报告"`
  413. ClassifyIdFirst int `description:"一级分类id"`
  414. ClassifyNameFirst string `description:"一级分类名称"`
  415. ClassifyIdSecond int `description:"二级分类id"`
  416. ClassifyNameSecond string `description:"二级分类名称"`
  417. ClassifyIdThird int `description:"三级分类id"`
  418. ClassifyNameThird string `description:"三级分类名称"`
  419. Title string `description:"标题"`
  420. Abstract string `description:"摘要"`
  421. Author string `description:"作者"`
  422. Frequency string `description:"频度"`
  423. State int `description:"状态:1:未发布,2:已发布"`
  424. Content string `description:"内容"`
  425. CreateTime string `description:"创建时间"`
  426. ReportVersion int `description:"1:旧版,2:新版"`
  427. ContentStruct string `description:"内容组件"`
  428. HeadImg string `description:"报告头图地址"`
  429. EndImg string `description:"报告尾图地址"`
  430. CanvasColor string `description:"画布颜色"`
  431. NeedSplice int `description:"是否拼接版头版位的标记,主要是为了兼容历史报告。0-不需要 1-需要"`
  432. HeadResourceId int `description:"版头资源ID"`
  433. EndResourceId int `description:"版尾资源ID"`
  434. CollaborateType int8 `description:"协作方式,1:个人,2:多人协作。默认:1"`
  435. ReportLayout int8 `description:"报告布局,1:常规布局,2:智能布局。默认:1"`
  436. IsPublicPublish int8 `description:"是否公开发布,1:是,2:否"`
  437. InheritReportId int `description:"待继承的报告ID"`
  438. GrantAdminIdList []int `description:"授权用户id列表"`
  439. }
  440. type PrePublishReq struct {
  441. ReportId int `description:"报告id"`
  442. PrePublishTime string `description:"预发布时间"`
  443. PreMsgSend int `description:"定时发布成功后是否立即推送模版消息:0否,1是"`
  444. ReportUrl string `description:"报告Url"`
  445. }
  446. type AddResp struct {
  447. ReportId int64 `description:"报告id"`
  448. ReportCode string `description:"报告code"`
  449. }
  450. func AddReport(item *Report) (lastId int64, err error) {
  451. o := orm.NewOrmUsingDB("rddp")
  452. lastId, err = o.Insert(item)
  453. return
  454. }
  455. type EditReq struct {
  456. ReportId int64 `description:"报告id"`
  457. ClassifyIdFirst int `description:"一级分类id"`
  458. ClassifyNameFirst string `description:"一级分类名称"`
  459. ClassifyIdSecond int `description:"二级分类id"`
  460. ClassifyNameSecond string `description:"二级分类名称"`
  461. ClassifyIdThird int `description:"三级分类id"`
  462. ClassifyNameThird string `description:"三级分类名称"`
  463. Title string `description:"标题"`
  464. Abstract string `description:"摘要"`
  465. Author string `description:"作者"`
  466. Frequency string `description:"频度"`
  467. State int `description:"状态:1:未发布,2:已发布"`
  468. Content string `description:"内容"`
  469. CreateTime string `description:"创建时间"`
  470. ContentStruct string `description:"内容组件"`
  471. HeadImg string `description:"报告头图地址"`
  472. EndImg string `description:"报告尾图地址"`
  473. CanvasColor string `description:"画布颜色"`
  474. NeedSplice int `description:"是否拼接版头版位的标记,主要是为了兼容历史报告。0-不需要 1-需要"`
  475. HeadResourceId int `description:"版头资源ID"`
  476. EndResourceId int `description:"版尾资源ID"`
  477. //CollaborateType int8 `description:"协作方式,1:个人,2:多人协作。默认:1"`
  478. //ReportLayout int8 `description:"报告布局,1:常规布局,2:智能布局。默认:1"`
  479. IsPublicPublish int8 `description:"是否公开发布,1:是,2:否"`
  480. GrantAdminIdList []int `description:"授权用户id列表"`
  481. }
  482. type EditResp struct {
  483. ReportId int64 `description:"报告id"`
  484. ReportCode string `description:"报告code"`
  485. }
  486. func EditReport(item *Report, reportId int64) (err error) {
  487. //o := orm.NewOrmUsingDB("rddp")
  488. sql := `UPDATE report
  489. SET
  490. classify_id_first =?,
  491. classify_name_first = ?,
  492. classify_id_second = ?,
  493. classify_name_second = ?,
  494. title = ?,
  495. abstract = ?,
  496. author = ?,
  497. frequency = ?,
  498. state = ?,
  499. content = ?,
  500. content_sub = ?,
  501. stage =?,
  502. create_time = ?,
  503. modify_time = ?
  504. WHERE id = ? `
  505. //_, err = o.Raw(sql, item.ClassifyIdFirst, item.ClassifyNameFirst, item.ClassifyIdSecond, item.ClassifyNameSecond, item.Title,
  506. // item.Abstract, item.Author, item.Frequency, item.State, item.Content, item.ContentSub, item.Stage, item.CreateTime, time.Now(), reportId).Exec()
  507. err = global.DmSQL["rddp"].Exec(sql, item.ClassifyIdFirst, item.ClassifyNameFirst, item.ClassifyIdSecond, item.ClassifyNameSecond, item.Title,
  508. item.Abstract, item.Author, item.Frequency, item.State, item.Content, item.ContentSub, item.Stage, item.CreateTime, time.Now(), reportId).Error
  509. return
  510. }
  511. func (m *Report) Update(cols []string) (err error) {
  512. //o := orm.NewOrmUsingDB("rddp")
  513. //_, err = o.Update(m, cols...)
  514. err = global.DmSQL["rddp"].Select(cols).Updates(m).Error
  515. return
  516. }
  517. type ReportDetailReq struct {
  518. ReportId int `description:"报告id"`
  519. }
  520. type ClassifyIdDetailReq struct {
  521. ClassifyIdFirst int `description:"报告一级分类id"`
  522. ClassifyIdSecond int `description:"报告二级分类id"`
  523. }
  524. func GetReportDetailByClassifyId(classifyIdFirst, classifyIdSecond int) (item *Report, err error) {
  525. //o := orm.NewOrmUsingDB("rddp")
  526. sql := ` SELECT * FROM report WHERE 1=1 `
  527. if classifyIdSecond > 0 {
  528. sql = sql + ` AND classify_id_second=? ORDER BY stage DESC LIMIT 1`
  529. //err = o.Raw(sql, classifyIdSecond).QueryRow(&item)
  530. err = global.DmSQL["rddp"].Raw(sql, classifyIdSecond).First(&item).Error
  531. } else {
  532. sql = sql + ` AND classify_id_first=? ORDER BY stage DESC LIMIT 1`
  533. //err = o.Raw(sql, classifyIdFirst).QueryRow(&item)
  534. err = global.DmSQL["rddp"].Raw(sql, classifyIdFirst).First(&item).Error
  535. }
  536. return
  537. }
  538. type SendTemplateMsgReq struct {
  539. ReportId int `description:"报告id"`
  540. }
  541. // SendTemplateMsgResp
  542. // @Description: 报告推送返回结构体
  543. type SendTemplateMsgResp struct {
  544. ReportId int `description:"报告id"`
  545. MsgSendTime string `description:"报告推送时间"`
  546. }
  547. func ModifyReportMsgIsSend(reportId int) (err error) {
  548. //o := orm.NewOrmUsingDB("rddp")
  549. report, err := GetReportById(reportId)
  550. if err != nil {
  551. return
  552. }
  553. if report.MsgIsSend == 0 {
  554. sql := `UPDATE report SET msg_is_send = 1, msg_send_time=NOW() WHERE id = ? `
  555. err = global.DmSQL["rddp"].Exec(sql, reportId).Error
  556. //_, err = o.Raw(sql, reportId).Exec()
  557. }
  558. return
  559. }
  560. func ModifyReportVideo(reportId int, videoUrl, videoName, videoSize string, playSeconds float64) (err error) {
  561. //o := orm.NewOrmUsingDB("rddp")
  562. sql := `UPDATE report SET video_url=?,video_name=?,video_play_seconds=?,video_size=? WHERE id=? `
  563. //_, err = o.Raw(sql, videoUrl, videoName, playSeconds, videoSize, reportId).Exec()
  564. err = global.DmSQL["rddp"].Exec(sql, videoUrl, videoName, playSeconds, videoSize, reportId).Error
  565. return
  566. }
  567. // ModifyReportVideoByNoVideo
  568. // @Description: 修改无音频的报告音频信息
  569. // @author: Roc
  570. // @datetime 2024-07-25 18:03:05
  571. // @param reportId int
  572. // @param videoUrl string
  573. // @param videoName string
  574. // @param videoSize string
  575. // @param playSeconds float64
  576. // @return err error
  577. func ModifyReportVideoByNoVideo(reportId int, videoUrl, videoName, videoSize string, playSeconds float64) (err error) {
  578. //o := orm.NewOrmUsingDB("rddp")
  579. sql := `UPDATE report SET video_url=?,video_name=?,video_play_seconds=?,video_size=? WHERE id=? AND video_url=""`
  580. //_, err = o.Raw(sql, videoUrl, videoName, playSeconds, videoSize, reportId).Exec()
  581. err = global.DmSQL["rddp"].Exec(sql, videoUrl, videoName, playSeconds, videoSize, reportId).Error
  582. return
  583. }
  584. type ReportItem struct {
  585. gorm.Model
  586. Id int `gorm:"column:id;primary_key;autoIncrement" description:"报告Id"`
  587. AddType int `gorm:"column:add_type" description:"新增方式:1:新增报告,2:继承报告"`
  588. ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类id"`
  589. ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"`
  590. ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类id"`
  591. ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"`
  592. Title string `gorm:"column:title" description:"标题"`
  593. Abstract string `gorm:"column:abstract" description:"摘要"`
  594. Author string `gorm:"column:author" description:"作者"`
  595. Frequency string `gorm:"column:frequency" description:"频度"`
  596. CreateTime time.Time `gorm:"column:create_time" description:"创建时间"`
  597. ModifyTime time.Time `gorm:"column:modify_time" description:"修改时间"`
  598. State int `gorm:"column:state" description:"1:未发布,2:已发布"`
  599. PublishTime time.Time `gorm:"column:publish_time" description:"发布时间"`
  600. Stage int `gorm:"column:stage" description:"期数"`
  601. MsgIsSend int `gorm:"column:msg_is_send" description:"消息是否已发送,0:否,1:是"`
  602. Content string `gorm:"column:content" description:"内容"`
  603. VideoUrl string `gorm:"column:video_url" description:"音频文件URL"`
  604. VideoName string `gorm:"column:video_name" description:"音频文件名称"`
  605. VideoPlaySeconds string `gorm:"column:video_play_seconds" description:"音频播放时长"`
  606. ContentSub string `gorm:"column:content_sub" description:"内容前两个章节"`
  607. }
  608. func GetReportItemById(reportId int) (item *ReportItem, err error) {
  609. //o := orm.NewOrmUsingDB("rddp")
  610. sql := `SELECT * FROM report WHERE id=?`
  611. //err = o.Raw(sql, reportId).QueryRow(&item)
  612. err = global.DmSQL["rddp"].Raw(sql, reportId).First(&item).Error
  613. return
  614. }
  615. type SaveReportContent struct {
  616. Content string `description:"内容"`
  617. ReportId int `description:"报告id"`
  618. NoChange int `description:"内容是否未改变:1:内容未改变"`
  619. // 以下是智能研报相关
  620. ContentStruct string `description:"内容组件"`
  621. HeadImg string `description:"报告头图地址"`
  622. EndImg string `description:"报告尾图地址"`
  623. CanvasColor string `description:"画布颜色"`
  624. NeedSplice int `description:"是否拼接版头版位的标记,主要是为了兼容历史报告。0-不需要 1-需要"`
  625. HeadResourceId int `description:"版头资源ID"`
  626. EndResourceId int `description:"版尾资源ID"`
  627. }
  628. func AddReportSaveLog(reportId, adminId int, content, contentSub, contentStruct, canvasColor, adminName string, headResourceId, endResourceId int) (err error) {
  629. //o := orm.NewOrmUsingDB("rddp")
  630. sql := ` INSERT INTO report_save_log(report_id, content,content_sub,content_struct,canvas_color,head_resource_id,end_resource_id,admin_id,admin_name) VALUES (?,?,?,?,?,?,?,?,?) `
  631. //_, err = o.Raw(sql, reportId, content, contentSub, contentStruct, canvasColor, headResourceId, endResourceId, adminId, adminName).Exec()
  632. err = global.DmSQL["rddp"].Exec(sql, reportId, content, contentSub, contentStruct, canvasColor, headResourceId, endResourceId, adminId, adminName).Error
  633. return
  634. }
  635. func MultiAddReportChaptersSaveLog(items []*ReportChapter, adminId int, adminRealName string) (err error) {
  636. //o := orm.NewOrmUsingDB("rddp")
  637. //p, err := o.Raw(`INSERT INTO report_save_log(report_id, report_chapter_id, content, content_sub,content_struct,admin_id, admin_name) VALUES (?,?,?,?,?,?,?)`).Prepare()
  638. //if err != nil {
  639. // return
  640. //}
  641. //defer func() {
  642. // _ = p.Close()
  643. //}()
  644. //for _, v := range items {
  645. // _, err = p.Exec(v.ReportId, v.ReportChapterId, v.Content, v.ContentSub, v.ContentStruct, adminId, adminRealName)
  646. // if err != nil {
  647. // return
  648. // }
  649. //}
  650. tx := global.DmSQL["rddp"].Begin()
  651. for _, v := range items {
  652. err = tx.Exec(`INSERT INTO report_save_log(report_id, report_chapter_id, content, content_sub,content_struct,admin_id, admin_name) VALUES (?,?,?,?,?,?,?)`, v.ReportId, v.ReportChapterId, v.Content, v.ContentSub, v.ContentStruct, adminId, adminRealName).Error
  653. if err != nil {
  654. tx.Rollback()
  655. return
  656. }
  657. }
  658. tx.Commit()
  659. return
  660. }
  661. type SaveReportContentResp struct {
  662. ReportId int `description:"报告id"`
  663. }
  664. func ModifyReportCode(reportId int64, reportCode string) (err error) {
  665. //o := orm.NewOrmUsingDB("rddp")
  666. sql := `UPDATE report SET report_code=? WHERE id=? `
  667. //_, err = o.Raw(sql, reportCode, reportId).Exec()
  668. err = global.DmSQL["rddp"].Exec(sql, reportCode, reportId).Error
  669. return
  670. }
  671. func ModifyReportThsMsgIsSend(item *ReportDetail) (err error) {
  672. //o := orm.NewOrmUsingDB("rddp")
  673. if item.ThsMsgIsSend == 0 {
  674. sql := `UPDATE report SET ths_msg_is_send = 1 WHERE id = ? `
  675. //_, err = o.Raw(sql, item.Id).Exec()
  676. err = global.DmSQL["rddp"].Exec(sql, item.Id).Error
  677. }
  678. return
  679. }
  680. type ThsSendTemplateMsgReq struct {
  681. ReportId []int `description:"报告id"`
  682. }
  683. type PublishDayWeekReportReq struct {
  684. ReportId int `description:"报告ID"`
  685. }
  686. // SaveDayWeekReportReq 新增晨报周报请求体
  687. type SaveDayWeekReportReq struct {
  688. ReportId int `description:"报告ID"`
  689. Title string `description:"标题"`
  690. ReportType string `description:"一级分类ID"`
  691. Author string `description:"作者"`
  692. CreateTime string `description:"创建时间"`
  693. }
  694. // GetReportByReportId 主键获取报告
  695. func GetReportByReportId(reportId int) (item *Report, err error) {
  696. //o := orm.NewOrmUsingDB("rddp")
  697. sql := `SELECT * FROM report WHERE id = ?`
  698. //err = o.Raw(sql, reportId).QueryRow(&item)
  699. err = global.DmSQL["rddp"].Raw(sql, reportId).First(&item).Error
  700. return
  701. }
  702. // DeleteDayWeekReportAndChapter 删除晨周报及章节
  703. func DeleteDayWeekReportAndChapter(reportId int) (err error) {
  704. //o := orm.NewOrmUsingDB("rddp")
  705. //to, err := o.Begin()
  706. to := global.DmSQL["rddp"].Begin()
  707. defer func() {
  708. if err != nil {
  709. _ = to.Rollback()
  710. } else {
  711. _ = to.Commit()
  712. }
  713. }()
  714. sql := ` DELETE FROM report WHERE id = ? LIMIT 1 `
  715. //if _, err = to.Raw(sql, reportId).Exec(); err != nil {
  716. // return
  717. //}
  718. if err = to.Exec(sql, reportId).Error; err != nil {
  719. return
  720. }
  721. sql = ` DELETE FROM report_chapter WHERE report_id = ? `
  722. //if _, err = to.Raw(sql, reportId).Exec(); err != nil {
  723. // return
  724. //}
  725. if err = to.Exec(sql, reportId).Error; err != nil {
  726. return
  727. }
  728. return
  729. }
  730. // UpdateReport 更新报告
  731. func (reportInfo *Report) UpdateReport(cols []string) (err error) {
  732. //o := orm.NewOrmUsingDB("rddp")
  733. //_, err = o.Update(reportInfo, cols...)
  734. err = global.DmSQL["rddp"].Select(cols).Updates(reportInfo).Error
  735. return
  736. }
  737. // ReportDetailView
  738. // @Description: 晨周报详情
  739. type ReportDetailView struct {
  740. *ReportDetail
  741. ChapterList []*ReportChapter
  742. GrandAdminList []ReportDetailViewAdmin
  743. PermissionList []ReportDetailViewPermission
  744. }
  745. // ReportDetailViewAdmin
  746. // @Description: 报告里面的授权人
  747. type ReportDetailViewAdmin struct {
  748. AdminId int
  749. AdminName string
  750. }
  751. // ReportDetailViewPermission
  752. // @Description: 报告分类关联的品种权限
  753. type ReportDetailViewPermission struct {
  754. PermissionId int
  755. PermissionName string
  756. }
  757. type ElasticReportDetail struct {
  758. gorm.Model
  759. ReportId int `gorm:"column:report_id;index" description:"报告ID"`
  760. ReportChapterId int `gorm:"column:report_chapter_id" description:"报告章节ID"`
  761. Title string `gorm:"column:title" description:"标题"`
  762. Abstract string `gorm:"column:abstract" description:"摘要"`
  763. BodyContent string `gorm:"column:body_content" description:"内容"`
  764. PublishTime string `gorm:"column:publish_time" description:"发布时间"`
  765. PublishState int `gorm:"column:publish_state" description:"发布状态 1-未发布 2-已发布"`
  766. Author string `gorm:"column:author" description:"作者"`
  767. ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类ID"`
  768. ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"`
  769. ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类ID"`
  770. ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"`
  771. ClassifyId int `gorm:"column:classify_id" description:"最小单元的分类ID"`
  772. ClassifyName string `gorm:"column:classify_name" description:"最小单元的分类名称"`
  773. Categories string `gorm:"column:categories" description:"关联的品种名称(包括品种别名)"`
  774. StageStr string `gorm:"column:stage_str" description:"报告期数"`
  775. }
  776. // PublishReportAndChapter 发布报告及章节
  777. func PublishReportAndChapter(reportInfo *Report, isPublishReport bool, cols []string) (err error) {
  778. //o := orm.NewOrmUsingDB("rddp")
  779. //to, err := o.Begin()
  780. to := global.DmSQL["rddp"].Begin()
  781. defer func() {
  782. if err != nil {
  783. _ = to.Rollback()
  784. } else {
  785. _ = to.Commit()
  786. }
  787. }()
  788. // 更新报告
  789. if isPublishReport {
  790. // _, err = to.Update(reportInfo, cols...)
  791. err = to.Select(cols).Updates(reportInfo).Error
  792. if err != nil {
  793. return
  794. }
  795. }
  796. // 发布该报告的所有章节
  797. sql := ` UPDATE report_chapter SET publish_state = 2, publish_time = ? WHERE report_id = ? `
  798. //_, err = to.Raw(sql, reportInfo.PublishTime, reportInfo.Id).Exec()
  799. err = to.Exec(sql, reportInfo.PublishTime, reportInfo.Id).Error
  800. // 发布章节
  801. //if len(publishIds) > 0 {
  802. // sql := ` UPDATE report_chapter SET publish_state = 2, publish_time = ? WHERE report_id = ? AND report_chapter_id IN (` + utils.GetOrmInReplace(len(publishIds)) + `) `
  803. // _, err = to.Raw(sql, reportInfo.PublishTime, reportInfo.Id, publishIds).Exec()
  804. //}
  805. //if len(unPublishIds) > 0 {
  806. // sql := ` UPDATE report_chapter SET publish_state = 1, publish_time = NULL, is_edit = 0 WHERE report_id = ? AND report_chapter_id IN (` + utils.GetOrmInReplace(len(unPublishIds)) + `) `
  807. // _, err = to.Raw(sql, reportInfo.Id, unPublishIds).Exec()
  808. //}
  809. return
  810. }
  811. // PublishReportById 发布报告
  812. func PublishReportById(reportId int, publishTime time.Time, lastModifyAdminId int, lastModifyAdminName string) (err error) {
  813. //o := orm.NewOrmUsingDB("rddp")
  814. sql := `UPDATE report SET state = 2, publish_time = ?, pre_publish_time=null, pre_msg_send=0, modify_time = NOW(),last_modify_admin_id=?,last_modify_admin_name=? WHERE id = ? `
  815. //_, err = o.Raw(sql, publishTime, lastModifyAdminId, lastModifyAdminName, reportId).Exec()
  816. err = global.DmSQL["rddp"].Exec(sql, publishTime, lastModifyAdminId, lastModifyAdminName, reportId).Error
  817. return
  818. }
  819. // ResetReportById 重置报告状态
  820. func ResetReportById(reportId, state int, lastModifyAdminId int, lastModifyAdminName string) (err error) {
  821. //o := orm.NewOrmUsingDB("rddp")
  822. sql := `UPDATE report SET state = ?, pre_publish_time = null, pre_msg_send = 0, modify_time = NOW(),last_modify_admin_id=?,last_modify_admin_name=? WHERE id = ?`
  823. //_, err = o.Raw(sql, state, lastModifyAdminId, lastModifyAdminName, reportId).Exec()
  824. err = global.DmSQL["rddp"].Exec(sql, state, lastModifyAdminId, lastModifyAdminName, reportId).Error
  825. return
  826. }
  827. // 点赞相关的报告列表
  828. type LikeReportItem struct {
  829. gorm.Model
  830. ReportId int `gorm:"column:report_id;index" description:"报告Id"`
  831. ReportChapterId int `gorm:"column:report_chapter_id" description:"报告章节Id"`
  832. ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类id"`
  833. ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"`
  834. ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类id"`
  835. ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"`
  836. ReportChapterTypeId int `gorm:"column:report_chapter_type_id" description:"章节类型"`
  837. ReportChapterTypeName string `gorm:"column:report_chapter_type_name" description:"品种名称"`
  838. PublishTime time.Time `gorm:"column:publish_time" description:"发布时间"`
  839. Title string `gorm:"column:title" description:"标题"`
  840. }
  841. // SunCodeReq 获取太阳码请求体
  842. type SunCodeReq struct {
  843. CodePage string `json:"CodePage" description:"太阳码page"`
  844. CodeScene string `json:"CodeScene" description:"太阳码scene"`
  845. }
  846. // YbPcSuncode 活动海报表
  847. type YbPcSuncode struct {
  848. SuncodeID uint32 `gorm:"column:suncode_id;primaryKey" json:"suncodeId"` //`orm:"column(suncode_id);pk" gorm:"primaryKey" `
  849. Scene string `gorm:"column:scene;type:varchar(255);not null;default:0" json:"scene"` // 微信scene
  850. SceneMd5 string `gorm:"column:scene_md5;type:varchar(255);not null" json:"sceneMd5"`
  851. CodePage string `gorm:"column:code_page;type:varchar(255);not null;default:''" json:"codePage"` // 路径
  852. SuncodeUrl string `gorm:"column:suncode_url;type:varchar(255);not null;default:''" json:"suncodeUrl"` // 太阳码储存地址
  853. CreateTime time.Time `gorm:"column:create_time;type:timestamp;default:CURRENT_TIMESTAMP" json:"createTime"`
  854. }
  855. // GetYbPcSunCode 获取太阳码
  856. func GetYbPcSunCode(scene, page string) (item *YbPcSuncode, err error) {
  857. //o := orm.NewOrmUsingDB("weekly")
  858. sql := `SELECT * FROM yb_pc_suncode WHERE scene = ? AND code_page = ? `
  859. //err = o.Raw(sql, scene, page).QueryRow(&item)
  860. err = global.DmSQL["weekly"].Raw(sql, scene, page).First(&item).Error
  861. return
  862. }
  863. func AddYbPcSunCode(item *YbPcSuncode) (err error) {
  864. //o := orm.NewOrmUsingDB("weekly")
  865. //_, err = o.Insert(item)
  866. err = global.DmSQL["weekly"].Create(item).Error
  867. return
  868. }
  869. // YbSuncodePars 小程序太阳码scene参数
  870. type YbSuncodePars struct {
  871. ID uint32 `gorm:"column:id;primaryKey" json:"id"` //`orm:"column(id);pk" gorm:"primaryKey" `
  872. Scene string `gorm:"column:scene;type:varchar(255);not null;default:''" json:"scene"` // scene参数
  873. SceneKey string `gorm:"column:scene_key;type:varchar(32);not null;default:''" json:"scene_key"` // MD5值
  874. CreateTime time.Time `gorm:"column:create_time;type:datetime;default:CURRENT_TIMESTAMP" json:"createTime"`
  875. }
  876. func AddYbSuncodePars(item *YbSuncodePars) (err error) {
  877. //o := orm.NewOrmUsingDB("weekly")
  878. //_, err = o.Insert(item)
  879. err = global.DmSQL["weekly"].Create(item).Error
  880. return
  881. }
  882. // UpdateReportSecondClassifyNameByClassifyId 更新报告分类名称字段
  883. func UpdateReportSecondClassifyNameByClassifyId(classifyId int, classifyName string) (err error) {
  884. //o := orm.NewOrmUsingDB("rddp")
  885. sql := " UPDATE report SET classify_name_second = ? WHERE classify_id_second = ? "
  886. //_, err = o.Raw(sql, classifyName, classifyId).Exec()
  887. err = global.DmSQL["rddp"].Exec(sql, classifyName, classifyId).Error
  888. return
  889. }
  890. // UpdateReportFirstClassifyNameByClassifyId 更新报告分类一级名称字段
  891. func UpdateReportFirstClassifyNameByClassifyId(classifyId int, classifyName string) (err error) {
  892. //o := orm.NewOrmUsingDB("rddp")
  893. sql := " UPDATE report SET classify_name_first = ? WHERE classify_id_first = ? "
  894. //_, err = o.Raw(sql, classifyName, classifyId).Exec()
  895. err = global.DmSQL["rddp"].Exec(sql, classifyName, classifyId).Error
  896. return
  897. }
  898. // UpdateReportThirdClassifyNameByClassifyId 更新报告的三级分类名称字段
  899. func UpdateReportThirdClassifyNameByClassifyId(classifyId int, classifyName string) (err error) {
  900. //o := orm.NewOrmUsingDB("rddp")
  901. sql := " UPDATE report SET classify_name_third = ? WHERE classify_id_third = ? "
  902. //_, err = o.Raw(sql, classifyName, classifyId).Exec()
  903. err = global.DmSQL["rddp"].Exec(sql, classifyName, classifyId).Error
  904. return
  905. }
  906. // ModifyReportAuthor 更改报告作者
  907. func ModifyReportAuthor(condition string, pars []interface{}, authorName string) (count int, err error) {
  908. //产品权限
  909. //oRddp := orm.NewOrmUsingDB("rddp")
  910. sql := `UPDATE english_report set author = ? WHERE 1=1 `
  911. if condition != "" {
  912. sql += condition
  913. }
  914. //err = oRddp.Raw(sql, authorName, pars).QueryRow(&count)
  915. //err = global.DmSQL["rddp"].Raw(sql, utils.ForwardPars(pars, authorName)...).Scan(&count).Error
  916. result := global.DmSQL["rddp"].Raw(sql, utils.ForwardPars(pars, authorName)...)
  917. count = int(result.RowsAffected)
  918. err = result.Error
  919. return
  920. }
  921. func UpdateReportPublishTime(reportId int, videoNameDate string) (err error) {
  922. //o := orm.NewOrmUsingDB("rddp")
  923. sql1 := ` UPDATE report SET publish_time = NOW() WHERE id = ? `
  924. //_, err = o.Raw(sql1, reportId).Exec()
  925. err = global.DmSQL["rddp"].Exec(sql1, reportId).Error
  926. if err != nil {
  927. return
  928. }
  929. //修改音频标题
  930. sql2 := ` UPDATE report SET video_name=CONCAT(SUBSTRING_INDEX(video_name,"(",1),"` + videoNameDate + `") WHERE id = ? and (video_name !="" and video_name is not null)`
  931. //_, err = o.Raw(sql2, reportId).Exec()
  932. err = global.DmSQL["rddp"].Exec(sql2, reportId).Error
  933. return
  934. }
  935. func UpdateReportChapterPublishTime(reportId int, videoNameDate string) (err error) {
  936. //o := orm.NewOrmUsingDB("rddp")
  937. sql1 := ` UPDATE report_chapter SET publish_time = NOW() WHERE report_id = ? `
  938. //_, err = o.Raw(sql1, reportId).Exec()
  939. err = global.DmSQL["rddp"].Exec(sql1, reportId).Error
  940. if err != nil {
  941. return
  942. }
  943. //修改音频标题
  944. sql2 := ` UPDATE report_chapter SET video_name=CONCAT(SUBSTRING_INDEX(video_name,"(",1),"` + videoNameDate + `") WHERE report_id = ? and (video_name !="" and video_name is not null)`
  945. //_, err = o.Raw(sql2, reportId).Exec()
  946. err = global.DmSQL["rddp"].Exec(sql2, reportId).Error
  947. return
  948. }
  949. // MarkEditReport 标记编辑英文研报的请求数据
  950. type MarkEditReport struct {
  951. ReportId int `description:"研报id"`
  952. ReportChapterId int `description:"研报章节id"`
  953. Status int `description:"标记状态,1:编辑中,2:查询状态,3:编辑完成"`
  954. }
  955. type MarkReportResp struct {
  956. Status int `description:"状态:0:无人编辑, 1:当前有人在编辑"`
  957. Msg string `description:"提示信息"`
  958. Editor string `description:"编辑者姓名"`
  959. }
  960. type MarkReportItem struct {
  961. AdminId int `description:"编辑者ID"`
  962. Editor string `description:"编辑者姓名"`
  963. ReportClassifyNameFirst string
  964. }
  965. // GetReportByCondition 获取报告
  966. func GetReportByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string, isPage bool, startSize, pageSize int) (items []*Report, err error) {
  967. //o := orm.NewOrmUsingDB("rddp")
  968. fields := `*`
  969. if len(fieldArr) > 0 {
  970. fields = strings.Join(fieldArr, ",")
  971. }
  972. sql := `SELECT ` + fields + ` FROM report WHERE 1=1 `
  973. sql += condition
  974. order := ` ORDER BY modify_time DESC`
  975. if orderRule != `` {
  976. order = orderRule
  977. }
  978. sql += order
  979. if isPage {
  980. sql += ` LIMIT ?,?`
  981. //_, err = o.Raw(sql, pars...).QueryRows(&items)
  982. err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error
  983. } else {
  984. //_, err = o.Raw(sql, pars).QueryRows(&items)
  985. err = global.DmSQL["rddp"].Raw(sql, pars...).Find(&items).Error
  986. }
  987. return
  988. }
  989. // SetPrePublishReportById 设置定时发布
  990. func SetPrePublishReportById(reportId int, prePublishTime string, preMsgSend int) (err error) {
  991. //o := orm.NewOrmUsingDB("rddp")
  992. sql := `UPDATE report SET pre_publish_time=?, pre_msg_send=? WHERE id = ? and state = 1 `
  993. //_, err = o.Raw(sql, prePublishTime, preMsgSend, reportId).Exec()
  994. err = global.DmSQL["rddp"].Exec(sql, prePublishTime, preMsgSend, reportId).Error
  995. return
  996. }
  997. // ReportSubmitApproveReq 提交审批请求体
  998. type ReportSubmitApproveReq struct {
  999. ReportId int `description:"报告ID"`
  1000. }
  1001. // ReportCancelApproveReq 撤回审批请求体
  1002. type ReportCancelApproveReq struct {
  1003. ReportId int `description:"报告ID"`
  1004. }
  1005. func (m *Report) GetItemById(id int) (item *Report, err error) {
  1006. //o := orm.NewOrmUsingDB("rddp")
  1007. sql := `SELECT * FROM report WHERE id = ? LIMIT 1`
  1008. //err = o.Raw(sql, id).QueryRow(&item)
  1009. err = global.DmSQL["rddp"].Raw(sql, id).First(&item).Error
  1010. return
  1011. }
  1012. // GetReportStateCount 获取指定状态的报告数量
  1013. func GetReportStateCount(state int) (count int, err error) {
  1014. //o := orm.NewOrmUsingDB("rddp")
  1015. sql := `SELECT COUNT(1) AS count FROM report WHERE state = ?`
  1016. //err = o.Raw(sql, state).QueryRow(&count)
  1017. err = global.DmSQL["rddp"].Raw(sql, state).Scan(&count).Error
  1018. return
  1019. }
  1020. // UpdateReportsStateByCond 批量更新报告状态
  1021. func UpdateReportsStateByCond(classifyFirstId, classifySecondId, classifyThirdId, oldState, newState int) (err error) {
  1022. //o := orm.NewOrmUsingDB("rddp")
  1023. cond := ``
  1024. if classifyFirstId > 0 {
  1025. cond += fmt.Sprintf(` AND classify_id_first = %d`, classifyFirstId)
  1026. }
  1027. if classifySecondId > 0 {
  1028. cond += fmt.Sprintf(` AND classify_id_second = %d`, classifySecondId)
  1029. }
  1030. if classifyThirdId > 0 {
  1031. cond += fmt.Sprintf(` AND classify_id_third = %d`, classifyThirdId)
  1032. }
  1033. sql := fmt.Sprintf(`UPDATE report SET state = ?, pre_publish_time = NULL WHERE state = ? %s`, cond)
  1034. //_, err = o.Raw(sql, newState, oldState).Exec()
  1035. err = global.DmSQL["rddp"].Exec(sql, newState, oldState).Error
  1036. return
  1037. }
  1038. // UpdateReportsStateBySecondIds 批量更新二级分类报告状态
  1039. func UpdateReportsStateBySecondIds(oldState, newState int, secondIds []int) (err error) {
  1040. if len(secondIds) <= 0 {
  1041. return
  1042. }
  1043. //o := orm.NewOrmUsingDB("rddp")
  1044. // (有审批流的)未发布->待提交
  1045. sql := fmt.Sprintf(`UPDATE report SET state = ?, pre_publish_time = NULL WHERE state = ? AND classify_id_second IN (%s)`, utils.GetOrmInReplace(len(secondIds)))
  1046. //_, err = o.Raw(sql, newState, oldState, secondIds).Exec()
  1047. err = global.DmSQL["rddp"].Exec(sql, newState, oldState, secondIds).Error
  1048. if err != nil {
  1049. return
  1050. }
  1051. // (无审批流的)待提交->未发布
  1052. sql = fmt.Sprintf(`UPDATE report SET state = ?, pre_publish_time = NULL WHERE state = ? AND classify_id_second NOT IN (%s)`, utils.GetOrmInReplace(len(secondIds)))
  1053. //_, err = o.Raw(sql, oldState, newState, secondIds).Exec()
  1054. err = global.DmSQL["rddp"].Exec(sql, oldState, newState, secondIds).Error
  1055. return
  1056. }
  1057. // GetReportPdfUrlReq 获取报告pdf地址请求体
  1058. type GetReportPdfUrlReq struct {
  1059. ReportUrl string `description:"报告Url"`
  1060. ReportCode string `description:"报告Code"`
  1061. Type int `description:"类型 1-pdf 2-图片"`
  1062. }
  1063. func ModifyReportPdfUrl(reportId int, detailPdfUrl string) (err error) {
  1064. //o := orm.NewOrmUsingDB("rddp")
  1065. sql := `UPDATE report SET detail_pdf_url=? WHERE id=? `
  1066. //_, err = o.Raw(sql, detailPdfUrl, reportId).Exec()
  1067. err = global.DmSQL["rddp"].Exec(sql, detailPdfUrl, reportId).Error
  1068. return
  1069. }
  1070. func ModifyReportImgUrl(reportId int, detailImgUrl string) (err error) {
  1071. //o := orm.NewOrmUsingDB("rddp")
  1072. sql := `UPDATE report SET detail_img_url=? WHERE id=? `
  1073. //_, err = o.Raw(sql, detailImgUrl, reportId).Exec()
  1074. err = global.DmSQL["rddp"].Exec(sql, detailImgUrl, reportId).Error
  1075. return
  1076. }
  1077. // UpdatePdfUrlReportById 清空pdf相关字段
  1078. func UpdatePdfUrlReportById(reportId int) (err error) {
  1079. //o := orm.NewOrmUsingDB("rddp")
  1080. sql := `UPDATE report SET detail_img_url = '',detail_pdf_url='',modify_time=NOW() WHERE id = ? `
  1081. //_, err = o.Raw(sql, reportId).Exec()
  1082. err = global.DmSQL["rddp"].Exec(sql, reportId).Error
  1083. return
  1084. }
  1085. // InsertMultiReport
  1086. // @Description: 批量新增报告
  1087. // @author: Roc
  1088. // @datetime 2024-06-27 15:55:25
  1089. // @param items []*Report
  1090. // @return err error
  1091. func InsertMultiReport(items []*Report) (err error) {
  1092. //o := orm.NewOrmUsingDB("rddp")
  1093. //_, err = o.InsertMulti(500, items)
  1094. err = global.DmSQL["rddp"].CreateInBatches(items, utils.MultiAddNum).Error
  1095. return
  1096. }
  1097. // ReportLayout
  1098. // @Description: 报告布局
  1099. type ReportLayout struct {
  1100. Id int `gorm:"column:id;primaryKey"`
  1101. ReportLayout int8 `gorm:"column:report_layout"` //`description:"报告布局,1:常规布局,2:智能布局。默认:1"`
  1102. }
  1103. // GetReportLayoutByReportId
  1104. // @Description: 根据报告id获取报告的布局
  1105. // @author: Roc
  1106. // @datetime 2024-07-15 15:27:05
  1107. // @param reportId int
  1108. // @return item ReportLayout
  1109. // @return err error
  1110. func GetReportLayoutByReportId(reportId int) (item ReportLayout, err error) {
  1111. //o := orm.NewOrmUsingDB("rddp")
  1112. sql := `SELECT id, report_layout FROM report WHERE id = ? `
  1113. //err = o.Raw(sql, reportId).QueryRow(&item)
  1114. err = global.DmSQL["rddp"].Raw(sql, reportId).First(&item).Error
  1115. return
  1116. }
  1117. func GetReportFieldsByIds(ids []int, fields []string) (items []*Report, err error) {
  1118. if len(ids) == 0 {
  1119. return
  1120. }
  1121. //o := orm.NewOrmUsingDB("rddp")
  1122. field := " * "
  1123. if len(fields) > 0 {
  1124. field = fmt.Sprintf(" %s ", strings.Join(fields, ","))
  1125. }
  1126. sql := fmt.Sprintf(`SELECT %s FROM report WHERE id IN (%s)`, field, utils.GetOrmInReplace(len(ids)))
  1127. //_, err = o.Raw(sql, ids).QueryRows(&items)
  1128. err = global.DmSQL["rddp"].Raw(sql, ids).Find(&items).Error
  1129. return
  1130. }