mes-server-api/application/api/controller/LargeWasteRewardPunish.php

<?php

namespace app\api\controller;

use app\common\controller\Api;
use think\db;
use think\Request;
use function fast\e;

/**
 * 工序大废品惩奖记录接口
 */
class LargeWasteRewardPunish extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];

    /**
     * 首页
     *
     */
    public function index()
    {
        $this->success('请求成功');
    }

    /**
     * 获取工序大废品惩奖侧边栏
     * @ApiMethod (GET)
     */
    public function getTab()
    {
        //get请求
        if(!$this->request->isGet()){
            $this->error('请求方式错误');
        }
        $rows = db()->table('db_大废品')
            ->field('DISTINCT(LEFT(sys_rq, 7)) AS mouth,LEFT(sys_rq, 10) as date, COUNT(*) as counts')
            ->group('date')
            ->order('UniqId desc')
            ->limit(40)
            ->select();

        $list = [];
        foreach($rows as $key=>$value){
            if (!isset($list[$value['mouth']])){
                $list[$value['mouth']] = [];
            }
            $arr['date'] = str_replace('-', '.', $rows[$key]['date']);
            $arr['counts'] = $rows[$key]['counts'];
            array_push($list[$value['mouth']],$arr);
//            $list[$value['mouth']]['date'] = str_replace('-', '.', $rows[$key]['date']);

        }
        $this->success('成功',$list);
    }

    /**
     * 获取工序大废品惩奖侧边栏根据工单
     * @ApiMethod (GET)
     */
    public function getTabByGd()
    {
        //get请求
        if(!$this->request->isGet()){
            $this->error('请求方式错误');
        }
        $rows = db()->table('db_大废品')
            ->field('sczl_gdbh,rtrim(g.成品名称) as 成品名称')
            ->join('工单_基本资料 g','g.Gd_gdbh=db_大废品.sczl_gdbh','LEFT')
            ->group('sczl_gdbh')
            ->whereTime('db_大废品.sys_rq', '>=', strtotime('-60 days'))
            ->order('sczl_gdbh desc')
            ->select();
        foreach($rows as $key=>$value){
            $data[$key]['label']=$value['sczl_gdbh'].' 【'.$value['成品名称'].'】';
            $data[$key]['sczl_gdbh']=$value['sczl_gdbh'];
        }
        $this->success('成功',$data);
    }
    /**
     * 获取工序大废品惩奖列表
     * @ApiMethod (GET)
     * @param string $date 时间
     */
    public function getList()
    {
        //get请求
        if(!$this->request->isGet()){
            $this->error('请求方式错误');
        }
        $req = $this->request->param();
        $rq = $req['date'];
        $page = 1;
        $limit = 15;
        if (isset($req['page']) && !empty($req['page'])) $page = $req['page'];
        if (isset($req['limit']) && !empty($req['limit'])) $limit = $req['limit'];
        $date = substr($req['date'],0,10);
        $req['date'] = str_replace('.','-',$date);
        $where = [];
        if (isset($req['date']) && !empty($req['date'])){
            if (preg_match('/[\x{4e00}-\x{9fa5}]/u', $rq)>0){
                $where['sys_rq'] = ['LIKE',$req['date'].'%'];
            }else{
                $where['sczl_rq'] = ['LIKE',$req['date'].'%'];
            }

        }else{
            $this->error('参数错误');
        }
        $res = db()->table('db_大废品')
        ->field('sczl_gdbh, LEFT(sczl_rq, 10) as sczl_rq, rtrim(sczl_numDesc) as sczl_numDesc, sczl_ls, sczl_yjno, 
        rtrim(责任部门) as 责任部门,sczl_cl, 
        rtrim(sczl_fplxA) as sczl_fplxA, sczl_fplxB, jl_bzdh, JL_bh1, 
        sczl_jtbh as sczl_bzdh, sczl_bh1, sczl_je1, sczl_bh2, sczl_je2, rtrim(sys_id) as sys_id, sys_rq, UniqId')
        ->where('sczl_gdbh',$req['date'])
        ->order('UniqId desc')
        ->page($page,$limit)
        ->select();
        if($res){
            $rows=$res;
            $total = db()->table('db_大废品')->where('sczl_gdbh',$req['date'])->count();;
        }else{
            $rows = db()->table('db_大废品')
            ->field('sczl_gdbh, LEFT(sczl_rq, 10) as sczl_rq, rtrim(sczl_numDesc) as sczl_numDesc, sczl_ls, sczl_yjno, 
            rtrim(责任部门) as 责任部门, sczl_cl, 
            rtrim(sczl_fplxA) as sczl_fplxA, sczl_fplxB, jl_bzdh, JL_bh1, 
            sczl_jtbh as sczl_bzdh, sczl_bh1, sczl_je1, sczl_bh2, sczl_je2, rtrim(sys_id) as sys_id, sys_rq, UniqId')
            ->where($where)
            ->order('UniqId desc')
            ->page($page,$limit)
            ->select();
            halt($rows);
           $total = db()->table('db_大废品')->where($where)->count();
        }
        $gd = db()->table('工单_印件资料')->column('Yj_Gdbh, yj_yjmc');
        $rs = db()->table('人事_基本资料')->where('员工姓名','<>','通用编号')->column('员工编号, 员工姓名');
        foreach ($rows as $key=>$value) {
            $rows[$key]['yj_yjmc'] = array_key_exists($value['sczl_gdbh'],$gd) ? sprintf("%02d", $value['sczl_yjno']).'-'.trim($gd[$value['sczl_gdbh']]) : '';
            $rows[$key]['JL_bh1'] = array_key_exists($value['JL_bh1'],$rs) ? trim($rs[$value['JL_bh1']]) : '';
            $rows[$key]['sczl_bh1'] = array_key_exists($value['sczl_bh1'],$rs) ? trim($rs[$value['sczl_bh1']]) : '';
            $rows[$key]['sczl_bh2'] = array_key_exists($value['sczl_bh2'],$rs) ? trim($rs[$value['sczl_bh2']]) : '';
            $rows[$key]['sczl_fplxB'] = $value['sczl_fplxB'] == 1 ? '制程废' : '';
            if ($rows[$key]['sczl_bh1'] != '' && $value['sczl_je1'] > 0){
                $rows[$key]['sczl_bh1'] = $rows[$key]['sczl_bh1'].'(-'.$value['sczl_je1'].')';
            }
            if ($rows[$key]['sczl_bh2'] != '' && $value['sczl_je2'] > 0){
                $rows[$key]['sczl_bh2'] = $rows[$key]['sczl_bh2'].'(-'.$value['sczl_je2'].')';
            }
            unset($rows[$key]['sczl_yjno']);
        }

        $data = [
            'total'          => $total,
            'rows'          => $rows,
        ];
        $this->success('成功',$data);
    }

    /**
     * 获取工序大废品惩奖信息
     * @ApiMethod (GET)
     * @param string $UniqId UniqId
     */
    public function getInfo()
    {
        //get请求
        if(!$this->request->isGet()){
            $this->error('请求方式错误');
        }
        $req = $this->request->param();
        if (isset($req['UniqId']) && !empty($req['UniqId'])){
            $UniqId = $req['UniqId'];
        }else{
            $this->error('参数错误');
        }

        $rows = db()->table('db_大废品')->alias('d')
            ->field('sczl_gdbh,rtrim(g.Gd_cpmc) as Gd_cpmc,sczl_yjno,rtrim(yj.yj_yjmc) as yj_yjmc,
            rtrim(sczl_gxmc) as sczl_gxmc,sczl_gxh,rtrim(sczl_numDesc) as sczl_numDesc,LEFT(sczl_rq, 10)
            as sczl_rq,sczl_cl,sczl_ls,rtrim(sczl_fplxA) as sczl_fplxA,sczl_fplxB,rtrim(责任部门) as 责任部门,
            rtrim(jl_bzdh) as Jl_bzdh,jl_jtbh,JL_bh1,JL_bh2,JL_bh3,JL_bh4,JL_bh5,JL_bh6,JL_bh7,JL_bh8,JL_bh9,
            rtrim(jl1.员工姓名) as jlname1,rtrim(jl2.员工姓名) as jlname2,rtrim(jl3.员工姓名) as jlname3
            ,rtrim(jl4.员工姓名) as jlname4,rtrim(jl5.员工姓名) as jlname5,rtrim(jl6.员工姓名) as jlname6
            ,rtrim(jl7.员工姓名) as jlname7,rtrim(jl8.员工姓名) as jlname8,rtrim(jl9.员工姓名) as jlname9
            ,JL_Je1,JL_Je2,JL_Je3,JL_Je4,JL_Je5,JL_Je6,JL_Je7,JL_Je8,JL_Je9,rtrim(sczl_bzdh) as sczl_bzdh,
            sczl_jtbh,sczl_bh1,sczl_bh2,sczl_bh3,sczl_bh4,sczl_bh5,sczl_bh6,sczl_bh7,sczl_bh8,sczl_bh9,
            rtrim(jl_bzdh) as Jl_bzdh,jl_jtbh,JL_bh1,JL_bh2,JL_bh3,JL_bh4,JL_bh5,JL_bh6,JL_bh7,JL_bh8,JL_bh9,
            rtrim(zr1.员工姓名) as zrname1,rtrim(zr2.员工姓名) as zrname2,rtrim(zr3.员工姓名) as zrname3
            ,rtrim(zr4.员工姓名) as zrname4,rtrim(zr5.员工姓名) as zrname5,rtrim(zr6.员工姓名) as zrname6
            ,rtrim(zr7.员工姓名) as zrname7,rtrim(zr8.员工姓名) as zrname8,rtrim(zr9.员工姓名) as zrname9
            ,sczl_je1,sczl_je2,sczl_je3,sczl_je4,sczl_je5,sczl_je6,sczl_je7,sczl_je8,sczl_je9')
           ->join('工单_基本资料 g','g.Gd_gdbh=db_大废品.sczl_gdbh')
           ->join('工单_印件资料 yj','yj.Yj_Gdbh=db_大废品.sczl_gdbh','LEFT')
           ->join('人事_基本资料 jl1','jl1.员工编号=db_大废品.JL_bh1','LEFT')
           ->join('人事_基本资料 jl2','jl2.员工编号=db_大废品.JL_bh2','LEFT')
           ->join('人事_基本资料 jl3','jl3.员工编号=db_大废品.JL_bh3','LEFT')
           ->join('人事_基本资料 jl4','jl4.员工编号=db_大废品.JL_bh4','LEFT')
           ->join('人事_基本资料 jl5','jl5.员工编号=db_大废品.JL_bh5','LEFT')
           ->join('人事_基本资料 jl6','jl6.员工编号=db_大废品.JL_bh6','LEFT')
           ->join('人事_基本资料 jl7','jl7.员工编号=db_大废品.JL_bh7','LEFT')
           ->join('人事_基本资料 jl8','jl8.员工编号=db_大废品.JL_bh8','LEFT')
           ->join('人事_基本资料 jl9','jl9.员工编号=db_大废品.JL_bh9','LEFT')
           ->join('人事_基本资料 zr1','zr1.员工编号=db_大废品.sczl_bh1','LEFT')
           ->join('人事_基本资料 zr2','zr2.员工编号=db_大废品.sczl_bh2','LEFT')
           ->join('人事_基本资料 zr3','zr3.员工编号=db_大废品.sczl_bh3','LEFT')
           ->join('人事_基本资料 zr4','zr4.员工编号=db_大废品.sczl_bh4','LEFT')
           ->join('人事_基本资料 zr5','zr5.员工编号=db_大废品.sczl_bh5','LEFT')
           ->join('人事_基本资料 zr6','zr6.员工编号=db_大废品.sczl_bh6','LEFT')
           ->join('人事_基本资料 zr7','zr7.员工编号=db_大废品.sczl_bh7','LEFT')
           ->join('人事_基本资料 zr8','zr8.员工编号=db_大废品.sczl_bh8','LEFT')
           ->join('人事_基本资料 zr9','zr9.员工编号=db_大废品.sczl_bh9','LEFT')
            ->where('d.UniqId',$UniqId)->limit(1)->select();

        $this->success('成功',$rows);
    }

    /**
     * 工单编号获取
     * @return void
     * @throws \think\exception\DbException
     * @throws db\exception\DataNotFoundException
     * @throws db\exception\ModelNotFoundException
     */
    public function JunkWorkOrderList()
    {
        if ($this->request->isGet() === false){
            $this->error('非法请求');
        }
        $params = $this->request->param();
        if (empty($params['search'])){
            $this->error('参数错误');
        }
        $list = \db('工单_基本资料')
            ->field('rtrim(Gd_gdbh) as 工单编号,rtrim(成品名称) as 产品名称')
            ->where('Gd_gdbh','like','%'.$params['search'].'%')
            ->select();
        if (empty($list)){
            $this->success('未找到工单信息');
        }
        $this->success('成功',$list);
    }

    /**
     * 印件编号获取
     * @return void
     * @throws \think\exception\DbException
     * @throws db\exception\DataNotFoundException
     * @throws db\exception\ModelNotFoundException
     */
    public function PrintCodeList()
    {
        if ($this->request->isGet() === false){
            $this->error('非法请求');
        }
        $param = $this->request->param();
        if (empty($param['workorder'])){
            $this->error('参数错误');
        }
        $list = \db('工单_印件资料')
            ->field('rtrim(yj_Yjno) as 印件号,rtrim(yj_yjmc) as 印件名称')
            ->where('Yj_Gdbh',$param['workorder'])
            ->select();
        if (empty($list)){
            $this->success('未找到该工单印件');
        }
        $this->success('成功',$list);
    }

    /**
     * 工单工序获取
     * @return void
     * @throws \think\exception\DbException
     * @throws db\exception\DataNotFoundException
     * @throws db\exception\ModelNotFoundException
     */
    public function ProcessList()
    {
        if ($this->request->isGet() === false){
            $this->error('非法请求');
        }
        $param = $this->request->param();
        if (empty($param['workorder']) || empty($param['yjno'])){
            $this->error('参数错误');
        }
        $list = \db('工单_工艺资料')
            ->field('rtrim(Gy0_gxh) as gxh,rtrim(Gy0_gxmc) as gxmc')
            ->where('Gy0_gdbh',$param['workorder'])
            ->where('Gy0_yjno',$param['yjno'])
            ->select();
        if (empty($list)){
            $this->success('未找到该工单工艺');
        }
        $data = [];
        foreach ($list as $key=>$value){
            if ((int)$value['gxh'] < 10){
                $value['gxh'] = '0'.$value['gxh'];
            }
            $data[$key] = $value['gxh'].'-'.$value['gxmc'];
        }
        $this->success('成功',$data);
    }

    /**
     * 机台编号获取
     * @return void
     * @throws \think\exception\DbException
     * @throws db\exception\DataNotFoundException
     * @throws db\exception\ModelNotFoundException
     */
    public function MachineList()
    {
        if ($this->request->isGet() === false){
            $this->error('非法请求');
        }
        $param = $this->request->param();
        $list = \db('设备_产量计酬')
            ->alias('a')
            ->join('人事_基本资料 b1','a.sczl_bh1 = b1.员工编号','left')
            ->join('人事_基本资料 b2','a.sczl_bh2 = b2.员工编号','left')
            ->join('人事_基本资料 b3','a.sczl_bh3 = b3.员工编号','left')
            ->join('人事_基本资料 b4','a.sczl_bh4 = b4.员工编号','left')
            ->join('人事_基本资料 b5','a.sczl_bh5 = b5.员工编号','left')
            ->join('人事_基本资料 b6','a.sczl_bh6 = b6.员工编号','left')
            ->join('人事_基本资料 b7','a.sczl_bh7 = b7.员工编号','left')
            ->join('人事_基本资料 b8','a.sczl_bh8 = b8.员工编号','left')
            ->join('人事_基本资料 b9','a.sczl_bh9 = b9.员工编号','left')
            ->join('人事_基本资料 b10','a.sczl_bh10 = b10.员工编号','left')
            ->field('a.sczl_gxmc as 工序名称,a.sczl_jtbh as 机台编号,a.sczl_bh1 as 员工编号1,rtrim(b1.员工姓名) as 员工姓名1
            ,a.sczl_bh2 as 员工编号2,rtrim(b2.员工姓名) as 员工姓名2,a.sczl_bh3 as 员工编号3,rtrim(b3.员工姓名) as 员工姓名3
            ,a.sczl_bh4 as 员工编号4,rtrim(b4.员工姓名) as 员工姓名4,a.sczl_bh5 as 员工编号5,rtrim(b5.员工姓名) as 员工姓名5
            ,a.sczl_bh6 as 员工编号6,rtrim(b6.员工姓名) as 员工姓名6,a.sczl_bh7 as 员工编号7,rtrim(b7.员工姓名) as 员工姓名7
            ,a.sczl_bh8 as 员工编号8,rtrim(b8.员工姓名) as 员工姓名8,a.sczl_bh9 as 员工编号9,rtrim(b9.员工姓名) as 员工姓名9
            ,a.sczl_bh10 as 员工编号10,rtrim(b10.员工姓名) as 员工姓名10')
            ->where('a.sczl_gdbh',$param['gdbh'])
            ->where('a.sczl_yjno',$param['yjno'])
            ->where('a.sczl_bzdh','like',substr($param['bzdh'],0,1).'%')
            ->group('机台编号,员工编号1,员工编号2,员工编号3,员工编号4,员工编号5,员工编号6,员工编号7,员工编号8,员工编号9,员工编号10')
            ->select();
//        $list = \db('设备_基本资料')
//            ->field('rtrim(设备编号) as 设备编号')
//            ->where('sys_sbID','<>','')
//            ->select();
        if (empty($list)){
            $this->success('未找到机台编号');
        }
        $this->success('成功',$list);
    }

    /**
     * 机台班组获取
     * @return void
     * @throws \think\exception\DbException
     * @throws db\exception\DataNotFoundException
     * @throws db\exception\ModelNotFoundException
     */
    public function MachineClassList()
    {
        if ($this->request->isGet() === false){
            $this->error('非法请求');
        }
        $param = $this->request->param();
        if (empty($param['machine'])){
            $this->error('参数错误');
        }
        $list = \db('设备_班组资料')
            ->where('sczl_jtbh',$param['machine'])
            ->field('rtrim(sczl_bh1) as bh1,rtrim(sczl_bh2) as bh2,rtrim(sczl_bh3) as bh3,
            rtrim(sczl_bh4) as bh4,rtrim(sczl_bh5) as bh5,rtrim(sczl_bh6) as bh6,
            rtrim(sczl_bh7) as bh7,rtrim(sczl_bh8) as bh8,rtrim(sczl_bh9) as bh9,
            rtrim(sczl_bh10) as bh10,rtrim(sczl_bzdh) as 班组代号')
            ->select();
        if (empty($list)){
            $this->success('未找到该机台班组');
        }
        foreach ($list as $key=>$value){
            for ($i=1;$i<=10;$i++){
                if (!empty($value['bh'.$i])){
                    $name = \db('人事_基本资料')->where('员工编号',$value['bh'.$i])->field('rtrim(员工姓名) as name')->find();
                    if (isset($name['name'])){
                        $list[$key]['组员'.$i] = [
                            '编号' => $value['bh'.$i],
                            '姓名' => $name['name']
                        ];
                    }
                }else{
                    $list[$key]['组员'.$i] = [
                        '编号' => '',
                        '姓名' => ''
                    ];
                }
                unset($list[$key]['bh'.$i]);
            }
        }
        $this->success('成功',$list);
    }

    /**
     * 大废品数据修改
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     * @throws db\exception\BindParamException
     */
    public function JunkDetailEdit()
    {
        if (Request::instance()->isPost() === false){
            $this->error('非法请求');
        }
        $param = Request::instance()->post();
        if (empty($param['sczl_gdbh']) || empty($param['UniqId'])){
            $this->error('参数错误');
        }
        $param['mod_rq'] = date('Y-m-d H:i:s',time());
        $data = $param;
        unset($data['UniqId']);
        $sql = \db('db_大废品')
            ->where('UniqId',$param['UniqId'])
            ->fetchSql(true)
            ->update($data);
        $res = \db()->query($sql);
        if ($res !== false){
            $this->success('修改成功');
        }else{
            $this->error('失败');
        }
    }

    /**
     * 大废品数据添加
     * @return void
     * @throws \think\exception\PDOException
     * @throws db\exception\BindParamException
     */
    public function JunkDetailAdd()
    {
        if (Request::instance()->isPost() === false){
            $this->error('非法请求');
        }
        $param = Request::instance()->post();
        if (empty($param['sczl_gdbh'])){
            $this->error('参数错误');
        }
        $lastID = \db('db_大废品')->order('UniqId desc')->value('UniqId');
        $param['sys_rq'] = date('Y-m-d H:i:s',time());
        $param['mod_rq'] = '1900-01-01 00:00:00';
        $param['UniqId'] = $lastID + 1;
        $sql = \db('db_大废品')->fetchSql(true)->insert($param);
        $res = \db()->query($sql);
        if ($res !== false){
            $this->success('添加成功');
        }else{
            $this->error('失败');
        }
    }

    /**
     * 大废品数据删除
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function JunkDetailDel()
    {
        if ($this->request->isGet() === false){
            $this->error('非法请求');
        }
        $param = $this->request->param();
        if (empty($param['UniqId'])){
            $this->error('参数错误');
        }
        $idList = explode(',',$param['UniqId']);
        $res = \db('db_大废品')
            ->whereIn('UniqId',$idList)
            ->delete();
        if ($res !== false){
            $this->success('删除成功');
        }else{
            $this->error('失败');
        }
    }
}