github
/
jeecg-boot
mirror of https://github.com/jeecgboot/jeecg-boot
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

feat: skip recent orders from MabangJob (within 5 min)

pull/8523/head
Xue YANG 2025-05-09 15:41:27 +02:00
parent ffc8d8e9bf
commit 5bbc3d9d92
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/domain/job/MabangJob.java
View File

@ -32,13 +32,15 @@ public class MabangJob implements Job {
private IPlatformOrderMabangService platformOrderMabangService; private IPlatformOrderMabangService platformOrderMabangService;
private static final Integer DEFAULT_NUMBER_OF_DAYS = 5; private static final Integer DEFAULT_NUMBER_OF_DAYS = 5;
private static final Integer SKIP_RECENT_MINUTES = 5;
private static final DateType DEFAULT_DATE_TYPE = DateType.EXPRESS; private static final DateType DEFAULT_DATE_TYPE = DateType.EXPRESS;
private static final List<OrderStatus> DEFAULT_STATUSES = Arrays.asList(AllUnshipped, Shipped, Completed); private static final List<OrderStatus> DEFAULT_STATUSES = Arrays.asList(AllUnshipped, Shipped, Completed);
@Override @Override
public void execute(JobExecutionContext context) throws JobExecutionException { public void execute(JobExecutionContext context) throws JobExecutionException {
LocalDateTime endDateTime = LocalDateTime.now(ZoneId.of(ZoneId.SHORT_IDS.get("CTT"))); LocalDateTime endDateTime = LocalDateTime.now(ZoneId.of(ZoneId.SHORT_IDS.get("CTT"))).minusMinutes(SKIP_RECENT_MINUTES);
LocalDateTime startDateTime = endDateTime.minusDays(DEFAULT_NUMBER_OF_DAYS); LocalDateTime startDateTime = endDateTime.minusDays(DEFAULT_NUMBER_OF_DAYS);
log.info("抓单时间范围: {} 到 {}", startDateTime, endDateTime);
DateType dateType = DEFAULT_DATE_TYPE; DateType dateType = DEFAULT_DATE_TYPE;
boolean overrideRestriction = false; boolean overrideRestriction = false;
List<OrderStatus> statuses = DEFAULT_STATUSES; List<OrderStatus> statuses = DEFAULT_STATUSES;