| | |
| | | @Autowired |
| | | private IntegralDetailMapper integralDetailMapper; |
| | | |
| | | private static final Object Lock= new Object(); |
| | | /** |
| | | * 积分超市新增和修改 |
| | | * @param integralDetailEntity |
| | |
| | | String sysUserId = sysUserInfo.getUserId(); |
| | | String companyId = sysUserInfo.getCompanyId(); |
| | | //扣积分逻辑 |
| | | synchronized (Lock){ |
| | | IntegralAccountEntity integralAccountEntity = IntegralAccountEntity |
| | | .builder() |
| | | .userId(integralDetailEntity.getUserId()) |
| | |
| | | integralDetailEntity.setIntegralSource("积分超市"); |
| | | //添加或修改明细 |
| | | integralDetailMapper.insertDetailAndUpdate(integralDetailEntity); |
| | | } |
| | | return BasicResult.success(); |
| | | } |
| | | |
| | |
| | | Double totalConsumption = queryAccount.getTotalConsumption();//总消耗 |
| | | Double accumulateIntegral = queryAccount.getAccumulateIntegral();//累计积分 |
| | | Double totalIntegral = queryAccount.getTotalIntegral();//当前余额 |
| | | |
| | | synchronized (Lock){ |
| | | IntegralAccountEntity integralAccountEntity = IntegralAccountEntity |
| | | .builder() |
| | | .userId(integralDetailEntity.getUserId()) |
| | |
| | | .build(); |
| | | integralDetailMapper.insertAndUpdateAccount(integralAccountEntity); |
| | | integralDetailMapper.delete(id); |
| | | } |
| | | return BasicResult.success(); |
| | | } |
| | | |