From c71d8ff8dc155e12fa7e91b9c278260d23de8c90 Mon Sep 17 00:00:00 2001 From: qinjie <463333974@qq.com> Date: Mon, 9 Dec 2024 16:05:45 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E8=AE=BE=E5=A4=87=E7=BC=93?= =?UTF-8?q?=E5=AD=98=E6=B8=85=E9=99=A4=E7=9A=84=E8=B0=83=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../isu/gaswellwatch/service/impl/DeviceServiceImpl.java | 7 +++++++ 1 file changed, 7 insertions(+) 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