neiyou_user_web/app/Http/Controllers/Admin/RuleController.php

<?php

namespace App\Http\Controllers\Admin;

use App\Http\Controllers\Controller;
use App\Models\Node;
use App\Models\Rule;
use App\Models\RuleGroup;
use App\Models\RuleLog;
use Exception;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Response;
use Validator;

class RuleController extends Controller {
	// 审计规则列表
	public function index(Request $request) {
		$type = $request->input('type');
		$query = Rule::query();

		if($type){
			$query->whereType($type);
		}

		$view['rules'] = $query->paginate(15)->appends($request->except('page'));
		return view('admin.rule.index', $view);
	}

	// 添加审计规则
	public function store(Request $request): JsonResponse {
		$validator = Validator::make($request->all(), [
			'type'    => 'required|between:1,4',
			'name'    => 'required',
			'pattern' => 'required',
		]);

		if($validator->fails()){
			return Response::json(['status' => 'fail', 'message' => $validator->errors()->all()]);
		}

		$obj = new Rule();
		$obj->type = $request->input('type');
		$obj->name = $request->input('name');
		$obj->pattern = $request->input('pattern');
		$obj->save();

		if($obj->id){
			return Response::json(['status' => 'success', 'message' => '提交成功']);
		}
		return Response::json(['status' => 'fail', 'message' => '操作失败']);
	}

	// 编辑审计规则
	public function update(Request $request, $id): JsonResponse {
		$ret = Rule::whereId($id)->update([
			'name'    => $request->input('rule_name'),
			'pattern' => $request->input('rule_pattern')
		]);
		if($ret){
			return Response::json(['status' => 'success', 'message' => '操作成功']);
		}
		return Response::json(['status' => 'fail', 'message' => '操作失败']);
	}

	// 删除审计规则
	public function destroy($id): JsonResponse {
		try{
			Rule::whereId($id)->delete();

			foreach(RuleGroup::all() as $ruleGroup){
				$rules = $ruleGroup->rules;
				if($rules && in_array($id, $rules, true)){
					$ruleGroup->rules = array_merge(array_diff($rules, [$id]));
					$ruleGroup->save();
				}
			}
		}catch(Exception $e){
			return Response::json(['status' => 'fail', 'message' => '操作失败, '.$e->getMessage()]);
		}
		return Response::json(['status' => 'success', 'message' => '操作成功']);
	}

	// 用户触发审计规则日志
	public function ruleLogList(Request $request) {
		$uid = $request->input('uid');
		$email = $request->input('email');
		$nodeId = $request->input('node_id');
		$ruleId = $request->input('rule_id');
		$query = RuleLog::query();

		if($uid){
			$query->whereUserId($uid);
		}
		if(isset($email)){
			$query->whereHas('user', static function($q) use ($email) {
				$q->where('email', 'like', '%'.$email.'%');
			});
		}
		if($nodeId){
			$query->whereNodeId($nodeId);
		}
		if($ruleId){
			$query->whereRuleId($ruleId);
		}

		$view['nodeList'] = Node::all();
		$view['ruleList'] = Rule::all();
		$view['ruleLogs'] = $query->latest()->paginate(15)->appends($request->except('page'));
		return view('admin.rule.log', $view);
	}

	// 清除所有审计触发日志
	public function clearLog(): JsonResponse {
		try{
			$ret = RuleLog::query()->delete();
		}catch(Exception $e){
			return Response::json(['status' => 'fail', 'message' => '清理失败, '.$e->getMessage()]);
		}
		$result = RuleLog::doesntExist();
		if($ret || $result){
			return Response::json(['status' => 'success', 'message' => '清理成功']);
		}

		return Response::json(['status' => 'fail', 'message' => '清理失败']);
	}
}