mes-sdai-server-api/application/api/controller/Process.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use \think\Request;
use \think\Db;

/**
 * 工序损耗管理接口
 */
class Process extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];

    /**
     * 首页
     *
     */
    public function index()
    {
        $this->success('请求成功');
    }
    /**
     * 单个工序损耗接口
     * @ApiMethod GET
     * @params string code
    */
    public function getProcessLoss(){
        if (Request::instance()->isGet() == false){
            $this->error('非法请求');
        }
        $params = Request::instance()->param();
        $code = $params['code'];
        if (!isset($code)){
            $this->error('参数不能为空');
        }
        $where['sys_bh'] = $code;
        $field = 'rtrim(sys_bh) as sys_bh,rtrim(sys_mc) as sys_mc,sys_rate0,sys_rate1,rtrim(适用机型) as remark';
        $data = Db::name('dic_lzsh')->where($where)->field($field)->select();
        $this->success('请求成功',$data);
    }
    /**
     * 获取工序损耗列表接口
     * @ApiParams GET
    */
    public function getProcess(){
        if (Request::instance()->isGet() == false){
            $this->error('非法请求');
        }
        $field = 'Key_,Parent,rtrim(sys_bh) as sys_bh,rtrim(sys_mc) as sys_mc';
        $list = Db::name('dic_lzsh')->field($field)->select();
        $data = [];
        $i = 0;
        foreach ($list as $value){
            if ($value['Parent'] == '0_'){
                $data[$i] = $value;
                //一级菜单
                $data[$i]['child'] = Db::name('dic_lzsh')->where('Parent',$value['Key_'])->field($field)->select();
                foreach ($data[$i]['child'] as $k=>$v){
                    $children = Db::name('dic_lzsh')->where('Parent',$v['Key_'])->field($field)->select();
                    //二级菜单
                    $data[$i]['child'][$k]['children'] =  $children;
                    if (!empty($children)){
                        foreach ($children as $key=>$item){
                            $childrens = Db::name('dic_lzsh')->where('Parent',$item['Key_'])->field($field)->select();
                            //三级菜单
                            $data[$i]['child'][$k]['children'][$key]['childrens'] =  $childrens;
                            if (!empty($childrens)){
                                foreach ($childrens as $k1=>$v1){
                                    $fiveChild = Db::name('dic_lzsh')->where('Parent',$v1['Key_'])->field($field)->select();
                                    $data[$i]['child'][$k]['children'][$key]['childrens'][$k1]['fiveChild'] =  $fiveChild;
                                }
                            }else{
                                $data[$i]['child'][$k]['children'][$key]['childrens'] = [];
                            }
                        }
                    }else{
                        $data[$i]['child'][$k]['children']= [];
                    }
                }
                $i++;
            }
        }
        $this->success('请求成功',$data);
    }
    /**
     * 获取工序损耗编码
     * @ApiMethod GET
     * @params string code
     * @params string same_item
     * @params string child_item
    */
    public function getProcessCode(){
        if (Request::instance()->isGet() == false){
            $this->error('非法请求');
        }
        $params = Request::instance()->param();
        if (!isset($params['code']) || !isset($params['same_item']) || !isset($params['child_item'])){
            $this->error('参数错误');
        }
        $code = $params['code'];
        if (empty($code)){//科目编码为空,表示需要增加一级科目
           $res = Db::name('dic_lzsh')->where('Parent','0_')->field('rtrim(sys_bh) as sys_bh')->order('UniqId desc')->find();
           $num = (int)$res['sys_bh'] + 1;
           $new_code = $num > 10 ? '0'.$num : '00'.$num;
           $this->success('请求成功',$new_code);
        }else{
            if (($params['same_item'] == 0 && $params['child_item'] == 0) || ($params['same_item'] == 1 && $params['child_item'] == 1) ){
                $this->error('参数错误');
            }
            $res = Db::name('dic_lzsh')->where('sys_bh',$code)->find();
            if ($params['same_item'] == 1){ //表示增加同级科目
                $list = Db::name('dic_lzsh')->where('Parent',$res['Parent'])->field('rtrim(sys_bh) as sys_bh')->order('UniqId desc')->find();
                $num = (int)$list['sys_bh'] + 1;
                $num = substr($num,-3);
                $str = substr($code,0,-3);
                $new_code = $str . $num;
                halt($new_code);
            }else{
                $list = Db::name('dic_lzsh')->where('Parent',$res['Key_'])->field('rtrim(sys_bh) as sys_bh')->order('UniqId desc')->find();
                if (!empty($list)){
                    $num = (int)$list['sys_bh'] + 1;
                    $num = substr($num,-3);
                    $new_code = $code . $num;
                }else{
                    $num = '001';
                    $new_code = $code . $num;
                }
            }
            $this->success('请求成功',$new_code);
        }
    }
    /**
     * 增加左侧科目
     * @ApiMethod POST
     * @params string code
     * @params string name
     * @params float  sys_rate0
     * @params float  sys_rate1
     * @params string  remark
    */
    public function add(){
        if (Request::instance()->isPost() == false){
            $this->error('非法请求');
        }
        $params = Request::instance()->post();
        if (empty($params) || !isset($params['code']) || !isset($params['name'])){
            $this->error('参数不能为空');
        }
        $parentCode = $str = substr($params['code'],0,-3);
        $list = Db::name('dic_lzsh')->where('sys_bh',$parentCode)->field('Key_')->find();
        $data = [];
        $data['sys_bh'] = $params['code'];
        $data['Parent'] = $list['Key_'];
        $data['sys_mc'] = $params['name'];
        $data['sys_rate0'] = $params['sys_rate0'];
        $data['sys_rate1'] = $params['sys_rate1'];
        if (!empty($params['remark'])){
            $data['适用机型'] = $params['remark'];
        }
        $sql = Db::name('dic_lzsh')->fetchSql(true)->insert($data);
        $res = Db::query($sql);
        if ($res !== false){
            $this->success('新增成功');
        }else{
            $this->error('新增失败');
        }
    }
    /**
     * 修改左侧科目
     * @params string code
     * @params string name
     * @params float  sys_rate0
     * @params float  sys_rate1
     * @params string  remark
    */
    public function edit(){
        if (Request::instance()->isPost() == false){
            $this->error('非法请求');
        }
        $params = Request::instance()->post();
        if (empty($params) || !isset($params['code']) || !isset($params['name'])){
            $this->error('参数不能为空');
        }
        $data = [];
        $data['sys_mc'] = $params['name'];
        $data['sys_rate0'] = $params['sys_rate0'];
        $data['sys_rate1'] = $params['sys_rate1'];

        if (!empty($params['remark'])){
            $data['适用机型'] = $params['remark'];
        }
        $sql = Db::name('dic_lzsh')->where('sys_bh',$params['code'])->fetchSql(true)->update($data);
        $res = Db::query($sql);
        if ($res !== false){
            $this->success('更新成功');
        }else{
            $this->error('更新失败');
        }
    }
    /**
     * 删除
     * @ApiMethod POST
     * @params string code
    */
    public function delete(){
        if (Request::instance()->isPost() == false){
            $this->error('非法请求');
        }
        $params = Request::instance()->post();
        if (empty($params) || !isset($params['code'])){
            $this->error('参数不能为空');
        }
        $res = Db::name('dic_lzsh')->where('sys_bh',$params['code'])->delete();
        if ($res !== false){
            $this->success('删除成功');
        }else{
            $this->error('删除失败');
        }
    }
}