package com.rongyichuang.activity.repository; import com.rongyichuang.activity.entity.Activity; import org.springframework.data.domain.Page; import org.springframework.data.domain.Pageable; import org.springframework.data.jpa.repository.JpaRepository; import org.springframework.data.jpa.repository.Query; import org.springframework.data.repository.query.Param; import java.util.List; public interface ActivityRepository extends JpaRepository { Page findByPidAndStateAndNameContainingOrderByCreateTimeDesc(Long pid, int state, String name, Pageable pageable); Page findByPidAndNameContainingOrderByCreateTimeDesc(Long pid, String name, Pageable pageable); Page findByPidOrderByCreateTimeDesc(Long pid, Pageable pageable); Page findByPidAndStateOrderByCreateTimeDesc(Long pid, int state, Pageable pageable); List findByPidAndStateOrderByCreateTimeAsc(Long pid, int state); List findByStateOrderByPidAscNameAsc(int state); @Query("SELECT a FROM Activity a WHERE a.pid = 0 ORDER BY a.createTime DESC") Page findRecentActivities(Pageable pageable); /** * 根据活动ID查询活动 */ @Query("SELECT a FROM Activity a WHERE a.id = :id") Activity findActivityById(@Param("id") Long id); /** * 根据状态查询活动数量 */ @Query("SELECT COUNT(a) FROM Activity a WHERE a.state = :state") Long countByState(@Param("state") int state); /** * 统计当前进行中的活动数量(状态为1且pid=0的主活动) */ @Query("SELECT COUNT(a) FROM Activity a WHERE a.state = 1 AND a.pid = 0") Long countActiveActivities(); /** * 查询所有父级活动(pid = 0) */ @Query("SELECT a FROM Activity a WHERE a.pid = 0 ORDER BY a.createTime DESC") List findAllParentActivities(); /** * 根据父级ID查询子活动 */ @Query("SELECT a FROM Activity a WHERE a.pid = :pid ORDER BY a.createTime DESC") List findChildActivitiesByPid(@Param("pid") Long pid); /** * 根据名称模糊查询活动 */ @Query("SELECT a FROM Activity a WHERE a.name LIKE %:name% ORDER BY a.createTime DESC") List findByNameContaining(@Param("name") String name); /** * 查询指定状态的活动,按创建时间排序 */ @Query("SELECT a FROM Activity a WHERE a.state = :state ORDER BY a.createTime DESC") List findByStateOrderByCreateTimeDesc(@Param("state") int state); /** * 分页查询指定状态的活动 */ @Query("SELECT a FROM Activity a WHERE a.state = :state ORDER BY a.createTime DESC") Page findByStateOrderByCreateTimeDesc(@Param("state") int state, Pageable pageable); /** * 查询活动及其评分方案 */ @Query("SELECT a FROM Activity a LEFT JOIN FETCH a.ratingScheme WHERE a.id = :id") Activity findActivityWithRatingScheme(@Param("id") Long id); /** * 查询进行中的活动(状态为1的活动) */ @Query("SELECT a FROM Activity a WHERE a.state = 1 ORDER BY a.createTime DESC") List findOngoingActivities(); /** * 查找指定活动的第一阶段(sortOrder=1) */ @Query("SELECT a FROM Activity a WHERE a.pid = :activityId AND a.sortOrder = 1 AND a.state = 1") Activity findFirstStageByActivityId(@Param("activityId") Long activityId); /** * 根据父级ID和状态查询活动,按sortOrder排序 */ List findByPidAndStateOrderBySortOrderAsc(Long pid, Integer state); }