Ümit Tunç
759 lines
29 KiB
PHP
759 lines
29 KiB
PHP
<?php
|
|
|
|
namespace App\Services\WeldLogTriggers\Triggers;
|
|
|
|
use App\Services\WeldLogTriggers\Base\BaseTrigger;
|
|
use App\Models\PaintMatrix;
|
|
use App\Helpers\TransactionHelper;
|
|
use Illuminate\Support\Facades\Log;
|
|
use Carbon\Carbon;
|
|
|
|
/**
|
|
* Paint Follow Ups Sync Trigger
|
|
*
|
|
* Mirrors the LineList trigger logic while running during WeldLog saves:
|
|
* - Requires matching Line List + painting cycle
|
|
* - Generates SHOP + FIELD entries with temperature/volume data
|
|
* - Protects finished records, manages cycle changes, cleans up orphans
|
|
*/
|
|
class PaintFollowUpsSyncTrigger extends BaseTrigger
|
|
{
|
|
public function getName(): string
|
|
{
|
|
return 'Paint Follow Ups Sync';
|
|
}
|
|
|
|
public function getOrder(): int
|
|
{
|
|
return 11;
|
|
}
|
|
|
|
public function getDependentFields(): array
|
|
{
|
|
return [
|
|
'line_number',
|
|
'spool_number',
|
|
'no_of_the_joint_as_per_as_built_survey',
|
|
'fluid_code',
|
|
'iso_number',
|
|
'project',
|
|
'design_area',
|
|
'type_of_joint'
|
|
];
|
|
}
|
|
|
|
protected function process($data, $beforeData, array $context): array
|
|
{
|
|
$paintFollowUpCreated = 0;
|
|
$paintFollowUpUpdated = 0;
|
|
$deletedOrphanedCount = 0;
|
|
$finalCleanupCount = 0;
|
|
|
|
try {
|
|
$weldLog = db("weld_logs")->where("id", $data->id)->first();
|
|
|
|
if (!$weldLog) {
|
|
return ['success' => false, 'reason' => 'weld_log_not_found'];
|
|
}
|
|
|
|
if (empty($weldLog->line_number)) {
|
|
return ['success' => false, 'reason' => 'line_number_empty'];
|
|
}
|
|
|
|
$lineList = db("line_lists")
|
|
->where('line_no', $weldLog->line_number)
|
|
->first();
|
|
|
|
if (!$lineList) {
|
|
return ['success' => false, 'reason' => 'line_list_not_found'];
|
|
}
|
|
|
|
if (empty($lineList->painting_cycle)) {
|
|
return ['skipped' => true, 'reason' => 'painting_cycle_empty'];
|
|
}
|
|
|
|
$matchingWeldLogExists = db("weld_logs")
|
|
->where("line_number", $lineList->line_no)
|
|
->where("design_area", $lineList->unit)
|
|
->where("fluid_code", $lineList->fluid_code)
|
|
->exists();
|
|
|
|
if (!$matchingWeldLogExists) {
|
|
return ['skipped' => true, 'reason' => 'no_matching_weld_log'];
|
|
}
|
|
|
|
$deletedOrphanedCount = $this->cleanupOrphanedRecords($weldLog, $beforeData);
|
|
|
|
$resultFields = [
|
|
'vt_result',
|
|
'rt_result',
|
|
'ut_result',
|
|
'pt_result',
|
|
'mt_result',
|
|
'pmi_result',
|
|
'ht_result',
|
|
'ferrite_result'
|
|
];
|
|
|
|
$allWeldLogs = db("weld_logs")
|
|
->where("line_number", $lineList->line_no)
|
|
->where("design_area", $lineList->unit)
|
|
->where("fluid_code", $lineList->fluid_code)
|
|
->where(function ($query) {
|
|
$query->where("no_of_the_joint_as_per_as_built_survey", "not like", "%clone%");
|
|
})
|
|
->where(function ($query) use ($resultFields) {
|
|
foreach ($resultFields as $field) {
|
|
$query->where(function ($subQuery) use ($field) {
|
|
$subQuery->whereNull($field)
|
|
->orWhere($field, '')
|
|
->orWhere($field, 'Accept / Годен');
|
|
});
|
|
}
|
|
})
|
|
->orderBy('id', 'ASC')
|
|
->get();
|
|
|
|
if ($allWeldLogs->isEmpty()) {
|
|
return ['skipped' => true, 'reason' => 'no_weld_logs_for_line'];
|
|
}
|
|
|
|
$paintMatrix = PaintMatrix::where('line', $lineList->line_no)
|
|
->where('fluid_code', $lineList->fluid_code)
|
|
->where('area', $lineList->unit)
|
|
->where('paint_cycle', $lineList->painting_cycle)
|
|
->first();
|
|
|
|
if (!$paintMatrix) {
|
|
$paintMatrix = PaintMatrix::create([
|
|
'project' => $allWeldLogs->first()->project ?? '',
|
|
'area' => $lineList->unit,
|
|
'description' => "PIPE",
|
|
'line' => $lineList->line_no,
|
|
'fluid_code_description' => $lineList->fluid_ru,
|
|
'fluid_code' => $lineList->fluid_code,
|
|
'paint_cycle' => $lineList->painting_cycle,
|
|
'created_at' => now(),
|
|
'updated_at' => now()
|
|
]);
|
|
}
|
|
|
|
$temperatures = j(setting("temperatures"));
|
|
$todayTempData = null;
|
|
|
|
$blastingDateRecord = db('construction_paint_logs')
|
|
->where('line', $lineList->line_no)
|
|
->whereNotNull('blasting_date')
|
|
->first();
|
|
|
|
if (!is_null($temperatures) && $blastingDateRecord && !empty($blastingDateRecord->blasting_date)) {
|
|
$blastingDate = Carbon::parse($blastingDateRecord->blasting_date);
|
|
$dayOfYear = $blastingDate->format('z');
|
|
$todayTempData = $temperatures[$dayOfYear] ?? null;
|
|
}
|
|
|
|
$fAvgNps = $allWeldLogs->where("type_of_joint", "F")->avg("nps_1");
|
|
$sAvgNps = $allWeldLogs->where("type_of_joint", "S")->avg("nps_1");
|
|
|
|
$mtoTotal = db("m_t_o_s")
|
|
->where("description_en", "like", "%pipe%")
|
|
->where("line", $lineList->line_no)
|
|
->selectRaw("SUM(quantity * POWER(odmm_1/2000, 2) * PI()) AS total")
|
|
->first()->total ?? 0;
|
|
|
|
$fVolume = round(pi() * pow($fAvgNps, 2) * 200, 2);
|
|
$sVolume = round($mtoTotal, 2);
|
|
|
|
$processedPaintFollowUpIds = [];
|
|
$processedShopSpools = [];
|
|
$replacedJointNumbers = $this->determineReplacedJointNumbers($allWeldLogs);
|
|
|
|
TransactionHelper::chunkTransaction(
|
|
$allWeldLogs,
|
|
function ($paintWeldLogChunk) use (
|
|
$lineList,
|
|
$paintMatrix,
|
|
$todayTempData,
|
|
$fVolume,
|
|
$sVolume,
|
|
&$paintFollowUpCreated,
|
|
&$paintFollowUpUpdated,
|
|
&$processedPaintFollowUpIds,
|
|
&$processedShopSpools,
|
|
$replacedJointNumbers
|
|
) {
|
|
foreach ($paintWeldLogChunk as $currentWeldLog) {
|
|
if (empty($currentWeldLog->fluid_code)) {
|
|
continue;
|
|
}
|
|
|
|
if ($this->shouldSkipJoint($currentWeldLog, $replacedJointNumbers)) {
|
|
continue;
|
|
}
|
|
|
|
$basePaintFollowUpData = [
|
|
'project' => $currentWeldLog->project ?? '',
|
|
'description' => "PIPE",
|
|
'area' => $lineList->unit ?? '',
|
|
'line' => $lineList->line_no,
|
|
'iso_number' => $currentWeldLog->iso_number ?? '',
|
|
'fluid_code' => $lineList->fluid_code,
|
|
'fluid_code_description' => $lineList->fluid_ru ?? '',
|
|
'cycle' => $lineList->painting_cycle ?? '',
|
|
'primer_coat_name_1' => $paintMatrix->primer_coat ?? '',
|
|
'brend_name_1' => $paintMatrix->brend_name_1 ?? '',
|
|
'colour_1' => $paintMatrix->colour_1 ?? '',
|
|
'ral_code_1' => $paintMatrix->ral_code_1 ?? '',
|
|
'thickness_1' => $paintMatrix->thickness_1 ?? '',
|
|
'intermediate_coat_name_2' => $paintMatrix->intermediate_coat ?? '',
|
|
'brend_name_2' => $paintMatrix->brend_name_2 ?? '',
|
|
'colour_2' => $paintMatrix->colour_2 ?? '',
|
|
'ral_code_2' => $paintMatrix->ral_code_2 ?? '',
|
|
'thickness_2' => $paintMatrix->thickness_2 ?? '',
|
|
'final_coat_name_3' => $paintMatrix->final_coat ?? '',
|
|
'brend_name_3' => $paintMatrix->brend_name_3 ?? '',
|
|
'colour_3' => $paintMatrix->colour_3 ?? '',
|
|
'ral_code_3' => $paintMatrix->ral_code_3 ?? '',
|
|
'thickness_3' => $paintMatrix->thickness_3 ?? '',
|
|
'status' => 'In Progress',
|
|
'updated_at' => now()
|
|
];
|
|
|
|
$result = $this->processShopRecord(
|
|
$lineList,
|
|
$currentWeldLog,
|
|
$basePaintFollowUpData,
|
|
$paintMatrix,
|
|
$todayTempData,
|
|
$sVolume,
|
|
$paintFollowUpCreated,
|
|
$paintFollowUpUpdated,
|
|
$processedShopSpools
|
|
);
|
|
$paintFollowUpCreated = $result['created'];
|
|
$paintFollowUpUpdated = $result['updated'];
|
|
$processedShopSpools = $result['processed_spools'];
|
|
|
|
$fieldResult = $this->processFieldRecord(
|
|
$lineList,
|
|
$currentWeldLog,
|
|
$basePaintFollowUpData,
|
|
$paintMatrix,
|
|
$todayTempData,
|
|
$fVolume,
|
|
$paintFollowUpCreated,
|
|
$paintFollowUpUpdated,
|
|
$processedPaintFollowUpIds
|
|
);
|
|
$paintFollowUpCreated = $fieldResult['created'];
|
|
$paintFollowUpUpdated = $fieldResult['updated'];
|
|
$processedPaintFollowUpIds = $fieldResult['processed_ids'];
|
|
}
|
|
return $paintWeldLogChunk->count();
|
|
},
|
|
1,
|
|
10000
|
|
);
|
|
|
|
$finalCleanupCount = $this->cleanupNonMatchingRecords($lineList->line_no);
|
|
|
|
} catch (\Throwable $th) {
|
|
Log::error("Paint Follow Ups sync error: " . $th->getMessage(), [
|
|
'weld_log_id' => $data->id
|
|
]);
|
|
throw $th;
|
|
}
|
|
|
|
return [
|
|
'success' => true,
|
|
'created' => $paintFollowUpCreated,
|
|
'updated' => $paintFollowUpUpdated,
|
|
'deleted_orphaned' => $deletedOrphanedCount,
|
|
'deleted_final_cleanup' => $finalCleanupCount
|
|
];
|
|
}
|
|
|
|
protected function processShopRecord(
|
|
$lineList,
|
|
$weldLog,
|
|
$basePaintFollowUpData,
|
|
$paintMatrix,
|
|
$todayTempData,
|
|
$sVolume,
|
|
$paintFollowUpCreated,
|
|
$paintFollowUpUpdated,
|
|
$processedShopSpools
|
|
): array {
|
|
$hasShopJoint = db("weld_logs")
|
|
->where('line_number', $lineList->line_no)
|
|
->where('spool_number', $weldLog->spool_number)
|
|
->where('type_of_joint', 'S')
|
|
->exists();
|
|
|
|
if (!$hasShopJoint || empty($weldLog->spool_number)) {
|
|
return [
|
|
'created' => $paintFollowUpCreated,
|
|
'updated' => $paintFollowUpUpdated,
|
|
'processed_spools' => $processedShopSpools
|
|
];
|
|
}
|
|
|
|
if (in_array($weldLog->spool_number, $processedShopSpools, true)) {
|
|
return [
|
|
'created' => $paintFollowUpCreated,
|
|
'updated' => $paintFollowUpUpdated,
|
|
'processed_spools' => $processedShopSpools
|
|
];
|
|
}
|
|
|
|
$processedShopSpools[] = $weldLog->spool_number;
|
|
|
|
$shopData = $basePaintFollowUpData;
|
|
$shopData['location'] = 'SHOP';
|
|
$shopData['spool_no_joint_no'] = $weldLog->spool_number;
|
|
$shopData['surface_roughness'] = $paintMatrix->surface_preparation ?? '';
|
|
|
|
if ($todayTempData) {
|
|
$shopData['substrate_temprature'] = $todayTempData['temp_material_shop'] ?? null;
|
|
$shopData['ambient_temprature'] = $todayTempData['shop_ambient'] ?? null;
|
|
}
|
|
$shopData['volume_1'] = $sVolume;
|
|
$shopData['volume_2'] = $sVolume;
|
|
$shopData['volume_3'] = $sVolume;
|
|
$shopData['total_volume'] = $sVolume * 3;
|
|
|
|
$shopUniqueConstraintCondition = [
|
|
'line' => $lineList->line_no,
|
|
'spool_no_joint_no' => $weldLog->spool_number,
|
|
'cycle' => $lineList->painting_cycle,
|
|
'location' => 'SHOP'
|
|
];
|
|
|
|
$shopWhereCondition = [
|
|
'line' => $lineList->line_no,
|
|
'spool_no_joint_no' => $weldLog->spool_number,
|
|
'location' => 'SHOP'
|
|
];
|
|
|
|
$existingShopRecord = db("paint_follow_ups")
|
|
->where($shopUniqueConstraintCondition)
|
|
->first();
|
|
|
|
$recordsWithDifferentPaintCycle = db("paint_follow_ups")
|
|
->where($shopWhereCondition)
|
|
->where('cycle', '!=', $lineList->painting_cycle)
|
|
->get();
|
|
|
|
if ($existingShopRecord) {
|
|
$hasAllEmptyDates = $this->hasAllEmptyDates($existingShopRecord);
|
|
|
|
if ($hasAllEmptyDates) {
|
|
db("paint_follow_ups")
|
|
->where('id', $existingShopRecord->id)
|
|
->update($shopData);
|
|
$paintFollowUpUpdated++;
|
|
} else {
|
|
$tempVolumeData = $this->getTempVolumeUpdateData(
|
|
$existingShopRecord,
|
|
$todayTempData,
|
|
$sVolume,
|
|
'SHOP'
|
|
);
|
|
|
|
if (!empty($tempVolumeData)) {
|
|
db("paint_follow_ups")
|
|
->where('id', $existingShopRecord->id)
|
|
->update($tempVolumeData);
|
|
}
|
|
}
|
|
} else {
|
|
if ($recordsWithDifferentPaintCycle->count() > 0) {
|
|
foreach ($recordsWithDifferentPaintCycle as $oldRecord) {
|
|
$hasAnyDateFilled = !$this->hasAllEmptyDates($oldRecord);
|
|
|
|
if ($hasAnyDateFilled) {
|
|
db("paint_follow_ups")
|
|
->where('id', $oldRecord->id)
|
|
->update([
|
|
'status' => 'HOLD',
|
|
'updated_at' => now()
|
|
]);
|
|
} else {
|
|
db("paint_follow_ups")
|
|
->where('id', $oldRecord->id)
|
|
->update([
|
|
'cycle' => $lineList->painting_cycle,
|
|
'updated_at' => now()
|
|
]);
|
|
$paintFollowUpUpdated++;
|
|
return [
|
|
'created' => $paintFollowUpCreated,
|
|
'updated' => $paintFollowUpUpdated,
|
|
'processed_spools' => $processedShopSpools
|
|
];
|
|
}
|
|
}
|
|
}
|
|
|
|
$shopData['primer_coating_start_date'] = null;
|
|
$shopData['primer_coating_finish_date'] = null;
|
|
$shopData['start_intermediate_date2'] = null;
|
|
$shopData['finish_intermediate_date2'] = null;
|
|
$shopData['final_coat_start_date3'] = null;
|
|
$shopData['final_coat_finish_date3'] = null;
|
|
$shopData['created_at'] = now();
|
|
$shopData['updated_at'] = now();
|
|
|
|
db("paint_follow_ups")->insert($shopData);
|
|
$paintFollowUpCreated++;
|
|
}
|
|
|
|
return [
|
|
'created' => $paintFollowUpCreated,
|
|
'updated' => $paintFollowUpUpdated,
|
|
'processed_spools' => $processedShopSpools
|
|
];
|
|
}
|
|
|
|
protected function processFieldRecord(
|
|
$lineList,
|
|
$weldLog,
|
|
$basePaintFollowUpData,
|
|
$paintMatrix,
|
|
$todayTempData,
|
|
$fVolume,
|
|
$paintFollowUpCreated,
|
|
$paintFollowUpUpdated,
|
|
$processedPaintFollowUpIds
|
|
): array {
|
|
if (empty($weldLog->no_of_the_joint_as_per_as_built_survey)) {
|
|
return [
|
|
'created' => $paintFollowUpCreated,
|
|
'updated' => $paintFollowUpUpdated,
|
|
'processed_ids' => $processedPaintFollowUpIds
|
|
];
|
|
}
|
|
|
|
$jointNo = $weldLog->no_of_the_joint_as_per_as_built_survey;
|
|
|
|
$fieldData = $basePaintFollowUpData;
|
|
$fieldData['location'] = 'FIELD';
|
|
$fieldData['spool_no_joint_no'] = $jointNo;
|
|
$fieldData['surface_roughness'] = $paintMatrix->touch_up_of_damaged_parts ?? '';
|
|
|
|
if ($todayTempData) {
|
|
$fieldData['substrate_temprature'] = $todayTempData['temp_material_field'] ?? null;
|
|
$fieldData['ambient_temprature'] = $todayTempData['field_ambient'] ?? null;
|
|
}
|
|
$fieldData['volume_1'] = $fVolume;
|
|
$fieldData['volume_2'] = $fVolume;
|
|
$fieldData['volume_3'] = $fVolume;
|
|
$fieldData['total_volume'] = $fVolume * 3;
|
|
|
|
$fieldUniqueConstraintCondition = [
|
|
'line' => $lineList->line_no,
|
|
'spool_no_joint_no' => $jointNo,
|
|
'cycle' => $lineList->painting_cycle,
|
|
'location' => 'FIELD'
|
|
];
|
|
|
|
$fieldWhereCondition = [
|
|
'line' => $lineList->line_no,
|
|
'spool_no_joint_no' => $jointNo,
|
|
'location' => 'FIELD'
|
|
];
|
|
|
|
$existingFieldRecord = db("paint_follow_ups")
|
|
->where($fieldUniqueConstraintCondition)
|
|
->first();
|
|
|
|
$recordsWithDifferentPaintCycle = db("paint_follow_ups")
|
|
->where($fieldWhereCondition)
|
|
->where('cycle', '!=', $lineList->painting_cycle)
|
|
->get();
|
|
|
|
if ($existingFieldRecord) {
|
|
if (in_array($existingFieldRecord->id, $processedPaintFollowUpIds)) {
|
|
return [
|
|
'created' => $paintFollowUpCreated,
|
|
'updated' => $paintFollowUpUpdated,
|
|
'processed_ids' => $processedPaintFollowUpIds
|
|
];
|
|
}
|
|
|
|
$processedPaintFollowUpIds[] = $existingFieldRecord->id;
|
|
|
|
$hasAllEmptyDates = $this->hasAllEmptyDates($existingFieldRecord);
|
|
|
|
if ($hasAllEmptyDates) {
|
|
db("paint_follow_ups")
|
|
->where('id', $existingFieldRecord->id)
|
|
->update($fieldData);
|
|
$paintFollowUpUpdated++;
|
|
} else {
|
|
$tempVolumeData = $this->getTempVolumeUpdateData(
|
|
$existingFieldRecord,
|
|
$todayTempData,
|
|
$fVolume,
|
|
'FIELD'
|
|
);
|
|
|
|
if (!empty($tempVolumeData)) {
|
|
db("paint_follow_ups")
|
|
->where('id', $existingFieldRecord->id)
|
|
->update($tempVolumeData);
|
|
}
|
|
}
|
|
} else {
|
|
if ($recordsWithDifferentPaintCycle->count() > 0) {
|
|
foreach ($recordsWithDifferentPaintCycle as $oldRecord) {
|
|
$hasAnyDateFilled = !$this->hasAllEmptyDates($oldRecord);
|
|
|
|
if ($hasAnyDateFilled) {
|
|
db("paint_follow_ups")
|
|
->where('id', $oldRecord->id)
|
|
->update([
|
|
'status' => 'HOLD',
|
|
'updated_at' => now()
|
|
]);
|
|
} else {
|
|
db("paint_follow_ups")
|
|
->where('id', $oldRecord->id)
|
|
->update([
|
|
'cycle' => $lineList->painting_cycle,
|
|
'updated_at' => now()
|
|
]);
|
|
$paintFollowUpUpdated++;
|
|
return [
|
|
'created' => $paintFollowUpCreated,
|
|
'updated' => $paintFollowUpUpdated,
|
|
'processed_ids' => $processedPaintFollowUpIds
|
|
];
|
|
}
|
|
}
|
|
}
|
|
|
|
$fieldData['primer_coating_start_date'] = null;
|
|
$fieldData['primer_coating_finish_date'] = null;
|
|
$fieldData['start_intermediate_date2'] = null;
|
|
$fieldData['finish_intermediate_date2'] = null;
|
|
$fieldData['final_coat_start_date3'] = null;
|
|
$fieldData['final_coat_finish_date3'] = null;
|
|
$fieldData['created_at'] = now();
|
|
$fieldData['updated_at'] = now();
|
|
|
|
db("paint_follow_ups")->insert($fieldData);
|
|
$paintFollowUpCreated++;
|
|
}
|
|
|
|
return [
|
|
'created' => $paintFollowUpCreated,
|
|
'updated' => $paintFollowUpUpdated,
|
|
'processed_ids' => $processedPaintFollowUpIds
|
|
];
|
|
}
|
|
|
|
protected function cleanupOrphanedRecords($weldLog, $beforeData): int
|
|
{
|
|
if (!$beforeData) {
|
|
return 0;
|
|
}
|
|
|
|
$deletedCount = 0;
|
|
|
|
try {
|
|
if (isset($beforeData->no_of_the_joint_as_per_as_built_survey) &&
|
|
$beforeData->no_of_the_joint_as_per_as_built_survey != $weldLog->no_of_the_joint_as_per_as_built_survey &&
|
|
!empty($beforeData->no_of_the_joint_as_per_as_built_survey)) {
|
|
|
|
$oldJointNo = $beforeData->no_of_the_joint_as_per_as_built_survey;
|
|
|
|
$deleted = db("paint_follow_ups")
|
|
->where('line', $weldLog->line_number)
|
|
->where('spool_no_joint_no', $oldJointNo)
|
|
->where('location', 'FIELD')
|
|
->delete();
|
|
|
|
$deletedCount += $deleted;
|
|
}
|
|
|
|
if (isset($beforeData->spool_number) &&
|
|
$beforeData->spool_number != $weldLog->spool_number &&
|
|
!empty($beforeData->spool_number)) {
|
|
|
|
$oldSpoolNumber = $beforeData->spool_number;
|
|
|
|
$deleted = db("paint_follow_ups")
|
|
->where('line', $weldLog->line_number)
|
|
->where('spool_no_joint_no', $oldSpoolNumber)
|
|
->where('location', 'SHOP')
|
|
->delete();
|
|
|
|
$deletedCount += $deleted;
|
|
}
|
|
|
|
} catch (\Throwable $th) {
|
|
Log::warning("Failed to cleanup orphaned records", [
|
|
'error' => $th->getMessage(),
|
|
'weld_log_id' => $weldLog->id
|
|
]);
|
|
}
|
|
|
|
return $deletedCount;
|
|
}
|
|
|
|
protected function cleanupNonMatchingRecords(string $lineNumber): int
|
|
{
|
|
$deletedCount = 0;
|
|
|
|
try {
|
|
$validFieldJointNos = db("weld_logs")
|
|
->where("line_number", $lineNumber)
|
|
->whereNotNull("no_of_the_joint_as_per_as_built_survey")
|
|
->where("no_of_the_joint_as_per_as_built_survey", "!=", "")
|
|
->pluck("no_of_the_joint_as_per_as_built_survey")
|
|
->toArray();
|
|
|
|
$validShopSpoolNos = db("weld_logs")
|
|
->where("line_number", $lineNumber)
|
|
->where("type_of_joint", "S")
|
|
->whereNotNull("spool_number")
|
|
->where("spool_number", "!=", "")
|
|
->pluck("spool_number")
|
|
->toArray();
|
|
|
|
if (!empty($validFieldJointNos)) {
|
|
$deletedField = db("paint_follow_ups")
|
|
->where('line', $lineNumber)
|
|
->where('location', 'FIELD')
|
|
->whereNotIn('spool_no_joint_no', $validFieldJointNos)
|
|
->delete();
|
|
|
|
$deletedCount += $deletedField;
|
|
} else {
|
|
$deletedField = db("paint_follow_ups")
|
|
->where('line', $lineNumber)
|
|
->where('location', 'FIELD')
|
|
->delete();
|
|
|
|
$deletedCount += $deletedField;
|
|
}
|
|
|
|
if (!empty($validShopSpoolNos)) {
|
|
$deletedShop = db("paint_follow_ups")
|
|
->where('line', $lineNumber)
|
|
->where('location', 'SHOP')
|
|
->whereNotIn('spool_no_joint_no', $validShopSpoolNos)
|
|
->delete();
|
|
|
|
$deletedCount += $deletedShop;
|
|
} else {
|
|
$deletedShop = db("paint_follow_ups")
|
|
->where('line', $lineNumber)
|
|
->where('location', 'SHOP')
|
|
->delete();
|
|
|
|
$deletedCount += $deletedShop;
|
|
}
|
|
|
|
} catch (\Throwable $th) {
|
|
Log::warning("Failed to cleanup non-matching records", [
|
|
'error' => $th->getMessage(),
|
|
'line_number' => $lineNumber
|
|
]);
|
|
}
|
|
|
|
return $deletedCount;
|
|
}
|
|
|
|
protected function hasAllEmptyDates($record): bool
|
|
{
|
|
return empty($record->primer_coating_start_date) &&
|
|
empty($record->primer_coating_finish_date) &&
|
|
empty($record->start_intermediate_date2) &&
|
|
empty($record->finish_intermediate_date2) &&
|
|
empty($record->final_coat_start_date3) &&
|
|
empty($record->final_coat_finish_date3);
|
|
}
|
|
|
|
protected function getTempVolumeUpdateData($record, $todayTempData, $volume, $location): array
|
|
{
|
|
$updateData = [];
|
|
|
|
if ($todayTempData) {
|
|
$tempField = $location === 'SHOP' ? 'temp_material_shop' : 'temp_material_field';
|
|
$ambientField = $location === 'SHOP' ? 'shop_ambient' : 'field_ambient';
|
|
|
|
if (empty($record->substrate_temprature) && isset($todayTempData[$tempField])) {
|
|
$updateData['substrate_temprature'] = $todayTempData[$tempField];
|
|
}
|
|
if (empty($record->ambient_temprature) && isset($todayTempData[$ambientField])) {
|
|
$updateData['ambient_temprature'] = $todayTempData[$ambientField];
|
|
}
|
|
}
|
|
|
|
if (empty($record->volume_1)) {
|
|
$updateData['volume_1'] = $volume;
|
|
}
|
|
if (empty($record->volume_2)) {
|
|
$updateData['volume_2'] = $volume;
|
|
}
|
|
if (empty($record->volume_3)) {
|
|
$updateData['volume_3'] = $volume;
|
|
}
|
|
if (empty($record->total_volume)) {
|
|
$updateData['total_volume'] = $volume * 3;
|
|
}
|
|
|
|
return $updateData;
|
|
}
|
|
|
|
protected function determineReplacedJointNumbers($weldLogs): array
|
|
{
|
|
$toSkip = [];
|
|
|
|
foreach ($weldLogs as $log) {
|
|
$jointNo = $log->no_of_the_joint_as_per_as_built_survey;
|
|
if ($this->isRepairJoint($jointNo)) {
|
|
$baseJoint = $this->stripRepairSuffix($jointNo);
|
|
if (!empty($baseJoint)) {
|
|
$toSkip[] = $baseJoint;
|
|
}
|
|
}
|
|
}
|
|
|
|
return array_unique($toSkip);
|
|
}
|
|
|
|
protected function shouldSkipJoint($weldLog, array $replacedJointNumbers): bool
|
|
{
|
|
$jointNo = $weldLog->no_of_the_joint_as_per_as_built_survey;
|
|
|
|
if (empty($jointNo)) {
|
|
return false;
|
|
}
|
|
|
|
return in_array($jointNo, $replacedJointNumbers, true);
|
|
}
|
|
|
|
protected function isRepairJoint(?string $jointNo): bool
|
|
{
|
|
return !empty($jointNo) && strpos($jointNo, 'R') !== false;
|
|
}
|
|
|
|
protected function stripRepairSuffix(?string $jointNo): ?string
|
|
{
|
|
if (empty($jointNo)) {
|
|
return $jointNo;
|
|
}
|
|
|
|
$pos = strpos($jointNo, 'R');
|
|
if ($pos === false) {
|
|
return $jointNo;
|
|
}
|
|
|
|
return substr($jointNo, 0, $pos);
|
|
}
|
|
}
|
|
|