PDO::ERRMODE_EXCEPTION]); } catch (PDOException $e) { die("Database connection failed"); } $dataDir = '/opt/PLATFOMRDELIVERABILITYWEVAL'; $response = ['success' => false, 'message' => '', 'data' => null]; if ($_SERVER['REQUEST_METHOD'] === 'POST') { header('Content-Type: application/json'); $action = $_POST['action'] ?? ''; if ($action === 'scan_files') { $files = []; if (is_dir($dataDir)) { foreach (new DirectoryIterator($dataDir) as $file) { if ($file->isDot()) continue; $ext = strtolower($file->getExtension()); if (!in_array($ext, ['csv', 'txt'])) continue; $lines = 0; $handle = fopen($file->getPathname(), 'r'); while (!feof($handle)) { fgets($handle); $lines++; } fclose($handle); $fn = strtolower($file->getBasename()); $isp = 'Mixed'; if (strpos($fn,'gmail')!==false) $isp='Gmail'; elseif (strpos($fn,'hotmail')!==false || strpos($fn,'outlook')!==false) $isp='Hotmail'; elseif (strpos($fn,'yahoo')!==false) $isp='Yahoo'; elseif (strpos($fn,'gmx')!==false) $isp='GMX'; $seg = 'cold'; if (strpos($fn,'click')!==false) $seg='hot'; elseif (strpos($fn,'open')!==false || strpos($fn,'active')!==false) $seg='warm'; $country = null; if (preg_match('/[_-](us|uk|ca|de|fr|au|es|nl|se|no|fi)[\._-]/i', $fn, $m)) $country = strtoupper($m[1]); $files[] = ['name'=>$file->getBasename(),'size'=>round($file->getSize()/1024,1).'KB','lines'=>$lines-1,'isp'=>$isp,'segment'=>$seg,'country'=>$country]; } } usort($files, fn($a,$b) => $b['lines'] - $a['lines']); echo json_encode(['success'=>true,'data'=>$files]); exit; } if ($action === 'import_file') { $file = basename($_POST['file'] ?? ''); $segment = $_POST['segment'] ?? 'cold'; $country = $_POST['country'] ?? null; $filepath = $dataDir . '/' . $file; if (!file_exists($filepath)) { echo json_encode(['success'=>false,'message'=>'File not found']); exit; } $handle = fopen($filepath, 'r'); $first = fgets($handle); rewind($handle); $delim = substr_count($first,';') > substr_count($first,',') ? ';' : ','; fgetcsv($handle, 0, $delim); $imported = 0; $skipped = 0; $stmt = $pdo->prepare("INSERT INTO admin.leads (email,country,segment,isp,source_file,created_at) VALUES (?,?,?,?,?,NOW()) ON CONFLICT (email) DO UPDATE SET segment=CASE WHEN EXCLUDED.segment='hot' THEN 'hot' WHEN admin.leads.segment='hot' THEN 'hot' WHEN EXCLUDED.segment='warm' THEN 'warm' ELSE admin.leads.segment END, updated_at=NOW()"); while (($row = fgetcsv($handle, 0, $delim)) !== false) { $email = null; foreach ($row as $val) { if (filter_var(trim($val), FILTER_VALIDATE_EMAIL)) { $email = strtolower(trim($val)); break; } } if (!$email) { $skipped++; continue; } $domain = substr(strrchr($email, "@"), 1); $isp = 'Other'; if (strpos($domain,'gmail')!==false) $isp='Gmail'; elseif (strpos($domain,'hotmail')!==false || strpos($domain,'outlook')!==false || strpos($domain,'live')!==false) $isp='Hotmail'; elseif (strpos($domain,'yahoo')!==false) $isp='Yahoo'; try { $stmt->execute([$email,$country,$segment,$isp,$file]); $imported++; } catch(Exception $e) { $skipped++; } } fclose($handle); echo json_encode(['success'=>true,'message'=>"Imported: $imported, Skipped: $skipped",'data'=>['imported'=>$imported,'skipped'=>$skipped]]); exit; } } $totalLeads = $pdo->query("SELECT COUNT(*) FROM admin.leads")->fetchColumn() ?: 0; $todayImported = $pdo->query("SELECT COUNT(*) FROM admin.leads WHERE created_at::date = CURRENT_DATE")->fetchColumn() ?: 0; ?> WEVAL SEND Import
-
📁 Files Found
-
📧 Total Records
✅ In Database
📊 Today
📂 Data Files - /opt/PLATFOMRDELIVERABILITYWEVAL
📂

Loading files...

📋 Import Log
Ready to import data...
function renderFiles(files){ const grid=document.getElementById('fileGrid'); if(files.length===0){grid.innerHTML='
📭

No files found

';return} let html=''; files.forEach(f=>{ const segCls=f.segment==='hot'?'badge-hot':f.segment==='warm'?'badge-warm':'badge-cold'; const segIcon=f.segment==='hot'?'🔥':f.segment==='warm'?'🌡️':'❄️'; html+=`
${f.name} ${f.size} ${f.lines.toLocaleString()} ${f.isp} ${segIcon} ${f.segment} ${f.country||'-'}
`; }); grid.innerHTML=html; } async function importSelected(){ const checked=document.querySelectorAll('.file-check:checked'); if(checked.length===0){alert('Select files first');return} if(!confirm('Import '+checked.length+' file(s)?'))return; showLoading();document.getElementById('progressBar').style.display='block'; let done=0,totalImported=0,totalSkipped=0; for(const cb of checked){ const name=cb.dataset.name,seg=cb.dataset.segment,country=cb.dataset.country; log('Importing '+name+'...','info'); try{ const r=await fetch('',{method:'POST',headers:{'Content-Type':'application/x-www-form-urlencoded'},body:'action=import_file&file='+encodeURIComponent(name)+'&segment='+seg+'&country='+country}); const res=await r.json(); if(res.success){log('✅ '+name+': '+res.message,'success');totalImported+=res.data.imported;totalSkipped+=res.data.skipped} else{log('❌ '+name+': '+res.message,'error')} }catch(e){log('❌ '+name+': '+e.message,'error')} done++;document.getElementById('progressFill').style.width=(done/checked.length*100)+'%'; } log('📊 Total: '+totalImported+' imported, '+totalSkipped+' skipped','info'); hideLoading();setTimeout(()=>location.reload(),2000); } function log(msg,type='info'){const a=document.getElementById('logArea');a.innerHTML+=`
[${new Date().toLocaleTimeString()}] ${msg}
`;a.scrollTop=a.scrollHeight} function clearLog(){document.getElementById('logArea').innerHTML='Ready...';document.getElementById('progressBar').style.display='none'} function showLoading(){document.getElementById('loading').style.display='flex'} function hideLoading(){document.getElementById('loading').style.display='none'}