626 lines
20 KiB
PHP
626 lines
20 KiB
PHP
<?php
|
|
|
|
namespace App\Services;
|
|
|
|
use App\Constants\HttpEnumCode;
|
|
use App\Model\Popup;
|
|
use App\Model\SubTemplate;
|
|
use App\Model\User;
|
|
use App\Model\User as UserModel;
|
|
use App\Model\UserDoctor;
|
|
use App\Model\UserDoctorInfo;
|
|
use App\Model\UserPatient;
|
|
use App\Model\UserShipAddress;
|
|
use App\Utils\Mask;
|
|
use App\Utils\PcreMatch;
|
|
use Extend\TencentIm\Profile;
|
|
use Extend\Wechat\Wechat;
|
|
use GuzzleHttp\Exception\GuzzleException;
|
|
use Hyperf\Amqp\Result;
|
|
use Hyperf\DbConnection\Db;
|
|
use Hyperf\Redis\Redis;
|
|
use Hyperf\Utils\WaitGroup;
|
|
use Psr\Container\ContainerExceptionInterface;
|
|
use Psr\Container\NotFoundExceptionInterface;
|
|
use Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface;
|
|
use Symfony\Contracts\HttpClient\Exception\DecodingExceptionInterface;
|
|
use Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface;
|
|
use Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface;
|
|
use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
|
|
|
|
class UserService extends BaseService
|
|
{
|
|
/**
|
|
* 添加订阅消息
|
|
* @return array
|
|
* @throws ContainerExceptionInterface
|
|
* @throws NotFoundExceptionInterface
|
|
* @throws ClientExceptionInterface
|
|
* @throws DecodingExceptionInterface
|
|
* @throws RedirectionExceptionInterface
|
|
* @throws ServerExceptionInterface
|
|
* @throws TransportExceptionInterface
|
|
*/
|
|
public function addSubMessage(): array
|
|
{
|
|
// 下载消息模版
|
|
$weChat = new Wechat(1);
|
|
$result = $weChat->getTemplate();
|
|
if (empty($result)) {
|
|
Db::rollBack();
|
|
return fail();
|
|
}
|
|
|
|
$template = json_decode($result, true);
|
|
|
|
foreach ($template['data'] as $item) {
|
|
$params = array();
|
|
$params['wx_template_id'] = $item['priTmplId'];
|
|
$sub_template = SubTemplate::getOne($params);
|
|
if (empty($sub_template)) {
|
|
// 新增模版
|
|
$data = array();
|
|
$data['client_type'] = 1;
|
|
$data['wx_template_id'] = $item['priTmplId'];
|
|
$data['template_title'] = $item['title'];
|
|
$data['template_type'] = $item['type'];
|
|
$data['template_content'] = $item['content'];
|
|
$sub_template = SubTemplate::addSubTemplate($data);
|
|
if (empty($sub_template)) {
|
|
Db::rollBack();
|
|
return fail();
|
|
}
|
|
}
|
|
}
|
|
|
|
return success();
|
|
}
|
|
|
|
/**
|
|
* 修改用户头像
|
|
* @return array
|
|
* @throws GuzzleException
|
|
*/
|
|
public function putUserAvatar(): array
|
|
{
|
|
$user_info = $this->request->getAttribute("userInfo") ?? [];
|
|
|
|
$avatar = $this->request->input('avatar');
|
|
|
|
// 获取用户信息
|
|
$params = array();
|
|
$params['user_id'] = $user_info['user_id'];
|
|
$user = User::getOne($params);
|
|
if (empty($user)) {
|
|
return fail();
|
|
}
|
|
|
|
if ($avatar == $user['avatar']){
|
|
return success();
|
|
}
|
|
|
|
// 匹配去除oss网址
|
|
$avatar = PcreMatch::pregRemoveOssWebsite($avatar);
|
|
|
|
Db::beginTransaction();
|
|
try {
|
|
// 修改用户表
|
|
$data = array();
|
|
$data['avatar'] = $avatar;
|
|
|
|
$params = array();
|
|
$params['user_id'] = $user_info['user_id'];
|
|
User::editUser($params, $data);
|
|
|
|
// 获取对应用户信息
|
|
if ($user['user_type'] == 1) {
|
|
// 患者
|
|
$params = array();
|
|
$params['user_id'] = $user_info['user_id'];
|
|
$user_patient = UserPatient::getOne($params);
|
|
if (empty($user_patient)) {
|
|
Db::rollBack();
|
|
return fail();
|
|
}
|
|
|
|
if ($user_patient['avatar'] != $avatar) {
|
|
$data = array();
|
|
$data['avatar'] = $avatar;
|
|
|
|
$params = array();
|
|
$params['patient_id'] = $user_patient['patient_id'];
|
|
UserPatient::editUserPatient($params, $data);
|
|
}
|
|
} elseif ($user['user_type'] == 2) {
|
|
// 医生
|
|
$params = array();
|
|
$params['user_id'] = $user_info['user_id'];
|
|
$user_doctor = UserDoctor::getOne($params);
|
|
if (empty($user_doctor)) {
|
|
Db::rollBack();
|
|
return fail();
|
|
}
|
|
|
|
if ($user_doctor['avatar'] != $avatar) {
|
|
$data = array();
|
|
$data['avatar'] = $avatar;
|
|
|
|
$params = array();
|
|
$params['doctor_id'] = $user_doctor['doctor_id'];
|
|
UserDoctor::editUserDoctor($params, $data);
|
|
}
|
|
} elseif ($user['user_type'] == 3) {
|
|
// 药师
|
|
$params = array();
|
|
$params['user_id'] = $user_info['user_id'];
|
|
$user_pharmacist = UserPatient::getOne($params);
|
|
if (empty($user_pharmacist)) {
|
|
Db::rollBack();
|
|
return fail();
|
|
}
|
|
|
|
if ($user_pharmacist['avatar'] != $avatar) {
|
|
$data = array();
|
|
$data['avatar'] = $avatar;
|
|
|
|
$params = array();
|
|
$params['pharmacist_id'] = $user_pharmacist['pharmacist_id'];
|
|
UserPatient::editUserPatient($params, $data);
|
|
}
|
|
}
|
|
|
|
// 修改im头像
|
|
$profile = new Profile();
|
|
$arg = array();
|
|
$arg['Tag_Profile_IM_Image'] = addAliyunOssWebsite($avatar);
|
|
$profile->setProfile($user_info['user_id'], $arg);
|
|
|
|
Db::commit();
|
|
} catch (\Exception $e) {
|
|
Db::rollBack();
|
|
return fail(HttpEnumCode::HTTP_ERROR, $e->getMessage());
|
|
}
|
|
|
|
return success();
|
|
}
|
|
|
|
/**
|
|
* 修改用户名
|
|
* @return array
|
|
*/
|
|
public function putUserName(): array
|
|
{
|
|
$user_info = $this->request->getAttribute("userInfo") ?? [];
|
|
|
|
$user_name = $this->request->input('user_name');
|
|
|
|
// 获取用户信息
|
|
$params = array();
|
|
$params['user_id'] = $user_info['user_id'];
|
|
$user = User::getOne($params);
|
|
if (empty($user)) {
|
|
return fail();
|
|
}
|
|
|
|
if ($user['user_type'] != 1) {
|
|
return fail(HttpEnumCode::HTTP_ERROR, "禁止修改");
|
|
}
|
|
|
|
if ($user['user_name'] == $user_name) {
|
|
return success();
|
|
}
|
|
|
|
Db::beginTransaction();
|
|
try {
|
|
// 修改用户表
|
|
$data = array();
|
|
$data['user_name'] = $user_name;
|
|
|
|
$params = array();
|
|
$params['user_id'] = $user['user_id'];
|
|
User::editUser($params, $data);
|
|
|
|
// 修改对应用户表
|
|
if ($user['user_type'] == 1) {
|
|
// 患者
|
|
$data = array();
|
|
$data['user_name'] = $user_name;
|
|
|
|
$params = array();
|
|
$params['user_id'] = $user['user_id'];
|
|
UserPatient::editUserPatient($params, $data);
|
|
}
|
|
|
|
Db::commit();
|
|
} catch (\Exception $e) {
|
|
Db::rollBack();
|
|
return fail(HttpEnumCode::SERVER_ERROR, $e->getMessage());
|
|
}
|
|
|
|
return success();
|
|
}
|
|
|
|
/**
|
|
* 退出登陆
|
|
* @return array
|
|
* @throws ContainerExceptionInterface
|
|
* @throws NotFoundExceptionInterface
|
|
*/
|
|
public function putLoginout(): array
|
|
{
|
|
$user_info = $this->request->getAttribute("userInfo") ?? [];
|
|
|
|
// 获取用户信息
|
|
$params = array();
|
|
$params['user_id'] = $user_info['user_id'];
|
|
$user = User::getOne($params);
|
|
if (empty($user)) {
|
|
return fail();
|
|
}
|
|
|
|
// 获取token
|
|
$bearer_token = $this->request->getHeader('Authorization');
|
|
if (empty($bearer_token)) {
|
|
return fail();
|
|
}
|
|
|
|
$token = explode(' ', $bearer_token[0]);
|
|
if (!isset($token[1])) {
|
|
return fail();
|
|
}
|
|
|
|
$redis = $this->container->get(Redis::class);
|
|
|
|
// 旧token加入黑名单 5天有效期，5天内，无法继续进行访问
|
|
$res = $redis->set('jwt_black_' . $token[1], time(), 60 * 60 * 24 * 5);
|
|
if (!$res) {
|
|
return fail(HttpEnumCode::SERVER_ERROR);
|
|
}
|
|
|
|
return success();
|
|
}
|
|
|
|
/**
|
|
* 获取用户收获地址列表
|
|
* @return array
|
|
*/
|
|
public function getUserAddress(): array
|
|
{
|
|
$user_info = $this->request->getAttribute("userInfo") ?? [];
|
|
|
|
$params = array();
|
|
$params['user_id'] = $user_info['user_id'];
|
|
$user_ship_address = UserShipAddress::getList($params);
|
|
if (empty($user_ship_address)) {
|
|
return success();
|
|
}
|
|
|
|
return success($user_ship_address->toArray());
|
|
}
|
|
|
|
/**
|
|
* 获取用户收获地址详情
|
|
* @return array
|
|
*/
|
|
public function getUserAddressInfo(): array
|
|
{
|
|
$user_info = $this->request->getAttribute("userInfo") ?? [];
|
|
|
|
$address_id = $this->request->route('address_id');
|
|
|
|
$params = array();
|
|
$params['address_id'] = $address_id;
|
|
$params['user_id'] = $user_info['user_id'];
|
|
$user_ship_address = UserShipAddress::getOne($params);
|
|
if (empty($user_ship_address)) {
|
|
return fail();
|
|
}
|
|
|
|
return success($user_ship_address->toArray());
|
|
}
|
|
|
|
/**
|
|
* 添加用户收获地址
|
|
* @return array
|
|
*/
|
|
public function addUserAddress(): array
|
|
{
|
|
$user_info = $this->request->getAttribute("userInfo") ?? [];
|
|
|
|
$request_params = $this->request->all();
|
|
|
|
$areaService = new AreaService();
|
|
$req = $areaService->checkAreaById($request_params['province_id'], $request_params['city_id'], $request_params['county_id']);
|
|
if (empty($req)) {
|
|
return fail(HttpEnumCode::HTTP_ERROR, "地区选择错误");
|
|
}
|
|
|
|
$area = $areaService->getAreaById($request_params['province_id'], $request_params['city_id'], $request_params['county_id']);
|
|
|
|
Db::beginTransaction();
|
|
|
|
try {
|
|
if ($request_params['is_default'] == 1) {
|
|
// 获取默认地址
|
|
$params = array();
|
|
$params['user_id'] = $user_info['user_id'];
|
|
$params['is_default'] = $request_params['is_default'];
|
|
$user_ship_address = UserShipAddress::getOne($params);
|
|
if (!empty($user_ship_address)) {
|
|
$data = array();
|
|
$data['is_default'] = 0;
|
|
|
|
$params = array();
|
|
$params['address_id'] = $user_ship_address['address_id'];
|
|
$params['user_id'] = $user_info['user_id'];
|
|
UserShipAddress::edit($params, $data);
|
|
}
|
|
}
|
|
|
|
// 新增
|
|
$data = array();
|
|
$data['user_id'] = $user_info['user_id'];
|
|
$data['province_id'] = $request_params['province_id'];
|
|
$data['province'] = $area['province']['area_name'];
|
|
$data['city_id'] = $request_params['city_id'];
|
|
$data['city'] = $area['city']['area_name'];
|
|
$data['county_id'] = $request_params['county_id'];
|
|
$data['county'] = $area['county']['area_name'];
|
|
$data['address'] = $request_params['address'];
|
|
$data['address_mask'] = Mask::maskAddressStr($request_params['address']);
|
|
$data['consignee_name'] = $request_params['consignee_name'];
|
|
$data['consignee_name_mask'] = Mask::maskNameStr($request_params['consignee_name']);
|
|
$data['consignee_tel'] = $request_params['consignee_tel'];
|
|
$data['consignee_tel_mask'] = Mask::maskPhoneStr($request_params['consignee_tel']);
|
|
$data['is_default'] = $request_params['is_default'];
|
|
$data['tag'] = $request_params['tag'] ?? 4;
|
|
$user_ship_address = UserShipAddress::addUserShipAddress($data);
|
|
if (empty($user_ship_address)) {
|
|
Db::rollBack();
|
|
return fail(HttpEnumCode::SERVER_ERROR);
|
|
}
|
|
|
|
$user_ship_address = $user_ship_address->toArray();
|
|
$user_ship_address['address_id'] = (string)$user_ship_address['address_id'];
|
|
Db::commit();
|
|
} catch (\Exception $e) {
|
|
Db::rollBack();
|
|
return fail(HttpEnumCode::HTTP_ERROR, $e->getMessage());
|
|
}
|
|
|
|
return success($user_ship_address);
|
|
}
|
|
|
|
/**
|
|
* 修改用户收获地址
|
|
* @return array
|
|
*/
|
|
public function putUserAddress(): array
|
|
{
|
|
$user_info = $this->request->getAttribute("userInfo") ?? [];
|
|
|
|
$request_params = $this->request->all();
|
|
$address_id = $this->request->route('address_id');
|
|
|
|
$params = array();
|
|
$params['address_id'] = $address_id;
|
|
$params['user_id'] = $user_info['user_id'];
|
|
$user_ship_address = UserShipAddress::getOne($params);
|
|
if (empty($user_ship_address)) {
|
|
return fail();
|
|
}
|
|
|
|
$data = array();
|
|
|
|
if ($user_ship_address['province_id'] != $request_params['province_id'] || $user_ship_address['city_id'] != $request_params['city_id'] || $user_ship_address['county_id'] != $request_params['county_id']) {
|
|
$areaService = new AreaService();
|
|
$req = $areaService->checkAreaById($request_params['province_id'], $request_params['city_id'], $request_params['county_id']);
|
|
if (empty($req)) {
|
|
return fail(HttpEnumCode::HTTP_ERROR, "地区选择错误");
|
|
}
|
|
|
|
$area = $areaService->getAreaById($request_params['province_id'], $request_params['city_id'], $request_params['county_id']);
|
|
|
|
$data['province_id'] = $request_params['province_id'];
|
|
$data['province'] = $area['province']['area_name'];
|
|
$data['city_id'] = $request_params['city_id'];
|
|
$data['city'] = $area['city']['area_name'];
|
|
$data['county_id'] = $request_params['county_id'];
|
|
$data['county'] = $area['county']['area_name'];
|
|
}
|
|
|
|
if ($user_ship_address['address'] != $request_params['address']) {
|
|
$data['address'] = $request_params['address'];
|
|
$data['address_mask'] = Mask::maskAddressStr($request_params['address']);
|
|
}
|
|
|
|
if ($user_ship_address['consignee_name'] != $request_params['consignee_name']) {
|
|
$data['consignee_name'] = $request_params['consignee_name'];
|
|
$data['consignee_name_mask'] = Mask::maskNameStr($request_params['consignee_name']);
|
|
}
|
|
|
|
if ($user_ship_address['consignee_tel'] != $request_params['consignee_tel']) {
|
|
$data['consignee_tel'] = $request_params['consignee_tel'];
|
|
$data['consignee_tel_mask'] = Mask::maskPhoneStr($request_params['consignee_tel']);
|
|
}
|
|
|
|
if (isset($request_params['tag'])){
|
|
if ($user_ship_address['tag'] != $request_params['tag']) {
|
|
$data['tag'] = $request_params['tag'];
|
|
}
|
|
}
|
|
|
|
if ($user_ship_address['is_default'] != $request_params['is_default']) {
|
|
$data['is_default'] = $request_params['is_default'];
|
|
}
|
|
|
|
Db::beginTransaction();
|
|
try {
|
|
if ($request_params['is_default'] == 1 && $user_ship_address['is_default'] != $request_params['is_default']) {
|
|
// 获取默认地址
|
|
$params = array();
|
|
$params['user_id'] = $user_info['user_id'];
|
|
$params['is_default'] = $request_params['is_default'];
|
|
$default_user_ship_address = UserShipAddress::getOne($params);
|
|
if (!empty($default_user_ship_address)) {
|
|
$default_data = array();
|
|
$default_data['is_default'] = 0;
|
|
|
|
$params = array();
|
|
$params['address_id'] = $default_user_ship_address['address_id'];
|
|
$params['user_id'] = $user_info['user_id'];
|
|
UserShipAddress::edit($params, $default_data);
|
|
}
|
|
}
|
|
|
|
if (!empty($data)) {
|
|
$params = array();
|
|
$params['address_id'] = $user_ship_address['address_id'];
|
|
UserShipAddress::edit($params, $data);
|
|
}
|
|
|
|
Db::commit();
|
|
} catch (\Exception $e) {
|
|
Db::rollBack();
|
|
return fail(HttpEnumCode::HTTP_ERROR, $e->getMessage());
|
|
}
|
|
|
|
return success();
|
|
}
|
|
|
|
/**
|
|
* 删除用户收获地址
|
|
* @return array
|
|
*/
|
|
public function deleteUserAddress(): array
|
|
{
|
|
$user_info = $this->request->getAttribute("userInfo") ?? [];
|
|
|
|
$address_id = $this->request->route('address_id');
|
|
|
|
$params = array();
|
|
$params['address_id'] = $address_id;
|
|
$params['user_id'] = $user_info['user_id'];
|
|
$user_ship_address = UserShipAddress::getOne($params);
|
|
if (empty($user_ship_address)) {
|
|
return fail();
|
|
}
|
|
|
|
$res = UserShipAddress::deleteUserShipAddress($params);
|
|
if (!$res){
|
|
return fail(HttpEnumCode::SERVER_ERROR);
|
|
}
|
|
|
|
return success();
|
|
}
|
|
|
|
/**
|
|
* 获取弹窗数据
|
|
* @return array
|
|
*/
|
|
public function getUserPopup(): array
|
|
{
|
|
$user_info = $this->request->getAttribute("userInfo") ?? [];
|
|
|
|
$popup_type = $this->request->input('popup_type');
|
|
|
|
if (empty($user_info)){
|
|
// 未登陆
|
|
return success();
|
|
}
|
|
|
|
$params = array();
|
|
$params['user_id'] = $user_info['user_id'];
|
|
$params['popup_type'] = $popup_type;
|
|
$popup = Popup::getList($params);
|
|
if (empty($popup)){
|
|
return success();
|
|
}
|
|
|
|
foreach ($popup as $key => $item){
|
|
$popup[$key]['popup_content'] = json_decode($item['popup_content']);
|
|
}
|
|
|
|
return success($popup->toArray());
|
|
}
|
|
|
|
/**
|
|
* 通过user_id获取用户openid
|
|
* @param string|int $user_id
|
|
* @param int $user_type
|
|
* @return string
|
|
*/
|
|
public function getOpenIdWithUserId(string|int $user_id, int|string $user_type): string
|
|
{
|
|
$open_id = '';
|
|
if ($user_type == 1) {
|
|
// 患者
|
|
$params = array();
|
|
$params['user_id'] = $user_id;
|
|
$user_patient = UserPatient::getOne($params);
|
|
if (empty($user_patient)) {
|
|
return "";
|
|
}
|
|
|
|
if (empty($user_patient['open_id'])) {
|
|
return "";
|
|
}
|
|
|
|
$open_id = $user_patient['open_id'];
|
|
} elseif ($user_type == 2) {
|
|
// 医生
|
|
$params = array();
|
|
$params['user_id'] = $user_id;
|
|
$user_doctor = UserDoctor::getOne($params);
|
|
if (empty($user_doctor)) {
|
|
return "";
|
|
}
|
|
|
|
if (empty($user_doctor['open_id'])) {
|
|
return "";
|
|
}
|
|
|
|
$open_id = $user_doctor['open_id'];
|
|
} elseif ($user_type == 3) {
|
|
// 药师
|
|
$params = array();
|
|
$params['user_id'] = $user_id;
|
|
$user_pharmacist = UserPatient::getOne($params);
|
|
if (empty($user_pharmacist)) {
|
|
return "";
|
|
}
|
|
|
|
if (empty($user_pharmacist['open_id'])) {
|
|
return "";
|
|
}
|
|
|
|
$open_id = $user_pharmacist['open_id'];
|
|
}
|
|
|
|
return $open_id;
|
|
}
|
|
|
|
/**
|
|
* 获取用户默认头像oss地址
|
|
* @param int|string $user_type
|
|
* @return string
|
|
*/
|
|
public function getUserDefaultOssAvatar(int|string $user_type): string
|
|
{
|
|
$avatar = "";
|
|
if (empty($user_type)){
|
|
return $avatar;
|
|
}
|
|
|
|
if ($user_type == 1){
|
|
// 患者
|
|
$avatar = "/basic/file/patient_avatar.png";
|
|
}elseif ($user_type == 2){
|
|
// 医生
|
|
$avatar = "/basic/file/doctor_avatar.png";
|
|
}
|
|
|
|
return $avatar;
|
|
}
|
|
|
|
} |