diff --git a/src/api_cross/wzry/ApiRank.ts b/src/api_cross/wzry/ApiRank.ts
index 767fdc8..77ccad7 100644
--- a/src/api_cross/wzry/ApiRank.ts
+++ b/src/api_cross/wzry/ApiRank.ts
@@ -1,23 +1,29 @@
 import {ApiCall} from "tsrpc";
 import {ReqRank, ResRank} from "../../cross/protocols/wzry/PtlRank";
 import {player} from "../../shared/protocols/user/type";
-import {FindOptions} from "mongodb";
+import {Filter, FindOptions, OptionalId} from "mongodb";
+import { CollectionRankList } from "../../module/collection_rank";
 
-export async function getRankList(limit?: number, projection?: any) {
+export async function getRankList(limit?: number, projection?: any, _where?:any) {
     let option: FindOptions = {
         sort: {
             'data.valArr': -1,
             'data.player.power': -1
         }
     }
+    let filter:Filter<OptionalId<CollectionRankList>> = {type: 'wzryCross'};
+
     if (limit != null) {
         option.limit = limit;
     }
     if (projection != null) {
         option.projection = projection;
     }
+    if (_where != null) {
+        Object.assign(filter, _where);
+    }
 
-    let listArr = await G.mongodb.collection('rankList').find({type: 'wzryCross'}, option).toArray();
+    let listArr = await G.mongodb.collection('rankList').find(filter, option).toArray();
     let list = listArr.map(l => l.data);
 
     return list;
diff --git a/src/public/scheduler/scheduler_wzry.ts b/src/public/scheduler/scheduler_wzry.ts
index 2ae2094..02d3a8a 100644
--- a/src/public/scheduler/scheduler_wzry.ts
+++ b/src/public/scheduler/scheduler_wzry.ts
@@ -102,9 +102,10 @@ export class SchedulerWzryDlDjinji extends SchedulerWzryAutoBaoMing {
             return
         }
 
-        let _zuanshiUser = await getRankList(null,{
+        let _zuanshiUser = await getRankList(256,{
             'data.player.uid':1
-        }); //Rank.list.wzryCross.getRankListAll()  
+        },{'data.player.isNpc':{$exists:false}});
+
         if (_zuanshiUser.length < 256) {
             console.log("本期无玩家,此次不执行")
             await this.record()
@@ -117,10 +118,10 @@ export class SchedulerWzryDlDjinji extends SchedulerWzryAutoBaoMing {
         for (let index = 0; index < _zuanshiUser.length; index++) {
             const element = _zuanshiUser[index];
             _userList.push(element.player.uid)
-            if (element.player.uid.indexOf('npc_') != -1) {
-                if (_userList.length >= 256) break
-                continue
-            }
+            // if (element.player.uid.indexOf('npc_') != -1) {
+            //     if (_userList.length >= 256) break
+            //     continue
+            // }
             // 发送晋级钻石赛奖励
             prize.length > 0 && EmailFun.addEmail({
                 uid: element.player.uid,