How to realize automatic receipt of goods in php

php method to realize automatic receipt: 1. Query the order information about to be confirmed for receipt through Linux scheduled tasks; 2. Store the order information on redis; 3. Execute the corresponding script. .

The operating environment of this article: linux5.9.8 system, PHP7.1 version, DELL G3 computer

How to achieve automatic receipt of goods with php ?

PHP implements automatic confirmation of receipt of e-commerce orders redis queue

1. Scenario

In the e-commerce platform we built before, after receiving the goods, most users would not take the initiative to click to confirm the receipt. As a result, when paying the merchants, the merchants complained all kinds of things, so According to demand, if you want to make an order, the receipt will be automatically confirmed x days after shipment. The so-called automatic confirmation of receipt of orders means executing an update statement at a specific time to change the status of the order.

2. Idea

The most cumbersome method is to query qualified orders through Linux background scheduled tasks. Then update. Ideally, this approach would work if there are orders that need to be updated every minute. However, the platform is too small, and most of the seller's delivery time is intensive and will not be scattered every minute of the 24 hours. Then, for scheduled tasks, there are too many queries and it is not suitable. Here, you can first store the order information that will automatically confirm the receipt in other media, such as redis, memcache, rabbitmq, and then execute the script to obtain the order information from the previous media for judgment. This can greatly reduce the query pressure on the database.

Redis Queue Producer

In this regard, we choose to use Linux scheduled tasks at two o'clock in the morning every day to process the upcoming tasks. The order information to confirm the receipt is queried and then stored in redis. The queue we selected on redis is characterized by first-in-first-out. When querying the order, the previous data is sorted by the delivery time, so it is the first to be dequeued. must be the order closest to the specified automatic receipt time. The code is as follows

$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);

Consumer of the redis queue

The consumer of the queue is not done through Linux scheduled tasks, but uses Linux screen php The cli mode executes the php script. The consumer only needs to continuously read the order information from the queue, and then determine the delivery time in the order information. If the requirements for automatic receipt are met, the update statement is executed. At the same time, if the delivery time has not been reached and the gap between the delivery time and the delivery time is relatively large, you can let the php script sleep for a certain number of times. This time number can be adjusted by yourself. The obtained orders that do not meet the time requirements need to be reset. Push it to the redis queue, and it is also the top of the queue. So that you can get it next time. The code is as follows:

$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++;
}

To execute the php script here, you need to use the Linux screen or supervisor or nohup daemon. The specific usage can be found on Baidu. It is best to have necessary log records in the same script.

3. Thinking

As the business grows, there are multiple orders that need to be processed in the queue within the same second. When only one relevant order information can be retrieved from the queue at a time, the model of one producer and multiple consumers can be adopted. In this case, a lock mechanism can be used to ensure that a message can only reach one consumer. When redis data reaches a certain amount, the producer's execution frequency and corresponding conditions can be appropriately adjusted.

Recommended learning: "PHP Video Tutorial"

The above is the detailed content of How to realize automatic receipt of goods in php. For more information, please follow other related articles on the PHP Chinese website!