EmployeeService.php 43 KB

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