<?php

/**
 * 飞书消息逻辑完整测试
 * 测试所有消息发送场景
 */

require_once __DIR__ . '/vendor/autoload.php';
require_once __DIR__ . '/support/bootstrap.php';

use app\model\ApprovalOrder;
use app\model\ApprovalFlow;
use app\model\ApprovalNode;
use app\model\ApprovalRecord;
use app\model\FeishuMessage;
use app\model\FeishuMessageLog;
use app\model\User;
use app\service\ApprovalService;
use app\service\FeishuNotificationService;
use support\Db;

echo "====================================\n";
echo "飞书消息逻辑完整测试\n";
echo "====================================\n\n";

// 测试配置
$testApplicantId = 1;  // 李佳博
$testApprover1 = 2;    // 陈兰
$testApprover2 = 3;    // 陈标
$testApprover3 = 4;    // 闫继光00022

// 检查测试用户的飞书 ID
function checkFeishuUserId($userId) {
    $user = User::find($userId);
    if (!$user) {
        echo "❌ 用户 ID {$userId} 不存在\n";
        return false;
    }
    if (empty($user->feishu_user_id)) {
        echo "⚠️  用户 {$user->name} (ID:{$userId}) 没有绑定飞书 ID\n";
        return false;
    }
    echo "✅ 用户 {$user->name} (ID:{$userId}) 飞书 ID: {$user->feishu_user_id}\n";
    return true;
}

echo "检查测试用户:\n";
echo "----------------------------------------\n";
$user1 = checkFeishuUserId($testApplicantId);
$user2 = checkFeishuUserId($testApprover1);
$user3 = checkFeishuUserId($testApprover2);
$user4 = checkFeishuUserId($testApprover3);

if (!$user1 || !$user2 || !$user3) {
    echo "\n⚠️  部分用户没有绑定飞书 ID，将跳过实际 API 调用测试\n";
    $skipApiTest = true;
} else {
    $skipApiTest = false;
}

echo "\n";

// 测试场景
$testResults = [];

// ========== 测试1: 单人审批通知 ==========
echo "【测试1】单人审批通知消息\n";
echo "========================================\n";

try {
    Db::beginTransaction();

    // 查找单人审批节点
    $singleApproverNode = ApprovalNode::where('type', 'approver')->first();
    if (!$singleApproverNode) {
        $singleApproverNode = ApprovalNode::create([
            'flow_id' => 2,
            'name' => '单人审批测试',
            'type' => 'approver',
            'sequence' => 0,
        ]);
    }

    $order = ApprovalOrder::create([
        'business_type' => 'business_trip',
        'business_id' => 2001,
        'title' => '单人审批消息测试',
        'applicant_id' => $testApplicantId,
        'status' => 'pending',
        'current_nodes' => [$singleApproverNode->id],
        'flow_id' => 2,
        'form_data' => ['approvers' => [$testApprover1]],
    ]);

    echo "创建订单: ID={$order->id}, 审批人={$testApprover1}\n";

    // 发送审批通知
    $notificationService = new FeishuNotificationService();
    $result = $notificationService->sendApprovalNotification([
        'user_id' => $testApprover1,
        'applicant_id' => $testApplicantId,
        'title' => '新的审批申请',
        'applicant' => User::find($testApplicantId)->name ?? '未知',
        'type' => '审批测试',
        'content' => '单人审批消息测试',
        'url' => 'https://uniservice-mobile.hnxinyouhe.com/approval/detail/' . $order->id,
        'order_id' => $order->id,
        'node_id' => $singleApproverNode->id,
    ]);

    Db::rollBack(); // 回滚测试数据

    if ($result) {
        echo "✅ 单人审批通知发送成功\n";
        $testResults['test1'] = 'PASS';
    } else {
        echo "⚠️  单人审批通知发送失败\n";
        $testResults['test1'] = 'SKIP';
    }

    // 检查消息日志
    $logs = FeishuMessageLog::where('order_id', $order->id)
        ->where('action', 'send')
        ->get();

    echo "消息日志记录: {$logs->count()} 条\n";

} catch (Exception $e) {
    Db::rollBack();
    echo "❌ 测试1失败: " . $e->getMessage() . "\n";
    $testResults['test1'] = 'FAIL';
}

echo "\n";

// ========== 测试2: 会签审批通知 ==========
echo "【测试2】会签审批通知消息\n";
echo "========================================\n";

try {
    Db::beginTransaction();

    $andApproveNode = ApprovalNode::where('type', 'and_approve')->first();
    if (!$andApproveNode) {
        $andApproveNode = ApprovalNode::create([
            'flow_id' => 2,
            'name' => '会签测试',
            'type' => 'and_approve',
            'sequence' => 0,
        ]);
    }

    $order = ApprovalOrder::create([
        'business_type' => 'business_trip',
        'business_id' => 2002,
        'title' => '会签消息测试',
        'applicant_id' => $testApplicantId,
        'status' => 'pending',
        'current_nodes' => [$andApproveNode->id],
        'flow_id' => 2,
        'form_data' => ['approvers' => [$testApprover1, $testApprover2]],
    ]);

    echo "创建订单: ID={$order->id}, 审批人=[2, 3]\n";

    $notificationService = new FeishuNotificationService();

    // 发送给两个审批人
    $result1 = $notificationService->sendApprovalNotification([
        'user_id' => $testApprover1,
        'applicant_id' => $testApplicantId,
        'title' => '新的审批申请',
        'applicant' => User::find($testApplicantId)->name ?? '未知',
        'type' => '会签测试',
        'content' => '会签消息测试',
        'url' => 'https://uniservice-mobile.hnxinyouhe.com/approval/detail/' . $order->id,
        'order_id' => $order->id,
        'node_id' => $andApproveNode->id,
    ]);

    $result2 = $notificationService->sendApprovalNotification([
        'user_id' => $testApprover2,
        'applicant_id' => $testApplicantId,
        'title' => '新的审批申请',
        'applicant' => User::find($testApplicantId)->name ?? '未知',
        'type' => '会签测试',
        'content' => '会签消息测试',
        'url' => 'https://uniservice-mobile.hnxinyouhe.com/approval/detail/' . $order->id,
        'order_id' => $order->id,
        'node_id' => $andApproveNode->id,
    ]);

    Db::rollBack();

    if ($result1 && $result2) {
        echo "✅ 会签审批通知发送成功（2人）\n";
        $testResults['test2'] = 'PASS';
    } else {
        echo "⚠️  会签审批通知发送失败\n";
        $testResults['test2'] = 'SKIP';
    }

} catch (Exception $e) {
    Db::rollBack();
    echo "❌ 测试2失败: " . $e->getMessage() . "\n";
    $testResults['test2'] = 'FAIL';
}

echo "\n";

// ========== 测试3: 或签审批通知 + 消息更新 ==========
echo "【测试3】或签审批通知 + 消息卡片更新\n";
echo "========================================\n";

try {
    Db::beginTransaction();

    $orApproveNode = ApprovalNode::where('type', 'or_approve')->first();
    if (!$orApproveNode) {
        $orApproveNode = ApprovalNode::create([
            'flow_id' => 2,
            'name' => '或签测试',
            'type' => 'or_approve',
            'sequence' => 0,
        ]);
    }

    $order = ApprovalOrder::create([
        'business_type' => 'business_trip',
        'business_id' => 2003,
        'title' => '或签消息测试',
        'applicant_id' => $testApplicantId,
        'status' => 'pending',
        'current_nodes' => [$orApproveNode->id],
        'flow_id' => 2,
        'form_data' => ['approvers' => [$testApprover1, $testApprover2, $testApprover3]],
    ]);

    echo "创建订单: ID={$order->id}, 审批人=[2, 3, 4]\n";

    $notificationService = new FeishuNotificationService();

    // 发送给三个审批人
    $messageIds = [];
    foreach ([$testApprover1, $testApprover2, $testApprover3] as $approverId) {
        $result = $notificationService->sendApprovalNotification([
            'user_id' => $approverId,
            'applicant_id' => $testApplicantId,
            'title' => '新的审批申请',
            'applicant' => User::find($testApplicantId)->name ?? '未知',
            'type' => '或签测试',
            'content' => '或签消息测试',
            'url' => 'https://uniservice-mobile.hnxinyouhe.com/approval/detail/' . $order->id,
            'order_id' => $order->id,
            'node_id' => $orApproveNode->id,
        ]);

        // 获取消息ID（从日志中）
        $log = FeishuMessageLog::where('order_id', $order->id)
            ->where('user_id', $approverId)
            ->where('action', 'send')
            ->orderBy('id', 'desc')
            ->first();

        if ($log && $log->message_id) {
            $messageIds[$approverId] = $log->message_id;
        }
    }

    echo "发送了 " . count($messageIds) . " 条消息\n";

    // 第一人审批通过
    $approvalService = new ApprovalService();
    $approvalService->approve($order->id, $testApprover1);

    echo "审批人 {$testApprover1} 通过\n";
    $order->refresh();

    echo "订单状态: {$order->status}\n";

    // 检查是否触发了消息更新
    $updateLogs = FeishuMessageLog::where('order_id', $order->id)
        ->where('action', 'update')
        ->get();

    echo "消息更新日志: {$updateLogs->count()} 条\n";

    Db::rollBack();

    if ($order->status === 'approved') {
        echo "✅ 或签审批完成正确\n";
        $testResults['test3_status'] = 'PASS';
    } else {
        echo "❌ 或签审批状态错误: {$order->status}\n";
        $testResults['test3_status'] = 'FAIL';
    }

    if ($updateLogs->count() > 0 || count($messageIds) === 0) {
        // 如果没有消息ID（没有飞书ID），更新日志为0是正常的
        $testResults['test3'] = 'PASS';
    } else {
        $testResults['test3'] = 'SKIP';
    }

} catch (Exception $e) {
    Db::rollBack();
    echo "❌ 测试3失败: " . $e->getMessage() . "\n";
    $testResults['test3'] = 'FAIL';
}

echo "\n";

// ========== 测试4: 审批结果通知（通过） ==========
echo "【测试4】审批结果通知（通过）\n";
echo "========================================\n";

try {
    Db::beginTransaction();

    $andApproveNode = ApprovalNode::where('type', 'and_approve')->first();
    if (!$andApproveNode) {
        echo "跳过：没有会签节点\n";
        $testResults['test4'] = 'SKIP';
    } else {
        $order = ApprovalOrder::create([
            'business_type' => 'business_trip',
            'business_id' => 2004,
            'title' => '结果通知测试',
            'applicant_id' => $testApplicantId,
            'status' => 'pending',
            'current_nodes' => [$andApproveNode->id],
            'flow_id' => 2,
            'form_data' => ['approvers' => [$testApprover1, $testApprover2]],
        ]);

        echo "创建订单: ID={$order->id}\n";

        $approvalService = new ApprovalService();
        $approvalService->approve($order->id, $testApprover1);
        echo "审批人 {$testApprover1} 通过\n";

        $approvalService->approve($order->id, $testApprover2);
        echo "审批人 {$testApprover2} 通过\n";

        $order->refresh();
        echo "订单状态: {$order->status}\n";

        // 检查结果通知
        $resultLogs = FeishuMessageLog::where('order_id', $order->id)
            ->whereIn('action', ['result', 'send'])
            ->get();

        echo "结果通知日志: {$resultLogs->count()} 条\n";

        Db::rollBack();

        if ($order->status === 'approved') {
            echo "✅ 订单状态正确\n";
            $testResults['test4'] = 'PASS';
        } else {
            echo "❌ 订单状态错误\n";
            $testResults['test4'] = 'FAIL';
        }
    }

} catch (Exception $e) {
    Db::rollBack();
    echo "❌ 测试4失败: " . $e->getMessage() . "\n";
    $testResults['test4'] = 'FAIL';
}

echo "\n";

// ========== 测试5: 审批结果通知（拒绝） ==========
echo "【测试5】审批结果通知（拒绝）\n";
echo "========================================\n";

try {
    Db::beginTransaction();

    $andApproveNode = ApprovalNode::where('type', 'and_approve')->first();
    if (!$andApproveNode) {
        echo "跳过：没有会签节点\n";
        $testResults['test5'] = 'SKIP';
    } else {
        $order = ApprovalOrder::create([
            'business_type' => 'business_trip',
            'business_id' => 2005,
            'title' => '拒绝通知测试',
            'applicant_id' => $testApplicantId,
            'status' => 'pending',
            'current_nodes' => [$andApproveNode->id],
            'flow_id' => 2,
            'form_data' => ['approvers' => [$testApprover1, $testApprover2]],
        ]);

        echo "创建订单: ID={$order->id}\n";

        $approvalService = new ApprovalService();
        $approvalService->reject($order->id, $testApprover1, '测试拒绝');

        echo "审批人 {$testApprover1} 拒绝\n";

        $order->refresh();
        echo "订单状态: {$order->status}\n";

        Db::rollBack();

        if ($order->status === 'rejected') {
            echo "✅ 拒绝状态正确\n";
            $testResults['test5'] = 'PASS';
        } else {
            echo "❌ 拒绝状态错误\n";
            $testResults['test5'] = 'FAIL';
        }
    }

} catch (Exception $e) {
    Db::rollBack();
    echo "❌ 测试5失败: " . $e->getMessage() . "\n";
    $testResults['test5'] = 'FAIL';
}

echo "\n";

// ========== 测试6: 撤销通知 ==========
echo "【测试6】撤销通知\n";
echo "========================================\n";

try {
    Db::beginTransaction();

    $andApproveNode = ApprovalNode::where('type', 'and_approve')->first();
    if (!$andApproveNode) {
        echo "跳过：没有会签节点\n";
        $testResults['test6'] = 'SKIP';
    } else {
        $order = ApprovalOrder::create([
            'business_type' => 'business_trip',
            'business_id' => 2006,
            'title' => '撤销通知测试',
            'applicant_id' => $testApplicantId,
            'status' => 'pending',
            'current_nodes' => [$andApproveNode->id],
            'flow_id' => 2,
            'form_data' => ['approvers' => [$testApprover1, $testApprover2]],
        ]);

        echo "创建订单: ID={$order->id}\n";

        $approvalService = new ApprovalService();
        $approvalService->cancel($order->id, $testApplicantId);

        echo "申请人撤销订单\n";

        $order->refresh();
        echo "订单状态: {$order->status}\n";

        Db::rollBack();

        if ($order->status === 'cancelled') {
            echo "✅ 撤销状态正确\n";
            $testResults['test6'] = 'PASS';
        } else {
            echo "❌ 撤销状态错误\n";
            $testResults['test6'] = 'FAIL';
        }
    }

} catch (Exception $e) {
    Db::rollBack();
    echo "❌ 测试6失败: " . $e->getMessage() . "\n";
    $testResults['test6'] = 'FAIL';
}

echo "\n";

// ========== 测试7: 抄送通知 ==========
echo "【测试7】抄送通知\n";
echo "========================================\n";

try {
    Db::beginTransaction();

    $notifyNode = ApprovalNode::where('type', 'notify')->first();
    if (!$notifyNode) {
        echo "跳过：没有通知节点\n";
        $testResults['test7'] = 'SKIP';
    } else {
        $order = ApprovalOrder::create([
            'business_type' => 'business_trip',
            'business_id' => 2007,
            'title' => '抄送测试',
            'applicant_id' => $testApplicantId,
            'status' => 'pending',
            'current_nodes' => [$notifyNode->id],
            'flow_id' => 2,
            'form_data' => ['approvers' => []],
        ]);

        echo "创建订单: ID={$order->id}\n";

        $notificationService = new FeishuNotificationService();
        $result = $notificationService->sendCcNotification([
            'user_id' => $testApprover1,
            'title' => '抄送通知',
            'applicant' => User::find($testApplicantId)->name ?? '未知',
            'type' => '抄送测试',
            'content' => '这是一条抄送消息',
            'url' => 'https://uniservice-mobile.hnxinyouhe.com/approval/detail/' . $order->id,
            'order_id' => $order->id,
            'node_id' => $notifyNode->id,
        ]);

        Db::rollBack();

        if ($result) {
            echo "✅ 抄送通知发送成功\n";
            $testResults['test7'] = 'PASS';
        } else {
            echo "⚠️  抄送通知发送失败\n";
            $testResults['test7'] = 'SKIP';
        }
    }

} catch (Exception $e) {
    Db::rollBack();
    echo "❌ 测试7失败: " . $e->getMessage() . "\n";
    $testResults['test7'] = 'FAIL';
}

echo "\n";

// ========== 测试总结 ==========
echo "====================================\n";
echo "测试总结\n";
echo "====================================\n\n";

$passed = 0;
$failed = 0;
$skipped = 0;

foreach ($testResults as $test => $result) {
    $status = $result === 'PASS' ? '✅ PASS' : ($result === 'FAIL' ? '❌ FAIL' : '⏭️  SKIP');
    echo "{$status}: {$test}\n";

    if ($result === 'PASS') $passed++;
    elseif ($result === 'FAIL') $failed++;
    else $skipped++;
}

echo "\n";
echo "总计: " . count($testResults) . " 个测试\n";
echo "通过: {$passed}\n";
echo "失败: {$failed}\n";
echo "跳过: {$skipped}\n";

echo "\n";

// ========== 检查消息日志表 ==========
echo "====================================\n";
echo "消息日志数据检查\n";
echo "====================================\n\n";

// 因为上面都回滚了，检查最近的真实日志
$allLogs = FeishuMessageLog::orderBy('id', 'desc')->limit(10)->get();

echo "最近 10 条消息日志:\n";
foreach ($allLogs as $log) {
    $statusIcon = $log->status === 'success' ? '✅' : '❌';
    echo "{$statusIcon} [ID:{$log->id}] action={$log->action}, order_id={$log->order_id}, status={$log->status}\n";
    if ($log->error_message) {
        echo "    错误: {$log->error_message}\n";
    }
}

echo "\n";
echo "====================================\n";
echo "测试完成\n";
echo "====================================\n";