From 90e17fbce7c3398180df3a4718333acf4b9be7c9 Mon Sep 17 00:00:00 2001 From: anlicheng <244108715@qq.com> Date: Fri, 9 Jan 2026 14:40:58 +0800 Subject: [PATCH] add efka client --- apps/aircon/src/aircon_mqtt_subscriber.erl | 24 ++++++++-------- apps/aircon/src/aircon_sup.erl | 32 +++++++++++----------- 2 files changed, 27 insertions(+), 29 deletions(-) diff --git a/apps/aircon/src/aircon_mqtt_subscriber.erl b/apps/aircon/src/aircon_mqtt_subscriber.erl index 7fbff18..8108959 100644 --- a/apps/aircon/src/aircon_mqtt_subscriber.erl +++ b/apps/aircon/src/aircon_mqtt_subscriber.erl @@ -185,16 +185,14 @@ emqx_opts(ClientSuffix) when is_binary(ClientSuffix) -> -spec dispatch(DeviceMac :: binary(), Message :: binary()) -> no_return(). dispatch(DeviceMac, Message) when is_binary(DeviceMac), is_binary(Message) -> - logger:notice("[mqtt_subscriber] device_mac: ~p, device_uuid not found", [DeviceMac]), - ok. - %case aircon_args:get_device_uuid(DeviceMac) of - % error -> - % logger:notice("[mqtt_subscriber] device_mac: ~p, device_uuid not found", [DeviceMac]); - % {ok, DeviceUUID} -> - % case aircon_device_sup:ensure_device_started(DeviceUUID) of - % {ok, DevicePid} -> - % aircon_device:metric_data(DevicePid, Message); - % {error, Reason} -> - % logger:notice("[mqtt_subscriber] start device get error: ~p", [Reason]) - % end - %end. \ No newline at end of file + case aircon_args:get_device_uuid(DeviceMac) of + error -> + logger:notice("[mqtt_subscriber] device_mac: ~p, device_uuid not found", [DeviceMac]); + {ok, DeviceUUID} -> + case aircon_device_sup:ensure_device_started(DeviceUUID) of + {ok, DevicePid} -> + aircon_device:metric_data(DevicePid, Message); + {error, Reason} -> + logger:notice("[mqtt_subscriber] start device get error: ~p", [Reason]) + end + end. \ No newline at end of file diff --git a/apps/aircon/src/aircon_sup.erl b/apps/aircon/src/aircon_sup.erl index 7b92db6..d45a3f0 100644 --- a/apps/aircon/src/aircon_sup.erl +++ b/apps/aircon/src/aircon_sup.erl @@ -36,23 +36,23 @@ init([]) -> RegisterName = read_service_name(), ChildSpecs = [ - %#{ - % id => 'efka_client', - % start => {'efka_client', start_link, [RegisterName, Host, Port]}, - % restart => permanent, - % shutdown => 2000, - % type => worker, - % modules => ['efka_client'] - %}, + #{ + id => 'efka_client', + start => {'efka_client', start_link, [RegisterName, Host, Port]}, + restart => permanent, + shutdown => 2000, + type => worker, + modules => ['efka_client'] + }, - %#{ - % id => 'aircon_args', - % start => {'aircon_args', start_link, []}, - % restart => permanent, - % shutdown => 2000, - % type => worker, - % modules => ['aircon_args'] - %}, + #{ + id => 'aircon_args', + start => {'aircon_args', start_link, []}, + restart => permanent, + shutdown => 2000, + type => worker, + modules => ['aircon_args'] + }, #{ id => aircon_logger,