微调
This commit is contained in:
@@ -84,8 +84,8 @@ public class AskDeviceDataServiceImpl implements AskDeviceDataService {
|
||||
public boolean downloadFile(String nDid, String name, Integer size, String fileCheck) {
|
||||
boolean result = true;
|
||||
try {
|
||||
redisUtil.saveByKeyWithExpire("fileDowning:"+nDid,"fileDowning",120L);
|
||||
redisUtil.saveByKeyWithExpire("fileCheck"+nDid+name,fileCheck,120L);
|
||||
redisUtil.saveByKeyWithExpire("fileDowning:"+nDid,"fileDowning",300L);
|
||||
redisUtil.saveByKey("fileCheck"+nDid+name,fileCheck);
|
||||
Object object = getDeviceMid(nDid);
|
||||
if (!Objects.isNull(object)) {
|
||||
mid = (Integer) object;
|
||||
|
||||
@@ -176,8 +176,6 @@ public class FileServiceImpl implements IFileService {
|
||||
csEventLogs.setNowStep(1);
|
||||
csEventLogs.setAllStep(1);
|
||||
csEventLogs.setIsAll(1);
|
||||
//redisUtil.delete(AppRedisKey.FILE_PART_TIME.concat(appFileMessage.getMsg().getName()));
|
||||
//redisUtil.delete(AppRedisKey.RMQ_FILE_CONSUME_KEY.concat(fileName));
|
||||
//存储文件信息
|
||||
fileStreamDto.setTotal(appFileMessage.getMsg().getFrameTotal());
|
||||
fileStreamDto.setNDid(appFileMessage.getId());
|
||||
@@ -235,9 +233,6 @@ public class FileServiceImpl implements IFileService {
|
||||
if (file.exists()) {
|
||||
file.delete();
|
||||
}
|
||||
//redisUtil.delete(AppRedisKey.FILE_PART_TIME.concat(appFileMessage.getMsg().getName()));
|
||||
//redisUtil.delete(AppRedisKey.RMQ_FILE_CONSUME_KEY.concat(fileName));
|
||||
//redisUtil.delete(AppRedisKey.FILE_DOWN_TIME.concat(appFileMessage.getMsg().getName()));
|
||||
//针对补召文件
|
||||
String key = AppRedisKey.MAKE_UP_FILES + appFileMessage.getId();
|
||||
Object object = redisUtil.getObjectByKey(key);
|
||||
|
||||
Reference in New Issue
Block a user