将Yii控制器动作移动到cron作业中


Moving Yii controller action into cron job

我使用这个站点作为在yii中设置cron作业的指南。

当我将给定值(Value2)从"a"更改为"B"时,我在TableA (update)中的当前控制器动作将执行sql事务以填充我的数据库中的TableB。

下面是我目前用来完成这个任务的代码。这是在控制器A

的更新操作中
$connection = yii::app()->db;
$sql1 = "INSERT INTO TableB (value1, value2, value3)
     VALUES(:val1, :val2, :val3)";
$command=$connection->createCommand($sql1);
$command->bindValue(":val1", $model->tableAId);
$command->bindValue(":val2", 'B');
$command->bindValue(":val3", $model->Attribute2);
$command->execute();

因为我使用bindValue很容易得到我的值输入到不同的表。将此逻辑移到cron作业中,我不知道从哪里开始执行相同的操作。

那么在cron作业中使用类似的代码是否也能工作呢?

public function run($args)
{
    $transactions = TableA::model()
    ->findBySql('SELECT * FROM `TableA` '.
    'WHERE `value2` = A '.
    'AND TO_DAYS(`DateCreated`)+3 < TO_DAYS(NOW())');
    foreach ($transactions as $transaction) {
        $connection = yii::app()->db;
        $sql1 = "INSERT INTO tableB (value1, value2, value3)
             VALUES(:val1, :val2, :val3)";
        $command=$connection->createCommand($sql1);
        $command->bindValue(":val1", $model->tableAId);
        $command->bindValue(":val2", 'B');
        $command->bindValue(":val3", $model->Attribute2);
        $command->execute();
    }
}

我需要在TableB中创建一个新记录,但也更新TableA中的value2从"a"到"B"

我已经尝试运行这个cron作业,但没有得到任何结果,不知道如何去解决它

是否可以使用TableA和TableB模型?

in Controller A:

$model = $this->loadModel();
$model->value2 = 'B';
if ($model->save()) {
   $modelB = new TableB();
   $modelB->value1 = $model->value1;
   $modelB->value2 = $model->value2;
   $modelB->value3 = $model->value3;
   $modelB->save();
}

// find all
$transactions = TableA::model()->findAll(array('condition' => array(
  'value2 = :A',
  new CDbExpression('TO_DAYS(`DateCreated`)+3 < TO_DAYS(NOW())'),
), 'params' => array( ':A' => 'A')));
foreach ($transactions as $transaction) {
    $model->value2 = 'B';
    if ($model->save()) {
        $modelB = new TableB();
        $modelB->value1 = $model->value1;
        $modelB->value2 = $model->value2;
        $modelB->value3 = $model->value3;
        $modelB->save();
    }
}

或者也可以在modelA中创建函数:

public function createB()
{
    $modelB = new TableB();
    $modelB->value1 = $model->value1;
    $modelB->value2 = $model->value2;
    $modelB->value3 = $model->value3;
    $modelB->save();
}

需要的时候调用