feat(dashboard): add aggregated dashboard stats API, robust logout, and warehouse seeders
deploy-chabokan / deploy (push) Canceled after 0s
deploy-chabokan / deploy (push) Canceled after 0s
This commit is contained in:
@@ -0,0 +1,11 @@
|
||||
const catchAsync = require('../../globalErrorHandler/catchAsync')
|
||||
const dashboardService = require('./dashboardService')
|
||||
|
||||
exports.getDashboardStats = catchAsync(async (req, res, next) => {
|
||||
const stats = await dashboardService.getDashboardStats()
|
||||
|
||||
res.status(200).json({
|
||||
status: 'success',
|
||||
data: stats,
|
||||
})
|
||||
})
|
||||
@@ -0,0 +1,12 @@
|
||||
const express = require('express')
|
||||
const dashboardController = require('./dashboardController')
|
||||
const loginCheck = require('../../middlewares/loginCheck')
|
||||
|
||||
const router = new express.Router()
|
||||
|
||||
router.use(loginCheck.loginProtect)
|
||||
|
||||
router.get('/stats', dashboardController.getDashboardStats)
|
||||
router.get('/summary', dashboardController.getDashboardStats)
|
||||
|
||||
module.exports = router
|
||||
@@ -0,0 +1,232 @@
|
||||
const Property = require('../property/propertyModel')
|
||||
const Category = require('../category/categoryModel')
|
||||
const PropertyStatus = require('../propertyStatus/propertyStatusModel')
|
||||
const Warehouse = require('../warehouse/warehouseModel')
|
||||
const WarehouseItem = require('../warehouseItem/warehouseItemModel')
|
||||
const WarehouseItemTransaction = require('../warehouseItem/warehouseItemTransactionModel')
|
||||
const User = require('../user/userModel')
|
||||
const Role = require('../role/roleModel')
|
||||
const { getSignedUrl } = require('../file/fileService')
|
||||
|
||||
/**
|
||||
* Aggregates live dashboard statistics across properties, warehouses, inventory, and users
|
||||
*/
|
||||
const getDashboardStats = async () => {
|
||||
// 1. Overview counts
|
||||
const [
|
||||
totalProperties,
|
||||
totalAreaResult,
|
||||
totalWarehouseItems,
|
||||
totalWarehouses,
|
||||
totalWarehouseTransactions,
|
||||
totalUsers,
|
||||
totalCategories,
|
||||
totalRoles,
|
||||
] = await Promise.all([
|
||||
Property.countDocuments({ isActive: { $ne: false } }),
|
||||
Property.aggregate([
|
||||
{ $match: { isActive: { $ne: false }, area: { $gt: 0 } } },
|
||||
{ $group: { _id: null, totalArea: { $sum: '$area' } } },
|
||||
]),
|
||||
WarehouseItem.countDocuments({ isActive: { $ne: false } }),
|
||||
Warehouse.countDocuments(),
|
||||
WarehouseItemTransaction.countDocuments(),
|
||||
User.countDocuments({ isActive: { $ne: false } }),
|
||||
Category.countDocuments(),
|
||||
Role.countDocuments(),
|
||||
])
|
||||
|
||||
const totalArea = totalAreaResult?.[0]?.totalArea || 0
|
||||
|
||||
// 2. Properties grouped by Category
|
||||
const propertiesByCategoryRaw = await Property.aggregate([
|
||||
{ $match: { isActive: { $ne: false } } },
|
||||
{
|
||||
$group: {
|
||||
_id: '$category',
|
||||
count: { $sum: 1 },
|
||||
totalArea: { $sum: { $ifNull: ['$area', 0] } },
|
||||
},
|
||||
},
|
||||
{
|
||||
$lookup: {
|
||||
from: 'categories',
|
||||
localField: '_id',
|
||||
foreignField: '_id',
|
||||
as: 'categoryDoc',
|
||||
},
|
||||
},
|
||||
{ $unwind: { path: '$categoryDoc', preserveNullAndEmptyArrays: true } },
|
||||
{ $sort: { count: -1 } },
|
||||
])
|
||||
|
||||
const propertiesByCategory = propertiesByCategoryRaw.map((item) => ({
|
||||
categoryId: item._id,
|
||||
name: item.categoryDoc?.nativeName || item.categoryDoc?.englishName || 'بدون دستهبندی',
|
||||
englishName: item.categoryDoc?.englishName || 'Uncategorized',
|
||||
count: item.count,
|
||||
totalArea: item.totalArea || 0,
|
||||
percentage: totalProperties > 0 ? Math.round((item.count / totalProperties) * 100) : 0,
|
||||
}))
|
||||
|
||||
// 3. Properties grouped by Status
|
||||
const propertiesByStatusRaw = await Property.aggregate([
|
||||
{ $match: { isActive: { $ne: false } } },
|
||||
{
|
||||
$group: {
|
||||
_id: '$status',
|
||||
count: { $sum: 1 },
|
||||
},
|
||||
},
|
||||
{
|
||||
$lookup: {
|
||||
from: 'propertystatuses',
|
||||
localField: '_id',
|
||||
foreignField: '_id',
|
||||
as: 'statusDoc',
|
||||
},
|
||||
},
|
||||
{ $unwind: { path: '$statusDoc', preserveNullAndEmptyArrays: true } },
|
||||
{ $sort: { count: -1 } },
|
||||
])
|
||||
|
||||
const propertiesByStatus = propertiesByStatusRaw.map((item) => ({
|
||||
statusId: item._id,
|
||||
name: item.statusDoc?.nativeName || item.statusDoc?.englishName || 'نامشخص',
|
||||
englishName: item.statusDoc?.englishName || 'Unknown',
|
||||
color: item.statusDoc?.color || '#3b82f6',
|
||||
count: item.count,
|
||||
percentage: totalProperties > 0 ? Math.round((item.count / totalProperties) * 100) : 0,
|
||||
}))
|
||||
|
||||
// 4. Warehouse transactions summary (IN vs OUT)
|
||||
const warehouseFlowRaw = await WarehouseItemTransaction.aggregate([
|
||||
{
|
||||
$group: {
|
||||
_id: '$type',
|
||||
count: { $sum: 1 },
|
||||
totalQuantity: { $sum: '$quantity' },
|
||||
},
|
||||
},
|
||||
])
|
||||
|
||||
const warehouseFlow = {
|
||||
inCount: warehouseFlowRaw.find((f) => f._id === 'IN')?.count || 0,
|
||||
outCount: warehouseFlowRaw.find((f) => f._id === 'OUT')?.count || 0,
|
||||
inQuantity: warehouseFlowRaw.find((f) => f._id === 'IN')?.totalQuantity || 0,
|
||||
outQuantity: warehouseFlowRaw.find((f) => f._id === 'OUT')?.totalQuantity || 0,
|
||||
}
|
||||
|
||||
// 5. Recent registered properties (Last 6)
|
||||
const recentPropertiesRaw = await Property.find({ isActive: { $ne: false } })
|
||||
.sort({ createdAt: -1 })
|
||||
.limit(6)
|
||||
.populate('category', 'nativeName englishName')
|
||||
.populate('status', 'nativeName englishName color')
|
||||
.lean()
|
||||
|
||||
const recentProperties = await Promise.all(
|
||||
recentPropertiesRaw.map(async (prop) => {
|
||||
let thumb = null
|
||||
if (prop.mainImageUrls && prop.mainImageUrls.length > 0) {
|
||||
thumb = await getSignedUrl(prop.mainImageUrls[0], 'properties').catch(() => null)
|
||||
}
|
||||
return {
|
||||
_id: prop._id,
|
||||
propertyCode: prop.propertyCode || prop._id.toString().slice(-6),
|
||||
name: prop.name || 'ملک بدون عنوان',
|
||||
category: prop.category?.nativeName || 'عمومی',
|
||||
status: prop.status?.nativeName || 'عادی',
|
||||
statusColor: prop.status?.color || '#3b82f6',
|
||||
ownerName: prop.ownerName || '—',
|
||||
area: prop.area || 0,
|
||||
dong: prop.dong || 6,
|
||||
imageUrl: thumb || 'https://cloud.mbmanager.ir/images/item-no-image.png',
|
||||
registrationPlate: prop.registrationPlate || '—',
|
||||
createdAt: prop.createdAt,
|
||||
}
|
||||
})
|
||||
)
|
||||
|
||||
// 6. Recent warehouse transactions (Last 6)
|
||||
const recentWarehouseTransactionsRaw = await WarehouseItemTransaction.find()
|
||||
.sort({ createdAt: -1 })
|
||||
.limit(6)
|
||||
.populate('item', 'nameFa nameEn code unitFa')
|
||||
.populate('warehouse', 'name location')
|
||||
.lean()
|
||||
|
||||
const recentWarehouseTransactions = recentWarehouseTransactionsRaw.map((tx) => ({
|
||||
_id: tx._id,
|
||||
type: tx.type, // 'IN' | 'OUT'
|
||||
quantity: tx.quantity,
|
||||
unit: tx.unit || tx.item?.unitFa || 'عدد',
|
||||
itemName: tx.item?.nameFa || 'کالای نامشخص',
|
||||
itemCode: tx.item?.code || '—',
|
||||
warehouseName: tx.warehouse?.name || 'انبار مرکزی',
|
||||
reason: tx.reason || (tx.type === 'IN' ? 'ورود به انبار' : 'خروج از انبار'),
|
||||
actorName: tx.actorName || 'کاربر سیستم',
|
||||
date: tx.date || tx.createdAt,
|
||||
}))
|
||||
|
||||
// 7. Monthly Property & Warehouse Trend (Last 6 months)
|
||||
const sixMonthsAgo = new Date()
|
||||
sixMonthsAgo.setMonth(sixMonthsAgo.getMonth() - 5)
|
||||
sixMonthsAgo.setDate(1)
|
||||
sixMonthsAgo.setHours(0, 0, 0, 0)
|
||||
|
||||
const monthlyPropertiesRaw = await Property.aggregate([
|
||||
{ $match: { createdAt: { $gte: sixMonthsAgo }, isActive: { $ne: false } } },
|
||||
{
|
||||
$group: {
|
||||
_id: {
|
||||
year: { $year: '$createdAt' },
|
||||
month: { $month: '$createdAt' },
|
||||
},
|
||||
count: { $sum: 1 },
|
||||
},
|
||||
},
|
||||
{ $sort: { '_id.year': 1, '_id.month': 1 } },
|
||||
])
|
||||
|
||||
const monthlyWarehouseRaw = await WarehouseItemTransaction.aggregate([
|
||||
{ $match: { createdAt: { $gte: sixMonthsAgo } } },
|
||||
{
|
||||
$group: {
|
||||
_id: {
|
||||
year: { $year: '$createdAt' },
|
||||
month: { $month: '$createdAt' },
|
||||
type: '$type',
|
||||
},
|
||||
count: { $sum: 1 },
|
||||
},
|
||||
},
|
||||
{ $sort: { '_id.year': 1, '_id.month': 1 } },
|
||||
])
|
||||
|
||||
return {
|
||||
overview: {
|
||||
totalProperties,
|
||||
totalArea,
|
||||
totalWarehouseItems,
|
||||
totalWarehouses,
|
||||
totalWarehouseTransactions,
|
||||
totalUsers,
|
||||
totalCategories,
|
||||
totalRoles,
|
||||
},
|
||||
propertiesByCategory,
|
||||
propertiesByStatus,
|
||||
warehouseFlow,
|
||||
recentProperties,
|
||||
recentWarehouseTransactions,
|
||||
monthlyTrend: {
|
||||
properties: monthlyPropertiesRaw,
|
||||
warehouse: monthlyWarehouseRaw,
|
||||
},
|
||||
}
|
||||
}
|
||||
|
||||
module.exports = {
|
||||
getDashboardStats,
|
||||
}
|
||||
Reference in New Issue
Block a user