1

zj

2025-08-18 67db7b820ee5bc318d2e7d5510b5ede981e57f3f

 src/main/java/com/nq/service/impl/UserBankServiceImpl.java

@@ -1,6 +1,9 @@
package com.nq.service.impl;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.nq.common.ServerResponse;

import com.nq.dao.UserBankMapper;
@@ -17,6 +20,7 @@
import com.nq.vo.user.UserBankInfoVO;

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

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
@@ -24,9 +28,10 @@
import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;

 @Service("iUserBankService")
 public class UserBankServiceImpl implements IUserBankService {
@Service("iUserBankService")
 public class UserBankServiceImpl extends ServiceImpl<UserBankMapper, UserBank> implements IUserBankService  {

   @Resource
   UserBankMapper userBankMapper;
@@ -34,100 +39,45 @@
   @Autowired
   IUserService iUserService;

   public UserBank findUserBankByUserId(Integer userId) { return this.userBankMapper.findUserBankByUserId(userId); }

   @Override
   public ServerResponse addBank(UserBank bank, HttpServletRequest request) {

     User user = this.iUserService.getCurrentUser(request);
     UserBank dbBank = this.userBankMapper.findUserBankByUserId(user.getId());
     if (dbBank != null) {
       return ServerResponse.createByErrorMsg("银行信息已经存在。不要再加一次",request );
     synchronized (user.getId()){
       List<UserBank> userBanks = this.userBankMapper.selectList(new LambdaQueryWrapper<UserBank>().eq(UserBank::getBankNo, bank.getBankNo()));
       if (CollectionUtils.isNotEmpty(userBanks)) {
         return ServerResponse.createByErrorMsg("银行信息已经存在。不要再加一次",request );
       }
       bank.setUserId(user.getId());
       int insertCount = this.userBankMapper.insert(bank);
       if (insertCount > 0) {
         return ServerResponse.createBySuccess("添加银行卡成功",request );
       }
       return ServerResponse.createByErrorMsg("添加银行卡失败",request );
     }
     UserBank userBank = new UserBank();

     userBank.setUserId(user.getId());

     userBank.setBankName(bank.getBankName());

     userBank.setBankNo(bank.getBankNo());

     userBank.setBankAddress(bank.getBankAddress());

     userBank.setBankImg(bank.getBankImg());

     userBank.setBankPhone(bank.getBankPhone());

     userBank.setAddTime(new Date());

     int insertCount = this.userBankMapper.insert(userBank);

     if (insertCount > 0) {
       return ServerResponse.createBySuccess("添加银行卡成功",request );

     }

     return ServerResponse.createByErrorMsg("添加银行卡失败",request );

   }

   public ServerResponse updateBank(UserBank bank, HttpServletRequest request) {

     User user = this.iUserService.getCurrentUser(request);

     UserBank dbBank = this.userBankMapper.findUserBankByUserId(user.getId());

     UserBank dbBank = this.userBankMapper.selectById(bank.getId());
     if (dbBank == null) {

       return ServerResponse.createByErrorMsg("修改失败。银行找不到",request );

     }

     dbBank.setBankName(bank.getBankName());

     dbBank.setBankNo(bank.getBankNo());

     dbBank.setBankAddress(bank.getBankAddress());

     dbBank.setBankImg(bank.getBankImg());

     dbBank.setBankPhone(bank.getBankPhone());

     int updateCount = this.userBankMapper.updateByPrimaryKeySelective(dbBank);

     int updateCount = this.userBankMapper.updateById(bank);
     if (updateCount > 0) {

       return ServerResponse.createBySuccess("修改银行卡成功",request );

     }

     return ServerResponse.createByErrorMsg("修改银行卡失败",request );
   }

   @Override
   public ServerResponse getBankInfo(HttpServletRequest request) {

     User user = this.iUserService.getCurrentUser(request);

     UserBank dbBank = this.userBankMapper.findUserBankByUserId(user.getId());

     if (dbBank == null) {

     List<UserBank> userBanks = this.userBankMapper.selectList(new LambdaQueryWrapper<UserBank>().eq(UserBank::getUserId,user.getId()));
     if (userBanks == null) {
       return ServerResponse.createByErrorMsg("没有添加银行信息",request );

     }

     UserBankInfoVO userBankInfoVO = new UserBankInfoVO();

     userBankInfoVO.setRealName(user.getRealName());

     userBankInfoVO.setBankName(dbBank.getBankName());

     userBankInfoVO.setBankImg(dbBank.getBankImg());

     userBankInfoVO.setBankAddress(dbBank.getBankAddress());

     userBankInfoVO.setBankNo(dbBank.getBankNo());

     return ServerResponse.createBySuccess(userBankInfoVO);
     return ServerResponse.createBySuccess(userBanks);

   }

@@ -149,6 +99,23 @@

   }

   public ServerResponse getBank(Integer userId) { return ServerResponse.createBySuccess(this.userBankMapper.findUserBankByUserId(userId)); }
   public ServerResponse getBank(Integer userId) { return ServerResponse.createBySuccess(this.userBankMapper.selectList(new LambdaQueryWrapper<UserBank>().eq(UserBank::getUserId,userId)));}

 }
   @Override
   public ServerResponse delete(String id, HttpServletRequest request) {
     User user = this.iUserService.getCurrentUser(request);
     UserBank userBank = userBankMapper.selectOne(new LambdaQueryWrapper<>(UserBank.class).eq(UserBank::getId,id).eq(UserBank::getUserId,user.getId()));
     if(ObjectUtils.isEmpty(userBank)){
       return ServerResponse.createByErrorMsg("删除失败，银行卡不存在",request);
     }
     userBankMapper.deleteById(userBank.getId());
     return ServerResponse.createBySuccessMsg("删除成功",request);
   }

  @Override
  public ServerResponse getById(String id, HttpServletRequest request) {
    UserBank userBank = userBankMapper.selectById(id);
    return ServerResponse.createBySuccess(userBank);
  }

}