EmployeeService.php 58 KB

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