1.优化

 package com.topdraw.business.process.service.impl;
 package com.topdraw.business.process.service.impl;
 
 
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.JSONObject;
+import com.google.gson.JsonObject;
 import com.topdraw.business.module.coupon.service.CouponService;
 import com.topdraw.business.module.coupon.service.CouponService;
 import com.topdraw.business.module.coupon.service.dto.CouponDTO;
 import com.topdraw.business.module.coupon.service.dto.CouponDTO;
 import com.topdraw.business.module.member.group.service.MemberGroupService;
 import com.topdraw.business.module.member.group.service.MemberGroupService;
@@ -111,14 +113,14 @@ public class TaskOperationServiceImpl implements TaskOperationService {
         }
         }
 
 
         // 1.通过任务标识获取任务模板，通过模板参数获取具体的模板
         // 1.通过任务标识获取任务模板，通过模板参数获取具体的模板
-        TaskTemplate taskTemplate = this.getTaskTemplate(event,dataSyncMsg);
+        TaskTemplate taskTemplate = this.getTaskTemplate(event, dataSyncMsg);
         // 2.通过任务模板获取对应的任务列表
         // 2.通过任务模板获取对应的任务列表
-        List<Task> taskList = this.loadListTaskByTaskTemplate(taskTemplate,dataSyncMsg);
+        List<Task> taskList = this.loadListTaskByTaskTemplate(taskTemplate, dataSyncMsg);
         // 4.判断当前用户是否满足任务完成条件
         // 4.判断当前用户是否满足任务完成条件
-        boolean checkResult = this.checkTaskCompletion(memberId,taskList);
+        boolean checkResult = this.checkTaskCompletion(memberId, taskList, event, msgData);
         if (checkResult) {
         if (checkResult) {
             // 5.权益区分(积分、权益、成长值)
             // 5.权益区分(积分、权益、成长值)
-            Map<RightType,Object> tempRightsMap = this.distinguishRight(memberId,taskList,msgData);
+            Map<RightType,Object> tempRightsMap = this.distinguishRight(memberId, taskList, msgData);
 
 
             // 6.风控检查
             // 6.风控检查
             boolean result = this.checkRiskManagement(memberId,tempRightsMap);
             boolean result = this.checkRiskManagement(memberId,tempRightsMap);
@@ -532,7 +534,7 @@ public class TaskOperationServiceImpl implements TaskOperationService {
      * @return boolean true:success false:fail
      * @return boolean true:success false:fail
      */
      */
     //<taskId,boolean>
     //<taskId,boolean>
-    private boolean checkTaskCompletion(Long memberId , List<Task> taskList) {
+    private boolean checkTaskCompletion(Long memberId , List<Task> taskList, Integer event, DataSyncMsg.MsgData msgData) {
         if (!CollectionUtils.isEmpty(taskList)) {
         if (!CollectionUtils.isEmpty(taskList)) {
             // 会员信息
             // 会员信息
             MemberDTO memberDTO = this.memberService.findById(memberId);
             MemberDTO memberDTO = this.memberService.findById(memberId);
@@ -557,7 +559,7 @@ public class TaskOperationServiceImpl implements TaskOperationService {
                         return false;
                         return false;
 
 
                     // 获取当前任务的完成情况
                     // 获取当前任务的完成情况
-                    boolean result = this.checkAndRefreshTaskCompletion(memberId,taskList);
+                    boolean result = this.checkAndRefreshTaskCompletion(memberId,taskList,event,msgData);
 
 
                     return result;
                     return result;
 
 
@@ -673,7 +675,7 @@ public class TaskOperationServiceImpl implements TaskOperationService {
      * @param taskStream
      * @param taskStream
      * @return boolean false:失败 true:成功
      * @return boolean false:失败 true:成功
      */
      */
-    private boolean checkAndRefreshTaskCompletion(Long memberId , List<Task> taskStream) {
+    private boolean checkAndRefreshTaskCompletion(Long memberId , List<Task> taskStream, Integer event, DataSyncMsg.MsgData msgData) {
         String time1 = LocalDateTimeUtil.todayStart();
         String time1 = LocalDateTimeUtil.todayStart();
         for (Task task : taskStream) {
         for (Task task : taskStream) {
 
 
@@ -690,6 +692,30 @@ public class TaskOperationServiceImpl implements TaskOperationService {
             // 行为量（完成此任务需要多少次相同行为的触发）
             // 行为量（完成此任务需要多少次相同行为的触发）
             Integer actionAmount = task.getActionAmount();
             Integer actionAmount = task.getActionAmount();
 
 
+            switch (event) {
+                // 播放记录
+                case 8:
+                    if (!CollectionUtils.isEmpty(trTaskProgressDTOS)) {
+                        TrTaskProgressDTO trTaskProgressDTO_0 = trTaskProgressDTOS.get(0);
+                        Integer status_0 = trTaskProgressDTO_0.getStatus();
+                        Integer currentActionAmount_0 = trTaskProgressDTO_0.getCurrentActionAmount();
+                        Timestamp completionTime_0 = trTaskProgressDTO_0.getCompletionTime();
+                        if (status_0 == 1 && currentActionAmount_0 != null && Objects.nonNull(completionTime_0)) {
+                            return false;
+                        }
+                    }
+                    String param = msgData.getParam();
+                    JSONObject jsonObject = JSON.parseObject(param);
+                    Integer value = Integer.valueOf(jsonObject.get("playDuration").toString());
+                    if (value >= actionAmount) {
+                        currentActionAmount = actionAmount;
+                        completionTime = TimestampUtil.now();
+                        status = TASK_FINISH_STATUS;
+                    }
+
+                    break;
+
+                default:
                     // 行为量 1
                     // 行为量 1
                     if (actionAmount == 1) {
                     if (actionAmount == 1) {
 
 
@@ -769,6 +795,12 @@ public class TaskOperationServiceImpl implements TaskOperationService {
 
 
                     }
                     }
 
 
+                    break;
+
+            }
+
+
+
             TrTaskProgress trTaskProgress = new TrTaskProgress();
             TrTaskProgress trTaskProgress = new TrTaskProgress();
             trTaskProgress.setId(id);
             trTaskProgress.setId(id);
             trTaskProgress.setCurrentActionAmount(currentActionAmount);
             trTaskProgress.setCurrentActionAmount(currentActionAmount);