From c06b96e98a79236aace6fed9c71f1533daf6bdcb Mon Sep 17 00:00:00 2001
From: sangelxiu1 <15781802@163.com>
Date: Fri, 18 Jul 2025 10:15:34 +0800
Subject: [PATCH] =?UTF-8?q?##=20Opt=20-=20=E7=9B=92=E6=95=B0&=E5=B8=82?=
 =?UTF-8?q?=E5=9C=BA=E5=8A=A8=E6=80=81,=20=E5=87=8C=E6=99=A83=E5=A4=A9?=
 =?UTF-8?q?=E5=89=8D=E5=8F=96-1=E5=A4=A9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../CuMemberRetailAchieveServiceImpl.java     | 39 +++++++++++++++++--
 1 file changed, 36 insertions(+), 3 deletions(-)

diff --git a/bd-business/bd-business-member/src/main/java/com/hzs/retail/member/service/impl/CuMemberRetailAchieveServiceImpl.java b/bd-business/bd-business-member/src/main/java/com/hzs/retail/member/service/impl/CuMemberRetailAchieveServiceImpl.java
index 8b707c7c..c9d25241 100644
--- a/bd-business/bd-business-member/src/main/java/com/hzs/retail/member/service/impl/CuMemberRetailAchieveServiceImpl.java
+++ b/bd-business/bd-business-member/src/main/java/com/hzs/retail/member/service/impl/CuMemberRetailAchieveServiceImpl.java
@@ -33,6 +33,8 @@ import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
 import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.LocalTime;
 import java.time.format.DateTimeFormatter;
 import java.time.temporal.ChronoUnit;
 import java.time.temporal.TemporalAdjusters;
@@ -334,6 +336,37 @@ public class CuMemberRetailAchieveServiceImpl extends ServiceImpl<CuMemberRetail
         int period = cuMemberSettlePeriod.getPkId();
         return TableNameConstants.CU_MEMBER_RETAIL_S + period;
     }
+    private String getTableNameSpecial() {
+        String localDate = LocalDate.now().minus(1, ChronoUnit.DAYS).format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
+        if(isBeforeThreeAm()){
+            localDate = LocalDate.now().minus(2, ChronoUnit.DAYS).format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
+        }
+        CuMemberSettlePeriod cuMemberSettlePeriod =iCuMemberSettlePeriodService.getCuMemberSettlePeriodByDate(localDate);
+        if(ObjectUtil.isEmpty(cuMemberSettlePeriod)){
+            return null;
+        }
+        int period = cuMemberSettlePeriod.getPkId();
+        return TableNameConstants.CU_MEMBER_RETAIL_RANGE + period;
+    }
+    private String getDayTableNameSpecial() {
+        String localDate = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
+        if(isBeforeThreeAm()){
+            localDate = LocalDate.now().minus(1, ChronoUnit.DAYS).format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
+        }
+        CuMemberSettlePeriod cuMemberSettlePeriod =iCuMemberSettlePeriodService.getCuMemberSettlePeriodByDate(localDate);
+        if(ObjectUtil.isEmpty(cuMemberSettlePeriod)){
+            return null;
+        }
+        int period = cuMemberSettlePeriod.getPkId();
+        return TableNameConstants.CU_MEMBER_RETAIL_S + period;
+    }
+    public static boolean isBeforeThreeAm() {
+        LocalDateTime now = LocalDateTime.now();
+        // 获取当天凌晨3点的时间（日期与当前日期相同，时间为03:00:00）
+        LocalDateTime threeAm = now.with(LocalTime.of(3, 0, 0));
+        // 比较当前时间是否在3点之前
+        return now.isBefore(threeAm);
+    }
 
 
     /**
@@ -587,8 +620,8 @@ public class CuMemberRetailAchieveServiceImpl extends ServiceImpl<CuMemberRetail
     @Override
     public CuMemberRetailDataStatisticsResultVO getRetailDataStatisticsDetail(Long pkMember, Integer pkCountry, Integer systemType) {
         Long userId = SecurityUtils.getUserId();
-        String memberRetailTable = getTableName();
-        String memberSecondTable = getDayTableName();
+        String memberRetailTable = getTableNameSpecial();
+        String memberSecondTable = getDayTableNameSpecial();
         //查询直推会员
         List<Long> pkMemberList = baseMapper.selectDirectPushByPkMember(pkMember, systemType);
         pkMemberList.add(userId);
@@ -610,7 +643,7 @@ public class CuMemberRetailAchieveServiceImpl extends ServiceImpl<CuMemberRetail
         Integer systemType = SecurityUtils.getSystemType();
 
         DataStatisticsUtil.setQueryDateParam(param);
-        param.setCurrentDayTableName(getDayTableName());
+        param.setCurrentDayTableName(getDayTableNameSpecial());
         param.setCurrentMonthTableName(getDayTableName(param.getYesterdayDate()));
         param.setLastMonthTableName(getDayTableName(param.getLastMonthDate()));
         log.info("MarketDynamicsQueryDateParam : {}", JSONUtil.toJsonStr(param));