| 
						
						
							
								
							
						
						
					 | 
					@ -14,6 +14,7 @@ import com.epmet.constant.SystemMessageType; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.dto.extract.form.ExtractOriginFormDTO; | 
					 | 
					 | 
					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.service.evaluationindex.screen.ScreenProjectDataService; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import com.epmet.util.DimIdGenerator; | 
					 | 
					 | 
					import com.epmet.util.DimIdGenerator; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import lombok.extern.slf4j.Slf4j; | 
					 | 
					 | 
					import lombok.extern.slf4j.Slf4j; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					import org.apache.commons.lang3.StringUtils; | 
					 | 
					 | 
					import org.apache.commons.lang3.StringUtils; | 
				
			
			
		
	
	
		
		
			
				
					| 
						
							
								
							
						
						
							
								
							
						
						
					 | 
					@ -160,7 +161,7 @@ public class ProjectChangedCustomListener implements MessageListenerConcurrently | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					                type = SystemMessageType.PROJECT_EDIT; | 
					 | 
					 | 
					                type = SystemMessageType.PROJECT_EDIT; | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            } | 
					 | 
					 | 
					            } | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            DisputeProcessMQMsg msg = new DisputeProcessMQMsg(customerId, msgObj.getProjectId(), type); | 
					 | 
					 | 
					            DisputeProcessMQMsg msg = new DisputeProcessMQMsg(customerId, msgObj.getProjectId(), type); | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					            //SpringContextUtils.getBean(ScreenProjectDataService.class).sendProjectChangeMq(msg);
 | 
					 | 
					 | 
					            SpringContextUtils.getBean(ScreenProjectDataService.class).sendProjectChangeMq(msg); | 
				
			
			
				
				
			
		
	
		
		
	
		
		
			
				
					 | 
					 | 
					        } catch (RenException e) { | 
					 | 
					 | 
					        } catch (RenException e) { | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            // 如果是我们手动抛出的异常,说明在业务可控范围内。目前不需要MQ重试
 | 
					 | 
					 | 
					            // 如果是我们手动抛出的异常,说明在业务可控范围内。目前不需要MQ重试
 | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            logger.error("【RocketMQ】消费项目变动消息失败:",e); | 
					 | 
					 | 
					            logger.error("【RocketMQ】消费项目变动消息失败:",e); | 
				
			
			
		
	
	
		
		
			
				
					| 
						
							
								
							
						
						
						
					 | 
					
  |