直播红娘任务

dating-agency-mall-entity/src/main/java/com/qniao/dam/domain/aggregate/utc/entity/UserSubTaskComplete.java

@@ -36,4 +36,13 @@ public class UserSubTaskComplete extends Entity<UserSubTaskComplete> {
         return entity;
     }
 
+    public void commit(Integer commitCount, Integer requiredCount) {
+        if (!completeStatus) {
+            completeCount = commitCount + commitCount;
+            completeStatus = completeCount >= requiredCount;
+            if (completeStatus) {
+                completeTime = LocalDateTime.now();
+            }
+        }
+    }
 }

dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/utc/UserTaskCompleteEventHandler.java

@@ -66,20 +66,18 @@ public class UserTaskCompleteEventHandler extends BaseApplicationService {
                                 if (Objects.isNull(userTaskComplete)) {
                                     userTaskComplete = UserTaskComplete.init(mq.getUserId(), taskTemplate.getId(), tuple.get(0), tuple.get(1));
                                     UserSubTaskComplete userSubTaskComplete = UserSubTaskComplete.init(subTaskTemplate.getId());
+                                    userSubTaskComplete.commit(mq.getCommitCount(), subTaskTemplate.getRequiredCount());
                                     userTaskComplete.setInsertSubList(Collections.singletonList(userSubTaskComplete));
                                 } else {
                                     if (!userTaskComplete.getCompleteStatus()) {
                                         UserSubTaskComplete userSubTaskComplete = userTaskCompleteQueryService.querySubBy(userTaskComplete.getId(), subTaskTemplate.getId());
                                         if (Objects.isNull(userSubTaskComplete)) {
                                             userSubTaskComplete = UserSubTaskComplete.init(subTaskTemplate.getId());
+                                            userSubTaskComplete.commit(mq.getCommitCount(), subTaskTemplate.getRequiredCount());
                                             userTaskComplete.setInsertSubList(Collections.singletonList(userSubTaskComplete));
                                         } else {
                                             if (!userSubTaskComplete.getCompleteStatus()) {
-                                                userSubTaskComplete.setCompleteCount(userSubTaskComplete.getCompleteCount() + mq.getCommitCount());
-                                                userSubTaskComplete.setCompleteStatus(userSubTaskComplete.getCompleteCount() >= subTaskTemplate.getRequiredCount());
-                                                if (userSubTaskComplete.getCompleteStatus()) {
-                                                    userSubTaskComplete.setCompleteTime(LocalDateTime.now());
-                                                }
+                                                userSubTaskComplete.commit(mq.getCommitCount(), subTaskTemplate.getRequiredCount());
                                                 userTaskComplete.setUpdateSubList(Collections.singletonList(userSubTaskComplete));
                                             }
                                         }