baoshi-was/app/Http/Controllers/StorageController.php

<?php

namespace App\Http\Controllers;

use App\Commodity;
use App\CommodityMaterialBoxModel;
use App\Components\AsyncResponse;
use App\MaterialBox;
use App\MaterialBoxModel;
use App\Owner;
use App\Station;
use App\StationTask;
use App\StationTaskMaterialBox;
use App\Storage;
use App\StoreItem;
use App\TaskTransaction;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Foundation\Auth\AuthenticatesUsers;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Gate;
use Illuminate\Support\Facades\Validator;

class StorageController extends Controller
{
    use AsyncResponse;
    use AuthenticatesUsers;

    public function putShelf()
    {
        $this->gate("入库管理-入库-缓存架入库");
        $asn = \request("asn");
        $ide = \request("ide");
        $barCode = \request("barCode");
        $amount = (int)\request("amount");
        //check info
        if (!$asn || !$ide || !$barCode || !$amount)$this->error("信息不完整");
        $fromLocation = app("MaterialBoxService")->getBoxLocation($ide);
        if (!$fromLocation)$this->error("WAS无此库位信息");
        $box = MaterialBox::query()->where("code",$ide)->first();
        if (!$box)$this->error("WAS无此料箱");

        //库存相关信息
        /** @var Station|\stdClass $station */
        $station = Station::query()->firstOrCreate(["code"=>$fromLocation],[
            'name' => $fromLocation, 'code' => $fromLocation, 'station_type_id' => 5
        ]);
        $item = StoreItem::query()->whereHas("store",function (Builder $query){
            $query->where("asn_code",request("asn"));
        })->whereHas("commodity",function (Builder $query)use($barCode){
            $query->whereHas("barcodes",function (Builder $query)use($barCode){
                $query->where("code",$barCode);
            });
        })->first();
        //get flux
        $tasks = app("StorageService")->getFluxTask($asn,$barCode,$amount);
        if (!$tasks)$this->error("该单无上架任务或不存在");
        //此处嵌套三层事务 以最高层级为准
        DB::beginTransaction(); //总体事务 回滚WAS错误操作
        try{
            //库存记录
            if (!app("StorageService")->enterWarehouse($station->id, $box->id, $item->commodity_id ?? null, $amount, $box->material_box_model_id))$this->error("库存异常");

            DB::connection("oracle")->transaction(function ()use($tasks,$ide){ //单体嵌套事务 回滚FLUX失败任务
                foreach ($tasks as $task)if (!app("StorageService")->fluxPA($task,$ide)){
                    DB::connection("oracle")->rollBack();
                    $this->error("FLUX上架失败");
                };
            });
            DB::commit();
        }catch (\Exception $e){
            DB::rollBack();
            $this->error($e->getMessage());
        }
        //亮灯
        app("CacheShelfService")->_stationCacheLightOn($fromLocation,$ide);

        $maximum = app("CommodityMaterialBoxModelService")->getMaximum($box->material_box_model_id,$item->commodity_id ?? null);
        if ($maximum && $maximum<$amount)app("CommodityMaterialBoxModelService")->setMaximum($box->material_box_model_id,$item->commodity_id ?? null,$amount);
        $this->success(["model" => $box->material_box_model_id,"commodity" => $item->commodity_id ?? null, "maximum" => $maximum]);
    }

    public function setMaximum()
    {
        app("CommodityMaterialBoxModelService")->setMaximum(request("model"),request("commodity"),request("maximum"));
        $this->success();
    }

    /**
     * 检查最大限值并返回
     *
     */
    public function checkMaximum()
    {
        $item = app("StoreItemService")->getMaxAvailableDetail(request("asn"),request("barCode"));
        if (!$item)$this->error("无此单据记录");
        $models = CommodityMaterialBoxModel::query()->where("commodity_id",$item->commodity_id)->get();
        if ($models->count()==0)$this->error("商品首入，请使用缓存架空箱入库");
        foreach ($models as $model){
            $result = app("StorageService")->getHalfBoxLocation($model,$item,request("asn"));
            if ($result){
                $result->maximum = $model->maximum-$result->amount;
                $this->success($result);
            }
        }
        $this->success(["need"=>$models[0]->maximum,"material_box_model_id"=>$models[0]->material_box_model_id,"commodity_id"=>$item->commodity_id]);
    }

    /**
     * 检查ASN可上架总数
     */
    public function checkAsnAmount()
    {
        $sql = <<<sql
SELECT sum(fmqty) amount FROM DOC_ASN_DETAILS LEFT JOIN BAS_SKU ON DOC_ASN_DETAILS.CUSTOMERID = BAS_SKU.CUSTOMERID AND DOC_ASN_DETAILS.SKU = BAS_SKU.SKU
LEFT JOIN TSK_TASKLISTS ON DOC_ASN_DETAILS.ASNNO = TSK_TASKLISTS.DOCNO AND DOC_ASN_DETAILS.ASNLINENO = TSK_TASKLISTS.DOCLINENO
WHERE ASNNO = ? AND (ALTERNATE_SKU1 = ? OR ALTERNATE_SKU2 = ? OR ALTERNATE_SKU3 = ?)
  AND TASKPROCESS = '00' AND TASKTYPE = 'PA'
sql;
        $task = DB::connection("oracle")->selectOne(DB::raw($sql),[request("asn"),request("barCode"),request("barCode"),request("barCode")]);
        $this->success($task->amount ?? 0);
    }

    /**
     * 重置缓存架指定格口
     */
    public function resetCacheShelf()
    {
        $this->gate("入库管理-入库-缓存架入库");
        $boxes = request("boxes");
        //清理任务
        $data = '';
        $occupy = Storage::query()->with("station:id,code")->whereIn("station_id",Station::query()->select("id")->whereIn("code",$boxes))->where("status",1)->get();
        foreach ($occupy as $item){
            unset($boxes[array_search($item->station->code,$boxes)]);
            $data .= '“'.$item->station->code.'”,';
        }
        if ($occupy->count()>0){
            $data .= "存在任务待处理,无法调取  ";
            $boxes = array_values($boxes);
        }
        $tasks = StationTaskMaterialBox::query()->with("station:id,code")
            ->whereIn("station_id",Station::query()->select("id")->whereIn("code",$boxes))
            ->whereNotIn("status",["完成","取消"])->get();
        foreach ($tasks as $task){
            unset($boxes[array_search($task->station->code,$boxes)]);
            $data .= '“'.$task->station->code.'”,';
        };
        if ($tasks->count()>0){
            $data .= "任务排队中,无法调取";
            $boxes = array_values($boxes);
        }
        //重新调取料箱
        $result = app("ForeignHaiRoboticsService")->paddingCacheShelf(Station::query()->whereIn("code",$boxes)->get());
        if ($result===null)$this->error("任务下发错误，检查日志");
        if ($result===false)$this->error("已无可用料箱，部分库位填充失败");
        $this->success(["data"=>$data,"boxes"=>$boxes]);
    }

    /**
     * 取得料箱
     */
    public function acquireBox()
    {
        $this->gate("入库管理-入库-半箱补货入库");
        $boxId = request("material_box_id");
        $modelId = request("material_box_model_id");
        //获取目标库位
        $station = app("StationService")->getMirrorMappingLocation(request("station"));
        if (!$station)$this->error("未知库位");
        $occupyTask = StationTaskMaterialBox::query()->where("station_id",$station->id)->whereNotIn("status",["完成","取消"])->first();
        if ($occupyTask)$this->error("库位存在任务未处理完成");
        $amount = app("StorageService")->checkPutAmount(request("asn"),request("barCode"));
        if ($amount<request("amount"))$this->error("待上架数量不足，最大可上数量为{$amount}");
        //获取料箱
        if ($boxId && !app("MaterialBoxService")->checkUsableBox($boxId)){
            $blacklist = [$boxId];
            $boxId = null;
            //料箱存在且不可用
            $models = CommodityMaterialBoxModel::query()->where("commodity_id",request("commodity_id"))->get();
            $item = app("StoreItemService")->getMaxAvailableDetail(request("asn"),request("barCode"));
            if (!$item)$this->error("无此单据记录");
            foreach ($models as $model){
                //料箱不可用寻找新料箱
                $result = app("StorageService")->getHalfBoxLocation($model,$item,request("asn"),$blacklist);
                while ($result){
                    //料箱可用并且数量符合本次半箱数量 跳出
                    if (app("MaterialBoxService")->checkUsableBox($result->material_box_id)
                        && $model->maximum-$result->amount>=request("amount")){$boxId = $result->material_box_id;break;}
                    else $blacklist[] = $result->material_box_id;
                    //否则黑名单此料箱继续查找 直至料箱为空
                    $result = app("StorageService")->getHalfBoxLocation($model,$item,request("asn"),$blacklist);
                }
            }
        }
        //料箱不存在且该商品有过入库记录 拿取空箱
        if (!$boxId){
            if (!$modelId){
                $box = null;
                $models = CommodityMaterialBoxModel::query()->with("materialBoxModel")->where("commodity_id",request("commodity_id"))->get();
                foreach ($models as $model){
                    if (!$model->materialBoxModel)continue;
                    $box = app("MaterialBoxService")->getAnEmptyBox($model->materialBoxModel);
                    if($box)break;
                }
            }else $box = app("MaterialBoxService")->getAnEmptyBox(MaterialBoxModel::query()->find($modelId));
            if (!$box)$this->error("无可用料箱");
            $boxId = $box->id;
        }
        //发起取箱任务
        DB::beginTransaction();
        $collection = new Collection();
        $task = StationTask::query()->create([
            'status' => "待处理",
            'station_id' => $station->id,
        ]);
        $collection->add(StationTaskMaterialBox::query()->create([
            'station_id' => $station->id,
            'material_box_id'=>$boxId,
            'status'=>"待处理",
            'type' => '取',
            'station_task_id' => $task->id,
        ]));
        if (!app("ForeignHaiRoboticsService")->fetchGroup($station->code,$collection,'','立架出至缓存架'))$this->error("呼叫机器人失败");
        //生成临时任务事务
        TaskTransaction::query()->create([
            "doc_code" => request("asn"),
            "bar_code" => request("barCode"),
            "fm_station_id" => $station->id,
            "material_box_id" => $boxId,
            "commodity_id" => request("commodity_id"),
            "amount" => request("amount"),
            "type" => "入库",
            "user_id" => Auth::id(),
            "mark" => 1
        ]);
        DB::commit();
        //亮灯
        app("CacheShelfService")->stationLightUp($station->code,null,'2');
        $this->success();
    }

    /**
     * 溢出校正
     */
    public function overflowRevision()
    {
        $this->gate("入库管理-入库-半箱补货入库");
        $station = request("station");
        $amount = request("amount");
        //获取目标库位
        $station = app("StationService")->getMirrorMappingLocation($station);
        if (!$station)$this->error("未知库位");
        $task = TaskTransaction::query()->with("materialBox")->where("fm_station_id",$station->id)->where("amount",">",$amount)
            ->where("type","入库")->where("mark",1)->where("status",0)->first();
        if (!$task)$this->error("无任务存在");
        $task->update(["amount" => DB::raw("amount - {$amount}")]);
        $storage = Storage::query()->where("material_box_id",$task->material_box_id)->first();
        $maximum = (($storage->amount ?? 0)+$task->amount)-$amount;
        CommodityMaterialBoxModel::query()->where("material_box_model_id",$task->materialBox->material_box_model_id)
            ->where("commodity_id",$task->commodity_id)->update(["maximum"=>$maximum]);
        $this->success("校正成功");
    }

    public function syncStorage()
    {
        ini_set('max_execution_time', 0);
        $model = MaterialBoxModel::query()->create([
            "code" => "common"
        ]);
        $sql = <<<sql
    select * from INV_LOT_LOC_ID where traceid = '*' and locationid like 'IDE%'
sql;
        DB::beginTransaction();
        foreach (DB::connection("oracle")->select(DB::raw($sql)) as $inv){
            $materialBox = MaterialBox::query()->firstOrCreate(["code"=>$inv->locationid],[
                "code" => $inv->locationid,
                "material_box_model_id"=>$model
            ]);
            $owner = Owner::query()->firstOrCreate([
                "code" => $inv->customerid
            ],[
                "code" => $inv->customerid,
                "name" => $inv->customerid,
            ]);
            $commodity = Commodity::query()->where("owner_id",$owner->id)->where("sku",$inv->sku)->first();
            $s = \App\Storage::query()->where("material_box_id",$materialBox->id)
                ->where("commodity_id",$commodity->id)->first();
            if (!$s)\App\Storage::query()->create([
                "material_box_id" => $materialBox->id,
                "commodity_id" => $commodity->id,
                "amount" => $inv->qty,
            ]);else $s->update(["amount" => $inv->qty]);
        }
        DB::commit();
        $this->success();
    }

    /**
     * 在安卓端的个体登录鉴权
     *
     */
    public function androidLogin()
    {
        $errors=Validator::make(request()->input(),[
            "name"      => 'required|string',
            'password'  => 'required|string'])->errors();
        if($errors->count()>0){return ['success'=>false,'errors'=>$errors];}
        request()->offsetSet("remember",true);
        if (!$this->attemptLogin(request()))return ['success'=>false,'errors'=>['name'=>['登录信息验证失败']]];
        if (!Gate::allows("入库管理-入库-缓存架入库") && !Gate::allows("入库管理-入库-半箱补货入库"))return ['success'=>false,'errors'=>['name'=>['用户无权操作入库']]];
        return ['success'=>true,'url'=>url("store/inStorage/android.index")];
    }
    public function username(): string
    {
        return 'name';
    }

    /**
     * 库外箱绑定至库位
     */
    public function bindBox()
    {
        $location = request("location");
        $box = request("ide");
        if (!$location || !$box)$this->error("参数传递错误");
        $task = StationTaskMaterialBox::query()->select("id")->where(function ($query)use($location,$box){
            /** @var Builder $query */
            $query->whereHas("station",function ($query)use($location){
                /** @var Builder $query */
                $query->where("code",$location);
            })->orWhereHas("materialBox",function ($query)use($box){
                /** @var Builder $query */
                $query->where("code",$box);
            });
        })->whereNotIn("status",["完成","取消"])->first();
        if ($task)$this->error("库位或料箱存在任务待执行,无法放置料箱");
        $ks = DB::connection("mysql_haiRobotics")->table("ks_bin")->select(DB::raw("1"))
            ->where("ks_bin_code",$box)->where("status",4)->first();
        if (!$ks)$this->error("海柔料箱状态异常");
        DB::beginTransaction();
        try {
            $storages = Storage::query()->whereHas("station",function ($query)use($location){
                /** @var Builder $query */
                $query->where("code",$location);
            })->orWhereHas("materialBox",function ($query)use($box){
                /** @var Builder $query */
                $query->where("code",$box);
            })->lockForUpdate()->first();
            $station = Station::query()->where("code",$location)->first();
            $box = MaterialBox::query()->where("code",$box)->first();
            if (!$station || !$box)$this->error("库位或料箱未在WAS记录");
            switch ($storages->count()){
                case 0:
                    Storage::query()->create([
                        "station_id" => $station->id,
                        "material_box_id" => $box->id,
                    ]);
                    break;
                case 1:
                    $storage = $storages->first();
                    if ($storage->status==1)$this->error("库存占用中");
                    //已经映射库位 跳出
                    if ($storage->station_id==$station->id && $storage->material_box_id==$box->id)break;
                    //库存中 仅有库位信息
                    if ($storage->station_id==$station->id){
                        //料箱信息存在且有库存-》新建库位映射，将此料箱库位清空
                        if ($storage->material_box_id && $storage->amount){
                            Storage::query()->create([
                                "station_id" => $station->id,
                                "material_box_id" => $box->id,
                            ]);
                            $storage->update(["station_id"=>null]);
                            //料箱信息不存在或没有库存信息 映射到当前库位
                        }else $storage->update(["material_box_id"=>$box->id,"commodity_id"=>null,"amount"=>0]);
                    }else $storage->update(["station_id"=>$station->id]);
                    break;
                case 2:
                    //ls：库位库存 bs：料箱库存
                    $ls = null;
                    $bs = null;
                    foreach ($storages as $storage){
                        if ($storage->station_id==$station->id)$ls = $storage;
                        else $bs = $storage;
                    }
                    //其一不存在说明库存中重复记录 需要人工筛查
                    if (!$ls || !$bs)$this->error("库存中重复库位记录或料箱记录");
                    //库位库存存在有效库存 库位置空 否则删除库存记录
                    if ($ls->material_box_id && $ls->amount)$ls->update(["station_id"=>null]);
                    else $ls->delete();
                    //料箱映射库位改至当前库位
                    $bs->update(["station_id"=>$station->id]);
                    break;
                default:
                    $this->error("库存信息异常，料箱或库位未完全释放");
            }
            DB::commit();
            $this->success();
        }catch (\Exception $e){
            DB::rollBack();
            $this->error($e->getMessage());
        }
    }

    public function bindModelIndex(){
        $models = MaterialBoxModel::query()->get();
        return view("store.inStorage.boxBindModel",compact("models"));
    }

    public function searchIde()
    {
        $ide = request("ide");
        $box = MaterialBox::query()->where("code",$ide)->first();
        if (!$box)$this->error("料箱不存在");
        $this->success($box->material_box_model_id);
    }

    public function boxBindModel()
    {
        $this->success(MaterialBox::query()->where("code",request("ide"))
            ->update(["material_box_model_id"=>request("material_box_model_id")]));
    }
}