EmployeeService.php 44 KB

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