作者 lyh

Merge branch 'develop' of http://47.244.231.31:8099/zhl/globalso-v6 into develop

@@ -63,18 +63,18 @@ class ProjectImport extends Command @@ -63,18 +63,18 @@ class ProjectImport extends Command
63 return true; 63 return true;
64 } 64 }
65 65
  66 + $total_count = 0; //总条数
66 $success_count = 0; //成功导入条数 67 $success_count = 0; //成功导入条数
67 - $count_line = count($line_of_text); //总条数  
68 - if ($count_line > 1) { 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;
@@ -88,10 +88,11 @@ class ProjectImport extends Command @@ -88,10 +88,11 @@ class ProjectImport extends Command
88 } 88 }
89 89
90 $task->status = ImportTask::STATUS_COM;//导入完成 90 $task->status = ImportTask::STATUS_COM;//导入完成
  91 + $task->total_count = $total_count;
91 $task->success_count = $success_count; 92 $task->success_count = $success_count;
92 $task->save(); 93 $task->save();
93 94
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; 95 + 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 96
96 sleep(2); 97 sleep(2);
97 } 98 }
@@ -272,6 +272,16 @@ class NewsCategoryLogic extends BaseLogic @@ -272,6 +272,16 @@ class NewsCategoryLogic extends BaseLogic
272 return $this->success(); 272 return $this->success();
273 } 273 }
274 274
  275 + /**
  276 + * 新闻导入:分类处理
  277 + * @param $project_id
  278 + * @param $user_id
  279 + * @param $category
  280 + * @return string
  281 + * @throws \Exception
  282 + * @author Akun
  283 + * @date 2023/09/20 17:35
  284 + */
275 public function importNewsCategory($project_id,$user_id,$category){ 285 public function importNewsCategory($project_id,$user_id,$category){
276 $return = []; 286 $return = [];
277 287
@@ -256,6 +256,16 @@ class NewsLogic extends BaseLogic @@ -256,6 +256,16 @@ class NewsLogic extends BaseLogic
256 return $this->success(); 256 return $this->success();
257 } 257 }
258 258
  259 + /**
  260 + * 新闻导入
  261 + * @param $project_id
  262 + * @param $user_id
  263 + * @param $data
  264 + * @return bool
  265 + * @throws \Exception
  266 + * @author Akun
  267 + * @date 2023/09/20 17:51
  268 + */
259 public function importNews($project_id, $user_id, $data) 269 public function importNews($project_id, $user_id, $data)
260 { 270 {
261 $category_id = ''; 271 $category_id = '';
@@ -264,6 +274,31 @@ class NewsLogic extends BaseLogic @@ -264,6 +274,31 @@ class NewsLogic extends BaseLogic
264 $newsCategoryLogic = new NewsCategoryLogic(); 274 $newsCategoryLogic = new NewsCategoryLogic();
265 $category_id = $newsCategoryLogic->importNewsCategory($project_id, $user_id, $data[2]); 275 $category_id = $newsCategoryLogic->importNewsCategory($project_id, $user_id, $data[2]);
266 } 276 }
267 - dd($category_id); 277 +
  278 + $news = $this->model->read(['name'=>$data[0]]);
  279 + if(!$news){
  280 + $id = $this->model->addReturnId(
  281 + [
  282 + 'name' => $data[0],
  283 + 'category_id' => $category_id,
  284 + 'text' => $data[4],
  285 + 'remark' => $data[3],
  286 + 'image' => '',//TODO: 远程图片下载本地
  287 + 'seo_title' => $data[6],
  288 + 'seo_keywords' => $data[7],
  289 + 'seo_description' => $data[8],
  290 + 'project_id' => $project_id,
  291 + 'operator_id' => $user_id,
  292 + 'create_id' => $user_id
  293 + ]
  294 + );
  295 + //更新路由
  296 + $route = RouteMap::setRoute($data[0], RouteMap::SOURCE_NEWS, $id, $project_id);
  297 + $this->edit(['url' => $route], ['id' => $id]);
  298 +
  299 + return true;
  300 + }
  301 +
  302 + return false;
268 } 303 }
269 } 304 }