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.