src/public/scheduler/scheduler_xiaofeijingsai.ts

@@ -39,20 +39,17 @@ export class Scheduler_xfjs_Local_Ctor extends Scheduler {
 
         let limit = _hd.data?.rank?.slice(-1)?.[0]?.rank?.slice(-1)?.[0] || 100
 
-        let rmbuse = await G.crossmongodb.collection('rmbuse').find({type: `xfjs_${_hd.hdid}`}).sort({change: 1}).limit(limit).toArray()
+        let rmbuse = await G.crossmongodb.collection('rmbuse').find({type: `xfjs_${G.huodong.xfjsId}`}).sort({change: 1}).limit(limit).toArray()
 
         let list: any = rmbuse.map(i => ({...i, total: R.negate(i.change)}))
 
-        let rankList = sortRankList(_hd.data.rank, list)
-
-        let userList = await G.crossmongodb.collection('huodong_user').find({uid: {$in: rankList.map(i => i._id).filter(i => i != 'system')}}).toArray()
-
-        rankList = rankList.map(i => ({...i, player: userList.find(v => v.uid == i.uid) || {}}))
+        let ranklist = sortRankList(_hd.data.rank, list)
 
         R.forEach(i => {
-            let users = R.slice(i.rank[0] - 1, i.rank[1])(rankList).filter(i => i._id != 'system')
+            let users = R.slice(i.rank[0] - 1, i.rank[1])(ranklist)
             users.map(v => {
-                if (G.config.serverId != v.player?.sid) return;
+                if (v._id == 'system') return
+                if (G.config.serverId != users.sid) return;
                 EmailFun.addEmail({
                     uid: v._id,
                     type: 'system',