remove unused code

apps/iot/src/iot_device.erl

@@ -122,5 +122,4 @@ report_event(DeviceUUID, NewStatus) when is_binary(DeviceUUID), is_integer(NewSt
         <<"name">> => <<"设备状态"/utf8>>,
         <<"timestamp">> => Timestamp
     }],
-    iot_router:route_uuid(DeviceUUID, FieldsList, Timestamp),
     lager:debug("[iot_device] device_uuid: ~p, route fields: ~p", [DeviceUUID, FieldsList]).

apps/iot/src/iot_host.erl

@@ -481,8 +481,6 @@ report_event(UUID, NewStatus) when is_binary(UUID), is_integer(NewStatus) ->
         <<"name">> => <<"主机状态"/utf8>>,
         <<"timestamp">> => Timestamp
     }],
-    %% todo 这里需要实现新的机制
-    % iot_router:route_uuid(UUID, FieldsList, Timestamp),
     lager:debug("[iot_host] host_uuid: ~p, route fields: ~p", [UUID, FieldsList]).
 
 %% 将当前的state转换成map

apps/iot/src/iot_router.erl

@@ -1,26 +0,0 @@
-%%%-------------------------------------------------------------------
-%%% @author aresei
-%%% @copyright (C) 2023, <COMPANY>
-%%% @doc
-%%%
-%%% @end
-%%% Created : 04. 7月 2023 11:30
-%%%-------------------------------------------------------------------
--module(iot_router).
--author("aresei").
--include("iot.hrl").
-
-%% API
--export([route_uuid/3]).
-
--spec route_uuid(RouterUUID :: binary(), Fields :: list(), Timestamp :: integer()) -> no_return().
-route_uuid(RouterUUID, Fields, Timestamp) when is_binary(RouterUUID), is_list(Fields), is_integer(Timestamp) ->
-    %% 查找终端设备对应的点位信息
-    case redis_client:hget(RouterUUID, <<"location_code">>) of
-        {ok, undefined} ->
-            lager:warning("[iot_host] the north_data hget location_code, uuid: ~p, not found, fields: ~p", [RouterUUID, Fields]);
-        {ok, LocationCode} when is_binary(LocationCode) ->
-            iot_zd_endpoint:forward(LocationCode, Fields, Timestamp);
-        {error, Reason} ->
-            lager:warning("[iot_host] the north_data hget location_code uuid: ~p, get error: ~p, fields: ~p", [RouterUUID, Reason, Fields])
-    end.

apps/iot/src/mocker/iot_mock.erl

@@ -13,7 +13,7 @@
 %% API
 -export([rsa_encode/1]).
 -export([insert_services/1]).
--export([test_mqtt/0, test_influxdb/0]).
+-export([test_influxdb/0]).
 
 test_influxdb() ->
     UUID = <<"device123123">>,
@@ -29,13 +29,6 @@ test_influxdb() ->
                                          end)
                   end, lists:seq(1, 100)).
 
-test_mqtt() ->
-    iot_zd_endpoint:forward(<<"location_code_test123">>, [
-        #{<<"key">> => <<"name">>, <<"value">> => <<"anlicheng">>},
-        #{<<"key">> => <<"age">>, <<"value">> => 30},
-        #{<<"key">> => <<"flow">>, <<"value">> => 30}
-    ], iot_util:timestamp_of_seconds()).
-
 insert_services(Num) ->
     lists:foreach(fun(Id) ->
         Res = mysql_pool:insert(mysql_iot, <<"micro_service">>,