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

<?php

namespace app\api\controller;


use app\common\controller\Api;
use Monolog\Handler\IFTTTHandler;
use PhpOffice\PhpSpreadsheet\Cell\Coordinate;
use think\Db;
use think\Request;
use PhpOffice\PhpSpreadsheet\IOFactory;

/**
 * 工单资料管理
 */
class WorkOrder extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];

    /**
     * 工单资料菜单列表
     *
     * @ApiMethod (GET)
     * @return false|string
     * @throws \think\Exception
     */
    public function DataList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
//        if (isset($param['sort'])){
//            $where['工单分类'] = 2;
//        }else{
//            $where['工单分类'] = ['in',[1,3]];
//        }
        $where['行号'] = ['in',['1','10']];
        //获取总计划中数量和总生产中数量
        $productingAll = \db('工单_基本资料')->where($where)->where('成品代号','<>','')->where('行号','1')->where('gd_statu','2-生产中')->cache(true)->count();
        $progressAll = \db('工单_基本资料')->where($where)->where('成品代号','<>','')->where('行号','1')->where('gd_statu','3-计划中')->cache(true)->count();
        $data = [
            'productingAll' => $productingAll,
            'progressAll' => $progressAll,
//            '客户编号' => []
        ];
        $list = \db('产品_基本资料')
            ->where('客户编号','<>','')
            ->field('客户编号,客户名称')
            ->group('客户编号,客户名称')
            ->order('客户编号')
            ->select();
        if (empty($list)){
            $this->success('',[]);
        }
        $data['翌星工单']=$data['MN工单']=[];
        foreach ($list as $key=>$value){
            $value['客户编号'] = rtrim($value['客户编号']);
            //这条sql查出来的数据可能不对，试一下以下sql
            $productIng = \db('工单_基本资料')->where($where)->where('Gd_cpdh|成品代号','LIKE',rtrim($value['客户编号']).'%')->where('gd_statu','2-生产中')->count();
            $proGress = \db('工单_基本资料')->where($where)->where('Gd_cpdh|成品代号','LIKE',rtrim($value['客户编号']).'%')->where('gd_statu','3-计划中')->count();
            $string = '';
            if ($productIng != 0){
                $string = $string."生产中:".$productIng;
            }
            if ($proGress != 0){
                $string = $string."计划中:".$proGress;
            }
            if ($string !== ''){
                $name = $value['客户编号'].'【'.$string.'】'.rtrim($value['客户名称']);
                if (strpos($value['客户编号'],'J') !== false || strpos($value['客户编号'],'Y') !== false){
                    array_push($data['翌星工单'],$name);
                }else{
                    array_push($data['MN工单'],$name);
                }
//                array_push($data['客户编号'],$name);
            }
//            else{
//                $name = $value['客户编号'].$value['客户名称'];
//                if (strpos($value['客户编号'],'J') !== false){
//                    array_push($data['糊盒工单'],$name);
//                }else{
//                    array_push($data['印刷工单'],$name);
//                }
//            }
        }
        $this->success('成功',$data);
    }

    /**
     * 工单基本资料列表
     * @ApiMethod (GET)
     * @param string $limit 查询长度
     * @param string $Gd_khdh 客户代号
     * @param string $startTime 接单日期开始时间
     * @param string $endTime  接单日期结束时间
     * @return \think\response\Json
     * @throws \think\exception\DbException
     */
    public function WorkList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $search = input('search');
        $clientNumber = input('Gd_khdh');
        $startTime = input('start');
        $endTime = input('end');
        $page = input('page');
        $limit = input('limit');
        $param = $this->request->param();
        if (isset($param['sort'])){
            $sort = 2;
        }else{
            $sort = 1;
        }
        $where = [];
        if (!empty($clientNumber)){
            if (substr($clientNumber,0,1) !== 'Y' && substr($clientNumber,0,1) !== 'J')
            {
                $clientNumber = substr($clientNumber,0,4);
            }
            if ($clientNumber === 'Y1401'){
                $where['Gd_cpdh'] = ['like',$clientNumber.'%'];
            }else{
                $where['成品代号'] = ['like',$clientNumber.'%'];
            }
        }

        if (!empty($workOrder)){
            $where['Gd_gdbh'] = $workOrder;
        }
        if (!empty($productCode)){
            $where['Gd_cpdh'] = $productCode;
        }
        if (!empty($search)){
            $where['Gd_lx|Gd_gdbh|Gd_客户代号|Gd_客户名称|Gd_khdh|Gd_khmc|Gd_cpdh|Gd_cpmc|成品代号|成品名称|产品版本号'] = ['like','%'.$search.'%'];
        }
        if (!empty($startTime) && !empty($endTime)){
            $where['接单日期'] = ['between',[$startTime,$endTime]];
        }
        $total = \db('工单_基本资料')->where($where)->distinct(true)->field('Gd_gdbh')->count();
        $list = \db('工单_基本资料')
            ->where($where)
            ->order('Gd_statu desc')
            ->limit(($page-1)*$limit,$limit)
            ->group('Gd_gdbh')
            ->select();
        //工单基本资料数据整理
        $data = [];
        foreach ($list as $key=>$value){
            $data[$key] = [
                '工单编号' => rtrim($value['Gd_gdbh']),
                '生产分类' => rtrim($value['Gd_生产分类']),
                '销售订单号' => rtrim($value['销售订单号']),
                '产品代号' => rtrim($value['成品代号']),
                '产品名称' => rtrim($value['成品名称']),
                '订单数量' => floatval($value['订单数量']),
                '单位' => rtrim($value['计量单位']),
                '折合大箱' => rtrim((int)$value['投料大箱']),
                '投料率' => rtrim($value['投料率']),
                '平均合格率' => '',
                '开单日期' => date('Y-m-d',strtotime(rtrim($value['接单日期']))),
                '交货日期' => date('Y-m-d',strtotime(rtrim($value['交货日期']))),
                '工单类型' => rtrim($value['Gd_lx']),
                '工单状态' => rtrim($value['gd_statu']),
                '当前生产工序' => '',
                '产量提交时间' =>  '',
                '建档用户' => rtrim($value['Sys_id']),
                '建档时间' => rtrim($value['Sys_rq']),
                '更新时间' => rtrim($value['Mod_rq']),
                'Uniqid' => rtrim($value['Uniqid'])
            ];

            $number = \db('工单_工艺资料')->where('Gy0_gdbh',$data[$key]['工单编号'])->count();
            if ($number === 0){
                $data[$key]['status'] = '*';
            }else{
                $data[$key]['status'] = '';
            }
        }
        $this->success('成功',['data'=>$data,'total'=>$total]);
    }

    /**
     * 工单详情
     * @ApiMethod  (GET)
     * @param  void
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function workOrderListDetail()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $Gd_gdbh = input('Gd_gdbh');
        $param = $this->request->param();
        if (empty($Gd_gdbh)){
            $this->error('参数错误');
        }
        if (isset($param['sort'])){
            $where['yj_Yjno'] = ['>=','10'];
        }else{
            $where['yj_Yjno'] = ['<','10'];
        }
        $data = [];
        //印件资料
        $printList = \db('工单_印件资料')
            ->where('Yj_Gdbh',$Gd_gdbh)
            ->where($where)
            ->select();
        if (!empty($printList)){
            foreach ($printList as $key=>$value){
                $data['printList'][$key] = [
                    '印件号' => rtrim($value['yj_Yjno']),
                    '印件代号' => rtrim($value['yj_Yjdh']),
                    '印件名称' => rtrim($value['yj_yjmc']),
                    '纸张代号' => rtrim($value['yj_zzdh']),
                    '纸张名称' => rtrim($value['yj_zzmc']),
                    '投料规格' => rtrim($value['yj_tlgg']),
                    '平张投料' => rtrim($value['yj_平张投料']),
                    '开料规格' => rtrim($value['yj_klgg']),
                    '开数*联数' => rtrim($value['yj_ks']).'*'.rtrim($value['yj_ls']),
                    '建档用户' => rtrim($value['Sys_id']),
                    '建档时间' => rtrim($value['Sys_rq']),
                    '更新时间' => rtrim($value['Mod_rq']),
                    'zzdh1'  => rtrim($value['yj_zzdh1']),
                    'zzdh2'  => rtrim($value['yj_zzdh2']),
                    'zzdh3'  => rtrim($value['yj_zzdh3']),
                    'zzdh4'  => rtrim($value['yj_zzdh4']),
                    'zzmc1'  => rtrim($value['yj_zzmc1']),
                    'zzmc2'  => rtrim($value['yj_zzmc2']),
                    'zzmc3'  => rtrim($value['yj_zzmc3']),
                    'zzmc4'  => rtrim($value['yj_zzmc4']),
                    '订单数量' => rtrim($value['yj_成品数量']),
                    '万小张' => rtrim($value['yj_实际投料']),
                    '开数' => rtrim($value['yj_ks']),
                    '联数' => rtrim($value['yj_ls']),
                    '核算规格' => rtrim($value['Yj_核算规格']),
                    '备注' => rtrim($value['yj_desc']),
                    'Uniqid' => rtrim($value['Uniqid'])
                ];
            }
        }else{
            $data['printList'] = [];
        }

        //工艺资料
        if (isset($param['sort'])){
            $Prowhere['Gy0_yjno'] = ['>=','10'];
        }else{
            $Prowhere['Gy0_yjno'] = ['<','10'];
        }
        $processList = \db('工单_工艺资料')
            ->where('Gy0_gdbh',$Gd_gdbh)
            ->where($Prowhere)
            ->order('Gy0_yjno,Gy0_gxh')
            ->select();
        if (!empty($processList)){
            foreach ($processList as $key=>$value){
                if ($value['Gy0_yjno']<10){
                    $value['Gy0_yjno'] = '0'.$value['Gy0_yjno'];
                }
                if ($value['Gy0_gxh']<10){
                    $value['Gy0_gxh'] = '0'.$value['Gy0_gxh'];
                }
                if (rtrim($value['Gy0_shdh']) == '' || $value['Gy0_计划接货数'] == 0){
                    $number = 0;
                }else{
                    $number = round(((int)$value['Gy0_计划损耗']/(int)($value['Gy0_计划接货数']))*100,2).'%';
                }
                if ($value['PD_WG'] !== '1900-01-01 00:00:00'){
                    $status = '已完工';
                }else{
                    $status = '未完工';
                }
                $data['processList'][$key] = [
                    '重点工序' => rtrim($value['重点工序']),
                    '印件-工序' => rtrim($value['Gy0_yjno']).'-'.rtrim($value['Gy0_gxh']),
                    '备选工序' => rtrim($value['备选工序']),
                    '工序名称' => rtrim($value['Gy0_gxmc']).'【'.rtrim($value['Add_gxmc']).'】',
                    '印件号' => rtrim($value['Gy0_yjno']),
                    '工序号' => rtrim($value['Gy0_gxh']),
                    '工艺名称' => rtrim($value['Gy0_gxmc']),
                    'gxmc' => rtrim($value['Add_gxmc']),
                    '计划产量' => $value['Gy0_计划接货数'],
                    '基础损耗' => rtrim($value['Gy0_Rate0']),
                    '损耗率' => rtrim($value['Gy0_Rate1']),
                    '机台编号' => rtrim($value['Gy0_sbbh']),
                    '报废定额' => rtrim($value['Gy0_计划损耗']),
                    '计损色数' => rtrim($value['Gy0_ms']),
                    '允损比例' => $number,
                    '难度系数' => isset($value['工价系数'])?rtrim($value['工价系数']):'',
                    '损耗系数' => isset($value['损耗系数'])?rtrim($value['损耗系数']):'',
                    '人工检_次品板' => (int)$value['人工检_次品板']=0?'':$value['人工检_次品板'],
                    '人工检_废检' => (int)$value['人工检_废检']=0?'':$value['人工检_废检'],
                    '机检_正品板' => (int)$value['机检_正品板']=0?'':$value['机检_正品板'],
                    '机检_次品板' => (int)$value['机检_次品板']=0?'':$value['机检_次品板'],
                    '机检_废检' => (int)$value['机检_废检']=0?'':$value['机检_废检'],
                    '开数*联数' => rtrim($value['Gy0_ks']).'*'.rtrim($value['Gy0_ls']),
                    '备注' => isset($value['工序备注'])?rtrim($value['工序备注']):'',
                    '印刷方式' => isset($value['印刷方式'])?rtrim($value['印刷方式']):'',
                    '版距' => isset($value['版距'])?rtrim($value['版距']):'',
                    '建档用户' => rtrim($value['Sys_id']),
                    '建档日期' => isset($value['Sys_rq'])?rtrim($value['Sys_rq']):'',
                    '更新时间' => isset($value['Mod_rq'])?rtrim($value['Mod_rq']):'',
                    '车间名称' => rtrim($value['Gy0_SITE']),
                    '质量要求' => rtrim($value['质量要求']),
                    '质量隐患' => rtrim($value['质量隐患']),
                    '开数' => rtrim($value['Gy0_ks']),
                    '联数' => rtrim($value['Gy0_ls']),
                    'UniqId' => rtrim($value['UniqId']),
                    'shdh' => rtrim($value['Gy0_shdh']),
                    '辅助工时' => rtrim($value['Gy0_辅助工时']),
                    '小时产能' => rtrim($value['Gy0_小时产能']),
                    'status' => $status
                ];
            }
        }else{
            $data['processList'] = [];
        }

        //BOM资料
        $field = 'rtrim(BOM_方案) as 方案,rtrim(BOM_物料编码) as 物料编号,rtrim(BOM_物料名称) as 物料名称,BOM_投料单位,
        BOM_投入数,BOM_产出数,BOM_产出单位,rtrim(BOM_计划用量) as 计划用量,rtrim(Sys_ID) as 建档用户,rtrim(Sys_rq) as 建档时间,rtrim(Mod_rq) as 更新时间';
        $bomList = \db('工单_bom资料')
            ->where('BOM_工单编号',$Gd_gdbh)
            ->field($field)
            ->select();
        if (!empty($bomList)){
            foreach ($bomList as $key=>$value){
                $bomList[$key]['消耗定量'] = rtrim($value['BOM_投入数']).rtrim($value['BOM_投料单位']).'/'.rtrim($value['BOM_产出数']).rtrim($value['BOM_产出单位']);
                unset($bomList[$key]['BOM_投料单位'],$bomList[$key]['BOM_投入数'],$bomList[$key]['BOM_产出数'],$bomList[$key]['BOM_产出单位']);
                $bomList[$key]['计划用量'] = rtrim((float)$value['计划用量']);
            }
            $data['BOM'] = $bomList;
        }else{
            $data['BOM'] = [];
        }

        //工单附件资料
        $jsRes = db('工单_相关附件')
            ->where('关联编号','like','%'.$Gd_gdbh.'%')
            ->select();
        if (!empty($jsRes)){
            foreach ($jsRes as $key=>&$value){
                if(mb_detect_encoding($value['附件内容'])!='ASCII'){
                    $value['附件内容'] = '';
                }
            }
            $data['jsData'] = $jsRes;
        }else{
            $data['jsData'] = [];
        }

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

    /**
     * 编辑页面展示
     * @ApiMethod (GET)
     * @param string $workOrder   工单编号
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function DataCorrection()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $workOrder = input('Gd_gdbh');
        if (empty($workOrder)){
            $this->error('参数错误');
        }
        $field = 'rtrim(Gd_lx) as 重点工单,rtrim(Gd_gdbh) as 工单编号,rtrim(Gd_生产分类) as 生产类型,rtrim(Gd_khdh) as 客户代号,rtrim(Gd_客户名称) as 客户名称,
        rtrim(Gd_cpdh) as 印件代号,rtrim(Gd_cpmc) as 印件名称,rtrim(成品代号) as 产品代号,rtrim(成品名称) as 产品名称,rtrim(开单日期) as 开单日期,rtrim(订单数量) as 订单数量,rtrim(交货日期) as 交货日期,
        rtrim(投料率) as 投料率,rtrim(实际投料) as 万小张,rtrim(计量单位) as 单位,rtrim(投料大箱) as 投料大箱,rtrim(排产时库存) as 库存大箱,rtrim(警语版面) as 警语版面,
        rtrim(销售订单号) as 销售订单号,rtrim(产品版本号) as 版本号,rtrim(客户ERP编码) as 客户ERP编码,rtrim(码源数量) as 码源数量,rtrim(进程备注) as 进程备注,rtrim(Gd_desc) as 备注,rtrim(Uniqid) as Uniqid,rtrim(计划投料) as 平张投料';
        $list = \db('工单_基本资料')->where('Gd_gdbh',$workOrder)->field($field)->find(); 
        if (empty($list)){
            $this->error('未找到该工单信息');
        }
        $printData = \db('工单_印件资料')
            ->where('Yj_Gdbh',$workOrder)
            ->field('rtrim(yj_yjmc) as 印件名称,rtrim(yj_Yjdh) as 印件代号,rtrim(Uniqid) as id')
            ->cache(true,84600)
            ->find();
        if (empty($printData)){
            $list['印件名称'] = '';
            $list['印件代号'] = '';
            $list['印件ID'] = '';
        }else{
            $list['印件名称'] = $printData['印件名称'];
            $list['印件代号'] = $printData['印件代号'];
            $list['印件ID'] = $printData['id'];
        }
        $this->success('成功',$list);
    }

    /**
     * 工单资料修改
     * @ApiMethod (POST)
     * @param  void
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */

    public function WorkOrderEdit()
    {
        if (Request::instance()->isPost() === false){
            $this->error('请求错误');
        }
        $param = Request::instance()->post();
        if (empty($param) || isset($param['Uniqid']) === false){
            $this->error('参数错误');
        }
        // 先查询原始数据用于日志对比
        $oldData = \db('工单_基本资料')
            ->where('Uniqid', $param['Uniqid'])
            ->find();
        //配置修改数据
        $row = [
            'Gd_lx' => isset($param['lx'])?$param['lx']:'',
            '开单日期' => isset($param['kdrq'])?$param['kdrq']:'',
            'Gd_gdbh' => isset($param['gdbh'])?$param['gdbh']:'',
            'Gd_生产分类' => isset($param['scfl'])?$param['scfl']:'',
            'Gd_客户代号' => isset($param['khdh'])?$param['khdh']:'',
            'Gd_客户名称' => isset($param['khmc'])?$param['khmc']:'',
            '成品代号' => isset($param['cpdh'])?$param['cpdh']:'',
            '成品名称' => isset($param['cpmc'])?$param['cpmc']:'',
            '订单数量' => isset($param['ddsl'])?$param['ddsl']:'',
            '交货日期' => isset($param['jhrq'])?$param['jhrq']:'',
            '投料率' => isset($param['tll'])?$param['tll']:'',
            '计划投料' => isset($param['jhtl'])?$param['jhtl']:'',
            '实际投料' => isset($param['sjtl'])?$param['sjtl']:'',
            '计量单位' => isset($param['jldw'])?$param['jldw']:'',
            '投料大箱' => isset($param['tldx'])?$param['tldx']:'',
            '销售订单号' => isset($param['xsddh'])?$param['xsddh']:'',
            '警语版面' => isset($param['jymb'])?$param['jymb']:'',
            '产品版本号' => isset($param['bbh'])?$param['bbh']:'',
            '客户ERP编码' => isset($param['erp'])?$param['erp']:'',
            '码源数量' => isset($param['ymsl'])?$param['ymsl']:'',
            '进程备注' => isset($param['jcbz'])?$param['jcbz']:'',
            'Gd_desc' => isset($param['desc'])?$param['desc']:'',
            '排产时库存' => isset($param['kc'])?$param['kc']:'',
            '平均合格率' => isset($param['avg'])?$param['avg']:'',
        ];
        // 修改工单主信息时记录变更
        $changes = [];
        foreach ($row as $field => $newValue) {
            $oldValue = $oldData[$field] ?? null;
            if ($oldValue != $newValue) {
                $changes[] = [
                    'field' => $field,
                    'old'   => $oldValue,
                    'new'   => $newValue
                ];
            }
        }
        //获取印件资料
        $printCode = \db('工单_印件资料')
            ->where('Uniqid',$param['printID'])
            ->value('yj_Yjno');
        if (!empty($printCode)){
            if ((int)$param['jhtl'] >0){
                //修改工单工艺计划产量
                $result = $this->PlannedProcessYield($param['gdbh'],$printCode,0,$param['jhtl']);
                if ($result === false){
                    $this->success('分配工序计划产量失败');
                }
            }

            //修改印件信息
            $printSql = \db('工单_印件资料')
                ->where('Uniqid',$param['printID'])
                ->fetchSql(true)
                ->update(['Yj_Gdbh'=>$param['gdbh'],'yj_yjmc'=>$param['yjmc'],'yj_Yjdh'=>$param['yjdh'],'yj_平张投料'=>$param['jhtl']]);
            $printRes = Db::query($printSql);
        }
        //修改工单信息
        $sql = \db('工单_基本资料')->where('Uniqid',$param['Uniqid'])->fetchSql(true)->update($row);
        $res = Db::query($sql);
        // 记录修改日志（仅当有字段变更时）
        if (!empty($changes)) {
            $logData = [];
            foreach ($changes as $change) {
                $logData[] = [
                    'Gd_gdbh'      => $oldData['Gd_gdbh'], // 使用原始工单编号
                    'ModifyUser'   => $param['sys_id'],
                    'ModifyTime'   => date('Y-m-d H:i:s'),
                    'FieldName'    => $change['field'],
                    'OldValue'     => $change['old'],
                    'NewValue'     => $change['new'],
                    'ModifySource' => '工单编辑'
                ];
            }
            $logSql = \db('系统操作日志表')->fetchSql(true)->insertAll($logData);
            $result = \db()->query($logSql);
        }
        //修改订单数量该工单下的订单数量
        //1. 查询该id下的工单编号, 防止其手动修改工单编号导致条件错误
        $gdbh = \db('工单_基本资料')->where('Uniqid',$param['Uniqid'])->value('Gd_gdbh');
        // 获取修改前的订单数量
        $oldQuantity = \db('工单_基本资料')
            ->where('Gd_gdbh', $gdbh)
            ->value('订单数量');
        //2. 根据查出的工单编号修改订单数量
        $sql = \db('工单_基本资料')->where('Gd_gdbh',$param['gdbh'])->fetchSql(true)->update(['订单数量'=>$row['订单数量']]);
        $res1 = Db::query($sql);
        // 记录订单数量单独变更
        if ($res1 && $oldQuantity != $row['订单数量']) {
            $logSql = \db('系统操作日志表')->fetchSql(true)->insert([
                'Gd_gdbh'      => $gdbh,
                'ModifyUser'   => $param['sys_id'],
                'ModifyTime'   => date('Y-m-d H:i:s'),
                'FieldName'    => '订单数量',
                'OldValue'     => $oldQuantity,
                'NewValue'     => $row['订单数量'],
                'ModifySource' => '数量修正'
            ]);
            $result = \db()->query($logSql);
        }
        if ($res !== false && $res1 !== false){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }


    /**
     * U8投料试算
     * @ApiMethod (GET)
     * @param string  $processCode   产品编号
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */

    public function U8Trial()
    {
        if ($this->request->isGet() === false)
        {
            $this->error('请求错误');
        }
        $productCode = input('productCode');
        if (empty($productCode)){
            $this->error('参数错误');
        }
        $field = 'rtrim(Gy0_cpdh) as 产品代号,rtrim(Gy0_yjno) as 印件号,rtrim(Gy0_gxh) as 工序号,rtrim(gy0_gxmc) as gxmc,rtrim(Add_gxmc) as add_gxmc,
        rtrim(Gy0_Ms) as 墨色数,rtrim(Gy0_shdh) as 损耗代号,rtrim(损耗系数) as 损耗系数,rtrim(Gy0_ls) as 加工联数';
        $list = \db('产品_工艺资料')->where('Gy0_cpdh',$productCode)->field($field)->select();
        if (empty($list)){
            $this->success('未找到该产品工序');
        }
        foreach ($list as $key=>$value){
            $data = \db('dic_lzsh')->where('sys_bh',$value['损耗代号'])->field('rtrim(sys_rate0) as rate0,rtrim(sys_rate1) as rate1')->cache(true)->find();
            $list[$key]['调机损耗'] = isset($data['rate0'])?$data['rate0']:'';
            $list[$key]['运行损耗率'] = isset($data['rate1'])?$data['rate1']:'';
            if ($value['add_gxmc'] !== ''){
                $list[$key]['工序名称'] = $value['gxmc'].'【'.$value['add_gxmc'].'】';
            }else{
                $list[$key]['工序名称'] = $value['gxmc'];
            }
            unset($list[$key]['gxmc'],$list[$key]['add_gxmc']);
        }
        $this->success('成功',$list);
    }


    /**
     * 引用产品资料->获取产品资料
     * @ApiMethod  (GET)
     * @param  string $workOrder   工单编号
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */

    public function ProductInformation()
    {
        if ($this->request->isGet() === false)
        {
            $this->error('请求错误');
        }
        $workOrder = input('workOrder');
        if (empty($workOrder)){
            $this->error('参数错误');
        }
        $field = 'rtrim(Gd_gdbh) as 工单编号,rtrim(Gd_客户名称) as 客户名称,rtrim(成品代号) as 产品代号,rtrim(成品名称) as 产品名称';
        $Detail = \db('工单_基本资料')->where('Gd_gdbh',$workOrder)->field($field)->find();
        if (empty($Detail)){
            $this->success('未找到工单信息');
        }
        $Detail['客户代号'] = substr($Detail['产品代号'],0,4);
        $this->success('成功',$Detail);
    }

    /**
     * 引用产品资料->复制产品工艺资料
     * @ApiMethod  (POST)
     * @param string $oldWorkOrder   被复制工单编号
     * @param string $newWorkOrder   复制工单编号
     * @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 ProductInformationEdit()
    {
        if (Request::instance()->isPost() === false)
        {
            $this->error('请求错误');
        }
        $oldWorkOrder = input('oldWorkOrder');
        $newWorkOrder = input('newWorkOrder');
        if (empty($oldWorkOrder) || empty($newWorkOrder))
        {
            $this->error('参数错误');
        }
        $lastId = \db('工单_工艺资料')->order('UniqId desc')->value('UniqId');
        if ($lastId<10000000){
            $lastId = 10000000;
        }else{
            $lastId = $lastId + 1;
        }
        //获取原工单工艺资料
        $oldProcessData = \db('工单_工艺资料')->where('Gy0_gdbh',$newWorkOrder)->select();
        $ProsessUniqId = \db('工单_工艺资料')->field('UniqId')->order('UniqId desc')->find();
        foreach ($oldProcessData as $k=>$v){
            $oldProcessData[$k]['Gy0_gdbh']  = $oldWorkOrder;
            $oldProcessData[$k]['Sys_id'] = '';
            $oldProcessData[$k]['Gy0_sj1'] = '1900-01-01 00:00:00';
            $oldProcessData[$k]['Gy0_sj2'] = '1900-01-01 00:00:00';
            $oldProcessData[$k]['UniqId'] = $lastId + $k;
            $oldProcessData[$k]['PD_WG'] = '1900-01-01 00:00:00';
        }
        if (\db('工单_工艺资料')->where('Gy0_gdbh',$oldWorkOrder)->find()){
            \db('工单_工艺资料')->where('Gy0_gdbh',$oldWorkOrder)->delete();
        }
        //获取原工单印件资料
        $lastUniqId = \db('工单_印件资料')->order('UniqId desc')->value('UniqId');
        if ($lastUniqId<1000000){
            $lastUniqId = 1000000;
        }else{
            $lastUniqId = $lastUniqId + 1;
        }
        $oldPrintData = \db('工单_印件资料')->where('Yj_Gdbh',$newWorkOrder)->select();
        $PrintUniqId = \db('工单_印件资料')->field('Uniqid')->order('Uniqid desc')->find();
        foreach ($oldPrintData as $k=>$v){
            $oldPrintData[$k]['Yj_Gdbh']  = $oldWorkOrder;
            $oldPrintData[$k]['Sys_id'] = '';
            $oldPrintData[$k]['Uniqid'] = $lastUniqId +$k +1;
            $oldPrintData[$k]['质量考核'] = 1;
        }
        if (\db('工单_印件资料')->where('Yj_Gdbh',$oldWorkOrder)->find()){
            \db('工单_印件资料')->where('Yj_Gdbh',$oldWorkOrder)->delete();
        }
        //复制印件、工艺资料
        $ProcessSQL = \db('工单_工艺资料')->fetchSql(true)->insertAll($oldProcessData);
        $ProcessRes = Db::query($ProcessSQL);
        $PrintSQL = \db('工单_印件资料')->fetchSql(true)->insertAll($oldPrintData);
        $PrintRes = Db::query($PrintSQL);
        if ($ProcessRes !== false && $PrintRes !== false){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }


    /**
     * 工艺流程调成->获取当前工单工艺资料
     * @ApiMethod (GET)
     * @param string $workorder  当前工单编号
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function ProcessFlow()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $workOrder = input('workOrder');
        if (empty($workOrder)){
            $this->error('参数错误');
        }
        $list = \db('工单_基本资料')->where('Gd_gdbh',$workOrder)->field('rtrim(成品代号) as 成品编号,rtrim(成品名称) as 成品名称')->find();
        if (empty($list)){
            $this->success('未找到工单信息');
        }
        $filed = 'rtrim(Gy0_方案) as 方案,rtrim(Gy0_yjno) as 印件号,rtrim(Gy0_gxh) as 工序号,rtrim(Gy0_gxmc) as gxmc,rtrim(Add_gxmc) as add_gxmc,
        rtrim(工价系数) as 工价系数,rtrim(损耗系数) as 损耗系数,rtrim(Gy0_ks) as ks,rtrim(Gy0_ls) as ls,rtrim(工序备注) as 备注,rtrim(Gy0_SITE) as 车间,
        rtrim(Gy0_sbbh) as 设备编号,rtrim(Gy0_sbmc) as 设备名称,rtrim(Sys_id) as 建档用户,rtrim(Sys_rq) as 建档时间,rtrim(Mod_rq) as 更新时间,rtrim(UniqId) as UniqId';
        $process = \db('工单_工艺资料')->where('Gy0_gdbh',$workOrder)->cache(true,84600)->field($filed)->select();
        if (empty($process)){
            $this->error('未找到该工单工艺资料');
        }
        foreach ($process as $key=>$value){
            if (isset($value['add_gxmc'])){
                $process[$key]['工序名称'] = $value['gxmc'] . '【'.$value['add_gxmc'].'】';
            }else{
                $process[$key]['工序名称'] = $value['gxmc'];
            }
            $process[$key]['工价系数'] = (float)$value['工价系数'];
            $process[$key]['损耗系数'] = (float)$value['损耗系数'];
            $process[$key]['开数*联数'] = $value['ks'].'*'.$value['ls'];
        }
        $list['process'] = $process;
        $this->success('成功',$list);
    }

    /**
     * 参照工单列表获取
     * @ApiMethod (GET)
     * @param string $workOrder  工单编号
     * @param string $productCode   产品代号
     * @return void
     */
    public function ReferenceWorkOrder()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $productCode = input('productCode');
        $workOrder = input('workOrder');
        if (empty($productCode) || empty($workOrder)){
            $this->error('参数错误');
        }
        $list = \db('工单_基本资料')->where('成品代号',$productCode)->distinct(true)->where('Gd_gdbh','<>',$workOrder)->column('Gd_gdbh');
        if (empty($list)){
            $this->success('未获取该产品其他工单信息');
        }
        $this->success('成功',$list);
    }

    /**
     * 工艺资料复制
     * @ApiMethod (POST)
     * @param  string $oldWorkOrder    被复制工单编号
     * @param  string $newWorkOrder    复制工单编号
     * @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 ProcessCopy()
    {
        if (Request::instance()->isPost() === false){
            $this->error('请求错误');
        }
        $param = Request::instance()->post();
        if (empty($param)){
            $this->error('参数错误');
        }
        $i = 0;
        foreach ($param as $key => $value){
            $sql = \db('工单_工艺资料')
                ->where('UniqId',$value['UniqId'])
                ->fetchSql(true)
                ->update(['Gy0_gxh'=>$value['gxh']]);
            $res = \db()->query($sql);
            if ($res === false){
                $i++;
            }
        }
        if ($i === 0){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
//        $UniqId = [];
//        $lastId = \db('工单_工艺资料')->field('rtrim(UniqId) as id')->order('UniqId desc')->find();
//        if ($lastId['id']>10000000){
//            $lastUniqId = $lastId['id'];
//        }else{
//            $lastUniqId = 10000000;
//        }
//        foreach ($param as $key=>$value){
//            $UniqId[$key] = $value['UniqId'];
//        }
//        $processList = \db('工单_工艺资料')->where('UniqId','in',$UniqId)->select();
//        if (empty($processList)){
//            $this->success('未找到工艺资料');
//        }
//        halt($processList);
//        $data = [];
//        foreach ($param as $key=>$value){
//            foreach ($processList as $k=>$v){
//                if ($value['UniqId'] = $v['UniqId']){
//                    $data[$key] = $v;
//                    $data[$key]['Gy0_gxh'] = $value['gxh'];
//                    $data[$key]['Gy0_gdbh'] = $value['workOrder'];
//                    $data[$key]['UniqId'] = $lastUniqId + $key + 1;
//                }
//            }
//        }
//        $res = \db('工单_工艺资料')->where(['Gy0_gdbh'=>$param[0]['workOrder']])->delete();
//        if ($res !== false){
//            $result = \db('工单_工艺资料')->insertAll($data);
//            if ($result !== false){
//                $this->success('成功');
//            }else{
//                $this->error('失败');
//            }
//        }else{
//            $this->error('失败');
//        }
    }

    /**
     * U8工单列表
     * @ApiMethod (GET)
     * @param  void
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function U8workOrder()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $filed = 'rtrim(Gd_gdbh) as 工单编号,rtrim(行号) as 行号,rtrim(Gd_客户代号) as 客户代号,rtrim(Gd_客户名称) as 客户名称,
        rtrim(成品代号) as 成品代号,rtrim(成品名称) as 成品名称,rtrim(Mod_rq) as 获取日期,rtrim(Uniqid) as 序号';
        $list = \db('工单_基本资料')->where('Gd_gdbh',$param['workOrder'])->field($filed)->select();
        if (empty($list)){
            $this->success('未找到工单');
        }
        $this->success('成功',$list);
    }

    /**
     * U8工单资料删除
     * @param string $workOrder  工单编号
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function U8DataCorrection()
    {
        if($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $workOrder = input('Uniqid');
        if (empty($workOrder)){
            $this->error('参数错误');
        }
        $data = [];
        if (strpos($workOrder,',')){
            $data = explode(',',$workOrder);
        }else{
            $data[0] = $workOrder;
        }
        $res = \db('工单_基本资料')->where('Uniqid','in',$data)->delete();
        if ($res !== false){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }


    /**
     * 产品废检系数调整->质检工艺数据获取
     * @ApiMethod (GET)
     * @param  string  $workOrder   工单编号
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function TestCoefficient()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $workOrder = input('workOrder');
        if (empty($workOrder)){
            $this->error('参数错误');
        }
        $where = [
            'Gy0_gdbh' => $workOrder,
            'Gy0_gxmc' => ['like','%检%']
        ];
        $filed = 'rtrim(Gy0_gdbh) as gdbh,rtrim(Gy0_yjno) as yjno,rtrim(Gy0_gxh) as gxh,rtrim(Gy0_gxmc) as gxmc,rtrim(人工检_正品板) as 人工正品板,
        rtrim(人工检_次品板) as 人工次品板,rtrim(人工检_废检) as 人工废检,rtrim(机检_正品板) as 机检正品板,rtrim(机检_次品板) as 机检次品板,
        rtrim(机检_废检) as 机检废检,rtrim(Gy0_sbbh) as 设备编号,rtrim(Uniqid) as Uniqid';
        $list = \db('工单_工艺资料')->where($where)->field($filed)->select();
        if (empty($list)){
            $this->success('未找到该工单工艺');
        }
        $name = \db('工单_基本资料')
            ->where('Gd_gdbh',$workOrder)
            ->field('rtrim(Gd_cpdh) as 产品代号,rtrim(Gd_khmc) as 客户名称,rtrim(Gd_cpmc) as 产品名称')
            ->find();
        if (empty($name)){
            $this->success('未找到该工单');
        }
        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['gdbh'].'-'.$value['yjno'].'-'.$value['gxh'].'-'.$value['gxmc'];
            unset($list[$key]['gdbh'],$list[$key]['yjno'],$list[$key]['gxmc']);
            $list[$key]['产品编号'] = $name['产品代号'];
            $list[$key]['产品名称'] = $name['产品名称'];
            $list[$key]['客户名称'] = $name['客户名称'];
        }
        $this->success('成功',$list);
    }

    /**
     * 产品质检系数调整->系数修改
     * @ApiMethod (GET)
     * @param string $workorder   工单编号
     * @param string $processCode  工序号
     * @param float $code1  人工正品板
     * @param float $code2  人工次品板
     * @param float $code3  人工废检
     * @param float $code4  机检正品板
     * @param float $code5  机检次品板
     * @param float $code6  机检废检
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function TestCoefficientEdit()
    {
        if (Request::instance()->isPost() === false){
            $this->error('请求错误');
        }
        $workOrder = input('workOrder');
        $processCode = input('processCode');
        $row = [
            '人工检_正品板' => input('code1'),
            '人工检_次品板' => input('code2'),
            '人工检_废检'   => input('code3'),
            '机检_正品板' => input('code4'),
            '机检_次品板' => input('code5'),
            '机检_废检' => input('code6'),
        ];
        if (empty($workOrder) || empty($processCode)){
            $this->error('参数错误');
        }
        $where = [
            'Gy0_gdbh' => $workOrder,
            'Gy0_gxh' => $processCode
        ];
        $sql = \db('工单_工艺资料')->where($where)->fetchSql(true)->update($row);
        $res = Db::query($sql);
        if ($res !== false){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }


    /**
     * 修正工单核算参数->数据获取
     * @ApiMethod (GET)
     * @param string $workOrder  工单编号
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function AccountingParameter()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $workOrder = input('workOrder');
        if (empty($workOrder)){
            $this->error('参数错误');
        }
        $field = 'rtrim(Gy0_方案) as 方案,rtrim(Gy0_yjno) as yjno,rtrim(Gy0_gxh) as gxh,rtrim(Gy0_gxmc) as gxmc,rtrim(Add_gxmc) as add_gxmc,
        rtrim(Gy0_sbbh) as 参照设备,rtrim(工价系数) as 难度系数,rtrim(Gy0_shdh) as 损耗代号,rtrim(Gy0_Rate0) as 基础损耗,rtrim(Gy0_Rate1) as 损耗率,
        rtrim(印刷方式) as 印刷方式,rtrim(版距) as 版距,rtrim(Gy0_ms) as 计损色数,rtrim(损耗系数) as 损耗系数,rtrim(UniqId) as UniqId';
        $list = \db('工单_工艺资料')->where('Gy0_gdbh',$workOrder)->field($field)->select();
        if (empty($list)){
            $this->success('未找到该工单工艺资料');
        }
        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'].'('.$value['add_gxmc'].')';
        }
        $this->success('成功',$list);
    }


    /**
     * 修正工单核算参数->参数修改
     * @ApiMethod （POST）
     * @param  void
     * @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 AccountingParameterEdit()
    {
        if (Request::instance()->isPost() === false){
            $this->error('请求错误');
        }
        $param = Request::instance()->post();
        if (empty($param) || isset($param[0]['Uniqid']) === false){
            $this->error('参数错误');
        }
        $i = 0;
        foreach ($param as $key=>$value){
            $data['rate0'] = 0;
            $data['rate1'] = 0;
            $rate = \db('dic_lzsh')->where('sys_bh',$value['loss'])->field('rtrim(sys_rate0) as rate0,rtrim(sys_rate1) as rate1')->find();
            if (!empty($rate)){
                $data['rate0'] = $rate['rate0'];
                $data['rate1'] = $rate['rate1'];
            }
            $row = [
                'Gy0_shdh' => $value['loss']?:'',
                '印刷方式' => $value['printMode']?:'',
                '版距' => $value['plate']?:'',
                'Gy0_ms' => $value['chromatic']?:'',
                '损耗系数' => $value['wastage']?:'',
                'Gy0_Rate0' => $data['rate0'],
                'Gy0_Rate1' => $data['rate1']
            ];
            if (isset($value['difficulty'])){
                $row['工价系数'] = $value['difficulty'];
            }
            $sql = \db('工单_工艺资料')->where('Uniqid',$value['Uniqid'])->fetchSql(true)->update($row);
            $res = Db::query($sql);
            if ($res !== false){
                $i++;
            }
        }
        if ($i !== 0){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }

    /**
     * 印件资料修改
     * @ApiMethod （POST）
     * @param  void
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */

    public function PrintedEdit()
    {
        if (Request::instance()->isPost() === false){
            $this->error('请求错误');
        }
        $param = Request::instance()->post();
        if (empty($param) || isset($param['Uniqid']) === false){
            $this->error('参数错误');
        }
        $param['Yj_Gdbh'] = \db('工单_印件资料')->where('Uniqid',$param['Uniqid'])->value('Yj_Gdbh');
        $data = [
            'Yj_Gdbh' =>$param['Yj_Gdbh'],
            'yj_Yjno' =>$param['yjno'],
            'yj_Yjdh' =>$param['yjdh'],
            'yj_yjmc' =>$param['yjmc'],
            'yj_zzdh' =>$param['zzdh'],
            'yj_zzdh1' =>$param['zzdh1'],
            'yj_zzdh2' =>$param['zzdh2'],
            'yj_zzdh3' =>$param['zzdh3'],
            'yj_zzdh4' =>$param['zzdh4'],
            'yj_zzmc' =>$param['zzmc'],
            'yj_zzmc1' =>$param['zzmc1'],
            'yj_zzmc2' =>$param['zzmc2'],
            'yj_zzmc3' =>$param['zzmc3'],
            'yj_zzmc4' =>$param['zzmc4'],
            'yj_tlgg' =>$param['tlgg'],
            'yj_klgg' =>$param['klgg'],
            'Yj_核算规格' =>$param['hsgg'],
            'yj_成品数量' =>$param['cpsl'],
            'yj_平张投料' =>$param['pztl'],
            'yj_ks' =>$param['ks'],
            'yj_ls' =>$param['ls'],
            'yj_desc' =>$param['desc'],
        ];

        $UniqId = $param['Uniqid'];
        $sql = \db('工单_印件资料')->where('Uniqid',$UniqId)->fetchSql(true)->update($data);
        $res = Db::query($sql);
        $process = \db('工单_工艺资料')
            ->where('Gy0_gdbh',$data['Yj_Gdbh'])
            ->where('Gy0_yjno',$data['yj_Yjno'])
            ->select();
        if ((int)$data['yj_平张投料'] > 0 && !empty($process)){
            //重新分配工序计划产量
            $result = $this->PlannedProcessYield($data['Yj_Gdbh'],$data['yj_Yjno'],0,$data['yj_平张投料']);
            if ($result === false){
                $this->success('修改工序产量失败');
            }
        }
        if ($res !== false){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }

    /**
     * 工艺资料修改
     * @ApiMethod (POST)
     * @param void
     * @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 ProcessDetailEdit()
    {
        Db::startTrans();
        try {
            // 请求验证
            if (!Request::instance()->isPost()) {
                throw new Exception('非法请求方法');
            }

            $param = Request::instance()->post();
            if (empty($param) || !isset($param['UniqId'])) {
                throw new Exception('缺少必要参数');
            }

            $UniqId = $param['UniqId'];

            // 获取原始数据（全字段）
            $oldData = Db::name('工单_工艺资料')
                ->where('UniqId', $UniqId)
                ->find();
            if (!$oldData) {
                throw new Exception('目标数据不存在');
            }

            // 动态构建更新数据 --------------------------------------------------------
            $updateData = [];
            $logsData = [];
            $systemFields = array('UniqId', 'Mod_rq'); // 显式声明数组

            // 合并所有有效字段（PHP7.2兼容写法）
            foreach ($param as $key => $value) {
                if (!in_array($key, $systemFields)) {
                    $updateData[$key] = $value;
                    $logsData[$key] = $value;
                }
            }

            // 处理业务逻辑字段
            if (empty($param['Gy0_shdh'])) {
                $updateData['Gy0_Rate0'] = 0;
                $updateData['Gy0_Rate1'] = 0;
            } else {
                $rate = Db::name('dic_lzsh')
                    ->where('sys_bh', $param['Gy0_shdh'])
                    ->field('rtrim(sys_rate0) as rate0, rtrim(sys_rate1) as rate1')
                    ->find();
                $rate = $rate ? $rate : array('rate0' => 0, 'rate1' => 0);
                $updateData['Gy0_Rate0'] = $rate['rate0'];
                $updateData['Gy0_Rate1'] = $rate['rate1'];
            }

            // 添加系统字段
            $updateData['Mod_rq'] = date('Y-m-d H:i:s');

            // 执行全字段更新（PHP7.2兼容的回调函数）-----------------------------------
            $rawSql = Db::name('工单_工艺资料')
                ->where('UniqId', $UniqId)
                ->fetchSql(true)
                ->update($updateData);

            // 中文字段安全处理（传统匿名函数写法）
            $safeSql = preg_replace_callback(
                '/`([\x{4e00}-\x{9fa5}]+)`/u',
                function($matches) {
                    return '`' . addslashes($matches[1]) . '`';
                },
                $rawSql
            );

            // 执行并验证
            $affected = Db::execute($safeSql);
            if ($affected < 0) {
                throw new Exception('数据库执行失败');
            }

            // 记录全字段变更日志 -----------------------------------------------------
            $changes = array();
            foreach ($logsData as $field => $newValue) {
                $oldValue = isset($oldData[$field]) ? $oldData[$field] : 'NULL';

                // 严格值比较（PHP7.2兼容的类型转换）
                if ((string)$oldValue !== (string)$newValue) {
                    $changes[] = array(
                        'field' => $field,
                        'old'   => $oldValue,
                        'new'   => $newValue
                    );
                }
            }

            if (!empty($changes)) {
                $logs = array();
                foreach ($changes as $change) {
                    $logs[] = array(
                        'Gd_gdbh'      => $oldData['Gy0_gdbh'],
                        'yjno'         => $oldData['Gy0_yjno'],
                        'gxh'          => $oldData['Gy0_gxh'],
                        'ModifyUser'   => $param['Sys_id'],
                        'ModifyTime'   => date('Y-m-d H:i:s'),
                        'FieldName'    => $change['field'],
                        'OldValue'     => $change['old'],
                        'NewValue'     => $change['new'],
                        'ModifySource' => '工艺调整'
                    );
                }

                Db::name('系统操作日志表')->insertAll($logs);
            }

            //获取工单第一道工艺编号
            $minGxh = \db('工单_工艺资料')->where('Gy0_gdbh',$param['Gy0_gdbh'])->column('min(Gy0_gxh) as gxh');
            //获取工艺资料数据
            $list = \db('工单_工艺资料')->where('UniqId',$UniqId)->field('Gy0_yjno,Gy0_gxh,rtrim(Gy0_计划接货数) as 计划接货数')->find();
            //如果是第一道工序需从印件资料中获取计划产量
            $list['计划接货数'] = \db('工单_印件资料')->where('Yj_Gdbh',$param['Gy0_gdbh'])->where('yj_Yjno',$param['Gy0_yjno'])->column('yj_平张投料')[0];
            //修改工单状态
            $status = \db('工单_基本资料')->where('Gd_gdbh',$param['Gy0_gdbh'])->field('rtrim(gd_statu) as status')->find();
            if ($status['status'] !== '2-生产中'){
                $statusSql = \db('工单_基本资料')->where('Gd_gdbh',$param['Gy0_gdbh'])->fetchSql(true)->update(['gd_statu'=>'2-生产中']);
                Db::query($statusSql);
                $logData = [
                    'Gd_gdbh'      => $param['Gy0_gdbh'],
                    'ModifyUser'   => $param['Sys_id'],
                    'ModifyTime'   => date('Y-m-d H:i:s'),
                    'FieldName'    => 'gd_statu',
                    'OldValue'     => $status['status'],
                    'NewValue'     => '2-生产中',
                    'ModifySource' => '工单状态变更'
                ];
                \db('系统操作日志表')->insert($logData);
            }
            //重新分配工序计划产量
            if ((int)$list['计划接货数'] > 0){
                $result = $this->PlannedProcessYield($param['Gy0_gdbh'],$list['Gy0_yjno'],0,$list['计划接货数']);
            }

            Db::commit();
            $this->success('操作成功');

        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
    }
    /**
     * 工艺资料编辑->机台列表获取
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function MachineList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $list = \db('设备_基本资料')
            ->where('使用部门',$param['address'])
            ->where('sys_sbID','<>','')
            ->field('rtrim(设备编号) as 设备编号,rtrim(设备名称) as 设备名称')
            ->order('设备编组,设备编号')
            ->select();
        if (empty($list)){
            $this->success('未找到该车间机台');
        }
        $data = [];
        foreach ($list as $key=>$value){
            $data[$key] = $value['设备编号'].'-->'.$value['设备名称'];
        }
        $this->success('成功',$data);
    }

    /**
     * 打印作业通知单->工单印件和工序获取
     * @ApiMethod (GET)
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function PrintCodeList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $list = \db('工单_印件资料')
            ->field([
                'rtrim(yj_Yjno)' => '印件号',
                'rtrim(yj_yjmc)' => '印件名称'
            ])
            ->where('Yj_Gdbh',$param['workOrder'])
            ->select();
        $this->success('成功',$list);
    }

    /**
     * 打印作业通知单->工艺编号获取
     * @ApiMethod (GET)
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function ProcessCodeList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $list = \db('工单_工艺资料')
            ->field('rtrim(Gy0_gxh) as 工序号')
            ->where([
                'Gy0_gdbh' => $param['workOrder'],
                'Gy0_yjno' => $param['yjno']
            ])
            ->select();
        $this->success('成功',$list);
    }
    /**
     * 打印作业通知单
     * @ApiMethod (POST)
     * @param  void
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function PrintJobOrder()
    {
        if ($this->request->isGet() === false) {
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $data = $this->workOrderDetailGet($param['workOrder'],$param['yjno']);
        if (empty($data)){
            $this->success('未找到工单信息');
        }
        $materiel = $this->MaterielDetailGet($param['workOrder']);
        $printDetail = $this->PrintDetailGet($param['workOrder'],$param['yjno'],$param['gxh']);
        if (empty($printDetail)){
            $this->success('未找到工艺信息');
        }
        $number = 0;
        foreach ($printDetail as $key=>$value){
            $value['允损比例'] = (float)substr($value['允损比例'],0,-1);
            $number = $number+$value['允损比例'];
        }
        $data['制单'] = $param['PrepareDocument'];
        $data['审核'] = $param['examine'];
        $data['目标合格率'] = 100-$number.'%';
        $data['materiel'] = $materiel;
        $data['printDetail'] = $printDetail;
        $this->success('成功',$data);
    }

    /**
     * 打印作业通知单->工单及印件资料获取
     * @param $workOrder
     * @return mixed
     */
    public function workOrderDetailGet($workOrder,$yjno)
    {
        $sql = "SELECT
                RTRIM( a.Gd_lx) AS  工单类型,
                RTRIM( a.Gd_gdbh ) AS 生产批次号,
                RTRIM( a.销售订单号 ) AS 销售订单号,
                RTRIM( a.Gd_客户代号 ) AS 客户代号,
                RTRIM( a.Gd_客户名称 ) AS 客户名称,
                RTRIM( a.成品代号 ) AS 产品代码,
                RTRIM( a.成品名称 ) AS 产品名称,
                RTRIM( a.产品版本号 ) AS 版本号,
                RTRIM( a.警语版面 ) AS 警语版面,
                RTRIM( a.码源数量 ) AS 码源数量,
                RTRIM( a.客户ERP编码 ) AS 客户ERP编码,
                RTRIM( a.接单日期 ) AS 开单日期,
                RTRIM( a.交货日期 ) AS 交货日期,
                RTRIM( a.Gd_desc ) AS 工单说明,
                RTRIM( a.投料率 ) AS 投料率,
                RTRIM( a.订单数量 ) AS 订单数量,
                RTRIM( a.平均合格率 ) AS 平均合格率,
                RTRIM( a.投料大箱 ) AS 订货数量,
                RTRIM( a.排产时库存 ) AS 排产时库存,
                RTRIM( b.yj_Yjno ) AS 印件,
                RTRIM( b.yj_Yjdh ) AS 印件代号,
                RTRIM( b.yj_yjmc ) AS 印件名称,
                RTRIM( b.yj_平张投料 ) AS 平张投料量,
                RTRIM( b.yj_zzmc ) AS 纸张名称,
                RTRIM( b.yj_tlgg ) AS 投料规格,
                RTRIM( b.yj_ks ) AS 开数,
                RTRIM( b.yj_ls ) AS 联数,
                RTRIM( b.yj_desc ) AS 印件备注 
            FROM
                `工单_基本资料` AS a
                JOIN `工单_印件资料` AS b ON b.Yj_Gdbh = a.Gd_gdbh 
            WHERE
                a.Gd_gdbh = '{$workOrder}' AND b.yj_Yjno = '{$yjno}'";
        $list = Db::query($sql);
        if (empty($list)){
            $this->success('未找到订单数据');
        }
        $list[0]['开单日期'] = date('Y-m-d',strtotime($list[0]['开单日期']));
        $list[0]['交货日期'] = date('Y-m-d',strtotime($list[0]['交货日期']));
        if (strpos($list[0]['产品名称'],'条') !== false){
            $list[0]['订货数量'] = (int)$list[0]['订单数量']*40;
            $list[0]['投料数量'] = intval($list[0]['平张投料量']*$list[0]['联数']/250);
        }else{
            $list[0]['订货数量'] = (int)$list[0]['订单数量']*4;
            $list[0]['投料数量'] = intval($list[0]['平张投料量']*$list[0]['联数']/2500);
        }
        $list[0]['联数'] = (int)$list[0]['联数'];
        $list[0]['印件代号及名称']  = $list[0]['印件代号'].' '.$list[0]['印件名称'];
//        $list[0]['投料数量'] = $list[0]['订货数量'];
        unset($list[0]['印件代号'],$list[0]['印件名称']);
        return($list[0]);
    }

    /**打印作业流程单->物料资料获取
     * @param $workOrder
     * @return bool|\PDOStatement|string|\think\Collection
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function MaterielDetailGet($workOrder)
    {
        $where = [
            'BOM_工单编号' => $workOrder,
        ];
        $filed = 'rtrim(BOM_物料编码) as 物料编码,rtrim(BOM_物料名称) as 物料名称,rtrim(BOM_投料单位) as 投料单位,rtrim(BOM_计划用量) as 计划用量';
        $list = \db('工单_bom资料')->where($where)->field($filed)->select();
        if (!empty($list)){
            foreach ($list as $key=>$value){
                $list[$key]['物料代码及名称'] = $value['物料编码'].' '.$value['物料名称'];
                $list[$key]['计划用量'] = (float)$value['计划用量'];
                unset($list[$key]['物料编码'],$list[$key]['物料名称']);
            }
        }
        return $list;
    }

    /**
     * 打印作业流程单->工艺资料获取
     * @param $workOrder
     * @return bool|\PDOStatement|string|\think\Collection
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function PrintDetailGet($workOrder,$yjno,$gxh)
    {
        $where = [
            'Gy0_gdbh' => $workOrder,
            'Gy0_yjno' => $yjno,
            'Gy0_gxh'  => ['<=',$gxh]
        ];
        $filed = 'rtrim(Gy0_yjno) as yjno,rtrim(Gy0_gxh) as gxh,rtrim(Gy0_gxmc) as gxmc,rtrim(Add_gxmc) as add_gxmc,
        rtrim(损耗系数) as 损耗系数,rtrim(Gy0_ls) as ls,rtrim(Gy0_计划接货数) as 计划接货数,rtrim(Gy0_计划损耗) as 计划损耗,
        rtrim(Gy0_辅助工时) as 装版工时,rtrim(Gy0_小时产能) as 小时定额,rtrim(Gy0_生产工时) as 生产工时,rtrim(工序备注) as 工序备注';
        $list = \db('工单_工艺资料')
            ->where($where)
            ->field($filed)
            ->select();
        if (empty($list)){
            $this->success('工单工艺为空');
        }
        foreach ($list  as $key=>$value){
            if ($value['yjno']<10){
                $value['yjno'] = '0'.$value['yjno'];
            }
            if ($value['gxh']<10){
                $value['gxh'] = '0'.$value['gxh'];
            }
            if ($value['add_gxmc'] !== null){
                $list[$key]['印件及工序名称'] = $value['yjno'].'-'.$value['gxh'].'-->'.$value['gxmc'].'【'.$value['add_gxmc'].'】';
            }else{
                $list[$key]['印件及工序名称'] = $value['yjno'].'-'.$value['gxh'].'-->'.$value['gxmc'];
            }
            // $list[$key]['转序数'] = (int)($value['计划接货数']/$value['ls']);
            // $list[$key]['报废定额'] = (int)($value['计划损耗']/$value['ls']);
            $list[$key]['转序数'] = $value['计划接货数'];
            $list[$key]['报废定额'] = $value['计划损耗'];
            if ((int)$value['计划接货数'] === 0){
                $list[$key]['允损比例'] = 0;
            }else{
                $list[$key]['允损比例'] = round(($value['计划损耗']/$value['计划接货数'])*100,2).'%';
            }
            unset($list[$key]['yjno'],$list[$key]['gxh'],$list[$key]['gxmc'],$list[$key]['add_gxmc'],$list[$key]['计划接货数'],$list[$key]['计划损耗']);
        }
        return $list;
    }

    /**
     * 获取小时产能
     * @ApiMethod  (GET)
     * @param  void
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */

    public function capacityList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $machine = explode(' ',$param['machine'])[0];
        $number = \db('设备_基本资料')->where('设备编号',$machine)->field('rtrim(排单小时定额) as 小时产能')->find();
        if (empty($number)){
            $this->error('未找到小时产能');
        }
        $this->success('成功',$number['小时产能']);
    }


    /**
     * 新增工单->添加工单
     * @ApiMethod （POST）
     * @param
     * @return void
     * @throws \think\Exception
     * @throws \think\db\exception\BindParamException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */

    public function WorkOrderAdd()
    {
        if (Request::instance()->isPost() === false){
            $this->error('请求错误');
        }
        $param = Request::instance()->post();
        if (empty($param)){
            $this->error('参数错误');
        }
        if (isset($param['sort'])){
            $sort = 2;
            unset($param['sort']);
        }else{
            $sort = 1;
        }
        $num = \db('工单_基本资料')->where('Gd_gdbh',$param['gdbh'])->count();
        //插入产品资料
        $productData = \db('产品_基本资料')
            ->where('产品编号',$param['cpdh'])
            ->count();
        if ($productData === 0) {
            $clientCode = substr($param['cpdh'], 0, 5);
            $product = [
                '客户编号' => $clientCode,
                '客户名称' => $param['khmc'],
                '产品编号' => $param['cpdh'],
                '产品名称' => $param['cpmc'],
                '计量单位' => '万张',
                '状态' => '',
                'Mod_rq' => date('Y-m-d H:i:s', time()),
                'UniqID' => \db('产品_基本资料')->order('UniqID desc')->value('UniqID') + 1,
            ];
            if (strpos($product['产品名称'], '小盒') === false) {
                $product['产品类别'] = '条盒';
            } else {
                $product['产品类别'] = '小盒';
            }
            $productSql = \db('产品_基本资料')->fetchSql(true)->insert($product);
            \db()->query($productSql);
        }
        //添加工单
        $productDetail = \db('产品_基本资料')->where('产品编号',$param['cpdh'])->find();
        if (empty($productDetail)){
            $productDetail['客户料号'] = '';
        }
        $lastId = \db('工单_基本资料')->order('Uniqid desc')->value('Uniqid');
        $data = [
            'Gd_lx' =>$param['zdgd'],
            'Gd_生产分类' =>$param['sclx'],
            '成本处理类别' =>'',
            'Gd_gdbh' =>$param['gdbh'],
            '行号' =>$num+1 ,
            'Gd_客户代号' =>$param['khdh'],
            'Gd_客户名称' =>$param['khmc'],
            'Gd_khdh' =>$param['khdh'],
            'Gd_khmc' =>$param['khmc'],
            '客户料号' =>rtrim($productDetail['客户料号']),
            '客户ERP编码' =>$param['erp'],
            'Gd_cpdh' =>'',
            'Gd_cpmc' =>'',
            '成品代号' =>$param['cpdh'],
            '成品名称' =>$param['cpmc'],
            '产品版本号' =>$param['bbh'],
            '销售订单号' =>$param['xsddh'],
            '警语版面' =>$param['jybm'],
            '码源数量' =>$param['mysl'],
            '排产时库存' =>$param['kcdx'],
            '投料大箱' =>$param['tldx'],
            '投料率' =>$param['tll'],
            '平均合格率' =>$param['hgl'],
            '进程备注' =>$param['jcbz'],
            'Gd_desc' =>$param['remark'],
            '开单日期' =>date('Y-m-d H:i:s',time()),
            '接单日期' =>$param['start'],
            '交货日期' =>$param['end'],
            '订单数量' =>$param['number'],
            '计量单位' =>$param['tldw'],
            '计划投料' =>$param['pztl'],
            '实际投料' =>$param['wxz'],
            '产品单价' =>0,
            '入仓日期' =>'1900-01-01 00:00:00',
            '工单入仓数量' =>0,
            '工单制程废品' => 0,
            '工单质检废品' => 0,
            '工单无形损' => 0,
            '工单计划损耗' => 0,
            '工单完工日期' => $param['end'],
            '投料确认' => '',
            'gd_statu' => '3-计划中',
            '直接人工' => 0,
            '分摊人工' => 0,
            '直接材料' => 0,
            '考核直接材料' => 0,
            '分摊材料' => 0,
            '考核分摊材料' => 0,
            '直接折旧' => 0,
            '水电气费' => 0,
            '分摊空调' => 0,
            '分摊锅炉' => 0,
            '分摊废气处理' => 0,
            '分摊空压机' => 0,
            '分摊鼓风机' => 0,
            '分摊其他' => 0,
            '待摊人工' => 0,
            '待摊折旧' => 0,
            '待摊场地租金' => 0,
            '待摊其他费用' => 0,
            '加工费' => 0,
            '加工费单价' => 0,
            '成本考核_胶印' => 1,
            '成本考核_凹印' => 1,
            '成本考核_丝印' => 1,
            '成本考核_模切' => 1,
            '成本考核_检验' => 1,
            '印版费' => 0,
            'V23制造成本' => 0,
            'Prt_rq' => date('Y-m-d H:i:s',time()),
            'Sys_id' => $param['Sys_id'],
            'Sys_rq' => date('Y-m-d H:i:s',time()),
            'Mod_rq' => date('Y-m-d H:i:s',time()),
            'U8UID' => '',
            'Uniqid' => $lastId+1,
            '工序加工费' => 0,
            '工单分类' => $sort,
        ];
        $sql= \db('工单_基本资料')->fetchSql(true)->insert($data);
        $res = \db()->query($sql);
        //创建日志数据
        $logs = array(
            'Gd_gdbh'      => $data['Gd_gdbh'],
            'ModifyUser'   => $param['Sys_id'],
            'ModifyTime'   => date('Y-m-d H:i:s'),
            'ModifySource' => '工单添加'
        );
        \db('系统操作日志表')->insert($logs);
        if ($res !== false){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }

    /**
     * 新增工单->客户代号列表获取
     * @return void
     * @throws \think\db\exception\BindParamException
     * @throws \think\exception\PDOException
     */
    public function ClientList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (isset($param['search'])){
            $where = $param['search'].'%';
            $sql = "SELECT DISTINCT
                        (客户编号),rtrim(客户名称 ) as 客户名称
                    FROM
                        `产品_基本资料`
                    WHERE
                        客户编号 LIKE "."'".$where."'"."
                    OR
                        客户名称 LIKE "."'".$where."'"."
                    GROUP BY
                        客户编号
                    order by
                        客户编号";
        }else{
            $sql = "SELECT DISTINCT
                    (客户编号),rtrim(客户名称 ) as 客户名称
                FROM
                    `产品_基本资料`
                GROUP BY
                    客户编号
                order by
                    客户编号";
        }
        $list = \db()->query($sql);
        if (empty($list)){
            $this->success('未找到客户列表');
        }
        foreach ($list as $key=>$value){
            if (empty($value['客户编号'])){
                unset($list[$key]);
            }else{
                $list[$key]['客户编号'] = rtrim($value['客户编号']);
                $list[$key]['name'] = rtrim($value['客户编号']).'【'.$value['客户名称'].'】';
                if ($value['客户编号'] == '1098'){
                    $list[$key]['客户名称'] = '打样专用';
                }
            }
        }
        $list = array_values($list);
        $this->success('成功',$list);
    }

    /**
     * 新增工单->产品代号获取
     * @ApiMethod (GET)
     * @param  void
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function ProductCodeList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (isset($param['cilent']) === false){
            $this->error('参数错误');
        }
        $where = ['产品编号'=>['like',$param['cilent'].'%']];
        $list = \db('产品_基本资料')
            ->where($where)
            ->field('rtrim(产品编号) as 产品编号,rtrim(产品名称) as 产品名称')
            ->limit(50)
            ->select();
        if (empty($list)){
            $this->success('未获取到产品数据');
        }
        $res = db('产品_工艺资料')->where('Gy0_cpdh',$list[0]['产品编号'])->distinct(true)->column('rtrim(Gy0_方案) as gy_plan');
        $list[0]['gy'] = $res;
        foreach ($list as $key=>$value){
            $list[$key]['name'] = $value['产品编号'].'【'.$value['产品名称'].'】';
            $list[$key]['yj'] = db('产品_印件资料')->where('yj_cpdh',$value['产品编号'])->column('yj_yjno');
        }

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

    /**
     * 新增印件资料->印件资料添加
     * @return void
     * @throws \think\db\exception\BindParamException
     * @throws \think\exception\PDOException
     */
    public function PrintDetailAdd()
    {
        if (Request::instance()->isPost() === false){
            $this->error('请求错误');
        }
        $param = Request::instance()->post();
        if (empty($param)){
            $this->error('参数错误');
        }
        $lastId = \db('工单_印件资料')->order('Uniqid desc')->value('Uniqid');
        if (empty($lastId)){
            $lastId = 0;
        }else{
            $lastId = $lastId + 1;
        }
        $param['Uniqid'] = $lastId;
        $param['Sys_rq'] = date('Y-m-d H:i:s',time());
        $param['Mod_rq'] = date('Y-m-d H:i:s',time());
        //判断印件号是否存在在工单基本资料表中，存在不增加行号，不存在增加行号
        if (empty(\db('工单_基本资料')->where('Gd_gdbh',$param['Yj_Gdbh'])->where('行号',$param['yj_Yjno'])->find())){
            $list = \db('工单_基本资料')->where('Gd_gdbh',$param['Yj_Gdbh'])->find();
            $list['行号'] = $param['yj_Yjno'];
            $list['Gd_cpdh'] = $param['yj_Yjdh'];
            $list['Gd_cpmc'] = $param['yj_yjmc'];
            $list['Sys_id'] = $param['Sys_id'];
            $list['Sys_rq'] = $param['Sys_rq'];
            $list['Mod_rq'] = $param['Mod_rq'];
            unset($list['Uniqid']);
            $workSql = \db('工单_基本资料')->fetchSql(true)->insert($list);
        }else{
            $data['Gd_cpdh'] = $param['yj_Yjdh'];
            $data['Gd_cpmc'] = $param['yj_yjmc'];
            $workSql = \db('工单_基本资料')
                ->where('Gd_gdbh',$param['Yj_Gdbh'])
                ->where('行号',$param['yj_Yjno'])
                ->fetchSql(true)
                ->update($data);
        }

        //开启事务
        Db::startTrans();
        try{
            $sql = \db('工单_印件资料')->fetchSql(true)->insert($param);
            $res = \db()->query($sql);
            $workRes = \db()->query($workSql);
            //提交事务
            \db()->commit();
        } catch (\Exception $e) {
            echo $e->getMessage();
            // 回滚事务
            \db()->rollback();
        }
        if ($res !== false && $workRes !== false){
            $this->success('成功');
        }else{
            $this->error('失败');
        }
    }

    /**
     * 新增工艺资料->工艺资料添加
     * @return void
     * @throws \think\db\exception\BindParamException
     * @throws \think\exception\PDOException
     */
    public function ProcessDetailAdd()
    {
        if (Request::instance()->isPost() === false){
            $this->error('请求错误');
        }
        $param = Request::instance()->post();
        if (empty($param)){
            $this->error('参数错误');
        }
        $lastId = \db('工单_工艺资料')->order('UniqId desc')->value('UniqId');
        if (empty($lastId)){
            $lastId = 0;
        }else{
            $lastId = $lastId + 1;
        }
        if (empty($param['Gy0_shdh'])){
            $param['Gy0_Rate0'] = 0;
            $param['Gy0_Rate1'] = 0;
        }else{
            $detail = \db('dic_lzsh')->field('sys_rate0,sys_rate1')->where('sys_bh',$param['Gy0_shdh'])->find();
            $param['Gy0_Rate0'] = $detail['sys_rate0'];
            $param['Gy0_Rate1'] = $detail['sys_rate1'];
        }
        $param['Sys_rq'] = date('Y-m-d H:i:s',time());
        $param['Mod_rq'] = '1900-01-01 00:00:00';
        $param['Gy0_sj1'] = '1900-01-01 00:00:00';
        $param['Gy0_sj2'] = '1900-01-01 00:00:00';
        $param['PD_WG'] = '1900-01-01 00:00:00';
        $param['UniqId'] = $lastId;
        //添加工序
        $sql = \db('工单_工艺资料')
            ->fetchSql(true)
            ->insert($param);
        $res = \db()->query($sql);
        //获取平张投料
        $number = \db('工单_印件资料')
            ->where('Yj_Gdbh',$param['Gy0_gdbh'])
            ->where('yj_Yjno',$param['Gy0_yjno'])
            ->value('rtrim(yj_平张投料)');
        //分配工艺计划产量
        if ((int)$number >0){
            $this->PlannedProcessYield($param['Gy0_gdbh'],$param['Gy0_yjno'],0,$number);
        }
        //操作日志数据
        $logs = array(
            'Gd_gdbh'      => $param['Gy0_gdbh'],
            'yjno'         => $param['Gy0_yjno'],
            'gxh'          => $param['Gy0_gxh'],
            'ModifyUser'   => $param['Sys_id'],
            'ModifyTime'   => date('Y-m-d H:i:s'),
            'ModifySource' => '工艺新增'
        );
        \db('系统操作日志表')->insert($logs);
        if ($res !== false){
            $this->success('成功');
        }else{
            $this->error('失败');
        }

    }

    /**
     * 新增工艺资料->印件编号获取
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function PrintDetailList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param)){
            $this->error('参数错误');
        }
        $printList = \db('工单_印件资料')
            ->where('Yj_Gdbh',$param['workOrder'])
            ->order('yj_Yjno')
            ->select();
        if (empty($printList)){
            $this->success('未找到该工单印件资料');
        }
        $list = [];
        foreach ($printList as $key=>$value){
            $list[$key]['name'] = rtrim($value['yj_Yjno']).'-->'.rtrim($value['yj_yjmc']);
            $list[$key]['no'] = rtrim($value['yj_Yjno']);
        }
        $this->success('成功',$list);
    }

    /**
     * 工单资料管理->印件资料删除
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function PrintDetailDel()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (isset($param['UniqId']) === false){
            $this->error('参数错误');
        }
        $printId = explode(',',$param['UniqId']);
        $i = 0;
        foreach ($printId as $value){
            $res = \db('工单_印件资料')
                ->where('Uniqid',$value)
                ->delete();
            if ($res === false){
                $i++;
            }
        }
        if ($i === 0){
            $this->success('删除成功');
        }else{
            $this->error('删除失败');
        }

    }

    /**
     * 工单资料管理->工艺资料删除
     * @return void
     * @throws \think\Exception
     * @throws \think\exception\PDOException
     */
    public function ProcessDetailDel()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (isset($param['UniqId']) === false){
            $this->error('参数错误');
        }
        $printId = explode(',',$param['UniqId']);
        $i = 0;
        //获取工单编号、印件号
        $codeList = \db('工单_工艺资料')
            ->where('UniqId',$printId[0])
            ->field('rtrim(Gy0_gdbh) as 工单编号,rtrim(Gy0_yjno) as 印件号')
            ->find();
        //获取平张投料数量
        $number = \db('工单_印件资料')
            ->where([
                'Yj_Gdbh' => $codeList['工单编号'],
                'yj_Yjno' => $codeList['印件号']
            ])
            ->value('rtrim(yj_平张投料)');
        // 新增：批量获取要删除的工序号
        $gxhList = \db('工单_工艺资料')
            ->where('UniqId', 'in', $printId)
            ->column('rtrim(Gy0_gxh) as gxh', 'UniqId');
        //循环删除工艺资料
        $deletedGxh = [];
        foreach ($printId as $value){
            $process = \db('工单_工艺资料')
                ->where('UniqId',$value)
                ->find();
            $processCount = \db('设备_产量计酬')
                ->where('sczl_gdbh',$process['Gy0_gdbh'])
                ->where('sczl_yjno',$process['Gy0_yjno'])
                ->where('sczl_gxh',$process['Gy0_gxh'])
                ->count();
            if ($processCount > 0){
                $this->error('工序'.$process['Gy0_gxh'].'已上报数据,无法删除,请核对');
            }
            $res = \db('工单_工艺资料')
                ->where('UniqId',$value)
                ->delete();
            if ($res) {
                // 记录成功删除的工序号
                if (isset($gxhList[$value])) {
                    $deletedGxh[] = $gxhList[$value];
                }
            } else {
                $i++;
            }
        }
        //重新分配工艺计划产量
        if ((int)$number>0){
            $this->PlannedProcessYield($codeList['工单编号'],$codeList['印件号'],0,$number);
        }
        // 新增：写入操作日志
        \db('系统操作日志表')->insert([
            'ModifyUser'      => $param['sys_id'],
            'ModifyTime'  => date('Y-m-d H:i:s',time()),
            'Gd_gdbh'          => $codeList['工单编号'],
            'yjno'          => $codeList['印件号'],
            'gxh'           => implode(',', $deletedGxh),
            'ModifySource'  => '工艺资料删除'
        ]);
        if ($i === 0){
            $this->success('删除成功');
        }else{
            $this->error('删除失败');
        }
    }

    /**
     * 工艺资料添加->工序损耗代码
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function WastageList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param['process'])){
            $this->error('参数错误');
        }
        if (strlen($param['process'])>6){
            $param['process'] = substr($param['process'],0,6);
        }
        $order = \db('dic_lzsh')
            ->where('sys_mc','like',$param['process'].'%')
            ->value('rtrim(sys_bh) as 编号');
        $this->success('成功',$order);
    }

    /**
     * 获取产品附件列表
     */
    public function getAnnexTable(){
        if(!$this->request->isGet()){
            $this->error('请求方式错误');
        }
        $req = $this->request->param();
        if (isset($req['cpdh']) && !empty($req['cpdh'])){
            $where['关联产品'] = ['LIKE','%'.$req['cpdh'].'%'];
        }else{
            $this->error('参数错误');
        }
        $rows = db('产品_技术附件')
            ->where($where)
            ->select();
        foreach ($rows as $key=>&$value){
            if(mb_detect_encoding($value['附件内容'])!='ASCII'){
                $value['附件内容'] = '';
            }
        }
        $this->success('成功',$rows);
    }

    /**
     * 产品附件新增
     */
    public function annexAdd(){
        if(!$this->request->isPost()){
            $this->error('请求方式错误');
        }
        $req = $this->request->param();

        $arr = [
            'sys_id',
            '序号',
            '附件备注',
            '附件内容',
            '附件类型',
            '适用工序',
            '关联产品'
        ];
        $data = [];
        foreach ($arr as $key => $value){
            if (!isset($req[$value])){
                $this->error('参数错误',$value,$key+1);
            }
            $data[$value] = $req[$value];
        }
        $data['sys_rq'] = date('Y-m-d H:i:s');

        //查询UniqId
        $UniqId = db('产品_技术附件')->max('UniqId');
        $data['UniqId'] = $UniqId < 10000000 ? 10000000 : $UniqId + 1;

        //开启事务
        db()->startTrans();
        try{
            $sql = db('产品_技术附件')->fetchSql(true)->insert($data);
            $bool = db()->query($sql);
            // 提交事务
            db()->commit();
        } catch (\Exception $e) {
            // 回滚事务
            db()->rollback();
            $this->error($e->getMessage());
        }

        if($bool===false) $this->error('失败');

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

    /**
     * 产品附件修改
     * @ApiMethod (GET)
     * @param string 'UniqId'
     */
    public function annexDel()
    {
        if(!$this->request->isGet()){
            $this->error('请求方式错误');
        }
        $req = $this->request->param();

        if (!(isset($req['UniqId']) && trim($req['UniqId'])!='')){
            $this->error('参数错误','UniqId',100);
        }

        //开启事务
        db()->startTrans();
        try{
            $bool = db('产品_技术附件')->where('UniqId',$req['UniqId'])->delete();
            // 提交事务
            db()->commit();
        } catch (\Exception $e) {
            // 回滚事务
            db()->rollback();
            $this->error($e->getMessage());
        }

        if($bool===false) $this->error('失败');

        $this->success('成功');

    }

    /**
     * 获取产品附件列表
     */
    public function getGdAnnexTable(){
        if(!$this->request->isGet()){
            $this->error('请求方式错误');
        }
        $req = $this->request->param();
        if (isset($req['gdbh']) && !empty($req['gdbh'])){
            $where['关联编号'] = ['LIKE','%'.$req['gdbh'].'%'];
        }else{
            $this->error('参数错误');
        }
        $rows = db('工单_相关附件')
            ->where($where)
            ->select();
        foreach ($rows as $key=>&$value){
            if(mb_detect_encoding($value['附件内容'])!='ASCII'){
                $value['附件内容'] = '';
            }
        }
        $this->success('成功',$rows);
    }

    /**
     * 产品附件新增
     */
    public function gdAnnexAdd(){
        if(!$this->request->isPost()){
            $this->error('请求方式错误');
        }
        $req = $this->request->param();

        $arr = [
            'sys_id',
            '附件备注',
            '附件内容',
            '附件类型',
            '关联编号'
        ];
        $data = [];
        foreach ($arr as $key => $value){
            if (!isset($req[$value])){
                $this->error('参数错误',$value,$key+1);
            }
            $data[$value] = $req[$value];
        }
        $data['sys_rq'] = date('Y-m-d H:i:s');

        //查询UniqId
        $UniqId = db('工单_相关附件')->max('UniqId');
        $data['UniqId'] = $UniqId < 10000000 ? 10000000 : $UniqId + 1;

        //开启事务
        db()->startTrans();
        try{
            $sql = db('工单_相关附件')->fetchSql(true)->insert($data);
            $bool = db()->query($sql);
            // 提交事务
            db()->commit();
        } catch (\Exception $e) {
            // 回滚事务
            db()->rollback();
            $this->error($e->getMessage());
        }

        if($bool===false) $this->error('失败');

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

    /**
     * 产品附件修改
     * @ApiMethod (GET)
     * @param string 'UniqId'
     */
    public function gdAnnexDel()
    {
        if(!$this->request->isGet()){
            $this->error('请求方式错误');
        }
        $req = $this->request->param();

        if (!(isset($req['UniqId']) && trim($req['UniqId'])!='')){
            $this->error('参数错误','UniqId',100);
        }

        //开启事务
        db()->startTrans();
        try{
            $bool = db('工单_相关附件')->where('UniqId',$req['UniqId'])->delete();
            // 提交事务
            db()->commit();
        } catch (\Exception $e) {
            // 回滚事务
            db()->rollback();
            $this->error($e->getMessage());
        }

        if($bool===false) $this->error('失败');

        $this->success('成功');

    }

    /**
     * 引用工单资料数据查询
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function WorkOrderDetailCope()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param['search'])){
            $this->error('参数错误');
        }
        $list = \Db('工单_基本资料')
            ->alias('a')
            ->field([
                'rtrim(a.Gd_gdbh)' => '工单编号',
                'rtrim(b.客户编号)' => '客户编号',
                'rtrim(b.客户名称)' => '客户名称',
                'rtrim(b.产品编号)' => '产品编号',
                'rtrim(b.产品名称)' => '产品名称'
            ])
            ->join('产品_基本资料 b', 'a.成品代号 = b.产品编号')
            ->join('产品_工艺资料 c', 'a.成品代号 = c.Gy0_cpdh')
            ->join('产品_印件资料 d', 'a.成品代号 = d.yj_cpdh')
            ->where(function($query) use ($param) {
                $query->where('a.Gd_gdbh', 'like', '%'.$param['search'].'%')
                    ->whereOr('a.成品名称', 'like', '%'.$param['search'].'%');
            })
            ->where(function($query) {
                $query->where('c.Gy0_cpdh', '<>', '')
                    ->where('d.yj_cpdh', '<>', '')
                    ->where('b.状态', 'not like', '%停用%')
                    ->where('b.产品名称', 'not like', '%停用%');
            })
            ->group('a.Gd_gdbh')
            ->order('a.Uniqid desc')
            ->select();
        if (empty($list)){
            $this->success('未找到工单资料');
        }else{
            $this->success('成功',$list);
        }
    }

    /**
     * 引用产品印件、工艺资料
     * @return void
     * @throws \think\db\exception\BindParamException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */
    public function WorkOrderDetailListCope()
    {
        if (Request::instance()->isPost() === false){
            $this->error('请求错误');
        }

        $param = Request::instance()->post();
        if (empty($param['workorder']) || empty($param['productCode']) || empty($param['option'])){
            $this->error('参数错误');
        }
        if (isset($param['sort'])){
            $priWhere['yj_yjno'] = ['>=',10];
            $proWhere['a.Gy0_yjno'] = ['>=',10];
        }else{
            $priWhere['yj_yjno'] = ['<',10];
            $proWhere['a.Gy0_yjno'] = ['<',10];
        }
        $list = \db('工单_基本资料')
            ->where('Gd_gdbh',$param['workorder'])
//            ->where('成品代号',$param['productCode'])
            ->field('行号,Gd_cpdh')
            ->select();
        $cpdhList = \db('工单_基本资料')
            ->where('Gd_gdbh',$param['workorder'])
            ->column('Gd_cpdh');
        //引用印件资料
        $PrintList = \db('产品_印件资料')
            ->where('yj_cpdh',$param['productCode'])
            ->whereIn('yj_yjdh',$cpdhList)
            ->where($priWhere)
            ->select();
        if (empty($PrintList)){
            $this->error('未找到印件资料');
        }
        $number = \db('工单_基本资料')
            ->where('Gd_gdbh',$param['workorder'])
            ->where('成品代号',$param['productCode'])
            ->value('rtrim(计划投料)');
        $arr = [];
        foreach ($PrintList as $key => $value){
            foreach ($list as $k=>$v){
                if (rtrim($value['yj_yjdh']) === $v['Gd_cpdh']){
                    $PrintList[$key]['Yj_Gdbh'] = $param['workorder'];
                    $PrintList[$key]['yj_Yjno'] = $value['yj_yjno'];
                    $PrintList[$key]['yj_Yjdh'] = $value['yj_yjdh'];
                    $PrintList[$key]['yj_ks'] = $value['yj_ks'];
                    $PrintList[$key]['yj_ls'] = $value['yj_ls'];
                    $PrintList[$key]['yj_平张投料'] = $number;
                    $PrintList[$key]['Sys_id'] = $value['sys_id'];
//                    $PrintList[$key]['Uniqid'] = $PrintLastId + $key + 1;
                    $PrintList[$key]['Sys_rq'] = date('Y-m-d H:i:s',time());
                    $PrintList[$key]['Mod_rq'] = date('Y-m-d H:i:s',time());
                    array_push($arr,[$value['yj_yjno'],$v['行号']]);
                }
                $sql = \db('工单_基本资料')
                    ->where('Gd_gdbh',$param['workorder'])
                    ->where('Gd_cpdh',$value['yj_yjdh'])
                    ->fetchSql(true)
                    ->update(['行号'=>$value['yj_yjno']]);
                \db()->query($sql);
                $bomSql = \db('工单_bom资料')
                    ->where('BOM_工单编号',$param['workorder'])
                    ->where('BOM_产品编号',$value['yj_yjdh'])
                    ->fetchSql(true)
                    ->update(['BOM_工单行号'=>$value['yj_yjno']]);
                \db()->query($bomSql);
            }
            unset($PrintList[$key]['mod_rq'],$PrintList[$key]['sys_rq'],$PrintList[$key]['sys_id'],$PrintList[$key]['KgToPages'],$PrintList[$key]['yj_tll'],$PrintList[$key]['yj_yjdh'],$PrintList[$key]['yj_yjno'],$PrintList[$key]['UniqId']);
        }
        //引用工艺资料
        $processWhere = [
            'a.Gy0_方案' => $param['option'],
            'a.Gy0_cpdh' => $param['productCode']
        ];
        $yjnolist = \db('工单_基本资料')
            ->where('Gd_gdbh',$param['workorder'])
            ->column('Gd_cpdh');
        $ProcessList = \db('产品_工艺资料')
            ->alias('a')
            ->field('a.*')
            ->join('产品_印件资料 b','a.Gy0_cpdh = b.yj_cpdh AND a.Gy0_yjno = yj_yjno')
            ->where($processWhere)
            ->where($proWhere)
            ->whereIn('b.yj_yjdh',$yjnolist)
            ->order('Gy0_yjno,Gy0_gxh')
            ->select();
        if (empty($ProcessList)){
            $this->error('未找到产品工艺资料');
        }
        $ProcesslastId = \db('工单_工艺资料')->order('UniqId desc')->value('rtrim(UniqId)');
        foreach ($ProcessList as $key=>$value){
            if (empty(trim($value['Gy0_shdh']))){
                $rate['rate0'] = 0;
                $rate['rate1'] = 0;
            }else{
                $rate = \db('dic_lzsh')->where('sys_bh',$value['Gy0_shdh'])->field('rtrim(sys_rate0) as rate0,rtrim(sys_rate1) as rate1')->find();
                if (empty($rate)){
                    $this->error('该产品印件号'.$value['Gy0_yjno'].'工序号为'.$value['gy0_gxmc'].'的损耗代号错误,请调整之后再引用');
                }
            }
            //设置默认机台
            $machineList = \db('设备_基本资料')
                ->where('生产工序','like','%'.$value['gy0_gxmc'].'%')
                ->where('使用部门','<>','研发中心')
                ->where('设备编组','<>','')
                ->where('sys_sbID','<>','')
                ->order('设备编号')
                ->value('设备编号');
            $ProcessList[$key]['Gy0_sbbh'] = '';
            if (!empty($machineList)){
                $ProcessList[$key]['Gy0_sbbh'] = $machineList;
            }
            $ProcessList[$key]['Gy0_yjno'] = $value['Gy0_yjno'];
            $ProcessList[$key]['Gy0_gdbh'] = $param['workorder'];
            $ProcessList[$key]['Gy0_gxmc'] = $value['gy0_gxmc'];
            $ProcessList[$key]['Gy0_SITE'] = $value['Gy0_site'];
            $ProcessList[$key]['Gy0_shdh'] = $value['Gy0_shdh'];
            $ProcessList[$key]['Gy0_Rate0'] = $rate['rate0'];
            $ProcessList[$key]['Gy0_Rate1'] = $rate['rate1'];
            $ProcessList[$key]['Gy0_ks'] = $value['Gy0_Ks'];
            $ProcessList[$key]['Gy0_ms'] = $value['Gy0_Ms'];
            $ProcessList[$key]['Gy0_oil'] = $value['Gy0_Oil'];
            $ProcessList[$key]['Gy0_计划接货数'] = 0;
            $ProcessList[$key]['Gy0_计划损耗'] = 0;
            $ProcessList[$key]['无形损承担比例'] = 0;
            $ProcessList[$key]['超节损承担比例'] = 1;
            $ProcessList[$key]['超节损核算单价'] = 0;
            $ProcessList[$key]['Gy0_sj1'] = '1900-01-01 00:00:00';
            $ProcessList[$key]['Gy0_sj2'] = '1900-01-01 00:00:00';
//            $ProcessList[$key]['UniqId'] = $ProcesslastId + $key + 1;
            $ProcessList[$key]['PD_WG'] = '1900-01-01 00:00:00';
            $ProcessList[$key]['Sys_rq'] = date('Y-m-d H:i:s', time());
            unset($ProcessList[$key]['Gy0_Oil'],$ProcessList[$key]['Gy0_Ms'],$ProcessList[$key]['Gy0_Ks'],$ProcessList[$key]['UniqID'],$ProcessList[$key]['Gy0_cpdh'],$ProcessList[$key]['gy0_gxmc'],$ProcessList[$key]['Gy0_site']);
        }
        //插入数据
        \db()->startTrans();
        try {
            \db('工单_工艺资料')->where('Gy0_gdbh',$param['workorder'])->delete();
            $processSql = \db('工单_工艺资料')->fetchSql(true)->insertAll($ProcessList);
            \db()->query($processSql);
            \db('工单_印件资料')->where('Yj_Gdbh',$param['workorder'])->delete();
            $printSql = \db('工单_印件资料')->fetchSql(true)->insertAll($PrintList);
            \db()->query($printSql);
            \db()->commit();
        }catch (\Exception $e){
            \db()->rollback();
//            echo $e->getMessage();
        }
        //计算工序计划生产数量
        if ($number !== null){
            $list = \db('工单_印件资料')->where('Yj_Gdbh',$param['workorder'])->field('yj_Yjno,yj_平张投料')->select();
            foreach ($list as $value){
                if ((int)$value['yj_平张投料'] >0){
                    $this->PlannedProcessYield($param['workorder'],$value['yj_Yjno'],0,$value['yj_平张投料']);
                }
            }
        }
        $this->success('成功');
    }

    /**
     * 引用产品印件、工艺资料->信息获取
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function ProductCopeDetail()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param['workorder'])){
            $this->error('参数错误');
        }
        $list = \db('工单_基本资料')
            ->alias('a')
            ->field([
                'rtrim(a.Gd_gdbh)' => '工单编号',
                'rtrim(b.客户编号)' => '客户编号',
                'rtrim(b.客户名称)' => '客户名称',
                'rtrim(b.产品编号)' => '产品编号',
                'rtrim(b.产品名称)' => '产品名称'
            ])
            ->join('产品_基本资料 b','a.成品代号 = b.产品编号')
            ->where('a.Gd_gdbh',$param['workorder'])
            ->find();
        if (empty($list)){
            $this->error('未找到工单信息');
        }
        $option = \db('产品_工艺资料')
            ->field('rtrim(Gy0_方案) as 方案')
            ->where('Gy0_cpdh',$list['产品编号'])
            ->group('Gy0_方案')
            ->select();
        $list['方案'] = $option;
        $this->success('成功',$list);
    }


    /**
     * 工艺资料计划产量重新分配
     * @param string $workOrder 工单
     * @param int $yjno 印件号
     * @param int $gxh 工序号
     * @param int $feed 平张投料
     * @return bool
     * @throws \think\Exception
     * @throws \think\db\exception\BindParamException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @throws \think\exception\PDOException
     */
    public function PlannedProcessYield($workOrder,$yjno,$gxh,$feed)
    {

        $where = [
            'Gy0_gdbh'=>$workOrder,
            'Gy0_yjno'=>$yjno,
        ];
        //获取工艺资料
        $processList = \db('工单_工艺资料')
            ->where($where)
            ->field('CONCAT(rtrim(Gy0_gxmc),"[",rtrim(Add_gxmc),"]") as 工序名称,Gy0_Rate0 as 损耗定额,Gy0_Rate1 as 损耗率,rtrim(损耗系数) as 损耗系数,Gy0_ms,Gy0_ls,UniqId')
            ->order('Gy0_gxh')
            ->select();
        if (empty($processList)){
            $this->success('未找到该工单工序资料');
        }
        $processDetail = \db('工单_工艺资料')
            ->where($where)
            ->field('CONCAT(rtrim(Gy0_gxmc),"[",rtrim(Add_gxmc),"]") as 工序名称,Gy0_ls as 联数')
            ->select();
        $number1 = $number2 = 1;
        foreach ($processDetail as $k => $v) {
            if (strpos($v['工序名称'],'分切') !== false) {
                $number1 = $v['联数'];
            }
            if (strpos($v['工序名称'],'分切') === false && $v['联数'] > 1) {
                $number2 = $v['联数'];
            }
        }
        $Multiple = $number1/$number2;
        if (is_int($Multiple) === false) {
            $Multiple = 1;
        }
        //计算损耗定额和计划产量
        $production = [];
        $i = $m = 0;
        foreach ($processList as $key=>$value){
            if (strpos($v['工序名称'],'分切') !== false) {
                $m = $key;
            }
            if ($key === 0){
                array_push($production,$feed);
            }else{
                if ($key === $m+1){
                    $production[$key] = $production[$key]/$value['Gy0_ls']/$Multiple;
                }else{
                    $production[$key] = $production[$key]/$value['Gy0_ls'];
                }
            }
            $wastage = 0;
            if ($value['损耗率'] !== 0 && !empty($value['损耗率'])){
                $wastage = ($production[$key]*$value['损耗率']+$value['损耗定额'])*$value['损耗系数'];
            }
            if ($value['Gy0_ms'] >0 && !empty($value['Gy0_ms'])){
                $wastage = round($wastage * $value['Gy0_ms']);
            }
            array_push($production,ceil($production[$key]-$wastage)*$value['Gy0_ls']);
            $processSql = \db('工单_工艺资料')
                ->where('UniqId',$value['UniqId'])
                ->fetchSql(true)
                ->update(['Gy0_计划接货数'=>$production[$key],'Gy0_计划损耗'=>$wastage]);
            $res = \db()->query($processSql);
            if ($res === false){
                $i++;
            }
        }
        if ($i===0){
            return true;
        }else{
            return false;
        }
    }

    /**
     * 工单资料删除
     * @return void
     * @throws \think\exception\PDOException
     */
    public function WorkOrderDel()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (isset($param['UniqId']) === false){
            $this->error('参数错误');
        }
        $WorkOrderId = explode(',',$param['UniqId']);
        $i = 0;
        foreach ($WorkOrderId as $key=>$value){
            //获取工单编号
            $workorder = \db('工单_基本资料')
                ->where('Uniqid',$value)
                ->value('rtrim(Gd_gdbh)');
            $status = \db('设备_产量计酬')
                ->where('sczl_gdbh',$workorder)
                ->count();
            if ($status === 0){
                //删除工单资料、工艺资料、印件资料
                \db()->startTrans();
                try {
                    \db('工单_基本资料')->where('Gd_gdbh',$workorder)->delete();
                    if (!empty(\db('工单_工艺资料')->where('Gy0_gdbh',$workorder)->find())){
                        \db('工单_工艺资料')->where('Gy0_gdbh',$workorder)->delete();
                    }
                    if (!empty(\db('工单_印件资料')->where('Yj_Gdbh',$workorder)->find())){
                        \db('工单_印件资料')->where('Yj_Gdbh',$workorder)->delete();
                    }
                    if (!empty(\db('工单_bom资料')->where('BOM_工单编号',$workorder)->find())){
                        \db('工单_bom资料')->where('BOM_工单编号',$workorder)->delete();
                    }
                    \db()->commit();

                    // 成功删除后记录日志
                    $logSql = \db('系统操作日志表')->fetchSql(true)->insert([
                        'Gd_gdbh'      => $workorder,
                        'ModifyUser'   => $param['sys_id'],
                        'ModifyTime'   => date('Y-m-d H:i:s'),
                        'FieldName'    => '工单删除',
                        'NewValue'     => '已删除',
                        'ModifySource' => '工单删除'
                    ]);
                    \db()->query($logSql);
                }catch (\Exception $e){
                    \db()->rollback();
                    $i++;
                }
            }else{
                $this->error('工单'.$workorder.'已上报数据无法删除，请重新确认');
            }

        }
        if ($i === 0){
            $this->success('删除成功');
        }else{
            $this->error('删除失败');
        }
    }

    /**
     * 修正核算参数-》工单产品信息获取
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function ProductNameData()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $workOrder = input('workOrder');
        if (empty($workOrder)){
            $this->error('参数错误');
        }
        $orderList = \db('工单_基本资料')
            ->field('rtrim(Gd_cpdh) as 印件代号,rtrim(Gd_cpmc) as 印件名称,rtrim(成品代号) as 产品代号,rtrim(成品名称) as 产品名称')
            ->where('Gd_gdbh',$workOrder)
            ->find();
        $this->success('成功',$orderList);
    }

    /**
     * 获取联数
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getCouplet()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param['gdbh']) || empty($param['yjno'])){
            $this->error('参数错误');
        }
        $list = \db('工单_印件资料')
            ->where('Yj_gdbh',$param['gdbh'])
            ->where('yj_Yjno',$param['yjno'])
            ->field('rtrim(yj_ks) as 开数,rtrim(yj_ls) as 联数')
            ->find();
        $process = \db('工单_工艺资料')
            ->where('Gy0_gdbh',$param['gdbh'])
            ->where('Gy0_yjno',$param['yjno'])
            ->order('Gy0_gxh desc')
            ->value('Gy0_gxh');
        $list['工序号'] = $process + 1;
        $this->success('成功',$list);
    }

    /**
     * 糊盒工单配件完成度查询
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function Accessories()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param['batch'])){
            $this->error('参数错误');
        }
        $list = \db('工单_基本资料')
            ->alias('a')
            ->join('工单_印件资料 b','a.Gd_gdbh=b.Yj_Gdbh')
            ->join('成品入仓 c','a.Gd_gdbh=c.jjcp_gdbh and a.销售订单号 = c.订单编号 and b.yj_Yjno = c.jjcp_yjno','left')
            ->where('a.销售订单号',$param['batch'])
            ->field('a.Gd_gdbh as 工单编号,b.yj_Yjno as 印件号,b.yj_yjmc as 印件名称,b.yj_平张投料*b.yj_ls*b.yj_ks as 计划产量,SUM(c.jjcp_sl) as 入仓数量')
            ->group('a.Gd_gdbh,b.yj_Yjno')
            ->order('a.Gd_gdbh,b.yj_Yjno')
            ->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 HuheWorkOrderSearch()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param['search'])){
            $this->error('参数错误');
        }
        $where['Gd_gdbh|Gd_cpmc|成品名称'] = ['like','%'.$param['search'].'%'];
        $where['Gd_lx'] = '糊盒标准工单';
        $list = \db('工单_基本资料')
            ->field('Gd_gdbh as 工单编号,Gd_cpdh as 产品编号,Gd_cpmc as 产品名称,成品代号,成品名称,Uniqid')
            ->where($where)
            ->group('Gd_gdbh,Gd_cpdh,Gd_cpmc')
            ->order('Gd_gdbh,Gd_cpdh')
            ->select();
        if (empty($list)){
            $this->error('未找到数据');
        }else{
            $this->success('成功',$list);
        }
    }


    /**
     * 复制糊盒工单
     * @return void
     */
    public function HuheWorkOrderCopy()
    {
        try {
            // 1. 请求验证
            if (!$this->request->isGet()) {
                throw new \Exception('请求方式错误，请使用GET请求');
            }

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

            // 2. 查询工单基本信息
            $sourceWorkOrder = $this->getWorkOrderInfo($param['form_Uniqid'], ['Gd_gdbh', '行号']);
            $targetWorkOrder = $this->getWorkOrderInfo($param['to_Uniqid'], ['Gd_gdbh', '行号', '订单数量', '实际投料']);

            // 3. 复制印件资料和工艺资料
            $this->copyPrintingData($sourceWorkOrder, $targetWorkOrder, $param['sys_id']);
            $this->copyProcessData($sourceWorkOrder, $targetWorkOrder, $param['sys_id']);

            $this->success('复制成功');

        } catch (\Exception $e) {

            $this->error($e->getMessage());
        }
    }

    /**
     * 验证复制所需的参数
     * @param array $params
     * @throws \Exception
     */
    private function validateCopyParams(array $params): void
    {
        if (empty($params['to_Uniqid'])) {
            throw new \Exception('目标工单ID（to_Uniqid）不能为空');
        }

        if (empty($params['form_Uniqid'])) {
            throw new \Exception('源工单ID（form_Uniqid）不能为空');
        }

        if (empty($params['sys_id'])) {
            throw new \Exception('系统ID（sys_id）不能为空');
        }
    }

    /**
     * 获取工单信息
     * @param string $uniqid 工单唯一标识
     * @param array $fields 需要查询的字段
     * @return array 工单信息
     * @throws \Exception
     */
    private function getWorkOrderInfo(string $uniqid, array $fields = []): array
    {
        $info = \db('工单_基本资料')
            ->field($fields)
            ->where('Uniqid', $uniqid)
            ->find();

        if (empty($info)) {
            throw new \Exception("工单不存在，ID: {$uniqid}");
        }

        return $info;
    }

    /**
     * 复制印件资料
     * @param array $sourceWorkOrder 源工单信息
     * @param array $targetWorkOrder 目标工单信息
     * @param string $sysId 系统ID
     * @throws \Exception
     */
    private function copyPrintingData(array $sourceWorkOrder, array $targetWorkOrder, string $sysId): void
    {
        // 常量定义，便于维护
        $tableName = '工单_印件资料';
        $excludeFields = ['Uniqid', 'Yj_Gdbh', 'yj_Yjno', 'yj_成品数量', 'yj_平张投料', '印件完工日期', 'Sys_id', 'Sys_rq', 'Mod_rq'];

        // 查询源印件资料
        $printingData = \db($tableName)
            ->where('Yj_Gdbh', $sourceWorkOrder['Gd_gdbh'])
            ->where('yj_Yjno', $sourceWorkOrder['行号'])
            ->find();

        if (empty($printingData)) {
            throw new \Exception('未找到源工单印件资料');
        }

        // 构建新的印件资料
        $newPrintingData = $this->buildCopyData(
            $printingData,
            $excludeFields,
            [
                'Yj_Gdbh' => $targetWorkOrder['Gd_gdbh'],
                'yj_Yjno' => $targetWorkOrder['行号'],
                'yj_成品数量' => $targetWorkOrder['订单数量'],
                'yj_平张投料' => $targetWorkOrder['实际投料'],
                '印件完工日期' => null,
                'Sys_id' => $sysId,
                'Sys_rq' => date('Y-m-d H:i:s'),
                'Mod_rq' => null
            ]
        );

        \db($tableName)
            ->where('Yj_Gdbh',$newPrintingData['Yj_Gdbh'])
            ->where('yj_Yjno',$newPrintingData['yj_Yjno'])
            ->delete();
        // 执行插入操作（保留fetchSql和query兼容中文字段）
        $sql = \db($tableName)->fetchSql(true)->insert($newPrintingData);
        $result = \db()->query($sql);
        if ($result === false) {
            throw new \Exception("印件资料复制失败，SQL: {$sql}");
        }
    }

    /**
     * 复制工艺资料
     * @param array $sourceWorkOrder 源工单信息
     * @param array $targetWorkOrder 目标工单信息
     * @param string $sysId 系统ID
     * @throws \Exception
     */
    private function copyProcessData(array $sourceWorkOrder, array $targetWorkOrder, string $sysId): void
    {
        // 常量定义
        $tableName = '工单_工艺资料';
        $excludeFields = ['UniqId', 'Gy0_gdbh', 'Gy0_yjno', 'Gy0_sbbh', 'Gy0_计划接货数', 'Gy0_最早开工时间', 'Gy0_sj1', 'Gy0_sj2', 'PD_WG', 'Sys_id', 'Sys_rq', 'Mod_rq'];
        $defaultDate = '1900-01-01 00:00:00';
        $currentTime = date('Y-m-d H:i:s');

        // 查询源工艺资料列表
        $processList = \db($tableName)
            ->where('Gy0_gdbh', $sourceWorkOrder['Gd_gdbh'])
            ->where('Gy0_yjno', $sourceWorkOrder['行号'])
            ->select();

        if (empty($processList)) {
            throw new \Exception('未找到源工单工艺资料');
        }

        // 构建新的工艺资料列表
        $newProcessData = [];
        foreach ($processList as $item) {
            $newProcessData[] = $this->buildCopyData(
                $item,
                $excludeFields,
                [
                    'Gy0_gdbh' => $targetWorkOrder['Gd_gdbh'],
                    'Gy0_yjno' => $targetWorkOrder['行号'],
                    'Gy0_sbbh' => '',
                    'Gy0_计划接货数' => $targetWorkOrder['实际投料'],
                    'Gy0_最早开工时间' => $defaultDate,
                    'Gy0_sj1' => $defaultDate,
                    'Gy0_sj2' => $defaultDate,
                    'PD_WG' => $defaultDate,
                    'Sys_id' => $sysId,
                    'Sys_rq' => $currentTime,
                    'Mod_rq' => null
                ]
            );
        }

        \db($tableName)
            ->where('Gy0_gdbh', $targetWorkOrder['Gd_gdbh'])
            ->where('Gy0_yjno', $targetWorkOrder['行号'])
            ->delete();
        // 执行批量插入（保留fetchSql和query兼容中文字段）
        if (!empty($newProcessData)) {
            $sql = \db($tableName)->fetchSql(true)->insertAll($newProcessData);
            $result = \db()->query($sql);
            if ($result === false) {
                throw new \Exception("工艺资料复制失败，SQL: {$sql}");
            }
        }
    }

    /**
     * 构建复制的数据
     * @param array $sourceData 源数据
     * @param array $excludeFields 需要排除的字段
     * @param array $overrideData 需要覆盖的字段和值
     * @return array 构建后的新数据
     */
    private function buildCopyData(array $sourceData, array $excludeFields, array $overrideData): array
    {
        $newData = [];

        // 复制源数据中不需要排除的字段
        foreach ($sourceData as $key => $value) {
            if (!in_array($key, $excludeFields)) {
                $newData[$key] = $value;
            }
        }

        // 覆盖需要替换的字段
        return array_merge($newData, $overrideData);
    }


    /**
     * 糊盒标准工单左侧菜单栏
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function HuheDataList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $list = \db('产品_基本资料')
            ->where('客户编号','<>','')

            ->field('rtrim(客户编号) as 客户编号,rtrim(客户名称) as 客户名称')
            ->group('客户编号,客户名称')
            ->order('客户编号')
            ->select();
        if (empty($list)){
            $this->success('',[]);
        }
        $data['糊盒工单'] = [];
        foreach ($list as $key=>$value){

            $work_order_count = \db('工单_基本资料')
                ->where('行号','1')
                ->where('Gd_cpdh|成品代号','LIKE',rtrim($value['客户编号']).'%')
                ->where('Gd_lx','糊盒标准工单')
                ->count();
            if (!empty($value['客户名称']) && $work_order_count !== 0){
                $name = $value['客户编号'].rtrim($value['客户名称']);
                if (strpos($value['客户编号'],'J') !== false ){
                    array_push($data['糊盒工单'],$name);
                }
            }

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


    /**
     * 糊盒标准工单列表
     * @return void
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function HuheWorkList()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $search = input('search');
        $clientNumber = input('Gd_khdh');
        $startTime = input('start');
        $endTime = input('end');
        $page = input('page');
        $limit = input('limit');
        $param = $this->request->param();

        $where = [];
        if (!empty($clientNumber)){
            if (substr($clientNumber,0,1) !== 'Y' && substr($clientNumber,0,1) !== 'J')
            {
                $clientNumber = substr($clientNumber,0,4);
            }
            if ($clientNumber === 'Y1401'){
                $where['Gd_cpdh'] = ['like',$clientNumber.'%'];
            }else{
                $where['成品代号'] = ['like',$clientNumber.'%'];
            }
        }

        if (!empty($workOrder)){
            $where['Gd_gdbh'] = $workOrder;
        }
        if (!empty($productCode)){
            $where['Gd_cpdh'] = $productCode;
        }
        if (!empty($search)){
            $where['Gd_gdbh|Gd_客户代号|Gd_客户名称|Gd_khdh|Gd_khmc|Gd_cpdh|Gd_cpmc|成品代号|成品名称|产品版本号'] = ['like','%'.$search.'%'];
        }
        if (!empty($startTime) && !empty($endTime)){
            $where['接单日期'] = ['between',[$startTime,$endTime]];
        }
        $where['Gd_lx'] = '糊盒标准工单';
        $total = \db('工单_基本资料')->where($where)->distinct(true)->field('Gd_gdbh')->count();
        $list = \db('工单_基本资料')
            ->where($where)
            ->order('Gd_statu desc')
            ->limit(($page-1)*$limit,$limit)
            ->group('Gd_gdbh')
            ->select();
        //工单基本资料数据整理
        $data = [];
        foreach ($list as $key=>$value){
            $data[$key] = [
                '工单编号' => rtrim($value['Gd_gdbh']),
                '生产分类' => rtrim($value['Gd_生产分类']),
                '销售订单号' => rtrim($value['销售订单号']),
                '产品代号' => rtrim($value['成品代号']),
                '产品名称' => rtrim($value['成品名称']),
                '订单数量' => floatval($value['订单数量']),
                '单位' => rtrim($value['计量单位']),
                '折合大箱' => rtrim((int)$value['投料大箱']),
                '投料率' => rtrim($value['投料率']),
                '平均合格率' => '',
                '开单日期' => date('Y-m-d',strtotime(rtrim($value['接单日期']))),
                '交货日期' => date('Y-m-d',strtotime(rtrim($value['交货日期']))),
                '工单类型' => rtrim($value['Gd_lx']),
                '工单状态' => rtrim($value['gd_statu']),
                '当前生产工序' => '',
                '产量提交时间' =>  '',
                '建档用户' => rtrim($value['Sys_id']),
                '建档时间' => rtrim($value['Sys_rq']),
                '更新时间' => rtrim($value['Mod_rq']),
                'Uniqid' => rtrim($value['Uniqid'])
            ];

            $number = \db('工单_工艺资料')->where('Gy0_gdbh',$data[$key]['工单编号'])->count();
            if ($number === 0){
                $data[$key]['status'] = '*';
            }else{
                $data[$key]['status'] = '';
            }
        }
        $this->success('成功',['data'=>$data,'total'=>$total]);
    }



    /**
     * 成品入仓之后定时任务，更新工单状态（建议每天凌晨执行）
     * 条件：已录入末板，且最后一条入仓时间超过1个月，工单未完工
     * @return void
     */
    public function updateWorkOrderStatus()
    {
        $deadline = date('Y-m-d H:i:s', strtotime('-1 month'));
        $now = date('Y-m-d H:i:s');
        $endBoardOrders = \db('成品入仓')
            ->where('jjcp_smb', 'like', '末%')
            ->field('jjcp_gdbh,jjcp_yjno')
            ->group('jjcp_gdbh,jjcp_yjno')
            ->select();

        $updated = 0;
        $skipped = 0;
        $logs = [];

        foreach ($endBoardOrders as $order) {
            $gdbh = trim((string)$order['jjcp_gdbh']);
            $yjno = trim((string)$order['jjcp_yjno']);
            if ($gdbh === '' || $yjno === '') {
                $skipped++;
                continue;
            }

            $lastSj = \db('成品入仓')
                ->where('jjcp_gdbh', $gdbh)
                ->where('jjcp_yjno', $yjno)
                ->max('jjcp_sj');
            if (empty($lastSj) || $lastSj > $deadline) {
                $skipped++;
                continue;
            }

            $workOrder = \db('工单_基本资料')
                ->where('Gd_gdbh', $gdbh)
                ->where('行号', $yjno)
                ->field('Gd_gdbh,行号,rtrim(gd_statu) as gd_statu,工单完工日期')
                ->find();
            if (empty($workOrder)) {
                $skipped++;
                continue;
            }

            if (!$this->isEmptyWorkOrderFinishDate($workOrder['工单完工日期'])) {
                $skipped++;
                continue;
            }
            if (trim((string)$workOrder['gd_statu']) === '1-已完工') {
                $skipped++;
                continue;
            }

            $updateResult = \db('工单_基本资料')
                ->where('Gd_gdbh', $gdbh)
                ->where('行号', $yjno)
                ->update([
                    '工单完工日期' => $now,
                    'gd_statu'     => '1-已完工',
                    'Mod_rq'       => $now,
                ]);
            if ($updateResult === false) {
                $skipped++;
                continue;
            }

            $updated++;
            $logs[] = [
                'Gd_gdbh'      => $gdbh,
                'yjno'         => $yjno,
                'ModifyUser'   => 'system',
                'ModifyTime'   => $now,
                'FieldName'    => 'gd_statu',
                'OldValue'     => trim((string)$workOrder['gd_statu']),
                'NewValue'     => '1-已完工',
                'ModifySource' => '成品入仓定时任务',
            ];
            $logs[] = [
                'Gd_gdbh'      => $gdbh,
                'yjno'         => $yjno,
                'ModifyUser'   => 'system',
                'ModifyTime'   => $now,
                'FieldName'    => '工单完工日期',
                'OldValue'     => trim((string)$workOrder['工单完工日期']),
                'NewValue'     => $now,
                'ModifySource' => '成品入仓定时任务',
            ];
        }

        if (!empty($logs)) {
            \db('系统操作日志表')->insertAll($logs);
        }

        $this->success('定时任务执行完成', [
            'updated'       => $updated,
            'skipped'       => $skipped,
            'total_checked' => count($endBoardOrders),
            'deadline'      => $deadline,
        ]);
    }

    /**
     * 判断工单完工日期是否为空
     * @param mixed $date
     * @return bool
     */
    protected function isEmptyWorkOrderFinishDate($date)
    {
        if ($date === null) {
            return true;
        }
        $date = trim((string)$date);
        if ($date === '') {
            return true;
        }
        $timestamp = strtotime($date);
        return $timestamp === false || $timestamp <= strtotime('1900-01-02');
    }
}