diff --git a/src/main/java/com/docus/server/message/busservice/impl/ZqBusinessServiceImpl.java b/src/main/java/com/docus/server/message/busservice/impl/ZqBusinessServiceImpl.java
index 4ea44c5..a6cfd9f 100644
--- a/src/main/java/com/docus/server/message/busservice/impl/ZqBusinessServiceImpl.java
+++ b/src/main/java/com/docus/server/message/busservice/impl/ZqBusinessServiceImpl.java
@@ -34,6 +34,7 @@ import java.time.LocalDateTime;
 import java.util.Date;
 import java.util.List;
 import java.util.Objects;
+import java.util.concurrent.locks.ReentrantLock;
 
 /**
  * 肇庆业务实现类
@@ -60,8 +61,11 @@ public class ZqBusinessServiceImpl implements ZqBusinessService {
     @Resource
     private IdService idService;
 
+    private final ReentrantLock SUBMIT_LOCK = new ReentrantLock();
+
     @Override
     public MessageResponse recordSubmitHandle(Message message) {
+        SUBMIT_LOCK.lock();
         try {
             CollectTaskConfig.TaskConfig taskConfig = CollectTaskConfig.getTaskConfig("WS_RECORD_SUBMIT");
             if (taskConfig == null || Func.isEmpty(taskConfig.getCollectorIds())) {
@@ -101,11 +105,14 @@ public class ZqBusinessServiceImpl implements ZqBusinessService {
             MessageResponse response = new MessageResponse(ResultCode.FAILED.getCode(), fail("系统错误"));
             response.setRetry(1);
             return response;
+        }finally {
+            SUBMIT_LOCK.unlock();
         }
     }
 
     @Override
     public MessageResponse wsNurseSubmitHandle(Message message) {
+        SUBMIT_LOCK.lock();
         try {
             CollectTaskConfig.TaskConfig taskConfig = CollectTaskConfig.getTaskConfig("WS_NURS_SUBMIT");
             if (taskConfig == null || Func.isEmpty(taskConfig.getCollectorIds())) {
@@ -150,6 +157,8 @@ public class ZqBusinessServiceImpl implements ZqBusinessService {
             MessageResponse response = new MessageResponse(ResultCode.FAILED.getCode(), fail("系统错误"));
             response.setRetry(1);
             return response;
+        }finally {
+            SUBMIT_LOCK.unlock();
         }
     }
 
diff --git a/src/main/java/com/docus/server/message/service/UnifyMessageServiceImpl.java b/src/main/java/com/docus/server/message/service/UnifyMessageServiceImpl.java
index ad057c7..6f5c2fa 100644
--- a/src/main/java/com/docus/server/message/service/UnifyMessageServiceImpl.java
+++ b/src/main/java/com/docus/server/message/service/UnifyMessageServiceImpl.java
@@ -14,7 +14,9 @@ import com.docus.server.message.result.ResultUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import sun.misc.BASE64Encoder;
 
+import java.io.FileInputStream;
 import java.util.Date;
 import java.util.List;
 import java.util.stream.Collectors;
@@ -99,6 +101,24 @@ public class UnifyMessageServiceImpl implements UnifyMessageService {
         return responseLis.get(0).getRespMessage();
     }
 
+    public static void main(String[] args) throws Exception {
+
+
+            String path="F:\\xiamen-jiashi\\pdf\\interface.pdf";
+
+            BASE64Encoder encoder = new BASE64Encoder();
+
+            FileInputStream inputStream2 = new FileInputStream(path);
+            System.out.println(inputStream2.available());
+            byte[] bytes2 = new byte[inputStream2.available()];
+            inputStream2.read(bytes2, 0, inputStream2.available());
+            inputStream2.close();
+            String base642 = encoder.encode(bytes2);
+
+            System.out.println(base642);
+
+
+    }
     private UnifyMessage saveMessage(String method, String message) {
         UnifyMessage unifyMessage = new UnifyMessage();
         unifyMessage.setId(idService.getDateSeq());