huahuibao/console/controllers/MqController.php

<?php

namespace console\controllers;

use bizHd\purchase\classes\PurchaseClass;
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";
        while ($count = Yii::$app->redis->executeCommand('LLEN', [$noticeKey])) {
            $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);
                    }
                }
            }
        }
    }

    //供货商开单通知花店 ssh 20231129
    public function actionGhsKdNoticeHd()
    {
        $noticeKey = "ghsKdNoticeHd";
        while ($count = Yii::$app->redis->executeCommand('LLEN', [$noticeKey])) {
            $json = Yii::$app->redis->executeCommand('RPOP', [$noticeKey]);
            if (!empty($json)) {
                $arr = json_decode($json, true);
                $id = $arr['id'] ?? 0;
                if (!empty($id)) {
                    $cg = PurchaseClass::getById($id, true);
                    $shopId = $cg->shopId ?? 0;
                    $shop = ShopClass::getById($shopId, true);
                    if (!empty($shop)) {
                        WxMessageClass::hdNewCgOrderInform($shop, $cg);
                    }
                }
            }
        }
    }

}