测试多Agent任务分配:张飞、关羽、赵云各一个测试任务
This commit is contained in:
+62
@@ -0,0 +1,62 @@
|
||||
#!/bin/bash
|
||||
# 修正版Agent监控脚本
|
||||
|
||||
AGENT="$1"
|
||||
|
||||
if [ -z "$AGENT" ]; then
|
||||
echo "使用方法: ./agent_monitor_fixed.sh <agent_name>"
|
||||
echo "例如: ./agent_monitor_fixed.sh pangtong"
|
||||
echo "支持的agent: pangtong, zhangfei, guanyu, zhaoyun, jiangwei, simayi"
|
||||
exit 1
|
||||
fi
|
||||
|
||||
LOG_FILE="${AGENT}_monitor.log"
|
||||
AGENT_DIR="management/agents/${AGENT}"
|
||||
|
||||
echo "=========================================" >> "$LOG_FILE"
|
||||
echo "Agent监控启动 - $AGENT" >> "$LOG_FILE"
|
||||
echo "启动时间: $(date '+%Y-%m-%d %H:%M:%S')" >> "$LOG_FILE"
|
||||
echo "监控目录: $AGENT_DIR" >> "$LOG_FILE"
|
||||
echo "检查间隔: 30秒" >> "$LOG_FILE"
|
||||
echo "=========================================" >> "$LOG_FILE"
|
||||
|
||||
echo "🚀 $AGENT Agent监控器启动"
|
||||
echo "📊 监控目录: $AGENT_DIR"
|
||||
echo "📝 日志文件: $LOG_FILE"
|
||||
echo "⏰ 检查间隔: 30秒"
|
||||
|
||||
while true; do
|
||||
TIMESTAMP=$(date '+%Y-%m-%d %H:%M:%S')
|
||||
|
||||
# 检查是否有.task文件
|
||||
TASK_FILES=$(ls ${AGENT_DIR}/*.task 2>/dev/null)
|
||||
|
||||
if [ -n "$TASK_FILES" ]; then
|
||||
for TASK_FILE in $TASK_FILES; do
|
||||
TASK_ID=$(basename "$TASK_FILE" .task)
|
||||
|
||||
echo "[$TIMESTAMP] $AGENT 发现新任务: $TASK_ID" >> "$LOG_FILE"
|
||||
echo "[$TIMESTAMP] $AGENT 发现新任务: $TASK_ID"
|
||||
|
||||
# 读取任务内容
|
||||
TASK_CONTENT=$(head -10 "$TASK_FILE" 2>/dev/null)
|
||||
echo "[$TIMESTAMP] 任务内容预览:" >> "$LOG_FILE"
|
||||
echo "$TASK_CONTENT" >> "$LOG_FILE"
|
||||
|
||||
# 模拟Agent执行
|
||||
echo "[$TIMESTAMP] $AGENT 开始执行任务..." >> "$LOG_FILE"
|
||||
echo "[$TIMESTAMP] $AGENT 开始执行任务..."
|
||||
|
||||
# 完成任务后删除.task文件
|
||||
sleep 1 # 模拟执行时间
|
||||
rm "$TASK_FILE"
|
||||
echo "[$TIMESTAMP] $AGENT 完成任务: $TASK_ID" >> "$LOG_FILE"
|
||||
echo "[$TIMESTAMP] $AGENT 完成任务: $TASK_ID"
|
||||
done
|
||||
else
|
||||
echo "[$TIMESTAMP] $AGENT 无新任务" >> "$LOG_FILE"
|
||||
fi
|
||||
|
||||
# 等待30秒
|
||||
sleep 30
|
||||
done
|
||||
Executable
+55
@@ -0,0 +1,55 @@
|
||||
#!/bin/bash
|
||||
# 修正版任务分配脚本
|
||||
|
||||
if [ $# -lt 2 ]; then
|
||||
echo "使用方法: ./assign_fixed.sh <任务ID> <负责人>"
|
||||
echo "例如: ./assign_fixed.sh TASK-20260322230434 pangtong"
|
||||
echo ""
|
||||
echo "支持的负责人:"
|
||||
echo " pangtong - 庞统(价值投资)"
|
||||
echo " zhangfei - 张飞(技术策略)"
|
||||
echo " guanyu - 关羽(风险管理)"
|
||||
echo " zhaoyun - 赵云(数据工程)"
|
||||
echo " jiangwei - 姜维(平台部署)"
|
||||
echo " simayi - 司马懿(质量总监)"
|
||||
exit 1
|
||||
fi
|
||||
|
||||
TASK_ID="$1"
|
||||
AGENT="$2"
|
||||
|
||||
PENDING_FILE="management/tasks/pending/${TASK_ID}.md"
|
||||
ASSIGNED_FILE="management/tasks/assigned/${TASK_ID}.md"
|
||||
AGENT_FILE="management/agents/${AGENT}/${TASK_ID}.task"
|
||||
|
||||
# 检查任务是否存在
|
||||
if [ ! -f "$PENDING_FILE" ]; then
|
||||
echo "❌ 错误: 任务不存在: $PENDING_FILE"
|
||||
exit 1
|
||||
fi
|
||||
|
||||
# 确保Agent目录存在
|
||||
mkdir -p "management/agents/${AGENT}"
|
||||
|
||||
echo "📋 分配任务: $TASK_ID → $AGENT"
|
||||
|
||||
# 1. 复制到assigned目录
|
||||
cp "$PENDING_FILE" "$ASSIGNED_FILE"
|
||||
|
||||
# 2. 更新状态
|
||||
sed -i '' "s/# 状态: pending/# 状态: assigned/" "$ASSIGNED_FILE"
|
||||
sed -i '' "s/# 负责人:.*/# 负责人: $AGENT/" "$ASSIGNED_FILE"
|
||||
|
||||
# 3. 复制到Agent目录
|
||||
cp "$ASSIGNED_FILE" "$AGENT_FILE"
|
||||
|
||||
# 4. 删除pending文件
|
||||
rm "$PENDING_FILE"
|
||||
|
||||
echo "✅ 任务分配成功"
|
||||
echo "📄 任务文件: $ASSIGNED_FILE"
|
||||
echo "📨 Agent通知: $AGENT_FILE"
|
||||
echo ""
|
||||
echo "📝 下一步:"
|
||||
echo "1. 提交到Gitee: git add . && git commit -m '分配任务给$AGENT' && git push"
|
||||
echo "2. $AGENT Agent会自动发现并执行任务"
|
||||
Regular → Executable
Regular → Executable
+3
-3
@@ -1,9 +1,9 @@
|
||||
#!/bin/bash
|
||||
# 修复版任务创建脚本
|
||||
# 修正版任务创建脚本 - 无语法错误
|
||||
|
||||
if [ -z "$1" ]; then
|
||||
echo "使用方法: ./create_task_fixed.sh \"任务描述\""
|
||||
echo "例如: ./create_task_fixed.sh \"整合选股报告\""
|
||||
echo "使用方法: ./create_correct.sh \"任务描述\""
|
||||
echo "例如: ./create_correct.sh \"整合选股报告\""
|
||||
exit 1
|
||||
fi
|
||||
|
||||
|
||||
Executable
+46
@@ -0,0 +1,46 @@
|
||||
#!/bin/bash
|
||||
# 健康检查脚本
|
||||
|
||||
echo "========================================="
|
||||
echo "🔍 系统健康检查报告"
|
||||
echo "时间: $(date '+%Y-%m-%d %H:%M:%S')"
|
||||
echo "========================================="
|
||||
echo ""
|
||||
|
||||
echo "📊 1. 文件系统状态:"
|
||||
echo " 当前目录: $(pwd)"
|
||||
echo " 权限检查:"
|
||||
if touch test_health.tmp 2>/dev/null; then
|
||||
echo " ✅ 文件系统可写"
|
||||
rm test_health.tmp
|
||||
else
|
||||
echo " ❌ 文件系统不可写"
|
||||
fi
|
||||
|
||||
echo ""
|
||||
echo "📁 2. 目录结构:"
|
||||
echo " tasks/pending: $(ls management/tasks/pending/ 2>/dev/null | wc -l) 个文件"
|
||||
echo " tasks/assigned: $(ls management/tasks/assigned/ 2>/dev/null | wc -l) 个文件"
|
||||
echo " agents/pangtong: $(ls management/agents/pangtong/ 2>/dev/null | wc -l) 个文件"
|
||||
|
||||
echo ""
|
||||
echo "🔄 3. Git状态:"
|
||||
git status --porcelain 2>/dev/null | head -10
|
||||
|
||||
echo ""
|
||||
echo "🎯 4. 工作流验证:"
|
||||
if [ -f "management/tasks/assigned/TASK-20260322230434.md" ]; then
|
||||
echo " ✅ 任务文件存在"
|
||||
if [ -f "management/agents/pangtong/TASK-20260322230434.task" ]; then
|
||||
echo " ✅ Agent通知文件存在"
|
||||
else
|
||||
echo " ❌ Agent通知文件不存在"
|
||||
fi
|
||||
else
|
||||
echo " ❌ 任务文件不存在"
|
||||
fi
|
||||
|
||||
echo ""
|
||||
echo "========================================="
|
||||
echo "🎉 健康检查完成 - 系统正常"
|
||||
echo "========================================="
|
||||
Reference in New Issue
Block a user