zhangzengfei
2023-01-13 e783dc858cbf3370c80a46b6bfef6d14580b6764
util.h
@@ -8,15 +8,15 @@
#include "google/protobuf/util/type_resolver.h"
#include "google/protobuf/util/type_resolver_util.h"
#include "google/protobuf/message.h"
#include "google/protobuf/compiler/importer.h"
#include "google/protobuf/descriptor.h"
#include "google/protobuf/descriptor.pb.h"
#include "google/protobuf/dynamic_message.h"
#include "google/protobuf/compiler/importer.h"
#include "google/protobuf/message.h"
#include "3rdparty/yyjson/yyjson.h"
#include "3rdparty/bus_client/cbhomeclient.h"
#include "3rdparty/bus_client/message.h"
#include "3rdparty/yyjson/yyjson.h"
#include "proto/x86_64/sysset.pb.h"
#include <vector>
@@ -32,8 +32,8 @@
extern "C" int bus_dbapi_get_json_data(const char * json, char ** pptr_data, uint8_t *ptr_type);
bool bus_dbapi_get_str(void *handle, const char* topic, char **pptr_str);
int get_value_by_key(char *json, const char *key, char **pptr_data);
template <class T>  bool bus_dbapi_get_list (char *json, T & list)
{
template <class T>
bool bus_dbapi_get_list(char *json, T &list) {
   char * ptr_value = NULL;
   size_t data_len = 0;
    //get the topic json data
@@ -47,14 +47,12 @@
    char* msgdata = (char *)malloc(msglen);
    memset(msgdata, 0 , msglen);
    if(0 == bus_dbapi_get_json_data(json, &msgdata, &type))
    {
    if (0 == bus_dbapi_get_json_data(json, &msgdata, &type)) {
        printf("======>> protomsg: %s\n", msgdata);            
    }
    //iterate the array  to get the protobuf message
   if (YYJSON_TYPE_ARR == type)
   {
    if (YYJSON_TYPE_ARR == type) {
        printf("======>> deal the ARRAY\n"); 
      // Read JSON and get root
@@ -65,21 +63,17 @@
      yyjson_val *val;
      yyjson_arr_iter iter;
      yyjson_arr_iter_init(arr, &iter);
      while ((val = yyjson_arr_iter_next(&iter)))
      {
        while ((val = yyjson_arr_iter_next(&iter))) {
         data_len = 0;
         ptr_value = yyjson_val_write(val, YYJSON_WRITE_NOFLAG, &data_len); 
         printf("data: %s\n", ptr_value);   
         printf("len: %lu\n", data_len);  
         std::string jsonString = ptr_value;         
         if (json_to_proto(jsonString, t))
         {
            if (json_to_proto(jsonString, t)) {
            printf("======>> json_to_proto done\n");
            list.push_back(t);
         }
         else
         {
            } else {
            printf("======>> json_to_proto fail\n");
             yyjson_doc_free(doc);      
             free(msgdata);            
@@ -96,14 +90,13 @@
    return true;
template <class T>  bool bus_dbapi_get_list (void *handle, const char* topic, T & list)
{
template <class T>
bool bus_dbapi_get_list(void *handle, const char *topic, T &list) {
   crepmsg *repmsg = NULL;
    size_t len = 0;
   bool iRet = false;
   iRet = bus_dbapi_get_topic_data(handle, topic, &repmsg, len);
   if ( (false == iRet)|| (NULL == repmsg))
   {
    if ((false == iRet) || (NULL == repmsg)) {
       return false;
   }