diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/domain/job/MabangOrderSyncJob.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/domain/job/MabangOrderSyncJob.java index f77d49d32..62f1e9fc2 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/domain/job/MabangOrderSyncJob.java +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/domain/job/MabangOrderSyncJob.java @@ -58,10 +58,7 @@ public class MabangOrderSyncJob implements Job { List> platformOrderIdLists = Lists.partition(platformOrderIds, 10); List requests = new ArrayList<>(); for (List platformOrderIdList : platformOrderIdLists) { - // There's no other way to sync orders of all statuses, so we duplicate requests to make sure - // that we get all orders - requests.add(new OrderListRequestBody().setPlatformOrderIds(platformOrderIdList).setStatus(OrderStatus.AllUnshipped)); - requests.add(new OrderListRequestBody().setPlatformOrderIds(platformOrderIdList).setStatus(OrderStatus.AllNonUnshipped)); + requests.add(new OrderListRequestBody().setPlatformOrderIds(platformOrderIdList)); } List mabangOrders = new ArrayList<>(); ExecutorService executor = Executors.newFixedThreadPool(DEFAULT_NUMBER_OF_THREADS);