| | |
| | | import com.zy.asrs.task.core.ReturnT; |
| | | import com.zy.asrs.task.handler.WorkMastHandler; |
| | | import com.zy.asrs.task.support.OutboundBatchSeqReleaseGuard; |
| | | import com.zy.asrs.task.support.WorkPublishLockKeys; |
| | | import com.zy.asrs.utils.Utils; |
| | | import com.zy.common.utils.RedisUtil; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | public class WorkMastScheduler { |
| | | |
| | | private static final Logger log = LoggerFactory.getLogger(WorkMastScheduler.class); |
| | | private static final int MAX_PUBLISH_TASKS_ONCE = 20; |
| | | private static final long OUTBOUND_USER_NO_LOCK_SECONDS = 60L; |
| | | |
| | | @Autowired |
| | | private WcsApiService wcsApiService; |
| | |
| | | private WorkMastHandler workMastHandler; |
| | | @Autowired |
| | | private OutboundBatchSeqReleaseGuard outboundBatchSeqReleaseGuard; |
| | | @Autowired |
| | | private RedisUtil redisUtil; |
| | | |
| | | @Scheduled(cron = "0/3 * * * * ? ") |
| | | private void execute(){ |
| | |
| | | * @date 2026/1/10 14:42 |
| | | */ |
| | | @Scheduled(cron = "0/10 * * * * ? ") |
| | | private void autoPubTasks() { |
| | | private synchronized void autoPubTasks() { |
| | | // 仅处理待下发/已生成下发号的工作档。 |
| | | List<WrkMast> wrkMasts = wrkMastService.selectList(new EntityWrapper<WrkMast>().in("wrk_sts", Arrays.asList(1L, 11L)) |
| | | .orderBy("user_no", true) |
| | |
| | | } |
| | | } |
| | | |
| | | if (!paramsList.isEmpty()) { |
| | | R r = wcsApiService.pubWrksToWcs(paramsList); |
| | | if (r == null || !Objects.equals(r.get("code"), 200)) { |
| | | log.warn("批量下发任务到WCS失败, result={}", r); |
| | | } |
| | | if (publishTaskChunks(paramsList)) { |
| | | return; |
| | | } |
| | | |
| | | if (outboundTasksByUserNo.isEmpty()) { |
| | |
| | | continue; |
| | | } |
| | | |
| | | R r = wcsApiService.pubWrksToWcs(batchParams); |
| | | if (r == null || !Objects.equals(r.get("code"), 200)) { |
| | | log.warn("批量下发出库任务到WCS失败, userNo={}, batchSeq={}, result={}", userNo, batchSeq, r); |
| | | break; |
| | | if (publishOutboundTaskChunks(userNo, batchSeq, batchParams)) { |
| | | return; |
| | | } |
| | | } |
| | | } |
| | |
| | | return Cools.isEmpty(value) ? "" : value; |
| | | } |
| | | |
| | | private boolean publishTaskChunks(List<WorkTaskParams> paramsList) { |
| | | if (paramsList == null || paramsList.isEmpty()) { |
| | | return false; |
| | | } |
| | | for (int start = 0; start < paramsList.size(); start += MAX_PUBLISH_TASKS_ONCE) { |
| | | int end = Math.min(start + MAX_PUBLISH_TASKS_ONCE, paramsList.size()); |
| | | List<WorkTaskParams> chunk = paramsList.subList(start, end); |
| | | R r = wcsApiService.pubWrksToWcs(chunk); |
| | | if (isWcsSuccess(r)) { |
| | | return true; |
| | | } |
| | | log.warn("批量下发任务到WCS失败, start={}, size={}, result={}", start, chunk.size(), r); |
| | | } |
| | | return false; |
| | | } |
| | | |
| | | private boolean publishOutboundTaskChunks(String userNo, String batchSeq, List<WorkTaskParams> batchParams) { |
| | | if (batchParams == null || batchParams.isEmpty()) { |
| | | return false; |
| | | } |
| | | for (int start = 0; start < batchParams.size(); start += MAX_PUBLISH_TASKS_ONCE) { |
| | | int end = Math.min(start + MAX_PUBLISH_TASKS_ONCE, batchParams.size()); |
| | | List<WorkTaskParams> chunk = batchParams.subList(start, end); |
| | | String lockKey = WorkPublishLockKeys.outboundUserNoLock(userNo); |
| | | String lockValue = String.valueOf(System.currentTimeMillis()); |
| | | if (!redisUtil.setIfAbsent(lockKey, lockValue, OUTBOUND_USER_NO_LOCK_SECONDS)) { |
| | | log.info("出库任务正在下发,跳过本轮, userNo={}, batchSeq={}, lockKey={}", userNo, batchSeq, lockKey); |
| | | return false; |
| | | } |
| | | try { |
| | | R r = wcsApiService.pubWrksToWcs(chunk); |
| | | if (isWcsSuccess(r)) { |
| | | return true; |
| | | } |
| | | log.warn("批量下发出库任务到WCS失败, userNo={}, batchSeq={}, start={}, size={}, result={}", |
| | | userNo, batchSeq, start, chunk.size(), r); |
| | | } finally { |
| | | Object currentLockValue = redisUtil.get(lockKey); |
| | | if (Objects.equals(currentLockValue, lockValue)) { |
| | | redisUtil.del(lockKey); |
| | | } |
| | | } |
| | | } |
| | | return false; |
| | | } |
| | | |
| | | private boolean isWcsSuccess(R r) { |
| | | return r != null && Objects.equals(r.get("code"), 200); |
| | | } |
| | | |
| | | } |