| 
						
						
							
								
							
						
						
					 | 
				
				 | 
				
					@ -6,9 +6,7 @@ import com.epmet.commons.tools.utils.HttpClientManager; | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					import com.epmet.commons.tools.utils.Result; | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					import org.apache.logging.log4j.LogManager; | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					import org.apache.logging.log4j.Logger; | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					import org.springframework.stereotype.Component; | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					
 | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					import javax.annotation.PostConstruct; | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					import java.util.ArrayList; | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					import java.util.HashMap; | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					import java.util.List; | 
				
			
			
		
	
	
		
			
				
					| 
						
						
						
							
								
							
						
					 | 
				
				 | 
				
					@ -17,20 +15,21 @@ import java.util.Map; | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					/** | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					 * desc:订阅积分事件 | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					 */ | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					@Component | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					//@Component
 | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					public class MqSubcribeConfig { | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
						private Logger logger = LogManager.getLogger(MqSubcribeConfig.class); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					
 | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
						private String mqServer = "https://epmet-dev.elinkservice.cn/estos/mq-subscriber/subscribe"; | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
						private String token = "1cfcbb5ade1e3202855ee5819983d773"; | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
					
 | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
						@PostConstruct | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
						//todo 由于api订阅报错 暂时通过页面订阅
 | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
						//@PostConstruct
 | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
						private void subscribe() { | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							MqSubscribeFormDTO event = new MqSubscribeFormDTO(); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							event.setBelongAppId("202007161443499985fa2d397436d10356542134c8f008c48"); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							event.setEventClass("epmet_heart"); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							event.setEventTag("active_send_point"); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							String callbackUrl = "http://192.168.1.119/point/callback/sendPoint"; | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							event.setBelongAppId("202007151206522723ab739c43c73afe1e696f88ef4ee45a9"); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							event.setEventClass("test_event_cls_1"); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							event.setEventTag("test_event_1"); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							String callbackUrl = "http://118.190.150.119/testpub/test/post"; | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							//callbackUrl = "";
 | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							event.setCallbackUrl(callbackUrl); | 
				
			
			
		
	
		
			
				
					 | 
					 | 
				
				 | 
				
							List<MqSubscribeFormDTO> subscribeFormDTOList = new ArrayList<>(); | 
				
			
			
		
	
	
		
			
				
					| 
						
							
								
							
						
						
						
					 | 
				
				 | 
				
					
  |