From 04019064039c3d92b238c52bbe7e39da41cf8dae Mon Sep 17 00:00:00 2001 From: zhl Date: Wed, 9 Jun 2021 19:50:52 +0800 Subject: [PATCH] =?UTF-8?q?=E9=82=AE=E4=BB=B6=E5=88=97=E8=A1=A8=E6=94=AF?= =?UTF-8?q?=E6=8C=81=E7=9F=AD=E5=BA=97=E9=93=BAid?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/api/controllers/mail.controller.ts | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/src/api/controllers/mail.controller.ts b/src/api/controllers/mail.controller.ts index 7575879..5c3d9df 100644 --- a/src/api/controllers/mail.controller.ts +++ b/src/api/controllers/mail.controller.ts @@ -4,19 +4,27 @@ import { UserMail } from '../../models/user/UserMail' import { SysMail } from '../../models/content/SysMail' import { ZError } from '../../common/ZError' import { UserReward } from '../../models/user/UserReward' +import { Shop } from '../../models/shop/Shop' class MailController extends BaseController { @role('anon') @router('post /api/:accountId/mails') async list(req: any) { const { accountId, sid } = req.params + if (!sid) { + throw new ZError(10, '缺少必要参数: sid') + } + const shop = await Shop.fetchByID(sid) + if (!shop) { + throw new ZError(11, '无法找到对应店铺') + } await UserMail.updateExpire(accountId) let mails = await UserMail.find({ accountId }).sort({ status: 1, _id: -1 }) let mailSet: Set = new Set() for (let mail of mails) { mailSet.add(mail.oid) } - let sysMails = await SysMail.findMail(accountId, sid, [...mailSet]) + let sysMails = await SysMail.findMail(accountId, shop.id, [...mailSet]) if (sysMails?.length > 0) { for (let _m of sysMails) { let mail = await UserMail.receiveOne(accountId, _m)