diff --git a/src/main/java/com/hivekion/room/bean/MoveRootTask.java b/src/main/java/com/hivekion/room/bean/MoveRootTask.java
index f6d7b45..f630946 100644
--- a/src/main/java/com/hivekion/room/bean/MoveRootTask.java
+++ b/src/main/java/com/hivekion/room/bean/MoveRootTask.java
@@ -1,33 +1,14 @@
 package com.hivekion.room.bean;
 
 import cn.hutool.extra.spring.SpringUtil;
-import com.alibaba.fastjson2.JSON;
-import com.alibaba.fastjson2.JSONArray;
-import com.alibaba.fastjson2.JSONObject;
-import com.hivekion.Global;
-import com.hivekion.baseData.entity.Scenario;
-import com.hivekion.baseData.service.ScenarioService;
-import com.hivekion.common.MultiPointGeoPosition;
-import com.hivekion.common.entity.ResponseCmdInfo;
 import com.hivekion.common.redis.RedisUtil;
-import com.hivekion.enums.WsCmdTypeEnum;
 import com.hivekion.room.func.TaskAction;
 import com.hivekion.scenario.entity.ScenarioTask;
 import com.hivekion.statistic.bean.StatisticBean;
 import com.hivekion.statistic.service.impl.StatisticServiceImpl;
-import java.time.Duration;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Map.Entry;
-import java.util.NavigableMap;
-import java.util.TreeMap;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicReference;
-import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.core.env.Environment;
 
@@ -97,8 +78,6 @@ public class MoveRootTask extends AbtParentTask implements TaskAction {
 
 
 
-
-
   private void fuelConsumption() {
 
     ScheduledExecutorService schedule = Executors.newScheduledThreadPool(
@@ -107,16 +86,14 @@ public class MoveRootTask extends AbtParentTask implements TaskAction {
       if (getRoomStatus()) {
         double currentUseUp = consumptionTaskInterval * SPEED / 1000 * fuelConsumption;
 
-
-
         //更新redis中油品的消耗
         Object currentFuelObj = redis.hget(
             scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
-            "fuelConsume");
+            "fuel");
         if (currentFuelObj != null) {
           double fuel = Double.parseDouble(currentFuelObj.toString());
-            fuel = fuel + currentUseUp;
-            //更新值
+          fuel = fuel - currentUseUp;
+
             redis.hset(
                 scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
                 "fuelConsume", fuel);
@@ -124,11 +101,12 @@ public class MoveRootTask extends AbtParentTask implements TaskAction {
 
           double totalFuel =  statisticBean.getFuel().getTotal();
           if(fuel*100/totalFuel<fuelThreshold){
-              //产生一个需求
-            //insertRequest(totalFuel-fuel,getDuringTime());
+                //需要产生需求
+                //产生任务
+                //插入消耗表
           }
         }
-       // statistic();
+
       }
 
 
@@ -136,86 +114,7 @@ public class MoveRootTask extends AbtParentTask implements TaskAction {
 
   }
 
-//  private void statistic() {
-//
-//    Object positionObj = redis.hget(
-//        scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
-//        "position");
-//    if (positionObj != null) {
-//      Coordinate coordinate = JSONObject.parseObject(positionObj.toString(), Coordinate.class);
-//      statisticBean.getTeam().setLat(coordinate.lat + "");
-//      statisticBean.getTeam().setLng(coordinate.lng + "");
-//
-//    }
-//    //设置人员受伤信息
-//    Object deathPerson = redis.hget(
-//        scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
-//        "deathConsume");
-//    if (deathPerson != null) {
-//      statisticBean.getPerson().setDeath(Integer.parseInt(deathPerson.toString()));
-//      statisticBean.getPerson().setCurrent(
-//          statisticBean.getPerson().getTotal() - Integer.parseInt(deathPerson.toString()));
-//    }
-//    Object injuredPerson = redis.hget(
-//        scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
-//        "injuredConsume");
-//    if (injuredPerson != null) {
-//      statisticBean.getPerson().setInjured(Integer.parseInt(injuredPerson.toString()));
-//    }
-//    //设置弹药信息
-//    Object ammunitionObj = redis.hget(
-//        scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
-//        "ammunitionConsume");
-//    if (ammunitionObj != null) {
-//      statisticBean.getAmmunition().setCurrent(
-//          statisticBean.getAmmunition().getTotal() - Integer.parseInt(ammunitionObj.toString()));
-//    }
-//    //设置食品信息
-//    Object foodObj = redis.hget(
-//        scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
-//        "foodConsume");
-//    if (foodObj != null) {
-//      statisticBean.getFood()
-//          .setCurrent(statisticBean.getFood().getTotal() - Integer.parseInt(foodObj.toString()));
-//    }
-//    //设置水信息
-//    Object waterObj = redis.hget(
-//        scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
-//        "waterConsume");
-//    if (waterObj != null) {
-//      statisticBean.getWater()
-//          .setCurrent(statisticBean.getWater().getTotal() - Integer.parseInt(waterObj.toString()));
-//    }
-//    //设置油料信息
-//    Object fuelObj = redis.hget(
-//        scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
-//        "fuelConsume");
-//    if (fuelObj != null) {
-//      statisticBean.getFuel()
-//          .setCurrent(statisticBean.getFuel().getTotal() - Integer.parseInt(fuelObj.toString()));
-//    }
-//    //设置药品信息
-//    Object medicalObj = redis.hget(
-//        scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
-//        "medicalConsume");
-//    if (medicalObj != null) {
-//      statisticBean.getMedical().setCurrent(
-//          statisticBean.getMedical().getTotal() - Integer.parseInt(medicalObj.toString()));
-//    }
-//    Global.sendCmdInfoQueue.add(
-//        ResponseCmdInfo.create(WsCmdTypeEnum.STATISTIC.getCode(), roomId,
-//            scenarioTask.getScenarioId(), statisticBean));
-//  }
-  //插入需求表
-//  private void insertRequest(double num,long second){
-//
-//
-//  }
-//  //插入消耗表
-//  private void insertConsumption (double num,long second) {
-//
-//
-//  }
+
 
 }
 
diff --git a/src/main/java/com/hivekion/room/bean/SupplierTask.java b/src/main/java/com/hivekion/room/bean/SupplierTask.java
index e4f0c34..9cf2f79 100644
--- a/src/main/java/com/hivekion/room/bean/SupplierTask.java
+++ b/src/main/java/com/hivekion/room/bean/SupplierTask.java
@@ -1,7 +1,11 @@
 package com.hivekion.room.bean;
 
+import cn.hutool.extra.spring.SpringUtil;
+import com.hivekion.common.redis.RedisUtil;
 import com.hivekion.room.func.TaskAction;
 import com.hivekion.scenario.entity.ScenarioTask;
+import com.hivekion.statistic.bean.StatisticBean;
+import com.hivekion.statistic.service.StatisticService;
 
 /**
  * [类的简要说明]
@@ -21,9 +25,87 @@ public class SupplierTask extends AbtParentTask implements TaskAction {
 
   @Override
   public void doSomeThing() {
+    StatisticBean statistic = SpringUtil.getBean(StatisticService.class)
+        .statistic(scenarioTask.getResourceId());
+    initPath(); //初始化路径
+    updatePath(30, new TaskAction() {
+
+      @Override
+      public void doSomeThing() {
+        //达到终点点后，给目标补充物资
+        switch (scenarioTask.getTaskType()) {
+          case "4":
+            supplierAmmunition(statistic);
+            break;
+          case "5":
+            supplierWater(statistic);
+            break;
+          case "6":
+            supplierFuel(statistic);
+            break;
+          case "7":
+            supplierFood(statistic);
+            break;
+          case "8":
+            supplierMedical(statistic);
+            break;
+        }
+        //推送最新状态信息
+
+      }
+
+      @Override
+      public String getId() {
+        return "";
+      }
+
+      @Override
+      public String getType() {
+        return "";
+      }
+    });
+  }
+
+  private void supplierMedical(StatisticBean statistic) {
+
+    SpringUtil.getBean(RedisUtil.class)
+        .hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
+            "medical", statistic.getMedical().getTotal());
+
+
+  }
+
+  private void supplierFuel(StatisticBean statistic) {
+
+    SpringUtil.getBean(RedisUtil.class)
+        .hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
+            "fuel", statistic.getFuel().getTotal());
+
+  }
+
+  private void supplierAmmunition(StatisticBean statistic) {
+
+    SpringUtil.getBean(RedisUtil.class)
+        .hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
+            "ammunition", statistic.getAmmunition().getTotal());
+
+  }
+
+  private void supplierWater(StatisticBean statistic) {
+
+    SpringUtil.getBean(RedisUtil.class)
+        .hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
+            "water", statistic.getWater().getTotal());
+
+  }
+
+  private void supplierFood(StatisticBean statistic) {
+
+    SpringUtil.getBean(RedisUtil.class)
+        .hset(scenarioTask.getScenarioId() + "-" + roomId + "-" + scenarioTask.getResourceId(),
+            "food", statistic.getFood().getTotal());
 
   }
 
 
-
 }