279 lines
11 KiB
PHP
279 lines
11 KiB
PHP
<?php
|
|
namespace app\controller\api;
|
|
|
|
use app\exception\RepositoryException;
|
|
use app\model\BusinessCircle;
|
|
use app\model\Category;
|
|
use app\repository\AccountRepository;
|
|
use app\repository\BusinessRepository;
|
|
use app\repository\CouponRepository;
|
|
use app\repository\DictionaryRepository;
|
|
use app\validate\BusinessValidate;
|
|
use think\Collection;
|
|
use think\exception\ValidateException;
|
|
use app\model\{Business as BusinessModel, Account as AccountModel, CouponMain};
|
|
use think\response\Json;
|
|
|
|
/**
|
|
* 商家端：商家
|
|
*
|
|
* Class Business
|
|
* @package app\controller\api
|
|
*/
|
|
class Business extends Base
|
|
{
|
|
|
|
protected $noNeedLogin = [
|
|
'couponDetail',
|
|
];
|
|
/**
|
|
* 商家认证注册
|
|
*
|
|
* 重新编辑注册则覆盖之前的审核信息，并重新进行审核
|
|
*/
|
|
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, '商家信息查询失败！');
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 获取商家类型
|
|
* */
|
|
public function getBusinessTypeList()
|
|
{
|
|
$data = Category::getList();
|
|
return $this->json(1,"ok",$data);
|
|
}
|
|
/**
|
|
* 获取商家类型
|
|
* */
|
|
public function getBusinessCircle()
|
|
{
|
|
$data = BusinessCircle::getList();
|
|
return $this->json(1,"ok",$data);
|
|
}
|
|
|
|
/**
|
|
* 商家优惠券详情
|
|
* */
|
|
public function couponDetail()
|
|
{
|
|
$accountId = $this->request->user['user_id'] ?? 0;
|
|
$account = AccountRepository::getInstance()->findById($accountId, [], function ($q) {
|
|
return $q->with(['business', 'parent']);
|
|
});
|
|
|
|
$couponMainId = input("id/d");
|
|
$couponMain = CouponMain::findOne(["id"=>$couponMainId]);
|
|
if(empty($couponMain)){
|
|
return $this->json(4001,"优惠券不存在");
|
|
}
|
|
if(!$business = BusinessRepository::getInstance()->findOneByWhere(["code"=>$couponMain["business_code"]])){
|
|
return $this->json(4001,"优惠券商家信息不存在");
|
|
}
|
|
|
|
$list = $business->toArray();
|
|
$list = DictionaryRepository::getInstance()->parseAreaText($list);
|
|
|
|
$data = [];
|
|
|
|
$data["businessAddress"] = $list['province_text'] . $list['city_text'] . $list['county_text'] . $business['business_address'];
|
|
$data["businessName"] = $list['business_name'];
|
|
$data["count"] = $couponMain->count;
|
|
$data["couponName"] = $couponMain->name;
|
|
$data["deductionMoney"] = $couponMain->deduction_money;
|
|
$data["startTime"] = $couponMain->start_time;
|
|
$data["endTime"] = $couponMain->end_time;
|
|
$data["id"] = $couponMain->id;
|
|
$data["imageUrl"] = $this->request->domain(). $couponMain->image_url;
|
|
$data["intro"] = $couponMain->intro;//简介
|
|
$data["lat"] = $couponMain->lat;
|
|
$data["lng"] = $couponMain->lng;
|
|
$data["money"] = $couponMain->money;
|
|
$data["usingRule"] = DictionaryRepository::getInstance()->getUsingRuleByCouponMainId($couponMain->id);
|
|
$data["punishRule"] = '';//处罚规则 已取消
|
|
|
|
//未登录可以领取 0可领取 1已领取
|
|
if (empty($account)) {
|
|
$data["receiveStatus"] = CouponMain::COMMON_OFF;//领取状态
|
|
}else{
|
|
$data["receiveStatus"] = AccountRepository::getInstance()->getCouponReceiveStatus($account->user_code,$couponMain);//领取状态
|
|
}
|
|
$data["receivedCount"] = $couponMain->received_count;//已领取数量
|
|
$data["typeName"] = $couponMain->type_name;
|
|
|
|
return $this->json(0,"success",$data);
|
|
}
|
|
|
|
}
|
|
|
|
|