diff --git a/src/main/java/com/lz/modules/app/controller/TestController.java b/src/main/java/com/lz/modules/app/controller/TestController.java
index d90ff5c7..ab853483 100644
--- a/src/main/java/com/lz/modules/app/controller/TestController.java
+++ b/src/main/java/com/lz/modules/app/controller/TestController.java
@@ -306,7 +306,7 @@ public class TestController {
     }
 
 
-    // 重置：http://localhost:8080/lz_management/test/approval?resultRecordId=3702&status=9&menuName=cccc&flowRecordId=33987&resetFlag=0
+    // 重置：http://localhost:8080/lz_management/test/approval?resultRecordId=3682&status=9&menuName=cccc&flowRecordId=33919&resetFlag=0
     @RequestMapping("/test/approval")
     public R approval(ApprovalDto approvalDto) {
         try {
diff --git a/src/main/java/com/lz/modules/app/dto/ApprovalDto.java b/src/main/java/com/lz/modules/app/dto/ApprovalDto.java
index dde458e2..0181ebbe 100644
--- a/src/main/java/com/lz/modules/app/dto/ApprovalDto.java
+++ b/src/main/java/com/lz/modules/app/dto/ApprovalDto.java
@@ -12,4 +12,5 @@ public class ApprovalDto {
     private Long transferStaffId;   // 转交员工 id
     private Long flowRecordId;//   流程 id
     private int resetFlag;
+    private int clearFlag;//0 全清，1 还是保留指标
 }
diff --git a/src/main/java/com/lz/modules/flow/dao/FlowRecordMapper.java b/src/main/java/com/lz/modules/flow/dao/FlowRecordMapper.java
index 3ca3392c..32a5e48d 100644
--- a/src/main/java/com/lz/modules/flow/dao/FlowRecordMapper.java
+++ b/src/main/java/com/lz/modules/flow/dao/FlowRecordMapper.java
@@ -99,4 +99,8 @@ public interface FlowRecordMapper extends BaseMapper<FlowRecord> {
 	void deleteFlowRecordByRecordId(@Param("recordId") Long recordId);
 
 	void updateFlowRecordIdById(@Param("id") Long id, @Param("newId") Long newId);
+
+	FlowRecord selectPreFlowRecordByRecordIdMinIdStatusList(@Param("recordId") Long recordId, @Param("flowIndex") Integer flowIndex, @Param("statusList") List<Integer> statusList);
+
+	List<FlowRecord> selectFlowRecordByRecordIdFlowIndexStatusList(@Param("recordId") Long recordId, @Param("flowIndex") Integer flowIndex, @Param("statusList") List<Integer> statusList);
 }
\ No newline at end of file
diff --git a/src/main/java/com/lz/modules/flow/service/FlowRecordService.java b/src/main/java/com/lz/modules/flow/service/FlowRecordService.java
index fecd051f..7b2eca4f 100644
--- a/src/main/java/com/lz/modules/flow/service/FlowRecordService.java
+++ b/src/main/java/com/lz/modules/flow/service/FlowRecordService.java
@@ -94,5 +94,9 @@ public interface FlowRecordService extends IService<FlowRecord> {
 
 	void deleteFlowRecordByRecordId(Long recordId);
 
-	void updateFlowRecordIdById(@Param("id") Long id, @Param("newId") Long newId);
+	void updateFlowRecordIdById(Long id, Long newId);
+
+	FlowRecord selectPreFlowRecordByRecordIdMinIdStatusList(Long recordId, Integer flowIndex, List<Integer> statusList);
+
+	List<FlowRecord> selectFlowRecordByRecordIdFlowIndexStatusList(Long recordId, Integer flowIndex, List<Integer> statusList);
 }
\ No newline at end of file
diff --git a/src/main/java/com/lz/modules/flow/service/impl/FlowRecordServiceImpl.java b/src/main/java/com/lz/modules/flow/service/impl/FlowRecordServiceImpl.java
index 57e7ade1..88f6208f 100644
--- a/src/main/java/com/lz/modules/flow/service/impl/FlowRecordServiceImpl.java
+++ b/src/main/java/com/lz/modules/flow/service/impl/FlowRecordServiceImpl.java
@@ -251,4 +251,14 @@ public class FlowRecordServiceImpl extends ServiceImpl<FlowRecordMapper, FlowRec
 		flowRecordMapper.updateFlowRecordIdById(id,newId);
 	}
 
+	@Override
+	public FlowRecord selectPreFlowRecordByRecordIdMinIdStatusList(Long recordId, Integer flowIndex, List<Integer> statusList) {
+		return flowRecordMapper.selectPreFlowRecordByRecordIdMinIdStatusList(recordId,flowIndex,statusList);
+	}
+
+	@Override
+	public List<FlowRecord> selectFlowRecordByRecordIdFlowIndexStatusList(Long recordId, Integer flowIndex, List<Integer> statusList) {
+		return flowRecordMapper.selectFlowRecordByRecordIdFlowIndexStatusList(recordId,flowIndex,statusList);
+	}
+
 }
diff --git a/src/main/java/com/lz/modules/sys/service/app/ResultRecordService.java b/src/main/java/com/lz/modules/sys/service/app/ResultRecordService.java
index 416f9af8..e0849f19 100644
--- a/src/main/java/com/lz/modules/sys/service/app/ResultRecordService.java
+++ b/src/main/java/com/lz/modules/sys/service/app/ResultRecordService.java
@@ -128,5 +128,5 @@ public interface ResultRecordService extends IService<ResultRecord> {
 
     R getResetData(RecordDetailDto recordDetailDto);
 
-	R resetData(Long recordId);
+	R resetData(Long recordId,int clearFlag);
 }
\ No newline at end of file
diff --git a/src/main/java/com/lz/modules/sys/service/app/impl/ResultRecordServiceImpl.java b/src/main/java/com/lz/modules/sys/service/app/impl/ResultRecordServiceImpl.java
index 9795d7dc..35bf2071 100644
--- a/src/main/java/com/lz/modules/sys/service/app/impl/ResultRecordServiceImpl.java
+++ b/src/main/java/com/lz/modules/sys/service/app/impl/ResultRecordServiceImpl.java
@@ -932,8 +932,8 @@ public class ResultRecordServiceImpl extends ServiceImpl<ResultRecordMapper, Res
     }
 
     private R resetNode(ApprovalDto approvalDto) {
-        FlowRecord resultRecord = flowRecordService.selectFlowRecordById(approvalDto.getFlowRecordId());
-        List<FlowRecord> flowRecords = flowRecordService.selectFlowRecordByRecordIdGeFlowIndex(resultRecord.getRecordId(),resultRecord.getFlowIndex());
+        FlowRecord f = flowRecordService.selectFlowRecordById(approvalDto.getFlowRecordId());
+        List<FlowRecord> flowRecords = flowRecordService.selectFlowRecordByRecordIdGeFlowIndex(f.getRecordId(),f.getFlowIndex());
         for(FlowRecord flowRecord:flowRecords){
             // 如果结果录入己经走了
             if (new Integer(3).equals(flowRecord.getFlowProcess()) && (flowRecord.getStatus() == 1 || flowRecord.getStatus() == 4) ) {
@@ -941,9 +941,19 @@ public class ResultRecordServiceImpl extends ServiceImpl<ResultRecordMapper, Res
             }else{
                 flowRecord.setStatus(0);        //表示流程己经被重置
             }
-
             flowRecordService.updateFlowRecordById(flowRecord);
         }
+        FlowRecord preFlowRecord = flowRecordService.selectPreFlowRecordByRecordIdMinIdStatusList(f.getRecordId(), f.getFlowIndex() - 1, Arrays.asList(1, 2));
+        List<FlowRecord> runing = new ArrayList<>();
+        if (preFlowRecord != null) {
+            runing = flowRecordService.selectFlowRecordByRecordIdFlowIndex(f.getRecordId(), preFlowRecord.getFlowIndex());
+        } else {
+            runing = flowRecordService.selectFlowRecordByRecordIdFlowIndex(f.getRecordId(), 0);
+        }
+        for (FlowRecord r : runing) {
+            r.setStatus(2);
+            flowRecordService.updateFlowRecordById(r);
+        }
         return R.ok();
     }
 
@@ -973,7 +983,7 @@ public class ResultRecordServiceImpl extends ServiceImpl<ResultRecordMapper, Res
                 }
             }
         }
-        resultRecordService.resetData(flowRecord.getRecordId());
+        resultRecordService.resetData(flowRecord.getRecordId(),approvalDto.getClearFlag());
         return R.ok();
     }
 
@@ -1432,7 +1442,7 @@ public class ResultRecordServiceImpl extends ServiceImpl<ResultRecordMapper, Res
     }
 
     @Override
-    public R resetData(Long recordId) {
+    public R resetData(Long recordId,int clearFlag) {
         return null;
     }
 }
diff --git a/src/main/resources/mapper/flow/FlowRecordMapper.xml b/src/main/resources/mapper/flow/FlowRecordMapper.xml
index f2df4e8c..e293b6f6 100644
--- a/src/main/resources/mapper/flow/FlowRecordMapper.xml
+++ b/src/main/resources/mapper/flow/FlowRecordMapper.xml
@@ -330,6 +330,26 @@
         select * from lz_flow_record  where  is_delete = 0 and record_id = #{recordId} and flow_index >= #{flowIndex}
     </select>
 
+    <select id="selectPreFlowRecordByRecordIdMinIdStatusList" resultType="com.lz.modules.flow.entity.FlowRecord">
+        select * from lz_flow_record  where  is_delete = 0 and flow_index <![CDATA[<=]]> #{flowIndex}
+        and record_id = #{recordId}
+        and status in
+        <foreach item="item" collection="statusList"  open="(" separator="," close=")">
+            #{item}
+        </foreach>
+         order by flow_index desc limit 1
+    </select>
+
+
+    <select id="selectFlowRecordByRecordIdFlowIndexStatusList" resultType="com.lz.modules.flow.entity.FlowRecord">
+        select * from lz_flow_record  where  is_delete = 0 and flow_index = #{flowIndex}
+        and record_id = #{recordId}
+        and status in
+        <foreach item="item" collection="statusList"  open="(" separator="," close=")">
+            #{item}
+        </foreach>
+    </select>
+
     <delete id="deleteFlowRecordByRecordId">
         delete from lz_flow_record where record_id = #{recordId}
     </delete>