xc-mall.git - Gitblit

			@@ -863,6 +863,47 @@
			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);

			/**
			* 更新用户上级收益，冻结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);
			/**
			* 先插入流水记录，然后定时器每小时，循环一次找寻对应的数据执行
			*/
			String frozenDays = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
			DataDictionaryEnum.BASIC_PERK_DIRECT_FROZEN.getType(),
			DataDictionaryEnum.BASIC_PERK_DIRECT_FROZEN.getCode()
			).getValue();
			String orderNo = MallUtils.getOrderNum("FNFT");
			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);
			}


			}
			}
			}
			}
			@@ -1026,6 +1067,62 @@
			}
			}

			@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;
			}
			for(MallMoneyFlow mallMoneyFlow : mallMoneyFlows){
			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);
			}
			}
			}

			public void insertSell(Long memberId,BigDecimal nftCnt,BigDecimal nftCntAva,
			BigDecimal nftFee,BigDecimal fcmFeeCnt){
			String orderNo = MallUtils.getOrderNum("NFT");
			@@ -1041,4 +1138,41 @@
			mallProductSellMapper.insert(mallProductSell);
			}

			public static List<Integer> findMissingNumbers(int[] nums) {
			//定义一个标记数组，标记出现过的下表为true
			boolean[] flag = new boolean[nums.length+1];
			for(int temp:nums){
			flag[temp] = true;
			}
			List<Integer> arr = new ArrayList<Integer>();
			//以连续的i作为本应该的下标，查找之前的标记数组，没有被标记过的下标，就是消失的数字
			for(int i = 1;i <= nums.length; i++){
			if(!flag[i]){
			arr.add(i);
			}
			}
			return arr;
			}

			public static List<Integer> findDisappearedNumbers(int[] nums) {
			Set<Integer> set = new HashSet<>(); // 利用Set对象元素不重复的特性
			// 把nums里的每一个数字都添加至set中
			for(int i = 0; i < nums.length; ++i) {
			set.add(nums[i]);
			}
			List<Integer> list = new ArrayList<>();
			// 把1~n的每一个数字都添加至set中，若添加成功则说明原数组不存在该数字，加入list即可
			for(int i = 1; i <= nums.length; ++i) {
			if(set.add(i)) {
			list.add(i);
			}
			}
			return list;
			}
			public static void main(String[] args) {
			int[] nums = {1, 2, 2, 5, 2};
			List<Integer> missingNumbers = findDisappearedNumbers(nums);
			System.out.println("缺失的数字为：" + missingNumbers);
			}

			}