fnvtk/cunkebao_v3
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

【触客宝】 自动分配好友根群

Browse Source
This commit is contained in:
wong
2025-04-25 09:28:52 +08:00
parent 16a723bcaf
commit 3b12d6befd
5 changed files with 540 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

144
Server/application/api/controller/AutomaticAssign.php Normal file
View File

@@ -0,0 +1,144 @@
<?php
namespace app\api\controller;
use app\api\model\CompanyAccountModel;
use app\api\model\CompanyModel;
use Library\S2\Logics\AccountLogic;
use think\Db;
use think\facade\Request;
/**
* 账号管理控制器
* 包含账号管理和部门管理的相关功能
*/
class AutomaticAssign extends BaseController
{
/**
* 自动分配微信好友
* @return \think\response\Json
*/
public function autoAllotWechatFriend($toAccountId = '', $wechatAccountKeyword = '', $isDeleted = false)
{
// 获取授权token
$authorization = trim($this->request->header('authorization', $this->authorization));
if (empty($authorization)) {
return errorJson('缺少授权信息');
}
try {
// 获取请求参数
$toAccountId = !empty($toAccountId) ? $toAccountId : input('toAccountId', '');
$wechatAccountKeyword = !empty($wechatAccountKeyword) ? $wechatAccountKeyword : input('wechatAccountKeyword', '');
$isDeleted = !empty($isDeleted) ? $isDeleted : input('isDeleted', false);
if (empty($toAccountId)) {
return errorJson('目标账号ID不能为空');
}
$params = [
'accountKeyword' => '',
'addFrom' => [],
'allotAccountId' => '',
'containAllLabel' => false,
'containSubDepartment' => false,
'departmentId' => '',
'extendFields' => [],
'friendKeyword' => '',
'friendPhoneKeyword' => '',
'friendPinYinKeyword' => '',
'friendRegionKeyword' => '',
'friendRemarkKeyword' => '',
'gender' => '',
'groupId' => null,
'isByRule' => false,
'isDeleted' => $isDeleted,
'isPass' => true,
'keyword' => '',
'labels' => [],
'pageIndex' => 0,
'pageSize' => 100,
'preFriendId' => '',
'toAccountId' => $toAccountId,
'wechatAccountKeyword' => $wechatAccountKeyword
];
// 设置请求头
$headerData = ['client:system'];
$header = setHeader($headerData, $authorization, 'json');
// 发送请求
$result = requestCurl($this->baseUrl . 'api/WechatFriend/allotSearchResult', $params, 'PUT', $header,'json');
$response = handleApiResponse($result);
if($response){
return successJson([],'微信好友自动分配成功');
}else{
return errorJson($response);
}
} catch (\Exception $e) {
return errorJson('微信好友自动分配失败：' . $e->getMessage());
}
}
/**
* 自动分配微信群聊
* @param string $toAccountId 目标账号ID
* @param string $wechatAccountKeyword 微信账号关键字
* @param bool $isDeleted 是否已删除
* @return \think\response\Json
*/
public function autoAllotWechatChatroom($toAccountId = '', $wechatAccountKeyword = '', $isDeleted = false)
{
// 获取授权token
$authorization = trim($this->request->header('authorization', $this->authorization));
if (empty($authorization)) {
return errorJson('缺少授权信息');
}
try {
// 获取请求参数
$toAccountId = !empty($toAccountId) ? $toAccountId : input('toAccountId', '');
$wechatAccountKeyword = !empty($wechatAccountKeyword) ? $wechatAccountKeyword : input('wechatAccountKeyword', '');
$isDeleted = !empty($isDeleted) ? $isDeleted : input('isDeleted', false);
if (empty($toAccountId)) {
return errorJson('目标账号ID不能为空');
}
$params = [
'AllotBySearch' => true,
'byRule' => false,
'comment' => '',
'groupId' => null,
'isDeleted' => $isDeleted,
'keyword' => '',
'memberKeyword' => '',
'notifyReceiver' => false,
'toAccountId' => $toAccountId,
'wechatAccountKeyword' => $wechatAccountKeyword,
'wechatChatroomId' => 0,
'wechatChatroomIds' => []
];
// 设置请求头
$headerData = ['client:system'];
$header = setHeader($headerData, $authorization, 'json');
// 发送请求
$result = requestCurl($this->baseUrl . 'api/WechatChatroom/allotChatroom', $params, 'PUT', $header, 'json');
$response = handleApiResponse($result);
if($response){
return successJson([], '微信群聊自动分配成功');
}else{
return errorJson($response);
}
} catch (\Exception $e) {
return errorJson('微信群聊自动分配失败：' . $e->getMessage());
}
}
}

102
Server/application/command/AllotChatroomCommand.php Normal file
View File

@@ -0,0 +1,102 @@
<?php
namespace app\command;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\console\input\Option;
use think\facade\Log;
use think\Queue;
use app\job\AllotChatroomJob;
use think\facade\Cache;
class AllotChatroomCommand extends Command
{
// 队列名称
protected $queueName = 'allot_chatroom';
protected function configure()
{
$this->setName('allotChatroom:run')
->setDescription('自动分配微信群聊')
->addOption('toAccountId', null, Option::VALUE_REQUIRED, '目标账号ID')
->addOption('wechatAccountKeyword', null, Option::VALUE_REQUIRED, '微信账号关键字')
->addOption('isDeleted', null, Option::VALUE_OPTIONAL, '是否已删除状态: 0=未删除(false), 1=已删除(true)', 0)
->addOption('jobId', null, Option::VALUE_OPTIONAL, '任务ID，用于区分不同实例', date('YmdHis') . rand(1000, 9999));
}
protected function execute(Input $input, Output $output)
{
$output->writeln('开始处理微信群聊自动分配任务...');
try {
// 获取命令参数
$toAccountId = $input->getOption('toAccountId');
$wechatAccountKeyword = $input->getOption('wechatAccountKeyword');
$isDeleted = $input->getOption('isDeleted');
$jobId = $input->getOption('jobId');
// 验证必填参数
if (empty($toAccountId)) {
$output->writeln('错误: 目标账号ID不能为空');
return false;
}
if (empty($wechatAccountKeyword)) {
$output->writeln('错误: 微信账号关键字不能为空');
return false;
}
$output->writeln('目标账号ID: ' . $toAccountId);
$output->writeln('微信账号关键字: ' . $wechatAccountKeyword);
$output->writeln('删除状态: ' . ($isDeleted ? '已删除' : '未删除'));
$output->writeln('任务ID: ' . $jobId);
// 检查队列是否已经在运行
$queueLockKey = "queue_lock:{$this->queueName}:{$wechatAccountKeyword}";
if (Cache::get($queueLockKey)) {
$output->writeln("队列 {$this->queueName} 已经在运行中，wechatAccountKeyword:{$wechatAccountKeyword}，跳过执行");
Log::warning("队列 {$this->queueName} 已经在运行中，wechatAccountKeyword:{$wechatAccountKeyword}，跳过执行");
return false;
}
// 设置队列运行锁，有效期1小时
Cache::set($queueLockKey, $jobId, 3600);
$output->writeln("已设置队列运行锁，键名:{$queueLockKey}，值:{$jobId}，有效期:1小时");
// 将任务添加到队列
$this->addToQueue($toAccountId, $wechatAccountKeyword, $isDeleted, $jobId, $queueLockKey);
$output->writeln('微信群聊自动分配任务已添加到队列');
} catch (\Exception $e) {
Log::error('微信群聊自动分配任务添加失败：' . $e->getMessage());
$output->writeln('微信群聊自动分配任务添加失败：' . $e->getMessage());
return false;
}
return true;
}
/**
* 添加任务到队列
* @param string $toAccountId 目标账号ID
* @param string $wechatAccountKeyword 微信账号关键字
* @param bool $isDeleted 是否已删除状态
* @param string $jobId 任务ID
* @param string $queueLockKey 队列锁键名
*/
public function addToQueue($toAccountId, $wechatAccountKeyword, $isDeleted = false, $jobId = '', $queueLockKey = '')
{
$data = [
'toAccountId' => $toAccountId,
'wechatAccountKeyword' => $wechatAccountKeyword,
'isDeleted' => $isDeleted,
'jobId' => $jobId,
'queueLockKey' => $queueLockKey
];
// 添加到队列
Queue::push(AllotChatroomJob::class, $data, $this->queueName);
}
}

102
Server/application/command/AllotFriendCommand.php Normal file
View File

@@ -0,0 +1,102 @@
<?php
namespace app\command;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\console\input\Option;
use think\facade\Log;
use think\Queue;
use app\job\AllotFriendJob;
use think\facade\Cache;
class AllotFriendCommand extends Command
{
// 队列名称
protected $queueName = 'allot_friends';
protected function configure()
{
$this->setName('allotFriends:run')
->setDescription('自动分配微信好友')
->addOption('toAccountId', null, Option::VALUE_REQUIRED, '目标账号ID')
->addOption('wechatAccountKeyword', null, Option::VALUE_REQUIRED, '微信账号关键字')
->addOption('isDeleted', null, Option::VALUE_OPTIONAL, '是否已删除状态: 0=未删除(false), 1=已删除(true)', 0)
->addOption('jobId', null, Option::VALUE_OPTIONAL, '任务ID，用于区分不同实例', date('YmdHis') . rand(1000, 9999));
}
protected function execute(Input $input, Output $output)
{
$output->writeln('开始处理微信好友自动分配任务...');
try {
// 获取命令参数
$toAccountId = $input->getOption('toAccountId');
$wechatAccountKeyword = $input->getOption('wechatAccountKeyword');
$isDeleted = $input->getOption('isDeleted');
$jobId = $input->getOption('jobId');
// 验证必填参数
if (empty($toAccountId)) {
$output->writeln('错误: 目标账号ID不能为空');
return false;
}
if (empty($wechatAccountKeyword)) {
$output->writeln('错误: 微信账号关键字不能为空');
return false;
}
$output->writeln('目标账号ID: ' . $toAccountId);
$output->writeln('微信账号关键字: ' . $wechatAccountKeyword);
$output->writeln('删除状态: ' . ($isDeleted ? '已删除' : '未删除'));
$output->writeln('任务ID: ' . $jobId);
// 检查队列是否已经在运行
$queueLockKey = "queue_lock:{$this->queueName}:{$wechatAccountKeyword}";
if (Cache::get($queueLockKey)) {
$output->writeln("队列 {$this->queueName} 已经在运行中，wechatAccountKeyword:{$wechatAccountKeyword}，跳过执行");
Log::warning("队列 {$this->queueName} 已经在运行中，wechatAccountKeyword:{$wechatAccountKeyword}，跳过执行");
return false;
}
// 设置队列运行锁，有效期1小时
Cache::set($queueLockKey, $jobId, 3600);
$output->writeln("已设置队列运行锁，键名:{$queueLockKey}，值:{$jobId}，有效期:1小时");
// 将任务添加到队列
$this->addToQueue($toAccountId, $wechatAccountKeyword, $isDeleted, $jobId, $queueLockKey);
$output->writeln('微信好友自动分配任务已添加到队列');
} catch (\Exception $e) {
Log::error('微信好友自动分配任务添加失败：' . $e->getMessage());
$output->writeln('微信好友自动分配任务添加失败：' . $e->getMessage());
return false;
}
return true;
}
/**
* 添加任务到队列
* @param string $toAccountId 目标账号ID
* @param string $wechatAccountKeyword 微信账号关键字
* @param bool $isDeleted 是否已删除状态
* @param string $jobId 任务ID
* @param string $queueLockKey 队列锁键名
*/
public function addToQueue($toAccountId, $wechatAccountKeyword, $isDeleted = false, $jobId = '', $queueLockKey = '')
{
$data = [
'toAccountId' => $toAccountId,
'wechatAccountKeyword' => $wechatAccountKeyword,
'isDeleted' => $isDeleted,
'jobId' => $jobId,
'queueLockKey' => $queueLockKey
];
// 添加到队列
Queue::push(AllotFriendJob::class, $data, $this->queueName);
}
}

96
Server/application/job/AllotChatroomJob.php Normal file
View File

@@ -0,0 +1,96 @@
<?php
namespace app\job;
use app\command\AllotChatroomCommand;
use think\facade\Log;
use think\facade\Cache;
use think\Queue;
use app\api\controller\AutomaticAssign;
class AllotChatroomJob
{
/**
* 队列执行方法
* @param $job 队列任务
* @param $data 数据
* @return bool
*/
public function fire($job, $data)
{
try {
// 获取数据
$toAccountId = $data['toAccountId'];
$wechatAccountKeyword = $data['wechatAccountKeyword'];
$isDeleted = $data['isDeleted'];
$jobId = isset($data['jobId']) ? $data['jobId'] : '';
$queueLockKey = isset($data['queueLockKey']) ? $data['queueLockKey'] : '';
// 记录日志
Log::info('开始处理微信群聊自动分配任务: ' . json_encode([
'toAccountId' => $toAccountId,
'wechatAccountKeyword' => $wechatAccountKeyword,
'isDeleted' => $isDeleted,
'jobId' => $jobId,
'queueLockKey' => $queueLockKey
]));
// 如果没有提供队列锁键，生成一个
if (empty($queueLockKey)) {
$queueLockKey = "queue_lock:allot_chatroom:{$wechatAccountKeyword}";
}
// 实例化控制器
$automaticAssignController = new AutomaticAssign();
// 调用微信群聊自动分配方法
$result = $automaticAssignController->autoAllotWechatChatroom($toAccountId, $wechatAccountKeyword, $isDeleted);
$response = json_decode($result, true);
// 判断是否成功
if ($response['code'] == 1) {
Log::info("微信群聊自动分配成功: toAccountId={$toAccountId}, wechatAccountKeyword={$wechatAccountKeyword}");
// 释放队列锁
Cache::rm($queueLockKey);
Log::info("任务完成，释放队列锁: {$queueLockKey}");
$job->delete();
return true;
} else {
// API调用出错，记录错误
$errorMsg = isset($response['msg']) ? $response['msg'] : '未知错误';
Log::error("微信群聊自动分配失败: {$errorMsg}");
if ($job->attempts() > 3) {
// 超过重试次数，删除任务并释放队列锁
Cache::rm($queueLockKey);
Log::info("由于错误多次尝试失败，释放队列锁: {$queueLockKey}");
$job->delete();
} else {
// 任务失败，重新放回队列
Log::warning("微信群聊自动分配任务执行失败，重试次数: " . $job->attempts());
$job->release(10); // 延迟10秒后重试
}
return false;
}
} catch (\Exception $e) {
// 出现异常，记录错误并释放队列锁
Log::error('微信群聊自动分配任务异常: ' . $e->getMessage());
if (!empty($queueLockKey)) {
Cache::rm($queueLockKey);
Log::info("由于异常释放队列锁: {$queueLockKey}");
}
if ($job->attempts() > 3) {
$job->delete();
} else {
$job->release(10);
}
return false;
}
}
}

96
Server/application/job/AllotFriendJob.php Normal file
View File

@@ -0,0 +1,96 @@
<?php
namespace app\job;
use app\command\AllotFriendCommand;
use think\facade\Log;
use think\facade\Cache;
use think\Queue;
use app\api\controller\AutomaticAssign;
class AllotFriendJob
{
/**
* 队列执行方法
* @param $job 队列任务
* @param $data 数据
* @return bool
*/
public function fire($job, $data)
{
try {
// 获取数据
$toAccountId = $data['toAccountId'];
$wechatAccountKeyword = $data['wechatAccountKeyword'];
$isDeleted = $data['isDeleted'];
$jobId = isset($data['jobId']) ? $data['jobId'] : '';
$queueLockKey = isset($data['queueLockKey']) ? $data['queueLockKey'] : '';
// 记录日志
Log::info('开始处理微信好友自动分配任务: ' . json_encode([
'toAccountId' => $toAccountId,
'wechatAccountKeyword' => $wechatAccountKeyword,
'isDeleted' => $isDeleted,
'jobId' => $jobId,
'queueLockKey' => $queueLockKey
]));
// 如果没有提供队列锁键，生成一个
if (empty($queueLockKey)) {
$queueLockKey = "queue_lock:allot_friends:{$wechatAccountKeyword}";
}
// 实例化控制器
$automaticAssignController = new AutomaticAssign();
// 调用微信好友自动分配方法
$result = $automaticAssignController->autoAllotWechatFriend($toAccountId, $wechatAccountKeyword, $isDeleted);
$response = json_decode($result, true);
// 判断是否成功
if ($response['code'] == 1) {
Log::info("微信好友自动分配成功: toAccountId={$toAccountId}, wechatAccountKeyword={$wechatAccountKeyword}");
// 释放队列锁
Cache::rm($queueLockKey);
Log::info("任务完成，释放队列锁: {$queueLockKey}");
$job->delete();
return true;
} else {
// API调用出错，记录错误
$errorMsg = isset($response['msg']) ? $response['msg'] : '未知错误';
Log::error("微信好友自动分配失败: {$errorMsg}");
if ($job->attempts() > 3) {
// 超过重试次数，删除任务并释放队列锁
Cache::rm($queueLockKey);
Log::info("由于错误多次尝试失败，释放队列锁: {$queueLockKey}");
$job->delete();
} else {
// 任务失败，重新放回队列
Log::warning("微信好友自动分配任务执行失败，重试次数: " . $job->attempts());
$job->release(10); // 延迟10秒后重试
}
return false;
}
} catch (\Exception $e) {
// 出现异常，记录错误并释放队列锁
Log::error('微信好友自动分配任务异常: ' . $e->getMessage());
if (!empty($queueLockKey)) {
Cache::rm($queueLockKey);
Log::info("由于异常释放队列锁: {$queueLockKey}");
}
if ($job->attempts() > 3) {
$job->delete();
} else {
$job->release(10);
}
return false;
}
}
}