1830 lines
77 KiB
Python
1830 lines
77 KiB
Python
#!/usr/bin/env python3
|
||
"""
|
||
项目服务管理面板 v2.1.0
|
||
端口: 19013
|
||
修复: 后台链接使用 externalIp 替代 localhost
|
||
"""
|
||
|
||
import os
|
||
import json
|
||
import subprocess
|
||
import signal
|
||
import threading
|
||
import sys
|
||
import sqlite3
|
||
import shutil
|
||
import re
|
||
from datetime import datetime
|
||
from flask import Flask, render_template_string, jsonify, request, g
|
||
import urllib.request
|
||
import urllib.error
|
||
|
||
app = Flask(__name__)
|
||
|
||
BASE_DIR = os.path.dirname(os.path.abspath(__file__))
|
||
WORKSPACE_DIR = os.path.dirname(BASE_DIR) # works目录
|
||
ROOT_DIR = os.path.dirname(WORKSPACE_DIR) # workspace-coder目录
|
||
PROJECTS_FILE = os.path.join(BASE_DIR, 'projects.json')
|
||
LOG_FILE = os.path.join(BASE_DIR, 'logs', 'app.log')
|
||
DB_FILE = os.path.join(BASE_DIR, 'cron_manager.db')
|
||
CRON_BACKUP_DIR = os.path.join(BASE_DIR, 'cron_backups')
|
||
|
||
# 进程状态缓存
|
||
process_cache = {}
|
||
|
||
|
||
def get_db():
|
||
"""获取数据库连接"""
|
||
if 'db' not in g:
|
||
g.db = sqlite3.connect(DB_FILE)
|
||
g.db.row_factory = sqlite3.Row
|
||
return g.db
|
||
|
||
|
||
@app.teardown_appcontext
|
||
def close_db(error):
|
||
"""关闭数据库连接"""
|
||
if hasattr(g, 'db'):
|
||
g.db.close()
|
||
|
||
|
||
def init_db():
|
||
"""初始化数据库"""
|
||
conn = sqlite3.connect(DB_FILE)
|
||
conn.row_factory = sqlite3.Row
|
||
c = conn.cursor()
|
||
|
||
# Cron 任务表
|
||
c.execute('''CREATE TABLE IF NOT EXISTS cron_tasks (
|
||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||
name TEXT NOT NULL,
|
||
expression TEXT NOT NULL,
|
||
command TEXT NOT NULL,
|
||
description TEXT,
|
||
category TEXT DEFAULT 'other',
|
||
enabled INTEGER DEFAULT 1,
|
||
created_at TEXT DEFAULT CURRENT_TIMESTAMP,
|
||
updated_at TEXT DEFAULT CURRENT_TIMESTAMP
|
||
)''')
|
||
|
||
# Cron 历史版本表
|
||
c.execute('''CREATE TABLE IF NOT EXISTS cron_history (
|
||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||
task_id INTEGER NOT NULL,
|
||
version INTEGER NOT NULL,
|
||
name TEXT,
|
||
expression TEXT,
|
||
command TEXT,
|
||
description TEXT,
|
||
category TEXT,
|
||
enabled INTEGER,
|
||
operation TEXT,
|
||
operator TEXT DEFAULT 'system',
|
||
created_at TEXT DEFAULT CURRENT_TIMESTAMP,
|
||
FOREIGN KEY (task_id) REFERENCES cron_tasks(id)
|
||
)''')
|
||
|
||
# Cron 执行日志表
|
||
c.execute('''CREATE TABLE IF NOT EXISTS cron_logs (
|
||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||
task_id INTEGER,
|
||
execution_time TEXT DEFAULT CURRENT_TIMESTAMP,
|
||
status TEXT,
|
||
output TEXT,
|
||
FOREIGN KEY (task_id) REFERENCES cron_tasks(id)
|
||
)''')
|
||
|
||
# 创建索引
|
||
c.execute('CREATE INDEX IF NOT EXISTS idx_cron_history_task ON cron_history(task_id)')
|
||
c.execute('CREATE INDEX IF NOT EXISTS idx_cron_logs_task ON cron_logs(task_id)')
|
||
|
||
conn.commit()
|
||
conn.close()
|
||
|
||
|
||
def log_message(msg):
|
||
"""写入日志"""
|
||
timestamp = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
|
||
log_line = f"[{timestamp}] {msg}\n"
|
||
print(log_line.strip())
|
||
try:
|
||
os.makedirs(os.path.dirname(LOG_FILE), exist_ok=True)
|
||
with open(LOG_FILE, 'a') as f:
|
||
f.write(log_line)
|
||
except:
|
||
pass
|
||
|
||
|
||
def signal_handler(signum, frame):
|
||
"""处理信号"""
|
||
signal_names = {
|
||
signal.SIGTERM: 'SIGTERM',
|
||
signal.SIGINT: 'SIGINT',
|
||
signal.SIGHUP: 'SIGHUP',
|
||
}
|
||
sig_name = signal_names.get(signum, f'SIGNAL_{signum}')
|
||
log_message(f"⚠️ 进程收到 {sig_name} 信号，即将退出!")
|
||
sys.exit(0)
|
||
|
||
|
||
signal.signal(signal.SIGTERM, signal_handler)
|
||
signal.signal(signal.SIGINT, signal_handler)
|
||
try:
|
||
signal.signal(signal.SIGHUP, signal_handler)
|
||
except:
|
||
pass
|
||
|
||
|
||
def load_projects():
|
||
"""加载项目配置"""
|
||
with open(PROJECTS_FILE, 'r', encoding='utf-8') as f:
|
||
return json.load(f)['projects']
|
||
|
||
|
||
def save_projects(projects):
|
||
"""保存项目配置"""
|
||
with open(PROJECTS_FILE, 'w', encoding='utf-8') as f:
|
||
json.dump({'projects': projects}, f, ensure_ascii=False, indent=2)
|
||
|
||
|
||
def check_port(port):
|
||
"""检查端口是否有进程监听"""
|
||
try:
|
||
import socket
|
||
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
||
sock.settimeout(1)
|
||
result = sock.connect_ex(('localhost', port))
|
||
sock.close()
|
||
return result == 0
|
||
except:
|
||
return False
|
||
|
||
|
||
def check_health(url):
|
||
"""检查健康检查URL"""
|
||
try:
|
||
req = urllib.request.Request(url, method='GET')
|
||
with urllib.request.urlopen(req, timeout=3) as response:
|
||
return response.status == 200
|
||
except:
|
||
return False
|
||
|
||
|
||
def get_process_on_port(port):
|
||
"""获取占用端口的进程信息"""
|
||
try:
|
||
result = subprocess.run(
|
||
f"lsof -i :{port} -t 2>/dev/null | head -1",
|
||
shell=True, capture_output=True, text=True, timeout=5
|
||
)
|
||
pid = result.stdout.strip()
|
||
if pid:
|
||
cmd_result = subprocess.run(
|
||
f"ps -p {pid} -o pid,ppid,user,cmd --no-headers 2>/dev/null",
|
||
shell=True, capture_output=True, text=True
|
||
)
|
||
return {'pid': int(pid), 'info': cmd_result.stdout.strip()}
|
||
except:
|
||
pass
|
||
return None
|
||
|
||
|
||
def get_project_status(project):
|
||
"""获取项目状态"""
|
||
project_type = project.get('type', 'web')
|
||
|
||
if project_type == 'web':
|
||
ports = project.get('ports', [])
|
||
if not ports:
|
||
return {'status': 'unknown', 'message': '未配置端口'}
|
||
|
||
port_status = {}
|
||
all_running = True
|
||
for port in ports:
|
||
running = check_port(port)
|
||
port_status[port] = {'running': running, 'process': get_process_on_port(port) if running else None}
|
||
if not running:
|
||
all_running = False
|
||
|
||
health_ok = None
|
||
if all_running and project.get('health_url'):
|
||
health_ok = check_health(project['health_url'])
|
||
|
||
return {
|
||
'status': 'running' if all_running else ('partial' if any(p['running'] for p in port_status.values()) else 'stopped'),
|
||
'ports': port_status,
|
||
'health': health_ok
|
||
}
|
||
|
||
elif project_type == 'cron':
|
||
cron_expr = project.get('cron', '')
|
||
cron_cmd = project.get('cron_cmd', '')
|
||
try:
|
||
result = subprocess.run(f"crontab -l 2>/dev/null | grep -F '{cron_cmd}'", shell=True, capture_output=True, text=True)
|
||
cron_configured = bool(result.stdout.strip())
|
||
except:
|
||
cron_configured = False
|
||
return {'status': 'configured' if cron_configured else 'not_configured', 'cron': cron_expr, 'cron_configured': cron_configured}
|
||
|
||
elif project_type == 'extension':
|
||
return {'status': 'completed', 'message': '浏览器插件，手动安装'}
|
||
|
||
elif project_type == 'cli':
|
||
return {'status': 'ready', 'message': '命令行工具，按需运行'}
|
||
|
||
return {'status': 'unknown'}
|
||
|
||
|
||
def run_command(cmd, cwd, project_id, action):
|
||
"""异步执行命令"""
|
||
def _run():
|
||
try:
|
||
log_file = os.path.join(BASE_DIR, 'logs', f'{project_id}.log')
|
||
os.makedirs(os.path.dirname(log_file), exist_ok=True)
|
||
|
||
with open(log_file, 'a') as f:
|
||
f.write(f"\n{'='*50}\n[{datetime.now().isoformat()}] {action}\nCommand: {cmd}\nDirectory: {cwd}\n")
|
||
|
||
process = subprocess.Popen(cmd, shell=True, cwd=cwd, stdout=open(log_file, 'a'), stderr=subprocess.STDOUT, start_new_session=True)
|
||
process_cache[project_id] = process.pid
|
||
except Exception as e:
|
||
with open(os.path.join(BASE_DIR, 'logs', 'error.log'), 'a') as f:
|
||
f.write(f"[{datetime.now().isoformat()}] Error: {e}\n")
|
||
|
||
thread = threading.Thread(target=_run)
|
||
thread.daemon = True
|
||
thread.start()
|
||
|
||
|
||
def stop_process(port):
|
||
"""停止占用端口的进程"""
|
||
try:
|
||
result = subprocess.run(f"lsof -i :{port} -t 2>/dev/null", shell=True, capture_output=True, text=True, timeout=5)
|
||
pids = [p for p in result.stdout.strip().split('\n') if p]
|
||
for pid in pids:
|
||
try:
|
||
os.kill(int(pid), signal.SIGTERM)
|
||
except:
|
||
pass
|
||
return len(pids)
|
||
except:
|
||
return 0
|
||
|
||
|
||
# ==================== Cron 管理 API ====================
|
||
|
||
def backup_crontab():
|
||
"""备份当前 crontab"""
|
||
os.makedirs(CRON_BACKUP_DIR, exist_ok=True)
|
||
timestamp = datetime.now().strftime('%Y%m%d_%H%M%S')
|
||
backup_file = os.path.join(CRON_BACKUP_DIR, f'crontab_{timestamp}.txt')
|
||
try:
|
||
result = subprocess.run("crontab -l 2>/dev/null", shell=True, capture_output=True, text=True)
|
||
with open(backup_file, 'w') as f:
|
||
f.write(result.stdout)
|
||
return backup_file
|
||
except:
|
||
return None
|
||
|
||
|
||
def sync_crontab_from_db():
|
||
"""从数据库同步到系统 crontab"""
|
||
db = get_db()
|
||
c = db.cursor()
|
||
c.execute("SELECT expression, command, enabled FROM cron_tasks WHERE enabled = 1")
|
||
tasks = c.fetchall()
|
||
|
||
lines = []
|
||
for task in tasks:
|
||
lines.append(f"{task['expression']} {task['command']}")
|
||
|
||
# 写入临时文件
|
||
tmp_file = '/tmp/crontab_sync.tmp'
|
||
with open(tmp_file, 'w') as f:
|
||
f.write('\n'.join(lines) + '\n')
|
||
|
||
# 安装 crontab
|
||
subprocess.run(f"crontab {tmp_file}", shell=True)
|
||
os.remove(tmp_file)
|
||
|
||
# 备份
|
||
backup_crontab()
|
||
|
||
|
||
def get_system_crons():
|
||
"""获取系统所有 cron 任务"""
|
||
crons = []
|
||
|
||
try:
|
||
result = subprocess.run("crontab -l 2>/dev/null", shell=True, capture_output=True, text=True, timeout=5)
|
||
for line in result.stdout.strip().split('\n'):
|
||
line = line.strip()
|
||
if line and not line.startswith('#'):
|
||
parts = line.split()
|
||
if len(parts) >= 6:
|
||
crons.append({'source': 'user', 'expression': ' '.join(parts[:5]), 'command': ' '.join(parts[5:]), 'line': line})
|
||
except:
|
||
pass
|
||
|
||
try:
|
||
if os.path.exists('/etc/crontab'):
|
||
with open('/etc/crontab', 'r') as f:
|
||
for line in f:
|
||
line = line.strip()
|
||
if line and not line.startswith('#'):
|
||
parts = line.split()
|
||
if len(parts) >= 7:
|
||
crons.append({'source': 'system', 'expression': ' '.join(parts[:5]), 'user': parts[5], 'command': ' '.join(parts[6:]), 'line': line})
|
||
except:
|
||
pass
|
||
|
||
try:
|
||
if os.path.exists('/etc/cron.d'):
|
||
for filename in os.listdir('/etc/cron.d'):
|
||
filepath = os.path.join('/etc/cron.d', filename)
|
||
if os.path.isfile(filepath):
|
||
with open(filepath, 'r') as f:
|
||
for line in f:
|
||
line = line.strip()
|
||
if line and not line.startswith('#'):
|
||
parts = line.split()
|
||
if len(parts) >= 7:
|
||
crons.append({'source': 'cron.d', 'file': filename, 'expression': ' '.join(parts[:5]), 'user': parts[5], 'command': ' '.join(parts[6:]), 'line': line})
|
||
except:
|
||
pass
|
||
|
||
return crons
|
||
|
||
|
||
def parse_cron_expression(expr):
|
||
"""解析 cron 表达式为人类可读格式"""
|
||
parts = expr.split()
|
||
if len(parts) != 5:
|
||
return expr
|
||
|
||
minute, hour, day, month, weekday = parts
|
||
desc = []
|
||
|
||
if minute == '*':
|
||
desc.append('每分钟')
|
||
elif minute.startswith('*/'):
|
||
desc.append(f'每{minute[2:]}分钟')
|
||
else:
|
||
desc.append(f'{minute}分')
|
||
|
||
if hour != '*':
|
||
if minute == '*':
|
||
desc = [f'{hour}点每分钟']
|
||
else:
|
||
desc = [f'{hour}点{minute}分']
|
||
|
||
if day != '*':
|
||
desc.append(f'{day}号')
|
||
|
||
if month != '*':
|
||
desc.append(f'{month}月')
|
||
|
||
if weekday != '*':
|
||
weekdays = ['周日', '周一', '周二', '周三', '周四', '周五', '周六']
|
||
try:
|
||
desc.append(weekdays[int(weekday)])
|
||
except:
|
||
desc.append(f'周{weekday}')
|
||
|
||
return ' '.join(desc) if desc else expr
|
||
|
||
|
||
def cron_expression_to_human(expr):
|
||
"""更友好的人类可读格式"""
|
||
parts = expr.split()
|
||
if len(parts) != 5:
|
||
return expr
|
||
|
||
minute, hour, day, month, weekday = parts
|
||
|
||
# 特殊模式
|
||
patterns = [
|
||
('0 4 * * *', '每天凌晨4点'),
|
||
('0 0 * * *', '每天午夜0点'),
|
||
('*/5 * * * *', '每5分钟'),
|
||
('*/10 * * * *', '每10分钟'),
|
||
('*/20 * * * *', '每20分钟'),
|
||
('*/30 * * * *', '每30分钟'),
|
||
('0 */1 * * *', '每小时'),
|
||
('0 */2 * * *', '每2小时'),
|
||
('0 9 * * 1', '每周一9点'),
|
||
('0 9 * * 1-5', '每周一到五9点'),
|
||
]
|
||
|
||
for pattern, desc in patterns:
|
||
if expr == pattern:
|
||
return desc
|
||
|
||
# 通用解析
|
||
return parse_cron_expression(expr)
|
||
|
||
|
||
@app.route('/api/cron/tasks')
|
||
def api_cron_tasks():
|
||
"""获取数据库中的 Cron 任务列表"""
|
||
db = get_db()
|
||
c = db.cursor()
|
||
c.execute("SELECT * FROM cron_tasks ORDER BY created_at DESC")
|
||
tasks = [dict(row) for row in c.fetchall()]
|
||
|
||
# 添加人类可读描述和下次执行时间
|
||
for task in tasks:
|
||
task['human_time'] = cron_expression_to_human(task['expression'])
|
||
task['next_run'] = get_next_run_time(task['expression'])
|
||
|
||
return jsonify({'tasks': tasks})
|
||
|
||
|
||
@app.route('/api/cron/tasks', methods=['POST'])
|
||
def api_cron_add():
|
||
"""添加新的 Cron 任务"""
|
||
data = request.json
|
||
|
||
if not data.get('name') or not data.get('expression') or not data.get('command'):
|
||
return jsonify({'error': '缺少必要字段'}), 400
|
||
|
||
db = get_db()
|
||
c = db.cursor()
|
||
|
||
# 插入任务
|
||
c.execute('''INSERT INTO cron_tasks (name, expression, command, description, category, enabled)
|
||
VALUES (?, ?, ?, ?, ?, ?)''',
|
||
(data['name'], data['expression'], data['command'], data.get('description', ''), data.get('category', 'other'), 1))
|
||
|
||
task_id = c.lastrowid
|
||
db.commit()
|
||
|
||
# 记录历史（版本1）
|
||
c.execute('''INSERT INTO cron_history (task_id, version, name, expression, command, description, category, enabled, operation)
|
||
VALUES (?, 1, ?, ?, ?, ?, ?, ?, 'create')''',
|
||
(task_id, data['name'], data['expression'], data['command'], data.get('description', ''), data.get('category', 'other'), 1))
|
||
db.commit()
|
||
|
||
# 同步到系统 crontab
|
||
sync_crontab_from_db()
|
||
|
||
log_message(f"添加 Cron 任务: {data['name']} ({data['expression']})")
|
||
|
||
return jsonify({'message': '任务添加成功', 'task_id': task_id})
|
||
|
||
|
||
@app.route('/api/cron/tasks/<int:task_id>', methods=['PUT'])
|
||
def api_cron_update(task_id):
|
||
"""更新 Cron 任务"""
|
||
data = request.json
|
||
db = get_db()
|
||
c = db.cursor()
|
||
|
||
# 获取当前任务
|
||
c.execute("SELECT * FROM cron_tasks WHERE id = ?", (task_id,))
|
||
old_task = c.fetchone()
|
||
if not old_task:
|
||
return jsonify({'error': '任务不存在'}), 404
|
||
|
||
# 获取当前版本号
|
||
c.execute("SELECT MAX(version) FROM cron_history WHERE task_id = ?", (task_id,))
|
||
max_version = c.fetchone()[0] or 0
|
||
new_version = max_version + 1
|
||
|
||
# 更新任务
|
||
update_fields = []
|
||
update_values = []
|
||
for field in ['name', 'expression', 'command', 'description', 'category', 'enabled']:
|
||
if field in data:
|
||
update_fields.append(f"{field} = ?")
|
||
update_values.append(data[field])
|
||
|
||
if update_fields:
|
||
update_fields.append("updated_at = CURRENT_TIMESTAMP")
|
||
c.execute(f"UPDATE cron_tasks SET {','.join(update_fields)} WHERE id = ?", update_values + [task_id])
|
||
db.commit()
|
||
|
||
# 记录历史
|
||
c.execute('''INSERT INTO cron_history (task_id, version, name, expression, command, description, category, enabled, operation)
|
||
VALUES (?, ?, ?, ?, ?, ?, ?, ?, 'update')''',
|
||
(task_id, new_version, data.get('name', old_task['name']), data.get('expression', old_task['expression']),
|
||
data.get('command', old_task['command']), data.get('description', old_task['description']),
|
||
data.get('category', old_task['category']), data.get('enabled', old_task['enabled'])))
|
||
db.commit()
|
||
|
||
# 同步到系统 crontab
|
||
sync_crontab_from_db()
|
||
|
||
log_message(f"更新 Cron 任务 ID={task_id}: 版本 {new_version}")
|
||
|
||
return jsonify({'message': '任务更新成功', 'version': new_version})
|
||
|
||
|
||
@app.route('/api/cron/tasks/<int:task_id>', methods=['DELETE'])
|
||
def api_cron_delete(task_id):
|
||
"""删除 Cron 任务"""
|
||
db = get_db()
|
||
c = db.cursor()
|
||
|
||
c.execute("SELECT * FROM cron_tasks WHERE id = ?", (task_id,))
|
||
task = c.fetchone()
|
||
if not task:
|
||
return jsonify({'error': '任务不存在'}), 404
|
||
|
||
# 记录删除历史
|
||
c.execute("SELECT MAX(version) FROM cron_history WHERE task_id = ?", (task_id,))
|
||
max_version = c.fetchone()[0] or 0
|
||
|
||
c.execute('''INSERT INTO cron_history (task_id, version, name, expression, command, description, category, enabled, operation)
|
||
VALUES (?, ?, ?, ?, ?, ?, ?, ?, 'delete')''',
|
||
(task_id, max_version + 1, task['name'], task['expression'], task['command'], task['description'], task['category'], task['enabled']))
|
||
db.commit()
|
||
|
||
# 删除任务
|
||
c.execute("DELETE FROM cron_tasks WHERE id = ?", (task_id,))
|
||
db.commit()
|
||
|
||
# 同步到系统 crontab
|
||
sync_crontab_from_db()
|
||
|
||
log_message(f"删除 Cron 任务 ID={task_id}: {task['name']}")
|
||
|
||
return jsonify({'message': '任务删除成功'})
|
||
|
||
|
||
@app.route('/api/cron/tasks/<int:task_id>/toggle', methods=['POST'])
|
||
def api_cron_toggle(task_id):
|
||
"""启用/禁用 Cron 任务"""
|
||
db = get_db()
|
||
c = db.cursor()
|
||
|
||
c.execute("SELECT enabled FROM cron_tasks WHERE id = ?", (task_id,))
|
||
task = c.fetchone()
|
||
if not task:
|
||
return jsonify({'error': '任务不存在'}), 404
|
||
|
||
new_enabled = 0 if task['enabled'] == 1 else 1
|
||
c.execute("UPDATE cron_tasks SET enabled = ?, updated_at = CURRENT_TIMESTAMP WHERE id = ?", (new_enabled, task_id))
|
||
db.commit()
|
||
|
||
# 记录历史
|
||
c.execute("SELECT MAX(version) FROM cron_history WHERE task_id = ?", (task_id,))
|
||
max_version = c.fetchone()[0] or 0
|
||
c.execute('''INSERT INTO cron_history (task_id, version, operation, enabled)
|
||
VALUES (?, ?, ?, ?)''', (task_id, max_version + 1, 'toggle', new_enabled))
|
||
db.commit()
|
||
|
||
# 同步到系统 crontab
|
||
sync_crontab_from_db()
|
||
|
||
log_message(f"切换 Cron 任务 ID={task_id} 状态: {new_enabled}")
|
||
|
||
return jsonify({'message': '状态已切换', 'enabled': new_enabled})
|
||
|
||
|
||
@app.route('/api/cron/tasks/<int:task_id>/history')
|
||
def api_cron_history(task_id):
|
||
"""获取任务历史版本"""
|
||
db = get_db()
|
||
c = db.cursor()
|
||
c.execute("SELECT * FROM cron_history WHERE task_id = ? ORDER BY version DESC", (task_id,))
|
||
history = [dict(row) for row in c.fetchall()]
|
||
|
||
for h in history:
|
||
if h['expression']:
|
||
h['human_time'] = cron_expression_to_human(h['expression'])
|
||
|
||
return jsonify({'history': history})
|
||
|
||
|
||
@app.route('/api/cron/tasks/<int:task_id>/rollback/<int:version>', methods=['POST'])
|
||
def api_cron_rollback(task_id, version):
|
||
"""回退到指定版本"""
|
||
db = get_db()
|
||
c = db.cursor()
|
||
|
||
c.execute("SELECT * FROM cron_history WHERE task_id = ? AND version = ?", (task_id, version))
|
||
history = c.fetchone()
|
||
if not history:
|
||
return jsonify({'error': '版本不存在'}), 404
|
||
|
||
# 更新任务到历史版本
|
||
c.execute('''UPDATE cron_tasks SET name = ?, expression = ?, command = ?, description = ?, category = ?, enabled = ?, updated_at = CURRENT_TIMESTAMP
|
||
WHERE id = ?''',
|
||
(history['name'], history['expression'], history['command'], history['description'], history['category'], history['enabled'], task_id))
|
||
db.commit()
|
||
|
||
# 记录回退操作
|
||
c.execute("SELECT MAX(version) FROM cron_history WHERE task_id = ?", (task_id,))
|
||
max_version = c.fetchone()[0] or 0
|
||
c.execute('''INSERT INTO cron_history (task_id, version, name, expression, command, description, category, enabled, operation)
|
||
VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)''',
|
||
(task_id, max_version + 1, history['name'], history['expression'], history['command'], history['description'], history['category'], history['enabled'], f'rollback to v{version}'))
|
||
db.commit()
|
||
|
||
# 同步到系统 crontab
|
||
sync_crontab_from_db()
|
||
|
||
log_message(f"回退 Cron 任务 ID={task_id} 到版本 {version}")
|
||
|
||
return jsonify({'message': f'已回退到版本 {version}'})
|
||
|
||
|
||
@app.route('/api/cron/tasks/<int:task_id>/logs')
|
||
def api_cron_logs(task_id):
|
||
"""获取任务执行日志"""
|
||
enable_logs = request.args.get('enable', 'true') == 'true'
|
||
|
||
if not enable_logs:
|
||
return jsonify({'logs': [], 'message': '日志功能已关闭'})
|
||
|
||
db = get_db()
|
||
c = db.cursor()
|
||
c.execute("SELECT * FROM cron_logs WHERE task_id = ? ORDER BY execution_time DESC LIMIT 100", (task_id,))
|
||
logs = [dict(row) for row in c.fetchall()]
|
||
|
||
return jsonify({'logs': logs})
|
||
|
||
|
||
@app.route('/api/cron/categories')
|
||
def api_cron_categories():
|
||
"""获取任务分类列表"""
|
||
categories = [
|
||
{'id': 'monitor', 'name': '系统监控', 'icon': 'ri-heart-pulse-line', 'color': 'blue'},
|
||
{'id': 'backup', 'name': '数据备份', 'icon': 'ri-archive-line', 'color': 'green'},
|
||
{'id': 'cleanup', 'name': '清理任务', 'icon': 'ri-delete-bin-line', 'color': 'yellow'},
|
||
{'id': 'report', 'name': '报表生成', 'icon': 'ri-file-chart-line', 'color': 'purple'},
|
||
{'id': 'sync', 'name': '数据同步', 'icon': 'ri-refresh-line', 'color': 'cyan'},
|
||
{'id': 'notification', 'name': '通知提醒', 'icon': 'ri-notification-line', 'color': 'orange'},
|
||
{'id': 'other', 'name': '其他任务', 'icon': 'ri-more-line', 'color': 'gray'},
|
||
]
|
||
return jsonify({'categories': categories})
|
||
|
||
|
||
@app.route('/api/cron/sync', methods=['POST'])
|
||
def api_cron_sync():
|
||
"""从系统 crontab 同步到数据库"""
|
||
crons = get_system_crons()
|
||
user_crons = [c for c in crons if c['source'] == 'user']
|
||
|
||
db = get_db()
|
||
c = db.cursor()
|
||
|
||
synced_count = 0
|
||
for cron in user_crons:
|
||
# 检查是否已存在
|
||
c.execute("SELECT id FROM cron_tasks WHERE expression = ? AND command = ?", (cron['expression'], cron['command']))
|
||
existing = c.fetchone()
|
||
|
||
if not existing:
|
||
# 尝试从命令推断分类和名称
|
||
name = guess_cron_name(cron['command'])
|
||
category = guess_cron_category(cron['command'])
|
||
|
||
c.execute('''INSERT INTO cron_tasks (name, expression, command, description, category, enabled)
|
||
VALUES (?, ?, ?, ?, ?, 1)''',
|
||
(name, cron['expression'], cron['command'], '', category))
|
||
synced_count += 1
|
||
|
||
db.commit()
|
||
|
||
log_message(f"从系统 crontab 同步了 {synced_count} 个任务")
|
||
|
||
return jsonify({'message': f'同步完成，新增 {synced_count} 个任务'})
|
||
|
||
|
||
def guess_cron_name(command):
|
||
"""从命令推断任务名称"""
|
||
keywords = {
|
||
'service-monitor': '服务监控',
|
||
'board_monitor': 'A股板块监控',
|
||
'daily-summary': '每日总结',
|
||
'backup': '数据备份',
|
||
'cleanup': '清理任务',
|
||
'xian-favor': 'Xian Favor 备份',
|
||
}
|
||
|
||
for keyword, name in keywords.items():
|
||
if keyword in command:
|
||
return name
|
||
|
||
# 从文件名推断
|
||
match = re.search(r'/([^/]+\.py)', command)
|
||
if match:
|
||
return match.group(1).replace('.py', '').replace('_', ' ')
|
||
|
||
return '未命名任务'
|
||
|
||
|
||
def guess_cron_category(command):
|
||
"""从命令推断任务分类"""
|
||
if 'monitor' in command or 'check' in command:
|
||
return 'monitor'
|
||
if 'backup' in command:
|
||
return 'backup'
|
||
if 'cleanup' in command or 'clean' in command:
|
||
return 'cleanup'
|
||
if 'report' in command or 'summary' in command:
|
||
return 'report'
|
||
if 'sync' in command:
|
||
return 'sync'
|
||
if 'notify' in command or 'mail' in command:
|
||
return 'notification'
|
||
return 'other'
|
||
|
||
|
||
def get_next_run_time(expression):
|
||
"""获取下次执行时间"""
|
||
try:
|
||
from croniter import croniter
|
||
base = datetime.now()
|
||
cron = croniter(expression, base)
|
||
next_time = cron.get_next(datetime)
|
||
return next_time.strftime('%Y-%m-%d %H:%M:%S')
|
||
except:
|
||
return '无法计算'
|
||
|
||
|
||
@app.route('/api/crons')
|
||
def api_crons():
|
||
"""获取系统 cron 列表（兼容旧接口）"""
|
||
crons = get_system_crons()
|
||
for cron in crons:
|
||
cron['description'] = parse_cron_expression(cron['expression'])
|
||
return jsonify({'crons': crons})
|
||
|
||
|
||
# ==================== 项目管理 API ====================
|
||
|
||
@app.route('/')
|
||
def index():
|
||
return render_template_string(HTML_TEMPLATE)
|
||
|
||
|
||
@app.route('/api/projects')
|
||
def api_projects():
|
||
projects = load_projects()
|
||
for project in projects:
|
||
project['status'] = get_project_status(project)
|
||
return jsonify({'projects': projects})
|
||
|
||
|
||
@app.route('/api/projects/<project_id>')
|
||
def api_project(project_id):
|
||
projects = load_projects()
|
||
project = next((p for p in projects if p['id'] == project_id), None)
|
||
if not project:
|
||
return jsonify({'error': '项目不存在'}), 404
|
||
project['status'] = get_project_status(project)
|
||
return jsonify(project)
|
||
|
||
|
||
@app.route('/api/projects/<project_id>/start', methods=['POST'])
|
||
def api_start(project_id):
|
||
projects = load_projects()
|
||
project = next((p for p in projects if p['id'] == project_id), None)
|
||
if not project:
|
||
return jsonify({'error': '项目不存在'}), 404
|
||
|
||
if project['type'] != 'web':
|
||
return jsonify({'error': '只有Web服务支持启动'}), 400
|
||
|
||
directory = project.get('directory', '')
|
||
if directory.startswith('/'):
|
||
cwd = directory
|
||
else:
|
||
cwd = os.path.join(ROOT_DIR, directory)
|
||
|
||
if not os.path.exists(cwd):
|
||
return jsonify({'error': f'目录不存在: {cwd}'}), 400
|
||
|
||
if project.get('start_cmds'):
|
||
for name, info in project['start_cmds'].items():
|
||
run_command(info['cmd'], cwd, project_id, f'start-{name}')
|
||
else:
|
||
cmd = project.get('start_cmd', 'python3 app.py')
|
||
run_command(cmd, cwd, project_id, 'start')
|
||
|
||
return jsonify({'message': '服务启动中...'})
|
||
|
||
|
||
@app.route('/api/projects/<project_id>/stop', methods=['POST'])
|
||
def api_stop(project_id):
|
||
projects = load_projects()
|
||
project = next((p for p in projects if p['id'] == project_id), None)
|
||
if not project:
|
||
return jsonify({'error': '项目不存在'}), 404
|
||
|
||
if project['type'] != 'web':
|
||
return jsonify({'error': '只有Web服务支持停止'}), 400
|
||
|
||
ports = project.get('ports', [])
|
||
stopped = 0
|
||
for port in ports:
|
||
stopped += stop_process(port)
|
||
|
||
return jsonify({'message': f'已停止 {stopped} 个进程'})
|
||
|
||
|
||
@app.route('/api/projects/<project_id>/run', methods=['POST'])
|
||
def api_run(project_id):
|
||
projects = load_projects()
|
||
project = next((p for p in projects if p['id'] == project_id), None)
|
||
if not project:
|
||
return jsonify({'error': '项目不存在'}), 404
|
||
|
||
if project['type'] != 'cli':
|
||
return jsonify({'error': '只有CLI工具支持运行'}), 400
|
||
|
||
directory = project.get('directory', '')
|
||
if directory.startswith('/'):
|
||
cwd = directory
|
||
else:
|
||
cwd = os.path.join(ROOT_DIR, directory)
|
||
|
||
cmd = project.get('run_cmd', '')
|
||
if not cmd:
|
||
return jsonify({'error': '未配置运行命令'}), 400
|
||
|
||
run_command(cmd, cwd, project_id, 'run')
|
||
return jsonify({'message': 'CLI工具已开始运行...'})
|
||
|
||
|
||
@app.route('/api/projects/<project_id>/log')
|
||
def api_log(project_id):
|
||
log_file = os.path.join(BASE_DIR, 'logs', f'{project_id}.log')
|
||
if os.path.exists(log_file):
|
||
with open(log_file, 'r', encoding='utf-8', errors='ignore') as f:
|
||
lines = f.readlines()[-1000:]
|
||
return jsonify({'log': ''.join(lines)})
|
||
return jsonify({'log': '暂无日志'})
|
||
|
||
|
||
@app.route('/api/projects/add', methods=['POST'])
|
||
def api_add_project():
|
||
data = request.json
|
||
if not data.get('name') or not data.get('type'):
|
||
return jsonify({'error': '缺少必要字段'}), 400
|
||
|
||
projects = load_projects()
|
||
project_id = re.sub(r'[^a-z0-9-]', '-', data['name'].lower())
|
||
|
||
if any(p['id'] == project_id for p in projects):
|
||
return jsonify({'error': '项目ID已存在'}), 400
|
||
|
||
new_project = {
|
||
'id': project_id,
|
||
'name': data['name'],
|
||
'type': data['type'],
|
||
'description': data.get('description', ''),
|
||
'directory': data.get('directory', ''),
|
||
'version': data.get('version', 'v1.0.0'),
|
||
'git_repo': data.get('git_repo'),
|
||
}
|
||
|
||
if data['type'] == 'web':
|
||
new_project['ports'] = data.get('ports', [])
|
||
new_project['start_cmd'] = data.get('start_cmd', 'python3 app.py')
|
||
new_project['health_url'] = data.get('health_url')
|
||
new_project['admin_url'] = data.get('admin_url')
|
||
elif data['type'] == 'cron':
|
||
new_project['cron'] = data.get('cron')
|
||
new_project['cron_cmd'] = data.get('cron_cmd')
|
||
elif data['type'] == 'cli':
|
||
new_project['run_cmd'] = data.get('run_cmd')
|
||
|
||
projects.append(new_project)
|
||
save_projects(projects)
|
||
|
||
return jsonify({'message': '项目添加成功', 'project': new_project})
|
||
|
||
|
||
@app.route('/api/projects/<project_id>', methods=['PUT'])
|
||
def api_update_project(project_id):
|
||
projects = load_projects()
|
||
project = next((p for p in projects if p['id'] == project_id), None)
|
||
if not project:
|
||
return jsonify({'error': '项目不存在'}), 404
|
||
|
||
data = request.json
|
||
for key, value in data.items():
|
||
if key != 'id':
|
||
project[key] = value
|
||
|
||
save_projects(projects)
|
||
return jsonify({'message': '更新成功', 'project': project})
|
||
|
||
|
||
@app.route('/api/projects/<project_id>', methods=['DELETE'])
|
||
def api_delete_project(project_id):
|
||
projects = load_projects()
|
||
project = next((p for p in projects if p['id'] == project_id), None)
|
||
if not project:
|
||
return jsonify({'error': '项目不存在'}), 404
|
||
|
||
projects = [p for p in projects if p['id'] != project_id]
|
||
save_projects(projects)
|
||
return jsonify({'message': '删除成功'})
|
||
|
||
|
||
# ==================== HTML 模板 ====================
|
||
|
||
HTML_TEMPLATE = '''<!DOCTYPE html>
|
||
<html lang="zh-CN">
|
||
<head>
|
||
<meta charset="UTF-8">
|
||
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||
<title>项目服务管理面板 v2.1</title>
|
||
<link rel="icon" href="data:image/svg+xml,<svg xmlns='http://www.w3.org/2000/svg' viewBox='0 0 100 100'><text y='.9em' font-size='90'>📊</text></svg>">
|
||
<script src="https://cdn.tailwindcss.com"></script>
|
||
<link href="https://cdn.jsdelivr.net/npm/remixicon@3.5.0/fonts/remixicon.css" rel="stylesheet">
|
||
<style>
|
||
body { background: #0f172a; }
|
||
.card { background: #1e293b; border: 1px solid #334155; }
|
||
.status-dot { width: 12px; height: 12px; border-radius: 50%; }
|
||
.status-running { background: #22c55e; box-shadow: 0 0 10px #22c55e; }
|
||
.status-stopped { background: #ef4444; }
|
||
.status-partial { background: #f59e0b; }
|
||
.status-ready { background: #3b82f6; }
|
||
.status-configured { background: #22c55e; }
|
||
.status-not-configured { background: #6b7280; }
|
||
.status-completed { background: #8b5cf6; }
|
||
.btn { transition: all 0.2s; }
|
||
.btn:hover { transform: translateY(-1px); }
|
||
.btn:active { transform: translateY(0); }
|
||
.type-badge { font-size: 0.7rem; padding: 2px 6px; border-radius: 4px; }
|
||
.nav-buttons { position: fixed; right: 20px; bottom: 20px; z-index: 100; display: flex; flex-direction: column; gap: 8px; }
|
||
.nav-btn { width: 40px; height: 40px; border-radius: 50%; display: flex; align-items: center; justify-content: center; cursor: pointer; transition: all 0.2s; background: #334155; border: 1px solid #475569; }
|
||
.nav-btn:hover { background: #475569; transform: scale(1.1); }
|
||
.nav-btn i { font-size: 20px; color: #94a3b8; }
|
||
.nav-btn:hover i { color: #f1f5f9; }
|
||
.tab-btn { border-bottom: 2px solid transparent; }
|
||
.tab-btn.active { border-bottom-color: #3b82f6; }
|
||
.cron-card { transition: all 0.2s; }
|
||
.cron-card:hover { border-color: #475569; }
|
||
.history-item { border-left: 3px solid #334155; padding-left: 12px; }
|
||
.history-item.rollback { border-left-color: #f59e0b; }
|
||
.history-item.update { border-left-color: #3b82f6; }
|
||
.history-item.create { border-left-color: #22c55e; }
|
||
.history-item.delete { border-left-color: #ef4444; }
|
||
.history-item.toggle { border-left-color: #8b5cf6; }
|
||
.modal-overlay { position: fixed; inset: 0; background: rgba(0,0,0,0.5); z-index: 50; display: flex; align-items: center; justify-content: center; }
|
||
.modal-content { max-width: 600px; width: 90%; max-height: 80vh; overflow: auto; }
|
||
</style>
|
||
</head>
|
||
<body class="min-h-screen text-gray-100">
|
||
<div class="container mx-auto px-4 py-8">
|
||
<!-- 头部 -->
|
||
<div class="flex items-center justify-between mb-6">
|
||
<div>
|
||
<h1 class="text-3xl font-bold flex items-center gap-3">
|
||
<i class="ri-dashboard-3-line text-blue-400"></i>
|
||
项目服务管理面板
|
||
<span class="text-sm text-gray-500">v2.1</span>
|
||
</h1>
|
||
</div>
|
||
<div class="flex items-center gap-3">
|
||
<div class="flex items-center gap-2">
|
||
<span class="text-gray-400 text-sm">对外IP:</span>
|
||
<input type="text" id="externalIp" value="192.168.2.17" class="bg-gray-700 text-gray-200 px-2 py-1 rounded text-sm w-28" onchange="saveExternalIp()">
|
||
</div>
|
||
<button onclick="refreshAll()" class="btn bg-blue-600 hover:bg-blue-700 px-4 py-2 rounded-lg flex items-center gap-2">
|
||
<i class="ri-refresh-line"></i> 刷新
|
||
</button>
|
||
<div class="flex items-center gap-1">
|
||
<span class="text-gray-400 text-xs">间隔:</span>
|
||
<input type="number" id="refreshInterval" value="30" min="5" max="300" class="bg-gray-700 text-gray-200 px-2 py-1 rounded text-xs w-12" onchange="updateRefreshInterval()">
|
||
<span class="text-gray-500 text-xs">s</span>
|
||
</div>
|
||
<span id="updateTime" class="text-gray-400 text-sm"></span>
|
||
<div id="connectionStatus" class="flex items-center gap-1 px-2 py-1 rounded bg-green-500/20">
|
||
<div class="w-2 h-2 rounded-full bg-green-400 animate-pulse"></div>
|
||
<span class="text-green-400 text-xs">已连接</span>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
|
||
<!-- Tab 切换 -->
|
||
<div class="flex gap-4 mb-6 border-b border-gray-700">
|
||
<button onclick="switchTab('projects')" class="tab-btn active px-4 py-2 text-gray-300 hover:text-white" data-tab="projects">
|
||
<i class="ri-apps-line"></i> 项目服务
|
||
</button>
|
||
<button onclick="switchTab('cron')" class="tab-btn px-4 py-2 text-gray-300 hover:text-white" data-tab="cron">
|
||
<i class="ri-timer-line"></i> Cron 管理
|
||
</button>
|
||
</div>
|
||
|
||
<!-- 项目服务 Tab -->
|
||
<div id="projectsTab">
|
||
<!-- 统计卡片 -->
|
||
<div class="grid grid-cols-2 md:grid-cols-4 gap-4 mb-6">
|
||
<div class="card rounded-xl p-4">
|
||
<div class="flex items-center justify-between">
|
||
<div>
|
||
<p class="text-gray-400 text-sm">Web服务</p>
|
||
<p id="webCount" class="text-2xl font-bold text-blue-400">-</p>
|
||
</div>
|
||
<i class="ri-server-line text-3xl text-blue-400 opacity-50"></i>
|
||
</div>
|
||
</div>
|
||
<div class="card rounded-xl p-4">
|
||
<div class="flex items-center justify-between">
|
||
<div>
|
||
<p class="text-gray-400 text-sm">运行中</p>
|
||
<p id="runningCount" class="text-2xl font-bold text-green-400">-</p>
|
||
</div>
|
||
<i class="ri-play-circle-line text-3xl text-green-400 opacity-50"></i>
|
||
</div>
|
||
</div>
|
||
<div class="card rounded-xl p-4">
|
||
<div class="flex items-center justify-between">
|
||
<div>
|
||
<p class="text-gray-400 text-sm">Cron任务</p>
|
||
<p id="cronCount" class="text-2xl font-bold text-yellow-400">-</p>
|
||
</div>
|
||
<i class="ri-time-line text-3xl text-yellow-400 opacity-50"></i>
|
||
</div>
|
||
</div>
|
||
<div class="card rounded-xl p-4">
|
||
<div class="flex items-center justify-between">
|
||
<div>
|
||
<p class="text-gray-400 text-sm">CLI工具</p>
|
||
<p id="cliCount" class="text-2xl font-bold text-purple-400">-</p>
|
||
</div>
|
||
<i class="ri-terminal-box-line text-3xl text-purple-400 opacity-50"></i>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
|
||
<!-- 筛选器 -->
|
||
<div class="flex gap-2 mb-4">
|
||
<button onclick="filterType('all')" class="filter-btn px-3 py-1 rounded-lg bg-gray-700 hover:bg-gray-600 text-sm" data-type="all">全部</button>
|
||
<button onclick="filterType('web')" class="filter-btn px-3 py-1 rounded-lg bg-gray-700 hover:bg-gray-600 text-sm" data-type="web">Web服务</button>
|
||
<button onclick="filterType('cli')" class="filter-btn px-3 py-1 rounded-lg bg-gray-700 hover:bg-gray-600 text-sm" data-type="cli">CLI工具</button>
|
||
<button onclick="filterType('extension')" class="filter-btn px-3 py-1 rounded-lg bg-gray-700 hover:bg-gray-600 text-sm" data-type="extension">插件</button>
|
||
</div>
|
||
|
||
<!-- 项目列表 -->
|
||
<div id="projectsList" class="space-y-4">
|
||
<div class="text-center py-12 text-gray-400"><i class="ri-loader-4-line text-4xl animate-spin"></i><p class="mt-2">加载中...</p></div>
|
||
</div>
|
||
</div>
|
||
|
||
<!-- Cron 管理 Tab -->
|
||
<div id="cronTab" class="hidden">
|
||
<!-- Cron 统计 -->
|
||
<div class="grid grid-cols-2 md:grid-cols-4 gap-4 mb-6">
|
||
<div class="card rounded-xl p-4">
|
||
<div class="flex items-center justify-between">
|
||
<div>
|
||
<p class="text-gray-400 text-sm">总任务数</p>
|
||
<p id="cronTotal" class="text-2xl font-bold text-orange-400">-</p>
|
||
</div>
|
||
<i class="ri-timer-line text-3xl text-orange-400 opacity-50"></i>
|
||
</div>
|
||
</div>
|
||
<div class="card rounded-xl p-4">
|
||
<div class="flex items-center justify-between">
|
||
<div>
|
||
<p class="text-gray-400 text-sm">启用</p>
|
||
<p id="cronEnabled" class="text-2xl font-bold text-green-400">-</p>
|
||
</div>
|
||
<i class="ri-play-circle-line text-3xl text-green-400 opacity-50"></i>
|
||
</div>
|
||
</div>
|
||
<div class="card rounded-xl p-4">
|
||
<div class="flex items-center justify-between">
|
||
<div>
|
||
<p class="text-gray-400 text-sm">禁用</p>
|
||
<p id="cronDisabled" class="text-2xl font-bold text-red-400">-</p>
|
||
</div>
|
||
<i class="ri-pause-circle-line text-3xl text-red-400 opacity-50"></i>
|
||
</div>
|
||
</div>
|
||
<div class="card rounded-xl p-4">
|
||
<div class="flex items-center justify-between">
|
||
<div>
|
||
<p class="text-gray-400 text-sm">历史记录</p>
|
||
<p id="cronHistoryCount" class="text-2xl font-bold text-purple-400">-</p>
|
||
</div>
|
||
<i class="ri-history-line text-3xl text-purple-400 opacity-50"></i>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
|
||
<!-- Cron 操作按钮 -->
|
||
<div class="flex gap-2 mb-4">
|
||
<button onclick="showAddCronModal()" class="btn bg-green-600 hover:bg-green-700 px-3 py-2 rounded-lg flex items-center gap-1">
|
||
<i class="ri-add-line"></i> 添加任务
|
||
</button>
|
||
<button onclick="syncFromSystem()" class="btn bg-blue-600 hover:bg-blue-700 px-3 py-2 rounded-lg flex items-center gap-1">
|
||
<i class="ri-refresh-line"></i> 从系统同步
|
||
</button>
|
||
<button onclick="loadCronTasks()" class="btn bg-gray-600 hover:bg-gray-700 px-3 py-2 rounded-lg flex items-center gap-1">
|
||
<i class="ri-reload-line"></i> 刷新列表
|
||
</button>
|
||
<div class="flex items-center gap-2 ml-4">
|
||
<span class="text-gray-400 text-sm">执行日志:</span>
|
||
<input type="checkbox" id="enableLogs" onchange="toggleLogs()" class="w-4 h-4">
|
||
</div>
|
||
</div>
|
||
|
||
<!-- Cron 任务列表 -->
|
||
<div id="cronTasksList" class="space-y-3">
|
||
<div class="text-center py-12 text-gray-400"><i class="ri-loader-4-line text-4xl animate-spin"></i><p class="mt-2">加载中...</p></div>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
|
||
<!-- 日志模态框 -->
|
||
<div id="logModal" class="fixed inset-0 bg-black/50 hidden items-center justify-center z-50">
|
||
<div class="card rounded-xl w-11/12 max-w-4xl max-h-[80vh] flex flex-col">
|
||
<div class="flex items-center justify-between p-4 border-b border-gray-700">
|
||
<h3 id="logTitle" class="font-bold text-lg">日志</h3>
|
||
<button onclick="closeLogModal()" class="text-gray-400 hover:text-white"><i class="ri-close-line text-xl"></i></button>
|
||
</div>
|
||
<div class="flex-1 overflow-auto p-4">
|
||
<pre id="logContent" class="text-sm text-gray-300 font-mono whitespace-pre-wrap"></pre>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
|
||
<!-- 添加/编辑 Cron 模态框 -->
|
||
<div id="cronModal" class="modal-overlay hidden">
|
||
<div class="card rounded-xl modal-content p-6">
|
||
<div class="flex items-center justify-between mb-4">
|
||
<h3 id="cronModalTitle" class="font-bold text-lg">添加 Cron 任务</h3>
|
||
<button onclick="closeCronModal()" class="text-gray-400 hover:text-white"><i class="ri-close-line text-xl"></i></button>
|
||
</div>
|
||
|
||
<form id="cronForm" onsubmit="saveCronTask(event)">
|
||
<input type="hidden" id="cronTaskId">
|
||
|
||
<div class="mb-4">
|
||
<label class="block text-gray-400 text-sm mb-1">任务名称 *</label>
|
||
<input type="text" id="cronName" required class="w-full bg-gray-700 text-gray-200 px-3 py-2 rounded-lg" placeholder="例如：服务监控">
|
||
</div>
|
||
|
||
<div class="mb-4">
|
||
<label class="block text-gray-400 text-sm mb-1">时间表达式 *</label>
|
||
<input type="text" id="cronExpression" required class="w-full bg-gray-700 text-gray-200 px-3 py-2 rounded-lg" placeholder="例如：0 4 * * * (每天凌晨4点)">
|
||
<p id="cronHumanTime" class="text-sm text-blue-400 mt-1"></p>
|
||
</div>
|
||
|
||
<div class="mb-4">
|
||
<label class="block text-gray-400 text-sm mb-1">执行命令 *</label>
|
||
<textarea id="cronCommand" required class="w-full bg-gray-700 text-gray-200 px-3 py-2 rounded-lg" rows="3" placeholder="例如：python3 /path/to/script.py"></textarea>
|
||
</div>
|
||
|
||
<div class="mb-4">
|
||
<label class="block text-gray-400 text-sm mb-1">任务分类</label>
|
||
<select id="cronCategory" class="w-full bg-gray-700 text-gray-200 px-3 py-2 rounded-lg">
|
||
<option value="monitor">系统监控</option>
|
||
<option value="backup">数据备份</option>
|
||
<option value="cleanup">清理任务</option>
|
||
<option value="report">报表生成</option>
|
||
<option value="sync">数据同步</option>
|
||
<option value="notification">通知提醒</option>
|
||
<option value="other">其他任务</option>
|
||
</select>
|
||
</div>
|
||
|
||
<div class="mb-4">
|
||
<label class="block text-gray-400 text-sm mb-1">说明备注</label>
|
||
<textarea id="cronDescription" class="w-full bg-gray-700 text-gray-200 px-3 py-2 rounded-lg" rows="2" placeholder="任务的详细说明..."></textarea>
|
||
</div>
|
||
|
||
<div class="flex items-center gap-2 mb-4">
|
||
<input type="checkbox" id="cronEnabled" checked class="w-4 h-4">
|
||
<label class="text-gray-300">启用任务</label>
|
||
</div>
|
||
|
||
<div class="flex justify-end gap-2">
|
||
<button type="button" onclick="closeCronModal()" class="btn bg-gray-600 hover:bg-gray-700 px-4 py-2 rounded-lg">取消</button>
|
||
<button type="submit" class="btn bg-blue-600 hover:bg-blue-700 px-4 py-2 rounded-lg">保存</button>
|
||
</div>
|
||
</form>
|
||
</div>
|
||
</div>
|
||
|
||
<!-- 历史记录模态框 -->
|
||
<div id="historyModal" class="modal-overlay hidden">
|
||
<div class="card rounded-xl modal-content p-6">
|
||
<div class="flex items-center justify-between mb-4">
|
||
<h3 id="historyModalTitle" class="font-bold text-lg">历史版本</h3>
|
||
<button onclick="closeHistoryModal()" class="text-gray-400 hover:text-white"><i class="ri-close-line text-xl"></i></button>
|
||
</div>
|
||
<div id="historyList" class="space-y-3"></div>
|
||
</div>
|
||
</div>
|
||
|
||
<!-- 导航按钮 -->
|
||
<div class="nav-buttons">
|
||
<button onclick="scrollToTop()" class="nav-btn" title="回到顶部"><i class="ri-arrow-up-line"></i></button>
|
||
<button onclick="scrollToBottom()" class="nav-btn" title="滚动到底部"><i class="ri-arrow-down-line"></i></button>
|
||
</div>
|
||
|
||
<script>
|
||
let projects = [];
|
||
let cronTasks = [];
|
||
let currentTab = 'projects';
|
||
let currentFilter = 'all';
|
||
let externalIp = localStorage.getItem('externalIp') || '192.168.2.17';
|
||
let enableLogs = localStorage.getItem('enableLogs') === 'true';
|
||
|
||
document.getElementById('externalIp').value = externalIp;
|
||
document.getElementById('enableLogs').checked = enableLogs;
|
||
|
||
// Tab 切换
|
||
function switchTab(tab) {
|
||
currentTab = tab;
|
||
document.querySelectorAll('.tab-btn').forEach(btn => {
|
||
btn.classList.toggle('active', btn.dataset.tab === tab);
|
||
});
|
||
document.getElementById('projectsTab').classList.toggle('hidden', tab !== 'projects');
|
||
document.getElementById('cronTab').classList.toggle('hidden', tab !== 'cron');
|
||
|
||
if (tab === 'cron') {
|
||
loadCronTasks();
|
||
}
|
||
}
|
||
|
||
// IP 保存
|
||
function saveExternalIp() {
|
||
externalIp = document.getElementById('externalIp').value.trim();
|
||
localStorage.setItem('externalIp', externalIp);
|
||
renderProjects();
|
||
}
|
||
|
||
// 项目加载和渲染（保持原有逻辑）
|
||
async function loadProjects() {
|
||
try {
|
||
const res = await fetch('/api/projects');
|
||
const data = await res.json();
|
||
projects = data.projects;
|
||
renderProjects();
|
||
updateStats();
|
||
updateConnectionStatus(true);
|
||
} catch (e) {
|
||
console.error('加载失败:', e);
|
||
updateConnectionStatus(false);
|
||
}
|
||
}
|
||
|
||
function updateStats() {
|
||
const webProjects = projects.filter(p => p.type === 'web');
|
||
const runningProjects = webProjects.filter(p => p.status?.status === 'running');
|
||
const cronProjects = projects.filter(p => p.type === 'cron');
|
||
const cliProjects = projects.filter(p => p.type === 'cli' || p.type === 'extension');
|
||
|
||
document.getElementById('webCount').textContent = webProjects.length;
|
||
document.getElementById('runningCount').textContent = `${runningProjects.length}/${webProjects.length}`;
|
||
document.getElementById('cronCount').textContent = cronProjects.length;
|
||
document.getElementById('cliCount').textContent = cliProjects.length;
|
||
document.getElementById('updateTime').textContent = new Date().toLocaleTimeString();
|
||
}
|
||
|
||
function filterType(type) {
|
||
currentFilter = type;
|
||
document.querySelectorAll('.filter-btn').forEach(btn => {
|
||
btn.classList.toggle('bg-blue-600', btn.dataset.type === type);
|
||
btn.classList.toggle('bg-gray-700', btn.dataset.type !== type);
|
||
});
|
||
renderProjects();
|
||
}
|
||
|
||
function renderProjects() {
|
||
const list = document.getElementById('projectsList');
|
||
const filtered = currentFilter === 'all' ? projects : projects.filter(p => p.type === currentFilter);
|
||
|
||
if (filtered.length === 0) {
|
||
list.innerHTML = '<div class="text-center py-12 text-gray-400"><i class="ri-folder-open-line text-4xl"></i><p class="mt-2">暂无项目</p></div>';
|
||
return;
|
||
}
|
||
|
||
const activeStatus = getActiveStatus();
|
||
const grouped = {};
|
||
filtered.forEach(p => {
|
||
if (!grouped[p.type]) grouped[p.type] = [];
|
||
grouped[p.type].push(p);
|
||
});
|
||
|
||
let html = '';
|
||
const typeNames = {
|
||
'web': { name: 'Web服务', icon: 'ri-server-line', color: 'blue' },
|
||
'cron': { name: 'Cron任务', icon: 'ri-time-line', color: 'yellow' },
|
||
'cli': { name: 'CLI工具', icon: 'ri-terminal-box-line', color: 'purple' },
|
||
'extension': { name: '浏览器插件', icon: 'ri-chrome-line', color: 'pink' }
|
||
};
|
||
|
||
for (const [type, projs] of Object.entries(grouped)) {
|
||
const typeInfo = typeNames[type] || { name: type, icon: 'ri-folder-line', color: 'gray' };
|
||
|
||
if (type === 'web') {
|
||
const activeProjs = projs.filter(p => activeStatus[p.id] !== false);
|
||
const archivedProjs = projs.filter(p => activeStatus[p.id] === false);
|
||
|
||
if (activeProjs.length > 0) {
|
||
html += `<div class="mb-6"><h2 class="text-lg font-semibold text-gray-300 mb-3 flex items-center gap-2"><i class="${typeInfo.icon} text-${typeInfo.color}-400"></i>${typeInfo.name}<span class="text-sm text-gray-500">(${activeProjs.length})</span></h2><div class="grid grid-cols-2 md:grid-cols-3 lg:grid-cols-4 gap-3">`;
|
||
activeProjs.forEach(p => { html += renderProjectCard(p, true); });
|
||
html += '</div></div>';
|
||
}
|
||
|
||
if (archivedProjs.length > 0) {
|
||
html += `<div class="mb-6 opacity-60"><h2 class="text-lg font-semibold text-gray-400 mb-3 flex items-center gap-2"><i class="ri-archive-line text-gray-400"></i>归档服务<span class="text-sm text-gray-500">(${archivedProjs.length})</span></h2><div class="grid grid-cols-2 md:grid-cols-3 lg:grid-cols-4 gap-3">`;
|
||
archivedProjs.forEach(p => { html += renderProjectCard(p, false); });
|
||
html += '</div></div>';
|
||
}
|
||
} else {
|
||
html += `<div class="mb-6"><h2 class="text-lg font-semibold text-gray-300 mb-3 flex items-center gap-2"><i class="${typeInfo.icon} text-${typeInfo.color}-400"></i>${typeInfo.name}<span class="text-sm text-gray-500">(${projs.length})</span></h2><div class="grid grid-cols-2 md:grid-cols-3 lg:grid-cols-4 gap-3">`;
|
||
projs.forEach(p => { html += renderProjectCard(p, true); });
|
||
html += '</div></div>';
|
||
}
|
||
}
|
||
list.innerHTML = html;
|
||
}
|
||
|
||
function getActiveStatus() {
|
||
const stored = localStorage.getItem('serviceActiveStatus');
|
||
return stored ? JSON.parse(stored) : {};
|
||
}
|
||
|
||
function toggleServiceActive(id) {
|
||
const status = getActiveStatus();
|
||
status[id] = status[id] === false ? true : false;
|
||
localStorage.setItem('serviceActiveStatus', JSON.stringify(status));
|
||
renderProjects();
|
||
}
|
||
|
||
function renderProjectCard(p, isActive = true) {
|
||
const statusInfo = getStatusInfo(p.status?.status);
|
||
|
||
// 处理后台链接：将 localhost 替换为 externalIp
|
||
let adminUrl = p.admin_url || '';
|
||
if (adminUrl && adminUrl.includes('localhost')) {
|
||
adminUrl = adminUrl.replace(/localhost/g, externalIp);
|
||
}
|
||
|
||
return `
|
||
<div class="card rounded-lg p-3 hover:border-gray-500 transition-colors">
|
||
<div class="flex items-center justify-between mb-2">
|
||
<div class="flex items-center gap-2">
|
||
<div class="status-dot ${statusInfo.class}" title="${statusInfo.text}"></div>
|
||
<h3 class="font-semibold text-sm truncate">${p.name}</h3>
|
||
</div>
|
||
<span class="text-xs ${statusInfo.textColor}">${statusInfo.text}</span>
|
||
</div>
|
||
${p.ports && p.ports.length > 0 ? `
|
||
<div class="flex items-center gap-1 text-xs mb-2">
|
||
${p.ports.map(port => {
|
||
const portStatus = p.status?.ports?.[port];
|
||
const isRunning = portStatus?.running;
|
||
return `<a href="http://${externalIp}:${port}" target="_blank" class="px-2 py-0.5 rounded ${isRunning ? 'bg-green-500/20 text-green-400 hover:bg-green-500/30' : 'bg-red-500/20 text-red-400'}">${port}</a>`;
|
||
}).join('')}
|
||
${adminUrl ? `<a href="${adminUrl}" target="_blank" class="text-yellow-400 hover:text-yellow-300 ml-1">后台</a>` : ''}
|
||
</div>
|
||
` : ''}
|
||
${p.type === 'web' ? `
|
||
<div class="flex items-center justify-between mt-2">
|
||
<div class="flex items-center gap-1">
|
||
${(p.status?.status === 'running' || p.status?.status === 'partial') ? `
|
||
<button onclick="stopProject('${p.id}')" class="btn bg-red-600 hover:bg-red-700 px-2 py-0.5 rounded text-xs">停止</button>
|
||
<button onclick="restartProject('${p.id}')" class="btn bg-yellow-600 hover:bg-yellow-700 px-2 py-0.5 rounded text-xs">重启</button>
|
||
` : `<button onclick="startProject('${p.id}')" class="btn bg-green-600 hover:bg-green-700 px-2 py-0.5 rounded text-xs">启动</button>`}
|
||
<button onclick="viewLog('${p.id}')" class="btn bg-gray-600 hover:bg-gray-700 px-2 py-0.5 rounded text-xs">日志</button>
|
||
</div>
|
||
<button onclick="toggleServiceActive('${p.id}')" class="text-xs ${isActive ? 'text-green-400 hover:text-green-300' : 'text-gray-400 hover:text-gray-300'}" title="${isActive ? '点击归档' : '点击激活'}">
|
||
<i class="ri-${isActive ? 'checkbox-circle' : 'archive'}-line"></i>
|
||
</button>
|
||
</div>
|
||
` : ''}
|
||
</div>
|
||
`;
|
||
}
|
||
|
||
function getStatusInfo(status) {
|
||
const map = {
|
||
'running': { text: '运行中', class: 'status-running', textColor: 'text-green-400' },
|
||
'stopped': { text: '已停止', class: 'status-stopped', textColor: 'text-red-400' },
|
||
'partial': { text: '部分运行', class: 'status-partial', textColor: 'text-yellow-400' },
|
||
'ready': { text: '就绪', class: 'status-ready', textColor: 'text-blue-400' },
|
||
'configured': { text: '已配置', class: 'status-configured', textColor: 'text-green-400' },
|
||
'not_configured': { text: '未配置', class: 'status-not-configured', textColor: 'text-gray-400' },
|
||
'completed': { text: '已完成', class: 'status-completed', textColor: 'text-purple-400' },
|
||
'unknown': { text: '未知', class: 'bg-gray-500', textColor: 'text-gray-400' }
|
||
};
|
||
return map[status] || map['unknown'];
|
||
}
|
||
|
||
async function startProject(id) {
|
||
if (!confirm('确定要启动此服务吗？')) return;
|
||
try {
|
||
const res = await fetch(`/api/projects/${id}/start`, { method: 'POST' });
|
||
const data = await res.json();
|
||
alert(data.message || data.error);
|
||
setTimeout(loadProjects, 2000);
|
||
} catch (e) {
|
||
alert('启动失败: ' + e.message);
|
||
}
|
||
}
|
||
|
||
async function stopProject(id) {
|
||
if (!confirm('确定要停止此服务吗？')) return;
|
||
try {
|
||
const res = await fetch(`/api/projects/${id}/stop`, { method: 'POST' });
|
||
const data = await res.json();
|
||
alert(data.message || data.error);
|
||
setTimeout(loadProjects, 1000);
|
||
} catch (e) {
|
||
alert('停止失败: ' + e.message);
|
||
}
|
||
}
|
||
|
||
async function restartProject(id) {
|
||
if (!confirm('确定要重启此服务吗？')) return;
|
||
try {
|
||
await fetch(`/api/projects/${id}/stop`, { method: 'POST' });
|
||
setTimeout(async () => {
|
||
const res = await fetch(`/api/projects/${id}/start`, { method: 'POST' });
|
||
const data = await res.json();
|
||
alert(data.message || data.error);
|
||
loadProjects();
|
||
}, 2000);
|
||
} catch (e) {
|
||
alert('重启失败: ' + e.message);
|
||
}
|
||
}
|
||
|
||
async function viewLog(id) {
|
||
const project = projects.find(p => p.id === id);
|
||
document.getElementById('logTitle').textContent = `${project?.name || id} - 日志`;
|
||
document.getElementById('logModal').classList.remove('hidden');
|
||
document.getElementById('logModal').classList.add('flex');
|
||
|
||
try {
|
||
const res = await fetch(`/api/projects/${id}/log`);
|
||
const data = await res.json();
|
||
document.getElementById('logContent').textContent = data.log || '暂无日志';
|
||
} catch (e) {
|
||
document.getElementById('logContent').textContent = '获取日志失败: ' + e.message;
|
||
}
|
||
}
|
||
|
||
function closeLogModal() {
|
||
document.getElementById('logModal').classList.add('hidden');
|
||
document.getElementById('logModal').classList.remove('flex');
|
||
}
|
||
|
||
// ==================== Cron 管理 ====================
|
||
|
||
async function loadCronTasks() {
|
||
try {
|
||
const res = await fetch('/api/cron/tasks');
|
||
const data = await res.json();
|
||
cronTasks = data.tasks;
|
||
renderCronTasks();
|
||
updateCronStats();
|
||
} catch (e) {
|
||
console.error('加载 Cron 任务失败:', e);
|
||
document.getElementById('cronTasksList').innerHTML = '<div class="text-center py-8 text-red-400"><i class="ri-error-warning-line text-2xl"></i><p class="mt-2 text-sm">加载失败: ' + e.message + '</p></div>';
|
||
}
|
||
}
|
||
|
||
function updateCronStats() {
|
||
const total = cronTasks.length;
|
||
const enabled = cronTasks.filter(t => t.enabled === 1).length;
|
||
const disabled = total - enabled;
|
||
|
||
document.getElementById('cronTotal').textContent = total;
|
||
document.getElementById('cronEnabled').textContent = enabled;
|
||
document.getElementById('cronDisabled').textContent = disabled;
|
||
|
||
// 获取历史总数
|
||
fetch('/api/cron/tasks').then(() => {
|
||
let historyCount = 0;
|
||
cronTasks.forEach(t => {
|
||
fetch(`/api/cron/tasks/${t.id}/history`).then(res => res.json()).then(data => {
|
||
historyCount += data.history.length;
|
||
document.getElementById('cronHistoryCount').textContent = historyCount;
|
||
});
|
||
});
|
||
});
|
||
}
|
||
|
||
function renderCronTasks() {
|
||
const list = document.getElementById('cronTasksList');
|
||
|
||
if (cronTasks.length === 0) {
|
||
list.innerHTML = '<div class="text-center py-12 text-gray-400"><i class="ri-folder-open-line text-4xl"></i><p class="mt-2">暂无 Cron 任务</p><p class="text-sm mt-1">点击"从系统同步"导入现有任务</p></div>';
|
||
return;
|
||
}
|
||
|
||
const categoryIcons = {
|
||
'monitor': { icon: 'ri-heart-pulse-line', color: 'blue' },
|
||
'backup': { icon: 'ri-archive-line', color: 'green' },
|
||
'cleanup': { icon: 'ri-delete-bin-line', color: 'yellow' },
|
||
'report': { icon: 'ri-file-chart-line', color: 'purple' },
|
||
'sync': { icon: 'ri-refresh-line', color: 'cyan' },
|
||
'notification': { icon: 'ri-notification-line', color: 'orange' },
|
||
'other': { icon: 'ri-more-line', color: 'gray' }
|
||
};
|
||
|
||
let html = '';
|
||
cronTasks.forEach(task => {
|
||
const catInfo = categoryIcons[task.category] || categoryIcons['other'];
|
||
|
||
html += `
|
||
<div class="cron-card card rounded-lg p-4">
|
||
<div class="flex items-start justify-between gap-4">
|
||
<div class="flex-1">
|
||
<div class="flex items-center gap-2 mb-2">
|
||
<i class="${catInfo.icon} text-${catInfo.color}-400"></i>
|
||
<h3 class="font-semibold">${task.name}</h3>
|
||
<span class="px-2 py-0.5 rounded text-xs ${task.enabled ? 'bg-green-500/20 text-green-400' : 'bg-red-500/20 text-red-400'}">${task.enabled ? '启用' : '禁用'}</span>
|
||
</div>
|
||
<div class="flex items-center gap-3 mb-2">
|
||
<code class="text-yellow-400 text-sm font-mono">${task.expression}</code>
|
||
<span class="text-gray-500">→</span>
|
||
<span class="text-blue-400 text-sm">${task.human_time || ''}</span>
|
||
${task.next_run ? `<span class="text-gray-500 text-xs">下次: ${task.next_run}</span>` : ''}
|
||
</div>
|
||
<div class="text-gray-300 text-sm font-mono break-all bg-gray-800/50 rounded p-2">${escapeHtml(task.command)}</div>
|
||
${task.description ? `<div class="text-gray-400 text-sm mt-2"><i class="ri-info-line"></i> ${task.description}</div>` : ''}
|
||
</div>
|
||
<div class="flex flex-col gap-1">
|
||
<button onclick="editCronTask(${task.id})" class="btn bg-blue-600 hover:bg-blue-700 px-2 py-1 rounded text-xs flex items-center gap-1"><i class="ri-edit-line"></i> 编辑</button>
|
||
<button onclick="toggleCronTask(${task.id})" class="btn ${task.enabled ? 'bg-yellow-600 hover:bg-yellow-700' : 'bg-green-600 hover:bg-green-700'} px-2 py-1 rounded text-xs flex items-center gap-1">
|
||
<i class="ri-${task.enabled ? 'pause' : 'play'}-line"></i> ${task.enabled ? '禁用' : '启用'}
|
||
</button>
|
||
<button onclick="showHistory(${task.id}, '${task.name}')" class="btn bg-purple-600 hover:bg-purple-700 px-2 py-1 rounded text-xs flex items-center gap-1"><i class="ri-history-line"></i> 历史</button>
|
||
<button onclick="deleteCronTask(${task.id})" class="btn bg-red-600 hover:bg-red-700 px-2 py-1 rounded text-xs flex items-center gap-1"><i class="ri-delete-bin-line"></i> 删除</button>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
`;
|
||
});
|
||
list.innerHTML = html;
|
||
}
|
||
|
||
function showAddCronModal() {
|
||
document.getElementById('cronModalTitle').textContent = '添加 Cron 任务';
|
||
document.getElementById('cronTaskId').value = '';
|
||
document.getElementById('cronName').value = '';
|
||
document.getElementById('cronExpression').value = '';
|
||
document.getElementById('cronCommand').value = '';
|
||
document.getElementById('cronCategory').value = 'other';
|
||
document.getElementById('cronDescription').value = '';
|
||
document.getElementById('cronEnabled').checked = true;
|
||
document.getElementById('cronHumanTime').textContent = '';
|
||
document.getElementById('cronModal').classList.remove('hidden');
|
||
}
|
||
|
||
function editCronTask(id) {
|
||
const task = cronTasks.find(t => t.id === id);
|
||
if (!task) return;
|
||
|
||
document.getElementById('cronModalTitle').textContent = '编辑 Cron 任务';
|
||
document.getElementById('cronTaskId').value = id;
|
||
document.getElementById('cronName').value = task.name;
|
||
document.getElementById('cronExpression').value = task.expression;
|
||
document.getElementById('cronCommand').value = task.command;
|
||
document.getElementById('cronCategory').value = task.category;
|
||
document.getElementById('cronDescription').value = task.description || '';
|
||
document.getElementById('cronEnabled').checked = task.enabled === 1;
|
||
document.getElementById('cronHumanTime').textContent = task.human_time || '';
|
||
document.getElementById('cronModal').classList.remove('hidden');
|
||
}
|
||
|
||
function closeCronModal() {
|
||
document.getElementById('cronModal').classList.add('hidden');
|
||
}
|
||
|
||
async function saveCronTask(event) {
|
||
event.preventDefault();
|
||
|
||
const id = document.getElementById('cronTaskId').value;
|
||
const data = {
|
||
name: document.getElementById('cronName').value,
|
||
expression: document.getElementById('cronExpression').value,
|
||
command: document.getElementById('cronCommand').value,
|
||
category: document.getElementById('cronCategory').value,
|
||
description: document.getElementById('cronDescription').value,
|
||
enabled: document.getElementById('cronEnabled').checked ? 1 : 0
|
||
};
|
||
|
||
try {
|
||
let res;
|
||
if (id) {
|
||
res = await fetch(`/api/cron/tasks/${id}`, { method: 'PUT', headers: {'Content-Type': 'application/json'}, body: JSON.stringify(data) });
|
||
} else {
|
||
res = await fetch('/api/cron/tasks', { method: 'POST', headers: {'Content-Type': 'application/json'}, body: JSON.stringify(data) });
|
||
}
|
||
|
||
const result = await res.json();
|
||
if (result.error) {
|
||
alert('保存失败: ' + result.error);
|
||
} else {
|
||
alert(result.message);
|
||
closeCronModal();
|
||
loadCronTasks();
|
||
}
|
||
} catch (e) {
|
||
alert('保存失败: ' + e.message);
|
||
}
|
||
}
|
||
|
||
async function toggleCronTask(id) {
|
||
try {
|
||
const res = await fetch(`/api/cron/tasks/${id}/toggle`, { method: 'POST' });
|
||
const data = await res.json();
|
||
alert(data.message);
|
||
loadCronTasks();
|
||
} catch (e) {
|
||
alert('操作失败: ' + e.message);
|
||
}
|
||
}
|
||
|
||
async function deleteCronTask(id) {
|
||
if (!confirm('确定要删除此任务吗？删除后会从系统 crontab 中移除。')) return;
|
||
|
||
try {
|
||
const res = await fetch(`/api/cron/tasks/${id}`, { method: 'DELETE' });
|
||
const data = await res.json();
|
||
alert(data.message);
|
||
loadCronTasks();
|
||
} catch (e) {
|
||
alert('删除失败: ' + e.message);
|
||
}
|
||
}
|
||
|
||
async function showHistory(id, name) {
|
||
document.getElementById('historyModalTitle').textContent = `${name} - 历史版本`;
|
||
document.getElementById('historyModal').classList.remove('hidden');
|
||
|
||
try {
|
||
const res = await fetch(`/api/cron/tasks/${id}/history`);
|
||
const data = await res.json();
|
||
renderHistory(data.history, id);
|
||
} catch (e) {
|
||
document.getElementById('historyList').innerHTML = '<div class="text-center py-8 text-red-400">加载失败</div>';
|
||
}
|
||
}
|
||
|
||
function renderHistory(history, taskId) {
|
||
if (history.length === 0) {
|
||
document.getElementById('historyList').innerHTML = '<div class="text-center py-8 text-gray-400">暂无历史记录</div>';
|
||
return;
|
||
}
|
||
|
||
const operationLabels = {
|
||
'create': { text: '创建', class: 'create' },
|
||
'update': { text: '更新', class: 'update' },
|
||
'delete': { text: '删除', class: 'delete' },
|
||
'toggle': { text: '切换状态', class: 'toggle' },
|
||
};
|
||
|
||
let html = '';
|
||
history.forEach(h => {
|
||
const opInfo = operationLabels[h.operation] || { text: h.operation, class: 'update' };
|
||
const isRollback = h.operation.includes('rollback');
|
||
|
||
html += `
|
||
<div class="history-item ${isRollback ? 'rollback' : opInfo.class} py-2">
|
||
<div class="flex items-center justify-between">
|
||
<div>
|
||
<div class="flex items-center gap-2">
|
||
<span class="text-gray-400 text-sm">v${h.version}</span>
|
||
<span class="text-xs px-2 py-0.5 rounded ${isRollback ? 'bg-yellow-500/20 text-yellow-400' : 'bg-blue-500/20 text-blue-400'}">${isRollback ? '回退' : opInfo.text}</span>
|
||
</div>
|
||
<div class="text-gray-300 text-sm mt-1">${h.created_at}</div>
|
||
${h.expression ? `<code class="text-yellow-400 text-xs font-mono">${h.expression}</code>` : ''}
|
||
${h.enabled !== null ? `<span class="text-xs ml-2 ${h.enabled ? 'text-green-400' : 'text-red-400'}">${h.enabled ? '启用' : '禁用'}</span>` : ''}
|
||
</div>
|
||
${!isRollback && h.version > 1 ? `<button onclick="rollbackTo(${taskId}, ${h.version})" class="btn bg-yellow-600 hover:bg-yellow-700 px-2 py-1 rounded text-xs"><i class="ri-history-line"></i> 回退</button>` : ''}
|
||
</div>
|
||
</div>
|
||
`;
|
||
});
|
||
document.getElementById('historyList').innerHTML = html;
|
||
}
|
||
|
||
async function rollbackTo(taskId, version) {
|
||
if (!confirm(`确定要回退到版本 ${version} 吗？`)) return;
|
||
|
||
try {
|
||
const res = await fetch(`/api/cron/tasks/${taskId}/rollback/${version}`, { method: 'POST' });
|
||
const data = await res.json();
|
||
alert(data.message);
|
||
closeHistoryModal();
|
||
loadCronTasks();
|
||
} catch (e) {
|
||
alert('回退失败: ' + e.message);
|
||
}
|
||
}
|
||
|
||
function closeHistoryModal() {
|
||
document.getElementById('historyModal').classList.add('hidden');
|
||
}
|
||
|
||
async function syncFromSystem() {
|
||
if (!confirm('从系统 crontab 同步任务到数据库？')) return;
|
||
|
||
try {
|
||
const res = await fetch('/api/cron/sync', { method: 'POST' });
|
||
const data = await res.json();
|
||
alert(data.message);
|
||
loadCronTasks();
|
||
} catch (e) {
|
||
alert('同步失败: ' + e.message);
|
||
}
|
||
}
|
||
|
||
function toggleLogs() {
|
||
enableLogs = document.getElementById('enableLogs').checked;
|
||
localStorage.setItem('enableLogs', enableLogs);
|
||
}
|
||
|
||
// 解析 cron 表达式显示友好时间
|
||
document.getElementById('cronExpression').addEventListener('input', function() {
|
||
const expr = this.value;
|
||
// 简单解析
|
||
const patterns = {
|
||
'0 4 * * *': '每天凌晨4点',
|
||
'0 0 * * *': '每天午夜0点',
|
||
'*/5 * * * *': '每5分钟',
|
||
'*/10 * * * *': '每10分钟',
|
||
'*/20 * * * *': '每20分钟',
|
||
'*/30 * * * *': '每30分钟',
|
||
'0 */1 * * *': '每小时',
|
||
'0 */2 * * *': '每2小时',
|
||
};
|
||
|
||
document.getElementById('cronHumanTime').textContent = patterns[expr] || '';
|
||
});
|
||
|
||
// ==================== 通用功能 ====================
|
||
|
||
function refreshAll() {
|
||
if (currentTab === 'projects') {
|
||
loadProjects();
|
||
} else {
|
||
loadCronTasks();
|
||
}
|
||
}
|
||
|
||
function scrollToTop() { window.scrollTo({ top: 0, behavior: 'smooth' }); }
|
||
function scrollToBottom() { window.scrollTo({ top: document.body.scrollHeight, behavior: 'smooth' }); }
|
||
|
||
function updateConnectionStatus(ok) {
|
||
const statusEl = document.getElementById('connectionStatus');
|
||
if (ok) {
|
||
statusEl.innerHTML = '<div class="w-2 h-2 rounded-full bg-green-400 animate-pulse"></div><span class="text-green-400 text-xs">已连接</span>';
|
||
statusEl.className = 'flex items-center gap-1 px-2 py-1 rounded bg-green-500/20';
|
||
} else {
|
||
statusEl.innerHTML = '<div class="w-2 h-2 rounded-full bg-red-400"></div><span class="text-red-400 text-xs">断开</span>';
|
||
statusEl.className = 'flex items-center gap-1 px-2 py-1 rounded bg-red-500/20';
|
||
}
|
||
}
|
||
|
||
function escapeHtml(text) {
|
||
const div = document.createElement('div');
|
||
div.textContent = text;
|
||
return div.innerHTML;
|
||
}
|
||
|
||
// 初始化
|
||
loadProjects();
|
||
|
||
let refreshIntervalMs = parseInt(localStorage.getItem('refreshInterval') || '30') * 1000;
|
||
document.getElementById('refreshInterval').value = refreshIntervalMs / 1000;
|
||
let refreshTimer = setInterval(() => { if (currentTab === 'projects') loadProjects(); }, refreshIntervalMs);
|
||
|
||
function updateRefreshInterval() {
|
||
const seconds = Math.max(5, Math.min(300, parseInt(document.getElementById('refreshInterval').value) || 30));
|
||
document.getElementById('refreshInterval').value = seconds;
|
||
localStorage.setItem('refreshInterval', seconds);
|
||
clearInterval(refreshTimer);
|
||
refreshTimer = setInterval(() => { if (currentTab === 'projects') loadProjects(); }, seconds * 1000);
|
||
}
|
||
|
||
setInterval(() => {
|
||
fetch('/api/projects').then(() => updateConnectionStatus(true)).catch(() => updateConnectionStatus(false));
|
||
}, 10000);
|
||
</script>
|
||
</body>
|
||
</html>
|
||
'''
|
||
|
||
|
||
if __name__ == '__main__':
|
||
os.makedirs(os.path.join(BASE_DIR, 'logs'), exist_ok=True)
|
||
os.makedirs(CRON_BACKUP_DIR, exist_ok=True)
|
||
init_db()
|
||
|
||
log_message("=" * 50)
|
||
log_message("项目服务管理面板 v2.0.0 启动")
|
||
log_message("访问地址: http://localhost:19013")
|
||
log_message(f"进程PID: {os.getpid()}")
|
||
log_message("=" * 50)
|
||
|
||
app.run(host='0.0.0.0', port=19013, debug=False) |