diff --git a/ssjygl-xsx-common/pom.xml b/ssjygl-xsx-common/pom.xml index 2d226dc..ff63313 100644 --- a/ssjygl-xsx-common/pom.xml +++ b/ssjygl-xsx-common/pom.xml @@ -44,7 +44,7 @@ com.alibaba fastjson - 1.2.78 + 1.2.79 diff --git a/ssjygl-xsx-local/pom.xml b/ssjygl-xsx-local/pom.xml index c3b4024..da5e552 100644 --- a/ssjygl-xsx-local/pom.xml +++ b/ssjygl-xsx-local/pom.xml @@ -76,7 +76,7 @@ com.alibaba fastjson - 1.2.78 + 1.2.79 diff --git a/ssjygl-xsx-service/pom.xml b/ssjygl-xsx-service/pom.xml index 46b3daf..d6dcfc0 100644 --- a/ssjygl-xsx-service/pom.xml +++ b/ssjygl-xsx-service/pom.xml @@ -77,7 +77,7 @@ com.alibaba fastjson - 1.2.78 + 1.2.79 diff --git a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/supermarket/SupermarketSyncService.java b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/supermarket/SupermarketSyncService.java index 752b926..f6ef2ce 100644 --- a/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/supermarket/SupermarketSyncService.java +++ b/ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/supermarket/SupermarketSyncService.java @@ -189,7 +189,7 @@ public class SupermarketSyncService extends BaseSyncService { if (orderclusterList != null && !orderclusterList.isEmpty()) { for (Ordercluster ordercluster : orderclusterList) { ordercluster.setUnitPrice(BigDecimal.valueOf(unit_price)); - if (!map.containsKey(ordercluster.getId())) { + if (!map.containsKey(ordercluster.getSupermarketId())) { map.put(ordercluster.getSupermarketId(), new SyncTask()); } map.get(ordercluster.getSupermarketId()).addUpdateData(ordercluster); @@ -237,6 +237,12 @@ public class SupermarketSyncService extends BaseSyncService { } }); + if (ret) { + for (Map.Entry entry : map.entrySet()) { + SyncTaskService.me.send(entry.getValue()); + } + } + return Result.object(ret); } }