jiaoyi-api/app/queue/redis/slow/PrintState.php

<?php

namespace app\queue\redis\slow;

use app\extra\tools\PrintExtend;
use app\model\saas\SaasPrint;
use Webman\RedisQueue\Consumer;

class PrintState implements Consumer
{

    /**
     * 消费队列名
     * 更新云打印件
     * @var string
     */
    public string $queue = "print-state";

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

    public function consume($data): bool
    {
        echo getDateFull()."===批量查询打印件状态\n";
        $print = (new SaasPrint)->select();
        $sn = [];
        if ($print->isEmpty()) return true;
        foreach ($print as $key => $value) {
            $sn[$key] = $value['sn'];
        }
        $resp = (new PrintExtend)->config(['appid' => sConf('wechat.ex_appid'),'secret' => sConf('wechat.ex_secret')])->deviceState($sn);
        if (!$resp['status']) return true;
        if (empty($resp['data'])) return true;
        foreach ($resp['data'] as $key => $val) {
            echo getDateFull()."===更新序列号=={$val['sn']}=={$val['status']}=={$val['deviceStatus']}\n";
            $state = (new SaasPrint)->where("sn",$val['sn'])->update(["online" => $val['status'],"device_state" => $val['deviceStatus']]);
            echo "更新状态==={$state}\n";
        }
        return true;
    }

}