geg-gas/geg-gas-pcitc
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

-----添加事件监听

Browse Source
This commit is contained in:
张福财
2025-12-09 18:04:59 +08:00
parent a6aa52c318
commit 8c9dcae89e
2 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/config/PEventListenerConfig.java
View File

@ -1,6 +1,5 @@
package com.pictc.config; package com.pictc.config;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate; import org.springframework.web.client.RestTemplate;

4
itc-pcitc-dependencies/itc-pcitc-dependencies-service/src/main/java/com/pictc/listener/PEventListenerPublisher.java
View File

@ -38,12 +38,12 @@ public class PEventListenerPublisher {
Set<String> services = TNacosManager.getNotSelfServices(); Set<String> services = TNacosManager.getNotSelfServices();
boolean flag = single?false:true; boolean flag = single?false:true;
if(CollectionUtils.isNotEmpty(services)) { if(CollectionUtils.isNotEmpty(services)) {
HttpHeaders headers = TNacosManager.createNewHeaders();
byte[] bytes = ObjectUtils.toBytes(conetext);
for (String serviceId : services) { for (String serviceId : services) {
try { try {
URI uri = TNacosManager.getServiceURI(serviceId); URI uri = TNacosManager.getServiceURI(serviceId);
if(uri!=null) { if(uri!=null) {
HttpHeaders headers = TNacosManager.createNewHeaders();
byte[] bytes = ObjectUtils.toBytes(conetext);
RequestEntity<byte[]> request = new RequestEntity<byte[]>(bytes,headers,HttpMethod.POST,uri); RequestEntity<byte[]> request = new RequestEntity<byte[]>(bytes,headers,HttpMethod.POST,uri);
ResponseEntity<Boolean> responseEntity = rest.exchange(request,boolean.class); ResponseEntity<Boolean> responseEntity = rest.exchange(request,boolean.class);
if(single && responseEntity.hasBody() && responseEntity.getBody()) { if(single && responseEntity.hasBody() && responseEntity.getBody()) {