@@ -198,6 +260,10 @@ document.addEventListener('DOMContentLoaded', function() {
function setupEventListeners() {
// Form submission
document.getElementById('importForm').addEventListener('submit', handleImport);
+ document.getElementById('batchImportForm').addEventListener('submit', handleBatchImport);
+
+ // Upload mode switching
+ document.getElementById('uploadMode').addEventListener('change', switchUploadMode);
// Validation button
document.getElementById('validateBtn').addEventListener('click', validateFile);
@@ -205,6 +271,10 @@ function setupEventListeners() {
// File type selection
document.getElementById('fileType').addEventListener('change', updateFileTypeDescription);
+ // Batch file selection
+ document.getElementById('batchFiles').addEventListener('change', updateSelectedFiles);
+ document.getElementById('clearBatchBtn').addEventListener('click', clearBatchSelection);
+
// Refresh status
document.getElementById('refreshStatusBtn').addEventListener('click', loadImportStatus);
@@ -222,7 +292,16 @@ async function loadAvailableFiles() {
headers: getAuthHeaders()
});
- if (!response.ok) throw new Error('Failed to load available files');
+ if (response.status === 401 || response.status === 403) {
+ console.error('Authentication error - redirecting to login');
+ window.location.href = '/login';
+ return;
+ }
+
+ if (!response.ok) {
+ const errorData = await response.json().catch(() => ({}));
+ throw new Error(errorData.error?.message || `HTTP ${response.status}: ${response.statusText}`);
+ }
const data = await response.json();
availableFiles = data;
@@ -260,7 +339,16 @@ async function loadImportStatus() {
headers: getAuthHeaders()
});
- if (!response.ok) throw new Error('Failed to load import status');
+ if (response.status === 401 || response.status === 403) {
+ console.error('Authentication error - redirecting to login');
+ window.location.href = '/login';
+ return;
+ }
+
+ if (!response.ok) {
+ const errorData = await response.json().catch(() => ({}));
+ throw new Error(errorData.error?.message || `HTTP ${response.status}: ${response.statusText}`);
+ }
const status = await response.json();
displayImportStatus(status);
@@ -571,6 +659,217 @@ function viewLogs() {
showAlert('Import logs functionality coming soon', 'info');
}
+function switchUploadMode() {
+ const mode = document.getElementById('uploadMode').value;
+ const singleForm = document.querySelector('.single-upload');
+ const batchForm = document.querySelector('.batch-upload');
+
+ if (mode === 'batch') {
+ singleForm.classList.add('hidden');
+ batchForm.classList.remove('hidden');
+ } else {
+ singleForm.classList.remove('hidden');
+ batchForm.classList.add('hidden');
+ }
+}
+
+function updateSelectedFiles() {
+ const fileInput = document.getElementById('batchFiles');
+ const countSpan = document.getElementById('selectedFilesCount');
+ const filesList = document.getElementById('selectedFilesList');
+ const filesListContent = document.getElementById('filesList');
+
+ const files = Array.from(fileInput.files);
+ countSpan.textContent = `${files.length} files selected`;
+
+ if (files.length > 0) {
+ // Define import order
+ const importOrder = [
+ "STATES.csv", "GRUPLKUP.csv", "EMPLOYEE.csv", "FILETYPE.csv", "FILESTAT.csv",
+ "TRNSTYPE.csv", "TRNSLKUP.csv", "FOOTERS.csv", "SETUP.csv", "PRINTERS.csv",
+ "ROLODEX.csv", "PHONE.csv", "FILES.csv", "LEDGER.csv", "TRNSACTN.csv",
+ "QDROS.csv", "PENSIONS.csv", "PLANINFO.csv", "PAYMENTS.csv", "DEPOSITS.csv",
+ "FILENOTS.csv", "FORM_INX.csv", "FORM_LST.csv", "FVARLKUP.csv", "RVARLKUP.csv"
+ ];
+
+ // Sort files by import order
+ const orderedFiles = [];
+ const fileMap = {};
+ files.forEach(file => fileMap[file.name] = file);
+
+ importOrder.forEach(fileName => {
+ if (fileMap[fileName]) {
+ orderedFiles.push(fileMap[fileName]);
+ delete fileMap[fileName];
+ }
+ });
+
+ // Add remaining files
+ Object.values(fileMap).forEach(file => orderedFiles.push(file));
+
+ // Display ordered list
+ let html = '
';
+ orderedFiles.forEach((file, index) => {
+ const isSupported = availableFiles.available_files && availableFiles.available_files.includes(file.name);
+ const statusClass = isSupported ? 'text-success-600 dark:text-success-400' : 'text-warning-600 dark:text-warning-400';
+ const statusIcon = isSupported ? 'circle-check' : 'triangle-exclamation';
+
+ html += `
+
+ ${(index + 1).toString().padStart(2, '0')}.
+
+ ${file.name}
+ (${(file.size / 1024).toFixed(1)}KB)
+
+ `;
+ });
+ html += '
';
+
+ filesListContent.innerHTML = html;
+ filesList.classList.remove('hidden');
+ } else {
+ filesList.classList.add('hidden');
+ }
+}
+
+function clearBatchSelection() {
+ document.getElementById('batchFiles').value = '';
+ updateSelectedFiles();
+}
+
+async function handleBatchImport(event) {
+ event.preventDefault();
+
+ if (importInProgress) {
+ showAlert('Import already in progress', 'warning');
+ return;
+ }
+
+ const fileInput = document.getElementById('batchFiles');
+ const replaceExisting = document.getElementById('batchReplaceExisting').checked;
+
+ if (!fileInput.files || fileInput.files.length === 0) {
+ showAlert('Please select at least one CSV file', 'warning');
+ return;
+ }
+
+ if (fileInput.files.length > 20) {
+ showAlert('Maximum 20 files allowed per batch', 'warning');
+ return;
+ }
+
+ importInProgress = true;
+
+ const formData = new FormData();
+ for (let file of fileInput.files) {
+ formData.append('files', file);
+ }
+ formData.append('replace_existing', replaceExisting);
+
+ try {
+ showProgress(true, 'Processing batch import...');
+
+ const response = await fetch('/api/import/batch-upload', {
+ method: 'POST',
+ headers: getAuthHeaders(),
+ body: formData
+ });
+
+ if (!response.ok) {
+ const error = await response.json();
+ throw new Error(error.detail || 'Batch import failed');
+ }
+
+ const result = await response.json();
+ displayBatchResults(result);
+
+ // Refresh status after successful import
+ await loadImportStatus();
+
+ // Reset form
+ document.getElementById('batchImportForm').reset();
+ updateSelectedFiles();
+
+ } catch (error) {
+ console.error('Batch import error:', error);
+ showAlert('Batch import failed: ' + error.message, 'danger');
+ } finally {
+ importInProgress = false;
+ showProgress(false);
+ }
+}
+
+function displayBatchResults(result) {
+ const panel = document.getElementById('batchResultsPanel');
+ const container = document.getElementById('batchResults');
+
+ const summary = result.summary;
+ const successRate = ((summary.total_imported / (summary.total_imported + summary.total_errors)) * 100) || 0;
+
+ let html = `
+
+
Batch Import Completed
+
+
+ Total Files: ${summary.total_files}
+
+
+ Successful: ${summary.successful_files}
+
+
+ Failed: ${summary.failed_files}
+
+
+ Total Records: ${summary.total_imported.toLocaleString()}
+
+
+
+ `;
+
+ // Individual file results
+ html += '
File Import Details
';
+ html += '
';
+
+ result.batch_results.forEach(fileResult => {
+ let statusClass, statusIcon;
+
+ if (fileResult.status === 'success') {
+ statusClass = 'success';
+ statusIcon = 'circle-check';
+ } else if (fileResult.status === 'completed_with_errors') {
+ statusClass = 'warning';
+ statusIcon = 'triangle-exclamation';
+ } else if (fileResult.status === 'skipped') {
+ statusClass = 'info';
+ statusIcon = 'circle-info';
+ } else {
+ statusClass = 'danger';
+ statusIcon = 'circle-xmark';
+ }
+
+ html += `
+
+
+
+
+ ${fileResult.file_type}
+
+
+ ${fileResult.imported_count ? `${fileResult.imported_count} imported` : ''}
+ ${fileResult.errors ? `${fileResult.errors} errors` : ''}
+
+
+
${fileResult.message}
+
+ `;
+ });
+
+ html += '
';
+
+ container.innerHTML = html;
+ panel.classList.remove('hidden');
+}
+
function showAlert(message, type = 'info') {
if (window.alerts && typeof window.alerts.show === 'function') {
window.alerts.show(message, type);