This commit is contained in:
雷欧(林平凡)
2024-11-24 01:48:36 +08:00
parent e19c59e491
commit 6808d26890

View File

@@ -255,6 +255,9 @@ public class JDUtils {
// 订单号不存在就保存,存在就更新订单状态 // 订单号不存在就保存,存在就更新订单状态
orderRowRepository.save(orderRow); 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); LocalDateTime endTime = isRealTime ? startTime.plusMinutes(10) : startTime.plusHours(1);
String key = startTime.format(DATE_TIME_FORMATTER); String key = startTime.format(DATE_TIME_FORMATTER);
@@ -332,7 +335,7 @@ public class JDUtils {
SetOperations<String, String> setOps = redisTemplate.opsForSet(); SetOperations<String, String> setOps = redisTemplate.opsForSet();
// 调用 API 以拉取订单 // 调用 API 以拉取订单
UnionOpenOrderRowQueryResponse unionOpenOrderRowQueryResponse = getUnionOpenOrderRowQueryResponse(startTime, endTime); UnionOpenOrderRowQueryResponse unionOpenOrderRowQueryResponse = getUnionOpenOrderRowQueryResponse(startTime, endTime,page);
// 标记已拉取 // 标记已拉取
setOps.add(key, hourRange); setOps.add(key, hourRange);
@@ -377,6 +380,7 @@ public class JDUtils {
content.append(":::高级菜单:::\r"); content.append(":::高级菜单:::\r");
content.append("菜单:京+高级+命令 \n 如: 京高级违规30\r"); content.append("菜单:京+高级+命令 \n 如: 京高级违规30\r");
content.append("京高级违规+整数\r"); content.append("京高级违规+整数\r");
content.append("京高级SKU+sku\\r\"");
break; break;
case "今日统计": { case "今日统计": {
List<OrderRow> todayOrders = filterOrdersByDate(orderRows, 0); List<OrderRow> todayOrders = filterOrdersByDate(orderRows, 0);