diff --git a/performance-web/src/main/java/com/clx/performance/service/impl/settle/SettlementOwnerServiceImpl.java b/performance-web/src/main/java/com/clx/performance/service/impl/settle/SettlementOwnerServiceImpl.java index aeac2d5c2d6223497e467d64fa23658a0ac8cda7..54eeab3bcebfc9de140cb3792b888bd554ab9606 100644 --- a/performance-web/src/main/java/com/clx/performance/service/impl/settle/SettlementOwnerServiceImpl.java +++ b/performance-web/src/main/java/com/clx/performance/service/impl/settle/SettlementOwnerServiceImpl.java @@ -30,6 +30,7 @@ import com.clx.performance.model.settle.SettlementPlatformAccount; import com.clx.performance.param.pc.owner.*; import com.clx.performance.service.OwnerAccountService; import com.clx.performance.service.PlatformAccountConfigService; +import com.clx.performance.service.broker.OrderChildBrokerMqService; import com.clx.performance.service.settle.SettlementLogService; import com.clx.performance.service.settle.SettlementMqHandlerService; import com.clx.performance.service.settle.SettlementOwnerService; @@ -99,7 +100,7 @@ public class SettlementOwnerServiceImpl implements SettlementOwnerService { private final PlatformAccountConfigService platformAccountConfigService; private final OrderFeign orderFeign; private final BreakContractSettlementOwnerDao breakContractSettlementOwnerDao; - + private final OrderChildBrokerMqService orderChildBrokerMqService; @Override @@ -893,6 +894,10 @@ public class SettlementOwnerServiceImpl implements SettlementOwnerService { settlementOwnerDao.saveEntity(merge); //鏇存柊璐т富杩愬崟璁¤垂鏄庣粏 settlementOwnerDetailDao.updateSettlementMerge(settlementNo,settlementNos); + + List<SettlementOwnerDetail> settlementOwnerDetailList = settlementOwnerDetailDao.getBySettlementNo(settlementNo); + // 鍙戦€乵q (杩愬崟鏇存柊) + orderChildBrokerMqService.orderChildUpdate(settlementOwnerDetailList.stream().map(item->item.getChildNo()).collect(Collectors.toList())); } }