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
28ae9723
Commit
28ae9723
authored
Mar 05, 2019
by
guanghui.cui
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
代码中tab统一用4个空格替换,保证代码在各个平台看起来格式一样
parent
9a50462f
Hide whitespace changes
Inline
Side-by-side
Showing
4 changed files
with
41 additions
and
41 deletions
+41
-41
base/BaseDefine.h
+23
-23
src/JsonModule.cpp
+2
-2
src/SocketModule.cpp
+4
-4
src/main.cpp
+12
-12
No files found.
base/BaseDefine.h
View file @
28ae9723
...
...
@@ -18,9 +18,9 @@
#define ORDERSTATUS_REFUND_PART 1021 //申请部分退款
#define ORDERSTATUS_REFUND_COMPLETE 1022 //退款完成
//#define ORDERSTATUS_LOCK 1100 //外卖-已锁定
#define ORDERSTATUS_APPOINTMENT_PAID 1030
//已支付(点取分离)
#define ORDERSTATUS_APPOINTMENT_REFUND 1031
//用户退款(点取分离)
#define ORDERSTATUS_SCANCODE_PAID 1032
//已支付(扫码购)
#define ORDERSTATUS_APPOINTMENT_PAID 1030
//已支付(点取分离)
#define ORDERSTATUS_APPOINTMENT_REFUND 1031
//用户退款(点取分离)
#define ORDERSTATUS_SCANCODE_PAID 1032
//已支付(扫码购)
//请求类型对照表
#define REQUEST_TYPE_INIT 1000 //初始化
...
...
@@ -57,9 +57,9 @@
#define DELIVERY_STATUS_CANCELED 2 //配送单已取消
#define DELIVERY_STATUS_SHIPPING 3 //配送中
#define DELIVERY_STATUS_COMPLETE 4 //配送完成
#define DELIVERY_STATUS_RECRY_CONFIRM 5
//配送员取消抢单,等待重新抢单
#define DELIVERY_STATUS_FAILED 6
//配送失败
#define DELIVERY_STATUS_UNWRITE -1
//未写入状态
#define DELIVERY_STATUS_RECRY_CONFIRM 5
//配送员取消抢单,等待重新抢单
#define DELIVERY_STATUS_FAILED 6
//配送失败
#define DELIVERY_STATUS_UNWRITE -1
//未写入状态
//平台代码对照表
#define PLANTFORM_CODE_OFFLINE_COMMON 101 //线下普通单
...
...
@@ -119,22 +119,22 @@
#define ODS_ORDERSTATUS_REFUND_AGREE 30 //同意退款
#define ODS_ORDERSTATUS_REFUND_DISAGREE 40 //不同意退款
#define ODS_ORDERSTATUS_REFUND_COMPLETE 100 //退款完成
#define ODS_ORDERSTATUS_CANCELED_TIMEOUT 3001
//超时取消
#define ODS_ORDERSTATUS_CANCELED_USER 3002
//用户取消
#define ODS_ORDERSTATUS_CANCELED_KEFU 3003
//客服取消
#define ODS_ORDERSTATUS_CANCELED_SYS 3004
//系统取消
#define ODS_ORDERSTATUS_CANCELED_OTHER 3100
//其他原因取消
#define ODS_ORDERSTATUS_LOCK -1
//已锁定
#define ODS_ORDERSTATUS_APPOINTMENT_PAID 20004
//已支付(点取分离)
#define ODS_ORDERSTATUS_APPOINTMENT_REFUND 20005
//用户退款(点取分离)
#define ODS_ORDERSTATUS_SCANCODE_PAID 30004
//已支付(扫码购)
#define ODS_ORDERSTATUS_COFFEE_CANCEL 40002
//已取消(咖啡小程序)
#define ODS_ORDERSTATUS_COFFEE_TIMEOUT_CANCEL 40003
//超时取消(咖啡小程序)
#define ODS_ORDERSTATUS_COFFEE_PAID 40004
//已支付(咖啡小程序)
#define ODS_ORDERSTATUS_COFFEE_REFUND_USER 40005
//用户退款申请成功(咖啡小程序)
#define ODS_ORDERSTATUS_COFFEE_CONFIRMED 40006
//已接单(咖啡小程序)
#define ODS_ORDERSTATUS_COFFEE_SHIPPING 40008
//配送中(咖啡小程序)
#define ODS_ORDERSTATUS_COFFEE_DONE 40009
//已完成(咖啡小程序)
#define ODS_ORDERSTATUS_CANCELED_TIMEOUT 3001
//超时取消
#define ODS_ORDERSTATUS_CANCELED_USER 3002
//用户取消
#define ODS_ORDERSTATUS_CANCELED_KEFU 3003
//客服取消
#define ODS_ORDERSTATUS_CANCELED_SYS 3004
//系统取消
#define ODS_ORDERSTATUS_CANCELED_OTHER 3100
//其他原因取消
#define ODS_ORDERSTATUS_LOCK -1
//已锁定
#define ODS_ORDERSTATUS_APPOINTMENT_PAID 20004
//已支付(点取分离)
#define ODS_ORDERSTATUS_APPOINTMENT_REFUND 20005
//用户退款(点取分离)
#define ODS_ORDERSTATUS_SCANCODE_PAID 30004
//已支付(扫码购)
#define ODS_ORDERSTATUS_COFFEE_CANCEL 40002
//已取消(咖啡小程序)
#define ODS_ORDERSTATUS_COFFEE_TIMEOUT_CANCEL 40003
//超时取消(咖啡小程序)
#define ODS_ORDERSTATUS_COFFEE_PAID 40004
//已支付(咖啡小程序)
#define ODS_ORDERSTATUS_COFFEE_REFUND_USER 40005
//用户退款申请成功(咖啡小程序)
#define ODS_ORDERSTATUS_COFFEE_CONFIRMED 40006
//已接单(咖啡小程序)
#define ODS_ORDERSTATUS_COFFEE_SHIPPING 40008
//配送中(咖啡小程序)
#define ODS_ORDERSTATUS_COFFEE_DONE 40009
//已完成(咖啡小程序)
//推送类型
#define ODS_PUSH_TYPE_HEARTBEAT 3 //心跳
...
...
@@ -145,7 +145,7 @@
//POS主动推送请求类型
#define ODS_POSPUSH_CONFIRM 1 //确认接单
#define ODS_POSPUSH_CANCEL
2 //拒绝接单
#define ODS_POSPUSH_CANCEL
2 //拒绝接单
#define ODS_POSPUSH_REFUND_AGREE 5 //同意退款
#define ODS_POSPUSH_REFUND_DISAGREE 6 //拒绝退款
...
...
src/JsonModule.cpp
View file @
28ae9723
...
...
@@ -2425,9 +2425,9 @@ std::string JsonModule::_getPickupCodeString(std::string &channel,std::string &p
else
if
(
"208"
==
channel
){
rlt
=
"京东到家"
+
pickup_code
+
"号"
;
}
//vs默认编码是gbk,如果是windows系统,需要转换为utf8编码
//vs默认编码是gbk,如果是windows系统,需要转换为utf8编码
#ifdef WIN32
rlt
=
charset_g2u
(
rlt
);
rlt
=
charset_g2u
(
rlt
);
#endif // WIN32
return
rlt
;
...
...
src/SocketModule.cpp
View file @
28ae9723
...
...
@@ -246,7 +246,7 @@ bool TCPClient::receive(std::string &message)
{
//首先读取头部
//Packet buf = {0, 0};
unsigned
int
msgLen
=
0
;
unsigned
int
msgLen
=
0
;
size_t
readBytes
=
readn
(
m_sockfd
,
&
msgLen
,
sizeof
(
msgLen
));
if
(
readBytes
==
(
size_t
)
-
1
)
{
...
...
@@ -258,10 +258,10 @@ bool TCPClient::receive(std::string &message)
m_bValid
=
false
;
return
false
;
}
//然后读取数据部分
//然后读取数据部分
bool
rlt
=
true
;
unsigned
int
lenHost
=
ntohl
(
msgLen
);
char
*
temp
=
new
char
[
lenHost
+
1
];
char
*
temp
=
new
char
[
lenHost
+
1
];
if
(
lenHost
>
FM_BUF_SIZE
)
{
LOG
(
INFO
)
<<
"Too long message,the message length is:"
<<
lenHost
;
}
...
...
@@ -278,7 +278,7 @@ bool TCPClient::receive(std::string &message)
}
temp
[
lenHost
]
=
'\0'
;
message
=
temp
;
delete
[]
temp
;
delete
[]
temp
;
return
rlt
;
}
...
...
src/main.cpp
View file @
28ae9723
...
...
@@ -235,7 +235,7 @@ void* listen_pos_func(void* arg)
}
}
#ifdef WIN32
return
0
;
return
0
;
#endif // WIN32
}
...
...
@@ -305,14 +305,14 @@ int main(int argc,char *argv[])
//end
#ifdef WIN32
HANDLE
hTakeway
=
CreateThread
(
NULL
,
0
,
listen_pos_func
,
NULL
,
0
,
NULL
);
HANDLE
hTakeway
=
CreateThread
(
NULL
,
0
,
listen_pos_func
,
NULL
,
0
,
NULL
);
#else
// 监听POS请求的线程
pthread_t
listen_pos_id
;
/*创建 listen_pos 线程*/
if
(
pthread_create
(
&
listen_pos_id
,
NULL
,
listen_pos_func
,
NULL
))
LOG
(
INFO
)
<<
"create listen_pos thread failed"
;
// 监听POS请求的线程
pthread_t
listen_pos_id
;
/*创建 listen_pos 线程*/
if
(
pthread_create
(
&
listen_pos_id
,
NULL
,
listen_pos_func
,
NULL
))
LOG
(
INFO
)
<<
"create listen_pos thread failed"
;
#endif // WIN32
...
...
@@ -396,7 +396,7 @@ int main(int argc,char *argv[])
{
LOG
(
INFO
)
<<
"---------------- ODS ===>> PLUGIN ---------------"
;
LOG
(
INFO
)
<<
odsPushData
;
int
dataType
=
jsonTool
.
isHeartbeatData
(
odsPushData
.
data
());
int
dataType
=
jsonTool
.
isHeartbeatData
(
odsPushData
.
data
());
if
(
2
==
dataType
){
if
(
jsonTool
.
convertDataOds2Pos
(
odsPushData
,
pushPosData
)
)
{
...
...
@@ -428,9 +428,9 @@ int main(int argc,char *argv[])
LOG
(
INFO
)
<<
"maybe pos restart,reconnect!!!"
;
}
}
else
if
(
3
==
dataType
){
LOG
(
INFO
)
<<
"illegal data!!"
;
}
else
if
(
3
==
dataType
){
LOG
(
INFO
)
<<
"illegal data!!"
;
}
}
else
{
...
...
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