update

@@ -6,6 +6,7 @@ use App\Http\Logic\Bside\Blog\BlogLogic;
 use App\Http\Logic\Bside\News\NewsLogic;
 use App\Http\Logic\Bside\Product\ProductLogic;
 use App\Models\Import\ImportTask;
+use App\Models\Mail\Mail;
 use App\Services\ProjectServer;
 use Illuminate\Console\Command;
 use Illuminate\Support\Facades\DB;
@@ -56,6 +57,8 @@ class ProjectImport extends Command
             echo 'date:' . date('Y-m-d H:i:s') . ', task_id: ' . $task->id . ', import fail, error: 文件编码格式错误' . PHP_EOL;
             $task->status = ImportTask::STATUS_COM;//导入完成
             $task->save();
+
+            $this->send_mail($task->user_id, $task->created_at, 0, '文件编码格式错误，仅支持UTF-8和GBK编码格式');
             return true;
         } elseif ($file_code_type === 'GBK') {
             $is_gbk = 1;
@@ -74,6 +77,8 @@ class ProjectImport extends Command
             echo 'date:' . date('Y-m-d H:i:s') . ', task_id: ' . $task->id . ', import fail, error: ' . $e->getMessage() . PHP_EOL;
             $task->status = ImportTask::STATUS_COM;//导入完成
             $task->save();
+
+            $this->send_mail($task->user_id, $task->created_at, 0, '读取文件数据失败');
             return true;
         }
 
@@ -125,6 +130,8 @@ class ProjectImport extends Command
         $task->success_count += $success_count;
         $task->save();
 
+        $this->send_mail($task->user_id, $task->created_at, $success_count, '');
+
         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;
 
         sleep(2);
@@ -143,4 +150,19 @@ class ProjectImport extends Command
         }
         return false;
     }
+
+    //发生站内通知
+    protected function send_mail($user_list, $time, $success_count, $reason)
+    {
+        $title = '导入结果通知';
+        $content = '您于 ' . $time . ' 添加的导入任务已执行完成， 成功导入数据条数：' . $success_count . '。';
+        $reason && $content .= '原因：' . $reason;
+
+        $mail_model = new Mail();
+        $mail_model->add([
+            'user_list' => $mail_model->setUserList($user_list),
+            'title' => $title,
+            'content' => $content
+        ]);
+    }
 }