baoshi-was/app/Services/StorageService.php

<?php 

namespace App\Services;

use App\StationTask;
use App\StationTaskMaterialBox;
use App\Traits\ServiceAppAop;
use App\Storage;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\DB;

class StorageService
{
    use ServiceAppAop;
    protected $modelClass=Storage::class;


    /**
     * 填充缓存架
     *
     * @param \Illuminate\Database\Eloquent\Collection $stations
     */
    public function paddingCacheShelf($stations)
    {
        $collection = new Collection();
        $stationCollection = new Collection();
        $blacklist = [];
        foreach ($stations as $station){
            $box = app("MaterialBoxService")->getAnEmptyBox($blacklist);
            if (!$box)continue;
            $task = StationTask::query()->create([
                'status' => "待处理",
                'station_id' => $station->id,
            ]);
            $collection->add(StationTaskMaterialBox::query()->create([
                'station_id' => $station->id,
                'material_box_id'=>$box->id,
                'status'=>"待处理",
                'type' => '取',
                'station_task_id' => $task->id,
            ]));
            $stationCollection->add($station->code);
            $blacklist[] = $box->id;
        }
        app("ForeignHaiRoboticsService")->fetchGroup_multiLocation($stationCollection,$collection,'','立架出至缓存架');
    }

    /**
     * 释放库位占用
     *
     * @param StationTaskMaterialBox|\stdClass $stationTaskMaterialBox
     */
    public function releaseOccupation($stationTaskMaterialBox)
    {
        $stationTaskMaterialBox->loadMissing("station");
        if ($stationTaskMaterialBox->station->station_type_id != 5)return;
        $storage = Storage::query()->where("material_box_id",$stationTaskMaterialBox->material_box_id)->first();
        if (!$storage)return;
        $update = [];
        if ($storage->status == 1)$update["status"] = 0;
        if ($storage->station_id)$update["station_id"] = null;
        if ($update)$storage->update($update);
    }

    /**
     * 入库
     *
     * @param integer $stationId
     * @param integer $boxId
     * @param integer $commodityId
     * @param integer $amount
     */
    public function enterWarehouse($stationId, $boxId, $commodityId, $amount)
    {
        $storage = Storage::query()->where("material_box_id",$boxId)->first();
        $obj = [
            "station_id" => $stationId,
            "material_box_id" => $boxId,
            "commodity_id" => $commodityId,
            "amount" => $amount,
            "status" => 1,
        ];
        if ($storage){
            $obj["amount"] = DB::raw("amount+{$amount}");
            $storage->update($obj);
        } else Storage::query()->create($obj);
    }
}