kalugin66/minicrm
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

doc

Browse Source
This commit is contained in:
kalugin66
2026-01-27 15:12:27 +05:00
parent d2c530bb3a
commit 9714ac5004
6 changed files with 2499 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

438
server.js
View File

@@ -14,7 +14,6 @@ const { sendTaskNotifications, checkUpcomingDeadlines, getStatusText } = require
const { setupUploadMiddleware } = require('./upload-middleware');
const { setupTaskEndpoints } = require('./task-endpoints');
const app = express();
const PORT = process.env.PORT || 3000;
@@ -24,6 +23,37 @@ let serverReady = false;
let adminRouter = null;
let upload = null;
// Инициализируем multer сразу с настройками по умолчанию
const uploadsDir = path.join(__dirname, 'data', 'uploads');
const createDirIfNotExists = (dirPath) => {
if (!fs.existsSync(dirPath)) {
fs.mkdirSync(dirPath, { recursive: true });
}
};
createDirIfNotExists(uploadsDir);
// Создаем базовую конфигурацию multer
const storage = multer.diskStorage({
destination: function (req, file, cb) {
cb(null, uploadsDir);
},
filename: function (req, file, cb) {
// Используем оригинальное имя файла с timestamp для уникальности
const uniqueSuffix = Date.now() + '-' + Math.round(Math.random() * 1E9);
const ext = path.extname(file.originalname);
const name = path.basename(file.originalname, ext);
cb(null, name + '-' + uniqueSuffix + ext);
}
});
// Создаем экземпляр multer сразу
upload = multer({
storage: storage,
limits: {
fileSize: 50 * 1024 * 1024 // 50MB
}
});
// Middleware
app.use(express.json());
app.use(express.urlencoded({ extended: true }));
@@ -40,7 +70,6 @@ app.use(session({
}
}));
// Middleware для проверки готовности сервера
app.use((req, res, next) => {
if (!serverReady && req.path !== '/health' && req.path !== '/api/health') {
@@ -72,12 +101,6 @@ app.get('/api/health', (req, res) => {
});
// Вспомогательные функции
const createDirIfNotExists = (dirPath) => {
if (!fs.existsSync(dirPath)) {
fs.mkdirSync(dirPath, { recursive: true });
}
};
function checkIfOverdue(dueDate, status) {
if (!dueDate || status === 'completed') return false;
const now = new Date();
@@ -552,6 +575,7 @@ app.get('/admin', (req, res) => {
}
res.sendFile(path.join(__dirname, 'public/admin.html'));
});
// Страница профилей пользователей (только для админов)
app.get('/admin/profiles', (req, res) => {
if (!req.session.user || req.session.user.role !== 'admin') {
@@ -559,6 +583,7 @@ app.get('/admin/profiles', (req, res) => {
}
res.sendFile(path.join(__dirname, 'public/admin-profiles.html'));
});
// Админ панель для документов
app.get('/admin-doc', (req, res) => {
if (!req.session.user || req.session.user.role !== 'admin') {
@@ -575,6 +600,387 @@ app.get('/doc', (req, res) => {
res.sendFile(path.join(__dirname, 'public/doc.html'));
});
// API для типов документов
app.get('/api/document-types', requireAuth, (req, res) => {
db.all("SELECT * FROM document_types ORDER BY name", [], (err, rows) => {
if (err) {
res.status(500).json({ error: err.message });
return;
}
res.json(rows);
});
});
// API для документов (ИСПРАВЛЕНО: upload определен в начале файла)
app.post('/api/documents', requireAuth, upload.array('files', 15), async (req, res) => {
try {
const userId = req.session.user.id;
const {
title,
description,
dueDate,
documentTypeId,
documentNumber,
documentDate,
pagesCount,
urgencyLevel,
comment
} = req.body;
// Находим группу "Секретарь"
db.get("SELECT id FROM users WHERE groups LIKE '%Секретарь%' OR groups LIKE '%\"Секретарь\"%' LIMIT 1", async (err, secretary) => {
if (err) {
return res.status(500).json({ error: err.message });
}
if (!secretary) {
return res.status(400).json({ error: 'Не найден секретарь для согласования документов' });
}
// Создаем задачу
db.run(`
INSERT INTO tasks (title, description, due_date, created_by, status)
VALUES (?, ?, ?, ?, 'assigned')
`, [title, description, dueDate || null, userId], function(err) {
if (err) {
return res.status(500).json({ error: err.message });
}
const taskId = this.lastID;
// Создаем запись документа
db.run(`
INSERT INTO documents (
task_id, document_type_id, document_number,
document_date, pages_count, urgency_level, comment
) VALUES (?, ?, ?, ?, ?, ?, ?)
`, [
taskId,
documentTypeId || null,
documentNumber || null,
documentDate || null,
pagesCount || null,
urgencyLevel || 'normal',
comment || null
], function(err) {
if (err) {
// Удаляем задачу если не удалось создать документ
db.run("DELETE FROM tasks WHERE id = ?", [taskId]);
return res.status(500).json({ error: err.message });
}
// Назначаем задачу секретарю
db.run(`
INSERT INTO task_assignments (task_id, user_id, status)
VALUES (?, ?, 'assigned')
`, [taskId, secretary.id], function(err) {
if (err) {
return res.status(500).json({ error: err.message });
}
// Загружаем файлы если есть
if (req.files && req.files.length > 0) {
const uploadPromises = req.files.map(file => {
return new Promise((resolve, reject) => {
const filePath = file.path;
const originalName = Buffer.from(file.originalname, 'latin1').toString('utf8');
db.run(`
INSERT INTO task_files (task_id, user_id, file_path, original_name, file_size)
VALUES (?, ?, ?, ?, ?)
`, [taskId, userId, filePath, originalName, file.size], function(err) {
if (err) reject(err);
else resolve();
});
});
});
Promise.all(uploadPromises)
.then(() => {
const { logActivity } = require('./database');
logActivity(taskId, userId, 'TASK_CREATED', `Создан документ для согласования: ${title}`);
res.json({ success: true, taskId: taskId });
})
.catch(error => {
console.error('Ошибка загрузки файлов:', error);
res.json({ success: true, taskId: taskId });
});
} else {
const { logActivity } = require('./database');
logActivity(taskId, userId, 'TASK_CREATED', `Создан документ для согласования: ${title}`);
res.json({ success: true, taskId: taskId });
}
});
});
});
});
} catch (error) {
console.error('Ошибка создания документа:', error);
res.status(500).json({ error: 'Ошибка создания документа' });
}
});
// Получение моих документов
app.get('/api/documents/my', requireAuth, (req, res) => {
const userId = req.session.user.id;
db.all(`
SELECT
t.id,
t.title,
t.description,
t.due_date,
t.created_at,
t.status,
d.document_type_id,
dt.name as document_type_name,
d.document_number,
d.document_date,
d.pages_count,
d.urgency_level,
d.comment,
d.refusal_reason,
u.name as creator_name,
GROUP_CONCAT(tf.id) as file_ids
FROM tasks t
LEFT JOIN documents d ON t.id = d.task_id
LEFT JOIN document_types dt ON d.document_type_id = dt.id
LEFT JOIN users u ON t.created_by = u.id
LEFT JOIN task_files tf ON t.id = tf.task_id
WHERE t.created_by = ?
AND t.title LIKE 'Документ:%'
GROUP BY t.id
ORDER BY t.created_at DESC
`, [userId], async (err, tasks) => {
if (err) {
return res.status(500).json({ error: err.message });
}
// Загружаем файлы для каждой задачи
const tasksWithFiles = await Promise.all(tasks.map(async (task) => {
if (task.file_ids) {
const fileIds = task.file_ids.split(',').filter(id => id);
const files = await new Promise((resolve, reject) => {
db.all(`
SELECT tf.*, u.name as user_name
FROM task_files tf
LEFT JOIN users u ON tf.user_id = u.id
WHERE tf.id IN (${fileIds.map(() => '?').join(',')})
`, fileIds, (err, rows) => {
if (err) reject(err);
else resolve(rows);
});
});
task.files = files;
} else {
task.files = [];
}
return task;
}));
res.json(tasksWithFiles);
});
});
// Получение документов для секретаря
app.get('/api/documents/secretary', requireAuth, (req, res) => {
const userId = req.session.user.id;
// Проверяем, что пользователь секретарь
if (!req.session.user.groups || !req.session.user.groups.includes('Секретарь')) {
return res.status(403).json({ error: 'Недостаточно прав' });
}
db.all(`
SELECT
t.id,
t.title,
t.description,
t.due_date,
t.created_at,
ta.status,
d.document_type_id,
dt.name as document_type_name,
d.document_number,
d.document_date,
d.pages_count,
d.urgency_level,
d.comment,
d.refusal_reason,
u.name as creator_name,
GROUP_CONCAT(tf.id) as file_ids
FROM tasks t
JOIN task_assignments ta ON t.id = ta.task_id
LEFT JOIN documents d ON t.id = d.task_id
LEFT JOIN document_types dt ON d.document_type_id = dt.id
LEFT JOIN users u ON t.created_by = u.id
LEFT JOIN task_files tf ON t.id = tf.task_id
WHERE ta.user_id = ?
AND t.title LIKE 'Документ:%'
AND t.status = 'active'
AND t.closed_at IS NULL
GROUP BY t.id
ORDER BY
CASE d.urgency_level
WHEN 'very_urgent' THEN 1
WHEN 'urgent' THEN 2
ELSE 3
END,
t.due_date ASC,
t.created_at DESC
`, [userId], async (err, tasks) => {
if (err) {
return res.status(500).json({ error: err.message });
}
// Загружаем файлы для каждой задачи
const tasksWithFiles = await Promise.all(tasks.map(async (task) => {
if (task.file_ids) {
const fileIds = task.file_ids.split(',').filter(id => id);
const files = await new Promise((resolve, reject) => {
db.all(`
SELECT tf.*, u.name as user_name
FROM task_files tf
LEFT JOIN users u ON tf.user_id = u.id
WHERE tf.id IN (${fileIds.map(() => '?').join(',')})
`, fileIds, (err, rows) => {
if (err) reject(err);
else resolve(rows);
});
});
task.files = files;
} else {
task.files = [];
}
return task;
}));
res.json(tasksWithFiles);
});
});
// Обновление статуса документа
app.put('/api/documents/:id/status', requireAuth, (req, res) => {
const documentId = req.params.id;
const { status, comment, refusalReason } = req.body;
const userId = req.session.user.id;
// Проверяем права (только секретарь или администратор)
if (!req.session.user.groups || !req.session.user.groups.includes('Секретарь')) {
if (req.session.user.role !== 'admin') {
return res.status(403).json({ error: 'Недостаточно прав' });
}
}
db.get("SELECT task_id FROM documents WHERE id = ?", [documentId], (err, document) => {
if (err || !document) {
return res.status(404).json({ error: 'Документ не найден' });
}
const taskId = document.task_id;
// Обновляем статус в задании
db.run("UPDATE task_assignments SET status = ? WHERE task_id = ? AND user_id = ?",
[status, taskId, userId], function(err) {
if (err) {
return res.status(500).json({ error: err.message });
}
// Обновляем причину отказа если есть
if (refusalReason) {
db.run("UPDATE documents SET refusal_reason = ? WHERE id = ?",
[refusalReason, documentId]);
}
// Логируем действие
const { logActivity } = require('./database');
const actionMap = {
'approved': 'Документ согласован',
'received': 'Оригинал документа получен',
'signed': 'Документ подписан',
'refused': 'В согласовании отказано'
};
const actionText = actionMap[status] || `Статус изменен на: ${status}`;
logActivity(taskId, userId, 'STATUS_CHANGED', actionText);
res.json({ success: true });
}
);
});
});
// Отзыв документа
app.post('/api/documents/:id/cancel', requireAuth, (req, res) => {
const documentId = req.params.id;
const userId = req.session.user.id;
db.get("SELECT task_id FROM documents WHERE id = ?", [documentId], (err, document) => {
if (err || !document) {
return res.status(404).json({ error: 'Документ не найден' });
}
const taskId = document.task_id;
// Проверяем, что пользователь создатель задачи
db.get("SELECT created_by FROM tasks WHERE id = ?", [taskId], (err, task) => {
if (err || !task) {
return res.status(404).json({ error: 'Задача не найдена' });
}
if (parseInt(task.created_by) !== parseInt(userId)) {
return res.status(403).json({ error: 'Вы не являетесь создателем этого документа' });
}
// Обновляем статус задачи
db.run("UPDATE tasks SET status = 'cancelled' WHERE id = ?", [taskId], function(err) {
if (err) {
return res.status(500).json({ error: err.message });
}
// Логируем действие
const { logActivity } = require('./database');
logActivity(taskId, userId, 'STATUS_CHANGED', 'Документ отозван создателем');
res.json({ success: true });
});
});
});
});
// Получение пакета документов
app.get('/api/documents/:id/package', requireAuth, async (req, res) => {
const documentId = req.params.id;
const userId = req.session.user.id;
// Проверяем доступ к документу
db.get(`
SELECT t.id, t.created_by
FROM documents d
JOIN tasks t ON d.task_id = t.id
WHERE d.id = ?
`, [documentId], async (err, result) => {
if (err || !result) {
return res.status(404).json({ error: 'Документ не найден' });
}
// Проверяем, что пользователь имеет доступ (создатель или секретарь)
const isCreator = parseInt(result.created_by) === parseInt(userId);
const isSecretary = req.session.user.groups && req.session.user.groups.includes('Секретарь');
if (!isCreator && !isSecretary) {
return res.status(403).json({ error: 'Недостаточно прав' });
}
// Здесь будет логика создания ZIP архива с документами
// Пока возвращаем заглушку
res.json({
success: true,
message: 'Функция создания пакета документов будет реализована в следующей версии'
});
});
});
// API для получения настроек уведомлений пользователя
app.get('/api/user/settings', requireAuth, async (req, res) => {
try {
@@ -782,6 +1188,7 @@ app.get('/api/email-health', requireAuth, async (req, res) => {
res.status(500).json({ error: error.message });
}
});
// Страница управления группами
app.get('/admin/groups', (req, res) => {
if (!req.session.user || req.session.user.role !== 'admin') {
@@ -789,6 +1196,7 @@ app.get('/admin/groups', (req, res) => {
}
res.sendFile(path.join(__dirname, 'public/admin-groups.html'));
});
// Инициализация сервера
async function initializeServer() {
console.log('🚀 Инициализация сервера...');
@@ -801,20 +1209,20 @@ async function initializeServer() {
// 2. Получаем объект БД
db = getDb();
console.log('✅ База данных готова');
const { initializeDocumentTypes } = require('./init-document-types');
initializeDocumentTypes(db);
console.log('✅ Сервис document готов');
// 3. Настраиваем authService с БД
authService.setDatabase(db);
console.log('✅ Сервис аутентификации готов');
// 4. Настраиваем загрузку файлов
upload = setupUploadMiddleware();
console.log('✅ Middleware загрузки файлов настроен');
// 5. Настраиваем endpoint'ы для задач
// 4. Настраиваем endpoint'ы для задач (upload уже настроен в начале файла)
setupTaskEndpoints(app, db, upload);
console.log('✅ Endpoint\'ы задач настроены');
// 6. Загружаем админ роутер динамически
// 5. Загружаем админ роутер динамически
try {
adminRouter = require('./admin-server');
console.log('Admin router loaded:', adminRouter);
@@ -851,7 +1259,7 @@ async function initializeServer() {
console.log('⚠️ Создана заглушка для админ роутера из-за ошибки');
}
// 7. Помечаем сервер как готовый
// 6. Помечаем сервер как готовый
serverReady = true;
console.log('✅ Сервер полностью инициализирован');