SET NAMES utf8mb4;
SET CHARACTER SET utf8mb4;
-- ============================================================
--  灵枢智能任务平台 —— 演示数据初始化
--  执行前请确保已执行 灵枢数据库设计.sql
-- ============================================================

USE lingshu;

-- ── 1. 用户 ──────────────────────────────────────────────────
INSERT INTO users (id, username, display_name, password_hash, avatar_color) VALUES
(1, 'wangpai',  '王牌参谋', '$2b$12$placeholder_hash', '#3b82f6'),
(2, 'liming',   '李明',     '$2b$12$placeholder_hash', '#8b5cf6'),
(3, 'zhaoqiang','赵强',     '$2b$12$placeholder_hash', '#10b981')
ON DUPLICATE KEY UPDATE display_name=VALUES(display_name);

-- ── 2. 团队 ──────────────────────────────────────────────────
INSERT INTO teams (id, team_code, team_name, description, owner_id) VALUES
(1, 'T-9082', '灵枢作战团队', '负责全域智能任务编排与情报处理', 1)
ON DUPLICATE KEY UPDATE team_name=VALUES(team_name);

-- ── 3. 团队成员 ──────────────────────────────────────────────
INSERT INTO team_members (team_id, user_id, role, is_online) VALUES
(1, 1, 'admin',  1),
(1, 2, 'editor', 1),
(1, 3, 'viewer', 0)
ON DUPLICATE KEY UPDATE role=VALUES(role);

-- ── 4. 数据源 ─────────────────────────────────────────────────
INSERT INTO datasources (owner_id, team_id, name, ds_type, host, database_name, username, credential_enc, connection_status) VALUES
(1, 1, '核心战情数据库 (MySQL)', 'mysql', '192.168.1.100:3306', 'lingshu', 'db_admin', 'cGxhY2Vob2xkZXI=', 'ok')
ON DUPLICATE KEY UPDATE name=VALUES(name);

-- ── 5. 任务 ───────────────────────────────────────────────────
-- 需要先有 agent id，取已插入的 agent
SET @agent_cv = (SELECT id FROM agents WHERE agent_code='a2-cv-target-detect' LIMIT 1);
SET @agent_llm = (SELECT id FROM agents WHERE agent_code='a1-qwen-summarize' LIMIT 1);
SET @agent_db = (SELECT id FROM agents WHERE agent_code='a3-db-statistics' LIMIT 1);

INSERT INTO tasks (owner_id, team_id, name, cron_expression, agent_id, trigger_type, status) VALUES
(1, 1, '边境巡逻无人机数据处理与告警', '0 */2 * * *', @agent_cv,  'cron', 'running'),
(1, 1, '每日战备情报自动分发',           '0 6 * * *',   @agent_llm, 'cron', 'running'),
(1, 1, '某型装备健康度定时评估',         '0 0 * * 0',   @agent_db,  'cron', 'stopped')
ON DUPLICATE KEY UPDATE status=VALUES(status);

-- ── 6. 执行记录与日志（最近几条演示数据） ─────────────────────
SET @task1_id = (SELECT id FROM tasks WHERE name='边境巡逻无人机数据处理与告警' LIMIT 1);

INSERT INTO task_executions (task_id, trigger_type, status, started_at, ended_at, duration_ms, cpu_usage_pct, memory_usage_pct) VALUES
(@task1_id, 'cron', 'success', NOW() - INTERVAL 2 HOUR, NOW() - INTERVAL 2 HOUR + INTERVAL 1 SECOND, 1150, 42.5, 68.3),
(@task1_id, 'cron', 'success', NOW() - INTERVAL 4 HOUR, NOW() - INTERVAL 4 HOUR + INTERVAL 1 SECOND, 1080, 38.2, 65.1),
(@task1_id, 'cron', 'failed',  NOW() - INTERVAL 6 HOUR, NOW() - INTERVAL 6 HOUR + INTERVAL 5 SECOND, NULL, NULL, NULL);

SET @exec1_id = (SELECT id FROM task_executions WHERE task_id=@task1_id ORDER BY started_at DESC LIMIT 1 OFFSET 2);

INSERT INTO task_logs (execution_id, task_id, log_level, log_time, message, node_name) VALUES
(@exec1_id, @task1_id, 'info',    NOW() - INTERVAL 2 HOUR,                      'Task Workflow Triggered',                    'Cron定时触发'),
(@exec1_id, @task1_id, 'info',    NOW() - INTERVAL 2 HOUR + INTERVAL 1 SECOND,  'Initializing node context... OK',            'Cron定时触发'),
(@exec1_id, @task1_id, 'info',    NOW() - INTERVAL 2 HOUR + INTERVAL 2 SECOND,  'Fetching UAV data stream... 32 frames',      '图像目标检测'),
(@exec1_id, @task1_id, 'info',    NOW() - INTERVAL 2 HOUR + INTERVAL 3 SECOND,  'Invoking Vision AI Agent (CV-Model)...',     '图像目标检测'),
(@exec1_id, @task1_id, 'success', NOW() - INTERVAL 2 HOUR + INTERVAL 4 SECOND,  'Agent analysis complete. Targets found: 2', '图像目标检测'),
(@exec1_id, @task1_id, 'info',    NOW() - INTERVAL 2 HOUR + INTERVAL 5 SECOND,  'Writing results to database...',             '写入数据库'),
(@exec1_id, @task1_id, 'success', NOW() - INTERVAL 2 HOUR + INTERVAL 6 SECOND,  'Task workflow finished in 1.15 seconds',     '写入数据库');

-- ── 7. 团队共享资源 ───────────────────────────────────────────
SET @tpl1_id = (SELECT id FROM task_templates LIMIT 1);
-- 仅在有模板时插入
INSERT INTO team_shared_resources (team_id, resource_type, resource_id, resource_name, shared_by, usage_count)
SELECT 1, 'task_template', id, title, 1, 45 FROM task_templates LIMIT 2
ON DUPLICATE KEY UPDATE usage_count=VALUES(usage_count);

-- ── 8. 团队审计日志 ───────────────────────────────────────────
INSERT INTO team_audit_logs (team_id, user_id, action, resource_type) VALUES
(1, 1, '创建了任务「边境巡逻无人机数据处理与告警」', 'task'),
(1, 2, '修改了流程编排「情报分发流程」', 'task'),
(1, 3, '查看了监控日志', 'task_log'),
(1, 1, '发布了模板到任务广场', 'task_template'),
(1, 2, '启动了任务「每日战备情报自动分发」', 'task');

-- ── 9. 团队留言 ───────────────────────────────────────────────
INSERT INTO team_comments (team_id, user_id, content) VALUES
(1, 2, '今天的情报摘要格式需要调整一下，加上来源标注。'),
(1, 1, '已修改模板，增加了一个来源字段节点。');

-- ── 10. 每日统计（供工作台图表） ─────────────────────────────
INSERT INTO daily_stats (stat_date, user_id, total_executions, success_count, fail_count, avg_duration_ms) VALUES
(CURDATE() - INTERVAL 6 DAY, 1, 12, 11, 1, 1200),
(CURDATE() - INTERVAL 5 DAY, 1, 18, 17, 1, 1100),
(CURDATE() - INTERVAL 4 DAY, 1, 15, 15, 0, 980),
(CURDATE() - INTERVAL 3 DAY, 1, 22, 20, 2, 1350),
(CURDATE() - INTERVAL 2 DAY, 1, 19, 18, 1, 1050),
(CURDATE() - INTERVAL 1 DAY, 1, 25, 24, 1, 1080),
(CURDATE(),                   1, 20, 19, 1, 1150)
ON DUPLICATE KEY UPDATE total_executions=VALUES(total_executions), success_count=VALUES(success_count), fail_count=VALUES(fail_count);

SELECT '演示数据初始化完成！' AS result;