From 9363a3f7b60b2c99e500a74438f21e11b889e955 Mon Sep 17 00:00:00 2001
From: David Bomba <turbo124@gmail.com>
Date: Sun, 25 Jun 2023 19:04:06 +1000
Subject: [PATCH] Fixes for imports

---
 app/Jobs/Util/Import.php | 70 ++++++++++++++++++++++++++++++++++++++++
 1 file changed, 70 insertions(+)

diff --git a/app/Jobs/Util/Import.php b/app/Jobs/Util/Import.php
index bae27f44c5c0..ceedd63d0c3e 100644
--- a/app/Jobs/Util/Import.php
+++ b/app/Jobs/Util/Import.php
@@ -135,6 +135,7 @@ class Import implements ShouldQueue
         'recurring_expenses',
         'tasks',
         'documents',
+        'activities',
     ];
 
     /**
@@ -1776,6 +1777,75 @@ class Import implements ShouldQueue
         $data = null;
     }
 
+    private function processActivities(array $data): void
+    {
+        Activity::where('company_id', $this->company->id)->cursor()->each(function ($a){
+            $a->forceDelete();
+        });
+
+        Activity::unguard();
+
+        foreach ($data as $resource) {
+            $modified = $resource;
+
+            $modified['company_id'] = $this->company->id;
+            $modified['user_id'] = $this->processUserId($resource);
+
+try {
+    if (isset($modified['client_id'])) {
+        $modified['client_id'] = $this->transformId('clients', $resource['client_id']);
+    }
+
+    if (isset($modified['invoice_id'])) {
+        $modified['invoice_id'] = $this->transformId('invoices', $resource['invoice_id']);
+    }
+
+    if (isset($modified['quote_id'])) {
+        $modified['quote_id'] = $this->transformId('quotes', $resource['quote_id']);
+    }
+
+    if (isset($modified['recurring_invoice_id'])) {
+        $modified['recurring_invoice_id'] = $this->transformId('recurring_invoices', $resource['recurring_invoice_id']);
+    }
+
+    if (isset($modified['payment_id'])) {
+        $modified['payment_id'] = $this->transformId('payments', $resource['payment_id']);
+    }
+
+    if (isset($modified['credit_id'])) {
+        $modified['credit_id'] = $this->transformId('credits', $resource['credit_id']);
+    }
+
+    if (isset($modified['expense_id'])) {
+        $modified['expense_id'] = $this->transformId('expenses', $resource['expense_id']);
+    }
+
+    if (isset($modified['task_id'])) {
+        $modified['task_id'] = $this->transformId('tasks', $resource['task_id']);
+    }
+
+    if (isset($modified['client_contact_id'])) {
+        $modified['client_contact_id'] = $this->transformId('client_contacts', $resource['client_contact_id']);
+    }
+
+    $act = Activity::make($modified);
+
+    $act->save(['timestamps' => false]);
+}
+catch (\Exception $e) {
+
+nlog("could not import activity: {$e->getMessage()}");
+
+}
+
+        }
+
+    
+        Activity::reguard();
+
+    }
+
+
     private function processExpenses(array $data) :void
     {
         Expense::unguard();