EmployeeService.php 44 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357
  1. <?php
  2. namespace App\Service;
  3. use App\Model\DDEmployee;
  4. use App\Model\Depart;
  5. use App\Model\Employee;
  6. use App\Model\EmployeeDepartPermission;
  7. use App\Model\EmployeeIndex;
  8. use App\Model\EmployeeManagerDepart;
  9. use App\Model\EmployeeMenuPermission;
  10. use App\Model\EmployeeRole;
  11. use App\Model\EmployeeTeamPermission;
  12. use App\Model\Role;
  13. use App\Model\RoleMenu;
  14. use App\Model\RoleMenuButton;
  15. use App\Model\SysMenu;
  16. use App\Model\SysMenuButton;
  17. use App\Model\Team;
  18. use Illuminate\Support\Facades\DB;
  19. use Illuminate\Support\Facades\Hash;
  20. use Mockery\Exception;
  21. /**
  22. * 人员相关
  23. * @package App\Models
  24. */
  25. class EmployeeService extends Service
  26. {
  27. public function employeeEditOther($data,$user){
  28. list($status,$msg) = $this->employeeOtherRule($data,$user);
  29. if(!$status) return [$status,$msg];
  30. try {
  31. DB::beginTransaction();
  32. $model = new Employee();
  33. $model = $model->where('id',$user['id'])->first();
  34. $model->password = Hash::make($data['new_password']);
  35. $model->save();
  36. DB::commit();
  37. }catch (\Exception $exception){
  38. DB::rollBack();
  39. return [false, $exception->getMessage()];
  40. }
  41. return [true,''];
  42. }
  43. public function employeeOtherRule($data,$user){
  44. if(! isset($data['old_password'])) return [false,'请输入原密码'];
  45. if($data['old_password'] == "") return [false,'原密码不能为空'];
  46. if(! isset($data['new_password'])) return [false,'请输入新密码'];
  47. if($data['new_password'] == "") return [false,'新密码不能为空'];
  48. if(! isset($data['re_password'])) return [false,'请输入确认密码'];
  49. if($data['re_password'] == "") return [false,'确认密码不能为空'];
  50. if(! Hash::check($data['old_password'], $user['password'])) return [false,'原密码错误'];
  51. if($data['new_password'] == $data['old_password']) return [false,'原密码与新密码一致'];
  52. if($data['new_password'] !== $data['re_password']) return [false,'新密码与确认密码不一致'];
  53. return [true,''];
  54. }
  55. /**
  56. * 用户编辑
  57. * @param $data
  58. * @param $user
  59. * @return array
  60. */
  61. public function employeeEdit($data,$user){
  62. list($status,$msg) = $this->employeeRule($data,false);
  63. if(!$status) return [$status,$msg];
  64. try {
  65. DB::beginTransaction();
  66. $model = new Employee();
  67. $model = $model->where('id',$data['id'])->first();
  68. $model->is_admin = $data['is_admin'];
  69. $model->account = $data['number'];
  70. if($model->is_admin == 1){
  71. if($data['password'] !== '******'){
  72. $model->password = Hash::make($data['password']);
  73. }
  74. }else{
  75. $model->password = "";
  76. }
  77. $model->save();
  78. $time = time();
  79. EmployeeRole::where('employee_id',$data['id'])->update([
  80. 'del_time' => $time
  81. ]);
  82. if(isset($data['role'])){
  83. $insert = [];
  84. foreach ($data['role'] as $value){
  85. $insert[] = [
  86. 'employee_id' => $model->id,
  87. 'role_id' => $value,
  88. 'crt_time' => $time,
  89. 'upd_time' => $time,
  90. ];
  91. }
  92. EmployeeRole::insert($insert);
  93. }
  94. if(! empty($data['index_array'])){
  95. EmployeeIndex::where('del_time',0)
  96. ->where('employee_id', $data['id'])
  97. ->update(['del_time' => $time]);
  98. EmployeeIndex::insert($data['index_array']);
  99. }
  100. DB::commit();
  101. }catch (\Exception $exception){
  102. DB::rollBack();
  103. return [false, $exception->getMessage()];
  104. }
  105. return [true,''];
  106. }
  107. /**
  108. * 用户新增
  109. * @param $data
  110. * @param $user
  111. * @return array
  112. */
  113. public function employeeAdd($data,$user){
  114. list($status,$msg) = $this->employeeRule($data);
  115. if(!$status) return [$status,$msg];
  116. try{
  117. DB::beginTransaction();
  118. $model = new Employee();
  119. $model->number = $data['number'];
  120. $model->emp_name = $data['emp_name'];
  121. $model->mobile = $data['mobile'] ?? '';
  122. $model->leave_time = $data['leave_time'] ?? '';
  123. $model->entry_time = $data['entry_time'] ?? '';
  124. $model->state = empty($data['leave_time']) ? Employee::USE : Employee::NOT_USE;
  125. $model->crt_id = $user['id'];
  126. $model->is_admin = $data['is_admin'];
  127. $model->account = $data['number'];
  128. if($model->is_admin == 1){
  129. if($data['password'] !== '******'){
  130. $model->password = Hash::make($data['password']);
  131. }
  132. }
  133. $model->save();
  134. if(isset($data['depart'])){
  135. $insert = [];
  136. foreach ($data['depart'] as $value){
  137. $insert[] = [
  138. 'employee_id' => $model->id,
  139. 'depart_id' => $value,
  140. ];
  141. }
  142. EmployeeDepartPermission::insert($insert);
  143. }
  144. if(isset($data['role'])){
  145. $insert = [];
  146. foreach ($data['role'] as $value){
  147. $insert[] = [
  148. 'employee_id' => $model->id,
  149. 'role_id' => $value,
  150. 'crt_time' => time(),
  151. 'upd_time' => time(),
  152. ];
  153. }
  154. EmployeeRole::insert($insert);
  155. }
  156. DB::commit();
  157. }catch (Exception $e){
  158. DB::rollBack();
  159. return [false, $e->getMessage()];
  160. }
  161. return [true,''];
  162. }
  163. /**
  164. * 用户删除
  165. * @param $data
  166. * @return array
  167. */
  168. public function employeeDel($data){
  169. if($this->isEmpty($data,'id')) return [false,'请选择删除的数据!'];
  170. try {
  171. DB::beginTransaction();
  172. Employee::whereIn('id',$data['id'])->update([
  173. 'del_time'=>time()
  174. ]);
  175. EmployeeRole::where('del_time',0)->whereIn('employee_id',$data['id'])->update([
  176. 'del_time'=>time()
  177. ]);
  178. EmployeeDepartPermission::whereIn('employee_id',$data['id'])->delete();
  179. DB::commit();
  180. }catch (\Throwable $exception){
  181. DB::rollBack();
  182. return [false, $exception->getMessage()];
  183. }
  184. return [true,'删除成功'];
  185. }
  186. public function employeeDetail($data){
  187. if($this->isEmpty($data,'id')) return [false,'人员id不能为空'];
  188. $user = Employee::where('id', $data['id'])->where('del_time',0)->first();
  189. if(empty($user)) return [false, '人员不存在或已被删除'];
  190. $user = $user->toArray();
  191. if($user['is_admin']){
  192. $user['password'] = "******";
  193. }else{
  194. $user['password'] = "";
  195. }
  196. $detail = EmployeeIndex::where('del_time',0)
  197. ->where('employee_id',$user['id'])
  198. ->select('employee_id','index','index_2','index_3','type','start_time','end_time')
  199. ->get()->toArray();
  200. $user['index_array'] = $detail;
  201. $res = DB::table('employee_role as a')
  202. ->leftJoin('role as b','a.role_id','=','b.id')
  203. ->where('a.del_time',0)
  204. ->where('b.del_time',0)
  205. ->where("a.employee_id",$user['id'])
  206. ->select('a.employee_id','b.title','b.id')
  207. ->get()->toArray();
  208. $role_name = "";
  209. $role = [];
  210. foreach ($res as $value){
  211. if(empty($role_name)){
  212. $role_name = $value->title;
  213. }else{
  214. $role_name .= ',' . $value->title;
  215. }
  216. $role[] = $value->id;
  217. }
  218. $user['role'] = $role;
  219. $user['role_name'] = $role_name;
  220. return [true, $user];
  221. }
  222. /**
  223. * 用户列表
  224. * @param $data
  225. * @param $user
  226. * @return array
  227. */
  228. public function employeeList($data,$user){
  229. $model = Employee::where('del_time',0)
  230. ->select('number','mobile','emp_name','id','is_admin','state')
  231. ->orderBy('state','asc');
  232. if(! empty($data['number'])) $model->where('number', 'LIKE', '%'.$data['number'].'%');
  233. if(! empty($data['emp_name'])) $model->where('emp_name', 'LIKE', '%'.$data['emp_name'].'%');
  234. if(! empty($data['state'])) $model->where('state',$data['state']);
  235. if(! empty($data['mobile'])) $model->where('mobile', 'LIKE', '%'.$data['mobile'].'%');
  236. if(! isset($data['all_emp'])) $model->where('id','<>',Employee::SPECIAL_ADMIN);
  237. if(isset($data['is_admin'])) $model->where('is_admin', $data['is_admin']);
  238. if(! empty($data['role'])) {
  239. $emp = EmployeeRole::where('role_id',$data['role'])
  240. ->where('del_time',0)
  241. ->select('employee_id')->get()->toArray();
  242. $model->whereIn('id',array_column($emp,'employee_id'));
  243. }
  244. if($user['id'] != Employee::SPECIAL_ADMIN) $model->where('is_manager',0);
  245. $list = $this->limit($model,'',$data);
  246. //组织数据
  247. $list = $this->organizationEmployeeData($list);
  248. return [true , $list];
  249. }
  250. /**
  251. * 用户数据组装
  252. * @param $data
  253. * @return array
  254. */
  255. public function organizationEmployeeData($data) {
  256. if (empty($data['data'])) return $data;
  257. $res = DB::table('employee_role as a')
  258. ->leftJoin('role as b','a.role_id','=','b.id')
  259. ->where('a.del_time',0)
  260. ->where('b.del_time',0)
  261. ->whereIn("a.employee_id",array_column($data['data'],'id'))
  262. ->select('a.employee_id','b.title','b.id')
  263. ->get()->toArray();
  264. $role = $role2 = [];
  265. foreach ($res as $value){
  266. if(isset($role[$value->employee_id])){
  267. $role[$value->employee_id] .= ',' . $value->title;
  268. }else{
  269. $role[$value->employee_id] = $value->title;
  270. }
  271. $role2[$value->employee_id][] = $value->id;
  272. }
  273. $res = DB::table('employee_depart_permission as a')
  274. ->select('a.employee_id','b.title','b.id')
  275. ->join('depart as b','a.depart_id','=','b.id')
  276. ->whereIn("a.employee_id",array_column($data['data'],'id'))
  277. ->orderBy('b.id')
  278. ->get()->toArray();
  279. $depart_title = $depart_id = [];
  280. foreach ($res as $value){
  281. if(isset($depart_title[$value->employee_id])){
  282. $depart_title[$value->employee_id] .= ',' . $value->title;
  283. }else{
  284. $depart_title[$value->employee_id] = $value->title;
  285. }
  286. $depart_id[$value->employee_id][] = $value->id;
  287. }
  288. foreach ($data['data'] as $key => $value){
  289. $data['data'][$key]['role'] = $role2[$value['id']] ?? [];
  290. $data['data'][$key]['role_name'] = $role[$value['id']] ?? '';
  291. $data['data'][$key]['depart'] = $depart_id[$value['id']] ?? [];
  292. $data['data'][$key]['depart_title'] = $depart_title[$value['id']] ?? '';
  293. $data['data'][$key]['state_title'] = $value['state'] == Employee::USE ? "启用" : "停用";
  294. $data['data'][$key]['is_admin_title'] = $value['is_admin'] ? "是" : "否";
  295. }
  296. return $data;
  297. }
  298. /**
  299. * 用户参数规则
  300. * @param $data
  301. * @param $is_add
  302. * @return array
  303. */
  304. public function employeeRule(&$data, $is_add = true){
  305. if(! empty($data['index_array'])){
  306. $typeIntervals = []; // 用于收集每个 type 的时间区间,用于后续不相交校验
  307. foreach ($data['index_array'] as $key => $value){
  308. if(empty($value['type'])) return [false, '人员指标类型不能为空'];
  309. if(! isset(EmployeeIndex::$type_name[$value['type']])) return [false, '人员指标类型不存在'];
  310. $name = EmployeeIndex::$type_name[$value['type']];
  311. if(empty($value['crt_time'][0]) || empty($value['crt_time'][1]) || ! is_array($value['crt_time'])) return [false, $name . ":时间区间不能为空"];
  312. list($start_time, $end_time) = $this->changeDateToTimeStampAboutRange($value['crt_time']);
  313. $data['index_array'][$key]['start_time'] = $start_time;
  314. $data['index_array'][$key]['end_time'] = $end_time;
  315. $data['index_array'][$key]['employee_id'] = $data['id'];
  316. $data['index_array'][$key]['mark'] = $value['mark'] ?? "";
  317. unset($data['index_array'][$key]['crt_time']);
  318. if ($start_time === null || $end_time === null || $start_time > $end_time) return [false, $name . ":时间区间无效"];
  319. // 收集每个 type 的时间区间,用于后续不相交校验
  320. $type = $value['type'];
  321. $typeIntervals[$type][] = [
  322. 'start' => $start_time,
  323. 'end' => $end_time,
  324. 'index' => $key, // 用于报错定位
  325. ];
  326. if(! isset($value['index'])) return [false, 'index不存在'];
  327. if(! isset($value['index_2'])) return [false, 'index_2不存在'];
  328. if(! isset($value['index_3'])) return [false, 'index_3不存在'];
  329. if(isset(EmployeeIndex::$positive[$value['type']])){
  330. $name_string = EmployeeIndex::$positive[$value['type']];
  331. $res = $this->checkNumber($value['index'],2,'non-negative');
  332. if(! $res['valid']) return [false, $name_string . ":" . $res['error']];
  333. }elseif(isset(EmployeeIndex::$null[$value['type']])){
  334. $name_string = EmployeeIndex::$positive[$value['type']];
  335. $res = $this->checkNumber($value['index']);
  336. if(! $res['valid']) return [false, $name_string . ":" . $res['error']];
  337. }elseif(isset(EmployeeIndex::$positive_2[$value['type']])){
  338. $name_string = EmployeeIndex::$positive_2[$value['type']];
  339. $res = $this->checkNumber($value['index'],2,'positive');
  340. if(! $res['valid']) return [false, $name_string . "基数:" . $res['error']];
  341. $res = $this->checkNumber($value['index_2'],2,'positive');
  342. if(! $res['valid']) return [false, $name_string . "比例:" . $res['error']];
  343. $res = $this->checkNumber($value['index_3'],2,'positive');
  344. if(! $res['valid']) return [false, $name_string . ":" . $res['error']];
  345. }
  346. }
  347. //在校验循环之后
  348. foreach ($typeIntervals as $type => $intervals) {
  349. if (count($intervals) < 2) continue;
  350. usort($intervals, function($a, $b) {
  351. return $a['start'] <=> $b['start'];
  352. });
  353. for ($i = 1; $i < count($intervals); $i++) {
  354. $prev = $intervals[$i - 1];
  355. $curr = $intervals[$i];
  356. // 方式1:闭区间 [start, end] —— 推荐大多数场景
  357. if ($prev['end'] >= $curr['start']) {
  358. $typeName = EmployeeIndex::$type_name[$type] ?? $type;
  359. return [false, "{$typeName}的时间区间存在重叠,请检查"];
  360. }
  361. }
  362. }
  363. }
  364. if(! $is_add){
  365. if(empty($data['id'])) return [false,'人员ID不能为空'];
  366. $bool = Employee::where('del_time',0)
  367. ->where('id', $data['id'])
  368. ->exists();
  369. if(! $bool) return [false, '人员不存在或已被删除'];
  370. }
  371. return [true,''];
  372. }
  373. /**
  374. * 角色编辑
  375. * @param $data
  376. * @return array
  377. */
  378. public function roleEdit($data,$user){
  379. list($status,$msg) = $this->roleRule($data,$user, false);
  380. if(!$status) return [$status,$msg];
  381. $model = new Role();
  382. $model = $model->where('id',$data['id'])->first();
  383. $model->title = $data['title'];
  384. $model->save();
  385. return [true,''];
  386. }
  387. /**
  388. * 角色新增
  389. * @param $data
  390. * @param $user
  391. * @return array
  392. */
  393. public function roleAdd($data,$user){
  394. list($status,$msg) = $this->roleRule($data,$user);
  395. if(!$status) return [$status,$msg];
  396. $model = new Role();
  397. $model->title = $data['title'] ;
  398. $model->save();
  399. return [true,''];
  400. }
  401. /**
  402. * 角色删除
  403. * @param $data
  404. * @return array
  405. */
  406. public function roleDel($data){
  407. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  408. $bool = EmployeeRole::where('del_time',0)
  409. ->whereIn('role_id',$data['id'])
  410. ->exists();
  411. if($bool) return [false,'角色已绑定人员!'];
  412. try {
  413. DB::beginTransaction();
  414. Role::whereIn('id',$data['id'])->update([
  415. 'del_time' => time()
  416. ]);
  417. RoleMenu::where('del_time',0)->whereIn('role_id',$data['id'])->update([
  418. 'del_time' => time()
  419. ]);
  420. RoleMenuButton::where('del_time',0)->whereIn('role_id',$data['id'])->update([
  421. 'del_time' => time()
  422. ]);
  423. DB::commit();
  424. }catch (\Throwable $exception){
  425. DB::rollBack();
  426. return [false, $exception->getMessage()];
  427. }
  428. return [true, ''];
  429. }
  430. /**
  431. * 角色列表
  432. * @param $data
  433. * @return array
  434. */
  435. public function roleList($data,$user){
  436. $model = Role::where('del_time',0)
  437. ->select('title','crt_time','id','upd_time')
  438. ->orderBy('id','desc');
  439. if(! empty($data['title'])) $model->where('title', 'LIKE', '%' . $data['title'] . '%');
  440. $list = $this->limit($model,'',$data);
  441. $list = $this->fillRoleList($list, $user);
  442. return [true, $list];
  443. }
  444. public function fillRoleList($list,$user){
  445. if(empty($list)) return $list;
  446. foreach ($list['data'] as $key => $value){
  447. $list['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d",$value['crt_time']) : "";
  448. }
  449. return $list;
  450. }
  451. /**
  452. * 角色参数规则
  453. * @param $data
  454. * @param $is_check
  455. * @return array
  456. */
  457. public function roleRule(&$data,$user, $is_check = true){
  458. if($this->isEmpty($data,'title')) return [false,'名称不能为空!'];
  459. if($is_check){
  460. $bool = Role::where('title',$data['title'])
  461. ->where('del_time',0)
  462. ->exists();
  463. if($bool) return [false,'角色名称已存在!'];
  464. }else{
  465. if($this->isEmpty($data,'id')) return [false,'ID不能为空!'];
  466. $bool = Role::where('title',$data['title'])
  467. ->where('id','<>',$data['id'])
  468. ->where('del_time',0)
  469. ->exists();
  470. if($bool) return [false,'角色名称已存在!'];
  471. }
  472. return [true, ''];
  473. }
  474. /**
  475. * 角色菜单更新
  476. * @param $data
  477. * @return array
  478. */
  479. public function roleMenu($data){
  480. if(empty($data['role_id'])) return [false,'角色不能为空!'];
  481. if(empty($data['menu'])) return [false,'菜单数据不能为空!'];
  482. DB::beginTransaction();
  483. try {
  484. RoleMenu::where('del_time',0)->where('role_id',$data['role_id'])->update(['del_time' => time()]);
  485. RoleMenuButton::where('del_time',0)->where('role_id',$data['role_id'])->update(['del_time' => time()]);
  486. $insert = $insert2 = [];
  487. foreach ($data['menu'] as $t){
  488. $insert[] = [
  489. 'role_id' => $data['role_id'],
  490. 'menu_id' => $t['menu_id'],
  491. 'type' => $t['type'],
  492. 'crt_time' => time()
  493. ];
  494. if(! empty($t['button'])){
  495. foreach ($t['button'] as $b){
  496. $insert2[] = [
  497. 'role_id' => $data['role_id'],
  498. 'menu_id' => $t['menu_id'],
  499. 'button_id' => $b,
  500. 'crt_time' => time()
  501. ];
  502. }
  503. RoleMenuButton::insert($insert2);
  504. }
  505. }
  506. RoleMenu::insert($insert);
  507. DB::commit();
  508. }catch (\Throwable $exception){
  509. DB::rollBack();
  510. return [false,$exception->getMessage()];
  511. }
  512. return [true, ''];
  513. }
  514. /**
  515. * 角色详情
  516. * @param $data
  517. * @return array
  518. */
  519. public function roleDetail($data){
  520. if(empty($data['role_id'])) return [false,'请选择角色'];
  521. $role = Role::where('id',$data['role_id'])
  522. ->where('del_time',0)
  523. ->select('id','title')
  524. ->first();
  525. if(empty($role)) return [false,'角色不存在或已被删除'];
  526. $role = $role->toArray();
  527. $menu = RoleMenu::where('role_id',$data['role_id'])
  528. ->where('del_time',0)
  529. ->select('menu_id','type')
  530. ->get()->toArray();
  531. $button = $this->fillRoleButton([$data['role_id']]);
  532. foreach ($menu as $key => $value){
  533. $menu[$key]['button'] = $button[$value['menu_id']] ?? [];
  534. }
  535. $role['menu'] = $menu;
  536. return [true, $role];
  537. }
  538. /**
  539. * 部门编辑
  540. * @param $data
  541. * @return array
  542. */
  543. public function departEdit($data, $user){
  544. list($status,$msg) = $this->departRule($data,$user,false);
  545. if(!$status) return [$status,$msg];
  546. $update = $msg['data'][0];
  547. $model = new Depart();
  548. $model->where('id',$data['id'])->update($update);
  549. return [true, ''];
  550. }
  551. /**
  552. * 部门新增
  553. * @param $data
  554. * @param $user
  555. * @return array
  556. */
  557. public function departAdd($data,$user){
  558. list($status,$msg) = $this->departRule($data,$user);
  559. if(!$status) return [$status,$msg];
  560. try {
  561. DB::beginTransaction();
  562. foreach ($msg['data'] as $value){
  563. $model = new Depart();
  564. $model->parent_id = $value['parent_id'];
  565. $model->title = $value['title'];
  566. $model->code = $value['code'];
  567. $model->is_main = $value['is_main'];
  568. $model->save();
  569. $depart_id = $model->id;
  570. if(empty($depart_id)) {
  571. DB::rollBack();
  572. return [false,'部门新建失败'];
  573. }
  574. }
  575. DB::commit();
  576. }catch (\Exception $exception){
  577. DB::rollBack();
  578. return [false,$exception->getMessage()];
  579. }
  580. return [true,'保存成功!'];
  581. }
  582. /**
  583. * 部门删除
  584. * @param $data
  585. * @return array
  586. */
  587. public function departDel($data){
  588. list($status,$msg) = $this->checkDepartDel($data);
  589. if(! $status) return [false, $msg];
  590. Depart::whereIn('id',$data['id'])->update([
  591. 'del_time'=>time()
  592. ]);
  593. return [true,'删除成功'];
  594. }
  595. /**
  596. * 判断部门是否可以删除
  597. * @param $data
  598. * @return array
  599. */
  600. public function checkDepartDel($data){
  601. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  602. $bool = Depart::whereIn('parent_id',$data['id'])->where('del_time',0)->exists();
  603. if($bool) return [false,'部门下有子部门!'];
  604. if($this->checkDepartHasPerson($data['id'])) return [false,'部门下有人员档案!'];
  605. return [true, ''];
  606. }
  607. /**
  608. * 部门列表
  609. * @param $data
  610. * @param $user
  611. * @return array
  612. */
  613. public function departList($data,$user){
  614. $model = Depart::where('del_time',0)
  615. ->select('title','id','code','parent_id','is_use')
  616. ->orderby('id', 'asc');
  617. if(isset($data['parent_id'])) $model->where('parent_id', $data['parent_id']);
  618. if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
  619. if(! empty($data['code'])) $model->where('code', 'LIKE', '%'.$data['code'].'%');
  620. if(isset($data['is_use'])) $model->where('is_use', $data['is_use']);
  621. $list = $model->get()->toArray();
  622. $list = $this->fillDepartList($list, $user);
  623. $list_tree = $list;
  624. if(! empty($list_tree)) {
  625. $list_tree = $this->makeTree(0,$list_tree);
  626. $list_tree = $this->set_sort_circle($list_tree);
  627. }
  628. return [200,['data' => $list,'tree' => $list_tree]];
  629. }
  630. public function fillDepartList($list,$user){
  631. if(empty($list)) return $list;
  632. foreach ($list as $key => $value){
  633. $list[$key]['is_use_title'] = $value['is_use'] ? "启用" : "停用";
  634. }
  635. return $list;
  636. }
  637. //获取可见的部门范围
  638. public function getDepartIdList($user){
  639. $list = Depart::where('del_time',0)->select('id','parent_id')->get()->toArray();
  640. $result = [];
  641. foreach ($user['depart_range'] as $v){
  642. // 查找所有父级id
  643. $parentIds = $this->findParentIds($v, $list);
  644. // 查找所有子级id
  645. $childIds = $this->findChildIds($v, $list);
  646. // 合并父级和子级id
  647. $tmp = array_merge($parentIds, $childIds, [$v]);
  648. $result = array_merge($result,$tmp);
  649. }
  650. return array_unique($result);
  651. }
  652. /**
  653. * 部门参数规则
  654. * @param $data
  655. * @param $is_check
  656. * @return array
  657. */
  658. public function departRule($data,$user, $is_check = true){
  659. if($this->isEmpty($data,'data')) return [false,'数据不能为空!'];
  660. $code = array_column($data['data'],'code');
  661. $title = array_column($data['data'],'title');
  662. $code = array_map(function($val) {
  663. return $val !== null ? $val : 0;
  664. }, $code);
  665. $title = array_map(function($val) {
  666. return $val !== null ? $val : 0;
  667. }, $title);
  668. $code_count = array_count_values($code);
  669. $title_count = array_count_values($title);
  670. foreach ($code as $value){
  671. if(empty($value)) return [false,'编码不能为空!'];
  672. if($code_count[$value] > 1) return [false,'编码不能重复'];
  673. }
  674. foreach ($title as $value){
  675. if(empty($value)) return [false,'名称不能为空!'];
  676. if($title_count[$value] > 1) return [false,'名称不能重复'];
  677. }
  678. foreach ($data['data'] as $key => $value){
  679. if(empty($value['parent_id'])) $data['data'][$key]['parent_id'] = 0;
  680. $data['data'][$key]['upd_time'] = time();
  681. if($is_check){
  682. $data['data'][$key]['crt_time'] = time();
  683. $bool = Depart::whereRaw("binary code = '{$value['code']}'")
  684. ->where('del_time',0)
  685. ->exists();
  686. }else{
  687. if($this->isEmpty($data,'id')) return [false,'id不能为空!'];
  688. $bool = Depart::whereRaw("binary code = '{$value['code']}'")
  689. ->where('id','<>',$data['id'])
  690. ->where('del_time',0)
  691. ->exists();
  692. }
  693. if($bool) return [false,'编码不能重复'];
  694. }
  695. return [true, $data];
  696. }
  697. /**
  698. * 检测部门下是否存在人员
  699. * @param $depart_id
  700. * @return false
  701. */
  702. public function checkDepartHasPerson($depart_id = []){
  703. if(empty($depart_id)) return false;
  704. $bool = EmployeeDepartPermission::from('employee_depart_permission as a')
  705. ->leftJoin('employee as b','b.id','a.employee_id')
  706. ->where('b.del_time',0)
  707. ->whereIn('a.depart_id',$depart_id)
  708. ->exists();
  709. return $bool;
  710. }
  711. /**
  712. * 班组编辑
  713. * @param $data
  714. * @return array
  715. */
  716. public function teamEdit($data){
  717. list($status,$msg) = $this->teamRule($data,false);
  718. if(!$status) return [$status,$msg];
  719. $model = new Team();
  720. $model = $model->where('id',$data['id'])->first();
  721. $model->title = $data['title'];
  722. $model->code = $data['code'];
  723. $model->save();
  724. return [true,'保存成功!'];
  725. }
  726. /**
  727. * 班组新增
  728. * @param $data
  729. * @param $user
  730. * @return array
  731. */
  732. public function teamAdd($data,$user){
  733. list($status,$msg) = $this->teamRule($data);
  734. if(!$status) return [$status,$msg];
  735. $model = new Team();
  736. $model->title = $data['title'] ;
  737. $model->code = $data['code'];
  738. $model->save();
  739. return [true,'保存成功!'];
  740. }
  741. /**
  742. * 班组删除
  743. * @param $data
  744. * @return array
  745. */
  746. public function teamDel($data){
  747. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  748. Team::where('id',$data['id'])->update([
  749. 'del_time'=>time()
  750. ]);
  751. return [true,'删除成功'];
  752. }
  753. /**
  754. * 班组列表
  755. * @param $data
  756. * @return array
  757. */
  758. public function teamList($data){
  759. $list = Team::where('del_time',0)
  760. ->select('title','id','crt_time','upd_time','code')
  761. ->orderBy('id','desc');
  762. $list = $this->limit($list,'',$data);
  763. return [200,$list];
  764. }
  765. /**
  766. * 班组参数规则
  767. * @param $data
  768. * @param $is_add
  769. * @return array
  770. */
  771. public function teamRule($data,$is_add = true){
  772. if($this->isEmpty($data,'title')) return [false,'名称不存在!'];
  773. if($this->isEmpty($data,'code')) return [false,'编码不存在'];
  774. $model = Team::where('title',$data['title'])
  775. ->where('code',$data['code'])
  776. ->where('del_time',0);
  777. if(! $is_add){
  778. if($this->isEmpty($data,'id')) return [false,'ID不能为空'];
  779. $model->where('id','<>',$data['id']);
  780. }
  781. $bool = $model->exists();
  782. if($bool) return [false,'名称和编码已存在!'];
  783. return [true,''];
  784. }
  785. /**
  786. * 班组详情
  787. * @param $data
  788. * @return array
  789. */
  790. public function teamDetail($data){
  791. if($this->isEmpty($data,'id')) return [false,'ID不能为空!'];
  792. $result = EmployeeTeamPermission::from('employee_team_permission as a')
  793. ->leftJoin('employee as b','b.id','a.employee_id')
  794. ->where('team_id',$data['id'])
  795. ->select('b.id','b.emp_name','b.number as code')
  796. ->get()->toArray();
  797. return [true,$result];
  798. }
  799. /**
  800. * 人员权限
  801. * @param $data
  802. * @return array
  803. */
  804. public function employeeRole($data){
  805. $role_ids = [];
  806. $employee_ids = [];
  807. foreach ($data as $v){
  808. if(isset($v['role_id'])){
  809. if(!in_array($v['role_id'],$role_ids)){
  810. $role_ids[] = $v['role_id'];
  811. }
  812. }
  813. if(isset($v['employee_id'])){
  814. if(!in_array($v['employee_id'],$employee_ids)){
  815. $employee_ids[] = $v['employee_id'];
  816. }
  817. }
  818. }
  819. EmployeeMenuPermission::wherein('role_id',$role_ids)->delete();
  820. EmployeeMenuPermission::wherein('employee_id',$employee_ids)->delete();
  821. EmployeeMenuPermission::insert($data);
  822. return [200,'保存成功!'];
  823. }
  824. /**
  825. * 人员部门关系更新
  826. * @param $data
  827. * @return array
  828. */
  829. public function employeeDepart($data){
  830. if($this->isEmpty($data,'insert')) return [false,'数据不能为空!'];
  831. DB::beginTransaction();
  832. try {
  833. if($data['type'] == 1){
  834. EmployeeDepartPermission::whereIn('depart_id',$data['insert']['depart_id'])->delete();
  835. }else{
  836. EmployeeDepartPermission::whereIn('employee_id',$data['insert']['employee_id'])->delete();
  837. }
  838. $insert = [];
  839. foreach ($data['insert']['depart_id'] as $t){
  840. foreach ($data['insert']['employee_id'] as $e){
  841. $insert[] = [
  842. 'depart_id' => $t,
  843. 'employee_id' => $e
  844. ];
  845. }
  846. }
  847. EmployeeDepartPermission::insert($insert);
  848. DB::commit();
  849. }catch (\Throwable $exception){
  850. DB::rollBack();
  851. return [false,$exception->getMessage()];
  852. }
  853. return [true,'保存成功!'];
  854. }
  855. /**
  856. * 人员班组关系更新
  857. * @param $data
  858. * @return array
  859. */
  860. public function employeeTeam($data){
  861. if($this->isEmpty($data,'insert')) return [false,'数据不能为空!'];
  862. DB::beginTransaction();
  863. try {
  864. if($data['type'] == 1){
  865. EmployeeTeamPermission::whereIn('team_id',$data['insert']['team_id'])->delete();
  866. }else{
  867. EmployeeTeamPermission::whereIn('employee_id',$data['insert']['employee_id'])->delete();
  868. }
  869. $insert = [];
  870. foreach ($data['insert']['team_id'] as $t){
  871. foreach ($data['insert']['employee_id'] as $e){
  872. $insert[] = [
  873. 'team_id' => $t,
  874. 'employee_id' => $e
  875. ];
  876. }
  877. }
  878. EmployeeTeamPermission::insert($insert);
  879. DB::commit();
  880. }catch (\Throwable $exception){
  881. DB::rollBack();
  882. return [false,$exception->getMessage()];
  883. }
  884. return [true,'保存成功!'];
  885. }
  886. /**
  887. * 登陆参数规则
  888. * @param $data
  889. * @return array
  890. */
  891. public function loginRule($data){
  892. if($this->isEmpty($data,'account')) return [false,'账号不能为空!'];
  893. if($this->isEmpty($data,'password')) return [false,'密码不存在!'];
  894. $account = $data['account'];
  895. $res = Employee::where('del_time',0)
  896. ->where(function ($query)use($account) {
  897. $query->where('account', $account)
  898. ->orWhere('mobile', $account);
  899. })
  900. ->get()->toArray();
  901. if(empty($res)) return [false,'账号不存在或已被删除'];
  902. if(count($res) > 1) return [false,'该手机号检测出多个账户,请联系后台管理员'];
  903. $res = reset($res);
  904. if(! Hash::check($data['password'], $res['password'])) return [false,'密码错误'];
  905. if($res['is_admin'] != Employee::IS_ADMIN) return [false,'账号限制登录'];
  906. if($res['state'] == Employee::NOT_USE) return [false,'账号已停用'];
  907. return [true, ['id'=>$res['id'],'name'=>$res['emp_name'], 'number' => $res['number']]];
  908. }
  909. /**
  910. * 检查人员信息
  911. * @param $userId
  912. * @return array
  913. */
  914. public static function checkUser($userId){
  915. $res = Employee::where('id', $userId)
  916. ->where('del_time',0)
  917. ->where('is_admin',Employee::IS_ADMIN)
  918. ->where('state',Employee::USE)->get()->first();
  919. if(empty($res)) return [false, '该账号无法登录,请联系管理员!'];
  920. return [true, $res];
  921. }
  922. /**
  923. * 获取登录账号的角色
  924. * @param $employee_id
  925. * @return array
  926. */
  927. public static function getPersonRole($employee_id){
  928. if(empty($employee_id) || $employee_id == Employee::SPECIAL_ADMIN) return [];
  929. $role = EmployeeRole::where('del_time',0)
  930. ->where('employee_id',$employee_id)
  931. ->select('role_id')
  932. ->get()->toArray();
  933. //组织
  934. $role_id = array_unique(array_column($role,'role_id'));
  935. asort($role_id);
  936. return array_values($role_id);
  937. }
  938. public static function getPersonRoleQx($role_id = []){
  939. if(empty($role_id)) return [];
  940. $role = RoleMenu::where('del_time',0)
  941. ->whereIn('role_id',$role_id)
  942. ->select('menu_id','type')
  943. ->get()->toArray();
  944. $sys_menu = SysMenu::where('del_time',0)
  945. ->where('is_authority','>',0)
  946. ->select('id')
  947. ->get()->toArray();
  948. $sys_menu_id = array_column($sys_menu,'id');
  949. $return = [];
  950. foreach ($role as $value){
  951. if(! in_array($value['menu_id'],$sys_menu_id)) continue;
  952. if(isset($return[$value['menu_id']])){
  953. if($return[$value['menu_id']] < $value['type']) $return[$value['menu_id']] = $value['type'];
  954. }else{
  955. $return[$value['menu_id']] = $value['type'];
  956. }
  957. }
  958. return $return;
  959. }
  960. public static function getSpecialButton($role_id,$user){
  961. $return = [];
  962. $special_button = config('specialButton');
  963. if($user == Employee::SPECIAL_ADMIN) {
  964. foreach ($special_button as $value){
  965. $return[] = $value['id'];
  966. }
  967. return $return;
  968. }
  969. $role_button = RoleMenuButton::where('del_time',0)
  970. ->where('button_id','<',0)
  971. ->whereIn('role_id',$role_id)
  972. ->select('menu_id','button_id')
  973. ->get()->toArray();
  974. foreach ($role_button as $value){
  975. $return[] = $value['button_id'];
  976. }
  977. return $return;
  978. }
  979. //通过角色获取菜单
  980. public function getMenuByRoleInList($user){
  981. $role_id = $user['role'] ?? [];
  982. $menu = SysMenu::where('del_time',0)->select('id')->get()->toArray();
  983. if($user['id'] == Employee::SPECIAL_ADMIN) return array_column($menu,'id');
  984. //没绑定角色
  985. if(empty($role_id)) return [];
  986. $role_menu = RoleMenu::whereIn('role_id',$role_id)
  987. ->where('del_time',0)
  988. ->select('menu_id')
  989. ->get()->toArray();
  990. return array_column($role_menu,'menu_id');
  991. }
  992. //通过角色获取菜单以及按钮
  993. public function getMenuByRole($user){
  994. $role_id = $user['role'] ?? [];
  995. $menu = SysMenu::where('del_time',0)->select('id','uri')->get()->toArray();
  996. $button = SysMenuButton::where('del_time',0)->select('id','title','sort','func','menu_id')->get()->toArray();
  997. $button_map = [];
  998. foreach ($button as $value){
  999. $button_map[$value['menu_id']][] = $value;
  1000. }
  1001. $special_button = config('specialButton');
  1002. foreach ($special_button as $value){
  1003. $button_map[$value['menu_id']][] = $value;
  1004. }
  1005. $object = [];
  1006. //超级管理员
  1007. if($user['id'] == Employee::SPECIAL_ADMIN){
  1008. foreach ($menu as $value){
  1009. $object[] = [
  1010. 'id' => $value['id'],
  1011. // 'type' => 0,//所有权限
  1012. 'uri' => $value['uri'],
  1013. 'button' => $button_map[$value['id']] ?? [],
  1014. ];
  1015. }
  1016. }else{
  1017. //没绑定角色
  1018. if(empty($role_id)) return [];
  1019. $search = RoleMenu::whereIn('role_id',$role_id)
  1020. ->where('del_time',0)
  1021. ->select('menu_id','type')
  1022. ->get()->toArray();
  1023. $menu_map = array_column($menu,'uri','id');
  1024. //该角色下 菜单里所有按钮
  1025. $button_menu = $this->fillRoleButton($role_id);
  1026. foreach ($search as $value){
  1027. $bt = $button_menu[$value['menu_id']] ?? [];
  1028. $new = [];
  1029. $button_tmp = $button_map[$value['menu_id']] ?? [];
  1030. $button_tmp = array_column($button_tmp,null,'id');
  1031. foreach ($bt as $b){
  1032. if(! empty($button_tmp[$b])) $new[] = $button_tmp[$b];
  1033. }
  1034. $object[] = [
  1035. 'id' => $value['menu_id'],
  1036. 'uri' => $menu_map[$value['menu_id']] ?? '',
  1037. // 'type' => $value['type'],
  1038. 'button' => $new,
  1039. ];
  1040. }
  1041. }
  1042. return $object;
  1043. }
  1044. /**
  1045. * 人员直接绑定部门
  1046. * @param $data
  1047. * @param $user
  1048. * @return array
  1049. */
  1050. public function employeeManagerDepart($data,$user){
  1051. if($user['id'] != Employee::SPECIAL_ADMIN) return [false,'非ADMIN账号不能操作'];
  1052. if($this->isEmpty($data,'employee_id')) return [false,'请选择操作人员'];
  1053. if($this->isEmpty($data,'depart_id')) return [false,'请选择部门'];
  1054. EmployeeManagerDepart::where('employee_id',$data['employee_id'])->update([
  1055. 'del_time' => time()
  1056. ]);
  1057. $insert = [];
  1058. foreach ($data['depart_id'] as $value){
  1059. $insert[] = [
  1060. 'employee_id' => $data['employee_id'],
  1061. 'depart_id' => $value,
  1062. 'crt_time' => time(),
  1063. 'upd_time' => time(),
  1064. ];
  1065. }
  1066. EmployeeManagerDepart::insert($insert);
  1067. return [true,''];
  1068. }
  1069. /**
  1070. * 填充角色下的按钮
  1071. * @param $role_id
  1072. * @return array
  1073. */
  1074. public function fillRoleButton($role_id){
  1075. $button = RoleMenuButton::whereIn('role_id',$role_id)
  1076. ->where('del_time',0)
  1077. ->select('menu_id','button_id')
  1078. ->get()->toArray();
  1079. $button_map = [];
  1080. foreach ($button as $value){
  1081. if(! isset($button_map[$value['menu_id']])){
  1082. $button_map[$value['menu_id']][] = $value['button_id'];
  1083. }else{
  1084. if(! in_array($value['button_id'], $button_map[$value['menu_id']])) $button_map[$value['menu_id']][] = $value['button_id'];
  1085. }
  1086. }
  1087. return $button_map;
  1088. }
  1089. /**
  1090. * 获取登录账号的部门
  1091. * @param $employee_id
  1092. * @return array|string[]
  1093. */
  1094. public static function getLoginDepart($employee_id){
  1095. if(empty($employee_id)) return [];
  1096. //自己绑定的部门 且 启用的部门
  1097. $depart = EmployeeDepartPermission::from('employee_depart_permission as a')
  1098. ->join('depart as b','b.id','a.depart_id')
  1099. ->where('a.employee_id',$employee_id)
  1100. ->where('b.is_use',Depart::IS_UES)
  1101. ->select('a.depart_id')
  1102. ->orderBy('b.parent_id','asc')
  1103. ->orderBy('a.depart_id','asc')
  1104. ->get()->toArray();
  1105. return $depart;
  1106. }
  1107. /**
  1108. * 获取顶级id
  1109. * @param $id
  1110. * @param $data
  1111. * @return int
  1112. */
  1113. public static function getTopParentId($id, $data) {
  1114. foreach ($data as $item) {
  1115. if ($item['id'] == $id) {
  1116. if ($item['parent_id'] == 0) {
  1117. // 找到最顶级的id
  1118. return $item['id'];
  1119. } else {
  1120. // 继续递归查找父级
  1121. return self::getTopParentId($item['parent_id'], $data);
  1122. }
  1123. }
  1124. }
  1125. // 如果没有找到匹配的id,则返回null或者其他你希望的默认值
  1126. return 0;
  1127. }
  1128. /**
  1129. * 递归获取所有id
  1130. * @param $data
  1131. * @param $id
  1132. * @return array
  1133. */
  1134. public static function getAllIds($data, $id) {
  1135. $result = array(); // 存储结果的数组
  1136. foreach ($data as $node) {
  1137. if ($node['parent_id'] == $id) { // 如果当前节点的父 ID 等于指定 ID,则将该节点添加到结果中
  1138. $result[] = $node['id'];
  1139. // 递归查询该节点的所有子孙节点,并将结果合并到结果数组中
  1140. $result = array_merge($result, self::getAllIds($data, $node['id']));
  1141. }
  1142. }
  1143. return $result;
  1144. }
  1145. public static function checkWxUser($userId){
  1146. $res = Employee::where('id', $userId)
  1147. ->where('del_time',0)
  1148. ->where('state',Employee::USE)->get()->first();
  1149. if(empty($res)) return [false, '该账号无法登录,请联系管理员!'];
  1150. return [true, $res];
  1151. }
  1152. public function getTopMessage($data,$user){
  1153. $top = $user['depart_top'] ?? [];
  1154. return [true, ['top' => $top]];
  1155. }
  1156. public function searchByEmpName($emp_name){
  1157. $emp = Employee::where('del_time',0)
  1158. ->where('emp_name', 'LIKE', '%'.$emp_name.'%')
  1159. ->select('id')
  1160. ->get()->toArray();
  1161. return array_column($emp,'id');
  1162. }
  1163. }