Compare commits
5 Commits
bae3d86f2f
...
bbc3dbb047
Author | SHA1 | Date |
---|---|---|
adriano | bbc3dbb047 | |
adriano | b15fd47c8b | |
adriano | df9d468700 | |
adriano | f9594aa114 | |
adriano | 1bb4f7562f |
|
@ -11,8 +11,8 @@ import Queue from "../models/Queue";
|
||||||
import UserOnlineTime from "../models/UserOnlineTime";
|
import UserOnlineTime from "../models/UserOnlineTime";
|
||||||
|
|
||||||
import { Op, Sequelize, literal } from "sequelize";
|
import { Op, Sequelize, literal } from "sequelize";
|
||||||
import format from 'date-fns/format';
|
import format from "date-fns/format";
|
||||||
import ptBR from 'date-fns/locale/pt-BR';
|
import ptBR from "date-fns/locale/pt-BR";
|
||||||
import { splitDateTime } from "../helpers/SplitDateTime";
|
import { splitDateTime } from "../helpers/SplitDateTime";
|
||||||
import ListUserOnlineOffline from "../services/UserServices/ListUsersOnlineOfflineService";
|
import ListUserOnlineOffline from "../services/UserServices/ListUsersOnlineOfflineService";
|
||||||
import ListUserParamiterService from "../services/UserServices/ListUserParamiterService";
|
import ListUserParamiterService from "../services/UserServices/ListUserParamiterService";
|
||||||
|
@ -23,8 +23,7 @@ import CountTicketsByUserQueue from "../services/UserServices/CountTicketsByUser
|
||||||
|
|
||||||
import ShowQueuesByUser from "../services/UserServices/ShowQueuesByUser";
|
import ShowQueuesByUser from "../services/UserServices/ShowQueuesByUser";
|
||||||
|
|
||||||
|
// import { filter } from "bluebird";
|
||||||
// import { filter } from "bluebird";
|
|
||||||
|
|
||||||
import { getIO } from "../libs/socket";
|
import { getIO } from "../libs/socket";
|
||||||
import { Json } from "sequelize/types/lib/utils";
|
import { Json } from "sequelize/types/lib/utils";
|
||||||
|
@ -39,82 +38,125 @@ type IndexQuery = {
|
||||||
type ReportOnQueue = {
|
type ReportOnQueue = {
|
||||||
userId: string;
|
userId: string;
|
||||||
identifier: string;
|
identifier: string;
|
||||||
}
|
};
|
||||||
|
|
||||||
|
|
||||||
export const reportUserByDateStartDateEnd = async (req: Request, res: Response): Promise<Response> => {
|
|
||||||
|
|
||||||
|
export const reportUserByDateStartDateEnd = async (
|
||||||
|
req: Request,
|
||||||
|
res: Response
|
||||||
|
): Promise<Response> => {
|
||||||
if (req.user.profile !== "master" && req.user.profile !== "admin") {
|
if (req.user.profile !== "master" && req.user.profile !== "admin") {
|
||||||
throw new AppError("ERR_NO_PERMISSION", 403);
|
throw new AppError("ERR_NO_PERMISSION", 403);
|
||||||
}
|
}
|
||||||
|
|
||||||
const { userId, startDate, endDate, pageNumber } = req.query as IndexQuery
|
const { userId, startDate, endDate, pageNumber } = req.query as IndexQuery;
|
||||||
|
|
||||||
const { tickets, count, hasMore } = await ShowTicketReport({ userId, startDate, endDate, pageNumber });
|
const { tickets, count, hasMore } = await ShowTicketReport({
|
||||||
|
userId,
|
||||||
|
startDate,
|
||||||
|
endDate,
|
||||||
|
pageNumber
|
||||||
|
});
|
||||||
|
|
||||||
return res.status(200).json({ tickets, count, hasMore });
|
return res.status(200).json({ tickets, count, hasMore });
|
||||||
};
|
};
|
||||||
|
|
||||||
|
export const reportUserService = async (
|
||||||
export const reportUserService = async (req: Request, res: Response): Promise<Response> => {
|
req: Request,
|
||||||
|
res: Response
|
||||||
|
): Promise<Response> => {
|
||||||
if (req.user.profile !== "master" && req.user.profile !== "admin") {
|
if (req.user.profile !== "master" && req.user.profile !== "admin") {
|
||||||
throw new AppError("ERR_NO_PERMISSION", 403);
|
throw new AppError("ERR_NO_PERMISSION", 403);
|
||||||
}
|
}
|
||||||
const { userId, startDate, endDate } = req.query as IndexQuery
|
const { userId, startDate, endDate } = req.query as IndexQuery;
|
||||||
|
|
||||||
|
let usersProfile = await ListUserParamiterService({
|
||||||
|
profile: "user",
|
||||||
|
raw: true
|
||||||
|
});
|
||||||
|
|
||||||
let usersProfile = await ListUserParamiterService({ profile: 'user' })
|
const sumUserOlineTime = await ShowUserServiceReport({
|
||||||
|
startDate,
|
||||||
|
endDate,
|
||||||
|
userId
|
||||||
|
});
|
||||||
|
const closedByUser = await ShowUserServiceReport({
|
||||||
|
startDate,
|
||||||
|
endDate,
|
||||||
|
ticketStatus: "closed",
|
||||||
|
userId
|
||||||
|
});
|
||||||
|
const openByUser = await ShowUserServiceReport({
|
||||||
|
startDate,
|
||||||
|
endDate,
|
||||||
|
ticketStatus: "open",
|
||||||
|
userId
|
||||||
|
});
|
||||||
|
|
||||||
const sumUserOlineTime = await ShowUserServiceReport({ startDate, endDate, userId });
|
let dateTime = splitDateTime(
|
||||||
const closedByUser = await ShowUserServiceReport({ startDate, endDate, ticketStatus: 'closed', userId });
|
new Date(format(new Date(), "yyyy-MM-dd HH:mm:ss", { locale: ptBR }))
|
||||||
const openByUser = await ShowUserServiceReport({ startDate, endDate, ticketStatus: 'open', userId });
|
);
|
||||||
|
const onlineUsers = await ListUserOnlineOffline({ date: dateTime.fullDate });
|
||||||
|
|
||||||
let dateTime = splitDateTime(new Date(format(new Date(), 'yyyy-MM-dd HH:mm:ss', { locale: ptBR })))
|
const openByUserOnQueue = await CountTicketsByUserQueue({
|
||||||
const onlineUsers = await ListUserOnlineOffline({ date: dateTime.fullDate })
|
startDate: startDate,
|
||||||
|
endDate: endDate,
|
||||||
|
status: "open",
|
||||||
|
clientChatStart: true
|
||||||
|
});
|
||||||
|
const openByUserOutQueue = await CountTicketsByUserQueue({
|
||||||
|
startDate: startDate,
|
||||||
|
endDate: endDate,
|
||||||
|
status: "open",
|
||||||
|
clientChatStart: false
|
||||||
|
});
|
||||||
|
|
||||||
const openByUserOnQueue = await CountTicketsByUserQueue({ startDate: startDate, endDate: endDate, status: 'open', clientChatStart: true })
|
const closedByUserOnQueue = await CountTicketsByUserQueue({
|
||||||
const openByUserOutQueue = await CountTicketsByUserQueue({ startDate: startDate, endDate: endDate, status: 'open', clientChatStart: false })
|
startDate: startDate,
|
||||||
|
endDate: endDate,
|
||||||
const closedByUserOnQueue = await CountTicketsByUserQueue({ startDate: startDate, endDate: endDate, status: 'closed', clientChatStart: true })
|
status: "closed",
|
||||||
const closedUserOutQueue = await CountTicketsByUserQueue({ startDate: startDate, endDate: endDate, status: 'closed', clientChatStart: false })
|
clientChatStart: true
|
||||||
|
});
|
||||||
|
const closedUserOutQueue = await CountTicketsByUserQueue({
|
||||||
|
startDate: startDate,
|
||||||
|
endDate: endDate,
|
||||||
|
status: "closed",
|
||||||
|
clientChatStart: false
|
||||||
|
});
|
||||||
|
|
||||||
// let openQueueInOut = openByUserOnQueue.concat(openByUserOutQueue)
|
// let openQueueInOut = openByUserOnQueue.concat(openByUserOutQueue)
|
||||||
// let closedQueueInOut = closedByUserOnQueue.concat(closedUserOutQueue)
|
// let closedQueueInOut = closedByUserOnQueue.concat(closedUserOutQueue)
|
||||||
|
|
||||||
|
const queuesByUser = await ShowQueuesByUser({ profile: "user" });
|
||||||
|
|
||||||
const queuesByUser = await ShowQueuesByUser({ profile: 'user' })
|
let openCloseOnQueue = openByUserOnQueue.concat(closedByUserOnQueue);
|
||||||
|
let openCloseOutQueue = openByUserOutQueue.concat(closedUserOutQueue);
|
||||||
let openCloseOnQueue = openByUserOnQueue.concat(closedByUserOnQueue)
|
|
||||||
let openCloseOutQueue = openByUserOutQueue.concat(closedUserOutQueue)
|
|
||||||
|
|
||||||
|
|
||||||
// console.log('onlineUsers: ',JSON.parse(JSON.stringify(onlineUsers)))
|
// console.log('onlineUsers: ',JSON.parse(JSON.stringify(onlineUsers)))
|
||||||
// console.log('sumUserOlineTime: ', JSON.parse(JSON.stringify(sumUserOlineTime)))
|
// console.log('sumUserOlineTime: ', JSON.parse(JSON.stringify(sumUserOlineTime)))
|
||||||
|
|
||||||
for (let i = 0; i < queuesByUser.length; i++) {
|
for (let i = 0; i < queuesByUser.length; i++) {
|
||||||
|
queuesByUser[i].countOpen = 0;
|
||||||
queuesByUser[i].countOpen = 0
|
queuesByUser[i].countClosed = 0;
|
||||||
queuesByUser[i].countClosed = 0
|
|
||||||
|
|
||||||
for (let x = 0; x < openCloseOnQueue.length; x++) {
|
for (let x = 0; x < openCloseOnQueue.length; x++) {
|
||||||
if ((queuesByUser[i].userId == openCloseOnQueue[x].userId) &&
|
if (
|
||||||
(queuesByUser[i].queueId == openCloseOnQueue[x].queueId && openCloseOnQueue[x].status == 'open')) {
|
queuesByUser[i].userId == openCloseOnQueue[x].userId &&
|
||||||
queuesByUser[i].countOpen = openCloseOnQueue[x].totAttendance
|
queuesByUser[i].queueId == openCloseOnQueue[x].queueId &&
|
||||||
|
openCloseOnQueue[x].status == "open"
|
||||||
|
) {
|
||||||
|
queuesByUser[i].countOpen = openCloseOnQueue[x].totAttendance;
|
||||||
|
} else if (
|
||||||
|
queuesByUser[i].userId == openCloseOnQueue[x].userId &&
|
||||||
|
queuesByUser[i].queueId == openCloseOnQueue[x].queueId &&
|
||||||
|
openCloseOnQueue[x].status == "closed"
|
||||||
|
) {
|
||||||
|
queuesByUser[i].countClosed = openCloseOnQueue[x].totAttendance;
|
||||||
}
|
}
|
||||||
else if ((queuesByUser[i].userId == openCloseOnQueue[x].userId) &&
|
|
||||||
(queuesByUser[i].queueId == openCloseOnQueue[x].queueId && openCloseOnQueue[x].status == 'closed')) {
|
|
||||||
queuesByUser[i].countClosed = openCloseOnQueue[x].totAttendance
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
usersProfile.map((user: any) => {
|
usersProfile.map((user: any) => {
|
||||||
|
let index = sumUserOlineTime.findIndex((e: any) => e.userId == user.id);
|
||||||
let index = sumUserOlineTime.findIndex((e: any) => e.userId == user.id)
|
|
||||||
|
|
||||||
if (index != -1) {
|
if (index != -1) {
|
||||||
user.sumOnlineTime = sumUserOlineTime[index];
|
user.sumOnlineTime = sumUserOlineTime[index];
|
||||||
|
@ -122,101 +164,97 @@ export const reportUserService = async (req: Request, res: Response): Promise<Re
|
||||||
// console.log('user.sumOlineTime: 'user.sumOnlineTime)
|
// console.log('user.sumOlineTime: 'user.sumOnlineTime)
|
||||||
}
|
}
|
||||||
|
|
||||||
index = closedByUser.findIndex((e: any) => e.userId == user.id)
|
index = closedByUser.findIndex((e: any) => e.userId == user.id);
|
||||||
|
|
||||||
if (index != -1) {
|
if (index != -1) {
|
||||||
user.sumClosed = closedByUser[index];
|
user.sumClosed = closedByUser[index];
|
||||||
}
|
}
|
||||||
|
|
||||||
index = openByUser.findIndex((e: any) => e.userId == user.id)
|
index = openByUser.findIndex((e: any) => e.userId == user.id);
|
||||||
|
|
||||||
if (index != -1) {
|
if (index != -1) {
|
||||||
user.sumOpen = openByUser[index]
|
user.sumOpen = openByUser[index];
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
// OPEN, CLOSED TICKETS STARTED BY USERS
|
// OPEN, CLOSED TICKETS STARTED BY USERS
|
||||||
let openClosedOutQueue = {}
|
let openClosedOutQueue = {};
|
||||||
let open = openCloseOutQueue.filter((e) => e.userId == user.id && e.status == 'open')
|
let open = openCloseOutQueue.filter(
|
||||||
let closed = openCloseOutQueue.filter((e) => e.userId == user.id && e.status == 'closed')
|
e => e.userId == user.id && e.status == "open"
|
||||||
|
);
|
||||||
|
let closed = openCloseOutQueue.filter(
|
||||||
|
e => e.userId == user.id && e.status == "closed"
|
||||||
|
);
|
||||||
|
|
||||||
openClosedOutQueue = {
|
openClosedOutQueue = {
|
||||||
...openClosedOutQueue,
|
...openClosedOutQueue,
|
||||||
userId: user.id,
|
userId: user.id,
|
||||||
countOpen: open && open.length > 0 ? open[0].totAttendance : 0,
|
countOpen: open && open.length > 0 ? open[0].totAttendance : 0,
|
||||||
countClosed: closed && closed.length > 0 ? closed[0].totAttendance : 0
|
countClosed: closed && closed.length > 0 ? closed[0].totAttendance : 0
|
||||||
}
|
};
|
||||||
|
|
||||||
user.openClosedOutQueue = openClosedOutQueue
|
|
||||||
|
|
||||||
|
user.openClosedOutQueue = openClosedOutQueue;
|
||||||
|
|
||||||
// OPEN, CLOSED TICKETS STARTED BY CLIENTS
|
// OPEN, CLOSED TICKETS STARTED BY CLIENTS
|
||||||
let openClosedInQueue = queuesByUser.filter((e) => e.userId == user.id)
|
let openClosedInQueue = queuesByUser.filter(e => e.userId == user.id);
|
||||||
|
|
||||||
if (openClosedInQueue && openClosedInQueue.length > 0) {
|
if (openClosedInQueue && openClosedInQueue.length > 0) {
|
||||||
user.openClosedInQueue = openClosedInQueue
|
user.openClosedInQueue = openClosedInQueue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
index = onlineUsers.findIndex((e: any) => e.userId == user.id);
|
||||||
index = onlineUsers.findIndex((e: any) => e.userId == user.id)
|
|
||||||
|
|
||||||
if (index != -1) {
|
if (index != -1) {
|
||||||
user.statusOnline = onlineUsers[index]
|
user.statusOnline = onlineUsers[index];
|
||||||
}
|
}
|
||||||
|
|
||||||
if (startDate.length > 0 && startDate.split('-').length == 3) {
|
if (startDate.length > 0 && startDate.split("-").length == 3) {
|
||||||
let date = startDate.split('-')
|
let date = startDate.split("-");
|
||||||
user.startDate = `${date[2]}/${date[1]}/${date[0]}`
|
user.startDate = `${date[2]}/${date[1]}/${date[0]}`;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (endDate.length > 0 && endDate.split('-').length == 3) {
|
if (endDate.length > 0 && endDate.split("-").length == 3) {
|
||||||
let date = endDate.split('-')
|
let date = endDate.split("-");
|
||||||
user.endDate = `${date[2]}/${date[1]}/${date[0]}`
|
user.endDate = `${date[2]}/${date[1]}/${date[0]}`;
|
||||||
}
|
}
|
||||||
|
});
|
||||||
|
|
||||||
})
|
return res.status(200).json({ usersProfile: usersProfile });
|
||||||
|
|
||||||
return res.status(200).json({usersProfile: usersProfile});
|
|
||||||
|
|
||||||
};
|
};
|
||||||
|
|
||||||
|
export const reportMessagesUserByDateStartDateEnd = async (
|
||||||
|
req: Request,
|
||||||
export const reportMessagesUserByDateStartDateEnd = async (req: Request, res: Response): Promise<Response> => {
|
res: Response
|
||||||
|
): Promise<Response> => {
|
||||||
if (req.user.profile !== "master" && req.user.profile !== "admin") {
|
if (req.user.profile !== "master" && req.user.profile !== "admin") {
|
||||||
throw new AppError("ERR_NO_PERMISSION", 403);
|
throw new AppError("ERR_NO_PERMISSION", 403);
|
||||||
}
|
}
|
||||||
|
|
||||||
const { userId, startDate, endDate } = req.query as IndexQuery
|
const { userId, startDate, endDate } = req.query as IndexQuery;
|
||||||
|
|
||||||
let data_query_messages = await ShowMessageReport(userId, startDate, endDate);
|
let data_query_messages = await ShowMessageReport(userId, startDate, endDate);
|
||||||
|
|
||||||
for (var i = 0; i < data_query_messages.length; i++) {
|
for (var i = 0; i < data_query_messages.length; i++) {
|
||||||
|
|
||||||
if (data_query_messages[i].fromMe) {
|
if (data_query_messages[i].fromMe) {
|
||||||
data_query_messages[i].fromMe = 'Atendente'
|
data_query_messages[i].fromMe = "Atendente";
|
||||||
}
|
} else {
|
||||||
else {
|
data_query_messages[i].fromMe = "Cliente";
|
||||||
data_query_messages[i].fromMe = 'Cliente'
|
|
||||||
}
|
}
|
||||||
|
|
||||||
data_query_messages[i].id = (i + 1)
|
data_query_messages[i].id = i + 1;
|
||||||
|
|
||||||
console.log('data_query_messages: ', data_query_messages[i])
|
console.log("data_query_messages: ", data_query_messages[i]);
|
||||||
}
|
}
|
||||||
|
|
||||||
return res.status(200).json(data_query_messages);
|
return res.status(200).json(data_query_messages);
|
||||||
|
|
||||||
};
|
};
|
||||||
|
|
||||||
|
export const reportOnQueue = async (
|
||||||
|
req: Request,
|
||||||
export const reportOnQueue = async (req: Request, res: Response): Promise<Response> => {
|
res: Response
|
||||||
|
): Promise<Response> => {
|
||||||
// console.log(req.body)
|
// console.log(req.body)
|
||||||
|
|
||||||
const { adminId, identifier, queueStatus, file } = req.body
|
const { adminId, identifier, queueStatus, file } = req.body;
|
||||||
|
|
||||||
const io = getIO();
|
const io = getIO();
|
||||||
io.emit("queryOnQueueStatus", {
|
io.emit("queryOnQueueStatus", {
|
||||||
|
@ -229,10 +267,5 @@ export const reportOnQueue = async (req: Request, res: Response): Promise<Respon
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
return res.status(200).json({ message: 'ok' })
|
return res.status(200).json({ message: "ok" });
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -10,11 +10,15 @@ import UpdateUserService from "../services/UserServices/UpdateUserService";
|
||||||
import ShowUserService from "../services/UserServices/ShowUserService";
|
import ShowUserService from "../services/UserServices/ShowUserService";
|
||||||
import DeleteUserService from "../services/UserServices/DeleteUserService";
|
import DeleteUserService from "../services/UserServices/DeleteUserService";
|
||||||
|
|
||||||
import ListUserParamiterService from "../services/UserServices/ListUserParamiterService"
|
import ListUserParamiterService from "../services/UserServices/ListUserParamiterService";
|
||||||
import User from "../models/User";
|
import User from "../models/User";
|
||||||
|
|
||||||
import { startWhoIsOnlineMonitor, stopWhoIsOnlineMonitor } from "../helpers/WhoIsOnlineMonitor"
|
import {
|
||||||
import UserOnlineTIme from '../models/UserOnlineTime'
|
startWhoIsOnlineMonitor,
|
||||||
|
stopWhoIsOnlineMonitor
|
||||||
|
} from "../helpers/WhoIsOnlineMonitor";
|
||||||
|
import UserOnlineTIme from "../models/UserOnlineTime";
|
||||||
|
import ListUser from "../services/UserServices/ListUserParamiterService";
|
||||||
|
|
||||||
type IndexQuery = {
|
type IndexQuery = {
|
||||||
searchParam: string;
|
searchParam: string;
|
||||||
|
@ -31,13 +35,12 @@ export const index = async (req: Request, res: Response): Promise<Response> => {
|
||||||
profile
|
profile
|
||||||
});
|
});
|
||||||
|
|
||||||
if (req.user.profile !== 'master') {
|
if (req.user.profile !== "master") {
|
||||||
|
|
||||||
let auxUsers: Array<object> = [];
|
let auxUsers: Array<object> = [];
|
||||||
|
|
||||||
for (var user of users) {
|
for (var user of users) {
|
||||||
if (user.profile !== 'master') {
|
if (user.profile !== "master") {
|
||||||
auxUsers.push(user)
|
auxUsers.push(user);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -46,34 +49,44 @@ export const index = async (req: Request, res: Response): Promise<Response> => {
|
||||||
|
|
||||||
return res.json({ users, count, hasMore });
|
return res.json({ users, count, hasMore });
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
// const { users, count, hasMore } = await ListUsersService({
|
// const { users, count, hasMore } = await ListUsersService({
|
||||||
// searchParam,
|
// searchParam,
|
||||||
// pageNumber
|
// pageNumber
|
||||||
// });
|
// });
|
||||||
|
|
||||||
// if(req.user.profile!=='master'){
|
// if(req.user.profile!=='master'){
|
||||||
|
|
||||||
// let auxUsers: Array<object> = [];
|
// let auxUsers: Array<object> = [];
|
||||||
|
|
||||||
// for (var user of users) {
|
// for (var user of users) {
|
||||||
// if(user.profile!=='master'){
|
// if(user.profile!=='master'){
|
||||||
// auxUsers.push(user)
|
// auxUsers.push(user)
|
||||||
// }
|
// }
|
||||||
// }
|
// }
|
||||||
|
|
||||||
// return res.json({ users: auxUsers, count, hasMore });
|
// return res.json({ users: auxUsers, count, hasMore });
|
||||||
// }
|
// }
|
||||||
|
|
||||||
// return res.json({ users, count, hasMore });
|
// return res.json({ users, count, hasMore });
|
||||||
};
|
};
|
||||||
|
|
||||||
|
export const all = async (req: Request, res: Response): Promise<Response> => {
|
||||||
|
const { profile } = req.query as IndexQuery;
|
||||||
|
|
||||||
|
const users = await ListUser({
|
||||||
|
profile
|
||||||
|
});
|
||||||
|
|
||||||
|
return res.json({ users });
|
||||||
|
};
|
||||||
|
|
||||||
export const store = async (req: Request, res: Response): Promise<Response> => {
|
export const store = async (req: Request, res: Response): Promise<Response> => {
|
||||||
const { email, password, name, profile, queueIds } = req.body;
|
const { email, password, name, profile, queueIds } = req.body;
|
||||||
|
|
||||||
if (req.url === "/signup" && (await CheckSettingsHelper("userCreation")) === "disabled") {
|
if (
|
||||||
|
req.url === "/signup" &&
|
||||||
|
(await CheckSettingsHelper("userCreation")) === "disabled"
|
||||||
|
) {
|
||||||
throw new AppError("ERR_USER_CREATION_DISABLED", 403);
|
throw new AppError("ERR_USER_CREATION_DISABLED", 403);
|
||||||
} else if (req.url !== "/signup" && req.user.profile !== "master") {
|
} else if (req.url !== "/signup" && req.user.profile !== "master") {
|
||||||
throw new AppError("ERR_NO_PERMISSION", 403);
|
throw new AppError("ERR_NO_PERMISSION", 403);
|
||||||
|
@ -93,9 +106,8 @@ export const store = async (req: Request, res: Response): Promise<Response> => {
|
||||||
user
|
user
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
||||||
// await stopWhoIsOnlineMonitor()
|
// await stopWhoIsOnlineMonitor()
|
||||||
await startWhoIsOnlineMonitor()
|
await startWhoIsOnlineMonitor();
|
||||||
|
|
||||||
return res.status(200).json(user);
|
return res.status(200).json(user);
|
||||||
};
|
};
|
||||||
|
@ -108,17 +120,18 @@ export const show = async (req: Request, res: Response): Promise<Response> => {
|
||||||
return res.status(200).json(user);
|
return res.status(200).json(user);
|
||||||
};
|
};
|
||||||
|
|
||||||
|
export const logoutUser = async (
|
||||||
export const logoutUser = async (req: Request, res: Response): Promise<Response> => {
|
req: Request,
|
||||||
|
res: Response
|
||||||
|
): Promise<Response> => {
|
||||||
const { userId } = req.params;
|
const { userId } = req.params;
|
||||||
|
|
||||||
|
await stopWhoIsOnlineMonitor();
|
||||||
await stopWhoIsOnlineMonitor()
|
|
||||||
|
|
||||||
let onlineTime = {
|
let onlineTime = {
|
||||||
userId: userId,
|
userId: userId,
|
||||||
status: 'logout...'
|
status: "logout..."
|
||||||
}
|
};
|
||||||
|
|
||||||
const io = getIO();
|
const io = getIO();
|
||||||
io.emit("onlineStatus", {
|
io.emit("onlineStatus", {
|
||||||
|
@ -126,13 +139,12 @@ export const logoutUser = async (req: Request, res: Response): Promise<Response>
|
||||||
userOnlineTime: onlineTime
|
userOnlineTime: onlineTime
|
||||||
});
|
});
|
||||||
|
|
||||||
await startWhoIsOnlineMonitor()
|
await startWhoIsOnlineMonitor();
|
||||||
//
|
//
|
||||||
|
|
||||||
return res.status(200).json({});
|
return res.status(200).json({});
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
export const update = async (
|
export const update = async (
|
||||||
req: Request,
|
req: Request,
|
||||||
res: Response
|
res: Response
|
||||||
|
@ -165,26 +177,23 @@ export const remove = async (
|
||||||
throw new AppError("ERR_NO_PERMISSION", 403);
|
throw new AppError("ERR_NO_PERMISSION", 403);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
await DeleteUserService(userId);
|
await DeleteUserService(userId);
|
||||||
|
|
||||||
|
|
||||||
const io = getIO();
|
const io = getIO();
|
||||||
io.emit("user", {
|
io.emit("user", {
|
||||||
action: "delete",
|
action: "delete",
|
||||||
userId
|
userId
|
||||||
});
|
});
|
||||||
|
|
||||||
|
//test del
|
||||||
//test del
|
await stopWhoIsOnlineMonitor();
|
||||||
await stopWhoIsOnlineMonitor()
|
|
||||||
|
|
||||||
io.emit("onlineStatus", {
|
io.emit("onlineStatus", {
|
||||||
action: "delete",
|
action: "delete",
|
||||||
userOnlineTime: userId
|
userOnlineTime: userId
|
||||||
});
|
});
|
||||||
|
|
||||||
await startWhoIsOnlineMonitor()
|
await startWhoIsOnlineMonitor();
|
||||||
//
|
//
|
||||||
|
|
||||||
return res.status(200).json({ message: "User deleted" });
|
return res.status(200).json({ message: "User deleted" });
|
||||||
|
|
|
@ -5,10 +5,11 @@ import * as UserController from "../controllers/UserController";
|
||||||
|
|
||||||
const userRoutes = Router();
|
const userRoutes = Router();
|
||||||
|
|
||||||
|
userRoutes.get("/users/all", isAuth, UserController.all);
|
||||||
|
|
||||||
userRoutes.get("/users", isAuth, UserController.index);
|
userRoutes.get("/users", isAuth, UserController.index);
|
||||||
|
|
||||||
userRoutes.post("/users", isAuth, UserController.store);
|
userRoutes.post("/users", isAuth, UserController.store);
|
||||||
|
|
||||||
userRoutes.put("/users/:userId", isAuth, UserController.update);
|
userRoutes.put("/users/:userId", isAuth, UserController.update);
|
||||||
|
|
||||||
|
|
|
@ -1,4 +1,3 @@
|
||||||
|
|
||||||
import { Op, Sequelize } from "sequelize";
|
import { Op, Sequelize } from "sequelize";
|
||||||
import Queue from "../../models/Queue";
|
import Queue from "../../models/Queue";
|
||||||
import User from "../../models/User";
|
import User from "../../models/User";
|
||||||
|
@ -7,65 +6,54 @@ import UserQueue from "../../models/UserQueue";
|
||||||
interface Request {
|
interface Request {
|
||||||
userId?: string | number;
|
userId?: string | number;
|
||||||
profile?: string;
|
profile?: string;
|
||||||
|
raw?: boolean;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const ListUser = async ({ profile, userId, raw }: Request): Promise<User[]> => {
|
||||||
const ListUser = async ({ profile, userId }: Request): Promise<User[]> => {
|
let where_clause = {};
|
||||||
|
|
||||||
let where_clause = {}
|
|
||||||
|
|
||||||
if (userId && profile) {
|
if (userId && profile) {
|
||||||
where_clause = {
|
where_clause = {
|
||||||
[Op.and]: [
|
[Op.and]: [{ userId: userId }, { profile: profile }]
|
||||||
{ userId: userId },
|
};
|
||||||
{ profile: profile }
|
} else if (userId) {
|
||||||
]
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else if (userId) {
|
|
||||||
where_clause = {
|
where_clause = {
|
||||||
[Op.and]: [
|
[Op.and]: [{ userId: userId }]
|
||||||
{ userId: userId },
|
};
|
||||||
]
|
} else if (profile) {
|
||||||
}
|
|
||||||
}
|
|
||||||
else if (profile) {
|
|
||||||
where_clause = {
|
where_clause = {
|
||||||
profile: profile
|
profile: profile
|
||||||
}
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const queryOptions: any = {
|
||||||
const users = await User.findAll({
|
|
||||||
where: where_clause,
|
where: where_clause,
|
||||||
raw: true,
|
raw,
|
||||||
attributes: ['id', 'name', 'email'],
|
attributes: ["id", "name", "email"],
|
||||||
|
order: [["id", "ASC"]]
|
||||||
|
};
|
||||||
|
|
||||||
// include: [
|
if (!raw) {
|
||||||
// {
|
queryOptions.include = [
|
||||||
// model: UserQueue,
|
{ model: Queue, as: "queues", attributes: ["id", "name", "color"] }
|
||||||
// separate: true,
|
];
|
||||||
|
}
|
||||||
|
|
||||||
// attributes: ['id',],
|
const users = await User.findAll(queryOptions);
|
||||||
|
|
||||||
// order: [
|
// const users = await User.findAll({
|
||||||
// ['createdAt', 'ASC']
|
// where: where_clause,
|
||||||
// ]
|
// raw,
|
||||||
// },
|
// attributes: ['id', 'name', 'email'],
|
||||||
// ],
|
|
||||||
|
|
||||||
|
// include: [
|
||||||
|
// { model: Queue, as: "queues", attributes: ["id", "name", "color"] }
|
||||||
|
// ],
|
||||||
|
|
||||||
|
// order: [["id", "ASC"]],
|
||||||
order: [["id", "ASC"]],
|
// })
|
||||||
})
|
|
||||||
|
|
||||||
|
|
||||||
return users;
|
return users;
|
||||||
};
|
};
|
||||||
|
|
||||||
export default ListUser;
|
export default ListUser;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -1,30 +1,30 @@
|
||||||
import React, { useState, useContext, useMemo } from "react";
|
import React, { useState, useContext, useMemo, useRef, useEffect } from "react"
|
||||||
import { useHistory } from "react-router-dom";
|
import { useHistory } from "react-router-dom"
|
||||||
|
|
||||||
import Button from "@material-ui/core/Button";
|
import Button from "@material-ui/core/Button"
|
||||||
import Dialog from "@material-ui/core/Dialog";
|
import Dialog from "@material-ui/core/Dialog"
|
||||||
import Select from "@material-ui/core/Select";
|
import Select from "@material-ui/core/Select"
|
||||||
import FormControl from "@material-ui/core/FormControl";
|
import FormControl from "@material-ui/core/FormControl"
|
||||||
import InputLabel from "@material-ui/core/InputLabel";
|
import InputLabel from "@material-ui/core/InputLabel"
|
||||||
import MenuItem from "@material-ui/core/MenuItem";
|
import MenuItem from "@material-ui/core/MenuItem"
|
||||||
import { makeStyles } from "@material-ui/core";
|
import { makeStyles } from "@material-ui/core"
|
||||||
|
|
||||||
import DialogActions from "@material-ui/core/DialogActions";
|
import DialogActions from "@material-ui/core/DialogActions"
|
||||||
import DialogContent from "@material-ui/core/DialogContent";
|
import DialogContent from "@material-ui/core/DialogContent"
|
||||||
import DialogTitle from "@material-ui/core/DialogTitle";
|
import DialogTitle from "@material-ui/core/DialogTitle"
|
||||||
|
|
||||||
import { i18n } from "../../translate/i18n";
|
import { i18n } from "../../translate/i18n"
|
||||||
import api from "../../services/api";
|
import api from "../../services/api"
|
||||||
import ButtonWithSpinner from "../ButtonWithSpinner";
|
import ButtonWithSpinner from "../ButtonWithSpinner"
|
||||||
import toastError from "../../errors/toastError";
|
import toastError from "../../errors/toastError"
|
||||||
|
|
||||||
import { WhatsAppsContext } from "../../context/WhatsApp/WhatsAppsContext";
|
import { WhatsAppsContext } from "../../context/WhatsApp/WhatsAppsContext"
|
||||||
|
|
||||||
const useStyles = makeStyles((theme) => ({
|
const useStyles = makeStyles((theme) => ({
|
||||||
maxWidth: {
|
maxWidth: {
|
||||||
width: "100%",
|
width: "100%",
|
||||||
},
|
},
|
||||||
}));
|
}))
|
||||||
|
|
||||||
// Receive array of queues arrays
|
// Receive array of queues arrays
|
||||||
// Return a new array with unique queues from all arrays has passed by the parameter
|
// Return a new array with unique queues from all arrays has passed by the parameter
|
||||||
|
@ -45,49 +45,117 @@ const queueArraysToOneArray = (array) => {
|
||||||
|
|
||||||
|
|
||||||
const TransferTicketModal = ({ modalOpen, onClose, ticketid }) => {
|
const TransferTicketModal = ({ modalOpen, onClose, ticketid }) => {
|
||||||
const history = useHistory();
|
const history = useHistory()
|
||||||
const { whatsApps } = useContext(WhatsAppsContext);
|
const { whatsApps } = useContext(WhatsAppsContext)
|
||||||
const [loading, setLoading] = useState(false);
|
const [loading, setLoading] = useState(false)
|
||||||
const [selectedQueue, setSelectedQueue] = useState('');
|
const [selectedQueue, setSelectedQueue] = useState('')
|
||||||
const classes = useStyles();
|
const [selectedUser, setSelectedUser] = useState('')
|
||||||
const queues = useMemo(() => {
|
const classes = useStyles()
|
||||||
if (!whatsApps) return []
|
|
||||||
|
const [users, setUsers] = useState([])
|
||||||
|
const [queues, setQueues] = useState([])
|
||||||
|
const isRun = useRef(false)
|
||||||
|
|
||||||
|
|
||||||
|
const _queues = useMemo(() => {
|
||||||
|
if (!whatsApps) return []
|
||||||
const whatsAppsQueues = whatsApps.map(({ queues }) => queues)
|
const whatsAppsQueues = whatsApps.map(({ queues }) => queues)
|
||||||
//const whatsAppsQueues = whatsApps.filter(({ status }) => status === "CONNECTED" ).map(({ queues }) => queues)
|
//const whatsAppsQueues = whatsApps.filter(({ status }) => status === "CONNECTED" ).map(({ queues }) => queues)
|
||||||
const uniqueQueuesAvailable = queueArraysToOneArray(whatsAppsQueues)
|
const uniqueQueuesAvailable = queueArraysToOneArray(whatsAppsQueues)
|
||||||
|
|
||||||
return uniqueQueuesAvailable
|
return uniqueQueuesAvailable
|
||||||
}, [whatsApps])
|
}, [whatsApps])
|
||||||
const [itemHover, setItemHover] = useState(-1)
|
const [itemHover, setItemHover] = useState(-1)
|
||||||
|
|
||||||
|
useEffect(() => {
|
||||||
|
if (isRun.current) return
|
||||||
|
setQueues(_queues)
|
||||||
|
|
||||||
|
isRun.current = true
|
||||||
|
}, [whatsApps])
|
||||||
|
|
||||||
|
useEffect(() => {
|
||||||
|
console.log('==========> selectedUser: ', selectedUser)
|
||||||
|
|
||||||
|
if (selectedUser) {
|
||||||
|
|
||||||
|
let { queues } = users.find(u => +u.id == +selectedUser)
|
||||||
|
const userQueues = queues.map((q) => {
|
||||||
|
const { id, color, name } = q
|
||||||
|
return { id, color, name }
|
||||||
|
})
|
||||||
|
|
||||||
|
setQueues(userQueues)
|
||||||
|
setSelectedQueue('')
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
setQueues(_queues)
|
||||||
|
setSelectedUser('')
|
||||||
|
}
|
||||||
|
}, [selectedUser])
|
||||||
|
|
||||||
const handleClose = () => {
|
const handleClose = () => {
|
||||||
onClose();
|
onClose()
|
||||||
};
|
}
|
||||||
|
|
||||||
const handleSaveTicket = async e => {
|
const handleSaveTicket = async e => {
|
||||||
e.preventDefault();
|
e.preventDefault()
|
||||||
if (!ticketid) return;
|
if (!ticketid) return
|
||||||
if (!selectedQueue) return;
|
if (!selectedQueue) return
|
||||||
setLoading(true);
|
setLoading(true)
|
||||||
try {
|
try {
|
||||||
let data = {};
|
let data = {}
|
||||||
|
|
||||||
if (selectedQueue && selectedQueue !== null) {
|
if (selectedQueue && selectedQueue !== null) {
|
||||||
data.queueId = selectedQueue
|
data.queueId = selectedQueue
|
||||||
}
|
}
|
||||||
|
|
||||||
// test del PARA APARECER NA FILA DE OUTRO ATENDENTE E O MESMO CLICAR EM ACEITAR AO INVES DE ENVIAR PARA ATENDENDO
|
|
||||||
data.status = 'pending'
|
|
||||||
data.transfer = true
|
|
||||||
|
|
||||||
await api.put(`/tickets/${ticketid}`, data);
|
if (selectedUser) {
|
||||||
|
data.userId = selectedUser
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
// test del PARA APARECER NA FILA DE OUTRO ATENDENTE E O MESMO CLICAR EM ACEITAR AO INVES DE ENVIAR PARA ATENDENDO
|
||||||
|
data.status = 'pending'
|
||||||
|
data.transfer = true
|
||||||
|
}
|
||||||
|
|
||||||
setLoading(false);
|
await api.put(`/tickets/${ticketid}`, data)
|
||||||
history.push(`/tickets`);
|
|
||||||
|
setLoading(false)
|
||||||
|
history.push(`/tickets`)
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
setLoading(false);
|
setLoading(false)
|
||||||
toastError(err);
|
toastError(err)
|
||||||
}
|
}
|
||||||
};
|
}
|
||||||
|
|
||||||
|
|
||||||
|
useEffect(() => {
|
||||||
|
|
||||||
|
const delayDebounceFn = setTimeout(() => {
|
||||||
|
|
||||||
|
const fetchUsers = async () => {
|
||||||
|
try {
|
||||||
|
|
||||||
|
const { data } = await api.get("/users/all", {
|
||||||
|
params: { profile: 'user' },
|
||||||
|
})
|
||||||
|
|
||||||
|
setUsers(data.users)
|
||||||
|
|
||||||
|
console.log('data.users: ', data.users)
|
||||||
|
|
||||||
|
} catch (err) {
|
||||||
|
console.log(err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fetchUsers()
|
||||||
|
|
||||||
|
}, 500)
|
||||||
|
return () => clearTimeout(delayDebounceFn)
|
||||||
|
}, [])
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<Dialog open={modalOpen} onClose={handleClose} maxWidth="lg" scroll="paper">
|
<Dialog open={modalOpen} onClose={handleClose} maxWidth="lg" scroll="paper">
|
||||||
|
@ -98,6 +166,7 @@ const TransferTicketModal = ({ modalOpen, onClose, ticketid }) => {
|
||||||
<DialogContent dividers>
|
<DialogContent dividers>
|
||||||
<FormControl variant="outlined" className={classes.maxWidth}>
|
<FormControl variant="outlined" className={classes.maxWidth}>
|
||||||
<InputLabel>{i18n.t("transferTicketModal.fieldQueueLabel")}</InputLabel>
|
<InputLabel>{i18n.t("transferTicketModal.fieldQueueLabel")}</InputLabel>
|
||||||
|
|
||||||
<Select
|
<Select
|
||||||
value={selectedQueue}
|
value={selectedQueue}
|
||||||
onChange={(e) => setSelectedQueue(e.target.value)}
|
onChange={(e) => setSelectedQueue(e.target.value)}
|
||||||
|
@ -118,6 +187,26 @@ const TransferTicketModal = ({ modalOpen, onClose, ticketid }) => {
|
||||||
</MenuItem>
|
</MenuItem>
|
||||||
))}
|
))}
|
||||||
</Select>
|
</Select>
|
||||||
|
|
||||||
|
|
||||||
|
<br />
|
||||||
|
|
||||||
|
<Select
|
||||||
|
value={selectedUser}
|
||||||
|
onChange={e => setSelectedUser(e.target.value)}
|
||||||
|
label={'Transfeir para usuario'}
|
||||||
|
>
|
||||||
|
<MenuItem style={{ background: "white", }} value={''}> </MenuItem>
|
||||||
|
{users.map((user) => (
|
||||||
|
<MenuItem
|
||||||
|
key={user.id}
|
||||||
|
value={user.id}
|
||||||
|
>{user.name}
|
||||||
|
</MenuItem>
|
||||||
|
))}
|
||||||
|
</Select>
|
||||||
|
|
||||||
|
|
||||||
</FormControl>
|
</FormControl>
|
||||||
</DialogContent>
|
</DialogContent>
|
||||||
<DialogActions>
|
<DialogActions>
|
||||||
|
@ -140,7 +229,7 @@ const TransferTicketModal = ({ modalOpen, onClose, ticketid }) => {
|
||||||
</DialogActions>
|
</DialogActions>
|
||||||
</form>
|
</form>
|
||||||
</Dialog >
|
</Dialog >
|
||||||
);
|
)
|
||||||
};
|
}
|
||||||
|
|
||||||
export default TransferTicketModal;
|
export default TransferTicketModal
|
Loading…
Reference in New Issue