текущее состояние

app/Casts/BinaryTextCast.php

@@ -5,75 +5,22 @@ namespace App\Casts;
 use Illuminate\Contracts\Database\Eloquent\CastsAttributes;
 use Illuminate\Support\Facades\DB;
 
-/**
- * Каст для двоичных полей MSSQL (VARBINARY).
- *
- * Чтение: удаляет нулевые байты в конце, пытается дважды декодировать base64,
- * затем приводит к UTF-8 и убирает управляющие символы.
- * Запись: принимает человекочитаемую строку, при необходимости конвертирует из UTF-8 в CP1251,
- * выполняет двойной base64 и сохраняет как HEX-литерал 0x... для совместимости с VARBINARY на MSSQL.
- * Пустая строка сохраняется как 0x, NULL — как NULL.
- */
 class BinaryTextCast implements CastsAttributes
 {
-    /**
-     * Кэш размеров колонок VARBINARY: ["connection.table.column" => int|null]
-     */
-    private static $maxLenCache = [];
 
-    /**
-     * Декодирует значение из двойного base64 и приводит к UTF-8.
-     */
     public function get($model, string $key, $value, array $attributes)
     {
-        $value = $this->stripNulls($value);
-        if ($value === null || $value === '') {
-            return $value;
-        }
-
-        $firstByte = ord($value[0]);
-        if ($firstByte === 0) {
-            return $this->ensureUtf8(substr($value, 1));
+        if (is_null($value)) {
+            return null;
         }
 
-        if ($firstByte === 1) {
-            $payload = substr($value, 1);
-            $decoded = base64_decode($payload, true);
-            return $this->ensureUtf8($decoded !== false ? $decoded : $payload);
+        if (ctype_xdigit($value) && str_starts_with(strtolower($value), '0x')) {
+            $binary_data = hex2bin(substr($value, 2));
+        } else {
+            $binary_data = $value;
         }
 
-        $decoded = $value;
-        $hadDecode = false;
-
-        for ($i = 0; $i < 2; $i++) {
-            $tmp = base64_decode($decoded, true);
-            if ($tmp === false) {
-                break;
-            }
-
-            $hadDecode = true;
-            $decoded = $this->stripNulls($tmp);
-            if ($decoded === null || $decoded === '') {
-                break;
-            }
-
-            if (!$this->isBase64($decoded)) {
-                break;
-            }
-        }
-
-        if ($hadDecode && is_string($decoded)) {
-            return $this->ensureUtf8($decoded);
-        }
-
-        if ($this->isBase64($value)) {
-            $single = base64_decode($value, true);
-            if ($single !== false) {
-                return $this->ensureUtf8($single);
-            }
-        }
-
-        return $this->ensureUtf8($value);
+        return rtrim(mb_convert_encoding($binary_data, 'UTF-8', 'Windows-1251'));
     }
 
     /**
@@ -81,192 +28,19 @@ class BinaryTextCast implements CastsAttributes
      */
     public function set($model, string $key, $value, array $attributes)
     {
-        $value = $this->stripNulls($value);
-        if ($value === null) {
-            return $value; // сохраняем NULL как есть
-        }
-        if ($value === '') {
-            // Пустая бинарная строка для VARBINARY в MSSQL
-            return DB::raw('0x');
-        }
-
-        // Определяем максимально допустимую длину VARBINARY для данной колонки
-        $maxLen = $this->getVarbinaryMaxLength($model, $key);
-        $raw = $this->prepareRawPayload($value);
-
-        $candidates = [
-            base64_encode(base64_encode($raw)),
-            "\x01" . base64_encode($raw),
-            "\x00" . $raw,
-        ];
-
-        $payload = null;
-
-        foreach ($candidates as $candidate) {
-            if (!is_int($maxLen) || strlen($candidate) <= $maxLen) {
-                $payload = $candidate;
-                break;
-            }
-        }
-
-        if ($payload === null) {
-            if (!is_int($maxLen) || $maxLen <= 0) {
-                return DB::raw('0x');
-            }
-
-            $allowedRaw = max(0, $maxLen - 1);
-            $raw = substr($raw, 0, $allowedRaw);
-            $payload = "\x00" . $raw;
-        }
-
-        return DB::raw('0x' . bin2hex($payload));
-    }
-
-    private function prepareRawPayload(string $value): string
-    {
-        if ($value === '') {
-            return '';
-        }
-
-        if ($this->isBase64($value)) {
-            $first = base64_decode($value, true);
-            if (is_string($first)) {
-                $first = $this->stripNulls($first) ?? '';
-                if ($first !== '' && $this->isBase64($first)) {
-                    $second = base64_decode($first, true);
-                    if (is_string($second)) {
-                        $second = $this->stripNulls($second) ?? '';
-                        return $second;
-                    }
-                }
-
-                return $first;
-            }
-        }
-
-        if (function_exists('iconv')) {
-            $converted = @iconv('UTF-8', 'CP1251//IGNORE', $value);
-            if (is_string($converted)) {
-                return $converted;
-            }
-        }
-
-        return $value;
-    }
-
-    /**
-     * Удаляет завершающие нулевые байты (часто встречаются в char(n)).
-     */
-    private function stripNulls(?string $value): ?string
-    {
-        return $value === null ? null : rtrim($value, "\0");
-    }
-
-    /**
-     * Лояльная проверка, что строка похожа на base64.
-     */
-    private function isBase64(string $value): bool
-    {
-        if ($value === '') {
-            return false;
-        }
-        if (preg_match('/^[A-Za-z0-9+\/\r\n]+=*$/', $value) !== 1) {
-            return false;
-        }
-        return (strlen($value) % 4 === 0);
-    }
-
-    /**
-     * Гарантирует корректный UTF-8, пытаясь конвертацию из CP1251/ISO-8859-1
-     * и удаляя управляющие символы.
-     */
-    private function ensureUtf8(string $value): string
-    {
-        if ($value === '') {
-            return '';
-        }
-
-        if (mb_check_encoding($value, 'UTF-8')) {
-            return $this->removeControlChars($value);
-        }
-
-        $candidates = [];
-
-        if (function_exists('iconv')) {
-            $candidates[] = fn () => @iconv('CP1251', 'UTF-8//IGNORE', $value);
-        }
-
-        if (function_exists('mb_convert_encoding')) {
-            $candidates[] = fn () => @mb_convert_encoding($value, 'UTF-8', 'CP1251');
-            $candidates[] = fn () => @mb_convert_encoding($value, 'UTF-8', 'ISO-8859-1');
-        }
-
-        $candidates[] = fn () => utf8_encode($value);
-
-        foreach ($candidates as $candidate) {
-            $converted = $candidate();
-            if (is_string($converted) && mb_check_encoding($converted, 'UTF-8')) {
-                return $this->removeControlChars($converted);
-            }
+        if (is_null($value)) {
+            return [$key => null];
         }
 
-        if (function_exists('iconv')) {
-            $sanitized = @iconv('UTF-8', 'UTF-8//IGNORE', $value);
-            if (is_string($sanitized) && mb_check_encoding($sanitized, 'UTF-8')) {
-                return $this->removeControlChars($sanitized);
-            }
-        }
+        $win1251_string = mb_convert_encoding($value, 'Windows-1251', 'UTF-8');
+        $hex_string = bin2hex($win1251_string);
 
-        return '';
-    }
+        $binary_literal = '0x' . $hex_string;
 
-    /**
-     * Удаляет управляющие ASCII-символы (0x00–0x1F, 0x7F).
-     */
-    private function removeControlChars(string $value): string
-    {
-        $clean = preg_replace('/[\x00-\x08\x0B\x0C\x0E-\x1F\x7F]/u', '', $value);
-        return is_string($clean) ? $clean : '';
+        return [
+            $key => DB::raw("CONVERT(VARBINARY(MAX), " . $binary_literal . ")")
+        ];
     }
 
-    /**
-     * Возвращает максимально допустимую длину VARBINARY для указанной колонки.
-     * Для varbinary(max) возвращает null (без ограничения).
-     */
-    private function getVarbinaryMaxLength($model, string $key): ?int
-    {
-        try {
-            $connection = $model->getConnectionName();
-            $table = $model->getTable();
-            $cacheKey = $connection . '.' . $table . '.' . $key;
-            if (array_key_exists($cacheKey, self::$maxLenCache)) {
-                return self::$maxLenCache[$cacheKey];
-            }
-
-            $conn = DB::connection($connection);
-            // Запрашиваем max_length из системных таблиц
-            $sql = "SELECT c.max_length, t.name AS type_name
-                    FROM sys.columns c
-                    JOIN sys.types t ON c.user_type_id = t.user_type_id
-                    JOIN sys.tables tb ON c.object_id = tb.object_id
-                    WHERE tb.name = ? AND c.name = ?";
-            $rows = $conn->select($sql, [$table, $key]);
-            if (!empty($rows)) {
-                $row = (array) $rows[0];
-                $type = isset($row['type_name']) ? $row['type_name'] : ($row['type_name'] ?? null);
-                $max = isset($row['max_length']) ? (int) $row['max_length'] : null;
-                // Для varbinary(max) max_length = -1
-                if ($max === -1 && in_array(strtolower((string) $type), ['varbinary', 'binary'], true)) {
-                    self::$maxLenCache[$cacheKey] = null;
-                    return null;
-                }
-                self::$maxLenCache[$cacheKey] = $max;
-                return $max;
-            }
-        } catch (\Throwable $e) {
-            // Игнорируем ошибки определения схемы, работаем без ограничения
-        }
-        return null;
-    }
 
 }