xc-mall.git - Gitblit

			@@ -3,6 +3,8 @@
			import cc.mrbird.febs.common.enumerates.*;
			import cc.mrbird.febs.common.utils.AppContants;
			import cc.mrbird.febs.common.utils.MallUtils;
			import cc.mrbird.febs.mall.dto.ScoreSettingDto;
			import cc.mrbird.febs.mall.dto.TeamPerkDto;
			import cc.mrbird.febs.mall.entity.*;
			import cc.mrbird.febs.mall.mapper.*;
			import cc.mrbird.febs.mall.service.*;
			@@ -18,6 +20,7 @@
			import cn.hutool.core.util.StrUtil;
			import cn.hutool.json.JSONUtil;
			import com.alibaba.fastjson.JSONObject;
			import com.baomidou.mybatisplus.core.conditions.Wrapper;
			import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
			import lombok.RequiredArgsConstructor;
			import lombok.extern.slf4j.Slf4j;
			@@ -860,17 +863,135 @@
			mallProductBuy.setMateState(ProductEnum.PRODUCT_BUY_MATE_STATE_SUCCESS.getValue());
			mallProductBuyMapper.updateById(mallProductBuy);
			BigDecimal nftTotal = mallProductBuy.getNftTotal();
			insertSell(mallProductBuy.getMemberId(),nftTotal,nftTotal,BigDecimal.ZERO,BigDecimal.ZERO);
			BigDecimal profit = nftTotal.multiply(profitPercent.multiply(new BigDecimal(0.01)));
			insertSell(mallProductBuy.getMemberId(),profit,profit,BigDecimal.ZERO,BigDecimal.ZERO);
			BigDecimal add = nftTotal.add(profit);
			insertSell(mallProductBuy.getMemberId(),add,add,BigDecimal.ZERO,BigDecimal.ZERO);
			// insertSell(mallProductBuy.getMemberId(),profit,profit,BigDecimal.ZERO,BigDecimal.ZERO);

			/**
			* 更新用户上级收益，冻结7天，7天时间到期自动释放到动态钱包
			*/
			Long memberId = mallProductBuy.getMemberId();
			MallMember mallMember = memberMapper.selectById(memberId);
			if(ObjectUtil.isNotEmpty(mallMember)){
			//直推
			String referrerId = mallMember.getReferrerId();
			MallMember directMember = memberMapper.selectInfoByInviteId(referrerId);
			if(ObjectUtil.isNotEmpty(directMember)){
			BigDecimal basicPerkDirectPercent = new BigDecimal(dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
			DataDictionaryEnum.BASIC_PERK_DIRECT.getType(),
			DataDictionaryEnum.BASIC_PERK_DIRECT.getCode()
			).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);
			/**
			* 先插入流水记录，然后定时器每小时，循环一次找寻对应的数据执行
			*/
			String orderNo = MallUtils.getOrderNum("DNFT");
			mallMoneyFlowService.addMoneyFlow(
			directMember.getId(),
			basicPerkDirect,
			MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT.getValue(),
			orderNo,
			null,
			FlowTypeNewEnum.NFT.getValue(),
			MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT.getDescrition(),
			AppContants.MEMBER_FLOW_ING);

			MallMemberAmount mallMemberAmountDirect = mallMemberAmountMapper.selectByMemberId(directMember.getId());
			mallMemberAmountDirect.setFrozenNft(mallMemberAmountDirect.getFrozenNft().add(basicPerkDirect));
			mallMemberAmountMapper.updateFrozenNftById(mallMemberAmountDirect);
			}

			/**
			* 团队奖励
			*
			*/
			String level = MemberLevelNewEnum.ZERO_LEVEL.getType();
			BigDecimal equalsPerkBasic = BigDecimal.ZERO;//平级收益，假设平级，则算平级收益的百分比收益
			boolean flag = false;
			String parentId = mallMember.getReferrerId();
			if (StrUtil.isBlank(parentId)) {
			flag = true;
			}
			while (!flag) {
			MallMember mallMemberRef = memberMapper.selectInfoByInviteId(parentId);
			String levelRef = mallMemberRef.getLevel();
			//会员等级为ZERO_LEVEL，则不参与团队返佣
			if(!MemberLevelNewEnum.ZERO_LEVEL.getType().equals(levelRef)){
			int compareLevel = MemberLevelNewEnum.ZERO_LEVEL.compareLevel(level, levelRef);
			DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
			levelRef, levelRef
			);
			TeamPerkDto teamPerkDto = JSONObject.parseObject(dataDictionaryCustom.getValue(), TeamPerkDto.class);
			if(compareLevel == 0){//团队奖励
			BigDecimal PerkPercent = new BigDecimal(teamPerkDto.getPerkPercent())
			.multiply(new BigDecimal("0.01"));
			BigDecimal teamPerk = PerkPercent.multiply(profit).setScale(2,BigDecimal.ROUND_DOWN);
			/**
			* 先插入流水记录，然后定时器循环,找寻对应的数据执行
			*/
			String orderNo = MallUtils.getOrderNum("TNFT");

			if(teamPerk.compareTo(BigDecimal.ZERO) > 0){
			insertFlowUpdateFrozenNft(
			orderNo,
			mallMemberRef.getId(),
			teamPerk,
			MoneyFlowTypeNewEnum.TEAM_PERK_DIRECT.getValue(),
			FlowTypeNewEnum.NFT.getValue(),
			MoneyFlowTypeNewEnum.TEAM_PERK_DIRECT.getDescrition(),
			AppContants.MEMBER_FLOW_ING);
			}
			equalsPerkBasic = teamPerk;
			level = levelRef;
			}else if(compareLevel == 2){//平级奖励
			BigDecimal equalsPerkPercent = new BigDecimal(teamPerkDto.getEqualsPerkPercent())
			.multiply(new BigDecimal("0.01"));
			BigDecimal equalsPerk = equalsPerkPercent.multiply(equalsPerkBasic).setScale(2,BigDecimal.ROUND_DOWN);
			String orderNo = MallUtils.getOrderNum("PJNFT");
			if(equalsPerk.compareTo(BigDecimal.ZERO) > 0){
			insertFlowUpdateFrozenNft(
			orderNo,
			mallMemberRef.getId(),
			equalsPerk,
			MoneyFlowTypeNewEnum.TEAM_PERK_EQUALS.getValue(),
			FlowTypeNewEnum.NFT.getValue(),
			MoneyFlowTypeNewEnum.TEAM_PERK_EQUALS.getDescrition(),
			AppContants.MEMBER_FLOW_ING);
			}
			equalsPerkBasic = equalsPerk;
			}
			}
			parentId = mallMemberRef.getReferrerId();
			if (StrUtil.isBlank(mallMemberRef.getReferrerId())) {
			flag = true;
			}
			}
			}
			}
			}
			}
			}

			/**
			* 先插入流水记录，更新冻结NFT，后续定时器循环,找寻对应的数据执行
			*/
			public void insertFlowUpdateFrozenNft(String orderNo,Long memberId,BigDecimal perk,Integer type,Integer flowType,String desc,
			Integer isReturn){
			mallMoneyFlowService.addMoneyFlow(
			memberId,
			perk,
			type,
			orderNo,
			null,
			flowType,
			desc,
			isReturn);

			MallMemberAmount mallMemberAmountDirect = mallMemberAmountMapper.selectByMemberId(memberId);
			mallMemberAmountDirect.setFrozenNft(mallMemberAmountDirect.getFrozenNft().add(perk));
			mallMemberAmountMapper.updateFrozenNftById(mallMemberAmountDirect);
			}

			@Override
			@@ -1031,6 +1152,276 @@
			}
			}

			@Override
			public void basicMemberPerk() {
			QueryWrapper<MallMoneyFlow> queryMallMoneyFlow = new QueryWrapper<>();
			queryMallMoneyFlow.eq("type",MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT.getValue());
			queryMallMoneyFlow.eq("is_return",AppContants.MEMBER_FLOW_ING);
			queryMallMoneyFlow.eq("flow_type",FlowTypeNewEnum.NFT.getValue());
			List<MallMoneyFlow> mallMoneyFlows = mallMoneyFlowMapper.selectList(queryMallMoneyFlow);
			if(CollUtil.isNotEmpty(mallMoneyFlows)){
			return;
			}

			String frozenDays = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
			DataDictionaryEnum.BASIC_PERK_DIRECT_FROZEN.getType(),
			DataDictionaryEnum.BASIC_PERK_DIRECT_FROZEN.getCode()
			).getValue();
			for(MallMoneyFlow mallMoneyFlow : mallMoneyFlows){
			//创建时间往后增加冻结天数，与当前时间进行比较，如果大于当前时间,则跳出循环。
			Date createdTime = mallMoneyFlow.getCreatedTime();
			DateTime dateTime = DateUtil.offsetDay(createdTime, Integer.parseInt(frozenDays));
			if(DateUtil.compare(dateTime, new Date()) > 0){
			continue;
			}
			mallMoneyFlow.setIsReturn(AppContants.MEMBER_FLOW_DONE);
			mallMoneyFlowMapper.updateById(mallMoneyFlow);
			/**
			* 如果用户是冻结，则直接销毁
			*/
			Long memberId = mallMoneyFlow.getMemberId();
			MallMember mallMember = memberMapper.selectById(memberId);
			Integer isFrozen = mallMember.getIsFrozen();
			if(ProductEnum.MEMBER_UNFROZEN.getValue() == isFrozen){
			MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId);
			mallMemberAmount.setFrozenNft(mallMemberAmount.getFrozenNft().subtract(mallMoneyFlow.getAmount()));
			mallMemberAmountMapper.updateFrozenNftById(mallMemberAmount);
			//插入一条流水记录
			String orderNo = MallUtils.getOrderNum("FNFTW");
			mallMoneyFlowService.addMoneyFlow(
			memberId,
			mallMoneyFlow.getAmount().negate(),
			MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getValue(),
			orderNo,
			null,
			FlowTypeNewEnum.NFT.getValue(),
			MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getDescrition(),
			AppContants.MEMBER_FLOW_ING);

			}else {
			MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId);
			mallMemberAmount.setFrozenNft(mallMemberAmount.getFrozenNft().subtract(mallMoneyFlow.getAmount()));
			mallMemberAmount.setTrendsNft(mallMemberAmount.getTrendsNft().add(mallMoneyFlow.getAmount()));
			mallMemberAmountMapper.updateTrendsNftAndFrozenNftById(mallMemberAmount);

			//插入一条流水记录
			String orderNo = MallUtils.getOrderNum("NFT");
			mallMoneyFlowService.addMoneyFlow(
			memberId,
			mallMoneyFlow.getAmount().negate(),
			MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_DONE.getValue(),
			orderNo,
			null,
			FlowTypeNewEnum.NFT.getValue(),
			MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_DONE.getDescrition(),
			AppContants.MEMBER_FLOW_DONE);
			}
			}
			}

			@Override
			public void teamMemberPerk() {
			QueryWrapper<MallMoneyFlow> queryMallMoneyFlow = new QueryWrapper<>();
			queryMallMoneyFlow.eq("type",MoneyFlowTypeNewEnum.TEAM_PERK_DIRECT.getValue());
			queryMallMoneyFlow.eq("is_return",AppContants.MEMBER_FLOW_ING);
			queryMallMoneyFlow.eq("flow_type",FlowTypeNewEnum.NFT.getValue());
			List<MallMoneyFlow> mallMoneyFlows = mallMoneyFlowMapper.selectList(queryMallMoneyFlow);
			if(CollUtil.isNotEmpty(mallMoneyFlows)){
			return;
			}

			String frozenDays = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
			DataDictionaryEnum.BASIC_PERK_DIRECT_FROZEN.getType(),
			DataDictionaryEnum.BASIC_PERK_DIRECT_FROZEN.getCode()
			).getValue();
			for(MallMoneyFlow mallMoneyFlow : mallMoneyFlows){
			//创建时间往后增加冻结天数，与当前时间进行比较，如果大于当前时间,则跳出循环。
			Date createdTime = mallMoneyFlow.getCreatedTime();
			DateTime dateTime = DateUtil.offsetDay(createdTime, Integer.parseInt(frozenDays));
			if(DateUtil.compare(dateTime, new Date()) > 0){
			continue;
			}
			mallMoneyFlow.setIsReturn(AppContants.MEMBER_FLOW_DONE);
			mallMoneyFlowMapper.updateById(mallMoneyFlow);
			/**
			* 如果用户是冻结，则直接销毁
			*/
			Long memberId = mallMoneyFlow.getMemberId();
			MallMember mallMember = memberMapper.selectById(memberId);
			Integer isFrozen = mallMember.getIsFrozen();
			if(ProductEnum.MEMBER_UNFROZEN.getValue() == isFrozen){
			MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId);
			mallMemberAmount.setFrozenNft(mallMemberAmount.getFrozenNft().subtract(mallMoneyFlow.getAmount()));
			mallMemberAmountMapper.updateFrozenNftById(mallMemberAmount);
			//插入一条流水记录
			String orderNo = MallUtils.getOrderNum("FNFTW");
			mallMoneyFlowService.addMoneyFlow(
			memberId,
			mallMoneyFlow.getAmount().negate(),
			MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getValue(),
			orderNo,
			null,
			FlowTypeNewEnum.NFT.getValue(),
			MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getDescrition(),
			AppContants.MEMBER_FLOW_ING);

			}else {
			MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId);
			mallMemberAmount.setFrozenNft(mallMemberAmount.getFrozenNft().subtract(mallMoneyFlow.getAmount()));
			mallMemberAmount.setTrendsNft(mallMemberAmount.getTrendsNft().add(mallMoneyFlow.getAmount()));
			mallMemberAmountMapper.updateTrendsNftAndFrozenNftById(mallMemberAmount);

			//插入一条流水记录
			String orderNo = MallUtils.getOrderNum("NFT");
			mallMoneyFlowService.addMoneyFlow(
			memberId,
			mallMoneyFlow.getAmount().negate(),
			MoneyFlowTypeNewEnum.TEAM_PERK_DIRECT_DONE.getValue(),
			orderNo,
			null,
			FlowTypeNewEnum.NFT.getValue(),
			MoneyFlowTypeNewEnum.TEAM_PERK_DIRECT_DONE.getDescrition(),
			AppContants.MEMBER_FLOW_DONE);
			}
			}
			}

			@Override
			public void equalsMemberPerk() {
			QueryWrapper<MallMoneyFlow> queryMallMoneyFlow = new QueryWrapper<>();
			queryMallMoneyFlow.eq("type",MoneyFlowTypeNewEnum.TEAM_PERK_EQUALS.getValue());
			queryMallMoneyFlow.eq("is_return",AppContants.MEMBER_FLOW_ING);
			queryMallMoneyFlow.eq("flow_type",FlowTypeNewEnum.NFT.getValue());
			List<MallMoneyFlow> mallMoneyFlows = mallMoneyFlowMapper.selectList(queryMallMoneyFlow);
			if(CollUtil.isNotEmpty(mallMoneyFlows)){
			return;
			}

			String frozenDays = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
			DataDictionaryEnum.BASIC_PERK_DIRECT_FROZEN.getType(),
			DataDictionaryEnum.BASIC_PERK_DIRECT_FROZEN.getCode()
			).getValue();
			for(MallMoneyFlow mallMoneyFlow : mallMoneyFlows){
			//创建时间往后增加冻结天数，与当前时间进行比较，如果大于当前时间,则跳出循环。
			Date createdTime = mallMoneyFlow.getCreatedTime();
			DateTime dateTime = DateUtil.offsetDay(createdTime, Integer.parseInt(frozenDays));
			if(DateUtil.compare(dateTime, new Date()) > 0){
			continue;
			}
			mallMoneyFlow.setIsReturn(AppContants.MEMBER_FLOW_DONE);
			mallMoneyFlowMapper.updateById(mallMoneyFlow);
			/**
			* 如果用户是冻结，则直接销毁
			*/
			Long memberId = mallMoneyFlow.getMemberId();
			MallMember mallMember = memberMapper.selectById(memberId);
			Integer isFrozen = mallMember.getIsFrozen();
			if(ProductEnum.MEMBER_UNFROZEN.getValue() == isFrozen){
			MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId);
			mallMemberAmount.setFrozenNft(mallMemberAmount.getFrozenNft().subtract(mallMoneyFlow.getAmount()));
			mallMemberAmountMapper.updateFrozenNftById(mallMemberAmount);
			//插入一条流水记录
			String orderNo = MallUtils.getOrderNum("FNFTW");
			mallMoneyFlowService.addMoneyFlow(
			memberId,
			mallMoneyFlow.getAmount().negate(),
			MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getValue(),
			orderNo,
			null,
			FlowTypeNewEnum.NFT.getValue(),
			MoneyFlowTypeNewEnum.BASIC_PERK_DIRECT_WRONG.getDescrition(),
			AppContants.MEMBER_FLOW_ING);

			}else {
			MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(memberId);
			mallMemberAmount.setFrozenNft(mallMemberAmount.getFrozenNft().subtract(mallMoneyFlow.getAmount()));
			mallMemberAmount.setTrendsNft(mallMemberAmount.getTrendsNft().add(mallMoneyFlow.getAmount()));
			mallMemberAmountMapper.updateTrendsNftAndFrozenNftById(mallMemberAmount);

			//插入一条流水记录
			String orderNo = MallUtils.getOrderNum("NFT");
			mallMoneyFlowService.addMoneyFlow(
			memberId,
			mallMoneyFlow.getAmount().negate(),
			MoneyFlowTypeNewEnum.TEAM_PERK_EQUALS_DONE.getValue(),
			orderNo,
			null,
			FlowTypeNewEnum.NFT.getValue(),
			MoneyFlowTypeNewEnum.TEAM_PERK_EQUALS_DONE.getDescrition(),
			AppContants.MEMBER_FLOW_DONE);
			}
			}
			}

			@Override
			public void memberLevelUp() {
			/**
			* 获取当前所有的已完成、未转换的买单的用户
			*/
			QueryWrapper<MallProductBuy> query = new QueryWrapper<>();
			query.eq("state",ProductEnum.PRODUCT_BUY_SUCCESS.getValue());
			query.eq("mate_state",ProductEnum.PRODUCT_BUY_MATE_STATE_FAIL.getValue());
			List<MallProductBuy> mallProductBuys = mallProductBuyMapper.selectList(query);
			if(CollUtil.isEmpty(mallProductBuys)){
			return;
			}

			Set<Long> collect = mallProductBuys.stream().map(MallProductBuy::getMemberId).collect(Collectors.toSet());
			if(CollUtil.isEmpty(collect)){
			return;
			}
			for(Long memberId : collect){
			MallMember mallMember = memberMapper.selectById(memberId);
			if(ObjectUtil.isEmpty(mallMember)){
			continue;
			}
			//上级
			String referrerId = mallMember.getReferrerId();
			MallMember mallMemberRef = memberMapper.selectInfoByInviteId(referrerId);
			List<MallMember> mallMembersAll = memberMapper.selectAllChildAgentListByInviteId(referrerId);

			List<MallMember> mallMembers = memberMapper.selectByRefererId(referrerId);
			Set<Long> mallMembersSet = mallMembers.stream().map(MallMember::getId).collect(Collectors.toSet());
			mallMembersSet.retainAll(collect);
			List<Long> intersection = new ArrayList<>(mallMembersSet);//上级直推有效人数
			if(CollUtil.isEmpty(intersection)){
			mallMemberRef.setLevel(MemberLevelNewEnum.ZERO_LEVEL.getType());
			memberMapper.updateById(mallMemberRef);
			continue;
			}
			/**
			* 从会员等级最低到最高，比较intersection与会员设置的直推人数directCntLevel比较
			* directCntLevel >= intersection.size()，则满足升级会员等级条件，跳出循环
			* teamCnt >= mallMembersAll.size()，则满足升级会员等级条件，跳出循环
			* 达到最高级别后，升级会员等级，跳出循环
			*/
			String level = MemberLevelNewEnum.ZERO_LEVEL.getType();
			boolean flag = false;
			while (!flag){
			DataDictionaryCustom levelDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
			level, level
			);
			TeamPerkDto teamPerkDto = JSONObject.parseObject(levelDic.getValue(), TeamPerkDto.class);
			Integer directCntLevel = teamPerkDto.getDirectCnt();
			Integer teamCnt = teamPerkDto.getTeamCnt();
			if(directCntLevel >= intersection.size() &&
			teamCnt >= mallMembersAll.size()){
			mallMemberRef.setLevel(level);
			memberMapper.updateById(mallMemberRef);
			flag = true;
			}
			String nextLevel = MemberLevelNewEnum.ZERO_LEVEL.getNextLevel(level);
			level = nextLevel;
			if(level.equals(MemberLevelNewEnum.WU_LEVEL.getType()) &&
			nextLevel.equals(MemberLevelNewEnum.WU_LEVEL.getType()) ){
			mallMemberRef.setLevel(level);
			memberMapper.updateById(mallMemberRef);
			flag = true;
			}
			}
			}
			}

			public void insertSell(Long memberId,BigDecimal nftCnt,BigDecimal nftCntAva,
			BigDecimal nftFee,BigDecimal fcmFeeCnt){
			String orderNo = MallUtils.getOrderNum("NFT");