huahuibao/console/controllers/MqController.php

<?php

namespace console\controllers;

use bizHd\shop\classes\ShopClass;
use biz\wx\classes\WxMessageClass;
use yii\console\Controller;
use bizGhs\order\classes\OrderClass;
use Yii;

class MqController extends Controller
{

    //花店采购通知供货商 ssh 20230805
    public function actionHdCgNoticeGhs()
    {
        $noticeKey = "hdCgNoticeGhs";
        $json = Yii::$app->redis->executeCommand('RPOP', [$noticeKey]);
        if (!empty($json)) {
            $arr = json_decode($json, true);
            $orderId = $arr['orderId'] ?? 0;
            if (!empty($orderId)) {
                $order = OrderClass::getById($orderId, true);
                $shopId = $order->shopId ?? 0;
                $shop = ShopClass::getById($shopId, true);
                if (!empty($shop)) {
                    WxMessageClass::ghsHasNewOrderInform($shop, $order);
                }
            }
            print_r($arr);
        }
    }

}