Skip to content

F
fmp_vip
Commit 3799713d by gujin.wang
Options

将支付结果写入sqlite数据库

parent 609da0c9
Showing with 113 additions and 12 deletions
fmp_vip_server.cpp
......@@ -37,8 +37,9 @@ void FMPVipServer::Write(const QByteArray &data)
return;
}
QString ip = FMPVipSettings::instance()->getMonitorServer();
QTcpSocket client;
client.connectToHost("127.0.0.1", 23771);
client.connectToHost(ip, 23771);
if(!client.waitForConnected())
{
FMP_ERROR() << "Connect monitor failed. " << client.errorString();
......@@ -75,7 +76,7 @@ void FMPVipServer::Write(const QByteArray &data)
}
void FMPVipServer::onNewConnection()
{
{
socket = nextPendingConnection();
connect(socket, &QTcpSocket::disconnected, this, &FMPVipServer::onDisconnected);
......
fmp_vip_settings.cpp
......@@ -27,6 +27,11 @@ bool FMPVipSettings::getIsNeedSocketHeader()
return _GetValue(FMP_INIKEY_NEEDSOCKETHEADER, false).toBool();
}
QString FMPVipSettings::getMonitorServer()
{
return _GetValue(FMP_INIKEY_MONITORSERVER, "127.0.0.1").toString();
}
QVariant FMPVipSettings::_GetValue(const QString &key, QVariant defaultValue)
{
if (_settings) {
......
fmp_vip_settings.h
......@@ -16,6 +16,7 @@ public:
QString getServerUrl();
bool getIsNeedSocketHeader();
QString getMonitorServer();
private:
explicit FMPVipSettings(QObject *parent = 0);
......
fmvipdispatcher.cpp
......@@ -2,6 +2,9 @@
#include <QAction>
#include <QTimer>
#include <QJsonParseError>
#include <QSqlDatabase>
#include <QSqlQuery>
#include <QSqlError>
#include "fmp_vip_settings.h"
#include <winsock2.h>
#include "fmvipdispatcher.h"
......@@ -52,6 +55,87 @@ void FMVipDispatcher::doTask(const QByteArray &reqData, QByteArray &rspData)
case FM_Pay: {
TaskPay taskPay(jsonObj, &session);
rspData = taskPay.doTask();
QJsonObject temp = QJsonDocument::fromJson(rspData).object();
temp["pay_id"] = FM_Pay; //把支付类型一并返回，monitor可以此区分具体的支付类型
rspData = QJsonDocument(temp).toJson(QJsonDocument::Compact);
//如果是虚拟支付，则不需再写入，因为已在fmp_epay插件中写入
if(temp["isCodePay"].toBool())
{
break;
}
//将订单记录写入sqlite数据库(fmp_pay表)
QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE", "VIP");
db.setDatabaseName("fmp_test.db");
if(!db.open())
{
FMP_ERROR() << QString::fromLocal8Bit("回写会员支付结果到fmp_test.db失败: ") + db.lastError().text();
}
else
{
QSqlQuery query(db);
QString sql;
if(temp[PosProps.StatusCode].toInt() == 100)
{
sql = QString("insert into fmp_pay(fmId,code,trans_id,pay_id,pay_ebcode,total_amount,business_date,isrefund,statusCode,operator_id,pay_total) "
"values('%1','%2','%3','%4','%5','%6','%7',%8,%9,%10,%11)")
.arg(temp[PosProps.Fm_id].toString())
.arg(session.data(PosProps.Fm_open_id).toString())
.arg(temp[PosProps.TransId].toString())
.arg(QString::fromLocal8Bit("非码会员支付"))
.arg(QString::number(FM_Pay))
.arg(temp["paid_total_amount"].toInt())
.arg(QDate::currentDate().toString("yyyy-MM-dd"))
.arg(false)
.arg(temp[PosProps.StatusCode].toInt())
.arg(jsonObj[PosProps.OperatorId].toString())
.arg(temp["paid_total_amount"].toInt());
}
else
{
sql = QString("insert into fmp_pay(code,trans_id,pay_id,pay_ebcode,total_amount,business_date,isrefund,statusCode,operator_id,pay_total) "
"values('%1','%2','%3','%4',%5,'%6',%7,%8,'%9',%10)")
.arg(session.data(PosProps.Fm_open_id).toString())
.arg(jsonObj[PosProps.TransId].toString())
.arg(QString::fromLocal8Bit("非码会员支付"))
.arg(QString::number(FM_Pay))
.arg(jsonObj[PosProps.Transaction].toObject()[PosProps.OrderAmount].toInt())
.arg(QDate::currentDate().toString("yyyy-MM-dd"))
.arg(false)
.arg(temp[PosProps.StatusCode].toInt())
.arg(jsonObj[PosProps.OperatorId].toString())
.arg(0);
}
FMP_DEBUG() << "vip sql: " << sql;
if(!query.exec(sql))
{
FMP_ERROR() << QString::fromLocal8Bit("写入会员支付结果失败: ") << query.lastError().text();
}
//同时记录会员余额支付、积分支付、卡券支付 的详情
if(temp[PosProps.StatusCode].toInt() == 100)
{
QJsonArray pay_ids = temp["pay_ids"].toArray();
for(int i = 0; i < pay_ids.size(); i++)
{
QJsonObject pay_id = pay_ids[i].toObject();
sql = QString("insert into fmp_vip values('%1','%2','%3','%4',%5)")
.arg(temp[PosProps.TransId].toString())
.arg(pay_id[PosProps.Pay_str].toString())
.arg(pay_id[PosProps.Coupon_code].toString())
.arg("")
.arg(pay_id[PosProps.Pay_amount].toInt());
if(!query.exec(sql))
{
FMP_ERROR() << QString::fromLocal8Bit("写入会员支付详情失败: ") << pay_id[PosProps.Pay_str].toString() << " " << query.lastError().text();
}
FMP_DEBUG() << "vip detail: " << sql;
}
}
}
db.close();
session.clear();
break;
}
......@@ -62,6 +146,9 @@ void FMVipDispatcher::doTask(const QByteArray &reqData, QByteArray &rspData)
epay->DockPayRequest(reqData);
rspData = epay->DockPayRespond();
epay->StopService();
QJsonObject temp = QJsonDocument::fromJson(rspData).object();
temp["pay_id"] = FM_QR_Pay; //把支付类型一并返回，monitor可以此区分具体的支付类型
rspData = QJsonDocument(temp).toJson(QJsonDocument::Compact);
break;
}
case FM_Refund: {
......
task/taskothers.cpp
......@@ -100,4 +100,5 @@ void TaskRefundOrder::packagePOSRsp()
posRspJsonObj[prop] = getServerJsonValue(ServerProps(prop));
}
posRspJsonObj[PosProps.Prompt] = 1;
posReqJsonObj[ServerProps(PosProps.Fm_id)] = getServerJsonValue(ServerProps(PosProps.Fm_id));
}
task/taskpay.cpp
......@@ -27,20 +27,20 @@ TaskPay::~TaskPay()
QByteArray TaskPay::doTask()
{
FMP_DEBUG() << __FUNCTION__;
QByteArray resultArray;
QString fm_open_id_pos = getPosJsonValue(PosProps.Fm_open_id).toString();
QString fm_open_id_session = session()->data(PosProps.Fm_open_id).toString();
if(fm_open_id_session == "" || fm_open_id_pos!=fm_open_id_session || session()->data(PosProps.CanPay).toBool() == false) {
preTask = new TaskLogin(posReqJsonObj, _session, this);
preTask->session()->addData(PosProps.FM_Type, FM_Pay);
QByteArray loginRst = preTask->doTask();
resultArray = preTask->doTask();
if(preTask->error() != FM_API_SUCCESS) {
QJsonObject result = QJsonDocument::fromJson(loginRst).object();
QJsonObject result = QJsonDocument::fromJson(resultArray).object();
result[PosProps.TransId] = getPosJsonValue(PosProps.TransId).toString();
result[PosProps.Pay_id] = FM_Pay;
loginRst = QJsonDocument(result).toJson(QJsonDocument::Compact);
resultArray = QJsonDocument(result).toJson(QJsonDocument::Compact);
FMMsgWnd::FailureWnd(result[PosProps.Msg].toString());
return loginRst;
return resultArray;
}
this->_session = preTask->session();
}
......@@ -53,18 +53,18 @@ QByteArray TaskPay::doTask()
connect(couponThread, SIGNAL(finished(Session*)), SLOT(onGetCoupons(Session*)));
couponThread->start();
QByteArray resultArray = FMTask::doTask();
resultArray = FMTask::doTask();
//如果是扫码支付，则直接返回其支付结果即可
if(isCodePay)
{
return codePayResult;
}
QJsonObject resultJson = QJsonDocument::fromJson(resultArray).object();
if(resultJson[PosProps.StatusCode].toInt() != FM_API_SUCCESS)
{
FMP_INFO() << "Pay failed: timeout. To reversal.";
FMP_INFO() << "Pay failed: To reversal.";
TaskRefundPay taskRefundPay(posReqJsonObj);
taskRefundPay.doTask();
......@@ -169,7 +169,6 @@ QByteArray TaskPay::doTask()
}
}
posRspJsonObj[PosProps.Pay_id] = FM_Pay;
QByteArray result = QJsonDocument(posRspJsonObj).toJson(QJsonDocument::Compact);
return result;
}
......@@ -279,7 +278,7 @@ void TaskPay::packagePOSRsp()
posRspJsonObj[PosProps.TransId] = getPosJsonValue(PosProps.TransId);
posRspJsonObj[PosProps.Fm_id] = getServerJsonValue(ServerProps(PosProps.Fm_id)).toString();
posRspJsonObj[PosProps.Fm_transId] = getPosJsonValue(PosProps.TransId).toString();
posRspJsonObj[PosProps.Fm_transId] = getPosJsonValue(ServerProps(PosProps.Fm_id)).toString();
QJsonArray servPayArray = getServerJsonValue("payList").toArray();
//支付方式描述
......@@ -337,7 +336,14 @@ void TaskPay::onCodePay()
epay->StopService();
isCodePay = true;
//保存虚拟支付标志
QJsonObject virtualPay = QJsonDocument::fromJson(rspData).object();
virtualPay["isCodePay"] = isCodePay;
rspData = QJsonDocument(virtualPay).toJson(QJsonDocument::Compact);
codePayResult = rspData;
//_window->accept();
_window->reject();
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment