feat: 添加消息日志记录功能,用于调试消息走向
新增功能: 1. 创建 feishu_message_log 表,记录消息发送和更新操作 2. FeishuMessageLog 模型:管理消息日志 3. DebugController:提供调试接口查看日志 使用方式: - GET /debug/message-logs?limit=50 - 查看最近50条日志 - GET /debug/message-logs?order_id=123 - 查看指定订单的日志 - POST /debug/clear-logs - 清空日志 Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
@@ -0,0 +1,64 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace app\controller;
|
||||||
|
|
||||||
|
use support\Request;
|
||||||
|
use support\Response;
|
||||||
|
use app\model\FeishuMessageLog;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 调试控制器 - 仅用于开发调试
|
||||||
|
*/
|
||||||
|
class DebugController
|
||||||
|
{
|
||||||
|
/**
|
||||||
|
* 获取消息日志列表
|
||||||
|
*/
|
||||||
|
public function messageLogs(Request $request): Response
|
||||||
|
{
|
||||||
|
// 仅允许在开发环境访问
|
||||||
|
if (config('app.app_env') !== 'dev' && !$request->get('debug')) {
|
||||||
|
return json(['code' => 403, 'msg' => 'Forbidden']);
|
||||||
|
}
|
||||||
|
|
||||||
|
$limit = (int) $request->get('limit', 50);
|
||||||
|
$orderId = $request->get('order_id');
|
||||||
|
|
||||||
|
$query = FeishuMessageLog::orderBy('created_at', 'desc');
|
||||||
|
|
||||||
|
if ($orderId) {
|
||||||
|
$query->where('order_id', $orderId);
|
||||||
|
}
|
||||||
|
|
||||||
|
$logs = $query->limit($limit)->get()->toArray();
|
||||||
|
|
||||||
|
// 解析 JSON 字段
|
||||||
|
foreach ($logs as &$log) {
|
||||||
|
$log['request_data'] = $log['request_data'] ? json_decode($log['request_data'], true) : null;
|
||||||
|
$log['response_data'] = $log['response_data'] ? json_decode($log['response_data'], true) : null;
|
||||||
|
}
|
||||||
|
|
||||||
|
return json([
|
||||||
|
'code' => 0,
|
||||||
|
'msg' => 'success',
|
||||||
|
'data' => $logs,
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 清空消息日志
|
||||||
|
*/
|
||||||
|
public function clearLogs(Request $request): Response
|
||||||
|
{
|
||||||
|
if (config('app.app_env') !== 'dev' && !$request->get('debug')) {
|
||||||
|
return json(['code' => 403, 'msg' => 'Forbidden']);
|
||||||
|
}
|
||||||
|
|
||||||
|
FeishuMessageLog::query()->delete();
|
||||||
|
|
||||||
|
return json([
|
||||||
|
'code' => 0,
|
||||||
|
'msg' => 'Logs cleared',
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,81 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace app\model;
|
||||||
|
|
||||||
|
use support\Model;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 飞书消息日志模型
|
||||||
|
*/
|
||||||
|
class FeishuMessageLog extends Model
|
||||||
|
{
|
||||||
|
protected $table = 'feishu_message_log';
|
||||||
|
|
||||||
|
protected $fillable = [
|
||||||
|
'order_id',
|
||||||
|
'node_id',
|
||||||
|
'user_id',
|
||||||
|
'message_id',
|
||||||
|
'action',
|
||||||
|
'status',
|
||||||
|
'request_data',
|
||||||
|
'response_data',
|
||||||
|
'error_message',
|
||||||
|
];
|
||||||
|
|
||||||
|
const ACTION_SEND = 'send'; // 发送消息
|
||||||
|
const ACTION_UPDATE = 'update'; // 更新消息
|
||||||
|
const ACTION_UPDATE_CARD = 'update_card'; // 更新卡片
|
||||||
|
|
||||||
|
const STATUS_SUCCESS = 'success';
|
||||||
|
const STATUS_FAILED = 'failed';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 记录日志
|
||||||
|
*/
|
||||||
|
public static function log(
|
||||||
|
string $action,
|
||||||
|
int $orderId,
|
||||||
|
?int $nodeId,
|
||||||
|
?int $userId,
|
||||||
|
?string $messageId,
|
||||||
|
string $status,
|
||||||
|
?array $requestData = null,
|
||||||
|
?array $responseData = null,
|
||||||
|
?string $errorMessage = null
|
||||||
|
): self {
|
||||||
|
return self::create([
|
||||||
|
'action' => $action,
|
||||||
|
'order_id' => $orderId,
|
||||||
|
'node_id' => $nodeId,
|
||||||
|
'user_id' => $userId,
|
||||||
|
'message_id' => $messageId,
|
||||||
|
'status' => $status,
|
||||||
|
'request_data' => $requestData ? json_encode($requestData, JSON_UNESCAPED_UNICODE) : null,
|
||||||
|
'response_data' => $responseData ? json_encode($responseData, JSON_UNESCAPED_UNICODE) : null,
|
||||||
|
'error_message' => $errorMessage,
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 获取最近的日志
|
||||||
|
*/
|
||||||
|
public static function getRecentLogs(int $limit = 50): array
|
||||||
|
{
|
||||||
|
return self::orderBy('created_at', 'desc')
|
||||||
|
->limit($limit)
|
||||||
|
->get()
|
||||||
|
->toArray();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 根据订单获取日志
|
||||||
|
*/
|
||||||
|
public static function getLogsByOrder(int $orderId): array
|
||||||
|
{
|
||||||
|
return self::where('order_id', $orderId)
|
||||||
|
->orderBy('created_at', 'desc')
|
||||||
|
->get()
|
||||||
|
->toArray();
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -160,7 +160,7 @@ class FeishuNotificationService
|
|||||||
|
|
||||||
error_log("📨 发送卡片消息: 不是自审批");
|
error_log("📨 发送卡片消息: 不是自审批");
|
||||||
$card = $this->buildApprovalCard($params, $user->company_id);
|
$card = $this->buildApprovalCard($params, $user->company_id);
|
||||||
$messageId = $this->sendMessage($feishuUserId, $card);
|
$messageId = $this->sendMessage($feishuUserId, $card, $orderId, $nodeId, $userId);
|
||||||
|
|
||||||
if ($messageId && $orderId && $nodeId) {
|
if ($messageId && $orderId && $nodeId) {
|
||||||
// 保存消息映射
|
// 保存消息映射
|
||||||
@@ -552,8 +552,13 @@ class FeishuNotificationService
|
|||||||
* 发送消息到飞书
|
* 发送消息到飞书
|
||||||
* @return string|false 返回 message_id 或 false
|
* @return string|false 返回 message_id 或 false
|
||||||
*/
|
*/
|
||||||
private function sendMessage(string $feishuUserId, array $card)
|
private function sendMessage(string $feishuUserId, array $card, ?int $orderId = null, ?int $nodeId = null, ?int $userId = null)
|
||||||
{
|
{
|
||||||
|
$requestData = [
|
||||||
|
'feishu_user_id' => $feishuUserId,
|
||||||
|
'card' => $card,
|
||||||
|
];
|
||||||
|
|
||||||
try {
|
try {
|
||||||
$app = $this->getAppConfig();
|
$app = $this->getAppConfig();
|
||||||
$token = $this->getAccessToken();
|
$token = $this->getAccessToken();
|
||||||
@@ -580,18 +585,65 @@ class FeishuNotificationService
|
|||||||
|
|
||||||
if ($code !== 0) {
|
if ($code !== 0) {
|
||||||
error_log('❌ 飞书消息发送失败: ' . json_encode($response));
|
error_log('❌ 飞书消息发送失败: ' . json_encode($response));
|
||||||
|
|
||||||
|
// 记录失败日志
|
||||||
|
if ($orderId) {
|
||||||
|
\app\model\FeishuMessageLog::log(
|
||||||
|
\app\model\FeishuMessageLog::ACTION_SEND,
|
||||||
|
$orderId,
|
||||||
|
$nodeId,
|
||||||
|
$userId,
|
||||||
|
null,
|
||||||
|
\app\model\FeishuMessageLog::STATUS_FAILED,
|
||||||
|
$requestData,
|
||||||
|
$response,
|
||||||
|
$response['msg'] ?? 'Unknown error'
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
$messageId = $response['data']['message_id'] ?? null;
|
$messageId = $response['data']['message_id'] ?? null;
|
||||||
if ($messageId) {
|
if ($messageId) {
|
||||||
error_log('✅ 飞书消息发送成功, message_id=' . $messageId);
|
error_log('✅ 飞书消息发送成功, message_id=' . $messageId);
|
||||||
|
|
||||||
|
// 记录成功日志
|
||||||
|
if ($orderId) {
|
||||||
|
\app\model\FeishuMessageLog::log(
|
||||||
|
\app\model\FeishuMessageLog::ACTION_SEND,
|
||||||
|
$orderId,
|
||||||
|
$nodeId,
|
||||||
|
$userId,
|
||||||
|
$messageId,
|
||||||
|
\app\model\FeishuMessageLog::STATUS_SUCCESS,
|
||||||
|
$requestData,
|
||||||
|
$response
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
return $messageId;
|
return $messageId;
|
||||||
}
|
}
|
||||||
|
|
||||||
return false;
|
return false;
|
||||||
} catch (Exception $e) {
|
} catch (Exception $e) {
|
||||||
error_log('❌ sendMessage 异常: ' . $e->getMessage());
|
error_log('❌ sendMessage 异常: ' . $e->getMessage());
|
||||||
|
|
||||||
|
// 记录异常日志
|
||||||
|
if ($orderId) {
|
||||||
|
\app\model\FeishuMessageLog::log(
|
||||||
|
\app\model\FeishuMessageLog::ACTION_SEND,
|
||||||
|
$orderId,
|
||||||
|
$nodeId,
|
||||||
|
$userId,
|
||||||
|
null,
|
||||||
|
\app\model\FeishuMessageLog::STATUS_FAILED,
|
||||||
|
$requestData,
|
||||||
|
null,
|
||||||
|
$e->getMessage()
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -650,6 +702,13 @@ class FeishuNotificationService
|
|||||||
],
|
],
|
||||||
];
|
];
|
||||||
|
|
||||||
|
$requestData = [
|
||||||
|
'message_id' => $message->message_id,
|
||||||
|
'card' => $updatedCard,
|
||||||
|
'status' => $status,
|
||||||
|
'operator' => $operatorName,
|
||||||
|
];
|
||||||
|
|
||||||
$response = HttpClient::httpPost(
|
$response = HttpClient::httpPost(
|
||||||
"https://open.feishu.cn/open-apis/im/v1/messages/{$message->message_id}/update",
|
"https://open.feishu.cn/open-apis/im/v1/messages/{$message->message_id}/update",
|
||||||
[
|
[
|
||||||
@@ -667,11 +726,49 @@ class FeishuNotificationService
|
|||||||
// 标记消息为已更新
|
// 标记消息为已更新
|
||||||
$message->status = \app\model\FeishuMessage::STATUS_UPDATED;
|
$message->status = \app\model\FeishuMessage::STATUS_UPDATED;
|
||||||
$message->save();
|
$message->save();
|
||||||
|
|
||||||
|
// 记录成功日志
|
||||||
|
\app\model\FeishuMessageLog::log(
|
||||||
|
\app\model\FeishuMessageLog::ACTION_UPDATE_CARD,
|
||||||
|
$orderId,
|
||||||
|
$nodeId,
|
||||||
|
$message->user_id,
|
||||||
|
$message->message_id,
|
||||||
|
\app\model\FeishuMessageLog::STATUS_SUCCESS,
|
||||||
|
$requestData,
|
||||||
|
$response
|
||||||
|
);
|
||||||
} else {
|
} else {
|
||||||
error_log("❌ 消息卡片更新失败: message_id={$message->message_id}, error=" . json_encode($response));
|
error_log("❌ 消息卡片更新失败: message_id={$message->message_id}, error=" . json_encode($response));
|
||||||
|
|
||||||
|
// 记录失败日志
|
||||||
|
\app\model\FeishuMessageLog::log(
|
||||||
|
\app\model\FeishuMessageLog::ACTION_UPDATE_CARD,
|
||||||
|
$orderId,
|
||||||
|
$nodeId,
|
||||||
|
$message->user_id,
|
||||||
|
$message->message_id,
|
||||||
|
\app\model\FeishuMessageLog::STATUS_FAILED,
|
||||||
|
$requestData,
|
||||||
|
$response,
|
||||||
|
$response['msg'] ?? 'Unknown error'
|
||||||
|
);
|
||||||
}
|
}
|
||||||
} catch (Exception $e) {
|
} catch (Exception $e) {
|
||||||
error_log("❌ 更新消息卡片异常: message_id={$message->message_id}, error=" . $e->getMessage());
|
error_log("❌ 更新消息卡片异常: message_id={$message->message_id}, error=" . $e->getMessage());
|
||||||
|
|
||||||
|
// 记录异常日志
|
||||||
|
\app\model\FeishuMessageLog::log(
|
||||||
|
\app\model\FeishuMessageLog::ACTION_UPDATE_CARD,
|
||||||
|
$orderId,
|
||||||
|
$nodeId,
|
||||||
|
$message->user_id,
|
||||||
|
$message->message_id,
|
||||||
|
\app\model\FeishuMessageLog::STATUS_FAILED,
|
||||||
|
null,
|
||||||
|
null,
|
||||||
|
$e->getMessage()
|
||||||
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -24,6 +24,12 @@ Route::get('/login/callback', [app\controller\AuthController::class, 'qrcodeLogi
|
|||||||
// 飞书卡片回调(不需要认证,飞书服务器直接调用)
|
// 飞书卡片回调(不需要认证,飞书服务器直接调用)
|
||||||
Route::post('/feishu/card/callback', [app\controller\FeishuCardController::class, 'callback']);
|
Route::post('/feishu/card/callback', [app\controller\FeishuCardController::class, 'callback']);
|
||||||
|
|
||||||
|
// 调试接口(开发环境使用)
|
||||||
|
Route::group('/debug', function () {
|
||||||
|
Route::get('/message-logs', [app\controller\DebugController::class, 'messageLogs']);
|
||||||
|
Route::post('/clear-logs', [app\controller\DebugController::class, 'clearLogs']);
|
||||||
|
});
|
||||||
|
|
||||||
// 用户路由(需要认证)
|
// 用户路由(需要认证)
|
||||||
Route::group('/api/v1/user', function () {
|
Route::group('/api/v1/user', function () {
|
||||||
Route::get('/info', [app\controller\UserController::class, 'info']);
|
Route::get('/info', [app\controller\UserController::class, 'info']);
|
||||||
|
|||||||
Reference in New Issue
Block a user