376 lines
18 KiB
JavaScript
376 lines
18 KiB
JavaScript
"use strict";
|
||
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
|
||
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
|
||
return new (P || (P = Promise))(function (resolve, reject) {
|
||
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
|
||
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
|
||
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
|
||
step((generator = generator.apply(thisArg, _arguments || [])).next());
|
||
});
|
||
};
|
||
var __importDefault = (this && this.__importDefault) || function (mod) {
|
||
return (mod && mod.__esModule) ? mod : { "default": mod };
|
||
};
|
||
Object.defineProperty(exports, "__esModule", { value: true });
|
||
require("dotenv/config");
|
||
const telegraf_1 = require("telegraf");
|
||
const start_1 = require("./commands/start");
|
||
const menuScenes_1 = require("./modules/menuScenes");
|
||
const express_1 = __importDefault(require("express"));
|
||
const cors_1 = __importDefault(require("cors"));
|
||
const events_1 = require("./modules/scenes/events");
|
||
const form_data_1 = __importDefault(require("form-data"));
|
||
const fs_1 = __importDefault(require("fs"));
|
||
const path_1 = __importDefault(require("path"));
|
||
const axios_1 = __importDefault(require("axios"));
|
||
const savevacansy_1 = require("./modules/scenes/savevacansy");
|
||
const accept_1 = require("./modules/scenes/accept");
|
||
const app = (0, express_1.default)();
|
||
const bot = new telegraf_1.Telegraf(process.env.BOT_TOKEN);
|
||
app.use((req, res, next) => {
|
||
req.bot = bot;
|
||
next();
|
||
});
|
||
app.use(express_1.default.json());
|
||
app.use((0, cors_1.default)());
|
||
bot.start(start_1.startCommand);
|
||
app.post('/api/resume', (req, res) => __awaiter(void 0, void 0, void 0, function* () {
|
||
try {
|
||
const postData = req.body;
|
||
const resumeTemplatePath = path_1.default.resolve(__dirname, 'assets', 'шаблон МТУСИ.docx');
|
||
yield bot.telegram.sendDocument(postData.id, { source: resumeTemplatePath }, { caption: 'Пример резюме' });
|
||
yield bot.telegram.sendMessage(postData.id, `Ваша анкета заполнена! Отправьте своё резюме для завершения регистрации`, {
|
||
reply_markup: {
|
||
inline_keyboard: [
|
||
[
|
||
{ text: 'Загрузить резюме', callback_data: 'uploadresume' },
|
||
// { text: 'Пропустить загрузку', callback_data: 'skip' },
|
||
],
|
||
],
|
||
},
|
||
});
|
||
console.log(`Ваш id ${postData.id}`);
|
||
return res.json({ status: 'success' });
|
||
}
|
||
catch (e) {
|
||
console.error('Error:', e);
|
||
res.status(500).json({ error: 'An error occurred' });
|
||
throw e;
|
||
}
|
||
}));
|
||
// const resumeScene: Scenes.WizardScene<MyWizardContext> = new Scenes.WizardScene(
|
||
// 'resumeScene',
|
||
// async ctx => {
|
||
// await ctx.reply(
|
||
// 'Отправьте своё резюме в PDF формате или отправьте /cancel для отмены.'
|
||
// );
|
||
// return ctx.wizard.next();
|
||
// },
|
||
// async ctx => {
|
||
// if (
|
||
// ctx.message &&
|
||
// 'text' in ctx.message &&
|
||
// ctx.from &&
|
||
// ctx.message.text == '/cancel'
|
||
// ) {
|
||
// await ctx.reply('Отправка резюме отменена.');
|
||
// await ctx.reply(
|
||
// 'Меню',
|
||
// Markup.keyboard([
|
||
// ['Моя анкета'],
|
||
// ['Вакансии'],
|
||
// ['Уведомления: включены'],
|
||
// ]).resize()
|
||
// );
|
||
// return ctx.scene.leave();
|
||
// }
|
||
// if (ctx.message && 'document' in ctx.message && ctx.from) {
|
||
// const file = ctx.message.document;
|
||
// if (file.mime_type !== 'application/pdf') {
|
||
// ctx.reply('Пожалуйста, отправьте файл в формате PDF.');
|
||
// return;
|
||
// }
|
||
// try {
|
||
// const fileLink = await ctx.telegram.getFileLink(file.file_id);
|
||
// const filePath = path.join(__dirname, `${file.file_id}.pdf`);
|
||
// // Загрузка файла на локальную машину
|
||
// const response = await axios.get(fileLink.href, {
|
||
// responseType: 'stream',
|
||
// });
|
||
// response.data
|
||
// .pipe(fs.createWriteStream(filePath))
|
||
// .on('finish', async () => {
|
||
// // Создание формы данных
|
||
// const form = new FormData();
|
||
// form.append('file', fs.createReadStream(filePath));
|
||
// try {
|
||
// // Установка времени ожидания (в миллисекундах)
|
||
// const uploadResponse = await axios.post(
|
||
// `${process.env.API}services/resume/`,
|
||
// form,
|
||
// {
|
||
// headers: {
|
||
// ...form.getHeaders(),
|
||
// 'X-API-KEY':
|
||
// 'SbRHOVoK97GKCx3Lqx6hKXLbZZJEd0GTGbeglXdpK9PhSB9kpr4eWCsuIIwnD6F2mgpTDlVHFCRbeFmuSfqBVsb12lNwF3P1tmdxiktl7zH9sDS2YK7Pyj2DecCWAZ3n',
|
||
// },
|
||
// timeout: 10000, // Увеличьте время ожидания до 10 секунд
|
||
// }
|
||
// );
|
||
// const fileName = uploadResponse.data.filename;
|
||
// // Выполнение PUT-запроса для обновления поля Link у студента
|
||
// await axios.patch(
|
||
// `${process.env.API}students/${
|
||
// ctx.from?.id
|
||
// }?Link=${encodeURIComponent(fileName)}`,
|
||
// {},
|
||
// {
|
||
// headers: {
|
||
// 'X-API-KEY':
|
||
// 'SbRHOVoK97GKCx3Lqx6hKXLbZZJEd0GTGbeglXdpK9PhSB9kpr4eWCsuIIwnD6F2mgpTDlVHFCRbeFmuSfqBVsb12lNwF3P1tmdxiktl7zH9sDS2YK7Pyj2DecCWAZ3n',
|
||
// 'Content-Type': 'application/json',
|
||
// },
|
||
// }
|
||
// );
|
||
// await ctx.reply('Резюме успешно загружено.');
|
||
// await ctx.reply(
|
||
// 'Меню',
|
||
// Markup.keyboard([
|
||
// ['Моя анкета'],
|
||
// ['Вакансии'],
|
||
// ['Уведомления: включены'],
|
||
// ]).resize()
|
||
// );
|
||
// return ctx.scene.leave();
|
||
// } catch (uploadError) {
|
||
// console.error('Ошибка при загрузке резюме на API:', uploadError);
|
||
// await ctx.reply('Произошла ошибка при загрузке резюме.');
|
||
// return ctx.scene.leave();
|
||
// } finally {
|
||
// // Удаление временного файла после загрузки
|
||
// fs.unlinkSync(filePath);
|
||
// }
|
||
// });
|
||
// } catch (error) {
|
||
// console.error('Ошибка при загрузке файла:', error);
|
||
// await ctx.reply('Произошла ошибка при загрузке файла.');
|
||
// }
|
||
// } else {
|
||
// await ctx.reply('Отправьте файл в формате PDF');
|
||
// }
|
||
// }
|
||
// );
|
||
const resumeScene = new telegraf_1.Scenes.WizardScene('resumeScene', (ctx) => __awaiter(void 0, void 0, void 0, function* () {
|
||
yield ctx.reply('Отправьте своё резюме в формате Word (DOC/DOCX) или отправьте /cancel для отмены.');
|
||
return ctx.wizard.next();
|
||
}), (ctx) => __awaiter(void 0, void 0, void 0, function* () {
|
||
if (ctx.message &&
|
||
'text' in ctx.message &&
|
||
ctx.from &&
|
||
ctx.message.text === '/cancel') {
|
||
yield ctx.reply('Отправка резюме отменена.');
|
||
yield ctx.reply('Меню', telegraf_1.Markup.keyboard([
|
||
['Моя анкета'],
|
||
['Вакансии'],
|
||
['Уведомления: включены'],
|
||
]).resize());
|
||
return ctx.scene.leave();
|
||
}
|
||
if (ctx.message && 'document' in ctx.message && ctx.from) {
|
||
const file = ctx.message.document;
|
||
const allowedMimeTypes = [
|
||
// 'application/pdf',
|
||
'application/msword',
|
||
'application/vnd.openxmlformats-officedocument.wordprocessingml.document',
|
||
];
|
||
if (!allowedMimeTypes.includes(file.mime_type || '')) {
|
||
yield ctx.reply('Пожалуйста, отправьте файл в формате DOC или DOCX.');
|
||
return;
|
||
}
|
||
try {
|
||
const fileLink = yield ctx.telegram.getFileLink(file.file_id);
|
||
const fileExtension = file.mime_type === 'application/pdf'
|
||
? 'pdf'
|
||
: file.mime_type === 'application/msword'
|
||
? 'doc'
|
||
: 'docx';
|
||
const filePath = path_1.default.join(__dirname, `${file.file_id}.${fileExtension}`);
|
||
// Загрузка файла на локальную машину
|
||
const response = yield axios_1.default.get(fileLink.href, {
|
||
responseType: 'stream',
|
||
});
|
||
response.data
|
||
.pipe(fs_1.default.createWriteStream(filePath))
|
||
.on('finish', () => __awaiter(void 0, void 0, void 0, function* () {
|
||
var _a;
|
||
const form = new form_data_1.default();
|
||
form.append('file', fs_1.default.createReadStream(filePath));
|
||
try {
|
||
const uploadResponse = yield axios_1.default.post(`${process.env.API}services/resume/`, form, {
|
||
headers: Object.assign(Object.assign({}, form.getHeaders()), { 'X-API-KEY': 'SbRHOVoK97GKCx3Lqx6hKXLbZZJEd0GTGbeglXdpK9PhSB9kpr4eWCsuIIwnD6F2mgpTDlVHFCRbeFmuSfqBVsb12lNwF3P1tmdxiktl7zH9sDS2YK7Pyj2DecCWAZ3n' }),
|
||
timeout: 10000,
|
||
});
|
||
const fileName = uploadResponse.data.filename;
|
||
yield axios_1.default.patch(`${process.env.API}students/${(_a = ctx.from) === null || _a === void 0 ? void 0 : _a.id}?Link=${encodeURIComponent(fileName)}`, {}, {
|
||
headers: {
|
||
'X-API-KEY': 'SbRHOVoK97GKCx3Lqx6hKXLbZZJEd0GTGbeglXdpK9PhSB9kpr4eWCsuIIwnD6F2mgpTDlVHFCRbeFmuSfqBVsb12lNwF3P1tmdxiktl7zH9sDS2YK7Pyj2DecCWAZ3n',
|
||
'Content-Type': 'application/json',
|
||
},
|
||
});
|
||
yield ctx.reply('Резюме успешно загружено.');
|
||
yield ctx.reply('Меню', telegraf_1.Markup.keyboard([
|
||
['Моя анкета'],
|
||
['Вакансии'],
|
||
['Уведомления: включены'],
|
||
]).resize());
|
||
return ctx.scene.leave();
|
||
}
|
||
catch (uploadError) {
|
||
console.error('Ошибка при загрузке резюме на API:', uploadError);
|
||
yield ctx.reply('Произошла ошибка при загрузке резюме.');
|
||
return ctx.scene.leave();
|
||
}
|
||
finally {
|
||
fs_1.default.unlinkSync(filePath);
|
||
}
|
||
}));
|
||
}
|
||
catch (error) {
|
||
console.error('Ошибка при загрузке файла:', error);
|
||
yield ctx.reply('Произошла ошибка при загрузке файла.');
|
||
}
|
||
}
|
||
else {
|
||
yield ctx.reply('Пожалуйста, отправьте файл в формате PDF, DOC или DOCX.');
|
||
}
|
||
}));
|
||
// app.post('/api/resume', async (req: Request, res: Response) => {
|
||
// try {
|
||
// const postData = req.body;
|
||
// // Проверяем наличие chatId в теле запроса
|
||
// if (!postData.StudentID) {
|
||
// throw new Error('Chat ID is missing in the request body');
|
||
// }
|
||
// const [userInstance, created] = await Resume.findOrCreate({
|
||
// where: { id: postData.StudentID },
|
||
// defaults: {
|
||
// id: postData.StudentID || 0,
|
||
// name: postData.Name,
|
||
// group: postData.Group,
|
||
// type: postData.Type,
|
||
// skills: '',
|
||
// softskills: postData.Soft_skills,
|
||
// email: postData.Email,
|
||
// },
|
||
// });
|
||
// await UserBase.update(
|
||
// { resume_id: postData.StudentID },
|
||
// { where: { id: postData.StudentID } }
|
||
// );
|
||
// if (userInstance instanceof Resume) {
|
||
// // userInstance теперь имеет тип User
|
||
// if (created) {
|
||
// console.log('New user created:', userInstance);
|
||
// } else {
|
||
// console.log('User already exists:', userInstance);
|
||
// }
|
||
// console.log('Привет! Вы успешно зарегистрированы.');
|
||
// } else {
|
||
// console.error('Ошибка: userInstance не является экземпляром User.');
|
||
// }
|
||
// console.log('Received data:', postData);
|
||
// res.status(200).json({ message: 'Data received successfully' });
|
||
// } catch (error) {
|
||
// console.error(error);
|
||
// res.status(500).json({ error: 'Internal Server Error' });
|
||
// }
|
||
// });
|
||
app.post('/webhook', (req, res) => __awaiter(void 0, void 0, void 0, function* () {
|
||
try {
|
||
const postData = req.body;
|
||
const entityType = postData.data.entity_type;
|
||
const updatedMatches = postData.data.updated_matches;
|
||
console.log(postData);
|
||
if (entityType === 'job') {
|
||
for (const match of updatedMatches) {
|
||
const chatId = match.student_id;
|
||
const jobId = match.entity_id; // Получаем ID вакансии
|
||
const messageText = 'Ваше совпадение с вакансией было обновлено. Вот детали вакансии:';
|
||
if (!chatId) {
|
||
throw new Error('Неправильный Chat ID (student_id) в теле запроса.');
|
||
}
|
||
// Выполняем GET-запрос для получения данных о вакансии
|
||
const response = yield axios_1.default.get(`${process.env.API}jobs/${jobId}`, // Запрашиваем данные о вакансии по её ID
|
||
{
|
||
headers: {
|
||
'X-API-KEY': 'SbRHOVoK97GKCx3Lqx6hKXLbZZJEd0GTGbeglXdpK9PhSB9kpr4eWCsuIIwnD6F2mgpTDlVHFCRbeFmuSfqBVsb12lNwF3P1tmdxiktl7zH9sDS2YK7Pyj2DecCWAZ3n',
|
||
},
|
||
});
|
||
const vacancyData = response.data; // Данные о вакансии
|
||
console.log(vacancyData);
|
||
// Отправляем вакансию пользователю
|
||
yield sendVacancyToUser(chatId, vacancyData);
|
||
console.log(`Сообщение с вакансией отправлено пользователю с ID ${chatId}`);
|
||
}
|
||
}
|
||
return res.status(200).json({ status: 'success' });
|
||
}
|
||
catch (e) {
|
||
console.error('Error:', e);
|
||
res.status(500).json({ error: 'Произошла ошибка при отправке сообщения' });
|
||
}
|
||
}));
|
||
// Функция для отправки вакансии пользователю
|
||
function sendVacancyToUser(chatId, data) {
|
||
return __awaiter(this, void 0, void 0, function* () {
|
||
yield bot.telegram.sendMessage(chatId, `<b>${data.Job_name}</b>\n\n` +
|
||
`<b>Компания:</b> ${data.Company_name}\n` +
|
||
`<b>Заработная плата:</b> ${data.Salary} руб/мес\n` +
|
||
`<b>Контактные данные:</b> ${data.Email}\n\n` +
|
||
`<b>Требования к кандидату:</b>\n` +
|
||
` - ${data.Year} курс\n` +
|
||
` - Опыт работы по специальности: ${data.Qualification}\n` +
|
||
` - Soft skills: ${data.Soft_skills}\n` +
|
||
`<b>Обязанности:</b>\n` +
|
||
`${data.Responsibilities}`, {
|
||
parse_mode: 'HTML', // Используем HTML для форматирования текста
|
||
reply_markup: {
|
||
inline_keyboard: [
|
||
[
|
||
{
|
||
text: 'Сохранить вакансию',
|
||
callback_data: `savevacancy+${data.JobID}`,
|
||
},
|
||
],
|
||
],
|
||
},
|
||
});
|
||
});
|
||
}
|
||
// Обработчик для получения файла резюме
|
||
const stage = new telegraf_1.Scenes.Stage([resumeScene]);
|
||
bot.use((0, telegraf_1.session)());
|
||
bot.use(stage.middleware());
|
||
bot.use(menuScenes_1.menuSceneMiddleware);
|
||
(0, events_1.events)(bot);
|
||
(0, accept_1.accept)(bot);
|
||
bot.action('uploadresume', (ctx) => __awaiter(void 0, void 0, void 0, function* () {
|
||
ctx.scene.enter('resumeScene');
|
||
ctx.answerCbQuery();
|
||
}));
|
||
(0, savevacansy_1.saveVacansy)(bot);
|
||
bot
|
||
.launch({
|
||
webhook: {
|
||
domain: process.env.DOMAIN || '',
|
||
port: parseInt(process.env.HOOKPORT || ''),
|
||
},
|
||
})
|
||
.then(() => console.log('Webhook bot listening on port', parseInt(process.env.HOOKPORT || '')));
|
||
// bot.launch().then(() => {
|
||
// console.log('Бот запущен');
|
||
// });
|
||
app.listen(process.env.PORT, () => {
|
||
console.log(`Server is running at http://localhost:${process.env.PORT}`);
|
||
});
|