Bulk actions for Purchase Orders

app/Http/Controllers/PurchaseOrderController.php

@@ -23,8 +23,9 @@ use App\Http\Requests\PurchaseOrder\EditPurchaseOrderRequest;
 use App\Http\Requests\PurchaseOrder\ShowPurchaseOrderRequest;
 use App\Http\Requests\PurchaseOrder\StorePurchaseOrderRequest;
 use App\Http\Requests\PurchaseOrder\UpdatePurchaseOrderRequest;
-use App\Jobs\Invoice\PurchaseOrderEmail;
 use App\Jobs\Invoice\ZipInvoices;
+use App\Jobs\PurchaseOrder\PurchaseOrderEmail;
+use App\Jobs\PurchaseOrder\ZipPurchaseOrders;
 use App\Models\Client;
 use App\Models\PurchaseOrder;
 use App\Repositories\PurchaseOrderRepository;
@@ -495,7 +496,7 @@ class PurchaseOrderController extends BaseController
                 }
             });
 
-            ZipInvoices::dispatch($purchase_orders, $purchase_orders->first()->company, auth()->user());
+            ZipPurchaseOrders::dispatch($purchase_orders, $purchase_orders->first()->company, auth()->user());
 
             return response()->json(['message' => ctrans('texts.sent_message')], 200);
         }
@@ -631,6 +632,11 @@ class PurchaseOrderController extends BaseController
                 //check query parameter for email_type and set the template else use calculateTemplate
                 PurchaseOrderEmail::dispatch($purchase_order, $purchase_order->company);
 
+
+                if (! $bulk) {
+                    return response()->json(['message' => 'email sent'], 200);
+                }
+
             default:
                 return response()->json(['message' => ctrans('texts.action_unavailable', ['action' => $action])], 400);
                 break;

app/Http/Requests/PurchaseOrder/StorePurchaseOrderRequest.php

@@ -38,7 +38,7 @@ class StorePurchaseOrderRequest extends Request
     {
         $rules = [];
 
-        $rules['vendor_id'] = 'required';
+        $rules['vendor_id'] = 'bail|required|exists:vendors,id,company_id,'.auth()->user()->company()->id.',is_deleted,0';
 
         $rules['number'] = ['nullable', Rule::unique('purchase_orders')->where('company_id', auth()->user()->company()->id)];
         $rules['discount']  = 'sometimes|numeric';

app/Jobs/PurchaseOrder/ZipPurchaseOrders.php

@@ -0,0 +1,125 @@
+<?php
+/**
+ * Invoice Ninja (https://invoiceninja.com).
+ *
+ * @link https://github.com/invoiceninja/invoiceninja source repository
+ *
+ * @copyright Copyright (c) 2022. Invoice Ninja LLC (https://invoiceninja.com)
+ *
+ * @license https://www.elastic.co/licensing/elastic-license
+ */
+
+namespace App\Jobs\PurchaseOrder;
+
+use App\Jobs\Entity\CreateEntityPdf;
+use App\Jobs\Mail\NinjaMailerJob;
+use App\Jobs\Mail\NinjaMailerObject;
+use App\Jobs\Util\UnlinkFile;
+use App\Jobs\Vendor\CreatePurchaseOrderPdf;
+use App\Libraries\MultiDB;
+use App\Mail\DownloadInvoices;
+use App\Models\Company;
+use App\Models\User;
+use App\Utils\TempFile;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Support\Facades\Mail;
+use Illuminate\Support\Facades\Storage;
+use ZipArchive;
+
+class ZipPurchaseOrders implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    public $purchase_orders;
+
+    private $company;
+
+    private $user;
+
+    public $settings;
+
+    public $tries = 1;
+
+    /**
+     * @param $purchase_orders
+     * @param Company $company
+     * @param $email
+     * @deprecated confirm to be deleted
+     * Create a new job instance.
+     *
+     */
+    public function __construct($purchase_orders, Company $company, User $user)
+    {
+        $this->purchase_orders = $purchase_orders;
+
+        $this->company = $company;
+
+        $this->user = $user;
+
+        $this->settings = $company->settings;
+    }
+
+    /**
+     * Execute the job.
+     *
+     * @return void
+     * @throws \ZipStream\Exception\FileNotFoundException
+     * @throws \ZipStream\Exception\FileNotReadableException
+     * @throws \ZipStream\Exception\OverflowException
+     */
+    
+    public function handle()
+    {
+        MultiDB::setDb($this->company->db);
+
+        # create new zip object
+        $zipFile = new \PhpZip\ZipFile();
+        $file_name = date('Y-m-d').'_'.str_replace(' ', '_', trans('texts.invoices')).'.zip';
+        $invitation = $this->purchase_orders->first()->invitations->first();
+        $path = $this->purchase_orders->first()->vendor->purchase_order_filepath($invitation);
+
+        $this->purchase_orders->each(function ($purchase_order){
+
+            CreatePurchaseOrderPdf::dispatchNow($purchase_order->invitations()->first());
+
+        });
+
+        try{
+            
+            foreach ($this->purchase_orders as $purchase_order) {
+        
+                $file = $purchase_order->service()->getPurchaseOrderPdf();
+                $zip_file_name = basename($file);
+                $zipFile->addFromString($zip_file_name, Storage::get($file));
+
+            }
+
+            Storage::put($path.$file_name, $zipFile->outputAsString());
+
+            $nmo = new NinjaMailerObject;
+            $nmo->mailable = new DownloadInvoices(Storage::url($path.$file_name), $this->company);
+            $nmo->to_user = $this->user;
+            $nmo->settings = $this->settings;
+            $nmo->company = $this->company;
+            
+            NinjaMailerJob::dispatch($nmo);
+            
+            UnlinkFile::dispatch(config('filesystems.default'), $path.$file_name)->delay(now()->addHours(1));
+            
+
+        }
+        catch(\PhpZip\Exception\ZipException $e){
+            nlog("could not make zip => ". $e->getMessage());
+        }
+        finally{
+            $zipFile->close();
+        }
+
+
+    }
+
+}

app/Models/PurchaseOrderInvitation.php

@@ -1,4 +1,13 @@
 <?php
+/**
+ * Invoice Ninja (https://invoiceninja.com).
+ *
+ * @link https://github.com/invoiceninja/invoiceninja source repository
+ *
+ * @copyright Copyright (c) 2022. Invoice Ninja LLC (https://invoiceninja.com)
+ *
+ * @license https://www.elastic.co/licensing/elastic-license
+ */
 
 
 namespace App\Models;
@@ -9,6 +18,7 @@ use App\Utils\Traits\Inviteable;
 use App\Utils\Traits\MakesDates;
 use Carbon\Carbon;
 use Illuminate\Database\Eloquent\SoftDeletes;
+use Illuminate\Support\Str;
 
 class PurchaseOrderInvitation extends BaseModel
 {
@@ -104,4 +114,37 @@ class PurchaseOrderInvitation extends BaseModel
 
     }
 
+    public function getLink() :string
+    {
+        $entity_type = Str::snake(class_basename($this->entityType()));
+
+        if(Ninja::isHosted()){
+            $domain = $this->company->domain();
+        }
+        else
+            $domain = config('ninja.app_url');
+
+        switch ($this->company->portal_mode) {
+            case 'subdomain':
+                return $domain.'/vendor/'.$entity_type.'/'.$this->key;
+                break;
+            case 'iframe':
+                return $domain.'/vendor/'.$entity_type.'/'.$this->key;
+                break;
+            case 'domain':
+                return $domain.'/vendor/'.$entity_type.'/'.$this->key;
+                break;
+
+            default:
+                return '';
+                break;
+        }
+    }
+
+    public function getAdminLink() :string
+    {
+        return $this->getLink().'?silent=true';
+    }
+
+
 }

tests/Feature/CompanyTest.php

@@ -50,8 +50,8 @@ class CompanyTest extends TestCase
     {
         $this->withoutMiddleware(PasswordProtection::class);
 
-        $cc = Company::first();
-        $cc->delete();
+        // $cc = Company::first();
+        // $cc->delete();
 
         $response = $this->withHeaders([
                 'X-API-SECRET' => config('ninja.api_secret'),