<?php
namespace app\goods\controller;
use app\goods\service\ProductService;
use controller\BasicAdmin;
use service\DataService;
use service\ToolsService;
use think\Db;
use think\exception\HttpResponseException;
/**
* 商店产品管理
* Class Goods
* @package app\store\controller
* @author Anyon <zoujingli@qq.com>
* @date 2017/03/27 14:43
*/
class Product extends BasicAdmin
{
public $table = 'Goods';
public function index()
{
$this->title = '产品管理';
$get = $this->request->get();
$db = Db::name($this->table)->where(['is_deleted' => '0']);
if (isset($get['tags_id']) && $get['tags_id'] !== '') {
$db->whereLike('tags_id', "%,{$get['tags_id']},%");
}
if (isset($get['goods_title']) && $get['goods_title'] !== '') {
$db->whereLike('goods_title', "%{$get['goods_title']}%");
}
foreach (['cate_id', 'brand_id'] as $field) {
(isset($get[$field]) && $get[$field] !== '') && $db->where($field, $get[$field]);
}
if (isset($get['create_at']) && $get['create_at'] !== '') {
list($start, $end) = explode(' - ', $get['create_at']);
$db->whereBetween('create_at', ["{$start} 00:00:00", "{$end} 23:59:59"]);
}
return parent::_list($db->order('status desc,sort asc,id desc'));
}
protected function _data_filter(&$data)
{
$result = ProductService::buildGoodsList($data);
$this->assign([
'brands' => $result['brand'],
'cates' => ToolsService::arr2table($result['cate']),
]);
}
public function add()
{
if ($this->request->isGet()) {
$this->title = '添加产品';
$this->_form_assign();
return $this->_form($this->table, 'form');
}
try {
$data = $this->_form_build_data();
Db::transaction(function () use ($data) {
$goodsID = Db::name($this->table)->insertGetId($data['main']);
foreach ($data['list'] as &$vo) {
$vo['goods_id'] = $goodsID;
}
Db::name('GoodsList')->insertAll($data['list']);
});
} catch (HttpResponseException $exception) {
return $exception->getResponse();
} catch (\Exception $e) {
$this->error('产品添加失败，请稍候再试！');
}
list($base, $spm, $url) = [url('@admin'), $this->request->get('spm'), url('goods/product/index')];
$this->success('添加产品成功！', "{$base}#{$url}?spm={$spm}");
}
public function edit()
{
if (!$this->request->isPost()) {
$goods_id = $this->request->get('id');
$goods = Db::name($this->table)->where(['id' => $goods_id, 'is_deleted' => '0'])->find();
empty($goods) && $this->error('需要编辑的产品不存在！');
$goods['list'] = Db::name('GoodsList')->where(['goods_id' => $goods_id, 'is_deleted' => '0'])->select();
$this->_form_assign();
return $this->fetch('form', ['vo' => $goods, 'title' => '编辑产品']);
}
try {
$data = $this->_form_build_data();
$goods_id = $this->request->post('id');
$goods = Db::name($this->table)->where(['id' => $goods_id, 'is_deleted' => '0'])->find();
empty($goods) && $this->error('产品编辑失败，请稍候再试！');
foreach ($data['list'] as &$vo) {
$vo['goods_id'] = $goods_id;
}
Db::transaction(function () use ($data, $goods_id, $goods) {
$where = ['id' => $goods_id, 'is_deleted' => '0'];
Db::name('Goods')->where($where)->update(array_merge($goods, $data['main']));
Db::name('GoodsList')->where(['goods_id' => $goods_id])->delete();
Db::name('GoodsList')->insertAll($data['list']);
});
} catch (HttpResponseException $exception) {
return $exception->getResponse();
} catch (\Exception $e) {
$this->error('产品编辑失败，请稍候再试！' . $e->getMessage());
}
list($base, $spm, $url) = [url('@admin'), $this->request->get('spm'), url('goods/product/index')];
$this->success('产品编辑成功！', "{$base}#{$url}?spm={$spm}");
}
protected function _form_assign()
{
list($where, $order) = [['status' => '1', 'is_deleted' => '0'], 'sort asc,id desc'];
$specs = (array)Db::name('GoodsSpec')->where($where)->order($order)->select();
$brands = (array)Db::name('GoodsBrand')->where($where)->order($order)->select();
$cates = (array)Db::name('GoodsCate')->where($where)->order($order)->select();
$where = ['is_deleted' => '0', 'status' => '1'];
$goodsListField = 'goods_id,goods_spec,goods_stock,goods_sale';
$goods = Db::name('Goods')->field('id,goods_title')->where($where)->select();
$list = Db::name('GoodsList')->field($goodsListField)->where($where)->select();
foreach ($goods as $k => $g) {
$goods[$k]['list'] = [];
foreach ($list as $v) {
($g['id'] === $v['goods_id']) && $goods[$k]['list'][] = $v;
}
}
array_unshift($specs, ['spec_title' => ' - 不使用规格模板 -', 'spec_param' => '[]', 'id' => '0']);
$this->assign([
'specs' => $specs,
'cates' => ToolsService::arr2table($cates),
'brands' => $brands,
'all' => $goods,
]);
}
protected function _form_build_data()
{
list($main, $list, $post, $verify) = [[], [], $this->request->post(), false];
empty($post['goods_logo']) && $this->error('产品LOGO不能为空，请上传后再提交数据！');
$main['cate_id'] = $this->request->post('cate_id', '0');
$main['spec_id'] = $this->request->post('spec_id', '0');
$main['brand_id'] = $this->request->post('brand_id', '0');
$main['goods_logo'] = $this->request->post('goods_logo', '');
$main['goods_title'] = $this->request->post('goods_title', '');
$main['goods_video'] = $this->request->post('goods_video', '');
$main['goods_image'] = $this->request->post('goods_image', '');
$main['goods_desc'] = $this->request->post('goods_desc', '', null);
$main['goods_content'] = $this->request->post('goods_content', '');
$main['tags_id'] = ',' . join(',', isset($post['tags_id']) ? $post['tags_id'] : []) . ',';
if (!empty($post['goods_spec'])) {
foreach ($post['goods_spec'] as $key => $value) {
$goods = [];
$goods['goods_spec'] = $value;
$goods['market_price'] = $post['market_price'][$key];
$goods['selling_price'] = $post['selling_price'][$key];
$goods['status'] = intval(!empty($post['spec_status'][$key]));
!empty($goods['status']) && $verify = true;
$list[] = $goods;
}
} else {
$this->error('没有产品规格或套餐信息哦！');
}
!$verify && $this->error('没有设置有效的产品规格！');
return ['main' => $main, 'list' => $list];
}
public function del()
{
if (DataService::update($this->table)) {
$this->success("产品删除成功！", '');
}
$this->error("产品删除失败，请稍候再试！");
}
public function forbid()
{
if (DataService::update($this->table)) {
$this->success("产品禁用成功！", '');
}
$this->error("产品禁用失败，请稍候再试！");
}
public function resume()
{
if (DataService::update($this->table)) {
$this->success("产品启用成功！", '');
}
$this->error("产品启用失败，请稍候再试！");
}
}