feat: filter artennachweis, restriktionen, gebaeude, and wohngebaeude by project (either by project ID or within 5km of project parcels)

This commit is contained in:
Johannes Baumeister 2026-06-25 09:25:39 +02:00
parent 685bfb1f3b
commit ed821296f3
2 changed files with 111 additions and 22 deletions

8
app.js
View File

@ -1252,7 +1252,7 @@ document.addEventListener('DOMContentLoaded', async () => {
// Artennachweis laden // Artennachweis laden
console.log("Lade Artennachweis-Layer aus Datenbank..."); console.log("Lade Artennachweis-Layer aus Datenbank...");
const artenResp = await fetch('/api/layers/artennachweis').catch(err => { const artenResp = await fetch(`/api/layers/artennachweis?project=${encodeURIComponent(projId)}`).catch(err => {
console.error("Netzwerkfehler beim Laden des Artennachweis-Layers:", err); console.error("Netzwerkfehler beim Laden des Artennachweis-Layers:", err);
return null; return null;
}); });
@ -1293,7 +1293,7 @@ document.addEventListener('DOMContentLoaded', async () => {
// Artennachweis Restriktionsabstände laden // Artennachweis Restriktionsabstände laden
console.log("Lade Artennachweise-Restriktionen aus Datenbank..."); console.log("Lade Artennachweise-Restriktionen aus Datenbank...");
const restriktionResp = await fetch('/api/layers/artennachweise_restriktionen').catch(err => { const restriktionResp = await fetch(`/api/layers/artennachweise_restriktionen?project=${encodeURIComponent(projId)}`).catch(err => {
console.error("Netzwerkfehler beim Laden der Restriktionsabstände:", err); console.error("Netzwerkfehler beim Laden der Restriktionsabstände:", err);
return null; return null;
}); });
@ -1368,7 +1368,7 @@ document.addEventListener('DOMContentLoaded', async () => {
// Gebäude laden // Gebäude laden
console.log("Lade Gebäude aus Datenbank..."); console.log("Lade Gebäude aus Datenbank...");
const gebaudeResp = await fetch('/api/layers/gebaeude').catch(err => { const gebaudeResp = await fetch(`/api/layers/gebaeude?project=${encodeURIComponent(projId)}`).catch(err => {
console.error("Netzwerkfehler beim Laden der Gebäude:", err); console.error("Netzwerkfehler beim Laden der Gebäude:", err);
return null; return null;
}); });
@ -1401,7 +1401,7 @@ document.addEventListener('DOMContentLoaded', async () => {
// Wohngebäude laden // Wohngebäude laden
console.log("Lade Wohngebäude aus Datenbank..."); console.log("Lade Wohngebäude aus Datenbank...");
const wohngebaudeResp = await fetch('/api/layers/wohngebeaude').catch(err => { const wohngebaudeResp = await fetch(`/api/layers/wohngebeaude?project=${encodeURIComponent(projId)}`).catch(err => {
console.error("Netzwerkfehler beim Laden der Wohngebäude:", err); console.error("Netzwerkfehler beim Laden der Wohngebäude:", err);
return null; return null;
}); });

125
server.js
View File

@ -269,9 +269,25 @@ app.get('/api/layers/alkis', async (req, res) => {
// NEU: API zum Laden des Artennachweis-Layers als GeoJSON // NEU: API zum Laden des Artennachweis-Layers als GeoJSON
app.get('/api/layers/artennachweis', async (req, res) => { app.get('/api/layers/artennachweis', async (req, res) => {
log("Lade Artennachweis-Layer aus Datenbank..."); const projectParam = req.query.project || req.query.projekt_id || req.query.projekt;
log(`Lade Artennachweis-Layer aus Datenbank für Projekt: ${projectParam || 'alle'}`);
const client = await pool.connect();
try { try {
const result = await pool.query( let whereClause = '';
const params = [];
if (projectParam) {
const projId = await resolveProjectId(client, projectParam);
whereClause = `WHERE projekt_id = $1`;
params.push(projectParam); // e.g. 'test' or 'BWSamern-Ohne'
if (projId) {
whereClause += ` OR projekt_id = $2`;
params.push(projId);
}
}
const result = await client.query(
`SELECT jsonb_build_object( `SELECT jsonb_build_object(
'type', 'FeatureCollection', 'type', 'FeatureCollection',
'features', COALESCE(jsonb_agg(features.feature), '[]'::jsonb) 'features', COALESCE(jsonb_agg(features.feature), '[]'::jsonb)
@ -285,20 +301,43 @@ app.get('/api/layers/artennachweis', async (req, res) => {
) )
) AS feature ) AS feature
FROM geodaten.artennachweise FROM geodaten.artennachweise
) features` ${whereClause}
) features`,
params
); );
res.json(result.rows[0].jsonb_build_object); res.json(result.rows[0].jsonb_build_object);
} catch (err) { } catch (err) {
log(`FEHLER beim Laden des Artennachweis-Layers: ${err.message}`); log(`FEHLER beim Laden des Artennachweis-Layers: ${err.message}`);
res.status(500).json({ error: err.message }); res.status(500).json({ error: err.message });
} finally {
client.release();
} }
}); });
// NEU: API zum Laden der Artennachweis Restriktionsabstände // NEU: API zum Laden der Artennachweis Restriktionsabstände
app.get('/api/layers/artennachweise_restriktionen', async (req, res) => { app.get('/api/layers/artennachweise_restriktionen', async (req, res) => {
log("Lade Artennachweise-Restriktionen aus Datenbank..."); const projectParam = req.query.project || req.query.projekt_id || req.query.projekt;
log(`Lade Artennachweise-Restriktionen aus Datenbank für Projekt: ${projectParam || 'alle'}`);
const client = await pool.connect();
try { try {
const result = await pool.query( let whereClause = '';
const params = [];
if (projectParam) {
const projId = await resolveProjectId(client, projectParam);
if (projId) {
whereClause = `WHERE EXISTS (
SELECT 1
FROM geodaten.flaecheneigentuemer_alkis alkis
JOIN geodaten.flaecheneigentuemer_alkis_zuweisung z ON alkis."FSK" = z.fsk
WHERE z.projekt_id = $1
AND ST_DWithin(a.geom, alkis.geom, 5000)
)`;
params.push(projId);
}
}
const result = await client.query(
`SELECT jsonb_build_object( `SELECT jsonb_build_object(
'type', 'FeatureCollection', 'type', 'FeatureCollection',
'features', COALESCE(jsonb_agg(features.feature), '[]'::jsonb) 'features', COALESCE(jsonb_agg(features.feature), '[]'::jsonb)
@ -306,16 +345,20 @@ app.get('/api/layers/artennachweise_restriktionen', async (req, res) => {
FROM ( FROM (
SELECT jsonb_build_object( SELECT jsonb_build_object(
'type', 'Feature', 'type', 'Feature',
'geometry', ST_AsGeoJSON(ST_Transform(geom, 4326))::jsonb, 'geometry', ST_AsGeoJSON(ST_Transform(a.geom, 4326))::jsonb,
'properties', jsonb_build_object() 'properties', jsonb_build_object()
) AS feature ) AS feature
FROM geodaten.artennachweise_restriktion_abstand FROM geodaten.artennachweise_restriktion_abstand a
) features` ${whereClause}
) features`,
params
); );
res.json(result.rows[0].jsonb_build_object); res.json(result.rows[0].jsonb_build_object);
} catch (err) { } catch (err) {
log(`FEHLER beim Laden der Restriktionen: ${err.message}`); log(`FEHLER beim Laden der Restriktionen: ${err.message}`);
res.status(500).json({ error: err.message }); res.status(500).json({ error: err.message });
} finally {
client.release();
} }
}); });
@ -371,9 +414,28 @@ app.get('/api/layers/leitungsverlaeufe', async (req, res) => {
// NEU: API zum Laden der Gebäude // NEU: API zum Laden der Gebäude
app.get('/api/layers/gebaeude', async (req, res) => { app.get('/api/layers/gebaeude', async (req, res) => {
log("Lade Gebäude aus Datenbank..."); const projectParam = req.query.project || req.query.projekt_id || req.query.projekt;
log(`Lade Gebäude aus Datenbank für Projekt: ${projectParam || 'alle'}`);
const client = await pool.connect();
try { try {
const result = await pool.query( let whereClause = '';
const params = [];
if (projectParam) {
const projId = await resolveProjectId(client, projectParam);
if (projId) {
whereClause = `WHERE EXISTS (
SELECT 1
FROM geodaten.flaecheneigentuemer_alkis alkis
JOIN geodaten.flaecheneigentuemer_alkis_zuweisung z ON alkis."FSK" = z.fsk
WHERE z.projekt_id = $1
AND ST_DWithin(g.geom, alkis.geom, 5000)
)`;
params.push(projId);
}
}
const result = await client.query(
`SELECT jsonb_build_object( `SELECT jsonb_build_object(
'type', 'FeatureCollection', 'type', 'FeatureCollection',
'features', COALESCE(jsonb_agg(features.feature), '[]'::jsonb) 'features', COALESCE(jsonb_agg(features.feature), '[]'::jsonb)
@ -381,24 +443,47 @@ app.get('/api/layers/gebaeude', async (req, res) => {
FROM ( FROM (
SELECT jsonb_build_object( SELECT jsonb_build_object(
'type', 'Feature', 'type', 'Feature',
'geometry', ST_AsGeoJSON(ST_Transform(geom, 4326))::jsonb, 'geometry', ST_AsGeoJSON(ST_Transform(g.geom, 4326))::jsonb,
'properties', jsonb_build_object() 'properties', jsonb_build_object()
) AS feature ) AS feature
FROM geodaten.gebaeude FROM geodaten.gebaeude g
) features` ${whereClause}
) features`,
params
); );
res.json(result.rows[0].jsonb_build_object); res.json(result.rows[0].jsonb_build_object);
} catch (err) { } catch (err) {
log(`FEHLER beim Laden der Gebäude: ${err.message}`); log(`FEHLER beim Laden der Gebäude: ${err.message}`);
res.status(500).json({ error: err.message }); res.status(500).json({ error: err.message });
} finally {
client.release();
} }
}); });
// NEU: API zum Laden der Wohngebäude // NEU: API zum Laden der Wohngebäude
app.get('/api/layers/wohngebeaude', async (req, res) => { app.get('/api/layers/wohngebeaude', async (req, res) => {
log("Lade Wohngebäude aus Datenbank..."); const projectParam = req.query.project || req.query.projekt_id || req.query.projekt;
log(`Lade Wohngebäude aus Datenbank für Projekt: ${projectParam || 'alle'}`);
const client = await pool.connect();
try { try {
const result = await pool.query( let whereClause = '';
const params = [];
if (projectParam) {
const projId = await resolveProjectId(client, projectParam);
if (projId) {
whereClause = `WHERE EXISTS (
SELECT 1
FROM geodaten.flaecheneigentuemer_alkis alkis
JOIN geodaten.flaecheneigentuemer_alkis_zuweisung z ON alkis."FSK" = z.fsk
WHERE z.projekt_id = $1
AND ST_DWithin(w.geom, alkis.geom, 5000)
)`;
params.push(projId);
}
}
const result = await client.query(
`SELECT jsonb_build_object( `SELECT jsonb_build_object(
'type', 'FeatureCollection', 'type', 'FeatureCollection',
'features', COALESCE(jsonb_agg(features.feature), '[]'::jsonb) 'features', COALESCE(jsonb_agg(features.feature), '[]'::jsonb)
@ -406,16 +491,20 @@ app.get('/api/layers/wohngebeaude', async (req, res) => {
FROM ( FROM (
SELECT jsonb_build_object( SELECT jsonb_build_object(
'type', 'Feature', 'type', 'Feature',
'geometry', ST_AsGeoJSON(ST_Transform(geom, 4326))::jsonb, 'geometry', ST_AsGeoJSON(ST_Transform(w.geom, 4326))::jsonb,
'properties', jsonb_build_object() 'properties', jsonb_build_object()
) AS feature ) AS feature
FROM geodaten.wohngebeaude FROM geodaten.wohngebeaude w
) features` ${whereClause}
) features`,
params
); );
res.json(result.rows[0].jsonb_build_object); res.json(result.rows[0].jsonb_build_object);
} catch (err) { } catch (err) {
log(`FEHLER beim Laden der Wohngebäude: ${err.message}`); log(`FEHLER beim Laden der Wohngebäude: ${err.message}`);
res.status(500).json({ error: err.message }); res.status(500).json({ error: err.message });
} finally {
client.release();
} }
}); });