KKSU
2024-04-02 5363215e8adc5a8106c598bbea281196c31e70ae
src/main/java/cc/mrbird/febs/mall/service/impl/AgentServiceImpl.java
@@ -1128,6 +1128,22 @@
                    mallMemberAmountMapper.updateTotalPerkById(mallMemberAmountPerk);
                }
//                    insertSell(mallProductBuy.getMemberId(),profit,profit,BigDecimal.ZERO,BigDecimal.ZERO);
                MallMember mallMemberMe = memberMapper.selectById(mallProductBuy.getMemberId());
                if(ProductEnum.MEMBER_FROZEN.getValue() == mallMemberMe.getIsFrozen()){
                    //插入一条流水记录
                    String orderNo = MallUtils.getOrderNum("FNFTW");
                    mallMoneyFlowService.addMoneyFlow(
                            mallProductBuy.getMemberId(),
                            profit.negate(),
                            MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getValue(),
                            orderNo,
                            null,
                            FlowTypeNewEnum.NFT.getValue(),
                            MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getDescrition(),
                            AppContants.MEMBER_FLOW_ING);
                }else{
                String orderNoSY = MallUtils.getOrderNum("SYNFT");
                mallMoneyFlowService.addMoneyFlow(
                        mallProductBuy.getMemberId(),
@@ -1142,7 +1158,7 @@
                MallMemberAmount mallMemberAmountMine = mallMemberAmountMapper.selectByMemberId(mallProductBuy.getMemberId());
                mallMemberAmountMine.setTrendsNft(mallMemberAmountMine.getTrendsNft().add(profit));
                mallMemberAmountMapper.updateTrendsNftById(mallMemberAmountMine);
                }
                BigDecimal remainderDirect = bigDecimal.divide(new BigDecimal(String.valueOf(cycle)),0,BigDecimal.ROUND_DOWN);//取余
                if(remainderDirect.compareTo(BigDecimal.ONE) == 0){
@@ -1163,6 +1179,21 @@
                                ).getValue()).multiply(new BigDecimal("0.01"));
//                            BigDecimal basicPerkDirect = profit.multiply(basicPerkDirectPercent).setScale(2, BigDecimal.ROUND_DOWN);
                                BigDecimal basicPerkDirect = nftTotal.multiply(basicPerkDirectPercent).setScale(2, BigDecimal.ROUND_DOWN);
                                if(ProductEnum.MEMBER_FROZEN.getValue() == directMember.getIsFrozen()){
                                    //插入一条流水记录
                                    String orderNo = MallUtils.getOrderNum("FNFTW");
                                    mallMoneyFlowService.addMoneyFlow(
                                            directMember.getId(),
                                            profit.negate(),
                                            MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getValue(),
                                            orderNo,
                                            null,
                                            FlowTypeNewEnum.NFT.getValue(),
                                            MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getDescrition(),
                                            AppContants.MEMBER_FLOW_ING);
                                }else{
                                /**
                                 * 先插入流水记录,然后定时器每小时,循环一次找寻对应的数据执行
                                 */
@@ -1181,7 +1212,7 @@
                                mallMemberAmountDirect.setFrozenNft(mallMemberAmountDirect.getFrozenNft().add(basicPerkDirect));
                                mallMemberAmountMapper.updateFrozenNftById(mallMemberAmountDirect);
                            }
                            }
                        }
                        /**