UserService.php 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615
  1. <?php
  2. namespace App\JsonRpc;
  3. use App\Model\Role;
  4. use App\Model\RoleLog;
  5. use App\Model\RoleUser;
  6. use App\Model\User;
  7. use App\Model\UserInfo;
  8. use App\Model\UserLogin;
  9. use App\Model\WebsiteGroup;
  10. use App\Model\Wechat;
  11. use App\Tools\Result;
  12. use Hyperf\DbConnection\Db;
  13. use Hyperf\RpcServer\Annotation\RpcService;
  14. #[RpcService(name: "UserService", protocol: "jsonrpc-http", server: "jsonrpc-http")]
  15. class UserService implements UserServiceInterface
  16. {
  17. /**
  18. * @param string $name
  19. * @param int $gender
  20. * @return string
  21. */
  22. public function createUser(array $data): array
  23. {
  24. Db::beginTransaction();
  25. try {
  26. $dataUserReq = [
  27. 'user_name' => $data['user_name'],
  28. 'password' => md5(md5($data['password']) . $data['salt']),
  29. 'avatar' => $data['avatar'] ?? 'http://183.131.25.186:9501/image/20241212/1733992868958074.png',
  30. 'type_id' => $data['type_id'] ?? '20000',
  31. 'mobile' => $data['mobile'] ?? '', //手机号
  32. 'status' => $data['status'] ?? 1,
  33. 'email' => $data['email'] ?? '',
  34. 'salt' => $data['salt'],
  35. 'admin_id' => isset($data['admin_id']) && $data['admin_id'] != '' ? $data['admin_id'] : 0,
  36. // 'level_id'=>$data['level_id']??0, //会员等级
  37. 'nickname' => $data['nickname'] ?? $data['user_name'], //把账号同步到昵称里面
  38. 'last_login_ip' => $data['last_login_ip'] ?? '',
  39. 'sszq' => $data['sszq'] ?? '',
  40. ];
  41. var_dump("user:", $dataUserReq);
  42. $userid = User::query()->insertGetId($dataUserReq);
  43. $dataUserInfoReq = [
  44. 'user_id' => $userid,
  45. 'id_card' => $data['id_card'] ?? '',
  46. 'gender' => $data['gender'] ?? 0,
  47. 'real_name' => $data['real_name'] ?? '',
  48. 'business_name' => $data['business_name'] ?? '',
  49. 'job' => $data['job'] ?? '',
  50. 'city_id' => $data['city_id'] ?? 0,
  51. 'birthday' => $data['birthday'] ?? '',
  52. 'number' => $data['number'] ?? '',
  53. 'city_arr_id' => $data['city_arr_id'] ?? '',
  54. 'from_time' => $data['from_time'] ?? null,
  55. 'to_time' => $data['to_time'] ?? null,
  56. 'long_time' => $data['long_time'] ?? 0,
  57. 'native_place_id' => $data['native_place_id'] ?? 0,
  58. 'native_place_arr_id' => $data['native_place_arr_id'] ?? '',
  59. 'qq' => $data['qq'] ?? '',
  60. 'zip_code' => $data['zip_code'] ?? '',
  61. 'address_arr_id' => $data['address_arr_id'] ?? '',
  62. 'address_id' => $data['address_id'] ?? 0,
  63. 'address' => $data['address'] ?? '',
  64. 'other' => $data['other'] ?? '',
  65. 'remark' => $data['remark'] ?? '',
  66. 'fax' => $data['fax'] ?? '',
  67. 'position' => $data['position'] ?? '',
  68. 'legal_person_real_name' => $data['legal_person_real_name'] ?? '',
  69. 'legal_person_mobile' => $data['legal_person_mobile'] ?? '',
  70. 'legal_person_id_card' => $data['legal_person_id_card'] ?? '',
  71. 'administrative_unit_arr_id' => $data['administrative_unit_arr_id'] ?? '',
  72. 'administrative_unit_id' => $data['administrative_unit_id'] ?? 0,
  73. // 企业会员 相关 公司信息
  74. 'company_hy_id' => $data['company_hy_id']?? 0,
  75. 'company_size' => $data['company_size']?? 0,
  76. 'company_nature' => $data['company_nature']?? '',
  77. 'introduction' => $data['introduction']?? '',
  78. 'company_url' => $data['company_url']?? '',
  79. ];
  80. var_dump("UserINfo:::", $dataUserInfoReq);
  81. $userInfoId = UserInfo::query()->insertGetId($dataUserInfoReq);
  82. $roleUserData = [
  83. 'role_id' => isset($data['role_id']) && $data['role_id'] != '' ? $data['role_id'] : 0,
  84. 'user_id' => $userid,
  85. 'admin_user_id' => isset($data['admin_id']) && $data['admin_id'] != '' ? $data['admin_id'] : 0,
  86. ];
  87. RoleUser::insert($roleUserData);
  88. var_dump("userInfo:", $userInfoId);
  89. Db::commit();
  90. } catch (\Throwable $ex) {
  91. Db::rollBack();
  92. var_dump($ex->getMessage());
  93. return Result::error("创建失败", 0);
  94. }
  95. return $userInfoId ? Result::success(["id" => $userid]) : Result::error("创建失败", 0);
  96. }
  97. /**
  98. * @return array
  99. */
  100. public function getUserList(array $data): array
  101. {
  102. $where = [];
  103. if (isset($data['keyword']) && $data['keyword']) {
  104. array_push($where, ['user.user_name', 'like', '%' . $data['keyword'] . '%']);
  105. }
  106. if (isset($data['type_id']) && $data['type_id']) {
  107. array_push($where, ['user.type_id', '=', $data['type_id']]);
  108. }
  109. if (isset($data['status']) && $data['status'] != '' && intval($data['status']) >= 0) {
  110. array_push($where, ['user.status', '=', $data['status']]);
  111. }
  112. $result = User::where($where)
  113. ->leftJoin('user_info', 'user.id', '=', 'user_info.user_id')
  114. ->leftJoin("user_info as user_infoA", 'user.admin_id', "user_infoA.user_id")
  115. ->leftJoin("role_user", 'role_user.user_id', "user.id")
  116. ->leftJoin("role", 'role.id', "role_user.role_id")
  117. ->orderBy("user.id", "desc")->paginate(intval($data['pageSize']),
  118. [
  119. 'user.id',
  120. 'user.admin_id',
  121. 'user.user_name',
  122. 'user_info.real_name',
  123. 'user.mobile',
  124. 'user.type_id',
  125. 'user.created_at',
  126. 'user.status',
  127. 'user_infoA.real_name as admin_real_name',
  128. 'role.role_name',
  129. ],
  130. 'page', intval($data['page']));
  131. $count = $result->total();
  132. if (empty($result)) {
  133. return Result::error("没有数据", 0);
  134. }
  135. $rep = $result->items();
  136. //1:个人会员 2:政务会员 3:企业会员 4:调研员 10000:管理员 20000:游客
  137. $type = ['1' => "个人会员", '2' => "政务会员", '3' => "企业会员", '4' => '调研员', '10000' => '管理员', '20000' => '游客'];
  138. if ($rep) {
  139. foreach ($rep as $k => $v) {
  140. $rep[$k]['type_name'] = $type[$v['type_id']];
  141. // $rep[$k]['gender_name'] = $gender[$v['gender']];
  142. // $rep[$k]['status_name'] = $status[$v['status']];
  143. // $rep[$k]['city_id'] = $v['city_id']?json_decode($v['city_id']):[];
  144. }
  145. }
  146. $data = [
  147. 'rows' => $rep,
  148. 'count' => $count,
  149. ];
  150. return Result::success($data);
  151. }
  152. /**
  153. * @param int $id
  154. * @return array
  155. */
  156. public function getUserInfo(int $id): array
  157. {
  158. $userInfo = Db::table('user')
  159. ->leftJoin('user_info', 'user.id', '=', 'user_info.user_id')
  160. ->leftJoin('role_user', 'role_user.user_id', '=', 'user.id')
  161. ->select('user.*',
  162. 'user_info.id as user_info_id',
  163. 'user_info.real_name',
  164. 'user_info.id_card',
  165. 'user_info.birthday',
  166. 'user_info.gender',
  167. 'user_info.city_id',
  168. 'user_info.business_name',
  169. 'user_info.job',
  170. 'user_info.number',
  171. 'user_info.city_arr_id',
  172. 'user_info.from_time',
  173. 'user_info.to_time',
  174. 'user_info.long_time',
  175. 'user_info.native_place_id',
  176. 'user_info.native_place_arr_id',
  177. 'user_info.qq',
  178. 'user_info.zip_code',
  179. 'user_info.address_arr_id',
  180. 'user_info.address_id',
  181. 'user_info.address',
  182. 'user_info.other',
  183. 'user_info.remark',
  184. 'user_info.fax',
  185. 'user_info.position',
  186. 'user_info.legal_person_real_name',
  187. 'user_info.legal_person_mobile',
  188. 'user_info.legal_person_id_card',
  189. 'user_info.administrative_unit_arr_id',
  190. 'user_info.administrative_unit_id',
  191. // 企业会员 相关 公司信息
  192. 'user_info.company_hy_id',
  193. 'user_info.company_size',
  194. 'user_info.company_nature',
  195. 'user_info.introduction',
  196. 'user_info.company_url',
  197. 'role_user.role_id',
  198. )
  199. ->where('user.id', '=', $id)->first();
  200. if (empty($userInfo)) {
  201. return Result::error("找不到用户", 0, []);
  202. }
  203. return Result::success($userInfo);
  204. }
  205. /**
  206. * 检测用户是否存在
  207. * @param array $data
  208. * @return array
  209. */
  210. public function verifyUserInfo(array $data): array
  211. {
  212. var_dump("进不进来");
  213. if (isset($data['id'])) {
  214. $data[] = ['id', "!=", $data['id']];
  215. unset($data['id']);
  216. }
  217. $userInfo = User::query()->where($data)->first();
  218. if (empty($userInfo)) {
  219. return Result::error("找不到用户", 0);
  220. }
  221. return Result::success($userInfo->toArray());
  222. }
  223. /**
  224. * @param array $data
  225. * @return array
  226. */
  227. public function createUserLogin(array $data): array
  228. {
  229. $id = UserLogin::insertGetId($data);
  230. if (empty($id)) {
  231. return Result::error("创建登录日志失败", 0);
  232. }
  233. return Result::success(["id" => $id]);
  234. }
  235. /**
  236. * 更新用户信息和userInfo
  237. * @param array $data
  238. * @return array
  239. */
  240. public function updateUser(array $data): array
  241. {
  242. Db::beginTransaction();
  243. try {
  244. $userInfos = User::where(['id' => $data['id']])->first(); //查询用户昵称
  245. $dataUserReq = [
  246. 'user_name' => $data['user_name'],
  247. 'avatar' => $data['avatar'] ?? '',
  248. 'type_id' => $data['type_id'] ?? '20000',
  249. 'mobile' => $data['mobile'] ?? '', //手机号
  250. 'status' => $data['status'] ?? 1,
  251. 'email' => $data['email'] ?? '',
  252. 'admin_id' => $data['admin_id'],
  253. 'nickname' => $userInfos['nickname'] ?? $data['user_name'], //存在昵称同步一下,不存在取账号
  254. 'last_login_ip' => $data['last_login_ip'] ?? '',
  255. 'sszq' => $data['sszq'] ?? '', //网站标识
  256. ];
  257. $userRep = User::where(['id' => $data['id']])->update($dataUserReq);
  258. var_dump("修改user:", $userRep);
  259. $dataUserInfoReq = [
  260. 'id_card' => $data['id_card'] ?? '',
  261. 'gender' => $data['gender'] ?? 0,
  262. 'real_name' => $data['real_name'] ?? '',
  263. 'job' => $data['job'] ?? '',
  264. 'city_id' => $data['city_id'] ?? 0,
  265. 'birthday' => $data['birthday'] ?? '',
  266. 'number' => $data['number'] ?? '',
  267. 'city_arr_id' => $data['city_arr_id'] ?? '',
  268. 'from_time' => $data['from_time'] ?? null,
  269. 'business_name' => $data['business_name'] ?? '',
  270. 'to_time' => $data['to_time'] ?? null,
  271. 'long_time' => $data['long_time'] ?? 0,
  272. 'native_place_id' => $data['native_place_id'] ?? 0,
  273. 'native_place_arr_id' => $data['native_place_arr_id'] ?? '',
  274. 'qq' => $data['qq'] ?? '',
  275. 'zip_code' => $data['zip_code'] ?? '',
  276. 'address_arr_id' => $data['address_arr_id'] ?? '',
  277. 'address_id' => $data['address_id'] ?? 0,
  278. 'address' => $data['address'] ?? '',
  279. 'other' => $data['other'] ?? '',
  280. 'remark' => $data['remark'] ?? '',
  281. 'fax' => $data['fax'] ?? '',
  282. 'position' => $data['position'] ?? '',
  283. 'legal_person_real_name' => $data['legal_person_real_name'] ?? '',
  284. 'legal_person_mobile' => $data['legal_person_mobile'] ?? '',
  285. 'legal_person_id_card' => $data['legal_person_id_card'] ?? '',
  286. 'administrative_unit_arr_id' => $data['administrative_unit_arr_id'] ?? '',
  287. 'administrative_unit_id' => $data['administrative_unit_id'] ?? 0,
  288. // 企业会员 相关 公司信息
  289. 'company_hy_id' => $data['company_hy_id']?? 0,
  290. 'company_size' => $data['company_size']?? 0,
  291. 'company_nature' => $data['company_nature']?? '',
  292. 'introduction' => $data['introduction']?? '',
  293. 'company_url' => $data['company_url']?? '',
  294. ];
  295. $userInfoRep = UserInfo::where(['user_id' => $data['id']])->update($dataUserInfoReq);
  296. var_dump("修改userInfo:", $userInfoRep);
  297. $roleUserData = [
  298. 'role_id' => $data['role_id'],
  299. 'admin_user_id' => $data['admin_id'],
  300. ];
  301. $resultRoleUserRep = RoleUser::where(['user_id' => $data['id']])->update($roleUserData);
  302. var_dump("修改用户角色权限:", $resultRoleUserRep);
  303. Db::commit();
  304. } catch (\Throwable $ex) {
  305. Db::rollBack();
  306. var_dump($ex->getMessage());
  307. return Result::error("创建失败", 0);
  308. }
  309. return Result::success([]);
  310. }
  311. /**
  312. * @param array $data
  313. * @return array
  314. */
  315. public function updateUserInfo(array $data): array
  316. {
  317. return 1;
  318. }
  319. /**
  320. * @param array $data
  321. * @return array|int
  322. */
  323. public function resetPassword(array $data): array
  324. {
  325. $where = [
  326. 'id' => $data['id'],
  327. ];
  328. $data = [
  329. 'password' => md5(md5($data['password']) . $data['salt']),
  330. 'salt' => $data['salt'],
  331. ];
  332. $result = User::where($where)->update($data);
  333. if ($result) {
  334. return Result::error("修改失败", 0);
  335. } else {
  336. return Result::success([]);
  337. }
  338. }
  339. /**
  340. * @param int $id
  341. * @return array
  342. */
  343. public function delUser(int $id): array
  344. {
  345. Db::beginTransaction();
  346. try {
  347. User::where(['id' => $id])->delete();
  348. UserInfo::where(['user_id' => $id])->delete();
  349. Db::commit();
  350. } catch (\Throwable $ex) {
  351. Db::rollBack();
  352. return Result::error("删除失败", 0);
  353. }
  354. return Result::success([]);
  355. }
  356. /**
  357. * @param array $data
  358. * @return array
  359. */
  360. public function addRole(array $data): array
  361. {
  362. Db::beginTransaction();
  363. try {
  364. $data['sort'] = intval($data['sort']) ?? 0;
  365. Role::insertGetId($data);
  366. $logData = [
  367. 'user_id' => $data['user_id'],
  368. 'data' => json_encode($data),
  369. 'type' => 1,
  370. ];
  371. RoleLog::insertGetId($logData);
  372. Db::commit();
  373. } catch (\Throwable $ex) {
  374. Db::rollBack();
  375. return Result::error("新增失败", 0);
  376. }
  377. return Result::success([]);
  378. }
  379. /**
  380. * @param array $data
  381. * @return array
  382. */
  383. public function delRole(array $data): array
  384. {
  385. Db::beginTransaction();
  386. try {
  387. $roleInfo = Role::where(['id' => $data['id']])->first();
  388. $logData = [
  389. 'user_id' => $data['user_id'],
  390. 'data' => json_encode($roleInfo->toArray()),
  391. 'type' => 2,
  392. ];
  393. RoleLog::insertGetId($logData);
  394. RoleUser::where(['role_id' => $data['id']])->delete();
  395. $result = Role::where(['id' => $data['id']])->delete();
  396. Db::commit();
  397. } catch (\Throwable $ex) {
  398. Db::rollBack();
  399. return Result::error("删除失败", 0);
  400. }
  401. return Result::success($result);
  402. }
  403. /**
  404. * @param array $data
  405. * @return array
  406. */
  407. public function updateRole(array $data): array
  408. {
  409. Db::beginTransaction();
  410. try {
  411. $result = Role::where(['id' => $data['id']])->update($data);
  412. $logData = [
  413. 'user_id' => $data['user_id'],
  414. 'data' => json_encode($data),
  415. 'type' => 3,
  416. ];
  417. RoleLog::insertGetId($logData);
  418. Db::commit();
  419. } catch (\Throwable $ex) {
  420. Db::rollBack();
  421. return Result::error("更新失败");
  422. }
  423. return Result::success($result);
  424. }
  425. /**
  426. * @param array $data
  427. * @return array
  428. */
  429. public function roleInfo(array $data): array
  430. {
  431. $roleInfo = Role::where(['id' => $data['id']])->first();
  432. if ($roleInfo) {
  433. return Result::success($roleInfo->toArray());
  434. } else {
  435. return Result::error("没有数据");
  436. }
  437. }
  438. /**
  439. * @param array $data
  440. * @return array
  441. */
  442. public function roleList(array $data): array
  443. {
  444. $where = [];
  445. if (isset($data['keyword']) && $data['keyword']) {
  446. array_push($where, ['role.role_name', 'like', '%' . $data['keyword'] . '%']);
  447. }
  448. $result = Role::withCount('users')->where($where)->limit($data['pageSize'])->offset(($data['page'] - 1) * $data['pageSize'])->get();
  449. $count = Role::where($where)->count();
  450. if (empty($result)) {
  451. return Result::error("没有数据", 0);
  452. }
  453. $data = [
  454. 'rows' => $result->toArray(),
  455. 'count' => $count,
  456. ];
  457. return Result::success($data);
  458. }
  459. /**
  460. * 获取小程序注册信息
  461. * @param array $data
  462. * @return array
  463. */
  464. public function getWechatInfo(array $data): array
  465. {
  466. $where = [
  467. 'purePhoneNumber' => $data['purePhoneNumber'],
  468. 'openid' => $data['openid'],
  469. ];
  470. $result = Wechat::where($where)->first();
  471. var_dump($result);
  472. if ($result) {
  473. return Result::success($result);
  474. } else {
  475. return Result::error('没有数据');
  476. }
  477. }
  478. /**
  479. * 添加小程序 注册信息
  480. * @param array $data
  481. * @return array
  482. */
  483. public function addWechatInfo(array $data): array
  484. {
  485. $result = Wechat::insertGetId($data);
  486. if ($result) {
  487. return Result::success($result);
  488. } else {
  489. return Result::error('添加失败');
  490. }
  491. }
  492. /**
  493. * 修改密码
  494. * @param array $data
  495. * @return array
  496. */
  497. public function changePassword(array $data): array
  498. {
  499. Db::beginTransaction();
  500. $userInfo = User::where(['id' => $data['user_id']])->first();
  501. // return Result::success($userInfo);
  502. try {
  503. $dataUserReq = [
  504. 'password' => md5(md5($data['new_password1']) . $userInfo['salt']),
  505. ];
  506. if ($userInfo['password'] != md5(md5($data['password']) . $userInfo['salt'])) {
  507. return Result::error('您输入的密码错误');
  508. }
  509. $userRep = User::where(['id' => $data['user_id']])->update($dataUserReq);
  510. Db::commit();
  511. } catch (\Throwable $ex) {
  512. Db::rollBack();
  513. var_dump($ex->getMessage());
  514. return Result::error("创建失败", 0);
  515. }
  516. return Result::success([]);
  517. }
  518. /**
  519. * 修改用户状态
  520. * @param array $data
  521. * @return array
  522. */
  523. public function upUserStatus(array $data): array
  524. {
  525. $where = [
  526. 'id' => $data['id'],
  527. ];
  528. $result = User::where($where)->update($data);
  529. if ($result) {
  530. return Result::success($result);
  531. } else {
  532. return Result::error('修改失败');
  533. }
  534. }
  535. /**
  536. * 修改用户头像昵称
  537. * @param array $data
  538. * @return array
  539. */
  540. public function updateUserAvatarNickname(array $data): array
  541. {
  542. Db::beginTransaction();
  543. try {
  544. $where1 = [
  545. 'id' => $data['user_id'],
  546. ];
  547. $updateData = [];
  548. if (!empty($data['nickname'])) {
  549. $updateData['nickname'] = $data['nickname'];
  550. }
  551. if (!empty($data['avatar'])) {
  552. $updateData['avatar'] = $data['avatar'];
  553. }
  554. $result = User::where($where1)->update($updateData);
  555. $updateData = [];
  556. $where = [
  557. 'user_id' => $data['user_id'],
  558. ];
  559. if (!empty($data['real_name'])) {
  560. $updateData = ['real_name' => $data['real_name']];
  561. }
  562. $result = UserInfo::where($where)->update($updateData);
  563. $result = User::where($where1)->first();
  564. Db::commit();
  565. return Result::success($result);
  566. } catch (\Throwable $ex) {
  567. Db::rollBack();
  568. var_dump($ex->getMessage());
  569. return Result::error("创建失败", 0);
  570. }
  571. }
  572. /**
  573. * 获取网站组信息
  574. * @param array $data
  575. * @return array
  576. */
  577. public function getWebsiteGroupInfo(array $data): array
  578. {
  579. $result = WebsiteGroup::where(['id'=>$data['id']])->first();
  580. if ($result) {
  581. return Result::success($result);
  582. } else {
  583. return Result::error('查询失败');
  584. }
  585. }
  586. }