在tp框架中往往需要定义一些命令去大批量的操作行为,直接在控制器中会有超时报错的情况,而且也会很慢,所以就需要使用到tp里的自定义命令行来完成这些操作行为。
比如:现在有一张表数据有上百万,要更新表中某个字段的值就可以使用自定义命令
1、建立命令类文件,新建application/index/command/Test.php
<?php
declare (strict_types = 1);
namespace app\index\command;
use think\console\Command;
use think\console\Input;
use think\console\input\Argument;
use think\console\input\Option;
use think\console\Output;
use think\facade\Db;
use think\Exception;
class Test extends Command
{
protected function configure()
{
// 指令配置
$this->setName('test')
->setDescription('the test command');
}
protected function execute(Input $input, Output $output)
{
ini_set('memory_limit', '1024M');
$output->writeln('********** 同步开始 **********');
$this->updatePayDepartmentID(); // 更新方法
$output->writeln('********** 同步结束 **********');
}
protected function updatePayDepartmentID() {
}
}
updatePayDepartmentID方法,我是需要更新用户ID,每次更新5000条,一直更新所有为止
protected function updatePayDepartmentID() {
// 查询出第一条ID
$ids = Db::table('table_name')->order('ID ASC')->limit(1)->select()->toArray();
$id = $ids[0]['ID'];
$num = $id + 5000; // 5000更新一次
while (1) {
try {
$data = Db::table('table_name')->where('ID','>=', $id)->where('ID','<=',$num)->select()->toArray();
if(!$data){
exit('没了吧1');
}
foreach($data as $k=>$v){
// 根据旧用户ID 更换新用户ID
$user = Db::table('table_user')->where('xsc_id', $v['Xsc_ID'])->value('id');
$userID = empty($user) ? 0: $user;
$res = Db::table('table_name')->where('ID', $v['ID'])->update(['user_ID'=>$userID]);
echo $v['ID']."\n";
}
$id = $id + 5000;
$num = $num + 5000;
} catch (Exception $e) {
echo $e->getMessage()."\n";
break;
}
}
}
2、配置console.php文件,目录在application/config/console.php(tp不同版本,配置文件不一样)这个是thinkphp6的配置
<?php
// +----------------------------------------------------------------------
// | 控制台配置
// +----------------------------------------------------------------------
return [
// 指令定义
'commands' => [
// 更新erp用户ID
'test' => \app\index\command\Test::class,
],
];
4、打开cmd命令窗口切换目录到站点根目录,然后执行
php think test ,效果如下,会一直输出更新过的数据ID