369 lines
15 KiB
PHP
Executable File
369 lines
15 KiB
PHP
Executable File
<?php
|
|
|
|
namespace Modules\M3\Http\Controllers;
|
|
|
|
use Config;
|
|
use Datatables;
|
|
use DB;
|
|
use Excel;
|
|
use Illuminate\Http\Request;
|
|
use Illuminate\Support\Facades\Schema;
|
|
use Modules\M3\Services\SpreadsheetExport;
|
|
use Str;
|
|
|
|
class M3ErrorsDispController extends Controller
|
|
{
|
|
public static function index(Request $request)
|
|
{
|
|
$macpkr = isset($request->macpkr) ? trim($request->macpkr) : '';
|
|
$shsource = isset($request->shsource) ? trim($request->shsource) : '';
|
|
$showerrors = isset($request->showerrors) ? trim($request->showerrors) : 'N';
|
|
$skipdates = isset($request->skipdates) ? trim($request->skipdates) : 'N';
|
|
|
|
// Get users from ICM428M
|
|
$connection = config('m3.connection', 'pgsql');
|
|
$iCM428M = Schema::connection($connection)->hasTable('icm428m')
|
|
? DB::connection($connection)->table('icm428m')->select('R428US', 'R428FIRST', 'R428FAMILY')->get()
|
|
: collect();
|
|
$iCM428MCOL = collect($iCM428M);
|
|
$iCM428MCOL->filter(function ($value) {
|
|
return $value->R428US = trim($value->R428US);
|
|
});
|
|
$iCM428MCOL->filter(function ($value) {
|
|
return $value->R428FIRST = trim($value->R428FIRST);
|
|
});
|
|
$iCM428MCOL->filter(function ($value) {
|
|
return $value->R428FAMILY = trim($value->R428FAMILY);
|
|
});
|
|
|
|
return view('m3::liberty-theme.pages.M3ErrorsDisplay', ['macpkr' => $macpkr, 'shsource' => $shsource, 'showerrors' => $showerrors, 'skipdates' => $skipdates, 'ICM428MCOL' => $iCM428MCOL]);
|
|
}
|
|
|
|
public function datatables(Request $request)
|
|
{
|
|
$this->configureDataTableRuntime();
|
|
$filters = $this->dataTableFilters($request);
|
|
$connection = config('m3.connection', 'pgsql');
|
|
|
|
if (! Schema::connection($connection)->hasTable('icm699m')) {
|
|
return Datatables::of(collect())->addIndexColumn()->make(true);
|
|
}
|
|
|
|
$profile = $this->findM3Profile($connection, $filters['SHUSER']);
|
|
$query = $this->buildM3LogQuery($connection);
|
|
$this->applyM3LogFilters($query, $filters, $profile);
|
|
|
|
return Datatables::of($query)->addIndexColumn()->make(true);
|
|
}
|
|
|
|
private function configureDataTableRuntime(): void
|
|
{
|
|
$timeout = (string) Config::get('arrays.PHPTimeOut');
|
|
ini_set('max_execution_time', $timeout);
|
|
ini_set('max_input_time', $timeout);
|
|
ini_set('default_socket_timeout', $timeout);
|
|
ini_set('memory_limit', '1024M');
|
|
}
|
|
|
|
private function dataTableFilters(Request $request): array
|
|
{
|
|
return [
|
|
'SHMACPKR' => trim((string) $request->input('SHMACPKR', '')),
|
|
'SHSOURCE' => trim((string) $request->input('SHSOURCE', '')),
|
|
'STARTDATE' => trim((string) $request->input('STARTDATE', today()->subDays(1)->format('Y-m-d'))),
|
|
'ENDDATE' => trim((string) $request->input('ENDDATE', today()->format('Y-m-d'))),
|
|
'SHOWERRORS' => trim((string) $request->input('SHOWERRORS', 'N')),
|
|
'SHUSER' => m3User() !== '' ? Str::upper(trim(m3User())) : '',
|
|
'SKIPDATES' => trim((string) $request->input('SKIPDATES', 'N')),
|
|
];
|
|
}
|
|
|
|
private function findM3Profile(string $connection, string $user): ?object
|
|
{
|
|
if ($user === '' || ! Schema::connection($connection)->hasTable('icm428m')) {
|
|
return null;
|
|
}
|
|
|
|
return DB::connection($connection)->table('icm428m')
|
|
->select('R428US', 'R428CO', 'R428WH')
|
|
->where('R428US', $user)
|
|
->first();
|
|
}
|
|
|
|
private function buildM3LogQuery(string $connection)
|
|
{
|
|
$query = DB::connection($connection)->table('icm699m')
|
|
->select('ICM699M.*', DB::raw("ICM699M.SHDT || ' ' || ICM699M.SHTIME AS SHDATETIME"))
|
|
->distinct();
|
|
|
|
if (Schema::connection($connection)->hasTable('icm428m')) {
|
|
$query->addSelect('ICM428M.R428FIRST', 'ICM428M.R428FAMILY')
|
|
->leftJoin('ICM428M', 'ICM699M.SHUSER', '=', 'ICM428M.R428US');
|
|
}
|
|
if (Schema::connection($connection)->hasTable('icm688m1')) {
|
|
$query->addSelect('ICM688M1.A4ONO', 'ICM688M1.A4SHSHNM')
|
|
->leftJoin('ICM688M1', 'ICM699M.SHMACPKR', '=', 'ICM688M1.A4MACPKR');
|
|
}
|
|
if (Schema::connection($connection)->hasTable('icm666m')) {
|
|
$query->addSelect('ICM666M.A1ONO', 'ICM666M.A1SHSHNM')
|
|
->leftJoin('ICM666M', 'ICM699M.SHMACPKR', '=', 'ICM666M.A1DELNO');
|
|
}
|
|
|
|
return $query;
|
|
}
|
|
|
|
private function applyM3LogFilters($query, array $filters, ?object $profile): void
|
|
{
|
|
if ($profile !== null) {
|
|
$query->whereIn('SHCO', [trim((string) ($profile->R428CO ?? '')), ''])
|
|
->whereIn('SHWHS', [trim((string) ($profile->R428WH ?? '')), '']);
|
|
} else {
|
|
$query->whereNull('SHCO')->whereNull('SHWHS');
|
|
}
|
|
|
|
foreach (['SHMACPKR', 'SHSOURCE'] as $field) {
|
|
if ($filters[$field] !== '') {
|
|
$query->where($field, $filters[$field]);
|
|
}
|
|
}
|
|
|
|
$query->where('SHSOURCE', '!=', 'PdfStorageAPI');
|
|
if ($filters['SHMACPKR'] === '' && $filters['SKIPDATES'] === 'N') {
|
|
$query->whereBetween('SHDT', [$filters['STARTDATE'], $filters['ENDDATE']]);
|
|
}
|
|
if ($filters['SHOWERRORS'] === 'Y') {
|
|
$query->where('SHERROR', 'X');
|
|
}
|
|
$query->where('SHTYPE', 'like', '%M3%');
|
|
}
|
|
|
|
public static function update699M(Request $request)
|
|
{
|
|
$sHMACPKR = $request->SHMACPKR != null ? trim($request->SHMACPKR) : '';
|
|
$sHSOURCE = $request->SHSOURCE != null ? trim($request->SHSOURCE) : '';
|
|
$sHCO = $request->SHCO != null ? trim($request->SHCO) : '';
|
|
$sHWHS = $request->SHWHS != null ? trim($request->SHWHS) : '';
|
|
$sHDT = $request->SHDT != null ? trim($request->SHDT) : '';
|
|
$sHTIME = $request->SHTIME != null ? trim($request->SHTIME) : '';
|
|
$sHTYPE = $request->SHTYPE != null ? trim($request->SHTYPE) : '';
|
|
$sHACKNOTE = $request->SHACKNOTE != null ? trim(substr($request->SHACKNOTE, 0, 99)) : '';
|
|
$sHUSER = m3User() !== '' ? Str::upper(m3User()) : '';
|
|
$cLOSESIM = $request->CLOSESIM != null ? trim($request->CLOSESIM) : 'N';
|
|
|
|
if ($cLOSESIM == 'N') {
|
|
DB::connection(config('m3.connection', 'pgsql'))->table('icm699m')
|
|
->where('SHMACPKR', $sHMACPKR)
|
|
->where('SHDT', $sHDT)
|
|
->where('SHTIME', $sHTIME)
|
|
->where('SHCO', $sHCO)
|
|
->where('SHWHS', $sHWHS)
|
|
->where('SHSOURCE', $sHSOURCE)
|
|
->where('SHERROR', 'X')
|
|
->where('SHTYPE', $sHTYPE)
|
|
->update(['SHERROR' => 'Z', 'SHACKUSER' => $sHUSER, 'SHACKDATE' => date('Y-m-d'), 'SHACKTIME' => date('H:i:s'), 'SHACKNOTE' => $sHACKNOTE]);
|
|
|
|
} else {
|
|
DB::connection(config('m3.connection', 'pgsql'))->table('icm699m')
|
|
->where('SHCO', $sHCO)
|
|
->where('SHWHS', $sHWHS)
|
|
->where('SHSOURCE', $sHSOURCE)
|
|
->where('SHERROR', 'X')
|
|
->where('SHTYPE', $sHTYPE)
|
|
->update(['SHERROR' => 'Z', 'SHACKUSER' => $sHUSER, 'SHACKDATE' => date('Y-m-d'), 'SHACKTIME' => date('H:i:s'), 'SHACKNOTE' => $sHACKNOTE]);
|
|
}
|
|
|
|
if ($sHSOURCE == 'CloseShipmentCoChargeAPI') {
|
|
// Update ICM688M1 : Change A4PICKSTS
|
|
DB::connection(config('m3.connection', 'pgsql'))->table('icm688m1')
|
|
->where('A4MACPKR', $sHMACPKR)
|
|
->where('A4CO', $sHCO)
|
|
->where('A4WHS', $sHWHS)
|
|
->update(['A4PICKSTS' => 'a']);
|
|
}
|
|
|
|
return response()->json(['success' => true]);
|
|
}
|
|
|
|
// Export To Excel
|
|
public static function exporttoExcel(Request $request)
|
|
{
|
|
self::configureExportRuntime();
|
|
|
|
try {
|
|
$filters = self::exportFiltersFromRequest($request);
|
|
[$profileUser, $company, $warehouse] = self::exportUserScope($filters['user']);
|
|
$users = self::exportUsers();
|
|
[$query, $countQuery] = self::exportQueries();
|
|
|
|
self::applyExportFilters($query, $countQuery, [
|
|
'profileUser' => $profileUser,
|
|
'company' => $company,
|
|
'warehouse' => $warehouse,
|
|
'manifest' => $filters['manifest'],
|
|
'source' => $filters['source'],
|
|
'startDate' => $filters['startDate'],
|
|
'endDate' => $filters['endDate'],
|
|
'skipDates' => $filters['skipDates'],
|
|
'showErrors' => $filters['showErrors'],
|
|
]);
|
|
|
|
$limitResponse = self::validateExportCount($countQuery->count());
|
|
if ($limitResponse !== null) {
|
|
return $limitResponse;
|
|
}
|
|
|
|
$rows = self::prepareExportRows($query->get(), $users);
|
|
|
|
return app(SpreadsheetExport::class)->download(
|
|
$rows,
|
|
'transactionLog_' . $filters['startDate'] . '-' . $filters['endDate'] . '.xlsx',
|
|
);
|
|
} catch (\Throwable $th) {
|
|
Log::error($th);
|
|
|
|
return redirect()->back()->withInput()->with('message', 'Unable to export the transaction log.');
|
|
}
|
|
}
|
|
|
|
private static function configureExportRuntime(): void
|
|
{
|
|
ini_set('max_execution_time', Config::get('arrays.PHPTimeOut'));
|
|
ini_set('max_input_time', Config::get('arrays.PHPTimeOut'));
|
|
ini_set('default_socket_timeout', Config::get('arrays.PHPTimeOut'));
|
|
ini_set('memory_limit', '1024M');
|
|
}
|
|
|
|
private static function exportFiltersFromRequest(Request $request): array
|
|
{
|
|
return [
|
|
'manifest' => trim((string) $request->input('SHMACPKR', '')),
|
|
'source' => trim((string) $request->input('SHSOURCE', '')),
|
|
'startDate' => trim((string) $request->input('STARTDATE', today()->subDays(1)->format('Y-m-d'))),
|
|
'endDate' => trim((string) $request->input('ENDDATE', today()->format('Y-m-d'))),
|
|
'showErrors' => trim((string) $request->input('SHOWERRORS', 'N')),
|
|
'skipDates' => trim((string) $request->input('SKIPDATES', 'N')),
|
|
'user' => Str::upper(trim(m3User())),
|
|
];
|
|
}
|
|
|
|
private static function exportUserScope(string $user): array
|
|
{
|
|
$profile = DB::connection(config('m3.connection', 'pgsql'))->table('icm428m')
|
|
->select('R428US', 'R428CO', 'R428WH')
|
|
->where('R428US', $user)
|
|
->first();
|
|
|
|
return [
|
|
trim((string) ($profile->R428US ?? '')),
|
|
trim((string) ($profile->R428CO ?? '')),
|
|
trim((string) ($profile->R428WH ?? '')),
|
|
];
|
|
}
|
|
|
|
private static function exportUsers()
|
|
{
|
|
return DB::connection(config('m3.connection', 'pgsql'))->table('icm428m')
|
|
->select('R428US', 'R428FIRST', 'R428FAMILY')
|
|
->get()
|
|
->each(function ($value): void {
|
|
$value->R428US = trim((string) $value->R428US);
|
|
$value->R428FIRST = trim((string) $value->R428FIRST);
|
|
$value->R428FAMILY = trim((string) $value->R428FAMILY);
|
|
});
|
|
}
|
|
|
|
private static function exportQueries(): array
|
|
{
|
|
$query = DB::connection(config('m3.connection', 'pgsql'))->table('icm699m')
|
|
->select(
|
|
DB::raw('COALESCE(ICM688M1.A4ONO, ICM666M.A1ONO) AS DELIVERY_NUM '),
|
|
'ICM699M.SHMACPKR',
|
|
DB::raw('COALESCE(ICM688M1.A4SHSHNM, ICM666M.A1SHSHNM) AS CUSTOMER '),
|
|
DB::raw(" ICM699M.SHDT || ' ' || ICM699M.SHTIME AS SHDATETIME"),
|
|
DB::raw("CASE WHEN ICM699M.SHERROR !='Z' THEN TRIM(ICM699M.SHERROR) ELSE 'Closed' END AS ERROR"),
|
|
'ICM699M.SHTYPE',
|
|
'ICM699M.SHSOURCE',
|
|
DB::raw("CASE WHEN ICM428M.R428FIRST IS NOT NULL THEN TRIM(ICM428M.R428FIRST) ||' '|| TRIM(ICM428M.R428FAMILY) ELSE TRIM(ICM699M.SHUSER) END AS USER"),
|
|
'ICM699M.SHCODE',
|
|
'ICM699M.SHCO',
|
|
'ICM699M.SHWHS',
|
|
DB::raw(" ICM699M.SHACKDATE ||' '||ICM699M.SHACKTIME AS ACKDATE"),
|
|
'ICM699M.SHACKUSER',
|
|
'ICM699M.SHINTBOX',
|
|
'ICM699M.SHACKNOTE',
|
|
DB::raw('SUBSTR(ICM699M.SHDATA, 1, 200)'),
|
|
)
|
|
->distinct()
|
|
->leftJoin('ICM428M', 'ICM699M.SHUSER', '=', 'ICM428M.R428US')
|
|
->leftJoin('ICM688M1', 'ICM699M.SHMACPKR', '=', 'ICM688M1.A4MACPKR')
|
|
->leftJoin('ICM666M', 'ICM699M.SHMACPKR', '=', 'ICM666M.A1DELNO');
|
|
|
|
return [$query, DB::connection(config('m3.connection', 'pgsql'))->table('icm699m')];
|
|
}
|
|
|
|
private static function validateExportCount(int $count)
|
|
{
|
|
$maxRecords = (int) Config::get('arrays.maxRecDL');
|
|
if ($count <= $maxRecords) {
|
|
return null;
|
|
}
|
|
|
|
return redirect()->back()->withInput()->with(
|
|
'message',
|
|
'Maximum allowed records for Excel Download is: ' . number_format($maxRecords)
|
|
. ' current records: ' . number_format($count) . ' , change your search criteria.',
|
|
);
|
|
}
|
|
|
|
private static function prepareExportRows($records, $users)
|
|
{
|
|
$transactionTypes = Config::get('arrays.transxTypes');
|
|
$rows = collect($records)->each(function ($value) use ($transactionTypes, $users): void {
|
|
$source = trim((string) $value->SHSOURCE);
|
|
$value->SHSOURCE = $transactionTypes[$source] ?? $source;
|
|
$user = $users->firstWhere('R428US', trim((string) $value->SHACKUSER));
|
|
$value->SHACKUSER = $user
|
|
? trim($user->R428FIRST . ' ' . $user->R428FAMILY)
|
|
: trim((string) $value->SHACKUSER);
|
|
});
|
|
|
|
$rows->prepend([
|
|
'SHMACPKR' => 'Delivery Note', 'DELIVERY_NUM' => 'Order #', 'CUSTOMER' => 'Customer',
|
|
'SHDATETIME' => 'Date', 'ERROR' => 'Error', 'SHTYPE' => 'Request Type',
|
|
'SHSOURCE' => 'Source of transaction', 'USER' => 'User', 'SHCODE' => 'Request or Response Data',
|
|
'SHCO' => 'Division', 'SHWHS' => 'Warehouse', 'ACKDATE' => 'Acknowledge/Retry Date',
|
|
'SHACKUSER' => 'Acknowledged/Retried by User', 'SHINTBOX' => 'Internal Box Number',
|
|
'SHACKNOTE' => 'Note', 'SHDATA' => 'Error description',
|
|
]);
|
|
|
|
return $rows;
|
|
}
|
|
|
|
private static function applyExportFilters($query, $countQuery, array $filters): void
|
|
{
|
|
$queries = [$query, $countQuery];
|
|
foreach ($queries as $builder) {
|
|
if ($filters['profileUser'] !== '') {
|
|
$builder->whereIn('SHCO', [$filters['company'], ''])->whereIn('SHWHS', [$filters['warehouse'], '']);
|
|
} else {
|
|
$builder->whereNull('SHCO')->whereNull('SHWHS');
|
|
}
|
|
|
|
if ($filters['manifest'] !== '') {
|
|
$builder->where('SHMACPKR', $filters['manifest']);
|
|
}
|
|
if ($filters['source'] !== '') {
|
|
$builder->where('SHSOURCE', $filters['source']);
|
|
}
|
|
$builder->where('SHSOURCE', '!=', 'PdfStorageAPI');
|
|
if ($filters['manifest'] === '' && $filters['skipDates'] === 'N') {
|
|
$builder->whereBetween('SHDT', [$filters['startDate'], $filters['endDate']]);
|
|
}
|
|
if ($filters['showErrors'] === 'Y') {
|
|
$builder->where('SHERROR', 'X');
|
|
}
|
|
$builder->where('SHTYPE', 'like', '%M3%');
|
|
}
|
|
}
|
|
}
|