本篇主要介紹PHP實現電商訂單自動確認收貨redis隊列的方法,有興趣的朋友參考下,希望對大家有幫助。
一、場景
#之前做的電商平台,用戶收到貨之後,大部分都不會主動的點擊確認收貨,導致給商家結帳的時候,商家各種投訴,於是就根據需求,要做一個訂單在發貨之後的x天自動確認收貨。所謂的訂單自動確認收貨,就是在特定的時間,執行一條update語句,改變訂單的狀態。
二、想法
#最笨重的做法,透過linux後台定時任務,查詢符合條件的訂單,然後update。最理想情況下,如果每分鐘都有需要update的訂單,這種方式也還好。奈何平台太小,以及賣家出貨時間大部分也是密集的,不會分散在24小時的每分鐘。那麼,定時任務的話,查詢過多,不適合。這裡可以先把將要自動確認收貨的訂單資訊儲存到其他媒體上,例如redis,memcache,rabbitmq,然後執行的腳本從前面的媒體獲取到訂單資訊來判斷,這裡可以大大的減少資料庫的查詢壓力。
redis隊列的生產者
對此,我們選擇每天在凌晨兩點的時候,透過linux的定時任務把即將要確認收貨的訂單資訊查詢出來,然後儲存在redis上,redis上我們選擇的隊列,隊列處理的特點就是先進先出,前面的資料在查詢訂單時,透過出貨時間排序,所以最先出隊列的肯定是距離規定的自動收貨時間最近的訂單。程式碼如下
$successCount=0; $failCount=0; $screen_time = 3600*24*9;//设置筛选天数 $data = array(); $now_time = time(); //查询符合要求的数据 $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); //当队列还有数据时将数据记录并清除 while($redis->LLEN('auto_recevice_order')){ $txt = '执行时间:'.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++; } //重新填充数据进队列 while ($row = $res->fetch_assoc()) { $successCount++; $redis->LPUSH('auto_recevice_order',json_encode($row1)); } $con->close(); $success=date('Y-m-d H:i:s').':[推送成功]:本次成功推送数据:'.$successCount.'条;记录上次处理失败数据:'.$failCount."条\r\n"; file_put_contents('./success_log.txt',$success."\r\n".PHP_EOL,FILE_APPEND);
redis佇列的消費者
##佇列的消費者沒有通過linux的定時任務去做,用linux的screen php cli模式執行php腳本,消費者只需要不斷的從隊列中讀取訂單信息,然後判斷訂單信息中的發貨時間,如果達到自動收貨的要求,就執行update語句。同時如果沒有達到收貨的時間,而且與收貨時間間距比較大的時候,可以讓php腳本休眠sleep一定的時間數,這個時間數自己調節設計,獲取出來的未達到時間要求的訂單,需要重新推送到redis佇列中去,而且還是佇列的頂端。以便下次獲取。程式碼如下:$set_time = 3600*24*10;//设置几天后自动收货 while(true){ if($i%30==0){ usleep(10);//防止while 循环使CPU使用率过高 } if($redis->LLEN('auto_recevice_order')){ $data = json_decode($redis->RPOP('auto_recevice_order')); $id = (int)$data->id;//将数据转化为整形 $deliver_time = (int)$data->deliver_time;//将数据转化为整形 $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);//更新数据 $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,'系统自动收货','$ip','系统','服务器','收货',$now_time)";//写入订单日志 $res2 = $con->query($sql2);//添加日志数据 } } if($res1==false){//将没达到条件的数据重新插入队列中 $redis->RPUSH('auto_recevice_order',json_encode(array('id'=>$id,'deliver_time'=>$deliver_time))); } } $i++; }
三、思考
隨著業務的成長,在佇列中同一秒內,存在的多個需要處理的訂單,而一次只能從隊列中取出一個相關訂單資訊的時候,可以採用一個生產者多個消費者的模式,這種情況下,可以用到鎖機制,保證一則訊息只能到達一個消費者。當redis資料達到一定的量之後,也可以適當的調整生產者的執行頻率和對應的條件。 以上這篇PHP實現電商訂單自動確認收貨redis隊列就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持腳本之家。 相關推薦:電子商務網站自動確認收貨怎麼實現的
PHP取得redis裡不存在的6位元隨機數的方法
PHP實作redis訊息佇列發布微博的方法
以上是PHP實現電商訂單自動確認收貨redis隊列的方法的詳細內容。更多資訊請關注PHP中文網其他相關文章!