m

app/Console/Commands/CorpInformation/BatchMarkTagDeal.php

@@ -116,7 +116,56 @@ class BatchMarkTagDeal extends Command
 
         $stat = ['success' => 0, 'fail' => 0];
         foreach ($externalUserIdList as $externalUserId) {
+            if(1 == $taskInfo['type']) {
+                $newAddTagIdList = $newTagList;
+                $newRemoveTagIdList = [];
+            } else if(2 == $taskInfo['type']) {
+                $newAddTagIdList = [];
+                $newRemoveTagIdList = $newTagList;
+            }
+
+            $this->markTag($taskInfo['corpid'], $recordInfo['user_id'], $externalUserId, $newAddTagIdList, $newRemoveTagIdList);
+        }
+    }
+
+    private function markTag($corpid, $userId, $externalUserId, $newAddTagIdList, $newRemoveTagIdList, $retry = 0) {
+        $responseData = QyCommon::mark_tag($corpid, $userId, $externalUserId, $newAddTagIdList, $newRemoveTagIdList);
+
+        if(isset($responseData['errcode']) && $responseData['errcode'] == 0) {
+            // 编辑成功了
+            TagService::updateLocalCustomerTagSecond($corpid, $userId, $externalUserId, $newAddTagIdList, $newRemoveTagIdList);
+
+            $state = $data['state'] ?? null;
+            if (!is_null($state)) {
+                // 客户详情10s同步一遍
+                RedisModel::lPush(CustomerDetails::CUSTOMER_DATA_SYNC_RDS, json_encode([
+                    'corpid' => $corpid,
+                    'user_id' => $userId,
+                    'external_userid' => $externalUserId,
+                    'exec_time' => time() + 10
+                ]));
+            }
 
+            return true;
+        } else {
+           if(!in_array($responseData['errcode'], [84061, 60111])) { # 无法处理的状态码：没有好友关系或者客服ID不存在
+                // 判断重试次数
+                if($ <= 5) {
+                    $re_times++;
+                    $data['re_times'] = $re_times;
+                    // RedisModel::lPush(CustomerTagService::CUSTOMER_TAG_MARK_RDS, json_encode($data));
+                } else {
+                    // 还是一直失败，则不再请求，日志记录一下
+                    Log::logError('', [
+                        'corpid' => $corpid,
+                        'param' => $data,
+                        'message' => '请求企微打标签接口3次重试均失败',
+                    ], $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));
+                }
+//            }
         }
     }
 }