workHour/app/Service/ItemService.php

<?php

namespace App\Service;

use App\Jobs\ProcessOssTask;
use App\Model\CustomFieldValue;
use App\Model\Device;
use App\Model\Draft;
use App\Model\Employee;
use App\Model\Item;
use App\Model\ItemDetails;
use App\Model\ItemEmployee;
use App\Model\ItemFile;
use App\Model\ItemNode;
use App\Model\ItemNodeDetails;
use App\Model\ItemNodeEmployee;
use App\Model\ItemNodeMission;
use App\Model\ItemNodeMissionContent;
use App\Model\ItemNodeMissionDetails;
use App\Model\ItemNodeMissionEmployee;
use App\Model\ItemNodeMissionShare;
use App\Model\SysOssTasks;
use App\Model\Tag;
use App\Model\SysMenu;
use App\Model\WorkFlowTemplates;
use Illuminate\Support\Facades\DB;

class ItemService extends Service
{
    public function itemGannetCommon($data,$user){
        if(empty($data['time'][0]) || empty($data['time'][1])) return [false, '请选择开始与结束时间'];
        $return = $this->changeDateToTimeStampAboutRange($data['time']);
        $start = $return[0];
        $end = $return[1];
        $oneYearLater = strtotime('+1 year', $start);
        if ($end > $oneYearLater) return [false, '查询范围不能超过一年'];
        $type = [
            'item' => Item::class,
            'item_node' => ItemNode::class,
            'item_node_mission' => ItemNodeMission::class,
        ];
        $field = [
            'item' => ['id','code', 'title', 'start_time', 'end_time', 'charge_id', 'state', 'crt_id','progress', 'priority_id'],
            'item_node' => ['id','code', 'title', 'start_time', 'end_time', 'charge_id', 'state', 'crt_id','progress', 'priority_id'],
            'item_node_mission' => ['id','code', 'title', 'start_time', 'end_time', 'charge_id', 'state', 'progress', 'crt_id', 'priority_id'],
        ];
        if (empty($data['type']) && ! isset($type[$data['type']])) return [false , '类型错误'];
        $class = $type[$data['type']];
        $select = $field[$data['type']];
        $model = $class::TopAndEmployeeClear($user,$data);
        $model = $model->where('del_time',0)
            ->where('start_time', '<=', $end)
            ->where('end_time', '>=', $start)
            ->select($select)
            ->orderby('id', 'desc');


        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
        if(! empty($data['code'])) $model->where('code', 'LIKE', '%'.$data['code'].'%');
        if(isset($data['state'])) $model->where('state', $data['state']);

        return [true , $model];
    }

    public function itemGannetList($data,$user){
        list($status, $model) = $this->itemGannetCommon($data, $user);
        if(! $status) return [false, $model];
        $list = $model->get()->toArray();
        $list = $this->fillItemGannetList($list, $data);

        return [true, $list];
    }

    public function fillItemGannetList($data, $erg){
        if(empty($data)) return $data;

        $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_merge_recursive(array_column($data,'charge_id'), array_column($data,'crt_id'))));
        $tag = (new TagService())->getTagMap(array_unique(array_column($data,'priority_id')));
        foreach ($data as $key => $value){
            $data[$key]['start_time'] = $value['start_time'] ? date('Y-m-d',$value['start_time']) : '';
            $data[$key]['end_time'] = $value['end_time'] ? date('Y-m-d',$value['end_time']) : '';
            $data[$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
            $data[$key]['charge_name'] = $emp[$value['charge_id']] ?? '';
            $data[$key]['state_title'] = ItemNodeMission::State_Type[$value['state']] ?? "";
            $data[$key]['type'] = $erg['type'];
            $priority_tmp = $tag[$value['priority_id']] ?? [];
            $data[$key]['priority_title'] = $priority_tmp['title'] ?? '';
            $data[$key]['priority_color'] = $priority_tmp['color'] ?? '';
        }

        return $data;
    }

    public function itemGannetGetSonData($data,$user){
        if(empty($data['id'])) return [false, 'ID不能为空'];
        $type = [
            'item' => ItemNode::class,
            'item_node' => ItemNodeMission::class,
            'item_node_mission' => ItemNodeMission::class,
        ];
        $field = [
            'item' => ['id','code', 'title', 'start_time', 'end_time', 'charge_id', 'state', 'crt_id','progress', 'priority_id'],
            'item_node' => ['id','code', 'title', 'start_time', 'end_time', 'charge_id', 'state', 'crt_id','progress', 'priority_id'],
            'item_node_mission' => ['id','code', 'title', 'start_time', 'end_time', 'charge_id', 'state', 'progress', 'crt_id', 'priority_id'],
        ];
        $search = [
            'item' => "(item_id = {$data['id']})",
            'item_node' => "(item_node_id = {$data['id']})",
            'item_node_mission' => "(parent_item_node_mission_id = {$data['id']})",
        ];
        $next_type = [
            'item' => 'item_node',
            'item_node' => 'item_node_mission',
            'item_node_mission' => 'item_node_mission',
        ];
        if (empty($data['type']) && ! isset($type[$data['type']])) return [false , '类型错误'];
        $class = $type[$data['type']];
        $select = $field[$data['type']];
        $whereRaw = $search[$data['type']];
        $model = $class::TopAndEmployeeClear($user,$data);
        $list = $model->where('del_time',0)
            ->whereRaw($whereRaw)
            ->select($select)
            ->orderby('id', 'desc')
            ->get()->toArray();

        $data['type'] = $next_type[$data['type']];
        $list = $this->fillItemGannetList($list, $data);

        return [true, $list];
    }

    public function itemFileUpLoad($data,$user){
        // 1. 基础校验
        $from = $data['from'] ?? null;
        $fromMap = ItemFile::from;
        if (empty($from)) return [false, '上传来源类型不能为空'];
        if (!isset($fromMap[$from])) return [false, '上传来源类型错误'];

        $id = $data['id'] ?? null;
        if (empty($id)) return [false, '来源ID不能为空'];

        $modelMap = [
            ItemFile::from_one => Item::class,
            ItemFile::from_two => ItemNode::class,
            ItemFile::from_three => ItemNodeMission::class,
        ];

        $modelClass = $modelMap[$from] ?? "";
        $item = $modelClass::where('id', $id)->where('del_time', 0)->first();
        if (!$item) return [false, $fromMap[$from] . "不存在或已被删除"];
        if ($item->state == Item::TYPE_THREE) return [false, '已完成状态不允许上传文件'];

        $itemId = $item->item_id ?? $item->id;
        $itemNodeId = $item->item_node_id ?? ($from == ItemFile::from_one ? 0 : $item->id);
        $missionId = ($from != ItemFile::from_one && $from != ItemFile::type_two) ? $item->id : 0;

        $files = $data['file'] ?? [];
        if (empty($files)) return [false, '上传文件不能为空'];

        $time = time();
        $pendingTasks = [];
        foreach ($files as &$file) {
            if (empty($file['url']) || empty($file['type']) || empty($file['name'])) {
                return [false, '文件信息（URL/类型/名称）不完整'];
            }

            $file['top_depart_id'] = $user['top_depart_id'];
            $file['from'] = $from;
            $file['item_id'] = $itemId;
            $file['item_node_id'] = $itemNodeId;
            $file['item_node_mission_id'] = $missionId;
            $file['crt_time'] = $time;
            $file['crt_id'] = $user['id'];

            $pendingTasks[] = ['type' => SysOssTasks::type_two, 'url' => $file['url'], 'top_depart_id' => $user['top_depart_id'], 'crt_time' => $time];
        }

        unset($file);
        $data['file'] = $files;

        try {
            DB::beginTransaction();

            ItemFile::insert($data['file']);

            //触发 OSS 任务
            if (!empty($pendingTasks)) {
                SysOssTasks::insert($pendingTasks);
                ProcessOssTask::dispatch()->onQueue(SysOssTasks::job);
            }

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

        return [true, ''];
    }

    public function itemFileUpDelete1($data,$user){
        $fromMap = [
            'custom_fields' => CustomFieldValue::class,
            'item_file' => ItemFile::class,
        ];

        // 1. 基础校验
        $type = $data['type'] ?? null;
        if (empty($type)) return [false, '删除来源类型不能为空'];
        if (!isset($fromMap[$type])) return [false, '删除来源类型错误'];

        $id = $data['id'] ?? null;
        if (empty($id)) return [false, '来源ID不能为空'];

        $modelClass = $fromMap[$type] ?? "";
        $item = $modelClass::where('id', $id)->where('del_time', 0)->first();
        if (! $item) return [false, "文件不存在或已被删除"];
        $modelMap = [
            ItemFile::from_one => Item::class,
            ItemFile::from_two => ItemNode::class,
            ItemFile::from_three => ItemNodeMission::class,
        ];
        $modelClass = $modelMap[$item->from] ?? "";
        if(! $modelClass) return [false, '来源不存在'];
        $model2Map = [
            ItemFile::from_one => 'item_id',
            ItemFile::from_two => 'item_node_id',
            ItemFile::from_three => 'item_node_mission_id',
        ];
        $id = $model2Map[$item->from];
        $m = $modelClass::where('id', $id)->where('del_time', 0)->first();
        if ($m->state == Item::TYPE_THREE) return [false, '已完成状态不允许删除文件'];

        try {
            DB::beginTransaction();

            $time = time();
            if($type == 'custom_fields'){
                if(empty($item->field_value)) return [false, '文件为空'];
                $pendingTasks[] = ['type' => SysOssTasks::type_one, 'url' => $item->field_value, 'top_depart_id' => $user['top_depart_id'], 'crt_time' => $time];
                $item->update([
                    'field_value' => '',
                    'field_name' => ''
                ]);
            }else{
                if(empty($item->url)) return [false, '文件为空'];
                $pendingTasks[] = ['type' => SysOssTasks::type_one, 'url' => $item->url, 'top_depart_id' => $user['top_depart_id'], 'crt_time' => $time];
                $item->update(['del_time' => $time]);
            }

            //触发 OSS 任务
            if (! empty($pendingTasks)) {
                SysOssTasks::insert($pendingTasks);
                ProcessOssTask::dispatch()->onQueue(SysOssTasks::job);
            }

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

        return [true, ''];
    }

    public function itemFileUpDelete($data, $user)
    {
        $fromMap = [
            'custom_fields' => CustomFieldValue::class,
            'item_file'     => ItemFile::class,
        ];

        // 1. 基础参数校验
        $type = $data['type'] ?? null;
        if (empty($type)) return [false, '删除来源类型不能为空'];
        if (!isset($fromMap[$type])) return [false, '删除来源类型错误'];

        $id = $data['id'] ?? null;
        if (empty($id)) return [false, '来源ID不能为空'];

        // 2. 查询当前文件记录
        $modelClass = $fromMap[$type];
        $item = $modelClass::where('id', $id)->where('del_time', 0)->first();
        if (!$item) return [false, "文件不存在或已被删除"];

        // 3. 【核心统一】根据 from 动态映射对应的上级主体 Model 类名
        $modelMap = [
            ItemFile::from_one   => Item::class,
            ItemFile::from_two   => ItemNode::class,
            ItemFile::from_three => ItemNodeMission::class,
        ];

        $upperClass = $modelMap[$item->from] ?? null;
        if (!$upperClass) return [false, '未知的来源所属类型'];

        // 4. 根据 from 动态匹配当前模型里的外键字段名
        $foreignKeyMap = [
            ItemFile::from_one   => 'item_id',
            ItemFile::from_two   => 'item_node_id',
            ItemFile::from_three => 'item_node_mission_id',
        ];
        $foreignKey = $foreignKeyMap[$item->from] ?? 'item_id';

        // 动态获取外键 ID 值（例如 $item->item_node_id）
        $upperId = $item->$foreignKey ?? 0;

        // 5. 查询上级主体，校验完结状态
        $upperModel = $upperClass::where('id', $upperId)->where('del_time', 0)->first();
        if ($upperModel && $upperModel->state == Item::TYPE_THREE) return [false, '已完成状态不允许删除文件'];

        // 6. 执行删除事务与异步 OSS 任务
        try {
            DB::beginTransaction();

            $time = time();

            if ($type === 'custom_fields') {
                if (empty($item->field_value)) return [false, '文件为空'];
                $fileUrl = $item->field_value;

                // 清空自定义字段
                $item->update([
                    'field_value' => '',
                    'field_name'  => ''
                ]);
            } else {
                if (empty($item->url)) return [false, '文件为空'];
                $fileUrl = $item->url;

                // 软删除附件记录
                $item->update(['del_time' => $time]);
            }

            // OSS 文件真实清理任务
            $pendingTask = [
                'type'           => SysOssTasks::type_one,
                'url'            => $fileUrl,
                'top_depart_id'  => $user['top_depart_id'],
                'crt_time'       => $time
            ];
            SysOssTasks::insert($pendingTask);
            ProcessOssTask::dispatch()->onQueue(SysOssTasks::job);

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

        return [true, ''];
    }

    public function itemFileIsDelivery1($data, $user)
    {
        $typeMap = [
            1 => '标记为交付物',
            2 => '解除交付物',
        ];
        $fromMap = [
            'custom_fields' => CustomFieldValue::class,
            'item_file' => ItemFile::class,
        ];

        if (empty($data['opt_type']) || !isset($typeMap[$data['opt_type']])) return [false, '操作标识错误'];
        if (empty($data) || !is_array($data['data'])) return [false, '文件数据不能为空'];

        // 状态值映射
        $statusValue = ($data['opt_type'] == 1) ? 1 : 0;

        $idsByType = [
            'custom_fields' => [],
            'item_file' => [],
        ];

        foreach ($data['data'] as $value) {
            if (empty($value['id'])) return [false, '文件ID不能为空'];
            if (empty($value['type']) || !isset($fromMap[$value['type']])) return [false, '文件类型错误'];

            $idsByType[$value['type']][] = $value['id'];
        }

        try {
            DB::beginTransaction();

            foreach ($idsByType as $type => $ids) {
                if (!empty($ids)) {
                    $modelClass = $fromMap[$type];
                    $modelClass::whereIn('id', $ids)->update([
                        'is_delivery' => $statusValue,
                    ]);
                }
            }

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

        return [true, ''];
    }

    public function itemFileIsDelivery($data, $user)
    {
        $typeMap = [
            1 => '标记为交付物',
            2 => '解除交付物',
        ];
        $fromMap = [
            'custom_fields' => CustomFieldValue::class,
            'item_file' => ItemFile::class,
        ];

        // 1. 基础参数校验
        if (empty($data['opt_type']) || !isset($typeMap[$data['opt_type']])) return [false, '操作标识错误'];
        if (empty($data['data']) || !is_array($data['data'])) return [false, '文件数据不能为空'];

        $statusValue = ($data['opt_type'] == 1) ? 1 : 0;

        // 按文件分类归拢 ID
        $idsByType = [
            'custom_fields' => [],
            'item_file' => [],
        ];

        foreach ($data['data'] as $value) {
            if (empty($value['id'])) return [false, '文件ID不能为空'];
            if (empty($value['type']) || !isset($fromMap[$value['type']])) return [false, '文件类型错误'];

            $idsByType[$value['type']][] = $value['id'];
        }

        // 2. 【核心新增】上级主体完结状态校验（防止已完结的主体还能修改交付物状态）
        $modelMap = [
            ItemFile::from_one   => Item::class,
            ItemFile::from_two   => ItemNode::class,
            ItemFile::from_three => ItemNodeMission::class,
        ];
        $foreignKeyMap = [
            ItemFile::from_one   => 'item_id',
            ItemFile::from_two   => 'item_node_id',
            ItemFile::from_three => 'item_node_mission_id',
        ];

        foreach ($idsByType as $type => $ids) {
            if (empty($ids)) continue;

            $modelClass = $fromMap[$type];
            // 批量一次性查出这些文件记录
            $files = $modelClass::whereIn('id', $ids)->where('del_time', 0)->get();

            foreach ($files as $file) {
                $upperClass = $modelMap[$file->from] ?? null;
                $foreignKey = $foreignKeyMap[$file->from] ?? 'item_id';
                $upperId = $file->$foreignKey ?? 0;

                if ($upperClass && $upperId > 0) {
                    // 校验上级主体状态
                    $upperModel = $upperClass::where('id', $upperId)->where('del_time', 0)->first();
                    if ($upperModel && $upperModel->state == Item::TYPE_THREE) {
                        return [false, '相关项目/节点/任务已完结，无法修改交付物状态'];
                    }
                }
            }
        }

        // 3. 执行批量更新事务
        try {
            DB::beginTransaction();

            foreach ($idsByType as $type => $ids) {
                if (!empty($ids)) {
                    $modelClass = $fromMap[$type];
                    $modelClass::whereIn('id', $ids)->update([
                        'is_delivery' => $statusValue,
                    ]);
                }
            }

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

        return [true, ''];
    }

    public function changedCommon($user, $oldData){
        //是否存在审批流
        if(empty($oldData['review_id'])) return false;

        //创建人 直接通过
        if($user['id'] !== $oldData['crt_id']) return true;

        return false;
    }

    public function itemFinish($data, $user){
        if(empty($data['id'])) return [false, 'ID不能为空'];
        $model = Item::where('id',$data['id'])
            ->where('del_time',0)
            ->first();
        if(empty($model)) return [false, '项目不存在或已被删除'];
        $tableName = $model->getTable();
        $oldData = $model->toArray();
        if($oldData['state'] == Item::TYPE_THREE) return [false, '项目已完成，请勿重复操作'];

//        list($bool, $msg) = $this->checkIsDelivery($oldData, $tableName);
//        if(! $bool) return [false , $msg];

        $bool = ItemNode::where('del_time',0)
            ->where('item_id', $data['id'])
            ->where('state', '<>',ItemNode::TYPE_THREE)
            ->exists();
        if($bool) return [false, '项目下存在节点未完结'];

        try {
            DB::beginTransaction();

            $bool = $this->changedCommon($user, $oldData);
            if($bool) {
                // 更新项目状态
                $model->approval_state = Item::TYPE_MINUS_ONE;
                $model->save();
                //触发审批流
                $this->createWorkFlow(['id' => $data['id'], 'state' => Item::TYPE_THREE], $user, $model->getTable(), $oldData, 2);

                DB::commit();
                return [true, '更新记录成功，记录草稿，进入审批流程'];
            }

            $model->state = Item::TYPE_THREE;
            $model->save();

            //更新进度
            ProgressCalculatorService::calculate(ProgressCalculatorService::TYPE_ITEM, $model->id);

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

        return [true, ''];
    }

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

        list($status, $msg) = $this->itemEditSave($data, $user);
        return [$status, $msg];
    }

    public function itemEditSave($data, $user){
        try {
            DB::beginTransaction();

            $model = Item::where('id', $data['id'])->first();
            $tableName = $model->getTable();

            if(isset($data['draft'])){
                // 更新项目状态
                $model->approval_state = Item::TYPE_MINUS_ONE;
                $model->save();
                //触发审批流
                $this->createWorkFlow($data, $user, $tableName, $model->toArray());

                DB::commit();
                return [true, '更新记录成功，记录草稿，进入审批流程'];
            }

            $old_employee_id = $model->charge_id;
            $model->code = $data['code'] ?? '';
            $model->title = $data['title'] ?? '';
            $model->mark = $data['mark'] ?? "";
            $model->start_time = $data['start_time'] ?? 0;
            $model->end_time = $data['end_time'] ?? 0;
            $model->state = $data['state'] ?? 0;
            $model->budget = $data['budget'] ?? 0;
            $model->charge_id = $data['charge_id'] ?? 0;
            $model->field = $data['field'] ?? "";
            $model->item_attribute = $data['item_attribute'] ?? 0;
            //项目管理的字段
            if($user['select_tree_type'] == SysMenu::tree_type_one){
                $model->is_review_required = $data['is_review_required'] ?? 0;
                $model->review_id = $data['review_id'] ?? 0;
                $model->priority_id = $data['priority_id'] ?? 0;
            }
            $model->save();

            $time = time();

            // 人员项目表
            $this->saveEmployee($data['id'], $time, $data, $user, $old_employee_id);

            ItemDetails::where('del_time',0)
                ->where('item_id', $model->id)
                ->update(['del_time' => $time]);
            $this->saveDetail($model->id, $time, $data);

            //客户自定义字段
            list($status, $msg) = CustomFieldSettingService::syncCustomFieldData($model->id, $tableName, $data, $user);
            if (! $status) {
                DB::rollBack();
                return [false, $msg];
            }

            //更新进度
            ProgressCalculatorService::calculate(ProgressCalculatorService::TYPE_ITEM, $model->id);

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

        return [true, ''];
    }

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

        try {
            DB::beginTransaction();

            $model = new Item();
            $tableName = $model->getTable();
            $model->code = $data['code'] ?? '';
            $model->title = $data['title'] ?? '';
            $model->mark = $data['mark'] ?? "";
            $model->start_time = $data['start_time'] ?? 0;
            $model->end_time = $data['end_time'] ?? 0;
            $model->state = $data['state'] ?? 0;
            $model->budget = $data['budget'] ?? 0;
            $model->charge_id = $data['charge_id'] ?? 0;
            $model->field = $data['field'] ?? "";
            $model->item_attribute = $data['item_attribute'] ?? 0;
            $model->is_review_required = $data['is_review_required'] ?? 0;
            $model->review_id = $data['review_id'] ?? 0;
            $model->priority_id = $data['priority_id'] ?? 0;
            $model->crt_id = $user['id'];
            $model->top_depart_id = $data['top_depart_id'];
            $model->save();

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

            // 人员项目表
            $this->saveEmployee($model->id, $time, $data, $user);

            list($status, $msg) = CustomFieldSettingService::syncCustomFieldData($model->id, $tableName, $data, $user);
            if (!$status) {
                DB::rollBack();
                return [false, $msg];
            }

            //更新进度
            ProgressCalculatorService::calculate(ProgressCalculatorService::TYPE_ITEM, $model->id);

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

        return [true, ''];
    }

    public function checkIsChanged($data, $user) {
        // 获取旧数据
        list($status, $oldData) = $this->itemDetail($data, $user);
        if (!$status) return [false, $oldData];

        //工时修改 直接通过
        $select_tree_type = $user['select_tree_type'];
        if(empty($select_tree_type)) return false;

        //创建人 直接通过
        $bool = $this->changedCommon($user, $oldData);
        if(! $bool) return false;

        // --- 表头基础字段比对 ---
        $fields = [
            'code', 'title', 'mark', 'state', 'budget',
            'charge_id', 'item_attribute', 'start_time', 'end_time'
        ];

        // 权限字段校验
        if (($user['select_tree_type']) == SysMenu::tree_type_one) {
            $fields = array_merge($fields, ['is_review_required', 'review_id', 'priority_id']);
        }

        foreach ($fields as $field) {
            $oldValue = $oldData[$field] ?? '';
            $newValue = $data[$field] ?? '';

            // 日期格式对齐（确保 Y-m-d 格式一致）
            if (in_array($field, ['start_time', 'end_time'])) {
                $newValue = !empty($newValue) ? date("Y-m-d", $newValue) : "";
            }

            if ($oldValue != $newValue) {
                return true;
            }
        }

        // --- 自定义字段比对 ---
        if (isset($data['custom_fields']) && is_array($data['custom_fields'])) {
            $oldCustomMap = array_column($oldData['custom_fields'] ?? [], 'field_value', 'id');

            foreach ($data['custom_fields'] as $customField) {
                $fid = $customField['id'] ?? 0;
                $newVal = $customField['field_value'] ?? '';
                $oldVal = $oldCustomMap[$fid] ?? '';

                if ($oldVal != $newVal) {
                    return true;
                }
            }
        }

        // --- 表体：人员名单比对 (man_list) ---
        $oldMans = collect($oldData['man_list'] ?? [])->pluck('data_id')->sort()->values()->toArray();
        $newMans = collect($data['man_list'] ?? [])->pluck('data_id')->sort()->values()->toArray();
        if ($oldMans !== $newMans) {
            return true;
        }

        // --- 表体：设备名单比对 (device_list) ---
        $oldDevices = collect($oldData['device_list'] ?? [])->pluck('data_id')->sort()->values()->toArray();
        $newDevices = collect($data['device_list'] ?? [])->pluck('data_id')->sort()->values()->toArray();
        if ($oldDevices !== $newDevices) {
            return true;
        }

        return false; // 没有任何变动
    }

    public function createDraft($data, $user, $type, $opt_type = 1) {
        if(isset($data['draft'])) unset($data['draft']);

        Draft::insert([
            'document_type' => $type,
            'document_id' => $data['id'],
            'content' => json_encode($data),
            'opt_user' => json_encode($user),
            'crt_id' => $user['id'],
            'top_depart_id' => $user['top_depart_id'],
            'opt_type' => $opt_type,
            'crt_time' => time()
        ]);
    }

    private function saveDetail($id, $time, $data){
        if(! empty($data['man_list'])){
            $unit = [];
            foreach ($data['man_list'] as $value){
                $unit[] = [
                    'item_id' => $id,
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'crt_time' => $time,
                    'top_depart_id' => $value['top_depart_id'],
                ];
            }
            if(! empty($unit)) ItemDetails::insert($unit);
        }

        if(! empty($data['device_list'])){
            $receipt = [];
            foreach ($data['device_list'] as $value){
                $receipt[] = [
                    'item_id' => $id,
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'crt_time' => $time,
                    'top_depart_id' => $value['top_depart_id'],
                ];
            }
            if(! empty($receipt)) ItemDetails::insert($receipt);
        }
    }

    private function saveEmployee($id, $time, $data, $user, $old_employee_id = 0){
        if($old_employee_id != $data['charge_id']){
            //项目负责人更新
            ItemEmployee::where('del_time',0)
                ->where('item_id', $id)
                ->where('data_id', $old_employee_id)
                ->delete();

            ItemEmployee::insert([
                'item_id' => $id,
                'data_id' => $data['charge_id'],
                'top_depart_id' => $user['top_depart_id'],
                'crt_time' => $time
            ]);

            // 项目下的节点 如果有数据也要更新
            $item_node = ItemNodeEmployee::where('item_id', $id)
                ->where('type', ItemNodeEmployee::type_one)
                ->where('data_id', $old_employee_id)
                ->select('item_id', 'item_node_id', 'top_depart_id')
                ->get()->toArray();
            ItemNodeEmployee::where('item_id', $id)
                ->where('type', ItemNodeEmployee::type_one)
                ->where('data_id', $old_employee_id)
                ->delete();
            if(! empty($item_node)){
                foreach ($item_node as $key => $value){
                    $item_node[$key]['data_id'] = $data['charge_id'];
                    $item_node[$key]['crt_time'] = $time;
                }
                ItemNodeEmployee::insert($item_node);
            }

            // 项目下的节点的任务 如果有数据也要更新
            $item_node_mission = ItemNodeMissionEmployee::where('item_id', $id)
                ->where('type', ItemNodeMissionEmployee::type_one)
                ->where('data_id', $old_employee_id)
                ->select('item_id', 'item_node_id', 'item_node_mission_id', 'top_depart_id')
                ->get()->toArray();
            ItemNodeMissionEmployee::where('item_id', $id)
                ->where('type', ItemNodeMissionEmployee::type_one)
                ->where('data_id', $old_employee_id)
                ->delete();
            if(! empty($item_node_mission)){
                foreach ($item_node_mission as $key => $value){
                    $item_node_mission[$key]['data_id'] = $data['charge_id'];
                    $item_node_mission[$key]['crt_time'] = $time;
                }
                ItemNodeMissionEmployee::insert($item_node_mission);
            }
        }
    }

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

        $id = $id2 = [];
        foreach ($data as $value){
            if($value['type'] == ItemDetails::type_one) {
                $id[] = $value['data_id'];
            }else{
                $id2[] = $value['data_id'];
            }
        }
        $map = Employee::whereIn('id', $id)->select('title','id','number')->get()->toArray();
        $map = array_column($map,null,'id');
        $map2 = Device::whereIn('id', $id2)->select('code','id','title','type')->get()->toArray();
        $map2 = array_column($map2,null,'id');

        $unit = $receipt = [];
        foreach ($data as $value){
            if($value['type'] == ItemDetails::type_one) {
                $tmp = $map[$value['data_id']] ?? [];
                $unit[] = [
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'data_title' => $tmp['title'],
                    'data_code' => $tmp['number'],
                ];
            }else{
                $tmp = $map2[$value['data_id']] ?? [];
                $receipt[] = [
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'data_title' => $tmp['title'] ?? "",
                    'data_code' => $tmp['code'] ?? "",
                    'type_title' => Device::$type[$tmp['type']],
                ];
            }
        }

        return [
            'man_list' => $unit,
            'device_list' => $receipt,
        ];
    }

    public function getItemMap($ids){
        $ids = array_filter((array)$ids);
        if (empty($ids)) return [];

        return Item::whereIn('id', $ids)
            ->select('id', 'title', 'code')
            ->get()
            ->keyBy('id')
            ->toArray();
    }

    private function checkDelete($data, $type = 1)
    {
        $id = $data['id'] ?? null;
        if (!$id) return [false, '参数错误'];

        // 1. 定义配置数组，将不同类型的校验逻辑抽离，消除 if-else 臃肿
        $config = [
            1 => [
                'model' => Item::class,
                'name'  => '项目',
                'relations' => [
                    ['model' => ItemNode::class, 'key' => 'item_id', 'msg' => '项目下已存在节点'],
                    ['model' => ItemNodeMission::class, 'key' => 'item_id', 'msg' => '项目下已存在任务'],
                ]
            ],
            2 => [
                'model' => ItemNode::class,
                'name'  => '节点',
                'relations' => [
                    ['model' => ItemNodeMission::class, 'key' => 'item_node_id', 'msg' => '节点下已存在任务'],
                ]
            ],
            3 => [
                'model' => ItemNodeMission::class,
                'name'  => '任务',
                'relations' => [
                    ['model' => ItemNodeMission::class, 'key' => 'parent_item_node_mission_id', 'msg' => '该任务下已存在子任务，请先删除子任务']
                ],
            ],
        ];

        $cfg = $config[$type] ?? null;
        if (!$cfg) return [false, '无效的类型'];

        // 2. 统一查询主体对象
        $target = $cfg['model']::where('id', $id)
        ->where('del_time', 0)
        ->first();

        // 3. 健壮性检查：防止操作不存在的记录
        if (!$target) return [false, "未找到该{$cfg['name']}"];

        // 4. 状态校验：统一判断是否已完成
        // 建议在 Model 中统一定义 TYPE_THREE 的常量名或方法
        if ($target->approval_state == $cfg['model']::TYPE_MINUS_ONE) {
            return [false, "{$cfg['name']}处于审核中"];
        }

        if ($target->state == $cfg['model']::TYPE_THREE) {
            return [false, "{$cfg['name']}已完成"];
        }

        // 5. 关联依赖校验
        foreach ($cfg['relations'] as $rel) {
            $exists = $rel['model']::where('del_time', 0)
                ->where($rel['key'], $id)
                ->exists();
            if ($exists) return [false, $rel['msg']];
        }

        return [true, ''];
    }

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

        list($status, $msg) = $this->checkDelete($data);
        if(! $status) return [false, $msg];

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

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

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

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

        return [true, ''];
    }

    public function itemDetail($data, $user){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];
        $customer = Item::where('del_time',0)
            ->withCustomData($user)
            ->where('id',$data['id'])
            ->first();
        if(empty($customer)) return [false,'项目不存在或已被删除'];
        $customer->getFormattedCustomFields();// 自定义数据附件处理
        $customer = $customer->toArray();

        $customer['start_time']  = ! empty($customer['start_time']) ? date("Y-m-d", $customer['start_time']) : "";
        $customer['end_time']  = ! empty($customer['end_time']) ? date("Y-m-d", $customer['end_time']) : "";
        $customer['crt_name'] = Employee::where('id',$customer['crt_id'])->value('title');
        $customer['charge_name'] = Employee::where('id',$customer['charge_id'])->value('title');
        $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';
        $customer['state_title'] = Item::State_Type[$customer['state']] ?? '';
        $customer['approval_state_title'] = Item::State_Type[$customer['approval_state']] ?? '';
        $tag = (new TagService())->getTagMap(array_unique([$customer['priority_id']]));
        $priority_tmp = $tag[$customer['priority_id']] ?? [];
        $customer['priority_title'] = $priority_tmp['title'] ?? '';
        $customer['priority_code'] = $priority_tmp['code'] ?? '';
        $customer['priority_color'] = $priority_tmp['color'] ?? '';
        $customer['review_title'] = WorkFlowTemplates::where('id', $customer['review_id'])->value('title') ?? "";

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

        return [true, $customer];
    }

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

        //节点信息
        $customer['node_list'] = $this->itemNodeBoard($data, $user);

        //文件归档
        $customer['file_list'] = $this->getFile($data, $user, $customer);

        return [true, $customer];
    }

    public function itemNodeBoard($data,$user){
        $model = ItemNode::TopAndEmployeeClear($user,$data);
        $list = $model->where('del_time',0)
            ->where('item_id', $data['id'])
            ->select('*')
            ->orderby('upd_time', 'desc')
            ->orderby('id', 'desc')
            ->get()->toArray();

        $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_merge_recursive(array_column($list,'charge_id'), array_column($list,'crt_id'))));
        $tag = (new TagService())->getTagMap(array_unique(array_merge_recursive(array_column($list,'priority_id'),array_column($list,'node_id'))));
        foreach ($list as $key => $value){
            $list[$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $list[$key]['start_time'] = $value['start_time'] ? date('Y-m-d',$value['start_time']) : '';
            $list[$key]['end_time'] = $value['end_time'] ? date('Y-m-d',$value['end_time']) : '';
            $list[$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
            $list[$key]['charge_name'] = $emp[$value['charge_id']] ?? '';
            $list[$key]['state_title'] = ItemNode::State_Type[$value['state']] ?? "";
            $list[$key]['approval_state_title'] = Item::State_Type[$value['approval_state']] ?? '';
            $priority_tmp = $tag[$value['priority_id']] ?? [];
            $list[$key]['priority_title'] = $priority_tmp['title'] ?? '';
            $list[$key]['priority_code'] = $priority_tmp['code'] ?? '';
            $list[$key]['priority_color'] = $priority_tmp['color'] ?? '';
            $node_tmp = $tag[$value['node_id']] ?? [];
            $list[$key]['node_title'] = $node_tmp['title'] ?? '';
            $list[$key]['node_code'] = $node_tmp['code'] ?? '';
        }

        return $list;
    }

    public function getFile($data,$user, $item){
        $file = ItemFile::where('del_time',0)
            ->where('item_id', $data['id'])
            ->get()->toArray();

        $employee_id = array_unique(array_merge_recursive(array_column($file,'crt_id'), array_column($item['custom_fields'],'crt_id')));
        $map = (new EmployeeService())->getEmployeeMap($employee_id);

        $nodeIds = [];
        $missionIds = [];

        // 分类收集附件对应的来源 ID
        foreach ($file as $v) {
            if ($v['from'] == ItemFile::from_two) {
                $nodeIds[] = $v['item_node_id'];
            } elseif ($v['from'] == ItemFile::from_three) {
                $missionIds[] = $v['item_node_mission_id'];
            }
        }

        // 批量捞出各自表的名字映射 (Id => Title)
        $itemMap    = Item::where('id', $data['id'])->pluck('title', 'id')->toArray();
        $nodeMap    = !empty($nodeIds) ? ItemNode::whereIn('id', array_unique($nodeIds))->pluck('title', 'id')->toArray() : [];
        $missionMap = !empty($missionIds) ? ItemNodeMission::whereIn('id', array_unique($missionIds))->pluck('title', 'id')->toArray() : [];

        $return = [];
        if(! empty($item['custom_fields'])){
            foreach ($item['custom_fields'] as $value){
                if($value['field_type'] == CustomFieldValue::type_two){
                    $return[] = [
                        'id' => $value['id'],
                        'url' => $value['field_value'],
                        'name' => $value['field_name'],
                        'show_url' => $value['field_value_show'],
                        'type_name' => '项目',
                        'type_name_2' => CustomFieldValue::type[CustomFieldValue::type_two],
                        'type' => 'custom_fields',
                        'from' => ItemFile::from_one,
                        'from_name' => $itemMap[$value['model_id']] ?? "",
                        'crt_name' => $map[$value['crt_id']],
                        'crt_time' => date("Y-m-d", $value['crt_time']),
                        'crt_id' => $value['crt_id'],
                        'is_delivery' => $value['is_delivery'],
                    ];
                }
            }
        }

        if(! empty($file)){
            $fileUploadService = new FileUploadService();
            foreach ($file as $value){
                $fromName = '';
                if ($value['from'] == ItemFile::from_one) {
                    $fromName = $itemMap[$value['item_id']] ?? '';
                } elseif ($value['from'] == ItemFile::from_two) {
                    $fromName = $nodeMap[$value['item_node_id']] ?? '';
                } elseif ($value['from'] == ItemFile::from_three) {
                    $fromName = $missionMap[$value['item_node_mission_id']] ?? '';
                }
                $return[] = [
                    'id' => $value['id'],
                    'url' => $value['url'],
                    'name' => $value['name'],
                    'show_url' => $fileUploadService->getFileShow($value['url']),
                    'type_name' => ItemFile::from[$value['from']],
                    'type_name_2' => ItemFile::type[$value['type']],
                    'type' => 'item_file',
                    'from' => $value['from'],
                    'from_name' => $fromName,
                    'crt_name' => $map[$value['crt_id']],
                    'crt_time' => date("Y-m-d", $value['crt_time']),
                    'crt_id' => $value['crt_id'],
                    'is_delivery' => $value['is_delivery'],
                ];
            }
        }

        return $return;
    }

    public function itemCommon($data,$user, $field = []){
        if(empty($field)) $field = Item::$field;

        $model = Item::TopClear($user,$data);
        $model = $model->where('del_time',0)
            ->select($field)
            ->orderby('id', 'desc');

        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
        if(! empty($data['code'])) $model->where('code', 'LIKE', '%'.$data['code'].'%');
        if(! empty($data['id'])) $model->whereIn('id', $data['id']);
        if(! empty($data['state'])) $model->where('state', $data['state']);
        if(! empty($data['approval_state'])) $model->where('approval_state', $data['approval_state']);
        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 itemCommon1($data,$user, $field = []){
        if(empty($field)) $field = Item::$field;

        $model = Item::TopAndEmployeeClear($user,$data);
        $model = $model->where('del_time',0)
            ->select($field)
            ->orderby('id', 'desc');

        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
        if(! empty($data['code'])) $model->where('code', 'LIKE', '%'.$data['code'].'%');
        if(! empty($data['id'])) $model->whereIn('id', $data['id']);
        if(! empty($data['state'])) $model->where('state', $data['state']);
        if(! empty($data['approval_state'])) $model->where('approval_state', $data['approval_state']);
        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 itemList($data,$user){
        $select_tree_type = $user['select_tree_type'];
        if(empty($select_tree_type)){
            //工时
            $model = $this->itemCommon($data, $user);
        }else{
            //项目管理
            $model = $this->itemCommon1($data, $user);
        }

        $list = $this->limit($model,'',$data);
        $list = $this->fillData($list);

        return [true, $list];
    }

    public function itemRule1(&$data, $user, $is_add = true){
        $data['top_depart_id'] = $user['top_depart_id'];
        if(empty($data['code'])) return [false, '项目编码不能为空'];
        if(empty($data['title'])) return [false, '项目名称不能为空'];
        if(! empty($data['start_time'])) $data['start_time'] = $this->changeDateToDate($data['start_time']);
        if(! empty($data['end_time'])) $data['end_time'] = $this->changeDateToDate($data['end_time'],true);
        if(! empty($data['start_time']) && ! empty($data['end_time']) && $data['start_time'] > $data['end_time']) return [false, '开始时间不能大于结束时间'];
        $isMonthEnd = date('j', $data['end_time']) == date('t', $data['end_time']);
        if(! $isMonthEnd) return [false, '项目结束日期必须是当月最后一天'];
        if(empty($data['state'])) return [false, '项目状态不能为空'];
        if(! isset(Item::State_Type[$data['state']])) return [false, '项目状态不存在'];
        if(empty($data['man_list'])) return [false, '人员不能为空'];
        foreach ($data['man_list'] as $key => $value){
            if(empty($value['type'])) return [false, '类型不能为空'];
            if(empty($value['data_id'])) return [false, '人员不能为空'];
            $data['man_list'][$key]['top_depart_id'] = $data['top_depart_id'];
        }
        list($status, $msg) = $this->checkArrayRepeat($data['man_list'],'data_id','人员');
        if(! $status) return [false, $msg];
        if(empty($data['device_list'])) return [false, '设备不能为空'];
        if(isset($data['device_list'])){
            foreach ($data['device_list'] as $key => $value){
                if(empty($value['type'])) return [false, '类型不能为空'];
                if(empty($value['data_id'])) return [false, '设备ID不能为空'];
                $data['device_list'][$key]['top_depart_id'] = $data['top_depart_id'];
            }
        }

        list($status, $msg) = $this->checkArrayRepeat($data['device_list'],'data_id','设备');
        if(! $status) return [false, $msg];

        if(isset($data['budget'])){
            $res = $this->checkNumber($data['budget'],2,'non-negative');
            if(! $res['valid']) return [false,'预算：' . $res['error']];
        }
        if(! empty($data['item_attribute']) && ! isset(Item::Item_Attribute[$data['item_attribute']])) return [false, '项目属性不存在'];

        if($is_add){
            $bool = Item::where('code',$data['code'])
                ->where('top_depart_id', $data['top_depart_id'])
                ->where('del_time',0)
                ->exists();
        }else{
            if(empty($data['id'])) return [false,'ID不能为空'];
            $item = Item::where('id', $data['id'])
                ->where('del_time',0)
                ->first();
            if(empty($item)) return [false, '项目不存在或已被删除'];
            if($item->state == ItemNodeMission::TYPE_THREE) return [false, '项目已完结，操作失败'];
            if($item->approval_state == ItemNodeMission::TYPE_MINUS_ONE) return [false, '项目审核中，操作失败'];
            if($data['state'] == Item::TYPE_THREE) {
                $bool = ItemNode::where('del_time',0)
                    ->where('item_id', $data['id'])
                    ->where('state', '<>',ItemNode::TYPE_THREE)
                    ->exists();
                if($bool) return [false, '项目下存在节点未完结'];
            }

            $bool = Item::where('code',$data['code'])
                ->where('top_depart_id', $data['top_depart_id'])
                ->where('id','<>', $data['id'])
                ->where('del_time',0)
                ->exists();

            if($user['select_tree_type'] && $item->approval_state == Item::TYPE_MINUS_ONE) return [false, '审核中不允许编辑'];
        }
        if($bool) return [false, '项目编码已存在'];

        //判断是否编辑 然后需要审核的 需要后 就更新状态 记录草稿
        if(! $is_add){
            $return = $this->checkIsChanged($data, $user);
            if(is_array($return)) {
                list($status, $msg) = $return;
                return [$status, $msg];
            }else{
                if($return) $data['draft'] = true;
            }
        }

        return [true, ''];
    }

    public function itemRule(&$data, $user, $is_add = true)
    {
        $data['top_depart_id'] = $user['top_depart_id'];

        // 1. 基础必填校验
        if (empty($data['code'])) return [false, '项目编码不能为空'];
        if (empty($data['title'])) return [false, '项目名称不能为空'];
        if (empty($data['state'])) return [false, '项目状态不能为空'];
        if (!isset(Item::State_Type[$data['state']])) return [false, '项目状态不存在'];
        if (!empty($data['item_attribute']) && !isset(Item::Item_Attribute[$data['item_attribute']])) return [false, '项目属性不存在'];

        // 2. 时间校验
        if (!empty($data['start_time'])) $data['start_time'] = $this->changeDateToDate($data['start_time']);
        if (!empty($data['end_time'])) $data['end_time'] = $this->changeDateToDate($data['end_time'], true);

        if (!empty($data['start_time']) && !empty($data['end_time'])) {
            if ($data['start_time'] > $data['end_time']) return [false, '开始时间不能大于结束时间'];

            $isMonthEnd = date('j', $data['end_time']) == date('t', $data['end_time']);
            if (!$isMonthEnd) return [false, '项目结束日期必须是当月最后一天'];
        }

        // 3. 预算校验
        if (isset($data['budget'])) {
            $res = $this->checkNumber($data['budget'], 2, 'non-negative');
            if (!$res['valid']) return [false, '预算：' . $res['error']];
        }

        // 4. 列表类数据校验（人员与设备）
        if (empty($data['man_list'])) return [false, '人员不能为空'];
        list($status, $msg) = $this->validateListRelation($data['man_list'], $data['top_depart_id'], '人员', 'data_id');
        if (!$status) return [false, $msg];

        if (empty($data['device_list'])) return [false, '设备不能为空'];
        list($status, $msg) = $this->validateListRelation($data['device_list'], $data['top_depart_id'], '设备', 'data_id');
        if (!$status) return [false, $msg];

        // 5. 核心业务逻辑校验（新增 vs 编辑）
        $codeQuery = Item::where('code', $data['code'])
            ->where('top_depart_id', $data['top_depart_id'])
            ->where('del_time', 0);

        if ($is_add) {
            // 新增：只需查重
            if ($codeQuery->exists()) return [false, '项目编码已存在'];
        } else {
            // 编辑：深度校验状态
            if (empty($data['id'])) return [false, 'ID不能为空'];

            $item = Item::where('id', $data['id'])->where('del_time', 0)->first();
            if (empty($item)) return [false, '项目不存在或已被删除'];

            //交付物
//            if($data['state'] == Item::TYPE_THREE){
//                $tableName = $item->getTable();
//                list($bool, $msg) = $this->checkIsDelivery($item->toArray(), $tableName);
//                if(! $bool) return [false , $msg];
//            }

            // 状态拦截
            if ($item->state == Item::TYPE_THREE) return [false, '项目已完结，操作失败'];

            // 统一权限和审核状态拦截
            if ($item->approval_state == Item::TYPE_MINUS_ONE) {
                $errorMsg = $user['select_tree_type'] ? '审核中不允许编辑' : '项目审核中，操作失败';
                return [false, $errorMsg];
            }

            // 试图完结项目时，校验下游节点
            if ($data['state'] == Item::TYPE_THREE) {
                $hasUnfinishedNode = ItemNode::where('del_time', 0)
                    ->where('item_id', $data['id'])
                    ->where('state', '<>', ItemNode::TYPE_THREE)
                    ->exists();
                if ($hasUnfinishedNode) return [false, '项目下存在节点未完结'];
            }

            // 查重排除自身
            if ($codeQuery->where('id', '<>', $data['id'])->exists()) {
                return [false, '项目编码已存在'];
            }

            // 变更及草稿判定
            $return = $this->checkIsChanged($data, $user);
            if (is_array($return)) {
                return $return; // 直接返回 checkIsChanged 的错误结果
            } elseif ($return) {
                $data['draft'] = true;
            }
        }

        return [true, ''];
    }

    /**
     * 辅助方法：提取出来的公共列表和排重校验
     */
    private function validateListRelation(&$list, $topDepartId, $fieldTitle, $keyName = 'data_id')
    {
        foreach ($list as $key => $value) {
            if (empty($value['type'])) return [false, "{$fieldTitle}类型不能为空"];
            if (empty($value[$keyName])) return [false, "{$fieldTitle}不能为空"];
            $list[$key]['top_depart_id'] = $topDepartId;
        }
        return $this->checkArrayRepeat($list, $keyName, $fieldTitle);
    }

    public function fillData($data){
        if(empty($data['data'])) return $data;

        $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_merge_recursive(array_column($data['data'],'charge_id'), array_column($data['data'],'crt_id'))));
        $tag = (new TagService())->getTagMap(array_unique(array_column($data['data'],'priority_id')));

        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $data['data'][$key]['start_time'] = $value['start_time'] ? date('Y-m-d',$value['start_time']) : '';
            $data['data'][$key]['end_time'] = $value['end_time'] ? date('Y-m-d',$value['end_time']) : '';
            $data['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
            $data['data'][$key]['charge_name'] = $emp[$value['charge_id']] ?? '';
            $data['data'][$key]['state_title'] = Item::State_Type[$value['state']] ?? "";
            $data['data'][$key]['approval_state_title'] = Item::State_Type[$value['approval_state']] ?? "";
            $priority_tmp = $tag[$value['priority_id']] ?? [];
            $data['data'][$key]['priority_title'] = $priority_tmp['title'] ?? '';
            $data['data'][$key]['priority_color'] = $priority_tmp['color'] ?? '';
        }

        return $data;
    }

    /**
     * 填充项目导出数据（主表与明细平铺）
     */
    public function fillDataForExport($data, $column, $user, &$return)
    {
        if (empty($data)) return;

        $dataArray = is_array($data) ? $data : $data->toArray();
        $mainIds = array_column($dataArray, 'id');

        // 1. 获取详情映射 [item_id => [ [type_title=>..., code_2=>..., title=>...], ... ]]
        $detailsMap = $this->getDetailsMap($mainIds, $user);

        // 2. 获取主表状态映射
        $stateMap = \App\Model\Item::State_Type;
        $attrMap = \App\Model\Item::Item_Attribute;

        $empMap = Employee::whereIn('id', array_unique(array_column($dataArray,'charge_id')))->get()->keyBy('id');

        foreach ($dataArray as $main) {
            $itemId = $main['id'];
            $details = $detailsMap[$itemId] ?? [];

            // 3. 提取并格式化主表信息
            $mainInfo = $main;
            $mainInfo['state_title'] = $stateMap[$main['state'] ?? ''] ?? '';
            $mainInfo['item_attribute_title'] = $attrMap[$main['item_attribute'] ?? ''] ?? '';

            $tmpEmp = $empMap[$main['charge_id']] ?? null;
            $mainInfo['charge_number'] = $tmpEmp ? $tmpEmp->number : '';
            $mainInfo['charge_name'] = $tmpEmp ? $tmpEmp->title : '';

            // 日期格式化
            $mainInfo['start_time'] = !empty($main['start_time']) ? date('Y-m-d', $main['start_time']) : '';
            $mainInfo['end_time']   = !empty($main['end_time']) ? date('Y-m-d', $main['end_time']) : '';

            if (empty($details)) {
                // 如果单据没有明细，保底出一行
                $tempRow = [];
                foreach ($column as $col) {
                    $tempRow[] = $mainInfo[$col] ?? '';
                }
                $return[] = $tempRow;
            } else {
                // 4. 核心平铺逻辑：每一行明细都带上主表信息
                foreach ($details as $sub) {
                    // 合并主表数据和详情数据（sub 中包含 type_title, code_2, title 等）
                    $fullRowData = array_merge($mainInfo, $sub);

                    $tempRow = [];
                    foreach ($column as $col) {
                        $tempRow[] = $fullRowData[$col] ?? '';
                    }
                    $return[] = $tempRow;
                }
            }
        }
    }

    /**
     * 获取明细聚合映射表
     */
    public function getDetailsMap($mainIds, $user)
    {
        $details = ItemDetails::where('del_time', 0)
            ->whereIn('item_id', $mainIds)
            ->where('top_depart_id', $user['top_depart_id'])
            ->get();

        if ($details->isEmpty()) return [];

        // 1. 批量提取关联 ID
        $empIds = $details->where('type', ItemDetails::type_one)->pluck('data_id')->unique();
        $devIds = $details->where('type', ItemDetails::type_two)->pluck('data_id')->unique();

        // 2. 批量获取档案 Map
        $empMap = Employee::whereIn('id', $empIds)->get()->keyBy('id');
        $devMap = Device::whereIn('id', $devIds)->get()->keyBy('id');

        $typeNames = ItemDetails::$type_name;

        $res = [];
        foreach ($details as $item) {
            $detailRow = [];
            $detailRow['type_title'] = $typeNames[$item->type] ?? '';

            // 根据类型处理影子列 code_2 和 名称 title
            if ($item->type == ItemDetails::type_one) {
                $emp = $empMap[$item->data_id] ?? null;
                $detailRow['code_2'] = $emp ? $emp->number : '';
                $detailRow['title_2']  = $emp ? $emp->title : '';
            } else {
                $dev = $devMap[$item->data_id] ?? null;
                $detailRow['code_2'] = $dev ? $dev->code : '';
                $detailRow['title_2']  = $dev ? $dev->title : '';
            }

            // 归档到对应的主表 ID 下
            $res[$item->item_id][] = $detailRow;
        }

        return $res;
    }

    public function itemNodeFinish($data, $user){
        if(empty($data['id'])) return [false, 'ID不能为空'];
        $model = ItemNode::where('id',$data['id'])
            ->where('del_time',0)
            ->first();
        if(empty($model)) return [false, '项目节点不存在或已被删除'];
        $tableName = $model->getTable();
        $oldData = $model->toArray();
        if($oldData['state'] == ItemNode::TYPE_THREE) return [false, '项目节点已完成，请勿重复操作'];

        //交付物
        list($bool, $msg) = $this->checkIsDelivery($oldData, $tableName);
        if(! $bool) return [false , $msg];

        $bool = ItemNodeMission::where('del_time',0)
            ->where('item_node_id', $data['id'])
            ->where('state', '<>',ItemNodeMission::TYPE_THREE)
            ->exists();
        if($bool) return [false, '节点下存在任务未完结'];

        try {
            DB::beginTransaction();

            $bool = $this->changedCommon($user, $oldData);
            if($bool) {
                // 更新项目状态
                $model->approval_state = ItemNode::TYPE_MINUS_ONE;
                $model->save();
                //触发审批流
                $this->createWorkFlow(['id' => $data['id'], 'state' => ItemNode::TYPE_THREE], $user, $model->getTable(), $oldData, 2);

                DB::commit();
                return [true, '更新记录成功，记录草稿，进入审批流程'];
            }

            $model->state = ItemNode::TYPE_THREE;
            $model->save();

            //更新进度
            ProgressCalculatorService::calculate(ProgressCalculatorService::TYPE_NODE, $model->id);

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

        return [true, ''];
    }

    //项目节点
    public function itemNodeEdit($data,$user){
        list($status,$msg) = $this->itemNodeRule($data, $user, false);
        if(!$status) return [$status,$msg];

        list($status, $msg) = $this->itemNodeEditSave($data, $user);
        return [$status, $msg];
    }

    public function itemNodeEditSave($data, $user){
        try {
            DB::beginTransaction();

            $model = ItemNode::where('id', $data['id'])->first();
            $tableName = $model->getTable();

            if(isset($data['draft'])){
                // 更新项目节点状态
                $model->approval_state = ItemNode::TYPE_MINUS_ONE;
                $model->save();
                //触发审批流
                $this->createWorkFlow($data, $user, $tableName, $model->toArray());

                DB::commit();
                return [true, '更新记录成功，记录草稿，进入审批流程'];
            }

            $old_employee_id = $model->charge_id;
            $tableName = $model->getTable();
            $model->title = $data['title'] ?? '';
            $model->mark = $data['mark'] ?? "";
            $model->start_time = $data['start_time'] ?? 0;
            $model->end_time = $data['end_time'] ?? 0;
            $model->is_delivery_required = $data['is_delivery_required'] ?? 0;
            $model->entrust_type = $data['entrust_type'] ?? 0;
            $model->charge_id = $data['charge_id'] ?? 0;
            $model->node_id = $data['node_id'] ?? 0;
            $model->node_weight = $data['node_weight'] ?? 0;
            $model->is_review_required = $data['is_review_required'] ?? 0;
            $model->review_id = $data['review_id'] ?? 0;
            $model->priority_id = $data['priority_id'] ?? 0;
            $model->state = $data['state'] ?? 0;
            $model->save();

            $time = time();
            ItemNodeDetails::where('del_time',0)
                ->where('item_node_id', $model->id)
                ->update(['del_time' => $time]);

            $this->saveNodeDetail($model->id, $time, $data);

            // 人员项目节点表
            $this->saveNodeEmployee($model->id, $time, $data, $user, $old_employee_id);

            list($status, $msg) = CustomFieldSettingService::syncCustomFieldData($model->id, $tableName, $data, $user);
            if (! $status) {
                DB::rollBack();
                return [false, $msg];
            }

            //更新进度
            ProgressCalculatorService::calculate(ProgressCalculatorService::TYPE_NODE, $model->id);

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

        return [true, ''];
    }

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

        try {
            DB::beginTransaction();

            $model = new ItemNode();
            $model->item_id = $data['item_id'] ?? 0;
            $tableName = $model->getTable();
            $model->code = $this->generateBillNo([
                'top_depart_id' => $user['top_depart_id'],
                'type' => ItemNode::Order_type,
                'period' => date("Ym", time())
            ]);
            $model->title = $data['title'] ?? '';
            $model->mark = $data['mark'] ?? "";
            $model->start_time = $data['start_time'] ?? 0;
            $model->end_time = $data['end_time'] ?? 0;
            $model->is_delivery_required = $data['is_delivery_required'] ?? 0;
            $model->entrust_type = $data['entrust_type'] ?? 0;
            $model->charge_id = $data['charge_id'] ?? 0;
            $model->node_id = $data['node_id'] ?? 0;
            $model->node_weight = $data['node_weight'] ?? 0;
            $model->is_review_required = $data['is_review_required'] ?? 0;
            $model->review_id = $data['review_id'] ?? 0;
            $model->priority_id = $data['priority_id'] ?? 0;
            $model->crt_id = $user['id'];
            $model->top_depart_id = $data['top_depart_id'];
            $model->state = $data['state'] ?? 0;
            $model->save();

            $time = time();
            $this->saveNodeDetail($model->id, $time, $data);

            // 人员项目节点表
            $this->saveNodeEmployee($model->id, $time, $data, $user);

            list($status, $msg) = CustomFieldSettingService::syncCustomFieldData($model->id, $tableName, $data, $user);
            if (!$status) {
                DB::rollBack();
                return [false, $msg];
            }

            //更新进度
            ProgressCalculatorService::calculate(ProgressCalculatorService::TYPE_NODE, $model->id);

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

        return [true, ''];
    }

    public function checkItemNodeIsChanged($data, $user) {
        // 1. 获取旧数据
        list($status, $oldData) = $this->itemNodeDetail($data, $user);
        if (!$status) return [false, $oldData];

        //创建人 直接通过
        $bool = $this->changedCommon($user, $oldData);
        if(! $bool) return false;

        // --- 表头基础字段比对 ---
        $fields = [
            'code', 'title', 'mark', 'state', 'budget',
            'charge_id', 'is_delivery_required', 'start_time', 'end_time',
            'entrust_type', 'is_review_required', 'review_id', 'priority_id', 'node_id', 'node_weight'
        ];

        foreach ($fields as $field) {
            $oldValue = $oldData[$field] ?? '';
            $newValue = $data[$field] ?? '';

            // 日期格式对齐（确保 Y-m-d 格式一致）
            if (in_array($field, ['start_time', 'end_time'])) {
                $newValue = !empty($newValue) ? date("Y-m-d", $newValue) : "";
            }

            if ($oldValue != $newValue) {
                return true;
            }
        }

        // --- 自定义字段比对 ---
        if (isset($data['custom_fields']) && is_array($data['custom_fields'])) {
            $oldCustomMap = array_column($oldData['custom_fields'] ?? [], 'field_value', 'id');

            foreach ($data['custom_fields'] as $customField) {
                $fid = $customField['id'] ?? 0;
                $newVal = $customField['field_value'] ?? '';
                $oldVal = $oldCustomMap[$fid] ?? '';

                if ($oldVal != $newVal) {
                    return true;
                }
            }
        }

        // --- 表体：人员名单比对 (man_list) ---
        $oldMans = collect($oldData['man_list'] ?? [])->pluck('data_id')->sort()->values()->toArray();
        $newMans = collect($data['man_list'] ?? [])->pluck('data_id')->sort()->values()->toArray();
        if ($oldMans !== $newMans) {
            return true;
        }

        // --- 表体：设备名单比对 (device_list) ---
        $oldDevices = collect($oldData['device_list'] ?? [])->pluck('data_id')->sort()->values()->toArray();
        $newDevices = collect($data['device_list'] ?? [])->pluck('data_id')->sort()->values()->toArray();
        if ($oldDevices !== $newDevices) {
            return true;
        }

        return false; // 没有任何变动
    }

    private function saveNodeEmployee($id, $time, $data, $user, $old_employee_id = 0){
        //负责人更换
        if($old_employee_id != $data['charge_id']){
            //节点负责人
            ItemNodeEmployee::where('del_time',0)
                ->where('item_node_id', $id)
                ->where('data_id', $old_employee_id)
                ->where('type', ItemNodeEmployee::type_zero)
                ->delete();

            ItemNodeEmployee::insert([
                'item_node_id' => $id,
                'item_id' => $data['item_id'],
                'data_id' => $data['charge_id'],
                'top_depart_id' => $user['top_depart_id'],
                'crt_time' => $time
            ]);

            //更新节点的项目负责人
            $charge_id = Item::where('id', $data['item_id'])->value('charge_id');
            ItemNodeEmployee::where('del_time',0)
                ->where('item_node_id', $id)
                ->where('data_id', $charge_id)
                ->where('type', ItemNodeEmployee::type_one)
                ->delete();
            ItemNodeEmployee::insert([
                'item_node_id' => $id,
                'item_id' => $data['item_id'],
                'data_id' => $charge_id,
                'top_depart_id' => $user['top_depart_id'],
                'type' => ItemNodeEmployee::type_one,
                'crt_time' => $time
            ]);

            //如果任务有数据 更新任务下的节点负责人
            $item_node_mission = ItemNodeMissionEmployee::where('item_node_id', $id)
                ->where('type', ItemNodeMissionEmployee::type_two)
                ->where('data_id', $old_employee_id)
                ->select('item_id', 'item_node_id', 'item_node_mission_id', 'top_depart_id')
                ->get()->toArray();
            ItemNodeMissionEmployee::where('item_id', $id)
                ->where('type', ItemNodeMissionEmployee::type_two)
                ->where('data_id', $old_employee_id)
                ->delete();
            if(! empty($item_node_mission)){
                foreach ($item_node_mission as $key => $value){
                    $item_node_mission[$key]['data_id'] = $data['charge_id'];
                    $item_node_mission[$key]['crt_time'] = $time;
                }
                ItemNodeMissionEmployee::insert($item_node_mission);
            }
        }
    }

    private function saveNodeDetail($id, $time, $data){
        if(! empty($data['man_list'])){
            $unit = [];
            foreach ($data['man_list'] as $value){
                $unit[] = [
                    'item_id' => $data['item_id'],
                    'item_node_id' => $id,
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'crt_time' => $time,
                    'top_depart_id' => $value['top_depart_id'],
                ];
            }
            if(! empty($unit)) ItemNodeDetails::insert($unit);
        }

        if(! empty($data['device_list'])){
            $receipt = [];
            foreach ($data['device_list'] as $value){
                $receipt[] = [
                    'item_id' => $data['item_id'],
                    'item_node_id' => $id,
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'crt_time' => $time,
                    'top_depart_id' => $value['top_depart_id'],
                ];
            }
            if(! empty($receipt)) ItemNodeDetails::insert($receipt);
        }
    }

    private function getNodeDetail($id){
        $data = ItemNodeDetails::where('del_time',0)
            ->where('item_node_id', $id)
            ->get()->toArray();

        $id = $id2 = [];
        foreach ($data as $value){
            if($value['type'] == ItemNodeDetails::type_one) {
                $id[] = $value['data_id'];
            }else{
                $id2[] = $value['data_id'];
            }
        }
        $map = Employee::whereIn('id', $id)->select('title','id','number')->get()->toArray();
        $map = array_column($map,null,'id');
        $map2 = Device::whereIn('id', $id2)->select('code','id','title','type')->get()->toArray();
        $map2 = array_column($map2,null,'id');

        $unit = $receipt = [];
        foreach ($data as $value){
            if($value['type'] == ItemNodeDetails::type_one) {
                $tmp = $map[$value['data_id']] ?? [];
                $unit[] = [
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'data_title' => $tmp['title'],
                    'data_code' => $tmp['number'],
                ];
            }else{
                $tmp = $map2[$value['data_id']] ?? [];
                $receipt[] = [
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'data_title' => $tmp['title'] ?? "",
                    'data_code' => $tmp['code'] ?? "",
                    'type_title' => Device::$type[$tmp['type']],
                ];
            }
        }

        return [
            'man_list' => $unit,
            'device_list' => $receipt,
        ];
    }

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

        list($status, $msg) = $this->checkDelete($data,2);
        if(! $status) return [false, $msg];

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

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

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

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

        return [true, ''];
    }

    public function itemNodeDetail($data, $user){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];
        $customer = ItemNode::where('del_time',0)
            ->withCustomData($user)
            ->where('id',$data['id'])
            ->first();
        if(empty($customer)) return [false,'项目节点不存在或已被删除'];
        $customer->getFormattedCustomFields();// 自定义数据附件处理
        $customer = $customer->toArray();

        $customer['start_time']  = ! empty($customer['start_time']) ? date("Y-m-d", $customer['start_time']) : "";
        $customer['end_time']  = ! empty($customer['end_time']) ? date("Y-m-d", $customer['end_time']) : "";
        $customer['crt_name'] = Employee::where('id',$customer['crt_id'])->value('title');
        $customer['charge_name'] = Employee::where('id',$customer['charge_id'])->value('title');
        $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';
        $customer['state_title'] = ItemNode::State_Type[$customer['state']] ?? '';
        $customer['approval_state_title'] = ItemNode::State_Type[$customer['approval_state']] ?? '';

        $tag = (new TagService())->getTagMap(array_unique([$customer['priority_id'], $customer['node_id'] ]));
        $priority_tmp = $tag[$customer['priority_id']] ?? [];
        $customer['priority_title'] = $priority_tmp['title'] ?? '';
        $customer['priority_code'] = $priority_tmp['code'] ?? '';
        $customer['priority_color'] = $priority_tmp['color'] ?? '';
        $node_tmp = $tag[$customer['node_id']] ?? [];
        $customer['node_title'] = $node_tmp['title'] ?? '';
        $customer['node_code'] = $node_tmp['code'] ?? '';
        $customer['node_color'] = $node_tmp['color'] ?? '';
        $item = Item::where('id', $customer['item_id'])->first();
        $customer['item_code'] = $item->code ?? '';
        $customer['item_title'] = $item->title ?? '';
        $customer['review_title'] = WorkFlowTemplates::where('id', $customer['review_id'])->value('title') ?? "";

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

        return [true, $customer];
    }

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

        //节点信息
        $customer['mission_list'] = $this->itemMissionBoard($data, $user);

        //文件归档
        $customer['file_list'] = $this->getNodeFile($data, $user, $customer);

        return [true, $customer];
    }

    public function itemMissionBoard($data,$user){
        $model = ItemNodeMission::TopAndEmployeeClear($user, $data);
        $list = $model->where('del_time',0)
            ->where('item_node_id', $data['id'])
            ->select('*')
            ->orderby('upd_time', 'desc')
            ->orderby('id', 'desc')
            ->get()->toArray();

        $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_merge_recursive(array_column($list,'charge_id'), array_column($list,'crt_id'))));
        $tag = (new TagService())->getTagMap(array_unique(array_merge_recursive(array_column($list,'priority_id'),array_column($list,'mission_id'))));
        foreach ($list as $key => $value){
            $list[$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $list[$key]['start_time'] = $value['start_time'] ? date('Y-m-d',$value['start_time']) : '';
            $list[$key]['end_time'] = $value['end_time'] ? date('Y-m-d',$value['end_time']) : '';
            $list[$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
            $list[$key]['charge_name'] = $emp[$value['charge_id']] ?? '';
            $list[$key]['state_title'] = ItemNodeMission::State_Type[$value['state']] ?? "";
            $list[$key]['approval_state_title'] = ItemNodeMission::State_Type[$value['approval_state']] ?? "";
            $priority_tmp = $tag[$value['priority_id']] ?? [];
            $list[$key]['priority_title'] = $priority_tmp['title'] ?? '';
            $list[$key]['priority_code'] = $priority_tmp['code'] ?? '';
            $list[$key]['priority_color'] = $priority_tmp['color'] ?? '';
            $node_tmp = $tag[$value['mission_id']] ?? [];
            $list[$key]['mission_title'] = $node_tmp['title'] ?? '';
            $list[$key]['mission_code'] = $node_tmp['code'] ?? '';
            $list[$key]['mission_color'] = $node_tmp['color'] ?? '';
        }

        return $list;
    }

    public function getNodeFile($data, $user, $item){
        $file = ItemFile::where('del_time',0)
            ->where('item_node_id', $data['id'])
            ->get()->toArray();

        $employee_id = array_unique(array_merge_recursive(array_column($file,'crt_id'), array_column($item['custom_fields'],'crt_id')));
        $map = (new EmployeeService())->getEmployeeMap($employee_id);

        $missionIds = [];

        // 分类收集附件对应的来源 ID
        foreach ($file as $v) {
            if ($v['from'] == ItemFile::from_three) {
                $missionIds[] = $v['item_node_mission_id'];
            }
        }

        // 批量捞出各自表的名字映射 (Id => Title)
        $nodeMap    = ItemNode::where('id', $data['id'])->pluck('title', 'id')->toArray();
        $missionMap = !empty($missionIds) ? ItemNodeMission::whereIn('id', array_unique($missionIds))->pluck('title', 'id')->toArray() : [];

        $return = [];
        if(! empty($item['custom_fields'])){
            foreach ($item['custom_fields'] as $value){
                if($value['field_type'] == CustomFieldValue::type_two){
                    $return[] = [
                        'id' => $value['id'],
                        'url' => $value['field_value'],
                        'name' => $value['field_name'],
                        'show_url' => $value['field_value_show'],
                        'type_name' => '节点',
                        'type_name_2' => CustomFieldValue::type[CustomFieldValue::type_two],
                        'type' => 'custom_fields',
                        'from' => ItemFile::type_two,
                        'from_name' => $nodeMap[$value['model_id']] ?? '',
                        'crt_name' => $map[$value['crt_id']],
                        'crt_time' => date("Y-m-d", $value['crt_time']),
                        'crt_id' => $value['crt_id'],
                        'is_delivery' => $value['is_delivery'],
                    ];
                }
            }
        }

        if(! empty($file)){
            $fileUploadService = new FileUploadService();
            foreach ($file as $value){
                $fromName = '';
                if ($value['from'] == ItemFile::from_two) {
                    $fromName = $nodeMap[$value['item_node_id']] ?? '';
                } elseif ($value['from'] == ItemFile::from_three) {
                    $fromName = $missionMap[$value['item_node_mission_id']] ?? '';
                }
                $return[] = [
                    'id' => $value['id'],
                    'url' => $value['url'],
                    'name' => $value['name'],
                    'show_url' => $fileUploadService->getFileShow($value['url']),
                    'type_name' => ItemFile::from[$value['from']],
                    'type_name_2' => ItemFile::type[$value['type']],
                    'type' => 'item_file',
                    'from' => $value['from'],
                    'from_name' => $fromName,
                    'crt_name' => $map[$value['crt_id']],
                    'crt_time' => date("Y-m-d", $value['crt_time']),
                    'crt_id' => $value['crt_id'],
                    'is_delivery' => $value['is_delivery'],
                ];
            }
        }

        return $return;
    }

    public function itemNodeCommon($data,$user, $field = []){
        if(empty($field)) $field = ItemNode::$field;

        $model = ItemNode::TopAndEmployeeClear($user,$data);
        $model = $model->where('del_time',0)
            ->select($field)
            ->orderby('id', 'desc');

        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
        if(! empty($data['code'])) $model->where('code', 'LIKE', '%'.$data['code'].'%');
        if(! empty($data['id'])) $model->whereIn('id', $data['id']);
        if(! empty($data['item_id'])) $model->where('item_id', $data['item_id']);
        if(isset($data['state'])) $model->where('state', $data['state']);
        if(isset($data['approval_stateapproval_state'])) $model->where('approval_state', $data['approval_state']);
        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 itemNodeList($data,$user){
        $model = $this->itemNodeCommon($data, $user);
        $list = $this->limit($model,'',$data);
        $list = $this->fillNodeData($list);

        return [true, $list];
    }

    public function itemNodeRule(&$data, $user, $is_add = true)
    {
        $data['top_depart_id'] = $user['top_depart_id'];

        // 1. 关联项目及状态基础校验
        if (empty($data['item_id'])) return [false, '项目ID不能为空'];

        $project = Item::where('id', $data['item_id'])->where('del_time', 0)->first();
        if (empty($project)) return [false, '项目不存在或已被删除'];
        if ($project->state == Item::TYPE_THREE) return [false, '项目已完结，操作失败'];

        // 2. 节点基础字段校验
        if (empty($data['title'])) return [false, '节点名称不能为空'];
        if (!isset($data['node_weight'])) return [false, '节点权重不存在'];

        list($status, $res) = $this->checkWeight($data['node_weight'], '节点权重');
        if (!$status) return [false, $res];

        // 3. 时间及边界校验
        if (!empty($data['start_time'])) $data['start_time'] = $this->changeDateToDate($data['start_time']);
        if (!empty($data['end_time'])) $data['end_time'] = $this->changeDateToDate($data['end_time'], true);

        if (!empty($data['start_time']) && !empty($data['end_time'])) {
            if ($data['start_time'] > $data['end_time']) return [false, '开始时间不能大于结束时间'];
        }

        // 校验节点时间是否超出项目大周期边界
        if (!empty($data['start_time']) && $project->start_time > 0 && $data['start_time'] < $project->start_time) {
            return [false, '节点开始时间不能早于项目开始时间：' . date('Y-m-d', $project->start_time)];
        }
        if (!empty($data['end_time']) && $project->end_time > 0 && $data['end_time'] > $project->end_time) {
            return [false, '节点结束时间不能晚于项目结束时间：' . date('Y-m-d', $project->end_time)];
        }

        // 4. 列表类数据校验（复用公共辅助方法）
        if (!empty($data['man_list'])) {
            list($status, $msg) = $this->validateListRelation($data['man_list'], $data['top_depart_id'], '人员', 'data_id');
            if (!$status) return [false, $msg];
        }

        if (!empty($data['device_list'])) {
            list($status, $msg) = $this->validateListRelation($data['device_list'], $data['top_depart_id'], '设备', 'data_id');
            if (!$status) return [false, $msg];
        }

        // 5. 核心业务逻辑校验（新增 vs 编辑）
        $titleQuery = ItemNode::where('item_id', $data['item_id'])
            ->where('top_depart_id', $data['top_depart_id'])
            ->where('title', $data['title'])
            ->where('del_time', 0);

        if ($is_add) {
            // 新增：同项目下名称查重
            if ($titleQuery->exists()) return [false, '该项目下节点名称已存在'];
        } else {
            // 编辑：深度状态及下游校验
            if (empty($data['id'])) return [false, 'ID不能为空'];

            $node = ItemNode::where('id', $data['id'])->where('del_time', 0)->first();
            if (empty($node)) return [false, '项目节点不存在或已被删除'];
            // 状态拦截
            if ($node->state == ItemNode::TYPE_THREE) return [false, '节点已完结，操作失败'];
            if ($node->approval_state == ItemNode::TYPE_MINUS_ONE) return [false, '节点审核中，操作失败'];

            //交付物
            if($data['state'] == ItemNode::TYPE_THREE){
                $tableName = $node->getTable();
                list($bool, $msg) = $this->checkIsDelivery($node->toArray(), $tableName);
                if(! $bool) return [false , $msg];
            }

            // 试图完结节点时，校验下游任务
            if (isset($data['state']) && $data['state'] == ItemNode::TYPE_THREE) {
                $hasUnfinishedMission = ItemNodeMission::where('del_time', 0)
                    ->where('item_node_id', $data['id'])
                    ->where('state', '<>', ItemNodeMission::TYPE_THREE)
                    ->exists();
                if ($hasUnfinishedMission) return [false, '节点下存在任务未完结'];
            }

            // 编辑查重：排除自身
            if ($titleQuery->where('id', '<>', $data['id'])->exists()) {
                return [false, '该项目下节点名称已存在'];
            }

            // 变更及草稿判定
            $return = $this->checkItemNodeIsChanged($data, $user);
            if (is_array($return)) {
                return $return;
            } elseif ($return) {
                $data['draft'] = true;
            }
        }

        return [true, ''];
    }

    public function fillNodeData($data){
        if(empty($data['data'])) return $data;

        $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_merge_recursive(array_column($data['data'],'charge_id'), array_column($data['data'],'crt_id'))));
        $tag = (new TagService())->getTagMap(array_unique(array_merge_recursive(array_column($data['data'],'priority_id'),array_column($data['data'],'node_id'))));
        $item = Item::whereIn('id', array_unique(array_column($data['data'],'item_id')))
            ->pluck('title','id')
            ->toArray();
        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $data['data'][$key]['start_time'] = $value['start_time'] ? date('Y-m-d',$value['start_time']) : '';
            $data['data'][$key]['end_time'] = $value['end_time'] ? date('Y-m-d',$value['end_time']) : '';
            $data['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
            $data['data'][$key]['charge_name'] = $emp[$value['charge_id']] ?? '';
            $data['data'][$key]['state_title'] = ItemNode::State_Type[$value['state']] ?? "";
            $data['data'][$key]['approval_state_title'] = ItemNode::State_Type[$value['approval_state']] ?? "";
            $priority_tmp = $tag[$value['priority_id']] ?? [];
            $data['data'][$key]['priority_title'] = $priority_tmp['title'] ?? '';
            $data['data'][$key]['priority_code'] = $priority_tmp['code'] ?? '';
            $data['data'][$key]['priority_color'] = $priority_tmp['color'] ?? '';
            $node_tmp = $tag[$value['node_id']] ?? [];
            $data['data'][$key]['node_title'] = $node_tmp['title'] ?? '';
            $data['data'][$key]['node_code'] = $node_tmp['code'] ?? '';
            $data['data'][$key]['node_color'] = $node_tmp['color'] ?? '';
            $data['data'][$key]['item_title'] = $item[$value['item_id']] ?? '';
        }

        return $data;
    }

    public function itemNodeMissionFinish($data, $user){
        if(empty($data['id'])) return [false, 'ID不能为空'];
        $model = ItemNodeMission::where('id',$data['id'])
            ->where('del_time',0)
            ->first();
        if(empty($model)) return [false, '任务不存在或已被删除'];
        $tableName = $model->getTable();
        $oldData = $model->toArray();
        if($oldData['state'] == ItemNodeMission::TYPE_THREE) return [false, '任务已完成，请勿重复操作'];

        list($bool, $msg) = $this->checkIsDelivery($oldData, $tableName);
        if(! $bool) return [false , $msg];

        $bool = ItemNodeMission::where('del_time',0)
            ->where('parent_item_node_mission_id', $data['id'])
            ->where('state', '<>',ItemNodeMission::TYPE_THREE)
            ->exists();
        if($bool) return [false, '任务下存在子任务未完结'];

        try {
            DB::beginTransaction();

            $bool = $this->changedCommon($user, $oldData);
            if($bool) {
                // 更新项目状态
                $model->approval_state = ItemNodeMission::TYPE_MINUS_ONE;
                $model->save();
                //触发审批流
                $this->createWorkFlow(['id' => $data['id'], 'state' => ItemNodeMission::TYPE_THREE], $user, $model->getTable(), $oldData, 2);

                DB::commit();
                return [true, '更新记录成功，记录草稿，进入审批流程'];
            }

            $model->state = ItemNodeMission::TYPE_THREE;
            $model->save();

            //更新进度
            ProgressCalculatorService::calculate(ProgressCalculatorService::TYPE_MISSION, $model->id);

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

        return [true, ''];
    }

    //项目节点任务
    public function itemNodeMissionEdit($data,$user){
        list($status,$msg) = $this->itemNodeMissionRule($data, $user, false);
        if(!$status) return [$status,$msg];

        list($status, $msg) = $this->itemNodeMissionEditSave($data, $user);
        return [$status, $msg];
    }

    public function itemNodeMissionEditSave($data, $user){
        try {
            DB::beginTransaction();

            $model = ItemNodeMission::where('id', $data['id'])->first();
            $tableName = $model->getTable();

            if(isset($data['draft'])){
                // 更新项目节点状态
                $model->approval_state = ItemNodeMission::TYPE_MINUS_ONE;
                $model->save();
                //触发审批流
                $this->createWorkFlow($data, $user, $tableName, $model->toArray());

                DB::commit();
                return [true, '更新记录成功，记录草稿，进入审批流程'];
            }

            $old_employee_id = $model->charge_id;
            $tableName = $model->getTable();
            $model->title = $data['title'] ?? '';
            $model->mark = $data['mark'] ?? "";
            $model->start_time = $data['start_time'] ?? 0;
            $model->end_time = $data['end_time'] ?? 0;
            $model->due_work_hour = $data['due_work_hour'] ?? 0;
            $model->is_delivery_required = $data['is_delivery_required'] ?? 0;
            $model->entrust_type = $data['entrust_type'] ?? 0;
            $model->charge_id = $data['charge_id'] ?? 0;
            $model->mission_id = $data['mission_id'] ?? 0;
            $model->mission_weight = $data['mission_weight'] ?? 0;
            $model->is_review_required = $data['is_review_required'] ?? 0;
            $model->review_id = $data['review_id'] ?? 0;
            $model->priority_id = $data['priority_id'] ?? 0;
            $model->state = $data['state'] ?? 0;
            $model->save();

            $time = time();
            ItemNodeMissionDetails::where('del_time',0)
                ->where('item_node_mission_id', $model->id)
                ->update(['del_time' => $time]);

            $this->saveNodeMissionDetail($model->id, $time, $data);

            // 人员项目节点任务表
            $this->saveNodeMissionEmployee($model->id, $time, $data, $user, $old_employee_id);

            list($status, $msg) = CustomFieldSettingService::syncCustomFieldData($model->id, $tableName, $data, $user);
            if (! $status) {
                DB::rollBack();
                return [false, $msg];
            }

            //更新进度
            ProgressCalculatorService::calculate(ProgressCalculatorService::TYPE_MISSION, $model->id);

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

        return [true, ''];
    }

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

        try {
            DB::beginTransaction();

            $model = new ItemNodeMission();
            $model->item_id = $data['item_id'] ?? 0;
            $model->item_node_id = $data['item_node_id'] ?? 0;
            $model->parent_item_node_mission_id = $data['parent_item_node_mission_id'] ?? 0;
            $tableName = $model->getTable();
            $model->code = $this->generateBillNo([
                'top_depart_id' => $user['top_depart_id'],
                'type' => ItemNodeMission::Order_type,
                'period' => date("Ym", time())
            ]);
            $model->title = $data['title'] ?? '';
            $model->mark = $data['mark'] ?? "";
            $model->start_time = $data['start_time'] ?? 0;
            $model->end_time = $data['end_time'] ?? 0;
            $model->due_work_hour = $data['due_work_hour'] ?? 0;
            $model->is_delivery_required = $data['is_delivery_required'] ?? 0;
            $model->entrust_type = $data['entrust_type'] ?? 0;
            $model->charge_id = $data['charge_id'] ?? 0;
            $model->mission_id = $data['mission_id'] ?? 0;
            $model->mission_weight = $data['mission_weight'] ?? 0;
            $model->is_review_required = $data['is_review_required'] ?? 0;
            $model->review_id = $data['review_id'] ?? 0;
            $model->priority_id = $data['priority_id'] ?? 0;
            $model->state = $data['state'] ?? 0;
            $model->crt_id = $user['id'];
            $model->top_depart_id = $data['top_depart_id'];
            $model->save();

            $time = time();
            $this->saveNodeMissionDetail($model->id, $time, $data);

            // 人员项目节点任务表
            $this->saveNodeMissionEmployee($model->id, $time, $data, $user);

            list($status, $msg) = CustomFieldSettingService::syncCustomFieldData($model->id, $tableName, $data, $user);
            if (!$status) {
                DB::rollBack();
                return [false, $msg];
            }

            //更新进度
            ProgressCalculatorService::calculate(ProgressCalculatorService::TYPE_MISSION, $model->id);

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

        return [true, ''];
    }

    private function saveNodeMissionEmployee($id, $time, $data, $user, $old_employee_id = 0){
        if($old_employee_id != $data['charge_id']){
            ItemNodeMissionEmployee::where('del_time',0)
                ->where('item_node_mission_id', $id)
                ->where('data_id', $old_employee_id)
                ->where('type', ItemNodeMissionEmployee::type_zero)
                ->delete();

            ItemNodeMissionEmployee::insert([
                'item_node_mission_id' => $id,
                'item_node_id' => $data['item_node_id'],
                'item_id' => $data['item_id'],
                'data_id' => $data['charge_id'],
                'top_depart_id' => $user['top_depart_id'],
                'crt_time' => $time
            ]);

            //更新任务的节点负责人
            $charge_id = ItemNode::where('id', $data['item_node_id'])->value('charge_id');
            ItemNodeMissionEmployee::where('del_time',0)
                ->where('item_node_mission_id', $id)
                ->where('data_id', $charge_id)
                ->where('type', ItemNodeMissionEmployee::type_two)
                ->delete();
            ItemNodeMissionEmployee::insert([
                'item_node_mission_id' => $id,
                'item_node_id' => $data['item_node_id'],
                'item_id' => $data['item_id'],
                'data_id' => $charge_id,
                'top_depart_id' => $user['top_depart_id'],
                'type' =>  ItemNodeMissionEmployee::type_two,
                'crt_time' => $time
            ]);

            //更新任务的项目负责人
            $charge_id = Item::where('id', $data['item_id'])->value('charge_id');
            ItemNodeMissionEmployee::where('del_time',0)
                ->where('item_node_mission_id', $id)
                ->where('data_id', $charge_id)
                ->where('type', ItemNodeMissionEmployee::type_one)
                ->delete();
            ItemNodeMissionEmployee::insert([
                'item_node_mission_id' => $id,
                'item_node_id' => $data['item_node_id'],
                'item_id' => $data['item_id'],
                'data_id' => $charge_id,
                'top_depart_id' => $user['top_depart_id'],
                'type' =>  ItemNodeMissionEmployee::type_one,
                'crt_time' => $time
            ]);
        }
    }

    private function saveNodeMissionDetail($id, $time, $data){
        if(! empty($data['man_list'])){
            $unit = [];
            foreach ($data['man_list'] as $value){
                $unit[] = [
                    'item_id' => $data['item_id'],
                    'item_node_id' => $data['item_node_id'],
                    'item_node_mission_id' => $id,
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'crt_time' => $time,
                    'top_depart_id' => $value['top_depart_id'],
                ];
            }
            if(! empty($unit)) ItemNodeMissionDetails::insert($unit);
        }

        if(! empty($data['device_list'])){
            $receipt = [];
            foreach ($data['device_list'] as $value){
                $receipt[] = [
                    'item_id' => $data['item_id'],
                    'item_node_id' => $data['item_node_id'],
                    'item_node_mission_id' => $id,
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'crt_time' => $time,
                    'top_depart_id' => $value['top_depart_id'],
                ];
            }
            if(! empty($receipt)) ItemNodeMissionDetails::insert($receipt);
        }
    }

    private function getNodeMissionDetail($id){
        $data = ItemNodeMissionDetails::where('del_time',0)
            ->where('item_node_mission_id', $id)
            ->get()->toArray();

        $id = $id2 = [];
        foreach ($data as $value){
            if($value['type'] == ItemNodeMissionDetails::type_one) {
                $id[] = $value['data_id'];
            }else{
                $id2[] = $value['data_id'];
            }
        }
        $map = Employee::whereIn('id', $id)->select('title','id','number')->get()->toArray();
        $map = array_column($map,null,'id');
       $map2 = Device::whereIn('id', $id2)->select('code','id','title','type')->get()->toArray();
        $map2 = array_column($map2,null,'id');

        $unit = $receipt = [];
        foreach ($data as $value){
            if($value['type'] == ItemNodeMissionDetails::type_one) {
                $tmp = $map[$value['data_id']] ?? [];
                $unit[] = [
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'data_title' => $tmp['title'],
                    'data_code' => $tmp['number'],
                ];
            }else{
                $tmp = $map2[$value['data_id']] ?? [];
                $receipt[] = [
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'data_title' => $tmp['title'] ?? "",
                    'data_code' => $tmp['code'] ?? "",
                    'type_title' => Device::$type[$tmp['type']],
                ];
            }
        }

        return [
            'man_list' => $unit,
            'device_list' => $receipt,
        ];
    }

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

        list($status, $msg) = $this->checkDelete($data,3);
        if(! $status) return [false, $msg];
        try {
            DB::beginTransaction();
            $time = time();

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

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

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

        return [true, ''];
    }

    public function itemNodeMissionDetail($data, $user){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];
        $customer = ItemNodeMission::where('del_time',0)
            ->withCustomData($user)
            ->where('id',$data['id'])
            ->first();
        if(empty($customer)) return [false,'项目节点任务不存在或已被删除'];
        $customer->getFormattedCustomFields();// 自定义数据附件处理
        $customer = $customer->toArray();

        $customer['start_time']  = ! empty($customer['start_time']) ? date("Y-m-d", $customer['start_time']) : "";
        $customer['end_time']  = ! empty($customer['end_time']) ? date("Y-m-d", $customer['end_time']) : "";
        $customer['crt_name'] = Employee::where('id',$customer['crt_id'])->value('title');
        $customer['charge_name'] = Employee::where('id',$customer['charge_id'])->value('title');
        $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';
        $customer['state_title'] = ItemNodeMission::State_Type[$customer['state']] ?? '';
        $customer['approval_state_title'] = ItemNodeMission::State_Type[$customer['approval_state']] ?? '';

        $tag = (new TagService())->getTagMap(array_unique([$customer['priority_id'], $customer['mission_id'] ]));
        $priority_tmp = $tag[$customer['priority_id']] ?? [];
        $customer['priority_title'] = $priority_tmp['title'] ?? '';
        $customer['priority_code'] = $priority_tmp['code'] ?? '';
        $customer['priority_color'] = $priority_tmp['color'] ?? '';
        $node_tmp = $tag[$customer['mission_id']] ?? [];
        $customer['mission_title'] = $node_tmp['title'] ?? '';
        $customer['mission_code'] = $node_tmp['code'] ?? '';
        $customer['mission_color'] = $node_tmp['color'] ?? '';
        $customer['parent_item_node_mission_title'] = ItemNodeMission::where('id', $customer['parent_item_node_mission_id'])->value('title') ?? '';
        $customer['review_title'] = WorkFlowTemplates::where('id', $customer['review_id'])->value('title') ?? "";

        $item_map = $this->getItemMap([$customer['item_id']]);
        $item_tmp = $item_map[$customer['item_id']] ?? [];
        $customer['item_title'] = $item_tmp['title'] ?? '';

        $item_node_map = $this->getItemNodeMap($customer['id']);
        $customer['item_node_title'] = $item_node_map[$customer['id']];

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

        return [true, $customer];
    }

    public function itemNodeMissionUpdateState($data, $user){
        if(empty($data['id'])) return [false, '任务ID不能为空'];
        if(empty($data['state']) || ! isset(ItemNodeMission::State_Type[$data['state']])) return [false, '状态不存在错误'];
        $model = ItemNodeMission::where('del_time',0)
            ->where('id',$data['id'])
            ->first();
        if(empty($model)) return [false,'项目节点任务不存在或已被删除'];
        $tableName = $model->getTable();
        $oldData = $model->toArray();
        if($model->approval_state == ItemNodeMission::TYPE_MINUS_ONE) return [false, '任务审核中'];
        if($model->state == ItemNodeMission::TYPE_THREE) return [false, '任务已完结'];

        //完结校验交付物
        if($data['state'] == ItemNodeMission::TYPE_THREE){
            list($bool, $msg) = $this->checkIsDelivery($oldData, $tableName);
            if(! $bool) return [false , $msg];
        }

        try {
            DB::beginTransaction();

            $bool = $this->changedCommon($user, $oldData);
            if($bool) {
                // 更新项目状态
                $model->approval_state = ItemNodeMission::TYPE_MINUS_ONE;
                $model->save();
                //触发审批流
                $this->createWorkFlow(['id' => $data['id'], 'state' => ItemNodeMission::TYPE_THREE], $user, $tableName, $oldData, 2);

                DB::commit();
                return [true, '更新记录成功，记录草稿，进入审批流程'];
            }

            $model->state = $data['state'];
            $model->save();

            //更新进度
            ProgressCalculatorService::calculate(ProgressCalculatorService::TYPE_MISSION, $model->id);

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

        return [true, ''];
    }

    public function itemNodeMissionUpdateProgressContent($data, $user){
        if(empty($data['id'])) return [false, '任务ID不能为空'];
        $customer = ItemNodeMission::where('del_time',0)
            ->where('id',$data['id'])
            ->first();
        if(empty($customer)) return [false,'项目节点任务不存在或已被删除'];
        $customer = $customer->toArray();
        if($customer['state'] == ItemNodeMission::TYPE_THREE) return [false, '任务已完成'];

        if(empty($data['data'])) return [false, '任务进展明细不能为空'];

        $empDisplayMap = Employee::whereIn('id', array_unique(array_column($data['data'],'data_id')))
            ->get(['id', 'number', 'title'])
            ->mapWithKeys(function($item){
                return [$item->id => "[{$item->number}]{$item->title}"];
            })->toArray();

        foreach ($data['data'] as $key => $value){
            $line = $key + 1;
            $t = "第" . $line . "行";
            if(empty($value['data_id'])) return [false, '人员ID不能为空'];
            $empId = $value['data_id'] ?? 0;
            $empName = $empDisplayMap[$empId] ?? "ID:{$empId}";
            if(empty($value['order_time'])) return [false, '提交日期不能为空'];
            $order_time = $this->changeDateToDate($value['order_time']);
            if($order_time > $customer['end_time'] || $order_time < $customer['start_time']) return [false, $t . "提交日期必须在任务周期内"];
            $data['data'][$key]['order_time'] = $order_time;

            // 校验数字有效性
            $res = $this->checkNumber($value['start_time_hour'], 0, 'non-negative');
            if(!$res['valid']) return [false, $t . "人员{$empName}开始点：" . $res['error']];
            if($value['start_time_hour'] > 23) return [false, false, $t . "人员{$empName}开始点不合法"];
            $res = $this->checkNumber($value['start_time_min'], 0, 'non-negative');
            if(!$res['valid']) return [false, $t ."人员{$empName}开始分：" . $res['error']];
            if($value['start_time_min'] > 60) return [false, false, $t . "人员{$empName}开始点不合法"];
            $res = $this->checkNumber($value['end_time_hour'], 0, 'non-negative');
            if(!$res['valid']) return [false, $t ."人员{$empName}结束点：" . $res['error']];
            if($value['end_time_hour'] > 24) return [false, false, $t . "人员{$empName}结束点不合法"];
            $res = $this->checkNumber($value['end_time_min'], 0, 'non-negative');
            if(!$res['valid']) return [false, $t ."人员{$empName}结束分：" . $res['error']];
            if($value['end_time_min'] > 60) return [false, false, $t . "人员{$empName}结束分不合法"];

            $currentStart = $value['start_time_hour'] * 60 + $value['start_time_min'];
            $currentEnd   = $value['end_time_hour'] * 60 + $value['end_time_min'];

            if ($currentStart >= $currentEnd) {
                return [false, $t . "人员{$empName}：开始时间必须早于结束时间"];
            }

            // --- 新增：总分钟数校验 ---
            $calculatedTotal = $currentEnd - $currentStart;
            if (!isset($value['total_work_min']) || intval($value['total_work_min']) !== $calculatedTotal) {
                return [false, $t . "人员{$empName}：工时计算有误，应为 {$calculatedTotal} 分钟"];
            }

            // --- 3. 内部重叠校验（防止一次提交多行重复） ---
            if (isset($internalOverlap[$empId])) {
                foreach ($internalOverlap[$empId] as $period) {
                    if ($currentStart < $period['e'] && $period['s'] < $currentEnd) {
                        return [false, "人员{$empName}在本次提交的多行明细中时间段重叠"];
                    }
                }
            }
            $internalOverlap[$empId][] = ['s' => $currentStart, 'e' => $currentEnd];

            $data['data'][$key]['item_id'] = $customer['item_id'];
            $data['data'][$key]['item_node_id'] = $customer['item_node_id'];
            $data['data'][$key]['item_node_mission_id'] = $customer['id'];
            $data['data'][$key]['top_depart_id'] = $user['top_depart_id'];
            $data['data'][$key]['crt_id'] = $user['id'];
        }

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

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

            ItemNodeMissionContent::insert($data['data']);

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

        return [true, ''];
    }

    public function itemNodeMissionUpdateProgress($data, $user){
        if(empty($data['id'])) return [false, 'ID不能为空'];
        $customer = ItemNodeMission::where('del_time',0)
            ->where('id',$data['id'])
            ->first();
        if(empty($customer)) return [false,'项目节点任务不存在或已被删除'];
        $order = $customer->toArray();
        if($order['state'] == ItemNodeMission::TYPE_THREE) return [false, '任务已完成'];
        if(empty($data['progress'])) return [false, '任务进展不能为空'];
        $res = $this->checkNumber($data['progress'],0,'positive');
        if (! $res['valid']) return [false, "任务进展:" . $res['error']];
        if($data['progress'] > 100) return [false, '任务进展不能超过100'];

        $customer->progress = $data['progress'];
        $customer->save();

        return [true, ''];
    }

    public function itemNodeMissionBatchUpdateProgressContent($data, $user)
    {
        if (empty($data['data']) || !is_array($data['data'])) {
            return [false, '任务进展明细不能为空'];
        }

        // 1. 批量收集涉及的所有任务 ID 和人员 ID，用于前置内存缓存
        $missionIds = array_filter(array_unique(array_column($data['data'], 'item_node_mission_id')));
        $empIds     = array_filter(array_unique(array_column($data['data'], 'data_id')));
        $detailIds  = array_filter(array_unique(array_column($data['data'], 'id'))); // 收集所有传了的明细ID

        if (empty($missionIds)) return [false, '明细中缺少有效的任务ID'];

        // 2. 批量查出相关任务和人员花名册，杜绝循环查 SQL
        $missionsMap = ItemNodeMission::where('del_time', 0)->whereIn('id', $missionIds)->get()->keyBy('id')->toArray();
        $empDisplayMap = Employee::whereIn('id', $empIds)->get(['id', 'number', 'title'])->mapWithKeys(function($item){
            return [$item->id => "[{$item->number}]{$item->title}"];
        })->toArray();

        // 3. 一次性把这些任务/人在这些日期的已有数据库报告捞出来（用于做高效率的重叠比对）
        // 这样就不用在 for 循环里去一条条 count 查重了
        $dbPeriods = ItemNodeMissionContent::where('del_time', 0)
            ->whereIn('item_node_mission_id', $missionIds)
            ->whereIn('data_id', $empIds)
            ->get(['id', 'item_node_mission_id', 'data_id', 'order_time', 'start_time_hour', 'start_time_min', 'end_time_hour', 'end_time_min'])
            ->toArray();

        // 用于校验“本次提交内部”时间段是否重叠
        $internalOverlap = [];
        // 最终准备执行的数据集
        $finalRows = [];

        // 4. 循环校验
        foreach ($data['data'] as $key => $value) {
            $line = $key + 1;
            $t = "第 " . $line . " 行：";

            $detailId  = $value['id'] ?? 0; // 明细自增ID（有代表修改，无代表新增）
            $missionId = $value['item_node_mission_id'] ?? 0;
            $empId     = $value['data_id'] ?? 0;

            if (empty($missionId) || empty($empId)) return [false, $t . '任务ID和人员ID不能为空'];
            if (!isset($missionsMap[$missionId])) return [false, $t . "任务[ID:{$missionId}]不存在"];

            $customer = $missionsMap[$missionId];
            $empName  = $empDisplayMap[$empId] ?? "ID:{$empId}";

            if ($customer['state'] == ItemNodeMission::TYPE_THREE) {
                return [false, $t . "任务【{$customer['title']}】已完成，不可操作"];
            }

            // 日期校验
            if (empty($value['order_time'])) return [false, $t . '提交日期不能为空'];
            $order_time = $this->changeDateToDate($value['order_time']);
            if ($order_time > $customer['end_time'] || $order_time < $customer['start_time']) {
                return [false, $t . "人员{$empName}的提交日期必须在任务周期内"];
            }

            // 基础数字校验 (调用你的校验函数)
            if ($value['start_time_hour'] > 23 || $value['start_time_min'] > 59 || $value['end_time_hour'] > 24 || $value['end_time_min'] > 59) {
                return [false, $t . "人员{$empName}提交的时间点不合法"];
            }

            // 转化为分钟数
            $currentStart = $value['start_time_hour'] * 60 + $value['start_time_min'];
            $currentEnd   = $value['end_time_hour'] * 60 + $value['end_time_min'];

            if ($currentStart >= $currentEnd) return [false, $t . "人员{$empName}：开始时间必须早于结束时间"];

            // 总分钟数校验
            $calculatedTotal = $currentEnd - $currentStart;
            if (!isset($value['total_work_min']) || intval($value['total_work_min']) !== $calculatedTotal) {
                return [false, $t . "人员{$empName}：工时计算有误，应为 {$calculatedTotal} 分钟"];
            }

            // --- 5. 校验【本次提交内部】的重叠 ---
            if (isset($internalOverlap[$missionId][$empId][$order_time])) {
                foreach ($internalOverlap[$missionId][$empId][$order_time] as $period) {
                    if ($currentStart < $period['e'] && $period['s'] < $currentEnd) {
                        return [false, $t . "人员{$empName}在本次提交的多行明细中时间段重叠"];
                    }
                }
            }
            $internalOverlap[$missionId][$empId][$order_time][] = ['s' => $currentStart, 'e' => $currentEnd];

            // --- 6. 核心：校验【与数据库已有数据】的重叠 ---
            foreach ($dbPeriods as $dbRow) {
                // 只有当 任务、人、日期 完全一致时，才需要比对时间段
                if ($dbRow['item_node_mission_id'] == $missionId && $dbRow['data_id'] == $empId && $dbRow['order_time'] == $order_time) {

                    // 【核心优化点】：如果是编辑状态，排查重叠时必须“排除掉自己这条记录”
                    if ($detailId > 0 && $dbRow['id'] == $detailId) {
                        continue;
                    }

                    $dbStart = $dbRow['start_time_hour'] * 60 + $dbRow['start_time_min'];
                    $dbEnd   = $dbRow['end_time_hour'] * 60 + $dbRow['end_time_min'];

                    // 判断时间段是否有交集：开始A < 结束B 并且 开始B < 结束A
                    if ($currentStart < $dbEnd && $dbStart < $currentEnd) {
                        return [false, $t . "人员{$empName}在系统已有记录中存在重叠的时间段({$dbRow['start_time_hour']}:{$dbRow['start_time_min']} ~ {$dbRow['end_time_hour']}:{$dbRow['end_time_min']})"];
                    }
                }
            }

            // 收集待处理数据
            $finalRows[] = [
                'id'                         => $detailId, // 捎带上ID，后面分流用
                'item_id'                    => $customer['item_id'],
                'item_node_id'               => $customer['item_node_id'],
                'item_node_mission_id'       => $missionId,
                'data_id'                    => $empId,
                'content'                    => $value['content'] ?? '',
                'order_time'                 => $order_time,
                'total_work_min'             => $calculatedTotal,
                'start_time_hour'            => $value['start_time_hour'],
                'start_time_min'             => $value['start_time_min'],
                'end_time_hour'              => $value['end_time_hour'],
                'end_time_min'               => $value['end_time_min'],
            ];
        }

        // 7. 事务处理：分流执行 Update 和 Insert
        try {
            DB::beginTransaction();
            $time = time();

            $inserts = [];
            foreach ($finalRows as $row) {
                $id = $row['id'];
                unset($row['id']); // 从数组中剥离自增 ID

                if ($id > 0) {
                    // 情况 A：有 ID，执行精准修改
                    ItemNodeMissionContent::where('id', $id)->update($row);
                } else {
                    // 情况 B：没有 ID，放入待插入队列
                    $row['top_depart_id'] = $user['top_depart_id'];
                    $row['crt_id']        = $user['id'];
                    $row['crt_time']      = $time;
                    $inserts[] = $row;
                }
            }

            // 批量插入新数据
            if (!empty($inserts)) {
                ItemNodeMissionContent::insert($inserts);
            }

            DB::commit();
        } catch (\Exception $exception) {
            DB::rollBack();
            return [false, '保存失败：' . $exception->getMessage()];
        }

        return [true, ''];
    }

    /**
     * 批量删除任务报告
     * @param array $data ['id' => [1, 2, 3...]] 报告ID数组
     * @param array $user 当前登录人信息
     * @return array [bool, string]
     */
    public function itemNodeMissionContentDelete($data, $user)
    {
        // 兼容前端可能传单个 ID 或 ID 数组的情况
        $ids = isset($data['id']) ? (array)$data['id'] : [];
        $ids = array_filter(array_unique($ids));

        if (empty($ids)) {
            return [false, '请选择要删除的任务报告'];
        }

        // 1. 连表查询这些报告所属任务的状态
        // 目的：找出有没有属于“已完成”状态任务的报告
        $completedMissions = DB::table('item_node_mission_content as e')
            ->join('item_node_mission as i', 'e.item_node_mission_id', '=', 'i.id')
            ->whereIn('e.id', $ids)
            ->where('e.del_time', 0)
            ->where('i.state', ItemNodeMission::TYPE_THREE) // 任务已完成状态
            ->select('e.id as content_id', 'i.title as mission_title')
            ->get();

        // 2. 核心校验：如果存在已完成任务的报告，直接拦截报错
        if ($completedMissions->isNotEmpty()) {
            $firstError = $completedMissions->first();
            return [false, "任务【{$firstError->mission_title}】已完成，不允许删除该任务下的任何进展报告"];
        }

        // 3. 事务处理：批量执行软删除
        try {
            DB::beginTransaction();
            $time = time();

            // 批量将这些报告的 del_time 更新为当前时间戳（软删除）
            $effectRows = ItemNodeMissionContent::whereIn('id', $ids)
                ->where('del_time', 0)
                ->update([
                    'del_time' => $time,
                    'upd_time' => $time // 顺便把更新时间也同步了
                ]);

            if ($effectRows === 0) {
                DB::rollBack();
                return [false, '未找到有效的任务报告或报告已被删除'];
            }

            DB::commit();
        } catch (\Exception $exception) {
            DB::rollBack();
            return [false, '删除失败：' . $exception->getMessage()];
        }

        return [true, ''];
    }

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

        //任务进展信息
        list($status, $msg) = $this->itemMissionProgressBoard($data, $user);
        $customer['mission_progress'] = $msg;

        //文件归档
        $customer['file_list'] = $this->getMissionProgressFile($data, $user, $customer);

        return [true, $customer];
    }

    public function itemMissionProgressListCommon($data, $user, $field = []){
        $item_id = $data['item_id'] ?? 0;
        $item_node_id = $data['item_node_id'] ?? 0;
        $item_node_mission_id = $data['item_node_mission_id'] ?? 0;
        $employee_id = $data['employee_id'] ?? 0;

        // 是否是超级管理员
        $isAdmin = ($user['is_admin'] ?? 0) == Employee::IS_ADMIN_TWO;

        $model = ItemNodeMission::from('item_node_mission as i');
        $model = $model->TopAndEmployeeClear($user, $data)

            // 2. 优化重点：把报告可见性逻辑直接作为 JOIN 条件绑定
            ->leftJoin('item_node_mission_content as e', function($join) use ($user, $isAdmin) {
                $join->on('i.id', '=', 'e.item_node_mission_id')
                    ->where('e.del_time', 0);

                // 如果【不是】超级管理员，才进行严格的“负责人/自己填写的报告”权限隔离
                if (!$isAdmin) {
                    $join->where(function($q) use ($user) {
                        // 或者是当前登录人自己写的报告
                        $q->where('e.data_id', $user['id'])
                            // 或者当前登录人是这笔任务的负责人
                            ->orWhereExists(function ($subQuery) use ($user) {
                                $subQuery->from('item_node_mission_employee')
                                    ->whereColumn('item_node_mission_employee.item_node_mission_id', 'i.id')
                                    ->where('item_node_mission_employee.data_id', $user['id'])
                                    ->where('item_node_mission_employee.del_time', 0);
                            });
                    });
                }
                // 如果是超级管理员，直接跳过限制，无缝关联该任务下的【所有】进展报告
            })
            ->where('e.del_time', 0)

            // 【重要修复】：下面的业务筛选必须查主表 `i` 的字段！
            // 因为主表 `i` 是必然有数据的，而 `e` 是 leftJoin 出来的，查 `i` 才能保证索引和数据的绝对正确
            ->when(! empty($item_id), function ($query) use($item_id){
                return $query->where('i.item_id', $item_id);
            })
            ->when(! empty($item_node_id), function ($query) use($item_node_id){
                return $query->where('i.item_node_id', $item_node_id);
            })
            ->when(! empty($item_node_mission_id), function ($query) use($item_node_mission_id){
                return $query->where('i.id', $item_node_mission_id);
            })
            // 如果传了具体要查某个人(employee_id)写的报告，这里可以查 e.data_id
            ->when(! empty($employee_id), function ($query) use($employee_id){
                return $query->where('e.data_id', $employee_id);
            })
            ->select('e.*')
            ->orderby('e.id', 'desc');

        return $model;
    }

    public function itemMissionProgressList($data, $user){
        $model = $this->itemMissionProgressListCommon($data, $user);
        $list = $this->limit($model,'',$data);
        $list = $this->fillItemMissionProgressList($list, $user);

        return [true, $list];
    }

    public function fillItemMissionProgressList($list, $user){
        $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_merge_recursive(array_column($list['data'],'data_id'), array_column($list['data'],'crt_id'))));

        $item = $this->getItemMap(array_unique(array_column($list['data'],'item_id')));
        $itemNode = $this->getItemNodeMap2(array_unique(array_column($list['data'],'item_node_id')));
        $mission_id = array_unique(array_column($list['data'],'item_node_mission_id'));
        $itemNodeMission = $this->getItemNodeMissionMap($mission_id);
        $mission_man = $this->getMissionMembersMap($mission_id, $user);
        foreach ($list['data'] as $key => $value){
            $list['data'][$key]['order_time'] = $value['order_time'] ? date('Y-m-d',$value['order_time']) : '';
            $list['data'][$key]['start_time'] = $value['start_time_hour'] . ':' . $value['start_time_min'];
            $list['data'][$key]['end_time'] = $value['end_time_hour'] . ':' . $value['end_time_min'];
            $list['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $list['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
            $list['data'][$key]['data_name'] = $emp[$value['data_id']] ?? '';
            $item_tmp = $item[$value['item_id']] ?? [];
            $list['data'][$key]['item_title'] = $item_tmp['title'] ?? '';
            $item_node_tmp = $itemNode[$value['item_node_id']] ?? [];
            $list['data'][$key]['item_node_title'] = $item_node_tmp['title'] ?? '';
            $item_node_mission_tmp = $itemNodeMission[$value['item_node_mission_id']] ?? [];
            $list['data'][$key]['item_node_mission_title'] = $item_node_mission_tmp['title'] ?? '';
            $list['data'][$key]['mission_man'] = $mission_man[$value['item_node_mission_id']] ?? [];
        }

        return $list;
    }

    public function itemMissionProgressBoard($data = [], $user = []){
        $is_my = $data['is_my'] ?? 0;
        $my = $user['id'] ?? 0;
        $share_id = $data['item_node_mission_share_id'] ?? 0;
        $list = ItemNodeMissionContent::where('del_time',0)
            ->where('item_node_mission_id', $data['id'])
            ->when(! empty($is_my),function ($query) use($my){
                return $query->where('crt_id', $my);
            })
            ->when(! empty($share_id),function ($query) use($share_id){
                return $query->where('item_node_mission_share_id', $share_id);
            })
            ->select('*')
            ->get()->toArray();

        $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_merge_recursive(array_column($list,'data_id'), array_column($list,'crt_id'))));
        foreach ($list as $key => $value){
            $list[$key]['order_time'] = $value['order_time'] ? date('Y-m-d',$value['order_time']) : '';
            $list[$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $list[$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
            $list[$key]['data_name'] = $emp[$value['data_id']] ?? '';
        }

        return [true, $list];
    }

    public function getMissionProgressFile($data, $user, $item){
        $file = ItemFile::where('del_time',0)
            ->where('item_node_mission_id', $data['id'])
            ->get()->toArray();

        $employee_id = array_unique(array_merge_recursive(array_column($file,'crt_id'), array_column($item['custom_fields'],'crt_id')));
        $map = (new EmployeeService())->getEmployeeMap($employee_id);

        $missionIds = [];

        // 分类收集附件对应的来源 ID
        foreach ($file as $v) {
            if ($v['from'] == ItemFile::from_three) {
                $missionIds[] = $v['item_node_mission_id'];
            }
        }

        // 批量捞出各自表的名字映射 (Id => Title)
        $missionMap = !empty($missionIds) ? ItemNodeMission::whereIn('id', array_unique($missionIds))->pluck('title', 'id')->toArray() : [];

        $return = [];
        if(! empty($item['custom_fields'])){
            foreach ($item['custom_fields'] as $value){
                if($value['field_type'] == CustomFieldValue::type_two){
                    $return[] = [
                        'id' => $value['id'],
                        'url' => $value['field_value'],
                        'name' => $value['field_name'],
                        'show_url' => $value['field_value_show'],
                        'type_name' => '任务',
                        'type_name_2' => CustomFieldValue::type[CustomFieldValue::type_two],
                        'type' => 'custom_fields',
                        'from' => ItemFile::type_two,
                        'from_name' =>$missionMap[$value['model_id']] ?? '',
                        'crt_name' => $map[$value['crt_id']],
                        'crt_time' => date("Y-m-d", $value['crt_time']),
                        'crt_id' => $value['crt_id'],
                        'is_delivery' => $value['is_delivery'],
                    ];
                }
            }
        }

        if(! empty($file)){
            $fileUploadService = new FileUploadService();
            foreach ($file as $value){
                $fromName = '';
                if ($value['from'] == ItemFile::from_three) {
                    $fromName = $missionMap[$value['item_node_mission_id']] ?? '';
                }
                $return[] = [
                    'id' => $value['id'],
                    'url' => $value['url'],
                    'name' => $value['name'],
                    'show_url' => $fileUploadService->getFileShow($value['url']),
                    'type_name' => ItemFile::from[$value['from']],
                    'type_name_2' => ItemFile::type[$value['type']],
                    'type' => 'item_file',
                    'from' => $value['from'],
                    'from_name' => $fromName,
                    'crt_name' => $map[$value['crt_id']],
                    'crt_time' => date("Y-m-d", $value['crt_time']),
                    'crt_id' => $value['crt_id'],
                    'is_delivery' => $value['is_delivery'],
                ];
            }
        }

        return $return;
    }

    public function itemNodeMissionCommon($data,$user, $field = []){
        if(empty($field)) $field = ItemNodeMission::$field;

        $item_id = $data['item_id'] ?? 0;
        $item_node_id = $data['item_node_id'] ?? 0;
        $except_state = $data['except_state'] ?? 0;
        $model = ItemNodeMission::TopAndEmployeeClear($user,$data);
        $model = $model->where('del_time',0)
            ->when(! empty($item_id),function ($query) use($item_id){
                return $query->where('item_id', $item_id);
            })
            ->when(! empty($item_node_id),function ($query) use($item_node_id){
                return $query->where('item_node_id', $item_node_id);
            })
            ->when(! empty($except_state),function ($query) use($except_state){
                return $query->whereNotIn('state', (array)$except_state);
            })
            ->select($field)
            ->orderby('id', 'desc');


        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
        if(! empty($data['code'])) $model->where('code', 'LIKE', '%'.$data['code'].'%');
        if(! empty($data['id'])) $model->whereIn('id', $data['id']);
        if(isset($data['state'])) $model->where('state', $data['state']);
        if(isset($data['approval_state'])) $model->where('approval_state', $data['approval_state']);
        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 itemNodeMissionList($data,$user){
        $model = $this->itemNodeMissionCommon($data, $user);
        $list = $this->limit($model,'',$data);
        $list = $this->fillNodeMissionData($list, $data, $user);

        return [true, $list];
    }

    public function itemNodeMissionListBySearch($data,$user){
        list($status, $model) = $this->itemNodeMissionCommonBySearch($data, $user);
        if(! $status) return [false, $model];

        $list['data'] = $model->get()->toArray();
        $list = $this->fillNodeMissionData($list, $data, $user);

        return [true, $list['data']];
    }

    public function itemNodeMissionCommonBySearch($data,$user, $field = []){
        if(empty($field)) $field = ItemNodeMission::$field;
        if(empty($data['item_id'])) return [false, '请选择项目'];
        $item_node_id = $data['item_node_id'] ?? 0;

        $model = ItemNodeMission::TopAndEmployeeClear($user,$data);
        $model = $model->where('del_time',0)
            ->where('item_id', $data['item_id'])
            ->when(! empty($item_node_id),function ($query) use($item_node_id){
                return $query->where('item_node_id', $item_node_id);
            })
            ->select($field)
            ->orderby('id', 'desc');

        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
        if(! empty($data['code'])) $model->where('code', 'LIKE', '%'.$data['code'].'%');
        if(! empty($data['id'])) $model->whereIn('id', $data['id']);
        if(isset($data['state'])) $model->where('state', $data['state']);
        if(isset($data['approval_state'])) $model->where('approval_state', $data['approval_state']);
        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 [true, $model];
    }

    public function itemNodeMissionRule(&$data, $user, $is_add = true)
    {
        $data['top_depart_id'] = $user['top_depart_id'];

        // 1. 父级任务与关联节点前置校验
        if (!empty($data['parent_item_node_mission_id'])) {
            $parentMission = ItemNodeMission::where('id', $data['parent_item_node_mission_id'])
                ->where('del_time', 0)
                ->first();
            if (empty($parentMission)) return [false, '父任务不存在或已被删除'];

            // 如果前端没传节点 ID，自动继承父任务的节点 ID
            if (empty($data['item_node_id'])) {
                $data['item_node_id'] = $parentMission->item_node_id;
            }
        }

        if (empty($data['item_node_id'])) return [false, '项目节点ID不能为空'];

        // 2. 关联节点及状态校验
        $node = ItemNode::where('id', $data['item_node_id'])->where('del_time', 0)->first();
        if (empty($node)) return [false, '项目节点不存在或已被删除'];
        if ($node->state == ItemNode::TYPE_THREE) return [false, '节点已完结，操作失败'];
        $data['item_id'] = $node->item_id;

        // 3. 任务基础字段与权重校验
        if (empty($data['title'])) return [false, '任务名称不能为空'];
        if (!isset($data['mission_weight'])) return [false, '任务权重不存在'];

        list($status, $res) = $this->checkWeight($data['mission_weight'], '任务权重');
        if (!$status) return [false, $res];

        // 4. 时间及大周期边界校验
        if (!empty($data['start_time'])) $data['start_time'] = $this->changeDateToDate($data['start_time']);
        if (!empty($data['end_time'])) $data['end_time'] = $this->changeDateToDate($data['end_time'], true);

        if (!empty($data['start_time']) && !empty($data['end_time'])) {
            if ($data['start_time'] > $data['end_time']) return [false, '开始时间不能大于结束时间'];
        }

        // 校验任务时间是否超出节点大周期
        if (!empty($data['start_time']) && $node->start_time > 0 && $data['start_time'] < $node->start_time) {
            return [false, '任务开始时间不能早于项目节点开始时间：' . date('Y-m-d', $node->start_time)];
        }
        if (!empty($data['end_time']) && $node->end_time > 0 && $data['end_time'] > $node->end_time) {
            return [false, '任务结束时间不能晚于项目节点结束时间：' . date('Y-m-d', $node->end_time)];
        }

        if(! isset($data['due_work_hour'])) return [false, '预计投入工时不存在'];
        $res = $this->checkNumber($data['due_work_hour'],0,'positive');
        if (! $res['valid']) return [false, "预计投入工时:" . $res['error']];

        // 5. 人员与设备列表校验
        if (!empty($data['man_list'])) {
            list($status, $msg) = $this->validateListRelation($data['man_list'], $data['top_depart_id'], '人员', 'data_id');
            if (!$status) return [false, $msg];
        }

        if (!empty($data['device_list'])) {
            list($status, $msg) = $this->validateListRelation($data['device_list'], $data['top_depart_id'], '设备', 'data_id');
            if (!$status) return [false, $msg];
        }

        // 6. 核心重名与状态校验（新增 vs 编辑）
        $titleQuery = ItemNodeMission::where('item_node_id', $data['item_node_id'])
            ->where('top_depart_id', $data['top_depart_id'])
            ->where('title', $data['title'])
            ->where('del_time', 0);

        if ($is_add) {
            // 新增：同节点下任务重名校验
            if ($titleQuery->exists()) return [false, '该项目节点下任务名称已存在'];
        } else {
            // 编辑：状态、下游子任务校验
            if (empty($data['id'])) return [false, 'ID不能为空'];

            $mission = ItemNodeMission::where('id', $data['id'])->where('del_time', 0)->first();
            if (empty($mission)) return [false, '项目节点下任务不存在或已被删除'];
            // 状态拦截
            if ($mission->state == ItemNodeMission::TYPE_THREE) return [false, '任务已完结，操作失败'];
            if ($mission->approval_state == ItemNodeMission::TYPE_MINUS_ONE) return [false, '任务审核中，操作失败'];

            if($data['state'] == ItemNodeMission::TYPE_THREE){
                $tableName = $mission->getTable();
                list($bool, $msg) = $this->checkIsDelivery($mission->toArray(), $tableName);
                if(! $bool) return [false , $msg];
            }

            // 试图完结任务时，校验其下面的子任务是否全部完结
            if (isset($data['state']) && $data['state'] == ItemNodeMission::TYPE_THREE) {
                $hasUnfinishedSubMission = ItemNodeMission::where('del_time', 0)
                    ->where('parent_item_node_mission_id', $data['id'])
                    ->where('state', '<>', ItemNodeMission::TYPE_THREE)
                    ->exists();
                if ($hasUnfinishedSubMission) return [false, '任务下存在子任务未完结'];
            }

            // 编辑查重：排除自身
            if ($titleQuery->where('id', '<>', $data['id'])->exists()) {
                return [false, '该项目节点下任务名称已存在'];
            }

            // 变更及草稿判定
            $return = $this->checkItemNodeMissionIsChanged($data, $user);
            if (is_array($return)) {
                return $return;
            } elseif ($return) {
                $data['draft'] = true;
            }
        }

        return [true, ''];
    }

    public function checkItemNodeMissionIsChanged($data, $user) {
        // 1. 获取旧数据
        list($status, $oldData) = $this->itemNodeMissionDetail($data, $user);
        if (!$status) return [false, $oldData];

        //创建人 直接通过
        $bool = $this->changedCommon($user, $oldData);
        if(! $bool) return false;

        // --- 表头基础字段比对 ---
        $fields = [
            'code', 'title', 'mark', 'state', 'budget',
            'charge_id', 'is_delivery_required', 'start_time', 'end_time',
            'entrust_type', 'is_review_required', 'review_id', 'priority_id', 'mission_id', 'mission_weight', 'progress', 'due_work_hour'
        ];

        foreach ($fields as $field) {
            $oldValue = $oldData[$field] ?? '';
            $newValue = $data[$field] ?? '';

            // 日期格式对齐（确保 Y-m-d 格式一致）
            if (in_array($field, ['start_time', 'end_time'])) {
                $newValue = !empty($newValue) ? date("Y-m-d", $newValue) : "";
            }

            if ($oldValue != $newValue) {
                return true;
            }
        }

        // --- 自定义字段比对 ---
        if (isset($data['custom_fields']) && is_array($data['custom_fields'])) {
            $oldCustomMap = array_column($oldData['custom_fields'] ?? [], 'field_value', 'id');

            foreach ($data['custom_fields'] as $customField) {
                $fid = $customField['id'] ?? 0;
                $newVal = $customField['field_value'] ?? '';
                $oldVal = $oldCustomMap[$fid] ?? '';

                if ($oldVal != $newVal) {
                    return true;
                }
            }
        }

        // --- 表体：人员名单比对 (man_list) ---
        $oldMans = collect($oldData['man_list'] ?? [])->pluck('data_id')->sort()->values()->toArray();
        $newMans = collect($data['man_list'] ?? [])->pluck('data_id')->sort()->values()->toArray();
        if ($oldMans !== $newMans) {
            return true;
        }

        // --- 表体：设备名单比对 (device_list) ---
        $oldDevices = collect($oldData['device_list'] ?? [])->pluck('data_id')->sort()->values()->toArray();
        $newDevices = collect($data['device_list'] ?? [])->pluck('data_id')->sort()->values()->toArray();
        if ($oldDevices !== $newDevices) {
            return true;
        }

        return false; // 没有任何变动
    }

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

        $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_merge_recursive(array_column($data['data'],'charge_id'), array_column($data['data'],'crt_id'))));
        $tag = (new TagService())->getTagMap(array_unique(array_merge_recursive(array_column($data['data'],'priority_id'),array_column($data['data'],'mission_id'))));
        $mission_id = array_column($data['data'],'id');
        $item_node_map = $this->getItemNodeMap($mission_id);
        if(isset($ergs['get_item_node_mission_man'])) $mission_man = $this->getMissionMembersMap($mission_id, $user);
        $item = $this->getItemMap(array_unique(array_column($data['data'],'item_id')));
        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $data['data'][$key]['start_time'] = $value['start_time'] ? date('Y-m-d',$value['start_time']) : '';
            $data['data'][$key]['end_time'] = $value['end_time'] ? date('Y-m-d',$value['end_time']) : '';
            $data['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
            $data['data'][$key]['charge_name'] = $emp[$value['charge_id']] ?? '';
            $data['data'][$key]['state_title'] = ItemNodeMission::State_Type[$value['state']] ?? "";
            $data['data'][$key]['approval_state_title'] = ItemNodeMission::State_Type[$value['approval_state']] ?? "";
            $priority_tmp = $tag[$value['priority_id']] ?? [];
            $data['data'][$key]['priority_title'] = $priority_tmp['title'] ?? '';
            $data['data'][$key]['priority_code'] = $priority_tmp['code'] ?? '';
            $data['data'][$key]['priority_color'] = $priority_tmp['color'] ?? '';
            $node_tmp = $tag[$value['mission_id']] ?? [];
            $data['data'][$key]['mission_title'] = $node_tmp['title'] ?? '';
            $data['data'][$key]['mission_code'] = $node_tmp['code'] ?? '';
            $data['data'][$key]['mission_color'] = $node_tmp['color'] ?? '';
            $data['data'][$key]['item_node_title'] = $item_node_map[$value['id']] ?? '';
            $data['data'][$key]['mission_man'] = $mission_man[$value['id']] ?? [];
            $item_tmp = $item[$value['item_id']] ?? [];
            $data['data'][$key]['item_title'] = $item_tmp['title'] ?? '';
        }

        return $data;
    }

    public function getMissionMembersMap1(array $missionIds, int $userId)
    {
        if (empty($missionIds)) {
            return [];
        }

        // 1. 批量查出当前用户在这些任务里哪些是【负责人】身份
        $chargeMissionIds = DB::table('item_node_mission_employee')
            ->whereIn('item_node_mission_id', $missionIds)
            ->where('data_id', $userId)
            ->where('del_time', 0)
            ->pluck('item_node_mission_id')
            ->toArray();

        // 2. 准备查询成员表的 Query，并连表关联 employee
        $query = DB::table('item_node_mission_details as d')
            ->join('employee as e', 'd.data_id', '=', 'e.id')
            ->whereIn('d.item_node_mission_id', $missionIds)
            ->where('d.type', 1)
            ->where('d.del_time', 0)
            ->where('e.del_time', 0)
            ->select('d.item_node_mission_id', 'd.data_id as id', 'e.title'); // 别名直接对齐你需要的 id 和 title

        // 3. 核心分流：找出哪些任务用户【不是负责人】
        $notChargeMissionIds = array_diff($missionIds, $chargeMissionIds);

        if (!empty($notChargeMissionIds)) {
            $query->where(function ($q) use ($chargeMissionIds, $userId) {
                if (!empty($chargeMissionIds)) {
                    $q->whereIn('d.item_node_mission_id', $chargeMissionIds)
                        ->orWhere(function ($subQ) use ($userId) {
                            $subQ->where('d.data_id', $userId);
                        });
                } else {
                    $q->where('d.data_id', $userId);
                }
            });
        }

        // 4. 查出过滤后的所有成员数据
        $details = $query->get();

        // 5. 初始化 Map 壳子
        $resultMap = [];
        foreach ($missionIds as $id) {
            $resultMap[$id] = [];
        }

        // 6. 组装成你需要的规范二维结构
        foreach ($details as $detail) {
            $resultMap[$detail->item_node_mission_id][] = [
                'id'    => $detail->id,
                'title' => $detail->title
            ];
        }

        return $resultMap;
    }

    /**
     * 根据任务 ID 数组获取当前登录人可见的任务成员 Map 结构（包含超管特权）
     * @param array $missionIds 任务 ID 数组
     * @param array $user 当前登录人完整用户信息数组（包含 id 和 is_admin）
     * @return array
     */
    public function getMissionMembersMap(array $missionIds, array $user)
    {
        if (empty($missionIds)) {
            return [];
        }

        $userId = $user['id'] ?? 0;

        // 1. 批量查出当前用户在这些任务里哪些是【负责人】身份
        $chargeMissionIds = \DB::table('item_node_mission_employee')
            ->whereIn('item_node_mission_id', $missionIds)
            ->where('data_id', $userId)
            ->where('del_time', 0)
            ->pluck('item_node_mission_id')
            ->toArray();

        // 2. 准备查询成员表的 Query，并连表关联 employee
        $query = \DB::table('item_node_mission_details as d')
            ->join('employee as e', 'd.data_id', '=', 'e.id')
            ->whereIn('d.item_node_mission_id', $missionIds)
            ->where('d.type', 1)
            ->where('d.del_time', 0)
            ->where('e.del_time', 0)
            ->select('d.item_node_mission_id', 'd.data_id as id', 'e.title');

        // ==============================================================
        // 【核心新增：超级管理员特权判定】
        // ==============================================================
        $isAdmin = ($user['is_admin'] ?? 0) == Employee::IS_ADMIN_TWO;

        if (!$isAdmin) {
            // 如果【不是】超级管理员，才执行原本严格的“负责人/普通成员”分流限制
            $notChargeMissionIds = array_diff($missionIds, $chargeMissionIds);

            if (!empty($notChargeMissionIds)) {
                $query->where(function ($q) use ($chargeMissionIds, $userId) {
                    if (!empty($chargeMissionIds)) {
                        $q->whereIn('d.item_node_mission_id', $chargeMissionIds)
                            ->orWhere(function ($subQ) use ($userId) {
                                $subQ->where('d.data_id', $userId);
                            });
                    } else {
                        $q->where('d.data_id', $userId);
                    }
                });
            }
        }
        // 如果是超级管理员，直接不进上面的 if，SQL 保持原样，天然查出 $missionIds 下的所有成员！

        // 4. 查出过滤后的所有成员数据
        $details = $query->get();

        // 5. 初始化 Map 壳子
        $resultMap = [];
        foreach ($missionIds as $id) {
            $resultMap[$id] = [];
        }

        // 6. 组装成你需要的规范二维结构
        foreach ($details as $detail) {
            $resultMap[$detail->item_node_mission_id][] = [
                'id'    => $detail->id,
                'title' => $detail->title
            ];
        }

        return $resultMap;
    }

    public function getItemNodeMap($item_node_mission_id){
        if(! is_array($item_node_mission_id)) $item_node_mission_id = [$item_node_mission_id];
        return ItemNodeMission::from('item_node_mission as a')
            ->leftJoin('item_node as b','b.id','a.item_node_id')
            ->whereIn('a.id', $item_node_mission_id)
            ->pluck('b.title','a.id')
            ->toArray();
    }

    public function getItemNodeMissionMap($ids){
        $ids = array_filter((array)$ids);
        if (empty($ids)) return [];

        return ItemNodeMission::whereIn('id', $ids)
            ->select('id', 'title', 'code')
            ->get()
            ->keyBy('id')
            ->toArray();
    }

    public function getItemNodeMap2($ids){
        $ids = array_filter((array)$ids);
        if (empty($ids)) return [];

        return ItemNode::whereIn('id', $ids)
            ->select('id', 'title', 'code')
            ->get()
            ->keyBy('id')
            ->toArray();
    }

    public function checkIsDelivery($data, $tableName){
        //是否需要交付物完结
        if($data['is_delivery_required']){
            $column = $tableName . '_id';
            $type_map = [
                "item" => 1,
                "item_node" => 2,
                "item_node_mission" => 3,
            ];
            $type = $type_map[$tableName];
            $bool = ItemFile::where('del_time',0)
                ->where($column, $data['id'])
                ->where('top_depart_id', $data['top_depart_id'])
                ->where('is_delivery', ItemFile::delivery_one)
                ->where('type', $type)
                ->exists();
            if($bool) return [true, ''];

            $bool = CustomFieldValue::where('del_time',0)
                ->where('table_name', $tableName)
                ->where('model_id', $data['id'])
                ->where('top_depart_id', $data['top_depart_id'])
                ->where('field_type', CustomFieldValue::type_two)
                ->where('is_delivery', CustomFieldValue::delivery_one)
                ->exists();
            if($bool) return [true, ''];

            return [false, '请先上传交付物后再提交完结'];
        }

        return [true, ''];
    }

    /**
     * 通用权重校验
     * @param int|float $weight 权重值
     * @param string $fieldTitle 字段名称提示（如：节点权重、任务权重）
     * @return array [bool, string]
     */
    public function checkWeight($weight, $fieldTitle = '权重') {
        // 1. 判断是否为空或非数字
        if (!is_numeric($weight)) {
            return [false, $fieldTitle . '必须是数字'];
        }

        // 2. 校验范围 0 - 100
        if ($weight < 0 || $weight > 100) {
            return [false, $fieldTitle . '范围必须在 0 到 100 之间'];
        }

        return [true, ''];
    }

    /**
     * 触发生成审批流
     * @param $data 草稿数据
     * @param $user 提交人
     * @param $tableName 操作表
     * @param $oldData 原数据
     * @param $opt_type 操作类型 1 全量编辑  2 单字段编辑
     */
    public function createWorkFlow($data, $user, $tableName, $oldData, $opt_type = 1){
        // 创建草稿
        $this->createDraft($data, $user, $tableName, $opt_type);
        //触发审批
        list($status, $msg) = (new WorkFlowService())->triggerWorkflow($oldData['review_id'],$oldData['id'],$tableName,$user);
        if(! $status) throw new \Exception($msg);
    }

    // 创建链接分享
    public function shareAdd($data, $user)
    {
        // 执行校验
        list($status, $msg) = $this->shareRule($data, $user);
        if (!$status) return [$status, $msg];

        try {
            DB::beginTransaction();

            $mission = $data['mission_data'];

            // 生成唯一的随机 Token (32位字符串)
            $shareToken = bin2hex(random_bytes(16));

            $model = new ItemNodeMissionShare();
            $model->item_id = $mission->item_id;
            $model->item_node_id = $mission->item_node_id;
            $model->item_node_mission_id = $mission->id;
            $model->item_title = $data['item_title'];
            $model->item_node_title = $data['item_node_title'];
            $model->item_node_mission_title = $data['item_node_mission_title'];
            $model->share_token = $shareToken;
            $model->expire_time = $data['expire_time'];
            $model->type = $data['type'];
            $model->remark = $data['remark'] ?? '';
            $model->crt_id = $user['id'];
            $model->top_depart_id = $data['top_depart_id'];
            $model->save();

            DB::commit();

            return [true, ''];

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

    public function shareEdit($data, $user)
    {
        // 执行校验
        list($status, $msg) = $this->shareRule($data, $user, false);
        if (!$status) return [$status, $msg];

        try {
            DB::beginTransaction();

            $model = $data['share_model'];
            $model->expire_time = $data['expire_time'];
            $model->remark = $data['remark'] ?? '';
            $model->type = $data['type'] ?? 0;
            $model->save();

            DB::commit();

            return [true, ''];

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

    public function shareRule(&$data, $user, $is_add = true)
    {
        $data['top_depart_id'] = $user['top_depart_id'];
        $currentTime = time();

        // 1. 基础参数校验
        if (empty($data['item_node_mission_id'])) return [false, '请选择任务'];
        if (empty($data['expire_time'])) return [false, '请选择链接过期时间'];
        if (! isset($data['type']) || ! isset(ItemNodeMissionShare::QX_Type[$data['type']])) return [false, '链接权限不能为空或错误'];

        $mission = DB::table('item_node_mission')
            ->where('id', $data['item_node_mission_id'])
            ->where('del_time', 0)
            ->first();
        if (empty($mission)) return [false, '任务不存在或已被删除'];
        if ($mission->approval_state == -1) return [false, '任务正在审核中，无法生成/编辑分享链接'];
        $data['item_node_mission_title'] = $mission->title;
        $data['item_node_title'] = ItemNode::where('id', $mission->item_node_id)->value('title') ?? '';
        $data['item_title'] = Item::where('id', $mission->item_id)->value('title') ?? '';

        // 时间校验与转换
        $data['expire_time'] = $this->changeDateToDate($data['expire_time'], true);
        if ($data['expire_time'] < $currentTime) {
            return [false, '过期时间不能小于当前时间'];
        }
        if ($mission->end_time > 0 && $data['expire_time'] > $mission->end_time) {
            return [false, '链接过期时间不能超过任务的结束时间'];
        }

        // 4. 新增 编辑 的差异化校验
        if ($is_add) {
            // 【新增场景】同一个任务下的同一个人，只允许存在一个有效的分享链接
            // 健壮性设计：状态是0 并且 事实上还没过期的链接，都算有效链接
            $existsValidShare = ItemNodeMissionShare::where('item_node_mission_id', $data['item_node_mission_id'])
                ->where('status', ItemNodeMissionShare::TYPE_ZERO) // 0-已生效
                ->where('type', $data['type'])
                ->where('expire_time', '>', $currentTime) // 必须也没过期
                ->where('del_time', 0)
                ->exists();

            $qx = ItemNodeMissionShare::QX_Type[$data['type']] ?? '';
            if ($existsValidShare) return [false, '该任务下已存在一个生效中的分享链接(权限:' . $qx . ')'];
        } else {
            if (empty($data['id'])) return [false, 'ID不能为空'];

            $share = ItemNodeMissionShare::where('id', $data['id'])
                ->where('top_depart_id', $data['top_depart_id'])
                ->where('del_time', 0)
                ->first();
            if (empty($share)) return [false, '链接不存在或已被删除'];

            // 核心拦截：已过期(1) 或 已作废(2) 或者是时间戳层面的实际过期，均不允许编辑
            if ($share->status == ItemNodeMissionShare::TYPE_ONE || $share->expire_time <= $currentTime) {
                return [false, '该分享链接已过期，不允许操作'];
            }
            if ($share->status == ItemNodeMissionShare::TYPE_TWO) {
                return [false, '该分享链接已作废，不允许操作'];
            }

            // 编辑时查重：排除自身 ID
            $existsOtherValidShare = ItemNodeMissionShare::where('item_node_mission_id', $data['item_node_mission_id'])
                ->where('id', '<>', $data['id']) // 排除自己
                ->where('status', ItemNodeMissionShare::TYPE_ZERO)
                ->where('type', $share->type)
                ->where('expire_time', '>', $currentTime)
                ->where('del_time', 0)
                ->exists();

            $qx = ItemNodeMissionShare::QX_Type[$share->type] ?? '';
            if ($existsOtherValidShare) {
                return [false, '该任务下已存在一个生效中的分享链接(权限:' . $qx . ')'];
            }

            $data['share_model'] = $share;
        }

        $data['mission_data'] = $mission;

        return [true, ''];
    }

    public function shareCommon($data,$user, $field = []){
        if(empty($field)) $field = ItemNodeMissionShare::$field;

        $model = ItemNodeMissionShare::Clear($user,$data);
        $model = $model->where('del_time',0)
            ->select($field)
            ->orderby('id', 'desc');

        if(! empty($data['item_title'])) $model->where('item_title', 'LIKE', '%'.$data['item_title'].'%');
        if(! empty($data['item_id'])) $model->where('item_id', $data['item_id']);
        if(! empty($data['item_node_title'])) $model->where('item_node_title', 'LIKE', '%'.$data['item_node_title'].'%');
        if(! empty($data['item_node_id'])) $model->where('item_node_id', $data['item_node_id']);
        if(! empty($data['item_node_mission_title'])) $model->where('item_node_mission_title', 'LIKE', '%'.$data['item_node_mission_title'].'%');
        if(! empty($data['item_node_mission_id'])) $model->where('item_node_mission_id', $data['item_node_mission_id']);
        if(! empty($data['id'])) $model->whereIn('id', $data['id']);
        if(isset($data['status'])) $model->where('status', $data['status']);
        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 shareList($data,$user){
        $model = $this->shareCommon($data, $user);
        $list = $this->limit($model,'',$data);
        $list = $this->fillShareData($list);

        return [true, $list];
    }

    public function fillShareData($data){
        if(empty($data['data'])) return $data;

        $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_column($data['data'],'crt_id')));
        $time = time();
        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $data['data'][$key]['expire_time'] = $value['expire_time'] ? date('Y-m-d',$value['expire_time']) : '';
            $data['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
            $data['data'][$key]['status_title'] = ItemNodeMissionShare::State_Type[$value['status']] ?? '';
            $data['data'][$key]['type_title'] = ItemNodeMissionShare::QX_Type[$value['type']] ?? '';
            $final_status = $this->fillFinalStatus($value, $time);
            $data['data'][$key]['final_status'] = $final_status;
            $data['data'][$key]['final_status_title'] = ItemNodeMissionShare::State_Type[$final_status] ?? '';
        }

        return $data;
    }

    public function shareDetail($data, $user){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];
        $customer = ItemNodeMissionShare::where('del_time',0)
            ->where('id',$data['id'])
            ->first();
        if(empty($customer)) return [false,'分享链接不存在或已被删除'];
        $customer = $customer->toArray();

        $final_status = $this->fillFinalStatus($customer, time());
        $customer['expire_time']  = ! empty($customer['expire_time']) ? date("Y-m-d", $customer['expire_time']) : "";
        $customer['crt_name'] = Employee::where('id',$customer['crt_id'])->value('title');
        $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';
        $customer['status_title'] = ItemNodeMissionShare::State_Type[$customer['status']] ?? '';
        $customer['type_title'] = ItemNodeMissionShare::QX_Type[$customer['type']] ?? '';
        $customer['final_status'] = $final_status;
        $customer['final_status_title'] = ItemNodeMissionShare::State_Type[$final_status] ?? '';

        //任务详情
        $customer['item_node_mission'] = ItemNodeMission::where('id', $customer['item_node_mission_id'])->first();

        //任务进展信息 该链接下所有
        list($status, $msg) = $this->itemMissionProgressBoard(['id' => $customer['item_node_mission_id'], 'item_node_mission_share_id' => $customer['id']]);
        $customer['mission_progress'] = $msg;

        return [true, $customer];
    }

    private function fillFinalStatus($value, $currentTime){
        if ($value['status'] == ItemNodeMissionShare::TYPE_ONE || $value['expire_time'] <= $currentTime) {
            return 1;
        }

        return $value['status'];
    }

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

        $share = ItemNodeMissionShare::where('id', $data['id'])
            ->where('del_time', 0)
            ->first();
        if (empty($share)) return [false, '分享链接不存在或已被删除'];

        $time = time();

        // 核心拦截：已过期(1) 或 已作废(2) 或者是时间戳层面的实际过期，均不允许编辑
        if ($share->status == ItemNodeMissionShare::TYPE_ONE || $share->expire_time <= $time) {
            return [false, '该分享链接已过期，不允许操作'];
        }
        if ($share->status == ItemNodeMissionShare::TYPE_TWO) {
            return [false, '该分享链接已作废，不允许操作'];
        }
        try {
            DB::beginTransaction();

            $share->status = ItemNodeMissionShare::TYPE_TWO;
            $share->save();

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

        return [true, ''];
    }

    public function shareOutSideHTML($data){
        if(empty($data['share_token'])) return [false, '分享链接不能为空'];

        $share = ItemNodeMissionShare::where('share_token', $data['share_token'])
            ->where('del_time', 0)
            ->first();
        if (empty($share)) return [false, '分享链接不存在或已被删除'];
        if ($share->status == ItemNodeMissionShare::TYPE_ONE || $share->expire_time <= time()) {
            return [false, '该分享链接已过期'];
        }
        if ($share->status == ItemNodeMissionShare::TYPE_TWO) {
            return [false, '该分享链接已作废'];
        }

        $share_array = $share->toArray();
        list($status, $msg) = $this->itemNodeMissionDetail(['id' => $share_array['item_node_mission_id']], ['top_depart_id' => $share_array['top_depart_id']]);
        if(! $status) return [false, $msg];
        $share_array['item_node_mission_data'] = $msg;

        return [true, $share_array];
    }

    /**
     * 外部人员更新任务进展（单条模式）
     */
    public function itemNodeMissionUpdateProgressContentOutSide($data, $user)
    {
        list($status, $msg) = $this->progressOutsideRule($data, $user);
        if (!$status) return [$status, $msg];

        try {
            DB::beginTransaction();

            $insertData = $data['processed_data'];
            ItemNodeMissionContent::insert($insertData);

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

        return [true, ''];
    }

    /**
     * 进展提交校验逻辑
     */
    public function progressOutsideRule(&$data, $user)
    {
        if(empty($data['share_token'])) return [false, '分享链接不能为空'];
        list($status, $msg) = $this->shareCheck($data['share_token'], $user['id']);
        if(! $status) return [false, $msg];
        $share_array = $msg;

        // 1. 基础校验
        if (empty($data['id'])) return [false, '任务ID不能为空'];

        $customer = ItemNodeMission::where('del_time', 0)
            ->where('id', $data['id'])
            ->first();
        if (empty($customer)) return [false, '项目节点任务不存在或已被删除'];
        $customer = $customer->toArray();
        if($customer['state'] == ItemNodeMission::TYPE_THREE) return [false, '任务已完成'];

        if (empty($data['data']) || !is_array($data['data'])) return [false, '任务进展明细不能为空'];

        // 强制获取第一条数据（确保单条限制）
        $value = reset($data['data']);
        $empId = $user['id'] ?? 0;

        // 2. 日期校验
        if (empty($value['order_time'])) return [false, '提交日期不能为空'];
        $order_time = $this->changeDateToDate($value['order_time']);
        if ($order_time > $customer['end_time'] || $order_time < $customer['start_time']) {
            return [false, "提交日期必须在任务周期内"];
        }

        // 3. 数字与合法性校验
        $res = $this->checkNumber($value['start_time_hour'], 0, 'non-negative');
        if (!$res['valid']) return [false, "开始点：" . $res['error']];
        if ($value['start_time_hour'] > 23) return [false, "开始点不合法"];

        $res = $this->checkNumber($value['start_time_min'], 0, 'non-negative');
        if (!$res['valid']) return [false, "开始分：" . $res['error']];
        if ($value['start_time_min'] > 59) return [false, "开始分不合法"];

        $res = $this->checkNumber($value['end_time_hour'], 0, 'non-negative');
        if (!$res['valid']) return [false, "结束点：" . $res['error']];
        if ($value['end_time_hour'] > 24) return [false, "结束点不合法"];

        $res = $this->checkNumber($value['end_time_min'], 0, 'non-negative');
        if (!$res['valid']) return [false, "结束分：" . $res['error']];
        if ($value['end_time_min'] > 59) return [false, "结束分不合法"];

        // 4. 计算当前提交的时间段（分钟数）
        $currentStart = $value['start_time_hour'] * 60 + $value['start_time_min'];
        $currentEnd   = $value['end_time_hour'] * 60 + $value['end_time_min'];

        if ($currentStart >= $currentEnd) {
            return [false, "开始时间必须早于结束时间"];
        }

        $calculatedTotal = $currentEnd - $currentStart;
        if (!isset($value['total_work_min']) || intval($value['total_work_min']) !== $calculatedTotal) {
            return [false, "工时计算有误，应为 {$calculatedTotal} 分钟"];
        }

        $hasDbOverlap = ItemNodeMissionContent::where('del_time', 0)
            ->where('crt_id', $empId)
            ->where('order_time', $order_time)
            ->where('item_node_mission_id', '<>', $customer['id'])
            ->where(function ($query) use ($value) {

                // 【条件一】：数据库开始时间 < 前端结束时间
                $query->where(function ($q) use ($value) {
                    $q->where('start_time_hour', '<', $value['end_time_hour'])
                        ->orWhere(function ($sub) use ($value) {
                            $sub->where('start_time_hour', '=', $value['end_time_hour'])
                                ->where('start_time_min', '<', $value['end_time_min']);
                        });
                })

                    // 【条件二】：前端开始时间 < 数据库结束时间
                    ->where(function ($q) use ($value) {
                        $q->where('end_time_hour', '>', $value['start_time_hour'])
                            ->orWhere(function ($sub) use ($value) {
                                $sub->where('end_time_hour', '=', $value['start_time_hour'])
                                    ->where('end_time_min', '>', $value['start_time_min']);
                            });
                    });

            })
            ->exists();

        if ($hasDbOverlap) {
            return [false, "您在该日期（" . date('Y-m-d', $order_time) . "）下已提交过冲突的工时阶段"];
        }

        // 6. 拼装标准的单条入库数据结构（包在数组里以适配单次批量 insert）
        $processedData = [
            [
                'item_id'               => $customer['item_id'],
                'item_node_id'          => $customer['item_node_id'],
                'item_node_mission_id'  => $customer['id'],
                'data_id'               => $empId,
                'top_depart_id'         => $user['top_depart_id'],
                'crt_id'                => $empId,
                'order_time'            => $order_time,
                'start_time_hour'       => $value['start_time_hour'],
                'start_time_min'        => $value['start_time_min'],
                'end_time_hour'         => $value['end_time_hour'],
                'end_time_min'          => $value['end_time_min'],
                'total_work_min'        => $calculatedTotal,
                'content'                  => $value['content'] ?? '',
                'crt_time'              => time(),
                'item_node_mission_share_id' => $share_array['id']
            ]
        ];

        $data['processed_data'] = $processedData;

        return [true, ''];
    }

    public function shareCheck($share_token = "", $employee = 0){
        $share = ItemNodeMissionShare::where('del_time',0)
            ->where('share_token', $share_token)
            ->first();
        if(empty($share)) return [false, '分享链接不存在或已被删除'];

        $time = time();

        // 核心拦截：已过期(1) 或 已作废(2) 或者是时间戳层面的实际过期，均不允许编辑
        if ($share->status == ItemNodeMissionShare::TYPE_ONE || $share->expire_time <= $time) {
            return [false, '该分享链接已过期'];
        }
        if ($share->status == ItemNodeMissionShare::TYPE_TWO) {
            return [false, '该分享链接已作废'];
        }

        $bool = ItemNodeMissionDetails::where('del_time',0)
            ->where('type',ItemNodeMissionDetails::type_one)
            ->where('item_node_mission_id', $share->item_node_mission_id)
            ->where('data_id', $employee)
            ->exists();
        if(! $bool) return [false, '账号无该链接编辑权限'];

        return [true, $share->toArray()];
    }
}