EmployeeService.php 44 KB

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