391 lines
17 KiB
PHP
391 lines
17 KiB
PHP
<?php
|
|
require_once "class/VisualLimsApiClient.class.php";
|
|
include('include/headscript.php');
|
|
|
|
$dbHandler = DBHandlerSelect::getInstance();
|
|
$pdo = $dbHandler->getConnection();
|
|
|
|
header("Content-Type: application/json");
|
|
|
|
// 🔹 Configura directory log (creala se non esiste)
|
|
$logDir = __DIR__ . '/logs/api/';
|
|
if (!is_dir($logDir)) {
|
|
mkdir($logDir, 0755, true);
|
|
}
|
|
|
|
$uploadDir = realpath(__DIR__ . '/../photostrf') . '/';
|
|
|
|
// 🔹 Base URL API
|
|
$apiBaseUrl = 'https://93.43.5.102/limsapi/api/odata/';
|
|
|
|
// 🔹 Funzione per validare e convertire date
|
|
function validateDate($value)
|
|
{
|
|
// Prova a validare come data (accetta formati comuni)
|
|
$date = DateTime::createFromFormat('Y-m-d', $value) ?: DateTime::createFromFormat('Y-m-d H:i:s', $value);
|
|
if ($date) {
|
|
return $date->format('Y-m-d\TH:i:sP'); // Formato ISO 8601
|
|
}
|
|
return null; // Imposta null se non è una data valida
|
|
}
|
|
|
|
try {
|
|
$iddatadb = $_POST['iddatadb'] ?? null;
|
|
if (!$iddatadb) {
|
|
throw new Exception("Missing iddatadb");
|
|
}
|
|
|
|
// 🔹 STEP 1+2: Fetch Cliente ID from datadb and Schema ID from excel_templates
|
|
// Also fetch fixed fields stored in datadb
|
|
$stmt = $pdo->prepare("
|
|
SELECT d.idclient AS clienteId, et.idschema AS schemaId,
|
|
d.cliente_responsabile_id,
|
|
d.moltiplicatore_prezzo_id,
|
|
d.anagrafica_certest_object_id,
|
|
d.anagrafica_certest_service_id,
|
|
d.cliente_fornitore_id,
|
|
d.consegna_richiesta
|
|
FROM datadb as d
|
|
INNER JOIN excel_templates as et ON d.templateid = et.id
|
|
WHERE d.iddatadb = :iddatadb
|
|
LIMIT 1
|
|
");
|
|
$stmt->execute(['iddatadb' => $iddatadb]);
|
|
$result = $stmt->fetch(PDO::FETCH_ASSOC);
|
|
|
|
if (!$result) {
|
|
throw new Exception("No Cliente/Schema found for iddatadb {$iddatadb}");
|
|
}
|
|
|
|
$clienteId = (int) $result['clienteId'];
|
|
$schemaId = (int) $result['schemaId'];
|
|
|
|
// Extract fixed fields (nullable INTs)
|
|
$clienteResponsabile = !empty($result['cliente_responsabile_id']) ? (int) $result['cliente_responsabile_id'] : null;
|
|
$moltiplicatorePrezzo = !empty($result['moltiplicatore_prezzo_id']) ? (int) $result['moltiplicatore_prezzo_id'] : null;
|
|
$anagraficaObject = !empty($result['anagrafica_certest_object_id']) ? (int) $result['anagrafica_certest_object_id'] : null;
|
|
$anagraficaService = !empty($result['anagrafica_certest_service_id'])? (int) $result['anagrafica_certest_service_id']: null;
|
|
$clienteFornitore = !empty($result['cliente_fornitore_id'])? (int) $result['cliente_fornitore_id']: null;
|
|
$consegnaRichiesta = !empty($result['consegna_richiesta']) ? $result['consegna_richiesta'] : null;
|
|
|
|
// 🔹 STEP 3: Fetch Parts (including idmatrice)
|
|
$stmt = $pdo->prepare("
|
|
SELECT part_number, part_description, material, color, mix, idmatrice
|
|
FROM identification_parts
|
|
WHERE iddatadb = :iddatadb
|
|
");
|
|
$stmt->execute(['iddatadb' => $iddatadb]);
|
|
$parts = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
|
|
// 🔹 STEP 4: Fetch Field Values with Labels
|
|
$stmt = $pdo->prepare("
|
|
SELECT
|
|
idd.field_value,
|
|
m.field_label,
|
|
m.schema_id,
|
|
m.field_id
|
|
FROM
|
|
import_data_details as idd
|
|
JOIN template_mapping m ON idd.mapping_id = m.id
|
|
WHERE idd.id = :iddatadb
|
|
");
|
|
$stmt->execute(['iddatadb' => $iddatadb]);
|
|
$rows = $stmt->fetchAll(PDO::FETCH_ASSOC);
|
|
|
|
$fieldValues = [];
|
|
$valueMap = [];
|
|
foreach ($rows as $row) {
|
|
$fieldValues[] = [
|
|
"IdCommesseCustomFields" => (int) $row['field_id'],
|
|
"Valore" => $row['field_value'],
|
|
"FieldLabel" => $row['field_label']
|
|
];
|
|
$valueMap[(int) $row['field_id']] = $row['field_value'];
|
|
}
|
|
|
|
// Logga i fieldValues in error_log
|
|
$logFieldValues = "FieldValues dal DB (iddatadb={$iddatadb}):\n" . json_encode($fieldValues, JSON_PRETTY_PRINT);
|
|
error_log($logFieldValues);
|
|
|
|
// 🔹 Initialize API client
|
|
$api = VisualLimsApiClient::getInstance();
|
|
|
|
// 🔹 STEP 5: Create CommessaWeb
|
|
// Fixed fields are sent as direct properties — they are navigation properties on Commessa
|
|
// accepted by the XAF API even though not explicitly listed in OData $metadata
|
|
$commessaWebPayload = [
|
|
"Cliente" => $clienteId,
|
|
"SchemaCustomField" => $schemaId,
|
|
"Richiedente" => "Test Web Import", // TODO: replace with real value
|
|
"Descrizione" => "TEST CommessaWeb", // TODO: replace with real value
|
|
"ClienteResponsabile" => $clienteResponsabile,
|
|
"MoltiplicatorePrezzo" => $moltiplicatorePrezzo,
|
|
"AnagraficaCertestObject" => $anagraficaObject,
|
|
"AnagraficaCertestService" => $anagraficaService,
|
|
"ClienteFornitore" => $clienteFornitore, // PLACEHOLDER — to be implemented
|
|
// DeliveryRequest goes to Campione, not CommessaWeb
|
|
];
|
|
|
|
// Costruisci log curl-like per STEP 5
|
|
$jsonPayload = json_encode($commessaWebPayload, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES);
|
|
$logContentStep5 = "curl --location --request POST '{$apiBaseUrl}CommessaWeb' \\\n" .
|
|
"--header 'Content-Type: application/json' \\\n" .
|
|
"--header 'Authorization: Bearer ••••••' \\\n" .
|
|
"--data '{$jsonPayload}'";
|
|
|
|
$commessaWeb = $api->post("CommessaWeb", $commessaWebPayload);
|
|
|
|
$logContentStep5 .= "\n\nRESPONSE:\n" . json_encode($commessaWeb, JSON_PRETTY_PRINT);
|
|
|
|
// Salva log
|
|
$logFileStep5 = $logDir . "commessa_create_step5_" . $iddatadb . "_" . time() . ".txt";
|
|
file_put_contents($logFileStep5, $logContentStep5);
|
|
|
|
$commessaId = $commessaWeb["IdCommessa"];
|
|
$commessaWebCode = substr($commessaWeb["CodiceCommessa"] ?? "TEST CommessaWeb", 0, 30); // Limite a 30 caratteri
|
|
|
|
// 🔹 STEP 6: Create Campioni (Samples) for each part
|
|
$campioni = [];
|
|
$logContentStep6 = "";
|
|
|
|
foreach ($parts as $index => $part) {
|
|
$matriceId = (int) ($part["idmatrice"] ?? 0);
|
|
|
|
if ($matriceId <= 0) {
|
|
throw new Exception("Invalid or missing idmatrice for part: " . ($part["part_number"] ?? "Unknown"));
|
|
}
|
|
|
|
$campionePayload = [
|
|
"Commessa" => $commessaId,
|
|
"Matrice" => $matriceId,
|
|
"SottoMatrice" => null,
|
|
"SchemaCustomField" => $schemaId,
|
|
"NoteWeb" => $part["part_description"] ?? "",
|
|
"DeliveryRequest" => $consegnaRichiesta,
|
|
];
|
|
|
|
// Costruisci curl-like per questo campione
|
|
$jsonPayload = json_encode($campionePayload, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES);
|
|
$logContentStep6 .= "CAMPIONE #{$index}\n" .
|
|
"curl --location --request POST '{$apiBaseUrl}Campione' \\\n" .
|
|
"--header 'Content-Type: application/json' \\\n" .
|
|
"--header 'Authorization: Bearer ••••••' \\\n" .
|
|
"--data '{$jsonPayload}'\n\n";
|
|
|
|
$campione = $api->post("Campione", $campionePayload);
|
|
|
|
$logContentStep6 .= "RESPONSE:\n" . json_encode($campione, JSON_PRETTY_PRINT) . "\n\n---\n";
|
|
|
|
$campione["PartNumber"] = $part["part_number"] ?? "";
|
|
$campione["Material"] = $part["material"] ?? "";
|
|
$campione["Color"] = $part["color"] ?? "";
|
|
$campione["Mix"] = $part["mix"] ?? "";
|
|
|
|
$campioni[] = $campione;
|
|
}
|
|
|
|
// Salva log per STEP 6
|
|
$logFileStep6 = $logDir . "commessa_{$commessaId}_campioni_step6_" . time() . ".txt";
|
|
file_put_contents($logFileStep6, $logContentStep6);
|
|
|
|
// 🔹 STEP 6.1: Fetch photos linked to this iddatadb
|
|
$stmtPhotos = $pdo->prepare("
|
|
SELECT id, file_path, file_name
|
|
FROM datadb_photos
|
|
WHERE iddatadb = :iddatadb
|
|
ORDER BY id ASC
|
|
");
|
|
$stmtPhotos->execute(['iddatadb' => $iddatadb]);
|
|
$photos = $stmtPhotos->fetchAll(PDO::FETCH_ASSOC);
|
|
|
|
|
|
// 🔹 STEP 6.2: Upload photos to the first (main) Campione only
|
|
$photosUploaded = 0;
|
|
$logContentPhotos = "Photos for CommessaWeb {$commessaId} (iddatadb={$iddatadb}):\n";
|
|
$logContentPhotos .= "Total photos found: " . count($photos) . ", campioni: " . count($campioni) . "\n\n";
|
|
|
|
if (!empty($campioni) && !empty($photos)) {
|
|
$mainCampione = $campioni[0];
|
|
$campioneId = (int)($mainCampione['IdCampione'] ?? 0);
|
|
|
|
if ($campioneId > 0) {
|
|
$logContentPhotos .= "=== Campione {$campioneId} (main) ===\n";
|
|
|
|
foreach ($photos as $photo) {
|
|
$photoPath = $uploadDir . '/' . ltrim($photo['file_path'], './');
|
|
$fullPath = realpath($photoPath);
|
|
|
|
if (!$fullPath || !file_exists($fullPath)) {
|
|
$logContentPhotos .= "SKIP (file not found): {$photoPath}\n";
|
|
continue;
|
|
}
|
|
|
|
$photoEndpoint = "Campione({$campioneId})/UploadCampioneFile";
|
|
$logContentPhotos .= "curl --location --request POST '{$apiBaseUrl}{$photoEndpoint}' \\\n" .
|
|
"--header 'Authorization: Bearer ••••••' \\\n" .
|
|
"--form 'file=@{$fullPath}'\n\n";
|
|
|
|
$photoResult = $api->postMultipart($photoEndpoint, $fullPath, $photo['file_name']);
|
|
$logContentPhotos .= "RESPONSE:\n" . json_encode($photoResult, JSON_PRETTY_PRINT) . "\n\n---\n";
|
|
$photosUploaded++;
|
|
}
|
|
} else {
|
|
$logContentPhotos .= "SKIP: main campione has invalid IdCampione\n";
|
|
}
|
|
} elseif (empty($campioni)) {
|
|
$logContentPhotos .= "SKIP: no campioni created, cannot upload photos\n";
|
|
}
|
|
|
|
$logFilePhotos = $logDir . "commessa_{$commessaId}_photos_step5_2_" . time() . ".txt";
|
|
file_put_contents($logFilePhotos, $logContentPhotos);
|
|
|
|
// 🔹 STEP 7: Update Custom Fields for CommessaWeb
|
|
if (!empty($fieldValues)) {
|
|
// GET con espansione per CustomField
|
|
$expand = "CommesseCustomFields(\$expand=CustomField)";
|
|
$commessaWithFields = $api->get("CommessaWeb({$commessaId})?\$expand={$expand}");
|
|
|
|
// Logga il GET
|
|
$logContentGet = "curl --location --request GET '{$apiBaseUrl}CommessaWeb({$commessaId})?\$expand=CommesseCustomFields(\$expand=CustomField)' \\\n" .
|
|
"--header 'Authorization: Bearer ••••••'\n\n" .
|
|
"RESPONSE:\n" . json_encode($commessaWithFields, JSON_PRETTY_PRINT);
|
|
$logFileGet = $logDir . "commessa_{$commessaId}_get_step7_" . time() . ".txt";
|
|
file_put_contents($logFileGet, $logContentGet);
|
|
|
|
// Prepara payload PATCH
|
|
$commessaCustomFields = [];
|
|
foreach ($commessaWithFields["CommesseCustomFields"] as $customField) {
|
|
$definitionId = (int) ($customField["CustomField"]["IdCustomField"] ?? 0);
|
|
$fieldId = (int) $customField["IdCommesseCustomFields"];
|
|
$currentValue = $customField["Valore"] ?? '';
|
|
$fieldType = $customField["CustomField"]["Tipo"] ?? '';
|
|
$newValue = isset($valueMap[$definitionId]) ? $valueMap[$definitionId] : $currentValue;
|
|
|
|
// Valida se il campo è di tipo Data
|
|
if ($fieldType === 'Data' && $newValue !== $currentValue) {
|
|
$newValue = validateDate($newValue);
|
|
}
|
|
|
|
$commessaCustomFields[] = [
|
|
"IdCommesseCustomFields" => $fieldId,
|
|
"Valore" => $newValue
|
|
];
|
|
}
|
|
|
|
$logFileStep7 = null;
|
|
if (!empty($commessaCustomFields)) {
|
|
$updatePayload = ["CommesseCustomFields" => $commessaCustomFields];
|
|
|
|
// Logga payload e response
|
|
$jsonPayload = json_encode($updatePayload, JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES);
|
|
$logContentStep7 = "curl --location --request PATCH '{$apiBaseUrl}CommessaWeb({$commessaId})' \\\n" .
|
|
"--header 'Content-Type: application/json' \\\n" .
|
|
"--header 'Authorization: Bearer ••••••' \\\n" .
|
|
"--data '{$jsonPayload}'";
|
|
|
|
$patchResponse = $api->patch("CommessaWeb({$commessaId})", $updatePayload);
|
|
|
|
$logContentStep7 .= "\n\nRESPONSE:\n" . json_encode($patchResponse, JSON_PRETTY_PRINT);
|
|
$logFileStep7 = $logDir . "commessa_{$commessaId}_update_step7_" . time() . ".txt";
|
|
file_put_contents($logFileStep7, $logContentStep7);
|
|
}
|
|
}
|
|
|
|
// 🔹 STEP 8: Update datadb with idcommessaweb, commessaweb, and status
|
|
$stmt = $pdo->prepare("
|
|
UPDATE datadb
|
|
SET idcommessaweb = :idcommessaweb, commessaweb = :commessaweb, status = 'l'
|
|
WHERE iddatadb = :iddatadb
|
|
");
|
|
$stmt->execute([
|
|
'idcommessaweb' => $commessaId,
|
|
'commessaweb' => $commessaWebCode,
|
|
'iddatadb' => $iddatadb
|
|
]);
|
|
|
|
// 🔹 STEP 9: Send CommessaWeb to laboratory (commentato come richiesto)
|
|
|
|
$sendResult = $api->post("CommessaWeb({$commessaId})/InviaCommessa", []);
|
|
|
|
// Logga il POST
|
|
$logContentStep9 = "curl --location --request POST '{$apiBaseUrl}CommessaWeb({$commessaId})/InviaCommessa' \\\n" .
|
|
"--header 'Content-Type: application/json' \\\n" .
|
|
"--header 'Authorization: Bearer ••••••' \\\n" .
|
|
"--data '{}'\n\n" .
|
|
"RESPONSE:\n" . json_encode($sendResult, JSON_PRETTY_PRINT);
|
|
$logFileStep9 = $logDir . "commessa_{$commessaId}_send_step9_" . time() . ".txt";
|
|
file_put_contents($logFileStep9, $logContentStep9);
|
|
|
|
|
|
// 🔹 STEP 9.5: Importazione da CommessaWeb a Commessa (commentato come richiesto)
|
|
// Supplier call: POST api/odata/CommessaWeb(XXX)/ImportaCommessa
|
|
|
|
$importResult = $api->post("CommessaWeb({$commessaId})/ImportaCommessa", []);
|
|
|
|
// Logga il POST
|
|
$logContentStep91 = "curl --location --request POST '{$apiBaseUrl}CommessaWeb({$commessaId})/ImportaCommessa' \\\n" .
|
|
"--header 'Content-Type: application/json' \\\n" .
|
|
"--header 'Authorization: Bearer ••••••' \\\n" .
|
|
"--data '{}'\n\n" .
|
|
"RESPONSE:\n" . json_encode($importResult, JSON_PRETTY_PRINT);
|
|
$logFileStep91 = $logDir . "commessa_{$commessaId}_importa_step91_" . time() . ".txt";
|
|
file_put_contents($logFileStep91, $logContentStep91);
|
|
|
|
// 🔹 STEP 10: GET di controllo post-PATCH
|
|
$expand = "CommesseCustomFields(\$expand=CustomField)";
|
|
$commessaAfterPatch = $api->get("CommessaWeb(" . $commessaId . ")?\$expand=" . $expand);
|
|
|
|
// Logga il GET di controllo
|
|
$logContentStep10 = "curl --location --request GET '{$apiBaseUrl}CommessaWeb({$commessaId})?\$expand=CommesseCustomFields(\$expand=CustomField)' \\\n" .
|
|
"--header 'Authorization: Bearer ••••••'\n\n" .
|
|
"RESPONSE:\n" . json_encode($commessaAfterPatch, JSON_PRETTY_PRINT);
|
|
$logFileStep10 = $logDir . "commessa_{$commessaId}_get_step10_" . time() . ".txt";
|
|
file_put_contents($logFileStep10, $logContentStep10);
|
|
|
|
// 🔹 STEP 11: Prepare final response
|
|
$finalCommessa = [
|
|
"Cliente" => $clienteId,
|
|
"SchemaCustomField" => $schemaId,
|
|
"Richiedente" => $commessaWeb["Richiedente"] ?? "Web Import",
|
|
"Descrizione" => $commessaWeb["Descrizione"] ?? "",
|
|
"CommesseCustomFields" => $commessaAfterPatch["CommesseCustomFields"] ?? [],
|
|
"Campioni" => $campioni,
|
|
"Inviata" => 0 // Non inviato, come richiesto
|
|
];
|
|
|
|
echo json_encode([
|
|
"success" => true,
|
|
"idcommessaweb" => $commessaId,
|
|
"commessaweb" => $commessaWebCode,
|
|
"commessaWeb" => $finalCommessa,
|
|
"commessaWebApiResponse" => $commessaWeb, // Incluso per debug
|
|
"totalCampioni" => count($campioni),
|
|
"totalCustomFields" => count($commessaAfterPatch["CommesseCustomFields"] ?? []),
|
|
"totalPhotos" => count($photos),
|
|
"message" => "Export successful",
|
|
"logFiles" => [
|
|
"step5_create" => $logFileStep5,
|
|
"step5_2_photos" => $logFilePhotos,
|
|
"step6_campioni" => $logFileStep6,
|
|
"step7_patch" => $logFileStep7 ?? null,
|
|
"step9_1_importa" => $logFileStep91,
|
|
"step10_get" => $logFileStep10
|
|
]
|
|
]);
|
|
} catch (Exception $e) {
|
|
error_log("LIMS Export Error: " . $e->getMessage() . "\nTrace: " . $e->getTraceAsString());
|
|
|
|
echo json_encode([
|
|
"success" => false,
|
|
"message" => "Export failed: " . $e->getMessage(),
|
|
"logFiles" => [
|
|
"step5_create" => $logFileStep5 ?? null,
|
|
"step5_2_photos" => $logFilePhotos ?? null,
|
|
"step6_campioni" => $logFileStep6 ?? null,
|
|
"step7_patch" => $logFileStep7 ?? null,
|
|
"step9_1_importa" => $logFileStep91 ?? null,
|
|
"step10_get" => $logFileStep10 ?? null
|
|
]
|
|
]);
|
|
}
|