root
04947ae52d
- 修改API路径为 /open-apis/im/v1/messages (message/v4已废弃) - 添加卡片config配置 - 修复content格式(直接传卡片对象,不需要包裹) - 添加测试接口 /api/v1/test/notification 测试结果: 成功发送通知到李佳博(feishu_user_id: 481g947d) Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
459 lines
13 KiB
PHP
459 lines
13 KiB
PHP
<?php
|
|
|
|
namespace app\service;
|
|
|
|
use app\model\User;
|
|
use app\model\Company;
|
|
use app\util\FeishuUtil;
|
|
use app\util\HttpClient;
|
|
use Exception;
|
|
|
|
/**
|
|
* 飞书通知服务
|
|
* 提供多种卡片类型的消息通知功能
|
|
*/
|
|
class FeishuNotificationService
|
|
{
|
|
private ?int $companyId = null;
|
|
private ?int $appId = null;
|
|
|
|
/**
|
|
* 设置当前操作的公司
|
|
*/
|
|
public function setCompany(int $companyId): self
|
|
{
|
|
$this->companyId = $companyId;
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* 设置飞书应用ID（支持多应用）
|
|
*/
|
|
public function setApp(int $appId): self
|
|
{
|
|
$this->appId = $appId;
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* 获取飞书应用配置
|
|
*/
|
|
private function getAppConfig(): array
|
|
{
|
|
if (!$this->companyId) {
|
|
throw new Exception('未设置公司ID');
|
|
}
|
|
|
|
if ($this->appId) {
|
|
$app = \app\model\CompanyFeishuApp::find($this->appId);
|
|
if (!$app || $app->status !== 1) {
|
|
throw new Exception('飞书应用配置不存在');
|
|
}
|
|
return $app->toArray();
|
|
}
|
|
|
|
$app = \app\model\CompanyFeishuApp::where('company_id', $this->companyId)
|
|
->where('system_id', 1)
|
|
->where('status', 1)
|
|
->orderBy('sort')
|
|
->first();
|
|
|
|
if (!$app) {
|
|
throw new Exception('未配置飞书应用');
|
|
}
|
|
|
|
return $app->toArray();
|
|
}
|
|
|
|
/**
|
|
* 获取 access_token
|
|
*/
|
|
private function getAccessToken(): string
|
|
{
|
|
$app = $this->getAppConfig();
|
|
return FeishuUtil::getAppAccessToken($app['id']);
|
|
}
|
|
|
|
/**
|
|
* 发送审批通知
|
|
*
|
|
* @param array $params
|
|
* - user_id: 接收人ID
|
|
* - title: 通知标题
|
|
* - applicant: 申请人姓名
|
|
* - type: 申请类型
|
|
* - content: 申请内容摘要
|
|
* - url: 详情链接
|
|
* - approve_url: 通过按钮链接（可选）
|
|
* - reject_url: 拒绝按钮链接（可选）
|
|
* @return bool
|
|
*/
|
|
public function sendApprovalNotification(array $params): bool
|
|
{
|
|
$userId = $params['user_id'] ?? null;
|
|
if (!$userId) {
|
|
error_log('❌ sendApprovalNotification: 缺少 user_id');
|
|
return false;
|
|
}
|
|
|
|
try {
|
|
$user = User::find($userId);
|
|
if (!$user || !$user->feishu_user_id) {
|
|
error_log("❌ sendApprovalNotification: 用户不存在或未绑定飞书, user_id={$userId}");
|
|
return false;
|
|
}
|
|
|
|
$card = $this->buildApprovalCard($params);
|
|
return $this->sendMessage($user->feishu_user_id, $card);
|
|
} catch (Exception $e) {
|
|
error_log('❌ sendApprovalNotification 失败: ' . $e->getMessage());
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 发送系统通知
|
|
*
|
|
* @param array $params
|
|
* - user_ids: 接收人ID数组
|
|
* - title: 通知标题
|
|
* - content: 通知内容
|
|
* - url: 跳转链接（可选）
|
|
* @return array 返回每个用户的发送结果
|
|
*/
|
|
public function sendSystemNotification(array $params): array
|
|
{
|
|
$userIds = $params['user_ids'] ?? [];
|
|
if (empty($userIds)) {
|
|
error_log('❌ sendSystemNotification: 缺少 user_ids');
|
|
return [];
|
|
}
|
|
|
|
$results = [];
|
|
foreach ($userIds as $userId) {
|
|
try {
|
|
$user = User::find($userId);
|
|
if (!$user || !$user->feishu_user_id) {
|
|
$results[$userId] = false;
|
|
continue;
|
|
}
|
|
|
|
$card = $this->buildSystemCard($params);
|
|
$results[$userId] = $this->sendMessage($user->feishu_user_id, $card);
|
|
} catch (Exception $e) {
|
|
error_log("❌ sendSystemNotification 失败: user_id={$userId}, error=" . $e->getMessage());
|
|
$results[$userId] = false;
|
|
}
|
|
}
|
|
|
|
return $results;
|
|
}
|
|
|
|
/**
|
|
* 发送提醒通知
|
|
*
|
|
* @param array $params
|
|
* - user_id: 接收人ID
|
|
* - title: 提醒标题
|
|
* - content: 提醒内容
|
|
* - level: 提醒级别 (info/warning/urgent)
|
|
* - url: 跳转链接（可选）
|
|
* @return bool
|
|
*/
|
|
public function sendReminderNotification(array $params): bool
|
|
{
|
|
$userId = $params['user_id'] ?? null;
|
|
if (!$userId) {
|
|
error_log('❌ sendReminderNotification: 缺少 user_id');
|
|
return false;
|
|
}
|
|
|
|
try {
|
|
$user = User::find($userId);
|
|
if (!$user || !$user->feishu_user_id) {
|
|
error_log("❌ sendReminderNotification: 用户不存在或未绑定飞书, user_id={$userId}");
|
|
return false;
|
|
}
|
|
|
|
$card = $this->buildReminderCard($params);
|
|
return $this->sendMessage($user->feishu_user_id, $card);
|
|
} catch (Exception $e) {
|
|
error_log('❌ sendReminderNotification 失败: ' . $e->getMessage());
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 批量发送通知
|
|
*
|
|
* @param array $params
|
|
* - user_ids: 接收人ID数组
|
|
* - type: 通知类型 (approval/system/reminder)
|
|
* - 其他参数根据类型不同而不同
|
|
* @return array
|
|
*/
|
|
public function sendBatchNotification(array $params): array
|
|
{
|
|
$userIds = $params['user_ids'] ?? [];
|
|
$type = $params['type'] ?? 'system';
|
|
|
|
$results = [];
|
|
foreach ($userIds as $userId) {
|
|
$notifyParams = array_merge($params, ['user_id' => $userId]);
|
|
unset($notifyParams['user_ids']);
|
|
|
|
switch ($type) {
|
|
case 'approval':
|
|
$results[$userId] = $this->sendApprovalNotification($notifyParams);
|
|
break;
|
|
case 'reminder':
|
|
$results[$userId] = $this->sendReminderNotification($notifyParams);
|
|
break;
|
|
case 'system':
|
|
default:
|
|
$results[$userId] = $this->sendSystemNotification(['user_ids' => [$userId]] + $params)[$userId] ?? false;
|
|
break;
|
|
}
|
|
}
|
|
|
|
return $results;
|
|
}
|
|
|
|
/**
|
|
* 构建审批通知卡片
|
|
*/
|
|
private function buildApprovalCard(array $params): array
|
|
{
|
|
$title = $params['title'] ?? '新的审批申请';
|
|
$applicant = $params['applicant'] ?? '未知';
|
|
$type = $params['type'] ?? '申请';
|
|
$content = $params['content'] ?? '';
|
|
$url = $params['url'] ?? '';
|
|
|
|
// 简化版卡片，先测试
|
|
$elements = [];
|
|
|
|
if ($content) {
|
|
$elements[] = [
|
|
'tag' => 'div',
|
|
'text' => [
|
|
'content' => "**申请人**: {$applicant}\n**申请类型**: {$type}\n\n{$content}",
|
|
'tag' => 'lark_md',
|
|
],
|
|
];
|
|
} else {
|
|
$elements[] = [
|
|
'tag' => 'div',
|
|
'text' => [
|
|
'content' => "**申请人**: {$applicant}\n**申请类型**: {$type}",
|
|
'tag' => 'lark_md',
|
|
],
|
|
];
|
|
}
|
|
|
|
if ($url) {
|
|
$elements[] = [
|
|
'tag' => 'action',
|
|
'actions' => [
|
|
[
|
|
'tag' => 'button',
|
|
'text' => [
|
|
'content' => '查看详情',
|
|
'tag' => 'plain_text',
|
|
],
|
|
'type' => 'default',
|
|
'url' => $url,
|
|
],
|
|
],
|
|
];
|
|
}
|
|
|
|
return [
|
|
'config' => [
|
|
'wide_screen_mode' => false,
|
|
],
|
|
'header' => [
|
|
'title' => [
|
|
'content' => "📋 {$title}",
|
|
'tag' => 'plain_text',
|
|
],
|
|
'template' => 'blue',
|
|
],
|
|
'elements' => $elements,
|
|
];
|
|
}
|
|
|
|
/**
|
|
* 构建系统通知卡片
|
|
*/
|
|
private function buildSystemCard(array $params): array
|
|
{
|
|
$title = $params['title'] ?? '系统通知';
|
|
$content = $params['content'] ?? '';
|
|
$url = $params['url'] ?? '';
|
|
|
|
$elements = [];
|
|
|
|
if ($content) {
|
|
$elements[] = [
|
|
'tag' => 'div',
|
|
'text' => [
|
|
'content' => $content,
|
|
'tag' => 'plain_text',
|
|
],
|
|
];
|
|
}
|
|
|
|
if ($url) {
|
|
$elements[] = [
|
|
'tag' => 'action',
|
|
'actions' => [
|
|
[
|
|
'tag' => 'button',
|
|
'text' => [
|
|
'content' => '查看详情',
|
|
'tag' => 'plain_text',
|
|
],
|
|
'type' => 'default',
|
|
'url' => $url,
|
|
],
|
|
],
|
|
];
|
|
}
|
|
|
|
return [
|
|
'config' => [
|
|
'wide_screen_mode' => false,
|
|
],
|
|
'header' => [
|
|
'title' => [
|
|
'content' => "🔔 {$title}",
|
|
'tag' => 'plain_text',
|
|
],
|
|
'template' => 'gray',
|
|
],
|
|
'elements' => $elements,
|
|
];
|
|
}
|
|
|
|
/**
|
|
* 构建提醒通知卡片
|
|
*/
|
|
private function buildReminderCard(array $params): array
|
|
{
|
|
$title = $params['title'] ?? '提醒';
|
|
$content = $params['content'] ?? '';
|
|
$level = $params['level'] ?? 'info'; // info, warning, urgent
|
|
$url = $params['url'] ?? '';
|
|
|
|
// 根据级别选择模板颜色
|
|
$templateMap = [
|
|
'info' => 'blue',
|
|
'warning' => 'orange',
|
|
'urgent' => 'red',
|
|
];
|
|
$template = $templateMap[$level] ?? 'blue';
|
|
|
|
// 根据级别选择图标
|
|
$iconMap = [
|
|
'info' => '💡',
|
|
'warning' => '⚠️',
|
|
'urgent' => '🚨',
|
|
];
|
|
$icon = $iconMap[$level] ?? '💡';
|
|
|
|
$elements = [];
|
|
|
|
if ($content) {
|
|
$elements[] = [
|
|
'tag' => 'div',
|
|
'text' => [
|
|
'content' => $content,
|
|
'tag' => 'plain_text',
|
|
],
|
|
];
|
|
}
|
|
|
|
if ($url) {
|
|
$elements[] = [
|
|
'tag' => 'action',
|
|
'actions' => [
|
|
[
|
|
'tag' => 'button',
|
|
'text' => [
|
|
'content' => '查看',
|
|
'tag' => 'plain_text',
|
|
],
|
|
'type' => 'primary',
|
|
'url' => $url,
|
|
],
|
|
],
|
|
];
|
|
}
|
|
|
|
return [
|
|
'config' => [
|
|
'wide_screen_mode' => false,
|
|
],
|
|
'header' => [
|
|
'title' => [
|
|
'content' => "{$icon} {$title}",
|
|
'tag' => 'plain_text',
|
|
],
|
|
'template' => $template,
|
|
],
|
|
'elements' => $elements,
|
|
];
|
|
}
|
|
|
|
/**
|
|
* 发送消息到飞书
|
|
*/
|
|
private function sendMessage(string $feishuUserId, array $card): bool
|
|
{
|
|
try {
|
|
$app = $this->getAppConfig();
|
|
$token = $this->getAccessToken();
|
|
|
|
$body = [
|
|
'receive_id_type' => 'user_id',
|
|
'receive_id' => $feishuUserId,
|
|
'msg_type' => 'interactive',
|
|
'content' => json_encode(['card' => $card]),
|
|
];
|
|
|
|
error_log('📤 发送飞书消息: app_id=' . $app['app_id'] . ', feishu_user_id=' . $feishuUserId);
|
|
error_log('📦 消息卡片: ' . json_encode($card, JSON_UNESCAPED_UNICODE));
|
|
|
|
$content = json_encode($card);
|
|
error_log('📤 发送的content: ' . $content);
|
|
|
|
$response = HttpClient::httpPost(
|
|
"https://open.feishu.cn/open-apis/im/v1/messages?receive_id_type=user_id",
|
|
[
|
|
'receive_id' => $feishuUserId,
|
|
'msg_type' => 'interactive',
|
|
'content' => $content,
|
|
],
|
|
[
|
|
'Authorization: Bearer ' . $token,
|
|
]
|
|
);
|
|
|
|
$code = $response['code'] ?? -1;
|
|
error_log('📥 飞书响应: code=' . $code . ', msg=' . ($response['msg'] ?? 'null'));
|
|
|
|
if ($code !== 0) {
|
|
error_log('❌ 飞书消息发送失败: ' . json_encode($response));
|
|
} else {
|
|
error_log('✅ 飞书消息发送成功');
|
|
}
|
|
|
|
return $code === 0;
|
|
} catch (Exception $e) {
|
|
error_log('❌ sendMessage 异常: ' . $e->getMessage());
|
|
return false;
|
|
}
|
|
}
|
|
}
|