diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/domain/job/ShopifySyncJob.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/domain/job/ShopifySyncJob.java index 8d5666701..c0d4e3902 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/domain/job/ShopifySyncJob.java +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/domain/job/ShopifySyncJob.java @@ -61,7 +61,7 @@ public class ShopifySyncJob implements Job { mapper.disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES); List ordersReadyForShopifySync = platformOrderService.fetchOrderInShopsReadyForShopifySync(shops); Map syncMap = ordersReadyForShopifySync.stream() - .collect(toMap(PlatformOrderShopSync::getPlatformOrderId, Function.identity())); + .collect(toMap(sync -> sync.getPlatformOrderId().split("_")[0], Function.identity())); List fulfillmentOrders = new ArrayList<>();