Admin stat vehicles
This commit is contained in:
@@ -52,3 +52,17 @@ func (s *ServicesHandler) GetBookings() (bookings []storage.Booking, err error)
|
||||
|
||||
return
|
||||
}
|
||||
|
||||
func (s *ServicesHandler) GetVehiclesMap() (vehicles map[string]storage.Vehicle, err error) {
|
||||
vehicles = map[string]storage.Vehicle{}
|
||||
|
||||
request := &fleets.GetVehiclesRequest{}
|
||||
resp, err := s.GRPC.Fleets.GetVehicles(context.TODO(), request)
|
||||
if err == nil {
|
||||
for _, vehicle := range resp.Vehicles {
|
||||
vehicles[vehicle.Id] = vehicle.ToStorageType()
|
||||
}
|
||||
}
|
||||
|
||||
return
|
||||
}
|
||||
|
||||
@@ -1,7 +1,10 @@
|
||||
package services
|
||||
|
||||
import (
|
||||
"context"
|
||||
|
||||
groupsmanagement "git.coopgo.io/coopgo-platform/groups-management/grpcapi"
|
||||
"git.coopgo.io/coopgo-platform/groups-management/storage"
|
||||
"google.golang.org/grpc"
|
||||
)
|
||||
|
||||
@@ -21,3 +24,17 @@ func NewGroupsManagementService(groupsManagementDial string) (*GroupsManagementS
|
||||
GroupsManagementClient: client,
|
||||
}, nil
|
||||
}
|
||||
|
||||
func (s *ServicesHandler) GetGroupsMap() (groups map[string]storage.Group, err error) {
|
||||
groups = map[string]storage.Group{}
|
||||
|
||||
request := &groupsmanagement.GetGroupsRequest{}
|
||||
resp, err := s.GRPC.GroupsManagement.GetGroups(context.TODO(), request)
|
||||
if err == nil {
|
||||
for _, group := range resp.Groups {
|
||||
groups[group.Id] = group.ToStorageType()
|
||||
}
|
||||
}
|
||||
|
||||
return
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user