package com.xcong.excoin.modules.coin.service.impl;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.RandomUtil;
|
import cn.hutool.core.util.StrUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.core.date.DateUtil;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.xcong.excoin.common.LoginUserUtils;
|
import com.xcong.excoin.common.enumerates.CoinTypeEnum;
|
import com.xcong.excoin.common.enumerates.MemberWalletCoinEnum;
|
import com.xcong.excoin.common.response.Result;
|
import com.xcong.excoin.modules.coin.dao.*;
|
import com.xcong.excoin.modules.coin.entity.*;
|
import com.xcong.excoin.modules.coin.parameter.dto.RecordsPageDto;
|
import com.xcong.excoin.modules.coin.parameter.dto.ZhiyaRewardRecordsPageDto;
|
import com.xcong.excoin.modules.coin.parameter.dto.ZhiyaRewardRecordsTypePageDto;
|
import com.xcong.excoin.modules.coin.parameter.vo.MemberGusdInfoVo;
|
import com.xcong.excoin.modules.coin.parameter.vo.UsdtToGusdVo;
|
import com.xcong.excoin.modules.coin.parameter.vo.ZhiyaInfoVo;
|
import com.xcong.excoin.modules.coin.parameter.vo.ZhiyaRewardVo;
|
import com.xcong.excoin.modules.coin.service.ZhiyaService;
|
import com.xcong.excoin.modules.member.dao.MemberDao;
|
import com.xcong.excoin.modules.member.dao.MemberWalletCoinDao;
|
import com.xcong.excoin.modules.member.entity.MemberEntity;
|
import com.xcong.excoin.modules.member.entity.MemberWalletCoinEntity;
|
import com.xcong.excoin.utils.MessageSourceUtils;
|
import com.xcong.excoin.utils.RedisUtils;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
@Service
|
public class ZhiyaServiceImpl extends ServiceImpl<ZhiYaDao, ZhiYaEntity> implements ZhiyaService {
|
|
@Resource
|
MemberWalletCoinDao memberWalletCoinDao;
|
@Resource
|
MemberAccountMoneyChangeDao memberAccountMoneyChangeDao;
|
@Resource
|
ZhiYaRecordDao zhiYaRecordDao;
|
@Resource
|
ZhiyaRewardDao zhiyaRewardDao;
|
@Resource
|
ZhiYaDao zhiYaDao;
|
@Resource
|
ZhiyaTeamDao zhiyaTeamDao;
|
@Resource
|
MemberDao memberdao;
|
@Resource
|
RedisUtils redisUtils;
|
@Override
|
@Transactional
|
public Result usdtToGusd(BigDecimal balance, Integer type) {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
if (balance.compareTo(BigDecimal.ZERO) <= 0) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0004"));
|
}
|
if(1 == type){
|
// 扣币
|
String walletCode = MemberWalletCoinEnum.WALLETCOINCODE.getValue();
|
MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, walletCode);
|
BigDecimal availableBalance = memberWalletCoinEntity.getAvailableBalance();
|
BigDecimal totalBalance = memberWalletCoinEntity.getTotalBalance();
|
|
BigDecimal available = availableBalance.subtract(balance);
|
if (available.compareTo(BigDecimal.ZERO) < 0) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0005"));
|
}
|
BigDecimal total = totalBalance.subtract(balance);
|
if (total.compareTo(BigDecimal.ZERO) < 0) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0005"));
|
}
|
|
memberWalletCoinEntity.setAvailableBalance(available);
|
memberWalletCoinEntity.setTotalBalance(total);
|
int i = memberWalletCoinDao.updateById(memberWalletCoinEntity);
|
if (i < 1) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0096"));
|
}
|
//添加资金划转历史记录
|
MemberAccountMoneyChange memberAccountRecord = new MemberAccountMoneyChange();
|
//获取usdt兑换gusd的兑换比例
|
BigDecimal usdtToGusd = new BigDecimal(redisUtils.getString("USDTTOGSD"));
|
BigDecimal gusdBalance = balance.multiply(usdtToGusd);
|
|
ZhiYaEntity zhiya = zhiYaDao.selectByMemberId(memberId);
|
BigDecimal gusdAvailableBalance = zhiya.getAvailableBalance();
|
BigDecimal gusdTotalBalance = zhiya.getTotalBalance();
|
zhiya.setAvailableBalance(gusdAvailableBalance.add(gusdBalance));
|
zhiya.setTotalBalance(gusdTotalBalance.add(gusdBalance));
|
|
int updateById = zhiYaDao.updateById(zhiya);
|
if (updateById < 1) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0096"));
|
}
|
|
//添加资金划转历史记录
|
memberAccountRecord.setMemberId(memberId);
|
memberAccountRecord.setStatus(MemberAccountMoneyChange.STATUS_SUCCESS_INTEGER);
|
memberAccountRecord.setSymbol(walletCode);
|
memberAccountRecord.setContent(MemberWalletCoinEnum.ZHIYATOGUSD.getValue());
|
memberAccountRecord.setType(MemberAccountMoneyChange.TYPE_WALLET_COIN);
|
memberAccountRecord.setAmount(gusdBalance);
|
memberAccountMoneyChangeDao.insert(memberAccountRecord);
|
}else if(2 == type){
|
// 扣币
|
ZhiYaEntity zhiya = zhiYaDao.selectByMemberId(memberId);
|
BigDecimal availableBalance = zhiya.getAvailableBalance();
|
BigDecimal totalBalance = zhiya.getTotalBalance();
|
|
BigDecimal available = availableBalance.subtract(balance);
|
if (available.compareTo(BigDecimal.ZERO) < 0) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0005"));
|
}
|
BigDecimal total = totalBalance.subtract(balance);
|
if (total.compareTo(BigDecimal.ZERO) < 0) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0005"));
|
}
|
|
zhiya.setAvailableBalance(available);
|
zhiya.setTotalBalance(total);
|
int i = zhiYaDao.updateById(zhiya);
|
if (i < 1) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0096"));
|
}
|
//添加资金划转历史记录
|
MemberAccountMoneyChange memberAccountRecord = new MemberAccountMoneyChange();
|
//获取usdt兑换gusd的兑换比例
|
BigDecimal usdtToGusd = new BigDecimal(redisUtils.getString("USDTTOGSD"));
|
BigDecimal usdtBalance = balance.divide(usdtToGusd);
|
|
String walletCode = MemberWalletCoinEnum.WALLETCOINCODE.getValue();
|
MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberId, walletCode);
|
|
BigDecimal gusdAvailableBalance = memberWalletCoinEntity.getAvailableBalance();
|
BigDecimal gusdTotalBalance = memberWalletCoinEntity.getTotalBalance();
|
memberWalletCoinEntity.setAvailableBalance(gusdAvailableBalance.add(usdtBalance));
|
memberWalletCoinEntity.setTotalBalance(gusdTotalBalance.add(usdtBalance));
|
|
int updateById = memberWalletCoinDao.updateById(memberWalletCoinEntity);
|
if (updateById < 1) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0096"));
|
}
|
|
//添加资金划转历史记录
|
memberAccountRecord.setMemberId(memberId);
|
memberAccountRecord.setStatus(MemberAccountMoneyChange.STATUS_SUCCESS_INTEGER);
|
memberAccountRecord.setSymbol(walletCode);
|
memberAccountRecord.setContent(MemberWalletCoinEnum.ZHIYATOUSDT.getValue());
|
memberAccountRecord.setType(MemberAccountMoneyChange.TYPE_WALLET_COIN);
|
memberAccountRecord.setAmount(usdtBalance);
|
memberAccountMoneyChangeDao.insert(memberAccountRecord);
|
|
}else{
|
return Result.fail("member_controller_0005");
|
}
|
|
return Result.ok(MessageSourceUtils.getString("member_service_0024"));
|
}
|
|
@Override
|
@Transactional
|
public Result zhiYaGusd(BigDecimal balance) {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
if (balance.compareTo(new BigDecimal(100)) < 0) {
|
return Result.fail(MessageSourceUtils.getString("zhiya_service_0006"));
|
}
|
|
//质押Gusd，质押数量进入冻结余额，
|
ZhiYaEntity zhiya = zhiYaDao.selectByMemberId(memberId);
|
BigDecimal gusdAvailableBalance = zhiya.getAvailableBalance();
|
BigDecimal gusdTotalBalance = zhiya.getTotalBalance();
|
BigDecimal gusdfrozenBalance = zhiya.getFrozenBalance();
|
|
BigDecimal available = gusdAvailableBalance.subtract(balance);
|
if (available.compareTo(BigDecimal.ZERO) < 0) {
|
return Result.fail(MessageSourceUtils.getString("zhiya_service_0005"));
|
}
|
BigDecimal total = gusdTotalBalance.subtract(balance);
|
if (total.compareTo(BigDecimal.ZERO) < 0) {
|
return Result.fail(MessageSourceUtils.getString("zhiya_service_0005"));
|
}
|
zhiya.setFrozenBalance(gusdfrozenBalance.add(balance));
|
zhiya.setAvailableBalance(gusdAvailableBalance.subtract(balance));
|
|
int updateById = zhiYaDao.updateById(zhiya);
|
if (updateById < 1) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0096"));
|
}
|
//产生质押单，当前有的话，累加质押数量
|
// ZhiYaRecordEntity zhiYaRecord = zhiYaRecordDao.selectByMemberIdAndOrderStatus(memberId,1);
|
// if(ObjectUtil.isEmpty(zhiYaRecord)){
|
//产生一条质押记录
|
ZhiYaRecordEntity zhiYaRecordEntity = new ZhiYaRecordEntity();
|
zhiYaRecordEntity.setMemberId(memberId);
|
zhiYaRecordEntity.setOrderNo(generateSimpleSerialno(memberId.toString()));
|
zhiYaRecordEntity.setSymbol(MemberWalletCoinEnum.WALLETGUSDCOINCODE.getValue());
|
zhiYaRecordEntity.setZhiyaCnt(balance);
|
zhiYaRecordEntity.setOrderStatus(1);
|
Date date = new Date();
|
Date newDate = DateUtil.offsetDay(date, 1);
|
zhiYaRecordEntity.setEffectDate(newDate);
|
zhiYaRecordDao.insert(zhiYaRecordEntity);
|
// }else{
|
// zhiYaRecord.setZhiyaCnt(zhiYaRecord.getZhiyaCnt().add(balance));
|
// Date date = new Date();
|
// Date newDate = DateUtil.offsetDay(date, 1);
|
// zhiYaRecord.setEffectDate(newDate);
|
// zhiYaRecordDao.updateById(zhiYaRecord);
|
// }
|
//更新团队算力表
|
MemberEntity memberEntity = memberdao.selectById(memberId);
|
String refererIds = memberEntity.getRefererIds();
|
if(StrUtil.isNotEmpty(refererIds)){
|
BigDecimal gricetoagent = new BigDecimal(redisUtils.getString("GRICETOAGENT"));
|
String[] split = refererIds.split(",");
|
List<String> strings = Arrays.asList(split);
|
if(CollUtil.isNotEmpty(Arrays.asList(split))){
|
for(String str : strings){
|
if(StrUtil.isNotEmpty(str)){
|
BigDecimal isAgent = BigDecimal.ZERO;
|
MemberEntity memberShangJi = memberdao.selectMemberInfoByInviteId(str);
|
ZhiYaTeam zhiyaTeamByMemberId = zhiYaRecordDao.selectZhiyaTeamRecordByMemberId(memberShangJi.getId());
|
if(ObjectUtil.isNotEmpty(zhiyaTeamByMemberId)){
|
//更新数据
|
zhiyaTeamByMemberId.setZhiyaCnt(zhiyaTeamByMemberId.getZhiyaCnt().add(balance));
|
if(isAgent.compareTo(gricetoagent) >= 0){
|
zhiyaTeamByMemberId.setIsAgent(1);
|
}
|
zhiyaTeamDao.updateById(zhiyaTeamByMemberId);
|
}else{
|
//新增数据
|
ZhiYaTeam zhiYaTeam = new ZhiYaTeam();
|
zhiYaTeam.setRefererId(memberShangJi.getRefererId());
|
zhiYaTeam.setRefererIds(memberShangJi.getRefererIds());
|
zhiYaTeam.setMemberId(memberShangJi.getId());
|
if(ObjectUtil.isNotEmpty(zhiyaTeamByMemberId)){
|
zhiYaTeam.setZhiyaCnt(zhiyaTeamByMemberId.getZhiyaCnt().add(balance));
|
isAgent = zhiyaTeamByMemberId.getZhiyaCnt().add(balance);
|
}else{
|
zhiYaTeam.setZhiyaCnt(balance);
|
isAgent = balance;
|
}
|
if(isAgent.compareTo(gricetoagent) >= 0){
|
zhiYaTeam.setIsAgent(1);
|
}
|
zhiyaTeamDao.insert(zhiYaTeam);
|
}
|
}
|
}
|
}
|
}
|
|
return Result.ok(MessageSourceUtils.getString("member_service_0024"));
|
}
|
|
@Override
|
@Transactional
|
public Result shuhuiGusd(BigDecimal balance,Long id) {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
if (balance.compareTo(BigDecimal.ZERO) <= 0) {
|
return Result.fail(MessageSourceUtils.getString("zhiya_service_0004"));
|
}
|
//赎回Gusd，获取质押单据，
|
ZhiYaRecordEntity zhiYaRecordEntity = zhiYaRecordDao.selectByIdAndMemberId(id,memberId);
|
if(ObjectUtil.isEmpty(zhiYaRecordEntity)){
|
return Result.fail(MessageSourceUtils.getString("zhiya_service_0002"));
|
}
|
if(1 != zhiYaRecordEntity.getOrderStatus()){
|
return Result.fail(MessageSourceUtils.getString("zhiya_service_0003"));
|
}
|
BigDecimal zhiyaCnt = zhiYaRecordEntity.getZhiyaCnt();
|
if(balance.compareTo(zhiyaCnt) > 0){
|
return Result.fail(MessageSourceUtils.getString("zhiya_service_0004"));
|
}
|
// zhiYaRecordEntity.setZhiyaCnt(zhiyaCnt.subtract(balance));
|
if(zhiyaCnt.compareTo(balance) != 0){
|
return Result.fail(MessageSourceUtils.getString("zhiya_service_0001"));
|
}
|
zhiYaRecordEntity.setOrderStatus(2);
|
zhiYaRecordDao.updateById(zhiYaRecordEntity);
|
//赎回Gusd，质押数量进入可用余额，
|
ZhiYaEntity zhiya = zhiYaDao.selectByMemberId(memberId);
|
BigDecimal gusdAvailableBalance = zhiya.getAvailableBalance();
|
BigDecimal gusdTotalBalance = zhiya.getTotalBalance();
|
BigDecimal gusdfrozenBalance = zhiya.getFrozenBalance();
|
|
BigDecimal frozen = gusdfrozenBalance.subtract(balance);
|
if (frozen.compareTo(BigDecimal.ZERO) < 0) {
|
return Result.fail(MessageSourceUtils.getString("zhiya_service_0001"));
|
}
|
BigDecimal total = gusdTotalBalance.subtract(balance);
|
if (total.compareTo(BigDecimal.ZERO) < 0) {
|
return Result.fail(MessageSourceUtils.getString("member_service_0005"));
|
}
|
zhiya.setFrozenBalance(gusdfrozenBalance.subtract(balance));
|
zhiya.setAvailableBalance(gusdAvailableBalance.add(balance));
|
zhiYaDao.updateById(zhiya);
|
//更新团队算力表
|
MemberEntity memberEntity = memberdao.selectById(memberId);
|
String refererIds = memberEntity.getRefererIds();
|
if(StrUtil.isNotEmpty(refererIds)){
|
BigDecimal gricetoagent = new BigDecimal(redisUtils.getString("GRICETOAGENT"));
|
String[] split = refererIds.split(",");
|
List<String> strings = Arrays.asList(split);
|
if(CollUtil.isNotEmpty(Arrays.asList(split))){
|
for(String str : strings){
|
if(StrUtil.isNotEmpty(str)){
|
BigDecimal isAgent = BigDecimal.ZERO;
|
MemberEntity memberShangJi = memberdao.selectMemberInfoByInviteId(str);
|
ZhiYaTeam zhiyaTeamByMemberId = zhiYaRecordDao.selectZhiyaTeamRecordByMemberId(memberShangJi.getId());
|
if(ObjectUtil.isNotEmpty(zhiyaTeamByMemberId)){
|
//更新数据
|
zhiyaTeamByMemberId.setZhiyaCnt(zhiyaTeamByMemberId.getZhiyaCnt().subtract(balance));
|
isAgent = zhiyaTeamByMemberId.getZhiyaCnt().subtract(balance);
|
if(isAgent.compareTo(gricetoagent) >= 0){
|
zhiyaTeamByMemberId.setIsAgent(1);
|
}
|
zhiyaTeamDao.updateById(zhiyaTeamByMemberId);
|
}else{
|
//新增数据
|
ZhiYaTeam zhiYaTeam = new ZhiYaTeam();
|
zhiYaTeam.setRefererId(memberShangJi.getRefererId());
|
zhiYaTeam.setRefererIds(memberShangJi.getRefererIds());
|
zhiYaTeam.setMemberId(memberShangJi.getId());
|
if(ObjectUtil.isNotEmpty(zhiyaTeamByMemberId)){
|
zhiYaTeam.setZhiyaCnt(zhiyaTeamByMemberId.getZhiyaCnt().subtract(balance));
|
isAgent = zhiyaTeamByMemberId.getZhiyaCnt().subtract(balance);
|
}else{
|
zhiYaTeam.setZhiyaCnt(balance);
|
isAgent = balance;
|
}
|
if(isAgent.compareTo(gricetoagent) >= 0){
|
zhiYaTeam.setIsAgent(1);
|
}
|
zhiyaTeamDao.insert(zhiYaTeam);
|
}
|
}
|
}
|
}
|
}
|
return Result.ok(MessageSourceUtils.getString("member_service_0024"));
|
}
|
|
@Override
|
public Result findMemberGusdInfo() {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
ZhiYaEntity zhiYaEntity = zhiYaDao.selectByMemberId(memberId);
|
MemberGusdInfoVo memberGusdInfoVo = new MemberGusdInfoVo();
|
memberGusdInfoVo.setMemberId(memberId);
|
memberGusdInfoVo.setFrozenBalance(zhiYaEntity.getFrozenBalance());
|
memberGusdInfoVo.setTotalBalance(zhiYaEntity.getTotalBalance());
|
memberGusdInfoVo.setAvailableBalance(zhiYaEntity.getAvailableBalance());
|
return Result.ok(memberGusdInfoVo);
|
}
|
|
@Override
|
public Result getZhiyaRecords(RecordsPageDto recordsPageDto) {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
|
Page<ZhiyaInfoVo> page = new Page<>(recordsPageDto.getPageNum(), recordsPageDto.getPageSize());
|
ZhiYaEntity zhiya = new ZhiYaEntity();
|
zhiya.setMemberId(memberId);
|
IPage<ZhiyaInfoVo> lists = zhiYaRecordDao.selectByMemberIdInPage(page, zhiya);
|
return Result.ok(lists);
|
}
|
|
@Override
|
public Result getusdtToGusdRecords(RecordsPageDto recordsPageDto) {
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
|
Page<UsdtToGusdVo> page = new Page<>(recordsPageDto.getPageNum(), recordsPageDto.getPageSize());
|
MemberAccountMoneyChange memberAccountMoneyChange = new MemberAccountMoneyChange();
|
memberAccountMoneyChange.setMemberId(memberId);
|
IPage<UsdtToGusdVo> lists = memberAccountMoneyChangeDao.selectByMemberIdInPage(page, memberAccountMoneyChange);
|
return Result.ok(lists);
|
}
|
|
@Override
|
@Transactional
|
public void grantZhiyaAmount() {
|
//获取GUSD质押比例
|
BigDecimal gusdReward = new BigDecimal(redisUtils.getString("GUSDREWARD"));
|
BigDecimal fixedGusdReward = gusdReward.multiply(new BigDecimal(0.8));
|
if(fixedGusdReward.compareTo(BigDecimal.ZERO) > 0){
|
//获取今天之前满足发放奖励的全部质押单
|
//生效时间小于当前时间
|
//状态为生效中
|
List<ZhiYaRecordEntity> lists = zhiYaRecordDao.selectZhiYaRewardByStatueAndTime(1,new Date());
|
if(CollUtil.isNotEmpty(lists)){
|
for(ZhiYaRecordEntity zhiYaRecordEntity : lists){
|
ZhiyaRewardEntity zhiyaRewardEntity = new ZhiyaRewardEntity();
|
//查询今天有没有发送过了
|
String orderNo = zhiYaRecordEntity.getOrderNo();
|
Long memberId = zhiYaRecordEntity.getMemberId();
|
Date date = new Date();
|
List<ZhiyaRewardEntity> zhiyaRewardEntityDone = zhiYaRecordDao.selectZhiyaTeamRecordByMemberIdAndOrderNo(orderNo,memberId,date);
|
if(ObjectUtil.isEmpty(zhiyaRewardEntityDone)){
|
zhiyaRewardEntity.setRecordId(zhiYaRecordEntity.getId());
|
zhiyaRewardEntity.setRecordNo(zhiYaRecordEntity.getOrderNo());
|
zhiyaRewardEntity.setMemberId(zhiYaRecordEntity.getMemberId());
|
zhiyaRewardEntity.setType(1);
|
MemberEntity member = memberdao.selectById(zhiYaRecordEntity.getMemberId());
|
//获取当前人的上两级
|
BigDecimal multiplyReward = BigDecimal.ZERO;
|
MemberEntity memberEntity = memberdao.selectMemberInfoByInviteId(member.getRefererId());
|
if(ObjectUtil.isNotEmpty(memberEntity)){
|
//以及1代理的比例
|
BigDecimal agetShangji = new BigDecimal(redisUtils.getString("GUSDREWARDAGENTONE"));
|
BigDecimal multiply = zhiYaRecordEntity.getZhiyaCnt().multiply(gusdReward).multiply(agetShangji);
|
multiplyReward = (zhiYaRecordEntity.getZhiyaCnt().multiply(gusdReward).subtract(multiply));
|
ZhiyaRewardEntity zhiyaRewardEntitySJ = new ZhiyaRewardEntity();
|
zhiyaRewardEntitySJ.setRecordId(zhiYaRecordEntity.getId());
|
zhiyaRewardEntitySJ.setRecordNo(zhiYaRecordEntity.getOrderNo());
|
zhiyaRewardEntitySJ.setMemberId(memberEntity.getId());
|
zhiyaRewardEntitySJ.setType(2);
|
zhiyaRewardEntitySJ.setRewardAmout(multiply);
|
zhiyaRewardDao.insert(zhiyaRewardEntitySJ);
|
|
MemberWalletCoinEntity memberWalletCoinEntity = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberEntity.getId(), CoinTypeEnum.GRICE.toString());
|
memberWalletCoinEntity.setAvailableBalance(memberWalletCoinEntity.getAvailableBalance().add(multiply));
|
memberWalletCoinEntity.setTotalBalance(memberWalletCoinEntity.getAvailableBalance().add(multiply));
|
memberWalletCoinDao.updateById(memberWalletCoinEntity);
|
|
MemberEntity memberEntitySSJ = memberdao.selectMemberInfoByInviteId(memberEntity.getRefererId());
|
if(ObjectUtil.isNotEmpty(memberEntitySSJ)){
|
BigDecimal agetSSJ = new BigDecimal(redisUtils.getString("GUSDREWARDAGENTTWO"));
|
BigDecimal multiplySSJ = zhiYaRecordEntity.getZhiyaCnt().multiply(gusdReward).multiply(agetSSJ);
|
multiplyReward = (zhiYaRecordEntity.getZhiyaCnt().multiply(gusdReward).subtract(multiply).subtract(multiplySSJ));
|
|
MemberWalletCoinEntity memberWalletCoinEntitySSJ = memberWalletCoinDao.selectWalletCoinBymIdAndCode(memberEntity.getId(), CoinTypeEnum.GRICE.toString());
|
memberWalletCoinEntitySSJ.setAvailableBalance(memberWalletCoinEntitySSJ.getAvailableBalance().add(multiply));
|
memberWalletCoinEntitySSJ.setTotalBalance(memberWalletCoinEntitySSJ.getAvailableBalance().add(multiply));
|
memberWalletCoinDao.updateById(memberWalletCoinEntitySSJ);
|
|
ZhiyaRewardEntity zhiyaRewardEntitySSJ = new ZhiyaRewardEntity();
|
zhiyaRewardEntitySSJ.setRecordId(zhiYaRecordEntity.getId());
|
zhiyaRewardEntitySSJ.setRecordNo(zhiYaRecordEntity.getOrderNo());
|
zhiyaRewardEntitySSJ.setMemberId(memberEntitySSJ.getId());
|
zhiyaRewardEntitySSJ.setType(2);
|
zhiyaRewardEntitySSJ.setRewardAmout(multiplySSJ);
|
zhiyaRewardDao.insert(zhiyaRewardEntitySSJ);
|
}
|
}else{
|
multiplyReward = (zhiYaRecordEntity.getZhiyaCnt().multiply(gusdReward));
|
}
|
zhiyaRewardEntity.setRewardAmout(multiplyReward);
|
zhiyaRewardDao.insert(zhiyaRewardEntity);
|
|
String refererIds = member.getRefererIds();
|
if(StrUtil.isNotEmpty(refererIds)){
|
String[] split = refererIds.split(",");
|
List<String> strings = Arrays.asList(split);
|
if(CollUtil.isNotEmpty(strings)){
|
for(String str : strings){
|
if(StrUtil.isNotEmpty(str)){
|
MemberEntity memberShangJi = memberdao.selectMemberInfoByInviteId(str);
|
ZhiYaTeam zhiyaTeamByMemberId = zhiYaRecordDao.selectZhiyaTeamRecordByMemberId(memberShangJi.getId());
|
if(ObjectUtil.isNotEmpty(zhiyaTeamByMemberId)){
|
//更新数据
|
zhiyaTeamByMemberId.setRewardCnt(
|
(zhiyaTeamByMemberId.getRewardCnt() == null ? BigDecimal.ZERO:zhiyaTeamByMemberId.getRewardCnt()).add(multiplyReward));
|
zhiyaTeamDao.updateById(zhiyaTeamByMemberId);
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
|
@Override
|
public Result getZhiyaReward(ZhiyaRewardRecordsPageDto recordsPageDto) {
|
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
|
Page<ZhiyaRewardVo> page = new Page<>(recordsPageDto.getPageNum(), recordsPageDto.getPageSize());
|
ZhiyaRewardEntity zhiyaRewardEntity = new ZhiyaRewardEntity();
|
zhiyaRewardEntity.setMemberId(memberId);
|
zhiyaRewardEntity.setRecordNo(recordsPageDto.getOrderNo());
|
IPage<ZhiyaRewardVo> lists = zhiYaRecordDao.selectZhiyaRewardByMemberIdInPage(page, zhiyaRewardEntity);
|
return Result.ok(lists);
|
}
|
|
@Override
|
public Result getZhiyaRewardTypeTo(ZhiyaRewardRecordsTypePageDto recordsPageDto) {
|
|
//获取用户ID
|
Long memberId = LoginUserUtils.getAppLoginUser().getId();
|
|
Page<ZhiyaRewardVo> page = new Page<>(recordsPageDto.getPageNum(), recordsPageDto.getPageSize());
|
ZhiyaRewardEntity zhiyaRewardEntity = new ZhiyaRewardEntity();
|
zhiyaRewardEntity.setMemberId(memberId);
|
IPage<ZhiyaRewardVo> lists = zhiYaRecordDao.selectZhiyaRewardTypeToByMemberIdInPage(page, zhiyaRewardEntity);
|
return Result.ok(lists);
|
}
|
|
public String generateSimpleSerialno(String userId) {
|
StringBuilder sb = new StringBuilder();
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
SimpleDateFormat sd = new SimpleDateFormat("yyyyMMdd");
|
Date now = new Date();
|
sb.append(sd.format(now));
|
Calendar calendar = new GregorianCalendar();
|
calendar.setTime(now);
|
calendar.add(calendar.DATE, 1);
|
Date nextDate = calendar.getTime();
|
if (StrUtil.isNotEmpty(userId)) {
|
sb.append(userId);
|
}
|
sb.append(RandomUtil.randomInt(2));
|
long count = zhiYaRecordDao.getOrderCountByToday(sdf.format(now), sdf.format(nextDate));
|
count++;
|
int size = 4;
|
for (int i = 0; i < size - String.valueOf(count).length(); i++) {
|
sb.append("0");
|
}
|
sb.append(count);
|
return sb.toString();
|
}
|
}
|
