PLeaveOverService.php 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469
  1. <?php
  2. namespace App\Service;
  3. use App\Model\CalendarDetails;
  4. use App\Model\PLeaveOverOrder;
  5. use App\Model\PLeaveOverOrderDetails;
  6. use App\Model\Employee;
  7. use App\Model\Item;
  8. use App\Model\WorkRangeDetails;
  9. use Illuminate\Support\Facades\DB;
  10. class PLeaveOverService extends Service
  11. {
  12. public function pLeaveOverEdit($data,$user){
  13. list($status,$msg) = $this->pLeaveOverRule($data, $user, false);
  14. if(!$status) return [$status,$msg];
  15. try {
  16. DB::beginTransaction();
  17. $model = PLeaveOverOrder::where('id',$data['id'])->first();
  18. $model->save();
  19. $time = time();
  20. PLeaveOverOrderDetails::where('del_time',0)
  21. ->where('main_id', $model->id)
  22. ->update(['del_time' => $time]);
  23. $this->saveDetail($model->id, $time, $data);
  24. DB::commit();
  25. }catch (\Exception $exception){
  26. DB::rollBack();
  27. return [false,$exception->getMessage()];
  28. }
  29. return [true, ''];
  30. }
  31. public function pLeaveOverAdd($data,$user){
  32. list($status,$msg) = $this->pLeaveOverRule($data, $user);
  33. if(!$status) return [$status,$msg];
  34. try {
  35. DB::beginTransaction();
  36. $model = new PLeaveOverOrder();
  37. $model->code = $this->generateBillNo([
  38. 'top_depart_id' => $user['top_depart_id'],
  39. 'type' => PLeaveOverOrder::Order_type,
  40. 'period' => date("Ym", $data['order_time'])
  41. ]);
  42. $model->order_time = $data['order_time'] ?? 0;
  43. $model->type = $data['type'];
  44. $model->crt_id = $user['id'];
  45. $model->top_depart_id = $data['top_depart_id'];
  46. $model->save();
  47. $this->saveDetail($model->id, time(), $data);
  48. DB::commit();
  49. }catch (\Exception $exception){
  50. DB::rollBack();
  51. return [false,$exception->getMessage()];
  52. }
  53. return [true, ''];
  54. }
  55. private function saveDetail($id, $time, $data){
  56. if(! empty($data['details'])){
  57. $unit = [];
  58. foreach ($data['details'] as $value){
  59. $unit[] = [
  60. 'main_id' => $id,
  61. 'employee_id' => $value['employee_id'],
  62. 'start_time_hour' => $value['start_time_hour'],
  63. 'start_time_min' => $value['start_time_min'],
  64. 'end_time_hour' => $value['end_time_hour'],
  65. 'end_time_min' => $value['end_time_min'],
  66. 'total_min' => $value['total_min'],
  67. 'crt_time' => $time,
  68. 'top_depart_id' => $value['top_depart_id'],
  69. 'type' => $value['type'],
  70. ];
  71. }
  72. if(! empty($unit)) PLeaveOverOrderDetails::insert($unit);
  73. }
  74. }
  75. private function getDetail($id){
  76. $data = PLeaveOverOrderDetails::where('del_time',0)
  77. ->where('main_id', $id)
  78. ->select('employee_id', 'start_time_hour', 'start_time_min', 'end_time_hour', 'end_time_min', 'total_min')
  79. ->get()->toArray();
  80. $id = array_column($data,'employee_id');
  81. $map = Employee::whereIn('id', $id)
  82. ->select('title','id','number')
  83. ->get()
  84. ->keyBy('id')
  85. ->toArray();
  86. foreach ($data as $key => $value){
  87. $tmp = $map[$value['employee_id']] ?? [];
  88. $merge = [];
  89. $merge['employee_title'] = $tmp['title'];
  90. $merge['employee_number'] = $tmp['number'];
  91. $data[$key] = array_merge($value, $merge);
  92. }
  93. $detail = [
  94. 'details' => $data,
  95. ];
  96. foreach ($detail as $key => $value) {
  97. if (empty($value)) {
  98. $detail[$key] = (object)[]; // 转成 stdClass 对象
  99. }
  100. }
  101. return $detail;
  102. }
  103. public function pLeaveOverDel($data){
  104. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  105. try {
  106. DB::beginTransaction();
  107. $time = time();
  108. PLeaveOverOrder::where('del_time',0)
  109. ->whereIn('id',$data['id'])
  110. ->update(['del_time' => $time]);
  111. PLeaveOverOrderDetails::where('del_time',0)
  112. ->whereIn('main_id', $data['id'])
  113. ->update(['del_time' => $time]);
  114. DB::commit();
  115. }catch (\Exception $exception){
  116. DB::rollBack();
  117. return [false,$exception->getMessage()];
  118. }
  119. return [true, ''];
  120. }
  121. public function pLeaveOverDetail($data, $user){
  122. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  123. $customer = PLeaveOverOrder::where('del_time',0)
  124. ->where('id',$data['id'])
  125. ->first();
  126. if(empty($customer)) return [false,'单据不存在或已被删除'];
  127. $customer = $customer->toArray();
  128. $customer['type_title'] = PLeaveOverOrder::Type[$customer['type']] ?? "";
  129. $customer['crt_name'] = Employee::where('id',$customer['crt_id'])->value('title');
  130. $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';
  131. $customer['order_time'] = $customer['order_time'] ? date("Y-m-d",$customer['order_time']): '';
  132. $details = $this->getDetail($data['id']);
  133. $customer = array_merge($customer, $details);
  134. return [true, $customer];
  135. }
  136. public function pLeaveOverCommon($data,$user, $field = []){
  137. if(empty($field)) $field = PLeaveOverOrder::$field;
  138. $model = PLeaveOverOrder::Clear($user,$data);
  139. $model = $model->where('del_time',0)
  140. ->select($field)
  141. ->orderby('id', 'desc');
  142. if(! empty($data['code'])) $model->where('code', 'LIKE', '%'.$data['code'].'%');
  143. if(! empty($data['type'])) $model->where('type', $data['type']);
  144. if(! empty($data['id'])) $model->whereIn('id', $data['id']);
  145. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  146. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  147. $model->where('crt_time','>=',$return[0]);
  148. $model->where('crt_time','<=',$return[1]);
  149. }
  150. if(! empty($data['time'][0]) && ! empty($data['time'][1])) {
  151. $return = $this->changeDateToTimeStampAboutRange($data['time']);
  152. $model->where('order_time','>=',$return[0]);
  153. $model->where('order_time','<=',$return[1]);
  154. }
  155. return $model;
  156. }
  157. public function pLeaveOverList($data,$user){
  158. $model = $this->pLeaveOverCommon($data, $user);
  159. $list = $this->limit($model,'',$data);
  160. $list = $this->fillData($list);
  161. return [true, $list];
  162. }
  163. public function pLeaveOverRule(&$data, $user, $is_add = true)
  164. {
  165. $data['top_depart_id'] = $user['top_depart_id'];
  166. $topDepartId = $data['top_depart_id'];
  167. // 1. 基础校验
  168. if (empty($data['type']) || ! isset(PLeaveOverOrder::Type[$data['type']])) return [false, '单据类型非法'];
  169. $typeName = PLeaveOverOrder::Type[$data['type']];
  170. if (empty($data['order_time'])) return [false, '单据日期不能为空'];
  171. $data['order_time'] = $this->changeDateToDate($data['order_time']);
  172. $orderTime = $data['order_time'];
  173. $orderType = $data['type'];
  174. if (!$is_add) {
  175. if (empty($data['id'])) return [false, 'ID不能为空'];
  176. $orderExists = DB::table('p_leave_over_order')
  177. ->where('id', $data['id'])
  178. ->where('top_depart_id', $topDepartId)
  179. ->where('del_time', 0)
  180. ->exists();
  181. if (!$orderExists) return [false, '原单据不存在或已被删除'];
  182. }
  183. // --- 日历工作日校验 ---
  184. $calendar = DB::table('calendar_details')
  185. ->where('del_time', 0)
  186. ->where('top_depart_id', $topDepartId)
  187. ->where('time', $orderTime)
  188. ->first();
  189. if (!$calendar) return [false, '所选日期未在公司日历中设置,无法校验'];
  190. $isWorkDay = (int)$calendar->is_work === CalendarDetails::TYPE_ONE;
  191. if (!$isWorkDay && $orderType == PLeaveOverOrder::TYPE_ONE) {
  192. return [false, date("Y-m-d", $orderTime) . "为非工作日,无需提交请假单"];
  193. }
  194. // 2. 获取【通用】工作时间段
  195. $commonWorkPeriods = [];
  196. if ($isWorkDay) {
  197. $workRanges = DB::table('work_range_details')
  198. ->where('del_time', 0)
  199. ->where('top_depart_id', $topDepartId)
  200. ->get();
  201. foreach ($workRanges as $wr) {
  202. $commonWorkPeriods[] = [
  203. 's' => $wr->start_time_hour * 60 + $wr->start_time_min,
  204. 'e' => $wr->end_time_hour * 60 + $wr->end_time_min
  205. ];
  206. }
  207. }
  208. // 3. 预加载明细中所有人员的信息及【个性化】工时
  209. if (empty($data['details'])) return [false, '明细不能为空'];
  210. $allEmpIds = array_filter(array_unique(array_column($data['details'], 'employee_id')));
  211. $empDisplayMap = Employee::whereIn('id', $allEmpIds)
  212. ->get(['id', 'number', 'title'])
  213. ->mapWithKeys(fn($item) => [$item->id => "[{$item->number}]{$item->title}"])->toArray();
  214. // --- 新增:预加载个性化工时 ---
  215. $specialWorkMap = DB::table('employee_work_range')
  216. ->whereIn('employee_id', $allEmpIds)
  217. ->where('top_depart_id', $topDepartId)
  218. ->get()
  219. ->groupBy('employee_id');
  220. // 预查库内已有时段 (保持不变)
  221. $dbExistingDetails = DB::table('p_leave_over_order_details as d')
  222. ->join('p_leave_over_order as m', 'd.main_id', '=', 'm.id')
  223. ->where('m.top_depart_id', $topDepartId)
  224. ->where('m.order_time', $orderTime)
  225. ->where('m.del_time', 0)
  226. ->where('d.del_time', 0)
  227. ->whereIn('d.employee_id', $allEmpIds)
  228. ->when(!$is_add, fn($q) => $q->where('m.id', '<>', $data['id']))
  229. ->select('d.employee_id', 'd.start_time_hour', 'd.start_time_min', 'd.end_time_hour', 'd.end_time_min', 'm.type as order_type')
  230. ->get()
  231. ->groupBy('employee_id');
  232. // 4. 循环明细校验
  233. $internalOverlap = [];
  234. foreach ($data['details'] as $key => &$value) {
  235. $empId = $value['employee_id'] ?? 0;
  236. $empName = $empDisplayMap[$empId] ?? "";
  237. if(empty($empName)) return [false, '人员不存在或已被删除'];
  238. // A. 时间合法性校验
  239. if ($value['start_time_hour'] > 23 || $value['end_time_hour'] > 24 || $value['start_time_min'] > 59 || $value['end_time_min'] > 59) {
  240. return [false, "人员{$empName}:填写的时间段不合法"];
  241. }
  242. $currentStart = $value['start_time_hour'] * 60 + $value['start_time_min'];
  243. $currentEnd = $value['end_time_hour'] * 60 + $value['end_time_min'];
  244. if ($currentStart >= $currentEnd) return [false, "人员{$empName}:开始时间必须早于结束时间"];
  245. $value['total_min'] = $currentEnd - $currentStart;
  246. $value['type'] = $orderType;
  247. // B. 工作时间逻辑校验 (重点:确定使用哪套工时标准)
  248. if ($isWorkDay) {
  249. // 判定:是个性化还是通用?
  250. $currentEmpPeriods = [];
  251. if (isset($specialWorkMap[$empId])) {
  252. foreach ($specialWorkMap[$empId] as $sw) {
  253. $currentEmpPeriods[] = [
  254. 's' => $sw->start_time_hour * 60 + $sw->start_time_min,
  255. 'e' => $sw->end_time_hour * 60 + $sw->end_time_min
  256. ];
  257. }
  258. } else {
  259. $currentEmpPeriods = $commonWorkPeriods;
  260. }
  261. if (empty($currentEmpPeriods)) return [false, "人员{$empName}:未找到对应的工作时间设置,无法校验"];
  262. if ($orderType == PLeaveOverOrder::TYPE_ONE) {
  263. // 请假:必须在工作时间内
  264. $inWorkRange = false;
  265. foreach ($currentEmpPeriods as $wp) {
  266. if ($currentStart >= $wp['s'] && $currentEnd <= $wp['e']) {
  267. $inWorkRange = true;
  268. break;
  269. }
  270. }
  271. if (!$inWorkRange) return [false, "人员{$empName}:请假时间必须在对应的工作时间段内"];
  272. } else {
  273. // 加班:不能在工作时间段内
  274. foreach ($currentEmpPeriods as $wp) {
  275. if ($currentStart < $wp['e'] && $wp['s'] < $currentEnd) {
  276. return [false, "人员{$empName}:加班时间与正常工作时间重叠"];
  277. }
  278. }
  279. }
  280. }
  281. // C. 内部重叠校验
  282. if (isset($internalOverlap[$empId])) {
  283. foreach ($internalOverlap[$empId] as $period) {
  284. if ($currentStart < $period['e'] && $period['s'] < $currentEnd) {
  285. return [false, "人员{$empName}:本次提交的数据中存在时间重叠"];
  286. }
  287. }
  288. }
  289. $internalOverlap[$empId][] = ['s' => $currentStart, 'e' => $currentEnd];
  290. // D. 库内同类型重叠校验
  291. if (isset($dbExistingDetails[$empId])) {
  292. foreach ($dbExistingDetails[$empId] as $dbD) {
  293. if ($dbD->order_type == $orderType) {
  294. $exStart = $dbD->start_time_hour * 60 + $dbD->start_time_min;
  295. $exEnd = $dbD->end_time_hour * 60 + $dbD->end_time_min;
  296. if ($currentStart < $exEnd && $exStart < $currentEnd) {
  297. $typeStr = $orderType == PLeaveOverOrder::TYPE_ONE ? "请假" : "加班";
  298. return [false, "人员{$empName}:该时段与已有的{$typeStr}记录重叠"];
  299. }
  300. }
  301. }
  302. }
  303. $value['top_depart_id'] = $topDepartId;
  304. }
  305. // 5. 唯一性校验
  306. $uniqueCheck = PLeaveOverOrder::where('top_depart_id', $topDepartId)
  307. ->where('order_time', $orderTime)
  308. ->where('type', $orderType)
  309. ->where('del_time', 0);
  310. if (! $is_add) $uniqueCheck->where('id', '<>', $data['id']);
  311. if ($uniqueCheck->exists()) {
  312. return [false, date("Y-m-d", $orderTime) . "已存在{$typeName},请在原单据上修改"];
  313. }
  314. return [true, ''];
  315. }
  316. public function fillData($data){
  317. if(empty($data['data'])) return $data;
  318. $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_column($data['data'],'crt_id')));
  319. foreach ($data['data'] as $key => $value){
  320. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
  321. $data['data'][$key]['order_time'] = $value['order_time'] ? date('Y-m-d',$value['order_time']) : '';
  322. $data['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
  323. $data['data'][$key]['type_title'] = PLeaveOverOrder::Type[$value['type']] ?? "";
  324. }
  325. return $data;
  326. }
  327. public function fillDataForExportDaily($data, $column, &$return)
  328. {
  329. if (empty($data)) return;
  330. $mainIds = array_column($data, 'id');
  331. // 1. 获取子表详情及关联档案映射
  332. $detailsMap = $this->getLeaveOverDetailsMap($mainIds);
  333. foreach ($data as $main) {
  334. $mainId = $main['id'];
  335. $details = $detailsMap[$mainId] ?? [];
  336. // 2. 提取并格式化主表共有信息
  337. $mainInfo = [
  338. 'code' => $main['code'],
  339. 'order_time' => !empty($main['order_time']) ? date('Y-m-d', $main['order_time']) : '',
  340. ];
  341. if (empty($details)) {
  342. // 如果主表没有明细,依然根据 column 导出一行(包含主表信息,明细列为空)
  343. $tempRow = [];
  344. foreach ($column as $col) {
  345. $tempRow[] = $mainInfo[$col] ?? '';
  346. }
  347. $return[] = $tempRow;
  348. } else {
  349. // 3. 平铺导出:每一行明细都带上主表的 code 和日期
  350. foreach ($details as $sub) {
  351. $fullRowData = array_merge($mainInfo, $sub);
  352. $tempRow = [];
  353. foreach ($column as $col) {
  354. // $col 对应的是配置里的 export 字段,如 'employee_number', 'start_time' 等
  355. $tempRow[] = $fullRowData[$col] ?? '';
  356. }
  357. $return[] = $tempRow;
  358. }
  359. }
  360. }
  361. }
  362. public function getLeaveOverDetailsMap($mainIds)
  363. {
  364. // 1. 获取所有子表记录
  365. $details = DB::table('p_leave_over_order_details')
  366. ->where('del_time', 0)
  367. ->whereIn('main_id', $mainIds)
  368. ->get();
  369. if ($details->isEmpty()) return [];
  370. // 2. 批量获取人员档案映射
  371. $empIds = $details->pluck('employee_id')->unique()->toArray();
  372. $empMap = DB::table('employee')
  373. ->whereIn('id', $empIds)
  374. ->get(['id', 'title', 'number'])
  375. ->keyBy('id');
  376. $res = [];
  377. foreach ($details as $item) {
  378. $emp = $empMap[$item->employee_id] ?? null;
  379. // 3. 组装明细行数据(Key 必须与 header 配置中的 export 字段一致)
  380. $detailRow = [
  381. // 人员信息
  382. 'employee_number' => $emp ? $emp->number : '',
  383. 'employee_title' => $emp ? $emp->title : '',
  384. // 时间段格式化 8:0 -> 08:00
  385. 'start_time' => sprintf('%02d:%02d', $item->start_time_hour, $item->start_time_min),
  386. 'end_time' => sprintf('%02d:%02d', $item->end_time_hour, $item->end_time_min),
  387. // 时长(分钟)
  388. 'total_min' => $item->total_min,
  389. ];
  390. $res[$item->main_id][] = $detailRow;
  391. }
  392. return $res;
  393. }
  394. }