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-10-24 15:12:34 +08:00
parent ac0c8fe4de
commit 810d4ea1d0
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/activity/LotteryRecordQryExe.java
View File

@ -14,6 +14,7 @@ import com.red.circle.other.infra.database.rds.service.activity.LotteryPrizeServ
import com.red.circle.other.infra.database.rds.service.activity.LotteryRecordService; import com.red.circle.other.infra.database.rds.service.activity.LotteryRecordService;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Objects;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -56,6 +57,9 @@ public class LotteryRecordQryExe {
} }
IPage<LotteryRecord> recordPage = query.orderByDesc(LotteryRecord::getDrawTime).page(page); IPage<LotteryRecord> recordPage = query.orderByDesc(LotteryRecord::getDrawTime).page(page);
if (recordPage.getRecords().isEmpty()) {
return new PageResult<>();
}
// 查询关联数据 // 查询关联数据
List<Long> activityIds = recordPage.getRecords().stream() List<Long> activityIds = recordPage.getRecords().stream()
@ -65,7 +69,7 @@ public class LotteryRecordQryExe {
List<Long> prizeIds = recordPage.getRecords().stream() List<Long> prizeIds = recordPage.getRecords().stream()
.map(LotteryRecord::getPrizeId) .map(LotteryRecord::getPrizeId)
.filter(id -> id != null) .filter(Objects::nonNull)
.distinct() .distinct()
.collect(Collectors.toList()); .collect(Collectors.toList());