From 14bf9ee7665cf043d70d6f08f4f06d0a7042c293 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Fri, 28 May 2021 14:58:25 +0800
Subject: [PATCH] 20210528

---
 src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcOrderServiceImpl.java |   19 +++++++++++++++++++
 1 files changed, 19 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcOrderServiceImpl.java b/src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcOrderServiceImpl.java
index 7e18ea5..688afe5 100644
--- a/src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcOrderServiceImpl.java
+++ b/src/main/java/com/xcong/excoin/modules/otc/service/impl/OtcOrderServiceImpl.java
@@ -1,11 +1,13 @@
 package com.xcong.excoin.modules.otc.service.impl;
 
 import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUnit;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.crypto.SecureUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -61,6 +63,8 @@
     @Transactional(rollbackFor = Exception.class)
     public Result buyOrder(OtcOrderAddDto orderAddDto) {
         MemberEntity member = LoginUserUtils.getAppLoginUser();
+
+//        MemberEntity member = memberDao.selectById(445L);
         OtcEntrustOrder entrustOrder = otcEntrustOrderDao.selectById(orderAddDto.getId());
         if (entrustOrder == null) {
             throw new GlobalException("委托单不存在");
@@ -96,6 +100,18 @@
         BigDecimal cny = orderAddDto.getUsdtAmount().multiply(entrustOrder.getUnitPrice());
         if (cny.compareTo(orderAddDto.getCnyAmount()) != 0) {
             throw new GlobalException("数量与金额不符");
+        }
+        /**
+         * 最多三单未付款
+         */
+        QueryWrapper<OtcOrder> objectQueryWrapper = new QueryWrapper<>();
+        objectQueryWrapper.eq("member_id",member.getId());
+        objectQueryWrapper.lt("status",OtcOrder.STATUS_PAY);
+        List<OtcOrder> otcOrders = this.baseMapper.selectList(objectQueryWrapper);
+        if(CollUtil.isNotEmpty(otcOrders)){
+            if(otcOrders.size() >= 3){
+                throw new GlobalException("最多可同时有三个待付款订单");
+            }
         }
 
         OtcOrder otcOrder = new OtcOrder();
@@ -337,7 +353,9 @@
         }
 
         buyDetail.setSaleName(saleMember.getName());
+
         buyDetail.setSaleMemberId(saleMember.getId());
+        buyDetail.setMemberId(member.getId());
 
         buyDetail.setBankName(buyOrder.getBankName());
         buyDetail.setBankNo(buyOrder.getBankNo());
@@ -386,6 +404,7 @@
 
         saleDetail.setSaleName(buyMember.getName());
         saleDetail.setSaleMemberId(buyMember.getId());
+        saleDetail.setMemberId(member.getId());
 
         saleDetail.setPayType(saleOrder.getPayType());
         saleDetail.setIsOwnEntrust(member.getId().equals(saleOrder.getEntrustMemberId()) ? 1 : 2);

--
Gitblit v1.9.1