diff --git a/src/main/java/com/hivekion/room/bean/AbtParentTask.java b/src/main/java/com/hivekion/room/bean/AbtParentTask.java
index 9902065..7b804d1 100644
--- a/src/main/java/com/hivekion/room/bean/AbtParentTask.java
+++ b/src/main/java/com/hivekion/room/bean/AbtParentTask.java
@@ -3,11 +3,8 @@ package com.hivekion.room.bean;
 import com.hivekion.room.RoomManager;
 import com.hivekion.room.func.TaskAction;
 import com.hivekion.scenario.entity.ScenarioTask;
-import java.util.concurrent.LinkedBlockingQueue;
-import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.ThreadFactory;
-import java.util.concurrent.ThreadPoolExecutor;
-import java.util.concurrent.TimeUnit;
+
+import java.util.concurrent.*;
 import java.util.concurrent.atomic.AtomicInteger;
 import org.springframework.web.reactive.function.client.WebClient;
 
@@ -75,6 +72,22 @@ public abstract class AbtParentTask implements TaskAction {
   public boolean getRoomStatus() {
     return RoomManager.isRunning(roomId);
   }
+
+  public void createBattleTaskOnTimingHandle(BizTaskOnTiming bizTaskOnTiming){
+    ScheduledExecutorService schedule = Executors.newScheduledThreadPool(
+            1);
+    schedule.scheduleWithFixedDelay(() -> {
+      bizTaskOnTiming.execTask();
+    }, 0, 10, TimeUnit.SECONDS);
+    //房间统一管理定时器；房间关闭后，定时器销毁
+    addScheduledExecutorServiceRefenceToRoom(schedule);
+  }
+
+}
+
+ interface BizTaskOnTiming{
+
+  public void execTask();
 }
 
 // 自定义线程工厂
diff --git a/src/main/java/com/hivekion/room/bean/BattleRootTask.java b/src/main/java/com/hivekion/room/bean/BattleRootTask.java
index 1cd1aa1..17836df 100644
--- a/src/main/java/com/hivekion/room/bean/BattleRootTask.java
+++ b/src/main/java/com/hivekion/room/bean/BattleRootTask.java
@@ -69,7 +69,7 @@ public class BattleRootTask extends AbtParentTask  {
   public void doSomeThing() {
     this.initBean();
     if(this.getRoomStatus()) {
-      long initduringTime = this.getDuringTime();
+      long initDuringTime = this.getDuringTime();
       StatisticBean statisticBean = statisticService.statistic(scenarioTask.getResourceId());
 //      statisticBean.getAmmunition().getCurrent()
       //初始化本次战斗任务各种资源数
@@ -80,90 +80,91 @@ public class BattleRootTask extends AbtParentTask  {
       redisUtil.hset(scenarioTask.getScenarioId()+"-"+roomId+"-"+scenarioTask.getResourceId(),"water",statisticBean.getWater().getCurrent());
       redisUtil.hset(scenarioTask.getScenarioId()+"-"+roomId+"-"+scenarioTask.getResourceId(),"person",statisticBean.getPerson().getCurrent());
       redisUtil.hset(scenarioTask.getScenarioId()+"-"+roomId+"-"+scenarioTask.getResourceId(),"team",statisticBean.getPerson().getCurrent());
-      redisUtil.hset(scenarioTask.getScenarioId()+"-"+roomId+"-"+scenarioTask.getResourceId(),"duringTime",initduringTime);
+      redisUtil.hset(scenarioTask.getScenarioId()+"-"+roomId+"-"+scenarioTask.getResourceId(),"duringTime",initDuringTime);
       log.info("===============================初始化本次战斗任务各种资源数====================================");
+
       //定时检查统计各种资源消耗量
-      ScheduledExecutorService schedule = Executors.newScheduledThreadPool(
-              1);
-      schedule.scheduleWithFixedDelay(() -> {
-        log.info("===============================定时检查统计各种资源消耗量 begin====================================");
-        Double teamConsume = null;
-        Long personConsume = null;
-        Double ammunitionConsume = null;
-        Double foodConsume = null;
-        Double waterConsume = null;
-        Double fuelConsume = null;
-        Double medicalConsume = null;
-        JSONObject jsonObject = new JSONObject();
-        try {
-          long duringTime = getDuringTime();
-          long lastDuringTime = (long) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "duringTime");
-          long intervalDuringTime = duringTime - lastDuringTime;
-          double ammunition = (double) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "ammunition");
-          double food = (double) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "food");
-          double fuel = (double) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "fuel");
-          double medical = (double) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "medical");
-          double water = (double) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "water");
-          int person = (int) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "person");
-          double team = (double) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "team");
+      this.createBattleTaskOnTimingHandle(new BizTaskOnTiming() {
+        @Override
+        public void execTask() {
+          log.info("===============================定时检查统计各种资源消耗量 begin====================================");
+          Double teamConsume = null;
+          Long personConsume = null;
+          Double ammunitionConsume = null;
+          Double foodConsume = null;
+          Double waterConsume = null;
+          Double fuelConsume = null;
+          Double medicalConsume = null;
+          JSONObject jsonObject = new JSONObject();
+          try {
+            long duringTime = getDuringTime();
+            long lastDuringTime = (long) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "duringTime");
+            long intervalDuringTime = duringTime - lastDuringTime;
+            double ammunition = (double) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "ammunition");
+            double food = (double) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "food");
+            double fuel = (double) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "fuel");
+            double medical = (double) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "medical");
+            double water = (double) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "water");
+            int person = (int) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "person");
+            double team = (double) redisUtil.hget(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "team");
 
-          //
-           teamConsume = intervalDuringTime * TEAM_SPREED;
-           personConsume = intervalDuringTime * PERSON_SPREED;
-           ammunitionConsume = intervalDuringTime * AMMUNITION_SPREED;
-           foodConsume = intervalDuringTime * FOOD_SPREED;
-           waterConsume = intervalDuringTime * WATER_SPREED;
-           fuelConsume = intervalDuringTime * FUEL_SPREED;
-           medicalConsume = intervalDuringTime * MEDICAL_SPREED;
+            //
+            teamConsume = intervalDuringTime * TEAM_SPREED;
+            personConsume = intervalDuringTime * PERSON_SPREED;
+            ammunitionConsume = intervalDuringTime * AMMUNITION_SPREED;
+            foodConsume = intervalDuringTime * FOOD_SPREED;
+            waterConsume = intervalDuringTime * WATER_SPREED;
+            fuelConsume = intervalDuringTime * FUEL_SPREED;
+            medicalConsume = intervalDuringTime * MEDICAL_SPREED;
 
-          redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "ammunition", ammunition - ammunitionConsume);
-          redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "food", food - foodConsume);
-          redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "fuel", fuel - fuelConsume);
-          redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "medical", medical - medicalConsume);
-          redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "water", water - waterConsume);
-          redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "person", person - personConsume);
-          redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "team", team - teamConsume);
-          redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "duringTime", duringTime);
-        }catch (Exception ex){
-          log.error("==============================设置消耗信息失败=============================================",ex.getMessage());
-        }
-        try {
-          //推送消耗數據
-          ResponseCmdInfo<JSONObject> sendConsumeMsg = new ResponseCmdInfo<>();
-          jsonObject.put("teamConsume", teamConsume);
-          jsonObject.put("personConsume", personConsume);
-          jsonObject.put("ammunitionConsume", ammunitionConsume);
-          jsonObject.put("foodConsume", foodConsume);
-          jsonObject.put("waterConsume", waterConsume);
-          jsonObject.put("fuelConsume", fuelConsume);
-          jsonObject.put("medicalConsume", medicalConsume);
-          sendConsumeMsg.setData(jsonObject);
-          Global.sendCmdInfoQueue.add(sendConsumeMsg);
-        }catch (Exception ex){
-          log.error("==================推送消耗數據 失败============================================",ex.getMessage());
-        }
-
-        try {
-          LocalDateTime currentDateTime = new Date().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime();
-          List<SupplierRequest> requestList = new ArrayList<>();
-          Set<Map.Entry<String, Object>> consumeSet = jsonObject.entrySet();
-          for (Map.Entry<String, Object> consumeEntry : consumeSet) {
-            SupplierRequest supplierRequest = new SupplierRequest();
-            supplierRequest.setFromResourceId(scenarioTask.getResourceId());
-            supplierRequest.setSupplierNum((Double) consumeEntry.getValue());
-            supplierRequest.setSupplierType(consumeEntry.getKey());
-            supplierRequest.setGeneralTime(currentDateTime);
-            requestList.add(supplierRequest);
+            redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "ammunition", ammunition - ammunitionConsume);
+            redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "food", food - foodConsume);
+            redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "fuel", fuel - fuelConsume);
+            redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "medical", medical - medicalConsume);
+            redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "water", water - waterConsume);
+            redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "person", person - personConsume);
+            redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "team", team - teamConsume);
+            redisUtil.hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(), "duringTime", duringTime);
+          }catch (Exception ex){
+            log.error("==============================设置消耗信息失败=============================================",ex.getMessage());
+          }
+          try {
+            //推送消耗數據
+            ResponseCmdInfo<JSONObject> sendConsumeMsg = new ResponseCmdInfo<>();
+            jsonObject.put("teamConsume", teamConsume);
+            jsonObject.put("personConsume", personConsume);
+            jsonObject.put("ammunitionConsume", ammunitionConsume);
+            jsonObject.put("foodConsume", foodConsume);
+            jsonObject.put("waterConsume", waterConsume);
+            jsonObject.put("fuelConsume", fuelConsume);
+            jsonObject.put("medicalConsume", medicalConsume);
+            sendConsumeMsg.setData(jsonObject);
+            Global.sendCmdInfoQueue.add(sendConsumeMsg);
+          }catch (Exception ex){
+            log.error("==================推送消耗數據 失败============================================",ex.getMessage());
           }
-          supplierRequestService.saveBatch(requestList);
-        }catch (Exception ex){
-           log.error("===========BattleRootTask supplierRequestService.saveBatch error====================",ex.getMessage());
-        }
-        log.info("===============================定时检查统计各种资源消耗量 end====================================");
-      }, 0, 10, TimeUnit.SECONDS);
 
-      //房间统一管理定时器；房间关闭后，定时器销毁
-      addScheduledExecutorServiceRefenceToRoom(schedule);
+          try {
+            LocalDateTime currentDateTime = new Date().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime();
+            List<SupplierRequest> requestList = new ArrayList<>();
+            Set<Map.Entry<String, Object>> consumeSet = jsonObject.entrySet();
+            for (Map.Entry<String, Object> consumeEntry : consumeSet) {
+              SupplierRequest supplierRequest = new SupplierRequest();
+              supplierRequest.setFromResourceId(scenarioTask.getResourceId());
+              supplierRequest.setSupplierNum((Double) consumeEntry.getValue());
+              supplierRequest.setSupplierType(consumeEntry.getKey());
+              supplierRequest.setGeneralTime(currentDateTime);
+              requestList.add(supplierRequest);
+            }
+            supplierRequestService.saveBatch(requestList);
+          }catch (Exception ex){
+            log.error("===========BattleRootTask supplierRequestService.saveBatch error====================",ex.getMessage());
+          }
+          log.info("===============================定时检查统计各种资源消耗量 end====================================");
+        }
+      });
+
+
     }