Merge pull request '#77-progress-pitch-books-table' (#79) from #77-progress-pitch-books-table into main
Reviewed-on: #79pull/78/head^2
commit
443a0c5d66
|
|
@ -5,7 +5,6 @@ from dotenv import load_dotenv
|
|||
from controller import register_routes
|
||||
from model.database import init_db
|
||||
from controller.socketIO import socketio
|
||||
from controller.kennzahlen import kennzahlen_bp
|
||||
|
||||
app = Flask(__name__)
|
||||
CORS(app)
|
||||
|
|
@ -22,9 +21,6 @@ init_db(app)
|
|||
register_routes(app)
|
||||
|
||||
|
||||
# Register blueprints
|
||||
app.register_blueprint(kennzahlen_bp)
|
||||
|
||||
@app.route("/health")
|
||||
def health_check():
|
||||
return "OK"
|
||||
|
|
|
|||
|
|
@ -1,61 +0,0 @@
|
|||
from flask import Blueprint, jsonify, request
|
||||
from model.kennzahl import Kennzahl
|
||||
from model.database import db
|
||||
|
||||
kennzahlen_bp = Blueprint('kennzahlen', __name__)
|
||||
|
||||
# Beispieldaten
|
||||
EXAMPLE_DATA = [
|
||||
{"pdf_id": "example", "label": "Fondsname", "value": "Fund Real Estate Prime Europe", "page": 1, "status": "ok"},
|
||||
{"pdf_id": "example", "label": "Fondsmanager", "value": "", "page": 1, "status": "error"},
|
||||
{"pdf_id": "example", "label": "Risikoprofil", "value": "Core/Core+", "page": 10, "status": "warning"},
|
||||
{"pdf_id": "example", "label": "LTV", "value": "30-35 %", "page": 8, "status": "ok"},
|
||||
{"pdf_id": "example", "label": "Ausschüttungsrendite", "value": "4%", "page": 34, "status": "ok"}
|
||||
]
|
||||
|
||||
|
||||
@kennzahlen_bp.route('/api/kennzahlen/init', methods=['POST'])
|
||||
def init_kennzahlen():
|
||||
try:
|
||||
# Lösche existierende Beispieldaten
|
||||
Kennzahl.query.filter_by(pdf_id='example').delete()
|
||||
|
||||
# Füge Beispieldaten ein
|
||||
for data in EXAMPLE_DATA:
|
||||
kennzahl = Kennzahl(
|
||||
pdf_id=data['pdf_id'],
|
||||
label=data['label'],
|
||||
value=data['value'],
|
||||
page=data['page'],
|
||||
status=data['status']
|
||||
)
|
||||
db.session.add(kennzahl)
|
||||
|
||||
db.session.commit()
|
||||
return jsonify({"message": "Kennzahlen erfolgreich initialisiert"})
|
||||
|
||||
except Exception as e:
|
||||
db.session.rollback()
|
||||
return jsonify({"error": str(e)}), 500
|
||||
|
||||
|
||||
@kennzahlen_bp.route('/api/kennzahlen', methods=['GET'])
|
||||
def get_kennzahlen():
|
||||
pdf_id = request.args.get('pdf_id', 'example') # Default zu 'example' für Beispieldaten
|
||||
kennzahlen = Kennzahl.query.filter_by(pdf_id=pdf_id).all()
|
||||
return jsonify([k.to_dict() for k in kennzahlen])
|
||||
|
||||
|
||||
@kennzahlen_bp.route('/api/kennzahlen/<label>', methods=['PUT'])
|
||||
def update_kennzahl(label):
|
||||
data = request.get_json()
|
||||
pdf_id = request.args.get('pdf_id', 'example') # Default zu 'example' für Beispieldaten
|
||||
|
||||
kennzahl = Kennzahl.query.filter_by(pdf_id=pdf_id, label=label).first()
|
||||
if not kennzahl:
|
||||
return jsonify({'error': 'Kennzahl nicht gefunden'}), 404
|
||||
|
||||
kennzahl.value = data.get('value', kennzahl.value)
|
||||
db.session.commit()
|
||||
|
||||
return jsonify(kennzahl.to_dict())
|
||||
|
|
@ -35,7 +35,7 @@ def create_kpi_setting():
|
|||
"translation",
|
||||
"example",
|
||||
"position",
|
||||
"active"
|
||||
"active",
|
||||
]
|
||||
for field in required_fields:
|
||||
if field not in data:
|
||||
|
|
@ -61,7 +61,7 @@ def create_kpi_setting():
|
|||
translation=data["translation"],
|
||||
example=data["example"],
|
||||
position=data["position"],
|
||||
active=data["active"]
|
||||
active=data["active"],
|
||||
)
|
||||
|
||||
db.session.add(new_kpi_setting)
|
||||
|
|
@ -136,7 +136,12 @@ def update_kpi_positions():
|
|||
try:
|
||||
for update_item in data:
|
||||
if "id" not in update_item or "position" not in update_item:
|
||||
return jsonify({"error": "Each item must have 'id' and 'position' fields"}), 400
|
||||
return (
|
||||
jsonify(
|
||||
{"error": "Each item must have 'id' and 'position' fields"}
|
||||
),
|
||||
400,
|
||||
)
|
||||
|
||||
kpi_setting = KPISettingModel.query.get_or_404(update_item["id"])
|
||||
kpi_setting.position = update_item["position"]
|
||||
|
|
@ -148,4 +153,4 @@ def update_kpi_positions():
|
|||
|
||||
except Exception as e:
|
||||
db.session.rollback()
|
||||
return jsonify({"error": f"Failed to update positions: {str(e)}"}), 500
|
||||
return jsonify({"error": f"Failed to update positions: {str(e)}"}), 500
|
||||
|
|
|
|||
|
|
@ -19,6 +19,6 @@ def progress():
|
|||
):
|
||||
return jsonify({"error": "Invalid progress value"}), 400
|
||||
|
||||
socketio.emit("progress", {"id": data["id"], "progress": data["progress"]})
|
||||
socketio.emit("progress", {"id": int(data["id"]), "progress": data["progress"]})
|
||||
# Process the data and return a response
|
||||
return jsonify({"message": "Progress updated"})
|
||||
|
|
|
|||
|
|
@ -14,4 +14,5 @@ def init_db(app):
|
|||
with app.app_context():
|
||||
db.create_all()
|
||||
from model.seed_data import seed_default_kpi_settings
|
||||
|
||||
seed_default_kpi_settings()
|
||||
|
|
|
|||
|
|
@ -1,26 +0,0 @@
|
|||
from .database import db
|
||||
|
||||
|
||||
class Kennzahl(db.Model):
|
||||
__tablename__ = 'kennzahlen'
|
||||
|
||||
id = db.Column(db.Integer, primary_key=True)
|
||||
pdf_id = db.Column(db.String(100), nullable=False) # ID des PDFs
|
||||
label = db.Column(db.String(100), nullable=False)
|
||||
value = db.Column(db.String(100))
|
||||
page = db.Column(db.Integer)
|
||||
status = db.Column(db.String(20))
|
||||
|
||||
# Zusammengesetzter Unique-Constraint für pdf_id und label
|
||||
__table_args__ = (
|
||||
db.UniqueConstraint('pdf_id', 'label', name='unique_pdf_kennzahl'),
|
||||
)
|
||||
|
||||
def to_dict(self):
|
||||
return {
|
||||
'pdf_id': self.pdf_id,
|
||||
'label': self.label,
|
||||
'value': self.value,
|
||||
'page': self.page,
|
||||
'status': self.status
|
||||
}
|
||||
|
|
@ -38,10 +38,12 @@ class KPISettingModel(db.Model):
|
|||
"translation": self.translation,
|
||||
"example": self.example,
|
||||
"position": self.position,
|
||||
"active": self.active
|
||||
"active": self.active,
|
||||
}
|
||||
|
||||
def __init__(self, name, description, mandatory, type, translation, example, position, active):
|
||||
def __init__(
|
||||
self, name, description, mandatory, type, translation, example, position, active
|
||||
):
|
||||
self.name = name
|
||||
self.description = description
|
||||
self.mandatory = mandatory
|
||||
|
|
|
|||
|
|
@ -1,6 +1,7 @@
|
|||
from model.database import db
|
||||
from sqlalchemy.orm import Mapped, mapped_column
|
||||
from sqlalchemy import LargeBinary
|
||||
from datetime import datetime
|
||||
|
||||
|
||||
class PitchBookModel(db.Model):
|
||||
|
|
@ -8,9 +9,15 @@ class PitchBookModel(db.Model):
|
|||
filename: Mapped[str] = mapped_column()
|
||||
file: Mapped[bytes] = mapped_column(LargeBinary)
|
||||
kpi: Mapped[str | None]
|
||||
created_at: Mapped[datetime] = mapped_column(default=datetime.utcnow)
|
||||
|
||||
def to_dict(self):
|
||||
return {"id": self.id, "filename": self.filename, "kpi": self.kpi}
|
||||
return {
|
||||
"id": self.id,
|
||||
"filename": self.filename,
|
||||
"kpi": self.kpi,
|
||||
"created_at": self.created_at.isoformat() if self.created_at else None,
|
||||
}
|
||||
|
||||
def __init__(self, filename, file):
|
||||
self.filename = filename
|
||||
|
|
|
|||
|
|
@ -1,6 +1,7 @@
|
|||
from model.database import db
|
||||
from model.kpi_setting_model import KPISettingModel, KPISettingType
|
||||
|
||||
|
||||
def seed_default_kpi_settings():
|
||||
if KPISettingModel.query.first() is not None:
|
||||
print("KPI Settings bereits vorhanden, Seeding übersprungen")
|
||||
|
|
@ -15,7 +16,7 @@ def seed_default_kpi_settings():
|
|||
"translation": "Fund Name",
|
||||
"example": "Alpha Real Estate Fund I",
|
||||
"position": 1,
|
||||
"active": True
|
||||
"active": True,
|
||||
},
|
||||
{
|
||||
"name": "Fondsmanager",
|
||||
|
|
@ -25,7 +26,7 @@ def seed_default_kpi_settings():
|
|||
"translation": "Fund Manager",
|
||||
"example": "Max Mustermann",
|
||||
"position": 2,
|
||||
"active": True
|
||||
"active": True,
|
||||
},
|
||||
{
|
||||
"name": "AIFM",
|
||||
|
|
@ -35,7 +36,7 @@ def seed_default_kpi_settings():
|
|||
"translation": "AIFM",
|
||||
"example": "Alpha Investment Management GmbH",
|
||||
"position": 3,
|
||||
"active": True
|
||||
"active": True,
|
||||
},
|
||||
{
|
||||
"name": "Datum",
|
||||
|
|
@ -45,7 +46,7 @@ def seed_default_kpi_settings():
|
|||
"translation": "Date",
|
||||
"example": "05.05.2025",
|
||||
"position": 4,
|
||||
"active": True
|
||||
"active": True,
|
||||
},
|
||||
{
|
||||
"name": "Risikoprofil",
|
||||
|
|
@ -55,7 +56,7 @@ def seed_default_kpi_settings():
|
|||
"translation": "Risk Profile",
|
||||
"example": "Core/Core++",
|
||||
"position": 5,
|
||||
"active": True
|
||||
"active": True,
|
||||
},
|
||||
{
|
||||
"name": "Artikel",
|
||||
|
|
@ -65,7 +66,7 @@ def seed_default_kpi_settings():
|
|||
"translation": "Article",
|
||||
"example": "Artikel 8",
|
||||
"position": 6,
|
||||
"active": True
|
||||
"active": True,
|
||||
},
|
||||
{
|
||||
"name": "Zielrendite",
|
||||
|
|
@ -75,7 +76,7 @@ def seed_default_kpi_settings():
|
|||
"translation": "Target Return",
|
||||
"example": "6.5",
|
||||
"position": 7,
|
||||
"active": True
|
||||
"active": True,
|
||||
},
|
||||
{
|
||||
"name": "Rendite",
|
||||
|
|
@ -85,7 +86,7 @@ def seed_default_kpi_settings():
|
|||
"translation": "Return",
|
||||
"example": "5.8",
|
||||
"position": 8,
|
||||
"active": True
|
||||
"active": True,
|
||||
},
|
||||
{
|
||||
"name": "Zielausschüttung",
|
||||
|
|
@ -95,7 +96,7 @@ def seed_default_kpi_settings():
|
|||
"translation": "Target Distribution",
|
||||
"example": "4.0",
|
||||
"position": 9,
|
||||
"active": True
|
||||
"active": True,
|
||||
},
|
||||
{
|
||||
"name": "Ausschüttung",
|
||||
|
|
@ -105,7 +106,7 @@ def seed_default_kpi_settings():
|
|||
"translation": "Distribution",
|
||||
"example": "3.8",
|
||||
"position": 10,
|
||||
"active": True
|
||||
"active": True,
|
||||
},
|
||||
{
|
||||
"name": "Laufzeit",
|
||||
|
|
@ -115,7 +116,7 @@ def seed_default_kpi_settings():
|
|||
"translation": "Duration",
|
||||
"example": "7 Jahre, 10, Evergreen",
|
||||
"position": 11,
|
||||
"active": True
|
||||
"active": True,
|
||||
},
|
||||
{
|
||||
"name": "LTV",
|
||||
|
|
@ -125,7 +126,7 @@ def seed_default_kpi_settings():
|
|||
"translation": "LTV",
|
||||
"example": "65.0",
|
||||
"position": 12,
|
||||
"active": True
|
||||
"active": True,
|
||||
},
|
||||
{
|
||||
"name": "Managementgebühren",
|
||||
|
|
@ -135,7 +136,7 @@ def seed_default_kpi_settings():
|
|||
"translation": "Management Fees",
|
||||
"example": "1.5",
|
||||
"position": 13,
|
||||
"active": True
|
||||
"active": True,
|
||||
},
|
||||
{
|
||||
"name": "Sektorenallokation",
|
||||
|
|
@ -145,7 +146,7 @@ def seed_default_kpi_settings():
|
|||
"translation": "Sector Allocation",
|
||||
"example": "Büro, Wohnen, Logistik, Studentenwohnen",
|
||||
"position": 14,
|
||||
"active": True
|
||||
"active": True,
|
||||
},
|
||||
{
|
||||
"name": "Länderallokation",
|
||||
|
|
@ -155,8 +156,8 @@ def seed_default_kpi_settings():
|
|||
"translation": "Country Allocation",
|
||||
"example": "Deutschland,Frankreich, Österreich, Schweiz",
|
||||
"position": 15,
|
||||
"active": True
|
||||
}
|
||||
"active": True,
|
||||
},
|
||||
]
|
||||
|
||||
print("Füge Standard KPI Settings hinzu...")
|
||||
|
|
@ -170,15 +171,17 @@ def seed_default_kpi_settings():
|
|||
translation=kpi_data["translation"],
|
||||
example=kpi_data["example"],
|
||||
position=kpi_data["position"],
|
||||
active=kpi_data["active"]
|
||||
active=kpi_data["active"],
|
||||
)
|
||||
|
||||
db.session.add(kpi_setting)
|
||||
|
||||
try:
|
||||
db.session.commit()
|
||||
print(f"Erfolgreich {len(default_kpi_settings)} Standard KPI Settings hinzugefügt")
|
||||
print(
|
||||
f"Erfolgreich {len(default_kpi_settings)} Standard KPI Settings hinzugefügt"
|
||||
)
|
||||
except Exception as e:
|
||||
db.session.rollback()
|
||||
print(f"Fehler beim Hinzufügen der Standard KPI Settings: {e}")
|
||||
raise
|
||||
raise
|
||||
|
|
|
|||
|
|
@ -42,7 +42,7 @@ export default function KennzahlenTable({
|
|||
data,
|
||||
pdfId,
|
||||
settings,
|
||||
from
|
||||
from,
|
||||
}: KennzahlenTableProps) {
|
||||
const [editingIndex, setEditingIndex] = useState<string>("");
|
||||
const [editValue, setEditValue] = useState("");
|
||||
|
|
@ -229,12 +229,17 @@ export default function KennzahlenTable({
|
|||
</Tooltip>
|
||||
) : (
|
||||
<Tooltip
|
||||
title={hasNoValue ?
|
||||
<>
|
||||
<b>Problem</b>
|
||||
<br />
|
||||
Es wurden keine Kennzahlen gefunden. Bitte ergänzen!
|
||||
</> : ""
|
||||
title={
|
||||
hasNoValue ? (
|
||||
<>
|
||||
<b>Problem</b>
|
||||
<br />
|
||||
Es wurden keine Kennzahlen gefunden. Bitte
|
||||
ergänzen!
|
||||
</>
|
||||
) : (
|
||||
""
|
||||
)
|
||||
}
|
||||
placement="bottom"
|
||||
arrow
|
||||
|
|
@ -261,7 +266,10 @@ export default function KennzahlenTable({
|
|||
}}
|
||||
>
|
||||
{hasNoValue && (
|
||||
<ErrorOutlineIcon fontSize="small" color="error" />
|
||||
<ErrorOutlineIcon
|
||||
fontSize="small"
|
||||
color="error"
|
||||
/>
|
||||
)}
|
||||
{editingIndex === row.setting.name ? (
|
||||
<TextField
|
||||
|
|
@ -306,7 +314,10 @@ export default function KennzahlenTable({
|
|||
onClick={() => {
|
||||
const extractedValue = row.extractedValues.at(0);
|
||||
if (extractedValue?.page && extractedValue.page > 0) {
|
||||
onPageClick?.(Number(extractedValue.page), extractedValue.entity || "");
|
||||
onPageClick?.(
|
||||
Number(extractedValue.page),
|
||||
extractedValue.entity || "",
|
||||
);
|
||||
}
|
||||
}}
|
||||
sx={{ cursor: "pointer" }}
|
||||
|
|
|
|||
|
|
@ -1,186 +1,388 @@
|
|||
import { Box, Paper, Table, TableBody, TableCell, TableContainer, TableHead, TableRow, Typography, CircularProgress, Chip } from "@mui/material";
|
||||
import { useSuspenseQuery } from "@tanstack/react-query";
|
||||
import CheckCircleIcon from "@mui/icons-material/CheckCircle";
|
||||
import HourglassEmptyIcon from "@mui/icons-material/HourglassEmpty";
|
||||
import PictureAsPdfIcon from "@mui/icons-material/PictureAsPdf";
|
||||
import {
|
||||
Box,
|
||||
Chip,
|
||||
CircularProgress,
|
||||
LinearProgress,
|
||||
Paper,
|
||||
Table,
|
||||
TableBody,
|
||||
TableCell,
|
||||
TableContainer,
|
||||
TableHead,
|
||||
TableRow,
|
||||
Typography,
|
||||
} from "@mui/material";
|
||||
import { useQueryClient, useSuspenseQuery } from "@tanstack/react-query";
|
||||
import { useNavigate } from "@tanstack/react-router";
|
||||
import { useCallback, useEffect, useState } from "react";
|
||||
import { socket } from "../socket";
|
||||
import { fetchPitchBooksById } from "../util/api";
|
||||
import { pitchBooksQueryOptions } from "../util/query";
|
||||
import PictureAsPdfIcon from '@mui/icons-material/PictureAsPdf';
|
||||
import CheckCircleIcon from '@mui/icons-material/CheckCircle';
|
||||
import HourglassEmptyIcon from '@mui/icons-material/HourglassEmpty';
|
||||
|
||||
interface PitchBook {
|
||||
id: number;
|
||||
filename: string;
|
||||
created_at: string;
|
||||
kpi?: string | {
|
||||
[key: string]: {
|
||||
label: string;
|
||||
entity: string;
|
||||
page: number;
|
||||
status: string;
|
||||
source: string;
|
||||
}[];
|
||||
};
|
||||
status?: 'processing' | 'completed';
|
||||
id: number;
|
||||
filename: string;
|
||||
created_at: string;
|
||||
kpi?:
|
||||
| string
|
||||
| {
|
||||
[key: string]: {
|
||||
label: string;
|
||||
entity: string;
|
||||
page: number;
|
||||
status: string;
|
||||
source: string;
|
||||
}[];
|
||||
};
|
||||
status?: "processing" | "completed";
|
||||
}
|
||||
|
||||
export function PitchBooksTable() {
|
||||
const navigate = useNavigate();
|
||||
const { data: pitchBooks, isLoading } = useSuspenseQuery(pitchBooksQueryOptions());
|
||||
const [loadingPitchBooks, setLoadingPitchBooks] = useState<
|
||||
{
|
||||
id: number;
|
||||
progress: number;
|
||||
filename?: string;
|
||||
buffer: number;
|
||||
intervalId?: number;
|
||||
}[]
|
||||
>([]);
|
||||
const navigate = useNavigate();
|
||||
const { data: pitchBooks, isLoading } = useSuspenseQuery(
|
||||
pitchBooksQueryOptions(),
|
||||
);
|
||||
|
||||
const handleRowClick = (pitchBookId: number) => {
|
||||
navigate({
|
||||
to: "/extractedResult/$pitchBook",
|
||||
params: { pitchBook: pitchBookId.toString() },
|
||||
search: { from: "overview" }
|
||||
});
|
||||
};
|
||||
const handleRowClick = (pitchBookId: number) => {
|
||||
navigate({
|
||||
to: "/extractedResult/$pitchBook",
|
||||
params: { pitchBook: pitchBookId.toString() },
|
||||
search: { from: "overview" },
|
||||
});
|
||||
};
|
||||
|
||||
const getKPIValue = (pitchBook: PitchBook, fieldName: string): string => {
|
||||
if (!pitchBook.kpi || typeof pitchBook.kpi === 'string') {
|
||||
try {
|
||||
const parsedKPI = JSON.parse(pitchBook.kpi as string);
|
||||
// Convert array to object format if needed
|
||||
const kpiObj = Array.isArray(parsedKPI) ?
|
||||
parsedKPI.reduce((acc: any, item: any) => {
|
||||
if (!acc[item.label]) acc[item.label] = [];
|
||||
acc[item.label].push(item);
|
||||
return acc;
|
||||
}, {}) : parsedKPI;
|
||||
const onConnection = useCallback(() => {
|
||||
console.log("connected");
|
||||
}, []);
|
||||
|
||||
return kpiObj[fieldName]?.[0]?.entity || 'N/A';
|
||||
} catch {
|
||||
return 'N/A';
|
||||
}
|
||||
}
|
||||
const queryClient = useQueryClient();
|
||||
|
||||
return (pitchBook.kpi as any)[fieldName]?.[0]?.entity || 'N/A';
|
||||
};
|
||||
const onProgress = useCallback(
|
||||
(progress: { id: number; progress: number }) => {
|
||||
if (progress.progress === 100) {
|
||||
setLoadingPitchBooks((prev) => {
|
||||
const intervalId = prev.find(
|
||||
(item) => item.id === progress.id,
|
||||
)?.intervalId;
|
||||
console.log(intervalId, prev);
|
||||
intervalId && clearInterval(intervalId);
|
||||
|
||||
const getStatus = (pitchBook: PitchBook) => {
|
||||
if (pitchBook.kpi &&
|
||||
((typeof pitchBook.kpi === 'string' && pitchBook.kpi !== '{}') ||
|
||||
(typeof pitchBook.kpi === 'object' && Object.keys(pitchBook.kpi).length > 0))) {
|
||||
return 'completed';
|
||||
}
|
||||
return 'processing';
|
||||
};
|
||||
return [...prev.filter((item) => item.id !== progress.id)];
|
||||
});
|
||||
queryClient.invalidateQueries({
|
||||
queryKey: pitchBooksQueryOptions().queryKey,
|
||||
});
|
||||
} else {
|
||||
setLoadingPitchBooks((prev) => {
|
||||
const oldItem = prev.find((item) => item.id === progress.id);
|
||||
let intervalId = oldItem?.intervalId;
|
||||
if (!oldItem) {
|
||||
intervalId = setInterval(() => {
|
||||
setLoadingPitchBooks((prev) => {
|
||||
const oldItem = prev.find((item) => item.id === progress.id);
|
||||
if (!oldItem) return prev;
|
||||
|
||||
if (isLoading) {
|
||||
return (
|
||||
<Box display="flex" justifyContent="center" alignItems="center" height="400px">
|
||||
<CircularProgress sx={{ color: "#383838" }} />
|
||||
</Box>
|
||||
);
|
||||
}
|
||||
return [
|
||||
...prev.filter((e) => e.id !== progress.id),
|
||||
{
|
||||
id: progress.id,
|
||||
progress: oldItem?.progress ?? progress.progress,
|
||||
filename: oldItem?.filename,
|
||||
buffer: oldItem ? oldItem.buffer + 0.5 : 0,
|
||||
intervalId: oldItem.intervalId,
|
||||
},
|
||||
];
|
||||
});
|
||||
}, 400);
|
||||
|
||||
return (
|
||||
<TableContainer
|
||||
component={Paper}
|
||||
sx={{
|
||||
width: "85%",
|
||||
maxWidth: 1200,
|
||||
boxShadow: "0 2px 8px rgba(0,0,0,0.1)",
|
||||
}}
|
||||
>
|
||||
<Table>
|
||||
<TableHead>
|
||||
<TableRow sx={{ backgroundColor: "#f5f5f5" }}>
|
||||
<TableCell sx={{ width: "60px" }}></TableCell>
|
||||
<TableCell sx={{ fontWeight: "bold" }}>Fondsname</TableCell>
|
||||
<TableCell sx={{ fontWeight: "bold" }}>Fondsmanager</TableCell>
|
||||
<TableCell sx={{ fontWeight: "bold" }}>Dateiname</TableCell>
|
||||
<TableCell sx={{ fontWeight: "bold", width: "120px" }}>Status</TableCell>
|
||||
</TableRow>
|
||||
</TableHead>
|
||||
<TableBody>
|
||||
{pitchBooks.map((pitchBook: PitchBook) => {
|
||||
const status = getStatus(pitchBook);
|
||||
const fundName = getKPIValue(pitchBook, 'FONDSNAME') ||
|
||||
getKPIValue(pitchBook, 'FUND_NAME') ||
|
||||
getKPIValue(pitchBook, 'NAME');
|
||||
fetchPitchBooksById(progress.id)
|
||||
.then((res) => {
|
||||
setLoadingPitchBooks((prev) => [
|
||||
...prev.filter((item) => item.id !== progress.id),
|
||||
{
|
||||
id: progress.id,
|
||||
progress: progress.progress,
|
||||
filename: res.filename,
|
||||
buffer: 0,
|
||||
intervalId,
|
||||
},
|
||||
]);
|
||||
})
|
||||
.catch((err) => {
|
||||
console.error(err);
|
||||
});
|
||||
}
|
||||
return [
|
||||
...prev.filter((item) => item.id !== progress.id),
|
||||
{
|
||||
id: progress.id,
|
||||
progress: progress.progress,
|
||||
filename: oldItem?.filename,
|
||||
buffer: 0,
|
||||
intervalId,
|
||||
},
|
||||
];
|
||||
});
|
||||
}
|
||||
},
|
||||
[queryClient],
|
||||
);
|
||||
|
||||
const manager = getKPIValue(pitchBook, 'FONDSMANAGER') ||
|
||||
getKPIValue(pitchBook, 'MANAGER') ||
|
||||
getKPIValue(pitchBook, 'PORTFOLIO_MANAGER');
|
||||
useEffect(() => {
|
||||
socket.on("connect", onConnection);
|
||||
socket.on("progress", onProgress);
|
||||
return () => {
|
||||
socket.off("connect", onConnection);
|
||||
socket.off("progress", onProgress);
|
||||
};
|
||||
}, [onConnection, onProgress]);
|
||||
|
||||
return (
|
||||
<TableRow
|
||||
key={pitchBook.id}
|
||||
onClick={() => handleRowClick(pitchBook.id)}
|
||||
sx={{
|
||||
cursor: "pointer",
|
||||
"&:hover": {
|
||||
backgroundColor: "#f9f9f9",
|
||||
},
|
||||
}}
|
||||
>
|
||||
<TableCell>
|
||||
<Box
|
||||
sx={{
|
||||
width: 40,
|
||||
height: 50,
|
||||
backgroundColor: "#f0f0f0",
|
||||
borderRadius: 1,
|
||||
display: "flex",
|
||||
alignItems: "center",
|
||||
justifyContent: "center",
|
||||
border: "1px solid #e0e0e0",
|
||||
}}
|
||||
>
|
||||
<PictureAsPdfIcon fontSize="small" sx={{ color: "#666" }} />
|
||||
</Box>
|
||||
</TableCell>
|
||||
<TableCell>
|
||||
<Typography variant="body2" fontWeight="medium">
|
||||
{fundName}
|
||||
</Typography>
|
||||
</TableCell>
|
||||
<TableCell>{manager}</TableCell>
|
||||
<TableCell>
|
||||
<Typography variant="body2" color="text.secondary" fontSize="0.875rem">
|
||||
{pitchBook.filename}
|
||||
</Typography>
|
||||
</TableCell>
|
||||
<TableCell>
|
||||
{status === 'completed' ? (
|
||||
<Chip
|
||||
icon={<CheckCircleIcon />}
|
||||
label="Abgeschlossen"
|
||||
size="small"
|
||||
sx={{
|
||||
backgroundColor: "#e8f5e9",
|
||||
color: "#2e7d32",
|
||||
"& .MuiChip-icon": {
|
||||
color: "#2e7d32",
|
||||
},
|
||||
}}
|
||||
/>
|
||||
) : (
|
||||
<Chip
|
||||
icon={<HourglassEmptyIcon />}
|
||||
label="In Bearbeitung"
|
||||
size="small"
|
||||
sx={{
|
||||
backgroundColor: "#fff3e0",
|
||||
color: "#e65100",
|
||||
"& .MuiChip-icon": {
|
||||
color: "#e65100",
|
||||
},
|
||||
}}
|
||||
/>
|
||||
)}
|
||||
</TableCell>
|
||||
</TableRow>
|
||||
);
|
||||
})}
|
||||
</TableBody>
|
||||
</Table>
|
||||
{pitchBooks.length === 0 && (
|
||||
<Box p={4} textAlign="center">
|
||||
<Typography color="text.secondary">
|
||||
Keine Pitch Books vorhanden
|
||||
</Typography>
|
||||
</Box>
|
||||
)}
|
||||
</TableContainer>
|
||||
);
|
||||
}
|
||||
const getKPIValue = (pitchBook: PitchBook, fieldName: string): string => {
|
||||
if (!pitchBook.kpi || typeof pitchBook.kpi === "string") {
|
||||
try {
|
||||
const parsedKPI = JSON.parse(pitchBook.kpi as string);
|
||||
// Convert array to object format if needed
|
||||
const kpiObj = Array.isArray(parsedKPI)
|
||||
? parsedKPI.reduce((acc, item) => {
|
||||
if (!acc[item.label]) acc[item.label] = [];
|
||||
acc[item.label].push(item);
|
||||
return acc;
|
||||
}, {})
|
||||
: parsedKPI;
|
||||
|
||||
return kpiObj[fieldName]?.[0]?.entity || "N/A";
|
||||
} catch {
|
||||
return "N/A";
|
||||
}
|
||||
}
|
||||
|
||||
return pitchBook.kpi[fieldName]?.[0]?.entity || "N/A";
|
||||
};
|
||||
|
||||
const getStatus = (pitchBook: PitchBook) => {
|
||||
if (
|
||||
pitchBook.kpi &&
|
||||
((typeof pitchBook.kpi === "string" && pitchBook.kpi !== "{}") ||
|
||||
(typeof pitchBook.kpi === "object" &&
|
||||
Object.keys(pitchBook.kpi).length > 0))
|
||||
) {
|
||||
return "completed";
|
||||
}
|
||||
return "processing";
|
||||
};
|
||||
|
||||
if (isLoading) {
|
||||
return (
|
||||
<Box
|
||||
display="flex"
|
||||
justifyContent="center"
|
||||
alignItems="center"
|
||||
height="400px"
|
||||
>
|
||||
<CircularProgress sx={{ color: "#383838" }} />
|
||||
</Box>
|
||||
);
|
||||
}
|
||||
|
||||
return (
|
||||
<TableContainer
|
||||
component={Paper}
|
||||
sx={{
|
||||
width: "85%",
|
||||
maxWidth: 1200,
|
||||
boxShadow: "0 2px 8px rgba(0,0,0,0.1)",
|
||||
}}
|
||||
>
|
||||
<Table>
|
||||
<TableHead>
|
||||
<TableRow sx={{ backgroundColor: "#f5f5f5" }}>
|
||||
<TableCell sx={{ width: "60px" }} />
|
||||
<TableCell sx={{ fontWeight: "bold" }}>Fondsname</TableCell>
|
||||
<TableCell sx={{ fontWeight: "bold" }}>Fondsmanager</TableCell>
|
||||
<TableCell sx={{ fontWeight: "bold" }}>Dateiname</TableCell>
|
||||
<TableCell sx={{ fontWeight: "bold", width: "120px" }}>
|
||||
Status
|
||||
</TableCell>
|
||||
</TableRow>
|
||||
</TableHead>
|
||||
<TableBody>
|
||||
{pitchBooks
|
||||
.filter(
|
||||
(pitchbook: PitchBook) =>
|
||||
!loadingPitchBooks.some((e) => e.id === pitchbook.id),
|
||||
)
|
||||
.sort(
|
||||
(a: PitchBook, b: PitchBook) =>
|
||||
new Date(a.created_at).getTime() -
|
||||
new Date(b.created_at).getTime(),
|
||||
)
|
||||
.map((pitchBook: PitchBook) => {
|
||||
const status = getStatus(pitchBook);
|
||||
const fundName =
|
||||
getKPIValue(pitchBook, "FONDSNAME") ||
|
||||
getKPIValue(pitchBook, "FUND_NAME") ||
|
||||
getKPIValue(pitchBook, "NAME");
|
||||
|
||||
const manager =
|
||||
getKPIValue(pitchBook, "FONDSMANAGER") ||
|
||||
getKPIValue(pitchBook, "MANAGER") ||
|
||||
getKPIValue(pitchBook, "PORTFOLIO_MANAGER");
|
||||
|
||||
return (
|
||||
<TableRow
|
||||
key={pitchBook.id}
|
||||
onClick={() => handleRowClick(pitchBook.id)}
|
||||
sx={{
|
||||
cursor: "pointer",
|
||||
"&:hover": {
|
||||
backgroundColor: "#f9f9f9",
|
||||
},
|
||||
}}
|
||||
>
|
||||
<TableCell>
|
||||
<Box
|
||||
sx={{
|
||||
width: 40,
|
||||
height: 50,
|
||||
backgroundColor: "#f0f0f0",
|
||||
borderRadius: 1,
|
||||
display: "flex",
|
||||
alignItems: "center",
|
||||
justifyContent: "center",
|
||||
border: "1px solid #e0e0e0",
|
||||
}}
|
||||
>
|
||||
<PictureAsPdfIcon
|
||||
fontSize="small"
|
||||
sx={{ color: "#666" }}
|
||||
/>
|
||||
</Box>
|
||||
</TableCell>
|
||||
<TableCell>
|
||||
<Typography variant="body2" fontWeight="medium">
|
||||
{fundName}
|
||||
</Typography>
|
||||
</TableCell>
|
||||
<TableCell>{manager}</TableCell>
|
||||
<TableCell>
|
||||
<Typography
|
||||
variant="body2"
|
||||
color="text.secondary"
|
||||
fontSize="0.875rem"
|
||||
>
|
||||
{pitchBook.filename}
|
||||
</Typography>
|
||||
</TableCell>
|
||||
<TableCell>
|
||||
{status === "completed" ? (
|
||||
<Chip
|
||||
icon={<CheckCircleIcon />}
|
||||
label="Abgeschlossen"
|
||||
size="small"
|
||||
sx={{
|
||||
backgroundColor: "#e8f5e9",
|
||||
color: "#2e7d32",
|
||||
"& .MuiChip-icon": {
|
||||
color: "#2e7d32",
|
||||
},
|
||||
}}
|
||||
/>
|
||||
) : (
|
||||
<Chip
|
||||
icon={<HourglassEmptyIcon />}
|
||||
label="In Bearbeitung"
|
||||
size="small"
|
||||
sx={{
|
||||
backgroundColor: "#fff3e0",
|
||||
color: "#e65100",
|
||||
"& .MuiChip-icon": {
|
||||
color: "#e65100",
|
||||
},
|
||||
}}
|
||||
/>
|
||||
)}
|
||||
</TableCell>
|
||||
</TableRow>
|
||||
);
|
||||
})}
|
||||
{loadingPitchBooks
|
||||
.sort((a, b) => a.id - b.id)
|
||||
.map((pitchBook) => (
|
||||
<TableRow key={pitchBook.id}>
|
||||
<TableCell>
|
||||
<Box
|
||||
sx={{
|
||||
width: 40,
|
||||
height: 50,
|
||||
backgroundColor: "#f0f0f0",
|
||||
borderRadius: 1,
|
||||
display: "flex",
|
||||
alignItems: "center",
|
||||
justifyContent: "center",
|
||||
border: "1px solid #e0e0e0",
|
||||
}}
|
||||
>
|
||||
<PictureAsPdfIcon fontSize="small" sx={{ color: "#666" }} />
|
||||
</Box>
|
||||
</TableCell>
|
||||
<TableCell colSpan={2}>
|
||||
<LinearProgress
|
||||
variant="buffer"
|
||||
value={pitchBook.progress}
|
||||
valueBuffer={
|
||||
pitchBook.buffer
|
||||
? pitchBook.progress + pitchBook.buffer
|
||||
: pitchBook.progress
|
||||
}
|
||||
/>
|
||||
</TableCell>
|
||||
<TableCell>
|
||||
{" "}
|
||||
<Typography
|
||||
variant="body2"
|
||||
color="text.secondary"
|
||||
fontSize="0.875rem"
|
||||
>
|
||||
{pitchBook.filename}
|
||||
</Typography>
|
||||
</TableCell>
|
||||
<TableCell>
|
||||
<Chip
|
||||
icon={<HourglassEmptyIcon />}
|
||||
label="In Bearbeitung"
|
||||
size="small"
|
||||
sx={{
|
||||
backgroundColor: "#fff3e0",
|
||||
color: "#e65100",
|
||||
"& .MuiChip-icon": {
|
||||
color: "#e65100",
|
||||
},
|
||||
}}
|
||||
/>
|
||||
</TableCell>
|
||||
</TableRow>
|
||||
))}
|
||||
</TableBody>
|
||||
</Table>
|
||||
{pitchBooks.length === 0 && (
|
||||
<Box p={4} textAlign="center">
|
||||
<Typography color="text.secondary">
|
||||
Keine Pitch Books vorhanden
|
||||
</Typography>
|
||||
</Box>
|
||||
)}
|
||||
</TableContainer>
|
||||
);
|
||||
}
|
||||
|
|
|
|||
|
|
@ -1,11 +1,11 @@
|
|||
import SettingsIcon from "@mui/icons-material/Settings";
|
||||
import { Backdrop, Box, Button, IconButton, Paper } from "@mui/material";
|
||||
import { useNavigate } from "@tanstack/react-router";
|
||||
import { useNavigate, useRouter } from "@tanstack/react-router";
|
||||
import { useCallback, useEffect, useState } from "react";
|
||||
import FileUpload from "react-material-file-upload";
|
||||
import { socket } from "../socket";
|
||||
import { CircularProgressWithLabel } from "./CircularProgressWithLabel";
|
||||
import { API_HOST } from "../util/api";
|
||||
import { CircularProgressWithLabel } from "./CircularProgressWithLabel";
|
||||
|
||||
export default function UploadPage() {
|
||||
const [files, setFiles] = useState<File[]>([]);
|
||||
|
|
@ -13,6 +13,7 @@ export default function UploadPage() {
|
|||
const [loadingState, setLoadingState] = useState<number | null>(null);
|
||||
const fileTypes = ["pdf"];
|
||||
const navigate = useNavigate();
|
||||
const router = useRouter();
|
||||
|
||||
const uploadFile = useCallback(async () => {
|
||||
const formData = new FormData();
|
||||
|
|
@ -178,6 +179,7 @@ export default function UploadPage() {
|
|||
backgroundColor: "#383838",
|
||||
"&:hover": { backgroundColor: "#2e2e2e" },
|
||||
}}
|
||||
onMouseEnter={() => router.preloadRoute({ to: "/pitchbooks" })}
|
||||
onClick={() => navigate({ to: "/pitchbooks" })}
|
||||
>
|
||||
Alle Pitch Books anzeigen
|
||||
|
|
|
|||
|
|
@ -1,6 +1,6 @@
|
|||
import type { Kennzahl } from "@/types/kpi";
|
||||
|
||||
const API_HOST = import.meta.env.VITE_API_HOST || 'http://localhost:5050';
|
||||
const API_HOST = import.meta.env.VITE_API_HOST || "http://localhost:5050";
|
||||
|
||||
export { API_HOST };
|
||||
|
||||
|
|
@ -15,9 +15,7 @@ export const fetchKPI = async (
|
|||
source: string;
|
||||
}[];
|
||||
}> => {
|
||||
const response = await fetch(
|
||||
`${API_HOST}/api/pitch_book/${pitchBookId}`,
|
||||
);
|
||||
const response = await fetch(`${API_HOST}/api/pitch_book/${pitchBookId}`);
|
||||
const data = await response.json();
|
||||
|
||||
return data.kpi ? getKPI(data.kpi) : {};
|
||||
|
|
@ -46,13 +44,10 @@ export const fetchPutKPI = async (
|
|||
const formData = new FormData();
|
||||
formData.append("kpi", JSON.stringify(flattenKPIArray(kpi)));
|
||||
|
||||
const response = await fetch(
|
||||
`${API_HOST}/api/pitch_book/${pitchBookId}`,
|
||||
{
|
||||
method: "PUT",
|
||||
body: formData,
|
||||
},
|
||||
);
|
||||
const response = await fetch(`${API_HOST}/api/pitch_book/${pitchBookId}`, {
|
||||
method: "PUT",
|
||||
body: formData,
|
||||
});
|
||||
if (!response.ok) {
|
||||
throw new Error(`HTTP error! status: ${response.status}`);
|
||||
}
|
||||
|
|
@ -119,3 +114,11 @@ export async function fetchPitchBooks() {
|
|||
}
|
||||
return response.json();
|
||||
}
|
||||
|
||||
export async function fetchPitchBooksById(id: number) {
|
||||
const response = await fetch(`${API_HOST}/api/pitch_book/${id}`);
|
||||
if (!response.ok) {
|
||||
throw new Error("Failed to fetch pitch books");
|
||||
}
|
||||
return response.json();
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue