baoshi-was/app/Services/StationTaskMaterialBoxService.php

<?php


namespace App\Services;


use App\Batch;
use App\OrderCommodity;
use App\StationTaskMaterialBox;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\Cache;

class StationTaskMaterialBoxService
{
    /** @var StationService $stationService */
    private $stationService;
    /** @var StationTypeService $stationTypeService */
    private $stationTypeService;
    /** @var StationTaskService $stationTaskService */
    private $stationTaskService;
    /** @var MaterialBoxService $materialBoxService */
    private $materialBoxService;
    public function __construct(){
        $this->stationService=null;
        $this->stationTypeService=null;
        $this->stationTaskService=null;
        $this->materialBoxService=null;
    }
    function createByBatches(array $batches,Collection $stationTasks_toAttach): Collection
    {
        return $this->stationTaskService
            ->registerSubTasks(
                $stationTasks_toAttach,
                (function()use($batches){
                    $stationTaskMaterialBoxes_listByBatch=new Collection();
                    foreach ($batches as $batch){
                        $stationTaskMaterialBoxes_listByBatch->push(
                            $this->createByBatch($batch)
                        );
                    }
                    return $stationTaskMaterialBoxes_listByBatch;
                })());

    }

    function createByBatch(Batch $batch): Collection
    {
        $this->materialBoxService=app('MaterialBoxService');
        $this->stationTypeService=app('StationTypeService');
        $this->stationService=app('StationService');
        $stationMaterialBoxes_toCreate=new Collection();
        $order_ids=data_get($batch['orders'],'*.id');
        $orderCommodities=OrderCommodity::query()->with('orderBin')->whereIn('order_id',$order_ids)->get();
        foreach ($orderCommodities as $orderCommodity){
            $stationType=$this->stationTypeService->getForMaterialBox();
            $station=$this->stationService->getStation_byType($stationType['name']);
            $materialBox=$this->materialBoxService->firstOrCreate(['code' => $orderCommodity['location']]);
            $stationMaterialBoxes_toCreate->push([
                'station_id'=>$station['id'],
                'material_box_id'=>$materialBox['id'],
                'status'=>'待处理'
            ]);
        }
        $this->insert($stationMaterialBoxes_toCreate->toArray());
    }

    function get(array $kvPairs){
        ksort($kvPairs);
        return Cache::remember('StationTaskMaterialBox'.md5(json_encode($kvPairs)), config('cache.expirations.fastChange'), function ()use($kvPairs) {
            $query = StationTaskMaterialBox::query();
            foreach ($kvPairs as $column => $value){
                if (is_array($value))$query->whereIn($column,$value);
                else $query->where($column,$value);
            }
            return $query->get();
        });
    }

    public function insert(array $stationTaskMaterialBoxes): bool
    {
        $inserted = StationTaskMaterialBox::query()->insert($stationTaskMaterialBoxes);
        LogService::log(__METHOD__,__FUNCTION__,json_encode($stationTaskMaterialBoxes).
            '||'.json_encode(array_slice(debug_backtrace(DEBUG_BACKTRACE_IGNORE_ARGS),0,3)));
        return $inserted;
    }

    function markHasPut($taskCode,$binCode){
        //如果
        //标记箱子任务处理中
        //标记箱子关联的商品任务处理中
        //标记波次处理中
    }

    function markHasTaken($taskCode,$binCode){

    }
}