[Improve][DM30][DW30][OCPP]: Change the function place of OCPP database related functions.

2020.06.16 / TC Hsu

Actions: Sync the place of SQLite3 related functions same as alston's application code, include DB_Open(), DB_Insert_Record() and DB_Update_Operactive() function.

Image version    : N/A
Image checksum   : N/A

Hardware PWB P/N : N/A
Hardware Version : N/A

Files:

	modified:   EVSE/Projects/DM30/Apps/main.c
	modified:   EVSE/Projects/DW30/Apps/main.c

EVSE/Projects/DM30/Apps/main.c

@@ -138,191 +138,6 @@ char* fwVersion = "D5.14.00.0000.00";
 sqlite3 *localDb;
 bool isDb_ready;
 
-int DB_Open(sqlite3 *db)
-{
-    int result = PASS;
-    char* errMsg = NULL;
-    char* createRecordSql = "CREATE TABLE IF NOT EXISTS charging_record("
-                            "idx integer primary key AUTOINCREMENT, "
-                            "reservationId text, "
-                            "transactionId text, "
-                            "startMethod text, "
-                            "userId text, "
-                            "dateTimeStart text, "
-                            "dateTimeStop text,"
-                            "socStart text, "
-                            "socStop text, "
-                            "chargeEnergy text, "
-                            "stopReason text"
-                            ");";
-
-    char* createCfgSql =    "CREATE TABLE IF NOT EXISTS config ( "
-                            "`idx` INTEGER PRIMARY KEY AUTOINCREMENT, "
-                            "`IsAvailable` TEXT NOT NULL, "
-                            "`connector` INTEGER NOT NULL, "
-                            "`val` TEXT NOT NULL, unique(IsAvailable,connector) on conflict replace);";
-
-    if(sqlite3_open(DB_FILE, &db))
-    {
-        result = FAIL;
-        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
-        sqlite3_close(db);
-    }
-    else
-    {
-        PRINTF_FUNC( "Local charging record database open successfully.\r\n");
-
-        if (sqlite3_exec(db, createRecordSql, 0, 0, &errMsg) != SQLITE_OK)
-        {
-            result = FAIL;
-            PRINTF_FUNC( "Create local charging record table error message: %s\n", errMsg);
-        }
-        else
-        {
-            PRINTF_FUNC( "Opened local charging record table successfully\n");
-        }
-
-        if (sqlite3_exec(db, createCfgSql, 0, 0, &errMsg) != SQLITE_OK)
-        {
-            result = FAIL;
-            PRINTF_FUNC( "Create local config table error message: %s\n", errMsg);
-        }
-        else
-        {
-            PRINTF_FUNC( "Opened local config table successfully\n");
-        }
-
-        sqlite3_close(db);
-    }
-
-    return result;
-}
-
-int DB_Insert_Record(sqlite3 *db, int gun_index)
-{
-    int result = PASS;
-    char* errMsg = NULL;
-    char insertSql[1024];
-
-    sprintf(insertSql, "insert into charging_record(reservationId, transactionId, startMethod, userId, dateTimeStart, dateTimeStop, socStart, socStop, chargeEnergy, stopReason) "
-            "values('%d', '%d', '%d', '%s', '%s', '%s', '%d', '%d', '%f', '%s');",
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].ReservationId,
-            ShmOCPP16Data->StartTransaction[gun_index].ResponseTransactionId,
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StartMethod,
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StartUserId,
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StartDateTime,
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StopDateTime,
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].EvBatterySoc,
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].EvBatterySoc,
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].PresentChargedEnergy,
-            ShmOCPP16Data->StopTransaction[gun_index].StopReason);
-
-    if(sqlite3_open("/Storage/ChargeLog/localCgargingRecord.db", &db))
-    {
-        result = FAIL;
-        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
-        sqlite3_close(db);
-    }
-    else
-    {
-        PRINTF_FUNC( "Local charging record database open successfully.\r\n");
-        if (sqlite3_exec(db, insertSql, 0, 0, &errMsg) != SQLITE_OK)
-        {
-            result = FAIL;
-            PRINTF_FUNC( "Insert local charging record error message: %s\n", errMsg);
-        }
-        else
-        {
-            PRINTF_FUNC( "Insert local charging record successfully\n");
-        }
-        sqlite3_close(db);
-    }
-
-    return result;
-}
-
-int DB_Update_Operactive(sqlite3 *db, uint8_t gun_index, uint8_t IsAvailable)
-{
-    uint8_t result = false;
-    char* errMsg = NULL;
-    char sqlStr[1024];
-    srand(time(NULL));
-
-    if(sqlite3_open(DB_FILE, &db))
-    {
-        result = FAIL;
-        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
-        sqlite3_close(db);
-    }
-    else
-    {
-        PRINTF_FUNC( "Local charging record database open successfully.\r\n");
-
-        sprintf(sqlStr, "insert or replace into config (IsAvailable, connector, val) values('IsAvailable', %d, %d);", gun_index, IsAvailable);
-
-        PRINTF_FUNC("sqlStr= %s\r\n", sqlStr);
-
-        if (sqlite3_exec(db, sqlStr, 0, 0, &errMsg) != SQLITE_OK)
-        {
-            result = FAIL;
-            PRINTF_FUNC( "update config error message: %s\n", errMsg);
-        }
-        else
-        {
-            PRINTF_FUNC("update connector-%d config item isOperactive to %d\r\n", gun_index, IsAvailable);
-        }
-
-        sqlite3_close(db);
-    }
-
-    return result;
-}
-
-int DB_Get_Operactive(sqlite3 *db, uint8_t gun_index)
-{
-    uint8_t result = true;
-    char* errMsg = NULL;
-    char sqlStr[1024];
-    char **rs;
-    int  rows, cols;
-
-    sprintf(sqlStr, "select * from config where IsAvailable='IsAvailable' and connector=%d;", gun_index);
-    //DEBUG_INFO("sqlStr= %s\r\n", sqlStr);
-
-    if(sqlite3_open(DB_FILE, &db))
-    {
-        result = FAIL;
-        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
-        sqlite3_close(db);
-    }
-    else
-    {
-        PRINTF_FUNC( "Local config query database open successfully.\r\n");
-        sqlite3_get_table(db, sqlStr, &rs, &rows, &cols, &errMsg);
-
-        if(rows>0)
-        {
-            for(int idxRow=1;idxRow<=rows;idxRow++)
-            {
-                if(strcmp(rs[(idxRow*cols)+3], "0") == 0)
-                {
-                    result = false;
-                }
-                PRINTF_FUNC("Query connector-%d isOperactive: %s\r\n", gun_index, rs[(idxRow*cols)+3]);
-            }
-        }
-        else
-        {
-            PRINTF_FUNC("Query connector-%d fail, set default value to operactive.\r\n", gun_index);
-        }
-
-        sqlite3_free_table(rs);
-        sqlite3_close(db);
-    }
-
-    return result;
-}
-
 //================================================
 // initial can-bus
 //================================================
@@ -4092,6 +3907,191 @@ bool CheckBackendChargingEnergy(byte gunIndex)
     return result;
 }
 
+//===============================================
+// SQLite3 related routine
+//===============================================
+int DB_Open(sqlite3 *db)
+{
+    int result = PASS;
+    char* errMsg = NULL;
+    char* createRecordSql="CREATE TABLE IF NOT EXISTS charging_record("
+                          "idx integer primary key AUTOINCREMENT, "
+                          "reservationId text, "
+                          "transactionId text, "
+                          "startMethod text, "
+                          "userId text, "
+                          "dateTimeStart text, "
+                          "dateTimeStop text,"
+                          "socStart text, "
+                          "socStop text, "
+                          "chargeEnergy text, "
+                          "stopReason text"
+                          ");";
+
+    char* createCfgSql="CREATE TABLE IF NOT EXISTS `config` ( "
+                       "`idx` INTEGER PRIMARY KEY AUTOINCREMENT, "
+                       "`IsAvailable` TEXT NOT NULL, "
+                       "`connector` INTEGER NOT NULL, "
+                       "`val` TEXT NOT NULL, unique(IsAvailable,connector) on conflict replace);";
+
+    if(sqlite3_open(DB_FILE, &db))
+    {
+        result = FAIL;
+        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
+        sqlite3_close(db);
+    }
+    else
+    {
+        PRINTF_FUNC( "Local charging record database open successfully.\r\n");
+
+        if (sqlite3_exec(db, createRecordSql, 0, 0, &errMsg) != SQLITE_OK)
+        {
+            result = FAIL;
+            PRINTF_FUNC( "Create local charging record table error message: %s\n", errMsg);
+        }
+        else
+        {
+            PRINTF_FUNC( "Opened local charging record table successfully\n");
+        }
+
+        if (sqlite3_exec(db, createCfgSql, 0, 0, &errMsg) != SQLITE_OK)
+        {
+            result = FAIL;
+            PRINTF_FUNC( "Create local config table error message: %s\n", errMsg);
+        }
+        else
+        {
+            PRINTF_FUNC( "Opened local config table successfully\n");
+        }
+
+        sqlite3_close(db);
+    }
+
+    return result;
+}
+
+int DB_Insert_Record(sqlite3 *db, int gun_index)
+{
+    int result = PASS;
+    char* errMsg = NULL;
+    char insertSql[1024];
+
+    sprintf(insertSql, "insert into charging_record(reservationId, transactionId, startMethod, userId, dateTimeStart, dateTimeStop, socStart, socStop, chargeEnergy, stopReason) "
+                       "values('%d', '%d', '%d', '%s', '%s', '%s', '%d', '%d', '%f', '%s');",
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].ReservationId,
+                       ShmOCPP16Data->StartTransaction[gun_index].ResponseTransactionId,
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StartMethod,
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StartUserId,
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StartDateTime,
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StopDateTime,
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].EvBatterySoc,
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].EvBatterySoc,
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].PresentChargedEnergy,
+                       ShmOCPP16Data->StopTransaction[gun_index].StopReason);
+
+    if(sqlite3_open("/Storage/ChargeLog/localCgargingRecord.db", &db))
+    {
+        result = FAIL;
+        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
+        sqlite3_close(db);
+    }
+    else
+    {
+        PRINTF_FUNC( "Local charging record database open successfully.\r\n");
+        if (sqlite3_exec(db, insertSql, 0, 0, &errMsg) != SQLITE_OK)
+        {
+            result = FAIL;
+            PRINTF_FUNC( "Insert local charging record error message: %s\n", errMsg);
+        }
+        else
+        {
+            PRINTF_FUNC( "Insert local charging record successfully\n");
+        }
+        sqlite3_close(db);
+    }
+
+    return result;
+}
+
+int DB_Update_Operactive(sqlite3 *db, uint8_t gun_index, uint8_t IsAvailable)
+{
+    uint8_t result = false;
+    char* errMsg = NULL;
+    char sqlStr[1024];
+    srand(time(NULL));
+
+    if(sqlite3_open(DB_FILE, &db))
+    {
+        result = FAIL;
+        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
+        sqlite3_close(db);
+    }
+    else
+    {
+        PRINTF_FUNC( "Local charging record database open successfully (%d).\r\n", IsAvailable);
+
+        sprintf(sqlStr, "insert or replace into config (IsAvailable, connector, val) values('IsAvailable', %d, %d);", gun_index, IsAvailable);
+        PRINTF_FUNC("sqlStr= %s\r\n", sqlStr);
+        if (sqlite3_exec(db, sqlStr, 0, 0, &errMsg) != SQLITE_OK)
+        {
+            result = FAIL;
+            PRINTF_FUNC( "update config error message: %s\n", errMsg);
+        }
+        else
+        {
+            PRINTF_FUNC("update connector-%d config item isOperactive to %d\r\n", gun_index, IsAvailable);
+        }
+
+        sqlite3_close(db);
+    }
+
+    return result;
+}
+
+int DB_Get_Operactive(sqlite3 *db, uint8_t gun_index)
+{
+    uint8_t result = true;
+    char* errMsg = NULL;
+    char sqlStr[1024];
+    char **rs;
+    int  rows, cols;
+
+    sprintf(sqlStr, "select * from config where IsAvailable='IsAvailable' and connector=%d;", gun_index);
+    //DEBUG_INFO("sqlStr= %s\r\n", sqlStr);
+
+    if(sqlite3_open(DB_FILE, &db))
+    {
+        result = FAIL;
+        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
+        sqlite3_close(db);
+    }
+    else
+    {
+        PRINTF_FUNC( "Local config query database open successfully.\r\n");
+        sqlite3_get_table(db, sqlStr, &rs, &rows, &cols, &errMsg);
+        if(rows>0)
+        {
+            for(int idxRow=1;idxRow<=rows;idxRow++)
+            {
+                if(strcmp(rs[(idxRow*cols)+3], "0") == 0)
+                {
+                    result = false;
+                }
+                PRINTF_FUNC("Query connector-%d isOperactive: %s\r\n", gun_index, rs[(idxRow*cols)+3]);
+            }
+        }
+        else
+        {
+            PRINTF_FUNC("Query connector-%d fail, set default value to operactive.\r\n", gun_index);
+        }
+
+        sqlite3_free_table(rs);
+        sqlite3_close(db);
+    }
+
+    return result;
+}
+
 //===============================================
 // Config process
 //===============================================

EVSE/Projects/DW30/Apps/main.c

@@ -138,191 +138,6 @@ char* fwVersion = "D5.14.00.0000.00";
 sqlite3 *localDb;
 bool isDb_ready;
 
-int DB_Open(sqlite3 *db)
-{
-    int result = PASS;
-    char* errMsg = NULL;
-    char* createRecordSql = "CREATE TABLE IF NOT EXISTS charging_record("
-                            "idx integer primary key AUTOINCREMENT, "
-                            "reservationId text, "
-                            "transactionId text, "
-                            "startMethod text, "
-                            "userId text, "
-                            "dateTimeStart text, "
-                            "dateTimeStop text,"
-                            "socStart text, "
-                            "socStop text, "
-                            "chargeEnergy text, "
-                            "stopReason text"
-                            ");";
-
-    char* createCfgSql =    "CREATE TABLE IF NOT EXISTS config ( "
-                            "`idx` INTEGER PRIMARY KEY AUTOINCREMENT, "
-                            "`IsAvailable` TEXT NOT NULL, "
-                            "`connector` INTEGER NOT NULL, "
-                            "`val` TEXT NOT NULL, unique(IsAvailable,connector) on conflict replace);";
-
-    if(sqlite3_open(DB_FILE, &db))
-    {
-        result = FAIL;
-        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
-        sqlite3_close(db);
-    }
-    else
-    {
-        PRINTF_FUNC( "Local charging record database open successfully.\r\n");
-
-        if (sqlite3_exec(db, createRecordSql, 0, 0, &errMsg) != SQLITE_OK)
-        {
-            result = FAIL;
-            PRINTF_FUNC( "Create local charging record table error message: %s\n", errMsg);
-        }
-        else
-        {
-            PRINTF_FUNC( "Opened local charging record table successfully\n");
-        }
-
-        if (sqlite3_exec(db, createCfgSql, 0, 0, &errMsg) != SQLITE_OK)
-        {
-            result = FAIL;
-            PRINTF_FUNC( "Create local config table error message: %s\n", errMsg);
-        }
-        else
-        {
-            PRINTF_FUNC( "Opened local config table successfully\n");
-        }
-
-        sqlite3_close(db);
-    }
-
-    return result;
-}
-
-int DB_Insert_Record(sqlite3 *db, int gun_index)
-{
-    int result = PASS;
-    char* errMsg = NULL;
-    char insertSql[1024];
-
-    sprintf(insertSql, "insert into charging_record(reservationId, transactionId, startMethod, userId, dateTimeStart, dateTimeStop, socStart, socStop, chargeEnergy, stopReason) "
-            "values('%d', '%d', '%d', '%s', '%s', '%s', '%d', '%d', '%f', '%s');",
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].ReservationId,
-            ShmOCPP16Data->StartTransaction[gun_index].ResponseTransactionId,
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StartMethod,
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StartUserId,
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StartDateTime,
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StopDateTime,
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].EvBatterySoc,
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].EvBatterySoc,
-            ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].PresentChargedEnergy,
-            ShmOCPP16Data->StopTransaction[gun_index].StopReason);
-
-    if(sqlite3_open("/Storage/ChargeLog/localCgargingRecord.db", &db))
-    {
-        result = FAIL;
-        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
-        sqlite3_close(db);
-    }
-    else
-    {
-        PRINTF_FUNC( "Local charging record database open successfully.\r\n");
-        if (sqlite3_exec(db, insertSql, 0, 0, &errMsg) != SQLITE_OK)
-        {
-            result = FAIL;
-            PRINTF_FUNC( "Insert local charging record error message: %s\n", errMsg);
-        }
-        else
-        {
-            PRINTF_FUNC( "Insert local charging record successfully\n");
-        }
-        sqlite3_close(db);
-    }
-
-    return result;
-}
-
-int DB_Update_Operactive(sqlite3 *db, uint8_t gun_index, uint8_t IsAvailable)
-{
-    uint8_t result = false;
-    char* errMsg = NULL;
-    char sqlStr[1024];
-    srand(time(NULL));
-
-    if(sqlite3_open(DB_FILE, &db))
-    {
-        result = FAIL;
-        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
-        sqlite3_close(db);
-    }
-    else
-    {
-        PRINTF_FUNC( "Local charging record database open successfully.\r\n");
-
-        sprintf(sqlStr, "insert or replace into config (IsAvailable, connector, val) values('IsAvailable', %d, %d);", gun_index, IsAvailable);
-
-        PRINTF_FUNC("sqlStr= %s\r\n", sqlStr);
-
-        if (sqlite3_exec(db, sqlStr, 0, 0, &errMsg) != SQLITE_OK)
-        {
-            result = FAIL;
-            PRINTF_FUNC( "update config error message: %s\n", errMsg);
-        }
-        else
-        {
-            PRINTF_FUNC("update connector-%d config item isOperactive to %d\r\n", gun_index, IsAvailable);
-        }
-
-        sqlite3_close(db);
-    }
-
-    return result;
-}
-
-int DB_Get_Operactive(sqlite3 *db, uint8_t gun_index)
-{
-    uint8_t result = true;
-    char* errMsg = NULL;
-    char sqlStr[1024];
-    char **rs;
-    int  rows, cols;
-
-    sprintf(sqlStr, "select * from config where IsAvailable='IsAvailable' and connector=%d;", gun_index);
-    //DEBUG_INFO("sqlStr= %s\r\n", sqlStr);
-
-    if(sqlite3_open(DB_FILE, &db))
-    {
-        result = FAIL;
-        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
-        sqlite3_close(db);
-    }
-    else
-    {
-        PRINTF_FUNC( "Local config query database open successfully.\r\n");
-        sqlite3_get_table(db, sqlStr, &rs, &rows, &cols, &errMsg);
-
-        if(rows>0)
-        {
-            for(int idxRow=1;idxRow<=rows;idxRow++)
-            {
-                if(strcmp(rs[(idxRow*cols)+3], "0") == 0)
-                {
-                    result = false;
-                }
-                PRINTF_FUNC("Query connector-%d isOperactive: %s\r\n", gun_index, rs[(idxRow*cols)+3]);
-            }
-        }
-        else
-        {
-            PRINTF_FUNC("Query connector-%d fail, set default value to operactive.\r\n", gun_index);
-        }
-
-        sqlite3_free_table(rs);
-        sqlite3_close(db);
-    }
-
-    return result;
-}
-
 //================================================
 // initial can-bus
 //================================================
@@ -4092,6 +3907,191 @@ bool CheckBackendChargingEnergy(byte gunIndex)
     return result;
 }
 
+//===============================================
+// SQLite3 related routine
+//===============================================
+int DB_Open(sqlite3 *db)
+{
+    int result = PASS;
+    char* errMsg = NULL;
+    char* createRecordSql="CREATE TABLE IF NOT EXISTS charging_record("
+                          "idx integer primary key AUTOINCREMENT, "
+                          "reservationId text, "
+                          "transactionId text, "
+                          "startMethod text, "
+                          "userId text, "
+                          "dateTimeStart text, "
+                          "dateTimeStop text,"
+                          "socStart text, "
+                          "socStop text, "
+                          "chargeEnergy text, "
+                          "stopReason text"
+                          ");";
+
+    char* createCfgSql="CREATE TABLE IF NOT EXISTS `config` ( "
+                       "`idx` INTEGER PRIMARY KEY AUTOINCREMENT, "
+                       "`IsAvailable` TEXT NOT NULL, "
+                       "`connector` INTEGER NOT NULL, "
+                       "`val` TEXT NOT NULL, unique(IsAvailable,connector) on conflict replace);";
+
+    if(sqlite3_open(DB_FILE, &db))
+    {
+        result = FAIL;
+        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
+        sqlite3_close(db);
+    }
+    else
+    {
+        PRINTF_FUNC( "Local charging record database open successfully.\r\n");
+
+        if (sqlite3_exec(db, createRecordSql, 0, 0, &errMsg) != SQLITE_OK)
+        {
+            result = FAIL;
+            PRINTF_FUNC( "Create local charging record table error message: %s\n", errMsg);
+        }
+        else
+        {
+            PRINTF_FUNC( "Opened local charging record table successfully\n");
+        }
+
+        if (sqlite3_exec(db, createCfgSql, 0, 0, &errMsg) != SQLITE_OK)
+        {
+            result = FAIL;
+            PRINTF_FUNC( "Create local config table error message: %s\n", errMsg);
+        }
+        else
+        {
+            PRINTF_FUNC( "Opened local config table successfully\n");
+        }
+
+        sqlite3_close(db);
+    }
+
+    return result;
+}
+
+int DB_Insert_Record(sqlite3 *db, int gun_index)
+{
+    int result = PASS;
+    char* errMsg = NULL;
+    char insertSql[1024];
+
+    sprintf(insertSql, "insert into charging_record(reservationId, transactionId, startMethod, userId, dateTimeStart, dateTimeStop, socStart, socStop, chargeEnergy, stopReason) "
+                       "values('%d', '%d', '%d', '%s', '%s', '%s', '%d', '%d', '%f', '%s');",
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].ReservationId,
+                       ShmOCPP16Data->StartTransaction[gun_index].ResponseTransactionId,
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StartMethod,
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StartUserId,
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StartDateTime,
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].StopDateTime,
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].EvBatterySoc,
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].EvBatterySoc,
+                       ShmSysConfigAndInfo->SysInfo.AcChargingData[gun_index].PresentChargedEnergy,
+                       ShmOCPP16Data->StopTransaction[gun_index].StopReason);
+
+    if(sqlite3_open("/Storage/ChargeLog/localCgargingRecord.db", &db))
+    {
+        result = FAIL;
+        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
+        sqlite3_close(db);
+    }
+    else
+    {
+        PRINTF_FUNC( "Local charging record database open successfully.\r\n");
+        if (sqlite3_exec(db, insertSql, 0, 0, &errMsg) != SQLITE_OK)
+        {
+            result = FAIL;
+            PRINTF_FUNC( "Insert local charging record error message: %s\n", errMsg);
+        }
+        else
+        {
+            PRINTF_FUNC( "Insert local charging record successfully\n");
+        }
+        sqlite3_close(db);
+    }
+
+    return result;
+}
+
+int DB_Update_Operactive(sqlite3 *db, uint8_t gun_index, uint8_t IsAvailable)
+{
+    uint8_t result = false;
+    char* errMsg = NULL;
+    char sqlStr[1024];
+    srand(time(NULL));
+
+    if(sqlite3_open(DB_FILE, &db))
+    {
+        result = FAIL;
+        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
+        sqlite3_close(db);
+    }
+    else
+    {
+        PRINTF_FUNC( "Local charging record database open successfully (%d).\r\n", IsAvailable);
+
+        sprintf(sqlStr, "insert or replace into config (IsAvailable, connector, val) values('IsAvailable', %d, %d);", gun_index, IsAvailable);
+        PRINTF_FUNC("sqlStr= %s\r\n", sqlStr);
+        if (sqlite3_exec(db, sqlStr, 0, 0, &errMsg) != SQLITE_OK)
+        {
+            result = FAIL;
+            PRINTF_FUNC( "update config error message: %s\n", errMsg);
+        }
+        else
+        {
+            PRINTF_FUNC("update connector-%d config item isOperactive to %d\r\n", gun_index, IsAvailable);
+        }
+
+        sqlite3_close(db);
+    }
+
+    return result;
+}
+
+int DB_Get_Operactive(sqlite3 *db, uint8_t gun_index)
+{
+    uint8_t result = true;
+    char* errMsg = NULL;
+    char sqlStr[1024];
+    char **rs;
+    int  rows, cols;
+
+    sprintf(sqlStr, "select * from config where IsAvailable='IsAvailable' and connector=%d;", gun_index);
+    //DEBUG_INFO("sqlStr= %s\r\n", sqlStr);
+
+    if(sqlite3_open(DB_FILE, &db))
+    {
+        result = FAIL;
+        PRINTF_FUNC( "Can't open database: %s\r\n", sqlite3_errmsg(db));
+        sqlite3_close(db);
+    }
+    else
+    {
+        PRINTF_FUNC( "Local config query database open successfully.\r\n");
+        sqlite3_get_table(db, sqlStr, &rs, &rows, &cols, &errMsg);
+        if(rows>0)
+        {
+            for(int idxRow=1;idxRow<=rows;idxRow++)
+            {
+                if(strcmp(rs[(idxRow*cols)+3], "0") == 0)
+                {
+                    result = false;
+                }
+                PRINTF_FUNC("Query connector-%d isOperactive: %s\r\n", gun_index, rs[(idxRow*cols)+3]);
+            }
+        }
+        else
+        {
+            PRINTF_FUNC("Query connector-%d fail, set default value to operactive.\r\n", gun_index);
+        }
+
+        sqlite3_free_table(rs);
+        sqlite3_close(db);
+    }
+
+    return result;
+}
+
 //===============================================
 // Config process
 //===============================================