diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/task/TaskListener.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/task/TaskListener.java index f077cda7..37d66ae1 100644 --- a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/task/TaskListener.java +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/task/TaskListener.java @@ -139,7 +139,7 @@ public class TaskListener implements MessageListener { } else { int result = Integer.parseInt(inc) + 1; eventBody.setTargetValue(10); - eventBody.setCompleteValue(result); + eventBody.setCompleteValue(Math.min(result, 10)); boolean updated = updateTaskStatus(eventBody); if (updated) { redisService.increment(redisKey, 1); @@ -220,7 +220,7 @@ public class TaskListener implements MessageListener { Long friendsCount = relationshipFriendService.selectMyFriendsCount(eventBody.getUserId()); eventBody.setTargetValue(10); - eventBody.setCompleteValue(friendsCount.intValue()); + eventBody.setCompleteValue(Math.min(friendsCount.intValue(), 10)); updateTaskStatus(eventBody); } @@ -278,7 +278,7 @@ public class TaskListener implements MessageListener { } else { int result = Integer.parseInt(countStr) + num; eventBody.setTargetValue(10); - eventBody.setCompleteValue(result); + eventBody.setCompleteValue(Math.min(result, 10)); boolean updated = updateTaskStatus(eventBody); if (updated) { redisService.increment(redisKey, 1); @@ -352,7 +352,7 @@ public class TaskListener implements MessageListener { } else { int result = Integer.parseInt(inc) + 1; eventBody.setTargetValue(3); - eventBody.setCompleteValue(result); + eventBody.setCompleteValue(Math.min(result, 3)); boolean updated = updateTaskStatus(eventBody); if (updated) { redisService.increment(redisKey, 1);