es

application/command.php

@@ -22,4 +22,5 @@ return [
     \app\common\command\OrderExpiredCommand::class,
     \app\admin\command\MobileImportCommand::class,
     \app\admin\command\MobileExportCommand::class,
+    \app\common\command\EsImportCommand::class,
 ];

application/common.php

@@ -8,6 +8,7 @@ use app\common\service\SubService;
 use Cache\Adapter\Redis\RedisCachePool;
 use Cache\Bridge\SimpleCache\SimpleCacheBridge;
 use EasyWeChat\Factory;
+use Elastic\Elasticsearch\ClientBuilder;
 use Symfony\Component\VarExporter\VarExporter;
 use think\Cache;
 use think\exception\HttpResponseException;
@@ -624,4 +625,11 @@ function cache_simple(){
         $instance = new SimpleCacheBridge($pool);
     }
     return $instance;
+}
+function es(){
+    static $es;
+    if(!$es){
+        $es= ClientBuilder::create()->build();
+    }
+    return $es;
 }

application/common/command/EsImportCommand.php

@@ -0,0 +1,45 @@
+<?php
+namespace app\common\command;
+
+use app\admin\command\Api\library\Builder;
+use app\api\controller\AdminAuth;
+use app\api\controller\AdminCoupon;
+use app\api\controller\AdminOrder;
+use app\api\controller\AdminUser;
+use app\api\controller\CommentController;
+use app\api\controller\Common;
+use app\api\controller\Ems;
+use app\api\controller\InfoController;
+use app\api\controller\Knowledge;
+use app\api\controller\NotificationController;
+use app\api\controller\Sender;
+use app\api\controller\SenderOrderController;
+use app\api\controller\Sms;
+use app\api\controller\Token;
+use app\api\controller\User;
+use app\api\controller\UserAddressController;
+use app\api\controller\UserCouponController;
+use app\api\controller\UserMoneyController;
+use app\api\controller\UserOrder;
+use app\api\controller\Validate;
+use app\common\model\Mobile;
+use app\common\model\UserRule;
+use think\console\Command;
+use think\console\Input;
+use think\console\Output;
+use think\Db;
+
+class EsImportCommand extends Command{
+    protected function configure()
+    {
+        $this->setName('es:import')->setDescription('test');
+    }
+
+    protected function execute(Input $input, Output $output)
+    {
+        dd(es());
+        Mobile::where('type',1)->chunk(100,function ($mobile){
+
+        });
+    }
+}

application/service/EsService.php

@@ -0,0 +1,6 @@
+<?php
+namespace app\service;
+
+class EsService{
+
+}