format('Y-m-d H:i:s'); // Fecha y hora actual
//$hora_antes = Carbon::now()->subHours(100)->format('Y-m-d H:i:s'); // 24 horas antes
$hora_antes = Carbon::now()->subMinutes(15)->format('Y-m-d H:i:s');
$this->validarSaldosNegativos($hora_antes, $fecha_ahora);
$resultados = Historiale::select('vendedor_id')
->selectRaw('COUNT(*) as total')
->where('estado', 'activo')
->whereBetween('created_at', [$hora_antes, $fecha_ahora])
->groupBy('vendedor_id')
->havingRaw('COUNT(*) > 1')
->get();
foreach ($resultados as $resultado) {
$registro_vendedores_duplicados = Historiale::where('vendedor_id', $resultado->vendedor_id)
->where('estado', 'activo')
->whereBetween('created_at', [$hora_antes, $fecha_ahora])
->orderBy('created_at', 'asc') // Ordenar por fecha ascendente para comparar correctamente
->get();
foreach ($registro_vendedores_duplicados as $index => $registro) {
if ($index > 0) {
$anterior = $registro_vendedores_duplicados[$index - 1];
if ($anterior->valor == $registro->valor && $anterior->tarifa_id == $registro->tarifa_id && $anterior->promocion_id == $registro->promocion_id) {
$diferencia = Carbon::parse($anterior->created_at)->diffInSeconds(Carbon::parse($registro->created_at));
if ($diferencia < 20) {
//echo "Diferencia: {$diferencia} segundos
Vendedor ID: {$anterior->nombre_cliente}- {$anterior->created_at} - {$registro->created_at}
";
$validar_actual = Log_general::where('historial_id', $registro->id)
->where('tipo', 'compra')
->exists(); // Corregido
$validar_anterior = Log_general::where('historial_id', $anterior->id)
->where('tipo', 'compra')
->exists(); // Corregido
if ($validar_actual && $validar_anterior) {
echo "Compra duplicada: {$anterior->created_at} - {$registro->created_at}
";
$vendedor = User::find($resultado->vendedor_id);
$email = $vendedor->email;
$mensaje = "⚠️ Compra Duplicada ⚠️\nUsuario: {$email}\nFechas:\n- Anterior: {$anterior->created_at}\n- Actual: {$registro->created_at}\nDiferencia: {$diferencia} segundos";
$this->enviarTelegram($mensaje);
$corregido = $this->corregir($anterior->id, $registro->id);
//echo "Corregido: " . $corregido;
if ($corregido === true) { // Aseguramos que la corrección fue exitosa
$vendedor->refresh(); // Actualizar el modelo
$mensaje = "📌 Corregido 📌\n" .
"🆔 Historial ID inactivo: " . addslashes($registro->id) . "\n" .
"🆔 Historial ID activo: " . addslashes($anterior->id) . "\n" .
"👤 Saldo retornado: " . addslashes($registro->valor) . "\n" .
"👤 Usuario: " . addslashes($email) . "\n" .
"📅 Fechas:\n" .
" ➤ Anterior: " . addslashes(Carbon::parse($anterior->created_at)->format('d M Y h:i:s A')) . "\n" .
" ➤ Actual: " . addslashes(Carbon::parse($registro->created_at)->format('d M Y h:i:s A')) . "";
$this->enviarTelegram($mensaje);
Log_general::create([
'user_id' => $resultado->vendedor_id,
'historial_id' => $registro->id,
'tipo' => 'corregido',
'detalle' => 'Se ha corregido la compra duplicada, usuario: ' . $email . ' - ' .
Carbon::parse($registro->created_at)->format('d M Y h:i A') . ' - ' .
Carbon::parse($anterior->created_at)->format('d M Y h:i A') . ' - Saldo retornado:' . $registro->valor .'- Saldo actual: '.$vendedor->saldo->valor,
]);
}
}
}
}
}
}
}
}
public function enviarTelegram($mensaje)
{
$token = '8163118229:AAENDu4PQGruSx1EHSfMH6BecunxAGyhixY';
$chat_id = '7583714074';
$mensaje = 'Sirpremium:' . "\n" . $mensaje;
$response = Http::get("https://api.telegram.org/bot{$token}/sendMessage", [
'chat_id' => $chat_id,
'text' => $mensaje,
]);
if ($response->successful()) {
Log::info('Mensaje enviado a Telegram');
} else {
Log::error('Error al enviar mensaje a Telegram');
}
}
public function corregir($anterior, $actual)
{
try {
DB::beginTransaction(); // Iniciar una transacción
$historial_anterior = Historiale::find($anterior);
$historial_actual = Historiale::find($actual);
if (!$historial_anterior || !$historial_actual) {
return response()->json(['error' => 'Historial no encontrado'], 404);
}
$usuario_anterior = $historial_anterior->vendedor_id;
$actualizar_saldo = User::find($usuario_anterior);
if (!$actualizar_saldo) {
return response()->json(['error' => 'Usuario no encontrado'], 404);
}
// Devolver saldo
$nuevo_saldo = $actualizar_saldo->saldo->valor + $historial_actual->valor;
Saldo::where('user_id', $usuario_anterior)->update(['valor' => $nuevo_saldo]);
// Cancelar historial actual
$historial_actual->estado = 'cancelado';
$historial_actual->save();
$cuentahistorial = Historial_cuenta::where('historial_id', $historial_actual->id)->get();
// Eliminar cuentas asociadas
if (!$cuentahistorial->isEmpty()) {
foreach ($cuentahistorial as $cuenta) {
$cuenta->delete();
}
}
Log_general::where('historial_id', $actual)
->where('tipo', 'compra')
->update(['tipo' => 'revertida']);
DB::commit(); // Confirmar la transacción
return true; //
} catch (\Exception $e) {
DB::rollBack(); // Revertir si hay un error
return response()->json(['error' => 'Error al corregir: ' . $e->getMessage()], 500);
}
}
public function validarSaldosNegativos($anterior, $actual)
{
$consultaLog = Log_general::whereBetween('created_at', [$anterior, $actual])
->where('detalle', 'LIKE', '%disponible: $-%')
->get();
//dd($consultaLog);
if (!$consultaLog->isEmpty()) {
foreach ($consultaLog as $log) {
$historial = Historiale::find($log->historial_id);
$usuario = User::find($historial->vendedor_id);
$email = $usuario->email;
$mensaje = "⚠️ Saldo Negativo ⚠️\nUsuario: {$email}\nFecha: {$log->created_at}\nDetalle: {$log->detalle}";
$this->enviarTelegram($mensaje);
}
}
return;
}
}