baoshi-was/app/Services/StoreService.php

<?php

namespace App\Services;

use App\Feature;
use App\Jobs\RejectedPushJob;
use App\Jobs\StoreCreateInstantBill;
use App\Order;
use App\OwnerFeeDetail;
use App\OwnerFeeOperation;
use App\OwnerFeeOperationDetail;
use App\Services\common\BatchUpdateService;
use App\Services\common\DataHandlerService;
use App\Services\common\QueryService;
use App\Store;
use App\StoreRejected;
use App\ValueStore;
use App\Warehouse;
use Carbon\Carbon;
use Illuminate\Support\Facades\Cache;

use App\Traits\ServiceAppAop;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;


class StoreService
{
    use ServiceAppAop;
    protected $modelClass=Store::class;
    private function conditionQuery(array $params)
    {
        $stores = Store::query()->with(['storeItems.store', 'warehouse', 'owner'])->where('is_fast_stored', '无')->orderBy('id', 'DESC');
        $columnQueryRules = [
            'asn_code' => ['batch' => ''],
            'remark' => ['batch' => '','timeLimit' => 15],
            'created_at_start' => ['alias' => 'created_at', 'startDate' => ' 00:00:00'],
            'created_at_end' => ['alias' => 'created_at', 'endDate' => ' 23:59:59'],
            'owner' => ['alias' => 'owner_id','multi' => ','],
            'warehouse' => ['alias' => 'warehouse_id','multi' => ','],
            'status' => ['multi' => ','],
            'stored_method' => ['multi' => ','],
            'id' => ['multi' => ',']
        ];
        $stores = app(QueryService::class)->query($params, $stores, $columnQueryRules, 'stores');
        return $stores;
    }

    public function paginate(array $params)
    {
        return $this->conditionQuery($params)->paginate($params['paginate'] ?? 50);
    }

    public function create(array $params)
    {
        return Store::query()->create($params);
    }

    public function storeCreateByWms()
    {
        $created_at = config('sync.asn_sync.created_at');
        $create_set = config('sync.asn_sync.cache_prefix.create_set');
        $create_keys = config('sync.asn_sync.cache_prefix.create_keys');
        $create_key = config('sync.asn_sync.cache_prefix.create');

        /** @var OracleDocAsnHerderService $oracleDocAsnHerderService */
        $oracleDocAsnHerderService = app(OracleDocAsnHerderService::class);
        $last_time = $this->getAsnLastSyncAt($created_at, 'create');
        $asnHerders = $oracleDocAsnHerderService->getWmsAsnOnStartDateCreate($last_time);
        try {
            RejectedPushJob::dispatch($asnHerders);
        } catch (\Exception $e) {
            Log::error("退货推送asn集合失败",[$e->getMessage()]);
        }
        if (count($asnHerders)<1) return;
        $last_time = $asnHerders->first()['addtime'];
        $last_records = $asnHerders->where('addtime', $last_time);
        $this->createStore($asnHerders);
        $this->createStoreRejected($asnHerders);
        $this->deleteCacheKey($create_set, $create_keys);
        $this->setLastRecordsByRedis($create_key, $create_set, $create_keys, $last_records);
        $this->setAsnLastSyncAt($created_at, $last_time);
    }

    public function storeUpdateByWms()
    {
        $updated_at = config('sync.asn_sync.updated_at');
        $update_set = config('sync.asn_sync.cache_prefix.update_set');
        $update_keys = config('sync.asn_sync.cache_prefix.update_keys');
        $update_key = config('sync.asn_sync.cache_prefix.update');

        /** @var OracleDocAsnHerderService $oracleDocAsnHerderService */
        $oracleDocAsnHerderService = app(OracleDocAsnHerderService::class);
        $last_time = $this->getAsnLastSyncAt($updated_at, 'update');
        app('LogService')
            ->log(__METHOD__, __FUNCTION__, '11 获取上次更新时间：' . $last_time );
        $asnHerders = $oracleDocAsnHerderService->getWmsAsnOnStartDateEdit($last_time);
        try {
            RejectedPushJob::dispatch($asnHerders);
        } catch (\Exception $e) {
            Log::error("退货推送asn集合失败",[$e->getMessage()]);
        }
        if (count($asnHerders)<1) return;
        $last_time = $asnHerders->first()['edittime'];
        $last_records = $asnHerders->where('edittime', $last_time);
        $this->createStore($asnHerders,"update");
        $this->updateStore($asnHerders);
        $this->createStoreRejected($asnHerders);
        $this->deleteCacheKey($update_set, $update_keys);
        $this->setLastRecordsByRedis($update_key, $update_set, $update_keys, $last_records);
        $this->setAsnLastSyncAt($updated_at, $last_time);

    }

    public function createStore($asnHerders,$isUpdate=null)
    {
        if (!$asnHerders) return null;
        /** @var OwnerService $ownerService */
        $ownerService = app(OwnerService::class);
        $owner_codes = [];
        $warehouse_codes = [];
        foreach ($asnHerders as $asnHerder) {
            if (!empty($asnHerder['customerid']))
                $owner_codes[$asnHerder['customerid']] = $asnHerder['customerid'];
            if (!empty($asnHerder['warehouseid']))
                $warehouse_codes[$asnHerder['warehouseid']] = $asnHerder['warehouseid'];
        }
        $owners = $ownerService->getOwnerByCodes($owner_codes);
        $warehouses = Warehouse::query()->get();
        $owners_code_map=[];
        foreach ($owners as $owner) {
            $owners_code_map[$owner->code] = $owner;
        }
        $warehouses_code_map=[];
        foreach ($warehouses as $warehouse) {
            $warehouses_code_map[$warehouse->code] = $warehouse;
        }
        $params = $this->getParamsByAsnHeader($asnHerders, $owners_code_map, $warehouses_code_map);
        if (count($params) > 0) $this->insertStore($params);
        /** @var StoreItemService $storeItemService */
        $storeItemService = app(StoreItemService::class);
        $storeItemService->storeItemCreateByWms($asnHerders);
        /** @var RejectedBillService $rejectedBillService */
        $rejectedBillService = app(RejectedBillService::class);
        $rejectedBillService->syncLoadedStatusByAsnHerder($asnHerders);
        if (!$isUpdate)$this->pushJob($asnHerders);
        if (!$isUpdate) unset($asnHerders);
        unset($owners_code_map, $warehouses_code_map);
    }

    public function getParamsByAsnHeader($asnHerders, $owners_code_map, $warehouses_code_map)
    {
        $params = [];
        $stores = Store::query()->whereIn('asn_code', data_get($asnHerders, '*.asnno'))->get();
        $store_asn_code_map = [];
        foreach ($stores as $store) {
            $store_asn_code_map[$store->asn_code] = $store;
        }
        foreach ($asnHerders as $asnHerder) {
            if ($store_asn_code_map[$asnHerder->asnno] ?? false) continue;
            $owner = $owners_code_map[$asnHerder->customerid] ?? null;
            $warehouse = $warehouses_code_map[$asnHerder->warehouseid] ?? null;
            $status = null;
            if ($asnHerder->asnStatus && $asnHerder->asnStatus->codename_c == '完全收货') $status = '已入库';
            if ($asnHerder->asnStatus && $asnHerder->asnStatus->codename_c == '订单创建') $status = '未入库';
            $params[] = [
                'asn_code' => $asnHerder->asnno,
                'warehouse_id' => $warehouse->id ?? null,
                'owner_id' => $owner->id ?? null,
                'stored_method' => $asnHerder->asnType ? $asnHerder->asnType->codename_c : '',
                'status' => $status ? $status : $asnHerder->asnStatus->codename_c,
                'remark' => $asnHerder->notes ?? null,
                'created_at' => $asnHerder->addtime ?? null,
                'updated_at' => $asnHerder->edittime ?? null,
            ];
        }
        return $params;
    }

    public function insertStore(array $params)
    {
        if (count($params) === 0) return;
        foreach (array_chunk($params, 1000) as $item) {
            try {
                $bool = $this->insert($item);
                if ($bool) {
                    app('LogService')->log(__METHOD__, __FUNCTION__, "批量创建 store success " . count($item) . ' || ' . json_encode($item));
                } else app('LogService')->log(__METHOD__, __FUNCTION__, "批量添加 store FAILED " . ' || ' . json_encode($item));
            } catch (\Exception $e) {
                app('LogService')->log(__METHOD__, __FUNCTION__, "批量添加 store ERROR " . ' || ' . json_encode($params) . ' || ' . json_encode($e->getMessage()) . ' || ' . json_encode($e->getTraceAsString()));
            }
        }
    }

    public function updateStore($asnHerders)
    {
        if (!$asnHerders || $asnHerders->count() == 0) return null;
        /**
         * @var DataHandlerService $dataHandlerService
         * @var OwnerService $ownerService
         */
        $ownerService = app(OwnerService::class);
        $dataHandlerService = app(DataHandlerService::class);
        $stores = $this->getByWms($asnHerders);
        $store_asn_code_map = $dataHandlerService->dataHeader(['asn_code'], $stores);
        $owners = $ownerService->getOwnerByCodes(array_unique(data_get($asnHerders,'*.customerid')));
        $warehouses = Warehouse::query()->get();
        $owner_code_map = $dataHandlerService->dataHeader(['code'], $owners);
        $warehouses_map = $dataHandlerService->dataHeader(['code'], $warehouses);
        $updateParams = [[
            'id', 'asn_code', 'warehouse_id', 'owner_id', 'stored_method', 'status', 'remark', 'updated_at'
        ]];
        foreach ($asnHerders as $asnHerder) {
            $store = $dataHandlerService->getKeyValue(['asn_code' => $asnHerder->asnno], $store_asn_code_map);
            if (!$store) continue;
            $owner = $dataHandlerService->getKeyValue(['code' => $asnHerder->customerid], $owner_code_map);
            $warehouse = $dataHandlerService->getKeyValue(['code' => $asnHerder->warehouseid], $warehouses_map);
            $owner_id = $owner->id ?? null;
            $warehouse_id = $warehouse->id ?? null;
            $status = null;
            if ($asnHerder->asnStatus && $asnHerder->asnStatus->codename_c == '完全收货') $status = '已入库';
            if ($asnHerder->asnStatus && $asnHerder->asnStatus->codename_c == '订单创建') $status = '未入库';
            if ($store->asn_code != $asnHerder->asnno ||
                $store->warehouse_id != $warehouse_id ||
                $store->owner_id != $owner_id ||
                $store->stored_method != ($asnHerder->asnType->codename_c ??'')||
                $store->status != ($asnHerder->asnStatus->codename_c ?? '')||
                $store->remark != $asnHerder->notes ||
                $store->updated_at != $asnHerder->edittime) {
                $updateParams[] = [
                    'id' => $store->id,
                    'asn_code' => $asnHerder->asnno,
                    'warehouse_id' => $warehouse_id,
                    'owner_id' => $owner_id,
                    'stored_method' => $asnHerder->asnType ? $asnHerder->asnType->codename_c : '',
                    'status' => $status ? $status : $asnHerder->asnStatus->codename_c,
                    'remark' => $asnHerder->notes,
                    'updated_at' => $asnHerder->edittime,
                ];
            }
        }
        if (count($updateParams) > 1) {$this->batchUpdate($updateParams);}
        /** @var StoreItemService $storeItemService */
        $storeItemService = app(StoreItemService::class);
        $storeItemService->storeItemUpdateByWms($asnHerders);
        /** @var RejectedBillService $rejectedBillService */
        $rejectedBillService = app(RejectedBillService::class);
        $rejectedBillService->syncLoadedStatusByAsnHerder($asnHerders);
        $this->pushJob($asnHerders);
        unset($updateParams, $asnHerders);
    }

    public function pushJob($asnHerders){
        dispatch(new StoreCreateInstantBill(Store::query()->with(["storeItems"])->where('status','已入库')->whereIn('asn_code', data_get($asnHerders,'*.asnno'))->get()));
    }

    public function insert($params)
    {
        return Store::query()->insert($params);
    }

    public function batchUpdate($params)
    {
        return app(BatchUpdateService::class)->batchUpdate('stores', $params);
    }

    public function getByWms($asnHerders)
    {
        if (!$asnHerders) {
            return null;
        }
        $asn_nos = array_unique(data_get($asnHerders, '*.asnno'));
        return Store::query()->whereIn('asn_code', $asn_nos)->get();
    }

    public function getAsnLastSyncAt($key, $type)
    {
        $last_time = ValueStore::query()->where('name', $key)->value('value');
        if ($last_time) return $last_time;
        if ($type == 'create') {
            $store = Store::query()->orderByDesc('created_at')->first();
            if ($store) return $store->created_at;
        } else {
            $store = Store::query()->orderByDesc('updated_at')->first();
            if ($store) return $store->updated_at;
        }
        return Carbon::now()->subSeconds(65);
    }

    public function setAsnLastSyncAt($key, $last_time)
    {
        $asnLastSyncAt = ValueStore::query()->updateOrCreate([
            'name' => $key,
        ], [
            'name' => $key,
            'value' => $last_time,
        ]);
        return $asnLastSyncAt;
    }

    public function deleteCacheKey($set, $keys)
    {
        if (Cache::get($set)) {
            $cacheKeys = Cache::get($keys);
            if (!$cacheKeys) return;
            foreach ($cacheKeys as $cacheKey) {
                Cache::forget($cacheKey);
            }
            Cache::forget($keys);
        }
    }

    public function setLastRecordsByRedis($prefixKey, $set, $keys, $last_records)
    {
        $cacheKeys = [];
        foreach ($last_records as $last_record) {
            Cache::put($prefixKey . $last_record->customerid . '_' . $last_record->asnno, true);
            array_push($cacheKeys, $prefixKey . $last_record->customerid . '_' . $last_record->asnno);
        }
        Cache::put($keys, $cacheKeys);
        Cache::put($set, true);
    }

    public function createInstantBill(Store $store): bool
    {
        /** @var \stdClass $store */
        if (!$store || $store->status != "已入库") return false;
        if (Cache::has("owner_fee_details:stores_".$store->id))return true;
        $store->loadMissing(["storeItems.commodity","warehouse"]);
        /** @var OwnerPriceOperationService $service */
        $service = app("OwnerPriceOperationService");

        $workedAt = $store->updated_at;
        $month = substr($workedAt,0,7);

        $GLOBALS["FEE_INFO"] = [];
        list($id,$money,$taxFee) = $service->matching($month, $store, Feature::MAPPING["store"], $store->owner_id, "入库");

        $amount = 0;
        if ($store->storeItems)foreach ($store->storeItems as $item)$amount += $item->amount;
        if (!app("OwnerFeeDetailService")->create([
            "owner_id" => $store->owner_id,
            "worked_at" => $workedAt,
            "type" => "收货",
            "operation_bill" => $store->asn_code,
            "commodity_amount" => $amount,
            "work_fee" => $money,
            "owner_price_operation_id" => $id,
            "created_at" => date('Y-m-d H:i:s'),
            "outer_id" => $store->id,
            "outer_table_name" => "stores",
            "work_tax_fee" => $taxFee,
        ])) return false;
        $this->setStoreAmount($store->owner_id,$amount,$month);
        if ($money>0)$this->constructFeeInfo([
            "worked_at" => $workedAt,
            "owner_id" => $store->owner_id,
            "model_id"  => $id,
            "source_number"=> null,
            "doc_number"   => $store->asn_code,
            "commodity_id" => 0,
            "total_fee"    =>0,
            "tax_rate"     =>0,
            "fee_description"=>'',
        ]);
        Cache::put("owner_fee_details:stores_".$store->id,1,86400);
        return true;
    }

    /**
     * 构建费用信息
     *
     * @param array $defaultInfo
     *
     * @return void
     */
    public function constructFeeInfo(array $defaultInfo)
    {
        foreach ($GLOBALS["FEE_INFO"] as $info){
            $operation = $defaultInfo;
            foreach ($operation as $key=>$val)if (isset($info[$key]))$operation[$key] = $info[$key];
            $model = OwnerFeeOperation::query()->create($operation);
            if($info['details'])foreach ($info['details'] as &$detail)$detail["owner_fee_operation_id"] = $model->id;
            OwnerFeeOperationDetail::query()->insert($info['details']);
        }
    }
    /**
     * 清除费用信息
     *
     * @param string $docNumber
     */
    public function clearFeeInfo(string $docNumber)
    {
        try {
            $models = OwnerFeeOperation::query()->where("doc_number",$docNumber)->get();
            if ($models->count()==0)return;
            OwnerFeeOperationDetail::query()->whereIn("owner_fee_operation_id",array_column($models->toArray(),"id"))->delete();
            OwnerFeeOperation::query()->where("doc_number",$docNumber)->delete();
        }catch (\Exception $e){
            Log::warning("清除费用信息发送错误",["ASN号：{$docNumber}",isset($models) ? $models->toJson() : "查费用信息时被锁定",$e->getMessage()]);
        }
    }

    /**
     * @param $asnHerders
     * @return null
     */
    public function createStoreRejected($asnHerders){
        if (!$asnHerders) return null;
        $stores = $this->getByWms($asnHerders);
        $orders = Order::query()->whereIn('client_code', data_get($asnHerders, '*.asnreference2'))->get();
        $store_rejecteds=StoreRejected::query()->whereIn('order_id',data_get($orders,'*.id'))->whereIn('store_id',data_get($stores,'*.id'))->get();
        /** @var DataHandlerService $dataHandlerService */
        $dataHandlerService = app(DataHandlerService::class);
        $order_map = $dataHandlerService->dataHeader(['client_code'], $orders);
        $store_map = $dataHandlerService->dataHeader(['asn_code'], $stores);
        $store_rejected_map=$dataHandlerService->dataHeader(['store_id','order_id','logistic_number_return'],$store_rejecteds);
        $insert_param=[];
        foreach ($asnHerders as $asnHerder){
            if (!$asnHerder->asnreference2) continue;
            $order=$dataHandlerService->getKeyValue(['client_code'=>$asnHerder->asnreference2],$order_map);
            $store=$dataHandlerService->getKeyValue(['asn_code'=>$asnHerder->asnno],$store_map);
            if (!$order || !$store)continue;
            $store_rejected=$dataHandlerService->getKeyValue(['store_id'=>$store->id,'order_id'=>$order->id,'logistic_number_return'=>$asnHerder->asnreference3],$store_rejected_map);
            if ($store_rejected) continue;
            $insert_param[]=[
                'store_id'=>$store->id,
                'order_id'=>$order->id,
                'logistic_number_return'=>$asnHerder->asnreference3 ?? '',
                'created_at'=>Carbon::now()->toDateTimeString(),
            ];
        }
        if (count($insert_param)>0) StoreRejected::query()->insert($insert_param);
        app('LogService')
            ->log(__METHOD__, __FUNCTION__, '11 createStoreRejected：'.json_encode($insert_param));
    }

    /**
     * 入库件数丢失补偿逻辑
     *
     * @param int $owner
     * @param string $month
     */
    private function storeAmountCompensationLogic(int $owner, string $month)
    {
        $query = DB::raw(<<<sql
SELECT sum(amount) total FROM `store_items` LEFT JOIN stores ON store_items.store_id=stores.id WHERE stores.owner_id = ? AND (stores.status='已入库' OR stores.status='ASN关闭') AND store_items.updated_at LIKE ?
sql
        );
        $statistics = DB::selectOne($query,[$owner,date("Y-m")."%"]);
        Cache::put($month."|A|".$owner,$statistics->total ?: 0,2764800);
    }

    /**
     * 设置货主下的本月入库件数
     *
     * @param int $owner
     * @param int $amount
     * @param string $month
     */
    public function setStoreAmount(int $owner, int $amount, string $month)
    {
        $date = date("Y-m");
        if (!Cache::has($date."|A|".$owner))$this->storeAmountCompensationLogic($owner,$month);//补偿逻辑
        Cache::increment($date."|A|".$owner,$amount);
    }

    /**
     * 获取货主下的本月入库件数
     *
     * @param int $owner
     * @param string $date
     *
     * @return int
     */
    public function getStoreAmount(int $owner, string $date):int
    {
        if (!Cache::has($date."|A|".$owner))$this->storeAmountCompensationLogic($owner,$date);
        return Cache::get($date."|A|".$owner);
    }
}