| 
						
						
							
								
							
						
						
					 | 
					@ -2,7 +2,6 @@ package com.epmet.mq; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					
 | 
					 | 
					 | 
					
 | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.alibaba.fastjson.JSON; | 
					 | 
					 | 
					import com.alibaba.fastjson.JSON; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.commons.rocketmq.messages.ProjectChangedMQMsg; | 
					 | 
					 | 
					import com.epmet.commons.rocketmq.messages.ProjectChangedMQMsg; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.commons.tools.constant.NumConstant; | 
					 | 
					 | 
					 | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.commons.tools.distributedlock.DistributedLock; | 
					 | 
					 | 
					import com.epmet.commons.tools.distributedlock.DistributedLock; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.commons.tools.exception.RenException; | 
					 | 
					 | 
					import com.epmet.commons.tools.exception.RenException; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.commons.tools.redis.RedisKeys; | 
					 | 
					 | 
					import com.epmet.commons.tools.redis.RedisKeys; | 
				
			
			
		
	
	
		
		
			
				
					| 
						
						
						
							
								
							
						
					 | 
					@ -12,8 +11,6 @@ import com.epmet.dto.extract.form.ExtractOriginFormDTO; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.service.evaluationindex.extract.todata.FactOriginExtractService; | 
					 | 
					 | 
					import com.epmet.service.evaluationindex.extract.todata.FactOriginExtractService; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.service.evaluationindex.extract.toscreen.ScreenExtractService; | 
					 | 
					 | 
					import com.epmet.service.evaluationindex.extract.toscreen.ScreenExtractService; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.util.DimIdGenerator; | 
					 | 
					 | 
					import com.epmet.util.DimIdGenerator; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.google.common.cache.Cache; | 
					 | 
					 | 
					 | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.google.common.cache.CacheBuilder; | 
					 | 
					 | 
					 | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import lombok.extern.slf4j.Slf4j; | 
					 | 
					 | 
					import lombok.extern.slf4j.Slf4j; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import org.apache.commons.lang3.StringUtils; | 
					 | 
					 | 
					import org.apache.commons.lang3.StringUtils; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext; | 
					 | 
					 | 
					import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext; | 
				
			
			
		
	
	
		
		
			
				
					| 
						
						
						
							
								
							
						
					 | 
					@ -23,7 +20,6 @@ import org.apache.rocketmq.common.message.MessageExt; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import org.redisson.api.RLock; | 
					 | 
					 | 
					import org.redisson.api.RLock; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import org.slf4j.Logger; | 
					 | 
					 | 
					import org.slf4j.Logger; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import org.slf4j.LoggerFactory; | 
					 | 
					 | 
					import org.slf4j.LoggerFactory; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import org.springframework.data.redis.core.RedisTemplate; | 
					 | 
					 | 
					 | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					
 | 
					 | 
					 | 
					
 | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import javax.annotation.PreDestroy; | 
					 | 
					 | 
					import javax.annotation.PreDestroy; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import java.util.Date; | 
					 | 
					 | 
					import java.util.Date; | 
				
			
			
		
	
	
		
		
			
				
					| 
						
							
								
							
						
						
							
								
							
						
						
					 | 
					@ -119,11 +115,12 @@ public class ProjectChangedCustomListener implements MessageListenerConcurrently | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            extractOriginFormDTO.setDateId(dateId); | 
					 | 
					 | 
					            extractOriginFormDTO.setDateId(dateId); | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            Future<?> aBoolean = SpringContextUtils.getBean(FactOriginExtractService.class).submitProjectRelationData(extractOriginFormDTO,null); | 
					 | 
					 | 
					            Future<?> aBoolean = SpringContextUtils.getBean(FactOriginExtractService.class).submitProjectRelationData(extractOriginFormDTO,null); | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            try { | 
					 | 
					 | 
					            try { | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					                aBoolean.get(); | 
					 | 
					 | 
					                Object o = aBoolean.get(); | 
				
			
			
				
				
			
		
	
		
		
	
		
		
			
				
					 | 
					 | 
					 | 
					 | 
					 | 
					                log.info("submitProjectRelationData result:{}",o); | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            } catch (InterruptedException e) { | 
					 | 
					 | 
					            } catch (InterruptedException e) { | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					                e.printStackTrace(); | 
					 | 
					 | 
					                log.error("submitProjectRelationData tread InterruptedException",e); | 
				
			
			
				
				
			
		
	
		
		
	
		
		
			
				
					 | 
					 | 
					            } catch (ExecutionException e) { | 
					 | 
					 | 
					            } catch (ExecutionException e) { | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					                e.printStackTrace(); | 
					 | 
					 | 
					                log.error("submitProjectRelationData tread ExecutionException",e); | 
				
			
			
				
				
			
		
	
		
		
	
		
		
			
				
					 | 
					 | 
					            } | 
					 | 
					 | 
					            } | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            if (aBoolean.isDone()){ | 
					 | 
					 | 
					            if (aBoolean.isDone()){ | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					                // 指标库,实时数据只更新:【screen_project_data】
 | 
					 | 
					 | 
					                // 指标库,实时数据只更新:【screen_project_data】
 | 
				
			
			
		
	
	
		
		
			
				
					| 
						
							
								
							
						
						
						
					 | 
					
  |