diff --git a/app/command/CrmRotateUserCommand.php b/app/command/CrmRotateUserCommand.php
new file mode 100644
index 0000000..5defb24
--- /dev/null
+++ b/app/command/CrmRotateUserCommand.php
@@ -0,0 +1,105 @@
+<?php
+
+namespace app\command;
+
+use app\crm\model\CustomerHis;
+use support\Db;
+use Symfony\Component\Console\Command\Command as SymfonyCommand;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+
+class CrmRotateUserCommand extends SymfonyCommand
+{
+    protected static $defaultName = 'crm:rotate-user';
+    protected static $defaultDescription = '将满足条件的 crm_customer 的 user_id 轮流改为 1、2、3';
+
+    protected function configure()
+    {
+        $this->setHelp('查询 user 表中 status=2 且 corp_id=3 的用户，
+然后查找其关联的 crm_customer 记录，
+按顺序将这些 crm_customer.user_id 轮流设置为 1、2、3。');
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output): int
+    {
+        $corpId = 3;
+        $status = 2;
+        $roundRobinUserIds = [64,63,83,93,118,131,132,143,145,150,156,157,158,160];
+
+        $output->writeln('<info>开始执行 crm:rotate-user</info>');
+
+        try {
+            // 1) 找到 user 表中满足条件的用户ID,派卡离职用户
+            $userRows = Db::table('user')
+                ->where('corp_id', $corpId)
+                ->where('status', $status)
+                ->get(['id','name']);
+
+            $userIds = [];
+            $userNames = [];
+            foreach ($userRows as $row) {
+                $userIds[] = (int)$row->id;
+                $userNames[] = $row->name;
+            }
+
+            if (empty($userIds)) {
+                $output->writeln('<comment>未找到满足条件的用户（status=2 且 corp_id=3）。无需处理。</comment>');
+                return self::SUCCESS;
+            }
+
+            $output->writeln('<info>匹配到用户数：' . count($userIds) .' '. implode(',',$userNames) . '</info>');
+
+            // 2) 查找 crm_customer 中属于这些用户的记录
+            $customers = Db::table('crm_customer')
+                ->whereIn('user_id', $userIds)
+                ->orderBy('id', 'asc')
+                ->get(['id','user_id']);
+
+            if (!$customers || count($customers) === 0) {
+                $output->writeln('<comment>未找到相关的 crm_customer 记录。</comment>');
+                return self::SUCCESS;
+            }
+
+            $output->writeln('<info>需要处理的 crm_customer 数量：' . count($customers) . '</info>');
+
+            // 3) 事务中按顺序轮流设置
+            // 初始化 UID 轮询器
+            $uidRotator = new \app\common\utils\RedisUidRotator('email_parsed_result_20250804');
+            $uidRotator->setUids([64, 63, 83, 93, 118, 131, 132, 143, 145, 150, 156, 157, 158, 160], false);
+
+            Db::connection()->transaction(function () use ($customers, $roundRobinUserIds, $output, $uidRotator) {
+                $assignCount = 0;
+                $targetCount = count($roundRobinUserIds);
+
+                foreach ($customers as $index => $customer) {
+                    // 获取下一个分配的UID
+                    $newUserId = $uidRotator->next();
+                    Db::table('crm_customer')
+                        ->where('id', $customer->id)
+                        ->update(['user_id' => $newUserId]);
+
+                    $his = CustomerHis::create([
+                        'customer_id' => $customer->id,
+                        'user_his' => $customer->user_id,
+                        'user_id' => $newUserId,
+                    ]);
+
+
+                    $assignCount++;
+
+                    if ($assignCount % 500 === 0) {
+                        $output->writeln('<comment>已处理：' . $assignCount . '</comment>');
+                    }
+                }
+
+                $output->writeln('<info>处理完成，共更新 crm_customer：' . $assignCount . ' 条</info>');
+            });
+
+            return self::SUCCESS;
+        } catch (\Throwable $e) {
+            $output->writeln('<error>执行失败：' . $e->getMessage() . '</error>');
+            return self::FAILURE;
+        }
+    }
+}
+