From b3b3987e17a80b4fe6bc29f3835429058eb2e0fc Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Tue, 21 Mar 2023 10:26:59 +0800 Subject: [PATCH] 后台修改 --- src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java | 91 ++++++++++++++++++++++++++------------------- 1 files changed, 52 insertions(+), 39 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 e968cb9..11f0189 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 @@ -78,6 +78,7 @@ private final DataDictionaryCustomMapper dataDictionaryCustomMapper; private final MallAchieveRecordMapper mallAchieveRecordMapper; private final MallMemberWalletMapper mallMemberWalletMapper; + private final MallMqRecordMapper mallMqRecordMapper; @Override @Transactional(rollbackFor = Exception.class) @@ -206,25 +207,19 @@ /** * 使用积分折扣现金 */ - DataDictionaryCustom scorePercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( - DataDictionaryEnum.SCORE_PERCENT.getType(), - DataDictionaryEnum.SCORE_PERCENT.getCode() - ); DataDictionaryCustom scoreChangeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.SCORE_CHANGE.getType(), DataDictionaryEnum.SCORE_CHANGE.getCode() ); BigDecimal score = ObjectUtil.isEmpty(addOrderDto.getScore()) ? BigDecimal.ZERO : addOrderDto.getScore(); orderInfo.setScoreCnt(score); - if(ObjectUtil.isNotEmpty(scorePercentDic)){ - BigDecimal scoreChange = BigDecimal.ONE; - if(ObjectUtil.isNotEmpty(scoreChangeDic)){ - scoreChange = new BigDecimal(scoreChangeDic.getValue()).abs().setScale(2,BigDecimal.ROUND_DOWN); - } - //折扣现金 - BigDecimal scorePercentAmount = score.divide(scoreChange,BigDecimal.ROUND_DOWN).setScale(2,BigDecimal.ROUND_DOWN); - orderInfo.setScoreAmount(scorePercentAmount); + BigDecimal scoreChange = BigDecimal.ONE; + if(ObjectUtil.isNotEmpty(scoreChangeDic)){ + scoreChange = new BigDecimal(scoreChangeDic.getValue()).abs().setScale(2,BigDecimal.ROUND_DOWN); } + //折扣现金 + BigDecimal scorePercentAmount = score.divide(scoreChange,BigDecimal.ROUND_DOWN).setScale(2,BigDecimal.ROUND_DOWN); + orderInfo.setScoreAmount(scorePercentAmount); orderInfo.setAmount(total); if(2 == deliverType){ orderInfo.setDeliverType(2); @@ -349,6 +344,15 @@ orderInfo.setPayResult("1"); changeWallet(orderInfo.getId()); + /** + * 插入一条待处理记录 + * mq处理之后,更新状态 + */ + MallMqRecord mallMqRecord = new MallMqRecord(); + mallMqRecord.setOrderId(orderInfo.getId()); + mallMqRecord.setState(2); + mallMqRecord.setRetryTimes(2); + mallMqRecordMapper.insert(mallMqRecord); //发送补贴消息 agentProducer.sendPerkMoneyMsg(orderInfo.getId()); //发送代理自动升级消息 @@ -454,11 +458,13 @@ */ if (mallGoods.getIsNormal() == 2) { hasTc = true; - BigDecimal star = mallGoods.getStar()==null ? BigDecimal.ZERO : mallGoods.getStar(); + BigDecimal star = (mallGoods.getStar()==null ? BigDecimal.ZERO : mallGoods.getStar()) + .multiply(new BigDecimal(orderItem.getCnt())); starSum = starSum.add(star); scoreSum = scoreSum.add( new BigDecimal(mallGoods.getPresentPrice()) .multiply(new BigDecimal(3)) + .multiply(new BigDecimal(orderItem.getCnt())) .abs() .setScale(2,BigDecimal.ROUND_DOWN)); } @@ -478,6 +484,15 @@ MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(memberId); BigDecimal star = new BigDecimal(mallMemberWallet.getStar()); if(starGet.compareTo(star.add(starSum)) < 0){ + if(starGet.compareTo(BigDecimal.ZERO) == 0){ + mallMemberWalletMapper.addStarByMemberId(starSum.intValue(), memberId); + mallMoneyFlowService.addMoneyFlow( + memberId, + starSum, + MoneyFlowTypeEnum.STAR.getValue(), + orderInfo.getOrderNo(), + FlowTypeEnum.STAR.getValue()); + } if(starGet.compareTo(star) > 0){ BigDecimal subtract = starGet.subtract(star); if(subtract.compareTo(starSum) < 0){ @@ -842,18 +857,24 @@ } boolean hasTc = false; + //总的折扣积分数量 BigDecimal total = BigDecimal.ZERO; for (AddOrderItemDto item : addOrderDto.getItems()) { - MallGoodsSku sku = mallGoodsSkuMapper.selectSkuInfoById(item.getSkuId()); - MallGoods mallGoods = mallGoodsMapper.selectById(sku.getGoodsId()); - /** - * 贡献点判断 + MallGoodsSku sku = mallGoodsSkuMapper.selectSkuInfoById(item.getSkuId()); + MallGoods mallGoods = mallGoodsMapper.selectById(sku.getGoodsId()); + /** + * 贡献点判断 + */ + if (mallGoods.getIsNormal() == 2) { + hasTc = true; + } + /* + 获取单个商品的折扣积分数量 + = 现价 * 数量 * 折扣现金比例 */ - if (mallGoods.getIsNormal() == 2) { - hasTc = true; - } - BigDecimal amount = sku.getPresentPrice().multiply(BigDecimal.valueOf(item.getCnt())); - total = total.add(amount); + BigDecimal scorePercent = new BigDecimal(mallGoods.getScorePercent()).multiply(new BigDecimal(0.01)); + BigDecimal amount = sku.getPresentPrice().multiply(BigDecimal.valueOf(item.getCnt())).multiply(scorePercent); + total = total.add(amount); } BigDecimal score = ObjectUtil.isEmpty(addOrderDto.getScore()) ? BigDecimal.ZERO : addOrderDto.getScore(); @@ -880,28 +901,20 @@ /** * 使用积分折扣现金 */ - DataDictionaryCustom scorePercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( - DataDictionaryEnum.SCORE_PERCENT.getType(), - DataDictionaryEnum.SCORE_PERCENT.getCode() - ); DataDictionaryCustom scoreChangeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode( DataDictionaryEnum.SCORE_CHANGE.getType(), DataDictionaryEnum.SCORE_CHANGE.getCode() ); - if(ObjectUtil.isNotEmpty(scorePercentDic)){ - //商品的现金折扣比例 - BigDecimal scorePercent = new BigDecimal(scorePercentDic.getValue()).multiply(BigDecimal.valueOf(0.01)); - //最大折扣金额对应需要的总积分数目 - BigDecimal scorePercentMaxAmount = total.multiply(scorePercent); - BigDecimal scoreChange = BigDecimal.ONE; - if(ObjectUtil.isNotEmpty(scoreChangeDic)){ - scoreChange = new BigDecimal(scoreChangeDic.getValue()).abs().setScale(2,BigDecimal.ROUND_DOWN); - } - scorePercentMaxAmount = scorePercentMaxAmount.multiply(scoreChange).setScale(2,BigDecimal.ROUND_DOWN); - if(scorePercentMaxAmount.compareTo(score) < 0){ - throw new FebsException("最多可使用"+scorePercentMaxAmount+"积分"); - } + //最大折扣金额对应需要的总积分数目 + BigDecimal scorePercentMaxAmount = total; + BigDecimal scoreChange = BigDecimal.ONE; + if(ObjectUtil.isNotEmpty(scoreChangeDic)){ + scoreChange = new BigDecimal(scoreChangeDic.getValue()).abs().setScale(2,BigDecimal.ROUND_DOWN); + } + scorePercentMaxAmount = scorePercentMaxAmount.multiply(scoreChange).setScale(2,BigDecimal.ROUND_DOWN); + if(scorePercentMaxAmount.compareTo(score) < 0){ + throw new FebsException("最多可使用"+scorePercentMaxAmount+"积分"); } return new FebsResponse().success(); } -- Gitblit v1.9.1