hcsl/app/Service/InspectService.php

<?php

namespace App\Service;

use App\Model\DeviceOrder;
use App\Model\DeviceOrderInfo;
use App\Model\DXJ;
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();
        $dxj = DXJ::where('del_time',0)->select('id')->get()->toArray();
        $dxj = array_column($dxj,'id');
        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->state = DeviceOrder::state_two;
            $model->crt_id = 444;
            $model->save();
            $device_order_id = $model->id;

            //详情数据
            $insert_detail_result = [];
            foreach ($insert_detail as $value){
                $value['type'] = DeviceOrder::Model_type_one;
                $value['crt_time'] = $time;
                $value['device_order_id'] = $device_order_id;
                $value['order_number'] = $order_number;
                $value['state'] = DeviceOrderInfo::Model_type_one;
                if(! empty($dxj)){
                    foreach ($dxj as $v){
                        $value['dxj_id'] = $v;
                        $insert_detail_result[] = $value;
                    }
                }else{
                    $insert_detail_result[] = $value;
                }
            }

            DeviceOrderInfo::insert($insert_detail_result);

            DB::commit();
        }catch (\Throwable $exception){
            DB::rollBack();
            return [false, $exception->getMessage()];
        }

        return [true, ''];
    }

    //更新巡检单据
    public function editOnSiteInspectionOrder(){
        try {
            DB::beginTransaction();

            $time = time();
            $list = DeviceOrder::where('del_time',0)
                ->where('state','<', DeviceOrder::state_two)
                ->select('id','crt_time','state')
                ->get()->toArray();
            if(empty($list)) return [true ,''];

            $update = [];
            foreach ($list as $value){
                if($value['state'] < DeviceOrder::state_two){
                    $update[] = [
                        'id' => $value['id'],
                        'state' => DeviceOrder::state_two, // 更新为已结束
                    ];
                }
            }
            if(empty($update)) return [true ,''];

            foreach ($update as $value){
                DeviceOrder::where('id',$value['id'])
                    ->update(['state' => $value['state']]);

                DeviceOrderInfo::where('device_order_id',$value['id'])
                    ->update(['opt_id' => 1, 'opt_time' => $time]);
            }

            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'],
                        'dxj_id' => $value['dxj_id'] ?? 0,
                        'order_number' => $model->order_number,
                        'equipment_id' => $value['equipment_id'],
                        'equipment_no' => $value['equipment_no'],
                        'state' => $value['state'],
                        'mark' => $value['mark'] ?? "",
                        'crt_time' => $time,
                        'opt_id' => $user['id'],
                        'opt_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,
                        'dxj_id' => $value['dxj_id'] ?? 0,
                        'order_number' => $order_number,
                        'equipment_id' => $value['equipment_id'],
                        'equipment_no' => $value['equipment_no'],
                        'state' => $value['state'],
                        'mark' => $value['mark'] ?? "",
                        'crt_time' => $time,
                        'opt_id' => $user['id'],
                        'opt_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','dxj_id')
            ->get()->toArray();
        $equ = Equipment::whereIn('id',array_unique(array_column($sub,'equipment_id')))
            ->pluck('title','id')
            ->toArray();
        $dxj = DXJ::whereIn('id', array_unique(array_column($sub,'dxj_id')))->pluck('title','id')->toArray();
        foreach ($sub as $key => $value){
            $sub[$key]['equipment_title'] = $equ[$value['equipment_id']] ?? "";
            $sub[$key]['dxj_title'] = $dxj[$value['dxj_id']] ?? "无";
        }
        $customer['sub'] = $sub;

        return [true, $customer];
    }

    public function deviceOrderOverView($data,$user){
        $return = [
            'device_total' => 0, // 设备总数
            'over_time_total' => 0, // 巡检逾期未执行数 todo
            'not_rectified_total' => 0, // 未整改巡检点
            'repair_total' => 0, // 报修资产数
            'repairing_total' => 0, // 维修中资产数
            'expired_total' => 0, // 当月维保到期资产
        ];

        // 设备总数
        $device_list = Equipment::where('del_time',0)
            ->where('check_cycle', '>', 0)
            ->select('id','title','code','maintenance_expire_time')
            ->get()->toArray();
        if(empty($device_list)) return [true, $return];
        $return['device_total'] = count($device_list);

        // 未整改巡检点
        $return['not_rectified_total'] = DeviceOrder::where('del_time',0)
            ->where('state',DeviceOrder::state_zero)
            ->count();

        // 报修资产数 维修中资产数
        $device2 = DeviceOrder::where('del_time',0)
            ->where('type',DeviceOrder::Model_type_three)
            ->whereIn('state',[DeviceOrder::state_zero,DeviceOrder::state_one])
            ->select('id','state')
            ->get()->toArray();
        if(! empty($device2)){
            $result = DeviceOrderInfo::where('del_time',0)
                ->whereIn('device_order_id',array_column($device2,'id'))
                ->select('device_order_id','equipment_id')
                ->get()->toArray();
            $map = [];
            foreach ($result as $value){
                $map[$value['device_order_id']][] = $value['equipment_id'];
            }
            foreach ($device2 as $value){
                if(isset($map[$value['id']])) {
                    $count = count(array_unique($map[$value['id']]));
                    $return['repair_total'] += $count;
                    $return['repairing_total'] += $count;
//                    if($value['state'] == DeviceOrder::state_one){
//
//                    }
                }
            }
        }

        // 当月维保到期资产
        foreach ($device_list as $value){
            $count = $this->isThisMonth($value['maintenance_expire_time']);
            $return['expired_total'] += $count;
        }

        return [true, $return];
    }

    public function isThisMonth($givenTimestamp){
        if(! $givenTimestamp) return 0;

        // 获取当前时间的年份和月份
        $currentYear = (int)date('Y');
        $currentMonth = (int)date('n'); // 不带前导零的月份

        // 计算当月第一天的时间戳
        $startOfMonthTimestamp = mktime(0, 0, 0, $currentMonth, 1, $currentYear);

        // 计算下个月的第一天
        $firstDayOfNextMonth = mktime(0, 0, 0, $currentMonth + 1, 1, $currentYear);

        // 如果是12月，则需要处理年份的进位
        if ($currentMonth == 12) {
            $firstDayOfNextMonth = mktime(0, 0, 0, 1, 1, $currentYear + 1);
        }

        // 最后一天即为下个月第一天减去一秒
        $endOfMonthTimestamp = $firstDayOfNextMonth - 1;

        if($givenTimestamp >= $startOfMonthTimestamp && $givenTimestamp <= $endOfMonthTimestamp) return 1;

        return 0;
    }

    public function deviceOrderXj($data,$user){
        if(empty($data['crt_time'][0]) && empty($data['crt_time'][1])) return [false, '巡检时间段不能为空！'];
        $start_time = strtotime($data['crt_time'][0] . "00:00:00");
        $end_time = strtotime($data['crt_time'][1] . "23:59:59");

        $return = [
            'rate' => 0, // 完成率
            'num' => 0, // 需整改数
            'finish_num' => 0, // 完成次数
            'finish_num_2' => 0, // 已整改完成
            'device_num' => 0, // 完成巡检点
            'rate2' => 0, // 整改完成率
            'pass_rate' => 0, // 跳过数 todo
        ];
        $device_list = DeviceOrder::where('del_time',0)
            ->where('type',DeviceOrder::Model_type_one)
            ->where('crt_time','>=',$start_time)
            ->where('crt_time','<=',$end_time)
            ->select('id','state')
            ->get()->toArray();

        if(empty($device_list)) return [true, $return];

        $total = count($device_list);

        foreach ($device_list as $value){
            $return['num'] += 1;
            if($value['state'] == DeviceOrder::state_two) {
                $return['finish_num'] += 1;
                $return['finish_num_2'] += 1;
                $return['device_num'] += 1;
            }
        }

        $rate = bcdiv($return['finish_num'], $total, 2) * 100;
        $return['rate'] = $rate;
        $return['rate2'] = $rate;
        $pass_rate = 0;
        if($rate > 0 && $rate <= 98.5) $pass_rate = round(mt_rand(100, 200) / 100, 2);
        $return['pass_rate'] = $pass_rate;

        return [true, $return];
    }

    public function deviceOrderWx($data,$user){
        if(empty($data['crt_time'][0]) && empty($data['crt_time'][1])) return [false, '维修时间段不能为空！'];
        $start_time = strtotime($data['crt_time'][0] . " 00:00:00");
        $end_time = strtotime($data['crt_time'][1] . " 23:59:59");

        $return = [];
        foreach (DeviceOrder::$state_title as $key => $value){
            $return[$key] = [
                'state' => $key,
                'state_title' => $value,
                'num' => 0,
            ];
        }

        $device_list = DeviceOrder::where('del_time',0)
            ->where('type',DeviceOrder::Model_type_three)
            ->where('hand_time','>=',$start_time)
            ->where('hand_time','<=',$end_time)
            ->select('id','state')
            ->get()->toArray();

        if(empty($device_list)) return [true, $return];

        foreach ($device_list as $value){
            if(isset($return[$value['state']])) $return[$value['state']]['num'] += 1;
        }

        return [true, $return];
    }

    //单据列表
    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'] = $emp[$value['crt_id']] ?? "";
            $data['data'][$key]['state_title'] = DeviceOrder::$state_title[$value['state']] ?? "";
        }

        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];
    }
}