swh
/
one-health-mybasic
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

金额操作修改

pull/2/head
shaowenhao 2023-10-29 11:28:48 +08:00
parent f6b14edcd2
commit 9b942c105a
2 changed files with 13 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/com/ruoyi/mybasic/mapper/InvitationMapper.java
View File

@ -6,6 +6,7 @@ import com.ruoyi.mybasic.common.domain.Purse;
import com.ruoyi.mybasic.common.domain.request.InvitationRecordRequest;
import com.ruoyi.mybasic.common.domain.request.PurseRequest;
import com.ruoyi.mybasic.common.domain.request.RequestInvitationRecord;
import com.ruoyi.mybasic.common.domain.response.PurseResponse;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
@ -46,8 +47,8 @@ public interface InvitationMapper {
/**
* 修改钱包余额
* @param purse
* @param purseResponse
* @return
*/
int updateUserMoney(Purse purse);
int updateUserMoney(PurseResponse purseResponse);
}

23
src/main/java/com/ruoyi/mybasic/service/Impl/InvitationServiceImpl.java
View File

@ -31,8 +31,7 @@ public class InvitationServiceImpl implements InvitationService {
private InvitationMapper invitationMapper;
@Autowired
private PurseServiceTwo purseServiceTwo;
@Autowired
private RedisService redisService;
@ -107,27 +106,25 @@ public class InvitationServiceImpl implements InvitationService {
Integer status = userMoneyLogs.getStatus();
//查询钱包当前信息
PurseResponse purseResponse = purseServiceTwo.purseObject(Long.valueOf(userId));
Purse purse = new Purse();
purse.setUserId(userId);
purse.setUpdateTime(new Date());
PurseResponse purseResponse = purseServiceTwo.purseObject();
purseResponse.setUpdateTime(new Date());
if (status == 1){
//判断余额是否充足
if (purseResponse.getBalanceFee() < amountIncome){
throw new RuntimeException("钱包内余额不足!");
}
//支出操作
purse.setBalanceFee(purseResponse.getBalanceFee() - amountIncome);
purse.setWalletOutcome(purseResponse.getWalletOutcome() + amountIncome);
purse.setWalletIncome(purseResponse.getWalletIncome());
purseResponse.setBalanceFee(purseResponse.getBalanceFee() - amountIncome);
purseResponse.setWalletOutcome(purseResponse.getWalletOutcome() + amountIncome);
// purseResponse.setWalletIncome(purseResponse.getWalletIncome());
}else{
//收入操作
purse.setBalanceFee(purseResponse.getBalanceFee() + amountIncome);
purse.setWalletIncome(purseResponse.getWalletIncome() + amountIncome);
purse.setWalletOutcome(purseResponse.getWalletOutcome());
purseResponse.setBalanceFee(purseResponse.getBalanceFee() + amountIncome);
purseResponse.setWalletIncome(purseResponse.getWalletIncome() + amountIncome);
// purse.setWalletOutcome(purseResponse.getWalletOutcome());
}
//修改钱包余额
i = invitationMapper.updateUserMoney(purse);
i = invitationMapper.updateUserMoney(purseResponse);
if (i < 0){
throw new RuntimeException("钱包余额变更失败!");
}