BroadbandSaler/app/DataApiNew/Helper/SystemMsgHelper.php

<?php
/*
 * @Description: 系统消息表
 * @Version: *
 * @Autor: lexuan
 * @Date: 2024-12-02 15:25:21
 * @LastEditors: lexuan
 * @LastEditTime: 2024-12-02 15:25:21
 */

namespace App\DataApiNew\Helper;

use App\DataApiNew\Models\SystemMsg;
use App\Models\Pages;
use App\Models\SpoutExport;
use App\Models\SpoutImport;
use App\DataApiNew\Models\AdminUsers;
use Illuminate\Http\Request;

class SystemMsgHelper
{
    // 查询条件
    public function whens($query, $request)
    {
        return $query
            ->when($request->filled('id'), fn ($q) => $q->where('id', $request->id))
            ->when($request->filled('source'), fn ($q) => $q->where('source', $request->source))
            ->when($request->filled('type'), fn ($q) => $q->where('type', $request->type));
    }

    // 查询列表
    public function select(Request $request)
    {
        $page = new Pages($request, SystemMsg::query());

        $page->before(function ($query) use ($request) {
            $query->select(SystemMsg::$selectFields);
            return $this->whens($query, $request);
        });

        $result = $page->paginate();

        return $result;
    }

    // 导出
    public function export(Request $request)
    {
        $query = SystemMsg::select(SystemMsg::$selectFields);
        $query = $this->whens($query, $request);
        $query->orderBy('created_at', 'desc');
        $header = [
            '唯一标识符' => 'id',
            '用户ID' => 'user_id',
            '消息内容' => 'text',
            '消息标题' => 'title',
            '可见时间' => 'visibility_time',
            '创建时间' => 'created_at',
            '更新时间' => 'updated_at',
            '来源 1系统消息 2用户消息' => 'source',
        ];
        $getEnValue = $this->getEnValue();

        $excel = new SpoutExport($header);
        $excel->setData($query->get());
        $result = $excel->setEnum($getEnValue)->spoutToExcel('excel_out');

        return $result ? success($result['url']) : error();
    }

    // 导入
    public function import(Request $request)
    {
        $header = [
            '唯一标识符' => 'id',
            '用户ID' => 'user_id',
            '消息内容' => 'text',
            '消息标题' => 'title',
            '可见时间' => 'visibility_time',
            '创建时间' => 'created_at',
            '更新时间' => 'updated_at',
            '来源 1系统消息 2用户消息' => 'source',
        ];
        $SpoutImport = new SpoutImport($header);
        $dataList = $SpoutImport->setRequest($request)->getExcelData();
        return $dataList;
    }

    // 获取枚举值
    public function getEnValue()
    {
        $data = [];
        return $data;
    }

    // 查询一条
    public function find(Request $request)
    {
        $request->validate([
            'id' => 'required|integer',
        ]);
        $result = SystemMsg::where(['id' => $request->id])->select(SystemMsg::$selectFields)->first();
        return success($result);
    }

    // 添加
    public function insert(Request $request)
    {
        $request->validate([
            // 'name' => 'required',
        ]);
        $result = SystemMsg::create($request->all());
        if ($result) {
            return success();
        } else {
            return error();
        }
    }

    // 修改
    public function update(Request $request)
    {
        $request->validate([
            'id' => 'required|integer',
        ]);

        $result = SystemMsg::where(['id' => $request->id])->update($request->all());
        if ($result) {
            return success();
        } else {
            return error();
        }
    }

    // 删除
    public function delete(Request $request)
    {
        $request->validate([
            'ids' => 'required',
        ]);
        $id_str = $request->ids;
        $arr = explode(",", $id_str);
        // 查询是否存在子数据
        // $count = Shop::whereIn('tm_id',$arr)->count();
        // if($count > 0){
        //     return ['code'=>0,'msg'=>"存在子数据，禁止删除"];
        // }
        $result = SystemMsg::whereIn('id', $arr)->delete();
        if ($result) {
            return success();
        } else {
            return error();
        }
    }

    // 获取用户消息
    public function selectUserMsg(Request $request)
    {
        $request->validate([
            'source' => 'required|in:' . implode(',', array_keys(SystemMsg::$source)),
            'type' => 'required|in:' . implode(',', array_keys(SystemMsg::$type)),
        ]);

        $user_id = auth()->id();

        $currentTime = now()->format('Y-m-d H:i:s');

        $page = new Pages($request, SystemMsg::query());

        if ($request->source == SystemMsg::SOURCE_SYSTEM) {
            $page->before(function ($query) use ($request, $currentTime) {
                $query->where('source', SystemMsg::SOURCE_SYSTEM)
                    ->where('visibility_time', '<=', $currentTime)
                    ->when($request->filled('type'), fn ($q) => $q->where('type', $request->type))
                    ->select([
                        'id',
                        'text',
                        'title',
                        'created_at',
                    ]);
                return $query;
            });
        } elseif ($request->source == SystemMsg::SOURCE_USER) {
            $page->before(function ($query) use ($request, $user_id, $currentTime) {
                $query->where('user_id', $user_id)
                    ->where('source', SystemMsg::SOURCE_USER)
                    ->where('visibility_time', '<=', $currentTime)
                    ->when($request->filled('type'), fn ($q) => $q->where('type', $request->type))
                    ->select([
                        'id',
                        'user_id',
                        'text',
                        'title',
                        'created_at',
                    ]);
                return $query;
            });
        } else {
            return error();
        }

        $result = $page->paginate();

        return $result;
    }

    // 获取用户最后一条消息
    public function getLastUserMsg(Request $request)
    {
        $user_id = $request->user()->id;
        $userReadLastId = $request->input('last_id', 0);

        $userinfo = AdminUsers::where('id', $user_id)->value('last_system_msg_id');
        if ($userinfo < $userReadLastId) {
            AdminUsers::where('id', $user_id)
            ->update(['last_system_msg_id' => $userReadLastId]);
        }

        $query = SystemMsg::selectRaw('count(*) as count, max(id) as last_id')
        ->where('visibility_time', '<=', now())
        ->where(function ($query) use ($user_id) {
            $query->where('source', SystemMsg::SOURCE_SYSTEM)
                ->orWhere(function ($q) use ($user_id) {
                    $q->where('user_id', $user_id)->where('source', SystemMsg::SOURCE_USER);
                });
        })
        ->first();
    
        $count = $query->count;
        $last_id = $query->last_id;

        return ['code' => 1, 'msg' => "success", 'data' => ['count' => $count, 'last_id' => $last_id]];
    }
}