冲突

App/Crontab/BalanceCrontab.php

@@ -148,6 +148,7 @@ class BalanceCrontab implements JobInterface
                 'keyword2' => ['value'=>date('Y年m月d日',$sendData['end_time'])],
                 'remark' => ['value'=>'欢迎登录「'.$sendData['operators_name'].'」小程序选购心仪的商品。'],
 //                'remark' => ['value'=>'开工红包派发中，最高888元，点击领取', 'color' => '#E3170D'],
+//                'remark' => ['value'=>'做最美的女神，点击领取走心好礼', 'color' => '#E3170D'],
             ]);
             $status = $api_res['response']['errcode']!==0?2:1;  //0无响应 1成功 2失败
             

App/Crontab/SeckillCrontab.php

@@ -0,0 +1,60 @@
+<?php
+
+namespace App\Crontab;
+
+use EasySwoole\Crontab\JobInterface;
+use EasySwoole\Mysqli\QueryBuilder;
+use EasySwoole\ORM\DbManager;
+use App\Models\BalancePushSet;
+use App\Models\ShopGoods;
+use App\Models\SeckillGoods;
+
+
+class SeckillCrontab implements JobInterface
+{
+
+    protected $set; //秒杀库存归还
+
+    public function jobName(): string
+    {
+        // 定时任务的名称
+        return 'SeckillCrontab';
+    }
+
+    public function crontabRule(): string
+    {
+        // 定义执行规则 根据 Crontab 来定义
+        // 每分钟执行一次
+        return '*/1 * * * *';
+    }
+
+    public function run()
+    {
+        // 定时任务的执行逻辑
+        $this->set = BalancePushSet::create()->get()->toArray();
+        //是否启用
+        if($this->set['enable']!=1){
+            return;
+        }
+        $endTime = time();
+        $sql = "SELECT a.`name`,b.active_id,b.operators_id,b.goodsid,b.total FROM ims_superdesk_shop_seckill_active a LEFT JOIN ims_superdesk_shop_seckill_active_operators_goods b ON a.id=b.active_id WHERE a.endtime<{$endTime} AND b.total>0";
+        $queryBuild = new QueryBuilder();
+        $queryBuild->raw($sql);
+        $res_data = DbManager::getInstance()->query($queryBuild, true, 'default')->toArray();
+        foreach($res_data['result'] as $k=>$val){
+            ShopGoods::create()->update([
+                'total' => QueryBuilder::inc(intval($val['total'])),
+            ], ['id' => $val['goodsid']]);
+            SeckillGoods::create()->update([
+                'total' => 0,
+            ], ['active_id' => $val['active_id'], 'operators_id' => $val['operators_id'], 'goodsid' => $val['goodsid']]);
+        }
+    }
+
+    public function onException(\Throwable $throwable)
+    {
+        // 捕获 run 方法内所抛出的异常
+    }
+
+
+}

App/Models/SeckillGoods.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace App\Models;
+
+use EasySwoole\ORM\AbstractModel;
+
+/**
+ * 秒杀商品表
+ * Class WarningBody
+ */
+class SeckillGoods extends AbstractModel
+{
+     /**
+      * @var string 
+      */
+     protected $tableName = 'ims_superdesk_shop_seckill_active_operators_goods';
+     
+}

App/Models/ShopGoods.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace App\Models;
+
+use EasySwoole\ORM\AbstractModel;
+
+/**
+ * 主站商品表
+ * Class WarningBody
+ */
+class ShopGoods extends AbstractModel
+{
+     /**
+      * @var string 
+      */
+     protected $tableName = 'ims_superdesk_shop_goods';
+     
+}

EasySwooleEvent.php

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