gg

.idea/workspace.xml

@@ -5,26 +5,9 @@
   </component>
   <component name="ChangeListManager">
     <list default="true" id="eacd3dd8-1e95-428c-a6af-1aadb9921989" name="Default Changelist" comment="">
-      <change afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/Swagger2.java" afterDir="false" />
-      <change afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/config/CorsConfig.java" afterDir="false" />
-      <change afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/controller/WeatherController.java" afterDir="false" />
-      <change afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/dao/WebServiceCityRepository.java" afterDir="false" />
-      <change afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/dao/WebServiceProvinceRepository.java" afterDir="false" />
-      <change afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/dao/WebServiceWeatherInfoRepository.java" afterDir="false" />
-      <change afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/entity/WebServiceCity.java" afterDir="false" />
-      <change afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/entity/WebServiceProvince.java" afterDir="false" />
-      <change afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/entity/WebServiceWeatherInfo.java" afterDir="false" />
-      <change afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/service/WebServiceWeatherService.java" afterDir="false" />
-      <change afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/service/impl/WebServiceWeatherServiceImpl.java" afterDir="false" />
-      <change afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/task/WebServiceWeatherTask.java" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/.idea/workspace.xml" beforeDir="false" afterPath="$PROJECT_DIR$/.idea/workspace.xml" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/README.md" beforeDir="false" afterPath="$PROJECT_DIR$/README.md" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/pom.xml" beforeDir="false" afterPath="$PROJECT_DIR$/pom.xml" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/MqttRSAClient.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/MqttRSAClient.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/dao/TemperatureRepository.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/dao/TemperatureRepository.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/task/WebServiceWeatherTask.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/task/WebServiceWeatherTask.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/task/AgencyTask.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/task/AgencyTask.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/utils/WebServiceUtils.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/utils/WebServiceUtils.java" afterDir="false" />
-      <change beforePath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/webservice/WebServicePublishConfig.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/com/rehome/mqttclienttemperature/webservice/WebServicePublishConfig.java" afterDir="false" />
       <change beforePath="$PROJECT_DIR$/src/main/resources/application.yml" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/resources/application.yml" afterDir="false" />
     </list>
     <option name="SHOW_DIALOG" value="false" />
@@ -158,6 +141,7 @@
       <workItem from="1744852581603" duration="362000" />
       <workItem from="1744855448002" duration="3224000" />
       <workItem from="1744859279484" duration="19530000" />
+      <workItem from="1744904630034" duration="708000" />
     </task>
     <servers />
   </component>

src/main/java/com/rehome/mqttclienttemperature/MqttRSAClient.java

@@ -107,7 +107,7 @@ public class MqttRSAClient {
                     System.out.println("topic:"+s);
                     System.out.println("Qos:"+mqttMessage.getQos());
                     System.out.println("message RSA:"+strData);
-                    temperatureService.saveTemperature(strData,s);
+                    //temperatureService.saveTemperature(strData,s);
                 }
 
                 @Override

src/main/java/com/rehome/mqttclienttemperature/task/WebServiceWeatherTask.java

@@ -28,7 +28,7 @@ public class WebServiceWeatherTask {
     private WebServiceWeatherService webServiceWeatherService;
 
     //每1小时执行一次,同步省份和城市
-    //@Scheduled(cron = "0 0 0/1 * * ?")
+    //@Scheduled(cron = "0 51 23 * * ?")
     protected void addRfqs() {
         log.info("每1小时执行一次,同步省份和城市，时间：{}", new Date());
         try {
@@ -50,7 +50,7 @@ public class WebServiceWeatherTask {
             List<WebServiceCity> cityList = webServiceWeatherService.findAllCity();
             if(cityList.size()>0){
                 for (WebServiceCity cityItem:cityList) {
-                    Thread.sleep(5000);
+                    Thread.sleep(6000);
                     String[] weatherArray = weatherController.getWeatherByCityCode(cityItem.getCode());
                     if(weatherArray.length>0&&weatherArray.length==23){
                         System.out.println("----------weatherArray-----------");

src/main/resources/application.yml

@@ -9,8 +9,8 @@ spring:
 #    url: jdbc:sqlserver://127.0.0.1:1433;DatabaseName=appserver;encrypt=false;
 #    username: sa
 #    password: Skyinno251,
-    #url: jdbc:mysql://192.168.1.21:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
+    url: jdbc:mysql://192.168.3.29:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
-    url: jdbc:mysql://127.0.0.1:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
+    #url: jdbc:mysql://127.0.0.1:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
     #url: jdbc:mysql://192.168.2.18:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
     #url: jdbc:mysql://192.168.1.24:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true
     #url: jdbc:mysql://192.168.3.7:3306/appserver?useUnicode=true&characterEncoding=utf-8&useSSL=false&autoReconnect=true