baoshi-was/app/Imports/OrderIssueImport.php

<?php

namespace App\Imports;

use App\Events\AddOrUpdateOrderIssues;
use App\Jobs\SyncOrderIssueOrWorkOrderBySWMS;
use App\Jobs\SyncRejectedBillRejectingStatusJob;
use App\OracleActAllocationDetails;
use App\OracleDOCOrderHeader;
use App\Order;
use App\OrderIssue;
use App\OrderIssueProcessLog;
use App\OrderIssueType;
use App\OrderPackage;
use App\Services\OrderService;
use App\Services\RejectedService;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\Auth;
use Illuminate\Support\Facades\Cache;
use Maatwebsite\Excel\Concerns\ToCollection;
use Maatwebsite\Excel\Concerns\WithHeadingRow;
use Maatwebsite\Excel\Concerns\WithMultipleSheets;
use Maatwebsite\Excel\Imports\HeadingRowFormatter;

HeadingRowFormatter::default('none');

class OrderIssueImport implements ToCollection, WithHeadingRow, WithMultipleSheets
{
    /** @var  OrderService $orderService*/
    private $orderService;
    /** @var RejectedService  $rejectedService */
    private $rejectedService;


    public function Collection(Collection $collection)
    {

        $this->orderService = app(OrderService::class);
        $this->rejectedService = app(RejectedService::class);

        $endIS = false;
        $headerRow = $collection->toArray()[0];
        if (!isset($headerRow['原始运单号']) || !isset($headerRow['情况说明']) || !isset($headerRow['问题类别'])) {
            Cache::put('error', '请检查您第一行标题是否存在原始运单号，情况说明，问题类别');
        } else {
            $endIS = true;
        }
        $exception = [];
        $sum = 2;
        if ($endIS) {
            foreach ($collection as $row) {
                $logistic_number = trim($row['原始运单号'], ' ');
                if (!$row['原始运单号']) {
                    array_push($exception, ['第' . $sum . '行数据运单号为空!']);
                    $sum++;
                    continue;
                } else if (!$row['情况说明']) {
                    array_push($exception, ['第' . $sum . '行问题说明为空!']);
                    $sum++;
                    continue;
                } else if (!$row['问题类别']) {
                    array_push($exception, ['第' . $sum . '行问题类别为空!']);
                    $sum++;
                    continue;
                }
                $order_type = OrderIssueType::query()->where('name', $row['问题类别'])->first();
                if (!$order_type) {
                    array_push($exception, ['原始运单号' . $row['原始运单号'] . '对应的的问题件类别不存在']);
                    continue;
                }
                $count = OracleDOCOrderHeader::query()->where('soreference5', $logistic_number)->count();
                $detailCount = OracleActAllocationDetails::query()->where('picktotraceid', $logistic_number)->count();
                if (!$count && !$detailCount) {
                    array_push($exception, ['原始运单号' . $row['原始运单号'] . '对应的WMS运单不存在']);
                    $sum++;
                    continue;
                }
                $query = OrderPackage::query()->select('order_id')->where('logistic_number', $logistic_number);
                $order_issue_exists = OrderIssue::query()->whereIn('order_id', $query)->exists();
                if ($order_issue_exists) {
                    array_push($exception, ['原始运单号' . $row['原始运单号'] . '对应的问题件已存在']);
                    continue;
                }
                $client_no = null;
                $order_nos = [];
                if ($count) {
                    $orderHeader = OracleDOCOrderHeader::query()->where('soreference5', $logistic_number)->first();
                    $client_no = $orderHeader['soreference1'];
                    $order_nos[] = $orderHeader['orderno'];
                } else if ($detailCount) {
                    $detail = OracleActAllocationDetails::query()->where('picktotraceid', $logistic_number)->first();
                    $orderHeader = OracleDOCOrderHeader::query()->where('orderno', $detail['orderno'])->first();
                    $client_no = $orderHeader['soreference1'];
                    $order_nos[] = $orderHeader['orderno'];
                }
                $this->orderService->syncOrderInfoByWmsOrderNos($order_nos);
                $query = Order::query()->where('code', $order_nos[0]);
                $orderIssue = OrderIssue::query()->where('order_id', $query)->first();
                $rejectedBill = $this->rejectedService->getRejectedByClientNo($client_no);
                if ($orderIssue) {
                    array_push($exception, ['原始运单号' . $row['原始运单号'] . '对应的问题件已存在']);
                    $sum++;
                    continue;
                }
                $arr = ['order_id' => $orderIssue->order_id, 'order_issue_type_id' => $order_type['id'], 'result_explain' => $row['情况说明'], 'imported_status' => '导入未处理'];
                if ($rejectedBill) {
                    $arr['rejected_bill_id'] = $rejectedBill['id'];
                }

                /** @var OrderIssue $orderIssue */
                $orderIssue = OrderIssue::query()->create($arr);
                event(new AddOrUpdateOrderIssues([$orderIssue->order_id]));
                SyncRejectedBillRejectingStatusJob::dispatch($orderIssue->order);

                if ($orderIssue) {
                    array_push($exception, ['订单' . $row['原始运单号'] . '问题件创建成功！']);
                    SyncOrderIssueOrWorkOrderBySWMS::dispatch($orderIssue,SyncOrderIssueOrWorkOrderBySWMS::$ORDER_ISSUE_TYPE);

                    OrderIssueProcessLog::query()->create(['order_issue_id' => $orderIssue['id'], 'user_id' => Auth::user()['id'], 'content' => '', 'type' => '创建']);
                } else {
                    array_push($exception, ['订单' . $row['原始运单号'] . '问题件创建失败']);
                }
                $sum++;
            }
        }
        Cache::put('exception', $exception, 86400);
    }

    /**
     * 该方法是实现上传文件只选中 第一个表
     * ExcelImport 默认是有多少个分表就执行多少次的分表
     * @return OrderIssueImport[]|array
     */
    public function sheets(): array
    {
        return [0 => new OrderIssueImport()];
    }
}