EmployeeService.php 58 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687
  1. <?php
  2. namespace App\Service;
  3. use App\Model\BasicType;
  4. use App\Model\Depart;
  5. use App\Model\DepartIndex;
  6. use App\Model\Employee;
  7. use App\Model\EmployeeDepartPermission;
  8. use App\Model\EmployeeFile;
  9. use App\Model\EmployeeManagerDepart;
  10. use App\Model\EmployeeMenuPermission;
  11. use App\Model\EmployeeRole;
  12. use App\Model\EmployeeTeamPermission;
  13. use App\Model\ProductInventory;
  14. use App\Model\ProductInventorySet;
  15. use App\Model\Role;
  16. use App\Model\RoleMenu;
  17. use App\Model\RoleMenuButton;
  18. use App\Model\Storehouse;
  19. use App\Model\Supplier;
  20. use App\Model\SysMenu;
  21. use App\Model\SysMenuButton;
  22. use App\Model\Team;
  23. use App\Model\WxEmployeeOfficial;
  24. use App\Service\Weixin\WeixinService;
  25. use Illuminate\Support\Facades\DB;
  26. use Illuminate\Support\Facades\Hash;
  27. use Mockery\Exception;
  28. /**
  29. * 人员相关
  30. * @package App\Models
  31. */
  32. class EmployeeService extends Service
  33. {
  34. public function employeeEditImg($data, $user){
  35. $time = time();
  36. try {
  37. DB::beginTransaction();
  38. $old = EmployeeFile::where('del_time',0)
  39. ->where('employee_id',$user['id'])
  40. ->select('file')
  41. ->get()->toArray();
  42. $old = array_column($old,'file');
  43. EmployeeFile::where('del_time',0)
  44. ->where('employee_id',$user['id'])
  45. ->update(['del_time' => $time]);
  46. $new = [];
  47. $insert = [];
  48. if(! empty($data['img_url'])){
  49. $insert[] = [
  50. 'employee_id' => $user['id'],
  51. 'file' => $data['img_url'],
  52. 'crt_time' => $time,
  53. ];
  54. EmployeeFile::insert($insert);
  55. $new[] = $data['img_url'];
  56. }
  57. DB::commit();
  58. }catch (\Throwable $exception){
  59. DB::rollBack();
  60. return [false, $exception->getMessage()];
  61. }
  62. return [true, ['file' => ['new' => $new, 'old' => $old]]];
  63. }
  64. public function getEmployeeImg($user){
  65. $file = EmployeeFile::where('del_time',0)
  66. ->where('employee_id',$user['id'])
  67. ->select('file')
  68. ->get()->toArray();
  69. $file = array_column($file,'file');
  70. $file = $file[0] ?? "";
  71. $img_str = "";
  72. $timpstamp = 86400;
  73. if(! empty($file)){
  74. $fileUploadService = new FileUploadService();
  75. $img_str = $fileUploadService->getFileShow($file, $timpstamp);
  76. }
  77. return [true, ['img_url' => $img_str]];
  78. }
  79. public function employeeEditOther($data,$user){
  80. list($status,$msg) = $this->employeeOtherRule($data,$user);
  81. if(!$status) return [$status,$msg];
  82. try {
  83. DB::beginTransaction();
  84. $model = new Employee();
  85. $model = $model->where('id',$user['id'])->first();
  86. $model->password = Hash::make($data['new_password']);
  87. $model->save();
  88. DB::commit();
  89. }catch (\Exception $exception){
  90. DB::rollBack();
  91. return [false, $exception->getMessage()];
  92. }
  93. return [true,''];
  94. }
  95. public function employeeOtherRule($data,$user){
  96. if(! isset($data['old_password'])) return [false,'请输入原密码'];
  97. if($data['old_password'] == "") return [false,'原密码不能为空'];
  98. if(! isset($data['new_password'])) return [false,'请输入新密码'];
  99. if($data['new_password'] == "") return [false,'新密码不能为空'];
  100. if(! isset($data['re_password'])) return [false,'请输入确认密码'];
  101. if($data['re_password'] == "") return [false,'确认密码不能为空'];
  102. if(! Hash::check($data['old_password'], $user['password'])) return [false,'原密码错误'];
  103. if($data['new_password'] == $data['old_password']) return [false,'原密码与新密码一致'];
  104. if($data['new_password'] !== $data['re_password']) return [false,'新密码与确认密码不一致'];
  105. return [true,''];
  106. }
  107. /**
  108. * 用户编辑
  109. * @param $data
  110. * @param $user
  111. * @return array
  112. */
  113. public function employeeEdit($data,$user){
  114. list($status,$msg) = $this->employeeRule($data,false);
  115. if(!$status) return [$status,$msg];
  116. try {
  117. DB::beginTransaction();
  118. $model = new Employee();
  119. $model = $model->where('id',$data['id'])->first();
  120. $model->number = $data['number'];
  121. $model->emp_name = $data['emp_name'];
  122. $model->mobile = $data['mobile'] ?? '';
  123. $model->leave_time = $data['leave_time'] ?? '';
  124. $model->entry_time = $data['entry_time'] ?? '';
  125. $model->state = empty($data['leave_time']) ? Employee::USE : Employee::NOT_USE;
  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. EmployeeDepartPermission::where('employee_id',$data['id'])->delete();
  135. if(isset($data['depart'])){
  136. $insert = [];
  137. foreach ($data['depart'] as $value){
  138. $insert[] = [
  139. 'employee_id' => $model->id,
  140. 'depart_id' => $value,
  141. ];
  142. }
  143. EmployeeDepartPermission::insert($insert);
  144. }
  145. EmployeeRole::where('employee_id',$data['id'])->update([
  146. 'del_time' => time()
  147. ]);
  148. if(isset($data['role'])){
  149. $insert = [];
  150. foreach ($data['role'] as $value){
  151. $insert[] = [
  152. 'employee_id' => $model->id,
  153. 'role_id' => $value,
  154. 'crt_time' => time(),
  155. 'upd_time' => time(),
  156. ];
  157. }
  158. EmployeeRole::insert($insert);
  159. }
  160. DB::commit();
  161. }catch (\Exception $exception){
  162. DB::rollBack();
  163. return [false, $exception->getMessage()];
  164. }
  165. return [true,''];
  166. }
  167. /**
  168. * 用户新增
  169. * @param $data
  170. * @param $user
  171. * @return array
  172. */
  173. public function employeeAdd($data,$user){
  174. list($status,$msg) = $this->employeeRule($data);
  175. if(!$status) return [$status,$msg];
  176. try{
  177. DB::beginTransaction();
  178. $model = new Employee();
  179. $model->number = $data['number'];
  180. $model->emp_name = $data['emp_name'];
  181. $model->mobile = $data['mobile'] ?? '';
  182. $model->leave_time = $data['leave_time'] ?? '';
  183. $model->entry_time = $data['entry_time'] ?? '';
  184. $model->state = empty($data['leave_time']) ? Employee::USE : Employee::NOT_USE;
  185. $model->crt_id = $user['id'];
  186. $model->is_admin = $data['is_admin'];
  187. $model->account = $data['number'];
  188. if($model->is_admin == 1){
  189. if($data['password'] !== '********'){
  190. $model->password = Hash::make($data['password']);
  191. }
  192. }
  193. $model->save();
  194. if(isset($data['depart'])){
  195. $insert = [];
  196. foreach ($data['depart'] as $value){
  197. $insert[] = [
  198. 'employee_id' => $model->id,
  199. 'depart_id' => $value,
  200. ];
  201. }
  202. EmployeeDepartPermission::insert($insert);
  203. }
  204. if(isset($data['role'])){
  205. $insert = [];
  206. foreach ($data['role'] as $value){
  207. $insert[] = [
  208. 'employee_id' => $model->id,
  209. 'role_id' => $value,
  210. 'crt_time' => time(),
  211. 'upd_time' => time(),
  212. ];
  213. }
  214. EmployeeRole::insert($insert);
  215. }
  216. DB::commit();
  217. }catch (Exception $e){
  218. DB::rollBack();
  219. return [false, $e->getMessage()];
  220. }
  221. return [true,''];
  222. }
  223. /**
  224. * 用户删除
  225. * @param $data
  226. * @return array
  227. */
  228. public function employeeDel($data){
  229. if($this->isEmpty($data,'id')) return [false,'请选择删除的数据!'];
  230. Employee::whereIn('id',$data['id'])->update([
  231. 'del_time'=>time()
  232. ]);
  233. EmployeeRole::where('del_time',0)->whereIn('employee_id',$data['id'])->update([
  234. 'del_time'=>time()
  235. ]);
  236. return [true,'删除成功'];
  237. }
  238. /**
  239. * 用户列表
  240. * @param $data
  241. * @param $user
  242. * @return array
  243. */
  244. public function employeeList($data,$user){
  245. $model = Employee::where('del_time',0)
  246. ->select('number','mobile','emp_name','id','entry_time','leave_time','is_admin','state')
  247. ->orderBy('id','desc');
  248. if(! empty($data['depart'])) {
  249. $depart = Depart::where('del_time',0)
  250. ->select('id','parent_id')
  251. ->get()->toArray();
  252. $result = array_merge($this->getAllDescendants($depart,$data['depart']),[$data['depart']]);
  253. $employee_id = DB::table('employee_depart_permission')
  254. ->whereIn("depart_id", $result)
  255. ->select("employee_id")
  256. ->get()->toArray();
  257. $employee_id = array_column($employee_id,'employee_id');
  258. $model->whereIn("id", $employee_id);
  259. }else{
  260. if(! $user['is_all_depart']){
  261. $employee_id = $this->getEmployee($user);
  262. $model->whereIn('id',$employee_id);
  263. }
  264. }
  265. if(! empty($data['number'])) $model->where('number', 'LIKE', '%'.$data['number'].'%');
  266. if(! empty($data['emp_name'])) $model->where('emp_name', 'LIKE', '%'.$data['emp_name'].'%');
  267. if(! empty($data['state'])) $model->where('state',$data['state']);
  268. if(! empty($data['mobile'])) $model->where('mobile', 'LIKE', '%'.$data['mobile'].'%');
  269. if(! isset($data['all_emp'])) $model->where('id','<>',Employee::SPECIAL_ADMIN);
  270. if(! empty($data['role'])) {
  271. $emp = EmployeeRole::where('role_id',$data['role'])
  272. ->where('del_time',0)
  273. ->select('employee_id')->get()->toArray();
  274. $model->whereIn('id',array_column($emp,'employee_id'));
  275. }
  276. if($user['id'] != Employee::SPECIAL_ADMIN) $model->where('is_manager',0);
  277. $list = $this->limit($model,'',$data);
  278. //组织数据
  279. $list = $this->organizationEmployeeData($list);
  280. return [true , $list];
  281. }
  282. /**
  283. * 用户数据组装
  284. * @param $data
  285. * @return array
  286. */
  287. public function organizationEmployeeData($data) {
  288. if (empty($data['data'])) return $data;
  289. $res = DB::table('employee_role as a')
  290. ->leftJoin('role as b','a.role_id','=','b.id')
  291. ->where('a.del_time',0)
  292. ->where('b.del_time',0)
  293. ->whereIn("a.employee_id",array_column($data['data'],'id'))
  294. ->select('a.employee_id','b.title','b.id')
  295. ->get()->toArray();
  296. $role = $role2 = [];
  297. foreach ($res as $value){
  298. if(isset($role[$value->employee_id])){
  299. $role[$value->employee_id] .= ',' . $value->title;
  300. }else{
  301. $role[$value->employee_id] = $value->title;
  302. }
  303. $role2[$value->employee_id][] = $value->id;
  304. }
  305. $res = DB::table('employee_depart_permission as a')
  306. ->select('a.employee_id','b.title','b.id')
  307. ->join('depart as b','a.depart_id','=','b.id')
  308. ->whereIn("a.employee_id",array_column($data['data'],'id'))
  309. ->orderBy('b.id')
  310. ->get()->toArray();
  311. $depart_title = $depart_id = [];
  312. foreach ($res as $value){
  313. if(isset($depart_title[$value->employee_id])){
  314. $depart_title[$value->employee_id] .= ',' . $value->title;
  315. }else{
  316. $depart_title[$value->employee_id] = $value->title;
  317. }
  318. $depart_id[$value->employee_id][] = $value->id;
  319. }
  320. $wx = WxEmployeeOfficial::where('appid',WeixinService::APPID)
  321. ->where('employee_id','>',0)
  322. ->select('employee_id')
  323. ->get()->toArray();
  324. $wx = array_column($wx,'employee_id');
  325. foreach ($data['data'] as $key => $value){
  326. $data['data'][$key]['role'] = $role2[$value['id']] ?? [];
  327. $data['data'][$key]['role_name'] = $role[$value['id']] ?? '';
  328. $data['data'][$key]['depart'] = $depart_id[$value['id']] ?? [];
  329. $data['data'][$key]['depart_title'] = $depart_title[$value['id']] ?? '';
  330. $is_wx = "未绑定微信公众号";
  331. if(in_array($value['id'], $wx)) $is_wx = "已绑定微信公众号";
  332. $data['data'][$key]['is_wx'] = $is_wx;
  333. }
  334. return $data;
  335. }
  336. //获取当前顶级部门下人员id
  337. public function getEmployee($user){
  338. $top_depart_id = $user['depart_top'][0] ?? [];
  339. $top_depart_id = $top_depart_id['depart_id'] ?? 0;
  340. $list = Depart::where('del_time',0)->select('id','parent_id')->get()->toArray();
  341. // 查找所有子级id
  342. $childIds = $this->findChildIds($top_depart_id, $list);
  343. $childIds[] = $top_depart_id;
  344. $employee_id = EmployeeDepartPermission::whereIn('depart_id',$childIds)
  345. ->select("employee_id")
  346. ->get()->toArray();
  347. return array_unique(array_column($employee_id,'employee_id'));
  348. }
  349. /**
  350. * 用户参数规则
  351. * @param $data
  352. * @param $is_add
  353. * @return array
  354. */
  355. public function employeeRule($data,$is_add = true){
  356. if($this->isEmpty($data,'number')) return [false,'工号不存在!'];
  357. if($this->isEmpty($data,'emp_name')) return [false,'姓名不存在!'];
  358. if(empty($data['depart'])) return [false,'部门不能为空'];
  359. $mobile = $data['mobile'] ?? "";
  360. $number = $data['number'] ?? "";
  361. if(! $is_add){
  362. if($this->isEmpty($data,'id')) return [false,'ID不能为空!'];
  363. $bool = Employee::where('del_time',0)
  364. ->where('id','<>',$data['id'])
  365. ->where(function ($query) use ($mobile, $number){
  366. $query->where('number', $number);
  367. $query->when(! empty($mobile), function ($query) use ($mobile) {
  368. return $query->orWhere('mobile', $mobile);
  369. });
  370. })->exists();
  371. }else{
  372. $bool = Employee::where('del_time',0)
  373. ->where(function ($query) use ($mobile, $number){
  374. $query->where('number', $number);
  375. $query->when(! empty($mobile), function ($query) use ($mobile) {
  376. return $query->orWhere('mobile', $mobile);
  377. });
  378. })->exists();
  379. }
  380. if($bool) return [false,'工号或手机号码已存在!'];
  381. return [true,''];
  382. }
  383. /**
  384. * 角色编辑
  385. * @param $data
  386. * @return array
  387. */
  388. public function roleEdit($data,$user){
  389. list($status,$msg) = $this->roleRule($data,$user, false);
  390. if(!$status) return [$status,$msg];
  391. $model = new Role();
  392. $model = $model->where('id',$data['id'])->first();
  393. $model->title = $data['title'];
  394. $model->save();
  395. return [true,'保存成功!'];
  396. }
  397. /**
  398. * 角色新增
  399. * @param $data
  400. * @param $user
  401. * @return array
  402. */
  403. public function roleAdd($data,$user){
  404. list($status,$msg) = $this->roleRule($data,$user);
  405. if(!$status) return [$status,$msg];
  406. $model = new Role();
  407. $model->title = $data['title'] ;
  408. $model->depart_id = $data['depart_id'] ?? 0;
  409. $model->top_depart_id = $data['top_depart_id'] ?? 0;
  410. $model->save();
  411. return [true,'保存成功!'];
  412. }
  413. /**
  414. * 角色删除
  415. * @param $data
  416. * @return array
  417. */
  418. public function roleDel($data){
  419. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  420. $bool = EmployeeRole::where('del_time',0)
  421. ->whereIn('role_id',$data['id'])
  422. ->exists();
  423. if($bool) return [false,'角色已绑定人员!'];
  424. Role::where('id',$data['id'])->update([
  425. 'del_time' => time()
  426. ]);
  427. RoleMenu::where('del_time',0)->where('role_id',$data['id'])->update([
  428. 'del_time' => time()
  429. ]);
  430. RoleMenuButton::where('del_time',0)->where('role_id',$data['id'])->update([
  431. 'del_time' => time()
  432. ]);
  433. return [true,'删除成功'];
  434. }
  435. /**
  436. * 角色列表
  437. * @param $data
  438. * @return array
  439. */
  440. public function roleList($data,$user){
  441. $model = Role::TopClear($user,$data);
  442. $model = $model->where('del_time',0)
  443. ->select('title','crt_time','id','upd_time')
  444. ->orderBy('id','desc');
  445. if(! empty($data['title'])) $model->where('title', 'LIKE', '%' . $data['title'] . '%');
  446. $list = $this->limit($model,'',$data);
  447. return [200,$list];
  448. }
  449. /**
  450. * 角色参数规则
  451. * @param $data
  452. * @param $is_check
  453. * @return array
  454. */
  455. public function roleRule(&$data,$user, $is_check = true){
  456. if($this->isEmpty($data,'title')) return [false,'名称不能为空!'];
  457. //所属部门 以及 顶级部门
  458. if(empty($data['depart_id'])) $data['depart_id'] = $this->getDepart($user);
  459. $data['top_depart_id'] = $user['depart_map'][$data['depart_id']] ?? 0;
  460. if($is_check){
  461. $bool = Role::where('title',$data['title'])
  462. ->where('top_depart_id',$data['top_depart_id'])
  463. ->where('del_time',0)
  464. ->exists();
  465. if($bool) return [false,'角色名称已存在!'];
  466. }else{
  467. if($this->isEmpty($data,'id')) return [false,'ID不能为空!'];
  468. $top_depart_id = Role::where('id',$data['id'])->value('top_depart_id');
  469. $bool = Role::where('title',$data['title'])
  470. ->where('top_depart_id',$top_depart_id)
  471. ->where('id','<>',$data['id'])
  472. ->where('del_time',0)
  473. ->exists();
  474. if($bool) return [false,'角色名称已存在!'];
  475. }
  476. return [true,''];
  477. }
  478. /**
  479. * 角色菜单更新
  480. * @param $data
  481. * @return array
  482. */
  483. public function roleMenu($data){
  484. if(empty($data['role_id'])) return [false,'角色不能为空!'];
  485. if(empty($data['menu'])) return [false,'菜单数据不能为空!'];
  486. DB::beginTransaction();
  487. try {
  488. RoleMenu::where('del_time',0)->where('role_id',$data['role_id'])->update(['del_time' => time()]);
  489. RoleMenuButton::where('del_time',0)->where('role_id',$data['role_id'])->update(['del_time' => time()]);
  490. $insert = $insert2 = [];
  491. foreach ($data['menu'] as $t){
  492. $insert[] = [
  493. 'role_id' => $data['role_id'],
  494. 'menu_id' => $t['menu_id'],
  495. 'type' => $t['type'],
  496. 'crt_time' => time()
  497. ];
  498. if(! empty($t['button'])){
  499. foreach ($t['button'] as $b){
  500. $insert2[] = [
  501. 'role_id' => $data['role_id'],
  502. 'menu_id' => $t['menu_id'],
  503. 'button_id' => $b,
  504. 'crt_time' => time()
  505. ];
  506. }
  507. RoleMenuButton::insert($insert2);
  508. }
  509. }
  510. RoleMenu::insert($insert);
  511. DB::commit();
  512. }catch (\Throwable $exception){
  513. DB::rollBack();
  514. return [false,$exception->getMessage()];
  515. }
  516. return [true,'保存成功!'];
  517. }
  518. /**
  519. * 角色详情
  520. * @param $data
  521. * @return array
  522. */
  523. public function roleDetail($data){
  524. if(empty($data['role_id'])) return [false,'请选择角色'];
  525. $role = Role::where('id',$data['role_id'])
  526. ->where('del_time',0)
  527. ->select('id','title')
  528. ->first();
  529. if(empty($role)) return [false,'角色不存在或已被删除'];
  530. $role = $role->toArray();
  531. $menu = RoleMenu::where('role_id',$data['role_id'])
  532. ->where('del_time',0)
  533. ->select('menu_id','type')
  534. ->get()->toArray();
  535. $button = $this->fillRoleButton([$data['role_id']]);
  536. foreach ($menu as $key => $value){
  537. $menu[$key]['button'] = $button[$value['menu_id']] ?? [];
  538. }
  539. $role['menu'] = $menu;
  540. return [true, $role];
  541. }
  542. public function departSetIndex($data,$user){
  543. if(empty($data['data'])) return [false, '指标数据不能为空'];
  544. $time = time();
  545. $insert = [];
  546. foreach ($data['data'] as $value){
  547. if(empty($value['top_depart_id'])) return [false, '请选择门店'];
  548. if(! isset($value['param_one'])) return [false, '请填写销售额'];
  549. if(in_array(0.0, floatval($value['param_one']), true)) return [false,'销售额不能为空'];
  550. $insert[] = [
  551. 'top_depart_id' => $value['top_depart_id'],
  552. 'param_one' => $value['param_one'],
  553. 'crt_time' => $time,
  554. ];
  555. }
  556. if(empty($insert)) return [true, ''];
  557. //删除指标
  558. DepartIndex::where('del_time',0)
  559. ->update(['del_time' => $time]);
  560. //写入指标
  561. DepartIndex::insert($insert);
  562. return [true, ''];
  563. }
  564. /**
  565. * 部门编辑
  566. * @param $data
  567. * @return array
  568. */
  569. public function departEdit($data, $user){
  570. list($status,$msg) = $this->departRule($data,$user,false);
  571. if(!$status) return [$status,$msg];
  572. $update = $msg['data'][0];
  573. $model = new Depart();
  574. $model->where('id',$data['id'])->update($update);
  575. return [true,'保存成功!'];
  576. }
  577. /**
  578. * 部门新增
  579. * @param $data
  580. * @param $user
  581. * @return array
  582. */
  583. public function departAdd($data,$user){
  584. list($status,$msg) = $this->departRule($data,$user);
  585. if(!$status) return [$status,$msg];
  586. try {
  587. DB::beginTransaction();
  588. $time = time();
  589. foreach ($msg['data'] as $value){
  590. $model = new Depart();
  591. $model->parent_id = $value['parent_id'];
  592. $model->title = $value['title'];
  593. $model->code = $value['code'];
  594. $model->is_main = $value['is_main'];
  595. $model->basic_type_id = $value['basic_type_id'] ?? 0;
  596. $model->rate = $value['rate'] ?? 0;
  597. $model->notify_id = $value['notify_id'] ?? 0;
  598. $model->area = $value['area'] ?? 0;
  599. $model->province = $value['province'] ?? "";
  600. $model->save();
  601. $depart_id = $model->id;
  602. if(empty($depart_id)) {
  603. DB::rollBack();
  604. return [false,'部门新建失败'];
  605. }
  606. if(empty($value['parent_id'])){
  607. $m = new Storehouse();
  608. $m->title = $value['title'];
  609. $m->depart_id = $depart_id;
  610. $m->top_depart_id = $depart_id;
  611. $m->crt_id = $user['id'];
  612. $m->save();
  613. if(empty($m->id)) {
  614. DB::rollBack();
  615. return [false,'仓库生成失败'];
  616. }
  617. $employee = new Employee();
  618. $number = "admin" . $value['code'];
  619. $employee->number = $number;
  620. $employee->emp_name = $value['title'] . "管理员账号";
  621. $employee->entry_time = date('Y-m-d');
  622. $employee->state = 1;
  623. $employee->crt_id = $user['id'];
  624. $employee->is_admin = 1;
  625. $employee->account = $number;
  626. $employee->password = Hash::make("password");
  627. $employee->is_manager = 1;
  628. $employee->save();
  629. if(empty($employee->id)) {
  630. DB::rollBack();
  631. return [false,'管理员账号生成失败'];
  632. }
  633. $depart = new EmployeeDepartPermission();
  634. $depart->employee_id = $employee->id;
  635. $depart->depart_id = $depart_id;
  636. $depart->save();
  637. if(empty($depart->id)) {
  638. DB::rollBack();
  639. return [false,'管理员账号部门关联生成失败'];
  640. }
  641. //公司系统设置
  642. ProductInventorySet::insert(['top_depart_id' => $depart_id, 'param_one' => 1, 'crt_time' => $time]);
  643. // if(! empty($value['is_main'])){
  644. // //总供应商 所有分社可见
  645. // Supplier::insert([
  646. // 'title' => $value['title'],
  647. // 'crt_id' => $user['id'],
  648. // 'crt_time' => $time,
  649. // 'depart_id' => $depart_id,
  650. // 'top_depart_id' => $depart_id,
  651. // 'is_main' => Supplier::is_main,
  652. // ]);
  653. // }
  654. }
  655. }
  656. DB::commit();
  657. }catch (\Exception $exception){
  658. DB::rollBack();
  659. return [false,$exception->getMessage()];
  660. }
  661. return [true,'保存成功!'];
  662. }
  663. /**
  664. * 部门删除
  665. * @param $data
  666. * @return array
  667. */
  668. public function departDel($data){
  669. list($status,$msg) = $this->checkDepartDel($data);
  670. if(! $status) return [false, $msg];
  671. Depart::whereIn('id',$data['id'])->update([
  672. 'del_time'=>time()
  673. ]);
  674. return [true,'删除成功'];
  675. }
  676. /**
  677. * 判断部门是否可以删除
  678. * @param $data
  679. * @return array
  680. */
  681. public function checkDepartDel($data){
  682. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  683. $bool = Depart::whereIn('parent_id',$data['id'])->where('del_time',0)->exists();
  684. if($bool) return [false,'部门下有子部门!'];
  685. if($this->checkDepartHasPerson($data['id'])) return [false,'部门下有人员档案!'];
  686. $bool = ProductInventory::where('top_depart_id',$data['id'])->where('del_time',0)->exists();
  687. if($bool) return [false,'部门下的仓库有产品信息!'];
  688. return [true, ''];
  689. }
  690. /**
  691. * 部门列表
  692. * @param $data
  693. * @param $user
  694. * @return array
  695. */
  696. public function departList($data,$user){
  697. $model = Depart::where('del_time',0)
  698. ->select('title','id','code','parent_id','is_main','basic_type_id','rate','notify_id','channel_id','area','province')
  699. ->orderby('id', 'asc');
  700. if(! empty($data['get_top']) && $data['get_top'] == 1){
  701. //指派销售
  702. $depart_id = $this->getDepartIdListOfMySales($user);
  703. $model->whereIn('id', $depart_id);
  704. }else{
  705. if(! $user['is_all_depart']){
  706. $depart_id = $this->getDepartIdList($user);
  707. $model->whereIn('id',$depart_id);
  708. }
  709. }
  710. if(isset($data['parent_id'])) $model->where('parent_id', $data['parent_id']);
  711. if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
  712. if(! empty($data['code'])) $model->where('code', 'LIKE', '%'.$data['code'].'%');
  713. $list = $model->get()->toArray();
  714. $list = $this->fillDepartList($list, $user);
  715. $list_tree = $list;
  716. if(! empty($list_tree)) {
  717. $list_tree = $this->makeTree(0,$list_tree);
  718. $list_tree = $this->set_sort_circle($list_tree);
  719. }
  720. return [200,['data' => $list,'tree' => $list_tree]];
  721. }
  722. public function fillDepartList($list,$user){
  723. if(empty($list)) return $list;
  724. $basic = BasicType::where('del_time',0)
  725. ->whereIn('id', array_unique(array_column($list,'basic_type_id')))
  726. ->pluck('title','id')->toArray();
  727. $emp_id = array_unique(array_merge_recursive(array_column($list,'notify_id'),array_column($list,'channel_id')));
  728. $emp_map = Employee::whereIn('id',$emp_id)
  729. ->pluck('emp_name','id')
  730. ->toArray();
  731. //省
  732. $address_map = config('address');
  733. $address_map = array_column($address_map,'label','value');
  734. foreach ($list as $key => $value){
  735. $list[$key]['basic_type_title'] = $basic[$value['basic_type_id']] ?? '';
  736. $list[$key]['is_show_basic_type'] = $user['is_all_depart'];
  737. $list[$key]['notify_name'] = $emp_map[$value['notify_id']] ?? '';
  738. $list[$key]['channel_name'] = $emp_map[$value['channel_id']] ?? '';
  739. $list[$key]['area_name'] = Depart::$area[$value['area']] ?? '';
  740. $list[$key]['province_name'] = $address_map[$value['province']] ?? '';
  741. }
  742. return $list;
  743. }
  744. //获取可见的部门范围
  745. public function getDepartIdList($user){
  746. $list = Depart::where('del_time',0)->select('id','parent_id')->get()->toArray();
  747. $result = [];
  748. foreach ($user['depart_range'] as $v){
  749. // 查找所有父级id
  750. $parentIds = $this->findParentIds($v, $list);
  751. // 查找所有子级id
  752. $childIds = $this->findChildIds($v, $list);
  753. // 合并父级和子级id
  754. $tmp = array_merge($parentIds, $childIds, [$v]);
  755. $result = array_merge($result,$tmp);
  756. }
  757. return array_unique($result);
  758. }
  759. //获取指派销售时的部门
  760. public function getDepartIdListOfMySales($user){
  761. $top = $user['depart_top'][0] ?? [];
  762. $top = $top['depart_id'] ?? 0;
  763. $list = Depart::where('del_time',0)->select('id','parent_id')->get()->toArray();
  764. // 查找所有子级id
  765. $childIds = $this->findChildIds($top, $list);
  766. $result = array_merge($childIds, [$top]);
  767. return $result;
  768. }
  769. /**
  770. * 部门参数规则
  771. * @param $data
  772. * @param $is_check
  773. * @return array
  774. */
  775. public function departRule($data,$user, $is_check = true){
  776. if($this->isEmpty($data,'data')) return [false,'数据不能为空!'];
  777. $code = array_column($data['data'],'code');
  778. $title = array_column($data['data'],'title');
  779. $code = array_map(function($val) {
  780. return $val !== null ? $val : 0;
  781. }, $code);
  782. $title = array_map(function($val) {
  783. return $val !== null ? $val : 0;
  784. }, $title);
  785. $code_count = array_count_values($code);
  786. $title_count = array_count_values($title);
  787. foreach ($code as $value){
  788. if(empty($value)) return [false,'编码不能为空!'];
  789. if($code_count[$value] > 1) return [false,'编码不能重复'];
  790. }
  791. foreach ($title as $value){
  792. if(empty($value)) return [false,'名称不能为空!'];
  793. if($title_count[$value] > 1) return [false,'名称不能重复'];
  794. }
  795. $count = 0;
  796. foreach ($data['data'] as $value){
  797. if(empty($value['parent_id']) && ! empty($value['is_main'])) $count ++;
  798. }
  799. if($count > 1) return [false,'总社已存在!'];
  800. if($count == 1){
  801. $id = $data['id'] ?? 0;
  802. $bool = Depart::where('del_time',0)
  803. ->where('parent_id',0)
  804. ->where('is_main',1)
  805. ->when(! empty($id), function ($query) use ($id) {
  806. return $query->where('id', '<>',$id);
  807. })
  808. ->exists();
  809. if($bool) return [false,'总社已存在!'];
  810. }
  811. //省
  812. $address_map = config('address');
  813. $address_map = array_column($address_map,'label','value');
  814. foreach ($data['data'] as $key => $value){
  815. if(! empty($value['area'])){
  816. $area = array_keys(Depart::$area);
  817. if(! in_array($value['area'], $area)) return [false, '门店所属大区不存在'];
  818. }
  819. if(! empty($value['province']) && ! isset($address_map[$value['province']])) return [false, '门店所属省份不存在'];
  820. if(empty($value['parent_id'])) $data['data'][$key]['parent_id'] = 0;
  821. $data['data'][$key]['upd_time'] = time();
  822. //Depart::whereRaw("(binary code = '{$value['code']}' OR title = '{$value['title']}')")
  823. if($is_check){
  824. if(empty($user['is_all_depart']) && empty($value['parent_id'])) return [false,'上级部门必须选择'];
  825. $data['data'][$key]['crt_time'] = time();
  826. $bool = Depart::whereRaw("binary code = '{$value['code']}'")
  827. ->where('del_time',0)
  828. ->exists();
  829. }else{
  830. if($this->isEmpty($data,'id')) return [false,'id不能为空!'];
  831. if($data['id'] == $user['head']['id'] && empty($data['is_main'])) return [false,'总社不支持变更!'];
  832. $bool = Depart::whereRaw("binary code = '{$value['code']}'")
  833. ->where('id','<>',$data['id'])
  834. ->where('del_time',0)
  835. ->exists();
  836. }
  837. if($bool) return [false,'编码不能重复'];
  838. }
  839. return [true, $data];
  840. }
  841. /**
  842. * 检测部门下是否存在人员
  843. * @param $depart_id
  844. * @return false
  845. */
  846. public function checkDepartHasPerson($depart_id = []){
  847. if(empty($depart_id)) return false;
  848. $bool = EmployeeDepartPermission::from('employee_depart_permission as a')
  849. ->leftJoin('employee as b','b.id','a.employee_id')
  850. ->where('b.del_time',0)
  851. ->whereIn('a.depart_id',$depart_id)
  852. ->exists();
  853. return $bool;
  854. }
  855. /**
  856. * 班组编辑
  857. * @param $data
  858. * @return array
  859. */
  860. public function teamEdit($data){
  861. list($status,$msg) = $this->teamRule($data,false);
  862. if(!$status) return [$status,$msg];
  863. $model = new Team();
  864. $model = $model->where('id',$data['id'])->first();
  865. $model->title = $data['title'];
  866. $model->code = $data['code'];
  867. $model->save();
  868. return [true,'保存成功!'];
  869. }
  870. /**
  871. * 班组新增
  872. * @param $data
  873. * @param $user
  874. * @return array
  875. */
  876. public function teamAdd($data,$user){
  877. list($status,$msg) = $this->teamRule($data);
  878. if(!$status) return [$status,$msg];
  879. $model = new Team();
  880. $model->title = $data['title'] ;
  881. $model->code = $data['code'];
  882. $model->save();
  883. return [true,'保存成功!'];
  884. }
  885. /**
  886. * 班组删除
  887. * @param $data
  888. * @return array
  889. */
  890. public function teamDel($data){
  891. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  892. Team::where('id',$data['id'])->update([
  893. 'del_time'=>time()
  894. ]);
  895. return [true,'删除成功'];
  896. }
  897. /**
  898. * 班组列表
  899. * @param $data
  900. * @return array
  901. */
  902. public function teamList($data){
  903. $list = Team::where('del_time',0)
  904. ->select('title','id','crt_time','upd_time','code')
  905. ->orderBy('id','desc');
  906. $list = $this->limit($list,'',$data);
  907. return [200,$list];
  908. }
  909. /**
  910. * 班组参数规则
  911. * @param $data
  912. * @param $is_add
  913. * @return array
  914. */
  915. public function teamRule($data,$is_add = true){
  916. if($this->isEmpty($data,'title')) return [false,'名称不存在!'];
  917. if($this->isEmpty($data,'code')) return [false,'编码不存在'];
  918. $model = Team::where('title',$data['title'])
  919. ->where('code',$data['code'])
  920. ->where('del_time',0);
  921. if(! $is_add){
  922. if($this->isEmpty($data,'id')) return [false,'ID不能为空'];
  923. $model->where('id','<>',$data['id']);
  924. }
  925. $bool = $model->exists();
  926. if($bool) return [false,'名称和编码已存在!'];
  927. return [true,''];
  928. }
  929. /**
  930. * 班组详情
  931. * @param $data
  932. * @return array
  933. */
  934. public function teamDetail($data){
  935. if($this->isEmpty($data,'id')) return [false,'ID不能为空!'];
  936. $result = EmployeeTeamPermission::from('employee_team_permission as a')
  937. ->leftJoin('employee as b','b.id','a.employee_id')
  938. ->where('team_id',$data['id'])
  939. ->select('b.id','b.emp_name','b.number as code')
  940. ->get()->toArray();
  941. return [true,$result];
  942. }
  943. /**
  944. * 人员权限
  945. * @param $data
  946. * @return array
  947. */
  948. public function employeeRole($data){
  949. $role_ids = [];
  950. $employee_ids = [];
  951. foreach ($data as $v){
  952. if(isset($v['role_id'])){
  953. if(!in_array($v['role_id'],$role_ids)){
  954. $role_ids[] = $v['role_id'];
  955. }
  956. }
  957. if(isset($v['employee_id'])){
  958. if(!in_array($v['employee_id'],$employee_ids)){
  959. $employee_ids[] = $v['employee_id'];
  960. }
  961. }
  962. }
  963. EmployeeMenuPermission::wherein('role_id',$role_ids)->delete();
  964. EmployeeMenuPermission::wherein('employee_id',$employee_ids)->delete();
  965. EmployeeMenuPermission::insert($data);
  966. return [200,'保存成功!'];
  967. }
  968. /**
  969. * 人员部门关系更新
  970. * @param $data
  971. * @return array
  972. */
  973. public function employeeDepart($data){
  974. if($this->isEmpty($data,'insert')) return [false,'数据不能为空!'];
  975. DB::beginTransaction();
  976. try {
  977. if($data['type'] == 1){
  978. EmployeeDepartPermission::whereIn('depart_id',$data['insert']['depart_id'])->delete();
  979. }else{
  980. EmployeeDepartPermission::whereIn('employee_id',$data['insert']['employee_id'])->delete();
  981. }
  982. $insert = [];
  983. foreach ($data['insert']['depart_id'] as $t){
  984. foreach ($data['insert']['employee_id'] as $e){
  985. $insert[] = [
  986. 'depart_id' => $t,
  987. 'employee_id' => $e
  988. ];
  989. }
  990. }
  991. EmployeeDepartPermission::insert($insert);
  992. DB::commit();
  993. }catch (\Throwable $exception){
  994. DB::rollBack();
  995. return [false,$exception->getMessage()];
  996. }
  997. return [true,'保存成功!'];
  998. }
  999. /**
  1000. * 人员班组关系更新
  1001. * @param $data
  1002. * @return array
  1003. */
  1004. public function employeeTeam($data){
  1005. if($this->isEmpty($data,'insert')) return [false,'数据不能为空!'];
  1006. DB::beginTransaction();
  1007. try {
  1008. if($data['type'] == 1){
  1009. EmployeeTeamPermission::whereIn('team_id',$data['insert']['team_id'])->delete();
  1010. }else{
  1011. EmployeeTeamPermission::whereIn('employee_id',$data['insert']['employee_id'])->delete();
  1012. }
  1013. $insert = [];
  1014. foreach ($data['insert']['team_id'] as $t){
  1015. foreach ($data['insert']['employee_id'] as $e){
  1016. $insert[] = [
  1017. 'team_id' => $t,
  1018. 'employee_id' => $e
  1019. ];
  1020. }
  1021. }
  1022. EmployeeTeamPermission::insert($insert);
  1023. DB::commit();
  1024. }catch (\Throwable $exception){
  1025. DB::rollBack();
  1026. return [false,$exception->getMessage()];
  1027. }
  1028. return [true,'保存成功!'];
  1029. }
  1030. /**
  1031. * 登陆参数规则
  1032. * @param $data
  1033. * @return array
  1034. */
  1035. public function loginRule($data){
  1036. if($this->isEmpty($data,'account')) return [false,'账号不能为空!'];
  1037. if($this->isEmpty($data,'password')) return [false,'密码不存在!'];
  1038. $account = $data['account'];
  1039. $res = Employee::where('del_time',0)
  1040. ->where(function ($query)use($account) {
  1041. $query->where('account', $account)
  1042. ->orWhere('mobile', $account);
  1043. })
  1044. ->get()->toArray();
  1045. if(empty($res)) return [false,'账号不存在或已被删除!'];
  1046. if(count($res) > 1) return [false,'该手机号检测出多个账户,请联系后台!'];
  1047. $res = reset($res);
  1048. if(! Hash::check($data['password'], $res['password'])) return [false,'密码错误!'];
  1049. if($res['is_admin'] != Employee::IS_ADMIN) return [false,'该账号不能登录!'];
  1050. if($res['state'] == Employee::NOT_USE) return [false,'账号停用!'];
  1051. //门店的信息
  1052. $login_message = EmployeeService::getLoginMessage($res['id']);
  1053. return [true, ['id'=>$res['id'],'name'=>$res['emp_name'],'all_top'=> $login_message]];
  1054. }
  1055. /**
  1056. * 检查人员信息
  1057. * @param $userId
  1058. * @return array
  1059. */
  1060. public static function checkUser($userId){
  1061. $res = Employee::where('id', $userId)
  1062. ->where('del_time',0)
  1063. ->where('is_admin',Employee::IS_ADMIN)
  1064. ->where('state',Employee::USE)->get()->first();
  1065. if(empty($res)) return [false, '该账号无法登录,请联系管理员!'];
  1066. return [true, $res];
  1067. }
  1068. /**
  1069. * 获取登录账号的角色
  1070. * @param $employee_id
  1071. * @return array
  1072. */
  1073. public static function getPersonRole($employee_id){
  1074. if(empty($employee_id) || $employee_id == Employee::SPECIAL_ADMIN) return [];
  1075. $role = EmployeeRole::where('del_time',0)
  1076. ->where('employee_id',$employee_id)
  1077. ->select('role_id')
  1078. ->get()->toArray();
  1079. //组织
  1080. $role_id = array_unique(array_column($role,'role_id'));
  1081. asort($role_id);
  1082. $role_id = array_values($role_id);
  1083. return $role_id;
  1084. }
  1085. public static function getPersonRoleQx($role_id = []){
  1086. if(empty($role_id)) return [];
  1087. $role = RoleMenu::where('del_time',0)
  1088. ->whereIn('role_id',$role_id)
  1089. ->select('menu_id','type')
  1090. ->get()->toArray();
  1091. $sysmenu = SysMenu::where('del_time',0)
  1092. ->where('is_authority','>',0)
  1093. ->select('id')
  1094. ->get()->toArray();
  1095. $sysmenu = array_column($sysmenu,'id');
  1096. $return = [];
  1097. foreach ($role as $value){
  1098. if(! in_array($value['menu_id'],$sysmenu)) continue;
  1099. if(isset($return[$value['menu_id']])){
  1100. if($return[$value['menu_id']] < $value['type']) $return[$value['menu_id']] = $value['type'];
  1101. }else{
  1102. $return[$value['menu_id']] = $value['type'];
  1103. }
  1104. }
  1105. return $return;
  1106. }
  1107. public static function getSpecialButton($role_id,$user){
  1108. $return = [];
  1109. $special_button = config('specialButton');
  1110. if($user == Employee::SPECIAL_ADMIN) {
  1111. foreach ($special_button as $value){
  1112. $return[] = $value['id'];
  1113. }
  1114. return $return;
  1115. }
  1116. $role_button = RoleMenuButton::where('del_time',0)
  1117. ->where('button_id','<',0)
  1118. ->whereIn('role_id',$role_id)
  1119. ->select('menu_id','button_id')
  1120. ->get()->toArray();
  1121. foreach ($role_button as $value){
  1122. $return[] = $value['button_id'];
  1123. }
  1124. return $return;
  1125. }
  1126. //通过角色获取菜单
  1127. public function getMenuByRoleInList($user){
  1128. $role_id = $user['role'] ?? [];
  1129. $menu = SysMenu::where('del_time',0)->select('id')->get()->toArray();
  1130. if($user['id'] == Employee::SPECIAL_ADMIN) return array_column($menu,'id');
  1131. //没绑定角色
  1132. if(empty($role_id)) return [];
  1133. $role_menu = RoleMenu::whereIn('role_id',$role_id)
  1134. ->where('del_time',0)
  1135. ->select('menu_id')
  1136. ->get()->toArray();
  1137. return array_column($role_menu,'menu_id');
  1138. }
  1139. //通过角色获取菜单以及按钮
  1140. public function getMenuByRole($user){
  1141. $role_id = $user['role'] ?? [];
  1142. $menu = SysMenu::where('del_time',0)->select('id','uri')->get()->toArray();
  1143. $button = SysMenuButton::where('del_time',0)->select('id','title','sort','func','menu_id')->get()->toArray();
  1144. $button_map = [];
  1145. foreach ($button as $value){
  1146. $button_map[$value['menu_id']][] = $value;
  1147. }
  1148. $object = [];
  1149. //超级管理员
  1150. if($user['id'] == Employee::SPECIAL_ADMIN){
  1151. foreach ($menu as $value){
  1152. $object[] = [
  1153. 'id' => $value['id'],
  1154. // 'type' => 0,//所有权限
  1155. 'uri' => $value['uri'],
  1156. 'button' => $button_map[$value['id']] ?? [],
  1157. ];
  1158. }
  1159. }else{
  1160. //没绑定角色
  1161. if(empty($role_id)) return [];
  1162. $search = RoleMenu::whereIn('role_id',$role_id)
  1163. ->where('del_time',0)
  1164. ->select('menu_id','type')
  1165. ->get()->toArray();
  1166. $menu_map = array_column($menu,'uri','id');
  1167. //该角色下 菜单里所有按钮
  1168. $button_menu = $this->fillRoleButton($role_id);
  1169. $button_t = array_column($button,null,'id');
  1170. foreach ($search as $value){
  1171. $bt = $button_menu[$value['menu_id']] ?? [];
  1172. $new = [];
  1173. foreach ($bt as $b){
  1174. if(! empty($button_t[$b])) $new[] = $button_t[$b];
  1175. }
  1176. $object[] = [
  1177. 'id' => $value['menu_id'],
  1178. 'uri' => $menu_map[$value['menu_id']] ?? '',
  1179. // 'type' => $value['type'],
  1180. 'button' => $new,
  1181. ];
  1182. }
  1183. }
  1184. return $object;
  1185. }
  1186. /**
  1187. * 人员直接绑定部门
  1188. * @param $data
  1189. * @param $user
  1190. * @return array
  1191. */
  1192. public function employeeManagerDepart($data,$user){
  1193. if($user['id'] != Employee::SPECIAL_ADMIN) return [false,'非ADMIN账号不能操作'];
  1194. if($this->isEmpty($data,'employee_id')) return [false,'请选择操作人员'];
  1195. if($this->isEmpty($data,'depart_id')) return [false,'请选择部门'];
  1196. EmployeeManagerDepart::where('employee_id',$data['employee_id'])->update([
  1197. 'del_time' => time()
  1198. ]);
  1199. $insert = [];
  1200. foreach ($data['depart_id'] as $value){
  1201. $insert[] = [
  1202. 'employee_id' => $data['employee_id'],
  1203. 'depart_id' => $value,
  1204. 'crt_time' => time(),
  1205. 'upd_time' => time(),
  1206. ];
  1207. }
  1208. EmployeeManagerDepart::insert($insert);
  1209. return [true,''];
  1210. }
  1211. /**
  1212. * 填充角色下的按钮
  1213. * @param $role_id
  1214. * @return array
  1215. */
  1216. public function fillRoleButton($role_id){
  1217. $button = RoleMenuButton::whereIn('role_id',$role_id)
  1218. ->where('del_time',0)
  1219. ->select('menu_id','button_id')
  1220. ->get()->toArray();
  1221. $button_map = [];
  1222. foreach ($button as $value){
  1223. if(! isset($button_map[$value['menu_id']])){
  1224. $button_map[$value['menu_id']][] = $value['button_id'];
  1225. }else{
  1226. if(! in_array($value['button_id'], $button_map[$value['menu_id']])) $button_map[$value['menu_id']][] = $value['button_id'];
  1227. }
  1228. }
  1229. return $button_map;
  1230. }
  1231. /**
  1232. * 获取登录账号的部门
  1233. * @param $employee_id
  1234. * @return array|string[]
  1235. */
  1236. public static function getLoginDepart($employee_id, $top_depart_id = 0){
  1237. if(empty($employee_id)) return [];
  1238. //自己绑定的部门 启用的部门
  1239. $depart = EmployeeDepartPermission::from('employee_depart_permission as a')
  1240. ->join('depart as b','b.id','a.depart_id')
  1241. ->where('a.employee_id',$employee_id)
  1242. ->where('b.is_use',Depart::IS_UES)
  1243. ->select('a.depart_id','b.is_main','b.parent_id','b.basic_type_id','b.title')
  1244. ->orderBy('b.parent_id','asc')
  1245. ->orderBy('b.is_main','desc')
  1246. ->orderBy('a.depart_id','asc')
  1247. ->get()->toArray();
  1248. $top = $map = $rule = $head = [];
  1249. $res_data = [];//获取当前所在部门(也可能是门店 为了 depart_id)
  1250. $my_depart = [];//当前门店下 我勾选的门店以及部门信息
  1251. $is_all_depart = 0;
  1252. if(! empty($depart)){
  1253. //库存校验
  1254. $set_map = ProductInventorySet::where('del_time',0)->pluck('param_one','top_depart_id')->toArray();
  1255. //所有部门
  1256. $list = Depart::where('del_time',0)->get()->toArray();
  1257. $depart_map = array_column($list,null,'id');
  1258. foreach ($depart as $key => $value){
  1259. if($value['parent_id'] == 0){
  1260. $is_stock = $set_map[$value['depart_id']] ?? 1;
  1261. $depart[$key]['is_stock'] = $is_stock;
  1262. $top[$value['depart_id']] = [
  1263. 'depart_id' => $value['depart_id'],
  1264. 'is_main' => $value['is_main'],
  1265. 'basic_type_id' => $value['basic_type_id'],
  1266. 'title' => $value['title'],
  1267. 'is_stock' => $is_stock,
  1268. ];
  1269. $map[$value['depart_id']] = $value['depart_id'];
  1270. if($value['depart_id'] == $top_depart_id) {
  1271. $my_depart[] = $depart[$key];
  1272. if(empty($res_data)){
  1273. $res_data = $depart[$key];
  1274. }else{
  1275. if($value['depart_id'] >= $res_data['depart_id']) $res_data = $depart[$key];
  1276. }
  1277. }
  1278. }else{
  1279. $t = self::getTopParentId($value['depart_id'],$list);
  1280. if($t && isset($depart_map[$t])) {
  1281. $is_stock = $set_map[$t] ?? 1;
  1282. $depart[$key]['is_stock'] = $is_stock;
  1283. $t_tmp = $depart_map[$t] ?? [];
  1284. if( ! isset($top[$t_tmp['id']])){
  1285. $top[$t_tmp['id']] = [
  1286. 'depart_id' => $t_tmp['id'],
  1287. 'is_main' => $t_tmp['is_main'],
  1288. 'basic_type_id' => $t_tmp['basic_type_id'],
  1289. 'title' => $t_tmp['title'],
  1290. 'is_stock' => $set_map[$t] ?? 1,
  1291. ];
  1292. }
  1293. $map[$value['depart_id']] = $t;
  1294. }
  1295. if($t == $top_depart_id){
  1296. $my_depart[] = $depart[$key];
  1297. if(empty($res_data)){
  1298. $res_data = $depart[$key];
  1299. }else{
  1300. if($value['depart_id'] >= $res_data['depart_id']) $res_data = $depart[$key];
  1301. }
  1302. }
  1303. }
  1304. }
  1305. //-------------重组当前所在门店
  1306. $top = array_values($top);
  1307. usort($top, function($a, $b) {
  1308. return $b['is_main'] - $a['is_main'];
  1309. });
  1310. if(! empty($top_depart_id)){
  1311. $targetArray = null;
  1312. foreach ($top as $key => $value) {
  1313. if ($value['depart_id'] == $top_depart_id) {
  1314. $targetArray = $value;
  1315. unset($top[$key]); // 从原数组中移除目标数组
  1316. break; // 找到后跳出循环
  1317. }
  1318. }
  1319. if ($targetArray) array_unshift($top, $targetArray);
  1320. }
  1321. //-------------重组当前所在门店
  1322. //-------------拥有的数据权限(门店、部门)
  1323. $my_top = $top[0] ?? [];
  1324. foreach ($my_depart as $value){
  1325. if(in_array($value['depart_id'],$rule)) continue;
  1326. if(! $value['parent_id']){ //顶级
  1327. if(! empty($value['is_main']) && ! $is_all_depart) $is_all_depart = 1;
  1328. if($value['is_main']) {//是总公司
  1329. //所有部门都有
  1330. $rule = array_column($list,'id');
  1331. }else{//不是总公司
  1332. //自己以及子部门
  1333. $depart_id = array_merge(self::getAllIds($list,$map[$value['depart_id']]),[$map[$value['depart_id']]]);
  1334. $rule = array_merge_recursive($rule,$depart_id);
  1335. }
  1336. }else{//非顶级
  1337. if(! empty($my_top['is_main']) && $value['is_main'] && ! $is_all_depart) $is_all_depart = 1;
  1338. if($value['is_main']) {//是总社
  1339. $top_tmp = $map[$value['depart_id']];
  1340. if(! empty($depart_map[$top_tmp]['is_main'])){
  1341. //顶级公司是总公司 所有部门都有
  1342. $rule = array_column($list,'id');
  1343. }else{
  1344. //顶级公司是分公司 分公司所有部门
  1345. $depart_id = array_merge(self::getAllIds($list,$top_tmp),[$top_tmp]);
  1346. $rule = array_merge_recursive($rule,$depart_id);
  1347. }
  1348. }else{//不是总社
  1349. $rule = array_merge($rule,[$value['depart_id']]);
  1350. }
  1351. }
  1352. }
  1353. //-------------拥有的数据权限(门店、部门)
  1354. //总店
  1355. foreach ($list as $value){
  1356. if(empty($value['parent_id']) && ! empty($value['is_main'])) $head = $value;
  1357. }
  1358. }
  1359. $rule = array_unique($rule);
  1360. return [$depart,$top,$map,$rule,$is_all_depart,$head,$res_data];
  1361. }
  1362. //获取用户的所属门店信息
  1363. public static function getLoginMessage($employee_id){
  1364. if(empty($employee_id)) return [];
  1365. //自己绑定的部门 启用的部门
  1366. $depart = EmployeeDepartPermission::from('employee_depart_permission as a')
  1367. ->join('depart as b','b.id','a.depart_id')
  1368. ->where('a.employee_id',$employee_id)
  1369. ->where('b.is_use',Depart::IS_UES)
  1370. ->select('a.depart_id','b.is_main','b.parent_id','b.basic_type_id','b.title')
  1371. ->orderBy('b.parent_id','asc')
  1372. ->orderBy('b.is_main','desc')
  1373. ->orderBy('a.depart_id','asc')
  1374. ->get()->toArray();
  1375. $top = [];
  1376. if(! empty($depart)){
  1377. //所有部门
  1378. $list = Depart::where('del_time',0)->get()->toArray();
  1379. $depart_map = array_column($list,null,'id');
  1380. foreach ($depart as $value){
  1381. if($value['parent_id'] == 0){//顶级
  1382. if(! isset($top[$value['depart_id']])){
  1383. $top[$value['depart_id']] = [
  1384. 'depart_id' => $value['depart_id'],
  1385. 'is_main' => $value['is_main'],
  1386. 'title' => $value['title'],
  1387. ];
  1388. }
  1389. }else{
  1390. //门店
  1391. $t = self::getTopParentId($value['depart_id'],$list);
  1392. if($t && isset($depart_map[$t])) {
  1393. $t_tmp = $depart_map[$t] ?? [];
  1394. $is_all_depart = 0;
  1395. if(! empty($t_tmp['is_main']) && $value['is_main']) $is_all_depart = 1;
  1396. if(! isset($top[$t_tmp['id']])){
  1397. $top[$t_tmp['id']] = [
  1398. 'depart_id' => $t_tmp['id'],
  1399. 'is_main' => $is_all_depart,
  1400. 'title' => $t_tmp['title'],
  1401. ];
  1402. }else{
  1403. if(! empty($is_all_depart)) $top[$t_tmp['id']]['is_main'] = $is_all_depart;
  1404. }
  1405. }
  1406. }
  1407. }
  1408. }
  1409. $top = array_values($top);
  1410. usort($top, function($a, $b) {
  1411. return $b['is_main'] - $a['is_main'];
  1412. });
  1413. return $top;
  1414. }
  1415. /**
  1416. * 获取顶级id
  1417. * @param $id
  1418. * @param $data
  1419. * @return int
  1420. */
  1421. public static function getTopParentId($id, $data) {
  1422. foreach ($data as $item) {
  1423. if ($item['id'] == $id) {
  1424. if ($item['parent_id'] == 0) {
  1425. // 找到最顶级的id
  1426. return $item['id'];
  1427. } else {
  1428. // 继续递归查找父级
  1429. return self::getTopParentId($item['parent_id'], $data);
  1430. }
  1431. }
  1432. }
  1433. // 如果没有找到匹配的id,则返回null或者其他你希望的默认值
  1434. return 0;
  1435. }
  1436. /**
  1437. * 递归获取所有id
  1438. * @param $data
  1439. * @param $id
  1440. * @return array
  1441. */
  1442. public static function getAllIds($data, $id) {
  1443. $result = array(); // 存储结果的数组
  1444. foreach ($data as $node) {
  1445. if ($node['parent_id'] == $id) { // 如果当前节点的父 ID 等于指定 ID,则将该节点添加到结果中
  1446. $result[] = $node['id'];
  1447. // 递归查询该节点的所有子孙节点,并将结果合并到结果数组中
  1448. $result = array_merge($result, self::getAllIds($data, $node['id']));
  1449. }
  1450. }
  1451. return $result;
  1452. }
  1453. public static function checkWxUser($userId){
  1454. $res = Employee::where('id', $userId)
  1455. ->where('del_time',0)
  1456. ->where('state',Employee::USE)->get()->first();
  1457. if(empty($res)) return [false, '该账号无法登录,请联系管理员!'];
  1458. return [true, $res];
  1459. }
  1460. public function getTopMessage($data,$user){
  1461. $top = $user['depart_top'] ?? [];
  1462. return [true, ['top' => $top]];
  1463. }
  1464. }