Sfoglia il codice sorgente

修改同步逻辑

tianboguang 3 anni fa
parent
commit
a6101a7a5e

+ 6 - 1
platform-shop/src/main/java/com/platform/service/impl/SceneServiceImpl.java

@@ -120,7 +120,12 @@ public class SceneServiceImpl implements SceneService {
         List<HashMap<String, String>> scenes = result.get("scenes");
 
         if(!ObjectUtils.isEmpty(scenes)){
-            scenes.parallelStream().forEach(map->{
+            scenes.parallelStream().forEach(map -> {
+                // 查询本地场景是否存在
+                SceneEntity sceneEntity = queryByScene(map.get("num"));
+                if (!ObjectUtils.isEmpty(sceneEntity)) {
+                    return;
+                }
                 SceneEntity scene = new SceneEntity();
                 scene.setName(map.get("sceneName"));
                 scene.setSceneUrl(map.get("webSite"));