php 订单过期处理,PHP实现处理过期或者超时订单，并还原库存
訂單是我們在日常開發(fā)中經(jīng)常會遇到的一個功能，最近在做一個訂單過期與超時的開發(fā)。訂單過期與超時就不用我解釋了吧，其實兩者都是同一個問題來著，就是訂單未支付的處理，我們要做的是對這些未支付的訂單到了一定時間就自動取消，好了，你第一反應(yīng)那肯定就是做一個定時任務(wù)了！是的，就是定時任務(wù)，但是哪個才會是最佳方案呢，下面來看看：
一、前端到時間請求取消
你肯定不會想著在前端來做定時請求取消該訂單的，因為如果客戶禁用了該應(yīng)用或者沒聯(lián)網(wǎng)，那到了一定時間時，還一直都是未處理狀態(tài)的。所以前端一般都是手動去觸發(fā)取消訂單的。
二、服務(wù)端定時查詢有沒有需要取消的訂單，然后批量處理。
這種方法我們用得最多的，不過存在準確度的問題，還有需要確認定時任務(wù)的周期，但是我們可以結(jié)合redis來實現(xiàn)，我們可以在存redis時候順便存在mysql這樣的數(shù)據(jù)庫做長久存儲然后用服務(wù)端定時查詢，這里我用到了redis的訂閱功能。
首先先修改一下配置
vim?/etc/redis/redis.conf
notify-keyspace-events?“Ex”?#x 代表了過期事件。
然后再重啟redis
service?redis?restart
這里創(chuàng)建4個文件
index.php? 創(chuàng)建訂單，發(fā)布消息，10s后查詢訂單狀態(tài)并更新訂單
lRange('order',0,9999999);
$mysql??????=?new?\mysql();
$mysql->connect();
$data???????=?['ordersn'=>'SN'.time().'T'.rand(10000000,99999999),'status'=>0,'createtime'=>date('Y-m-d?H:i:s',time())];
$mysql->insert('order',$data);
$order_sn???=?$data['ordersn'];
$redis2->setex($order_sn,10,$order_sn);
psubscribe.php，發(fā)布redis訂閱的一些邏輯處理
setOption();
$redis->psubscribe(array('__keyevent@0__:expired'),?'keyCallback');
//?回調(diào)函數(shù),這里寫處理邏輯
function?keyCallback($redis,?$pattern,?$chan,?$msg)
{
$mysql?=?new?\mysql();
$mysql->connect();
$where?=?"ordersn?=?'".$msg."'";
$mysql->select('order','',$where);
$finds=$mysql->fetchAll();
if(isset($finds[0]['status'])?&&?$finds[0]['status']==0){
$data???=?array('status'?=>?3,'updatetime'=>date('Y-m-d?H:i:s',time()));
$where??=?"id?=?".$finds[0]['id'];
$mysql->update('order',$data,$where);
}
}
這里我把redis的一些操作和mysql的一些處理做了封裝處理，這個你們可以用到你們自己的項目當中的
Redis2.class.php
redis?=?new?Redis();
$this->redis->connect($host,?$port);
$this->redis->auth('123456');
}
public?function?setex($key,?$time,?$val)
{
return?$this->redis->setex($key,?$time,?$val);
}
public?function?set($key,?$val)
{
return?$this->redis->set($key,?$val);
}
public?function?get($key)
{
return?$this->redis->get($key);
}
public?function?expire($key?=?null,?$time?=?0)
{
return?$this->redis->expire($key,?$time);
}
public?function?psubscribe($patterns?=?array(),?$callback)
{
$this->redis->psubscribe($patterns,?$callback);
}
public?function?setOption()
{
$this->redis->setOption(\Redis::OPT_READ_TIMEOUT,?-1);
}
public?function?lRange($key,$start,$end)
{
return?$this->redis->lRange($key,$start,$end);
}
public?function?lPush($key,?$value1,?$value2?=?null,?$valueN?=?null?){
return?$this->redis->lPush($key,?$value1,?$value2?=?null,?$valueN?=?null?);
}
public?function?delete($key1,?$key2?=?null,?$key3?=?null)
{
return?$this->redis->delete($key1,?$key2?=?null,?$key3?=?null);
}
}
db.class.php，對sql處理的一些封裝
'127.0.0.1',
'username'=>'root',
'password'=>'123456qwerty',
'database'=>'marhal',
'port'=>3306,
);
$host?=?$config['host'];????//主機地址
$username?=?$config['username'];//用戶名
$password?=?$config['password'];//密碼
$database?=?$config['database'];//數(shù)據(jù)庫
$port?=?$config['port'];????//端口號
$this->mysqli?=?new?mysqli($host,?$username,?$password,?$database,?$port);
}
/**
*?數(shù)據(jù)查詢
*?@param?$table?數(shù)據(jù)表
*?@param?null?$field?字段
*?@param?null?$where?條件
*?@return?mixed?查詢結(jié)果數(shù)目
*/
public?function?select($table,?$field?=?null,?$where?=?null)
{
$sql?=?"SELECT?*?FROM?`{$table}`";
//echo?$sql;exit;
if?(!empty($field))?{
$field?=?'`'?.?implode('`,`',?$field)?.?'`';
$sql?=?str_replace('*',?$field,?$sql);
}
if?(!empty($where))?{
$sql?=?$sql?.?'?WHERE?'?.?$where;
}
$this->result?=?$this->mysqli->query($sql);
return?$this->result;
}
/**
*?@return?mixed?獲取全部結(jié)果
*/
public?function?fetchAll()
{
return?$this->result->fetch_all(MYSQLI_ASSOC);
}
/**
*?插入數(shù)據(jù)
*?@param?$table?數(shù)據(jù)表
*?@param?$data?數(shù)據(jù)數(shù)組
*?@return?mixed?插入ID
*/
public?function?insert($table,?$data)
{
foreach?($data?as?$key?=>?$value)?{
$data[$key]?=?$this->mysqli->real_escape_string($value);
}
$keys?=?'`'?.?implode('`,`',?array_keys($data))?.?'`';
$values?=?'\''?.?implode("','",?array_values($data))?.?'\'';
$sql?=?"INSERT?INTO?`{$table}`(?{$keys}?)VALUES(?{$values}?)";
$this->mysqli->query($sql);
return?$this->mysqli->insert_id;
}
/**
*?更新數(shù)據(jù)
*?@param?$table?數(shù)據(jù)表
*?@param?$data?數(shù)據(jù)數(shù)組
*?@param?$where?過濾條件
*?@return?mixed?受影響記錄
*/
public?function?update($table,?$data,?$where)
{
foreach?($data?as?$key?=>?$value)?{
$data[$key]?=?$this->mysqli->real_escape_string($value);
}
$sets?=?array();
foreach?($data?as?$key?=>?$value)?{
$kstr?=?'`'?.?$key?.?'`';
$vstr?=?'\''?.?$value?.?'\'';
array_push($sets,?$kstr?.?'='?.?$vstr);
}
$kav?=?implode(',',?$sets);
$sql?=?"UPDATE?`{$table}`?SET?{$kav}?WHERE?{$where}";
$this->mysqli->query($sql);
return?$this->mysqli->affected_rows;
}
/**
*?刪除數(shù)據(jù)
*?@param?$table?數(shù)據(jù)表
*?@param?$where?過濾條件
*?@return?mixed?受影響記錄
*/
public?function?delete($table,?$where)
{
$sql?=?"DELETE?FROM?`{$table}`?WHERE?{$where}";
$this->mysqli->query($sql);
return?$this->mysqli->affected_rows;
}
}
對每一次訂單的訪問我們做了服務(wù)器監(jiān)聽任務(wù)，如下：
cd?/var/www/html/redis
#即時監(jiān)聽，ctrl+c?退出監(jiān)聽??ctrl+z?暫停監(jiān)聽
nohup?php?psubscribe.php
#后臺監(jiān)聽
nohup?php?psubscribe.php?&
設(shè)置本地域名并訪問http://www.startphp.cn/index.php
此時，每訪問一次index.php，就會創(chuàng)建一個訂單，10s鐘后，如果該訂單依舊處于未支付狀態(tài)，就設(shè)置訂單失效。
這里要注意一下：
在命令之前加上 nohup ，啟動的進程將會忽略linux的掛起信號 (SIGHUP)
這時候，當我們組合 nohup 和 &兩種方式時，啟動的進程不會占用控制臺，并且不依賴控制臺，控制臺關(guān)閉之后，進程被1號進程收養(yǎng)，成為孤兒進程，這就和守護進程的機制非常類似了，并且nohup默認會把程序的輸出重定向到當前目錄下的nohup.out文件，如果沒有可寫權(quán)限，則寫入 $homepath/nohup.out
但是php的cli模式在服務(wù)器運行后，總是會掉線，處理這個問題的方法，寫一個腳本
1.編寫shell腳本，定時檢查進程是否存在，不存在的話就開啟服務(wù)，并且將運行情況寫入日志
cd?/
mkdir?mytask
cd?mytask
touch?phprunning.sh
vi?phprunning.sh
腳本文件如下：
#!/bin/sh
PIDS=`pidof?php`
if?[?"$PIDS"?!=?""?];?then
echo?"在運行"
echo?-e?$(date?+%Y"."%m"."%d"?"%k":"%M":"%S)"?running....."?>>?/mytask/task.run.log
else
echo?"不在運行，開始啟動"
echo?-e?$(date?+%Y"."%m"."%d"?"%k":"%M":"%S)"?start?php?start....."?>>?/mytask/task.start.log
cd?/var/www/html/redis
php?psubscribe.php?&
echo?-e?$(date?+%Y"."%m"."%d"?"%k":"%M":"%S)"?start?php?success....."?>>?/mytask/task.start.log
fi
在crontab任務(wù)里創(chuàng)建任務(wù)，這里設(shè)定的是每5s檢查一次，crontab -e
*?*?*?*?*?sleep?5;?sh?/mytask/phprunning.sh?>>?/mytask/crontab.log
*?*?*?*?*?sleep?10;?sh?/mytask/phprunning.sh?>>?/mytask/crontab.log
*?*?*?*?*?sleep?15;?sh?/mytask/phprunning.sh?>>?/mytask/crontab.log
*?*?*?*?*?sleep?20;?sh?/mytask/phprunning.sh?>>?/mytask/crontab.log
*?*?*?*?*?sleep?25;?sh?/mytask/phprunning.sh?>>?/mytask/crontab.log
*?*?*?*?*?sleep?30;?sh?/mytask/phprunning.sh?>>?/mytask/crontab.log
*?*?*?*?*?sleep?35;?sh?/mytask/phprunning.sh?>>?/mytask/crontab.log
*?*?*?*?*?sleep?40;?sh?/mytask/phprunning.sh?>>?/mytask/crontab.log
*?*?*?*?*?sleep?45;?sh?/mytask/phprunning.sh?>>?/mytask/crontab.log
*?*?*?*?*?sleep?50;?sh?/mytask/phprunning.sh?>>?/mytask/crontab.log
*?*?*?*?*?sleep?55;?sh?/mytask/phprunning.sh?>>?/mytask/crontab.log
效果你可以查看task.run.log
cat?/mytask/task.run.log
結(jié)果如下：
-e?2019.10.22?14:28:41?running.....
-e?2019.10.22?14:28:46?running.....
-e?2019.10.22?14:28:51?running.....
-e?2019.10.22?14:28:56?running.....
-e?2019.10.22?14:29:06?running.....
-e?2019.10.22?14:29:11?running.....
-e?2019.10.22?14:29:16?running.....
-e?2019.10.22?14:29:21?running.....
-e?2019.10.22?14:29:26?running.....
-e?2019.10.22?14:29:31?running.....
-e?2019.10.22?14:29:36?running.....
-e?2019.10.22?14:29:41?running.....
-e?2019.10.22?14:29:46?running.....
與50位技術(shù)專家面對面20年技術(shù)見證，附贈技術(shù)全景圖總結(jié)
以上是生活随笔為你收集整理的php 订单过期处理,PHP实现处理过期或者超时订单，并还原库存的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： php限制小程序访问,PHP投票小程序，
- 下一篇： s matlab toolbox,Mat