huahuibao/console/controllers/BookController.php

<?php

namespace console\controllers;

use bizGhs\cg\classes\CgOrderClass;
use bizGhs\order\classes\PurchaseOrderClass;
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(['book' => $bookSn, 'status' => 3], null, '*', null, true);
            if (empty($cgList)) {
                foreach ($cgList as $cg) {
                    $connection = Yii::$app->db;
                    $transaction = $connection->beginTransaction();
                    try {
                        PurchaseOrderClass::assign($cg);
                        $transaction->commit();
                    } catch (\Exception $exception) {
                        $transaction->rollBack();
                        noticeUtil::push("部分门店待入库采购单，重新分配货位出错，原因：" . $exception->getMessage(), '15280215347');
                    }
                }
            }
        }
    }

}