no message

src/biz/member/msgActivity.ts

@@ -5,7 +5,7 @@
 import moment = require("moment");
 import { ACTIVITYSTATE, ACTIVITYTYPE, CLIENTACTIVITYLABLE, CLIENTACTIVITYSTATE, CLIENTMSGLABLE, MEMBERLEVEL, MEMBERTYPE, STATE } from "../../config/enum";
 import { ERRORENUM } from "../../config/errorEnum";
-import { addOneData } from "../../data/add";
+import { addManyData, addOneData } from "../../data/add";
 import { TABLEENUM } from "../../data/models/model";
 import { find, findCount, findOnce, findToPage, findToSort, findToSortToPage } from "../../data/select";
 import { generateSystemId, getTodayMs, successErrorResult, successResult } from "../../tools/system";
@@ -112,17 +112,18 @@ export async function addMessage({userId, lableId, msgTitle, effectiveTime, msgC
     }
 
     let userInfo = await find(TABLEENUM.用户表, selectParam, ["userId"]);
+    let addReadInfo = [];
     for (let i = 0; i < userInfo.length; i++) {
         /**消息已读Id */
         const readId = generateSystemId(TABLEENUM.消息已读状态表, userId);
-        let addReadInfo = {
+        addReadInfo.push({
             readId,
             msgId,
             userId:userInfo[i].userId,
             isRead:STATE.否
-        }
-        await addOneData(TABLEENUM.消息已读状态表, addReadInfo);
+        });
     }
+    await addManyData(TABLEENUM.消息已读状态表, addReadInfo);
 
     return successResult();
 }
@@ -187,7 +188,7 @@ export async function delMessage({msgId}) {
 
     let dataList = [];
     const SelectFiles = ["msgId", "msgTitle", "effectiveTime", "msgContent", "isPop"];
-    let msgInfo = await find(TABLEENUM.消息通知表, selectParam, SelectFiles);
+    let msgInfo = await findToSort(TABLEENUM.消息通知表, selectParam, {createTime:-1}, SelectFiles);
     // if (!msgInfo || !msgInfo.msgId) throw new BizError(ERRORENUM.目标数据不存在);
     if (msgInfo) {
         msgInfo.forEach( info => {
@@ -409,17 +410,18 @@ export async function addActivity({userId, form}) {
         selectParam = {lableId:{"$in":form.lableId}}
     }
     let userInfo = await find(TABLEENUM.用户表, selectParam, ["userId"]);
+    let addReadInfo = [];
     for (let i = 0; i < userInfo.length; i++) {
         /**活动已读Id */
         const arId = generateSystemId(TABLEENUM.活动通知已读状态表, userId);
-        let addReadInfo = {
+        addReadInfo.push({
             arId,
             activityId,
             userId:userInfo[i].userId,
             isRead:STATE.否
-        }
-        await addOneData(TABLEENUM.活动通知已读状态表, addReadInfo);
+        });
     }
+    await addManyData(TABLEENUM.活动通知已读状态表, addReadInfo);
 
     return successResult();
 }