EmployeeService.php 54 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326
  1. <?php
  2. namespace App\Service;
  3. use App\Model\CalendarDetails;
  4. use App\Model\Company;
  5. use App\Model\Depart;
  6. use App\Model\Employee;
  7. use App\Model\EmployeeDepartPermission;
  8. use App\Model\EmployeeFile;
  9. use App\Model\EmployeeRole;
  10. use App\Model\EmployeeWorkRange;
  11. use App\Model\Role;
  12. use App\Model\RoleMenu;
  13. use App\Model\RoleMenuButton;
  14. use App\Model\WorkRangeDetails;
  15. use App\Model\WxEmployee;
  16. use Illuminate\Support\Facades\DB;
  17. use Illuminate\Support\Facades\Hash;
  18. use Mockery\Exception;
  19. class EmployeeService extends Service
  20. {
  21. public function companySet($data, $user)
  22. {
  23. // 1. 基础校验
  24. if (empty($data['title'])) return [false, '公司全称不能为空'];
  25. if (empty($data['code'])) return [false, '统一社会信用代码不能为空'];
  26. // 2. 准备查询条件
  27. $attributes = [
  28. 'top_depart_id' => $user['top_depart_id']
  29. ];
  30. // 3. 准备需要更新或插入的数据
  31. $values = [
  32. 'title' => $data['title'],
  33. 'code' => $data['code'],
  34. 'address' => $data['address'] ?? '',
  35. 'legal_representative' => $data['legal_representative'] ?? '',
  36. 'mobile' => $data['mobile'] ?? '',
  37. 'e_mail' => $data['e_mail'] ?? '',
  38. 'industry' => $data['industry'] ?? '',
  39. 'start_time' => $data['start_time'] ?? '',
  40. 'money' => $data['money'] ?? '',
  41. 'number' => $data['number'] ?? '',
  42. 'del_time' => 0, // 建议重置删除标志,防止在更新已软删除的数据时出错
  43. ];
  44. try {
  45. Company::updateOrCreate($attributes, $values);
  46. } catch (\Exception $e) {
  47. return [false, '保存失败:' . $e->getMessage()];
  48. }
  49. return [true, ''];
  50. }
  51. public function companyDetail($data, $user)
  52. {
  53. $company = Company::where('del_time',0)
  54. ->where('top_depart_id', $user['top_depart_id'])
  55. ->first();
  56. if(empty($company)) return [true, []];
  57. return [true, $company->toArray()];
  58. }
  59. public function companyWorkArrangeSet($data, $user)
  60. {
  61. if (empty($data['work_range'])) return [false, '公司工作时段不能为空'];
  62. // 用于暂存转换后的分钟区间,格式:[['start' => X, 'end' => Y], ...]
  63. $timeSegments = [];
  64. foreach ($data['work_range'] as $key => $value){
  65. // 1. 基础合法性校验
  66. $res = $this->checkNumber($value['start_time_hour'], 0, 'non-negative');
  67. if(!$res['valid']) return [false, "开始点:" . $res['error']];
  68. if($value['start_time_hour'] > 23) return [false, "开始点不合法(应为0-23)"];
  69. $res = $this->checkNumber($value['start_time_min'], 0, 'non-negative');
  70. if(!$res['valid']) return [false, "开始分:" . $res['error']];
  71. if($value['start_time_min'] > 59) return [false, "开始分不合法(应为0-59)"]; // 修正为59
  72. $res = $this->checkNumber($value['end_time_hour'], 0, 'non-negative');
  73. if(!$res['valid']) return [false, "结束点:" . $res['error']];
  74. if($value['end_time_hour'] > 24) return [false, "结束点不合法(应为0-24)"];
  75. $res = $this->checkNumber($value['end_time_min'], 0, 'non-negative');
  76. if(!$res['valid']) return [false, "结束分:" . $res['error']];
  77. // 如果是24点,分钟必须是0,其余情况应小于60
  78. if($value['end_time_hour'] == 24 && $value['end_time_min'] > 0) {
  79. return [false, "结束时间不能超过24:00"];
  80. }
  81. if($value['end_time_min'] > 59 && $value['end_time_hour'] != 24) {
  82. return [false, "结束分不合法(应为0-59)"];
  83. }
  84. // 2. 计算绝对分钟数
  85. $startTotalMin = $value['start_time_hour'] * 60 + $value['start_time_min'];
  86. $endTotalMin = $value['end_time_hour'] * 60 + $value['end_time_min'];
  87. // 3. 校验单一时段的逻辑正确性
  88. if ($endTotalMin <= $startTotalMin) {
  89. return [false, "第 " . ($key + 1) . " 个时段的结束时间必须大于开始时间"];
  90. }
  91. // 4. 【核心新增】:时段冲突/重叠校验
  92. // 拿当前时段和之前已经校验过的所有时段逐一比对
  93. foreach ($timeSegments as $index => $existingSegment) {
  94. // 交叉重叠判别式:S1 < E2 && S2 < E1
  95. if ($startTotalMin < $existingSegment['end'] && $existingSegment['start'] < $endTotalMin) {
  96. $currentPeriod = "{$value['start_time_hour']}:" . str_pad($value['start_time_min'], 2, '0', STR_PAD_LEFT) . "~{$value['end_time_hour']}:" . str_pad($value['end_time_min'], 2, '0', STR_PAD_LEFT);
  97. return [false, "时段冲突!当前时段 [{$currentPeriod}] 与其他设置的时段存在重叠"];
  98. }
  99. }
  100. // 5. 校验通过,记录该区间用于后续比对
  101. $timeSegments[] = [
  102. 'start' => $startTotalMin,
  103. 'end' => $endTotalMin
  104. ];
  105. // 6. 补全写入数据库的隐藏字段
  106. $data['work_range'][$key]['total_work_min'] = $endTotalMin - $startTotalMin;
  107. $data['work_range'][$key]['top_depart_id'] = $user['top_depart_id'];
  108. }
  109. // 7. 写入数据库(包含事务包裹)
  110. try {
  111. $time = time();
  112. DB::beginTransaction();
  113. WorkRangeDetails::where('del_time', 0)
  114. ->where('top_depart_id', $user['top_depart_id'])
  115. ->update(['del_time' => $time]);
  116. WorkRangeDetails::insert($data['work_range']);
  117. DB::commit();
  118. } catch (\Exception $e) {
  119. DB::rollBack();
  120. return [false, '保存失败:' . $e->getMessage()];
  121. }
  122. return [true, ''];
  123. }
  124. public function companyWorkArrangeDetail($data, $user)
  125. {
  126. $company = WorkRangeDetails::where('del_time',0)
  127. ->where('top_depart_id', $user['top_depart_id'])
  128. ->get()->toArray();
  129. return [true, $company];
  130. }
  131. public static function getCompanyDetail($user){
  132. $company = Company::where('del_time',0)
  133. ->where('top_depart_id', $user['top_depart_id'])
  134. ->first();
  135. if(empty($company)){
  136. //默认名字
  137. $title = Depart::where('id', $user['top_depart_id'])->value('title');
  138. $return['title'] = $title;
  139. return $return;
  140. }
  141. return $company->toArray();
  142. }
  143. public function employeeEditOther($data,$user){
  144. list($status,$msg) = $this->employeeOtherRule($data,$user);
  145. if(!$status) return [$status,$msg];
  146. try {
  147. DB::beginTransaction();
  148. $model = new Employee();
  149. $model = $model->where('id',$user['id'])->first();
  150. $model->password = Hash::make($data['new_password']);
  151. $model->p_version = $model->p_version + 1;
  152. $model->save();
  153. DB::commit();
  154. }catch (\Exception $exception){
  155. DB::rollBack();
  156. return [false, $exception->getMessage()];
  157. }
  158. return [true,''];
  159. }
  160. public function employeeOtherRule($data,$user){
  161. if(! isset($data['old_password'])) return [false,'请输入原密码'];
  162. if($data['old_password'] == "") return [false,'原密码不能为空'];
  163. if(! isset($data['new_password'])) return [false,'请输入新密码'];
  164. if($data['new_password'] == "") return [false,'新密码不能为空'];
  165. if(! isset($data['re_password'])) return [false,'请输入确认密码'];
  166. if($data['re_password'] == "") return [false,'确认密码不能为空'];
  167. if(! Hash::check($data['old_password'], $user['password'])) return [false,'原密码错误'];
  168. if($data['new_password'] == $data['old_password']) return [false,'原密码与新密码一致'];
  169. if($data['new_password'] !== $data['re_password']) return [false,'新密码与确认密码不一致'];
  170. return [true,''];
  171. }
  172. public function employeeEdit($data,$user){
  173. list($status,$msg) = $this->employeeRule($data,$user,false);
  174. if(!$status) return [$status,$msg];
  175. try {
  176. DB::beginTransaction();
  177. $model = new Employee();
  178. $model = $model->where('id',$data['id'])->first();
  179. $oldMobile = $model->mobile ?? "";
  180. $newMobile = $data['mobile'] ?? "";
  181. $model->number = $data['number'] ?? "";
  182. $model->title = $data['title'] ?? "";
  183. $model->mobile = $data['mobile'] ?? "";
  184. $model->sex = $data['sex'] ?? 0;
  185. $model->education = $data['education'] ?? "";
  186. $model->id_card = $data['id_card'] ?? "";
  187. $model->major = $data['major'] ?? "";
  188. $model->position = $data['position'] ?? "";
  189. $model->p_title = $data['p_title'] ?? "";
  190. $model->state = $data['state'] ?? 0;
  191. $model->employee_type = $data['employee_type'] ?? 0;
  192. $model->is_admin = $data['is_admin'] ?? 0;
  193. $model->is_wx_admin = $data['is_wx_admin'] ?? 0;
  194. $model->entrust_type = $data['entrust_type'] ?? 0;
  195. $model->man_type = $data['man_type'] ?? 0;
  196. if($model->is_admin && $data['password'] !== '******') {
  197. $model->password = Hash::make($data['password']);
  198. $model->p_version = $model->p_version + 1;
  199. }
  200. $model->save();
  201. if (trim((string)$oldMobile) !== trim((string)$newMobile)) {
  202. //如果修改了手机号 清空微信小程序关联关系
  203. WxEmployee::where('employee_id', $model->id)->delete();
  204. }
  205. $time = time();
  206. EmployeeDepartPermission::where('employee_id',$data['id'])->delete();
  207. if(isset($data['depart'])){
  208. $insert = [];
  209. foreach ($data['depart'] as $value){
  210. $insert[] = [
  211. 'employee_id' => $model->id,
  212. 'depart_id' => $value,
  213. 'top_depart_id' => $user['top_depart_id'],
  214. ];
  215. }
  216. EmployeeDepartPermission::insert($insert);
  217. }
  218. EmployeeRole::join('role', 'role.id', '=', 'employee_role.role_id')
  219. ->where('employee_role.employee_id', $data['id'])
  220. ->where('role.tree_type', $user['select_tree_type'])
  221. ->where('employee_role.del_time', 0)
  222. ->update([
  223. 'employee_role.del_time' => $time
  224. ]);
  225. if(isset($data['role'])){
  226. $insert = [];
  227. foreach ($data['role'] as $value){
  228. $insert[] = [
  229. 'employee_id' => $model->id,
  230. 'role_id' => $value,
  231. 'crt_time' => $time,
  232. ];
  233. }
  234. EmployeeRole::insert($insert);
  235. }
  236. EmployeeWorkRange::where('employee_id',$data['id'])->delete();
  237. if(isset($data['work_range'])){
  238. $insert = [];
  239. foreach ($data['work_range'] as $value){
  240. $insert[] = [
  241. 'employee_id' => $model->id,
  242. 'start_time_hour' => $value['start_time_hour'],
  243. 'start_time_min' => $value['start_time_min'],
  244. 'end_time_hour' => $value['end_time_hour'],
  245. 'end_time_min' => $value['end_time_min'],
  246. 'total_work_min' => $value['total_work_min'],
  247. 'top_depart_id' => $value['top_depart_id'],
  248. 'crt_time' => time(),
  249. ];
  250. }
  251. EmployeeWorkRange::insert($insert);
  252. }
  253. $old = EmployeeFile::where('del_time',0)
  254. ->where('employee_id',$model->id)
  255. ->pluck('file')
  256. ->toArray();
  257. EmployeeFile::where('del_time',0)
  258. ->where('employee_id',$model->id)
  259. ->update(['del_time' => $time]);
  260. $new = [];
  261. if(! empty($data['img_url'])){
  262. if(in_array($data['img_url'], $old)) {
  263. foreach ($old as $o_k => $o_v){
  264. if($o_v == $data['img_url']) unset($old[$o_k]);
  265. }
  266. }else{
  267. $new[] = $data['img_url'];
  268. }
  269. EmployeeFile::insert([
  270. 'employee_id' => $model->id,
  271. 'file' => $data['img_url'],
  272. 'crt_time' => $time,
  273. 'top_depart_id' => $user['top_depart_id'],
  274. ]);
  275. }
  276. DB::commit();
  277. }catch (\Exception $exception){
  278. DB::rollBack();
  279. return [false, $exception->getMessage()];
  280. }
  281. return [true, ['file' => ['new' => $new, 'old' => $old]]];
  282. }
  283. public function employeeAdd($data,$user){
  284. list($status,$msg) = $this->employeeRule($data, $user);
  285. if(!$status) return [$status,$msg];
  286. try{
  287. DB::beginTransaction();
  288. $model = new Employee();
  289. $model->number = $data['number'] ?? "";
  290. $model->title = $data['title'] ?? "";
  291. $model->mobile = $data['mobile'] ?? "";
  292. $model->sex = $data['sex'] ?? 0;
  293. $model->education = $data['education'] ?? "";
  294. $model->id_card = $data['id_card'] ?? "";
  295. $model->major = $data['major'] ?? "";
  296. $model->position = $data['position'] ?? "";
  297. $model->p_title = $data['p_title'] ?? "";
  298. $model->state = $data['state'] ?? 0;
  299. $model->employee_type = $data['employee_type'] ?? 0;
  300. $model->crt_id = $user['id'];
  301. $model->is_admin = $data['is_admin'] ?? 0;
  302. $model->is_wx_admin = $data['is_wx_admin'] ?? 0;
  303. $model->account = $data['account'] ?? "";
  304. $model->entrust_type = $data['entrust_type'] ?? 0;
  305. $model->man_type = $data['man_type'] ?? 0;
  306. if($model->is_admin) $model->password = Hash::make($data['password']);
  307. $model->top_depart_id = $data['top_depart_id'];
  308. $model->save();
  309. $time = time();
  310. if(isset($data['depart'])){
  311. $insert = [];
  312. foreach ($data['depart'] as $value){
  313. $insert[] = [
  314. 'employee_id' => $model->id,
  315. 'depart_id' => $value,
  316. 'top_depart_id' => $user['top_depart_id'],
  317. ];
  318. }
  319. EmployeeDepartPermission::insert($insert);
  320. }
  321. if(isset($data['role'])){
  322. $insert = [];
  323. foreach ($data['role'] as $value){
  324. $insert[] = [
  325. 'employee_id' => $model->id,
  326. 'role_id' => $value,
  327. 'crt_time' => $time,
  328. ];
  329. }
  330. EmployeeRole::insert($insert);
  331. }
  332. if(isset($data['work_range'])){
  333. $insert = [];
  334. foreach ($data['work_range'] as $value){
  335. $insert[] = [
  336. 'employee_id' => $model->id,
  337. 'start_time_hour' => $value['start_time_hour'],
  338. 'start_time_min' => $value['start_time_min'],
  339. 'end_time_hour' => $value['end_time_hour'],
  340. 'end_time_min' => $value['end_time_min'],
  341. 'total_work_min' => $value['total_work_min'],
  342. 'top_depart_id' => $value['top_depart_id'],
  343. 'crt_time' => $time,
  344. ];
  345. }
  346. EmployeeWorkRange::insert($insert);
  347. }
  348. $new = [];
  349. $insert = [];
  350. if(! empty($data['img_url'])){
  351. $insert[] = [
  352. 'employee_id' => $model->id,
  353. 'file' => $data['img_url'],
  354. 'top_depart_id' => $value['top_depart_id'],
  355. 'crt_time' => $time,
  356. ];
  357. EmployeeFile::insert($insert);
  358. $new[] = $data['img_url'];
  359. }
  360. DB::commit();
  361. }catch (Exception $e){
  362. DB::rollBack();
  363. return [false, $e->getMessage()];
  364. }
  365. return [true, ['file' => ['new' => $new]]];
  366. }
  367. public function employeeDel($data){
  368. if($this->isEmpty($data,'id')) return [false,'请选择删除的数据!'];
  369. try {
  370. DB::beginTransaction();
  371. $time = time();
  372. Employee::whereIn('id',$data['id'])->update([
  373. 'del_time'=>$time
  374. ]);
  375. EmployeeRole::where('del_time',0)->whereIn('employee_id',$data['id'])->update([
  376. 'del_time'=>$time
  377. ]);
  378. EmployeeDepartPermission::whereIn('employee_id',$data['id'])->delete();
  379. EmployeeWorkRange::whereIn('employee_id',$data['id'])->delete();
  380. //清空微信小程序关联关系
  381. WxEmployee::whereIn('employee_id', $data['id'])->delete();
  382. $old = EmployeeFile::where('del_time',0)
  383. ->whereIn('employee_id',$data['id'])
  384. ->pluck('file')
  385. ->toArray();
  386. DB::commit();
  387. }catch (\Exception $exception){
  388. DB::rollBack();
  389. return [false,$exception->getMessage()];
  390. }
  391. return [true, ['file' => ['old' => $old]]];
  392. }
  393. public function employeeDetail($data, $user){
  394. if(empty($data['id'])) return [false,'人员id不能为空'];
  395. list($status, $return) = $this->employeeList(['id' => [$data['id']]], $user);
  396. $user = $return['data'][0] ?? [];
  397. list($img, $img2) = $this->showUserImg($data['id']);
  398. $user['img_url'] = $img;
  399. $user['img_url_show'] = $img2;
  400. return [true, $user];
  401. }
  402. public function getEmployeeImg($data, $user){
  403. list($img, $img_str) = $this->showUserImg($user['id']);
  404. return [true, ['img_url' => $img_str]];
  405. }
  406. private function showUserImg($id){
  407. $file = EmployeeFile::where('del_time',0)
  408. ->where('employee_id',$id)
  409. ->pluck('file')
  410. ->toArray();
  411. $file = $file[0] ?? "";
  412. $img_str = "";
  413. $timeStamp = 86400;
  414. if(! empty($file)){
  415. $fileUploadService = new FileUploadService();
  416. $img_str = $fileUploadService->getFileShow($file, $timeStamp);
  417. }
  418. return [$file, $img_str];
  419. }
  420. public function employeeCommon($data,$user, $field = []){
  421. if(empty($field)) $field = Employee::$field;
  422. $model = Employee::TopClear($user,$data);
  423. $model = $model->where('del_time',0)
  424. ->where('is_admin', '<=', Employee::IS_ADMIN_ONE)
  425. ->select($field)
  426. ->orderBy('id','desc');
  427. if(! empty($data['id'])) $model->whereIn('id', $data['id']);
  428. if(! empty($data['number'])) $model->where('number', 'LIKE', '%'.$data['number'].'%');
  429. if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
  430. if(! empty($data['mobile'])) $model->where('mobile', 'LIKE', '%'.$data['mobile'].'%');
  431. if(isset($data['is_admin'])) $model->where('is_admin', $data['is_admin']);
  432. if(! empty($data['state'])) $model->where('state', $data['state']);
  433. if(isset($data['education'])) $model->where('education', $data['education']);
  434. if(! empty($data['role'])) {
  435. $emp = EmployeeRole::where('role_id',$data['role'])
  436. ->where('del_time',0)
  437. ->select('employee_id')->get()->toArray();
  438. $model->whereIn('id',array_column($emp,'employee_id'));
  439. }
  440. if(! empty($data['depart'])) {
  441. // 1. 获取所有子部门 ID(包含自身)
  442. $allDeparts = Depart::where('del_time', 0)->select('id', 'parent_id')->get();
  443. $departIds = array_merge($this->getAllDescendants($allDeparts->toArray(), $data['depart']), [$data['depart']]);
  444. // 2. 优化:直接使用子查询,避免拉取巨大的 $employee_id 数组到内存
  445. $model->whereIn('id', function ($query) use ($departIds) {
  446. $query->select('employee_id')
  447. ->from('employee_depart_permission')
  448. ->whereIn('depart_id', $departIds);
  449. });
  450. }
  451. return $model;
  452. }
  453. /**
  454. * 产品列表
  455. * @param $data
  456. * @param $user
  457. * @return array
  458. */
  459. public function employeeList($data,$user){
  460. $model = $this->employeeCommon($data, $user);
  461. $list = $this->limit($model,'',$data);
  462. $list = $this->organizationEmployeeData($list, $data, $user);
  463. return [true, $list];
  464. }
  465. public function organizationEmployeeData($data, $ergs, $user)
  466. {
  467. if (empty($data['data'])) return $data;
  468. // 获取员工ID并查询扩展数据
  469. $employee_ids = array_column($data['data'], 'id');
  470. list($status, $extraMap) = $this->getEmployee($employee_ids, $user);
  471. $map = [];
  472. if(isset($ergs['search_for_month_work'])) list($status, $map) = $this->getEmployeesMonthStats($employee_ids, $ergs['search_for_month_work'], $user);
  473. foreach ($data['data'] as &$item) {
  474. $id = $item['id'];
  475. $extra = $extraMap[$id] ?? null;
  476. $item['role'] = $extra['role_ids'] ?? [];
  477. $item['role_name'] = isset($extra['role_names']) ? implode(',', $extra['role_names']) : '';
  478. $item['depart'] = $extra['depart_ids'] ?? [];
  479. $item['depart_title'] = isset($extra['depart_names']) ? implode(',', $extra['depart_names']) : '';
  480. // 业务状态字段
  481. $item['is_admin_title'] = Employee::IS_ADMIN_TITLE[$item['is_admin']] ?? "";
  482. $item['is_wx_admin_title'] = Employee::IS_WX_ADMIN_TITLE_SIMPLE[$item['is_wx_admin']] ?? "";
  483. $item['state_title'] = Employee::State_Type[$item['state']] ?? "";
  484. $item['employee_type_title'] = Employee::E_State_Type[$item['employee_type']] ?? "";
  485. $item['sex_title'] = Employee::SEX_TYPE[$item['sex']] ?? "";
  486. $item['man_type_title'] = Employee::Man_Type[$item['man_type']] ?? "";
  487. $item['entrust_type_title'] = Employee::WT_Type[$item['entrust_type']] ?? "";
  488. $item['education_title'] = Employee::Education[$item['education']] ?? "";
  489. $item['crt_time'] = !empty($item['crt_time']) ? date("Y-m-d", $item['crt_time']) : "";
  490. if (isset($ergs['search_for_month_work'])) {
  491. $item['month_pw'] = []; // 默认空数组
  492. if ($status) {
  493. $item['month_pw'] = $map[$item['id']] ?? [];
  494. }
  495. }
  496. }
  497. return $data;
  498. }
  499. public function getEmployeesMonthStats($employee_ids, $month, $user)
  500. {
  501. $topDepartId = $user['top_depart_id'];
  502. // 1. 月份初始化
  503. if(is_numeric($month)){
  504. $monthStart = $month;
  505. }else{
  506. $monthStart = $this->changeDateToDate($month);
  507. $monthStr = date("Y-m", $monthStart);
  508. }
  509. $endTime = strtotime("+1 month", $monthStart) - 1;
  510. // 2. 获取当月标准工作日天数 (基数)
  511. $standardWorkDays = DB::table('calendar_details')
  512. ->where('top_depart_id', $topDepartId)
  513. ->where('del_time', 0)
  514. ->where('time', '>=', $monthStart)
  515. ->where('time', '<=', $endTime)
  516. ->where('is_work', CalendarDetails::TYPE_ONE)
  517. ->count();
  518. if ($standardWorkDays <= 0) return [false, '工作日信息未设置'];
  519. // 3. 批量获取个性化工时设置
  520. $empWorkRanges = DB::table('employee_work_range')
  521. ->whereIn('employee_id', $employee_ids)
  522. ->where('top_depart_id', $topDepartId)
  523. ->select('employee_id', DB::raw('SUM(total_work_min) as total_min'))
  524. ->groupBy('employee_id')
  525. ->pluck('total_min', 'employee_id')
  526. ->toArray();
  527. // 4. 获取公司通用工时设置
  528. $commonWorkMin = DB::table('work_range_details')
  529. ->where('top_depart_id', $topDepartId)
  530. ->where('del_time', 0)
  531. ->sum('total_work_min');
  532. if(empty($commonWorkMin)) return [false, '公司工作时段未设置'];
  533. // 5. 批量获取请假与加班汇总
  534. $actualStats = DB::table('p_leave_over_order_details as d')
  535. ->join('p_leave_over_order as m', 'd.main_id', '=', 'm.id')
  536. ->whereIn('d.employee_id', $employee_ids)
  537. ->where('m.order_time', '>=', $monthStart)
  538. ->where('m.order_time', '<=', $endTime)
  539. ->where('m.del_time', 0)
  540. ->where('d.del_time', 0)
  541. ->select(
  542. 'd.employee_id',
  543. DB::raw("SUM(CASE WHEN m.type = 1 THEN d.total_min ELSE 0 END) as leave_min"),
  544. DB::raw("SUM(CASE WHEN m.type = 2 THEN d.total_min ELSE 0 END) as overtime_min")
  545. )
  546. ->groupBy('d.employee_id')
  547. ->get()
  548. ->keyBy('employee_id');
  549. // 6. 核心逻辑汇总
  550. $result = [];
  551. foreach ($employee_ids as $empId) {
  552. // A. 确定该人员每日标准时长 (基数)
  553. $dailyStandardMin = isset($empWorkRanges[$empId]) ? (float)$empWorkRanges[$empId] : (float)$commonWorkMin;
  554. // 如果每日标准时长没设置,跳过该人防止除以0错误
  555. if ($dailyStandardMin <= 0) continue;
  556. // B. 获取加班和请假数据
  557. $empActual = $actualStats->get($empId);
  558. $leaveMin = $empActual ? (float)$empActual->leave_min : 0;
  559. $overtimeMin = $empActual ? (float)$empActual->overtime_min : 0;
  560. // 净增减工时(分)
  561. $netDiffMin = $overtimeMin - $leaveMin;
  562. // C. 计算出勤总工时 (标准总分钟 + 净增减)
  563. $standardMonthMin = $standardWorkDays * $dailyStandardMin;
  564. $finalWorkMin = $standardMonthMin + $netDiffMin;
  565. // D. 计算出勤总天数 (标准天数 + 净增减折算天数)
  566. // 计算公式:出勤天数 = (标准总分钟 + 加班分钟 - 请假分钟) / 每日标准分钟
  567. $finalAttendanceDays = round($finalWorkMin / $dailyStandardMin, 2);
  568. $result[$empId] = [
  569. // 'standard_days' => $standardWorkDays, // 标准工作天数
  570. 'attendance_days' => $finalAttendanceDays, // 出勤总天数 * (结算后)
  571. // 'standard_month_min' => $standardMonthMin, // 标准总工时 (分钟)
  572. // 'final_work_min' => $finalWorkMin, // 出勤总工时 * (结算后分钟)
  573. 'final_work_hour' => round($finalWorkMin / 60, 2), // 出勤总工时 * (结算后小时)
  574. // 'leave_min' => $leaveMin,
  575. // 'overtime_min' => $overtimeMin,
  576. // 'daily_standard_min' => $dailyStandardMin
  577. ];
  578. }
  579. return [true, $result];
  580. }
  581. public function getEmployee(array $employee_ids, $user)
  582. {
  583. if (empty($employee_ids)) return [false, []];
  584. // 1. 一次性获取所有角色
  585. $roles = DB::table('employee_role as a')
  586. ->join('role as b', 'a.role_id', '=', 'b.id')
  587. ->where('a.del_time', 0)
  588. ->where('b.del_time', 0)
  589. ->where('b.tree_type', $user['select_tree_type'])
  590. ->whereIn("a.employee_id", $employee_ids)
  591. ->select('a.employee_id', 'b.title', 'b.id')
  592. ->get();
  593. // 2. 一次性获取所有部门
  594. $departs = DB::table('employee_depart_permission as a')
  595. ->join('depart as b', 'a.depart_id', '=', 'b.id')
  596. ->whereIn("a.employee_id", $employee_ids)
  597. ->select('a.employee_id', 'b.title', 'b.id')
  598. ->orderBy('b.id')
  599. ->get();
  600. $work_range = DB::table('employee_work_range as a')
  601. ->whereIn("employee_id", $employee_ids)
  602. ->select('employee_id','start_time_hour', 'start_time_min', 'end_time_hour', 'end_time_min')
  603. ->get();
  604. // 3. 结果按员工ID分组归纳
  605. $resultMap = [];
  606. foreach ($employee_ids as $id) {
  607. $resultMap[$id] = [
  608. 'role_ids' => [],
  609. 'role_names' => [],
  610. 'depart_ids' => [],
  611. 'depart_names' => [],
  612. 'work_range' => [],
  613. ];
  614. }
  615. foreach ($roles as $r) {
  616. $resultMap[$r->employee_id]['role_ids'][] = $r->id;
  617. $resultMap[$r->employee_id]['role_names'][] = $r->title;
  618. }
  619. foreach ($departs as $d) {
  620. $resultMap[$d->employee_id]['depart_ids'][] = $d->id;
  621. $resultMap[$d->employee_id]['depart_names'][] = $d->title;
  622. }
  623. foreach ($work_range as $d) {
  624. $resultMap[$d->employee_id]['work_range'][] = $d;
  625. }
  626. return [true, $resultMap];
  627. }
  628. public function fillDataForExport($data, $column, $user, &$return)
  629. {
  630. if (empty($data)) return;
  631. $dataArray = is_array($data) ? $data : $data->toArray();
  632. $mainIds = array_column($dataArray, 'id');
  633. // 1. 获取详情映射 [员工ID => [ [部门编码, 部门名称], [部门编码, 部门名称] ]]
  634. $detailsMap = $this->getEmployeeDetailsMap($mainIds, $user);
  635. // 枚举映射
  636. $sexMap = Employee::SEX_TYPE;
  637. $eduMap = Employee::Education;
  638. $stateMap = Employee::State_Type;
  639. $eMap = Employee::E_State_Type;
  640. foreach ($dataArray as $main) {
  641. $empId = $main['id'];
  642. $details = $detailsMap[$empId] ?? [];
  643. // 2. 格式化主表信息(这些是这一人所有行共有的内容)
  644. $mainInfo = $main;
  645. $mainInfo['sex_title'] = $sexMap[$main['sex']] ?? '';
  646. $mainInfo['education_title'] = $eduMap[$main['education']] ?? '';
  647. $mainInfo['state_title'] = $stateMap[$main['state']] ?? '';
  648. $mainInfo['employee_type_title'] = $eMap[$main['employee_type']] ?? '';
  649. if (empty($details)) {
  650. // 如果没部门,保底出一行
  651. $tempRow = [];
  652. foreach ($column as $col) {
  653. $tempRow[] = $mainInfo[$col] ?? '';
  654. }
  655. $return[] = $tempRow;
  656. } else {
  657. // 3. 核心拆分点:遍历部门明细,每一个部门都产生一个新的 $tempRow
  658. foreach ($details as $sub) {
  659. // 将员工基本信息与“当前这一个”部门信息合并
  660. $fullRowData = array_merge($mainInfo, $sub);
  661. $tempRow = [];
  662. // 严格按配置顺序取值
  663. foreach ($column as $col) {
  664. $tempRow[] = $fullRowData[$col] ?? '';
  665. }
  666. // 【重点】这里是追加,不是覆盖!
  667. // 如果张三有2个部门,这里会先后 push 两次,Excel 就会多出两行
  668. $return[] = $tempRow;
  669. }
  670. }
  671. }
  672. }
  673. public function getEmployeeDetailsMap($empIds, $user)
  674. {
  675. // 关联查询权限表和部门档案
  676. $list = DB::table('employee_depart_permission as p')
  677. ->join('depart as d', 'p.depart_id', '=', 'd.id')
  678. ->whereIn('p.employee_id', $empIds)
  679. ->where('p.top_depart_id', $user['top_depart_id'])
  680. ->where('d.del_time', 0)
  681. ->select('p.employee_id', 'd.code as depart_code', 'd.title as depart_title')
  682. ->get();
  683. $res = [];
  684. foreach ($list as $item) {
  685. // 【重点】注意这里的 [],它保证了同一个 employee_id 下可以挂载多个部门数组
  686. $res[$item->employee_id][] = [
  687. 'depart_code' => $item->depart_code,
  688. 'depart_title' => $item->depart_title,
  689. ];
  690. }
  691. return $res;
  692. }
  693. public function employeeRule1(&$data, $user,$is_add = true){
  694. if(empty($data['number'])) return [false,'工号不存在'];
  695. if(empty($data['title'])) return [false,'姓名不存在'];
  696. if(! empty($data['sex']) && ! isset(Employee::SEX_TYPE[$data['sex']])) return [false, '性别不存在'];
  697. if(empty($data['mobile'])) return [false,'联系电话不能为空'];
  698. // if(! $this->isValidPhone($data['mobile'])) return [false, '手机号码格式错误'];
  699. // if(empty($data['major'])) return [false, '专业领域不能为空'];
  700. if(! empty($data['education']) && ! isset(Employee::Education[$data['education']])) return [false, '学历不存在'];
  701. if(empty($data['id_card'])) return [false, '身份证号不能为空'];
  702. if(empty($data['depart'])) return [false,'部门不能为空'];
  703. if(empty($data['state'])) return [false,'状态不能为空'];
  704. if(! isset(Employee::State_Type[$data['state']])) return [false,'状态不存在'];
  705. if(empty($data['employee_type'])) return [false,'聘用类型不能为空'];
  706. if(! isset(Employee::E_State_Type[$data['employee_type']])) return [false,'聘用类型不存在'];
  707. if(! empty($data['is_admin'])){
  708. if(! isset(Employee::IS_ADMIN_TITLE_SIMPLE[$data['is_admin']])) return [false, 'is_admin类型不存在'];
  709. if(empty($data['password'])) return [false, '密码不能为空'];
  710. if(mb_strlen($data['password']) < 6) return [false, '密码长度不得小于6位长度'];
  711. if(empty($data['role'])) return [false, '角色不能为空'];
  712. }
  713. if(! empty($data['is_wx_admin']) && ! isset(Employee::IS_WX_ADMIN_TITLE_SIMPLE[$data['is_wx_admin']])) return [false, 'is_wx_admin类型不存在'];
  714. if(empty($data['man_type'])) return [false,'是否技术人员不能为空'];
  715. if(! isset(Employee::Man_Type[$data['man_type']])) return [false,'是否技术人员不存在'];
  716. if(! isset($data['entrust_type'])) return [false,'委托方式不能为空'];
  717. if(! isset(Employee::WT_Type[$data['entrust_type']])) return [false,'委托方式不存在'];
  718. $data['top_depart_id'] = $user['top_depart_id'];
  719. if(! empty($data['work_range'])){
  720. foreach ($data['work_range'] as $key => $value){
  721. $res = $this->checkNumber($value['start_time_hour'], 0, 'non-negative');
  722. if(!$res['valid']) return [false, "开始点:" . $res['error']];
  723. if($value['start_time_hour'] > 23) return [false, false, "开始点不合法"];
  724. $res = $this->checkNumber($value['start_time_min'], 0, 'non-negative');
  725. if(!$res['valid']) return [false, "开始分:" . $res['error']];
  726. if($value['start_time_min'] > 60) return [false, false, "开始点不合法"];
  727. $res = $this->checkNumber($value['end_time_hour'], 0, 'non-negative');
  728. if(!$res['valid']) return [false, "结束点:" . $res['error']];
  729. if($value['end_time_hour'] > 24) return [false, false, "结束点不合法"];
  730. $res = $this->checkNumber($value['end_time_min'], 0, 'non-negative');
  731. if(!$res['valid']) return [false, "结束分:" . $res['error']];
  732. if($value['end_time_min'] > 60) return [false, false, "结束分不合法"];
  733. $data['work_range'][$key]['total_work_min'] = ($value['end_time_hour'] * 60 + $value['end_time_min']) - ($value['start_time_hour'] * 60 + $value['start_time_min']);
  734. $data['work_range'][$key]['top_depart_id'] = $data['top_depart_id'];
  735. }
  736. }
  737. if(! $is_add){
  738. if($this->isEmpty($data,'id')) return [false,'ID不能为空'];
  739. $bool = Employee::where('del_time',0)
  740. ->where('id','<>',$data['id'])
  741. ->where('top_depart_id', $data['top_depart_id'])
  742. ->where('number', $data['number'])
  743. ->exists();
  744. }else{
  745. $code = Depart::where('id', $user['top_depart_id'])->value('code');
  746. $data['account'] = $code . "_" . $data['number'];
  747. $bool = Employee::where('del_time',0)
  748. ->where('top_depart_id', $data['top_depart_id'])
  749. ->where('number', $data['number'])
  750. ->exists();
  751. }
  752. if($bool) return [false,'人员工号已存在'];
  753. return [true,''];
  754. }
  755. public function employeeRule(&$data, $user, $is_add = true){
  756. if(empty($data['number'])) return [false,'工号不存在'];
  757. if(empty($data['title'])) return [false,'姓名不存在'];
  758. if(! empty($data['sex']) && ! isset(Employee::SEX_TYPE[$data['sex']])) return [false, '性别不存在'];
  759. if(empty($data['mobile'])) return [false,'联系电话不能为空'];
  760. // if(! $this->isValidPhone($data['mobile'])) return [false, '手机号码格式错误'];
  761. // if(empty($data['major'])) return [false, '专业领域不能为空'];
  762. if(! empty($data['education']) && ! isset(Employee::Education[$data['education']])) return [false, '学历不存在'];
  763. if(empty($data['id_card'])) return [false, '身份证号不能为空'];
  764. if(empty($data['depart'])) return [false,'部门不能为空'];
  765. if(empty($data['state'])) return [false,'状态不能为空'];
  766. if(! isset(Employee::State_Type[$data['state']])) return [false,'状态不存在'];
  767. if(empty($data['employee_type'])) return [false,'聘用类型不能为空'];
  768. if(! isset(Employee::E_State_Type[$data['employee_type']])) return [false,'聘用类型不存在'];
  769. if(! empty($data['is_admin'])){
  770. if(! isset(Employee::IS_ADMIN_TITLE_SIMPLE[$data['is_admin']])) return [false, 'is_admin类型不存在'];
  771. if(empty($data['password'])) return [false, '密码不能为空'];
  772. if(mb_strlen($data['password']) < 6) return [false, '密码长度不得小于6位长度'];
  773. if(empty($data['role'])) return [false, '角色不能为空'];
  774. }
  775. if(! empty($data['is_wx_admin']) && ! isset(Employee::IS_WX_ADMIN_TITLE_SIMPLE[$data['is_wx_admin']])) return [false, 'is_wx_admin类型不存在'];
  776. if(empty($data['man_type'])) return [false,'是否技术人员不能为空'];
  777. if(! isset(Employee::Man_Type[$data['man_type']])) return [false,'是否技术人员不存在'];
  778. if(! isset($data['entrust_type'])) return [false,'委托方式不能为空'];
  779. if(! isset(Employee::WT_Type[$data['entrust_type']])) return [false,'委托方式不存在'];
  780. $data['top_depart_id'] = $user['top_depart_id'];
  781. if(! empty($data['work_range'])){
  782. foreach ($data['work_range'] as $key => $value){
  783. $res = $this->checkNumber($value['start_time_hour'], 0, 'non-negative');
  784. if(!$res['valid']) return [false, "开始点:" . $res['error']];
  785. if($value['start_time_hour'] > 23) return [false, false, "开始点不合法"];
  786. $res = $this->checkNumber($value['start_time_min'], 0, 'non-negative');
  787. if(!$res['valid']) return [false, "开始分:" . $res['error']];
  788. if($value['start_time_min'] > 60) return [false, false, "开始点不合法"];
  789. $res = $this->checkNumber($value['end_time_hour'], 0, 'non-negative');
  790. if(!$res['valid']) return [false, "结束点:" . $res['error']];
  791. if($value['end_time_hour'] > 24) return [false, false, "结束点不合法"];
  792. $res = $this->checkNumber($value['end_time_min'], 0, 'non-negative');
  793. if(!$res['valid']) return [false, "结束分:" . $res['error']];
  794. if($value['end_time_min'] > 60) return [false, false, "结束分不合法"];
  795. $data['work_range'][$key]['total_work_min'] = ($value['end_time_hour'] * 60 + $value['end_time_min']) - ($value['start_time_hour'] * 60 + $value['start_time_min']);
  796. $data['work_range'][$key]['top_depart_id'] = $data['top_depart_id'];
  797. }
  798. }
  799. // 初始化查询基础条件
  800. $query = Employee::where('del_time', 0)
  801. ->where('top_depart_id', $data['top_depart_id']);
  802. if(! $is_add){
  803. if(empty($data['id'])) return [false,'ID不能为空'];
  804. $exists = Employee::where('id', $data['id'])->where('del_time', 0)->exists();
  805. if (!$exists) return [false, '账号不存在或已被删除'];
  806. // 编辑模式:排除自身 ID 记录
  807. $query->where('id', '<>', $data['id']);
  808. } else {
  809. $code = Depart::where('id', $user['top_depart_id'])->value('code');
  810. //默认账号规则
  811. $data['account'] = $code . "_" . $data['number'];
  812. }
  813. // 查出重复的人员记录信息
  814. $existUser = $query->where(function($q) use ($data) {
  815. $q->where('number', $data['number'])
  816. ->orWhere('mobile', $data['mobile']);
  817. })->first(['number', 'mobile']);
  818. if (!empty($existUser)) {
  819. if ($existUser->number == $data['number']) {
  820. return [false, '人员工号已存在'];
  821. }
  822. if ($existUser->mobile == $data['mobile']) {
  823. return [false, '手机号码已存在'];
  824. }
  825. }
  826. return [true,''];
  827. }
  828. public function roleEdit($data,$user){
  829. list($status,$msg) = $this->roleRule($data,$user, false);
  830. if(!$status) return [$status,$msg];
  831. $model = new Role();
  832. $model = $model->where('id',$data['id'])->first();
  833. $model->title = $data['title'];
  834. $model->tree_type = $user['select_tree_type'];
  835. $model->save();
  836. return [true,''];
  837. }
  838. public function roleAdd($data,$user){
  839. list($status,$msg) = $this->roleRule($data,$user);
  840. if(!$status) return [$status,$msg];
  841. $model = new Role();
  842. $model->title = $data['title'] ;
  843. $model->top_depart_id = $data['top_depart_id'];
  844. $model->tree_type = $user['select_tree_type'];
  845. $model->save();
  846. return [true,''];
  847. }
  848. public function roleDel($data){
  849. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  850. $bool = EmployeeRole::where('del_time',0)
  851. ->whereIn('role_id',$data['id'])
  852. ->exists();
  853. if($bool) return [false,'角色已绑定人员'];
  854. try {
  855. DB::beginTransaction();
  856. $time = time();
  857. Role::where('id',$data['id'])->update([
  858. 'del_time' => $time
  859. ]);
  860. RoleMenu::where('del_time',0)->where('role_id',$data['id'])->update([
  861. 'del_time' => $time
  862. ]);
  863. RoleMenuButton::where('del_time',0)->where('role_id',$data['id'])->update([
  864. 'del_time' => $time
  865. ]);
  866. DB::commit();
  867. }catch (\Exception $exception){
  868. DB::rollBack();
  869. return [false,$exception->getMessage()];
  870. }
  871. return [true, ''];
  872. }
  873. public function roleList($data,$user){
  874. $select_tree_type = $user['select_tree_type'];
  875. $model = Role::TopClear($user,$data);
  876. $model = $model->where('del_time',0)
  877. ->where('tree_type', $select_tree_type)
  878. ->select('title','crt_time','id','upd_time')
  879. ->orderBy('id','desc');
  880. if(! empty($data['title'])) $model->where('title', 'LIKE', '%' . $data['title'] . '%');
  881. $list = $this->limit($model,'',$data);
  882. return [true, $list];
  883. }
  884. public function roleRule(&$data,$user, $is_check = true){
  885. if($this->isEmpty($data,'title')) return [false,'名称不能为空'];
  886. $data['top_depart_id'] = $user['top_depart_id'];
  887. if($is_check){
  888. $bool = Role::where('title',$data['title'])
  889. ->where('top_depart_id', $data['top_depart_id'])
  890. ->where('del_time',0)
  891. ->exists();
  892. if($bool) return [false,'角色名称已存在'];
  893. }else{
  894. if($this->isEmpty($data,'id')) return [false,'ID不能为空'];
  895. $top_depart_id = Role::where('id',$data['id'])->value('top_depart_id');
  896. $bool = Role::where('title',$data['title'])
  897. ->where('top_depart_id',$top_depart_id)
  898. ->where('id','<>',$data['id'])
  899. ->where('del_time',0)
  900. ->exists();
  901. if($bool) return [false,'角色名称已存在'];
  902. }
  903. return [true, ''];
  904. }
  905. public function roleMenu($data){
  906. if(empty($data['role_id'])) return [false,'角色不能为空!'];
  907. if(empty($data['menu'])) return [false,'菜单数据不能为空!'];
  908. DB::beginTransaction();
  909. try {
  910. RoleMenu::where('del_time',0)->where('role_id',$data['role_id'])->update(['del_time' => time()]);
  911. RoleMenuButton::where('del_time',0)->where('role_id',$data['role_id'])->update(['del_time' => time()]);
  912. $insert = $insert2 = [];
  913. foreach ($data['menu'] as $t){
  914. $insert[] = [
  915. 'role_id' => $data['role_id'],
  916. 'menu_id' => $t['menu_id'],
  917. 'type' => $t['type'],
  918. 'crt_time' => time()
  919. ];
  920. if(! empty($t['button'])){
  921. foreach ($t['button'] as $b){
  922. $insert2[] = [
  923. 'role_id' => $data['role_id'],
  924. 'menu_id' => $t['menu_id'],
  925. 'button_id' => $b,
  926. 'crt_time' => time()
  927. ];
  928. }
  929. RoleMenuButton::insert($insert2);
  930. }
  931. }
  932. RoleMenu::insert($insert);
  933. DB::commit();
  934. }catch (\Throwable $exception){
  935. DB::rollBack();
  936. return [false,$exception->getMessage()];
  937. }
  938. return [true, ''];
  939. }
  940. public function roleDetail($data){
  941. if(empty($data['role_id'])) return [false,'请选择角色'];
  942. $role = Role::where('id',$data['role_id'])
  943. ->where('del_time',0)
  944. ->select('id','title')
  945. ->first();
  946. if(empty($role)) return [false,'角色不存在或已被删除'];
  947. $role = $role->toArray();
  948. $menu = RoleMenu::where('role_id',$data['role_id'])
  949. ->where('del_time',0)
  950. ->select('menu_id','type')
  951. ->get()->toArray();
  952. $button = $this->fillRoleButton([$data['role_id']]);
  953. foreach ($menu as $key => $value){
  954. $menu[$key]['button'] = $button[$value['menu_id']] ?? [];
  955. }
  956. $role['menu'] = $menu;
  957. return [true, $role];
  958. }
  959. public function departEdit($data, $user){
  960. list($status,$msg) = $this->departRule($data,$user,false);
  961. if(!$status) return [$status,$msg];
  962. $update = $msg['data'][0];
  963. $model = new Depart();
  964. $model->where('id',$data['id'])->update([
  965. 'title' => $update['title'],
  966. 'code' => $update['code'],
  967. ]);
  968. return [true, ''];
  969. }
  970. public function departAdd($data,$user){
  971. list($status,$msg) = $this->departRule($data,$user);
  972. if(!$status) return [$status,$msg];
  973. try {
  974. DB::beginTransaction();
  975. foreach ($msg['data'] as $value){
  976. $model = new Depart();
  977. $model->parent_id = $value['parent_id'];
  978. $model->title = $value['title'];
  979. $model->code = $value['code'];
  980. $model->top_depart_id = $value['top_depart_id'];
  981. $model->save();
  982. }
  983. DB::commit();
  984. }catch (\Exception $exception){
  985. DB::rollBack();
  986. return [false,$exception->getMessage()];
  987. }
  988. return [true,''];
  989. }
  990. public function departDel($data){
  991. list($status,$msg) = $this->checkDepartDel($data);
  992. if(! $status) return [false, $msg];
  993. Depart::whereIn('id',$data['id'])->update([
  994. 'del_time'=>time()
  995. ]);
  996. return [true,''];
  997. }
  998. public function checkDepartDel($data){
  999. if($this->isEmpty($data,'id')) return [false,'ID不能为空'];
  1000. $bool = Depart::whereIn('parent_id',$data['id'])->where('del_time',0)->exists();
  1001. if($bool) return [false,'部门下有子部门'];
  1002. if($this->checkDepartHasPerson($data['id'])) return [false,'部门下有人员档案'];
  1003. return [true, ''];
  1004. }
  1005. public function departCommon($data, $user, $field = []){
  1006. if(empty($field)) $field = Depart::$field;
  1007. $model = Depart::TopClear($user,$data);
  1008. $model = $model->where('del_time',0)
  1009. ->select($field)
  1010. ->orderby('id', 'asc');
  1011. if(isset($data['parent_id'])) $model->where('parent_id', $data['parent_id']);
  1012. if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
  1013. if(! empty($data['code'])) $model->where('code', 'LIKE', '%'.$data['code'].'%');
  1014. return $model;
  1015. }
  1016. public function departList($data, $user){
  1017. $model = $this->departCommon($data, $user);
  1018. $list = $model->get()->toArray();
  1019. $list = $this->fillDepartList($list, $user, true);
  1020. $list_tree = $list;
  1021. if(! empty($list_tree)) {
  1022. $minParentId = min(array_column($list_tree, 'parent_id'));
  1023. $list_tree = $this->makeTree($minParentId,$list_tree);
  1024. $list_tree = $this->set_sort_circle($list_tree);
  1025. }
  1026. return [true,['data' => $list,'tree' => $list_tree]];
  1027. }
  1028. public function fillDepartList($list,$user, $is_export = false){
  1029. if(isset($list['data'])){
  1030. $data = $list['data'];
  1031. }else{
  1032. $data = $list;
  1033. }
  1034. if($is_export){
  1035. $map = Depart::where('del_time',0)
  1036. ->whereIn('id', array_column($data, 'parent_id'))
  1037. ->select('code','id', 'title')
  1038. ->get()->toArray();
  1039. $map = array_column($map,null,'id');
  1040. foreach ($data as $key => $value){
  1041. $tmp = $map[$value['parent_id']] ?? "";
  1042. if($tmp['code'] == $user['top_depart_code']) {
  1043. $code = $title = "";
  1044. }else{
  1045. $code = $tmp['code'];
  1046. $title = $tmp['title'];
  1047. }
  1048. $data[$key]['parent_code'] = $code;
  1049. $data[$key]['parent_title'] = $title;
  1050. }
  1051. }
  1052. return $data;
  1053. }
  1054. public function departRule($data,$user, $is_check = true){
  1055. if(empty($data['data'])) return [false,'数据不能为空!'];
  1056. $code = array_column($data['data'],'code');
  1057. $title = array_column($data['data'],'title');
  1058. $code = array_map(function($val) {
  1059. return $val !== null ? $val : 0;
  1060. }, $code);
  1061. $title = array_map(function($val) {
  1062. return $val !== null ? $val : 0;
  1063. }, $title);
  1064. $code_count = array_count_values($code);
  1065. $title_count = array_count_values($title);
  1066. foreach ($code as $value){
  1067. if(empty($value)) return [false,'编码不能为空!'];
  1068. if($code_count[$value] > 1) return [false,'编码不能重复'];
  1069. }
  1070. foreach ($title as $value){
  1071. if(empty($value)) return [false,'名称不能为空!'];
  1072. if($title_count[$value] > 1) return [false,'名称不能重复'];
  1073. }
  1074. foreach ($data['data'] as $key => $value){
  1075. $top_depart_id = $user['top_depart_id'];
  1076. if(empty($value['parent_id'])) {
  1077. $parent_id = $top_depart_id;
  1078. $data['data'][$key]['parent_id'] = $parent_id;
  1079. }
  1080. $data['data'][$key]['top_depart_id'] = $top_depart_id;
  1081. $data['data'][$key]['upd_time'] = time();
  1082. if($is_check){
  1083. $data['data'][$key]['crt_time'] = time();
  1084. $bool = Depart::whereRaw("binary code = '{$value['code']}'")
  1085. ->where('top_depart_id', $top_depart_id)
  1086. ->where('del_time',0)
  1087. ->exists();
  1088. }else{
  1089. if($this->isEmpty($data,'id')) return [false,'id不能为空!'];
  1090. $bool = Depart::whereRaw("binary code = '{$value['code']}'")
  1091. ->where('top_depart_id', $top_depart_id)
  1092. ->where('id','<>',$data['id'])
  1093. ->where('del_time',0)
  1094. ->exists();
  1095. }
  1096. if($bool) return [false,'部门编码已存在'];
  1097. }
  1098. return [true, $data];
  1099. }
  1100. public function checkDepartHasPerson($depart_id = []){
  1101. if(empty($depart_id)) return false;
  1102. $bool = EmployeeDepartPermission::from('employee_depart_permission as a')
  1103. ->leftJoin('employee as b','b.id','a.employee_id')
  1104. ->where('b.del_time',0)
  1105. ->whereIn('a.depart_id',$depart_id)
  1106. ->exists();
  1107. return $bool;
  1108. }
  1109. public function fillRoleButton($role_id){
  1110. $button = RoleMenuButton::whereIn('role_id',$role_id)
  1111. ->where('del_time',0)
  1112. ->select('menu_id','button_id')
  1113. ->get()->toArray();
  1114. $button_map = [];
  1115. foreach ($button as $value){
  1116. if(! isset($button_map[$value['menu_id']])){
  1117. $button_map[$value['menu_id']][] = $value['button_id'];
  1118. }else{
  1119. if(! in_array($value['button_id'], $button_map[$value['menu_id']])) $button_map[$value['menu_id']][] = $value['button_id'];
  1120. }
  1121. }
  1122. return $button_map;
  1123. }
  1124. public function getEmployeeMap($employee_ids){
  1125. $employee_ids = array_filter((array)$employee_ids);
  1126. if (empty($employee_ids)) return [];
  1127. return Employee::whereIn('id', $employee_ids)
  1128. ->pluck('title', 'id')
  1129. ->toArray();
  1130. }
  1131. }