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