123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385 |
- #include "plt.h"
- struct station_t STA;
- int plt_init_ctndb()
- {
- int ret = 0;
- int rc = 0;
- char buf[128];
- sprintf(buf, "../cfg/ctn.db");
- if (access(buf, 0) < 0)
- {
- log_dbg("%s, access ctn cfg db fail, path:%s", __func__, buf);
- ret = -1;
- }
- else
- {
- rc = sqlite3_open(buf, &STA.cfg_db);
- if (rc == SQLITE_OK)
- {
- pthread_mutex_init(&STA.cfg_db_mutex, NULL);
- }
- else
- {
- ret = -2;
- }
- }
- log_dbg("%s, ret:%d", __func__, ret);
- return ret;
- }
- sqlite3 *plt_get_ctndb()
- {
- return STA.cfg_db;
- }
- void plt_lock_ctndb()
- {
- pthread_mutex_lock(&STA.cfg_db_mutex);
- }
- void plt_unlock_ctndb()
- {
- pthread_mutex_unlock(&STA.cfg_db_mutex);
- }
- int plt_init_projdb()
- {
- int ret = 0;
- int rc = 0;
- char buf[128];
- sprintf(buf, "../cfg/project.db");
- if (access(buf, 0) < 0)
- {
- log_dbg("%s, access ctn project db fail, path:%s", __func__, buf);
- ret = -1;
- }
- else
- {
- rc = sqlite3_open(buf, &STA.proj_db);
- if (rc == SQLITE_OK)
- {
- pthread_mutex_init(&STA.proj_db_mutex, NULL);
- }
- else
- {
- ret = -2;
- }
- }
- log_dbg("%s, ret:%d", __func__, ret);
- return ret;
- }
- void plt_lock_projdb()
- {
- pthread_mutex_lock(&STA.proj_db_mutex);
- }
- void plt_unlock_projdb()
- {
- pthread_mutex_unlock(&STA.proj_db_mutex);
- }
- sqlite3 *plt_get_projdb()
- {
- return STA.proj_db;
- }
- int plt_init_devdb()
- {
- int ret = 0;
- int rc = 0;
- char buf[128];
- sprintf(buf, "../cfg/dev.db");
- if (access(buf, 0) < 0)
- {
- log_dbg("%s, access dev db fail, path:%s", __func__, buf);
- ret = -1;
- }
- else
- {
- rc = sqlite3_open(buf, &STA.dev_db);
- if (rc == SQLITE_OK)
- {
- pthread_mutex_init(&STA.dev_db_mutex, NULL);
- }
- else
- {
- ret = -2;
- }
- }
- log_dbg("%s, ret:%d", __func__, ret);
- return ret;
- }
- void plt_lock_devdb()
- {
- pthread_mutex_lock(&STA.dev_db_mutex);
- }
- void plt_unlock_devdb()
- {
- pthread_mutex_unlock(&STA.dev_db_mutex);
- }
- sqlite3 *plt_get_devdb()
- {
- return STA.dev_db;
- }
- extern int VERSION[3];
- static char version_string[256];
- int plt_init()
- {
- syslog(LOG_INFO, "%s, ++", __func__);
- int ret = 0;
- time_t t = VERSION[1];
- struct tm *p = localtime(&t);
- sprintf(version_string, "%07x-%d build time: %s", VERSION[0], VERSION[2], asctime(p));
- snow_config_t config = {
- .interface = NULL,
- .timestamp_path = "./timestamp.out",
- .allowable_downtime = 2592000000,
- };
- snow_init(&config);
- syslog(LOG_INFO, "%s, --, ret:%d", __func__, ret);
- return ret;
- }
- /*
- int plt_init_stp1()
- {
- int ret = 0;
- syslog(LOG_INFO,"%s, ++",__func__);
- memset(&STA,0,sizeof(struct station_t));
- STA.version[0] = VERSION[0];
- STA.version[1] = VERSION[1];
- STA.version[2] = VERSION[2];
- sprintf(version_string, "%d.%d.%d", VERSION[0], VERSION[1], VERSION[2]);
- if(log_init() != 0){
- ret = -1;
- }else if( shm_init()!=0 ){
- ret = -2;
- }else if( cfg_db_init()!=0 ){
- ret = -3;
- }else if( ctn_init() != 0){
- ret = -4;
- }else if( pcs_init()!=0 ){
- ret = -5;
- }else if( pack_init()!=0 ){
- ret = -6;
- }else if( meter_init()!=0 ){
- ret = -7;
- }else if( ac_init()!=0 ){
- ret = -8;
- }else if( env_init()!=0 ){
- ret = -9;
- }else if( plc_init()!=0 ){
- ret = -10;
- }else if( ups_init()!=0 ){
- ret = -11;
- }
- syslog(LOG_INFO,"%s, --, ret:%d",__func__,ret);
- return ret;
- }
- */
- int plt_init_stp2()
- {
- int ret = 0;
- log_dbg("%s, ++", __func__);
- if (chan_init() != 0)
- {
- ret = -1;
- }
- else if (mqtt_init() != 0)
- { /* mqtt_init() != 0 */
- ret = -1;
- }
- else if (mac_init() != 0)
- {
- ret = -1;
- }
- log_dbg("%s, --, ret:%d", __func__, ret);
- return ret;
- }
- int plt_devm_str2nbr(char *szdev_model)
- {
- int devm = DEVM_INVALID;
- if (strcmp(szdev_model, "cess2000") == 0)
- {
- devm = DEVM_CESS2000;
- }
- else if (strcmp(szdev_model, "ies1000") == 0)
- {
- devm = DEVM_IES1000;
- }
- else if (strcmp(szdev_model, "catl280a") == 0)
- {
- devm = DEVM_CATL280A;
- }
- else if (strcmp(szdev_model, "dtsd1352") == 0)
- {
- devm = DEVM_DTSD1352;
- }
- else if (strcmp(szdev_model, "dlt645") == 0)
- {
- devm = DEVM_DLT645;
- }
- else if (strcmp(szdev_model, "simatic_s7") == 0)
- {
- devm = DEVM_SIMATIC_S7;
- }
- else if (strcmp(szdev_model, "mc90hdnc1a") == 0)
- {
- devm = DEVM_MC90HDNC1A;
- }
- else if (strcmp(szdev_model, "rs_ws_n") == 0)
- {
- devm = DEVM_RS_WS_N;
- }
- else if (strcmp(szdev_model, "sga500e") == 0)
- {
- devm = DEVM_SGA500E;
- }
- else if (strcmp(szdev_model, "e3ks") == 0)
- {
- devm = DEVM_E3KS;
- }
- else if (strcmp(szdev_model, "abb_b23_4") == 0)
- {
- devm = DEVM_ABB_B23_4;
- }
- else if (strcmp(szdev_model, "kelie") == 0)
- {
- devm = DEVM_KL;
- }
- else if (strcmp(szdev_model, "it6000") == 0)
- {
- devm = DEVM_IT6000;
- }
- else if (strcmp(szdev_model, "cell280") == 0)
- {
- devm = DEVM_CELL280;
- }
- else if (strcmp(szdev_model, "pws1") == 0)
- {
- devm = DEVM_PWS1;
- }
- else if (strcmp(szdev_model, "n9") == 0)
- {
- devm = DEVM_N9;
- }
- else if (strcmp(szdev_model, "gt") == 0)
- {
- devm = DEVM_GT_BMS;
- }
- else if (strcmp(szdev_model, "mc0051gs") == 0)
- {
- devm = DEVM_MC0051GS;
- }
- else if (strcmp(szdev_model, "rh811ad053f") == 0)
- {
- devm = DEVM_RH811AD053F;
- }
- else if (strcmp(szdev_model, "sdcs") == 0)
- {
- devm = DEVM_SDCS;
- }
- else if (strcmp(szdev_model, "cd1f3300") == 0)
- {
- devm = DEVM_CD1F3300;
- }
- else if (strcmp(szdev_model, "adl200") == 0)
- {
- devm = DEVM_ADL200;
- }
- else if (strcmp(szdev_model, "zh200") == 0)
- {
- devm = DEVM_ZH200;
- }
- else if (strcmp(szdev_model, "yf2825") == 0)
- {
- devm = DEVM_YF2825;
- }
- else if (strcmp(szdev_model, "rs311") == 0)
- {
- devm = DEVM_RS311;
- }
- else if (strcmp(szdev_model, "cw1310") == 0)
- {
- devm = DEVM_CW1310;
- }
- else if (strcmp(szdev_model, "zlgmcu") == 0)
- {
- devm = DEVM_ZLGMCU_DIDO;
- }
- else if (strcmp(szdev_model, "tongfei") == 0)
- {
- devm = DEVM_TONGFEI;
- }
- else if (strcmp(szdev_model, "evc") == 0)
- {
- devm = DEVM_EVC;
- }
- else
- {
- devm = DEVM_INVALID;
- }
- return devm;
- }
- char *plt_get_version_string()
- {
- return version_string;
- }
- static char buf[1024] = {0};
- char *plt_get_hostname()
- {
- if (strlen(buf) == 0)
- {
- if (gethostname(buf, sizeof(buf)) != 0)
- {
- strcpy(buf, "unknown");
- }
- }
- return buf;
- }
- int plt_get_devid_prefix(char *buf)
- {
- if (buf == NULL)
- {
- return -1;
- }
- if (sprintf(buf, "%s", plt_get_hostname()) > 0)
- {
- return 0;
- }
- else
- {
- return -1;
- }
- }
|