更细业务，异步更新关联业务名称

base-manager/src/main/java/com/mortals/xhx/module/business/service/impl/BusinessServiceImpl.java

@@ -7,6 +7,7 @@ import com.mortals.framework.model.Context;
 import com.mortals.framework.model.PageInfo;
 import com.mortals.framework.model.Result;
 import com.mortals.framework.service.impl.AbstractCRUDCacheServiceImpl;
+import com.mortals.framework.util.ThreadPool;
 import com.mortals.xhx.base.system.message.MessageService;
 import com.mortals.xhx.busiz.req.ApiThirdPartyReq;
 import com.mortals.xhx.busiz.req.BussinessThirdPartyReq;
@@ -84,23 +85,34 @@ public class BusinessServiceImpl extends AbstractCRUDCacheServiceImpl<BusinessDa
 
     @Override
     protected void updateAfter(BusinessEntity entity, Context context) throws AppException {
+
+        Runnable runnable = new Runnable() {
+            /**
+             *
+             */
+            @Override
+            public void run() {
                 //同步更新所有站点
-        List<SiteBusinessEntity> collect = siteBusinessService.find(new SiteBusinessQuery().businessId(entity.getId())).stream()
+                List<SiteBusinessEntity> siteBusinessEntityList = siteBusinessService.find(new SiteBusinessQuery().businessId(entity.getId())).stream()
                         .map(item -> {
-                    BeanUtils.copyProperties(entity, item, new String[]{"id"});
                             item.setBusinessName(entity.getName());
                             return item;
                         }).collect(Collectors.toList());
-        siteBusinessService.update(collect, context);
-
-        //更新事项业务表中字段
-        List<SiteBusinessEntity> siteBusinessEntities = siteBusinessService.find(new SiteBusinessQuery().businessId(entity.getId()))
-                .stream()
-                .filter(item -> !item.getBusinessName().equals(entity.getName()))
-                .peek(item -> item.setBusinessName(entity.getName()))
-                .collect(Collectors.toList());
-        if (!ObjectUtils.isEmpty(siteBusinessEntities)) {
-            siteBusinessService.update(siteBusinessEntities, context);
+
+                if (!ObjectUtils.isEmpty(siteBusinessEntityList)) {
+                    siteBusinessService.update(siteBusinessEntityList, context);
+                }
+
+                for (SiteBusinessEntity siteBusinessEntity : siteBusinessEntityList) {
+                    List<WindowBusinessEntity> windowBusinessEntityList = windowBusinessService.find(new WindowBusinessQuery().siteBusinessId(siteBusinessEntity.getId())).stream().map(item -> {
+                        item.setBusinessName(entity.getName());
+                        return item;
+                    }).collect(Collectors.toList());
+
+                    if( !ObjectUtils.isEmpty(windowBusinessEntityList)) {
+                        windowBusinessService.update(windowBusinessEntityList, context);
+                    }
+
                 }
 
                 //通知第三方平台
@@ -114,6 +126,11 @@ public class BusinessServiceImpl extends AbstractCRUDCacheServiceImpl<BusinessDa
                 apiThirdPartyReq.setStatus(ThirdPartyStatusEnum.修改.getValue());
                 apiThirdPartyReq.setData(bussinessThirdPartyReq);
                 messageService.sendThirdParty(phpUrl, JSON.toJSONString(apiThirdPartyReq));
+
+            }
+        };
+        ThreadPool.getInstance().execute(runnable);
+
         super.updateAfter(entity, context);
     }
 

base-manager/src/test/java/com/mortals/httpclient/site/SiteBusinessController.http

@@ -41,7 +41,7 @@ client.global.set("SiteBusiness_id", JSON.parse(response.body).data.id);
 %}
 
 ###站点业务查看
-GET {{baseUrl}}/site/business/info?id={{SiteBusiness_id}}
+GET {{baseUrl}}/site/business/interinfo?id=24
 Accept: application/json
 
 ###站点业务编辑

base-manager/src/test/java/com/mortals/httpclient/window/WindowBusinessController.http

@@ -5,6 +5,12 @@ Content-Type: application/json
 
 {"windowIdList":["77","78","79","80","81","82","83","84","85","86","87","88","89","90","91","92","93","94","95","96","97","98","99"],"size":-1}
 
+###窗口业务列表
+POST {{baseUrl}}/window/business/interlist
+Content-Type: application/json
+
+{"windowIdList":["16"],"size":-1}
+
 
 
 ###窗口业务列表缓存