|
|
@@ -122,16 +122,7 @@ public class CompanyRechargeController extends BaseController
|
|
|
LoginUser loginUser = tokenService.getLoginUser(ServletUtils.getRequest());
|
|
|
if(companyRecharge.getIsAudit()==1){
|
|
|
Company company=companyService.selectCompanyById(companyRecharge.getCompanyId());
|
|
|
-
|
|
|
- // 同步redis缓存
|
|
|
- // 注意:在进行充值审核之前,需要先执行一下定时任务同步缓存数据到数据库,再进行后续操作,否则金额不正确
|
|
|
- R r = companyRechargeService.syncUpdateRedisCompanyRecharge(company, companyRecharge.getMoney(), 1);
|
|
|
- if(!"200".equals(r.get("code").toString())){
|
|
|
- return r;
|
|
|
- }
|
|
|
- // 充值后,需要同步更新余额到数据库,否则余额与缓存中的不一致
|
|
|
- String newMoney = r.get("newMoney").toString();
|
|
|
- company.setMoney(new BigDecimal(newMoney));
|
|
|
+ company.setMoney(company.getMoney().add(companyRecharge.getMoney()));
|
|
|
companyService.updateCompany(company);
|
|
|
CompanyMoneyLogs log=new CompanyMoneyLogs();
|
|
|
log.setCompanyId(companyRecharge.getCompanyId());
|