| 
						
						
							
								
							
						
						
					 | 
					@ -67,7 +67,7 @@ public class ICWarnStatsEventListener implements MessageListenerConcurrently { | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            lock = distributedLock.getLock(String.format("lock:ic_warn_stats:%s", obj.getCustomerId()), | 
					 | 
					 | 
					            lock = distributedLock.getLock(String.format("lock:ic_warn_stats:%s", obj.getCustomerId()), | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					                    30L, 30L, TimeUnit.SECONDS); | 
					 | 
					 | 
					                    30L, 30L, TimeUnit.SECONDS); | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            //待执行方法
 | 
					 | 
					 | 
					            //待执行方法
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					            SpringContextUtils.getBean(StatsResiWarnService.class).resiWarnByOne(obj.getCustomerId(), obj.getIcResiUser()); | 
					 | 
					 | 
					            SpringContextUtils.getBean(StatsResiWarnService.class).resiWarn(obj.getCustomerId()); | 
				
			
			
				
				
			
		
	
		
		
	
		
		
			
				
					 | 
					 | 
					        } catch (RenException e) { | 
					 | 
					 | 
					        } catch (RenException e) { | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            // 如果是我们手动抛出的异常,说明在业务可控范围内。目前不需要MQ重试
 | 
					 | 
					 | 
					            // 如果是我们手动抛出的异常,说明在业务可控范围内。目前不需要MQ重试
 | 
				
			
			
		
	
		
		
			
				
					 | 
					 | 
					            logger.error("【开放数据事件监听器】-客户居民信息变动MQ失败:".concat(ExceptionUtils.getErrorStackTrace(e))); | 
					 | 
					 | 
					            logger.error("【开放数据事件监听器】-客户居民信息变动MQ失败:".concat(ExceptionUtils.getErrorStackTrace(e))); | 
				
			
			
		
	
	
		
		
			
				
					| 
						
							
								
							
						
						
						
					 | 
					
  |