供应商规格自动同步到代理商产品规格上

app/AdminSupplier/Controllers/ProductController.php

@@ -5,6 +5,7 @@ namespace App\AdminSupplier\Controllers;
 use App\AdminSupplier\Repositories\Product;
 use App\Common\OrderStatus;
 use App\Common\ProductStatus;
+use App\Jobs\ProductSpecSync;
 use App\Models\AgentProduct;
 use App\Models\AgentProductItem;
 use App\Models\AgentProductSpec;
@@ -373,45 +374,13 @@ class ProductController extends AdminController
 			}
 		})->saved(function (Form $form, $result) {
 			if ($form->isEditing() && $result) {
-				$ap_ids = AgentProductItem::where('product_id', $form->getKey())->pluck('agent_product_id')->toArray();
-
-				if ($ap_ids) {
-					//修改信息同步信息到代理商产品，注：组合产品不同步
-					AgentProduct::whereIn('id', $ap_ids)->where('type', 0)->update([
-						'title' => $form->title,
-						'pictures' => explode(',', $form->pictures),
-						'know' => $form->know,
-						'content' => $form->content,
-					]);
-				}
-
 				$delete_specs = array_filter($form->spec, fn($v) => $v['_remove_'] !== null); //删除的规格
 
 				//同步删除代理商规格
 				AgentProductSpec::whereIn('product_spec_id', array_keys($delete_specs))->delete();
 
-				//最新销售价同步到代理商规格
-				$product_id = $form->getKey();
-
-				$agent_product_ids = AgentProduct::where('product_id', $product_id)->pluck('id')->toArray(); //获取当前供应商产品的所有供应商产品ID
-				$product_specs = ProductSpec::where('product_id', $product_id)->get();
-				$product_spec_old_ids = $form->model()->spec->pluck('id')->toArray(); //旧的规格ID（不包括新增的）
-
-				if ($agent_product_ids && $product_spec_old_ids) {
-					//将代理商规格价格小于供应商销售价的，设置代理商规格的价格设置为供应商的售价
-					foreach ($product_specs->whereIn('id', $product_spec_old_ids) as $v) {
-						AgentProductSpec::whereIn('agent_product_id', $agent_product_ids)
-							->where([['product_spec_id', '=', $v->id], ['price', '<', $v->price]])
-							->update(['price' => $v->price]);
-					}
-				}
-
-				/*if ($product_spec_old_ids) {
-					$product_spec_new_ids = $product_specs->whereNotIn('id', $product_spec_old_ids)->get()->toArray(); //新增的规格
-					if ($product_spec_new_ids) {
-						//暂时不处理新增的规格
-					}
-				}*/
+				//最新规格信息同步到代理商
+				ProductSpecSync::dispatch($form->getKey());
 			}
 		})->deleting(function (Form $form) {
 			//不允许删除非自己的数据

app/Jobs/ProductSpecSync.php

@@ -0,0 +1,97 @@
+<?php
+
+namespace App\Jobs;
+
+use App\Models\AgentProduct;
+use App\Models\AgentProductSpec;
+use App\Models\ProductSpec;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldBeUnique;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+
+class ProductSpecSync implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+	/**
+	 * 任务可尝试的次数
+	 * @var int
+	 */
+	public $tries = 3;
+
+	/**
+	 * 任务失败前允许的最大异常数
+	 * @var int
+	 */
+	public $maxExceptions = 3;
+
+    /**
+     * Create a new job instance.
+     *
+     * @return void
+     */
+    public function __construct(private int $product_id)
+    {
+        //
+    }
+
+    /**
+     * Execute the job.
+     *
+     * @return void
+     */
+    public function handle()
+    {
+		//获取当前供应商产品的所有规格
+		$product_specs = ProductSpec::where('product_id', $this->product_id)->get();
+
+		//获取当前供应商产品的所有代理商产品ID
+		AgentProduct::query()
+			->where('product_id', $this->product_id)
+			->chunk(5, function ($agent_products) use ($product_specs) {
+				//当前供应商产品所有规格的ID
+				$product_spec_ids = $product_specs->pluck('id')->toArray();
+
+				//删除供应商已经删除的规格
+				AgentProductSpec::query()
+					->whereIn('agent_product_id', $agent_products->pluck('id')->toArray())
+					->whereNotIn('product_spec_id', $product_spec_ids)
+					->delete();
+
+				//将代理商规格中销售价小于供应商销售价的，将代理商的销售价设置为供应商的销售价
+				foreach ($product_specs as $spec) {
+					AgentProductSpec::query()
+						->where([['product_spec_id', '=', $spec->id], ['price', '<', $spec->price]])
+						->update(['price' => $spec->price]);
+				}
+
+				//供应商新增，但代理商还没有的规格，同步给代理商
+				foreach ($agent_products as $ap) {
+					//代理商已有的规格（如果代理商删除过的规格不再同步过来，这里加上withTrashed即可）
+					$ap_spec_ids = AgentProductSpec::where('agent_product_id', $ap->id)->pluck('product_spec_id')->toArray();
+
+					//代理商没有的规格
+					$agent_no_spec_ids = array_diff($product_spec_ids, $ap_spec_ids);
+
+					AgentProductSpec::query()
+						->insert(
+							array_map(function ($v) use ($ap, $product_specs) {
+								$product_spec = $product_specs->find($v);
+								return [
+									'agent_product_id' => $ap->id,
+									'product_spec_id' => $v,
+									'name' => '',
+									'date' => null,
+									'stock' => $product_spec->stock,
+									'original_price' => $product_spec->original_price,
+									'price' => $product_spec->price,
+								];
+							}, $agent_no_spec_ids)
+						);
+				}
+			});
+    }
+}