diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/lottery/PointManager.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/lottery/PointManager.java index 57c44e64..33d15fcc 100644 --- a/ruoyi-cai/src/main/java/com/ruoyi/cai/lottery/PointManager.java +++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/lottery/PointManager.java @@ -106,6 +106,7 @@ public class PointManager { if(checkPointIncr.isAllowPoint()){ User user = userService.getById(userId); User inviteUser = userService.getById(inviteUserId); + accountMapper.incrPoint(user.getId(), checkPointIncr.getGivePoint()); PointChangeLog pointChangeLog = new PointChangeLog(); pointChangeLog.setUserId(userId); pointChangeLog.setUsercode(user.getUsercode()); @@ -122,6 +123,9 @@ public class PointManager { pointChangeLog.setTraceLinkType(PointChangeTraceTypeEnum.INVITE.getCode()); pointChangeLog.setTraceId(traceId); pointChangeLogService.save(pointChangeLog); + String redisKey = getRedisKey(user.getId()); + RAtomicLong atomicLong = redissonClient.getAtomicLong(redisKey); + atomicLong.addAndGet(checkPointIncr.getGivePoint()); } } @@ -165,6 +169,7 @@ public class PointManager { if(checkPointIncr.isAllowPoint()){ // 参与积分 User user = userService.getById(userId); User inviteUser = userService.getById(inviteUserId); + accountMapper.incrPoint(user.getId(), checkPointIncr.getGivePoint()); PointChangeLog pointChangeLog = new PointChangeLog(); pointChangeLog.setUserId(userId); pointChangeLog.setUsercode(user.getUsercode()); @@ -181,6 +186,9 @@ public class PointManager { pointChangeLog.setTraceLinkType(PointChangeTraceTypeEnum.INVITE.getCode()); pointChangeLog.setTraceId(traceId); pointChangeLogService.save(pointChangeLog); + String redisKey = getRedisKey(user.getId()); + RAtomicLong atomicLong = redissonClient.getAtomicLong(redisKey); + atomicLong.addAndGet(checkPointIncr.getGivePoint()); } } diff --git a/ruoyi-cai/src/main/java/com/ruoyi/cai/util/RestTemplateUtil.java b/ruoyi-cai/src/main/java/com/ruoyi/cai/util/RestTemplateUtil.java index accd7c88..8a17426f 100644 --- a/ruoyi-cai/src/main/java/com/ruoyi/cai/util/RestTemplateUtil.java +++ b/ruoyi-cai/src/main/java/com/ruoyi/cai/util/RestTemplateUtil.java @@ -125,7 +125,7 @@ public class RestTemplateUtil { headers.add(entry.getKey(),entry.getValue()); } HttpEntity request = new HttpEntity<>(object, headers); - return restTemplate.postForObject(url, request, String.class); + return NO_SSL_REST_TEMPLATE.postForObject(url, request, String.class); }