// 开发文档: https://uniapp.dcloud.net.cn/uniCloud/cloud-obj
|
function uniPush(appId) {
|
return uniCloud.getPushManager({appId})
|
}
|
const uniID = require('uni-id-common')
|
module.exports = {
|
_before: async function() {
|
const clientInfo = this.getClientInfo()
|
this.uniID = uniID.createInstance({
|
clientInfo
|
})
|
const token = this.getUniIdToken()
|
let payload = await this.uniID.checkToken(token)
|
let role = payload.role||[]
|
//检查是不是管理员，或者自己的云函数调用此云函数
|
if(clientInfo.source != 'server' && !role.includes('admin')){
|
return {
|
errCode: 'uni-push-co-permission-denied',
|
errMsg: '你没有访问此接口权限'
|
}
|
}
|
},
|
async sendMessage(data) {
|
const appId = data.appId
|
data.must_report = true //默认为false，消息接受者为单设备时，不统计推送结果。开启此项将都会统计。但整体推送速度会慢100-500毫秒
|
// delete data.appId
|
let res = await uniPush(appId).sendMessage(data)
|
if (res.errCode == 0 && res.before_id) {
|
const UniPushCo = uniCloud.importObject("uni-push-co")
|
data.before_id = res.before_id //查询的初始id，用于高性能分页查询
|
data.taskid = res.data.taskid || Object.keys(res.data)[0]
|
|
UniPushCo.sendMessage(data).catch(e=>{
|
// console.log(e.message);
|
})
|
// 等待500毫秒给下一个请求发出去的时间
|
return new Promise((resolve, reject) => {
|
setTimeout(() => {
|
resolve(res)
|
}, 500)
|
})
|
}
|
return res
|
},
|
async getReport({
|
appId,
|
taskid
|
}) {
|
let res = await uniPush(appId).getReport({
|
taskid
|
})
|
//获取推送结果
|
console.log(JSON.stringify(res));
|
return res
|
},
|
async getAdminUrl(appId) {
|
let res = await uniPush(appId).getAdminUrl() //获取推送结果
|
console.log(JSON.stringify(res));
|
return res
|
}
|
}
|
