bot-28/app/Http/Controllers/admin/RechargeChannel.php

<?php

namespace App\Http\Controllers\admin;

use App\Http\Controllers\Controller;
use App\Models\RechargeChannel as RechargeChannelModel;
use App\Models\RechargeChannelGroup;
use App\Services\Payment\PaymentProviderCatalog;
use App\Services\Payment\RechargeChannelConfigurationService;
use App\Services\Payment\PaymentProviderService;
use Illuminate\Support\Facades\DB;
use Illuminate\Validation\Rule;
use Illuminate\Validation\ValidationException;
use Illuminate\Database\Eloquent\ModelNotFoundException;
use Exception;
use App\Constants\HttpStatus;

class RechargeChannel extends Controller
{
    public function delete(RechargeChannelConfigurationService $service)
    {
        try {
            $params = request()->validate(['id' => ['required', 'integer', 'min:1']]);
            $service->delete((int)$params['id']);
            return $this->success();
        } catch (ValidationException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (ModelNotFoundException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, '通道不存在');
        } catch (\PDOException $e) {
            report($e);
            return $this->error(HttpStatus::CUSTOM_ERROR, '删除通道失败，请稍后重试');
        } catch (Exception $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->getMessage());
        }
    }

    public function options(RechargeChannelConfigurationService $service)
    {
        try {
            $params = request()->validate([
                'data_type' => ['required', 'integer', 'in:1,2,3'],
                'id' => ['nullable', 'integer', 'min:1'],
            ]);
            return $this->success($service->options((int)$params['data_type'], isset($params['id']) ? (int)$params['id'] : null));
        } catch (ValidationException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (ModelNotFoundException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, '数据不存在');
        } catch (\PDOException $e) {
            report($e);
            return $this->error(HttpStatus::CUSTOM_ERROR, '读取通道选项失败');
        } catch (Exception $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->getMessage());
        }
    }

    //获取充值方式
    public function getChannel()
    {
        $data_type = request()->input('data_type', 1);
        $channel = RechargeChannelModel::getChannel($data_type);
        return $this->success(['total' => count($channel), 'data' => $channel]);
    }

    /**
     * 充值通道组合列表
     */
    public function groupList()
    {
        try {
            $page = request()->input('page', 1);
            $limit = request()->input('limit', 15);

            $query = new RechargeChannelGroup();
            $count = $query->count();
            $list = $query
                ->forPage($page, $limit)
                ->get();
            foreach($list as &$item) {
                $item->rechargeTypes = $item['recharge_type'] ? RechargeChannelModel::getChannel(1, $item['recharge_type']) : [];
                $item->withdrawTypes = $item['withdraw_type'] ? RechargeChannelModel::getChannel(2, $item['withdraw_type']) : [];
                $item->activityTypes = $item['activity_type'] ? RechargeChannelModel::getChannel(3, $item['activity_type']) : [];
            }
        } catch (Exception $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR,$e->getMessage());
        }
        return $this->success(['total' => $count, 'data' => $list]);
    }

    /**
     * 充值通道组合管理更新
     */
    public function updateGroup()
    {
        try {
            $params = request()->validate([
                'id' => ['nullable','integer'],
                'name' => ['required','string'],
                'recharge_type' => ['present','array'],
                'withdraw_type' => ['present','array'],
                'activity_type' => ['nullable','array'],
            ]);
            DB::transaction(function () use ($params) {
                foreach (['recharge_type' => 1, 'withdraw_type' => 2, 'activity_type' => 3] as $field => $dataType) {
                    if ($field === 'activity_type' && !request()->exists('activity_type')) {
                        unset($params['activity_type']);
                        continue;
                    }
                    $types = array_values(array_unique(array_filter(array_map('strval', $params[$field] ?? []))));
                    if ($types) {
                        $existingCount = RechargeChannelModel::query()->where('data_type', $dataType)
                            ->whereIn('type', $types)->distinct()->lockForUpdate()->get(['type'])->count();
                        if ($existingCount !== count($types)) throw new Exception("{$field} 包含不存在的通道类型");
                    }
                    $params[$field] = $types;
                }

                if (empty($params['id'])) {
                    RechargeChannelGroup::create($params);
                } else {
                    $info = RechargeChannelGroup::where('id', $params['id'])->first();
                    if (!$info) throw new Exception('数据不存在');
                    $info->update($params);
                    $info->save();
                }
            }, 3);
            
            return $this->success();
        } catch (Exception $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR,$e->getMessage());
        }
    }

    /**
     * 充值通道管理列表
     */
    public function list()
    {
        try {
            $params = request()->validate([
                'page' => ['nullable', 'integer', 'min:1'],
                'limit' => ['nullable', 'integer', 'min:1'],
                'data_type' => ['nullable', 'string'],
                'type' => ['nullable', 'string'],
                'from' => ['nullable', 'integer'],
                'key' => ['nullable', 'string'],
                'name' => ['nullable', 'string'],
                'payment_company' => ['nullable', Rule::in(PaymentProviderCatalog::codes())],
            ]);
            $page = request()->input('page', 1);
            $limit = request()->input('limit', 15);

            $query = new RechargeChannelModel();
            if (!empty($params['data_type'])) {
                $query = $query->where('data_type', $params['data_type']);
            }
            if (!empty($params['type'])) {
                $query = $query->where('type', $params['type']);
            }
            if (isset($params['from'])) {
                $query = $query->where('from', $params['from']);
            }
            if (!empty($params['key'])) {
                $query = $query->where('key', $params['key']);
            }
            if (!empty($params['name'])) {
                $query = $query->where('name', 'like', '%'.$params['name'].'%');
            }
            if (!empty($params['payment_company'])) {
                $direction = !empty($params['data_type']) ? (int)$params['data_type'] : null;
                $query = $query->where('from', 1)->whereIn('data_type', [1, 2])->whereIn('type',
                    PaymentProviderCatalog::channelTypesForProvider($params['payment_company'], $direction));
            }
            $count = $query->count();
            $companyStatuses = PaymentProviderService::statuses();
            $list = $query
                ->forPage($page, $limit)
                ->orderBy('sort', 'asc')
                ->orderBy('id', 'asc')
                ->get()->map(function (RechargeChannelModel $channel) use ($companyStatuses) {
                    $row = $channel->toArray();
                    return $row + PaymentProviderCatalog::channelDisplay($row, $companyStatuses);
                });
        } catch (Exception $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR,$e->getMessage());
        }
        return $this->success(['total' => $count, 'data' => $list]);
    }

    /**
     * 充值通道管理更新
     */
    public function update(RechargeChannelConfigurationService $service)
    {
        try {
            $params = request()->validate([
                'id' => ['nullable','integer'],
                'from' => ['nullable','integer','in:1,2,3'],
                'payment_company' => ['nullable', Rule::in(PaymentProviderCatalog::codes())],
                'key' => ['nullable','string','max:100'],
                'name' => ['nullable','string','max:100'],
                'data_type' => ['required','integer','in:1,2,3'],
                'type' => ['required','string','max:100'],
                'rate' => ['required','numeric','min:0'],
                'min' => ['nullable','numeric','min:0'],
                'max' => ['nullable','numeric','gte:min'],
                'fixed' => ['nullable','string'],
                'status' => ['nullable','integer','in:0,1'],
                'sort' => ['nullable','integer','min:0'],
            ]);

            $service->save($params);
            
            return $this->success();
        } catch (ValidationException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (ModelNotFoundException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, '数据不存在');
        } catch (\PDOException $e) {
            report($e);
            return $this->error(HttpStatus::CUSTOM_ERROR, '保存通道失败，请稍后重试');
        } catch (Exception $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR,$e->getMessage());
        }
    }

}