hqyt/app/Service/RDService.php

<?php

namespace App\Service;

use App\Model\Device;
use App\Model\Employee;
use App\Model\Item;
use App\Model\RD;
use App\Model\RdDetails;
use App\Model\RdLock;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Str;

class RDService extends Service
{
    public function rdCreate($data, $user){
        $month = $data['month'];
        $lock = RdLock::where('del_time',0)
            ->where('belong_month', strtotime(date($data['month'] . '-01')))
            ->where('type', RD::type_one)
            ->exists();
        if($lock) return [false, RD::$type_name[RD::type_one] . '在' . $month . '已封存，生成失败'];
        list($status, $msg) = (new RdGenerateService())->generate($data);
        return [$status, $msg];
    }

    public function rdCreate2($data, $user){
        $month = $data['month'];
        $lock = RdLock::where('del_time',0)
            ->where('belong_month', strtotime(date($data['month'] . '-01')))
            ->where('type', RD::type_two)
            ->exists();
        if($lock) return [false, RD::$type_name[RD::type_two] . '在' . $month . '已封存，生成失败'];
        list($status, $msg) = (new RdGenerateDeviceService())->generate($data);
        return [$status, $msg];
    }

    public function rdEdit($data,$user){
        list($status,$msg) = $this->rdRule($data, $user, false);
        if(!$status) return [$status,$msg];

        try {
            DB::beginTransaction();

            $model = RD::where('id',$data['id'])->first();
            $model->type = $data['type'] ?? 0;
            $model->item_id = $data['item_id'] ?? 0;
            $model->order_time = $data['order_time'] ?? 0;
            $model->start_time_hour = $data['start_time_hour'] ?? 0;
            $model->start_time_min = $data['start_time_min'] ?? 0;
            $model->end_time_hour = $data['end_time_hour'] ?? 0;
            $model->end_time_min = $data['end_time_min'] ?? 0;
            $model->total_hours = $data['total_hours'] ?? 0;
            $model->save();

            $time = time();
            RdDetails::where('del_time',0)
                ->where('rd_id', $model->id)
                ->update(['del_time' => $time]);
            $this->saveDetail($model->id, $time, $data);

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

        return [true, ''];
    }

    public function rdAdd($data,$user){
        list($status,$msg) = $this->rdRule($data, $user);
        if(!$status) return [$status,$msg];

        try {
            DB::beginTransaction();

            $model = new RD();
            $model->order_number = $this->generateOrderNumber($data['type'],$data['item_id']);
            $model->type = $data['type'] ?? 0;
            $model->item_id = $data['item_id'] ?? 0;
            $model->order_time = $data['order_time'] ?? 0;
            $model->start_time_hour = $data['start_time_hour'] ?? 0;
            $model->start_time_min = $data['start_time_min'] ?? 0;
            $model->end_time_hour = $data['end_time_hour'] ?? 0;
            $model->end_time_min = $data['end_time_min'] ?? 0;
            $model->total_hours = $data['total_hours'] ?? 0;
            $model->crt_id = $user['id'];
            $model->save();
            
            $this->saveDetail($model->id, time(), $data);

            DB::commit();
        }catch (\Exception $exception){
            DB::rollBack();
            if (str_contains($exception->getMessage(), '1062') || str_contains($exception->getMessage(), 'Duplicate entry')) {
                return [false, '网络波动，请重新操作！'];
            }
            return [false,$exception->getMessage()];
        }

        return [true, ''];
    }

    private function saveDetail($id, $time, $data){
        if(! empty($data['man_list'])){
            $unit = [];
            foreach ($data['man_list'] as $value){
                $unit[] = [
                    'rd_id' => $id,
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'crt_time' => $time,
                ];
            }
            if(! empty($unit)) RdDetails::insert($unit);
        }

        if(! empty($data['device_list'])){
            $receipt = [];
            foreach ($data['device_list'] as $value){
                $receipt[] = [
                    'rd_id' => $id,
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'crt_time' => $time,
                ];
            }
            if(! empty($receipt)) RdDetails::insert($receipt);
        }
    }

    private function getDetail($id){
        $data = RdDetails::where('del_time',0)
            ->where('rd_id', $id)
            ->get()->toArray();

        $id = $id2 = [];
        foreach ($data as $value){
            if($value['type'] == RdDetails::type_one) {
                $id[] = $value['data_id'];
            }else{
                $id2[] = $value['data_id'];
            }
        }
        $map = Employee::whereIn('id', $id)->select('emp_name','id','number')->get()->toArray();
        $map = array_column($map,null,'id');
        $map2 = Device::whereIn('id', $id2)->select('code','id','title')->get()->toArray();
        $map2 = array_column($map2,null,'id');

        $unit = $receipt = [];
        foreach ($data as $value){
            if($value['type'] == RdDetails::type_one) {
                $tmp = $map[$value['data_id']] ?? [];
                $unit[] = [
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'data_title' => $tmp['emp_name'],
                    'data_code' => $tmp['number'],
                ];
            }else{
                $tmp = $map2[$value['data_id']] ?? [];
                $receipt[] = [
                    'type' => $value['type'],
                    'data_id' => $value['data_id'],
                    'data_title' => $tmp['title'] ?? "",
                    'data_code' => $tmp['code'] ?? "",
                ];
            }
        }

        $detail = [
            'man_list' => $unit,
            'device_list' => $receipt,
        ];

        foreach ($detail as $key => $value) {
            if (empty($value)) {
                $detail[$key] = (object)[]; // 转成 stdClass 对象
            }
        }

        return $detail;
    }

    public function rdDel($data){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];

        try {
            DB::beginTransaction();
            $time = time();

            RD::where('del_time',0)
                ->whereIn('id',$data['id'])
                ->update(['del_time' => $time]);

            RdDetails::where('del_time',0)
                ->whereIn('rd_id', $data['id'])
                ->update(['del_time' => $time]);

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

        return [true, ''];
    }

    public function rdDetail($data, $user){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];
        $customer = RD::where('del_time',0)
            ->where('id',$data['id'])
            ->first();
        if(empty($customer)) return [false,'订单不存在或已被删除'];
        $customer = $customer->toArray();
        $customer['crt_name'] = 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['order_time'] = $customer['order_time'] ? date("Y-m-d",$customer['order_time']): '';
        $customer['item_title'] = $customer['item_id'] ? Item::where('id',$customer['item_id'])->value('title') : "";

        $details = $this->getDetail($data['id']);
        $customer = array_merge($customer, $details);

        return [true, $customer];
    }

    public function rdCommon($data,$user, $field = []){
        if(empty($field)) $field = RD::$field;

        $model = RD::Clear($user,$data);
        $model = $model->where('del_time',0)
            ->select($field)
            ->orderby('crt_time', 'desc');

        if(! empty($data['type'])) $model->where('type', $data['type']);
        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
        if(! empty($data['order_number'])) $model->where('order_number', 'LIKE', '%'.$data['order_number'].'%');
        if(! empty($data['id'])) $model->whereIn('id', $data['id']);
        if(! empty($data['item_title'])) {
            $item_id = Item::where('title', 'LIKE', '%'.$data['item_title'].'%')
                ->where('del_time',0)
                ->pluck('id')->toArray();
            $model->whereIn('item_id', $item_id);
        }
        if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
            $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
            $model->where('crt_time','>=',$return[0]);
            $model->where('crt_time','<=',$return[1]);
        }
        if(! empty($data['order_time'][0]) && ! empty($data['order_time'][1])) {
            $return = $this->changeDateToTimeStampAboutRange($data['order_time']);
            $model->where('order_time','>=',$return[0]);
            $model->where('order_time','<=',$return[1]);
        }

        return $model;
    }

    public function rdList($data,$user){
        $model = $this->rdCommon($data, $user);
        $list = $this->limit($model,'',$data);
        $list = $this->fillData($list);

        $list['count'] = $this->countTotal($list['data'], $user['header_default']);

        return [true, $list];
    }

    public function rdRule(&$data, $user, $is_add = true){
        if(empty($data['type'])) return [false, '工时单类型不能为空'];
        if(! isset(RD::$type_name[$data['type']])) return [false, '工时单类型错误'];
        $type_title = RD::$type_name[$data['type']];
        if(empty($data['order_time'])) return [false, '订单日期不能为空'];
        $data['order_time'] = $this->changeDateToDate($data['order_time']);

        $month = date('Y-m', $data['order_time']);
        $lock = RdLock::where('del_time',0)
            ->where('belong_month', strtotime(date('Y-m-01', $data['order_time'])))
            ->where('type', $data['type'])
            ->exists();
        if($lock) return [false, $type_title . '在' . $month . '已封存，单据创建失败'];

        if($data['type'] == RD::type_one){
            if(empty($data['man_list'])) return [false, '研发人员不能为空'];
            foreach ($data['man_list'] as $value){
                if(empty($value['type'])) return [false, '类型不能为空'];
                if(empty($value['data_id'])) return [false, '数据ID不能为空'];
            }
            list($status, $msg) = $this->checkArrayRepeat($data['man_list'],'data_id','研发人员');
            if(! $status) return [false, $msg];
        }else{
            if(empty($data['device_list'])) return [false, '研发设备不能为空'];
            foreach ($data['device_list'] as $value){
                if(empty($value['type'])) return [false, '类型不能为空'];
                if(empty($value['data_id'])) return [false, '数据ID不能为空'];
            }
            list($status, $msg) = $this->checkArrayRepeat($data['device_list'],'data_id','研发设备');
            if(! $status) return [false, $msg];
        }

        if(empty($data['item_id'])) return [false,'项目不能为空'];
        $res = $this->checkNumber($data['start_time_hour'],0,'non-negative');
        if(! $res['valid']) return [false,'研发时段开始点：' . $res['error']];
        $res = $this->checkNumber($data['start_time_min'],0,'non-negative');
        if(! $res['valid']) return [false,'研发时段开始分：' . $res['error']];
        $res = $this->checkNumber($data['end_time_hour'],0,'non-negative');
        if(! $res['valid']) return [false,'研发时段结束点：' . $res['error']];
        $res = $this->checkNumber($data['end_time_hour'],0,'non-negative');
        if(! $res['valid']) return [false,'研发时段结束分：' . $res['error']];
        $res = $this->checkNumber($data['total_hours'],2,'positive');
        if(! $res['valid']) return [false,'研发合计工时：' . $res['error']];

        if($is_add){

        }else{
            if(empty($data['id'])) return [false,'ID不能为空'];
            $bool = RD::where('id',$data['id'])
                ->where('del_time',0)
                ->exists();
            if(! $bool) return [false, $type_title . '不存在或已被删除'];
        }

        return [true, $data];
    }

    public function fillData($data){
        if(empty($data['data'])) return $data;

        $emp = (new EmployeeService())->getEmployeeMap(array_unique(array_column($data['data'],'crt_id')));
        $emp2 = (new ItemService())->getItemMap(array_unique(array_column($data['data'],'item_id')));
        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
            $data['data'][$key]['order_time'] = $value['order_time'] ? date('Y-m-d',$value['order_time']) : '';
            $data['data'][$key]['crt_name'] = $emp[$value['crt_id']] ?? '';
            $data['data'][$key]['item_title'] = $emp2[$value['item_id']] ?? '';
            $start_time = strtotime(date('Y-m-d',$value['order_time']) ." " . $value['start_time_hour'] . ":" . $value['start_time_min']);
            $end_time = strtotime(date('Y-m-d',$value['order_time']) ." " . $value['end_time_hour'] . ":" . $value['end_time_min']);
            $data['data'][$key]['start_time'] = date("H:i",$start_time);
            $data['data'][$key]['end_time'] = date("H:i",$end_time);
            $data['data'][$key]['total_hours'] = bcdiv($value['total_hours'],60,2);
        }

        return $data;
    }

    public function generateOrderNumber($type, $itemId = 0)
    {
        $dateStr = date('Ymd');

        if ($type == 1) {
            // --- 方案：日期 + (项目ID或默认值) + 微秒哈希 ---
            // substr(uniqid(), 7, 5) 提取的是微秒级变化的随机串，比 md5 更短且在单机并发下极难重复
            $orderNumber = sprintf("RD%s%d%s",
                $dateStr,
                $itemId ?: 0,
                substr(uniqid(), 8, 5)
            );
        } else {
            // --- 方案：日期 + 随机序列 ---
            // 使用 dechex(mt_rand()) 将随机数转为 16 进制，进一步缩短长度
            $orderNumber = 'RD' . $dateStr . dechex(mt_rand(100000, 999999)) . substr(uniqid(), -4);
        }

        return strtoupper($orderNumber); // 统一转大写，看起来更专业

        $yyyymm = date('Ym');

        // 数据库事务（防止并发）
        return DB::transaction(function () use ($yyyymm) {

            // 先尝试读取
            $row = DB::table('order_sequence')->where('yyyymm', $yyyymm)->lockForUpdate()->first();

            if ($row) {
                $seq = $row->seq + 1;
                DB::table('order_sequence')->where('yyyymm', $yyyymm)
                    ->update(['seq' => $seq]);
            } else {
                // 当月第一次生成
                $seq = 1;
                DB::table('order_sequence')->insert([
                    'yyyymm' => $yyyymm,
                    'seq' => $seq
                ]);
            }

            // 拼接成单号 2025110001
            return $yyyymm . str_pad($seq, 4, '0', STR_PAD_LEFT);
        });
    }
}