alimall.hdlkeji.com/application/api/controller/TimedTask.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use app\common\model\DiscountCoupon;
use app\common\model\Order;
use think\Db;
use think\Exception;

/**
 * 定时任务
 */
class TimedTask extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = '*';

    /**
     * 订单过期/优惠券过期自动取消
     * @return void
     */
    public function cancellation_order(){
        //订单过期自动取消
        $orderlist = Order::all(function ($query){
            $query->where(['type'=>1,'status'=>1])->field('id,create_time,discount_id');
        });
        foreach ($orderlist as $k=>$value){
            if($value){
                $create_time = strtotime($value['create_time']) + 1800;
                if($create_time < time()){
                    Db::startTrans();
                    try {
                        Order::where('id',$value['id'])->update(['status'=>0]);
                        if($value['discount_id']){
                            DiscountCoupon::where('id',$value['discount_id'])->update(['status'=>1]);
                        }
                        Db::commit();
                    }catch (Exception $exception){
                        Db::rollback();
                        $this->error($exception);
                    }
                }
            }
        }
        //报价单过期自动取消
        $pjdorderlist = Order::all(function ($query){
            $query->where(['type'=>2,'status'=>1])->field('id,valid_time');
        });
        foreach ($pjdorderlist as $k=>$v){
            $valid_time = strtotime($v['valid_time']);
            if($valid_time < time()){
                Db::startTrans();
                try {
                    Order::where('id',$v['id'])->update(['status'=>0]);
                    Db::commit();
                }catch (Exception $exception){
                    Db::rollback();
                    $this->error($exception);
                }
            }
        }
        //优惠券过期
        $couponlist = DiscountCoupon::all(function ($query){
            $query->where(['status'=>1])->field('id,expiration_time');
        });
        foreach ($couponlist as $v){
            $valid_time = strtotime($v['expiration_time']);
            if($valid_time < time()){
                Db::startTrans();
                try {
                    DiscountCoupon::where('id',$v['id'])->update(['status'=>3]);
                    Db::commit();
                }catch (Exception $exception){
                    Db::rollback();
                    $this->error($exception);
                }
            }
        }
    }
}