| | |
|---|
| | | if (applyProvider && providerPointsChange != 0) { |
|---|
| | | PointsFlow providerFlow = new PointsFlow(); |
|---|
| | | providerFlow.setUserId(providerId); |
|---|
| | | providerFlow.setUnitId(providerId); |
|---|
| | | providerFlow.setUnitId(null); |
|---|
| | | providerFlow.setDataType(ruleType); |
|---|
| | | providerFlow.setDataCategory(addPointsFlowDTO.getCategory()); |
|---|
| | | providerFlow.setPoints(providerPointsChange); |
|---|
| | |
|---|
| | | if (!providerSaved) { |
|---|
| | | throw new BusinessException("保存提供者积分流水失败"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | updateProviderUnitPoints(providerId, providerPointsChange); |
|---|
| | | updateUserPointsByRule(providerId, null, userPointsChange); |
|---|
| | | // updateProviderUnitPoints(providerId, providerPointsChange); |
|---|
| | | } |
|---|
| | | |
|---|
| | | return true; |
|---|
| | |
|---|
| | | |
|---|
| | | userPoints = new UserPoints(); |
|---|
| | | userPoints.setUserId(userId); |
|---|
| | | userPoints.setUnitId(unitId); |
|---|
| | | if(StringUtils.hasText(unitId)){ |
|---|
| | | userPoints.setUnitId(unitId); |
|---|
| | | } |
|---|
| | | userPoints.setBalance(pointsValue); |
|---|
| | | userPoints.setTotalEarned(pointsValue > 0 ? pointsValue : 0); |
|---|
| | | userPoints.setTotalConsumed(pointsValue < 0 ? Math.abs(pointsValue) : 0); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 更新单位积分账户 |
|---|
| | | QueryWrapper<UserPoints> unitWrapper = new QueryWrapper<>(); |
|---|
| | | /* QueryWrapper<UserPoints> unitWrapper = new QueryWrapper<>(); |
|---|
| | | unitWrapper.eq("deleted", 0) |
|---|
| | | .eq("unit_id", unitId); |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | unitPoints.setUpdateTime(LocalDateTime.now()); |
|---|
| | | userPointsMapper.updateById(unitPoints); |
|---|
| | | } |
|---|
| | | } */ |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
