# 某大型項目應用本Redis類源碼示例(含事務 樂觀鎖)
### 服務層源碼
~~~
/**
* @description
* @author Mikkle
*/
public function completeParkByBill($data){
$this->functionName = __FUNCTION__;
$this->args = $data;
//檢驗數據
if ( ! isset($data[OptionsCenter::$fieldChargeToken]) || ! $this->parseToken($data[OptionsCenter::$fieldChargeToken]) ){
$this->addError("登錄Token參數缺失或已經失效");
return ShowCode::jsonCodeWithoutData(1003,$this->error);
}
if(! $this->checkArrayValueEmpty($data,[OptionsCenter::$fieldBillNum,OptionsCenter::$fieldPayMoney])){
$this->addError("信息中缺失必要的信息");
return ShowCode::jsonCodeWithoutData(1003,$this->error);
}
$billCenter = BillInfoCenter::instance($data[OptionsCenter::$fieldBillNum]);
$data[OptionsCenter::$fieldSerialNum] = $billCenter->getParkCarSerialNum();
$data[OptionsCenter::$fieldParkMoney] = $billCenter->getInfoFieldValue(OptionsCenter::$fieldParkMoney);
$data[OptionsCenter::$fieldBillMoney] = $billCenter->getInfoFieldValue(OptionsCenter::$fieldBillMoney);
if (!is_numeric($data[OptionsCenter::$fieldBillMoney])|| !is_numeric($data[OptionsCenter::$fieldPayMoney]) ){
$this->addError("賬單金額類型錯誤");
return ShowCode::jsonCodeWithoutData(1003,$this->error);
}elseif ( $data[OptionsCenter::$fieldPayMoney]<=0){
$this->addError("付款金額不能小于等于0");
return ShowCode::jsonCodeWithoutData(1003,$this->error);
}elseif ($data[OptionsCenter::$fieldBillMoney] != $data[OptionsCenter::$fieldPayMoney]){
if ($data[OptionsCenter::$fieldBillMoney]> $data[OptionsCenter::$fieldPayMoney]){
if (!$this->checkArrayValueEmpty($data,[ OptionsCenter::$fieldDebtType]) || $data[ OptionsCenter::$fieldDebtType] !=2 ){
$this->addError("付款金額小于訂單金額時,缺失拒付類型正確參數");
return ShowCode::jsonCodeWithoutData(1003,$this->error);
}
}elseif ($data[OptionsCenter::$fieldBillMoney] < $data[OptionsCenter::$fieldPayMoney]){
$this->addError("付款金額不可以大于訂單金額");
return ShowCode::jsonCodeWithoutData(1003,$this->error);
}
}
//流水號信息驗證
if ( ! isset($data[OptionsCenter::$fieldSerialNum]) || empty($data[OptionsCenter::$fieldSerialNum]) ){
$this->addError("信息中缺失必要的停車序號信息");
return ShowCode::jsonCodeWithoutData(1003,$this->error);
}
if (!AuthCenter::existParkSerialBySerialId($data[OptionsCenter::$fieldSerialNum])){
$this->addError("信息中的序號信息不正確");
return ShowCode::jsonCodeWithoutData(1003,$this->error);
};
$carSerialCenter = CarSerialCenter::instance($data[OptionsCenter::$fieldSerialNum]);
$parkingInfo = $carSerialCenter->getParkingInfo($this->options);
if ($parkingInfo[OptionsCenter::$fieldBillNum] != $data[OptionsCenter::$fieldBillNum]){
$this->addError("你的Bill單號已經過期,請使用最新的Bill號");
return ShowCode::jsonCodeWithoutData(1003,$this->error);
}
//檢測流水訂單狀態
if (!$this->checkParkSerialBillState($parkingInfo)){
return ShowCode::jsonCodeWithoutData(1003,$this->error);
}
//判斷賬單是否有5分鐘內的結清賬單
if ($this->checkBillPayState($parkingInfo)){
return ShowCode::jsonCode(1099,[OptionsCenter::$fieldSerialNum=>$data[OptionsCenter::$fieldSerialNum]]);
}
$endTime = $billCenter->getInfoFieldValue(OptionsCenter::$fieldEndTime);
//附加上收費員信息和日報ID
$data[OptionsCenter::$idCharge] = $this->chargeId;
$data[OptionsCenter::$idDocument] = $this->terminalId;
if ($data[OptionsCenter::$fieldBillMoney] == $data[OptionsCenter::$fieldPayMoney] ){
$status = 2;
}elseif($data[OptionsCenter::$fieldBillMoney] > $data[OptionsCenter::$fieldPayMoney]){
$status = 1;
}else{
$status = 0;
}
//獲取已經付款金額
$alreadyPayMoney = $this->getAlreadyPayMoney($parkingInfo);
if ($alreadyPayMoney>0){
}
$billData =[
OptionsCenter::$fieldBillNum=>$data[OptionsCenter::$fieldBillNum],
OptionsCenter::$fieldPayMoney => $data[OptionsCenter::$fieldPayMoney],
OptionsCenter::$fieldBillTime =>$this->getTime($endTime),
OptionsCenter::$fieldBillStatus =>$status ,
];
$serialData= [
OptionsCenter::$prefixEnd . OptionsCenter::$idCharge => $this->chargeId,
OptionsCenter::$prefixEnd . OptionsCenter::$nameCharge => $this->chargeName,
OptionsCenter::$prefixEnd . OptionsCenter::$idTerminal => $this->terminalId,
OptionsCenter::$fieldParkMoney => $data[OptionsCenter::$fieldParkMoney] ,
//總付款金額
OptionsCenter::$fieldPayMoney => $alreadyPayMoney+$data[OptionsCenter::$fieldPayMoney],
OptionsCenter::$fieldPayStatus => $status , //已結清費用2 部分為1
OptionsCenter::$fieldEndTime => $this->getTime($endTime),
OptionsCenter::$fieldCompleteTime => time(),
OptionsCenter::$stringStatus => 2,
];
switch (true){
//全款結賬賬單
case($status==2):
if ( !$carSerialCenter->completeBillSerialByAllCash($data,$serialData,$billData)){
return ShowCode::jsonCode(1008,"存儲停車信息失敗");
}
//處理報表信息
DocumentInfoCenter::instance($this->documentId)->updateDocumentByParkSerialNum($data[OptionsCenter::$fieldSerialNum]);
//清除泊位信息
if ($this->checkArrayValueEmpty($parkingInfo,OptionsCenter::$idPlace)){
$this->clearPlaceParkInfo($parkingInfo[OptionsCenter::$idPlace],$data[OptionsCenter::$fieldSerialNum]);
}
return ShowCode::jsonCode(1001, $carSerialCenter->getParkingInfo(),"",[OptionsCenter::$stringVersion=>ParkInfoCenter::instance($this->parkId)->updateVersion()]);
break;
//拒付部分訂單
case($status==1):
if ( !$carSerialCenter->completeBillSerialByPartCash($data,$serialData,$billData)){
return ShowCode::jsonCode(1008,"存儲停車信息失敗");
}
//處理報表信息
DocumentInfoCenter::instance($this->documentId)->updateDocumentByParkSerialNum($data[OptionsCenter::$fieldSerialNum]);
//清除泊位信息
if ($this->checkArrayValueEmpty($parkingInfo,OptionsCenter::$idPlace)){
$this->clearPlaceParkInfo($parkingInfo[OptionsCenter::$idPlace],$data[OptionsCenter::$fieldSerialNum]);
}
return ShowCode::jsonCode(1001, $carSerialCenter->getParkingInfo(),"",[OptionsCenter::$stringVersion=>ParkInfoCenter::instance($this->parkId)->updateVersion()]);
break;
}
return ShowCode::jsonCode(1008,"你不應該看到這個");
}
~~~
### 數據邏輯處理
~~~
/**
* @description
* @author Mikkle
*/
public function completeBillSerialByPartCash($data, $serialData, $billData){
//獲取當前的收費員的帳號余額和版本號
$chargeAmount = Db::table(OptionsCenter::$tableCharge)
->where([OptionsCenter::$pk =>$data[OptionsCenter::$idCharge]])
->field([OptionsCenter::$stringAmount,OptionsCenter::$prefixAmount.OptionsCenter::$stringVersion])->find();
if (!is_numeric($chargeAmount[OptionsCenter::$stringAmount]) || !is_numeric($chargeAmount[OptionsCenter::$prefixAmount.OptionsCenter::$stringVersion]) ){
throw new Exception("收費員的余款數據不正確");
}
$amount = (int)$chargeAmount[OptionsCenter::$stringAmount];
$newAmount = $amount-(int)$data[OptionsCenter::$fieldPayMoney];
$version = (int)$chargeAmount[OptionsCenter::$prefixAmount.OptionsCenter::$stringVersion];
//收費員賬戶流水表信息
$chargePriceDate = [
OptionsCenter::$fieldBillNum=>$data[OptionsCenter::$fieldBillNum],
OptionsCenter::$stringType=>2, //金額的類型 （1為 充值 2為扣除）
OptionsCenter::$stringMode=>2 , //充值方式(1 人工充值或扣除) 2 現金繳款扣除
OptionsCenter::$stringDesc=>"停車單:{$data[OptionsCenter::$fieldBillNum]}扣款",
OptionsCenter::$stringPrice => $data[OptionsCenter::$fieldPayMoney],
OptionsCenter::$stringAmount => $newAmount,
];
$serialInfo = $this->getInfoList();
//設置拒付信息
$debtData=[
OptionsCenter::$fieldDebtNum=>RandNumCenter::createDebtSerialNumber(), //欠費流水號
OptionsCenter::$fieldSerialNum=> $serialInfo[OptionsCenter::$fieldSerialNum], //停車流水號
OptionsCenter::$fieldCarCode=>$serialInfo[OptionsCenter::$fieldCarCode],
OptionsCenter::$idPark=>$serialInfo[OptionsCenter::$idPark],
OptionsCenter::$namePark=>$serialInfo[OptionsCenter::$namePark],
OptionsCenter::$fieldDebtType=>2, //拒繳部分
OptionsCenter::$fieldStartTime=>$serialInfo[OptionsCenter::$fieldStartTime],
OptionsCenter::$prefixStart.OptionsCenter::$idCharge=>$serialInfo[OptionsCenter::$prefixStart.OptionsCenter::$idCharge],
OptionsCenter::$prefixStart.OptionsCenter::$nameCharge=>$serialInfo[OptionsCenter::$prefixStart.OptionsCenter::$nameCharge],
OptionsCenter::$fieldEndTime=>$serialData[OptionsCenter::$fieldEndTime],
OptionsCenter::$prefixEnd.OptionsCenter::$idCharge => $serialData[OptionsCenter::$prefixEnd.OptionsCenter::$idCharge],
OptionsCenter::$prefixEnd.OptionsCenter::$nameCharge => $serialData[OptionsCenter::$prefixEnd.OptionsCenter::$nameCharge],
OptionsCenter::$stringStatus=>1,
OptionsCenter::$fieldCreateTime=>time(),
OptionsCenter::$fieldParkMoney=>$serialData[OptionsCenter::$fieldParkMoney],
OptionsCenter::$fieldPayMoney=>$serialData[OptionsCenter::$fieldPayMoney],
OptionsCenter::$fieldDebtMoney => (int)($serialData[OptionsCenter::$fieldParkMoney] - $serialData[OptionsCenter::$fieldPayMoney]) ,
];
//設置付款信息
$payDate=[
OptionsCenter::$fieldPayNum=>RandNumCenter::createPaySerialNumber(),
OptionsCenter::$fieldBillNum=>$data[OptionsCenter::$fieldBillNum],
OptionsCenter::$fieldSerialNum=>$this->infoId,
OptionsCenter::$idPark=>$serialData[OptionsCenter::$idPark],
OptionsCenter::$fieldPayType=>1,
OptionsCenter::$fieldPayMoney=>$data[OptionsCenter::$fieldPayMoney],
OptionsCenter::$fieldPayTime=>RandNumCenter::getTimeString(),
OptionsCenter::$fieldCreateTime=>time(),
OptionsCenter::$stringStatus=>1,
];
try{
//多表處理 開啟事務
Db::startTrans();
//升級收費員余額 加入了樂觀鎖判斷
if (!Db::table(OptionsCenter::$tableCharge)
->where([OptionsCenter::$pk=>$data[OptionsCenter::$idCharge],OptionsCenter::$prefixAmount.OptionsCenter::$stringVersion =>$version ])
->update([OptionsCenter::$stringAmount=>$newAmount,OptionsCenter::$prefixAmount.OptionsCenter::$stringVersion=>$version+1])
){
throw new Exception("操作員的余額信息已經變動,請重試");
}
//插入欠費信息
if (!Db::table(OptionsCenter::$tableParkInfoDebt)->insert($debtData)){
throw new Exception("插入欠費信息失敗");
}
//插入付款流水信息
if (!Db::table(OptionsCenter::$tableParkInfoPay)->insert($payDate)){
throw new Exception("插入付款流水信息失敗");
}
//插入金額流水信息
if (!Db::table(OptionsCenter::$tableChargePrice)->insert($chargePriceDate)){
throw new Exception("插入金額流水信息失敗");
}
if (!Db::table(OptionsCenter::$tableParkInfoTemp)->where([OptionsCenter::$fieldSerialNum=>$this->infoId])->update($serialData)){
throw new Exception("保存訂單流水信息失敗");
}
if (!Db::table(OptionsCenter::$tableParkInfoBill)->where([OptionsCenter::$fieldBillNum=>$data[OptionsCenter::$fieldBillNum]])->update($billData)){
throw new Exception("完成賬單信息失敗");
}
$this->updateAllBillBySerialNumToComplete();
//更新流水信息
$this->setInfoArray($serialData);
//更新賬單信息
BillInfoCenter::instance($data[OptionsCenter::$fieldBillNum])->setInfoArray($billData);
//設置7天 自動釋放redis內存
BillInfoCenter::instance($data[OptionsCenter::$fieldBillNum])->setExpire(3600*24*7);
//更新帳號余額
ChargeInfoCenter::instance($data[OptionsCenter::$idCharge])->refreshChargeAmount($newAmount);
//處理泊位信息
$this->setExpire(3600*24*7);
Db::commit();
return true;
}catch (Exception $e){
Log::error($e->getMessage());
dump($e);
Db::rollback();
return false;
}
}
~~~
感謝大家關注 交流請加QQ群 321449759
- 序言及更新日志
- 前言一 開發PHP必備的環境(你可以不看)
- LinUX系統ThinkPHP5鏈接MsSQL數據庫的pdo_dblib擴展
- centos7.2掛載硬盤攻略
- Centos系統Redis安裝及Redis的PHP擴展安裝
- Centos系統增加Swap(系統交換區)的方法
- 前言二 開發PHP軟件配置和介紹(你依然可以不看)
- 數據庫SQL文件
- 本地Git(版本控制)的搭建
- GIT遠程倉庫的克隆和推送
- Git常用命令
- PHP面向對象思想實戰經驗領悟
- PHP面向對象實戰----命名空間
- PHP面向對象實戰----繼承
- 基類實戰--底層方法封裝
- 基類實戰--構造函數實戰
- 基類實戰--析構函數的使用
- TP5實戰開發前篇---控制器(controller)
- 控制器中Request類的使用
- 控制器中基類的使用
- TP5實戰開發前篇---模型篇(model)
- TP5實戰開發前篇---驗證器篇(Validate)
- TP5實戰課程入門篇---花拳繡腿
- 模塊以及類的文件的建立
- Api開發------單條信息顯示
- Api開發---單條信息復雜關聯顯示
- Api開發---查詢信息緩存Cache的應用
- TP5實戰技巧---開發思路 引路造橋
- TP5實戰技巧---整合基類 化繁為簡
- TP5實戰課程入門篇---數據操作
- Api開發---數據的添加和修改
- API開發---快速開發API通用接口
- TP5專用微信sdk使用教程
- THINKPHP5微信SDK更新記錄及升級指導
- TP5專用SDK 微信參數配置方法
- 微信公眾號推送接口對接教程
- 微信推送接口對接示例含掃描登錄微信端部分
- TP5專用微信支付SDK使用簡介
- TP5專用支付寶支付SDK使用說明
- 使用NW將開發的網站打包成桌面應用
- TP5高階實戰課程 進階篇概述
- 進階篇一 實戰開發之習慣及要求
- 進階篇二 實戰開發之控制器
- 控制器基類之控制器基類使用方法
- 控制器基類之控制器基類常用方法分享
- 控制器基類之構造函數的使用方法
- 進階篇三 實戰開發之權限控制
- TP5實戰源碼 --- 全局用戶信息驗證類Auth
- TP5實戰源碼 --- 微信Auth實戰開發源碼
- 進階篇四 實戰開發之模型
- 模型基類之模型基類的用途
- 模型基類之常用數據處理方法
- 模型邏輯層之實戰代碼(含事務)
- 模型實戰開發之模型常用方法
- 模型實戰源碼 --- 樂觀鎖的應用
- 模型實戰技巧---Model事件功能的使用
- 模型事件實戰應用---數據庫操作日志
- 進階篇五 實戰開發之緩存(Cache)
- TP5實戰源碼---應用緩存獲取城市信息
- TP5實戰源碼---應用緩存獲取分類詳情
- 進階篇六 TP5類庫的封裝和使用
- DataEdit快捷操作類庫
- ShowCode快捷使用類庫
- 阿里大于 短信API接口 TP5專用類庫
- DatabaseUpgrade數據庫對比及更新類庫
- AuthWeb權限類使用說明
- 進階篇七 服務層的應用
- 服務層源碼示例
- 服務層基類源碼
- 進階篇八 應用層Redis數據處理基類
- Redis服務層基類源碼
- 進階篇九 使用Redis類庫處理一般的搶購(秒殺)活動示例
- 進階篇十 某大型項目應用本Redis類源碼示例(含事務 樂觀鎖)
- 進階篇十一 邏輯層的應用
- 邏輯層基類源碼
- 進階篇 服務層代碼示例
- 高階實戰課程 進階篇持續新增中
- 高階篇一 TP5命令行之守護任務源碼
- TP5實戰源碼 --- 命令行
- TP5實戰源碼 --- 通過shell建立PHP守護程序
- 高階篇二 使用Redis隊列發送微信模版消息
- 高階篇二 之 Worker隊列基類源碼
- 高階篇三 TP5實戰之Redis緩存應用
- Redis實戰源碼之Hash專用類庫源碼
- Redis實戰源碼之Model類結合
- Redis實戰源碼之模型Hash基類源碼
- Redis實戰源碼之Hash查詢使用技巧
- Redis實戰源碼之 shell腳本中redis賦值和取值
- 高階篇四 Swoole的實戰應用
- swoole基類代碼
- Swoole擴展WebsocketServer專用類
- 基于Swoole的多Room聊天室的程序
- Swoole守護服務shell源碼
- 高階篇五 命令行異步多進程隊列類的應用
- tp_worker類源碼
- WorkerBase
- WorkerCommand
- WorkerRedis
- Redis類
- CycleWorkBase
- WorkerHookBase異步鉤子
- 隊列日志SQL
- 高階篇六 定時執行隊列類庫以及使用方法
- 定時隊列類庫源碼
- 高階篇七 異步執行循環隊列類庫以及使用教程
- CycleWorkBase源碼
- 高階實戰課程 進階篇持續新增中
- Extend便捷類庫源碼庫
- 阿里相關類庫
- SendSms--驗證碼API接口文件
- 權限相關類庫目錄
- AuthWeb 權限驗證類庫
- Redis便捷操作類庫(20171224更新)
- Redis
- Tools工具類庫集
- Curl類庫
- DataEdit
- Rand類庫
- ShowCode類庫
- Upload類庫
- 附件集合
- 附件一:微信支付 實戰開發源碼
- 微信支付類庫源代碼
- Common_util_pub.php
- DownloadBill_pub.php
- JsApi_pub.php
- NativeCall_pub.php
- NativeLink_pub.php
- OrderQuery_pub.php
- Refund_pub.php
- RefundQuery_pub.php
- SDKRuntimeException.php
- ShortUrl_pub.php
- UnifiedOrder_pub.php
- Wxpay_client_pub.php
- Wxpay_server_pub.php
- WxPayConf_pub.php
- 微信支付回調頁面源碼
- 附件二 順豐快遞BSP接口實戰開發源碼
- 順豐快遞BSP接口實戰開發源碼
- 順豐BSP基類
- 順豐BSP基礎代碼
- 順豐BSP下單接口
- 順豐BSP查單接口
- 順豐BSP確認/取消接口
- 附件三 APP注冊登陸接口源碼(含融云平臺接口)
- 附件四 TP5訂單Model(含事務 獲取器 修改器等方法)
- 附錄五 RSA加密解密
- Rsa文件源碼
- 附件六 阿里大于短信接口
- 附件七 AES加解密類
- AES加解密類源碼
- 附件八 TP5路由設置源碼
- 附件九 TP5 Excel導入導出下載便捷類庫
- Excel類庫TP5源碼
- 附件十 TP5便捷操作Redis類庫源碼
- TP5源碼 Redis操作便捷類庫
- 附件十一 TP5源碼 上傳文件入庫類源碼
- 上傳類Upload源碼
- Upload類上傳配置文件
- 存儲圖像文件的數據庫SQL文件
- 存儲文件的數據庫SQL文件
- 附件十二 TP5 圖片處理增強類 支持縮略圖在線顯示
- 附件十三 微信推送消息接口類庫源碼
- 附件十三 微信推送消息接口類庫源碼 之 基類
- 附件十四 存儲微信昵稱的處理方法