|
|
|
@ -80,12 +80,13 @@ 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) |
|
|
|
{ |
|
|
|
decoded_PV=decoded_PV_variable; |
|
|
|
MsgCenter_SendTo(MODULE_NAME_CUSTOM, CUSTOM_GET_PV, (void *)&decoded_PV, sizeof(decoded_PV)); |
|
|
|
MsgCenter_SendTo(MODULE_NAME_DAEMON, DAEMON_SET_MK32_SERIAL, NULL, 0); |
|
|
|
} |
|
|
|
} |
|
|
|
else if (*(_pBuffer + 2) == 0x02 && *(_pBuffer + 3) == 0x01) //设置PV
|
|
|
|
|