up
This commit is contained in:
@@ -20,6 +20,7 @@ class ShowCorreoConfig extends Component
|
||||
public string $correo_imap_password = '';
|
||||
public string $correo_imap_folder = 'INBOX';
|
||||
public string $correo_imap_enabled = '0';
|
||||
public string $correo_imap_minutos = '5'; // ventana de tiempo en minutos
|
||||
|
||||
// ── Estado de prueba ─────────────────────────
|
||||
public bool $testing = false;
|
||||
@@ -33,6 +34,7 @@ class ShowCorreoConfig extends Component
|
||||
'correo_imap_user' => 'required|email',
|
||||
'correo_imap_password' => 'required|string',
|
||||
'correo_imap_folder' => 'required|string|max:100',
|
||||
'correo_imap_minutos' => 'required|integer|min:1|max:1440',
|
||||
];
|
||||
|
||||
public function mount(): void
|
||||
@@ -40,7 +42,7 @@ class ShowCorreoConfig extends Component
|
||||
$keys = [
|
||||
'correo_imap_host', 'correo_imap_port', 'correo_imap_ssl',
|
||||
'correo_imap_user', 'correo_imap_password', 'correo_imap_folder',
|
||||
'correo_imap_enabled',
|
||||
'correo_imap_enabled', 'correo_imap_minutos',
|
||||
];
|
||||
foreach ($keys as $key) {
|
||||
$this->{$key} = WhatsappSystemConfig::get($key, $this->{$key});
|
||||
@@ -54,7 +56,7 @@ class ShowCorreoConfig extends Component
|
||||
$keys = [
|
||||
'correo_imap_host', 'correo_imap_port', 'correo_imap_ssl',
|
||||
'correo_imap_user', 'correo_imap_password', 'correo_imap_folder',
|
||||
'correo_imap_enabled',
|
||||
'correo_imap_enabled', 'correo_imap_minutos',
|
||||
];
|
||||
foreach ($keys as $key) {
|
||||
WhatsappSystemConfig::set($key, (string) $this->{$key});
|
||||
@@ -83,7 +85,7 @@ class ShowCorreoConfig extends Component
|
||||
timeout: 20
|
||||
);
|
||||
|
||||
$raw = $service->fetchLatest(5);
|
||||
$raw = $service->fetchLatest(5, (int) $this->correo_imap_minutos);
|
||||
|
||||
// Añadir datos parseados de Bancolombia a cada correo
|
||||
$this->emails = array_map(function (array $email) {
|
||||
|
||||
@@ -37,6 +37,7 @@ class CorreoImapService
|
||||
* luego se filtra por fecha en PHP.
|
||||
*
|
||||
* Cada elemento: [seq, from, subject, date, body]
|
||||
* El campo 'fuera_de_ventana' indica si el resultado vino del fallback (sin filtro de tiempo).
|
||||
*/
|
||||
public function fetchLatest(int $limit = 5, int $minutesBack = 5): array
|
||||
{
|
||||
@@ -50,7 +51,6 @@ class CorreoImapService
|
||||
}
|
||||
|
||||
// Descargar un lote suficiente para cubrir la ventana de tiempo.
|
||||
// 20 mensajes es razonable; si el buzón tiene pocos, se ajusta.
|
||||
$fetchSize = min($total, max($limit * 4, 20));
|
||||
$from = max(1, $total - $fetchSize + 1);
|
||||
$set = "{$from}:{$total}";
|
||||
@@ -65,22 +65,29 @@ class CorreoImapService
|
||||
$result = [];
|
||||
|
||||
foreach ($emails as $email) {
|
||||
// Parsear la fecha del correo
|
||||
$ts = $email['date'] ? @strtotime($email['date']) : false;
|
||||
|
||||
// Si la fecha es válida y el correo es más antiguo que la ventana → parar
|
||||
// Correo más antiguo que la ventana → parar
|
||||
if ($ts !== false && $ts < $cutoff) {
|
||||
break;
|
||||
}
|
||||
|
||||
$result[] = $email;
|
||||
|
||||
// Límite de cantidad alcanzado → parar
|
||||
if (count($result) >= $limit) {
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
// ── Fallback: si la ventana no devolvió nada, mostrar los últimos $limit sin filtro
|
||||
if (empty($result)) {
|
||||
$result = array_slice($emails, 0, $limit);
|
||||
foreach ($result as &$e) {
|
||||
$e['fuera_de_ventana'] = true;
|
||||
}
|
||||
unset($e);
|
||||
}
|
||||
|
||||
return $result;
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user