From 2a7b8da24508519bb3d5850c58210e8d9071f321 Mon Sep 17 00:00:00 2001
From: anlicheng <244108715@qq.com>
Date: Sat, 28 Feb 2026 23:44:32 +0800
Subject: [PATCH] fix mysql binlog

---
 apps/sdlan/src/policy/maxwell_redis_channel.erl | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/apps/sdlan/src/policy/maxwell_redis_channel.erl b/apps/sdlan/src/policy/maxwell_redis_channel.erl
index 98af208..87bf5b5 100644
--- a/apps/sdlan/src/policy/maxwell_redis_channel.erl
+++ b/apps/sdlan/src/policy/maxwell_redis_channel.erl
@@ -78,11 +78,11 @@ handle_data(#{<<"database">> := <<"punchnet_v2">>, <<"table">> := <<"identity_po
     identity_policy_ets:update(Data, Old);
 %% 处理rule
 handle_data(#{<<"database">> := <<"punchnet_v2">>, <<"table">> := <<"rule">>, <<"type">> := <<"insert">>, <<"data">> := Data}) ->
-    identity_policy_ets:insert(Data);
+    rule_ets:insert(Data);
 handle_data(#{<<"database">> := <<"punchnet_v2">>, <<"table">> := <<"rule">>, <<"type">> := <<"delete">>, <<"data">> := Data}) ->
-    identity_policy_ets:delete(Data);
+    rule_ets:delete(Data);
 handle_data(#{<<"database">> := <<"punchnet_v2">>, <<"table">> := <<"rule">>, <<"type">> := <<"update">>, <<"data">> := Data, <<"old">> := Old}) ->
-    identity_policy_ets:update(Data, Old);
+    rule_ets:update(Data, Old);
 handle_data(_Json) ->
     ok.