Add command to archive job order data. #762
This commit is contained in:
Korina Cordero
parent
8c11ec9e8f
commit
22d4201097
1 changed files with 344 additions and 0 deletions
344
src/Command/GetJobOrderArchiveDataCommand.php
Normal file
344
src/Command/GetJobOrderArchiveDataCommand.php
Normal file
|
|
@ -0,0 +1,344 @@
|
||||||
|
<?php
|
||||||
|
|
||||||
|
namespace App\Command;
|
||||||
|
|
||||||
|
use Symfony\Component\Console\Command\Command;
|
||||||
|
use Symfony\Component\Console\Input\InputArgument;
|
||||||
|
use Symfony\Component\Console\Input\InputInterface;
|
||||||
|
use Symfony\Component\Console\Output\OutputInterface;
|
||||||
|
use Symfony\Component\HttpKernel\KernelInterface;
|
||||||
|
use Symfony\Component\Filesystem\Filesystem;
|
||||||
|
|
||||||
|
use Doctrine\ORM\EntityManagerInterface;
|
||||||
|
|
||||||
|
use PDO;
|
||||||
|
use DateTime;
|
||||||
|
|
||||||
|
class GetJobOrderArchiveDataCommand extends Command
|
||||||
|
{
|
||||||
|
protected $em;
|
||||||
|
protected $project_dir;
|
||||||
|
protected $filesystem;
|
||||||
|
|
||||||
|
public function __construct(EntityManagerInterface $em, KernelInterface $kernel, FileSystem $filesystem)
|
||||||
|
{
|
||||||
|
$this->em = $em;
|
||||||
|
$this->project_dir = $kernel->getProjectDir();
|
||||||
|
$this->filesystem = $filesystem;
|
||||||
|
|
||||||
|
parent::__construct();
|
||||||
|
}
|
||||||
|
|
||||||
|
protected function configure()
|
||||||
|
{
|
||||||
|
$this->setName('joborder:archive')
|
||||||
|
->setDescription('Get job order data to archive.')
|
||||||
|
->setHelp('Get job order data to archive.')
|
||||||
|
->addArgument('cutoff_date', InputArgument::REQUIRED, 'cutoff_date')
|
||||||
|
->addArgument('period', InputArgument::REQUIRED, 'period');
|
||||||
|
}
|
||||||
|
|
||||||
|
protected function execute(InputInterface $input, OutputInterface $output)
|
||||||
|
{
|
||||||
|
// get table to back up
|
||||||
|
$period = $input->getArgument('period');
|
||||||
|
$cutoff_date = $input->getArgument('cutoff_date');
|
||||||
|
|
||||||
|
$em = $this->em;
|
||||||
|
|
||||||
|
$db = $em->getConnection();
|
||||||
|
|
||||||
|
// create the archive table
|
||||||
|
$archive_table_name = $this->createArchiveTable($cutoff_date, $period);
|
||||||
|
|
||||||
|
// sql query to retrieve the rows or entries for backup
|
||||||
|
$query_sql = 'SELECT id,
|
||||||
|
customer_id,
|
||||||
|
cvehicle_id,
|
||||||
|
rider_id,
|
||||||
|
date_create,
|
||||||
|
date_schedule,
|
||||||
|
date_fulfill,
|
||||||
|
coordinates,
|
||||||
|
flag_advance,
|
||||||
|
service_type,
|
||||||
|
source,
|
||||||
|
date_cancel,
|
||||||
|
status,
|
||||||
|
delivery_instructions,
|
||||||
|
delivery_address,
|
||||||
|
create_user_id,
|
||||||
|
assign_user_id,
|
||||||
|
date_assign,
|
||||||
|
warranty_class,
|
||||||
|
process_user_id,
|
||||||
|
hub_id,
|
||||||
|
cancel_reason,
|
||||||
|
ref_jo_id,
|
||||||
|
tier1_notes,
|
||||||
|
tier2_notes,
|
||||||
|
mode_of_payment,
|
||||||
|
or_name,
|
||||||
|
landmark,
|
||||||
|
promo_detail,
|
||||||
|
or_num,
|
||||||
|
trade_in_type,
|
||||||
|
flag_rider_rating,
|
||||||
|
flag_coolant,
|
||||||
|
facilitated_hub_id,
|
||||||
|
facilitated_type,
|
||||||
|
coord_long,
|
||||||
|
coord_lat,
|
||||||
|
priority,
|
||||||
|
meta,
|
||||||
|
status_autoassign,
|
||||||
|
first_name,
|
||||||
|
last_name,
|
||||||
|
plate_number,
|
||||||
|
phone_mobile,
|
||||||
|
no_trade_in_reason,
|
||||||
|
will_wait,
|
||||||
|
reason_not_waiting,
|
||||||
|
not_waiting_notes,
|
||||||
|
delivery_status,
|
||||||
|
emergency_type_id,
|
||||||
|
ownership_type_id,
|
||||||
|
cust_location_id,
|
||||||
|
source_of_awareness,
|
||||||
|
remarks,
|
||||||
|
initial_concern,
|
||||||
|
initial_concern_notes,
|
||||||
|
gender,
|
||||||
|
caller_classification,
|
||||||
|
inventory_count
|
||||||
|
FROM job_order
|
||||||
|
WHERE DATE_CREATE < DATE_SUB(:cutoff_date, INTERVAL ' . $period . ' YEAR)';
|
||||||
|
|
||||||
|
$query_stmt = $db->prepare($query_sql);
|
||||||
|
$query_stmt->bindValue('cutoff_date', $cutoff_date, PDO::PARAM_STR);
|
||||||
|
|
||||||
|
$results = $query_stmt->executeQuery();
|
||||||
|
|
||||||
|
$backup_data = [];
|
||||||
|
|
||||||
|
while ($row = $results->fetchAssociative())
|
||||||
|
{
|
||||||
|
$backup_data[] = $this->createBackupData($row);
|
||||||
|
}
|
||||||
|
|
||||||
|
// create the load file for the backup data
|
||||||
|
$this->createLoadDataFileForBackupData($backup_data);
|
||||||
|
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
protected function createArchiveTable($str_date, $period)
|
||||||
|
{
|
||||||
|
// form the archive table name <original table name>_archive_<year of data being archived>
|
||||||
|
$modifier = '-' . $period. 'year';
|
||||||
|
|
||||||
|
// convert the date string into DateTime
|
||||||
|
$date = new DateTime($str_date);
|
||||||
|
$year = $date->modify($modifier)->format('Y');
|
||||||
|
|
||||||
|
$archive_table_name = 'job_order_archive_' . $year;
|
||||||
|
|
||||||
|
// create the table if it doesn't exist
|
||||||
|
$db = $this->em->getConnection();
|
||||||
|
|
||||||
|
$create_sql = 'CREATE TABLE IF NOT EXISTS `' . $archive_table_name . '` (
|
||||||
|
`id` int(11) NOT NULL,
|
||||||
|
`customer_id` int(11) DEFAULT NULL,
|
||||||
|
`cvehicle_id` int(11) DEFAULT NULL,
|
||||||
|
`rider_id` int(11) DEFAULT NULL,
|
||||||
|
`date_create` datetime NOT NULL,
|
||||||
|
`date_schedule` datetime NOT NULL,
|
||||||
|
`date_fulfill` datetime DEFAULT NULL,
|
||||||
|
`coordinates` point NOT NULL COMMENT \'(DC2Type:point)\',
|
||||||
|
`flag_advance` tinyint(1) NOT NULL,
|
||||||
|
`service_type` varchar(25) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
|
`source` varchar(30) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
|
`date_cancel` datetime DEFAULT NULL,
|
||||||
|
`status` varchar(15) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
|
`delivery_instructions` longtext COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`delivery_address` longtext COLLATE utf8_unicode_ci NOT NULL,
|
||||||
|
`create_user_id` int(11) DEFAULT NULL,
|
||||||
|
`assign_user_id` int(11) DEFAULT NULL,
|
||||||
|
`date_assign` datetime DEFAULT NULL,
|
||||||
|
`warranty_class` varchar(25) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
|
`process_user_id` int(11) DEFAULT NULL,
|
||||||
|
`hub_id` int(11) DEFAULT NULL,
|
||||||
|
`cancel_reason` varchar(200) COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`ref_jo_id` int(11) DEFAULT NULL,
|
||||||
|
`tier1_notes` longtext COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`tier2_notes` longtext COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`mode_of_payment` varchar(50) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
|
`or_name` varchar(80) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
|
`landmark` longtext COLLATE utf8_unicode_ci NOT NULL,
|
||||||
|
`promo_detail` varchar(80) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
|
`or_num` varchar(80) COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`trade_in_type` varchar(25) COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`flag_rider_rating` tinyint(1) DEFAULT NULL,
|
||||||
|
`flag_coolant` tinyint(1) NOT NULL,
|
||||||
|
`facilitated_hub_id` int(11) DEFAULT NULL,
|
||||||
|
`facilitated_type` varchar(8) COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`coord_long` decimal(11,8) NOT NULL,
|
||||||
|
`coord_lat` decimal(11,8) NOT NULL,
|
||||||
|
`priority` int(11) NOT NULL DEFAULT 0,
|
||||||
|
`meta` longtext CHARACTER SET utf8mb4 COLLATE utf8mb4_bin NOT NULL,
|
||||||
|
`status_autoassign` varchar(30) COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`first_name` varchar(80) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
|
`last_name` varchar(80) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
|
`plate_number` varchar(100) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
|
`phone_mobile` varchar(30) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
|
`no_trade_in_reason` varchar(80) COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`will_wait` varchar(30) COLLATE utf8_unicode_ci NOT NULL,
|
||||||
|
`reason_not_waiting` varchar(80) COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`not_waiting_notes` longtext COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`delivery_status` varchar(30) COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`emergency_type_id` int(11) DEFAULT NULL,
|
||||||
|
`ownership_type_id` int(11) DEFAULT NULL,
|
||||||
|
`cust_location_id` int(11) DEFAULT NULL,
|
||||||
|
`source_of_awareness` varchar(80) COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`remarks` longtext COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`initial_concern` varchar(80) COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`initial_concern_notes` longtext COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`gender` varchar(80) COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`caller_classification` varchar(80) COLLATE utf8_unicode_ci DEFAULT NULL,
|
||||||
|
`inventory_count` smallint(6) NOT NULL, PRIMARY KEY (`id`))';
|
||||||
|
|
||||||
|
$create_stmt = $db->prepare($create_sql);
|
||||||
|
|
||||||
|
$result = $create_stmt->execute();
|
||||||
|
|
||||||
|
return $archive_table_name;
|
||||||
|
}
|
||||||
|
|
||||||
|
protected function createBackupData($row)
|
||||||
|
{
|
||||||
|
// get job order data
|
||||||
|
// check for nulls. check the ff fields since these can be null: date_fulfill, date_cancel, date_assign, create_user_id,
|
||||||
|
// assign_user_id, proces_user_id, hub_id, rider_id, cancel_reason, ref_jo_id, or_num, trade_in_type,
|
||||||
|
// flag_rider_rating, facilitated_type, facilitated_hub_id, status_autoassign, reason_not_waiting,
|
||||||
|
// not_waiting_notes, no_trade_in_reason, delivery_status, source_of_awareness, remarks, initial_concern,
|
||||||
|
// initial_concern_notes, gender, caller_classifications, emergency_type_id, ownership_type_id, cust_location_id
|
||||||
|
|
||||||
|
$id = $row['id'];
|
||||||
|
$cust_id = $row['customer_id'];
|
||||||
|
$cv_id = $row['cvehicle_id'];
|
||||||
|
|
||||||
|
$rider_id = '\N';
|
||||||
|
if ($row['rider_id'] != NULL)
|
||||||
|
$rider_id = $row]'rider_id'];
|
||||||
|
|
||||||
|
$date_create = $row['date_create'];
|
||||||
|
$date_schedule = $row['date_schedule'];
|
||||||
|
|
||||||
|
$date_fulfill = '\N';
|
||||||
|
if ($row['date_fulfill'] != NULL)
|
||||||
|
$date_fulfill = $row['date_schedule'];
|
||||||
|
|
||||||
|
$coordinates = $row['coordinates'];
|
||||||
|
$flag_advance = $row['flag_advance'];
|
||||||
|
$service_type = $row['service_type'];
|
||||||
|
$source = $row['source'];
|
||||||
|
|
||||||
|
$date_cancel = '\N';
|
||||||
|
if ($row['date_cancel'] != NULL)
|
||||||
|
$date_cancel = $row['date_cancel'];
|
||||||
|
|
||||||
|
$status = $row['status'];
|
||||||
|
$del_instructions = $row['delivery_instructions'];
|
||||||
|
$del_address = $row['delivery_address'];
|
||||||
|
|
||||||
|
$create_user_id = '\N';
|
||||||
|
if ($row['create_user_id'] != NULL)
|
||||||
|
$create_user_id = $row['create_user_id'];
|
||||||
|
|
||||||
|
$assign_user_id = '\N';
|
||||||
|
if ($row['assign_user_id'] != NULL)
|
||||||
|
$assign_user_id = $row['assign_user_id'];
|
||||||
|
|
||||||
|
$date_assign = '\N';
|
||||||
|
if ($row['date_assign'] != NULL)
|
||||||
|
$date_assign = $row['date_assign'];
|
||||||
|
|
||||||
|
$warr_class = $row['warranty_class'];
|
||||||
|
|
||||||
|
$process_user_id = '\N';
|
||||||
|
if ($row['process_user_id'] != NULL)
|
||||||
|
$process_user_id = $row['process_user_id'];
|
||||||
|
|
||||||
|
$hub_id = '\N';
|
||||||
|
if ($row['hub_id'] != NULL)
|
||||||
|
$hub_id = $row['hub_id'];
|
||||||
|
|
||||||
|
$cancel_reason = '\N';
|
||||||
|
if ($row['cancel_reason'] != NULL)
|
||||||
|
$cancel_reason = $row['cancel_reason'];
|
||||||
|
|
||||||
|
$ref_jo_id = '\N';
|
||||||
|
if ($row['ref_jo_id'] != NULL)
|
||||||
|
$ref_jo_id = $row['ref_jo_id'];
|
||||||
|
|
||||||
|
$tier1_notes = $row['tier1_notes'];
|
||||||
|
$tier2_notes = $row['tier2_notes'];
|
||||||
|
$mode_of_payment = $row['mode_of_payment'];
|
||||||
|
$or_name = $row['or_name'];
|
||||||
|
$landmark = $row['landmark'];
|
||||||
|
$promo_details = $row['promo_detail'];
|
||||||
|
|
||||||
|
$or_num = '\N';
|
||||||
|
if ($row['or_num'] != NULL)
|
||||||
|
$or_num = $row['or_num'];
|
||||||
|
|
||||||
|
$trade_in_type = '\N';
|
||||||
|
if ($row['trade_in_type'] != NULL)
|
||||||
|
$trade_in_type = $row['trade_in_type'];
|
||||||
|
|
||||||
|
$flag_rider_rating = '\N';
|
||||||
|
if ($row['flag_rider_rating'] != NULL)
|
||||||
|
$flag_rider_rating = $row['flag_rider_rating'];
|
||||||
|
|
||||||
|
$flag_coolant = $row['flag_coolant'];
|
||||||
|
|
||||||
|
$fac_hub_id = '\N';
|
||||||
|
if ($row['facilitated_hub_id'] != NULL)
|
||||||
|
$fac_hub_id = $row['facilitated_hub_id'];
|
||||||
|
|
||||||
|
$fac_type = '\N';
|
||||||
|
if ($row['facilitated_type'] != NULL)
|
||||||
|
$fac_type = $row['facilitated_type'];
|
||||||
|
|
||||||
|
$coord_long = $row['coord_long'];
|
||||||
|
$coord_lat = $row['coord_lat'];
|
||||||
|
$priority = $row['priority'];
|
||||||
|
$meta = $row['meta'];
|
||||||
|
$status_autoassign = $row['status_autoassign'];
|
||||||
|
$first_name = $row['first_name'];
|
||||||
|
$last_name = $row['last_name'];
|
||||||
|
$plate_number = $row['plate_number'];
|
||||||
|
$phone_mobile = $row['phone_mobile'];
|
||||||
|
$no_trade_in_reason = $row[' no_trade_in_reason'];
|
||||||
|
$will_wait = $row['will_wait'];
|
||||||
|
$reason_not_waiting = $row['reason_not_waiting'];
|
||||||
|
$not_waiting_notes = $row['not_waiting_notes'];
|
||||||
|
$del_status = $row['delivery_status'];
|
||||||
|
$emergency_type_id = $row['emergency_type_id'];
|
||||||
|
$owner_type_id = $row['ownership_type_id'];
|
||||||
|
$cust_location_id = $row['cust_location_id'];
|
||||||
|
$source_of_awareness = $row['source_of_awareness'];
|
||||||
|
$remarks = $row['remarks'];
|
||||||
|
$initial_concern = $row['initial_concern'];
|
||||||
|
$initial_concern_notes = $row['initial_concern_notes'];
|
||||||
|
$gender = $row['gender'];
|
||||||
|
$caller_class = $row['caller_classification'];
|
||||||
|
$inv_count = $row['inventory_count'];
|
||||||
|
|
||||||
|
// check for nulls. check the ff fields since these can be null: date_fulfill, date_cancel, date_assign, create_user_id,
|
||||||
|
// assign_user_id, proces_user_id, hub_id, rider_id, cancel_reason, ref_jo_id, or_num, trade_in_type,
|
||||||
|
// flag_rider_rating, facilitated_type, facilitated_hub_id, status_autoassign, reason_not_waiting,
|
||||||
|
// not_waiting_notes, no_trade_in_reason, delivery_status, source_of_awareness, remarks, initial_concern,
|
||||||
|
// initial_concern_notes, gender, caller_classifications, emergency_type_id, ownership_type_id, cust_location_id
|
||||||
|
}
|
||||||
|
}
|
||||||
Loading…
Reference in a new issue