From 28508288126c0ad261ee953db78a33950299e870 Mon Sep 17 00:00:00 2001
From: "review512jwy@163.com" <“review512jwy@163.com”>
Date: Wed, 1 Apr 2026 15:35:50 +0800
Subject: [PATCH] =?UTF-8?q?f10=E8=BD=AC=E5=8F=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../receiver/config/DataCenterEnvConfig.java   |  7 +++++++
 .../receiver/listener/RedisStreamConsumer.java | 18 ++++++++++++++++++
 src/main/resources/application-dev.properties  |  2 +-
 3 files changed, 26 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/techsor/datacenter/receiver/config/DataCenterEnvConfig.java b/src/main/java/com/techsor/datacenter/receiver/config/DataCenterEnvConfig.java
index 53acbee..eb608a9 100644
--- a/src/main/java/com/techsor/datacenter/receiver/config/DataCenterEnvConfig.java
+++ b/src/main/java/com/techsor/datacenter/receiver/config/DataCenterEnvConfig.java
@@ -35,6 +35,9 @@ public class DataCenterEnvConfig {
     @Value("${data.center.zaiot_process.api:#{'/v1/generic/zaiot_process'}}")
     private String zaiotProcessApiUrl;
 
+    @Value("${data.center.f10.api:#{'/v1/generic/f10'}}")
+    private String f10ApiUrl;
+
 
     public String getReceiveUrl() {
         return apiAddress+apiUrl;
@@ -102,4 +105,8 @@ public class DataCenterEnvConfig {
     public String getGW150ProcessUrl() {
         return apiAddress+this.processGW150Url;
     }
+
+    public String getF10ApiUrl() {
+        return apiAddress+f10ApiUrl;
+    }
 }
diff --git a/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java b/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java
index eb1c27c..07cad5d 100644
--- a/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java
+++ b/src/main/java/com/techsor/datacenter/receiver/listener/RedisStreamConsumer.java
@@ -1,11 +1,17 @@
 package com.techsor.datacenter.receiver.listener;
 
+import com.google.gson.Gson;
+import com.techsor.datacenter.receiver.config.DataCenterEnvConfig;
+import com.techsor.datacenter.receiver.utils.DefaultHttpRequestUtil;
+import com.techsor.datacenter.receiver.utils.MyHTTPResponse;
 import jakarta.annotation.PostConstruct;
 import jakarta.annotation.PreDestroy;
+import jakarta.annotation.Resource;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Range;
 import org.springframework.data.redis.connection.stream.*;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Component;
 
@@ -23,6 +29,10 @@ public class RedisStreamConsumer {
 
     @Autowired
     private StringRedisTemplate redisTemplate;
+    @Resource
+    private DefaultHttpRequestUtil defaultHttpRequestUtil;
+    @Resource
+    private DataCenterEnvConfig dataCenterEnvConfig;
 
     private static final int PARTITIONS = 16;
     private static final String STREAM_PREFIX = "aeon_tcp_stream_";
@@ -232,6 +242,14 @@ public class RedisStreamConsumer {
             /**
              * ===== 业务逻辑 =====
              */
+            Gson gson = new Gson();
+            String jsonParams = gson.toJson(body);
+            MyHTTPResponse response = this.defaultHttpRequestUtil.postJson(dataCenterEnvConfig.getF10ApiUrl(), jsonParams);
+            if (response.getCode() == 200) {
+                log.info("F10 data sent successfully....");
+            } else {
+                log.error("F10 data sent failed....");
+            }
 
             success = true;
         } catch (Exception e) {
diff --git a/src/main/resources/application-dev.properties b/src/main/resources/application-dev.properties
index e0ec52d..0a9f446 100644
--- a/src/main/resources/application-dev.properties
+++ b/src/main/resources/application-dev.properties
@@ -66,7 +66,7 @@ spring.redis.lettuce.shutdown-timeout=1000
 
 redis.lock.expire=${redisLockExpire:1000}
 
-data.center.receive.address=${dataCenterReceiverTargetUrl:}
+data.center.receive.address=${dataCenterReceiverTargetUrl:http://localhost:8201}
 data.center.receive.api=/v1/main_receiver
 
 amazon.aws.accesskey=${awsaccesskey:AKIAVRXFMB43XVQ3GXAL}