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

<?php

namespace App\Http\Controllers;

use App\Batch;
use App\Components\AsyncResponse;
use App\Order;
use App\OrderBin;
use App\Services\WaveService;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Gate;
use Oursdreams\Export\Export;

class WaveController extends Controller
{
    use AsyncResponse;
    public function __construct()
    {
        app()->bind("WaveService",WaveService::class);
    }

    // 主页
    public function index(Request $request){
        if(!Gate::allows('订单管理-波次-查询')){ return redirect(url('/'));  }
        $waveService = app("WaveService");
        $waves = $waveService->queryWave($request);
        $param =  $waveService->getPageParameter($request);
        $search = $waveService->getSearchCondition($request);
        foreach ($waves as $index=>$wave){
            $wave->pickerPrint = '';
            $wave->pickerPrintTime = '';
            $wave->expressPrinting = '';
            $wave->expressPrintTime = '';
            if(!is_null($wave->userdefine1)){
                $str = $wave->userdefine1;
                $index = strpos($str,'-PK');
                $wave->pickerPrint = substr($str,0,$index);
                $wave->pickerPrintTime = substr($str,$index+3);
            }
            if(!is_null($wave->userdefine2)){
                $str = $wave->userdefine2;
                if(strpos($str,'-EX')){
                    $index = strpos($str,'-EX');
                    $wave->expressPrinting = substr($str,0,$index);
                    $wave->expressPrintTime = substr($str,$index+3);
                }else if(strpos($str,'-Auto')){
                    $index = strpos($str,'-Auto');
                    $wave->expressPrinting = substr($str,0,$index);
                    $wave->expressPrintTime = substr($str,$index+5);
                }
            }
        }
        return view("order/wave/search",compact('waves','param','search'));
    }

    public function cancelPrinting(Request $request){
        if(!Gate::allows('订单管理-波次-重置打印')){ return ['success'=>false,'fail_info'=>'没有权限，请联系管理员'];  }
        $waveService = app("WaveService");
        $ids = $request->input("ids");
        /** @var WaveService $waveService */
        $meg = $waveService->cancelPrint($ids);
        if($meg['fail_info']){
            return $meg;
        }
        app('LogService')->log(__METHOD__,'重置打印标记'.__FUNCTION__,json_encode($request->toArray()),Auth::user()['id']);
        return $meg;
    }

    public function exportExcelOnParams(Request $request){
        $sql = app("WaveService")->getSql($request);
        $e = new Export();
        $e->setOracleConnection(config('database.connections.oracle.host'),
            config('database.connections.oracle.port'),config('database.connections.oracle.database')
            ,config('database.connections.oracle.username'),config('database.connections.oracle.password'));
        $e->setFileName("波次记录");
        return $e->sql($sql,[
            "WAVENO"=>"波次号","CODENAME_C"=>"波次状态",
            "WAVERULE"=>"波次规则","DESCR"=>"波次描述",
            "DESCR_C"=>"承运人","ADDWHO"=>"操作员",
            "ADDTIME"=>"创建时间","pickerPrint"=>"拣货单打印人",
            "pickerPrintTime"=>"拣货单打印时间","expressPrinting"=>"快递单号打印人",
            "expressPrintTime"=>"快递单号打印时间"
        ])->direct();
    }
    public function repairBatch()
    {
        $error = [];
        foreach (\request("codes") as $code){
            if (!$code)continue;
            $wave = DB::connection("oracle")->selectOne(DB::raw("select * from DOC_WAVE_HEADER where WAVENO = ?"),[$code]);
            if (!$wave){
                $error[] = $code."FLUX无波次";
                continue;
            }
            $owner = app("OwnerService")->codeGetOwner($wave->customerid);
            $obj = [
                "wms_status" => $this->wms_status($wave),
                "wms_type"=>$wave->descr,
                "created_at"=>date("Y-m-d H:i:s"),
                "wms_created_at"=>$wave->addtime,
                "updated_at"=>$wave->edittime,
                "owner_id"=>$owner->id,
            ];
            $wave = Batch::query()->where("code",$code)->first();
            if (!$wave){
                $error[] = $code."本地无波次";
                $obj["code"] = $code;
                $wave = Batch::query()->create($obj);
            }else{
                Batch::query()->where("code",$code)->update($obj);
            }
            $ordernos = array_column(DB::connection("oracle")->select(DB::raw("select orderno from DOC_WAVE_DETAILS where WAVENO = ?"),[$code]),"orderno");
            $count = Order::query()->whereIn("code",$ordernos)->count();
            if (count($ordernos)!=$count)$error[] = $code."本地订单缺失";
            Order::query()->whereIn("code",$ordernos)->update([
                "batch_id"=>$wave->id
            ]);
            Order::query()->with(["batch","bin"])->whereIn("code",$ordernos)->get()->each(function ($order){
                if (!$order->bin){
                    $bin = DB::connection("oracle")->selectOne(DB::raw("select seqno from DOC_WAVE_DETAILS where waveno = ? and orderno = ?"),[$order->batch->code,$order->code]);
                    if ($bin){
                        OrderBin::query()->create([
                            'order_id' => $order->id,
                            'number' => $bin->seqno,
                        ]);
                    }
                }
            });
        }
        $this->success($error);
    }
    /**
     * @param $wave
     * @return string
     */
    private function wms_status($wave): string
    {
        switch ($wave->wavestatus) {
            case 00:
                $wms_status = '创建';
                break;
            case 40:
                $wms_status = '部分收货';
                break;
            case 90:
                $wms_status = '取消';
                break;
            case 99:
                $wms_status = '完成';
                break;
            case 62:
                $wms_status = '部分装箱';
                break;
            default:
                $wms_status = (string)$wave->wavestatus;
        }
        return $wms_status;
    }

    public function split()
    {
        $codes = \request("codes",[]);
        $splitSize = \request("split");
        $splitNumber = \request("number");
        if (!$codes || (!$splitSize && !$splitNumber))$this->error("无记录");
        if ((!is_numeric($splitSize) || !is_int((int)$splitSize)) && !is_numeric($splitNumber) || !is_int((int)$splitNumber))$this->error("非法输入");
        if ($splitSize){
            $size = Batch::query()->whereIn("code",$codes)->whereNull("split_size")->count();
            if ($size!=count($codes))$this->error("波次不全或不允许二次分割");
            Batch::query()->whereIn("code",$codes)->whereNull("split_size")->update([
                "split_size" => $splitSize
            ]);
        }else{
            $no = "";
            foreach ($codes as $code){
                $no .= "'".$code."',";
            }
            $no = rtrim($no,',');
            $sql = <<<SQL
SELECT WAVENO,MAX(SEQNO) count from DOC_WAVE_DETAILS WHERE WAVENO IN ({$no}) GROUP BY WAVENO
SQL;
            foreach (DB::connection("oracle")->select(DB::raw($sql)) as $wave){
                Batch::query()->where("code",$wave->waveno)->update(["split_size" => (int)ceil($wave->count/$splitNumber)]);
            };
        }
        $this->success();
    }

    public function printChild()
    {
        $codes = \request("codes",[]);
        if (!$codes)$this->error("无记录");
        $batches = [];
        foreach (Batch::query()->select("code","split_size","id")
                     ->whereIn("code",$codes)->whereNotNull("split_size")->get() as $batch){
            if ($batch->orders_count==0)continue;
            $bin = OrderBin::query()->selectRaw("MAX(number) max")->whereIn("order_id",Order::query()
                ->select("id")->where("batch_id",$batch->id))->first();
            $batches[$batch->code] = (int)ceil($bin->max/$batch->split_size);
        }
        $this->success($batches);
    }

    public function picking()
    {
        return view("order/wave/picking");
    }

    public function loadBatch()
    {
        $code = \request("code");
        $batch = null;
        if (!$code || !$batch = Batch::query()->select("id","split_size")->where("code",$code)->first())$this->error("无记录");
        $sql = <<<SQL
SELECT a.ORDERNO,a.QTY,s.ALTERNATE_SKU1,a.LOCATION,w.SEQNO FROM ACT_ALLOCATION_DETAILS a
    LEFT JOIN DOC_ORDER_HEADER o ON a.ORDERNO = o.ORDERNO
    LEFT JOIN DOC_WAVE_DETAILS w ON o.ORDERNO = w.ORDERNO
    LEFT JOIN BAS_SKU s ON a.SKU = s.SKU
WHERE w.WAVENO = '{$code}' ORDER BY w.SEQNO
SQL;
        $orders = DB::connection("oracle")->select(DB::raw($sql));
        $result = [];
        $currentList = [];
        $nodeSign = "";
        foreach ($orders as $order){
            if ($order->seqno%$batch->split_size==0 && $nodeSign!=$order->orderno){
                $result[] = $currentList;
                $currentList = [];
                $nodeSign = $order->orderno;
            }
            $currentList[] = ["barcode"=>$order->alternate_sku1,"qty"=>$order->qty,"location"=>$order->location];
        }
        if ($currentList)$result[] = $currentList;
        $this->success($result);
    }
}