update ws and fix bug
This commit is contained in:
@@ -7,11 +7,15 @@ const OldPieceRequest = require('../../models/OldPieceRequest')
|
||||
const BufferRequest = require('../../models/BufferRequest')
|
||||
const GuaranteeReport = require('../../models/GuaranteeReport')
|
||||
const Complaint = require('../../models/Complaint')
|
||||
|
||||
const Withdraw = require('../../models/GPS.Withdraw');
|
||||
const RequestGPS = require('../../models/GPS.Request')
|
||||
const AwardRequest = require('../../models/GPS.AwardRequest');
|
||||
const InstalledDevice = require('../../models/GPS.InstalledDevice');
|
||||
|
||||
module.exports.getAllNotifs = async socket => {
|
||||
try {
|
||||
const allData = await Promise.all([
|
||||
|
||||
// unreadCuMsgs
|
||||
ContactPageMessage.countDocuments({ read: false }),
|
||||
|
||||
@@ -36,7 +40,19 @@ module.exports.getAllNotifs = async socket => {
|
||||
// newGuaranteeReports
|
||||
GuaranteeReport.countDocuments({ status: 'sent', seen: false }),
|
||||
|
||||
Complaint.countDocuments({ read: false })
|
||||
Complaint.countDocuments({ read: false }),
|
||||
|
||||
// unread withdraw request
|
||||
Withdraw.countDocuments({ status: 0 }),
|
||||
|
||||
// unread GPS request
|
||||
RequestGPS.countDocuments({ status: 0 }),
|
||||
|
||||
// unread award request
|
||||
AwardRequest.countDocuments({ status: 0 }),
|
||||
|
||||
// unread install device request
|
||||
InstalledDevice.countDocuments({ status: 0 })
|
||||
])
|
||||
|
||||
const unreadCuMsgs = allData[0]
|
||||
@@ -48,6 +64,10 @@ module.exports.getAllNotifs = async socket => {
|
||||
const newBufferRequests = allData[6]
|
||||
const newGuaranteeReports = allData[7]
|
||||
const newComplaintReports = allData[8]
|
||||
const newWithdrawRequest = allData[9]
|
||||
const newGpsRequest = allData[10]
|
||||
const newAwardRequest = allData[11]
|
||||
const newInstallDeviceRequest = allData[12]
|
||||
|
||||
|
||||
socket.emit(`admin:allNotifs`, {
|
||||
@@ -59,7 +79,11 @@ module.exports.getAllNotifs = async socket => {
|
||||
newOldPieceRequests,
|
||||
newBufferRequests,
|
||||
newGuaranteeReports,
|
||||
newComplaintReports
|
||||
newComplaintReports,
|
||||
newWithdrawRequest,
|
||||
newGpsRequest,
|
||||
newAwardRequest,
|
||||
newInstallDeviceRequest
|
||||
})
|
||||
} catch (e) {
|
||||
console.log(e)
|
||||
|
||||
Reference in New Issue
Block a user