119 lines
4.4 KiB
JavaScript
119 lines
4.4 KiB
JavaScript
const jsdom = require('jsdom');
|
|
const mysql = require('mysql');
|
|
|
|
module.exports = Self => {
|
|
Self.remoteMethodCtx('closeTicket', {
|
|
description: 'Close tickets without response from the user',
|
|
accessType: 'READ',
|
|
returns: {
|
|
type: 'Object',
|
|
root: true
|
|
},
|
|
http: {
|
|
path: `/closeTicket`,
|
|
verb: 'POST'
|
|
}
|
|
});
|
|
|
|
Self.closeTicket = async ctx => {
|
|
const models = Self.app.models;
|
|
const config = await models.OsTicketConfig.findOne();
|
|
const ostUri = `${config.host}/login.php`;
|
|
|
|
if (!config.user || !config.password || !config.userDb || !config.passwordDb)
|
|
return false;
|
|
|
|
const con = mysql.createConnection({
|
|
host: `${config.hostDb}`,
|
|
user: `${config.userDb}`,
|
|
password: `${config.passwordDb}`,
|
|
port: `${config.portDb}`
|
|
});
|
|
|
|
const sql = `SELECT ot.ticket_id, ot.number
|
|
FROM osticket.ost_ticket ot
|
|
JOIN osticket.ost_ticket_status ots ON ots.id = ot.status_id
|
|
JOIN osticket.ost_thread ot2 ON ot2.object_id = ot.ticket_id AND ot2.object_type = 'T'
|
|
JOIN (
|
|
SELECT ote.thread_id, MAX(ote.created) created, MAX(ote.updated) updated
|
|
FROM osticket.ost_thread_entry ote
|
|
WHERE ote.staff_id != 0 AND ote.type = 'R'
|
|
GROUP BY ote.thread_id
|
|
) sub ON sub.thread_id = ot2.id
|
|
WHERE ot.isanswered = 1
|
|
AND ots.state = '${config.oldStatus}'
|
|
AND IF(sub.updated > sub.created, sub.updated, sub.created) < DATE_SUB(CURDATE(), INTERVAL ${config.day} DAY)`;
|
|
|
|
let ticketsId = [];
|
|
con.connect(err => {
|
|
if (err) throw err;
|
|
con.query(sql, (err, results) => {
|
|
if (err) throw err;
|
|
for (const result of results)
|
|
ticketsId.push(result.ticket_id);
|
|
});
|
|
});
|
|
|
|
await requestToken();
|
|
|
|
async function requestToken() {
|
|
const response = await fetch(ostUri);
|
|
|
|
const result = response.headers.get('set-cookie');
|
|
const [firtHeader] = result.split(' ');
|
|
const firtCookie = firtHeader.substring(0, firtHeader.length - 1);
|
|
const body = await response.text();
|
|
const dom = new jsdom.JSDOM(body);
|
|
const token = dom.window.document.querySelector('[name="__CSRFToken__"]').value;
|
|
|
|
await login(token, firtCookie);
|
|
}
|
|
|
|
async function login(token, firtCookie) {
|
|
const data = {
|
|
__CSRFToken__: token,
|
|
do: 'scplogin',
|
|
userid: config.user,
|
|
passwd: config.password,
|
|
ajax: 1
|
|
};
|
|
const params = {
|
|
method: 'POST',
|
|
body: new URLSearchParams(data),
|
|
headers: {
|
|
'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8',
|
|
'Cookie': firtCookie
|
|
}
|
|
};
|
|
const response = await fetch(ostUri, params);
|
|
const result = response.headers.get('set-cookie');
|
|
const [firtHeader] = result.split(' ');
|
|
const secondCookie = firtHeader.substring(0, firtHeader.length - 1);
|
|
|
|
await close(token, secondCookie);
|
|
}
|
|
|
|
async function close(token, secondCookie) {
|
|
for (const ticketId of ticketsId) {
|
|
const ostUri = `${config.host}/ajax.php/tickets/${ticketId}/status`;
|
|
const data = {
|
|
status_id: config.newStatusId,
|
|
comments: config.comment,
|
|
undefined: config.action
|
|
};
|
|
const params = {
|
|
method: 'POST',
|
|
body: new URLSearchParams(data),
|
|
headers: {
|
|
'Content-Type': 'application/x-www-form-urlencoded; charset=UTF-8',
|
|
'X-CSRFToken': token,
|
|
'Cookie': secondCookie
|
|
}
|
|
};
|
|
|
|
return fetch(ostUri, params);
|
|
}
|
|
}
|
|
};
|
|
};
|