<?php

namespace App\Services;

use App\Process;
use App\Services\common\QueryService;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Support\Facades\DB;
use App\Traits\ServiceAppAop;


class ProcessService
{
    use ServiceAppAop;
    protected $modelClass=Process::class;
    /**
     * @param array $params
     * @return Builder
     */
    private function conditionQuery(array $params){
        $processes=Process::filterAuthorities()->with(['owner','processMethod','tutorials.owner','signs','operatorLogs.user',
            'signUnitPrice','processesContents'=>function($query){
            return $query->with(['signCommodityName','signCommoditySku','signCommodityBarcode','commodity'=>function($query){
                return $query->with('barcodes');
            }]);
        }])->orderBy('processes.id','DESC');
        if ($params['commodity_barcode'] ?? false){
            $barcode=$params['commodity_barcode'];
            $processes=$processes->whereHas('processesContents',function ($query)use($barcode){
                $query->whereHas('commodity',function ($builder)use($barcode){
                    $builder->whereHas('barcodes',function ($builder)use($barcode){
                        if (strpos($barcode, ',') || strpos($barcode, '，') || strpos($barcode, ' ')) {
                            $arr = array_filter(preg_split('/[,， ]+/is', $barcode));
                            $builder->whereIn('code',$arr);
                        } else {
                            $builder->where('code','like',$barcode);
                        }
                    });
                });
            });
            unset($params['commodity_barcode']);
        }
        if ($params['wms_code'] ?? false){
            $wms_code=$params['wms_code'];
            $processes=$processes->whereHas('processesContents',function ($builder)use ($wms_code){
                if (strpos($wms_code, ',') || strpos($wms_code, '，') || strpos($wms_code, ' ')) {
                    $arr = array_filter(preg_split('/[,， ]+/is', $wms_code));
                    $builder->whereIn('wms_code',$arr);
                } else {
                    $builder->where('wms_code','like',$wms_code);
                }
            });
            unset($params['wms_code']);
        }
        if (!($params['is_accomplish'] ?? false)){
            $processes=$processes->where('status','!=','交接完成');
        }else unset($params['is_accomplish']);
        if ($params["designate"] ?? false) {
            $designate = $params["designate"];
            $processes=$processes->whereHas('designate', function ($builder)use($designate) {
                $builder->where('name','like','%'.$designate.'%');
            });
            unset($params['designate']);
        }
        $columnQueryRules=[
            'date_start' => ['alias' => 'created_at' , 'startDate' => ' 00:00:00'],
            'date_end' => ['alias' => 'created_at' , 'endDate' => ' 23:59:59'],
            'code' => ['batch' => ''],
            'owners' => ['alias' => 'owner_id' ,'multi' => ','],
            'id' => ['multi' => ','],
        ];
        return app(QueryService::class)->query($params,$processes,$columnQueryRules,"processes");
    }

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

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

    public function getSql(array $params){
        return $this->conditionQuery($params)->whereNull('processes.deleted_at')
                ->selectRaw('processes.code,processes.amount,processes.completed_amount,processes.status,processes.remark,processes.unit_price,processes.created_at')
            ->leftJoin('owners','processes.owner_id','owners.id')
                ->selectRaw('owners.name owner_name')
            ->leftJoin('process_methods','processes.process_method_id','process_methods.id')
                ->selectRaw('process_methods.name process_method_name')
            ->leftJoin('processes_contents','processes.id','processes_contents.process_id')
                ->selectRaw('processes_contents.bill_type content_bill_type,processes_contents.wms_code content_wms_code,processes_contents.amount content_amount')
            ->leftJoin('commodities','processes_contents.commodity_id','commodities.id')
                ->selectRaw('commodities.name commodity_name,commodities.sku commodity_sku')
            ->leftJoin('commodity_barcodes','commodities.id','commodity_barcodes.commodity_id')
                ->selectRaw(DB::raw("GROUP_CONCAT(commodity_barcodes.code) commodity_barcode_code"))
                ->groupBy("processes_contents.id","processes_contents.commodity_id")
            ->leftJoin('signs as sign_commodity_sku',function ($join){
                $join->on('sign_commodity_sku.signable_type',DB::raw("'processes_contents'"))
                    ->on('sign_commodity_sku.signable_id','processes_contents.id')
                    ->on('sign_commodity_sku.field',DB::raw("'commodity_sku'"));
            })
                ->selectRaw('sign_commodity_sku.mark sign_commodity_sku_mark')
            ->leftJoin('signs as sign_commodity_name',function ($join){
                $join->on('sign_commodity_name.signable_type',DB::raw("'processes_contents'"))
                    ->on('sign_commodity_name.signable_id','processes_contents.id')
                    ->on('sign_commodity_name.field',DB::raw("'commodity_name'"));
            })
                ->selectRaw('sign_commodity_name.mark sign_commodity_name_mark')
            ->leftJoin('signs as sign_commodity_barcode',function ($join){
                $join->on('sign_commodity_barcode.signable_type',DB::raw("'processes_contents'"))
                    ->on('sign_commodity_barcode.signable_id','processes_contents.id')
                    ->on('sign_commodity_barcode.field',DB::raw("'commodity_barcode'"));
            })
                ->selectRaw('sign_commodity_barcode.mark sign_commodity_barcode_mark')
            ->sql();
    }

    public function createInstantBill(Process $process)
    {
        /** @var \stdClass $process */
        if (!$process || $process->status!="交接完成")return false;
        if (!$process->processStatistic)$process->load("processStatistic");

        if (app("OwnerFeeDetailService")->create([
            "owner_id"          => $process->owner_id,
            "worked_at"         => $process->processStatistic ? $process->processStatistic->ended_at : '',
            "type"              => "增值服务",
            "operation_bill"    => $process->code,
            "commodity_amount"  => $process->completed_amount,
            "process_method_id" => $process->process_method_id,
            "work_fee"          => $process->processStatistic ? $process->processStatistic->revenue : null,
            "created_at"        => date('Y-m-d H:i:s'),
            "outer_id"          => $process->id,
            "outer_table_name"  => "processes",
        ]))return true;
        return false;
    }
}