ctnd/platform/abs/dehumi.c

#include "dehumi.h"
#include "plt.h"

struct dehumi_t dehumi[DEHUMI_NBR_MAX + 1];

static int dehumi_dbcb_0(void *para, int ncolumn, char **columnvalue, char *columnname[])
{
    int i;
    struct dbcbparam_t *pcbparam = (struct dbcbparam_t *)para;
    struct dehumi_t *dev = &dehumi[1];

    pcbparam->nrow++;
    log_dbg("%s, ++,row:%d, col:%d", __func__, pcbparam->nrow, ncolumn);

    for (i = 0; i < ncolumn; i++)
    {
        if (strcmp("model", columnname[i]) == 0)
        {
            strcpy(dev->szmodel, columnvalue[i]);
            dev->model = plt_devm_str2nbr(dev->szmodel);
        }
    }
    dev->model_nbr = 1;

    pcbparam->ret = 0;
    log_dbg("%s, --,ret:%d", __func__, pcbparam->ret);
    return 0;
}

int dehumi_get_model()
{
    return dehumi[1].model;
}

int dehumi_get_init_data(int ctn_idx, char *buf)
{
    int model = dehumi[1].model;
    if (model == DEVM_SDCS)
    {
        return sdcs_get_init_data(ctn_idx, 1, buf);
    }
    else
    {
        return NULL;
    }
}

int dehumi_init()
{
    int result;
    char *errmsg = NULL;
    sqlite3 *db = NULL;
    char sql[1024];
    struct dbcbparam_t cbparam;
    int ret = 0;
    int model = 0;

    log_dbg("%s, ++", __func__);

    plt_lock_ctndb();
    db = plt_get_ctndb();
    sprintf(sql, "select * from dehumi");
    cbparam.nrow = 0;
    result = sqlite3_exec(db, sql, dehumi_dbcb_0, (void *)&cbparam, &errmsg);
    plt_unlock_ctndb();
    if (result != SQLITE_OK)
    {
        log_dbg("%s, result != SQLITE_OK : %d", __func__, result);
        ret = -1;
    }
    else if (cbparam.ret != 0)
    {
        log_dbg("%s, cbparam.ret != 0 : %d", __func__, cbparam.ret);
        ret = -2;
    }
    else if (cbparam.nrow != 1)
    {
        log_dbg("%s, cbparam.nrow != 1 : %d", __func__, cbparam.nrow);
        ret = -3;
    }
    else
    {
        model = dehumi_get_model();
        if (model == DEVM_SDCS)
        {
            sdcs_init();
        }
        else
        {
            log_dbg("%s, unknown model:%d", __func__, model);
            ret = -4;
        }
    }

    log_dbg("%s, --, ret:%d", __func__, ret);
    return ret;
}

// 0 : ok, all device in stat
int dehumi_chk_state_all(int stat)
{
    int model = dehumi[1].model;
    if (model == DEVM_SDCS)
    {
        return sdcs_chk_stat_all(stat);
    }
    else
    {
        return -1;
    }
}

int dehumi_get_comm_st(int idx)
{
    int model = dehumi[1].model;
    if (model == DEVM_SDCS)
    {
        return sdcs_get_comm_st(idx);
    }
    else
    {
        return -1;
    }
}

int dehumi_send_sm_cmd_all(int cmd)
{
    int model = dehumi[1].model;
    if (model == DEVM_SDCS)
    {
        return sdcs_send_sm_cmd_all(cmd);
    }
    else
    {
        return -1;
    }
}

int dehumi_send_sm_cmd(int idx, int cmd)
{
    int model = dehumi[1].model;
    if (model == DEVM_SDCS)
    {
        return sdcs_send_sm_cmd(idx, cmd);
    }
    else
    {
        return -1;
    }
}

// char* dehumi_get_work_stat_str(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_workstat_str(idx );
//     }else{
//         return NULL;
//     }
// }

// int dehumi_get_work_stat(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_workstat(idx );
//     }else{
//         return -1;
//     }
// }

// char* dehumi_get_infan_stat_str(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_infan_stat_str(idx );
//     }else{
//         return NULL;
//     }
// }

// int dehumi_get_infan_stat(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_infan_stat(idx );
//     }else{
//         return -1;
//     }
// }

// char* dehumi_get_outfan_stat_str(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_outfan_stat_str(idx );
//     }else{
//         return NULL;
//     }
// }

// int dehumi_get_outfan_stat(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_outfan_stat(idx );
//     }else{
//         return -1;
//     }
// }

// char* dehumi_get_cmp_stat_str(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_cmp_stat_str(idx );
//     }else{
//         return NULL;
//     }
// }

// int dehumi_get_cmp_stat(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_cmp_stat(idx );
//     }else{
//         return -1;
//     }
// }

// int dehumi_get_rtnwind_temp(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_rtnwind_temp(idx );
//     }else{
//         return -100;
//     }
// }

// int dehumi_get_cond_temp(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_cond_temp(idx );
//     }else{
//         return -100;
//     }
// }

// int dehumi_get_eva_temp(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_eva_temp(idx );
//     }else{
//         return -100;
//     }
// }

// int dehumi_get_infan_spd(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_infan_spd(idx );
//     }else{
//         return -100;
//     }
// }

// int dehumi_get_outfan_spd(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_outfan_spd(idx );
//     }else{
//         return -100;
//     }
// }

// int dehumi_get_comm_st(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_comm_st(idx);
//     }else{
//         return -1;
//     }
// }

// int dehumi_get_nbr()
//  {
//      int model = dehumi[1].model;
//      if( model == DEVM_SDCS ){
//          return sdcs_get_nbr();
//      }else{
//          return -1;
//      }
//  }

// int dehumi_get_state(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_state(idx);
//     }else{
//         return -1;
//     }
// }

char *dehumi_get_model_str(int idx)
{
    return dehumi[idx].szmodel;
}

// int dehumi_get_chan_idx(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_chan_idx(idx);
//     }else{
//         return -1;
//     }
// }

// char* dehumi_get_comm_st_str(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_comm_st_str(idx);
//     }else{
//         return NULL;
//     }
// }

// int dehumi_get_tick(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_tick(idx);
//     }else{
//         return -1;
//     }
// }

// int dehumi_get_addr(int idx)
// {
//     int model = dehumi[1].model;
//     if( model == DEVM_SDCS ){
//         return sdcs_get_addr(idx);
//     }else{
//         return -1;
//     }
// }

int dehumi_get_tool_data(char *buf)
{
    int model = dehumi[1].model;
    int i = 0;
    char temp_buf[2048];
    if (model == DEVM_SDCS)
    {
        sprintf(buf, "" REVERSE "DEHUMI" NONE "model:%s info:%s\n", dehumi[1].szmodel, dehumi[1].szinfo);
        for (i = 1; i <= sdcs_get_nbr(); i++)
        {
            memset(temp_buf, 0, sizeof(temp_buf));
            sdcs_get_tool_data(i, temp_buf);
            strcat(buf, temp_buf);
        }
        return 0;
    }
    else
    {
        return -1;
    }
}

int dehumi_get_tbmqtt_data(char *buf)
{
    for (int i = 1; i <= dehumi[1].model_nbr; i++)
    {
        if (dehumi[1].model == DEVM_SDCS)
        {
            for (int idx = 1; idx <= sdcs_get_nbr(); idx++)
            {
                if (sdcs_get_comm_st(idx) != COMMST_NORMAL)
                {
                    if (i == dehumi[1].model_nbr && idx == sdcs_get_nbr() && strlen(buf) > 1)
                    {
                        buf[strlen(buf) - 1] = 0;
                    }
                    continue;
                }
                char temp_buf[1024];
                memset(temp_buf, 0, sizeof(temp_buf));
                sdcs_get_tbmqtt_data(idx, temp_buf);
                strcat(buf, temp_buf);
                if (i != dehumi[1].model_nbr || idx != sdcs_get_nbr())
                {
                    strcat(buf, ",");
                }
            }
        }
    }
}

int dehumi_get_cloud_data(int ctn_idx, char *buf)
{
    for (int i = 1; i <= dehumi[1].model_nbr; i++)
    {
        if (dehumi[1].model == DEVM_SDCS)
        {
            for (int idx = 1; idx <= sdcs_get_nbr(); idx++)
            {
                if (sdcs_get_comm_st(idx) != COMMST_NORMAL)
                {
                    if (i == dehumi[1].model_nbr && idx == sdcs_get_nbr() && strlen(buf) > 1)
                    {
                        buf[strlen(buf) - 1] = 0;
                    }
                    continue;
                }
                char temp_buf[1024];
                memset(temp_buf, 0, sizeof(temp_buf));
                sdcs_get_cloud_data(ctn_idx, idx, temp_buf);
                strcat(buf, temp_buf);
                if (i != dehumi[1].model_nbr || idx != sdcs_get_nbr())
                {
                    strcat(buf, ",");
                }
            }
        }
    }
}

int dehumi_get_modbus_data(int idx, unsigned short *data)
{
    int model = dehumi[1].model;
    if (model == DEVM_SDCS)
    {
        sdcs_get_modbus_data(idx, data);
    }
    else
    {
        data[0] = (unsigned short)model;
        data[1] = (unsigned short)0;
    }
    return 0;
}

double dehumi_get_temp(int idx)
{
    int model = dehumi[1].model;
    if (model == DEVM_SDCS)
    {
        return sdcs_get_temp(idx);
    }
    else
    {
        return -1;
    }
}

double dehumi_get_humi(int idx)
{
    int model = dehumi[1].model;
    if (model == DEVM_SDCS)
    {
        return sdcs_get_humi(idx);
    }
    else
    {
        return -1;
    }
}
// int dehumi_get_bkds_data(char* buf)
// {
//     int model = dehumi[1].model;
//     int i = 0;
//     char buf_temp[8000];
//     sprintf(buf,"\"dehumi\":[");
//     if( model == DEVM_SDCS ){
//         for(i = 1;i <= sdcs_get_nbr();i ++ ){
//             strcat(buf,"{");
//             sdcs_get_bkds_data(i,buf_temp);
//             strcat(buf,buf_temp);
//             strcat(buf,"}");
//             if(i != sdcs_get_nbr()){
//                 strcat(buf,",");
//             }
//         }
//     }else{
//         return -1;
//     }
//     strcat(buf,"]");
// }