baoshi-was/app/Services/StationTaskBatchService.php

<?php


namespace App\Services;


use App\Batch;
use App\StationTaskBatch;
use App\StationTaskBatchType;
use Exception;
use Illuminate\Support\Facades\Cache;

class StationTaskBatchService
{
    /** @var StationService $stationService */
    private $stationService;
    /** @var StationTaskBatchTypeService $stationTaskBatchTypeService */
    private $stationTaskBatchTypeService;
    /** @var BatchService $batchService */
    private $batchService;
    public function __construct(){
        $this->stationService=null;
        $this->stationTaskBatchTypeService=null;
        $this->batchService=null;
    }

    /**
     * @param $batches Batch[]
     * @throws Exception
     */
    public function createByBatches(array $batches){
        $this->stationService=app('StationService');
        $this->stationTaskBatchTypeService=app('StationTaskBatchTypeService');
        $this->batchService=app('BatchService');

        $stationMissionBatches_toCreate=[];
        $station=$this->stationService->getDefaultStation('料箱出货口');
        $id_stationMissionBatchType=$this->stationTaskBatchTypeService->firstByWhere('name','U型线分捡');

        foreach ($batches as &$batch){
            if ($batch['status']=='未处理'){
                $stationMissionBatches_toCreate[]=[
                    'batch_id'=>$batch['id'],
                    'station_id'=>$station['id'],
                    'station_mission_batch_type_id'=> $id_stationMissionBatchType,
                    'status'=>'待处理'
                ];
                $batch = '已处理';
            }
        }
        $this->batchService->updateWhereIn('id',data_get($batches,'*.id'),['status'=>'处理中']);
        $this->insert($stationMissionBatches_toCreate);
    }

    public function insert(array $stationMissionBatches_inArray){
        return StationTaskBatch::query()->insert($stationMissionBatches_inArray);
    }
}