xc-mall.git - Gitblit

			@@ -14,6 +14,7 @@
			import cc.mrbird.febs.system.mapper.UserMapper;
			import cn.hutool.core.collection.CollUtil;
			import cn.hutool.core.date.DateTime;
			import cn.hutool.core.date.DateUnit;
			import cn.hutool.core.date.DateUtil;
			import cn.hutool.core.math.MathUtil;
			import cn.hutool.core.util.ObjectUtil;
			@@ -823,7 +824,14 @@
			List<MallMember> thirdLevelRecord = getStarRecord(fourLevelRecord, MemberLevelEnum.THIRD_LEVEL.name(), amount, orderNo, 0L,MoneyFlowTypeEnum.STAR_PERK_THREE.getValue());
			List<MallMember> secondLevelRecord = getStarRecord(thirdLevelRecord, MemberLevelEnum.SECOND_LEVEL.name(), amount, orderNo, 0L,MoneyFlowTypeEnum.STAR_PERK_TWO.getValue());
			}

			public static void main(String[] args) {
			Long number = 0L; // 这里可以替换成你需要检查的数字
			if (number % 3 == 0) {
			System.out.println(number + " 可以被3整除");
			} else {
			System.out.println(number + " 不能被3整除");
			}
			}
			@Override
			public void BuyToSell() {
			/**
			@@ -850,22 +858,46 @@
			BigDecimal profitPercent = mallProductNft.getProfit();
			for(MallProductBuy mallProductBuy : mallProductBuys){



			Date payTime = mallProductBuy.getPayTime();


			// //偏移时间--
			// DateTime dateTime = DateUtil.offsetDay(payTime, cycle);
			// int compare = DateUtil.compare(now, dateTime);
			// if(compare >= 0){
			// mallProductBuy.setMateState(ProductEnum.PRODUCT_BUY_MATE_STATE_SUCCESS.getValue());
			// mallProductBuyMapper.updateById(mallProductBuy);
			//偏移时间
			DateTime dateTime = DateUtil.offsetDay(payTime, cycle);
			int compare = DateUtil.compare(now, dateTime);
			if(compare >= 0){
			String s = String.valueOf(DateUtil.between(payTime, DateUtil.date(), DateUnit.DAY));//相差日期天数
			BigDecimal bigDecimal = new BigDecimal(s).setScale(0, BigDecimal.ROUND_DOWN);//只取整数位
			if(bigDecimal.compareTo(BigDecimal.ZERO) <= 0){
			continue;
			}
			BigDecimal remainder = bigDecimal.remainder(new BigDecimal(String.valueOf(cycle)));//取余
			if (remainder.compareTo(BigDecimal.ZERO) == 0) {
			/**
			* 更新买单状态
			* 收益生成一条卖单
			* 本金生成一条卖单
			* 用户的账户增加对应的收益
			*/
			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);
			// insertSell(mallProductBuy.getMemberId(),profit,profit,BigDecimal.ZERO,BigDecimal.ZERO);
			String orderNoSY = MallUtils.getOrderNum("SYNFT");
			mallMoneyFlowService.addMoneyFlow(
			mallProductBuy.getMemberId(),
			profit,
			MoneyFlowTypeNewEnum.PERK_CYCLE.getValue(),
			orderNoSY,
			null,
			FlowTypeNewEnum.NFT.getValue(),
			MoneyFlowTypeNewEnum.PERK_CYCLE.getDescrition(),
			AppContants.MEMBER_FLOW_DONE);

			MallMemberAmount mallMemberAmountMine = mallMemberAmountMapper.selectByMemberId(mallProductBuy.getMemberId());
			mallMemberAmountMine.setTrendsNft(mallMemberAmountMine.getTrendsNft().add(profit));
			mallMemberAmountMapper.updateTrendsNftById(mallMemberAmountMine);


			/**
			* 更新用户上级收益，冻结7天，7天时间到期自动释放到动态钱包
			@@ -881,7 +913,8 @@
			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 = profit.multiply(basicPerkDirectPercent).setScale(2, BigDecimal.ROUND_DOWN);
			BigDecimal basicPerkDirect = nftTotal.multiply(basicPerkDirectPercent).setScale(2, BigDecimal.ROUND_DOWN);
			/**
			* 先插入流水记录，然后定时器每小时，循环一次找寻对应的数据执行
			*/
			@@ -923,7 +956,8 @@
			);
			TeamPerkDto teamPerkDto = JSONObject.parseObject(dataDictionaryCustom.getValue(), TeamPerkDto.class);
			if(compareLevel == 0){//团队奖励
			BigDecimal PerkPercent = new BigDecimal(teamPerkDto.getPerkPercent());
			BigDecimal PerkPercent = new BigDecimal(teamPerkDto.getPerkPercent())
			.multiply(new BigDecimal("0.01"));
			BigDecimal teamPerk = PerkPercent.multiply(profit).setScale(2,BigDecimal.ROUND_DOWN);
			/**
			* 先插入流水记录，然后定时器循环,找寻对应的数据执行
			@@ -943,7 +977,8 @@
			equalsPerkBasic = teamPerk;
			level = levelRef;
			}else if(compareLevel == 2){//平级奖励
			BigDecimal equalsPerkPercent = new BigDecimal(teamPerkDto.getEqualsPerkPercent());
			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){
			@@ -1374,6 +1409,7 @@
			//上级
			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());
			@@ -1387,6 +1423,7 @@
			/**
			* 从会员等级最低到最高，比较intersection与会员设置的直推人数directCntLevel比较
			* directCntLevel >= intersection.size()，则满足升级会员等级条件，跳出循环
			* teamCnt >= mallMembersAll.size()，则满足升级会员等级条件，跳出循环
			* 达到最高级别后，升级会员等级，跳出循环
			*/
			String level = MemberLevelNewEnum.ZERO_LEVEL.getType();
			@@ -1397,7 +1434,9 @@
			);
			TeamPerkDto teamPerkDto = JSONObject.parseObject(levelDic.getValue(), TeamPerkDto.class);
			Integer directCntLevel = teamPerkDto.getDirectCnt();
			if(directCntLevel >= intersection.size()){
			Integer teamCnt = teamPerkDto.getTeamCnt();
			if(directCntLevel >= intersection.size() &&
			teamCnt >= mallMembersAll.size()){
			mallMemberRef.setLevel(level);
			memberMapper.updateById(mallMemberRef);
			flag = true;
			@@ -1460,10 +1499,10 @@
			}
			return list;
			}
			public static void main(String[] args) {
			int[] nums = {1, 2, 2, 5, 2};
			List<Integer> missingNumbers = findDisappearedNumbers(nums);
			System.out.println("缺失的数字为：" + missingNumbers);
			}
			// public static void main(String[] args) {
			// int[] nums = {1, 2, 2, 5, 2};
			// List<Integer> missingNumbers = findDisappearedNumbers(nums);
			// System.out.println("缺失的数字为：" + missingNumbers);
			// }

			}