'use strict';
|
module.exports = {
|
/**
|
* 此函数名称
|
* @url user/pub/test1 前端调用的url参数地址
|
* data 请求参数
|
* @param {String} params1 参数1
|
*/
|
main: async (event) => {
|
let {
|
data = {}, userInfo, util, filterResponse, originalParam
|
} = event;
|
let {
|
customUtil,
|
config,
|
pubFun,
|
vk,
|
db,
|
_
|
} = util;
|
let {
|
uid
|
} = data;
|
let res = {
|
code: 0,
|
msg: "",
|
data: {}
|
};
|
// 业务逻辑开始-----------------------------------------------------------
|
let {
|
monthStart,
|
monthEnd,
|
yearStart,
|
yearEnd,
|
} = vk.pubfn.getCommonTime(new Date());
|
console.log(vk.pubfn)
|
let times = vk.pubfn.getOffsetTime(new Date(), {
|
year: 1,
|
month: 0,
|
day: 0,
|
hours: 0,
|
minutes: 0,
|
seconds: 0,
|
mode: "before", // after 之后 before 之前
|
});
|
|
|
let qntime = vk.pubfn.getCommonTime(new Date(times))
|
|
// let requestRes = await vk.request({
|
// url: `https://www.tianqiapi.com/api/`,
|
// method: "GET",
|
// data: {
|
// appid: '63642244',
|
// appsecret: 'kUxZk9Nh',
|
// version: 'v9',
|
// city: '合肥'
|
// },
|
// });
|
let requestRes = {
|
data: [{
|
wea: '-',
|
tem2: '-',
|
tem1: '-',
|
air_tips: '-'
|
}]
|
}
|
res.data.wea =
|
`今日${requestRes.data[0].wea}，${requestRes.data[0].tem2}℃ -${requestRes.data[0].tem1}℃，${requestRes.data[0].air_tips}`
|
console.log(requestRes)
|
// 总用户
|
// res.data.total_user = await vk.baseDao.count({
|
// dbName: "uni-id-users"
|
// })
|
|
// 今天日期
|
let today = new Date(new Date().toLocaleDateString()).getTime();
|
|
// 今日客户订单
|
res.data.t_c_order = await vk.baseDao.count({
|
dbName: "uni-id-base-order",
|
whereJson: {
|
status: 2,
|
_add_time: _.and(_.gt(today), _.lt(today + 24 * 60 * 60 * 1000))
|
}
|
})
|
// 昨日客户订单
|
res.data.y_c_order = await vk.baseDao.count({
|
dbName: "uni-id-base-order",
|
whereJson: {
|
status: 2,
|
_add_time: _.and(_.gt(today - 24 * 60 * 60 * 1000), _.lt(today))
|
}
|
})
|
// 下单客户总数
|
res.data.a_c_order = await vk.baseDao.count({
|
dbName: "uni-id-base-order",
|
status: 2,
|
})
|
|
// 今日下单用户数
|
res.data.t_s_order = await vk.baseDao.count({
|
dbName: "uni-id-base-order",
|
whereJson: {
|
status: 2,
|
_add_time: _.and(_.gt(today), _.lt(today + 24 * 60 * 60 * 1000))
|
},
|
groupJson: {
|
_id: "$user_id", // _id是分组id， $ 后面接字段名
|
},
|
})
|
// 昨日下单用户数
|
res.data.y_s_order = await vk.baseDao.count({
|
dbName: "uni-id-base-order",
|
whereJson: {
|
status: 2,
|
_add_time: _.and(_.gt(today - 24 * 60 * 60 * 1000), _.lt(today))
|
},
|
groupJson: {
|
_id: "$user_id", // _id是分组id， $ 后面接字段名
|
},
|
})
|
// 总下单用户数
|
res.data.a_s_order = await vk.baseDao.count({
|
dbName: "uni-id-base-order",
|
whereJson: {
|
status: 2,
|
},
|
groupJson: {
|
_id: "$user_id", // _id是分组id， $ 后面接字段名
|
},
|
})
|
|
// 今年交易额度
|
//正常订单金额
|
|
res.data.t_g_money = await vk.baseDao.sum({
|
dbName: "uni-id-base-order",
|
fieldName: "total_fee",
|
whereJson: {
|
status: 2,
|
_add_time: _.and(_.gt(today), _.lt(today + 24 * 60 * 60 * 1000))
|
}
|
})
|
|
|
|
|
// 去年交易额度
|
//正常订单金额
|
res.data.y_g_money = await vk.baseDao.sum({
|
dbName: "uni-id-base-order",
|
fieldName: "total_fee",
|
whereJson: {
|
status: 2,
|
_add_time: _.and(_.gt(today - 24 * 60 * 60 * 1000), _.lt(today))
|
}
|
})
|
//退货交易金额
|
|
|
//总交易额
|
|
|
res.data.a_g_money = await vk.baseDao.sum({
|
dbName: "uni-id-base-order",
|
fieldName: "total_fee",
|
whereJson: {
|
status: 2
|
}
|
})
|
|
|
|
//总用户
|
res.data.a_g_user = await vk.baseDao.count({
|
dbName: "uni-id-users",
|
whereJson: {
|
|
}
|
});
|
|
//今日新注册
|
res.data.t_d_user = await vk.baseDao.count({
|
dbName: "uni-id-users",
|
whereJson: {
|
register_date: _.and(_.gt(today), _.lt(today + 24 * 60 * 60 * 1000))
|
}
|
});
|
|
|
//今日新注册
|
res.data.y_d_user = await vk.baseDao.count({
|
dbName: "uni-id-users",
|
whereJson: {
|
register_date: _.and(_.gt(today - 24 * 60 * 60 * 1000), _.lt(today))
|
|
}
|
});
|
|
|
// 正常订单待审核数量
|
|
// 回款折线图表
|
// let lastMonth = vk.pubfn.getDayOffsetStartAndEnd(-31).startTime
|
// let step = 24 * 60 * 60 * 1000
|
// let map = {
|
// _add_time: _.gt(lastMonth)
|
// }
|
// let obj = await db.collection('orders-received').where(map).field().get()
|
// const orderList = obj.data
|
// const dateList = []
|
// for (let i = lastMonth; i <= today; i += step) {
|
// let payArr = orderList.filter(item => {
|
// return item._add_time >= i && item._add_time < i + step
|
// }).map(item => {
|
// return item.rebate_amount
|
// })
|
|
// dateList.push({
|
// _id: vk.pubfn.timeFormat(i, "MM-dd"),
|
// sum: payArr.length > 0 ? +payArr.reduce((a, b) => a + b).toFixed(2) : 0
|
// })
|
// }
|
// res.chartData = dateList
|
// 回款饼图
|
// res.pieData = await vk.baseDao.selects({
|
// dbName: "orders-received",
|
// getMain: true,
|
// pageIndex: 1,
|
// pageSize: -1,
|
// whereJson: {
|
// status: _.exists(false)
|
// },
|
// groupJson: {
|
// _id: "$company_name",
|
// sum: _.$.sum("$rebate_amount")
|
// }
|
// })
|
|
// // 平台金额（初始金额 + 订单回款 + 开支 + 其他回款）
|
// let base_money = await vk.baseDao.sum({
|
// dbName: "base-money",
|
// fieldName: "number"
|
// })
|
// let daily_expenses = await vk.baseDao.sum({
|
// dbName: "daily-expenses",
|
// fieldName: "total"
|
// })
|
// let payback_record = await vk.baseDao.sum({
|
// dbName: "payback-record",
|
// fieldName: "total"
|
// })
|
// res.data.plant_total = base_money + res.data.a_g_money + daily_expenses + payback_record
|
|
// // 账号余额
|
// res.data.account = await vk.baseDao.sum({
|
// dbName: "account-balance",
|
// fieldName: "balance"
|
// })
|
|
// 业务逻辑结束-----------------------------------------------------------
|
return res;
|
}
|
}
|
