Microservice/govern
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

下载优化

Browse Source
This commit is contained in:
xy
2024-09-18 20:06:59 +08:00
parent 73374c6b8d
commit e0d5c3e52c
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/DeviceFtpServiceImpl.java
View File

@@ -68,7 +68,11 @@ public class DeviceFtpServiceImpl implements DeviceFtpService {
redisUtil.delete(AppRedisKey.PROJECT_INFO + nDid); redisUtil.delete(AppRedisKey.PROJECT_INFO + nDid);
// 请求设备文件或目录信息 // 请求设备文件或目录信息
askDeviceDataFeignClient.askDeviceFileOrDir(nDid, name); askDeviceDataFeignClient.askDeviceFileOrDir(nDid, name);
Thread.sleep(3000); if (name.contains("comtrade")) {
Thread.sleep(10000);
} else {
Thread.sleep(5000);
}
// 从 Redis 获取对象 // 从 Redis 获取对象
Object object = redisUtil.getObjectByKey(AppRedisKey.PROJECT_INFO + nDid); Object object = redisUtil.getObjectByKey(AppRedisKey.PROJECT_INFO + nDid);
if (object != null) { if (object != null) {
@@ -100,7 +104,6 @@ public class DeviceFtpServiceImpl implements DeviceFtpService {
try { try {
redisUtil.delete("downloadFilePath:"+name); redisUtil.delete("downloadFilePath:"+name);
boolean file = askDeviceDataFeignClient.downloadFile(nDid,name,size,fileCheck).getData(); boolean file = askDeviceDataFeignClient.downloadFile(nDid,name,size,fileCheck).getData();
Thread.sleep(5000);
if (!file) { if (!file) {
redisUtil.delete("fileDowning:"+nDid); redisUtil.delete("fileDowning:"+nDid);
redisUtil.delete("fileCheck"+name); redisUtil.delete("fileCheck"+name);