客户批量打标签 调试

app/Console/Commands/CorpInformation/BatchMarkTagNew.php

@@ -192,8 +192,6 @@ class BatchMarkTagNew extends Command
             $newFilterCustomerList = [];
         }
 
-        Log::logInfo('过滤客户记录', $newFilterCustomerList, $this->logName);
-
         # 先查询出所有需要执行的客服，再按照客服来查询客户列表
         $userIdList = $params['user_id_list'];
         if (empty($userIdList)) {
@@ -206,8 +204,6 @@ class BatchMarkTagNew extends Command
             $userIdList = array_intersect($params['user_id_list'], $activeUserList);
         }
 
-        Log::logInfo('激活客服记录', $userIdList, $this->logName);
-
         foreach ($userIdList as $userId) {
             $params['user_id_list'] = [$userId];
             $page = 1;
@@ -215,30 +211,37 @@ class BatchMarkTagNew extends Command
             do {
                 $customerQuery = CustomerDetails::getCustomerBySearchNew($params, $source);
                 $count = $customerQuery->count();
-                $customerList = $customerQuery->selectRaw("customer_id, external_userid")
-                    ->offset(($page - 1) * $limit)->limit($limit)->get();
-                Log::logInfo('初始客户列表', [$customerList->toArray()], $this->logName);
-
-                $userFilterCustomerList = $newFilterCustomerList[$userId]['list'] ?? [];
-                if (!empty($userFilterCustomerList)) {
-                    $newCustomerList = $customerList->whereNotIn('customer_id', $userFilterCustomerList)->all()->toArray();
-                } else {
-                    $newCustomerList = $customerList->all()->toArray();
-                }
-                Log::logInfo('过滤后客户列表', [$newCustomerList], $this->logName);
-
-                $userExternalUserIdList = array_column($newCustomerList, 'external_userid');
-                $externalUserIdArr = array_chunk($userExternalUserIdList, $this->limit);
-                foreach ($externalUserIdArr as $externalUserIdList) {
-                    $result = BatchMarkTagRecord::savedData($taskInfo['id'], $taskInfo['corpid'], $userId, $externalUserIdList);
-
-                    if (!$result) {
-                        Log::logError('记录写入失败', ['task_info' => $taskInfo], $this->logName);
+                if($count > 0) {
+                    $customerList = $customerQuery->selectRaw("customer_id, external_userid")
+                        ->offset(($page - 1) * $limit)->limit($limit)->get();
+                    Log::logInfo('初始客户列表', ['user_id' => $userId, 'customer_list' => $customerList->toArray()], $this->logName);
+
+                    $userFilterCustomerList = $newFilterCustomerList[$userId]['list'] ?? [];
+                    Log::logInfo('待过滤客户列表', ['user_id' => $userId, 'customer_list' => $userFilterCustomerList], $this->logName);
+                    if (!empty($userFilterCustomerList)) {
+                        $customerIdList = array_column($customerList->toArray(), 'customer_id');
+                        $newCustomerIdList = array_diff($customerIdList, $userFilterCustomerList);
+                        $newCustomerList = $customerList->whereIn('customer_id', $newCustomerIdList)->all();
+                        $newCustomerList = json_decode(json_encode($newCustomerList), 1);
                     } else {
-                        RedisModel::rPush(BatchMarkTagRecord::BATCH_MARK_TAG_RECORD, $result->id);
+                        $newCustomerList = $customerList->toArray();
                     }
+                    Log::logInfo('过滤后客户列表', [$newCustomerList], $this->logName);
+
+//                $userExternalUserIdList = array_column($newCustomerList, 'external_userid');
+//                $externalUserIdArr = array_chunk($userExternalUserIdList, $this->limit);
+//                foreach ($externalUserIdArr as $externalUserIdList) {
+//                    $result = BatchMarkTagRecord::savedData($taskInfo['id'], $taskInfo['corpid'], $userId, $externalUserIdList);
+//
+//                    if (!$result) {
+//                        Log::logError('记录写入失败', ['task_info' => $taskInfo], $this->logName);
+//                    } else {
+//                        RedisModel::rPush(BatchMarkTagRecord::BATCH_MARK_TAG_RECORD, $result->id);
+//                    }
+//                }
                 }
 
+
                 $page++;
             } while ($count == $limit);
         }