resourceManageService.go 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970
  1. package service
  2. import (
  3. "app.yhyue.com/moapp/jyResourcesCenter/entity"
  4. "app.yhyue.com/moapp/jyResourcesCenter/rpc/resourcesCenter"
  5. )
  6. type ResourceManageService struct{}
  7. //查询用户资源权限
  8. func (service *ResourceManageService) FindResourcesAuth(data *resourcesCenter.ResourcesAuthReq) ([]*resourcesCenter.ResourcesAuth, error) {
  9. orm := entity.Engine.NewSession()
  10. var authArr []*entity.ResourcesAuth
  11. var authList []*resourcesCenter.ResourcesAuth
  12. err := orm.Table("resources_authorization").Where("accountId = ?", data.EmployeeId).Find(&authArr)
  13. if err != nil {
  14. return authList, err
  15. }
  16. for _, v := range authArr {
  17. authList = append(authList,&resourcesCenter.ResourcesAuth{
  18. Id:v.Id,
  19. EmployeeId:v.EmployeeId,
  20. ResourcesId:v.ResourcesId,
  21. Quota:v.Quota,
  22. State:v.State,
  23. Ratio:v.Ratio,
  24. })
  25. }
  26. return authList, nil
  27. }
  28. //查询账户资源余额
  29. func (service *ResourceManageService) FindAccountBalance(in *resourcesCenter.AccountBalanceReq)([]*resourcesCenter.ResourceBalance,error){
  30. orm := entity.Engine.NewSession()
  31. var accountBalanceArr []*entity.AccountBalance
  32. var dataList []*resourcesCenter.ResourceBalance
  33. err := orm.Table("account_resources").Where("employeeId = ?", in.EmployeeId).Find(&accountBalanceArr)
  34. if err != nil {
  35. return dataList, err
  36. }
  37. for _, v := range accountBalanceArr {
  38. dataList = append(dataList,&resourcesCenter.ResourceBalance{
  39. Id:v.Id,
  40. EmployeeId:v.EmployeeId,
  41. Name:v.Name,
  42. Code:v.Code,
  43. Number:v.Number,
  44. Spec:v.Spec,
  45. })
  46. }
  47. return dataList, nil
  48. }
  49. //查询账户资源余额
  50. func (service *ResourceManageService) FindConsumeRecord(in *resourcesCenter.ConsumeRecordReq)([]*resourcesCenter.ConsumeRecord,error){
  51. orm := entity.Engine.NewSession()
  52. var recordArr []*entity.ConsumeRecord
  53. var dataList []*resourcesCenter.ConsumeRecord
  54. err := orm.Table("consume_record").Where("employeeId = ?", in.EmployeeId).Find(&recordArr)
  55. if err != nil {
  56. return dataList, err
  57. }
  58. for _, v := range recordArr {
  59. dataList = append(dataList,&resourcesCenter.ConsumeRecord{
  60. Id:v.Id,
  61. })
  62. }
  63. return dataList, nil
  64. }