billiards-server/application/api/controller/AgencyAction.php

<?php

namespace app\api\controller;

use app\admin\model\Admin;
use app\api\model\system\Feedback;
use app\api\service\AgencyActionService;
use app\api\service\WxService;
use app\api\validate\BaseApiValidate;
use think\Request;

class AgencyAction extends AgencyBaseApi
{

    private $service;
    protected $cNoNeedLogin = ["login", "loginByMobile", "getAdmin"];

    public function __construct(Request $request = null)
    {
        parent::__construct($request);
        $this->service = new AgencyActionService();
    }

    public function login()
    {
        $params = (new BaseApiValidate([
            "account" => "require",
            "password" => "require",
        ]))->checkBody();
        $r = $this->service->login($params["account"], $params["password"]);
        $r->code() ? $this->success($r->data()) : $this->error($r->msg());
    }


    public function loginByMobile()
    {
        $params = (new BaseApiValidate([
            "mobile" => "require",
            "sms_code" => "require|number",
        ]))->checkBody();
        $r = $this->service->loginByMobile($params["mobile"], $params["sms_code"]);
        $r->code() ? $this->success($r->data()) : $this->error($r->msg());
    }

    public function wxAppLogin()
    {
        $params = (new BaseApiValidate([
            "openId" => "require",
            "unionId" => "require"
        ]))->checkBody();
        $r = $this->service->wxAppLogin($params["openId"], $params["unionId"]);
        $r->code() ? $this->success($r->data()) : $this->error($r->msg());
    }

    public function bindAppWx()
    {
        $params = (new BaseApiValidate([
            "openId" => "require",
            "unionId" => "require"
        ]))->checkBody();
        $r = $this->service->bindAppWx($this->admin['id'], $params["openId"], $params["unionId"]);
        $r->code() ? $this->success($r->data()) : $this->error($r->msg());
    }

    public function bindAppletWx()
    {
        $params = (new BaseApiValidate([
            "code" => "require"
        ]))->checkBody();
        $r = (new WxService())->wxLoginByApplet($params["code"]);
        if (0 === $r->code())
            $this->error($r->msg());
        $info = $r->data();
        if (!isset($info["unionid"]) || !isset($info["openid"]))
            $this->error("微信登录错误! unionid|openid 不能为空!");
        $model = new Admin();
        $agency = $model->where("id", $this->admin["id"])->find();
        if (!$agency)
            $this->error("用户不存在!");
        if ($agency["union_id"] === $info["unionid"] && $agency["applet_openid"] === $info["openid"]) {
            $this->success(true);
        }
        $A = $model->findByUnionId($info["unionid"]);
        if ($A)
            $this->error("该微信已经绑定助教,无法重复绑定!");
        $model->update([
            "applet_openid" => $info["openid"],
            "union_id" => $info["unionid"],
        ], ["id" => $this->admin['id']]);
        $this->success(true);
    }


    public function fetchPermission()
    {
        $this->success($this->service->fetchPermission($this->admin['id']));
    }

    public function fetchTodayPerformance()
    {
        $params = (new BaseApiValidate([
            "city_code" => "number",
            "store_id" => "number",
        ]))->checkBody();
        $r = $this->service->fetchTodayPerformance(
            $this->admin,
            $params["city_code"] ?? null,
            $params["store_id"] ?? null
        );
        $r->code() ? $this->success($r->data()) : $this->error($r->msg());
    }

    // 获取订单
    public function fetchOrders()
    {
        $params = (new BaseApiValidate([
            "city_code" => "number",
            "store_id" => "number",
            "page" => "require|number",
            "size" => "require|number"
        ]))->checkBody();
        $paginate = $this->service->fetchOrders(
            $this->admin,
            $params["city_code"] ?? null,
            $params["store_id"] ?? null,
            $params["page"],
            $params["size"]
        );
        $this->success([
            $paginate->items(),
            $paginate->total()
        ]);
    }

    // 获取分润账单
    public function fetchBill()
    {
        $params = (new BaseApiValidate([
            "city_code" => "number",
            "store_id" => "number",
            "page" => "require|number",
            "size" => "require|number"
        ]))->checkBody();
        $paginate = $this->service->fetchBill(
            $this->admin,
            $params["city_code"] ?? null,
            $params["store_id"] ?? null,
            $params["page"],
            $params["size"]
        );
        $this->success([
            $paginate->items(),
            $paginate->total()
        ]);
    }

    public function fetchMassager()
    {
        $params = (new BaseApiValidate([
            "city_code" => "number",
            "store_id" => "number",
            "page" => "require|number",
            "size" => "require|number"
        ]))->checkBody();
        $paginate = $this->service->fetchMassger(
            $this->admin,
            $params["city_code"] ?? null,
            $params["store_id"] ?? null,
            $params["page"],
            $params["size"]
        );
        $this->success([
            $paginate->items(),
            $paginate->total()
        ]);
    }

    public function backlog()
    {
        $this->success($this->service->backlog($this->admin));
    }

    public function fetchCheckComment()
    {
        $this->success($this->service->fetchCheckComment($this->admin));
    }

    public function commentCheck()
    {
        $params = (new BaseApiValidate([
            "id" => "require|number",
            "check" => "require"
        ]))->checkBody();
        if (!in_array($params["check"], ["pass", "reject"]))
            $this->error("处理结果异常 pass|reject");
        $r = $this->service->commentCheck(
            $this->admin,
            $params["id"],
            $params["check"]
        );
        $r->code() ? $this->success($r->data()) : $this->error($r->msg());
    }


    public function fetchCheckMassager()
    {
        $this->success($this->service->fetchCheckMassager($this->admin));
    }

    public function massagerCheck()
    {
        $params = (new BaseApiValidate([
            "id" => "require|number",
            "check" => "require"
        ]))->checkBody();
        if (!in_array($params["check"], ["pass", "reject"]))
            $this->error("处理结果异常 pass|reject");
        $r = $this->service->massagerCheck(
            $this->admin,
            $params["id"],
            $params["check"]
        );
        $r->code() ? $this->success($r->data()) : $this->error($r->msg());
    }

    public function fetchCheckVisa()
    {
        $this->success($this->service->fetchCheckVisa($this->admin));
    }

    public function visaCheck()
    {
        $params = (new BaseApiValidate([
            "id" => "require|number",
            "check" => "require"
        ]))->checkBody();
        if (!in_array($params["check"], ["pass", "reject"]))
            $this->error("处理结果异常 pass|reject");
        $r = $this->service->visaCheck(
            $this->admin,
            $params["id"],
            $params["check"]
        );
        $r->code() ? $this->success($r->data()) : $this->error($r->msg());
    }

    public function fetchCheckClosing()
    {
        $this->success($this->service->fetchCheckClosing($this->admin));
    }

    public function closingCheck()
    {
        $params = (new BaseApiValidate([
            "id" => "require|number",
            "check" => "require"
        ]))->checkBody();
        if (!in_array($params["check"], ["pass", "reject"]))
            $this->error("处理结果异常 pass|reject");
        $r = $this->service->closingCheck(
            $this->admin,
            $params["id"],
            $params["check"]
        );
        $r->code() ? $this->success($r->data()) : $this->error($r->msg());
    }


    // 球房列表
    public function fetchStore()
    {
        $params = (new BaseApiValidate([
            "page" => "require|number",
            "size" => "require|number"
        ]))->checkBody();
        $this->success($this->service->fetchStore(
            $this->admin,
            $params["page"],
            $params["size"]
        ));
    }

    // 发起提现
    public function deposit()
    {
        $params = (new BaseApiValidate([
            'platform' => 'require',
            'amount' => 'require|between:1,100000',
        ]))->checkBody();
        if (!in_array($params["platform"], [\E_ORDER_PAY_TYPE::Wechat, \E_ORDER_PAY_TYPE::ALi, \E_ORDER_PAY_TYPE::Bank]))
            $this->error("platform error");

        $r = $this->service->deposit(
            $this->admin,
            $params["platform"],
            fixed2Float($params["amount"])
        );
        $r->code() ? $this->success($r->data(), $r->msg()) : $this->error($r->msg());
    }


    public function feedback()
    {
        $params = (new BaseApiValidate([
            "reason" => "require",
            "mobile" => "require",
            "content" => "require"
        ]))->checkBody();
        (new Feedback())->save([
            "agency_id" => $this->admin["id"],
            "user_id" => null,
            "images" => isset($params["images"]) ? $params["images"] : null,
            "type" => "feedback",
            "reason" => $params["reason"],
            "mobile" => $params["mobile"],
            "content" => $params["content"],
            "status" => \E_MASSAGER_STATUS::Default,
            "createtime" => time(),
            "updatetime" => time()
        ]);
        $this->success();
    }

    public function findAgency()
    {
        $agency = (new Admin())->where("id", $this->admin["id"])->find();
        $agency ? $this->success($agency) : $this->error("代理商不存在!");
    }

    public function fetchSystemMessage()
    {
        $params = (new BaseApiValidate([
            'page' => 'require|number',
            'size' => 'require|number',
        ]))->checkBody();
        $this->success($this->service->fetchSystemMessage($this->admin["id"], $params["page"], $params["size"]));
    }

    public function updateBankInfo()
    {
        $params = (new BaseApiValidate([
            "opening_bank_name" => 'require',
            "bank_real_name" => 'require',
            "bank_no" => 'require'
        ]))->checkBody();
        $this->success($this->service->updateBankInfo($this->admin, $params["opening_bank_name"], $params["bank_real_name"], $params["bank_no"]));
    }

    public function getAgency()
    {
        $params = (new BaseApiValidate([
            "agency_id" => "require|number"
        ]))->checkBody();
        $this->success((new Admin())->get($params["agency_id"]));
    }
}