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

Viết tắt: WHS = easyposbase:src/main/java/sds/ep/baseservice/services/impl/BaseWarehouseServiceImpl.java, CHS = easyposbase:src/main/java/sds/ep/baseservice/services/impl/BaseCogsHistoryServiceImpl.java, TLS = easyposbase:src/main/java/sds/ep/baseservice/services/impl/BaseTaskLogServiceImpl.java. Đường dẫn mới tính từ C:/Projects/warehouse-service-wt/ws1/src/main/java/com/softdreams/easypos/warehouse/.

F-01 Nhận yêu cầu, chọn nhánh, gửi task log tính sau

• Điểm vào: cũ easyposbackend1:src/main/java/vn/softdreams/easypos/web/rest/WarehouseResource.java:136-140 → mới presentation/web/inventory/CogsController.java:42-54
• Quy tắc: R-01, R-02, R-03, R-04, R-05, R-15, R-16, R-17, R-18

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

sequenceDiagram
    participant C as Client
    participant W as CogsController.calculateCogs
    participant S as CogsCalculationService.calculateCogs (@Transactional)
    participant CC as CurrentCompanyService.requireCompanyOfCurrentUser
    participant R as CogsRelationalRepository
    participant A as CogsTaskLogMongoRabbitAdapter.publishCompletion
    participant Q as SendQueueConfigRelationalAdapter.requireValid
    C->>W: POST /api/client/page/warehouse/cogs/calculate
    W->>S: calculateCogs(InventoryWebMapper.toCalculateCogsCommand)
    S->>CC: comId (null/khác token → 400)
    alt fromDate/toDate null
      S-->>W: Outcome.fail(null)
    end
    S->>S: CogsPeriod.of (00:00 VN, normDate, quarter)
    opt paramCheckAll == TRUE
      S->>R: findPrimaryPpuIds(comId)
    end
    alt rỗng/null
      S-->>W: fail(PRODUCT_LIST_NOT_EMPTY)
    else size > 100 hoặc checkAll
      loop mỗi lô 100 (subList, giữ thứ tự/trùng)
        S->>A: CogsCompletionTask(batch, comId, from, to)
        A->>Q: config.business_type + company.service
        A->>A: mongoTemplate.insert(Document) task_log_reference
        A->>A: rabbitTemplate.send(amq.direct, cogs-completion, "id" JSON) — lỗi AMQP chỉ log
      end
      S-->>W: success(CALCULATE_COGS_SUCCESSFULLY, null, size)
    else ≤ 100
      S->>S: CogsComputationService.calculate (F-02)
    end
    W-->>C: 200 BaseResponseDTO{code, reason, success=true, data, count}

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

Dữ liệu và side effect

Transaction, khoá, idempotency, tenant

• Ranh giới transaction: cũ: class @Transactional của WHS:66, processMongoTaskLog tham gia → mới: @Transactional ở CogsCalculationService.java:52.
• Khoá / cập nhật nguyên tử: cả hai đều không có.
• Idempotency, thời điểm phát: task log ghi Mongo và gửi Rabbit ngay, trước commit SQL, ở cả cũ và mới (D-05). Gọi lại API thì tạo task log mới ở cả hai.
• Lọc comId: có trong findPrimaryPpuIds (cả ppu và p); comId lấy từ requireCompanyOfCurrentUser (D-01).

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

Không có.

Dev cần chú ý khi review

F-02 Tính giá vốn đồng bộ, gửi cập nhật, ghi lịch sử

• Điểm vào: cũ CHS:59-124 (gọi từ WHS:1923) → mới application/cogs/CogsComputationService.java:65-91 (gọi từ CogsCalculationService.java:74)
• Quy tắc: R-06 … R-15, R-17, R-18

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

sequenceDiagram
    participant S as CogsComputationService.calculate (@Transactional, tham gia)
    participant R as CogsRelationalRepository
    participant I as CogsItem
    participant A as CogsTaskLogMongoRabbitAdapter.publishUpdate
    S->>R: findChildren(comId, parentPpuIds)
    S->>S: HashSet(parent) ∪ children → ArrayList → subList 100
    loop mỗi lô
      S->>R: findConvertRates, findDetailRows, findBillRows
      S->>I: aggregate(row, rate(ppu dòng), normFrom) theo master
      S->>I: calculate() mọi item
      S->>A: RS_INOUTWARD_DETAIL (chunk 1000) — phiếu xuất trong kỳ
      S->>A: BILL_PRODUCT (chunk 1000) — item master đã có
    end
    S->>A: RS_INOUTWARD (TreeMap theo id, chunk 1000)
    alt items rỗng
      S-->>S: success(EMPTY_DATA_PROCESSS)
    else
      S->>R: findWarehouseIds, findProductUnitIds
      S->>R: saveHistories (batch 2000)
      S-->>S: success(CALCULATE_COGS_SUCCESSFULLY, results, count = số item chính)
    end

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

Dữ liệu và side effect

Transaction, khoá, idempotency, tenant

• Ranh giới transaction: cũ: calculateByPpuIds @Transactional tham gia transaction của WHS → mới: CogsComputationService.calculate @Transactional tham gia CogsCalculationService, gọi qua bean khác nên không bị self-invocation. JdbcTemplate dựng từ cùng DataSource (cùng mẫu với các adapter khác trong repo) nên dùng chung connection của transaction.
• Khoá / cập nhật nguyên tử: không có ở cả hai. Hai request song song cùng ppu đều ghi cogs_history và gửi update như cũ.
• Idempotency, thời điểm phát: task log gửi trước INSERT cogs_history và trước commit. Nếu INSERT lỗi thì task log đã gửi vẫn còn (D-05). Phía tiêu thụ giữ nguyên (status = 1 bỏ qua).
• Lọc comId: mọi SQL đều có com_id (rio.com_id, b.com_id, inventory.com_id, ppu.com_id), như cũ. Truy vấn theo lô 100, không có N+1.

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

Không có.

Dev cần chú ý khi review