<?php

namespace Modules\Manage\Controllers;

use App\Constants\CommonConstant;
use App\Repositories\Criterias\FanGroupCriteria;
use App\Repositories\Criterias\OrderLimitCriteria;
use App\Repositories\FanGroupRepository;
use Hyperf\Validation\Contract\ValidatorFactoryInterface;
use Modules\Manage\Responses\PaymentSuccessUidResponse;
class FanGroupController extends BaseController
{
    use \Hyperf\Di\Aop\ProxyTrait;
    use \Hyperf\Di\Aop\PropertyHandlerTrait;
    function __construct()
    {
        if (method_exists(parent::class, '__construct')) {
            parent::__construct(...func_get_args());
        }
        $this->__handlePropertyHandler(__CLASS__);
    }
    public function lists(ValidatorFactoryInterface $validatorFactory)
    {
        $inputData = $this->getJsonData();
        $rules = ['page' => 'required|numeric', 'page_size' => 'required|numeric', 'status' => 'nullable|in:1,2', 'title' => 'nullable|string'];
        $validator = $validatorFactory->make($inputData, $rules);
        if ($validator->fails()) {
            // 如果有错误（可能是多个信息），这里只取第一个错误信息返回.
            return json_fail($validator->errors()->first());
        }
        $pageSize = $inputData['page_size'] ?? CommonConstant::PAGE_SIZE;
        if ($pageSize > 500) {
            $pageSize = CommonConstant::PAGE_SIZE;
        }
        $page = isset($inputData['page']) ? intval($inputData['page']) : 1;
        $page = format_page($page);
        $orders = [['created_at', 'DESC']];
        $res = make(FanGroupRepository::class)->pushCriteria(new FanGroupCriteria($inputData))->pushCriteria(new OrderLimitCriteria($orders))->paginate($pageSize, ['*'], $page);
        return json_success($res);
    }
    /**
     * 创建群组
     *
     * @param ValidatorFactoryInterface $validatorFactory
     * @return mixed|PaymentSuccessUidResponse
     */
    public function create(ValidatorFactoryInterface $validatorFactory)
    {
        $inputData = $this->getJsonData();
        $rules = ['log' => 'required|string', 'title' => 'required|string', 'status' => 'required|in:1,2', 'link' => 'required|string', 'sort' => 'required|integer'];
        $validator = $validatorFactory->make($inputData, $rules);
        if ($validator->fails()) {
            // 如果有错误（可能是多个信息），这里只取第一个错误信息返回.
            return json_fail($validator->errors()->first());
        }
        $inserData = ['log' => $inputData['log'], 'title' => $inputData['title'], 'status' => $inputData['status'], 'link' => $inputData['link'], 'sort' => $inputData['sort']];
        $result = make(FanGroupRepository::class)->create($inserData);
        if (!$result) {
            return json_fail('创建失败');
        } else {
            $logSubject = '添加一个支付通道,通道名字:' . $inputData['title'];
            $logSvalue = $result->id;
            $logDbData = ['after_items' => [$result->toArray()], 'before_items' => []];
            $this->log($logSubject, $logSvalue, $logDbData);
            return new PaymentSuccessUidResponse($result->id);
        }
    }
    /**
     * 修改群组
     *
     * @param ValidatorFactoryInterface $validatorFactory
     * @return mixed|PaymentSuccessUidResponse
     */
    public function modify(ValidatorFactoryInterface $validatorFactory)
    {
        $inputData = $this->getJsonData();
        $rules = ['id' => 'required', 'log' => 'nullable|string', 'title' => 'nullable|string', 'status' => 'nullable|in:1,2', 'link' => 'nullable|string', 'sort' => 'nullable|integer'];
        $validator = $validatorFactory->make($inputData, $rules);
        if ($validator->fails()) {
            // 如果有错误（可能是多个信息），这里只取第一个错误信息返回.
            return json_fail($validator->errors()->first());
        }
        $fanGroupInfo = make(FanGroupRepository::class)->findBy('id', $inputData['id']);
        if (!$fanGroupInfo) {
            return json_fail('修改的粉丝群组不存在!');
        }
        $oldFanGroupInfo = clone $fanGroupInfo;
        if (!empty($inputData['log'])) {
            $fanGroupInfo->log = $inputData['log'];
        }
        if (!empty($inputData['title'])) {
            $fanGroupInfo->title = $inputData['title'];
        }
        if (!empty($inputData['status'])) {
            $fanGroupInfo->status = $inputData['status'];
        }
        if (!empty($inputData['link'])) {
            $fanGroupInfo->link = $inputData['link'];
        }
        if (!empty($inputData['sort'])) {
            $fanGroupInfo->sort = $inputData['sort'];
        }
        $result = $fanGroupInfo->save();
        if (!$result) {
            return json_fail('修改失败');
        } else {
            $logSubject = '修改一个粉丝群组:' . $fanGroupInfo->name;
            $logSvalue = $fanGroupInfo->id;
            $logDbData = ['after_items' => [$fanGroupInfo->toArray()], 'before_items' => [$oldFanGroupInfo->toArray()]];
            $this->log($logSubject, $logSvalue, $logDbData);
            return new PaymentSuccessUidResponse($fanGroupInfo->id);
        }
    }
    /**
     * 删除群组
     *
     * @param ValidatorFactoryInterface $validatorFactory
     * @return mixed|PaymentSuccessUidResponse
     */
    public function delete(ValidatorFactoryInterface $validatorFactory)
    {
        $inputData = $this->getJsonData();
        $rules = ['id' => 'required'];
        $validator = $validatorFactory->make($inputData, $rules);
        if ($validator->fails()) {
            // 如果有错误（可能是多个信息），这里只取第一个错误信息返回.
            return json_fail($validator->errors()->first());
        }
        $fanGroupInfo = make(FanGroupRepository::class)->findBy('id', $inputData['id']);
        if (!$fanGroupInfo) {
            return json_fail('删除的粉丝群组不存在!');
        }
        $oldFanGroupInfo = clone $fanGroupInfo;
        $result = $fanGroupInfo->delete();
        if (!$result) {
            return json_fail('删除失败');
        } else {
            $logSubject = '删除一个粉丝群组:' . $fanGroupInfo->name;
            $logSvalue = $fanGroupInfo->manager_id;
            $logDbData = ['after_items' => [], 'before_items' => [$oldFanGroupInfo->toArray()]];
            $this->log($logSubject, $logSvalue, $logDbData);
            return new PaymentSuccessUidResponse($inputData->id);
        }
    }
}