BroadbandSaler/app/DataApiNew/Helper/HotRefreshHelper.php

<?php
/*
 * @Description: 热更新
 * @Version: *
 * @Autor: lexuan
 * @Date: 2025-01-07 10:17:19
 * @LastEditors: lexuan
 * @LastEditTime: 2025-01-07 10:17:19
 */
 
namespace App\DataApiNew\Helper;
 
use App\DataApiNew\Models\HotRefresh;
use App\Models\Pages;
use App\Models\SpoutExport;
use App\Models\SpoutImport;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

class HotRefreshHelper{
    // 查询条件
    public function whens($query,$request)
    {
        return $query
        ->when($request->filled('id'), fn($q) => $q->where('id', $request->id));
    }
    
    // 查询列表
    public function select(Request $request)
    {
        $page = new Pages($request,HotRefresh::query());

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

        $result = $page->paginate();
        
        return $result;
    }

    // 导出
    public function export(Request $request)
    {   
        $query = HotRefresh::select(HotRefresh::$selectFields);
        $query = $this->whens($query,$request);
        $query->orderBy('created_at','desc');
        $header = [
            '热更新包路径' => 'wgt_path',
            '版本号' => 'version',
            '描述' => 'desc',
            '发布状态 0未发布 1发布' => 'status',
            '创建时间' => 'created_at',
            '更新时间' => 'updated_at',
            '删除时间' => 'deleted_at',
            '是否强制更新 0不强制 1强制' => 'is_force',
          ];
        $getEnValue = $this->getEnValue();
        
        $excel = new SpoutExport($header);
        $excel->setQuery($query);
        $result = $excel->setEnum($getEnValue)->spoutToExcel('excel_out');
        
        return $result ? success($result['url']) : error();
    }
    
    // 导入
    public function import(Request $request)
    {   
        $header = [
            '热更新包路径' => 'wgt_path',
            '版本号' => 'version',
            '描述' => 'desc',
            '发布状态 0未发布 1发布' => 'status',
            '创建时间' => 'created_at',
            '更新时间' => 'updated_at',
            '删除时间' => 'deleted_at',
            '是否强制更新 0不强制 1强制' => 'is_force',
          ];
        $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 = HotRefresh::where(['id'=>$request->id])->select(HotRefresh::$selectFields)->first();
        return success($result);
    }
    
    // 添加
    public function insert(Request $request)
    {
        $request->validate([
            // 'name' => 'required',
        ]);
        $result = HotRefresh::create($request->all());
        if($result){
            return success();
        }else{
            return error();
        }
    }
    
    // 修改
    public function update(Request $request)
    {
        $request->validate([
            'id' => 'required|integer',
        ]);
 
        $result = HotRefresh::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 error('存在子数据，无法删除');
        // }
        $result = HotRefresh::whereIn('id', $arr)->delete();
        if($result){
            return success();
        }else{
            return error();
        }
    }

    // 查询当前发布版本
    public function getNowVersion()
    {
        return success(HotRefresh::where(['status'=>1])->first());
    }

    // 设置当前发布版本
    public function setNowVersion(Request $request)
    {
        $request->validate([
            'id' => 'required|integer',
        ]);

        sys_log($request, '设置当前发布版本', '热更新');

        $result = DB::transaction(function () use ($request){
            try {
                HotRefresh::where('id','!=',$request->id)->update(['status'=>0]);
                HotRefresh::where('id', $request->id)->update(['status' => 1]);
                return true;
            } catch (\Exception $e) {
                DB::rollBack();
                Log::error("设置当前发布版本失败",[$e]);
                return false;
            }
        });
        return $result ? success() : error();
    }
}