1、断点续传结束消息增加最后时间
This commit is contained in:
parent
33b646d05b
commit
b8722665a5
@ -14,9 +14,13 @@ import java.util.concurrent.TimeUnit;
|
||||
*/
|
||||
@Component(value = "local")
|
||||
public class LocalDeviceServiceImpl implements DeviceService {
|
||||
/*static RemovalListener<String, Device> removalListener = new RemovalListener<String, Device>() {
|
||||
public void onRemoval(RemovalNotification<String, Device> removal) {
|
||||
|
||||
}
|
||||
};*/
|
||||
private static final Cache<String, Device> deviceCache = CacheBuilder.newBuilder().
|
||||
expireAfterWrite(30, TimeUnit.MINUTES).build();
|
||||
expireAfterWrite(90, TimeUnit.MINUTES).build();
|
||||
|
||||
private static final Cache<String, List<Device>> subDeviceCache = CacheBuilder.newBuilder().
|
||||
expireAfterWrite(10, TimeUnit.MINUTES).build();
|
||||
@ -49,9 +53,12 @@ public class LocalDeviceServiceImpl implements DeviceService {
|
||||
}
|
||||
|
||||
public void refresh(String deviceId){
|
||||
Device device = delegate.findByDeviceId(deviceId);
|
||||
Device device = deviceCache.getIfPresent(deviceId);
|
||||
if (device != null) {
|
||||
deviceCache.put(deviceId, device);
|
||||
if(device.getParentId()!=null) {
|
||||
subDeviceCache.invalidate(device.getParentId());
|
||||
}
|
||||
deviceCache.invalidate(deviceId);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user