hy/aslan-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

房间新增日统计

Browse Source
This commit is contained in:
tianfeng 2025-09-29 17:38:47 +08:00
parent a19efc4511
commit d9024a0d23
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/mongo/service/live/impl/RoomContributionRankCountServiceImpl.java
View File

@ -47,6 +47,10 @@ public class RoomContributionRankCountServiceImpl implements RoomContributionRan
// 类型，过期时间，分组日期 // 类型，过期时间，分组日期
List<ImmutableTriple<String, Timestamp, Integer>> dates = List.of( List<ImmutableTriple<String, Timestamp, Integer>> dates = List.of(
ImmutableTriple.of("HOUR",
TimestampUtils.nowPlusHours(1),
dateNumberNowHour()
),
ImmutableTriple.of("DAY", ImmutableTriple.of("DAY",
TimestampUtils.nowPlusDays(1), TimestampUtils.nowPlusDays(1),
dateNumberNowDay() dateNumberNowDay()
@ -108,6 +112,9 @@ public class RoomContributionRankCountServiceImpl implements RoomContributionRan
} }
private Integer getDateNumber(String dateType) { private Integer getDateNumber(String dateType) {
if (Objects.equals(dateType, "HOUR")) {
return dateNumberNowHour();
}
if (Objects.equals(dateType, "DAY")) { if (Objects.equals(dateType, "DAY")) {
return dateNumberNowDay(); return dateNumberNowDay();
} }
@ -120,6 +127,10 @@ public class RoomContributionRankCountServiceImpl implements RoomContributionRan
return 0; return 0;
} }
private Integer dateNumberNowHour() {
return Integer.valueOf(ZonedDateTimeAsiaRiyadhUtils.nowFormat("yyyyMMddHH"));
}
private Integer dateNumberNowMonth() { private Integer dateNumberNowMonth() {
return ZonedDateTimeAsiaRiyadhUtils.nowYearMonthToInt(); return ZonedDateTimeAsiaRiyadhUtils.nowYearMonthToInt();
} }
@ -193,6 +204,7 @@ public class RoomContributionRankCountServiceImpl implements RoomContributionRan
return; return;
} }
updateCorrectionData(roomId, userId, "HOUR", quantity.longValue());
updateCorrectionData(roomId, userId, "DAY", quantity.longValue()); updateCorrectionData(roomId, userId, "DAY", quantity.longValue());
updateCorrectionData(roomId, userId, "WEEK", quantity.longValue()); updateCorrectionData(roomId, userId, "WEEK", quantity.longValue());
updateCorrectionData(roomId, userId, "MONTH", quantity.longValue()); updateCorrectionData(roomId, userId, "MONTH", quantity.longValue());
@ -200,7 +212,7 @@ public class RoomContributionRankCountServiceImpl implements RoomContributionRan
} }
/** /**
* 矫正年月日数据 * 矫正数据
*/ */
private void updateCorrectionData(Long roomId, Long userId, String dateType, Long quantity) { private void updateCorrectionData(Long roomId, Long userId, String dateType, Long quantity) {