phpstock/app/admin/controller/Cat.php

<?php

namespace app\admin\controller;

use app\admin\model\ActionLog;
use app\admin\model\ChangeLog;
use app\BaseController;
use think\App;
use think\Exception;
use think\facade\Db;
use think\facade\Validate;

//分类
class Cat extends Base
{

    //树状列表
    public function list()
    {
        $param = $this->request->only(['pid' => 0, 'cat_name' => ''], 'post', 'trim');

        $where = [['is_del', '=', 0], ['pid', '=', $param['pid']]];

        if ($param['cat_name'] !== '') $where[] = ['cat_name', 'like', '%' . $param['cat_name'] . '%'];

        $data = Db::name('cat')->where($where)->order("id desc")->cursor();
        $vmp = [];
        foreach ($data as $sts) {
            $vmp[] = stro($sts);
        }
        return app_show(0, '获取成功', $vmp);
    }

    //列表(含规格和创建人部门)
    public function plist()
    {
        $param = $this->request->only(['page' => 1, 'size' => 10, 'cat_name' => '', 'pid' => '', 'status' => '', 'company_name' => ''], 'post', 'trim');
        $where = [['c.is_del', '=', 0]];
        if ($param['cat_name'] !== '') $where[] = ['c.cat_name', 'like', '%' . $param['cat_name'] . '%'];
        if ($param['pid'] !== '') $where[] = ['c.pid', '=', $param['pid']];
        if ($param['status'] !== '') $where[] = ['c.status', '=', $param['status']];
        if ($param['company_name'] !== '') $where[] = ['c.createrid', 'in', get_company_item_user_by_name($param['company_name'])];

        $count = Db::name('cat')->alias('c')->where($where)->count();
        $list = Db::name('cat')
            ->alias('c')
            ->where($where)
            ->page($param['page'], $param['size'])
            ->order(['c.id'=>'desc'])
            ->select()
            ->toArray();
        $var = [];
        $all_createrid = array_column($list,'createrid');
        $item = get_company_name_by_uid($all_createrid);

        foreach ($list as $value) {
            $temp = Db::name('cat_specs')
                ->field('a.specs_id,b.spec_name')
                ->alias('a')
                ->leftJoin('specs b', 'b.id=a.specs_id')
                ->where(['a.cat_id' => $value['id'], 'a.is_del' => 0])
                ->select()
                ->toArray();
            if (empty($temp)) {
                $temp = [];
            }
            $value['im'] = $temp;
            $value['company_name'] = $item[$value['createrid']]??'';
            $var[] = $value;
        }
        return app_show(0, '获取成功', ['list' => $var, 'count' => $count]);
    }

    //查看所有三级分类
    public function wlist()
    {
        $param = $this->request->only(['page' => 1, 'size' => 10, 'cat_name' => '', 'search' => '', 'pid' => '', 'status' => ''], 'post', 'trim');

        $where = [['is_del', '=', 0], ['level', '=', 3]];
        if ($param['cat_name'] !== '') $where[] = ['cat_name', 'like', '%' . $param['cat_name'] . '%'];
        if ($param['search'] !== '') $where[] = ['search', 'like', '%' . $param['search'] . '%'];
        if ($param['pid'] !== '') $where[] = ['pid', '=', $param['pid']];
        if ($param['status'] !== '') $where[] = ['status', '=', $param['status']];
        $count = Db::name('cat')
            ->where($where)
            ->count();
        $list = Db::name('cat')
            ->where($where)
            ->page($param['page'], $param['size'])
            ->select()
            ->toArray();
        $data = [];
        foreach ($list as $value) {
            $value['item'] = array_column(made($value['id'] ?? 0), 'id');
//            $value['is_gold'] = cat_is_gold($value['id']);;
            $data[] = $value;
        }
        return app_show(0, '获取成功', ['list' => $data, 'count' => $count]);
    }

    //列表
    public function title()
    {
        $param = $this->request->only(['cat_name' => '', 'pid' => '', 'status' => '',], 'post', 'trim');


        $where = [['is_del', '=', 0]];
        if ($param['cat_name'] !== '') $where[] = ['cat_name', 'like', '%' . $param['cat_name'] . '%'];
        if ($param['pid'] !== '') $where[] = ['pid', '=', $param['pid']];
        if ($param['status'] !== '') $where[] = ['status', '=', $param['status']];

        $list = Db::name('cat')
            ->where($where)
            ->select()
            ->toArray();
        return app_show(0, '获取成功', $list);
    }

    //列表
    public function tlist()
    {
        $param = $this->request->only(['page' => 1, 'size' => 10, 'cat_name' => '', 'status' => '', 'creater' => '', 'start' => '', 'end' => '', 'company_name' => ''], 'post', 'trim');


        $where = [['c.is_del', '=', 0]];
        if ($param['cat_name'] !== '') $where[] = ['c.cat_name', 'like', '%' . $param['cat_name'] . '%'];
        if ($param['status'] !== '') $where[] = ['c.status', '=', $param['status']];
        if ($param['creater'] !== '') $where[] = ['c.creater', 'like', '%' . $param['creater'] . '%'];
        if ($param['start'] !== '') $where[] = ['c.addtime', '>=', $param['start']];
        if ($param['end'] !== '') $where[] = ['c.addtime', '<=', $param['end']];
        if ($param['company_name'] !== '') $where[] = ['c.createrid', 'in', get_company_item_user_by_name($param['company_name'])];

        $count = Db::name('cat')
            ->alias('c')
            ->leftJoin('depart_user u', 'u.uid=c.createrid AND u.is_del=0')
            ->where($where)
            ->count();
//        $total = ceil($count / $size);
//        $page = $page >= $total ? $total : $page;
        $list = Db::name('cat')
            ->alias('c')
            ->where($where)
            ->page($param['page'], $param['size'])
            ->order("id desc")
            ->select()
            ->toArray();
        $var = [];
        $all_createrid = array_column($list,'createrid');
        $item = get_company_name_by_uid($all_createrid);
        foreach ($list as $value) {
            $temp = Db::name('cat_specs')
                ->field('a.specs_id,b.spec_name')
                ->alias('a')
                ->leftJoin('specs b', 'b.id=a.specs_id')
                ->where(['a.cat_id' => $value['id'], 'a.is_del' => 0])
                ->select()
                ->toArray();

            $value['im'] = $temp;
            $value['company_name'] = $item[$value['createrid']] ?? '';
            $var[] = $value;
        }
        return app_show(0, '获取成功', ['list' => $var, 'count' => $count]);
    }

    //创建
    public function create()
    {
        $param = $this->request->only(['cat_name', 'pid', 'cat_desc' => '', 'fund_code' => '', 'specs_id', 'weight' => 0, 'status' => 0], 'post', 'trim');
        $val = Validate::rule([
            'cat_name|分类名称' => 'require|max:255',
            'pid|父级id' => 'require|number|egt:0',
            'specs_id' => 'require|array|max:100',
            'weight|权重' => 'number|egt:0',
            'status|状态' => 'number|in:0,1',
        ]);

        if (!$val->check($param)) return json_show(1004, $val->getError());
        $level = 1;

        if ($param['pid'] != 0) {
            $levl = Db::name('cat')
                ->field('id,level,search')
                ->where(['id' => $param['pid']])
                ->find();
            if (empty($levl)) return json_show(1002, '未找到父级数据');

            $level = $levl['level'] + 1;
            $temp = $levl['search'];
        }
        if ($level == 1) $search = $param['cat_name'];
        else $search = $temp . '-' . $param['cat_name'];

        $repeat_name = Db::name('cat')
            ->field('id')
            ->where(['is_del' => 0, 'cat_name' => $param['cat_name']])
            ->find();

        $int = isset($repeat_name['id']) && $repeat_name['id'] != 0 ? made($repeat_name['id']) : [];
        $im = array_column($int, 'name');
        $in = implode('/', $im);
        if (!empty($repeat_name)) {
            return json_show(1004, "分类名称已在{$in}存在");
        }
//        $specs_id = isset($this->post['specs_id']) && $this->post['specs_id'] !== '' ? $this->post['specs_id'] : [];
//        if (empty($specs_id)) {
//            return error_show(1002, '参数specs_id不能为空');
//        }
//        $token = isset($this->post['token']) && $this->post['token'] != '' ? trim($this->post['token']) : '';
//        if ($token == '') {
//            return error_show(105, '参数token不能为空');
//        }
//        $user = GetUserInfo($token);
//        if (empty($user) || $user['code'] != 0) {
//            return error_show(102, '创建人数据不存在');
//        }
        $createrid = $this->uid;//isset($user['data']['id']) ? $user['data']['id'] : '';
        $creater = $this->uname;//($user['data']['nickname']) ? $user['data']['nickname'] : '';
//        $weight = isset($this->post['weight']) && $this->post['weight'] !== '' ? intval($this->post['weight']) : '0';
//        $status = isset($this->post['status']) && $this->post['status'] !== '' ? intval($this->post['status']) : '0';
        Db::startTrans();
        try {
            $date = date('Y-m-d H:i:s');
            $data = [
                'cat_name' => $param['cat_name'],
                'pid' => $param['pid'],
                'level' => $level,
                'search' => $search,
                'weight' => $param['weight'],
                'status' => $param['status'],
                'cat_desc' => $param['cat_desc'],
                'fund_code' => $param['fund_code'],
                'creater' => $creater,
                'createrid' => $createrid,
                'is_del' => 0,
                'addtime' => $date,
                'updatetime' => $date,
            ];
            $datainfo = Db::name('cat')->insertGetId($data);
            $vat = [];
            if ($datainfo > 0) {
                $stx = ['order_code' => $param['pid'], 'status' => $param['status'], 'action_remark' => '', 'action_type' => 'create'];
                ActionLog::logAdd(['id' => $createrid, 'nickname' => $creater], $stx, 'sxd', $param['status'], $stx);
                $spc = [];
                $spc['cat_id'] = $datainfo;
                $spc['exam_status'] = 0;
                $spc['status'] = 0;
                $spc['creater'] = $creater;
                $spc['createrid'] = $createrid;
                $spc['is_del'] = 0;
                $spc['addtime'] = $date;
                $spc['updatetime'] = $date;
                $vpn = Db::name('cat_spec')->insertGetId($spc);
                if ($vpn == '') throw new Exception('新建失败');

                foreach ($param['specs_id'] as $value) {
                    $item = [];
                    $item['cat_id'] = $datainfo;
                    $item['specs_id'] = $value;
                    $item['is_del'] = 0;
                    $item['addtime'] = $date;
                    $vat[] = $item;
                }
                $vp = Db::name('cat_specs')->insertAll($vat);
                if ($vp == 0) throw new Exception('新建失败');


                $catinfo = ['cat_id' => $datainfo, 'apply_name' => $creater, 'apply_id' => $createrid, 'fund_code' => $param['fund_code'], 'status' => 0];
                $this->addPlat($catinfo);
                Db::commit();
                return json_show(0, '新建成功');
            } else {
                Db::rollback();
                return json_show(1002, '新建失败');
            }
        } catch (Exception $exception) {
            Db::rollback();
            return json_show(1005, $exception->getMessage());
        }

    }

    //编辑
    public function edit()
    {
        $id = isset($this->post['id']) && $this->post['id'] !== '' ? intval($this->post['id']) : '';
        $idinfo = Db::name('cat')->where(['id' => $id])->find();
        if ($idinfo == '') {
            return error_show(1002, '未找到商品数据');
        }
        $cat_name = isset($this->post['cat_name']) && $this->post['cat_name'] !== '' ? trim($this->post['cat_name']) : '';
        if ($cat_name == '') {
            return error_show(1002, '参数cat_name不能为空');
        }
        $pid = isset($this->post['pid']) && $this->post['pid'] !== '' ? intval($this->post['pid']) : '';
        if ($pid === '') {
            return error_show(1002, '参数pid不能为空');
        }
        $cat_desc = isset($this->post['cat_desc']) && $this->post['cat_desc'] !== '' ? trim($this->post['cat_desc']) : '';
        $fund_code = isset($this->post['fund_code']) && $this->post['fund_code'] !== '' ? trim($this->post['fund_code']) : '';
        $specs_id = isset($this->post['specs_id']) && $this->post['specs_id'] !== '' ? $this->post['specs_id'] : [];
        if (empty($specs_id)) {
            return error_show(1002, '参数specs_id不能为空');
        }
//        $token = isset($this->post['token']) && $this->post['token'] != '' ? trim($this->post['token']) : '';
//        if ($token == '') {
//            return error_show(105, '参数token不能为空');
//        }
//        $user = GetUserInfo($token);
//        if (empty($user) || $user['code'] != 0) {
//            return error_show(102, '创建人数据不存在');
//        }

        $level = 1;
        if ($pid !== 0) {
            $levl = Db::name('cat')->where(['id' => $pid])->find();
            if (empty($levl)) {
                return error_show(1002, '未找到父级数据');
            }
            $level = $levl['level'] + 1;
            $temp = $levl['search'];
        }
        if ($level == 1) {
            $search = $cat_name;
        } else {
            $search = $temp . '_' . $cat_name;
        }
        $createrid = $this->uid;//isset($user['data']['id']) ? $user['data']['id'] : '';
        $creater = $this->uname;//isset($user['data']['nickname']) ? $user['data']['nickname'] : '';
        //$level = isset($this->post['level']) && $this->post['level'] !=='' ? intval($this->post['level']) :'';

        $weight = isset($this->post['weight']) && $this->post['weight'] !== '' ? intval($this->post['weight']) : '0';
        $status = isset($this->post['status']) && $this->post['status'] !== '' ? intval($this->post['status']) : '0';
        Db::startTrans();
        try {
            $str = [
                'id' => $id,
                'cat_name' => $cat_name,
                'pid' => $pid,
                'level' => $level,
                'weight' => $weight,
                // 'status'=>$status,
                'cat_desc' => $cat_desc,
                'is_del' => 0,
                'fund_code' => $fund_code,
                'updatetime' => date('Y-m-d H:i:s'),
                'search' => $search
            ];
            $strinfo = Db::name('cat')->where(['id' => $id])->save($str);
            $temp = array_diff($str, $idinfo);
            $json = json_encode($temp, JSON_UNESCAPED_UNICODE);
            $jsp = json_encode($idinfo, JSON_UNESCAPED_UNICODE);
            if ($strinfo) {
                $order = ['order_code' => $id, 'status' => $status, 'action_remark' => '', 'action_type' => 'edit'];
                ActionLog::logAdd(['id'=>$createrid,'nickname'=>$creater], $order, 'sxd', $status, $order);
                ChangeLog::logAdd(7, $idinfo['id'], $jsp, $json, ['id'=>$createrid,'nickname'=>$creater]);
                $spc = [];
                $vp = Db::name('cat_spec')->where(['cat_id' => $idinfo['id'], 'is_del' => 0])->find();
                $str = '';
                if ($vp != false) {
                    isset($vp['id']) && $vp['id'] !== '' ? $spc['id'] = $vp['id'] : '';
                    $spc['cat_id'] = $idinfo['id'];
                    $spc['exam_status'] = 0;
                    $spc['status'] = 0;
                    $spc['is_del'] = 0;
                    $spc['updatetime'] = date('Y-m_d H:i:s');
                    $str = $vp['id'];
                    $vpn = Db::name('cat_spec')->save($spc);
                } else {

                    $spc['cat_id'] = $idinfo['id'];
                    $spc['exam_status'] = 0;
                    $spc['status'] = 0;
                    $spc['creater'] = $creater;
                    $spc['createrid'] = $createrid;
                    $spc['is_del'] = 0;
                    $spc['addtime'] = date('Y-m-d H:i:d');
                    $spc['updatetime'] = date('Y-m_d H:i:s');

                    $vpn = Db::name('cat_spec')->insert($spc, true);
                    $str = $vpn;
                }
                if ($vpn == false) {
                    Db::rollback();
                    return error_show(1002, '更新失败');
                }
                $db = Db::name('cat_specs')->where(['cat_id' => $idinfo['id'], 'is_del' => 0])->column('specs_id');
                if (empty($db)) {
                    $db = [];
                }
                $sn = array_diff($specs_id, $db);

                $st = array_diff($db, $specs_id);
                if (!empty($st)) {
                    $int['is_del'] = 1;
                    $dn = Db::name('cat_specs')->where(['cat_id' => $idinfo['id'], 'specs_id' => $st, 'is_del' => 0])->save($int);
                    if ($dn == false) {
                        Db::rollback();
                        return error_show(1002, '编辑失败');
                    }
                }
                if (!empty($sn)) {
                    $vat = [];
                    foreach ($sn as $value) {
                        $item = [];
                        $item['cat_id'] = $idinfo['id'];
                        $item['specs_id'] = $value;
                        $item['is_del'] = 0;
                        $item['addtime'] = date('Y-m-d H:i:s');
                        $vat[] = $item;
                    }
                    $vp = Db::name('cat_specs')->insertAll($vat);
                    if ($vp == 0) {
                        Db::rollback();
                        return error_show(1002, '编辑失败');
                    }
                }
                $itn = sear($id);
                Db::commit();
                return error_show(0, '编辑成功');
            } else {
                Db::rollback();
                return error_show(1002, '编辑失败');
            }
        } catch (\Exception $e) {
            Db::rollback();
            return error_show(1005, $e->getMessage());
        }
    }

    //更新分类利率相关
    public function ratedit()
    {
        $id = isset($this->post['id']) && $this->post['id'] !== '' ? intval($this->post['id']) : '';
        $idinfo = Db::name('cat')->where(['id' => $id])->find();
        if ($idinfo == '') {
            return error_show(1002, '未找到商品数据');
        }
        $rate = isset($this->post['rate']) && $this->post['rate'] !== '' ? floatval($this->post['rate']) : '';
        $order_rate = isset($this->post['order_rate']) && $this->post['order_rate'] !== '' ? floatval($this->post['order_rate']) : '';
        $sale_rate = isset($this->post['sale_rate']) && $this->post['sale_rate'] !== '' ? floatval($this->post['sale_rate']) : '';
        $lower_rate = isset($this->post['lower_rate']) && $this->post['lower_rate'] !== '' ? floatval($this->post['lower_rate']) : '';
        $money_rate = isset($this->post['money_rate']) && $this->post['money_rate'] !== '' ? floatval($this->post['money_rate']) : '';
        $low_rate = isset($this->post['low_rate']) && $this->post['low_rate'] !== '' ? floatval($this->post['low_rate']) : '';
        if ($idinfo['pid'] == 0) {
            if ($rate === '') {
                return error_show(1003, '参数rate不能为空');
            }
            if ($order_rate === '') {
                return error_show(1003, '参数order_rate不能为空');
            }
            if ($sale_rate === '') {
                return error_show(1003, '参数sale_rate不能为空');
            }
            if ($lower_rate === '') {
                return error_show(1003, '参数lower_rate不能为空');
            }
            if ($money_rate == '') {
                return error_show(1003, '参数money_rate不能为空');
            }
            if ($low_rate == '') {
                return error_show(1003, '参数low_rate不能为空');
            }
        }
        $data = [
            'id' => $id,
            'rate' => $rate,
            'lower_rate' => $lower_rate,
            'order_rate' => $order_rate,
            'sale_rate' => $sale_rate,
            'money_rate' => $money_rate,
            'low_rate' => $low_rate,
            'is_del' => 0,
            'updatetime' => date('Y-m-d H:i:s'),
        ];
        $strinfo = Db::name('cat')->where(['id' => $id])->save($data);
        if ($strinfo) {
            return error_show(0, '更新成功');
        } else {
            return error_show(1002, '更新失败');
        }
    }

    //详情
    public function info()
    {

        $id = $this->request->post('id/d', 0, 'trim');
        $idinfo = Db::name('cat')
            ->where(['id' => $id])
            ->append(['spec'])
            ->withAttr('spec', function ($val, $da) {
                return Db::name('cat_specs')
                    ->alias('a')
                    ->leftJoin('specs b', 'b.id=a.specs_id')
                    ->where(['a.cat_id' => $da['id'], 'a.is_del' => 0])
                    ->field('a.specs_id id,b.spec_name')
                    ->select()
                    ->toArray();
            })
            ->findOrEmpty();
        
        return $idinfo ? json_show(0, '获取成功', $idinfo) : json_show(1002, '未找到数据');
    }

    //启禁用
    public function status()
    {
        $id = isset($this->post['id']) && $this->post['id'] !== '' ? intval($this->post['id']) : '';
        if ($id === '') {
            return error_show(1002, '参数id不能为空');
        }
        $stn = Db::name('cat')->where(['id' => $id])->find();
        if (empty($stn)) {
            return error_show(1002, '未找到商品数据');
        }
        $status = isset($this->post['status']) && $this->post['status'] !== '' ? intval($this->post['status']) : '';
        if ($status === '') {
            return error_show(1002, '参数status不能为空');
        }

        if ($stn['level'] == 3) {
            if ($status == 1) {
                $can = made($stn['id']);
                $cat = array_column($can, 'id');
            } else {
                $cat = $stn['id'];
            }
            // return error_show(1002, '所在级别不能启用');
        }
        if ($stn['level'] == 2 || $stn['level'] == 1) {
            if ($status == 1) {
                return error_show(1002, '所在等级不能启用');
            } else {
                $db = Db::name('cat')->where(['pid' => $stn['id'], 'status' => 1, 'is_del' => 0])->count();
                if ($db == 0) {
                    $cat = $stn['id'];
                } else {
                    return error_show(1002, '子级分类未禁用');
                }
            }
        }
        // $pd= $stn['status'];
        $it = [];
        $it['status'] = $status;
        $it['updatetime'] = date('Y-m-d H:i:s');
        $str = Db::name('cat')->where(['id' => $cat, 'is_del' => 0])->save($it);
        if ($str) {

            $catinfo = ['cat_id' => $id, 'status' => $status];
            $this->addPlat($catinfo);
            if (!empty($cat)) {
                $catinfo = ['cat_id' => $cat, 'status' => $status];
                $this->addPlat($catinfo);
            }
            return error_show(0, '状态更新成功');
        } else {
            return error_show(1002, '状态更新失败');
        }
    }

    //删除
    public function delete()
    {
        $id = isset($this->post['id']) && $this->post['id'] !== '' ? intval($this->post['id']) : '';
        $info = Db::name('cat')->where(['is_del' => 0, 'id' => $id])->find();
        if ($info == false) {
            return error_show(1002, '未找到数据');
        }
        $supp = Db::name('cat')->update(['id' => $id, 'is_del' => 1, 'updatetime' => date('Y-m-d H:i:s')]);
        if ($supp) {
            return error_show(0, '删除成功');
        } else {
            return error_show(1002, '删除失败');
        }
    }

    //平台添加分类
    private function addPlat($cat)
    {
        $plat = Db::name('platform')
            ->field('id')
            ->where(['platform_type' => 1, 'is_del' => 0])
            ->select()
            ->toArray();
        if (empty($plat)) return false;

        $date = date('Y-m-d H:i:s');

        $isT = Db::name('cat_plat')
            ->where(['cat_id' => $cat['cat_id'], 'is_del' => 0])
            ->column('id', 'platform_id');

        foreach ($plat as $value) {
            $cat['platform_id'] = $value['id'];
            $cat['addtime'] = $date;
            $cat['updatetime'] = $date;
            if (isset($isT[$cat['platform_id']])) {
                $data = $cat;
                unset($data['cat_id']);
                unset($data['addtime']);
                Db::name('cat_plat')
                    ->where('id', $isT[$cat['platform_id']])
                    ->update($data);
            } else  Db::name('cat_plat')->save($cat);


        }

        return true;

    }
}