diff --git a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
index d5a0230..34b5362 100644
--- a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
+++ b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
@@ -18,6 +18,7 @@
 
 import java.io.IOException;
 import java.util.List;
+import java.util.concurrent.ExecutionException;
 
 /**
  * @Description: 业务看板
@@ -35,7 +36,7 @@
 
     @ApiOperation("实时工作统计")
     @GetMapping("/workStatistics")
-    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() {
+    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() throws ExecutionException, InterruptedException {
         return ReturnUtil.success(boardService.workStatistics());
     }
 
@@ -72,7 +73,7 @@
 
     @ApiOperation("实时工作统计导出")
     @GetMapping("/workStatistics/export")
-    public void workStatisticsExport() throws IOException {
+    public void workStatisticsExport() throws IOException, ExecutionException, InterruptedException {
         List<BoardWorkStatisticsResponse> list = boardService.workStatistics();
         super.exportExcel(BoardWorkStatisticsResponse.class, list, ExportEnum.WORK_STATISTICS_EXPORT.getSheetName());
     }

diff --git a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
index d5a0230..34b5362 100644
--- a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
+++ b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
@@ -18,6 +18,7 @@
 
 import java.io.IOException;
 import java.util.List;
+import java.util.concurrent.ExecutionException;
 
 /**
  * @Description: 业务看板
@@ -35,7 +36,7 @@
 
     @ApiOperation("实时工作统计")
     @GetMapping("/workStatistics")
-    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() {
+    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() throws ExecutionException, InterruptedException {
         return ReturnUtil.success(boardService.workStatistics());
     }
 
@@ -72,7 +73,7 @@
 
     @ApiOperation("实时工作统计导出")
     @GetMapping("/workStatistics/export")
-    public void workStatisticsExport() throws IOException {
+    public void workStatisticsExport() throws IOException, ExecutionException, InterruptedException {
         List<BoardWorkStatisticsResponse> list = boardService.workStatistics();
         super.exportExcel(BoardWorkStatisticsResponse.class, list, ExportEnum.WORK_STATISTICS_EXPORT.getSheetName());
     }
diff --git a/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java b/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
index e883a12..321b0f1 100644
--- a/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
+++ b/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
@@ -10,11 +10,13 @@
 import org.springframework.beans.factory.support.BeanDefinitionRegistry;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
+import org.springframework.context.annotation.Bean;
 import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ForkJoinPool;
 import java.util.function.Function;
 
 /**
@@ -96,4 +98,9 @@
         });
     }
 
+    @Bean
+    public ForkJoinPool forkJoinPool() {
+        return new ForkJoinPool(100);
+    }
+
 }

diff --git a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
index d5a0230..34b5362 100644
--- a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
+++ b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
@@ -18,6 +18,7 @@
 
 import java.io.IOException;
 import java.util.List;
+import java.util.concurrent.ExecutionException;
 
 /**
  * @Description: 业务看板
@@ -35,7 +36,7 @@
 
     @ApiOperation("实时工作统计")
     @GetMapping("/workStatistics")
-    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() {
+    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() throws ExecutionException, InterruptedException {
         return ReturnUtil.success(boardService.workStatistics());
     }
 
@@ -72,7 +73,7 @@
 
     @ApiOperation("实时工作统计导出")
     @GetMapping("/workStatistics/export")
-    public void workStatisticsExport() throws IOException {
+    public void workStatisticsExport() throws IOException, ExecutionException, InterruptedException {
         List<BoardWorkStatisticsResponse> list = boardService.workStatistics();
         super.exportExcel(BoardWorkStatisticsResponse.class, list, ExportEnum.WORK_STATISTICS_EXPORT.getSheetName());
     }
diff --git a/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java b/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
index e883a12..321b0f1 100644
--- a/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
+++ b/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
@@ -10,11 +10,13 @@
 import org.springframework.beans.factory.support.BeanDefinitionRegistry;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
+import org.springframework.context.annotation.Bean;
 import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ForkJoinPool;
 import java.util.function.Function;
 
 /**
@@ -96,4 +98,9 @@
         });
     }
 
+    @Bean
+    public ForkJoinPool forkJoinPool() {
+        return new ForkJoinPool(100);
+    }
+
 }
diff --git a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
index 1670281..f601d91 100644
--- a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
+++ b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
@@ -210,7 +210,7 @@
     </select>
 
     <select id="selectRemindQuantity" resultType="java.lang.Integer">
-        SELECT COUNT(mfa.id)
+        SELECT IFNULL(COUNT(mfa.id),0)
         FROM equipment_fixed_assets mfa
         LEFT JOIN sys_user su ON su.id = mfa.use_person
         LEFT JOIN sys_dept sd ON sd.id = mfa.use_dept

diff --git a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
index d5a0230..34b5362 100644
--- a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
+++ b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
@@ -18,6 +18,7 @@
 
 import java.io.IOException;
 import java.util.List;
+import java.util.concurrent.ExecutionException;
 
 /**
  * @Description: 业务看板
@@ -35,7 +36,7 @@
 
     @ApiOperation("实时工作统计")
     @GetMapping("/workStatistics")
-    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() {
+    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() throws ExecutionException, InterruptedException {
         return ReturnUtil.success(boardService.workStatistics());
     }
 
@@ -72,7 +73,7 @@
 
     @ApiOperation("实时工作统计导出")
     @GetMapping("/workStatistics/export")
-    public void workStatisticsExport() throws IOException {
+    public void workStatisticsExport() throws IOException, ExecutionException, InterruptedException {
         List<BoardWorkStatisticsResponse> list = boardService.workStatistics();
         super.exportExcel(BoardWorkStatisticsResponse.class, list, ExportEnum.WORK_STATISTICS_EXPORT.getSheetName());
     }
diff --git a/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java b/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
index e883a12..321b0f1 100644
--- a/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
+++ b/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
@@ -10,11 +10,13 @@
 import org.springframework.beans.factory.support.BeanDefinitionRegistry;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
+import org.springframework.context.annotation.Bean;
 import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ForkJoinPool;
 import java.util.function.Function;
 
 /**
@@ -96,4 +98,9 @@
         });
     }
 
+    @Bean
+    public ForkJoinPool forkJoinPool() {
+        return new ForkJoinPool(100);
+    }
+
 }
diff --git a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
index 1670281..f601d91 100644
--- a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
+++ b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
@@ -210,7 +210,7 @@
     </select>
 
     <select id="selectRemindQuantity" resultType="java.lang.Integer">
-        SELECT COUNT(mfa.id)
+        SELECT IFNULL(COUNT(mfa.id),0)
         FROM equipment_fixed_assets mfa
         LEFT JOIN sys_user su ON su.id = mfa.use_person
         LEFT JOIN sys_dept sd ON sd.id = mfa.use_dept
diff --git a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml
index a52bcf9..b6cabee 100644
--- a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml
+++ b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml
@@ -79,7 +79,7 @@
     </select>
 
     <select id="selectRemindQuantity" resultType="java.lang.Integer">
-        SELECT COUNT(mse.id)
+        SELECT IFNULL(COUNT(mse.id),0)
         FROM equipment_standard_equipment mse
         LEFT JOIN sys_user su ON su.id = mse.standard_owner
         LEFT JOIN meter_organize mo on mo.dept_id = mse.standard_laboratory

diff --git a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
index d5a0230..34b5362 100644
--- a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
+++ b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
@@ -18,6 +18,7 @@
 
 import java.io.IOException;
 import java.util.List;
+import java.util.concurrent.ExecutionException;
 
 /**
  * @Description: 业务看板
@@ -35,7 +36,7 @@
 
     @ApiOperation("实时工作统计")
     @GetMapping("/workStatistics")
-    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() {
+    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() throws ExecutionException, InterruptedException {
         return ReturnUtil.success(boardService.workStatistics());
     }
 
@@ -72,7 +73,7 @@
 
     @ApiOperation("实时工作统计导出")
     @GetMapping("/workStatistics/export")
-    public void workStatisticsExport() throws IOException {
+    public void workStatisticsExport() throws IOException, ExecutionException, InterruptedException {
         List<BoardWorkStatisticsResponse> list = boardService.workStatistics();
         super.exportExcel(BoardWorkStatisticsResponse.class, list, ExportEnum.WORK_STATISTICS_EXPORT.getSheetName());
     }
diff --git a/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java b/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
index e883a12..321b0f1 100644
--- a/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
+++ b/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
@@ -10,11 +10,13 @@
 import org.springframework.beans.factory.support.BeanDefinitionRegistry;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
+import org.springframework.context.annotation.Bean;
 import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ForkJoinPool;
 import java.util.function.Function;
 
 /**
@@ -96,4 +98,9 @@
         });
     }
 
+    @Bean
+    public ForkJoinPool forkJoinPool() {
+        return new ForkJoinPool(100);
+    }
+
 }
diff --git a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
index 1670281..f601d91 100644
--- a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
+++ b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
@@ -210,7 +210,7 @@
     </select>
 
     <select id="selectRemindQuantity" resultType="java.lang.Integer">
-        SELECT COUNT(mfa.id)
+        SELECT IFNULL(COUNT(mfa.id),0)
         FROM equipment_fixed_assets mfa
         LEFT JOIN sys_user su ON su.id = mfa.use_person
         LEFT JOIN sys_dept sd ON sd.id = mfa.use_dept
diff --git a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml
index a52bcf9..b6cabee 100644
--- a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml
+++ b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml
@@ -79,7 +79,7 @@
     </select>
 
     <select id="selectRemindQuantity" resultType="java.lang.Integer">
-        SELECT COUNT(mse.id)
+        SELECT IFNULL(COUNT(mse.id),0)
         FROM equipment_standard_equipment mse
         LEFT JOIN sys_user su ON su.id = mse.standard_owner
         LEFT JOIN meter_organize mo on mo.dept_id = mse.standard_laboratory
diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BoardRecursiveTask.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BoardRecursiveTask.java
new file mode 100644
index 0000000..30b2a7e
--- /dev/null
+++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BoardRecursiveTask.java
@@ -0,0 +1,40 @@
+package com.casic.missiles.service.Impl.business;
+
+import com.casic.missiles.mapper.business.BusinessBoardMapper;
+import lombok.Data;
+import lombok.SneakyThrows;
+
+import java.lang.reflect.Method;
+import java.util.Objects;
+import java.util.concurrent.RecursiveTask;
+
+/**
+ * @Description:
+ * @Author: wangpeng
+ * @Date: 2023/4/15 12:19
+ */
+@Data
+public class BoardRecursiveTask extends RecursiveTask<Object> {
+    private BusinessBoardMapper boardMapper;
+    //执行的方法
+    private String methodName;
+    //方法的参数
+    private Object param;
+
+    public BoardRecursiveTask(BusinessBoardMapper boardMapper, String methodName, Object param) {
+        this.boardMapper = boardMapper;
+        this.methodName = methodName;
+        this.param = param;
+    }
+
+    @SneakyThrows
+    @Override
+    protected Object compute() {
+        Class c = BusinessBoardMapper.class;
+        Method declaredMethod = c.getDeclaredMethod(methodName);
+        if (Objects.nonNull(param)) {
+            return declaredMethod.invoke(boardMapper, param);
+        }
+        return declaredMethod.invoke(boardMapper);
+    }
+}

diff --git a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
index d5a0230..34b5362 100644
--- a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
+++ b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
@@ -18,6 +18,7 @@
 
 import java.io.IOException;
 import java.util.List;
+import java.util.concurrent.ExecutionException;
 
 /**
  * @Description: 业务看板
@@ -35,7 +36,7 @@
 
     @ApiOperation("实时工作统计")
     @GetMapping("/workStatistics")
-    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() {
+    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() throws ExecutionException, InterruptedException {
         return ReturnUtil.success(boardService.workStatistics());
     }
 
@@ -72,7 +73,7 @@
 
     @ApiOperation("实时工作统计导出")
     @GetMapping("/workStatistics/export")
-    public void workStatisticsExport() throws IOException {
+    public void workStatisticsExport() throws IOException, ExecutionException, InterruptedException {
         List<BoardWorkStatisticsResponse> list = boardService.workStatistics();
         super.exportExcel(BoardWorkStatisticsResponse.class, list, ExportEnum.WORK_STATISTICS_EXPORT.getSheetName());
     }
diff --git a/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java b/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
index e883a12..321b0f1 100644
--- a/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
+++ b/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
@@ -10,11 +10,13 @@
 import org.springframework.beans.factory.support.BeanDefinitionRegistry;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
+import org.springframework.context.annotation.Bean;
 import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ForkJoinPool;
 import java.util.function.Function;
 
 /**
@@ -96,4 +98,9 @@
         });
     }
 
+    @Bean
+    public ForkJoinPool forkJoinPool() {
+        return new ForkJoinPool(100);
+    }
+
 }
diff --git a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
index 1670281..f601d91 100644
--- a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
+++ b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
@@ -210,7 +210,7 @@
     </select>
 
     <select id="selectRemindQuantity" resultType="java.lang.Integer">
-        SELECT COUNT(mfa.id)
+        SELECT IFNULL(COUNT(mfa.id),0)
         FROM equipment_fixed_assets mfa
         LEFT JOIN sys_user su ON su.id = mfa.use_person
         LEFT JOIN sys_dept sd ON sd.id = mfa.use_dept
diff --git a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml
index a52bcf9..b6cabee 100644
--- a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml
+++ b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml
@@ -79,7 +79,7 @@
     </select>
 
     <select id="selectRemindQuantity" resultType="java.lang.Integer">
-        SELECT COUNT(mse.id)
+        SELECT IFNULL(COUNT(mse.id),0)
         FROM equipment_standard_equipment mse
         LEFT JOIN sys_user su ON su.id = mse.standard_owner
         LEFT JOIN meter_organize mo on mo.dept_id = mse.standard_laboratory
diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BoardRecursiveTask.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BoardRecursiveTask.java
new file mode 100644
index 0000000..30b2a7e
--- /dev/null
+++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BoardRecursiveTask.java
@@ -0,0 +1,40 @@
+package com.casic.missiles.service.Impl.business;
+
+import com.casic.missiles.mapper.business.BusinessBoardMapper;
+import lombok.Data;
+import lombok.SneakyThrows;
+
+import java.lang.reflect.Method;
+import java.util.Objects;
+import java.util.concurrent.RecursiveTask;
+
+/**
+ * @Description:
+ * @Author: wangpeng
+ * @Date: 2023/4/15 12:19
+ */
+@Data
+public class BoardRecursiveTask extends RecursiveTask<Object> {
+    private BusinessBoardMapper boardMapper;
+    //执行的方法
+    private String methodName;
+    //方法的参数
+    private Object param;
+
+    public BoardRecursiveTask(BusinessBoardMapper boardMapper, String methodName, Object param) {
+        this.boardMapper = boardMapper;
+        this.methodName = methodName;
+        this.param = param;
+    }
+
+    @SneakyThrows
+    @Override
+    protected Object compute() {
+        Class c = BusinessBoardMapper.class;
+        Method declaredMethod = c.getDeclaredMethod(methodName);
+        if (Objects.nonNull(param)) {
+            return declaredMethod.invoke(boardMapper, param);
+        }
+        return declaredMethod.invoke(boardMapper);
+    }
+}
diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BusinessLabExecutiveInfoServiceImpl.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BusinessLabExecutiveInfoServiceImpl.java
index 349f876..4d38f29 100644
--- a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BusinessLabExecutiveInfoServiceImpl.java
+++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BusinessLabExecutiveInfoServiceImpl.java
@@ -556,8 +556,8 @@
             Long id = labExecutiveInfoMapper.selectMinSeq(request.getOrderId(), request.getSampleId());
             //仅分发了一个实验室检测或无实验室可分配的情况
             if(seqUpdateFlag <= 0 && Objects.isNull(id)){
-                // TODO: 2023/3/14 分发列表仅一个实验室情况：将样品状态置为待分发或让分发员在分发的检测中进行编辑
-                // TODO: 2023/3/14 无实验室可分配的情况：是否要将样品状态置为检测完成或让分发员在分发的检测中进行编辑
+                //将样品状态变为待分发
+                orderSampleRelationMapper.updateByOrderIdAndSampleId(request.getOrderId(), request.getSampleId(), SampleStatusEnum.TO_HANDOUT);
                 return ReturnUtil.success();
             }
             BusinessLabExecutiveInfo info = new BusinessLabExecutiveInfo();

diff --git a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
index d5a0230..34b5362 100644
--- a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
+++ b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
@@ -18,6 +18,7 @@
 
 import java.io.IOException;
 import java.util.List;
+import java.util.concurrent.ExecutionException;
 
 /**
  * @Description: 业务看板
@@ -35,7 +36,7 @@
 
     @ApiOperation("实时工作统计")
     @GetMapping("/workStatistics")
-    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() {
+    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() throws ExecutionException, InterruptedException {
         return ReturnUtil.success(boardService.workStatistics());
     }
 
@@ -72,7 +73,7 @@
 
     @ApiOperation("实时工作统计导出")
     @GetMapping("/workStatistics/export")
-    public void workStatisticsExport() throws IOException {
+    public void workStatisticsExport() throws IOException, ExecutionException, InterruptedException {
         List<BoardWorkStatisticsResponse> list = boardService.workStatistics();
         super.exportExcel(BoardWorkStatisticsResponse.class, list, ExportEnum.WORK_STATISTICS_EXPORT.getSheetName());
     }
diff --git a/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java b/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
index e883a12..321b0f1 100644
--- a/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
+++ b/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
@@ -10,11 +10,13 @@
 import org.springframework.beans.factory.support.BeanDefinitionRegistry;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
+import org.springframework.context.annotation.Bean;
 import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ForkJoinPool;
 import java.util.function.Function;
 
 /**
@@ -96,4 +98,9 @@
         });
     }
 
+    @Bean
+    public ForkJoinPool forkJoinPool() {
+        return new ForkJoinPool(100);
+    }
+
 }
diff --git a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
index 1670281..f601d91 100644
--- a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
+++ b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
@@ -210,7 +210,7 @@
     </select>
 
     <select id="selectRemindQuantity" resultType="java.lang.Integer">
-        SELECT COUNT(mfa.id)
+        SELECT IFNULL(COUNT(mfa.id),0)
         FROM equipment_fixed_assets mfa
         LEFT JOIN sys_user su ON su.id = mfa.use_person
         LEFT JOIN sys_dept sd ON sd.id = mfa.use_dept
diff --git a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml
index a52bcf9..b6cabee 100644
--- a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml
+++ b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml
@@ -79,7 +79,7 @@
     </select>
 
     <select id="selectRemindQuantity" resultType="java.lang.Integer">
-        SELECT COUNT(mse.id)
+        SELECT IFNULL(COUNT(mse.id),0)
         FROM equipment_standard_equipment mse
         LEFT JOIN sys_user su ON su.id = mse.standard_owner
         LEFT JOIN meter_organize mo on mo.dept_id = mse.standard_laboratory
diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BoardRecursiveTask.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BoardRecursiveTask.java
new file mode 100644
index 0000000..30b2a7e
--- /dev/null
+++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BoardRecursiveTask.java
@@ -0,0 +1,40 @@
+package com.casic.missiles.service.Impl.business;
+
+import com.casic.missiles.mapper.business.BusinessBoardMapper;
+import lombok.Data;
+import lombok.SneakyThrows;
+
+import java.lang.reflect.Method;
+import java.util.Objects;
+import java.util.concurrent.RecursiveTask;
+
+/**
+ * @Description:
+ * @Author: wangpeng
+ * @Date: 2023/4/15 12:19
+ */
+@Data
+public class BoardRecursiveTask extends RecursiveTask<Object> {
+    private BusinessBoardMapper boardMapper;
+    //执行的方法
+    private String methodName;
+    //方法的参数
+    private Object param;
+
+    public BoardRecursiveTask(BusinessBoardMapper boardMapper, String methodName, Object param) {
+        this.boardMapper = boardMapper;
+        this.methodName = methodName;
+        this.param = param;
+    }
+
+    @SneakyThrows
+    @Override
+    protected Object compute() {
+        Class c = BusinessBoardMapper.class;
+        Method declaredMethod = c.getDeclaredMethod(methodName);
+        if (Objects.nonNull(param)) {
+            return declaredMethod.invoke(boardMapper, param);
+        }
+        return declaredMethod.invoke(boardMapper);
+    }
+}
diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BusinessLabExecutiveInfoServiceImpl.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BusinessLabExecutiveInfoServiceImpl.java
index 349f876..4d38f29 100644
--- a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BusinessLabExecutiveInfoServiceImpl.java
+++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BusinessLabExecutiveInfoServiceImpl.java
@@ -556,8 +556,8 @@
             Long id = labExecutiveInfoMapper.selectMinSeq(request.getOrderId(), request.getSampleId());
             //仅分发了一个实验室检测或无实验室可分配的情况
             if(seqUpdateFlag <= 0 && Objects.isNull(id)){
-                // TODO: 2023/3/14 分发列表仅一个实验室情况：将样品状态置为待分发或让分发员在分发的检测中进行编辑
-                // TODO: 2023/3/14 无实验室可分配的情况：是否要将样品状态置为检测完成或让分发员在分发的检测中进行编辑
+                //将样品状态变为待分发
+                orderSampleRelationMapper.updateByOrderIdAndSampleId(request.getOrderId(), request.getSampleId(), SampleStatusEnum.TO_HANDOUT);
                 return ReturnUtil.success();
             }
             BusinessLabExecutiveInfo info = new BusinessLabExecutiveInfo();
diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/IBusinessBoardServiceImpl.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/IBusinessBoardServiceImpl.java
index 12bd686..5577e2a 100644
--- a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/IBusinessBoardServiceImpl.java
+++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/IBusinessBoardServiceImpl.java
@@ -6,14 +6,18 @@
 import com.casic.missiles.service.IBaseApprovalService;
 import com.casic.missiles.service.business.IBusinessBoardService;
 import com.casic.missiles.utils.ConvertUtils;
+import lombok.SneakyThrows;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.util.StopWatch;
 
 import javax.annotation.Resource;
 import java.math.BigDecimal;
-import java.util.List;
-import java.util.Objects;
-import java.util.Optional;
+import java.util.*;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ForkJoinPool;
+import java.util.concurrent.ForkJoinTask;
+import java.util.concurrent.RecursiveTask;
 
 /**
  * @Description:
@@ -24,45 +28,81 @@
 public class IBusinessBoardServiceImpl implements IBusinessBoardService {
     @Autowired
     private BusinessBoardMapper boardMapper;
-
     @Resource
     private IBaseApprovalService baseApprovalService;
+    @Autowired
+    private ForkJoinPool forkJoinPool;
+
+    private static List<String> workStatisticsMethodList =
+            Arrays.asList("selectSamplesCompletedToday", "selectCertificatesToday",
+                    "selectExpireSamplesToday", "selectSamplesThisYear",
+                    "selectExpireSamplesThisYear", "selectInMeasureExpireSamplesThisYear");
 
     @Override
-    public List<BoardWorkStatisticsResponse> workStatistics() {
+    public List<BoardWorkStatisticsResponse> workStatistics() throws ExecutionException, InterruptedException {
         //多业务表关联查询无法实现统一查询结果（不同维度），拆分查询，松耦合，方便多处组合调用
-        //1、当日检测完样品
+        //1、selectSamplesCompletedToday:当日检测完样品
         //计量组织表&实验室检测记录表
-        List<BoardWorkStatisticsResponse> completedTodayList = boardMapper.selectSamplesCompletedToday();
-        //2、当日检定员出具证书数，证书表（出具日期）
+        //2、selectCertificatesToday:当日检定员出具证书数，证书表（出具日期）
         //计量组织表&证书报告表
-        List<BoardWorkStatisticsResponse> certificatesTodayList = boardMapper.selectCertificatesToday();
-        //3、当日到期样品数，实验室检测记录表关联委托书表（实验室检测记录中的委托书id个数等价于样品id个数）
+        //3、selectExpireSamplesToday:当日到期样品数，实验室检测记录表关联委托书表（实验室检测记录中的委托书id个数等价于样品id个数）
         //计量组织表&实验室检测记录表&委托书表
-        List<BoardWorkStatisticsResponse> expireSamplesTodayList = boardMapper.selectExpireSamplesToday();
-        //4、今年样品数（所有的）
+        //4、selectSamplesThisYear:今年样品数（所有的）
         //计量组织表&实验室检测记录表&委托书样品关联表
-        //协助排查注释：一个实验室存在对应一个委托书的多个样品检测
-        //      无需添加内检查询条件，在实验室检测记录中的一定是内检
-        List<BoardWorkStatisticsResponse> samplesThisYearList = boardMapper.selectSamplesThisYear();
-        //5、今年超期样品总数（今年超过期的，无论现在状态如何（无需检测只发生在收发阶段也不用考虑））
+        //协助排查注释：一个实验室存在对应一个委托书的多个样品检测；无需添加内检查询条件，在实验室检测记录中的一定是内检
+        //5、selectExpireSamplesThisYear:今年超期样品总数（今年超过期的，无论现在状态如何（无需检测只发生在收发阶段也不用考虑））
         //计量组织表&实验室检测记录表&委托书表&委托书样品关联表
-        List<BoardWorkStatisticsResponse> expireSamplesThisYearList = boardMapper.selectExpireSamplesThisYear();
-        //6、今年超期样品总数-检测中
+        //6、selectInMeasureExpireSamplesThisYear:今年超期样品总数-检测中
         //计量组织表&实验室检测记录表&委托书表&委托书样品关联表
-        List<BoardWorkStatisticsResponse> inMeasureExpireSamplesThisYearList = boardMapper.selectInMeasureExpireSamplesThisYear();
-        //结果组装
-        completedTodayList.forEach(dto -> {
-            dto.setCertificatesToday(certificatesTodayList.stream().filter(
-                    c -> c.getId().equals(dto.getId())).findAny().get().getCertificatesToday());
-            dto.setExpireSamplesToday(expireSamplesTodayList.stream().filter(
-                    e -> e.getId().equals(dto.getId())).findAny().get().getExpireSamplesToday());
-            dto.setSamplesYear(samplesThisYearList.stream().filter(
-                    s -> s.getId().equals(dto.getId())).findAny().get().getSamplesYear());
-            dto.setExpireSamplesYear(expireSamplesThisYearList.stream().filter(
-                    e -> e.getId().equals(dto.getId())).findAny().get().getExpireSamplesYear());
-            dto.setInMeasureExpireSamplesYear(inMeasureExpireSamplesThisYearList.stream().filter(
-                    i -> i.getId().equals(dto.getId())).findAny().get().getInMeasureExpireSamplesYear());
+        StopWatch stopWatch = new StopWatch();
+        stopWatch.start("workStatistics");
+        List<List<BoardWorkStatisticsResponse>> transferList = new ArrayList<>();
+        ForkJoinTask<List<List<BoardWorkStatisticsResponse>>> taskResponse = forkJoinPool.submit(new RecursiveTask<List<List<BoardWorkStatisticsResponse>>>() {
+            @SneakyThrows
+            @Override
+            protected List<List<BoardWorkStatisticsResponse>> compute() {
+                List<BoardRecursiveTask> taskList = new ArrayList<>();
+                for (String methodName : workStatisticsMethodList) {
+                    BoardRecursiveTask boardRecursiveTask = new BoardRecursiveTask(boardMapper, methodName, null);
+                    taskList.add(boardRecursiveTask);
+                    boardRecursiveTask.fork();
+                }
+                for (BoardRecursiveTask boardRecursiveTask : taskList) {
+                    List<BoardWorkStatisticsResponse> list = (List<BoardWorkStatisticsResponse>) boardRecursiveTask.get();
+                    transferList.add(list);
+                }
+                return transferList;
+            }
+        });
+        List<BoardWorkStatisticsResponse> resultList;
+        List<List<BoardWorkStatisticsResponse>> lists = taskResponse.get();
+        resultList = lists.get(0);
+        lists.remove(0);
+        lists.forEach(list -> {
+            BoardWorkStatisticsResponse boardWorkStatisticsResponse = list.get(0);
+            if (Objects.nonNull(boardWorkStatisticsResponse.getCertificatesToday())) {
+                resultList.forEach(dto -> {
+                    dto.setCertificatesToday(list.stream().filter(c -> c.getId().equals(dto.getId())).findAny().get().getCertificatesToday());
+                });
+            } else if (Objects.nonNull(boardWorkStatisticsResponse.getExpireSamplesToday())) {
+                resultList.forEach(dto -> {
+                    dto.setExpireSamplesToday(list.stream().filter(c -> c.getId().equals(dto.getId())).findAny().get().getExpireSamplesToday());
+                });
+            } else if (Objects.nonNull(boardWorkStatisticsResponse.getSamplesYear())) {
+                resultList.forEach(dto -> {
+                    dto.setSamplesYear(list.stream().filter(c -> c.getId().equals(dto.getId())).findAny().get().getSamplesYear());
+                });
+            } else if (Objects.nonNull(boardWorkStatisticsResponse.getExpireSamplesYear())) {
+                resultList.forEach(dto -> {
+                    dto.setExpireSamplesYear(list.stream().filter(c -> c.getId().equals(dto.getId())).findAny().get().getExpireSamplesYear());
+                });
+            } else if (Objects.nonNull(boardWorkStatisticsResponse.getInMeasureExpireSamplesYear())) {
+                resultList.forEach(dto -> {
+                    dto.setInMeasureExpireSamplesYear(list.stream().filter(c -> c.getId().equals(dto.getId())).findAny().get().getInMeasureExpireSamplesYear());
+                });
+            }
+        });
+        resultList.forEach(dto -> {
             BigDecimal expire = BigDecimal.valueOf(dto.getExpireSamplesYear());
             BigDecimal total = BigDecimal.valueOf(dto.getSamplesYear());
             if (0 == (BigDecimal.ZERO).compareTo(total)) {
@@ -71,7 +111,10 @@
                 dto.setExpireRate(expire.multiply(BigDecimal.valueOf(100)).divide(total, 2, BigDecimal.ROUND_HALF_UP).toPlainString() + "%");
             }
         });
-        return completedTodayList;
+        stopWatch.stop();
+        System.out.println(stopWatch.prettyPrint());
+
+        return resultList;
     }
 
     @Override
@@ -110,9 +153,9 @@
                             if (0 == (BigDecimal.ZERO).compareTo(samplesTotal) || 0 == (BigDecimal.ZERO).compareTo(certificatesTotal)) {
                                 dto.setOutPut("0");
                             } else {
-                                dto.setOutPut(actualAmount.divide(samplesTotal,2, BigDecimal.ROUND_HALF_UP)
+                                dto.setOutPut(actualAmount.divide(samplesTotal, 2, BigDecimal.ROUND_HALF_UP)
                                         .multiply(personalCertificatesTotal)
-                                        .divide(certificatesTotal,0, BigDecimal.ROUND_HALF_UP)
+                                        .divide(certificatesTotal, 0, BigDecimal.ROUND_HALF_UP)
                                         .toPlainString());
                             }
                         }

diff --git a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
index d5a0230..34b5362 100644
--- a/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
+++ b/casic-metering-api/src/main/java/com/casic/missiles/controller/business/BusinessBoardController.java
@@ -18,6 +18,7 @@
 
 import java.io.IOException;
 import java.util.List;
+import java.util.concurrent.ExecutionException;
 
 /**
  * @Description: 业务看板
@@ -35,7 +36,7 @@
 
     @ApiOperation("实时工作统计")
     @GetMapping("/workStatistics")
-    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() {
+    public ReturnDTO<List<BoardWorkStatisticsResponse>> workStatistics() throws ExecutionException, InterruptedException {
         return ReturnUtil.success(boardService.workStatistics());
     }
 
@@ -72,7 +73,7 @@
 
     @ApiOperation("实时工作统计导出")
     @GetMapping("/workStatistics/export")
-    public void workStatisticsExport() throws IOException {
+    public void workStatisticsExport() throws IOException, ExecutionException, InterruptedException {
         List<BoardWorkStatisticsResponse> list = boardService.workStatistics();
         super.exportExcel(BoardWorkStatisticsResponse.class, list, ExportEnum.WORK_STATISTICS_EXPORT.getSheetName());
     }
diff --git a/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java b/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
index e883a12..321b0f1 100644
--- a/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
+++ b/casic-metering-common/src/main/java/com/casic/missiles/utils/SpringContextUtil.java
@@ -10,11 +10,13 @@
 import org.springframework.beans.factory.support.BeanDefinitionRegistry;
 import org.springframework.context.ApplicationContext;
 import org.springframework.context.ApplicationContextAware;
+import org.springframework.context.annotation.Bean;
 import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
 
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.ForkJoinPool;
 import java.util.function.Function;
 
 /**
@@ -96,4 +98,9 @@
         });
     }
 
+    @Bean
+    public ForkJoinPool forkJoinPool() {
+        return new ForkJoinPool(100);
+    }
+
 }
diff --git a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
index 1670281..f601d91 100644
--- a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
+++ b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentFixedAssetsMapper.xml
@@ -210,7 +210,7 @@
     </select>
 
     <select id="selectRemindQuantity" resultType="java.lang.Integer">
-        SELECT COUNT(mfa.id)
+        SELECT IFNULL(COUNT(mfa.id),0)
         FROM equipment_fixed_assets mfa
         LEFT JOIN sys_user su ON su.id = mfa.use_person
         LEFT JOIN sys_dept sd ON sd.id = mfa.use_dept
diff --git a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml
index a52bcf9..b6cabee 100644
--- a/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml
+++ b/casic-metering-dao/src/main/resources/mapper/equipment/EquipmentStandardEquipmentMapper.xml
@@ -79,7 +79,7 @@
     </select>
 
     <select id="selectRemindQuantity" resultType="java.lang.Integer">
-        SELECT COUNT(mse.id)
+        SELECT IFNULL(COUNT(mse.id),0)
         FROM equipment_standard_equipment mse
         LEFT JOIN sys_user su ON su.id = mse.standard_owner
         LEFT JOIN meter_organize mo on mo.dept_id = mse.standard_laboratory
diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BoardRecursiveTask.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BoardRecursiveTask.java
new file mode 100644
index 0000000..30b2a7e
--- /dev/null
+++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BoardRecursiveTask.java
@@ -0,0 +1,40 @@
+package com.casic.missiles.service.Impl.business;
+
+import com.casic.missiles.mapper.business.BusinessBoardMapper;
+import lombok.Data;
+import lombok.SneakyThrows;
+
+import java.lang.reflect.Method;
+import java.util.Objects;
+import java.util.concurrent.RecursiveTask;
+
+/**
+ * @Description:
+ * @Author: wangpeng
+ * @Date: 2023/4/15 12:19
+ */
+@Data
+public class BoardRecursiveTask extends RecursiveTask<Object> {
+    private BusinessBoardMapper boardMapper;
+    //执行的方法
+    private String methodName;
+    //方法的参数
+    private Object param;
+
+    public BoardRecursiveTask(BusinessBoardMapper boardMapper, String methodName, Object param) {
+        this.boardMapper = boardMapper;
+        this.methodName = methodName;
+        this.param = param;
+    }
+
+    @SneakyThrows
+    @Override
+    protected Object compute() {
+        Class c = BusinessBoardMapper.class;
+        Method declaredMethod = c.getDeclaredMethod(methodName);
+        if (Objects.nonNull(param)) {
+            return declaredMethod.invoke(boardMapper, param);
+        }
+        return declaredMethod.invoke(boardMapper);
+    }
+}
diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BusinessLabExecutiveInfoServiceImpl.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BusinessLabExecutiveInfoServiceImpl.java
index 349f876..4d38f29 100644
--- a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BusinessLabExecutiveInfoServiceImpl.java
+++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/BusinessLabExecutiveInfoServiceImpl.java
@@ -556,8 +556,8 @@
             Long id = labExecutiveInfoMapper.selectMinSeq(request.getOrderId(), request.getSampleId());
             //仅分发了一个实验室检测或无实验室可分配的情况
             if(seqUpdateFlag <= 0 && Objects.isNull(id)){
-                // TODO: 2023/3/14 分发列表仅一个实验室情况：将样品状态置为待分发或让分发员在分发的检测中进行编辑
-                // TODO: 2023/3/14 无实验室可分配的情况：是否要将样品状态置为检测完成或让分发员在分发的检测中进行编辑
+                //将样品状态变为待分发
+                orderSampleRelationMapper.updateByOrderIdAndSampleId(request.getOrderId(), request.getSampleId(), SampleStatusEnum.TO_HANDOUT);
                 return ReturnUtil.success();
             }
             BusinessLabExecutiveInfo info = new BusinessLabExecutiveInfo();
diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/IBusinessBoardServiceImpl.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/IBusinessBoardServiceImpl.java
index 12bd686..5577e2a 100644
--- a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/IBusinessBoardServiceImpl.java
+++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/business/IBusinessBoardServiceImpl.java
@@ -6,14 +6,18 @@
 import com.casic.missiles.service.IBaseApprovalService;
 import com.casic.missiles.service.business.IBusinessBoardService;
 import com.casic.missiles.utils.ConvertUtils;
+import lombok.SneakyThrows;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.util.StopWatch;
 
 import javax.annotation.Resource;
 import java.math.BigDecimal;
-import java.util.List;
-import java.util.Objects;
-import java.util.Optional;
+import java.util.*;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ForkJoinPool;
+import java.util.concurrent.ForkJoinTask;
+import java.util.concurrent.RecursiveTask;
 
 /**
  * @Description:
@@ -24,45 +28,81 @@
 public class IBusinessBoardServiceImpl implements IBusinessBoardService {
     @Autowired
     private BusinessBoardMapper boardMapper;
-
     @Resource
     private IBaseApprovalService baseApprovalService;
+    @Autowired
+    private ForkJoinPool forkJoinPool;
+
+    private static List<String> workStatisticsMethodList =
+            Arrays.asList("selectSamplesCompletedToday", "selectCertificatesToday",
+                    "selectExpireSamplesToday", "selectSamplesThisYear",
+                    "selectExpireSamplesThisYear", "selectInMeasureExpireSamplesThisYear");
 
     @Override
-    public List<BoardWorkStatisticsResponse> workStatistics() {
+    public List<BoardWorkStatisticsResponse> workStatistics() throws ExecutionException, InterruptedException {
         //多业务表关联查询无法实现统一查询结果（不同维度），拆分查询，松耦合，方便多处组合调用
-        //1、当日检测完样品
+        //1、selectSamplesCompletedToday:当日检测完样品
         //计量组织表&实验室检测记录表
-        List<BoardWorkStatisticsResponse> completedTodayList = boardMapper.selectSamplesCompletedToday();
-        //2、当日检定员出具证书数，证书表（出具日期）
+        //2、selectCertificatesToday:当日检定员出具证书数，证书表（出具日期）
         //计量组织表&证书报告表
-        List<BoardWorkStatisticsResponse> certificatesTodayList = boardMapper.selectCertificatesToday();
-        //3、当日到期样品数，实验室检测记录表关联委托书表（实验室检测记录中的委托书id个数等价于样品id个数）
+        //3、selectExpireSamplesToday:当日到期样品数，实验室检测记录表关联委托书表（实验室检测记录中的委托书id个数等价于样品id个数）
         //计量组织表&实验室检测记录表&委托书表
-        List<BoardWorkStatisticsResponse> expireSamplesTodayList = boardMapper.selectExpireSamplesToday();
-        //4、今年样品数（所有的）
+        //4、selectSamplesThisYear:今年样品数（所有的）
         //计量组织表&实验室检测记录表&委托书样品关联表
-        //协助排查注释：一个实验室存在对应一个委托书的多个样品检测
-        //      无需添加内检查询条件，在实验室检测记录中的一定是内检
-        List<BoardWorkStatisticsResponse> samplesThisYearList = boardMapper.selectSamplesThisYear();
-        //5、今年超期样品总数（今年超过期的，无论现在状态如何（无需检测只发生在收发阶段也不用考虑））
+        //协助排查注释：一个实验室存在对应一个委托书的多个样品检测；无需添加内检查询条件，在实验室检测记录中的一定是内检
+        //5、selectExpireSamplesThisYear:今年超期样品总数（今年超过期的，无论现在状态如何（无需检测只发生在收发阶段也不用考虑））
         //计量组织表&实验室检测记录表&委托书表&委托书样品关联表
-        List<BoardWorkStatisticsResponse> expireSamplesThisYearList = boardMapper.selectExpireSamplesThisYear();
-        //6、今年超期样品总数-检测中
+        //6、selectInMeasureExpireSamplesThisYear:今年超期样品总数-检测中
         //计量组织表&实验室检测记录表&委托书表&委托书样品关联表
-        List<BoardWorkStatisticsResponse> inMeasureExpireSamplesThisYearList = boardMapper.selectInMeasureExpireSamplesThisYear();
-        //结果组装
-        completedTodayList.forEach(dto -> {
-            dto.setCertificatesToday(certificatesTodayList.stream().filter(
-                    c -> c.getId().equals(dto.getId())).findAny().get().getCertificatesToday());
-            dto.setExpireSamplesToday(expireSamplesTodayList.stream().filter(
-                    e -> e.getId().equals(dto.getId())).findAny().get().getExpireSamplesToday());
-            dto.setSamplesYear(samplesThisYearList.stream().filter(
-                    s -> s.getId().equals(dto.getId())).findAny().get().getSamplesYear());
-            dto.setExpireSamplesYear(expireSamplesThisYearList.stream().filter(
-                    e -> e.getId().equals(dto.getId())).findAny().get().getExpireSamplesYear());
-            dto.setInMeasureExpireSamplesYear(inMeasureExpireSamplesThisYearList.stream().filter(
-                    i -> i.getId().equals(dto.getId())).findAny().get().getInMeasureExpireSamplesYear());
+        StopWatch stopWatch = new StopWatch();
+        stopWatch.start("workStatistics");
+        List<List<BoardWorkStatisticsResponse>> transferList = new ArrayList<>();
+        ForkJoinTask<List<List<BoardWorkStatisticsResponse>>> taskResponse = forkJoinPool.submit(new RecursiveTask<List<List<BoardWorkStatisticsResponse>>>() {
+            @SneakyThrows
+            @Override
+            protected List<List<BoardWorkStatisticsResponse>> compute() {
+                List<BoardRecursiveTask> taskList = new ArrayList<>();
+                for (String methodName : workStatisticsMethodList) {
+                    BoardRecursiveTask boardRecursiveTask = new BoardRecursiveTask(boardMapper, methodName, null);
+                    taskList.add(boardRecursiveTask);
+                    boardRecursiveTask.fork();
+                }
+                for (BoardRecursiveTask boardRecursiveTask : taskList) {
+                    List<BoardWorkStatisticsResponse> list = (List<BoardWorkStatisticsResponse>) boardRecursiveTask.get();
+                    transferList.add(list);
+                }
+                return transferList;
+            }
+        });
+        List<BoardWorkStatisticsResponse> resultList;
+        List<List<BoardWorkStatisticsResponse>> lists = taskResponse.get();
+        resultList = lists.get(0);
+        lists.remove(0);
+        lists.forEach(list -> {
+            BoardWorkStatisticsResponse boardWorkStatisticsResponse = list.get(0);
+            if (Objects.nonNull(boardWorkStatisticsResponse.getCertificatesToday())) {
+                resultList.forEach(dto -> {
+                    dto.setCertificatesToday(list.stream().filter(c -> c.getId().equals(dto.getId())).findAny().get().getCertificatesToday());
+                });
+            } else if (Objects.nonNull(boardWorkStatisticsResponse.getExpireSamplesToday())) {
+                resultList.forEach(dto -> {
+                    dto.setExpireSamplesToday(list.stream().filter(c -> c.getId().equals(dto.getId())).findAny().get().getExpireSamplesToday());
+                });
+            } else if (Objects.nonNull(boardWorkStatisticsResponse.getSamplesYear())) {
+                resultList.forEach(dto -> {
+                    dto.setSamplesYear(list.stream().filter(c -> c.getId().equals(dto.getId())).findAny().get().getSamplesYear());
+                });
+            } else if (Objects.nonNull(boardWorkStatisticsResponse.getExpireSamplesYear())) {
+                resultList.forEach(dto -> {
+                    dto.setExpireSamplesYear(list.stream().filter(c -> c.getId().equals(dto.getId())).findAny().get().getExpireSamplesYear());
+                });
+            } else if (Objects.nonNull(boardWorkStatisticsResponse.getInMeasureExpireSamplesYear())) {
+                resultList.forEach(dto -> {
+                    dto.setInMeasureExpireSamplesYear(list.stream().filter(c -> c.getId().equals(dto.getId())).findAny().get().getInMeasureExpireSamplesYear());
+                });
+            }
+        });
+        resultList.forEach(dto -> {
             BigDecimal expire = BigDecimal.valueOf(dto.getExpireSamplesYear());
             BigDecimal total = BigDecimal.valueOf(dto.getSamplesYear());
             if (0 == (BigDecimal.ZERO).compareTo(total)) {
@@ -71,7 +111,10 @@
                 dto.setExpireRate(expire.multiply(BigDecimal.valueOf(100)).divide(total, 2, BigDecimal.ROUND_HALF_UP).toPlainString() + "%");
             }
         });
-        return completedTodayList;
+        stopWatch.stop();
+        System.out.println(stopWatch.prettyPrint());
+
+        return resultList;
     }
 
     @Override
@@ -110,9 +153,9 @@
                             if (0 == (BigDecimal.ZERO).compareTo(samplesTotal) || 0 == (BigDecimal.ZERO).compareTo(certificatesTotal)) {
                                 dto.setOutPut("0");
                             } else {
-                                dto.setOutPut(actualAmount.divide(samplesTotal,2, BigDecimal.ROUND_HALF_UP)
+                                dto.setOutPut(actualAmount.divide(samplesTotal, 2, BigDecimal.ROUND_HALF_UP)
                                         .multiply(personalCertificatesTotal)
-                                        .divide(certificatesTotal,0, BigDecimal.ROUND_HALF_UP)
+                                        .divide(certificatesTotal, 0, BigDecimal.ROUND_HALF_UP)
                                         .toPlainString());
                             }
                         }
diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/business/IBusinessBoardService.java b/casic-metering-service/src/main/java/com/casic/missiles/service/business/IBusinessBoardService.java
index 2b76a1e..3d37caa 100644
--- a/casic-metering-service/src/main/java/com/casic/missiles/service/business/IBusinessBoardService.java
+++ b/casic-metering-service/src/main/java/com/casic/missiles/service/business/IBusinessBoardService.java
@@ -3,6 +3,7 @@
 import com.casic.missiles.dto.business.board.*;
 
 import java.util.List;
+import java.util.concurrent.ExecutionException;
 
 /**
  * @Description:
@@ -10,7 +11,7 @@
  * @Date: 2023/4/7 17:35
  */
 public interface IBusinessBoardService {
-    List<BoardWorkStatisticsResponse> workStatistics();
+    List<BoardWorkStatisticsResponse> workStatistics() throws ExecutionException, InterruptedException;
 
     List<BoardDeptOutputResponse> deptOutput(BoardBaseRequest request);