huahuibao/console/controllers/BookController.php

<?php

namespace console\controllers;

use bizGhs\cg\classes\CgOrderClass;
use bizGhs\order\classes\PurchaseOrderClass;
use bizGhs\shop\classes\ShopAdminClass;
use common\components\noticeUtil;
use yii\console\Controller;
use Yii;

class BookController extends Controller
{

    //全部待入库采购单重新分配货位 ssh 20240711
    public function actionAssignSeat()
    {
        ini_set('memory_limit', '2045M');
        set_time_limit(0);
        $cacheKey = 'assign_seat_main_book_sn_list';
        $num = Yii::$app->redis->executeCommand('SCARD', [$cacheKey]);
        noticeUtil::push("每三分钟执行一次吗", '15280215347');
        if ($num <= 0) {
            echo "没有数量\n";
            return false;
        }
        if ($num > 15) {
            noticeUtil::push("assign seat all 已经超过15家了，请及时解决", '15280215347');
        }
        $list = Yii::$app->redis->executeCommand('SMEMBERS', [$cacheKey]);
        if (empty($list)) {
            echo "没有数量哦\n";
            return false;
        }
        Yii::$app->redis->executeCommand('DEL', [$cacheKey]);
        Yii::$app->params['errorReport'] = 1;
        foreach ($list as $key => $bookSn) {
            $cgList = CgOrderClass::getAllByCondition(['bookSn' => $bookSn, 'status' => 3], null, '*', null, true);
            if (empty($cgList)) {
                foreach ($cgList as $cg) {
                    $connection = Yii::$app->db;
                    $transaction = $connection->beginTransaction();
                    try {
                        $respond = PurchaseOrderClass::assign($cg);
                        $transaction->commit();
                        $hasChange = $respond['hasChange'] ?? 0;
                        if ($hasChange == 1) {
                            //通知采购单页要刷新货位
                            $cacheKey = 'ghs_cg_order_staff_refresh_seat_' . $bookSn;
                            $mainId = $order->mainId ?? 0;
                            $staffList = ShopAdminClass::getAllByCondition(['mainId' => $mainId], null, '*', null, true);
                            if (!empty($staffList)) {
                                foreach ($staffList as $staff) {
                                    $staffId = $staff->id ?? 0;
                                    $params = $cgId . '-' . $staffId;
                                    Yii::$app->redis->executeCommand('SADD', [$cacheKey, $params]);
                                }
                            }
                            $cacheKey = 'ghs_cg_order_guest_refresh_seat_' . $bookSn;
                            Yii::$app->redis->executeCommand('SADD', [$cacheKey, $cgId]);
                        }
                    } catch (\Exception $exception) {
                        $transaction->rollBack();
                        noticeUtil::push("部分门店待入库采购单，重新分配货位出错，原因：" . $exception->getMessage(), '15280215347');
                    }
                }
            }
        }
    }

}