🌈 MoodTracker - 智能心情追踪与分析系统
1. 实际应用场景描述
场景设定
在快节奏的现代生活中，人们的情绪健康越来越受到关注。无论是工作压力、人际关系、生活变化还是身体健康，都可能影响我们的心情状态。
典型用户画像：
- 职场新人小李：刚入职感到焦虑和压力，想了解什么因素影响自己的心情，如何更好地适应工作环境
- 研究生小王：面临论文压力和导师关系，希望找到情绪低谷的规律，学会情绪管理
- 新手妈妈张女士：产后情绪波动大，需要记录并分析情绪变化，获得专业建议
- 退休教师王大爷：想保持积极心态，通过记录发现生活的美好，维持心理健康
- 大学生小陈：面对学业、就业、感情多重压力，需要科学的方法进行情绪调节
痛点分析
1. 情绪记录困难：传统方式（日记本、便签）容易遗忘，缺乏结构化记录
2. 规律发现困难：人脑难以从大量日常数据中识别长期情绪变化趋势
3. 原因分析模糊：不清楚什么具体因素导致情绪变化，无法针对性改善
4. 专业指导缺乏：缺乏基于科学研究的情绪调节建议
5. 数据隐私担忧：担心个人情绪数据被滥用或泄露
6. 坚持使用困难：传统方法单调枯燥，难以形成长期记录习惯
7. 分析能力不足：缺乏心理学和统计学知识，无法正确解读情绪数据
2. 核心逻辑讲解
系统架构设计
用户界面层 → 业务逻辑层 → 数据管理层 → 分析引擎层 → 建议生成层
↓ ↓ ↓ ↓ ↓
GUI/WEB 心情记录 SQLite数据库 统计分析引擎 个性化建议
CLI接口 数据验证 用户信息管理 机器学习模型 科学依据支撑
REST API 统计分析 隐私加密存储 自然语言处理 专家知识库
微信小程序 趋势预测 数据备份恢复 情感词典匹配 社区经验分享
关键技术算法
1. 情绪识别与量化算法
def analyze_emotion_intensity(text_description: str, mood_tags: List[str]) -> Dict:
"""
基于文本描述和标签的情绪强度分析
"""
# 情感词典匹配
sentiment_scores = match_sentiment_words(text_description)
# 标签权重计算
tag_weights = calculate_tag_weights(mood_tags)
# 上下文分析
context_factors = analyze_context_factors(text_description)
# 综合情绪强度计算
intensity_score = (
sentiment_scores['polarity'] * 0.4 +
tag_weights['intensity'] * 0.4 +
context_factors['impact'] * 0.2
)
return {
'overall_intensity': normalize_score(intensity_score),
'positive_component': sentiment_scores['positive'],
'negative_component': sentiment_scores['negative'],
'confidence_level': calculate_confidence(sentiment_scores, tag_weights),
'emotion_categories': classify_emotions(mood_tags)
}
2. 影响因素关联分析算法
def analyze_correlation_factors(mood_records: List[MoodRecord], lookback_days: int = 7) -> Dict:
"""
分析心情与各因素的关联关系
"""
correlations = {}
# 提取可能影响因素
factors = extract_potential_factors(mood_records)
for factor_name, factor_values in factors.items():
# 皮尔逊相关系数计算
correlation_coeff = pearson_correlation(
[record.mood_score for record in mood_records],
factor_values
)
# 显著性检验
p_value = calculate_significance(correlation_coeff, len(mood_records))
# 滞后相关性分析（某些因素影响可能有延迟）
lag_correlations = analyze_lag_correlation(mood_records, factor_values)
correlations[factor_name] = {
'correlation_coefficient': correlation_coeff,
'p_value': p_value,
'significance': 'significant' if p_value < 0.05 else 'not_significant',
'lag_effects': lag_correlations,
'effect_direction': 'positive' if correlation_coeff > 0 else 'negative'
}
# 识别最强的影响因素
top_factors = sorted(
correlations.items(),
key=lambda x: abs(x[1]['correlation_coefficient']),
reverse=True
)[:5]
return {
'all_correlations': correlations,
'top_factors': top_factors,
'insights': generate_correlation_insights(top_factors)
}
3. 情绪预测与预警算法
def predict_mood_trend(mood_history: List[MoodRecord], prediction_days: int = 7) -> Dict:
"""
基于历史数据预测未来情绪趋势
"""
# 特征工程
features = extract_temporal_features(mood_history)
# 时间序列分析
arima_model = fit_arima_model(features)
arima_forecast = arima_model.forecast(steps=prediction_days)
# 机器学习模型
ml_model = train_ml_model(features)
ml_forecast = ml_model.predict(features, steps=prediction_days)
# 融合预测结果
ensemble_forecast = ensemble_predictions([arima_forecast, ml_forecast])
# 风险预警
risk_indicators = identify_risk_indicators(ensemble_forecast, mood_history)
return {
'predicted_scores': ensemble_forecast,
'confidence_intervals': calculate_confidence_intervals(ensemble_forecast),
'trend_direction': determine_trend_direction(ensemble_forecast),
'risk_warnings': risk_indicators,
'recommendations': generate_preventive_recommendations(risk_indicators)
}
4. 个性化建议生成算法
def generate_personalized_suggestions(
user_profile: UserProfile,
mood_analysis: Dict,
correlation_results: Dict,
prediction_results: Dict
) -> List[Dict]:
"""
基于多维度分析生成个性化建议
"""
suggestions = []
# 基于当前情绪状态的建议
current_mood = mood_analysis.get('current_mood', {})
if current_mood.get('intensity', 0) < 0.3: # 情绪低落
suggestions.extend(generate_mood_lifting_suggestions(user_profile))
elif current_mood.get('intensity', 0) > 0.8: # 情绪过度兴奋
suggestions.extend(generate_calmness_suggestions(user_profile))
# 基于相关因素的建议
top_factors = correlation_results.get('top_factors', [])
for factor_name, factor_data in top_factors:
if abs(factor_data['correlation_coefficient']) > 0.5: # 强相关
factor_suggestions = generate_factor_based_suggestions(
factor_name, factor_data, user_profile
)
suggestions.extend(factor_suggestions)
# 基于预测结果的预防建议
risk_warnings = prediction_results.get('risk_warnings', [])
for warning in risk_warnings:
preventive_suggestions = generate_preventive_suggestions(warning, user_profile)
suggestions.extend(preventive_suggestions)
# 去重和排序
unique_suggestions = remove_duplicates(suggestions)
prioritized_suggestions = prioritize_suggestions(unique_suggestions, user_profile)
return prioritized_suggestions[:10] # 返回前10条最相关的建议
3. 代码实现
项目结构
moodtracker/
├── main.py # 主程序入口
├── config/ # 配置模块
│ ├── settings.py # 系统设置
│ ├── emotion_config.py # 情绪配置
│ ├── privacy_config.py # 隐私设置
│ └── suggestion_config.py # 建议配置
├── models/ # 数据模型
│ ├── mood_record.py # 心情记录模型
│ ├── user_profile.py # 用户档案模型
│ ├── factor_data.py # 影响因素数据模型
│ ├── analysis_result.py # 分析结果模型
│ └── suggestion.py # 建议模型
├── services/ # 业务服务
│ ├── mood_service.py # 心情服务
│ ├── analysis_service.py # 分析服务
│ ├── suggestion_service.py # 建议服务
│ ├── prediction_service.py # 预测服务
│ ├── privacy_service.py # 隐私服务
│ └── export_service.py # 导出服务
├── processors/ # 处理器
│ ├── text_analyzer.py # 文本分析器
│ ├── correlation_analyzer.py # 关联分析器
│ ├── trend_analyzer.py # 趋势分析器
│ ├── nlp_processor.py # NLP处理器
│ └── data_validator.py # 数据验证器
├── algorithms/ # 算法模块
│ ├── emotion_detection.py # 情绪检测算法
│ ├── pattern_recognition.py # 模式识别算法
│ ├── clustering.py # 聚类分析算法
│ ├── time_series.py # 时间序列分析
│ └── recommendation.py # 推荐算法
├── knowledge_base/ # 知识库
│ ├── psychology_knowledge.py # 心理学知识
│ ├── intervention_methods.py # 干预方法
│ ├── research_studies.py # 研究文献
│ └── expert_guidelines.py # 专家指导
├── interfaces/ # 用户界面
│ ├── web_interface.py # Web界面
│ ├── mobile_interface.py # 移动界面
│ ├── cli_interface.py # 命令行界面
│ └── voice_interface.py # 语音界面
├── database/ # 数据库
│ ├── db_manager.py # 数据库管理器
│ ├── migration_manager.py # 迁移管理器
│ └── backup_manager.py # 备份管理器
├── utils/ # 工具函数
│ ├── date_utils.py # 日期工具
│ ├── text_utils.py # 文本工具
│ ├── math_utils.py # 数学工具
│ ├── file_utils.py # 文件工具
│ └── visualization.py # 可视化工具
├── integrations/ # 第三方集成
│ ├── health_apps.py # 健康应用集成
│ ├── calendar_apps.py # 日历应用集成
│ ├── social_media.py # 社交媒体集成
│ └── wearable_devices.py # 可穿戴设备集成
├── analytics/ # 分析模块
│ ├── statistical_analyzer.py # 统计分析器
│ ├── ml_analyzer.py # 机器学习分析器
│ ├── behavioral_analyzer.py # 行为分析器
│ └── comparative_analyzer.py # 比较分析器
├── security/ # 安全模块
│ ├── encryption.py # 加密工具
│ ├── anonymization.py # 匿名化工具
│ ├── access_control.py # 访问控制
│ └── audit_logger.py # 审计日志
├── tests/ # 测试文件
│ ├── unit_tests/ # 单元测试
│ ├── integration_tests/ # 集成测试
│ ├── performance_tests/ # 性能测试
│ └── mock_data/ # 模拟数据
├── data/ # 数据文件
│ ├── sample_data/ # 样本数据
│ ├── knowledge_base/ # 知识库数据
│ ├── user_data/ # 用户数据
│ └── exports/ # 导出数据
└── docs/ # 文档
├── api_documentation.md # API文档
├── user_manual.md # 用户手册
├── developer_guide.md # 开发者指南
└── research_papers/ # 研究论文
核心代码实现
main.py - 主程序
#!/usr/bin/env python3
"""
MoodTracker - 智能心情追踪与分析系统
科学记录情绪，发现生活规律，获得专业建议
"""
import sys
import os
import json
import argparse
import logging
import threading
import time
from datetime import datetime, timedelta
from pathlib import Path
from typing import List, Dict, Optional, Tuple, Any, Union
import sqlite3
import schedule
import requests
import numpy as np
import pandas as pd
import matplotlib.pyplot as plt
import seaborn as sns
from dataclasses import dataclass, asdict, field
from enum import Enum, IntEnum
import re
import hashlib
import pickle
from collections import defaultdict, Counter
from concurrent.futures import ThreadPoolExecutor, as_completed
import warnings
warnings.filterwarnings('ignore')
# 导入自定义模块
from config.settings import AppConfig, DatabaseConfig, PrivacyConfig, SuggestionConfig
from config.emotion_config import EmotionConfig, MoodScale, FactorCategories
from config.privacy_config import PrivacyLevel, DataRetentionPolicy
from config.suggestion_config import SuggestionType, InterventionStrategy
from models.mood_record import MoodRecord, MoodEntry, TriggerFactor, CopingStrategy
from models.user_profile import UserProfile, Demographics, HealthInfo, LifestyleFactors
from models.factor_data import FactorData, DailyActivity, SocialInteraction, EnvironmentalFactor
from models.analysis_result import AnalysisResult, CorrelationAnalysis, TrendAnalysis, RiskAssessment
from models.suggestion import Suggestion, ActionableStep, ResourceLink, ExpertOpinion
from services.mood_service import MoodService
from services.analysis_service import AnalysisService
from services.suggestion_service import SuggestionService
from services.prediction_service import PredictionService
from services.privacy_service import PrivacyService
from services.export_service import ExportService
from processors.text_analyzer import TextAnalyzer
from processors.correlation_analyzer import CorrelationAnalyzer
from processors.trend_analyzer import TrendAnalyzer
from processors.nlp_processor import NLPProcessor
from processors.data_validator import DataValidator
from algorithms.emotion_detection import EmotionDetectionAlgorithm
from algorithms.pattern_recognition import PatternRecognitionAlgorithm
from algorithms.clustering import ClusteringAlgorithm
from algorithms.time_series import TimeSeriesAnalyzer
from algorithms.recommendation import RecommendationAlgorithm
from knowledge_base.psychology_knowledge import PsychologyKnowledgeBase
from knowledge_base.intervention_methods import InterventionMethods
from knowledge_base.research_studies import ResearchStudies
from knowledge_base.expert_guidelines import ExpertGuidelines
from interfaces.web_interface import WebInterface
from interfaces.mobile_interface import MobileInterface
from interfaces.cli_interface import CLIInterface
from interfaces.voice_interface import VoiceInterface
from database.db_manager import DatabaseManager
from database.migration_manager import MigrationManager
from database.backup_manager import BackupManager
from utils.date_utils import DateUtils
from utils.text_utils import TextUtils
from utils.math_utils import MathUtils
from utils.file_utils import FileUtils
from utils.visualization import VisualizationEngine
from integrations.health_apps import HealthAppsIntegration
from integrations.calendar_apps import CalendarAppsIntegration
from integrations.social_media import SocialMediaIntegration
from integrations.wearable_devices import WearableDevicesIntegration
from analytics.statistical_analyzer import StatisticalAnalyzer
from analytics.ml_analyzer import MLAnalyzer
from analytics.behavioral_analyzer import BehavioralAnalyzer
from analytics.comparative_analyzer import ComparativeAnalyzer
from security.encryption import EncryptionManager
from security.anonymization import AnonymizationTool
from security.access_control import AccessControlManager
from security.audit_logger import AuditLogger
class MoodTrackerSystem:
"""智能心情追踪与分析系统主控制器"""
def __init__(self, config_path: str = "config/settings.py"):
"""初始化系统"""
self._setup_logging()
self.config = AppConfig(config_path)
self.db_manager = DatabaseManager(self.config.database_config)
self.privacy_service = PrivacyService(self.config.privacy_config)
# 初始化核心服务
self.mood_service = MoodService(self.db_manager, self.privacy_service)
self.analysis_service = AnalysisService(self.db_manager)
self.suggestion_service = SuggestionService(self.db_manager)
self.prediction_service = PredictionService(self.db_manager)
self.export_service = ExportService(self.db_manager)
# 初始化处理器
self.text_analyzer = TextAnalyzer()
self.correlation_analyzer = CorrelationAnalyzer()
self.trend_analyzer = TrendAnalyzer()
self.nlp_processor = NLPProcessor()
self.data_validator = DataValidator()
# 初始化算法模块
self.emotion_detector = EmotionDetectionAlgorithm()
self.pattern_recognizer = PatternRecognitionAlgorithm()
self.clusterer = ClusteringAlgorithm()
self.time_series_analyzer = TimeSeriesAnalyzer()
self.recommender = RecommendationAlgorithm()
# 初始化知识库
self.psychology_kb = PsychologyKnowledgeBase()
self.intervention_methods = InterventionMethods()
self.research_studies = ResearchStudies()
self.expert_guidelines = ExpertGuidelines()
# 初始化用户界面
self.cli_interface = CLIInterface(self)
self.web_interface = WebInterface(self)
self.mobile_interface = MobileInterface(self)
self.voice_interface = VoiceInterface(self)
# 初始化分析器
self.statistical_analyzer = StatisticalAnalyzer()
self.ml_analyzer = MLAnalyzer()
self.behavioral_analyzer = BehavioralAnalyzer()
self.comparative_analyzer = ComparativeAnalyzer()
# 初始化集成服务
self.health_apps = HealthAppsIntegration()
self.calendar_apps = CalendarAppsIntegration()
self.social_media = SocialMediaIntegration()
self.wearable_devices = WearableDevicesIntegration()
# 初始化安全模块
self.encryption_manager = EncryptionManager(self.config.privacy_config)
self.anonymization_tool = AnonymizationTool()
self.access_control = AccessControlManager()
self.audit_logger = AuditLogger()
# 初始化可视化引擎
self.viz_engine = VisualizationEngine()
# 系统状态
self.is_running = False
self.background_threads = []
self.current_user = None
self.logger.info("MoodTracker System initialized successfully!")
def run(self, mode: str = "cli", user_id: Optional[str] = None):
"""运行应用程序"""
try:
self.is_running = True
# 设置当前用户
if user_id:
self.current_user = self.mood_service.get_user_profile(user_id)
if not self.current_user:
self.logger.warning(f"User {user_id} not found")
if mode == "cli":
self._run_cli_mode()
elif mode == "web":
self._run_web_mode()
elif mode == "mobile":
self._run_mobile_mode()
elif mode == "voice":
self._run_voice_mode()
elif mode == "service":
self._run_service_mode()
else:
self.logger.error(f"Unknown mode: {mode}")
except KeyboardInterrupt:
self.logger.info("Application interrupted by user")
except Exception as e:
self.logger.error(f"Application error: {e}")
raise
finally:
self.stop()
def stop(self):
"""停止系统"""
self.is_running = False
# 停止后台任务
self._stop_background_tasks()
# 等待后台线程结束
for thread in self.background_threads:
thread.join(timeout=5)
self.logger.info("MoodTracker System stopped")
def _run_cli_mode(self):
"""运行命令行模式"""
self.cli_interface.run()
def _run_web_mode(self):
"""运行Web服务模式"""
self.web_interface.run(host='localhost', port=8080)
def _run_mobile_mode(self):
"""运行移动服务模式"""
self.mobile_interface.run(port=8081)
def _run_voice_mode(self):
"""运行语音服务模式"""
self.voice_interface.run()
def _run_service_mode(self):
"""运行服务模式（后台守护进程）"""
self.logger.info("Starting MoodTracker Service Mode...")
# 启动后台任务调度器
self._start_background_tasks()
# 保持服务运行
while self.is_running:
time.sleep(1)
def _start_background_tasks(self):
"""启动后台任务"""
# 定时生成分析报告
self.task_scheduler.add_job(
func=self._generate_daily_insights,
trigger='cron',
hour=8,
minute=0,
id='daily_insights'
)
# 定时预测情绪趋势
self.task_scheduler.add_job(
func=self._update_mood_predictions,
trigger='cron',
hour=20,
minute=0,
id='mood_prediction'
)
# 定时数据备份
self.task_scheduler.add_job(
func=self._backup_user_data,
trigger='cron',
day_of_week='sunday',
hour=2,
minute=0,
id='data_backup'
)
# 定时清理过期数据
self.task_scheduler.add_job(
func=self._cleanup_old_data,
trigger='cron',
day_of_month=1,
hour=3,
minute=0,
id='data_cleanup'
)
# 启动调度器
self.task_scheduler.start()
self.logger.info("Background tasks started")
def _stop_background_tasks(self):
"""停止后台任务"""
if hasattr(self, 'task_scheduler'):
self.task_scheduler.stop_all_jobs()
def _generate_daily_insights(self):
"""生成每日洞察"""
try:
if not self.current_user:
return
# 获取昨天的情绪数据
yesterday = datetime.now() - timedelta(days=1)
daily_data = self.mood_service.get_daily_summary(self.current_user.id, yesterday)
if daily_data:
# 生成洞察分析
insights = self.analysis_service.generate_daily_insights(daily_data)
# 生成个性化建议
suggestions = self.suggestion_service.generate_daily_suggestions(
self.current_user, insights
)
# 发送每日洞察通知
self._send_daily_insights_notification(insights, suggestions)
self.logger.info(f"Generated daily insights for user {self.current_user.id}")
except Exception as e:
self.logger.error(f"Error generating daily insights: {e}")
def _update_mood_predictions(self):
如果你觉得这个工具好用，欢迎关注我！
