diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java
index f49c643..4d1a6f8 100644
--- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java
+++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java
@@ -12,6 +12,7 @@ import org.springframework.beans.factory.InitializingBean;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.io.UnsupportedEncodingException;
 import java.util.HashSet;
 import java.util.Set;
 import java.util.concurrent.BlockingQueue;
@@ -56,9 +57,13 @@ public class SendMysqlSyncDatUtil implements InitializingBean {
     {
         SqlRequest request = new SqlRequest();
         request.setSql(sql);
-        request.setSqlId(sqlId);
-        syncSqlQueue.add(request);
-        System.out.println("syncSqlQueue size = " + syncSqlQueue.size());
+        try {
+            request.setSqlId(Base64.encodeBase64String(sqlId.getBytes("utf-8")));
+            syncSqlQueue.add(request);
+            System.out.println("syncSqlQueue size = " + syncSqlQueue.size());
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
     }