From 8beb64e310c27cbca52ed7d45fdad96326b79770 Mon Sep 17 00:00:00 2001
From: lroyia <lirh@chinaweal.com.cn>
Date: Tue, 24 Mar 2026 09:52:55 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=8F=82=E6=95=B0=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../org/controller/ImsSyncController.java     | 31 ++++++++++++++++---
 1 file changed, 26 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/chinaweal/aiccs/org/controller/ImsSyncController.java b/src/main/java/com/chinaweal/aiccs/org/controller/ImsSyncController.java
index 0ca7d0d..cb65627 100644
--- a/src/main/java/com/chinaweal/aiccs/org/controller/ImsSyncController.java
+++ b/src/main/java/com/chinaweal/aiccs/org/controller/ImsSyncController.java
@@ -8,10 +8,16 @@ import com.chinaweal.aiccs.org.service.IImsUserService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import org.apache.commons.io.IOUtils;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.*;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.ServletInputStream;
+import javax.servlet.http.HttpServletRequest;
+import java.io.ByteArrayOutputStream;
 
 /**
  * IMS统一身份管理系统数据同步接口
@@ -41,8 +47,15 @@ public class ImsSyncController {
      */
     @PostMapping("/org/orgSynchronous")
     @ApiOperation(value = "机构同步接口", notes = "接收IMS推送的机构数据，支持新增、修改、删除操作")
-    public ImsResultVO orgSynchronous(@RequestBody ImsOrgDTO dto) {
+    public ImsResultVO orgSynchronous(@RequestBody ImsOrgDTO dto, HttpServletRequest request) {
         log.info("IMS机构同步请求: type={}, orgCode={}", dto.getType(), dto.getCode());
+        try (ServletInputStream inputStream = request.getInputStream();
+             ByteArrayOutputStream os = new ByteArrayOutputStream()) {
+            IOUtils.copy(inputStream, os);
+            log.info("IMS机构同步请求body：{}", os);
+        } catch (Exception e) {
+            log.error("IMS机构同步请求参数读取失败", e);
+        }
 
         try {
             boolean result = imsOrgService.syncOrg(dto);
@@ -66,9 +79,17 @@ public class ImsSyncController {
      */
     @PostMapping("/user/userSynchronous")
     @ApiOperation(value = "用户同步接口", notes = "接收IMS推送的用户数据，支持新增、修改、删除操作")
-    public ImsResultVO userSynchronous(@RequestBody ImsUserDTO dto) {
+    public ImsResultVO userSynchronous(@RequestBody ImsUserDTO dto, HttpServletRequest request) {
         log.info("IMS用户同步请求: type={}, userCode={}", dto.getType(), dto.getUsercode());
 
+        try (ServletInputStream inputStream = request.getInputStream();
+             ByteArrayOutputStream os = new ByteArrayOutputStream()) {
+            IOUtils.copy(inputStream, os);
+            log.info("IMS用户同步请求body：{}", os);
+        } catch (Exception e) {
+            log.error("IMS用户同步请求参数读取失败", e);
+        }
+
         try {
             boolean result = imsUserService.syncUser(dto);
             if (result) {