diff --git a/backend/src/main/java/com/yfd/platform/qgc_env/wq/controller/EnvWqDataController.java b/backend/src/main/java/com/yfd/platform/qgc_env/wq/controller/EnvWqDataController.java
index 6d0a35b7..f944ba50 100644
--- a/backend/src/main/java/com/yfd/platform/qgc_env/wq/controller/EnvWqDataController.java
+++ b/backend/src/main/java/com/yfd/platform/qgc_env/wq/controller/EnvWqDataController.java
@@ -3,6 +3,7 @@ package com.yfd.platform.qgc_env.wq.controller;
 import com.yfd.platform.common.DataSourceRequest;
 import com.yfd.platform.config.ResponseResult;
 import com.yfd.platform.qgc_base.entity.vo.BatchDeleteAo;
+import com.yfd.platform.qgc_env.wq.entity.vo.WqOperateRequest;
 import com.yfd.platform.qgc_env.wq.service.EnvWqDataService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -59,8 +60,8 @@ public class EnvWqDataController {
 
     @PostMapping("/updateWqRsData")
     @Operation(summary = "修改水质小时数据")
-    public ResponseResult updateWqRsData(@RequestBody Map<String, Object> updateData) {
-        envWqDataService.updateWqRsData(updateData);
+    public ResponseResult updateWqRsData(@RequestBody WqOperateRequest wqOperateRequest) {
+        envWqDataService.updateWqRsData(wqOperateRequest.getUpdateData());
         return ResponseResult.success();
     }
 
diff --git a/backend/src/main/java/com/yfd/platform/qgc_env/wq/entity/vo/WqOperateRequest.java b/backend/src/main/java/com/yfd/platform/qgc_env/wq/entity/vo/WqOperateRequest.java
new file mode 100644
index 00000000..4b7d5050
--- /dev/null
+++ b/backend/src/main/java/com/yfd/platform/qgc_env/wq/entity/vo/WqOperateRequest.java
@@ -0,0 +1,13 @@
+package com.yfd.platform.qgc_env.wq.entity.vo;
+
+import lombok.Data;
+
+import java.util.Map;
+
+@Data
+public class WqOperateRequest {
+
+    private String source;
+
+    private Map<String, Object> updateData;
+}
diff --git a/backend/src/main/java/com/yfd/platform/qgc_env/wt/controller/SdWTMonitorController.java b/backend/src/main/java/com/yfd/platform/qgc_env/wt/controller/SdWTMonitorController.java
index 6dccdf94..f72e1270 100644
--- a/backend/src/main/java/com/yfd/platform/qgc_env/wt/controller/SdWTMonitorController.java
+++ b/backend/src/main/java/com/yfd/platform/qgc_env/wt/controller/SdWTMonitorController.java
@@ -8,6 +8,7 @@ import com.yfd.platform.common.DataSourceResult;
 import com.yfd.platform.common.exception.BizException;
 import com.yfd.platform.config.ResponseResult;
 import com.yfd.platform.qgc_base.entity.vo.BatchDeleteAo;
+import com.yfd.platform.qgc_env.wt.entity.vo.WtOperateRequest;
 import com.yfd.platform.qgc_env.wt.entity.vo.WtrvInfo;
 import com.yfd.platform.qgc_env.wt.entity.vo.WtrvAmendSaveVo;
 import com.yfd.platform.qgc_env.wt.service.*;
@@ -245,8 +246,8 @@ public class SdWTMonitorController {
 
     @PostMapping("/cxDetail/updateWtvtRData")
     @Operation(summary = "修改垂向水温数据")
-    public ResponseResult updateWtvtRData(@RequestBody Map<String, Object> updateData) {
-        sdWtvtRService.updateWtvtRData(updateData);
+    public ResponseResult updateWtvtRData(@RequestBody WtOperateRequest wtOperateRequest) {
+        sdWtvtRService.updateWtvtRData(wtOperateRequest.getUpdateData());
         return ResponseResult.success();
     }
 
diff --git a/backend/src/main/java/com/yfd/platform/qgc_env/wt/entity/vo/WtOperateRequest.java b/backend/src/main/java/com/yfd/platform/qgc_env/wt/entity/vo/WtOperateRequest.java
new file mode 100644
index 00000000..cdddcf9b
--- /dev/null
+++ b/backend/src/main/java/com/yfd/platform/qgc_env/wt/entity/vo/WtOperateRequest.java
@@ -0,0 +1,13 @@
+package com.yfd.platform.qgc_env.wt.entity.vo;
+
+import lombok.Data;
+
+import java.util.Map;
+
+@Data
+public class WtOperateRequest {
+
+    private String source;
+
+    private Map<String, Object> updateData;
+}
diff --git a/backend/src/main/java/com/yfd/platform/qgc_env/zq/controller/ZqMonitorController.java b/backend/src/main/java/com/yfd/platform/qgc_env/zq/controller/ZqMonitorController.java
index 91cd4c78..2e378585 100644
--- a/backend/src/main/java/com/yfd/platform/qgc_env/zq/controller/ZqMonitorController.java
+++ b/backend/src/main/java/com/yfd/platform/qgc_env/zq/controller/ZqMonitorController.java
@@ -3,6 +3,7 @@ package com.yfd.platform.qgc_env.zq.controller;
 import com.yfd.platform.common.DataSourceRequest;
 import com.yfd.platform.config.ResponseResult;
 import com.yfd.platform.qgc_base.entity.vo.BatchDeleteAo;
+import com.yfd.platform.qgc_env.zq.entity.vo.ZqOperateRequest;
 import com.yfd.platform.qgc_env.zq.service.ZqMonitorService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -65,8 +66,8 @@ public class ZqMonitorController {
 
     @PostMapping("/river/updateRiverRData")
     @Operation(summary = "修改流量站小时数据")
-    public ResponseResult updateRiverRData(@RequestBody Map<String, Object> updateData) {
-        zqMonitorService.updateRiverRData(updateData);
+    public ResponseResult updateRiverRData(@RequestBody ZqOperateRequest zqOperateRequest) {
+        zqMonitorService.updateRiverRData(zqOperateRequest.getUpdateData());
         return ResponseResult.success();
     }
 
diff --git a/backend/src/main/java/com/yfd/platform/qgc_env/zq/entity/vo/ZqOperateRequest.java b/backend/src/main/java/com/yfd/platform/qgc_env/zq/entity/vo/ZqOperateRequest.java
new file mode 100644
index 00000000..5073c1e7
--- /dev/null
+++ b/backend/src/main/java/com/yfd/platform/qgc_env/zq/entity/vo/ZqOperateRequest.java
@@ -0,0 +1,13 @@
+package com.yfd.platform.qgc_env.zq.entity.vo;
+
+import lombok.Data;
+
+import java.util.Map;
+
+@Data
+public class ZqOperateRequest {
+
+    private String source;
+
+    private Map<String, Object> updateData;
+}