ScheduleService.php 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413
  1. <?php
  2. namespace App\Service;
  3. use App\Model\BasicType;
  4. use App\Model\Construction;
  5. use App\Model\Employee;
  6. use App\Model\Product;
  7. use App\Model\ProductActivity;
  8. use App\Model\ProductActivityPrice;
  9. use App\Model\Schedule;
  10. use App\Model\ScheduleDetail;
  11. use App\Model\ScheduleInfo;
  12. use Illuminate\Support\Facades\DB;
  13. class ScheduleService extends Service
  14. {
  15. public function edit($data,$user){
  16. list($status,$msg) = $this->scheduleRule($data, $user, false);
  17. if(!$status) return [$status,$msg];
  18. try {
  19. DB::beginTransaction();
  20. $model = Schedule::where('id',$data['id'])->first();
  21. $model->start_time = $data['start_time'] ?? 0;
  22. $model->end_time = $data['end_time'] ?? 0;
  23. $model->mark = $data['mark'] ?? '';
  24. $model->save();
  25. $time = time();
  26. ScheduleDetail::where('schedule_id',$data['id'])
  27. ->where('del_time',0)
  28. ->update(['del_time' => $time]);
  29. ScheduleInfo::where('schedule_id',$data['id'])
  30. ->where('del_time',0)
  31. ->update(['del_time' => $time]);
  32. if(! empty($data['day_time'])){
  33. $insert_detail = $insert = [];
  34. foreach ($data['day_time'] as $value){
  35. $insert_detail[] = [
  36. 'schedule_id' => $model->id,
  37. 'crt_time' => $time,
  38. 'start_time' => $value['start_time'] ?? "",
  39. 'end_time' => $value['end_time'] ?? "",
  40. 'num' => $value['num'] ?? 0,
  41. ];
  42. for ($i=0;$i<$value['num'];$i++){
  43. foreach ($data['time_range'] as $range){
  44. $date = date('Y-m-d',$range);
  45. $start_time = strtotime($date . " " .$value['start_time']);
  46. $end_time = strtotime($date . " " .$value['end_time']);
  47. $insert[] = [
  48. 'schedule_id' => $model->id,
  49. 'crt_time' => $time,
  50. 'day' => $range ?? 0, //0点的时间戳
  51. 'start_time' => $start_time ?? 0, //加上开始时间段
  52. 'end_time' => $end_time ?? 0,//加上结束时间段
  53. ];
  54. }
  55. }
  56. }
  57. ScheduleDetail::insert($insert_detail);
  58. ScheduleInfo::insert($insert);
  59. }
  60. DB::commit();
  61. }catch (\Exception $exception){
  62. DB::rollBack();
  63. return [false,$exception->getMessage()];
  64. }
  65. return [true,''];
  66. }
  67. public function add($data,$user){
  68. list($status,$msg) = $this->scheduleRule($data, $user);
  69. if(!$status) return [$status,$msg];
  70. try {
  71. DB::beginTransaction();
  72. $model = new Schedule();
  73. $model->start_time = $data['start_time'] ?? 0;
  74. $model->end_time = $data['end_time'] ?? 0;
  75. $model->mark = $data['mark'] ?? '';
  76. $model->crt_id = $user['id'];
  77. $model->depart_id = $data['depart_id'] ?? 0;
  78. $model->top_depart_id = $data['top_depart_id'] ?? 0;
  79. $model->save();
  80. $time = time();
  81. if(! empty($data['day_time'])){
  82. $insert_detail = $insert = [];
  83. foreach ($data['day_time'] as $value){
  84. $insert_detail[] = [
  85. 'schedule_id' => $model->id,
  86. 'crt_time' => $time,
  87. 'start_time' => $value['start_time'] ?? "",
  88. 'end_time' => $value['end_time'] ?? "",
  89. 'num' => $value['num'] ?? 0,
  90. ];
  91. for ($i=0;$i<$value['num'];$i++){
  92. foreach ($data['time_range'] as $range){
  93. $date = date('Y-m-d',$range);
  94. $start_time = strtotime($date . " " .$value['start_time']);
  95. $end_time = strtotime($date . " " .$value['end_time']);
  96. $insert[] = [
  97. 'schedule_id' => $model->id,
  98. 'crt_time' => $time,
  99. 'day' => $range ?? 0, //0点的时间戳
  100. 'start_time' => $start_time ?? 0, //加上开始时间段
  101. 'end_time' => $end_time ?? 0,//加上结束时间段
  102. ];
  103. }
  104. }
  105. }
  106. ScheduleDetail::insert($insert_detail);
  107. ScheduleInfo::insert($insert);
  108. }
  109. DB::commit();
  110. }catch (\Exception $exception){
  111. DB::rollBack();
  112. return [false,$exception->getMessage()];
  113. }
  114. return [true,''];
  115. }
  116. public function del($data){
  117. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  118. $boolean = Construction::where('del_time',0)
  119. ->where('schedule_id',$data['id'])
  120. ->exists();
  121. if($boolean) return [false,'施工单已使用排期,操作失败!'];
  122. try {
  123. DB::beginTransaction();
  124. $time = time();
  125. Schedule::where('id',$data['id'])->update(['del_time' => $time]);
  126. ScheduleDetail::where('schedule_id',$data['id'])
  127. ->where('del_time',0)
  128. ->update(['del_time' => $time]);
  129. ScheduleInfo::where('schedule_id',$data['id'])
  130. ->where('del_time',0)
  131. ->update(['del_time' => $time]);
  132. DB::commit();
  133. }catch (\Exception $exception){
  134. DB::rollBack();
  135. return [false,$exception->getMessage()];
  136. }
  137. return [true,''];
  138. }
  139. public function detail($data,$user){
  140. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  141. $schedule = Schedule::where('del_time',0)
  142. ->where('id',$data['id'])
  143. ->first();
  144. if(empty($schedule)) return [false,'排班设置不存在或已被删除'];
  145. $schedule = $schedule->toArray();
  146. $info = ScheduleDetail::where('del_time',0)
  147. ->where('schedule_id',$data['id'])
  148. ->select('start_time','end_time','num')
  149. ->get()->toArray();
  150. foreach ($info as $key => $value){
  151. $info[$key]['choose'] = 1;
  152. }
  153. $schedule['detail'] = array_values($info);
  154. $schedule['crt_name'] = Employee::where('id',$schedule['crt_id'])->value('emp_name');
  155. $schedule['crt_time'] = $schedule['crt_time'] ? date("Y-m-d H:i:s",$schedule['crt_time']): '';
  156. return [true, $schedule];
  157. }
  158. //暂时不用
  159. public function detail2($data,$user){
  160. if($this->isEmpty($data,'id')) return [false,'请选择数据!'];
  161. $schedule = Schedule::where('del_time',0)
  162. ->where('id',$data['id'])
  163. ->first();
  164. if(empty($schedule)) return [false,'排班设置不存在或已被删除'];
  165. $schedule = $schedule->toArray();
  166. $date1 = date("Y-m-d", $schedule['start_time']);
  167. $date2 = date("Y-m-d", $schedule['end_time']);
  168. $datetime1 = new \DateTime($date1);
  169. $datetime2 = new \DateTime($date2);
  170. $interval = $datetime1->diff($datetime2);
  171. $day = $interval->days + 1;
  172. $info = ScheduleInfo::where('del_time',0)
  173. ->where('schedule_id',$data['id'])
  174. ->select('start_time','end_time','num')
  175. ->get()->toArray();
  176. $infos = [];
  177. foreach ($info as $value){
  178. $start_time = date("H:i",$value['start_time']);
  179. $end_time = date("H:i",$value['end_time']);
  180. if(isset($infos[$start_time . $end_time])){
  181. $infos[$start_time . $end_time]['num'] += 1;
  182. }else{
  183. $infos[$start_time . $end_time] = [
  184. 'start_time' => $start_time,
  185. 'end_time' => $end_time,
  186. 'num' => 1,
  187. 'choose' => 1,
  188. ];
  189. }
  190. }
  191. foreach ($infos as $key => $value){
  192. $infos[$key]['num'] = $value['num'] / $day;
  193. }
  194. ksort($infos);
  195. $schedule['detail'] = array_values($infos);
  196. $schedule['crt_name'] = Employee::where('id',$schedule['crt_id'])->value('emp_name');
  197. $schedule['crt_time'] = $schedule['crt_time'] ? date("Y-m-d H:i:s",$schedule['crt_time']): '';
  198. return [true, $schedule];
  199. }
  200. public function getList($data,$user){
  201. $model = Schedule::TopClear($user,$data);
  202. $model = $model->where('del_time',0)
  203. ->select('id','crt_id','mark','start_time','end_time','crt_time')
  204. ->orderby('id', 'desc');
  205. if(! empty($data['mark'])) $model->where('mark', 'LIKE', '%'.$data['mark'].'%');
  206. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  207. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  208. $model->where('crt_time','>=',$return[0]);
  209. $model->where('crt_time','<=',$return[1]);
  210. }
  211. if(! empty($data['schedule'][0]) && ! empty($data['schedule'][1])) {
  212. $return = $this->changeDateToTimeStampAboutRange($data['schedule']);
  213. $model->where('start_time','>=',$return[0]);
  214. $model->where('end_time','<=',$return[1]);
  215. }
  216. $list = $this->limit($model,'',$data);
  217. $list = $this->fillData($list,$user);
  218. return [true, $list];
  219. }
  220. public function scheduleRule(&$data, $user, $is_add = true){
  221. if(empty($data['schedule'][0]) || empty($data['schedule'][1])) return [false,'排班日期不能为空'];
  222. $data['start_time'] = $this->changeDateToDate($data['schedule'][0]);
  223. $data['end_time'] = $this->changeDateToDate($data['schedule'][1]);
  224. $data['time_range'] = $this->getTimestampRange($data['start_time'],$data['end_time']);
  225. if(empty($data['day_time'])) return [false,'排班时间段不能为空'];
  226. foreach ($data['day_time'] as $value){
  227. if(empty($value['start_time'])) return [false,'排班时间段开始时间不能为空'];
  228. if(empty($value['end_time'])) return [false,'排班时间段结束时间不能为空'];
  229. if(empty($value['num'])) return [false,'排班车间数量不能为空'];
  230. }
  231. if($is_add){
  232. $model = Schedule::TopClear($user,$data);
  233. $bool = $model->where('del_time',0)
  234. ->where('start_time', '<=', $data['end_time'])
  235. ->where('end_time', '>=', $data['start_time'])
  236. ->exists();
  237. }else{
  238. if(empty($data['id'])) return [false,'ID不能为空'];
  239. $model = Schedule::TopClear($user,$data);
  240. $bool = $model->where('del_time',0)
  241. ->where('id','<>',$data['id'])
  242. ->where('start_time', '<=', $data['end_time'])
  243. ->where('end_time', '>=', $data['start_time'])
  244. ->exists();
  245. $boolean = Construction::where('del_time',0)
  246. ->where('schedule_id',$data['id'])
  247. ->exists();
  248. if($boolean) return [false,'施工单已使用排期,编辑失败!'];
  249. }
  250. if($bool) return [false,'排班日期已经设置,请不要重复设置!'];
  251. //所属部门 以及 顶级部门
  252. if(empty($data['depart_id'])) $data['depart_id'] = $this->getDepart($user);
  253. $data['top_depart_id'] = $user['depart_map'][$data['depart_id']] ?? 0;
  254. return [true, $data];
  255. }
  256. public function fillData($data, $user){
  257. if(empty($data['data'])) return $data;
  258. $emp = Employee::whereIn('id',array_unique(array_column($data['data'],'crt_id')))
  259. ->pluck('emp_name','id')
  260. ->toArray();
  261. foreach ($data['data'] as $key => $value){
  262. $start_time = $value['start_time'] ? date("Y-m-d",$value['start_time']) : '';
  263. $end_time = $value['end_time'] ? date("Y-m-d",$value['end_time']) : '';
  264. $data['data'][$key]['schedule'] = $start_time . '——' . $end_time;
  265. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
  266. $data['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
  267. }
  268. return $data;
  269. }
  270. public function scheduleGetForConstruction($data,$user){
  271. if(empty($data['schedule'])) return [false,'请选择日期!'];
  272. $schedule = $this->changeDateToDate($data['schedule']);
  273. $model = Schedule::TopClear($user,$data);
  274. $schedule_id = $model->where('del_time',0)
  275. ->where('start_time', '<=', $schedule)
  276. ->where('end_time', '>=', $schedule)
  277. ->select('id')->get()->toArray();
  278. $schedule_id = array_column($schedule_id,'id');
  279. if(empty($schedule_id)) return [false,'该时间排班设置不存在或已被删除!'];
  280. $schedule_detail_list = ScheduleInfo::where('del_time',0)
  281. ->whereIn('schedule_id',$schedule_id)
  282. ->where('day',$schedule)
  283. ->where('is_use',ScheduleInfo::not_use)
  284. ->select('schedule_id','day','start_time','end_time')
  285. ->get()->toArray();
  286. if(empty($schedule_detail_list)) return [false,'该时间排班已满、不存在或已被删除!'];
  287. $return = [];
  288. foreach ($schedule_detail_list as $value){
  289. if(isset($return[$value['start_time'] . $value['end_time']])){
  290. $return[$value['start_time'] . $value['end_time']]['num'] += 1;
  291. }else{
  292. $tmp['schedule_id'] = $value['schedule_id'];
  293. $tmp['num'] = 1;
  294. $tmp['day_stamp'] = $value['day'];
  295. $tmp['day_start_stamp'] = $value['start_time'];
  296. $tmp['day_end_stamp'] = $value['end_time'];
  297. $tmp['day'] = date('Y-m-d',$value['day']);
  298. $tmp['start_time'] = date('H:i',$value['start_time']);
  299. $tmp['end_time'] = date('H:i',$value['end_time']);
  300. $return[$value['start_time'] . $value['end_time']] = $tmp;
  301. }
  302. }
  303. ksort($return);
  304. return [true, array_values($return)];
  305. }
  306. public function getTimestampRange($startTimestamp, $endTimestamp){
  307. // 将时间戳转换为日期格式
  308. $startDate = date('Y-m-d', $startTimestamp);
  309. $endDate = date('Y-m-d', $endTimestamp);
  310. // 创建日期范围
  311. $dateRange = [];
  312. $currentDate = strtotime($startDate);
  313. while ($currentDate <= strtotime($endDate)) {
  314. $dateRange[] = $currentDate;
  315. $currentDate = strtotime('+1 day', $currentDate);
  316. }
  317. // 将每个日期设置为当天的 0 点 0 分 0 秒并转换为时间戳
  318. $zeroTimestamps = [];
  319. foreach ($dateRange as $date) {
  320. $zeroTimestamps[] = strtotime(date('Y-m-d 00:00:00', $date));
  321. }
  322. return $zeroTimestamps;
  323. }
  324. public function getScheduleSetting($data,$user){
  325. if(empty($data['schedule'])) return [true,''];
  326. // 获取指定年月的开始日期时间戳
  327. $startTimestamp = strtotime($data['schedule'] . "-01");
  328. // 获取下个月的开始日期时间戳,然后减去一秒得到本月的结束日期时间戳
  329. $endTimestamp = strtotime("+1 month", $startTimestamp) - 1;
  330. $model = Schedule::TopClear($user,$data);
  331. $schedule = $model->where('del_time',0)
  332. ->where('start_time', '>=', $startTimestamp)
  333. ->where('end_time', '<=', $endTimestamp)
  334. ->get()->toArray();
  335. if(empty($schedule)) return [true,''];
  336. $schedule_detail_list = ScheduleDetail::where('del_time',0)
  337. ->whereIn('schedule_id',array_column($schedule,'id'))
  338. ->select('schedule_id','num','start_time','end_time')
  339. ->get()->toArray();
  340. if(empty($schedule_detail_list)) return [true,''];
  341. $schedule_detail_list_map = [];
  342. foreach ($schedule_detail_list as $key => $value){
  343. $schedule_detail_list_map[$value['schedule_id']][] = $value;
  344. }
  345. foreach ($schedule as $key => $value){
  346. $schedule[$key]['detail'] = $schedule_detail_list_map[$value['id']] ?? [];
  347. }
  348. return [true, $schedule];
  349. }
  350. }