snipe-it/app/Console/Commands/ObjectImportCommand.php

<?php
namespace App\Console\Commands;

use Illuminate\Console\Command;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Input\InputArgument;
use League\Csv\Reader;
use App\Models\Accessory;
use App\Models\Asset;
use App\Models\AssetModel;
use App\Models\Category;
use App\Models\Company;
use App\Models\Consumable;
use App\Models\Location;
use App\Models\Manufacturer;
use App\Models\Statuslabel;
use App\Models\Supplier;
use App\Models\User;
use App\Models\CustomField;
use DB;
use App\Models\Setting;
use Illuminate\Database\Eloquent\Model;

ini_set('max_execution_time', 600); //600 seconds = 10 minutes
ini_set('memory_limit', '500M');

/**
 * Class ObjectImportCommand
 */
class ObjectImportCommand extends Command {

	/**
	 * The console command name.
	 *
	 * @var string
	 */
	protected $name = 'snipeit:import';

	/**
	 * The console command description.
	 *
	 * @var string
	 */
	protected $description = 'Import Items from CSV';

	/**
	 * Create a new command instance.
	 *
	 * @return void
	 */
	public function __construct()
	{
		parent::__construct();
	}

	/**
	 * Execute the console command.
	 *
	 * @return mixed
	 */
	public function fire()
	{
		$filename = $this->argument('filename');


		if(!$this->option('web-importer')) {
			$logFile = $this->option('logfile');
			\Log::useFiles($logFile);
			if ($this->option('testrun')) {
				$this->comment('====== TEST ONLY Asset Import for '.$filename.' ====');
				$this->comment('============== NO DATA WILL BE WRITTEN ==============');
			} else {

				$this->comment('======= Importing Assets from '.$filename.' =========');
			}
		}

		if (! ini_get("auto_detect_line_endings")) {
			ini_set("auto_detect_line_endings", '1');
		}

		$csv = Reader::createFromPath($this->argument('filename'));
		$csv->setNewline("\r\n");
		$results = $csv->fetchAssoc();
		$newarray = NULL;

		foreach ($results as $index => $arraytoNormalize)
		{
			$internalnewarray = array_change_key_case($arraytoNormalize);
			$newarray[$index] = $internalnewarray;
		}



		$this->locations = Location::All(['name', 'id']);
		$this->categories = Category::All(['name', 'category_type', 'id']);
		$this->manufacturers = Manufacturer::All(['name', 'id']);
		$this->asset_models = AssetModel::All(['name','modelno','category_id','manufacturer_id', 'id']);
		$this->companies = Company::All(['name', 'id']);
		$this->status_labels = Statuslabel::All(['name', 'id']);
		$this->suppliers = Supplier::All(['name', 'id']);
		$this->assets = Asset::all(['asset_tag']);
		$this->accessories = Accessory::All(['name']);
		$this->consumables = Consumable::All(['name']);
		$this->customfields = CustomField::All(['name']);
                $bar = NULL;
                if(!$this->option('web-importer')) {
		        $bar = $this->output->createProgressBar(count($newarray));
                }
		// Loop through the records
		DB::transaction(function() use (&$newarray, $bar){
		Model::unguard();
		$item_type = strtolower($this->option('item-type'));



		foreach( $newarray as $row ) {

			// Let's just map some of these entries to more user friendly words

			// Fetch general items here, fetch item type specific items in respective methods
			/** @var Asset, License, Accessory, or Consumable $item_type */

			$item_category = $this->array_smart_fetch($row, "category");
			$item_company_name = $this->array_smart_fetch($row, "company");
			$item_location = $this->array_smart_fetch($row, "location");

			$item_status_name = $this->array_smart_fetch($row, "status");

			$item["item_name"] = $this->array_smart_fetch($row, "item name");
			if ($this->array_smart_fetch($row, "purchase date")!='') {
				$item["purchase_date"] = date("Y-m-d 00:00:01", strtotime($this->array_smart_fetch($row, "purchase date")));
			} else {
				$item["purchase_date"] = null;
			}

			$item["purchase_cost"] = $this->array_smart_fetch($row, "purchase cost");
			$item["order_number"] = $this->array_smart_fetch($row, "order number");
			$item["notes"] = $this->array_smart_fetch($row, "notes");
			$item["quantity"] = $this->array_smart_fetch($row, "quantity");
			$item["requestable"] = $this->array_smart_fetch($row, "requestable");
			


			$this->current_assetId = $item["item_name"];
			$this->log('Category: ' . $item_category);
			$this->log('Location: ' . $item_location);
			$this->log('Purchase Date: ' . $item["purchase_date"]);
			$this->log('Purchase Cost: ' . $item["purchase_cost"]);
			$this->log('Company Name: ' . $item_company_name);
			$this->log('Status: ' . $item_status_name);

			$item["user"] = $this->createOrFetchUser($row);

			$item["location"] = $this->createOrFetchLocation($item_location);
			$item["category"] = $this->createOrFetchCategory($item_category, $item_type);
			$item["manufacturer"] = $this->createOrFetchManufacturer($row);
			$item["company"] = $this->createOrFetchCompany($item_company_name);

			$item["status_label"] = $this->createOrFetchStatusLabel($item_status_name);

			switch ($item_type) {
				case "asset":
					// -----------------------------
					// CUSTOM FIELDS
					// -----------------------------
					// Loop through custom fields in the database and see if we have any matches in the CSV
					foreach ($this->customfields as $customfield) {
						if ($item['custom_fields'][$customfield->db_column_name()] = $this->array_smart_custom_field_fetch($row, $customfield)) {
							$this->log('Custom Field '. $customfield->name.': '.$this->array_smart_custom_field_fetch($row, $customfield));
						}

					}

					$this->createAssetIfNotExists($row, $item);
					break;
				case "accessory":
					$this->createAccessoryIfNotExists($item);
					break;
				case 'consumable':
					$this->createConsumableIfNotExists($item);
					break;
			}

                        if(!$this->option('web-importer')) {
			        $bar->advance();
                        }
			$this->log('------------- Action Summary ----------------');

		}
	});
                if(!$this->option('web-importer')) {
		        $bar->finish();
                }


			$this->log('=====================================');
			if(!$this->option('web-importer'))
			{
				if(!empty($this->errors)) {
					$this->comment("The following Errors were encountered.");
					foreach($this->errors as $asset => $error)
					{
						$this->comment('Error: Item: ' . $asset . 'failed validation: ' . json_encode($error));
					}
				} else {
					$this->comment("All Items imported successfully!");
				}
			} else {
				if(empty($this->errors))
					return 0;
				else {
					$this->comment(json_encode($this->errors)); //Send a big string to the 
					return 1;
				}
			}
			$this->comment("");

			return 2;
	}
	// Tracks the current item for error messages
	private $current_assetId;

	// An array of errors encountered while parsing
	private $errors;

	public function jsonError($field, $errorString)
	{
		$this->errors[$this->current_assetId] = array($field => $errorString);
		if($this->option('verbose'))
			parent::error($errorString);
	}

	/**
	 * Log a message to file, configurable by the --log-file parameter.
	 * If a warning message is passed, we'll spit it to the console as well.
	 *
	 * @author Daniel Melzter
	 * @since 3.0
	 * @param string $string
	 * @param string $level
	*/
	private function log($string, $level = 'info')
	{
		if($this->option('web-importer'))
			return;
		if($level === 'warning')
		{
			\Log::warning($string);
			$this->comment($string);
		}
		else {
			\Log::Info($string);
			if($this->option('verbose')) {
				$this->comment($string);
			}
		}
	}

	/**
	 * Check to see if the given key exists in the array, and trim excess white space before returning it
	 *
	 * @author Daniel Melzter
	 * @since 3.0
	 * @param $array array
	 * @param $key string
	 * @param $default string
	 * @return string
     */
	public function array_smart_fetch(Array $array, $key, $default = '') {
		return array_key_exists($key,$array) ? e(trim($array[ $key ])) : $default;
	}


	/**
	 * Figure out the fieldname of the custom field
	 *
	 * @author A. Gianotto <snipe@snipe.net>
	 * @since 3.0
	 * @param $array array
	 * @return string
	 */
	public function array_smart_custom_field_fetch(Array $array, $key) {
		$index_name = strtolower($key->name);
		return array_key_exists($index_name,$array) ? e(trim($array[$index_name])) : '';
	}



	private $asset_models;
    /**
	 * Select the asset model if it exists, otherwise create it.
	 *
	 * @author Daniel Melzter
	 * @since 3.0
     * @param array
     * @param $category Category
     * @param $manufacturer Manufacturer
     * @return Model
     * @internal param $asset_modelno string
     */
	public function createOrFetchAssetModel(array $row, $category, $manufacturer)
	{

		$asset_model_name = $this->array_smart_fetch($row, "model name");
		$asset_modelno = $this->array_smart_fetch($row, "model number");
		if(empty($asset_model_name))
			$asset_model_name='Unknown';
		if(empty($asset_modelno))
			$asset_modelno='';
		$this->log('Model Name: ' . $asset_model_name);
		$this->log('Model No: ' . $asset_modelno);


		foreach ($this->asset_models as $tempmodel) {
			if ((strcasecmp($tempmodel->name, $asset_model_name) == 0)
				&& $tempmodel->modelno == $asset_modelno
				&& $tempmodel->category_id == $category->id 
				&& $tempmodel->manufacturer_id == $manufacturer->id )
			{
				$this->log('A matching model ' . $asset_model_name . ' with model number ' . $asset_modelno . ' already exists');
				return $tempmodel;
			}
		}
		$asset_model = new AssetModel();
		$asset_model->name = $asset_model_name;
		$asset_model->manufacturer_id = $manufacturer->id;
		$asset_model->modelno = $asset_modelno;
		$asset_model->category_id = $category->id;
		$asset_model->user_id = $this->option('user_id');


		if(!$this->option('testrun')) {
			if ($asset_model->save()) {
				$this->asset_models->add($asset_model);
				$this->log('Asset Model ' . $asset_model_name . ' with model number ' . $asset_modelno . ' was created');
				return $asset_model;
			} else {
                $this->jsonError('Asset Model', $asset_model->getErrors());
				return $asset_model;
			}
		} else {
			$this->asset_models->add($asset_model);
			return $asset_model;
		}

	}

	private $categories;

	/**
	 * Finds a category with the same name and item type in the database, otherwise creates it
	 *
	 * @author Daniel Melzter
	 * @since 3.0
	 * @param $asset_category string
	 * @param $item_type string
	 * @return Category
	 */
	public function createOrFetchCategory($asset_category, $item_type)
	{
		if (empty($asset_category))
			$asset_category = 'Unnamed Category';

		foreach($this->categories as $tempcategory) {
			if( (strcasecmp($tempcategory->name, $asset_category) == 0) && $tempcategory->category_type === $item_type) {
				$this->log('Category ' . $asset_category . ' already exists');
				return $tempcategory;
			}
		}

		$category = new Category();

		$category->name = $asset_category;
		$category->category_type = $item_type;
		$category->user_id = $this->option('user_id');


		if(!$this->option('testrun')) {
			if ($category->save()) {
				$this->categories->add($category);
				$this->log('Category ' . $asset_category . ' was created');
				return $category;
			} else {
                $this->jsonError('Category', $category->getErrors());
                return $category;
			}
		} else {
			$this->categories->add($category);
			return $category;
		}

	}

	private $companies;

	/**
	 * Fetch an existing company, or create new if it doesn't exist
	 *
	 * @author Daniel Melzter
	 * @since 3.0
	 * @param $asset_company_name string
	 * @return Company
	 */
	public function createOrFetchCompany($asset_company_name)
	{
		foreach ($this->companies as $tempcompany) {
			if (strcasecmp($tempcompany->name, $asset_company_name) == 0) {
				$this->log('A matching Company ' . $asset_company_name . ' already exists');
				return $tempcompany;
			}
		}

		$company = new Company();
		$company->name = $asset_company_name;

		if(!$this->option('testrun')) {
			if ($company->save()) {
				$this->companies->add($company);
				$this->log('Company ' . $asset_company_name . ' was created');
				return $company;
			} else {
                $this->log('Company', $company->getErrors());
			}
		} else {
			$this->companies->add($company);
			return $company;
		}
	}
	private $status_labels;
	/**
	 * Fetch the existing status label or create new if it doesn't exist.
	 *
	 * @author Daniel Melzter
	 * @since 3.0
	 * @param string $asset_statuslabel_name 
	 * @return Company
	 */
	public function createOrFetchStatusLabel($asset_statuslabel_name)
	{
		if(empty($asset_statuslabel_name))
			return;
		foreach ($this->status_labels as $tempstatus) {
			if (strcasecmp($tempstatus->name, $asset_statuslabel_name) == 0 ) {
				$this->log('A matching Status ' . $asset_statuslabel_name . ' already exists');
				return $tempstatus;
			}
		}
		$status = new Statuslabel();
		$status->name = $asset_statuslabel_name;


		if(!$this->option('testrun')) {
			if ($status->save()) {
				$this->status_labels->add($status);
				$this->log('Status ' . $asset_statuslabel_name . ' was created');
				return $status;
			} else {
                $this->jsonError('Status', $status->getErrors());
				return $status;
			}
		} else {
			$this->status_labels->add($status);
			return $status;
		}
	}

	private $manufacturers;

	/**
	 * Finds a manufacturer with matching name, otherwise create it.
	 *
	 * @author Daniel Melzter
	 * @since 3.0
	 * @param $row array
	 * @return Manufacturer
	 * @internal param $asset_mfgr string
	 */

	public function createOrFetchManufacturer(array $row)
	{
		$asset_mfgr = $this->array_smart_fetch($row, "manufacturer");

		if(empty($asset_mfgr)) {
			$asset_mfgr='Unknown';
		}
		$this->log('Manufacturer ID: ' . $asset_mfgr);

		foreach ($this->manufacturers as $tempmanufacturer) {
			if (strcasecmp($tempmanufacturer->name, $asset_mfgr) == 0 ) {
				$this->log('Manufacturer ' . $asset_mfgr . ' already exists') ;
				return $tempmanufacturer;
			}
		}

		//Otherwise create a manufacturer.

		$manufacturer = new Manufacturer();
		$manufacturer->name = $asset_mfgr;
		$manufacturer->user_id = $this->option('user_id');

		if (!$this->option('testrun')) {
			if ($manufacturer->save()) {
				$this->manufacturers->add($manufacturer);
				$this->log('Manufacturer ' . $manufacturer->name . ' was created');
				return $manufacturer;
			} else {
                $this->jsonError('Manufacturer', $manufacturer->getErrors());
				return $manufacturer;
			}

		} else {
			$this->manufacturers->add($manufacturer);
			return $manufacturer;
		}
	}

	/**
	 * @var
     */
	private $locations;
	/**
	 * Checks the DB to see if a location with the same name exists, otherwise create it
	 *
	 * @author Daniel Melzter
	 * @since 3.0
	 * @param $asset_location string
	 * @return Location
	 */
	public function createOrFetchLocation($asset_location)
	{
		foreach($this->locations as $templocation) {
			if( strcasecmp($templocation->name, $asset_location) == 0 ) {
				$this->log('Location ' . $asset_location . ' already exists');
				return $templocation;
			}
		}
		// No matching locations in the collection, create a new one.
		$location = new Location();

		if (!empty($asset_location)) {
			$location->name = $asset_location;
			$location->address = '';
			$location->city = '';
			$location->state = '';
			$location->country = '';
			$location->user_id = $this->option('user_id');

			if (!$this->option('testrun')) {
				if ($location->save()) {
					$this->locations->add($location);
					$this->log('Location ' . $asset_location . ' was created');
					return $location;
				} else {
					$this->log('Location', $location->getErrors()) ;
					return $location;
				}
			} else {
				$this->locations->add($location);
				return $location;
			}
		} else {
			$this->log('No location given, so none created.');
			return $location;
		}

	}

	private $suppliers;

	/**
	 * Fetch an existing supplier or create new if it doesn't exist
	 *
	 * @author Daniel Melzter
	 * @since 3.0
	 * @param $row array
	 * @return Supplier
     */
	public function createOrFetchSupplier(array $row)
	{
		$supplier_name = $this->array_smart_fetch($row, "supplier");
		if(empty($supplier_name))
			$supplier_name='Unknown';
		foreach ($this->suppliers as $tempsupplier) {
			if (strcasecmp($tempsupplier->name, $supplier_name) == 0) {
				$this->log('A matching Company ' . $supplier_name . ' already exists');
				return $tempsupplier;
			}
		}

		$supplier = new Supplier();
		$supplier->name = $supplier_name;
		$supplier->user_id = $this->option('user_id');

		if(!$this->option('testrun')) {
			if ($supplier->save()) {
				$this->suppliers->add($supplier);
				$this->log('Supplier ' . $supplier_name . ' was created');
				return $supplier;
			} else {
                $this->log('Supplier', $supplier->getErrors());
                return $supplier;
			}
		} else {
			$this->suppliers->add($supplier);
			return $supplier;
		}
	}

	/**
	 * Finds the user matching given data, or creates a new one if there is no match
	 *
	 * @author Daniel Melzter
	 * @since 3.0
	 * @param $row array
	 * @return User Model w/ matching name
	 * @internal param string $user_username Username extracted from CSV
	 * @internal param string $user_email Email extracted from CSV
	 * @internal param string $first_name
	 * @internal param string $last_name
	 */
	public function createOrFetchUser($row)
	{
		$user_name = $this->array_smart_fetch($row, "name");
		$user_email = $this->array_smart_fetch($row, "email");
		$user_username = $this->array_smart_fetch($row, "username");

		// A number was given instead of a name
		if (is_numeric($user_name)) {
			$this->log('User '.$user_name.' is not a name - assume this user already exists');
			$user_username = '';
            $first_name = '';
			$last_name = '';

		// No name was given
		} elseif (empty($user_name)) {
			$this->log('No user data provided - skipping user creation, just adding asset');
			$first_name = '';
			$last_name = '';
			//$user_username = '';
		} else {
			$user_email_array = User::generateFormattedNameFromFullName(Setting::getSettings()->email_format, $user_name);
			$first_name = $user_email_array['first_name'];
			$last_name = $user_email_array['last_name'];

			if ($user_email=='') {
				$user_email = $user_email_array['username'].'@'.Setting::getSettings()->email_domain;
			}

			if ($user_username=='') {
				if ($this->option('username_format')=='email') {
					$user_username = $user_email;
				} else {
					$user_name_array = User::generateFormattedNameFromFullName(Setting::getSettings()->username_format, $user_name);
					$user_username = $user_name_array['username'];
				}

			}

		}
		$this->log("--- User Data ---");
		$this->log('Full Name: ' . $user_name);
		$this->log('First Name: ' . $first_name);
		$this->log('Last Name: ' . $last_name);
		$this->log('Username: ' . $user_username);
		$this->log('Email: ' . $user_email);
		$this->log('--- End User Data ---');

        if($this->option('testrun'))
            return new User;

		if (!empty($user_username)) {
			if ($user = User::MatchEmailOrUsername($user_username, $user_email)
				->whereNotNull('username')->first()) {

				$this->log('User '.$user_username.' already exists');
			} else if(( $first_name != '') && ($last_name != '') && ($user_username != '')) {
                $user = new \App\Models\User;
                $password  = substr(str_shuffle("0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"), 0, 20);

                $user->first_name = $first_name;
                $user->last_name = $last_name;
                $user->username = $user_username;
                $user->email = $user_email;
                $user->password = bcrypt($password);
                $user->activated = 1;
                if ($user->save()) {
                    $this->log('User '.$first_name.' created');
                } else {
                    $this->jsonError('User', $user->getErrors());
                }

			} else {
				$user = new User;
			}
		} else {
			$user = new User;
		}
		return $user;
	}

	private $assets;

	/**
	 * Create the asset if it doesn't exist.
	 *
	 * @author Daniel Melzter
	 * @since 3.0
	 * @param array $row
	 * @param array $item
	 */
	public function createAssetIfNotExists(array $row, array $item )
	{
        $asset_serial = $this->array_smart_fetch($row, "serial number");
        $asset_tag = $this->array_smart_fetch($row, "asset tag");
        $asset_image = $this->array_smart_fetch($row, "image");
        $asset_warranty_months = intval($this->array_smart_fetch($row, "warranty months"));
        if(empty($asset_warranty_months)) {
        	$asset_warranty_months = NULL;
        }
        // Check for the asset model match and create it if it doesn't exist
        $asset_model = $this->createOrFetchAssetModel($row, $item["category"], $item["manufacturer"]);
		$supplier = $this->createOrFetchSupplier($row);

		$this->current_assetId = $asset_tag;

        $this->log('Serial No: '.$asset_serial);
        $this->log('Asset Tag: '.$asset_tag);
        $this->log('Notes: '.$item["notes"]);
        $this->log('Warranty Months: ' . $asset_warranty_months);

		foreach ($this->assets as $tempasset) {
			if (strcasecmp($tempasset->asset_tag, $asset_tag ) == 0 ) {
				$this->log('A matching Asset ' . $asset_tag . ' already exists');
				// $this->comment('A matching Asset ' . $asset_tag . ' already exists');
				return;
			}
		}

		if($item["status_label"]) {
			$status_id = $item["status_label"]->id;

		} else {
			// FIXME: We're already grabbing the list of statuses, we should probably not hardcode here
			$this->log("No status field found, defaulting to id 1.");
			$status_id = 1;
		}

		$asset = new Asset();
		$asset->name = $item["item_name"];
		if ($item["purchase_date"] != '') {
			$asset->purchase_date = $item["purchase_date"];
		} else {
			$asset->purchase_date = NULL;
		}

                if( array_key_exists('custom_fields', $item)) {
		        foreach ($item['custom_fields'] as $custom_field => $val) {
			        $asset->{$custom_field} = $val;
                        }
                }

		if (!empty($item["purchase_cost"])) {
			//TODO How to generalize this for not USD?
			$purchase_cost = substr($item["purchase_cost"],0,1) === '$' ? substr($item["purchase_cost"],1) : $item["purchase_cost"];
			$asset->purchase_cost = number_format($purchase_cost,2);
			$this->log("Asset cost parsed: " . $asset->purchase_cost);
		} else {
			$asset->purchase_cost = 0.00;
		}
		$asset->serial = $asset_serial;
		$asset->asset_tag = $asset_tag;
                $asset->warranty_months = $asset_warranty_months;

		if($asset_model)
			$asset->model_id = $asset_model->id;
		if($item["user"])
			$asset->assigned_to = $item["user"]->id;
		if($item["location"])
			$asset->rtd_location_id = $item["location"]->id;
		$asset->user_id = $this->option('user_id');
		$this->log("status_id: " . $status_id);
		$asset->status_id = $status_id;
		if($item["company"])
			$asset->company_id = $item["company"]->id;
		$asset->order_number = $item["order_number"];
		if($supplier)
			$asset->supplier_id = $supplier->id;
		$asset->notes = $item["notes"];
		$asset->image = $asset_image;
		$this->assets->add($asset);
		if (!$this->option('testrun')) {

			if ($asset->save()) {
				$this->log('Asset ' . $item["item_name"] . ' with serial number ' . $asset_serial . ' was created');
			} else {
                $this->jsonError('Asset', $asset->getErrors());
			}

		} else {
			return;
		}
	}

	private $accessories;

	/**
	 * Create an accessory if a duplicate does not exist
	 *
	 * @author Daniel Melzter
	 * @since 3.0
	 * @param $item array
	 */
	public function createAccessoryIfNotExists(array $item )
	{
		$this->log("Creating Accessory");
		foreach ($this->accessories as $tempaccessory) {
			if (strcasecmp($tempaccessory->name, $item["item_name"] ) == 0 ) {
				$this->log('A matching Accessory ' . $item["item_name"] . ' already exists.  ');
				// FUTURE: Adjust quantity on import maybe?
				return;
			}
		}

		$accessory = new Accessory();
		$accessory->name = $item["item_name"];

		if (!empty($item["purchase_date"])) {
			$accessory->purchase_date = $item["purchase_date"];
		} else {
			$accessory->purchase_date = NULL;
		}
		if (!empty($item["purchase_cost"])) {
			$accessory->purchase_cost = number_format(e($item["purchase_cost"]),2);
		} else {
			$accessory->purchase_cost = 0.00;
		}
		if($item["location"])
			$accessory->location_id = $item["location"]->id;
		$accessory->user_id = $this->option('user_id');
		if($item["company"])
			$accessory->company_id = $item["company"]->id;
		$accessory->order_number = $item["order_number"];
		if($item["category"])
			$accessory->category_id = $item["category"]->id;

		//TODO: Implement
//		$accessory->notes = e($item_notes);
		$accessory->requestable = filter_var($item["requestable"], FILTER_VALIDATE_BOOLEAN);

		//Must have at least zero of the item if we import it.
		if($item["quantity"] > -1) {
			$accessory->qty = $item["quantity"];
		} else {
			$accessory->qty = 1;
		}

		if (!$this->option('testrun')) {
			if ($accessory->save()) {
				$this->log('Accessory ' . $item["item_name"] . ' was created');
				// $this->comment('Accessory ' . $item["item_name"] . ' was created');

			} else {
				$this->jsonError('Accessory', $accessory->getErrors()) ;
			}
		} else {
			$this->log('TEST RUN - Accessory  ' . $item["item_name"] . ' not created');
		}
	}

	private $consumables;

	/**
	 * Create a consumable if a duplicate does not exist
	 *
	 * @author Daniel Melzter
	 * @since 3.0
	 * @param $item array
	 */
	public function createConsumableIfNotExists(array $item)
	{
		$this->log("Creating Consumable");
		foreach($this->consumables as $tempconsumable) {
			if(strcasecmp($tempconsumable->name, $item["item_name"]) == 0) {
				$this->log("A matching consumable " . $item["item_name"] . " already exists");
				//TODO: Adjust quantity if different maybe?
				return;
			}
		}

		$consumable = new Consumable();
		$consumable->name = $item["item_name"];

		if(!empty($item["purchase_date"])) {
			$consumable->purchase_date = $item["purchase_date"];
		} else {
			$consumable->purchase_date = NULL;
		}

		if(!empty($item["purchase_cost"])) {
			$consumable->purchase_cost = number_format(e($item["purchase_cost"]),2);
		} else {
			$consumable->purchase_cost = 0.00;
		}
		$consumable->location_id = $item["location"]->id;
		$consumable->user_id = $this->option('user_id');
		$consumable->company_id = $item["company"]->id;
		$consumable->order_number = $item["order_number"];
		$consumable->category_id = $item["category"]->id;
		// TODO:Implement
		//$consumable->notes= e($item_notes);
		$consumable->requestable = filter_var($item["requestable"], FILTER_VALIDATE_BOOLEAN);

		if($item["quantity"] > -1) {
			$consumable->qty = $item["quantity"];
		} else {
			$consumable->qty = 1;
		}

		if(!$this->option("testrun")) {
			if($consumable->save()) {
				$this->log("Consumable " . $item["item_name"] . ' was created');
				// $this->comment("Consumable " . $item["item_name"] . ' was created');

			} else {
				$this->jsonError('Consumable', $consumable->getErrors());
			}
		} else {
			$this->log('TEST RUN - Consumable ' . $item['item_name'] . ' not created');
		}
	}

	/**
	 * Get the console command arguments.
	 *
	 * @author Daniel Melzter
	 * @since 3.0
	 * @return array
	 */
	protected function getArguments()
	{
		return array(
			array('filename', InputArgument::REQUIRED, 'File for the CSV import.'),
		);
	}


	/**
	 * Get the console command options.
	 *
	 * @author Daniel Melzter
	 * @since 3.0
	 * @return array
	 */
	protected function getOptions()
	{
	return array(
		array('email_format', null, InputOption::VALUE_REQUIRED, 'The format of the email addresses that should be generated. Options are firstname.lastname, firstname, filastname', null),
		array('username_format', null, InputOption::VALUE_REQUIRED, 'The format of the username that should be generated. Options are firstname.lastname, firstname, filastname, email', null),
		array('testrun', null, InputOption::VALUE_NONE, 'If set, will parse and output data without adding to database', null),
		array('logfile', null, InputOption::VALUE_REQUIRED, 'The path to log output to.  storage/logs/importer.log by default', storage_path('logs/importer.log') ),
		array('item-type', null, InputOption::VALUE_REQUIRED, 'Item Type To import.  Valid Options are Asset, Consumable, Or Accessory', 'Asset'),
                array('web-importer', null, InputOption::VALUE_NONE, 'Internal: packages output for use with the web importer'),
                array('user_id', null, InputOption::VALUE_REQUIRED, 'ID of user creating items', 1)
	);

	}



}