|
@ -300,6 +300,8 @@ async function getLatestDynamic (ctx) { |
|
|
order: [['time', 'desc']], |
|
|
order: [['time', 'desc']], |
|
|
}); |
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
console.log(111111,news); |
|
|
|
|
|
|
|
|
//查项目名称 查用户名
|
|
|
//查项目名称 查用户名
|
|
|
let pepPojectIds = new Set(), notedUserIds = new Set(), emailSendPomsProjectIds = new Set(); |
|
|
let pepPojectIds = new Set(), notedUserIds = new Set(), emailSendPomsProjectIds = new Set(); |
|
|
for (let p of news) { |
|
|
for (let p of news) { |
|
@ -318,6 +320,10 @@ async function getLatestDynamic (ctx) { |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
console.log(222222,notedUserIds); |
|
|
|
|
|
console.log(333333,emailSendPomsProjectIds); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// EM 推送的特殊处理
|
|
|
// EM 推送的特殊处理
|
|
|
// 查找对应的 projectCorrelation
|
|
|
// 查找对应的 projectCorrelation
|
|
|
const emailLogProjectCorrelationRes = |
|
|
const emailLogProjectCorrelationRes = |
|
@ -328,19 +334,31 @@ async function getLatestDynamic (ctx) { |
|
|
} |
|
|
} |
|
|
}) : [] |
|
|
}) : [] |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
console.log(444444,emailLogProjectCorrelationRes); |
|
|
|
|
|
|
|
|
for (let { dataValues: p } of emailLogProjectCorrelationRes) { |
|
|
for (let { dataValues: p } of emailLogProjectCorrelationRes) { |
|
|
if (p.pepProjectId) { |
|
|
if (p.pepProjectId) { |
|
|
pepPojectIds.add(p.pepProjectId) |
|
|
pepPojectIds.add(p.pepProjectId) |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
console.log(555555,pepPojectIds); |
|
|
|
|
|
|
|
|
let pepProjects = pepPojectIds.size ? await clickHouse.projectManage.query(` |
|
|
let pepProjects = pepPojectIds.size ? await clickHouse.projectManage.query(` |
|
|
SELECT id, project_name FROM t_pim_project WHERE id IN (${[...pepPojectIds].join(',')},-1) |
|
|
SELECT id, project_name FROM t_pim_project WHERE id IN (${[...pepPojectIds].join(',')},-1) |
|
|
`).toPromise() : [];
|
|
|
`).toPromise() : [];
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
console.log(666666,pepProjects); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
let userPepRes = notedUserIds.size ? await clickHouse.pepEmis.query( |
|
|
let userPepRes = notedUserIds.size ? await clickHouse.pepEmis.query( |
|
|
`SELECT DISTINCT user.id AS id, "user"."name" AS name FROM user WHERE user.id IN (${[...notedUserIds].join(',')},-1)
|
|
|
`SELECT DISTINCT user.id AS id, "user"."name" AS name FROM user WHERE user.id IN (${[...notedUserIds].join(',')},-1)
|
|
|
`).toPromise() : []
|
|
|
`).toPromise() : []
|
|
|
|
|
|
|
|
|
|
|
|
console.log(777777,userPepRes); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
let appear = [], notice = [], confirm = []; |
|
|
let appear = [], notice = [], confirm = []; |
|
|
news.map(d => { |
|
|
news.map(d => { |
|
@ -381,6 +399,7 @@ async function getLatestDynamic (ctx) { |
|
|
confirm//确认
|
|
|
confirm//确认
|
|
|
}; |
|
|
}; |
|
|
} catch (error) { |
|
|
} catch (error) { |
|
|
|
|
|
console.log(888888,error); |
|
|
ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`); |
|
|
ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`); |
|
|
ctx.status = 400; |
|
|
ctx.status = 400; |
|
|
ctx.body = { |
|
|
ctx.body = { |
|
|