客户批量打标签处理 调试

app/Console/Commands/CorpInformation/BatchMarkTagDeal.php

@@ -6,10 +6,13 @@ use App\Log;
 use App\Models\AuthorizeCorp;
 use App\Models\BatchMarkTag;
 use App\Models\BatchMarkTagRecord;
+use App\Models\CustomerDetails;
 use App\Models\DjUser;
 use App\Models\Tag;
 use App\RedisModel;
+use App\Service\TagService;
 use App\Support\EmailQueue;
+use App\Support\qyApi\QyCommon;
 use Illuminate\Console\Command;
 
 class BatchMarkTagDeal extends Command
@@ -52,9 +55,9 @@ class BatchMarkTagDeal extends Command
         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
+            EmailQueue::rPush('客户批量打标签处理任务出现异常', $e->getTraceAsString(), $this->emailReceiver, $this->emailSender);
+            Log::logError('程序异常', [
+                'line'  => $e->getLine(), 'msg'   => $e->getMessage(), 'param' => $redisVal
             ], $this->logName);
 
             return false;
@@ -66,7 +69,7 @@ class BatchMarkTagDeal extends Command
     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);
+            Log::logError('队列数据异常', [$redisData], $this->logName);
             EmailQueue::rPush('处理客户批量打标签 - 队里数据异常', $redisVal, $this->emailReceiver, $this->emailSender);
             return false;
         }
@@ -78,7 +81,7 @@ class BatchMarkTagDeal extends Command
             Log::logError('根据任务ID查询任务信息失败', ['task_id' => $taskId], $this->logName);
             EmailQueue::rPush('处理客户批量打标签 - 根据任务ID查询任务信息失败', $redisVal, $this->emailReceiver, $this->emailSender);
             $status = -1;
-            BatchMarkTagRecord::updateStatus($recordId, $status);
+            BatchMarkTagRecord::updateData($recordId, ['status' => $status]);
             return false;
         }
 
@@ -89,7 +92,7 @@ class BatchMarkTagDeal extends Command
             Log::logError('根据记录ID查询记录信息失败', ['record_id' => $recordId], $this->logName);
             EmailQueue::rPush('处理客户批量打标签 - 根据记录ID查询记录信息失败', $redisVal, $this->emailReceiver, $this->emailSender);
             $status = -1;
-            BatchMarkTagRecord::updateStatus($recordId, $status);
+            BatchMarkTagRecord::updateData($recordId, ['status' => $status]);
             return false;
         }
 
@@ -104,7 +107,7 @@ class BatchMarkTagDeal extends Command
             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);
+            BatchMarkTagRecord::updateData($recordInfo['id'], ['status' => $status]);
             return false;
         }
 
@@ -114,7 +117,7 @@ class BatchMarkTagDeal extends Command
             ->whereIn('tag_md5', $tagList)->get();
         $newTagList = $newTagList->isNotEmpty() ? array_column($newTagList->toArray(), 'tag_id') : [];
 
-        $stat = ['success' => 0, 'fail' => 0];
+        $update = ['exec_success' => 0, 'exec_fail' => 0];
         foreach ($externalUserIdList as $externalUserId) {
             if(1 == $taskInfo['type']) {
                 $newAddTagIdList = $newTagList;
@@ -124,8 +127,33 @@ class BatchMarkTagDeal extends Command
                 $newRemoveTagIdList = $newTagList;
             }
 
-            $this->markTag($taskInfo['corpid'], $recordInfo['user_id'], $externalUserId, $newAddTagIdList, $newRemoveTagIdList);
+            $res = $this->markTag($taskInfo['corpid'], $recordInfo['user_id'], $externalUserId, $newAddTagIdList, $newRemoveTagIdList);
+            if($res) {
+                $update['exec_success']++;
+            } else {
+                $update['exec_fail']++;
+            }
+        }
+
+        # 验证总数
+        if($update['success'] + $update['exec_fail'] != $recordInfo['exec_total']) {
+            Log::logError('程序异常', ['record_id' => $recordInfo['id'], 'stat' => $update], $this->logName);
+            EmailQueue::rPush('客户批量打标签 - 处理数据总数与待处理数据总数不一致', json_encode(['record_id' => $recordInfo['id'], 'stat' => $update]), $this->emailReceiver, $this->emailSender);
         }
+
+        # 更新任务状态
+        if($update['fail'] == $recordInfo['exec_total']) {
+            $update['status'] = -1;
+        } else {
+            $update['status'] = 1;
+        }
+        $res = BatchMarkTagRecord::updateData($recordInfo['id'], $update);
+        if(!$res) {
+            Log::logError('数据更新失败', ['record_id' => $recordInfo['id'], 'update' => $update], $this->logName);
+        }
+
+        # 判断总体任务是否执行完成
+        $this->chargeTaskStatus($taskInfo['id']);
     }
 
     private function markTag($corpid, $userId, $externalUserId, $newAddTagIdList, $newRemoveTagIdList, $retry = 0) {
@@ -148,24 +176,44 @@ class BatchMarkTagDeal extends Command
 
             return true;
         } else {
-           if(!in_array($responseData['errcode'], [84061, 60111])) { # 无法处理的状态码：没有好友关系或者客服ID不存在
+           if( $responseData['errcode'] != 84061 ) { # 无法处理的状态码：没有好友关系
                 // 判断重试次数
-                if($ <= 5) {
-                    $re_times++;
-                    $data['re_times'] = $re_times;
-                    // RedisModel::lPush(CustomerTagService::CUSTOMER_TAG_MARK_RDS, json_encode($data));
+                if($retry <= 5) {
+                    $retry++;
+                    return $this->markTag($corpid, $userId, $externalUserId, $newAddTagIdList, $newRemoveTagIdList, $retry);
                 } else {
+                    $params = ['corpid' => $corpid, 'user_id' => $userId, 'external_userid' => $externalUserId, 'add_tag_id_list' => $newAddTagIdList, 'remove_tag_id_list' => $newRemoveTagIdList];
                     // 还是一直失败，则不再请求，日志记录一下
-                    Log::logError('', [
-                        'corpid' => $corpid,
-                        'param' => $data,
-                        'message' => '请求企微打标签接口3次重试均失败',
+                    Log::logError('请求企微打标签接口3次重试均失败', [
+                        'param' => $params,
+                        'response' => $responseData,
                     ], $this->logName);
-                    EmailQueue::rPush('请求企微打标签接口3次重试均失败', json_encode(['params' => $data, 'res' => $responseData], 256), $this->emailReceiver, $this->emailSender);
-                    // 邮件报警
-                    // $this->exceptionHandler(json_encode(['params' => $data, 'msg' => '请求企微打标签接口3次重试均失败', 'res' => $responseData], 256));
+                    EmailQueue::rPush('请求企微打标签接口3次重试均失败', json_encode(['params' => $params, 'res' => $responseData], 256), $this->emailReceiver, $this->emailSender);
+                    return false;
                 }
-//            }
+            } else {
+               //todo 隔1小时报警一次
+
+               return false;
+           }
+        }
+    }
+
+    private function chargeTaskStatus($taskId) {
+        $countData = BatchMarkTagRecord::recordCount($taskId);
+        $total = 0; $exec = 0;
+        if($countData->isNotEmpty()) {
+            foreach ($countData as $countInfo) {
+                if(0 == $countInfo->status) {
+                    $exec += $countInfo->count;
+                }
+
+                $total += $countInfo->count;
+            }
+        }
+
+        if($exec == 0) {
+            BatchMarkTag::updateStatus($taskId, 3);
         }
     }
 }

app/Console/Commands/CorpInformation/BatchMarkTagNew.php

@@ -75,6 +75,7 @@ class BatchMarkTagNew extends Command
         }
 
         $taskInfo = json_decode(json_encode($taskInfo), 1);
+        BatchMarkTag::updateStatus($taskId, 2);
 
         # 客服许可(兼容新授权到系统的企微，此种企微的客服没有许可，但是会有75天的试用期)
         $corpInfo = AuthorizeCorp::getCorpInfo($taskInfo['corpid']);

app/Models/BatchMarkTagRecord.php

@@ -29,7 +29,12 @@ class BatchMarkTagRecord extends Model
         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]);
+    public static function updateData($recordId, $update) {
+        return self::query()->where('id', $recordId)->update($update);
+    }
+
+    public static function recordCount($taskId) {
+        $model = self::query()->where('enable', 1)->where('task_id', $taskId);
+        return $model->selectRaw('status, count(1) as count')->groupBy(['status'])->get();
     }
 }