diff --git a/src/main/java/cn/van/business/util/JDUtils.java b/src/main/java/cn/van/business/util/JDUtils.java index dd87aa1..600ff01 100644 --- a/src/main/java/cn/van/business/util/JDUtils.java +++ b/src/main/java/cn/van/business/util/JDUtils.java @@ -255,6 +255,9 @@ public class JDUtils { // 订单号不存在就保存,存在就更新订单状态 orderRowRepository.save(orderRow); } + if (response.getQueryResult().getHasMore()){ + continue; + } } } } @@ -323,7 +326,7 @@ public class JDUtils { /** * 根据指定的日期时间拉取订单 */ - public UnionOpenOrderRowQueryResponse fetchOrdersForDateTime(LocalDateTime startTime, boolean isRealTime) throws Exception { + public UnionOpenOrderRowQueryResponse fetchOrdersForDateTime(LocalDateTime startTime, boolean isRealTime,Integer page) throws Exception { LocalDateTime endTime = isRealTime ? startTime.plusMinutes(10) : startTime.plusHours(1); String key = startTime.format(DATE_TIME_FORMATTER); @@ -332,7 +335,7 @@ public class JDUtils { SetOperations setOps = redisTemplate.opsForSet(); // 调用 API 以拉取订单 - UnionOpenOrderRowQueryResponse unionOpenOrderRowQueryResponse = getUnionOpenOrderRowQueryResponse(startTime, endTime); + UnionOpenOrderRowQueryResponse unionOpenOrderRowQueryResponse = getUnionOpenOrderRowQueryResponse(startTime, endTime,page); // 标记已拉取 setOps.add(key, hourRange); @@ -377,6 +380,7 @@ public class JDUtils { content.append(":::高级菜单:::\r"); content.append("菜单:京+高级+命令 \n 如: 京高级违规30\r"); content.append("京高级违规+整数\r"); + content.append("京高级SKU+sku\\r\""); break; case "今日统计": { List todayOrders = filterOrdersByDate(orderRows, 0);