优化

2026-09-18 09:59:07 +08:00
parent 13a8dde0a5
commit 4f59f7bd28
45 changed files with 358 additions and 157 deletions
@@ -1438,7 +1438,7 @@ CREATE TABLE fl_consumed_event (
 CREATE TABLE fl_container_booking (
  id bigint unsigned NOT NULL COMMENT '货柜预订ID（雪花ID）',
  booking_no varchar(40) NOT NULL COMMENT '平台唯一货柜预订单号',
-  container_no varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '集装箱号；确认前允许修订',
+  container_no varchar(64) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL COMMENT '真实集装箱号权威快照；同一订舱内唯一，不同提单允许复用；确认前允许修订',
  cabinet_no varchar(64) NOT NULL COMMENT '平台唯一内部柜号',
  source_type varchar(24) NOT NULL DEFAULT 'SIMULATION' COMMENT '记录来源：SIMULATION内部模拟柜、OCEAN_BOOKING订舱真实柜',
  record_status varchar(16) NOT NULL DEFAULT 'ACTIVE' COMMENT '记录状态：ACTIVE可操作、MERGED已合并历史',
@@ -1494,7 +1494,8 @@ CREATE TABLE fl_container_booking (
  PRIMARY KEY (id),
  UNIQUE KEY uk_container_booking_no (booking_no),
  UNIQUE KEY uk_container_booking_cabinet (cabinet_no),
-  UNIQUE KEY uk_container_booking_container_no (container_no),
+  UNIQUE KEY uk_container_booking_ocean_container (ocean_booking_id,container_no),
+  KEY idx_container_booking_container_no (container_no,updated_at,id),
  KEY idx_container_booking_merge (record_status,merged_into_container_booking_id),
  KEY idx_container_booking_warehouse (warehouse_id,updated_at,id),
  KEY idx_container_booking_voyage (voyage_no,updated_at),
@@ -3368,6 +3369,7 @@ CREATE TABLE fl_ocean_booking (
  version int unsigned NOT NULL DEFAULT '0' COMMENT '乐观锁版本号',
  PRIMARY KEY (id),
  UNIQUE KEY uk_ocean_booking_no (booking_no),
+  UNIQUE KEY uk_ocean_booking_bill_of_lading (bill_of_lading_no),
  KEY idx_ocean_booking_customer (customer_id,status,updated_at,id),
  KEY idx_ocean_booking_voyage (vessel_name,voyage_no,updated_at),
  CONSTRAINT chk_ocean_booking_carrier_code CHECK (((carrier_code is null) or (carrier_code in (_utf8mb4'MATSON',_utf8mb4'SML',_utf8mb4'ZIM',_utf8mb4'COSCO',_utf8mb4'EMC',_utf8mb4'HEDE',_utf8mb4'OTHER')))),
@@ -73,7 +73,7 @@
 - Order 渠道变更门禁必须检查装柜或后续状态、PDA task、预装、分柜及同柜组兼容性；任何不确定结果均失败关闭。`ORDER_DECLARATION_UPDATED_V1` 消费必须校验订单号/入仓码归属，永久保留 `eventId + payload hash` 幂等历史并按版本单调更新申报投影；不得覆盖仓库实测、箱码、测量审核或已确认费用。
 - 订舱状态固定为 `DRAFT → RELEASED`：草稿允许资料不完整并可替换或删除，放舱时校验完整持久化聚合，放舱后永久只读。创建草稿和放舱都只维护订舱聚合、三类参与方及柜型需求，不创建真实 `containerNo`、货柜行或分配关系；真实货柜只在后续提柜关联时占用已放舱柜型需求。
 - 订舱柜型需求至少一项、最多 20 项，数量必须为正整数，容量和限重必须匹配平台柜型规格。起运仓必须是启用的国内中转仓；物流渠道必须来自该仓当前 ACTIVE 价格版本，服务端保存渠道名称快照，渠道失效时失败关闭。
- 订舱号统一使用 `OB-yyMMdd-####`，按北京时间创建日每日独立递增且单日最多 9999；不得以实体 ID 拼接生成。放舱不要求真实柜号，也不得为满足放舱校验伪造柜号。
+- 订舱号统一使用 `OB-yyMMdd-####`，按北京时间创建日每日独立递增且单日最多 9999；不得以实体 ID 拼接生成。提单号在订舱主表全局唯一，柜次表只保存快照；真实集装箱号只在同一订舱内唯一，不同提单允许复用。放舱不要求真实柜号，也不得为满足放舱校验伪造柜号。
 - 订舱列表 `containerCount` 固定为该订舱全部柜型需求 `quantity` 之和，与真实柜关联/解除无关；关联候选只返回 `RELEASED`、剩余数量大于 0 且 `warehouseId + channelCode + containerType` 精确匹配的需求，由服务端集合查询 ACTIVE 分配量。前端不得扇出详情计算或用已关联柜数覆盖该字段，最终关联命令仍须重验目标货柜可修改性。
 - 拖车预约是平台级订舱聚合，不是客户或柜次资源：请求、实体、查询、响应和附件不得恢复 `customerId/customerName`，公开 DTO 也不得出现 `containerBookingId/loadingPlanId/cabinetNo/containerNo`。创建候选只返回有提单号、ACTIVE `BOOKING_CONFIRMATION` 或 `BILL_OF_LADING` 且没有非终态拖车单的 `RELEASED` 订舱；创建或编辑只冻结订舱仓库/提单与 TRUCKING/DOMESTIC 国内拖车供应商快照。每订舱通过查询锁与唯一约束最多一张非终态预约，重复创建返回现有派车单号；PDA 装柜完成不得改变拖车状态；只有订舱全部柜型需求均已关联且每柜全部入仓绑定确认国内离仓，才自动完成（含草稿/晚提交）。离仓、拖车创建/编辑/操作统一先锁订舱，完成状态、`AUTO_COMPLETE` 历史、按实装体积守恒分摊的柜次应付及 Finance Outbox 同事务落库；取消/异常单不自动恢复，已有有效或完成单不得重复创建。应付拖车费仅人民币 RMB（财务快照为 CNY），固定使用 `FEE_TYPE_108`，关联 ACTIVE/TRUCKING/DOMESTIC 供应商，零金额不生成费用；正金额缺归属、有效体积或费用配置时失败关闭，不丢费、不伪造均分。手工 DEPART/COMPLETE 动作已移除。附件使用 `tenantId=0 + TRUCK_APPOINTMENT_ATTACHMENT + appointmentId`，提单文件继续归订舱。
 - 海外仓业务船节点任务从确认柜子离开国内仓库后启用，必须绑定真实订舱和柜次；十个标准节点、预计/实际时间、异常事实、供应商缺失节点和还柜停止规则统一以 `../../docs/海外仓业务/船节点标准化契约.md` 为准。`CarrierScheduleQuery` 的正常业务查询槽位固定为 `Asia/Shanghai` 每日 09:00、12:30、16:00；每分钟任务只扫描已到期 `next_allowed_at`，不是每分钟请求船司。成功、无变化、需人工或永久失败进入下一固定槽位；仅技术性 `RETRYABLE_FAILURE` 在当前槽内按15/30分钟退避，含首次最多3次且不得跨下一槽，实际 `EMPTY_RETURNED` 后停止。错过的正常槽位直接顺延，不在服务恢复时补跑；单轮按受控批次持续领取并受最大任务数保护。租约、调度尝试和内部停止入口不得暴露为平台页面 API，外部失败不得推进业务节点，不得在国内货柜履约另建查询任务。
@@ -168,9 +168,6 @@ public interface ContainerBookingMapper extends BaseMapper<ContainerBookingEntit
                         @Param("version") int version, @Param("operatorId") long operatorId,
                         @Param("operatorName") String operatorName);

-    @Select("SELECT * FROM fl_container_booking WHERE container_no=#{containerNo} AND record_status='ACTIVE'")
-    ContainerBookingEntity selectActiveByContainerNo(@Param("containerNo") String containerNo);
-
    @Update("""
        UPDATE fl_container_booking SET unloading_completed_at=#{unloadingCompletedAt},
          unloading_photo_uploaded_at=#{photoUploadedAt}, estimated_empty_reported_at=#{estimatedEmptyReportedAt},
@@ -39,7 +39,7 @@ public final class OceanBookingDtos {
        }
    }

-    public record LinkCandidate(Long oceanBookingId, String bookingNo, Long requirementId,
+    public record LinkCandidate(Long oceanBookingId, String bookingNo, String billOfLadingNo, Long requirementId,
                                String containerType, BigDecimal capacityCbm, BigDecimal maxWeightKg,
                                int requiredQuantity, long allocatedQuantity, long remainingQuantity,
                                String customerName, String warehouseName, String channelName) {}
@@ -55,7 +55,7 @@ public interface OceanBookingMapper extends BaseMapper<OceanBookingEntity> {

    @Select("""
        <script>
-        SELECT booking.id ocean_booking_id,booking.booking_no,requirement.id requirement_id,
+        SELECT booking.id ocean_booking_id,booking.booking_no,booking.bill_of_lading_no,requirement.id requirement_id,
          requirement.container_type,requirement.capacity_cbm,requirement.max_weight_kg,
          requirement.quantity required_quantity,
          COALESCE(allocated.allocated_quantity,0) allocated_quantity,
@@ -38,6 +38,12 @@ public class OceanBookingRepository {
    }
    public OceanBookingEntity find(long id) { return bookings.selectById(id); }
    public OceanBookingEntity findForUpdate(long id) { return bookings.selectForUpdate(id); }
+    public boolean billOfLadingNoExists(String billOfLadingNo, Long excludedId) {
+        if (billOfLadingNo == null) return false;
+        return bookings.selectCount(new LambdaQueryWrapper<OceanBookingEntity>()
+            .eq(OceanBookingEntity::getBillOfLadingNo, billOfLadingNo)
+            .ne(excludedId != null, OceanBookingEntity::getId, excludedId)) > 0;
+    }
    public void insert(OceanBookingEntity value) { bookings.insert(value); }
    public int transition(long id, String from, String to, int version, long operatorId, String operatorName) {
        return bookings.transition(id, from, to, version, operatorId, operatorName);
@@ -102,9 +108,6 @@ public class OceanBookingRepository {
    public void replaceParties(long id, List<OceanBookingPartyEntity> values) { parties.delete(new LambdaQueryWrapper<OceanBookingPartyEntity>().eq(OceanBookingPartyEntity::getOceanBookingId, id)); values.forEach(parties::insert); }
    public void replaceRequirements(long id, List<OceanBookingContainerRequirementEntity> values) { requirements.delete(new LambdaQueryWrapper<OceanBookingContainerRequirementEntity>().eq(OceanBookingContainerRequirementEntity::getOceanBookingId, id)); values.forEach(requirements::insert); }
    public OceanBookingContainerRequirementEntity requirement(long id, long requirementId) { return requirements.selectOne(new LambdaQueryWrapper<OceanBookingContainerRequirementEntity>().eq(OceanBookingContainerRequirementEntity::getOceanBookingId, id).eq(OceanBookingContainerRequirementEntity::getId, requirementId)); }
-    public boolean containerNoExists(String containerNo) {
-        return containerBookings.containerNoExists(containerNo, null);
-    }
    public void insertContainer(ContainerBookingEntity value) { containerBookings.insert(value); }
    public void insert(OceanBookingContainerAllocationEntity value) { allocations.insert(value); }
    public int reassignAllocation(long sourceId, long targetId) {
@@ -24,6 +24,7 @@ import com.fasterxml.jackson.databind.ObjectMapper;
 import jakarta.annotation.Resource;
 import org.springframework.stereotype.Service;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.dao.DuplicateKeyException;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.StringUtils;
 import feign.FeignException;
@@ -110,9 +111,11 @@ public class OceanBookingService {
        value.setBookingNo(documentNumbers.next("OB"));
        value.setStatus(OceanBookingStatus.DRAFT.name());
        copy(value, request.data(), resolved);
+        requireUniqueBillOfLadingNo(value.getBillOfLadingNo(), null);
        value.setCreatedBy(operatorId); value.setCreatedByName(operatorName);
        value.setUpdatedBy(operatorId); value.setUpdatedByName(operatorName); value.setVersion(0);
-        repository.insert(value);
+        try { repository.insert(value); }
+        catch (DuplicateKeyException exception) { throw duplicateBillOfLadingNo(); }
        repository.replaceParties(value.getId(), parties(value.getId(), request.data().parties()));
        List<OceanBookingContainerRequirementEntity> requirements = requirements(
            value.getId(), request.data().containerRequirements());
@@ -132,7 +135,10 @@ public class OceanBookingService {
        validateDraftStructure(request.data());
        ResolvedDraft resolved = resolveDraft(request.data());
        copy(before, request.data(), resolved);
-        if (repository.updateDraft(before, request.expectedVersion(), operatorId, operatorName) != 1) throw concurrent();
+        requireUniqueBillOfLadingNo(before.getBillOfLadingNo(), id);
+        try {
+            if (repository.updateDraft(before, request.expectedVersion(), operatorId, operatorName) != 1) throw concurrent();
+        } catch (DuplicateKeyException exception) { throw duplicateBillOfLadingNo(); }
        repository.replaceParties(id, parties(id, request.data().parties()));
        repository.replaceRequirements(id, requirements(id, request.data().containerRequirements()));
        OceanBookingEntity after = required(id);
@@ -294,6 +300,14 @@ public class OceanBookingService {
        v.setRemark(trim(d.remark()));
    }

+    private void requireUniqueBillOfLadingNo(String billOfLadingNo, Long excludedId) {
+        if (repository.billOfLadingNoExists(billOfLadingNo, excludedId)) throw duplicateBillOfLadingNo();
+    }
+
+    private static BizException duplicateBillOfLadingNo() {
+        return conflict("提单号已存在，请检查是否重复创建订舱");
+    }
+
    private void validateMasterData(OceanBookingEntity booking) {
        resolveCustomer(booking.getCustomerId(), booking.getCustomerName());
        resolveCarrier(booking.getShippingCompanyId(), booking.getShippingCompanyName(), booking.getCarrierCode());
@@ -22,9 +22,10 @@ public class ContainerRepository {
    public ContainerBookingEntity findForUpdate(long id) { return mapper.selectBookingForUpdate(id); }
    public ContainerBookingEntity findActiveForUpdate(long id) { return mapper.selectActiveBookingForUpdate(id); }
    public boolean departed(long id) { return mapper.hasActiveOutboundDeparture(id) > 0; }
-    public boolean containerNoExists(String no, Long excludedId) {
+    public boolean containerNoExists(long oceanBookingId, String no, Long excludedId) {
        if (no == null) return false;
        return mapper.selectCount(new LambdaQueryWrapper<ContainerBookingEntity>()
+            .eq(ContainerBookingEntity::getOceanBookingId, oceanBookingId)
            .eq(ContainerBookingEntity::getContainerNo, no)
            .ne(excludedId != null, ContainerBookingEntity::getId, excludedId)) > 0;
    }
@@ -93,7 +93,9 @@ public class ContainerService {
        if (requirement == null) throw new BizException(ResultCode.NOT_FOUND, "订舱箱型需求不存在");
        long allocated = oceanBookings.activeLinkedCount(request.oceanBookingId(), request.requirementId());
        if (allocated >= requirement.getQuantity()) throw conflict("该订舱箱型需求已达到数量上限");
-        if (containerNo != null && repository.containerNoExists(containerNo, id)) throw conflict("集装箱号已存在");
+        if (containerNo != null && repository.containerNoExists(request.oceanBookingId(), containerNo, id)) {
+            throw conflict("当前提单下集装箱号已存在");
+        }
        if (!java.util.Objects.equals(container.getWarehouseId(), booking.getWarehouseId())
            || !java.util.Objects.equals(container.getChannelGroupCode(), booking.getChannelCode())
            || !java.util.Objects.equals(container.getContainerType(), requirement.getContainerType())) {
@@ -105,7 +107,7 @@ public class ContainerService {
                throw conflict("真实订舱柜已被消费或货柜版本发生变化，请刷新后重试");
            }
        } catch (DuplicateKeyException exception) {
-            throw conflict("集装箱号已存在");
+            throw conflict("当前提单下集装箱号已存在");
        }
        OceanBookingContainerAllocationEntity allocation = new OceanBookingContainerAllocationEntity(); allocation.setId(IdWorker.getId()); allocation.setOceanBookingId(request.oceanBookingId()); allocation.setRequirementId(request.requirementId()); allocation.setContainerBookingId(id); allocation.setAllocatedBy(operatorId); allocation.setAllocatedByName(operatorName); allocation.setAllocatedAt(LocalDateTime.now()); oceanBookings.insert(allocation);
        return required(id);
@@ -126,13 +128,15 @@ public class ContainerService {
            throw conflict("已进入PDA、证据、单证或不可逆装柜阶段，不能补录真实柜号");
        }
        String containerNo = Iso6346ContainerNumber.require(requestedContainerNo);
-        if (repository.containerNoExists(containerNo, id)) throw conflict("集装箱号已存在");
+        if (repository.containerNoExists(container.getOceanBookingId(), containerNo, id)) {
+            throw conflict("当前提单下集装箱号已存在");
+        }
        try {
            if (repository.assignRealContainerNo(id, containerNo, expectedVersion, operatorId, operatorName) != 1) {
                throw conflict("真实柜号已被补录或货柜版本发生变化，请刷新后重试");
            }
        } catch (DuplicateKeyException exception) {
-            throw conflict("集装箱号已存在");
+            throw conflict("当前提单下集装箱号已存在");
        }
        return required(id);
    }
@@ -463,9 +463,10 @@ public class LoadingListService {
            && java.util.Objects.equals(before.getVoyageNo(), voyageNo)) {
            return repository.preloadDetail(before);
        }
-        if (containerNo != null
-            && containerRepository.containerNoExists(containerNo, before.getContainerBookingId())) {
-            throw conflict("集装箱号已存在");
+        if (containerNo != null && before.getOceanBookingId() != null
+            && containerRepository.containerNoExists(before.getOceanBookingId(), containerNo,
+                before.getContainerBookingId())) {
+            throw conflict("当前提单下集装箱号已存在");
        }
        try {
            int updated = initialContainerFill
@@ -477,7 +478,7 @@ public class LoadingListService {
                throw conflict("预装计划、PDA领取或物理作业状态已变化，请刷新后重试");
            }
        } catch (DuplicateKeyException exception) {
-            throw conflict("集装箱号已存在");
+            throw conflict("当前提单下集装箱号已存在");
        }
        repository.appendHistory(planId, operationId, "UPDATE_PRELOAD_TRANSPORT",
            before.getPlanStatus(), before.getPlanStatus(), json(snapshot(before)),
@@ -36,6 +36,7 @@ CREATE TABLE IF NOT EXISTS fl_ocean_booking (
  version INT UNSIGNED NOT NULL DEFAULT 0 COMMENT '乐观锁版本号',
  PRIMARY KEY (id),
  UNIQUE KEY uk_ocean_booking_no (booking_no),
+  UNIQUE KEY uk_ocean_booking_bill_of_lading (bill_of_lading_no),
  KEY idx_ocean_booking_customer (customer_id,status,updated_at,id),
  KEY idx_ocean_booking_voyage (vessel_name,voyage_no,updated_at),
  CONSTRAINT chk_ocean_booking_customer CHECK (customer_id > 0),
@@ -52,6 +53,18 @@ ALTER TABLE fl_ocean_booking
  MODIFY COLUMN customer_id BIGINT UNSIGNED NULL COMMENT '可选客户ID快照',
  MODIFY COLUMN customer_name VARCHAR(128) NULL COMMENT '可选客户名称快照';

+SET @ocean_add_bill_unique = (
+  SELECT IF(COUNT(*) = 0,
+    'ALTER TABLE fl_ocean_booking ADD UNIQUE KEY uk_ocean_booking_bill_of_lading (bill_of_lading_no)',
+    'SELECT 1')
+    FROM information_schema.statistics
+   WHERE table_schema=DATABASE() AND table_name='fl_ocean_booking'
+     AND index_name='uk_ocean_booking_bill_of_lading'
+);
+PREPARE ocean_bill_unique_stmt FROM @ocean_add_bill_unique;
+EXECUTE ocean_bill_unique_stmt;
+DEALLOCATE PREPARE ocean_bill_unique_stmt;
+
 -- Recreate triggers and the current two-state constraint on repeatable initialization.
 DROP TRIGGER IF EXISTS trg_ocean_booking_before_update;
 DROP TRIGGER IF EXISTS trg_ocean_party_before_insert;
@@ -36,7 +36,7 @@ CREATE TABLE IF NOT EXISTS fl_document_sequence (
 CREATE TABLE IF NOT EXISTS fl_container_booking (
  id BIGINT UNSIGNED NOT NULL COMMENT '货柜预订ID（雪花ID）',
  booking_no VARCHAR(40) NOT NULL COMMENT '平台唯一货柜预订单号',
-  container_no VARCHAR(64) NULL COMMENT '国内唯一权威真实集装箱号；ISO 6346标准格式；订舱关联可选写入、提柜后可原子补录、预装纠错命令可修改',
+  container_no VARCHAR(64) NULL COMMENT '国内柜次真实集装箱号权威快照；ISO 6346标准格式；同一订舱内唯一，不同提单允许复用；订舱关联可选写入、提柜后可原子补录、预装纠错命令可修改',
  cabinet_no VARCHAR(64) NOT NULL COMMENT '平台唯一内部柜号',
  source_type VARCHAR(24) NOT NULL DEFAULT 'SIMULATION' COMMENT '记录来源：SIMULATION内部模拟柜、OCEAN_BOOKING订舱真实柜',
  record_status VARCHAR(16) NOT NULL DEFAULT 'ACTIVE' COMMENT '记录状态：ACTIVE可操作、MERGED已合并历史',
@@ -92,7 +92,8 @@ CREATE TABLE IF NOT EXISTS fl_container_booking (
  PRIMARY KEY (id),
  UNIQUE KEY uk_container_booking_no (booking_no),
  UNIQUE KEY uk_container_booking_cabinet (cabinet_no),
-  UNIQUE KEY uk_container_booking_container_no (container_no),
+  UNIQUE KEY uk_container_booking_ocean_container (ocean_booking_id,container_no),
+  KEY idx_container_booking_container_no (container_no,updated_at,id),
  KEY idx_container_booking_merge (record_status,merged_into_container_booking_id),
  KEY idx_container_booking_warehouse (warehouse_id, updated_at, id),
  KEY idx_container_booking_voyage (voyage_no, updated_at),
@@ -203,9 +204,17 @@ BEGIN
    ALTER TABLE fl_container_booking ADD COLUMN pickup_code_updated_at DATETIME(3) NULL
      COMMENT 'PU码最后填写时间' AFTER pickup_code_updated_by_name;
  END IF;
-  IF NOT EXISTS (SELECT 1 FROM information_schema.statistics WHERE table_schema=DATABASE()
+  IF EXISTS (SELECT 1 FROM information_schema.statistics WHERE table_schema=DATABASE()
      AND table_name='fl_container_booking' AND index_name='uk_container_booking_container_no') THEN
-    ALTER TABLE fl_container_booking ADD UNIQUE KEY uk_container_booking_container_no (container_no);
+    ALTER TABLE fl_container_booking DROP INDEX uk_container_booking_container_no;
+  END IF;
+  IF NOT EXISTS (SELECT 1 FROM information_schema.statistics WHERE table_schema=DATABASE()
+      AND table_name='fl_container_booking' AND index_name='uk_container_booking_ocean_container') THEN
+    ALTER TABLE fl_container_booking ADD UNIQUE KEY uk_container_booking_ocean_container (ocean_booking_id,container_no);
+  END IF;
+  IF NOT EXISTS (SELECT 1 FROM information_schema.statistics WHERE table_schema=DATABASE()
+      AND table_name='fl_container_booking' AND index_name='idx_container_booking_container_no') THEN
+    ALTER TABLE fl_container_booking ADD KEY idx_container_booking_container_no (container_no,updated_at,id);
  END IF;
  IF NOT EXISTS (SELECT 1 FROM information_schema.statistics WHERE table_schema=DATABASE()
      AND table_name='fl_container_booking' AND index_name='idx_container_booking_merge') THEN
@@ -457,7 +457,7 @@ paths:
  /api/platform/v1/containers/{id}/ocean-booking-link:
    post:
      summary: 将内部模拟柜关联到已发布订舱需求
-      description: 需要 platform:firstleg:container:edit；请求指定 RELEASED oceanBookingId 和未满配 requirementId，containerNo 可空。首次关联允许 WAIT_LOADING 或已有预排货的 EDITING 模拟柜，保留原 containerBookingId/cabinetNo/loadingPlanId/items，原子写入订舱、运输和范围快照并创建 allocation；提柜后由拖车链调用柜次服务原子补录真实柜号。若关联请求已提供 containerNo，服务端仍规范化并校验 ISO 6346 结构、设备类别、校验位和全局唯一性。存在跨仓、跨渠道、柜型规格不一致、超量、重复柜号、PDA、有效装柜证据、业务单证或 LOADING/COMPLETED 等事实时拒绝。
+      description: 需要 platform:firstleg:container:edit；请求指定 RELEASED oceanBookingId 和未满配 requirementId，containerNo 可空。首次关联允许 WAIT_LOADING 或已有预排货的 EDITING 模拟柜，保留原 containerBookingId/cabinetNo/loadingPlanId/items，原子写入订舱、运输和范围快照并创建 allocation；提柜后由拖车链调用柜次服务原子补录真实柜号。若关联请求已提供 containerNo，服务端仍规范化并校验 ISO 6346 结构、设备类别和校验位，并保证同一订舱内唯一；不同提单允许复用同一集装箱号。存在跨仓、跨渠道、柜型规格不一致、超量、同提单重复柜号、PDA、有效装柜证据、业务单证或 LOADING/COMPLETED 等事实时拒绝。
      parameters: [{$ref: '#/components/parameters/ContainerBookingId'}]
      requestBody: {required: true, content: {application/json: {schema: {$ref: '#/components/schemas/ContainerOceanBookingLinkRequest'}}}}
      responses: {'200': {description: 关联后的同一模拟柜 containerBookingId/cabinetNo；列表仍只有这一条 ACTIVE 操作身份}}
@@ -2765,7 +2765,7 @@ components:
      properties:
        oceanBookingId: {type: integer, format: int64, minimum: 1, description: RELEASED订舱ID}
        requirementId: {type: integer, format: int64, minimum: 1, description: 未满配的订舱柜型需求ID}
-        containerNo: {type: string, nullable: true, maxLength: 64, description: 可选；港口提柜后可由拖车链另行原子补录。非空时服务端移除格式空白、转大写并校验ISO 6346结构、设备类别、校验位和全局唯一性}
+        containerNo: {type: string, nullable: true, maxLength: 64, description: 可选；港口提柜后可由拖车链另行原子补录。非空时服务端移除格式空白、转大写并校验ISO 6346结构、设备类别、校验位和同一订舱内唯一性}
        expectedVersion: {type: integer, minimum: 0}
    ContainerFeeAdjustRequest:
      type: object
@@ -167,7 +167,7 @@ components:
        customerName: {type: string, nullable: true, description: 可选名称提示；有客户ID时由服务端校验并保存客户主数据名称，清空客户时同时置null}
        channelCode: {type: string, nullable: true, description: 固定计划物流渠道组编码}
        warehouseId: {type: integer, format: int64, nullable: true}
-        billOfLadingNo: {type: string, nullable: true}
+        billOfLadingNo: {type: string, nullable: true, description: 全局唯一提单号；草稿未取得时可为空}
        shippingCompanyId: {type: integer, format: int64, nullable: true}
        shippingCompanyName: {type: string, nullable: true}
        carrierCode:
@@ -267,10 +267,11 @@ components:
        carrierCodes: {type: array, items: {type: string, enum: [MATSON, SML, ZIM, COSCO, EMC, HEDE, OTHER]}}
    LinkCandidate:
      type: object
-      required: [oceanBookingId, bookingNo, requirementId, containerType, capacityCbm, maxWeightKg, requiredQuantity, allocatedQuantity, remainingQuantity, customerName, warehouseName, channelName]
+      required: [oceanBookingId, bookingNo, billOfLadingNo, requirementId, containerType, capacityCbm, maxWeightKg, requiredQuantity, allocatedQuantity, remainingQuantity, customerName, warehouseName, channelName]
      properties:
        oceanBookingId: {type: string, pattern: '^[0-9]+$'}
        bookingNo: {type: string}
+        billOfLadingNo: {type: string, description: 已发布订舱的全局唯一提单号}
        requirementId: {type: string, pattern: '^[0-9]+$'}
        containerType: {type: string}
        capacityCbm: {type: number}
@@ -106,7 +106,7 @@ class ContainerControllerContractTest {
            .contains("未满配 requirementId")
            .contains("containerNo 可空")
            .contains("提柜后由拖车链调用柜次服务原子补录真实柜号")
-            .contains("校验 ISO 6346 结构、设备类别、校验位和全局唯一性")
+            .contains("校验 ISO 6346 结构、设备类别和校验位，并保证同一订舱内唯一")
            .doesNotContain("/api/platform/v1/containers/{id}/transport:")
            .doesNotContain("ContainerOceanBookingUnlinkRequest")
            .doesNotContain("ContainerTransportUpdateRequest")
@@ -52,6 +52,7 @@ class OceanBookingMapperContractTest {
            com.baomidou.mybatisplus.extension.plugins.pagination.Page.class, LinkCandidateQuery.class)
            .getAnnotation(Select.class).value());
        assertThat(sql)
+            .contains("booking.bill_of_lading_no")
            .contains("booking.status='RELEASED'")
            .contains("booking.warehouse_id=#{query.warehouseId}")
            .contains("booking.channel_code=#{query.channelGroupCode}")
@@ -4,6 +4,8 @@ import org.junit.jupiter.api.Test;
 import org.springframework.core.io.ClassPathResource;

 import java.nio.charset.StandardCharsets;
+import java.nio.file.Files;
+import java.nio.file.Path;

 import static org.assertj.core.api.Assertions.assertThat;

@@ -23,6 +25,8 @@ class OceanBookingSqlContractTest {
            .contains("customer_name VARCHAR(128) NULL COMMENT '可选客户名称快照'")
            .contains("MODIFY COLUMN customer_id BIGINT UNSIGNED NULL COMMENT '可选客户ID快照'")
            .contains("MODIFY COLUMN customer_name VARCHAR(128) NULL COMMENT '可选客户名称快照'")
+            .contains("UNIQUE KEY uk_ocean_booking_bill_of_lading (bill_of_lading_no)")
+            .contains("ADD UNIQUE KEY uk_ocean_booking_bill_of_lading (bill_of_lading_no)")
            .doesNotContain("service_term")
            .doesNotContain("freight_term")
            .contains("carrier_code VARCHAR(16) NULL COMMENT '船司标准编码")
@@ -33,6 +37,14 @@ class OceanBookingSqlContractTest {
            .doesNotContain("ALTER TABLE fl_container_booking");
    }

+    @Test
+    void billOfLadingNumberIsUniqueInModuleAndUnifiedInitialization() throws Exception {
+        String unified = Files.readString(Path.of("../deploy/sql/头程数据库统一增量-MySQL8.sql"));
+        for (String source : new String[] {sql(), unified}) {
+            assertThat(source).contains("UNIQUE KEY uk_ocean_booking_bill_of_lading (bill_of_lading_no)");
+        }
+    }
+
    @Test
    void enforcesStateIdempotencyAndAuditContracts() throws Exception {
        assertThat(sql())
@@ -326,7 +326,7 @@ class OceanBookingServiceTest {

    @Test
    void linkCandidatesDefaultsPaginationAndDelegatesOneNormalizedSetQuery() {
-        LinkCandidate candidate = new LinkCandidate(101L, "OB-260818-0001", 201L, "40HQ",
+        LinkCandidate candidate = new LinkCandidate(101L, "OB-260818-0001", "BL-001", 201L, "40HQ",
            new BigDecimal("68"), new BigDecimal("19500"), 3, 1, 2,
            "客户A", "深圳中转仓", "美森正班");
        when(repository.linkCandidates(any())).thenReturn(new PageResult<>(List.of(candidate), 1, 20, 1, 1));
@@ -347,6 +347,18 @@ class OceanBookingServiceTest {
        verify(repository, never()).containers(anyLong());
    }

+    @Test
+    void rejectsDuplicateBillOfLadingNumberBeforeCreatingDraft() {
+        stubMasterData();
+        when(repository.billOfLadingNoExists("BL-001", null)).thenReturn(true);
+
+        assertThatThrownBy(() -> service.create(9L, "admin", "duplicate-bill",
+            new CreateRequest(0, completeDraft())))
+            .isInstanceOf(BizException.class).hasMessageContaining("提单号已存在");
+
+        verify(repository, never()).insert(any(OceanBookingEntity.class));
+    }
+
    @Test
    void linkCandidatesReturnsNormalEmptyPageWithOneSetQueryAndNoDiagnosticFields() {
        when(repository.linkCandidates(any())).thenReturn(new PageResult<>(List.of(), 1, 20, 0, 0));
@@ -106,16 +106,18 @@ class ContainerBookingMapperContractTest {
    }

    @Test
-    @DisplayName("初始化与统一增量锁定真实柜号权威、唯一和ISO结构约束")
+    @DisplayName("初始化与统一增量锁定真实柜号权威、订舱内唯一和ISO结构约束")
    void databaseContractsFreezeAuthoritativeContainerNumber() throws Exception {
        String module = Files.readString(Path.of("src/main/resources/db/phase3-smart-loading-schema.sql"));
        String unified = Files.readString(Path.of("../deploy/sql/头程数据库统一增量-MySQL8.sql"));
        assertThat(module.toLowerCase())
-            .contains("国内唯一权威真实集装箱号")
+            .contains("国内柜次真实集装箱号权威快照")
+            .contains("同一订舱内唯一，不同提单允许复用")
            .contains("提柜后可原子补录");
        for (String source : new String[] {module, unified}) {
            assertThat(source.toLowerCase())
-                .contains("unique key uk_container_booking_container_no (container_no)")
+                .contains("unique key uk_container_booking_ocean_container (ocean_booking_id,container_no)")
+                .contains("key idx_container_booking_container_no (container_no,updated_at,id)")
                .contains("constraint chk_container_booking_iso6346")
                .contains("^[a-z]{3}[ujz][0-9]{7}$");
        }
@@ -68,7 +68,8 @@ class SmartLoadingSqlContractTest {
            .contains("source_type varchar(24) NOT NULL DEFAULT 'SIMULATION'")
            .contains("record_status varchar(16) NOT NULL DEFAULT 'ACTIVE'")
            .contains("merged_into_container_booking_id bigint unsigned DEFAULT NULL")
-            .contains("UNIQUE KEY uk_container_booking_container_no (container_no)")
+            .contains("UNIQUE KEY uk_container_booking_ocean_container (ocean_booking_id,container_no)")
+            .contains("KEY idx_container_booking_container_no (container_no,updated_at,id)")
            .contains("KEY idx_container_booking_merge (record_status,merged_into_container_booking_id)")
            .contains("CREATE TRIGGER trg_loading_plan_before_update")
            .contains("装柜状态只允许单向推进")
@@ -246,7 +246,7 @@ class ContainerServiceTest {

        assertThat(result.getContainerNo()).isNull();
        assertThat(result.getCabinetNo()).isEqualTo("柜-001");
-        verify(repository, never()).containerNoExists(anyString(), anyLong());
+        verify(repository, never()).containerNoExists(anyLong(), anyString(), anyLong());
        verify(repository).linkReleasedBooking(eq(11L), eq(21L), eq(31L), isNull(),
            any(OceanBookingEntity.class), eq(2), eq(9L), eq("admin"));
        verify(oceanBookings).insert(any(OceanBookingContainerAllocationEntity.class));
@@ -303,12 +303,12 @@ class ContainerServiceTest {
    }

    @Test
-    @DisplayName("提柜补录真实柜号仍拒绝全局重复号")
+    @DisplayName("提柜补录真实柜号拒绝同一订舱内重复号")
    void rejectsDuplicateRealContainerNumberAfterPickup() {
        ContainerBookingEntity linked = booking("EDITING", 3);
        linked.setContainerNo(null); linked.setOceanBookingId(21L); linked.setOceanBookingRequirementId(31L);
        when(repository.find(11L)).thenReturn(linked);
-        when(repository.containerNoExists("MSCU6639870", 11L)).thenReturn(true);
+        when(repository.containerNoExists(21L, "MSCU6639870", 11L)).thenReturn(true);

        assertThatThrownBy(() -> service.assignRealContainerNo(
            11L, "MSCU6639870", 3, 9L, "admin"))
@@ -331,10 +331,10 @@ class ContainerServiceTest {
    }

    @Test
-    @DisplayName("首次关联规范化后按全局唯一真实柜号拒绝冲突")
+    @DisplayName("首次关联规范化后按同一订舱唯一真实柜号拒绝冲突")
    void rejectsNormalizedContainerNumberConflict() {
        stubLinkContext();
-        when(repository.containerNoExists("MSCU6639870", 11L)).thenReturn(true);
+        when(repository.containerNoExists(21L, "MSCU6639870", 11L)).thenReturn(true);

        assertThatThrownBy(() -> service.linkOceanBooking(11L, 9L, "admin",
            new OceanBookingLinkRequest(21L, 31L, "ms cu6639870", 2)))
@@ -276,19 +276,19 @@ class LoadingListServiceTest {
    }

    @Test
-    void rejectsGlobalUniqueConflictIncludingConcurrentConstraintRace() {
+    void rejectsSameBookingContainerConflictIncludingConcurrentConstraintRace() {
        AggregateRow before = row("EDITING", 3);
        before.setContainerNo("MSCU6639870");
        when(repository.aggregate(10L)).thenReturn(before);
-        when(containerRepository.containerNoExists("CSQU3054383", 30L)).thenReturn(true);
+        when(containerRepository.containerNoExists(90L, "CSQU3054383", 30L)).thenReturn(true);

        assertThatThrownBy(() -> service.updateTransport(10L, 100L, 9L, "operator", "unique-key",
            new TransportUpdateRequest("CSQU3054383", null, 3, "唯一冲突")))
            .isInstanceOf(BizException.class).hasMessageContaining("已存在");

-        when(containerRepository.containerNoExists("CSQU3054383", 30L)).thenReturn(false);
+        when(containerRepository.containerNoExists(90L, "CSQU3054383", 30L)).thenReturn(false);
        when(repository.updateTransport(10L, 3, "CSQU3054383", null, 9L, "operator"))
-            .thenThrow(new org.springframework.dao.DuplicateKeyException("uk_container_booking_container_no"));
+            .thenThrow(new org.springframework.dao.DuplicateKeyException("uk_container_booking_ocean_container"));
        assertThatThrownBy(() -> service.updateTransport(10L, 100L, 9L, "operator", "race-key",
            new TransportUpdateRequest("CSQU3054383", null, 3, "并发唯一冲突")))
            .isInstanceOf(BizException.class).hasMessageContaining("已存在");
@@ -961,6 +961,7 @@ class LoadingListServiceTest {
        row.setPlanStatus(status);
        row.setWarehouseId(100L);
        row.setChannelCode("OA_LA_TRUCK");
+        row.setOceanBookingId(90L);
        row.setOutboundConfirmedAt(java.time.LocalDateTime.now());
        row.setVersion(version);
        return row;
@@ -342,7 +342,7 @@ paths:
    get:
      tags: [IAM Resources / IAM 资源]
      summary: 查询当前用户有效权限
-      description: 返回当前有效客户成员权限编码。资金账户和流水只读返回 `merchant:finance:account:view`，提交充值申请返回 `merchant:finance:recharge:create`，两者独立授权。海外采购、本土卡、本土散板分别按 `:list`、`:create`（可编辑业务另有 `:edit`）拆分；海外仓入库、尾程订单、换标、转运、废弃、退货预报和退货库存均返回各自 `merchant:warehouse:*` 或 `merchant:overseas-warehouse:*` 权限。客户派送返回 `merchant:warehouse:delivery:list` 和 `merchant:warehouse:delivery:create`。列表权限包含详情只读，创建、文件、确认、取消和转换操作独立授权。
+      description: 返回当前有效客户成员权限编码。资金账户和流水只读返回 `merchant:finance:account:view`，提交充值申请返回 `merchant:finance:recharge:create`，两者独立授权。海外采购、本土卡、本土散板的列表入口分别返回 `merchant:cross-border:procurement:list`、`merchant:cross-border:domestic-trucking:list`、`merchant:cross-border:pallet-shipping:list`，创建和编辑另行授权；海外仓入库返回 `merchant:warehouse:inbound:list`，尾程订单、换标、转运、废弃、退货预报和退货库存均返回各自 `merchant:overseas-warehouse:*` 权限。客户派送返回 `merchant:warehouse:delivery:list` 和 `merchant:warehouse:delivery:create`。列表权限包含详情只读，创建、文件、确认、取消和转换操作独立授权。
      responses:
        '200':
          description: 当前商户成员权限查询成功
@@ -20,7 +20,7 @@ class MerchantReturnInventoryPermissionSqlContractTest {
        assertThat(sql).contains(
            "(5306140,0,'MERCHANT','MENU',0,'" + PERMISSION + "','退货库存'",
            "role.role_code='MERCHANT_OWNER'",
-            "'" + PERMISSION + "')) <> 24",
+            ")) <> 24 THEN",
            "客户默认管理员授权不完整");

        int grantStart = sql.indexOf("-- 客户默认管理员获得当前客户海外业务入口");
@@ -51,7 +51,7 @@ class OverseasCustomerPermissionSqlContractTest {
            "'merchant:cross-border:pallet-shipping:list','美本土散板','/cross-border/pallet-shipping'",
            "'merchant:warehouse:inbound:list','海外仓入库订单','/orders/inbound'",
            "'merchant:overseas-warehouse:return-inventory:list','退货库存','/overseas-warehouse/return-inventory'",
-            "'merchant:overseas-warehouse:relabel:files','维护换标文件'",
+            "'merchant:overseas-warehouse:relabel:files','管理贴标文件'",
            "'merchant:overseas-warehouse:discard:cancel','取消货物废弃申请'");
    }

@@ -27,7 +27,7 @@
 |---|---|
 | 内部模块化基线与依赖分析 | `docs/lastleg-internal-modularization-baseline.md`、`scripts/analyze-lastleg-dependencies.mjs`、`scripts/analyze-lastleg-dependencies.test.mjs`、`src/test/resources/architecture/lastleg-slice-dependencies.json`；只约束本服务内部包依赖，不改变部署单元或数据库边界 |
 | 事件接收、平台订单列表/详情/导出、柜级进度、目的仓调整 | `src/main/java/com/baiyue/lastleg/controller/LastlegOrderController.java`；`/api/platform/v1/last-leg/orders/container-summaries` 按 `sourceContainerBookingId` 服务端聚合全柜订单、入仓码、有效计划及托盘资源异常并分页返回全部稳定来源柜，已完成计划转换的柜仍保留用于接柜仓查询与修改；单票手工计划保存后，整柜最后一票齐全时自动生成并绑定全柜托盘码，一票柜立即生成，`resourcePendingPlanCount` 只作为失败重试事实；`/{sourceContainerBookingId}` 返回柜内全部订单/入仓码/计划状态且不受订单分页截断；`plannedArrivalAt` 只取装柜完成事件 `estimatedWarehouseArrivalAt` 冻结到 `ll_order.estimated_warehouse_at` 的正式事实，按其升序、null 最后、稳定柜 ID 排序；目的仓调整仅接受国内 Warehouse Service 平台公共 `ACTIVE + FBA` 主档，写入前由 `service/FbaWarehouseValidator.java` 经内部只读目录校验 ID/编码/名称一致 |
-| 尾程订单完整计划、柜级到仓时间、暂扣与人工节点 | `controller/LastlegOrderController.java`、`service/LastlegOrderCommandService.java`、`inboundplan/service/InboundPlanService.java`、`dto/LastlegOrderCommandDtos.java`；Admin 清关提柜列表通过 `/orders/container-arrival-times/query` 批量读取整柜预计/实际到仓，预计时间在任何入库计划生成前按柜级版本与幂等键人工维护并原子同步全柜 `ll_order.estimated_warehouse_at`，实际时间只取海外 PDA 会话首次 `receiving_at`。单票计划写入校验订单版本、客户范围、订单冻结入仓码、稳定接柜仓 ID、当前仓库主档与幂等键；预计到仓日期不接受计划请求输入，必须锁定来源柜全部订单的 `estimated_warehouse_at`，缺失或同柜不一致时阻断，人工与自动计划统一写其日期；一件代发人工计划必须逐托沿用不可变头程封托的 DP 托盘码和箱数，托数及各托箱数均不得重新分配，禁止保存无法绑定真实资源的半成品计划；接柜仓编码/名称以该 ID 当前目录快照为准，不要求订单残留旧展示快照。暂扣/解除写不可变历史并发布 `InboundOrderDetainedOutboxService`，已拣货、已发运或已有出库单时禁止新增暂扣；暂扣期间不得进入排车或出库。人工节点必须一次提交固定八行完整快照且至少一个时间，首次保存后永久使用 `MANUAL` 来源，不得回退柜级节点或反向修改头程船节点 |
+| 尾程订单完整计划、柜级到仓时间、暂扣与人工节点 | `controller/LastlegOrderController.java`、`service/LastlegOrderCommandService.java`、`inboundplan/service/InboundPlanService.java`、`dto/LastlegOrderCommandDtos.java`；Admin 清关提柜列表通过 `/orders/container-arrival-times/query` 批量读取整柜预计/实际到仓，预计时间在任何入库计划生成前按柜级版本与幂等键人工维护并原子同步全柜 `ll_order.estimated_warehouse_at`，实际时间只取海外 PDA 会话首次 `receiving_at`。单票计划写入校验订单版本、客户范围、订单冻结入仓码、稳定接柜仓 ID、当前仓库主档与幂等键；预计到仓日期不接受计划请求输入，必须锁定来源柜全部订单的 `estimated_warehouse_at`，缺失或同柜不一致时阻断，人工与自动计划统一写其日期；一件代发人工计划必须逐托沿用不可变头程封托的 DP 托盘码和箱数，托数及各托箱数均不得重新分配，禁止保存无法绑定真实资源的半成品计划；接柜仓编码/名称以该 ID 当前目录快照为准，不要求订单残留旧展示快照。暂扣/解除写不可变历史并发布 `InboundOrderDetainedOutboxService`；新增暂扣只允许完成入库且尚未进入出库流程的订单，解除暂扣不受该状态限制；暂扣只阻断排车和出库，不阻断入库计划或入库作业。人工节点必须一次提交固定八行完整快照且至少一个时间，首次保存后永久使用 `MANUAL` 来源，不得回退柜级节点或反向修改头程船节点 |
 | 客户尾程订单列表与详情 | `controller/MerchantLastlegOrderController.java`；客户范围只取认证身份，稳定类型/状态见 `model/LastlegOrderType.java`、`LastlegOrderStatus.java` |
 | 装柜完成事件消费 | `service/LoadingCompletedConsumer.java`；当前生产信封为 `FIRST_LEG_LOADING_PLAN_COMPLETED` V3，消费端除冻结 V2 货物事实外，按 `sourceContainerBookingId` 幂等投影物理柜五类国内装柜照片；FBA 可按箱数且不生成逐箱作业账，OVERSEAS 必须逐箱校验并生成箱级事实；V1/V2 仅用于历史事件读取 |
 | 尾程单号生成 | `service/LastlegOrderNoGenerator.java` |
@@ -179,7 +179,8 @@ public class LastlegOrderController {
    @PutMapping("/api/platform/v1/last-leg/orders/{id}/hold")
    @PreAuthorize("hasAuthority('" + OverseasPermissions.LAST_MILE_ORDER_EDIT + "')")
    @Operation(summary = "暂扣或解除单票尾程订单",
-        description = "要求版本与幂等键；暂扣只作用于该票并阻断其出库推进。Required authority: " + OverseasPermissions.LAST_MILE_ORDER_EDIT)
+        description = "要求版本与幂等键；新增暂扣只允许完成入库且尚未进入出库流程的订单，"
+            + "暂扣只作用于该票并仅阻断排车和出库。Required authority: " + OverseasPermissions.LAST_MILE_ORDER_EDIT)
    public ApiResponse<LastlegOrderCommandDtos.HoldResponse> hold(
        @AuthenticationPrincipal AuthenticatedUser user,
        @RequestParam(required = false) String customerId,
@@ -114,12 +114,6 @@ public final class LastlegOrderRequests {
    ) {
    }

-    public record SetDetained(
-        @NotNull Boolean detained,
-        @NotBlank @Size(max = 500) String remark
-    ) {
-    }
-
    public record SetPalletMergeRequired(
        @NotNull Boolean palletMergeRequired
    ) {
@@ -126,7 +126,7 @@ public interface InboundPlanOrderMapper {
    @Update("UPDATE ll_order SET inbound_order_no=#{planNo},current_status='INBOUND_PLANNED'," +
        "pallet_merge_flag=CASE WHEN #{mergeRequired}=1 THEN 'MERGE_REQUIRED' ELSE NULL END," +
        "pallet_count=#{palletCount},version=version+1,updated_at=#{updatedAt} " +
-        "WHERE customer_id=#{customerId} AND id=#{orderId} AND version=#{expectedVersion} AND detained=0 " +
+        "WHERE customer_id=#{customerId} AND id=#{orderId} AND version=#{expectedVersion} " +
        "AND current_status IN ('PENDING_ASSIGNMENT','DESTINATION_ASSIGNED') AND inbound_order_no IS NULL")
    int markPlannedManual(@Param("customerId") String customerId, @Param("orderId") Long orderId,
                          @Param("planNo") String planNo, @Param("palletCount") int palletCount,
@@ -2,6 +2,7 @@ package com.baiyue.lastleg.inboundplan.pda.dto;

 import jakarta.validation.Valid;
 import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.Max;
 import jakarta.validation.constraints.NotNull;
 import jakarta.validation.constraints.Pattern;
 import jakarta.validation.constraints.Positive;
@@ -23,7 +24,8 @@ public final class ReceivingContainerRequests {
    public record PalletResolve(@NotBlank String palletCode, @NotBlank String inboundCode) { }
    /** packageCount 是该托当前累计实收箱数，不是本次增量。 */
    public record BulkReceive(@NotBlank String inboundCode, @NotBlank String palletCode,
-                              @Positive int packageCount, Integer expectedPalletVersion,
+                              @Positive @Max(value = 66, message = "一个托盘最多只能收66箱，请拆分到其他托盘") int packageCount,
+                              Integer expectedPalletVersion,
                              @NotBlank @Size(max = 255) String idempotencyKey) {
        public BulkReceive(String inboundCode, String palletCode, int packageCount, String idempotencyKey) {
            this(inboundCode, palletCode, packageCount, null, idempotencyKey);
@@ -73,6 +73,9 @@ public class ReceivingContainerService {
        "/api/pda/v1/last-leg/receiving-containers/current/domestic-loading-photos/{type}/content";
    private static final String PALLET_MERGE_HINT =
        "该入库计划可选择合托：合托时扫描同目的仓已使用的托盘码，独立收货时扫描新托盘码；不强制合托";
+    private static final int MAX_PACKAGES_PER_PALLET = 66;
+    private static final String PALLET_CAPACITY_MESSAGE =
+        "一个托盘最多只能收66箱，请拆分到其他托盘";

    @Resource private InboundPlanMapper plans;
    @Resource private InboundPlanLineMapper lines;
@@ -364,6 +367,7 @@ public class ReceivingContainerService {
                                                            ReceivingContainerRequests.BulkReceive request) {
        ReceivingContainerOperation replay = replay(operatorKey, "BULK_RECEIVE", request.idempotencyKey(), request);
        if (replay != null) return read(replay, ReceivingContainerResponses.Receipt.class);
+        requirePalletCapacity(request.packageCount());
        ReceivingContainerSession session = requireSigned(operatorKey);
        InboundRef ref = requireInbound(session.getContainerNo(), request.inboundCode());
        if ("ONE_CLICK_DROPSHIP".equals(ref.order().getOrderType())) {
@@ -463,6 +467,10 @@ public class ReceivingContainerService {
        PalletSelection selection = resolveReceivingPallet(ref, request.palletCode(), true);
        WarehouseResourceGateway.WarehousePalletReference resource = selection.resource();
        InboundPlanPallet pallet = selection.pallet();
+        long packagesOnPallet = cartons.selectCount(new LambdaQueryWrapper<InboundPlanCarton>()
+            .eq(InboundPlanCarton::getWarehousePalletId, resource.palletId())
+            .eq(InboundPlanCarton::getStatus, "ON_PALLET"));
+        requirePalletCapacity(packagesOnPallet + 1);
        workflow.validateCartonResolved(customerId, ref.plan(), ref.line(), pallet, request.cartonMark());
        Long resourceLockId = workflow.assignResolvedPallet(customerId, ref.plan(), pallet, resource);
        try {
@@ -492,6 +500,8 @@ public class ReceivingContainerService {
        if (sourcePalletNo == null) throw notFound("DP or carton is not part of the current container");
        requireCompleteManifest(session.getContainerNo(), sourcePalletNo);
        List<DropshipPalletRef> matches = dropshipPalletRefs(session.getContainerNo(), sourcePalletNo);
+        int total = matches.stream().mapToInt(value -> value(value.allocation().getPlannedPackageCount())).sum();
+        requirePalletCapacity(total);
        boolean alreadyReceived = matches.stream().allMatch(match ->
            value(match.allocation().getPickedPackageCount()) == value(match.allocation().getPlannedPackageCount()));
        int accepted = 0;
@@ -511,7 +521,6 @@ public class ReceivingContainerService {
        }
        List<InboundRef> group = matches.stream().map(DropshipPalletRef::ref).distinct().toList();
        List<String> inboundCodes = group.stream().map(value -> value.line().getInboundCode()).distinct().sorted().toList();
-        int total = matches.stream().mapToInt(value -> value(value.allocation().getPlannedPackageCount())).sum();
        int received = matches.stream().mapToInt(value -> value(value.allocation().getPickedPackageCount())).sum();
        InboundRef first = group.get(0);
        ReceivingContainerResponses.Inbound inbound = inbound(first);
@@ -885,6 +894,10 @@ public class ReceivingContainerService {
                || "LOCKED".equals(pallet.getAssignmentStatus()));
    }

+    private void requirePalletCapacity(long packageCount) {
+        if (packageCount > MAX_PACKAGES_PER_PALLET) throw conflict(PALLET_CAPACITY_MESSAGE);
+    }
+
    private void requireMaterializedPlans(List<InboundPlan> containerPlans) {
        for (InboundPlan plan : containerPlans) {
            int expected = plan.getPalletCount() == null ? 0 : plan.getPalletCount();
@@ -126,7 +126,6 @@ public class InboundPlanService {
        if (order.version() != request.expectedOrderVersion()) {
            throw new ResponseStatusException(HttpStatus.CONFLICT, "尾程订单版本已变化，请刷新后重试");
        }
-        if (order.detained()) throw new ResponseStatusException(HttpStatus.CONFLICT, "暂扣尾程订单不能生成入库计划");
        if (!Objects.equals(containerWarehouseId, trimToNull(order.overseasWarehouseId()))) {
            throw new ResponseStatusException(HttpStatus.CONFLICT, "来源柜接柜仓冻结事实已变化，请刷新后重试");
        }
@@ -269,7 +268,6 @@ public class InboundPlanService {
        boolean planned = trimToNull(row.planNo()) != null;
        if (!planned) {
            if (trimToNull(row.inboundCode()) == null) blockers.add("MISSING_INBOUND_CODE");
-            if (row.detained()) blockers.add("ORDER_DETAINED");
            if (!("PENDING_ASSIGNMENT".equals(row.currentStatus())
                || "DESTINATION_ASSIGNED".equals(row.currentStatus()))) blockers.add("ORDER_STATUS_NOT_READY");
            if (containerNo == null || !Objects.equals(containerNo, trimToNull(row.containerNo()))) {
@@ -60,6 +60,12 @@ public interface InventoryCommandMapper {
                          @Param("sourceIdentity") String sourceIdentity,
                          @Param("skuCode") String skuCode);

+    @Select("SELECT p.* FROM ll_inventory_position p JOIN ll_inventory_balance b ON b.id=p.balance_id " +
+        "WHERE p.customer_id=#{customerId} AND b.inbound_order_id=#{inboundOrderId} " +
+        "AND p.available_packages>0 ORDER BY p.id FOR UPDATE")
+    List<InventoryPosition> lockInboundAvailablePositions(@Param("customerId") String customerId,
+                                                           @Param("inboundOrderId") Long inboundOrderId);
+
    @Select("SELECT p.* FROM ll_inventory_position p JOIN ll_inventory_balance b ON b.id=p.balance_id " +
        "WHERE p.customer_id=#{customerId} AND b.inbound_order_id=#{inboundOrderId} " +
        "AND p.hold_packages>0 ORDER BY p.id FOR UPDATE")
@@ -142,6 +142,17 @@ public class InventoryCommandService {
        });
    }

+    @Transactional
+    public void holdInboundOrderInventory(String customerId, String operatorId, long inboundOrderId,
+                                          String businessOrderNo, String remark) {
+        for (InventoryPosition position : commands.lockInboundAvailablePositions(customerId, inboundOrderId)) {
+            long packages = value(position.getAvailablePackages());
+            if (packages == 0) continue;
+            hold(customerId, operatorId, new InventoryCommandRequests.Move(position.getId(), packages,
+                businessOrderNo, null, null, "ORDER_HOLD:" + inboundOrderId + ":" + position.getId(), remark));
+        }
+    }
+
    @Transactional
    public void releaseInboundOrderHold(String customerId, String operatorId, long inboundOrderId,
                                        String businessOrderNo, String remark) {
@@ -15,6 +15,7 @@ import com.baiyue.lastleg.mapper.LastlegOrderManualNodeHistoryMapper;
 import com.baiyue.lastleg.mapper.LastlegOrderManualNodeMapper;
 import com.baiyue.lastleg.mapper.LastlegOrderMapper;
 import com.baiyue.lastleg.mapper.LastlegOrderOperationLogMapper;
+import com.baiyue.lastleg.inventory.command.service.InventoryCommandService;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import jakarta.annotation.Resource;
@@ -51,6 +52,7 @@ public class LastlegOrderCommandService {
    @Resource private LastlegOrderManualNodeHistoryMapper manualNodeHistory;
    @Resource private LastlegOrderOperationLogMapper operationLogs;
    @Resource private InboundOrderDetainedOutboxService detainedOutbox;
+    @Resource private InventoryCommandService inventory;
    @Resource private ObjectMapper objectMapper;

    @Transactional
@@ -69,6 +71,9 @@ public class LastlegOrderCommandService {
        if (Boolean.TRUE.equals(order.getDetained()) == held) {
            throw conflict(held ? "尾程订单已暂扣" : "尾程订单未处于暂扣状态");
        }
+        if (held && !"INBOUND_COMPLETED".equals(order.getCurrentStatus())) {
+            throw conflict("货物完成入库后才能暂扣");
+        }
        if (held && (positive(order.getPickedPackageCount()) || positive(order.getShippedPackageCount())
            || text(order.getOutboundOrderNo()) != null)) {
            throw conflict("尾程订单已进入出库流程，不能新增暂扣");
@@ -79,6 +84,13 @@ public class LastlegOrderCommandService {
        if (orders.updateHold(order.getCustomerId(), orderId, held, chargeable, reason, version, now) != 1) {
            throw conflict("尾程订单版本已变化，请刷新后重试");
        }
+        if (held) {
+            inventory.holdInboundOrderInventory(order.getCustomerId(), operatorId, orderId,
+                order.getOrderNo(), reason);
+        } else {
+            inventory.releaseInboundOrderHold(order.getCustomerId(), operatorId, orderId,
+                order.getOrderNo(), reason);
+        }
        int nextVersion = version + 1;
        LastlegOrderCommandDtos.HoldResponse response = new LastlegOrderCommandDtos.HoldResponse(
            orderId, held, chargeable, held ? reason : null, nextVersion);
@@ -48,7 +48,6 @@ import java.io.ByteArrayOutputStream;
 import java.io.IOException;
 import java.io.OutputStream;
 import java.time.LocalDateTime;
-import java.time.ZoneOffset;
 import java.security.MessageDigest;
 import java.util.ArrayList;
 import java.util.LinkedHashMap;
@@ -79,7 +78,6 @@ public class LastlegOrderService {
    @Resource private InboundPlanCartonMapper cartonMapper;
    @Resource private FbaWarehouseValidator fbaWarehouseValidator;
    @Resource private InventoryCommandService inventory;
-    @Resource private InboundOrderDetainedOutboxService detainedOutbox;
    @Resource private ReceivingWarehouseOperationMapper receivingWarehouseOperations;
    @Resource private ContainerArrivalTimeOperationMapper containerArrivalTimeOperations;
    @Resource private WarehouseResourceGateway warehouseResourceGateway;
@@ -387,47 +385,6 @@ public class LastlegOrderService {
        return fee;
    }

-    @Transactional
-    public void setDetained(String customerId, long orderId, LastlegOrderRequests.SetDetained request,
-                            String operatorName) {
-        setDetained(customerId, orderId, request, null, operatorName);
-    }
-
-    @Transactional
-    public void setDetained(String customerId, long orderId, LastlegOrderRequests.SetDetained request,
-                            String operatorId, String operatorName) {
-        LastlegOrder current = findOwned(customerId, orderId);
-        LastlegOrder order = orderMapper.lockById(current.getCustomerId(), orderId);
-        if (order == null) throw new ResponseStatusException(HttpStatus.NOT_FOUND, "Tail-leg order not found");
-        boolean detained = request.detained();
-        if (Boolean.TRUE.equals(order.getDetained()) == detained) {
-            throw new ResponseStatusException(HttpStatus.CONFLICT, detained ? "Order is already held" : "Order is not held");
-        }
-        if (detained && "INBOUND_COMPLETED".equals(order.getCurrentStatus())) {
-            throw new ResponseStatusException(HttpStatus.CONFLICT, "Completed inbound orders cannot be newly held");
-        }
-        LocalDateTime now = LocalDateTime.now();
-        order.setDetained(detained);
-        order.setUpdatedAt(now);
-        orderMapper.updateById(order);
-        if (!detained && "INBOUND_COMPLETED".equals(order.getCurrentStatus())) {
-            inventory.releaseInboundOrderHold(order.getCustomerId(), operatorName, orderId, order.getOrderNo(), request.remark().trim());
-        }
-        LastlegOrderOperationLog operation = new LastlegOrderOperationLog();
-        operation.setId(IdWorker.getId());
-        operation.setCustomerId(order.getCustomerId());
-        operation.setOrderId(orderId);
-        operation.setOperationNode(detained ? "暂扣" : "解除暂扣");
-        operation.setOperatorName(operatorName);
-        operation.setResult(request.remark().trim());
-        operation.setCreatedAt(now);
-        operationLogMapper.insert(operation);
-        if (StringUtils.hasText(order.getSourceInboundId())) {
-            detainedOutbox.publish(order, detained, request.remark().trim(), operatorId, operatorName,
-                now.toInstant(ZoneOffset.UTC), operation.getId());
-        }
-    }
-
    @Transactional
    public void setPalletMergeRequired(String customerId, long orderId,
                                       LastlegOrderRequests.SetPalletMergeRequired request,
@@ -126,21 +126,21 @@ paths:
  /api/pda/v1/last-leg/receiving-containers/current/receipts/bulk:
    post:
      summary: FBA 入仓码按箱数收货
-      description: 权限 lastleg:pda:operate；只允许普通 FBA。packageCount 是该托现场累计箱数，服务端按当前柜+FBA目的仓稳定分摊到全部关联入仓码；超出计划部分只记差异，不生成可用库存。
+      description: 权限 lastleg:pda:operate；只允许普通 FBA。packageCount 是该托现场累计箱数，单托最多 66 箱；服务端按当前柜+FBA目的仓稳定分摊到全部关联入仓码；超出计划但未超出单托上限的部分只记差异，不生成可用库存。
      security: [{ bearerAuth: [] }]
      requestBody: { required: true, content: { application/json: { schema: { $ref: '#/components/schemas/ReceivingBulk' } } } }
-      responses: { '200': { description: 本次与累计实收进度，超收返回 DIFFERENCE_RECORDED, content: { application/json: { schema: { $ref: '#/components/schemas/ReceivingReceiptApiResponse' } } } }, '409': { description: 非普通FBA、累计数回退、版本变化或托盘不匹配 } }
+      responses: { '200': { description: 本次与累计实收进度，超收返回 DIFFERENCE_RECORDED, content: { application/json: { schema: { $ref: '#/components/schemas/ReceivingReceiptApiResponse' } } } }, '409': { description: 非普通FBA、累计数回退、单托超过66箱、版本变化或托盘不匹配 } }
  /api/pda/v1/last-leg/receiving-containers/current/receipts/carton:
    post:
      summary: 海外仓入仓码逐箱收货
-      description: 权限 lastleg:pda:operate；只允许 destinationType=OVERSEAS，拒绝跨柜、重复箱和不匹配托盘。
+      description: 权限 lastleg:pda:operate；只允许 destinationType=OVERSEAS，单托最多 66 箱，拒绝跨柜、重复箱和不匹配托盘。
      security: [{ bearerAuth: [] }]
      requestBody: { required: true, content: { application/json: { schema: { $ref: '#/components/schemas/ReceivingCarton' } } } }
      responses: { '200': { description: 本次与累计实收进度, content: { application/json: { schema: { $ref: '#/components/schemas/ReceivingReceiptApiResponse' } } } }, '409': { description: FBA逐箱、跨柜、重复箱或托盘不匹配 } }
  /api/pda/v1/last-leg/receiving-containers/current/receipts/pallet:
    post:
      summary: 一件代发按完整来源托盘收货
-      description: 权限 lastleg:pda:operate；只允许 ONE_CLICK_DROPSHIP，扫描 DP 或该托任一箱码，一次接收跨客户完整 DP；所有客户事件分片清单一致且齐全后才允许收货。
+      description: 权限 lastleg:pda:operate；只允许 ONE_CLICK_DROPSHIP，扫描 DP 或该托任一箱码，一次接收跨客户完整 DP；单托最多 66 箱，所有客户事件分片清单一致且齐全后才允许收货。
      security: [{ bearerAuth: [] }]
      requestBody: { required: true, content: { application/json: { schema: { $ref: '#/components/schemas/ReceivingWholePallet' } } } }
      responses: { '200': { description: 本次与累计实收进度, content: { application/json: { schema: { $ref: '#/components/schemas/ReceivingReceiptApiResponse' } } } }, '404': { description: 来源托盘不属于当前柜 }, '409': { description: 非一件代发、来源托盘重复或已操作 } }
@@ -232,7 +232,7 @@ paths:
  /api/platform/v1/last-leg/orders/{id}/hold:
    put:
      summary: 设置或解除尾程订单暂扣
-      description: 权限 platform:overseas-warehouse:last-mile-order:edit；使用订单版本和 Idempotency-Key 原子写入计费标记、原因及不可变历史。已进入出库流程的订单不得新增暂扣；暂扣只作用于当前票，不影响同柜其他订单。
+      description: 权限 platform:overseas-warehouse:last-mile-order:edit；使用订单版本和 Idempotency-Key 原子写入计费标记、原因及不可变历史。仅完成入库且尚未进入出库流程的订单允许新增暂扣；解除暂扣不受该状态限制。暂扣只作用于当前票并仅阻断排车和出库，不影响入库计划或同柜其他订单。
      security: [{ bearerAuth: [] }]
      parameters:
        - { name: id, in: path, required: true, schema: { type: integer, format: int64 } }
@@ -245,7 +245,7 @@ paths:
            schema: { $ref: '#/components/schemas/LastlegOrderHoldRequest' }
      responses:
        '200': { description: 暂扣状态已更新, content: { application/json: { schema: { type: object, properties: { code: { type: string }, data: { $ref: '#/components/schemas/LastlegOrderHoldResponse' } } } } } }
-        '409': { description: 版本冲突、幂等键冲突、重复状态或订单已进入出库流程 }
+        '409': { description: 版本冲突、幂等键冲突、重复状态、尚未完成入库或订单已进入出库流程 }
  /api/platform/v1/last-leg/orders/{id}/manual-nodes:
    get:
      summary: 查询尾程订单人工展示节点
@@ -496,7 +496,7 @@ paths:
  /api/platform/v1/last-leg/inbound-plans/manual:
    post:
      summary: 平台按单票手工生成入库计划
-      description: 权限 platform:overseas-warehouse:inbound-order:create；按 customerId 与 orderId 锁定单票，校验订单版本、状态、暂扣状态、真实入仓码、客户归属及有效公共接柜仓。预计到仓日期由服务端锁定读取来源柜全部订单的 estimatedWarehouseAt，缺失或同柜不一致时拒绝生成，不接受调用方提交。一次只生成当前票的独立计划，不改变同柜其他订单；命令原子且幂等。
+      description: 权限 platform:overseas-warehouse:inbound-order:create；按 customerId 与 orderId 锁定单票，校验订单版本、状态、真实入仓码、客户归属及有效公共接柜仓。暂扣只限制排车和出库，不阻断入库计划。预计到仓日期由服务端锁定读取来源柜全部订单的 estimatedWarehouseAt，缺失或同柜不一致时拒绝生成，不接受调用方提交。一次只生成当前票的独立计划，不改变同柜其他订单；命令原子且幂等。
      security: [{ bearerAuth: [] }]
      parameters:
        - { name: Idempotency-Key, in: header, required: true, schema: { type: string, minLength: 1, maxLength: 128 } }
@@ -508,7 +508,7 @@ paths:
      responses:
        '200': { description: 统一 ApiResponse 包装的入库计划详情 }
        '400': { description: 客户、入仓码、仓库主数据或请求字段无效 }
-        '409': { description: 订单版本、状态、暂扣状态、柜级预计到仓时间、重复计划或幂等键冲突 }
+        '409': { description: 订单版本、状态、柜级预计到仓时间、重复计划或幂等键冲突 }
  /api/platform/v1/last-leg/inbound-plans/convert-container:
    post:
      summary: 按整柜批量生成剩余入库计划
@@ -2044,7 +2044,7 @@ components:
      properties:
        inboundCode: { type: string, minLength: 1 }
        palletCode: { type: string, minLength: 1 }
-        packageCount: { type: integer, minimum: 1 }
+        packageCount: { type: integer, minimum: 1, maximum: 66 }
        expectedPalletVersion: { type: integer, minimum: 0, nullable: true }
        idempotencyKey: { type: string, minLength: 1, maxLength: 255 }
    ReceivingCarton:
@@ -153,6 +153,8 @@ class ReceivingContainerContractTest {
        assertTrue(yaml.contains("enum: [LICENSE_PLATE, CONTAINER_SEAL, DOOR_OPEN]"));
        assertTrue(yaml.contains("photos: { type: array, minItems: 3, maxItems: 3"));
        assertTrue(yaml.contains("required: [role, fileId, downloadPath]"));
+        assertTrue(yaml.contains("packageCount: { type: integer, minimum: 1, maximum: 66 }"));
+        assertTrue(receivingPaths.contains("单托最多 66 箱"));
        assertTrue(yaml.contains("overseasWarehouseId: { type: string"));
        assertTrue(yaml.contains("overseasWarehouseName: { type: string"));
        assertFalse(receivingPaths.contains("photoFileIds"));
@@ -49,6 +49,7 @@ import static org.assertj.core.api.Assertions.assertThat;
 import static org.assertj.core.api.Assertions.assertThatThrownBy;
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.anyInt;
+import static org.mockito.ArgumentMatchers.anyLong;
 import static org.mockito.Mockito.doThrow;
 import static org.mockito.Mockito.never;
 import static org.mockito.Mockito.verify;
@@ -422,6 +423,55 @@ class ReceivingContainerServiceBehaviorTest {
        verifyNoInteractions(workflow);
    }

+    @Test
+    void fbaPalletAccepts66PackagesAndRejects67BeforeReceivingStarts() {
+        stubCurrent("FBA", "CONT-A");
+        InboundPlanLine fbaLine = line("FBA");
+        fbaLine.setRequiredPackageCount(66);
+        when(lines.selectList(any())).thenReturn(List.of(fbaLine));
+        when(orderDetails.selectList(any())).thenReturn(List.of(detail("SKU-1", 66)));
+        when(skuReceipts.listLineSku("100", 10L, "SKU-1")).thenReturn(List.of());
+        stubReservedFbaPallet();
+        when(workflow.receiveBulkResolved(any(), any(), any(), any(), anyInt(), any(), any()))
+            .thenAnswer(invocation -> invocation.getArgument(4));
+        when(fbaPalletCounts.insert(any(ReceivingFbaPalletCount.class))).thenReturn(1);
+        when(sessions.updateById(any(ReceivingContainerSession.class))).thenReturn(1);
+        when(operations.insert(any(ReceivingContainerOperation.class))).thenReturn(1);
+
+        var accepted = service.receiveBulk("7", "receiver",
+            new ReceivingContainerRequests.BulkReceive("IN-1", "PAL-1", 66, "capacity-66"));
+
+        assertThat(accepted.acceptedPackages()).isEqualTo(66);
+
+        org.mockito.Mockito.reset(sessions, workflow, warehouse);
+        assertThatThrownBy(() -> service.receiveBulk("7", "receiver",
+            new ReceivingContainerRequests.BulkReceive("IN-1", "PAL-1", 67, "capacity-67")))
+            .isInstanceOf(ResponseStatusException.class)
+            .hasMessageContaining("66箱");
+        verifyNoInteractions(sessions, workflow, warehouse);
+    }
+
+    @Test
+    void overseasCartonIsRejectedWhenPhysicalPalletAlreadyContains66Packages() {
+        stubCurrent("OVERSEAS", "CONT-A");
+        when(cartons.selectOne(any())).thenReturn(carton(1L, "IN-1#67"));
+        InboundPlanPallet reserved = planPallet();
+        reserved.setPalletNo("PAL-1"); reserved.setWarehousePalletId(30L); reserved.setWarehouseLocationId(40L);
+        reserved.setWarehouseResourceLockId(50L); reserved.setAssignmentStatus("RESERVED");
+        when(pallets.selectList(any())).thenReturn(List.of(reserved));
+        when(warehouse.resolveReservedPallet("PAL-1", "100", 100L, 30L, 40L, 50L))
+            .thenReturn(resource(100L, null));
+        when(cartons.selectCount(any())).thenReturn(66L);
+
+        assertThatThrownBy(() -> service.receiveCarton("7", "receiver",
+            new ReceivingContainerRequests.CartonReceive("IN-1#67", "PAL-1", "carton-capacity")))
+            .isInstanceOf(ResponseStatusException.class)
+            .hasMessageContaining("66箱");
+
+        verify(workflow, never()).validateCartonResolved(any(), any(), any(), any(), any());
+        verify(workflow, never()).assignResolvedPallet(any(), any(), any(), any());
+    }
+
    @Test
    void crossContainerCartonAndMismatchedPalletAreRejectedBeforeReservation() {
        stubCurrent("OVERSEAS", "CONT-A");
@@ -950,6 +1000,29 @@ class ReceivingContainerServiceBehaviorTest {
        verifyNoInteractions(warehouse);
    }

+    @Test
+    void dropshipWholePalletOver66PackagesIsRejectedBeforePicking() {
+        stubCurrent("OVERSEAS", "CONT-A");
+        LastlegOrder dropship = order("OVERSEAS"); dropship.setOrderType("ONE_CLICK_DROPSHIP");
+        when(orders.selectById(1L)).thenReturn(dropship);
+        InboundPlanPallet pallet = planPallet();
+        pallet.setPalletNo("DP-260909-0067"); pallet.setSourcePalletNo("DP-260909-0067");
+        pallet.setWarehousePalletId(30L);
+        InboundPlanPalletAllocation pending = new InboundPlanPalletAllocation();
+        pending.setId(67L); pending.setCustomerId("100"); pending.setPlanId(2L);
+        pending.setLineId(10L); pending.setPalletId(20L); pending.setPlannedPackageCount(67);
+        when(pallets.selectList(any())).thenReturn(List.of(pallet));
+        when(allocations.selectList(any())).thenReturn(List.of(pending));
+        stubCompleteManifest("DP-260909-0067", 67);
+
+        assertThatThrownBy(() -> service.receiveWholePallet("7", "receiver",
+            new ReceivingContainerRequests.WholePalletReceive("DP-260909-0067", "whole-capacity")))
+            .isInstanceOf(ResponseStatusException.class)
+            .hasMessageContaining("66箱");
+
+        verify(workflow, never()).pickWholePallet(any(), any(), anyLong(), any());
+    }
+
    @Test
    void domesticLoadingPhotoDownloadIsScopedToTheCurrentPhysicalContainer() {
        ReceivingContainerSession current = session("CONT-A", "SIGNED");
@@ -85,6 +85,22 @@ class ContainerInboundPlanPreviewTest {
        assertFalse(result.ready());
    }

+    @Test
+    void heldHistoricalOrderRemainsReadyBecauseHoldOnlyBlocksOutbound() {
+        when(orderMapper.containerPreviewOrders("BOOKING-HELD")).thenReturn(List.of(
+            new InboundPlanOrderMapper.ContainerPreviewOrderRow("100", 1L, "LM-HELD", "FO-1",
+                "测试客户", "FIRST_LEG", "FBA", "IN-1", "PENDING_ASSIGNMENT", null,
+                "MSCU6639870", 1, 10, new BigDecimal("1.0000"), "193000000000200003", "US-LAX-01",
+                "洛杉矶仓", "ACY2", null, null, "Amazon ACY2", 0, true, 1,
+                null, null, null, null, 1)));
+
+        var result = service.previewContainer("BOOKING-HELD");
+
+        assertEquals(true, result.ready());
+        assertEquals("READY", result.groups().get(0).orders().get(0).readiness());
+        assertEquals(List.of(), result.groups().get(0).orders().get(0).blockers());
+    }
+
    @Test
    void dropshipPreviewKeepsUnderlyingFbaFactSeparateFromItsDisplayCategory() {
        when(orderMapper.containerPreviewOrders("BOOKING-DROPSHIP")).thenReturn(List.of(
@@ -352,21 +352,23 @@ class InboundPlanServiceTest {
    }

    @Test
-    void refusesManualPlanForHeldOrderBeforeWriting() {
+    void createsManualPlanForHeldHistoricalOrderBecauseHoldOnlyBlocksOutbound() {
        SourceOrderSnapshot held = new SourceOrderSnapshot(2L, "100", "MSCU6639870", "RK-2",
            "PENDING_ASSIGNMENT", null, new BigDecimal("1.0000"), 10, 0,
            "193000000000200003", "US-LAX-01", "洛杉矶仓", null,
-            null, "WH-A", "仓A", 1, 0, true, 5);
+            "WH-A", "WH-A", "仓A", 1, 0, true, 5);
        when(orderMapper.lockOrder("100", 2L)).thenReturn(List.of(held));
+        when(orderMapper.markPlannedManual(eq("100"), eq(2L), any(), eq(1), eq(false), eq(5), any()))
+            .thenReturn(1);

-        ResponseStatusException error = assertThrows(ResponseStatusException.class, () -> service.convertManual(
+        var result = service.convertManual(
            new ManualInboundPlanRequest("100", 2L, 5,
                1, "STANDARD", false, false, false, null),
-            "manual-held", "900"));
+            "manual-held", "900");

-        assertEquals(409, error.getStatusCode().value());
-        verify(planMapper, never()).insert(any(InboundPlan.class));
-        verify(commandMapper, never()).insert(any(com.baiyue.lastleg.entity.LastlegOrderCommandRecord.class));
+        assertEquals(2L, result.sourceOrderId());
+        verify(planMapper).insert(any(InboundPlan.class));
+        verify(orderMapper).markPlannedManual(eq("100"), eq(2L), any(), eq(1), eq(false), eq(5), any());
    }

    @Test
@@ -280,6 +280,23 @@ class InventoryCommandServiceTest {
        verify(balances, never()).updateById(any(InventoryBalance.class));
    }

+    @Test
+    void holdsAllAvailablePositionsForOneInboundOrder() {
+        InventoryBalance balance = balance(200L, 5);
+        InventoryPosition position = position(201L, 200L, 5);
+        when(commands.lockInboundAvailablePositions("100", 101L)).thenReturn(List.of(position));
+        when(commands.lockPosition("100", 201L)).thenReturn(position);
+        when(commands.lockBalance("100", 200L)).thenReturn(balance);
+
+        service.holdInboundOrderInventory("100", "7", 101L, "ORD-1", "质检暂扣");
+
+        assertEquals(0L, position.getAvailablePackages());
+        assertEquals(5L, position.getHoldPackages());
+        assertEquals(0L, balance.getAvailablePackages());
+        assertEquals(5L, balance.getHoldPackages());
+        verify(ledgers).insert(any(InventoryLedger.class));
+    }
+
    @Test
    void replayUsesPersistedResultWithoutMutatingInventoryAgain() throws Exception {
        var request = stockIn("IN-1", "stock-in-1", 12, 24);
@@ -16,6 +16,15 @@ class MerchantOverseasOpenApiContractTest {
        }

        for (String path : new String[] {
+            "/api/merchant/v1/last-leg/orders:",
+            "/api/merchant/v1/last-leg/orders/{id}:",
+            "/api/merchant/v1/last-leg/warehouse-transfers:",
+            "/api/merchant/v1/last-leg/warehouse-transfers/{transferNo}:",
+            "/api/merchant/v1/last-leg/warehouse-transfers/{transferNo}/confirm-measurement:",
+            "/api/merchant/v1/last-leg/cargo-discards:",
+            "/api/merchant/v1/last-leg/cargo-discards/inventory-candidates:",
+            "/api/merchant/v1/last-leg/cargo-discards/{discardNo}:",
+            "/api/merchant/v1/last-leg/cargo-discards/{discardNo}/cancel:",
            "/api/merchant/v1/last-leg/overseas-procurements:",
            "/api/merchant/v1/last-leg/overseas-procurements/{orderNo}:",
            "/api/merchant/v1/last-leg/us-truck-orders:",
@@ -35,6 +44,20 @@ class MerchantOverseasOpenApiContractTest {
            .contains("merchant:cross-border:pallet-shipping:list")
            .contains("merchant:cross-border:pallet-shipping:create")
            .contains("merchant:cross-border:pallet-shipping:edit")
+            .contains("merchant:overseas-warehouse:last-mile-order:list")
+            .contains("merchant:overseas-warehouse:transfer:list")
+            .contains("merchant:overseas-warehouse:transfer:create")
+            .contains("merchant:overseas-warehouse:transfer:confirm")
+            .contains("merchant:overseas-warehouse:discard:list")
+            .contains("merchant:overseas-warehouse:discard:create")
+            .contains("merchant:overseas-warehouse:discard:cancel")
+            .contains("merchant:overseas-warehouse:relabel:list")
+            .contains("merchant:overseas-warehouse:relabel:create")
+            .contains("merchant:overseas-warehouse:relabel:files")
+            .contains("merchant:overseas-warehouse:relabel:confirm")
+            .contains("merchant:overseas-warehouse:return-order:list")
+            .contains("merchant:overseas-warehouse:return-order:create")
+            .contains("merchant:overseas-warehouse:return-order:relabel")
            .contains("merchant:warehouse:inbound:list")
            .contains("#/components/schemas/ProcurementDetailResponse")
            .contains("#/components/schemas/TruckDetailResponse")
@@ -12,6 +12,7 @@ import com.baiyue.lastleg.mapper.LastlegOrderManualNodeHistoryMapper;
 import com.baiyue.lastleg.mapper.LastlegOrderManualNodeMapper;
 import com.baiyue.lastleg.mapper.LastlegOrderMapper;
 import com.baiyue.lastleg.mapper.LastlegOrderOperationLogMapper;
+import com.baiyue.lastleg.inventory.command.service.InventoryCommandService;
 import com.fasterxml.jackson.databind.json.JsonMapper;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
@@ -48,6 +49,7 @@ class LastlegOrderCommandServiceTest {
    @Mock LastlegOrderManualNodeHistoryMapper manualNodeHistory;
    @Mock LastlegOrderOperationLogMapper operationLogs;
    @Mock InboundOrderDetainedOutboxService detainedOutbox;
+    @Mock InventoryCommandService inventory;
    LastlegOrderCommandService service;

    @BeforeEach
@@ -60,12 +62,14 @@ class LastlegOrderCommandServiceTest {
        ReflectionTestUtils.setField(service, "manualNodeHistory", manualNodeHistory);
        ReflectionTestUtils.setField(service, "operationLogs", operationLogs);
        ReflectionTestUtils.setField(service, "detainedOutbox", detainedOutbox);
+        ReflectionTestUtils.setField(service, "inventory", inventory);
        ReflectionTestUtils.setField(service, "objectMapper", JsonMapper.builder().findAndAddModules().build());
    }

    @Test
    void holdsOnlySelectedOrderWithVersionAndImmutableHistory() {
        LastlegOrder order = order(11L, 3);
+        order.setCurrentStatus("INBOUND_COMPLETED");
        when(orders.selectById(11L)).thenReturn(order);
        when(orders.lockById("100", 11L)).thenReturn(order);
        when(orders.updateHold(eq("100"), eq(11L), eq(true), eq(true), eq("海关查验"), eq(3),
@@ -80,9 +84,42 @@ class LastlegOrderCommandServiceTest {
        verify(orders).updateHold(eq("100"), eq(11L), eq(true), eq(true), eq("海关查验"), eq(3), any());
        verify(holdHistory).insert(any(LastlegOrderHoldHistory.class));
        verify(commands).insert(any(LastlegOrderCommandRecord.class));
+        verify(inventory).holdInboundOrderInventory("100", "900", 11L, "LL-11", "海关查验");
        verify(orders, never()).lockContainerOrders(any());
    }

+    @Test
+    void releasingHoldMovesOrderInventoryBackToAvailable() {
+        LastlegOrder order = order(11L, 3);
+        order.setCurrentStatus("INBOUND_COMPLETED");
+        order.setDetained(true);
+        when(orders.selectById(11L)).thenReturn(order);
+        when(orders.lockById("100", 11L)).thenReturn(order);
+        when(orders.updateHold(eq("100"), eq(11L), eq(false), eq(false), eq("质检通过"), eq(3),
+            any(LocalDateTime.class))).thenReturn(1);
+
+        service.hold("100", 11L, "release-11",
+            new LastlegOrderCommandDtos.HoldRequest(false, false, "质检通过", 3), "900", "管理员");
+
+        verify(inventory).releaseInboundOrderHold("100", "900", 11L, "LL-11", "质检通过");
+    }
+
+    @Test
+    void rejectsNewHoldBeforeInboundCompletion() {
+        LastlegOrder order = order(11L, 3);
+        when(orders.selectById(11L)).thenReturn(order);
+        when(orders.lockById("100", 11L)).thenReturn(order);
+
+        ResponseStatusException error = assertThrows(ResponseStatusException.class, () -> service.hold("100", 11L,
+            "hold-before-inbound", new LastlegOrderCommandDtos.HoldRequest(true, false, "待入库", 3),
+            "900", "管理员"));
+
+        assertEquals(409, error.getStatusCode().value());
+        assertEquals("货物完成入库后才能暂扣", error.getReason());
+        verify(orders, never()).updateHold(anyString(), anyLong(), anyBoolean(), anyBoolean(),
+            nullable(String.class), anyInt(), any(LocalDateTime.class));
+    }
+
    @Test
    void rejectsStaleHoldWithoutAnyWrite() {
        LastlegOrder order = order(11L, 4);
@@ -49,7 +49,6 @@ import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.ArgumentMatchers.anyLong;
 import static org.mockito.ArgumentMatchers.anyInt;
 import static org.mockito.ArgumentMatchers.eq;
-import static org.mockito.ArgumentMatchers.isNull;
 import static org.mockito.ArgumentMatchers.anyLong;
 import static org.mockito.Mockito.never;
 import static org.mockito.Mockito.verify;
@@ -69,7 +68,6 @@ class LastlegOrderServiceTest {
    @Mock InboundPlanCartonMapper cartons;
    @Mock FbaWarehouseValidator fbaWarehouses;
    @Mock InventoryCommandService inventory;
-    @Mock InboundOrderDetainedOutboxService detainedOutbox;
    @Mock ReceivingWarehouseOperationMapper receivingWarehouseOperations;
    @Mock ContainerArrivalTimeOperationMapper containerArrivalTimeOperations;
    @Mock WarehouseResourceGateway warehouseResourceGateway;
@@ -116,7 +114,6 @@ class LastlegOrderServiceTest {
                Long.parseLong(invocation.getArgument(0)), invocation.getArgument(1), invocation.getArgument(2),
                "US", "CA"));
        ReflectionTestUtils.setField(service, "inventory", inventory);
-        ReflectionTestUtils.setField(service, "detainedOutbox", detainedOutbox);
        ReflectionTestUtils.setField(service, "receivingWarehouseOperations", receivingWarehouseOperations);
        ReflectionTestUtils.setField(service, "containerArrivalTimeOperations", containerArrivalTimeOperations);
        ReflectionTestUtils.setField(service, "warehouseResourceGateway", warehouseResourceGateway);
@@ -559,40 +556,6 @@ class LastlegOrderServiceTest {
        assertEquals("NYEXX2609060063", result.records().get(2).inboundCode());
    }

-    @Test
-    void holdingBeforeInboundPersistsTheOrderMarkerAndOperationRemark() {
-        LastlegOrder order = order(11L, "100", "PENDING_INBOUND", null);
-        when(orders.selectOne(any())).thenReturn(order);
-        when(orders.lockById("100", 11L)).thenReturn(order);
-
-        service.setDetained("100", 11L, new LastlegOrderRequests.SetDetained(true, "等待质检"), "operator");
-
-        assertTrue(order.getDetained());
-        verify(orders).updateById(order);
-        ArgumentCaptor<com.baiyue.lastleg.entity.LastlegOrderOperationLog> operation =
-            ArgumentCaptor.forClass(com.baiyue.lastleg.entity.LastlegOrderOperationLog.class);
-        verify(operations).insert(operation.capture());
-        assertEquals("暂扣", operation.getValue().getOperationNode());
-        assertEquals("等待质检", operation.getValue().getResult());
-        verify(detainedOutbox).publish(eq(order), eq(true), eq("等待质检"), isNull(), eq("operator"), any(), anyLong());
-        verify(inventory, never()).releaseInboundOrderHold(any(), any(), anyLong(), any(), any());
-    }
-
-    @Test
-    void releasingAfterInboundMovesAllOrderHeldInventoryToAvailable() {
-        LastlegOrder order = order(11L, "100", "INBOUND_COMPLETED", "IP-1");
-        order.setOrderNo("LM-1");
-        order.setDetained(true);
-        when(orders.selectOne(any())).thenReturn(order);
-        when(orders.lockById("100", 11L)).thenReturn(order);
-
-        service.setDetained("100", 11L, new LastlegOrderRequests.SetDetained(false, "质检通过"), "operator");
-
-        verify(inventory).releaseInboundOrderHold("100", "operator", 11L, "LM-1", "质检通过");
-        assertEquals(false, order.getDetained());
-        verify(detainedOutbox).publish(eq(order), eq(false), eq("质检通过"), isNull(), eq("operator"), any(), anyLong());
-    }
-
    private static LastlegOrder order(long id, String customerId, String status, String inboundOrderNo) {
        LastlegOrder order = new LastlegOrder();
        order.setId(id);