update online mode csv save

Author: hom-wang

CMakeLists.txt

@@ -19,9 +19,9 @@ add_executable(${TARGET_NAME}
 )
 
 add_definitions(
-    -DDEFAULE_LOGFILE="LOG_SAMSUNG_SMG973F_20210722_234221.csv"
-    -DLOGOUT_RELATE_PATH="result/"
-    -DLOGOUT_FILE_TAG="_result"
+    -DONLINE_LOGOUT_RELATE_PATH="result/"
+    -DOFFLINE_LOGOUT_RELATE_PATH="result/"
+    -DOFFLINE_LOGOUT_FILE_TAG="_result"
 )
 
 include_directories(

ksfeeder.c

@@ -58,7 +58,6 @@ int ksfeeder(int index, ksraw_tag_t *raw)
         raw->m[0], raw->m[1], raw->m[2],
         raw->t);
 #endif
-
     // user run process
     // ...
 

main.c

@@ -119,11 +119,11 @@ int main(int argc, char **argv)
             klogd(">> Online Mode ... %s\n", argv[1]);
             int updaterate = DEFAULT_ONLINE_UPDATE_RATE;
             int savelog = KS_FALSE;
-            if (argv[1] != NULL)
+            if (argv[2] != NULL)
             {
                 updaterate = strtoul(argv[2], NULL, 10);
             }
-            if (argv[2] != NULL)
+            if (argv[3] != NULL)
             {
                 savelog = KS_TRUE;
                 klogd("savelog = KS_TRUE\n");

offline.c

@@ -22,20 +22,22 @@
 
 /* Define ----------------------------------------------------------------------------------*/
 
-#ifndef LOGOUT_RELATE_PATH
-#define LOGOUT_RELATE_PATH     "output/"
+#ifndef OFFLINE_LOGOUT_RELATE_PATH
+#define OFFLINE_LOGOUT_RELATE_PATH                      "output/"
 #endif
 
-#ifndef LOGOUT_FILE_TAG
-#define LOGOUT_FILE_TAG         "_output"
+#ifndef OFFLINE_LOGOUT_FILE_TAG
+#define OFFLINE_LOGOUT_FILE_TAG                         "_output"
 #endif
 
 /* Macro -----------------------------------------------------------------------------------*/
 /* Typedef ---------------------------------------------------------------------------------*/
 /* Variables -------------------------------------------------------------------------------*/
 
-static char RelatePath[1024] = {LOGOUT_RELATE_PATH};
-static char OutputFileTag[1024] = {LOGOUT_FILE_TAG};
+static char *LOG[] = {"sn","dt","gx","gy","gz","mx","my","mz","mbx","mby","mbz"};
+
+static char RelatePath[1024] = {OFFLINE_LOGOUT_RELATE_PATH};
+static char OutputFileTag[1024] = {OFFLINE_LOGOUT_FILE_TAG};
 
 /* Prototypes ------------------------------------------------------------------------------*/
 
@@ -89,7 +91,6 @@ int run_offline(char *filename, int *range)
     //     strcpy(OutputFileTag, filetag);
     // }
     // create csv
-    char *LOG[] = {"sn","dt","gx","gy","gz","mx","my","mz","mbx","mby","mbz"};
     if (kscsv_create(&csv, RelatePath, OutputFileTag, LOG, sizeof(LOG) >> 2) != KS_OK)
     {
         klogd("create csv failed !!!\n");

online.c

@@ -17,6 +17,7 @@
 /* Includes --------------------------------------------------------------------------------*/
 #include <stdlib.h>
 #include <conio.h>
+#include <time.h>
 
 #include "serial.h"
 
@@ -26,13 +27,22 @@
 #include "ksfeeder.h"
 
 /* Define ----------------------------------------------------------------------------------*/
+
+#ifndef ONLINE_LOGOUT_RELATE_PATH
+#define ONLINE_LOGOUT_RELATE_PATH                       "log/"
+#endif
+
 /* Macro -----------------------------------------------------------------------------------*/
 /* Typedef ---------------------------------------------------------------------------------*/
 /* Variables -------------------------------------------------------------------------------*/
+
+static char *LOG[] = {"sn","dt","gx","gy","gz","ax","ay","az","mx","my","mz"};
+
 /* Prototypes ------------------------------------------------------------------------------*/
 
+static int datetimestring(char *datestring);
 static void ksraw_update(ksraw_t *praw, kserial_packet_t *pk, int dt);
-static int ksfeed_serial(ksraw_t *raw, kscsv_t *csv, int updaterate);
+static int ksfeed_serial(ksraw_t *raw, kscsv_t *csv, int updaterate, int save);
 
 /* Functions -------------------------------------------------------------------------------*/
 
@@ -73,8 +83,22 @@ int run_online(char *comport, int updaterate, int save)
     }
     klogd(", id=0x%04X\n", id);
 
+    if (save == KS_TRUE)
+    {
+        // create csv
+        char filename[256] = {0};
+        char datestring[256] = {0};
+        datetimestring(datestring);
+        sprintf(filename, "%sLOG_SERIAL_%s.csv", ONLINE_LOGOUT_RELATE_PATH, datestring);
+        if (kscsv_create(&csv, filename, NULL, LOG, sizeof(LOG) >> 2) != KS_OK)
+        {
+            klogd("create csv failed !!!\n");
+            return -1;
+        }
+    }
+
     // run
-    ksfeed_serial(&raw, &csv, updaterate);
+    ksfeed_serial(&raw, &csv, updaterate, save);
 
     // close serial port and free portlist
     serial_close(&s);
@@ -83,7 +107,24 @@ int run_online(char *comport, int updaterate, int save)
     return 0;
 }
 
-static char getKey(void)
+static int datetimestring(char *datestring)
+{
+    time_t t = time(NULL);
+    struct tm ts = *localtime(&t);
+    int lens;
+    int datetime[6] = {0};
+    datetime[0] = ts.tm_year + 1900;
+    datetime[1] = ts.tm_mon + 1;
+    datetime[2] = ts.tm_mday;
+    datetime[3] = ts.tm_hour;
+    datetime[4] = ts.tm_min;
+    datetime[5] = ts.tm_sec;
+    lens = sprintf(datestring, "%04d%02d%02d_%02d%02d%02d",
+        datetime[0], datetime[1], datetime[2], datetime[3], datetime[4], datetime[5]);
+    return lens;
+}
+
+static char getkey(void)
 {
     char ch = 0;
     if (_kbhit())
@@ -116,7 +157,7 @@ static void ksraw_update(ksraw_t *praw, kserial_packet_t *pk, int dt)
     }
 }
 
-static int ksfeed_serial(ksraw_t *raw, kscsv_t *csv, int updaterate)
+static int ksfeed_serial(ksraw_t *raw, kscsv_t *csv, int updaterate, int save)
 {
     int loop = KS_TRUE;
 
@@ -149,6 +190,17 @@ static int ksfeed_serial(ksraw_t *raw, kscsv_t *csv, int updaterate)
             ksraw_update(raw, &pk, dt);
             ksfeeder(raw->raw.index, &raw->raw);
 #endif
+#if 1
+            if ((raw->raw.index > 0) && (save == KS_TRUE))
+            {
+                // tag: sn,dt,gx,gy,gz,ax,ay,az,mx,my,mz
+                kscsv_write(csv, "%d,%.10f,%.10f,%.10f,%.10f,%.10f,%.10f,%.10f,%.10f,%.10f,%.10f",
+                    raw->raw.index, raw->raw.dt,
+                    raw->raw.g[0], raw->raw.g[1], raw->raw.g[2],
+                    raw->raw.a[0], raw->raw.a[1], raw->raw.a[2],
+                    raw->raw.m[0], raw->raw.m[1], raw->raw.m[2]);
+            }
+#endif
 #if 0
             klogc("[%6d][%3d][%s][%02X:%02X][%4dHz] ", total, count, KS_TYPE_STRING[pk.type], pk.param[0], pk.param[1], (int32_t)packetFreq);
             for (int i = 0; i < pk.lens; i++)
@@ -174,9 +226,8 @@ static int ksfeed_serial(ksraw_t *raw, kscsv_t *csv, int updaterate)
             klogc("\n");
             klogc(NULL);
 #endif
-
         }
-        switch (getKey())
+        switch (getkey())
         {
             case 17:    // ctrl + q
             {