解冻账户判断重复解冻

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

@@ -44,6 +44,7 @@ import org.springframework.transaction.annotation.Transactional;
 import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.util.*;
+import java.util.stream.Collectors;
 
 @Slf4j
 @Service
@@ -802,12 +803,19 @@ public class OwnerAccountServiceImpl implements OwnerAccountService {
     public void ownerAccountThaw(ThawAccountParam param) {
         String orderNo = param.getOrderNo();
         List<OwnerRunningWaterRecord> list = ownerRunningWaterRecordDao.getOwnerRunningWaterRecord(orderNo);
-
+        if (CollectionUtil.isEmpty(list)) {
+            log.info("解冻预付运费、保证金账户出错,查询出冻结流水有问题,参数为{}", JSONUtil.parse(param));
+            return;
+        }
+        List<OwnerRunningWaterRecord> thawList = list.stream().filter(i -> {
+                    return i.getRunningWaterType().equals(OwnerAccountEnum.RunningWaterStatus.THAW.getCode());
+                }
+        ).collect(Collectors.toList());
+        if (CollectionUtil.isNotEmpty(thawList)) {
+            log.info("当前订单已经产生了解冻流水,参数为{}", JSONUtil.parse(param));
+            return;
+        }
         if (OwnerAccountEnum.OrderChildTypeStatus.ORDINARY.getCode().equals(param.getOrderType())) {
-            if (CollectionUtil.isEmpty(list)) {
-                log.info("解冻预付运费、保证金账户出错,查询出冻结流水有问题,参数为{}", JSONUtil.parse(param));
-                return;
-            }
             generateOrdinary(list);
         }
         else {