diff --git a/nflg-wms-scheduled/src/main/java/com/nflg/wms/scheduled/processor/QCMaterialSyncProcessor.java b/nflg-wms-scheduled/src/main/java/com/nflg/wms/scheduled/processor/QCMaterialSyncProcessor.java index 889741b9..6e92d196 100644 --- a/nflg-wms-scheduled/src/main/java/com/nflg/wms/scheduled/processor/QCMaterialSyncProcessor.java +++ b/nflg-wms-scheduled/src/main/java/com/nflg/wms/scheduled/processor/QCMaterialSyncProcessor.java @@ -2,6 +2,7 @@ package com.nflg.wms.scheduled.processor; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollectionUtil; +import cn.hutool.core.util.NumberUtil; import cn.hutool.core.util.StrUtil; import com.nflg.wms.common.pojo.dto.MaterialMainListByDateDTO; import com.nflg.wms.common.util.UserUtil; @@ -18,10 +19,12 @@ import tech.powerjob.worker.log.OmsLogger; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; +import java.time.temporal.TemporalUnit; import java.util.ArrayList; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; +import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; /** @@ -41,9 +44,19 @@ public class QCMaterialSyncProcessor implements BasicProcessor { OmsLogger log = context.getOmsLogger(); try { log.info("开始"); + String params = context.getJobParams(); + log.info("参数:{}", params); + int minutes = 5; + if (StrUtil.isNotBlank(params)) { + if (NumberUtil.isNumber(params)) { + minutes = NumberUtil.parseInt(params); + } else { + log.warn("参数不是数字,将使用默认值:" + minutes); + } + } DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); - String startDateTime = LocalDate.now().minusDays(1).atStartOfDay().format(formatter); - String endDateTime = LocalDate.now().minusDays(1).atTime(23, 59, 59).format(formatter); + String endDateTime = LocalDateTime.now().format(formatter); + String startDateTime = LocalDateTime.now().minusMinutes(minutes).format(formatter); log.info("开始同步物料,范围开始时间:{},结束时间:{}", startDateTime, endDateTime); // 从主物料系统查询指定日期范围的物料列表