From daddb4bfff3af3bb124ee3ea388dca903520270b Mon Sep 17 00:00:00 2001 From: lin <648540858@qq.com> Date: Thu, 20 Nov 2025 17:29:06 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=88=A0=E9=99=A4=E8=BF=87?= =?UTF-8?q?=E6=9C=9F=E6=8E=A8=E6=B5=81=E6=95=B0=E6=8D=AE=E7=9A=84SQL?= =?UTF-8?q?=E5=85=BC=E5=AE=B9=E6=80=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../iot/vmp/streamPush/dao/StreamPushMapper.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/streamPush/dao/StreamPushMapper.java b/src/main/java/com/genersoft/iot/vmp/streamPush/dao/StreamPushMapper.java index 0077d7b65..96664487c 100755 --- a/src/main/java/com/genersoft/iot/vmp/streamPush/dao/StreamPushMapper.java +++ b/src/main/java/com/genersoft/iot/vmp/streamPush/dao/StreamPushMapper.java @@ -158,8 +158,13 @@ public interface StreamPushMapper { ""}) int batchUpdate(List streamPushItemForUpdate); - @Delete(" DELETE FROM wvp_stream_push st " + - " LEFT join wvp_device_channel wdc on wdc.data_type = 2 and st.id = wdc.data_device_id " + - " where wdc.id is null and st.server_id = #{serverId}") + @Delete(" DELETE FROM wvp_stream_push" + + " WHERE server_id = #{serverId}" + + " AND NOT EXISTS (" + + " SELECT 1 " + + " FROM wvp_device_channel wdc " + + " WHERE wdc.data_type = 2 " + + " AND wvp_stream_push.id = wdc.data_device_id" + + " );") void deleteWithoutGBId(@Param("serverId") String serverId); }