outside_report.go 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101
  1. // @Author gmy 2024/9/19 14:53:00
  2. package document_manage_model
  3. import (
  4. "github.com/beego/beego/v2/client/orm"
  5. "github.com/rdlucklib/rdluck_tools/paging"
  6. )
  7. type OutsideReport struct {
  8. OutsideReportId int `orm:"column(outside_report_id);pk" description:"外部报告ID"`
  9. Source int `orm:"column(source)" description:"来源,1:ETA系统录入;2:API接口录入;3:邮件监听录入"`
  10. Title string `orm:"column(title)" description:"报告标题"`
  11. Abstract string `orm:"column(abstract)" description:"摘要"`
  12. ClassifyId int `orm:"column(classify_id)" description:"所属分类id"`
  13. ClassifyName string `orm:"column(classify_name)" description:"所属分类名称(整个分类链条)"`
  14. Content string `orm:"column(content)" description:"报告富文本内容"`
  15. SysUserId int `orm:"column(sys_user_id)" description:"创建人id"`
  16. SysUserName string `orm:"column(sys_user_name)" description:"创建人姓名"`
  17. EmailMessageUid int `orm:"column(email_message_uid)" description:"该邮件在邮箱中的唯一id"`
  18. ReportUpdateTime string `orm:"column(report_update_time)" description:"报告更新时间,如果来源于邮件,那么取邮件的收件时间"`
  19. ModifyTime string `orm:"column(modify_time)" description:"最近一次修改时间"`
  20. CreateTime string `orm:"column(create_time)" description:"创建时间"`
  21. }
  22. type OutsideReportPage struct {
  23. List []OutsideReport `description:"报告列表"`
  24. Paging *paging.PagingItem `description:"分页数据"`
  25. }
  26. type OutsideReportBO struct {
  27. OutsideReportId int `orm:"column(outside_report_id);pk" description:"外部报告ID"`
  28. Source int `orm:"column(source)" description:"来源,1:ETA系统录入;2:API接口录入;3:邮件监听录入"`
  29. Title string `orm:"column(title)" description:"报告标题"`
  30. Abstract string `orm:"column(abstract)" description:"摘要"`
  31. ClassifyId int `orm:"column(classify_id)" description:"所属分类id"`
  32. ClassifyName string `orm:"column(classify_name)" description:"所属分类名称(整个分类链条)"`
  33. Content string `orm:"column(content)" description:"报告富文本内容"`
  34. SysUserId int `orm:"column(sys_user_id)" description:"创建人id"`
  35. SysUserName string `orm:"column(sys_user_name)" description:"创建人姓名"`
  36. AttachmentList []*OutsideReportAttachment
  37. }
  38. // 在 init 函数中注册模型
  39. func init() {
  40. orm.RegisterModel(new(OutsideReport))
  41. }
  42. // GetOutsideReportListByConditionCount 根据条件查询列表条数
  43. func GetOutsideReportListByConditionCount(condition string, pars []interface{}) (count int, err error) {
  44. o := orm.NewOrmUsingDB("rddp")
  45. sql := `select count(distinct t1.outside_report_id) from outside_report t1 left join chart_permission_search_key_word_mapping t2 on t1.classify_id = t2.classify_id where 1 = 1 `
  46. sql += condition
  47. err = o.Raw(sql, pars).QueryRow(&count)
  48. if err != nil {
  49. return 0, err
  50. }
  51. return count, err
  52. }
  53. // GetOutsideReportListByCondition 根据条件查询列表
  54. func GetOutsideReportListByCondition(condition string, pars []interface{}, currentIndex int, pageSize int) (list []OutsideReport, err error) {
  55. o := orm.NewOrmUsingDB("rddp")
  56. sql := `select distinct t1.* from outside_report t1 left join chart_permission_search_key_word_mapping t2 on t1.classify_id = t2.classify_id where 1 = 1 `
  57. sql += condition
  58. sql += ` limit ?, ?`
  59. _, err = o.Raw(sql, pars, (currentIndex-1)*pageSize, pageSize).QueryRows(&list)
  60. if err != nil {
  61. return nil, err
  62. }
  63. return list, err
  64. }
  65. // SaveOutsideReport 保存报告
  66. func SaveOutsideReport(outsideReport OutsideReport) (id int64, err error) {
  67. o := orm.NewOrmUsingDB("rddp")
  68. id, err = o.Insert(&outsideReport)
  69. return
  70. }
  71. // GetOutsideReportById 根据ID获取报告
  72. func GetOutsideReportById(id int) (outsideReport *OutsideReport, err error) {
  73. o := orm.NewOrmUsingDB("rddp")
  74. err = o.QueryTable("outside_report").Filter("outside_report_id", id).One(&outsideReport)
  75. return
  76. }
  77. // UpdateOutsideReport 更新报告
  78. func UpdateOutsideReport(outsideReport *OutsideReport) (err error) {
  79. o := orm.NewOrmUsingDB("rddp")
  80. _, err = o.Update(&outsideReport)
  81. return
  82. }
  83. // DeleteOutsideReport 删除报告
  84. func DeleteOutsideReport(id int) (err error) {
  85. o := orm.NewOrmUsingDB("rddp")
  86. _, err = o.QueryTable("outside_report").Filter("outside_report_id", id).Delete()
  87. return
  88. }