From a97949ab0ecf7cbf2d6713ce76d810c03101d7f6 Mon Sep 17 00:00:00 2001
From: dengzedong <dengzedong@email>
Date: 星期四, 15 五月 2025 17:22:31 +0800
Subject: [PATCH] 指标数据 当前月,上个月

---
 iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/ind/collection/utils/IndSqlUtils.java |   53 ++++++++++++++++++++++++++++-------------------------
 1 files changed, 28 insertions(+), 25 deletions(-)

diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/ind/collection/utils/IndSqlUtils.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/ind/collection/utils/IndSqlUtils.java
index e5d4636..08f68dd 100644
--- a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/ind/collection/utils/IndSqlUtils.java
+++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/ind/collection/utils/IndSqlUtils.java
@@ -13,6 +13,7 @@
 import com.iailab.module.data.ind.item.vo.IndItemAtomVO;
 import com.iailab.module.data.ind.item.vo.IndItemDerVO;
 import com.iailab.module.data.ind.value.dto.QuerySourceValueDTO;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
@@ -26,6 +27,7 @@
  * @Description
  * @createTime 2024年10月04日
  */
+@Slf4j
 @Component
 public class IndSqlUtils {
 
@@ -197,30 +199,36 @@
                 break;
             case THIS_MONTH:
                 whereSql.append(indItem.getTimeLabel());
-                whereSql.append("='");
-                whereSql.append(getYearMonth(calendar,indItem.getMonthStart()));
-                whereSql.append("'");
-                break;
-            case LAST_MONTH:
-                whereSql.append(indItem.getTimeLabel());
-                whereSql.append("' < '");
-                whereSql.append(getYearMonth(calendar,indItem.getMonthStart()));
+                whereSql.append(" < '");
+                whereSql.append(getYearMonth(calendar,indItem.getMonthStart(),datePattern));
                 whereSql.append("' AND ");
                 whereSql.append(indItem.getTimeLabel());
                 whereSql.append(" >= '");
                 calendar.add(Calendar.MONTH, -1);
-                whereSql.append(getYearMonth(calendar,indItem.getMonthStart()));
+                whereSql.append(getYearMonth(calendar,indItem.getMonthStart(),datePattern));
+                whereSql.append("'");
+                break;
+            case LAST_MONTH:
+                whereSql.append(indItem.getTimeLabel());
+                whereSql.append(" < '");
+                calendar.add(Calendar.MONTH, -1);
+                whereSql.append(getYearMonth(calendar,indItem.getMonthStart(),datePattern));
+                whereSql.append("' AND ");
+                whereSql.append(indItem.getTimeLabel());
+                whereSql.append(" >= '");
+                calendar.add(Calendar.MONTH, -1);
+                whereSql.append(getYearMonth(calendar,indItem.getMonthStart(),datePattern));
                 whereSql.append("'");
                 break;
             case LAST_MONTH_12:
                 whereSql.append(indItem.getTimeLabel());
-                whereSql.append(" <= '");
-                whereSql.append(getYearMonth(calendar,indItem.getMonthStart()));
+                whereSql.append(" < '");
+                whereSql.append(getYearMonth(calendar,indItem.getMonthStart(),datePattern));
                 whereSql.append("' AND ");
                 whereSql.append(indItem.getTimeLabel());
-                whereSql.append("' >= '");
+                whereSql.append(" >= '");
                 calendar.add(Calendar.MONTH, -12);
-                whereSql.append(getYearMonth(calendar,indItem.getMonthStart()));
+                whereSql.append(getYearMonth(calendar,indItem.getMonthStart(),datePattern));
                 whereSql.append("'");
                 break;
             case THIS_YEAR_MONTH:
@@ -275,6 +283,7 @@
             default:
                 break;
         }
+        log.info("whereSql:" + whereSql);
         result.setWhereSql(whereSql.toString());
 
         // 拼接GROUP
@@ -293,23 +302,17 @@
         return result;
     }
 
-    public static String getYearMonth(Calendar now,Integer monthStart) {
+    public static String getYearMonth(Calendar calendar,Integer monthStart,String datePattern) {
+        Calendar now = (Calendar) calendar.clone();
         int day = now.get(Calendar.DAY_OF_MONTH);
 
-        // 当前月
-        if (monthStart > 0) {
-            if (day < monthStart) {
-                now.add(Calendar.MONTH, -1);
-            }
+        if (day >= Math.abs(monthStart)) {
+            now.add(Calendar.MONTH, 1);
         }
 
-        if (monthStart < 0) {
-            if (day >= Math.abs(monthStart)) {
-                now.add(Calendar.MONTH, 1);
-            }
-        }
+        now.set(Calendar.DAY_OF_MONTH,Math.abs(monthStart));
         // 定义日期格式化对象,指定格式为 yyyy-MM
-        SimpleDateFormat sdf = new SimpleDateFormat(PATTERN_MON);
+        SimpleDateFormat sdf = new SimpleDateFormat(datePattern);
         // 格式化日期并返回结果
         return sdf.format(now.getTime());
     }

--
Gitblit v1.9.3