| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529 | <?phpnamespace App\Service;use App\Model\Construction;use App\Model\ConstructionProductInfo;use App\Model\Depart;use App\Model\Employee;use App\Model\InOutRecord;use App\Model\InvoiceOrder;use App\Model\InvoiceOrderInfo;use App\Model\OrderOperation;use App\Model\PaymentReceipt;use App\Model\ProductInventory;use App\Model\ProductInventorySet;use App\Model\PurchaseOrder;use App\Model\PurchaseOrderInfo;use App\Model\PurchaseOrderSpecial;use App\Model\PurchaseOrderSpecialInfo;use App\Model\ReturnExchangeOrder;use App\Model\ReturnExchangeOrderProductInfo;use App\Model\SalesOrder;use App\Model\SalesOrderInfo;use App\Model\SalesOrderOtherFee;use App\Model\SalesOrderProductInfo;use App\Model\SeeRange;use App\Model\Storehouse;use App\Model\Supplier;use App\Service\OaService;use Illuminate\Support\Facades\DB;class CheckService extends Service{    //审批操作对应的数值    const one = 1; //收货    const two = 2; //发货    const three = 3; //采购单入库    const four = 4; //合同公司完结    const five = 5; //施工单    const six = 6; //退换货单    const seven = 7; //采购单确认    const eight = 8; //合同确认    const nine = 9; //合同客户完结    const ten  = 10; //收付款确认    const eve  = 11; //接受派单    //中文对照    public $map = [        self::one => '收货单',        self::two => '发货单',//确认后出库        self::three => '采购单入库',//确认后入库        self::four => '公司完结', // 安装件 合同完结        self::five => '施工单',//确认后出库        self::six => '退换货单',//确认后出库或出库入库        self::seven => '采购单确认',        self::eight => '合同确认',        self::nine => '合同客户完结',        self::ten => '收付款确认',        self::eve => '接受门店派单',    ];    //入库操作    public static $in_opt = [        self::three,    ];    //出库操作    public static $out_opt = [        self::two,        self::five,    ];    const TYPE_ONE = 1;//通过    const TYPE_TWO = 2;//不通过    const TYPE_THREE = 3;//通过后驳回    //改为待审核状态 校验    public static $opt_1case_check = [        self::five => 'checkConstruction',//施工单    ];    //改为待审核状态    public static $opt_1case = [        self::two => 'waitInvoice',//发货单//        self::three => 'waitPurchase',//采购单 入库        self::five => 'waitConstruction',//施工单        self::six => 'waitReturnExchange',//退换货单        self::seven => 'waitPurchaseConfirm', //采购单确认        self::eight => 'waitSales', // 合同安装件 合同确认        self::ten => 'waitPaymentReceipt', //收付款确认    ];    public static $finished = [        self::three => 'confirmPurchaseOrder',//采购单 入库        self::four => 'settleSalesOrder', // 合同 安装件 合同公司完结        self::nine => 'settleSalesOrderCustomer', // 合同 安装件 合同客户完结        self::eve => 'settleSalesOrderConfirm', // 合同 安装件 合同接收    ];    //单据操作    public static $opt_case = [        self::two => 'confirmInvoiceOrder',//        self::three => 'confirmPurchaseOrder',        self::five => 'confirmConstruction',        self::six => 'confirmReturnExchangeOrder',        self::seven => 'confirmPurchaseOrderState',        self::eight => 'confirmSales', // 合同 安装件 合同确认        self::ten => 'confirmPaymentReceipt', // 确认收付款单    ];    //单据库存流水    public static $record = [        self::two => 'recordInvoiceOrder',        self::three => 'recordPurchaseOrder',        self::five => 'recordConstruction',        self::six => 'recordReturnExchangeOrder'    ];    //自动生成    public static $create = [        self::seven => 'createPurchaseOrderSales', //分社合同生成        self::four => 'createPurchaseOrder', // 派给分社的合同确认以后生成虚拟采购单    ];    //自动生成的删除    public static $create_del = [        self::seven => 'delCreatePurchaseOrderSales', //分社合同生成(删除)//        self::four => 'createPurchaseOrder', // 派给分社的合同确认以后生成虚拟采购单    ];    //审核通过后 驳回    public static $opt_case_reject = [        self::four => 'reject_sales', // 合同//        self::three => 'reject_purchase', //采购入库        self::seven => 'reject_purchase_confirm', //采购确认驳回        self::five => 'reject_construction',//施工单        self::six => 'reject_return_exchange',//退换货        self::ten => 'reject_payment_receipt',//收付款单    ];    //审核通过后 驳回 产生流水    public static $reject_record = [        self::five => 'reject_record_construction', //施工单驳回        self::three => 'reject_record_purchase', //采购        self::six => 'reject_record_return_exchange',//退换货    ];    //旅程日志 同意    public static $operation_order = [        self::eight => OrderOperation::three, //合同确认        self::two => OrderOperation::eight, //发货单确认        self::six => OrderOperation::nine, //退换货审核        self::five => OrderOperation::eve, //施工单        self::seven => OrderOperation::thi,//采购单确认        self::three => OrderOperation::fourteen,//采购单入库        self::ten => OrderOperation::twenty_one,//收付款单    ];    //旅程日志 驳回    public static $operation_order_reject = [        self::four => OrderOperation::four, //合同弃审        self::six => OrderOperation::ten, //退换货弃审        self::five => OrderOperation::twl, //施工单弃审        self::three => OrderOperation::fif,//采购单入库弃审        self::seven => OrderOperation::twenty,//采购单确认弃审        self::ten => OrderOperation::twenty_two,//收付款单    ];    //校验    public function checkConstruction($data, $user){        $order = Construction::where('del_time',0)            ->where('order_number',$data['order_number'])            ->first();        if(empty($order)) return [false,'施工单不存在或已被删除'];        $order = $order->toArray();        //总社id        $head = $user['head'] ?? [];        $head = $head['id'] ?? 0;        //分社自己的施工单 直接返回        if($order['top_depart_id'] != $head) return [true, ''];        //不校验库存        if($user['is_check_stock'] == ProductInventorySet::type_two)  return [true,''];        //施工单产品        $sub = ConstructionProductInfo::where('construction_id',$order['id'])            ->where('del_time',0)            ->get()->toArray();        if(empty($sub)) return [false,'施工单产品不存在或已被删除'];        $product_submit = $product_id = [];        foreach ($sub as $value){            $product_id[] = $value['product_id'];            $key = $value['product_id'] . ',' . $value['storehouse_id'];            if(isset($product_save[$key])){                $product_submit[$key] += $value['number'];            }else{                $product_submit[$key] = $value['number'];            }        }        //比较库存        list($status,$msg) = (new ProductInventoryService())->compareStock($user,$product_id, $product_submit, []);        if(! $status) return [false, $msg];        //锁定库存        ProductInventoryService::changeLockNumber($user,$product_submit);        return [true, ''];    }    //改为待审核---------------------------------    public function waitInvoice($data){        $model = InvoiceOrder::where('id',$data['id'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '发货单不存在或已被删除'];        if($model->state != InvoiceOrder::STATE_ZERO) return [false, '请确认发货单状态,操作失败'];        InvoiceOrder::where('del_time',0)->where('id',$data['id'])            ->update(['state' => InvoiceOrder::STATE_ONE]);        return [true, $model->toArray()];    }    public function waitPurchaseConfirm($data){        $model = PurchaseOrder::where('id',$data['id'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false,'采购单不存在或已被删除'];        if($model->state != PurchaseOrder::STATE_ZERO) return [false,'请确认采购单状态,操作失败'];        //待确认        PurchaseOrder::where('id',$data['id'])->update(['state' => PurchaseOrder::STATE_ONE]);        return [true, $model->toArray()];    }    public function waitPurchase($data){        $model = PurchaseOrder::where('id',$data['id'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '采购订单不存在或已被删除'];        if($model->state != PurchaseOrder::STATE_TWO) return [false, '请确认采购订单状态,操作失败'];        //待入库        PurchaseOrder::where('del_time',0)->where('id',$data['id'])            ->update(['state' => PurchaseOrder::STATE_Three]);        return [true, $model->toArray()];    }    public function waitConstruction($data){        $model = Construction::where('id',$data['id'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '施工单不存在或已被删除'];        if($model->state != Construction::STATE_ZERO) return [false, '请确认施工单状态,操作失败'];        //待确认        Construction::where('del_time',0)->where('id',$data['id'])            ->update(['state' => Construction::STATE_ONE]);        return [true, $model->toArray()];    }    public function waitReturnExchange($data){        $model = ReturnExchangeOrder::where('id',$data['id'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '退换货单不存在或已被删除'];        if($model->state != ReturnExchangeOrder::State_zero) return [false, '请确认退换货单状态,操作失败'];        //待确认        ReturnExchangeOrder::where('del_time',0)->where('id',$data['id'])            ->update(['state' => ReturnExchangeOrder::State_one]);        return [true, $model->toArray()];    }    public function waitSales($data){        $model = SalesOrder::where('id', $data['id'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '合同不存在或已被删除'];        //安装件        if($model->state != SalesOrder::State_zero) return [false, '请确认合同状态,操作失败'];        SalesOrder::where('del_time',0)->where('id',$data['id'])            ->update(['state' => SalesOrder::State_one]);        return [true, $model->toArray()];    }    public function waitPaymentReceipt($data){        $model = PaymentReceipt::where('id', $data['id'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '收付款单不存在或已被删除'];        if($model->state != PaymentReceipt::STATE_ZERO) return [false, '请确认收付款单状态,操作失败'];        PaymentReceipt::where('del_time',0)->where('id',$data['id'])            ->update(['state' => PaymentReceipt::STATE_ONE]);        return [true, $model->toArray()];    }    //改为待审核---------------------------------    //自动生成-----------------------------------    //总社派给分社的合同 完成生成虚拟采购单    public function createPurchaseOrder($order,$user){        //快递件        if($order['sales_order_type'] == SalesOrder::Order_type_two) return [true,''];        //不是总公司的合同        $head = $user['head'] ?? [];        $head = $head['id'] ?? 0; //总社id        if($head != $order['top_depart_id']) return [true, ''];        $see = SeeRange::where('del_time',0)            ->where('data_id',$order['id'])            ->where('data_type',SeeRange::type_seven)            ->where('type',SeeRange::data_three)            ->first();        if(empty($see)) return [false, '未找到指派分社信息'];        $depart_id = $see->param_id;//指派的分社        //总社指派给自己        if($depart_id == $head) return [true, ''];        //获取指派分社时候的金额        $fee = SalesOrderOtherFee::where('del_time',0)            ->where('sales_order_id',$order['id'])            ->first();        if(empty($fee)) return [false, '未找到指派分社时填写的金额'];        $fee = $fee->toArray();        $order_number = (new OrderNoService())->createOrderNumber(PurchaseOrderSpecial::prefix);        $storehouse = Storehouse::where('depart_id',$head)->value('id');        $product = SalesOrderProductInfo::where('del_time',0)            ->where('sales_order_id',$order['id'])            ->select('product_id','number','retail_price')            ->get()->toArray();        $product_map = $rate = [];        $total = 0;        foreach ($product as $value){            $total += $value['number'] * $value['retail_price'];            if(isset($product_map[$value['product_id']])){                $product_map[$value['product_id']] += $value['retail_price'] * $value['number'];            }else{                $product_map[$value['product_id']] = $value['retail_price'] * $value['number'];            }        }        foreach ($product_map as $key => $value){            $rate[$key] = sprintf("%.2f", round($value / $total, 2));        }        $model = new PurchaseOrderSpecial();        $model->order_number = $order_number;        $model->sales_order_id = $order['id'];        $model->depart_id = $head;        $model->top_depart_id = $head;        $model->crt_id = Employee::SPECIAL_ADMIN;        $model->purchase_id = Employee::SPECIAL_ADMIN;        $model->purchase_total = $fee['other_fee_1'] ?? 0;        $model->storehouse_id = $storehouse ?? 0;        $model->save();        if(empty($model->id)) return [false,'采购单主信息生成失败'];        $purchase_order_id = $model->id;        $insert = [];$product_total = 0;        foreach ($product as $value){            $rate_tmp = $rate[$value['product_id']] ?? 0;            $price = sprintf("%.2f", round($rate_tmp * $fee['other_fee_1'] / $value['number'], 2));            $product_total += $price * $value['number'];            $insert[] = [                'purchase_order_special_id' => $purchase_order_id,                'product_id' => $value['product_id'],                'order_number' => $order_number,                'number' => $value['number'],                'price' => $price,                'storehouse_id' => $storehouse,            ];        }        PurchaseOrderSpecialInfo::insert($insert);        PurchaseOrderSpecial::where('id',$purchase_order_id)->update(['total' => $product_total]);        return [true, ''];    }    //分社向总社采购 生成 分社订货合同    public function createPurchaseOrderSales($order,$user){        //没有供应商 不创建合同        if(empty($order['supplier'])) return [true, ''];        //总公司的采购单 不创建合同        $head = $user['head'] ?? [];        $head = $head['id'] ?? 0; //总社id        if($head == $order['top_depart_id']) return [true, ''];        //分社公司的采购单 不向总供应商采购 不创建合同        $is_create = Supplier::where('id',$order['supplier'])->value('is_main');        if(empty($is_create)) return [true, ''];        $customer_short_name = Depart::where('id',$order['top_depart_id'])->value('title') ?? "";        $prefix = SalesOrder::$prefix[SalesOrder::Model_type_two];        $order_number = OrderNoService::createSalesOrderNumber($prefix);        $product = PurchaseOrderInfo::where('del_time',0)            ->where('purchase_order_id',$order['id'])            ->get()->toArray();        if(empty($product)) return [false, '采购订单产品数据不能为空'];        $time = time();        $model = new SalesOrder();        $model->model_type = SalesOrder::Model_type_two;        $model->sales_order_type = SalesOrder::Order_type_two;        $model->customer_short_name = $customer_short_name;        $model->order_number = $order_number;        $model->crt_id = $order['crt_id'];        $model->depart_id = $head;        $model->top_depart_id = $head;        $model->other_fee = $order['other_fee'];        $model->discount_fee = $order['discount_fee'];        $model->contract_fee = $order['purchase_total'];        $model->contact_order_no = $order['order_number'];        $model->sign_time = $time;        $model->save();        $sales_order_id = $model->id;        //产品字典        $product_map = (new ProductService())->getProductDetail(array_column($product,'product_id'));        $insert = [];        $product_total = 0;        foreach ($product as $value){            $tmp = $product_map[$value['product_id']] ?? [];            $product_total += $value['price'] * $value['number'];            $insert[] = [                'sales_order_id' => $sales_order_id,                'product_id' => $value['product_id'],                'number' => $value['number'],                'basic_type_id' => $value['basic_type_id'],                'price' => $value['price'],                'cost' => $tmp['cost'] ?? 0,                'retail_price' => $tmp['retail_price'] ?? 0,                'final_amount' => $value['price'] * $value['number'],            ];        }        $bool = SalesOrderProductInfo::insert($insert);        if(! $bool) return [false,'合同生成失败!'];        //反写数据        $tmp = $product_total + $order['other_fee'];        $tmp = $tmp > 0 ? $tmp : 1;        $rate = ($product_total + $order['other_fee'] - $order['discount_fee']) / $tmp;        SalesOrder::where('id',$sales_order_id)->update([            'product_total' => $product_total,            'rate' => $rate        ]);        //生成付款单        $model = new PaymentReceipt();        $model->order_number = (new OrderNoService())->createOrderNumber(PaymentReceipt::prefix);        $model->data_order_no = $order_number;        $model->data_type = PaymentReceipt::data_type_one;        $model->type = PaymentReceipt::type_one;        $model->amount = $order['purchase_total'] ?? 0;        $model->crt_id = $user['id'];        $model->depart_id = $head;        $model->top_depart_id = $head;        $model->save();        return [true,''];    }    //自动生成-----------------------------------    //自动生成删除    public function delCreatePurchaseOrderSales($data, $order){        $sale_order = SalesOrder::where('del_time',0)            ->where('contact_order_no',$order['order_number'])            ->select('id','order_number')            ->get()->toArray();        if(empty($sale_order)) return [true,''];        foreach ($sale_order as $value){            list($status, $msg) = (new SalesOrderService())->salesOrderDel(['id' => $value['id']]);            if(! $status) return [false,$msg];            list($status, $msg) = (new PaymentReceiptService())->customerDel(['id' => $value['id']]);            if(! $status) return [false,$msg];        }        return [true, ''];    }    //自动生成删除    public function confirmPaymentReceipt($data){        $model = PaymentReceipt::where('order_number',$data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '收付款单不存在或已被删除'];        if($model->state != PaymentReceipt::STATE_ONE) return [false, '请确认收付款单状态,操作失败'];        if($data['type'] == self::TYPE_ONE){            //通过            $model->state = PaymentReceipt::STATE_TWO;            $model->save();        }else{            //驳回            $model->state = InvoiceOrder::STATE_ZERO;            $model->save();        }        return [true, $model->toArray()];    }    public function confirmInvoiceOrder($data){        $model = InvoiceOrder::where('order_number',$data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '发货单不存在或已被删除'];        if($model->state != InvoiceOrder::STATE_ONE) return [false, '请确认发货单状态,操作失败'];        if($data['type'] == self::TYPE_ONE){            //通过            $model->state = InvoiceOrder::STATE_TWO;            $model->save();            $sale = SalesOrder::where('id',$model->sales_order_id)->first();            if($sale['sales_order_type'] == SalesOrder::Order_type_one){                //安装件更新发货状态                SalesOrder::where('id',$model->sales_order_id)                    ->update(['invoice_state' => SalesOrder::invoice_one]);            }else{                //快递件更新 单据状态 发货状态                SalesOrder::where('id',$model->sales_order_id)                    ->update([                        'state' => SalesOrder::State2_one,                        'invoice_state' => SalesOrder::invoice_one                    ]);            }        }else{            //驳回            $model->state = InvoiceOrder::STATE_ZERO;            $model->save();        }        return [true, $model->toArray()];    }    public function recordInvoiceOrder($data, $order){        $result = InvoiceOrderInfo::where('del_time',0)            ->where('order_number',$order['order_number'])            ->get()->toArray();        if(empty($result)) return [false,'发货单产品信息不存在或已被删除'];        $insert = [];        $time = time();        foreach ($result as $value){            $key = $value['product_id'] . $value['storehouse_id'];            if(isset($insert[$key])){                $insert[$key]['number'] += -($value['number']);            }else{                $insert[$key] = [                    'product_id' => $value['product_id'],                    'number' => -($value['number']),                    'order_type' => InvoiceOrder::prefix,                    'order_number' => $order['order_number'],                    'crt_time' => $time,                    'storehouse_id' => $value['storehouse_id'],                    'depart_id' => $order['depart_id'],                    'top_depart_id' => $order['top_depart_id'],                ];            }        }        $insert = array_values($insert);        $bool = InOutRecord::insert($insert);        if(! $bool) return [false,'流水写入失败'];        return [true,''];    }    public function confirmPurchaseOrderState($data){        $model = PurchaseOrder::where('order_number',$data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false,'采购单不存在或已被删除'];        if($model->state != PurchaseOrder::STATE_ONE) return [false,'请确认采购单状态,操作失败'];        if($data['type'] == self::TYPE_ONE){            $model->state = PurchaseOrder::STATE_TWO;            $model->save();        }else{            $model->state = PurchaseOrder::STATE_ZERO;            $model->save();        }        return [true, $model->toArray()];    }    public function confirmPurchaseOrder($data,$user){        $model = PurchaseOrder::where('order_number',$data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '采购订单不存在或已被删除'];        if($model->state != PurchaseOrder::STATE_TWO) return [false, '请确认采购订单状态,操作失败'];        $model->state = PurchaseOrder::STATE_Four;        $model->save();        return [true, $model->toArray()];    }    public function recordPurchaseOrder($data, $order){        $result = PurchaseOrderInfo::where('del_time',0)            ->where('order_number',$order['order_number'])            ->get()->toArray();        if(empty($result)) return [false,'采购单产品信息不存在或已被删除'];        $insert = [];        $time = time();        foreach ($result as $value){            $key = $value['product_id'] . $value['storehouse_id'];            if(isset($insert[$key])){                $insert[$key]['number'] += $value['number'];            }else{                $insert[$key] = [                    'product_id' => $value['product_id'],                    'number' => $value['number'],                    'order_type' => PurchaseOrder::prefix,                    'order_number' => $order['order_number'],                    'crt_time' => $time,                    'storehouse_id' => $value['storehouse_id'],                    'depart_id' => $order['depart_id'],                    'top_depart_id' => $order['top_depart_id'],                ];            }        }        $insert = array_values($insert);        $bool = InOutRecord::insert($insert);        if(! $bool) return [false,'流水写入失败'];        return [true,''];    }    public function confirmConstruction($data){        $model = Construction::where('order_number',$data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '施工单不存在或已被删除'];        if($model->state != Construction::STATE_ONE) return [false, '请确认施工单状态,操作失败'];        if($data['type'] == self::TYPE_ONE){            $model->state = Construction::STATE_TWO;            $model->save();            //已下施工            SalesOrder::where('id',$model->sales_order_id)->update(['state' => SalesOrder::State_five]);        }else{            $model->state = Construction::STATE_ZERO;            $model->save();        }        return [true, $model->toArray()];    }    public function recordConstruction($data, $order){        $result = ConstructionProductInfo::where('del_time',0)            ->where('construction_id',$order['id'])            ->get()->toArray();        if(empty($result)) return [false,'施工单产品信息不存在或已被删除'];        $insert = [];        $time = time();        foreach ($result as $value){            $key = $value['product_id'] . $value['storehouse_id'];            if(isset($insert[$key])){                $insert[$key]['number'] += -($value['number']);            }else{                $insert[$key] = [                    'product_id' => $value['product_id'],                    'number' => -($value['number']),                    'order_type' => Construction::$prefix[$order['model_type']] ?? '',                    'order_number' => $order['order_number'],                    'crt_time' => $time,                    'storehouse_id' => $value['storehouse_id'],                    'depart_id' => $order['depart_id'],                    'top_depart_id' => $order['top_depart_id'],                ];            }        }        $insert = array_values($insert);        $bool = InOutRecord::insert($insert);        if(! $bool) return [false,'流水写入失败'];        return [true,''];    }    public function confirmReturnExchangeOrder($data){        $model = ReturnExchangeOrder::where('order_number',$data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '退换货单不存在或已被删除'];        if($model->state != ReturnExchangeOrder::State_one) return [false, '请确认退换货单状态,操作失败'];        if($data['type'] == self::TYPE_ONE){            $model->state = ReturnExchangeOrder::State_two;            $model->save();//            if($model->data_type == ReturnExchangeOrder::Order_type){//                SalesOrder::where('id', $model->data_id)->update([//                    'state' => SalesOrder::State_six//                ]);//            }        }else{            $model->state = ReturnExchangeOrder::State_zero;            $model->save();        }        return [true, $model->toArray()];    }    public function recordReturnExchangeOrder($data, $order){        $result = ReturnExchangeOrderProductInfo::where('del_time',0)            ->where('return_exchange_id',$order['id'])            ->get()->toArray();        if(empty($result)) return [false,'退换货单产品信息不存在或已被删除'];        $insert = $insert2 = [];        $time = time();        foreach ($result as $value){            $key = $value['product_id'] . $value['storehouse_id'];            $prefix = ReturnExchangeOrder::$prefix[$value['return_or_exchange']] ?? '';            if($value['return_or_exchange'] == ReturnExchangeOrderProductInfo::type_one){                //退货                if(isset($insert[$key])){                    $insert[$key]['number'] += $value['number'];                }else{                    $insert[$key] = [                        'product_id' => $value['product_id'],                        'number' => $value['number'],                        'order_type' => $prefix,                        'order_number' => $order['order_number'],                        'crt_time' => $time,                        'storehouse_id' => $value['storehouse_id'],                        'depart_id' => $order['depart_id'],                        'top_depart_id' => $order['top_depart_id'],                    ];                }            }else{                //换货                if(isset($insert2[$key])){                    $insert2[$key]['number'] += -($value['number']);                }else{                    $insert2[$key] = [                        'product_id' => $value['product_id'],                        'number' => -($value['number']),                        'order_type' => $prefix,                        'order_number' => $order['order_number'],                        'crt_time' => $time,                        'storehouse_id' => $value['storehouse_id'],                        'depart_id' => $order['depart_id'],                        'top_depart_id' => $order['top_depart_id'],                    ];                }            }        }        $insert = array_values($insert);        $bool = InOutRecord::insert($insert);        if(! $bool) return [false,'流水写入失败'];        if(! empty($insert2)) {            $insert2 = array_values($insert2);            $bool = InOutRecord::insert($insert2);            if(! $bool) return [false,'流水写入失败'];        }        return [true,''];    }    public function settleSalesOrder($data,$user){        $model = SalesOrder::where('order_number', $data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '合同不存在或已被删除'];        //安装件        if($model->state <= SalesOrder::State_four || $model->state >= SalesOrder::State_seven) return [false, '请确认合同状态,操作失败'];        SalesOrder::where('del_time',0)->where('order_number',$data['order_number'])            ->update(['state' => SalesOrder::State_seven]);        return [true, $model->toArray()];    }    public function settleSalesOrderCustomer($data,$user){        $model = SalesOrder::where('order_number', $data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '合同不存在或已被删除'];        if(empty($data['img'])) return [false,'图片不能为空'];        //安装件        if($model->state != SalesOrder::State_seven) return [false, '请确认合同状态,操作失败'];        SalesOrder::where('del_time',0)->where('order_number',$data['order_number'])            ->update(['state' => SalesOrder::State_eight]);        SalesOrderInfo::insert([            'sales_order_id' => $model->id,            'type' => SalesOrderInfo::type_six,            'file' => $data['img'],            'crt_time' => time(),        ]);        return [true, $model->toArray()];    }    public function settleSalesOrderConfirm($data,$user){        $model = SalesOrder::where('order_number', $data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '合同不存在或已被删除'];        //安装件        if($model->state != SalesOrder::State_four) return [false, '请确认合同状态,操作失败'];        $model->is_confirm = 1;        $model->save();        $emp_name = Employee::where('id',$user['id'])->value('emp_name');        $tmp_data = [            $model->order_number,            "派单合同",            "接收派单成功",            $emp_name,            date('Y-m-d H:i:s'),        ];        if(! empty($model->dispatch_time_second_id)) (new OaService())->sendWxMsg($model->dispatch_time_second_id,2,0,37,$tmp_data);        return [true, $model->toArray()];    }    public function confirmSales($data){        $model = SalesOrder::where('order_number', $data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '合同不存在或已被删除'];        if($model->state != SalesOrder::State_one) return [false, '请确认合同状态,操作失败'];        if($data['type'] == self::TYPE_ONE){            $state = SalesOrder::State_three;            if($model->model_type == SalesOrder::Model_type_four){                //线上订单                $state = SalesOrder::State_two;            }            $model->state = $state;            $model->save();        }else{            $model->state = SalesOrder::State_zero;            $model->save();        }        return [true, $model->toArray()];    }    public function reject_sales($data){        $model = SalesOrder::where('order_number', $data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '合同不存在或已被删除'];        //安装件        if($model->model_type == SalesOrder::Model_type_four){            //线上订单            if($model->state != SalesOrder::State_two) return [false, '请确认合同状态,操作失败'];        }else{            //除线上订单之外            if($model->state != SalesOrder::State_three) return [false, '请确认合同状态,操作失败'];        }        //未确认        $model->state = SalesOrder::State_zero;        $model->save();        return [true, $model->toArray()];    }    public function reject_purchase($data){        $model = PurchaseOrder::where('order_number', $data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '采购单不存在或已被删除'];        //安装件        if($model->state != PurchaseOrder::STATE_Four) return [false, '请确认采购单状态,操作失败'];        $model->state = PurchaseOrder::STATE_TWO;        $model->save();        return [true, $model->toArray()];    }    public function reject_purchase_confirm($data){        $model = PurchaseOrder::where('order_number', $data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '采购单不存在或已被删除'];        //安装件        if($model->state != PurchaseOrder::STATE_TWO) return [false, '请确认采购单状态,操作失败'];        $model->state = PurchaseOrder::STATE_ZERO;        $model->save();        return [true, $model->toArray()];    }    public function reject_construction($data){        $model = Construction::where('order_number', $data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '施工单不存在或已被删除'];        //安装件        if($model->state != Construction::STATE_TWO) return [false, '请确认施工单状态,操作失败'];        $model->state = Construction::STATE_ZERO;        $model->save();        return [true, $model->toArray()];    }    public function reject_payment_receipt($data){        $model = PaymentReceipt::where('order_number', $data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '收付款单不存在或已被删除'];        if($model->state != PaymentReceipt::STATE_TWO) return [false, '请确认收付款单状态,操作失败'];        $model->state = PaymentReceipt::STATE_ZERO;        $model->save();        return [true, $model->toArray()];    }    public function reject_return_exchange($data){        $model = ReturnExchangeOrder::where('order_number', $data['order_number'])            ->where('del_time',0)            ->first();        if(empty($model)) return [false, '退换货单不存在或已被删除'];        if($model->state != ReturnExchangeOrder::State_two) return [false, '请确认退换货单状态,操作失败'];        $model->state = ReturnExchangeOrder::State_zero;        $model->save();        return [true, $model->toArray()];    }    public function reject_record_construction($data,$order){        //获取单据最新数据时间 正常施工数据        $latest = InOutRecord::where('del_time',0)            ->where('order_number',$data['order_number'])            ->where('number','<',0)            ->select('crt_time')            ->orderBy('crt_time', 'desc')            ->first();        $latest = $latest->toArray();        $result = InOutRecord::where('del_time',0)            ->where('crt_time',$latest['crt_time'])            ->where('order_number',$data['order_number'])            ->where('number','<',0)            ->select('product_id','storehouse_id','number','depart_id','order_number','top_depart_id','order_type')            ->get()->toArray();        if(empty($result)) return [false,'施工出库流水数据未找到'];        //生成对冲数据        $time = time();        foreach ($result as $key => $value){            $result[$key]['number'] = abs($value['number']);            $result[$key]['crt_time'] = $time;        }        $bool = InOutRecord::insert($result);        if(! $bool) return [false,'流水写入失败'];        //写入流水        return [true, ''];    }    public function reject_record_purchase($data,$order){        //获取单据最新数据时间 正常采购入库数据        $latest = InOutRecord::where('del_time',0)            ->where('order_number',$data['order_number'])            ->where('number','>',0)            ->select('crt_time')            ->orderBy('crt_time', 'desc')            ->first();        $latest = $latest->toArray();        $result = InOutRecord::where('del_time',0)            ->where('crt_time',$latest['crt_time'])            ->where('order_number',$data['order_number'])            ->where('number','>',0)            ->select('product_id','storehouse_id','number','depart_id','order_number','top_depart_id','order_type')            ->get()->toArray();        if(empty($result)) return [false,'采购入库流水数据未找到'];        //生成对冲数据        $time = time();        foreach ($result as $key => $value){            $result[$key]['number'] = - $value['number'];            $result[$key]['crt_time'] = $time;        }        $bool = InOutRecord::insert($result);        if(! $bool) return [false,'流水写入失败'];        //写入流水        return [true, ''];    }    public function reject_record_return_exchange($data,$order){        $result = ReturnExchangeOrderProductInfo::where('del_time',0)            ->where('return_exchange_id',$order['id'])            ->get()->toArray();        if(empty($result)) return [false,'退换货单产品信息不存在或已被删除'];        $insert = $insert2 = [];        $time = time();        foreach ($result as $value){            $key = $value['product_id'] . $value['storehouse_id'];            $prefix = ReturnExchangeOrder::$prefix[$value['return_or_exchange']] ?? '';            if($value['return_or_exchange'] == ReturnExchangeOrderProductInfo::type_one){                //退货 扣出                if(isset($insert[$key])){                    $insert[$key]['number'] += -($value['number']);                }else{                    $insert[$key] = [                        'product_id' => $value['product_id'],                        'number' => -($value['number']),                        'order_type' => $prefix,                        'order_number' => $order['order_number'],                        'crt_time' => $time,                        'storehouse_id' => $value['storehouse_id'],                        'depart_id' => $order['depart_id'],                        'top_depart_id' => $order['top_depart_id'],                    ];                }            }else{                //换货 加回                if(isset($insert2[$key])){                    $insert2[$key]['number'] += $value['number'];                }else{                    $insert2[$key] = [                        'product_id' => $value['product_id'],                        'number' => $value['number'],                        'order_type' => $prefix,                        'order_number' => $order['order_number'],                        'crt_time' => $time,                        'storehouse_id' => $value['storehouse_id'],                        'depart_id' => $order['depart_id'],                        'top_depart_id' => $order['top_depart_id'],                    ];                }            }        }        $insert = array_values($insert);        $bool = InOutRecord::insert($insert);        if(! $bool) return [false,'流水写入失败'];        if(! empty($insert2)) {            $insert2 = array_values($insert2);            $bool = InOutRecord::insert($insert2);            if(! $bool) return [false,'流水写入失败'];        }        return [true,''];    }    public function getOrderDetail($data,$user){        if(empty($data['order_number'])) return [false,'必传参数不能为空'];        $array = [];        foreach (Construction::$prefix as $value){            $array[$value] = "\App\Service\\ConstructionService";        }        foreach (ReturnExchangeOrder::$prefix as $value){            $array[$value] = "\App\Service\\ReturnExchangeOrderService";        }        foreach (SalesOrder::$prefix as $value){            $array[$value] = "\App\Service\\SalesOrderService";        }        $status = true;        $msg = [];        foreach ($array as $key => $value){            if(strpos($data['order_number'],$key) !== false) {                list($status, $msg) = (new $value)->detail($data);                return [$status, $msg];            }        }        if(strpos($data['order_number'],PurchaseOrder::prefix) !== false){            $service = "\App\Service\\PurchaseOrderService";            list($status, $msg) = (new $service)->detail($data,$user);            return [$status, $msg];        }        return [$status, $msg];    }    public function checkAll($data,$user){        if(empty($data['id']) || empty($data['order_number'])|| empty($data['opt_case'])) return [false,'必传参数不能为空或者参数值错误!'];        list($status,$msg) = $this->limitingSendRequestBackgExpire($data['order_number'].$data['opt_case']);        if(! $status) return [false,$msg];        //走审批流 单据校验        $function_check = self::$opt_1case_check[$data['opt_case']] ?? '';        //走审批流 单据状态改为待审批方法        $function = self::$opt_1case[$data['opt_case']] ?? '';        //单据不走审批流        $function2 = self::$finished[$data['opt_case']] ?? '';        try{            DB::beginTransaction();            //不走审批流,更新完直接返回            if($function2) {                list($bool,$msg) = $this->$function2($data,$user);                if($bool) {                    $order = $msg;                    list($bool,$err) = $this->createRecordAndInventoryMy($data,$user,$order);                    if($bool){                        DB::commit();                        return [true, ''];                    }else{                        DB::rollBack();                        return [false, $err];                    }                }else{                    DB::rollBack();                    return [false, $msg];                }            }            //需要审批流,校验            if($function_check){                list($bool,$msg) = $this->$function_check($data, $user);                if(! $bool){                    DB::rollBack();                    return [false, $msg];                }            }            //需要审批流,从未审核变成待审核            if($function){                list($bool,$msg) = $this->$function($data);                if(! $bool){                    DB::rollBack();                    return [false, $msg];                }                //创建审批流                $args = [                    'order_no' => $data['order_number'],                    'menu_id' => $data['menu_id'] ?? 0,                    'opt_case' => $data['opt_case'],                    'order' => $msg,                ];                $oa = new OaService($user);                list($bool,$msg) = $oa->createOaOrder($args);                if(! $bool) {                    DB::rollBack();                    if($msg) return [false,$msg];                }            }            DB::commit();            return [true, ''];        }catch (\Throwable $exception){            DB::rollBack();            return [false, $exception->getMessage() . $exception->getFile(). $exception->getLine()];        }    }    //更新库存    public function changeInventory($data,$order,$user){        $number_symbol = "";        if(in_array($data['opt_case'],self::$in_opt)){            $number_symbol = ">";        }elseif (in_array($data['opt_case'],self::$out_opt)){            $number_symbol = "<";        }        //获取单据最新数据时间 正常审核的数据        $latest = InOutRecord::where('del_time',0)            ->where('order_number',$order['order_number'])            ->when(! empty($number_symbol), function ($query) use ($number_symbol) {                return $query->where('number', $number_symbol,0);            })            ->select('crt_time')            ->orderBy('crt_time', 'desc')            ->first();        $model = InOutRecord::where('del_time',0)            ->where('order_number',$order['order_number'])            ->when(! empty($number_symbol), function ($query) use ($number_symbol) {                return $query->where('number', $number_symbol,0);            })            ->select('number','crt_time','product_id','storehouse_id','top_depart_id');        if(! empty($latest)) {            $t = $latest->toArray();            $model->where('crt_time',$t['crt_time']);        }        $record = $model->get()->toArray();        if (empty($record)) return [false,'流水记录不存在'];        $top_depart_id = Storehouse::where('id', $order['storehouse_id'])->value('top_depart_id');        $result = $lock_number = [];        foreach ($record as $value){            $key = $value['product_id'] . $value['storehouse_id'];            if(isset($result[$key])){                $result[$key]['number'] += $value['number'];            }else{                $result[$key] = [                    'product_id' => $value['product_id'],                    'number' => $value['number'],                    'crt_time' => $value['crt_time'],                    'storehouse_id' => $value['storehouse_id'],                    'top_depart_id' => $top_depart_id,                ];            }            if($value['number'] < 0){                if(isset($lock_number[$key])){                    $lock_number[$key] += $value['number'];                }else{                    $lock_number[$key] = $value['number'];                }            }        }        //是否校验库存 是的话锁定数量要更新(根据当前操作人所在门店是否校验库存)        $lock = $user['is_check_stock'];        $result = array_values($result);        foreach ($result as $key => $value){            $keys = $value['product_id'] . $value['storehouse_id'];            $m = ProductInventory::where('product_id',$value['product_id'])                ->where('storehouse_id',$value['storehouse_id'])                ->select('product_id','number','storehouse_id')                ->first();            if(empty($m)){                ProductInventory::insert($result[$key]);            }else{                //锁定数量                $lock_number_tmp = 0;                if($lock && ! empty($lock_number[$keys])) $lock_number_tmp = $lock_number[$keys];                ProductInventory::where('product_id',$m->product_id)                    ->where('storehouse_id',$m->storehouse_id)                    ->lockForUpdate()                    ->update([                        'number' => DB::raw('number + ('. $value['number'] . ')'),                        'lock_number' => DB::raw('lock_number + ('. $lock_number_tmp . ')')                    ]);            }        }        return [true,''];    }    //业务单据审批通过后 驳回 更新库存    public function changeInventoryReject($data,$order,$user){        $number_symbol = "";        if(in_array($data['opt_case'],self::$in_opt)){            $number_symbol = "<";        }elseif (in_array($data['opt_case'],self::$out_opt)){            $number_symbol = ">";        }        //获取单据最新数据时间 正常审核的数据        $latest = InOutRecord::where('del_time',0)            ->where('order_number',$order['order_number'])            ->when(! empty($number_symbol), function ($query) use ($number_symbol) {                return $query->where('number', $number_symbol,0);            })            ->select('crt_time')            ->orderBy('crt_time', 'desc')            ->first();        $model = InOutRecord::where('del_time',0)            ->where('order_number',$order['order_number'])            ->when(! empty($number_symbol), function ($query) use ($number_symbol) {                return $query->where('number', $number_symbol,0);            })            ->select('number','crt_time','product_id','storehouse_id','top_depart_id');        if(! empty($latest)) {            $t = $latest->toArray();            $model->where('crt_time',$t['crt_time']);        }        $record = $model->get()->toArray();        if (empty($record)) return [false,'流水记录不存在'];        $top_depart_id = Storehouse::where('id', $order['storehouse_id'])->value('top_depart_id');        $result = $lock_number = [];        foreach ($record as $value){            $key = $value['product_id'] . $value['storehouse_id'];            if(isset($result[$key])){                $result[$key]['number'] += $value['number'];            }else{                $result[$key] = [                    'product_id' => $value['product_id'],                    'number' => $value['number'],                    'crt_time' => $value['crt_time'],                    'storehouse_id' => $value['storehouse_id'],                    'top_depart_id' => $top_depart_id,                ];            }            if($value['number'] > 0){                if(isset($lock_number[$key])){                    $lock_number[$key] += $value['number'];                }else{                    $lock_number[$key] = $value['number'];                }            }        }        //是否校验库存 是的话锁定数量要更新(根据当前操作人所在门店是否校验库存)        $lock = $user['is_check_stock'];        $result = array_values($result);        foreach ($result as $key => $value){            $keys = $value['product_id'] . $value['storehouse_id'];            $m = ProductInventory::where('product_id',$value['product_id'])                ->where('storehouse_id',$value['storehouse_id'])                ->select('product_id','number','storehouse_id')                ->first();            if(empty($m)){                ProductInventory::insert($result[$key]);            }else{                //锁定数量                $lock_number_tmp = 0;                if($lock && ! empty($lock_number[$keys])) $lock_number_tmp = $lock_number[$keys];                ProductInventory::where('product_id',$m->product_id)                    ->where('storehouse_id',$m->storehouse_id)                    ->lockForUpdate()                    ->update([                        'number' => DB::raw('number + ('. $value['number'] . ')'),                        'lock_number' => DB::raw('lock_number + ('. $lock_number_tmp . ')')                    ]);            }        }        return [true,''];    }    public function createRecordAndInventory($data = []){        if(empty($data['type']) || empty($data['opt_case']) || empty($data['order_number'])) return [false, '传递参数缺少'];        $user = $data['user_data'] ?? [];        if($data['type'] == self::TYPE_THREE){            //通过后弃审            if(! isset(self::$opt_case_reject[$data['opt_case']])) return [false, '该操作不存在'];            //具体方法            $function = self::$opt_case_reject[$data['opt_case']];            //流水            $function2 = self::$reject_record[$data['opt_case']] ?? '';            //自动生成删除            $function3 = self::$create_del[$data['opt_case']] ?? '';            try{                DB::beginTransaction();                //更新单据的状态                list($bool,$msg) = $this->$function($data);                if(! $bool){                    DB::rollBack();                    return [false, $msg];                }                $order = $msg;                if($function3){                    list($boolean,$msg) = $this->$function3($data,$order);                    if(! $boolean) {                        DB::rollBack();                        return [false, $msg];                    }                }                if($function2) {                    //流水                    list($boolean,$msg) = $this->$function2($data,$order);                    if(! $boolean) {                        DB::rollBack();                        return [false, $msg];                    }                    //库存                    list($bool,$msg) = $this->changeInventoryReject($data,$order,$user);                    if(! $bool){                        DB::rollBack();                        return [false, $msg];                    }                }                if(! empty(self::$operation_order_reject[$data['opt_case']])){                    $type = self::$operation_order_reject[$data['opt_case']];                    (new OrderOperationService())->add([                        'order_number' => $order['order_number'],                        'msg' => OrderOperation::$type[$type],                        'type' => $type                    ],$user);                }                DB::commit();                return [true, ''];            }catch (\Throwable $exception){                DB::rollBack();                return [false, $exception->getMessage() . $exception->getLine() . $exception->getFile()];            }        }else{            //具体方法            $function = self::$opt_case[$data['opt_case']] ?? "";            $record = self::$record[$data['opt_case']] ?? "";            $create = self::$create[$data['opt_case']] ?? "";            try{                DB::beginTransaction();                list($bool,$msg) = $this->$function($data);                if(! $bool){                    DB::rollBack();                    return [false, $msg];                }                $order = $msg;                if($data['type'] == self::TYPE_ONE){                    if($record) {                        //流水                        $bool = $this->$record($data, $order);                        if(! $bool) {                            DB::rollBack();                            return [false, $msg];                        }                        //库存                        list($bool,$msg) = $this->changeInventory($data, $order, $user);                        if(! $bool) {                            DB::rollBack();                            return [false, $msg];                        }                    }                    if($create) {                        list($bool,$msg) = $this->$create($order,$user);                        if(! $bool) {                            DB::rollBack();                            return [false, $msg];                        }                    }                }                if(! empty(self::$operation_order[$data['opt_case']])){                    $user = $data['user_data'] ?? [];                    $type = self::$operation_order[$data['opt_case']];                    (new OrderOperationService())->add([                        'order_number' => $order['order_number'],                        'msg' => OrderOperation::$type[$type],                        'type' => $type                    ],$user);                }                DB::commit();                return [true, ''];            }catch (\Throwable $exception){                DB::rollBack();                return [false, $exception->getMessage() . $exception->getLine() . $exception->getFile()];            }        }    }    //不需要走审批流 直接调用    public function createRecordAndInventoryMy($data = [],$user = [],$order = []){        if(! empty($data['type']) && $data['type'] == self::TYPE_THREE){        }else{            //具体方法            $record = self::$record[$data['opt_case']] ?? "";            $create = self::$create[$data['opt_case']] ?? "";            try{                DB::beginTransaction();                if($record) {                    //流水                    list($bool,$msg) = $this->$record($data, $order);                    if(! $bool) {                        DB::rollBack();                        return [false, $msg];                    }                    //库存                    list($bool,$msg) = $this->changeInventory($data, $order, $user);                    if(! $bool) {                        DB::rollBack();                        return [false, $msg];                    }                }                if($create) {                    list($bool,$msg) = $this->$create($order,$user);                    if(! $bool) {                        DB::rollBack();                        return [false, $msg];                    }                }                if(! empty(self::$operation_order[$data['opt_case']])){                    $type = self::$operation_order[$data['opt_case']];                    (new OrderOperationService())->add([                        'order_number' => $order['order_number'],                        'msg' => OrderOperation::$type[$type],                        'type' => $type                    ],$user);                }                DB::commit();                return [true, ''];            }catch (\Throwable $exception){                DB::rollBack();                return [false, $exception->getMessage() . $exception->getLine() . $exception->getFile()];            }        }    }}
 |