itemRule($data, $user, false); if(!$status) return [$status,$msg]; try { DB::beginTransaction(); $model = Item::where('id',$data['id'])->first(); $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->save(); $time = time(); ItemDetails::where('del_time',0) ->where('item_id', $model->id) ->update(['del_time' => $time]); $this->saveDetail($model->id, $time, $data); 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(); $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->crt_id = $user['id']; $model->top_depart_id = $data['top_depart_id']; $model->save(); $this->saveDetail($model->id, time(), $data); 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 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')->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'] ?? "", ]; } } $detail = [ 'man_list' => $unit, 'device_list' => $receipt, ]; foreach ($detail as $key => $value) { if (empty($value)) { $detail[$key] = (object)[]; // 转成 stdClass 对象 } } return $detail; } public function getItemMap($ids){ if(empty($ids)) return []; if(! is_array($ids)) $ids = [$ids]; return Item::whereIn('id', $ids) ->pluck('title', '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) ->where('id',$data['id']) ->first(); if(empty($customer)) return [false,'项目不存在或已被删除']; $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['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): ''; $customer['state_title'] = Employee::State_Type[$customer['state']] ?? ''; $details = $this->getDetail($data['id']); $customer = array_merge($customer, $details); return [true, $customer]; } public function itemCommon($data,$user, $field = []){ if(empty($field)) $field = Item::$field; $model = Item::Clear($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){ $model = $this->itemCommon($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, '设备不能为空']; 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 = 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, $is_export = false){ if(empty($data['data'])) return $data; $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_column($data['data'],'crt_id'))); $map = []; if($is_export) $map = $this->getDetailsMap(array_column($data['data'],'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]['state_title'] = Item::State_Type[$value['state']] ?? ""; $tmp = $map[$value['id']] ?? []; $data['data'][$key]['man_list'] = $tmp['man'] ?? ""; $data['data'][$key]['device_list'] = $tmp['device'] ?? ""; } return $data; } public function getDetailsMap($item_id){ // 1. 获取明细数据,注意一定要选出 item_id $data = ItemDetails::where('del_time', 0) ->whereIn('item_id', $item_id) ->select('item_id', 'data_id', 'type') ->get(); // 2. 收集 ID 并按类型分类(去重以减少查询压力) $manIds = $data->where('type', ItemDetails::type_one)->pluck('data_id')->unique()->toArray(); $devIds = $data->where('type', ItemDetails::type_two)->pluck('data_id')->unique()->toArray(); // 3. 一次性查出对应的映射 (假设人员表字段是 number, 设备表是 code) // 注意:pluck('显示内容', 'ID') $manMap = Employee::whereIn('id', $manIds)->pluck('number', 'id')->toArray(); $devMap = Device::whereIn('id', $devIds)->pluck('code', 'id')->toArray(); // 4. 按 item_id 分组处理成字符串 $result = []; foreach ($item_id as $id) { // 初始化每个 item_id 的默认结构 $result[$id] = [ 'man' => '', 'device' => '' ]; } // 5. 遍历明细填充数据 $grouped = $data->groupBy('item_id'); foreach ($grouped as $itemId => $items) { $mans = []; $devices = []; foreach ($items as $item) { if ($item->type == ItemDetails::type_one) { if (isset($manMap[$item->data_id])) { $mans[] = $manMap[$item->data_id]; } } else { if (isset($devMap[$item->data_id])) { $devices[] = $devMap[$item->data_id]; } } } $result[$itemId] = [ 'man' => implode(',', $mans), 'device' => implode(',', $devices) ]; } return $result; } }