From f6cad359672398b5550c602095535d4f4cf667f1 Mon Sep 17 00:00:00 2001 From: anlicheng <244108715@qq.com> Date: Thu, 21 Aug 2025 17:10:59 +0800 Subject: [PATCH] fix endpoint --- apps/iot/include/endpoint.hrl | 6 +- apps/iot/src/database/endpoint_bo.erl | 35 +- apps/iot/src/endpoint/endpoint_kafka.erl | 21 +- docs/north_data.md | 1213 ---------------------- docs/router.md | 3 - docs/zhongdian_mqtt.md | 58 -- 6 files changed, 31 insertions(+), 1305 deletions(-) delete mode 100644 docs/north_data.md delete mode 100644 docs/router.md delete mode 100644 docs/zhongdian_mqtt.md diff --git a/apps/iot/include/endpoint.hrl b/apps/iot/include/endpoint.hrl index c49830b..5676be8 100644 --- a/apps/iot/include/endpoint.hrl +++ b/apps/iot/include/endpoint.hrl @@ -24,10 +24,8 @@ }). -record(kafka_endpoint, { - enable_sasl = false :: boolean(), - username = <<>> :: binary(), - password = <<>> :: binary(), - mechanism :: atom(), + % {mechanism :: atom(), username = <<>> :: binary(), password = <<>> :: binary()} + sasl_config :: undefined | tuple(), bootstrap_servers = [] :: [{string(), integer()}], topic = <<>> :: binary() }). diff --git a/apps/iot/src/database/endpoint_bo.erl b/apps/iot/src/database/endpoint_bo.erl index 54637c1..2688916 100644 --- a/apps/iot/src/database/endpoint_bo.erl +++ b/apps/iot/src/database/endpoint_bo.erl @@ -60,15 +60,7 @@ parse_config(<<"http">>, #{<<"url">> := Url, <<"pool_size">> := PoolSize}) -> url = Url, pool_size = PoolSize }; -parse_config(<<"kafka">>, #{<<"enable_sasl">> := EnableSasl, <<"username">> := Username, <<"password">> := Password, <<"mechanism">> := Mechanism0, <<"bootstrap_servers">> := BootstrapServers0, <<"topic">> := Topic}) -> - BootstrapServers = lists:filtermap(fun(S) -> - case binary:split(S, <<":">>) of - [Host0, Port0] -> - {true, {binary_to_list(Host0), binary_to_integer(Port0)}}; - _ -> - false - end - end, BootstrapServers0), +parse_config(<<"kafka">>, #{<<"sasl_config">> := #{<<"username">> := Username, <<"password">> := Password, <<"mechanism">> := Mechanism0}, <<"bootstrap_servers">> := BootstrapServers, <<"topic">> := Topic}) -> Mechanism = case Mechanism0 of <<"sha_256">> -> scram_sha_256; @@ -81,12 +73,25 @@ parse_config(<<"kafka">>, #{<<"enable_sasl">> := EnableSasl, <<"username">> := U end, #kafka_endpoint{ - enable_sasl = EnableSasl, - username = Username, - password = Password, - mechanism = Mechanism, - bootstrap_servers = BootstrapServers, + sasl_config = {Mechanism, Username, Password}, + bootstrap_servers = parse_bootstrap_servers(BootstrapServers), + topic = Topic + }; +parse_config(<<"kafka">>, #{<<"bootstrap_servers">> := BootstrapServers, <<"topic">> := Topic}) -> + #kafka_endpoint{ + sasl_config = undefined, + bootstrap_servers = parse_bootstrap_servers(BootstrapServers), topic = Topic }; parse_config(_, _) -> - throw(invalid_config). \ No newline at end of file + throw(invalid_config). + +parse_bootstrap_servers(BootstrapServers) when is_list(BootstrapServers) -> + lists:filtermap(fun(S) -> + case binary:split(S, <<":">>) of + [Host0, Port0] -> + {true, {binary_to_list(Host0), binary_to_integer(Port0)}}; + _ -> + false + end + end, BootstrapServers). \ No newline at end of file diff --git a/apps/iot/src/endpoint/endpoint_kafka.erl b/apps/iot/src/endpoint/endpoint_kafka.erl index d77b024..273b866 100644 --- a/apps/iot/src/endpoint/endpoint_kafka.erl +++ b/apps/iot/src/endpoint/endpoint_kafka.erl @@ -92,23 +92,20 @@ handle_cast({forward, ServiceId, Metric}, State = #state{buffer = Buffer}) -> {noreply, NewState :: #state{}, timeout() | hibernate} | {stop, Reason :: term(), NewState :: #state{}}). handle_info({timeout, _, connect}, State = #state{buffer = Buffer, status = ?DISCONNECTED, client_id = ClientId, - endpoint = #endpoint{title = Title, config = #kafka_endpoint{enable_sasl = EnableSasl, username = Username, password = Password, mechanism = Mechanism, bootstrap_servers = BootstrapServers, topic = Topic}}}) -> + endpoint = #endpoint{title = Title, config = #kafka_endpoint{sasl_config = SaslConfig, bootstrap_servers = BootstrapServers, topic = Topic}}}) -> lager:debug("[endpoint_kafka] endpoint: ~p, create postman", [Title]), - ClientConfig0 = [ + BaseConfig = [ {reconnect_cool_down_seconds, 5}, - {socket_options, [ - {keepalive, true} - ]} + {socket_options, [{keepalive, true}]} ], - ClientConfig = case EnableSasl of - true -> - SaslConfig = {sasl, {Mechanism, Username, Password}}, - [SaslConfig|ClientConfig0]; - false -> - ClientConfig0 - end, + ClientConfig = case SaslConfig of + {Mechanism, Username, Password} -> + [{sasl, {Mechanism, Username, Password}}|BaseConfig]; + undefined -> + BaseConfig + end, case brod:start_link_client(BootstrapServers, ClientId, ClientConfig) of {ok, ClientPid} -> diff --git a/docs/north_data.md b/docs/north_data.md deleted file mode 100644 index 014e1f4..0000000 --- a/docs/north_data.md +++ /dev/null @@ -1,1213 +0,0 @@ -# 概念说明 - 遥测为AI；遥信为DI；事件为SOE。其中AI和DI我可以实现数据的展示，SOE只能报警显示无法实现画面的二次应用。对于智慧照明，开关灯定义为SOE，我后台这边只存在一条事件 - - -# 水表 - -## 流量累计值(数据) -```text - { - "key": "flow", - "value": float, - "type": "AI", - "unit": 44, (立方米) - "label": "m3" - "name": "流量", - "timestamp": int(10) - } -``` - -# 电表 - -## 正向有功总电能(数据) - -```text - { - "key": " positive_power", - "value": float, - "type": "AI", - "unit": 5, - "label": "kwh" - "name": "正向有功总电能", - "timestamp": int(10) - } -``` - -## A相电压(数据) - -```text - { - "key": "voltage_A", - "value": float, - "type": "AI", - "unit": 0, - "label": "V" - "name": "A相电压", - "timestamp": int(10) - } -``` - -## 设备状态变化 - -```text - -{ - "key": "device_status", - "value": NewStatus, 0: 离线， 1: 在线 - "unit": 0, - "type": <<"DI">>, - "name": "设备状态", - "timestamp": int(10) -} - -``` - - -## 边缘主机设备状态变化 - -```text - -{ - "key": "host_status", - "value": NewStatus, 0: 离线， 1: 在线 - "unit": 0, - "type": <<"DI">>, - "name": "主机状态", - "timestamp": int(10) -} - -``` - - -# 智慧照明 - -## 总能耗(数据) - -```text - { - "key": "total_power", - "value": float, - "type": "AI", - "unit": 2, - "name": "总能耗", - "label": "W.h", - "timestamp": int(10) - } -``` - -## 总运行时间(数据) - -```text - { - "key": "total_runtime", - "value": float, - "type": "AI", - "unit": 0, - "name": "总运行时间", - "label": "h", - "timestamp": int(10) - } -``` - -## 实时功率(数据) - -```text - { - "key": "actual_power", - "value": float, - "type": "AI", - "unit": 18, - "name": "实时功率", - "label": "W", - "timestamp": int(10) - } -``` - -## 使用次数(数据) - -```text - { - "key": "use_times", - "value": int, - "type": "AI", - "unit": 0, - "name": "使用次数", - "label": "次", - "timestamp": int(10) - } -``` - -## 灯开关(事件) -```text - { - "key": "light_switch", - "value": bool, 1: 开，0: 关 - "type": "DI", - "unit": 0, - "name": "开关", - "timestamp": int(10) - } -``` - -## 亮度变化(事件) - -```text - { - "key": "light_brightness", - "value": int, 范围: 0 ~ 100 - "type": "SOE", - "unit": 0, - "name": "亮度", - "timestamp": int(10) - } -``` - -## 变亮变暗时间(事件) - -```text - { - "key": "light_change_time", - "value": int, 范围: 1 ~ 200 - "type": "SOE", - "unit": 0, - "name": "变亮变暗时间", - "timestamp": int(10) - } -``` - -## 色温(事件) - -```text - { - "key": "light_rgb", - "value": int, - "type": "SOE", - "unit": 0, - "name": "色温", - "timestamp": int(10) - } -``` - -## RGB (事件) - -```text - { - "key": "light_rgb", - "value": string, - "type": "SOE", - "unit": 0, - "name": "RGB", - "timestamp": int(10) - } -``` - -## 是否损坏(事件) - -```text - { - "key": "light_status", - "value": int, 0: 正常, 1: 不灭, 2: 不亮, 3: 异常波动 - "type": "SOE", - "unit": 0, - "name": "是否损坏", - "timestamp": int(10) - } -``` - -# 施耐德强电 - -## A相相电压 -```text - { - "key":"voltage_a", - "label":"v", - "name":"A相相电压", - "timestamp":1701395303, - "type":"AI", - "unit":0, - "value":9119 - }, -``` - -## B相相电压 -```text - { - "key":"voltage_b", - "label":"v", - "name":"B相相电压", - "timestamp":1701395303, - "type":"AI", - "unit":0, - "value":8815 - }, -``` -## C相相电压 -```text - { - "key":"voltage_c", - "label":"v", - "name":"C相相电压", - "timestamp":1701395303, - "type":"AI", - "unit":0, - "value":422 - }, -``` - -## AB线电压 -```text - { - "key":"voltage_ab", - "label":"v", - "name":"AB线电压", - "timestamp":1701395303, - "type":"AI", - "unit":0, - "value":9119 - }, -``` - -## BC线电压 -```text - { - "key":"voltage_bc", - "label":"v", - "name":"BC线电压", - "timestamp":1701395303, - "type":"AI", - "unit":0, - "value":8815 - }, -``` - -## CA线电压 -```text - { - "key":"voltage_ca", - "label":"v", - "name":"CA线电压", - "timestamp":1701395303, - "type":"AI", - "unit":0, - "value":422 - }, -``` - -## 线电压平均值 -```text - { - "key":"voltage_avg", - "label":"v", - "name":"线电压平均值", - "timestamp":1701395303, - "type":"AI", - "unit":0, - "value":422 - }, -``` - -## A相电流 -```text - { - "key":"currency_a", - "label":"a", - "name":"A相电流", - "timestamp":1701395303, - "type":"AI", - "unit":3, - "value":0 - }, -``` - -## B相电流 -```text - { - "key":"currency_b", - "label":"a", - "name":"B相电流", - "timestamp":1701395303, - "type":"AI", - "unit":3, - "value":11 - }, -``` - -## C相电流 -```text - { - "key":"currency_c", - "label":"a", - "name":"C相电流", - "timestamp":1701395303, - "type":"AI", - "unit":3, - "value":13 - }, -``` - -## 中性线电流 -```text - { - "key":"currency", - "label":"a", - "name":"中性线电流", - "timestamp":1701395303, - "type":"AI", - "unit":3, - "value":13 - }, -``` - -## 频率 -```text - { - "key":"frequency", - "label":"HZ", - "name":"频率", - "timestamp":1701395303, - "type":"AI", - "unit":16, - "value":13 - }, -``` - -## A相有功功率 -```text - { - "key":"p_a", - "label":"kw", - "name":"A相有功功率", - "timestamp":1701395303, - "type":"AI", - "unit":23, - "value":0 - }, -``` - -## B相有功功率 -```text - { - "key":"p_b", - "label":"kw", - "name":"B相有功功率", - "timestamp":1701395303, - "type":"AI", - "unit":23, - "value":90 - }, -``` - -## C相有功功率 -```text - { - "key":"p_c", - "label":"kw", - "name":"C相有功功率", - "timestamp":1701395303, - "type":"AI", - "unit":23, - "value":107 - }, -``` - -## 总有功功率 -```text - { - "key":"p", - "label":"kw", - "name":"总有功功率", - "timestamp":1701395303, - "type":"AI", - "unit":23, - "value":10 - }, -``` - -## A相无功功率 -```text - { - "key":"q_a", - "label":"kvar", - "name":"A相无功功率", - "timestamp":1701395303, - "type":"AI", - "unit":23, - "value":0 - }, -``` - -## B相无功功率 -```text - { - "key":"q_b", - "label":"kvar", - "name":"B相无功功率", - "timestamp":1701395303, - "type":"AI", - "unit":23, - "value":-21 - }, -``` - -## C相无功功率 -```text - { - "key":"q_c", - "label":"kvar", - "name":"C相无功功率", - "timestamp":1701395303, - "type":"AI", - "unit":23, - "value":-10 - }, -``` - -## 总无功功率 -```text - { - "key":"q", - "label":"kvar", - "name":"总无功功率", - "timestamp":1701395303, - "type":"AI", - "unit":23, - "value":20 - }, -``` - -## A相真实功率因数 -```text - - { - "key":"factor_a", - "label":"", - "name":"A相真实功率因数", - "timestamp":1701395303, - "type":"AI", - "unit":16, - "value":-0 - }, -``` - -## B相真实功率因数 -```text - { - "key":"factor_b", - "label":"", - "name":"B相真实功率因数", - "timestamp":1701395303, - "type":"AI", - "unit":16, - "value":0.974 - }, -``` - -## C相真实功率因数 -```text - { - "key":"factor_c", - "label":"", - "name":"C相真实功率因数", - "timestamp":1701395303, - "type":"AI", - "unit":16, - "value":0.995 - }, -``` - -## 总真实功率因数 -```text - { - "key":"factor", - "label":"", - "name":"总真实功率因数", - "timestamp":1701395303, - "type":"AI", - "unit":16, - "value":1.151 - }, -``` - -## 输入的有功电能 -```text - { - "key":"power_input", - "label":"kWH", - "name":"输入的有功电能", - "timestamp":1701395303, - "type":"AI", - "unit":5, - "value":180998765272498 - }, -``` - -## 输入的无功电能 -```text - { - "key":"p_input", - "label":"kVarH", - "name":"输入的无功电能", - "timestamp":1701395303, - "type":"AI", - "unit":2, - "value":180998765272498 - }, -``` - -## 倒送的有功电能 -```text - { - "key":"power_back", - "label":"kWH", - "name":"倒送的有功电能", - "timestamp":1701395303, - "type":"AI", - "unit":5, - "value":180998765272498 - }, -``` - -## 倒送的无功电能 -```text - { - "key":"p_back", - "label":"kVarH", - "name":"倒送的无功电能", - "timestamp":1701395303, - "type":"AI", - "unit":2, - "value":180998765272498 - } -``` - -# 盛帆数据上传格式 - 盛帆有三种表，每种表格式不一致。 - -## NB三相表 - NB三相表数据上传格式如下： - -### 正向总有功电能 - -```text - { - "key":"epi", - "name":"正向总有功电能", - "unit":"5", - "label":"kWh", - "value":"321876", - "type": "AI", - "timestamp":1701396585, - }, -``` - -### A相电压 -```text - { - "key":"a_voltage", - "name": "A相电压", - "unit":0, - "label":"V", - "value":224, - "type": "AI", - "timestamp":1701396585 - }, -``` - -### A相电流 -```text - { - "key":"a_current", - "name": "A相电流", - "unit":3, - "label":"A", - "value":0.122, - "type": "AI", - "timestamp":1701396585 - }, -``` - -### B相电压 -```text - { - "key":"b_voltage", - "name": "B相电压", - "unit":0, - "label":"V", - "value":224.3, - "type": "AI", - "timestamp":1701396585 - }, -``` - -### B相电流 -```text - { - "key":"b_current", - "name": "B相电流", - "unit":3, - "label":"A", - "value":0.125, - "type": "AI", - "timestamp":1701396585 - }, -``` - -### C相电压 -```text - { - "key":"c_voltage", - "name": "C相电压", - "unit":0, - "label":"V", - "value":224.3, - "type": "AI", - "timestamp":1701396585 - }, - -``` - -### C相电流 -```text - { - "key":"c_current", - "name": "C相电流", - "unit":3, - "label":"A", - "value":0.091, - "type": "AI", - "timestamp":1701396585 - }, -``` - -### 瞬时总有功功率 -```text - { - "key":"active_power", - "name": "瞬时总有功功率", - "unit":23, - "label":"kW", - "value":44.28, - "type": "AI", - "timestamp":1701396585 - }, -``` - -### 总功率因数 -```text - { - "key":"power_factor", - "name": "总功率因数", - "unit":16, - "label":"", - "value":0.978, - "type": "AI", - "timestamp":1701396585 - } -] -``` - -## 三相表 - -### 正向总有功电能 -```text - { - "key": "epi", - "name": "正向总有功电能", - "unit":5, - "label":"kWh", - "value":11022.2, - "type": "AI", - "timestamp":1701892979 - }, -``` - -### 剩余电量 -```text - { - "key":"dump_energy", - "name":"剩余电量", - "unit":5, - "label":"kWh", - "value":83.6, - "type": "AI", - "timestamp":170189297, - }, -``` - -### 电压 -```text - { - "key":"voltage", - "name":"电压", - "unit":0, - "label":"V", - "value":227.2, - "type": "AI", - "timestamp":170189297, - }, -``` - -### 电流 - -```text - { - "key":"current", - "name":"电流", - "unit":3, - "label":"A", - "value":0, - "type": "AI", - "timestamp":170189297, - }, - -``` -### 瞬时总有功功率 -```text - { - "key":"active_power", - "name":"瞬时总有功功率", - "unit":23, - "label":"kW", - "value":0, - "type": "AI", - "timestamp":170189297, - }, -``` - -### 总功率因数 -```text - { - "key":"power_factor", - "name":"总功率因数", - "unit":16, - "label":"", - "value":1, - "type": "AI", - "timestamp":1701892979 - } -] -``` - -## 双回路电表 - -### 正向总有功电能 -```text - { - "key":"epi", - "name":"正向总有功电能", - "unit":5, - "label":"kWh", - "value":2.169771e+06, - "type": "AI", - "timestamp":170189299, - }, -``` - -### A相电压 -```text - { - "key":"a_voltage", - "name":"A相电压", - "unit":0, - "label":"V ", - "value":221, - "type": "AI", - "timestamp":170189299, - }, -``` - -### A相电流 -```text - { - "key":"a_current", - "name":"A相电流", - "unit":3, - "label":"A", - "value":2.05, - "type": "AI", - "timestamp":170189299, - }, -``` - -### B相电压 -```text - { - "key":"b_voltage", - "name":"B相电压", - "unit":0, - "label":"V", - "value":221.5, - "type": "AI", - "timestamp":170189299, - }, -``` - -### B相电流 -```text - { - "key":"b_current", - "name":"B相电流", - "unit":3, - "label":"A", - "value":2.006, - "type": "AI", - "timestamp":170189299, - }, -``` - -### C相电压 -```text - { - "key":"c_voltage", - "name":"C相电压", - "unit":0, - "label":"V", - "value":222.1, - "type": "AI", - "timestamp":170189299, - }, -``` - -### C相电流 -```text - { - "key":"c_current", - "name":"C相电流", - "unit":3, - "label":"A", - "value":2.064, - "type": "AI", - "timestamp":170189299, - }, -``` - -### 瞬时总有功功率 -```text - { - "key":"active_power", - "name":"瞬时总有功功率", - "unit":23, - "label":"kW", - "value":62.106, - "type": "AI", - "timestamp":170189299, - }, -``` - -### 总功率因数 -```text - { - "key":"power_factor", - "name":"总功率因数", - "unit":16, - "label":"", - "value":0.765, - "type": "AI", - "timestamp":170189299, - } -``` - -# 中电计费电表(2023-12-26 新增) - -```text -[ - { - "key":"energy", - "label":"kwh", - "name":"正向有功总电能", - "type":"AI", - "unit":5, - "value":0 - }, - { - "key":"energy_l1", - "label":"kwh", - "name":"L1正向有功电能", - "type":"AI", - "unit":5, - "value":0 - }, - { - "key":"energy_l2", - "label":"kwh", - "name":"L2正向有功电能", - "type":"AI", - "unit":5, - "value":0 - }, - { - "key":"energy_l3", - "label":"kwh", - "name":"L3正向有功电能", - "type":"AI", - "unit":5, - "value":0 - }, - { - "key":"voltage", - "label":"V", - "name":"系统电压", - "type":"AI", - "unit":0, - "value":225.7 - }, - { - "key":"frequency", - "label":"", - "name":"电网频率", - "type":"AI", - "unit":16, - "value":50.02 - }, - { - "key":"price", - "label":"rmb/kwh", - "name":"当前电价", - "type":"AI", - "unit":54, - "value":0 - }, - { - "key":"current_l1", - "label":"A", - "name":"L1回路电流", - "type":"AI", - "unit":3, - "value":0 - }, - { - "key":"current_l2", - "label":"A", - "name":"L2回路电流", - "type":"AI", - "unit":3, - "value":0 - }, - { - "key":"current_l3", - "label":"A", - "name":"L3回路电流", - "type":"AI", - "unit":3, - "value":0 - }, - { - "key":"p_all", - "label":"KW", - "name":"瞬时总有功功率", - "type":"AI", - "unit":23, - "value":0 - }, - { - "key":"p_l1", - "label":"KW", - "name":"L1瞬时有功功率", - "type":"AI", - "unit":23, - "value":0 - }, - { - "key":"p_l2", - "label":"KW", - "name":"L2瞬时有功功率", - "type":"AI", - "unit":23, - "value":0 - }, - { - "key":"p_l3", - "label":"KW", - "name":"L3瞬时有功功率", - "type":"AI", - "unit":23, - "value":0 - }, - { - "key":"q_all", - "label":"Kvar", - "name":"瞬时总无功功率", - "type":"AI", - "unit":23, - "value":0 - }, - { - "key":"q_l1", - "label":"Kvar", - "name":"L1瞬时无功功率", - "type":"AI", - "unit":23, - "value":0 - }, - { - "key":"q_l2", - "label":"Kvar", - "name":"L2瞬时无功功率", - "type":"AI", - "unit":23, - "value":0 - }, - { - "key":"q_l3", - "label":"Kvar", - "name":"L3瞬时无功功率", - "type":"AI", - "unit":23, - "value":0 - }, - { - "key":"factor_all", - "label":"", - "name":"总功率因数", - "type":"AI", - "unit":16, - "value":1 - }, - { - "key":"factor_l1", - "label":"", - "name":"L1功率因数", - "type":"AI", - "unit":16, - "value":1 - }, - { - "key":"factor_l2", - "label":"", - "name":"L2功率因数", - "type":"AI", - "unit":16, - "value":1 - }, - { - "key":"factor_l3", - "label":"", - "name":"L3功率因数", - "type":"AI", - "unit":16, - "value":1 - }, - { - "key":"l1_relay", - "label":"", - "name":"L1回路继电器状态", - "type":"DI", - "unit":16, - "value":"通" - }, - { - "key":"l2_relay", - "label":"", - "name":"L2回路继电器状态", - "type":"DI", - "unit":16, - "value":"通" - }, - { - "key":"l3_relay", - "label":"", - "name":"L3回路继电器状态", - "type":"DI", - "unit":16, - "value":"通" - }, - { - "key":"l1_circuit", - "label":"", - "name":"L1回路保电状态", - "type":"DI", - "unit":16, - "value":"非保电" - }, - { - "key":"l2_circuit", - "label":"", - "name":"L2回路保电状态", - "type":"DI", - "unit":16, - "value":"非保电" - }, - { - "key":"l3_circuit", - "label":"", - "name":"L3回路保电状态", - "type":"DI", - "unit":16, - "value":"非保电" - }, - { - "key":"relay_status", - "label":"", - "name":"继电器状态", - "type":"DI", - "unit":16, - "value":"通" - }, - { - "key":"run_zone", - "label":"", - "name":"当前运行时区", - "type":"DI", - "unit":16, - "value":"第一套" - }, - { - "key":"pre_close", - "label":"", - "name":"预跳闸报警状态", - "type":"DI", - "unit":16, - "value":"有" - }, - { - "key":"id_status", - "label":"", - "name":"身份认证状态", - "type":"DI", - "unit":16, - "value":"失效" - }, - { - "key":"oper_time", - "label":"", - "name":"当前运行时段", - "type":"DI", - "unit":16, - "value":"第一套" - }, - { - "key":"relay_cmd", - "label":"", - "name":"继电器命令状态", - "type":"DI", - "unit":16, - "value":"通" - }, - { - "key":"meter_type", - "label":"", - "name":"电能表类型", - "type":"DI", - "unit":16, - "value":"非预付费表" - }, - { - "key":"price_type", - "label":"", - "name":"当前电价方案", - "type":"DI", - "unit":16, - "value":"第一套" - }, - { - "key":"save_power", - "label":"", - "name":"保电状态", - "type":"DI", - "unit":16, - "value":"非保电" - }, -] -``` - - diff --git a/docs/router.md b/docs/router.md deleted file mode 100644 index 1ae748a..0000000 --- a/docs/router.md +++ /dev/null @@ -1,3 +0,0 @@ -# 数据路由设计文档 - - diff --git a/docs/zhongdian_mqtt.md b/docs/zhongdian_mqtt.md deleted file mode 100644 index c055798..0000000 --- a/docs/zhongdian_mqtt.md +++ /dev/null @@ -1,58 +0,0 @@ -# 中电mqtt通讯规约 -## 服务器地址 - MQTT服务器IP：172.30.6.161 - MQTT服务器端口：1883 - MQTT服务器账号：admin - MQTT服务器密码：public - -## topic - 南向： - MQTT ClientID: CET/NX - 发布Topic:CET/NX/upload - 订阅Topic:CET/NX/downlod - - 中电： - MQTT ClientID:CET/NX - 订阅Topic:CET/NX/upload - 发布Topic:CET/NX/download - -## 数据格式 -```text -{ - "version": "1.0", - "location_code": "string", - "ts ": 1688606685, - "properties": [ - { - "type": "AI", - "key": "A相电流", - "value": 0.25, - "unit": "A", - "timestamp": 1688354258 - }, - { - "type": "AI", - "key": "A相电压", - "value": 220.5, - "unit": "V", - "timestamp": 1688354258 - }, - { - "type": "SOE", - "key": "电压越限", - "value": 1, - "unit": "V", - "timestamp": 1688354258 - } - ] -} - -南向上送数据 - -CET应答： -{ - "location_code": string, //(点位编码信息), - "ts ":1688606685 , - "result":1(int) -} -```