428 lines
19 KiB
PHP
Executable File
428 lines
19 KiB
PHP
Executable File
<?php
|
|
/**
|
|
* Niushop商城系统 - 团队十年电商经验汇集巨献!
|
|
* =========================================================
|
|
* Copy right 2019-2029 杭州牛之云科技有限公司, 保留所有权利。
|
|
* ----------------------------------------------
|
|
* 官方网址: https://www.niushop.com
|
|
* =========================================================
|
|
*/
|
|
|
|
namespace addon\shopcomponent\model;
|
|
|
|
use app\model\BaseModel;
|
|
|
|
class Goods extends BaseModel
|
|
{
|
|
/**
|
|
* 商品状态
|
|
* @var string[]
|
|
*/
|
|
private $status = [
|
|
0 => '未上架',
|
|
5 => '上架中',
|
|
11 => '已下架',
|
|
13 => '违规下架'
|
|
];
|
|
|
|
/**
|
|
* 审核状态
|
|
* @var string[]
|
|
*/
|
|
private $editStatus = [
|
|
0 => '审核中',
|
|
1 => '编辑中',
|
|
2 => '审核中',
|
|
3 => '审核失败',
|
|
4 => '审核成功',
|
|
];
|
|
|
|
/**
|
|
* 获取商品列表
|
|
* @param array $condition
|
|
* @param bool $field
|
|
* @param string $order
|
|
* @param int $page
|
|
* @param int $list_rows
|
|
* @param string $alias
|
|
* @param array $join
|
|
* @return array
|
|
*/
|
|
public function getGoodsPageList($condition = [], $field = true, $order = '', $page = 1, $list_rows = PAGE_LIST_ROWS, $alias = 'a', $join = [])
|
|
{
|
|
$field = 'sg.*,
|
|
g.goods_name,g.goods_image,g.price,g.goods_stock,g.recommend_way';
|
|
$alias = 'sg';
|
|
$join = [
|
|
[ 'goods g', 'g.goods_id = sg.out_product_id', 'inner' ],
|
|
];
|
|
$data = model('shopcompoent_goods')->pageList($condition, $field, $order, $page, $list_rows, $alias, $join);
|
|
|
|
if (!empty($data[ 'list' ])) {
|
|
foreach ($data[ 'list' ] as $k => $item) {
|
|
$data[ 'list' ][ $k ][ 'goods_stock' ] = numberFormat($data[ 'list' ][ $k ][ 'goods_stock' ]);
|
|
$data[ 'list' ][ $k ][ 'status_name' ] = $this->status[ $item[ 'status' ] ] ?? '';
|
|
$data[ 'list' ][ $k ][ 'edit_status_name' ] = $this->editStatus[ $item[ 'edit_status' ] ] ?? '';
|
|
$arr_img = explode(',', $item[ 'goods_image' ]);
|
|
$data[ 'list' ][ $k ][ 'cover_img' ] = $arr_img[ 0 ] ?? '';
|
|
$data[ 'list' ][ $k ][ 'create_time' ] = $item[ 'create_time' ] > 0 ? time_to_date($item[ 'create_time' ]) : '--';
|
|
$data[ 'list' ][ $k ][ 'audit_time' ] = $item[ 'audit_time' ] > 0 ? time_to_date($item[ 'audit_time' ]) : '--';
|
|
$data[ 'list' ][ $k ][ 'reject_reason' ] = str_replace('https://developers.weixin.qq.com/miniprogram/dev/framework/ministore/minishopopencomponent/API/spu/add_spu.html', '', $item[ 'reject_reason' ]);
|
|
}
|
|
}
|
|
return $this->success($data);
|
|
}
|
|
|
|
/**
|
|
* 同步商品库商品
|
|
*/
|
|
public function syncGoods($start, $limit, $site_id, $status = 5)
|
|
{
|
|
$weapp = new Weapp($site_id);
|
|
$sync_res = $weapp->getSpuPage([ 'page' => $start, 'page_size' => $limit, 'status' => $status ]);
|
|
|
|
if ($sync_res[ 'code' ] < 0) return $sync_res;
|
|
|
|
if (!empty($sync_res[ 'data' ][ 'list' ])) {
|
|
foreach ($sync_res[ 'data' ][ 'list' ] as $goods_item) {
|
|
$count = model('shopcompoent_goods')->getCount([ [ 'out_product_id', '=', $goods_item[ 'out_product_id' ] ], [ 'site_id', '=', $site_id ] ]);
|
|
if ($count) {
|
|
model('shopcompoent_goods')->update([
|
|
'status' => $goods_item[ 'status' ],
|
|
'edit_status' => $goods_item[ 'edit_status' ],
|
|
'audit_time' => empty($goods_item[ 'audit_info' ]) ? 0 : strtotime($goods_item[ 'audit_info' ][ 'audit_time' ]),
|
|
'reject_reason' => $goods_item[ 'edit_status' ] == 3 ? $goods_item[ 'audit_info' ][ 'reject_reason' ] : ''
|
|
], [
|
|
[ 'out_product_id', '=', $goods_item[ 'out_product_id' ] ]
|
|
]);
|
|
} else {
|
|
$category = ( new Category() )->getCategoryInfo($goods_item[ 'third_cat_id' ], $site_id);
|
|
model('shopcompoent_goods')->add([
|
|
'site_id' => $site_id,
|
|
'product_id' => $goods_item[ 'product_id' ],
|
|
'out_product_id' => $goods_item[ 'out_product_id' ],
|
|
'third_cat_id' => $goods_item[ 'third_cat_id' ],
|
|
'brand_id' => $goods_item[ 'brand_id' ],
|
|
'info_version' => $goods_item[ 'info_version' ],
|
|
'status' => $goods_item[ 'status' ],
|
|
'edit_status' => $goods_item[ 'edit_status' ],
|
|
'create_time' => strtotime($goods_item[ 'create_time' ]),
|
|
'update_time' => strtotime($goods_item[ 'update_time' ]),
|
|
'audit_time' => empty($goods_item[ 'audit_info' ]) ? 0 : strtotime($goods_item[ 'audit_info' ][ 'audit_time' ]),
|
|
'reject_reason' => $goods_item[ 'edit_status' ] == 3 ? $goods_item[ 'audit_info' ][ 'reject_reason' ] : '',
|
|
'cat_name' => "{$category['first_cat_name']}>{$category['second_cat_name']}>{$category['third_cat_name']}"
|
|
]);
|
|
}
|
|
}
|
|
$total_page = ceil($sync_res[ 'data' ][ 'total' ] / $limit);
|
|
return $this->success([ 'page' => $start, 'total_page' => $total_page ]);
|
|
} else {
|
|
return $this->success([ 'page' => $start, 'total_page' => 1 ]);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 添加商品
|
|
* @param $param
|
|
*/
|
|
public function addGoods($param)
|
|
{
|
|
$goods_list = model('goods')->getList([ [ 'goods_id', 'in', explode(',', $param[ 'goods_ids' ]) ], [ 'site_id', '=', $param[ 'site_id' ] ] ], 'goods_id,goods_name,goods_image,sku_id,goods_content');
|
|
if (!empty($goods_list)) {
|
|
$category = ( new Category() )->getCategoryInfo($param[ 'third_cat_id' ], $param[ 'site_id' ]);
|
|
if (empty($category) || $category[ 'status' ] == 0) return $this->error('', '该类目不存在或未审核通过');
|
|
|
|
$weapp = new Weapp($param[ 'site_id' ]);
|
|
foreach ($goods_list as $goods_item) {
|
|
// 需加到库中的商品数据
|
|
$goods_data = [
|
|
'out_product_id' => $goods_item[ 'goods_id' ],
|
|
'third_cat_id' => $param[ 'third_cat_id' ],
|
|
'brand_id' => $param[ 'brand_id' ] ?? 2100000000,
|
|
'info_version' => '0.0.1',
|
|
];
|
|
|
|
//处理图片
|
|
$goods_image_arr = $this->handleImg($goods_item[ 'goods_image' ]);
|
|
$goods_image = [];
|
|
foreach ($goods_image_arr as $img_k => $img_y) {
|
|
$res = $weapp->getImg($img_y);
|
|
if ($res[ 'code' ] == 0) {
|
|
$goods_image[] = $res[ 'data' ][ 'img_info' ][ 'temp_img_url' ];
|
|
}
|
|
}
|
|
|
|
// 同步商品所需数据
|
|
$spu_data = [
|
|
'title' => $goods_item[ 'goods_name' ],
|
|
'path' => 'pages/goods/detail?sku_id=' . $goods_item[ 'sku_id' ],
|
|
'head_img' => $goods_image,
|
|
'qualification_pics' => $category[ 'product_qualification_type' ] == 0 ? '' : explode(',', $category[ 'qualification_pics' ]),
|
|
'desc_info' => [
|
|
'desc' => $goods_item[ 'goods_content' ]
|
|
],
|
|
'skus' => []
|
|
];
|
|
|
|
$sku_list = model('goods_sku')->getList([ [ 'goods_id', '=', $goods_item[ 'goods_id' ] ] ], 'sku_id,sku_no,sku_image,discount_price,market_price,stock,sku_spec_format');
|
|
foreach ($sku_list as $sku_item) {
|
|
//图片处理
|
|
$sku_res = $weapp->getImg($this->handleImg($sku_item[ 'sku_image' ])[ 0 ]);
|
|
$sku_image = '';
|
|
if ($sku_res[ 'code' ] == 0) {
|
|
$sku_image = $sku_res[ 'data' ][ 'img_info' ][ 'temp_img_url' ];
|
|
}
|
|
|
|
$sku_data = [
|
|
'out_product_id' => $goods_item[ 'goods_id' ],
|
|
'out_sku_id' => $sku_item[ 'sku_id' ],
|
|
'thumb_img' => $sku_image,
|
|
'sale_price' => $sku_item[ 'discount_price' ] * 100,
|
|
'market_price' => $sku_item[ 'market_price' ] * 100,
|
|
'stock_num' => numberFormat($sku_item[ 'stock' ]),
|
|
'sku_code' => $sku_item[ 'sku_no' ],
|
|
'sku_attrs' => []
|
|
];
|
|
if (!empty($sku_item[ 'sku_spec_format' ])) {
|
|
foreach (json_decode($sku_item[ 'sku_spec_format' ], true) as $spec_item) {
|
|
$sku_data['sku_attrs'][] = [
|
|
'attr_key' => $spec_item['spec_name'],
|
|
'attr_value' => $spec_item['spec_value_name']
|
|
];
|
|
}
|
|
} else {
|
|
$sku_data[ 'sku_attrs' ] = [
|
|
[
|
|
'attr_key' => '',
|
|
'attr_value' => ''
|
|
]
|
|
];
|
|
}
|
|
$spu_data['skus'][] = $sku_data;
|
|
}
|
|
|
|
// 添加商品到小程序
|
|
$add_res = $weapp->addSpu(array_merge($goods_data, $spu_data));
|
|
if ($add_res[ 'code' ] != 0) return $add_res;
|
|
|
|
$goods_data[ 'product_id' ] = $add_res[ 'data' ][ 'product_id' ];
|
|
$goods_data[ 'create_time' ] = !empty($add_res[ 'data' ][ 'create_time' ]) ? strtotime($add_res[ 'data' ][ 'create_time' ]) : time();
|
|
$goods_data[ 'site_id' ] = $param[ 'site_id' ];
|
|
$goods_data[ 'cat_name' ] = "{$category['first_cat_name']}>{$category['second_cat_name']}>{$category['third_cat_name']}";
|
|
|
|
model('shopcompoent_goods')->add($goods_data);
|
|
}
|
|
return $this->success();
|
|
} else {
|
|
return $this->error('', '未获取到要添加的商品');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 更新商品
|
|
* @param $param
|
|
* @return array
|
|
*/
|
|
public function updateGoods($param)
|
|
{
|
|
$shopcompoent_goods_info = model('shopcompoent_goods')->getInfo([ [ 'out_product_id', '=', $param[ 'goods_id' ] ], [ 'site_id', '=', $param[ 'site_id' ] ] ], '*');
|
|
$goods_info = model('goods')->getInfo([ [ 'goods_id', '=', $param[ 'goods_id' ] ], [ 'site_id', '=', $param[ 'site_id' ] ] ], 'goods_id,goods_name,goods_image,sku_id,goods_content');
|
|
if (!empty($shopcompoent_goods_info) && !empty($goods_info)) {
|
|
|
|
$third_cat_id = $param[ 'third_cat_id' ] ?? $shopcompoent_goods_info[ 'third_cat_id' ];
|
|
$category = ( new Category() )->getCategoryInfo($third_cat_id, $param[ 'site_id' ]);
|
|
if (empty($category) || $category[ 'status' ] == 0) return $this->error('', '该类目不存在或未审核通过');
|
|
|
|
$weapp = new Weapp($param[ 'site_id' ]);
|
|
|
|
//处理图片
|
|
$goods_image_arr = $this->handleImg($goods_info[ 'goods_image' ]);
|
|
$goods_image = [];
|
|
foreach ($goods_image_arr as $img_k => $img_y) {
|
|
$res = $weapp->getImg($img_y);
|
|
if ($res[ 'code' ] == 0) {
|
|
$goods_image[] = $res[ 'data' ][ 'img_info' ][ 'temp_img_url' ];
|
|
}
|
|
}
|
|
|
|
// 同步商品所需数据
|
|
$spu_data = [
|
|
'out_product_id' => $goods_info[ 'goods_id' ],
|
|
'third_cat_id' => $third_cat_id,
|
|
'brand_id' => $param[ 'brand_id' ] ?? $shopcompoent_goods_info[ 'brand_id' ],
|
|
'info_version' => '0.0.1',
|
|
'title' => $goods_info[ 'goods_name' ],
|
|
'path' => 'pages/goods/detail?sku_id=' . $goods_info[ 'sku_id' ],
|
|
'head_img' => $goods_image,
|
|
'qualification_pics' => $category[ 'product_qualification_type' ] == 0 ? '' : explode(',', $category[ 'qualification_pics' ]),
|
|
'desc_info' => [
|
|
'desc' => $goods_info[ 'goods_content' ]
|
|
],
|
|
'skus' => []
|
|
];
|
|
|
|
$sku_list = model('goods_sku')->getList([ [ 'goods_id', '=', $goods_info[ 'goods_id' ] ] ], 'sku_id,sku_no,sku_image,discount_price,market_price,stock,sku_spec_format');
|
|
foreach ($sku_list as $sku_item) {
|
|
//图片处理
|
|
$sku_res = $weapp->getImg($this->handleImg($sku_item[ 'sku_image' ])[ 0 ]);
|
|
$sku_image = '';
|
|
if ($sku_res[ 'code' ] == 0) {
|
|
$sku_image = $sku_res[ 'data' ][ 'img_info' ][ 'temp_img_url' ];
|
|
}
|
|
|
|
$sku_data = [
|
|
'out_product_id' => $goods_info[ 'goods_id' ],
|
|
'out_sku_id' => $sku_item[ 'sku_id' ],
|
|
'thumb_img' => $sku_image,
|
|
'sale_price' => $sku_item[ 'discount_price' ] * 100,
|
|
'market_price' => $sku_item[ 'market_price' ] * 100,
|
|
'stock_num' => numberFormat($sku_item[ 'stock' ]),
|
|
'sku_code' => $sku_item[ 'sku_no' ],
|
|
'sku_attrs' => []
|
|
];
|
|
if (!empty($sku_item[ 'sku_spec_format' ])) {
|
|
foreach (json_decode($sku_item[ 'sku_spec_format' ], true) as $spec_item) {
|
|
$sku_data['sku_attrs'][] = [
|
|
'attr_key' => $spec_item['spec_name'],
|
|
'attr_value' => $spec_item['spec_value_name']
|
|
];
|
|
}
|
|
} else {
|
|
$sku_data[ 'sku_attrs' ] = [
|
|
[
|
|
'attr_key' => '',
|
|
'attr_value' => ''
|
|
]
|
|
];
|
|
}
|
|
$spu_data['skus'][] = $sku_data;
|
|
}
|
|
|
|
// 更新商品
|
|
$update_res = $weapp->updateSpu($spu_data);
|
|
if ($update_res[ 'code' ] != 0) return $update_res;
|
|
|
|
$goods_data = [
|
|
'edit_status' => 0,
|
|
'update_time' => time(),
|
|
'third_cat_id' => $third_cat_id,
|
|
'cat_name' => "{$category['first_cat_name']}>{$category['second_cat_name']}>{$category['third_cat_name']}"
|
|
];
|
|
|
|
model('shopcompoent_goods')->update($goods_data, [ [ 'out_product_id', '=', $param[ 'goods_id' ] ], [ 'site_id', '=', $param[ 'site_id' ] ] ]);
|
|
|
|
return $this->success();
|
|
} else {
|
|
return $this->error('', '未获取到要更新的商品');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 处理图片
|
|
* @param $images
|
|
* @return false|string[]
|
|
*/
|
|
private function handleImg($images)
|
|
{
|
|
$img_arr = explode(',', $images);
|
|
foreach ($img_arr as $k => $v) {
|
|
$img_arr[ $k ] = img($v);
|
|
}
|
|
return $img_arr;
|
|
}
|
|
|
|
/**
|
|
* 删除商品
|
|
* @param $id
|
|
* @param $site_id
|
|
*/
|
|
public function deleteGoods($goods_ids, $site_id)
|
|
{
|
|
if (!empty($goods_ids)) {
|
|
$array_goodsIds = explode(',', $goods_ids);
|
|
}
|
|
foreach ($array_goodsIds as $k => $goods_id) {
|
|
$res[ $k ] = ( new Weapp($site_id) )->delSpu([ 'out_product_id' => $goods_id ]);
|
|
if ($res[ $k ][ 'code' ] != 0) return $res[ $k ];
|
|
}
|
|
model('shopcompoent_goods')->delete([ [ 'site_id', '=', $site_id ], [ 'out_product_id', 'in', $goods_ids ] ]);
|
|
return $this->success();
|
|
}
|
|
|
|
/**
|
|
* 商品上架
|
|
* @param $goods_ids
|
|
* @param $site_id
|
|
* @return array|mixed
|
|
* @throws \GuzzleHttp\Exception\GuzzleException
|
|
*/
|
|
public function goodsListing($goods_ids, $site_id)
|
|
{
|
|
if (!empty($goods_ids)) {
|
|
$array_goodsIds = explode(',', $goods_ids);
|
|
}
|
|
foreach ($array_goodsIds as $k => $goods_id) {
|
|
$res[ $k ] = ( new Weapp($site_id) )->listing([ 'out_product_id' => $goods_id ]);
|
|
if ($res[ $k ][ 'code' ] != 0) return $res[ $k ];
|
|
}
|
|
model('shopcompoent_goods')->update([ 'status' => 5 ], [ [ 'site_id', '=', $site_id ], [ 'out_product_id', 'in', $goods_ids ] ]);
|
|
return $this->success();
|
|
}
|
|
|
|
/**
|
|
* 商品下架
|
|
* @param $goods_ids
|
|
* @param $site_id
|
|
* @return array|mixed
|
|
* @throws \GuzzleHttp\Exception\GuzzleException
|
|
*/
|
|
public function goodsDelisting($goods_ids, $site_id)
|
|
{
|
|
if (!empty($goods_ids)) {
|
|
$array_goodsIds = explode(',', $goods_ids);
|
|
}
|
|
foreach ($array_goodsIds as $k => $goods_id) {
|
|
$res[ $k ] = ( new Weapp($site_id) )->delisting([ 'out_product_id' => $goods_id ]);
|
|
if ($res[ $k ][ 'code' ] != 0) return $res[ $k ];
|
|
}
|
|
model('shopcompoent_goods')->update([ 'status' => 11 ], [ [ 'site_id', '=', $site_id ], [ 'out_product_id', 'in', $goods_ids ] ]);
|
|
return $this->success();
|
|
}
|
|
|
|
/**
|
|
* @param $site_id
|
|
*/
|
|
public function getOrderPayInfo($site_id)
|
|
{
|
|
$join = [
|
|
[ 'goods g', 'g.goods_id = sg.out_product_id', 'left' ]
|
|
];
|
|
$condition = [
|
|
[ 'sg.site_id', '=', $site_id ],
|
|
[ 'sg.status', '=', 5 ],
|
|
[ 'sg.edit_status', '=', 4 ],
|
|
[ 'g.is_delete', '=', 0 ],
|
|
[ 'g.goods_state', '=', 1 ]
|
|
];
|
|
$goods_info = model('shopcompoent_goods')->getInfo($condition, 'g.goods_name,g.price,g.goods_id,g.sku_id', 'sg', $join);
|
|
if (empty($goods_info)) return $this->error('', '请先将商品同步到微信侧，等待商品审核通过并已上架');
|
|
|
|
$qrcode_res = event('Qrcode', [
|
|
'site_id' => $site_id,
|
|
'app_type' => 'weapp',
|
|
'type' => 'create',
|
|
'data' => [
|
|
'goods_id' => $goods_info[ 'goods_id' ],
|
|
'is_test' => 1
|
|
],
|
|
'page' => '/pages/goods/detail',
|
|
'qrcode_path' => 'upload/qrcode/goods',
|
|
'qrcode_name' => 'goods_qrcode_' . $goods_info[ 'sku_id' ]
|
|
], true);
|
|
if ($qrcode_res[ 'code' ] != 0) return $qrcode_res;
|
|
|
|
$goods_info[ 'qrcode_path' ] = $qrcode_res[ 'data' ][ 'path' ];
|
|
|
|
return $this->success($goods_info);
|
|
}
|
|
} |