sys_config.go 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180
  1. package service
  2. import (
  3. "errors"
  4. "IotAdmin/app/system/models"
  5. "IotAdmin/app/system/service/dto"
  6. cDto "IotAdmin/common/dto"
  7. "IotAdmin/core/sdk/service"
  8. "gorm.io/gorm"
  9. )
  10. type SysConfigService struct {
  11. service.Service
  12. }
  13. // GetPage 获取SysConfig列表
  14. func (e *SysConfigService) GetPage(c *dto.SysConfigGetPageReq, list *[]models.SysConfig, count *int64) error {
  15. err := e.Orm.
  16. Scopes(
  17. cDto.MakeCondition(c.GetNeedSearch()),
  18. cDto.Paginate(c.GetPageSize(), c.GetPageIndex()),
  19. ).
  20. Find(list).Limit(-1).Offset(-1).
  21. Count(count).Error
  22. if err != nil {
  23. e.Log.Errorf("Service GetSysConfigPage error:%s", err)
  24. return err
  25. }
  26. return nil
  27. }
  28. // Get 获取SysConfig对象
  29. func (e *SysConfigService) Get(d *dto.SysConfigGetReq, model *models.SysConfig) error {
  30. err := e.Orm.First(model, d.GetId()).Error
  31. if err != nil && errors.Is(err, gorm.ErrRecordNotFound) {
  32. err = errors.New("查看对象不存在或无权查看")
  33. e.Log.Errorf("Service GetSysConfigPage error:%s", err)
  34. return err
  35. }
  36. if err != nil {
  37. e.Log.Errorf("Service GetSysConfig error:%s", err)
  38. return err
  39. }
  40. return nil
  41. }
  42. // Insert 创建SysConfig对象
  43. func (e *SysConfigService) Insert(c *dto.SysConfigControl) error {
  44. var err error
  45. var data models.SysConfig
  46. c.Generate(&data)
  47. err = e.Orm.Create(&data).Error
  48. if err != nil {
  49. e.Log.Errorf("Service InsertSysConfig error:%s", err)
  50. return err
  51. }
  52. return nil
  53. }
  54. // Update 修改SysConfig对象
  55. func (e *SysConfigService) Update(c *dto.SysConfigControl) error {
  56. var err error
  57. var model = models.SysConfig{}
  58. e.Orm.First(&model, c.GetId())
  59. c.Generate(&model)
  60. db := e.Orm.Save(&model)
  61. err = db.Error
  62. if err != nil {
  63. e.Log.Errorf("Service UpdateSysConfig error:%s", err)
  64. return err
  65. }
  66. if db.RowsAffected == 0 {
  67. return errors.New("无权更新该数据")
  68. }
  69. return nil
  70. }
  71. // SetSysConfig 修改SysConfig对象
  72. func (e *SysConfigService) SetSysConfig(c *[]dto.GetSetSysConfigReq) error {
  73. var err error
  74. for _, req := range *c {
  75. var model = models.SysConfig{}
  76. e.Orm.Where("config_key = ?", req.ConfigKey).First(&model)
  77. if model.Id != 0 {
  78. req.Generate(&model)
  79. db := e.Orm.Save(&model)
  80. err = db.Error
  81. if err != nil {
  82. e.Log.Errorf("Service SetSysConfig error:%s", err)
  83. return err
  84. }
  85. if db.RowsAffected == 0 {
  86. return errors.New("无权更新该数据")
  87. }
  88. }
  89. }
  90. return nil
  91. }
  92. func (e *SysConfigService) GetForSet(c *[]dto.GetSetSysConfigReq) error {
  93. var err error
  94. var data models.SysConfig
  95. err = e.Orm.Model(&data).Find(c).Error
  96. if err != nil {
  97. e.Log.Errorf("Service GetSysSetConfig error:%s", err)
  98. return err
  99. }
  100. return nil
  101. }
  102. func (e *SysConfigService) UpdateForSet(c *[]dto.GetSetSysConfigReq) error {
  103. m := *c
  104. for _, req := range m {
  105. var data models.SysConfig
  106. if err := e.Orm.Where("config_key = ?", req.ConfigKey).First(&data).Error; err != nil {
  107. e.Log.Errorf("Service UpdateForSet query error:%s", err)
  108. return err
  109. }
  110. if data.ConfigValue != req.ConfigValue {
  111. data.ConfigValue = req.ConfigValue
  112. if err := e.Orm.Save(&data).Error; err != nil {
  113. e.Log.Errorf("Service UpdateForSet error:%s", err)
  114. return err
  115. }
  116. }
  117. }
  118. return nil
  119. }
  120. // Remove 删除SysConfig
  121. func (e *SysConfigService) Remove(d *dto.SysConfigDeleteReq) error {
  122. var err error
  123. var data models.SysConfig
  124. db := e.Orm.Delete(&data, d.Ids)
  125. if err = db.Error; err != nil {
  126. err = db.Error
  127. e.Log.Errorf("Service RemoveSysConfig error:%s", err)
  128. return err
  129. }
  130. if db.RowsAffected == 0 {
  131. err = errors.New("无权删除该数据")
  132. return err
  133. }
  134. return nil
  135. }
  136. // GetWithKey 根据Key获取SysConfig
  137. func (e *SysConfigService) GetWithKey(c *dto.SysConfigByKeyReq, resp *dto.GetSysConfigByKEYForServiceResp) error {
  138. var err error
  139. var data models.SysConfig
  140. err = e.Orm.Table(data.TableName()).Where("config_key = ?", c.ConfigKey).First(resp).Error
  141. if err != nil {
  142. e.Log.Errorf("At Service GetSysConfigByKEY Error:%s", err)
  143. return err
  144. }
  145. return nil
  146. }
  147. func (e *SysConfigService) GetWithKeyList(c *dto.SysConfigGetToSysAppReq, list *[]models.SysConfig) error {
  148. var err error
  149. err = e.Orm.
  150. Scopes(
  151. cDto.MakeCondition(c.GetNeedSearch()),
  152. ).
  153. Find(list).Error
  154. if err != nil {
  155. e.Log.Errorf("Service GetSysConfigByKey error:%s", err)
  156. return err
  157. }
  158. return nil
  159. }