Ümit Tunç
135 lines
4.8 KiB
PHP
135 lines
4.8 KiB
PHP
<?php
|
||
|
||
$table = "incoming_controls";
|
||
$certificatePath = "002_Project_Materials/002_Material Certificate";
|
||
$aktPath = "002_Project_Materials/001_Material Akt";
|
||
$emailTqPath = "002_Project_Materials/005_Material_Agreement";
|
||
$osdPath = "002_Project_Materials/006_Defect_Documents";
|
||
$nullDownload = db($table);
|
||
|
||
if(isset($fileName)) {
|
||
$fileName = str_replace(".pdf", "", $fileName);
|
||
$nullDownload = $nullDownload->where(function ($query) use ($fileName) {
|
||
$query->where("certificate_no", $fileName)
|
||
->orWhere("akt_number", $fileName)
|
||
->orWhere("email_tq_number", $fileName)
|
||
->orWhere("osd_report_no", $fileName);
|
||
});
|
||
$commitSize = 1;
|
||
}
|
||
$nullDownload = $nullDownload->get();
|
||
|
||
DB::beginTransaction();
|
||
$commitSize = 100; // Commit her 100 kayıtta bir yapılacak
|
||
$say = 0;
|
||
$kCertificate = 0;
|
||
$kAkt = 0;
|
||
$kEmailTq = 0;
|
||
$kOsd = 0;
|
||
|
||
Log::debug("📄$table PDF Link to DB Start " . simdi());
|
||
try {
|
||
foreach($nullDownload AS $ne) {
|
||
$updateData = [];
|
||
$updateData['certificate_file'] = null;
|
||
$updateData['akt_file'] = null;
|
||
$updateData['email_tq_file'] = null;
|
||
$updateData['osd_defect_akt_file'] = null;
|
||
|
||
// Certificate File işlemi
|
||
if(!empty($ne->certificate_no)) {
|
||
|
||
|
||
$certificateNo = trim($ne->certificate_no);
|
||
$certificateNo = str_replace("/", "*", $certificateNo);
|
||
$certificateNo = str_replace(" ", "*", $certificateNo);
|
||
|
||
if(trim($certificateNo) != "") {
|
||
$path = "storage/documents/$certificatePath/*$certificateNo*.pdf";
|
||
$searchPDF = glob($path);
|
||
|
||
if(isset($searchPDF[0])) {
|
||
$updateData['certificate_file'] = $searchPDF[0];
|
||
$kCertificate++;
|
||
}
|
||
}
|
||
}
|
||
|
||
// AKT File işlemi
|
||
if(!empty($ne->akt_number)) {
|
||
$aktNumber = trim($ne->akt_number);
|
||
$aktNumber = str_replace("/", "*", $aktNumber);
|
||
$aktNumber = str_replace(" ", "*", $aktNumber);
|
||
|
||
if(trim($aktNumber) != "") {
|
||
$path = "storage/documents/$aktPath/*$aktNumber*.pdf";
|
||
$searchPDF = glob($path);
|
||
|
||
if(isset($searchPDF[0])) {
|
||
$updateData['akt_file'] = $searchPDF[0];
|
||
$kAkt++;
|
||
}
|
||
}
|
||
}
|
||
// Email TQ File işlemi
|
||
if(!empty($ne->email_tq_number)) {
|
||
$emailTqNumber = trim($ne->email_tq_number);
|
||
$emailTqNumber = str_replace("/", "*", $emailTqNumber);
|
||
$emailTqNumber = str_replace(" ", "*", $emailTqNumber);
|
||
|
||
if(trim($emailTqNumber) != "") {
|
||
$path = "storage/documents/$emailTqPath/*$emailTqNumber*.pdf";
|
||
$searchPDF = glob($path);
|
||
|
||
if(isset($searchPDF[0])) {
|
||
$updateData['email_tq_file'] = $searchPDF[0];
|
||
$kEmailTq++;
|
||
}
|
||
}
|
||
}
|
||
|
||
// OSD File işlemi
|
||
if(!empty($ne->osd_report_no)) {
|
||
$osdReportNo = trim($ne->osd_report_no);
|
||
$osdReportNo = str_replace("/", "*", $osdReportNo);
|
||
$osdReportNo = str_replace(" ", "*", $osdReportNo);
|
||
|
||
if(trim($osdReportNo) != "") {
|
||
$path = "storage/documents/$osdPath/*$osdReportNo*.pdf";
|
||
$searchPDF = glob($path);
|
||
|
||
if(isset($searchPDF[0])) {
|
||
$updateData['osd_defect_akt_file'] = $searchPDF[0];
|
||
$kOsd++;
|
||
}
|
||
}
|
||
}
|
||
|
||
// Eğer herhangi bir güncelleme varsa
|
||
if(!is_null($updateData['certificate_file']) || !is_null($updateData['akt_file']) || !is_null($updateData['email_tq_file']) || !is_null($updateData['osd_defect_akt_file'])) {
|
||
db($table)
|
||
->where("id", $ne->id)
|
||
->update($updateData);
|
||
|
||
if($say == $commitSize) {
|
||
DB::commit();
|
||
DB::beginTransaction();
|
||
$say = 0;
|
||
}
|
||
|
||
$say++;
|
||
}
|
||
}
|
||
DB::commit();
|
||
Log::debug("$table update: Certificate PDF link for $kCertificate rows, AKT PDF link for $kAkt rows, Email/TQ PDF link for $kEmailTq rows, OSD PDF link for $kOsd rows");
|
||
//dump("$table update: Certificate PDF link for $kCertificate rows, AKT PDF link for $kAkt rows, Email/TQ PDF link for $kEmailTq rows, OSD PDF link for $kOsd rows");
|
||
|
||
} catch (\Throwable $th) {
|
||
DB::rollback();
|
||
Log::error("not update PDF links " . $th->getMessage());
|
||
dump($th->getMessage());
|
||
}
|
||
|
||
Log::debug("📄$table PDF Link to DB Finish " . simdi());
|
||
|
||
?>
|