select('user_id,birthday')->andWhere(['like', 'birthday', '%' . $md, false])->with(['user' => function($query){ $query->select('id,mall_id'); }])->asArray()->all(); if (empty($list)) { echo 'success'; return ExitCode::OK; } // 调用事件 $gift['gift_type'] = GiftEnum::GIFT_TYPE_BIRTHDAY; foreach ($list as $extra) { $gift['mall_id'] = $extra['user']['mall_id']; $gift['user_ids'] = $extra['user_id']; \Yii::$app->services->rabbitMq->push(RabbitMqEnum::EXCHANGE_TASK, RabbitMqEnum::TASK_QUEUE, $gift, UserGiftListener::class, 'async_handle'); } echo 'success'; return ExitCode::OK; } catch (\Exception $e) { echo $e->getMessage(); $this->stderr('Error: ' . ExitCode::getReason(ExitCode::UNSPECIFIED_ERROR)); return ExitCode::UNSPECIFIED_ERROR; } } }