baoshi-was/app/Services/BatchService.php

<?php

namespace App\Services;

use App\Batch;
use Exception;

Class BatchService
{
    public function get(array $params)
    {
        $query = Batch::query();
        foreach ($params as $column=>$param){
            if (is_array($param))$query->whereIn($column,$param);
            else $query->where($column,$param);
        }
        return $query->get();
    }

    public function insert(array $insert)
    {
        $result = Batch::query()->insert($insert);
        if($result)$this->assignMissions($insert);
        return $result;
    }

    public function updateWhereIn($key,$values,$updateKeyValues){
        Batch::query()->whereIn($key,$values)->update($updateKeyValues);
    }

    /**
     * 为波次附加任务，已附加的重复任务不影响
     * @param Batch[] $batches
     * @throws Exception
     */
    public function assignMissions(array $batches)
    {
        /** @var StationTaskBatchService $stationTaskBatchService */
        $stationTaskBatchService=app('StationTaskBatchService');
        $stationTaskBatchService->createByBatches($batches);
    }

}