WeWork MCP Server

Instructions

Phân tích các tasks trong dự án

Args:
    project_id: ID của dự án
    export_csv: Có xuất file CSV không (default: False)

Returns:
    Phân tích tasks dưới dạng dictionary

Implementation Reference

• wework_mcp_server.py:120-201 (handler)

  The core handler function for the 'analyze_project_tasks' MCP tool. It is decorated with @mcp.tool() for automatic registration, fetches project details and task analysis from WeWorkClient, processes data with pandas, computes task status statistics, converts to dictionary format, and optionally exports results to CSV.

  @mcp.tool()
  def analyze_project_tasks(project_id: str, export_csv: bool = False) -> Dict[str, Any]:
      """
      Phân tích các tasks trong dự án
      
      Args:
          project_id: ID của dự án
          export_csv: Có xuất file CSV không (default: False)
      
      Returns:
          Phân tích tasks dưới dạng dictionary
      """
      try:
          if not wework_client:
              return {'error': 'WeWork client not initialized'}
          
          logger.info(f"Analyzing tasks for project ID: {project_id}")
          
          # Lấy thông tin dự án
          project_info = wework_client.get_project_info(project_id)
          if not project_info:
              return {
                  'error': f'Không tìm thấy dự án với ID: {project_id}',
                  'success': False
              }
          
          # Phân tích tasks
          df = wework_client.get_project_analysis(project_id)
          
          if df.empty:
              return {
                  'success': True,
                  'project_name': project_info['name'],
                  'project_id': project_id,
                  'tasks': [],
                  'summary': {
                      'total_tasks': 0,
                      'completed_tasks': 0,
                      'in_progress_tasks': 0,
                      'failed_tasks': 0
                  }
              }
          
          # Tính thống kê
          status_counts = df['Trạng thái'].value_counts().to_dict() if 'Trạng thái' in df.columns else {}
          
          # Chuyển DataFrame thành dictionary
          tasks_data = df.to_dict(orient='records')
          
          # Xuất CSV nếu được yêu cầu
          csv_filename = None
          if export_csv:
              csv_filename = f"{project_info['name']}_tasks_analysis.csv"
              try:
                  df.to_csv(csv_filename, index=False, encoding='utf-8-sig')
                  logger.info(f"CSV exported to: {csv_filename}")
              except Exception as csv_error:
                  logger.error(f"Failed to export CSV: {csv_error}")
          
          result = {
              'success': True,
              'project_name': project_info['name'],
              'project_id': project_id,
              'tasks': tasks_data,
              'total_tasks': len(df),
              'summary': {
                  'total_tasks': len(df),
                  'completed_tasks': status_counts.get('Hoàn thành', 0),
                  'in_progress_tasks': status_counts.get('Đang thực hiện', 0),
                  'failed_tasks': status_counts.get('Thất bại', 0),
                  'status_breakdown': status_counts
              }
          }
          
          if csv_filename:
              result['csv_file'] = csv_filename
              
          return result
          
      except Exception as e:
          logger.error(f"Error in analyze_project_tasks: {e}")
          return {'error': str(e), 'success': False}

• wework_mcp_server.py:121-131 (schema)

  Input schema defined by function parameters with type hints (project_id: str, export_csv: bool = False) and output as Dict[str, Any]. Detailed in the docstring with Args and Returns sections.

  def analyze_project_tasks(project_id: str, export_csv: bool = False) -> Dict[str, Any]:
      """
      Phân tích các tasks trong dự án
      
      Args:
          project_id: ID của dự án
          export_csv: Có xuất file CSV không (default: False)
      
      Returns:
          Phân tích tasks dưới dạng dictionary
      """

• wework_mcp_server.py:120-120 (registration)

  The @mcp.tool() decorator registers the analyze_project_tasks function as an MCP tool in the FastMCP server.

  @mcp.tool()

• wework_http_server.py:38-39 (registration)

  Import of the analyze_project_tasks tool function from the MCP server module for use in the HTTP server endpoints.

  from wework_mcp_server import (
      search_projects, get_project_details, analyze_project_tasks,

• wework_http_server.py:133-133 (helper)

  Usage of the analyze_project_tasks function within the HTTP server's project analysis endpoint.

  result = analyze_project_tasks(project_id, export_csv)