run_dao.go 4.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144
  1. package dao
  2. import (
  3. "github.com/druidcaesa/gotool"
  4. "ulink-admin/frame"
  5. "ulink-admin/modules/car/models/model"
  6. "ulink-admin/modules/car/models/req"
  7. "ulink-admin/pkg/base"
  8. "ulink-admin/pkg/page"
  9. )
  10. type RunDao struct {
  11. base.BaseDao
  12. }
  13. // Page 查询营运记录分页数据
  14. func (this RunDao) Page(query *req.RunQuery) (*[]model.Run, int64) {
  15. run := make([]model.Run, 0)
  16. session := this.GetSession().Table(model.Run{}.TableName())
  17. if query.Id > 0 {
  18. session.And("id = ?", query.Id)
  19. }
  20. if !gotool.StrUtils.HasEmpty(query.ServiceNo) {
  21. session.And("service_no = ?", query.ServiceNo)
  22. }
  23. if !gotool.StrUtils.HasEmpty(query.Card) {
  24. session.And("card = ?", query.Card)
  25. }
  26. if !gotool.StrUtils.HasEmpty(query.Driver) {
  27. session.And("driver = ?", query.Driver)
  28. }
  29. if !gotool.StrUtils.HasEmpty(query.IdCard) {
  30. session.And("id_card = ?", query.IdCard)
  31. }
  32. if query.CompanyId > 0 {
  33. session.And("company_id = ?", query.CompanyId)
  34. }
  35. if !gotool.StrUtils.HasEmpty(query.CarNo) {
  36. session.And("car_no = ?", query.CarNo)
  37. }
  38. if !gotool.StrUtils.HasEmpty(query.Address) {
  39. session.And("address = ?", query.Address)
  40. }
  41. if !gotool.StrUtils.HasEmpty(query.ViolationDate) {
  42. session.And("violation_date = ?", query.ViolationDate)
  43. }
  44. if !gotool.StrUtils.HasEmpty(query.Content) {
  45. session.And("content = ?", query.Content)
  46. }
  47. if query.Score > 0 {
  48. session.And("score = ?", query.Score)
  49. }
  50. if !gotool.StrUtils.HasEmpty(query.Company) {
  51. session.And("company = ?", query.Company)
  52. }
  53. if !gotool.StrUtils.HasEmpty(query.HandlerDate) {
  54. session.And("handler_date = ?", query.HandlerDate)
  55. }
  56. if !gotool.StrUtils.HasEmpty(query.Remark) {
  57. session.And("remark = ?", query.Remark)
  58. }
  59. if !gotool.StrUtils.HasEmpty(query.CreateBy) {
  60. session.And("create_by = ?", query.CreateBy)
  61. }
  62. if !gotool.StrUtils.HasEmpty(query.UpdateBy) {
  63. session.And("update_by = ?", query.UpdateBy)
  64. }
  65. if !gotool.StrUtils.HasEmpty(query.BeginTime) {
  66. session.And("date_format(u.create_time,'%y%m%d') >= date_format(?,'%y%m%d')", query.BeginTime)
  67. }
  68. if !gotool.StrUtils.HasEmpty(query.EndTime) {
  69. session.And("date_format(u.create_time,'%y%m%d') <= date_format(?,'%y%m%d')", query.EndTime)
  70. }
  71. total, err := session.Limit(query.PageSize, page.StartSize(query.PageNum, query.PageSize)).FindAndCount(&run)
  72. if err != nil {
  73. frame.Throw(frame.SQL_CODE, "数据查询错误"+err.Error())
  74. }
  75. return &run, total
  76. }
  77. // List 查询营运记录分页数据
  78. func (this RunDao) List(query *req.RunQuery, list interface{}) {
  79. session := this.GetSession().Table(model.Run{}.TableName())
  80. if query.Id > 0 {
  81. session.And("id = ?", query.Id)
  82. }
  83. if !gotool.StrUtils.HasEmpty(query.ServiceNo) {
  84. session.And("service_no = ?", query.ServiceNo)
  85. }
  86. if !gotool.StrUtils.HasEmpty(query.Card) {
  87. session.And("card = ?", query.Card)
  88. }
  89. if !gotool.StrUtils.HasEmpty(query.Driver) {
  90. session.And("driver = ?", query.Driver)
  91. }
  92. if !gotool.StrUtils.HasEmpty(query.IdCard) {
  93. session.And("id_card = ?", query.IdCard)
  94. }
  95. if query.CompanyId > 0 {
  96. session.And("company_id = ?", query.CompanyId)
  97. }
  98. if !gotool.StrUtils.HasEmpty(query.CarNo) {
  99. session.And("car_no = ?", query.CarNo)
  100. }
  101. if !gotool.StrUtils.HasEmpty(query.Address) {
  102. session.And("address = ?", query.Address)
  103. }
  104. if !gotool.StrUtils.HasEmpty(query.ViolationDate) {
  105. session.And("violation_date = ?", query.ViolationDate)
  106. }
  107. if !gotool.StrUtils.HasEmpty(query.Content) {
  108. session.And("content = ?", query.Content)
  109. }
  110. if query.Score > 0 {
  111. session.And("score = ?", query.Score)
  112. }
  113. if !gotool.StrUtils.HasEmpty(query.Company) {
  114. session.And("company = ?", query.Company)
  115. }
  116. if !gotool.StrUtils.HasEmpty(query.HandlerDate) {
  117. session.And("handler_date = ?", query.HandlerDate)
  118. }
  119. if !gotool.StrUtils.HasEmpty(query.Remark) {
  120. session.And("remark = ?", query.Remark)
  121. }
  122. if !gotool.StrUtils.HasEmpty(query.CreateBy) {
  123. session.And("create_by = ?", query.CreateBy)
  124. }
  125. if !gotool.StrUtils.HasEmpty(query.UpdateBy) {
  126. session.And("update_by = ?", query.UpdateBy)
  127. }
  128. if !gotool.StrUtils.HasEmpty(query.BeginTime) {
  129. session.And("date_format(u.create_time,'%y%m%d') >= date_format(?,'%y%m%d')", query.BeginTime)
  130. }
  131. if !gotool.StrUtils.HasEmpty(query.EndTime) {
  132. session.And("date_format(u.create_time,'%y%m%d') <= date_format(?,'%y%m%d')", query.EndTime)
  133. }
  134. err := session.Find(list)
  135. if err != nil {
  136. frame.Throw(frame.SQL_CODE, "数据查询错误"+err.Error())
  137. }
  138. }