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; import com.nq.pojo.User; import com.nq.pojo.UserBank; import com.nq.service.IUserBankService; import com.nq.service.IUserService; import com.nq.vo.user.UserBankInfoVO; import java.util.Date; import java.util.List; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.util.ObjectUtils; @Service("iUserBankService") public class UserBankServiceImpl extends ServiceImpl implements IUserBankService { @Resource UserBankMapper userBankMapper; @Autowired IUserService iUserService; @Override public ServerResponse addBank(UserBank bank, HttpServletRequest request) { User user = this.iUserService.getCurrentUser(request); synchronized (user.getId()){ List userBanks = this.userBankMapper.selectList(new LambdaQueryWrapper().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 ); } } public ServerResponse updateBank(UserBank bank, HttpServletRequest request) { UserBank dbBank = this.userBankMapper.selectById(bank.getId()); if (dbBank == null) { return ServerResponse.createByErrorMsg("修改失败。银行找不到",request ); } 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); List userBanks = this.userBankMapper.selectList(new LambdaQueryWrapper().eq(UserBank::getUserId,user.getId())); if (userBanks == null) { return ServerResponse.createByErrorMsg("没有添加银行信息",request ); } return ServerResponse.createBySuccess(userBanks); } public ServerResponse updateBankByAdmin(UserBank userBank) { System.out.println(userBank.getId()); if (userBank.getId() == null) { return ServerResponse.createByErrorMsg("更改id必选"); } int updateCount = this.userBankMapper.updateByPrimaryKeySelective(userBank); if (updateCount > 0) { return ServerResponse.createBySuccessMsg("修改成功"); } return ServerResponse.createByErrorMsg("修改失败"); } public ServerResponse getBank(Integer userId) { return ServerResponse.createBySuccess(this.userBankMapper.selectList(new LambdaQueryWrapper().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); } }