Employee.php 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492
  1. <?php
  2. namespace App\Models\Manager\Personnel;
  3. use Illuminate\Database\Eloquent\Factories\HasFactory;
  4. use Illuminate\Database\Eloquent\Model;
  5. use Illuminate\Support\Facades\DB;
  6. use App\Models\Manager\Personnel\EmployeeArea as EmployeeAreaModel;
  7. use App\Models\Manager\Personnel\EmployeeDepartment as EmployeeDepartmentModel;
  8. use App\Facades\Servers\Encrypts\AccessToken;
  9. use App\Models\Manager\Personnel\EmployeePlatform as EmployeePlatformModel;
  10. use App\Models\Manager\Personnel\EmployeeProvince as EmployeeProvinceModel;
  11. use App\Models\Manager\Personnel\EmployeeZoning as EmployeeZoningModel;
  12. /**
  13. * 员工模型
  14. * @author 唐远望
  15. * @version 1.0
  16. * @date 2025-12-04
  17. */
  18. class Employee extends Model
  19. {
  20. use HasFactory;
  21. // 与模型关联的表名
  22. protected $table = 'personnel_employee';
  23. // 是否主动维护时间戳
  24. public $timestamps = false;
  25. // 定义时间戳字段名
  26. // const CREATED_AT = 'insert_time';
  27. // const UPDATED_AT = 'update_time';
  28. /**
  29. * 添加
  30. * @author 唐远望
  31. * @version 1.0
  32. * @date 2025-12-04
  33. */
  34. public function addEmployee_content($data)
  35. {
  36. $insert_data = [
  37. 'name' => $data['name'],
  38. 'mobile' => $data['mobile'],
  39. 'email' => $data['email'],
  40. 'password' => md5($data['password']),
  41. 'role_id' => $data['role_id'],
  42. 'department_id' => $data['department_id'],
  43. 'open_notice' => $data['open_notice'],
  44. 'duty_type' => isset($data['duty_type']) ? $data['duty_type'] : '',
  45. 'insert_time' => time(),
  46. ];
  47. $Employee_id = $this->insertGetId($insert_data);
  48. if ($Employee_id) {
  49. $this->where('id', $Employee_id)->update(['employee_code' => $this->employee_idToCode($Employee_id)]);
  50. }
  51. return $Employee_id;
  52. }
  53. /**
  54. * 处理用户城市大区显示
  55. * @author 唐远望
  56. * @version 1.0
  57. * @date 2026-03-19
  58. * @param int $id 编码
  59. *
  60. */
  61. public function get_area_info($uid)
  62. {
  63. $user_area_info = '';
  64. //获取用户关联大区信息
  65. $EmployeeZoningModel = new EmployeeZoningModel();
  66. $EmployeeProvinceModel = new EmployeeProvinceModel();
  67. $EmployeeAreaModel = new EmployeeAreaModel();
  68. $user_area_info = $EmployeeZoningModel->where('employee_id', $uid)->get()->toArray();
  69. if ($user_area_info) {
  70. //查询用户关联省份信息
  71. foreach ($user_area_info as $key => $value) {
  72. $province_info = $EmployeeProvinceModel->where(['employee_id' => $uid, 'zoning_id' => $value['zoning_id']])->get()->toArray();
  73. $user_area_info[$key]['province_info'] = '';
  74. if (empty($province_info)) continue;
  75. $user_area_info[$key]['province_info'] = $province_info;
  76. //查询用户关联城市信息
  77. foreach ($province_info as $k => $v) {
  78. $city_info = $EmployeeAreaModel->where(['employee_id' => $uid, 'province_id' => $v['province_id']])->get()->toArray();
  79. $user_area_info[$key]['province_info'][$k]['city_info'] = '';
  80. if (empty($city_info)) continue;
  81. $user_area_info[$key]['province_info'][$k]['city_info'] = $city_info;
  82. }
  83. }
  84. }
  85. return $user_area_info;
  86. }
  87. /**
  88. * id转编码
  89. * @author 唐远望
  90. * @version 1.0
  91. * @date 2025-12-04
  92. * @param int $id 编码
  93. *
  94. */
  95. public function employee_idToCode($id)
  96. {
  97. return 'RH' . str_pad($id, 9, '0', STR_PAD_LEFT);
  98. }
  99. /**
  100. * 编码转id
  101. * @author 唐远望
  102. * @version 1.0
  103. * @date 2025-12-04
  104. * @param string $code 编码
  105. *
  106. */
  107. public function employee_codeToId($code)
  108. {
  109. return intval(str_ireplace('RH', '', $code));
  110. }
  111. /**
  112. * 写入数据
  113. * @author 唐远望
  114. * @version 1.0
  115. * @date 2025-12-04
  116. * @param $data
  117. * @return bool
  118. */
  119. public function addEmployee($data)
  120. {
  121. DB::beginTransaction();
  122. try {
  123. $EmployeeAreaModel = new EmployeeAreaModel();
  124. $EmployeeDepartmentModel = new EmployeeDepartmentModel();
  125. $EmployeePlatformModel = new EmployeePlatformModel();
  126. $EmployeeProvinceModel = new EmployeeProvinceModel();
  127. $EmployeeZoningModel = new EmployeeZoningModel();
  128. $insert_data = [
  129. 'name' => $data['name'],
  130. 'mobile' => $data['mobile'],
  131. 'email' => $data['email'],
  132. 'password' => md5($data['password']),
  133. 'role_id' => $data['role_id'],
  134. 'department_ids' => isset($data['department_ids']) ? ',' . $data['department_ids'] . ',' : '',
  135. 'open_notice' => $data['open_notice'],
  136. 'duty_type' => isset($data['duty_type']) ? $data['duty_type'] : '',
  137. 'company_id' => $data['company_id'],
  138. 'insert_time' => time(),
  139. ];
  140. $Employee_id = $this->insertGetId($insert_data);
  141. if ($Employee_id) {
  142. $this->where('id', $Employee_id)->update(['employee_code' => $this->employee_idToCode($Employee_id)]);
  143. }
  144. //处理省份城市大区信息
  145. if (isset($data['area_data'])) {
  146. $area_data = $data['area_data'];
  147. foreach ($area_data as $zoning_key => $zoning_data) {
  148. $insert_zoning_data = [
  149. 'employee_id' => $Employee_id,
  150. 'zoning_name' => $zoning_data['zoning_name'],
  151. 'is_province_all' => $zoning_data['is_province_all'],
  152. 'zoning_id' => $zoning_data['zoning_id'],
  153. ];
  154. $EmployeeZoningModel->insert($insert_zoning_data);
  155. $province_data_list = $zoning_data['province_data'];
  156. foreach ($province_data_list as $province_key => $province_data) {
  157. $insert_province_data = [
  158. 'employee_id' => $Employee_id,
  159. 'zoning_id' => $zoning_data['zoning_id'],
  160. 'province_id' => $province_data['province_id'],
  161. 'province_name' => $province_data['province_name'],
  162. 'is_city_all' => $province_data['is_city_all'],
  163. ];
  164. $EmployeeProvinceModel->insert($insert_province_data);
  165. $city_ids = $province_data['city_ids'];
  166. foreach ($city_ids as $city_key => $city_info) {
  167. $insert_city_data = [
  168. 'employee_id' => $Employee_id,
  169. 'province_id' => $province_data['province_id'],
  170. 'city_id' => $city_info['id'],
  171. 'city_name' => $city_info['name']
  172. ];
  173. $EmployeeAreaModel->insert($insert_city_data);
  174. }
  175. }
  176. }
  177. }
  178. if ($data['department_ids']) {
  179. $insert_department_data = [];
  180. $department_ids = explode(',', $data['department_ids']);
  181. foreach ($department_ids as $department_id) {
  182. $insert_department_data[] = [
  183. 'employee_id' => $Employee_id,
  184. 'department_id' => $department_id,
  185. 'company_id' => $data['company_id'],
  186. ];
  187. }
  188. $EmployeeDepartmentModel->insert($insert_department_data);
  189. }
  190. if ($data['platform_ids']) {
  191. $insert_department_data = [];
  192. $platform_ids = explode(',', $data['platform_ids']);
  193. foreach ($platform_ids as $platform_id) {
  194. $insert_flatform_data[] = [
  195. 'employee_id' => $Employee_id,
  196. 'platform_id' => $platform_id,
  197. 'company_id' => $data['company_id'],
  198. ];
  199. }
  200. $EmployeePlatformModel->insert($insert_flatform_data);
  201. }
  202. DB::commit();
  203. return true;
  204. // 成功处理...
  205. } catch (\Exception $e) {
  206. DB::rollBack();
  207. // 错误处理...
  208. return false;
  209. }
  210. }
  211. /**
  212. * 编辑内容
  213. * @author 唐远望
  214. * @version 1.0
  215. * @date 2025-12-04
  216. * @param $data
  217. * @return bool
  218. */
  219. public function editEmployee_content($where, $data)
  220. {
  221. $Employee = $this->where($where)->first();
  222. if (!$Employee) {
  223. return false;
  224. }
  225. $Employee->name = $data['name'];
  226. $Employee->mobile = $data['mobile'];
  227. $Employee->email = $data['email'];
  228. if (isset($data['password']) && $data['password'] != '') $Employee->password = md5($data['password']);
  229. $Employee->role_id = $data['role_id'];
  230. $Employee->department_ids = isset($data['department_ids']) ? ',' . $data['department_ids'] . ',' : '';
  231. $Employee->open_notice = $data['open_notice'];
  232. $Employee->duty_type = isset($data['duty_type']) ? $data['duty_type'] : '';
  233. $Employee->company_id = $data['company_id'];
  234. $Employee->update_time = time();
  235. $Employee->save();
  236. return true;
  237. }
  238. /**
  239. * 更新数据
  240. * @author 唐远望
  241. * @version 1.0
  242. * @date 2025-12-04
  243. * @param $data
  244. * @return bool
  245. */
  246. public function updateEmployee($Employee, $data)
  247. {
  248. DB::beginTransaction();
  249. try {
  250. $EmployeeAreaModel = new EmployeeAreaModel();
  251. $EmployeeDepartmentModel = new EmployeeDepartmentModel();
  252. $EmployeePlatformModel = new EmployeePlatformModel();
  253. $EmployeeProvinceModel = new EmployeeProvinceModel();
  254. $EmployeeZoningModel = new EmployeeZoningModel();
  255. $Employee->name = $data['name'];
  256. $Employee->mobile = $data['mobile'];
  257. $Employee->email = $data['email'];
  258. if (isset($data['password']) && $data['password'] != '') $Employee->password = md5($data['password']);
  259. $Employee->role_id = $data['role_id'];
  260. $Employee->department_ids = isset($data['department_ids']) ? ',' . $data['department_ids'] . ',' : '';
  261. $Employee->open_notice = $data['open_notice'];
  262. $Employee->duty_type = isset($data['duty_type']) ? $data['duty_type'] : '';
  263. $Employee->company_id = $data['company_id'];
  264. $Employee->update_time = time();
  265. $Employee->save();
  266. $EmployeeAreaModel->where('employee_id', $Employee->id)->delete();
  267. $EmployeeProvinceModel->where('employee_id', $Employee->id)->delete();
  268. $EmployeeZoningModel->where('employee_id', $Employee->id)->delete();
  269. //处理省份城市大区信息
  270. if (isset($data['area_data'])) {
  271. $area_data = $data['area_data'];
  272. foreach ($area_data as $zoning_key => $zoning_data) {
  273. $insert_zoning_data = [
  274. 'employee_id' => $Employee->id,
  275. 'zoning_name' => $zoning_data['zoning_name'],
  276. 'is_province_all' => $zoning_data['is_province_all'],
  277. 'zoning_id' => $zoning_data['zoning_id'],
  278. ];
  279. $EmployeeZoningModel->insert($insert_zoning_data);
  280. $province_data_list = $zoning_data['province_data'];
  281. foreach ($province_data_list as $province_key => $province_data) {
  282. $insert_province_data = [
  283. 'employee_id' => $Employee->id,
  284. 'zoning_id' => $zoning_data['zoning_id'],
  285. 'province_id' => $province_data['province_id'],
  286. 'province_name' => $province_data['province_name'],
  287. 'is_city_all' => $province_data['is_city_all'],
  288. ];
  289. $EmployeeProvinceModel->insert($insert_province_data);
  290. $city_ids = $province_data['city_ids'];
  291. foreach ($city_ids as $city_key => $city_info) {
  292. $insert_city_data = [
  293. 'employee_id' => $Employee->id,
  294. 'province_id' => $province_data['province_id'],
  295. 'city_id' => $city_info['id'],
  296. 'city_name' => $city_info['name']
  297. ];
  298. $EmployeeAreaModel->insert($insert_city_data);
  299. }
  300. }
  301. }
  302. }
  303. $EmployeeDepartmentModel->where('employee_id', $Employee->id)->delete();
  304. if ($data['department_ids']) {
  305. $insert_department_data = [];
  306. $department_ids = explode(',', $data['department_ids']);
  307. foreach ($department_ids as $department_id) {
  308. $insert_department_data[] = [
  309. 'employee_id' => $Employee->id,
  310. 'department_id' => $department_id,
  311. 'company_id' => $data['company_id'],
  312. ];
  313. }
  314. $EmployeeDepartmentModel->insert($insert_department_data);
  315. }
  316. $EmployeePlatformModel->where('employee_id', $Employee->id)->delete();
  317. if ($data['platform_ids']) {
  318. $insert_department_data = [];
  319. $platform_ids = explode(',', $data['platform_ids']);
  320. foreach ($platform_ids as $platform_id) {
  321. $insert_flatform_data[] = [
  322. 'employee_id' => $Employee->id,
  323. 'platform_id' => $platform_id,
  324. 'company_id' => $data['company_id'],
  325. ];
  326. }
  327. $EmployeePlatformModel->insert($insert_flatform_data);
  328. }
  329. DB::commit();
  330. return true;
  331. // 成功处理...
  332. } catch (\Exception $e) {
  333. DB::rollBack();
  334. // 错误处理...
  335. return false;
  336. }
  337. }
  338. /**
  339. * 修改状态
  340. * @author 唐远望
  341. * @version 1.0
  342. * @date 2025-12-04
  343. * @param $id
  344. * @param $status
  345. * @return bool
  346. */
  347. public function changeStatus($where, $status)
  348. {
  349. $Employee = $this->where($where)->first();
  350. if (!$Employee) {
  351. return false;
  352. }
  353. $Employee->status = $status;
  354. $Employee->update_time = time();
  355. $Employee->save();
  356. return true;
  357. }
  358. /**
  359. * 删除数据
  360. * @author 唐远望
  361. * @version 1.0
  362. * @date 2025-12-04
  363. * @param $id
  364. * @return bool
  365. */
  366. public function deleteEmployee($where)
  367. {
  368. $Employee = $this->where($where)->first();
  369. if (!$Employee) {
  370. return false;
  371. }
  372. $Employee->delete();
  373. return true;
  374. }
  375. /**
  376. * 添加数据
  377. *
  378. */
  379. public function edit($id,$data)
  380. {
  381. // 更新时间
  382. $data['update_time'] = time();
  383. // 写入数据表
  384. $result = $this->query()->where(['id'=>$id])->update($data);
  385. // 如果操作失败
  386. if( !$result ) return 0;
  387. // 更新缓存
  388. $this->getList(true);
  389. // 返回结果
  390. return $id;
  391. }
  392. /**
  393. * 获取列表
  394. * @param Bool $force 是否强制更新
  395. *
  396. */
  397. public function getList($force = false)
  398. {
  399. // 结果数据
  400. $list = $force ? [] : cache('manager:admin:employee:list');
  401. // 不存在数据
  402. if ( !$list ) {
  403. // 从数据库获取数据
  404. $data = $this->query()->get(['id','name','mobile','status','password','status','insert_time','update_time'])->toArray();
  405. // 循环处理数据
  406. $list = [];
  407. // 进行更新
  408. foreach ($data as $value) {
  409. // 重组数据
  410. $list[$value['id']] = $value;
  411. }
  412. // 存起来
  413. cache(['manager:admin:employee:list'=>$list]);
  414. }
  415. // 返回结果
  416. return $list;
  417. }
  418. /**
  419. * 获取配置平台对应的应用数据
  420. *
  421. * @param int 用户ID
  422. * @param string 指定字段
  423. *
  424. */
  425. public function getOne($id,$field='')
  426. {
  427. // 获取列表数据
  428. $list = $this->getList();
  429. // 获取数据
  430. $one = isset($list[$id]) ? $list[$id] : [];
  431. // 返回值
  432. return empty($field) ? $one : ( isset($one[$field]) ? $one[$field] : null);
  433. }
  434. /**
  435. * 登录
  436. *
  437. * @param int 用户ID
  438. *
  439. */
  440. public function Login($uid,$company_id=0, $module = 'manager')
  441. {
  442. // 组合数据
  443. $jwtData = ['company_id'=>$company_id, 'uid' => $uid, 'is_admin' => '0', 'type' => $module, 'expire' => time() + 3600 * 8];
  444. // 登录成功
  445. $token = AccessToken::encode($jwtData);
  446. // 如果异常的话
  447. if (isset($token['error'])) return $token;
  448. // 登录成功
  449. cache([$module . ':employee:access_token:' . $uid => md5($token)], 3600 * 8);
  450. // 返回结果
  451. return ['access_token_' . $module => $token, 'expire' => 3600 * 8];
  452. }
  453. /**
  454. * 退出登录
  455. *
  456. * @param int 用户ID
  457. *
  458. */
  459. public function LoginOut($uid, $module = 'manager')
  460. {
  461. // 删除缓存
  462. cache([$module . ':employee:access_token:' . $uid => null]);
  463. // 返回结果
  464. return true;
  465. }
  466. }