添加窗口同步修改通知

base-manager/src/main/java/com/mortals/xhx/module/window/service/impl/WindowBusinessServiceImpl.java

@@ -176,29 +176,29 @@ public class WindowBusinessServiceImpl extends AbstractCRUDServiceImpl<WindowBus
     }
 
 
-    /**
+ /*   *//**
      * @param entity
      * @param context
      * @throws AppException
-     */
+     *//*
     @Override
     protected void saveAfter(WindowBusinessEntity entity, Context context) throws AppException {
         //通知php更新
         pushChangeMsg(entity);
         super.saveAfter(entity, context);
-    }
+    }*/
 
 
-    /**
+/*    *//**
      * @param entity
      * @param context
      * @throws AppException
-     */
+     *//*
     @Override
     protected void updateAfter(WindowBusinessEntity entity, Context context) throws AppException {
         pushChangeMsg(entity);
         super.updateAfter(entity, context);
-    }
+    }*/
 
     private void pushChangeMsg(WindowBusinessEntity entity) {
         String phpUrl = GlobalSysInfo.getParamValue(PARAM_SERVER_PHP_HTTP_URL, "http://172.15.28.116:8090");

base-manager/src/main/java/com/mortals/xhx/module/window/service/impl/WindowServiceImpl.java

@@ -132,7 +132,16 @@ public class WindowServiceImpl extends AbstractCRUDCacheServiceImpl<WindowDao, W
             }
             return windowBusinessEntity;
         }).filter(f -> f != null).collect(Collectors.toList());
-        windowBusinessService.save(windowBusinessEntities, context);
+
+        if (!ObjectUtils.isEmpty(windowBusinessEntities)) {
+            windowBusinessService.save(windowBusinessEntities, context);
+
+            WindowBusinessQuery condition = new WindowBusinessQuery();
+            condition.setWindowId(windowId);
+            condition.setSiteBusinessIdList(windowBusinessEntities.stream().map(i -> i.getId()).collect(Collectors.toList()));
+            pushChangeMsg(condition);
+        }
+        //批量推送
     }
 
     /**
@@ -272,4 +281,25 @@ public class WindowServiceImpl extends AbstractCRUDCacheServiceImpl<WindowDao, W
         }
         return successMsg.toString();
     }
+
+
+    private void pushChangeMsg(WindowBusinessQuery entity) {
+        String phpUrl = GlobalSysInfo.getParamValue(PARAM_SERVER_PHP_HTTP_URL, "http://172.15.28.116:8090");
+        phpUrl += "/api/window/winNameChange";
+        HashMap<String, Object> paramsMap = new HashMap<>();
+        paramsMap.put("windowid", entity.getWindowId());
+        paramsMap.put("bussinessid", entity.getSiteBusinessIdList().stream().map(String::valueOf).collect(Collectors.joining(",")));
+
+        paramsMap.put("typeinfo", 1);
+        String resp = null;
+        try {
+            Map<String, String> header = new HashMap<>();
+            header.put(HEADER_CONTENT_TYPE, "application/json");
+            log.info("\n thirdPartyUrl=>{} \n reqbody=>{} ", phpUrl, JSON.toJSONString(paramsMap));
+            resp = HttpUtil.doPost(phpUrl, header, JSON.toJSONString(paramsMap, SerializerFeature.WriteMapNullValue));
+            log.info("thirdPartyUrl =>resp:{}", resp);
+        } catch (Exception e) {
+            log.error("异常:", e);
+        }
+    }
 }
\ No newline at end of file