Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
F
familyMart_takeaway
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
guanghui.cui
familyMart_takeaway
Commits
ccab1d1d
Commit
ccab1d1d
authored
Jan 29, 2018
by
guanghui.cui
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
tab替换为4个空格
parent
a8033ca2
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
25 additions
and
28 deletions
+25
-28
src/JsonModule.cpp
+7
-7
src/SQLiteModule.cpp
+6
-9
src/SocketModule.cpp
+12
-12
No files found.
src/JsonModule.cpp
View file @
ccab1d1d
...
@@ -38,21 +38,21 @@ void parseJson(const char* json)
...
@@ -38,21 +38,21 @@ void parseJson(const char* json)
// 注意GetParseError()返回的是一个rapidjson::ParseErrorCode类型的枚举值
// 注意GetParseError()返回的是一个rapidjson::ParseErrorCode类型的枚举值
// 使用函数rapidjson::GetParseError_En()得到错误码的字符串说明,这里的En为English简写
// 使用函数rapidjson::GetParseError_En()得到错误码的字符串说明,这里的En为English简写
// 函数GetErrorOffset()返回出错发生的位置
// 函数GetErrorOffset()返回出错发生的位置
//LOG_ERROR("TakeawayOrder JSON parse error: (%d:%d)", document.GetParseError(), document.GetErrorOffset())
LOG
(
ERROR
)
<<
"JSON parse error:"
<<
document
.
GetParseError
()
<<
":"
<<
document
.
GetErrorOffset
();
}
}
else
else
{
{
rapidjson
::
Value
&
vStatusCode
=
document
[
"statusCode"
];
rapidjson
::
Value
&
vStatusCode
=
document
[
"statusCode"
];
rapidjson
::
Value
&
vMsg
=
document
[
"msg"
];
rapidjson
::
Value
&
vMsg
=
document
[
"msg"
];
rapidjson
::
Value
&
vOrderid
=
document
[
"orderid"
];
rapidjson
::
Value
&
vOrderid
=
document
[
"orderid"
];
int
iStatusCode
=
vStatusCode
.
GetInt
();
int
iStatusCode
=
vStatusCode
.
GetInt
();
std
::
string
strMsg
=
vMsg
.
GetString
();
std
::
string
strMsg
=
vMsg
.
GetString
();
std
::
string
strOrderid
=
vOrderid
.
GetString
();
std
::
string
strOrderid
=
vOrderid
.
GetString
();
LOG
(
INFO
)
<<
"statusCode:"
<<
iStatusCode
;
LOG
(
INFO
)
<<
"statusCode:"
<<
iStatusCode
;
LOG
(
INFO
)
<<
"msg:"
<<
strMsg
.
data
();
LOG
(
INFO
)
<<
"msg:"
<<
strMsg
.
data
();
LOG
(
INFO
)
<<
"orderId:"
<<
strOrderid
.
data
();
LOG
(
INFO
)
<<
"orderId:"
<<
strOrderid
.
data
();
}
}
}
}
src/SQLiteModule.cpp
View file @
ccab1d1d
...
@@ -18,7 +18,7 @@ SQLite::~SQLite()
...
@@ -18,7 +18,7 @@ SQLite::~SQLite()
bool
SQLite
::
initSQLite
()
bool
SQLite
::
initSQLite
()
{
{
std
::
string
strDbFileName
;
//*.db 名称
std
::
string
strDbFileName
;
//*.db 名称
std
::
string
strPath
=
GetProcDir
();
std
::
string
strPath
=
GetProcDir
();
strPath
.
append
(
"fmdata.db"
);
strPath
.
append
(
"fmdata.db"
);
strDbFileName
=
strPath
;
strDbFileName
=
strPath
;
...
@@ -51,8 +51,8 @@ bool SQLite::_createTable()
...
@@ -51,8 +51,8 @@ bool SQLite::_createTable()
bool
rlt
=
true
;
bool
rlt
=
true
;
std
::
string
strTableName
=
"fmTest"
;
std
::
string
strTableName
=
"fmTest"
;
if
(
!
isTableExist
(
pDB
,
strTableName
)){
if
(
!
isTableExist
(
pDB
,
strTableName
)){
char
szCreate
[
1024
]
=
{
0
};
char
szCreate
[
1024
]
=
{
0
};
sprintf
(
szCreate
,
"create table %s(fm_id varchar(50) NOT NULL,\
sprintf
(
szCreate
,
"create table %s(fm_id varchar(50) NOT NULL,\
statusCode int, \
statusCode int, \
msg varchar(200),\
msg varchar(200),\
prompt bool,\
prompt bool,\
...
@@ -69,7 +69,7 @@ bool SQLite::_createTable()
...
@@ -69,7 +69,7 @@ bool SQLite::_createTable()
}
}
}
}
else
{
else
{
LOG
(
INFO
)
<<
strTableName
.
data
()
<<
"已存在"
;
LOG
(
INFO
)
<<
strTableName
.
data
()
<<
"已存在"
;
}
}
return
rlt
;
return
rlt
;
...
@@ -92,17 +92,14 @@ bool SQLite::isTableExist(sqlite3 *sqDb, std::string strTableName)
...
@@ -92,17 +92,14 @@ bool SQLite::isTableExist(sqlite3 *sqDb, std::string strTableName)
int
count
=
sqlite3_column_int
(
pstmt
,
0
);
int
count
=
sqlite3_column_int
(
pstmt
,
0
);
sqlite3_finalize
(
pstmt
);
sqlite3_finalize
(
pstmt
);
if
(
count
>
0
)
if
(
count
>
0
)
return
true
;
return
true
;
return
false
;
return
false
;
}
}
int
SQLite
::
isRecordExist
(
std
::
string
strTable
,
std
::
string
strKey
)
int
SQLite
::
isRecordExist
(
std
::
string
strTable
,
std
::
string
strKey
)
{
{
char
*
lpSql
=
new
char
[
BUFFER_SIZE
];
char
*
lpSql
=
new
char
[
BUFFER_SIZE
];
sprintf_s
(
lpSql
,
BUFFER_SIZE
,
sprintf_s
(
lpSql
,
BUFFER_SIZE
,
"select * from %s where trans_id = '%s'"
,
strTable
.
c_str
(),
strKey
.
c_str
());
"select * from %s where trans_id = '%s'"
,
strTable
.
c_str
(),
strKey
.
c_str
());
char
**
pResult
;
char
**
pResult
;
int
nRow
=
0
;
int
nRow
=
0
;
int
nCol
=
0
;
int
nCol
=
0
;
...
...
src/SocketModule.cpp
View file @
ccab1d1d
...
@@ -30,7 +30,7 @@ int socketRecvData(char * recvBuf, int bufSize, int socket_fd)
...
@@ -30,7 +30,7 @@ int socketRecvData(char * recvBuf, int bufSize, int socket_fd)
while
(
0
<
needLength
)
while
(
0
<
needLength
)
{
{
//接收并打印客户端数据
//接收并打印客户端数据
int
length
=
recv
(
socket_fd
,
pcRcvBufer
+
rcvedLength
,
needLength
,
0
);
int
length
=
recv
(
socket_fd
,
pcRcvBufer
+
rcvedLength
,
needLength
,
0
);
if
(
0
<
length
)
if
(
0
<
length
)
{
{
needLength
-=
length
;
needLength
-=
length
;
...
@@ -40,7 +40,7 @@ int socketRecvData(char * recvBuf, int bufSize, int socket_fd)
...
@@ -40,7 +40,7 @@ int socketRecvData(char * recvBuf, int bufSize, int socket_fd)
{
{
if
(
0
==
rcvFlag
)
if
(
0
==
rcvFlag
)
{
{
//header rcved complete
//header rcved complete
rcvFlag
=
1
;
//to rcv payload
rcvFlag
=
1
;
//to rcv payload
int
flag
=
headx
.
flag
;
int
flag
=
headx
.
flag
;
...
@@ -51,8 +51,8 @@ int socketRecvData(char * recvBuf, int bufSize, int socket_fd)
...
@@ -51,8 +51,8 @@ int socketRecvData(char * recvBuf, int bufSize, int socket_fd)
if
(
len
>
bufSize
)
if
(
len
>
bufSize
)
{
{
rlt
=
-
1
;
rlt
=
-
1
;
LOG
(
ERROR
)
<<
"socket recv 接收数据长度大于接收缓冲区:"
<<
len
;
LOG
(
ERROR
)
<<
"socket recv 接收数据长度大于接收缓冲区:"
<<
len
;
break
;
break
;
}
}
needLength
=
len
;
needLength
=
len
;
pcRcvBufer
=
recvBuf
;
pcRcvBufer
=
recvBuf
;
...
@@ -61,7 +61,7 @@ int socketRecvData(char * recvBuf, int bufSize, int socket_fd)
...
@@ -61,7 +61,7 @@ int socketRecvData(char * recvBuf, int bufSize, int socket_fd)
}
}
else
else
{
{
//payload rcved complete
//payload rcved complete
rlt
=
rcvedLength
;
rlt
=
rcvedLength
;
break
;
break
;
}
}
...
@@ -69,9 +69,9 @@ int socketRecvData(char * recvBuf, int bufSize, int socket_fd)
...
@@ -69,9 +69,9 @@ int socketRecvData(char * recvBuf, int bufSize, int socket_fd)
}
}
else
if
(
length
==
0
)
else
if
(
length
==
0
)
{
{
//socket error
//socket error
rlt
=
-
1
;
rlt
=
-
1
;
LOG
(
ERROR
)
<<
"socket recv 返回值:"
<<
length
;
LOG
(
ERROR
)
<<
"socket recv 返回值:"
<<
length
;
break
;
break
;
}
}
}
}
...
@@ -98,12 +98,12 @@ int socketSendData(const char * sendBuf, int socket_fd)
...
@@ -98,12 +98,12 @@ int socketSendData(const char * sendBuf, int socket_fd)
while
(
curSendLength
<
toSendLength
)
while
(
curSendLength
<
toSendLength
)
{
{
int
res
=
send
(
socket_fd
,
pcSendBuf
+
curSendLength
,
toSendLength
-
curSendLength
,
0
);
int
res
=
send
(
socket_fd
,
pcSendBuf
+
curSendLength
,
toSendLength
-
curSendLength
,
0
);
if
(
res
==
SOCKET_ERROR
)
if
(
res
==
SOCKET_ERROR
)
{
{
LOG
(
ERROR
)
<<
"发送数据给fm服务端失败!"
;
LOG
(
ERROR
)
<<
"发送数据给fm服务端失败!"
;
rlt
=-
1
;
rlt
=-
1
;
break
;
break
;
}
}
...
@@ -112,7 +112,7 @@ int socketSendData(const char * sendBuf, int socket_fd)
...
@@ -112,7 +112,7 @@ int socketSendData(const char * sendBuf, int socket_fd)
if
(
curSendLength
!=
toSendLength
)
if
(
curSendLength
!=
toSendLength
)
{
{
rlt
=-
1
;
rlt
=-
1
;
LOG
(
ERROR
)
<<
"socket数据发送不完整!"
;
LOG
(
ERROR
)
<<
"socket数据发送不完整!"
;
}
}
return
rlt
;
return
rlt
;
}
}
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment