| 
					
				 | 
			
			
				@@ -3,7 +3,6 @@ package com.fs.statis.service.impl; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.fs.common.core.redis.RedisCache; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.fs.company.cache.ICompanyCacheService; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.fs.statis.StatisticsRedisConstant; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import com.fs.statis.cache.IStatisticsCacheService; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.fs.statis.dto.*; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.fs.statis.mapper.ConsumptionBalanceMapper; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.fs.statis.service.IStatisticsService; 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -12,7 +11,6 @@ import com.fs.store.service.cache.IFsUserCourseCacheService; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.hc.openapi.tool.util.ObjectUtils; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import com.hc.openapi.tool.util.StringUtils; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import org.springframework.beans.factory.annotation.Autowired; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-import org.springframework.scheduling.annotation.Scheduled; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import org.springframework.stereotype.Service; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 import java.math.BigDecimal; 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -42,7 +40,6 @@ public class StatisticsServiceImpl implements IStatisticsService { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     @Override 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Scheduled(cron = "0 0 * * * *") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public void dataOverviewTask() { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         DealerAggregatedDTO dealerAggregatedDTO = this.dealerAggregated(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         ConsumptionBalanceDataDTO consumptionBalanceDataDTO = this.rechargeConsumption(); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -56,12 +53,10 @@ public class StatisticsServiceImpl implements IStatisticsService { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Scheduled(cron = "0 0/15 * * * *") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public void analysisPreviewTask0(){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         analysisPreviewTask(0); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Scheduled(cron = "0 0 1 * * *") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public void analysisPreviewTask1(){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         analysisPreviewTask(0); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         analysisPreviewTask(1); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -124,7 +119,6 @@ public class StatisticsServiceImpl implements IStatisticsService { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Scheduled(cron = "0 0/15 * * * *") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public void watchEndPlayTrendTask0(){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         this.watchEndPlayTrendTask(0); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         this.watchEndPlayTrendTask(1); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -133,7 +127,6 @@ public class StatisticsServiceImpl implements IStatisticsService { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         this.watchEndPlayTrendTask(4); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Scheduled(cron = "0 0 1 * * *") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public void watchEndPlayTrendTask1(){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         this.watchEndPlayTrendTask(1); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         this.watchEndPlayTrendTask(2); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -186,13 +179,11 @@ public class StatisticsServiceImpl implements IStatisticsService { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Scheduled(cron = "0 0/15 * * * *") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public void companyWatchCourseTopTenTask0(){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         companyWatchCourseTopTenTask(0,0); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         companyWatchCourseTopTenTask(0,1); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Scheduled(cron = "0 0 1 * * *") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public void companyWatchCourseTopTenTask1(){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         companyWatchCourseTopTenTask(1,0); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         companyWatchCourseTopTenTask(1,1); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -295,7 +286,6 @@ public class StatisticsServiceImpl implements IStatisticsService { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         redisCache.setCacheObject( String.format("%s::%d::%d::%s", CHARTS_WATCH_TOP_TEN, type,statisticalType,sort), courseStatsDTOS); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Scheduled(cron = "0 0/15 * * * *") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public void watchCourseTopTenTask0(){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         watchCourseTopTenTask(0,0,"DESC"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         watchCourseTopTenTask(0,0,"ASC"); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -310,7 +300,6 @@ public class StatisticsServiceImpl implements IStatisticsService { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         watchCourseTopTenTask(0,3,"ASC"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Scheduled(cron = "0 0 1 * * *") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public void watchCourseTopTenTask1(){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         watchCourseTopTenTask(1,0,"DESC"); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         watchCourseTopTenTask(1,0,"ASC"); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -352,7 +341,6 @@ public class StatisticsServiceImpl implements IStatisticsService { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Scheduled(cron = "0 0/15 * * * *") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public void rewardMoneyTask15Minutes(){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         rewardMoneyTopTenTask(0,0); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         rewardMoneyTopTenTask(0,1); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -361,7 +349,6 @@ public class StatisticsServiceImpl implements IStatisticsService { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    @Scheduled(cron = "0 0 1 * * *") 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     public void rewardMoneyTaskEveryday(){ 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         rewardMoneyTopTenTask(1,0); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         rewardMoneyTopTenTask(1,1); 
			 |