mes-dc-server-api/application/api/controller/Manufacture.php

<?php

namespace app\api\controller;


use app\common\controller\Api;
use Monolog\Handler\IFTTTHandler;
use Overtrue\Socialite\Providers\WeWorkProvider;
use think\Db;
use think\Request;
use function fast\e;

/**
 *
 * 生产排单管理
 */
class Manufacture extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];

    /**
     * 计划中工单
     * @ApiMethod （GET）
     * @return \think\response\Json
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function Project()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        if ($param['status'] === '计划中'){
            $status = '3-计划中';
        }else{
            $status = '1-已完工';
        }
        $page = 0;
        $limit = 15;
        if (isset($param['page'])){
            $page = $param['page'];
        }
        if (isset($param['limit'])){
            $limit = $param['limit'];
        }
        $where = [
            'gd_statu' => $status,
            '行号' => '1',
        ];
        if (isset($param['search'])){
            $where['Gd_lx|Gd_gdbh|Gd_客户代号|Gd_客户名称|Gd_khdh|Gd_khmc|Gd_cpdh|Gd_cpmc|成品代号|成品名称|产品版本号'] = ['like','%'.$param['search'].'%'];
        }
        $field = 'rtrim(Gd_生产分类) as 生产分类,rtrim(Gd_gdbh) as 工单编号,rtrim(Gd_cpdh) as 产品代号,rtrim(Gd_cpmc) as 产品名称,rtrim(成品名称) as 成品名称,
        rtrim(接单日期) as 接单日期,rtrim(交货日期) as 交货日期,rtrim(订单数量) as 订单数量,rtrim(计量单位) as 计量单位,rtrim(Gd_khmc) as 客户名称,
        rtrim(Gd_客户代号) as 客户编号,rtrim(Gd_desc) as 备注,rtrim(客户料号) as 客户料号,rtrim(Sys_id) as 创建用户,rtrim(Sys_rq) as 创建时间,
        rtrim(Mod_rq) as 修改时间,rtrim(Uniqid) as UNIQID,rtrim(投料率) as 投料率,rtrim(销售订单号) as 销售订单号';
        $list = \db('工单_基本资料')->where($where)->field($field)->limit(($page-1)*$limit,$limit)->order('Uniqid desc')->select();
        $total = \db('工单_基本资料')->where($where)->count();
        if (empty($list)){
            $this->success('',[]);
        }
        foreach ($list as $key=>$value){
            $list[$key]['订单数量'] = rtrim((float)$value['订单数量']);
            $list[$key]['产品名称'] = $value['产品名称'] != '' ? $value['产品名称']:$value['成品名称'];
            $number = \db('工单_工艺资料')->where('Gy0_gdbh',$value['工单编号'])->count();
            if ($number === 0){
                $list[$key]['status'] = 0;
            }else{
                $list[$key]['status'] = 1;
            }
            unset($list[$key]['成品名称']);
        }
        $this->success('成功',['data'=>$list,'total'=>$total]);
    }

    /**
     * 计划中工单->工艺资料
     * @ApiMethod (GET)
     * @param string $Gd_gdbh   工单编号
     * @return \think\response\Json
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function projectCraft()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $Gd_gdbh = input('Gd_gdbh');
        if (empty($Gd_gdbh)){
            $this->error('参数错误');
        }
        $where = [
            'Gy0_gdbh' => $Gd_gdbh
        ];
        $filed = 'rtrim(Gy0_gdbh) as 工单编号,rtrim(重点工序) as 重点工序,Gy0_yjno,Gy0_gxh,Gy0_gxmc,Add_gxmc,rtrim(工序备注) as 工序备注,
        rtrim(Gy0_sbbh) as 机组,rtrim(Gy0_小时产能) as 小时产能,rtrim(Gy0_生产工时) as 生产工时,rtrim(Gy0_辅助工时) as 辅助工时,
        rtrim(印刷方式) as 印刷方式,rtrim(版距) as 版距,rtrim(Sys_id) as 创建用户,rtrim(Sys_rq) as 创建时间,rtrim(Mod_rq) as 修改时间,rtrim(UniqId) as UNIQID';
        $list = \db('工单_工艺资料')->where($where)->field($filed)->select();
        if (empty($list)){
            $this->success('',[]);
        }
        foreach ($list as $key=>$value){
            if ((int)$value['Gy0_yjno'] <10){
                $value['Gy0_yjno'] = '0'.rtrim($value['Gy0_yjno']);
            }
            if ((int)$value['Gy0_gxh'] <10){
                $value['Gy0_gxh'] = '0'.rtrim($value['Gy0_gxh']);
            }
            if (rtrim($value['Add_gxmc']) == ''){
                $list[$key]['印件工序及名称'] = $value['Gy0_yjno'].'-'.$value['Gy0_gxh'].'-->'.rtrim($value['Gy0_gxmc']);
            }else{
                $list[$key]['印件工序及名称'] = $value['Gy0_yjno'].'-'.$value['Gy0_gxh'].'-->'.rtrim($value['Gy0_gxmc']).'【'.rtrim($value['Add_gxmc']).'】';
            }
            unset($list[$key]['Gy0_gxmc'],$list[$key]['Add_gxmc']);
        }
        $this->success('成功',$list);
    }


    /**
     * 计划中工单->印件资料
     * @ApiMethod (GET)
     * @param string $Gd_gdbh   工单编号
     * @return \think\response\Json
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function projectPrint()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $Gd_gdbh = input('Gd_gdbh');
        if (empty($Gd_gdbh)){
            $this->error('参数错误');
        }
        $where = [
            'Yj_Gdbh' => $Gd_gdbh,
        ];
        $field = 'rtrim(Yj_Gdbh) as 工单编号,rtrim(yj_Yjno) as 印件号,rtrim(yj_Yjdh) as 印件代号,rtrim(yj_yjmc) as 印件名称,
        rtrim(yj_zzmc) as 纸张名称,rtrim(yj_tlgg) as 投料规格,rtrim(yj_成品数量) as 成品数量,rtrim(yj_实际投料) as 实际投料,
        rtrim(yj_Dw) as  投料单位,rtrim(yj_平张投料) as 平张投料,rtrim(yj_ls) as 联数,rtrim(yj_ks) as 开数,rtrim(Sys_id) as 创建用户,
        rtrim(Sys_rq) as 创建时间,rtrim(Mod_rq) as 修改时间,rtrim(Uniqid) as UNIQID';
        $list = \db('工单_印件资料')->where($where)->field($field)->select();
        if (empty($list)){
            $this->success('');
        }
        foreach ($list as $key=>$value){
            $list[$key]['成品数量'] = rtrim((float)$value['成品数量']);
            $list[$key]['实际投料'] = rtrim((float)$value['实际投料']);
        }
        $this->success('成功',$list);
    }

    /**
     * 排程中/制程中工单
     */
    public function Schedule(){
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $where = '';
        if (!empty($param['search'])){
            $where = "
                        a.Gd_gdbh LIKE '%{$param['search']}%' 
                        OR a.`成品名称` LIKE '%{$param['search']}%' 
                    ";
        }
        if ($param['status'] === '排程中'){
            $list = db('工单_基本资料')->alias('a')
                ->field([
                    'rtrim(a.Gd_gdbh)' => '工单编号',
                    'rtrim(a.Gd_cpdh)' => '产品代号',
                    'rtrim(a.Gd_cpmc)' => '产品名称',
                    'rtrim(a.接单日期)' => '接单日期',
                    'rtrim(a.交货日期)' => '交货日期',
                    'rtrim(a.订单数量)' => '订单数量',
                    'rtrim(a.计量单位)' => '计量单位',
                    'rtrim(a.销售订单号)' => '销售订单号',
                    'rtrim(a.Gd_客户代号)' => '客户编号',
                    'rtrim(a.Gd_客户名称)' => '客户名称',
                    'rtrim(a.客户料号)' => '客户料号',
                    'rtrim(a.Uniqid)' => 'GDUID',
                ])
                ->join('工单_工艺资料 b', 'a.Gd_gdbh = b.Gy0_gdbh')
                ->where([
                    'a.gd_statu' => '2-生产中',
                    'a.行号' => '1',
                    'b.PD_WG' => '1900-01-01 00:00:00',
                ])
                ->where($where)
//                ->whereNotExists(function ($query) {
//                    $query->table('工单_工艺资料')->alias('b2')
//                        ->where('b2.Gy0_gdbh = a.Gd_gdbh')
//                        ->where('b2.Gy0_sj1 <> "1900-01-01 00:00:00"');
//                })
                ->group('a.Gd_gdbh')
                ->select();
        }else{
            $list = db('工单_基本资料')->alias('a')
                ->field([
                    'rtrim(a.Gd_gdbh)' => '工单编号',
                    'rtrim(a.Gd_cpdh)' => '产品代号',
                    'rtrim(a.Gd_cpmc)' => '产品名称',
                    'rtrim(a.接单日期)' => '接单日期',
                    'rtrim(a.交货日期)' => '交货日期',
                    'rtrim(a.订单数量)' => '订单数量',
                    'rtrim(a.计量单位)' => '计量单位',
                    'rtrim(a.销售订单号)' => '销售订单号',
                    'rtrim(a.Gd_客户代号)' => '客户编号',
                    'rtrim(a.Gd_客户名称)' => '客户名称',
                    'rtrim(a.客户料号)' => '客户料号',
                    'rtrim(a.Uniqid)' => 'GDUID',
                ])
                ->join('工单_工艺资料 b', 'a.Gd_gdbh = b.Gy0_gdbh')
                ->where([
                    'a.gd_statu' => '2-生产中',
                    'a.行号' => '1',
                    'b.PD_WG' => '1900-01-01 00:00:00',
                    'b.Gy0_sj1' => ['<>', '1900-01-01 00:00:00'],
                ])
                ->where($where)
                ->group('a.Gd_gdbh')
                ->select();
        }
        if (empty($list)){
            $this->success('未找到工单信息');
        }
        $this->success('成功',$list);
    }

    /**
     * 排程中/制程中工单->工序列表
     * @ApiMethod (GET)
     * @param string $Gd_gdbh   工单编号
     * @return \think\response\Json
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */

    public function ScheduleProcess()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $Gd_gdbh = input('Gd_gdbh');
        if (empty($Gd_gdbh)){
            $this->error('参数错误');
        }
        $sql = "SELECT rtrim(a.Gy0_gdbh) as 工单编号,a.Gy0_yjno,a.Gy0_gxh,a.Gy0_gxmc,a.Add_gxmc,rtrim(a.Gy0_sbbh) as 设备编号,rtrim(a.Gy0_小时产能) as 小时产能,
                rtrim(a.工价系数) as 产能系数,rtrim(a.Gy0_生产工时) as 生产工时,rtrim(a.Gy0_辅助工时) as 辅助工时,rtrim(a.Gy0_最早开工时间) as 最早开工时间,
                rtrim(a.Gy0_sj1) as 计划开工时间,rtrim(a.Gy0_sj2) as 计划完工时间,rtrim(a.Gy0_班次安排) as 班次安排,rtrim(a.工序备注) as 排单备注,
                rtrim(a.PD_WG) as 工序完工,rtrim(a.UniqId) as UniqId,COALESCE(b.cl, 0) AS 产量, c.设备名称,rtrim(d.计划投料) as 工序产量
                FROM `工单_工艺资料` AS a
                JOIN `设备_基本资料` AS c ON a.Gy0_sbbh = c.设备编号
                JOIN `工单_基本资料` As d ON a.Gy0_gdbh = d.Gd_Gdbh
                LEFT JOIN (
                        SELECT sczl_gdbh, sczl_gxh, SUM(sczl_cl) AS cl
                        FROM `设备_产量计酬`
                        GROUP BY sczl_gdbh, sczl_gxh
                ) AS b ON a.Gy0_gdbh = b.sczl_gdbh AND (a.Gy0_gxh = b.sczl_gxh OR b.sczl_gxh IS NULL)
                WHERE a.Gy0_gdbh = '{$Gd_gdbh}' AND a.Gy0_sbbh != ''
                GROUP BY a.Gy0_yjno,a.Gy0_gxh";
        $list = Db::query($sql);
        if (empty($list)){
            $this->success('未找到工序');
        }
        foreach ($list as $key=>$value){
            if ((int)$value['Gy0_yjno'] <10){
                $value['Gy0_yjno'] = '0'.rtrim($value['Gy0_yjno']);
            }
            if ((int)$value['Gy0_gxh'] <10){
                $value['Gy0_gxh'] = '0'.rtrim($value['Gy0_gxh']);
            }
            if (rtrim($value['Add_gxmc']) == ''){
                $list[$key]['印件工序及名称'] = $value['Gy0_yjno'].'-'.$value['Gy0_gxh'].'-->'.rtrim($value['Gy0_gxmc']);
            }else{
                $list[$key]['印件工序及名称'] = $value['Gy0_yjno'].'-'.$value['Gy0_gxh'].'-->'.rtrim($value['Gy0_gxmc']).'【'.rtrim($value['Add_gxmc']).'】';
            }
            unset($list[$key]['Gy0_gxmc'],$list[$key]['Add_gxmc']);
            $list[$key]['机组'] = $value['设备编号'];
            $list[$key]['剩余产量'] = (int)$list[$key]['工序产量']-(int)$list[$key]['产量'];
        }
        $this->success('成功',$list);
    }
    /**
     * 排单页面左侧车间和机台菜单
     * @ApiMethod (GET)
     * @return \think\response\Json
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function workbench()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (isset($param['sort'])){
            $where['使用部门'] = '智能车间';
        }else{
            $where['使用部门'] = ['in',['印刷车间','印后车间']];
        }
        $data = [];
        $department = \db('设备_基本资料')
            ->distinct(true)
            ->where('使用部门','<>','研发中心')
            ->where('设备编组','<>','')
            ->where($where)
            ->order('设备编组')
            ->column('使用部门');
        if (empty($department)){
            $this->success('为获取到机台数据');
        }
        foreach ($department as $value){
            $benchClass = \db('设备_基本资料')->where('使用部门',$value)->distinct(true)->order('设备编组')->column('设备编组');
            foreach ($benchClass as $v){
                if (rtrim($v) !== ''){
                    $machine = \db('设备_基本资料')->where('使用部门',$value)->where('设备编组',$v)->field('rtrim(设备编号) as 设备编号,rtrim(设备名称) as 设备名称')->select();
                    foreach ($machine as $kk=>$vv){
                        $data[rtrim($value)][rtrim($v)][$kk] = $vv['设备编号'].'-->'.$vv['设备名称'];
                    }
                }
            }
        }

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


    /**
     * 工单状态设置
     * @ApiMethod (GET)
     * @param string $workOrder  工单编号
     * @param string $status   工单状态
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function StatusEdit()
    {
        if (Request::instance()->isPost() === false){
            $this->error('请求错误');
        }
        $workOrder = input('workOrder');
        $status = input('status');
        if (empty($workOrder) || empty($status)){
            $this->error('参数错误');
        }
        $sql = \db('工单_基本资料')->where('Gd_gdbh',$workOrder)->fetchSql(true)->update(['gd_statu'=>$status]);
        $res = Db::query($sql);
        if ($res !== false){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }

    /**
     * 更改工序状态
     * @ApiMethod (GET)
     * @param void
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function complete()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $data = $this->request->param();
        if (empty($data)){
            $this->error('参数错误');
        }
        $where = [
            'Gy0_gdbh' => $data['workOrder'],
            'Gy0_gxh'  => $data['processCode']
        ];
        $sql = \db('工单_工艺资料')->where($where)->fetchSql(true)->update(['PD_WG'=>date('Y-m-d H:i:s',time())]);
        $res = Db::query($sql);
        if ($res !== false){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }

    /**
     * 加入排产
     * @ApiMethod (POST)
     * @param void $data
     * @return void
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */

    public function ProductionSchedulingAdd()
    {
        if (Request::instance()->isPost() === false){
            $this->error('请求错误');
        }
        $data = Request::instance()->post();
        if (empty($data)){
            $this->error('参数错误');
        }
        $where = [
            'Gy0_gdbh' => $data['workOrder'],
            'Gy0_sbbh' => ['like','%'.$data['machine'].'%'],
            'Gy0_yjno' => $data['printCode'],
            'Gy0_gxh'  => $data['processCode']
        ];
        $result = \db('工单_工艺资料')->where($where)->field('rtrim(Gy0_sj1) as sj1')->find();
        if ($result['sj1'] != '1900-01-01 00:00:00'){
            $this->error('该工单已经是制程中');
        }
        $lastTime = \db('工单_工艺资料')
            ->where(['Gy0_sbbh'=>$where['Gy0_sbbh'],'Gy0_sj2'=>['<>','1900-01-01 00:00:00'],'Gy0_sj2'=>['<','2099-01-01 00:00:00']])
            ->field('rtrim(Gy0_sj2) as sj2')
            ->order('Gy0_sj2 desc')
            ->find();
        $date = date('Y-m-d H:i:s',time());
        if ($lastTime['sj2'] < $date){
            $newTime = $date;
        }else{
            $newTime = $lastTime['sj2'];
        }
        $row = \db('工单_工艺资料')
            ->where($where)
            ->field('rtrim(Gy0_计划接货数) as 计划接货数,rtrim(Gy0_小时产能) as 小时产能,rtrim(Gy0_辅助工时) as 辅助工时')
            ->find();
        if (empty($row)){
            $this->success('未找到该工单工艺资料');
        }
        $endTime = date('Y-m-d H:i:s',strtotime($newTime) + ((int)round($row['计划接货数']/$row['小时产能'])+(int)$row['辅助工时'])*3600);
        $sql = \db('工单_工艺资料')
            ->where($where)
            ->fetchSql(true)
            ->update(['Gy0_sj1'=>$newTime,'Gy0_sj2'=>$endTime,'Mod_rq'=>date('Y-m-d H:i:s',time())]);
        $res = Db::query($sql);
        if ($res !== false){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }

    /**
     * 暂停排产
     * @ApiMethod (POST)
     * @param  void  $data
     * @return void
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */

    public function ProductionSchedulingPause()
    {
        if (Request::instance()->isPost() === false){
            $this->error('请求错误');
        }
        $data = Request::instance()->post();
        if (empty($data)){
            $this->error('参数错误');
        }
        $where = [
            'Gy0_gdbh' => $data['workOrder'],
            'Gy0_sbbh' => ['like','%'.$data['machine'].'%'],
            'Gy0_yjno' => $data['printCode'],
            'Gy0_gxh'  => $data['processCode']
        ];
        $machine = $data['machine'];
        $endTime = \db('工单_工艺资料')->where($where)->field('rtrim(Gy0_sj2) as sj2,rtrim(PD_WG) as wg')->find();
        if (empty($endTime)){
            $this->success('未找到该工序');
        }
        $time = $endTime['sj2'];
        if ($endTime['sj2'] == '1900-01-01 00:00:00' || $endTime['wg'] != '1900-01-01 00:00:00'){
            $this->error('该工单不是制程中工单');
        }
        $sql = \db('工单_工艺资料')
            ->where($where)
            ->fetchSql(true)
            ->update(['Gy0_sj1'=>'1900-01-01 00:00:00','Gy0_sj2'=>'1900-01-01 00:00:00','Mod_rq'=>date('Y-m-d H:i:s')]);
        $row = \db('工单_工艺资料')
            ->where($where)
            ->field('rtrim(Gy0_计划接货数) as 计划接货数,rtrim(Gy0_小时产能) as 小时产能,rtrim(Gy0_辅助工时) as 辅助工时')
            ->find();
        if (empty($row)){
            $this->success('未找到该工序');
        }
        $number = -(int)round($row['计划接货数']/$row['小时产能'])+(int)$row['辅助工时'];
        $rechSql = "UPDATE `工单_工艺资料` SET Gy0_sj1 = DATE_ADD(Gy0_sj1, INTERVAL {$number} HOUR),Gy0_sj2 = DATE_ADD(Gy0_sj2, INTERVAL {$number} HOUR) WHERE Gy0_sbbh LIKE '%{$machine}%' AND Gy0_sj1 >= '{$time}' AND Gy0_sj1 < '2099-01-01 00:00:00'";
        $rechres = Db::query($rechSql);
        $res = Db::query($sql);
        if ($res !== false && $rechres !== false){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }

    /**
     * 工序状态更正
     * @ApiMethod (GET)
     * @param  void $param
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function ProcessStatusCorrection()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $where = [
            'Gy0_gdbh' => $param['workOrder'],
        ];
        $workOrder = $where['Gy0_gdbh'];
        $field = 'rtrim(Gy0_yjno) as yjno,rtrim(Gy0_gxh) as gxh,rtrim(Gy0_gxmc) as gxmc,rtrim(Gy0_sbbh) as 设备代号,rtrim(Gy0_计划接货数) as 计划接货数,rtrim(Gy0_ls) as ls,rtrim(PD_WG) as 完工时间,rtrim(UniqId) as UniqId';
        $list = \db('工单_工艺资料')->where($where)->field($field)->order('Gy0_yjno,Gy0_gxh')->select();
        if (empty($list)){
            $this->success('未找到该工单工艺资料');
        }
        $yieldSql = "SELECT
            a.Gy0_yjno AS yjno,
            a.Gy0_gxh AS gxh,
            SUM( b.sczl_cl ) AS cl 
        FROM
            `工单_工艺资料` AS a
            JOIN `设备_产量计酬` AS b ON a.Gy0_gxh = b.sczl_gxh AND a.Gy0_yjno = b.sczl_yjno
        WHERE
            a.Gy0_gdbh = '{$workOrder}' 
        GROUP BY
            a.Gy0_yjno,a.Gy0_gxh";
        $yield = Db::query($yieldSql);
        foreach ($list as $key=>$value){
            if ($value['yjno']<10){
                $value['yjno'] = '0'.$value['yjno'];
            }
            if ($value['gxh']<10){
                $value['gxh'] = '0'.$value['gxh'];
            }
            $list[$key]['印件及工序'] = $value['yjno'].'-'.$value['gxh'].'-->'.$value['gxmc'];
            foreach ($yield as $k=>$v){
                if ($v['yjno'] === $list[$key]['yjno']) {
                    if ($v['gxh'] === $list[$key]['gxh']){
                        $list[$key]['计划产量/已完成'] = (int)$value['计划接货数'] . '/' . $v['cl'];
                        if ($value['计划接货数'] !== 0 && $value['计划接货数'] !== '' && !empty($value['计划接货数'])) {
                            $num = (float)number_format(intval($v['cl']) / intval($value['计划接货数']), 4);
                            $list[$key]['完成率'] = $num * 100 . '%';
                        } else {
                            $list[$key]['完成率'] = '';
                        }
                    }else{
                        $list[$key]['计划产量/已完成'] = $value['计划接货数'].'/0';
                        $list[$key]['完成率'] = '';
                    }
                }
            }
            if ($value['完工时间'] == '1900-01-01 00:00:00') {
                $list[$key]['完工时间'] = '';
            }
            unset($list[$key]['yjno'],$list[$key]['gxh'],$list[$key]['gxmc'],$list[$key]['计划接货数'],$list[$key]['ls']);
        }
        $this->success('成功',$list);
    }


    /**
     * 工序状态更正->工序状态编辑
     * @ApiMethod (POST)
     * @param  void
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function ProcessStatusCorrectionEdit()
    {
        if (Request::instance()->isPost() === false){
            $this->error('请求错误');
        }
        $param = Request::instance()->post();
        if (empty($param)){
            $this->error('参数错误');
        }
        $i = 0;
        foreach ($param as $key=>$value){
            if ($value['PD_WG'] === null || $value['PD_WG'] === ''){
                $endTime = '1900-01-01 00:00:00';
            }else{
                $endTime = $value['PD_WG'];
            }
            $sql = \db('工单_工艺资料')
                ->where('UniqId',$value['UniqId'])
                ->fetchSql(true)
                ->update(['PD_WG'=>$endTime]);
            $res = Db::query($sql);
            if ($res !== false){
                $i++;
            }
        }
        if ($i !== 0){
            $this->success('成功');
        }else{
            $this->error('失败');
        }

    }

    /**
     * 班次选择
     * @ApiMethod （GET）
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function ScheduleSelection()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $list = \db('工单_排程班次')->field('rtrim(bcdh) as 班次代号,rtrim(desc_) as desc_,rtrim(stdtime) as stdtime')->select();
        if (empty($list)){
            $this->success('未找到班次数据');
        }
        foreach ($list as $key=>$value){
            $list[$key]['detail'] = $value['班次代号'].'||'.$value['desc_'].'||'.$value['stdtime'];
            unset($list[$key]['desc_'],$list[$key]['stdtime']);
        }
        $this->success('成功',$list);
    }

    /**
     * 车间设备制程展示
     * @ApiMethod （GET）
     * @param  void $param
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */

    public function EquipmentScheduling()
    {
        if ($this->request->isGet() === false){
            $this->error('参数错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $machine = $param['machine'];
        $list = \db('工单_基本资料')
            ->alias('a')
            ->field([
                'rtrim(b.Gy0_gdbh)' => '工单编号',
                'rtrim(b.Gy0_计划接货数)' => '计划接货数',
                'rtrim(b.Gy0_小时产能)' => '小时产能',
                'rtrim(b.Gy0_生产工时)' => '生产工时',
                'rtrim(b.Gy0_辅助工时)' => '辅助工时',
                'rtrim(b.Gy0_班次安排)' => '班次安排',
                'rtrim(b.工序备注)' => '排单备注',
                'rtrim(b.Gy0_最早开工时间)' => '最早开工时间',
                'rtrim(b.Gy0_sj1)' => '计划开工时间',
                'rtrim(b.Gy0_sj2)' => '计划完工时间',
                'rtrim(b.Gy0_yjno)' => 'yjno',
                'rtrim(b.Gy0_gxh)' => 'gxh',
                'rtrim(b.Gy0_gxmc)' => 'gxmc',
                'rtrim(b.Gy0_ls)' => 'ls',
                'rtrim(b.UniqId)' => 'UniqId',
                'SUM(c.sczl_cl)' => '已完成'
            ])
            ->join('工单_工艺资料 b','a.Gd_gdbh = b.Gy0_gdbh')
            ->join('设备_产量计酬 c','a.Gd_gdbh = c.sczl_gdbh AND b.Gy0_yjno = c.sczl_yjno AND b.Gy0_gxh = c.sczl_gxh','LEFT')
            ->where([
                'b.Gy0_sbbh' => $machine,
                'b.Gy0_sj1' => ['>','1900-01-01 00:00:00'],
                'b.PD_WG' => '1900-01-01 00:00:00',
                'a.gd_statu' => '2-生产中'
            ])
            ->where('b.Gy0_sj1','<','2099-01-01 00:00:00')
            ->group('a.Gd_gdbh')
            ->select();
        foreach ($list as $key=>$value){
            $list[$key]['计划接货数'] = (int)round($value['计划接货数']/$value['ls']);
            if ($value['yjno']<10){
                $value['yjno'] = '0'.$value['yjno'];
            }
            if ($value['gxh']<10){
                $value['gxh'] = '0'.$value['gxh'];
            }
            $list[$key]['印件/工序'] = $value['yjno'].'-'.$value['gxh'].'-'.$value['gxmc'];
            unset($list[$key]['yjno'],$list[$key]['gxh'],$list[$key]['gxmc'],$list[$key]['ls']);
        }
        $this->success('成功',$list);
    }

    /**
     * 车间设备排程编辑
     * @ApiMethod (POST)
     * @param  void $param
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function EquipmentSchedulingEdit()
    {
        if (Request::instance()->isPost() === false){
            $this->error('请求错误');
        }
        $param = Request::instance()->post();
        if (empty($param)){
            $this->error('参数错误');
        }
        $i = 0;
        foreach ($param as $key=>$value){
            $data = [
                'Gy0_小时产能' => $value['capacity'],
                'Gy0_生产工时' => $value['ProductionHours'],
                'Gy0_辅助工时' => $value['AuxiliaryHours'],
                'Gy0_班次安排' => $value['shift'],
                '工序备注' => $value['remark'],
                'Gy0_最早开工时间' => $value['start'] === ''?'1900-01-01 00:00:00':date('Y-m-d H:i:s',strtotime($value['start'])),
                'Gy0_sj1' => date('Y-m-d H:i:s',strtotime($value['projectTime'])),
//                'Gy0_sj2' => date('Y-m-d H:i:s',strtotime($value['projectTime'])+(ceil($value['ProductionHours'])+ceil($value['AuxiliaryHours']))*3600),
                'Gy0_sj2' => date('Y-m-d H:i:s',strtotime($value['endTime'])),
            ];
            $sql = \db('工单_工艺资料')
                ->where('UniqId',$value['UniqId'])
                ->fetchSql(true)
                ->update($data);
            $res = Db::query($sql);
            if ($res !== false){
                $i++;
            }
        }
        if ($i !== 0){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }


    /**
     * 机台工单展示
     * @ApiMethod ()
     * @return void
     * @throws \think\db\exception\BindParamException
     * @throws \think\exception\PDOException
     */
    public function MachineWorkOrderList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求失败');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $where = '';
        if (isset($param['search'])){
            $where = "
                        b.Gd_gdbh LIKE '%{$param['search']}%' 
                        OR b.`成品名称` LIKE '%{$param['search']}%' 
                    ";
        }
        $list = \db('工单_工艺资料')
            ->alias('a')
            ->field([
                'RTRIM( a.Gy0_yjno )' =>'yjno',
                'RTRIM( a.Gy0_gxh )' => 'gxh',
                'RTRIM( a.Gy0_gxmc )' => 'gxmc',
                'RTRIM( a.Add_gxmc )' => 'Add_gxmc',
                'RTRIM( c.yj_yjmc )' => '印件名称',
                'RTRIM( a.`Gy0_计划接货数` )' => '计划接货数',
                'RTRIM( a.`Gy0_小时产能` )' => '小时产能',
                'RTRIM( a.`工价系数` )' => '产能系数',
                'RTRIM( a.`Gy0_生产工时` )' => '生产工时',
                'RTRIM( a.Gy0_ls )' => 'ls',
                'RTRIM( a.`Gy0_辅助工时` )' => '辅助工时',
                'RTRIM( a.`Gy0_最早开工时间` )' => '最早开工时间',
                'RTRIM( a.Gy0_sj1 )' => '计划开工时间',
                'RTRIM( a.Gy0_sj2 )' => '计划完工时间',
                'RTRIM( a.`Gy0_班次安排` )' => '班次安排',
                'RTRIM( a.`工序备注` )' => '排单备注',
                'RTRIM( b.Gd_cpmc )' => '产品名称',
                'RTRIM( b.`成品名称` )' => '成品名称',
                'RTRIM( b.`订单数量` )' => '订单数量',
                'RTRIM( b.`计量单位` )' => '计量单位',
                'RTRIM( b.`交货日期` )' => '交货日期',
                'RTRIM( b.Gd_cpdh )' => '产品代号',
                'RTRIM( b.`成品代号` )' => '成品代号',
                'RTRIM( a.Gy0_sbbh )' => '设备编号',
                'RTRIM( a.Gy0_SITE )' => '车间名称',
                'RTRIM( a.UniqId )' => 'GYUID',
                'RTRIM( b.Uniqid )' => 'UNIQID',
                'SUM( d.sczl_cl )' => '已完成产量',
                'RTRIM( b.Gd_gdbh )' => '工单编号',
                'RTRIM( b.`销售订单号` )' => '销售订单号',
            ])
            ->join('工单_印件资料 c','c.Yj_Gdbh = a.Gy0_gdbh AND c.yj_Yjno = a.Gy0_yjno')
            ->join('工单_基本资料 b','b.Gd_gdbh = a.Gy0_gdbh')
            ->join('设备_产量计酬 d','a.Gy0_gdbh = d.sczl_gdbh AND a.Gy0_yjno = d.sczl_yjno AND a.Gy0_gxh = d.sczl_gxh AND a.Gy0_sbbh = d.sczl_jtbh','LEFT')
            ->where([
                'b.gd_statu' => '2-生产中',
                'a.Gy0_sbbh' => ['LIKE','%'.$param['machine'].'%'],
                'a.PD_WG' => '1900-01-01 00:00:00',
            ])
            ->where($where)
            ->group('a.Gy0_gdbh,a.Gy0_yjno,a.Gy0_gxh')
            ->order('Gy0_sj1')
            ->select();
        if (empty($list)){
            $this->success('',[]);
        }
        $data['制程'] = $data['排程'] = [];
        foreach ($list as $key=>$value){
            $list[$key]['设备编号'] = $param['machine'];
            if ((int)$value['yjno'] <10){
                $value['yjno'] = '0'.rtrim($value['yjno']);
            }
            if ((int)$value['gxh'] <10){
                $value['gxh'] = '0'.rtrim($value['gxh']);
            }
            if (rtrim($value['Add_gxmc']) == ''){
                $list[$key]['印件工序及名称'] = $value['yjno'].'-'.$value['gxh'].'-->'.rtrim($value['gxmc']);
            }else{
                $list[$key]['印件工序及名称'] = $value['yjno'].'-'.$value['gxh'].'-->'.rtrim($value['gxmc']).'【'.rtrim($value['Add_gxmc']).'】';
            }
            unset($list[$key]['Add_gxmc']);
            if ($value['产品名称'] == ''){
                $list[$key]['产品名称'] = $value['成品名称'];
            }
            if ($value['产品代号'] == ''){
                $list[$key]['产品代号'] = $value['成品代号'];
            }
            unset($list[$key]['成品代号'],$list[$key]['成品名称']);
            if ($list[$key]['计划开工时间'] !== '1900-01-01 00:00:00'){
                array_push($data['制程'],$list[$key]);
            }else{
                array_push($data['排程'],$list[$key]);
            }
        }

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

    /**
     * 机组调整
     * @return void
     * @throws \think\Exception
     * @throws \think\db\exception\BindParamException
     * @throws \think\exception\PDOException
     */
    public function MachineTeamEdit()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param) || isset($param['UniqId']) === false){
            $this->error('参数错误');
        }
        $sql = \db('工单_工艺资料')
            ->where('UniqId',$param['UniqId'])
            ->fetchSql(true)
            ->update(['Gy0_sbbh'=>$param['machine']]);
        $res = \db()->query($sql);
        if ($res !== false){
            $this->success('修改成功');
        }else{
            $this->error('修改失败');
        }
    }

    /**
     * 子订单领料派单
     */
    public function processAdd()
    {
        if (Request::instance()->post() === false){
            $this->error('参数错误');
        }
        $param = Request::instance()->post();
        if (empty($param)){
            $this->error('参数错误');
        }
        $data['班组编号'] = $param['班组'];
        $data['订单编号'] = $param['订单编号'];
        $data['子订单编号'] = $param['子订单编号'];
        $data['sys_id'] = $param['Sys_id'];
        $data['sys_rq'] = date('Y-m-d H:i:s',time());
        $sql = \db('工单_排程班次')->fetchSql(true)->insert($data);
        $res = \db()->query($sql);
        if ($res !== false){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }

    /**
     * 月度车间报工汇总-菜单显示
     */
    public function MachineList() {
        // 检查请求是否为 GET
        if (!$this->request->isGet()) {
            $this->error('请求错误');
        }

        // 定义要查询的生产工序及排序顺序
        $processList = ['裁剪', '车缝', '手工', '大烫', '总检', '包装'];

        // 查询所有数据
        $results = \db('设备_产量计酬')
            ->alias('a')
            ->join('设备_基本资料 b', 'a.sczl_jtbh = b.设备编号')
            ->field([
                'DATE_FORMAT(a.sczl_rq, "%Y-%m-%d")' => '时间', // 转化为 "YYYY-MM-DD" 格式
                'DATE_FORMAT(a.sczl_rq, "%Y-%m")' => '年月',    // 转化为 "YYYY-MM" 格式
                'RTRIM(a.sczl_jtbh)' => '机台编号',
                'b.设备编号',
                'b.设备编组',
                'b.生产工序'
            ])
            ->whereNull('a.mod_rq') // 筛选无修改日期的数据
            ->whereIn('b.生产工序', $processList) // 筛选指定的生产工序
            ->order('a.sczl_rq ASC') // 按时间升序排序
            ->select();

        // 初始化按年月分组的结果
        $formattedData = [];

        // 遍历查询结果并分组
        foreach ($results as $row) {
            $yearMonth = $row['年月']; // 获取年月 "YYYY-MM"
            $monthDay = $row['时间']; // 获取月份和日期 "MM-DD"
//            $monthDay = substr($row['时间'], 0, 5); // 获取月份和日期 "MM-DD"
            $process = $row['生产工序'];
            $machineKey = $row['设备编号'] . '--' . $row['设备编组'];

            // 初始化年份和工序结构
            if (!isset($formattedData[$yearMonth])) {
                $formattedData[$yearMonth] = array_fill_keys($processList, []); // 初始化月份，所有工序为空数组
            }
            if (!isset($formattedData[$yearMonth][$process][$machineKey])) {
                $formattedData[$yearMonth][$process][$machineKey] = [];
            }

            // 添加日期，避免重复
            if (!in_array($monthDay, $formattedData[$yearMonth][$process][$machineKey])) {
                $formattedData[$yearMonth][$process][$machineKey][] = $monthDay;
            }
        }

        // 对年份和月份进行排序（按年月降序排序）
        krsort($formattedData);

        // 按生产工序排序
        foreach ($formattedData as $yearMonth => &$processData) {
            // 1. 确保每个月的工序顺序符合 $processList（即使为空也保留顺序）
            $sortedProcessData = array_fill_keys($processList, []);

            // 将原有数据合并到排序后的结构中
            $processData = array_merge($sortedProcessData, $processData);

            // 2. 对每个工序下的设备组进行日期倒序排序
            foreach ($processData as $process => &$machines) {
                if (is_array($machines)) { // 确保 $machines 是数组
                    foreach ($machines as $machineKey => &$dates) {
                        if (is_array($dates) && !empty($dates)) { // 确保 $dates 存在并且是非空数组
                            rsort($dates); // 每台设备的日期倒序排序
                        }
                    }
                }
            }
        }

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



    /**
     * 月度车间报工汇总-列表详情数据
     */
    public function MachineDetail()
    {
        if ($this->request->isGet() === false) {
            $this->error('请求错误');
        }

        $param = $this->request->param();
        if (empty($param)) {
            $this->error('参数错误');
        }

        $where = [];

        // 获取当前年份
        $currentYear = date('Y');

        // 处理日期参数（可选）
        if (!empty($param['date'])) {
            // 日期参数的格式处理
            $where['a.sys_rq'] = ['like', "%{$param['date']}%"];
        }

        // 订单编号筛选
        if (!empty($param['order'])) {
            $where['b.订单编号|a.款号|b.子订单编号'] = ['like', '%' . $param['order'] . '%'];
        }

        // 机台号筛选
        if (!empty($param['machine'])) {
            // 针对机台号的特定条件判断
            $machineMapping = [
                '裁剪' => 'CQ', '车缝' => 'CF', '手工' => 'HD',
                '大烫' => 'DT', '总检' => 'ZJ', '包装' => 'BZ'
            ];

            if (isset($machineMapping[$param['machine']])) {
                $where['a.sczl_jtbh'] = ['like', '%' . $machineMapping[$param['machine']] . '%'];
            } elseif (preg_match('/^\d{4}-\d{2}$/', $param['machine'])) {
                $where['a.sczl_jtbh'] = '';  // 若为日期格式，清空该字段
            } else {
                $where['a.sczl_jtbh'] = $param['machine'];
            }
        }

        // 查询数据
        $offset = ($param['page'] - 1) * $param['limit'];
        $list = \db('设备_产量计酬')->alias('a')
            ->join('工单_印件资料 b', 'b.订单编号 = a.订单编号 AND a.子订单编号 = b.子订单编号')
            ->join('工单_基本资料 j', 'b.订单编号 = j.订单编号', 'LEFT')
            ->field('
                a.工序名称,a.sczl_bh,a.订单编号, a.子订单编号, b.款号, b.颜色, b.船样, a.尺码, b.zdtotal as 制单数, b.颜色备注,
                CASE 
                    WHEN a.工序名称 IN ("裁剪", "车缝") THEN a.数量
                    ELSE a.s_num 
                END as 数量,
                MIN(a.sys_rq) as 上报时间, a.UniqId,
                j.客户编号, j.生产款号, j.款式
            ')
            ->where($where)
            ->where('a.mod_rq', null)
            ->order('a.sys_rq desc, a.UniqId desc')
            ->limit($offset, $param['limit'])
            ->group('a.UniqId')
            ->select();

        $count = \db('设备_产量计酬')->alias('a')
            ->join('工单_印件资料 b', 'b.订单编号 = a.订单编号 AND a.子订单编号 = a.子订单编号')
            ->join('工单_基本资料 j', 'b.订单编号 = j.订单编号', 'LEFT')
            ->field('
                a.工序名称,a.sczl_bh,b.订单编号, b.子订单编号, b.款号, b.颜色, b.船样, a.尺码, b.zdtotal as 制单数, b.颜色备注,
                CASE 
                    WHEN a.工序名称 IN ("裁剪", "车缝") THEN a.数量
                    ELSE a.s_num 
                END as 数量,
                 MIN(a.sys_rq) as 上报时间, a.UniqId,
                j.客户编号, j.生产款号, j.款式
            ')
            ->where($where)
            ->where('a.mod_rq', null)
            ->order('a.sys_rq desc, a.UniqId desc')
            ->group('a.UniqId')
            ->select();

        // 提取所有的尺码，并去重，去除空格
        $sizeList = array_values(array_unique(array_map('trim', array_column($list, '尺码'))));

        // 自定义排序规则（已存在的排序逻辑）
        $sizeOrder = ['XXS', 'XS', 'S', 'M', 'L', 'XL', 'XXL', 'XXXL', 'XXXXL'];
        usort($sizeList, function ($a, $b) use ($sizeOrder) {
            // 数字优先比较
            if (is_numeric($a) && is_numeric($b)) {
                return $a - $b;
            }
            if (in_array($a, $sizeOrder) && in_array($b, $sizeOrder)) {
                return array_search($a, $sizeOrder) - array_search($b, $sizeOrder);
            }
            if (is_numeric($a)) return -1;
            if (is_numeric($b)) return 1;

            return strcmp($a, $b);
        });

        // 动态将尺码的数量添加到每个订单中，并替换已完成字段
        foreach ($list as &$item) {
            $size = $item['尺码'];
            $item[$size] = $item['数量'];
        }

        // 返回结果
        $this->success('请求成功', [
            'table' => $list,
            'length' => count($count),
            'headers' => $sizeList  // 返回所有的尺码作为表头
        ]);
    }

    /**
     * 样衣核批
     */
    public function Approval(){
        if ($this->request->isPost() === false) {
            $this->error('请求错误');
        }
        $param = Request::instance()->post();
        if (empty($param)) {
            $this->error('参数错误');
        }
        // 判断Uniqid是否为多个，多个以逗号分隔
        $uniqids = strpos($param['Uniqid'], ',') !== false ? explode(',', $param['Uniqid']) : [$param['Uniqid']];

        if (!empty($param['rq'])) {
            // 准备更新数据
            $data = [
                '审核日期' => $param['rq'],
                '审核' => $param['sys_id'],
            ];
        }else{
            // 准备更新数据
            $data = [
                '审核日期' => date('Y-m-d H:i:s'),
                '审核' => $param['sys_id'],
            ];
        }
        // 遍历所有Uniqid进行更新
        foreach ($uniqids as $uniqid) {
            $list = \db('工单_基本资料')
                ->where('Uniqid', $uniqid)
                ->fetchSql(true)
                ->update($data);
            $res = \db()->query($list);
            // 如果更新失败，直接返回错误
            if ($res === false) {
                $this->error('审核失败');
            }
        }
        // 所有更新操作都成功时，返回成功
        $this->success('审核成功');
    }

    /**
     * 订单状态及样衣批核
     */
    public function UnapprovalList()
    {
        if ($this->request->isGet() === false) {
            $this->error('请求错误');
        }

        $param = $this->request->param();

        // 设置查询条件
        $where = [
            'Mod_rq' => null,
            '订单编号|生产款号' => ['like', '%' . $param['search'] . '%'],
        ];

        $page = isset($param['page']) ? $param['page'] : 1;
        $limit = isset($param['limit']) ? $param['limit'] : 20;

        // 获取工单列表
        $list = \db('工单_基本资料')
            ->where($where)
            ->order('订单编号 desc')
            ->limit(($page - 1) * $limit, $limit)
            ->select();

        // 获取总记录数
        $count = \db('工单_基本资料')
            ->where($where)
            ->count();  // 使用 count() 方法优化
        $orderIds = array_column($list, '订单编号');

        // 合并查询相关附件
        $relatedOrders = \db('工单_相关附件')
            ->whereIn('关联编号', $orderIds)
            ->whereIn('附件备注', ['技术附件', '订单资料附件'])
            ->column('关联编号,附件备注');

        // 重新组织附件数据
        $groupedRelatedOrders = [
            'technical' => [],
            'order' => []
        ];

        foreach ($relatedOrders as $orderNumber => $attachmentRemark) {
            if ($attachmentRemark === '技术附件') {
                $groupedRelatedOrders['technical'][] = $orderNumber;
            } elseif ($attachmentRemark === '订单资料附件') {
                $groupedRelatedOrders['order'][] = $orderNumber;
            }
        }

        // 遍历工单列表并设置状态
        foreach ($list as &$value) {
            // 设置订单状态
            $value['status'] = in_array($value['订单编号'], $groupedRelatedOrders['technical']) ? '' : '*';
            $value['orderstatus'] = in_array($value['订单编号'], $groupedRelatedOrders['order']) ? '' : '*';

            // 定义工序编号数组
            $processIds = [
                2 => '裁剪完工数量',
                3 => '车缝完工数量',
                4 => '手工完工数量',
                5 => '大烫完工数量',
                6 => '总检完工数量',
                7 => '工单完工数量'
            ];

            // 遍历工序编号，获取对应的完工数量
            foreach ($processIds as $processId => $fieldName) {
                if ($processId === 2 || $processId === 3) {
                    // 查询所有记录
                    $records = \db('设备_产量计酬')
                        ->where('订单编号', $value['订单编号'])
                        ->where('工序编号', $processId)
                        ->select();  // 获取所有匹配记录

                    // 计算数量总和
                    $num_sum = 0;
                    foreach ($records as $record) {
                        $num_sum += $record['数量'];  // 手动累加数量
                    }

                    $value[$fieldName] = $num_sum; // 裁剪和车缝存储数量
                } else {
                    // 其他工序是 s_num，总和计算
                    $s_num_sum = \db('设备_产量计酬')
                        ->where('订单编号', $value['订单编号'])
                        ->where('工序编号', $processId)
                        ->sum('s_num'); // 继续使用 s_num 字段
                    $value[$fieldName] = $s_num_sum; // 其他工序存储 s_num 总和
                }
            }

            if ($value['落货日期']) {
                $value['落货日期'] = date('Y-m-d', strtotime($value['落货日期']));
            }
            // 格式化接单日期，去掉时间部分
            if ($value['接单日期']) {
                $value['接单日期'] = date('Y-m-d', strtotime($value['接单日期']));
            }
        }

        // 返回数据
        $data = [
            'total' => $count,
            'table' => $list,
        ];

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


    /**
     * 出货大货报表：辅料计划入库时间 / 计划生产小组（同一入口，按参数区分）
     * 辅料计划入库时间：Uniqid + rq + sys_id
     * 计划生产小组：     Uniqid + 计划生产小组 + sys_id（不传 rq）
     */
    public function AccessoriesInboundTime()
    {
        if (!$this->request->isPost()) {
            return $this->error('请求错误');
        }

        $param = $this->request->post();

        // 必传参数
        if (empty($param['Uniqid']) || empty($param['sys_id'])) {
            return $this->error('参数错误');
        }

        $uniqids = strpos($param['Uniqid'], ',') !== false
            ? explode(',', $param['Uniqid'])
            : [$param['Uniqid']];

        // ===================== 最简逻辑 =====================
        // 有 rq → 更新时间
        if (!empty($param['rq'])) {
            $data = [
                '辅料计划入库时间'   => trim($param['rq']),
                '辅料计划入库操作人' => $param['sys_id'],
            ];
        }
        // 没有 rq → 更新小组
        else {
            $data = [
                '计划生产小组'       => trim($param['计划生产小组'] ?? ''),
                '计划生产小组操作人' => $param['sys_id'],
                '计划生产小组时间'   => date('Y-m-d H:i:s'),
            ];
        }
        foreach ($uniqids as $uniqid) {
            $uniqid = trim($uniqid);
            if ($uniqid) {
                $list = \db('工单_基本资料')
                    ->where('Uniqid', $uniqid)
                    ->fetchSql(true)
                    ->update($data);
                $res = \db()->query($list);
                if ($res === false) {
                    $this->error('操作失败');
                }
            }
        }
        return $this->success('操作成功');
    }

//    /**
//     * 辅料计划入库时间更新
//     */
//    public function AccessoriesInboundTime(){
//        if ($this->request->isPost() === false) {
//            $this->error('请求错误');
//        }
//        $param = Request::instance()->post();
//        if (empty($param)) {
//            $this->error('参数错误');
//        }
//        // 判断Uniqid是否为多个，多个以逗号分隔
//        $uniqids = strpos($param['Uniqid'], ',') !== false ? explode(',', $param['Uniqid']) : [$param['Uniqid']];
//
//        if (!empty($param['rq'])) {
//            // 准备更新数据
//            $data = [
//                '辅料计划入库时间' => $param['rq'],
//                '辅料计划入库操作人' => $param['sys_id'],
//            ];
//        }else{
//            // 准备更新数据
//            $data = [
//                '辅料计划入库时间' => date('Y-m-d H:i:s'),
//                '辅料计划入库操作人' => $param['sys_id'],
//            ];
//        }
//        // 遍历所有Uniqid进行更新
//        foreach ($uniqids as $uniqid) {
//            $list = \db('工单_基本资料')
//                ->where('Uniqid', $uniqid)
//                ->fetchSql(true)
//                ->update($data);
//            $res = \db()->query($list);
//            // 如果更新失败，直接返回错误
//            if ($res === false) {
//                $this->error('更新辅料计划入库时间失败');
//            }
//        }
//        // 所有更新操作都成功时，返回成功
//        $this->success('更新成功');
//    }

    /**
     * 月度客户订单汇总
     */
    public function OrderYieldList(){
        // 获取前端传来的参数
        $param = $this->request->param();
        // 初始化查询条件
        $where = [];
        // 处理搜索条件
        if (isset($param['search']) && !empty($param['search'])) {
            $where['j.订单编号|j.生产款号'] = ['like', '%' . $param['search'] . '%'];
        }
        if (isset($param['client']) && !empty($param['client'])) {
            $where['j.客户编号'] = $param['client'];
        }
        if (isset($param['date']) && !empty($param['date'])) {
            $year = substr($param['date'], 0, 4);
            $month = substr($param['date'], 4, 2);
            $where['j.Sys_rq'] = ['like', "$year-$month%"];
        }
        // 只查询生产中的工单
//        $where['j.gd_statu'] = '2-生产中';
        $where['j.Mod_rq'] = null;
        $where['y.Mod_rq'] = null;
        // 执行查询
        $orderList = \db('工单_基本资料')->alias('j')
            ->join('工单_印件资料 y', 'j.订单编号 = y.订单编号')
            ->field('j.Sys_rq, y.订单编号, j.落货日期, j.生产款号, j.款式, SUM(y.sctotal) as 裁剪总数, SUM(y.zdtotal) as 制单总数,j.gd_statu,j.客户编号')
            ->group('y.订单编号')
            ->order('y.订单编号 desc')
            ->where($where)
            ->select();
        $orderIds = array_column($orderList, '订单编号');

        // 通过订单编号关联设备_产量计酬表，获取工序名称和数量，并进行分组和汇总
        $wheres['a.mod_rq'] = null;
        $wheres['j.Mod_rq'] = null;
        $processList = \db('设备_产量计酬')
            ->alias('a')
            ->join('工单_基本资料 j', 'a.订单编号 = j.订单编号')
            ->whereIn('a.订单编号', $orderIds)  // 只查询符合条件的订单编号
            ->field('a.订单编号, a.工序名称, 
                SUM(a.数量) as 总数量,SUM(a.s_num) as 上报数量,a.mod_rq')
            ->where($wheres)
            ->order('a.订单编号 desc')
            ->group('a.订单编号, a.工序名称')  // 按订单编号和工序名称分组
            ->select();

        // 合并两个结果
        $data = [];
        foreach ($orderList as $key => $order) {
            // 去掉落货日期的时间部分，只保留日期
            $orderDate = substr($order['落货日期'], 0, 10);  // 提取前10位
            //放入结果
            $data[$key] = [
                '订单编号' => $order['订单编号'],
                '落货日期' => $order['落货日期'],
                '生产款号' => $order['生产款号'],
                '款式' => $order['款式'],
                '客户编号' => $order['客户编号'],
                '订单状态' => $order['gd_statu'],
                '裁剪总数' => $order['裁剪总数'],
                '制单总数' => $order['制单总数'],
                '日期' => substr($order['Sys_rq'], 0, 7)
            ];
            //找到该订单编号对应的工序名称和数量
            //裁剪、车缝计算数量,其他计算s_num合计
            foreach ($processList as $process) {
                if($process['工序名称'] == '裁剪' || $process['工序名称'] == '车缝'){
                    if ($process['订单编号'] === $order['订单编号']) {
                        // 将工序名称和数量加入到结果中
                        $data[$key][$process['工序名称']] = $process['总数量'];
                    }
                }else{
                    if ($process['订单编号'] === $order['订单编号']) {
                        // 将工序名称和数量加入到结果中
                        $data[$key][$process['工序名称']] = $process['上报数量'];
                    }
                }

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

    /**
     * 订单状态及样衣批核-左侧菜单
     */
    public function dateList()
    {

    }
    /**
     * 车缝派单菜单
     * @return void
     */
    public function CfmachineList()
    {
        if ($this->request->isGet() === false) {
            $this->error('请求错误');
        }

        // 查询所有生产工序为"车缝"的设备编号和设备编组
        $machineList = \db('设备_基本资料')
            ->where('生产工序', '车缝')
            ->field('设备编号, 设备编组')
            ->order('设备编号') // 按设备编号排序
            ->select();

        // 如果没有设备，直接返回空结果
        if (empty($machineList)) {
            $this->success('成功', []);
        }

        // 提取所有设备编号
        $machineCodes = array_column($machineList, '设备编号');

        // 将设备列表转换为关联数组，便于快速查找设备编组
        $machineMap = [];
        foreach ($machineList as $machine) {
            $machineMap[$machine['设备编号']] = $machine['设备编组'];
        }

        // 一次性查询所有设备的产量计酬数据
        $allOrders = \db('设备_产量计酬')
            ->where('sczl_jtbh', 'in', $machineCodes)
            ->where('mod_rq', null)
            ->field('sczl_jtbh, 订单编号, sys_rq')
            ->select();

        // 按设备编号和月份分组统计订单数量
        $machineMonthlyOrders = [];
        foreach ($allOrders as $order) {
            $machineCode = $order['sczl_jtbh'];
            $yearMonth = date('Ym', strtotime($order['sys_rq']));

            if (!isset($machineMonthlyOrders[$machineCode])) {
                $machineMonthlyOrders[$machineCode] = [];
            }

            if (!isset($machineMonthlyOrders[$machineCode][$yearMonth])) {
                $machineMonthlyOrders[$machineCode][$yearMonth] = [];
            }

            // 使用数组键自动去重订单编号
            $machineMonthlyOrders[$machineCode][$yearMonth][$order['订单编号']] = true;
        }

        // 构建返回结果
        $result = [];
        foreach ($machineMonthlyOrders as $machineCode => $monthlyOrders) {
            $machineGroup = $machineMap[$machineCode];

            foreach ($monthlyOrders as $yearMonth => $orderMap) {
                $workOrderCount = count($orderMap); // 自动去重后的订单数量

                if (!isset($result[$yearMonth])) {
                    $result[$yearMonth] = [];
                }

                // 使用关联数组键自动去重设备
                $deviceKey = $machineCode . '【' . $machineGroup . ' 生产中：' . $workOrderCount . '】';
                $result[$yearMonth][$deviceKey] = true;
            }
        }

        // 转换为索引数组
        foreach ($result as &$monthDevices) {
            $monthDevices = array_keys($monthDevices);
            // 按设备编号排序
            sort($monthDevices);
        }

        // 按月份排序，确保最新的月份在前面
        krsort($result);

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

    /**
     * 车缝派单列表
     */
    public function CfdataList(){
        if ($this->request->isGet() === false) {
            $this->error('请求错误');
        }
        $param = $this->request->param();
        $search = input('search', '');

        // 只有当没有搜索参数时，才验证machine和date参数
        if (empty($search) && (empty($param['machine']) || empty($param['date']))) {
            $this->error('参数错误');
        }

        $where = [];

        // 添加搜索条件
        if (!empty($search)) {
            $where['c.订单编号|j.生产款号|j.款式'] = ['like', '%' . $search . '%'];
        }

        // 查询设备产量计酬与工单基本资料的关联数据
        $query = \db('设备_产量计酬')->alias('c')
            ->join('工单_基本资料 j', 'c.订单编号 = j.订单编号', 'left')
            ->where('c.mod_rq', null)
            ->where('j.Mod_rq', null)
            ->where('c.工序名称', '车缝') // 只统计工序名称为车缝的数据
            ->where($where);

        // 添加machine条件（如果提供）
        if (!empty($param['machine'])) {
            $query->where('c.sczl_jtbh', $param['machine']);
        }

        // 添加日期范围条件（如果提供）
        if (!empty($param['date'])) {
            // 将传入的 YYYYMM 格式日期转换为 YYYY-MM-01
            $year = substr($param['date'], 0, 4);
            $month = substr($param['date'], 4, 2);
            $startDate = "$year-$month-01 00:00:00";
            $endDate = date("Y-m-t 23:59:59", strtotime($startDate)); // 获取该月的最后一天
            $query->where('c.sczl_rq', '>=', $startDate)
                  ->where('c.sczl_rq', '<=', $endDate);
        }

        // 执行查询
        $list = $query->field('
            c.订单编号, c.款号 as 生产款号, j.款式, j.客户编号,
            CASE 
                WHEN c.工序名称 IN ("裁剪", "车缝") THEN sum(c.数量)
                ELSE sum(c.s_num )
            END as 完工数量,
            LEFT(j.落货日期, 10) as 落货日期,j.订单数量 as 制单数,
            LEFT(c.sczl_rq, 7) as 创建时间, j.gd_statu as 工单状态
        ')
        ->group('c.订单编号')
        ->select();

        $this->success('请求成功', ['table' => $list, 'length' => count($list)]);
    }


    //车缝派单删除
    public function CfdataDel()
    {
        if ($this->request->isGet() === false)
        {
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $sql = \db('工单_排程班次')
            ->where('UniqId',$param['UniqId'])
            ->fetchSql(true)
            ->update(['mod_rq'=>date('Y-m-d H:i:s',time())]);
        $res = \db()->query($sql);
        if ($res !== false){
            $this->success('删除成功');
        }else{
            $this->error('删除失败');
        }
    }

    //车缝派单数据
    public function CfdataAllList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $list = \db('工单_排程班次')
            ->where('mod_rq',null)
            ->order('sys_rq desc')
            ->field('订单编号,子订单编号,班组编号,sys_rq as 创建时间,sys_id as 创建人员,UniqId')
            ->group('子订单编号')
            ->select();
        $this->success('成功',$list);
    }

     //获取产量计酬日期节点（用于菜单栏）
public function getDateNodes()
{
    if ($this->request->isGet() === false) {
        $this->error('请求错误');
    }

    //获取所有不重复的年份
    $yearList = \db('设备_产量计酬')
        ->field("DISTINCT DATE_FORMAT(sczl_rq, '%Y') as year")
        ->where('sczl_rq', 'not null')
        ->order('year', 'desc')
        ->select();

    foreach ($yearList as $key => $year) {
        //根据年份获取不重复的月份
        $monthList = \db('设备_产量计酬')
            ->field("DISTINCT DATE_FORMAT(sczl_rq, '%m') as month")
            ->where('sczl_rq', 'not null')
            ->where("DATE_FORMAT(sczl_rq, '%Y') = '{$year['year']}'")
            ->order('month', 'asc')
            ->select();

        foreach ($monthList as $k => $month) {
            //根据年份和月份获取不重复的日期
            $dayList = \db('设备_产量计酬')
                ->field("DISTINCT DATE_FORMAT(sczl_rq, '%d') as day")
                ->where('sczl_rq', 'not null')
                ->where("DATE_FORMAT(sczl_rq, '%Y') = '{$year['year']}'")
                ->where("DATE_FORMAT(sczl_rq, '%m') = '{$month['month']}'")
                ->order('day', 'asc')
                ->select();

            $monthList[$k]['day_list'] = $dayList;
        }

        $yearList[$key]['month_list'] = $monthList;
    }

    $this->success('获取成功', $yearList);
}
//获取产量计酬详情数据
public function getCfdataDetail()
{
    if ($this->request->isGet() === false) {
        $this->error('请求错误');
    }

    $param = $this->request->param();
    if (empty($param['year']) || empty($param['month']) || empty($param['day'])) {
        $this->error('请选择日期');
    }

    //拼接日期进行筛选
    $date = $param['year'] . '-' . $param['month'] . '-' . $param['day'];

    //查询数据
    $list = \db('设备_产量计酬')
        ->where("DATE_FORMAT(sczl_rq, '%Y-%m-%d') = '{$date}'")
        ->field('订单编号, 子订单编号, 款号, 尺码, 数量, sczl_bh')
        ->select();

    if (empty($list)) {
        $this->success('暂无数据', []);
    }

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