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

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ỹ. Chế độ thu hẹp: F-01 có BatchWriter.java (nằm trong fix.diff) nên viết lại. Các bước không có trong fix.diff lấy kết luận của vòng 1.

F-01 Sửa lô (không id thì tạo)

• Điểm vào: cũ backend:web/rest/BatchesManagementResource.java:47-52 → mới src/main/java/com/softdreams/easypos/warehouse/presentation/web/batch/BatchController.java:67-71 (dùng chung save private ở dòng 74-86 với /create)
• Quy tắc: R-01 … R-09

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

sequenceDiagram
    participant C as Client
    participant BC as BatchController.update/save
    participant MS as BatchManagementService.save
    participant RR as BatchRelationalRepository (translate)
    participant W as BatchWriter
    C->>BC: POST /update BatchSaveRequest
    BC->>BC: Guard.validateInput (400 mọi vi phạm)
    BC->>MS: mapper.toSaveCommand
    MS->>MS: requireCompany (TOKEN_EXPIRED / COMPANY_NOT_EXISTS_CODE)
    MS->>MS: BatchExpiryWarning.requireWithinMax
    MS->>MS: BatchDateParser.parse(mfg, exp); exp < mfg → MFG_DATE_EXCEED_EXP_DATE
    alt id != null
        MS->>RR: findByIdAndComId(id, comId) → rỗng: LOT_NO_NOT_FOUND
    end
    MS->>RR: findDuplicate(comId, lotNo thô, mfg, exp) (nhiều dòng → EXCEPTION_ERROR)
    alt trùng lô khác / id null
        MS-->>BC: duplicated()
    else id null
        MS->>W: lockCompanyBatchCode (sp_getapplock) → countByComId → persist (INSERT ngay)
        MS-->>BC: saved(item đã làm sạch, created=true)
    else có id
        MS->>MS: code null → SystemException(EXCEPTION_ERROR)
        MS->>MS: gán thô: status (BatchStatusPolicy), normalizedName(code, lotNo thô)
        opt BatchDirtyCheck.isDirty
            MS->>RR: save(cleanedForUpdate: LegacyCleanText + updater/update_time)
            RR->>W: em.find (entity managed) → setter → em.flush() (UPDATE @DynamicUpdate, lỗi DB → EXCEPTION_ERROR)
        end
        MS-->>BC: saved(item, lotNo thô, created=false)
    end
    BC-->>C: 200 SUCCESS_UPDATE | SUCCESS_CREATE | status=false LOT_NO_DUPLICATE

Đố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 (BatchesManagementServiceImpl.java:55-57) → mới @Transactional trên BatchManagementService.save (BatchManagementService.java:56). Lệnh UPDATE của nhánh sửa nay chạy trong translate (BatchRelationalRepository.java:149-160). Lỗi DB ném ra SystemException, transaction rollback, trả 500 EXCEPTION_ERROR.
• Khoá / cập nhật nguyên tử: nhánh sửa ở cả cũ và mới đều không khoá, không version, ai ghi sau thì thắng. flush sớm giữ khoá ghi dòng tới commit như cũ, vì sau save không còn bước nào. Lô bị xoá đồng thời + dirty → UPDATE 0 dòng → OptimisticLockException → 500 EXCEPTION_ERROR (cũ 417). Nhánh không id có sp_getapplock theo công ty.
• Idempotency, thời điểm phát event: không có event. Gửi lại cùng request sửa → lần 2 không dirty → không gọi save, không flush, không ghi (như cũ).
• Lọc comId: findByIdAndComId(id, comId token) và findDuplicate đều lọc comId. em.find theo id chỉ chạy sau khi đã xác nhận lô thuộc công ty.

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

Không.

Dev cần chú ý khi review