sys_message_report.go 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899
  1. package models
  2. import (
  3. "time"
  4. "github.com/beego/beego/v2/client/orm"
  5. )
  6. type SysMessageReport struct {
  7. SysMessageReportId int `orm:"pk" description:"消息id"`
  8. UserId int `description:"到期用户id"`
  9. ReceiveSysUserId int `description:"接收系统用户id"`
  10. MessageType int `description:"消息类型"`
  11. Content string `description:"内容"`
  12. Remark string `description:"备注"`
  13. IsRead bool `description:"是否已读"`
  14. CreateTime time.Time `description:"创建时间"`
  15. ModifyTime time.Time `description:"修改时间"`
  16. }
  17. type SysMessageReportView struct {
  18. SysMessageReportId int `orm:"pk" description:"消息id"`
  19. UserId int `description:"到期用户id"`
  20. ReceiveSysUserId int `description:"接收系统用户id"`
  21. MessageType int `description:"消息类型"`
  22. Content string `description:"内容"`
  23. Remark string `description:"备注"`
  24. IsRead bool `description:"是否已读"`
  25. CreateTime string `description:"创建时间"`
  26. ModifyTime string `description:"修改时间"`
  27. }
  28. func (s *SysMessageReport) Update(cols []string) (err error) {
  29. o := orm.NewOrm()
  30. _, err = o.Update(s, cols...)
  31. return
  32. }
  33. func UpdateReadSysMessageReportByUserId(userId int) (err error) {
  34. o := orm.NewOrm()
  35. sql := `UPDATE sys_message_report SET is_read=1 WHERE receive_sys_user_id=? AND is_read=0`
  36. _, err = o.Raw(sql, userId).Exec()
  37. return
  38. }
  39. func GetSysMessageReportCountBySysUserId(sysUserId int) (count int, err error) {
  40. o := orm.NewOrm()
  41. sql := `SELECT COUNT(*) AS count FROM sys_message_report WHERE receive_sys_user_id=?`
  42. err = o.Raw(sql, sysUserId).QueryRow(&count)
  43. return
  44. }
  45. func GetSysMessageReportBySysUserId(sysUserId, startSize, pageSize int) (item []*SysMessageReport, err error) {
  46. o := orm.NewOrm()
  47. sql := `SELECT * FROM sys_message_report WHERE receive_sys_user_id=? ORDER BY is_read ASC, create_time DESC LIMIT ?,?`
  48. _, err = o.Raw(sql, sysUserId, startSize, pageSize).QueryRows(&item)
  49. return
  50. }
  51. func InsertMultiSysMessageReport(sysMessageReportList []*SysMessageReport) (err error) {
  52. o := orm.NewOrm()
  53. _, err = o.InsertMulti(500, sysMessageReportList)
  54. return
  55. }
  56. func GetSysMessageReportListById(sysMessageReportIds []int) (items []*SysMessageReport, err error) {
  57. o := orm.NewOrm()
  58. _, err = o.QueryTable(&SysMessageReport{}).
  59. Filter("sys_message_report_id__in", sysMessageReportIds).
  60. All(&items)
  61. return
  62. }
  63. func GetSysMessageReportCount(sysUserId, userId, messageType int) (count int, err error) {
  64. o := orm.NewOrm()
  65. sql := `SELECT COUNT(*) AS count FROM sys_message_report WHERE user_id=? AND message_type=? `
  66. err = o.Raw(sql, userId, messageType).QueryRow(&count)
  67. return
  68. }
  69. func GetSysMessageReportByCondition(condition string, pars []interface{}) (items []*SysMessageReport, err error) {
  70. o := orm.NewOrm()
  71. sql := `SELECT * FROM sys_message_report WHERE 1=1`
  72. if condition != "" {
  73. sql += condition
  74. }
  75. _, err = o.Raw(sql, pars...).QueryRows(&items)
  76. return
  77. }
  78. func GetSysMessageReportCountByCondition(condition string, pars []interface{}) (count int, err error) {
  79. o := orm.NewOrm()
  80. sql := `SELECT COUNT(*) AS count FROM sys_message_report `
  81. if condition != "" {
  82. sql += condition
  83. }
  84. err = o.Raw(sql, pars...).QueryRow(&count)
  85. return
  86. }