Merge branch 'main' of http://git.njrzwl.cn:3000/wangmingchuan/yanzong
* 'main' of http://git.njrzwl.cn:3000/wangmingchuan/yanzong: 1 1v1.0
wanghousheng
1 year ago
commit
1d0acf4eb3
@ -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,224 @@ |
|||||||
|
<?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; |
||||||
|
} |
||||||
|
$ret = $service->updateGoods($item[6], $data, $storeId); |
||||||
|
if ($ret == false) { |
||||||
|
continue; |
||||||
|
} |
||||||
|
// 记录导入成功 |
||||||
|
$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