From 7cf7a80569d3cb907e0260abc3b2dbd36ec6c4c2 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 22 Sep 2022 18:08:47 +0800
Subject: [PATCH] Merge branch 'group_buy' of http://120.27.238.55:7000/r/xc-mall into group_buy

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java |  249 ++++++++++++++++++++++++++++++++-----------------
 1 files changed, 160 insertions(+), 89 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java
index 72497e3..5a34903 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java
@@ -8,10 +8,12 @@
 import cc.mrbird.febs.mall.conversion.MallGoodsCommentConversion;
 import cc.mrbird.febs.mall.conversion.MallOrderInfoConversion;
 import cc.mrbird.febs.mall.conversion.MallOrderRefundConversion;
+import cc.mrbird.febs.mall.conversion.MallTeamLeaderConversion;
 import cc.mrbird.febs.mall.dto.*;
 import cc.mrbird.febs.mall.entity.*;
 import cc.mrbird.febs.mall.mapper.*;
 import cc.mrbird.febs.mall.service.*;
+import cc.mrbird.febs.mall.vo.ApiLeaderListVo;
 import cc.mrbird.febs.mall.vo.OrderDetailVo;
 import cc.mrbird.febs.mall.vo.OrderListVo;
 import cc.mrbird.febs.mall.vo.OrderRefundVo;
@@ -27,6 +29,8 @@
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.crypto.SecureUtil;
+import cn.hutool.json.JSONArray;
+import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -76,10 +80,13 @@
     private final DataDictionaryCustomMapper dataDictionaryCustomMapper;
     private final MallLeaderAchieveMapper mallLeaderAchieveMapper;
     private final IApiMallTeamLeaderService iApiMallTeamLeaderService;
+    private final IMallElectronicFenceService iMallElectronicFenceService;
+    private final MallElectronicFenceMapper mallElectronicFenceMapper;
 
     @Override
     @Transactional(rollbackFor = Exception.class)
     public Long createOrder(AddOrderDto addOrderDto) {
+//        synchronized(this){
         MallMember member = LoginUserUtil.getLoginUser();
         String takeUniqueCode = addOrderDto.getTakeUniqueCode();
         if(StrUtil.isEmpty(takeUniqueCode)){
@@ -90,6 +97,17 @@
         if(ObjectUtil.isEmpty(mallTeamLeader)){
             throw new FebsException("请重新选择团长");
         }
+
+        //订单范围内才允许下单
+        MallAddressInfo address = mallAddressInfoMapper.selectAddressInfoByMemberIdAndId(member.getId(), addOrderDto.getAddressId());
+//        MallElectronicFence mallElectronicFence = mallElectronicFenceMapper.selectByTeamLeaderCode(mallTeamLeader.getUniqueCode());
+//        if(ObjectUtil.isNotEmpty(mallElectronicFence)){
+//            String inStr = iMallElectronicFenceService.fenceToLocation(mallElectronicFence.getGKey(),
+//                    mallElectronicFence.getServiceId(), address.getLongitude() + "," + address.getLatitude(), mallElectronicFence.getGid());
+//            if("1".equals(inStr)){
+//                throw new FebsException("不在当前团长的配送范围内");
+//            }
+//        }
 
         String orderNo = MallUtils.getOrderNum();
         MallOrderInfo orderInfo = new MallOrderInfo();
@@ -111,86 +129,92 @@
         BigDecimal total = BigDecimal.ZERO;
         BigDecimal carriage = BigDecimal.ZERO;
         for (AddOrderItemDto item : addOrderDto.getItems()) {
-            MallOrderItem orderItem = new MallOrderItem();
+                MallOrderItem orderItem = new MallOrderItem();
 
-            // 积分商品提交订单
-            if (addOrderDto.getOrderType() == 2) {
-                MallGoods mallGoods = mallGoodsMapper.selectById(item.getSkuId());
-                if (mallGoods.getStock() < item.getCnt()) {
-                    throw new FebsException(mallGoods.getGoodsName() + "库存不足");
-                }
+                // 积分商品提交订单
+                if (addOrderDto.getOrderType() == 2) {
+                    MallGoods mallGoods = mallGoodsMapper.selectById(item.getSkuId());
+                    if (mallGoods.getStock() < item.getCnt()) {
+                        throw new FebsException(mallGoods.getGoodsName() + "库存不足");
+                    }
 
-                if (MallGoods.ISSALE_STATUS_DISABLED.equals(mallGoods.getIsSale())) {
-                    throw new FebsException(mallGoods.getGoodsName() + "已下架");
-                }
+                    if (MallGoods.ISSALE_STATUS_DISABLED.equals(mallGoods.getIsSale())) {
+                        throw new FebsException(mallGoods.getGoodsName() + "已下架");
+                    }
 
-                BigDecimal amount = mallGoods.getScore().multiply(BigDecimal.valueOf(item.getCnt()));
-                orderItem.setAmount(amount);
-                orderItem.setCnt(item.getCnt());
-                orderItem.setOrderId(orderInfo.getId());
-                orderItem.setPrice(mallGoods.getScore());
-                orderItem.setGoodsId(mallGoods.getId());
-                orderItem.setGoodsName(mallGoods.getGoodsName());
-                orderItem.setStyleName(mallGoods.getGoodsName());
-                orderItem.setSkuName(mallGoods.getGoodsName());
-                orderItem.setSkuImage(mallGoods.getThumb());
-                orderItem.setState(1);
+                    BigDecimal amount = mallGoods.getScore().multiply(BigDecimal.valueOf(item.getCnt()));
+                    orderItem.setAmount(amount);
+                    orderItem.setCnt(item.getCnt());
+                    orderItem.setOrderId(orderInfo.getId());
+                    orderItem.setPrice(mallGoods.getScore());
+                    orderItem.setGoodsId(mallGoods.getId());
+                    orderItem.setGoodsName(mallGoods.getGoodsName());
+                    orderItem.setStyleName(mallGoods.getGoodsName());
+                    orderItem.setSkuName(mallGoods.getGoodsName());
+                    orderItem.setSkuImage(mallGoods.getThumb());
+                    orderItem.setState(1);
 
-                total = total.add(amount);
-            } else {
-                MallGoodsSku sku = mallGoodsSkuMapper.selectSkuInfoById(item.getSkuId());
-                if (sku == null) {
-                    throw new FebsException("购买商品或sku不存在");
-                }
+                    total = total.add(amount);
+                } else {
+                    MallGoodsSku sku = mallGoodsSkuMapper.selectSkuInfoById(item.getSkuId());
+                    if (sku == null) {
+                        throw new FebsException("购买商品或sku不存在");
+                    }
 
-                if (sku.getStock() < item.getCnt()) {
-                    throw new FebsException(sku.getSkuName() + "库存不足");
-                }
+                    if (sku.getStock() < item.getCnt()) {
+                        throw new FebsException(sku.getSkuName() + "库存不足");
+                    }
 
-                MallGoods mallGoods = mallGoodsMapper.selectById(sku.getGoodsId());
-                // 零撸专区购买
-                if (new BigDecimal(mallGoods.getPresentPrice()).compareTo(BigDecimal.ZERO) == 0) {
-                    List<MallOrderItem> items = mallOrderItemMapper.selectItemByGoodsIdUnCancel(mallGoods.getId(), member.getId());
-                    if (CollUtil.isNotEmpty(items)) {
-                        throw new FebsException("无法重复领取同一个商品");
+                    MallGoods mallGoods = mallGoodsMapper.selectById(sku.getGoodsId());
+                    // 零撸专区购买
+                    if (new BigDecimal(mallGoods.getPresentPrice()).compareTo(BigDecimal.ZERO) == 0) {
+                        List<MallOrderItem> items = mallOrderItemMapper.selectItemByGoodsIdUnCancel(mallGoods.getId(), member.getId());
+                        if (CollUtil.isNotEmpty(items)) {
+                            throw new FebsException("无法重复领取同一个商品");
+                        }
+                    }
+
+                    if (MallGoods.ISSALE_STATUS_DISABLED.equals(mallGoods.getIsSale())) {
+                        throw new FebsException(mallGoods.getGoodsName() + "已下架");
+                    }
+
+//                    mallGoods.setStock(mallGoods.getStock() - item.getCnt());
+//                    mallGoods.setVolume(mallGoods.getVolume() + item.getCnt());
+                    Integer goodsResult = mallGoodsMapper.upDateStockAndVolumeByGoodsId(mallGoods.getId(), item.getCnt());
+                    if(1 != goodsResult){
+                        throw new FebsException(mallGoods.getGoodsName() + "库存不足");
+                    }
+
+                    BigDecimal amount = sku.getPresentPrice().multiply(BigDecimal.valueOf(item.getCnt()));
+                    orderItem.setAmount(amount);
+                    orderItem.setCnt(item.getCnt());
+                    orderItem.setOrderId(orderInfo.getId());
+                    orderItem.setPrice(sku.getPresentPrice());
+                    orderItem.setGoodsId(sku.getGoodsId());
+                    orderItem.setGoodsName(sku.getGoodsName());
+                    orderItem.setSkuId(sku.getId());
+                    orderItem.setState(1);
+                    orderItem.setStyleName(sku.getStyleName());
+                    orderItem.setSkuName(sku.getSkuName());
+                    orderItem.setSkuImage(sku.getSkuImage());
+                    orderItem.setIsNormal(mallGoods.getIsNormal());
+                    orderItem.setCostPrice(sku.getCostPrice());
+
+                    total = total.add(amount);
+                    carriage = carriage.add(mallGoods.getCarriage());
+
+//                    sku.setStock(sku.getStock() - item.getCnt());
+//                    sku.setSkuVolume(sku.getSkuVolume() + item.getCnt());
+//                    mallGoodsSkuMapper.updateById(sku);
+                    Integer skuResult = mallGoodsSkuMapper.upDateStockAndVolumeBySkuId(sku.getId(),item.getCnt());
+                    if(1 != skuResult){
+                        throw new FebsException(sku.getSkuName() + "库存不足");
+                    }
+                    if (addOrderDto.getType() == 1) {
+                        mallShoppingCartMapper.delBySkuId(sku.getId(), member.getId());
                     }
                 }
-
-                if (MallGoods.ISSALE_STATUS_DISABLED.equals(mallGoods.getIsSale())) {
-                    throw new FebsException(mallGoods.getGoodsName() + "已下架");
-                }
-
-                mallGoods.setStock(mallGoods.getStock() - item.getCnt());
-                mallGoods.setVolume(mallGoods.getVolume() + item.getCnt());
-                mallGoodsMapper.updateById(mallGoods);
-
-                BigDecimal amount = sku.getPresentPrice().multiply(BigDecimal.valueOf(item.getCnt()));
-                orderItem.setAmount(amount);
-                orderItem.setCnt(item.getCnt());
-                orderItem.setOrderId(orderInfo.getId());
-                orderItem.setPrice(sku.getPresentPrice());
-                orderItem.setGoodsId(sku.getGoodsId());
-                orderItem.setGoodsName(sku.getGoodsName());
-                orderItem.setSkuId(sku.getId());
-                orderItem.setState(1);
-                orderItem.setStyleName(sku.getStyleName());
-                orderItem.setSkuName(sku.getSkuName());
-                orderItem.setSkuImage(sku.getSkuImage());
-                orderItem.setIsNormal(mallGoods.getIsNormal());
-                orderItem.setCostPrice(sku.getCostPrice());
-
-                total = total.add(amount);
-                carriage = carriage.add(mallGoods.getCarriage());
-
-                sku.setStock(sku.getStock() - item.getCnt());
-                sku.setSkuVolume(sku.getSkuVolume() + item.getCnt());
-                mallGoodsSkuMapper.updateById(sku);
-
-                if (addOrderDto.getType() == 1) {
-                    mallShoppingCartMapper.delBySkuId(sku.getId(), member.getId());
-                }
-            }
-            mallOrderItemMapper.insert(orderItem);
+                mallOrderItemMapper.insert(orderItem);
         }
         //配送费
         BigDecimal delivaryAmount = addOrderDto.getDeliveryAmount() == null ? BigDecimal.ZERO : addOrderDto.getDeliveryAmount();
@@ -200,7 +224,6 @@
         }
         orderInfo.setAmount(total);
 
-        MallAddressInfo address = mallAddressInfoMapper.selectAddressInfoByMemberIdAndId(member.getId(), addOrderDto.getAddressId());
         orderInfo.setName(address.getName());
         orderInfo.setPhone(address.getPhone());
         orderInfo.setIsHome(addOrderDto.getIsHome());
@@ -217,6 +240,7 @@
 
         agentProducer.sendOrderCancelDelayMsg(orderInfo.getId(), 15 * 60 * 1000L);
         return orderInfo.getId();
+//        }
     }
 
 
@@ -454,11 +478,17 @@
 
     @Override
     public List<OrderListVo> findOrderList(OrderListDto orderListDto) {
+        log.info("订单查询");
         MallMember member = LoginUserUtil.getLoginUser();
         IPage<MallOrderInfo> page = new Page<>(orderListDto.getPageNum(), orderListDto.getPageSize());
 
         orderListDto.setMemberId(member.getId());
         IPage<MallOrderInfo> mallOrderInfos = this.baseMapper.selectApiOrderListInPage(page, orderListDto);
+        if (CollUtil.isNotEmpty(mallOrderInfos.getRecords())) {
+            mallOrderInfos.getRecords().forEach(item -> {
+                item.setItems(mallOrderItemMapper.selectListByOrderId(item.getId()));
+            });
+        }
         return MallOrderInfoConversion.INSTANCE.entitysToVos(mallOrderInfos.getRecords());
     }
 
@@ -525,23 +555,25 @@
         if(CollUtil.isNotEmpty(mallOrderItemList)){
 
             MallTeamLeader mallTeamLeader = mallTeamLeaderMapper.selectLeaderByUniqueCode(orderInfo.getTakeUniqueCode());
+            Integer profitSwitch = mallTeamLeader.getProfitSwitch()==null?2:mallTeamLeader.getProfitSwitch();
             BigDecimal bonusPercent =new BigDecimal(mallTeamLeader.getBonusPercent()==null?"0":mallTeamLeader.getBonusPercent());
-//            DataDictionaryCustom dicBonusPercent = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.BONUS_PERCENT.getType(), DataDictionaryEnum.BONUS_PERCENT.getCode());
-//            BigDecimal bonusPercent = new BigDecimal(dicBonusPercent.getValue()).setScale(2,BigDecimal.ROUND_DOWN);
-            for(MallOrderItem mallOrderItem : mallOrderItemList){
-                Integer state = mallOrderItem.getState() == null ? 1 : mallOrderItem.getState();
-                if(1 == state){
-                    MallLeaderAchieve mallLeaderAchieve = new MallLeaderAchieve();
-                    mallLeaderAchieve.setMemberId(orderInfo.getMemberId());
-                    mallLeaderAchieve.setOrderNo(orderInfo.getOrderNo());
-                    mallLeaderAchieve.setOrderItemId(mallOrderItem.getId());
-                    BigDecimal itemAmount = mallOrderItem.getAmount();
-                    mallLeaderAchieve.setAmount(itemAmount);
-                    BigDecimal bigDecimal = bonusPercent.multiply(itemAmount).setScale(2, BigDecimal.ROUND_DOWN);
-                    mallLeaderAchieve.setProfitAmount(bigDecimal);
-                    mallLeaderAchieve.setUniqueCode(orderInfo.getTakeUniqueCode());
-                    mallLeaderAchieve.setState(MallLeaderAchieve.STATE_ONE);
-                    mallLeaderAchieveMapper.insert(mallLeaderAchieve);
+
+            if(1 == profitSwitch){
+                for(MallOrderItem mallOrderItem : mallOrderItemList){
+                    Integer state = mallOrderItem.getState() == null ? 1 : mallOrderItem.getState();
+                    if(1 == state){
+                        MallLeaderAchieve mallLeaderAchieve = new MallLeaderAchieve();
+                        mallLeaderAchieve.setMemberId(orderInfo.getMemberId());
+                        mallLeaderAchieve.setOrderNo(orderInfo.getOrderNo());
+                        mallLeaderAchieve.setOrderItemId(mallOrderItem.getId());
+                        BigDecimal itemAmount = mallOrderItem.getAmount();
+                        mallLeaderAchieve.setAmount(itemAmount);
+                        BigDecimal bigDecimal = bonusPercent.multiply(itemAmount).setScale(2, BigDecimal.ROUND_DOWN);
+                        mallLeaderAchieve.setProfitAmount(bigDecimal);
+                        mallLeaderAchieve.setUniqueCode(orderInfo.getTakeUniqueCode());
+                        mallLeaderAchieve.setState(MallLeaderAchieve.STATE_ONE);
+                        mallLeaderAchieveMapper.insert(mallLeaderAchieve);
+                    }
                 }
             }
         }
@@ -821,4 +853,43 @@
         return new FebsResponse().success().message("已取消");
     }
 
+    @Override
+    public Boolean createOrderVerify(ApiCreateOrderVerifyDto apiCreateOrderVerifyDto) {
+        Boolean flag = false;
+        Long addressId = apiCreateOrderVerifyDto.getAddressId();
+        String takeUniqueCode = apiCreateOrderVerifyDto.getTakeUniqueCode();
+
+        MallAddressInfo mallAddressInfo = mallAddressInfoMapper.selectById(addressId);
+        if(ObjectUtil.isEmpty(mallAddressInfo)){
+            return flag;
+        }
+        MallElectronicFence mallElectronicFence = mallElectronicFenceMapper.selectByTeamLeaderCode(takeUniqueCode);
+        if(ObjectUtil.isEmpty(mallElectronicFence)){
+            return flag;
+        }
+        //{"data":{"count":1,"results":[{"gfid":800899,"gfname":"87053658_fence","in":0}]},"errcode":10000,"errdetail":null,"errmsg":"OK"}
+        String resultsStr = iMallElectronicFenceService.fenceToLocation(mallElectronicFence.getGKey(),
+                mallElectronicFence.getServiceId(),
+                mallAddressInfo.getLongitude() + "," + mallAddressInfo.getLatitude(),
+                mallElectronicFence.getGid());
+        if("fail".equals(resultsStr)){
+            return flag;
+        }
+        JSONArray objects = JSONUtil.parseArray(resultsStr);
+        for(Object obj : objects){
+            //{"gfid":800899,"gfname":"87053658_fence","in":0}
+            JSONObject jsonObject = JSONUtil.parseObj(obj);
+            String gfid = jsonObject.get("gfid").toString();
+            String in = jsonObject.get("in").toString();
+            String gfname = jsonObject.get("gfname").toString();
+            //指定坐标是否在围栏中
+            //1:在,
+            //0:不在;
+            if("1".equals(in)){
+                flag = true;
+            }
+        }
+        return flag;
+    }
+
 }

--
Gitblit v1.9.1