baoshi-was/app/Jobs/ResetInstantBill.php

<?php

namespace App\Jobs;

use App\Feature;
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);
                if (!$order || $order->wms_status != "订单完成")break;
                $order->loadMissing(["logistic","shop","packages.commodities.commodity","batch"]);
                /** @var OwnerPriceExpressService $service */
                $service = app("OwnerPriceExpressService");
                $logistic_fee = 0;
                $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){
                        $partAmount += $commodity->amount;
                    }
                    $amount += $partAmount;
                    $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;
                /** @var OwnerPriceOperationService $service */
                $service = app("OwnerPriceOperationService");
                $result = $service->matching($order,Feature::MAPPING["order"],$order->owner_id,"出库");

                $detail = $this->detail->update([
                    "owner_id"          => $order->owner_id,
                    "worked_at"         => $order->wms_edittime ?? $order->updated_at,
                    "shop_id"           => $order->shop_id,
                    "operation_bill"    => $order->code,
                    "consignee_name"    => $order->consignee_name,
                    "consignee_phone"   => $order->consignee_phone,
                    "commodity_amount"  => $amount,
                    "logistic_bill"     => rtrim($logistic_bill,","),
                    "volume"            => $volume,
                    "weight"            => $weight,
                    "logistic_id"       => $order->logistic_id,
                    "work_fee"          => is_array($result) ? ($result["money"]>0 ? $result["money"] : null) : null,
                    "owner_price_operation_id"  => is_array($result) ? $result["id"] : null,
                    "logistic_fee"      => $logistic_fee,
                ]);
                if ($detail){
                    OwnerFeeDetailLogistic::query()->where("owner_fee_detail_id",$detail->id)->delete();
                    foreach ($items as &$item)$item["owner_fee_detail_id"] = $detail->id;
                    if (count($items)>1)OwnerFeeDetailLogistic::query()->insert($items);
                    app("OrderService")->setOrderQuantity($order->owner_id,$order->logistic_id);
                }
                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);
                if (!$store || $store->status != "已入库") break;
                $store->loadMissing(["storeItems","warehouse"]);

                /** @var OwnerPriceOperationService $service */
                $service = app("OwnerPriceOperationService");
                $result = $service->matching($store, Feature::MAPPING["store"], $store->owner_id, "入库");
                $this->detail->update([
                    "owner_id" => $store->owner_id,
                    "worked_at" => $store->created_at,
                    "operation_bill" => $store->asn_code,
                    "commodity_amount" => array_sum(array_column($store->storeItems->toArray(), "amount")),
                    "work_fee" => is_array($result) ? ($result["money"]>0 ? $result["money"] : null) : null,
                    "owner_price_operation_id" => is_array($result) ? $result["id"] : null,
                ]);
                break;
        }
    }
}