From d8f20196fb659300b0a8eb3e7c5d7ab1ad7fcb7e Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Fri, 06 Jan 2023 15:21:29 +0800
Subject: [PATCH] 20221227 充值归集

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java |   54 ++++++++++++++++++++++++++++++++++++------------------
 1 files changed, 36 insertions(+), 18 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 f86db0a..7c9c839 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
@@ -119,7 +119,7 @@
         String yyyyMMdd = sdf.format(date);
         Integer times = this.baseMapper.selectCountByCreateTimeAndMemberId(yyyyMMdd,member.getId());
         if(buyTimes <= times){
-            throw new FebsException("会员今日已无法购买");
+            throw new FebsException("今日任务完成,明天再来");
         }
 
         String orderNo = MallUtils.getOrderNum();
@@ -132,6 +132,7 @@
         orderInfo.setOrderType(addOrderDto.getOrderType());
         //补贴金额
         orderInfo.setSubsidyAmount(goods.getSubsidyAmount());
+        orderInfo.setCommentState(MallOrderInfo.COMMENT_STATE_NO);
 
         this.baseMapper.insert(orderInfo);
         List<MallGoodsSku> mallGoodsSkus = mallGoodsSkuMapper.selectSkuByGoodsId(goods.getId());
@@ -506,22 +507,22 @@
         orderInfo.setStatus(OrderStatusEnum.FINISH.getValue());
         orderInfo.setReceivingTime(new Date());
         this.baseMapper.updateById(orderInfo);
-        /**
-         * 通过支付流水记录,返回下单金额
-         */
-        MallMoneyFlow payFlow = mallMoneyFlowMapper.selectOneByMemberIdAndOrderNoAndTypeAndStatusAndIsReturn(
-                member.getId(),
-                orderInfo.getOrderNo(),
-                MallMoneyFlowTypeEnum.PAY.getCode(),
-                MallMoneyFlow.STATUS_SUCCESS,
-                MallMoneyFlow.IS_RETURN_N);
-        if(ObjectUtil.isNotEmpty(payFlow)){
-            memberWalletService.addBalance(payFlow.getAmount().negate(),payFlow.getRtMemberId());
-            payFlow.setIsReturn(MallMoneyFlow.IS_RETURN_Y);
-            mallMoneyFlowMapper.updateById(payFlow);
-        }
-        //产生补贴流水记录
-        agentProducer.sendDirectRewardMsg(orderInfo.getId());
+//        /**
+//         * 通过支付流水记录,返回下单金额
+//         */
+//        MallMoneyFlow payFlow = mallMoneyFlowMapper.selectOneByMemberIdAndOrderNoAndTypeAndStatusAndIsReturn(
+//                member.getId(),
+//                orderInfo.getOrderNo(),
+//                MallMoneyFlowTypeEnum.PAY.getCode(),
+//                MallMoneyFlow.STATUS_SUCCESS,
+//                MallMoneyFlow.IS_RETURN_N);
+//        if(ObjectUtil.isNotEmpty(payFlow)){
+//            memberWalletService.addBalance(payFlow.getAmount().negate(),payFlow.getRtMemberId());
+//            payFlow.setIsReturn(MallMoneyFlow.IS_RETURN_Y);
+//            mallMoneyFlowMapper.updateById(payFlow);
+//        }
+//        //产生补贴流水记录
+//        agentProducer.sendDirectRewardMsg(orderInfo.getId());
 
     }
 
@@ -655,13 +656,30 @@
 
         orderInfo.setCommentState(MallOrderInfo.COMMENT_STATE_YES);
         this.baseMapper.updateById(orderInfo);
+        /**
+         * 通过支付流水记录,返回下单金额
+         */
+        MallMoneyFlow payFlow = mallMoneyFlowMapper.selectOneByMemberIdAndOrderNoAndTypeAndStatusAndIsReturn(
+                member.getId(),
+                orderInfo.getOrderNo(),
+                MallMoneyFlowTypeEnum.PAY.getCode(),
+                MallMoneyFlow.STATUS_SUCCESS,
+                MallMoneyFlow.IS_RETURN_N);
+        if(ObjectUtil.isNotEmpty(payFlow)){
+            memberWalletService.addBalance(payFlow.getAmount().negate(),payFlow.getRtMemberId());
+            payFlow.setIsReturn(MallMoneyFlow.IS_RETURN_Y);
+            mallMoneyFlowMapper.updateById(payFlow);
+        }
+        //产生补贴流水记录
+        agentProducer.sendDirectRewardMsg(orderInfo.getId());
 
         List<ApiAddCommentDto> apiAddCommentDtos = addCommentDtos.getApiAddCommentDtos();
         if(CollUtil.isNotEmpty(apiAddCommentDtos)){
             for(ApiAddCommentDto apiAddCommentDto : apiAddCommentDtos){
                 Long skuId = apiAddCommentDto.getSkuId();
-                MallGoodsSku mallGoodsSku = mallGoodsSkuMapper.selectById(skuId);
                 Long goodsId = apiAddCommentDto.getGoodsId();
+                List<MallGoodsSku> mallGoodsSkus = mallGoodsSkuMapper.selectSkuByGoodsId(goodsId);
+                MallGoodsSku mallGoodsSku = mallGoodsSkus.get(0);
                 MallGoods mallGoods = mallGoodsMapper.selectById(goodsId);
                 MallGoodsComment mallGoodsComment = MallGoodsCommentConversion.INSTANCE.dtoToEntity(apiAddCommentDto);
                 mallGoodsComment.setMemberId(member.getId());

--
Gitblit v1.9.1