<?php

namespace App\Service;

use App\Model\DDEmployee;
use App\Model\FieldData;
use App\Model\Inventory;
use App\Model\Record;
use App\Model\U8State;
use App\Model\Vendor;
use Illuminate\Support\Facades\DB;

class U8ServerService extends Service
{
    protected $databaseService;

    /**
     * @var string|null
     */
    protected $error;

    /**
     * U8ServerService constructor.
     */
    public function __construct($loginUser = [])
    {
        $service = new U8DatabaseServerService($loginUser);
        $this->databaseService = $service->db;
        $this->error = $service->error;
    }

    /**
     * 获取错误信息
     *
     * @return string|null
     */
    public function getError()
    {
        return $this->error;
    }

    public function purchaseOrder($data, $user){
        $qx = $user['qx'];
        $order_date = $data['order_date'] ?? [];
        $order_date = array_filter($order_date);
        $order_number = $data['order_number'] ?? "";

        $model = $this->databaseService->table('PO_Pomain as a')
            ->leftJoin('Vendor as c', 'c.cVenCode', 'a.cVenCode')      // 供应商
            ->leftJoin('Department as d', 'd.cDepCode', 'a.cDepCode')  // 部门
            ->leftJoin('Person as e', 'e.cPersonCode', 'a.cPersonCode')// 业务员
            ->leftJoin('PurchaseType as f', 'f.cPTCode', 'a.cPTCode')  // 采购类型
            ->when(empty($qx), function ($query) use($user){
                return $query->where('a.cMaker', $user['username']);
            })
            ->when(!empty($order_number), function ($query) use($order_number){
                return $query->where('a.cPOID', 'LIKE', '%'.$order_number.'%');
            })
            ->when(!empty($order_date), function ($query) use($order_date){
                $start = date('Y-m-d 00:00:00.000', $order_date[0]);
                $end = date('Y-m-d 23:59:59.000', $order_date[1]);
                return $query->whereBetween('a.dPODate', [$start, $end]);
            })
            ->where(function ($query) {
                $query->where('a.iverifystateex', 0)
                    ->orWhereNull('a.iverifystateex');
            })
            ->select(
                DB::raw("ISNULL(a.cBusType, '') as business_type"),      // 业务类型
                DB::raw("ISNULL(CONVERT(varchar(10), a.dPODate, 120), '') as order_date"), // 订单日期
                DB::raw("ISNULL(a.cPOID, '') as order_number"),          // 订单编号
                DB::raw("ISNULL(f.cPTName, '') as purchase_type"),       // 采购类型
                DB::raw("ISNULL(c.cVenName, '') as supplier_title"),     // 供应商
                DB::raw("ISNULL(d.cDepName, '') as department_name"),    // 部门
                DB::raw("ISNULL(e.cPersonName, '') as person_name"),     // 业务员
                DB::raw("CAST(ISNULL(a.iTaxRate, 0) AS varchar) as tax_rate"), // 税率（数值转字符，null转0或空）
                DB::raw("ISNULL(a.cexch_name, '') as currency_name"),    // 币种
                DB::raw("CAST(ISNULL(a.nflat, 0) AS varchar) as exchange_rate"), // 汇率
                DB::raw("ISNULL(a.cMemo, '') as remark"),                // 备注
                DB::raw("ISNULL(a.cMaker, '') as crt_name")              // 制单人
            )
            ->orderBy('a.POID', 'desc');

        $list = $this->limit($model, '', $data);
        $list = $this->fillAll($list, U8State::type_one, $user['login_type']);

        return [true, $list];
    }

    public function purchaseOrderDetail($data, $user){
        if(empty($data['order_number'])) return [false, '采购单号不能为空'];

        $order = $this->databaseService->table('PO_Pomain as a')
            ->leftJoin('Vendor as c', 'c.cVenCode', 'a.cVenCode')
            ->leftJoin('Department as d', 'd.cDepCode', 'a.cDepCode')
            ->leftJoin('Person as e', 'e.cPersonCode', 'a.cPersonCode')
            ->leftJoin('PurchaseType as f', 'f.cPTCode', 'a.cPTCode')
            ->where('a.cPOID', $data['order_number'])
            ->select(
                'a.POID',
                DB::raw("ISNULL(a.cBusType, '') as business_type"),
                DB::raw("ISNULL(CONVERT(varchar(10), a.dPODate, 120), '') as order_date"),
                DB::raw("ISNULL(a.cPOID, '') as order_number"),
                DB::raw("ISNULL(f.cPTName, '') as purchase_type"),
                DB::raw("ISNULL(c.cVenName, '') as supplier_title"),
                DB::raw("ISNULL(d.cDepName, '') as department_name"),
                DB::raw("ISNULL(e.cPersonName, '') as person_name"),
                DB::raw("CAST(ISNULL(a.iTaxRate, 0) AS varchar) as tax_rate"),
                DB::raw("ISNULL(a.cexch_name, '') as currency_name"),
                DB::raw("CAST(ISNULL(a.nflat, 0) AS varchar) as exchange_rate"),
                DB::raw("ISNULL(a.cMemo, '') as remark"),
                DB::raw("ISNULL(a.cMaker, '') as crt_name")
            )
            ->first();

        if(empty($order)) return [false, '采购单不存在'];
        $order = (array) $order;
        $order = $this->fillDetail($order, U8State::type_one, $user['login_type']);

        // 获取明细
        $detail = $this->databaseService->table('PO_Podetails as a')
            ->leftJoin('Inventory as b', 'b.cInvCode', 'a.cInvCode')
            ->leftJoin('ComputationUnit as c', 'c.cComunitCode', 'b.cComUnitCode')
            ->where('a.POID', $order['POID'])
            ->select(
                DB::raw("ISNULL(b.cInvCode, '') as product_code"),
                DB::raw("ISNULL(b.cInvName, '') as product_title"),
                DB::raw("ISNULL(b.cInvStd, '') as product_std"),
                DB::raw("ISNULL(c.cComUnitName, '') as unit_title"),
                // 数字转字符串并去除空格，NULL 则返回 '0.00' 或 ''
                DB::raw("ISNULL(LTRIM(STR(a.iQuantity, 20, 2)), '0.00') as quantity"),
                DB::raw("ISNULL(LTRIM(STR(a.iTaxPrice, 20, 4)), '0.0000') as tax_unit_price"),
                DB::raw("ISNULL(LTRIM(STR(a.iUnitPrice, 20, 4)), '0.0000') as unit_price"),
                DB::raw("ISNULL(LTRIM(STR(a.iMoney, 20, 2)), '0.00') as amount"),
                DB::raw("ISNULL(LTRIM(STR(a.iSum, 20, 2)), '0.00') as tax_amount"),
                DB::raw("ISNULL(LTRIM(STR(a.iPerTaxRate, 20, 2)), '0.00') as tax_rate"),
                DB::raw("ISNULL(CONVERT(varchar(10), a.dArriveDate, 120), '') as arrive_date"),
                DB::raw("ISNULL(b.cEnterprise, '') as factory_name")
            )
            ->get();

        // 转为数组
        $order['detail'] = $detail->map(function ($item) {
            return (array) $item;
        })->toArray();

        // 移除内部 ID 避免暴露
        unset($order['POID']);

        return [true, $order];
    }

    public function purchaseRequisition($data, $user){
        $qx = $user['qx'];
        $order_date = $data['order_date'] ?? [];
        $order_date = array_filter($order_date);
        $order_number = $data['order_number'] ?? "";

        $model = $this->databaseService->table('PU_AppVouch as a')
            ->leftJoin('Person as c', 'c.cPersonCode', 'a.cPersonCode') // 请购人
            ->leftJoin('Department as d', 'd.cDepCode', 'a.cDepCode')  // 请购部门
            ->leftJoin('PurchaseType as f', 'f.cPTCode', 'a.cPTCode')  // 采购类型
            ->when(empty($qx), function ($query) use($user){
                return $query->where('a.cMaker',$user['username']);
            })
            ->when(! empty($order_number), function ($query) use($order_number){
                return $query->where('a.cCode','LIKE', '%'.$order_number.'%');
            })
            ->when(! empty($order_date), function ($query) use($order_date){
                $start = date('Y-m-d 00:00:00.000', $order_date[0]);
                $end = date('Y-m-d 23:59:59.000', $order_date[1]);
                return $query->whereBetween('a.dDate', [$start, $end]);
            })
            ->where(function ($query) {
                $query->where('a.iverifystateex', 0)
                    ->orWhereNull('a.iverifystateex');
            })
            ->select(
                DB::raw("ISNULL(a.cBusType, '') as business_type"),      // 业务类型
                DB::raw("ISNULL(a.cCode, '') as order_number"),          // 单据号
                DB::raw("ISNULL(CONVERT(varchar(10), a.dDate, 120), '') as order_date"), // 日期
                DB::raw("ISNULL(d.cDepName, '') as department_name"),    // 请购部门
                DB::raw("ISNULL(c.cPersonName, '') as purchase_name"),   // 请购人员
                DB::raw("ISNULL(f.cPTName, '') as purchase_type"),       // 采购类型
                DB::raw("ISNULL(a.cMaker, '') as crt_name")              // 制单人
            )
            ->orderBy('a.ID','desc');

        $list = $this->limit($model,'',$data);
        $list = $this->fillAll($list, U8State::type_two, $user['login_type']);

        return [true , $list];
    }

    public function purchaseRequisitionDetail($data, $user){
        if(empty($data['order_number'])) return [false, '采购请购单号不能为空'];

        $order = $this->databaseService->table('PU_AppVouch as a')
            ->leftJoin('Person as c', 'c.cPersonCode', 'a.cPersonCode')
            ->leftJoin('Department as d', 'd.cDepCode', 'a.cDepCode')
            ->leftJoin('PurchaseType as f', 'f.cPTCode', 'a.cPTCode')
            ->where('a.cCode', $data['order_number'])
            ->select(
                'a.ID', // 用于关联子表
                DB::raw("ISNULL(a.cBusType, '') as business_type"),
                DB::raw("ISNULL(a.cCode, '') as order_number"),
                DB::raw("ISNULL(CONVERT(varchar(10), a.dDate, 120), '') as order_date"),
                DB::raw("ISNULL(d.cDepName, '') as department_name"),
                DB::raw("ISNULL(c.cPersonName, '') as purchase_name"),
                DB::raw("ISNULL(f.cPTName, '') as purchase_type"),
                DB::raw("ISNULL(a.cMaker, '') as crt_name")
            )
            ->first();

        if(empty($order)) return [false, '采购请购单不存在'];
        $order = (array) $order;
        $order = $this->fillDetail($order, U8State::type_two, $user['login_type']);

        $detail = $this->databaseService->table('PU_AppVouchs as a')
            ->leftJoin('Inventory as b', 'b.cInvCode', 'a.cInvCode')
            ->leftJoin('ComputationUnit as c', 'c.cComunitCode', 'b.cComUnitCode')
            ->where('a.ID', $order['ID'])
            ->select(
                DB::raw("ISNULL(b.cInvCode, '') as product_code"),    // 存货编码
                DB::raw("ISNULL(b.cInvName, '') as product_title"),   // 存货名称
                DB::raw("ISNULL(b.cInvStd, '') as product_std"),      // 规格型号
                DB::raw("ISNULL(c.cComUnitName, '') as unit_title"),  // 主计量
                DB::raw("ISNULL(LTRIM(STR(a.fQuantity, 20, 2)), '0.00') as quantity"), // 数量
                DB::raw("ISNULL(LTRIM(STR(a.fUnitPrice, 20, 4)), '0.0000') as unit_price"), // 本币单价
                DB::raw("ISNULL(LTRIM(STR(a.iOriSum, 20, 2)), '0.00') as tax_amount"), // 本币价税合计
                DB::raw("ISNULL(CONVERT(varchar(10), a.dRequirDate, 120), '') as need_arrived_date"), // 需求日期
                DB::raw("ISNULL(CONVERT(varchar(10), a.dArriveDate, 120), '') as suggest_order_date"), // 建议订货日期
                DB::raw("ISNULL(b.cEnterprise, '') as factory_name") // 生产企业
            )
            ->get();

        // 转为数组格式
        $order['detail'] = $detail->map(function ($item) {
            return (array) $item;
        })->toArray();

        unset($order['ID']); // 隐藏内部ID

        return [true, $order];
    }

    public function purchaseInOrder($data, $user){
        $qx = $user['qx'];
        $order_date = $data['order_date'] ?? [];
        $order_date = array_filter($order_date);
        $order_number = $data['order_number'] ?? "";

        $model = $this->databaseService->table('RdRecord01 as a')
            ->leftJoin('Vendor as c', 'c.cVenCode', 'a.cVenCode')      // 供货单位
            ->leftJoin('Warehouse as w', 'w.cWhCode', 'a.cWhCode')    // 仓库
            ->leftJoin('Department as d', 'd.cDepCode', 'a.cDepCode')  // 部门
            ->leftJoin('Person as p', 'p.cPersonCode', 'a.cPersonCode')// 业务员
            ->leftJoin('PurchaseType as pt', 'pt.cPTCode', 'a.cPTCode')// 采购类型
            ->leftJoin('Rd_Style as rs', 'rs.cRdCode', 'a.cRdCode')   // 入库类别
            ->when(empty($qx), function ($query) use($user){
                return $query->where('a.cMaker',$user['username']);
            })
            ->when(! empty($order_number), function ($query) use($order_number){
                return $query->where('a.cCode','LIKE', '%'.$order_number.'%');
            })
            ->when(! empty($order_date), function ($query) use($order_date){
                $start = date('Y-m-d 00:00:00.000', $order_date[0] / 1000);
                $end = date('Y-m-d 23:59:59.000', $order_date[1] / 1000);
                return $query->whereBetween('a.dDate', [$start, $end]);
            })
            ->whereNull('a.cHandler') // 未审核
            ->select(
                DB::raw("ISNULL(a.cCode, '') as order_number"),           // 入库单号
                DB::raw("ISNULL(CONVERT(varchar(10), a.dDate, 120), '') as order_date"), // 入库日期
                DB::raw("ISNULL(w.cWhName, '') as warehouse_name"),       // 仓库
                DB::raw("ISNULL(a.cOrderCode, '') as po_number"),         // 订单号
                DB::raw("ISNULL(a.cARVCode, '') as arrival_number"),      // 到货单号
                DB::raw("ISNULL(p.cPersonName, '') as person_name"),      // 业务员
                DB::raw("ISNULL(c.cVenName, '') as supplier_title"),      // 供货单位
                DB::raw("ISNULL(d.cDepName, '') as department_name"),     // 部门
                DB::raw("ISNULL(CONVERT(varchar(10), a.dARVDate, 120), '') as arrival_date"), // 到货日期
                DB::raw("ISNULL(a.cBusType, '') as business_type"),       // 业务类型
                DB::raw("ISNULL(pt.cPTName, '') as purchase_type"),       // 采购类型
                DB::raw("ISNULL(rs.cRdName, '') as rd_style_name"),       // 入库类别
                DB::raw("ISNULL(CONVERT(varchar(10), a.dVeriDate, 120), '') as audit_date"), // 审核日期
                DB::raw("ISNULL(a.cMemo, '') as remark"),                 // 备注
                DB::raw("ISNULL(a.cMaker, '') as crt_name")               // 制单人
            )
            ->orderBy('a.ID','desc');

        $list = $this->limit($model,'',$data);
        $list = $this->fillAll($list, U8State::type_three, $user['login_type']);

        return [true , $list];
    }

    public function purchaseInOrderDetail($data, $user){
        if(empty($data['order_number'])) return [false, '入库单号不能为空'];

        $order = $this->databaseService->table('RdRecord01 as a')
            ->leftJoin('Vendor as c', 'c.cVenCode', 'a.cVenCode')
            ->leftJoin('Warehouse as w', 'w.cWhCode', 'a.cWhCode')
            ->leftJoin('Department as d', 'd.cDepCode', 'a.cDepCode')
            ->leftJoin('Person as p', 'p.cPersonCode', 'a.cPersonCode')
            ->leftJoin('PurchaseType as pt', 'pt.cPTCode', 'a.cPTCode')
            ->leftJoin('Rd_Style as rs', 'rs.cRdCode', 'a.cRdCode')
            ->where('a.cCode', $data['order_number'])
            ->select(
                'a.ID',
                DB::raw("ISNULL(a.cCode, '') as order_number"),
                DB::raw("ISNULL(CONVERT(varchar(10), a.dDate, 120), '') as order_date"),
                DB::raw("ISNULL(w.cWhName, '') as warehouse_name"),
                DB::raw("ISNULL(a.cOrderCode, '') as po_number"),
                DB::raw("ISNULL(a.cARVCode, '') as arrival_number"),
                DB::raw("ISNULL(p.cPersonName, '') as person_name"),
                DB::raw("ISNULL(c.cVenName, '') as supplier_title"),
                DB::raw("ISNULL(d.cDepName, '') as department_name"),
                DB::raw("ISNULL(CONVERT(varchar(10), a.darvdate, 120), '') as arrival_date"),
                DB::raw("ISNULL(a.cBusType, '') as business_type"),
                DB::raw("ISNULL(pt.cPTName, '') as purchase_type"),
                DB::raw("ISNULL(rs.cRdName, '') as rd_style_name"),
                DB::raw("ISNULL(CONVERT(varchar(10), a.dVeriDate, 120), '') as audit_date"),
                DB::raw("ISNULL(a.cMemo, '') as remark"),
                DB::raw("ISNULL(a.cMaker, '') as crt_name")
            )
            ->first();

        if(empty($order)) return [false, '采购入库单不存在'];
        $order = (array) $order;
        $order = $this->fillDetail($order, U8State::type_three, $user['login_type']);

        $detail = $this->databaseService->table('rdrecords01 as a')
            ->leftJoin('Inventory as b', 'b.cInvCode', 'a.cInvCode')
            ->leftJoin('ComputationUnit as c', 'c.cComunitCode', 'b.cComUnitCode')
            ->where('a.ID', $order['ID'])
            ->select(
                DB::raw("ISNULL(b.cInvCode, '') as product_code"),    // 存货编码
                DB::raw("ISNULL(b.cInvName, '') as product_title"),   // 存货名称
                DB::raw("ISNULL(b.cInvStd, '') as product_std"),      // 规格型号
                DB::raw("ISNULL(c.cComUnitName, '') as unit_title"),  // 主计量单位
                DB::raw("ISNULL(LTRIM(STR(a.iQuantity, 20, 2)), '0.00') as quantity"), // 数量
                DB::raw("ISNULL(LTRIM(STR(a.iUnitCost, 20, 4)), '0.0000') as unit_price"), // 本币单价
                DB::raw("ISNULL(LTRIM(STR(a.iPrice, 20, 2)), '0.00') as amount"), // 本币金额
                DB::raw("ISNULL(LTRIM(STR(a.iTax, 20, 2)), '0.00') as tax"), // 税额
                DB::raw("ISNULL(LTRIM(STR(a.iTaxPrice, 20, 2)), '0.00') as nat_tax"), // 本币税额 (入库单本币税额通常等于原币税额)
                DB::raw("ISNULL(LTRIM(STR(a.iSum, 20, 2)), '0.00') as tax_amount") // 本币价税合计
            )
            ->get();

        $detailArr = $detail->map(function ($item) {
            return (array) $item;
        })->toArray();

        // 计算总金额（价税合计之和）
        $order['total_amount'] = number_format(array_sum(array_column($detailArr, 'tax_amount')), 2, '.', '');
        $order['detail'] = $detailArr;

        unset($order['ID']);

        return [true, $order];
    }

    public function inventoryDetail($data, $user){
        if(empty($data['order_number'])) return [false, '流水单号不能为空'];

        $order = Inventory::where('del_time',0)
            ->where('order_number', $data['order_number'])
            ->first();
        if(empty($order)) return [false, '存货不存在'];
        $order = $order->toArray() ;
        $order['crt_name'] = DDEmployee::where('login_type', $user['login_type'])->where('userid', $order['crt_id'])->value('name') ?? '';

        return [true, $order];
    }

    public function vendorDetail($data, $user){
        if(empty($data['order_number'])) return [false, '流水单号不能为空'];

        $order = Vendor::where('del_time',0)
            ->where('order_number', $data['order_number'])
            ->first();
        if(empty($order)) return [false, '供应商不存在'];
        $order = $order->toArray() ;
        $order['crt_name'] = DDEmployee::where('login_type', $user['login_type'])->where('userid', $order['crt_id'])->value('name') ?? '';

        return [true, $order];
    }

    public function getOrderDetails($data,$user){
        $type = $data['type'];
        if($type == 1){
            // 采购单
            [$success, $order] = $this->purchaseOrderDetail($data,$user);
        }elseif ($type == 2){
            // 采购请购单
            [$success, $order] = $this->purchaseRequisitionDetail($data,$user);
        }elseif ($type == 3){
            // 采购入库
            [$success, $order] = $this->purchaseInOrderDetail($data,$user);
        }elseif ($type == 4){
            // 存货
            [$success, $order] = $this->inventoryDetail($data,$user);
        }elseif ($type == 5){
            // 供应商
            [$success, $order] = $this->vendorDetail($data,$user);
        }

        return [$success, $order];
    }

    private function fillAll($list, $type, $login_type){
        if(empty($list['data'])) return $list;

        $map = U8State::where('del_time', 0)
            ->where('type', $type)
            ->where('login_type', $login_type)
            ->whereIn('order_number', array_column($list['data'], 'order_number'))
            ->pluck('state', 'order_number')
            ->toArray();

        foreach ($list['data'] as $key => $value){
            if(isset($map[$value->order_number])) {
                $m = $map[$value->order_number];
                $state = $m;
                $state_title = Record::state_name[$state];
            }else{
                $state = Record::state_minus_one;
                $state_title = Record::state_name[$state];
            }
            $list['data'][$key]->state = $state;
            $list['data'][$key]->state_title = $state_title;
        }

        return $list;
    }

    private function fillDetail($list, $type, $login_type){
        if(empty($list)) return $list;

        $map = U8State::where('del_time', 0)
            ->where('type', $type)
            ->where('login_type', $login_type)
            ->where('order_number', $list['order_number'])
            ->pluck('state', 'order_number')
            ->toArray();

        if(isset($map[$list['order_number']])) {
            $m = $map[$list['order_number']];
            $state = $m;
            $state_title = Record::state_name[$state];
        }else{
            $state = Record::state_minus_one;
            $state_title = Record::state_name[$state];
        }
        $list['state'] = $state;
        $list['state_title'] = $state_title;

        return $list;
    }

    public function stockList($data, $user)
    {
        try {
            $field_list = [];
            $employee = DDEmployee::where('userid', $user['userid'])->where('login_type', $user['login_type'])->first();
            $qx = $employee['qx'] ?? 0;
            if(empty($qx)) {
                $field_list = FieldData::where('userid', $user['userid'])
                    ->where('login_type', $user['login_type'])
                    ->where('type', FieldData::STATE_ZERO)
                    ->pluck('key')
                    ->all();
            }

            // 1. 构建基础查询：关联现存量表和存货档案表
            $query = $this->databaseService->table('CurrentStock as S')
                ->select([
                    'S.cWhCode',              // 仓库编码
                    'W.cWhName',              // 仓库名称
                    'S.cInvCode',             // 存货编码
                    'I.cInvName',             // 存货名称
                    'I.cInvStd',              // 规格型号
                    'I.cInvCCode',            // 分类编码

                    // --- 数量字段对齐你的结构 ---
                    'S.iQuantity',            // 结存数量 (账面现存量)
                    'S.fAvaQuantity',         // 可用数量
                    'S.fOutQuantity',         // 待发货数量 (待出)
                    'S.fInQuantity',          // 待入库数量 (待入)
                    'S.fStopQuantity',        // 冻结数量

                    // --- 批次与日期 ---
                    'S.cBatch',               // 批号
                    'S.dMdate',               // 生产日期
                    'S.dVDate',               // 失效日期
                ])
                ->join('Inventory as I', 'S.cInvCode', '=', 'I.cInvCode')
                ->leftJoin('Warehouse as W', 'S.cWhCode', '=', 'W.cWhCode')
                ->leftJoin('InventoryClass as IC', 'I.cInvCCode', '=', 'IC.cInvCCode');

            // 2. 过滤条件：存货名称 (支持模糊查询)
            if (!empty($data['material_title'])) {
                $query->where('I.cInvName', 'like', '%' . $data['material_title'] . '%');
            }

            // 2. 过滤条件：存货编码 (支持模糊查询)
            if (!empty($data['material_code'])) {
                $query->where('S.cInvCode', 'like', '%' . $data['material_code'] . '%');
            }

            // 3. 过滤条件：存货分类 (支持左匹配，即选大类查出所有子类)
            if (!empty($data['category_code'])) {
                // U8 分类是级次结构，用 like '01%' 可以查出 01 开头的所有子类
                $query->where('I.cInvCCode', 'like', $data['category_code'] . '%');
            }

            // 6. 排序
            $query->orderBy('S.cInvCode', 'asc')->orderBy('S.cWhCode', 'asc');

            // 7. 调用你定义的分页方法
            $columns = ['*'];
            $result = $this->limit($query, $columns, $data);

            // 注意这里的 &$item，加了 & 符号才能直接修改原数组里的内容
            foreach ($result['data'] as &$item) {
                $numFields = ['iQuantity', 'fAvaQuantity', 'fOutQuantity', 'fInQuantity', 'fStopQuantity'];

                foreach ($numFields as $field) {
                    if (isset($item->$field)) {
                        $item->$field = (float)$item->$field;
                    }
                }

                $item->dMdate = $item->dMdate ? date('Y-m-d', strtotime($item->dMdate)) : '';
                $item->dVDate = $item->dVDate ? date('Y-m-d', strtotime($item->dVDate)) : '';

                // 脱敏处理
                if (!empty($field_list)) {
                    foreach ($field_list as $blackField) {
                        if (isset($item->$blackField)) {
                            $item->$blackField = '*****';
                        }
                    }
                }
            }
            unset($item); // 销毁引用

            return [true, $result];

        } catch (\Throwable $exception) {
            return [false, "查询库存失败: " . $exception->getMessage()];
        }
    }

    public function vendorU8List($data, $user)
    {
        // 1. 构建基础查询
        $query = $this->databaseService->table('Vendor as V')
            ->select([
                'V.cVenCode',          // 供应商编码
                'V.cVenName',          // 供应商名称
                'V.cVenAbbName',       // 供应商简称
                'V.cVCCode',           // 分类编码
                'VC.cVCName',         // 分类名称 (来自 VendorClass)
                'V.cVenAddress',       // 地址
                'V.cVenPhone',         // 电话
                'V.dVenDevDate',       // 发展日期
                'V.cCreatePerson',     // 创建人
                'V.bVenTax',           // 是否计税
                'V.iId'                // 内部ID
            ])
            // 关联供应商分类表获取分类名称
            ->leftJoin('VendorClass as VC', 'V.cVCCode', '=', 'VC.cVCCode');

        // 2. 增加搜索逻辑 (可选)
        if (!empty($data['keyword'])) {
            $keyword = $data['keyword'];
            $query->where(function($q) use ($keyword) {
                $q->where('V.cVenCode', 'like', "%{$keyword}%")
                    ->orWhere('V.cVenName', 'like', "%{$keyword}%")
                    ->orWhere('V.cVenAbbName', 'like', "%{$keyword}%");
            });
        }

        // 3. 排序 (默认按编码排序)
        $query->orderBy('V.cVenCode', 'ASC');

        // 4. 调用你定义的分页方法
        // 注意：limit 方法内部会执行 paginate 并将结果填充到 $data
        $columns = ['*']; // select 已经在上面定义过了，这里传 * 即可
        $result = $this->limit($query, $columns, $data);

        return [true, $result];
    }

    public function vendorClassTree($data, $user)
    {
        try {
            // 1. 获取所有供应商分类 (表名: VendorClass)
            $classes = $this->databaseService->table('VendorClass')
                ->select('cVCCode', 'cVCName', 'iVCGrade', 'bVCEnd') // 编码、名称、级次
                ->orderBy('cVCCode', 'asc')
                ->get();

            if ($classes->isEmpty()) {
                return [true, []];
            }

            // 2. 格式化数据，以编码为 Key
            $classList = [];
            foreach ($classes as $item) {
                $classList[$item->cVCCode] = [
                    'label'    => $item->cVCName,
                    'value'    => $item->cVCCode, // 前端通常需要 value 字段
                    'code'     => $item->cVCCode,
                    'grade'    => $item->iVCGrade,
                    'is_end'    => $item->bVCEnd,
                    'children' => []
                ];
            }

            // 3. 构建引用树
            $tree = [];
            foreach ($classList as $code => &$node) {
                // 获取父级编码
                $parentCode = $this->getParentCode($code);

                if ($parentCode === null || !isset($classList[$parentCode])) {
                    // 顶级节点
                    $tree[] = &$node;
                } else {
                    // 挂载到父节点
                    $classList[$parentCode]['children'][] = &$node;
                }
            }

            return [true, $tree];

        } catch (\Throwable $exception) {
            return [false, "获取供应商分类树失败: " . $exception->getMessage()];
        }
    }

    /**
     * 辅助函数：根据 U8 编码规则获取父级编码
     * U8 的级次通常存储在 GradeDef 表，但通用逻辑是截取末尾
     */
    private function getParentCode($code)
    {
        $len = strlen($code);
        if ($len <= 2) return null; // 假设第一级是2位，小于等于2位则无父级

        // 这里假设级次是 2-2-2-2 (最常见配置)
        // 实际生产中，如果级次不固定，建议查询 GradeDef 表
        return substr($code, 0, $len - 2);
    }

    //U8 存货分类树结构
    public function inventoryClassTree($data, $user)
    {
        try {
            // 1. 从数据库获取所有存货分类
            $classes = $this->databaseService->table('InventoryClass')
                ->select('cInvCCode', 'cInvCName', 'iInvCGrade', 'bInvCEnd')
                ->orderBy('cInvCCode', 'asc')
                ->get();

            if ($classes->isEmpty()) return [true, []];

            // 2. 将集合转换为数组并以编码作为 Key，方便查找
            $classList = [];
            foreach ($classes as $item) {
                $classList[$item->cInvCCode] = [
                    'label'    => $item->cInvCName,
                    'code'     => $item->cInvCCode,
                    'grade'    => $item->iInvCGrade,
                    'is_end'    => $item->bInvCEnd,
                    'children' => []
                ];
            }

            // 3. 构建树形结构
            $tree = [];
            foreach ($classList as $code => &$node) {
                // 获取当前分类的级次 (U8 逻辑通常根据编码长度判断父级)
                // 比如 0101 的父级是 01
                $parentCode = $this->getParentCode($code);

                if ($parentCode === null || !isset($classList[$parentCode])) {
                    // 如果没有父级编码，或者父级编码不在列表里，说明是顶级分类
                    $tree[] = &$node;
                } else {
                    // 将当前节点引用到父节点的 children 数组中
                    $classList[$parentCode]['children'][] = &$node;
                }
            }

            return [true, $tree];

        } catch (\Throwable $exception) {
            return [false, "获取分类树失败: " . $exception->getMessage()];
        }
    }

    //U8 计量单位组（带默认主计量单位）
    public function getUnitGroups($data, $user)
    {
        $list = $this->databaseService->select("
        SELECT 
            G.cGroupCode, 
            G.cGroupName, 
            G.iGroupType, 
            U.cComUnitCode, 
            U.cComUnitName,
            U.iNumber
        FROM ComputationGroup AS G
        OUTER APPLY (
            SELECT TOP 1 cComUnitCode, cComUnitName, iNumber
            FROM ComputationUnit
            WHERE cGroupCode = G.cGroupCode
            ORDER BY 
                bMainUnit DESC,         -- 1. 优先主计量
                iNumber ASC,            -- 2. 序号最小 (若 NULL 会排在最前)
                cComUnitCode ASC        -- 3. 编码最小
        ) AS U
    ");

        return [true, $list];
    }

    //U8 计量单位档案
    public function getComputationUnitList($data, $user)
    {
        $list = $this->databaseService->table('ComputationUnit as U')
            ->select(
                'U.cComUnitCode',   // 单位编码
                'U.cComUnitName',   // 单位名称
                'U.cGroupCode',     // 所属组编码
                'U.bMainUnit',      // 是否主单位
                'U.iNumber'         // 排序序号
            )
            ->orderBy('U.cGroupCode', 'ASC')
            ->orderBy('U.iNumber', 'ASC') // 按照你要求的 iNumber 排序
            ->get();

        return [true, $list];
    }


    //U8 存货新增到用友
    public function inventoryAddToU8($data, $user){
        $inventory = Inventory::where('del_time', 0)
            ->where('id', $data['id'])
            ->first();
        if(empty($inventory)) return [false, '存货记录不存在或已被删除'];
        $inventory = $inventory->toArray();

        $title = $inventory['title'];
        $category_code = $inventory['category_code'];
        if(! empty($data['code'])){
            //用户传入
            $no = $inventory['code'];
            $flag_title = "重填";
        }else{
            //生成编码
            list($status, $msg) = $this->generate('inventory','1005');
            if(! $status) return [false, $msg];
            $no = $msg;
            $flag_title = "重试";
        }

        $inventoryData = [
            'cInvCode' => $no,
            'cInvName' => $title,
            'cInvCCode' => $category_code,
            'cInvStd' => $inventory['size'] ?? null, // 规格型号
            'bSale'         => $inventory['bSale'], //内销
            'bExpSale'        => $inventory['bExpSale'], //外销
            'bPurchase'     => $inventory['bPurchase'], // 采购
            'bSelf'         => $inventory['bSelf'], // 自制
            'bComsume'      => $inventory['bComsume'], // 生产耗材
            'iGroupType' => $inventory['unit_group_type'], // 计量单位组类别
            'cGroupCode' => $inventory['unit_group_code'], //计量单位组
            'cComUnitCode' => $inventory['unit_code'], // 主计量单位
            'cShopUnit' => $inventory['unit_code'], // 零售计量单位
            'iImpTaxRate' => $inventory['iImpTaxRate'], // 进项税率
            'iTaxRate'      => $inventory['iTaxRate'], // 销项税率
            'dSDate' => date("Y-m-d 00:00:00.000"), // 启用日期
            'cEnterprise' => $inventory['vendor_code_title'] ?? null,
            'iSupplyType' => '0', // 供应类型
            'fConvertRate' => '1.0', // 转换因子
            'bInTotalCost' => '1', // 成本累计否
            'cPlanMethod' => 'R',
            'cSRPolicy' => 'PE',
            'bBomMain' => '0', // 允许BOM母件
            'bBomSub' => '0', // 允许BOM子件
            'bProductBill' => '0', // 允许生产订单
            'iPlanDefault' => '1',
            'iAllocatePrintDgt' => '4',
            'bService' => '0',
            'bAccessary' => '0',
            'iInvAdvance' => '0.0',
            'bInvQuality' => '0',
            'bInvBatch' => '0',
            'bInvEntrust' => '0',
            'bInvOverStock' => '0',
            'bFree1' => '0',
            'bFree2' => '0',
            'bInvType' => '0',
            'bFree3' => '0',
            'bFree4' => '0',
            'bFree5' => '0',
            'bFree6' => '0',
            'bFree7' => '0',
            'bFree8' => '0',
            'bFree9' => '0',
            'bFree10' => '0',
            'cCreatePerson' => 'demo',
            'cModifyPerson' => 'demo', // 变更
            'dModifyDate' => date("Y-m-d H:i:s.000"),
            'bFixExch' => '0',
            'bTrack' => '0',
            'bSerial' => '0',
            'bBarCode' => '0',
            'bSolitude' => '0',
            'bSpecialties' => '0',
            'bPropertyCheck' => '0',
            'iRecipeBatch' => '0',
            'bPromotSales' => '0',
            'bPlanInv' => '0',
            'bProxyForeign' => '0',
            'bATOModel' => '0',
            'bCheckItem' => '0',
            'bPTOModel' => '0',
            'bEquipment' => '0',
            'bMPS' => '0',
            'bROP' => '0',
            'bRePlan' => '0',
            'bBillUnite' => '0',
            'bCutMantissa' => '0',
            'bConfigFree1' => '0',
            'bConfigFree2' => '0',
            'bConfigFree3' => '0',
            'bConfigFree4' => '0',
            'bConfigFree5' => '0',
            'bConfigFree6' => '0',
            'bConfigFree7' => '0',
            'bConfigFree8' => '0',
            'bConfigFree9' => '0',
            'bConfigFree10' => '0',
            'bPeriodDT' => '0',
            'bOutInvDT' => '0',
            'bBackInvDT' => '0',
            'bDTWarnInv' => '0',
            'bImportMedicine' => '0',
            'bFirstBusiMedicine' => '0',
            'bForeExpland' => '0',
            'bInvModel' => '0',
            'bKCCutMantissa' => '0',
            'bReceiptByDT' => '0',
            'bCheckBSATP' => '0',
            'bCheckFree1' => '0',
            'bCheckFree2' => '0',
            'bCheckFree3' => '0',
            'bCheckFree4' => '0',
            'bCheckFree5' => '0',
            'bCheckFree6' => '0',
            'bCheckFree7' => '0',
            'bCheckFree8' => '0',
            'bCheckFree9' => '0',
            'bCheckFree10' => '0',
            'iCheckATP' => '0',
            'bPiece' => '0',
            'bSrvItem' => '0',
            'bSrvFittings' => '0',
            'bSpecialOrder' => '0',
            'bTrackSaleBill' => '0',
            'bCheckBatch' => '0',
            'bMngOldpart' => '0',
        ];

        $inventorySubData = [
            'cInvSubCode' => $no,
            'iSurenessType' => '1',
            'bIsAttachFile' => '0',
            'bInByProCheck' => '1',
            'iRequireTrackStyle' => '0',
            'iExpiratDateCalcu' => '0',
            'iBOMExpandUnitType' => '1',
            'iDrawType' => $inventory['iDrawType'] ?? 0, // 领用方式
            'fInvCIQExch' => $inventory['customs_change_rate'] ?? 1, // 海关换算率
            'bInvKeyPart' => '1',
            'iAcceptEarlyDays' => '999',
            'dInvCreateDatetime' => date("Y-m-d H:i:s.000"),
            'bPUQuota' => '0',
            'bInvROHS' => '0',
            'bPrjMat' => '0',
            'bInvAsset' => '0',
            'bSrvProduct' => '0',
            'iAcceptDelayDays' => '0',
            'bSCkeyProjections' => '0',
            'iSupplyPeriodType' => '1',
            'iAvailabilityDate' => '1',
            'bImport' => '0',
            'bCheckSubitemCost' => '1',
            'fRoundFactor' => '0.0',
            'bConsiderFreeStock' => '1',
            'bSuitRetail' => '0',
            'bFeatureMatch' => '0',
            'bProduceByFeatureAllocate' => '0',
            'bMaintenance' => '0',
            'iMaintenanceCycleUnit' => '0',
            'bCoupon' => '0',
            'bStoreCard' => '0',
            'bProcessProduct' => '0',
            'bProcessMaterial' => '0',
            // 所有的价格自由项默认设为 '0'
            'bPurPriceFree1' => '0', 'bPurPriceFree2' => '0', 'bPurPriceFree3' => '0', 'bPurPriceFree4' => '0', 'bPurPriceFree5' => '0',
            'bPurPriceFree6' => '0', 'bPurPriceFree7' => '0', 'bPurPriceFree8' => '0', 'bPurPriceFree9' => '0', 'bPurPriceFree10' => '0',
            'bOMPriceFree1' => '0', 'bOMPriceFree2' => '0', 'bOMPriceFree3' => '0', 'bOMPriceFree4' => '0', 'bOMPriceFree5' => '0',
            'bOMPriceFree6' => '0', 'bOMPriceFree7' => '0', 'bOMPriceFree8' => '0', 'bOMPriceFree9' => '0', 'bOMPriceFree10' => '0',
            'bSalePriceFree1' => '0', 'bSalePriceFree2' => '0', 'bSalePriceFree3' => '0', 'bSalePriceFree4' => '0', 'bSalePriceFree5' => '0',
            'bSalePriceFree6' => '0', 'bSalePriceFree7' => '0', 'bSalePriceFree8' => '0', 'bSalePriceFree9' => '0', 'bSalePriceFree10' => '0',
            // 所有的控制自由项默认设为 '0'
            'bControlFreeRange1' => '0', 'bControlFreeRange2' => '0', 'bControlFreeRange3' => '0', 'bControlFreeRange4' => '0', 'bControlFreeRange5' => '0',
            'bControlFreeRange6' => '0', 'bControlFreeRange7' => '0', 'bControlFreeRange8' => '0', 'bControlFreeRange9' => '0', 'bControlFreeRange10' => '0',
            // 所有的批次属性默认设为 '0'
            'bBatchProperty1' => '0', 'bBatchProperty2' => '0', 'bBatchProperty3' => '0', 'bBatchProperty4' => '0', 'bBatchProperty5' => '0',
            'bBatchProperty6' => '0', 'bBatchProperty7' => '0', 'bBatchProperty8' => '0', 'bBatchProperty9' => '0', 'bBatchProperty10' => '0',
            'bBondedInv' => '0',
            'bBatchCreate' => '0',
        ];

        try {
            $this->databaseService->beginTransaction();

            $exists = $this->databaseService->table('Inventory')
                ->where('cInvCode', $inventoryData['cInvCode'])
                ->lockForUpdate() // 锁定该行，防止并发冲突
                ->exists();

            if ($exists) return [false, '存货编码已存在，请' . $flag_title];

            $this->databaseService->table('Inventory')->insert($inventoryData);
            $this->databaseService->table('Inventory_sub')->insert($inventorySubData);

            $this->databaseService->commit();
        } catch (\Throwable $exception) {
            $this->databaseService->rollBack();

            return [false, "创建用友失败: " . $exception->getMessage()];
        }

        return [true, ''];
    }

    //U8 供应商新增
    public function vendorAddToU8($data, $user){
        $vendor = Vendor::where('del_time', 0)
            ->where('id', $data['id'])
            ->first();
        if(empty($vendor)) return [false, '供应商记录不存在或已被删除'];
        $vendor = $vendor->toArray();
        if($vendor['status'] != Vendor::STATE_TWO) return [false, '供应商记录未审核通过'];

        if(! empty($vendor['code'])){
            //用户传入
            $no = $vendor['code'];
            $flag_title = "重填";
        }else{
            //生成编码
            list($status, $msg) = $this->generate('vendor');
            if(! $status) return [false, $msg];
            $no = $msg;
            $flag_title = "重试";
        }

        $vendorData = [
            'cVenCode' => $no,
            'cVenName' => $vendor['title'],
            'cVenAbbName' => $vendor['easy_title'],
            'cVCCode' => $vendor['category_code'],
            'dVenDevDate' => date("Y-m-d 00:00:00.000"),
            'iVenDisRate' => '0.0',
            'iVenCreLine' => '0.0',
            'iVenCreDate' => '0',
            'cVenHeadCode' => $no,
            'iAPMoney' => '0.0',
            'iLastMoney' => '0.0',
            'iLRMoney' => '0.0',
            'iFrequency' => '0',
            'bVenTax' => '1',
            'cCreatePerson' => 'demo',
            'cModifyPerson' => 'demo',
            'dModifyDate' => date("Y-m-d H:i:s.000"),
            'iGradeABC' => '-1',
            'bLicenceDate' => '0',
            'bBusinessDate' => '0',
            'bProxyDate' => '0',
            'bPassGMP' => '0',
            'bVenCargo' => '1', // 采购
            'bProxyForeign' => '0', // 委外
            'bVenService' => '0', // 服务
            'bVenOverseas' => '0', // 国外
            'cVenExch_name' => '人民币',
            'iVenGSPType' => '0',
            'iVenGSPAuth' => '-1',
            'bVenAccPeriodMng' => '0',
            'bVenHomeBranch' => '0',
            'dVenCreateDatetime' => date("Y-m-d H:i:s.000"),
            'bIsVenAttachFile' => '0',
            'bRetail' => '0',
        ];

        try {
            $this->databaseService->beginTransaction();

            $exists = $this->databaseService->table('Vendor')
                ->where('cVenCode', $vendorData['cVenCode'])
                ->lockForUpdate() // 锁定该行，防止并发冲突
                ->exists();

            if ($exists) return [false, '供应商编码已存在，请' . $flag_title];

            $this->databaseService->table('Vendor')->insert($vendorData);

            $this->databaseService->commit();

        } catch (\Throwable $exception) {
            $this->databaseService->rollBack();

            return [false, "创建供应商失败: " . $exception->getMessage()];
        }

        return [true, ''];
    }

    // 生成编码
    public function generate($type, $classCode = "")
    {
        try {
            // 1. 确定对象映射
            $cardNumber = ($type === 'inventory') ? 'inventory' : 'Vendor';
            $cardNumber_name = ($type === 'inventory') ? '存货' : '供应商';
            $table = ($type === 'inventory') ? 'Inventory' : 'Vendor';
            $codeField = ($type === 'inventory') ? 'cInvCode' : 'cVenCode';

            // 2. 获取 U8 规则定义
            $rule = $this->databaseService->table('VoucherNumber')
                ->where('CardNumber', $cardNumber)
                ->first();

            if (!$rule) return [false, "未找到 {$cardNumber_name} 的规则定义"];

            /**
             * 3. 动态解析前缀 (Prefix1, Prefix2, Prefix3)
             * U8 的规则通常存放在 PrefixRule 或 Prefix 字段中
             */
            $prefix = "";
            for ($i = 1; $i <= 3; $i++) {
                $ruleField = "Prefix{$i}Rule";
                $valField = "Prefix{$i}";

                // 检查规则描述
                $ruleDesc = $rule->$ruleField ?? ''; // 例如 "存货分类编码" 或 "GYS"
                $staticVal = $rule->$valField ?? '';

                if (str_contains($ruleDesc, '分类') || str_contains($staticVal, '分类')) {
                    // 如果规则提到“分类”，则填入传入的分类编码
                    $prefix .= $classCode;
                } elseif (!empty($ruleDesc)) {
                    // 如果规则是具体的字符（如 "GYS"），直接拼接
                    $prefix .= $ruleDesc;
                } elseif (!empty($staticVal) && $staticVal !== '手工输入' && $staticVal !== '存货分类编码') {
                    // 如果静态值不是提示语，则作为前缀
                    $prefix .= $staticVal;
                }
            }

            // 4. 获取流水号配置 (Glide)
            $glideLen = $rule->GlideLen > 0 ? $rule->GlideLen : 4;
            $startNum = $rule->iStartNumber ?? 1;

            // 5. 查找当前最大编码
            $expectedLen = strlen($prefix) + $glideLen;

            $lastCode = $this->databaseService->table($table)
                ->where($codeField, 'like', $prefix . '%')
                ->whereRaw("LEN($codeField) = $expectedLen")
                ->orderBy($codeField, 'desc')
                ->value($codeField);

            // 6. 生成编码
            if (!$lastCode) {
                // 初始：前缀 + 起始值补零
                $finalCode = $prefix . str_pad($startNum, $glideLen, '0', STR_PAD_LEFT);
            } else {
                // 截取流水号自增
                $lastSerial = substr($lastCode, -$glideLen);
                $nextSerial = ++$lastSerial;

                // 溢出检查
                if (strlen($nextSerial) > $glideLen) {
                    return [false, "流水号已溢出"];
                }
                $finalCode = $prefix . str_pad($nextSerial, $glideLen, '0', STR_PAD_LEFT);
            }

            return [true, $finalCode];

        } catch (\Throwable $e) {
            return [false, "生成失败: " . $e->getMessage()];
        }
    }
}