title = '商品数据管理'; $query = $this->_query($this->table); $query->like('name')->equal('status,cate'); // 加载对应数据 $this->type = $this->request->get('type', 'index'); if ($this->type === 'index') $query->where(['deleted' => 0]); elseif ($this->type === 'recycle') $query->where(['deleted' => 1]); else $this->error("无法加载 {$this->type} 数据列表!"); // 列表排序并显示 $query->order('sort desc,id desc')->page(); } /** * 商品选择器 * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function select() { $query = $this->_query($this->table)->equal('status,cate')->like('name'); $query->where(['deleted' => '0'])->order('sort desc,id desc')->page(); } /** * 数据列表处理 * @param array $data * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ protected function _page_filter(&$data) { $query = $this->app->db->name('ShopGoodsCate'); $query->where(['deleted' => 0, 'status' => 1])->order('sort desc,id desc'); $this->clist = DataExtend::arr2table($query->select()->toArray()); foreach ($data as &$vo) { [$vo['list'], $vo['cate']] = [[], []]; foreach ($this->clist as $cate) if ($cate['id'] === $vo['cate']) $vo['cate'] = $cate; } } /** * 商品库存入库 * @auth true * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function stock() { if ($this->request->isGet()) { $code = $this->request->get('code'); $goods = $this->app->db->name('ShopGoods')->where(['code' => $code])->find(); empty($goods) && $this->error('无效的商品信息,请稍候再试!'); $map = ['goods_code' => $code, 'status' => 1]; $goods['list'] = $this->app->db->name('ShopGoodsItem')->where($map)->select()->toArray(); $this->fetch('', ['vo' => $goods]); } else { [$post, $data] = [$this->request->post(), []]; if (isset($post['id']) && isset($post['goods_code']) && is_array($post['goods_code'])) { foreach (array_keys($post['goods_id']) as $key) if ($post['goods_number'][$key] > 0) array_push($data, [ 'goods_code' => $post['goods_code'][$key], 'goods_spec' => $post['goods_spec'][$key], 'stock_total' => $post['goods_number'][$key], ]); if (!empty($data)) { $this->app->db->name('ShopGoodsStock')->insertAll($data); GoodsService::instance()->syncStock($post['code']); $this->success('商品信息入库成功!'); } } $this->error('没有需要商品入库的数据!'); } } /** * 添加商品信息 * @auth true * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function add() { $this->mode = 'add'; $this->title = '添加商品信息'; $this->_form($this->table, 'form', 'code'); } /** * 编辑商品信息 * @auth true * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ public function edit() { $this->mode = 'edit'; $this->title = '编辑商品信息'; $this->_form($this->table, 'form', 'code'); } /** * 表单数据处理 * @param array $data * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ protected function _form_filter(&$data) { if (empty($data['code'])) { $data['code'] = CodeExtend::uniqidNumber(12, 'G'); } if ($this->request->isGet()) { // 商品分类数据 $this->cates = GoodsService::instance()->getCateList('arr2table'); // 商品默认规格 $fields = 'goods_sku `sku`,goods_code,goods_spec `key`,price_selling `selling`,price_market `market`,number_virtual `virtual`,number_express `express`,status'; $data['data_items'] = json_encode($this->app->db->name('ShopGoodsItem')->where(['goods_code' => $data['code']])->column($fields, 'goods_spec'), JSON_UNESCAPED_UNICODE); } elseif ($this->request->isPost()) { if (empty($data['cover'])) $this->error('商品图片不能为空!'); if (empty($data['slider'])) $this->error('轮播图不能为空!'); // 商品规格保存 [$count, $items] = [0, json_decode($data['data_items'], true)]; foreach ($items as $item) { $count += intval($item[0]['status']); if (empty($data['price_market'])) $data['price_market'] = $item[0]['market']; } if (empty($count)) $this->error('无可用的商品规格!'); $this->app->db->name('ShopGoodsItem')->where(['goods_code' => $data['code']])->update(['status' => 0]); foreach ($items as $item) data_save('ShopGoodsItem', [ 'goods_code' => $data['code'], 'goods_sku' => $item[0]['sku'], 'goods_spec' => $item[0]['key'], 'price_market' => $item[0]['market'], 'price_selling' => $item[0]['selling'], 'number_virtual' => $item[0]['virtual'], 'number_express' => $item[0]['express'], 'status' => $item[0]['status'] ? 1 : 0, ], 'goods_spec', ['goods_code' => $data['code']]); } } /** * 表单结果处理 * @param boolean $result * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\DbException * @throws \think\db\exception\ModelNotFoundException */ protected function _form_result($result) { if ($result && $this->request->isPost()) { GoodsService::instance()->syncStock(input('code')); $this->success('商品编辑成功!', 'javascript:history.back()'); } } /** * 上下架商品管理 * @auth true * @throws \think\db\exception\DbException */ public function state() { $this->_save($this->table, $this->_vali([ 'status.in:0,1' => '状态值范围异常!', 'status.require' => '状态值不能为空!', ]), 'code'); } /** * 删除商品信息 * @auth true * @throws \think\db\exception\DbException */ public function remove() { $this->_save($this->table, $this->_vali([ 'deleted.in:0,1' => '状态值范围异常!', 'deleted.require' => '状态值不能为空!', ]), 'code'); } }