baoshi-was/app/Services/OrderIssueService.php

<?php

namespace App\Services;

use App\OracleDOCASNDetail;
use App\OracleDOCASNHeader;
use App\OracleDOCOrderDetail;
use App\OracleDOCOrderHeader;
use App\OrderIssue;
use App\OrderPackage;
use App\Order;
use App\RejectedBill;
use App\Sign;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\Validator;

class OrderIssueService
{

    public function __construct()
    {
        app()->bind("orderService", OrderService::class);
        app()->bind("rejectedService", RejectedService::class);
    }


    public function getQuery(Request $request, array $condition = null)
    {
        if (!isset($condition)) {
            $condition = $request->all();
        }
        $user = Auth::user();
        $owner_ids = $user ? $user->getPermittingOwnerIdsAttribute() : [];

        $orders = Order::select('id')->whereIn('owner_id', $owner_ids)->get();
        $order_ids = [];
        foreach ($orders as $order) {
            $order_ids[] = $order->id;
        }

        $query = OrderIssue::with(['top', 'logs' => function ($query) {
            return $query->orderBy('created_at');
        }, 'order' => function ($query) use ($order_ids) {
            return $query->whereIn('id', $order_ids)->with(['shop', 'logistic', 'owner', 'packages' => function ($query) {
                return $query->with(['commodities' => function ($query) {
                    return $query->with('commodity');
                }]);
            }]);
        }])->whereIn('order_id', $order_ids);


        return $query;
    }

    public function getConditionQuery(Request $request, array $condition = null)
    {
        $query = $this->getQuery($request, $condition);
        if (!isset($condition)) {
            $condition = $request->all();
        }
        if (isset($condition['created_at_start'])) {
            $query->where('created_at', '>=', $condition['created_at_start'] . " 00:00:00");
        }
        if (isset($condition['created_at_end'])) {
            $query->where('created_at', '<=', $condition['created_at_end'] . " 23:59:59");
        }
        if (isset($condition['final_status'])) {
            $query->where('final_status', $condition['final_status']);
        }
        if (isset($condition['handle_status'])) {
            $query->where('handle_status', intval($condition['handle_status']));
        }
        if (isset($condition['logistic_indemnity_money'])) {
            $query->where('logistic_indemnity_money', $condition['logistic_indemnity_money']);
        }
        if (isset($condition['baoshi_express_remission'])) {
            $query->where('baoshi_express_remission', $condition['baoshi_express_remission']);
        }
        if(isset($condition['order_issue_ids'])){
            $orderIssuesId = $condition['order_issue_ids'];
            if(is_string($orderIssuesId)){
                $orderIssuesId = explode(',',$orderIssuesId);
            }
            $query->whereIn('id',$orderIssuesId);
        }
        return $query;
    }

    public function paginate(Request $request)
    {
        return $this->getConditionQuery($request)->paginate($request->input('paginate', 50));
    }

    // 置顶
    public function orderIssueOnTop(Request $request)
    {
        $mes = ['success' => false];
        $id = $request->input('id');
        $remark = $request->input('remark');
        if (!$request->input('id') || !$request->input('remark')) {
            $mes['fail_info'] = '没有输入对应的备注';
            $mes['fail_info'] = $request->input('id') ? $mes['fail_info'] : '没有选中问题件';
            return $mes;
        }
        OrderIssue::updateOrCreate(['orderIssue_id' => $id], ['remark' => $remark]);
        return ['success' => true];
    }

    // 标记问题件
    public function orderIssueTag(Request $request)
    {
        $orderNos = $request->input('orderNos');
        $meg = ['success' => false];
        if ($this->verifyOrderIssue($request)) {
            $meg['fail_info'] = '传入订单编号中对应的订单问题已有生成';
            return $meg;
        }
        foreach ($orderNos as $orderNo) {
            $this->createOrFind($orderNo);
        }
        $meg['success'] = '选中订单已标记为问题订单';
        return $meg;
    }

    public function createOrFind($orderNo)
    {
        $orderService = app('orderService');
        $order = $orderService->createOrFindBy($orderNo);
        $arr = [
            'order_id' => $order->id,
        ];
        return OrderIssue::create($arr);
    }

    public function createOrderIssue(Request $request)
    {
        $orderService = app('orderService');
        $this->validatorCreate($request)->validate();
        $oracleOrderNo = $request->input('order_id');
        $logistic_number = $request->input('logistic_number');
        $order = $orderService->createOrFindBy($oracleOrderNo);
        $this->create($request);
    }

    public function validatorCreate(Request $request)
    {
        return Validator::make($request->input(), [
            'order_issue_type_id' => ['required'],
            'baoshi_indemnity_money' => ['numeric'],
            'logistic_indemnity_money' => ['numeric'],
        ], [
            'required' => ':attribute 为必填项',
            'unique' => ':attribute 已存在',
            'numeric' => ':attribute 为数组',
        ], [
            'order_issue_type_id' => '问题类别',
            'baoshi_indemnity_money' => '宝时赔偿金额',
            'logistic_indemnity_money' => '承运商赔偿金额',
        ]);
    }

    public function createByRejectedBill(Request $request)
    {
        $orderService = app('orderService');
        $rejectedBill = RejectedBill::where(['logistic_number_return' => $request->input('logistic_number_return')])->first();
        $orderNo = $rejectedBill->order_number;
        $order = $orderService->createOrFindBy($orderNo);
        $arr = $request->only(
            ['order_issue_type_id', 'result_explain', 'second_order_id', 'rejected_bill_id', 'situation_explain',
                'final_status', 'final_status', 'logistic_indemnity_money',
                'logistic_express_remission', 'baoshi_indemnity_money', 'baoshi_express_remission',
                'user_workgroup_id']);
        $arr['order_id'] = $order->id;
        return OrderIssue::create($arr);
    }

    public function createByOracleOrderNo(Request $request)
    {
        $orderService = app('orderService');
        $rejectedService = app('rejectedService');
        if (!$request->has('wms_order_no')) {
            return null;
        }
        $wms_order_no = $request->input('wms_order_no');
        $rejectedBill = $rejectedService->getRejectedByOrderNumber($wms_order_no);

        $orderIssue = $this->createOrFind($wms_order_no);
        $orderIssue->order_issue_type_id = $request->input('order_issue_type_id');
        if ($rejectedBill) {
            $orderIssue->rejected_bill_id = $rejectedBill->id;
        }
        $orderIssue->save();
        return $orderIssue;
    }

    public function createByLogisticNumber(Request $request)
    {
        $orderService = app('orderService');
        if (!$request->has('logistic_number')) {
            return null;
        }
        $order = $orderService->create($request->fill());
        return OrderPackage::creaed(['order_id' => $order->id, 'logistic_number' => $request->input('logistic_number')]);
    }

    public function verifyOrderIssue(Request $request)
    {
        $orderIds = $request->input('orderNos');
        $orders = Order::whereIn('code', $orderIds)->get();
        if (count($orders) == 0) {
            return false;
        }
        $order_ids = [];
        foreach ($orders as $order) {
            $order_ids[] = $order->id;
        }
        $count = OrderIssue::whereIn('order_id', $order_ids)->count();
        return $count != 0;
    }

    public function verifyOracleOrderNo(Request $request)
    {
        $meg = ['success' => false];
        $oracleOrderNo = $request->input('oracleOrderNo');
        $type = $request->input('type');

        $orderHeader = OracleDOCOrderHeader::where('OrderNo', trim($oracleOrderNo, "'"))->first();

        if ($orderHeader == null) {
            $meg['fail_info'] = '没有编号对应的订单信息';
        } else {
            if ($type == 'backExpressNumber') {

                $orderASNHeader = OracleDOCASNHeader::where('ASNReference2', $orderHeader->soreference1)->first();

                if ($orderASNHeader == null) {
                    $meg['fail_info'] = '没有对应的退件信息';
                } else {
                    $express_number = $orderASNHeader->asnreference3; // 快递单号
                    $express_number == null ? $meg['fail_info'] = '没有对应的快递单号' : ($meg['success'] = true && $meg['expressNumber'] = $express_number);
                }
            } else if ($type == 'verify') {
                if (!$orderHeader) {
                    $mes['fail_info'] = '编号对应的订单信息不存在';
                } else {
                    $mes['success'] = true;
                }
            }
        }
        return $meg;
    }

    public function verifyLogisticNumber(Request $request)
    {
        $logisticNumber = $request->input('logisticNumber');
        $ASNHeader = OracleDOCASNHeader::where('ASNReference2', $logisticNumber)->first();
        $orderHeader = OracleDOCOrderHeader::where('soreference1', $ASNHeader->asnreference3)->first();
        $meg = ['success' => false];
        if (!$orderHeader) {
            $meg['fail_info'] = '快递单号没有对应的订单';
        }
        return $meg['success'] = true;
    }

    public function destroy($id)
    {
        return OrderIssue::where('id', $id)->delete();
    }

    public function getOrderHead(Request $request)
    {
        $data = ['orderHeader' => null, 'orderDetails' => null];
        $logisticNumberReturn = $request->input('logisticNumberReturn');
        $ASNOrderHeaders = OracleDOCASNHeader::where('ASNReference3', $logisticNumberReturn)->get();
        if (count($ASNOrderHeaders) == 0) {
            return $data;
        }
        $orderHeader = OracleDOCOrderHeader::where('SOReference1', $ASNOrderHeaders->asnreference3)->get();
        $data['orderHeader'] = $orderHeader;
        $orderDetails = OracleDOCASNDetail::with(['sku'])->where('OrderNo', $orderHeader)->get();
        $data['orderDetails'] = $orderDetails;
        return $data;
    }

    public function getReturnLogisticInfo(Request $request)
    {
        $logisticNumberReturn = $request->input('logisticNumberReturn');
        $ASNOrderHeaders = OracleDOCASNHeader::where('ASNReference3', $logisticNumberReturn)->get();
        $ASNNo = [];
        foreach ($ASNOrderHeaders as $ASNOrderHeader) {
            $ASNNo[] = $ASNOrderHeader->asnno;
        }
        return OracleDOCASNDetail::whereIn('asnno', $ASNNo)->get();
    }

    public function getOrderHeadByOrderNo(Request $request)
    {
        $orderNo = $request->input('orderNo');
        $orderHeader = OracleDOCOrderHeader::where('orderNo', $orderNo)->get();
        $orderDetails = OracleDOCOrderDetail::with(['sku'])->where('orderNo', $orderNo)->get();
        return ['orderHeader' => $orderHeader, 'orderDetails' => $orderDetails];
    }

    public function getOrderHeadByLogisticNumberReturn(Request $request)
    {
        $logisticNumberReturn = $request->input('logisticNumber');
    }

    public function exportExcel(Request $request)
    {

        $result = null;
        if ($request->getMethod() == 'GET') {
// 所有页
            if ($request->has('checkAllSign')) {
                $result = $this->getConditionQuery($request, null)->get();
            }
        } else if ($request->getMethod() == 'POST') {
// 选中
            $owner_id = $request->input('data');
            $result = $this->getConditionQuery($request, ['order_issue_ids' => $owner_id])->get();
        }
        dd($result);
        return $result;
    }

}