baoshi-was/app/Jobs/ResetInstantBill.php

<?php

namespace App\Jobs;

use App\Order;
use App\OwnerFeeDetail;
use App\OwnerFeeDetailLogistic;
use App\Process;
use App\Province;
use App\Services\CacheService;
use App\Services\OwnerPriceDirectLogisticService;
use App\Services\OwnerPriceExpressService;
use App\Services\OwnerPriceLogisticService;
use App\Services\OwnerPriceOperationService;
use App\Store;
use App\Waybill;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Cache;

class ResetInstantBill implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    /** @var \stdClass $detail  */
    private $detail;
    /**
     * Create a new job instance.
     *
     * @param OwnerFeeDetail $detail
     *
     * @return void
     */
    public function __construct(OwnerFeeDetail $detail)
    {
        $this->detail = $detail;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        switch ($this->detail->outer_table_name){
            case "orders":
                /** @var \stdClass $order */
                $order = Order::query()->find($this->detail->outer_id);
                $key = date("Y-m")."_".$order->owner_id;
                if (Cache::has($key))Cache::increment($key);
                else Cache::put($key,1,2678400);

                $order->loadMissing(["logistic","shop","packages.commodities.commodity","batch"]);

                /** @var OwnerPriceExpressService $service */
                $service = app("OwnerPriceExpressService");
                $logistic_fee = 0;
                $commodities = [];
                $amount = 0;
                $volume = 0;
                $weight = 0;
                $logistic_bill = "";

                if (!$order->logistic || $order->logistic->type != "快递")$logistic_fee = null;

                $items = [];
                foreach ($order->packages as &$package){
                    $logistic_bill .= $package->logistic_number.",";
                    $volume += $package->bulk;
                    $weight += $package->weight;

                    // 四维转二维
                    $partAmount = 0;
                    foreach($package->commodities as &$commodity){
                        $commodity["commodity_name"] = $commodity->commodity ? $commodity->commodity->name : '';
                        $commodity["sku"] = $commodity->commodity ? $commodity->commodity->sku : '';
                        $partAmount += $commodity->amount;
                    }
                    $amount += $partAmount;
                    $commodities = array_merge($commodities,$package->commodities->toArray());

                    $provinceName = mb_substr($order->province,0,2);
                    $province = app(CacheService::class)->getOrExecute("province_".$provinceName,function ()use($provinceName){
                        return Province::query()->where("name","like",$provinceName."%")->first();
                    },86400);
                    if ($province){
                        $fee = $service->matching($package->weight, $order->owner_id, $order->logistic_id, $province->id);
                    }else{
                        $logistic_fee = null;
                        $fee = null;
                    }

                    $items[] = [
                        "amount" => $partAmount,
                        "logistic_bill" => $package->logistic_number,
                        "volume"=>$package->bulk,
                        "weight"=>$package->weight,
                        "logistic_fee" => $fee>0 ? $fee : null,
                    ];
                    if ($logistic_fee!==null){
                        if ($fee<0)$logistic_fee = null;
                        else $logistic_fee += $fee;
                    }
                }
                if ($logistic_fee!==null && $logistic_fee<0)$logistic_fee = null;

                $object = ["commodities"=>$commodities,
                    "logistic_name"=>($order->logistic ? $order->logistic->name : ''),
                    "shop_name"=>($order->shop ? $order->shop->name : ''),
                    "order_type"=>$order->order_type,
                    "batch_type" => $order->batch ? $order->batch->wms_type : '',
                    "owner_id"=>$order->owner_id];
                $mapping = ["packages"=>"commodities","商品名称"=>"commodity_name",
                    "承运商"=>"logistic_name","店铺类型"=>"shop_name","订单类型"=>"order_type",
                    "波次类型"=>"batch_type"];

                /** @var OwnerPriceOperationService $service */
                $service = app("OwnerPriceOperationService");
                $result = $service->matching($object,$mapping,$order->owner_id,"出库");


                $detail = $this->detail->update([
                    "work_fee"          => is_array($result) ? ($result["money"]>0 ? $result["money"] : null) : null,
                    "logistic_fee"      => $logistic_fee,
                ]);
                if ($detail){
                    foreach ($items as $item){
                        OwnerFeeDetailLogistic::query()->where("owner_fee_detail_id",$detail->id)
                            ->where("logistic_bill",$item["logistic_bill"])
                            ->update($item);
                    }
                }
                break;
            case "processes":
                /** @var \stdClass $process */
                $process = Process::query()->with("processStatistic")->find($this->detail->outer_id);
                $this->detail->update([
                    "work_fee"  => $process->processStatistic ? $process->processStatistic->revenue : null,
                ]);
                break;
            case "waybills":
                /** @var \stdClass $waybill */
                $waybill = Waybill::query()->find($this->detail->outer_id);
                $waybill->loadMissing(["destinationCity","order.owner"]);
                if (!$waybill->destinationCity && !$waybill->order)break;

                $owner_id = $waybill->order->owner_id ?? $waybill->owner_id;

                if ($waybill->type == "专线"){
                    /** @var OwnerPriceLogisticService $service */
                    $service = app("OwnerPriceLogisticService");
                    $fee = $service->matching($waybill->carrier_weight_other,$owner_id,$waybill->logistic_id,
                        $waybill->carrier_weight_unit_id_other,$waybill->order ? app("RegionService")->getProvince($waybill->order->province) : $waybill->destinationCity->province_id,
                        $waybill->destination_city_id);
                }else{
                    /** @var OwnerPriceDirectLogisticService $service */
                    $service = app("OwnerPriceDirectLogisticService");
                    $fee = $service->matching($waybill->mileage,$owner_id,$waybill->carType_id);
                }
                $this->detail->update([
                    "logistic_fee" => $fee ?? null,
                ]);
                break;
            case "stores":
                /** @var \stdClass $store */
                $store = Store::query()->find($this->detail->outer_id);
                $store->loadMissing("storeItems");

                /** @var OwnerPriceOperationService $service */
                $service = app("OwnerPriceOperationService");

                $mapping = ["packages" => "storeItems", "商品名称" => "name", "订单类型" => "stored_method", "订单数"=>"amount"];

                $result = $service->matching($store, $mapping, $store->owner_id, "入库");

                $this->detail->update([
                    "work_fee" => is_array($result) ? ($result["money"]>0 ? $result["money"] : null) : null,
                ]);
                break;
        }
    }
}