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