客户批量打标签 调试

app/Console/Commands/CorpInformation/BatchMarkTagDeal.php

@@ -0,0 +1,122 @@
+<?php
+
+namespace App\Console\Commands\CorpInformation;
+
+use App\Log;
+use App\Models\AuthorizeCorp;
+use App\Models\BatchMarkTag;
+use App\Models\BatchMarkTagRecord;
+use App\Models\DjUser;
+use App\Models\Tag;
+use App\RedisModel;
+use App\Support\EmailQueue;
+use Illuminate\Console\Command;
+
+class BatchMarkTagDeal extends Command
+{
+    protected $signature = 'BatchMarkTagDeal';
+    protected $description = '客户批量打标签处理';
+
+    protected $emailSender = '猎羽-批量打标签';
+    protected $emailReceiver = ['song.shen@kuxuan-inc.com'];
+    protected $logName = 'BatchMarkTagDeal';
+
+    public function handle()
+    {
+        \DB::connection()->disableQueryLog();
+
+        $beginTime = time();
+        $this->info(date('m-d H:i:s') . ' 开始整理');
+
+        while(true) {
+            $result = $this->taskDeal();
+            if(!$result) sleep(1);
+            $now = time();
+            // 超过10分钟，主动停止循环
+            if ($now - $beginTime > 600) {
+                break;
+            }
+
+            sleep(1);
+        }
+
+        $this->info(date('Y-m-d H:i:s') . ' 整理结束');
+    }
+
+    private function taskDeal()
+    {
+        # 取出数据
+        $redisVal = RedisModel::rPop(BatchMarkTagRecord::BATCH_MARK_TAG_RECORD);
+        if(empty($redisVal))
+            return false;
+        try {
+            $this->createTask($redisVal);
+        } catch (\Exception $e) {
+            EmailQueue::rPush('创建客户批量打标签出现异常', $e->getTraceAsString(), $this->emailReceiver, $this->emailSender);
+            Log::logError('创建客户批量打标签出现异常', [
+                'line'  => $e->getLine(), 'msg'   => $e->getMessage(), 'param' => $taskId
+            ], $this->logName);
+
+            return false;
+        }
+
+        return true;
+    }
+
+    private function createTask($redisVal) {
+        $redisData = json_decode($redisVal, 1);
+        if(empty($redisData) || empty($redisData['task_id']) || empty($redisData['record_id'])) {
+            Log::logError('处理客户批量打标签 - 队里数据异常', [$redisData], $this->logName);
+            EmailQueue::rPush('处理客户批量打标签 - 队里数据异常', $redisVal, $this->emailReceiver, $this->emailSender);
+            return false;
+        }
+
+        $taskId = $redisData['task_id'];
+        $recordId = $redisData['record_id'];
+        $taskInfo = BatchMarkTag::getTaskInfoById($redisData['task_id']);
+        if(empty($taskInfo)) {
+            Log::logError('根据任务ID查询任务信息失败', ['task_id' => $taskId], $this->logName);
+            EmailQueue::rPush('处理客户批量打标签 - 根据任务ID查询任务信息失败', $redisVal, $this->emailReceiver, $this->emailSender);
+            $status = -1;
+            BatchMarkTagRecord::updateStatus($recordId, $status);
+            return false;
+        }
+
+        $taskInfo = json_decode(json_encode($taskInfo), 1);
+
+        $recordInfo = BatchMarkTagRecord::getInfoById($recordId);
+        if(empty($recordInfo)) {
+            Log::logError('根据记录ID查询记录信息失败', ['record_id' => $recordId], $this->logName);
+            EmailQueue::rPush('处理客户批量打标签 - 根据记录ID查询记录信息失败', $redisVal, $this->emailReceiver, $this->emailSender);
+            $status = -1;
+            BatchMarkTagRecord::updateStatus($recordId, $status);
+            return false;
+        }
+
+        $recordInfo = json_decode(json_encode($recordInfo), 1);
+
+        $this->dealTask($taskInfo, $recordInfo);
+    }
+
+    private function dealTask($taskInfo, $recordInfo) {
+        $externalUserIdList = explode(',', $recordInfo['external_userid']);
+        if(empty($externalUserIdList)) {
+            Log::logError('根据记录ID查询记录信息失败', ['record_id' => $recordInfo['id']], $this->logName);
+            EmailQueue::rPush('处理客户批量打标签 - 根据记录ID查询记录信息失败', 'task_id:'.$taskInfo['id'].'; record_id:'.$recordInfo['id'], $this->emailReceiver, $this->emailSender);
+            $status = -1;
+            BatchMarkTagRecord::updateStatus($recordInfo['id'], $status);
+            return false;
+        }
+
+        $tagList = json_decode($taskInfo['task_list'], 1);
+        // 标签转化
+        $newTagList = Tag::query()->where('corpid', $taskInfo['corpid'])->where('enable', 1)
+            ->whereIn('tag_md5', $tagList)->get();
+        $newTagList = $newTagList->isNotEmpty() ? array_column($newTagList->toArray(), 'tag_id') : [];
+
+        $stat = ['success' => 0, 'fail' => 0];
+        foreach ($externalUserIdList as $externalUserId) {
+
+        }
+    }
+}

app/Console/Commands/CorpInformation/BatchMarkTagNew.php

@@ -148,7 +148,7 @@ class BatchMarkTagNew extends Command
                     if(!$result) {
                         Log::logError('记录写入失败', ['task_info' => $taskInfo], $this->logName);
                     } else {
-                        RedisModel::rPush(BatchMarkTagRecord::BATCH_MARK_TAG_RECORD, $result->id);
+                        RedisModel::rPush(BatchMarkTagRecord::BATCH_MARK_TAG_RECORD, json_encode(['task_id' => $taskId, 'record_id' => $result->id]));
                     }
                 }
             }
@@ -230,7 +230,7 @@ class BatchMarkTagNew extends Command
                         if (!$result) {
                             Log::logError('记录写入失败', ['task_info' => $taskInfo], $this->logName);
                         } else {
-                            RedisModel::rPush(BatchMarkTagRecord::BATCH_MARK_TAG_RECORD, $result->id);
+                            RedisModel::rPush(BatchMarkTagRecord::BATCH_MARK_TAG_RECORD, json_encode(['task_id' => $taskInfo['id'], 'record' => $result->id]));
                         }
                     }
                 }

app/Console/Kernel.php

@@ -48,6 +48,7 @@ use App\Console\Commands\CleanData;
 use App\Console\Commands\ContactChangeRecycle;
 use App\Console\Commands\CorpAccessTokenRefresh;
 use App\Console\Commands\CorpDataSync;
+use App\Console\Commands\CorpInformation\BatchMarkTagDeal;
 use App\Console\Commands\CorpInformation\BatchMarkTagNew;
 use App\Console\Commands\CorpInformation\CustomerPayTagDeal;
 use App\Console\Commands\CorpInformation\LossContactCntStat;
@@ -478,7 +479,8 @@ class Kernel extends ConsoleKernel
         SyncYunXuanOrder::class,                // 同步云选联盟订单
         ECommerceUserActionsDataUpload::class,  // 电商直投订单数据回传
         OrganizationAccountGet::class,          // 查询组织下的广告主信息
-        BatchMarkTagNew::class,                 // 客户批量打标签（新）
+        BatchMarkTagNew::class,                 // 客户批量打标签任务分发（新）
+        BatchMarkTagDeal::class,                // 客户批量打标签任务处理
     ];
 
     /**

app/Models/BatchMarkTagRecord.php

@@ -24,4 +24,12 @@ class BatchMarkTagRecord extends Model
 
         return $model;
     }
+
+    public static function getInfoById($recordId) {
+        return self::query()->where('enable', 1)->where('id', $recordId)->first();
+    }
+
+    public static function updateStatus($recordId, $status) {
+        return self::query()->where('id', $recordId)->update(['status' => $status]);
+    }
 }