《PHP應(yīng)用：PHP實(shí)現(xiàn)電商訂單自動(dòng)確認(rèn)收貨redis隊(duì)列》要點(diǎn)：
本文介紹了PHP應(yīng)用：PHP實(shí)現(xiàn)電商訂單自動(dòng)確認(rèn)收貨redis隊(duì)列，希望對(duì)您有用。如果有疑問(wèn)，可以聯(lián)系我們。
一、場(chǎng)景PHP教程
之前做的電商平臺(tái),用戶在收到貨之后,大部分都不會(huì)主動(dòng)的點(diǎn)擊確認(rèn)收貨,導(dǎo)致給商家結(jié)款的時(shí)候,商家各種投訴,于是就根據(jù)需求,要做一個(gè)訂單在發(fā)貨之后的x天自動(dòng)確認(rèn)收貨.所謂的訂單自動(dòng)確認(rèn)收貨,就是在在特定的時(shí)間,執(zhí)行一條update語(yǔ)句,改變訂單的狀態(tài).PHP教程
二、思路PHP教程
最笨重的做法,通過(guò)linux后臺(tái)定時(shí)任務(wù),查詢符合條件的訂單,然后update.最理想情況下,如果每分鐘都有需要update的訂單,這種方式也還行.奈何平臺(tái)太小,以及賣家發(fā)貨時(shí)間大部分也是密集的,不會(huì)分散在24小時(shí)的每分鐘.那么,定時(shí)任務(wù)的話,查詢過(guò)多,不適合.這里可以先把將要自動(dòng)確認(rèn)收貨的訂單信息存儲(chǔ)到其他介質(zhì)上,比如redis,memcache,rabbitmq,然后執(zhí)行的腳本從前面的介質(zhì)獲取到訂單信息來(lái)判斷,這里可以大大的減少數(shù)據(jù)庫(kù)的查詢壓力.PHP教程
redis隊(duì)列的生產(chǎn)者PHP教程
對(duì)此,我們選擇每天在凌晨?jī)牲c(diǎn)的時(shí)候,通過(guò)linux的定時(shí)任務(wù)把即將要確認(rèn)收貨的訂單信息查詢出來(lái),然后存儲(chǔ)在redis上,redis上我們選擇的隊(duì)列,隊(duì)列處理的特點(diǎn)就是先進(jìn)先出,前面的數(shù)據(jù)在查詢訂單時(shí),通過(guò)發(fā)貨時(shí)間排序,所以最先出隊(duì)列的肯定是距離規(guī)定的自動(dòng)收貨時(shí)間最近的訂單.代碼如下PHP教程
$successCount=0;
$failCount=0;
$screen_time = 3600*24*9;//設(shè)置篩選天數(shù)
$data = array();
$now_time = time();
//查詢符合要求的數(shù)據(jù)
$sql="select id,send_time as deliver_time from `order` where is_send=1 and is_del=0 and is_cancel=0 and is_token=0 and send_time>0 and send_time + {$screen_time} < $now_time
order by send_time asc";
$res = $con->query($sql);
//當(dāng)隊(duì)列還有數(shù)據(jù)時(shí)將數(shù)據(jù)記錄并清除
while($redis->LLEN('auto_recevice_order')){
$txt = '執(zhí)行時(shí)間：'.date('Y-m-d H:i:s').',信息:'.$redis->RPOP('auto_recevice_order');
file_put_contents('./autoToken/fail_log.txt',$txt."\r\n".PHP_EOL,FILE_APPEND);
$failCount++;
}
//重新填充數(shù)據(jù)進(jìn)隊(duì)列
while ($row = $res->fetch_assoc()) {
$successCount++;
$redis->LPUSH('auto_recevice_order',json_encode($row1));
}
$con->close();
$success=date('Y-m-d H:i:s').':[推送成功]:本次成功推送數(shù)據(jù)：'.$successCount.'條;記錄上次處理失敗數(shù)據(jù):'.$failCount."條\r\n";
file_put_contents('./success_log.txt',$success."\r\n".PHP_EOL,FILE_APPEND);
redis隊(duì)列的消費(fèi)者PHP教程
隊(duì)列的消費(fèi)者沒(méi)有通過(guò)linux的定時(shí)任務(wù)去做,用linux的screen+php cli模式執(zhí)行php腳本,消費(fèi)者只需要不斷的從隊(duì)列中讀取訂單信息,然后判斷訂單信息中的發(fā)貨時(shí)間,如果達(dá)到自動(dòng)收貨的要求,就執(zhí)行update語(yǔ)句.同時(shí)如果沒(méi)有達(dá)到收貨的時(shí)間,而且與收貨時(shí)間間距比較大的時(shí)候,可以讓php腳本休眠sleep一定的時(shí)間數(shù),這個(gè)時(shí)間數(shù)自己調(diào)節(jié)設(shè)計(jì),獲取出來(lái)的未達(dá)到時(shí)間要求的訂單,需要重新推送到redis隊(duì)列中去,而且還是隊(duì)列的頂端.以便下次獲取.代碼如下：PHP教程
$set_time = 3600*24*10;//設(shè)置幾天后自動(dòng)收貨
while(true){
if($i%30==0){
usleep(10);//防止while 循環(huán)使CPU使用率過(guò)高
}
if($redis->LLEN('auto_recevice_order')){
$data = json_decode($redis->RPOP('auto_recevice_order'));
$id = (int)$data->id;//將數(shù)據(jù)轉(zhuǎn)化為整形
$deliver_time = (int)$data->deliver_time;//將數(shù)據(jù)轉(zhuǎn)化為整形
$res1 = $res2 =false;
$now_time = time();
if(($deliver_time+$set_time)<$now_time){
$sql1 = "update `order` set `is_token`='1',`token_time` = $now_time where id=$id and is_send=1 and is_del=0 and is_cancel=0 and is_token=0 and send_time + {$set_time} < $now_time";
$res1 = $con->query($sql1);//更新數(shù)據(jù)
$rows = mysqli_affected_rows($con);
if($rows){
$ip = $this->getIp();
$sql2 = "insert into `order_log`(`order_id`,`log_msg`,`log_ip`,`log_role`,`log_user`,`log_order_state`,`log_time`) VALUES($id,'系統(tǒng)自動(dòng)收貨','$ip','系統(tǒng)','服務(wù)器','收貨',$now_time)";//寫入訂單日志
$res2 = $con->query($sql2);//添加日志數(shù)據(jù)
}
}
if($res1==false){//將沒(méi)達(dá)到條件的數(shù)據(jù)重新插入隊(duì)列中
$redis->RPUSH('auto_recevice_order',json_encode(array('id'=>$id,'deliver_time'=>$deliver_time)));
}
}
$i++;
}
這里執(zhí)行php腳本,需要用到linux的screen或者supervisor、nohup守護(hù)進(jìn)程.具體用法可自行百度.同樣腳本里面最好有必須的日志記錄.PHP教程
三、思考PHP教程
隨著業(yè)務(wù)的增長(zhǎng),在隊(duì)列中同一秒內(nèi),存在的多個(gè)需要處理的訂單,而一次只能從隊(duì)列中取出一個(gè)相關(guān)訂單信息的時(shí)候,可以采用一個(gè)生產(chǎn)者多個(gè)消費(fèi)者的模式,這種情況下,可以用到鎖機(jī)制,保證一條消息只能到達(dá)一個(gè)消費(fèi)者.當(dāng)redis數(shù)據(jù)達(dá)到一定的量之后,也可以適當(dāng)?shù)恼{(diào)整生產(chǎn)者的執(zhí)行頻率和對(duì)應(yīng)的條件.PHP教程
以上這篇PHP實(shí)現(xiàn)電商訂單自動(dòng)確認(rèn)收貨redis隊(duì)列就是小編分享給大家的全部?jī)?nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持維易PHP.PHP教程
轉(zhuǎn)載請(qǐng)注明本頁(yè)網(wǎng)址：
http://www.fzlkiss.com/jiaocheng/795.html
