apksel-dev/apskel-pos-backend
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix unit

Browse Source
This commit is contained in:
Aditya Siregar 2025-08-10 20:58:32 +07:00
parent 835097d381
commit db7c862fa8
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/processor/unit_processor.go
View File

@ -1,6 +1,7 @@
package processor package processor
import ( import (
"apskel-pos-be/internal/appcontext"
"apskel-pos-be/internal/entities" "apskel-pos-be/internal/entities"
"apskel-pos-be/internal/mappers" "apskel-pos-be/internal/mappers"
"apskel-pos-be/internal/models" "apskel-pos-be/internal/models"
@ -54,7 +55,8 @@ func (p *UnitProcessorImpl) CreateUnit(ctx context.Context, req *models.CreateUn
} }
func (p *UnitProcessorImpl) GetUnitByID(ctx context.Context, id uuid.UUID) (*models.UnitResponse, error) { func (p *UnitProcessorImpl) GetUnitByID(ctx context.Context, id uuid.UUID) (*models.UnitResponse, error) {
organizationID := uuid.Nil // This should come from context contextInfo := appcontext.FromGinContext(ctx)
organizationID := contextInfo.OrganizationID
unit, err := p.unitRepo.GetByID(ctx, id, organizationID) unit, err := p.unitRepo.GetByID(ctx, id, organizationID)
if err != nil { if err != nil {
@ -124,7 +126,8 @@ func (p *UnitProcessorImpl) ListUnits(ctx context.Context, organizationID uuid.U
} }
func (p *UnitProcessorImpl) UpdateUnit(ctx context.Context, id uuid.UUID, req *models.UpdateUnitRequest) (*models.UnitResponse, error) { func (p *UnitProcessorImpl) UpdateUnit(ctx context.Context, id uuid.UUID, req *models.UpdateUnitRequest) (*models.UnitResponse, error) {
organizationID := uuid.Nil contextInfo := appcontext.FromGinContext(ctx)
organizationID := contextInfo.OrganizationID
existingUnit, err := p.unitRepo.GetByID(ctx, id, organizationID) existingUnit, err := p.unitRepo.GetByID(ctx, id, organizationID)
if err != nil { if err != nil {
@ -159,7 +162,8 @@ func (p *UnitProcessorImpl) UpdateUnit(ctx context.Context, id uuid.UUID, req *m
} }
func (p *UnitProcessorImpl) DeleteUnit(ctx context.Context, id uuid.UUID) error { func (p *UnitProcessorImpl) DeleteUnit(ctx context.Context, id uuid.UUID) error {
organizationID := uuid.Nil contextInfo := appcontext.FromGinContext(ctx)
organizationID := contextInfo.OrganizationID
err := p.unitRepo.Delete(ctx, id, organizationID) err := p.unitRepo.Delete(ctx, id, organizationID)
if err != nil { if err != nil {