<?php

namespace Model;

/**
 * 邮件发送任务
 * @author：dc
 * @time 2023/4/10 16:28
 * Class sendJobsSql
 * @package Model
 */
class sendJobsSql {

    /**
     * 表
     * @var string
     */
    public static $table = 'send_jobs';


    /**
     * 获取需要发送的邮件
     * @author：dc
     * @time 2023/4/11 14:56
     * @return string
     */
    public static function sendList():string {
        // 控制在500数量，协程数量就控制
        return "select * from `".self::$table."` where `status` = 0 and `send_time` <= ".time()." limit 500";
    }


    /**
     * 更新状态
     * @param int $id
     * @param int $status
     * @param null $db
     * @author：dc
     * @time 2023/4/11 16:06
     */
    public static function upStatus(int $id, int $status, $db=null){
        $db = $db?:db();
        // 更新状态
        $db->update(\Model\sendJobsSql::$table,[
            'status'    =>  $status
        ],dbWhere([
            'id'    =>  $id
        ]));
    }


}