diff --git a/app/controller/api/Demo.php b/app/controller/api/Demo.php
index a2b190f0..dbe9eba9 100644
--- a/app/controller/api/Demo.php
+++ b/app/controller/api/Demo.php
@@ -31,7 +31,13 @@ class Demo extends BaseController
 {
     public function index()
     {
-        Queue::push(ProductCopyJob::class, ['product_id' => 0, 'mer_id' =>0,'street_code'=>0,'type_id'=>0,'category_id'=>0]);//短信通知
+        $arr=Db::name('store_product')->where('mer_id',208)->where('status',1)->where('is_show',0)->find();
+        $mer_id=239;//导入到的商户
+        $street_code=510521116;//导入到的商户
+        $type_id=17;//导入到的商户分类
+        foreach($arr as $k=>$v){
+            Queue::push(ProductCopyJob::class, ['product_id' => $v['product_id'], 'mer_id' =>$mer_id,'street_code'=>$street_code,'type_id'=>$type_id,'category_id'=>$v['category_id']]);//短信通知
+        }
 
         halt(1);
         $mer_id = 104;
diff --git a/crmeb/jobs/ProductCopyJob.php b/crmeb/jobs/ProductCopyJob.php
index 932deac3..afca7931 100644
--- a/crmeb/jobs/ProductCopyJob.php
+++ b/crmeb/jobs/ProductCopyJob.php
@@ -24,7 +24,7 @@ class ProductCopyJob implements JobInterface
     public function fire($job, $data)
     {
         $make = app()->make(StoreProduct::class);
-        $make->copy($data['id'],$data['copy_id'],$data['street_code'],$data['type_id'],$data['category_id']);
+        $make->copy($data['product_id'],$data['mer_id'],$data['street_code'],$data['type_id'],$data['category_id']);
         $job->delete();
     }