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

<?php

namespace app\api\controller;


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

class GluingReport extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];


    /**
     * 设备角色菜单
     * @return void
     */
    public function getGluingcoleTab()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $data = [];
        $sist = ['印后糊盒车间','精品自动化车间','数字化车间'];
        $department = \db('设备_基本资料')
            ->distinct(true)
            ->where('使用部门','in',$sist)
            ->where('设备编组','<>','')
            ->where('sys_sbID','<>','')
            ->order('设备编组')
            ->column('rtrim(使用部门) as 使用部门');
        if (empty($department)){
            $this->success('为获取到机台数据');
        }
        foreach ($department as $value){
            $machine = \db('设备_基本资料')->where('使用部门',$value)->where('sys_sbID','<>','')->where('使用部门',$value)->field('rtrim(设备编号) as 设备编号,rtrim(设备名称) as 设备名称')->order('设备编号')->select();
            foreach ($machine as $k=>$v){
                $data[rtrim($value)][] = $v['设备编号'].'-->'.$v['设备名称'];
            }
        }
        $this->success('成功',$data);
    }


    /**
     * 设备角色列表
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getGluingcoleList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $list = db('设备_糊盒班组角色')
            ->where('jtbh',$param['machine'])
            ->select();
        if (empty($list)){
            $this->error('未找到数据');
        }else{
            $this->success('成功',$list);
        }
    }

    /**
     * 设备角色资料详情
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getGluingcoleDetail()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $list = db('设备_糊盒班组角色')
            ->where('id',$param['id'])
            ->find();
        if (empty($list)){
            $this->error('未找到数据详情');
        }else{
            $this->success('成功',$list);
        }
    }

    /**
     * 新增机台班组角色
     * @return void
     */
    public function saveGluingcoleDetail(){
        if ($this->request->isPost() === false){
            $this->error('请求错误');
        }
        $param = Request::instance()->post();
        if (empty($param)){
            $this->error('参数错误');
        }
        $param['sys_rq'] = date('Y-m-d H:i:s',time());
        $res = db('设备_糊盒班组角色')->insert($param);
        if (empty($res)){
            $this->error('新增失败');
        }else{
            $this->success('新增成功');
        }
    }

    /**
     * 修改设备角色资料
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function getGluingcoleDetaiEdit()
    {
        if ($this->request->isPost() === false){
            $this->error('请求错误');
        }
        $param = Request::instance()->post();
        if (empty($param['id'])){
            $this->error('参数错误');
        }
        $id = intval($param['id']);
        $param['mod_rq'] = date('Y-m-d H:i:s',time());
        unset($param['id']);
        $res = db('设备_糊盒班组角色')
            ->where('id',$id)
            ->update($param);
        if ($res === false){
            $this->error('修改失败');
        }else{
            $this->success('修改成功');
        }
    }


    /**
     * 设备当前班组角色
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function UpdateGluingcoleStatus()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param['id']) || empty($param['jtbh'])){
            $this->error('参数错误');
        }
        $updateRes = db('设备_糊盒班组角色')
            ->where('jtbh',$param['jtbh'])
            ->update(['status' => 0]);
        $res = db('设备_糊盒班组角色')
            ->where('id',$param['id'])
            ->update(['status' => 1]);
        if ($updateRes === false || $res === false){
            $this->error('更新失败');
        }else{
            $this->success('更新成功');
        }
    }

    /**
     * 设备班组资料列表
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getGluingClassLList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $list = db('设备_糊盒班组资料')
            ->where('jtbh',$param['machine'])
            ->select();
        foreach ($list as $k=>$v){
            for ($i = 1; $i <= 15; $i++){
                $bh = $v['bh'.$i];
                $list[$k]['name'.$i] = '';
                if (!empty($bh) && $bh !== ''){
                    $name = \db('人事_基本资料')
                        ->where('员工编号',$bh)
                        ->value('员工姓名');
                    $list[$k]['name'.$i] = $name;
                }
            }
        }
        if (empty($list)){
            $this->error('未找到数据');
        }else{
            $this->success('成功',$list);
        }
    }


    /**
     * 获取设备角色数据
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getGluingcole()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $list = db('设备_糊盒班组角色')
            ->where('jtbh',$param['machine'])
            ->where('status',1)
            ->find();
        if (empty($list)){
            $this->error('未找到角色资料');
        }else{
            $this->success('成功',$list);
        }
    }

    /**
     * 新增糊盒机台班组资料
     * @return void
     */
    public function AddGluingClass()
    {
        if ($this->request->isPost() === false){
            $this->error('请求错误');
        }
        $param = Request::instance()->post();
        if (empty($param)){
            $this->error('参数错误');
        }
        $param['sys_rq'] = date('Y-m-d H:i:s',time());
        $res = db('设备_糊盒班组资料')->insert($param);
        if ($res === false){
            $this->error('新增失败');
        }else{
            $this->success('新增成功');
        }
    }


    /**
     * 修改设备糊盒班组资料
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function UpdateGluingClass()
    {
        if ($this->request->isPost() === false){
            $this->error('请求错误');
        }
        $param = Request::instance()->post();
        if (empty($param['id'])){
            $this->error('参数错误');
        }
        $id = intval($param['id']);
        $param['mod_rq'] = date('Y-m-d H:i:s',time());
        unset($param['id']);
        $res = db('设备_糊盒班组资料')
            ->where('id',$id)
            ->update($param);
        if ($res === false){
            $this->error('修改失败');
        }else{
            $this->success('修改成功');
        }
    }


    /**
     * 糊盒机台报工
     * @return void
     * @throws \think\db\exception\BindParamException
     * @throws \think\exception\PDOException
     */
    public function AddGluingReportData()
    {
        if ($this->request->isPost() === false){
            $this->error('请求错误');
        }
        $param = Request::instance()->post();
        if (empty($param)){
            $this->error('参数错误');
        }
        $param['sys_rq'] = date('Y-m-d H:i:s',time());
        $Sql = db('设备_糊盒报工资料')->fetchSql(true)->insert($param);
        $res = db()->query($Sql);
        if ($res === false){
            $this->error('报工失败');
        }else{
            $this->success('报工成功');
        }
    }


    /**
     * 糊盒机台报工数据菜单
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getTab()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $data = [];
        $date = date('Y-m-d 00:00:00',time()-3888000);
        $sist = ['印后糊盒车间','精品自动化车间','数字化车间'];
        $department = \db('设备_基本资料')
            ->distinct(true)
            ->where('使用部门','in',$sist)
            ->where('设备编组','<>','')
            ->where('sys_sbID','<>','')
            ->order('设备编组')
            ->column('rtrim(使用部门) as 使用部门');
        if (empty($department)){
            $this->success('未获取到机台数据');
        }
        $list = \db('设备_糊盒报工资料')
            ->field([
                'DISTINCT(sczl_rq)' => '时间',
                'rtrim(sczl_jtbh)' => '机台编号'
            ])
            ->where('sczl_rq','>',$date)
            ->order('sczl_rq desc')
            ->select();

        foreach ($department as $value){
            $machine = \db('设备_基本资料')->where('使用部门',$value)->where('sys_sbID','<>','')->where('使用部门',$value)->field('rtrim(设备编号) as 设备编号,rtrim(设备名称) as 设备名称')->order('设备编号')->select();
            foreach ($machine as $k=>$v){
                $data[rtrim($value)][$v['设备编号'].'-->'.$v['设备名称']] = [];
                foreach ($list as $kk=>$vv){
                    if ($v['设备编号'] === $vv['机台编号']){
                        array_push($data[rtrim($value)][$v['设备编号'].'-->'.$v['设备名称']],date('Y-m-d',strtotime($vv['时间'])));
                    }
                }
            }
        }
        $this->success('成功',$data);
    }


    /**
     * 获取当前生产工单
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function GetProduction()
    {
        if (Request::instance()->isGet() == false) {
            $this->error('非法请求');
        }
        $params = Request::instance()->param();
        if (!isset($params['machine']) || empty($params['machine'])) {
            $this->error('参数错误');
        }
        $machine = $params['machine'];
        $machineCode = \db('dic_lzde')->where('适用机型',$machine)->value('sys_bh');
        $data = \db('设备_糊盒报工采集')->where('sczl_jtbh',$machine)->order('UID desc')->find();
        if (empty($data)){
            $this->success('未找到数据');
        }
        $list = [];
        $list['班组ID'] = $data['班组ID'];
        $row = [];
        if (!empty($data['sczl_gdbh'])){
            $endTime = \db('工单_工艺资料')
                ->where('Gy0_gdbh',$data['sczl_gdbh'])
                ->where('Gy0_yjno',$data['sczl_yjno'])
                ->where('Gy0_gxh',$data['sczl_gxh'])
                ->find();
            $list['工单编号'] = $data['sczl_gdbh'];
            if (!empty($endTime)){
                $list['印件号'] = $data['sczl_yjno'];
                $name = \db('工单_基本资料')->where('Gd_Gdbh',$data['sczl_gdbh'])->value('成品名称');
                $code = \db('工单_基本资料')->where('Gd_Gdbh',$data['sczl_gdbh'])->value('成品代号');
                $list['产品名称'] = rtrim($name);
                $list['产品代号'] = rtrim($code);
                $list['工序名称'] = $data['sczl_gxmc'];
            }
            $list['状态'] = rtrim($data['status']);
            $list['开工时间'] = $data['sczl_kgsj'];
        }else{
            $list['工单编号'] = '';
            $list['印件号'] = 0;
            $list['产品名称'] = '';
            $list['工序名称'] = '';
            $list['产品代号'] = '';
            $list['状态'] = '';
            $list['开工时间'] = '';
        }
        $list['班组编号'] = rtrim($data['sczl_bzbh']);
        $idList = explode(',',$data['班组ID']);
        foreach ($idList as $k=>$v){
            $class = \db('设备_糊盒班组资料')
                ->where('id',$v)
                ->field("role,rate,bh1,bh2,bh3,bh4,bh5,bh6,bh7,bh8,bh9,bh10,bh11,bh12,bh13,bh14,bh15")
                ->find();
            if (!empty($class)){
                for ($i=1;$i<16;$i++) {
                    if ($class['bh' . $i] != '' && $class['bh' . $i] != '000000') {
                        $name = \db('人事_基本资料')->where('员工编号', $class['bh' . $i])->field('rtrim(员工姓名) as 姓名')->find();
                        $row[] = [
                            '编号' => $class['bh' . $i],
                            '姓名' => $name['姓名'],
                            '比例' => $class['rate'],
                            '角色' => $class['role'],
                        ];
                    }
                }
                $row = array_values($row);
            }
        }


        $list['班组成员'] = $row;
        $list['定额代号'] = $machineCode;
        $this->success('成功',$list);
    }

    /**
     * 设置当前工单和当前班组
     * @return void
     */
    public function setMachineTeam()
    {
        if (Request::instance()->isPost() == false) {
            $this->error('非法请求');
        }
        $params = Request::instance()->post();
        if (!isset($params['machine']) || empty($params['machine'] )) {
            $this->error('参数不能为空');
        }
        if (empty($params['team_id']) || empty($params['sczl_bzdh'])){
            $this->error('请先选择班组成员');
        }
        $machine = $params['machine'] . '#';
        $data = [];
        $data['status'] = $params['status'];
        $data['sczl_sj'] = date('Y-m-d H:i:s');
        $data['sczl_jtbh'] = $machine;
        $data['sczl_gdbh'] = empty($params['order']) ? '':$params['order'];
        $data['sczl_yjno'] = empty($params['yjno']) ? '':$params['yjno'];
        $data['sczl_gxh'] = empty($params['gy_name']) ? '' : (int)substr($params['gy_name'], 0, 2);
        $data['sczl_gxmc'] = empty($params['gy_name']) ? '' : $params['gy_name'];
        $data['sczl_bzbh'] = $params['sczl_bzdh'];
        $data['班组ID'] = $params['team_id'];

        // 获取当前时间
        $current_time = time();
        // 设置时间范围
        $start_time1 = strtotime(date('Y-m-d') . ' 08:30:00');
        $end_time1 = strtotime(date('Y-m-d') . ' 20:30:00');
        $end_time2 = strtotime(date('Y-m-d') . ' 24:00:00');
        $start_time3 = strtotime(date('Y-m-d', strtotime('+1 day')) . ' 08:30:00');
        $start_time4 = strtotime(date('Y-m-d', strtotime('+1 day')) . ' 00:00:00');
        // 判断当前时间属于哪个时间范围
        if ($current_time >= $start_time1 && $current_time <= $end_time1) {
            $data['sczl_kgsj'] = date('Y-m-d') . ' 08:30:00';
        } elseif ($current_time > $end_time1 && $current_time <= $end_time2) {
            $data['sczl_kgsj'] = date('Y-m-d') . ' 20:30:00';

        } elseif ($current_time > $end_time1 && $current_time <= $start_time3) {
            $data['sczl_kgsj'] = date('Y-m-d', strtotime('+1 day')) . ' 08:30:00';
        }elseif ($current_time > $start_time4 && $current_time <= $start_time3){
            $data['sczl_kgsj'] = date('Y-m-d') . ' 20:30:00';
        }
        if (!empty($params['order']) && !empty($params['yjno'])){
            $option['Gy0_gdbh'] = $params['order'];
            $option['Gy0_yjno'] = $params['yjno'];
            $option['Gy0_gxh'] = $data['sczl_gxh'];
            $data['任务ID'] = \db('工单_工艺资料')->where($option)->value('UniqId');
        }else{
            $data['任务ID'] = '';
        }
        $sql = \db('设备_糊盒报工采集')->fetchSql(true)->insert($data);
        $res = Db::query($sql);
        if ($res === false) {
            $this->error('设置失败');
        } else {
            $this->success('设置成功');
        }
    }

    /**
     * 糊盒设备运行跟踪数据页面显示
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getGluingReportDataList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $params = $this->request->param();
        if (empty($params['machine']) || empty($params['day'])){
            $this->error('参数错误');
        }
        $where = [
            'a.sczl_jtbh' => $params['machine'],
            'a.sczl_rq' => ['like',$params['day'].'%']
        ];
        $field = ['a.sczl_gdbh as 工单编号','a.sczl_yjno as 印件号','a.sczl_gxh as 工序号','a.sczl_gxmc as 工序名称','a.来料数量','a.sczl_cl as 产量',
            'a.sczl_zcfp as 制程废品','a.startTime as 开始时间','a.endTime as 结束时间','a.sczl_ls as 联数','a.sczl_rq as 日期',
            'a.sczl_dedh as 定额代号','a.工价系数','a.保养工时','a.装版工时','a.异常工时','a.异常类型','a.设备运行工时','a.role',
            'a.sys_id as 创建人员','a.sys_rq as 上报时间','a.mod_rq as 修改时间','a.Uid','a.sczl_jtbh as 机台编号',
            'b.yj_Yjdh as 产品代号','yj_yjmc as 产品名称'];
        $list = \db('设备_糊盒报工资料')
            ->alias('a')
            ->join('工单_印件资料 b','a.sczl_gdbh = b.Yj_Gdbh and a.sczl_yjno = b.yj_Yjno','left')
            ->field($field)
            ->where($where)
            ->group('a.Uid')
            ->select();
        if (empty($list)){
            $this->error('未找到报工数据');
        }
        foreach ($list as $key=>$value){
            $list[$key]['class'] = [];
            $idList = explode(',',$value['role']);
            foreach ($idList as $item){
                $class = \db('设备_糊盒班组资料')
                    ->where('id',$item)
                    ->field("role,rate,bh1,bh2,bh3,bh4,bh5,bh6,bh7,bh8,bh9,bh10,bh11,bh12,bh13,bh14,bh15")
                    ->find();
                if (!empty($class)){
                    for ($i=1;$i<16;$i++) {
                        if ($class['bh' . $i] != '' && $class['bh' . $i] != '000000') {
                            $name = \db('人事_基本资料')->where('员工编号', $class['bh' . $i])->field('rtrim(员工姓名) as 姓名')->find();
                            $list[$key]['class'][] = [
                                '编号' => $class['bh' . $i],
                                '姓名' => $name['姓名'],
                                '比例' => $class['rate'],
                                '角色' => $class['role'],
                            ];
                        }
                    }
                    $list[$key]['class'] = array_values($list[$key]['class']);
                }
            }
            unset($list[$key]['role']);
        }

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


    /**
     * 报工数据详情显示
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */

    public function getGluingReportDataDetail()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $params = $this->request->param();
        if(!isset($params['id']) || empty($params['id'])){
            $this->error('参数错误');
        }
        $where = ['Uid'=>$params['id']];
        $field = ['a.sczl_gdbh as 工单编号','a.sczl_yjno as 印件号','a.sczl_gxh as 工序号','a.sczl_gxmc as 工序名称','a.来料数量','a.sczl_cl as 产量',
            'a.sczl_zcfp as 制程废品','a.startTime as 开始时间','a.endTime as 结束时间','a.sczl_ls as 联数','a.sczl_rq as 日期',
            'a.sczl_dedh as 定额代号','a.工价系数','a.保养工时','a.装版工时','a.异常工时','a.异常类型','a.设备运行工时','a.role',
            'a.sys_id as 创建人员','a.sys_rq as 上报时间','a.mod_rq as 修改时间','a.Uid','a.sczl_jtbh as 机台编号',
            'b.yj_Yjdh as 产品代号','yj_yjmc as 产品名称'];
        $list = \db('设备_糊盒报工资料')
            ->alias('a')
            ->join('工单_印件资料 b','a.sczl_gdbh = b.Yj_Gdbh and a.sczl_yjno = b.yj_Yjno','left')
            ->where($where)
            ->field($field)
            ->find();

        $list['class'] = [];
        $idList = explode(',',$list['role']);
        foreach ($idList as $item){
            $class = \db('设备_糊盒班组资料')
                ->where('id',$item)
                ->field("role,rate,bh1,bh2,bh3,bh4,bh5,bh6,bh7,bh8,bh9,bh10,bh11,bh12,bh13,bh14,bh15")
                ->find();
            if (!empty($class)){
                for ($i=1;$i<16;$i++) {
                    if ($class['bh' . $i] != '' && $class['bh' . $i] != '000000') {
                        $name = \db('人事_基本资料')->where('员工编号', $class['bh' . $i])->field('rtrim(员工姓名) as 姓名')->find();
                        $list['class'][] = [
                            '编号' => $class['bh' . $i],
                            '姓名' => $name['姓名'],
                            '比例' => $class['rate'],
                            '角色' => $class['role'],
                        ];
                    }
                }
                $list['class'] = array_values($list['class']);
            }
        }
        $this->success('成功',$list);
    }


    /**
     * 修改糊盒班组报工资料
     * @return void
     * @throws \think\Exception
     * @throws \think\db\exception\BindParamException
     * @throws \think\exception\PDOException
     */
    public function getGluingReportDetailUpdate()
    {
        if ($this->request->isPost() === false){
            $this->error('请求错误');
        }
        $params =  Request::instance()->post();
        if(!isset($params['id']) || empty($params['id'])){
            $this->error('参数错误');
        }
        $id = $params['id'];
        unset($params['id']);
        $params['mod_rq'] = date('Y-m-d H:i:s',time());
        $sql = \db('设备_糊盒报工资料')
            ->where('Uid',$id)
            ->fetchSql(true)
            ->update($params);
        $res = \db()->query($sql);
        if ($res === false) {
            $this->error('修改成功');
        }else{
            $this->success('修改失败');
        }
    }


    /**
     * 修改报工数据班组
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function UpdateGluingReportClass()
    {
        if ($this->request->isPost() === false){
            $this->error('请求错误');
        }
        $params = Request::instance()->post();
        if(!isset($params['id']) || empty($params['id'])){
            $this->error('参数错误');
        }
        $id = $params['id'];
        $data['role'] = $params['role'];
        $res = \db('设备_糊盒报工资料')->where('Uid',$id)->update($data);
        if ($res === false) {
            $this->error('修改失败');
        }else{
            $this->success('修改成功');
        }
    }
}