diff --git a/game-server/app/services/battleService.ts b/game-server/app/services/battleService.ts
index 06baf4b40..4e91c1c4f 100644
--- a/game-server/app/services/battleService.ts
+++ b/game-server/app/services/battleService.ts
@@ -122,13 +122,16 @@ export async function getTasks(roleId: string) {
     if(needRefresh) {
         role = await RoleModel.resetTowerCnt(roleId, curTime); 
         const batchCode = genCode(8);
-        let preTasks = await TowerTaskRecModel.getPreTasks(roleId);
-        if(preTasks && preTasks.length) {
-            let checkResult = checkTaskRewards(preTasks[0].batchCode, preTasks );
-            if(checkResult) {
-                await sendMailByContent(MAIL_TYPE.TOWER_TASK_REWARD, roleId, { goods: checkResult.rewards });
-                await TowerTaskRecModel.finishTask(preTasks[0].batchCode, preTasks.map(cur => cur.taskCode));
-            };
+        let tasksData = await TowerTaskRecModel.getPreTasks(roleId);
+        let preTasksMap = treatPreTasks(tasksData);
+        for(let [batchCode, preTasks] of preTasksMap) {
+            if(preTasks && preTasks.length) {
+                let checkResult = checkTaskRewards(batchCode, preTasks );
+                if(checkResult) {
+                    await sendMailByContent(MAIL_TYPE.TOWER_TASK_REWARD, roleId, { goods: checkResult.rewards });
+                    await TowerTaskRecModel.finishTask(batchCode, preTasks.map(cur => cur.taskCode));
+                };
+            }
         }
         
         curTasks = await refreshTasks(towerLv, batchCode, roleId, roleName, []); // 新建任务
@@ -146,13 +149,23 @@ export async function getTasks(roleId: string) {
     return {curTasks: treatTask(curTasks, curTime), refRemainTime, nextCostGold}
 }
 
+function treatPreTasks(tasks: TowerTaskRecType[]) {
+    let map = new Map<string, TowerTaskRecType[]>();
+    for(let task of tasks) {
+        if(!map.has(task.batchCode)) {
+            map.set(task.batchCode, []);
+        }
+        map.get(task.batchCode).push(task);
+    }
+    return map
+}
+
 export function checkTaskRewards(batchCode: string, tasks: TowerTaskRecType[]) {
     const curTime = new Date();
     let compTasks: string[] = [];
     let rewards: RewardInter[] = [];
     for (let task of tasks) {
-        if(task.batchCode != batchCode) return false;
-        if ( task.status === TOWER_TASK_STATUS.DOINING) {
+        if ( task.batchCode == batchCode && task.status === TOWER_TASK_STATUS.DOINING) {
             let {completeTime, reward, termsForAdd, additionalReward} = gameData.towerTask.get(task.taskId);
             if (task.sendTime && task.sendTime.getTime() + completeTime * 1000 < curTime.getTime()) {
                 compTasks.push(task.taskCode);
diff --git a/shared/db/TowerTaskRec.ts b/shared/db/TowerTaskRec.ts
index 511ae4d18..930a40c12 100644
--- a/shared/db/TowerTaskRec.ts
+++ b/shared/db/TowerTaskRec.ts
@@ -39,6 +39,7 @@ export class TaskHero {
   */
 @index({ roleId: 1, status: 1 })
 @index({ batchCode: 1 })
+@index({ createdAt: -1 })
 export default class TowerTaskRec extends BaseModel {
   @prop({ required: true })
   roleId: string; // 角色 id
@@ -71,7 +72,7 @@ export default class TowerTaskRec extends BaseModel {
 
   public static async getPreTasks(roleId: string) {
     let today = getZeroPointD();
-    const recs: TowerTaskRecType[] = await TowerTaskRecModel.find({ roleId, createdAt: { $lt: today }, status: TOWER_TASK_STATUS.DOINING }).sort({ position: 1}).lean();
+    const recs: TowerTaskRecType[] = await TowerTaskRecModel.find({ roleId, createdAt: { $lt: today }, status: TOWER_TASK_STATUS.DOINING }).sort({ createdAt: -1, position: 1}).lean();
     return recs;
   }