1#![recursion_limit = "1024"]
18#![allow(unused_imports)]
19
20pub mod domain;
22pub mod infrastructure;
23pub mod application;
24pub mod presentation;
25pub mod seeders;
26pub mod exports;
27
28pub use domain::entity::*;
30
31pub use infrastructure::persistence::*;
33
34pub use application::service::PickingBatchService;
36pub use application::service::DeliveryNoteService;
37pub use application::service::DeliveryNoteItemService;
38pub use application::service::InventoryCompanySettingService;
39pub use application::service::LandedCostService;
40pub use application::service::LandedCostLineService;
41pub use application::service::LandedCostAdjustmentLineService;
42pub use application::service::LocationService;
43pub use application::service::StockMoveService;
44pub use application::service::StockMoveLineService;
45pub use application::service::OperationTypeService;
46pub use application::service::TransferService;
47pub use application::service::RouteService;
48pub use application::service::RouteRuleService;
49pub use application::service::ReorderingRuleService;
50pub use application::service::PurchaseReceiptService;
51pub use application::service::PurchaseReceiptItemService;
52pub use application::service::QuantService;
53pub use application::service::ScrapService;
54pub use application::service::ScrapReasonTagService;
55pub use application::service::StockEntryService;
56pub use application::service::StockEntryItemService;
57pub use application::service::StockLedgerEntryService;
58pub use application::service::BinService;
59pub use application::service::StockReconciliationService;
60pub use application::service::StockReconciliationItemService;
61pub use application::service::PackageTypeService;
62pub use application::service::StorageCategoryService;
63pub use application::service::StorageCategoryCapacityService;
64pub use application::service::PutawayRuleService;
65pub use application::service::LotService;
66pub use application::service::PackageService;
67pub use application::service::WarehouseService;
68pub use application::service::StockItemService;
69
70pub use application::validator::{ValidationError, ValidationResult};
72
73use std::sync::Arc;
74use axum::Router;
75use sqlx::PgPool;
76
77pub struct InventoryModule {
90 pub(crate) picking_batch_service: Arc<PickingBatchService>,
91 pub(crate) delivery_note_service: Arc<DeliveryNoteService>,
92 pub(crate) delivery_note_item_service: Arc<DeliveryNoteItemService>,
93 pub(crate) inventory_company_setting_service: Arc<InventoryCompanySettingService>,
94 pub(crate) landed_cost_service: Arc<LandedCostService>,
95 pub(crate) landed_cost_line_service: Arc<LandedCostLineService>,
96 pub(crate) landed_cost_adjustment_line_service: Arc<LandedCostAdjustmentLineService>,
97 pub(crate) location_service: Arc<LocationService>,
98 pub(crate) stock_move_service: Arc<StockMoveService>,
99 pub(crate) stock_move_line_service: Arc<StockMoveLineService>,
100 pub(crate) operation_type_service: Arc<OperationTypeService>,
101 pub(crate) transfer_service: Arc<TransferService>,
102 pub(crate) route_service: Arc<RouteService>,
103 pub(crate) route_rule_service: Arc<RouteRuleService>,
104 pub(crate) reordering_rule_service: Arc<ReorderingRuleService>,
105 pub(crate) purchase_receipt_service: Arc<PurchaseReceiptService>,
106 pub(crate) purchase_receipt_item_service: Arc<PurchaseReceiptItemService>,
107 pub(crate) quant_service: Arc<QuantService>,
108 pub(crate) scrap_service: Arc<ScrapService>,
109 pub(crate) scrap_reason_tag_service: Arc<ScrapReasonTagService>,
110 pub(crate) stock_entry_service: Arc<StockEntryService>,
111 pub(crate) stock_entry_item_service: Arc<StockEntryItemService>,
112 pub(crate) stock_ledger_entry_service: Arc<StockLedgerEntryService>,
113 pub(crate) bin_service: Arc<BinService>,
114 pub(crate) stock_reconciliation_service: Arc<StockReconciliationService>,
115 pub(crate) stock_reconciliation_item_service: Arc<StockReconciliationItemService>,
116 pub(crate) package_type_service: Arc<PackageTypeService>,
117 pub(crate) storage_category_service: Arc<StorageCategoryService>,
118 pub(crate) storage_category_capacity_service: Arc<StorageCategoryCapacityService>,
119 pub(crate) putaway_rule_service: Arc<PutawayRuleService>,
120 pub(crate) lot_service: Arc<LotService>,
121 pub(crate) package_service: Arc<PackageService>,
122 pub(crate) warehouse_service: Arc<WarehouseService>,
123 pub(crate) stock_item_service: Arc<StockItemService>,
124}
125
126impl InventoryModule {
127 pub fn builder() -> InventoryModuleBuilder {
129 InventoryModuleBuilder::new()
130 }
131
132 pub fn all_crud_routes(&self) -> Router {
138 use presentation::http::{
139 create_picking_batch_read_routes,
140 create_delivery_note_read_routes,
141 create_delivery_note_item_read_routes,
142 create_inventory_company_setting_routes,
143 create_landed_cost_read_routes,
144 create_landed_cost_line_read_routes,
145 create_landed_cost_adjustment_line_read_routes,
146 create_location_routes,
147 create_stock_move_read_routes,
148 create_stock_move_line_read_routes,
149 create_operation_type_routes,
150 create_transfer_read_routes,
151 create_route_routes,
152 create_route_rule_routes,
153 create_reordering_rule_routes,
154 create_purchase_receipt_read_routes,
155 create_purchase_receipt_item_read_routes,
156 create_quant_read_routes,
157 create_scrap_read_routes,
158 create_scrap_reason_tag_routes,
159 create_stock_entry_read_routes,
160 create_stock_entry_item_read_routes,
161 create_stock_ledger_entry_read_routes,
162 create_bin_read_routes,
163 create_stock_reconciliation_read_routes,
164 create_stock_reconciliation_item_read_routes,
165 create_package_type_routes,
166 create_storage_category_routes,
167 create_storage_category_capacity_routes,
168 create_putaway_rule_routes,
169 create_lot_routes,
170 create_package_routes,
171 create_warehouse_routes,
172 create_stock_item_routes,
173 };
174
175 Router::new()
176 .merge(create_picking_batch_read_routes(self.picking_batch_service.clone()))
177 .merge(create_delivery_note_read_routes(self.delivery_note_service.clone()))
181 .merge(create_delivery_note_item_read_routes(self.delivery_note_item_service.clone()))
182 .merge(create_inventory_company_setting_routes(self.inventory_company_setting_service.clone()))
183 .merge(create_landed_cost_read_routes(self.landed_cost_service.clone()))
187 .merge(create_landed_cost_line_read_routes(self.landed_cost_line_service.clone()))
188 .merge(create_landed_cost_adjustment_line_read_routes(self.landed_cost_adjustment_line_service.clone()))
189 .merge(create_location_routes(self.location_service.clone()))
190 .merge(create_stock_move_read_routes(self.stock_move_service.clone()))
194 .merge(create_stock_move_line_read_routes(self.stock_move_line_service.clone()))
195 .merge(create_operation_type_routes(self.operation_type_service.clone()))
196 .merge(create_transfer_read_routes(self.transfer_service.clone()))
197 .merge(create_route_routes(self.route_service.clone()))
198 .merge(create_route_rule_routes(self.route_rule_service.clone()))
199 .merge(create_reordering_rule_routes(self.reordering_rule_service.clone()))
200 .merge(create_purchase_receipt_read_routes(self.purchase_receipt_service.clone()))
204 .merge(create_purchase_receipt_item_read_routes(self.purchase_receipt_item_service.clone()))
205 .merge(create_quant_read_routes(self.quant_service.clone()))
206 .merge(create_scrap_read_routes(self.scrap_service.clone()))
207 .merge(create_scrap_reason_tag_routes(self.scrap_reason_tag_service.clone()))
208 .merge(create_stock_entry_read_routes(self.stock_entry_service.clone()))
212 .merge(create_stock_entry_item_read_routes(self.stock_entry_item_service.clone()))
213 .merge(create_stock_ledger_entry_read_routes(self.stock_ledger_entry_service.clone()))
217 .merge(create_bin_read_routes(self.bin_service.clone()))
218 .merge(create_stock_reconciliation_read_routes(self.stock_reconciliation_service.clone()))
222 .merge(create_stock_reconciliation_item_read_routes(self.stock_reconciliation_item_service.clone()))
223 .merge(create_package_type_routes(self.package_type_service.clone()))
224 .merge(create_storage_category_routes(self.storage_category_service.clone()))
225 .merge(create_storage_category_capacity_routes(self.storage_category_capacity_service.clone()))
226 .merge(create_putaway_rule_routes(self.putaway_rule_service.clone()))
227 .merge(create_lot_routes(self.lot_service.clone()))
228 .merge(create_package_routes(self.package_service.clone()))
229 .merge(create_warehouse_routes(self.warehouse_service.clone()))
230 .merge(create_stock_item_routes(self.stock_item_service.clone()))
231 }
232
233 #[deprecated(note = "mounts unvalidated generic CRUD; prefer readonly_routes() + validated writes, or all_crud_routes() for the full/unguarded surface")]
239 pub fn routes(&self) -> Router {
240 self.all_crud_routes()
241 }
242
243 pub fn readonly_routes(&self) -> Router {
249 use presentation::http::{
250 create_picking_batch_read_routes,
251 create_delivery_note_read_routes,
252 create_delivery_note_item_read_routes,
253 create_inventory_company_setting_read_routes,
254 create_landed_cost_read_routes,
255 create_landed_cost_line_read_routes,
256 create_landed_cost_adjustment_line_read_routes,
257 create_location_read_routes,
258 create_stock_move_read_routes,
259 create_stock_move_line_read_routes,
260 create_operation_type_read_routes,
261 create_transfer_read_routes,
262 create_route_read_routes,
263 create_route_rule_read_routes,
264 create_reordering_rule_read_routes,
265 create_purchase_receipt_read_routes,
266 create_purchase_receipt_item_read_routes,
267 create_quant_read_routes,
268 create_scrap_read_routes,
269 create_scrap_reason_tag_read_routes,
270 create_stock_entry_read_routes,
271 create_stock_entry_item_read_routes,
272 create_stock_ledger_entry_read_routes,
273 create_bin_read_routes,
274 create_stock_reconciliation_read_routes,
275 create_stock_reconciliation_item_read_routes,
276 create_package_type_read_routes,
277 create_storage_category_read_routes,
278 create_storage_category_capacity_read_routes,
279 create_putaway_rule_read_routes,
280 create_lot_read_routes,
281 create_package_read_routes,
282 create_warehouse_read_routes,
283 create_stock_item_read_routes,
284 };
285
286 Router::new()
287 .merge(create_picking_batch_read_routes(self.picking_batch_service.clone()))
288 .merge(create_delivery_note_read_routes(self.delivery_note_service.clone()))
289 .merge(create_delivery_note_item_read_routes(self.delivery_note_item_service.clone()))
290 .merge(create_inventory_company_setting_read_routes(self.inventory_company_setting_service.clone()))
291 .merge(create_landed_cost_read_routes(self.landed_cost_service.clone()))
292 .merge(create_landed_cost_line_read_routes(self.landed_cost_line_service.clone()))
293 .merge(create_landed_cost_adjustment_line_read_routes(self.landed_cost_adjustment_line_service.clone()))
294 .merge(create_location_read_routes(self.location_service.clone()))
295 .merge(create_stock_move_read_routes(self.stock_move_service.clone()))
296 .merge(create_stock_move_line_read_routes(self.stock_move_line_service.clone()))
297 .merge(create_operation_type_read_routes(self.operation_type_service.clone()))
298 .merge(create_transfer_read_routes(self.transfer_service.clone()))
299 .merge(create_route_read_routes(self.route_service.clone()))
300 .merge(create_route_rule_read_routes(self.route_rule_service.clone()))
301 .merge(create_reordering_rule_read_routes(self.reordering_rule_service.clone()))
302 .merge(create_purchase_receipt_read_routes(self.purchase_receipt_service.clone()))
303 .merge(create_purchase_receipt_item_read_routes(self.purchase_receipt_item_service.clone()))
304 .merge(create_quant_read_routes(self.quant_service.clone()))
305 .merge(create_scrap_read_routes(self.scrap_service.clone()))
306 .merge(create_scrap_reason_tag_read_routes(self.scrap_reason_tag_service.clone()))
307 .merge(create_stock_entry_read_routes(self.stock_entry_service.clone()))
308 .merge(create_stock_entry_item_read_routes(self.stock_entry_item_service.clone()))
309 .merge(create_stock_ledger_entry_read_routes(self.stock_ledger_entry_service.clone()))
310 .merge(create_bin_read_routes(self.bin_service.clone()))
311 .merge(create_stock_reconciliation_read_routes(self.stock_reconciliation_service.clone()))
312 .merge(create_stock_reconciliation_item_read_routes(self.stock_reconciliation_item_service.clone()))
313 .merge(create_package_type_read_routes(self.package_type_service.clone()))
314 .merge(create_storage_category_read_routes(self.storage_category_service.clone()))
315 .merge(create_storage_category_capacity_read_routes(self.storage_category_capacity_service.clone()))
316 .merge(create_putaway_rule_read_routes(self.putaway_rule_service.clone()))
317 .merge(create_lot_read_routes(self.lot_service.clone()))
318 .merge(create_package_read_routes(self.package_service.clone()))
319 .merge(create_warehouse_read_routes(self.warehouse_service.clone()))
320 .merge(create_stock_item_read_routes(self.stock_item_service.clone()))
321 }
322
323}
324
325pub struct InventoryModuleBuilder {
327 db_pool: Option<PgPool>,
328}
329
330impl InventoryModuleBuilder {
331 pub fn new() -> Self {
333 Self {
334 db_pool: None,
335 }
336 }
337
338 pub fn with_database(mut self, pool: PgPool) -> Self {
340 self.db_pool = Some(pool);
341 self
342 }
343
344
345 pub fn build(self) -> anyhow::Result<InventoryModule> {
347 let db_pool = self.db_pool
348 .ok_or_else(|| anyhow::anyhow!("Database pool not configured"))?;
349
350 let picking_batch_repository = Arc::new(PickingBatchRepository::new(db_pool.clone()));
352 let picking_batch_service = Arc::new(PickingBatchService::with_repository(picking_batch_repository.clone()));
353
354 let delivery_note_repository = Arc::new(DeliveryNoteRepository::new(db_pool.clone()));
356 let delivery_note_service = Arc::new(DeliveryNoteService::with_repository(delivery_note_repository.clone()).with_guard(Arc::new(crate::application::service::DeliveryNoteRowRules)));
357
358 let delivery_note_item_repository = Arc::new(DeliveryNoteItemRepository::new(db_pool.clone()));
360 let delivery_note_item_service = Arc::new(DeliveryNoteItemService::with_repository(delivery_note_item_repository.clone()));
361
362 let inventory_company_setting_repository = Arc::new(InventoryCompanySettingRepository::new(db_pool.clone()));
364 let inventory_company_setting_service = Arc::new(InventoryCompanySettingService::with_repository(inventory_company_setting_repository.clone()));
365
366 let landed_cost_repository = Arc::new(LandedCostRepository::new(db_pool.clone()));
368 let landed_cost_service = Arc::new(LandedCostService::with_repository(landed_cost_repository.clone()));
369
370 let landed_cost_line_repository = Arc::new(LandedCostLineRepository::new(db_pool.clone()));
372 let landed_cost_line_service = Arc::new(LandedCostLineService::with_repository(landed_cost_line_repository.clone()));
373
374 let landed_cost_adjustment_line_repository = Arc::new(LandedCostAdjustmentLineRepository::new(db_pool.clone()));
376 let landed_cost_adjustment_line_service = Arc::new(LandedCostAdjustmentLineService::with_repository(landed_cost_adjustment_line_repository.clone()));
377
378 let location_repository = Arc::new(LocationRepository::new(db_pool.clone()));
380 let location_service = Arc::new(LocationService::with_repository(location_repository.clone()));
381
382 let stock_move_repository = Arc::new(StockMoveRepository::new(db_pool.clone()));
384 let stock_move_service = Arc::new(StockMoveService::with_repository(stock_move_repository.clone()).with_guard(Arc::new(crate::application::service::StockMoveRowRules)));
385
386 let stock_move_line_repository = Arc::new(StockMoveLineRepository::new(db_pool.clone()));
388 let stock_move_line_service = Arc::new(StockMoveLineService::with_repository(stock_move_line_repository.clone()));
389
390 let operation_type_repository = Arc::new(OperationTypeRepository::new(db_pool.clone()));
392 let operation_type_service = Arc::new(OperationTypeService::with_repository(operation_type_repository.clone()));
393
394 let transfer_repository = Arc::new(TransferRepository::new(db_pool.clone()));
396 let transfer_service = Arc::new(TransferService::with_repository(transfer_repository.clone()));
397
398 let route_repository = Arc::new(RouteRepository::new(db_pool.clone()));
400 let route_service = Arc::new(RouteService::with_repository(route_repository.clone()));
401
402 let route_rule_repository = Arc::new(RouteRuleRepository::new(db_pool.clone()));
404 let route_rule_service = Arc::new(RouteRuleService::with_repository(route_rule_repository.clone()));
405
406 let reordering_rule_repository = Arc::new(ReorderingRuleRepository::new(db_pool.clone()));
408 let reordering_rule_service = Arc::new(ReorderingRuleService::with_repository(reordering_rule_repository.clone()));
409
410 let purchase_receipt_repository = Arc::new(PurchaseReceiptRepository::new(db_pool.clone()));
412 let purchase_receipt_service = Arc::new(PurchaseReceiptService::with_repository(purchase_receipt_repository.clone()).with_guard(Arc::new(crate::application::service::PurchaseReceiptRowRules)));
413
414 let purchase_receipt_item_repository = Arc::new(PurchaseReceiptItemRepository::new(db_pool.clone()));
416 let purchase_receipt_item_service = Arc::new(PurchaseReceiptItemService::with_repository(purchase_receipt_item_repository.clone()));
417
418 let quant_repository = Arc::new(QuantRepository::new(db_pool.clone()));
420 let quant_service = Arc::new(QuantService::with_repository(quant_repository.clone()));
421
422 let scrap_repository = Arc::new(ScrapRepository::new(db_pool.clone()));
424 let scrap_service = Arc::new(ScrapService::with_repository(scrap_repository.clone()));
425
426 let scrap_reason_tag_repository = Arc::new(ScrapReasonTagRepository::new(db_pool.clone()));
428 let scrap_reason_tag_service = Arc::new(ScrapReasonTagService::with_repository(scrap_reason_tag_repository.clone()));
429
430 let stock_entry_repository = Arc::new(StockEntryRepository::new(db_pool.clone()));
432 let stock_entry_service = Arc::new(StockEntryService::with_repository(stock_entry_repository.clone()));
433
434 let stock_entry_item_repository = Arc::new(StockEntryItemRepository::new(db_pool.clone()));
436 let stock_entry_item_service = Arc::new(StockEntryItemService::with_repository(stock_entry_item_repository.clone()));
437
438 let stock_ledger_entry_repository = Arc::new(StockLedgerEntryRepository::new(db_pool.clone()));
440 let stock_ledger_entry_service = Arc::new(StockLedgerEntryService::with_repository(stock_ledger_entry_repository.clone()));
441
442 let bin_repository = Arc::new(BinRepository::new(db_pool.clone()));
444 let bin_service = Arc::new(BinService::with_repository(bin_repository.clone()));
445
446 let stock_reconciliation_repository = Arc::new(StockReconciliationRepository::new(db_pool.clone()));
448 let stock_reconciliation_service = Arc::new(StockReconciliationService::with_repository(stock_reconciliation_repository.clone()).with_guard(Arc::new(crate::application::service::StockReconciliationRowRules)));
449
450 let stock_reconciliation_item_repository = Arc::new(StockReconciliationItemRepository::new(db_pool.clone()));
452 let stock_reconciliation_item_service = Arc::new(StockReconciliationItemService::with_repository(stock_reconciliation_item_repository.clone()));
453
454 let package_type_repository = Arc::new(PackageTypeRepository::new(db_pool.clone()));
456 let package_type_service = Arc::new(PackageTypeService::with_repository(package_type_repository.clone()));
457
458 let storage_category_repository = Arc::new(StorageCategoryRepository::new(db_pool.clone()));
460 let storage_category_service = Arc::new(StorageCategoryService::with_repository(storage_category_repository.clone()));
461
462 let storage_category_capacity_repository = Arc::new(StorageCategoryCapacityRepository::new(db_pool.clone()));
464 let storage_category_capacity_service = Arc::new(StorageCategoryCapacityService::with_repository(storage_category_capacity_repository.clone()));
465
466 let putaway_rule_repository = Arc::new(PutawayRuleRepository::new(db_pool.clone()));
468 let putaway_rule_service = Arc::new(PutawayRuleService::with_repository(putaway_rule_repository.clone()));
469
470 let lot_repository = Arc::new(LotRepository::new(db_pool.clone()));
472 let lot_service = Arc::new(LotService::with_repository(lot_repository.clone()));
473
474 let package_repository = Arc::new(PackageRepository::new(db_pool.clone()));
476 let package_service = Arc::new(PackageService::with_repository(package_repository.clone()));
477
478 let warehouse_repository = Arc::new(WarehouseRepository::new(db_pool.clone()));
480 let warehouse_service = Arc::new(WarehouseService::with_repository(warehouse_repository.clone()));
481
482 let stock_item_repository = Arc::new(StockItemRepository::new(db_pool.clone()));
484 let stock_item_service = Arc::new(StockItemService::with_repository(stock_item_repository.clone()));
485
486
487 Ok(InventoryModule {
488 picking_batch_service,
489 delivery_note_service,
490 delivery_note_item_service,
491 inventory_company_setting_service,
492 landed_cost_service,
493 landed_cost_line_service,
494 landed_cost_adjustment_line_service,
495 location_service,
496 stock_move_service,
497 stock_move_line_service,
498 operation_type_service,
499 transfer_service,
500 route_service,
501 route_rule_service,
502 reordering_rule_service,
503 purchase_receipt_service,
504 purchase_receipt_item_service,
505 quant_service,
506 scrap_service,
507 scrap_reason_tag_service,
508 stock_entry_service,
509 stock_entry_item_service,
510 stock_ledger_entry_service,
511 bin_service,
512 stock_reconciliation_service,
513 stock_reconciliation_item_service,
514 package_type_service,
515 storage_category_service,
516 storage_category_capacity_service,
517 putaway_rule_service,
518 lot_service,
519 package_service,
520 warehouse_service,
521 stock_item_service,
522 })
523 }
524}
525
526impl Default for InventoryModuleBuilder {
527 fn default() -> Self {
528 Self::new()
529 }
530}
531
532include!("mod.ext.rs");