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

fix: device sysnc

Browse Source
This commit is contained in:
jhonliu 2022-05-04 15:51:42 +08:00
parent 1658d5b23c
commit 7388bedd29
1 changed files with 9 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
apps/dgiot_device/src/dgiot_product_hook.erl
View File

@ -21,17 +21,8 @@
-export([post/2, put/2, delete/2]).
post('before', #{<<"objectId">> := ProductId, <<"channel">> := Channel} = QueryData) ->
case QueryData of
#{<<"objectId">> := ProductId, <<"channel">> := Channel} ->
io:format("~s ~p Channel = ~p.~n", [?FILE, ?LINE, Channel]),
TdchannelId = maps:get(<<"tdchannel">>, Channel, <<"">>),
TaskchannelId = maps:get(<<"taskchannel">>, Channel, <<"">>),
Otherchannel = maps:get(<<"otherchannel">>, Channel, []),
dgiot_product:add_product_relation(Otherchannel ++ [TdchannelId] ++ [TaskchannelId], ProductId);
_ ->
pass
end;
post('before', _QueryData) ->
pass;
post('after', #{<<"objectId">> := ProductId, <<"channel">> := Channel} = QueryData) ->
TdchannelId = maps:get(<<"tdchannel">>, Channel, <<"">>),
@ -51,7 +42,8 @@ post('after', #{<<"objectId">> := ProductId, <<"producttemplet">> := #{<<"object
{ok, #{<<"results">> := Views}} when length(Views) > 0 ->
dgiot_product_view:post_batch(Views, ProductId);
_ ->
dgiot_product_knova:post(ProductId)
dgiot_product_knova:post(ProductId),
dgiot_product_amis:post(ProductId)
end;
post(_, _) ->
@ -67,7 +59,7 @@ put('after', #{<<"channel">> := Channel, <<"objectId">> := ProductId}) ->
Otherchannel = maps:get(<<"otherchannel">>, Channel, []),
dgiot_product:add_product_relation(Otherchannel ++ [TdchannelId] ++ [TaskchannelId], ProductId);
put('after', _) ->
put(_, _) ->
pass.
delete('before', _ProductId) ->
@ -86,5 +78,8 @@ delete('after', ProductId) ->
dgiot_product_view:delete_batch(Views);
_ ->
pass
end.
end;
delete(_, _) ->
pass.