İlk temizlik tamamlandı bir önceki projeden
This commit is contained in:
Ümit Tunç
@@ -0,0 +1,241 @@
|
||||
<?php
|
||||
|
||||
namespace App\Services\LineListTriggers\Triggers;
|
||||
|
||||
use App\Services\LineListTriggers\Base\BaseLineListTrigger;
|
||||
use App\Models\NdeMatrix;
|
||||
use App\Helpers\TransactionHelper;
|
||||
use Illuminate\Support\Facades\DB;
|
||||
use Illuminate\Support\Facades\Log;
|
||||
|
||||
/**
|
||||
* NDE Matrix Sync Trigger
|
||||
*
|
||||
* Handles NDE Matrix synchronization from WeldLogs and LineList:
|
||||
* - Collects spec joint types from weld_logs
|
||||
* - Creates/updates nde_matrices for each fluid_code + line_no + type_of_welds combination
|
||||
* - Handles PWHT, HT, NDT calculations
|
||||
*/
|
||||
class NdeMatrixSyncTrigger extends BaseLineListTrigger
|
||||
{
|
||||
public function getName(): string
|
||||
{
|
||||
return 'NDE Matrix Sync';
|
||||
}
|
||||
|
||||
public function getDependentFields(): array
|
||||
{
|
||||
return [
|
||||
|
||||
];
|
||||
}
|
||||
|
||||
protected function process($lineListData, $beforeData, array $context): array
|
||||
{
|
||||
// Get fresh weld logs data
|
||||
$weldlogs = db("weld_logs")
|
||||
->where("line_number", $lineListData->line_no)
|
||||
->get();
|
||||
|
||||
// Collect spec joint types from weld logs
|
||||
$specJointTypes = $this->collectSpecJointTypes($weldlogs, $lineListData);
|
||||
|
||||
if(empty($specJointTypes)) {
|
||||
return [
|
||||
'skipped' => true,
|
||||
'reason' => 'no_spec_joint_types_found'
|
||||
];
|
||||
}
|
||||
|
||||
Log::debug('specJointTypes içeriği:', ['specJointTypes' => $specJointTypes]);
|
||||
|
||||
$update = 0;
|
||||
$create = 0;
|
||||
|
||||
// Check if specJointTypes exist for this line list
|
||||
if(!isset($specJointTypes[$lineListData->fluid_code][$lineListData->line_no])) {
|
||||
Log::warning("NDE Matrix işlemi atlandı - specJointTypes bulunamadı", [
|
||||
'line_no' => $lineListData->line_no,
|
||||
'fluid_code' => $lineListData->fluid_code
|
||||
]);
|
||||
return [
|
||||
'skipped' => true,
|
||||
'reason' => 'spec_joint_types_not_found_for_line'
|
||||
];
|
||||
}
|
||||
|
||||
$typeOfJoint = $specJointTypes[$lineListData->fluid_code][$lineListData->line_no];
|
||||
|
||||
// Convert array to collection for chunk processing
|
||||
$jointCollection = collect($typeOfJoint);
|
||||
|
||||
Log::debug("NDE Matrix sync starting with chunk transaction", [
|
||||
'total_joint_types' => $jointCollection->count(),
|
||||
'line_no' => $lineListData->line_no,
|
||||
'fluid_code' => $lineListData->fluid_code
|
||||
]);
|
||||
|
||||
// Process joints in chunks with TransactionHelper
|
||||
TransactionHelper::chunkTransaction(
|
||||
$jointCollection,
|
||||
function ($jointChunk) use ($lineListData, &$update, &$create) {
|
||||
foreach($jointChunk as $jointItem) {
|
||||
$ht = 0;
|
||||
if($lineListData->pwht == "YES") $ht = 100;
|
||||
|
||||
$data = [
|
||||
'design_area' => $lineListData->unit,
|
||||
'fluid' => $lineListData->fluid_code,
|
||||
'line' => $lineListData->line_no,
|
||||
'line_spec' => $lineListData->line_specification,
|
||||
'operation_temp' => $lineListData->working_temperature,
|
||||
'operations_pressure_kg' => $lineListData->working_pressure_mpa,
|
||||
'pipe_material_class' => $lineListData->pipe_material_class,
|
||||
'type_of_joint' => $jointItem,
|
||||
'pwht' => $lineListData->pwht,
|
||||
'pwht_field' => $lineListData->pwht,
|
||||
'ht' => $ht,
|
||||
'ndt' => $lineListData->ndt,
|
||||
'piping_class_according_to_gost' => $lineListData->category,
|
||||
'piping_group' => $lineListData->fluid_group,
|
||||
'rev' => $lineListData->rev,
|
||||
'tracing' => $lineListData->tracing,
|
||||
'tracing_type' => $lineListData->tracing_type,
|
||||
'naks_technology' => $lineListData->naks_technology,
|
||||
];
|
||||
|
||||
// UNIQUE CONSTRAINT: line + type_of_joint + fluid
|
||||
$uniqueKey = [
|
||||
'line' => $lineListData->line_no,
|
||||
'type_of_joint' => $jointItem,
|
||||
'fluid' => $lineListData->fluid_code,
|
||||
];
|
||||
|
||||
// Check if record already exists with deadlock prevention
|
||||
$already = NdeMatrix::where($uniqueKey)
|
||||
->orderBy('id', 'ASC') // Deadlock prevention
|
||||
->first();
|
||||
|
||||
if($already) {
|
||||
unset($data['pwht_field']);
|
||||
|
||||
try {
|
||||
$updateResult = NdeMatrix::where($uniqueKey)
|
||||
->orderBy('id', 'ASC') // Deadlock prevention
|
||||
->update($data);
|
||||
|
||||
Log::debug("NDE Matrix record updated successfully", [
|
||||
'affected_rows' => $updateResult,
|
||||
'line_no' => $lineListData->line_no,
|
||||
'joint_type' => $jointItem,
|
||||
'fluid_code' => $lineListData->fluid_code
|
||||
]);
|
||||
|
||||
$update++;
|
||||
} catch (\Exception $e) {
|
||||
Log::error("NDE Matrix update error", [
|
||||
'line_no' => $lineListData->line_no,
|
||||
'joint_type' => $jointItem,
|
||||
'fluid_code' => $lineListData->fluid_code,
|
||||
'error_message' => $e->getMessage()
|
||||
]);
|
||||
throw $e;
|
||||
}
|
||||
} else {
|
||||
try {
|
||||
$ndeRecord = NdeMatrix::updateOrCreate($uniqueKey, $data);
|
||||
|
||||
$action = $ndeRecord->wasRecentlyCreated ? 'created' : 'updated';
|
||||
|
||||
Log::debug("NDE Matrix record processed successfully", [
|
||||
'record_id' => $ndeRecord->id,
|
||||
'action' => $action,
|
||||
'line_no' => $lineListData->line_no,
|
||||
'joint_type' => $jointItem,
|
||||
'fluid_code' => $lineListData->fluid_code
|
||||
]);
|
||||
|
||||
if($action === 'created') {
|
||||
$create++;
|
||||
} else {
|
||||
$update++;
|
||||
}
|
||||
} catch (\Exception $e) {
|
||||
Log::error("NDE Matrix create/update error", [
|
||||
'line_no' => $lineListData->line_no,
|
||||
'joint_type' => $jointItem,
|
||||
'fluid_code' => $lineListData->fluid_code,
|
||||
'error_message' => $e->getMessage()
|
||||
]);
|
||||
throw $e;
|
||||
}
|
||||
}
|
||||
}
|
||||
return $jointChunk->count();
|
||||
},
|
||||
1, // Chunk size
|
||||
10000 // 10ms delay - sufficient for deadlock prevention
|
||||
);
|
||||
|
||||
Log::info("NDE Matrix sync completed", [
|
||||
'updated' => $update,
|
||||
'created' => $create,
|
||||
'total_affected' => $update + $create
|
||||
]);
|
||||
|
||||
return [
|
||||
'success' => true,
|
||||
'created' => $create,
|
||||
'updated' => $update
|
||||
];
|
||||
}
|
||||
|
||||
/**
|
||||
* Collect spec joint types from weld logs
|
||||
*/
|
||||
protected function collectSpecJointTypes($weldlogs, $lineListData): array
|
||||
{
|
||||
$specJointTypes = [];
|
||||
|
||||
foreach($weldlogs AS $weldlog) {
|
||||
// Update fluid_code if empty
|
||||
if(empty($weldlog->fluid_code) && !empty($lineListData->fluid_code)) {
|
||||
db("weld_logs")
|
||||
->where("id", $weldlog->id)
|
||||
->update([
|
||||
'fluid_code' => $lineListData->fluid_code,
|
||||
'service_category' => $lineListData->category,
|
||||
'fluid_group' => $lineListData->fluid_group,
|
||||
]);
|
||||
|
||||
$weldlog->fluid_code = $lineListData->fluid_code;
|
||||
$weldlog->service_category = $lineListData->category;
|
||||
$weldlog->fluid_group = $lineListData->fluid_group;
|
||||
}
|
||||
|
||||
if(empty($weldlog->fluid_code)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
if(empty($weldlog->line_number)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
if(empty($weldlog->type_of_welds)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
if(!isset($specJointTypes[$weldlog->fluid_code][$weldlog->line_number])) {
|
||||
$specJointTypes[$weldlog->fluid_code][$weldlog->line_number] = [];
|
||||
}
|
||||
|
||||
if(!in_array($weldlog->type_of_welds, $specJointTypes[$weldlog->fluid_code][$weldlog->line_number])) {
|
||||
$specJointTypes[$weldlog->fluid_code][$weldlog->line_number][] = $weldlog->type_of_welds;
|
||||
}
|
||||
}
|
||||
|
||||
return $specJointTypes;
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user