diff --git a/src/main/java/com/isu/gaswellwatch/service/impl/DeviceServiceImpl.java b/src/main/java/com/isu/gaswellwatch/service/impl/DeviceServiceImpl.java index 280179b..890e681 100644 --- a/src/main/java/com/isu/gaswellwatch/service/impl/DeviceServiceImpl.java +++ b/src/main/java/com/isu/gaswellwatch/service/impl/DeviceServiceImpl.java @@ -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 implements private DeviceOptLogService deviceOptLogService; @Resource private DynamicRabbitListener dynamicRabbitListener; + @Resource + private CacheService cacheService; @Override public Page page(Integer currentPage, Integer pageSize, String gasWellName, String gasStationName, Long deviceTypeId, Long blockId) { @@ -145,6 +148,10 @@ public class DeviceServiceImpl extends ServiceImpl implements this.removeById(id); //解绑气井 this.gasWellService.unbindDevice(gasWellId); + + //删除t_data_设备历史数据表 删除缓存和MQ + cacheService.cleanDeviceCache(id); + } @Override