baoshi-was/app/OrderIssue.php

<?php

namespace App;

use App\Traits\ModelTimeFormat;
use Illuminate\Support\Facades\Gate;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Database\Eloquent\Relations\BelongsToMany;
use Illuminate\Database\Eloquent\SoftDeletes;
use Illuminate\Database\Eloquent\Relations\BelongsTo;
use Illuminate\Database\Eloquent\Relations\HasMany;
use Illuminate\Database\Eloquent\Relations\HasOne;


use App\Traits\ModelLogChanging;

/**
 * @method Builder filter
 */

class OrderIssue extends Model
{
    use ModelLogChanging;

    //
    use ModelTimeFormat;
    use SoftDeletes;

    protected $fillable = [
        'order_id', 'created_at', 'rejected_bill_id','user_owner_group_id',
        'rejecting_status', 'result_explain','logistic_number_return',
        'situation_explain', 'order_issue_type_id', 'second_order_id',
        'is_new_rejecting','second_client_no','second_logistic_number',
        'final_status',
        'logistic_indemnity_money', 'logistic_express_remission',
        'baoshi_indemnity_money', 'baoshi_express_remission', 'user_workgroup_id',
        'custom_code','imported_status','finance_confirm',
        'hidden_tag','archive_at',
        'is_intercept'
    ];
    /*
     * second_client_no 二次客户订单号
     * second_logistic_number 二次运单号 【二次运单号可以单独存在，当二次客户订单号有对应的订单信息时，显示的是二次客户订单号对应的运单号，没有的话显示二次原单号】
     * rejecting_status
     * result_explain 情况说明
     * final_status
     * situation_explain
     * custom_code  自定义订单号 客户客服自定义
     * imported_status 导入处理
     * 退回单号
     * finance_confirm 财务确认
     * hidden_tag 隐藏标识
     * archive_at 归档时间
     * is_intercept 是否拦截
     */
    protected $appends = [];

    public function order(): BelongsTo
    {
        return $this->belongsTo(Order::class, 'order_id', 'id');
    }

    public function rejectedBills(): BelongsToMany
    {
        return $this->belongsToMany(RejectedBill::class,'order_issue_rejected_bill','order_issue_id','logistic_number_return','id','logistic_number_return');
    }

    public function orderIssueRejectedBills(): HasMany
    {
        return $this->hasMany(OrderIssueRejectedBill::class,'order_id','order_id');
    }

    public function issueType(): BelongsTo
    {
        return $this->belongsTo('App\OrderIssueType', 'order_issue_type_id', 'id');
    }

    public function logs(): HasMany
    {
        return $this->hasMany('App\OrderIssueProcessLog', 'order_issue_id', 'id');
    }

    public function top(): HasOne
    {
        return $this->hasOne('App\OrderIssueOnTop', 'order_issue_id', 'id');
    }

    public function userWorkGroup(): BelongsTo
    {
        return $this->belongsTo('App\UserWorkgroup', 'user_workgroup_id', 'id');
    }

    public function userOwnerGroup(): BelongsTo
    {
        return $this->belongsTo(UserOwnerGroup::class);
    }

    public function secondOrder(): HasOne
    {
        return $this->hasOne('App\Order', 'client_code', 'second_client_no');
    }

    public function orderDetail(): HasOne
    {
        return $this->hasOne(OrderDetail::class,'order_id','order_id');
    }

    public function getCreateLogAttribute()
    {
        return $this->logs->where('type', '创建')->first();
    }

    public function getEndLogAttribute()
    {
        return $this->logs->where('type', '结束')->last();
    }

    public function getProcessingTimeAttribute(): ?string
    {
        $createLogs = $this->getCreateLogAttribute();
        $endLogs = $this->getEndLogAttribute();
        if (($createLogs ?? false) && ($endLogs ?? false)) {
            $time = date_diff($createLogs->created_at, $endLogs->created_at);
            return $time->format('%a天, %h小时');
        }
        return null;
    }

    public function getCreateUserAttribute()
    {
        $createLog = $this->getCreateLogAttribute();
        return $createLog->user->name ?? '';
    }

    public function getEndUserAttribute()
    {
        $createLog = $this->getEndLogAttribute();
        return $createLog->user->name ?? '';
    }

//    /**
//     * 同步退货状态
//     */
//    public function syncRejectingStatus()
//    {
//        $this->syncRejectedBillStatus($this);
//    }

//    public function syncRejectedBillStatus($orderIssue)
//    {
//        if (!$orderIssue->order_id) return;
//        $orderIssueMap = [];
//        $rejectedMap = [];
//        $owner_id = $orderIssue->order->owner_id;
//
//        // 获取对应订单的所有商品
//        $orderPackageQuery = OrderPackage::query()->selectRaw("id")->where('order_id', $orderIssue->order_id);
//        $orderPackageCommodities = OrderPackageCommodities::query()->with('commodity')->whereIn('order_package_id', $orderPackageQuery)->get();
//        foreach ($orderPackageCommodities as $orderPackageCommodity) {
//            $code = $orderPackageCommodity->commodity->sku;
//            if (empty($orderIssueMap[$code])) $orderIssueMap[$code] = $orderPackageCommodity->amount;
//            else $orderIssueMap[$code] += $orderPackageCommodity->amount;
//        }
//
//        // 获取对应退回单的所有商品
//        $orderIssueRejectedBillQuery = OrderIssueRejectedBill::query()->selectRaw("logistic_number_return")->where("order_issue_id", $orderIssue->id);
//        $RejectedBills = RejectedBill::query()->with('items.quality')->whereIn("logistic_number_return", $orderIssueRejectedBillQuery)->get();
//        /** @var RejectedBill $rejectedBill */
//        foreach ($RejectedBills as $rejectedBill) {
//            foreach ($rejectedBill->items as $item) {
//                $code = $item->barcode_goods;
//                $exists = Commodity::query()->where("sku", $code)->where('owner_id',$owner_id)->exists();
//                if (!$exists) {
//                    $commodityBarcodeQuery = CommodityBarcode::query()->select('commodity_id')->where('code',$code);
//                    $commodity = Commodity::query()->where('owner_id',$owner_id)->whereIn('id',$commodityBarcodeQuery)->first();
//                    if ($commodity)$code = $commodity->sku;
//                }
//                $qualityName = $item->quality->name;
//                if (empty($rejectedMap[$code]) || empty($rejectedMap[$code][$qualityName])) $rejectedMap[$code][$qualityName] = $item->amount;
//                else $rejectedMap[$code][$qualityName] += $item->amount;
//            }
//        }
//        // 比较
//        $status = $this->getRejectingStatus($orderIssueMap, $rejectedMap);
//        $this->update(['rejecting_status' => $status]);
//        $this->syncWorkOrder();
//    }

//    private function getRejectingStatus($orderIssueMap, $rejectedMap): string
//    {
//        //未退回，差异退回，全部退回，超量退回，部分退回
//        if (count($rejectedMap) == 0) return "未退回";
//        $equal = 0;
//        $portion = 0;
//        foreach ($rejectedMap as $key => $map) {
//            if (isset($map['残次']) && $map['残次'] > 0) return "差异退回";
//            if (empty($orderIssueMap[$key])) return "差异退回";
//            if(isset($rejectedMap[$key]['正品']) && isset($orderIssueMap[$key])){
//                if ( $rejectedMap[$key]['正品'] < $orderIssueMap[$key]) $portion += 1;
//                if ( $rejectedMap[$key]['正品'] > $orderIssueMap[$key]) return "超量退回";                                 // 超量退回
//                if ( $rejectedMap[$key]['正品'] == $orderIssueMap[$key]) $equal += 1;
//            }
//        }
//        if ($equal == count($orderIssueMap) && $equal == count($rejectedMap)  && $portion == 0) return "全部退回";        // 全部退回
//        if ($portion > 0) return "部分退回";                                                                              // 部分退回
//        // 部分退回
//        if (count(array_diff_key($orderIssueMap,$rejectedMap)) > 0)return '部分退回';
//        if (count(array_diff_key($rejectedMap,$orderIssueMap)) > 0)return '差异退回';
//        return "无";
//    }

    public function delete()
    {
        $this->logs()->delete();
        $this->top()->delete();
        return parent::delete();
    }

    public function deleteSafe()
    {
        return parent::delete();
    }

//    /**
//     * 同步退货单号
//     */
//    public function syncRejectedBills()
//    {
//        $order_packages = $this->order->packages;
//        if($order_packages){
//            foreach ($order_packages as $order_package) {
//                $logistic_number = $order_package->logistic_number;
//                $rejectedBill = RejectedBill::query()->where('logistic_number_return',$logistic_number)->first();
//                if($rejectedBill){
//                    if(OrderIssueRejectedBill::isExit($this->id,$logistic_number))continue;
//                    $this->joinRejectedBill($logistic_number);
//                    if(isset($rejectedBill->items))
//                        $this->is_new_rejecting = '有';
//                }
//            }
//            $this->save();
//        }
//    }

//    public function syncRejected($logistic_number)
//    {
//        $query = RejectedBill::query()->selectRaw('id');
//        if(is_array($logistic_number)){
//            $query->whereIn('logistic_number_return',$logistic_number);
//        }elseif (is_string($logistic_number)){
//            $query->where('logistic_number_return',$logistic_number);
//        }else return;
//        $items = RejectedBillItem::query()->whereIn('id_rejected_bill',$query);
//        if($items->count() > 0) $this->update(['is_new_rejecting'=>'有']);
//        elseif($items->count() == 0) $this->update(['is_new_rejecting'=>'无']);
//    }


//    /**
//     * @param array|string $logistic_number
//     * @return array|void
//     */
//    public function joinRejectedBill($logistic_number)
//    {
//        if(!$logistic_number)return null;
//        $this->syncRejected($logistic_number);
//        if(is_array($logistic_number)){
//            return $this->rejectedBills()->sync($logistic_number,false);
//        }
//        return $this->rejectedBills()->attach($logistic_number);
//    }
//
//    public function unJoinRejectedBill($logistic_number)
//    {
//        return $this->rejectedBills()->detach($logistic_number);
//    }
//
//    public function reviseJoinRejectedBill($logistic_number,$logistic_number_update)
//    {
//        return $this->rejectedBills()->updateExistingPivot($logistic_number,['logistic_number_return'=>$logistic_number_update]);
//    }

    public function scopeFilter($query, $filters)
    {
        return $filters->apply($query);
    }

    public function scopeDefaultWith($query)
    {
        $this->scopeJsonWith($query);
        return $query->with(['top'])
            ->selectRaw('order_issues.* ,order_issue_on_tops.id top_id ,order_issue_on_tops.remark,order_issue_on_tops.updated_at top_update')
            ->leftJoin('order_issue_on_tops', 'order_issue_on_tops.order_issue_id', '=', 'order_issues.id')
            ->whereNull('order_issue_on_tops.deleted_at')
            ->orderBy('order_issue_on_tops.updated_at', 'desc')
            ->orderBy('order_issues.id', 'desc');
    }

    public function scopeJsonWith($query)
    {
        return $query->with(['issueType', 'logs' => function ($query){
            if (Gate::denies('订单管理-问题件-客户不可见')){
                $query->with('user')->orderByDesc('created_at');
            } else{
                $query->with('user')->where('tag','=',0)->orderByDesc('created_at');
            }
        },'order'=>function($query){
            $query->with(['shop', 'logistic', 'owner', 'packages.commodities.commodity.barcodes']);
        },'secondOrder'=>function($query){
            $query->with(['shop', 'logistic', 'owner', 'packages.commodities.commodity.barcodes']);
        },'orderIssueRejectedBills.rejectedBill'=>function($query){
            $query->with(['owner','logistic','user','items.quality']);
        },'userWorkgroups','userOwnerGroup','orderDetail']);

    }

    public function userWorkgroups(): BelongsToMany
    {
        return $this->belongsToMany(UserWorkgroup::class);
    }

    // 库内拦截
    public function intercept(): bool
    {
        return $this->update(['is_intercept' => 1]);
    }
    public function syncWorkOrder(){
        $workOrder = WorkOrder::query()->where('order_id',$this->order_id)->orderByDesc('created_at')->first();
        if  (!$workOrder) return ;
        $workOrder->update(['rejecting_status' => $this->rejecting_status]);
        if ($this->rejecting_status !== '全部退回') return;
        /** @var WorkOrder $workOrder */
        $workOrder = WorkOrder::query()->whereHas('issueType',function($query){
            $query->where('name','拦截');
        })->where('order_id',$this->order_id)->orderByDesc('created_at')->first();
        if (!$workOrder) return ;
        $workOrder->syncIntercept();

    }
}