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