t_nine/app/Service/PurchaseOrderService.php

<?php

namespace App\Service;

use App\Model\BasicType;
use App\Model\BookingList;
use App\Model\Depart;
use App\Model\Employee;
use App\Model\InvoiceOrder;
use App\Model\PaymentReceipt;
use App\Model\PaymentReceiptInfo;
use App\Model\Product;
use App\Model\PurchaseOrder;
use App\Model\PurchaseOrderFile;
use App\Model\PurchaseOrderInfo;
use App\Model\PurchaseOrderInfoForOutBound;
use App\Model\ReturnExchangeOrder;
use App\Model\ReturnExchangeOrderProductInfo;
use App\Model\RoleMenuButton;
use App\Model\SalesOrder;
use App\Model\SeeRange;
use App\Model\SportsBag;
use App\Model\SportsBagProductInfo;
use App\Model\Storehouse;
use App\Model\Supplier;
use Carbon\Carbon;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;

/**
 * 采购单
 */
class PurchaseOrderService extends Service
{
    /**
     * 采购单编辑
     * @param $data
     * @param $user
     * @return array
     */
    public function edit($data,$user){
        list($status,$msg) = $this->orderRule($data,$user, false);
        if(!$status) return [$status,$msg];

        $params = $this->getDataFile($data);
        (new OperationLogService())->setOperationList($params,$user,2);

        try{
            DB::beginTransaction();
            $material_model = PurchaseOrder::where('order_number',$data['order_number'])->first();
            $material_model->purchase_type = $data['purchase_type'] ?? 0;
            $material_model->order_number = $data['order_number'];
//            $material_model->depart_id = $data['depart_id'] ?? 0;
//            $material_model->top_depart_id = $data['top_depart_id'] ?? 0;
            $material_model->total = $data['total'] ?? 0;
            $material_model->other_fee = $data['other_fee'] ?? 0;
            $material_model->discount_fee = $data['discount_fee'] ?? 0;
            $material_model->purchase_total = $data['purchase_total'] ?? 0;
            $material_model->supplier = $data['supplier'] ?? 0;
            $material_model->purchase_id = $data['purchase_id'] ?? 0;
            $material_model->order_type = $data['order_type'];
            $material_model->sales_order_id = $data['sales_order_id'] ?? 0;
            $material_model->mark = $data['mark'] ?? '';
            $material_model->storehouse_id = $data['storehouse_id'];
            $material_model->save();

            $time = time();
            PurchaseOrderInfo::where('order_number',$data['order_number'])
                ->where('del_time',0)
                ->update(['del_time' => time()]);
            if(!empty($data['product'])){
                $sub = [];
                foreach ($data['product'] as $value){
                    $sports_bag_product_info_id = 0;
                    if(! empty($value['sports_bag_id'])) $sports_bag_product_info_id = empty($value['id']) ? 0 : $value['id'];
                    $sub[] = [
                        'purchase_order_id' => $material_model->id,
                        'order_number' => $data['order_number'],
                        'storehouse_id' => $data['storehouse_id'] ?? 0,
                        'product_id' => $value['product_id'],
                        'number' => $value['number'],
                        'basic_type_id' => $value['basic_type_id'],
                        'price' => $value['price'],
                        'mark' => $value['mark'] ?? '',
                        'final_amount' => $value['final_amount'] ?? 0,
                        'sports_bag_id' => $value['sports_bag_id'] ?? 0,
                        'sports_bag_product_info_id' => $sports_bag_product_info_id,
                        'rate' => $value['rate'] ?? 0,
                    ];
                }
                PurchaseOrderInfo::insert($sub);
            }

            $old = PurchaseOrderFile::where('del_time',0)
                ->where('purchase_order_id',$data['id'])
                ->whereIn('type',[PurchaseOrderFile::type_one])
                ->select('file')
                ->get()->toArray();
            $old = array_column($old,'file');
            PurchaseOrderFile::where('order_number',$data['order_number'])
                ->where('del_time',0)
                ->update(['del_time' => time()]);
            $new = [];
            if(! empty($data['file'])){
                $insert = [];
                foreach ($data['file'] as $value){
                    $insert[] = [
                        'purchase_order_id' => $material_model->id,
                        'order_number' => $data['order_number'],
                        'file' => $value['url'],
                        'type' => PurchaseOrderFile::type_one,
                        'name' => $value['name'],
                        'crt_time' => $time,
                    ];
                    if(in_array($value['url'], $old)) {
                        foreach ($old as $o_k => $o_v){
                            if($o_v == $value['url']) unset($old[$o_k]);
                        }
                    }else{
                        $new[] = $value['url'];
                    }
                }
                PurchaseOrderFile::insert($insert);
            }

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

        if(! empty($data['check'])) {
            list($status,$msg) = (new CheckService())->checkAll([
                "id" => $material_model->id,
                "order_number" => $data['order_number'],
                "opt_case" => CheckService::seven,
                "menu_id" => $data['menu_id']
            ],$user);
//            if(! $status) return [true, '保存成功，采购单确认失败，异常信息：' . $msg];
        }

        return [true, ['file' => ['new' => $new, 'old' => $old]]];
    }

    /**
     * 采购单新增
     * @param $data
     * @param $user
     * @return array
     */
    public function add($data,$user){
        list($status,$msg) = $this->orderRule($data, $user);
        if(!$status) return [$status,$msg];

        try{
            DB::beginTransaction();
            $material_model = new PurchaseOrder();
            $material_model->order_number = $data['order_number'];
            $material_model->purchase_type = $data['purchase_type'] ?? 0;
            $material_model->depart_id = $data['depart_id'] ?? 0;
            $material_model->top_depart_id = $data['top_depart_id'] ?? 0;
            $material_model->total = $data['total'] ?? 0;
            $material_model->other_fee = $data['other_fee'] ?? 0;
            $material_model->discount_fee = $data['discount_fee'] ?? 0;
            $material_model->purchase_total = $data['purchase_total'] ?? 0;
            $material_model->supplier = $data['supplier'] ?? 0;
            $material_model->purchase_id = $data['purchase_id'] ?? 0;
            $material_model->order_type = $data['order_type'];
            $material_model->sales_order_id = $data['sales_order_id'] ?? 0;
            $material_model->mark = $data['mark'] ?? '';
            $material_model->crt_id = $user['id'];
            $material_model->storehouse_id = $data['storehouse_id'];
            $material_model->save();

            $time = time();
            if(!empty($data['product'])){
                $sub = [];
                foreach ($data['product'] as $value){
                    $sports_bag_product_info_id = 0;
                    if(! empty($value['sports_bag_id'])) $sports_bag_product_info_id = empty($value['id']) ? 0 : $value['id'];
                    $sub[] = [
                        'purchase_order_id' => $material_model->id,
                        'order_number' => $data['order_number'],
                        'storehouse_id' => $data['storehouse_id'] ?? 0,
                        'product_id' => $value['product_id'],
                        'number' => $value['number'],
                        'basic_type_id' => $value['basic_type_id'],
                        'price' => $value['price'],
                        'mark' => $value['mark'] ?? '',
                        'final_amount' => $value['final_amount'] ?? 0,
                        'sports_bag_id' => $value['sports_bag_id'] ?? 0,
                        'sports_bag_product_info_id' => $sports_bag_product_info_id,
                        'rate' => $value['rate'] ?? 0,
                    ];
                }
                PurchaseOrderInfo::insert($sub);
            }

            $new = [];
            if(! empty($data['file'])){
                $insert = [];
                foreach ($data['file'] as $value){
                    $insert[] = [
                        'purchase_order_id' => $material_model->id,
                        'order_number' => $data['order_number'],
                        'file' => $value['url'],
                        'type' => PurchaseOrderFile::type_one,
                        'name' => $value['name'],
                        'crt_time' => $time,
                    ];
                    if(! empty($value['url'])) $new[] = $value['url'];
                }
                PurchaseOrderFile::insert($insert);
            }

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

        (new OperationLogService())->setOperationList($data,$user);

        if(! empty($data['check'])) {
            list($status,$msg) = (new CheckService())->checkAll([
                "id" => $material_model->id,
                "order_number" => $data['order_number'],
                "opt_case" => CheckService::seven,
                "menu_id" => $data['menu_id']
            ],$user);
//            if(! $status) return [true, '保存成功，采购单确认失败，异常信息：' . $msg];
        }

        return [true, ['file' => ['new' => $new]]];
    }

    /**
     * 采购单详情
     * @param $data
     * @return array
     */
    public function detail($data,$user){
        if($this->isEmpty($data,'order_number')) return [false,'请选择数据'];

        $order = PurchaseOrder::where('order_number',$data['order_number'])
            ->where('del_time',0)
            ->select('id','order_number','depart_id','mark','state','crt_id','order_type','sales_order_id','supplier','purchase_id','total','other_fee','discount_fee','purchase_total','crt_time','storehouse_id','top_depart_id','purchase_type')
            ->first();
        if(empty($order)) return [false, '采购订单不存在或已被删除'];
        $order = $order->toArray();

        $order['activity_product'] = $order['file'] = [];
        $order['top_depart_title'] = Depart::where('id',$order['top_depart_id'])->value('title') ?? "";
        $order['purchase_type_title'] = BasicType::where('id',$order['purchase_type'])->value('title') ?? '';
        $order['storehouse_title'] = Storehouse::where('id',$order['storehouse_id'])->value('title');
        $supplier = Supplier::where('id',$order['supplier'])->first();
        $order['supplier_title'] = $supplier->title ?? '';
        $order['order_type_title'] = PurchaseOrder::$order_type[$order['order_type']] ?? '';
        $sales = SalesOrder::where('id',$order['sales_order_id'])->value('order_number');
        $order['sales_order_number'] = $sales;
        $saleForInvoice = SalesOrder::where('del_time',0)->where('contact_order_no', $order['order_number'])->first();
        $logistics_number = "";
        if(! empty($saleForInvoice)){
            $saleForInvoice = $saleForInvoice->toArray();
            $logistics_number = InvoiceOrder::where('del_time',0)->where('sales_order_id',$saleForInvoice['id'])->value('logistics_number') ?? "";
        }
        $order['logistics_number'] = $logistics_number;
        $emp_map = Employee::whereIn('id',array_unique(array_merge_recursive([$order['purchase_id']],[$order['crt_id']])))
            ->pluck('emp_name','id')
            ->toArray();
        $order['purchase_title'] = $emp_map[$order['purchase_id']] ?? '';

        // 填充产品
        list($product, $activity_product) = $this->purchaseFillDetailProduct($order);
        $order['product'] = $product;
        $order['activity_product'] = $activity_product;

        $file = PurchaseOrderFile::where('del_time',0)
            ->where('order_number',$data['order_number'])
            ->get()->toArray();
        $fileUploadService = new FileUploadService();
        foreach ($file as $value){
            if($value['type'] == PurchaseOrderFile::type_one){
                $tmp = [
                    'url' => $value['file'],
                    'name' => $value['name'],
                    'show_url' => $fileUploadService->getFileShow($value['file']),
                ];
                $order['file'][] = $tmp;
            }
        }
        $order['crt_name'] = $emp_map[$order['crt_id']] ?? '';
        $order['crt_time'] = $order['crt_time'] ? date("Y-m-d H:i:s",$order['crt_time']): '';

        $state_array = $this->getStateMake([$order]);
        $order['state_title'] = $this->makeState($order,$state_array);

        //可见范围
        $return = (new RangeService())->RangeDetail($order['id'],SeeRange::type_five);
        $order['depart'] = $return[0] ?? [];
        $order['employee'] = $return[1] ?? [];

        //对应的分社订货合同
        $order['sales_order_number2'] = SalesOrder::where('del_time',0)->where('contact_order_no',$data['order_number'])->value('order_number') ?? "";

        //回款信息
        $this->purchaseFillDetailPayment($order);

        $sale_order = SalesOrder::where('del_time',0)
            ->where('contact_order_no', $order['order_number'])
            ->value('id');
        $order['fsdh_id'] = $sale_order ?? 0;

        return [true, $order];
    }

    public function purchaseFillDetailProduct($order){
        $product = $activity_product = [];

        $p_info = PurchaseOrderInfo::where('del_time',0)
            ->where('order_number',$order['order_number'])
            ->get()->toArray();
        $sports_bag_id = array_unique(array_column($p_info,'sports_bag_id'));
        $bag = SportsBag::whereIn('id',$sports_bag_id)->get()->toArray();
        $bag_pro = SportsBagProductInfo::where('del_time',0)->whereIn('sports_bag_id',$sports_bag_id)
            ->get()->toArray();
        $bag_map = array_column($bag,null,'id');
        $bag_pro_map = [];
        foreach ($bag_pro as $value){
            $bag_pro_map[$value['sports_bag_id']][] = $value;
        }

        $basic_price = BasicType::whereIn('id',array_unique(array_column($p_info,'basic_type_id')))->pluck('title','id')->toArray();
        $map = (new ProductService())->getProductDetail(array_column($p_info,'product_id'));
        $sports_bag_arr = [];
        $sports_bag_pro = [];
        foreach ($p_info as $value){
            $tmp = $map[$value['product_id']] ?? [];
            if(! empty($value['sports_bag_id'])){
                $bag_tmp = $bag_map[$value['sports_bag_id']] ?? [];
                if(! isset($sports_bag_arr[$value['sports_bag_id']])) $sports_bag_arr[$value['sports_bag_id']] = $bag_tmp;
                $bag_pro_tmp = $bag_pro_map[$value['sports_bag_id']] ?? [];
                foreach ($bag_pro_tmp as $k => $v){
                    if($v['product_id'] != $value['product_id']) continue;
                    $is_choose = false;
                    $final_amount = 0;
                    $number = $v['number'];
                    $mark = "";
                    if($v['id'] == $value['sports_bag_product_info_id']){
                        $is_choose = true;
                        $final_amount = $value['final_amount'];
                        $number = $value['number'];
                        $mark = $value['mark'];
                    }
                    $bag_pro_tmp[$k]['is_choose'] = $is_choose;
                    $bag_pro_tmp[$k]['final_amount'] = $final_amount;
                    $bag_pro_tmp[$k]['number'] = $number;
                    $bag_pro_tmp[$k]['title'] = $tmp['title'] ?? "";
                    $bag_pro_tmp[$k]['code'] = $tmp['code'] ?? "";
                    $bag_pro_tmp[$k]['size'] = $tmp['size'] ?? "";
                    $bag_pro_tmp[$k]['unit'] = $tmp['unit'] ?? "";
                    $bag_pro_tmp[$k]['bar_code'] = $tmp['bar_code'] ?? "";
                    $bag_pro_tmp[$k]['mark'] = $mark ?? "";
                    $sports_bag_pro[$value['sports_bag_id']][] = $bag_pro_tmp[$k];
                }
            }else{
                $value['title'] = $tmp['title'] ?? "";
                $value['code'] = $tmp['code'] ?? "";
                $value['size'] = $tmp['size'] ?? "";
                $value['unit'] = $tmp['unit'] ?? "";
                $value['bar_code'] = $tmp['bar_code'] ?? "";
                $value['basic_type_title'] = $basic_price[$value['basic_type_id']] ?? "";
                $product[] = $value;
            }
        }
        foreach ($sports_bag_arr as $key => $value){
            $value['product'] = $sports_bag_pro[$key] ?? [];
            $activity_product[] = $value;
        }

        return [$product, $activity_product];
    }

    public function purchaseFillDetailPayment(&$order){
        //退换货信息
        $order['return_exchange'] = (new ReturnExchangeOrderService())->getDifferentAmount($order['id'],ReturnExchangeOrder::Order_type2);
        $order['return_exchange_amount'] = 0;
        foreach ($order['return_exchange'] as $value){
            if($value['state'] == ReturnExchangeOrder::State_two)  $order['return_exchange_amount'] += $value['difference_amount'];
        }

        //回款单信息 审核过的
        $order['payment_receipt_list'] = (new PaymentReceiptService())->getPaymentReceiptDataList($order,PaymentReceipt::data_type_two);
        //坏账金额 = 已审核退货退款金额 - 红冲金额
        $order['payment_receipt_list']['bad_amount'] = bcsub($order['return_exchange_amount'], $order['payment_receipt_list']['red_amount'],2);
        //未回款金额 = 总金额 - 已回款金额 - 坏账金额 - 红冲
        $order['payment_receipt_list']['not_receipt_amount'] = bcsub(bcsub(bcsub($order['purchase_total'], $order['payment_receipt_list']['receipt_amount'],2), $order['payment_receipt_list']['bad_amount'], 2),$order['payment_receipt_list']['red_amount'],2);
        //回款单信息 审核过的

        $order['not_payment_receipt_amount'] =  bcsub($order['purchase_total'],$order['payment_receipt_list']['not_confirm_receipt_amount'],2);
    }

    /**
     * 采购单删除
     * @param $data
     * @return array
     */
    public function del($data){
        if($this->isEmpty($data,'order_number')) return [false,'请选择数据！'];
        $order = PurchaseOrder::where('del_time',0)->where('order_number',$data['order_number'])->first();
        if(empty($order)) return [false,'采购单不存在或已被删除'];
        $order = $order->toArray();
        if($order['state'] > PurchaseOrder::STATE_ZERO) return [false,'请确认采购订单状态,删除失败！'];

        $bool = PaymentReceiptInfo::where('del_time',0)
            ->where('type',PaymentReceiptInfo::type_three)
            ->where('data_order_no', $order['order_number'])
            ->exists();
        if($bool) return [false, '采购已存在收付款单记录，请先删除收付款单据！'];

        try{
            DB::beginTransaction();
            PurchaseOrder::where('order_number',$data['order_number'])->where('del_time',0)->update([
                'del_time'=>time()
            ]);
            PurchaseOrderInfo::where('order_number',$data['order_number'])->where('del_time',0)->update([
                'del_time'=>time()
            ]);
            $old = PurchaseOrderFile::where('del_time',0)
                ->where('purchase_order_id',$order['id'])
                ->whereIn('type',[PurchaseOrderFile::type_one])
                ->select('file')
                ->get()->toArray();
            $old = array_column($old,'file');

            PurchaseOrderFile::where('order_number',$data['order_number'])
                ->where('del_time',0)
                ->update(['del_time' => time()]);
            (new RangeService())->RangeDelete($order['id'],SeeRange::type_five);

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

        return [true, ['file' => ['old' => $old]]];
    }

    public function purchaseCommon($data,$user,$field = []){
        if(empty($field)){
            $field = ['order_number','id','depart_id','top_depart_id','mark','crt_time','state','crt_id','order_type','sales_order_id','supplier','purchase_id','purchase_total','discount_fee','other_fee','total','storehouse_id','invoice_state'];
        }
        $model = PurchaseOrder::Clear($user,$data);
        $model = $model->where('del_time',0)
            ->select($field)
            ->orderby('id', 'desc');

        if(! empty($data['top_depart_title'])) {
            $depart = Depart::where('del_time',0)
                ->where('parent_id',0)
                ->where('title','LIKE', '%'.$data['top_depart_title'].'%')
                ->select('id')
                ->get()->toArray();
            $model->whereIn('top_depart_id', array_column($depart,'id'));
        }
        if(! empty($data['purchase_id'])) $model->where('id', $data['purchase_id']);
        if(! empty($data['order_number'])) $model->where('order_number', 'LIKE', '%'.$data['order_number'].'%');
        if(! empty($data['depart_id'])) $model->where('depart_id', $data['depart_id']);
        if(! empty($data['company_id'])) $model->where('company_id', $data['company_id']);
        if(isset($data['state'])) $model->where('state',$data['state']);
        if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
            $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
            $model->whereBetween('crt_time',[$return[0],$return[1]]);
        }
        if(! empty($data['time_type'])) {
            if($data['time_type'] == 1) {
                $start = strtotime('today');
                $end = strtotime('tomorrow') - 1;
            }elseif ($data['time_type'] == 2){
                $start = strtotime('this week',strtotime('today'));
                $end = strtotime('this week +6 days 23:59:59', strtotime('today'));
            }
            if(! empty($start) && ! empty($end)) {
                $model->where('crt_time','>=',$start);
                $model->where('crt_time','<=',$end);
            }
        }
        if(! empty($data['order_type'])) {
            if($data['order_type'] == PurchaseOrder::Order_type_five){
                $model->whereIn('order_type',[PurchaseOrder::Order_type_two,PurchaseOrder::Order_type_three,PurchaseOrder::Order_type_four]);
            }else{
                $model->where('order_type',$data['order_type']);
            }
        }
        if(! empty($data['sale_order'])){
            $sale_id = (new SalesOrderService())->orderNumberSearch($user, $data, $data['sale_order']);
            $model->whereIn('sales_order_id',$sale_id);
        }
        if(! empty($data['supplier_man'])){
            $emp = Supplier::where('del_time',0)
                ->where('title', 'LIKE', '%'.$data['supplier_man'].'%')
                ->select('id')
                ->get()->toArray();
            $model->whereIn('supplier',array_unique(array_column($emp,'id')));
        }
        if(! empty($data['purchase_man'])){
            $emp = Employee::where('del_time',0)
                ->where('emp_name', 'LIKE', '%'.$data['purchase_man'].'%')
                ->select('id')
                ->get()->toArray();
            $model->whereIn('purchase_id',array_unique(array_column($emp,'id')));
        }
        if(! empty($data['get_for_purchase'])){
            $model->whereIn('order_type',[PurchaseOrder::Order_type_three,PurchaseOrder::Order_type_four])
                ->where('state',">=",PurchaseOrder::STATE_TWO);
        }
        if(! empty($data['smart_search'])){
            $sale_id = (new SalesOrderService())->orderNumberSearch($user, $data, $data['smart_search']);
            $model->where(function (Builder $query) use ($data, $sale_id) {
                $query->where('order_number', 'LIKE', '%'.$data['smart_search'].'%')
                    ->orWhereIn('sales_order_id',$sale_id);
            });
        }
        if(! empty($data['wx_crt_time'][0]) && ! empty($data['wx_crt_time'][1])) {
            $model->where('crt_time','>=',$data['wx_crt_time'][0]);
            $model->where('crt_time','<=',$data['wx_crt_time'][1]);
        }

        return $model;
    }

    public function orderNumberSearch($user, $data, $message){
        $model2 = PurchaseOrder::Clear($user,$data);
        $purchase = $model2->where('del_time',0)
            ->where('order_number', 'LIKE', '%'.$message.'%')
            ->select('id')
            ->get()->toArray();

        return array_column($purchase,'id');
    }

    /**
     * 获取采购单列表
     * @param $data
     * @param $user
     * @return array
     */
    public function getList($data,$user){
        $model = $this->purchaseCommon($data, $user);
        $list = $this->limit($model,'',$data);
        $list = $this->fillListData($list,$data,$user);

        $count = $this->countData("crt_time", $data, $user);
        $list['today'] = $count[0] ?? 0;
        $list['yesterday'] = $count[1] ?? 0;

        return [true, $list];
    }

    /**
     * 拼接数据
     * @param $data
     * @return array
     */
    public function fillListData($data,$ergs,$user){
        if(empty($data['data'])) return $data;

        $depart_id = array_unique(array_column($data['data'],'depart_id'));
        $depart_map = Depart::whereIn('id',$depart_id)
            ->pluck('title','id')
            ->toArray();

        $emp_id = array_unique(array_merge_recursive(array_column($data['data'],'crt_id'),array_column($data['data'],'purchase_id')));
        $emp_map = Employee::whereIn('id',$emp_id)
                    ->pluck('emp_name','id')
                    ->toArray();

        $sales = SalesOrder::whereIn('id',array_unique(array_column($data['data'],'sales_order_id')))->pluck('order_number','id')->toArray();
        $storehouse = Storehouse::whereIn('id',array_unique(array_column($data['data'],'storehouse_id')))
            ->pluck('title','id')
            ->toArray();
        $supplier = Supplier::whereIn('id',array_unique(array_column($data['data'],'supplier')))
            ->select('title','id','is_main')
            ->get()
            ->toArray();
        $supplier_map = array_column($supplier,null,'id');
        $product = [];
        if(! empty($ergs['product'])){
            $purchase_order_id = array_column($data['data'],'id');
            $product = $this->getPurchaseProductForList($purchase_order_id, $ergs);
        }

        //分社订货合同
        $sales_array = [];
        if(! empty($ergs['get_for_purchase'])) $sales_array = $this->fsdhOrder($data);

        list($for_amount_list, $for_amount_list1) = (new PaymentReceiptService())->getPaymentReceiptDataCountList(array_column($data['data'],'order_number'));
        list($getDifferentAmountALL,$getDifferentAmountALL1) = (new ReturnExchangeOrderService())->getDifferentAmountALLNew(array_column($data['data'],'id'),1);

        //获取发货信息
//        $invoice_map = (new InvoiceOrderService())->getInvoiceData($data['data']);

        //订单状态数据组织
        $state_array = $this->getStateMake($data['data']);

        //特殊功能按钮
        $special_button = $user['special_button'] ?? [];

        foreach ($data['data'] as $key => $value){
            $supplier_tmp = $supplier_map[$value['supplier']] ?? [];
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']) : '';
            $data['data'][$key]['depart_name'] = $depart_map[$value['depart_id']] ?? '';
            $data['data'][$key]['crt_name'] = $emp_map[$value['crt_id']] ?? '';
            $data['data'][$key]['state_title'] = $this->makeState($data['data'][$key], $state_array);
            $data['data'][$key]['purchase_name'] = $emp_map[$value['purchase_id']] ?? '';
            $data['data'][$key]['order_type_title'] = PurchaseOrder::$order_type[$value['order_type']] ?? '';
            $data['data'][$key]['sales_order_number'] = $sales[$value['sales_order_id']] ?? '';
            $data['data'][$key]['fsdh_id'] = $sales_array[$value['order_number']] ?? 0;
            $data['data'][$key]['storehouse_title'] = $storehouse[$value['storehouse_id']] ?? '';
            $data['data'][$key]['supplier_title'] = $supplier_tmp['title'] ?? '';
            $data['data'][$key]['product'] = $product[$value['id']] ?? [];
            //发货信息 分社向总社采购
//            $invoice_state = "未发货";
//            if(! empty($invoice_map[$value['order_number']])) $invoice_state = implode(',',$invoice_map[$value['order_number']]);
            if(in_array($value['order_type'], [PurchaseOrder::Order_type_three,PurchaseOrder::Order_type_four])){
                $invoice_state = PurchaseOrder::$invoice_name[$value['invoice_state']] ?? "";
                $data['data'][$key]['state_message'] = "订单状态:" . $data['data'][$key]['state_title'] . "\n"."是否发货:" . $invoice_state;
            }else{
                $data['data'][$key]['state_message'] = "订单状态:" . $data['data'][$key]['state_title'];
            }

            //用于计算--------
            //已收（审核后）
            $one1 = $for_amount_list1[$value['order_number'] . PaymentReceipt::type_one] ?? 0;
            $data['data'][$key]['checked_payment_receipt_amount'] = $one1;
            //已收
            $one = $for_amount_list[$value['order_number'] . PaymentReceipt::type_one] ?? 0;
            $data['data'][$key]['payment_receipt_amount'] = $one;
            //已红冲
            $three = $for_amount_list[$value['order_number'] . PaymentReceipt::type_three] ?? 0;
            $data['data'][$key]['red_amount'] = $three;
            //已退货退款
            $return_exchange_amount = $getDifferentAmountALL[$value['id']] ?? 0;
            $data['data'][$key]['return_exchange_amount'] = $return_exchange_amount;
            //用于计算--------

            //用于统计--------
            $red = $for_amount_list1[$value['order_number'] . PaymentReceipt::type_three] ?? 0;
            $return_exchange_amount1 = $getDifferentAmountALL1[$value['id']] ?? 0;
            $bad = bcsub($return_exchange_amount1 ,$red,2);
            //已收金额
            $fee1 = bcsub($one1 ,$red,2);
            $data['data'][$key]['fee1'] = $fee1;
            //未收金额
            $fee2 = bcsub(bcsub(bcsub($value['purchase_total'], $fee1,2), $bad, 2),$red,2);
            $data['data'][$key]['fee2'] = $fee2;
            //红冲金额
            $data['data'][$key]['fee3'] = $red;
            //坏账金额
            $data['data'][$key]['fee4'] = $bad;
            //用于统计--------
        }

        return $data;
    }

    public function countData($column = "", $data, $user){
        if(empty($column) || empty($data['from_wx'])) return [0, 0];

        // 获取今天的开始和结束时间戳
        $todayStart = Carbon::today()->startOfDay()->timestamp;
        $todayEnd = Carbon::today()->endOfDay()->timestamp;

        // 获取昨天的开始和结束时间戳
        $yesterdayStart = Carbon::yesterday()->startOfDay()->timestamp;
        $yesterdayEnd = Carbon::yesterday()->endOfDay()->timestamp;

        $data['wx_' . $column] = [$todayStart, $todayEnd];
        $model = $this->purchaseCommon($data, $user);
        // 查询今天的数据条数
        $todayCount = $model->count();

        $data['wx_' . $column] = [$yesterdayStart, $yesterdayEnd];
        $model = $this->purchaseCommon($data, $user);
        // 查询昨天的数据条数
        $yesterdayCount = $model->count();

        return [$todayCount, $yesterdayCount];
    }

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

        $order_no = [];
        foreach ($data['data'] as $value){
            if(in_array($value['order_type'] , [PurchaseOrder::Order_type_three,PurchaseOrder::Order_type_four])) $order_no[] = $value['order_number'];
        }
        if(empty($order_no)) return [];

        $sale_order = SalesOrder::where('del_time',0)
            ->whereIn('contact_order_no', $order_no)
            ->pluck('id','contact_order_no')
            ->toArray();
        return $sale_order;
    }

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

        $order_no = [];
        foreach ($data as $value){
            if(! in_array($value['state'], [PurchaseOrder::State_minus_one,PurchaseOrder::STATE_ONE])) continue;
            $order_no[] = $value['order_number'];
        }

        return (new OaService())->getOaTeamDetailList($order_no);
    }

    public function makeState($value, $state_array){
        if(! empty($state_array[$value['order_number']])){
            $return = $state_array[$value['order_number']];
            if($value['state'] == PurchaseOrder::State_minus_one){
                $state = "驳回:" . $return;
            }else{
                $state = "待" . $return . "审核";
            }
        }elseif($value['state'] == PurchaseOrder::STATE_ZERO){
            $state = "待" . $value['crt_name'] . "提交";
        }else{
            $state = PurchaseOrder::$name[$value['state']] ?? '';
        }

        return $state;
    }

    /**
     * 采购单参数规则
     * @param $data
     * @param $is_check
     * @return array
     */
    public function orderRule(&$data, $user, $is_check = true){
        if(empty($data['order_type'])) return [false,'采购订单类型不能为空'];
        if($data['order_type'] == PurchaseOrder::Order_type_two && ! empty($data['supplier'])) {
            $supplier = Supplier::where('id',$data['supplier'])->first();
            if(! empty($supplier->is_main)) return [false,PurchaseOrder::$order_type[PurchaseOrder::Order_type_two] . '供应商请选择非总社供应商'];
        }
        if($data['order_type'] == PurchaseOrder::Order_type_three || $data['order_type'] == PurchaseOrder::Order_type_four) {
            if(empty($data['supplier'])){
                return [false,'请选择总部供应商'];
            }else{
                $supplier = Supplier::where('id',$data['supplier'])->first();
                if(empty($supplier->is_main)) return [false,'请选择总社供应商'];
            }
        }
        if($data['order_type'] == PurchaseOrder::Order_type_three && ! empty($data['sales_order_id'])) return [false,PurchaseOrder::$order_type[PurchaseOrder::Order_type_three] . '不需要选择合同'];
        if($data['order_type'] == PurchaseOrder::Order_type_four && empty($data['sales_order_id'])) return [false, PurchaseOrder::$order_type[PurchaseOrder::Order_type_four] . '必须选择合同'];
        if($this->isEmpty($data,'product')) return [false,'产品不能为空'];
        if(empty($data['storehouse_id'])) return [false,'请选择仓库'];
        if(empty($data['menu_id'])) return [false, '菜单信息不能为空'];
        if(! empty($data['other_fee'])){
            $res = $this->checkNumber($data['other_fee']);
            if(! $res) return [false, '其它费用请输入不超过两位小数并且大于0的数值'];
        }
        if(! empty($data['discount_fee'])){
            $res = $this->checkNumber($data['discount_fee']);
            if(! $res) return [false, '优惠金额请输入不超过两位小数并且大于0的数值'];
        }
        if(! empty($data['total'])){
            $res = $this->checkNumber($data['total']);
            if(! $res) return [false, '产品总价请输入不超过两位小数并且大于0的数值'];
        }
        if(! empty($data['purchase_total'])){
            $res = $this->checkNumber($data['purchase_total']);
            if(! $res) return [false, '采购总价请输入不超过两位小数并且大于0的数值'];
        }
        $sports_bag_id = [];$product_id = [];
        foreach ($data['product'] as $value){
            if(empty($value['number'])) return [false,'产品数量不能为空'];
            $res = $this->checkNumber($value['number']);
            if(! $res) return [false,'请输入正确的产品数量'];
            if(! empty($value['sports_bag_id']) && ! in_array($value['sports_bag_id'], $sports_bag_id)) $sports_bag_id[] = $value['sports_bag_id'];
            $product_id[] = $value['product_id'];
        }
        $maps = Product::where("del_time",0)
            ->whereIn('id',$product_id)
            ->pluck('title','id')
            ->toArray();
        foreach ($data['product'] as $value){
            if(! isset($maps[$value['product_id']])) return [false, '产品不存在'];
        }

        //所属部门 以及 顶级部门
        if(empty($data['depart_id'])) $data['depart_id'] = $this->getDepart($user);
        $data['top_depart_id'] = $user['depart_map'][$data['depart_id']] ?? 0;

        if($is_check){
            $order_number = (new OrderNoService())->createOrderNumber(PurchaseOrder::prefix);
            if(empty($order_number)) return [false,'采购单号生成失败！'];
            $data['order_number'] = $order_number;

            $check_id = $sports_bag_id;
        }else{
            if($this->isEmpty($data,'order_number')) return [false,'采购单号不能为空！'];
            $purchase = PurchaseOrder::where('del_time',0)->where('order_number',$data['order_number'])->first();
            if(empty($purchase)) return [false, '采购单不存在或已被删除'];
            $purchase = $purchase->toArray();
            if($purchase['state'] > PurchaseOrder::STATE_ZERO) return [false,'请确认采购单单据状态，修改失败'];

            //订单编辑提交限制
            $current_top_depart_id = $this->getMyTopDepart($user);
            list($status, $msg) = $this->returnOrderEditErrorCommon($current_top_depart_id, $purchase['top_depart_id']);
            if(! $status) return [false, $msg];

            $sports_bag_id_save = PurchaseOrderInfo::where('del_time',0)
                ->where('purchase_order_id',$data['id'])
                ->where('sports_bag_id','>',0)
                ->select('sports_bag_id')
                ->get()->toArray();
            $sports_bag_id_save = array_unique(array_column($sports_bag_id_save,'sports_bag_id'));
            $check_id = array_values(array_diff($sports_bag_id, $sports_bag_id_save));
        }

        //校验活动包有效性
        $service = new SportsBagService();
        list($status, $msg) = $service->checkSportsBag($check_id);
        if(! $status) return [false, $msg];

        return [true, ''];
    }

    //获取采购单产品数量 含退货 以及 出库 后最终产品数量 (通过产品以及仓库)
    public function getPurchaseProduct($product = [], $storehouse = 0){
        if(empty($product) || empty($storehouse)) return [];

        //采购单
        $purchase_id = PurchaseOrder::where('del_time',0)
            ->where('state',PurchaseOrder::STATE_Four)
            ->where('storehouse_id',$storehouse)
            ->select('id')
            ->get()->toArray();
        $purchase_id = array_column($purchase_id,'id');

        //采购单产品数量
        $purchase_product = PurchaseOrderInfo::where('del_time',0)
            ->whereIn('purchase_order_id',$purchase_id)
            ->whereIn('product_id',$product)
//            ->whereColumn('number','>','outbound_number')
            ->select('id','number','price','purchase_order_id','order_number','product_id')
            ->orderBy('id','asc')
            ->get()->toArray();
//        $map = (new ProductService())->getProductDetail(array_column($purchase_product,'product_id'));

        //采购单已出库产品（包含占用）
        $purchase_product_outbound = PurchaseOrderInfoForOutBound::where('del_time',0)
            ->whereIn('purchase_order_id',array_unique(array_column($purchase_product,'purchase_order_id')))
            ->where('type',PurchaseOrderInfoForOutBound::type_one)
            ->where('from_order_type',PurchaseOrderInfoForOutBound::from_type_zero)
            ->select('purchase_order_id','product_id','number','return_number')
            ->get()->toArray();
        $purchase_product_outbound_map = [];
        foreach ($purchase_product_outbound as $value){
            $key = $value['purchase_order_id'] . $value['product_id'];
            $tmp = bcsub($value['number'],$value['return_number'],2);
            if($tmp <= 0) continue;
            if(isset($purchase_product_outbound_map[$key])){
                $total_number = bcadd($purchase_product_outbound_map[$key], $tmp,2);
                $purchase_product_outbound_map[$key] = $total_number;
            }else{
                $purchase_product_outbound_map[$key] = $tmp;
            }
        }

        //退货
        $return = ReturnExchangeOrder::where('del_time',0)
            ->whereIn('data_id',$purchase_id)
            ->where('type',ReturnExchangeOrder::Order_type2)
            ->select('id','data_id')
            ->get()->toArray();
        $return_map = [];
        foreach ($return as $value){
            $return_map[$value['id']] = $value['data_id'];
        }

        $return_id = array_column($return,'id');
        $product_save = [];
        $sub = ReturnExchangeOrderProductInfo::where('return_or_exchange',ReturnExchangeOrderProductInfo::type_one)
            ->where('del_time',0)
            ->whereIn('return_exchange_id',$return_id)
            ->get()->toArray();
        foreach ($sub as $value){
            if(isset($return_map[$value['return_exchange_id']])){
                $purchase_tmp_id = $return_map[$value['return_exchange_id']];

                $key = $purchase_tmp_id . $value['product_id'];
                if(isset($product_save[$key])){
                    $tmp = bcadd($product_save[$key], $value['number'],2);
                    $product_save[$key] = $tmp;
                }else{
                    $product_save[$key] = $value['number'];
                }
            }
        }

        $return = [];
        foreach ($purchase_product as $value){
            $key = $value['purchase_order_id'] . $value['product_id'];
            $return_number_tmp = $product_save[$key] ?? 0; // 退货产品数量
            $purchase_number_lock_tmp = $purchase_product_outbound_map[$key] ?? 0; //采购单产品锁定未释放的数量

            //最终采购单下某个产品的实际数量
//            $number = bcsub($value['number'], $value['outbound_number'],2);
            $number = bcsub($value['number'], $purchase_number_lock_tmp,2);
            $number = bcsub($number,$return_number_tmp,2);

            if($number <= 0) continue;
//            $tmp = $map[$value['product_id']] ?? [];

            $return[$value['product_id']][] = [
                'id' => $value['id'],
                'purchase_order_id' => $value['purchase_order_id'],
                'number' => $number,
                'price' => $value['price'],
                'order_number' => $value['order_number'],
                'product_id' => $value['product_id'],
                'from_order_type' => PurchaseOrderInfoForOutBound::from_type_zero
//                'title' => $tmp['title'],
//                'code' => $tmp['code'],
//                'size' => $tmp['size'],
            ];
        }

        return $return;
    }

    //校验采购单产品数量 含退货 以及 出库 后最终产品数量 (通过采购单明细id)
    public function checkPurchaseProductByPurchaseInfoID($id, $product, $purchase_id){
        if(empty($purchase_id)) return [true, []];
        if(empty($product)) return [false, "出库产品校验产品不能为空"];
        //产品id
        $product_id = array_keys($product);

        //采购单产品数量
        $purchase_product = PurchaseOrderInfo::where('del_time',0)
            ->whereIn('purchase_order_id',$purchase_id)
            ->whereIn('product_id',$product_id)
//            ->whereColumn('number','>','outbound_number')
            ->select('id','number','price','purchase_order_id','order_number','product_id')
            ->orderBy('id','asc')
            ->get()->toArray();
        $purchase_product_map = [];
        foreach ($purchase_product as $value){
            $key = $value['purchase_order_id'] . $value['product_id'];
            if(isset($purchase_product_map[$key])){
                $total_number = bcadd($purchase_product_map[$key], $value['number'],2);
                $purchase_product_map[$key] = $total_number;
            }else{
                $purchase_product_map[$key] = $value['number'];
            }
        }

        //采购单占用未释放数据
        $purchase_product_outbound = PurchaseOrderInfoForOutBound::where('del_time',0)
            ->whereIn('purchase_order_id',array_column($purchase_product,'purchase_order_id'))
//            ->where('is_use',PurchaseOrderInfoForOutBound::is_not_use)
            ->where('type',PurchaseOrderInfoForOutBound::type_one)
            ->where('from_order_type',PurchaseOrderInfoForOutBound::from_type_zero)
            ->when(! empty($id), function ($query) use ($id) {
                return $query->where('data_id', '<>', $id);
            })
            ->select('purchase_order_id','product_id','number','return_number')
            ->get()->toArray();
        $purchase_product_outbound_map = [];
        foreach ($purchase_product_outbound as $value){
            $key = $value['purchase_order_id'] . $value['product_id'];
            $tmp = bcsub($value['number'],$value['return_number'],2);
            if($tmp <= 0) continue;
            if(isset($purchase_product_outbound_map[$key])){
                $total_number = bcadd($purchase_product_outbound_map[$key], $tmp,2);
                $purchase_product_outbound_map[$key] = $total_number;
            }else{
                $purchase_product_outbound_map[$key] = $tmp;
            }
        }

        //退货
        $return = ReturnExchangeOrder::where('del_time',0)
            ->whereIn('data_id',$purchase_id)
            ->where('type',ReturnExchangeOrder::Order_type2)
            ->select('id','data_id')
            ->get()->toArray();
        $return_map = [];
        foreach ($return as $value){
            $return_map[$value['id']] = $value['data_id'];
        }

        $return_id = array_column($return,'id');
        $product_save = [];
        $sub = ReturnExchangeOrderProductInfo::where('return_or_exchange',ReturnExchangeOrderProductInfo::type_one)
            ->where('del_time',0)
            ->whereIn('return_exchange_id',$return_id)
            ->get()->toArray();
        foreach ($sub as $value){
            if(isset($return_map[$value['return_exchange_id']])){
                $purchase_tmp_id = $return_map[$value['return_exchange_id']];

                $key = $purchase_tmp_id . $value['product_id'];
                if(isset($product_save[$key])){
                    $tmp = bcadd($product_save[$key], $value['number'],2);
                    $product_save[$key] = $tmp;
                }else{
                    $product_save[$key] = $value['number'];
                }
            }
        }

        //校验
        $count = [];
        foreach ($product as $value){
            $product_id = $value['product_id'];
            $total = $value['total'];
            foreach ($value['from'] as $f_v){
                if(! $f_v['id'] || ! $f_v['purchase_order_id'] || $f_v['from_order_type'] != PurchaseOrderInfoForOutBound::from_type_zero) continue;

                $key = $f_v['purchase_order_id'] . $product_id;
                $total_tmp = $purchase_product_map[$key] ?? 0; // 采购单产品总数
                $return_number_tmp = $product_save[$key] ?? 0; // 退货产品数量
                $purchase_number_lock_tmp = $purchase_product_outbound_map[$key] ?? 0; // 采购单产品锁定未释放的数量

                //最终采购单下某个产品的实际数量
//                $number = bcsub($value['number'], $value['outbound_number'],2);
                $number = bcsub($total_tmp, $purchase_number_lock_tmp,2);
                $number = bcsub($number,$return_number_tmp,2);

                //比较
                if($number < $f_v['number']) return [false, "采购单:" . $f_v['order_number'] . "实际可以出库的数量" . $number];

                if(isset($count[$value['product_id']])){
                    $num_tmp = bcadd($count[$value['product_id']], $f_v['number'],2);
                    $count[$value['product_id']] = $num_tmp;
                }else{
                    $count[$value['product_id']] = $f_v['number'];
                }
            }
        }

        return [true, $count];
    }

    //获取采购单产品数量 含退货 以及 出库 后最终产品数量 (在采购单列表页上，通过采购单id)
    public function getPurchaseProductForList($purchase_id, $search){
        if(empty($purchase_id)) return [];

        //采购单产品数量
        $purchase_product = PurchaseOrderInfo::where('del_time',0)
            ->whereIn('purchase_order_id',$purchase_id)
            ->get()->toArray();
        $basic_price = BasicType::whereIn('id',array_unique(array_column($purchase_product,'basic_type_id')))
            ->pluck('title','id')
            ->toArray();
        $map = (new ProductService())->getProductDetail(array_column($purchase_product,'product_id'));
        foreach ($purchase_product as $key => $value){
            $tmp = $map[$value['product_id']] ?? [];
            $purchase_product[$key]['title'] = $tmp['title'] ?? "";
            $purchase_product[$key]['code'] = $tmp['code'] ?? "";
            $purchase_product[$key]['size'] = $tmp['size'] ?? "";
            $purchase_product[$key]['unit'] = $tmp['unit'] ?? "";
            $purchase_product[$key]['bar_code'] = $tmp['bar_code'] ?? "";
            $purchase_product[$key]['basic_type_title'] = $basic_price[$value['basic_type_id']] ?? "";
        }

        if(! isset($search['product_usage'])) {
            return $this->clearProduct($purchase_product);
        }else{
            if($search['product_usage'] != PurchaseOrder::usage_return) return $this->clearProduct($purchase_product);
        }

        //采购单已出库产品（包含占用）
        $purchase_product_outbound = PurchaseOrderInfoForOutBound::where('del_time',0)
            ->whereIn('purchase_order_id',array_column($purchase_product,'purchase_order_id'))
            ->where('type',PurchaseOrderInfoForOutBound::type_one)
            ->where('from_order_type',PurchaseOrderInfoForOutBound::from_type_zero)
            ->select('purchase_order_id','product_id','number','return_number')
            ->get()->toArray();
        $purchase_product_outbound_map = [];
        foreach ($purchase_product_outbound as $value){
            $key = $value['purchase_order_id'] . $value['product_id'];
            $tmp = bcsub($value['number'],$value['return_number'],2);
            if($tmp <= 0) continue;
            if(isset($purchase_product_outbound_map[$key])){
                $total_number = bcadd($purchase_product_outbound_map[$key], $tmp,2);
                $purchase_product_outbound_map[$key] = $total_number;
            }else{
                $purchase_product_outbound_map[$key] = $tmp;
            }
        }

        //采购单退货
        $return = ReturnExchangeOrder::where('del_time',0)
            ->whereIn('data_id',$purchase_id)
            ->where('type',ReturnExchangeOrder::Order_type2)
            ->select('id','data_id')
            ->get()->toArray();
        $return_map = [];
        foreach ($return as $value){
            $return_map[$value['id']] = $value['data_id'];
        }
        $return_id = array_column($return,'id');
        $product_save = [];
        $sub = ReturnExchangeOrderProductInfo::where('return_or_exchange',ReturnExchangeOrderProductInfo::type_one)
            ->where('del_time',0)
            ->whereIn('return_exchange_id',$return_id)
            ->get()->toArray();
        foreach ($sub as $value){
            if(isset($return_map[$value['return_exchange_id']])){
                $purchase_tmp_id = $return_map[$value['return_exchange_id']];

                $key = $purchase_tmp_id . $value['product_id'];
                if(isset($product_save[$key])){
                    $tmp = bcadd($product_save[$key], $value['number'],2);
                    $product_save[$key] = $tmp;
                }else{
                    $product_save[$key] = $value['number'];
                }
            }
        }

        foreach ($purchase_product as $k => $value){
            $key = $value['purchase_order_id'] . $value['product_id'];
            $return_number_tmp = $product_save[$key] ?? 0; // 退货产品数量
            $purchase_number_lock_tmp = $purchase_product_outbound_map[$key] ?? 0; //采购单产品锁定未释放的数量

            //最终采购单下某个产品的实际数量
            $number = bcsub($value['number'], $purchase_number_lock_tmp,2);
            $number = bcsub($number,$return_number_tmp,2);

            if($number <= 0) {
                unset($purchase_product[$k]);
                continue;
            }

            $purchase_product[$k]['number'] = $number;
        }

        return $this->clearProduct($purchase_product);
    }

    public function clearProduct($purchase_product){
        $product = [];
        foreach ($purchase_product as $value){
            $product[$value['purchase_order_id']][] = $value;
        }

        return $product;
    }
}