{@link TenantJob} 会按租户分别执行；每个租户每次最多创建一条管芯抓取或托盘搬运任务。
+ */ @XxlJob("dailyPlanStockingJob") @TenantJob public void dailyPlanStockingJob() { @@ -26,7 +31,11 @@ public class DailyPlanCoreTubeJob { XxlJobHelper.handleSuccess(result); } - /** 每次每租户最多创建一条单根管芯出库任务。 */ + /** + * 执行套管调度。 + * + *{@link TenantJob} 会按租户分别执行；每个租户每次最多创建一条单根管芯出库任务。
+ */ @XxlJob("dailyPlanSleevingJob") @TenantJob public void dailyPlanSleevingJob() { diff --git a/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/coretube/CoreTubeTaskContext.java b/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/coretube/CoreTubeTaskContext.java index 0faf976f..66416de7 100644 --- a/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/coretube/CoreTubeTaskContext.java +++ b/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/coretube/CoreTubeTaskContext.java @@ -5,14 +5,24 @@ import lombok.Data; /** 管芯现场任务回调上下文。 */ @Data public class CoreTubeTaskContext { + /** 现场任务业务类型，用于在统一回调中区分处理分支。 */ private String bizType; + /** 任务服务的日计划。托盘移出任务可为空。 */ private Long dailyPlanId; + /** 单根任务对应的排他领取令牌。托盘任务为空。 */ private String claimToken; + /** 单根管芯实例ID。托盘任务为空。 */ private Long coreTubeId; + /** 虚拟管芯编号。 */ private String coreTubeCode; + /** 托盘号；单根任务中用于追踪管芯原托盘。 */ private String vehicleCode; + /** 起始点位记录ID。 */ private Long sourcePointId; + /** 起始点位编码。 */ private String sourcePointCode; + /** 目标点位记录ID；设备逻辑点位可能为空。 */ private Long targetPointId; + /** 目标点位编码。 */ private String targetPointCode; } diff --git a/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/coretube/CoreTubeTaskDispatchService.java b/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/coretube/CoreTubeTaskDispatchService.java index 9fda9a9d..ae3893ce 100644 --- a/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/coretube/CoreTubeTaskDispatchService.java +++ b/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/coretube/CoreTubeTaskDispatchService.java @@ -3,15 +3,19 @@ package cn.code.nl.module.lms.service.coretube; /** 管芯日计划现场任务调度服务。 */ public interface CoreTubeTaskDispatchService { - /** 执行一轮备货调度。 */ + /** + * 执行一轮备货调度。 + * + *优先从对接位抓取一根目标管芯；全部候选都不能直接抓取时，本轮最多创建一条托盘任务。
+ */ String dispatchStockingOnce(); - /** 执行一轮套管调度。 */ + /** 从管芯库选择一根目标管芯并创建出库任务；本轮最多创建一条。 */ String dispatchSleevingOnce(); - /** 处理任务完成。 */ + /** 幂等处理现场任务完成，仅单根任务完成时累计对应日计划进度。 */ void handleFinished(Long taskId, boolean sleeving); - /** 处理任务取消。 */ + /** 幂等处理现场任务取消，释放管芯占用及未确认的日计划 Claim。 */ void handleCancelled(Long taskId, boolean sleeving); } diff --git a/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/coretube/CoreTubeTaskDispatchServiceImpl.java b/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/coretube/CoreTubeTaskDispatchServiceImpl.java index bc96b59e..e64095da 100644 --- a/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/coretube/CoreTubeTaskDispatchServiceImpl.java +++ b/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/coretube/CoreTubeTaskDispatchServiceImpl.java @@ -32,34 +32,52 @@ import java.util.Set; @Service public class CoreTubeTaskDispatchServiceImpl implements CoreTubeTaskDispatchService { + /** 定时调度写入数据库的操作人标识。 */ private static final String OPERATOR = "SCHEDULER"; + /** Task 模块业务防重使用的归属服务。 */ private static final String OWNER_SERVICE = "LMS"; + /** 日计划候选、排他领取及进度确认服务。 */ @Resource private DailyPlanScheduleService dailyPlanScheduleService; + /** 管芯实例数据库访问对象。 */ @Resource private CoreTubeMapper coreTubeMapper; + /** 备货区点位及托盘格位数据库访问对象。 */ @Resource private StockingIvtMapper stockingIvtMapper; + /** 现场运输任务远程服务。 */ @Resource private TransportTaskApi transportTaskApi; + /** AGV 系统类型，由现场 Task/ACS 配置约定。 */ @Value("${lms.core-tube.agv-system-type:AGV}") private String agvSystemType; + /** 缓存位到对接位的托盘移入 ACS 任务类型。 */ @Value("${lms.core-tube.pallet-in-acs-type:CORE_PALLET_IN}") private String palletInAcsType; + /** 对接位到缓存位的托盘移出 ACS 任务类型。 */ @Value("${lms.core-tube.pallet-out-acs-type:CORE_PALLET_OUT}") private String palletOutAcsType; + /** 对接位单根管芯抓取 ACS 任务类型。 */ @Value("${lms.core-tube.stocking-pick-acs-type:CORE_STOCKING_PICK}") private String stockingPickAcsType; + /** 管芯库单根出库 ACS 任务类型。 */ @Value("${lms.core-tube.sleeving-out-acs-type:CORE_SLEEVING_OUT}") private String sleevingOutAcsType; + /** 备货抓取任务的管芯库入口逻辑点位。 */ @Value("${lms.core-tube.stocking-target-point:CORE_WAREHOUSE_IN}") private String stockingTargetPoint; + /** 管芯出库任务的套管机构入口逻辑点位。 */ @Value("${lms.core-tube.sleeving-target-point:SLEEVING_IN}") private String sleevingTargetPoint; - /** 执行一轮备货调度。 */ + /** + * 执行一轮备货调度。 + * + *按当前顺序/权重策略扫描不同规格，任一对接位存在目标管芯时立即创建一条单根抓取任务。 + * 全部规格都不能直接抓取时，才允许创建一条托盘移出或移入任务，避免一轮产生多条托盘任务。
+ */ @Override @Transactional(rollbackFor = Exception.class) public String dispatchStockingOnce() { @@ -81,7 +99,12 @@ public class CoreTubeTaskDispatchServiceImpl implements CoreTubeTaskDispatchServ return createPalletTask(candidates, checkedMaterials); } - /** 执行一轮套管调度。 */ + /** + * 执行一轮套管调度。 + * + *按策略扫描不同规格，从管芯库选择一根可用管芯创建出库任务。缺货时只记录 + * “正在备货”或“备货区库存不足”，继续尝试下一规格。
+ */ @Override @Transactional(rollbackFor = Exception.class) public String dispatchSleevingOnce() { @@ -108,7 +131,12 @@ public class CoreTubeTaskDispatchServiceImpl implements CoreTubeTaskDispatchServ return "全部待套管规格当前均无可出库管芯"; } - /** 创建单根抓取或出库任务。 */ + /** + * 创建单根抓取或出库任务。 + * + *先领取日计划的一根额度，再原子预占管芯并创建 Task。只有 Task 创建及本地绑定都成功， + * 才标记 Claim 已创建任务并推进权重游标；任一步失败由外层事务回滚本地占用。
+ */ protected Long createSingleTubeTask(DailyPlanScheduleCandidate preview, CoreTubeDO tube, boolean sleeving) { DailyPlanScheduleCandidate claim = sleeving ? dailyPlanScheduleService.claimSleevingCandidate(preview.getDailyPlanId(), OPERATOR) @@ -141,7 +169,12 @@ public class CoreTubeTaskDispatchServiceImpl implements CoreTubeTaskDispatchServ return taskId; } - /** 所有规格不能直接抓取时创建一条托盘任务。 */ + /** + * 所有规格都不能直接抓取时创建一条托盘任务。 + * + *对接位有托盘时优先移出；对接位为空时，按“可一次满足剩余量的最小托盘， + * 否则库存最多托盘”选择缓存位托盘。业务键保证同规格未完成移入任务唯一。
+ */ private String createPalletTask(ListTask 模块按 ownerService、bizType、bizId 防重。远程响应丢失时回查未完成任务， + * 避免调用方重试再创建一条相同现场任务。
+ */ private Long createTask(TransportTaskCreateReqDTO request, String bizType, String bizId) { request.setBizType(bizType); request.setBizId(bizId); @@ -262,7 +300,12 @@ public class CoreTubeTaskDispatchServiceImpl implements CoreTubeTaskDispatchServ || CoreTubeTaskBizTypeEnum.CORE_TUBE_STOCKING_PICK.name().equals(task.getBizType())); } - /** 处理任务完成。 */ + /** + * 幂等处理任务完成。 + * + *托盘任务只迁移点位和整托盘管芯位置，不累计日计划数量；单根抓取/出库任务 + * 完成后才清理管芯占用、确认 Claim，并分别累计已备货或已套管数量。
+ */ @Override @Transactional(rollbackFor = Exception.class) public void handleFinished(Long taskId, boolean sleeving) { @@ -302,7 +345,11 @@ public class CoreTubeTaskDispatchServiceImpl implements CoreTubeTaskDispatchServ } } - /** 处理任务取消。 */ + /** + * 幂等处理任务取消。 + * + *只有仍绑定当前 taskId 的管芯会恢复为可用，同时释放对应 Claim；重复取消不会重复释放。
+ */ @Override @Transactional(rollbackFor = Exception.class) public void handleCancelled(Long taskId, boolean sleeving) { diff --git a/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/dailyplan/DailyPlanScheduleServiceImpl.java b/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/dailyplan/DailyPlanScheduleServiceImpl.java index 96ce945d..d5992b56 100644 --- a/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/dailyplan/DailyPlanScheduleServiceImpl.java +++ b/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/dailyplan/DailyPlanScheduleServiceImpl.java @@ -41,25 +41,37 @@ import static cn.code.nl.module.lms.enums.ErrorCodeConstants.DAILY_PLAN_VERSION_ @Service public class DailyPlanScheduleServiceImpl implements DailyPlanScheduleService { + /** 备货进度日志对象编码。 */ private static final String TARGET_STOCKING = "STOCKING"; + /** 套管进度日志对象编码。 */ private static final String TARGET_SLEEVING = "SLEEVING"; + /** 进度变更日志操作类型。 */ private static final String TYPE_PROGRESS = "PROGRESS"; + /** Claim 活动状态。 */ private static final int CLAIM_ACTIVE = 0; + /** Claim 已确认状态。 */ private static final int CLAIM_CONFIRMED = 1; + /** 日计划及进度数据库访问对象。 */ @Resource private DailyPlanMapper dailyPlanMapper; + /** 日计划排他领取数据库访问对象。 */ @Resource private DailyPlanClaimMapper dailyPlanClaimMapper; + /** 顺序/权重调度策略数据库访问对象。 */ @Resource private DailyPlanStrategyMapper dailyPlanStrategyMapper; + /** 日计划操作日志数据库访问对象。 */ @Resource private DailyPlanOperationLogMapper dailyPlanOperationLogMapper; + /** 当前租户默认策略初始化器。 */ @Resource private DailyPlanStrategyInitializer strategyInitializer; + /** 未创建现场任务的 Claim 默认租期，单位秒。 */ @Value("${lms.daily-plan.claim-timeout-seconds:300}") private long claimTimeoutSeconds; + /** 兼容通用调度调用：领取当前策略下第一张备货候选计划。 */ @Override @Transactional(rollbackFor = Exception.class) public DailyPlanScheduleCandidate getNextStockingCandidate(String operator) { @@ -68,6 +80,7 @@ public class DailyPlanScheduleServiceImpl implements DailyPlanScheduleService { return candidates.isEmpty() ? null : claimStockingCandidate(candidates.get(0).getDailyPlanId(), operator); } + /** 兼容通用调度调用：领取当前策略下第一张套管候选计划。 */ @Override @Transactional(rollbackFor = Exception.class) public DailyPlanScheduleCandidate getNextSleevingCandidate(String operator) { @@ -88,7 +101,12 @@ public class DailyPlanScheduleServiceImpl implements DailyPlanScheduleService { return previewCandidates(DailyPlanStrategyTypeEnum.SLEEVING, dailyPlanMapper.selectSleevingCandidates()); } - /** 按当前策略排列候选，但不产生领取。 */ + /** + * 按当前策略排列候选，但不产生领取。 + * + *顺序模式从排序最小的计划开始；权重模式从策略游标开始轮转。预览阶段只决定尝试顺序， + * 不提前分配库存，也不会消耗权重。
+ */ private List同一日计划的备货与套管使用不同 strategyType，可并行各自领取；同一种作业通过 + * 活动唯一键保证同一时刻最多一个 Claim。
+ */ private DailyPlanScheduleCandidate claimCandidate(DailyPlanDO plan, int quantity, Integer strategyMode, DailyPlanStrategyTypeEnum type, String operator) { LocalDateTime expireTime = nextClaimExpireTime(); @@ -202,7 +225,11 @@ public class DailyPlanScheduleServiceImpl implements DailyPlanScheduleService { return candidate; } - /** 现场单根任务创建成功后推进权重轮转。 */ + /** + * 现场单根任务创建成功后推进权重轮转。 + * + *AGV 托盘任务和候选跳过都不会调用本方法，因此不会提前消耗某张计划的权重。
+ */ @Override @Transactional(rollbackFor = Exception.class) public void confirmTaskCreated(String claimToken, String operator) { diff --git a/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/dailyplan/DailyPlanStrategyInitializer.java b/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/dailyplan/DailyPlanStrategyInitializer.java index 2e167c0c..dd77932b 100644 --- a/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/dailyplan/DailyPlanStrategyInitializer.java +++ b/nl-module-lms/nl-module-lms-server/src/main/java/cn/code/nl/module/lms/service/dailyplan/DailyPlanStrategyInitializer.java @@ -19,13 +19,22 @@ import static cn.code.nl.module.lms.enums.ErrorCodeConstants.DAILY_PLAN_STRATEGY @Component public class DailyPlanStrategyInitializer { + /** 系统调度操作人标识。 */ private static final String SYSTEM_OPERATOR = "SCHEDULER"; + /** 日计划策略数据库访问对象。 */ @Resource private DailyPlanStrategyMapper strategyMapper; + /** 用于建立独立事务，隔离并发初始化产生的唯一键冲突。 */ @Resource private PlatformTransactionManager transactionManager; + /** + * 获取当前租户、指定作业类型的策略；不存在时初始化为顺序模式。 + * + *初始化始终使用独立事务。并发插入冲突后，必须等冲突事务回滚，再使用全新的事务读取 + * 另一线程已经提交的策略，避免 MySQL 可重复读快照导致误判策略仍不存在。
+ */ public DailyPlanStrategyDO getOrCreate(DailyPlanStrategyTypeEnum type) { TransactionTemplate transaction = new TransactionTemplate(transactionManager); transaction.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW); @@ -42,6 +51,7 @@ public class DailyPlanStrategyInitializer { } } + /** 在独立事务内查询或创建默认策略。 */ private DailyPlanStrategyDO loadOrInsert(DailyPlanStrategyTypeEnum type) { DailyPlanStrategyDO current = strategyMapper.selectByStrategyType(type.getCode()); if (current != null) {