test_15_events.py

"""
Test script: Write 15 different episodic events to m_flow memory bank.
"""

import asyncio
import os
import sys

# Ensure correct environment
os.environ["ENABLE_BACKEND_ACCESS_CONTROL"] = "false"
os.environ["MFLOW_EPISODIC_ENABLED"] = "true"

import m_flow

# 15 different events covering various topics
EVENTS = [
    {
        "title": "智能客服系统升级项目",
        "content": """# 智能客服系统升级项目报告

## 一、项目背景
随着公司业务快速扩张，现有客服系统已无法满足需求。2024年Q3客服工单量日均5万件，同比增长180%。人工客服团队扩展至200人，但客户等待时长仍达8分钟，客户满意度降至72%。

## 二、技术方案
选择GPT-4o-mini作为基础模型，响应延迟低于500ms，成本降低80%。采用RAG方案确保知识可控、可更新。实现人机协作模式，预计人工介入率降至30%。

## 三、数据库选型
LanceDB作为向量数据库，支持本地部署，查询性能p99<100ms。Kuzu作为图数据库，开源免费，支持Cypher查询。

## 四、投资与收益
总投资450万元：LLM API 120万/年，基础设施80万，开发人力200万。预计年省200万，18个月回本。

项目负责人：张三
报告日期：2024年12月20日
""",
    },
    {
        "title": "Q4销售业绩报告",
        "content": """# 2024年Q4销售业绩报告

## 业绩概览
Q4总销售额达到1.2亿元，同比增长25%，环比增长15%。华东区贡献45%，华南区30%，华北区25%。

## 核心产品表现
- A系列产品：销售额5000万，占比42%，增长30%
- B系列产品：销售额3500万，占比29%，增长18%
- C系列产品：销售额3500万，占比29%，增长22%

## 新客户开拓
新增企业客户150家，其中大客户（年采购额>100万）12家。客户续约率提升至92%。

## 销售团队
销售团队扩展至80人，人均产出150万/季度。Top销售王五实现个人业绩800万。

报告人：李经理
日期：2025年1月5日
""",
    },
    {
        "title": "年度产品规划会议",
        "content": """# 2025年产品规划会议纪要

## 会议信息
时间：2025年1月8日 14:00-17:00
地点：总部3楼会议室
参会人：产品部全员、技术负责人、市场代表

## 核心决策
1. **新产品线D系列**：定位中高端市场，预计Q2发布，研发预算800万
2. **A系列升级**：增加AI功能，提升用户体验，Q1完成
3. **C系列国际版**：适配欧美市场标准，Q3发布

## 技术路线
采用微服务架构重构后端，引入Kubernetes编排。前端升级到React 19，支持SSR。

## 资源分配
- D系列：15人团队，为期6个月
- A系列升级：8人团队，为期3个月
- C系列国际版：10人团队，为期4个月

主持人：产品VP赵总
""",
    },
    {
        "title": "技术架构升级方案",
        "content": """# 技术架构升级方案

## 当前问题
1. 单体架构难以扩展，部署周期长达2周
2. 数据库性能瓶颈，高峰期响应超过3秒
3. 缺乏容灾机制，去年发生2次重大故障

## 升级方案
### 微服务改造
- 拆分为12个独立服务
- 使用gRPC进行服务间通信
- 引入服务网格Istio

### 数据层优化
- 主数据库升级到PostgreSQL 16
- 引入Redis集群作为缓存层
- 实现读写分离，3主6从

### 容灾建设
- 双活数据中心（北京+上海）
- RPO<1分钟，RTO<5分钟
- 自动故障切换

## 实施计划
- Phase 1（Q1）：核心服务拆分
- Phase 2（Q2）：数据层优化
- Phase 3（Q3）：容灾建设

预算：500万元
负责人：技术VP陈工
""",
    },
    {
        "title": "人力资源年度报告",
        "content": """# 2024年人力资源年度报告

## 人员规模
年末员工总数580人，较年初增长20%。技术岗占比55%，销售岗20%，运营岗15%，职能岗10%。

## 招聘情况
全年新入职员工150人，离职率12%（行业平均18%）。平均招聘周期28天，offer接受率85%。

## 薪酬福利
- 年度调薪：平均涨幅8%
- 年终奖：平均2.5个月
- 新增福利：补充医疗保险、健身房补贴

## 培训发展
- 人均培训时长40小时
- 内部晋升比例35%
- 建立了技术专家和管理双通道

## 2025年计划
- 招聘目标：100人（重点技术岗）
- 优化绩效考核体系
- 推行OKR管理模式

HR负责人：刘总监
""",
    },
    {
        "title": "市场推广活动总结",
        "content": """# 双十一营销活动总结

## 活动概述
活动时间：2024年11月1日-11月11日
活动主题：「智享未来」
投放预算：200万元

## 活动成果
- 总曝光量：5000万次
- 官网访问：120万UV
- 新增注册：8万用户
- 直接转化订单：1500单
- 订单金额：2000万元
- ROI：10:1

## 渠道分析
- 抖音信息流：40%转化贡献
- 微信朋友圈：30%
- 百度SEM：20%
- KOL合作：10%

## 经验总结
1. 短视频内容效果最佳
2. 预热期应延长至2周
3. 客服响应需加强

市场部负责人：周经理
""",
    },
    {
        "title": "客户满意度调研报告",
        "content": """# 2024年客户满意度调研报告

## 调研概况
调研时间：2024年10月
样本量：2000份有效问卷
覆盖客户类型：企业客户60%，个人客户40%

## 整体满意度
- 总体满意度：85分（满分100）
- 较去年提升3分
- NPS净推荐值：45（优秀）

## 各维度得分
- 产品质量：88分
- 售后服务：82分
- 价格合理性：78分
- 交付速度：86分
- 技术支持：84分

## 主要反馈
### 正面
- 产品稳定性好
- 技术支持响应快
- 定制化能力强

### 待改进
- 价格偏高（35%提及）
- 文档不够完善（28%提及）
- 希望增加培训（22%提及）

调研负责人：客户成功部
""",
    },
    {
        "title": "数据安全合规审计",
        "content": """# 数据安全合规审计报告

## 审计范围
审计期间：2024年7月-12月
审计标准：ISO 27001、等保2.0三级

## 审计结果
整体评分：92分（良好）
发现问题：12项（高危0项，中危3项，低危9项）

## 主要发现
### 中危问题
1. 部分测试环境使用生产数据
2. 3台服务器未及时打安全补丁
3. VPN访问日志保留期不足

### 整改措施
- 测试数据脱敏：已完成
- 补丁更新：12月底前完成
- 日志保留延长至180天

## 合规认证
- ISO 27001：2024年9月通过
- 等保三级：2024年11月通过
- SOC 2 Type II：进行中

安全负责人：安全部王工
""",
    },
    {
        "title": "供应链优化项目",
        "content": """# 供应链优化项目报告

## 项目背景
原有供应链存在问题：库存周转天数45天（行业平均30天），采购成本偏高15%，供应商管理混乱。

## 优化措施
### 供应商整合
- 从120家缩减至60家
- 建立战略供应商10家
- 实施供应商评分制度

### 库存管理
- 引入智能补货系统
- 建立安全库存模型
- 实施ABC分类管理

### 物流优化
- 新建华中仓储中心
- 与京东物流达成合作
- 实现全国48小时达

## 优化成果
- 库存周转天数：45→32天
- 采购成本降低：12%
- 订单履约率：95%→99%

项目负责人：供应链总监孙总
""",
    },
    {
        "title": "新办公室装修计划",
        "content": """# 新办公室装修方案

## 项目信息
位置：科技园区B栋5-8层
面积：4000平方米
工期：2025年2月-5月

## 设计理念
「开放协作·绿色智能」
- 开放工位占比70%
- 独立办公室30间
- 会议室15间（大中小各5间）

## 功能区划
- 5层：前台、展厅、会议中心
- 6层：销售部、市场部
- 7层：技术部、产品部
- 8层：行政、财务、高管办公

## 智能化配置
- 人脸识别门禁
- 智能会议预约系统
- 环境监测与调控
- 无线投屏全覆盖

## 预算明细
- 硬装：300万
- 软装：100万
- 智能化：80万
- 家具：120万
- 总计：600万

行政负责人：行政部钱经理
""",
    },
    {
        "title": "AI研发中心成立",
        "content": """# AI研发中心成立方案

## 背景与目标
响应公司AI战略，成立专业AI研发中心。目标：3年内形成核心AI能力，赋能全产品线。

## 组织架构
- 中心总监：1人（外部招聘）
- 算法团队：15人
- 工程团队：10人
- 数据团队：5人

## 技术方向
1. **NLP方向**：智能客服、文档理解
2. **CV方向**：质量检测、安防
3. **推荐系统**：个性化推荐、智能匹配

## 基础设施
- GPU服务器：8台A100
- 存储：500TB
- 算力平台：基于Ray构建

## 预算
- 人力成本：1500万/年
- 硬件投入：800万（一次性）
- 云资源：200万/年

## 里程碑
- Q1：团队搭建完成
- Q2：第一个AI产品原型
- Q4：AI功能集成到主产品

发起人：CTO吴总
""",
    },
    {
        "title": "国际化战略规划",
        "content": """# 国际化战略规划

## 战略目标
2025-2027年完成国际化布局，海外收入占比达到30%。

## 市场选择
### 第一阶段（2025）
- 东南亚：新加坡、马来西亚、泰国
- 目标收入：2000万美元

### 第二阶段（2026）
- 日韩市场
- 目标收入：5000万美元

### 第三阶段（2027）
- 欧美市场
- 目标收入：1亿美元

## 本地化策略
- 产品多语言支持
- 本地合规适配（GDPR等）
- 建立本地团队

## 资源投入
- 海外办公室：新加坡、东京
- 本地化团队：50人
- 市场推广：500万美元/年

## 风险管控
- 汇率风险：对冲策略
- 政策风险：法务提前调研
- 文化差异：本地顾问团队

战略负责人：CEO郑总
""",
    },
    {
        "title": "年度财务报告",
        "content": """# 2024年度财务报告

## 营收概况
- 年度总营收：4.5亿元
- 同比增长：28%
- 毛利率：65%
- 净利率：18%

## 收入结构
- 产品收入：3.2亿（71%）
- 服务收入：1.0亿（22%）
- 其他收入：0.3亿（7%）

## 成本分析
- 人力成本：1.2亿（27%）
- 营销费用：0.6亿（13%）
- 研发投入：0.8亿（18%）
- 运营成本：0.5亿（11%）

## 现金流
- 经营性现金流：1.2亿
- 投资性现金流：-0.5亿
- 融资性现金流：0
- 期末现金余额：2.8亿

## 2025年预算
- 营收目标：6亿（+33%）
- 研发预算：1.2亿
- 营销预算：0.9亿

CFO：财务VP何总
""",
    },
    {
        "title": "员工关怀计划",
        "content": """# 2025年员工关怀计划

## 健康关怀
- 年度体检升级：增加专项检查
- 心理咨询服务：签约专业机构
- 健身房补贴：每月300元
- EAP员工援助计划

## 家庭关怀
- 带薪育儿假延长至6个月
- 子女教育补贴：最高5000元/年
- 父母体检：每年一次
- 家庭日活动：季度一次

## 成长发展
- 学习补贴：每年1万元
- 外部培训：提供带薪假期
- 导师计划：高管一对一
- 轮岗机会：跨部门体验

## 特别福利
- 工作满5年：额外10天年假
- 工作满10年：一次性奖励5万
- 每月下午茶、生日会
- 年度旅游：国内外可选

## 预算
年度总预算：500万元
人均福利成本：8600元

HR负责人：刘总监
""",
    },
    {
        "title": "技术债务清理计划",
        "content": """# 技术债务清理计划

## 现状评估
经过代码审计，识别出以下技术债务：
- 遗留代码：约15万行需要重构
- 依赖升级：32个包版本过旧
- 测试覆盖：整体覆盖率仅45%
- 文档缺失：30%接口无文档

## 清理优先级
### P0（Q1必须完成）
- 安全漏洞相关：5项
- 性能瓶颈代码：3处
- 已废弃的API

### P1（Q2完成）
- 核心模块重构
- 单元测试补充至70%
- 接口文档完善

### P2（下半年）
- 代码风格统一
- 依赖包全面升级
- 集成测试完善

## 执行策略
- 每个Sprint预留20%时间处理技术债务
- 建立代码质量门禁
- 定期技术债务评审会

## 预期收益
- 系统稳定性提升30%
- 开发效率提升20%
- Bug率降低40%

技术负责人：架构师林工
""",
    },
]


async def main():
    print("=" * 60)
    print("写入 15 个事件到 m_flow 记忆库")
    print("=" * 60)

    # Reset and setup
    print("\n[1/3] 清空数据库...")
    await m_flow.prune.prune_data()
    await m_flow.prune.prune_system(metadata=True)

    # Add all events
    print(f"\n[2/3] 添加 {len(EVENTS)} 个事件...")
    for i, event in enumerate(EVENTS, 1):
        print(f"  - 添加事件 {i}/{len(EVENTS)}: {event['title']}")
        await m_flow.add(event["content"])

    # Memorize
    print("\n[3/3] 处理记忆 (memorize)...")
    print("  这可能需要几分钟，请耐心等待...")
    await m_flow.memorize()

    print("\n" + "=" * 60)
    print("✅ 完成！15 个事件已写入记忆库")
    print("=" * 60)

    # Quick stats
    from m_flow.adapters.graph import get_graph_provider

    graph_engine = await get_graph_provider()

    try:
        episodes = await graph_engine.query("MATCH (n:Episode) RETURN count(n) as cnt")
        facets = await graph_engine.query("MATCH (n:Facet) RETURN count(n) as cnt")
        print("\n📊 统计:")
        print(f"  - Episodes: {episodes[0]['cnt'] if episodes else 0}")
        print(f"  - Facets: {facets[0]['cnt'] if facets else 0}")
    except:
        print("\n📊 统计: (查询失败，数据可能仍在处理中)")


if __name__ == "__main__":
    asyncio.run(main())