From 019a3f5be7c2fef4f38ada6427cbc2bf5989a173 Mon Sep 17 00:00:00 2001
From: punchhhh <87906027+punchhhh@users.noreply.github.com>
Date: Fri, 17 Jan 2025 14:38:56 +0800
Subject: [PATCH] =?UTF-8?q?=E5=94=AE=E7=A5=A8=E6=9F=A5=E8=AF=A2=E6=8C=89?=
 =?UTF-8?q?=E6=80=A7=E5=88=AB=E7=BB=9F=E8=AE=A1=E6=95=B0=E9=87=8F=20=20?=
 =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E8=BA=AB=E4=BB=BD=E8=AF=81=E9=9D=9E=E7=A9=BA?=
 =?UTF-8?q?=E5=88=A4=E6=96=AD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../saledata/SaleDataTodayRepository.java     | 37 +++++++++++++++++--
 1 file changed, 34 insertions(+), 3 deletions(-)

diff --git a/ludu-module-datacenter/ludu-module-datacenter-biz/src/main/java/cn/iocoder/yudao/module/datacenter/dal/mongodb/saledata/SaleDataTodayRepository.java b/ludu-module-datacenter/ludu-module-datacenter-biz/src/main/java/cn/iocoder/yudao/module/datacenter/dal/mongodb/saledata/SaleDataTodayRepository.java
index 549cebd70..aea877cc2 100644
--- a/ludu-module-datacenter/ludu-module-datacenter-biz/src/main/java/cn/iocoder/yudao/module/datacenter/dal/mongodb/saledata/SaleDataTodayRepository.java
+++ b/ludu-module-datacenter/ludu-module-datacenter-biz/src/main/java/cn/iocoder/yudao/module/datacenter/dal/mongodb/saledata/SaleDataTodayRepository.java
@@ -36,12 +36,43 @@ public interface SaleDataTodayRepository extends MongoRepository<SaleDataToday,S
 
     @Aggregation(pipeline = {
             "{$match: {sddate: { $gte: ?0, $lte: ?1 }}}",
-            "{$project: {certLength: {$strLenCP: '$certificateno'}, secondLastChar: {$substrCP: ['$certificateno', {$subtract: [{$strLenCP: '$certificateno'}, 2]}, 1]}}}",
-            "{$group: {_id: null, maleCount: {$sum: {$cond: {if: {$eq: [{$mod: [{$toInt: '$secondLastChar'}, 2]}, 1]}, then: 1, else: 0}}}, femaleCount: {$sum: {$cond: {if: {$eq: [{$mod: [{$toInt: '$secondLastChar'}, 2]}, 0]}, then: 1, else: 0}}}, totalCount: {$sum: 1}}}",
-            "{$project: {_id: 0, maleCount: 1, femaleCount: 1, maleRatio: {$divide: ['$maleCount', '$totalCount']}}}"
+            "{$project: {" +
+                    // 使用 $ifNull 处理 certficateno 为 null 或空字符串的情况
+            "       certLength: {$strLenCP: {$ifNull: ['$certificateno', '']}}, " +
+                    // 获取倒数第二个字符，并处理 certficateno 为 null 或长度小于 2 的情况
+            "       secondLastChar: {$cond: {" +
+            "           if: {$gte: [{$strLenCP: {$ifNull: ['$certificateno', '']}}, 2]}," +
+            "           then: {$substrCP: [" +
+            "               {$ifNull: ['$certificateno', '']}," +
+            "               {$subtract: [{$strLenCP: {$ifNull: ['$certificateno', '']}}, 2]}, 1" +
+            "           ]}, " +
+            "           else: '0'" + // 如果 certficateno 长度小于 2，返回 '0'
+            "       }}" +
+            "}}",
+            "{$group: {" +
+            "       _id: null," +
+                    // 统计男性人数，倒数第二个字符是奇数
+            "       maleCount: {$sum: {$cond: {" +
+            "           if: {$eq: [{$mod: [{$toInt: '$secondLastChar'}, 2]}, 1]}," +
+            "           then: 1, else: 0" +
+            "       }}}," +
+                    // 统计女性人数，倒数第二个字符是偶数
+            "       femaleCount: {$sum: {$cond: {" +
+            "           if: {$eq: [{$mod: [{$toInt: '$secondLastChar'}, 2]}, 0]}," +
+            "           then: 1, else: 0" +
+            "       }}}," +
+            "       totalCount: {$sum: 1}" + // 总数
+            "}}",
+            "{$project: {" +
+            "       _id: 0," +
+            "       maleCount: 1," +
+            "       femaleCount: 1," +
+            "       maleRatio: {$divide: ['$maleCount', '$totalCount']}" + // 计算男性比例
+            "}}"
     })
     AggregationVO findAllByCertificatenoSDTime(String starTime, String endTime);
 
+
     @Aggregation(pipeline = {
             "{$match: {sddate: { $gte: ?0, $lte: ?1 }}}",
             "{$match: {certificateno: {$regex: '^.{18}$'}}}",