2016-05-17 19:25:17 -07:00
< ? 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 ;
2016-05-24 15:14:01 -07:00
use App\Models\Statuslabel ;
2016-05-17 19:25:17 -07:00
use App\Models\Supplier ;
use App\Models\User ;
2016-06-13 21:41:09 -07:00
use App\Models\CustomField ;
2016-05-17 19:25:17 -07:00
use DB ;
2016-06-13 21:41:09 -07:00
use App\Models\Setting ;
use Illuminate\Database\Eloquent\Model ;
ini_set ( 'max_execution_time' , 600 ); //600 seconds = 10 minutes
ini_set ( 'memory_limit' , '500M' );
2016-05-17 19:25:17 -07:00
/**
* Class ObjectImportCommand
*/
2016-06-22 12:27:41 -07:00
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' ]);
2016-07-09 18:20:57 -07:00
$bar = null ;
2016-06-22 12:27:41 -07:00
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' ));
2016-06-13 21:45:52 -07:00
2016-06-22 12:27:41 -07:00
foreach ( $newarray as $row ) {
2016-05-17 19:25:17 -07:00
2016-06-22 12:27:41 -07:00
// Let's just map some of these entries to more user friendly words
2016-05-17 19:25:17 -07:00
2016-06-22 12:27:41 -07:00
// Fetch general items here, fetch item type specific items in respective methods
/** @var Asset, License, Accessory, or Consumable $item_type */
2016-05-17 19:25:17 -07:00
2016-06-22 12:27:41 -07:00
$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 " );
2016-05-17 19:25:17 -07:00
2016-06-22 12:27:41 -07:00
$item_status_name = $this -> array_smart_fetch ( $row , " status " );
2016-05-24 15:14:01 -07:00
2016-06-22 12:27:41 -07:00
$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 ;
}
2016-06-10 05:00:49 -07:00
2016-06-22 12:27:41 -07:00
$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 " );
$item [ " asset_tag " ] = $this -> array_smart_fetch ( $row , " asset tag " );
2016-05-17 19:25:17 -07:00
2016-06-22 12:27:41 -07:00
$this -> current_assetId = $item [ " item_name " ];
if ( $item [ " asset_tag " ] != '' ) {
$this -> current_assetId = $item [ " asset_tag " ];
}
$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 ));
}
2016-06-19 20:56:10 -07:00
}
2016-05-17 19:25:17 -07:00
2016-06-22 12:27:41 -07:00
$this -> createAssetIfNotExists ( $row , $item );
break ;
case " accessory " :
$this -> createAccessoryIfNotExists ( $item );
break ;
case 'consumable' :
$this -> createConsumableIfNotExists ( $item );
break ;
}
if ( ! $this -> option ( 'web-importer' )) {
$bar -> advance ();
2016-06-19 20:56:10 -07:00
}
2016-06-22 12:27:41 -07:00
$this -> log ( '------------- Action Summary ----------------' );
}
});
if ( ! $this -> option ( 'web-importer' )) {
$bar -> finish ();
}
2016-06-13 21:45:52 -07:00
2016-05-26 19:29:29 -07:00
2016-06-22 12:27:41 -07:00
$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 ][ $field ] = $errorString ;
if ( $this -> option ( 'verbose' )) {
parent :: error ( $field . $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
2016-05-17 19:25:17 -07:00
*/
2016-06-22 12:27:41 -07:00
public function array_smart_fetch ( array $array , $key , $default = '' )
{
return array_key_exists ( $key , $array ) ? e ( trim ( $array [ $key ])) : $default ;
}
2016-05-17 19:25:17 -07:00
2016-06-13 21:45:52 -07:00
2016-06-22 12:27:41 -07:00
/**
* 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 ])) : '' ;
}
2016-06-13 21:45:52 -07:00
2016-06-22 12:27:41 -07:00
private $asset_models ;
2016-05-17 19:47:38 -07:00
/**
2016-06-22 12:27:41 -07:00
* Select the asset model if it exists , otherwise create it .
*
* @ author Daniel Melzter
* @ since 3.0
2016-05-17 19:47:38 -07:00
* @ param array
* @ param $category Category
* @ param $manufacturer Manufacturer
* @ return Model
* @ internal param $asset_modelno string
2016-05-17 19:25:17 -07:00
*/
2016-06-22 12:27:41 -07:00
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 {
2016-06-22 14:07:55 -07:00
$this -> jsonError ( 'Asset Model ' . $asset_model_name , $asset_model -> getErrors ());
2016-06-22 12:27:41 -07:00
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 {
2016-06-22 14:07:55 -07:00
$this -> jsonError ( 'Category ' . $asset_category , $category -> getErrors ());
2016-05-25 17:34:54 -07:00
return $category ;
2016-06-22 12:27:41 -07:00
}
} 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 {
2016-05-31 16:04:01 -07:00
$this -> log ( 'Company' , $company -> getErrors ());
2016-06-22 12:27:41 -07:00
}
} 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 {
2016-06-22 14:07:55 -07:00
$this -> jsonError ( 'Status ' . $asset_statuslabel_name , $status -> getErrors ());
2016-06-22 12:27:41 -07:00
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 {
2016-06-22 14:07:55 -07:00
$this -> jsonError ( 'Manufacturer ' . $manufacturer -> name , $manufacturer -> getErrors ());
2016-06-22 12:27:41 -07:00
return $manufacturer ;
}
2016-05-17 19:25:17 -07:00
2016-06-22 12:27:41 -07:00
} else {
$this -> manufacturers -> add ( $manufacturer );
return $manufacturer ;
}
}
2016-05-17 19:25:17 -07:00
2016-06-22 12:27:41 -07:00
/**
* @ 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
2016-05-17 19:25:17 -07:00
*/
2016-06-22 12:27:41 -07:00
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
2016-05-17 19:25:17 -07:00
*/
2016-06-22 12:27:41 -07:00
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 {
2016-05-31 16:04:01 -07:00
$this -> log ( 'Supplier' , $supplier -> getErrors ());
2016-05-25 17:34:54 -07:00
return $supplier ;
2016-06-22 12:27:41 -07:00
}
} 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 = '' ;
2016-05-18 21:33:18 -07:00
$first_name = '' ;
2016-06-22 12:27:41 -07:00
$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' )) {
2016-05-17 19:47:38 -07:00
return new User ;
2016-06-22 12:27:41 -07:00
}
2016-05-18 21:33:18 -07:00
2016-06-22 12:27:41 -07:00
if ( ! empty ( $user_username )) {
if ( $user = User :: MatchEmailOrUsername ( $user_username , $user_email )
-> whereNotNull ( 'username' ) -> first ()) {
2016-05-24 19:40:52 -07:00
2016-06-22 12:27:41 -07:00
$this -> log ( 'User ' . $user_username . ' already exists' );
} elseif (( $first_name != '' ) && ( $last_name != '' ) && ( $user_username != '' )) {
2016-05-18 21:33:18 -07:00
$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 ()) {
2016-05-25 17:34:54 -07:00
$this -> log ( 'User ' . $first_name . ' created' );
2016-05-18 21:33:18 -07:00
} else {
2016-05-26 19:29:29 -07:00
$this -> jsonError ( 'User' , $user -> getErrors ());
2016-05-18 21:33:18 -07:00
}
2016-06-22 12:27:41 -07:00
} 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 )
{
2016-05-17 19:25:17 -07:00
$asset_serial = $this -> array_smart_fetch ( $row , " serial number " );
2016-05-18 20:33:55 -07:00
$asset_image = $this -> array_smart_fetch ( $row , " image " );
2016-05-25 19:13:26 -07:00
$asset_warranty_months = intval ( $this -> array_smart_fetch ( $row , " warranty months " ));
2016-06-22 12:27:41 -07:00
if ( empty ( $asset_warranty_months )) {
$asset_warranty_months = null ;
2016-05-25 19:13:26 -07:00
}
2016-05-17 19:25:17 -07:00
// Check for the asset model match and create it if it doesn't exist
$asset_model = $this -> createOrFetchAssetModel ( $row , $item [ " category " ], $item [ " manufacturer " ]);
2016-06-22 12:27:41 -07:00
$supplier = $this -> createOrFetchSupplier ( $row );
2016-05-17 19:25:17 -07:00
2016-05-25 17:34:54 -07:00
$this -> log ( 'Serial No: ' . $asset_serial );
2016-06-22 12:13:01 -07:00
$this -> log ( 'Asset Tag: ' . $item [ 'asset_tag' ]);
2016-05-25 17:34:54 -07:00
$this -> log ( 'Notes: ' . $item [ " notes " ]);
2016-06-19 20:06:54 -07:00
$this -> log ( 'Warranty Months: ' . $asset_warranty_months );
2016-05-17 19:25:17 -07:00
2016-06-22 12:27:41 -07:00
foreach ( $this -> assets as $tempasset ) {
if ( strcasecmp ( $tempasset -> asset_tag , $item [ 'asset_tag' ]) == 0 ) {
$this -> log ( 'A matching Asset ' . $item [ '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 ;
}
2016-06-13 21:45:52 -07:00
2016-06-22 12:27:41 -07:00
$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 = $item [ 'asset_tag' ];
2016-06-19 20:06:54 -07:00
$asset -> warranty_months = $asset_warranty_months ;
2016-05-25 17:34:54 -07:00
2016-06-22 12:27:41 -07:00
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 {
2016-05-26 19:29:29 -07:00
$this -> jsonError ( 'Asset' , $asset -> getErrors ());
2016-06-22 12:27:41 -07:00
}
} 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
2016-05-17 19:25:17 -07:00
// $accessory->notes = e($item_notes);
2016-06-22 12:27:41 -07:00
$accessory -> requestable = filter_var ( $item [ " requestable " ], FILTER_VALIDATE_BOOLEAN );
2016-05-17 19:25:17 -07:00
2016-06-22 12:27:41 -07:00
//Must have at least zero of the item if we import it.
if ( $item [ " quantity " ] > - 1 ) {
$accessory -> qty = $item [ " quantity " ];
} else {
$accessory -> qty = 1 ;
}
2016-05-17 19:25:17 -07:00
2016-06-22 12:27:41 -07:00
if ( ! $this -> option ( 'testrun' )) {
if ( $accessory -> save ()) {
$this -> log ( 'Accessory ' . $item [ " item_name " ] . ' was created' );
// $this->comment('Accessory ' . $item["item_name"] . ' was created');
2016-05-17 19:25:17 -07:00
2016-06-22 12:27:41 -07:00
} 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 )
);
2016-05-17 19:25:17 -07:00
2016-06-22 12:27:41 -07:00
}
2016-05-31 17:00:11 -07:00
}