|
@@ -491,44 +491,44 @@ public class AccountRunningWaterServiceImpl extends ServiceImpl<AccountRunningWa
|
|
|
* 余额操作
|
|
|
*/
|
|
|
private void changeRemainder(AccountRunningWater accountRunningWater) {
|
|
|
- // 修改账户余额表的余额
|
|
|
- AccountRemainder accountRemainder = accountRemainderService.getOne(q -> q
|
|
|
- .eq(AccountRemainder::getAccountManagementId, accountRunningWater.getAccountManagementId())
|
|
|
- .eq(AccountRemainder::getCurrency, accountRunningWater.getCurrency())
|
|
|
- );
|
|
|
- if (ObjectUtil.isEmpty(accountRemainder)) {
|
|
|
- throw new ServiceException("该账户不存在此币种,请前往资金账户添加");
|
|
|
- }
|
|
|
- BigDecimal amount = accountRunningWater.getAmount();
|
|
|
- String status = accountRunningWater.getStatus();
|
|
|
- BigDecimal remainder = accountRemainder.getRemainder();
|
|
|
-
|
|
|
- accountRemainder.setStatus(status);
|
|
|
- accountRemainder.setChangeRemainder(amount);
|
|
|
-
|
|
|
- boolean update = false;
|
|
|
- if ("10".equals(accountRunningWater.getStatus())) {
|
|
|
- //收入操作
|
|
|
- update = accountRemainderService.update(q -> q
|
|
|
- .setSql("remainder = remainder + " + accountRunningWater.getAmount())
|
|
|
- .setSql("change_remainder = " + accountRunningWater.getAmount())
|
|
|
- .eq(AccountRemainder::getId, accountRemainder.getId())
|
|
|
- );
|
|
|
- } else {
|
|
|
- //支出操作
|
|
|
- BigDecimal subtract = remainder.subtract(amount);
|
|
|
- if (subtract.compareTo(BigDecimal.ZERO) < 0) {
|
|
|
- throw new ServiceException("账户余额不足");
|
|
|
- }
|
|
|
-
|
|
|
- update = accountRemainderService.update(q -> q
|
|
|
- .setSql("remainder = remainder - " + accountRunningWater.getAmount())
|
|
|
- .setSql("change_remainder = " + accountRunningWater.getAmount())
|
|
|
- .eq(AccountRemainder::getId, accountRemainder.getId())
|
|
|
- .apply("remainder - {0} >= 0", accountRunningWater.getAmount())
|
|
|
- );
|
|
|
- }
|
|
|
- Assert.eqTrue(update, "余额操作失败,请重试!!!");
|
|
|
+// // 修改账户余额表的余额
|
|
|
+// AccountRemainder accountRemainder = accountRemainderService.getOne(q -> q
|
|
|
+// .eq(AccountRemainder::getAccountManagementId, accountRunningWater.getAccountManagementId())
|
|
|
+// .eq(AccountRemainder::getCurrency, accountRunningWater.getCurrency())
|
|
|
+// );
|
|
|
+// if (ObjectUtil.isEmpty(accountRemainder)) {
|
|
|
+// throw new ServiceException("该账户不存在此币种,请前往资金账户添加");
|
|
|
+// }
|
|
|
+// BigDecimal amount = accountRunningWater.getAmount();
|
|
|
+// String status = accountRunningWater.getStatus();
|
|
|
+// BigDecimal remainder = accountRemainder.getRemainder();
|
|
|
+//
|
|
|
+// accountRemainder.setStatus(status);
|
|
|
+// accountRemainder.setChangeRemainder(amount);
|
|
|
+//
|
|
|
+// boolean update = false;
|
|
|
+// if ("10".equals(accountRunningWater.getStatus())) {
|
|
|
+// //收入操作
|
|
|
+// update = accountRemainderService.update(q -> q
|
|
|
+// .setSql("remainder = remainder + " + accountRunningWater.getAmount())
|
|
|
+// .setSql("change_remainder = " + accountRunningWater.getAmount())
|
|
|
+// .eq(AccountRemainder::getId, accountRemainder.getId())
|
|
|
+// );
|
|
|
+// } else {
|
|
|
+// //支出操作
|
|
|
+// BigDecimal subtract = remainder.subtract(amount);
|
|
|
+// if (subtract.compareTo(BigDecimal.ZERO) < 0) {
|
|
|
+// throw new ServiceException("账户余额不足");
|
|
|
+// }
|
|
|
+//
|
|
|
+// update = accountRemainderService.update(q -> q
|
|
|
+// .setSql("remainder = remainder - " + accountRunningWater.getAmount())
|
|
|
+// .setSql("change_remainder = " + accountRunningWater.getAmount())
|
|
|
+// .eq(AccountRemainder::getId, accountRemainder.getId())
|
|
|
+// .apply("remainder - {0} >= 0", accountRunningWater.getAmount())
|
|
|
+// );
|
|
|
+// }
|
|
|
+// Assert.eqTrue(update, "余额操作失败,请重试!!!");
|
|
|
}
|
|
|
|
|
|
@Override
|