fix

Helius

2022-03-25 f5421991e02d1f146e9628bb1aa1d859519e0230

 src/main/java/cc/mrbird/febs/dapp/service/impl/DappUserServiceImpl.java

@@ -1,6 +1,8 @@
package cc.mrbird.febs.dapp.service.impl;

import cc.mrbird.febs.common.entity.QueryRequest;
import cc.mrbird.febs.common.exception.FebsException;
import cc.mrbird.febs.common.utils.FebsUtil;
import cc.mrbird.febs.common.utils.Md5Util;
import cc.mrbird.febs.dapp.entity.DappMemberEntity;
import cc.mrbird.febs.dapp.entity.DappUserMemberRelateEntity;
@@ -12,11 +14,16 @@
import cc.mrbird.febs.system.entity.UserRole;
import cc.mrbird.febs.system.mapper.UserMapper;
import cc.mrbird.febs.system.mapper.UserRoleMapper;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.List;

/**
 * @author wzy
@@ -33,6 +40,13 @@
    private final UserRoleMapper userRoleMapper;

    @Override
    public IPage<User> findInPage(User user, QueryRequest request) {
        Page<User> page = new Page<>(request.getPageNum(), request.getPageSize());
        return userMapper.selectDappUserInPage(user, page);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void add(User user) {
        DappMemberEntity member = dappMemberDao.selectMemberInfoByInviteId(user.getInviteId());
        if(member == null) {
@@ -48,14 +62,24 @@
        userMapper.insert(user);

        UserRole userRole = new UserRole();
        userRole.setRoleId(Long.parseLong(user.getRoleId()));
        userRole.setRoleId(81L);
        userRole.setUserId(user.getUserId());
        userRoleMapper.insert(userRole);

        User currentUser = FebsUtil.getCurrentUser();
        DappUserMemberRelateEntity relate = new DappUserMemberRelateEntity();
        relate.setMemberId(member.getId());
        relate.setUserId(user.getUserId());
        relate.setInviteId(user.getInviteId());
        relate.setCreateUser(currentUser.getUserId());
        dappUserMemberRelateDao.insert(relate);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void delete(String ids) {
        List<String> idsList = StrUtil.split(ids, ',');
        userMapper.deleteBatchIds(idsList);
        dappUserMemberRelateDao.deleteByUserIds(idsList);
    }
}