add linking between internal and external orders

backend/src/services/ausruestungsanfrage.service.ts

@@ -716,6 +716,73 @@ async function getLinkedOrders(anfrageId: number) {
   return result.rows;
 }
 
+async function createOrdersFromRequest(
+  anfrageId: number,
+  orders: Array<{
+    lieferant_id: number;
+    bezeichnung: string;
+    positionen: Array<{ position_id: number; bezeichnung: string; menge: number; einheit?: string; notizen?: string }>;
+  }>,
+  userId: string,
+) {
+  const client = await pool.connect();
+  try {
+    await client.query('BEGIN');
+
+    const createdBestellungen: Array<{ id: number; bezeichnung: string; lieferant_name: string }> = [];
+
+    for (const orderData of orders) {
+      const nrResult = await client.query(
+        `SELECT COALESCE(MAX(laufende_nummer), 0) + 1 AS next_nr
+         FROM bestellungen
+         WHERE EXTRACT(YEAR FROM erstellt_am) = EXTRACT(YEAR FROM NOW())`
+      );
+      const laufendeNummer = nrResult.rows[0].next_nr;
+
+      const bestellungResult = await client.query(
+        `INSERT INTO bestellungen (bezeichnung, lieferant_id, status, laufende_nummer, erstellt_von)
+         VALUES ($1, $2, 'wartet_auf_genehmigung', $3, $4)
+         RETURNING id, bezeichnung`,
+        [orderData.bezeichnung, orderData.lieferant_id, laufendeNummer, userId]
+      );
+      const bestellung = bestellungResult.rows[0];
+
+      for (const pos of orderData.positionen) {
+        await client.query(
+          `INSERT INTO bestellpositionen (bestellung_id, bezeichnung, menge, einheit, notizen)
+           VALUES ($1, $2, $3, $4, $5)`,
+          [bestellung.id, pos.bezeichnung, pos.menge, pos.einheit || 'Stk', pos.notizen || null]
+        );
+      }
+
+      await client.query(
+        `INSERT INTO ausruestung_anfrage_bestellung (anfrage_id, bestellung_id)
+         VALUES ($1, $2) ON CONFLICT DO NOTHING`,
+        [anfrageId, bestellung.id]
+      );
+
+      const vendorResult = await client.query('SELECT name FROM lieferanten WHERE id = $1', [orderData.lieferant_id]);
+      const lieferantName = vendorResult.rows[0]?.name ?? '';
+
+      createdBestellungen.push({ id: bestellung.id, bezeichnung: bestellung.bezeichnung, lieferant_name: lieferantName });
+    }
+
+    await client.query(
+      `UPDATE ausruestung_anfragen SET status = 'bestellt', aktualisiert_am = NOW() WHERE id = $1`,
+      [anfrageId]
+    );
+
+    await client.query('COMMIT');
+    return createdBestellungen;
+  } catch (error) {
+    await client.query('ROLLBACK');
+    logger.error('AusruestungsanfrageService.createOrdersFromRequest failed', { error });
+    throw new Error('Bestellungen konnten nicht erstellt werden');
+  } finally {
+    client.release();
+  }
+}
+
 // ---------------------------------------------------------------------------
 // Overview (aggregated)
 // ---------------------------------------------------------------------------
@@ -795,6 +862,7 @@ export default {
   linkToOrder,
   unlinkFromOrder,
   getLinkedOrders,
+  createOrdersFromRequest,
   getOverview,
   getWidgetOverview,
 };