jiaoyi-webman/app/queue/redis/slow/ImportOrder.php

<?php

namespace app\queue\redis\slow;

use app\model\saas\SaasChatMsg;
use app\model\saas\SaasOrder;
use app\model\saas\SaasOrderExpress;
use app\model\system\SystemImport;
use app\model\system\SystemUser;
use PhpOffice\PhpSpreadsheet\IOFactory;
use Webman\RedisQueue\Consumer;

class ImportOrder implements Consumer
{

    /**
     * 订单导入发货
     * 更新云打印件
     * @var string
     */
    public string $queue = "import-order";

    /**
     * 连接配置
     * @var string
     */
    public string $connection = "default";

    public function consume($data): bool
    {
        try {
            if(empty($data['logId'])) return true;
            if(empty($data['poi_id'])) return true;
            $path = public_path().$data['path'];
            $spreadsheet = IOFactory::load($path);
            $worksheet = $spreadsheet->getActiveSheet();
            $sheetData = $worksheet->toArray(null, true, true, true);
            // 5. 现在 $sheetData 就是一个二维数组，你可以遍历它处理每一行数据
            $orderMode = (new SaasOrder);
            $excelData= [];
            $expressData = [];
            foreach ($sheetData as $rowIndex => $row) {
                if ($rowIndex > 0 && !empty($row['A']) && !empty($row['C'])) {
                    $excelData[$rowIndex] = $row;
                }
            }
            if (!empty($excelData)) {
                $successData = $errData = [];
                foreach (array_values(array_filter($excelData)) as $key=>$val) {
                    if (!empty(trim($val['C'])) && !empty(trim($val['A']))) {
                        $order = $orderMode->where("order_sn",trim($val['A']))->findOrEmpty();
                        if ($order->isEmpty()) {
                            continue;
                        }
                        $order->express_status = 2;
                        $order->save();
                        $express = (new SaasOrderExpress)->where("express_sn",trim($val['C']))->findOrEmpty();
                        if ($express->isEmpty()) {
                            // 发送一条发货消息给用户
                            $lastMsg = (new SaasChatMsg)->where(['openid' => $order['openid'],'poi_id' => $order['poi_id']])->order("id desc")->findOrEmpty();
                            if ($lastMsg->isEmpty()) {
                                $serviceUser = (new SystemUser)->where(['store_id' => $order['poi_id'],"type" => 3])->order("last_msg_at","asc")->findOrEmpty();
                                $lastServiceId = $serviceUser['id'];
                            } else {
                                $lastServiceId = $lastMsg['service_id'];
                            }
                            $expressName = "";
                            if (isset($val['D'])) {
                                $expressName = "({$val['D']})";
                            }
                            (new SaasChatMsg)->insertGetId([
                                'openid' => $order['openid'],
                                'poi_id' => $order['poi_id'],
                                "source"    => 2,
                                "service_id" => $lastServiceId,
                                "msgId"     => md5($order['openid'].time()),
                                "content"   => "您的订单({$val['A']})预计3日内到你手中，快递单号：{$val['C']} {$expressName}",
                                "type"      => "text"
                            ]);
                            $expressData[$key] = [
                                "order_sn"      => trim($val['A']),
                                "express_sn"    => trim($val['C']),
                                "mobile"        => trim($val['B']),
                                "express_name"  => $val['D']?trim($val['D']):'',
                                "last_at"       => getDateFull()
                            ];
                            $successData[$key] = trim($val['A']);
                        } else {
                            $errData[$key] = trim($val['A']);
                        }
                    }
                }
            }
            if (!empty($expressData)) {
                (new SaasOrderExpress)->insertAll(array_values($expressData));
            }
            (new SystemImport)->where("id",$data['logId'])->update([
                'status'        => 1,
                "last_at"       => getDateFull(),
                'success_num'   => (!empty($successData)) ? count(array_values($successData)) : 0,
                'success_data'  => (!empty($successData)) ? json_encode(array_values($successData)) : "",
                'error_num'     => (!empty($errData)) ? count(array_values($errData)) : 0,
                'error_data'    => (!empty($errData)) ? json_encode(array_values($errData)) : '',
            ]);
            return true;
        } catch (\Throwable $throwable) {
            echo getDateFull()."==导入订单报错===\n";
            echo $throwable->getFile()."\n";
            echo $throwable->getLine()."\n";
            echo $throwable->getMessage()."\n";
        }
        return true;
    }

}