void SerialApp_ProcessMSGCmd( afIncomingMSGPacket_t *pkt ){ uint8 stat; uint8 seqnb; uint8 delay; switch ( pkt->clusterId ) { // A message with a serial data block to be transmitted on the serial port. case SERIALAPP_CLUSTERID1: // Store the address for sending and retrying. osal_memcpy(&SerialApp_RxAddr, &(pkt->srcAddr), sizeof( afAddrType_t )); seqnb = pkt->cmd.Data[0]; // Keep message if not a repeat packet if ( (seqnb > SerialApp_RxSeq) || // Normal ((seqnb < 0x80 ) && ( SerialApp_RxSeq > 0x80)) ) // Wrap-around { // Transmit the data on the serial port. if ( HalUARTWrite( SERIAL_APP_PORT, pkt->cmd.Data+1, (pkt->cmd.DataLength-1) ) ) { // Save for next incoming message SerialApp_RxSeq = seqnb; stat = OTA_SUCCESS; } else { stat = OTA_SER_BUSY; } } else { stat = OTA_DUP_MSG; } // Select approproiate OTA flow-control delay. delay = (stat == OTA_SER_BUSY) ? SERIALAPP_NAK_DELAY : SERIALAPP_ACK_DELAY; // Build & send OTA response message. SerialApp_RspBuf[0] = stat; SerialApp_RspBuf[1] = seqnb; SerialApp_RspBuf[2] = LO_UINT16( delay ); SerialApp_RspBuf[3] = HI_UINT16( delay ); osal_set_event( SerialApp_TaskID, SERIALAPP_RESP_EVT ); osal_stop_timerEx(SerialApp_TaskID, SERIALAPP_RESP_EVT); break; // A response to a received serial data block. case SERIALAPP_CLUSTERID2: if ((pkt->cmd.Data[1] == SerialApp_TxSeq) && ((pkt->cmd.Data[0] == OTA_SUCCESS) || (pkt->cmd.Data[0] == OTA_DUP_MSG))) { SerialApp_TxLen = 0; osal_stop_timerEx(SerialApp_TaskID, SERIALAPP_SEND_EVT); } else { // Re-start timeout according to delay sent from other device. delay = BUILD_UINT16( pkt->cmd.Data[2], pkt->cmd.Data[3] ); osal_start_timerEx( SerialApp_TaskID, SERIALAPP_SEND_EVT, delay ); } break; case SERIALAPP_CONNECTREQ_CLUSTER: SerialApp_ConnectReqProcess((uint8*)pkt->cmd.Data); case SERIALAPP_CONNECTRSP_CLUSTER: SerialApp_DeviceConnectRsp((uint8*)pkt->cmd.Data); default: break; }}每行代码注释

以下是对每行代码的注释：

void SerialApp_ProcessMSGCmd( afIncomingMSGPacket_t *pkt ){
  uint8 stat;  // OTA响应状态
  uint8 seqnb; // 序列号
  uint8 delay; // 延迟时间
  switch ( pkt->clusterId ) {
    // 一个包含要在串行端口上传输的串行数据块的消息。
    case SERIALAPP_CLUSTERID1:
      // 存储地址以便发送和重试。
      osal_memcpy(&SerialApp_RxAddr, &(pkt->srcAddr), sizeof( afAddrType_t ));
      seqnb = pkt->cmd.Data[0]; // 获取序列号
      // 如果不是重复的数据包，则保留消息。
      if ( (seqnb > SerialApp_RxSeq) || ((seqnb < 0x80 ) && ( SerialApp_RxSeq > 0x80)) ) {
        // 在串行端口上传输数据。
        if ( HalUARTWrite( SERIAL_APP_PORT, pkt->cmd.Data+1,  (pkt->cmd.DataLength-1) ) ) {
          // 保存下一个传入消息
          SerialApp_RxSeq = seqnb;
          stat = OTA_SUCCESS;
        } else {
          stat = OTA_SER_BUSY;
        }
      } else {
        stat = OTA_DUP_MSG;
      }
      // 选择适当的OTA流控延迟。
      delay = (stat == OTA_SER_BUSY) ? SERIALAPP_NAK_DELAY : SERIALAPP_ACK_DELAY;
      // 构建并发送OTA响应消息。
      SerialApp_RspBuf[0] = stat;
      SerialApp_RspBuf[1] = seqnb;
      SerialApp_RspBuf[2] = LO_UINT16( delay );
      SerialApp_RspBuf[3] = HI_UINT16( delay );
      osal_set_event( SerialApp_TaskID, SERIALAPP_RESP_EVT );
      osal_stop_timerEx(SerialApp_TaskID, SERIALAPP_RESP_EVT);
      break;
    // 对接收到的串行数据块的响应。
    case SERIALAPP_CLUSTERID2:
      if ((pkt->cmd.Data[1] == SerialApp_TxSeq) && ((pkt->cmd.Data[0] == OTA_SUCCESS) || (pkt->cmd.Data[0] == OTA_DUP_MSG))) {
        SerialApp_TxLen = 0;
        osal_stop_timerEx(SerialApp_TaskID, SERIALAPP_SEND_EVT);
      } else {
        // 根据从其他设备发送的延迟重新启动超时。
        delay = BUILD_UINT16( pkt->cmd.Data[2], pkt->cmd.Data[3] );
        osal_start_timerEx( SerialApp_TaskID, SERIALAPP_SEND_EVT, delay );
      }
      break;
    case SERIALAPP_CONNECTREQ_CLUSTER:
      SerialApp_ConnectReqProcess((uint8*)pkt->cmd.Data);
    case SERIALAPP_CONNECTRSP_CLUSTER:
      SerialApp_DeviceConnectRsp((uint8*)pkt->cmd.Data);
    default:
      break;
  }
}

希望对您有所帮助！