BroadbandSaler/app/DataApiNew/Helper/OrderSettRecordHelper.php

<?php
/*
 * @Description: 结算记录表
 * @Version: *
 * @Autor: lexuan
 * @Date: 2024-11-29 16:50:19
 * @LastEditors: lexuan
 * @LastEditTime: 2024-11-29 16:50:19
 */

namespace App\DataApiNew\Helper;

use App\DataApiNew\Models\OrderSettRecord;
use App\Models\Pages;
use App\Models\SpoutExport;
use App\Models\SpoutImport;
use App\Jobs\AutoSettleJob;
use Illuminate\Http\Request;

class OrderSettRecordHelper
{
    // 查询条件
    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, OrderSettRecord::query());

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

        $result = $page->paginate();

        return $result;
    }

    // 导出
    public function export(Request $request)
    {
        $query = OrderSettRecord::select(OrderSettRecord::$selectFields);
        $query = $this->whens($query, $request);
        $query->orderBy('created_at', 'desc');
        $header = [
            '导入文件路径' => 'put_file',
            '结算结果文件路径' => 'out_file',
            '状态 0待执行 1执行中 2执行成功 3执行失败 4停止执行' => 'status',
            '创建时间' => 'created_at',
            '更新时间' => 'updated_at',
            '删除时间' => 'deleted_at',
            '备注' => 'remark',
            '标题' => 'title',
            '1号卡 2设备 3靓号 4宽带' => 'type',
        ];
        $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 = [
            '导入文件路径' => 'put_file',
            '结算结果文件路径' => 'out_file',
            '状态 0待执行 1执行中 2执行成功 3执行失败 4停止执行' => 'status',
            '创建时间' => 'created_at',
            '更新时间' => 'updated_at',
            '删除时间' => 'deleted_at',
            '备注' => 'remark',
            '标题' => 'title',
            '1号卡 2设备 3靓号 4宽带' => 'type',
        ];
        $getEnValue = $this->getEnValue();
        $SpoutImport = new SpoutImport($header);
        $dataList = $SpoutImport->setRequest($request)->getExcelData();
        return $dataList;
    }

    // 获取枚举值
    public function getEnValue()
    {
        $data = [
            'open_status' =>  [
                0 => "待开卡",
                1 => "开卡中",
            ]
        ];
        return $data;
    }

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

    // 添加
    public function insert(Request $request)
    {
        $request->validate([
            'file' => 'required|mimes:csv,xls,xlsx',
            'type' => 'required|integer|in:1,2,3,4',
        ]);

        $title = $request->input('title', null);
        // 获取上传的文件
        $file = $request->file('file');
        $type = $request->type;
        // 生成唯一的文件名
        $filename = "sttle_put_" . uniqid() . '_' . time() . '.' . $file->getClientOriginalExtension();
        // 将文件保存到指定目录 public/csv/
        $file->storeAs("/batch_order_settle/put", $filename, 'csv');
        $file_path = "csv/batch_order_settle/put/" . $filename;

        $result = OrderSettRecord::create([
            'put_file' => $file_path,
            'title' => $title,
            'type' => $type,
        ]);
        if ($result) {
            AutoSettleJob::dispatch($result->id, $type);
            return ['code' => 1, 'msg' => "success", 'data' => config('app.url') . "/" . $file_path];
        } else {
            return error();
        }
    }

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

        $result = OrderSettRecord::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 = OrderSettRecord::whereIn('id', $arr)->delete();
        if ($result) {
            return success();
        } else {
            return error();
        }
    }

    // 获取导入模版
    public function getOrderSettImportTemplate()
    {
        $headers = ['订单号', '结算状态 [ 结算成功 结算失败 ]', '原因'];
        return (new SpoutImport([]))->generateImportTemplat($headers,[30,50,20]);
    }
}