ems.c

源文件路径：net/ems.c 所属模块：net（网络应用层 / 云端 EMS 通信） 代码行数：7289

1. 文件职责

net/ems.c 是 EMS 主控与云端服务器（AlphaCloud/自建平台）之间 TCP+JSON 协议的上行组包与协议状态机主体：它把本地电网电表、逆变器、BMS、充电桩、油机、能量统计、配置与事件等数据，按约定的 JSON 字段格式逐个封装成帧，再通过 uCOS-II 消息队列交给以太网任务发出。

它同时承担"云端下发指令的应答与执行编排"：重启、设/读配置、远程控制、对时、调度、功率因数、充电桩使能、一键停机、SOC 校准、电池激活时间、CAN 帧下发、安规配置读写、升级文件下载与断点续传等动作，都在本文件的状态机里被触发、组应答帧，并修改对应的全局标志位。

数据流的环节：设备中间件读数据（只读接口）→ 本文件组 JSON 帧 → g_au8NetSendPack/g_t_freq_dispatch_data.u8_send_buff → OSQPost(g_pEthernetQ) → midware/ethernt/ethernet.c 的以太网任务发送；下行帧的接收、解析与命令分发在 net/server.c，本文件只处理"我方要往外发"的一侧以及由此派生的本地副作用（例如置 g_u8RestartFlag 后的复位动作）。

驱动方式：所有逻辑运行在 user/main.c:255 创建的 task_net_app 任务中（TASK_NET_PRIO = 16、栈 512 word、循环周期 25 ms，见 UCOSII/uCOS-CONFIG/app_cfg.h:67、:94）。

2. 关键数据结构与宏

2.1 本文件定义/占用的全局变量

2.2 使用的主要类型（定义在 net/ems.h）

2.3 本文件用的重要宏常量

3. 函数清单

共 77 个函数定义（已用 grep -nE "^[A-Za-z_].*\)[ ]*$" net/ems.c 全量核对，文件内无遗漏）。

4. 核心逻辑解析

4.1 通信帧格式与封帧（fill_common_data，:333）

所有上行报文由 fill_common_data() 统一封帧，布局如下（偏移从 0 起）：

约定：l_u16Len 变量表示"JSON 已用到的末尾偏移（含 7 字节帧头）"；封帧后发送长度 g_u16DataSendLen = l_u16Len + 2。各 fill_* 的典型写法是每段 snprintf 后带一个尾逗号，最后一段前用 l_u16Len -= 1 退掉多余逗号再补 "}"。缓冲容量参数统一取 sizeof(g_au8NetSendPack) - 2（5118），调频类的 fill_* 则改用 sizeof(g_t_freq_dispatch_data.u8_send_buff) - 2 并把 JSON 写进 u8_send_buff。

超时与重试机制不在本文件用超时/重发计数器实现，而是靠两条机制：一是应用层的 if(OSTimeGet() - tick >= 周期) 周期节拍（见 4.10）；二是队列侧的 NET_DATA_SEND_TRY(50) 上限——同一报文在 g_stNetDataSend.u8Type 未被以太网任务清零时最多保留 50 个任务周期，之后由 check_idle_process() 强制丢弃并发下一包。

4.2 发送通道：消息队列与以太网任务协作

handle_message_queue(type, info, len)（:5362）把 type/指针/长度 写入全局 g_stNetDataSend（midware/ethernt/ethernet.c:34 定义，STEthernetData 含 u8lock 字段），然后 OSQPost(g_pEthernetQ, &g_stNetDataSend)：

• 投递成功 → g_stEMSInfo.u16OSQDealFailCnt = 0；
• 队满（OS_ERR_Q_FULL）→ OSQFlush(g_pEthernetQ) 清队列（丢历史包，保最新包）；
• 其它错误 → u16OSQDealFailCnt++（该计数在 midware/ethernt/ethernet.c 与我们 :49 的 OSQ_DEAL_FAIL 门限配合触发事件日志）。

发送完毕由以太网任务把 g_stNetDataSend.u8Type = STATUS_NONE、u8lock = FALSE（ethernet.c:574/615/788/859）。因此 ems_time_event() 开头有 if(g_stNetDataSend.u8lock == TRUE) return;（:5395）——发送期间整个状态机停摆一个周期，避免组包缓冲被并发改写。

例外：CAN 日志上报分支（:6228-6255）不走队列，直接调用 send(SOCK_TCP_CLIENT, ...) 发原始 socket，并自行按 10 s 间隔节流。

4.3 主状态机（ENStatus）与 ems_time_event() 的对应关系

ems_time_event()（:5390）是一个巨型 switch(get_state_tcp_protocol())；绝大多数分支的执行模式固定为：组包 → handle_message_queue() → changed_state_tcp_protocol(STATUS_IDLE)。状态之间的迁移由 check_idle_process() 在 STATUS_IDLE 时决定（一次性触发；回到 IDLE 后下一周期再由派发器选下一个动作，因此 25 ms 周期内最多发一包）。核心映射如下：

两个分支带"硬复位"副作用：STATUS_RESPSONED_RESTART（:5575）与 STATUS_RESPSONED_G100_REBOOT（:5691）在发完应答后 OSTimeDlyHMSM(0,0,5,0) 延时 5 s 再 system_hard_reset()。STATUS_RESPSONED_SET_CONFIG（:5589）除了应答，还会一次性把 g_u8RequestConfigFlag、g_u8RequestConfigFlagExtend11/12、g_u8appConfigFlag* 全部置真并刷新三个请求 tick，形成"配置被改 → 立即回读配置"的闭环。

4.4 check_idle_process()：派发优先级与周期表（:4521）

这是本文件最核心的调度逻辑，全部写成一个 if-else 阶梯，先命中先返回。三层结构：

1. 队列忙等（:4529）：g_stNetDataSend.u8Type != STATUS_NONE 时只做计数，累计 50 次（NET_DATA_SEND_TRY）后把 u8Type 强制清为 STATUS_NONE 并返回 IDLE（相当于发送超时丢包）。
2. 建链但未登录（:4547）：bIsLogin==FALSE && bIsBuiltSocket==TRUE && APP 未连接 → 每 10 s（SENCOND_10S）返回一次 STATUS_LOGIN。
3. 已登录（:4562）：
   • 先处理"配置回读"：(g_u8RequestConfigFlag && g_u8appConfigFlag) 每 5 s 发一次 STATUS_READ_CONFIG；扩展 1 每 10 s；扩展 2 每 15 s。
   • 然后进入大门闸 if((g_u8RequestConfigFlag == FALSE) || (g_u8appConfigFlag == FALSE))（:4601）——只要还处在"等待回读配置"状态，下面的全部业务上报都被跳过。门内的检查顺序（即优先级）为：

随后是 APP/局域网通道（:5255）：g_t_app_info.u8_app_connect_flag == TRUE 时，按 u8_set_cfg/u8_get_cfg/u8_send_run_info/u8_self_test_data/u8_set_cfg_extend1/u8_get_cfg_extend1/u8_send_run_info_extend1/u8_set_safety/u8_get_safety 九个一次性标志派发 STATUS_SET_CONFIG/STATUS_GET_CONFIG/STATUS_SEND_RUN_INFO/STATUS_SEND_SELF_TEST_INFO/…，并逐个把标志清零。

4.5 上报报文的内容与打包要点

• 主运行数据 fill_system_run_info()（:439）：字段体量最大的一帧，按电网电表（meter_read_*）→ PV/DC 电表 → 逆变器（PV/并网/备份/电池）→ BMS（总压总流 SOC、8 路支路电流/SOC、限功率、单体极值）→ 系统状态（Fault/Protection/Normal 三态由 ems_read_fault_code()、inverter_read_fault_code[_extend/extend2]()、bms_read_fault_code()、bms_read_protection_code() 决定，:664-669）→ 能量统计（PV/逆变器/电网/电池/油机/充电桩）→ 调试量（PcsPara1..12）顺序拼接。fun 参数决定方向：等于 CMD_SEND_DAT_SYS_RUN 时是主动上报（REQUEST_COMM，附加 Eirp/CSQ、调度信息、硬编码的 UVP/OVP/OFP 保护定值和 PcsPara*）；其它（如 CMD_SEND_RUN_INFO、CMD_GET_CONFIG）走 RESPONSE_COMM 且以 "Status":"Success" 开头，并以 APPErrorCode 数组（get_show_errcode(i)，ERRCODE_FIFO_SIZE 个）结尾（:847-853）。
• BMS 错误码在 ErrBmsList/WarBmsList 中按 g_t_bat_info.t_run_info.u8_num（上限 BATTERY_MAX_NUM）逐电池输出 {"id":n,"code":v}，末尾用"检查最后一个字符是否为逗号再回退"的方式去尾（:690-693、:711-714）。
• 扩展运行数据 fill_system_run_info_extend1()（:946）：充电桩数据在 get_evc_enable_flag() 为真时输出单路 EV1*，否则按 MAX_EVC_II_NUM 循环输出 EVn*（要求对应 g_t_evc_ii_single_config[i].u8_enable）；其余为备电盒 UBB*、GenConnectStatus/OperationalModeStatus（由 inverter_read_run_mode() 与 dercontrol/opmodgenlimw 推导）、12 个电池的 BatCycle/SOH/BatTempLow|High/BatRunHrs、欧盟 14a（EnWGCTRL/RRCRCTRL/RRCRRATE，取 u8_rrcr_en → u8_rrcr_feedin_percent，或 EZA_ENABLE → u8_eza_feedin_percent）、WlvCtrl/WlvRate；MID 电表段仅在 g_t_meter.t_config_data.u8_mid_meter_function_enable == TRUE 时输出；BatMaxCapacity 用"先按实际电池数输出、再补 0 至 BATTERY_MAX_NUM"的写法保证定长（:1192-1207）；A/B 簇信息仅在 bms_is_a_cluster_valid()/bms_is_b_cluster_valid() 为真时输出 6 个 {"id","status"}。
• 配置帧：fill_send_config_data()（:1676）可分两块——公共服务/APP 都有的字段（容量、型号、版本、时控段 1/2 的起止分钟数、GridCharge/CtrDis 布尔、备电盒优先级与 SOC 限值、安规类型、IP/子网/网关、Modbus 地址波特率、并机、AFCI 等）；仅当 fun == CMD_SEND_CONFIG_INFO 时追加干接点 1/2 时段、网络类型字符串（ALPHA_LINKER_WIFI/E_LINKER_WIFI/E_LINKER_4G/NONE，若 W5500 同时在线则 strcat 追加 " & W5500"）与 4G ICCID（:1877-1903）。fill_send_config_data_extend1()（:1931）同理分CMD_SET_CONFIG_DEV_EXTEND1 块：充电桩配置与两台 EVCn 28 元组、SystemFunction1/2 位域、并网功率限制、干接点馈电模式、TIMEChaDis1..28（14 组来自 t_config_extend1_data、14 组来自 t_config_extend2_data）、6 组电池强制馈网时段、电池激活时间（年份 <2000 时输出空位）、SOC 校准、EPO、EnWGEnable。fill_send_config_data_extend2()（:2181）输出削峰填谷 11 元组、CSIP 15 元组、GFCI/AFCI/MID 电表使能与版本、并机通信方式等。
• 升级相关：request_update_file_info()（:2945）按 get_current_point_file_mask() 选择设备分支（FILE_MASK_EMS/INV1/INV2/INV3/BMS/电表/EVC/AFCI）填 HardVer、FileMD5Code、FWType（型号字符串）与 UpdtReversed；request_update_file_content()（:3059）每次请求 min(剩余, LEN_REQ_FILE=1024) 字节，并把当前升级表的 as8MD5Code 一并带上（:3112）。两者在指针为空或长度已用尽时返回 FALSE，ems_time_event() 用返回值决定是否入队。
• 调频/调度帧：fill_system_fcas_data() 固定 10 组（每组 10 点，逐点 PInv/Fac/Pmeter/Ppv/PmeterDC/PvarMeter/Pbat/FMFlag）；fill_system_fast_fcas_data(cmd) 按 cmd 取 5 包（0x1B）或 20 包（0x19），输出 8 个数组；fill_system_dispatch_data() 的包数 cnt = 10000 / u32_dispatch_data_interval / 10（:3433）——与 get_dispatch_data() 的填数组上限 s_u8_index >= (10*1000)/interval（:6540）配对，且 interval 下限被钳到 50（:6509-6512）；fill_system_ffr_data_100ms() 固定 10 组、频率按两位小数输出。

4.6 登录与保活

• tcp_init_ems()（:191）在任务启动时把所有 tick 对齐到当前 OSTimeGet()，把状态机与 g_stNetDataSend 复位为空闲，并清 u8LogInCnt。
• fill_login_data()（:360）构造 {"UserName":SN,"CompanyName":...,"Password":...}：公司名/密码优先级为 g_system_custom_info.u8_login_flag 自定义值 > OEM 为 OEM_ZONERGYESS 时写死 zonergyess/Alpha0923 > 默认 AlphaESS/Alpha0912；当 get_server_data_encryption_flag() == NET_PRIVATE_ENCRYPTED 时改用动态密码 MD5("ALPHA"+SN) 取摘要第 12~15 字节格式化成 8 位大写 HEX。
• 保活链路：登录 → 心跳（:5038，周期 60 s）→ 运行数据（60 s/300 s）。链路异常由 midware/ethernt/ethernet.c 依据 u8LogInCnt >= LOGIN_NO_ACK_NUM、u16HeartRstCnt >= HEART_RST_FAIL、u8LogInNoAckRstCnt、u16OSQDealFailCnt 等计数处理（门限宏来自 net/ems.h），并调用本文件的 socket_abnormal_handle()（:140）复位通信状态。

4.7 升级与断点续传流程

升级（net/upd_download.c 提供状态查询，本文件负责驱动）：

1. check_need_response_updt_devcie(&s_u8DevType) 为真 → STATUS_RESPSONED_FORCE_UPDATE → handle_response_force_update()（:2851）：若 get_updt_status_current() > UPDT_STS_IDLE 或 IsSystemUpgrade() 为真，应答 "Status":"Error"，否则 Success；应答里带 CmdIndex（取 g_stEMSInfo.stUpt[s_u8DevType].au8IDCMDUpdate，s_u8DevType >= UPDT_MAX 时用空串），随后 set_response_force_upd_status(s_u8DevType, FALSE) 清标志。
2. load_current_update_data() 载入升级表（g_stEMSInfo.pstCurrUpt / stUpt[]，也可由 midware/interface/modbus/modbus.c:8779+ 经 Modbus 直接指定升级目标）。
3. STATUS_UPDATE_CHECK（5 s 周期）→ 0x20 上报本机掩码与版本信息，云端回帧决定是否需要下载。
4. STATUS_GET_UPDATE_FILE（100 ms 周期，REQUEST_UPDATE_INTERVAL）→ 0x21 分片请求。进入前 OSSemPend(g_pUpdateSem, 3000, &err)：拿到信号量后还要再判一次 is_goto_get_update_file_status()；OSSemPend 失败累计 >10 次则置 bIsLogin = FALSE（强制重新登录以续订文件）并 OSSemPost 归还信号量（:4686-4716）。每次请求前调用 ems_tick_init_wireless()，避免无线升级期间被判超时或升级后数据包错乱。
5. 升级过程中的进度上报由 send_upgrade_info_data()（:6673，每 25 ms 调一次）驱动：按 UPDT_EMS/INV1/INV3(ARM)/BMS/Meter(含 BACKUPBOX 分支)/EVC/AFCI 顺序匹配，填 u8_dev_code、u8_id_cmd_update、u32_upgrade_file_offset（优先取各设备自身记录的偏移）；状态迁移为 UPGRADE_NONE →(收到升级指令) DOWNLOAD_START →(不可升级⇒下载结束) DOWNLOAD_FINISH →(仍有升级⇒3 s 周期) UPGRADE_START →(结束且可升级) UPGRADE_FINISH，结束时按 u16_upgrade_error 位域选择原因字符串（success/WEB_ERROR/DOWNLOAD_ERROR/SYSTEM_UPS/MD5_ERROR/TIMEOUT/BOOT_ERROR）；UPGRADE_FINISH 且发送标志已清后整体清零 g_t_upgrade_run_info。

断点续传（数据由 data/resume_data/flash/flash_data_store.c 维护）：

• g_u8_resp_resume_flag 为真 → 清标志并回 0x08 应答（Handle_Response_Resume()，含 get_resume_cmd_id_code()）。
• Get_Resume_Status_Current() == RESUME_STS_Sending → 直接把 resume_buff_sdram（长度 g_u32_resume_data_len）作为完整报文入队，然后置 RESUME_STS_Over。
• == RESUME_STS_Over 时每 5 s 重试一次：g_u8ReumeFailCnt > 10 则清零 resume_buff_sdram、g_u32_resume_data_len = 0、状态回 RESUME_STS_Idle；否则重新置 RESUME_STS_Sending 再发一遍（:4881-4903）。
• 续传期间常规运行数据被抑制：发送 0x05/0x16 的条件里都带 !is_goto_get_update_file_status() && Get_Resume_Status_Current()==RESUME_STS_NONE && get_resume_index_length()==FALSE。

4.8 调频/调度/FFR 数据采集（get_*_data()）

这三个函数每 25 ms 被调用一次，把实时量写入 g_t_freq_dispatch_data 的并行数组，写满一个周期后置对应的 g_u8_send_*_flag，由状态机负责发送：

三者在"本轮采样完成（发送标志已置）"期间直接 return，避免覆盖未发出的数据；PV 功率按系统模式（DC_SYSTEM_MODE / AC / HYBIRD）计算：并网+混合模式取 inverter_read_pv_power(PV_CHANAL_ALL) + max(meter_read_actpower(PV_METER,PHASE_T), 0)。索引归零时把 g_t_freq_dispatch_data.t_datetime = SYSTEM_DATETIME 作为该批数据的时标。get_grid_ct_sampling_data()（:6620）只做标志搬运；send_debug_run_info_data()（:6642）用静态 send_data_enable_flag 保证使能后持续上传一段时间（u32_debug_run_info_time），到期清 g_u8_send_debug_run_info_flag 并 memset 整个 g_t_debug_run_info。

4.9 CAN 日志采集/上报两态机（需求 7）

控制块 s_can_log_ctrl 与缓存指针数组 s_can_log_raw_buffers[] 定义在 net/server.c:80/83，本文件负责采集与打包：

• 采集态（check_can_log_upload_task()，:6849，25 ms 轮询，active==1）：先查超时 current_tick - start_tick > CAN_LOG_CAPTURE_TIMEOUT_MS 或累计数达到 total_count，满足即转上报态并把包序号、ID 索引、偏移全部归零；否则从标准帧队列 get_can0_standard_pack() 与扩展帧队列 get_can0_exten_pack()（hardware/can/can0.c）取帧，一次最多 MAX_READ_PER_CALL=60 帧、最多耗 MAX_READ_TIME_MS=5 ms；帧 ID 与目标 ID 匹配时才停止取帧循环（不匹配的帧被丢弃并计数 read_count）；匹配到则写入 s_can_log_raw_buffers[matched_idx] 的第 current_count[matched_idx] 条（id/dlc/data/timestamp，时间戳由 SYSTEM_DATETIME 经 mktime() 生成）。
• 上报态（active==2）：is_can_log_upload_ready()（:7029）按"每个 ID 独立分包、每包 CAN_LOG_PACK_COUNT_PER_PACK 条"计算总包数 total_pack = Σ ceil(count_i / 每包条数)，只要 current_pack_seq <= total_pack 即返回真；ems_time_event() 的 STATUS_SEND_CAN_LOG_DATA 分支（:6228）带 10 s 节流（静态 s_last_send_tick），调 fill_send_can_log_data()（:7072）把当前包定位到"第几个 ID 的第几包"（:7110-7121），逐条输出 {"t":"YYMMDDHHMMSS","d":"16位HEX"}，帧头带 CmdIndex/TargetId/TotalCount/PackSeq/TotalPack；若采集超时且条数不足，尾部标记 "Description":"Partial"，否则 "OK"。发送成功后 current_pack_seq++；发送失败则调 socket_abnormal_handle() 并推进节流时间。上报完成后（current_pack_seq > total_pack）把 active 清 0 并清空各 ID 计数。
• test_can_log_upload_custom(ids[], id_count, target_count)（:7204）是自测入口，参数越界即返回，成功后调 start_can_log_capture(...,"CUSTOM",6)（实现在 net/server.c:7219），并用静态 s_test_done 保证只跑一次。

4.10 时间基准与定时语义

本文件混用两套时间基准，改动超时逻辑时必须区分：

• OSTimeGet()：uCOS-II 系统 tick，OS_TICKS_PER_SEC = 1000（UCOSII/uCOS-CONFIG/os_cfg.h:51），1 tick = 1 ms。用于心跳、登录、配置、升级、事件上报、断点续传、老化、升级信息等所有 SENCOND_* 比较。
• get_rtc_tick()：返回 RTC 换算出的 Unix 秒（midware/auxiliary/system_aux.c:373 由 mktime() 生成），用于运行数据（60 s/300 s，:4986、:5004）、油机数据（300 s）、常规 FCAS（1 s）。
• 反向跳变保护：几乎所有比较后面都跟一条 else if(tick > OSTimeGet()) { tick = OSTimeGet(); }（如 :4556、:4571、:4613 等），用于把因复位/RTC 校时而落到"未来"的 tick 拉回当前值。这类分支只修正一次，不是通用回绕处理。

task_net_app(p_arg)（:7250）任务体：先 tcp_init_ems() 与 set_info_status(SYSTEM_RESTART)（重启事件立即上报），随后 for(;;) 内固定顺序调用 ems_time_event() → app_connect_detect() → get_dispatch_data() → get_fcas_data() → get_ffr_data() → get_grid_ct_sampling_data() → send_debug_run_info_data() → send_upgrade_info_data() → can_send_task()（需求 3，实现在 midware/bms/bms.c:4320）→ check_can_log_upload_task()，然后刷新 g_stEMSInfo.u32EMSTaskTick = OSTimeGet() 并 OSTimeDlyHMSM(0,0,0,25) 睡 25 ms。u32EMSTaskTick 是任务存活的心跳：midware/ethernt/ethernet.c:1453 用它做"超过 60 s 未刷新 ⇒ printf("task_net_app is time out!")（ethernet.c:1456）"的监控，并在异常后把该值拉回当前时间。

4.11 关键全局变量的读写与触发条件

5. 对外接口

本文件导出的函数（在 net/ems.h 中有声明、供外部调用）

其它未在头文件声明的全局函数（get_setup_config_*、fill_*、handle_response_*、request_update_*、respond_*、get_*_data、ems_time_event、app_connect_detect、send_*_data、can_log_*、ems_get_upload_interval、obtain_event_log_data）经全仓检索只在本文件内被调用，属"事实上的文件内接口"，但未加 static（详见第 7 节）。

本文件导出的全局变量：g_stEMSInfo、g_u8RestartFlag 等全部跨模块标志（net/ems.h:467-506 声明；g_stEMSInfo 被 data/fault_warn_log、data/resume_data/flash、hmi/led/app_led.c、midware/interface/modbus、midware/ethernt/ethernet.c、net/server.c 等广泛使用）。

本文件调用的外部函数/变量（按来源模块）

• 时间与系统：system_aux.h → get_rtc_tick()、SYSTEM_DATETIME、system_hard_reset()、get_system_sn()、get_ems_hard_type/version()、get_ems_boot_ver()、get_server_data_encryption_flag()、IsSystemUpgrade()、IsSystemDownload()、g_system_custom_info、g_t_system_base_info、g_system_function_info、g_u8_rtc_debug_data、pstRest/g_t_restart_time、pstRest
• 电表：meter_read_voltage/current/frequent/actpower/reactpower/apparent/einput/eoutput、meter_read_meter_sn/software_version/hard_version、meter_get_meter_modle、meter_get_meter_or_ct、meter_get_meter_ct_rate/ct_enable、meter_read_bb_sn/bb_software_version、get_average_power_of_gridmeter()、g_t_meter
• 逆变器：inverter_read_*（PV/并网/备份/电池/温度/功率因数/运行模式/告警/故障/版本/SN/额定功率/能量）、inverter_get_phase_number()、inverter_get_parallel_mode()、inverter_read_afci()、inverter_read_n_n_short()、inverter_get_backup_freq_basic()、get_inverter_type()、g_t_inv_info（含 t_safty_info/t_safty_tset_info/t_run_info/t_config_data/t_afci_info/t_debug_log）
• BMS：bms_read_total_volt/cur/soc/power、bms_read_single_*（cur/soc/soh/cycle/temper/runhrs/max_capacity）、bms_read_status_flag/work_status/relay_status/shut_down/num、bms_read_max_charge_power/max_dischg_power、bms_read_fault_code[_by_id]、bms_is_fault_code_valid、bms_read_protection_code[_extend2_code]、bms_read_warning_code_by_id、bms_is_warning_code_valid、bms_read_battery_model/cell_model、bms_get_store_ver/store_sn/platform/ready_enable/self_lock_enable、bms_read_hard_version、bms_read_a_cluster_*/bms_read_b_cluster_*/bms_is_a|b_cluster_valid、bms_read_max_system_storage_capacity、bms_read_current_actual_remaining_available_electricity、g_t_bat_info
• 充电桩：get_evc_enable_flag/power_total/energy_total/chargemodel/hard_version/type、get_evc_ii_*（power_total/energy_total/chargemodel/gun_lock_flag/type）、g_t_evc_run_info、g_t_evc_setting_info、g_t_evc_config_table、g_t_evc_debug_data、g_t_evc_ii_run_info、g_t_evc_ii_single_config
• 能量统计（data/system_aux）：energy_read_storage_pv_input、energy_read_pv_inverter_output、energy_read_storage_inv_input/output、energy_read_storage_bat_charge/bat_dischg、energy_read_grid_consumption/feedin/chgrge、energy_read_bat_dischgrge/bat_dischg_feedin_grid、energy_read_gc_charge/gc_output、get_realtime_bat_chg/dischg/chg_from_grid/dischg_feedin_grid、get_energy_data_enable()
• 逻辑/调度：logic_read_*（sequencecontrol_mode、ac_total_set_*、inv_rated_*、bat_*_power_limit）、g_t_logic_info、get_dispatch_set_power()、get_dispatch_mode()、get_dispatch_running_freq()、get_fast_dispatch_running_freq()、get_dispatch_running_mode()、dispatch_api_data_interval()、frequency_regulation_flag()、dispatch_regulation_flag()、get_fcas_running_flag()、get_fast_fcas_running_flag()、get_very_fast_fcas_running_flag()、get_ffr_running_flag()、aging_mode_send_data_flag()、g_t_dispatch_t（含 t_stsystemcmdinfo、t_agingmode_info）
• 并机/PV 充电器：parallel_read_*（ac/dc 总功率设定、充满优先、SOC 阈值）、parallel_read_full_power_priority_enable、parallel_read_bat_soc_threshold、pvcharger_read_bat_*、g_t_host_machine_running_info[]
• 升级与下载（net/upd_download.h、net/server.h、各 *_download.h/*_upgrade.h）：get_updt_status_current()、check_need_response_updt_devcie()、get_flag_force_update()、set_response_force_upd_status()、get_flag_modbus_force_update()、set_save_firm_in_app_flash_flag()、load_current_update_data()、is_goto_update_check_status()、is_goto_get_update_file_status()、get_curr_updt_point_is_null()、get_current_point_*（file_mask/version/len/offset/flag/version_force_updt）、get_local_md5_ems_upt_file()、get_Meter_Updt_File_Mask()、get_meter_updt_object()、Get_Status_Is_Updated_From_Server()、check_force_upgradable_flag()、check_updt_force_is_none()、inverter_read_upgrade_file_offset[_arm]()、Get_Idx_Updt_BMS_Loacl()、get_upgrade_file_offset_meter/evc/afci、GetUpgradeFileOffsetBB()、get_updt_dev_type_curr()
• 断点续传：Get_Resume_Status_Current()、Set_Resume_Status_Current()、get_resume_index_length()、get_resume_cmd_id_code()、resume_buff_sdram、g_u32_resume_data_len
• 其他：common/crc.h 的 GetCrcCode_Modbus()、common/md5.h 的 MD5Init/Update/Final、logic/math_tools.h 的 fmt_fixed()、hmi/key.h/lcd.h 的 LCD_RTDB.u8_language、get_show_errcode()、data/fault_warn_log 的 read_event_log_data()、data/net_event_log 的 g_t_error_log_tab、dry_node.h 的 STDryNodeInfo、generator.h/diesel_generator.h 的 g_t_diesel_gen、afci_* 的 g_t_afci_log_tab、evc* 的 g_t_evc_*、flash_data_store/sdram.h 的定址宏、hardware/can/can0.h 的 get_can0_standard_pack/get_can0_exten_pack、ct.h 的 g_server_grid_sampling_curve_t、iwdg.h、modbus.h 的 g_t_modbus_config、bb_update.h、epo_read_config_enable()（system_config.h）、get_eeprom_hardware_read/write_fault_flag()、senergys_query_inv_register、g_t_wireless_info、g_e_linker_info、g_stNetInfo/g_stNetSysInfo/IP_Address、g_t_afci_log_tab。

6. 依赖关系

依赖（本文件 #include，:13-60）

• 网络层：socket.h、ethernet.h、server.h、ems.h、upd_download.h、ems_download.h、ems_boot_handle.h
• 设备固件升级：bms_download.h、inv_download.h、meter_download.h、evc_download.h、afci_download.h、evc_upgrade.h、meter_upgrade.h、battery_upgrade.h、bb_update.h
• 数据与逻辑：data.h、logic.h、dispatch.h、system_config.h、system_aux.h、fault_warn_log.h、net_event_log.h、flash_data_store.h、sdram.h
• 中间件：meter.h、bms.h、battery_comm.h、inverter.h、generator.h、diesel_generator.h、evc.h、evc_ii.h、ct.h、afci_comm.h、modbus.h、dry_node.h
• 人机与硬件：key.h、lcd.h、board_init.h、pcf8563.h、can0.h、iwdg.h
• 通用库：md5.h、crc.h、math_tools.h

被依赖

• net/ems.h 被 48 个文件包含（见 ems.h.md 第 6 节）；本文件即该头文件的主要实现者。
• 直接调用本文件符号的模块：user/main.c（创建任务）、net/server.c（set_info_status/clear_info_status/get_info_status/g_stEMSInfo/stUpt/reply_upload_can_log/g_as8SpecialCmdId/s_can_log_ctrl）、midware/ethernt/ethernet.c（socket_abnormal_handle、g_stEMSInfo 各 tick 与计数）、logic/logic.c、data/data.c、data/system_config/system_config.c、hmi/key.c、midware/bms/bms.c、midware/inverter/*、midware/meter/meter.c、midware/interface/modbus/modbus.c、data/fault_warn_log/fault_warn_log.c、data/resume_data/flash/flash_data_store.c、hmi/led/app_led.c（读取 g_stEMSInfo）。

7. 备注与风险点

1. snprintf 容量参数存在无符号下溢（最高危）。全文件通用写法是 snprintf(dst + l_u16Len, l_u16BufLen - l_u16Len, ...)，l_u16BufLen、l_u16Len 均为 u16：一旦某帧累计长度超过 l_u16BufLen（如 5118），l_u16BufLen - l_u16Len 会回绕成几万，snprintf 便会越界写 SDRAM。风险最高的是字段最多的几帧：fill_system_run_info（:439）、fill_system_run_info_extend1（:946）、fill_send_config_data（:1676）、fill_send_config_data_extend1（:1931）、fill_system_cell_run_data（:2335）、fill_bms_self_info（:3997）。其中 fill_system_cell_run_data 的循环上限直接取自 BMS 上行数据 g_t_bat_info.t_run_info.u8_cell_temper_number[i] / u8_cell_volt_number[i]（:2355、:2370），未做上限校验，BMS 上报异常值即可直接溢出。
2. l_u16Len -= 1 去逗号的写法缺少保护，属结构脆弱点。全文件共 51 处 l_u16Len -= 1;（已 grep -n 全量核对），约定是"每段 JSON 都以 , 结尾，拼接处先减 1 去掉该逗号再补 ] 或 }"。该约定在多处依赖"上一段一定输出过内容"，而恰恰有几段是条件输出的：fill_system_run_info 的 PcsPara8..12 组（:819-841 的 if/else if/else 在本快照下中间分支被条件编译成空语句块，必然少输出一段）、MID 电表段（:1143）、A/B 簇段（:1212、:1230）、fill_system_cell_run_data 中 u8_num == 0、fill_send_gen_run_data 的告警数组循环（:1611）。此时被减掉的其实是"上一段的尾逗号"，因所有段都以逗号结尾而侥幸仍然合法；但这种正确性完全依赖编码约定，没有任何断言或长度校验，后续若新增一段不以逗号结尾的字段就会直接产出非法 JSON。同类去逗号写法还有 :856、:1249、:1616、:1906、:2156、:2285、:2394、:3234、:3613、:3630 等。
3. CAN 日志模块在本快照中不可编译/不可验证。ems.h:522 将 check_can_log_upload_task 声明为非 static，而 ems.c:6849 定义为 static ——"static 声明跟随非 static 声明"在 C 中是错误，ARMCC 会报错。同时 CAN_LOG_CTRL_T、CAN_LOG_RAW_ITEM_T、MAX_CAN_LOG_ID_COUNT、MAX_CAN_LOG_COUNT、CAN_LOG_PACK_COUNT_PER_PACK、CAN_LOG_CAPTURE_TIMEOUT_MS、SPECIAL_CMD_CAN_SEND、SPECIAL_CMD_UPLOAD_CAN_LOG_STR 全仓（含被忽略文件）只能搜到使用（ems.c:7016/7088/7171/7216/7221、server.c:80/83/3090/3103），找不到任何定义，说明快照缺少对应头文件版本。另外 SDRAM_CAN_LOG_BUF_ADDR（hardware/sdram/sdram.h:68）注释标注长度仅 32 KB，而 net/server.c:7243 按 MAX_CAN_LOG_ID_COUNT * MAX_CAN_LOG_COUNT * sizeof(CAN_LOG_RAW_ITEM_T) 分配，若这两个常量取"多 ID × 多条"的量级，极可能越界踩到相邻 SDRAM 段。必须向代码维护者确认头文件与容量。
4. 编译期与运行期的逆变器类型不一致导致的分支差异。本快照 midware/inverter/inverter.h:172 中 INVERTER_TYPE == INVERTER_NULL(0)：
   • #if (INVERTER_TYPE == INOVANCE_TYPE) 段（:4178-4334）整体不编译，g_t_fault_scord_data 也无定义，但 net/ems.h:502/517/518 无条件 extern/声明、midware/inverter/inovance/inovance_comm_usart.c 会调用 → 声明与定义不匹配；
   • :626-631 的老化模式分支里，s32_bms_total_power = inverter_read_bat_power(); 被 #if ((INVERTER_TYPE == INVERTER_MAX) || (INVERTER_TYPE == ALPHAESS_TYPE)) 编译掉，若运行期 get_inverter_type() 判定为 ALPHAESS_TYPE 且 ControlMode == AGING_MODE，s32_bms_total_power 恒为 0（Pbat 字段会误报 0）；
   • :819-841 的两个 PcsPara8..12 分支按编译期宏互斥，可编译的只有"非 ALPHAESS/INOVANCE"分支，因此运行期即使接 AlphaESS 逆变器，上报的也是 s16_dc_* 字段组。
5. 注释与实现不符 / 硬编码魔法数字：
   • :5038 注释写"10*1000 * 1ms = 10s 即每10S发一包数据"，实际条件 SENCOND_60S（60 s）。
   • 欧盟电池法上传周期被硬编码为 l_u32_upload_interval_s = 10 * 60;（:5202），上面两行保留着"按云端下发周期"的注释方案（:5200-5201），导致 ems_get_upload_interval()（:4491）定义后在本文件内没有调用点。
   • :5242 硬编码 600000 ms 作为混搭信息周期；:4978/:4982 的 l_u16_send_running_time = 60/300、:5022 的 >= 300 均为硬编码秒数，未使用 SENCOND_* 常量。
   • :169 g_stEMSInfo.time_ticksenddata = get_rtc_tick() - 300 + 60; 两个无解释常量叠加。
   • :501/506/511 与 :1403/1408/1413 用 abs(功率) < 50 把电表相功率置零（0.01 kW 单位下即 0.5 kW），阈值写死。
   • :776-780 直接把 OVP1/OVP2/UVP1/UVP2/OFP/UFP 的保护定值写成字符串常量上报，而非读取 g_t_inv_info.t_safty_info。
   • :853 用一串 0,0,0,0,0,0,0,0,0,0 补齐 APPErrorCode 数组长度。
6. obtain_event_log_data()（:2414）无调用点（全仓仅本文件出现该名字），属死代码；fill_bat_log_ack()（:2903）、fill_bat_log_data_send()（:4348）分别位于 #if 0（:2895-2936、:4336-4408），其对应的 STATUS_SET_BAT_LOG_CMD / STATUS_SEND_BAT_LOG_DATA 两个 case 也在 #if 0（:6157-6180）内，但 check_idle_process() 仍会返回 STATUS_SET_BAT_LOG_CMD（:4906-4910，未加条件编译）——一旦 g_u8_bat_log_flag 被置真，状态机会落到 default 直接回 IDLE，成为"静默丢弃"的路径。
7. fill_send_fault_record_data() 的 s32 通道按 16 位解析：第二段循环（:4282-4286）传 sizeof(s16) 给 s32_channel（8 个通道），fill_channel_data() 内部按 s16* 取值（:4197-4200），拼出的通道值会被拆成两个半字，数据错误/截断。仅 INOVANCE 编译，但属明显 bug。
8. CAN 日志直接 send() 绕过队列（:6241）：与 task_ethernet 的发送路径并发操作同一 SOCK_TCP_CLIENT；失败时只调 socket_abnormal_handle() 并继续按 10 s 节流重试，不重建连接（真正的重连由以太网任务负责）。
9. 32 位毫秒计数长期回绕：u32TickSendBMSSelfInfo（:5205）、u32TickSendMIXBatInfo（:5242）用 *1000/600000 参与 32 位毫秒比较，约 49.7 天回绕一次；else if(tick > OSTimeGet()) 分支只能在下一次判定后被动修正，不是通用处理。
10. check_idle_process() 的"配置回读闸门"语义容易被误改：:4601 的 if((g_u8RequestConfigFlag == FALSE) || (g_u8appConfigFlag == FALSE)) 实际是"配置未同步完毕才允许业务上报"，两个标志同时为真（即 STATUS_RESPSONED_SET_CONFIG 之后、云端还没回配置的那段时间）会停止所有常规上报（包括心跳与运行数据），仅保留配置回读与升级相关分支。若云端不回配置或回帧被丢，会造成长时间"数据不上报"的现象。
11. clear_info_status() 名字与语义相反（:2736 为 &= 而非 &= ~），正确用法必须传 ~(1<<bit)（net/server.c:6770）；传错会清掉全部其它事件。
12. 未声明为 static 的"内部函数"：get_setup_config_*、全部 fill_*、handle_response_*、request_update_*、respond_*、get_*_data、ems_time_event、app_connect_detect、send_*_data、can_log_*、ems_get_upload_interval、obtain_event_log_data 全部是外部链接且无头文件声明，一旦与其它文件同名（如 fill_channel_data 这类通用名）会静默链接到一起，建议收窄作用域。
13. fill_send_info() 中的 sprintf/switch 分支：INV_UPGRADE_LOG 分支的 switch(g_t_inv_info.t_debug_log.u32_err_reason)（:2512-2565）没有 default 分支，未覆盖的错误码会让 l_s8_temp 保持空串（初始化为 {0}），且多处 sprintf 格式串末尾的逗号处理不一致（ERRNONE~RECVMASTERLASTERR 带逗号、其余不带）；l_s8_temp[128] 与 GET_VARIABLE_NAME 展开的宏名长度需人工确认不会溢出。
14. handle_response_special_cmd() 缩进可疑但语义正确：:2800-2801 的 STATUS_SEND_SET_BAT_BRAND 分支中 l_pu8Temp = SPECIAL_CMD_SET_BAT_BRAND_STR; 缩进与 if/else 不对齐；另有 STATUS_RESPSONED_CAN_SEND 分支（:2802-2803）同样只挂了单语句，容易在后续维护时被误改。
15. fill_system_run_info_extend1() 的逗号依赖：BatMaxCapacity、AClusterStatus、BClusterStatus 三段用"若存在则退逗号"的写法拼装（:1203-1206、:1226、:1245），而函数结尾又无条件 l_u16Len -= 1;（:1249）——当 MID 电表段、A/B 簇段全部不成立时，BatMaxCapacity 段（无条件输出）末尾的逗号会被减掉再接 }，结果仍合法；但这完全是靠"每段都以逗号结尾"的约定成立的，建议补上"是否已写入过内容"的标志位。
16. send_debug_run_info_data() 的 abs(send_debug_run_info_tick - OSTimeGet())（:6652）对 u32 相减结果取 abs（int），超过 INT_MAX 的差值语义不明确；同函数到期时 memset 整个 g_t_debug_run_info，会连带清掉 net/server.c 刚下发的使能配置，形成"下发一次只上报一段时间"的行为，与云端预期需对齐。
17. handle_message_queue() 的类型参数在几处传错（u8Type 仅用于队列/调试记账，不影响发送的字节流，但会让日志与超时判据失真）：:5801（扩展域名应答传 STATUS_SEND_INFO）、:5824、:5837（上传周期、电芯品牌应答都传 STATUS_SEND_INFO）、:6069（STATUS_GET_CONFIG_EXTEND1 却传 STATUS_SET_CONFIG_EXTEND1）、:6209（AFCI 日志传 STATUS_SEND_FAST_FCAS_DATA）。
18. fill_system_grid_ct_sampling_info() 的静态分包序号是文件级状态：static u8 l_u8_sampling_code（:881）从 1 递增到 25 后清零并清 g_server_grid_sampling_curve_t 的发送标志与计数，若中途某包发送失败（入队被丢弃），云端将永久缺少该包，没有补发机制。
19. STATUS_SEND_CAN_LOG_DATA 分支在状态机内声明静态变量（:6230 static u32 s_last_send_tick = 0;），与 check_can_log_upload_task() 里的另一个静态 s_last_check_tick（:6851）互相独立，两者节流周期（10 s 与 25 ms）需同时成立才会真正发帧，调参时容易顾此失彼。