test/dgiot
1
0
Fork 0
mirror of https://gitee.com/dgiiot/dgiot.git synced 2024-12-02 12:18:30 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

删除通道前，先禁用

Browse Source
This commit is contained in:
Evan You 2022-06-02 17:59:34 +08:00
parent d066a1c2d8
commit 538841cf68
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
apps/dgiot_device/src/dgiot_device_channel.erl
View File

@ -115,6 +115,7 @@ init(?TYPE, ChannelId, Args) ->
dgiot_parse_hook:subscribe(<<"Product">>, post, ChannelId),
dgiot_parse_hook:subscribe(<<"Product/*">>, put, ChannelId),
dgiot_parse_hook:subscribe(<<"Product/*">>, delete, ChannelId),
dgiot_parse_hook:subscribe(<<"Channel/*">>, delete, ChannelId),
{ok, State, []}.
handle_init(State) ->
@ -209,6 +210,15 @@ handle_message({sync_parse, _Pid, 'after', delete, _Token, <<"Product">>, Object
dgiot_product:delete(ObjectId),
{ok, State};
handle_message({sync_parse, _Pid, 'before', delete, _Token, <<"Channel">>, ObjectId}, State) ->
io:format("~s ~p ~p ~n", [?FILE, ?LINE, ObjectId]),
case dgiot_parse:get_object(<<"Channel">>, ObjectId) of
{ok, #{<<"isEnable">> := true}} ->
dgiot_bridge:control_channel(ObjectId, <<"disable">>);
_ -> pass
end,
{ok, State};
handle_message({update_schemas_json}, State) ->
%% 更新表字段
dgiot_parse:update_schemas_json(),