sms_dao.go 2.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980
  1. package dao
  2. import (
  3. "github.com/druidcaesa/gotool"
  4. "ulink-admin/frame"
  5. "ulink-admin/modules/system/models/model"
  6. "ulink-admin/modules/system/models/req"
  7. "ulink-admin/pkg/base"
  8. "ulink-admin/pkg/page"
  9. )
  10. type SmsDao struct {
  11. base.BaseDao
  12. }
  13. // Page 查询短信管理分页数据
  14. func (this SmsDao) Page(query *req.SmsQuery, list interface{}) int64 {
  15. session := this.GetSession().Table(model.Sms{}.TableName())
  16. if query.Id > 0 {
  17. session.And("id = ?", query.Id)
  18. }
  19. if !gotool.StrUtils.HasEmpty(query.Code) {
  20. session.And("code = ?", query.Code)
  21. }
  22. if !gotool.StrUtils.HasEmpty(query.Phone) {
  23. session.And("phone = ?", query.Phone)
  24. }
  25. if query.State > 0 {
  26. session.And("state = ?", query.State)
  27. }
  28. if !gotool.StrUtils.HasEmpty(query.Mode) {
  29. session.And("mode = ?", query.Mode)
  30. }
  31. if !gotool.StrUtils.HasEmpty(query.BeginTime) {
  32. session.And("date_format(u.create_time,'%y%m%d') >= date_format(?,'%y%m%d')", query.BeginTime)
  33. }
  34. if !gotool.StrUtils.HasEmpty(query.EndTime) {
  35. session.And("date_format(u.create_time,'%y%m%d') <= date_format(?,'%y%m%d')", query.EndTime)
  36. }
  37. /* total, _ := page.GetTotal(session.Clone())*/
  38. session.Desc("id")
  39. total, err := session.Limit(query.PageSize, page.StartSize(query.PageNum, query.PageSize)).FindAndCount(list)
  40. if err != nil {
  41. frame.Throw(frame.SQL_CODE, "数据查询错误"+err.Error())
  42. }
  43. return total
  44. }
  45. // List 查询短信管理分页数据
  46. func (this SmsDao) List(query *req.SmsQuery, list interface{}) {
  47. session := this.GetSession().Table(model.Sms{}.TableName())
  48. if query.Id > 0 {
  49. session.And("id = ?", query.Id)
  50. }
  51. if !gotool.StrUtils.HasEmpty(query.Code) {
  52. session.And("code = ?", query.Code)
  53. }
  54. if !gotool.StrUtils.HasEmpty(query.Phone) {
  55. session.And("phone = ?", query.Phone)
  56. }
  57. if query.State > 0 {
  58. session.And("state = ?", query.State)
  59. }
  60. if !gotool.StrUtils.HasEmpty(query.Mode) {
  61. session.And("mode = ?", query.Mode)
  62. }
  63. if !gotool.StrUtils.HasEmpty(query.BeginTime) {
  64. session.And("date_format(u.create_time,'%y%m%d') >= date_format(?,'%y%m%d')", query.BeginTime)
  65. }
  66. if !gotool.StrUtils.HasEmpty(query.EndTime) {
  67. session.And("date_format(u.create_time,'%y%m%d') <= date_format(?,'%y%m%d')", query.EndTime)
  68. }
  69. session.Desc("id")
  70. err := session.Find(list)
  71. if err != nil {
  72. frame.Throw(frame.SQL_CODE, "数据查询错误"+err.Error())
  73. }
  74. }