mall/jobs/CreatedCloudGoodsUpdateLog.php

<?php
/**
 * 重庆赤晓店信息科技有限公司
 * https://www.chixiaodian.com
 * Copyright (c) 2023 赤店商城 All rights reserved.
 */
namespace app\jobs;

use app\models\CloudGoodsUpdateLog;
use app\models\Goods;
use app\models\Option;
use yii\base\BaseObject;
use yii\queue\JobInterface;

/**
 * 用于平台修改商品后自动同步所有门店该商品属性
 */
class CreatedCloudGoodsUpdateLog extends BaseObject implements JobInterface
{
    public int $cloud_goods_id;
    public int $cloud_supplier_id;
    public int $price_open;

    public function execute($queue)
    {
        try {
            debug_log('CreatedCloudGoodsUpdateLog');
            $cloud_goods_id = $this->cloud_goods_id;
            $cloud_supplier_id = $this->cloud_supplier_id;
            $price_open = $this->price_open;
            $goods = Goods::find()->where(['cloud_goods_id' => $cloud_goods_id, 'is_delete' => 0])
                ->andWhere(['OR', ['is', 'is_wholesale', null], ['<=', 'is_wholesale', 0]])->asArray()->all();
            debug_log($cloud_goods_id);
            debug_log($cloud_supplier_id);
            foreach ($goods as $item) {
                //获取商城是否设置云仓产品自动更新
//                $cloud_is_update = Option::get('cloud_is_update', $item['store_id'], 'store')['value'];
                $log = CloudGoodsUpdateLog::findOne(['cloud_goods_id' => $cloud_goods_id, 'store_id' => $item['store_id']]) ?: new CloudGoodsUpdateLog();
                $log->cloud_supplier_id = $cloud_supplier_id;
                $log->cloud_goods_id = $cloud_goods_id;
                $log->store_id = $item['store_id'];
                $log->goods_id = $item['id'];
                $log->is_update = 0;
                $log->is_audit = $price_open;
                $log->status = (int)$item['status'];
                $log->created_at = time();
                $log->updated_at = '0';
                $res = $log->save();
                debug_log(json_encode($log->errors));
            }

        } catch (\Exception $e) {
            debug_log('创建云仓更新产品信息1'. json_encode($e->getFile() . $e->getMessage() . $e->getLine()));
        }
    }
}