|
@@ -0,0 +1,359 @@
|
|
|
+<?php
|
|
|
+
|
|
|
+namespace App\Service;
|
|
|
+
|
|
|
+use App\Model\DeviceOrder;
|
|
|
+use App\Model\DeviceOrderInfo;
|
|
|
+use App\Model\Employee;
|
|
|
+use App\Model\Equipment;
|
|
|
+use App\Model\EquipmentXj;
|
|
|
+use Illuminate\Support\Facades\DB;
|
|
|
+
|
|
|
+class InspectService extends Service
|
|
|
+{
|
|
|
+ //生成巡检单据
|
|
|
+ public function addOnSiteInspectionOrder(){
|
|
|
+ $deviceList = Equipment::where('del_time',0)
|
|
|
+ ->where('check_cycle','>',0)
|
|
|
+ ->select('id','title','code','check_cycle')
|
|
|
+ ->get()->toArray();
|
|
|
+ if(empty($deviceList)) return [false,'1.暂无启用巡检的设备'];
|
|
|
+ $timestamp1 = strtotime(date('Y-m-d 00:00:00'));
|
|
|
+ $timestamp2 = strtotime(date('Y-m-d 23:59:59'));
|
|
|
+ $equipment_id = array_column($deviceList,'id');
|
|
|
+ //今天已巡检的设备
|
|
|
+ $xj_data = DeviceOrderInfo::where('del_time',0)
|
|
|
+ ->where('type',DeviceOrder::Model_type_one)
|
|
|
+ ->whereIn('equipment_id', $equipment_id)
|
|
|
+ ->where('crt_time','>=',$timestamp1)
|
|
|
+ ->where('crt_time','<=',$timestamp2)
|
|
|
+ ->select('equipment_id')
|
|
|
+ ->get()->toArray();
|
|
|
+ $xj_data = array_column($xj_data,'equipment_id');
|
|
|
+ if(! empty($xj_data)) {
|
|
|
+ foreach ($deviceList as $key => $value){
|
|
|
+ if(in_array($value['id'], $xj_data)) unset($deviceList[$key]);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if(empty($deviceList)) return [false,'2.今日设备已全部生产巡检单'];
|
|
|
+
|
|
|
+ // 设备最大一次的巡检的时间 设置的首次巡检
|
|
|
+ list($equipment_map,$equipment_first_map) = $this->getXJLastData($equipment_id);
|
|
|
+
|
|
|
+ $insert_detail = [];
|
|
|
+ foreach ($deviceList as $value){
|
|
|
+ //设备巡检的时间
|
|
|
+ $first_time = $equipment_map[$value['id']] ?? 0;
|
|
|
+ if($first_time <= 0) continue;
|
|
|
+
|
|
|
+ if($timestamp2 >= $first_time && $timestamp1 <= $first_time){
|
|
|
+ $insert_detail[] = [
|
|
|
+ 'equipment_id' => $value['id'],
|
|
|
+ 'equipment_no' => $value['code'],
|
|
|
+ ];
|
|
|
+ }else{
|
|
|
+ //存在巡检数据 获取数据最近一次的时间 加上巡检周期
|
|
|
+ $detail_time = strtotime("+{$value['check_cycle']} days", $first_time);
|
|
|
+ if($timestamp2 >= $detail_time && $timestamp1 <= $detail_time){
|
|
|
+ $insert_detail[] = [
|
|
|
+ 'equipment_id' => $value['id'],
|
|
|
+ 'equipment_no' => $value['code'],
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if(empty($insert_detail)) return [false, '3.暂无今日要生成的巡检数据'];
|
|
|
+
|
|
|
+ //生成巡检单号
|
|
|
+ $order_number = $this->createOrderNumber();
|
|
|
+ try {
|
|
|
+ DB::beginTransaction();
|
|
|
+
|
|
|
+ $time = time();
|
|
|
+ $model = new DeviceOrder();
|
|
|
+ $model->type = DeviceOrder::Model_type_one;
|
|
|
+ $model->order_number = $order_number;
|
|
|
+ $model->crt_time = $time;
|
|
|
+ $model->hand_time = $time;
|
|
|
+ $model->save();
|
|
|
+ $device_order_id = $model->id;
|
|
|
+
|
|
|
+ //详情数据
|
|
|
+ foreach ($insert_detail as $key => $value){
|
|
|
+ $insert_detail[$key]['type'] = DeviceOrder::Model_type_one;
|
|
|
+ $insert_detail[$key]['crt_time'] = $time;
|
|
|
+ $insert_detail[$key]['device_order_id'] = $device_order_id;
|
|
|
+ $insert_detail[$key]['order_number'] = $order_number;
|
|
|
+ }
|
|
|
+ DeviceOrderInfo::insert($insert_detail);
|
|
|
+
|
|
|
+ DB::commit();
|
|
|
+ }catch (\Throwable $exception){
|
|
|
+ DB::rollBack();
|
|
|
+ return [false, $exception->getMessage()];
|
|
|
+ }
|
|
|
+
|
|
|
+ return [true, ''];
|
|
|
+ }
|
|
|
+
|
|
|
+ public function deviceOrderEdit($data,$user){
|
|
|
+ list($status,$msg) = $this->deviceRule($data, $user, false);
|
|
|
+ if(!$status) return [$status,$msg];
|
|
|
+
|
|
|
+ try {
|
|
|
+ DB::beginTransaction();
|
|
|
+
|
|
|
+ $model = DeviceOrder::where('id',$data['id'])->first();
|
|
|
+ if($model->del_time > 0) return [false, '单据不存在或已被删除'];
|
|
|
+
|
|
|
+ $model->mark = $data['mark'] ?? '';
|
|
|
+ $model->state = $data['state'] ?? 0;
|
|
|
+ $model->hand_time = $data['hand_time'] ?? 0;
|
|
|
+ $model->crt_id = $data['crt_id'] ?? 0;
|
|
|
+ $model->save();
|
|
|
+
|
|
|
+ $time = time();
|
|
|
+ DeviceOrderInfo::where('del_time',0)
|
|
|
+ ->where('device_order_id',$data['id'])
|
|
|
+ ->update(['del_time' => $time]);
|
|
|
+
|
|
|
+ if(! empty($data['sub'])){
|
|
|
+ $insert = [];
|
|
|
+ foreach ($data['sub'] as $value){
|
|
|
+ $insert[] = [
|
|
|
+ 'type' => $data['type'],
|
|
|
+ 'device_order_id' => $data['id'],
|
|
|
+ 'order_number' => $model->order_number,
|
|
|
+ 'equipment_id' => $value['equipment_id'],
|
|
|
+ 'equipment_no' => $value['equipment_no'],
|
|
|
+ 'state' => $value['state'],
|
|
|
+ 'mark' => $value['mark'] ?? "",
|
|
|
+ 'crt_time' => $time,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ DeviceOrderInfo::insert($insert);
|
|
|
+ }
|
|
|
+
|
|
|
+ DB::commit();
|
|
|
+ }catch (\Exception $exception){
|
|
|
+ DB::rollBack();
|
|
|
+ return [false,$exception->getMessage()];
|
|
|
+ }
|
|
|
+
|
|
|
+ return [true, ''];
|
|
|
+ }
|
|
|
+
|
|
|
+ public function deviceOrderAdd($data,$user){
|
|
|
+ list($status,$msg) = $this->deviceRule($data, $user);
|
|
|
+ if(!$status) return [$status,$msg];
|
|
|
+
|
|
|
+ try {
|
|
|
+ DB::beginTransaction();
|
|
|
+
|
|
|
+ $order_number = $this->createOrderNumber($data['type']);
|
|
|
+ $model = new DeviceOrder();
|
|
|
+ $model->type = $data['type'];
|
|
|
+ $model->order_number = $order_number;
|
|
|
+ $model->mark = $data['mark'] ?? '';
|
|
|
+ $model->state = $data['state'] ?? 0;
|
|
|
+ $model->hand_time = $data['hand_time'] ?? 0;
|
|
|
+ $model->crt_id = $data['crt_id'];
|
|
|
+ $model->save();
|
|
|
+ $device_order_id = $model->id;
|
|
|
+
|
|
|
+ $time = time();
|
|
|
+
|
|
|
+ if(! empty($data['sub'])){
|
|
|
+ $insert = [];
|
|
|
+ foreach ($data['sub'] as $value){
|
|
|
+ $insert[] = [
|
|
|
+ 'type' => $data['type'],
|
|
|
+ 'device_order_id' => $device_order_id,
|
|
|
+ 'order_number' => $order_number,
|
|
|
+ 'equipment_id' => $value['equipment_id'],
|
|
|
+ 'equipment_no' => $value['equipment_no'],
|
|
|
+ 'state' => $value['state'],
|
|
|
+ 'mark' => $value['mark'] ?? "",
|
|
|
+ 'crt_time' => $time,
|
|
|
+ ];
|
|
|
+ }
|
|
|
+ DeviceOrderInfo::insert($insert);
|
|
|
+ }
|
|
|
+
|
|
|
+ DB::commit();
|
|
|
+ }catch (\Exception $exception){
|
|
|
+ DB::rollBack();
|
|
|
+ return [false,$exception->getMessage()];
|
|
|
+ }
|
|
|
+
|
|
|
+ return [true, ''];
|
|
|
+ }
|
|
|
+
|
|
|
+ public function deviceRule(&$data, $user, $is_add = true){
|
|
|
+ if(empty($data['type'])) return [false,'单据类型不能为空'];
|
|
|
+ if(! isset(DeviceOrder::$prefix[$data['type']])) return [false,'单据类型不存在'];
|
|
|
+ if(! isset($data['crt_id'])) return [false,'单据创建人不能为空'];
|
|
|
+ if(empty($data['hand_time'])) return [false,'单据日期不能为空'];
|
|
|
+ if($data['type'] == DeviceOrder::Model_type_one) $data['hand_time'] = strtotime($data['hand_time']);
|
|
|
+ if(empty($data['sub'])) return [false, '表体信息不能为空'];
|
|
|
+
|
|
|
+ foreach ($data['sub'] as $value){
|
|
|
+ if(empty($value['equipment_id']) || empty($value['equipment_no'])) return [false, '设备信息不能为空'];
|
|
|
+ if(! isset($value['state']) || ! isset(DeviceOrderInfo::$prefix[$value['state']])) return [false, '设备状态信息不能为空'];
|
|
|
+ }
|
|
|
+
|
|
|
+ if(! $is_add){
|
|
|
+ if(empty($data['id'])) return [false, 'ID不能为空'];
|
|
|
+ }
|
|
|
+
|
|
|
+ return [true, $data];
|
|
|
+ }
|
|
|
+
|
|
|
+ public function deviceOrderDel($data,$user){
|
|
|
+ if($this->isEmpty($data,'id')) return [false,'请选择数据'];
|
|
|
+
|
|
|
+ try {
|
|
|
+ DB::beginTransaction();
|
|
|
+ $time = time();
|
|
|
+
|
|
|
+ DeviceOrder::where('del_time',0)->where('id',$data['id'])->update(['del_time' => $time]);
|
|
|
+ DeviceOrderInfo::where('device_order_id',$data['id'])
|
|
|
+ ->where('del_time',0)
|
|
|
+ ->update(['del_time' => $time]);
|
|
|
+
|
|
|
+ DB::commit();
|
|
|
+ }catch (\Exception $exception){
|
|
|
+ DB::rollBack();
|
|
|
+ return [false,$exception->getMessage()];
|
|
|
+ }
|
|
|
+
|
|
|
+ return [true, ''];
|
|
|
+ }
|
|
|
+
|
|
|
+ public function deviceOrderDetail($data,$user){
|
|
|
+ if($this->isEmpty($data,'id')) return [false,'请选择数据'];
|
|
|
+
|
|
|
+ $customer = DeviceOrder::where('del_time',0)
|
|
|
+ ->where('id',$data['id'])
|
|
|
+ ->first();
|
|
|
+ if(empty($customer)) return [false,'单据不存在或已被删除'];
|
|
|
+ $customer = $customer->toArray();
|
|
|
+ $customer['type_title'] = DeviceOrder::$prefix_title[$customer['type']] ?? "";
|
|
|
+ $customer['crt_title'] = Employee::where('id',$customer['crt_id'])->value('emp_name') ?? "系统生成";
|
|
|
+ $customer['crt_time'] = $customer['crt_time'] ? date("Y-m-d H:i:s",$customer['crt_time']): '';
|
|
|
+ $customer['hand_time'] = $customer['hand_time'] ? date("Y-m-d",$customer['hand_time']): '';
|
|
|
+ $customer['sub'] = [];
|
|
|
+ $sub = DeviceOrderInfo::where('del_time',0)
|
|
|
+ ->where('device_order_id',$data['id'])
|
|
|
+ ->select('equipment_id','equipment_no','state','mark')
|
|
|
+ ->get()->toArray();
|
|
|
+ $equ = Equipment::whereIn('id',array_unique(array_column($sub,'equipment_id')))
|
|
|
+ ->pluck('title','id')
|
|
|
+ ->toArray();
|
|
|
+ foreach ($sub as $key => $value){
|
|
|
+ $sub[$key]['equipment_title'] = $equ[$value['equipment_id']] ?? "";
|
|
|
+ }
|
|
|
+ $customer['sub'] = $sub;
|
|
|
+
|
|
|
+ return [true, $customer];
|
|
|
+ }
|
|
|
+
|
|
|
+ //单据列表
|
|
|
+ public function deviceOrderList($data){
|
|
|
+ $model = new DeviceOrder;
|
|
|
+ $model = $model->where('del_time',0)
|
|
|
+ ->select('type','id','order_number','crt_id','crt_time','mark','state','hand_time')
|
|
|
+ ->orderby('id', 'desc');
|
|
|
+
|
|
|
+ if(! empty($data['order_number'])) $model->where('order_number', 'LIKE', '%'.$data['order_number'].'%');
|
|
|
+ if(isset($data['type'])) $model->where('type', $data['type']);
|
|
|
+ if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) $model->whereBetween('crt_time',[$data['crt_time'][0],$data['crt_time'][1]]);
|
|
|
+ if(! empty($data['hand_time'][0]) && ! empty($data['hand_time'][1])) $model->whereBetween('hand_time',[$data['hand_time'][0],$data['hand_time'][1]]);
|
|
|
+ if(! empty($data['crt_id'])) $model->where('crt_id', $data['crt_id']);
|
|
|
+
|
|
|
+ $list = $this->limit($model,'',$data);
|
|
|
+ $list = $this->fillData($list);
|
|
|
+
|
|
|
+ return [true, $list];
|
|
|
+ }
|
|
|
+
|
|
|
+ public function fillData($data){
|
|
|
+ if(empty($data['data'])) return $data;
|
|
|
+
|
|
|
+ $emp = Employee::whereIn('id',array_unique(array_filter(array_column($data['data'],'crt_id'))))
|
|
|
+ ->pluck('emp_name','id')
|
|
|
+ ->toArray();
|
|
|
+ foreach ($data['data'] as $key => $value){
|
|
|
+ $data['data'][$key]['type_title'] = DeviceOrder::$prefix_title[$value['type']] ?? "";
|
|
|
+ $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d',$value['crt_time']) : '';
|
|
|
+ $data['data'][$key]['hand_time'] = $value['hand_time'] ? date('Y-m-d',$value['hand_time']) : '';
|
|
|
+ $data['data'][$key]['crt_title'] = $value['crt_id'] ? $emp[$value['crt_id']] : "系统生成";
|
|
|
+ }
|
|
|
+
|
|
|
+ return $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ public function createOrderNumber($type = 1){
|
|
|
+ $str = DeviceOrder::$prefix[$type] . date('Ymd',time());
|
|
|
+
|
|
|
+ $order_number = DeviceOrder::where('order_number','Like','%'. $str . '%')
|
|
|
+ ->where('type',$type)
|
|
|
+ ->max('order_number');
|
|
|
+
|
|
|
+ if(empty($order_number)){
|
|
|
+ $number = str_pad(1,2,'0',STR_PAD_LEFT);
|
|
|
+ $number = $str . $number;
|
|
|
+ }else{
|
|
|
+ $tmp = substr($order_number, -2);
|
|
|
+ $tmp = $tmp + 1;
|
|
|
+
|
|
|
+ //超过99999
|
|
|
+ if(strlen($tmp) > 5) return '';
|
|
|
+
|
|
|
+ $number = str_pad($tmp,2,'0',STR_PAD_LEFT);
|
|
|
+ $number = $str . $number;
|
|
|
+ }
|
|
|
+
|
|
|
+ return $number;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 设置的首次巡检,设备最大一次的巡检的时间
|
|
|
+ public function getXJLastData($equipment_id = []){
|
|
|
+ if(empty($equipment_id)) return [];
|
|
|
+
|
|
|
+ //设置的首次巡检
|
|
|
+ $equipment = EquipmentXj::where('del_time',0)
|
|
|
+ ->whereIn('equipment_id',$equipment_id)
|
|
|
+ ->select('equipment_id',DB::raw('MAX(first_time) as first_time'))
|
|
|
+ ->groupBy('equipment_id')
|
|
|
+ ->get()->toArray();
|
|
|
+ $equipment_first_map = array_column($equipment,'first_time','equipment_id');
|
|
|
+
|
|
|
+ //巡检单明细数据
|
|
|
+ $xj_data = DeviceOrderInfo::where('del_time',0)
|
|
|
+ ->where('type',DeviceOrder::Model_type_one)
|
|
|
+ ->whereIn('equipment_id', $equipment_id)
|
|
|
+ ->select('equipment_id', DB::raw('MAX(crt_time) as crt_time'))
|
|
|
+ ->groupBy('equipment_id')
|
|
|
+ ->get()->toArray();
|
|
|
+ $map = array_column($xj_data,'crt_time','equipment_id');
|
|
|
+
|
|
|
+ //设备最近一次的巡检的时间 (通过比较 巡检单明细数据 设置的首次巡检 谁大取谁)
|
|
|
+ $equipment_map = [];
|
|
|
+ foreach ($equipment as $value){
|
|
|
+ $xj_tmp = $map[$value['equipment_id']] ?? 0;
|
|
|
+ if(empty($xj_tmp)) {
|
|
|
+ $equipment_map[$value['equipment_id']] = $value['first_time'] ?? 0;
|
|
|
+ }else{
|
|
|
+ if($xj_tmp < $value['first_time']){
|
|
|
+ $equipment_map[$value['equipment_id']] = $value['first_time'] ?? 0;
|
|
|
+ }else{
|
|
|
+ $equipment_map[$value['equipment_id']] = $xj_tmp;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return [$equipment_map,$equipment_first_map];
|
|
|
+ }
|
|
|
+}
|