9 changed files with 268 additions and 5 deletions
@ -0,0 +1,208 @@ |
|||
package com.zc.business.controller; |
|||
|
|||
import com.ruoyi.common.utils.StringUtils; |
|||
import com.ruoyi.common.utils.spring.SpringUtils; |
|||
import com.ruoyi.system.service.ISysConfigService; |
|||
import com.zc.business.domain.DcWarning; |
|||
import com.zc.business.service.IDcWarningService; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.apache.commons.net.ftp.FTP; |
|||
import org.apache.commons.net.ftp.FTPClient; |
|||
import org.springframework.stereotype.Component; |
|||
|
|||
import java.io.BufferedInputStream; |
|||
import java.io.Closeable; |
|||
import java.io.IOException; |
|||
import java.io.InputStream; |
|||
import java.net.HttpURLConnection; |
|||
import java.net.URI; |
|||
import java.net.URISyntaxException; |
|||
import java.net.URL; |
|||
import java.time.Duration; |
|||
import java.time.LocalDateTime; |
|||
import java.time.format.DateTimeFormatter; |
|||
import java.util.List; |
|||
|
|||
/** |
|||
* |
|||
*/ |
|||
@Component() |
|||
@Slf4j |
|||
public class RadarController { |
|||
ISysConfigService configService = SpringUtils.getBean(ISysConfigService.class); |
|||
IDcWarningService dcWarningService = SpringUtils.getBean(IDcWarningService.class); |
|||
|
|||
public void radarDownload() { |
|||
|
|||
// 获取当前时间
|
|||
LocalDateTime now = LocalDateTime.now(); |
|||
// 定义格式
|
|||
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); |
|||
// 获取当前时间前5分钟的时间点
|
|||
LocalDateTime fifteenMinutesAgo = now.minus(Duration.ofMinutes(5)); |
|||
String FifteenMinutesAgo = fifteenMinutesAgo.format(formatter); |
|||
|
|||
// 获取当前时间前20分钟的时间点
|
|||
LocalDateTime twentyMinutesAgo = now.minus(Duration.ofMinutes(20)); |
|||
String TwentyMinutesAgo = twentyMinutesAgo.format(formatter); |
|||
DcWarning dcWarning = new DcWarning(); |
|||
|
|||
dcWarning.setStartDate(TwentyMinutesAgo); |
|||
dcWarning.setEndDate(FifteenMinutesAgo); |
|||
List<DcWarning> radarList = dcWarningService.radarList(dcWarning); |
|||
radarList.forEach(radar -> { |
|||
if (radar.getId() != null) { |
|||
try { |
|||
//获取雷达事件视频
|
|||
String baseUrl = dcWarningService.getRadarIncidentVideo(radar.getId()); |
|||
// String baseUrl = "http://10.0.11.252:9021/profile/mp4/G35 长清大学城站 内广场_20241108_090235_60.mp4";
|
|||
String ftpServer= configService.selectConfigByKey("FTP-IP");//密钥
|
|||
// int port = 21;
|
|||
int port= Integer.parseInt(configService.selectConfigByKey("FTP-PORT")); |
|||
//ftpuser
|
|||
//String user = "1911390090@qq.com";
|
|||
String username= configService.selectConfigByKey("FTP-USER");//密钥
|
|||
//Dxc123!@#
|
|||
String password= configService.selectConfigByKey("FPT-PASSWORD");//密钥
|
|||
/* String ftpServer = "10.168.71.135"; |
|||
int port = 21; |
|||
String username = "1911390090@qq.com"; |
|||
String password = "989878wxl";*/ |
|||
String[] split = StringUtils.split(baseUrl, "_"); |
|||
// 拼接文件名
|
|||
String fileName = radar.getStakeMark() + "_" + split[1] + "_" + split[2] + "_" + split[3]; |
|||
|
|||
DateTimeFormatter dirFormatter = DateTimeFormatter.ofPattern("yyyyMMdd"); |
|||
DateTimeFormatter hourFormatter = DateTimeFormatter.ofPattern("HH"); |
|||
String datePart = now.format(dirFormatter); |
|||
String hourPart = now.format(hourFormatter); |
|||
//文件路径
|
|||
// String remoteFilePath = "/path/to/remote/directory";
|
|||
String remoteFilePath = "/radar/" + datePart + "/" + hourPart; |
|||
String download = directDownloadToFtp(baseUrl, ftpServer, port, username, password, remoteFilePath, fileName); |
|||
DcWarning dcWarning1 = new DcWarning(); |
|||
dcWarning1.setId(radar.getId()); |
|||
dcWarning1.setRadarUrl(download); |
|||
int i = dcWarningService.updateDcWarning(dcWarning1); |
|||
} catch (Exception e) { |
|||
throw new RuntimeException(e); |
|||
} |
|||
|
|||
} |
|||
}); |
|||
} |
|||
|
|||
|
|||
public static String directDownloadToFtp(String baseUrl, String ftpServer, int port, String user, String pass, String remotePath, String fileName) throws IOException, URISyntaxException, InterruptedException { |
|||
FTPClient ftpClient = new FTPClient(); |
|||
HttpURLConnection httpConn = null; |
|||
InputStream inputStream = null; |
|||
String URL = "https://10.0.111.11/eventAi"; |
|||
try { |
|||
// 空格编码并构建URL
|
|||
String encodedUrl = encodeUriComponent(baseUrl); |
|||
System.out.println("encodedUrl: " + encodedUrl); |
|||
URI uri = new URI(encodedUrl); |
|||
URL url = uri.toURL(); |
|||
// 睡眠3秒钟
|
|||
Thread.sleep(3000); //
|
|||
httpConn = (HttpURLConnection) url.openConnection(); |
|||
int responseCode = httpConn.getResponseCode(); |
|||
|
|||
if (responseCode == HttpURLConnection.HTTP_OK) { |
|||
log.info("成功连接到HTTP服务器"); |
|||
// 连接到FTP服务器
|
|||
ftpClient.connect(ftpServer, port); |
|||
boolean loginResult = ftpClient.login(user, pass); |
|||
if (!loginResult) { |
|||
throw new IOException("FTP登录失败"); |
|||
} |
|||
log.info("成功登录到FTP服务器"); |
|||
// 设置为二进制传输模式和被动模式
|
|||
ftpClient.setFileType(FTP.BINARY_FILE_TYPE); |
|||
ftpClient.enterLocalPassiveMode(); // 使用被动模式
|
|||
// 创建输入流
|
|||
inputStream = new BufferedInputStream(httpConn.getInputStream()); |
|||
|
|||
// 创建远程目录
|
|||
if (!remotePath.isEmpty()) { |
|||
// 将路径拆分为各个部分，逐级创建目录
|
|||
for (String part : remotePath.split("/")) { |
|||
if (!part.isEmpty()) { |
|||
if (!ftpClient.changeWorkingDirectory(part)) { |
|||
if (ftpClient.makeDirectory(part)) { |
|||
log.info("成功创建远程目录: " + part); |
|||
if (!ftpClient.changeWorkingDirectory(part)) { |
|||
log.info("无法切换到新创建的远程目录: " + part); |
|||
} |
|||
} else { |
|||
log.info("无法创建远程目录: " + part); |
|||
} |
|||
} |
|||
} |
|||
} |
|||
// 确认最终工作目录
|
|||
log.info("最终工作目录: " + ftpClient.printWorkingDirectory()); |
|||
} |
|||
// 上传文件到FTP服务器
|
|||
boolean done = ftpClient.storeFile(fileName, inputStream); |
|||
if (done) { |
|||
log.info("文件上传成功"); |
|||
return URL+ftpClient.printWorkingDirectory()+"/" + fileName; |
|||
} else {// 文件上传失败
|
|||
return null; |
|||
} |
|||
} else { |
|||
throw new IOException("无法从HTTP服务器获取文件，响应码：" + responseCode); |
|||
} |
|||
} finally { |
|||
// 关闭资源
|
|||
closeQuietly(inputStream); |
|||
if (httpConn != null) { |
|||
httpConn.disconnect(); |
|||
} |
|||
if (ftpClient.isConnected()) { |
|||
try { |
|||
ftpClient.logout(); |
|||
ftpClient.disconnect(); |
|||
} catch (IOException ignored) { |
|||
} |
|||
} |
|||
} |
|||
} |
|||
|
|||
// 安全关闭流的方法
|
|||
private static void closeQuietly(Closeable closeable) { |
|||
if (closeable != null) { |
|||
try { |
|||
closeable.close(); |
|||
} catch (IOException ignored) { |
|||
} |
|||
} |
|||
} |
|||
|
|||
//
|
|||
|
|||
/* |
|||
private static String encodeUriComponent(String component, java.nio.charset.Charset charset) { |
|||
try { |
|||
return java.net.URLEncoder.encode(component, charset.toString()) |
|||
.replaceAll("\\+", "%20") // 将空格替换为 %20
|
|||
.replaceAll("%2F", "/"); // 保留斜杠
|
|||
} catch (Exception e) { |
|||
throw new RuntimeException(e); |
|||
} |
|||
} |
|||
*/ |
|||
//保留 URL 中的特殊字符如 : / 等
|
|||
private static String encodeUriComponent(String component) { |
|||
try { |
|||
URI uri = new URI(null, null, component, null); |
|||
return uri.toASCIIString(); |
|||
} catch (URISyntaxException e) { |
|||
throw new RuntimeException("URI编码错误", e); |
|||
} |
|||
} |
|||
|
|||
|
|||
} |
|||
Loading…
Reference in new issue