From 01a62b214cc07a007b9265ddcd9cb457765f02f7 Mon Sep 17 00:00:00 2001 From: "lisai17@sina.com" Date: Tue, 15 Feb 2022 22:03:11 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9fastjson=E7=89=88=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ssjygl-xsx-common/pom.xml | 2 +- ssjygl-xsx-local/pom.xml | 2 +- ssjygl-xsx-service/pom.xml | 2 +- .../ssjygl/supermarket/SupermarketSyncService.java | 8 +++++++- 4 files changed, 10 insertions(+), 4 deletions(-) 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); } }