Phân tích luồng sau chuyển — warehouse/create — vòng 2

Kết quả nguyên văn của agent logic-reviewer (phần sau dòng === PHÂN TÍCH LUỒNG ===).

F-01 Tạo kho mới (id không gửi)

• Điểm vào: cũ easyposbackend1:src/main/java/vn/softdreams/easypos/web/rest/WarehouseResource.java:52-57 → mới src/main/java/com/softdreams/easypos/warehouse/presentation/web/warehouse/WarehouseController.java:50-58
• Quy tắc: R-01, R-02, R-03, R-04, R-05, R-06, R-07, R-08, R-09, R-10, R-11, R-12, R-15, R-16

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

sequenceDiagram
    participant C as Client
    participant WC as WarehouseController.createWarehouse
    participant WS as WarehouseManagementService.saveWarehouse (@Transactional)
    participant CC as CurrentCompanyService.requireCompanyOfCurrentUser
    participant WR as WarehouseRelationalRepository
    participant SQ as SequenceService.nextCode
    participant SS as SequenceSeedJdbcRepository.findSeed
    participant LR as LegacyRedisSequenceReader
    participant RC as RedisSequenceCounter
    participant W as Warehouse / WarehouseDuplicatePolicy
    C->>WC: POST /create
    WC->>WC: Guard.validateInput(validator, request)
    WC->>WS: saveWarehouse(toSaveCommand(request))
    WS->>CC: requireCompanyOfCurrentUser(comId)
    WS->>WR: lockCompanyWarehouses (SELECT TOP 1 + sp_getapplock, 10s)
    WS->>WS: WarehouseAudit(findUserId().orElse(0), now(clock))
    loop generateCode ≤ 10
        WS->>SQ: nextCode(comId,"WH")
        SQ->>RC: current (HGET {comId}_SEQ_NEW WH)
        alt chưa có
            SQ->>SS: findSeed → warehouseSeed
            SS->>LR: findWarehouseSequence (GET {comId}_SEQ)
            SS->>SS: không có → SELECT COUNT(*) warehouse +1
            SQ->>RC: initialize (HSET)
        else đã có
            SQ->>RC: increase (HINCRBY 1)
        end
        WS->>WR: existsBySku(comId, code)
    end
    WS->>W: Warehouse.create(command, code, audit) (copyFrom, status=true, cleanText, audit)
    WS->>WR: findNameSkus(comId)
    WS->>W: WarehouseDuplicatePolicy.validate(rows, command)
    WS->>W: validateDefaultWarehouse()
    WS->>WR: save → JpaRepository.save(toEntity) (INSERT identity)
    WS-->>WC: WarehouseResult
    WC-->>C: BaseResponseDTO.ok(WarehouseResponse, SUCCESS_CREATE)

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

Dữ liệu và side effect

Transaction, khoá, idempotency, tenant

• Ranh giới transaction: cũ: class @Transactional BaseWarehouseServiceImpl.java:66 bao sinh mã, kiểm trùng và INSERT → mới: @Transactional ở WarehouseManagementService.java:74, bao khoá, đọc và INSERT. Controller gọi qua proxy, không có self-invocation. Redis nằm ngoài transaction ở cả hai bên.
• Khoá / cập nhật nguyên tử: cũ không khoá → mới dùng sp_getapplock Exclusive, owner Transaction, timeout 10s (kết quả < 0 → 500). Khoá chỉ bảo vệ giữa các request của service; monolith không lấy khoá này (D-05).
• Idempotency, thời điểm phát event: không có event; REST đồng bộ.
• Lọc comId: có ở mọi truy vấn (count, exists, findNameSkus, lệnh khoá) và ở Redis key.

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

Không có lệch thực chất. cleanText() của F-01 chạy trong Warehouse.create (Warehouse.java:80) chứ không chạy ngay trước save như sơ đồ. Kết quả lưu không đổi.

Dev cần chú ý khi review

F-02 /create gửi kèm id → sửa kho

• Điểm vào: cũ easyposbackend1:src/main/java/vn/softdreams/easypos/web/rest/WarehouseResource.java:52-57 → mới src/main/java/com/softdreams/easypos/warehouse/presentation/web/warehouse/WarehouseController.java:50-58
• Quy tắc: R-01, R-02, R-05, R-06, R-08, R-09, R-10, R-11, R-12, R-13, R-14, R-15, R-16

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

sequenceDiagram
    participant C as Client
    participant WC as WarehouseController.createWarehouse
    participant WS as WarehouseManagementService.saveWarehouse (@Transactional)
    participant CC as CurrentCompanyService
    participant WR as WarehouseRelationalRepository
    participant W as Warehouse / WarehouseDuplicatePolicy
    participant BP as BillRelationalAdapter
    C->>WC: POST /create {id,...}
    WC->>WC: Guard.validateInput
    WC->>WS: saveWarehouse(command)
    WS->>CC: requireCompanyOfCurrentUser(comId)
    WS->>WR: lockCompanyWarehouses(comId)
    WS->>WR: findById(comId,id) → JPA findByComIdAndId → toDomain (không có → SystemException WAREHOUSE_NOT_FOUND)
    WS->>W: warehouse.update(command, audit): copyFrom, status=activeStatus, so businessValues; đổi → cleanText + updater/updateTime
    WS->>WR: findNameSkus(comId)
    WS->>WS: duplicateRows: thay dòng id của kho bằng warehouse.nameSku()
    WS->>W: WarehouseDuplicatePolicy.validate (đếm, chạm 2 → lỗi)
    WS->>W: validateDefaultWarehouse()
    opt !isActive
        WS->>BP: countProcessingBills(comId, id) > 0 → BadRequest(WAREHOUSE_STATUS_FALSE_CHECK_BILL, tên hiện tại)
    end
    WS->>WR: save → findByComIdAndId (instance đã managed) → mapper.apply → toResult
    Note over WR: UPDATE (@DynamicUpdate) lúc commit, chỉ cột thay đổi
    WC-->>C: BaseResponseDTO.ok(..., SUCCESS_UPDATE)

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

Dữ liệu và side effect

Transaction, khoá, idempotency, tenant

• Ranh giới transaction: một @Transactional bao mọi thao tác, ở cả cũ và mới. Lỗi kiểm trùng, WH1 hoặc bill → rollback. Bên cũ rollback cả UPDATE đã flush; bên mới chưa ghi gì.
• Khoá / cập nhật nguyên tử: cũ không khoá, ghi đè toàn bộ bằng dữ liệu request → mới khoá theo công ty trước khi đọc kho (D-05). Không có đọc-sửa-ghi số lượng.
• Idempotency, event: không có.
• Lọc comId: findByComIdAndId, findNameSkus, COUNT bill đề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