invoiceninja/app/ninja/repositories/ClientRepository.php

<?php namespace ninja\repositories;

use Client;
use Contact;

class ClientRepository
{
	public function find($filter = null)
	{
    	$query = \DB::table('clients')
    				->join('contacts', 'contacts.client_id', '=', 'clients.id')
    				->where('clients.account_id', '=', \Auth::user()->account_id)
    				->where('contacts.is_primary', '=', true)
    				->select('clients.public_id','clients.name','contacts.first_name','contacts.last_name','clients.balance','clients.last_login','clients.created_at','clients.work_phone','contacts.email','clients.currency_id');

    	if (!\Session::get('show_trash:client'))
    	{
    		$query->where('clients.deleted_at', '=', null);
    	}

    	if ($filter)
    	{
    		$query->where(function($query) use ($filter)
            {
            	$query->where('clients.name', 'like', '%'.$filter.'%')
            		  ->orWhere('contacts.first_name', 'like', '%'.$filter.'%')
            		  ->orWhere('contacts.last_name', 'like', '%'.$filter.'%')
            		  ->orWhere('contacts.email', 'like', '%'.$filter.'%');
            });
    	}

    	return $query;
	}

	public function getErrors($data)
	{
		$contact = isset($data['contacts']) ? (array)$data['contacts'][0] : (isset($data['contact']) ? $data['contact'] : []);
		$validator = \Validator::make($contact, ['email' => 'required|email']);
		if ($validator->fails()) {
			return $validator->messages();
		}
		
		return false;		
	}

	public function save($publicId, $data, $notify = true)
	{
		if (!$publicId || $publicId == "-1") 
		{
			$client = Client::createNew();
			$client->currency_id = 1;
			$contact = Contact::createNew();
			$contact->is_primary = true;			
			$contact->send_invoice = true;
		}
		else
		{
			$client = Client::scope($publicId)->with('contacts')->firstOrFail();
			$contact = $client->contacts()->where('is_primary', '=', true)->firstOrFail();
		}
		
		if (isset($data['name'])) {
			$client->name = trim($data['name']);
		}
		if (isset($data['work_phone'])) {
			$client->work_phone = trim($data['work_phone']);
		}
		if (isset($data['custom_value1'])) {			
			$client->custom_value1 = trim($data['custom_value1']);
		}
		if (isset($data['custom_value2'])) {
			$client->custom_value2 = trim($data['custom_value2']);
		}
		if (isset($data['address1'])) {
			$client->address1 = trim($data['address1']);
		}
		if (isset($data['address2'])) {
			$client->address2 = trim($data['address2']);
		}
		if (isset($data['city'])) {
			$client->city = trim($data['city']);
		}
		if (isset($data['state'])) {
			$client->state = trim($data['state']);
		}
		if (isset($data['postal_code'])) {
			$client->postal_code = trim($data['postal_code']);
		}
		if (isset($data['country_id'])) {
			$client->country_id = $data['country_id'] ? $data['country_id'] : null;
		}
		if (isset($data['private_notes'])) {
			$client->private_notes = trim($data['private_notes']);
		}
		if (isset($data['size_id'])) {
			$client->size_id = $data['size_id'] ? $data['size_id'] : null;
		}
		if (isset($data['industry_id'])) {
			$client->industry_id = $data['industry_id'] ? $data['industry_id'] : null;
		}
		if (isset($data['currency_id'])) {
			$client->currency_id = $data['currency_id'] ? $data['currency_id'] : 1;
		}
		if (isset($data['payment_terms'])) {
			$client->payment_terms = $data['payment_terms'];
		}
		if (isset($data['website'])) {
			$client->website = trim($data['website']);
		}

		$client->save();
		
		$isPrimary = true;
		$contactIds = [];

		if (isset($data['contact']))
		{
			$info = $data['contact'];
			if (isset($info['email'])) {
				$contact->email = trim(strtolower($info['email']));
			}
			if (isset($info['first_name'])) {
				$contact->first_name = trim($info['first_name']);
			}
			if (isset($info['last_name'])) {				
				$contact->last_name = trim($info['last_name']);
			}
			if (isset($info['phone'])) {
				$contact->phone = trim($info['phone']);
			}
			$contact->is_primary = true;
			$contact->send_invoice = true;
			$client->contacts()->save($contact);
		}
		else
		{
			foreach ($data['contacts'] as $record)
			{
				$record = (array) $record;

				if ($publicId != "-1" && isset($record['public_id']) && $record['public_id'])
				{
					$contact = Contact::scope($record['public_id'])->firstOrFail();
				}
				else
				{
					$contact = Contact::createNew();
				}

				if (isset($record['email'])) {
					$contact->email = trim(strtolower($record['email']));
				}
				if (isset($record['first_name'])) {				
					$contact->first_name = trim($record['first_name']);
				}
				if (isset($record['last_name'])) {
					$contact->last_name = trim($record['last_name']);
				}
				if (isset($record['phone'])) {
					$contact->phone = trim($record['phone']);
				}
				$contact->is_primary = $isPrimary;
				$contact->send_invoice = isset($record['send_invoice']) ? $record['send_invoice'] : true;
				$isPrimary = false;

				$client->contacts()->save($contact);
				$contactIds[] = $contact->public_id;
			}
			
			foreach ($client->contacts as $contact)
			{
				if (!in_array($contact->public_id, $contactIds))
				{	
					$contact->delete();
				}
			}
		}

		$client->save();
		
		if (!$publicId || $publicId == "-1")
		{
			\Activity::createClient($client, $notify);
		}

		return $client;
	}

	public function bulk($ids, $action)
	{
		$clients = Client::scope($ids)->get();

		foreach ($clients as $client) 
		{			
			if ($action == 'delete') 
			{
				$client->is_deleted = true;
				$client->save();
			} 
			
			$client->delete();			
		}

		return count($clients);
	}	
}