AFE Path Service - Domain-Driven Design

1
2
3
4
5
6
7
8
9
10
11
12
public class AFEBatch {
    private String batchId;
    private String warehouseId;
    private String waveId;
    private List<String> orderIds;
    private int totalItems;
    private BatchStatus status;
    private String assignedInductStation;
    private LocalDateTime createdAt;
    private LocalDateTime inductStartedAt;
    private LocalDateTime inductCompletedAt;
}

1
2
3
4
5
6
7
8
public class RebinWall {
    private String wallId;
    private String warehouseId;
    private int totalSlots;
    private int availableSlots;
    private List<RebinSlot> slots;
    private WallStatus status;
}

1
2
3
4
5
6
7
public class InductStation {
    private String stationId;
    private String warehouseId;
    private StationStatus status;
    private String assignedBatchId;
    private int throughputPerHour;
}

1
2
3
4
5
6
public class SorterLane {
    private String laneId;
    private String sorterId;
    private LaneStatus status;
    private String assignedChuteId;
}

1
2
3
4
5
6
7
8
9
10
11
12
13
public record RebinSlot(
    int slotNumber,
    String orderId,
    SlotStatus status,
    int expectedItems,
    int receivedItems,
    LocalDateTime assignedAt,
    LocalDateTime completedAt
) {
    public boolean isComplete() {
        return receivedItems >= expectedItems;
    }
}

1
2
3
4
5
6
7
8
9
public interface AFEBatchService {
    AFEBatch createBatch(String warehouseId, String waveId, List<String> orderIds);
    AFEBatch assignToInductStation(String batchId, String inductStation);
    AFEBatch startInduction(String batchId);
    AFEBatch completeInduction(String batchId);
    AFEBatch completeRebinning(String batchId);
    AFEBatch getBatch(String batchId);
    List<AFEBatch> getBatchesByWave(String waveId);
}

1
2
3
4
5
6
7
public interface RebinService {
    RebinSlot assignOrderToSlot(String wallId, int slotNumber, String orderId, int expectedItems);
    RebinSlot addItemToSlot(String wallId, int slotNumber, String itemId);
    RebinSlot completeSlot(String wallId, int slotNumber);
    void clearSlot(String wallId, int slotNumber);
    RebinWall getWallStatus(String wallId);
}

1
2
3
4
5
public interface AFEWorkAssignmentService {
    void handlePathAssignment(ShipmentRoutedToPathEvent event);
    void handleRobotTaskCompleted(RobotTaskCompletedEvent event);
    void handlePodDelivered(PodDeliveredEvent event);
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
public interface AFEBatchRepository {
    AFEBatch save(AFEBatch batch);
    Optional<AFEBatch> findById(String batchId);
    List<AFEBatch> findByWaveId(String waveId);
    List<AFEBatch> findByStatus(BatchStatus status);
}

public interface RebinWallRepository {
    RebinWall save(RebinWall wall);
    Optional<RebinWall> findById(String wallId);
    List<RebinWall> findByWarehouseId(String warehouseId);
}

public interface InductStationRepository {
    InductStation save(InductStation station);
    Optional<InductStation> findById(String stationId);
    List<InductStation> findAvailable(String warehouseId);
}