| 
					
				 | 
			
			
				@@ -5,7 +5,6 @@ import com.baomidou.mybatisplus.core.metadata.IPage; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.yonge.cooleshow.auth.api.entity.SysUser; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.yonge.cooleshow.auth.api.client.SysUserFeignService; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.yonge.cooleshow.auth.api.entity.SysUser; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.yonge.cooleshow.biz.dal.dao.ActivityPlanDao; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.yonge.cooleshow.biz.dal.dao.ActivityPlanEvaluationDao; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.yonge.cooleshow.biz.dal.dto.ActivityPlanDto; 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -29,19 +28,14 @@ import org.apache.commons.collections.CollectionUtils; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import org.slf4j.Logger; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import org.slf4j.LoggerFactory; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.yonge.cooleshow.biz.dal.entity.ActivityPlan; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.yonge.cooleshow.biz.dal.vo.ActivityPlanVo; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.yonge.cooleshow.biz.dal.dto.search.ActivityPlanSearch; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.yonge.cooleshow.biz.dal.dao.ActivityPlanDao; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.yonge.cooleshow.biz.dal.service.ActivityPlanService; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import org.springframework.transaction.annotation.Transactional; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import org.springframework.beans.BeanUtils; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import org.springframework.beans.factory.annotation.Autowired; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import org.springframework.stereotype.Service; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import javax.annotation.Resource; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import java.math.BigDecimal; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import java.util.Date; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import java.util.Date; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import java.util.List; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import java.util.Optional; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -67,7 +61,7 @@ public class ActivityPlanServiceImpl extends ServiceImpl<ActivityPlanDao, Activi 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     @Autowired 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     private ActivityEvaluationRecordService activityEvaluationRecordService; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-	@Override 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    @Override 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public ActivityPlanVo detail(Long id) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         ActivityPlanVo detail = baseMapper.detail(id); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         if (null != detail) { 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -114,7 +108,7 @@ public class ActivityPlanServiceImpl extends ServiceImpl<ActivityPlanDao, Activi 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                     return true; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                 } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                 return false; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            }else{ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+            } else { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                 activityPlan.setUpdateBy(user.getId()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                 updateById(activityPlan); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -128,11 +122,25 @@ public class ActivityPlanServiceImpl extends ServiceImpl<ActivityPlanDao, Activi 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     @Override 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public Boolean updateActivityState(Long activityId, Integer activityState, Long id) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        ActivityPlanVo detail = detail(activityId); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         ActivityPlan activityPlan = new ActivityPlan(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        if (activityState == 1) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+            Date now = new Date(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+            if (detail.getActivityEnd().before(now)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+                return false; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+            } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+            if(detail.getActivityStart().after(now)){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+                activityPlan.setActivityStart(now); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+            } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         activityPlan.setId(activityId); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         activityPlan.setActivityState(activityState); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         activityPlan.setUpdateBy(id); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         activityPlan.setUpdateTime(new Date()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         baseMapper.updateById(activityPlan); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         return true; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -152,21 +160,19 @@ public class ActivityPlanServiceImpl extends ServiceImpl<ActivityPlanDao, Activi 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				- 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     @Override 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public MusicActivityVo getActivityInfo(Long activityPlanId, SysUser user) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         ActivityPlan activityPlan = this.getById(activityPlanId); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         MusicActivityVo activityVo = new MusicActivityVo(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        BeanUtils.copyProperties(activityPlan,activityVo); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        BeanUtils.copyProperties(activityPlan, activityVo); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         // 活动曲目 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        List<ActivityMusicVo> activityMusicVoList = activityEvaluationService.getActivityMusic(activityPlanId,user.getId()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        List<ActivityMusicVo> activityMusicVoList = activityEvaluationService.getActivityMusic(activityPlanId, user.getId()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         activityVo.setActivityMusicVoList(activityMusicVoList); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         // 报名状态 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        activityVo.setJoin(activityRegistrationService.getRegistration(user.getId(),activityPlanId)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        activityVo.setJoin(activityRegistrationService.getRegistration(user.getId(), activityPlanId)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         // 活动奖品 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         List<ActivityReward> activityRewardList = activityRewardService.getActivityReward(activityPlanId); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -200,7 +206,7 @@ public class ActivityPlanServiceImpl extends ServiceImpl<ActivityPlanDao, Activi 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         if (activityPlanPayDto.getActivityId() == null) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             throw new BizException("活动id不能为空"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        ActivityPlan activityPlan = getById(activityPlanPayDto.getActivityId() ); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        ActivityPlan activityPlan = getById(activityPlanPayDto.getActivityId()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         orderCreateRes.setRes(true); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         orderCreateRes.setGoodType(orderCreateRes.getGoodType()); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -213,9 +219,9 @@ public class ActivityPlanServiceImpl extends ServiceImpl<ActivityPlanDao, Activi 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     private boolean checkoutJoinActivity(Long activityId, Long userId) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         return activityRegistrationService.lambdaQuery() 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                                                   .eq(ActivityRegistration::getActivityId, activityId) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                                                   .eq(ActivityRegistration::getUserId, userId) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                                                   .count() >0; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+                .eq(ActivityRegistration::getActivityId, activityId) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+                .eq(ActivityRegistration::getUserId, userId) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+                .count() > 0; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     @Override 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -237,7 +243,7 @@ public class ActivityPlanServiceImpl extends ServiceImpl<ActivityPlanDao, Activi 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         checkActivityPay(activityEvaluation.getActivityId()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if (!checkoutJoinActivity(activityEvaluation.getActivityId(),user.getId())) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        if (!checkoutJoinActivity(activityEvaluation.getActivityId(), user.getId())) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             ActivityPlan activityPlan = this.getById(activityEvaluation.getActivityId()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             if (RegistrationMethodEnum.FREE.equals(activityPlan.getRegistrationMethod())) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -256,7 +262,7 @@ public class ActivityPlanServiceImpl extends ServiceImpl<ActivityPlanDao, Activi 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        List<Long> joinEvaluationIdList = activityEvaluationRecordService.getJoinEvaluationIdList(activityEvaluation.getActivityId(),user.getId()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        List<Long> joinEvaluationIdList = activityEvaluationRecordService.getJoinEvaluationIdList(activityEvaluation.getActivityId(), user.getId()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         // 保存参与活动项目记录 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         if (CollectionUtils.isEmpty(joinEvaluationIdList)) { 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -283,17 +289,17 @@ public class ActivityPlanServiceImpl extends ServiceImpl<ActivityPlanDao, Activi 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         if (activityPlan.getActivityState() == 0) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             throw new BizException("活动已停止"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if (new Date().compareTo(activityPlan.getActivityStart()) <0) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-            throw  new BizException("活动未开始"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        if (new Date().compareTo(activityPlan.getActivityStart()) < 0) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+            throw new BizException("活动未开始"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if (new Date().compareTo(activityPlan.getActivityEnd()) >0) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        if (new Date().compareTo(activityPlan.getActivityEnd()) > 0) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             throw new BizException("活动已结束"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     private SysUser getSysUser(Long userId) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         return Optional.ofNullable(userId) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                       .map(sysUserFeignService::queryUserById) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-                       .orElseThrow(() -> new BizException("用户不存在")); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+                .map(sysUserFeignService::queryUserById) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+                .orElseThrow(() -> new BizException("用户不存在")); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 } 
			 |