infoBoardService.go 2.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192
  1. package service
  2. import (
  3. "fmt"
  4. "iot_manager_service/app/device/dao"
  5. "iot_manager_service/util"
  6. "time"
  7. )
  8. var InfoBoardService = new(infoBoardService)
  9. type infoBoardService struct{}
  10. func (s *infoBoardService) Get(id int) (*dao.InfoBoard, *util.Errors) {
  11. // 创建查询实例
  12. device := &dao.InfoBoard{
  13. ID: id,
  14. }
  15. err := device.GetDevice()
  16. if err != nil {
  17. return nil, util.FailResponse(err.Error(), nil)
  18. }
  19. return device, nil
  20. }
  21. func (s *infoBoardService) CreateOrUpdate(userId int64, tenantId int, req dao.InfoBoard) *util.Errors {
  22. // 创建查询实例
  23. device := req
  24. device.TenantId = tenantId
  25. device.UpdateUser = userId
  26. device.UpdateTime = time.Now()
  27. if req.ID == 0 {
  28. device.CreateTime = time.Now()
  29. device.CreateUser = userId
  30. if device.IsExistedBySN() {
  31. fmt.Printf("Create GetDeviceID err \n")
  32. return util.ParamsInvalidResponse("编码不能重复,请重新填写!", nil)
  33. }
  34. if err := device.Create(); err != nil {
  35. fmt.Printf("Create err = %s \n", err.Error())
  36. return util.FailResponse(err.Error(), nil)
  37. }
  38. return util.SuccessResponse(util.Succeeded, nil)
  39. }
  40. if device.IsExistedByNameAndCode() {
  41. return util.ParamsInvalidResponse("编码不能重复,请重新填写!", nil)
  42. }
  43. if err := device.Update(); err != nil {
  44. fmt.Printf("Update err = %s \n", err.Error())
  45. return util.FailResponse(err.Error(), nil)
  46. }
  47. //todo operation record
  48. return util.SuccessResponse(util.Succeeded, nil)
  49. }
  50. func (s *infoBoardService) List(searchValue string, current, size int) ([]dao.InfoBoard, *util.Errors) {
  51. device := dao.InfoBoard{}
  52. if searchValue != "" {
  53. device.SN = searchValue
  54. device.InfoName = searchValue
  55. }
  56. offset := (current - 1) * size
  57. limit := size
  58. devices, err := device.GetDevices(offset, limit)
  59. if err != nil {
  60. return nil, util.FailResponse(err.Error(), nil)
  61. }
  62. return devices, nil
  63. }
  64. func (s *infoBoardService) Remove(userId int64, id int) *util.Errors {
  65. // 创建查询实例
  66. device := &dao.InfoBoard{
  67. ID: id,
  68. IsDeleted: 1,
  69. UpdateUser: userId,
  70. UpdateTime: time.Now(),
  71. }
  72. //todo
  73. // service.transformerService.CountRelation()
  74. //todo operation record
  75. err := device.Delete()
  76. if err != nil {
  77. return util.FailResponse(err.Error(), nil)
  78. }
  79. return nil
  80. }