一、场景
之前做的电商平台，用户在收到货之后，大部分都不会主动的点击确认收货，导致给商家结款的时候，商家各种投诉，于是就根据需求，要做一个订单在发货之后的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++;
}
这里执行php脚本，需要用到linux的screen或者supervisor、nohup守护进程。具体用法可自行百度.同样脚本里面最好有必须的日志记录。
三、思考
随着业务的增长，在队列中同一秒内，存在的多个需要处理的订单，而一次只能从队列中取出一个相关订单信息的时候，可以采用一个生产者多个消费者的模式，这种情况下，可以用到锁机制，保证一条消息只能到达一个消费者。当redis数据达到一定的量之后，也可以适当的调整生产者的执行频率和对应的条件。
以上这篇PHP实现电商订单自动确认收货redis队列就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持。
php,redis,队列
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！ 如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com
这一波大模型产业落地浪潮里，不少企业其实处在 “干瞪眼“的状态。
一种情况是，很多大模型产品看得见却摸不着，在台上一个个遥遥领先——今天Sora技精四座，明天英伟达的机器人又赢得满堂彩，可是到了台下一问：啥时候能用上啊？答曰：遥遥无期。
另一种情况是，企业想用上大模型，却又难免瞻前顾后——既要考虑场景融合，又得兼顾安全性，还要考虑打通现有系统，再加上各种部署成本和繁琐的采购流程……最后只能拂袖：罢了，再等等吧。
稳了！魔兽国服回归的3条重磅消息！官宣时间再确认！
昨天有一位朋友在大神群里分享，自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址，com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后，确实是网易的网址，也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情，因为以前都没有出现这样的情况，现在突然提示跳转到国服战网的网址，是不是说明了简体中文客户端已经开始进行更新了呢？