42 lines
1,000 B
Go
42 lines
1,000 B
Go
package merch
|
|
|
|
import "context"
|
|
|
|
func (s *service) createOrigin(ctx context.Context, o *newOriginDTO) error {
|
|
newOrigin := &Origin{
|
|
CreatedAt: s.utils.TimeNowUTC(),
|
|
DeletedAt: s.utils.DeletedNullTime(),
|
|
Name: o.Name,
|
|
}
|
|
|
|
logDebug(serviceLogHeader, "create origin success")
|
|
return s.repo.createOrigin(ctx, newOrigin)
|
|
}
|
|
|
|
func (s *service) getOrigins(ctx context.Context) (*originsDTO, error) {
|
|
data, err := s.repo.getOrigins(ctx)
|
|
if err != nil {
|
|
logErr(serviceLogHeader, err)
|
|
return nil, err
|
|
}
|
|
|
|
var origins []originItem
|
|
for _, item := range data {
|
|
origins = append(origins, originItem{
|
|
Id: item.Id,
|
|
Name: item.Name,
|
|
})
|
|
}
|
|
|
|
response := &originsDTO{
|
|
Origins: origins,
|
|
}
|
|
|
|
logDebug(serviceLogHeader, "get origins success")
|
|
return response, nil
|
|
}
|
|
|
|
func (s *service) deleteOrigin(ctx context.Context, origin *deleteOriginDTO) error {
|
|
logDebug(serviceLogHeader, "delete origin success")
|
|
return s.repo.deleteOriginByName(ctx, origin.Name, s.utils.NullTimeNowUTC())
|
|
}
|