update 只在当天有活动开始时调用发消息接口

daemon/Pindan.php

@@ -6,7 +6,7 @@ namespace Daemon;
 
 use Api\PhpServices\Daemon\DaemonServiceInterface;
 use Api\PhpUtils\Log\DaemonLog;
-use App\Services\marketing\MarketingService;
+use App\Models\marketing\mysql\Marketing;
 use Api\PhpServices\Wechat\Msg;
 
 class Pindan implements DaemonServiceInterface
@@ -22,15 +22,21 @@ class Pindan implements DaemonServiceInterface
         }
 
         try{
-            //查询进行中的拼单活动
-            $params['marketing_type'] = 4;//1分销 2团购 3秒杀 4团餐
-            $params['online_status'] = 1;//状态 ， 1启用，2关闭，3 到期
-            $params['activity_status'] = 2;//1 未开始，2进行中，3已结束
-            $params['page'] = 1;
-            $params['page_size'] = 1;
-            $list = MarketingService::marketingList($params);
+            //查询进行中的 今天开始的 拼单活动 --昨天16:40以后开始的活动 视为新上的活动
+            $lastStartTime = date("Y-m-d 16:40:00",strtotime('-1 days'));
+            $now = date("Y-m-d H:i:00");
+            $where['marketing_type'] = 4;
+            $where['online_status'] = 1;
+            $where["start_time[<=]"] = $now;
+            $where["start_time[>]"] = $lastStartTime;
+            $where["end_time[>=]"] = $now;
+            $where['ORDER'] = ["update_time" => "DESC"];
+            $where['LIMIT'] = [0, 1];
+            $list = Marketing::select(["marketing_id", "marketing_name", "marketing_type","start_time", "end_time",
+                    "online_status", "update_time", "create_time"]
+                , $where);
 
-            if(empty($list['result'])) {
+            if(empty($list)) {
                 DaemonLog::info(
                     'DaemonServiceInterface_pindan',
                     'no need to send at'.date('Y-m-d H:i:s')
@@ -47,9 +53,9 @@ class Pindan implements DaemonServiceInterface
             $type = 2; // 1 公众号 2 小程序
             //活动信息
             $params = [
-                self::emojiFilter($list['result'][0]['marketing_name']),
-                $list['result'][0]['create_time'],
-                $list['result'][0]['pindan_desc'] ?: self::DEFAULT_DESC
+                self::emojiFilter($list[0]['marketing_name']),
+                $list[0]['start_time'],
+                $list[0]['pindan_desc'] ?: self::DEFAULT_DESC
             ];
             //发送消息
             DaemonLog::info(