hy/aslan-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

task 修复2

Browse Source
This commit is contained in:
tianfeng 2025-10-23 19:02:14 +08:00
parent 9622cac009
commit 91b5cb524c
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/task/TaskListener.java
View File

@ -139,7 +139,7 @@ public class TaskListener implements MessageListener {
} else { } else {
int result = Integer.parseInt(inc) + 1; int result = Integer.parseInt(inc) + 1;
eventBody.setTargetValue(10); eventBody.setTargetValue(10);
eventBody.setCompleteValue(result); eventBody.setCompleteValue(Math.min(result, 10));
boolean updated = updateTaskStatus(eventBody); boolean updated = updateTaskStatus(eventBody);
if (updated) { if (updated) {
redisService.increment(redisKey, 1); redisService.increment(redisKey, 1);
@ -220,7 +220,7 @@ public class TaskListener implements MessageListener {
Long friendsCount = relationshipFriendService.selectMyFriendsCount(eventBody.getUserId()); Long friendsCount = relationshipFriendService.selectMyFriendsCount(eventBody.getUserId());
eventBody.setTargetValue(10); eventBody.setTargetValue(10);
eventBody.setCompleteValue(friendsCount.intValue()); eventBody.setCompleteValue(Math.min(friendsCount.intValue(), 10));
updateTaskStatus(eventBody); updateTaskStatus(eventBody);
} }
@ -278,7 +278,7 @@ public class TaskListener implements MessageListener {
} else { } else {
int result = Integer.parseInt(countStr) + num; int result = Integer.parseInt(countStr) + num;
eventBody.setTargetValue(10); eventBody.setTargetValue(10);
eventBody.setCompleteValue(result); eventBody.setCompleteValue(Math.min(result, 10));
boolean updated = updateTaskStatus(eventBody); boolean updated = updateTaskStatus(eventBody);
if (updated) { if (updated) {
redisService.increment(redisKey, 1); redisService.increment(redisKey, 1);
@ -352,7 +352,7 @@ public class TaskListener implements MessageListener {
} else { } else {
int result = Integer.parseInt(inc) + 1; int result = Integer.parseInt(inc) + 1;
eventBody.setTargetValue(3); eventBody.setTargetValue(3);
eventBody.setCompleteValue(result); eventBody.setCompleteValue(Math.min(result, 3));
boolean updated = updateTaskStatus(eventBody); boolean updated = updateTaskStatus(eventBody);
if (updated) { if (updated) {
redisService.increment(redisKey, 1); redisService.increment(redisKey, 1);