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));