From 6ae2d94d9c57ad162649cb610801553d3829fff4 Mon Sep 17 00:00:00 2001
From: Cruyse <742557672@163.com>
Date: Tue, 6 May 2025 10:22:03 +0800
Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E5=BA=86=E7=83=AD=E7=BA=BF-=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E4=BA=A4=E6=8D=A2=E5=8A=9F=E8=83=BD=E6=94=B9=E9=80=A0?=
 =?UTF-8?q?-=E7=9F=A5=E8=AF=86=E4=B8=8A=E6=8A=A5=E8=AF=B7=E6=B1=82?=
 =?UTF-8?q?=E4=BD=93=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ruoyi/business/controller/InBusinessController.java  | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/ruoyi-modules/ruoyi-system-dataexchange/src/main/java/com/ruoyi/business/controller/InBusinessController.java b/ruoyi-modules/ruoyi-system-dataexchange/src/main/java/com/ruoyi/business/controller/InBusinessController.java
index 5bf7693..4a7076e 100644
--- a/ruoyi-modules/ruoyi-system-dataexchange/src/main/java/com/ruoyi/business/controller/InBusinessController.java
+++ b/ruoyi-modules/ruoyi-system-dataexchange/src/main/java/com/ruoyi/business/controller/InBusinessController.java
@@ -134,6 +134,7 @@ public class InBusinessController {
 
         // 获取remark信息
         String urlSuffix = "";
+        String reqBody = "";
         JSONObject remarkJson = null;
         if (serviceBusiness.getRemark() != null) {
             try {
@@ -141,6 +142,10 @@ public class InBusinessController {
                 remarkJson = JSONObject.parseObject(serviceBusiness.getRemark());
                 // 提取 url 字段
                 urlSuffix = remarkJson.getString("url");
+                reqBody = remarkJson.getString("body");
+                if (StringUtils.isEmpty(reqBody)) {
+                    reqBody = "recordInfo";
+                }
             } catch (Exception e) {
                 logger.error("解析 remark 字段失败", e);
                 return AjaxResult.error("解析 remark 字段失败");
@@ -148,6 +153,8 @@ public class InBusinessController {
         }
         // 新增final副本用于lambda
         final String finalUrlSuffix = urlSuffix;
+        // 新增final副本用于lambda
+        final String finalReqBody = reqBody;
         // 分批处理逻辑
         int batchSize = 50;
         List<List<?>> batches = new ArrayList<>();
@@ -170,7 +177,7 @@ public class InBusinessController {
             futures.add(executor.submit(() -> {
                 try {
                     Map<String, Object> reqMap = new HashMap<>();
-                    reqMap.put("recordInfo", batch);
+                    reqMap.put(finalReqBody, batch);
 
                     TransportRequest request = buildRequest(ipcType, reqMap, finalToken);
                     logger.info("线程[{}] 请求报文:\n{}", Thread.currentThread().getId(), gson.toJson(request));