isDirty('status') && $product->status == ProductStatus::ON_SALE) { //自动上架 $agentIds = AgentProductItem::query() ->withoutGlobalScope('orderById') ->where('supplier_id', $product->supplier_id) ->whereHas('agent',function($query) { $query->where('type','!=',AgentType::CLUSTER); }) ->distinct() ->pluck('agent_id'); foreach ($agentIds as $v) { //如果没开启自动上架 滚蛋 if (empty(AgentSetting::val($v, 'auto_shelves'))) { continue; } //如果已经有这个产品 滚蛋 if(AgentProductItem::query()->where(['product_id' => $product->id,'agent_id' => $v])->exists()){ continue; } //啥有没有 自动添加商品 DB::beginTransaction(); try { $agentProduct = new AgentProduct(); $agentProduct->title = $product->title; $agentProduct->agent_id = $v; $agentProduct->product_id = $product->id; $agentProduct->product_ids = $product->id; $agentProduct->stock = $product->stock; $agentProduct->status = 1; $agentProduct->pictures = $product->pictures; $agentProduct->content = $product->content; $agentProduct->know = $product->know; //计算价格 $profit = AgentSetting::val($v, 'profit') ?? 0; $price = bcmul($product->price, bcdiv($profit + 100, 100, 6), 6); $agentProduct->price = $price; $agentProduct->original_price = $price; //自动添加分类 $autoCategory = AgentSetting::val($v, 'auto_category') ?? 0; if (!empty($autoCategory)) { $categoryName = Category::query()->where('id', $product->category_id)->value('name'); $category = Category::query()->firstOrCreate(['agent_id' => $v, 'name' => $categoryName]); $agentProduct->category_id = $category->id; } $agentProduct->save(); //维护关联表 $agentProductItem = AgentProductItem::query()->create([ 'agent_id' => $v, 'supplier_id' => $product->supplier_id, 'agent_product_id' => $agentProduct->id, 'product_id' => $product->id, ]); //规格 $productSpec = ProductSpec::query()->where('product_id',$product->id)->get(); if (!empty($productSpec)) { $agentSpecArr = []; foreach ($productSpec as $spec) { $agentSpecArr[] = [ 'agent_product_id' => $agentProduct->id, 'product_spec_id' => $spec->id, 'stock' => $spec->stock, 'original_price' => bcmul($spec->price, bcdiv($profit + 100, 100, 6), 6), 'price' => bcmul($spec->price, bcdiv($profit + 100, 100, 6), 6), ]; } $agentProduct->spec()->createMany($agentSpecArr); } DB::commit(); if(env('SMS_SWITCH','') == true) { $phone = Agent::query()->where('id',$v)->value('contact_phone'); (new SmsService)->send('auto_shelves',[$product->supplier->name,now(),SmsTraits::$systeaNameText['agent']],[$phone]); } } catch (\Exception $e) { Log::error('自动上架失败::' . $e->getTraceAsString()); DB::rollBack(); throw new \Exception('自动上架失败::' . $e->getTraceAsString()); } } } }); } }