So realisieren Sie den automatischen Wareneingang in PHP

So implementieren Sie den automatischen Wareneingang in PHP: 1. Fragen Sie die zur Lieferung zu bestätigenden Bestellinformationen über geplante Linux-Aufgaben ab. 2. Speichern Sie die Bestellinformationen auf Redis. 3. Führen Sie das entsprechende Skript aus.

Die Betriebsumgebung dieses Artikels: Linux5.9.8-System, PHP7.1-Version, DELL G3-Computer

Wie erreiche ich mit PHP einen automatischen Wareneingang?

PHP realisiert die automatische Empfangsbestätigung der Redis-Warteschlange für E-Commerce-Bestellungen

1. Szenario

In der E-Commerce-Plattform, die wir zuvor erstellt haben, werden die meisten Benutzer nach Erhalt nicht die Initiative ergreifen Das Anklicken der Wareneingangsbestätigung löste beim Händler beim Bezahlen diverse Beschwerden aus, so dass auf Nachfrage eine automatische Empfangsbestätigung x Tage nach Lieferung veranlasst wurde. Bei der sogenannten automatischen Empfangsbestätigung von Bestellungen handelt es sich um die Ausführung einer Update-Anweisung zu einem bestimmten Zeitpunkt, um den Status der Bestellung zu ändern.

2. Idee

Die umständlichste Methode besteht darin, qualifizierte Bestellungen über geplante Linux-Hintergrundaufgaben abzufragen und dann zu aktualisieren. Idealerweise funktioniert dieser Ansatz, wenn Bestellungen jede Minute aktualisiert werden müssen. Allerdings ist die Plattform zu klein und die Lieferzeit des Verkäufers ist größtenteils intensiv und wird nicht auf jede Minute der 24 Stunden verteilt. Dann gibt es für geplante Aufgaben zu viele Abfragen und es ist nicht geeignet. Hier können Sie zunächst die Bestellinformationen, die den Empfang automatisch bestätigen, in anderen Medien wie Redis, Memcache, Rabbitmq speichern und dann das Skript ausführen, um die Bestellinformationen zur Beurteilung von den vorherigen Medien abzurufen. Dies kann die Abfrage erheblich reduzieren Druck auf die Datenbank.

Redis Queue Producer

In diesem Zusammenhang fragen wir jeden Tag um zwei Uhr morgens die zu bestätigenden Bestellinformationen über die geplante Linux-Aufgabe ab und speichern sie dann auf Redis , redis In der von uns ausgewählten Warteschlange lautet das Merkmal der Warteschlangenverarbeitung „First In, First Out“. Bei der Abfrage von Bestellungen werden die vorherigen Daten nach Lieferzeit sortiert, sodass die erste Bestellung aus der Warteschlange die Bestellung sein muss, die der angegebenen automatischen Bestellung am nächsten kommt Empfangszeit. Der Code lautet wie folgt:

$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(&#39;auto_recevice_order&#39;)){
$txt = &#39;执行时间：&#39;.date(&#39;Y-m-d H:i:s&#39;).&#39;,信息:&#39;.$redis->RPOP(&#39;auto_recevice_order&#39;);
file_put_contents(&#39;./autoToken/fail_log.txt&#39;,$txt."\r\n".PHP_EOL,FILE_APPEND);
$failCount++;
}
//重新填充数据进队列
while ($row = $res->fetch_assoc()) {
 $successCount++;
 $redis->LPUSH(&#39;auto_recevice_order&#39;,json_encode($row1));
}
 $con->close();
 $success=date(&#39;Y-m-d H:i:s&#39;).&#39;:[推送成功]:本次成功推送数据：&#39;.$successCount.&#39;条;记录上次处理失败数据:&#39;.$failCount."条\r\n";
 file_put_contents(&#39;./success_log.txt&#39;,$success."\r\n".PHP_EOL,FILE_APPEND);

Redis-Warteschlangenverbraucher

Der Verbraucher der Warteschlange wird nicht über den Linux-Bildschirm- und PHP-CLI-Modus ausgeführt, um das PHP-Skript auszuführen Lesen Sie die Bestellinformationen kontinuierlich aus und ermitteln Sie dann die Lieferzeit in den Bestellinformationen. Wenn die Anforderungen für den automatischen Empfang erfüllt sind, führen Sie die Aktualisierungsanweisung aus. Wenn die Lieferzeit noch nicht erreicht ist und die Lücke zwischen der Lieferzeit und der Lieferzeit relativ groß ist, können Sie das PHP-Skript gleichzeitig für eine bestimmte Anzahl von Malen in den Ruhezustand versetzen. Diese Zeitspanne kann angepasst werden Die erhaltenen Aufträge, die die Zeitanforderungen nicht erfüllen, müssen in die Redis-Warteschlange verschoben werden, und sie befinden sich ebenfalls an der Spitze der Warteschlange. Damit Sie es beim nächsten Mal bekommen. Der Code lautet wie folgt:

$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`=&#39;1&#39;,`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,&#39;系统自动收货&#39;,&#39;$ip&#39;,&#39;系统&#39;,&#39;服务器&#39;,&#39;收货&#39;,$now_time)";//写入订单日志
 $res2 = $con->query($sql2);//添加日志数据
 }
 }
 if($res1==false){//将没达到条件的数据重新插入队列中
  $redis->RPUSH(&#39;auto_recevice_order&#39;,json_encode(array(&#39;id&#39;=>$id,&#39;deliver_time&#39;=>$deliver_time)));
 }
}
 $i++;
}

Um das PHP-Skript hier auszuführen, müssen Sie den Linux-Bildschirm oder den Supervisor oder den Nohup-Daemon verwenden. Die spezifische Verwendung finden Sie auf Baidu. Es ist am besten, die erforderlichen Protokolldatensätze im selben Skript zu haben.

3. Denken

Wenn das Unternehmen wächst, müssen mehrere Bestellungen gleichzeitig in der Warteschlange bearbeitet werden, und es kann jeweils nur eine relevante Bestellinformation aus der Warteschlange entnommen werden Sie können ein Modell mit einem Produzenten und mehreren Konsumenten verwenden. In diesem Fall kann ein Sperrmechanismus verwendet werden, um sicherzustellen, dass eine Nachricht nur einen Konsumenten erreichen kann. Wenn die Redis-Daten eine bestimmte Menge erreichen, können die Ausführungshäufigkeit des Herstellers und die entsprechenden Bedingungen entsprechend angepasst werden.

Empfohlenes Lernen: „PHP-Video-Tutorial“

Das obige ist der detaillierte Inhalt vonSo realisieren Sie den automatischen Wareneingang in PHP. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!