feat(sync): add customer synchronization from lic server

shop/lib/actions/companies.ts

@@ -262,3 +262,78 @@ export async function syncCompaniesFromLicServer() {
   return { success: true, count: partners.length }
 }
 
+export async function syncCustomersFromLicServer() {
+  const admin = createAdminClient()
+  const cfg = await getLicServerConfigSystem()
+
+  if (!cfg.base_url || !cfg.api_key) {
+    throw new Error('LicServer ist nicht konfiguriert.')
+  }
+
+  // 1. Get all local companies
+  const { data: companies, error: compErr } = await admin
+    .from('companies')
+    .select('id')
+
+  if (compErr) throw compErr
+  if (!companies || companies.length === 0) {
+    return { success: true, count: 0 }
+  }
+
+  let totalSynced = 0
+  const allUpsertRows: any[] = []
+
+  // 2. Fetch customers for each company
+  for (const company of companies) {
+    try {
+      const res = await fetch(`${cfg.base_url}/api-v1/partners/${company.id}/customers?pageSize=1000`, {
+        headers: { 'X-Api-Key': cfg.api_key, 'Accept': 'application/json' },
+        signal: AbortSignal.timeout(10_000),
+      })
+
+      if (res.ok) {
+        const result = await res.json()
+        const customers = result.items || []
+
+        for (const c of customers) {
+          const streetCombined = [c.street, c.houseNumber, c.houseNumberAddon]
+            .filter(Boolean)
+            .map(s => s.trim())
+            .join(' ')
+
+          allUpsertRows.push({
+            id: c.id,
+            partner_id: company.id,
+            company_name: c.name || 'Unbenannt',
+            street: streetCombined || null,
+            zip: c.zipCode || null,
+            city: c.city || null,
+            email: c.email || null,
+            is_anonymized: false,
+          })
+        }
+      } else {
+        console.warn(`[sync-customers] Skipping partner ${company.id} due to API status: ${res.status}`)
+      }
+    } catch (e: any) {
+      console.error(`[sync-customers] Error fetching customers for partner ${company.id}:`, e.message || e)
+    }
+  }
+
+  if (allUpsertRows.length > 0) {
+    const { error: upsertErr } = await admin
+      .from('end_customers')
+      .upsert(allUpsertRows, { onConflict: 'id' })
+
+    if (upsertErr) throw upsertErr
+    totalSynced = allUpsertRows.length
+  }
+
+  revalidatePath('/my-customers')
+  revalidatePath('/order')
+  revalidatePath('/admin/companies')
+
+  return { success: true, count: totalSynced }
+}
+
+