货主结算单数据同步货主客户端

performance-web/src/main/java/com/clx/performance/listener/settle/SettlementOwnerDtsListener.java

@@ -6,8 +6,10 @@ import com.clx.open.sdk.callback.message.SettlementOwnerBillMessage;
 import com.clx.order.enums.SyncPlatformEnum;
 import com.clx.performance.config.ThirdAppConfig;
 import com.clx.performance.constant.RabbitKeyConstants;
+import com.clx.performance.dao.settle.SettlementOwnerDetailDao;
 import com.clx.performance.dto.dts.DataTransportDTO;
 import com.clx.performance.enums.DtsOperationTypeEnum;
+import com.clx.performance.model.settle.SettlementOwnerDetail;
 import com.msl.common.result.Result;
 import com.msl.common.utils.DtsMapConvertUtil;
 import lombok.AllArgsConstructor;
@@ -16,7 +18,9 @@ import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
 import java.util.Objects;
+import java.util.stream.Collectors;
 
 @Slf4j
 @Component
@@ -25,6 +29,8 @@ public class SettlementOwnerDtsListener {
 
     private final ThirdAppConfig thirdAppConfig;
 
+    private final SettlementOwnerDetailDao settlementOwnerDetailDao;
+
 
 
     @RabbitListener(queues = RabbitKeyConstants.CLX_PERFORMANCE_SETTLEMENT_OWNER_QUEUE)
@@ -37,7 +43,8 @@ public class SettlementOwnerDtsListener {
             log.info("操作类型：{}",dataTransportDTO.getOperationType().getCode());
             SettlementOwnerBillMessage before = DtsMapConvertUtil.convert(dataTransportDTO.getBeforeMap(), new SettlementOwnerBillMessage());
             SettlementOwnerBillMessage after = DtsMapConvertUtil.convert(dataTransportDTO.getAfterMap(), new SettlementOwnerBillMessage());
-
+            List<SettlementOwnerDetail> settlementOwnerDetails = settlementOwnerDetailDao.getBySettlementNo(after.getSettlementNo());
+            after.setChildNos(settlementOwnerDetails.stream().map(SettlementOwnerDetail::getChildNo).collect(Collectors.toList()));
             if(Objects.equals(DtsOperationTypeEnum.DELETE.getCode(),dataTransportDTO.getOperationType().getCode())){
                 //数据删除
                 log.info("删除:{}",before);