yangzhe
/
gunshi-project-ss
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

数据同步修复

master
cxw 2024-09-29 17:14:55 +08:00
parent 7cb35a2557
commit d56f2c2621
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/com/gunshi/project/xyt/timetask/DataTaskTSG.java
View File

@ -22,6 +22,7 @@ import com.gunshi.project.xyt.service.StRiverRService;
import com.gunshi.project.xyt.service.StRsvrRRealService; import com.gunshi.project.xyt.service.StRsvrRRealService;
import com.gunshi.project.xyt.service.StRsvrRService; import com.gunshi.project.xyt.service.StRsvrRService;
import com.gunshi.project.xyt.util.OkHttpUtil; import com.gunshi.project.xyt.util.OkHttpUtil;
import jakarta.annotation.PostConstruct;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import okhttp3.FormBody; import okhttp3.FormBody;
import okhttp3.OkHttpClient; import okhttp3.OkHttpClient;
@ -56,7 +57,7 @@ import java.util.stream.Collectors;
@EnableScheduling//开启定时任务 @EnableScheduling//开启定时任务
@Component @Component
@Slf4j @Slf4j
@Profile("prod") @Profile("dev")
public class DataTaskTSG { public class DataTaskTSG {
private static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); private static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@ -77,8 +78,8 @@ public class DataTaskTSG {
public static String jcskPathPptnRoute = "/pptn/";// 雨情接口，需拼接源（sh、sw、qx） public static String jcskPathPptnRoute = "/pptn/";// 雨情接口，需拼接源（sh、sw、qx）
public static String jcskPathRrRiverRoute = "/rsvr/";// RR水库水位接口 public static String jcskPathRrRiverRoute = "/river/";// ZZ河道水位接口
public static String jcskPathZzRsvrRoute = "/river/";// ZZ河道水位接口 public static String jcskPathZzRsvrRoute = "/rsvr/";// RR水库水位接口
// 实时雨情 // 实时雨情
@Autowired @Autowired
@ -237,6 +238,7 @@ public class DataTaskTSG {
*/ */
@Async @Async
@Scheduled(fixedRate = 5, timeUnit = TimeUnit.MINUTES) @Scheduled(fixedRate = 5, timeUnit = TimeUnit.MINUTES)
@PostConstruct
public void getRiverData() { public void getRiverData() {
Date now = new Date(); Date now = new Date();
System.out.println("水情历史定时任务，执行时间：" + sdf.format(now)); System.out.println("水情历史定时任务，执行时间：" + sdf.format(now));
@ -272,9 +274,9 @@ public class DataTaskTSG {
stm = calendar.getTime(); stm = calendar.getTime();
String url = jcskPath; String url = jcskPath;
if ("rr".equals(sttp)) { if ("rr".equals(sttp)) {
url += jcskPathRrRiverRoute + source;
} else if ("zz".equals(sttp)) {
url += jcskPathZzRsvrRoute + source; url += jcskPathZzRsvrRoute + source;
} else if ("zz".equals(sttp)) {
url += jcskPathRrRiverRoute + source;
} else { } else {
continue; continue;
} }