baoshi-was/app/Http/Controllers/OrderIssueController.php

<?php

namespace App\Http\Controllers;

use App\Imports\OrderIssueImport;
use App\Logistic;
use App\OracleDOCOrderHeader;
use App\Order;
use App\OrderIssue;
use App\OrderIssueProcessLog;
use App\OrderIssueType;
use App\OrderPackage;
use App\Owner;
use App\QualityLabel;
use App\RejectedBill;
use App\Services\LogService;
use App\Services\OrderIssueProcessLogService;
use App\Services\OrderIssueService;
use App\Services\OrderPackageService;
use App\Services\OrderService;
use App\Services\OwnerService;
use App\Shop;
use App\UserWorkgroup;
use Exception;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\Gate;
use Illuminate\Support\Facades\Http;
use Illuminate\Support\Facades\Validator;
use Maatwebsite\Excel\Facades\Excel;

class OrderIssueController extends Controller
{

    public function index(Request $request)
    {
        if (!Gate::allows('订单管理-问题件-查询')) {
            return redirect(url('/'));
        }
        /** @var OrderIssueService $orderIssueService */
        $orderIssueService = app('OrderIssueService');
        $owners = app(OwnerService::class)->getAuthorizedOwners();
        $orderIssues = $orderIssueService->paginate($request->all());
        $orderIssueType = OrderIssueType::all();
        $qualityLabel = QualityLabel::all();
        $logistics = Logistic::all();
        $userWorkgroup = UserWorkgroup::all();
        return view('order/issue/index', compact('owners', 'orderIssues', 'orderIssueType', 'qualityLabel','userWorkgroup','logistics'));
    }

    public function create()
    {
        if (!Gate::allows('订单管理-订单问题件生成')) {
            return redirect(url('/'));
        }
        $types = OrderIssueType::all();
        $meg = ['success' => true];
        $userWorkGroup = UserWorkgroup::all();
        $logistic = Logistic::all();
        $owners = Owner::all();
        return view('order.issue.create', compact('types', 'meg', 'userWorkGroup', 'logistic', 'owners'));
    }

    public function store(Request $request)
    {
        if (!Gate::allows('订单管理-订单问题件生成')) {
            return redirect(url('/'));
        }
        $orderIssueService = app('OrderIssueService');
        $orderIssueService->validatorCreate($request)->validate();
        $orderIssue = null;
        if ($request->filled('logistic_number_return')) {
            $orderIssue = $orderIssueService->createByLogisticNumber($request->all());
        } else {
            $orderIssue = $orderIssueService->create($request->all());
        }
        OrderIssueProcessLog::query()->create(['order_issue_id' => $orderIssue['id'], 'user_id' => Auth::user()['id'], 'content' => '创建订单问题件', 'type' => '创建']);
        return redirect('order/issue/index');
    }

    public function edit($id)
    {
        if (!Gate::allows('订单管理-问题件-编辑')) {
            return redirect(url('/'));
        }
        $orderIssue = OrderIssue::query()->with(['order','secondOrder.packages.commodities.commodity'])->where('id', $id)->first();
        $order = $orderIssue->order;
        $secondOrder = $orderIssue->secondOrder;
        $rejectedBill = RejectedBill::query()->where('id', $orderIssue->rejected_bill_id)->first();
        $userWorkgroup = UserWorkgroup::all();
        $orderIssueType = OrderIssueType::all();
        $owners = Owner::all();
        $shops = Shop::all();
        $logistics = Logistic::all();
        return view('order/issue/edit', compact('orderIssue', 'owners', 'userWorkgroup', 'shops', 'logistics', 'orderIssueType', 'order', 'secondOrder', 'rejectedBill'));
    }

    public function batchImport(Request $request)
    {
        if (!Gate::allows('订单管理-订单问题件生成')) {
            return redirect(url('/'));
        }
        $file = $request->file('file');
        $fileSuffix = $file->getClientOriginalExtension();
        if (in_array($fileSuffix, ['xlsx', 'xlsm', 'xltx', 'xltm', 'xls', 'xlt', 'ods', 'ots', 'slk', 'xml', 'gnumeric', 'htm', 'html', 'csv', 'tsv'])) {
            ini_set('max_execution_time', 2100);
            ini_set('memory_limit', '512M');
            $extension = $request->file()['file']->getClientOriginalExtension();
            $extension[0] = strtoupper($extension[0]);
            Excel::import(new OrderIssueImport(), $request->file('file')->path(), null, $extension);
            if (Cache::has('error')) {
                return '<h1 class="text-danger">导入Excel失败<br><p style="color: red">' . Cache::pull('error') . '</p></h1>';
            } else {
                $exception = Cache::get('exception');
                $a = '';
                for ($i = 0; $i < count($exception); $i++) {
                    $a .= implode(',', $exception[$i]) . '&#10';
                };
                $this->log(__METHOD__, __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
                return '<h1 class="text-danger">导入Excel成功<br><textarea style="width: 50%;height: 50%">' . $a . '</textarea></h1>';
            }
        } else {
            return '<h1 class="text-danger">失败<br><p style="color: red">不支持该文件类型</p></h1>';
        }
    }

    public function exportOrderIssue(Request $request)
    {
        ini_set('max_execution_time', 2500);
        ini_set('memory_limit', '1526M');
        if (!Gate::allows('订单管理-问题件-查询')) {
            return redirect(url('/'));
        }
        if ($request->checkAllSign){
            $params = $request->input();
            unset($params['checkAllSign']);

            $sqlList = app('OrderIssueService')->getSqlList($params);
        }else{
            $sqlList = app('OrderIssueService')->getSqlList(['id'=>$request->data,"is_handle"=>true]);
        }
        $post = Http::post(config('go.export.url'),['type'=>'orderIssue','sqlList'=>json_encode($sqlList),'createFormat'=>'merge']);
        if ($post->status() == 500){
            throw new Exception($post->header("Msg"));
        }
        return response($post,200, [
            "Content-type"=>"application/octet-stream",
            "Content-Disposition"=>"attachment; filename=订单问题件-".date('ymdHis').'.xlsx',
        ]);
    }

    public function excelImport()
    {
        if (!Gate::allows('订单管理-订单问题件生成')) {
            return redirect(url('/'));
        }
        return view('order.issue.import');
    }

    public function apiOrderIssueTag(Request $request)
    {
        if (!Gate::allows('订单管理-订单问题件生成')) {
            return ['success' => false, 'fail_info' => '没有对应权限'];
        }
        if (!$request->input('orderNos')) {
            return ['success' => false, 'fail_info' => '没有传入的订单编号'];
        }
        /** @var OrderIssueService $orderIssueService */
        $orderIssueService = app(OrderIssueService::class);
        $exits_orderNos = $orderIssueService->校验问题件是否存在_WMS订单号_返回存在的订单号($request->input('orderNos'));
        if(count($exits_orderNos)>0){
            return ['success'=>false,'fail_info'=>'标记问题件存在已有订单号','exitsOrderNos' =>$exits_orderNos];
        }
        return $orderIssueService->orderIssueTag($request->all());
    }

    public function apiDestroy(Request $request)
    {
        if (!Gate::allows('订单管理-问题件-删除')) {
            return ['success' => false, 'fail_info' => '没有对应权限'];
        }
        if (!($request->has('id'))) {
            return ['success' => 'false', 'fail_info' => '没有问题题件相关的参数'];
        }
        $orderIssue = OrderIssue::query()->where('id', $request->input('id'))->first();
        $bool = $orderIssue->delete();
        if ($bool) {
            $this->log(__METHOD__, __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
            return ['success' => 'true'];
        } else {
            return ['success' => 'false', 'fail_info' => '删除问题单出现异常,请联系管理员'];
        }
    }

    public function updateApi(Request $request)
    {
        if (!Gate::allows('订单管理-问题件-编辑')) {
            return ['success' => false, 'fail_info' => '没有对应权限'];
        }
        try {
            $data =  $request->only([
                'order_issue_type_id','owner_id','logistic_id', 'logistic_number_return','result_explain','final_status','second_order_id','second_client_no',
                'logistic_indemnity_money','logistic_express_remission','baoshi_indemnity_money','baoshi_express_remission','user_workgroup_id'
            ]);
            $orderIssue = OrderIssue::query()->find($request->id);
            $orderIssue->update($data);
            $orderIssue->同步退单状态();
            LogService::log(__METHOD__,__FUNCTION__,json_encode($request));
            return  ['success' => true];
        } catch (Exception $e) {
            LogService::log(__METHOD__,__FUNCTION__,json_encode($request)."||".$e->getMessage().'||'.$e->getTraceAsString());
            return  ['success' => false ,'fail_info' => $e->getMessage()];
        }
    }


    public function apiEndOrderIssue(Request $request)
    {
        if (!Gate::allows('订单管理-问题件-编辑')) {
            return ['success' => false, 'fail_info' => '没有对应的权限'];
        }
        if (!$request->has('ids')) {
            return ['success' => false, 'fail_info' => '没有传入对应的参数'];
        }
        $count = OrderIssue::query()->whereIn('id', $request->input('ids'))->where('final_status', '已解决')->count();
        if ($count > 0) {
            return ['success' => false, 'fail_info' => '勾选的内容中已有完结的订单问题件,取消勾选后重试'];
        } else {
            OrderIssue::query()->whereIn('id', $request->input('ids'))->update(['final_status' => '已解决']);
            foreach ($request->input('ids') as $id) {
                OrderIssueProcessLog::query()->create(['order_issue_id' => $id, 'user_id' => Auth::user()['id'], 'type' => '结束', 'content' => '完结订单']);
            }
            $this->log(__METHOD__, __FUNCTION__, json_encode($request->toArray()), Auth::user()['id']);
            return ['success' => true];
        }
    }

    public function apiDisposeOrderIssue(Request $request)
    {
        if (!Gate::allows('订单管理-问题件-编辑')) {
            return ['success' => false, 'fail_info' => '没有对应权限'];
        }
        if (!$request->has('id')) {
            return ['success' => false, 'fail_info' => '没有传入对应参数'];
        }
        try {
            OrderIssue::query()
                ->where('id', $request->input('id'))
                ->update(['is_new_rejecting' => '已处理']);
            LogService::log(__METHOD__,__FUNCTION__,json_encode($request->getContent()));
            return ['success'=>true];
        } catch (Exception $e) {
            LogService::log(__METHOD__,__FUNCTION__,json_encode($request->getContent())."||".$e->getMessage()."||".$e->getTraceAsString());
            return ['success' => false,'fail_info' => $e->getMessage()];
        }
    }

    public function apiGetOrderInfoByClientNo(Request $request)
    {
        if (!$request->filled('clientNo')) {
            return ['success' => false, 'fail_info' => '缺失WMS订单参数无法查询'];
        }
        $orderInfo = app(OrderService::class)->findOrCreateByClientCode($request->input('clientNo'));
        if (!$orderInfo) {
            return ['success' => true, 'message' => '没有对应的订单信息'];
        }else{
            return ['success' => true, 'data' => $orderInfo];
        }
    }

    public function apiOrderIssueHasClientCode(Request $request)
    {
        if (!$request->filled('clientCode')) {
            return ['success' => false, 'fail_info' => '缺少对应的参数或条件'];
        }
        $orderService = app('OrderService');
        $clientCode = $request->input('clientCode');
        $order = Order::query()->where('client_code', $clientCode)->first();
        if ($order) {
            if (OrderIssue::query()->where('order_id', $order['id'])->count()) {
                return ['success' => false, 'fail_info' => '该客户订单号已有对应的订单问题件'];
            }
            $order = $orderService->findOrCreateByClientCode($clientCode);
            return ['success' => true, 'order' => $order];
        } else {
            $orderHeader = OracleDOCOrderHeader::query()->where('SOReference1', $clientCode)->first();
            if (!$orderHeader) {
                return ['success' => false, 'fail_info' => '该客户订单号没有对应的订单信息'];
            } else {
                $order = $orderService->findOrCreateByClientCode($clientCode);
                $rejectedBill = $orderService->getRejectedBillOfClientCode($clientCode);
                return ['success' => true, 'order' => $order, 'rejectedBill' => $rejectedBill];
            }
        }
    }

    public function apiOrderIssueHasLogisticNumberReturn(Request $request)
    {
        if (!$request->filled('logisticNumberReturn')) {
            return ['success' => false, 'fail_info' => '缺少对应的参数或条件'];
        }
        $logisticNumberReturn = $request->input('logisticNumberReturn');
        $rejectedBill = RejectedBill::with('items')->where('logistic_number_return', $logisticNumberReturn)->first();
        if ($rejectedBill) {
            $orderIssue = OrderIssue::query()->where('rejected_bill_id', $rejectedBill->id)->first();

            if ($orderIssue) {
                return ['success' => false, 'fail_info' => '该退回单号已有对应的问题件'];
            } else {
                $orderService = app('OrderService');
                $order = $orderService->findOrCreteByLogisticNumberReturn($logisticNumberReturn);
                return ['success' => true, 'order' => $order, 'rejectedBill' => $rejectedBill];
            }
        } else {
            return ['success' => true, 'meg' => '没有对应的退回单号，不与WMS同步'];
        }
    }

    public function isExistByOrderNoApi(Request $request){
        if (!Gate::allows('订单管理-订单问题件生成')) {
            return ['success'=>false,'fail_info' => '没有对应权限'];
        }
        $orderNos = $request->input('orderNos');
        $orderIssues =OrderIssue::query()->with('order')
            ->whereHas('order',function($query) use ($orderNos){
                $query->whereIn('code',$orderNos);
            })->get();

        if($orderIssues->count() == 0){
            return ['success'=>true ];
        }else{
            $is_exist_orderNos = '';
            foreach ($orderIssues as $orderIssue) {
                $is_exist_orderNos.= $orderIssue->order->code.',';
            }
            $is_exist_orderNos = rtrim($is_exist_orderNos,',');
            $is_exist_orderNos .= ';';
            return ['success'=>false,'fail_info'=>'选中的订单已有存在的问题件:'.$is_exist_orderNos];
        }
    }

    public function updateColumnApi(Request $request)
    {
        if (!Gate::allows('订单管理-问题件-编辑')) {
            return ['success'=>false,'fail_info' => '没有对应权限'];
        }
        try {
            OrderIssue::query()
                ->where('id', $request->input('id'))
                ->update([$request->input('column') => $request->input('value')]);
            LogService::log(__METHOD__,'更新问题件',json_encode($request->getContent()));
            return ['success' => true];
        } catch (Exception $e) {
            LogService::log(__METHOD__,'更新问题件error',json_encode($request->getContent()).'||'.$e->getMessage().'||'.$e->getTraceAsString());
            return ['success' => false, $e->getMessage()];
        }
    }

    public function batchDestroyApi(Request $request)
    {
        if (!Gate::allows('订单管理-问题件-删除')) {
            return ['success'=>false,'fail_info' => '没有对应权限'];
        }
        try {
            OrderIssue::query()->whereIn('id', $request->input('ids'))->delete();
            LogService::log(__METHOD__,__FUNCTION__,json_encode($request->getContent()));
            return ['success' => true];
        } catch (Exception $e) {
            LogService::log(__METHOD__,__FUNCTION__,json_encode($request)."||".$e->getMessage()."||".$e->getTraceAsString());
            return ['success' => false,'fail_info' => $e->getMessage()];
        }
    }

    public function updateLogisticNumberReturnApi(Request $request){
        if (!Gate::allows('订单管理-问题件-编辑')) {
            return ['success'=>false,'fail_info' => '没有对应权限'];
        }
        try {
            /** @var OrderIssue $orderIssue */
            $orderIssue = OrderIssue::query()->where('id',$request->input('id'))->first();
            $rejectedBill = RejectedBill::query()
                ->with('items')
                ->where('logistic_number_return',$request->input('logisticNumberReturn'))
                ->first();
            LogService::log(__METHOD__, __FUNCTION__, json_encode($request->getContent()));
            if(!$rejectedBill){
                $orderIssue->update(['logistic_number_return' => $request->input('logisticNumberReturn')]);
                return ['success' => false, 'message' => '退回单号已修改，退回单号没有相应退件信息'];
            }else{
                $orderIssue->update(['logistic_number_return' => $request->input('logisticNumberReturn'),'is_new_rejecting' => '有']);
                $orderIssue->同步退单状态();
                return ['success' => true, 'rejectedBill' => $rejectedBill,'rejectingStatus' =>$orderIssue->rejecting_status];
            }
        } catch (Exception $e) {
            LogService::log(__METHOD__, __FUNCTION__,'error'. json_encode($request->getContent()).'||'.$e->getMessage().'||'.$e->getTraceAsString());
            return ['success' => false ,'fail_info' => $e->getMessage()];
        }
    }

    public function apiUpdateValidator(array $arr)
    {
        return Validator::make($arr, [
            'order_issue_type_id' => ['required'],
            'handle_status' => ['nullable'],
            'result_explain' => ['nullable'],
            'logistic_indemnity_money' => ['nullable', 'numeric'],
            'logistic_express_remission' => ['nullable'],
            'baoshi_indemnity_money' => ['nullable', 'numeric'],
            'baoshi_express_remission' => ['nullable'],
        ], [
            'required' => [':attribute 为必填项', ':attribute'],
            'numeric' => [':attribute  为可确认的数值', ':attribute']
        ], [
            'order_issue_type_id' => '问题类别',
            'handle_status' => '处理状态',
            'result_explain' => '处理结果说明',
            'logistic_indemnity_money' => '承运商赔偿金额',
            'logistic_express_remission' => '承运商快递减免',
            'baoshi_indemnity_money' => '宝时赔偿金额',
            'baoshi_express_remission' => '宝时快递减免',
        ]);
    }

    public function apiUpdateValidatorRejectedBill(array $arr){
        return Validator::make($arr, [
            'logistic_number_return'=>['required'],
            'id_logistic_return'=>['required'],
        ], [
            'required' => [':attribute 为必填项', ':attribute'],
        ], [
            'logistic_number_return'=> '退回单号',
            'id_logistic_return'=> '退回单号承运商',
        ]);
    }

    public function endOrderIssuesApi(Request $request)
    {
        if (!Gate::allows('订单管理-问题件-编辑')) {
            return ['success'=>false,'fail_info' => '没有对应权限'];
        }
        $orderIssue_ids = $request->input('ids');
        $bool = app(OrderIssueService::class)->isExistOrderIssueTypeIsEnd($orderIssue_ids);
        if($bool)return ['success'=>false,'fail_info'=> '需要完结的订单问题件中已有完结的订单问题件'];
        $bool = app(OrderIssueService::class)->endOrderIssues($orderIssue_ids);
        if($bool == 0) return ['success'=>false,'fail_info' => '操作失败'];
        $params = ['ids'=>$orderIssue_ids,'content'=>'完结订单','type'=>'结束'];
        $logs = app(OrderIssueProcessLogService::class)->create($params);
        return ['success'=>true,'logs'=>$logs];
    }

    public function editSecondClientNoApi(Request $request)
    {
        if(!Gate::allows('订单管理-问题件-编辑')){
            return ['success'=>false,'fail_info'=>'没有对应权限'];
        }
        $secondClientNo = $request->input('secondClientNo');
        try {
            app(OrderIssueService::class)->editOrderIssueSecondClientNo($request->id,$secondClientNo);
            $order = Order::query()->with('packages.commodities.commodity')->where('client_code',$secondClientNo)->first();
            if (!$order) {
                return ['success' => true, 'message' => '二次客户单号已修改，没有对应的订单信息'];
            } else {
               return ['success' => true, 'order' => $secondClientNo =='' ? null : $order];
            }
        } catch (Exception $e) {
            LogService::log(__METHOD__, __FUNCTION__, json_encode($request->getContent()).$e->getMessage().$e->getTraceAsString());
            return  ['success' =>false ,'fail_info' => $e->getMessage()];
        }
    }

    public function editSecondLogisticNumberApi(Request $request)
    {
        if(!Gate::allows('订单管理-问题件-编辑'))
            return ['success'=>false,'fail_info'=>'没有对应权限'];
        /** @var OrderIssueService $service */
        $service = app(OrderIssueService::class);
        try {
            $message = $service->updateSecondLogisticNumber($request->input('id'), $request->logistic_number);
            LogService::log(__METHOD__,__FUNCTION__,json_encode($request->getContent()));
            return $message;
        } catch (Exception $e) {
            LogService::log(__METHOD__,__FUNCTION__,json_encode($request->getContent()).$e->getMessage().$e->getTraceAsString());
            return ['success'=>false,$e->getMessage()];
        }
    }

    public function disposeImportApi(Request $request)
    {
        if(!Gate::allows('订单管理-问题件-编辑'))
            return ['success'=>false,'fail_info'=>'没有对应权限'];
        return app(OrderIssueService::class)->disposeImport($request->input('ids'));
    }

    public function importPasteDataApi(Request $request)
    {
        if (!Gate::allows('订单管理-订单问题件生成'))
            return ['success'=>false,'fail_info'=>'没有对应权限'];
        $rows = $request->input('rows');
        $logistic_numbers = [];
        $types = [];
        $maps = [];
        $errors = [];
        $orderIssueTypes = OrderIssueType::all();
        $orderIssueType_map = [];
        foreach ($orderIssueTypes as $orderIssueType) {
            $orderIssueType_map[$orderIssueType->name] = $orderIssueType;
        }
        $array = explode("\n",$request->input('pasteDataText')); //拆分行
        /** @var OrderIssueService $service */
        $service =  app(OrderIssueService::class);
        foreach ($array as $i => $str) {
//            $string= preg_replace('/[\s,\,\，]+/','*++*',$str);
//            $items = explode('*++*',$string);
            $items=[];
            preg_match('/^(\w*?)[\s,，；;]([\x{4e00}-\x{9fa5}]*?)[\s,，；;](.*?)[\s,，；;](\w*?)$/u', $str, $items);
            array_shift($items);
            $head = '第'.($i+1).'行';
            if(count($items)<count($rows)-1){
                $errors[$head] = ['数据不完整'];
                unset($items);
                continue;
            }
            $map = [];
            foreach ($rows as $index=>$row) {
                if($row === '原始运单号'){
                    if(!$items[$index]){
                        $errors[$head][]='快递单号为空';
                        $map =[];
                    }
                    $logistic_numbers = [$items[$index]];
                    $exist_logistic =  $service->校验问题件是否存在_快递单号_返回存在的快递单号($logistic_numbers);
                    $orderHeaders=OracleDOCOrderHeader::query()->with('actAllocationDetails')->whereHas('actAllocationDetails',function($query)use($logistic_numbers){
                        $query->whereIn('picktotraceid',$logistic_numbers);
                    })->get();
                    if(count($exist_logistic) > 0){
                        $errors[$head][]='快递单号存在对应的问题件';
                        $map =[];
                    }else if($orderHeaders->count()==0){
                        $errors[$head][]='快递单号不存在对应的发运订单';
                        $map =[];
                    }
                    $logistic_numbers[] = $items[$index];
                    $map['logistic_number'] = $items[$index];
                }
                if($row==='情况说明'){
                    if(!$items[$index]){
                        $errors[$head][]='情况说明为空';
                        $map =[];
                    }
                    $map['result_explain'] = $items[$index];
                }
                if($row==='自定义订单号'){
                    if($items[$index]??false){
                        $map['custom_code'] = $items[$index];
                    }
                }
                if($row==='问题类别'){
                    if(!$items[$index]){
                        $errors[$head][]='问题类别为空';
                        $map = [];
                    }else{
                        $type =  $orderIssueType_map[$items[$index]] ?? null;
                        if(!$type){
                            $errors[$head][]='问题类型不存在';
                            $map = [];
                        }
                    }
                    $types[] =$items[$index];
                    $map['type'] = $items[$index];
                }
            }
            if(count($map)!==0)$maps[] = $map;
        }
//        if(count($errors)>0)
        if(count($errors)>0) return ['success'=>false,'fail_info'=>$errors];
        try {
            foreach ($maps as $map) {
                $logistic_number = $map['logistic_number'];
                $result_explain = $map['result_explain'];
                $type = $map['type'];
                $custom_code = $map['custom_code'] ?? null;
                $service->createOrderIssue($logistic_number, $type, $result_explain,'导入未处理',$custom_code);
            }
            return ['success'=>true];
        } catch (Exception $e) {
            LogService::log(__METHOD__,__FUNCTION__,'文本导入问题件失败'.json_encode($request->getContent().$e->getMessage().$e->getTraceAsString()));
            return ['success'=>false,'fail_info'=>$e->getMessage()];
        }
    }
}