Phân tích luồng sau chuyển — inventory/listener-cogs-update-async — 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/CogsUpdateAsyncListener.java:44-45 → mới src/main/java/com/softdreams/easypos/warehouse/presentation/messaging/CogsUpdateAsyncConsumer.java:61-62
• Quy tắc: R-01, R-02, R-05

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

sequenceDiagram
    participant Q as Rabbit cogs-update-async
    participant C as CogsUpdateAsyncConsumer.onMessage
    participant A as CogsUpdateTaskService.handle
    participant T as CogsTaskLogMongoStore
    participant B as CogsBatchUpdateService.apply (@Transactional)
    Q->>C: (Message, taskLogId, Channel)
    C->>C: sleeper.sleep(2000)
    C->>A: handle(taskLogId)
    A->>T: find(id) (_id, ObjectId nếu hợp lệ)
    alt không có
        A-->>C: SystemException TASK_LOG_NOT_FOUND → ném ra container, không ack
    else status == 1
        A-->>C: DONE → basicAck
    else
        A->>T: parseUpdate(content)
        alt lỗi Jackson / content null
            A->>T: markResult(id, 2, cause.getMessage())
            A-->>C: FAILED → basicNack(requeue=false)
        else
            A->>B: apply(update)
            alt RuntimeException
                A->>T: markResult(id, 2, NPE→"java.lang.NullPointerException" | cause.toString() | toString())
                A-->>C: FAILED → basicNack(requeue=false)
            else OK
                A->>T: markResult(id, 1, "OK") ($set status, error_message, update_time, updater 0)
                A-->>C: SUCCESS → basicAck
            end
        end
    end

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

Dữ liệu và side effect

Transaction, khoá, idempotency, tenant

• Ranh giới transaction: cũ thì listener không có transaction, chỉ processAsyncCogsUpdate có. Mới thì handle không có, chỉ apply có, gọi qua bean khác nên proxy hoạt động. Ghi Mongo nằm sau commit, giống cũ.
• Khoá / cập nhật nguyên tử: không có ở bước này.
• Idempotency: cả hai chỉ dựa vào status == 1, không dùng IdempotencyStore (D-02).
• Lọc comId: find không lọc com_id/type, giống cũ.

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

không

Dev cần chú ý khi review

F-02 Áp cập nhật đơn giá / tiền vào phiếu, hoá đơn, lệnh huỷ

• Điểm vào: cũ easyposbase:src/main/java/sds/ep/baseservice/services/impl/BaseCogsHistoryServiceImpl.java:225-227 → mới src/main/java/com/softdreams/easypos/warehouse/application/cogs/CogsBatchUpdateService.java:37-38
• Quy tắc: R-03, R-04

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

sequenceDiagram
    participant B as CogsBatchUpdateService.apply (@Transactional)
    participant R as CogsUpdateRelationalRepository (JdbcTemplate)
    B->>B: update.targetTable() (update null → NPE)
    opt RS_INOUTWARD_DETAIL và detailUpdates không rỗng
        B->>B: sortedById (id/phần tử null → NPE)
        B->>R: updateDetails(sorted) → batchUpdate UPDATE rs_inoutward_detail … WHERE id=?
        B->>R: syncProductionOrderPrices(id theo thứ tự gốc) → UPDATE pod … FROM … WHERE rid.id IN (?…)
    end
    opt BILL_PRODUCT và billUpdates không rỗng
        B->>R: updateBills(sorted) → batchUpdate UPDATE bill_product …
    end
    opt RS_INOUTWARD và wardUpdates không rỗng
        B->>R: addWardDeltas(sorted) → batchUpdate UPDATE rs_inoutward SET amount = ISNULL(amount,0)+? …
    end
    Note over R: DataAccessException → SystemException(EXCEPTION_ERROR, cause) → rollback

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

Dữ liệu và side effect

Transaction, khoá, idempotency, tenant

• Ranh giới transaction: cũ bao trọn processAsyncCogsUpdate, mới bao trọn CogsBatchUpdateService.apply; JdbcTemplate dùng chung connection với JpaTransactionManager.
• Khoá: UPDATE nguyên tử ở DB; thứ tự id tăng dần như cũ.
• Idempotency: cộng delta hai lần nếu giao lại sau commit, giống cũ (R-04, D-04). Không phát event.
• Lọc comId: không có ở cả hai bên (D-03).

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

không

Dev cần chú ý khi review