From 8bc8314073b699d06625003068735919d76273a4 Mon Sep 17 00:00:00 2001
From: xuyuncong <3422692813@qq.com>
Date: Thu, 9 Oct 2025 17:01:03 +0800
Subject: [PATCH] =?UTF-8?q?=E5=91=98=E5=B7=A5=E7=BB=9F=E8=AE=A1-=E5=91=98?=
 =?UTF-8?q?=E5=B7=A5=E8=AF=A6=E6=83=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mapper/InspectionWorkNodeMapper.java      |  9 ++++++
 .../service/IInspectionWorkNodeService.java   |  7 ++++
 .../impl/InspectionWorkNodeServiceImpl.java   |  5 +++
 .../service/impl/StatisticsServiceImpl.java   |  4 +++
 .../mapper/InspectionWorkNodeMapper.xml       | 32 +++++++++++++++++++
 5 files changed, 57 insertions(+)

diff --git a/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/mapper/InspectionWorkNodeMapper.java b/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/mapper/InspectionWorkNodeMapper.java
index fa42e004..72a67a03 100644
--- a/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/mapper/InspectionWorkNodeMapper.java
+++ b/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/mapper/InspectionWorkNodeMapper.java
@@ -72,4 +72,13 @@ public interface InspectionWorkNodeMapper extends BaseMapper<InspectionWorkNode>
      * @return: java.util.Map<java.lang.String,java.lang.Object>
      **/
     Map<String, Object> queryStaffInspectionCount(DlInspectionProject dlInspectionProject);
+
+    /**
+     * @description: 获取员工项目统计
+     * @author: 许
+     * @date: 2025/10/9 14:07
+     * @param: [dlInspectionProject]
+     * @return: java.util.Map<java.lang.String,java.lang.Object>
+     **/
+    Map<String, Object> queryOutputMoneyStatistics(DlInspectionProject dlInspectionProject);
 }
diff --git a/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/service/IInspectionWorkNodeService.java b/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/service/IInspectionWorkNodeService.java
index 89b9759a..48ac6654 100644
--- a/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/service/IInspectionWorkNodeService.java
+++ b/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/service/IInspectionWorkNodeService.java
@@ -115,4 +115,11 @@ public interface IInspectionWorkNodeService extends IService<InspectionWorkNode>
      * @return: java.util.Map<java.lang.String,java.lang.Object>
      **/
     Map<String, Object> queryStaffInspectionCount(DlInspectionProject dlInspectionProject);
+
+    /**
+     * @description: 获取员工产值统计信息
+     * @param dlInspectionProject
+     * @return
+     */
+    Map<String, Object> queryOutputMoneyStatistics(DlInspectionProject dlInspectionProject);
 }
diff --git a/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/service/impl/InspectionWorkNodeServiceImpl.java b/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/service/impl/InspectionWorkNodeServiceImpl.java
index fd6eea59..2a507258 100644
--- a/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/service/impl/InspectionWorkNodeServiceImpl.java
+++ b/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/service/impl/InspectionWorkNodeServiceImpl.java
@@ -614,6 +614,11 @@ public class InspectionWorkNodeServiceImpl extends ServiceImpl<InspectionWorkNod
         return baseMapper.queryStaffInspectionCount(dlInspectionProject);
     }
 
+    @Override
+    public Map<String, Object> queryOutputMoneyStatistics(DlInspectionProject dlInspectionProject) {
+        return baseMapper.queryOutputMoneyStatistics(dlInspectionProject);
+    }
+
     /**
      * 判断传入的 InspectionWorkNode 对象是否在集合中有后续项目
      *
diff --git a/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/service/impl/StatisticsServiceImpl.java b/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/service/impl/StatisticsServiceImpl.java
index b022e672..ec5c4041 100644
--- a/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/service/impl/StatisticsServiceImpl.java
+++ b/dl-module-inspection/src/main/java/cn/iocoder/yudao/module/inspection/service/impl/StatisticsServiceImpl.java
@@ -56,6 +56,10 @@ public class StatisticsServiceImpl implements StatisticsService {
         /*获取员工信息*/
         AdminUserRespDTO user = adminUserApi.getUser(dlInspectionProject.getUserId());
         result.put("staffInfo", user);
+
+        /*产值相关统计*/
+        Map<String, Object> outputMoneyStatistics = inspectionWorkNodeService.queryOutputMoneyStatistics(dlInspectionProject);
+        result.put("outputMoneyStatistics", outputMoneyStatistics);
         return result;
     }
 
diff --git a/dl-module-inspection/src/main/resources/mapper/InspectionWorkNodeMapper.xml b/dl-module-inspection/src/main/resources/mapper/InspectionWorkNodeMapper.xml
index 98765abf..aa2e0488 100644
--- a/dl-module-inspection/src/main/resources/mapper/InspectionWorkNodeMapper.xml
+++ b/dl-module-inspection/src/main/resources/mapper/InspectionWorkNodeMapper.xml
@@ -486,4 +486,36 @@
         </where>
         GROUP BY staff.user_id, ip.id;
     </select>
+    <select id="queryOutputMoneyStatistics" resultType="java.util.Map">
+        SELECT
+        iw.deal_user_id,
+
+        -- 初检公示产值：流程次数为1的订单公示价格
+        COALESCE(SUM(CASE WHEN iw.node_count = 1 THEN oi.goods_price ELSE 0 END) / 100, 0) AS initialInspectionOutputValue,
+
+        -- 复检公示产值：流程次数大于1的订单公示价格总和
+        COALESCE(SUM(CASE WHEN iw.node_count > 1 THEN oi.goods_price ELSE 0 END) / 100, 0) AS recheckInspectionOutputValue,
+
+        -- 初检合格产值：流程次数为1且status=2且type='1'的订单公示价格
+        COALESCE(SUM(CASE WHEN iw.node_count = 1 AND iw.status = '2' AND iw.type = '1' THEN oi.goods_price ELSE 0 END) / 100, 0) AS initialInspectionPassOutputValue,
+
+        -- 复检合格产值：流程次数大于1且status=2且type='1'的订单公示价格总和
+        COALESCE(SUM(CASE WHEN iw.node_count > 1 AND iw.status = '2' AND iw.type = '1' THEN oi.goods_price ELSE 0 END) / 100, 0) AS recheckInspectionPassOutputValue
+
+        FROM
+        inspection_work_node iw
+        JOIN
+        inspection_info ii ON iw.inspection_info_id = ii.id
+        JOIN
+        order_info oi ON ii.inspection_order_id = oi.id
+        WHERE
+        iw.deal_user_id = #{userId}  -- 替换为所需的处理人ID
+        AND iw.deleted = 0  -- 确保流程未被删除
+        AND ii.deleted = 0  -- 确保检测信息未被删除
+        <if test="datetimeRange != null and datetimeRange.size() == 2">
+            AND iw.create_time BETWEEN CONCAT(#{datetimeRange[0]}, ' 00:00:00') AND CONCAT(#{datetimeRange[1]}, ' 23:59:59')
+        </if>
+        GROUP BY
+        iw.deal_user_id;
+    </select>
 </mapper>