From e25b0ba048bc0096beb4f322f2764c8ab18047df Mon Sep 17 00:00:00 2001
From: Antinew <2357729423@qq.com>
Date: Wed, 30 Jul 2025 22:36:27 +0800
Subject: [PATCH] temp

---
 .../appsettings.Development.json              |  3 ++
 src/TrackCenter.Api/skyapm.json               | 30 ----------------
 .../InterfaceForwardService.cs                | 32 +++++++++++++++++
 .../InterfaceRelayUnifyResultDto.cs           | 36 +++++++++++++++++++
 .../TrackCenterApplicationModule.cs           |  7 ++++
 5 files changed, 78 insertions(+), 30 deletions(-)
 delete mode 100644 src/TrackCenter.Api/skyapm.json
 create mode 100644 src/TrackCenter.Application/Track2InterfaceRelay/InterfaceForwardService.cs
 create mode 100644 src/TrackCenter.Application/Track2InterfaceRelay/InterfaceRelayUnifyResultDto.cs

diff --git a/src/TrackCenter.Api/appsettings.Development.json b/src/TrackCenter.Api/appsettings.Development.json
index 604980b5..8d6d24a5 100644
--- a/src/TrackCenter.Api/appsettings.Development.json
+++ b/src/TrackCenter.Api/appsettings.Development.json
@@ -17,5 +17,8 @@
         "Name": "Console"
       }
     ]
+  },
+  "itfx": {
+    "BaseAddress": "http://43.139.210.35:8888/"
   }
 }
diff --git a/src/TrackCenter.Api/skyapm.json b/src/TrackCenter.Api/skyapm.json
deleted file mode 100644
index 92023e4e..00000000
--- a/src/TrackCenter.Api/skyapm.json
+++ /dev/null
@@ -1,30 +0,0 @@
-{
-  "SkyWalking": {
-    "ServiceName": "PackagePlatform",
-    "Namespace": "",
-    "HeaderVersions": [
-      "sw8"
-    ],
-    "Sampling": {
-      "SamplePer3Secs": -1,
-      "Percentage": -1.0
-    },
-    "Logging": {
-      "Level": "Information",
-      "FilePath": "logs\\skyapm-{Date}.log"
-    },
-    "Transport": {
-      "Interval": 3000,
-      "ProtocolVersion": "v8",
-      "QueueSize": 30000,
-      "BatchSize": 3000,
-      "gRPC": {
-        "Servers": "skywalking-skywalking-helm-oap.skywalking:11800",
-        "Timeout": 10000,
-        "ConnectTimeout": 10000,
-        "ReportTimeout": 600000,
-        "Authentication": ""
-      }
-    }
-  }
-}
\ No newline at end of file
diff --git a/src/TrackCenter.Application/Track2InterfaceRelay/InterfaceForwardService.cs b/src/TrackCenter.Application/Track2InterfaceRelay/InterfaceForwardService.cs
new file mode 100644
index 00000000..e75e37cb
--- /dev/null
+++ b/src/TrackCenter.Application/Track2InterfaceRelay/InterfaceForwardService.cs
@@ -0,0 +1,32 @@
+using InterfaceForward.Domain.Shared.Helpers;
+
+namespace TrackCenter.Application.Track2InterfaceRelay;
+
+public class InterfaceForwardService
+{
+    private readonly IHttpClientFactory _httpClientFactory;
+
+    public InterfaceForwardService(IHttpClientFactory httpClientFactory)
+    {
+        _httpClientFactory = httpClientFactory;
+    }
+
+    public async Task<InterfaceRelayUnifyResultDto> BatchForwardThenPushToQueueAsync(
+        string upStreamCode,
+        string serviceProviderCode,
+        List<object> data,
+        string resSubscribeName,
+        string? attach = null,
+        bool isReturnMessage = false)
+    {
+        var client = _httpClientFactory.CreateClient("itfx");
+
+        var body = data.ToJson();
+        var content = new StringContent(body);
+        using var response = await client.PostAsync("InterfaceForward/BatchForwardThenPushToQueue", content);
+
+        var res = await response.Content.ReadAsStringAsync();
+
+        return res.ToObject<InterfaceRelayUnifyResultDto>()!;
+    }
+}
diff --git a/src/TrackCenter.Application/Track2InterfaceRelay/InterfaceRelayUnifyResultDto.cs b/src/TrackCenter.Application/Track2InterfaceRelay/InterfaceRelayUnifyResultDto.cs
new file mode 100644
index 00000000..af29abb0
--- /dev/null
+++ b/src/TrackCenter.Application/Track2InterfaceRelay/InterfaceRelayUnifyResultDto.cs
@@ -0,0 +1,36 @@
+namespace TrackCenter.Application.Track2InterfaceRelay;
+
+[Serializable]
+public class InterfaceRelayUnifyResultDto
+{
+    public InterfaceRelayUnifyResultDto()
+    {
+
+    }
+    public InterfaceRelayUnifyResultDto(bool isSuccess, object data)
+    {
+        this.Code = isSuccess? 200.ToString(): 400.ToString();
+        this.Data = data;
+        this.Msg = isSuccess? "成功": "失败";
+    }
+    public string Code { get; set; }
+
+    public string Msg { get; set; }
+
+    public object Data { get; set; }
+
+    /// <summary>
+    /// 请求Id
+    /// </summary>
+    public Guid RequestId { get; set; }
+
+    /// <summary>
+    /// 原报文
+    /// </summary>
+    public string? OriginalMessage { get; set; }
+
+    /// <summary>
+    /// 附加数据
+    /// </summary>
+    public string? Attach { get; set; }
+}
diff --git a/src/TrackCenter.Application/TrackCenterApplicationModule.cs b/src/TrackCenter.Application/TrackCenterApplicationModule.cs
index 9dbbabef..56c968c0 100644
--- a/src/TrackCenter.Application/TrackCenterApplicationModule.cs
+++ b/src/TrackCenter.Application/TrackCenterApplicationModule.cs
@@ -186,6 +186,13 @@ public class TrackCenterApplicationModule : FakeModule
             o.ShutdownTimeout = TimeSpan.FromSeconds(10);
             o.WorkerCount = 1;
         });
+
+
+        context.Services.AddHttpClient("itfx", client =>
+        {
+            client.Timeout = TimeSpan.FromSeconds(20);
+            client.BaseAddress = new Uri(configuration["itfx:BaseAddress"]!);
+        });
     }
 
     public override void PreConfigureServices(ServiceConfigurationContext context)