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

<?php

namespace app\api\controller;

use app\common\controller\Api;
use think\Cache;
use think\Exception;
use think\Log;
use think\Queue;
use \think\Request;
use \think\Db;
/**
 * 工单超节损核算接口
 */
class OrderSuperLoss extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];

    /**
     * 首页-已核查成品编号
     *
     */
    public function index()
    {
        $this->success('请求成功');
    }
    /**
     * 获取左侧菜单栏
     * @ApiMethod GET
     */
    public function getTab()
    {
        if (Request::instance()->isGet() == false) {
            $this->error('非法请求');
        }
        $sql = "SELECT   
                    DATE_FORMAT(a.jjcp_sj, '%Y-%m') AS date,  -- Format the date for grouping  
                    RTRIM(b.`编号`) AS 编号,  
                    RTRIM(b.`名称`) AS 客户名称,  
                    COUNT(DISTINCT a.jjcp_gdbh) AS count   
                FROM   
                    `成品入仓` a  
                LEFT JOIN   
                    `物料_存货结构` b   
                    ON (CASE   
                            WHEN LEFT(a.`jjcp_cpdh`, 1) REGEXP '^[A-Za-z]' THEN LEFT(a.`jjcp_cpdh`, 5)   
                            ELSE LEFT(a.`jjcp_cpdh`, 4)   
                        END) = RTRIM(b.`编号`)  -- Conditional join based on the first character  
                
                WHERE   
                    a.jjcp_sj >= DATE_SUB(CURDATE(), INTERVAL 12 MONTH)  -- Direct date comparison  
                    AND (a.jjcp_smb IN ('末 板', '末板'))  -- Cleaner syntax for conditions  
                    AND a.`成品编码` != ''
                    AND a.jjcp_sj >= '2025-01-01 00:00:00'
                GROUP BY   
                    DATE_FORMAT(a.jjcp_sj, '%Y-%m'),  -- Group by formatted date  
                    RTRIM(b.`编号`)   
                ORDER BY   
                    date DESC,  
                    编号 ASC;";
        $data = Db::query($sql);

        // 创建一个新数组来存储整理后的数据
        $organizedData = [];
        // 遍历原始数据
        foreach ($data as $entry) {
            $date = date('Ym',strtotime($entry['date']));

            // 检查日期是否在已整理数据中存在
            if (isset($organizedData[$date])) {
                // 如果日期存在，将数据追加到该日期下
                $organizedData[$date][] = [
                    '客户名称' => $entry['客户名称'],
                    '客户编号' => $entry['编号'],
                    'total' => $entry['count'],
                ];
                // 统计该日期下所有数据的总和
                $organizedData[$date]['total_count'] += $entry['count'];
            } else {
                // 如果日期不存在，创建新的日期项并添加数据
                $organizedData[$date] = [
                    [
                        '客户名称' => $entry['客户名称'],
                        '客户编号' => $entry['编号'],
                        'total' => $entry['count'],
                    ]
                ];
                // 初始化该日期的总和
                $organizedData[$date]['total_count'] = $entry['count'];
            }
        }

        // 将整理后的数据调整为以日期和相加的总和为索引的格式
        $finalData = [];
        foreach ($organizedData as $date => $entries) {
            $totalCount = $entries['total_count'];
            $index = $date . '-' . $totalCount;
            unset($entries['total_count']);
            $finalData[$index] = $entries;
        }
        $this->success('请求成功',$finalData);
    }

    /**
     * 获取工单超节损工艺
     * @ApiMethod GET
     * @params string order
     */
    public function getOrderSuperLossGy(){
        if (Request::instance()->isGet() == false) {
            $this->error('非法请求');
        }
        $params = Request::instance()->param();
        if (!isset($params['order']) || empty($params['order'])) {
            $this->error('参数错误');
        }
        if (!isset($params['yjno']) || empty($params['yjno'])) {
            $this->error('参数错误');
        }
        $sql = "SELECT a.Gy0_gdbh,a.Gy0_yjno,a.Gy0_gxh,rtrim(a.Gy0_gxmc) as Gy0_gxmc,rtrim(a.Add_gxmc) as Add_gxmc,
                a.Gy0_ls,a.Gy0_Rate0,a.Gy0_Rate1,a.损耗系数,a.Gy0_ms,a.Gy0_计划接货数*a.Gy0_ls as Gy0_计划接货数,
                a.Gy0_计划损耗*a.Gy0_ls as Gy0_计划损耗,sum(b.sczl_cl) as total_cl,sum(b.sczl_zcfp) as total_fp,
                sum(c.sczl_cl) as cl,SUM(c.sczl_fp) as fp,rtrim(a.印刷方式) as 印刷方式,rtrim(a.版距) as 版距
                FROM `工单_工艺资料` a
                LEFT JOIN `设备_产量计酬` b ON a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_gxh = b.sczl_gxh
                LEFT JOIN `db_sczl` c ON a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_gxh = c.sczl_gxh
                WHERE a.Gy0_gdbh = '{$params['order']}' AND a.Gy0_yjno = '{$params['yjno']}' GROUP BY a.Gy0_gxh";
        $data = Db::query($sql);
        foreach ($data as $key=>$value){
            if (!empty($value['total_cl'])){
                $data[$key]['total_cl'] = $value['total_cl'] *$value['Gy0_ls'];
            }else{
                $data[$key]['total_cl'] =$value['cl'] *$value['Gy0_ls'];
            }
            if (!empty($value['total_fp'])){
                $data[$key]['total_fp'] = $value['total_fp'] *$value['Gy0_ls'];
            }else{
                $data[$key]['total_fp'] = $value['fp'] *$value['Gy0_ls'];
            }
            if ($value['印刷方式'] === '卷对卷'){
                $data[$key]['total_cl'] = ceil($data[$key]['total_cl'] / $value['版距']*1000);
                $data[$key]['total_fp'] = ceil($data[$key]['total_fp'] / $value['版距']*1000);
            }
            unset($data[$key]['cl']);
            unset($data[$key]['fp']);
        }
        $this->success('请求成功',$data);
    }
    /**
     * 工单超节损统计
     * @ApiMethod GET
     * @params string order
     * 节损奖 小盒0.02 大盒0.09
     */
    public function getOrderSuperLossCount(){
        if (Request::instance()->isGet() == false) {
            $this->error('非法请求');
        }
        $params = Request::instance()->param();
        if (!isset($params['order']) || empty($params['order'])) {
            $this->error('参数错误');
        }
        $order = $params['order'];
        $field = 'a.Gd_gdbh,rtrim(a.成品代号) as 成品代号,rtrim(a.成品名称) as 成品名称,rtrim(a.销售订单号) as 销售订单号,a.订单数量,c.yj_ls as ls,c.yj_ks as ks,SUM(b.st_sl) as 投料';
        $data =db('工单_基本资料')
            ->alias('a')
            ->join('物料_收发记录 b','a.Gd_gdbh = b.st_gdbh AND a.Gd_cpdh = b.cpdh')
            ->join('工单_印件资料 c','c.Yj_Gdbh = a.Gd_gdbh AND c.yj_Yjdh = a.Gd_cpdh')
            ->where('a.Gd_Gdbh',$order)
            ->where('a.行号',$params['yjno'])
            ->where('c.yj_Yjno',$params['yjno'])
            ->where(function($query) {
                $query->where('b.仓库编号', '101')
                    ->whereOr('b.仓库编号', 'Y101');})
            ->field($field)
            ->find();
        if ($data['ls'] == 0){
            $data['ls'] === 1;
        }
        if ($data['ks'] == 0){
            $data['ks'] === 1;
        }
        $data['实际投料'] = number_format($data['投料'] * $data['ls'] * $data['ks'] / 10000, 4, '.', '');
        if($data['实际投料'] == 0){
            $this->error('投料数据为 0,请点击超节损页面“修正工单投料”按钮进行修正');
            return;
        }
        //查出成品数量及日期
        $cp_sql = "SELECT SUM(jjcp_sl) as cp_sl,MAX(jjcp_sj) as jjcp_sj FROM `成品入仓` WHERE jjcp_gdbh = '{$order}' AND jjcp_yjno = '{$params['yjno']}' GROUP BY jjcp_gdbh,jjcp_yjno";
        $cp_data = Db::query($cp_sql);
        if (empty($cp_data)){
            $this->success('此工单未查询到成品入库信息,请核查该工单是否已进入超节损');
        }
        $data['warehousing_num'] = $cp_data[0]['cp_sl'];
        $data['warehousing_date'] = substr($cp_data[0]['jjcp_sj'],0,10);
        $gxh_values = $this->getSuperLossProcessGxhList($order, $params['yjno']);
        if (empty($gxh_values)) {
            $this->error('未查询到报工工序');
        }
        $sczlProcessSub = $this->buildSczlProcessAggSubSql();
        $gy_data =db('工单_工艺资料')
            ->alias('a')
            ->field([
                'a.Gy0_yjno', 'a.Gy0_gxh', 'RTRIM(a.Gy0_gxmc) as Gy0_gxmc','RTRIM(a.Add_gxmc) as Add_gxmc','a.Gy0_ks', 'a.Gy0_ls', 'a.Gy0_计划接货数*a.Gy0_ls as Gy0_计划接货数',
                'a.Gy0_计划损耗', 'a.无形损承担比例','a.超节损承担比例','SUM(b.sczl_zcfp) as total_fp','SUM(b.sczl_cl) as total_cl','SUM(c.cl) as cl','SUM(c.fp) as fp',
            ])
            ->join('设备_产量计酬 b', 'a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh','left')
            ->join([$sczlProcessSub => 'c'], 'a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_yjno = c.sczl_yjno AND a.Gy0_gxh = c.sczl_gxh', 'left')
            ->where([
                'a.Gy0_gdbh' => $order,
                'a.Gy0_yjno' => $params['yjno'],
                'a.Gy0_gxh' => ['in', $gxh_values]
            ])
            ->group('a.Gy0_yjno,a.Gy0_gxh')
            ->select();
        $arr = [];
        $plan_loss = [];//工单计划损耗
        foreach ($gy_data as $k=>$v){
            $rate =  round($v['Gy0_计划损耗'] / $v['Gy0_计划接货数'],5);
            $arr[$k] = floor($rate * 10000) /10000;
            $plan_loss[$k] = $v['Gy0_计划损耗'];
        }
        $target_rate =  (1-array_sum($arr))*100;
        $data['target_rate'] =$target_rate.'%'; //目标合格率
        $real_rate = $cp_data[0]['cp_sl'] / ((float)$data['实际投料'] * 10000) *100;
        $data['real_rate'] = number_format($real_rate,2) . '%';//实际合格率
        //制程废品
        $zzfp_data =db('设备_产量计酬')->where('sczl_gdbh',$order)->where('sczl_yjno',$params['yjno'])->value('SUM(sczl_zcfp) as sczl_zcfp');
        //联数
        $ls =db('工单_工艺资料')->where('Gy0_gdbh',$order)->field('Gy0_ls,Gy0_ks')->find();
        //制程废品*ls
        $data['zcfp'] = $zzfp_data * $ls['Gy0_ls'] * $ls['Gy0_ks'];
        //废品数量
        $wasteTotal = db('db_qczl')->where('qczl_gdbh',$order)->where('qczl_yjno',$params['yjno'])->sum('qczl_fp');
        if (empty($wasteTotal)){
            $wasteTotal = 0;
        }
        //废品合计
        $waste_total = $data['zcfp'] + $wasteTotal;
        //工单无形损
        $data['intangible_loss'] = (int)((float)$data['实际投料'] *10000 - $cp_data[0]['cp_sl'] - $waste_total);
        $out_sql = "SELECT fp_sl1,fp_sl2,fp_sl3,fp_sl4,fp_sl5,fp_sl6,fp_sl7,fp_sl8,fp_sl9,fp_sl10,fp_sl11,fp_sl12,fp_sl13,
                        fp_lb1,fp_lb2,fp_lb3,fp_lb4,fp_lb5,fp_lb6,fp_lb7,fp_lb8,fp_lb9,fp_lb10,fp_lb11,fp_lb12,fp_lb13, 
                        fp_bh1,fp_bh2,fp_bh3,fp_bh4,fp_bh5,fp_bh6,fp_bh7,fp_bh8,fp_bh9,fp_bh10,fp_bh11,fp_bh12,fp_bh13,
                        fp_gxmc1,fp_gxmc2,fp_gxmc3,fp_gxmc4,fp_gxmc5,fp_gxmc6,fp_gxmc7,fp_gxmc8,fp_gxmc9,fp_gxmc10,fp_gxmc11,fp_gxmc12,fp_gxmc13,UniqId
                        FROM db_qczl WHERE qczl_gdbh = '{$order}' AND qczl_yjno = '{$params['yjno']}'";
        $waste_out = Db::query($out_sql);
        $list = []; //外发废数组
        $quality = [];//质检废数组
        $material = [];//材料废数组
        $change = [];//零头处理数组
        $jijian = [];//机检数据
        $j = 0;
        $m = 0;
        $n = 0;
        $l = 0;
        $s = 0;
        foreach ($waste_out as $entry) {
            for ($i = 1; $i <= 13; $i++) {
                $labelKey = "fp_lb" . $i;
                $bhKey = "fp_bh" . $i;
                $gxmcKey = "fp_gxmc" . $i;
                $slKey = "fp_sl" . $i;
                if (!empty($entry[$labelKey])) {
                    //外发废
                    if (substr($entry[$labelKey],0,3) == 'M04'){
                        $list[$j]= $entry[$slKey];
                        $j++;
                    }
                    //材料废
                    if (substr($entry[$labelKey],0,1) == 'L' ){
                        $material[$n]= $entry[$slKey];
                        $n++;
                    }
                    //零头处理
                    if (substr($entry[$labelKey],0,3) == 'M01' ){
                        $change[$l]= $entry[$slKey];
                        $l++;
                    }

                    //机检数据
                    if (substr($entry[$labelKey],0,1) == 'K' ){
                        $jijian[$s]= $entry[$slKey];
                        $s++;
                    }
                }
                $quality[$m]= $entry[$slKey];
                $m++;
            }
        }
        $data['材料废'] = array_sum($material); //材料废
        $data['零头处理'] = array_sum($change); //零头处理
        $data['外发废'] = array_sum($list);//外发废
        $data['工单质检废'] =  array_sum($quality);//质检废
        $data['机检废品'] = array_sum($jijian);
        $plan_total = $this->getIntangibleAllocationPlanLossTotal($order, $params['yjno'], $gxh_values);
        if ($plan_total == 0) {
            $this->error('计划损耗数据为 0,请到工单资料管理页面修改工艺资料中选择正确的工序损耗');
            return;
        }
        //单据列表最后统计
        $total = [];
        $total['plan_loss'] = 0;
        $total['total_fp'] = 0;
        $total['waste_quality'] = 0;
        $total['waste_intangible'] = 0;
        $total['reward'] = 0; //超节损奖励数组
        //按工序打印
        if ($params['type'] == 1){
            $total['total_waste'] = 0;
            $total['loss'] = 0;
            $processIntangibleShares = $this->buildProcessIntangibleShareMap(
                $order,
                $params['yjno'],
                $gxh_values,
                floatval($data['intangible_loss'])
            );
            foreach ($gy_data as $k=>$item){
                $gy_data[$k]['Gy0_计划损耗'] = $item['Gy0_计划损耗']*$item['Gy0_ls']*$item['Gy0_ks'];
                $gy_data[$k]['waste_quality'] = 0;
                $gy_data[$k]['total_fp'] = $item['total_fp'] * $item['Gy0_ls'];
                $gy_data[$k]['total_cl'] = $item['total_cl'] * $item['Gy0_ls'];
                $gy_data[$k]['intangible_loss'] = (int)($processIntangibleShares[$this->normalizeGxhKey($item['Gy0_gxh'])] ?? 0);
                foreach ($waste_out as $entry) {
                    for ($i = 1; $i <= 13; $i++) {
                        $gxmcKey = "fp_gxmc" . $i;
                        $slKey = "fp_sl" . $i;
                        if (substr($entry[$gxmcKey], 0, 2) == $item['Gy0_gxh']
                            && !$this->isMachineInspectionProcess((string)$item['Gy0_gxmc'])) {
                            $gy_data[$k]['waste_quality'] += $entry[$slKey];
                        }
                    }
                }
                //报废合计
                $gy_data[$k]['total_waste'] = $gy_data[$k]['waste_quality'] + $gy_data[$k]['intangible_loss'] + $gy_data[$k]['total_fp'];
                //工序节损数
                $gy_data[$k]['loss'] = $item['Gy0_计划损耗'] * $item['Gy0_ls'] * $item['Gy0_ks'] - $gy_data[$k]['total_waste'];
                $this->applyMachineInspectionProcessLossRules(
                    (string)$item['Gy0_gxmc'],
                    (int)$gy_data[$k]['Gy0_计划损耗'],
                    $gy_data[$k]
                );
                //占投料报废率
                $gy_data[$k]['loss_rate'] = number_format($gy_data[$k]['loss'] / $item['Gy0_计划接货数'],4) * 100 .'%';
                //工序目标报废率
                $target_loss_rate = floor($item['Gy0_计划损耗'] / $item['Gy0_计划接货数'] * 10000) / 10000;
                if ($target_loss_rate == 0){
                    $target_loss_rate = round($item['Gy0_计划损耗'] / $item['Gy0_计划接货数'] * 10000) / 10000;
                }
                $gy_data[$k]['target_loss_rate'] = $target_loss_rate * 100 . '%';
                //工序实际报废率
                $gy_data[$k]['actual_loss_rate'] = number_format($gy_data[$k]['total_waste'] / ($data['实际投料']*10000),4) * 100 .'%';
                $gy_data[$k]['超节损承担比例'] = number_format($item['超节损承担比例'],4) * 100 .'%';
                $guige = \db('物料_存货编码')
                    ->where('物料代码',$data['成品代号'])
                    ->value('rtrim(规格)');
                //工序超节损金额
                if ($guige === '小盒'){
                    $moneyRate = 0.02;
                }else{
                    $moneyRate = 0.09;
                }
                if ($this->isSuperLossRewardExcluded((string)$item['Gy0_gxmc'])) {
                    $gy_data[$k]['工序超节损金额'] = '0.000000';
                } else {
                    $gy_data[$k]['工序超节损金额'] = number_format($gy_data[$k]['loss'] * $item['超节损承担比例'] * $moneyRate, 4);
                }
                $total['plan_loss'] += $gy_data[$k]['Gy0_计划损耗'];
                $total['total_fp'] += $gy_data[$k]['total_fp'];
                $total['waste_quality'] += $gy_data[$k]['waste_quality'];
                $total['waste_intangible'] += $gy_data[$k]['intangible_loss'];
                $total['total_waste'] += $gy_data[$k]['total_waste'];
                $total['loss'] += $gy_data[$k]['loss'];
                $total['reward'] += floatval(str_replace(',', '', $gy_data[$k]['工序超节损金额']));
            }
            $feedQty = floatval($data['实际投料']) * 10000;
            $realRateVal = $feedQty > 0 ? (floatval($cp_data[0]['cp_sl']) / $feedQty * 100) : 0;
            $rewardMultiplier = $this->resolveSuperLossRewardMultiplier(
                floatval($target_rate),
                $realRateVal,
                floatval($data['材料废'] ?? 0),
                $feedQty
            );
            $data['reward_rate'] = (string)$rewardMultiplier;
            $data['材料废占比'] = $feedQty > 0
                ? number_format(floatval($data['材料废'] ?? 0) / $feedQty * 100, 4) . '%'
                : null;
            if ($rewardMultiplier > 1) {
                $total['reward'] = 0;
                foreach ($gy_data as $k => $item) {
                    $baseReward = floatval(str_replace(',', '', (string)$gy_data[$k]['工序超节损金额']));
                    if ($baseReward != 0.0) {
                        $gy_data[$k]['工序超节损金额'] = number_format($baseReward * $rewardMultiplier, 4);
                    }
                    $total['reward'] += floatval(str_replace(',', '', $gy_data[$k]['工序超节损金额']));
                }
            }
            $total['reward'] = number_format($total['reward'], 2);
            $data['gy_data'] = $gy_data;
            $data['total'] = $total;
            $this->success('请求成功',$data);
        }else{ //按班组打印
            //总产量数据
            $total_cl_data = \db('工单_工艺资料')->alias('a')
                ->field(['a.Gy0_yjno', 'a.Gy0_gxh','a.Gy0_ls', 'SUM(b.sczl_cl) as total_cl', 'SUM(c.sczl_cl) as cl'])
                ->join('设备_产量计酬 b', 'a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh','left')
                ->join('db_sczl c', 'a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_yjno = c.sczl_yjno AND a.Gy0_gxh = c.sczl_gxh','left')
                ->where([
                    'a.Gy0_gdbh' => $order,
                    'a.Gy0_yjno' => $params['yjno'],
                    'a.Gy0_gxh' => ['IN', $gxh_values],
                    'b.sczl_cl|c.sczl_cl' => ['>', 0]
                ])
                ->group('b.sczl_gxh')
                ->order('a.Gy0_gxh')
                ->select();
            $sczlTeamSub = $this->buildSczlTeamAggSubSql();
            //按班组分的产量数据
            $gy_data =db('工单_工艺资料')
                ->alias('a')
                ->field([
                    'a.Gy0_yjno', 'a.Gy0_gxh', 'a.Gy0_ls', 'a.Gy0_ks' ,'a.Gy0_计划损耗', 'a.无形损承担比例', 'a.超节损承担比例', 'b.sczl_gxmc',
                    'SUM(b.sczl_zcfp) as sczl_zcfp', 'SUM(b.sczl_cl) as total_cl',
                    'b.sczl_bh1', 'b.sczl_bh2', 'b.sczl_bh3', 'b.sczl_bh4', 'b.sczl_bh5', 'b.sczl_bh6',
                    'b.sczl_bh7', 'b.sczl_bh8', 'b.sczl_bh9', 'b.sczl_bh10',
                    'c.gxmc', 'c.cl', 'c.fp', 'c.sczl_bh1 as sczl_bh'
                ])
                ->join('设备_产量计酬 b', 'a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh','left')
                ->join([$sczlTeamSub => 'c'], 'a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_yjno = c.sczl_yjno AND a.Gy0_gxh = c.sczl_gxh AND IFNULL(b.sczl_bh1,\'\') = IFNULL(c.sczl_bh1,\'\')', 'left')
                ->where([
                    'a.Gy0_gdbh' => $order,
                    'a.Gy0_yjno' => $params['yjno'],
                    'a.Gy0_gxh' => ['in', $gxh_values],
                    'b.sczl_cl|c.cl' => ['>', 0]
                ])
                ->group('b.sczl_gxh, b.sczl_bh1, CASE WHEN b.sczl_bh2 = "000000" THEN "" ELSE b.sczl_bh2 END, b.sczl_bh3, 
                         b.sczl_bh4, b.sczl_bh5, b.sczl_bh6, b.sczl_bh7, b.sczl_bh8, b.sczl_bh9')
                ->order('a.Gy0_gxh asc, b.开工时间 asc')
                ->select();
            foreach ($gy_data as $key=>$value){
                $gy_data[$key]['Gy0_yjno'] = $value['Gy0_yjno'] > 10 ? $value['Gy0_yjno'] : '0'.$value['Gy0_yjno'];
                //每道工序的产量（按班组分）
                $gy_data[$key]['total_cl'] = $value['total_cl'] * $value['Gy0_ls'];
                if (empty($value['total_cl'])){
                    $gy_data[$key]['total_cl'] = $value['cl'] * $value['Gy0_ls'];
                }
                $value['Gy0_计划损耗'] = $value['Gy0_计划损耗']*$value['Gy0_ls']*$value['Gy0_ks'];
                //计算每道工序的计划损耗
                foreach ($total_cl_data as $k=>$v){
                    //每道工序的总产量
                    $cl = $v['total_cl'] * $v['Gy0_ls'];
                    if (empty($cl)){
                        $cl = $v['cl'] * $v['Gy0_ls'];
                    }
                    if ($value['Gy0_yjno'] == $v['Gy0_yjno'] && $value['Gy0_gxh'] == $v['Gy0_gxh']){
                        $gy_data[$key]['计划损耗'] = round($gy_data[$key]['total_cl'] / $cl  * $value['Gy0_计划损耗']);
                    }
                }
                //每道工序的制程废品（按班组分）
                $gy_data[$key]['sczl_zcfp'] = $value['sczl_zcfp'] * $value['Gy0_ls'];
                if (empty($value['sczl_zcfp'])){
                    $gy_data[$key]['sczl_zcfp'] = $value['fp'] * $value['Gy0_ls'];
                }
                //计算每道工序的质检废(按班组)
                $gy_data[$key]['sczl_gxmc'] = $value['sczl_gxmc'];
                if (empty($value['sczl_gxmc'])){
                    $gy_data[$key]['sczl_gxmc'] = $value['gxmc'];
                }
                if (empty($value['sczl_bh1']) || is_null($value['sczl_bh1'])) {
                    $value['sczl_bh1'] = $value['sczl_bh'] ?? '';
                }
                $gy_data[$key]['sczl_bh1'] = $value['sczl_bh1'];
                $gy_data[$key]['质检废'] = 0;
                foreach ($waste_out as $entry) {
                    for ($i = 1; $i <= 13; $i++) {
                        $gxmcKey = "fp_gxmc" . $i;
                        $slKey = "fp_sl" . $i;
                        $bhKey = "fp_bh" . $i;
                        if ((int)substr($entry[$gxmcKey],0,2) == $value['Gy0_gxh'] && $entry[$bhKey] == $value['sczl_bh1']){
                            $gy_data[$key]['质检废'] += $entry[$slKey];
                        }
                    }
                }
                //班组成员
                $nameArr = [];
                for ($j = 1; $j <= 10; $j++) {
                    $bhKey = "sczl_bh" . $j;
                    if (!empty($value[$bhKey])){
                        $name = \db('人事_基本资料')->where('员工编号',$value[$bhKey])->value('rtrim(员工姓名)');
                        array_push($nameArr,$name);
                    }
                }
                $gy_data[$key]['member'] = implode(' ',$nameArr);
                unset($gy_data[$key]['Gy0_计划损耗']);
                unset($gy_data[$key]['gxmc']);
                unset($gy_data[$key]['cl']);
                unset($gy_data[$key]['fp']);
                unset($gy_data[$key]['sczl_bh']);

            }
            $this->assignIntangibleLossToGyDataRows(
                $gy_data,
                $order,
                $params['yjno'],
                $gxh_values,
                floatval($data['intangible_loss'])
            );
            $i = 0;
            foreach ($gy_data as &$item) {
                $sczl_bh1 = $item['sczl_bh1'];
                $total_cl = $item['total_cl'];
                //节损数量
                if ($item['无形损分摊'] > 0){
                    $total_waste = $item['质检废']  +  $item['sczl_zcfp'] + $item['无形损分摊'];
                }else{
                    $total_waste = $item['质检废']  +  $item['sczl_zcfp'];
                }
                $gy_data[$i]['节损数量'] = $item['计划损耗'] - $total_waste;
                //节损奖
                $guige = \db('物料_存货编码')
                    ->where('物料代码',$data['成品代号'])
                    ->value('rtrim(规格)');
                //工序超节损金额
                if ($guige === '小盒'){
                    $moneyRate = 0.02;
                }else{
                    $moneyRate = 0.09;
                }
                if ($this->isSuperLossRewardExcluded((string)$item['sczl_gxmc'])) {
                    $gy_data[$i]['节损奖'] = 0;
                } else {
                    $gy_data[$i]['节损奖'] = number_format($gy_data[$i]['节损数量'] * $item['超节损承担比例'] * $moneyRate, 4);
                }
                $gy_data[$i]['超节损承担比例'] = number_format($item['超节损承担比例'],4) * 100 .'%';

                $total['plan_loss'] += $item['计划损耗'];
                $total['total_fp'] += $item['sczl_zcfp'];
                $total['waste_quality'] += $item['质检废'];
                $total['waste_intangible'] += $item['无形损分摊'];
                $total['reward'] += floatval(str_replace(',', '', $gy_data[$i]['节损奖']));
                $i++;
            }
            $feedQty = floatval($data['实际投料']) * 10000;
            $realRateVal = $feedQty > 0 ? (floatval($cp_data[0]['cp_sl']) / $feedQty * 100) : 0;
            $rewardMultiplier = $this->resolveSuperLossRewardMultiplier(
                floatval($target_rate),
                $realRateVal,
                floatval($data['材料废'] ?? 0),
                $feedQty
            );
            $data['reward_rate'] = (string)$rewardMultiplier;
            if ($rewardMultiplier > 1) {
                $total['reward'] = 0;
                foreach ($gy_data as $idx => $item) {
                    $baseReward = floatval(str_replace(',', '', (string)$gy_data[$idx]['节损奖']));
                    if ($baseReward != 0.0) {
                        $gy_data[$idx]['节损奖'] = number_format($baseReward * $rewardMultiplier, 4);
                    }
                    $total['reward'] += floatval(str_replace(',', '', $gy_data[$idx]['节损奖']));
                }
            }
            $total['reward'] = number_format($total['reward'],2);
            $data['gy_data'] = $gy_data;
            $data['total'] = $total;
            $this->success('请求成功',$data);
        }
    }
    /**
     * 获取工单工艺
     * @ApiMethod GET
     * @params string order
     */
    public function getOrderGy(){
        if (Request::instance()->isGet() == false) {
            $this->error('非法请求');
        }
        $params = Request::instance()->param();
        if (!isset($params['order']) || empty($params['order'])) {
            $this->error('参数错误');
        }
        $order = $params['order'];
        $field = 'Gy0_yjno,Gy0_gxh,rtrim(Gy0_gxmc) as Gy0_gxmc,rtrim(Add_gxmc) as Add_gxmc,Gy0_rate0,Gy0_rate1,损耗系数,无形损承担比例 as loss_one,超节损承担比例 as loss_two,超节损核算单价 as loss_thr,UniqId';
        $data =db('工单_工艺资料')->where('Gy0_gdbh',$order)->where('Gy0_yjno',$params['yjno'])->field($field)->select();
        $this->success('请求成功',$data);
    }
    /**
     * 更新工单工艺
     * @ApiMethod POST
     * @params array data
     */
    public function updateOrderGy(){
        if (Request::instance()->isPost() == false) {
            $this->error('非法请求');
        }
        $params = Request::instance()->post();
        if (!isset($params) || !isset($params[0]['UniqId'])){
            $this->error('参数不能为空');
        }
        $i = 0;
        foreach ($params as $key=>$value){
            $data = [];
            $data['无形损承担比例'] = $value['loss_one'];
            $data['超节损承担比例'] = $value['loss_two'];
            $data['超节损核算单价'] = $value['loss_thr'];
            $sql =db('工单_工艺资料')->where('UniqId',$value['UniqId'])->fetchSql(true)->update($data);
            $res = Db::query($sql);
            if ($res !== false){
                $i++;
            }
        }
        if ($i !== 0){
            $this->success('更新成功');
        }else{
            $this->error('更新失败');
        }
    }
    /**
     * 获取工单印件考核资料
     * @ApiMethod GET
     * @params string order
     */
    public function getOrderYj(){
        if (Request::instance()->isGet() == false) {
            $this->error('非法请求');
        }
        $params = Request::instance()->request();
        if (!isset($params['order']) || empty($params['order'])) {
            $this->error('参数错误');
        }
        if (!isset($params['yjno']) || empty($params['yjno'])) {
            $this->error('参数错误');
        }
        $data =db('工单_印件资料')
            ->where('Yj_gdbh',$params['order'])
            ->where('Yj_Yjno', $params['yjno'])
            ->field('Yj_gdbh,rtrim(yj_Yjdh) as yj_Yjdh,yj_Yjno,rtrim(yj_yjmc) as yj_yjmc,质量考核')->find();
        $this->success('请求成功',$data);
    }
    /**
     * 更新工单印件考核资料
     * @ApiMethod POST
     * @params array data
     */
    public function updateOrderYj(){
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $params = $this->request->get();
        if (!isset($params['order'])){
            $this->error('参数不能为空');
        }
        if (!isset($params['yj_yjno'])){
            $this->error('参数不能为空');
        }
        if (!isset($params['examine'])){
            $this->error('参数不能为空');
        }
        if ($params['examine'] === '参与'){
            $examine = 0;
        }else{
            $examine = 1;
        }
        $where['Yj_Gdbh'] = $params['order'];
        $where['yj_Yjno'] = $params['yj_yjno'];
        $sql =db('工单_印件资料')->where($where)->fetchSql(true)->update(['质量考核'=>$examine]);
        $res = \db()->query($sql);
        $returnData = $this->OneOrderSuperLoss($where['Yj_Gdbh'],$where['yj_Yjno']);
        db('工单_质量考核汇总')
            ->where('Gy0_gdbh',$where['Yj_Gdbh'])
            ->where('印件及工序',$where['yj_Yjno'])
            ->delete();
        $sql = db('工单_质量考核汇总')->fetchSql(true)->insertAll($returnData);
        $result = db()->query($sql);
        if($result===false) $this->error('失败');
        if ($res !== false){
            $this->success('更新成功');
        }else{
            $this->error('更新失败');
        }
    }
    /**
     * 获取修正工单实际投料列表
     * @ApiMethod GET
     * @params string year
     * @params string month
     */
    public function getOrderFeedList(){
        if (Request::instance()->isGet() == false) {
            $this->error('非法请求');
        }
        $params = Request::instance()->request();
        if (empty($params['workorder']) || empty($params['yjno'])) {
            $this->error('参数错误');
        }
        $field = "a.Gd_gdbh,rtrim(c.yj_Yjdh) as yj_yjdh,c.yj_Yjno, c.yj_ks,c.yj_ls,rtrim(c.yj_zzdh) as yj_zzdh,
                  rtrim(b.BOM_物料名称) as BOM_物料名称,rtrim(c.yj_tlgg) as yj_tlgg,rtrim(d.st_dw) as BOM_投料单位,
                  a.订单数量,c.yj_平张投料, b.BOM_实际用量,d.st_sl as 实际投料,d.st_oldSl as 原投料,a.投料确认,
                  d.Uniqid as UniqId,d.mod_number";
        $data =db('工单_基本资料')->alias('a')
            ->join('工单_印件资料 c','a.Gd_gdbh = c.Yj_Gdbh ','left')
            ->join('工单_bom资料 b','c.Yj_Gdbh = b.BOM_工单编号 AND c.yj_zzdh = b.BOM_物料编码','left')
            ->join('物料_收发记录 d','a.Gd_gdbh = d.st_gdbh AND d.cpdh = c.yj_Yjdh')
            ->where('a.Gd_gdbh',$params['workorder'])
            ->where('c.yj_Yjno',$params['yjno'])
            ->where(function($query) {
                $query->where('d.仓库编号', '101')
                    ->whereOr('d.仓库编号', 'Y101');})
            ->field($field)
            ->group('a.Gd_gdbh,d.Uniqid')
            ->order('b.BOM_投料单位,a.UniqId asc')
            ->select();
        if (empty($data)){
            $this->success('请求成功');
        }
        foreach ($data as $key=>$value){
            $len = stripos($value['yj_tlgg'],'/');
            if ($len){
                $name = substr($value['yj_tlgg'],0,$len);
                $len_two = stripos($value['yj_tlgg'],'（');
                if ($len_two){
                    $name = substr($name,0,$len_two);
                }
                $data[$key]['yj_tlgg'] = $name;
            }
            $data[$key]['rate'] = '';
            if (empty($value['原投料'])){
                $data[$key]['原投料'] = $value['实际投料'];
            }
            if ($value['mod_number'] === 0){
                $data[$key]['实际投料'] = '';
            }
        }
        $this->success('请求成功',$data);
    }
    /**
     * 更新工单实际投料
     * @ApiMethod POST
     * @params int UniqId
     * @params string number
     */
    public function updateOrderFeed(){
        if (Request::instance()->isPost() == false) {
            $this->error('非法请求');
        }
        $params = Request::instance()->post();
        if (!isset($params[0]['UniqId']) || empty($params[0]['UniqId'])){
            $this->error('参数错误');
        }
        $i = 0;
        $list = \db('物料_收发记录')->where('Uniqid',$params['0']['UniqId'])->find();
        foreach ($params as $key=>$value){
            $mod_num = \db('物料_收发记录')
                ->where('Uniqid',$value['UniqId'])
                ->value('mod_number');
            $tl_sql = \db('物料_收发记录')
                ->where('Uniqid',$value['UniqId'])
                ->fetchSql(true)
                ->update(['st_sl'=>$value['number'],'st_oldSl'=>$value['old_number'],'mod_number'=>$mod_num+1,'st_dw' => $value['dw']]);
            $tlRes = Db::query($tl_sql);
            if (!$tlRes){
                $i++;
            }

        }
        $total_num = \db('物料_收发记录')
            ->alias('a')
            ->field('SUM(a.st_sl) as 投料数量,b.yj_ls,b.yj_ks')
            ->join('工单_印件资料 b','a.st_gdbh = b.Yj_Gdbh AND a.cpdh = b.yj_yjdh')
            ->where('a.st_gdbh',$list['st_gdbh'])
            ->where('a.cpdh',$list['cpdh'])
            ->where(function($query) {
                $query->where('a.仓库编号', '101')
                    ->whereOr('a.仓库编号', 'Y101');})
            ->find();
        $number = $total_num['投料数量']/10000*$total_num['yj_ls']*$total_num['yj_ks'];
        $res_sql = db('工单_基本资料')->where('Gd_gdbh',$list['st_gdbh'])->where('Gd_cpdh',$list['cpdh'])->fetchSql(true)->setField('实际投料',$number);
        $res = Db::query($res_sql);
        $data['yj_实际投料'] = $number;
        $yj_sql =db('工单_印件资料')->where('Yj_Gdbh',$list['st_gdbh'])->where('yj_Yjdh',$list['cpdh'])->fetchSql(true)->update($data);
        $yjRes = Db::query($yj_sql);
        $yjno = db('工单_印件资料')->where('Yj_Gdbh',$list['st_gdbh'])->where('yj_Yjdh',$list['cpdh'])->column('yj_Yjno')[0];

        /**
         * 重新计算工单超节损数据
         **/

        $result = $this->OneOrderSuperLoss($list['st_gdbh'],$yjno);

        //先删除数据
        \db('工单_质量考核汇总')
            ->where('Gy0_gdbh',$list['st_gdbh'])
            ->where('印件及工序',$yjno)
            ->delete();
        //插入新数据
        $lossSql = \db('工单_质量考核汇总')->fetchSql(true)->insertAll($result);
        $lossRes = \db()->query($lossSql);
        if ($i != 0 && $lossRes !== false){
            $this->success('更新成功');
        }else{
            $this->error('更新失败');
        }
    }
    /**
     * 工单工序产量统计
     * @ApiMethod GET
     * @params string order
     */
    public function getOrderProcessCount(){
        if (Request::instance()->isGet() == false) {
            $this->error('非法请求');
        }
        $params = Request::instance()->request();
        if (empty($params['order']) || empty($params['order'])) {
            $this->error('参数错误');
        }
        if (empty($params['yjno']) || empty($params['yjno'])) {
            $this->error('参数错误');
        }
        $order = $params['order'];
        $yjno = $params['yjno'];
        $sql = "SELECT a.Gy0_yjno,a.Gy0_gxh,rtrim(a.Gy0_gxmc) as Gy0_gxmc,rtrim(a.Add_gxmc) as Add_gxmc,a.Gy0_计划接货数,
                a.Gy0_ls,a.Gy0_sbbh,a.PD_WG,SUM(b.sczl_cl) as sczl_cl,SUM(b.sczl_zcfp) as sczl_zcfp,
                SUM(b.sczl_来料少数) as 来料异常,COUNT(DISTINCT b.sczl_num) as process_num,b.sczl_Pgcl,
                SUM(c.sczl_cl) as cl,b.sczl_rq,rtrim(a.印刷方式) as 印刷方式,rtrim(a.版距) as 版距
                FROM `工单_工艺资料` a
                LEFT JOIN `设备_产量计酬` b ON a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh
                LEFT JOIN db_sczl c ON a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_yjno = c.sczl_yjno AND a.Gy0_gxh = c.sczl_gxh
                WHERE a.Gy0_gdbh = '{$order}' and a.GY0_Yjno = '{$yjno}' GROUP BY a.Gy0_yjno, a.Gy0_gxh ORDER BY a.Gy0_yjno, a.Gy0_gxh";
        $data = Db::query($sql);
        //手检数据
        $handData =db('db_手工检验')->where('sczl_gdbh',$order)->field('sum(sczl_cl) as cl,rtrim(sczl_yjgx) as sczl_gxh')->select();
        //包装及成品防护数据
        $sql = "SELECT sczl_gdbh1,sczl_gdbh2,sczl_gdbh3,sczl_gdbh4,sczl_gdbh5,sczl_gdbh6,rtrim(sczl_gxmc1) as sczl_gxmc1,rtrim(sczl_gxmc2) as sczl_gxmc2,
                rtrim(sczl_gxmc3) as sczl_gxmc3,rtrim(sczl_gxmc4) as sczl_gxmc4,rtrim(sczl_gxmc5) as sczl_gxmc5,rtrim(sczl_gxmc6) as sczl_gxmc6,
                sczl_cl1,sczl_cl2,sczl_cl3,sczl_cl4,sczl_cl5,sczl_cl6,sczl_PgCl1,sczl_PgCl2,sczl_PgCl3,sczl_PgCl4,sczl_PgCl5,sczl_PgCl6
                FROM `db_包装计件` WHERE `sczl_gdbh1` LIKE '%{$order}%' OR `sczl_gdbh2` LIKE '%{$order}%' 
                OR `sczl_gdbh3` LIKE '%{$order}%' OR `sczl_gdbh4` LIKE '%{$order}%' OR `sczl_gdbh5` LIKE '%{$order}%' OR `sczl_gdbh6` LIKE '%{$order}%'";
        $package = Db::query($sql);
        $list = [];
        $j = 0;
        foreach ($package as $value){
            for ($i = 1; $i <= 6; $i++) {
                $gdbhlKey = "sczl_gdbh" . $i;
                $gxmcKey = "sczl_gxmc" . $i;
                $clKey = "sczl_cl" . $i;
                $pgclKey = "sczl_PgCl" . $i;
                if ($value[$gdbhlKey] == '2311743' && $value[$clKey] > 0) {
                    $list[$j]['sczl_gdbh'] = $value[$gdbhlKey];
                    $list[$j]['sczl_gxmc'] =  $value[$gxmcKey];
                    $list[$j]['sczl_cl'] =  $value[$clKey];
                    $list[$j]['sczl_PgCl'] =  $value[$pgclKey];
                    $j++;
                }
            }
        }
        // 创建一个关联数组，用于存储相同 sczl_gxmc 的值和对应的乘积之和
        $sumArray = [];
        foreach ($list as $item) {
            $key = $item['sczl_gxmc'];
            $cl = floatval($item['sczl_cl']);
            $pgCl = intval($item['sczl_PgCl']);
            $product = $cl * $pgCl;
            if (!isset($sumArray[$key])) {
                $sumArray[$key] = 0;
            }
            $sumArray[$key] += $product;
        }
        $handGxh = substr($handData[0]['sczl_gxh'],-2);
        foreach ($data as $key=>$item){
            $data[$key]['折算车头产量'] = $item['Gy0_计划接货数'];
            $data[$key]['Gy0_计划接货数'] = $item['Gy0_计划接货数']*$item['Gy0_ls'];
            $data[$key]['制程废品率'] = '';
            if ($item['sczl_zcfp'] > 0 && $item['sczl_cl']){
                $data[$key]['制程废品率'] = number_format($item['sczl_zcfp']/$item['sczl_cl']*100,4).'%';
            }
            if ($item['cl'] > 0){
                $data[$key]['sczl_cl'] = $item['cl'];
            }
            if ($item['sczl_Pgcl'] > 0){
                $data[$key]['sczl_cl'] = $item['sczl_cl'] * $item['sczl_Pgcl'];
            }
            if ($item['Gy0_gxh'] == (int)$handGxh){
                $data[$key]['sczl_cl'] = $handData[0]['cl'];
            }
            foreach ($sumArray as $k=>$v){
                if ($item['Gy0_gxmc'] == $k){
                    $data[$key]['sczl_cl'] = $v;
                }
            }
            if (substr($item['PD_WG'],0,4) == '1900'){
                $data[$key]['PD_WG'] = '计划';
            }else{
                $data[$key]['PD_WG'] = '完工';
            }
            //印刷方式为卷对卷时候：上报产量/版距*1000
            if ($item['印刷方式'] === '卷对卷'){
                $data[$key]['sczl_cl'] = ceil($data[$key]['sczl_cl']/$item['版距']*1000);
                $data[$key]['sczl_zcfp'] = ceil($data[$key]['sczl_zcfp']/$item['版距']*1000);
                $data[$key]['来料异常'] = ceil($data[$key]['来料异常']/$item['版距']*1000);
            }
        }
        $this->success('请求成功',$data);
    }


    /**
     * 月份员工超节损数据汇总
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function EmployeeDataCollect()
    {
        if ($this->request->isPost() === false) {
            $this->error('请求错误');
        }
        $params = $this->request->post();
        if (empty($params)) {
            $this->error('参数错误');
        }
        $date = date('Ym', strtotime($params['date']));
        $list = \db('工单_质量考核汇总')
            ->alias('a')
            ->join('工单_印件资料 b', 'a.Gy0_gdbh = b.Yj_Gdbh AND a.印件及工序 = b.yj_Yjno')
            ->join('成品入仓 c', 'a.Gy0_gdbh = c.jjcp_gdbh AND a.印件及工序 = c.jjcp_yjno')
            ->where('a.sys_ny', $date)
            ->where(function ($query) {
                $query->where('b.质量考核', 0)
                    ->whereOr('b.质量考核', null);
            })
            ->where('c.jjcp_smb', 'like', '末%')
            ->select();
        $data = [];

        foreach ($list as $item) {
            $workshop = $item["车间名称"] ?? '';

            for ($i = 1; $i <= 8; $i++) {
                if (!empty($item["sczl_bh{$i}"]) && $item["sczl_bh{$i}"]!== ''){
                    $bh = $item["sczl_bh{$i}"] ?? '';
                    $xm = $item["Xm{$i}"] ?? '';
                    $rateValue = floatval($item["sczl_rate{$i}"]) ?? '';

                    // 关键优化：如果分配比例为 0 或空，默认为 1
                    $rate = (empty($rateValue) || (float)$rateValue == 0) ? 1 : (float)$rateValue;
                    if (!empty($bh) && $bh !== '') {
                        $je = round((float)$item["CjsJe"] * $rate, 4);
                        $data[] = [
                            "bh" => $bh,
                            "xm" => $xm,
                            "je" => (float)number_format($je, 4, '.', ''),
                            "cj" => $workshop
                        ];
                    }
                }

            }
        }
        $result = [];

        foreach ($data as $item) {
            $cj = $item['cj'];
            $bh = $item['bh'];
            $je = round($item['je'], 2); // 保留两位小数

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

            if (isset($result[$cj][$bh])) {
                $result[$cj][$bh]['je'] += (float)$je;
            } else {
                $result[$cj][$bh] = [
                    'bh' => $bh,
                    'xm' => $item['xm'],
                    'je' => (float)$je,
                    'cj' => $cj
                ];
            }
        }
        // 将每个车间的子数组转换为索引数组
        foreach ($result as $cjName => &$items) {
            $items = array_values($items);
        }

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


    /**
     * 单条工单超节损计算
     * @param $gdbh
     * @param $yjno
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function OneOrderSuperLoss($gdbh,$yjno)
    {
        $param = [
            'gdbh' => $gdbh,
            'yjno' => $yjno
        ];
        //查询工单入仓数据
        $workOrderData = \db('成品入仓')
            ->where('jjcp_gdbh', $param['gdbh'])
            ->where('jjcp_yjno', $param['yjno'])
            ->where('jjcp_smb', '末 板')
            ->find();
        if (empty($workOrderData)) {
            $this->error('工单' . $param['gdbh'] . '-' . $param['yjno'] . '未查询到末板入仓记录');
        }
        //入仓数量
        $total_number = \db('成品入仓')
            ->where('jjcp_gdbh', $param['gdbh'])
            ->where('jjcp_yjno', $param['yjno'])
            ->column('SUM(jjcp_sl)');
        //查询工单资料、投料数据
        $field = 'a.Gd_gdbh,rtrim(a.成品代号) as 成品代号,rtrim(a.成品名称) as 成品名称,rtrim(a.Gd_客户代号) as Gd_客户代号,
                  rtrim(a.Gd_客户名称) as Gd_客户名称,rtrim(a.Gd_cpdh) as Gd_cpdh,rtrim(a.Gd_cpmc) as Gd_cpmc,
                  rtrim(a.销售订单号) as 销售订单号,a.订单数量,a.投料大箱,rtrim(a.计量单位) as 计量单位,
                  c.yj_ls as ls,c.yj_ks as ks,SUM(b.st_sl) as 投料,
                  b.st_dw,c.yj_zzmc,c.yj_tlgg,SUM(b.mod_number) as mod_num';
        $data = db('工单_基本资料')
            ->alias('a')
            ->join('物料_收发记录 b', 'a.Gd_gdbh = b.st_gdbh AND a.Gd_cpdh = b.cpdh')
            ->join('工单_印件资料 c', 'c.Yj_Gdbh = a.Gd_gdbh AND c.yj_Yjdh = a.Gd_cpdh')
            ->where('a.Gd_Gdbh', $param['gdbh'])
            ->where('c.yj_Yjno', $param['yjno'])
            ->where(function ($query) {
                $query->where('b.仓库编号', '101')
                    ->whereOr('b.仓库编号', 'Y101');
            })
            ->field($field)
            ->find();

        if ($data['投料'] == null){
            return false;
        }
        if (!empty($data['yj_tlgg'])){
            $number1 = (int)substr($data['yj_tlgg'],0,3);
            $number2 = (int)substr($data['yj_tlgg'],4,3);
            if ($number1 !== 0 && $number2 !== 0) {
                preg_match('/(\d+)g/',$data['yj_zzmc'], $matches);
                if ($data['st_dw'] === '吨'){
                    $data['投料'] = round(($data['投料']*1000*1000)/$matches[1]/($number1*$number2)*1000000);
                    $data['st_dw'] = '张';
                }
            }

        }

        //将开数、联数为0重新赋值
        if ($data['ls'] == 0) {
            $data['ls'] = 1;
        }
        if ($data['ks'] == 0) {
            $data['ks'] = 1;
        }

        //计算工单实际投料
        $data['实际投料'] = str_replace(',', '', number_format($data['投料'] * $data['ls'] * $data['ks'] / 10000, 4));
        new WorkOrder();
        (new WorkOrder)->PlannedProcessYield($param['gdbh'],$param['yjno'],0,$data['实际投料']*10000/$data['ls']);
        //工单入仓数量
        $data['warehousing_num'] = $total_number[0];
        //截取工单末版的入仓时间
        $data['warehousing_date'] = substr($workOrderData['jjcp_sj'], 0, 10);
        $gxh_values = $this->getSuperLossProcessGxhList($workOrderData['jjcp_gdbh'], $workOrderData['jjcp_yjno']);
        if (empty($gxh_values)) {
            $this->error("工单".$workOrderData['jjcp_gdbh']."-".$workOrderData['jjcp_yjno']."未查询到报工信息,请核查该工单是否已进入超节损");
        }
        $feedQty = floatval($data['实际投料']) * 10000;
        $realRateVal = $feedQty > 0 ? (floatval($total_number[0]) / $feedQty * 100) : 0;
        $data['real_rate'] = number_format($realRateVal, 2) . '%';
        $targetRateVal = 100.0;
        //制程废品
        $zzfp_data = db('设备_产量计酬')
            ->where('sczl_gdbh', $workOrderData['jjcp_gdbh'])
            ->where('sczl_yjno', $workOrderData['jjcp_yjno'])
            ->field('SUM(sczl_zcfp) as sczl_zcfp')
            ->select();
        //制程废品*ls*ks
        $data['zcfp'] = $zzfp_data[0]['sczl_zcfp'] * $data['ls'] * $data['ks'];
        //废品数量
        $wasteTotal = db('db_qczl')
            ->where('qczl_gdbh', $workOrderData['jjcp_gdbh'])
            ->where('qczl_yjno', $workOrderData['jjcp_yjno'])
            ->sum('qczl_fp');
        if (empty($wasteTotal)) {
            $wasteTotal = 0;
        }
        //废品合计=制程废品+核检废品
        $waste_total = $data['zcfp'] + $wasteTotal;
        //工单无形损 = 实际投料-入仓数量-废品合计
        $data['intangible_loss'] = (int)($data['实际投料'] * 10000 - $total_number[0] - $waste_total);
     
        //查询核检单废品上报数据
        $out_sql = "SELECT qczl_num,fp_sl1,fp_sl2,fp_sl3,fp_sl4,fp_sl5,fp_sl6,fp_sl7,fp_sl8,fp_sl9,fp_sl10,fp_sl11,fp_sl12,fp_sl13,
                        fp_lb1,fp_lb2,fp_lb3,fp_lb4,fp_lb5,fp_lb6,fp_lb7,fp_lb8,fp_lb9,fp_lb10,fp_lb11,fp_lb12,fp_lb13,
                        fp_bh1,fp_bh2,fp_bh3,fp_bh4,fp_bh5,fp_bh6,fp_bh7,fp_bh8,fp_bh9,fp_bh10,fp_bh11,fp_bh12,fp_bh13,
                        fp_bz1,fp_bz2,fp_bz3,fp_bz4,fp_bz5,fp_bz6,fp_bz7,fp_bz8,fp_bz9,fp_bz10,fp_bz11,fp_bz12,fp_bz13,
                        fp_gxmc1,fp_gxmc2,fp_gxmc3,fp_gxmc4,fp_gxmc5,fp_gxmc6,fp_gxmc7,fp_gxmc8,fp_gxmc9,fp_gxmc10,fp_gxmc11,fp_gxmc12,fp_gxmc13,UniqId
                        FROM db_qczl WHERE qczl_gdbh = '{$workOrderData['jjcp_gdbh']}' AND qczl_yjno = '{$workOrderData['jjcp_yjno']}'";
        $waste_out = Db::query($out_sql);
        $list = []; //外发废数组
        $quality = [];//质检废数组
        $material = [];//材料废数组
        $change = [];//零头处理数组
        $machine = [];//机检废品数组
        $j = 0;
        $m = 0;
        $n = 0;
        $l = 0;
        $o = 0;
        foreach ($waste_out as $entry) {
            for ($i = 1; $i <= 13; $i++) {
                $labelKey = "fp_lb" . $i;
                $bhKey = "fp_bh" . $i;
                $gxmcKey = "fp_gxmc" . $i;
                $slKey = "fp_sl" . $i;
                if (!empty($entry[$labelKey])) {
                    //外发加工废
                    if (substr($entry[$labelKey],0,3) == 'M04'){
                        $list[$j]= $entry[$slKey];
                        $j++;
                    }
                    //材料废
                    if (substr($entry[$labelKey],0,1) == 'L' ){
                        $material[$n]= $entry[$slKey];
                        $n++;
                    }
                    //零头处理
                    if (substr($entry[$labelKey],0,3) == 'M01' ){
                        $change[$l]= $entry[$slKey];
                        $l++;
                    }

                    //机检废品
                    if (substr($entry[$gxmcKey],0,2) == '01' ){
                        $machine[$o]= $entry[$slKey];
                        $o++;
                    }
                }
                $quality[$m]= $entry[$slKey];
                $m++;
            }
        }
        $data['材料废'] = array_sum($material); //材料废
        $data['零头处理'] = array_sum($change); //零头处理
        $data['外发废'] = array_sum($list);//外发废
        $data['工单质检废'] = array_sum($quality);//质检废
        $data['机检废'] = array_sum($machine);//机检废
        $plan_total = $this->getIntangibleAllocationPlanLossTotal(
            $workOrderData['jjcp_gdbh'],
            $workOrderData['jjcp_yjno'],
            $gxh_values
        );
        $targetRateVal = $this->calcSuperLossTargetQualificationRate(
            $workOrderData['jjcp_gdbh'],
            $workOrderData['jjcp_yjno'],
            $gxh_values
        );
        $data['target_rate'] = number_format($targetRateVal, 2) . '%';
        //单据列表最后统计/数据汇总
        $total = [];
        $total['plan_loss'] = 0;
        $total['total_fp'] = 0;
        $total['waste_quality'] = 0;
        $total['waste_intangible'] = 0;
        $total['reward'] = 0; //超节损奖励数组
        $sczlProcessSubForCl = $this->buildSczlProcessAggSubSql();
        //工单产量数据详情查询
        $total_cl_data = \db('工单_工艺资料')->alias('a')
            ->field(['a.Gy0_yjno', 'a.Gy0_gxh', 'rtrim(a.Gy0_gxmc) as gxmc', 'a.Gy0_ls', 'SUM(b.sczl_cl) as total_cl', 'MAX(c.cl) as cl','rtrim(a.印刷方式) as 印刷方式','rtrim(a.版距) as 版距'])
            ->join('设备_产量计酬 b', 'a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh', 'left')
            ->join([$sczlProcessSubForCl => 'c'], 'a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_yjno = c.sczl_yjno AND a.Gy0_gxh = c.sczl_gxh', 'left')
            ->where([
                'a.Gy0_gdbh' => $workOrderData['jjcp_gdbh'],
                'a.Gy0_yjno' => $workOrderData['jjcp_yjno'],
                'a.Gy0_gxh' => ['IN', $gxh_values],
            ])
            ->group('a.Gy0_gxh')
            ->order('a.Gy0_gxh')
            ->select();
        $payrollTeamSub = $this->buildPayrollTeamAggSubSql();
        $sczlTeamSub = $this->buildSczlTeamAggSubSql();
        $gxmcExpr = $this->processGxmcSqlExpr();
        //按班组分的产量数据
        $gy_data = db('工单_工艺资料')
            ->alias('a')
            ->field([
                'a.Gy0_gdbh', 'a.Gy0_yjno', 'a.Gy0_gxh', 'a.Gy0_ls', 'a.Gy0_ks', 'a.Gy0_计划损耗', 'a.超节损承担比例',
                $gxmcExpr . ' AS sczl_gxmc', 'b.sczl_zcfp', 'b.total_cl',
                'b.sczl_bh1', 'b.sczl_bh2', 'b.sczl_bh3', 'b.sczl_bh4', 'b.sczl_bh5', 'b.sczl_bh6',
                'b.sczl_bh7', 'b.sczl_bh8', 'b.sczl_bh9', 'b.sczl_bh10', 'b.流程单',
                'b.sczl_bzdh', 'b.sczl_rate1', 'b.sczl_rate2', 'b.sczl_rate3', 'b.sczl_rate4', 'b.sczl_rate5',
                'b.sczl_rate6', 'b.sczl_rate7', 'b.sczl_rate8', 'b.sczl_rate9', 'b.sczl_rate10',
                'c.gxmc', 'c.cl', 'c.fp', 'c.sczl_bh1 as sczl_bh',
                'd.使用部门 as 使用部门', 'c.bzdh', 'b.sczl_jtbh', 'a.损耗系数', 'a.Gy0_ms', 'a.Gy0_Rate0',
                'a.Gy0_Rate1', 'a.无形损承担比例', 'a.Gy0_计划接货数*a.Gy0_ls*a.Gy0_ks as 计划产量',
                'rtrim(a.Gy0_SITE) as Gy0_SITE',
                'rtrim(a.印刷方式) as 印刷方式', 'rtrim(a.版距) as 版距',
            ])
            ->join([$payrollTeamSub => 'b'], 'a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh', 'left')
            ->join([$sczlTeamSub => 'c'], 'a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_yjno = c.sczl_yjno AND a.Gy0_gxh = c.sczl_gxh AND IFNULL(b.sczl_bh1,\'\') = IFNULL(c.sczl_bh1,\'\')', 'left')
            ->join('设备_基本资料 d', 'd.设备编号 = b.sczl_jtbh', 'left')
            ->where([
                'a.Gy0_gdbh' => $workOrderData['jjcp_gdbh'],
                'a.Gy0_yjno' => $workOrderData['jjcp_yjno'],
                'a.Gy0_gxh' => ['in', $gxh_values],
            ])
            ->order('a.Gy0_gxh asc, b.开工时间 asc')
            ->select();
        $gy_data = $this->appendMissingSuperLossProcessRows(
            $gy_data,
            $gxh_values,
            $workOrderData['jjcp_gdbh'],
            $workOrderData['jjcp_yjno']
        );
        $gy_data = $this->expandSczlMultiTeamRows(
            $gy_data,
            $workOrderData['jjcp_gdbh'],
            $workOrderData['jjcp_yjno']
        );
        $sumBz = [];
        foreach ($gy_data as $kk => $vv){
            //每道工序的产量（按班组分）
            $vv['total_cl'] = $vv['total_cl'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
            if (empty($vv['total_cl'])) {
                $vv['total_cl'] = $vv['cl'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
            }
            if (empty($vv['sczl_bh1'])) {
                $vv['sczl_bh1'] = $vv['sczl_bh'] ?? '';
            }
            if (isset($sumBz[$vv['sczl_bh1'].'-'.$vv['Gy0_gxh']])){
                $sumBz[$vv['sczl_bh1'].'-'.$vv['Gy0_gxh']] += $vv['total_cl'];
            }else{
                $sumBz[$vv['sczl_bh1'].'-'.$vv['Gy0_gxh']] = $vv['total_cl'];
            }
        }
   
        foreach ($gy_data as $kk => $vv) {
            $this->fillSczlTeamMemberFields(
                $gy_data[$kk],
                $workOrderData['jjcp_gdbh'],
                $workOrderData['jjcp_yjno']
            );
            $vv = $gy_data[$kk];
            $banju = $vv['版距']/1000;
            if ($vv['印刷方式'] === '卷对卷'){
                $vv['total_cl'] = $vv['total_cl']*$banju;
            }
            //每道工序的产量（按班组分）
            $gy_data[$kk]['total_cl'] = (int)$vv['total_cl'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
            if (empty($vv['total_cl'])) {
                $gy_data[$kk]['total_cl'] = (int)$vv['cl'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
            }
            $gy_data[$kk]['Gy0_计划损耗'] = $vv['Gy0_计划损耗'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
            $vv['Gy0_计划损耗'] = $vv['Gy0_计划损耗'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
            //计算每道工序的计划损耗
            foreach ($total_cl_data as $k => $v) {
                //每道工序的总产量
                $cl = $v['total_cl'] * $v['Gy0_ls'];
                if (empty($cl)) {
                    $cl = $v['cl'] * $v['Gy0_ls'];
                }
                if ($vv['Gy0_yjno'] == $v['Gy0_yjno'] && $vv['Gy0_gxh'] == $v['Gy0_gxh']) {
                    if ($cl > 0) {
                        $gy_data[$kk]['计划损耗'] = round($gy_data[$kk]['total_cl'] / $cl * $vv['Gy0_计划损耗']);
                    }
                }
            }
            if (empty($gy_data[$kk]['计划损耗'])) {
                $gy_data[$kk]['计划损耗'] = (int)$vv['Gy0_计划损耗'];
            }
            //每道工序的制程废品（按班组分）
            $gy_data[$kk]['sczl_zcfp'] = $vv['sczl_zcfp'] * $vv['Gy0_ls'];
            if (empty($vv['sczl_zcfp'])) {
                $gy_data[$kk]['sczl_zcfp'] = $vv['fp'] * $vv['Gy0_ls'];
            }
            //计算每道工序的质检废(按班组)
            $gy_data[$kk]['sczl_gxmc'] = $vv['sczl_gxmc'];
            if (empty($vv['sczl_gxmc'])) {
                $gy_data[$kk]['sczl_gxmc'] = $vv['gxmc'];
            }
            if (empty($vv['sczl_bh1']) || is_null($vv['sczl_bh1'])) {
                $vv['sczl_bh1'] = $vv['sczl_bh'] ?? '';
            }
            $gy_data[$kk]['sczl_bh1'] = $vv['sczl_bh1'];
            $gy_data[$kk]['质检废'] = 0;
            $gy_data[$kk]['zjfp'] = 0;
            foreach ($waste_out as $entry) {
                for ($i = 1; $i <= 13; $i++) {
                    $gxmcKey = "fp_gxmc" . $i;
                    $gxlbKey = "fp_lb" . $i;
                    $slKey = "fp_sl" . $i;
                    $bhKey = "fp_bh" . $i;
                    if ((int)substr($entry[$gxmcKey], 0, 2) == $vv['Gy0_gxh'] && $entry[$bhKey] == $vv['sczl_bh1']) {
                        $gy_data[$kk]['zjfp'] += $entry[$slKey];
                    }
                }
            }
            $teamKey = $vv['sczl_bh1'] . '-' . $vv['Gy0_gxh'];
            $teamTotal = $sumBz[$teamKey] ?? 0;
            if ($teamTotal > 0) {
                $gy_data[$kk]['质检废'] = round($gy_data[$kk]['zjfp'] * ($gy_data[$kk]['total_cl'] / $teamTotal));
            } else {
                $gy_data[$kk]['质检废'] = (int)$gy_data[$kk]['zjfp'];
            }
            if ($this->isMachineInspectionProcess((string)$gy_data[$kk]['sczl_gxmc'])) {
                $gy_data[$kk]['质检废'] = 0;
                $gy_data[$kk]['zjfp'] = 0;
                $gy_data[$kk]['sczl_zcfp'] = 0;
            }
            //班组成员
            for ($j = 1; $j <= 10; $j++) {
                $bhKey = "sczl_bh" . $j;
                if (!empty($vv[$bhKey])) {
                    $name = \db('人事_基本资料')->where('员工编号', $vv[$bhKey])->value('rtrim(员工姓名)');
                    $gy_data[$kk]['sczl_name' . $j] = $name;
                } else {
                    $gy_data[$kk]['sczl_name' . $j] = '';
                }
            }
            //工序产量
            foreach ($total_cl_data as $k => $v) {
                $banju1 = $v['版距']/1000;
                if ($v['印刷方式'] === '卷对卷'){
                    $v['total_cl'] = $v['total_cl']/$banju1;
                }
                if ($v['Gy0_yjno'] === $vv['Gy0_yjno'] && $v['Gy0_gxh'] === $vv['Gy0_gxh']) {
                    if (strpos($v['gxmc'], '拆片') !== false) {
                        $gy_data[$kk]['工序产量'] = $v['cl'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
                    } else {
                        $gy_data[$kk]['工序产量'] = $v['total_cl'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
                    }
                }
            }

            unset($gy_data[$kk]['gxmc']);
            unset($gy_data[$kk]['cl']);
            unset($gy_data[$kk]['fp']);
            unset($gy_data[$kk]['sczl_bh']);
            unset($gy_data[$kk]['bzdh']);
        }

        $this->assignIntangibleLossToGyDataRows(
            $gy_data,
            $workOrderData['jjcp_gdbh'],
            $workOrderData['jjcp_yjno'],
            $gxh_values,
            floatval($data['intangible_loss'])
        );

        $guige = \db('物料_存货编码')
            ->where('物料代码', $data['成品代号'])
            ->value('rtrim(规格)');
        $moneyRate = (strpos((string)$guige, '小盒') !== false) ? 0.02 : 0.09;

        //计算超节损金额（班组行先汇总废品，节损数/金额按工序级：工序计划损耗 - 报废合计）
        foreach ($gy_data as $n => $item) {
            $gy_data[$n]['sys_ny'] = date('Ym', strtotime($workOrderData['jjcp_sj']));
            $gy_data[$n]['超节损核算单价'] = $moneyRate;
            $total['plan_loss'] += $item['计划损耗'];
            $total['total_fp'] += $item['sczl_zcfp'];
            $total['waste_quality'] += $item['质检废'];
            $total['waste_intangible'] += $item['无形损分摊'];
        }

        $processGxSummary = [];
        foreach ($gy_data as $n => $item) {
            $gk = $this->normalizeGxhKey($item['Gy0_gxh']);
            if ($gk === '') {
                continue;
            }
            if (!isset($processGxSummary[$gk])) {
                $processGxSummary[$gk] = [
                    'plan_loss' => (int)$item['Gy0_计划损耗'],
                    'zcfp' => 0,
                    'zj' => 0,
                    'intangible' => 0,
                    'row_indexes' => [],
                    'gxmc' => $item['sczl_gxmc'],
                    'ratio' => $item['超节损承担比例'],
                ];
            }
            $processGxSummary[$gk]['zcfp'] += (int)$item['sczl_zcfp'];
            $processGxSummary[$gk]['zj'] += (int)$item['质检废'];
            $processGxSummary[$gk]['intangible'] += (int)$item['无形损分摊'];
            $processGxSummary[$gk]['row_indexes'][] = $n;
        }

        $rewardMultiplier = $this->resolveSuperLossRewardMultiplier(
            $targetRateVal,
            $realRateVal,
            floatval($data['材料废'] ?? 0),
            $feedQty
        );
        $data['reward_rate'] = (string)$rewardMultiplier;
        $total['reward'] = 0;
        foreach ($processGxSummary as $summary) {
            if ($this->isMachineInspectionProcess((string)$summary['gxmc'])) {
                $processCjsSl = $summary['plan_loss'] - $summary['intangible'];
            } else {
                $totalWaste = $summary['zcfp'] + $summary['zj'] + $summary['intangible'];
                $processCjsSl = $summary['plan_loss'] - $totalWaste;
            }
            if ($this->isSuperLossRewardExcluded((string)$summary['gxmc'])) {
                $processCjsJe = 0.0;
            } else {
                $processCjsJe = $processCjsSl * floatval($summary['ratio']) * $moneyRate;
            }
            if ($rewardMultiplier > 1 && $processCjsJe != 0.0) {
                $processCjsJe *= $rewardMultiplier;
            }
            foreach ($summary['row_indexes'] as $idx => $n) {
                if ($idx === 0) {
                    $gy_data[$n]['节损数量'] = $processCjsSl;
                    $gy_data[$n]['节损奖'] = number_format($processCjsJe, 4);
                } else {
                    $gy_data[$n]['节损数量'] = 0;
                    $gy_data[$n]['节损奖'] = '0.0000';
                }
                $total['reward'] += floatval(str_replace(',', '', (string)$gy_data[$n]['节损奖']));
            }
        }

        //整合数据
        $result = [];
        foreach ($gy_data as $key => $value) {
            $result[$key] = [
                'sys_ny' => $value['sys_ny'],
                'Gy0_gdbh' => $value['Gy0_gdbh'],
                '印件及工序' => $value['Gy0_yjno'],
                '工序' => $value['Gy0_gxh'],
                '工序名称' => $value['sczl_gxmc'],
                '联数' => $value['Gy0_ls'],
                '基础损耗' => $value['Gy0_Rate0'],
                '损耗率' => $value['Gy0_Rate1'],
                '损耗系数' => $value['损耗系数'],
                '计损色数' => $value['Gy0_ms'],
                '计划产量' => $value['计划产量'],
                '计划损耗' => $value['Gy0_计划损耗'],
                '班组分摊计划损耗' => $value['计划损耗'],
                '印件工序产量' => $value['工序产量'],
                '班组产量' => $value['total_cl'],
                '班组制程废品' => $value['sczl_zcfp'],
                '工单质检废' => $data['工单质检废'],
                '班组质检废品' => $value['zjfp'],
                '班组分摊质检废品' => $value['质检废'],
                '无班组废品' => 0,
                '外发废' => $data['外发废'],
                '材料废' => $data['材料废'],
                '零头处理' => $data['零头处理'],
                '分摊废' => 0,
                '分摊废明细' => 0,
                '印件无形损' => $data['intangible_loss'],
                '班组分摊无形损' => $value['无形损分摊'],
                'CjsSl' => $value['节损数量'],
                'CjsJe' => str_replace(",", "", $value['节损奖']),
                '无形损承担比例' => $value['无形损承担比例'],
                '超节损承担比例' => $value['超节损承担比例'],
                '超节损核算单价' => $value['超节损核算单价'],
                'sczl_jtbh' => $value['sczl_jtbh'],
                'sczl_bzdh' => $value['sczl_bzdh'],
                'sczl_bh1' => $value['sczl_bh1'],
                'sczl_bh2' => $value['sczl_bh2'],
                'sczl_bh3' => $value['sczl_bh3'],
                'sczl_bh4' => $value['sczl_bh4'],
                'sczl_bh5' => $value['sczl_bh5'],
                'sczl_bh6' => $value['sczl_bh6'],
                'sczl_bh7' => $value['sczl_bh7'],
                'sczl_bh8' => $value['sczl_bh8'],
                'Xm1' => $value['sczl_name1'],
                'Xm2' => $value['sczl_name2'],
                'Xm3' => $value['sczl_name3'],
                'Xm4' => $value['sczl_name4'],
                'Xm5' => $value['sczl_name5'],
                'Xm6' => $value['sczl_name6'],
                'Xm7' => $value['sczl_name7'],
                'Xm8' => $value['sczl_name8'],
                'sczl_rate1' => $value['sczl_rate1'],
                'sczl_rate2' => $value['sczl_rate2'],
                'sczl_rate3' => $value['sczl_rate3'],
                'sczl_rate4' => $value['sczl_rate4'],
                'sczl_rate5' => $value['sczl_rate5'],
                'sczl_rate6' => $value['sczl_rate6'],
                'sczl_rate7' => $value['sczl_rate7'],
                'sczl_rate8' => $value['sczl_rate8'],
                '类型' => '',
                '客户代号' => $data['Gd_客户代号'] ?? '',
                '客户名称' => $data['Gd_客户名称'] ?? '',
                '产品代号' => $data['Gd_cpdh'] ?? $data['成品代号'],
                '产品名称' => $data['Gd_cpmc'] ?? $data['成品名称'],
                '销售订单号' => $data['销售订单号'],
                '订单数量' => $data['订单数量'],
                '计量单位' => $data['计量单位'] ?? '',
                '实际投料' => $data['实际投料'],
                '入仓数量' => $total_number[0],
                '入仓日期' => $workOrderData['jjcp_sj'],
                '大箱数' => $data['投料大箱'] ?? '',
                '废品合计' => $data['工单质检废'] + $data['zcfp'],
                'sys_id' => '',
                'sys_rq' => date('Y-m-d H:i:s', time()),
                '车间名称' => $value['Gy0_SITE']
            ];
        }

        return $result;

    }

    /**
     * 写入超节损核算结果（队列 OrderSuperLossJob / OrderLossQueueWorker 等调用）
     *
     * @param string $gdbh 工单编号
     * @param string $yjno 印件号
     * @param array $rows OneOrderSuperLoss 返回的行数据
     * @return bool
     */
    public function saveSuperLossResult($gdbh, $yjno, array $rows)
    {
        $gdbh = trim((string)$gdbh);
        $yjno = trim((string)$yjno);
        if ($gdbh === '' || $yjno === '' || empty($rows)) {
            return false;
        }

        db('工单_质量考核汇总')
            ->where('Gy0_gdbh', $gdbh)
            ->where('印件及工序', $yjno)
            ->delete();

        foreach ($rows as $idx => $row) {
            for ($r = 1; $r <= 8; $r++) {
                $key = 'sczl_rate' . $r;
                if (!isset($row[$key]) || $row[$key] === '' || $row[$key] === null) {
                    $rows[$idx][$key] = 0;
                }
            }
        }

        $sql = db('工单_质量考核汇总')->fetchSql(true)->insertAll($rows);
        $res = db()->query($sql);

        return $res !== false;
    }


    /**
     * 超节损列表
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getList()
    {
        if (!Request::instance()->isGet()) {
            $this->error('非法请求');
        }

        $params = Request::instance()->param();
        $where = [];

        // 设置默认分页和限制
        $limit = empty($params['limit']) ? 15 : intval($params['limit']);
        $pages = empty($params['page']) ? 1 : intval($params['page']);

        // 构建查询条件
        if (!empty($params['code'])) {
            // 根据产品代号是否含有字母确定匹配长度
            $prefixLength = preg_match('/[A-Za-z]/', $params['code']) ? 5 : 4;
            $where['a.jjcp_cpdh'] = ['LIKE', substr($params['code'], 0, $prefixLength) . '%'];
        }

        if (!empty($params['date'])) {
            $year = substr($params['date'], 0, 4); // 取前4位作为年份
            $month = substr($params['date'], 4, 2); // 取后2位作为月份

            // 格式化为需要的值
            $formattedDate = $year . '-' . $month;
            $where['a.jjcp_sj'] = ['like',$formattedDate.'%'];
        }

        if (!empty($params['search'])) {
            if (!empty($params['date']) || !empty($params['code'])) {
                $this->error('参数错误');
            }
            $where['a.jjcp_gdbh|a.jjcp_cpdh|a.jjcp_cpmc'] = ['like', '%' . $params['search'] . '%'];
        }

        // 定义字段
        $field = '  
        b.sys_ny,  
        a.jjcp_gdbh AS Gd_gdbh,  
        a.jjcp_yjno AS jjcp_yjno,  
        a.jjcp_yjno AS yj_Yjno, 
        c.yj_Yjdh as yjdh,
        c.yj_ls AS yj_ls,  
        c.yj_cpdh AS 成品编码,  
        c.yj_yjmc AS 成品名称,  
        b.`实际投料`,  
        b.`计量单位`,  
        DATE(a.jjcp_sj) AS warehousing_date,  
        total_sl.warehousing_num,
        SUM(DISTINCT b.`计划损耗`) AS `工单计划损耗`,  
        b.`废品合计`,  
        SUM(b.`CjsJe`) AS reward_money,  
        b.`印件无形损` AS 工单无形损,  
        b.`材料废`,  
        b.`零头处理`,  
        b.`外发废`,  
        SUM(b.`班组制程废品`) AS zcfp,  
        `工单质检废` AS 工单质检废,
        c.质量考核,
        c.工单类型
    ';

        // 子查询：计算所有记录的 jjcp_sl 总和（入仓数量）
        $subQuery = \db('成品入仓')
            ->alias('a_sub')
            ->field('
        a_sub.jjcp_gdbh AS Gd_gdbh_sub,
        a_sub.jjcp_yjno AS jjcp_yjno_sub,
        SUM(a_sub.jjcp_sl) AS warehousing_num
        ')
            ->group('a_sub.jjcp_gdbh, a_sub.jjcp_yjno')
            ->buildSql();

        $list = \db('成品入仓')
            ->alias('a')
            ->join('工单_质量考核汇总 b','a.jjcp_gdbh = b.Gy0_gdbh AND a.jjcp_yjno = b.印件及工序','left')
            ->join('工单_印件资料 c','a.jjcp_gdbh = c.Yj_Gdbh AND a.jjcp_yjno = c.yj_Yjno')
            ->join([$subQuery => 'total_sl'], 'a.jjcp_gdbh = total_sl.Gd_gdbh_sub AND a.jjcp_yjno = total_sl.jjcp_yjno_sub', 'left')
            ->field($field)
            ->where($where)
            ->where('a.jjcp_smb','like','末%')
            ->group('Gd_gdbh,jjcp_yjno')
            ->order('warehousing_date DESC')
            ->page($pages)
            ->limit($limit)
            ->select();
        // 处理查询结果
        foreach ($list as $key => $value) {
            $status = \db('工单_印件资料')
                ->where('Yj_Gdbh', $value['Gd_gdbh'])
                ->where('yj_Yjno', $value['jjcp_yjno'])
                ->value('质量考核');
            $processDetail = \db('工单_工艺资料')
                ->where('Gy0_gdbh', $value['Gd_gdbh'])
                ->where('Gy0_yjno', $value['jjcp_yjno'])
                ->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;
            }
            $list[$key]['工单质检废'] = $value['废品合计'] - $value['zcfp'];
            $list[$key]['质量考核'] = $status;
            $list[$key]['考核'] = ($status == 1) ? '否' : '是';
            if ($value['实际投料'] !== null){
                $actualMaterial = $value['实际投料'] * 10000;
                $list[$key]['target_rate'] = $this->calculateRate($actualMaterial, $value['工单计划损耗']);
                $list[$key]['real_rate'] = $value['warehousing_num']/($value['实际投料']*10000)*100;
                $list[$key]['real_rate'] = number_format($list[$key]['real_rate'], 2).'%';
            }else{
                $list[$key]['target_rate'] = null;
                $list[$key]['real_rate'] = null;
            }
            $list[$key]['reward_rate'] = '1'; // or some logic if needed
        }
        if (!empty($list)) {
            $this->success('成功', $list);
        } else {
            $this->error('未找到数据');
        }
    }

// 计算合格率
    private function calculateRate($actual, $loss)
    {
        if ($actual == 0) {
            return '0.00%'; // 防止除以零
        }
        $rate = ($actual - $loss) / $actual * 100;
        return number_format($rate, 2) . '%';
    }

    /**
     * 工序超节损
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function ProcessLoss()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param) || empty($param['order']) || empty($param['yjno'])){
            $this->error('参数错误');
        }
        $where = ['Gy0_gdbh'=>$param['order'],'印件及工序'=>$param['yjno']];
        //查询订单印件数据
        $field = '  
            Gy0_gdbh AS Gd_gdbh,   
            `印件及工序` AS yjno,   
            `联数` AS ls,  
            `产品代号` AS `成品代号`,  
            `产品名称` AS `成品名称`,  
            `实际投料`,  
            `计量单位`,  
            DATE(`入仓日期`) AS warehousing_date,  
            `入仓数量` AS warehousing_num,  
            SUM(DISTINCT `计划损耗`) AS `计划损耗`,  
            `废品合计`,  
            `印件无形损` as intangible_loss,  
            `材料废`,  
            `零头处理`,  
            `外发废`,  
            SUM(`班组制程废品`) AS `zcfp`,  
            `工单质检废` AS `班组分摊质检废品`,  
            `订单数量`,  
            `销售订单号`
            
        ';
        $list = \db('工单_质量考核汇总')
            ->field($field)
            ->where($where)
            ->group('Gy0_gdbh, `印件及工序`')
            ->order('sys_rq DESC')
            ->find();
        $processDetail = \db('工单_工艺资料')
            ->where('Gy0_gdbh', $param['order'])
            ->where('Gy0_yjno', $param['yjno'])
            ->field('CONCAT(rtrim(Gy0_gxmc),"[",rtrim(Add_gxmc),"]") as 工序名称,Gy0_ls as 联数')
            ->select();

            $status = \db('工单_印件资料')
    ->where('Yj_Gdbh', $param['order'])
    ->where('yj_Yjno', $param['yjno'])
    ->value('质量考核');

        // 添加到 $list 数组中
        $list['质量考核'] = $status;
        $list['考核'] = ($status == 1) ? '不参与考核' : '参与考核';

        $list['实际投料'] = $list['实际投料']*10000;
        //目标合格率
        $list['target_rate'] = ($list['实际投料']-$list['计划损耗'])/$list['实际投料']*100;
        $list['target_rate'] = number_format($list['target_rate'],2);
        $list['target_rate'] = $list['target_rate'].'%';
        //实际合格率
        $list['real_rate'] = $list['warehousing_num']/($list['实际投料'])*100;
        $list['real_rate'] = number_format($list['real_rate'],2);
        $list['real_rate'] = $list['real_rate'].'%';

        //查询工序数据（字段名与历史 ProcessLoss 一致）
        $gy_field = '  
            `工序` AS Gy0_gxh,  
            MAX(`工序名称`) AS Gy0_gxmc,  
            MAX(`印件及工序`) AS Gy0_yjno,  
            MAX(`联数`) AS Gy0_ls,  
            MAX(`计划损耗`) AS Gy0_计划损耗,  
            MAX(`计划产量`) AS Gy0_计划接货数,  
            SUM(`班组分摊无形损`) AS Gy0_无形损,  
            MAX(`印件工序产量`) AS total_cl,  
            SUM(`班组制程废品`) AS total_fp,  
            SUM(`班组分摊质检废品`) AS waste_quality,
            MAX(`超节损承担比例`) AS 超节损承担比例,
            MAX(`无形损承担比例`) AS 无形损承担比例
        ';
        $gy_data = \db('工单_质量考核汇总')
            ->field($gy_field)
            ->where($where)
            ->group('Gy0_gxh')
            ->select();
        $guige = \db('物料_存货编码')
            ->where('物料代码', $list['成品代号'] ?? $list['产品代号'] ?? '')
            ->value('rtrim(规格)');
        $moneyRate = (strpos((string)$guige, '小盒') !== false) ? 0.02 : 0.09;
        foreach ($gy_data as $key => $value) {
            //报废合计
            $gy_data[$key]['total_waste'] = $value['Gy0_无形损'] + $value['total_fp'] + $value['waste_quality'];
            //工序节损数 = 工序计划损耗 - 报废合计
            $gy_data[$key]['loss'] = (int)$value['Gy0_计划损耗'] - (int)$gy_data[$key]['total_waste'];
            $this->applyMachineInspectionProcessLossRules(
                (string)$value['Gy0_gxmc'],
                (int)$value['Gy0_计划损耗'],
                $gy_data[$key]
            );
            if ($this->isSuperLossRewardExcluded((string)$value['Gy0_gxmc'])) {
                $gy_data[$key]['工序超节损金额'] = 0;
            } else {
                $gy_data[$key]['工序超节损金额'] = round(
                    $gy_data[$key]['loss'] * floatval($value['超节损承担比例']) * $moneyRate,
                    4
                );
            }
            $denom = (float)$value['Gy0_计划接货数'];
            if ($denom <= 0) {
                $denom = 1;
            }
            //工序实际报废率
            $gy_data[$key]['actual_loss_rate'] = ((number_format($gy_data[$key]['total_waste'] / $denom, 4)) * 100) . '%';
            //工序目标报废率
            $gy_data[$key]['target_loss_rate'] = ((number_format($value['Gy0_计划损耗'] / $denom, 4)) * 100) . '%';
            //占投料报废率
            $gy_data[$key]['loss_rate'] = ((number_format(($value['Gy0_计划损耗'] - $gy_data[$key]['total_waste']) / $list['实际投料'], 4)) * 100) . '%';
        }
        $list['gy_data'] = $gy_data;
        $total = [
            'total_waste' => 0,
            'total_zjfp' => 0,
            'total_fp' => 0,
            'plan_loss' => 0,
            'waste_intangible' => 0,
            'loss' => 0,
            'reward' => 0,
        ];
        foreach ($gy_data as $item){
            $total['total_waste'] += $item['total_waste'];
            $total['total_zjfp'] += $item['waste_quality'];
            $total['total_fp'] += $item['total_fp'];
            $total['plan_loss'] += $item['Gy0_计划损耗'];
            $total['waste_intangible'] += $item['Gy0_无形损'];
            $total['loss'] += $item['loss'];
            $total['reward'] += $item['工序超节损金额'];
        }
        $total['reward'] = round($total['reward'],2);
        //查询废品数量
        $out_sql = "SELECT qczl_num,fp_sl1,fp_sl2,fp_sl3,fp_sl4,fp_sl5,fp_sl6,fp_sl7,fp_sl8,fp_sl9,fp_sl10,fp_sl11,fp_sl12,fp_sl13,
                        fp_lb1,fp_lb2,fp_lb3,fp_lb4,fp_lb5,fp_lb6,fp_lb7,fp_lb8,fp_lb9,fp_lb10,fp_lb11,fp_lb12,fp_lb13, 
                        fp_bh1,fp_bh2,fp_bh3,fp_bh4,fp_bh5,fp_bh6,fp_bh7,fp_bh8,fp_bh9,fp_bh10,fp_bh11,fp_bh12,fp_bh13,
                        fp_gxmc1,fp_gxmc2,fp_gxmc3,fp_gxmc4,fp_gxmc5,fp_gxmc6,fp_gxmc7,fp_gxmc8,fp_gxmc9,fp_gxmc10,fp_gxmc11,fp_gxmc12,fp_gxmc13,UniqId
                        FROM db_qczl WHERE qczl_gdbh = '{$param['order']}' AND qczl_yjno = '{$param['yjno']}'";
        $waste_out = Db::query($out_sql);
        $machine = [];//机检废品数组
        $o = 0;
        foreach ($waste_out as $entry) {
            for ($i = 1; $i <= 13; $i++) {
                $labelKey = "fp_lb" . $i;
                $slKey = "fp_sl" . $i;
                if (!empty($entry[$labelKey])) {
                    //机检废品
                    if (substr($entry[$labelKey],0,1) == 'K' ){
                        $machine[$o]= $entry[$slKey];
                        $o++;
                    }
                }
            }
        }
        $list['机检废'] = array_sum($machine);//机检废
        $list['total'] = $total;
        $list = $this->formatProcessLossResponse($list);
        $this->success('成功', $list);
    }


    //班组超节损数据
    public function ClassLossData()
    {
        if ($this->request->isGet() === false){
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param) || empty($param['order']) || empty($param['yjno'])){
            $this->error('参数错误');
        }
        $where = ['Gy0_gdbh'=>$param['order'],'印件及工序'=>$param['yjno']];
        //查询订单印件数据
        $field = '  
            Gy0_gdbh AS Gd_gdbh,   
            `印件及工序` AS yjno,   
            `联数` AS ls,  
            `产品代号` AS `成品代号`,  
            `产品名称` AS `成品名称`,  
            `实际投料`,  
            `计量单位`,  
            DATE(`入仓日期`) AS warehousing_date, 
            `入仓数量` AS warehousing_num,  
            SUM(DISTINCT `计划损耗`) AS `计划损耗`,  
            `废品合计`,  
            `印件无形损` as intangible_loss,  
            `材料废`,  
            `零头处理`,  
            `外发废`,  
            SUM(`班组制程废品`) AS `zcfp`,  
            `工单质检废` AS `班组分摊质检废品`,  
            `订单数量`,  
            `销售订单号`
            
        ';
        $list = \db('工单_质量考核汇总')
            ->field($field)
            ->where($where)
            ->group('Gy0_gdbh, `印件及工序`')
            ->order('sys_rq DESC')
            ->find();

        $processDetail = \db('工单_工艺资料')
            ->where('Gy0_gdbh', $param['order'])
            ->where('Gy0_yjno', $param['yjno'])
            ->field('CONCAT(rtrim(Gy0_gxmc),"[",rtrim(Add_gxmc),"]") as 工序名称,Gy0_ls as 联数')
            ->select();

            $status = \db('工单_印件资料')
    ->where('Yj_Gdbh', $param['order'])
    ->where('yj_Yjno', $param['yjno'])
    ->value('质量考核');

        // 添加到 $list 数组中
        $list['质量考核'] = $status;
        $list['考核'] = ($status == 1) ? '不参与考核' : '参与考核';

        $list['实际投料'] = $list['实际投料']*10000;
        //目标合格率
        $list['target_rate'] = ($list['实际投料']-$list['计划损耗'])/$list['实际投料']*100;
        $list['target_rate'] = number_format($list['target_rate'],2);
        $list['target_rate'] = $list['target_rate'].'%';
        //实际合格率

        $list['real_rate'] = $list['warehousing_num']/($list['实际投料'])*100;
        $list['real_rate'] = number_format($list['real_rate'],2);
        $list['real_rate'] = $list['real_rate'].'%';
        //班组数据
        $gy_data = \db('工单_质量考核汇总')
            ->where($where)
            ->select();
        $class_data = [];
        foreach ($gy_data as $item){
            $name = '';
            for ($i=1;$i<9;$i++){
                if ($item['Xm'.$i] !== ''){
                    $name = $name.' '.$item['Xm'.$i];
                }
            }
            $data = [
                'member' => $name,
                'sczl_gxmc' => $item['工序名称'],
                'total_cl' => $item['班组产量'],
                '计划损耗' => $item['班组分摊计划损耗'],
                '无形损分摊' => $item['班组分摊无形损'],
                '节损奖' => $item['CjsJe'],
                '节损数量' => $item['CjsSl'],
                'sczl_zcfp' => $item['班组制程废品'],
                '质检废' => $item['班组分摊质检废品'],
                '超节损承担比例' => ($item['超节损承担比例']*100).'%',
            ];
            array_push($class_data,$data);
        }
        $list['gy_data'] = $class_data;
        //工单节损数据
        $total_field = '
            SUM(`班组分摊质检废品`) as total_waste,
            SUM(`班组质检废品`) as total_zjfp,
            SUM(`班组制程废品`) as total_fp,
            SUM(DISTINCT `计划损耗`) AS plan_loss,
            `材料废`,
            `印件无形损` as waste_intangible,
            SUM(CjsSl) as loss,
            SUM(CjsJe) as reward
        ';
        $total = \db('工单_质量考核汇总')
            ->where($where)
            ->field($total_field)
            ->find();
        //查询废品数量
        $out_sql = "SELECT qczl_num,fp_sl1,fp_sl2,fp_sl3,fp_sl4,fp_sl5,fp_sl6,fp_sl7,fp_sl8,fp_sl9,fp_sl10,fp_sl11,fp_sl12,fp_sl13,
                        fp_lb1,fp_lb2,fp_lb3,fp_lb4,fp_lb5,fp_lb6,fp_lb7,fp_lb8,fp_lb9,fp_lb10,fp_lb11,fp_lb12,fp_lb13, 
                        fp_bh1,fp_bh2,fp_bh3,fp_bh4,fp_bh5,fp_bh6,fp_bh7,fp_bh8,fp_bh9,fp_bh10,fp_bh11,fp_bh12,fp_bh13,
                        fp_gxmc1,fp_gxmc2,fp_gxmc3,fp_gxmc4,fp_gxmc5,fp_gxmc6,fp_gxmc7,fp_gxmc8,fp_gxmc9,fp_gxmc10,fp_gxmc11,fp_gxmc12,fp_gxmc13,UniqId
                        FROM db_qczl WHERE qczl_gdbh = '{$param['order']}' AND qczl_yjno = '{$param['yjno']}'";
        $waste_out = Db::query($out_sql);
        $machine = [];//机检废品数组
        $o = 0;
        foreach ($waste_out as $entry) {
            for ($i = 1; $i <= 13; $i++) {
                $labelKey = "fp_lb" . $i;
                $slKey = "fp_sl" . $i;
                if (!empty($entry[$labelKey])) {
                    //机检废品
                    if (substr($entry[$labelKey],0,1) == 'K' ){
                        $machine[$o]= $entry[$slKey];
                        $o++;
                    }
                }
            }
        }
        $list['机检废'] = array_sum($machine);//机检废
        $list['total'] = $total;
        $this->success('成功',$list);

    }


    /**
     * 循环插入超节损数据
     * @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 orderLossData()
    {
        $param = $this->request->param();
        $where = [];
        if (isset($param['gdbh']) && isset($param['yjno']) && !empty($param['gdbh']) && !empty($param['yjno'])){
            $where['a.jjcp_gdbh'] = $param['gdbh'];
            $where['a.jjcp_yjno'] = $param['yjno'];
        }
        if (isset($param['mouth'])){
            $where['a.jjcp_sj'] = ['like',$param['mouth'].'%'];
        }
        $where['a.jjcp_smb'] = ['like','末%'];
        $list = \db('成品入仓')
            ->alias('a')
            ->join('设备_产量计酬 b','a.jjcp_gdbh = b.sczl_gdbh AND a.jjcp_yjno = b.sczl_yjno')
            ->join('物料_收发记录 c','a.jjcp_gdbh = c.st_gdbh AND a.jjcp_cpdh = c.cpdh')
            ->where($where)
            ->where(function ($query) {
                $query->where('c.仓库编号', '101')
                    ->whereOr('c.仓库编号', 'Y101');
            })
            ->field('a.jjcp_gdbh,a.jjcp_yjno')
            ->group('a.jjcp_gdbh,a.jjcp_yjno')
            ->select();

        $i = 0;
        if (empty($list)) {
            $this->error('未搜索到工单入仓数据');
        }
        foreach ($list as $item){
            $jobData = [
                'gdbh' => $item['jjcp_gdbh'],
                'yjno' => $item['jjcp_yjno'],
                'created_at' => date('Y-m-d H:i:s'),
            ];
            $res = Queue::push('app\\job\\OrderSuperLossJob', $jobData, 'order_loss_calculation');
            if (!$res) {
                $i++;
            }
        }
        if ($i === 0){
            $this->success('任务已提交，共' . count($list) . '条');
        }else{
            $this->error('提交完成，失败' . $i . '条');
        }
    }


    /**
     * 创建投料数
     * @return void
     */
    public function feedAdd()
    {
        // 1. 请求验证
        if (!$this->request->isPost()) {
            $this->error('请求错误');
        }

        $param = Request::instance()->post();
        if (empty($param)) {
            $this->error('参数错误');
        }

        // 2. 数据验证
        $requiredFields = ['st_gdbh', 'st_sl', 'st_dw', 'sys_id', 'cpdh'];
        foreach ($requiredFields as $field) {
            if (!isset($param[$field]) || $param[$field] === '') {
                $this->error("参数{$field}不能为空");
            }
        }

        try {
            // 3. 数据准备
            $currentTime = date('Y-m-d H:i:s');
            $currentDate = date('Y-m-d');

            // 仓库编号逻辑
            $cangku = preg_match('/[a-zA-Z]/', $param['st_gdbh']) ? 'Y101' : '101';

            // 4. 主数据
            $data = [
                'st_rq' => $currentDate,
                'st_jylb' => '生产领料',
                'st_gdbh' => $param['st_gdbh'],
                'st_wlbh' => $param['st_wlbh'],
                'st_sl' => $param['st_sl'],
                'st_dw' => $param['st_dw'],
                'sys_id' => $param['sys_id'],
                'sys_rq' => $currentTime,
                'cpdh' => $param['cpdh'],
            ];

            // 添加仓库编号（特殊处理）
            $data['`仓库编号`'] = $cangku;

            // 5. 日志数据
            $logData = [
                'Gd_gdbh' => $param['st_gdbh'],
                'ModifyUser' => $param['sys_id'],
                'ModifyTime' => $currentTime,
                'FieldName' => 'st_sl',
                'NewValue' => $param['st_sl'],
                'ModifySource' => '新增物料投料数'
            ];

            // 6. 开启事务
            Db::startTrans();

            // 7. 插入日志
            Db::name('系统操作日志表')->insert($logData);

            // 8. 插入主记录 - 手动构建安全的SQL语句
            $fields = array_keys($data);
            $values = array_values($data);

            // 构建字段名部分
            $fieldList = implode(', ', array_map(function($field) {
                return strpos($field, '`') === 0 ? $field : "`{$field}`";
            }, $fields));

            // 构建占位符
            $placeholders = implode(', ', array_fill(0, count($values), '?'));

            // 执行安全的参数化查询
            $sql = "INSERT INTO `物料_收发记录` ({$fieldList}) VALUES ({$placeholders})";
            $feedResult = Db::execute($sql, $values);

            if ($feedResult === false) {
                throw new Exception('新增物料记录失败');
            }

            // 9. 获取工单信息
            $totalNum = Db::name('工单_印件资料')
                ->field('yj_ls, yj_ks, yj_tlgg, yj_zzmc, yj_Yjno')
                ->where('Yj_Gdbh', $param['st_gdbh'])
                ->where('yj_Yjdh', $param['cpdh'])
                ->find();

            if (!$totalNum) {
                throw new Exception('未找到对应的工单印件资料');
            }

            // 10. 计算投料数量
            $num = $param['st_sl'];
            if (!empty($totalNum['yj_tlgg'])) {
                $dimensions = explode('*', $totalNum['yj_tlgg']);
                $number1 = (int)($dimensions[0] ?? 0);
                $number2 = (int)($dimensions[1] ?? 0);

                preg_match('/(\d+)g/', $totalNum['yj_zzmc'], $matches);
                $paperWeight = $matches[1] ?? 0;

                if ($param['st_dw'] === '吨' && $paperWeight > 0 && $number1 > 0 && $number2 > 0) {
                    $num = round(($param['st_sl'] * 1000000) / $paperWeight / ($number1 * $number2) * 1000000);
                }
            }

            // 11. 计算实际投料
            $actualFeed = $num / 10000 * $totalNum['yj_ls'] * $totalNum['yj_ks'];

            // 12. 更新工单基本资料 - 使用原生SQL处理中文字段
            $updateBasicSql = "UPDATE `工单_基本资料` SET `实际投料` = ? WHERE `Gd_gdbh` = ? AND `Gd_cpdh` = ?";
            $basicResult = Db::execute($updateBasicSql, [$actualFeed, $param['st_gdbh'], $param['cpdh']]);

            if ($basicResult === false) {
                throw new Exception('更新工单基本资料失败');
            }

            // 13. 更新工单印件资料 - 使用原生SQL
            $updateYjSql = "UPDATE `工单_印件资料` SET `yj_实际投料` = ? WHERE `Yj_Gdbh` = ? AND `yj_cpdh` = ?";
            $yjResult = Db::execute($updateYjSql, [$actualFeed, $param['st_gdbh'], $param['cpdh']]);

            if ($yjResult === false) {
                throw new Exception('更新工单印件资料失败');
            }

            $yjNo = $totalNum['yj_Yjno'];

            // 14. 重新计算工单超节损数据
            $resultAdd = $this->OneOrderSuperLoss($param['st_gdbh'], $yjNo);

            // 15. 更新质量考核汇总 - 先删除
            $deleteSql = "DELETE FROM `工单_质量考核汇总` WHERE `Gy0_gdbh` = ? AND `印件及工序` = ?";
            Db::execute($deleteSql, [$param['st_gdbh'], $yjNo]);

            // 16. 插入新的质量考核数据
            if (!empty($resultAdd)) {
                foreach ($resultAdd as $item) {
                    $fields = array_keys($item);
                    $values = array_values($item);

                    $fieldList = implode(', ', array_map(function($field) {
                        return strpos($field, '`') === 0 ? $field : "`{$field}`";
                    }, $fields));

                    $placeholders = implode(', ', array_fill(0, count($values), '?'));

                    $insertSql = "INSERT INTO `工单_质量考核汇总` ({$fieldList}) VALUES ({$placeholders})";
                    Db::execute($insertSql, $values);
                }
            }

            // 17. 提交事务
            Db::commit();

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

        } catch (Exception $e) {
            // 18. 回滚事务
            Db::rollback();
            $this->error('操作失败: ' . $e->getMessage());
        }
    }
    /**
     * 获取物料信息
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getFeedList()
    {
        if (Request::instance()->isGet() == false) {
            $this->error('非法请求');
        }
        $params = Request::instance()->request();
        if (empty($params['workorder']) || empty($params['yjno'])) {
            $this->error('参数错误');
        }
        $field = "a.Gd_gdbh,rtrim(c.yj_Yjdh) as yj_yjdh,c.yj_Yjno, c.yj_ks,c.yj_ls,rtrim(c.yj_zzdh) as yj_zzdh,
                  rtrim(b.BOM_物料名称) as BOM_物料名称,rtrim(c.yj_tlgg) as yj_tlgg,
                  a.订单数量,c.yj_平张投料, b.BOM_实际用量,a.投料确认";
        $data =db('工单_基本资料')->alias('a')
            ->join('工单_印件资料 c','a.Gd_gdbh = c.Yj_Gdbh ','left')
            ->join('工单_bom资料 b','c.Yj_Gdbh = b.BOM_工单编号 AND c.yj_zzdh = b.BOM_物料编码','left')
            ->where('a.Gd_gdbh',$params['workorder'])
            ->where('c.yj_Yjno',$params['yjno'])
            ->field($field)
            ->group('a.Gd_gdbh')
            ->order('b.BOM_投料单位,a.UniqId asc')
            ->select();
        if (empty($data)){
            $this->success('请求成功');
        }
        foreach ($data as $key=>$value){
            $len = stripos($value['yj_tlgg'],'/');
            if ($len){
                $name = substr($value['yj_tlgg'],0,$len);
                $len_two = stripos($value['yj_tlgg'],'（');
                if ($len_two){
                    $name = substr($name,0,$len_two);
                }
                $data[$key]['yj_tlgg'] = $name;
            }
            $data[$key]['rate'] = '';
        }
        $this->success('请求成功',$data);
    }


    /**
     * 获取工单类型
     * @return void
     */
    public function getWorkorderStatus()
    {
        if ($this->request->isGet() == false) {
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param['workorder']) || empty($param['yjno'])) {
            $this->error('参数错误');
        }
        $data = \db('工单_印件资料')
            ->where('Yj_Gdbh',$param['workorder'])
            ->where('yj_Yjno',$param['yjno'])
            ->field('Yj_gdbh,rtrim(yj_Yjdh) as yj_Yjdh,yj_Yjno,rtrim(yj_yjmc) as yj_yjmc,工单类型')
            ->find();
        $this->success('成功',$data);
    }

    /**
     * 工序号统一为与 getSuperLossProcessGxhList 一致的两位字符串，避免 9/09 重复补行
     */
    private function normalizeGxhKey($gxh): string
    {
        if ($gxh === null || $gxh === '') {
            return '';
        }
        $n = (int)$gxh;

        return $n < 10 ? sprintf('%02d', $n) : (string)$n;
    }

    /**
     * 工艺资料工序展示名（Add_gxmc 为空时不拼 null）
     */
    private function processGxmcSqlExpr(): string
    {
        return 'CONCAT(rtrim(a.Gy0_gxmc), IF(a.Add_gxmc IS NULL OR rtrim(a.Add_gxmc) = \'\', \'\', CONCAT(\'【\', rtrim(a.Add_gxmc), \'】\')))';
    }

    /** 外发：不参与无形损分摊 */
    private function isSuperLossIntangibleExcluded(string $gxName): bool
    {
        return strpos($gxName, '外发') !== false;
    }

    private function isMachineInspectionProcess(string $gxName): bool
    {
        return strpos($gxName, '机检') !== false;
    }

    /**
     * 机检：制程/质检不计入本行报废；无形损参与分摊并扣减节损数；超节损金额不计
     */
    private function applyMachineInspectionProcessLossRules(string $gxName, int $planLoss, array &$row): void
    {
        if (!$this->isMachineInspectionProcess($gxName)) {
            return;
        }
        if (array_key_exists('total_fp', $row)) {
            $row['total_fp'] = 0;
        }
        if (array_key_exists('waste_quality', $row)) {
            $row['waste_quality'] = 0;
        }
        $intangible = (int)($row['Gy0_无形损'] ?? $row['intangible_loss'] ?? 0);
        $row['total_waste'] = $intangible;
        $row['loss'] = $planLoss - $intangible;
    }

    /** 机检、外发：不计超节损金额 */
    private function isSuperLossRewardExcluded(string $gxName): bool
    {
        return $this->isMachineInspectionProcess($gxName) || $this->isSuperLossIntangibleExcluded($gxName);
    }

    /** 工序号查询兼容 9 / 09 / 9 */
    private function resolveGxhWhereValues($gxh): array
    {
        $values = [(string)$gxh, $this->normalizeGxhKey($gxh), (string)(int)$gxh];
        $n = (int)$gxh;
        if ($n < 10) {
            $values[] = sprintf('%02d', $n);
        }

        return array_values(array_unique(array_filter($values, static function ($v) {
            return $v !== '';
        })));
    }

    /**
     * 按 db_sczl 报工班组拆成多行（拆片等多员工，与历史入库一致）
     */
    private function buildGyRowsFromSczlTeams(string $gdbh, string $yjno, $gxh, array $templateRow): array
    {
        $gxValues = $this->resolveGxhWhereValues($gxh);
        $sczlRows = db('db_sczl')
            ->where('sczl_gdbh', $gdbh)
            ->where('sczl_yjno', $yjno)
            ->where('sczl_gxh', 'in', $gxValues)
            ->order('sczl_rq asc')
            ->select();
        if (count($sczlRows) <= 1) {
            return [];
        }

        $groups = [];
        foreach ($sczlRows as $sr) {
            $bh1 = trim((string)($sr['sczl_bh1'] ?? ''));
            if ($bh1 === '000000') {
                $bh1 = '';
            }
            $key = $bh1 !== '' ? ('bh:' . $bh1) : ('id:' . ($sr['UniqId'] ?? md5(json_encode($sr))));
            if (!isset($groups[$key])) {
                $groups[$key] = ['sczl' => $sr, 'cl' => 0.0, 'fp' => 0.0];
            }
            $groups[$key]['cl'] += floatval($sr['sczl_cl'] ?? 0);
            $groups[$key]['fp'] += floatval($sr['sczl_fp'] ?? 0);
        }
        if (count($groups) <= 1) {
            return [];
        }

        $rows = [];
        foreach ($groups as $g) {
            $sr = $g['sczl'];
            $row = $templateRow;
            $row['total_cl'] = $g['cl'];
            $row['cl'] = $g['cl'];
            $row['fp'] = $g['fp'];
            $row['sczl_zcfp'] = 0;
            $row['sczl_jtbh'] = $sr['sczl_jtbh'] ?? ($row['sczl_jtbh'] ?? '');
            $row['sczl_bzdh'] = $sr['sczl_bzdh'] ?? '';
            $row['sczl_bh'] = $sr['sczl_bh1'] ?? '';
            for ($j = 1; $j <= 10; $j++) {
                $bhKey = 'sczl_bh' . $j;
                $rateKey = 'sczl_rate' . $j;
                $val = isset($sr[$bhKey]) ? trim((string)$sr[$bhKey]) : '';
                if ($val === '000000') {
                    $val = '';
                }
                $row[$bhKey] = $val;
                $row[$rateKey] = (isset($sr[$rateKey]) && $sr[$rateKey] !== '') ? $sr[$rateKey] : 0;
            }
            $rows[] = $row;
        }

        return $rows;
    }

    /**
     * 仅 db_sczl 报工、无产量计酬时：若某工序只有一行且无计酬班组，按 sczl 多员工展开
     */
    private function expandSczlMultiTeamRows(array $gyData, string $gdbh, string $yjno): array
    {
        $byGx = [];
        foreach ($gyData as $idx => $row) {
            $gk = $this->normalizeGxhKey($row['Gy0_gxh'] ?? '');
            if ($gk === '') {
                continue;
            }
            $byGx[$gk][] = $idx;
        }

        $replaceGx = [];
        foreach ($byGx as $gk => $indexes) {
            if (count($indexes) !== 1) {
                continue;
            }
            $row = $gyData[$indexes[0]];
            $gxValues = $this->resolveGxhWhereValues($row['Gy0_gxh']);
            $payrollCnt = (int)db('设备_产量计酬')
                ->where('sczl_gdbh', $gdbh)
                ->where('sczl_yjno', $yjno)
                ->where('sczl_gxh', 'in', $gxValues)
                ->count();
            if ($payrollCnt > 0) {
                continue;
            }
            $teams = $this->buildGyRowsFromSczlTeams($gdbh, $yjno, $row['Gy0_gxh'], $row);
            if (count($teams) > 1) {
                $replaceGx[$gk] = $teams;
            }
        }

        if (empty($replaceGx)) {
            return $gyData;
        }

        $out = [];
        $doneGx = [];
        foreach ($gyData as $row) {
            $gk = $this->normalizeGxhKey($row['Gy0_gxh'] ?? '');
            if (isset($replaceGx[$gk]) && !isset($doneGx[$gk])) {
                foreach ($replaceGx[$gk] as $teamRow) {
                    $out[] = $teamRow;
                }
                $doneGx[$gk] = true;
                continue;
            }
            if (isset($doneGx[$gk])) {
                continue;
            }
            $out[] = $row;
        }

        return $out;
    }

    /**
     * 仅 db_sczl 报工、无产量计酬时，从最新一条报工补班组编号/分配比例（拆片等）
     */
    private function fillSczlTeamMemberFields(array &$row, string $gdbh, string $yjno): void
    {
        if (!empty($row['sczl_bh1'])) {
            return;
        }
        $gxh = $row['Gy0_gxh'] ?? '';
        if ($gxh === '') {
            return;
        }
        $sczl = db('db_sczl')
            ->where('sczl_gdbh', $gdbh)
            ->where('sczl_yjno', $yjno)
            ->where('sczl_gxh', $gxh)
            ->order('sczl_rq desc')
            ->find();
        if (empty($sczl)) {
            $sczl = db('db_sczl')
                ->where('sczl_gdbh', $gdbh)
                ->where('sczl_yjno', $yjno)
                ->where('sczl_gxh', (int)$gxh)
                ->order('sczl_rq desc')
                ->find();
        }
        if (empty($sczl)) {
            return;
        }
        for ($j = 1; $j <= 10; $j++) {
            $bhKey = 'sczl_bh' . $j;
            $rateKey = 'sczl_rate' . $j;
            if (!empty($sczl[$bhKey])) {
                $row[$bhKey] = $sczl[$bhKey];
            }
            if (isset($sczl[$rateKey]) && $sczl[$rateKey] !== '') {
                $row[$rateKey] = $sczl[$rateKey];
            }
        }
        if (!empty($sczl['sczl_bzdh'])) {
            $row['sczl_bzdh'] = $sczl['sczl_bzdh'];
        }
    }

    /**
     * ProcessLoss 接口返回结构与历史前端一致（多数数值为字符串，total/部分汇总为数字）
     */
    private function formatProcessLossResponse(array $list): array
    {
        $strFields = [
            'Gd_gdbh', 'yjno', 'ls', '成品代号', '成品名称', '计量单位', 'warehousing_date',
            'warehousing_num', '计划损耗', '废品合计', 'intangible_loss', '材料废', '零头处理',
            '外发废', 'zcfp', '班组分摊质检废品', '订单数量', '销售订单号', 'target_rate', 'real_rate', '考核',
        ];
        foreach ($strFields as $f) {
            if (array_key_exists($f, $list)) {
                $list[$f] = $list[$f] === null ? '' : (string)$list[$f];
            }
        }
        if (array_key_exists('订单数量', $list) && $list['订单数量'] !== '') {
            $list['订单数量'] = number_format((float)$list['订单数量'], 6, '.', '');
        }
        if (!array_key_exists('质量考核', $list) || $list['质量考核'] === '') {
            $list['质量考核'] = null;
        }
        $list['实际投料'] = $list['实际投料'] === null || $list['实际投料'] === ''
            ? 0
            : (float)$list['实际投料'];
        $list['机检废'] = isset($list['机检废']) ? (int)$list['机检废'] : 0;

        if (!empty($list['gy_data']) && is_array($list['gy_data'])) {
            foreach ($list['gy_data'] as $i => $row) {
                $list['gy_data'][$i]['Gy0_gxh'] = (string)($row['Gy0_gxh'] ?? '');
                $list['gy_data'][$i]['Gy0_gxmc'] = (string)($row['Gy0_gxmc'] ?? '');
                $list['gy_data'][$i]['Gy0_yjno'] = (string)($row['Gy0_yjno'] ?? '');
                $list['gy_data'][$i]['Gy0_ls'] = (string)($row['Gy0_ls'] ?? '');
                $list['gy_data'][$i]['Gy0_无形损'] = (string)(int)($row['Gy0_无形损'] ?? 0);
                $list['gy_data'][$i]['Gy0_计划损耗'] = (string)(int)($row['Gy0_计划损耗'] ?? 0);
                $list['gy_data'][$i]['Gy0_计划接货数'] = (string)(int)($row['Gy0_计划接货数'] ?? 0);
                $list['gy_data'][$i]['total_cl'] = (string)(int)($row['total_cl'] ?? 0);
                $list['gy_data'][$i]['total_fp'] = (string)(int)($row['total_fp'] ?? 0);
                $list['gy_data'][$i]['waste_quality'] = (string)(int)($row['waste_quality'] ?? 0);
                $list['gy_data'][$i]['loss'] = (string)(int)($row['loss'] ?? 0);
                $list['gy_data'][$i]['total_waste'] = (int)($row['total_waste'] ?? 0);
                $list['gy_data'][$i]['actual_loss_rate'] = (string)($row['actual_loss_rate'] ?? '');
                $list['gy_data'][$i]['target_loss_rate'] = (string)($row['target_loss_rate'] ?? '');
                $list['gy_data'][$i]['loss_rate'] = (string)($row['loss_rate'] ?? '');
                $list['gy_data'][$i]['工序超节损金额'] = number_format((float)($row['工序超节损金额'] ?? 0), 2, '.', '');
                $list['gy_data'][$i]['超节损承担比例'] = number_format((float)($row['超节损承担比例'] ?? 0), 3, '.', '');
                $list['gy_data'][$i]['无形损承担比例'] = number_format((float)($row['无形损承担比例'] ?? 0), 3, '.', '');
            }
        }

        if (!empty($list['total']) && is_array($list['total'])) {
            $t = &$list['total'];
            $t['total_waste'] = (int)($t['total_waste'] ?? 0);
            $t['total_zjfp'] = (int)($t['total_zjfp'] ?? 0);
            $t['total_fp'] = (int)($t['total_fp'] ?? 0);
            $t['plan_loss'] = (int)($t['plan_loss'] ?? 0);
            $t['waste_intangible'] = (int)($t['waste_intangible'] ?? 0);
            $t['loss'] = (int)($t['loss'] ?? 0);
            $t['reward'] = round((float)($t['reward'] ?? 0), 2);
        }

        return $list;
    }

    /**
     * 产量计酬按班组聚合，避免与工单基本资料等 JOIN 时 SUM(sczl_zcfp) 被放大
     */
    private function buildPayrollTeamAggSubSql(): string
    {
        return db('设备_产量计酬')
            ->field([
                'sczl_gdbh',
                'sczl_yjno',
                'sczl_gxh',
                'sczl_jtbh',
                'sczl_bh1',
                'sczl_bh2',
                'sczl_bh3',
                'sczl_bh4',
                'sczl_bh5',
                'sczl_bh6',
                'sczl_bh7',
                'sczl_bh8',
                'sczl_bh9',
                'sczl_bh10',
                'MAX(sczl_bzdh) as sczl_bzdh',
                'MAX(sczl_gxmc) as sczl_gxmc',
                'MAX(sczl_rate1) as sczl_rate1',
                'MAX(sczl_rate2) as sczl_rate2',
                'MAX(sczl_rate3) as sczl_rate3',
                'MAX(sczl_rate4) as sczl_rate4',
                'MAX(sczl_rate5) as sczl_rate5',
                'MAX(sczl_rate6) as sczl_rate6',
                'MAX(sczl_rate7) as sczl_rate7',
                'MAX(sczl_rate8) as sczl_rate8',
                'MAX(sczl_rate9) as sczl_rate9',
                'MAX(sczl_rate10) as sczl_rate10',
                'SUM(sczl_zcfp) as sczl_zcfp',
                'SUM(sczl_cl) as total_cl',
                'GROUP_CONCAT(DISTINCT sczl_num SEPARATOR ",") AS 流程单',
                'MIN(开工时间) as 开工时间',
            ])
            ->group('sczl_gdbh, sczl_yjno, sczl_gxh, sczl_jtbh, sczl_bh1, CASE WHEN sczl_bh2 = "000000" THEN "" ELSE sczl_bh2 END, sczl_bh3, sczl_bh4, sczl_bh5, sczl_bh6, sczl_bh7, sczl_bh8, sczl_bh9')
            ->buildSql();
    }

    /**
     * db_sczl 按工序聚合，避免与产量计酬 JOIN 时 SUM 被放大
     */
    private function buildSczlProcessAggSubSql(): string
    {
        return db('db_sczl')
            ->field('sczl_gdbh, sczl_yjno, sczl_gxh, SUM(sczl_cl) as cl, SUM(sczl_fp) as fp')
            ->group('sczl_gdbh, sczl_yjno, sczl_gxh')
            ->buildSql();
    }

    /**
     * db_sczl 按工序+班组聚合（与产量计酬 sczl_bh1 对齐）
     */
    private function buildSczlTeamAggSubSql(): string
    {
        return db('db_sczl')
            ->field([
                'sczl_gdbh',
                'sczl_yjno',
                'sczl_gxh',
                'sczl_bh1',
                'SUM(sczl_cl) as cl',
                'SUM(sczl_fp) as fp',
                'MAX(rtrim(sczl_gxmc)) as gxmc',
                'MAX(sczl_bzdh) as bzdh',
            ])
            ->group('sczl_gdbh, sczl_yjno, sczl_gxh, sczl_bh1')
            ->buildSql();
    }

    /**
     * 进入超节损的工序号（产量计酬 + 拆片报工），与 getOrderSuperLossCount 一致
     */
    private function getSuperLossProcessGxhList(string $gdbh, string $yjno): array
    {
        $sql = "SELECT sczl_gxh FROM (
                    SELECT sczl_gxh FROM 设备_产量计酬 WHERE sczl_gdbh = ? AND sczl_yjno = ?
                    UNION
                    SELECT sczl_gxh FROM db_sczl WHERE sczl_gdbh = ? AND sczl_yjno = ? AND sczl_gxmc LIKE '%拆片%'
                    UNION
                    SELECT Gy0_gxh AS sczl_gxh FROM 工单_工艺资料
                        WHERE Gy0_gdbh = ? AND Gy0_yjno = ?
                        AND (Gy0_gxmc LIKE '%外发%' OR IFNULL(Add_gxmc, '') LIKE '%外发%')
                    UNION
                    SELECT Gy0_gxh AS sczl_gxh FROM 工单_工艺资料
                        WHERE Gy0_gdbh = ? AND Gy0_yjno = ?
                        AND (Gy0_gxmc LIKE '%拆片%' OR IFNULL(Add_gxmc, '') LIKE '%拆片%')
                ) AS combined_result";
        $gxhArr = Db::query($sql, [$gdbh, $yjno, $gdbh, $yjno, $gdbh, $yjno, $gdbh, $yjno]);
        $gxhValues = array_column($gxhArr, 'sczl_gxh');
        foreach ($gxhValues as $k => $v) {
            if ((int)$v < 10) {
                $gxhValues[$k] = '0' . $v;
            }
        }

        return array_values(array_unique(array_filter($gxhValues)));
    }

    /**
     * 无形损分摊分母：参与超节损工序的计划损耗合计（含机检/拆片等；外发不参与）
     */
    private function getIntangibleAllocationPlanLossTotal(string $gdbh, string $yjno, array $gxhValues): float
    {
        if (empty($gxhValues)) {
            return 0.0;
        }

        return floatval(db('工单_工艺资料')
            ->where(['Gy0_gdbh' => $gdbh, 'Gy0_yjno' => $yjno, 'Gy0_gxh' => ['in', $gxhValues]])
            ->where('Gy0_gxmc', 'NOT LIKE', '%外发%')
            ->whereRaw("(Add_gxmc IS NULL OR rtrim(Add_gxmc) = '' OR Add_gxmc NOT LIKE '%外发%')")
            ->value('SUM(Gy0_计划损耗 * Gy0_ls * Gy0_ks)'));
    }

    /**
     * 按工序/班组计划损耗占比分摊印件无形损
     */
    private function calcIntangibleLossShareByPlanLoss(
        float $planLoss,
        float $planLossTotal,
        float $intangibleLoss,
        float $intangibleRate = 0.0
    ): int {
        if ($planLossTotal <= 0 || $intangibleLoss == 0.0 || $planLoss <= 0) {
            return 0;
        }
        $share = ($planLoss / $planLossTotal) * $intangibleLoss;
        if ($intangibleRate > 0) {
            $share *= $intangibleRate;
        }

        return (int)round($share);
    }

    /**
     * 按权重分配整数数量（最大余数法，保证合计等于 totalAmount）
     */
    private function allocateIntegerByWeights(int $totalAmount, array $weightsByKey): array
    {
        if ($totalAmount <= 0 || empty($weightsByKey)) {
            return array_fill_keys(array_keys($weightsByKey), 0);
        }
        $sum = array_sum($weightsByKey);
        if ($sum <= 0) {
            return array_fill_keys(array_keys($weightsByKey), 0);
        }

        $result = [];
        $fractions = [];
        $assigned = 0;
        foreach ($weightsByKey as $key => $weight) {
            if ($weight <= 0) {
                $result[$key] = 0;
                $fractions[$key] = 0.0;
                continue;
            }
            $exact = $totalAmount * $weight / $sum;
            $result[$key] = (int)floor($exact);
            $fractions[$key] = $exact - $result[$key];
            $assigned += $result[$key];
        }
        $remain = $totalAmount - $assigned;
        if ($remain > 0) {
            arsort($fractions);
            foreach (array_keys($fractions) as $key) {
                if ($remain <= 0) {
                    break;
                }
                if (($weightsByKey[$key] ?? 0) <= 0) {
                    continue;
                }
                $result[$key]++;
                $remain--;
            }
        }

        return $result;
    }

    /**
     * 印件无形损 → 各工序：按 Gy0_计划损耗×联数×开数 占比分摊（外发不参与；可叠加无形损承担比例）
     */
    private function buildProcessIntangibleShareMap(
        string $gdbh,
        string $yjno,
        array $gxhValues,
        float $intangibleLoss
    ): array {
        if ($intangibleLoss <= 0 || empty($gxhValues)) {
            return [];
        }
        $planTotal = $this->getIntangibleAllocationPlanLossTotal($gdbh, $yjno, $gxhValues);
        if ($planTotal <= 0) {
            return [];
        }

        $rows = db('工单_工艺资料')
            ->field([
                'Gy0_gxh', 'Gy0_计划损耗', 'Gy0_ls', 'Gy0_ks',
                'rtrim(Gy0_gxmc) as gxmc', 'rtrim(Add_gxmc) as add_gxmc', '无形损承担比例',
            ])
            ->where(['Gy0_gdbh' => $gdbh, 'Gy0_yjno' => $yjno, 'Gy0_gxh' => ['in', $gxhValues]])
            ->select();

        $weights = [];
        foreach ($rows as $row) {
            $gxName = (string)($row['gxmc'] ?? '');
            if (!empty($row['add_gxmc'])) {
                $gxName .= '【' . $row['add_gxmc'] . '】';
            }
            if ($this->isSuperLossIntangibleExcluded($gxName)) {
                continue;
            }
            $plan = floatval($row['Gy0_计划损耗']) * floatval($row['Gy0_ls']) * floatval($row['Gy0_ks']);
            if ($plan <= 0) {
                continue;
            }
            $rate = floatval($row['无形损承担比例'] ?? 0);
            $weight = $plan * ($rate > 0 ? $rate : 1.0);
            $gk = $this->normalizeGxhKey($row['Gy0_gxh']);
            $weights[$gk] = ($weights[$gk] ?? 0.0) + $weight;
        }

        return $this->allocateIntegerByWeights((int)round($intangibleLoss), $weights);
    }

    /**
     * 班组行无形损：先按工序计划损耗得工序份额，再按班组分摊计划损耗拆分到各行
     */
    private function assignIntangibleLossToGyDataRows(
        array &$gyData,
        string $gdbh,
        string $yjno,
        array $gxhValues,
        float $intangibleLoss
    ): void {
        $processShares = $this->buildProcessIntangibleShareMap($gdbh, $yjno, $gxhValues, $intangibleLoss);
        $indexesByGx = [];
        foreach ($gyData as $idx => $row) {
            $gk = $this->normalizeGxhKey($row['Gy0_gxh'] ?? '');
            if ($gk === '') {
                $gyData[$idx]['无形损分摊'] = 0;
                continue;
            }
            $indexesByGx[$gk][] = $idx;
        }

        foreach ($indexesByGx as $gk => $indexes) {
            $processShare = (int)($processShares[$gk] ?? 0);
            if ($processShare <= 0) {
                foreach ($indexes as $idx) {
                    $gyData[$idx]['无形损分摊'] = 0;
                }
                continue;
            }
            $weights = [];
            foreach ($indexes as $idx) {
                $weights[$idx] = max(0.0, floatval($gyData[$idx]['计划损耗'] ?? 0));
            }
            if (array_sum($weights) <= 0) {
                foreach ($indexes as $idx) {
                    $weights[$idx] = 1.0;
                }
            }
            $teamShares = $this->allocateIntegerByWeights($processShare, $weights);
            foreach ($indexes as $idx) {
                $gyData[$idx]['无形损分摊'] = (int)($teamShares[$idx] ?? 0);
            }
        }
    }

    /**
     * 目标合格率：1 - Σ(工序计划损耗率)，与 getOrderSuperLossCount type=1 一致
     */
    private function calcSuperLossTargetQualificationRate(string $gdbh, string $yjno, array $gxhValues): float
    {
        if (empty($gxhValues)) {
            return 100.0;
        }

        $rows = db('工单_工艺资料')
            ->alias('a')
            ->field('a.Gy0_计划损耗, a.Gy0_计划接货数 * a.Gy0_ls as Gy0_计划接货数')
            ->where(['a.Gy0_gdbh' => $gdbh, 'a.Gy0_yjno' => $yjno, 'a.Gy0_gxh' => ['in', $gxhValues]])
            ->group('a.Gy0_gxh')
            ->select();

        $arr = [];
        foreach ($rows as $row) {
            $denominator = floatval($row['Gy0_计划接货数']);
            if ($denominator <= 0) {
                continue;
            }
            $rate = round(floatval($row['Gy0_计划损耗']) / $denominator, 5);
            $arr[] = floor($rate * 10000) / 10000;
        }

        return empty($arr) ? 100.0 : (1 - array_sum($arr)) * 100;
    }

    /**
     * 班组无形损分摊：印件无形损 ×（本班组计划损耗 / 全部工序计划损耗合计）
     */
    private function calcTeamIntangibleLossShare(
        array $processRow,
        float $teamPlanLoss,
        float $processPlanLoss,
        float $planLossTotal,
        float $intangibleLoss
    ): int {
        $gxName = (string)($processRow['sczl_gxmc'] ?? $processRow['gxmc'] ?? '');
        if ($this->isSuperLossIntangibleExcluded($gxName)) {
            return 0;
        }

        $planBase = $teamPlanLoss > 0 ? $teamPlanLoss : $processPlanLoss;

        return $this->calcIntangibleLossShareByPlanLoss(
            $planBase,
            $planLossTotal,
            $intangibleLoss,
            floatval($processRow['无形损承担比例'] ?? 0)
        );
    }

    /**
     * 补全无产量报工、但应参与核算的工序（如外发、拆片等）的单行汇总
     */
    private function appendMissingSuperLossProcessRows(
        array $gyData,
        array $gxhValues,
        string $gdbh,
        string $yjno
    ): array {
        $present = [];
        foreach ($gyData as $row) {
            $present[$this->normalizeGxhKey($row['Gy0_gxh'])] = true;
        }

        $missing = [];
        foreach ($gxhValues as $gv) {
            if (!isset($present[$this->normalizeGxhKey($gv)])) {
                $missing[] = $gv;
            }
        }
        if (empty($missing)) {
            return $gyData;
        }

        $payrollProcessSub = db('设备_产量计酬')
            ->field('sczl_gdbh, sczl_yjno, sczl_gxh, SUM(sczl_zcfp) as sczl_zcfp, SUM(sczl_cl) as total_cl')
            ->group('sczl_gdbh, sczl_yjno, sczl_gxh')
            ->buildSql();
        $sczlProcessSub = $this->buildSczlProcessAggSubSql();
        $gxmcExpr = $this->processGxmcSqlExpr();
        $processRows = db('工单_工艺资料')
            ->alias('a')
            ->field([
                'a.Gy0_gdbh', 'a.Gy0_yjno', 'a.Gy0_gxh', 'a.Gy0_ls', 'a.Gy0_ks', 'a.Gy0_计划损耗', 'a.超节损承担比例',
                $gxmcExpr . ' AS sczl_gxmc',
                'b.sczl_zcfp', 'b.total_cl',
                'c.cl', 'c.fp',
                'a.无形损承担比例', 'a.Gy0_Rate0', 'a.Gy0_Rate1', 'a.损耗系数', 'a.Gy0_ms',
                'a.Gy0_计划接货数*a.Gy0_ls*a.Gy0_ks as 计划产量',
                'rtrim(a.Gy0_SITE) as Gy0_SITE', 'rtrim(a.印刷方式) as 印刷方式', 'rtrim(a.版距) as 版距',
            ])
            ->join([$payrollProcessSub => 'b'], 'a.Gy0_gdbh = b.sczl_gdbh AND a.Gy0_yjno = b.sczl_yjno AND a.Gy0_gxh = b.sczl_gxh', 'left')
            ->join([$sczlProcessSub => 'c'], 'a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_yjno = c.sczl_yjno AND a.Gy0_gxh = c.sczl_gxh', 'left')
            ->where(['a.Gy0_gdbh' => $gdbh, 'a.Gy0_yjno' => $yjno, 'a.Gy0_gxh' => ['in', $missing]])
            ->select();

        foreach ($processRows as $item) {
            $item['sczl_bh1'] = '';
            $item['sczl_bh'] = '';
            $item['gxmc'] = '';
            $item['sczl_jtbh'] = '';
            $item['sczl_bzdh'] = '';
            for ($j = 1; $j <= 10; $j++) {
                $item['sczl_bh' . $j] = '';
                $item['sczl_rate' . $j] = 0;
            }
            $teams = $this->buildGyRowsFromSczlTeams($gdbh, $yjno, $item['Gy0_gxh'], $item);
            if (!empty($teams)) {
                foreach ($teams as $teamRow) {
                    $gyData[] = $teamRow;
                }
            } else {
                $this->fillSczlTeamMemberFields($item, $gdbh, $yjno);
                $gyData[] = $item;
            }
        }

        return $gyData;
    }

    /**
     * 材料费（张数）未超投料 1.5% 时，按目标/实际合格率偏差确定节损金额倍率（边界向下归档）
     */
    private function resolveSuperLossRewardMultiplier(
        float $targetRate,
        float $realRate,
        float $materialWaste,
        float $feedQty
    ): float {
        if ($feedQty <= 0) {
            return 1.0;
        }
        if (($materialWaste / $feedQty) > 0.015) {
            return 1.0;
        }

        $diff = $realRate - $targetRate;

        if ($targetRate > 97) {
            $triggerHigh = 1.5;
            $triggerLow = -2.0;
            $multiplier = 1.3;
        } elseif ($targetRate > 95) {
            $triggerHigh = 2.0;
            $triggerLow = -2.5;
            $multiplier = 1.3;
        } elseif ($targetRate > 90) {
            $triggerHigh = 3.0;
            $triggerLow = -3.0;
            $multiplier = 1.3;
        } elseif ($targetRate > 80) {
            $triggerHigh = 4.0;
            $triggerLow = -4.0;
            $multiplier = 1.6;
        } else {
            $triggerHigh = 5.0;
            $triggerLow = -5.0;
            $multiplier = 1.6;
        }

        if ($diff > $triggerHigh || $diff < $triggerLow) {
            return $multiplier;
        }

        return 1.0;
    }

    public function updateWorkorderStatus()
    {
        if ($this->request->isGet() == false) {
            $this->error('请求错误');
        }
        $param = $this->request->param();
        if (empty($param['workorder']) || empty($param['yjno']) || empty($param['status'])) {
            $this->error('参数错误');
        }
        $sql = \db('工单_印件资料')
            ->where('Yj_Gdbh',$param['workorder'])
            ->where('yj_Yjno',$param['yjno'])
            ->fetchSql(true)
            ->update(['工单类型'=>$param['status']]);
        $result = db()->query($sql);
        if ($result !== false) {
            $this->success('修改成功');
        }else{
            $this->error('修改失败');
        }

    }
}