|
@@ -64,17 +64,17 @@ class ProjectImport extends Command |
|
@@ -64,17 +64,17 @@ class ProjectImport extends Command |
|
64
|
}
|
64
|
}
|
|
65
|
|
65
|
|
|
66
|
$success_count = 0; //成功导入条数
|
66
|
$success_count = 0; //成功导入条数
|
|
67
|
- $count_line = count($line_of_text); //总条数
|
|
|
|
68
|
- if ($count_line > 1) {
|
67
|
+ $total_count = 0; //总条数
|
|
|
|
68
|
+ if (count($line_of_text) > 1) {
|
|
69
|
$task->status = ImportTask::STATUS_ING;//导入中
|
69
|
$task->status = ImportTask::STATUS_ING;//导入中
|
|
70
|
- $task->total_count = $count_line - 1;
|
|
|
|
71
|
$task->save();
|
70
|
$task->save();
|
|
72
|
|
71
|
|
|
73
|
//设置数据库
|
72
|
//设置数据库
|
|
74
|
$project = ProjectServer::useProject($task->project_id);
|
73
|
$project = ProjectServer::useProject($task->project_id);
|
|
75
|
if ($project) {
|
74
|
if ($project) {
|
|
76
|
foreach ($line_of_text as $k => $v) {
|
75
|
foreach ($line_of_text as $k => $v) {
|
|
77
|
- if ($k > 0) {
|
76
|
+ if ($k > 0 && $v) {
|
|
|
|
77
|
+ $total_count += 1;
|
|
78
|
if ($task->type == ImportTask::TYPE_NEWS) {
|
78
|
if ($task->type == ImportTask::TYPE_NEWS) {
|
|
79
|
if ((new NewsLogic())->importNews($task->project_id, $task->user_id, $v)) {
|
79
|
if ((new NewsLogic())->importNews($task->project_id, $task->user_id, $v)) {
|
|
80
|
$success_count += 1;
|
80
|
$success_count += 1;
|
|
@@ -91,7 +91,7 @@ class ProjectImport extends Command |
|
@@ -91,7 +91,7 @@ class ProjectImport extends Command |
|
91
|
$task->success_count = $success_count;
|
91
|
$task->success_count = $success_count;
|
|
92
|
$task->save();
|
92
|
$task->save();
|
|
93
|
|
93
|
|
|
94
|
- echo 'date:' . date('Y-m-d H:i:s') . ', task_id: ' . $task->id . ', import end, total count: ' . ($count_line - 1) . ', success count: ' . $success_count . PHP_EOL;
|
94
|
+ echo 'date:' . date('Y-m-d H:i:s') . ', task_id: ' . $task->id . ', import end, total count: ' . $total_count . ', success count: ' . $success_count . PHP_EOL;
|
|
95
|
|
95
|
|
|
96
|
sleep(2);
|
96
|
sleep(2);
|
|
97
|
}
|
97
|
}
|