批量创建StudentSection时Observer未触发的问题求助

问题原因 #

Laravel的insert()批量插入方法直接执行原生SQL语句，不会为每条记录实例化模型对象，因此模型的created事件（以及对应的Observer钩子）不会被触发。而单个插入时使用的create()方法会实例化模型并执行save()，会正常触发事件。

解决方案 #

方案1：循环使用create()插入（保证事件触发，性能略低）

将批量插入改为循环调用create()，同时开启事务保证操作原子性：

public function setStudentsSection(Request $request)
{
    $enrollments = Enrollment::whereIn('student_id', $request->students)->where('session_id', $request->session_id)->get();
    $program_section = ProgramSection::withCount('students')->find($request->program_section_id);
    
    $totalStudents = $program_section->students_count + $enrollments->count();
    if($totalStudents <= $program_section->max_students) {
        DB::beginTransaction();
        try {
            foreach($enrollments as $enrollment) {
                StudentSection::create([
                    'student_id'    => $enrollment->student_id,
                    'enrollment_id' => $enrollment->id,
                    'section_id'    => $request->program_section_id,
                    'created_at'    => Carbon::now()
                ]);
            }
            DB::commit();
            return response()->json(['message' => '学生班级分配成功'], 200);
        } catch (\Exception $e) {
            DB::rollBack();
            return response()->json(['errors' => ['message' => '操作失败：'.$e->getMessage()]], 500);
        }
    }
    return response()->json(['errors' => ['message' => '所选班级已满']], 405);
}

方案2：批量插入后手动触发事件（兼顾性能与事件触发）

先执行批量插入，再查询出插入的记录，手动调用Observer的created方法：

public function setStudentsSection(Request $request)
{
    $enrollments = Enrollment::whereIn('student_id', $request->students)->where('session_id', $request->session_id)->get();
    $program_section = ProgramSection::withCount('students')->find($request->program_section_id);
    
    $totalStudents = $program_section->students_count + $enrollments->count();
    if($totalStudents <= $program_section->max_students) {
        $new_student_sections = [];
        $enrollmentIds = $enrollments->pluck('id')->toArray();
        
        foreach($enrollments as $enrollment) {
            $new_student_sections[] = [
                'student_id'    => $enrollment->student_id,
                'enrollment_id' => $enrollment->id,
                'section_id'    => $request->program_section_id,
                'created_at'    => Carbon::now()
            ];
        }
        
        $insertSuccess = StudentSection::insert($new_student_sections);
        
        if($insertSuccess) {
            // 查询刚插入的记录
            $insertedSections = StudentSection::whereIn('enrollment_id', $enrollmentIds)
                ->where('section_id', $request->program_section_id)
                ->get();
                
            // 获取Observer实例，手动触发created方法
            $observer = app(StudentSectionObserver::class);
            foreach($insertedSections as $section) {
                $observer->created($section);
            }
            
            return response()->json(['message' => '学生班级分配成功'], 200);
        }
        
        return response()->json(['errors' => ['message' => '插入操作失败']], 500);
    }
    return response()->json(['errors' => ['message' => '所选班级已满']], 405);
}

注意事项 #

• 方案1性能略低于批量插入，数据量较大（如上千条）时优先选方案2。
• 方案2查询插入记录时，需确保条件精准匹配刚插入的数据，避免误触发其他记录的事件。

内容的提问来源于stack exchange，提问作者Kael