2753265edb
## GitHub 同步说明 | 项 | 内容 | |:---|:---| | 仓库 | https://github.com/fnvtk/cunkebao_v3 | | 分支 | develop | | 方向 | 本地 → GitHub（单向 push） | | 是否拉取远程 | 否（未 fetch / pull / merge） | | 是否改本地源文件 | 否（仅 git add/commit，未编辑业务/文档正文） | | 远程基准 | origin/develop @b5b40e8b| | 本批工作区变更 | 999 files, +47622 / -4007 lines | ## 一并推送的本地已有 commit（此前未 push） 1.3aa7ecf8deploy: 官网 ckb.quwanzhi.com 宝塔上线 DNS+SSL+验收文档 2.16a70045fix(官网): 桌面导航仅保留一个留资 CTA 并重新上线 3.dbe7b7aafix(官网): Hero 改为主 CTA 按钮并去掉重复 1200+ 数据条 4.ac82726echore(部署): 五端上线验收46项并统一留资与缓存版本 ## 本 commit 目录统计 | 目录 | 文件数 | 说明 | |:---|---:|:---| | 开发文档/ | 639 | 10、项目管理、未完成项跨仓汇总、五端需求/部署/接口 | | Server/ | 129 | 后端 API、迁移、部署相关 | | Touchkebao/ | 80 | PC 工作台、获客、算力 | | 官网/ | 61 | ckb.quwanzhi.com 静态站与 CTA 迭代 | | Cunkebao/ | 49 | 移动端场景/设置/流量池 | | SuperAdmin/ | 26 | 超管后台 | | .cursor/ | 11 | 规则与 Skill | | 其他 | 14 | docker-compose、.obsidian、.codegraph 等 | ## 重点文件（本地为准） - 开发文档/1、需求/修改/未完成项与跨仓验收汇总.md - 开发文档/10、项目管理/账号密码与登录环境一览.md - 开发文档/10、项目管理/（新建项目管理目录与截图） - 官网/ 全站 + 宝塔上线文档 - 五端上线验收 46 项（见 ac82726e） ## 刻意未上传 - node_modules/、.DS_Store、.smart-env/ - .开发文档_nested_git_backup/ - **/__pycache__/ ## 验收 - 提交页（含本说明）: https://github.com/fnvtk/cunkebao_v3/commit/HEAD - 分支树: https://github.com/fnvtk/cunkebao_v3/tree/develop Co-authored-by: Cursor <cursoragent@cursor.com>
44 lines
1.4 KiB
PHP
44 lines
1.4 KiB
PHP
<?php
|
||
|
||
namespace app\command;
|
||
|
||
use app\cunkebao\service\TrafficPoolDedupeService;
|
||
use think\console\Command;
|
||
use think\console\Input;
|
||
use think\console\Output;
|
||
use think\console\input\Option;
|
||
|
||
/**
|
||
* 流量池同人去重：手机/微信相同 → 合并 master
|
||
*
|
||
* php think traffic_pool:dedupe [--companyId=] [--dry-run]
|
||
*/
|
||
class TrafficPoolDedupeCommand extends Command
|
||
{
|
||
protected function configure()
|
||
{
|
||
$this->setName('traffic_pool:dedupe')
|
||
->setDescription('流量池去重：同 company 内手机/微信相同客资合并')
|
||
->addOption('companyId', null, Option::VALUE_OPTIONAL, '公司 ID，0=全部', 0)
|
||
->addOption('dry-run', null, Option::VALUE_NONE, '仅统计不写入');
|
||
}
|
||
|
||
protected function execute(Input $input, Output $output)
|
||
{
|
||
$companyId = max(0, (int)$input->getOption('companyId'));
|
||
$dryRun = (bool)$input->getOption('dry-run');
|
||
$stats = TrafficPoolDedupeService::run($companyId, $dryRun);
|
||
$output->writeln(sprintf(
|
||
'<info>traffic_pool:dedupe done companyId=%d dryRun=%s groups=%d slaves=%d skipped=%d failed=%d firstError=%s</info>',
|
||
$companyId,
|
||
$dryRun ? 'yes' : 'no',
|
||
$stats['mergedGroups'],
|
||
$stats['mergedSlaves'],
|
||
$stats['skipped'],
|
||
$stats['failed'] ?? 0,
|
||
$stats['firstError'] ?? ''
|
||
));
|
||
return 0;
|
||
}
|
||
}
|