mkm/shop-php
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更新导入问题

Browse Source
This commit is contained in:
mkm 2023-12-01 11:28:49 +08:00
parent 9d23c78b7a
commit 4b14c557c4
2 changed files with 34 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
app/controller/merchant/store/StoreImport.php
View File

@ -16,6 +16,7 @@ use app\common\repositories\store\order\StoreImportDeliveryRepository;
use app\common\repositories\store\order\StoreOrderRepository;
use crmeb\jobs\ImportSpreadsheetExcelJob;
use crmeb\jobs\ImportPicJob;
use crmeb\jobs\ImportProductJob;
use crmeb\services\ExcelService;
use crmeb\services\SpreadsheetExcelService;
use crmeb\services\UploadService;
@ -232,7 +233,9 @@ class StoreImport extends BaseController
'where' => ['store_name' => 'A'],
]
];
app()->make(StoreOrderRepository::class)->setProduct($data['data'],$data['mer_id'],$type_id);
// app()->make(StoreOrderRepository::class)->setProduct($data['data'],$data['mer_id'],$type_id);
Queue::push(ImportProductJob::class,['mer_id'=>$data['mer_id'],'data'=>$data['data'],'type_id'=>$type_id]);
}else{
$check =[
'A1'=>'商品名称（必填）',
@ -258,7 +261,8 @@ class StoreImport extends BaseController
'where' => ['store_name' => 'A'],
]
];
app()->make(StoreOrderRepository::class)->setProduct($data['data'],$data['mer_id'],$type_id);
Queue::push(ImportProductJob::class,['mer_id'=>$data['mer_id'],'data'=>$data['data'],'type_id'=>$type_id]);
// app()->make(StoreOrderRepository::class)->setProduct($data['data'],$data['mer_id'],$type_id);
}
}
public function transcoding($fileName)

28
crmeb/jobs/ImportProductJob.php Normal file
View File

@ -0,0 +1,28 @@
<?php
namespace crmeb\jobs;
use crmeb\interfaces\JobInterface;
use think\facade\Log;
class ImportProductJob implements JobInterface
{
public function fire($job, $data)
{
Log::error('开始导入商品:' . $job->attempts());
if ($job->attempts() > 1) {
$job->delete();
$this->failed($data);
}
app()->make(StoreOrderRepository::class)->setProduct($data['data'],$data['mer_id'],$data['type_id']);
$job->delete();
}
public function failed($data)
{
Log::error('导入商品失败:' . json_encode($data));
// TODO: Implement failed() method.
}
}