287 lines
8.0 KiB
PHP
287 lines
8.0 KiB
PHP
<?php
|
|
namespace App\Domains\Virtual\Http\Controllers;
|
|
|
|
use Carbon\Carbon;
|
|
use App\Core\Controller;
|
|
use Illuminate\Http\Request;
|
|
use Illuminate\Support\Facades\DB;
|
|
use App\Models\Virtual\FlowPoolData;
|
|
use App\Exceptions\NotExistException;
|
|
use App\Models\Virtual\FlowPoolMonth;
|
|
use Illuminate\Support\Facades\Schema;
|
|
use App\Exceptions\NotAllowedException;
|
|
use App\Domains\Export\Services\ExportService;
|
|
use App\Domains\Virtual\Exports\FlowPoolExport;
|
|
use App\Domains\Virtual\Services\PackageService;
|
|
use App\Domains\Virtual\Services\ProductService;
|
|
use App\Domains\Virtual\Services\FlowPoolService;
|
|
|
|
use App\Domains\Virtual\Repositories\FlowPoolRepository;
|
|
use App\Domains\Virtual\Exports\FlowPoolExportDetailExport;
|
|
use App\Domains\Virtual\Repositories\OrderCardPartitionRepository;
|
|
|
|
class FlowPoolController extends Controller
|
|
{
|
|
protected $request;
|
|
protected $flowPoolService;
|
|
|
|
/**
|
|
* 构造函数，自动注入.
|
|
*/
|
|
public function __construct(Request $request, FlowPoolService $flowPoolService)
|
|
{
|
|
$this->request = $request;
|
|
$this->flowPoolService = $flowPoolService;
|
|
}
|
|
|
|
/**
|
|
* RD流量池列表
|
|
*
|
|
* @return void
|
|
*/
|
|
public function real()
|
|
{
|
|
$list = $this->flowPoolService->real();
|
|
return res($list, 'RD流量池列表', 201);
|
|
}
|
|
|
|
/**
|
|
* 后向套餐列表
|
|
*
|
|
* @return void
|
|
*/
|
|
public function packages()
|
|
{
|
|
$list = $this->flowPoolService->packages();
|
|
return res($list, '后向套餐列表', 201);
|
|
}
|
|
|
|
/**
|
|
* 列表.
|
|
*
|
|
* @return \Illuminate\Http\Response
|
|
*/
|
|
public function index()
|
|
{
|
|
$conditions = $this->request->all();
|
|
|
|
$flowPools = $this->flowPoolService->index($conditions);
|
|
|
|
return res($flowPools, '流量池列表', 201);
|
|
}
|
|
|
|
/**
|
|
* 详情.
|
|
*
|
|
* @return \Illuminate\Http\Response
|
|
*/
|
|
public function show()
|
|
{
|
|
$page = $this->request->get('page');
|
|
$conditions = $this->request->all();
|
|
$res = $this->flowPoolService->show($conditions);
|
|
return res($res, '流量池详情', 201);
|
|
}
|
|
|
|
/**
|
|
* 明细导出.
|
|
*
|
|
* @return \Illuminate\Http\Response
|
|
*/
|
|
public function detailExport()
|
|
{
|
|
$conditions = $this->request->only(['pool_id', 'month']);
|
|
|
|
$pool_id = $conditions['pool_id'];
|
|
$month = Carbon::parse($conditions['month']);
|
|
|
|
$table = app(FlowPoolMonth::class)->getTable() . '_' . $month->format('Ym');
|
|
|
|
if (!Schema::hasTable($table)) {
|
|
throw new NotAllowedException('无该月数据');
|
|
}
|
|
|
|
$total = app(FlowPoolMonth::class)->setTable($table)->where('pool_id', $pool_id)->count();
|
|
|
|
try {
|
|
$export = new FlowPoolExportDetailExport($conditions);
|
|
$queue = $total > 30000;
|
|
$url = ExportService::store($export, $disk = 'public', $queue);
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
|
|
return res($url, '导出成功', 201);
|
|
}
|
|
|
|
|
|
/**
|
|
* 创建.
|
|
*
|
|
* @return \Illuminate\Http\Response
|
|
*/
|
|
public function create()
|
|
{
|
|
$attributes = $this->request->all();
|
|
|
|
$flowPool = $this->flowPoolService->store($attributes);
|
|
|
|
return res($flowPool, '创建成功');
|
|
}
|
|
|
|
/**
|
|
* 编辑.
|
|
*
|
|
* @return \Illuminate\Http\Response
|
|
*/
|
|
public function update($id)
|
|
{
|
|
$attributes = $this->request->all();
|
|
$attributes['id'] = $id;
|
|
|
|
$flowPool = $this->flowPoolService->store($attributes);
|
|
|
|
return res($flowPool, '修改成功');
|
|
}
|
|
|
|
/**
|
|
* 删除.
|
|
*
|
|
* @return \Illuminate\Http\Response
|
|
*/
|
|
public function destroy()
|
|
{
|
|
$ids = $this->request->ids();
|
|
|
|
$this->flowPoolService->destroy($ids);
|
|
|
|
return res(true, '删除成功');
|
|
}
|
|
|
|
|
|
/**
|
|
* 编辑.
|
|
*
|
|
* @return \Illuminate\Http\Response
|
|
*/
|
|
public function setting()
|
|
{
|
|
$attributes = $this->request->all();
|
|
|
|
$setting = $this->flowPoolService->setting($attributes);
|
|
|
|
return res($setting, $attributes['id'] ? '修改成功' : '添加成功');
|
|
}
|
|
|
|
/**
|
|
* 数据生成.
|
|
*
|
|
* @return \Illuminate\Http\Response
|
|
*/
|
|
public function flows()
|
|
{
|
|
$pool_id = $this->request->get('pool_id');
|
|
$month = $this->request->time('month');
|
|
|
|
if ($this->request->isMethod('GET')) {
|
|
if (!$flowPool = app(FlowPoolRepository::class)->find($pool_id)) {
|
|
throw new NotExistException('流量池不存在或已删除');
|
|
}
|
|
|
|
$flowPool = FlowPoolService::transformer(collect([$flowPool]), $month)->first();
|
|
|
|
if ($flowPool->setting_status) {
|
|
$repository = app(OrderCardPartitionRepository::class);
|
|
|
|
$minimum_settings = $flowPool['settings'][0]['minimum_settings'] ?? [];
|
|
|
|
$package_ids = array_pluck($minimum_settings, 'package_id');
|
|
|
|
$conditions = [
|
|
'type' => [0, 1, 2],
|
|
'month' => $month,
|
|
'company_id' => $flowPool->company_id,
|
|
'package_id' => $package_ids,
|
|
'unit_price' => 0
|
|
];
|
|
|
|
$cards = $repository->select([
|
|
'package_id',
|
|
DB::raw('count(distinct sim) as total'),
|
|
])->withConditions($conditions)->groupBy('package_id')->get();
|
|
|
|
$cards->map(function ($item) {
|
|
$item->package_name = PackageService::load($item->package_id)['name'];
|
|
});
|
|
} else {
|
|
$cards = collect();
|
|
}
|
|
|
|
$flowPoolData = FlowPoolData::where('month', $month->format('Ym'))->where('pool_id', $pool_id)->first();
|
|
|
|
if (!$flowPoolData) {
|
|
$flowPoolData = [
|
|
'pool_id' => $pool_id,
|
|
'month' => $month->format('Y-m'),
|
|
'total_flows' => 0,
|
|
'settings' => [],
|
|
];
|
|
}
|
|
|
|
$settings = array_keyBy($flowPoolData['settings'], 'package_id');
|
|
|
|
foreach ($cards as $card) {
|
|
if (!isset($settings[$card['package_id']])) {
|
|
$settings[$card['package_id']] = [
|
|
'package_id' => $card['package_id'],
|
|
'package_name' => $card['package_name'],
|
|
'total' => $card['total'],
|
|
'news' => $card['total'],
|
|
];
|
|
} else {
|
|
$chunk = $settings[$card['package_id']]['cards'];
|
|
|
|
foreach ($chunk as &$value) {
|
|
$value['flow_range'][0] = sprintf('%.02f', $value['flow_range'][0]/1024);
|
|
$value['flow_range'][1] = sprintf('%.02f', $value['flow_range'][1]/1024);
|
|
}
|
|
|
|
$settings[$card['package_id']]['cards'] = $chunk;
|
|
|
|
$settings[$card['package_id']]['news'] = $card['total'] - array_sum(array_pluck($settings[$card['package_id']]['cards'], 'counts'));
|
|
}
|
|
}
|
|
|
|
$flowPoolData['total_flows'] = sprintf('%.02f', $flowPoolData['total_flows']/1024);
|
|
|
|
return res(['flowPool' => $flowPool, 'settings' => array_values($settings), 'total' => array_sum(array_pluck($cards, 'total')), 'total_flows' => $flowPoolData['total_flows']], '数据设置');
|
|
}
|
|
|
|
$conditions = $this->request->all();
|
|
|
|
$res = $this->flowPoolService->flows($conditions);
|
|
|
|
return res($res, '设置成功');
|
|
}
|
|
|
|
/**
|
|
* 导出.
|
|
*
|
|
* @return \Illuminate\Http\Response
|
|
*/
|
|
public function export()
|
|
{
|
|
$conditions = $this->request->except(['page', 'limit']);
|
|
$conditions['limit'] = 0;
|
|
|
|
try {
|
|
$export = new FlowPoolExport($conditions);
|
|
$url = ExportService::store($export, $disk = 'public');
|
|
} catch (\Exception $e) {
|
|
throw $e;
|
|
}
|
|
|
|
return res($url, '导出成功', 201);
|
|
}
|
|
}
|