drb/app/Service/U8ThirtyPartyDatabaseServerService.php

<?php
namespace App\Service;

use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

class U8ThirtyPartyDatabaseServerService extends Service
{
    protected $connectionName = 'u8_third_sqlserver';

    // Service 内部查询
    public function getPendingBills($config, $lastId)
    {
        try {

            $mainTable = $config['main'];
            $detailTable = $config['detail'];
            $mainKey = $config['main_key'];
            $foreignKey = $config['key'];
            $whereRaw = $config['whereRaw'];
            $main_field = $config['main_field'];
            $son_field = $config['son_field'];
            $limit = $config['limit'];

            // 1. 获取主表
            $mainRows = DB::connection($this->connectionName)
                ->table($mainTable)
                ->lock('WITH(NOLOCK)')
                ->where($mainKey, '>', $lastId) // 改用 ID
                ->whereRaw($whereRaw)
                ->select($main_field)
                ->orderBy($mainKey, 'ASC') // 按 ID 排序保证分页连续
                ->limit($limit)
                ->get();

            if ($mainRows->isEmpty()) return [true, []];
            if (empty($foreignKey) || empty($son_field)) {
                $array = $mainRows->map(function ($item) {
                    return (array) $item;
                })->toArray();
                return [true, $array];
            }

            // 2. 批量获取子表
            $mainIds = $mainRows->pluck('id')->toArray();
//            $details = DB::connection($this->connectionName)
//                ->table($detailTable . ' as detail') // 给子表起别名
//                ->leftJoin('Inventory as inv', 'detail.cInvCode', '=', 'inv.cInvCode') // 关联存货表
//                ->lock('WITH(NOLOCK)')
//                ->whereIn('detail.' . $foreignKey, $mainIds) // 注意这里要指定表别名
//                ->select($son_field) // 这里会读取你配置里的新字段
//                ->get()
//                ->groupBy('id');
            $details = DB::connection($this->connectionName)
                ->table($detailTable. ' as detail')
                ->lock('WITH(NOLOCK)')
                ->whereIn($foreignKey, $mainIds)
                ->select($son_field)
                ->addSelect(DB::raw("ROW_NUMBER() OVER(PARTITION BY detail.{$foreignKey} ORDER BY detail.AutoID) as lineNum"))
                ->get()
                ->groupBy('id');

            // 3. 组合
            $result = $mainRows->map(function($main) use ($details, $foreignKey) {
                $res = (array)$main;
                $mainId = $res['id'];
                $res['details'] = isset($details[$mainId])
                    ? $details[$mainId]->map(function($item) {
                        return (array)$item; // 强制把子表对象转成数组
                    })->values()->toArray()
                    : [];
                return $res;
            })->toArray();

            return [true, $result];

        } catch (\Throwable $e) {
            Log::channel('apiLog')->info('查询失败', [
                "error"    => $e->getMessage(),
            ]);
            return [false, $e->getMessage()];
        }
    }

    public function getBillSingle($config, $id)
    {
        try {
            $mainTable = $config['main'];
            $detailTable = $config['detail'];
            $mainKey = $config['main_key']; // 比如 ID
            $foreignKey = $config['key'];   // 比如 id (子表关联主表的字段)
            $main_field = $config['main_field'];
            $son_field = $config['son_field'];

            // 1. 获取主表单条记录
            $mainRow = DB::connection($this->connectionName)
                ->table($mainTable)
                ->lock('WITH(NOLOCK)')
                ->where($mainKey, $id) // 精确匹配单据 ID
                ->select($main_field)
                ->first();

            if (!$mainRow) {
                return [false, "单据 ID:{$id} 未找到数据"];
            }

            $result = (array)$mainRow;

            // 2. 如果不需要子表，直接返回
            if (empty($foreignKey) || empty($son_field)) {
                return [true, $result];
            }

            // 3. 获取该单据对应的子表详情
            // 注意：U8 子表通常用 id 关联主表的 ID，这里使用配置中的 $foreignKey
            $details = DB::connection($this->connectionName)
                ->table($detailTable . ' as detail')
                ->lock('WITH(NOLOCK)')
                ->where($foreignKey, $id)
                ->select($son_field)
                // 自动生成行号，按 AutoID 排序
//                ->addSelect(DB::raw("ROW_NUMBER() OVER(ORDER BY detail.AutoID) as lineNum"))
                ->orderBy('detail.AutoID', 'ASC')
                ->get();

            // 4. 组合数据
            $result['details'] = $details->map(function ($item) {
                return (array)$item;
            })->toArray();

            return [true, $result];

        } catch (\Throwable $e) {
            Log::channel('apiLog')->info('查询单个单据失败', [
                "id"    => $id,
                "error" => $e->getMessage(),
            ]);
            return [false, $e->getMessage()];
        }
    }

    public function getArrivalVouchById($orderId)
    {
        // 1. 获取主表 (PU_ArrivalVouch) 并关联 采购类型表 (PurchaseType)
        $main = DB::connection($this->connectionName)
            ->table('PU_ArrivalVouch as main')
            ->leftJoin('PurchaseType as pt', 'main.cPTCode', '=', 'pt.cPTCode') // 关联采购类型表
            ->lock('WITH(NOLOCK)')
            ->where('main.ID', $orderId)
            ->select([
                'main.ID as id',
                'main.cCode as no',
                'main.cVenCode as supply_code',
                'main.cDepCode as depart_code',
                'main.dDate as order_date',
                'main.cBusType as b_type',
                'main.cPTCode as cg_type',
                'pt.cRdCode as rd_code'
            ])
            ->first();

        if (!$main) return [];

        $order = (array)$main;

        // 2. 获取子表 (PU_ArrivalVouchs)
        $details = DB::connection($this->connectionName)
            ->table('PU_ArrivalVouchs as detail')
            ->lock('WITH(NOLOCK)')
            ->where('ID', $orderId) // 子表里的 ID 关联主表的 ID
            ->select([
                'detail.cInvCode',
                'detail.iQuantity',
                'detail.iQuantity as iNNum',
                'detail.iinvexchrate',
                'detail.cBatch',
                'detail.dPDate',
                'detail.dVDate',
                'detail.Autoid as iArrsId',
                'detail.ivouchrowno as iRowNo',
                'detail.iOriTaxCost',
                'detail.iTaxRate',
//                    'detail.cordercode',
                'detail.cWhCode',
            ])
            ->orderBy('detail.ivouchrowno', 'ASC') // 按 U8 原始行号排序
            ->get();

        // 3. 组合数据并返回
        $order['details'] = $details->map(function ($item) {
            return (array)$item;
        })->toArray();

        return $order;
    }

    /**
     * 获取存货档案（带分类名称）
     * @param array $config 配置项
     * @param mixed $lastId 上次分页的标识（这里用存货编码 cInvCode 或 自动增量标识）
     * @return array [bool, items]
     */
    public function getInventoryData1($config, $lastId = null)
    {
        try {
            $query = DB::connection('u8_third_sqlserver')
                ->table('Inventory as main')
                ->leftJoin('InventoryClass as sub', 'main.cInvCCode', '=', 'sub.cInvCCode')
                ->select([
                    'main.cInvCode as product_code',
                    'main.cInvName as product_name',
                    'main.cInvStd as product_size',
                    'main.cInvCCode as product_category_code',
                    'sub.cInvCName as product_category_name', // 直接联查分类名
                    'main.cComUnitCode as product_unit',
                    'main.fOutExcess as out_limit',
                    'main.cCurrencyName as common_name',
                    'main.fGrossW as grossWeight',
                    'main.dModifyDate as upd_time'
                ]);

            // 分页逻辑
            if ($lastId) {
                $query->where('main.cInvCode', '>', $lastId);
            }

            // 基础过滤条件
            if (!empty($config['whereRaw'])) {
                $query->whereRaw($config['whereRaw']);
            }

            $items = $query->orderBy('main.cInvCode', 'asc')
                ->limit($config['limit'])
                ->get();

            // 将 Collection 转为数组方便后续处理
            $items = json_decode(json_encode($items), true);

            return [true, $items];
        } catch (\Exception $e) {
            Log::channel('apiLog')->error("U8获取存货异常: " . $e->getMessage());
            return [false, []];
        }
    }

    public function getInventoryData($config, $lastCode = null)
    {
        try {
            $query = DB::connection('u8_third_sqlserver')
                ->table('Inventory as main')
                ->leftJoin('InventoryClass as sub', 'main.cInvCCode', '=', 'sub.cInvCCode')
                ->leftJoin('ComputationUnit as unit', 'main.cComUnitCode', '=', 'unit.cComUnitCode')
                ->select([
                    'main.cInvCode as product_code',
                    'main.cInvName as product_name',
                    'main.cInvStd as product_size',
                    'main.cInvCCode as product_category_code',
                    'sub.cInvCName as product_category_name', // 直接联查分类名
                    'main.cComUnitCode as product_unit',
                    'unit.cComUnitName as product_unit_title',
//                    'main.fOutExcess as out_limit',
//                    'main.cCurrencyName as common_name',
                    'main.fGrossW as grossWeight',
                    // 关键点：将二进制 ufts 转换为 0x... 字符串
                    DB::raw("master.sys.fn_varbintohexstr(main.pubufts) as ufts_str")
                ]);

            // 使用 product_code 做分页依据
            if ($lastCode) {
                $query->where('main.cInvCode', '>', $lastCode);
            }

            if (!empty($config['whereRaw'])) {
                $query->whereRaw($config['whereRaw']);
            }

            // 必须按编码排序，保证分页不重不漏
            $items = $query->orderBy('main.cInvCode', 'asc')
                ->limit($config['limit'])
                ->get();

            return [true, json_decode(json_encode($items), true)];
        } catch (\Exception $e) {
            Log::channel('apiLog')->error("U8获取存货异常: " . $e->getMessage());
            return [false, []];
        }
    }

    //获取单个产品报检单的明细
    public function getBjOrder($id){
        return DB::connection($this->connectionName)
            ->table('QMINSPECTVOUCHERS as detail')
            ->lock('WITH(NOLOCK)')
            ->where('detail.ID', $id)
            ->select('detail.*')
            ->get()
            ->map(function ($value) {
                return (array)$value;
            })
            ->keyBy('CINVCODE')
            ->toArray();
    }

    /**
     * 更新报检单明细
     * @param array $update [AutoID => [字段名 => 值], ...]
     * @param array $insert [[字段名 => 值], [字段名 => 值], ...]
     */
    public function updateBjOrder($update, $insert)
    {
        try {
            return DB::connection($this->connectionName)->transaction(function () use ($update, $insert) {

                // 1. 处理更新部分
                if (!empty($update)) {
                    foreach ($update as $autoId => $fields) {
                        DB::connection($this->connectionName)
                            ->table('QMINSPECTVOUCHERS')
                            ->where('AUTOID', $autoId)
                            ->update($fields);
                    }
                }

                // 2. 处理插入部分 (拆分行)
                if (!empty($insert)) {
                    // 获取当前单据的最大行号，确保新行号递增
                    // 注意：这里需要从 $insert 的第一个元素获取 ID，因为它们都属于同一个主表单据
                    $mainId = $insert[0]['ID'] ?? null;

                    if ($mainId) {
                        $maxRowID = DB::connection($this->connectionName)
                                ->table('QMINSPECTVOUCHERS')
                                ->max('AUTOID') ?? 0;

                        foreach ($insert as &$newRow) {
                            $maxRowID++;
                            $newRow['AUTOID'] = $maxRowID;
                        }

                        // 使用批量插入提高性能
                        DB::connection($this->connectionName)
                            ->table('QMINSPECTVOUCHERS')
                            ->insert($insert);
                    }
                }
            });
            return [true, ''];
        } catch (\Throwable $e) {
            return [false, $e->getMessage()];
        }
    }

    public function getJyOrder($id)
    {
        // 1. 获取表头信息 (主表)
        $main = DB::connection($this->connectionName)
            ->table('QMCHECKVOUCHER')
            ->lock('WITH(NOLOCK)')
            ->where('ID', $id)
            ->first();

        if (!$main) {
            return []; // 或者返回空数组 []
        }

        $main = (array)$main;

        return $main;
    }

    public function getScDetails($id)
    {
        // 1. 获取表头信息 (主表)
        $main = DB::connection($this->connectionName)
            ->table('mom_orderdetail')
            ->lock('WITH(NOLOCK)')
            ->where('MoDid', $id)
            ->first();

        if (!$main) {
            return []; // 或者返回空数组 []
        }

        $main = (array)$main;

        return $main;
    }

    //获取单个销售订单的信息
    public function getXsOrder($id)
    {
        // 1. 获取销售订单主表信息 (SO_SOMain)
        $main = DB::connection($this->connectionName)
            ->table('SO_SOMain')
            ->lock('WITH(NOLOCK)')
            ->where('ID', $id)
            ->first();

        if (!$main) {
            return [];
        }

        $main = (array)$main;

        // 2. 获取销售订单子表信息 (SO_SODetails)
        $details = DB::connection($this->connectionName)
            ->table('SO_SODetails')
            ->lock('WITH(NOLOCK)')
            ->where('ID', $id) // 子表通过 ID 关联主表
            ->get()
            ->map(function ($value) {
                return (array)$value;
            })
            ->toArray();

        // 3. 将子表数据放入 details 键中
        $main['details'] = $details;

        return $main;
    }

    public function getXsThOrder($id)
    {
        // 1. 获取销售退货单主表信息 (DispatchList)
        $main = DB::connection($this->connectionName)
            ->table('DispatchList')
            ->lock('WITH(NOLOCK)')
            ->where('DLID', $id) // 注意：主键叫 DLID
            ->first();

        if (!$main) {
            return [];
        }

        $main = (array)$main;

        // 2. 获取销售退货单子表信息 (DispatchLists)
        $details = DB::connection($this->connectionName)
            ->table('DispatchLists')
            ->lock('WITH(NOLOCK)')
            ->where('DLID', $id) // 通过 DLID 关联
            ->get()
            ->map(function ($value) {
                return (array)$value;
            })
            ->toArray();

        // 3. 将子表数据放入 details 键中
        $main['details'] = $details;

        return $main;
    }

    public function getFhOrder($id)
    {
        // 1. 获取销售发货单主表信息 (DispatchList)
        $main = DB::connection($this->connectionName)
            ->table('DispatchList')
            ->lock('WITH(NOLOCK)')
            ->where('DLID', $id) // U8发货单主键通常是 DLID
            ->first();

        if (!$main) {
            return [];
        }

        $main = (array)$main;

        // 2. 获取销售发货单子表信息 (DispatchLists)
        $details = DB::connection($this->connectionName)
            ->table('DispatchLists') // 注意这里是 DispatchLists
            ->lock('WITH(NOLOCK)')
            ->where('DLID', $id) // 子表通过 DLID 关联主表
            ->get()
            ->map(function ($value) {
                return (array)$value;
            })
            ->toArray();

        // 3. 将子表数据放入 details 键中
        $main['details'] = $details;

        return $main;
    }

    public function getCGDHDetails($id)
    {
        // 2. 获取采购到货单子表信息 (PU_ArrivalVouchs)
        $details = DB::connection($this->connectionName)
            ->table('PU_ArrivalVouchs')
            ->lock('WITH(NOLOCK)')
            ->where('ID', $id) // 通过 ID 关联主表
            ->get()
            ->map(function ($value) {
                return (array)$value;
            });

        // 3. 将子表数据以 cInvCode 为 Key 进行组织
        // 注意：如果一张单据里有重复的存货编码，后面的行会覆盖前面的行
        $details = $details->keyBy('cInvCode')->toArray();

        return $details;
    }

    public function getLlSQDetails($id)
    {
        // 1. 获取领料申请单子表信息 (MaterialAppVouchs)
        $details = DB::connection($this->connectionName)
            ->table('MaterialAppVouchs') // 领料申请单子表名
            ->lock('WITH(NOLOCK)')
            ->where('ID', $id) // 通过 ID 关联主表
            ->get()
            ->map(function ($value) {
                return (array)$value;
            });

        // 2. 将子表数据以 cInvCode 为 Key 进行组织
        // 提示：领料申请单中同一存货可能出现在不同行（如：对应不同的生产订单行）
        // 如果确定 cInvCode 唯一，可用 keyBy；如果不唯一，建议直接返回数组或 keyBy('AutoID')
        $details = $details->keyBy('cInvCode')->toArray();

        return $details;
    }

    public function updateDhOrder($update, $insert)
    {
        try {
            return DB::connection($this->connectionName)->transaction(function () use ($update, $insert) {

                // 1. 处理更新部分 (子表: PU_ArrivalVouchs)
                if (!empty($update)) {
                    foreach ($update as $autoId => $fields) {
                        DB::connection($this->connectionName)
                            ->table('PU_ArrivalVouchs') // 修正为子表名
                            ->where('Autoid', $autoId)  // U8 习惯大写 A 小写 utoid，但 SQL 不敏感
                            ->update($fields);
                    }
                }

                // 2. 处理插入部分 (拆分行)
                if (!empty($insert)) {
                    $mainId = $insert[0]['ID'] ?? null;

                    if ($mainId) {
                        // 获取全表最大 Autoid，确保全局唯一
                        $maxRowID = DB::connection($this->connectionName)
                                ->table('PU_ArrivalVouchs') // 修正为子表名
                                ->max('Autoid') ?? 0;

                        foreach ($insert as &$newRow) {
                            $maxRowID++;
                            $newRow['Autoid'] = $maxRowID;
                        }

                        // 使用批量插入
                        DB::connection($this->connectionName)
                            ->table('PU_ArrivalVouchs')
                            ->insert($insert);
                    }
                }

                return [true, '']; // 事务成功返回
            });
        } catch (\Throwable $e) {
            // 打印错误堆栈有助于调试
            return [false, "修改采购到货单失败: " . $e->getMessage()];
        }
    }

    public function getCgOrder($id)
    {
        // 1. 获取采购到货单主表信息 (PU_ArrivalVouch)
        // 关键：关联键是 ID
        $main = DB::connection($this->connectionName)
            ->table('PU_ArrivalVouch')
            ->lock('WITH(NOLOCK)')
            ->where('ID', $id)
            ->first();

        if (!$main) {
            return [];
        }

        $main = (array)$main;

        // 2. 获取采购到货单子表信息 (PU_ArrivalVouchs)
        $details = DB::connection($this->connectionName)
            ->table('PU_ArrivalVouchs')
            ->lock('WITH(NOLOCK)')
            ->where('ID', $id) // 子表通过 ID 关联主表
            ->get()
            ->map(function ($value) {
                return (array)$value;
            })
            ->toArray();

        // 3. 将子表数据放入 details 键中
        $main['details'] = $details;

        return $main;
    }

    public function getJyOrder2($id)
    {
        // 关联采购到货单子表 (PU_ArrivalVouchs) 获取金额字段
        $order = DB::connection($this->connectionName)
            ->table('QMCHECKVOUCHER as qm')
            ->leftJoin('PU_ArrivalVouchs as arr', 'qm.SOURCEAUTOID', '=', 'arr.Autoid')
            ->select(
                'qm.*',
                'arr.iCost',        // 原币无税单价
                'arr.iOriTaxCost',  // 原币含税单价
                'arr.iTaxRate'      // 税率
            )
            ->where('qm.ID', $id) // 假设这是检验单主表ID
            ->first();

        return $order ? (array)$order : [];
    }

    public function updateLLOrder($update, $insert)
    {
        try {
            return DB::connection($this->connectionName)->transaction(function () use ($update, $insert) {

                // 1. 处理更新部分 (子表: MaterialAppVouchs)
                if (!empty($update)) {
                    foreach ($update as $autoId => $fields) {
                        DB::connection($this->connectionName)
                            ->table('MaterialAppVouchs') // 领料申请单子表
                            ->where('autoid', $autoId)    // 注意字段名在 U8 里可能是 autoid 或 AutoID
                            ->update($fields);
                    }
                }

                // 2. 处理插入部分 (拆分行/新增行)
                if (!empty($insert)) {
                    // 获取当前领料申请单子表的最大 Autoid，确保手动分配不冲突
                    $maxRowID = DB::connection($this->connectionName)
                            ->table('MaterialAppVouchs')
                            ->max('autoid') ?? 0;

                    foreach ($insert as &$newRow) {
                        $maxRowID++;
                        // U8 的 autoid 通常必须手动指定
                        $newRow['autoid'] = $maxRowID;
                    }

                    // 使用批量插入
                    DB::connection($this->connectionName)
                        ->table('MaterialAppVouchs')
                        ->insert($insert);
                }

                return [true, ''];
            });
        } catch (\Throwable $e) {
            // 建议记录详细日志
            return [false, "修改领料申请单失败: " . $e->getMessage()];
        }
    }

    public function getLLOrder($id)
    {
        // 关键：关联键是 ID
        $main = DB::connection($this->connectionName)
            ->table('MaterialAppVouch')
            ->lock('WITH(NOLOCK)')
            ->where('ID', $id)
            ->first();

        if (!$main) {
            return [];
        }

        $main = (array)$main;

        // 2. 获取采购到货单子表信息 (PU_ArrivalVouchs)
        $details = DB::connection($this->connectionName)
            ->table('MaterialAppVouchs')
            ->lock('WITH(NOLOCK)')
            ->where('ID', $id) // 子表通过 ID 关联主表
            ->get()
            ->map(function ($value) {
                return (array)$value;
            })
            ->toArray();

        // 3. 将子表数据放入 details 键中
        $main['details'] = $details;

        return $main;
    }

    public function checkInventoryControl($invCodes)
    {
        if (empty($invCodes)) {
            return [false, '存货编码为空'];
        }

        // 1. 查询存货档案
        $list = DB::connection($this->connectionName)
            ->table('Inventory')
            ->whereIn('cInvCode', $invCodes)
            ->select(['cInvCode', 'cInvName', 'bInvBatch', 'bInvQuality'])
            ->get();

        $noBatch = [];      // 未开启批次管理的
        $noExpiration = []; // 未开启保质期管理的
        $notFound = array_diff($invCodes, $list->pluck('cInvCode')->toArray()); // 数据库中不存在的

        foreach ($list as $item) {
            // 检查批次管理 (bInvBatch 为 0 表示未开启)
            if (empty($item->bInvBatch)) {
                $noBatch[] = $item->cInvCode . '(' . $item->cInvName . ')';
            }

            // 检查保质期管理 (bInvQuality 为 0 表示未开启)
            if (empty($item->bInvQuality)) {
                $noExpiration[] = $item->cInvCode . '(' . $item->cInvName . ')';
            }
        }

        // 2. 组织提示结果
        $messages = [];
        if (!empty($noBatch)) {
            $messages[] = "【未开启批次管理】: " . implode(', ', $noBatch);
        }
        if (!empty($noExpiration)) {
            $messages[] = "【未开启保质期管理】: " . implode(', ', $noExpiration);
        }
        if (!empty($notFound)) {
            $messages[] = "【档案不存在】: " . implode(', ', $notFound);
        }

        if (empty($messages)) {
            return [true, ''];
        }

        return [false, implode("\n", $messages)];
    }

    public function rebuildDhDetails($mainId, $insertData)
    {
        try {
            return DB::connection($this->connectionName)->transaction(function () use ($mainId, $insertData) {

                // 1. 删除旧明细
                DB::connection($this->connectionName)
                    ->table('PU_ArrivalVouchs')
                    ->where('ID', $mainId)
                    ->delete();

                // 2. 获取新的起始 Autoid
                $maxAutoid = DB::connection($this->connectionName)
                        ->table('PU_ArrivalVouchs')
                        ->max('Autoid') ?? 0;

                // 3. 分配新 Autoid 并插入
                foreach ($insertData as &$row) {
                    $maxAutoid++;
                    $row['Autoid'] = $maxAutoid;
                }

                DB::connection($this->connectionName)
                    ->table('PU_ArrivalVouchs')
                    ->insert($insertData);

                return [true, ''];
            });
        } catch (\Throwable $e) {
            return [false, "重建明细失败: " . $e->getMessage()];
        }
    }

    public function rebuildLLDetails($mainId, $insertData)
    {
        try {
            return DB::connection($this->connectionName)->transaction(function () use ($mainId, $insertData) {

                // 1. 删除旧明细 (领料申请单子表)
                DB::connection($this->connectionName)
                    ->table('MaterialAppVouchs')
                    ->where('ID', $mainId)
                    ->delete();

                // 2. 获取新的起始 autoid
                $maxAutoid = DB::connection($this->connectionName)
                        ->table('MaterialAppVouchs')
                        ->max('AutoID') ?? 0;

                // 3. 分配新 autoid 并插入
                foreach ($insertData as &$row) {
                    $maxAutoid++;
                    $row['AutoID'] = $maxAutoid;
                }

                DB::connection($this->connectionName)
                    ->table('MaterialAppVouchs')
                    ->insert($insertData);

                return [true, ''];
            });
        } catch (\Throwable $e) {
            return [false, "重组领料申请单失败: " . $e->getMessage()];
        }
    }

    public function rebuildBjDetails1($mainId, $insertData)
    {
        try {
            return DB::connection($this->connectionName)->transaction(function () use ($mainId, $insertData) {

                // 1. 删除旧明细
                DB::connection($this->connectionName)
                    ->table('QMINSPECTVOUCHERS')
                    ->where('ID', $mainId)
                    ->delete();

                // 2. 获取新的起始 Autoid (报检单通常是 Autoid)
                $maxAutoid = DB::connection($this->connectionName)
                        ->table('QMINSPECTVOUCHERS')
                        ->max('Autoid') ?? 0;

                // 3. 分配新 Autoid
                foreach ($insertData as &$row) {
                    $maxAutoid++;
                    $row['Autoid'] = $maxAutoid;
                }

                // 4. 批量插入
                DB::connection($this->connectionName)
                    ->table('QMINSPECTVOUCHERS')
                    ->insert($insertData);

                return [true, ''];
            });
        } catch (\Throwable $e) {
            return [false, "重组报检单失败: " . $e->getMessage()];
        }
    }

    public function rebuildBjDetails($mainId, $insertData)
    {
        try {
            return DB::connection($this->connectionName)->transaction(function () use ($mainId, $insertData) {

                // 1. 删除旧明细
                DB::connection($this->connectionName)
                    ->table('QMINSPECTVOUCHERS')
                    ->where('ID', $mainId)
                    ->delete();

                $maxAutoid = DB::connection($this->connectionName)
                        ->table('QMINSPECTVOUCHERS')
                        ->max('Autoid') ?? 0;

                // 过滤掉不可插入的字段，特别是 UFTS
                foreach ($insertData as $key => $row) {
                    $maxAutoid++;

                    // 彻底清理：移除 UFTS 字段，防止插入报错及 JSON 转换报错
                    unset($row['UFTS']);

                    $row['Autoid'] = $maxAutoid;
                    $insertData[$key] = $row;
                }

                // 4. 批量插入
                DB::connection($this->connectionName)
                    ->table('QMINSPECTVOUCHERS')
                    ->insert($insertData);

                return [true, '操作成功'];
            });
        } catch (\Throwable $e) {
            // 这里返回错误信息时，确保不包含二进制内容
            return [false, "重组报检单失败: " . $e->getMessage()];
        }
    }
}