v1.0
lqmac
8 months ago
parent
cb47195bdf
commit
aed8414ea1
@ -0,0 +1,49 @@ |
||||
<?php |
||||
// +---------------------------------------------------------------------- |
||||
// | 萤火商城系统 [ 致力于通过产品和服务，帮助商家高效化开拓市场 ] |
||||
// +---------------------------------------------------------------------- |
||||
// | Copyright (c) 2017~2023 https://www.yiovo.com All rights reserved. |
||||
// +---------------------------------------------------------------------- |
||||
// | Licensed 这不是一个自由软件，不允许对程序代码以任何形式任何目的的再发行 |
||||
// +---------------------------------------------------------------------- |
||||
// | Author: 萤火科技 <admin@yiovo.com> |
||||
// +---------------------------------------------------------------------- |
||||
declare (strict_types=1); |
||||
|
||||
namespace app\job\controller\goods; |
||||
|
||||
use app\job\service\goods\GoodsUpdateImport as GoodsUpdateImportService; |
||||
use cores\BaseJob; |
||||
use cores\traits\QueueTrait; |
||||
use cores\exception\BaseException; |
||||
use think\db\exception\DataNotFoundException; |
||||
use think\db\exception\DbException; |
||||
use think\db\exception\ModelNotFoundException; |
||||
|
||||
/** |
||||
* 队列任务：商品批量导入 |
||||
* Class Import |
||||
* @package app\job\controller |
||||
*/ |
||||
class GoodsUpdateImport extends BaseJob |
||||
{ |
||||
use QueueTrait; |
||||
|
||||
/** |
||||
* 消费队列任务：商品导入 |
||||
* @param array $data 参数 [index队列顺序；totalCount商品总数量；list商品列表；storeId商城ID] |
||||
* @return bool 返回结果 |
||||
* @throws BaseException |
||||
* @throws DataNotFoundException |
||||
* @throws DbException |
||||
* @throws ModelNotFoundException |
||||
*/ |
||||
public function handle(array $data): bool |
||||
{ |
||||
$time = date('H:i:s'); |
||||
echo "\n ---- adminImport ---- {$time} ---- \n"; |
||||
|
||||
$service = new GoodsUpdateImportService; |
||||
return $service->batch($data['list'], $data['recordId'], $data['storeId']); |
||||
} |
||||
} |
||||
@ -0,0 +1,221 @@ |
||||
<?php |
||||
// +---------------------------------------------------------------------- |
||||
// | 萤火商城系统 [ 致力于通过产品和服务，帮助商家高效化开拓市场 ] |
||||
// +---------------------------------------------------------------------- |
||||
// | Copyright (c) 2017~2023 https://www.yiovo.com All rights reserved. |
||||
// +---------------------------------------------------------------------- |
||||
// | Licensed 这不是一个自由软件，不允许对程序代码以任何形式任何目的的再发行 |
||||
// +---------------------------------------------------------------------- |
||||
// | Author: 萤火科技 <admin@yiovo.com> |
||||
// +---------------------------------------------------------------------- |
||||
declare (strict_types=1); |
||||
|
||||
namespace app\job\service\goods; |
||||
|
||||
use app\common\library\helper; |
||||
use app\common\service\BaseService; |
||||
use app\common\model\Spec as SpecModel; |
||||
use app\common\model\Goods as GoodsModel; |
||||
use app\common\model\Category as CategoryModel; |
||||
use app\common\model\GoodsSku as GoodsSkuModel; |
||||
use app\common\model\Delivery as DeliveryModel; |
||||
use app\common\model\UploadFile as UploadFileModel; |
||||
use app\common\model\GoodsImage as GoodsImageModel; |
||||
use app\common\model\goods\Import as GoodsImportModel; |
||||
use app\common\model\GoodsSpecRel as GoodsSpecRelModel; |
||||
use app\common\model\goods\Service as GoodsServiceModel; |
||||
use app\common\model\goods\ServiceRel as GoodsServiceRelModel; |
||||
use app\common\model\GoodsCategoryRel as GoodsCategoryRelModel; |
||||
use app\common\enum\goods\Status as GoodsStatusEnum; |
||||
use app\common\enum\goods\GoodsType as GoodsTypeEnum; |
||||
use app\common\enum\goods\SpecType as GoodsSpecTypeEnum; |
||||
use app\common\enum\goods\ImportStatus as GoodsImportStatusEnum; |
||||
use app\common\enum\goods\DeductStockType as DeductStockTypeEnum; |
||||
use app\common\validate\goods\AdminImport as GoodsAdminImportValidate; |
||||
use cores\exception\BaseException; |
||||
use think\facade\Log; |
||||
use app\common\model\Channel; |
||||
use app\common\model\Region; |
||||
/** |
||||
* 服务类：商品批量导入 |
||||
* Class Import |
||||
* @package app\job\service\goods |
||||
*/ |
||||
class GoodsUpdateImport extends BaseService |
||||
{ |
||||
/** |
||||
* 错误日志记录 |
||||
* @var array |
||||
*/ |
||||
private array $errorLog = []; |
||||
|
||||
/** |
||||
* 导入成功的数量 |
||||
* @var int |
||||
*/ |
||||
private int $successCount = 0; |
||||
|
||||
|
||||
/** |
||||
* 批量导入商品 |
||||
* @param array $list |
||||
* @param int $recordId |
||||
* @param int $storeId |
||||
* @return bool |
||||
* @throws BaseException |
||||
* @throws \think\db\exception\DataNotFoundException |
||||
* @throws \think\db\exception\DbException |
||||
* @throws \think\db\exception\ModelNotFoundException |
||||
*/ |
||||
public function batch(array $list, int $recordId, int $storeId): bool |
||||
{ |
||||
$service = new \app\job\service\goods\Collector(); |
||||
foreach ($list as $item) { |
||||
|
||||
$data = $this->createData($item, $storeId); |
||||
if (!isset($item[6]) || !$item[6]) { |
||||
continue; |
||||
} |
||||
$service->updateGoods($item[6], $data, $storeId); |
||||
// 记录导入成功 |
||||
$this->successCount++; |
||||
} |
||||
// 更新导入记录 |
||||
$this->updateRecord($recordId, \count($list)); |
||||
return true; |
||||
} |
||||
|
||||
/** |
||||
* 更新导入记录 |
||||
* @param int $recordId 商品导入记录ID |
||||
* @param int $currentCount 当前任务导入的商品总量 |
||||
* @return void |
||||
*/ |
||||
private function updateRecord(int $recordId, int $currentCount) |
||||
{ |
||||
// 获取导入记录 |
||||
$model = GoodsImportModel::detail($recordId); |
||||
// 计算导入失败的数量 |
||||
$failCount = $currentCount - $this->successCount; |
||||
// 更新导入记录 |
||||
$model->save([ |
||||
'success_count' => $model['success_count'] + $this->successCount, |
||||
'fail_count' => $model['fail_count'] + $failCount, |
||||
'fail_log' => array_merge($model['fail_log'], $this->errorLog), |
||||
]); |
||||
// 判断是否为最后一次队列 |
||||
if ($model['total_count'] <= ($model['success_count'] + $model['fail_count'])) { |
||||
$model->save(['end_time' => \time(), 'status' => GoodsImportStatusEnum::COMPLETED]); |
||||
} |
||||
} |
||||
|
||||
|
||||
|
||||
/** |
||||
* 生成商品数据（用于写入数据库） |
||||
* @param array $original |
||||
* @param int $storeId |
||||
* @return array |
||||
* @throws \think\db\exception\DataNotFoundException |
||||
* @throws \think\db\exception\DbException |
||||
* @throws \think\db\exception\ModelNotFoundException |
||||
*/ |
||||
public function createData(array $original, int $storeId): array |
||||
{ |
||||
|
||||
// 整理商品数据 |
||||
$data = [ |
||||
'goods_id' => $original[0] ?? 0, |
||||
'goods_name' => $original[1] ?? "", |
||||
'cmmdty_model' => $original[2] ?? "", |
||||
'link' => $original[3] ?? "", |
||||
'cost_price_min' => $original[4] ?? "", |
||||
'stock_total' => $original[5] ?? "", |
||||
'link_other' => $original[6] ?? "", |
||||
'goods_price_min' => $original[7] ?? "", |
||||
|
||||
]; |
||||
return $data; |
||||
} |
||||
|
||||
/** |
||||
* ID集字符串转换成数组 |
||||
* @param string $value |
||||
* @return array|false|string[] |
||||
*/ |
||||
private function ids2array(string $value) |
||||
{ |
||||
return !empty($value) ? \explode(',', $value) : []; |
||||
} |
||||
|
||||
/** |
||||
* 创建标准的商品SKU数据 |
||||
* @param array $originalSkuList |
||||
* @param array $specList |
||||
* @return array |
||||
*/ |
||||
private function createSkuList(array $originalSkuList, array $specList): array |
||||
{ |
||||
$data = []; |
||||
foreach ($originalSkuList as $item) { |
||||
// 设置skuKeys数据 |
||||
foreach ($item['specNames'] as $spec) { |
||||
$specGroup = helper::arraySearch($specList, 'spec_name', $spec[0]); |
||||
$specValue = helper::arraySearch($specGroup['valueList'], 'spec_value', $spec[1]); |
||||
$item['skuKeys'][] = [ |
||||
'groupKey' => $specGroup['key'], |
||||
'valueKey' => $specValue['key'] |
||||
]; |
||||
} |
||||
// 整理SKU数据 |
||||
$data[] = [ |
||||
'image_id' => 0, |
||||
'goods_price' => $item[$this->mapSku['goods_price']], |
||||
'line_price' => $item[$this->mapSku['line_price']], |
||||
'stock_num' => $item[$this->mapSku['stock_num']], |
||||
'goods_weight' => $item[$this->mapSku['goods_weight']], |
||||
'goods_sku_no' => $item[$this->mapSku['goods_sku_no']], |
||||
'skuKeys' => $item['skuKeys'], |
||||
]; |
||||
} |
||||
return $data; |
||||
} |
||||
|
||||
/** |
||||
* 创建标准的商品规格数据（树状） |
||||
* @param array $originalSkuList |
||||
* @return array |
||||
*/ |
||||
private function createSpecList(array &$originalSkuList): array |
||||
{ |
||||
// 生成规格数据 |
||||
$data = []; |
||||
foreach ($originalSkuList as &$item) { |
||||
$tempArr1 = \explode(',', $item['H']); // ['颜色:白色', '尺码:小'] |
||||
foreach ($tempArr1 as $val) { |
||||
$tempArr2 = \explode(':', $val); // ['颜色','白色'] |
||||
$data[$tempArr2[0]][$tempArr2[1]] = 1; |
||||
$item['specNames'][] = $tempArr2; |
||||
} |
||||
} |
||||
// 整理为specList格式 |
||||
$specList = []; |
||||
foreach ($data as $specName => $specValues) { |
||||
$groupKey = \count($specList); |
||||
$valueList = []; |
||||
foreach ($specValues as $specValue => $key) { |
||||
$valueList[] = [ |
||||
'key' => \count($valueList), |
||||
'groupKey' => $groupKey, |
||||
'spec_value' => $specValue, |
||||
]; |
||||
} |
||||
$specList[] = [ |
||||
'key' => $groupKey, |
||||
'spec_name' => $specName, |
||||
'valueList' => $valueList, |
||||
]; |
||||
} |
||||
return $specList; |
||||
} |
||||
} |
||||
Loading…
Reference in new issue