如何使用php實(shí)現(xiàn)自動(dòng)收貨

如何使用php實(shí)現(xiàn)自動(dòng)收貨，相信很多沒(méi)有經(jīng)驗(yàn)的人對(duì)此束手無(wú)策，為此本文總結(jié)了問(wèn)題出現(xiàn)的原因和解決方法，通過(guò)這篇文章希望你能解決這個(gè)問(wèn)題。

公司主營(yíng)業(yè)務(wù)：做網(wǎng)站、成都網(wǎng)站制作、移動(dòng)網(wǎng)站開(kāi)發(fā)等業(yè)務(wù)。幫助企業(yè)客戶(hù)真正實(shí)現(xiàn)互聯(lián)網(wǎng)宣傳，提高企業(yè)的競(jìng)爭(zhēng)能力。成都創(chuàng)新互聯(lián)公司是一支青春激揚(yáng)、勤奮敬業(yè)、活力青春激揚(yáng)、勤奮敬業(yè)、活力澎湃、和諧高效的團(tuán)隊(duì)。公司秉承以“開(kāi)放、自由、嚴(yán)謹(jǐn)、自律”為核心的企業(yè)文化，感謝他們對(duì)我們的高要求，感謝他們從不同領(lǐng)域給我們帶來(lái)的挑戰(zhàn)，讓我們激情的團(tuán)隊(duì)有機(jī)會(huì)用頭腦與智慧不斷的給客戶(hù)帶來(lái)驚喜。成都創(chuàng)新互聯(lián)公司推出建平免費(fèi)做網(wǎng)站回饋大家。

php實(shí)現(xiàn)自動(dòng)收貨的方法：1、通過(guò)linux的定時(shí)任務(wù)把即將要確認(rèn)收貨的訂單信息查詢(xún)出來(lái)；2、將訂單信息存儲(chǔ)在redis上；3、執(zhí)行相應(yīng)腳本即可。

本文操作環(huán)境：linux5.9.8系統(tǒng)、PHP7.1版，DELL G3電腦

php怎么實(shí)現(xiàn)自動(dòng)收貨？

PHP實(shí)現(xiàn)電商訂單自動(dòng)確認(rèn)收貨redis隊(duì)列

一、場(chǎng)景

之前做的電商平臺(tái)，用戶(hù)在收到貨之后，大部分都不會(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)。

二、思路

最笨重的做法，通過(guò)linux后臺(tái)定時(shí)任務(wù)，查詢(xún)符合條件的訂單，然后update。最理想情況下，如果每分鐘都有需要update的訂單，這種方式也還行。奈何平臺(tái)太小，以及賣(mài)家發(fā)貨時(shí)間大部分也是密集的，不會(huì)分散在24小時(shí)的每分鐘。那么，定時(shí)任務(wù)的話，查詢(xún)過(guò)多，不適合。這里可以先把將要自動(dòng)確認(rèn)收貨的訂單信息存儲(chǔ)到其他介質(zhì)上，比如redis，memcache，rabbitmq，然后執(zhí)行的腳本從前面的介質(zhì)獲取到訂單信息來(lái)判斷，這里可以大大的減少數(shù)據(jù)庫(kù)的查詢(xún)壓力。

redis隊(duì)列的生產(chǎn)者

對(duì)此，我們選擇每天在凌晨?jī)牲c(diǎn)的時(shí)候，通過(guò)linux的定時(shí)任務(wù)把即將要確認(rèn)收貨的訂單信息查詢(xún)出來(lái)，然后存儲(chǔ)在redis上，redis上我們選擇的隊(duì)列，隊(duì)列處理的特點(diǎn)就是先進(jìn)先出，前面的數(shù)據(jù)在查詢(xún)訂單時(shí)，通過(guò)發(fā)貨時(shí)間排序，所以最先出隊(duì)列的肯定是距離規(guī)定的自動(dòng)收貨時(shí)間最近的訂單。代碼如下

$successCount=0;
$failCount=0;
$screen_time = 3600*24*9;//設(shè)置篩選天數(shù)
$data = array();
$now_time = time();
//查詢(xún)符合要求的數(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)者

隊(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ì)列的頂端。以便下次獲取。代碼如下：

$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)";//寫(xiě)入訂單日志
 $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)程。

三、思考

隨著業(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)的條件。

看完上述內(nèi)容，你們掌握如何使用php實(shí)現(xiàn)自動(dòng)收貨的方法了嗎？如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝各位的閱讀！

分享名稱(chēng)：如何使用php實(shí)現(xiàn)自動(dòng)收貨
網(wǎng)站網(wǎng)址：http://muchs.cn/article36/ihjspg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供面包屑導(dǎo)航、網(wǎng)站建設(shè)、網(wǎng)站制作、網(wǎng)站設(shè)計(jì)、外貿(mào)建站、微信公眾號(hào)

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容