sys_company_dao.go 2.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697
  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 SysCompanyDao struct {
  11. base.BaseDao
  12. }
  13. // Page 查询公司管理分页数据
  14. func (this SysCompanyDao) Page(query *req.SysCompanyQuery) (*[]model.SysCompany, int64) {
  15. sysCompany := make([]model.SysCompany, 0)
  16. session := this.GetSession().Table(model.SysCompany{}.TableName())
  17. if query.Id > 0 {
  18. session.And("id = ?", query.Id)
  19. }
  20. if !gotool.StrUtils.HasEmpty(query.Label) {
  21. session.And("label = ?", query.Label)
  22. }
  23. if query.UserId > 0 {
  24. session.And("user_id = ?", query.UserId)
  25. }
  26. if query.IsTip > 0 {
  27. session.And("is_tip = ?", query.IsTip)
  28. }
  29. if query.IsPay > 0 {
  30. session.And("is_pay = ?", query.IsPay)
  31. }
  32. if query.Status > 0 {
  33. session.And("status = ?", query.Status)
  34. }
  35. if !gotool.StrUtils.HasEmpty(query.CreateBy) {
  36. session.And("create_by = ?", query.CreateBy)
  37. }
  38. if !gotool.StrUtils.HasEmpty(query.UpdateBy) {
  39. session.And("update_by = ?", query.UpdateBy)
  40. }
  41. if !gotool.StrUtils.HasEmpty(query.BeginTime) {
  42. session.And("date_format(u.create_time,'%y%m%d') >= date_format(?,'%y%m%d')", query.BeginTime)
  43. }
  44. if !gotool.StrUtils.HasEmpty(query.EndTime) {
  45. session.And("date_format(u.create_time,'%y%m%d') <= date_format(?,'%y%m%d')", query.EndTime)
  46. }
  47. total, err := session.Limit(query.PageSize, page.StartSize(query.PageNum, query.PageSize)).FindAndCount(&sysCompany)
  48. if err != nil {
  49. frame.Throw(frame.SQL_CODE, "数据查询错误"+err.Error())
  50. }
  51. return &sysCompany, total
  52. }
  53. // List 查询公司管理分页数据
  54. func (this SysCompanyDao) List(query *req.SysCompanyQuery, list interface{}) {
  55. session := this.GetSession().Table(model.SysCompany{}.TableName())
  56. if query.Id > 0 {
  57. session.And("id = ?", query.Id)
  58. }
  59. if !gotool.StrUtils.HasEmpty(query.Label) {
  60. session.And("label = ?", query.Label)
  61. }
  62. if query.UserId > 0 {
  63. session.And("user_id = ?", query.UserId)
  64. }
  65. if query.IsTip > 0 {
  66. session.And("is_tip = ?", query.IsTip)
  67. }
  68. if query.IsPay > 0 {
  69. session.And("is_pay = ?", query.IsPay)
  70. }
  71. if query.Status > 0 {
  72. session.And("status = ?", query.Status)
  73. }
  74. if !gotool.StrUtils.HasEmpty(query.CreateBy) {
  75. session.And("create_by = ?", query.CreateBy)
  76. }
  77. if !gotool.StrUtils.HasEmpty(query.UpdateBy) {
  78. session.And("update_by = ?", query.UpdateBy)
  79. }
  80. if !gotool.StrUtils.HasEmpty(query.BeginTime) {
  81. session.And("date_format(u.create_time,'%y%m%d') >= date_format(?,'%y%m%d')", query.BeginTime)
  82. }
  83. if !gotool.StrUtils.HasEmpty(query.EndTime) {
  84. session.And("date_format(u.create_time,'%y%m%d') <= date_format(?,'%y%m%d')", query.EndTime)
  85. }
  86. err := session.Find(list)
  87. if err != nil {
  88. frame.Throw(frame.SQL_CODE, "数据查询错误"+err.Error())
  89. }
  90. }