First commit - es tut schon mal ganz gut

2026-02-27 12:35:29 +00:00
commit 53124c1c78
27 changed files with 8403 additions and 0 deletions
--- a/app/api/ausgaben/[id]/route.ts
+++ b/app/api/ausgaben/[id]/route.ts
@@ -0,0 +1,82 @@
+import { NextResponse } from 'next/server';
+import { getDbPool } from '@/lib/db';
+import { ResultSetHeader } from 'mysql2';
+
+// PUT /api/ausgaben/[id] - Update entry
+export async function PUT(
+  request: Request,
+  context: { params: Promise<{ id: string }> }
+) {
+  try {
+    const { id } = await context.params;
+    const body = await request.json();
+    const { Datum, WochTag, Wo, Was, Wieviel, Wie, OK } = body;
+
+    const pool = getDbPool();
+
+    const query = `
+      UPDATE Ausgaben_Tag
+      SET Datum = ?, WochTag = ?, Wo = ?, Was = ?, Wieviel = ?, Wie = ?, OK = ?
+      WHERE ID = ?
+    `;
+
+    const [result] = await pool.query<ResultSetHeader>(query, [
+      Datum,
+      WochTag,
+      Wo,
+      Was,
+      parseFloat(Wieviel),
+      Wie,
+      OK || 0,
+      parseInt(id),
+    ]);
+
+    if (result.affectedRows === 0) {
+      return NextResponse.json(
+        { success: false, error: 'Entry not found' },
+        { status: 404 }
+      );
+    }
+
+    return NextResponse.json({
+      success: true,
+    });
+  } catch (error) {
+    console.error('Database error:', error);
+    return NextResponse.json(
+      { success: false, error: 'Database error' },
+      { status: 500 }
+    );
+  }
+}
+
+// DELETE /api/ausgaben/[id] - Delete entry
+export async function DELETE(
+  request: Request,
+  context: { params: Promise<{ id: string }> }
+) {
+  try {
+    const { id } = await context.params;
+    const pool = getDbPool();
+
+    const query = 'DELETE FROM Ausgaben_Tag WHERE ID = ?';
+    const [result] = await pool.query<ResultSetHeader>(query, [parseInt(id)]);
+
+    if (result.affectedRows === 0) {
+      return NextResponse.json(
+        { success: false, error: 'Entry not found' },
+        { status: 404 }
+      );
+    }
+
+    return NextResponse.json({
+      success: true,
+    });
+  } catch (error) {
+    console.error('Database error:', error);
+    return NextResponse.json(
+      { success: false, error: 'Database error' },
+      { status: 500 }
+    );
+  }
+}
--- a/app/api/ausgaben/route.ts
+++ b/app/api/ausgaben/route.ts
@@ -0,0 +1,86 @@
+import { NextResponse } from 'next/server';
+import { getDbPool } from '@/lib/db';
+import { RowDataPacket, ResultSetHeader } from 'mysql2';
+
+// GET /api/ausgaben - Fetch entries
+export async function GET(request: Request) {
+  try {
+    const { searchParams } = new URL(request.url);
+    const limit = searchParams.get('limit') || '10';
+    const startDate = searchParams.get('startDate');
+    const month = searchParams.get('month');
+    const year = searchParams.get('year');
+
+    const pool = getDbPool();
+
+    let query = 'SELECT * FROM Ausgaben_Tag';
+    const params: any[] = [];
+
+    if (month && year) {
+      query += ' WHERE YEAR(Datum) = ? AND MONTH(Datum) = ?';
+      params.push(year, month);
+    } else if (startDate) {
+      query += ' WHERE Datum >= ?';
+      params.push(startDate);
+    }
+
+    query += ' ORDER BY Datum DESC, ID DESC LIMIT ?';
+    params.push(parseInt(limit));
+
+    const [rows] = await pool.query<RowDataPacket[]>(query, params);
+
+    return NextResponse.json({
+      success: true,
+      data: rows,
+    });
+  } catch (error) {
+    console.error('Database error:', error);
+    return NextResponse.json(
+      { success: false, error: 'Database error' },
+      { status: 500 }
+    );
+  }
+}
+
+// POST /api/ausgaben - Create new entry
+export async function POST(request: Request) {
+  try {
+    const body = await request.json();
+    const { Datum, WochTag, Wo, Was, Wieviel, Wie, OK } = body;
+
+    if (!Datum || !Wo || !Was || !Wieviel || !Wie) {
+      return NextResponse.json(
+        { success: false, error: 'Missing required fields' },
+        { status: 400 }
+      );
+    }
+
+    const pool = getDbPool();
+
+    const query = `
+      INSERT INTO Ausgaben_Tag (Datum, WochTag, Wo, Was, Wieviel, Wie, OK)
+      VALUES (?, ?, ?, ?, ?, ?, ?)
+    `;
+
+    const [result] = await pool.query<ResultSetHeader>(query, [
+      Datum,
+      WochTag,
+      Wo,
+      Was,
+      parseFloat(Wieviel),
+      Wie,
+      OK || 0,
+    ]);
+
+    return NextResponse.json({
+      success: true,
+      id: result.insertId,
+    });
+  } catch (error) {
+    console.error('Database error:', error);
+    return NextResponse.json(
+      { success: false, error: 'Database error' },
+      { status: 500 }
+    );
+  }
+}
--- a/app/api/ausgaben/stats/route.ts
+++ b/app/api/ausgaben/stats/route.ts
@@ -0,0 +1,69 @@
+import { NextResponse } from 'next/server';
+import { getDbPool } from '@/lib/db';
+import { RowDataPacket } from 'mysql2';
+
+// GET /api/ausgaben/stats - Get monthly statistics
+export async function GET(request: Request) {
+  try {
+    const { searchParams } = new URL(request.url);
+    const month = searchParams.get('month');
+    const year = searchParams.get('year');
+
+    if (!month || !year) {
+      return NextResponse.json(
+        { success: false, error: 'Month and year are required' },
+        { status: 400 }
+      );
+    }
+
+    const pool = getDbPool();
+
+    // Get total ausgaben and breakdown by payment type
+    const query = `
+      SELECT 
+        SUM(CASE WHEN Wie IN ('EC-R', 'EC-B', 'bar-R', 'bar-B', 'Ueber') THEN Wieviel ELSE 0 END) as totalAusgaben,
+        SUM(CASE WHEN Wie = 'EC-R' THEN Wieviel ELSE 0 END) as ECR,
+        SUM(CASE WHEN Wie = 'EC-B' THEN Wieviel ELSE 0 END) as ECB,
+        SUM(CASE WHEN Wie = 'bar-R' THEN Wieviel ELSE 0 END) as barR,
+        SUM(CASE WHEN Wie = 'bar-B' THEN Wieviel ELSE 0 END) as barB,
+        SUM(CASE WHEN Wie = 'Einnahme' THEN Wieviel ELSE 0 END) as Einnahmen,
+        SUM(CASE WHEN Wie = 'Ueber' THEN Wieviel ELSE 0 END) as Ueberweisungen
+      FROM Ausgaben_Tag
+      WHERE YEAR(Datum) = ? AND MONTH(Datum) = ?
+    `;
+
+    const [rows] = await pool.query<RowDataPacket[]>(query, [year, month]);
+
+    const data = rows[0] || {
+      totalAusgaben: 0,
+      ECR: 0,
+      ECB: 0,
+      barR: 0,
+      barB: 0,
+      Einnahmen: 0,
+      Ueberweisungen: 0,
+    };
+
+    // Convert string values from MySQL to numbers
+    const parsedData = {
+      totalAusgaben: parseFloat(data.totalAusgaben) || 0,
+      ECR: parseFloat(data.ECR) || 0,
+      ECB: parseFloat(data.ECB) || 0,
+      barR: parseFloat(data.barR) || 0,
+      barB: parseFloat(data.barB) || 0,
+      Einnahmen: parseFloat(data.Einnahmen) || 0,
+      Ueberweisungen: parseFloat(data.Ueberweisungen) || 0,
+    };
+
+    return NextResponse.json({
+      success: true,
+      data: parsedData,
+    });
+  } catch (error) {
+    console.error('Database error:', error);
+    return NextResponse.json(
+      { success: false, error: 'Database error' },
+      { status: 500 }
+    );
+  }
+}