From 716f77637e6e324fd5865e82039c2c2ee3f94bfa Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Wed, 14 Jan 2026 15:53:06 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/service/impl/UserBankServiceImpl.java | 148 +++++++++++++++++-------------------------------
1 files changed, 53 insertions(+), 95 deletions(-)
diff --git a/src/main/java/com/nq/service/impl/UserBankServiceImpl.java b/src/main/java/com/nq/service/impl/UserBankServiceImpl.java
index 898ad78..c82a3f6 100644
--- a/src/main/java/com/nq/service/impl/UserBankServiceImpl.java
+++ b/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;
@@ -14,147 +17,102 @@
import com.nq.service.IUserService;
-import com.nq.vo.user.UserBankInfoVO;
+import java.util.List;
-import java.util.Date;
-
+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 implements IUserBankService {
+@Service("iUserBankService")
+ public class UserBankServiceImpl extends ServiceImpl<UserBankMapper, UserBank> implements IUserBankService {
- @Autowired
+ @Resource
UserBankMapper userBankMapper;
@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);
- if (user == null ){
- return ServerResponse.createBySuccessMsg("Please log in first");
+ 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 dbBank = this.userBankMapper.findUserBankByUserId(user.getId());
-
- if (dbBank != null) {
-
- return ServerResponse.createByErrorMsg("The bank information already exists. Do not add it again");
-
- }
- 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("Add bank card successfully");
-
- }
-
- return ServerResponse.createByErrorMsg("Failed to add bank card");
-
}
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("The modification failed. The bank could not be found");
-
+ 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.updateByPrimaryKeySelective(bank);
if (updateCount > 0) {
-
- return ServerResponse.createBySuccess("Modified bank card successfully");
-
+ return ServerResponse.createBySuccess("修改银行卡成功",request );
}
-
- return ServerResponse.createByErrorMsg("Failed to modify bank card");
+ 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) {
-
- return ServerResponse.createByErrorMsg("No bank information was added");
-
+ 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);
}
public ServerResponse updateBankByAdmin(UserBank userBank) {
System.out.println(userBank.getId());
if (userBank.getId() == null) {
- return ServerResponse.createByErrorMsg("Change id Mandatory");
+ return ServerResponse.createByErrorMsg("更改id必选");
}
int updateCount = this.userBankMapper.updateByPrimaryKeySelective(userBank);
if (updateCount > 0) {
- return ServerResponse.createBySuccessMsg("Modified successfully");
+ return ServerResponse.createBySuccessMsg("修改成功");
}
- return ServerResponse.createByErrorMsg("Modification failure");
+ return ServerResponse.createByErrorMsg("修改失败");
}
- 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);
+ }
+
+}
--
Gitblit v1.9.3