diff --git a/service/src/main/java/com/hzya/frame/seeyon/service/ISeeyonExtService.java b/service/src/main/java/com/hzya/frame/seeyon/service/ISeeyonExtService.java
index 25297ba3..bf5d9f35 100644
--- a/service/src/main/java/com/hzya/frame/seeyon/service/ISeeyonExtService.java
+++ b/service/src/main/java/com/hzya/frame/seeyon/service/ISeeyonExtService.java
@@ -29,8 +29,8 @@ public interface ISeeyonExtService {
 
     /**
      * 更新英德赛表单
-     * @param sql
      * @param dataSourceCode
+     * @param sql
      */
-    void updateYdcForm(String sql,String dataSourceCode);
+    void updateYdcForm(String sql);
 }
diff --git a/service/src/main/java/com/hzya/frame/seeyon/service/impl/SeeyonExtServiceImpl.java b/service/src/main/java/com/hzya/frame/seeyon/service/impl/SeeyonExtServiceImpl.java
index becc9732..f5029cf9 100644
--- a/service/src/main/java/com/hzya/frame/seeyon/service/impl/SeeyonExtServiceImpl.java
+++ b/service/src/main/java/com/hzya/frame/seeyon/service/impl/SeeyonExtServiceImpl.java
@@ -151,7 +151,7 @@ public class SeeyonExtServiceImpl implements ISeeyonExtService {
                     if (StrUtil.isNotEmpty(sql)){
                         logger.info("要执行的sql:{}",sql);
                         //不调rest接口了，改成直接更新
-                        updateYdcForm(sql,"ydc_oa_sqlserver");
+                        updateYdcForm(sql);
 //                        String sign = SecureUtil.md5(sql);
 //                        String data = SecureUtil.aes(KEY.getBytes()).encryptHex(sql);
 //                        Map<String, String> headerMap = MapBuilder.<String, String>create(true)
@@ -200,13 +200,13 @@ public class SeeyonExtServiceImpl implements ISeeyonExtService {
      * 更新英德赛表单
      *
      * @param sql
-     * @param dataSourceCode
+     * @param
      */
     @Override
-    @DS("#dataSourceCode")
-    public void updateYdcForm(String sql, String dataSourceCode) {
+    @DS("ydc_oa_sqlserver_test")
+    public void updateYdcForm(String sql) {
         try {
-            executionService.execUpdateSql(sql,dataSourceCode);
+            executionService.execUpdateSql(sql,null);
         } catch (Exception e) {
             throw new RuntimeException(e);
         }