ship-expert/app/data/controller/shop/Goods.php

<?php

namespace app\data\controller\shop;

use app\data\controller\user\Admin;
use app\data\model\BaseUserDiscount;
use app\data\model\BaseUserPayment;
use app\data\model\BaseUserUpgrade;
use app\data\model\ShopGoods;
use app\data\model\ShopGoodsCate;
use app\data\model\ShopGoodsItem;
use app\data\model\ShopGoodsMark;
use app\data\model\ShopGoodsStock;
use app\data\model\SystemUser;
use app\data\service\ExpressService;
use app\data\service\GoodsService;
use think\admin\Controller;
use think\admin\extend\CodeExtend;
use think\admin\service\AdminService;

/**
 * 商品数据管理
 * Class Goods
 * @package app\data\controller\shop
 */
class Goods extends Controller
{

    /**
     * 商品数据管理
     * @auth true
     * @menu true
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function index()
    {

        $this->title = '商品数据管理';
        if(AdminService::getUserId()==10000){
            $admin_id = [];
        }
        else{
            $admin_id['admin_id']=AdminService::getUserId();
        }
        $query = ShopGoods::mQuery();
        // 加载对应数据
        $this->type = $this->request->get('type', 'index');
        if ($this->type === 'index') $query->where($admin_id)->where(['deleted' => 0,'examine'=>1]);
        elseif ($this->type === 'recycle') $query->where(['deleted' => 1]);
        else $this->error("无法加载 {$this->type} 数据列表！");

        //echo $this->request->get('cateids');
        $cateids = $this->request->get('cateids');

        // 代理搜索查询
        $db = SystemUser::mQuery()->like('nickname#nickname')->db();
        if ($db->getOptions('where')) $query->whereRaw("admin_id = {$db->field('id')->buildSql()}");

        // 列表排序并显示
        $query->like('code|name#name')
            ->like('marks', ',')
            ->when($cateids,function ($qu) use ($cateids){
                $qu->whereRaw("find_in_set(".$cateids.",cateids)");
            });
        $query->equal('status,vip_entry,truck_type,rebate_type,examine')->order('sort desc,id desc')->page();
    }

    protected function _index_page_filter(&$data)
    {
        foreach ($data as &$v){
            $arr = explode("|", $v['cover']);
            $v['cover'] = $arr[0];
            $users = SystemUser::mk()->whereIn('id', $v['admin_id'])->column('contact_phone,nickname', 'id');
            $v['user'] = $users[$v['admin_id']];
        }
    }

    /**
     * 商品选择器
     * @login true
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function select()
    {
        $query = ShopGoods::mQuery();
        $query->equal('status')->like('code,name,marks')->in('cateids');
        $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(array &$data)
    {
        $admin_id=AdminService::getUserId();
        $this->marks = ShopGoodsMark::items();
        $this->cates = ShopGoodsCate::treeTable();
        $this->assign('admin_id',$admin_id);
        GoodsService::bindData($data, false);
    }

    /**
     * 添加商品数据
     * @auth true
     */
    public function add()
    {
        $this->mode = 'add';
        $data['type'] = 'add';
        $this->type = $data['type'];
        $this->title = '添加商品数据';
        ShopGoods::mForm('form', 'code');
    }

    /**
     * 编辑商品数据
     * @auth true
     */
    public function edit()
    {
        $data = input();
        if(!isset($data['type'])){
            $data['type'] = 'edit';
        }
        $this->type = $data['type'];
        $this->mode = 'edit';
        $this->title = '编辑商品数据';
        ShopGoods::mForm('form', 'code');
    }

    protected function _edit_form_filter(&$data)
    {
//        var_dump($data);die;
        $arr = explode("|", $data['cover']);
        $data['cover_url'] = $arr[0];
//        var_dump($data);die;
//        foreach ($data['inde3x'] as &$v){
//            $arr = explode("|", $v['show_image']);
//            $v['show_image'] = $arr[0];
//        }
    }

    /**
     * 复制编辑商品
     * @auth true
     */
    public function copy()
    {
        $this->mode = 'copy';
        $this->title = '复制编辑商品';
        ShopGoods::mForm('form', 'code');
    }

    /**
     * 表单数据处理
     * @param array $data
     */
    protected function _copy_form_filter(array &$data)
    {
        if ($this->request->isPost()) {
            $data['code'] = CodeExtend::uniqidNumber(20, 'G');
        }
    }

    /**
     * 表单数据处理
     * @param array $data
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    protected function _form_filter(array &$data)
    {
        if (empty($data['code'])) {
            $data['code'] = CodeExtend::uniqidNumber(20, 'G');
        }
        if ($this->request->isGet()) {
            $data['marks'] = str2arr($data['marks'] ?? '');
            $data['payment'] = str2arr($data['payment'] ?? '');
            $data['cateids'] = str2arr($data['cateids'] ?? '');
            // 其他表单数据
            $this->marks = ShopGoodsMark::items();
            $this->cates = ShopGoodsCate::treeTable(true);
            $this->trucks = ExpressService::templates();
            $this->upgrades = BaseUserUpgrade::items();
            $this->payments = BaseUserPayment::mk()->where(['status' => 1, 'deleted' => 0])->order('sort desc,id desc')->column('type,code,name', 'code');
            $this->discounts = BaseUserDiscount::mk()->where(['status' => 1, 'deleted' => 0])->order('sort desc,id desc')->column('id,name,items', 'id');
            // 商品规格处理
            $fields = 'goods_sku `sku`,goods_code,goods_spec `key`,stock_total `stock`,price_selling `selling`,price_market `market`,number_virtual `virtual`,number_express `express`,reward_balance `balance`,reward_integral `integral`,status,show_image';
            $data['data_items'] = json_encode(ShopGoodsItem::mk()->where(['goods_code' => $data['code']])->column($fields, 'goods_spec'), JSON_UNESCAPED_UNICODE);

        } elseif ($this->request->isPost()) {

            //审核拒绝的情况
            if (!empty($data['examine_cause'])){
                $updata = [
                    'examine_cause'=>$data['examine_cause'],
                    'examine'=>2,
                    'examine_time'=>date('Y-m-d H:i:s'),
                    'examine_adminid'=>AdminService::getUserName()
                ];
                ShopGoods::update($updata,['id'=>$data['id']]);
                $this->success('操作成功1', 'javascript:history.back()');
                //$this->success('操作成功');
            }

            $data['admin_id']=AdminService::getUserId();
//            $data['examine']=0;

            $good = ShopGoodsItem::mk()->where(['goods_code' => $data['code']])->find();
            if($good){
                $data['admin_id'] = $good['admin_id'];
            }

            if (empty($data['cover'])) $this->error('商品图片不能为空！');
//            if (empty($data['slider'])) $this->error('轮播图片不能为空！');
//            if (empty($data['payment'])) $this->error('支付方式不能为空！');
            [$data['price_market'], $data['price_selling']] = [0, 0];
            $data['stock_total']=0;
            [$count, $items] = [0, array_column(json_decode($data['data_items'], true), 0)];

            foreach ($items as $item) if ($item['status'] > 0) {
                if ($data['price_market'] === 0 || $data['price_market'] > $item['market']) $data['price_market'] = $item['market'];
                if ($data['price_selling'] === 0 || $data['price_selling'] > $item['selling']) $data['price_selling'] = $item['selling'];
                $data['stock_total']+=$item['stock'];
                $count++;
            }
//            var_dump($count);die;
            if (empty($count)) $this->error('无效的的商品价格信息！');
            $data['marks'] = arr2str($data['marks'] ?? []);
//            $data['payment'] = arr2str($data['payment'] ?? []);
            ShopGoodsItem::mk()->where(['goods_code' => $data['code']])->update(['status' => 0]);
            ShopGoodsItem::mk()->where(['goods_code' => $data['code']])->delete();
            foreach ($items as $item) data_save(ShopGoodsItem::class, [
                'goods_sku'       => $item['sku'],
                'goods_spec'      => $item['key'],
                'goods_code'      => $data['code'],
                'stock_total'     => $item['stock'],
                'price_market'    => $item['market'],
                'price_selling'   => $item['selling'],
                'status'          => $item['status'] ? 1 : 0,
                'admin_id'        => $data['admin_id'],
                'show_image'      => $data['cover']
            ], '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(bool $result)
    {
        if ($result && $this->request->isPost()) {
//            GoodsService::stock(input('code'));
            $this->success('商品编辑成功！', 'javascript:history.back()');
        }
    }

    /**
     * 商品库存入库
     * @auth true
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function stock()
    {
        $map = $this->_vali(['code.require' => '商品编号不能为空哦！']);
        if ($this->request->isGet()) {
            $list = ShopGoods::mk()->where($map)->select()->toArray();
            if (empty($list)) $this->error('无效的商品数据，请稍候再试！');
            [$this->vo] = GoodsService::bindData($list);
            $this->fetch();
        } else {
            [$data, $post, $batch] = [[], $this->request->post(), CodeExtend::uniqidDate(12, 'B')];
            if (isset($post['goods_code']) && is_array($post['goods_code'])) {
                foreach (array_keys($post['goods_code']) as $key) {
                    if ($post['goods_stock'][$key] > 0) $data[] = [
                        'batch_no'    => $batch,
                        'goods_code'  => $post['goods_code'][$key],
                        'goods_spec'  => $post['goods_spec'][$key],
                        'goods_stock' => $post['goods_stock'][$key],
                    ];
                }
                if (!empty($data)) {
                    ShopGoodsStock::mk()->insertAll($data);
                    GoodsService::stock($map['code']);
                    $this->success('商品数据入库成功！');
                }
            }
            $this->error('没有需要商品入库的数据！');
        }
    }

    /**
     * 商品上下架
     * @auth true
     */
    public function state()
    {
        ShopGoods::mSave($this->_vali([
            'status.in:0,1'  => '状态值范围异常！',
            'status.require' => '状态值不能为空！',
        ]), 'code');
    }

    /**
     * 删除商品数据
     * @auth true
     */
    public function remove()
    {
        ShopGoods::mSave($this->_vali([
            'deleted.in:0,1'  => '状态值范围异常！',
            'deleted.require' => '状态值不能为空！',
        ]), 'code');
    }
    /**
     * 商品数据审核
     * @auth true
     * @menu true
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function examine()
    {
        if(AdminService::getUserId()==10000){
            $admin_id = [];
        }
        else{
            $admin_id['admin_id']=AdminService::getUserId();
        }
        $this->title = '商品数据审核';
        $query = ShopGoods::mQuery();
        // 加载对应数据
        $query->where(['deleted' => 0])->where($admin_id);
        // 列表排序并显示
        $query->where('examine','in','0,2')->like('code|name#name')->like('marks,cateids', ',');
        $list = $query->equal('status,vip_entry,truck_type,rebate_type')->order('sort desc,id desc')->select();
        $list->page();

    }

    protected function _examine_page_filter(&$data)
    {

        foreach ($data as &$v){
            $arr = explode("|", $v['cover']);
            $v['cover'] = $arr[0];
            $users = SystemUser::mk()->whereIn('id', $v['admin_id'])->column('contact_phone,nickname', 'id');
            $v['user'] = $users[$v['admin_id']];
        }
    }

    /**
     * 商品审核
     * @auth true
     * @menu true
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function examinex()
    {
//        if ($this->request->isGet()) {
//            $query = BasePostageCompany::mk()->where(['deleted' => 0, 'status' => 1]);
//            $this->items = $query->order('sort desc,id desc')->select()->toArray();
//        }
        if(input('examine')==1){
            ShopGoods::mSave($this->_vali([
                'examine.in:0,1,2'  => '状态值范围异常！',
                'examine.require' => '状态值不能为空！',
                'examine_time' => date('Y-m-d H:i:s'),
                'examine_adminid' => AdminService::getUserName()
            ]), 'code');
        }else{
            ShopGoods::mForm('examinex_form', 'id');
        }
    }

    /**
     * 商品审核1
     * @auth true
     * @menu true
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\DbException
     * @throws \think\db\exception\ModelNotFoundException
     */
    public function examines()
    {
//        if ($this->request->isGet()) {
//            $query = BasePostageCompany::mk()->where(['deleted' => 0, 'status' => 1]);
//            $this->items = $query->order('sort desc,id desc')->select()->toArray();
//        }
        if(input('examine')==1){
            $code = input('code');
            ShopGoods::where('code',$code)->update(['examine'=>1]);
            $this->success('商品编辑成功！', 'javascript:history.back()');
        }else{
            ShopGoods::mForm('examinex_form', 'id');
        }
    }

    /**
     * 商品编辑
     * @param array $data
     * @return void
     */
    public function examinex_edit(){
        if (empty($data['code'])) {
            $data['code'] = CodeExtend::uniqidNumber(20, 'G');
        }
        if ($this->request->isGet()) {
            $data['marks'] = str2arr($data['marks'] ?? '');
            $data['payment'] = str2arr($data['payment'] ?? '');
            $data['cateids'] = str2arr($data['cateids'] ?? '');
            // 其他表单数据
            $this->marks = ShopGoodsMark::items();
            $this->cates = ShopGoodsCate::treeTable(true);
            $this->trucks = ExpressService::templates();
            $this->upgrades = BaseUserUpgrade::items();
            $this->payments = BaseUserPayment::mk()->where(['status' => 1, 'deleted' => 0])->order('sort desc,id desc')->column('type,code,name', 'code');
            $this->discounts = BaseUserDiscount::mk()->where(['status' => 1, 'deleted' => 0])->order('sort desc,id desc')->column('id,name,items', 'id');
            // 商品规格处理
            $fields = 'goods_sku `sku`,goods_code,goods_spec `key`,stock_total `stock`,price_selling `selling`,price_market `market`,number_virtual `virtual`,number_express `express`,reward_balance `balance`,reward_integral `integral`,status,show_image';
            $data['data_items'] = json_encode(ShopGoodsItem::mk()->where(['goods_code' => $data['code']])->column($fields, 'goods_spec'), JSON_UNESCAPED_UNICODE);

        } elseif ($this->request->isPost()) {

            $data['admin_id']=AdminService::getUserId();
            $data['examine']=0;

            if (empty($data['cover'])) $this->error('商品图片不能为空！');
//            if (empty($data['slider'])) $this->error('轮播图片不能为空！');
//            if (empty($data['payment'])) $this->error('支付方式不能为空！');
            [$data['price_market'], $data['price_selling']] = [0, 0];
            $data['stock_total']=0;
            [$count, $items] = [0, array_column(json_decode($data['data_items'], true), 0)];
            foreach ($items as $item) if ($item['status'] > 0) {
                if ($data['price_market'] === 0 || $data['price_market'] > $item['market']) $data['price_market'] = $item['market'];
                if ($data['price_selling'] === 0 || $data['price_selling'] > $item['selling']) $data['price_selling'] = $item['selling'];
                $data['stock_total']+=$item['stock'];
                $count++;
            }
            if (empty($count)) $this->error('无效的的商品价格信息！');
            $data['marks'] = arr2str($data['marks'] ?? []);
//            $data['payment'] = arr2str($data['payment'] ?? []);
            ShopGoodsItem::mk()->where(['goods_code' => $data['code']])->update(['status' => 0]);
            foreach ($items as $item) data_save(ShopGoodsItem::class, [
                'goods_sku'       => $item['sku'],
                'goods_spec'      => $item['key'],
                'goods_code'      => $data['code'],
                'stock_total'     => $item['stock'],
                'price_market'    => $item['market'],
                'price_selling'   => $item['selling'],
                'status'          => $item['status'] ? 1 : 0,
                'admin_id'        => $data['admin_id'],
                'show_image'      => $data['cover']
            ], 'goods_spec', [
                'goods_code' => $data['code'],
            ]);
        }
    }


    public function _examinex_form_filter(array &$data)
    {
        if ($this->request->isPost()) {
            if (empty($data['examine_cause'])) $this->error('不能为空！');
            $updata = [
                'examine_cause'=>$data['examine_cause'],
                'examine'=>2,
                'examine_time'=>date('Y-m-d H:i:s'),
                'examine_adminid'=>AdminService::getUserName()
            ];
            ShopGoods::update($updata,['id'=>$data['id']]);
            //$this->success('操作成功1', 'javascript:history.back()');
            $this->success('操作成功');
        }
    }


}