ソースを参照

超节损无形损计算优化

unknown 3 時間 前
コミット
8caa140f7c
1 ファイル変更690 行追加441 行削除
  1. 690 441
      application/api/controller/OrderSuperLoss.php

+ 690 - 441
application/api/controller/OrderSuperLoss.php

@@ -1267,466 +1267,715 @@ class OrderSuperLoss extends Api
      * @throws \think\db\exception\ModelNotFoundException
      * @throws \think\exception\DbException
      */
-    public function OneOrderSuperLoss($gdbh,$yjno)
-    {
-//        $param = $this->request->param();
-        $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.销售订单号) as 销售订单号,a.订单数量,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();
+    /**
+ * 计算单个工单的超节损数据
+ * 
+ * @param string $gdbh 工单编号
+ * @param string $yjno 印件号
+ * @return array|false 返回超节损计算结果数组,失败返回false
+ */
+public function OneOrderSuperLoss($gdbh, $yjno)
+{
+    // ========== 阶段1: 基础数据查询 ==========
+    // 获取工单末板入仓数据
+    $workOrderData = $this->getWorkOrderWarehouse($gdbh, $yjno);
+    if (empty($workOrderData)) {
+        $this->error("工单{$gdbh}-{$yjno}未查询到末板入仓记录");
+    }
+    
+    // 获取工单入仓总数量
+    $totalNumber = $this->getTotalWarehouseCount($gdbh, $yjno);
+    // 获取工单资料和投料数据
+    $workOrderInfo = $this->getWorkOrderInfo($gdbh, $yjno);
+    
+    // 投料为空则返回失败
+    if (empty($workOrderInfo['投料'])) {
+        return false;
+    }
+    
+    // ========== 阶段2: 投料数据处理 ==========
+    // 处理投料单位转换和开数联数默认值
+    $data = $this->processMaterialData($workOrderInfo);
+    
+    // 调用外部方法计算计划工序产出
+    (new WorkOrder())->PlannedProcessYield($gdbh, $yjno, 0, $data['实际投料'] * 10000 / $data['ls']);
+    
+    // 添加工单入仓数据到结果集
+    $data['warehousing_num'] = $totalNumber;
+    $data['warehousing_date'] = substr($workOrderData['jjcp_sj'], 0, 10);
+    
+    // ========== 阶段3: 报工工序获取 ==========
+    // 获取有报工记录的工序列表
+    $gxhValues = $this->getReportedProcesses($workOrderData['jjcp_gdbh'], $workOrderData['jjcp_yjno']);
+    if (empty($gxhValues)) {
+        $this->error("工单{$workOrderData['jjcp_gdbh']}-{$workOrderData['jjcp_yjno']}未查询到报工信息");
+    }
+    
+    // ========== 阶段4: 合格率与废品计算 ==========
+    // 计算目标合格率和实际合格率
+    $data = $this->calculateRates($data, $totalNumber);
+    // 计算制程废品和无形损耗
+    $data = $this->calculateWaste($data, $workOrderData, $totalNumber);
+    
+    // ========== 阶段5: 废品数据处理 ==========
+    // 处理核检单废品上报数据,分类统计各类废品
+    $wasteResult = $this->processWasteData($workOrderData['jjcp_gdbh'], $workOrderData['jjcp_yjno']);
+    $data = array_merge($data, $wasteResult['summary']);
+    $wasteDetails = $wasteResult['details'];
+    
+    // ========== 阶段6: 工序产量数据获取 ==========
+    // 获取按班组分的产量数据和工序汇总数据
+    $productionData = $this->getProductionData($workOrderData, $gxhValues);
+    
+    // ========== 阶段7: 超节损计算 ==========
+    // 计算每道工序的超节损金额和节损奖
+    $gyData = $this->calculateSuperLoss(
+        $productionData['gy_data'], 
+        $productionData['total_cl_data'], 
+        $wasteDetails, 
+        $data, 
+        $workOrderData
+    );
+    
+    // ========== 阶段8: 结果整合 ==========
+    // 构建最终的超节损结果数据结构
+    return $this->buildResult($gyData, $data, $totalNumber, $workOrderData);
+}
 
-        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'] = '张';
-                }
-            }
+// ========== 私有方法实现 ==========
 
-        }
+/**
+ * 获取工单末板入仓数据
+ * 
+ * @param string $gdbh 工单编号
+ * @param string $yjno 印件号
+ * @return array 入仓数据
+ */
+private function getWorkOrderWarehouse($gdbh, $yjno)
+{
+    return \db('成品入仓')
+        ->where('jjcp_gdbh', $gdbh)
+        ->where('jjcp_yjno', $yjno)
+        ->where('jjcp_smb', '末 板')  // 只查询末板记录
+        ->find();
+}
 
-        //将开数、联数为0重新赋值
-        if ($data['ls'] == 0) {
-            $data['ls'] = 1;
-        }
-        if ($data['ks'] == 0) {
-            $data['ks'] = 1;
-        }
+/**
+ * 获取工单入仓总数量
+ * 
+ * @param string $gdbh 工单编号
+ * @param string $yjno 印件号
+ * @return int 入仓总数量
+ */
+private function getTotalWarehouseCount($gdbh, $yjno)
+{
+    $result = \db('成品入仓')
+        ->where('jjcp_gdbh', $gdbh)
+        ->where('jjcp_yjno', $yjno)
+        ->column('SUM(jjcp_sl)');  // 汇总入仓数量
+    return $result ? $result[0] : 0;
+}
 
-        //计算工单实际投料
-        $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);
-        //从设备产量计酬和sczl查出进入超节损的工序,有上报产量的工序就进入超节损
-        $gxh_sql = "SELECT sczl_gxh FROM
-                        (SELECT sczl_gxh FROM 设备_产量计酬 WHERE sczl_gdbh = '{$workOrderData['jjcp_gdbh']}' AND sczl_yjno = '{$workOrderData['jjcp_yjno']}'
-                        UNION SELECT sczl_gxh FROM db_sczl WHERE sczl_gdbh = '{$workOrderData['jjcp_gdbh']}' AND sczl_yjno = '{$workOrderData['jjcp_yjno']}') AS combined_result";
-        $gxh_arr = Db::query($gxh_sql);
-        if (empty($gxh_arr)) {
-            $this->error("工单".$workOrderData['jjcp_gdbh']."-".$workOrderData['jjcp_yjno']."未查询到报工信息,请核查该工单是否已进入超节损");
+/**
+ * 获取工单资料和投料数据
+ * 
+ * @param string $gdbh 工单编号
+ * @param string $yjno 印件号
+ * @return array 工单资料和投料数据
+ */
+private function getWorkOrderInfo($gdbh, $yjno)
+{
+    // 查询字段:工单编号、成品信息、销售订单、订单数量、开数、联数、投料量、单位等
+    $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 投料,
+              b.st_dw,c.yj_zzmc,c.yj_tlgg,SUM(b.mod_number) as mod_num';
+    
+    return 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', $gdbh)
+        ->where('c.yj_Yjno', $yjno)
+        ->where(function ($query) {
+            // 仓库编号限定为101或Y101
+            $query->where('b.仓库编号', '101')->whereOr('b.仓库编号', 'Y101');
+        })
+        ->field($field)
+        ->find();
+}
 
-        }
-        //整理查询处理的工序编号
-        $gxh_values = array_column($gxh_arr, 'sczl_gxh');
-        //将工序号小于10的编号前面加0
-        foreach ($gxh_values as $k => $v) {
-            if ((int)$v < 10) {
-                $gxh_values[$k] = '0' . $v;
+/**
+ * 获取有报工记录的工序列表
+ * 
+ * @param string $gdbh 工单编号
+ * @param string $yjno 印件号
+ * @return array 工序编号数组
+ */
+private function getReportedProcesses($gdbh, $yjno)
+{
+    // 使用UNION合并设备产量计酬和db_sczl表的报工工序
+    $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 = ?
+            ) AS combined_result";
+    
+    // 使用参数绑定防止SQL注入
+    $gxh_arr = Db::query($sql, [$gdbh, $yjno, $gdbh, $yjno]);
+    if (empty($gxh_arr)) return [];
+    
+    // 工序号小于10的前面补0,保证格式统一
+    return array_map(function ($v) {
+        return (int)$v < 10 ? '0' . $v : $v;
+    }, array_column($gxh_arr, 'sczl_gxh'));
+}
+
+/**
+ * 处理投料数据
+ * - 处理特殊单位转换(吨转张)
+ * - 设置开数、联数默认值
+ * - 计算实际投料量
+ * 
+ * @param array $workOrderInfo 工单资料
+ * @return array 处理后的投料数据
+ */
+private function processMaterialData($workOrderInfo)
+{
+    $data = $workOrderInfo;
+    
+    // 特殊投料单位转换:吨转张
+    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'] = '张';
             }
         }
-        $arr = [];
-        $plan_loss = [];//工单计划损耗
-        $target_rate = (1 - array_sum($arr)) * 100;
-        //目标合格率
-        $data['target_rate'] = $target_rate . '%';
-        //实际合格率
-        $real_rate = $total_number[0] / ($data['实际投料'] * 10000) * 100;
-        $data['real_rate'] = number_format($real_rate, 2) . '%';
-        //制程废品
-        $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++;
-                    }
+    }
+    
+    // 开数、联数为0时默认设为1(避免除零错误)
+    $data['ls'] = $data['ls'] == 0 ? 1 : $data['ls'];
+    $data['ks'] = $data['ks'] == 0 ? 1 : $data['ks'];
+    
+    // 计算工单实际投料量(除以10000转换单位)
+    $data['实际投料'] = str_replace(',', '', number_format($data['投料'] * $data['ls'] * $data['ks'] / 10000, 4));
+    
+    return $data;
+}
 
-                    //机检废品
-                    if (substr($entry[$gxmcKey],0,2) == '01' ){
-                        $machine[$o]= $entry[$slKey];
-                        $o++;
-                    }
-                }
-                $quality[$m]= $entry[$slKey];
-                $m++;
+/**
+ * 计算合格率
+ * 
+ * @param array $data 工单数据
+ * @param int $totalNumber 入仓数量
+ * @return array 包含合格率的数据
+ */
+private function calculateRates($data, $totalNumber)
+{
+    // 目标合格率默认100%
+    $data['target_rate'] = '100%';
+    // 实际合格率 = 入仓数量 / 实际投料 * 100%
+    $data['real_rate'] = number_format($totalNumber / ($data['实际投料'] * 10000) * 100, 2) . '%';
+    
+    return $data;
+}
+
+/**
+ * 计算废品数量和无形损耗
+ * 
+ * @param array $data 工单数据
+ * @param array $workOrderData 入仓数据
+ * @param int $totalNumber 入仓数量
+ * @return array 包含废品数据的结果
+ */
+private function calculateWaste($data, $workOrderData, $totalNumber)
+{
+    // 查询制程废品数量
+    $zzfpData = db('设备_产量计酬')
+        ->where('sczl_gdbh', $workOrderData['jjcp_gdbh'])
+        ->where('sczl_yjno', $workOrderData['jjcp_yjno'])
+        ->field('SUM(sczl_zcfp) as sczl_zcfp')
+        ->select();
+    
+    // 制程废品 = 原始制程废品 * 开数 * 联数
+    $data['zcfp'] = ($zzfpData[0]['sczl_zcfp'] ?? 0) * $data['ls'] * $data['ks'];
+    
+    // 查询核检单废品数量
+    $wasteTotal = db('db_qczl')
+        ->where('qczl_gdbh', $workOrderData['jjcp_gdbh'])
+        ->where('qczl_yjno', $workOrderData['jjcp_yjno'])
+        ->sum('qczl_fp') ?: 0;
+    
+    // 无形损耗 = 实际投料 - 入仓数量 - 制程废品 - 核检废品
+    $data['intangible_loss'] = (int)($data['实际投料'] * 10000 - $totalNumber - $data['zcfp'] - $wasteTotal);
+    
+    return $data;
+}
+
+/**
+ * 处理核检单废品数据
+ * 分类统计:外发废、材料废、零头处理、质检废、机检废
+ * 
+ * @param string $gdbh 工单编号
+ * @param string $yjno 印件号
+ * @return array 包含废品汇总和详情的数据
+ */
+private function processWasteData($gdbh, $yjno)
+{
+    // 查询核检单废品上报数据(包含13个废品字段)
+    $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 = ? AND qczl_yjno = ?";
+    
+    $waste_out = Db::query($sql, [$gdbh, $yjno]);
+    
+    // 初始化废品分类汇总数组
+    $summary = ['外发废' => 0, '材料废' => 0, '零头处理' => 0, '工单质检废' => 0, '机检废' => 0];
+    
+    // 遍历每条核检单记录
+    foreach ($waste_out as $entry) {
+        // 遍历13个废品字段
+        for ($i = 1; $i <= 13; $i++) {
+            $slValue = $entry["fp_sl{$i}"] ?? 0;
+            // 累计质检废总量
+            $summary['工单质检废'] += $slValue;
+            
+            // 根据废品类别进行分类
+            if (!empty($entry["fp_lb{$i}"])) {
+                $label = $entry["fp_lb{$i}"];
+                $gxmc = $entry["fp_gxmc{$i}"] ?? '';
+                
+                // M04开头为外发加工废
+                if (substr($label, 0, 3) === 'M04') $summary['外发废'] += $slValue;
+                // L开头为材料废
+                elseif (substr($label, 0, 1) === 'L') $summary['材料废'] += $slValue;
+                // M01开头为零头处理
+                elseif (substr($label, 0, 3) === 'M01') $summary['零头处理'] += $slValue;
+                // 工序名称以01开头为机检废品
+                elseif (substr($gxmc, 0, 2) === '01') $summary['机检废'] += $slValue;
             }
         }
-        $data['材料废'] = array_sum($material); //材料废
-        $data['零头处理'] = array_sum($change); //零头处理
-        $data['外发废'] = array_sum($list);//外发废
-        $data['工单质检废'] = array_sum($quality);//质检废
-        $data['机检废'] = array_sum($machine);//机检废
-        //查询计划损耗
-        $plan_total = db('工单_工艺资料')
-            ->where(['Gy0_gdbh' => $workOrderData['jjcp_gdbh'], 'Gy0_yjno' => $workOrderData['jjcp_yjno'], 'Gy0_gxh' => ['in', $gxh_values]])
-            ->value('SUM(Gy0_计划损耗 * Gy0_ls * Gy0_ks)');
-        //单据列表最后统计/数据汇总
-        $total = [];
-        $total['plan_loss'] = 0;
-        $total['total_fp'] = 0;
-        $total['waste_quality'] = 0;
-        $total['waste_intangible'] = 0;
-        $total['reward'] = 0; //超节损奖励数组
-        //工单产量数据详情查询
-        $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', 'SUM(c.sczl_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('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' => $workOrderData['jjcp_gdbh'],
-                'a.Gy0_yjno' => $workOrderData['jjcp_yjno'],
-                'a.Gy0_gxh' => ['IN', $gxh_values],
-                'b.sczl_cl|c.sczl_cl' => ['>', 0],
-            ])
-            ->group('a.Gy0_gxh')
-            ->order('a.Gy0_gxh')
-            ->select();
-        //按班组分的产量数据
-        $gy_data = db('工单_工艺资料')
-            ->alias('a')
-            ->field([
-                'a.Gy0_gdbh', 'a.Gy0_yjno', 'a.Gy0_gxh', 'a.Gy0_ls', 'a.Gy0_ks', 'a.Gy0_计划损耗', 'a.超节损承担比例',
-                'CONCAT(`a`.`Gy0_gxmc`, "【", a.Add_gxmc,"】") AS 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', 'GROUP_CONCAT(DISTINCT b.sczl_num SEPARATOR ",") AS 流程单',
-                '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',
-                'rtrim(c.sczl_gxmc) as gxmc', 'SUM(c.sczl_cl) as cl', 'SUM(c.sczl_fp) as fp', 'c.sczl_bh1 as sczl_bh',
-                'd.使用部门 as 使用部门', 'c.sczl_bzdh as bzdh', 'b.sczl_jtbh', 'a.损耗系数', 'a.Gy0_ms', 'a.Gy0_Rate0',
-                'a.Gy0_Rate1', 'a.无形损承担比例', 'a.Gy0_计划接货数*a.Gy0_ls*a.Gy0_ks as 计划产量', 'e.Gd_客户代号', 'e.Gd_客户名称',
-                'e.Gd_cpdh', 'e.Gd_cpmc', 'e.销售订单号', 'e.投料大箱', 'e.订单数量', 'e.计量单位', 'rtrim(a.Gy0_SITE) as Gy0_SITE',
-                '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('db_sczl c', 'a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_yjno = c.sczl_yjno AND a.Gy0_gxh = c.sczl_gxh', 'left')
-            ->join('设备_基本资料 d', 'd.设备编号 = b.sczl_jtbh', 'left')
-            ->join('工单_基本资料 e', 'a.Gy0_gdbh = e.Gd_gdbh AND a.Gy0_yjno = e.行号')
-            ->where([
-                'a.Gy0_gdbh' => $workOrderData['jjcp_gdbh'],
-                'a.Gy0_yjno' => $workOrderData['jjcp_yjno'],
-                'a.Gy0_gxh' => ['in', $gxh_values],
-                'b.sczl_cl|c.sczl_cl' => ['>', 0],
-            ])
-            ->group('a.Gy0_gxh,b.sczl_jtbh,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, c.sczl_bh1')
-            ->order('a.Gy0_gxh asc, b.开工时间 asc, c.sczl_rq desc')
-            ->select();
-        $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'];
+    }
+    
+    return ['summary' => $summary, 'details' => $waste_out];
+}
+
+/**
+ * 获取工序产量数据
+ * 
+ * @param array $workOrderData 入仓数据
+ * @param array $gxhValues 工序编号数组
+ * @return array 包含汇总数据和班组数据的数组
+ */
+private function getProductionData($workOrderData, $gxhValues)
+{
+    // 查询工序产量汇总数据
+    $totalClData = \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', 'SUM(c.sczl_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('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' => $workOrderData['jjcp_gdbh'],
+            'a.Gy0_yjno' => $workOrderData['jjcp_yjno'],
+            'a.Gy0_gxh' => ['IN', $gxhValues],
+            'b.sczl_cl|c.sczl_cl' => ['>', 0],  // 产量大于0
+        ])
+        ->group('a.Gy0_gxh')
+        ->order('a.Gy0_gxh')
+        ->select();
+    
+    // 查询按班组分的产量数据
+    $gyData = db('工单_工艺资料')->alias('a')
+        ->field([
+            'a.Gy0_gdbh', 'a.Gy0_yjno', 'a.Gy0_gxh', 'a.Gy0_ls', 'a.Gy0_ks', 
+            'a.Gy0_计划损耗', 'a.超节损承担比例', 'CONCAT(`a`.`Gy0_gxmc`, "【", a.Add_gxmc,"】") AS 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', 
+            'GROUP_CONCAT(DISTINCT b.sczl_num SEPARATOR ",") AS 流程单',
+            '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',
+            'rtrim(c.sczl_gxmc) as gxmc', 'SUM(c.sczl_cl) as cl', 'SUM(c.sczl_fp) as fp', 'c.sczl_bh1 as sczl_bh',
+            'd.使用部门 as 使用部门', 'c.sczl_bzdh as bzdh', 'b.sczl_jtbh', 'a.损耗系数', 'a.Gy0_ms', 'a.Gy0_Rate0',
+            'a.Gy0_Rate1', 'a.无形损承担比例', 'a.Gy0_计划接货数*a.Gy0_ls*a.Gy0_ks as 计划产量', 
+            'e.Gd_客户代号', 'e.Gd_客户名称', 'e.Gd_cpdh', 'e.Gd_cpmc', 'e.销售订单号', 
+            'e.投料大箱', 'e.订单数量', 'e.计量单位', 'rtrim(a.Gy0_SITE) as Gy0_SITE',
+            '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('db_sczl c', 'a.Gy0_gdbh = c.sczl_gdbh AND a.Gy0_yjno = c.sczl_yjno AND a.Gy0_gxh = c.sczl_gxh', 'left')
+        ->join('设备_基本资料 d', 'd.设备编号 = b.sczl_jtbh', 'left')
+        ->join('工单_基本资料 e', 'a.Gy0_gdbh = e.Gd_gdbh AND a.Gy0_yjno = e.行号')
+        ->where([
+            'a.Gy0_gdbh' => $workOrderData['jjcp_gdbh'],
+            'a.Gy0_yjno' => $workOrderData['jjcp_yjno'],
+            'a.Gy0_gxh' => ['in', $gxhValues],
+            'b.sczl_cl|c.sczl_cl' => ['>', 0],
+        ])
+        ->group('a.Gy0_gxh,b.sczl_jtbh,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, c.sczl_bh1')
+        ->order('a.Gy0_gxh asc, b.开工时间 asc, c.sczl_rq desc')
+        ->select();
+    
+    return ['total_cl_data' => $totalClData, 'gy_data' => $gyData];
+}
+
+/**
+ * 获取工单计划损耗总量
+ * 
+ * @param array $workOrderData 入仓数据
+ * @param array $gyData 工序数据
+ * @return float 计划损耗总量
+ */
+private function getPlanLossTotal($workOrderData, $gyData)
+{
+    $gxhValues = array_unique(array_column($gyData, 'Gy0_gxh'));
+    
+    return db('工单_工艺资料')
+        ->where(['Gy0_gdbh' => $workOrderData['jjcp_gdbh'], 
+                 'Gy0_yjno' => $workOrderData['jjcp_yjno'], 
+                 'Gy0_gxh' => ['in', $gxhValues]])
+        ->value('SUM(Gy0_计划损耗 * Gy0_ls * Gy0_ks)') ?: 0;
+}
+
+/**
+ * 计算班组产量
+ * 
+ * @param array $item 工序数据项
+ */
+private function calculateProduction(&$item)
+{
+    // 班组产量 = 原始产量 * 开数 * 联数
+    $item['total_cl'] = $item['total_cl'] * $item['Gy0_ls'] * $item['Gy0_ks'];
+    
+    // 如果设备产量计酬表没有数据,使用报工表数据
+    if (empty($item['total_cl'])) {
+        $item['total_cl'] = $item['cl'] * $item['Gy0_ls'] * $item['Gy0_ks'];
+    }
+    
+    // 班组编号为空时使用报工表的班组编号
+    if (empty($item['sczl_bh1'])) {
+        $item['sczl_bh1'] = $item['sczl_bh'];
+    }
+}
+
+/**
+ * 根据印刷方式调整产量(卷对卷需除以版距)
+ * 
+ * @param array $item 工序数据项
+ * @param array $totalClData 产量汇总数据
+ * @return int 调整后的产量
+ */
+private function adjustProduction($item, $totalClData)
+{
+    $banju = $item['版距'] / 1000;  // 版距转换为米
+    $cl = $item['total_cl'];  // 注意:这里已经在 calculateProduction() 中乘以了 ls 和 ks
+    
+    // 卷对卷印刷方式需要除以版距
+    if ($item['印刷方式'] === '卷对卷') {
+        $cl = $cl / $banju;
+    }
+    
+    // 不需要再乘以 ls 和 ks,避免重复计算
+    return (int)$cl;
+}
+
+/**
+ * 计算班组质检废品
+ * 
+ * @param array $item 工序数据项
+ * @param array $wasteDetails 废品详情数据
+ * @return int 质检废品数量
+ */
+private function calculateQualityWaste($item, $wasteDetails)
+{
+    $zjfp = 0;
+    
+    // 遍历废品详情,匹配工序和班组
+    foreach ($wasteDetails as $entry) {
+        for ($i = 1; $i <= 13; $i++) {
+            $gxmc = $entry["fp_gxmc{$i}"] ?? '';
+            $bh = $entry["fp_bh{$i}"] ?? '';
+            
+            // 匹配工序编号和班组编号
+            if ((int)substr($gxmc, 0, 2) == $item['Gy0_gxh'] && $bh == $item['sczl_bh1']) {
+                $zjfp += $entry["fp_sl{$i}"] ?? 0;
             }
         }
-   
-        foreach ($gy_data as $kk => $vv) {
-            $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']) {
-                    $gy_data[$kk]['计划损耗'] = round($gy_data[$kk]['total_cl'] / $cl * $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];
-                    }
-                }
-            }
-            $gy_data[$kk]['质检废'] = round($gy_data[$kk]['zjfp']*($gy_data[$kk]['total_cl']/$sumBz[$vv['sczl_bh1'].'-'.$vv['Gy0_gxh']]));
-            //无形损分摊
-            if ($plan_total > 0) {
-                $gy_data[$kk]['无形损分摊'] = round($gy_data[$kk]['计划损耗'] / $plan_total * $data['intangible_loss']);
-            } else {
-                $gy_data[$kk]['无形损分摊'] = 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'];
-                    }
-                }
-            }
+    }
+    
+    return $zjfp;
+}
 
-            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']);
-        }
-        // halt($gy_data);
-        //计算超节损金额
-        foreach ($gy_data as $n => $item) {
-            //节损数量
-            if ($item['无形损分摊'] > 0) {
-                $total_waste = $item['质检废'] + $item['sczl_zcfp'] + $item['无形损分摊'];
-            } else {
-                $total_waste = $item['质检废'] + $item['sczl_zcfp'];
-            }
-            $gy_data[$n]['节损数量'] = $item['计划损耗'] - $total_waste;
-            //节损奖
-            $guige = \db('物料_存货编码')
-                ->where('物料代码',$data['成品代号'])
-                ->value('rtrim(规格)');
-
-            //工序超节损金额
-            if (strpos($guige,'小盒') !== false){
-                $moneyRate = 0.02;
-            }else{
-                $moneyRate = 0.09;
+/**
+ * 计算工序产量
+ * 
+ * @param array $item 工序数据项
+ * @param array $totalClData 产量汇总数据
+ * @return int 工序产量
+ */
+private function calculateProcessProduction($item, $totalClData)
+{
+    foreach ($totalClData as $v) {
+        $banju = $v['版距'] / 1000;
+        $totalCl = $v['total_cl'];
+        
+        // 卷对卷需调整
+        if ($v['印刷方式'] === '卷对卷') {
+            $totalCl = $totalCl / $banju;
+        }
+        
+        // 匹配工序
+        if ($v['Gy0_yjno'] === $item['Gy0_yjno'] && $v['Gy0_gxh'] === $item['Gy0_gxh']) {
+            // 拆片工序使用报工产量,其他工序使用设备产量
+            // 注意:这里需要乘以 ls 和 ks,因为 total_cl 来自数据库原始值
+            return strpos($v['gxmc'], '拆片') !== false 
+                ? $v['cl'] * $item['Gy0_ls'] * $item['Gy0_ks']
+                : $totalCl * $item['Gy0_ls'] * $item['Gy0_ks'];
+        }
+    }
+    
+    return 0;
+}
+
+/**
+ * 清理工序数据中的临时字段
+ * 
+ * @param array $item 工序数据项
+ */
+private function cleanupProcessData(&$item)
+{
+    unset($item['gxmc'], $item['cl'], $item['fp'], $item['sczl_bh'], $item['bzdh']);
+}
+
+/**
+ * 计算超节损数据
+ * 
+ * @param array $gyData 工序数据
+ * @param array $totalClData 产量汇总数据
+ * @param array $wasteDetails 废品详情
+ * @param array $data 工单数据
+ * @param array $workOrderData 入仓数据
+ * @return array 计算后的工序数据
+ */
+private function calculateSuperLoss($gyData, $totalClData, $wasteDetails, $data, $workOrderData)
+{
+    $sumBz = [];  // 班组产量汇总
+    $planTotal = $this->getPlanLossTotal($workOrderData, $gyData);
+    
+    // 第一步:预计算班组产量总和
+    foreach ($gyData as &$item) {
+        $this->calculateProduction($item);
+        $key = "{$item['sczl_bh1']}-{$item['Gy0_gxh']}";
+        $sumBz[$key] = isset($sumBz[$key]) ? $sumBz[$key] + $item['total_cl'] : $item['total_cl'];
+    }
+    
+    // 第二步:收集所有员工编号用于批量查询
+    $employeeIds = [];
+    foreach ($gyData as $item) {
+        for ($j = 1; $j <= 10; $j++) {
+            if (!empty($item["sczl_bh{$j}"])) {
+                $employeeIds[] = $item["sczl_bh{$j}"];
             }
-            if (strpos($item['sczl_gxmc'], '机检') !== false) {
-                $gy_data[$n]['节损奖'] = 0;
-            } else {
-                $gy_data[$n]['节损奖'] = number_format($gy_data[$n]['节损数量'] * $item['超节损承担比例'] * $moneyRate, 4);
+        }
+    }
+    // 批量查询员工姓名
+    $employeeNames = $this->getEmployeeNames(array_unique($employeeIds));
+    
+    // 第三步:计算每道工序的超节损数据
+    foreach ($gyData as $kk => &$vv) {
+        // 注意:calculateProduction() 已在之前调用,total_cl 已乘以 ls 和 ks
+        // 现在只需要调整卷对卷的情况
+        $vv['total_cl'] = $this->adjustProduction($vv, $totalClData);
+        
+        // 计算计划损耗
+        $vv['Gy0_计划损耗'] = $vv['Gy0_计划损耗'] * $vv['Gy0_ls'] * $vv['Gy0_ks'];
+        
+        // 根据工序总产量计算班组分摊计划损耗
+        foreach ($totalClData as $v) {
+            if ($vv['Gy0_yjno'] == $v['Gy0_yjno'] && $vv['Gy0_gxh'] == $v['Gy0_gxh']) {
+                $cl = $v['total_cl'] ?: $v['cl'];
+                $vv['计划损耗'] = round($vv['total_cl'] / ($cl * $v['Gy0_ls']) * $vv['Gy0_计划损耗']);
+                break;
             }
-            $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['无形损分摊'];
-            $total['reward'] += floatval(str_replace(',', '', $gy_data[$n]['节损奖']));
         }
-        // halt($gy_data);
-        //整合数据
-        $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'],
-                '类型' => '',
-                '客户代号' => $value['Gd_客户代号'],
-                '客户名称' => $value['Gd_客户名称'],
-                '产品代号' => $value['Gd_cpdh'],
-                '产品名称' => $value['Gd_cpmc'],
-                '销售订单号' => $value['销售订单号'],
-                '订单数量' => $value['订单数量'],
-                '计量单位' => $value['计量单位'],
-                '实际投料' => $data['实际投料'],
-                '入仓数量' => $total_number[0],
-                '入仓日期' => $workOrderData['jjcp_sj'],
-                '大箱数' => $value['投料大箱'],
-                '废品合计' => $data['工单质检废'] + $data['zcfp'],
-                'sys_id' => '',
-                'sys_rq' => date('Y-m-d H:i:s', time()),
-                '车间名称' => $value['Gy0_SITE']
-            ];
+        
+        // 计算制程废品
+        $vv['sczl_zcfp'] = $vv['sczl_zcfp'] ? $vv['sczl_zcfp'] * $vv['Gy0_ls'] : ($vv['fp'] * $vv['Gy0_ls']);
+        
+        // 设置工序名称和班组编号
+        $vv['sczl_gxmc'] = $vv['sczl_gxmc'] ?: $vv['gxmc'];
+        $vv['sczl_bh1'] = $vv['sczl_bh1'] ?: $vv['sczl_bh'];
+        
+        // 计算质检废品
+        $vv['zjfp'] = $this->calculateQualityWaste($vv, $wasteDetails);
+        $vv['质检废'] = round($vv['zjfp'] * ($vv['total_cl'] / $sumBz["{$vv['sczl_bh1']}-{$vv['Gy0_gxh']}"]));
+        
+        // 无形损分摊
+        // 计算工序无形损(基于计划损耗分摊)
+        $rawIntangibleLoss = $planTotal > 0 ? $vv['计划损耗'] / $planTotal * $data['intangible_loss'] : 0;
+        // 计算工序计划产量的千分之三作为阈值
+        $intangibleThreshold = $vv['计划产量'] * 0.003;
+        // 判断:如果工序无形损不超过千分之三,则计为0;超过千分之三的部分取正整数计入超节损
+        if ($rawIntangibleLoss <= $intangibleThreshold) {
+            $vv['无形损分摊'] = 0;
+        } else {
+            // 超过千分之三的部分,取正整数
+            $vv['无形损分摊'] = max(0, (int)($rawIntangibleLoss - $intangibleThreshold));
         }
+                
+        // 填充员工姓名
+        for ($j = 1; $j <= 10; $j++) {
+            $vv["sczl_name{$j}"] = !empty($vv["sczl_bh{$j}"]) ? ($employeeNames[$vv["sczl_bh{$j}"]] ?? '') : '';
+        }
+        
+        // 计算工序产量
+        $vv['工序产量'] = $this->calculateProcessProduction($vv, $totalClData);
+        
+        // 清理临时字段
+        $this->cleanupProcessData($vv);
+    }
+    
+    // 第四步:计算节损奖
+    // 查询产品规格,确定核算单价
+    $guige = \db('物料_存货编码')->where('物料代码', $data['成品代号'])->value('rtrim(规格)');
+    $moneyRate = strpos($guige, '小盒') !== false ? 0.02 : 0.09;  // 小盒0.02元,其他0.09元
+    
+    foreach ($gyData as &$item) {
+        // 节损数量 = 计划损耗 - 实际损耗(质检废+制程废+无形损)
+        $totalWaste = $item['质检废'] + $item['sczl_zcfp'] + ($item['无形损分摊'] > 0 ? $item['无形损分摊'] : 0);
+        $item['节损数量'] = $item['计划损耗'] - $totalWaste;
+        
+        // 节损奖 = 节损数量 * 超节损承担比例 * 核算单价(机检工序无奖励)
+        $item['节损奖'] = strpos($item['sczl_gxmc'], '机检') !== false ? 0 : number_format($item['节损数量'] * $item['超节损承担比例'] * $moneyRate, 4);
+        
+        // 系统年月和核算单价
+        $item['sys_ny'] = date('Ym', strtotime($workOrderData['jjcp_sj']));
+        $item['超节损核算单价'] = $moneyRate;
+    }
+    
+    return $gyData;
+}
 
-        return $result;
-//        halt($result);
-//        \db('工单_质量考核汇总')
-//            ->where('Gy0_gdbh', $param['gdbh'])
-//            ->where('印件及工序', $param['yjno'])
-//            ->delete();
-//        $sql = \db('工单_质量考核汇总')
-//            ->fetchSql(true)
-//            ->insertAll($result);
-//        $res = \db()->query($sql);
+/**
+ * 构建最终的超节损结果数据结构
+ * 
+ * @param array $gyData 工序数据
+ * @param array $data 工单数据
+ * @param int $totalNumber 入仓数量
+ * @param array $workOrderData 入仓数据
+ * @return array 超节损结果数组
+ */
+private function buildResult($gyData, $data, $totalNumber, $workOrderData)
+{
+    $result = [];
+    
+    foreach ($gyData 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'],                 // 班组成员1
+            'sczl_bh2' => $value['sczl_bh2'],                 // 班组成员2
+            'sczl_bh3' => $value['sczl_bh3'],                 // 班组成员3
+            'sczl_bh4' => $value['sczl_bh4'],                 // 班组成员4
+            'sczl_bh5' => $value['sczl_bh5'],                 // 班组成员5
+            'sczl_bh6' => $value['sczl_bh6'],                 // 班组成员6
+            'sczl_bh7' => $value['sczl_bh7'],                 // 班组成员7
+            'sczl_bh8' => $value['sczl_bh8'],                 // 班组成员8
+            'Xm1' => $value['sczl_name1'],                    // 成员姓名1
+            'Xm2' => $value['sczl_name2'],                    // 成员姓名2
+            'Xm3' => $value['sczl_name3'],                    // 成员姓名3
+            'Xm4' => $value['sczl_name4'],                    // 成员姓名4
+            'Xm5' => $value['sczl_name5'],                    // 成员姓名5
+            'Xm6' => $value['sczl_name6'],                    // 成员姓名6
+            'Xm7' => $value['sczl_name7'],                    // 成员姓名7
+            'Xm8' => $value['sczl_name8'],                    // 成员姓名8
+            'sczl_rate1' => $value['sczl_rate1'],             // 成员效率1
+            'sczl_rate2' => $value['sczl_rate2'],             // 成员效率2
+            'sczl_rate3' => $value['sczl_rate3'],             // 成员效率3
+            'sczl_rate4' => $value['sczl_rate4'],             // 成员效率4
+            'sczl_rate5' => $value['sczl_rate5'],             // 成员效率5
+            'sczl_rate6' => $value['sczl_rate6'],             // 成员效率6
+            'sczl_rate7' => $value['sczl_rate7'],             // 成员效率7
+            'sczl_rate8' => $value['sczl_rate8'],             // 成员效率8
+            '类型' => '',                                     // 类型
+            '客户代号' => $value['Gd_客户代号'],                // 客户代号
+            '客户名称' => $value['Gd_客户名称'],                // 客户名称
+            '产品代号' => $value['Gd_cpdh'],                   // 产品代号
+            '产品名称' => $value['Gd_cpmc'],                   // 产品名称
+            '销售订单号' => $value['销售订单号'],                // 销售订单号
+            '订单数量' => $value['订单数量'],                   // 订单数量
+            '计量单位' => $value['计量单位'],                   // 计量单位
+            '实际投料' => $data['实际投料'],                    // 实际投料
+            '入仓数量' => $totalNumber,                       // 入仓数量
+            '入仓日期' => $workOrderData['jjcp_sj'],          // 入仓日期
+            '大箱数' => $value['投料大箱'],                    // 投料大箱数
+            '废品合计' => $data['工单质检废'] + $data['zcfp'], // 废品合计
+            'sys_id' => '',                                   // 系统ID
+            'sys_rq' => date('Y-m-d H:i:s', time()),          // 系统日期
+            '车间名称' => $value['Gy0_SITE']                  // 车间名称
+        ];
     }
+    
+    return $result;
+}
+
+/**
+ * 批量获取员工姓名
+ * 
+ * @param array $employeeIds 员工编号数组
+ * @return array 员工姓名映射表(编号=>姓名)
+ */
+private function getEmployeeNames($employeeIds)
+{
+    if (empty($employeeIds)) return [];
+    
+    return db('人事_基本资料')
+        ->where('员工编号', 'in', $employeeIds)
+        ->column('rtrim(员工姓名)', '员工编号');
+}
 
 
     /**