144 lines
4.5 KiB
PHP
144 lines
4.5 KiB
PHP
<?php
|
|
|
|
namespace App\Services;
|
|
|
|
use App\Config\Database;
|
|
use PDO;
|
|
|
|
class OrderProcessor
|
|
{
|
|
public function process($orderId, $type, $csvPath)
|
|
{
|
|
$conn = Database::getInstance()->getConnection();
|
|
|
|
if (!file_exists($csvPath)) {
|
|
throw new \Exception("Arquivo CSV não encontrado.");
|
|
}
|
|
|
|
$handle = fopen($csvPath, "r");
|
|
if ($handle === FALSE) {
|
|
throw new \Exception("Erro ao abrir arquivo CSV.");
|
|
}
|
|
|
|
$domains = [];
|
|
while (($data = fgetcsv($handle, 1000, ",")) !== FALSE) {
|
|
$raw = trim($data[0] ?? '');
|
|
if (empty($raw))
|
|
continue;
|
|
|
|
$domain = $this->cleanDomain($raw);
|
|
|
|
if ($domain) {
|
|
$domains[] = $domain;
|
|
}
|
|
}
|
|
fclose($handle);
|
|
|
|
$domains = array_unique($domains); // Remove duplicates in batch
|
|
|
|
$inTransaction = $conn->inTransaction();
|
|
if (!$inTransaction) {
|
|
$conn->beginTransaction();
|
|
}
|
|
|
|
try {
|
|
$stmtCheck = $conn->prepare("SELECT id FROM domains WHERE name = :name");
|
|
$stmtInsertDomain = $conn->prepare("INSERT INTO domains (name, status, last_order_id) VALUES (:name, :status, :order_id)");
|
|
$stmtUpdateDomain = $conn->prepare("UPDATE domains SET status = :status, last_order_id = :order_id WHERE id = :id");
|
|
$stmtInsertItem = $conn->prepare("INSERT INTO order_items (order_id, domain_id, action) VALUES (:order_id, :domain_id, :action)");
|
|
|
|
$status = ($type === 'block') ? 'blocked' : 'unblocked';
|
|
|
|
foreach ($domains as $domainName) {
|
|
// Check if exists
|
|
$stmtCheck->execute(['name' => $domainName]);
|
|
$existing = $stmtCheck->fetch();
|
|
|
|
$domainId = null;
|
|
|
|
if ($existing) {
|
|
$domainId = $existing['id'];
|
|
$stmtUpdateDomain->execute([
|
|
'status' => $status,
|
|
'order_id' => $orderId,
|
|
'id' => $domainId
|
|
]);
|
|
} else {
|
|
$stmtInsertDomain->execute([
|
|
'name' => $domainName,
|
|
'status' => $status,
|
|
'order_id' => $orderId
|
|
]);
|
|
$domainId = $conn->lastInsertId();
|
|
}
|
|
|
|
// Insert Item History
|
|
$stmtInsertItem->execute([
|
|
'order_id' => $orderId,
|
|
'domain_id' => $domainId,
|
|
'action' => $type
|
|
]);
|
|
}
|
|
|
|
if (!$inTransaction) {
|
|
$conn->commit();
|
|
}
|
|
return count($domains);
|
|
|
|
} catch (\Exception $e) {
|
|
if (!$inTransaction) {
|
|
$conn->rollBack();
|
|
}
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
private function cleanDomain($input)
|
|
{
|
|
// 1. Remove whitespace and common trailing punctuation
|
|
$input = trim($input);
|
|
$input = rtrim($input, ';,."\'');
|
|
|
|
// 2. Transliterate accents (e.g., domínio -> dominio)
|
|
// Using iconv to transliterate to ASCII
|
|
if (function_exists('iconv')) {
|
|
$input = iconv('UTF-8', 'ASCII//TRANSLIT', $input);
|
|
}
|
|
|
|
// 3. Handle Protocols and URLs
|
|
// If it doesn't have a protocol but looks like a URL path (e.g. domain.com/page), parse_url might fail or treat as path.
|
|
// We prepend http:// if missing to help parse_url, unless it's a mailto
|
|
if (stripos($input, 'mailto:') === 0) {
|
|
$input = str_ireplace('mailto:', '', $input);
|
|
}
|
|
|
|
if (strpos($input, '://') === false) {
|
|
$input = 'http://' . $input;
|
|
}
|
|
|
|
$parsed = parse_url($input);
|
|
if (!$parsed || !isset($parsed['host'])) {
|
|
return null;
|
|
}
|
|
|
|
$domain = $parsed['host'];
|
|
|
|
// 4. Remove 'www.' prefix (requested "www é um protocolo")
|
|
if (strpos($domain, 'www.') === 0) {
|
|
$domain = substr($domain, 4);
|
|
}
|
|
|
|
// 5. Lowercase
|
|
$domain = strtolower($domain);
|
|
|
|
// 6. Final Validation
|
|
// Must contain at least one dot (unless localhost, but for blocking usually FQDN)
|
|
// Must allow hyphens, dots, numbers, letters.
|
|
if (!preg_match('/^([a-z0-9]([a-z0-9-]*[a-z0-9])?\.)+[a-z0-9]([a-z0-9-]*[a-z0-9])?$/', $domain)) {
|
|
return null;
|
|
}
|
|
|
|
return $domain;
|
|
}
|
|
}
|