297 lines
9.9 KiB
PHP
297 lines
9.9 KiB
PHP
<?php
|
||
|
||
declare(strict_types=1);
|
||
|
||
namespace app\admin\controller\v1;
|
||
|
||
use app\admin\model\v1\ProductModel;
|
||
use app\admin\model\v1\ProductPurchaseLinkModel;
|
||
use app\admin\model\v1\ProductPurchaseLinkPlatformModel;
|
||
use app\admin\validate\v1\ProductPurchaseLinkValidate;
|
||
use think\facade\Db;
|
||
|
||
class ProductPurchaseLink
|
||
{
|
||
/**
|
||
* 获取购买平台
|
||
*/
|
||
public function platforms()
|
||
{
|
||
$platforms = ProductPurchaseLinkPlatformModel::withoutField([
|
||
'language_id',
|
||
'desc',
|
||
'sort',
|
||
'created_at'
|
||
])
|
||
->language(request()->lang_id)
|
||
->order(['sort' => 'asc', 'id' => 'desc'])
|
||
->select();
|
||
|
||
return success('获取成功', $platforms);
|
||
}
|
||
|
||
/**
|
||
* 购买链接分页数据
|
||
*/
|
||
public function index()
|
||
{
|
||
$params = request()->param([
|
||
'name' => '',
|
||
'spu' => '',
|
||
'page/d' => 1,
|
||
'size/d' => 10
|
||
]);
|
||
|
||
$links = ProductModel::alias('pd')
|
||
->field([
|
||
'pd.id',
|
||
'pd.spu',
|
||
'pd.name',
|
||
'CASE WHEN pd.is_show = 0 THEN "已下架" WHEN pd.is_show = 1 THEN "已上架" END' => 'is_show'
|
||
])
|
||
->leftJoin('product_purchase_link pl', 'pl.product_id = pd.id')
|
||
->leftJoin('product_purchase_platform pf', 'pf.id = pl.platform_id')
|
||
->where(function ($query) use ($params) {
|
||
$query->where('pd.is_show', '=', 1);
|
||
if (!empty($params['name'])) {
|
||
$query->where('pd.name', 'like', '%' . $params['name'] . '%');
|
||
}
|
||
if (!empty($params['spu'])) {
|
||
$query->where('pd.spu', 'like', '%' . $params['spu'] . '%');
|
||
}
|
||
})
|
||
->where('pd.language_id', '=', request()->lang_id)
|
||
->group('pd.id')
|
||
->order(['pl.sort' => 'asc', 'pl.id' => 'desc', 'pd.id' => 'desc'])
|
||
->paginate([
|
||
'list_rows' => $params['size'],
|
||
'page' => $params['page'],
|
||
]);
|
||
if ($links->isEmpty()) {
|
||
return success('获取成功', []);
|
||
}
|
||
|
||
$others = ProductPurchaseLinkModel::alias('pl')
|
||
->field([
|
||
'pl.product_id',
|
||
'pl.platform_id',
|
||
'pf.platform' => 'platform_name',
|
||
'pl.id' => 'link_id',
|
||
'pl.link'
|
||
])
|
||
->join('product_purchase_platform pf', 'pf.id = pl.platform_id')
|
||
->where('pl.language_id', '=', request()->lang_id)
|
||
->where('pl.product_id', 'in', array_column($links->items(), 'id'))
|
||
->select();
|
||
if (!$others->isEmpty()) {
|
||
$others_map = [];
|
||
$others_arr = $others->toArray();
|
||
foreach ($others_arr as $other) {
|
||
$product_id = $other['product_id'];
|
||
unset($other['product_id']);
|
||
$others_map[$product_id][] = $other;
|
||
}
|
||
$links->each(function ($item) use ($others_map) {
|
||
if (!empty($others_map[$item['id']])) {
|
||
$item['rowspan'] = $others_map[$item['id']];
|
||
}
|
||
return $item;
|
||
});
|
||
}
|
||
|
||
return success('获取成功', $links);
|
||
}
|
||
|
||
/**
|
||
* 导入
|
||
*/
|
||
public function import()
|
||
{
|
||
$file = request()->file('file');
|
||
if ($file->getSize() > 20 * 1024 * 1024) {
|
||
return error('上传文件不能超过20M');
|
||
}
|
||
|
||
// 从表格获取数据
|
||
$xlsx_data = xlsx_reader($file->getRealPath(), 2, ['A' => 'spu', 'B' => 'platform', 'C' => 'link']);
|
||
|
||
$platforms_name = array_unique(array_column($xlsx_data, 'platform'));
|
||
$platforms_map = ProductPurchaseLinkPlatformModel::language(request()->lang_id)
|
||
->where('platform', 'in', $platforms_name)
|
||
->column('id', 'platform');
|
||
|
||
// 表格中spu的平台重复次数
|
||
$spu_platform_map = [];
|
||
foreach ($xlsx_data as $v) {
|
||
if (!isset($spu_platform_map[$v['spu'] . '_' . $v['platform']])) {
|
||
$spu_platform_map[$v['spu'] . '_' . $v['platform']] = 0;
|
||
}
|
||
$spu_platform_map[$v['spu'] . '_' . $v['platform']]++;
|
||
}
|
||
|
||
$data = [];
|
||
$errors = [];
|
||
$chunks = array_chunk($xlsx_data, 500, true);
|
||
// 分组验证每行，并组装数据
|
||
foreach ($chunks as $chunk) {
|
||
$spus = array_unique(array_column($chunk, 'spu'));
|
||
$products_map = ProductModel::language(request()->lang_id)
|
||
->where('spu', 'in', $spus)
|
||
->column('id', 'spu');
|
||
|
||
$items = [];
|
||
foreach ($chunk as $r => $it) {
|
||
if (empty($platforms_map[$it['platform']])) {
|
||
$errors[] = sprintf("第%d行，平台名称错误", $r);
|
||
continue;
|
||
}
|
||
if (empty($products_map[$it['spu']])) {
|
||
$errors[] = sprintf("第%d行，型号不存在", $r);
|
||
continue;
|
||
}
|
||
if ($spu_platform_map[$it['spu'] . '_' . $it['platform']] > 1) {
|
||
$errors[] = sprintf("第%d行，型号【%s】和平台【%s】有重复", $r, $it['spu'], $it['platform']);
|
||
continue;
|
||
}
|
||
$items[] = [
|
||
'language_id' => request()->lang_id,
|
||
'product_id' => $products_map[$it['spu']],
|
||
'platform_id' => $platforms_map[$it['platform']],
|
||
'link' => $it['link'],
|
||
'sort' => 0,
|
||
];
|
||
}
|
||
if (!empty($items)) {
|
||
$data[] = $items;
|
||
}
|
||
}
|
||
|
||
// 组装sql，并执行
|
||
if (!empty($data)) {
|
||
$link_model = new ProductPurchaseLinkModel();
|
||
$sql = sprintf(
|
||
'REPLACE INTO %s (id, language_id, product_id, platform_id, link, sort) VALUES ',
|
||
$link_model->getTable(),
|
||
);
|
||
foreach ($data as $items) {
|
||
$products_id = array_unique(array_column($items, 'product_id'));
|
||
$links = $link_model->field([
|
||
'id',
|
||
'product_id',
|
||
'platform_id'
|
||
])
|
||
->where('product_id', 'in', $products_id)
|
||
->select();
|
||
$links_map = [];
|
||
if (!$links->isEmpty()) {
|
||
foreach ($links as $link) {
|
||
$links_map[$link['product_id'] . '_' . $link['platform_id']] = $link['id'];
|
||
}
|
||
}
|
||
|
||
foreach ($items as $item) {
|
||
$item['id'] = null;
|
||
if (!empty($links_map[$item['product_id'] . '_' . $item['platform_id']])) {
|
||
$item['id'] = $links_map[$item['product_id'] . '_' . $item['platform_id']];
|
||
}
|
||
$sql .= sprintf(
|
||
'(%d, %d, %d, %d, "%s", %d),',
|
||
$item['id'],
|
||
$item['language_id'],
|
||
$item['product_id'],
|
||
$item['platform_id'],
|
||
$item['link'],
|
||
$item['sort']
|
||
);
|
||
}
|
||
}
|
||
Db::execute(rtrim($sql, ','));
|
||
}
|
||
|
||
if (!empty($errors)) {
|
||
return error(implode(";\n", $errors));
|
||
}
|
||
|
||
return success('导入成功');
|
||
}
|
||
|
||
/**
|
||
* 导出
|
||
*/
|
||
public function export()
|
||
{
|
||
$schema = [
|
||
'spu' => '型号',
|
||
'platform' => '平台',
|
||
'link' => '链接'
|
||
];
|
||
|
||
// 获取导出数据
|
||
$data = $this->getExportLinkData();
|
||
|
||
/// 导出
|
||
xlsx_writer($data, $schema)->save('php://output');
|
||
}
|
||
private function getExportLinkData()
|
||
{
|
||
$params = request()->param([
|
||
'name' => '',
|
||
'spu' => ''
|
||
]);
|
||
|
||
return ProductModel::alias('pd')
|
||
->field([
|
||
'pd.spu',
|
||
'pf.platform',
|
||
'pl.link'
|
||
])
|
||
->leftJoin('product_purchase_link pl', 'pl.product_id = pd.id')
|
||
->leftJoin('product_purchase_platform pf', 'pf.id = pl.platform_id')
|
||
->where(function ($query) use ($params) {
|
||
$query->where('pd.is_show', '=', 1);
|
||
if (!empty($params['name'])) {
|
||
$query->where('pd.name', 'like', '%' . $params['name'] . '%');
|
||
}
|
||
if (!empty($params['spu'])) {
|
||
$query->where('pd.spu', 'like', '%' . $params['spu'] . '%');
|
||
}
|
||
})
|
||
->where('pd.language_id', '=', request()->lang_id)
|
||
->order(['pl.sort' => 'asc', 'pl.id' => 'desc', 'pd.id' => 'desc'])
|
||
->select();
|
||
}
|
||
|
||
/**
|
||
* 更新购买链接
|
||
*/
|
||
public function update()
|
||
{
|
||
$id = request()->param('id');
|
||
$put = request()->put([
|
||
'link',
|
||
'platform_id'
|
||
]);
|
||
|
||
$data = [
|
||
'id' => $id,
|
||
'link' => $put['link'],
|
||
'language_id' => request()->lang_id,
|
||
'platform_id' => $put['platform_id']
|
||
];
|
||
$validate = new ProductPurchaseLinkValidate;
|
||
if (!$validate->scene('update')->check($data)) {
|
||
return error($validate->getError());
|
||
}
|
||
|
||
$link = ProductPurchaseLinkModel::bypk($data['id'])->find();
|
||
if (empty($link)) {
|
||
return error('请确认操作对象是否存在');
|
||
}
|
||
|
||
if (!$link->save($data)) {
|
||
return error('操作失败');
|
||
}
|
||
return success('操作成功');
|
||
}
|
||
}
|