DeviceWorkService.php 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798
  1. <?php
  2. namespace App\Service;
  3. use App\Model\DailyDwOrder;
  4. use App\Model\DailyDwOrderDetails;
  5. use App\Model\Device;
  6. use App\Model\Employee;
  7. use App\Model\Item;
  8. use App\Model\MonthlyDwOrder;
  9. use App\Model\MonthlyDwOrderDetails;
  10. use Illuminate\Support\Facades\DB;
  11. class DeviceWorkService extends Service
  12. {
  13. //设备月工时单--------------------------------------------
  14. public function monthlyDwOrderEdit($data,$user){
  15. list($status,$msg) = $this->monthlyDwOrderRule($data, $user, false);
  16. if(!$status) return [$status,$msg];
  17. try {
  18. DB::beginTransaction();
  19. $model = MonthlyDwOrder::where('id',$data['id'])->first();
  20. // $model->month = $data['month'] ?? 0;
  21. // $model->save();
  22. $time = time();
  23. MonthlyDwOrderDetails::where('del_time',0)
  24. ->where('main_id', $model->id)
  25. ->update(['del_time' => $time]);
  26. $this->saveDetail($model->id, $time, $data);
  27. DB::commit();
  28. }catch (\Exception $exception){
  29. DB::rollBack();
  30. return [false,$exception->getMessage()];
  31. }
  32. return [true, ''];
  33. }
  34. public function monthlyDwOrderAdd($data,$user){
  35. list($status,$msg) = $this->monthlyDwOrderRule($data, $user);
  36. if(!$status) return [$status,$msg];
  37. try {
  38. DB::beginTransaction();
  39. $model = new MonthlyDwOrder();
  40. $model->code = $this->generateBillNo([
  41. 'top_depart_id' => $user['top_depart_id'],
  42. 'type' => MonthlyDwOrder::Order_type,
  43. 'period' => date("Ym", $data['month'])
  44. ]);
  45. $model->month = $data['month'] ?? 0;
  46. $model->crt_id = $user['id'];
  47. $model->top_depart_id = $data['top_depart_id'];
  48. $model->save();
  49. $this->saveDetail($model->id, time(), $data);
  50. DB::commit();
  51. }catch (\Exception $exception){
  52. DB::rollBack();
  53. return [false,$exception->getMessage()];
  54. }
  55. return [true, ''];
  56. }
  57. private function saveDetail($id, $time, $data){
  58. if(! empty($data['details'])){
  59. $unit = [];
  60. foreach ($data['details'] as $value){
  61. $unit[] = [
  62. 'main_id' => $id,
  63. 'device_id' => $value['device_id'],
  64. 'total_days' => $value['total_days'],
  65. 'rd_total_days' => $value['rd_total_days'],
  66. 'total_hours' => $value['total_hours'],
  67. 'rd_total_hours' => $value['rd_total_hours'],
  68. 'crt_time' => $time,
  69. 'top_depart_id' => $value['top_depart_id'],
  70. ];
  71. }
  72. if(! empty($unit)) MonthlyDwOrderDetails::insert($unit);
  73. }
  74. }
  75. private function getDetail($id){
  76. $data = MonthlyDwOrderDetails::where('del_time',0)
  77. ->where('main_id', $id)
  78. ->select('device_id', 'total_days', 'rd_total_days', 'total_hours', 'rd_total_hours')
  79. ->get()->toArray();
  80. $id = array_column($data,'device_id');
  81. $map = Device::whereIn('id', $id)->select('title','id','code')->get()->toArray();
  82. $map = array_column($map,null,'id');
  83. foreach ($data as $key => $value){
  84. $tmp = $map[$value['device_id']] ?? [];
  85. $merge = [];
  86. $merge['device_title'] = $tmp['title'];
  87. $merge['device_code'] = $tmp['code'];
  88. $data[$key] = array_merge($value, $merge);
  89. }
  90. $detail = [
  91. 'details' => $data,
  92. ];
  93. foreach ($detail as $key => $value) {
  94. if (empty($value)) {
  95. $detail[$key] = (object)[]; // 转成 stdClass 对象
  96. }
  97. }
  98. return $detail;
  99. }
  100. public function monthlyDwOrderDel($data){
  101. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  102. try {
  103. DB::beginTransaction();
  104. $time = time();
  105. MonthlyDwOrder::where('del_time',0)
  106. ->whereIn('id',$data['id'])
  107. ->update(['del_time' => $time]);
  108. MonthlyDwOrderDetails::where('del_time',0)
  109. ->whereIn('main_id', $data['id'])
  110. ->update(['del_time' => $time]);
  111. DB::commit();
  112. }catch (\Exception $exception){
  113. DB::rollBack();
  114. return [false,$exception->getMessage()];
  115. }
  116. return [true, ''];
  117. }
  118. public function monthlyDwOrderDetail($data, $user){
  119. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  120. $customer = MonthlyDwOrder::where('del_time',0)
  121. ->where('id',$data['id'])
  122. ->first();
  123. if(empty($customer)) return [false,'设备月度工时单不存在或已被删除'];
  124. $customer = $customer->toArray();
  125. $customer['crt_name'] = Employee::where('id',$customer['crt_id'])->value('title');
  126. $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';
  127. $customer['month'] = $customer['month'] ? date("Y-m",$customer['month']): '';
  128. $details = $this->getDetail($data['id']);
  129. $customer = array_merge($customer, $details);
  130. return [true, $customer];
  131. }
  132. public function monthlyDwOrderCommon($data,$user, $field = []){
  133. if(empty($field)) $field = MonthlyDwOrder::$field;
  134. $model = MonthlyDwOrder::Clear($user,$data);
  135. $model = $model->where('del_time',0)
  136. ->select($field)
  137. ->orderby('id', 'desc');
  138. if(! empty($data['code'])) $model->where('code', 'LIKE', '%'.$data['code'].'%');
  139. if(! empty($data['id'])) $model->whereIn('id', $data['id']);
  140. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  141. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  142. $model->where('crt_time','>=',$return[0]);
  143. $model->where('crt_time','<=',$return[1]);
  144. }
  145. return $model;
  146. }
  147. public function monthlyDwOrderList($data,$user){
  148. $model = $this->monthlyDwOrderCommon($data, $user);
  149. $list = $this->limit($model,'',$data);
  150. $list = $this->fillData($list);
  151. return [true, $list];
  152. }
  153. public function monthlyDwOrderRule(&$data, $user, $is_add = true)
  154. {
  155. if (empty($data['month'])) return [false, '月份不能为空'];
  156. $data['month'] = $this->changeDateToDate($data['month']);
  157. $data['top_depart_id'] = $user['top_depart_id'];
  158. if (empty($data['details'])) return [false, '设备月度工时单明细不能为空'];
  159. // --- 1. 批量获取设备档案信息 (用于展示 [编码]名称) ---
  160. $deviceIds = array_column($data['details'], 'device_id');
  161. $deviceMap = DB::table('device')
  162. ->whereIn('id', $deviceIds)
  163. ->where('top_depart_id', $data['top_depart_id'])
  164. ->get(['id', 'code', 'title'])
  165. ->mapWithKeys(fn($item) => [$item->id => "[{$item->code}]{$item->title}"])
  166. ->toArray();
  167. // --- 2. 获取设备考勤基准 ---
  168. list($status, $deviceStats) = (new DeviceService())->getDevicesMonthStats($deviceIds, $data['month'], $user);
  169. if (!$status) return [false, $deviceStats];
  170. // 字段中文映射,用于报错
  171. $fieldNames = [
  172. 'total_days' => '出勤总天数',
  173. 'rd_total_days' => '研发出勤天数',
  174. 'total_hours' => '出勤总工时',
  175. 'rd_total_hours'=> '研发总工时'
  176. ];
  177. // --- 3. 循环校验明细 ---
  178. foreach ($data['details'] as $key => $value) {
  179. $line = $key + 1; // 行号
  180. if (empty($value['device_id'])) return [false, "第{$line}行:设备ID不能为空"];
  181. $deviceId = $value['device_id'];
  182. $deviceDisplayName = $deviceMap[$deviceId] ?? "";
  183. if(empty($deviceDisplayName)) return [false, "第{$line}行:设备不存在或已被删除"];
  184. // 基础数字格式检查
  185. foreach ($fieldNames as $field => $cnName) {
  186. $precision = 2;
  187. $res = $this->checkNumber($value[$field], $precision, 'non-negative');
  188. if (!$res['valid']) {
  189. return [false, "第{$line}行:设备{$deviceDisplayName}的{$cnName}填写不规范({$res['error']})"];
  190. }
  191. }
  192. // --- 4. 业务逻辑校验 ---
  193. $sysData = $deviceStats[$deviceId] ?? null;
  194. if ($sysData) {
  195. // A. 内部逻辑:研发不能大于总额
  196. if ($value['rd_total_days'] > $value['total_days']) {
  197. return [false, "第{$line}行:设备{$deviceDisplayName}的研发出勤天数不能大于出勤总天数"];
  198. }
  199. if ($value['rd_total_hours'] > $value['total_hours']) {
  200. return [false, "第{$line}行:设备{$deviceDisplayName}的研发总工时不能大于出勤总工时"];
  201. }
  202. // B. 外部逻辑:不能超过系统根据日历算出的上限
  203. if ($value['total_days'] != $sysData['attendance_days']) {
  204. return [false, "第{$line}行:设备{$deviceDisplayName}的出勤总天数({$value['total_days']})不等于当月标准天数({$sysData['attendance_days']})"];
  205. }
  206. if ($value['total_hours'] != $sysData['final_work_hour']) {
  207. return [false, "第{$line}行:设备{$deviceDisplayName}的出勤总工时({$value['total_hours']})不等于当月标准工时({$sysData['final_work_hour']})"];
  208. }
  209. }
  210. $data['details'][$key]['top_depart_id'] = $data['top_depart_id'];
  211. }
  212. // --- 5. 查重与唯一性校验 ---
  213. list($status, $msg) = $this->checkArrayRepeat($data['details'], 'device_id', '设备');
  214. if (!$status) return [false, $msg];
  215. $query = MonthlyDwOrder::where('top_depart_id', $data['top_depart_id'])
  216. ->where('month', $data['month'])
  217. ->where('del_time', 0);
  218. if (!$is_add) {
  219. if (empty($data['id'])) return [false, 'ID不能为空'];
  220. $query->where('id', '<>', $data['id']);
  221. }
  222. if ($query->exists()) {
  223. return [false, date("Y-m", $data['month']) . '已存在设备月度研发工时单'];
  224. }
  225. return [true, ''];
  226. }
  227. public function monthlyDwOrderRule1(&$data, $user, $is_add = true){
  228. if(empty($data['month'])) return [false, '月份不能为空'];
  229. $data['month'] = $this->changeDateToDate($data['month']);
  230. $data['top_depart_id'] = $user['top_depart_id'];
  231. if(empty($data['details'])) return [false, '设备月度工时单明细不能为空'];
  232. foreach ($data['details'] as $key => $value){
  233. if(empty($value['device_id'])) return [false, '设备不能为空'];
  234. $res = $this->checkNumber($value['total_days'],0,'non-negative');
  235. if(! $res['valid']) return [false,'出勤总天数:' . $res['error']];
  236. $res = $this->checkNumber($value['rd_total_days'],0,'non-negative');
  237. if(! $res['valid']) return [false,'研发出勤总天数:' . $res['error']];
  238. $res = $this->checkNumber($value['total_hours'],2,'non-negative');
  239. if(! $res['valid']) return [false,'出勤总工时:' . $res['error']];
  240. $res = $this->checkNumber($value['rd_total_hours'],2,'non-negative');
  241. if(! $res['valid']) return [false,'研发总工时:' . $res['error']];
  242. $data['details'][$key]['top_depart_id'] = $data['top_depart_id'];
  243. }
  244. list($status, $msg) = $this->checkArrayRepeat($data['details'],'device_id','设备');
  245. if(! $status) return [false, $msg];
  246. if($is_add){
  247. $bool = MonthlyDwOrder::where('top_depart_id', $data['top_depart_id'])
  248. ->where('month', $data['month'])
  249. ->where('del_time',0)
  250. ->exists();
  251. }else{
  252. if(empty($data['id'])) return [false,'ID不能为空'];
  253. $bool = MonthlyDwOrder::where('top_depart_id', $data['top_depart_id'])
  254. ->where('month', $data['month'])
  255. ->where('id','<>',$data['id'])
  256. ->where('del_time',0)
  257. ->exists();
  258. }
  259. if($bool) return [false, date("Y-m", $data['month']) . '已存在设备月度研发工时单'];
  260. return [true, ''];
  261. }
  262. public function fillData($data){
  263. if(empty($data['data'])) return $data;
  264. $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_column($data['data'],'crt_id')));
  265. foreach ($data['data'] as $key => $value){
  266. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
  267. $data['data'][$key]['month'] = $value['month'] ? date('Y-m',$value['month']) : '';
  268. $data['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
  269. }
  270. return $data;
  271. }
  272. public function fillDataForExport($data, $column, &$return)
  273. {
  274. if(empty($data)) return;
  275. $mainIds = array_column($data, 'id');
  276. // 获取详情映射 [main_id => [details...]]
  277. $detailsMap = $this->getDetailsMap($mainIds);
  278. // 默认空行模板
  279. $defaultRow = array_fill_keys($column, '');
  280. foreach ($data as $main) {
  281. $mainId = $main['id'];
  282. $details = $detailsMap[$mainId] ?? [];
  283. // 提取主表信息
  284. $mainInfo = [
  285. 'code' => $main['code'],
  286. 'month' => $main['month'] ? date('Y-m', $main['month']) : '',
  287. ];
  288. if (empty($details)) {
  289. // 如果没有详情,至少导出一行主表信息(可选)
  290. $return[] = array_merge($defaultRow, $mainInfo);
  291. } else {
  292. // 核心:遍历详情,每一行详情都合并主表信息
  293. foreach ($details as $sub) {
  294. // 合并主表字段 + 详情字段
  295. $fullRow = array_merge($mainInfo, $sub);
  296. // 过滤掉不在导出列里的字段,并补充缺失列
  297. $return[] = array_merge($defaultRow, array_intersect_key($fullRow, $defaultRow));
  298. }
  299. }
  300. }
  301. }
  302. public function getDetailsMap($main_ids)
  303. {
  304. // 获取详情
  305. $details = MonthlyDwOrderDetails::where('del_time', 0)
  306. ->whereIn('main_id', $main_ids)
  307. ->get();
  308. // 获取设备信息
  309. $empIds = $details->pluck('device_id')->unique();
  310. $empMap = Device::whereIn('id', $empIds)->get()->keyBy('id');
  311. $res = [];
  312. foreach ($details as $item) {
  313. $tmpEmp = $empMap[$item->device_id] ?? null;
  314. // 组装每一行详情需要展示的字段
  315. $res[$item->main_id][] = [
  316. 'device_code' => $tmpEmp ? $tmpEmp->code : '',
  317. 'device_title' => $tmpEmp ? $tmpEmp->title : '',
  318. 'total_days' => $item->total_days,
  319. 'rd_total_days' => $item->rd_total_days,
  320. 'total_hours' => $item->total_hours,
  321. 'rd_total_hours' => $item->rd_total_hours,
  322. ];
  323. }
  324. return $res; // 返回 [main_id => [detail_row, detail_row]]
  325. }
  326. //设备日工时单----------------------------------------------
  327. public function dailyDwOrderEdit($data,$user){
  328. list($status,$msg) = $this->dailyDwOrderRule($data, $user, false);
  329. if(!$status) return [$status,$msg];
  330. try {
  331. DB::beginTransaction();
  332. $model = DailyDwOrder::where('id',$data['id'])->first();
  333. $model->item_id = $data['item_id'] ?? 0;
  334. $model->save();
  335. $time = time();
  336. DailyDwOrderDetails::where('del_time',0)
  337. ->where('main_id', $model->id)
  338. ->update(['del_time' => $time]);
  339. $this->saveDetailDaily($model->id, $time, $data);
  340. DB::commit();
  341. }catch (\Exception $exception){
  342. DB::rollBack();
  343. return [false,$exception->getMessage()];
  344. }
  345. return [true, ''];
  346. }
  347. public function dailyDwOrderAdd($data,$user){
  348. list($status,$msg) = $this->dailyDwOrderRule($data, $user);
  349. if(!$status) return [$status,$msg];
  350. try {
  351. DB::beginTransaction();
  352. $model = new DailyDwOrder();
  353. $model->code = $this->generateBillNo([
  354. 'top_depart_id' => $user['top_depart_id'],
  355. 'type' => DailyDwOrder::Order_type,
  356. 'period' => date("Ym", $data['order_time'])
  357. ]);
  358. $model->order_time = $data['order_time'] ?? 0;
  359. $model->item_id = $data['item_id'] ?? 0;
  360. $model->crt_id = $user['id'];
  361. $model->top_depart_id = $data['top_depart_id'];
  362. $model->save();
  363. $this->saveDetailDaily($model->id, time(), $data);
  364. DB::commit();
  365. }catch (\Exception $exception){
  366. DB::rollBack();
  367. return [false,$exception->getMessage()];
  368. }
  369. return [true, ''];
  370. }
  371. private function saveDetailDaily($id, $time, $data){
  372. if(! empty($data['details'])){
  373. $unit = [];
  374. foreach ($data['details'] as $value){
  375. $unit[] = [
  376. 'main_id' => $id,
  377. 'device_id' => $value['device_id'],
  378. 'start_time_hour' => $value['start_time_hour'],
  379. 'start_time_min' => $value['start_time_min'],
  380. 'end_time_hour' => $value['end_time_hour'],
  381. 'end_time_min' => $value['end_time_min'],
  382. 'total_work_min' => $value['total_work_min'],
  383. 'crt_time' => $time,
  384. 'top_depart_id' => $value['top_depart_id'],
  385. ];
  386. }
  387. if(! empty($unit)) DailyDwOrderDetails::insert($unit);
  388. }
  389. }
  390. private function getDetailDaily($id){
  391. $data = DailyDwOrderDetails::where('del_time',0)
  392. ->where('main_id', $id)
  393. ->select('device_id', 'start_time_hour', 'start_time_min', 'end_time_hour', 'end_time_min', 'total_work_min')
  394. ->get()->toArray();
  395. $id = array_column($data,'device_id');
  396. $map = Device::whereIn('id',$id)
  397. ->select('title','id','code')
  398. ->get()
  399. ->keyBy('id')
  400. ->toArray();
  401. foreach ($data as $key => $value){
  402. $tmp = $map[$value['device_id']] ?? [];
  403. $merge = [];
  404. $merge['device_title'] = $tmp['title'];
  405. $merge['device_code'] = $tmp['code'];
  406. $data[$key] = array_merge($value, $merge);
  407. }
  408. $detail = [
  409. 'details' => $data,
  410. ];
  411. foreach ($detail as $key => $value) {
  412. if (empty($value)) {
  413. $detail[$key] = (object)[]; // 转成 stdClass 对象
  414. }
  415. }
  416. return $detail;
  417. }
  418. public function dailyDwOrderDel($data){
  419. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  420. try {
  421. DB::beginTransaction();
  422. $time = time();
  423. DailyDwOrder::where('del_time',0)
  424. ->whereIn('id',$data['id'])
  425. ->update(['del_time' => $time]);
  426. DailyDwOrderDetails::where('del_time',0)
  427. ->whereIn('main_id', $data['id'])
  428. ->update(['del_time' => $time]);
  429. DB::commit();
  430. }catch (\Exception $exception){
  431. DB::rollBack();
  432. return [false,$exception->getMessage()];
  433. }
  434. return [true, ''];
  435. }
  436. public function dailyDwOrderDetail($data, $user){
  437. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  438. $customer = DailyDwOrder::where('del_time',0)
  439. ->where('id',$data['id'])
  440. ->first();
  441. if(empty($customer)) return [false,'设备日工时单不存在或已被删除'];
  442. $customer = $customer->toArray();
  443. $customer['crt_name'] = Employee::where('id',$customer['crt_id'])->value('title');
  444. $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';
  445. $item = Item::where('id', $customer['item_id'])->first();
  446. $customer['item_title'] = $item->title;
  447. $customer['item_code'] = $item->code;
  448. $customer['order_time'] = $customer['order_time'] ? date("Y-m-d",$customer['order_time']): '';
  449. $details = $this->getDetailDaily($data['id']);
  450. $customer = array_merge($customer, $details);
  451. return [true, $customer];
  452. }
  453. public function dailyDwOrderCommon($data,$user, $field = []){
  454. if(empty($field)) $field = DailyDwOrder::$field;
  455. $model = DailyDwOrder::Clear($user,$data);
  456. $model = $model->where('del_time',0)
  457. ->select($field)
  458. ->orderby('id', 'desc');
  459. if(! empty($data['code'])) $model->where('code', 'LIKE', '%'.$data['code'].'%');
  460. if(! empty($data['id'])) $model->whereIn('id', $data['id']);
  461. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  462. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  463. $model->where('crt_time','>=',$return[0]);
  464. $model->where('crt_time','<=',$return[1]);
  465. }
  466. return $model;
  467. }
  468. public function dailyDwOrderList($data,$user){
  469. $model = $this->dailyDwOrderCommon($data, $user);
  470. $list = $this->limit($model,'',$data);
  471. $list = $this->fillDataDaily($list);
  472. return [true, $list];
  473. }
  474. public function dailyDwOrderRule(&$data, $user, $is_add = true){
  475. if(empty($data['order_time'])) return [false, '单据日期不能为空'];
  476. $data['order_time'] = $this->changeDateToDate($data['order_time']);
  477. $orderTime = $data['order_time'];
  478. $itemId = $data['item_id'] ?? 0;
  479. if(empty($itemId)) return [false, '项目不能为空'];
  480. $bool = Item::where('del_time',0)->where('id', $itemId)->exists();
  481. if(!$bool) return [false, '项目不存在或已被删除'];
  482. $data['top_depart_id'] = $user['top_depart_id'];
  483. if(empty($data['details'])) return [false, '设备日工时单明细不能为空'];
  484. // --- 1. 批量预获取人员信息,用于报错提示 ---
  485. $allEmpIds = array_filter(array_unique(array_column($data['details'], 'device_id')));
  486. $empDisplayMap = Device::whereIn('id', $allEmpIds)
  487. ->get(['id', 'code', 'title'])
  488. ->mapWithKeys(function($item){
  489. return [$item->id => "[{$item->code}]{$item->title}"];
  490. })->toArray();
  491. // 2. 本次提交内部重叠记录
  492. $internalOverlap = [];
  493. foreach ($data['details'] as $key => $value){
  494. $empId = $value['device_id'] ?? 0;
  495. if(empty($empId)) return [false, '设备不能为空'];
  496. $empName = $empDisplayMap[$empId] ?? "ID:{$empId}";
  497. // 校验数字有效性
  498. $res = $this->checkNumber($value['start_time_hour'], 0, 'non-negative');
  499. if(!$res['valid']) return [false, "设备{$empName}开始点:" . $res['error']];
  500. if($value['start_time_hour'] > 23) return [false, false, "设备{$empName}开始点不合法"];
  501. $res = $this->checkNumber($value['start_time_min'], 0, 'non-negative');
  502. if(!$res['valid']) return [false, "设备{$empName}开始分:" . $res['error']];
  503. if($value['start_time_min'] > 60) return [false, false, "设备{$empName}开始点不合法"];
  504. $res = $this->checkNumber($value['end_time_hour'], 0, 'non-negative');
  505. if(!$res['valid']) return [false, "设备{$empName}结束点:" . $res['error']];
  506. if($value['end_time_hour'] > 24) return [false, false, "设备{$empName}结束点不合法"];
  507. $res = $this->checkNumber($value['end_time_min'], 0, 'non-negative');
  508. if(!$res['valid']) return [false, "设备{$empName}结束分:" . $res['error']];
  509. if($value['end_time_min'] > 60) return [false, false, "设备{$empName}结束分不合法"];
  510. $currentStart = $value['start_time_hour'] * 60 + $value['start_time_min'];
  511. $currentEnd = $value['end_time_hour'] * 60 + $value['end_time_min'];
  512. if ($currentStart >= $currentEnd) {
  513. return [false, "设备{$empName}:开始时间必须早于结束时间"];
  514. }
  515. // --- 3. 内部重叠校验(防止一次提交多行重复) ---
  516. if (isset($internalOverlap[$empId])) {
  517. foreach ($internalOverlap[$empId] as $period) {
  518. if ($currentStart < $period['e'] && $period['s'] < $currentEnd) {
  519. return [false, "设备{$empName}在本次提交的多行明细中时间段重叠"];
  520. }
  521. }
  522. }
  523. $internalOverlap[$empId][] = ['s' => $currentStart, 'e' => $currentEnd];
  524. $query = DB::table('daily_dw_order_details as d')
  525. ->join('daily_dw_order as m', 'd.main_id', '=', 'm.id')
  526. ->where('m.top_depart_id', $data['top_depart_id'])
  527. ->where('m.order_time', $orderTime)
  528. ->where('m.item_id', $itemId)
  529. ->where('d.device_id', $empId)
  530. ->where('m.del_time', 0)
  531. ->where('d.del_time', 0);
  532. if (!$is_add && !empty($data['id'])) {
  533. $query->where('m.id', '<>', $data['id']);
  534. }
  535. $existingPeriods = $query->select('d.start_time_hour', 'd.start_time_min', 'd.end_time_hour', 'd.end_time_min')->get();
  536. foreach ($existingPeriods as $p) {
  537. $exStart = $p->start_time_hour * 60 + $p->start_time_min;
  538. $exEnd = $p->end_time_hour * 60 + $p->end_time_min;
  539. if ($currentStart < $exEnd && $exStart < $currentEnd) {
  540. return [false, "设备{$empName}在该项目该日已有其他工时单创建重叠的时间段数据"];
  541. }
  542. }
  543. $data['details'][$key]['top_depart_id'] = $data['top_depart_id'];
  544. }
  545. if(!$is_add){
  546. if(empty($data['id'])) return [false,'ID不能为空'];
  547. $bool = DailyDwOrder::where('top_depart_id', $data['top_depart_id'])
  548. ->where('id',$data['id'])
  549. ->where('del_time',0)
  550. ->exists();
  551. if(!$bool) return [false, '设备日工时单不存在或已被删除'];
  552. }
  553. return [true, ''];
  554. }
  555. public function fillDataDaily($data){
  556. if(empty($data['data'])) return $data;
  557. $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_column($data['data'],'crt_id')));
  558. $item = (new ItemService())->getItemMap(array_unique(array_column($data['data'],'item_id')));
  559. foreach ($data['data'] as $key => $value){
  560. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
  561. $data['data'][$key]['order_time'] = $value['order_time'] ? date('Y-m-d',$value['order_time']) : '';
  562. $data['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
  563. $item_tmp = $item[$value['item_id']] ?? [];
  564. $data['data'][$key]['item_title'] = $item_tmp['title'] ?? '';
  565. $data['data'][$key]['item_code'] = $item_tmp['code'] ?? '';
  566. }
  567. return $data;
  568. }
  569. public function fillDataForExportDaily($data, $column, &$return)
  570. {
  571. if (empty($data)) return;
  572. $mainIds = array_column($data, 'id');
  573. // 1. 获取详情及所有关联档案(项目、设备)的映射
  574. $detailsMap = $this->getDwDailyDetailsMap($mainIds, $data);
  575. foreach ($data as $main) {
  576. $mainId = $main['id'];
  577. $details = $detailsMap[$mainId] ?? [];
  578. // 2. 提取并格式化主表共有信息
  579. $mainInfo = [
  580. 'code' => $main['code'],
  581. 'order_time' => !empty($main['order_time']) ? date('Y-m-d', $main['order_time']) : '',
  582. ];
  583. if (empty($details)) {
  584. // 无明细时只导出一行主表信息
  585. $tempRow = [];
  586. foreach ($column as $col) {
  587. $tempRow[] = $mainInfo[$col] ?? '';
  588. }
  589. $return[] = $tempRow;
  590. } else {
  591. // 3. 平铺:将设备明细信息、项目信息与主表信息合并
  592. foreach ($details as $sub) {
  593. $fullRowData = array_merge($mainInfo, $sub);
  594. $tempRow = [];
  595. foreach ($column as $col) {
  596. $tempRow[] = $fullRowData[$col] ?? '';
  597. }
  598. $return[] = $tempRow;
  599. }
  600. }
  601. }
  602. }
  603. public function getDwDailyDetailsMap($mainIds, $mainData)
  604. {
  605. // 1. 获取设备工时子表记录
  606. $details = DB::table('daily_dw_order_details')
  607. ->where('del_time', 0)
  608. ->whereIn('main_id', $mainIds)
  609. ->get();
  610. // 2. 提取关联 ID(设备 ID 和 项目 ID)
  611. $deviceIds = $details->pluck('device_id')->unique();
  612. $itemIds = array_unique(array_column($mainData, 'item_id'));
  613. // 3. 批量获取设备档案和项目档案
  614. $deviceMap = DB::table('device')
  615. ->whereIn('id', $deviceIds)
  616. ->get(['id', 'title', 'code'])
  617. ->keyBy('id');
  618. $itemMap = DB::table('item')
  619. ->whereIn('id', $itemIds)
  620. ->get(['id', 'title', 'code'])
  621. ->keyBy('id');
  622. // 4. 预挂载主表的项目信息(item_code, item_title)
  623. $mainItemInfo = [];
  624. foreach ($mainData as $m) {
  625. $proj = $itemMap[$m['item_id']] ?? null;
  626. $mainItemInfo[$m['id']] = [
  627. 'item_code' => $proj ? $proj->code : '',
  628. 'item_title' => $proj ? $proj->title : '',
  629. ];
  630. }
  631. $res = [];
  632. // 如果没有详情,初始化空结构
  633. if ($details->isEmpty()) {
  634. foreach ($mainItemInfo as $mId => $info) {
  635. $res[$mId] = [];
  636. }
  637. return $res;
  638. }
  639. // 5. 循环子表,合并设备档案信息
  640. foreach ($details as $item) {
  641. $device = $deviceMap[$item->device_id] ?? null;
  642. $detailRow = [
  643. // 设备信息(对应 Excel 配置中的 key)
  644. 'device_code' => $device ? $device->code : '',
  645. 'device_title' => $device ? $device->title : '',
  646. // 时间信息
  647. 'start_time' => sprintf('%02d:%02d', $item->start_time_hour, $item->start_time_min),
  648. 'end_time' => sprintf('%02d:%02d', $item->end_time_hour, $item->end_time_min),
  649. // 项目信息(由主表平铺而来)
  650. 'item_code' => $mainItemInfo[$item->main_id]['item_code'] ?? '',
  651. 'item_title' => $mainItemInfo[$item->main_id]['item_title'] ?? '',
  652. ];
  653. $res[$item->main_id][] = $detailRow;
  654. }
  655. return $res;
  656. }
  657. }