$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, '服务器繁忙!商户认证申请提交失败!'); } } }