qimall/addons/StarChain/console/controllers/StarChainCrontabController.php

<?php

namespace addons\StarChain\console\controllers;

use addons\StarChain\common\services\MessageHandlerService;
use common\models\mall\Mall;
use Swoole\Coroutine\Client;
use Swoole\Process;
use Swoole\Server;
use Swoole\Timer;
use yii\console\Controller;
use Co;
use yii\console\ExitCode;

use function Swoole\Coroutine\run;

/**
 * 星链
 */
class StarChainCrontabController extends Controller
{
    /**
     * 处理星链消息池消息
     * ./yii star-chain/star-chain-crontab/message-add
     *
     * @return void
     */
    public function actionMessageAdd()
    {
        echo "执行星链消息池处理添加\r";

        // 获取当前系统所有可用的 mall_id
        $malls = Mall::getEnableMallList();
        $mall_ids = array_column($malls, 'id');

        foreach ($mall_ids as $id) {
            $service = new MessageHandlerService(['mall_id' => $id]);
            $service->getMessagePool();
        }
    }

    /**
     * 处理消息
     * ./yii star-chain/star-chain-crontab/message-handler
     *
     * @return void
     */
    public function actionMessageHandler()
    {
        echo "执行星链消息池处理消费\r";

        // 获取当前系统所有可用的 mall_id
        $malls = Mall::getEnableMallList();
        $mall_ids = array_column($malls, 'id');

        foreach ($mall_ids as $id) {
            $service = new MessageHandlerService(['mall_id' => $id]);
            $service->messagePoolHandler();
        }
    }

    public function actionSokabe()
    {
        $service = new MessageHandlerService(['mall_id' => 1]);
        $service->testMsgList();
    }
}