import requests
import json
from datetime import datetime, timedelta

# 가상의 POS API 설정
POS_API_BASE_URL = "https://api.pos-vendor.com/v1"
POS_API_KEY = "YOUR_POS_API_KEY" # 실제 키로 대체 필요

def fetch_daily_sales_data(target_date: datetime):
    """
    지정된 날짜의 일별 매출 데이터를 POS API에서 가져옵니다.
    """
    endpoint = f"{POS_API_BASE_URL}/sales"
    
    # API 요청 파라미터 설정
    # POS API마다 파라미터 이름과 형식이 다를 수 있습니다.
    params = {
        "startDate": target_date.strftime("%Y-%m-%dT00:00:00Z"),
        "endDate": target_date.strftime("%Y-%m-%dT23:59:59Z"),
        "storeId": "STORE_001", # 특정 매장 ID, 실제 환경에서는 여러 매장을 순회
        "page": 1,
        "pageSize": 100
    }
    
    headers = {
        "Authorization": f"Bearer {POS_API_KEY}", # 또는 "X-API-KEY": POS_API_KEY
        "Content-Type": "application/json"
    }

    all_sales_data = []
    
    while True:
        try:
            print(f"Fetching sales data for {target_date.strftime(%Y-%m-%d)} (Page {params[page]})...")
            response = requests.get(endpoint, params=params, headers=headers, timeout=10)
            response.raise_for_status() # HTTP 오류 발생 시 예외 발생

            data = response.json()
            sales_records = data.get("sales", [])
            all_sales_data.extend(sales_records)
            
            # 페이지네이션 처리
            # 실제 API 응답 구조에 따라 nextPageToken, hasMore 등의 필드를 확인해야 합니다.
            if not data.get("hasNextPage") or not sales_records:
                break
            params["page"] += 1

        except requests.exceptions.RequestException as e:
            print(f"API 요청 중 오류 발생: {e}")
            break
        except json.JSONDecodeError:
            print(f"API 응답 JSON 디코딩 오류: {response.text}")
            break
        except Exception as e:
            print(f"알 수 없는 오류 발생: {e}")
            break
            
    return all_sales_data

if __name__ == "__main__":
    # 어제 날짜의 데이터를 가져오는 예시
    yesterday = datetime.now() - timedelta(days=1)
    sales_data = fetch_daily_sales_data(yesterday)

    if sales_data:
        print(f"\n총 {len(sales_data)}건의 매출 데이터가 성공적으로 수집되었습니다.")
        # 예시로 첫 3개 데이터 출력
        for i, record in enumerate(sales_data[:3]):
            print(f"  - 거래 ID: {record.get(transactionId)}, 금액: {record.get(totalAmount)}, 시간: {record.get(timestamp)}")
    else:
        print("매출 데이터를 가져오지 못했습니다.")

    # 수집된 데이터를 추가 처리 (정제, 저장 등)
    # ...

import pandas as pd

def clean_and_transform_sales_data(raw_sales_data: list):
    """
    POS에서 가져온 원본 매출 데이터를 정제하고 변환합니다.
    """
    if not raw_sales_data:
        return pd.DataFrame()

    df = pd.DataFrame(raw_sales_data)

    # 1. 컬럼명 표준화 (예시: POS API 응답에 따라 다를 수 있음)
    df = df.rename(columns={
        transactionId: transaction_id,
        totalAmount: total_amount,
        timestamp: sale_timestamp,
        productId: product_id,
        productName: product_name,
        quantity: quantity,
        unitPrice: unit_price,
        storeId: store_id
    })

    # 2. 데이터 타입 변환
    df[sale_timestamp] = pd.to_datetime(df[sale_timestamp], errors=coerce)
    df[total_amount] = pd.to_numeric(df[total_amount], errors=coerce)
    df[quantity] = pd.to_numeric(df[quantity], errors=coerce).fillna(0).astype(int)
    df[unit_price] = pd.to_numeric(df[unit_price], errors=coerce)

    # 3. 결측치 처리 (예시: 매출 금액이 없는 경우 해당 레코드 삭제)
    df.dropna(subset=[total_amount, sale_timestamp], inplace=True)

    # 4. 파생 변수 생성
    df[sale_date] = df[sale_timestamp].dt.date
    df[sale_hour] = df[sale_timestamp].dt.hour
    df[day_of_week] = df[sale_timestamp].dt.day_name() # 요일

    # 5. 이상치 제거 (예시: 매출 금액이 음수인 경우)
    df = df[df[total_amount] >= 0]
    df = df[df[quantity] >= 0]

    # 필요한 컬럼만 선택
    df = df[[transaction_id, store_id, sale_timestamp, sale_date, sale_hour,
             day_of_week, product_id, product_name, quantity, unit_price, total_amount]]

    return df

if __name__ == "__main__":
    # fetch_daily_sales_data 함수에서 가져온 가상의 매출 데이터 (단순화된 예시)
    sample_raw_sales = [
        {transactionId: T001, totalAmount: 10000, timestamp: 2023-10-26T10:30:00Z, productId: P001, productName: 아메리카노, quantity: 2, unitPrice: 5000, storeId: S001},
        {transactionId: T002, totalAmount: 15000, timestamp: 2023-10-26T11:00:00Z, productId: P002, productName: 카페라떼, quantity: 3, unitPrice: 5000, storeId: S001},
        {transactionId: T003, totalAmount: None, timestamp: 2023-10-26T12:00:00Z, productId: P001, productName: 아메리카노, quantity: 1, unitPrice: 5000, storeId: S002}, # 결측치 예시
        {transactionId: T004, totalAmount: 8000, timestamp: invalid-date, productId: P003, productName: 샌드위치, quantity: 1, unitPrice: 8000, storeId: S001}, # 잘못된 날짜 예시
        {transactionId: T005, totalAmount: 5000, timestamp: 2023-10-26T14:00:00Z, productId: P001, productName: 아메리카노, quantity: -1, unitPrice: 5000, storeId: S002}, # 음수 수량 예시
    ]

    cleaned_df = clean_and_transform_sales_data(sample_raw_sales)
    print("\n정제 및 변환된 데이터프레임:")
    print(cleaned_df.head())
    print(f"\n총 {len(cleaned_df)}건의 데이터가 정제 후 남았습니다.")

// src/components/DailySalesDashboard.js
import React, { useState, useEffect } from react;
import { Line } from react-chartjs-2;
import { Chart as ChartJS, CategoryScale, LinearScale, PointElement, LineElement, Title, Tooltip, Legend } from chart.js;

ChartJS.register(
  CategoryScale,
  LinearScale,
  PointElement,
  LineElement,
  Title,
  Tooltip,
  Legend
);

const DailySalesDashboard = () => {
  const [salesData, setSalesData] = useState([]);
  const [loading, setLoading] = useState(true);
  const [error, setError] = useState(null);

  useEffect(() => {
    const fetchSalesData = async () => {
      try {
        setLoading(true);
        // 백엔드 API 엔드포인트 호출
        const response = await fetch(/api/dashboard/daily-sales?storeId=S001&startDate=2023-10-01&endDate=2023-10-31);
        if (!response.ok) {
          throw new Error(`HTTP error! status: ${response.status}`);
        }
        const data = await response.json();
        setSalesData(data.sales);
      } catch (e) {
        setError(e.message);
      } finally {
        setLoading(false);
      }
    };

    fetchSalesData();
  }, []); // 컴포넌트 마운트 시 한 번만 실행

  if (loading) return <div>데이터를 불러오는 중입니다...</div>;
  if (error) return <div>오류 발생: {error}</div>;
  if (!salesData || salesData.length === 0) return <div>표시할 매출 데이터가 없습니다.</div>;

  // 차트 데이터 준비
  const chartLabels = salesData.map(item => item.date);
  const chartValues = salesData.map(item => item.totalAmount);

  const data = {
    labels: chartLabels,
    datasets: [
      {
        label: 일별 매출 (원),
        data: chartValues,
        fill: false,
        backgroundColor: rgb(75, 192, 192),
        borderColor: rgba(75, 192, 192, 0.8),
      },
    ],
  };

  const options = {
    responsive: true,
    plugins: {
      legend: {
        position: top,
      },
      title: {
        display: true,
        text: 최근 30일 일별 매출 현황,
      },
    },
    scales: {
      y: {
        beginAtZero: true,
        title: {
          display: true,
          text: 매출액 (원)
        }
      },
      x: {
        title: {
          display: true,
          text: 날짜
        }
      }
    }
  };

  return (
    <div style={{ width: 80%, margin: auto }}>
      <h2>일별 매출 대시보드</h2>
      <Line data={data} options={options} />
    </div>
  );
};

export default DailySalesDashboard;