baoshi-was/app/Services/RejectedBillService.php

<?php

namespace App\Services;

use App\OracleDOCOrderHeader;
use App\OrderIssue;
use App\RejectedBill;
use App\Services\common\BatchUpdateService;
use App\Services\common\DataHandlerService;
use Carbon\Carbon;

Class RejectedBillService
{
    private function conditionQuery(array $params){
        $query = RejectedBill::query();
        if ($params['order_number'] ?? false){
            $query->whereIn('order_number',$params['order_number']);
        }
        return $query;
    }

    public function get(array $params){
        return $this->conditionQuery($params)->get();
    }

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

    /**
     * @param RejectedBill $rejectedBill
     */
    public function syncOrderIssue($rejectedBill)
    {
        $orderIssue = $rejectedBill->orderIssue()->first();
        if(!$orderIssue && $rejectedBill['logistic_number'] === '原单退回'){   // 原单退回
            $orderIssue = OrderIssue::query()->with('order')->whereHas('order',function($query)use($rejectedBill){
                $query->where('client_code',$rejectedBill['order_number']);
            })->first();
        }
        if(!isset($orderIssue)){ // 没有对应的问题发货订单
            $orderHeader = OracleDOCOrderHeader::query()->where('soreference1',function($query)use($rejectedBill){
                $query->select('asnreference2')->from('DOC_ASN_HEADER')->where('asnreference3',$rejectedBill->logistic_number_return)->first();
            })->first();
//                $orderHeader = OracleDOCOrderHeader::query()->where('soreference1',function($query)use($rejectedBill){
//                    $query->select('asnreference2')->from('DOC_ASN_HEADER')->where('asnreference3',$rejectedBill->logistic_number_return)->first();
//                })->first();
            if(!isset($orderHeader))return;
            $orderIssue = OrderIssue::query()->with('order')->whereHas('order',function($query)use($orderHeader){
                $query->where('code',$orderHeader->orderno);
            })->first();
        }
        if(isset($orderIssue)){
            // 更新问题件的退回单号
            if($orderIssue['logistic_number_return']!=$rejectedBill['logistic_number_return'])
                $orderIssue->update(['logistic_number_return'=>$rejectedBill['logistic_number_return']]);
            //确认问题件有的时候需要更新状态和提示
            /**
             * @var OrderIssue $orderIssue
             */
            $orderIssue->同步退单状态();
            $orderIssue->update(['is_new_rejecting' => '有']);
            app('LogService')->log(__METHOD__,__FUNCTION__,'退回单同步问题件'.json_encode($rejectedBill).json_encode($orderIssue));
        }
    }

    public function syncLoadedStatusByAsnHerder($asnHerders){
        if ($asnHerders->isEmpty())return null;
        $updateCollect=$this->getUpdateCollect($asnHerders);
        if ($updateCollect->isEmpty())return null;
        $logisticNumberReturn=$this->getLogisticNumberReturn($updateCollect);
        $rejectedBills=$this->getRejectedBills($logisticNumberReturn);
        $updateParams = [[
            'logistic_number_return','is_loaded','updated_at'
        ]];
        $updated_at=Carbon::now()->toDateTimeString();
        /** @var DataHandlerService $dataHandlerService */
        $dataHandlerService =  app(DataHandlerService::class);
        $rejectedBills_map =  $dataHandlerService->dataHeader(['logistic_number_return'],$rejectedBills);
        foreach ($updateCollect as $data){
            if(!$data->asnreference3&&!$data->notes){continue;}
            $result=[];
            if ($data->asnreference3){
                $rejectedBill=$dataHandlerService->getKeyValue(['logistic_number_return'=>$data->asnreference3],$rejectedBills_map);
                if ($rejectedBill&&$rejectedBill->is_loaded!=1) $updateParams[] = [
                    'logistic_number_return'=>$data->asnreference3,
                    'is_loaded' => 1,
                    'updated_at' =>$updated_at,
                ];
            }else{
                preg_match("/[a-zA-Z]{0,5}\d{6,20}/",$data->notes, $result);
                $rejectedBill=$dataHandlerService->getKeyValue(['logistic_number_return'=>$result[0]],$rejectedBills_map);
                if ($rejectedBill&&$rejectedBill->is_loaded!=1) $updateParams[] = [
                    'logistic_number_return'=>$result[0],
                    'is_loaded' => 1,
                    'updated_at' =>$updated_at,
                ];
                unset($result);
            }
        }
        if(count($updateParams) > 1){
            $this->batchUpdate($updateParams);
        }
    }
    public function getUpdateCollect($asnHerders){
        $updateCollect=collect();
        foreach ($asnHerders as $asnHerder){
            if (($asnHerder->asnType->codename_c=='退货入库'
                    || $asnHerder->asnType->codename_c=='其他入库')
                &&$asnHerder->asnStatus->codename_c=='完全收货'){
                $updateCollect->add($asnHerder);
            }
        }
        return $updateCollect;
    }
    public function getLogisticNumberReturn($updateCollect){
        $logisticNumberReturn=[];
        foreach ($updateCollect as $data){
            if(!$data->asnreference3&&!$data->notes){continue;}
            $result=[];
            if ($data->asnreference3){
                array_push($logisticNumberReturn,$data->asnreference3);
            }else{
                preg_match("/[a-zA-Z]{0,5}\d{6,20}/",$data->notes, $result);
                array_push($logisticNumberReturn,$result[0]);
                $result=[];
            }
        }
        return $logisticNumberReturn;
    }

    public function batchUpdate($params){
        return app(BatchUpdateService::class)->batchUpdate('rejected_bills',$params);
    }
    public function getRejectedBills(array $logisticNumberReturn){
        if(count($logisticNumberReturn)<1){return null;}
        return RejectedBill::query()->whereIn('logistic_number_return',$logisticNumberReturn)->get();
    }
}