fee_config.go 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119
  1. package vehicle
  2. import (
  3. "errors"
  4. "server/dao"
  5. "server/global"
  6. "server/model/vehicle/request"
  7. )
  8. type feeConfigService struct{}
  9. func NewFeeConfigService() *feeConfigService {
  10. return &feeConfigService{}
  11. }
  12. // CreateFeeConfig 创建收费配置
  13. func (s *feeConfigService) CreateFeeConfig(req request.FeeConfigCreate) error {
  14. // 检查车辆类型是否已存在
  15. var existingConfig dao.FeeConfig
  16. result := global.GVA_DB.Where("vehicle_type = ?", req.VehicleType).First(&existingConfig)
  17. if result.RowsAffected > 0 {
  18. return errors.New("该车辆类型的收费配置已存在")
  19. }
  20. config := dao.FeeConfig{
  21. VehicleType: req.VehicleType,
  22. StartTime: req.StartTime,
  23. StartFee: req.StartFee,
  24. UnitTime: req.UnitTime,
  25. UnitFee: req.UnitFee,
  26. DailyMaxFee: req.DailyMaxFee,
  27. IsVIPFree: req.IsVIPFree,
  28. VIPDiscount: req.VIPDiscount,
  29. Description: req.Description,
  30. }
  31. return global.GVA_DB.Create(&config).Error
  32. }
  33. // UpdateFeeConfig 更新收费配置
  34. func (s *feeConfigService) UpdateFeeConfig(req request.FeeConfigUpdate) error {
  35. var config dao.FeeConfig
  36. result := global.GVA_DB.First(&config, req.ID)
  37. if result.RowsAffected == 0 {
  38. return errors.New("收费配置不存在")
  39. }
  40. // 检查车辆类型是否被其他配置使用
  41. var existingConfig dao.FeeConfig
  42. result = global.GVA_DB.Where("vehicle_type = ? AND id != ?", req.VehicleType, req.ID).First(&existingConfig)
  43. if result.RowsAffected > 0 {
  44. return errors.New("该车辆类型的收费配置已存在")
  45. }
  46. config.VehicleType = req.VehicleType
  47. config.StartTime = req.StartTime
  48. config.StartFee = req.StartFee
  49. config.UnitTime = req.UnitTime
  50. config.UnitFee = req.UnitFee
  51. config.DailyMaxFee = req.DailyMaxFee
  52. config.IsVIPFree = req.IsVIPFree
  53. config.VIPDiscount = req.VIPDiscount
  54. config.Description = req.Description
  55. return global.GVA_DB.Save(&config).Error
  56. }
  57. // GetFeeConfigByID 根据ID获取收费配置
  58. func (s *feeConfigService) GetFeeConfigByID(id uint) (dao.FeeConfig, error) {
  59. var config dao.FeeConfig
  60. result := global.GVA_DB.First(&config, id)
  61. if result.RowsAffected == 0 {
  62. return dao.FeeConfig{}, errors.New("收费配置不存在")
  63. }
  64. return config, nil
  65. }
  66. // GetFeeConfigByVehicleType 根据车辆类型获取收费配置
  67. func (s *feeConfigService) GetFeeConfigByVehicleType(vehicleType string) (dao.FeeConfig, error) {
  68. var config dao.FeeConfig
  69. result := global.GVA_DB.Where("vehicle_type = ?", vehicleType).First(&config)
  70. if result.RowsAffected == 0 {
  71. return dao.FeeConfig{}, errors.New("收费配置不存在")
  72. }
  73. return config, nil
  74. }
  75. // ListFeeConfigs 获取收费配置列表
  76. func (s *feeConfigService) ListFeeConfigs(req request.FeeConfigQuery) (int64, []dao.FeeConfig, error) {
  77. var configs []dao.FeeConfig
  78. var total int64
  79. query := global.GVA_DB.Model(&dao.FeeConfig{})
  80. if req.VehicleType != "" {
  81. query = query.Where("vehicle_type LIKE ?", "%"+req.VehicleType+"%")
  82. }
  83. // 计算总数
  84. query.Count(&total)
  85. // 分页查询
  86. offset := (req.Page - 1) * req.PageSize
  87. result := query.Offset(offset).Limit(req.PageSize).Find(&configs)
  88. if result.Error != nil {
  89. return 0, nil, result.Error
  90. }
  91. return total, configs, nil
  92. }
  93. // DeleteFeeConfig 删除收费配置
  94. func (s *feeConfigService) DeleteFeeConfig(id uint) error {
  95. result := global.GVA_DB.Delete(&dao.FeeConfig{}, id)
  96. if result.RowsAffected == 0 {
  97. return errors.New("收费配置不存在")
  98. }
  99. return result.Error
  100. }