Phân tích luồng sau chuyển — inventory/enable-inventory-tracking — vòng 2

Đường dẫn mới tính từ C:/Projects/warehouse-service-wt/ws1/src/main/java/com/softdreams/easypos/warehouse/; PMS = easyposbackend1:src/main/java/vn/softdreams/easypos/service/impl/ProductManagementServiceImpl.java.

F-01 Kiểm yêu cầu bật theo dõi tồn

• Điểm vào: cũ easyposbackend1:.../web/rest/ProductManagementResource.java:766-772 → PMS:3279 → mới presentation/web/inventory/InventoryTrackingController.java:45 → application/inventory/InventoryTrackingService.java:69
• Quy tắc: R-01, R-02, R-03, R-04, R-05, R-06, R-11, R-12, R-13

Sơ đồ luồng mới (theo code thực tế)

sequenceDiagram
    participant W as InventoryTrackingController
    participant S as InventoryTrackingService (@Transactional)
    participant U as CurrentUserPort
    participant I as InitialStockRelationalRepository
    participant P as ProductTrackingRelationalAdapter
    W->>W: Guard.validateInput(validator, request) (mọi vi phạm, 400)
    W->>S: enableInventoryTracking(command)
    S->>U: findCompanyId() — rỗng → 400 TOKEN_EXPIRED; khác comId → 500 COMPANY_NOT_EXISTS_CODE
    S->>I: findDefaultWarehouse(comId) (WH1 ORDER BY id, lấy dòng đầu, Optional)
    S->>S: validateRequest: tracking≠true → 400 FALSE; count null → 400; price null → 400
    S->>P: findUnit(comId, ppuId) — rỗng → 500 PRODUCT_NOT_FOUND; isPrimary null → 500 EXCEPTION_ERROR; false → 500 ENABLE_TRACKING_ERROR
    S->>P: findActiveProduct(comId, productId) — rỗng → 500 PRODUCT_NOT_FOUND; tracking null → 500 EXCEPTION_ERROR; true → 400 INVALID
    S-->>W: (sang F-02) rồi BaseResponseDTO.ok(null, UPDATE_PRODUCT_SUCCESS)

Đối chiếu từng bước

Dữ liệu và side effect

Transaction, khoá, idempotency, tenant

• Ranh giới transaction: cũ là class @Transactional (PMS). Mới đặt @Transactional ở InventoryTrackingService.enableInventoryTracking. Ở F-01 không có lệnh ghi.
• Khoá: cả hai đều không khoá. Hai request đồng thời có thể cùng qua bước kiểm "chưa theo dõi" ở cả cũ lẫn mới, không tệ hơn cũ.
• Idempotency: không áp dụng (API đồng bộ).
• Lọc comId: mọi truy vấn đọc ở F-01 đều có com_id.

Lệch so với luồng mới đã duyệt (spec mục 6)

không

Dev cần chú ý khi review

(F-01 chép nguyên từ vòng 1 — không đổi, không có file trong fix.diff.)

F-02 Tính và ghi sản phẩm, tồn, phiếu khởi tạo

• Điểm vào: cũ PMS:3321-3405 → mới application/inventory/InventoryTrackingService.java:83-97,99-124
• Quy tắc: R-07, R-08, R-09, R-10, R-13

Sơ đồ luồng mới (theo code thực tế)

sequenceDiagram
    participant S as InventoryTrackingService (@Transactional)
    participant Pl as InventoryTrackingPlan
    participant P as ProductTrackingRelationalAdapter (JDBC)
    participant R as InitialRsInoutwardService
    participant I as InitialStockRelationalRepository (JDBC)
    participant K as LegacyInventoryLogKafkaProducer (KafkaTemplate riêng, value StringSerializer)
    S->>P: findUnitsOfProduct (ORDER BY is_primary DESC)
    S->>Pl: plan(units, count, price) (cờ null / rate 0 → EXCEPTION_ERROR)
    S->>P: updateUnits: on_hand/purchase_price đổi → UPDATE toàn cột chuỗi đã làm sạch + audit
    S->>P: enableTracking: UPDATE inventory_tracking=1, in_price, inventory_count, audit, cột chuỗi đổi
    alt không có WH1
        S-->>S: return (commit, 200)
    else có WH1
        loop mỗi ppu is_primary = true
            S->>R: prepare: N2 (>1 → EXCEPTION_ERROR), SequenceService.nextCode(NK), dựng RsInoutward
        end
        S->>I: findStockRows(comId, WH1, ppuIds) — dòng không lô, trùng ppu giữ dòng cuối
        S->>K: send(LegacyInventoryLog) mỗi dòng — JSON thô, key productId, header messageId (ngay, trước commit)
        S->>I: updateOnHand(id, onHand, actor) mỗi dòng
        S->>R: save(phiếu đầu tiên) → RsInoutwardRepository.saveAll
    end

Đối chiếu từng bước

Dữ liệu và side effect

Transaction, khoá, idempotency, tenant

• Ranh giới transaction: một @Transactional ở InventoryTrackingService.enableInventoryTracking; mọi lỗi khác thiếu WH1 đều rollback hết (R-09).
  • KafkaTemplate mới dựng từ copyWithConfigurationOverride của factory chung, nên thuộc tính transactional giữ như factory gốc. Cả cũ lẫn mới đều gửi ngay, không chờ commit (D-07).
• Khoá: không khoá, đặt on_hand tuyệt đối, như cũ.
• Thời điểm phát event: trước khi đặt tồn, lưu phiếu và commit. Request lỗi sau đó thì message đã gửi vẫn ra ngoài, như cũ.
• Lọc comId: các truy vấn đọc có com_id; các lệnh UPDATE theo id (F-logic-3 vòng 1).

Lệch so với luồng mới đã duyệt (spec mục 6)

Không.

Dev cần chú ý khi review