作者 lyh

变更数据

... ... @@ -59,14 +59,11 @@ class GeoWritingsTask extends Command
try {
$geoWritingsModel = new GeoWritings();
$saveData = [
'project_id'=>$info['project_id'],
'type'=>$geoWritingsModel::TYPE_AI_CREATE,
'title'=>$info['title'],
'content'=>$introduction.($images[0] ?? '').PHP_EOL.$main.($images[1] ?? ''),
'content_length'=>strlen($introduction.PHP_EOL.$main),
'uniqid'=>md5(uniqid().$task_id.$info['project_id']),
];
$id = $geoWritingsModel->addReturnId($saveData);
$id = $geoWritingsModel->edit($saveData,['id'=>$info['writings_id']]);
$data = [
'introduction'=>$introduction,
'main'=>$main,
... ... @@ -100,7 +97,7 @@ class GeoWritingsTask extends Command
$task_id = Redis::rpop('geo_writings_task');
}
}else{
$geoWritingsTaskModel->edit(['status'=>1],['id'=>$task_id]);
$geoWritingsTaskModel->edit(['status'=>GeoWritings::STATUS_AI_RUNNING],['id'=>$task_id]);
}
return $task_id;
}
... ...
... ... @@ -116,7 +116,7 @@ class SyncProject extends Command
}
$item->status = NoticeLog::STATUS_SUCCESS;
$item->save();
echo 'success:' . $item['id'] . '执行时间:' . date('Y-m-d H:i:s') . PHP_EOL;
echo 'success:' . $item['id'] . '执行时间:'. 'ordet_id:'. $order_id . date('Y-m-d H:i:s') . PHP_EOL;
}catch (\Exception $e){
echo 'error:' . $item['id'] . $e->getMessage() .' line ' . $e->getLine() . '执行时间:' . PHP_EOL;
errorLog('项目同步失败', $item, $e);
... ...
... ... @@ -49,6 +49,11 @@ class GeoWritingsTaskLogic extends BaseLogic
$id = $this->param['id'];
$this->model->edit($this->param,['id'=>$id]);
}else{
//自动保存一条数据
$writingModel = new GeoWritings();
$this->param['writings_id'] = $writingModel->addReturnId(['project_id'=>$this->param['project_id'],
'type'=>$writingModel::TYPE_AI_CREATE,'status'=>$writingModel::STATUS_AI_WAIT,
'uniqid'=>md5(uniqid().rand(1, 99999).$this->param['project_id'])]);
$id = $this->model->addReturnId($this->param);
}
}catch (\Exception $e){
... ...