20 KiB
20 KiB
Lastleg Service 模块指引
职责与边界
- Mapper 统一显式使用
@Mapper,仅由BaiyueLastlegApplication.java对com.baiyue.lastleg根包按annotationClass = Mapper.class扫描;各业务切片不得新增*MapperConfiguration或维护包白名单。静态门禁见根scripts/mapper-scan-contract.mjs,模块内门禁见MapperRegistrationArchitectureTest.java。 - 负责消费头程装柜完成事件,保存业务 Inbox,并按最终实装入仓单建立待分配尾程订单、明细冻结快照和初始状态历史;事件不得自动创建入仓计划,平台人工调用
/api/platform/v1/last-leg/inbound-plans/convert后才生成计划并推进订单。 - 负责尾程订单列表、详情、导出和目的仓调整,以及海外入仓计划、托盘分配与 PDA 入仓作业;PDA 卸柜完成后通过本地 Outbox 向国内头程回传货柜报空事实。
- 不查询头程数据库,不调用头程接口补齐建单字段;事件快照缺失时应拒绝消费并保留可诊断错误。
快速索引
| 功能 | 入口 |
|---|---|
| 内部模块化基线与依赖分析 | 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 服务端聚合全柜订单、入仓码、计划数、未操作数和 allPlansReady,/{sourceContainerBookingId} 返回柜内全部订单/入仓码/计划状态且不受订单分页截断;plannedArrivalAt 只取装柜完成事件 estimatedWarehouseArrivalAt 冻结到 ll_order.estimated_warehouse_at 的正式事实,按其升序、null 最后、稳定柜 ID 排序;目的仓调整仅接受国内 Warehouse Service 平台公共 ACTIVE + FBA 主档,写入前由 service/FbaWarehouseValidator.java 经内部只读目录校验 ID/编码/名称一致 |
| 客户尾程订单列表与详情 | controller/MerchantLastlegOrderController.java;客户范围只取认证身份,稳定类型/状态见 model/LastlegOrderType.java、LastlegOrderStatus.java |
| 装柜完成事件消费 | service/LoadingCompletedConsumer.java;当前生产信封为 FIRST_LEG_LOADING_PLAN_COMPLETED V2,消费端冻结 destinationType:FBA 可按箱数且不生成逐箱作业账,OVERSEAS 必须逐箱校验并生成箱级事实;历史缺字段事件仅按明确 FBA 单号或目的仓与接柜仓一致性安全推断,歧义直接拒绝 |
| 尾程单号生成 | service/LastlegOrderNoGenerator.java |
| 订单查询与更新 | service/LastlegOrderService.java |
| 业务 Inbox | entity/LastlegEventInbox.java、mapper/LastlegEventInboxMapper.java |
| 尾程订单、明细、状态历史 | entity/LastlegOrder.java、LastlegOrderDetail.java、LastlegOrderStatusHistory.java 及对应 Mapper |
| 独立尾程入仓单快照 | entity/LastlegInboundOrder.java、mapper/LastlegInboundOrderMapper.java;按客户与来源入仓标识冻结 inboundCode、来源/根订单及目的仓,不以尾程订单行代替入仓单聚合 |
| 内部令牌保护 | security/InternalServiceTokenGuard.java |
| IAM 海外安全投影与实时校验 | 内部入口 security/controller/LastlegSecurityController.java,固定 /internal/lastleg/security/v1/events、/validate 且复用 InternalServiceTokenGuard;投影/校验 security/service/,DTO security/dto/,表固定 ll_security_event_inbox、ll_security_projection;MySQL 投影缺失、落后或不可用一律 fail-closed,Redis 仅为提交后可重建镜像;业务切片不得直接依赖投影内部类,边界由 SecurityProjectionArchitectureTest 与 Node 合同锁定 |
| 入仓计划分页、转换与详情 | inboundplan/controller/InboundPlanController.java、inboundplan/dto/InboundPlanRequests.java、InboundPlanListResponse.java、inboundplan/mapper/InboundPlanQueryMapper.java、inboundplan/service/InboundPlanService.java;整柜转换固定为 /convert-container,锁定同一 sourceContainerBookingId 后每票独立生成计划,整批原子且幂等 |
| 托盘分配算法 | inboundplan/service/PalletAllocator.java |
| FBA 预约创建、详情与编辑 | InboundPlanController.java 的 /fba-appointments/**、inboundplan/service/InboundFbaAppointmentService.java、BatchFbaAppointmentRequest.java、UpdateFbaAppointmentRequest.java |
| PDA 入仓、实收、上架与完成 | inboundplan/pda/controller/ReceivingContainerController.java、inboundplan/pda/service/ReceivingContainerService.java、内部编排 InboundPdaWorkflowService.java;公网入口固定为 /api/pda/v1/last-leg/receiving-containers/**,/warehouse-profile 只按 Token 绑定仓解析共享仓库中文名称与编码,旧 planNo/allocationId Controller 已移除 |
| PDA 卸柜照片上传、归属校验与预览 | ReceivingContainerController.java 的 /current/unload-photos/files、/current/unload-photos/files/{fileId}/download,网关 inboundplan/pda/gateway/UnloadPhotoFileGateway.java、HttpUnloadPhotoFileGateway.java;File 类型固定 OVERSEAS_UNLOAD_PHOTO,下载只允许当前会话已签收的 fileId 并返回 no-store |
| 卸柜照片与海外卸柜完成 Outbox | ReceivingContainerController.java、ReceivingContainerService.java、inboundplan/pda/service/InboundUnloadCompletedOutboxService.java、entity/LastlegEventOutbox.java、mapper/LastlegEventOutboxMapper.java;多计划同柜只能在全柜完成后调用 publishContainerCompleted,按来源柜预订 ID 幂等发布一次,完成时刻与拍照时刻分离;事件模型见 ../common-event-contract/AGENTS.md |
| 入仓后 SKU 库存余额、库位和流水 | inventory/;平台只读查询与非出库库存命令分别从 inventory/query/controller/InventoryQueryController.java、inventory/command/controller/InventoryCommandController.java 进入 |
| 海外PDA盘点、同仓整托移库、托盘组拆换绑与换标现场作业 | pda/stocktake/、pda/move/、palletops/、relabel/pda/;版本化契约 src/main/resources/openapi/overseas-pda-operations-v1.yaml;全部范围取自PDA Token,不含出库和派送 |
| 船节点接收与海外 PDA 可收货门禁 | shipping/service/ContainerShippingNodeConsumer.java、shipping/entity/ContainerShippingGate.java、shipping/mapper/ContainerShippingGateMapper.java;只单调接受实际标准节点,PICKUP_READY 及以后才允许对应柜进入 PDA 收货候选 |
| 平台排车列表/详情与智能预排 | dispatch/controller/DispatchQueryController.java、SmartDispatchController.java、dispatch/mapper/DispatchCandidateMapper.java、dispatch/service/DispatchService.java;草稿柜 entity/DispatchDraftContainer.java、mapper/DispatchDraftContainerMapper.java,托盘锁 DispatchPalletLock.java;入口 /api/platform/v1/last-leg/dispatches,范围开关与禁用写操作见“四期开发范围路由” |
| 仓储资源调用 | inboundplan/pda/gateway/WarehouseResourceGateway.java、HttpWarehouseResourceGateway.java |
| 仓储转运、历史订单/入仓绑定、可选换标联动 | transfer/controller/WarehouseTransferController.java、transfer/service/WarehouseTransferService.java |
| 一件代发接收、SKU/箱唛库存 | dropship/service/DropshipOrderService.java、dropship/entity/、dropship/mapper/ |
| 货物废弃、待审锁箱、审批扣减 | discard/controller/CargoDiscardController.java、discard/service/CargoDiscardService.java |
| 海外采购、客户下单、采购审核、客户/采购仓候选与操作流水 | procurement/controller/、procurement/service/OverseasProcurementService.java;OpenAPI src/main/resources/openapi/overseas-business-v1.yaml |
| 美国/本土卡车订单 | trucking/controller/PlatformUsTruckOrderController.java、MerchantUsTruckOrderController.java 及同子域 Service/DTO |
| 本土散板订单 | looseboard/controller/PlatformLocalLooseboardController.java 及同子域 Service/DTO/Entity/Mapper;OpenAPI src/main/resources/openapi/overseas-business-v1.yaml |
| 海外仓报价、月度汇率、车辆主数据 | 报价 masterdata/quote/、汇率 masterdata/exchange/;车辆入口 masterdata/vehicle/adapter/in/web/PlatformVehicleController.java,应用服务 application/VehicleApplicationService.java,持久化端口与适配器 application/port/out/VehicleRepository.java、adapter/out/persistence/;OpenAPI src/main/resources/openapi/overseas-master-data-v1.yaml,车辆档案不含派送履约历史 |
| 跨服务 HTTP 客户端装配 | config/LastlegRestClientFactory.java、config/LastlegRestClientProperties.java;目标地址与内部服务令牌只来自配置,不在业务子域手工创建客户端 |
| 数据库基线、表索引与中文注释契约 | src/main/resources/db/lastleg.sql、src/test/java/com/baiyue/lastleg/schema/SchemaChineseCommentContractTest.java |
| 测试 | src/test/java/com/baiyue/lastleg/ |
| 真实事件消费验收 | src/test/java/com/baiyue/lastleg/service/TaillegRealConsumerAcceptanceTest.java;覆盖真实 V2 建单、独立入仓单快照及下游转运/换标可消费性 |
四期开发范围路由
- 四期在本服务内只进入尾程订单、入仓计划/PDA 入仓、换标、产品与箱唛快照、库存、海外采购和本土卡车;本土散板新增实现也归本服务的独立稳定子域。
dispatch/、delivery/、出库单、PDA 出库拣货、派送和其他库存离仓能力虽然已存在于服务代码或表结构中,但不属于当前四期开发与验收范围,不得因代码已存在而自动纳入。- 历史排车编辑/取消/出库、PDA 出库和
delivery/Controller 默认不注册;只有后续阶段明确启用lastleg.future-outbound-api.enabled=true才可恢复。平台排车列表与详情由lastleg.dispatch-query-api.enabled=true独立启用;入库单智能排车候选、草稿锁定/解锁/释放和预排创建由lastleg.smart-dispatch-api.enabled=true独立启用。这些排车平台入口均不接收customerId:排车列表跨客户分页,详情按全局排车单号定位后使用记录自身客户范围加载明细;智能排车候选未传计划 ID 时跨客户查询,传入时根据计划 ID 解析范围;托盘移入草稿时立即以操作人和随机草稿标识锁定,移除或关闭时释放,草稿锁超时失效;预排创建根据所选托盘 ID 在服务端解析并校验唯一客户范围,并将当前操作人的草稿锁原子转换为正式排车锁。预排只能创建待出库排车并锁定托盘,不得借此开放编辑、取消、depart、PDA 出库或派送。四期平台库存 Controller 不映射 allocate、unallocate、pick、ship。 - 仓库 ID、类型、状态、地址和能力唯一权威归国内
warehouse-service;海外库位、实物托盘和资源锁归warehouse-overseas-service/且只引用同一国内warehouseId。Lastleg PDA 通过 Warehouse Overseas 内部资源入口校验该国内共享收货仓,不得要求海外数据库重复建仓;浏览器 API 统一经gateway-overseas/。
数据库表索引与注释约束
| 业务域 | 表名 | 中文含义 |
|---|---|---|
| 核心订单与事件 | ll_loading_*、ll_event_*、ll_order*、ll_inbound_order* |
事件收件/发件、尾程订单、明细及状态历史 |
| 入仓计划与作业 | ll_inbound_plan*、ll_inbound_pda*、ll_inbound_pallet_merge、ll_inbound_fba_appointment* |
入仓计划、托盘分配、PDA 作业、合托及 FBA 预约 |
| 库存 | ll_inventory_*、ll_inbound_stock_receipt |
库存余额、仓位、流水、命令幂等及实收快照 |
| 派车与出库 | ll_dispatch_*、ll_outbound_*、ll_delivery_order |
派车、PDA 拣货、出库及派送 |
| 转仓与换标 | ll_warehouse_transfer_*、ll_relabel_* |
转仓单、库存转移、目标收货及换标 |
| 一件代发与废弃 | ll_dropship_*、ll_cargo_discard_* |
托盘/箱唛库存、流水和废弃审批 |
| 采购、卡车与本土散板 | ll_overseas_procurement_*、ll_us_truck_*、ll_local_looseboard_* |
海外采购、美国卡车运输及本土散板订单 |
| 通用资料 | ll_overseas_quote*、ll_monthly_exchange_rate*、ll_vehicle |
海外仓报价、月度汇率及车辆档案;不保存车辆派送履约历史 |
| 海外安全投影 | ll_security_event_inbox、ll_security_projection |
IAM 安全事件可靠收件箱与 Lastleg 本地授权投影;只允许内部服务入口访问,不作为 loading、shipping、inbound 等业务模型 |
- 新增或修改表时,表
COMMENT和每个普通字段的COMMENT必须填写准确的中文业务含义,不得只写英文、字段名或类型名。 SchemaChineseCommentContractTest自动扫描全部ll_表,无需维护表名白名单;新增字段必须同步更新基线 SQL、建表增量和存量备注迁移,增量脚本的ADD/MODIFY COLUMN不得丢失中文备注。- 表备注、字段备注和索引变更必须可重复执行;存量库的备注修订通过统一增量脚本落地,不依赖基线建表语句。
事件建单规则
- 只接受冻结契约支持的事件类型和版本;校验事件 ID、租户、区域、Payload 哈希及必要字段。
- 同一实际集装箱
containerNo生成一个共享业务尾程单号;payload.orders每项按sourceInboundId独立落一条雪花 IDll_order,并保存对应明细和初始状态历史。整柜操作不使用cabinetNo。 ONE_CLICK_DROPSHIP每个来源入仓单必须携带一个或多个不可变来源托盘快照;每托按 SKU 携带箱数、数量和箱唛。校验订单汇总一致、托盘号/SKU/箱唛唯一后,按托建立档案及 SKU 库存,并建立箱唛和流水。仓库实物托盘由 Warehouse API 分配,不得覆盖来源托盘快照。- 其他订单类型只建立入仓单维度的尾程订单与冻结明细,来源
palletCount强制为 0;后续 PDA 托盘属于海外仓作业资源。 - 整个事件消费在一个事务内完成;任意订单失败时不得留下部分订单。
- 相同事件重复投递返回既有结果,不重新生成单号或插入明细。来源入仓单唯一约束是最终防线。
- 装柜完成事件只把尾程订单建立为
PENDING_ASSIGNMENT。FIRST_LEG在途库存使用不可变来源入仓码作为计划生成前的inbound_order_no展示快照;平台人工转换成功后,同一事务将订单推进为INBOUND_PLANNED,并把对应库存余额的该快照收口为新planNo。 - 内部接口先执行常量时间令牌校验;缺失或错误令牌不得进入消费事务。
- IAM 安全事件只能进入
/internal/lastleg/security/v1/events;通用/internal/lastleg/events只白名单接收装柜完成与实际船节点事件,禁止把 IAM 事件交给LoadingCompletedConsumer。 - Lastleg 安全投影只接受
ACTIVE/DISABLED两态安全语义;客户建档和审核的PROFILE_REQUIRED/PENDING/REJECTED/ARCHIVED由 IAM 在发布前统一折叠为DISABLED,Lastleg 不兼容或解释国内工作流状态。 - 开发基线只为国内固定
authUserId=1000001、tenantId=0的platform_admin写 USER/AUTHORIZATION version=0 投影;使用INSERT IGNORE,后续 IAM version>=1 事件单调覆盖。不得扩大为历史账号运行时补齐或缺失投影默认放行。 - PDA 入仓任务完成前必须先通过
/unload-photos保存非空且不重复的卸柜照片文件 ID;照片上传时间由服务端记录,预计报空时间固定为照片上传时间加两天。完成入仓时,库存入账、计划/任务状态推进与OVERSEAS_CONTAINER_UNLOADEDV1 Outbox 必须处于同一事务;事件绑定来源头程货柜身份,不得从前端请求拼装或回查头程数据库。 - 海外 PDA 柜号签收只允许平台
OVERSEAS_WAREHOUSE_PDA_OPERATOR使用lastleg:pda:operate;国内头程 PDA 角色不得进入。PDA 不接收customerId,候选跨客户读取,选柜时从柜内计划唯一解析并冻结真实客户。未完成会话按平台操作账号和柜号分别全局唯一,后续照片、扫码、实收、库存与完成操作只使用会话客户范围;平台管理员和客户账号不得进入该作业入口。
查询与租户约束
- 平台查询范围由可信身份/平台权限决定;商户查询只能使用认证身份中的客户 ID。
- 尾程平台只读查询接口的
customerId为可选筛选条件:平台身份省略时查询全部客户数据,传入时按指定客户过滤;商户身份忽略客户端传入值并始终按 Token 中的自身客户隔离。创建、编辑、审核等需要明确目标客户的写接口仍必须传入customerId。 - 常规入仓库存余额以客户、海外仓、目的仓和入仓单为唯一业务维度并汇总箱数;SKU 继续保存在箱唛、实收和流水快照中,余额 SKU 仅作单 SKU 展示或以
MIXED标识多 SKU,不参与当前唯一维度。 - 列表、详情、导出和更新必须使用同一租户边界,不能仅在列表过滤而让详情或更新越权。
- 目的仓变更必须写状态/操作历史或审计证据,并使用版本控制防止并发覆盖。
- 货物废弃只使用可核对 SKU 和箱唛的一件代发库存。创建申请只能将箱从
AVAILABLE锁定为DISCARD_PENDING,不得扣减 SKU 箱数;实际扣库存节点固定为具备lastleg:cargo-discard:approve权限的仓库/PDA 审核人确认废弃时,并且必须在审核事务内调用专用 discard adjustment。该 adjustment 必须将箱改为DISCARDED、写逐箱业务流水及唯一幂等键,并校验扣减前箱数 - 废弃箱数 = 扣减后箱数且逐箱数等于申请总箱数;任一环节失败须整体回滚。拒绝申请只释放锁箱,不得扣库存。 - 海外采购客户下单固定进入
PENDING_REVIEW;四期采购只维护采购订单、审核、入库数量、候选快照和操作流水,不提供采购出库端点、出库记录或出库数量。采购单据不得写入或冒充available_packages;只有海外仓 PDA 完成实收后,InboundStockReceiptService才能以PDA_STOCK_IN:{taskId}:{allocationId}幂等键调用库存stockIn转入可用库存。禁止通过通用平台接口绕过 PDA 入可用库存。 - 派车状态只允许 PDA 拣货、完成和出库动作推进,普通派车编辑接口不得修改状态。PDA 写操作要求
lastleg:pda:operate;后台库存表单操作要求lastleg:inventory:manage,盘点调整另要求lastleg:inventory:adjust,转仓库存操作要求lastleg:warehouse-transfer:manage。 ll_order.current_status只保存尾程主流程状态;换标、转仓、出库和派送等子单精确状态保存到各自单据并汇总到sub_order_status,不得再用子单状态覆盖主流程状态。PDA 入仓及库存落账完成后,主流程状态固定推进为INBOUND_COMPLETED。
修改与验证
- 移动包、拆分端口/适配器或引入新的跨子域依赖时,先核对内部模块化基线并运行
node --test scripts/analyze-lastleg-dependencies.test.mjs;确需更新依赖基线时必须说明稳定边界变化,不能把临时循环依赖登记为长期豁免。 - 安全投影边界变更同时运行
SecurityProjectionArchitectureTest与LastlegSecurityContractTest;security/controller|dto|service只允许依赖本子域和根InternalServiceTokenGuard,其他 Lastleg 业务包不得直接依赖这些投影内部包。 - 表字段、注释和索引同步维护基线 SQL 与统一增量 SQL;生产/存量库只执行增量脚本。
- 事件契约变化同时检查
common-event-contract版本、Event Bridge 消费方和旧 Payload 哈希兼容。 - 定向验证:
mvn -pl lastleg -am test。 - 事件链路变更至少覆盖重复事件、相同来源入仓单、事务回滚、并发单号、内部令牌和租户越权测试。