report.go 68 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595
  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, startSize, pageSize).QueryRows(&items)
  189. err = global.DmSQL["rddp"].Raw(sql, pars, startSize, pageSize).Find(&items).Error
  190. return
  191. }
  192. type ReportPvUv struct {
  193. ReportId int
  194. PvTotal int
  195. UvTotal int
  196. }
  197. func GetReportPvUvByReportIdList(reportIdList []int) (items []ReportPvUv, err error) {
  198. num := len(reportIdList)
  199. if num <= 0 {
  200. return
  201. }
  202. //o := orm.NewOrmUsingDB("rddp")
  203. 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`
  204. //_, err = o.Raw(sql, reportIdList).QueryRows(&items)
  205. err = global.DmSQL["rddp"].Raw(sql, reportIdList).Find(&items).Error
  206. return
  207. }
  208. // GetReportListCountByGrant
  209. // @Description: 获取共享报告列表的报告数量
  210. // @author: Roc
  211. // @datetime 2024-05-30 15:14:01
  212. // @param condition string
  213. // @param pars []interface{}
  214. // @return count int
  215. // @return err error
  216. func GetReportListCountByGrant(condition string, pars []interface{}) (count int, err error) {
  217. //o := orm.NewOrmUsingDB("rddp")
  218. sql := `SELECT a.id FROM report as a
  219. JOIN report_grant b on a.id=b.report_id
  220. WHERE 1=1 `
  221. if condition != "" {
  222. sql += condition
  223. }
  224. sql += " GROUP BY a.id "
  225. sql = `SELECT COUNT(1) AS count FROM (` + sql + `) d`
  226. //err = o.Raw(sql, pars).QueryRow(&count)
  227. err = global.DmSQL["rddp"].Raw(sql, pars).Scan(&count).Error
  228. return
  229. }
  230. // GetReportListByGrant
  231. // @Description: 获取共享报告列表的数据
  232. // @author: Roc
  233. // @datetime 2024-05-30 15:15:07
  234. // @param condition string
  235. // @param pars []interface{}
  236. // @param startSize int
  237. // @param pageSize int
  238. // @return items []*ReportList
  239. // @return err error
  240. func GetReportListByGrant(condition string, pars []interface{}, startSize, pageSize int) (items []*ReportList, err error) {
  241. //o := orm.NewOrmUsingDB("rddp")
  242. sql := `SELECT a.* FROM report as a JOIN report_grant b on a.id = b.report_id WHERE 1=1 `
  243. if condition != "" {
  244. sql += condition
  245. }
  246. // 排序:1:未发布;2:已发布;3-待提交;4-待审批;5-已驳回;6-已通过
  247. sql += ` GROUP BY a.id ORDER BY FIELD(state,3,1,4,5,6,2), a.modify_time DESC LIMIT ?,?`
  248. //_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  249. err = global.DmSQL["rddp"].Raw(sql, pars, startSize, pageSize).Find(&items).Error
  250. return
  251. }
  252. func GetReportListCount(condition string, pars []interface{}) (count int, err error) {
  253. //oRddp := orm.NewOrmUsingDB("rddp")
  254. sql := `SELECT COUNT(1) AS count FROM report WHERE 1=1 `
  255. if condition != "" {
  256. sql += condition
  257. }
  258. //err = oRddp.Raw(sql, pars).QueryRow(&count)
  259. err = global.DmSQL["rddp"].Raw(sql, pars).Scan(&count).Error
  260. return
  261. }
  262. func GetReportList(condition string, pars []interface{}, startSize, pageSize int) (items []*ReportList, err error) {
  263. //o := orm.NewOrmUsingDB("rddp")
  264. sql := `SELECT *,
  265. (SELECT COUNT(1) FROM report_view_record AS rvr WHERE rvr.report_id=report.id) AS pv,
  266. (SELECT COUNT(DISTINCT user_id) FROM report_view_record AS rvr WHERE rvr.report_id=report.id) AS uv
  267. FROM report WHERE 1=1 `
  268. if condition != "" {
  269. sql += condition
  270. }
  271. // 排序:1:未发布;2:已发布;3-待提交;4-待审批;5-已驳回;6-已通过
  272. sql += `ORDER BY FIELD(state,3,1,4,5,6,2), modify_time DESC LIMIT ?,?`
  273. //_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  274. err = global.DmSQL["rddp"].Raw(sql, pars, startSize, pageSize).Find(&items).Error
  275. return
  276. }
  277. // PublishReport 发布报告
  278. func PublishReport(reportIds []int) (err error) {
  279. if len(reportIds) == 0 {
  280. return
  281. }
  282. //o := orm.NewOrmUsingDB("rddp")
  283. sql := `UPDATE report SET state=2,publish_time=now(),modify_time=NOW() WHERE id IN (` + utils.GetOrmInReplace(len(reportIds)) + `)`
  284. //_, err = o.Raw(sql).Exec()
  285. err = global.DmSQL["rddp"].Exec(sql, reportIds).Error
  286. return
  287. }
  288. // PublishCancelReport 取消发布报告
  289. func PublishCancelReport(reportId, state int, publishTimeNullFlag bool, lastModifyAdminId int, lastModifyAdminName string) (err error) {
  290. //o := orm.NewOrmUsingDB("rddp")
  291. var sql string
  292. if publishTimeNullFlag {
  293. 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 =?`
  294. } else {
  295. 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 =?`
  296. }
  297. // _, err = o.Raw(sql, state, lastModifyAdminId, lastModifyAdminName, reportId).Exec()
  298. err = global.DmSQL["rddp"].Exec(sql, state, lastModifyAdminId, lastModifyAdminName, reportId).Error
  299. return
  300. }
  301. // 删除报告
  302. func DeleteReport(reportIds int) (err error) {
  303. //o := orm.NewOrmUsingDB("rddp")
  304. sql := ` DELETE FROM report WHERE id =? `
  305. //_, err = o.Raw(sql, reportIds).Exec()
  306. err = global.DmSQL["rddp"].Exec(sql, reportIds).Error
  307. return
  308. }
  309. type ReportDetail struct {
  310. gorm.Model
  311. Id int `gorm:"column:id;primary_key;autoIncrement" description:"报告Id"`
  312. AddType int `gorm:"column:add_type" description:"新增方式:1:新增报告,2:继承报告"`
  313. ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类id"`
  314. ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"`
  315. ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类id"`
  316. ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"`
  317. Title string `gorm:"column:title" description:"标题"`
  318. Abstract string `gorm:"column:abstract" description:"摘要"`
  319. Author string `gorm:"column:author" description:"作者"`
  320. Frequency string `gorm:"column:frequency" description:"频度"`
  321. CreateTime string `gorm:"column:create_time" description:"创建时间"`
  322. ModifyTime string `gorm:"column:modify_time" description:"修改时间"`
  323. State int `gorm:"column:state" description:"1:未发布,2:已发布"`
  324. PublishTime string `gorm:"column:publish_time" description:"发布时间"`
  325. PrePublishTime string `gorm:"column:pre_publish_time" description:"预发布时间"`
  326. Stage int `gorm:"column:stage" description:"期数"`
  327. MsgIsSend int `gorm:"column:msg_is_send" description:"消息是否已发送,0:否,1:是"`
  328. PreMsgSend int `gorm:"column:pre_msg_send" description:"定时发布成功后是否立即推送模版消息:0否,1是"`
  329. Content string `gorm:"column:content" description:"内容"`
  330. VideoUrl string `gorm:"column:video_url" description:"音频文件URL"`
  331. VideoName string `gorm:"column:video_name" description:"音频文件名称"`
  332. VideoPlaySeconds string `gorm:"column:video_play_seconds" description:"音频播放时长"`
  333. ContentSub string `gorm:"column:content_sub" description:"内容前两个章节"`
  334. ThsMsgIsSend int `gorm:"column:ths_msg_is_send" description:"客户群消息是否已发送,0:否,1:是"`
  335. HasChapter int `gorm:"column:has_chapter" description:"是否有章节 0-否 1-是"`
  336. ChapterType string `gorm:"column:chapter_type" description:"章节类型 day-晨报 week-周报"`
  337. AdminId int `gorm:"column:admin_id" description:"创建者账号"`
  338. AdminRealName string `gorm:"column:admin_real_name" description:"创建者姓名"`
  339. ReportCode string `gorm:"column:report_code" description:"报告唯一编码"`
  340. // eta1.8.3(研报改版)相关内容
  341. ContentStruct string `gorm:"column:content_struct" description:"内容组件"`
  342. LastModifyAdminId int `gorm:"column:last_modify_admin_id" description:"最后更新人ID"`
  343. LastModifyAdminName string `gorm:"column:last_modify_admin_name" description:"最后更新人姓名"`
  344. ContentModifyTime time.Time `gorm:"column:content_modify_time" description:"内容更新时间"`
  345. Pv int `gorm:"column:pv" description:"pv"`
  346. Uv int `gorm:"column:uv" description:"uv"`
  347. HeadImg string `gorm:"column:head_img" description:"报告头图地址"`
  348. EndImg string `gorm:"column:end_img" description:"报告尾图地址"`
  349. HeadStyle string `gorm:"column:head_style" description:"版头样式"`
  350. EndStyle string `gorm:"column:end_style" description:"版尾样式"`
  351. CanvasColor string `gorm:"column:canvas_color" description:"画布颜色"`
  352. NeedSplice int `gorm:"column:need_splice" description:"是否拼接版头版位的标记,主要是为了兼容历史报告。0-不需要 1-需要"`
  353. HeadResourceId int `gorm:"column:head_resource_id" description:"版头资源ID"`
  354. EndResourceId int `gorm:"column:end_resource_id" description:"版尾资源ID"`
  355. ClassifyIdThird int `gorm:"column:classify_id_third" description:"三级分类id"`
  356. ClassifyNameThird string `gorm:"column:classify_name_third" description:"三级分类名称"`
  357. CollaborateType int8 `gorm:"column:collaborate_type" description:"协作方式,1:个人,2:多人协作。默认:1"`
  358. ReportLayout int8 `gorm:"column:report_layout" description:"报告布局,1:常规布局,2:智能布局。默认:1"`
  359. IsPublicPublish int8 `gorm:"column:is_public_publish" description:"是否公开发布,1:是,2:否"`
  360. ReportCreateTime time.Time `gorm:"column:report_create_time" description:"报告时间创建时间"`
  361. }
  362. func GetReportById(reportId int) (item *ReportDetail, err error) {
  363. //o := orm.NewOrmUsingDB("rddp")
  364. sql := `SELECT * FROM report WHERE id=?`
  365. //err = o.Raw(sql, reportId).QueryRow(&item)
  366. err = global.DmSQL["rddp"].Raw(sql, reportId).First(&item).Error
  367. return
  368. }
  369. func GetReportByIds(reportIds string) (list []*ReportDetail, err error) {
  370. //o := orm.NewOrmUsingDB("rddp")
  371. sql := `SELECT * FROM report WHERE id in ` + reportIds
  372. //_, err = o.Raw(sql).QueryRows(&list)
  373. err = global.DmSQL["rddp"].Raw(sql).Find(&list).Error
  374. return
  375. }
  376. // GetSimpleReportByIds 根据报告ID查询报告基本信息
  377. func GetSimpleReportByIds(reportIds []int) (list []*Report, err error) {
  378. if len(reportIds) == 0 {
  379. return
  380. }
  381. //o := orm.NewOrmUsingDB("rddp")
  382. sql := `SELECT id, title, report_code FROM report WHERE id IN (` + utils.GetOrmInReplace(len(reportIds)) + `)`
  383. //_, err = o.Raw(sql, reportIds).QueryRows(&list)
  384. err = global.DmSQL["rddp"].Raw(sql, reportIds).Find(&list).Error
  385. return
  386. }
  387. // GetReportStage
  388. // @Description: 获取报告的最大期数(每一年的最大期数)
  389. // @author: Roc
  390. // @datetime 2024-06-03 17:44:14
  391. // @param classifyIdFirst int
  392. // @param classifyIdSecond int
  393. // @param classifyIdThird int
  394. // @return count int
  395. // @return err error
  396. func GetReportStage(classifyIdFirst, classifyIdSecond, classifyIdThird int) (count int, err error) {
  397. //o := orm.NewOrmUsingDB("rddp")
  398. classifyId := classifyIdThird
  399. if classifyId <= 0 {
  400. classifyId = classifyIdSecond
  401. }
  402. if classifyId <= 0 {
  403. classifyId = classifyIdFirst
  404. }
  405. if classifyId <= 0 {
  406. err = errors.New("错误的分类id")
  407. return
  408. }
  409. yearStart := time.Date(time.Now().Local().Year(), 1, 1, 0, 0, 0, 0, time.Local)
  410. sql := `SELECT MAX(stage) AS max_stage FROM report WHERE create_time > ? `
  411. if classifyIdThird > 0 {
  412. sql += " AND classify_id_third = ? "
  413. } else if classifyIdSecond > 0 {
  414. sql += " AND classify_id_second = ? "
  415. } else {
  416. sql += " AND classify_id_first = ? "
  417. }
  418. //o.Raw(sql, yearStart, classifyId).QueryRow(&count)
  419. err = global.DmSQL["rddp"].Raw(sql, yearStart, classifyId).Scan(&count).Error
  420. return
  421. }
  422. // GetReportStageEdit
  423. // @Description: 获取报告的最大期数(每一年的最大期数)
  424. // @author: Roc
  425. // @datetime 2024-06-04 13:50:34
  426. // @param classifyIdFirst int
  427. // @param classifyIdSecond int
  428. // @param classifyIdThird int
  429. // @param reportId int
  430. // @return count int
  431. // @return err error
  432. func GetReportStageEdit(classifyIdFirst, classifyIdSecond, classifyIdThird, reportId int) (count int, err error) {
  433. classifyId := classifyIdThird
  434. if classifyId <= 0 {
  435. classifyId = classifyIdSecond
  436. }
  437. if classifyId <= 0 {
  438. classifyId = classifyIdFirst
  439. }
  440. if classifyId <= 0 {
  441. err = errors.New("错误的分类id")
  442. return
  443. }
  444. yearStart := time.Date(time.Now().Local().Year(), 1, 1, 0, 0, 0, 0, time.Local)
  445. sql := `SELECT MAX(stage) AS max_stage FROM report WHERE create_time > ? AND id<>? `
  446. if classifyIdThird > 0 {
  447. sql += " AND classify_id_third = ? "
  448. } else if classifyIdSecond > 0 {
  449. sql += " AND classify_id_second = ? "
  450. } else {
  451. sql = " AND classify_id_first = ? "
  452. }
  453. //o := orm.NewOrmUsingDB("rddp")
  454. //o.Raw(sql, yearStart, reportId, classifyId).QueryRow(&count)
  455. err = global.DmSQL["rddp"].Raw(sql, yearStart, reportId, classifyId).Scan(&count).Error
  456. return
  457. }
  458. type PublishReq struct {
  459. ReportIds string `description:"报告id,多个用英文逗号隔开"`
  460. ReportUrl string `description:"报告Url"`
  461. }
  462. type PublishCancelReq struct {
  463. ReportIds int `description:"报告id"`
  464. }
  465. type DeleteReq struct {
  466. ReportIds int `description:"报告id"`
  467. }
  468. type AddReq struct {
  469. AddType int `description:"新增方式:1:新增报告,2:继承报告"`
  470. ClassifyIdFirst int `description:"一级分类id"`
  471. ClassifyNameFirst string `description:"一级分类名称"`
  472. ClassifyIdSecond int `description:"二级分类id"`
  473. ClassifyNameSecond string `description:"二级分类名称"`
  474. ClassifyIdThird int `description:"三级分类id"`
  475. ClassifyNameThird string `description:"三级分类名称"`
  476. Title string `description:"标题"`
  477. Abstract string `description:"摘要"`
  478. Author string `description:"作者"`
  479. Frequency string `description:"频度"`
  480. State int `description:"状态:1:未发布,2:已发布"`
  481. Content string `description:"内容"`
  482. CreateTime string `description:"创建时间"`
  483. ReportVersion int `description:"1:旧版,2:新版"`
  484. ContentStruct string `description:"内容组件"`
  485. HeadImg string `description:"报告头图地址"`
  486. EndImg string `description:"报告尾图地址"`
  487. CanvasColor string `description:"画布颜色"`
  488. NeedSplice int `description:"是否拼接版头版位的标记,主要是为了兼容历史报告。0-不需要 1-需要"`
  489. HeadResourceId int `description:"版头资源ID"`
  490. EndResourceId int `description:"版尾资源ID"`
  491. CollaborateType int8 `description:"协作方式,1:个人,2:多人协作。默认:1"`
  492. ReportLayout int8 `description:"报告布局,1:常规布局,2:智能布局。默认:1"`
  493. IsPublicPublish int8 `description:"是否公开发布,1:是,2:否"`
  494. InheritReportId int `description:"待继承的报告ID"`
  495. GrantAdminIdList []int `description:"授权用户id列表"`
  496. }
  497. type PrePublishReq struct {
  498. ReportId int `description:"报告id"`
  499. PrePublishTime string `description:"预发布时间"`
  500. PreMsgSend int `description:"定时发布成功后是否立即推送模版消息:0否,1是"`
  501. ReportUrl string `description:"报告Url"`
  502. }
  503. type AddResp struct {
  504. ReportId int64 `description:"报告id"`
  505. ReportCode string `description:"报告code"`
  506. }
  507. func AddReport(item *Report) (lastId int64, err error) {
  508. o := orm.NewOrmUsingDB("rddp")
  509. lastId, err = o.Insert(item)
  510. return
  511. }
  512. type EditReq struct {
  513. ReportId int64 `description:"报告id"`
  514. ClassifyIdFirst int `description:"一级分类id"`
  515. ClassifyNameFirst string `description:"一级分类名称"`
  516. ClassifyIdSecond int `description:"二级分类id"`
  517. ClassifyNameSecond string `description:"二级分类名称"`
  518. ClassifyIdThird int `description:"三级分类id"`
  519. ClassifyNameThird string `description:"三级分类名称"`
  520. Title string `description:"标题"`
  521. Abstract string `description:"摘要"`
  522. Author string `description:"作者"`
  523. Frequency string `description:"频度"`
  524. State int `description:"状态:1:未发布,2:已发布"`
  525. Content string `description:"内容"`
  526. CreateTime string `description:"创建时间"`
  527. ContentStruct string `description:"内容组件"`
  528. HeadImg string `description:"报告头图地址"`
  529. EndImg string `description:"报告尾图地址"`
  530. CanvasColor string `description:"画布颜色"`
  531. NeedSplice int `description:"是否拼接版头版位的标记,主要是为了兼容历史报告。0-不需要 1-需要"`
  532. HeadResourceId int `description:"版头资源ID"`
  533. EndResourceId int `description:"版尾资源ID"`
  534. //CollaborateType int8 `description:"协作方式,1:个人,2:多人协作。默认:1"`
  535. //ReportLayout int8 `description:"报告布局,1:常规布局,2:智能布局。默认:1"`
  536. IsPublicPublish int8 `description:"是否公开发布,1:是,2:否"`
  537. GrantAdminIdList []int `description:"授权用户id列表"`
  538. }
  539. type EditResp struct {
  540. ReportId int64 `description:"报告id"`
  541. ReportCode string `description:"报告code"`
  542. }
  543. func EditReport(item *Report, reportId int64) (err error) {
  544. //o := orm.NewOrmUsingDB("rddp")
  545. sql := `UPDATE report
  546. SET
  547. classify_id_first =?,
  548. classify_name_first = ?,
  549. classify_id_second = ?,
  550. classify_name_second = ?,
  551. title = ?,
  552. abstract = ?,
  553. author = ?,
  554. frequency = ?,
  555. state = ?,
  556. content = ?,
  557. content_sub = ?,
  558. stage =?,
  559. create_time = ?,
  560. modify_time = ?
  561. WHERE id = ? `
  562. //_, err = o.Raw(sql, item.ClassifyIdFirst, item.ClassifyNameFirst, item.ClassifyIdSecond, item.ClassifyNameSecond, item.Title,
  563. // item.Abstract, item.Author, item.Frequency, item.State, item.Content, item.ContentSub, item.Stage, item.CreateTime, time.Now(), reportId).Exec()
  564. err = global.DmSQL["rddp"].Exec(sql, item.ClassifyIdFirst, item.ClassifyNameFirst, item.ClassifyIdSecond, item.ClassifyNameSecond, item.Title,
  565. item.Abstract, item.Author, item.Frequency, item.State, item.Content, item.ContentSub, item.Stage, item.CreateTime, time.Now(), reportId).Error
  566. return
  567. }
  568. func (m *Report) Update(cols []string) (err error) {
  569. //o := orm.NewOrmUsingDB("rddp")
  570. //_, err = o.Update(m, cols...)
  571. err = global.DmSQL["rddp"].Select(cols).Updates(m).Error
  572. return
  573. }
  574. type ReportDetailReq struct {
  575. ReportId int `description:"报告id"`
  576. }
  577. type ClassifyIdDetailReq struct {
  578. ClassifyIdFirst int `description:"报告一级分类id"`
  579. ClassifyIdSecond int `description:"报告二级分类id"`
  580. }
  581. func GetReportDetailByClassifyId(classifyIdFirst, classifyIdSecond int) (item *Report, err error) {
  582. //o := orm.NewOrmUsingDB("rddp")
  583. sql := ` SELECT * FROM report WHERE 1=1 `
  584. if classifyIdSecond > 0 {
  585. sql = sql + ` AND classify_id_second=? ORDER BY stage DESC LIMIT 1`
  586. //err = o.Raw(sql, classifyIdSecond).QueryRow(&item)
  587. err = global.DmSQL["rddp"].Raw(sql, classifyIdSecond).First(&item).Error
  588. } else {
  589. sql = sql + ` AND classify_id_first=? ORDER BY stage DESC LIMIT 1`
  590. //err = o.Raw(sql, classifyIdFirst).QueryRow(&item)
  591. err = global.DmSQL["rddp"].Raw(sql, classifyIdFirst).First(&item).Error
  592. }
  593. return
  594. }
  595. type SendTemplateMsgReq struct {
  596. ReportId int `description:"报告id"`
  597. }
  598. // SendTemplateMsgResp
  599. // @Description: 报告推送返回结构体
  600. type SendTemplateMsgResp struct {
  601. ReportId int `description:"报告id"`
  602. MsgSendTime string `description:"报告推送时间"`
  603. }
  604. func ModifyReportMsgIsSend(reportId int) (err error) {
  605. //o := orm.NewOrmUsingDB("rddp")
  606. report, err := GetReportById(reportId)
  607. if err != nil {
  608. return
  609. }
  610. if report.MsgIsSend == 0 {
  611. sql := `UPDATE report SET msg_is_send = 1, msg_send_time=NOW() WHERE id = ? `
  612. err = global.DmSQL["rddp"].Exec(sql, reportId).Error
  613. //_, err = o.Raw(sql, reportId).Exec()
  614. }
  615. return
  616. }
  617. func ModifyReportVideo(reportId int, videoUrl, videoName, videoSize string, playSeconds float64) (err error) {
  618. //o := orm.NewOrmUsingDB("rddp")
  619. sql := `UPDATE report SET video_url=?,video_name=?,video_play_seconds=?,video_size=? WHERE id=? `
  620. //_, err = o.Raw(sql, videoUrl, videoName, playSeconds, videoSize, reportId).Exec()
  621. err = global.DmSQL["rddp"].Exec(sql, videoUrl, videoName, playSeconds, videoSize, reportId).Error
  622. return
  623. }
  624. // ModifyReportVideoByNoVideo
  625. // @Description: 修改无音频的报告音频信息
  626. // @author: Roc
  627. // @datetime 2024-07-25 18:03:05
  628. // @param reportId int
  629. // @param videoUrl string
  630. // @param videoName string
  631. // @param videoSize string
  632. // @param playSeconds float64
  633. // @return err error
  634. func ModifyReportVideoByNoVideo(reportId int, videoUrl, videoName, videoSize string, playSeconds float64) (err error) {
  635. //o := orm.NewOrmUsingDB("rddp")
  636. sql := `UPDATE report SET video_url=?,video_name=?,video_play_seconds=?,video_size=? WHERE id=? AND video_url=""`
  637. //_, err = o.Raw(sql, videoUrl, videoName, playSeconds, videoSize, reportId).Exec()
  638. err = global.DmSQL["rddp"].Exec(sql, videoUrl, videoName, playSeconds, videoSize, reportId).Error
  639. return
  640. }
  641. type ReportItem struct {
  642. gorm.Model
  643. Id int `gorm:"column:id;primary_key;autoIncrement" description:"报告Id"`
  644. AddType int `gorm:"column:add_type" description:"新增方式:1:新增报告,2:继承报告"`
  645. ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类id"`
  646. ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"`
  647. ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类id"`
  648. ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"`
  649. Title string `gorm:"column:title" description:"标题"`
  650. Abstract string `gorm:"column:abstract" description:"摘要"`
  651. Author string `gorm:"column:author" description:"作者"`
  652. Frequency string `gorm:"column:frequency" description:"频度"`
  653. CreateTime time.Time `gorm:"column:create_time" description:"创建时间"`
  654. ModifyTime time.Time `gorm:"column:modify_time" description:"修改时间"`
  655. State int `gorm:"column:state" description:"1:未发布,2:已发布"`
  656. PublishTime time.Time `gorm:"column:publish_time" description:"发布时间"`
  657. Stage int `gorm:"column:stage" description:"期数"`
  658. MsgIsSend int `gorm:"column:msg_is_send" description:"消息是否已发送,0:否,1:是"`
  659. Content string `gorm:"column:content" description:"内容"`
  660. VideoUrl string `gorm:"column:video_url" description:"音频文件URL"`
  661. VideoName string `gorm:"column:video_name" description:"音频文件名称"`
  662. VideoPlaySeconds string `gorm:"column:video_play_seconds" description:"音频播放时长"`
  663. ContentSub string `gorm:"column:content_sub" description:"内容前两个章节"`
  664. }
  665. func GetReportItemById(reportId int) (item *ReportItem, err error) {
  666. //o := orm.NewOrmUsingDB("rddp")
  667. sql := `SELECT * FROM report WHERE id=?`
  668. //err = o.Raw(sql, reportId).QueryRow(&item)
  669. err = global.DmSQL["rddp"].Raw(sql, reportId).First(&item).Error
  670. return
  671. }
  672. type SaveReportContent struct {
  673. Content string `description:"内容"`
  674. ReportId int `description:"报告id"`
  675. NoChange int `description:"内容是否未改变:1:内容未改变"`
  676. // 以下是智能研报相关
  677. ContentStruct string `description:"内容组件"`
  678. HeadImg string `description:"报告头图地址"`
  679. EndImg string `description:"报告尾图地址"`
  680. CanvasColor string `description:"画布颜色"`
  681. NeedSplice int `description:"是否拼接版头版位的标记,主要是为了兼容历史报告。0-不需要 1-需要"`
  682. HeadResourceId int `description:"版头资源ID"`
  683. EndResourceId int `description:"版尾资源ID"`
  684. }
  685. func EditReportContent(reportId int, content, contentSub string) (err error) {
  686. //o := orm.NewOrmUsingDB("rddp")
  687. sql := ` UPDATE report SET content=?,content_sub=?,modify_time=NOW() WHERE id=? `
  688. //_, err = o.Raw(sql, content, contentSub, reportId).Exec()
  689. err = global.DmSQL["rddp"].Exec(sql, content, contentSub, reportId).Error
  690. return
  691. }
  692. func AddReportSaveLog(reportId, adminId int, content, contentSub, contentStruct, canvasColor, adminName string, headResourceId, endResourceId int) (err error) {
  693. //o := orm.NewOrmUsingDB("rddp")
  694. 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 (?,?,?,?,?,?,?,?,?) `
  695. //_, err = o.Raw(sql, reportId, content, contentSub, contentStruct, canvasColor, headResourceId, endResourceId, adminId, adminName).Exec()
  696. err = global.DmSQL["rddp"].Exec(sql, reportId, content, contentSub, contentStruct, canvasColor, headResourceId, endResourceId, adminId, adminName).Error
  697. return
  698. }
  699. func MultiAddReportChaptersSaveLog(items []*ReportChapter, adminId int, adminRealName string) (err error) {
  700. //o := orm.NewOrmUsingDB("rddp")
  701. //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()
  702. //if err != nil {
  703. // return
  704. //}
  705. //defer func() {
  706. // _ = p.Close()
  707. //}()
  708. //for _, v := range items {
  709. // _, err = p.Exec(v.ReportId, v.ReportChapterId, v.Content, v.ContentSub, v.ContentStruct, adminId, adminRealName)
  710. // if err != nil {
  711. // return
  712. // }
  713. //}
  714. tx := global.DmSQL["rddp"].Begin()
  715. for _, v := range items {
  716. 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
  717. if err != nil {
  718. tx.Rollback()
  719. return
  720. }
  721. }
  722. tx.Commit()
  723. return
  724. }
  725. type SaveReportContentResp struct {
  726. ReportId int `description:"报告id"`
  727. }
  728. func ModifyReportCode(reportId int64, reportCode string) (err error) {
  729. //o := orm.NewOrmUsingDB("rddp")
  730. sql := `UPDATE report SET report_code=? WHERE id=? `
  731. //_, err = o.Raw(sql, reportCode, reportId).Exec()
  732. err = global.DmSQL["rddp"].Exec(sql, reportCode, reportId).Error
  733. return
  734. }
  735. func ModifyReportThsMsgIsSend(item *ReportDetail) (err error) {
  736. //o := orm.NewOrmUsingDB("rddp")
  737. if item.ThsMsgIsSend == 0 {
  738. sql := `UPDATE report SET ths_msg_is_send = 1 WHERE id = ? `
  739. //_, err = o.Raw(sql, item.Id).Exec()
  740. err = global.DmSQL["rddp"].Exec(sql, item.Id).Error
  741. }
  742. return
  743. }
  744. type ThsSendTemplateMsgReq struct {
  745. ReportId []int `description:"报告id"`
  746. }
  747. type PublishDayWeekReportReq struct {
  748. ReportId int `description:"报告ID"`
  749. }
  750. // SaveDayWeekReportReq 新增晨报周报请求体
  751. type SaveDayWeekReportReq struct {
  752. ReportId int `description:"报告ID"`
  753. Title string `description:"标题"`
  754. ReportType string `description:"一级分类ID"`
  755. Author string `description:"作者"`
  756. CreateTime string `description:"创建时间"`
  757. }
  758. // GetDayWeekReportStage 获取晨报周报期数
  759. func GetDayWeekReportStage(classifyIdFirst int, yearStart time.Time) (count int, err error) {
  760. //o := orm.NewOrmUsingDB("rddp")
  761. sql := " SELECT MAX(stage) AS max_stage FROM report WHERE classify_id_first = ? AND create_time > ? "
  762. //o.Raw(sql, classifyIdFirst, yearStart).QueryRow(&count)
  763. err = global.DmSQL["rddp"].Raw(sql, classifyIdFirst, yearStart).Scan(&count).Error
  764. return
  765. }
  766. // GetReportByReportId 主键获取报告
  767. func GetReportByReportId(reportId int) (item *Report, err error) {
  768. //o := orm.NewOrmUsingDB("rddp")
  769. sql := `SELECT * FROM report WHERE id = ?`
  770. //err = o.Raw(sql, reportId).QueryRow(&item)
  771. err = global.DmSQL["rddp"].Raw(sql, reportId).First(&item).Error
  772. return
  773. }
  774. // GetReportByOldReportId 根据老报告id主键获取报告
  775. func GetReportByOldReportId(reportId int) (item *Report, err error) {
  776. //o := orm.NewOrmUsingDB("rddp")
  777. sql := `SELECT * FROM report WHERE old_report_id = ?`
  778. //err = o.Raw(sql, reportId).QueryRow(&item)
  779. err = global.DmSQL["rddp"].Raw(sql, reportId).First(&item).Error
  780. return
  781. }
  782. // DeleteDayWeekReportAndChapter 删除晨周报及章节
  783. func DeleteDayWeekReportAndChapter(reportId int) (err error) {
  784. //o := orm.NewOrmUsingDB("rddp")
  785. //to, err := o.Begin()
  786. to := global.DmSQL["rddp"].Begin()
  787. if err != nil {
  788. return
  789. }
  790. defer func() {
  791. if err != nil {
  792. _ = to.Rollback()
  793. } else {
  794. _ = to.Commit()
  795. }
  796. }()
  797. sql := ` DELETE FROM report WHERE id = ? LIMIT 1 `
  798. //if _, err = to.Raw(sql, reportId).Exec(); err != nil {
  799. // return
  800. //}
  801. if err = to.Exec(sql, reportId).Error; err != nil {
  802. return
  803. }
  804. sql = ` DELETE FROM report_chapter WHERE report_id = ? `
  805. //if _, err = to.Raw(sql, reportId).Exec(); err != nil {
  806. // return
  807. //}
  808. if err = to.Exec(sql, reportId).Error; err != nil {
  809. return
  810. }
  811. return
  812. }
  813. // UpdateReport 更新报告
  814. func (reportInfo *Report) UpdateReport(cols []string) (err error) {
  815. //o := orm.NewOrmUsingDB("rddp")
  816. //_, err = o.Update(reportInfo, cols...)
  817. err = global.DmSQL["rddp"].Select(cols).Updates(reportInfo).Error
  818. return
  819. }
  820. // ReportDetailView
  821. // @Description: 晨周报详情
  822. type ReportDetailView struct {
  823. *ReportDetail
  824. ChapterList []*ReportChapter
  825. GrandAdminList []ReportDetailViewAdmin
  826. PermissionList []ReportDetailViewPermission
  827. }
  828. // ReportDetailViewAdmin
  829. // @Description: 报告里面的授权人
  830. type ReportDetailViewAdmin struct {
  831. AdminId int
  832. AdminName string
  833. }
  834. // ReportDetailViewPermission
  835. // @Description: 报告分类关联的品种权限
  836. type ReportDetailViewPermission struct {
  837. PermissionId int
  838. PermissionName string
  839. }
  840. func GetUnPublishDayReport(startTime time.Time, endTime time.Time) (item *Report, err error) {
  841. //o := orm.NewOrmUsingDB("rddp")
  842. sql := ` SELECT
  843. *
  844. FROM
  845. report AS a
  846. WHERE
  847. a.has_chapter = 1
  848. AND a.chapter_type = "day"
  849. AND a.state = 1
  850. AND (
  851. a.create_time BETWEEN ? AND ?
  852. )
  853. ORDER BY
  854. a.create_time DESC
  855. LIMIT 1 `
  856. //err = o.Raw(sql, startTime, endTime).QueryRow(&item)
  857. err = global.DmSQL["rddp"].Raw(sql, startTime, endTime).First(&item).Error
  858. return
  859. }
  860. type ElasticReportDetail struct {
  861. gorm.Model
  862. ReportId int `gorm:"column:report_id;index" description:"报告ID"`
  863. ReportChapterId int `gorm:"column:report_chapter_id" description:"报告章节ID"`
  864. Title string `gorm:"column:title" description:"标题"`
  865. Abstract string `gorm:"column:abstract" description:"摘要"`
  866. BodyContent string `gorm:"column:body_content" description:"内容"`
  867. PublishTime string `gorm:"column:publish_time" description:"发布时间"`
  868. PublishState int `gorm:"column:publish_state" description:"发布状态 1-未发布 2-已发布"`
  869. Author string `gorm:"column:author" description:"作者"`
  870. ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类ID"`
  871. ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"`
  872. ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类ID"`
  873. ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"`
  874. ClassifyId int `gorm:"column:classify_id" description:"最小单元的分类ID"`
  875. ClassifyName string `gorm:"column:classify_name" description:"最小单元的分类名称"`
  876. Categories string `gorm:"column:categories" description:"关联的品种名称(包括品种别名)"`
  877. StageStr string `gorm:"column:stage_str" description:"报告期数"`
  878. }
  879. // GetLastPublishedDayWeekReport 获取上一篇已发布的晨周报
  880. func GetLastPublishDayWeekReport(chapterType string) (item *Report, err error) {
  881. //o := orm.NewOrmUsingDB("rddp")
  882. sql := ` SELECT * FROM report WHERE has_chapter = 1 AND chapter_type = ? AND state = 2 ORDER BY publish_time DESC LIMIT 1 `
  883. //err = o.Raw(sql, chapterType).QueryRow(&item)
  884. err = global.DmSQL["rddp"].Raw(sql, chapterType).First(&item).Error
  885. return
  886. }
  887. // GetNewReportExist
  888. func GetNewReportExist(oldReportId int) (item *Report, err error) {
  889. //o := orm.NewOrmUsingDB("rddp")
  890. sql := ` SELECT id FROM report WHERE old_report_id = ? LIMIT 1 `
  891. //err = o.Raw(sql, oldReportId).QueryRow(&item)
  892. err = global.DmSQL["rddp"].Raw(sql, oldReportId).First(&item).Error
  893. return
  894. }
  895. // PublishReportAndChapter 发布报告及章节
  896. func PublishReportAndChapter(reportInfo *Report, isPublishReport bool, cols []string) (err error) {
  897. //o := orm.NewOrmUsingDB("rddp")
  898. //to, err := o.Begin()
  899. to := global.DmSQL["rddp"].Begin()
  900. if err != nil {
  901. return
  902. }
  903. defer func() {
  904. if err != nil {
  905. _ = to.Rollback()
  906. } else {
  907. _ = to.Commit()
  908. }
  909. }()
  910. // 更新报告
  911. if isPublishReport {
  912. // _, err = to.Update(reportInfo, cols...)
  913. err = to.Select(cols).Updates(reportInfo).Error
  914. if err != nil {
  915. return
  916. }
  917. }
  918. // 发布该报告的所有章节
  919. sql := ` UPDATE report_chapter SET publish_state = 2, publish_time = ? WHERE report_id = ? `
  920. //_, err = to.Raw(sql, reportInfo.PublishTime, reportInfo.Id).Exec()
  921. err = to.Exec(sql, reportInfo.PublishTime, reportInfo.Id).Error
  922. // 发布章节
  923. //if len(publishIds) > 0 {
  924. // sql := ` UPDATE report_chapter SET publish_state = 2, publish_time = ? WHERE report_id = ? AND report_chapter_id IN (` + utils.GetOrmInReplace(len(publishIds)) + `) `
  925. // _, err = to.Raw(sql, reportInfo.PublishTime, reportInfo.Id, publishIds).Exec()
  926. //}
  927. //if len(unPublishIds) > 0 {
  928. // 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)) + `) `
  929. // _, err = to.Raw(sql, reportInfo.Id, unPublishIds).Exec()
  930. //}
  931. return
  932. }
  933. func GetSyncEmptyVideoReport() (list []*Report, err error) {
  934. //o := orm.NewOrmUsingDB("rddp")
  935. sql := ` SELECT id FROM report WHERE old_report_id > 0 AND state = 2 AND chapter_type = "" AND (video_size = "" OR video_play_seconds = "")
  936. UNION ALL
  937. SELECT DISTINCT report_id FROM report_chapter WHERE publish_state = 2 AND (video_size = "" OR video_play_seconds = "") `
  938. //_, err = o.Raw(sql).QueryRows(&list)
  939. err = global.DmSQL["rddp"].Raw(sql).Find(&list).Error
  940. return
  941. }
  942. // PublishReportById 发布报告
  943. func PublishReportById(reportId int, publishTime time.Time, lastModifyAdminId int, lastModifyAdminName string) (err error) {
  944. //o := orm.NewOrmUsingDB("rddp")
  945. 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 = ? `
  946. //_, err = o.Raw(sql, publishTime, lastModifyAdminId, lastModifyAdminName, reportId).Exec()
  947. err = global.DmSQL["rddp"].Exec(sql, publishTime, lastModifyAdminId, lastModifyAdminName, reportId).Error
  948. return
  949. }
  950. // ResetReportById 重置报告状态
  951. func ResetReportById(reportId, state int, lastModifyAdminId int, lastModifyAdminName string) (err error) {
  952. //o := orm.NewOrmUsingDB("rddp")
  953. 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 = ?`
  954. //_, err = o.Raw(sql, state, lastModifyAdminId, lastModifyAdminName, reportId).Exec()
  955. err = global.DmSQL["rddp"].Exec(sql, state, lastModifyAdminId, lastModifyAdminName, reportId).Error
  956. return
  957. }
  958. // GetCommentReportByReportId 查询有留言的报告列表
  959. func GetCommentReportByReportId(condition string, pars []interface{}, startSize, pageSize int) (list []*Report, err error) {
  960. //o := orm.NewOrmUsingDB("rddp")
  961. sql := `SELECT
  962. id,
  963. create_time,
  964. title,
  965. classify_name_first,
  966. classify_id_first,
  967. classify_name_second,
  968. classify_id_second,
  969. state,
  970. IF
  971. ( publish_time, publish_time, create_time ) AS publish_time
  972. FROM
  973. report
  974. WHERE
  975. 1=1
  976. `
  977. if condition != "" {
  978. sql += condition
  979. }
  980. sql += ` ORDER BY publish_time DESC , title ASC LIMIT ?,?`
  981. //_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&list)
  982. err = global.DmSQL["rddp"].Raw(sql, pars, startSize, pageSize).Find(&list).Error
  983. return
  984. }
  985. // GetCommentReportByReportIdOrderBy 查询有留言的报告列表(指定排序)
  986. func GetCommentReportByReportIdOrderBy(condition string, pars []interface{}, startSize, pageSize int, orderBy string) (list []*Report, err error) {
  987. //o := orm.NewOrmUsingDB("rddp")
  988. sql := `SELECT
  989. id,
  990. create_time,
  991. title,
  992. classify_name_first,
  993. classify_id_first,
  994. classify_name_second,
  995. classify_id_second,
  996. state,
  997. IF
  998. ( publish_time, publish_time, create_time ) AS publish_time
  999. FROM
  1000. report
  1001. WHERE
  1002. 1=1
  1003. `
  1004. if condition != "" {
  1005. sql += condition
  1006. }
  1007. if orderBy == `` {
  1008. sql += ` ORDER BY publish_time DESC , title ASC `
  1009. } else {
  1010. sql += orderBy
  1011. }
  1012. sql += ` LIMIT ?,? `
  1013. //_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&list)
  1014. err = global.DmSQL["rddp"].Raw(sql, pars, startSize, pageSize).Find(&list).Error
  1015. return
  1016. }
  1017. // GetCommentReportTotalByReportId 查询有留言的报告列表总数
  1018. func GetCommentReportTotalByReportId(condition string, pars []interface{}) (total int64, err error) {
  1019. //o := orm.NewOrmUsingDB("rddp")
  1020. sql := `SELECT count(*)
  1021. FROM report WHERE 1=1`
  1022. if condition != "" {
  1023. sql += condition
  1024. }
  1025. //err = o.Raw(sql, pars).QueryRow(&total)
  1026. err = global.DmSQL["rddp"].Raw(sql, pars).Scan(&total).Error
  1027. return
  1028. }
  1029. // 点赞相关的报告列表
  1030. type LikeReportItem struct {
  1031. gorm.Model
  1032. ReportId int `gorm:"column:report_id;index" description:"报告Id"`
  1033. ReportChapterId int `gorm:"column:report_chapter_id" description:"报告章节Id"`
  1034. ClassifyIdFirst int `gorm:"column:classify_id_first" description:"一级分类id"`
  1035. ClassifyNameFirst string `gorm:"column:classify_name_first" description:"一级分类名称"`
  1036. ClassifyIdSecond int `gorm:"column:classify_id_second" description:"二级分类id"`
  1037. ClassifyNameSecond string `gorm:"column:classify_name_second" description:"二级分类名称"`
  1038. ReportChapterTypeId int `gorm:"column:report_chapter_type_id" description:"章节类型"`
  1039. ReportChapterTypeName string `gorm:"column:report_chapter_type_name" description:"品种名称"`
  1040. PublishTime time.Time `gorm:"column:publish_time" description:"发布时间"`
  1041. Title string `gorm:"column:title" description:"标题"`
  1042. }
  1043. // GetLikeReportByReportIdReportChapterId 获取有被点赞的报告列表
  1044. func GetLikeReportByReportIdReportChapterId(reportIds string, chapterIds string, orderStr string, startSize, pageSize int) (list []*LikeReportItem, err error) {
  1045. //o := orm.NewOrmUsingDB("rddp")
  1046. sql := `( SELECT
  1047. id AS report_id,
  1048. 0 AS report_chapter_id,
  1049. classify_id_first,
  1050. classify_id_second,
  1051. classify_name_first,
  1052. classify_name_second,
  1053. 0 as report_chapter_type_id,
  1054. "" as report_chapter_type_name,
  1055. publish_time,
  1056. title
  1057. FROM
  1058. report
  1059. WHERE
  1060. classify_name_first != "晨报"
  1061. AND classify_name_first != "周报"
  1062. AND id in (` + reportIds + `)
  1063. )
  1064. UNION
  1065. ( SELECT
  1066. report_id,
  1067. report_chapter_id,
  1068. classify_id_first,
  1069. 0 as classify_id_second,
  1070. classify_name_first,
  1071. null as classify_name_second,
  1072. type_id as report_chapter_type_id,
  1073. type_name as report_chapter_type_name,
  1074. publish_time,
  1075. title
  1076. FROM
  1077. report_chapter
  1078. WHERE
  1079. report_chapter_id in (` + chapterIds + `)
  1080. )`
  1081. if orderStr != "" {
  1082. sql += ` ORDER BY FIELD(CONCAT(report_id, "-",report_chapter_id),` + orderStr + `)`
  1083. } else {
  1084. sql += ` ORDER BY publish_time DESC, report_id Desc`
  1085. }
  1086. sql += ` LIMIT ?,?`
  1087. //_, err = o.Raw(sql, startSize, pageSize).QueryRows(&list)
  1088. err = global.DmSQL["rddp"].Raw(sql, startSize, pageSize).Find(&list).Error
  1089. return
  1090. }
  1091. // GetLikeReportTotalByReportIdReportChapterId 获取有被点赞的报告列表总数
  1092. func GetLikeReportTotalByReportIdReportChapterId(reportIds string, chapterIds string) (total int64, err error) {
  1093. //o := orm.NewOrmUsingDB("rddp")
  1094. sql := `select count(*) from (( SELECT
  1095. id AS report_id,
  1096. 0 AS report_chapter_id,
  1097. classify_id_first,
  1098. classify_id_second,
  1099. classify_name_first,
  1100. classify_name_second,
  1101. 0 as report_chapter_type_id,
  1102. publish_time,
  1103. title
  1104. FROM
  1105. report
  1106. WHERE
  1107. classify_name_first != "晨报"
  1108. AND classify_name_first != "周报"
  1109. AND id in (` + reportIds + `)
  1110. )
  1111. UNION
  1112. ( SELECT
  1113. report_id,
  1114. report_chapter_id,
  1115. classify_id_first,
  1116. 0 as classify_id_second,
  1117. classify_name_first,
  1118. null as classify_name_second,
  1119. type_id as report_chapter_type_id,
  1120. publish_time,
  1121. title
  1122. FROM
  1123. report_chapter
  1124. WHERE
  1125. report_chapter_id in (` + chapterIds + `)
  1126. )) r`
  1127. //err = o.Raw(sql).QueryRow(&total)
  1128. err = global.DmSQL["rddp"].Raw(sql).Scan(&total).Error
  1129. return
  1130. }
  1131. // GetPageReportList 分页获取报告列表
  1132. func GetPageReportList(condition string, pars []interface{}, startSize, pageSize int) (total int, items []*ReportList, err error) {
  1133. //o := orm.NewOrmUsingDB("rddp")
  1134. sql := `SELECT * FROM report WHERE 1=1 `
  1135. sql += condition
  1136. sql += ` ORDER BY modify_time DESC`
  1137. totalSql := `SELECT COUNT(1) total FROM (` + sql + `) z `
  1138. //err = o.Raw(totalSql, pars).QueryRow(&total)
  1139. err = global.DmSQL["rddp"].Raw(totalSql, pars).Scan(&total).Error
  1140. if err != nil {
  1141. return
  1142. }
  1143. sql += ` LIMIT ?,? `
  1144. //_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  1145. err = global.DmSQL["rddp"].Raw(sql, pars, startSize, pageSize).Find(&items).Error
  1146. return
  1147. }
  1148. // SunCodeReq 获取太阳码请求体
  1149. type SunCodeReq struct {
  1150. CodePage string `json:"CodePage" description:"太阳码page"`
  1151. CodeScene string `json:"CodeScene" description:"太阳码scene"`
  1152. }
  1153. // YbPcSuncode 活动海报表
  1154. type YbPcSuncode struct {
  1155. SuncodeID uint32 `gorm:"column:suncode_id" json:"suncodeId"` //`orm:"column(suncode_id);pk" gorm:"primaryKey" `
  1156. Scene string `gorm:"column:scene;type:varchar(255);not null;default:0" json:"scene"` // 微信scene
  1157. SceneMd5 string `gorm:"column:scene_md5;type:varchar(255);not null" json:"sceneMd5"`
  1158. CodePage string `gorm:"column:code_page;type:varchar(255);not null;default:''" json:"codePage"` // 路径
  1159. SuncodeUrl string `gorm:"column:suncode_url;type:varchar(255);not null;default:''" json:"suncodeUrl"` // 太阳码储存地址
  1160. CreateTime time.Time `gorm:"column:create_time;type:timestamp;default:CURRENT_TIMESTAMP" json:"createTime"`
  1161. }
  1162. // GetYbPcSunCode 获取太阳码
  1163. func GetYbPcSunCode(scene, page string) (item *YbPcSuncode, err error) {
  1164. //o := orm.NewOrmUsingDB("weekly")
  1165. sql := `SELECT * FROM yb_pc_suncode WHERE scene = ? AND code_page = ? `
  1166. //err = o.Raw(sql, scene, page).QueryRow(&item)
  1167. err = global.DmSQL["weekly"].Raw(sql, scene, page).First(&item).Error
  1168. return
  1169. }
  1170. func AddYbPcSunCode(item *YbPcSuncode) (err error) {
  1171. //o := orm.NewOrmUsingDB("weekly")
  1172. //_, err = o.Insert(item)
  1173. err = global.DmSQL["weekly"].Create(item).Error
  1174. return
  1175. }
  1176. // YbSuncodePars 小程序太阳码scene参数
  1177. type YbSuncodePars struct {
  1178. ID uint32 `gorm:"column:id" json:"id"` //`orm:"column(id);pk" gorm:"primaryKey" `
  1179. Scene string `gorm:"column:scene;type:varchar(255);not null;default:''" json:"scene"` // scene参数
  1180. SceneKey string `gorm:"column:scene_key;type:varchar(32);not null;default:''" json:"scene_key"` // MD5值
  1181. CreateTime time.Time `gorm:"column:create_time;type:datetime;default:CURRENT_TIMESTAMP" json:"createTime"`
  1182. }
  1183. func AddYbSuncodePars(item *YbSuncodePars) (err error) {
  1184. //o := orm.NewOrmUsingDB("weekly")
  1185. //_, err = o.Insert(item)
  1186. err = global.DmSQL["weekly"].Create(item).Error
  1187. return
  1188. }
  1189. // UpdateReportSecondClassifyNameByClassifyId 更新报告分类名称字段
  1190. func UpdateReportSecondClassifyNameByClassifyId(classifyId int, classifyName string) (err error) {
  1191. //o := orm.NewOrmUsingDB("rddp")
  1192. sql := " UPDATE report SET classify_name_second = ? WHERE classify_id_second = ? "
  1193. //_, err = o.Raw(sql, classifyName, classifyId).Exec()
  1194. err = global.DmSQL["rddp"].Exec(sql, classifyName, classifyId).Error
  1195. return
  1196. }
  1197. // UpdateReportFirstClassifyNameByClassifyId 更新报告分类一级名称字段
  1198. func UpdateReportFirstClassifyNameByClassifyId(classifyId int, classifyName string) (err error) {
  1199. //o := orm.NewOrmUsingDB("rddp")
  1200. sql := " UPDATE report SET classify_name_first = ? WHERE classify_id_first = ? "
  1201. //_, err = o.Raw(sql, classifyName, classifyId).Exec()
  1202. err = global.DmSQL["rddp"].Exec(sql, classifyName, classifyId).Error
  1203. return
  1204. }
  1205. // UpdateReportThirdClassifyNameByClassifyId 更新报告的三级分类名称字段
  1206. func UpdateReportThirdClassifyNameByClassifyId(classifyId int, classifyName string) (err error) {
  1207. //o := orm.NewOrmUsingDB("rddp")
  1208. sql := " UPDATE report SET classify_name_third = ? WHERE classify_id_third = ? "
  1209. //_, err = o.Raw(sql, classifyName, classifyId).Exec()
  1210. err = global.DmSQL["rddp"].Exec(sql, classifyName, classifyId).Error
  1211. return
  1212. }
  1213. // UpdateReportSecondClassifyFirstNameByClassifyId 更新报告二级分类的一级分类名称和id
  1214. func UpdateReportSecondClassifyFirstNameByClassifyId(classifyId, newClassifyId int, classifyName string) (err error) {
  1215. //o := orm.NewOrmUsingDB("rddp")
  1216. sql := " UPDATE report SET classify_name_first = ?, classify_id_first = ? WHERE classify_id_second = ? "
  1217. //_, err = o.Raw(sql, classifyName, newClassifyId, classifyId).Exec()
  1218. err = global.DmSQL["rddp"].Exec(sql, classifyName, newClassifyId, classifyId).Error
  1219. return
  1220. }
  1221. // GetEmptyContentSubPPTReport 获取前两章为空的PPT报告
  1222. func GetEmptyContentSubPPTReport() (list []*Report, err error) {
  1223. sql := `SELECT
  1224. r.id,
  1225. r.content,
  1226. r.content_sub
  1227. FROM
  1228. report AS r
  1229. JOIN ppt_v2 AS p ON r.id = p.report_id
  1230. WHERE
  1231. p.report_id > 0 AND r.content_sub = ""`
  1232. //_, err = orm.NewOrmUsingDB("rddp").Raw(sql).QueryRows(&list)
  1233. err = global.DmSQL["rddp"].Raw(sql).Find(&list).Error
  1234. return
  1235. }
  1236. // ModifyReportAuthor 更改报告作者
  1237. func ModifyReportAuthor(condition string, pars []interface{}, authorName string) (count int, err error) {
  1238. //产品权限
  1239. //oRddp := orm.NewOrmUsingDB("rddp")
  1240. sql := `UPDATE english_report set author = ? WHERE 1=1 `
  1241. if condition != "" {
  1242. sql += condition
  1243. }
  1244. //err = oRddp.Raw(sql, authorName, pars).QueryRow(&count)
  1245. err = global.DmSQL["rddp"].Raw(sql, authorName, pars).Scan(&count).Error
  1246. return
  1247. }
  1248. func UpdateReportPublishTime(reportId int, videoNameDate string) (err error) {
  1249. //o := orm.NewOrmUsingDB("rddp")
  1250. sql1 := ` UPDATE report SET publish_time = NOW() WHERE id = ? `
  1251. //_, err = o.Raw(sql1, reportId).Exec()
  1252. err = global.DmSQL["rddp"].Exec(sql1, reportId).Error
  1253. if err != nil {
  1254. return
  1255. }
  1256. //修改音频标题
  1257. sql2 := ` UPDATE report SET video_name=CONCAT(SUBSTRING_INDEX(video_name,"(",1),"` + videoNameDate + `") WHERE id = ? and (video_name !="" and video_name is not null)`
  1258. //_, err = o.Raw(sql2, reportId).Exec()
  1259. err = global.DmSQL["rddp"].Exec(sql2, reportId).Error
  1260. return
  1261. }
  1262. func UpdateReportChapterPublishTime(reportId int, videoNameDate string) (err error) {
  1263. //o := orm.NewOrmUsingDB("rddp")
  1264. sql1 := ` UPDATE report_chapter SET publish_time = NOW() WHERE report_id = ? `
  1265. //_, err = o.Raw(sql1, reportId).Exec()
  1266. err = global.DmSQL["rddp"].Exec(sql1, reportId).Error
  1267. if err != nil {
  1268. return
  1269. }
  1270. //修改音频标题
  1271. 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)`
  1272. //_, err = o.Raw(sql2, reportId).Exec()
  1273. err = global.DmSQL["rddp"].Exec(sql2, reportId).Error
  1274. return
  1275. }
  1276. // MarkEditReport 标记编辑英文研报的请求数据
  1277. type MarkEditReport struct {
  1278. ReportId int `description:"研报id"`
  1279. ReportChapterId int `description:"研报章节id"`
  1280. Status int `description:"标记状态,1:编辑中,2:查询状态,3:编辑完成"`
  1281. }
  1282. type MarkReportResp struct {
  1283. Status int `description:"状态:0:无人编辑, 1:当前有人在编辑"`
  1284. Msg string `description:"提示信息"`
  1285. Editor string `description:"编辑者姓名"`
  1286. }
  1287. type MarkReportItem struct {
  1288. AdminId int `description:"编辑者ID"`
  1289. Editor string `description:"编辑者姓名"`
  1290. ReportClassifyNameFirst string
  1291. }
  1292. // GetReportByCondition 获取报告
  1293. func GetReportByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string, isPage bool, startSize, pageSize int) (items []*Report, err error) {
  1294. //o := orm.NewOrmUsingDB("rddp")
  1295. fields := `*`
  1296. if len(fieldArr) > 0 {
  1297. fields = strings.Join(fieldArr, ",")
  1298. }
  1299. sql := `SELECT ` + fields + ` FROM report WHERE 1=1 `
  1300. sql += condition
  1301. order := ` ORDER BY modify_time DESC`
  1302. if orderRule != `` {
  1303. order = orderRule
  1304. }
  1305. sql += order
  1306. if isPage {
  1307. sql += ` LIMIT ?,?`
  1308. //_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  1309. err = global.DmSQL["rddp"].Raw(sql, pars, startSize, pageSize).Find(&items).Error
  1310. } else {
  1311. //_, err = o.Raw(sql, pars).QueryRows(&items)
  1312. err = global.DmSQL["rddp"].Raw(sql, pars).Find(&items).Error
  1313. }
  1314. return
  1315. }
  1316. // ModifyReportMsgIsSendV2 更新报告消息状态
  1317. func ModifyReportMsgIsSendV2(reportId int) (err error) {
  1318. //o := orm.NewOrmUsingDB("rddp")
  1319. sql := `UPDATE report SET msg_is_send = 1, ths_msg_is_send = 1, msg_send_time = NOW() WHERE id = ? LIMIT 1`
  1320. //_, err = o.Raw(sql, reportId).Exec()
  1321. err = global.DmSQL["rddp"].Exec(sql, reportId).Error
  1322. return
  1323. }
  1324. // SetPrePublishReportById 设置定时发布
  1325. func SetPrePublishReportById(reportId int, prePublishTime string, preMsgSend int) (err error) {
  1326. //o := orm.NewOrmUsingDB("rddp")
  1327. sql := `UPDATE report SET pre_publish_time=?, pre_msg_send=? WHERE id = ? and state = 1 `
  1328. //_, err = o.Raw(sql, prePublishTime, preMsgSend, reportId).Exec()
  1329. err = global.DmSQL["rddp"].Exec(sql, prePublishTime, preMsgSend, reportId).Error
  1330. return
  1331. }
  1332. // ReportSubmitApproveReq 提交审批请求体
  1333. type ReportSubmitApproveReq struct {
  1334. ReportId int `description:"报告ID"`
  1335. }
  1336. // ReportCancelApproveReq 撤回审批请求体
  1337. type ReportCancelApproveReq struct {
  1338. ReportId int `description:"报告ID"`
  1339. }
  1340. func (m *Report) GetItemById(id int) (item *Report, err error) {
  1341. //o := orm.NewOrmUsingDB("rddp")
  1342. sql := `SELECT * FROM report WHERE id = ? LIMIT 1`
  1343. //err = o.Raw(sql, id).QueryRow(&item)
  1344. err = global.DmSQL["rddp"].Raw(sql, id).First(&item).Error
  1345. return
  1346. }
  1347. // GetReportStateCount 获取指定状态的报告数量
  1348. func GetReportStateCount(state int) (count int, err error) {
  1349. //o := orm.NewOrmUsingDB("rddp")
  1350. sql := `SELECT COUNT(1) AS count FROM report WHERE state = ?`
  1351. //err = o.Raw(sql, state).QueryRow(&count)
  1352. err = global.DmSQL["rddp"].Raw(sql, state).Scan(&count).Error
  1353. return
  1354. }
  1355. // UpdateReportsStateByCond 批量更新报告状态
  1356. func UpdateReportsStateByCond(classifyFirstId, classifySecondId, classifyThirdId, oldState, newState int) (err error) {
  1357. //o := orm.NewOrmUsingDB("rddp")
  1358. cond := ``
  1359. if classifyFirstId > 0 {
  1360. cond += fmt.Sprintf(` AND classify_id_first = %d`, classifyFirstId)
  1361. }
  1362. if classifySecondId > 0 {
  1363. cond += fmt.Sprintf(` AND classify_id_second = %d`, classifySecondId)
  1364. }
  1365. if classifyThirdId > 0 {
  1366. cond += fmt.Sprintf(` AND classify_id_third = %d`, classifyThirdId)
  1367. }
  1368. sql := fmt.Sprintf(`UPDATE report SET state = ?, pre_publish_time = NULL WHERE state = ? %s`, cond)
  1369. //_, err = o.Raw(sql, newState, oldState).Exec()
  1370. err = global.DmSQL["rddp"].Exec(sql, newState, oldState).Error
  1371. return
  1372. }
  1373. // UpdateReportsStateBySecondIds 批量更新二级分类报告状态
  1374. func UpdateReportsStateBySecondIds(oldState, newState int, secondIds []int) (err error) {
  1375. if len(secondIds) <= 0 {
  1376. return
  1377. }
  1378. //o := orm.NewOrmUsingDB("rddp")
  1379. // (有审批流的)未发布->待提交
  1380. sql := fmt.Sprintf(`UPDATE report SET state = ?, pre_publish_time = NULL WHERE state = ? AND classify_id_second IN (%s)`, utils.GetOrmInReplace(len(secondIds)))
  1381. //_, err = o.Raw(sql, newState, oldState, secondIds).Exec()
  1382. err = global.DmSQL["rddp"].Exec(sql, newState, oldState, secondIds).Error
  1383. if err != nil {
  1384. return
  1385. }
  1386. // (无审批流的)待提交->未发布
  1387. sql = fmt.Sprintf(`UPDATE report SET state = ?, pre_publish_time = NULL WHERE state = ? AND classify_id_second NOT IN (%s)`, utils.GetOrmInReplace(len(secondIds)))
  1388. //_, err = o.Raw(sql, oldState, newState, secondIds).Exec()
  1389. err = global.DmSQL["rddp"].Exec(sql, oldState, newState, secondIds).Error
  1390. return
  1391. }
  1392. // GetReportPdfUrlReq 获取报告pdf地址请求体
  1393. type GetReportPdfUrlReq struct {
  1394. ReportUrl string `description:"报告Url"`
  1395. ReportCode string `description:"报告Code"`
  1396. Type int `description:"类型 1-pdf 2-图片"`
  1397. }
  1398. func ModifyReportPdfUrl(reportId int, detailPdfUrl string) (err error) {
  1399. //o := orm.NewOrmUsingDB("rddp")
  1400. sql := `UPDATE report SET detail_pdf_url=? WHERE id=? `
  1401. //_, err = o.Raw(sql, detailPdfUrl, reportId).Exec()
  1402. err = global.DmSQL["rddp"].Exec(sql, detailPdfUrl, reportId).Error
  1403. return
  1404. }
  1405. func ModifyReportImgUrl(reportId int, detailImgUrl string) (err error) {
  1406. //o := orm.NewOrmUsingDB("rddp")
  1407. sql := `UPDATE report SET detail_img_url=? WHERE id=? `
  1408. //_, err = o.Raw(sql, detailImgUrl, reportId).Exec()
  1409. err = global.DmSQL["rddp"].Exec(sql, detailImgUrl, reportId).Error
  1410. return
  1411. }
  1412. // UpdatePdfUrlReportById 清空pdf相关字段
  1413. func UpdatePdfUrlReportById(reportId int) (err error) {
  1414. //o := orm.NewOrmUsingDB("rddp")
  1415. sql := `UPDATE report SET detail_img_url = '',detail_pdf_url='',modify_time=NOW() WHERE id = ? `
  1416. //_, err = o.Raw(sql, reportId).Exec()
  1417. err = global.DmSQL["rddp"].Exec(sql, reportId).Error
  1418. return
  1419. }
  1420. // InsertMultiReport
  1421. // @Description: 批量新增报告
  1422. // @author: Roc
  1423. // @datetime 2024-06-27 15:55:25
  1424. // @param items []*Report
  1425. // @return err error
  1426. func InsertMultiReport(items []*Report) (err error) {
  1427. //o := orm.NewOrmUsingDB("rddp")
  1428. //_, err = o.InsertMulti(500, items)
  1429. err = global.DmSQL["rddp"].CreateInBatches(items, utils.MultiAddNum).Error
  1430. return
  1431. }
  1432. // ReportLayout
  1433. // @Description: 报告布局
  1434. type ReportLayout struct {
  1435. Id int `gorm:"column:id;primaryKey"`
  1436. ReportLayout int8 `gorm:"column:report_layout"` //`description:"报告布局,1:常规布局,2:智能布局。默认:1"`
  1437. }
  1438. // GetReportLayoutByReportId
  1439. // @Description: 根据报告id获取报告的布局
  1440. // @author: Roc
  1441. // @datetime 2024-07-15 15:27:05
  1442. // @param reportId int
  1443. // @return item ReportLayout
  1444. // @return err error
  1445. func GetReportLayoutByReportId(reportId int) (item ReportLayout, err error) {
  1446. //o := orm.NewOrmUsingDB("rddp")
  1447. sql := `SELECT id, report_layout FROM report WHERE id = ? `
  1448. //err = o.Raw(sql, reportId).QueryRow(&item)
  1449. err = global.DmSQL["rddp"].Raw(sql, reportId).First(&item).Error
  1450. return
  1451. }
  1452. func GetReportFieldsByIds(ids []int, fields []string) (items []*Report, err error) {
  1453. if len(ids) == 0 {
  1454. return
  1455. }
  1456. //o := orm.NewOrmUsingDB("rddp")
  1457. field := " * "
  1458. if len(fields) > 0 {
  1459. field = fmt.Sprintf(" %s ", strings.Join(fields, ","))
  1460. }
  1461. sql := fmt.Sprintf(`SELECT %s FROM report WHERE id IN (%s)`, field, utils.GetOrmInReplace(len(ids)))
  1462. //_, err = o.Raw(sql, ids).QueryRows(&items)
  1463. err = global.DmSQL["rddp"].Raw(sql, ids).Find(&items).Error
  1464. return
  1465. }