Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
F
fmp_vip
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
zhenfei.zhang
fmp_vip
Commits
a36edc05
Commit
a36edc05
authored
Apr 10, 2017
by
Carwyn
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
1.日志更新使用方式为不用参数
parent
d45d158b
Hide whitespace changes
Inline
Side-by-side
Showing
13 changed files
with
40 additions
and
52 deletions
+40
-52
backup/fmbackup.cpp
+9
-9
backup/resend.cpp
+1
-1
fmnetwork.cpp
+2
-2
fmp_ve_handlers.cpp
+2
-2
fmp_vip.cpp
+2
-0
fmp_vip_p.cpp
+2
-3
fmp_vip_server.cpp
+4
-4
fmp_vip_settings.cpp
+3
-9
fmp_vip_settings.h
+1
-8
fmvipdispatcher.cpp
+2
-2
task/fmtask.cpp
+9
-9
task/fmtasknownd.cpp
+1
-1
task/tasklogin.cpp
+2
-2
No files found.
backup/fmbackup.cpp
View file @
a36edc05
...
...
@@ -41,9 +41,9 @@ bool FMBackup::connect()
isOk
=
_db
.
open
();
}
VI
P_INFO
()
<<
QString
::
fromLocal8Bit
(
"连接数据库:"
)
<<
dbname
;
FM
P_INFO
()
<<
QString
::
fromLocal8Bit
(
"连接数据库:"
)
<<
dbname
;
if
(
!
isOk
)
{
VI
P_WARN
()
<<
QString
::
fromLocal8Bit
(
"连接失败:"
)
<<
_db
.
lastError
().
text
();
FM
P_WARN
()
<<
QString
::
fromLocal8Bit
(
"连接失败:"
)
<<
_db
.
lastError
().
text
();
}
return
isOk
;
...
...
@@ -58,9 +58,9 @@ bool FMBackup::createTable(const QString &dbname)
// 创建表
bool
isOk
=
query
.
exec
(
"create table tbl_req(id integer PRIMARY KEY autoincrement, url varchar(200), req text)"
);
VI
P_INFO
()
<<
QString
::
fromLocal8Bit
(
"创建数据库:"
)
<<
dbname
;
FM
P_INFO
()
<<
QString
::
fromLocal8Bit
(
"创建数据库:"
)
<<
dbname
;
if
(
!
isOk
)
{
VI
P_WARN
()
<<
QString
::
fromLocal8Bit
(
"创建数据库失败:"
)
<<
query
.
lastError
().
text
();
FM
P_WARN
()
<<
QString
::
fromLocal8Bit
(
"创建数据库失败:"
)
<<
query
.
lastError
().
text
();
}
return
isOk
;
}
...
...
@@ -93,9 +93,9 @@ bool FMBackup::updateReqData(const int id, const QString url, const QString &req
.
arg
(
reqData
)
.
arg
(
id
));
VI
P_INFO
()
<<
QString
::
fromLocal8Bit
(
"备份数据:"
)
<<
reqData
;
FM
P_INFO
()
<<
QString
::
fromLocal8Bit
(
"备份数据:"
)
<<
reqData
;
if
(
!
isOk
)
{
VI
P_WARN
()
<<
QString
::
fromLocal8Bit
(
"备份失败:"
)
<<
query
.
lastError
().
text
();
FM
P_WARN
()
<<
QString
::
fromLocal8Bit
(
"备份失败:"
)
<<
query
.
lastError
().
text
();
}
return
isOk
;
}
...
...
@@ -105,7 +105,7 @@ bool FMBackup::removeReqData(const int &id)
QSqlQuery
query
(
_db
);
bool
isOk
=
query
.
exec
(
QString
(
"delete from tbl_req where id==%1"
).
arg
(
id
));
if
(
!
isOk
)
{
VI
P_WARN
()
<<
QString
::
fromLocal8Bit
(
"删除数据时出现错误:"
)
<<
query
.
lastError
().
text
();
FM
P_WARN
()
<<
QString
::
fromLocal8Bit
(
"删除数据时出现错误:"
)
<<
query
.
lastError
().
text
();
}
return
isOk
;
}
...
...
@@ -115,7 +115,7 @@ QSqlQuery FMBackup::reqDataQuery() const
QSqlQuery
query
(
_db
);
bool
isOk
=
query
.
exec
(
"select * from tbl_req"
);
if
(
!
isOk
)
{
VI
P_WARN
()
<<
QString
::
fromLocal8Bit
(
"查询数据时出现错误:"
)
<<
query
.
lastError
().
text
();
FM
P_WARN
()
<<
QString
::
fromLocal8Bit
(
"查询数据时出现错误:"
)
<<
query
.
lastError
().
text
();
}
return
query
;
}
...
...
@@ -124,6 +124,6 @@ bool FMBackup::reset()
{
QSqlQuery
query
(
_db
);
bool
isOk
=
query
.
exec
(
"VACUUM"
);
VI
P_INFO
()
<<
QString
::
fromLocal8Bit
(
"数据库重置: "
)
<<
isOk
;
FM
P_INFO
()
<<
QString
::
fromLocal8Bit
(
"数据库重置: "
)
<<
isOk
;
return
isOk
;
}
backup/resend.cpp
View file @
a36edc05
...
...
@@ -35,7 +35,7 @@ void ReSend::trySend()
break
;
}
else
{
FMBackup
::
instance
()
->
removeReqData
(
id
);
VI
P_INFO
()
<<
QString
::
fromLocal8Bit
(
"重发响应成功:"
)
<<
rspData
;
FM
P_INFO
()
<<
QString
::
fromLocal8Bit
(
"重发响应成功:"
)
<<
rspData
;
}
}
}
...
...
fmnetwork.cpp
View file @
a36edc05
...
...
@@ -27,8 +27,8 @@ int FMNetwork::send(const QString &url, const QByteArray &reqData, QByteArray &r
{
error
=
FM_API_SUCCESS
;
VI
P_INFO
()
<<
"Send Url: "
<<
url
;
VI
P_INFO
()
<<
"Send Data: "
<<
reqData
;
FM
P_INFO
()
<<
"Send Url: "
<<
url
;
FM
P_INFO
()
<<
"Send Data: "
<<
reqData
;
_req
->
setUrl
(
url
);
...
...
fmp_ve_handlers.cpp
View file @
a36edc05
...
...
@@ -20,10 +20,10 @@ void FMPStartEventHandler::handleEvent(const ctkEvent &event)
_vip
->
StartVip
();
}
else
{
FMP_WARN
_CTX
(
_ctx
)
<<
"Refused start request"
<<
event
.
getTopic
();
FMP_WARN
(
)
<<
"Refused start request"
<<
event
.
getTopic
();
}
}
else
{
FMP_DEBUG
_CTX
(
_ctx
)
<<
"No handler instance for event"
<<
event
.
getTopic
();
FMP_DEBUG
(
)
<<
"No handler instance for event"
<<
event
.
getTopic
();
}
}
fmp_vip.cpp
View file @
a36edc05
...
...
@@ -9,6 +9,8 @@ FMPVip::FMPVip(ctkPluginContext *context)
d_ptr
(
new
FMPVipPrivate
(
this
))
{
FMPStartEventHandler
*
handler
=
new
FMPStartEventHandler
(
_ctx
,
this
);
FMPLoggerInterface
::
InitContext
(
context
);
}
int
FMPVip
::
StopService
()
...
...
fmp_vip_p.cpp
View file @
a36edc05
...
...
@@ -20,11 +20,10 @@ int FMPVipPrivate::StartVip()
{
Q_Q
(
FMPVip
);
FMPLoggerInterface
*
logger
=
q
->
GetService
<
FMPLoggerInterface
>
(
q
->
_ctx
);
FMP_INFO
(
logger
)
<<
"Vip start"
;
FMP_INFO
()
<<
"Vip start"
;
_settings
=
q
->
GetService
<
FMPSettingsInterface
>
(
q
->
_ctx
);
FMPVipSettings
::
instance
()
->
init
(
_settings
,
logger
);
FMPVipSettings
::
instance
()
->
init
(
_settings
);
emit
startVip
();
q
->
_inited
=
true
;
...
...
fmp_vip_server.cpp
View file @
a36edc05
...
...
@@ -22,14 +22,14 @@ FMPVipServer::FMPVipServer() :
void
FMPVipServer
::
Listen
(
quint16
port
)
{
if
(
!
this
->
listen
(
QHostAddress
::
Any
,
port
))
{
VI
P_ERROR
()
<<
"Listen error: "
<<
this
->
errorString
();
FM
P_ERROR
()
<<
"Listen error: "
<<
this
->
errorString
();
}
}
void
FMPVipServer
::
Write
(
const
QByteArray
&
data
)
{
if
(
socket
->
write
(
data
)
==
-
1
)
{
VI
P_ERROR
()
<<
"Write error: "
<<
socket
->
error
()
<<
socket
->
errorString
();
FM
P_ERROR
()
<<
"Write error: "
<<
socket
->
error
()
<<
socket
->
errorString
();
}
}
...
...
@@ -43,7 +43,7 @@ void FMPVipServer::onNewConnection()
void
FMPVipServer
::
onDisconnected
()
{
VI
P_DEBUG
()
<<
"Socket disconnected."
;
FM
P_DEBUG
()
<<
"Socket disconnected."
;
}
void
FMPVipServer
::
onReadyRead
()
...
...
@@ -53,7 +53,7 @@ void FMPVipServer::onReadyRead()
FMSOCKEHEADER
header
=
{
0
};
memcpy
(
&
header
,
recvData
.
data
(),
sizeof
(
FMSOCKEHEADER
));
if
(
header
.
flag
!=
FMSOCKFLAG
)
{
VI
P_WARN
()
<<
"Incompatible protocol."
;
FM
P_WARN
()
<<
"Incompatible protocol."
;
return
;
}
...
...
fmp_vip_settings.cpp
View file @
a36edc05
...
...
@@ -12,15 +12,9 @@ FMPVipSettings *FMPVipSettings::instance()
return
&
vipSettings
;
}
void
FMPVipSettings
::
init
(
FMPSettingsInterface
*
settings
,
FMPLoggerInterface
*
logger
)
void
FMPVipSettings
::
init
(
FMPSettingsInterface
*
settings
)
{
this
->
_settings
=
settings
;
this
->
_logger
=
logger
;
}
FMPLoggerInterface
*
FMPVipSettings
::
getLogger
()
{
return
_logger
;
}
QString
FMPVipSettings
::
getServerUrl
()
...
...
@@ -34,7 +28,7 @@ QVariant FMPVipSettings::_GetValue(const QString &key, QVariant defaultValue)
return
_settings
->
GetValue
(
key
);
}
else
{
VI
P_WARN
()
<<
"Settings service not available"
;
FM
P_WARN
()
<<
"Settings service not available"
;
}
return
defaultValue
;
...
...
@@ -47,7 +41,7 @@ bool FMPVipSettings::_SetValue(const QString &key, QVariant value)
return
true
;
}
else
{
VI
P_WARN
()
<<
"Settings service not available"
;
FM
P_WARN
()
<<
"Settings service not available"
;
}
return
false
;
...
...
fmp_vip_settings.h
View file @
a36edc05
...
...
@@ -12,9 +12,8 @@ class FMPVipSettings : public QObject
Q_OBJECT
public
:
static
FMPVipSettings
*
instance
();
void
init
(
FMPSettingsInterface
*
settings
,
FMPLoggerInterface
*
logger
);
void
init
(
FMPSettingsInterface
*
settings
);
FMPLoggerInterface
*
getLogger
();
QString
getServerUrl
();
private
:
...
...
@@ -25,12 +24,6 @@ private:
private
:
FMPSettingsInterface
*
_settings
;
FMPLoggerInterface
*
_logger
;
};
#define VIP_DEBUG() FMP_DEBUG(FMPVipSettings::instance()->getLogger())
#define VIP_INFO() FMP_INFO(FMPVipSettings::instance()->getLogger())
#define VIP_WARN() FMP_WARN(FMPVipSettings::instance()->getLogger())
#define VIP_ERROR() FMP_ERROR(FMPVipSettings::instance()->getLogger())
#endif // FMP_VIP_SETTINGS_H
fmvipdispatcher.cpp
View file @
a36edc05
...
...
@@ -51,7 +51,7 @@ FMVipDispatcher::~FMVipDispatcher()
void
FMVipDispatcher
::
doTask
(
const
QByteArray
&
reqData
,
QByteArray
&
rspData
)
{
VI
P_INFO
()
<<
"Recv POS reqData: "
<<
reqData
;
FM
P_INFO
()
<<
"Recv POS reqData: "
<<
reqData
;
...
...
@@ -62,7 +62,7 @@ void FMVipDispatcher::doTask(const QByteArray &reqData, QByteArray &rspData)
}
else
{
rspData
=
fmTask
->
doTask
();
}
VI
P_INFO
()
<<
"Send to pos: "
<<
rspData
;
FM
P_INFO
()
<<
"Send to pos: "
<<
rspData
;
// condition.wakeAll();
...
...
task/fmtask.cpp
View file @
a36edc05
...
...
@@ -10,7 +10,7 @@
#define RunFunction(function) do { \
function##(); \
if(error() != FM_API_SUCCESS) { \
VI
P_WARN() << QString("Task error %1: %2").arg(error()).arg(errorString()); \
FM
P_WARN() << QString("Task error %1: %2").arg(error()).arg(errorString()); \
return QString(ErrorMsgJson).arg(error()).arg(errorString()).toLatin1(); \
} \
} while(0);
...
...
@@ -44,7 +44,7 @@ FMTask::~FMTask()
QByteArray
FMTask
::
doTask
()
{
VI
P_DEBUG
()
<<
__FUNCTION__
;
FM
P_DEBUG
()
<<
__FUNCTION__
;
RunFunction
(
copyPros
);
RunFunction
(
setWindow
);
RunFunction
(
showWindow
);
...
...
@@ -56,7 +56,7 @@ QByteArray FMTask::doTask()
void
FMTask
::
stopTask
()
{
VI
P_DEBUG
()
<<
__FUNCTION__
;
FM
P_DEBUG
()
<<
__FUNCTION__
;
if
(
preTask
!=
nullptr
)
{
preTask
->
stopTask
();
}
...
...
@@ -70,7 +70,7 @@ void FMTask::stopTask()
void
FMTask
::
copyPros
()
{
VI
P_DEBUG
()
<<
__FUNCTION__
;
FM
P_DEBUG
()
<<
__FUNCTION__
;
for
(
int
i
=
0
;
i
<
sizeof
(
DefaultProps
)
/
sizeof
(
DefaultProps
[
0
]);
++
i
)
{
QString
posPro
=
DefaultProps
[
i
];
serverReqJsonObj
[
ServerProps
(
posPro
)]
=
posReqJsonObj
[
posPro
];
...
...
@@ -79,7 +79,7 @@ void FMTask::copyPros()
void
FMTask
::
showWindow
()
{
VI
P_DEBUG
()
<<
__FUNCTION__
;
FM
P_DEBUG
()
<<
__FUNCTION__
;
QString
sL
[]
=
{
PosProps
.
OperatorId
,
PosProps
.
BussinessDate
,
...
...
@@ -101,7 +101,7 @@ void FMTask::showWindow()
bool
FMTask
::
sendToServer
(
bool
isShowMsg
)
{
VI
P_DEBUG
()
<<
__FUNCTION__
;
FM
P_DEBUG
()
<<
__FUNCTION__
;
// 固定部分
serverReqJsonObj
[
PosProps
.
AppId
]
=
APP_ID
;
serverReqJsonObj
[
PosProps
.
PartnerId
]
=
PARTNER_ID
;
...
...
@@ -139,7 +139,7 @@ bool FMTask::sendToServer(bool isShowMsg)
}
}
VI
P_INFO
()
<<
"Server rsponse: "
<<
serverRspJsonObj
;
FM
P_INFO
()
<<
"Server rsponse: "
<<
serverRspJsonObj
;
if
(
_window
!=
nullptr
)
{
...
...
@@ -185,7 +185,7 @@ QJsonValue FMTask::getPosJsonValue(const QString prop)
QString
FMTask
::
sign
()
const
{
VI
P_DEBUG
()
<<
__FUNCTION__
;
FM
P_DEBUG
()
<<
__FUNCTION__
;
// 解析JSON插入MAP中按字典排序
QMap
<
QString
,
QString
>
mapData
;
...
...
@@ -215,7 +215,7 @@ QString FMTask::sign() const
QByteArray
bt
;
bt
.
append
(
sb
);
VI
P_INFO
()
<<
"Sign String: "
<<
bt
;
FM
P_INFO
()
<<
"Sign String: "
<<
bt
;
QByteArray
md5Bt
=
QCryptographicHash
::
hash
(
bt
,
QCryptographicHash
::
Md5
);
return
md5Bt
.
toHex
();
...
...
task/fmtasknownd.cpp
View file @
a36edc05
...
...
@@ -29,7 +29,7 @@ QByteArray FMTaskNoWnd::doTask()
copyPros
();
bool
isOk
=
sendToServer
();
if
(
!
isOk
)
{
VI
P_WARN
()
<<
QString
(
"Task error %1: %2"
).
arg
(
error
()).
arg
(
errorString
());
FM
P_WARN
()
<<
QString
(
"Task error %1: %2"
).
arg
(
error
()).
arg
(
errorString
());
return
QString
(
ErrorMsgJson
).
arg
(
error
()).
arg
(
errorString
()).
toLatin1
();
}
packagePOSRsp
();
...
...
task/tasklogin.cpp
View file @
a36edc05
...
...
@@ -44,13 +44,13 @@ void TaskLogin::onLogin()
// 认证失败
if
(
getServerJsonValue
(
PosProps
.
StatusCode
).
toInt
()
!=
FM_API_SUCCESS
)
{
QString
info
=
serverRspJsonObj
[
ServerProps
(
PosProps
.
Msg
)].
toString
();
VI
P_WARN
()
<<
"Login failed: "
<<
info
;
FM
P_WARN
()
<<
"Login failed: "
<<
info
;
FMMsgWnd
::
FailureWnd
(
info
,
_window
);
}
// 认证成功但限制用支付码
// else if((session()->data(PosProps.FM_Type).toInt() == FM_Pay) &&
// (getServerJsonValue(PosProps.CanPay).toInt() != 1)) {
//
VI
P_WARN() << ErrorNeedPayCode;
//
FM
P_WARN() << ErrorNeedPayCode;
// FMMsgWnd::FailureWnd(ErrorNeedPayCode);
// }
// 认证成功
...
...
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