workHour/app/Service/ItemService.php

<?php

namespace App\Service;

use App\Jobs\ProcessOssTask;
use App\Model\CustomFieldValue;
use App\Model\Device;
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\ItemNodeMissionDetails;
use App\Model\ItemNodeMissionEmployee;
use App\Model\SysOssTasks;
use App\Model\Tag;
use App\Model\SysMenu;
use Illuminate\Support\Facades\DB;

class ItemService extends Service
{
    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] . "不存在或已被删除"];

        $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 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不能为空'];

        $modelClass = $fromMap[$type] ?? "";
        $item = $modelClass::where('id', $id)->where('del_time', 0)->first();
        if (! $item) 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 itemFileIsDelivery($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['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 itemFinish($data, $user){
        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 == Item::TYPE_THREE) return [false, '项目已完成，请勿重复操作'];

        try {
            DB::beginTransaction();

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

            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];

        try {
            DB::beginTransaction();

            $model = Item::where('id', $data['id'])->first();
            $old_employee_id = $model->charge_id;
            $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;

            //项目管理的字段
            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];
            }

            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];
            }

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

        return [true, ''];
    }

    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
            ]);
        }
    }

    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();
    }

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

        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['priority_title'] = Tag::where('id', $customer['priority_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->getNodeFile($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']] ?? "";
            $priority_tmp = $tag[$value['priority_id']] ?? [];
            $list[$key]['priority_title'] = $priority_tmp['title'] ?? '';
            $list[$key]['priority_code'] = $priority_tmp['code'] ?? '';
            $node_tmp = $tag[$value['node_id']] ?? [];
            $list[$key]['node_title'] = $node_tmp['title'] ?? '';
            $list[$key]['node_code'] = $node_tmp['code'] ?? '';
            $list[$key]['progress'] = rand(1, 100); //todo
        }

        return $list;
    }

    public function getNodeFile($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);

        $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,
                        '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){
                $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'],
                    '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['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['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 itemRule(&$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);
        $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不能为空'];
            $bool = Item::where('code',$data['code'])
                ->where('top_depart_id', $data['top_depart_id'])
                ->where('id','<>',$data['id'])
                ->where('del_time',0)
                ->exists();
        }
        if($bool) return [false, '项目编码已存在'];

        return [true, ''];
    }

    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'))));
        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']] ?? "";
        }

        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不能为空'];
        $item = ItemNode::where('id',$data['id'])
            ->where('del_time',0)
            ->first();
        if(empty($item)) return [false, '项目节点不存在或已被删除'];
        if($item->state == ItemNode::TYPE_THREE) return [false, '项目节点已完成，请勿重复操作'];

        try {
            DB::beginTransaction();

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

            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];

        try {
            DB::beginTransaction();

            $model = ItemNode::where('id', $data['id'])->first();
            $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];
            }

            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];
            }

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

        return [true, ''];
    }

    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)
                ->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
            ]);
        }
    }

    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,'请选择数据！'];

        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']] ?? '';

        $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'] ?? '';
        $node_tmp = $tag[$customer['node_id']] ?? [];
        $customer['node_title'] = $node_tmp['title'] ?? '';
        $customer['node_code'] = $node_tmp['code'] ?? '';
        $item = Item::where('id', $customer['item_id'])->first();
        $customer['item_code'] = $item->code;
        $customer['item_title'] = $item->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->getMissionFile($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']] ?? "";
            $priority_tmp = $tag[$value['priority_id']] ?? [];
            $list[$key]['priority_title'] = $priority_tmp['title'] ?? '';
            $list[$key]['priority_code'] = $priority_tmp['code'] ?? '';
            $node_tmp = $tag[$value['mission_id']] ?? [];
            $list[$key]['mission_title'] = $node_tmp['title'] ?? '';
            $list[$key]['mission_code'] = $node_tmp['code'] ?? '';
            $list[$key]['progress'] = rand(1, 100); //todo
        }

        return $list;
    }

    public function getMissionFile($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);

        $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,
                        '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){
                $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'],
                    '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(isset($data['state'])) $model->where('state', $data['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'];
        if(empty($data['item_id'])) return [false, '项目ID不能为空'];
        $item = Item::where('id', $data['item_id'])->where('del_time',0)->first();
        if(empty($item)) return [false, '项目不存在或已被删除'];
        $item = $item->toArray();
        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);

        $itemStartTime = $item['start_time'];
        $itemEndTime = $item['end_time'];
        if (!empty($data['start_time'])) {
            $inputStartTime = $data['start_time'];

            if ($itemStartTime > 0 && $inputStartTime < $itemStartTime) {
                return [false, '节点开始时间不能早于项目开始时间：' . date('Y-m-d', $itemStartTime)];
            }
        }
        if (!empty($data['end_time'])) {
            $inputEndTime = $data['end_time'];
            if ($itemEndTime > 0 && $inputEndTime > $itemEndTime) {
                return [false, '节点结束时间不能晚于项目结束时间：' . date('Y-m-d', $itemEndTime)];
            }
        }

        if(! empty($data['man_list'])) {
            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'])) {
            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($is_add){
            $bool = ItemNode::where('item_id',$data['item_id'])
                ->where('top_depart_id', $data['top_depart_id'])
                ->where('title', $data['title'])
                ->where('del_time',0)
                ->exists();
        }else{
            if(empty($data['id'])) return [false,'ID不能为空'];
            $bool = ItemNode::where('title', $data['title'])
                ->where('item_id',$data['item_id'])
                ->where('top_depart_id', $data['top_depart_id'])
                ->where('id','<>',$data['id'])
                ->where('del_time',0)
                ->exists();
        }
        if($bool) return [false, '该项目下节点名称已存在'];

        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']] ?? "";
            $priority_tmp = $tag[$value['priority_id']] ?? [];
            $data['data'][$key]['priority_title'] = $priority_tmp['title'] ?? '';
            $data['data'][$key]['priority_code'] = $priority_tmp['code'] ?? '';
            $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]['item_title'] = $item[$value['item_id']] ?? '';
            $data['data'][$key]['progress'] = rand(1,100); // todo
        }

        return $data;
    }

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

        try {
            DB::beginTransaction();

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

            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];

        try {
            DB::beginTransaction();

            $model = ItemNodeMission::where('id', $data['id'])->first();
            $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->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];
            }

            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;
            $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->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];
            }

            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)
                ->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
            ]);
        }
    }

    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,'请选择数据！'];

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

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

            ItemNodeMissionDetails::where('del_time',0)
                ->whereIn('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']] ?? '';

        $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'] ?? '';
        $node_tmp = $tag[$customer['mission_id']] ?? [];
        $customer['mission_title'] = $node_tmp['title'] ?? '';
        $customer['mission_code'] = $node_tmp['code'] ?? '';

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

        return [true, $customer];
    }

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

        $model = ItemNodeMission::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(isset($data['state'])) $model->where('state', $data['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);

        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);

        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(! 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'];
        if(empty($data['item_node_id'])) return [false, '项目节点ID不能为空'];
        $item = ItemNode::where('id', $data['item_node_id'])->where('del_time',0)->first();
        if(empty($item)) return [false, '项目节点不存在或已被删除'];
        $item = $item->toArray();
        $data['item_id'] = $item['item_id'];
        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);

        $itemStartTime = $item['start_time'];
        $itemEndTime = $item['end_time'];
        if (!empty($data['start_time'])) {
            $inputStartTime = $data['start_time'];

            if ($itemStartTime > 0 && $inputStartTime < $itemStartTime) {
                return [false, '任务开始时间不能早于项目节点开始时间：' . date('Y-m-d', $itemStartTime)];
            }
        }
        if (!empty($data['end_time'])) {
            $inputEndTime = $data['end_time'];
            if ($itemEndTime > 0 && $inputEndTime > $itemEndTime) {
                return [false, '任务结束时间不能晚于项目节点结束时间：' . date('Y-m-d', $itemEndTime)];
            }
        }

        if(! empty($data['man_list'])) {
            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'])) {
            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($is_add){
            $bool = 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)
                ->exists();
        }else{
            if(empty($data['id'])) return [false,'ID不能为空'];
            $bool = ItemNodeMission::where('title', $data['title'])
                ->where('item_node_id',$data['item_node_id'])
                ->where('top_depart_id', $data['top_depart_id'])
                ->where('id','<>',$data['id'])
                ->where('del_time',0)
                ->exists();
        }
        if($bool) return [false, '该项目节点下任务名称已存在'];

        return [true, ''];
    }

    public function fillNodeMissionData($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'],'mission_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'] = ItemNode::State_Type[$value['state']] ?? "";
            $priority_tmp = $tag[$value['priority_id']] ?? [];
            $data['data'][$key]['priority_title'] = $priority_tmp['title'] ?? '';
            $data['data'][$key]['priority_code'] = $priority_tmp['code'] ?? '';
            $node_tmp = $tag[$value['mission_id']] ?? [];
            $data['data'][$key]['mission_title'] = $node_tmp['title'] ?? '';
            $data['data'][$key]['mission_code'] = $node_tmp['code'] ?? '';
        }

        return $data;
    }
}