| | |
|---|
| | | // asyncCjService.calculateAchieve(dappAchieve); |
|---|
| | | return new FebsResponse().success(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public FebsResponse zhiyaAddNew() { |
|---|
| | | List<DappFundFlowEntity> dappFundFlowEntities = dappFundFlowDao.selectList( |
|---|
| | | new QueryWrapper<DappFundFlowEntity>() |
|---|
| | | .ge("id", 7599L) |
|---|
| | | .lt("id", 7688L)); |
|---|
| | | |
|---|
| | | if(CollUtil.isNotEmpty(dappFundFlowEntities)){ |
|---|
| | | for(DappFundFlowEntity dappFundFlowEntity : dappFundFlowEntities){ |
|---|
| | | Integer type = dappFundFlowEntity.getType(); |
|---|
| | | if(FlowTypeEnum.HUA_DIAN_GEREN.getValue() == type || FlowTypeEnum.HUA_DIAN_TUANDUI_USDT.getValue() == type){ |
|---|
| | | Long memberId = dappFundFlowEntity.getMemberId(); |
|---|
| | | BigDecimal amount = dappFundFlowEntity.getAmount(); |
|---|
| | | DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId); |
|---|
| | | BigDecimal usdtBalance = dappMemberEntity.getUsdtBalance(); |
|---|
| | | dappMemberEntity.setUsdtBalance(usdtBalance.subtract(amount)); |
|---|
| | | dappMemberDao.updateUsdtBalanceWithVersion(dappMemberEntity); |
|---|
| | | log.info("流水处理中。。。。。。"+dappFundFlowEntity.getId()+",处理金额"+amount+",账户余额："+usdtBalance+",操作后余额："+dappMemberEntity.getUsdtBalance()); |
|---|
| | | dappFundFlowDao.deleteById(dappFundFlowEntity.getId()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return null; |
|---|
| | | } |
|---|
| | | } |
|---|
