客户批量打标签 调试

app/Console/Commands/CorpInformation/BatchMarkTagNew.php

                 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'][0] ?? [];
-                    Log::logInfo('待过滤客户列表', ['user_id' => $userId, 'customer_list' => $userFilterCustomerList], $this->logName);
                     if (!empty($userFilterCustomerList)) {
-//                        $newCustomerList = $this->filterCustomerList($customerList->toArray(), $userFilterCustomerList);
                         $newCustomerList = $customerList->whereNotIn('customer_id', $userFilterCustomerList)->all();
                     } else {
                         $newCustomerList = $customerList->all();
                     }
-                    Log::logInfo('过滤后客户列表', ['user_id' => $userId, 'customer_list' => json_decode(json_encode($newCustomerList),1)], $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);
-//                    }
-//                }
+
+                    $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);
+                        }
+                    }
                 }
 
 
             } while ($count == $limit);
         }
     }
-
-    private function filterCustomerList($customerList, $userFilterCustomerList) {
-        $data = [];
-        foreach ($customerList as $customerInfo) {
-            if(!in_array($customerInfo['customer_id'], $userFilterCustomerList)) {
-                $data[] = $customerInfo;
-            }
-        }
-
-        return $data;
-    }
 }