日志批量更新优化

src/Handler/LogTrace/LogTraceHandler.php

@@ -83,7 +83,6 @@ class LogTraceHandler
         if(!Coroutine::inCoroutine()) return;
         container(LogTraceQueue::class)->addToQueue([
             'request_id'=>self::getRequestId(),
-            'process_info'=>'',
             'is_completed'=>YES
         ]);
         //LogTrace::where('request_id', self::getRequestId())->update(['is_completed' => YES]);
@@ -117,8 +116,7 @@ class LogTraceHandler
 
         container(LogTraceQueue::class)->addToQueue([
             'request_id'=>self::getRequestId($isInAsyncCoroutine),
-            'process_info'=>$logInfo,
-            'is_completed'=>NO
+            'process_info'=>$logInfo
         ]);
 //        $log = LogTrace::where('request_id', self::getRequestId())->first();
 //        if(empty($log)) return ;

src/Handler/LogTrace/LogTraceQueue.php

@@ -22,11 +22,13 @@ class LogTraceQueue extends RedisQueueBatchHandler
     function batchDeal($dataArr)
     {
         $updateArr = [];
-        foreach ($dataArr as $arr){
+        $updateMarkComplete = [];
 
-            $updateArr[$arr['request_id']]['request_id'] = $arr['request_id'];
-            $updateArr[$arr['request_id']]['is_completed'] = $arr['is_completed'];
+        foreach ($dataArr as $arr){
 
+            if(isset($arr['is_completed'])&&$arr['is_completed']==YES){
+                $updateMarkComplete[]= $arr['request_id'] ;continue;
+            }
             $process_info = isset($updateArr[$arr['request_id']]['process_info'])?
                              $updateArr[$arr['request_id']]['process_info']:'';
 
@@ -49,7 +51,10 @@ class LogTraceQueue extends RedisQueueBatchHandler
             return $item;
         },$updateArr);
 
-
+        //批量更新
+        if(!empty($updateMarkComplete)){
+            LogTrace::whereIn('request_id',$updateMarkComplete)->update(['is_completed'=>YES]);
+        }
         LogTrace::getModel()->batchUpdateByField(array_values($updateArr),'request_id');
     }