coupon-admin/app/controller/api/Business.php

<?php
namespace app\controller\api;

use app\exception\RepositoryException;
use app\repository\AccountRepository;
use app\repository\BusinessRepository;
use app\repository\DictionaryRepository;
use app\validate\BusinessValidate;
use think\exception\ValidateException;
use app\model\{
    Business as BusinessModel,
    Account as AccountModel
};
use think\response\Json;

/**
 * 商家端：商家
 *
 * Class Business
 * @package app\controller\api
 */
class Business extends Base
{
    /**
     * 商家认证注册
     *
     * 重新编辑注册则覆盖之前的审核信息，并重新进行审核
     */
    public function registerBusiness()
    {
        $params = [
            'type'=> $this->request->param('type/d', 0),
            'business_name'=> $this->request->param('business_name', ''),
            'business_subtitle'=> $this->request->param('business_subtitle', ''),
            'business_license'=> $this->request->param('business_license', ''),
            'contact_name'=> $this->request->param('contact_name', ''),
            'contact_phone'=> $this->request->param('contact_phone', ''),
            'lat'=> $this->request->param('lat', ''),
            'lng'=> $this->request->param('lng', ''),
            'province'=> $this->request->param('province', ''),
            'city'=> $this->request->param('city', ''),
            'county'=> $this->request->param('county', ''),
            'business_address' => $this->request->param('business_address', ''),
            'business_circle_id' => $this->request->param('business_circle_id/d', 0),
            'agency_code'   => $this->request->param('agency_code', ''),
        ];

        $accountId  = $this->request->user['user_id'] ?? 0;


        try {
            $validate   = new BusinessValidate();
            $busRepo    = BusinessRepository::getInstance();
            $dicRepo    = DictionaryRepository::getInstance();
            $accountRepo    = AccountRepository::getInstance();

            $account = $accountRepo->findById($accountId);
            if (empty($account)) {
                throw new ValidateException('无效请求！');
            }

            if (!$validate->scene('apiRegister')->check($params)) {
                throw new ValidateException($validate->getError());
            }

            $businessCategory   = $dicRepo->findBusinessTypeById($params['type']);
            if (empty($businessCategory)) {
                throw new ValidateException('请选择正确的商家分类信息！');
            }

            if ($params['business_circle_id'] > 0) {
                $businessCircle = $dicRepo->findBusinessCircleById($params['business_circle_id']);
                if (empty($businessCircle)) {
                    throw new ValidateException('请选择正确的商圈信息！');
                }
                $params['business_circle']  = $businessCircle['name'];
            }

            if (!empty($params['agency_code'])) {
                $agencyBusiness = $busRepo->findOneByWhere(['code'=> $params['agency_code'], 'is_agency'=> self::BOOL_TRUE, 'state' => BusinessModel::state_on]);
                if (empty($agencyBusiness) || $agencyBusiness['is_delete'] == self::BOOL_TRUE) {
                    throw new ValidateException('没有相关的代理商记录！');
                } elseif ($agencyBusiness['enable'] == self::BOOL_TRUE) {
                    throw new ValidateException('该代理商已被封禁！');
                }
            }

            $business = null;
            if (isset($account['business_code']) && !empty($account['business_code'])) {
                $business = $busRepo->findOneByWhere(['code'=> $account['business_code']]);
            }

            $params['create_time']   = date('Y-m-d H:i:s');
            $params['is_delete']    = 0;
            $params['state']        = BusinessModel::state_reviewing;
            $params['enable']       = 0;
            $params['type_name']    = $businessCategory['name'];

            if ($business) {
                if ($business['state'] == BusinessModel::state_reviewing) {
                    throw new ValidateException('商户认证审批中，请勿重复提交！');
                }

                // 更新审批信息，重新审批
                $params['update_time']  = date('Y-m-d H:i:s');
                $business = $business->save($params);

            } else {
                // 添加审批记录
                $businessCode   = createUuid();
                $params['code'] = $businessCode;
                $business = $busRepo->create($params);
                if (!$business) {
                    throw new RepositoryException('服务器繁忙！商户认证申请提交失败！');
                }

                $account->save(['business_code' => $businessCode]);
            }

            $result = $busRepo->formatFrontBusinessInfo($business->toArray());
            return $this->json(0, 'success', $result);
        } catch (ValidateException $e) {
            return $this->json(4001, $e->getError());
        } catch (RepositoryException | \Exception $e) {
            return $this->json(5001, '服务器繁忙！商户认证申请提交失败！');
        }
    }

    /**
     * 获取当前账号所属商家的信息
     * 适用范围：商户账号 或 商户员工账号
     */
    public function getMyBusinessInfo()
    {
        $accountId = $this->request->user['user_id'] ?? 0;

        try {
            $account    = AccountRepository::getInstance()->findById($accountId, [], function ($q) {
                return $q->with(['business', 'parent']);
            });
            if (empty($account)) {
                return $this->json(4004, '无效请求！');
            }

            $result = [];
            if ($account['type'] == AccountModel::type_staff) {
                // 员工账号
                $businessCode   = $account['parent']['business_code'] ?? '';
                if (!empty($businessCode)) {
                    $business = BusinessRepository::getInstance()->findOneByWhere(['code' => $businessCode]);
                    if ($business) {
                        $result = $business->toArray();
                    }
                }

                $result = arrayKeysExcludeFilter($result, ['pay_account', 'total_recharge']);

            } elseif(!empty($account['business'])) {
                // 商户认证信息
                $result     = $account['business']->toArray();
            }

            if (count($result)) {
                $result     = DictionaryRepository::getInstance()->parseAreaText($result);
            }

            $result = arrayKeysExcludeFilter($result, ['update_time']);
            return $this->json(0, 'success', $result);
        } catch (\Exception $e) {
            return $this->json(5001, '商家信息查询失败！');
        }
    }

    /**
     * 获取商家信息(已认证通过的商户)
     * @return Json
     */
    public function getBusinessInfo()
    {
        $businessCode   = $this->request->param('businessCode/s', '');

        $busRepo        = BusinessRepository::getInstance();
        try {
            $business   = $busRepo->findOneByWhere(['code' => $businessCode, 'state' => BusinessModel::state_on]);
            if (empty($business)) {
                return $this->json(4004, '没有相关的商户！');
            }

            $list       = $business->toArray();
            $list       = DictionaryRepository::getInstance()->parseAreaText($list);
            $disableFields = ['is_delete', 'update_time', 'total_recharge', 'balance', 'is_assign', 'agency_code',
                'reason', 'pay_account', 'business_license'
            ];
            $result     = arrayKeysExcludeFilter($list, $disableFields);
            return $this->json(0, 'success', $result);
        } catch (\Exception $e) {
            return $this->json(5004, '商家信息查询失败！');
        }
    }

}