|
|
|
@ -80,8 +80,6 @@ void decode_PV(const char *_pBuffer, uint32_t _iSize) |
|
|
|
|
|
|
|
i_pv_stream = pb_istream_from_buffer((const pb_byte_t *)&_pBuffer[4], _iSize - 6); |
|
|
|
pb_decode(&i_pv_stream, PV_struct_define_fields, &decoded_PV_variable); |
|
|
|
MsgCenter_SendTo(MODULE_NAME_DAEMON, DAEMON_SET_MK32_SERIAL, NULL, 0); |
|
|
|
MsgCenter_SendTo(MODULE_NAME_DAEMON, DAEMON_SET_MK32_UDP, NULL, 0);// udp还没实现这里先防止报错
|
|
|
|
|
|
|
|
if(decoded_PV_variable.TimeStamp>decoded_PV.TimeStamp) |
|
|
|
{ |
|
|
|
@ -128,6 +126,8 @@ static void SendIV_ModuleHandler(const Msg_t *pstMsg) |
|
|
|
g_IV_buffer[IV_o_stream.bytes_written + 2] = (crc>>8) &0xff; |
|
|
|
g_IV_buffer[IV_o_stream.bytes_written + 3] = crc & 0xff;; |
|
|
|
|
|
|
|
MsgCenter_SendTo(MODULE_NAME_DAEMON, DAEMON_SET_MK32_SERIAL, NULL, 0); |
|
|
|
MsgCenter_SendTo(MODULE_NAME_DAEMON, DAEMON_SET_MK32_UDP, NULL, 0);// udp还没实现这里先防止报错
|
|
|
|
rd_ComSend(g_ptlpuart, g_IV_buffer, IV_o_stream.bytes_written + 4); |
|
|
|
} |
|
|
|
break; |
|
|
|
|