update:同步商品数据到es

.gitignore

@@ -2,4 +2,6 @@ composer.lock
 /yaconf/
 .idea
 .DS_Store
-.project
+.project
\ No newline at end of file
+ROOT_PATH
+logs
\ No newline at end of file

application/modules/Cli/controllers/GoodsToEs.php

+<?php
+
+use App\Base\Cli;
+use \App\Models\goods\mysql\GoodsSku;
+use \App\Services\goods\GoodsService;
+use Api\PhpUtils\Log\DaemonLog;
+use Api\PhpServices\JwUser\JwUser;
+
+/**
+ * 同步商品数据到es
+ * php public/cli.php goodsToEs index
+ * Class GoodsToEsController
+ */
+class GoodsToEsController extends Cli
+{
+    public function IndexAction()
+    {
+        $goodsSkuIds = $this->getGoodsSkuIdList();
+        $this->toEs($goodsSkuIds);
+    }
+
+    private function getGoodsSkuIdList()
+    {
+        return GoodsSku::select("goods_sku_id", []);
+    }
+
+    private function toEs($goodsSkuIds)
+    {
+        if (!empty($goodsSkuIds)) {
+            foreach ($goodsSkuIds as $goodsSkuId) {
+                echo "当前正在同步的商品sku_id: $goodsSkuId \n";
+                GoodsService::updateGoodsInfoToEs($goodsSkuId);
+            }
+        }
+    }
+
+}
\ No newline at end of file

application/modules/Cli/controllers/InitGoodsToEs.php

-<?php
-
-use App\Base\Cli;
-use \App\Models\goods\mysql\GoodsSku;
-
-class InitGoodsToEsController extends Cli
-{
-    /**
-     * php public/cli.php InitGoodsToEs index
-     */
-    public function IndexAction()
-    {
-        $goodsSkuIds = GoodsSku::select("goods_sku_id", ["goods_status" => 1]);
-
-        $request = $this->getRequest();
-        $params = $request->getParams();
-
-        $res = [
-            "data" => $params,
-            "code" => 0
-        ];
-        $response = $this->getResponse();
-        $response->setBody(json_encode($res));
-
-        var_dump($goodsSkuIds);
-//        $this->getAllGoodsSkuId();
-
-    }
-
-    public function getAllGoodsSkuId()
-    {
-        $goodsSkuIds = GoodsSku::select("goods_sku_id", ["goods_status" => 1]);
-        var_dump($goodsSkuIds);
-        exit;
-    }
-}
\ No newline at end of file

application/services/goods/GoodsService.php

@@ -856,7 +856,7 @@ class GoodsService
      * @return array|callable
      * @throws InterfaceException
      */
-    private static function updateGoodsInfoToEs($goodsSkuId)
+    public static function updateGoodsInfoToEs($goodsSkuId)
     {
         $goodsSkuInfoList = GoodsSku::getRecordMaster(["goods_sku_id" => $goodsSkuId]);
         if (!empty($goodsSkuInfoList)) {

public/cli.php

 <?php
+date_default_timezone_set("PRC");
 ini_set("display_errors", "On");//打开错误提示
-ini_set("error_reporting",E_ALL);//显示所有错误
+ini_set("error_reporting", E_ALL);//显示所有错误
 /*
  * cli入口脚本
  * cli 配置文件：conf/cli.ini
@@ -10,27 +11,27 @@ ini_set("error_reporting",E_ALL);//显示所有错误
  * 调用方式：php cli.php controller action "a=1&b=2"
  * 测试脚本：php cli.php test index "a=1&b=2"
  */
-if( !substr(php_sapi_name(), 0, 3) == 'cli' ) {
+if (!substr(php_sapi_name(), 0, 3) == 'cli') {
     die;
 }
-
-define('APPLICATION_PATH', realpath(__DIR__.'/../'));
+define('ROOT_PATH', realpath(__DIR__ . '/../'));
+define('APPLICATION_PATH', realpath(__DIR__ . '/../'));
 require APPLICATION_PATH . '/vendor/autoload.php';
-$application = new Yaf\Application( APPLICATION_PATH . "/conf/cli.ini");
+require APPLICATION_PATH . '/application/library/helper.php';
+$application = new Yaf\Application(APPLICATION_PATH . "/conf/cli.ini");
 
 /**
  * 获取模块/控制器/方法
  */
 $module = "cli";
 $controller = $argv[1] ?? "";
-$method     = $argv[2] ?? "";
-$param      = $argv[3] ?? [];
-if ($param)
-{
+$method = $argv[2] ?? "";
+$param = $argv[3] ?? [];
+if ($param) {
     $param = convertUrlQuery($param);
 }
 
-$application->bootstrap()->getDispatcher()->dispatch( new Yaf\Request\Simple("", $module, $controller,$method,$param) );
+$application->bootstrap()->getDispatcher()->dispatch(new Yaf\Request\Simple("", $module, $controller, $method, $param));
 
 function convertUrlQuery($query)
 {