anlicheng/iot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
anlicheng 2023-08-09 16:35:42 +08:00
parent a44c898c4f
commit b0440db7f5
1 changed files with 12 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
apps/iot/src/iot_host.erl
View File

@ -168,21 +168,22 @@ handle_event({call, From}, {rsa_encode, CommandType, PlainText}, session, State
handle_event({call, From}, {rsa_encode, _, _}, _, State) -> handle_event({call, From}, {rsa_encode, _, _}, _, State) ->
{keep_state, State, [{reply, From, {error, <<"会话未建立"/utf8>>}}]}; {keep_state, State, [{reply, From, {error, <<"会话未建立"/utf8>>}}]};
%% 发送普通格式的消息 %% 发送普通格式的消息, 激活的时候，会话时创建不成功的
handle_event({call, From}, {publish_message, ReceiverPid, CommandType, Command}, session, State = #state{aes = AES, channel_pid = ChannelPid}) -> handle_event({call, From}, {publish_message, ReceiverPid, CommandType, {aes, Command0}}, session, State = #state{aes = AES, channel_pid = ChannelPid}) ->
SendCommand = case Command of Command = iot_cipher_aes:encrypt(AES, Command0),
{aes, Command0} ->
iot_cipher_aes:encrypt(AES, Command0);
Command0 ->
Command0
end,
%% 通过websocket发送请求 %% 通过websocket发送请求
Ref = ws_channel:publish(ChannelPid, ReceiverPid, <<CommandType:8, SendCommand/binary>>), Ref = ws_channel:publish(ChannelPid, ReceiverPid, <<CommandType:8, Command/binary>>),
{keep_state, State, [{reply, From, {ok, Ref}}]}; {keep_state, State, [{reply, From, {ok, Ref}}]};
handle_event({call, From}, {publish_message, ReceiverPid, CommandType, Command}, _, State = #state{channel_pid = ChannelPid}) when is_binary(Command) ->
%% 通过websocket发送请求
Ref = ws_channel:publish(ChannelPid, ReceiverPid, <<CommandType:8, Command/binary>>),
{keep_state, State, [{reply, From, {ok, Ref}}]};
handle_event({call, From}, {publish_message, _, _, _}, _, State) -> handle_event({call, From}, {publish_message, _, _, _}, _, State) ->
{keep_state, State, [{reply, From, {error, <<"会话未建立"/utf8>>}}]}; {keep_state, State, [{reply, From, {error, <<"命令类型错误，发送命令失败"/utf8>>}}]};
handle_event({call, From}, reload, StateName, State = #state{uuid = UUID}) -> handle_event({call, From}, reload, StateName, State = #state{uuid = UUID}) ->
%% 重新加载主机信息 %% 重新加载主机信息