xky/app/Service/U8XkyServerService.php

<?php

namespace App\Service;

use App\Jobs\ProcessDataJob;
use App\Model\DDEmployee;
use App\Model\Field;
use App\Model\FieldData;
use App\Model\Inventory;
use App\Model\PoPodetails;
use App\Model\PoPomain;
use App\Model\PuAppVouch;
use App\Model\PuAppVouchs;
use App\Model\RdRecord01;
use App\Model\RdRecords01;
use App\Model\Record;
use App\Model\U8State;
use App\Model\Vendor;
use Illuminate\Support\Facades\DB;

class U8XkyServerService extends Service
{
    public function recordCommon($data, $user, $field = []){
       $state = $data['state'] ?? [];
       $qx = $user['qx'];
       $model = U8State::where('del_time',0)
           ->when(! empty($state), function ($query) use($state){
               return $query->whereIn('state', $state);
           })
           ->when(empty($qx), function ($query) use($qx, $user){
               return $query->where('userid', $user['userid']);
           })
           ->where('login_type', $user['login_type'])
           ->select('type', 'order_number', 'state')
           ->orderBy('id','desc');

       return $model;
    }

    public function recordList($data, $user){
        $model = $this->recordCommon($data, $user);
        $list = $this->limit($model,'',$data);
        $list = $this->fillRecordData($list,$user);

        return [true, $list];
    }

    public function fillRecordData($data, $user){
        if(empty($data['data'])) return $data;

        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['type_title'] = FieldData::$name[$value['type']] ?? '';
        }

        return $data;
    }

    //新增存货到本地-----------------------------------------------

    public function inventoryAdd($data, $user){
        list($status, $msg) = $this->inventoryRule($data, $user);
        if(! $status) return [false, $msg];

        try {
            DB::beginTransaction();

            $inventoryData = [
                'order_number' => $this->generateBillNo([
                    'type' => Inventory::Order_type,
                    'login_type' => $user['login_type'],
                    'period' => date("Ym")
                ]),
                'title' => $data['title'] ?? "",
                'size' => $data['size'] ?? "",
                'category_code' => $data['category_code'] ?? "",
                'category_code_title' => $data['category_code_title'] ?? "",
                'unit_group_type' => $data['unit_group_type'] ?? "",
                'unit_group_code' => $data['unit_group_code'] ?? "",
                'unit_group_code_title' => $data['unit_group_code_title'] ?? "",
                'unit_code' => $data['unit_code'] ?? "",
                'unit_code_title' => $data['unit_code_title'] ?? "",
                'vendor_code' => $data['vendor_code'] ?? "",
                'vendor_code_title' => $data['vendor_code_title'] ?? "",
                'bSale'         => $data['bSale'] ?? 0, //内销
                'bExpSale'        => $data['bExpSale'] ?? 0, //外销
                'bPurchase'     => $data['bPurchase'] ?? 0, // 采购
                'bSelf'         => $data['bSelf'] ?? 0, // 自制
                'bComsume'      => $data['bComsume'] ?? 0, // 生产耗材
                'iImpTaxRate' => $data['iImpTaxRate'] ?? 0, // 进项税率
                'iTaxRate'      => $data['iTaxRate'] ?? 0, // 销项税率
                'customs_change_rate'      => $data['customs_change_rate'] ?? 0,
                'login_type'      => $user['login_type'],
                'crt_id' => $user['userid'],
                'crt_time' => time(),
            ];

            Inventory::insert($inventoryData);

            DB::commit();
        } catch (\Throwable $exception) {
            DB::rollBack();
            return [false, "创建存货失败: " . $exception->getMessage()];
        }

        return [true, ''];
    }

    public function inventoryEdit($data, $user){
        list($status, $msg) = $this->inventoryRule($data, $user, false);
        if(! $status) return [false, $msg];

        try {
            DB::beginTransaction();

            $inventoryData = [
                'title' => $data['title'] ?? "",
                'size' => $data['size'] ?? "",
                'category_code' => $data['category_code'] ?? "",
                'category_code_title' => $data['category_code_title'] ?? "",
                'unit_group_type' => $data['unit_group_type'] ?? "",
                'unit_group_code' => $data['unit_group_code'] ?? "",
                'unit_group_code_title' => $data['unit_group_code_title'] ?? "",
                'unit_code' => $data['unit_code'] ?? "",
                'unit_code_title' => $data['unit_code_title'] ?? "",
                'vendor_code' => $data['vendor_code'] ?? "",
                'vendor_code_title' => $data['vendor_code_title'] ?? "",
                'bSale'         => $data['bSale'] ?? 0, //内销
                'bExpSale'        => $data['bExpSale'] ?? 0, //外销
                'bPurchase'     => $data['bPurchase'] ?? 0, // 采购
                'bSelf'         => $data['bSelf'] ?? 0, // 自制
                'bComsume'      => $data['bComsume'] ?? 0, // 生产耗材
                'iImpTaxRate' => $data['iImpTaxRate'] ?? 0, // 进项税率
                'iTaxRate'      => $data['iTaxRate'] ?? 0, // 销项税率
                'customs_change_rate'      => $data['customs_change_rate'] ?? 0,
                'upd_time' => time(),
            ];

            Inventory::where('id', $data['id'])->update($inventoryData);

            DB::commit();
        } catch (\Throwable $exception) {
            DB::rollBack();
            return [false, "编辑存货失败: " . $exception->getMessage()];
        }

        return [true, ''];
    }

    public function inventoryRule(&$data, $user, $is_add = true){
        if(! $is_add && empty($data['id'])) return [false, 'ID不能为空'];
        $id = $data['id'] ?? 0;
        $code = $data['code'] ?? "";
        if(empty($data['title'])) return [false, '存货名称不能为空'];
        $title = $data['title'];
        if(empty($data['category_code'])) return [false, '存货分类编码不能为空'];
        $category_code = $data['category_code'];
        if(empty($data['category_code_title'])) return [false, '存货分类名不能为空'];
        $category_code_title = $data['category_code_title'];
        if(! isset($data['unit_group_type'])) return [false, '计量单位组类型不存在'];
        $unit_group_type = $data['unit_group_type'] ?? "";
        if(empty($data['unit_group_code'])) return [false, '计量单位组编码不能为空'];
        $unit_group_code = $data['unit_group_code'] ?? "";
        if(empty($data['unit_group_code_title'])) return [false, '计量单位组名不能为空'];
        $unit_group_code_title = $data['unit_group_code_title'] ?? "";
        if(empty($data['unit_code'])) return [false, '主计量单位编码不能为空'];
        $unit_code = $data['unit_code'] ?? "";
        if(empty($data['unit_code_title'])) return [false, '主计量单位名称不能为空'];
        $unit_code_title = $data['unit_code_title'] ?? "";
        if(! empty($data['vendor_code_title']) && empty($data['vendor_code'])) return [false, '生产企业编码不能为空'];
        $vendor_code = $data['vendor_code'] ?? "";
        $vendor_code_title = $data['vendor_code_title'] ?? "";
        $bSale = $data['bSale'] ?? 0;
        $bExpSale = $data['bExpSale'] ?? 0;
        $bPurchase = $data['bPurchase'] ?? 0;
        $bSelf = $data['bSelf'] ?? 0;
        $bComsume = $data['bComsume'] ?? 0;
        $iImpTaxRate = $data['iImpTaxRate'] ?? 0;
        $iTaxRate = $data['iTaxRate'] ?? 0;
        $res = $this->checkNumber($iImpTaxRate,2,'positive');
        if(! $res['valid']) return [false,'进项税率：' . $res['error']];
        $res = $this->checkNumber($iTaxRate,2,'positive');
        if(! $res['valid']) return [false,'销项税率：' . $res['error']];
        $customs_change_rate = $data['customs_change_rate'] ?? 0;
        $res = $this->checkNumber($customs_change_rate,2,'positive');
        if(! $res['valid']) return [false,'海关换算率：' . $res['error']];

        if(! empty($code)){
            $bool = Inventory::where('del_time', 0)
                ->where('login_type', $user['login_type'])
                ->when(! empty($id), function ($query) use($id){
                    return $query->where('id', '<>', $id);
                })
                ->where('code', $code)
                ->exists();
            if($bool) return [false, '存货编码已存在记录，新增失败'];
        }

        if(! $is_add){
            $order = Inventory::where('id', $data['id'])->where('del_time',0)->first();
            if(empty($order)) return [false, '存货信息不存在或已被删除'];
            $order = $order->toArray();
            list($status, $msg) = $this->checkState(U8State::type_four, $user, $order['order_number']);
            if(! $status) return [false, $msg];
        }

        return [true, ''];
    }

    public function inventoryCommon($data, $user, $field = []){
        $type = U8State::type_four;
        $qx = $user['qx'];

        $model = Inventory::from('inventory as i')
            ->leftJoin('u8_state as s', function ($join) use ($type, $user) {
                $join->on('i.order_number', '=', 's.order_number')
                    ->where('s.type', '=', $type)
                    ->where('s.login_type', '=', $user['login_type'])
                    ->where('s.del_time', '=', 0);
            })
            ->where('i.del_time', 0)
            ->where('i.login_type', $user['login_type'])
            ->when(empty($qx), function ($query) use($user){
                return $query->where('v.crt_id', $user['userid']);
            })
            ->select('i.*', DB::raw('IFNULL(s.state, -1) as state'),'s.result')
            ->orderby('i.id', 'desc');

        // 2. 状态过滤逻辑
        if (isset($data['state']) && $data['state'] !== '') {
            $state_filter = $data['state'];
            if ($state_filter == -1) {
                // 未发起审批：在状态表里找不到记录
                $model->whereNull('s.state');
            } else {
                // 0:待审核 1:通过 2:驳回
                $model->where('s.state', $state_filter);
            }
        }

        if(! empty($data['code'])) $model->where('i.code', 'like', '%' . $data['code'] . '%');
        if(! empty($data['title'])) $model->where('i.title', 'like', '%' . $data['title'] . '%');
        if(! empty($data['id'])) $model->where('i.id', $data['id']);
        if(! empty($data['order_number'])) $model->where('i.order_number', 'like', '%' . $data['order_number'] . '%');

        if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
            $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
            $model->where('i.crt_time', '>=', $return[0]);
            $model->where('i.crt_time', '<=', $return[1]);
        }

        return $model;
    }

    public function inventoryDetail($data, $user){
       if(empty($data['id']) && empty($data['order_number'])) return [false, 'ID或流水号不能都为空'];
       list($status, $msg) = $this->inventoryList($data, $user);
       $return = $msg['data'][0] ?? [];

       return [true, $return];
    }

    public function inventoryList($data, $user){
        $model = $this->inventoryCommon($data, $user);
        $list = $this->limit($model,'',$data);
        $list = $this->fillInventoryData($list,$user);

        return [true, $list];
    }

    public function fillInventoryData($data, $user){
        if(empty($data['data'])) return $data;

        $e_map = DDEmployee::whereIn('userid', array_unique(array_column($data['data'], 'crt_id')))
            ->where('login_type', $user['login_type'])
            ->pluck('name', 'userid')
            ->toArray();
        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['bSale_title'] = $value['bSale'] ? '是' : '否';
            $data['data'][$key]['bExpSale_title'] = $value['bExpSale'] ? '是' : '否';
            $data['data'][$key]['bPurchase_title'] = $value['bPurchase'] ? '是' : '否';
            $data['data'][$key]['bSelf_title'] = $value['bSelf'] ? '是' : '否';
            $data['data'][$key]['bComsume_title'] = $value['bComsume'] ? '是' : '否';

            $data['data'][$key]['crt_name'] = $e_map[$value['crt_id']] ?? "";
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $data['data'][$key]['state_title'] = U8State::state_name[$value['state']];
        }

        return $data;
    }

    public function inventoryDel($data, $user){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];

        try {
            DB::beginTransaction();
            $time = time();

            $order = Inventory::where('id', $data['id'])->where('del_time',0)->first();
            if(empty($order)) return [false, '存货信息不存在或已被删除'];
            $order = $order->toArray();
            list($status, $msg) = $this->checkState(U8State::type_five, $user, $order['order_number']);
            if(! $status) return [false, $msg];

            Inventory::where('del_time',0)
                ->where('id',$data['id'])
                ->update(['del_time' => $time]);

            DB::commit();
        }catch (\Exception $exception){
            DB::rollBack();
            return [false,$exception->getMessage()];
        }

        return [true, ''];
    }

    //新增存货到本地-----------------------------------------------

    private function checkState($type, $user, $order_number){
        $lastRecord = U8State::where('del_time', 0)
            ->where('type', $type)
            ->where('login_type', $user['login_type'])
            ->where('order_number', $order_number)
            ->first(['state']); // 只取状态字段
        if ($lastRecord) {
            $text_o = U8State::type_name[$type];
            // 如果状态是 0 (待审核) 或 1 (审核通过)，拦截
            if (in_array($lastRecord->state, [U8State::state_zero, U8State::state_one])) {
                $text = U8State::state_name[$lastRecord->state];
                return [false, $text_o . ' (' . $order_number . ') 处于' . $text . '，操作失败'];
            }
        }

        return [true, ''];
    }

    //新增供应商到本地-----------------------------------------------

    public function vendorAdd($data, $user){
        list($status, $msg) = $this->vendorRule($data, $user);
        if(! $status) return [false, $msg];

        try {
            DB::beginTransaction();

            $vendorData = [
                'order_number' => $this->generateBillNo([
                    'type' => Vendor::Order_type,
                    'login_type' => $user['login_type'],
                    'period' => date("Ym")
                ]),
                'code' => "",
                'title' => $data['title'] ?? "",
                'easy_title' => $data['easy_title'] ?? "",
                'category_code' => $data['category_code'] ?? "",
                'category_code_title' => $data['category_code_title'] ?? "",
                'login_type' => $user['login_type'] ?? "",
                'crt_id' => $user['userid'],
                'crt_time' => time(),
            ];

            Vendor::insert($vendorData);

            DB::commit();
        } catch (\Throwable $exception) {
            DB::rollBack();
            return [false, "创建供应商失败: " . $exception->getMessage()];
        }

        return [true, ''];
    }

    public function vendorEdit($data, $user){
        list($status, $msg) = $this->vendorRule($data, $user, false);
        if(! $status) return [false, $msg];

        try {
            DB::beginTransaction();

            $vendorData = [
                'title' => $data['title'] ?? "",
                'easy_title' => $data['easy_title'] ?? "",
                'category_code' => $data['category_code'] ?? "",
                'category_code_title' => $data['category_code_title'] ?? "",
                'upd_time' => time(),
            ];

            Vendor::where('id', $data['id'])->update($vendorData);

            DB::commit();
        } catch (\Throwable $exception) {
            DB::rollBack();
            return [false, "编辑供应商失败: " . $exception->getMessage()];
        }

        return [true, ''];
    }

    public function vendorRule(&$data, $user, $is_add = true){
        if(! $is_add && empty($data['id'])) return [false, 'ID不能为空'];
        $id = $data['id'] ?? 0;
        $code = $data['code'] ?? "";
        if(empty($data['title'])) return [false, '供应商全称不能为空'];
        $title = $data['title'];
        if(empty($data['easy_title'])) return [false, '供应商简称不能为空'];
        $easy_title = $data['easy_title'];
        if(empty($data['category_code'])) return [false, '供应商分类编码不能为空'];
        $category_code = $data['category_code'];
        if(empty($data['category_code_title'])) return [false, '供应商分类名不能为空'];
        $category_code_title = $data['category_code_title'];

        if(! empty($code)){
            $bool = Vendor::where('del_time', 0)
                ->when(! empty($id), function ($query) use($id){
                    return $query->where('id', '<>', $id);
                })
                ->where('code', $code)
                ->exists();
            if($bool) return [false, '供应商编码已存在记录，新增失败'];
        }
        $bool = Vendor::where('del_time',0)
            ->when(! empty($id), function ($query) use($id){
                return $query->where('id', '<>', $id);
            })
            ->where('easy_title', $easy_title)
            ->exists();
        if($bool) return [false, '供应商简称已存在记录'];

        if(! $is_add){
            $order = Vendor::where('id', $data['id'])->where('del_time',0)->first();
            if(empty($order)) return [false, '供应商信息不存在或已被删除'];
            $order = $order->toArray();
            list($status, $msg) = $this->checkState(U8State::type_five, $user, $order['order_number']);
            if(! $status) return [false, $msg];
        }

        return [true, ''];
    }

    public function vendorCommon($data, $user, $field = []){
        $type = U8State::type_five;
        $qx = $user['qx'];

        $model = Vendor::from('vendor as v')
            ->leftJoin('u8_state as s', function ($join) use ($type, $user) {
                $join->on('v.order_number', '=', 's.order_number')
                    ->where('s.type', '=', $type)
                    ->where('s.login_type', '=', $user['login_type'])
                    ->where('s.del_time', '=', 0);
            })
            ->where('v.del_time', 0)
            ->when(empty($qx), function ($query) use($user){
                return $query->where('v.crt_id', $user['userid']);
            })
            ->select('v.*', DB::raw('IFNULL(s.state, -1) as state'),'s.result')
            ->orderby('v.id', 'desc');

        if (isset($data['state']) && $data['state'] !== '') {
            $state_filter = $data['state'];
            if ($state_filter == -1) {
                // 未发起审批：u8_states 表里没记录，s.id 就会是 NULL
                $model->whereNull('s.id');
            } else {
                // 0:待审核 1:通过 2:驳回
                $model->where('s.state', $state_filter);
            }
        }

        if(! empty($data['easy_title'])) $model->where('v.easy_title', 'like', '%' . $data['easy_title'] . '%');
        if(! empty($data['code'])) $model->where('v.code', 'like', '%' . $data['code'] . '%');
        if(! empty($data['title'])) $model->where('v.title', 'like', '%' . $data['title'] . '%');
        if(! empty($data['id'])) $model->where('v.id', $data['id']);
        if(! empty($data['order_number'])) $model->where('v.order_number', 'like', '%' . $data['order_number'] . '%');
        if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
            $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
            $model->where('v.crt_time', '>=', $return[0]);
            $model->where('v.crt_time', '<=', $return[1]);
        }

        return $model;
    }

    public function vendorList($data, $user){
        $model = $this->vendorCommon($data, $user);
        $list = $this->limit($model,'',$data);
        $list = $this->fillVendorData($list,$user);

        return [true, $list];
    }

    public function fillVendorData($data, $user){
        if(empty($data['data'])) return $data;

        $e_map = DDEmployee::whereIn('userid', array_unique(array_column($data['data'], 'crt_id')))
            ->where('login_type', $user['login_type'])
            ->pluck('name', 'userid')
            ->toArray();
        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['crt_name'] = $e_map[$value['crt_id']] ?? "";
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $data['data'][$key]['state_title'] = U8State::state_name[$value['state']];
        }

        return $data;
    }

    public function vendorDetail($data, $user){
        if(empty($data['id']) && empty($data['order_number'])) return [false, 'ID或流水号不能都为空'];
        list($status, $msg) = $this->vendorList($data, $user);
        $return = $msg['data'][0] ?? [];

        return [true, $return];
    }

    public function vendorDel($data, $user){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];

        try {
            DB::beginTransaction();
            $time = time();

            $order = Vendor::where('id', $data['id'])->where('del_time',0)->first();
            if(empty($order)) return [false, '供应商信息不存在或已被删除'];
            $order = $order->toArray();
            list($status, $msg) = $this->checkState(U8State::type_five, $user, $order['order_number']);
            if(! $status) return [false, $msg];

            Vendor::where('del_time',0)
                ->where('id',$data['id'])
                ->update(['del_time' => $time]);

            DB::commit();
        }catch (\Exception $exception){
            DB::rollBack();
            return [false,$exception->getMessage()];
        }

        return [true, ''];
    }

    public function getField($data, $user){
        if(empty($data['type'])) return [false, 'type类型不能为空'];
        $type = $data['type'];
        $config  = config("field.{$type}") ?? [];

        return [true, $config];
    }

    public function filedCommon($data, $user, $field = []){
        $type = $data['type'] ?? null;
        $name = $data['name'] ?? null;
        $model = Field::where('login_type', $user['login_type'])
            ->when(! empty($type), function ($query) use($type){
                return $query->where('type', $type);
            })
            ->when(! empty($name), function ($query) use($name, $user){
                $id = DDEmployee::where('login_type', $user['login_type'])
                    ->where('name', 'like', '%' . $name . '%')
                    ->pluck('userid')
                    ->toArray();
                return $query->whereIn('userid', $id);
            })
            ->select('id','userid','type');

        return $model;
    }

    public function fieldList($data, $user){
        if(empty($user['qx'])) return [false, '权限不足'];
        $model = $this->filedCommon($data, $user);
        $list = $this->limit($model,'',$data);
        $list = $this->fillFieldData($list,$user);

        return [true, $list];
    }

    public function fillFieldData($data, $user){
        if(empty($data['data'])) return $data;

        $map = DDEmployee::whereIn('userid', array_unique(array_column($data['data'],'userid')))
            ->pluck('name', 'userid')
            ->toArray();
        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['user_title'] = $map[$value['userid']] ?? '';
            $data['data'][$key]['type_title'] = FieldData::$name[$value['type']] ?? '';
        }

        return $data;
    }

    public function fieldDetail($data, $user){
        if(empty($user['qx'])) return [false, '权限不足'];
        if(empty($data['id'])) return [false, 'ID不能为空'];
        $order = Field::where('id', $data['id'])->first();
        if(empty($order)) return ['字段设置不存在或已删除'];
        $order = $order->toArray();
        $order['user_title'] = DDEmployee::where('userid', $order['userid'])
            ->value('name');
        $order['field'] = FieldData::where('field_id', $order['id'])
            ->get()->toArray();

        return [true, $order];
    }

    public function setFieldAdd($data, $user){
        list($status, $msg) = $this->setFieldRule($data, $user);
        if(! $status) return [false, $msg];

        try {

            // 1. 插入主表并获取实例
            $mainField = Field::create([
                'userid'     => $data['userid'],
                'crt_id'     => $user['userid'],
                'type'       => $data['type'],
                'login_type' => $user['login_type']
            ]);

            // 2. 获取返回的 ID
            $parentId = $mainField->id;

            // 3. 构造并插入子表数据
            $insert = [];
            foreach ($data['field'] as $value){
                $insert[] = [
                    'field_id'   => $parentId, // 将主表 ID 关联到子表
                    'userid'     => $data['userid'],
                    'key'        => $value['key'],
                    'title'      => $value['title'],
                    'login_type' => $user['login_type'],
                    'type'       => $data['type'],
                ];
            }

            FieldData::insert($insert);
        } catch (\Throwable $exception) {
            return [false, "异常: " . $exception->getMessage()];
        }

        return [true, ''];
    }

    public function setFieldEdit($data, $user){
        list($status, $msg) = $this->setFieldRule($data, $user, false);
        if(! $status) return [false, $msg];

        try {
            $insert = [];
            foreach ($data['field'] as $value){
                $insert[] = [
                    'field_id'   => $data['id'], // 将主表 ID 关联到子表
                    'userid' => $data['userid'],
                    'key' => $value['key'],
                    'title' => $value['title'],
                    'login_type' => $user['login_type'],
                    'type'       => $data['type'],
                ];
            }
            FieldData::where('field_id', $data['id'])->delete();
            FieldData::insert($insert);
        } catch (\Throwable $exception) {
            return [false, "异常: " . $exception->getMessage()];
        }

        return [true, ''];
    }

    public function setFieldRule(&$data, $user, $is_add = true){
        if(! $is_add && empty($data['id'])) return [false, 'ID不能为空'];
        $id = $data['id'] ?? 0;
        if(empty($user['qx'])) return [false, '权限不足，设置失败'];
        if(empty($data['userid'])) return [false, '人员ID不能为空'];
        if(empty($data['type'])) return [false, '设置类型不能为空'];
        if(empty($data['field'])) return [false, '字段列不存在'];
        foreach ($data['field'] as $value){
            if(empty($value['key'])) return [false, '字段名不能为空'];
            if(empty($value['title'])) return [false, '字段中文名不能为空'];
        }

        if(! $is_add){
            $order = Field::where('id', $id)->first();
            if(empty($order)) return [false, '字段信息不存在或已被删除'];
        }else{
            $bool = Field::where('userid', $data['userid'])->exists();
            if($bool) return [false, '该人员字段设置已存在，请勿重复新增'];
        }

        return [true, ''];
    }

    public function fieldDel($data, $user){
        if(empty($data['id'])) return [false, 'ID不能为空'];
        if(empty($user['qx'])) return [false, '权限不足'];
        $order = Field::where('id', $data['id'])->first();
        if(empty($order)) return ['字段设置不存在或已删除'];

        try {
            DB::beginTransaction();

            Field::where('id', $data['id'])->delete();
            FieldData::where('field_id', $data['id'])->delete();

            DB::commit();
        }catch (\Throwable $exception){
            DB::rollBack();
            return [false, $exception->getMessage()];
        }

        return [true, $order];
    }

    public function ddEmployeeList($data, $user){
        $model = $this->ddEmployeeCommon($data, $user);
        $list = $this->limit($model,'',$data);
        $list = $this->fillDDEmployeeData($list,$user);

        return [true, $list];
    }

    public function ddEmployeeCommon($data,$user, $field = []){
        $model = DDEmployee::where('login_type', $user['login_type'])
            ->select('*')
            ->orderby('id', 'desc');

        if(! empty($data['id'])) $model->where('id', $data['id']);
        if(! empty($data['name'])) $model->where('name', 'like', '%' . $data['name'] . '%');
        if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
            $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
            $model->where('crt_time','>=',$return[0]);
            $model->where('crt_time','<=',$return[1]);
        }

        return $model;
    }

    public function fillDDEmployeeData($data, $user){
        if(empty($data['data'])) return $data;

        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
        }

        return $data;
    }

    //新增供应商到本地-----------------------------------------------

    //新增采购请购单到本地--------------------------------------------

    public function purchaseRequisitionAdd($data, $user){
        list($status, $msg) = $this->purchaseRequisitionRule($data, $user);
        if(! $status) return [false, $msg];

        try {
            DB::beginTransaction();

            $model = new PuAppVouch();
            $model->order_number = $this->generateBillNo([
                'type' => PuAppVouch::Order_type,
                'login_type' => $user['login_type'],
                'period' => date("Ym")
            ]);
            $model->order_time = $data['order_time'];
            $model->cBusType = $data['cBusType']; // 业务类型前端写死
            $model->cPTCode = $data['cPTCode'];
            $model->cPTCodeTitle = $data['cPTCodeTitle'];
            $model->mark = $data['mark'] ?? '';
            $model->login_type = $user['login_type'];
            $model->crt_id = $user['userid'];
            $model->save();

            $this->saveDetail($model->id, $data);

            DB::commit();
        } catch (\Throwable $exception) {
            DB::rollBack();
            return [false, $exception->getMessage()];
        }

        return [true, ''];
    }

    private function saveDetail($id, $data){
        if(! empty($data['detail'])){
            $unit = [];
            foreach ($data['detail'] as $value){
                $unit[] = [
                    'main_id' => $id,
                    'cInvCode' => $value['cInvCode'],
                    'quantity' => $value['quantity'],
                    'price' => $value['price'] ?? 0,
                    'dRequirDate' => $value['dRequirDate'],
                    'dArriveDate' => $value['dArriveDate'],
                    'rate' => $value['rate'],
                    'name' => $value['name'],
                    'size' => $value['size'] ?? '',
                    'unit' => $value['unit'] ?? '',
                ];
            }
            if(! empty($unit)) PuAppVouchs::insert($unit);
        }
    }

    private function getDetail($id){
        $data = PuAppVouchs::where('del_time',0)
            ->where('main_id', $id)
            ->get()->toArray();

        $detail = [
            'detail' => $data,
        ];

        return $detail;
    }

    public function purchaseRequisitionEdit($data, $user){
        list($status, $msg) = $this->purchaseRequisitionRule($data, $user, false);
        if(! $status) return [false, $msg];

        try {
            DB::beginTransaction();

            $model = PuAppVouch::where('id', $data['id'])->first();
            $model->order_time = $data['order_time'];
            $model->cBusType = $data['cBusType'];
            $model->cPTCode = $data['cPTCode'];
            $model->cPTCodeTitle = $data['cPTCodeTitle'];
            $model->mark = $data['mark'] ?? '';
            $model->save();

            PuAppVouchs::where('del_time',0)
                ->where('main_id', $data['id'])
                ->update(['del_time' => time()]);

            $this->saveDetail($model->id, $data);

            DB::commit();
        } catch (\Throwable $exception) {
            DB::rollBack();
            return [false, "编辑请购单失败: " . $exception->getMessage()];
        }

        return [true, ''];
    }

    public function purchaseRequisitionRule(&$data, $user, $is_add = true){
        if(! $is_add && empty($data['id'])) return [false, 'ID不能为空'];
        $id = $data['id'] ?? 0;

        if(empty($data['order_time'])) return [false, '单据日期不能为空'];
        $orderTime = trim($data['order_time']);
        if (!preg_match('/^\d{4}-\d{2}-\d{2}$/', $orderTime) || strtotime($orderTime) === false) {
            return [false, '单据日期格式不正确，必须为 YYYY-MM-DD 格式（如：2026-04-04）'];
        }

        if(empty($data['detail'])) return [false, '表体不能为空'];
        foreach ($data['detail'] as $key => $value){
            $line = "第 " . ($key + 1) . "行";
            if(empty($value['cInvCode'])) return [false, $line . '存货编码不能为空'];
            if(empty($value['name'])) return [false, $line . '存货名称不能为空'];
            if(! is_numeric($value['quantity']) || floatval($value['quantity']) <= 0.0) return [false, $line . '存货数量不正常'];
            if(! isset($value['rate']) || ! is_numeric($value['rate'])) return [false, $line . '税率为空或非数字'];

            if(empty($value['dRequirDate'])) return [false, $line . '需求日期不能为空'];
            if(empty($value['dArriveDate'])) return [false, $line . '建议订货日期不能为空'];

            $dRequirDate = trim($value['dRequirDate']);
            $dArriveDate = trim($value['dArriveDate']);

            if (!preg_match('/^\d{4}-\d{2}-\d{2}$/', $dRequirDate) || strtotime($dRequirDate) === false) {
                return [false, $line . "需求日期格式不正确，必须为 YYYY-MM-DD"];
            }
            if (!preg_match('/^\d{4}-\d{2}-\d{2}$/', $dArriveDate) || strtotime($dArriveDate) === false) {
                return [false, $line . "建议订货日期格式不正确，必须为 YYYY-MM-DD"];
            }

            $timeOrder = strtotime($orderTime);
            $timeRequir = strtotime($dRequirDate);
            $timeArrive = strtotime($dArriveDate);

            if ($timeArrive < $timeOrder) {
                return [false, $line . "建议订货日期（{$dArriveDate}）不能早于单据日期（{$orderTime}）"];
            }
            if ($timeRequir < $timeArrive) {
                return [false, $line . "需求日期（{$dRequirDate}）不能早于建议订货日期（{$dArriveDate}）"];
            }
        }

        if(! $is_add){
            $order = PuAppVouch::where('id', $data['id'])->where('del_time',0)->first();
            if(empty($order)) return [false, '请购单信息不存在或已被删除'];
            $order = $order->toArray();
            list($status, $msg) = $this->checkState(U8State::type_two, $user, $order['order_number']);
            if(! $status) return [false, $msg];
        }

        return [true, ''];
    }

    public function purchaseRequisitionCommon($data, $user, $field = []){
        $type = U8State::type_two;
        $qx = $user['qx'];

        $model = PuAppVouch::from('pu_appvouch as v')
            ->leftJoin('u8_state as s', function ($join) use ($type, $user) {
                $join->on('v.order_number', '=', 's.order_number')
                    ->where('s.type', '=', $type)
                    ->where('s.login_type', '=', $user['login_type'])
                    ->where('s.del_time', '=', 0);
            })
            ->where('v.del_time', 0)
            ->where('v.login_type', $user['login_type'])
            ->when(empty($qx), function ($query) use($user){
                return $query->where('v.crt_id', $user['userid']);
            })
            ->select('v.*', DB::raw('IFNULL(s.state, -1) as state'),'s.result')
            ->orderby('v.id', 'desc');

        if (isset($data['state']) && $data['state'] !== '') {
            $state_filter = $data['state'];
            if ($state_filter == -1) {
                // 未发起审批：u8_states 表里没记录，s.id 就会是 NULL
                $model->whereNull('s.id');
            } else {
                // 0:待审核 1:通过 2:驳回
                $model->where('s.state', $state_filter);
            }
        }

        if(! empty($data['code'])) $model->where('v.code', 'like', '%' . $data['code'] . '%');
        if(! empty($data['id'])) $model->where('v.id', $data['id']);
        if(! empty($data['order_number'])) $model->where('v.order_number', 'like', '%' . $data['order_number'] . '%');
        if(! empty($data['order_time'])) $model->where('v.order_time', $data['order_time']);
        if(! empty($data['crt_id'])) $model->where('v.crt_id', $data['crt_id']);
        if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
            $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
            $model->where('v.crt_time', '>=', $return[0]);
            $model->where('v.crt_time', '<=', $return[1]);
        }

        return $model;
    }

    public function purchaseRequisitionList($data, $user){
        $model = $this->purchaseRequisitionCommon($data, $user);
        $list = $this->limit($model,'',$data);
        $list = $this->fillPurchaseRequisitionData($list,$user);

        return [true, $list];
    }

    public function fillPurchaseRequisitionData($data, $user){
        if(empty($data['data'])) return $data;

        $e_map = DDEmployee::whereIn('userid', array_unique(array_column($data['data'], 'crt_id')))
            ->where('login_type', $user['login_type'])
            ->pluck('name', 'userid')
            ->toArray();
        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['crt_name'] = $e_map[$value['crt_id']] ?? "";
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $data['data'][$key]['state_title'] = U8State::state_name[$value['state']];
            $this->fillStateDetail($data['data'][$key]);
        }

        return $data;
    }

    public function purchaseRequisitionMyDetail($data, $user){
        $id = $data['id'] ?? 0;
        $order_number = $data['order_number'] ?? "";
        if(empty($id) && empty($order_number)) return [false,'请选择数据'];

        $customer = PuAppVouch::where('del_time',0)
            ->when(! empty($id), function ($query) use($id){
                return $query->where('id', $id);
            })
            ->when(! empty($order_number), function ($query) use($order_number){
                return $query->where('order_number', $order_number);
            })
            ->where('login_type', $user['login_type'])
            ->first();
        if(empty($customer)) return [false,'采购请购单不存在或已被删除'];
        $customer = $customer->toArray();
        $customer['crt_name'] = DDEmployee::where('userid',$customer['crt_id'])->value('name');
        $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';

        $details = $this->getDetail($customer['id']);
        $customer = array_merge($customer, $details);

        return [true, $customer];
    }

    public function purchaseRequisitionDel($data, $user){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];

        try {
            DB::beginTransaction();
            $time = time();

            $order = PuAppVouch::where('id', $data['id'])->where('del_time',0)->first();
            if(empty($order)) return [false, '请购单信息不存在或已被删除'];
            $order = $order->toArray();
            list($status, $msg) = $this->checkState(U8State::type_two, $user, $order['order_number']);
            if(! $status) return [false, $msg];

            PuAppVouch::where('del_time',0)
                ->where('id',$data['id'])
                ->update(['del_time' => $time]);

            PuAppVouchs::where('del_time',0)
                ->where('main_id',$data['id'])
                ->update(['del_time' => $time]);

            DB::commit();
        }catch (\Exception $exception){
            DB::rollBack();
            return [false,$exception->getMessage()];
        }

        return [true, ''];
    }

    //新增采购订单到本地--------------------------------------------

    public function purchaseOrderAdd($data, $user){
        list($status, $msg) = $this->purchaseOrderRule($data, $user);
        if(! $status) return [false, $msg];

        try {
            DB::beginTransaction();

            $model = new PoPomain();
            $model->order_number = $this->generateBillNo([
                'type' => PoPomain::Order_type,
                'login_type' => $user['login_type'],
                'period' => date("Ym")
            ]);
            $model->order_time = $data['order_time'];
            $model->cBusType = $data['cBusType'];
            $model->cPTCode = $data['cPTCode'];
            $model->cPTCodeTitle = $data['cPTCodeTitle'];
            $model->cVenCode = $data['cVenCode'];
            $model->cVenCodeTitle = $data['cVenCodeTitle'];
            $model->cappcode = !empty($data['cappcode']) ? (array)$data['cappcode'] : [];
            $model->nflat = $data['nflat'] ?? 1;
            $model->cexch_name = $data['cexch_name'] ?? '人民币';
            $model->iTaxRate = $data['iTaxRate'] ?? 13;
            $model->mark = $data['mark'] ?? '';
            $model->login_type = $user['login_type'];
            $model->crt_id = $user['userid'];
            $model->save();

            $this->saveODetail($model->id, $data);

            DB::commit();
        } catch (\Throwable $exception) {
            DB::rollBack();
            return [false, $exception->getMessage()];
        }

        return [true, ''];
    }

    private function saveODetail($id, $data){
        if(! empty($data['detail'])){
            $unit = [];
            foreach ($data['detail'] as $value){
                $unit[] = [
                    'main_id' => $id,
                    'iAppIds' => $value['iAppIds'] ?? 0,
                    'cInvCode' => $value['cInvCode'],
                    'quantity' => $value['quantity'],
                    'price' => $value['price'],
                    'rate' => $value['rate'],
                    'dArriveDate' => $value['dArriveDate'],
                    'name' => $value['name'],
                    'size' => $value['size'] ?? '',
                    'unit' => $value['unit'] ?? '',
                ];
            }
            if(! empty($unit)) PoPodetails::insert($unit);
        }
    }

    private function getODetail($id){
        $data = PoPodetails::where('del_time',0)
            ->where('main_id', $id)
            ->get()->toArray();

        $detail = [
            'detail' => $data,
        ];

        return $detail;
    }

    public function purchaseOrderEdit($data, $user){
        list($status, $msg) = $this->purchaseOrderRule($data, $user, false);
        if(! $status) return [false, $msg];

        try {
            DB::beginTransaction();

            $model = PoPomain::where('id', $data['id'])->first();
            $model->order_time = $data['order_time'];
            $model->cBusType = $data['cBusType'];
            $model->cPTCode = $data['cPTCode'];
            $model->cPTCodeTitle = $data['cPTCodeTitle'];
            $model->cVenCode = $data['cVenCode'];
            $model->cVenCodeTitle = $data['cVenCodeTitle'];
            $model->cappcode = !empty($data['cappcode']) ? (array)$data['cappcode'] : [];
            $model->iTaxRate = $data['iTaxRate'] ?? 13;
            $model->nflat = $data['nflat'] ?? 1;
            $model->cexch_name = $data['cexch_name'] ?? '人民币';
            $model->mark = $data['mark'] ?? '';
            $model->save();

            PoPodetails::where('del_time',0)
                ->where('main_id', $data['id'])
                ->update(['del_time' => time()]);

            $this->saveODetail($model->id, $data);

            DB::commit();
        } catch (\Throwable $exception) {
            DB::rollBack();
            return [false, "编辑采购订单失败: " . $exception->getMessage()];
        }

        return [true, ''];
    }

    public function purchaseOrderRule(&$data, $user, $is_add = true)
    {
        if(! $is_add && empty($data['id'])) return [false, 'ID不能为空'];
        $id = $data['id'] ?? 0;

        if(empty($data['order_time'])) return [false, '单据日期不能为空'];
        $orderTime = trim($data['order_time']);
        if (!preg_match('/^\d{4}-\d{2}-\d{2}$/', $orderTime) || strtotime($orderTime) === false) {
            return [false, '单据日期格式不正确，必须为 YYYY-MM-DD 格式（如：2026-04-04）'];
        }
        if(empty($data['cVenCode']) || empty($data['cVenCodeTitle'])) return [false, '供应商信息不能为空'];

        // ==================== 核心修改：支持 JSON 字符串单号强校验 ====================
        $u8DetailsMap = [];
        $isRefApp = !empty($data['cappcode']);
        if($isRefApp && ! is_array($data['cappcode'])) return [false, '请购单号非数组结构'];

        if ($isRefApp) {
            $service = new U8ServerService($user);
            $error = $service->getError();
            if(! empty($error)) return [false, $error];

            // 1. 规整单号为干净的数组
            $cappcodes = $data['cappcode'];
            $cappcodes = array_filter(array_map('trim',$cappcodes));

            // 【优化】如果数组被过滤后变空了，说明没有真正的参照单号，将 $isRefApp 标记为 false 即可，不直接报错
            if (empty($cappcodes)) {
                $isRefApp = false;
            } else {
                // 2. 调用用友接口，获取最新的可用明细
                list($status, $u8Details) = $service->getRequisitionDetailsByCode($cappcodes);
                if(! $status) return [false, $u8Details];

                foreach ($u8Details as $u8Item) {
                    $u8DetailsMap[$u8Item['detail_id']] = $u8Item;
                }

                // 3. 统计本地已预占的数量
                $localOccupiedQuery = DB::table('po_pomain as m')
                    ->join('po_podetails as d', 'd.main_id', '=', 'm.id')
                    ->where('m.del_time', 0)
                    ->where('d.del_time', 0)
                    ->where('m.code', ''); // 还没同步成功

                // 如果是编辑操作，排除自身
                if (!$is_add) {
                    $localOccupiedQuery->where('m.id', '!=', $id);
                }

                // 使用 JSON_CONTAINS 匹配本地主表中的 JSON 字段
                $localOccupiedQuery->where(function ($query) use ($cappcodes) {
                    foreach ($cappcodes as $index => $code) {
                        if ($index === 0) {
                            $query->whereRaw('JSON_CONTAINS(m.cappcode, ?)', ['"' . $code . '"']);
                        } else {
                            $query->orWhereRaw('JSON_CONTAINS(m.cappcode, ?)', ['"' . $code . '"']);
                        }
                    }
                });

                // 聚合得出被预占的总数量
                $localOccupiedRows = $localOccupiedQuery->select(
                    'd.iAppIds',
                    DB::raw('SUM(d.quantity) as total_qty')
                )
                    ->groupBy('d.iAppIds')
                    ->get();

                $localOccupiedMap = [];
                foreach ($localOccupiedRows as $row) {
                    $localOccupiedMap[$row->iAppIds] = (float)$row->total_qty;
                }
            }
        }
        // ====================================================================

        if(empty($data['detail'])) return [false, '表体不能为空'];
        foreach ($data['detail'] as $key => $value){
            $line = "第 " . ($key + 1) . "行";
            if(empty($value['cInvCode'])) return [false, $line . '存货编码不能为空'];
            if(empty($value['name'])) return [false, $line . '存货名称不能为空'];

            $currentQty = floatval($value['quantity'] ?? 0);
            if(! is_numeric($value['quantity']) || $currentQty <= 0.0) return [false, $line . '存货数量不正常'];
            if(! isset($value['rate']) || ! is_numeric($value['rate'])) return [false, $line . '税率为空或非数字'];

            if(empty($value['dArriveDate'])) return [false, $line . '建议订货日期不能为空'];

            $dArriveDate = trim($value['dArriveDate']);
            if (!preg_match('/^\d{4}-\d{2}-\d{2}$/', $dArriveDate) || strtotime($dArriveDate) === false) {
                return [false, $line . "计划到货日期格式不正确，必须为 YYYY-MM-DD"];
            }

            $timeOrder = strtotime($orderTime);
            $timeArrive = strtotime($dArriveDate);
            if ($timeArrive < $timeOrder) {
                return [false, $line . "计划到货日期（{$dArriveDate}）不能早于单据日期（{$orderTime}）"];
            }

            // ==================== 逐行精确匹配校验数量（混合单据核心修改） ====================
            // 【关键改动】：不仅表头是参照，且当前行有具体的请购单明细ID（iAppIds > 0），才进行用友和本地库存校验
            $iAppIds = isset($value['iAppIds']) ? (int)$value['iAppIds'] : 0;

            if ($isRefApp && $iAppIds > 0) {

                if (!isset($u8DetailsMap[$iAppIds])) {
                    return [false, $line . "对应的请购单明细在用友系统已无剩余可用量或该请购单号输入有误，请刷新数据！"];
                }

                $u8RefCode = $u8DetailsMap[$iAppIds]['cappcode'];
                $u8AvailableQty = (float)$u8DetailsMap[$iAppIds]['available_qty'];
                $localOccupiedQty = $localOccupiedMap[$iAppIds] ?? 0.0;

                $realAvailableQty = $u8AvailableQty - $localOccupiedQty;

                if ($currentQty > $realAvailableQty) {
                    if ($localOccupiedQty > 0) {
                        return [false, $line . "【请购单:{$u8RefCode}】可下单数量不足！用友剩余: {$u8AvailableQty}，本地在途预占: {$localOccupiedQty}，实际可用仅剩: {$realAvailableQty}，当前输入: {$currentQty}"];
                    } else {
                        return [false, $line . "【请购单:{$u8RefCode}】可下单数量不足！用友系统最大可用量为: {$u8AvailableQty}，当前输入: {$currentQty}"];
                    }
                }
            }
            // ====================================================================
        }

        if(! $is_add){
            $order = PoPomain::where('id', $data['id'])->where('del_time',0)->first();
            if(empty($order)) return [false, '采购单信息不存在或已被删除'];
            $order = $order->toArray();
            list($status, $msg) = $this->checkState(U8State::type_one, $user, $order['order_number']);
            if(! $status) return [false, $msg];
        }

        return [true, ''];
    }

    public function purchaseOrderCommon($data, $user, $field = []){
        $type = U8State::type_one;
        $qx = $user['qx'];

        $model = PoPomain::from('po_pomain as v')
            ->leftJoin('u8_state as s', function ($join) use ($type, $user) {
                $join->on('v.order_number', '=', 's.order_number')
                    ->where('s.type', '=', $type)
                    ->where('s.login_type', '=', $user['login_type'])
                    ->where('s.del_time', '=', 0);
            })
            ->where('v.del_time', 0)
            ->where('v.login_type', $user['login_type'])
            ->when(empty($qx), function ($query) use($user){
                return $query->where('v.crt_id', $user['userid']);
            })
            ->select('v.*', DB::raw('IFNULL(s.state, -1) as state'),'s.result')
            ->orderby('v.id', 'desc');

        if (isset($data['state']) && $data['state'] !== '') {
            $state_filter = $data['state'];
            if ($state_filter == -1) {
                // 未发起审批：u8_states 表里没记录，s.id 就会是 NULL
                $model->whereNull('s.id');
            } else {
                // 0:待审核 1:通过 2:驳回
                $model->where('s.state', $state_filter);
            }
        }

        if(! empty($data['code'])) $model->where('v.code', 'like', '%' . $data['code'] . '%');
        if(! empty($data['id'])) $model->where('v.id', $data['id']);
        if(! empty($data['order_number'])) $model->where('v.order_number', 'like', '%' . $data['order_number'] . '%');
        if(! empty($data['order_time'])) $model->where('v.order_time', $data['order_time']);
        if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
            $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
            $model->where('v.crt_time', '>=', $return[0]);
            $model->where('v.crt_time', '<=', $return[1]);
        }
        if(! empty($data['crt_id'])) $model->where('v.crt_id', $data['crt_id']);

        return $model;
    }

    public function purchaseOrderList($data, $user){
        $model = $this->purchaseOrderCommon($data, $user);
        $list = $this->limit($model,'',$data);
        $list = $this->fillPurchaseOrderData($list,$user);

        return [true, $list];
    }

    public function fillPurchaseOrderData($data, $user){
        if(empty($data['data'])) return $data;

        $e_map = DDEmployee::whereIn('userid', array_unique(array_column($data['data'], 'crt_id')))
            ->where('login_type', $user['login_type'])
            ->pluck('name', 'userid')
            ->toArray();
        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['crt_name'] = $e_map[$value['crt_id']] ?? "";
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $data['data'][$key]['state_title'] = U8State::state_name[$value['state']];
            $this->fillStateDetail($data['data'][$key]);
        }

        return $data;
    }

    public function purchaseOrderMyDetail($data, $user){
        $id = $data['id'] ?? 0;
        $order_number = $data['order_number'] ?? "";
        if(empty($id) && empty($order_number)) return [false,'请选择数据'];

        $customer = PoPomain::where('del_time',0)
            ->when(! empty($id), function ($query) use($id){
                return $query->where('id', $id);
            })
            ->when(! empty($order_number), function ($query) use($order_number){
                return $query->where('order_number', $order_number);
            })
            ->where('login_type', $user['login_type'])
            ->first();
        if(empty($customer)) return [false,'采购订单不存在或已被删除'];
        $customer = $customer->toArray();
        $customer['crt_name'] = DDEmployee::where('userid',$customer['crt_id'])->value('name');
        $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';

        $details = $this->getODetail($customer['id']);
        $customer = array_merge($customer, $details);

        return [true, $customer];
    }

    public function purchaseOrderDel($data, $user){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];

        try {
            DB::beginTransaction();
            $time = time();

            $order = PoPomain::where('id', $data['id'])->where('del_time',0)->first();
            if(empty($order)) return [false, '采购订单信息不存在或已被删除'];
            $order = $order->toArray();
            list($status, $msg) = $this->checkState(U8State::type_one, $user, $order['order_number']);
            if(! $status) return [false, $msg];

            PoPomain::where('del_time',0)
                ->where('id',$data['id'])
                ->update(['del_time' => $time]);

            PoPodetails::where('del_time',0)
                ->where('main_id',$data['id'])
                ->update(['del_time' => $time]);

            DB::commit();
        }catch (\Exception $exception){
            DB::rollBack();
            return [false,$exception->getMessage()];
        }

        return [true, ''];
    }

    // 新增采购入库单到本地

    public function purchaseOrderInAdd($data, $user)
    {
        list($status, $msg) = $this->purchaseOrderInRule($data, $user);
        if (!$status) return [false, $msg];

        try {
            DB::beginTransaction();

            $model = new RdRecord01();
            $model->order_number = $this->generateBillNo([
                'type' => RdRecord01::Order_type,
                'login_type' => $user['login_type'],
                'period' => date("Ym")
            ]);
            $model->order_time         = $data['order_time'];
            $model->cBusType            = $data['cBusType'] ?? '普通采购';
            $model->cPTCode             = $data['cPTCode'];
            $model->cPTCodeTitle        = $data['cPTCodeTitle'];
            $model->cVenCode            = $data['cVenCode'];
            $model->cVenCodeTitle       = $data['cVenCodeTitle'];
            // 存储采购订单号数组为 JSON
            $model->cOrderCode = !empty($data['cOrderCode']) ? (array)$data['cOrderCode'] : [];
            $model->warehouseCode       = $data['warehouseCode'];
            $model->warehouseCodeTitle  = $data['warehouseCodeTitle'];
            $model->cRdCode             = $data['cRdCode'];
            $model->cRdCodeTitle        = $data['cRdCodeTitle'];
            $model->bredvouch           = isset($data['bredvouch']) ? (int)$data['bredvouch'] : 0; // 0蓝 1红
            $model->iTaxRate            = $data['iTaxRate'] ?? 13;
            $model->nflat               = $data['nflat'] ?? 1;
            $model->cexch_name          = $data['cexch_name'] ?? '人民币';
            $model->mark                = $data['mark'] ?? '';
            $model->login_type          = $user['login_type'];
            $model->crt_id              = $user['userid'];
            $model->save();

            $this->saveOIDetail($model->id, $data);

            DB::commit();
        } catch (\Throwable $exception) {
            DB::rollBack();
            return [false, "新增采购入库单失败: " . $exception->getMessage()];
        }

        return [true, ''];
    }

    public function purchaseOrderInEdit($data, $user)
    {
        list($status, $msg) = $this->purchaseOrderInRule($data, $user, false);
        if (!$status) return [false, $msg];

        try {
            DB::beginTransaction();

            $model = RdRecord01::where('id', $data['id'])->first();
            if (empty($model)) return [false, '单据不存在'];

            $model->order_time         = $data['order_time'];
            $model->cBusType            = $data['cBusType'] ?? '普通采购';
            $model->cPTCode             = $data['cPTCode'];
            $model->cPTCodeTitle        = $data['cPTCodeTitle'];
            $model->cVenCode            = $data['cVenCode'];
            $model->cVenCodeTitle       = $data['cVenCodeTitle'];
            $model->cOrderCode = !empty($data['cOrderCode']) ? (array)$data['cOrderCode'] : [];
            $model->warehouseCode       = $data['warehouseCode'];
            $model->warehouseCodeTitle  = $data['warehouseCodeTitle'];
            $model->cRdCode             = $data['cRdCode'];
            $model->cRdCodeTitle        = $data['cRdCodeTitle'];
            $model->iTaxRate            = $data['iTaxRate'] ?? 13;
            $model->nflat               = $data['nflat'] ?? 1;
            $model->cexch_name          = $data['cexch_name'] ?? '人民币';
            $model->mark                = $data['mark'] ?? '';
            $model->save();

            // 软删除老明细
            RdRecords01::where('del_time', 0)
                ->where('main_id', $data['id'])
                ->update(['del_time' => time()]);

            $this->saveOIDetail($model->id, $data);

            DB::commit();
        } catch (\Throwable $exception) {
            DB::rollBack();
            return [false, "编辑采购入库单失败: " . $exception->getMessage()];
        }

        return [true, ''];
    }

    public function purchaseOrderInRule(&$data, $user, $is_add = true)
    {
        if (!$is_add && empty($data['id'])) return [false, 'ID不能为空'];
        $id = $data['id'] ?? 0;

        if (empty($data['order_time'])) return [false, '单据日期不能为空'];
        $orderTime = trim($data['order_time']);
        if (!preg_match('/^\d{4}-\d{2}-\d{2}$/', $orderTime) || strtotime($orderTime) === false) {
            return [false, '单据日期格式不正确，必须为 YYYY-MM-DD 格式'];
        }
        if (empty($data['cVenCode']) || empty($data['cVenCodeTitle'])) return [false, '供应商信息不能为空'];
        if (empty($data['warehouseCode']) || empty($data['warehouseCodeTitle'])) return [false, '仓库信息不能为空'];
        if (empty($data['cRdCode']) || empty($data['cRdCodeTitle'])) return [false, '收发类别不能为空'];

        if(! isset($data['bredvouch'])) return [false, '蓝单|红单标识不存在'];
        $bredvouch = $data['bredvouch']; // 0蓝单 1红单

        // ==================== 核心逻辑：精准追溯用友采购订单及本地预占 ====================
        if(empty($data['cOrderCode']) || !is_array($data['cOrderCode'])) return [false, '采购订单不能为空或类型错误'];

        $u8PoDetailsMap = [];

        $service = new U8ServerService($user);
        $error = $service->getError();
        if (!empty($error)) return [false, $error];

        $cOrderCodes = array_filter(array_map('trim', $data['cOrderCode']));
        if (empty($cOrderCodes)) return [false, '参照生成的采购订单号不能为空'];

        // 1. 调用用友接口，获取最新采购订单的明细流（包含未入库量、已入库量、原订单量）
        list($status, $u8PoDetails) = $service->getPurchaseOrderDetailsByCode($cOrderCodes);
        if (!$status) return [false, $u8PoDetails];

        foreach ($u8PoDetails as $u8Item) {
            $u8PoDetailsMap[$u8Item['detail_id']] = $u8Item;
        }

        // 2. 统计本地已预占/已入库（code为空，未完全同步到用友）的入库数量
        $localOccupiedQuery = DB::table('rd_record01 as m')
            ->join('rd_records01 as d', 'd.main_id', '=', 'm.id')
            ->where('m.del_time', 0)
            ->where('d.del_time', 0)
            ->where('m.code', ''); // 排除用友已落单的数据，防止重复扣减

        if (!$is_add) {
            $localOccupiedQuery->where('m.id', '!=', $id);
        }

        // 使用 JSON_CONTAINS 圈定本次涉及的订单号在本地的预占
        $localOccupiedQuery->where(function ($query) use ($cOrderCodes) {
            foreach ($cOrderCodes as $index => $code) {
                if ($index === 0) {
                    $query->whereRaw('JSON_CONTAINS(m.cOrderCode, ?)', ['"' . $code . '"']);
                } else {
                    $query->orWhereRaw('JSON_CONTAINS(m.cOrderCode, ?)', ['"' . $code . '"']);
                }
            }
        });

        $localOccupiedRows = $localOccupiedQuery->select(
            'd.iPOsID',
            DB::raw('SUM(d.quantity) as total_qty') // 蓝单为正，红单为负，直接聚合
        )
            ->groupBy('d.iPOsID')
            ->get();

        $localOccupiedMap = [];
        foreach ($localOccupiedRows as $row) {
            $localOccupiedMap[$row->iPOsID] = (float)$row->total_qty;
        }
        // ====================================================================

        if (empty($data['detail'])) return [false, '表体明细不能为空'];
        foreach ($data['detail'] as $key => $value) {
            $line = "第 " . ($key + 1) . "行";
            if (empty($value['cInvCode'])) return [false, $line . '存货编码不能为空'];
            if (empty($value['name'])) return [false, $line . '存货名称不能为空'];

            $currentQty = floatval($value['quantity'] ?? 0);
            if ($bredvouch === 0 && $currentQty <= 0) {
                return [false, $line . '正数入库单（蓝单）存货数量必须大于0'];
            }
            if ($bredvouch === 1 && $currentQty >= 0) {
                return [false, $line . '负数入库单（红单/退货）存货数量必须小于0'];
            }

            if(empty($value['iPOsID'])) return [false, '采购订单子表ID不能为空'];

            // ==================== 混合单据逐行精细校验数量 ====================
            $iPOsID = $value['iPOsID'];

            if (!isset($u8PoDetailsMap[$iPOsID])) {
                return [false, $line . "对应的采购订单明细在用友系统不可用或已被关闭，请核对！"];
            }

            $poCode = $u8PoDetailsMap[$iPOsID]['order_number'];     // 来源采购订单号
            $poQty = (float)$u8PoDetailsMap[$iPOsID]['po_qty'];        // 订单总执行量
            $u8ReceivedQty = (float)$u8PoDetailsMap[$iPOsID]['received_qty']; // 用友端已入库累计
            $localOccupiedQty = $localOccupiedMap[$iPOsID] ?? 0;     // 本地中转在途入库累计

            if ($bredvouch === 0) {
                // 【蓝单场景】：控制不能超过未入库余量
                // 可入库余量 = 订单总数 - 用友已入库 - 本地在途入库
                $availableQty = $poQty - $u8ReceivedQty - $localOccupiedQty;
                if ($currentQty > $availableQty) {
                    return [false, $line . "【订单:{$poCode}】超过最大可入库量！用友订单待入库: " . ($poQty - $u8ReceivedQty) . "，本地在途预占: {$localOccupiedQty}，实际可用余量: {$availableQty}，当前输入: {$currentQty}"];
                }
            } else {
                // 【红单退货场景】：控制退货绝对值不能大于总共已经成功入库的数量
                // 总入库资产量 = 用友已确认入库 + 本地在途蓝单数量（若有本地在途红单则会冲减）
                $totalInStockQty = $u8ReceivedQty + $localOccupiedQty;
                if (abs($currentQty) > $totalInStockQty) {
                    return [false, $line . "【订单:{$poCode}】退货数量超标！该产品系统累计总入库数量为: {$totalInStockQty}，本次尝试退货: " . abs($currentQty)];
                }
            }
        }

        if (!$is_add) {
            $order = RdRecord01::where('id', $data['id'])->where('del_time', 0)->first();
            if (empty($order)) return [false, '单据信息不存在或已被删除'];
            $order = $order->toArray();
            if($order['bredvouch'] != $bredvouch) return [false, '编辑不允许修改红蓝单标识'];
            list($status, $msg) = $this->checkState(U8State::type_three, $user, $order['order_number']);
            if (!$status) return [false, $msg];
        }

        return [true, ''];
    }

    private function saveOIDetail($id, $data)
    {
        if (!empty($data['detail'])) {
            $unit = [];
            foreach ($data['detail'] as $value) {
                $unit[] = [
                    'main_id'     => $id,
                    'iPOsID'      => $value['iPOsID'] ?? 0, // 核心外键：对应用友采购订单明细AutoID
                    'cInvCode'    => $value['cInvCode'],
                    'quantity'    => $value['quantity'],
                    'price'       => $value['price'] ?? 0,
                    'rate'        => $value['rate'] ?? 0,
                    'name'        => $value['name'],
                    'size'        => $value['size'] ?? '',
                    'unit'        => $value['unit'] ?? '',
                    'cBatch'        => $value['cBatch'] ?? '',
                    'dMadeDate'        => $value['dMadeDate'] ?? '',
                    'dVDate'        => $value['dVDate'] ?? '',
                ];
            }
            if (!empty($unit)) RdRecords01::insert($unit);
        }
    }

    private function getOIDetail($id)
    {
        $data = RdRecords01::where('del_time', 0)
            ->where('main_id', $id)
            ->get()->toArray();

        return ['detail' => $data];
    }

    public function purchaseOrderInCommon($data, $user, $field = [])
    {
        $type = U8State::type_three;
        $qx = $user['qx'];

        $model = RdRecord01::from('rd_record01 as v')
            ->leftJoin('u8_state as s', function ($join) use ($type, $user) {
                $join->on('v.order_number', '=', 's.order_number')
                    ->where('s.type', '=', $type)
                    ->where('s.login_type', '=', $user['login_type'])
                    ->where('s.del_time', '=', 0);
            })
            ->where('v.del_time', 0)
            ->where('v.login_type', $user['login_type'])
            ->when(empty($qx), function ($query) use ($user) {
                return $query->where('v.crt_id', $user['userid']);
            })
            ->select('v.*', DB::raw('IFNULL(s.state, -1) as state'), 's.result')
            ->orderby('v.id', 'desc');

        if (isset($data['state']) && $data['state'] !== '') {
            $state_filter = $data['state'];
            if ($state_filter == -1) {
                $model->whereNull('s.id');
            } else {
                $model->where('s.state', $state_filter);
            }
        }

        if (!empty($data['code'])) $model->where('v.code', 'like', '%' . $data['code'] . '%');
        if (!empty($data['id'])) $model->where('v.id', $data['id']);
        if (!empty($data['order_number'])) $model->where('v.order_number', 'like', '%' . $data['order_number'] . '%');
        if(! empty($data['order_time'])) $model->where('v.order_time', $data['order_time']);
        if (!empty($data['crt_time'][0]) && !empty($data['crt_time'][1])) {
            $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
            $model->where('v.crt_time', '>=', $return[0]);
            $model->where('v.crt_time', '<=', $return[1]);
        }
        if(! empty($data['crt_id'])) $model->where('v.crt_id', $data['crt_id']);

        return $model;
    }

    public function purchaseOrderInList($data, $user)
    {
        $model = $this->purchaseOrderInCommon($data, $user);
        $list  = $this->limit($model, '', $data);
        $list  = $this->fillPurchaseOrderInData($list, $user);

        return [true, $list];
    }

    public function fillPurchaseOrderInData($data, $user)
    {
        if (empty($data['data'])) return $data;

        $e_map = DDEmployee::whereIn('userid', array_unique(array_column($data['data'], 'crt_id')))
            ->where('login_type', $user['login_type'])
            ->pluck('name', 'userid')
            ->toArray();
        foreach ($data['data'] as $key => $value) {
            $data['data'][$key]['crt_name']    = $e_map[$value['crt_id']] ?? "";
            $data['data'][$key]['crt_time']    = $value['crt_time'] ? date('Y-m-d H:i:s', $value['crt_time']) : '';
            $data['data'][$key]['state_title'] = U8State::state_name[$value['state']] ?? '';
            $data['data'][$key]['bredvouch_title'] = RdRecord01::$bredvouch_title[$value['bredvouch']] ?? '';
            $this->fillStateDetail($data['data'][$key]);
        }

        return $data;
    }

    public function purchaseOrderInMyDetail($data, $user)
    {
        $id = $data['id'] ?? 0;
        $order_number = $data['order_number'] ?? "";
        if (empty($id) && empty($order_number)) return [false, '请选择数据'];

        $customer = RdRecord01::where('del_time', 0)
            ->when(!empty($id), function ($query) use ($id) {
                return $query->where('id', $id);
            })
            ->when(!empty($order_number), function ($query) use ($order_number) {
                return $query->where('order_number', $order_number);
            })
            ->where('login_type', $user['login_type'])
            ->first();

        if (empty($customer)) return [false, '采购入库单不存在或已被删除'];
        $customer = $customer->toArray();
        $customer['crt_name']   = DDEmployee::where('userid', $customer['crt_id'])->value('name') ?: '';
        $customer['crt_time']   = $customer['crt_time'] ? date("Y-m-d H:i:s", $customer['crt_time']) : '';

        $details  = $this->getOIDetail($customer['id']);
        $customer = array_merge($customer, $details);

        return [true, $customer];
    }

    public function purchaseOrderInDel($data, $user)
    {
        if (empty($data['id'])) return [false, '请选择数据！'];

        try {
            DB::beginTransaction();
            $time = time();

            $order = RdRecord01::where('id', $data['id'])->where('del_time', 0)->first();
            if (empty($order)) return [false, '单据信息不存在或已被删除'];
            $order = $order->toArray();

            list($status, $msg) = $this->checkState(U8State::type_three, $user, $order['order_number']);
            if (!$status) return [false, $msg];

            RdRecord01::where('del_time', 0)->where('id', $data['id'])->update(['del_time' => $time]);
            RdRecords01::where('del_time', 0)->where('main_id', $data['id'])->update(['del_time' => $time]);

            DB::commit();
        } catch (\Exception $exception) {
            DB::rollBack();
            return [false, $exception->getMessage()];
        }

        return [true, ''];
    }

    public function fillStateDetail(&$value){
        $is_submit_again = 0;
        if($value['state'] == U8State::state_one && $value['result'] != ''){
            $is_submit_again = 1;
        }
        $value['is_submit_again'] = $is_submit_again;
    }

    public function submitAgain($data, $user){
        if(empty($data['order_number'])) return [false, '流水号不能为空'];
        //1 采购单 2 采购请购单 3 采购入库单
        if(empty($data['type'])) return [false, 'type不能为空'];
        if(! isset(Record::type_for_model[$data['type']])) return [false, 'type不存在'];
        $model = Record::type_for_model[$data['type']];
        $array = $model::where('login_type', $user['login_type'])
            ->where('order_number', $data['order_number'])
            ->where('del_time',0)
            ->first();
        if(empty($array)) return [false, '操作的来源单据不存在或已被删除'];
        $model_array = $array->toArray();

        //限制操作------------------------------------
        list($status,$msg) = $this->limitingSendRequestBackgExpire($model_array['order_number'].$data['type'].$model_array['login_type']);
        if(! $status) return [false,$msg];

        $state = U8State::where('type', $data['type'])
            ->where('del_time', 0)
            ->where('order_number', $model_array['order_number'])
            ->where('login_type', $model_array['login_type'])
            ->first();
        if(empty($state)) return [false,'操作来源单据暂未审批'];
        $state_array = $state->toArray();
        if($state_array['state'] != U8State::state_one || empty($state_array['result']) || $state_array['is_submit']) return [false, '操作的来源单据不允许提交'];

        $record = Record::where("del_time",2)
            ->where('login_type', $model_array['login_type'])
            ->where('order_number', $model_array['order_number'])
            ->where('type', $data['type'])
            ->where('msg', '<>', '')
            ->orderBy('id', 'desc')
            ->first();
        if(empty($record)) return [false, '提交记录数据不存在'];
        $record_array = $record->toArray();

        ProcessDataJob::dispatch($record_array)->onQueue(Record::$job);

        return [true, '已进入队列后台，正在重新传输入用友服务器'];
    }
}