增加设备缓存清除的调用
This commit is contained in:
parent
344b3c600f
commit
c71d8ff8dc
|
@ -13,6 +13,7 @@ import com.isu.gaswellwatch.entity.DeviceOptLog;
|
|||
import com.isu.gaswellwatch.entity.Dictionary;
|
||||
import com.isu.gaswellwatch.entity.GasWell;
|
||||
import com.isu.gaswellwatch.exception.BusinessException;
|
||||
import com.isu.gaswellwatch.modbus.data.CacheService;
|
||||
import com.isu.gaswellwatch.modbus.data.PersistenceHandler;
|
||||
import com.isu.gaswellwatch.modbus.data.Redis2DBPersistenceService;
|
||||
import com.isu.gaswellwatch.modbus.data.listener.DynamicRabbitListener;
|
||||
|
@ -56,6 +57,8 @@ public class DeviceServiceImpl extends ServiceImpl<DeviceDao, Device> implements
|
|||
private DeviceOptLogService deviceOptLogService;
|
||||
@Resource
|
||||
private DynamicRabbitListener dynamicRabbitListener;
|
||||
@Resource
|
||||
private CacheService cacheService;
|
||||
|
||||
@Override
|
||||
public Page<DeviceVO> page(Integer currentPage, Integer pageSize, String gasWellName, String gasStationName, Long deviceTypeId, Long blockId) {
|
||||
|
@ -145,6 +148,10 @@ public class DeviceServiceImpl extends ServiceImpl<DeviceDao, Device> implements
|
|||
this.removeById(id);
|
||||
//解绑气井
|
||||
this.gasWellService.unbindDevice(gasWellId);
|
||||
|
||||
//删除t_data_设备历史数据表 删除缓存和MQ
|
||||
cacheService.cleanDeviceCache(id);
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
|
|
Loading…
Reference in New Issue