加入sqlite相关代码

base/CommonStruct.h

@@ -204,8 +204,8 @@ struct serverResponseOperationObj
 //订单发送给pos失败结构体
 struct orderSendFailedObj
 {
+    long long timestamp=0;         //接收到订单时候的时间戳(精确到毫秒)
     std::string order_json;    //订单json字符串
-    unsigned int timestamp=0;  //接收到订单时候的时间戳
 };
 
 #endif
\ No newline at end of file

src/SQLiteModule.cpp

@@ -49,20 +49,13 @@ bool SQLite::_createTable()
     //第三个参数为callback函数，这里没有用，第四个参数为callback函数
     //中的第一个参数，第五个为出错信息
     bool rlt=true;
-    std::string strTableName="fmTest";
+    std::string strTableName="fmOrderFailed";
     if(!isTableExist(pDB,strTableName)){
         char szCreate[1024]={0};
-        sprintf(szCreate,"create table %s(fm_id varchar(50) NOT NULL,\
-                                    statusCode int, \
-                                    msg varchar(200),\
-                                    prompt bool,\
-                                    fm_open_id varchar(50),\
-                                    total_amount int,\
-                                    paid_total_amount int,\
-                                    invoice_amount int,\
-                                    incentives_amount int,\
-                                    logtime TIMESTAMP default (datetime('now', 'localtime')),\
-                                    PRIMARY KEY (fm_id))",strTableName.c_str());
+        sprintf(szCreate,"create table %s(id BIGINT NOT NULL,\
+                                          msg TEXT,\
+                                          logtime TIMESTAMP default (datetime('now', 'localtime')),\
+                                          PRIMARY KEY (id))",strTableName.c_str());
         if(!_execSql(szCreate)){
             //执行失败，退出
             exit(0);
@@ -99,7 +92,7 @@ bool SQLite::isTableExist(sqlite3 *sqDb, std::string strTableName)
 int SQLite::isRecordExist(std::string strTable,std::string strKey)
 {
     char* lpSql = new char[BUFFER_SIZE];
-    sprintf(lpSql, "select * from %s where trans_id = '%s'",strTable.c_str(),strKey.c_str());    
+    sprintf(lpSql, "select * from %s where id = '%s'",strTable.c_str(),strKey.c_str());    
     char** pResult;  
     int nRow = 0;   
     int nCol = 0;
@@ -140,14 +133,16 @@ bool SQLite::remove(const char* sql)
     return _execSql(sql);
 }
 
+std::vector<orderSendFailedObj> vecOrders;
 int callbackQuery(void* data,int n_columns,char** column_values,char** column_names)
 {   
     try
     {
-        std::string col0=column_values[0];
-        std::string col1=column_values[1];
-        std::string col2=column_values[2];
-        LOG(INFO)<<"column0:"<<col0<<" column1:"<<col1<<" column2:"<<col2;
+        orderSendFailedObj order;
+        order.timestamp=atoll(column_values[0]);
+        order.order_json=column_values[1];
+        vecOrders.push_back(order);
+        
     }
     catch(std::exception &ex)
     {
@@ -158,11 +153,15 @@ int callbackQuery(void* data,int n_columns,char** column_values,char** column_na
     return 0;
 }
 
-void SQLite::query(const char* sql)
+void SQLite::query(const char* sql,std::vector<orderSendFailedObj> &vecFailedOrders)
 {
+    vecOrders.clear();
     int rlt = sqlite3_exec(pDB,sql,callbackQuery, 0, &errMsg);
     if(rlt!= SQLITE_OK)
     {
         LOG(ERROR)<<"查询数据执行失败："<<errMsg;
     }
+    else{
+        vecFailedOrders.assign(vecOrders.begin(), vecOrders.end());
+    }
 }
\ No newline at end of file

src/SQLiteModule.h

@@ -2,6 +2,8 @@
 #define SQLITE_MODULE_H
 #include <iostream>
 #include <sqlite3.h>
+#include <vector>
+#include "../base/CommonStruct.h"
 
 class SQLite
 {
@@ -17,7 +19,7 @@ public:
     bool insert(const char* sql);
     bool update(const char* sql);
     bool remove(const char* sql);
-    void query(const char* sql);
+    void query(const char* sql,std::vector<orderSendFailedObj> &vecFailedOrders);
 private:
     bool _execSql(const char* sql);
     bool _createTable();

src/main.cpp

@@ -145,6 +145,23 @@ int main()
 
     LOG(INFO)<<"---------software start---------";
 
+    // //test sqlite
+    // orderSendFailedObj orderFailedObj;
+    // orderFailedObj.timestamp=1111222233334444;
+    // LOG(INFO)<<"--------- long long---------:"<<orderFailedObj.timestamp;
+    // SQLite sqlite;
+    // sqlite.initSQLite();
+    // sqlite.insert("insert into fmOrderFailed(id,msg) values(122233464555,'asdfdfdfdfdfsdadadafdadfafaf')");
+    // std::vector<orderSendFailedObj> vecFailedOrders;
+    // sqlite.query("select * from fmOrderFailed",vecFailedOrders);
+    // for(auto order:vecFailedOrders){
+    //     LOG(INFO)<<"vector element:"<<order.timestamp;
+    // }
+    // LOG(INFO)<<"seconds:"<<timestamp_seconds()<<" mSeconds:"<<timestamps_milliseconds();
+    // sqlite.closeSQLite();
+    // return 0;
+
+
     // 读取配置文件信息
     std::string strIniPath(strBinPath.data());
     strIniPath.append("config.ini");

utility/utility.cpp

@@ -5,6 +5,7 @@
 #include <iostream>
 #include <iconv.h>
 #include <string.h>
+#include <sys/time.h>
 
 #ifdef WIN32
 #include <Windows.h>
@@ -90,4 +91,19 @@ std::string charset_u2g(const std::string& utf8)
     charset_convert( "utf-8","gb2312", utf8, gb2312);
     //std::cout<<"convert res:"<<i<<std::endl;
     return gb2312;
+}
+
+//获取时间戳（毫秒）
+long long timestamps_milliseconds()
+{
+   struct timeval tv;    
+   gettimeofday(&tv,NULL);
+   return (int64_t)tv.tv_sec*1000 + tv.tv_usec/1000;
+} 
+//获取时间戳（秒）
+long long timestamp_seconds()
+{
+   struct timeval tv;    
+   gettimeofday(&tv,NULL);
+   return tv.tv_sec; 
 }
\ No newline at end of file

utility/utility.h

+#ifndef UTILITY_H
+#define UTILITY_H
 
 #include <string>
 
@@ -9,4 +11,12 @@ std::string GetProcDir();
 std::string charset_u2g(const std::string& utf8);
 
 //GB2312码转为UNICODE码
-std::string charset_g2u(const std::string& gb2312);
+std::string charset_g2u(const std::string& gb2312);
\ No newline at end of file
+
+//获取时间戳（秒）
+long long timestamp_seconds();
+
+//获取时间戳（毫秒）
+long long timestamps_milliseconds();
+
+#endif
\ No newline at end of file