定时更新商品表数据到ES搜索引擎中

App/Crontab/ElasticSearchGoodsCrontab.php

@@ -0,0 +1,85 @@
+<?php
+
+namespace App\Crontab;
+
+use EasySwoole\Crontab\JobInterface;
+use App\Com\SmtpSend;
+use EasySwoole\EasySwoole\Config;
+use App\Models\WarningBody;
+use EasySwoole\Mysqli\QueryBuilder;
+use EasySwoole\ORM\DbManager;
+use EasySwoole\EasySwoole\Logger;
+
+/**
+ * 任务说明：每10分钟抓取30分钟内更新的商品内容，
+ * 使用福利api提供的接口推送到Es搜索引擎中
+ */
+class ElasticSearchGoodsCrontab implements JobInterface
+{
+    public function jobName(): string
+    {
+        // 定时任务的名称
+        return 'ElasticSearchGoodsCrontab';
+    }
+
+    public function crontabRule(): string
+    {
+        // 定义执行规则 根据 Crontab 来定义
+        // 这里是每10分钟执行 1 次
+        return '*/10 * * * *';
+    }
+
+    public function run()
+    {
+        //定时任务的执行逻辑
+        $welfare_api_set = Config::getInstance()->getConf('WELFARE_API');
+        $goods = $this->getUpdateGoods();
+        foreach($goods as $key=>$value){
+            $res = $this->http_request(
+                $welfare_api_set['url'],
+                ['goodsid'=>$value['id'],'goods_body'=>json_encode($value)]
+            );
+            //返回内容写入日志
+            Logger::getInstance()->notice("商品ID{$value['id']}导入结果:{$res}\n");
+        }
+        
+    }
+
+    //获取30分钟内更新过的商品记录
+    protected function getUpdateGoods()
+    {
+        $where = ' g.`updatetime`>'.(time()-1800);    //30分钟内更新的商品
+            $que_sql = "SELECT * FROM ims_superdesk_shop_goods g 
+            WHERE {$where};
+            ";
+        $queryBuild = new QueryBuilder();
+        $queryBuild->raw($que_sql);
+        $res_data = DbManager::getInstance()->query($queryBuild, true, 'default')->toArray();
+        return $res_data['result'];
+    }
+
+
+    /**
+     * http请求
+     * @param $url 请求地址
+     * @param $data 数组内容
+     * @return String 请求返回原生数据
+     */
+    protected function http_rquest($url,$data){
+        $opts = array(
+            'http' => array(
+                'method' => 'POST',
+                'content' => http_build_query($data),
+            )
+        );
+        $context = stream_context_create($opts);
+        $response = file_get_contents($url,false,$context);
+        return $response;
+    }
+
+
+    public function onException(\Throwable $throwable)
+    {
+        // 捕获 run 方法内所抛出的异常
+    }
+}

EasySwooleEvent.php

@@ -12,6 +12,7 @@ use App\Crontab\XcxWarningCrontab;
 use EasySwoole\ORM\DbManager;
 use EasySwoole\ORM\Db\Connection;
 use EasySwoole\ORM\Db\Config;
+use App\Crontab\ElasticSearchGoodsCrontab;
 
 class EasySwooleEvent implements Event
 {
@@ -64,6 +65,7 @@ class EasySwooleEvent implements Event
 
         // 注册定时任务
         $crontab->register(new BalanceCrontab());
+        $crontab->register(new ElasticSearchGoodsCrontab());
         $crontab->attachToServer(ServerManager::getInstance()->getSwooleServer());
 
     }