diff --git a/mq2kb/src/main/java/com/shunzhi/mqtt2kanban/ApplicationRunnerImpl.java b/mq2kb/src/main/java/com/shunzhi/mqtt2kanban/ApplicationRunnerImpl.java
index cbbba6c..7a7b59b 100644
--- a/mq2kb/src/main/java/com/shunzhi/mqtt2kanban/ApplicationRunnerImpl.java
+++ b/mq2kb/src/main/java/com/shunzhi/mqtt2kanban/ApplicationRunnerImpl.java
@@ -104,6 +104,7 @@ public class ApplicationRunnerImpl implements ApplicationRunner {
             });
             try {
                 mqttClient.connect(connOpts);
+                sendMq();
             } catch (MqttException e) {
                 System.out.println("mqtt:" + e.toString());
                 e.printStackTrace();
@@ -120,6 +121,23 @@ public class ApplicationRunnerImpl implements ApplicationRunner {
         }
     }
 
+    private void sendMq() {
+        String recvClientId = groupId + "@@@09EA8EB5142F2964";
+        final String p2pSendTopic = topic + "/p2p/" + recvClientId;
+        String content = "{\"cmd\":\"37\",\"clientId\":\"\",\"data\": \"6:00-22:00\"}";
+        MqttMessage message = new MqttMessage(content.getBytes());
+        message.setQos(qosLevel);
+        System.out.println("发送内容:" + p2pSendTopic);
+        if (null != mqttClient) {
+            try {
+                mqttClient.publish(p2pSendTopic, message);
+            } catch (MqttException e) {
+                e.printStackTrace();
+            }
+        }
+
+    }
+
 
     /**
      * @param equipmentSN 控制器SN号
diff --git a/mq2kb/src/main/java/com/shunzhi/mqtt2kanban/Mqtt2kanbanApplication.java b/mq2kb/src/main/java/com/shunzhi/mqtt2kanban/Mqtt2kanbanApplication.java
index c370fa5..8609265 100644
--- a/mq2kb/src/main/java/com/shunzhi/mqtt2kanban/Mqtt2kanbanApplication.java
+++ b/mq2kb/src/main/java/com/shunzhi/mqtt2kanban/Mqtt2kanbanApplication.java
@@ -22,7 +22,6 @@ public class Mqtt2kanbanApplication {
     }
 
     private String indexPath = "C:\\index.txt";//存放当前取数的记录
-
     private String devicePath = "C:\\Users\\Administrator\\Desktop\\device.txt";//存放设备id的路径
     public static void main(String[] args) {
         SpringApplication.run(Mqtt2kanbanApplication.class, args);
diff --git a/mq2kb/src/main/java/com/shunzhi/mqtt2kanban/utils/ScheduledTasks.java b/mq2kb/src/main/java/com/shunzhi/mqtt2kanban/utils/ScheduledTasks.java
index d5682be..55ac2bc 100644
--- a/mq2kb/src/main/java/com/shunzhi/mqtt2kanban/utils/ScheduledTasks.java
+++ b/mq2kb/src/main/java/com/shunzhi/mqtt2kanban/utils/ScheduledTasks.java
@@ -55,7 +55,7 @@ public class ScheduledTasks {
 
 
     //每隔5秒取一次数据
-    @Scheduled(fixedDelay = 2000)
+    @Scheduled(fixedDelay = 200000)
     public void reportCurrentTime() {
         System.out.println("任务调度:" + new SimpleDateFormat("HH:mm:ss").format(new Date()));
         try {
@@ -63,8 +63,7 @@ public class ScheduledTasks {
             if (ApplicationRunnerImpl.isConnect) //MQ是否连接
                 getVaild();
 
-            readImgs();
-            //        getUser();
+//            readImgs();
         } catch (Exception e) {
             getVaild();
             System.out.println("eeeeeeee:" + e.toString());
diff --git a/mq2kb/src/main/resources/application.properties b/mq2kb/src/main/resources/application.properties
index ce3e281..7cc6adf 100644
--- a/mq2kb/src/main/resources/application.properties
+++ b/mq2kb/src/main/resources/application.properties
@@ -1,8 +1,8 @@
 server.port=10086
 
-spring.datasource.url=jdbc:mysql://10.1.16.3:3307/jcacardone?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
-spring.datasource.username=thd
-spring.datasource.password=654321
+spring.datasource.url=jdbc:mysql://localhost:3307/jcacardone?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
+spring.datasource.username=root
+spring.datasource.password=123456
 #spring.datasource.url=jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
 #spring.datasource.username=root
 #spring.datasource.password=123456
--
libgit2 0.21.0