修改字段

performance-web/src/main/java/com/clx/performance/service/impl/settle/SettlementOwnerDetailServiceImpl.java

@@ -89,7 +89,7 @@ public class SettlementOwnerDetailServiceImpl  implements SettlementOwnerDetailS
         if (ans.compareTo(BigDecimal.ZERO) <= 0) {
             settlementOwnerDetail.setPrepayFreight(BigDecimal.ZERO);
         } else {
-            List<OwnerRunningWaterRecord> runningWaterRecordList = ownerRunningWaterRecordDao.getOwnerRunningWaterRecord(orderChild.getOrderNo());
+            /*List<OwnerRunningWaterRecord> runningWaterRecordList = ownerRunningWaterRecordDao.getOwnerRunningWaterRecord(orderChild.getOrderNo());
             BigDecimal frozen = runningWaterRecordList.stream().filter(item -> {
                 return item.getRunningWaterType().equals(OwnerAccountEnum.RunningWaterStatus.FROZEN.getCode());
             }).map(OwnerRunningWaterRecord::getAlterationBalance).reduce(BigDecimal.ZERO, BigDecimal::add);
@@ -128,7 +128,7 @@ public class SettlementOwnerDetailServiceImpl  implements SettlementOwnerDetailS
                 ownerRunningWaterRecordDao.saveEntity(runningWaterRecord);
             } else {
                 settlementOwnerDetail.setPrepayFreight(BigDecimal.ZERO);
-            }
+            }*/
         }
 
         // 开票金额

performance-web/src/main/java/com/clx/performance/service/impl/settle/SettlementServiceImpl.java

 package com.clx.performance.service.impl.settle;
 
 import cn.hutool.json.JSONUtil;
+import com.clx.performance.component.IdGenerateSnowFlake;
 import com.clx.performance.component.ThirdComponent;
 import com.clx.performance.dao.OrderChildDao;
 import com.clx.performance.dao.OrderGoodsDao;
+import com.clx.performance.dao.OwnerAccountDao;
+import com.clx.performance.dao.OwnerRunningWaterRecordDao;
 import com.clx.performance.dao.settle.SettlementDriverDetailDao;
 import com.clx.performance.dao.settle.SettlementOwnerDetailDao;
 import com.clx.performance.dto.OrderChildSyncDTO;
+import com.clx.performance.enums.IdTypeEnum;
+import com.clx.performance.enums.OwnerAccountEnum;
 import com.clx.performance.enums.PerformanceResultEnum;
 import com.clx.performance.enums.settle.SettlementOwnerEnum;
 import com.clx.performance.feign.TransportFeignService;
 import com.clx.performance.model.OrderChild;
 import com.clx.performance.model.OrderGoods;
+import com.clx.performance.model.OwnerAccount;
+import com.clx.performance.model.OwnerRunningWaterRecord;
 import com.clx.performance.model.settle.SettlementDriverDetail;
 import com.clx.performance.model.settle.SettlementOwnerDetail;
 import com.clx.performance.param.feign.transport.ThirdOrderChildBrokerParam;
@@ -28,6 +35,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
+import java.util.List;
 import java.util.Objects;
 
 @Slf4j
@@ -47,10 +55,17 @@ public class SettlementServiceImpl implements SettlementService {
     private TransportSyncService transportSyncService;
     @Autowired
     private OrderGoodsDao orderGoodsDao;
+    @Autowired
+    private OwnerRunningWaterRecordDao ownerRunningWaterRecordDao;
+    @Autowired
+    private IdGenerateSnowFlake idGenerateSnowFlake;
 
     @Autowired
     private TransportFeignService transportFeignService;
 
+    @Autowired
+    private OwnerAccountDao ownerAccountDao;
+
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -81,9 +96,50 @@ public class SettlementServiceImpl implements SettlementService {
             log.info("OrderChildSyncDTO信息为:{}", JSONUtil.parse(bean));
             if (bean.getCode() == 0) {
                 Integer status = bean.getData().getStatus();
+                BigDecimal ans = settlementOwnerDetail.getFreight().subtract(settlementOwnerDetail.getLossFreight());
                 if (status == 1) {
                     //通过风控
                     invoiceType = SettlementOwnerEnum.InvoiceType.ONLINE.getCode();
+                    List<OwnerRunningWaterRecord> runningWaterRecordList = ownerRunningWaterRecordDao.getOwnerRunningWaterRecord(orderChild.getOrderNo());
+                    BigDecimal frozen = runningWaterRecordList.stream().filter(item -> {
+                        return item.getRunningWaterType().equals(OwnerAccountEnum.RunningWaterStatus.FROZEN.getCode());
+                    }).map(OwnerRunningWaterRecord::getAlterationBalance).reduce(BigDecimal.ZERO, BigDecimal::add);
+
+                    BigDecimal takeOut = runningWaterRecordList.stream().filter(item -> {
+                        return item.getRunningWaterType().equals(OwnerAccountEnum.RunningWaterStatus.TAKE_OUT.getCode());
+                    }).map(OwnerRunningWaterRecord::getAlterationBalance).reduce(BigDecimal.ZERO, BigDecimal::add);
+                    BigDecimal subtract = frozen.subtract(takeOut);
+                    if (subtract.compareTo(BigDecimal.ZERO) <= 0) {
+                        settlementOwnerDetail.setPrepayFreight(BigDecimal.ZERO);
+                    }
+                    if (subtract.subtract(ans).compareTo(BigDecimal.ZERO) >= 0) {
+                        OwnerAccount account = ownerAccountDao.getAccountByOwnerUserNoAndAccountType(orderChild.getOwnerUserNo(),
+                                OwnerAccountEnum.AccountTypeStatus.PREPAID_FREIGHT_ACCOUNT.getCode());
+
+                        settlementOwnerDetail.setPrepayFreight(ans);
+                        //生成扣除流水
+                        OwnerRunningWaterRecord runningWaterRecord = new OwnerRunningWaterRecord();
+                        runningWaterRecord.setOwnerUserName(orderChild.getOwnerName());
+                        runningWaterRecord.setMobile(orderChild.getDriverMobile());
+                        runningWaterRecord.setCreateBy("系统");
+                        runningWaterRecord.setOrderId(orderChild.getId());
+                        runningWaterRecord.setOrderNo(orderChild.getOrderNo());
+
+                        runningWaterRecord.setRelationId(null);
+                        runningWaterRecord.setAlterationBalance(ans);
+                        runningWaterRecord.setFrozenBalance(ans);
+                        runningWaterRecord.setUsableBalance(account.getUsableBalance());
+                        runningWaterRecord.setTakeOutBalance(BigDecimal.ZERO);
+                        runningWaterRecord.setAccountBalance(account.getAccountBalance());
+                        runningWaterRecord.setOwnerUserNo(account.getOwnerUserNo());
+
+                        runningWaterRecord.setAccountType(OwnerAccountEnum.AccountTypeStatus.PREPAID_FREIGHT_ACCOUNT.getCode());
+                        runningWaterRecord.setRunningWaterType(OwnerAccountEnum.RunningWaterStatus.TAKE_OUT.getCode());
+                        runningWaterRecord.setRunningWaterNo(idGenerateSnowFlake.nextId(IdTypeEnum.Type.TAKE_OUT.getCode()));
+                        ownerRunningWaterRecordDao.saveEntity(runningWaterRecord);
+                    } else {
+                        settlementOwnerDetail.setPrepayFreight(BigDecimal.ZERO);
+                    }
                 } else {
                     invoiceType = SettlementOwnerEnum.InvoiceType.ORDINARY.getCode();
                 }