用thinkphp 产生一个随机的不重复的整数

可以使用 PHP 的 mt_rand() 函数来产生随机整数，再通过查询数据库来判断该整数是否已存在。下面是一个使用 ThinkPHP 5.1 的例子：

// 产生随机整数
$randInt = mt_rand(1, 10000);

// 查询数据库判断是否已存在
$count = Db::name('table_name')->where('column_name', $randInt)->count();

// 如果已存在，则重新产生随机整数
while ($count > 0) {
    $randInt = mt_rand(1, 10000);
    $count = Db::name('table_name')->where('column_name', $randInt)->count();
}

// 这时 $randInt 就是一个不重复的随机整数

可以根据实际需求调整随机数的范围和查询的表名和列名。

相关问题

用thinkphp 写一个layui分页功能

以下是一个用ThinkPHP 5.1和Layui实现分页功能的示例代码：

在控制器中：

public function index()
{
    $list = Db::name('user')->paginate(10);
    $page = $list->render();
    $this->assign('list', $list);
    $this->assign('page', $page);
    return $this->fetch();
}

在视图文件中：

<table class="layui-table">
  <thead>
    <tr>
      <th>ID</th>
      <th>用户名</th>
      <th>邮箱</th>
    </tr>
  </thead>
  <tbody>
    <?php foreach ($list as $vo): ?>
      <tr>
        <td><?php echo $vo['id']; ?></td>
        <td><?php echo $vo['username']; ?></td>
        <td><?php echo $vo['email']; ?></td>
      </tr>
    <?php endforeach; ?>
  </tbody>
</table>
<div class="layui-box layui-laypage layui-laypage-default">
  <?php echo $page; ?>
</div>

其中，`Db::name('user')->paginate(10)` 用于获取用户列表并进行分页，第一个参数指定每页显示的记录数，这里是10。

`$list->render()` 用于生成分页 HTML 代码。

`$this->assign('list', $list)` 把用户列表赋值给模板变量 `$list`。

`$this->assign('page', $page)` 把分页 HTML 代码赋值给模板变量 `$page`。

最后在视图文件中使用 `foreach` 循环遍历用户列表，并使用 `$page` 变量渲染分页 HTML 代码。

请用thinkphp写一个消息队列的Demo

好的，下面是一个简单的消息队列Demo：

1. 创建消息队列表

首先需要在数据库中创建一个消息队列表，用来存储待处理的消息，可以使用以下SQL语句进行创建：

CREATE TABLE `message_queue` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `content` varchar(255) DEFAULT NULL,
  `status` tinyint(1) unsigned NOT NULL DEFAULT '0',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

2. 配置队列

在ThinkPHP中，可以使用Redis或者AMQP作为消息队列的驱动，这里以Redis作为例子，需要在`config.php`文件中添加以下配置信息：

// Redis配置
'redis' => [
    'type' => 'redis',
    'host' => '127.0.0.1',
    'port' => 6379,
    'password' => '',
    'select' => 0,
    'timeout' => 0,
],
// 消息队列配置
'queue' => [
    'type' => 'redis',
    'host' => '127.0.0.1',
    'port' => 6379,
    'password' => '',
    'select' => 0,
    'timeout' => 0,
    'expire' => 3600,
    'prefix' => 'queue_',
],

3. 定义消息队列处理器

创建一个名为`Queue`的控制器，在其中定义一个`push`方法，用来将消息插入到消息队列中：

class Queue
{
    public function push($content)
    {
        $queue = new \think\queue\Job\Redis([
            'redis' => 'redis',
            'queue' => 'default',
        ]);
        $queue->push('app\\queue\\Job@handle', [
            'content' => $content,
        ]);
        return 'success';
    }
}

其中，`Job@handle`表示具体处理消息的类和方法，需要在`app/queue`目录下创建一个名为`Job`的类，在其中定义一个`handle`方法，用来处理消息：

namespace app\queue;

class Job
{
    public function handle($job, $data)
    {
        // 处理消息
        echo $data['content'];

        // 标记消息为已处理
        $this->updateStatus($job->getId());
    }

    private function updateStatus($id)
    {
        db('message_queue')->where('id', $id)->update(['status' => 1]);
    }
}

4. 插入消息

在需要插入消息的地方调用`Queue`控制器的`push`方法即可将消息插入到消息队列中：

public function send()
{
    $content = 'hello world';
    $result = (new Queue())->push($content);
    echo $result;
}

5. 处理消息

在后台启动消息队列的监听器，用来处理消息，可以使用以下命令：

php think queue:listen --queue default --timeout 1800 --sleep 3

其中，`default`表示队列名，`timeout`表示超时时间，`sleep`表示处理完一条消息后等待的时间。

以上就是一个简单的消息队列Demo，可以根据具体需求进行修改和扩展。