diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/DeviceFtpController.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/DeviceFtpController.java index 67165ff..dc6213b 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/DeviceFtpController.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/controller/equipment/DeviceFtpController.java @@ -79,10 +79,10 @@ public class DeviceFtpController extends BaseController { public HttpResult downloadFile(@RequestParam("nDid") String nDid, @RequestParam("name") String name, @RequestParam("size") Integer size, @RequestParam("fileCheck") String fileCheck){ String methodDescribe = getMethodDescribe("downloadFile"); String result = deviceFtpService.downloadFile(nDid,name,size,fileCheck); + redisUtil.delete("downloadFilePath:"+name); + redisUtil.delete("fileCheck"+name); + redisUtil.delete("fileDowning:"+nDid); if (Objects.isNull(result)) { - redisUtil.delete("downloadFilePath:"+name); - redisUtil.delete("fileCheck"+name); - redisUtil.delete("fileDowning"); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, null, methodDescribe); } else { return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe); diff --git a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/DeviceFtpServiceImpl.java b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/DeviceFtpServiceImpl.java index 67ba226..6fc47aa 100644 --- a/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/DeviceFtpServiceImpl.java +++ b/cs-device/cs-device-boot/src/main/java/com/njcn/csdevice/service/impl/DeviceFtpServiceImpl.java @@ -89,7 +89,7 @@ public class DeviceFtpServiceImpl implements DeviceFtpService { public String downloadFile(String nDid, String name, Integer size, String fileCheck) { String result = null; judgeClientOnline(nDid); - Object task = redisUtil.getObjectByKey("fileDowning"); + Object task = redisUtil.getObjectByKey("fileDowning:"+nDid); if (Objects.nonNull(task)) { throw new BusinessException(AlgorithmResponseEnum.FILE_DOWNLOADING); } @@ -102,7 +102,7 @@ public class DeviceFtpServiceImpl implements DeviceFtpService { boolean file = askDeviceDataFeignClient.downloadFile(nDid,name,size,fileCheck).getData(); Thread.sleep(5000); if (!file) { - redisUtil.delete("fileDowning"); + redisUtil.delete("fileDowning:"+nDid); redisUtil.delete("fileCheck"+name); throw new BusinessException(AlgorithmResponseEnum.FILE_DOWNLOAD_ERROR); } @@ -111,10 +111,10 @@ public class DeviceFtpServiceImpl implements DeviceFtpService { result = (String) object; redisUtil.delete("downloadFilePath:"+name); redisUtil.delete("fileCheck"+name); - redisUtil.delete("fileDowning"); + redisUtil.delete("fileDowning:"+nDid); } } catch (Exception e) { - redisUtil.delete("fileDowning"); + redisUtil.delete("fileDowning:"+nDid); redisUtil.delete("fileCheck"+name); throw new BusinessException(AlgorithmResponseEnum.FILE_DOWNLOADING); }