qimall/addons/QiJuhe/console/controllers/OrderSyncController.php

<?php

namespace addons\QiJuhe\console\controllers;

use addons\QiJuhe\common\enums\QiJuheEnum;
use addons\QiJuhe\common\models\OrderModel;
use common\enums\OrderStatusEnum;
use common\enums\RabbitMqEnum;
use common\models\order\Order;
use yii\console\Controller;

class OrderSyncController extends Controller
{

    public function actionRetry()
    {
        /**
         * @var $each Order
         */
        foreach (Order::find()->where(['order_status' => OrderStatusEnum::PAY])->andWhere(['<', 'pay_time', time() - 600])->andWhere(['marketing_type' => QiJuheEnum::PLUGIN_SIGN])->select('id, mall_id')->each() as $each) {
            if (empty(OrderModel::findOne(['order_id' => $each->id]))) {
                \Yii::$app->services->rabbitMq->push(RabbitMqEnum::EXCHANGE_ORDER, RabbitMqEnum::ORDER_QUEUE, ['mall_id' => $each->mall_id, 'id' => $each->id],
                    \addons\QiJuhe\common\listeners\OrderPaidListener::class, 'async_handle');
            }
        }
    }
    
}