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

logic-reviewer viết dựa trên code đã implement (không phải thiết kế trong spec), đối chiếu với code cũ. Dev đọc file này cùng changes.diff: mỗi luồng cho biết code mới đi qua những đâu, khác code cũ ở bước nào, và chỗ nào cần đọc kỹ.

Viết tắt đường dẫn mới: ctl/ = presentation/web/batch/, app/ = application/batch/, dom/ = domain/batch/, inf/ = infrastructure/relational/batch/ (gốc src/main/java/com/softdreams/easypos/warehouse/). Cũ: svc = easyposbackend1:src/main/java/vn/softdreams/easypos/service/impl/BatchesManagementServiceImpl.java.

F-01 Lưu lô (tạo; /create kèm id thì sửa)

• Điểm vào: cũ easyposbackend1:src/main/java/vn/softdreams/easypos/web/rest/BatchesManagementResource.java:40-45 → mới ctl/BatchController.java:54-59
• Quy tắc: R-01 … R-14

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

sequenceDiagram
    participant C as Client
    participant BC as BatchController.create
    participant MS as BatchManagementService.save (@Transactional)
    participant BR as BatchRelationalRepository (translate)
    participant BW as BatchWriter
    participant DB as batches
    C->>BC: POST BatchSaveRequest
    BC->>BC: Guard.validateInput (mọi vi phạm, 400)
    BC->>MS: save(BatchWebMapper.toSaveCommand)
    MS->>MS: requireCompany: CurrentUserPort.findCompanyId → TOKEN_EXPIRED 400 / COMPANY_NOT_EXISTS_CODE 500
    MS->>MS: BatchExpiryWarning.requireWithinMax → BatchDateParser.parse(mfg), parse(exp) → MFG_DATE_EXCEED_EXP_DATE
    opt id != null
      MS->>BR: findByIdAndComId(id, comId) → rỗng: LOT_NO_NOT_FOUND 400
    end
    MS->>BR: findDuplicate(comId, lotNo thô, mfg, exp) (JPQL, null → IS NULL)
    alt trùng và (id null hoặc id khác)
      MS-->>BC: BatchSaveResult.duplicated()
      BC-->>C: 200 status=false LOT_NO_DUPLICATE
    else tạo (id null)
      MS->>BW: lockCompanyBatchCode (SELECT TOP 1 batches + sp_getapplock 10s)
      MS->>BW: countByComId → code = "LH"+(n+1)
      MS->>MS: status (BatchStatusPolicy), normalizedName thô → LegacyCleanText.clean(code, lotNo, normalizedName), audit = user/now
      MS->>BW: save → persist (INSERT ngay)
      BC-->>C: 200 SUCCESS_CREATE, data = lô đã làm sạch
    else sửa (id có)
      MS->>MS: code NULL → SystemException EXCEPTION_ERROR
      MS->>MS: gán giá trị thô (lotNo, ngày, status, normalizedName, expiryWarning*) → BatchDirtyCheck.isDirty
      opt dirty
        MS->>BW: save(đã làm sạch, updater/updateTime) → gán entity managed (UPDATE lúc commit)
      end
      BC-->>C: 200 SUCCESS_UPDATE, data.lotNo thô
    end

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

Dữ liệu và side effect

Transaction, khoá, idempotency, tenant

• Ranh giới transaction: cũ @Transactional cấp class trên BatchesManagementServiceImpl (svc:55-57) → mới @Transactional trên BatchManagementService.save (app/BatchManagementService.java:56), gọi từ controller (không self-invocation); kiểm, đếm, ghi trong một transaction; trùng trả bình thường, không ghi.
• Khoá / cập nhật nguyên tử: cũ không khoá → mới khoá theo công ty ngay trước câu đếm, giữ tới commit (D-11). Kiểm trùng vẫn chạy trước khoá như cũ (hai request cùng số lô/ngày đồng thời vẫn lọt trùng — giống cũ). Nhánh sửa không khoá, không version — giống cũ.
• Idempotency, thời điểm phát event: không có event/consumer.
• Lọc comId: mọi truy vấn có comId (= companyId token); BatchWriter.save nhánh sửa find theo id nhưng id đã được xác nhận thuộc comId ở bước 6 cùng transaction.

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

Không lệch thứ tự bước. Chi tiết thêm so với sơ đồ: nhánh sửa không gọi save khi không dirty; khoá nằm trong BatchWriter (thêm lớp) thay vì trực tiếp ở BatchRelationalRepository.

Dev cần chú ý khi review