hx-mini-api/app/queue/redis/ExportOrder.php

<?php

namespace app\queue\redis;

use app\extra\service\saas\OrderService;
use app\model\system\SystemExport;
use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
use PhpOffice\PhpSpreadsheet\Spreadsheet;
use Webman\RedisQueue\Consumer;

class ExportOrder implements Consumer
{

    public $queue = "export-order";

    public $connection = "default";


    /**
     * @param $data
     * @return bool
     */
    public function consume($data): bool
    {
        echo getDateFull()."===导出订单\n";
        $order = (new OrderService)->getListAll($data['param']);
        if (empty($order))
        {
            (new SystemExport)->where("id",$data['logId'])->save(['status' => 2]);
            return true;
        }
        $title = ["订单编号","所属门店","订单类型","商品ID","商品名称","规格","订单金额","收件人","收件电话","收件地址","券码"];
        $titCol = 'A';
        $spreadsheet = new Spreadsheet();
        $sheet = $spreadsheet->getActiveSheet();
        foreach($title as $k=>$v){
            $sheet->setCellValue($titCol."1",$v);
            $titCol ++;
        }
        $row = 2;
        foreach ($order as $item){
            $dataCol = "A";
            $newData = [
                "order_id"      => (string) $item['order_id'], // 余额
                "store"         => $item['store']['store_name']??'-',
                "type"          => $item['service_type']==1?'预约':'快递',
                "out_id"        => $item['product_id']??'-',
                "product_name"  => $item['product_name']??'-',
                "sku"           => $item['sku']??'-',
                "order_amount"  => "¥".$item['parent']['order_amount']??'-',
                "username"      => $item['username']??'-',
                "mobile"        => $item['mobile']??'-',
                "address"       => $item['region'].$item['address'],
                "certificate"   => $item['certificate_id']??'-'
            ];
            foreach ($newData as $value) {
                $sheet->setCellValue($dataCol . $row, ' '.$value);
                $dataCol++;
            }
            $row++;
        }
        $write = new Xlsx($spreadsheet);
        $pathName = public_path().DIRECTORY_SEPARATOR."logs".DIRECTORY_SEPARATOR.$data['param']['fileName'];
        (new SystemExport)->where("id",$data['logId'])->update([
            "down_url"  => "https://file.jsshuita.com.cn/logs/".$data['param']['fileName'],
            "status"    => 1
        ]);
        $write->save($pathName);
        return true;
    }

}