新增修改用户名、用户头像接口

2023-03-04 10:04:13 +08:00
parent 76cbcff76a
commit efd4718255
4 changed files with 187 additions and 4 deletions
@@ -4,11 +4,12 @@ namespace App\Services;

 use App\Constants\HttpEnumCode;
 use App\Model\SubTemplate;
-use App\Model\SubUser;
+use App\Model\User;
 use App\Model\User as UserModel;
 use App\Model\UserDoctor;
 use App\Model\UserDoctorInfo;
 use App\Model\UserPatient;
+use App\Utils\PcreMatch;
 use Extend\Wechat\Wechat;
 use Hyperf\Amqp\Result;
 use Hyperf\DbConnection\Db;
@@ -68,6 +69,140 @@ class UserService extends BaseService
        return success();
    }

+    /**
+     * 修改用户头像
+     * @return array
+     */
+    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();
+        }
+
+        // 匹配去除oss网址
+        $avatar = PcreMatch::pregRemoveOssWebsite($avatar);
+
+        // 获取对应用户信息
+        if ($user['user_type'] == 1){
+            // 患者
+            $params = array();
+            $params['user_id'] = $user_info['user_id'];
+            $user_patient = UserPatient::getOne($params);
+            if (empty($user_patient)){
+                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)){
+                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)){
+                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);
+            }
+        }
+
+        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();
+    }
+
    /**
     * 通过user_id获取用户openid
     * @param string|int $user_id