Phân tích luồng sau chuyển — inventory/listener-cogs-completion — vòng 1

F-01 Nhận message, đọc task log, ghi kết quả, ack/nack

• Điểm vào: cũ easyposasync:src/main/java/sds/ep/async/queueListener/CogsCompletionListener.java:34,51 → mới src/main/java/com/softdreams/easypos/warehouse/presentation/messaging/CogsCompletionConsumer.java:58-59
• Quy tắc: R-01, R-02, R-03, R-04, R-05, R-07, R-09

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

sequenceDiagram
    participant Q as Rabbit cogs-completion (container starter, MANUAL)
    participant C as CogsCompletionConsumer
    participant A as CogsCompletionTaskService
    participant T as CogsTaskLogMongoStore
    participant S as CogsComputationService (@Transactional)
    Q->>C: onMessage(raw, taskLogId, channel)
    C->>C: sleeper.sleep(2000)
    C->>A: handle(taskLogId)
    A->>T: find(id) — findOne {_id: ObjectId|String}
    alt không có
        T-->>A: empty
        A-->>C: throw SystemException(TASK_LOG_NOT_FOUND) → ra container, không ack/nack
    else status == 1
        A-->>C: DONE → basicAck
    else
        A->>T: parseCompletion(content) (lỗi → Failure(message của cause))
        A->>A: from/to/ppuIds null → Failure(null); comId null → bỏ tính
        A->>S: calculate(ppuIds, comId, CogsTaskPeriod.toCogsPeriod(from,to)) (xem F-02)
        A->>T: markResult(id, 1,"OK" | 2,msg) — updateFirst $set status/update_time/updater=0, $set|$unset error_message
        A-->>C: SUCCESS → basicAck | FAILED → basicNack(requeue=false)
    end

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

Dữ liệu và side effect

Transaction, khoá, idempotency, tenant

• Ranh giới transaction: cũ chỉ calculateByPpuIds (CH:60) → mới chỉ CogsComputationService.calculate (@Transactional, gọi qua bean khác nên proxy có hiệu lực). Đọc/ghi Mongo và ack nằm ngoài transaction ở cả hai bên.
• Khoá / cập nhật nguyên tử: cả hai không có khoá. Mới dùng $set nên không ghi đè các field khác.
• Idempotency: chỉ dựa vào status == 1 như cũ (D-05, lệch ADR-0301 có chủ đích). Giao trùng đồng thời hoặc crash trước markResult thì tính lại, cũ cũng vậy.
• Lọc comId: tìm task log không lọc com_id (như cũ). comId dùng để tính lấy từ content (CogsCompletionTaskService.java:62-65).

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

Không có. Code đúng như sơ đồ mục 6; có thêm parseCompletion trên port.

Dev cần chú ý khi review

F-02 Tính giá vốn từ nội dung task log

• Điểm vào: cũ easyposasync:…/CogsCompletionListener.java:117 → easyposbase:…/services/impl/BaseCogsHistoryServiceImpl.java:61 → mới CogsCompletionTaskService.java:63-65 → CogsComputationService.java:65-66
• Quy tắc: R-06, R-08

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

sequenceDiagram
    participant A as CogsCompletionTaskService
    participant P as CogsTaskPeriod
    participant S as CogsComputationService (@Transactional)
    participant R as CogsRelationalRepository
    participant TL as CogsTaskLogMongoRabbitAdapter
    A->>P: toCogsPeriod(from, to) — norm/quý theo zone message, from/to đổi sang giờ VN
    A->>S: calculate(ppuIds, comId, period)
    S->>R: findChildren, theo lô 100: findConvertRates, findDetailRows, findBillRows
    S->>TL: publishUpdate (requireValid comId → insert Mongo → send Rabbit) mỗi chunk 1000
    S->>TL: publishUpdate ward deltas
    S->>R: findWarehouseIds, findProductUnitIds, saveHistories (cogs_history)

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

Dữ liệu và side effect

Transaction, khoá, idempotency, tenant

• Ranh giới transaction: cũ @Transactional calculateByPpuIds → mới @Transactional CogsComputationService.calculate, gọi từ bean khác.
• Khoá / cập nhật nguyên tử: không khoá. Cập nhật phiếu/hoá đơn nằm ở consumer COGS_UPDATE_ASYNC, ngoài unit này.
• Idempotency, thời điểm phát event: task log được gửi trước khi commit, như cũ. Tính lại (giao lại message) thì gửi lại task log và INSERT thêm cogs_history, như cũ (D-05).
• Lọc comId: mọi truy vấn và lệnh ghi dùng comId lấy từ content.

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

Không có.

Dev cần chú ý khi review