admin/smartDriveEE
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

定时器 ，周期性的统计分析品牌维度

Browse Source
This commit is contained in:
spllzh
2025-09-21 16:53:07 +08:00
parent cd72a3680c
commit 004ba02996
26 changed files with 118 additions and 207 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/java/com/rj/common/PasswordUtil.java
View File

@@ -112,5 +112,6 @@ public class PasswordUtil {

1
src/main/java/com/rj/common/ServiceManager.java
View File

@@ -96,5 +96,6 @@ public class ServiceManager {

1
src/main/java/com/rj/config/AliyunConfig.java
View File

@@ -74,5 +74,6 @@ public class AliyunConfig {

1
src/main/java/com/rj/controller/sys/AuthController.java
View File

@@ -195,5 +195,6 @@ public class AuthController {

1
src/main/java/com/rj/controller/sys/MenuController.java
View File

@@ -334,5 +334,6 @@ public class MenuController {

1
src/main/java/com/rj/controller/sys/RoleController.java
View File

@@ -304,5 +304,6 @@ public class RoleController {

1
src/main/java/com/rj/controller/sys/UserRoleController.java
View File

@@ -310,5 +310,6 @@ public class UserRoleController {

1
src/main/java/com/rj/dto/DifyWorkflowResponseDto.java
View File

@@ -78,3 +78,4 @@ public class DifyWorkflowResponseDto {

1
src/main/java/com/rj/mapper/CustomerProfileAnalysisMapper.java
View File

@@ -22,3 +22,4 @@ public interface CustomerProfileAnalysisMapper extends BaseMapper<CustomerProfil

1
src/main/java/com/rj/pojo/sys/LoginResponse.java
View File

@@ -61,5 +61,6 @@ public class LoginResponse {

1
src/main/java/com/rj/scheduler/AudioStatisticsScheduler.java
View File

@@ -80,5 +80,6 @@ public class AudioStatisticsScheduler {

50
src/main/java/com/rj/scheduler/CpaBrandCoreScheduler.java
View File

@@ -33,7 +33,7 @@ public class CpaBrandCoreScheduler {
log.info("开始执行经销商品牌得分日统计任务...");
LocalDate yesterday = LocalDate.now().minusDays(1);
int count = cpaBrandScoreStatisticsService.generateAndSaveStatistics("daily", yesterday, yesterday, "system");
int count = cpaBrandScoreStatisticsService.generateAndSaveStatistics("daily", yesterday, yesterday, "systemScheduler");
log.info("经销商品牌得分日统计任务执行完成，统计日期：{}，生成记录数：{}",
yesterday.format(DateTimeFormatter.ofPattern("yyyy-MM-dd")), count);
@@ -44,21 +44,17 @@ public class CpaBrandCoreScheduler {
/**
* 每周一凌晨4点执行周统计任务
* 统计上周的数据
* 统计上周的数据（服务层自动计算上周时间范围）
*/
@Scheduled(cron = "0 0 4 * * MON")
public void generateWeeklyStatistics() {
try {
log.info("开始执行经销商品牌得分周统计任务...");
LocalDate lastWeekStart = LocalDate.now().minusWeeks(1).with(java.time.DayOfWeek.MONDAY);
LocalDate lastWeekEnd = lastWeekStart.plusDays(6);
// 周统计的时间范围由服务层自动计算，这里传递null即可
int count = cpaBrandScoreStatisticsService.generateAndSaveStatistics("weekly", null, null, "systemCpaBrandCoreScheduler");
int count = cpaBrandScoreStatisticsService.generateAndSaveStatistics("weekly", lastWeekStart, lastWeekEnd, "system");
log.info("经销商品牌得分周统计任务执行完成，统计周期：{} - {}，生成记录数：{}",
lastWeekStart.format(DateTimeFormatter.ofPattern("yyyy-MM-dd")),
lastWeekEnd.format(DateTimeFormatter.ofPattern("yyyy-MM-dd")), count);
log.info("经销商品牌得分周统计任务执行完成，生成记录数：{}", count);
} catch (Exception e) {
log.error("经销商品牌得分周统计任务执行失败", e);
}
@@ -66,21 +62,17 @@ public class CpaBrandCoreScheduler {
/**
* 每月1号凌晨5点执行月统计任务
* 统计上个月的数据
* 统计上个月的数据（服务层自动计算上月时间范围）
*/
@Scheduled(cron = "0 0 5 1 * ?")
public void generateMonthlyStatistics() {
try {
log.info("开始执行经销商品牌得分月统计任务...");
LocalDate lastMonthStart = LocalDate.now().minusMonths(1).withDayOfMonth(1);
LocalDate lastMonthEnd = lastMonthStart.withDayOfMonth(lastMonthStart.lengthOfMonth());
// 月统计的时间范围由服务层自动计算，这里传递null即可
int count = cpaBrandScoreStatisticsService.generateAndSaveStatistics("monthly", null, null, "systemCpaBrandCoreScheduler");
int count = cpaBrandScoreStatisticsService.generateAndSaveStatistics("monthly", lastMonthStart, lastMonthEnd, "system");
log.info("经销商品牌得分月统计任务执行完成，统计周期：{} - {}，生成记录数：{}",
lastMonthStart.format(DateTimeFormatter.ofPattern("yyyy-MM-dd")),
lastMonthEnd.format(DateTimeFormatter.ofPattern("yyyy-MM-dd")), count);
log.info("经销商品牌得分月统计任务执行完成，生成记录数：{}", count);
} catch (Exception e) {
log.error("经销商品牌得分月统计任务执行失败", e);
}
@@ -95,7 +87,7 @@ public class CpaBrandCoreScheduler {
try {
log.info("开始执行经销商品牌得分总计统计任务...");
int count = cpaBrandScoreStatisticsService.generateAndSaveStatistics("total", null, null, "system");
int count = cpaBrandScoreStatisticsService.generateAndSaveStatistics("total", null, null, "systemCpaBrandCoreScheduler");
log.info("经销商品牌得分总计统计任务执行完成，生成记录数：{}", count);
} catch (Exception e) {
@@ -113,7 +105,7 @@ public class CpaBrandCoreScheduler {
public int manualGenerateStatistics(LocalDate date, String statisticsType) {
try {
log.info("手动执行经销商品牌得分统计任务，统计日期：{}，统计类型：{}", date, statisticsType);
int count = cpaBrandScoreStatisticsService.generateAndSaveStatistics(statisticsType, date, date, "manual");
int count = cpaBrandScoreStatisticsService.generateAndSaveStatistics(statisticsType, date, date, "manualCpaBrandCoreScheduler");
log.info("手动经销商品牌得分统计任务执行完成，统计日期：{}，统计类型：{}，生成记录数：{}",
date, statisticsType, count);
return count;
@@ -126,17 +118,27 @@ public class CpaBrandCoreScheduler {
/**
* 手动触发日期范围统计任务
*
* @param startDate 开始日期
* @param endDate 结束日期
* @param startDate 开始日期（对于weekly/monthly类型，此参数将被忽略，服务层自动计算）
* @param endDate 结束日期（对于weekly/monthly类型，此参数将被忽略，服务层自动计算）
* @param statisticsType 统计类型
* @return 生成的记录数
*/
public int manualGenerateStatisticsByRange(LocalDate startDate, LocalDate endDate, String statisticsType) {
try {
log.info("手动执行经销商品牌得分统计任务，统计范围：{} - {}，统计类型：{}", startDate, endDate, statisticsType);
if ("weekly".equals(statisticsType) || "monthly".equals(statisticsType)) {
log.info("手动执行经销商品牌得分统计任务，统计类型：{}（时间范围由服务层自动计算）", statisticsType);
} else {
log.info("手动执行经销商品牌得分统计任务，统计范围：{} - {}，统计类型：{}", startDate, endDate, statisticsType);
}
int count = cpaBrandScoreStatisticsService.generateAndSaveStatistics(statisticsType, startDate, endDate, "manual");
log.info("手动经销商品牌得分统计任务执行完成，统计范围：{} - {}，统计类型：{}，生成记录数：{}",
startDate, endDate, statisticsType, count);
if ("weekly".equals(statisticsType) || "monthly".equals(statisticsType)) {
log.info("手动经销商品牌得分统计任务执行完成，统计类型：{}，生成记录数：{}", statisticsType, count);
} else {
log.info("手动经销商品牌得分统计任务执行完成，统计范围：{} - {}，统计类型：{}，生成记录数：{}",
startDate, endDate, statisticsType, count);
}
return count;
} catch (Exception e) {
log.error("手动经销商品牌得分统计任务执行失败，统计范围：{} - {}，统计类型：{}", startDate, endDate, statisticsType, e);

21
src/main/java/com/rj/scheduler/CustomerProfileMockInsertDataScheduler.java
View File

@@ -134,18 +134,23 @@ public class CustomerProfileMockInsertDataScheduler {
public void generateDailyCustomerProfileData() {
try {
log.info("开始执行客户画像数据生成任务...");
// 生成昨天的数据
LocalDateTime yesterday = LocalDateTime.now().minusDays(1);
int count = generateCustomerProfileDataForDate(yesterday);
log.info("客户画像数据生成任务执行完成，生成日期：{}，生成记录数：{}",
yesterday.format(DateTimeFormatter.ofPattern("yyyy-MM-dd")), count);
// 生成今天的数据
LocalDateTime today = LocalDateTime.now().minusDays(0);
int todayCount = generateCustomerProfileDataForDate(today);
// 生成昨天的数据
LocalDateTime yesterday = LocalDateTime.now().minusDays(1);
int count = generateCustomerProfileDataForDate(yesterday);
// 生成前天天的数据
LocalDateTime yesterday2 = LocalDateTime.now().minusDays(2);
int count2 = generateCustomerProfileDataForDate(yesterday2);
log.info("客户画像数据生成任务执行完成，生成日期：{}，生成记录数：{}",
yesterday.format(DateTimeFormatter.ofPattern("yyyy-MM-dd")), count);
log.info("客户画像数据生成任务执行完成，生成日期：{}，生成记录数：{}",
today.format(DateTimeFormatter.ofPattern("yyyy-MM-dd")), todayCount);
} catch (Exception e) {

1
src/main/java/com/rj/service/biz/ICustomerProfileAnalysisService.java
View File

@@ -43,3 +43,4 @@ public interface ICustomerProfileAnalysisService extends IService<CustomerProfil

1
src/main/java/com/rj/service/biz/impl/CustomerProfileAnalysisServiceImpl.java
View File

@@ -78,3 +78,4 @@ public class CustomerProfileAnalysisServiceImpl extends ServiceImpl<CustomerProf

67
src/main/java/com/rj/service/impl/CpaBrandScoreStatisticsServiceImpl.java
View File

@@ -106,36 +106,81 @@ public class CpaBrandScoreStatisticsServiceImpl extends ServiceImpl<CpaBrandScor
public int generateAndSaveStatistics(String statisticsType, LocalDate startDate, LocalDate endDate, String createdBy) {
try {
log.info("开始生成统计数据，统计类型：{}，日期范围：{} - {}", statisticsType, startDate, endDate);
// 先删除已存在的统计数据
deleteByCondition(null, statisticsType, startDate, endDate);
List<Map<String, Object>> statisticsResults;
// 根据统计类型执行不同的统计SQL
if ("daily".equals(statisticsType)) {
// 日统计：按经销商和日期双重分组
// 日统计：使用传入的日期，按经销商和日期双重分组
if (startDate == null) {
throw new IllegalArgumentException("日统计需要提供统计日期");
}
// 先删除已存在的统计数据
deleteByCondition(null, statisticsType, startDate, startDate);
String startDateTime = startDate.atStartOfDay().format(java.time.format.DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
String endDateTime = startDate.atTime(23, 59, 59).format(java.time.format.DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
statisticsResults = cpaBrandScoreStatisticsMapper.executeDailyStatistics(startDateTime, endDateTime);
} else if ("weekly".equals(statisticsType) || "monthly".equals(statisticsType)) {
// 周统计或月统计：按日期范围统计
String startDateTime = startDate.atStartOfDay().format(java.time.format.DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
String endDateTime = endDate.atTime(23, 59, 59).format(java.time.format.DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
} else if ("weekly".equals(statisticsType)) {
// 周统计：自动计算上周的开始和结束时间
LocalDate lastWeekStart = LocalDate.now().minusWeeks(1).with(java.time.DayOfWeek.MONDAY);
LocalDate lastWeekEnd = lastWeekStart.plusDays(6);
log.info("周统计自动计算时间范围：{} - {}", lastWeekStart, lastWeekEnd);
// 先删除已存在的统计数据
deleteByCondition(null, statisticsType, lastWeekStart, lastWeekEnd);
String startDateTime = lastWeekStart.atStartOfDay().format(java.time.format.DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
String endDateTime = lastWeekEnd.atTime(23, 59, 59).format(java.time.format.DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
statisticsResults = cpaBrandScoreStatisticsMapper.executeDateRangeStatistics(startDateTime, endDateTime);
} else if ("monthly".equals(statisticsType)) {
// 月统计：自动计算上个月的开始和结束时间
LocalDate lastMonthStart = LocalDate.now().minusMonths(1).withDayOfMonth(1);
LocalDate lastMonthEnd = lastMonthStart.withDayOfMonth(lastMonthStart.lengthOfMonth());
log.info("月统计自动计算时间范围：{} - {}", lastMonthStart, lastMonthEnd);
// 先删除已存在的统计数据
deleteByCondition(null, statisticsType, lastMonthStart, lastMonthEnd);
String startDateTime = lastMonthStart.atStartOfDay().format(java.time.format.DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
String endDateTime = lastMonthEnd.atTime(23, 59, 59).format(java.time.format.DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
statisticsResults = cpaBrandScoreStatisticsMapper.executeDateRangeStatistics(startDateTime, endDateTime);
} else if ("total".equals(statisticsType)) {
// 总计统计：统计所有历史数据
// 先删除已存在的统计数据
deleteByCondition(null, statisticsType, null, null);
statisticsResults = cpaBrandScoreStatisticsMapper.executeTotalStatistics();
} else {
throw new IllegalArgumentException("不支持的统计类型：" + statisticsType);
}
// 转换为实体对象并保存
List<CpaBrandScoreStatistics> statisticsList = convertToStatisticsList(statisticsResults, endDate, statisticsType, createdBy);
LocalDate statisticsDate;
if ("weekly".equals(statisticsType)) {
// 周统计使用上周的结束日期作为统计日期
statisticsDate = LocalDate.now().minusWeeks(1).with(java.time.DayOfWeek.MONDAY).plusDays(6);
} else if ("monthly".equals(statisticsType)) {
// 月统计使用上月的最后一天作为统计日期
statisticsDate = LocalDate.now().minusMonths(1).withDayOfMonth(1).withDayOfMonth(
LocalDate.now().minusMonths(1).withDayOfMonth(1).lengthOfMonth());
} else {
// 日统计和总计统计使用传入的日期
statisticsDate = endDate;
}
List<CpaBrandScoreStatistics> statisticsList = convertToStatisticsList(statisticsResults, statisticsDate, statisticsType, createdBy);
boolean success = batchSave(statisticsList);
if (success) {
log.info("统计数据生成完成，统计类型：{}，生成记录数：{}", statisticsType, statisticsList.size());
log.info("统计数据生成完成，统计类型：{}，统计日期：{}，生成记录数：{}", statisticsType, statisticsDate, statisticsList.size());
return statisticsList.size();
} else {
log.error("统计数据保存失败，统计类型：{}", statisticsType);

1
src/main/java/com/rj/service/sys/IMenuService.java
View File

@@ -43,5 +43,6 @@ public interface IMenuService extends IService<Menu> {

1
src/main/java/com/rj/service/sys/IUserRoleService.java
View File

@@ -43,5 +43,6 @@ public interface IUserRoleService extends IService<UserRole> {

1
src/main/java/com/rj/service/sys/impl/MenuServiceImpl.java
View File

@@ -47,5 +47,6 @@ public class MenuServiceImpl extends ServiceImpl<MenuMapper, Menu> implements IM

1
src/main/java/com/rj/service/sys/impl/RoleServiceImpl.java
View File

@@ -47,5 +47,6 @@ public class RoleServiceImpl extends ServiceImpl<RoleMapper, Role> implements IR

1
src/main/java/com/rj/service/sys/impl/UserRoleServiceImpl.java
View File

@@ -47,5 +47,6 @@ public class UserRoleServiceImpl extends ServiceImpl<UserRoleMapper, UserRole> i