优化

tongfei_river_data_collection/src/main/java/com/ublinkage/datacollection/service/QxybDataCollectionTask.java

@@ -309,11 +309,13 @@ public class QxybDataCollectionTask implements InitializingBean {
                     log.error("e:{}", e.getMessage());
                 }
                 try {
+                    LocalDateTime st24=LocalDateTime.of(publishTime.getYear(), publishTime.getMonthValue(), publishTime.getDayOfMonth(), 0, 0, 0).plusDays(1);
                     //24小时雨量
                     for (int i = 0; i <= duration / 24; i++) {
                         int hour = 24;
                         String content = "precipitation";
-                        LocalDateTime dateTime = st.plusDays(i);
+                        LocalDateTime dateTime = st24.plusDays(i);
+
                         String dt1 = dateTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd_HH_mm_ss"));
                         String dt2 = dateTime.plusHours(hour).format(DateTimeFormatter.ofPattern("yyyy-MM-dd_HH_mm_ss"));
                         String result = HttpUtil.get("http://111.198.2.202:6657/getForecastMatrixByWrfRDField?RDField=" + RDField + "&publishDT=" + publishInfo.getPublishDT() + "&ensemble=" + publishInfo.getEnsemble() + "&domain=" + domain + "&content=" + content + "&DT1=" + dt1 + "&DT2=" + dt2 + "&step=" + hour);

tongfei_river_data_collection/src/main/resources/application.properties

@@ -8,8 +8,8 @@ download.file.path=/Users/ocean/Downloads/qxyb/
 
 
 
-yb.startTime=2022_12_15_00_00_00
-yb.endTime=2022_12_16_00_00_00
+yb.startTime=2022_12_29_00_00_00
+yb.endTime=2022_12_30_00_00_00
 
 yb.fixedTime=false
 

tongfei_river_data_transfer/src/test/java/com/ublinkage/transfer/SimpleTests.java

@@ -2,6 +2,7 @@ package com.ublinkage.transfer;
 
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.io.FileUtil;
+import com.alibaba.fastjson.JSONObject;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.test.context.junit4.SpringRunner;
@@ -19,6 +20,12 @@ public class SimpleTests {
 
 
     }
+    @Test
+    public void test2() {
+        String s = FileUtil.readUtf8String("/Users/ocean/Downloads/errordata/TempSiteData,20221230_12_192,1,mp3_cu3,1672442221057.json");
+        JSONObject object = JSONObject.parseObject(s);
+        System.out.println("打印输出...object的值:"+object);
+    }
 
 
 }