hcsl/app/Service/DispatchService.php

<?php

namespace App\Service;

use App\Model\Dispatch;
use App\Model\DispatchSub;
use App\Model\Employee;
use App\Model\EmployeeTeamPermission;
use App\Model\Equipment;
use App\Model\FinishedOrderSub;
use App\Model\OrdersProduct;
use App\Model\OrdersProductProcess;
use App\Model\Process;
use App\Model\Team;
use Illuminate\Support\Facades\DB;

class DispatchService extends Service
{
    public function edit($data){}

    public function setOrderNO(){
        $str = date('Ymd',time());

        $order_number = Dispatch::where('dispatch_no','Like','%'. $str . '%')
            ->max('dispatch_no');

        if(empty($order_number)){
            $number = str_pad(1,3,'0',STR_PAD_LEFT);
            $number = $str . $number;
        }else{
            $tmp = substr($order_number, -3);
            $tmp = $tmp + 1;

            //超过99999
            if(strlen($tmp) > 3) return '';

            $number = str_pad($tmp,3,'0',STR_PAD_LEFT);
            $number = $str . $number;
        }

        return $number;
    }

    public function add($data,$user){
        //数据校验以及填充
        list($status,$msg) = $this->orderRule($data);
        if(!$status) return [$status,$msg];

        $dispatch_no = $this->setOrderNO();
        try{
            DB::beginTransaction();

            //主表
            Dispatch::insert(['dispatch_no' => $dispatch_no,'process_id' => $data['process_id'],'equipment_id' => $data['equipment_id'], 'team_id' => $data['team_id'],'dispatch_time_start' => $data['dispatch_time'][0],'dispatch_time_end' => $data['dispatch_time'][1], 'crt_time' => time()]);

            //生产数据的源数据
            $result = $msg;

            date_default_timezone_set("PRC");
            $time_tmp = date("Ymd", $data['out_order_no_time'][0]);
            $process_model = new OrdersProductProcess(['channel' => $time_tmp]);

            $time = time();
            foreach ($result as $key => $value){
                $quantity_tmp = $data['quantity'][$key];
                $result[$key]['dispatch_no'] = $dispatch_no;
                $result[$key]['process_id'] = $data['process_id'];
                $result[$key]['equipment_id'] = $data['equipment_id'];
                $result[$key]['team_id'] = $data['team_id'];
                $result[$key]['dispatch_time_start'] = $data['dispatch_time'][0];
                $result[$key]['dispatch_time_end'] = $data['dispatch_time'][1];
                $result[$key]['dispatch_quantity'] = $quantity_tmp;
                $result[$key]['crt_time'] = $time;
                $result[$key]['crt_id'] = $user['id'];

                $process_model->where('order_product_id',$value['order_product_id'])
                    ->where('process_id',$data['process_id'])
                    ->where('dispatch_no','')
                    ->take($quantity_tmp)
                    ->update([
                        'dispatch_no' => $dispatch_no,
                        'status' => 1
                    ]);
            }

            DispatchSub::insert($result);

            //反写已派工数量
            $this->writeDispatchQuantity(array_column($result,'order_product_id'));

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

        return [true,'保存成功！'];
    }

    public function del($data){
        if($this->isEmpty($data,'id')) return [false,'ID不能为空！'];

        return [true,'删除成功'];
    }

    public function orderDetail($data){
        return [200,''];
    }

    public function is_same_month($timestamp1,$timestamp2){
        date_default_timezone_set("PRC");

        // 格式化时间戳为年份和月份
        $year1 = date('Y', $timestamp1);
        $month1 = date('m', $timestamp1);

        $year2 = date('Y', $timestamp2);
        $month2 = date('m', $timestamp2);

        if ($year1 === $year2 && $month1 === $month2) {
            return true;
        } else {
            return false;
        }
    }

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

        $model = OrdersProduct::where('del_time',0)
            ->select('id','order_no','out_order_no','out_order_no_time','customer_no','customer_name','table_header_mark','product_no','product_title','product_size','product_unit','order_quantity','technology_material','technology_name','wood_name','process_mark','table_body_mark','out_crt_man','out_checker_man','out_checker_time','production_quantity','production_time','production_no','status','crt_id')
//            ->whereBetween('out_order_no_time',[$data['out_order_no_time'][0],$data['out_order_no_time'][1]])
            ->whereIn('id',$msg)
            ->orderBy('id','desc');

        if(! empty($data['order_no'])) $model->where('order_no', 'LIKE', '%'.$data['order_no'].'%');
        if(! empty($data['out_order_no'])) $model->where('out_order_no', 'LIKE', '%'.$data['out_order_no'].'%');
        if(! empty($data['production_no'])) $model->where('production_no', 'LIKE', '%'.$data['production_no'].'%');
        if(! empty($data['customer_name'])) $model->where('customer_name', 'LIKE', '%'.$data['customer_name'].'%');
        if(! empty($data['product_title'])) $model->where('product_title', 'LIKE', '%'.$data['product_title'].'%');
        if(! empty($data['product_size'])) $model->where('product_size', 'LIKE', '%'.$data['product_size'].'%');
        if(! empty($data['technology_material'])) $model->where('technology_material', 'LIKE', '%'.$data['technology_material'].'%');
        if(! empty($data['technology_name'])) $model->where('technology_name', 'LIKE', '%'.$data['technology_name'].'%');
        if(! empty($data['wood_name'])) $model->where('wood_name', 'LIKE', '%'.$data['wood_name'].'%');
        if(! empty($data['process_mark'])) $model->where('process_mark', 'LIKE', '%'.$data['process_mark'].'%');
        if(! empty($data['table_header_mark'])) $model->where('table_header_mark', 'LIKE', '%'.$data['table_header_mark'].'%');
        if(! empty($data['table_body_mark'])) $model->where('table_body_mark', 'LIKE', '%'.$data['table_body_mark'].'%');
        if(! empty($data['out_checker_man'])) $model->where('out_checker_man', 'LIKE', '%'.$data['out_checker_man'].'%');
        if(! empty($data['out_crt_man'])) $model->where('out_crt_man', 'LIKE', '%'.$data['out_crt_man'].'%');
        if(! empty($data['out_checker_time'][0]) && ! empty($data['out_checker_time'][1])) $model->whereBetween('out_checker_time',[$data['out_checker_time'][0],$data['out_checker_time'][1]]);
        if(! empty($data['production_time'][0]) && ! empty($data['production_time'][1])) $model->whereBetween('production_time',[$data['production_time'][0],$data['production_time'][1]]);
        if(isset($data['status'])) $model->where('status',$data['status']);

        $list = $this->limit($model,'',$data);
        $list = $this->fillData($list);

        return [true,$list];
    }

    public function orderListRule($data){
        if(empty($data['process_id'])) return [false, '工序必须选择！'];
        if(empty($data['out_order_no_time'][0]) || empty($data['out_order_no_time'][1])) return [false,'制单日期必须选择'];
        $bool = $this->is_same_month($data['out_order_no_time'][0],$data['out_order_no_time'][1]);
        if(! $bool) return [false,'制单日期必须同月！'];

        date_default_timezone_set("PRC");
        $time = date("Ymd",$data['out_order_no_time'][0]);
        $process_model = new OrdersProductProcess(['channel' => $time]);
        if(! $process_model->is_table_isset()) return [true, []];//不存在process子表 返回空数据
        $process_array = $process_model->where('del_time',0)
            ->where('process_id',$data['process_id'])
            ->distinct()
            ->select('order_product_id')
            ->get()->toArray();
        $order_product_id = array_column($process_array,'order_product_id');
        if(empty($order_product_id)) return [true,[]];//process子表无数据 返回空数据

        return [true, $order_product_id];
    }

    public function orderRule($data){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];
        if($this->isEmpty($data,'quantity')) return [false,'请填写数量！'];
        if(in_array(false, $data['quantity'], true) || in_array(0, $data['quantity'], true) || in_array('', $data['quantity'], true))return [false,'数量不能为空！'];
        if(empty($data['dispatch_time'][0]) || empty($data['dispatch_time'][1])) return [false,'计划生产时间不能为空！'];
        if(empty($data['out_order_no_time'][0]) || empty($data['out_order_no_time'][1])) return [false,'制单时间不能为空！'];
        if($this->isEmpty($data,'process_id')) return [false,'工序不能为空！'];
        if($this->isEmpty($data,'equipment_id')) return [false,'设备不能为空！'];
        if($this->isEmpty($data,'team_id')) return [false,'班组不能为空！'];

        $result = OrdersProduct::whereIn('id',$data['id'])
            ->select('id as order_product_id','sale_orders_product_id','order_no','table_header_mark','product_no','product_title','product_size','product_unit','production_quantity','technology_material','technology_name','wood_name','process_mark','table_body_mark','sale_orders_product_id','out_order_no_time')
            ->get()->toArray();

        //已派工数据
        $map = $this->getDispatchQuantity($data['id']);

        foreach ($result as $key => $value){
            if(isset($map[$value['order_product_id']])){
                if($map[$value['order_product_id']] + $data['quantity'][$key] > $value['production_quantity']) return [false,'派单数量不能大于生产订单数量'];
            }else{
                if($data['quantity'][$key] > $value['production_quantity']) return [false,'派单数量不能大于生产订单数量'];
            }
        }

        return [true, $result];
    }

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

        $map = $this->getDispatchQuantity(array_column($data['data'],'id'));
        $emp_map = Employee::whereIn('id',array_column($data['data'],'crt_id'))
            ->pluck('emp_name','id')
            ->toArray();
        date_default_timezone_set("PRC");
        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['out_order_no_time'] = $value['out_order_no_time'] ? date('Y-m-d',$value['out_order_no_time']) : '';
            $data['data'][$key]['out_checker_time'] = $value['out_checker_time'] ? date('Y-m-d',$value['out_checker_time']) : '';
            $data['data'][$key]['production_time'] = $value['production_time'] ? date('Y-m-d',$value['production_time']) : '';
            $data['data'][$key]['dispatch_quantity'] = $map[$value['id']] ?? 0;
            $data['data'][$key]['not_dispatch_quantity'] = $value['production_quantity'] - ($map[$value['id']] ?? 0);
            $data['data'][$key]['order_product_man'] = $emp_map[$value['crt_id']] ?? '';
        }
        $data['production_quantity'] = array_sum(array_column($data['data'], 'production_quantity'));
        $data['dispatch_quantity'] = array_sum(array_column($data['data'], 'dispatch_quantity'));
        $data['not_dispatch_quantity'] = array_sum(array_column($data['data'], 'not_dispatch_quantity'));

        return $data;
    }

    //返回已派工数量
    public function getDispatchQuantity($order_product_id = []){
        if(empty($order_product_id)) return [];

        $result = DispatchSub::where('del_time',0)
            ->whereIn("order_product_id",$order_product_id)
            ->select(DB::raw("sum(dispatch_quantity) as dispatch_quantity"),'order_product_id')
            ->groupby('order_product_id')
            ->pluck('dispatch_quantity','order_product_id')
            ->toArray();

        return $result;
    }

    public function dispatchOrderList($data){
        $model = DispatchSub::where('del_time',0)
            ->select('id','order_no','table_header_mark','product_no','product_title','product_size','product_unit','dispatch_quantity','technology_material','technology_name','wood_name','process_mark','table_body_mark','production_quantity','dispatch_no','status','crt_id','process_id','equipment_id','team_id','dispatch_time_start','dispatch_time_end','crt_time')
            ->orderBy('id','desc');

        if(! empty($data['order_no'])) $model->where('order_no', 'LIKE', '%'.$data['order_no'].'%');
        if(! empty($data['dispatch_no'])) $model->where('dispatch_no', 'LIKE', '%'.$data['dispatch_no'].'%');
        if(! empty($data['process_id'])) $model->where('process_id',$data['process_id']);
        if(! empty($data['team_id'])) $model->where('team_id',$data['team_id']);
        if(! empty($data['equipment_id'])) $model->where('equipment_id',$data['equipment_id'].'%');
        if(! empty($data['technology_material'])) $model->where('technology_material', 'LIKE', '%'.$data['technology_material'].'%');
        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['dispatch_time'][0]) && ! empty($data['dispatch_time'][1])){
            $model->where('dispatch_time_start','<=',$data['dispatch_time'][0]);
            $model->where('dispatch_time_end','>=',$data['dispatch_time'][1]);
        }
        if(! empty($data['employee_id'])) {
            $team_id = Employee::from('employee as a')
                ->leftJoin('employee_team_permission as b','b.employee_id','a.id')
                ->where('a.id', $data['employee_id'])
                ->select('b.team_id')
                ->get()->toArray();
            $team_id = array_column($team_id,'team_id');
            $model->where('team_id',$team_id ?? []);
        }

        $list = $this->limit($model,'',$data);
        $list = $this->fillDispatchOrderListData($list);

        return [true,$list];
    }

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

        $team = EmployeeTeamPermission::from('employee_team_permission as a')
            ->leftJoin('employee as b','b.id','a.employee_id')
            ->whereIn('a.team_id',array_column($data['data'],'team_id'))
            ->select('b.emp_name','a.team_id')
            ->get()
            ->toArray();
        $team_map = [];
        if(! empty($team)){
            foreach ($team as $value){
                if(isset($team_map[$value['team_id']])){
                    $team_map[$value['team_id']] .= ','. $value['emp_name'];
                }else{
                    $team_map[$value['team_id']] = $value['emp_name'];
                }
            }
        }

        $process_map = Process::whereIn('id',array_column($data['data'],'process_id'))
            ->pluck('title','id')
            ->toArray();
        $team_maps = Team::whereIn('id',array_column($data['data'],'team_id'))
            ->pluck('title','id')
            ->toArray();
        $equipment_map = Equipment::whereIn('id',array_column($data['data'],'equipment_id'))
            ->pluck('title','id')
            ->toArray();

        $finished_map = $this->getFinishedQuantity(array_column($data['data'],'id'));
        date_default_timezone_set("PRC");
        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d',$value['crt_time']) : '';

            $time1 = $value['dispatch_time_start'] ? date('Y-m-d',$value['dispatch_time_start']) : '';
            $time2 = $value['dispatch_time_end'] ? date('Y-m-d',$value['dispatch_time_end']) : '';
            $data['data'][$key]['dispatch_time'] = $time1 . ' ' . $time2;
            $data['data'][$key]['team_man'] = $team_map[$value['team_id']] ?? '';
            $data['data'][$key]['process_name'] = $process_map[$value['process_id']] ?? '';
            $data['data'][$key]['team_name'] = $team_maps[$value['team_id']] ?? '';
            $data['data'][$key]['equipment_name'] = $equipment_map[$value['equipment_id']] ?? '';
            $data['data'][$key]['un_finished_quantity'] = $value['dispatch_quantity'] - ($finished_map[$value['id']] ?? 0);
        }
        $data['dispatch_quantity'] = array_sum(array_column($data['data'], 'dispatch_quantity'));

        return $data;
    }

    //反写写完工数量
    public function writeDispatchQuantity($order_product_id){
        if(empty($order_product_id)) return;

        $result = DispatchSub::where('del_time',0)
            ->whereIn('order_product_id',$order_product_id)
            ->select(DB::raw("sum(dispatch_quantity) as dispatch_quantity"),'order_product_id')
            ->groupby('order_product_id')
            ->pluck('dispatch_quantity','order_product_id')
            ->toArray();

        if(empty($result)) return;

        foreach ($result as $key => $value){
            OrdersProduct::where('id',$key)->update([
                'dispatch_complete_quantity' => $value
            ]);
        }
    }

    //返回已完工数量
    public function getFinishedQuantity($dispatch_id = []){
        if(empty($dispatch_id)) return [];

        $result = FinishedOrderSub::where('del_time',0)
            ->whereIn("dispatch_id",$dispatch_id)
            ->select(DB::raw("sum(finished_num) as finished_num"),'dispatch_id')
            ->groupby('dispatch_id')
            ->pluck('finished_num','dispatch_id')
            ->toArray();

        return $result;
    }
}