<?php


namespace app\api\controller;

use app\common\controller\Api;

class CostCalculation extends Api
{

    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];

    // 车间常量
    const WORKSHOP_ROLLER_PRESS = '03、卷凹机组';
    const WORKSHOP_LIST_ALL = ['凹丝印车间', '胶印车间', '印后车间', '检验车间'];

    // 科目名称关键词
    const SUBJECT_WASTE_GAS = '废气处理';
    const SUBJECT_BOILER = '锅炉';
    const SUBJECT_HOT_WATER_BOILER = '热水锅炉';
    const SUBJECT_AIR_COMPRESSOR_A = '空压机A';
    const SUBJECT_AIR_COMPRESSOR_B = '空压机B';
    const SUBJECT_VACUUM_BLOWER_A = '真空鼓风机A';
    const SUBJECT_VACUUM_BLOWER_B = '真空鼓风机B';
    const SUBJECT_CENTRAL_AIR_CONDITIONER_A = '中央空调A';
    const SUBJECT_CENTRAL_AIR_CONDITIONER_B = '中央空调B';
    const SUBJECT_TOTAL_TO_APPORTION = '待分摊总额';

    /**
     * 统一的安全数值获取方法
     * 处理空字符串和null值，转换为0
     */
    protected function getSafeNumericValue($value)
    {
        if ($value === null || $value === '' || $value === false) {
            return 0;
        }
        return floatval($value);
    }

    /**
     * 安全的金额计算
     */
    protected function calculateSafeAmount($quantity, $unitPrice)
    {
        $safeQuantity = $this->getSafeNumericValue($quantity);
        $safeUnitPrice = $this->getSafeNumericValue($unitPrice);
        return $safeQuantity * $safeUnitPrice;
    }

    public function costCalculation()
    {
        if (!$this->request->isGet()) {
            $this->error('请求错误');
        }

        $param = $this->request->param();
        if (empty($param['month'])) {
            $this->error('请选择月份');
        }

        $month = $param['month'];

        // 计算车间水电气分摊（返回统计结果）
        $apportionmentResults = $this->apportionmentOne($month);

        // 格式化最终结果
        $formattedResults = $this->formatFinalResults($apportionmentResults,$month,$param['sys_id']);
        $machine = [];
        foreach ($formattedResults as $formattedResult) {
            $machine[] = $formattedResult['设备编号'];
        }
        $machineList = array_unique($machine);
        $machineWorkOrder = [];
        foreach ($machineList as $machine) {
            $machineWorkOrder[$machine] = $this->getMachineWorkOrder($machine, $month);
        }

        $apportionData = db('成本_各月分摊系数')->where(['Sys_ny' => $month])->select();
        if (!empty($apportionData)) {
            db('成本_各月分摊系数')->where(['Sys_ny' => $month])->delete();
        }
        $apportionSql = db('成本_各月分摊系数')->fetchSql(true)->insertAll($formattedResults);
        $apportionResults = db()->query($apportionSql);

        //查询车间机台色度数
        $machineTotal = $this->getMachineTotal($month);
        $data = [];
        foreach ($machineWorkOrder as $machineCode => $orders) {
            // 检查机台编号是否存在于第二个数组中
            if (!isset($machineTotal[$machineCode])) {
                continue; // 如果机台在分摊数组中不存在，跳过
            }

            $machineRates = $machineTotal[$machineCode]; // 获取该机台的费用单价

            // 遍历该机台下的所有工单
            foreach ($orders as $order) {
                $occupationHours = (float)$order['占用机时']; // 占用机时

                // 创建新记录（基础信息）
                $newRecord = [
                    'sczl_gdbh' => $order['工单编号'],
                    'sczl_yjno' => $order['印件号'],
                    'sczl_gxh' => $order['工序号'],
                    'sczl_jtbh' => $order['机台编号']
                ];

                // 动态添加所有科目分摊金额（基于第二个数组中的科目名称）
                foreach ($machineRates as $subject => $rate) {
                    if ($subject === '待分摊总额') {
                        $subject = '分摊水电';
                    }
                    $newRecord[$subject] = round($occupationHours * $rate, 2);
                    $newRecord['直接水电'] = round($occupationHours * 0.69, 2);
                }

                $data[] = $newRecord;
            }
        }
        $i = 0;
        foreach ($data as $item) {
            $gdbh = $item['sczl_gdbh'];
            $yjno = $item['sczl_yjno'];
            $gxh = $item['sczl_gxh'];
            $jtbh = $item['sczl_jtbh'];
            unset($item['sczl_gdbh'], $item['sczl_yjno'], $item['sczl_gxh'], $item['sczl_jtbh']);
            $sql = db('成本v23_月度成本明细')
                ->where([
                    'sys_ny' => $month,
                    'sczl_gdbh' => $gdbh,
                    'sczl_yjno' => $yjno,
                    'sczl_gxh' => $gxh,
                    'sczl_jtbh' => $jtbh,
                ])
                ->fetchSql(true)
                ->update($item);
            $res = db()->query($sql);
            if ($res === false) {
                $i++;
            }
        }
        if ($i > 0) {
            $this->error('失败');
        }

    }


    /**
     * 计算水电气分摊费用（优化版）
     */
    protected function apportionmentOne($month)
    {
        $utilityList = db('成本_各月水电气')
            ->where('Sys_ny', $month)
            ->whereLike('费用类型', '%分摊%')
            ->select();

        if (empty($utilityList)) {
            return [];
        }

        // 初始化统计数据结构
        $machineSummary = [];        // 按机台统计
        $subjectSummary = [];        // 按科目统计
        $workshopSummary = [];       // 按车间统计
        $apportionmentResults = [];  // 原始分摊结果
        $allMachineData = [];        // 所有机台数据

        // 先处理所有分摊项目
        foreach ($utilityList as $item) {
            // 确保数值安全
            $item['耗电量'] = $this->getSafeNumericValue($item['耗电量']);
            $item['单位电价'] = $this->getSafeNumericValue($item['单位电价']);
            $item['耗气量'] = $this->getSafeNumericValue($item['耗气量']);
            $item['单位气价'] = $this->getSafeNumericValue($item['单位气价']);

            $result = $this->processUtilityItem($item, $month);
            if ($result) {
                $apportionmentResults[] = $result;

                // 合并所有机台数据
                $this->mergeMachineData($result['data'], $allMachineData, $item['科目名称']);
            }
        }

        // 按机台+科目进行汇总统计
        $this->summarizeByMachineAndSubject($allMachineData, $machineSummary, $subjectSummary, $workshopSummary);

        // 对统计结果进行排序
        ksort($machineSummary);
        return $machineSummary;
    }

    /**
     * 合并所有机台数据
     */
    protected function mergeMachineData($machineData, &$allMachineData, $subjectName)
    {
        if (empty($machineData)) {
            return;
        }

        foreach ($machineData as $machine) {
            $machineId = $machine['机台编号'] ?? '';
            $workshop = $machine['车间名称'] ?? '未知车间';
            $workOrder = $machine['工单编号'] ?? '';
            $processNo = $machine['工序号'] ?? '';
            $printNo = $machine['印件号'] ?? '';
            $machineTime = floatval($machine['占用机时'] ?? 0);
            $uniqid = $machine['Uniqid'] ?? '';

            if (empty($machineId)) {
                continue;
            }

            // 初始化机台数据
            if (!isset($allMachineData[$machineId])) {
                $allMachineData[$machineId] = [
                    '机台编号' => $machineId,
                    '车间名称' => $workshop,
                    '占用机时' => $machineTime,
                    '工单编号' => $workOrder,
                    '工序号' => $processNo,
                    '印件号' => $printNo,
                    'Uniqid' => $uniqid,
                    '科目明细' => [],
                    '工单列表' => [],
                    '科目总计' => 0
                ];
            }

            // 更新机台基础信息（如果有更完整的信息）
            if (empty($allMachineData[$machineId]['工单编号']) && !empty($workOrder)) {
                $allMachineData[$machineId]['工单编号'] = $workOrder;
            }
            if (empty($allMachineData[$machineId]['工序号']) && !empty($processNo)) {
                $allMachineData[$machineId]['工序号'] = $processNo;
            }
            if (empty($allMachineData[$machineId]['印件号']) && !empty($printNo)) {
                $allMachineData[$machineId]['印件号'] = $printNo;
            }

            // 记录工单（去重）
            if (!empty($workOrder) && !in_array($workOrder, $allMachineData[$machineId]['工单列表'])) {
                $allMachineData[$machineId]['工单列表'][] = $workOrder;
            }

            // 合并科目金额
            $apportionmentTypes = ['分摊水电', '废气处理', '锅炉', '热水锅炉',
                '空压机A', '空压机B', '真空鼓风机A', '真空鼓风机B',
                '中央空调A', '中央空调B'];

            $machineTotal = 0;
            foreach ($apportionmentTypes as $type) {
                if (isset($machine[$type]) && floatval($machine[$type]) > 0) {
                    $amount = floatval($machine[$type]);
                    $machineTotal += $amount;

                    // 初始化科目明细
                    if (!isset($allMachineData[$machineId]['科目明细'][$type])) {
                        $allMachineData[$machineId]['科目明细'][$type] = [
                            'subject_name' => $type,
                            'total_amount' => 0,
                            'source_count' => 0,
                            'source_subjects' => ''
                        ];
                    }

                    // 累加金额
                    $allMachineData[$machineId]['科目明细'][$type]['total_amount'] += $amount;
                    $allMachineData[$machineId]['科目明细'][$type]['source_count']++;

                    // 记录来源科目
                    $allMachineData[$machineId]['科目明细'][$type]['source_subjects'] = $subjectName;

                }
            }

            // 更新机台总计
            $allMachineData[$machineId]['科目总计'] += $machineTotal;
        }
    }

    /**
     * 按机台+科目进行汇总统计
     */
    protected function summarizeByMachineAndSubject($allMachineData, &$machineSummary, &$subjectSummary, &$workshopSummary)
    {
        foreach ($allMachineData as $machineId => $machineInfo) {
            $workshop = $machineInfo['车间名称'];

            // 1. 按机台统计
            $machineSummary[$machineId] = [
                '机台编号' => $machineId,
                '车间名称' => $workshop,
                '工单数量' => count($machineInfo['工单列表']),
                '占用机时' => $machineInfo['占用机时'],
                '科目总计' => round($machineInfo['科目总计'], 2),
                '科目明细' => [],
                '工单列表' => $machineInfo['工单列表']
            ];

            // 处理科目明细
            foreach ($machineInfo['科目明细'] as $subjectType => $subjectDetail) {
                $amount = round($subjectDetail['total_amount'], 2);
                $machineSummary[$machineId]['科目明细'][$subjectType] = [
                    'amount' => $amount,
                    'source_count' => $subjectDetail['source_count'],
                    'source_subjects' => $subjectDetail['source_subjects'],
                    'percentage' => $machineInfo['科目总计'] > 0
                        ? round(($subjectDetail['total_amount'] / $machineInfo['科目总计']) * 100, 2)
                        : 0
                ];
            }

            // 2. 按科目统计
            foreach ($machineInfo['科目明细'] as $subjectType => $subjectDetail) {
                $amount = round($subjectDetail['total_amount'], 2);

                // 初始化科目统计
                if (!isset($subjectSummary[$subjectType])) {
                    $subjectSummary[$subjectType] = [
                        'subject_name' => $subjectType,
                        'total_amount' => 0,
                        'machine_count' => 0,
                        'workshop_distribution' => [],
                        'machine_list' => []
                    ];
                }

                // 累加科目总计
                $subjectSummary[$subjectType]['total_amount'] += $subjectDetail['total_amount'];
                $subjectSummary[$subjectType]['machine_count']++;

                // 按车间分布
                if (!isset($subjectSummary[$subjectType]['workshop_distribution'][$workshop])) {
                    $subjectSummary[$subjectType]['workshop_distribution'][$workshop] = 0;
                }
                $subjectSummary[$subjectType]['workshop_distribution'][$workshop] += $subjectDetail['total_amount'];

                // 机台列表
                $subjectSummary[$subjectType]['machine_list'][] = [
                    'machine_id' => $machineId,
                    'workshop' => $workshop,
                    'amount' => $amount,
                    'percentage' => $subjectSummary[$subjectType]['total_amount'] > 0
                        ? round(($subjectDetail['total_amount'] / $subjectSummary[$subjectType]['total_amount']) * 100, 2)
                        : 0
                ];
            }

            // 3. 按车间统计
            if (!isset($workshopSummary[$workshop])) {
                $workshopSummary[$workshop] = [
                    'workshop_name' => $workshop,
                    'machine_count' => 0,
                    'total_amount' => 0,
                    'subject_distribution' => [],
                    'machine_list' => []
                ];
            }

            $workshopSummary[$workshop]['machine_count']++;
            $workshopSummary[$workshop]['total_amount'] += $machineInfo['科目总计'];

            // 车间内科目分布
            foreach ($machineInfo['科目明细'] as $subjectType => $subjectDetail) {
                if (!isset($workshopSummary[$workshop]['subject_distribution'][$subjectType])) {
                    $workshopSummary[$workshop]['subject_distribution'][$subjectType] = 0;
                }
                $workshopSummary[$workshop]['subject_distribution'][$subjectType] += $subjectDetail['total_amount'];
            }

            // 车间内机台列表
            $workshopSummary[$workshop]['machine_list'][] = [
                'machine_id' => $machineId,
                'total_amount' => round($machineInfo['科目总计'], 2),
                'subject_count' => count($machineInfo['科目明细']),
                'work_order_count' => count($machineInfo['工单列表'])
            ];
        }

        // 对科目统计进行后处理
        $this->processSubjectSummary($subjectSummary);

        // 对车间统计进行后处理
        $this->processWorkshopSummary($workshopSummary);
    }


    /**
     * 处理科目统计
     */
    protected function processSubjectSummary(&$subjectSummary)
    {
        foreach ($subjectSummary as &$subject) {
            // 金额四舍五入
            $subject['total_amount'] = round($subject['total_amount'], 2);

            // 车间分布百分比
            foreach ($subject['workshop_distribution'] as $workshop => &$amount) {
                $amount = round($amount, 2);
            }

            // 按金额排序机台列表
            usort($subject['machine_list'], function($a, $b) {
                return $b['amount'] <=> $a['amount'];
            });

            // 计算机台平均金额
            $subject['avg_per_machine'] = $subject['machine_count'] > 0
                ? round($subject['total_amount'] / $subject['machine_count'], 2)
                : 0;
        }
    }

    /**
     * 处理车间统计
     */
    protected function processWorkshopSummary(&$workshopSummary)
    {
        foreach ($workshopSummary as &$workshop) {
            // 金额四舍五入
            $workshop['total_amount'] = round($workshop['total_amount'], 2);

            // 科目分布百分比
            $workshop['subject_percentage'] = [];
            foreach ($workshop['subject_distribution'] as $subjectType => $amount) {
                $roundedAmount = round($amount, 2);
                $workshop['subject_distribution'][$subjectType] = $roundedAmount;

                if ($workshop['total_amount'] > 0) {
                    $workshop['subject_percentage'][$subjectType] =
                        round(($roundedAmount / $workshop['total_amount']) * 100, 2);
                }
            }

            // 按金额排序机台列表
            usort($workshop['machine_list'], function($a, $b) {
                return $b['total_amount'] <=> $a['total_amount'];
            });

            // 计算机台平均金额
            $workshop['avg_per_machine'] = $workshop['machine_count'] > 0
                ? round($workshop['total_amount'] / $workshop['machine_count'], 2)
                : 0;

            // 统计科目种类数
            $workshop['subject_count'] = count($workshop['subject_distribution']);
        }
    }

    /**
     * 处理单个水电费用项
     */
    protected function processUtilityItem($item, $month)
    {
        $subjectName = $item['科目名称'];

        // 使用switch-like结构提高可读性
        $processMap = [
            self::SUBJECT_TOTAL_TO_APPORTION => 'processTotalApportionment',
            self::SUBJECT_WASTE_GAS => 'processWasteGas',
            self::SUBJECT_BOILER => 'processBoiler',
            self::SUBJECT_AIR_COMPRESSOR_A => 'processAirCompressorA',
            self::SUBJECT_AIR_COMPRESSOR_B => 'processAirCompressorB',
            self::SUBJECT_VACUUM_BLOWER_A => 'processVacuumBlowerA',
            self::SUBJECT_VACUUM_BLOWER_B => 'processVacuumBlowerB',
            self::SUBJECT_CENTRAL_AIR_CONDITIONER_A => 'processCentralAirConditionerA',
            self::SUBJECT_CENTRAL_AIR_CONDITIONER_B => 'processCentralAirConditionerB',
            self::SUBJECT_HOT_WATER_BOILER => 'processHotWaterBoiler',
        ];

        // 检查是否完全匹配
        if (isset($processMap[$subjectName])) {
            $method = $processMap[$subjectName];
            return $this->$method($item, $month);
        }

        // 检查是否包含关键词
        foreach ($processMap as $keyword => $method) {
            if (strpos($subjectName, $keyword) !== false) {
                // 特殊处理：如果包含"锅炉"但不包含"热水锅炉"
                if ($keyword === self::SUBJECT_BOILER && strpos($subjectName, self::SUBJECT_HOT_WATER_BOILER) !== false) {
                    continue;
                }
                return $this->$method($item, $month);
            }
        }

        return null;
    }

    /**
     * 处理待分摊总额
     */
    protected function processTotalApportionment($item, $month)
    {
        $money = $this->calculateSafeAmount($item['耗电量'], $item['单位电价']);
        $data = $this->getMachineTime($item['部门名称'], $month);

        foreach ($data['machine'] as &$machine) {
            $machine['分摊水电'] = $this->calculateApportionment($money, $machine['占用机时'], $data['sist']);
        }

        return [
            'type' => 'total_apportionment',
            'data' => $data['machine']
        ];
    }

    /**
     * 处理废气处理
     */
    protected function processWasteGas($item, $month)
    {
        $electricityMoney = $this->calculateSafeAmount($item['耗电量'], $item['单位电价']);
        $gasMoney = $this->calculateSafeAmount($item['耗气量'], $item['单位气价']);
        $data = $this->getMachineTime(self::WORKSHOP_ROLLER_PRESS, $month);

        foreach ($data['machine'] as &$machine) {
            $machine['分摊水电'] = $this->calculateApportionment($electricityMoney, $machine['占用机时'], $data['sist']);
            $machine['废气处理'] = $this->calculateApportionment($gasMoney, $machine['占用机时'], $data['sist']);
        }

        return [
            'type' => 'waste_gas',
            'data' => $data['machine']
        ];
    }

    /**
     * 处理锅炉
     */
    protected function processBoiler($item, $month)
    {
        $electricityMoney = $this->calculateSafeAmount($item['耗电量'], $item['单位电价']);
        $gasMoney = $this->calculateSafeAmount($item['耗气量'], $item['单位气价']);
        $data = $this->getMachineTime(self::WORKSHOP_ROLLER_PRESS, $month);

        foreach ($data['machine'] as &$machine) {
            $machine['分摊水电'] = $this->calculateApportionment($electricityMoney, $machine['占用机时'], $data['sist']);
            $machine['锅炉'] = $this->calculateApportionment($gasMoney, $machine['占用机时'], $data['sist']);
        }

        return [
            'type' => 'boiler',
            'data' => $data['machine']
        ];
    }

    /**
     * 处理空压机A
     */
    protected function processAirCompressorA($item, $month)
    {
        return $this->processGeneralElectricEquipment($item, $month, self::SUBJECT_AIR_COMPRESSOR_A);
    }

    /**
     * 处理空压机B
     */
    protected function processAirCompressorB($item, $month)
    {
        return $this->processGeneralElectricEquipment($item, $month, self::SUBJECT_AIR_COMPRESSOR_B);
    }

    /**
     * 处理真空鼓风机A
     */
    protected function processVacuumBlowerA($item, $month)
    {
        return $this->processGeneralElectricEquipment($item, $month, self::SUBJECT_VACUUM_BLOWER_A);
    }

    /**
     * 处理真空鼓风机B
     */
    protected function processVacuumBlowerB($item, $month)
    {
        return $this->processGeneralElectricEquipment($item, $month, self::SUBJECT_VACUUM_BLOWER_B);
    }

    /**
     * 处理中央空调A
     */
    protected function processCentralAirConditionerA($item, $month)
    {
        return $this->processGeneralElectricEquipment($item, $month, self::SUBJECT_CENTRAL_AIR_CONDITIONER_A);
    }

    /**
     * 处理中央空调B
     */
    protected function processCentralAirConditionerB($item, $month)
    {
        return $this->processGeneralElectricEquipment($item, $month, self::SUBJECT_CENTRAL_AIR_CONDITIONER_B);
    }

    /**
     * 处理热水锅炉
     */
    protected function processHotWaterBoiler($item, $month)
    {
        return $this->processGeneralElectricEquipment($item, $month, '热水锅炉');
    }

    /**
     * 通用电气设备处理（适用于所有车间）
     */
    protected function processGeneralElectricEquipment($item, $month, $equipmentType)
    {
        $money = $this->calculateSafeAmount($item['耗电量'], $item['单位电价']);
        $data = $this->getMachineTime(self::WORKSHOP_LIST_ALL, $month);

        foreach ($data['machine'] as &$machine) {
            $machine[$equipmentType] = $this->calculateApportionment($money, $machine['占用机时'], $data['sist']);
        }

        return [
            'type' => $equipmentType,
            'data' => $data['machine']
        ];
    }

    /**
     * 计算分摊金额
     */
    protected function calculateApportionment($totalAmount, $machineTime, $totalTime)
    {
        if ($totalTime <= 0) {
            return 0;
        }
        return round($totalAmount * ($machineTime / $totalTime), 2);
    }

    /**
     * 查询车间机台通电机时数据（优化版）
     */
    protected function getMachineTime($workshop, $month)
    {
        $where = [
            'a.sys_ny' => $month,
            'b.sys_sbID' => ['<>','']
        ];

        // 构建车间查询条件
        if (is_array($workshop)) {
            $where['a.车间名称'] = ['in', $workshop];
        } else {
            if (strpos($workshop, '机组') !== false) {
                $where['b.设备编组'] = $workshop;
            } elseif (strpos($workshop, '车间') !== false) {
                $where['a.车间名称'] = $workshop;
            }
        }

        // 查询机台数据
        $machine = db('成本v23_月度成本明细')
            ->alias('a')
            ->join('设备_基本资料 b', 'a.sczl_jtbh = b.设备编号', 'left')
            ->field('rtrim(车间名称) as 车间名称,a.sczl_gdbh as 工单编号,a.sczl_yjno as 印件号,a.sczl_gxh as 工序号,a.sczl_jtbh as 机台编号,a.占用机时,a.Uniqid')
            ->where($where)
            ->select();

        // 查询总时长
        $totalTime = db('成本v23_月度成本明细')
            ->alias('a')
            ->join('设备_基本资料 b', 'a.sczl_jtbh = b.设备编号', 'left')
            ->where($where)
            ->value('sum(a.占用机时) as 占用机时', 0);

        return [
            'machine' => $machine,
            'sist' => $totalTime
        ];
    }


    /**
     * 统计分摊结果
     */
    protected function summarizeApportionment($result, $department, $subject,
                                              &$summaryByDepartment, &$summaryBySubject,
                                              &$summaryByDepartmentSubject)
    {
        $resultType = $result['type'];
        $machineData = $result['data'];

        if (empty($machineData)) {
            return;
        }

        // 清洗部门名称
        $cleanDepartment = trim($department);
        $cleanSubject = trim($subject);

        // 初始化统计键
        if (!isset($summaryByDepartment[$cleanDepartment])) {
            $summaryByDepartment[$cleanDepartment] = [];
        }
        if (!isset($summaryBySubject[$resultType])) {
            $summaryBySubject[$resultType] = [];
        }
        if (!isset($summaryByDepartmentSubject[$cleanDepartment])) {
            $summaryByDepartmentSubject[$cleanDepartment] = [];
        }
        if (!isset($summaryByDepartmentSubject[$cleanDepartment][$resultType])) {
            $summaryByDepartmentSubject[$cleanDepartment][$resultType] = [
                'department' => $cleanDepartment,
                'subject' => $cleanSubject,
                'result_type' => $resultType,
                'total_amount' => 0,
                'machine_count' => 0,
                'work_order_count' => 0
            ];
        }

        // 按车间和机台统计
        foreach ($machineData as $machine) {
            // 获取车间名称（已使用rtrim清洗过）
            $workshop = isset($machine['车间名称']) ? $machine['车间名称'] : '未知车间';

            // 统计按部门
            if (!isset($summaryByDepartment[$cleanDepartment][$workshop])) {
                $summaryByDepartment[$cleanDepartment][$workshop] = [
                    'total_amount' => 0,
                    'machine_count' => 0,
                    'subjects' => []
                ];
            }

            // 统计按科目
            if (!isset($summaryBySubject[$resultType][$workshop])) {
                $summaryBySubject[$resultType][$workshop] = [
                    'total_amount' => 0,
                    'machine_count' => 0,
                    'departments' => []
                ];
            }

            // 计算此机台的总分摊金额
            $machineTotal = 0;
            $apportionmentTypes = ['分摊水电', '废气处理', '锅炉', '热水锅炉',
                '空压机A', '空压机B', '真空鼓风机A', '真空鼓风机B',
                '中央空调A', '中央空调B'];

            foreach ($apportionmentTypes as $type) {
                if (isset($machine[$type])) {
                    $amount = floatval($machine[$type]);
                    $machineTotal += $amount;

                    // 按部门+车间统计各科目金额
                    if (!isset($summaryByDepartment[$cleanDepartment][$workshop]['subjects'][$type])) {
                        $summaryByDepartment[$cleanDepartment][$workshop]['subjects'][$type] = 0;
                    }
                    $summaryByDepartment[$cleanDepartment][$workshop]['subjects'][$type] += $amount;

                    // 按科目+车间统计各部门金额
                    if (!in_array($cleanDepartment, $summaryBySubject[$resultType][$workshop]['departments'])) {
                        $summaryBySubject[$resultType][$workshop]['departments'][] = $cleanDepartment;
                    }
                }
            }

            // 更新统计信息
            if ($machineTotal > 0) {
                $summaryByDepartment[$cleanDepartment][$workshop]['total_amount'] += $machineTotal;
                $summaryByDepartment[$cleanDepartment][$workshop]['machine_count']++;

                $summaryBySubject[$resultType][$workshop]['total_amount'] += $machineTotal;
                $summaryBySubject[$resultType][$workshop]['machine_count']++;

                $summaryByDepartmentSubject[$cleanDepartment][$resultType]['total_amount'] += $machineTotal;
                $summaryByDepartmentSubject[$cleanDepartment][$resultType]['machine_count']++;

                // 统计工单数（去重）
                if (!isset($summaryByDepartmentSubject[$cleanDepartment][$resultType]['work_orders'])) {
                    $summaryByDepartmentSubject[$cleanDepartment][$resultType]['work_orders'] = [];
                }
                if (isset($machine['工单编号'])) {
                    $summaryByDepartmentSubject[$cleanDepartment][$resultType]['work_orders'][] = $machine['工单编号'];
                }
            }
        }

        // 计算工单数（去重）
        foreach ($summaryByDepartmentSubject[$cleanDepartment] as $type => &$data) {
            if (isset($data['work_orders'])) {
                $data['work_order_count'] = count(array_unique($data['work_orders']));
                unset($data['work_orders']);
            }
        }

        // 为部门统计添加汇总信息
        $this->addSummaryToDepartment($summaryByDepartment[$cleanDepartment]);

        // 为科目统计添加汇总信息
        $this->addSummaryToSubject($summaryBySubject[$resultType]);
    }


    /**
     * 为部门统计添加汇总信息
     */
    protected function addSummaryToDepartment(&$departmentData)
    {
        $totalAmount = 0;
        $totalMachines = 0;

        foreach ($departmentData as $workshop => $data) {
            if ($workshop === 'summary') continue;

            $totalAmount += $data['total_amount'];
            $totalMachines += $data['machine_count'];
        }

        $departmentData['summary'] = [
            'total_amount' => round($totalAmount, 2),
            'total_machines' => $totalMachines,
            'workshop_count' => count($departmentData) - 1
        ];
    }

    /**
     * 为科目统计添加汇总信息
     */
    protected function addSummaryToSubject(&$subjectData)
    {
        $totalAmount = 0;
        $totalMachines = 0;
        $allDepartments = [];

        foreach ($subjectData as $workshop => $data) {
            if ($workshop === 'summary') continue;

            $totalAmount += $data['total_amount'];
            $totalMachines += $data['machine_count'];
            $allDepartments = array_merge($allDepartments, $data['departments']);
        }

        $subjectData['summary'] = [
            'total_amount' => round($totalAmount, 2),
            'total_machines' => $totalMachines,
            'workshop_count' => count($subjectData) - 1,
            'department_count' => count(array_unique($allDepartments))
        ];
    }


    /**
     * 格式化最终统计结果
     */
    protected function formatFinalResults($apportionmentResults,$month,$sys)
    {
        $data = [];
        foreach ($apportionmentResults as $key => $value) {
            foreach ($value['科目明细'] as $item) {
                $data[] = [
                    'Sys_ny' => $month,
                    '科目名称' => $item['source_subjects'],
                    '设备编号' => $key,
                    '分摊系数' => 1,
                    '分摊金额' => $item['amount'],
                    'Sys_id' => $sys,
                    'Sys_rq' => date('Y-m-d H:i:s',time()),
                ];
            }
        }
        return $data;
    }

    /**
     * 获取车间机台生产工单
     * @param $sist
     * @param $month
     * @return bool|\PDOStatement|string|\think\Collection
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    protected function getMachineWorkOrder($machine,$month)
    {
        $list = db('成本v23_月度成本明细')
            ->where([
                'sys_ny' => $month,
                'sczl_jtbh' => $machine,
                ])
            ->field([
                'sczl_gdbh' => '工单编号',
                'sczl_yjno' => '印件号',
                'sczl_gxh' => '工序号',
                'sczl_jtbh' => '机台编号',
                '占用机时',
                ])
            ->group('工单编号,印件号,工序号')
            ->select();
        return $list;
    }

    /**
     * 查询车间机台色度数
     * @param $month
     * @return bool|\PDOStatement|string|\think\Collection
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    protected function getMachineTotal($month)
    {
        $list = db('成本_各月分摊系数')
            ->alias('a')
            ->join('成本v23_月度成本明细 b', 'b.sys_ny = a.Sys_ny and b.sczl_jtbh = a.设备编号','LEFT')
            ->where([
                'a.Sys_ny' => $month,
                'b.车间名称' => ['in', self::WORKSHOP_LIST_ALL],
                ])
            ->field([
                'b.sczl_jtbh' => '机台编号',
                'sum(b.占用机时)' => '占用机时',
                'a.分摊金额',
                'a.科目名称',
            ])
            ->group('机台编号,a.科目名称')
            ->select();
        foreach ($list as $key => $item) {
            $list[$key]['金额'] = round($item['分摊金额']/$item['占用机时'], 2);
        }
        $data = [];
        foreach ($list as $item) {
            $machineCode = $item['机台编号'];
            $subjectName = explode('(',$item['科目名称']);
            $amount = $item['金额'];

            // 如果这个机台编号还没有在结果数组中，初始化它
            if (!isset($data[$machineCode])) {
                $data[$machineCode] = [];
            }

            // 将科目名称和金额添加到对应的机台编号下
            $data[$machineCode][$subjectName[0]] = $amount;
        }
        return $data;
    }

}