Browse Source

修改发送消息提醒环境限制

kevin_zhangl 3 years ago
parent
commit
ca5c97bf3b
2 changed files with 39 additions and 39 deletions
  1. 3 3
      common/components/SwooleAsyncTimer.php
  2. 36 36
      common/libs/taskQueue/TaskFunc.php

+ 3 - 3
common/components/SwooleAsyncTimer.php

@@ -68,9 +68,9 @@ class SwooleAsyncTimer extends SwooleAsyncTimerComponent implements SocketInterf
             // 初始化备份历史奖金数据表
 //            TaskFunc::initAutoBakBalance();
             // 初始化自动发送钉钉推送消息
-            if (YII_ENV == YII_ENV_PROD) {
-                TaskFunc::initAutoSendDingTalk();
-            }
+//            if (YII_ENV == YII_ENV_PROD) {
+//                TaskFunc::initAutoSendDingTalk();
+//            }
         }
     }
 

+ 36 - 36
common/libs/taskQueue/TaskFunc.php

@@ -45,40 +45,40 @@ class TaskFunc
         print_r('执行到测试任务'.PHP_EOL);
     }
 
-    /**
-     * 初始化自动发送钉钉提醒任务
-     */
-    public static function initAutoSendDingTalk() {
-        // 查看数据库中是否存在未开始的任务,如果没有就添加一个新任务
-        if(!TaskQueue::find()->where('TYPE=:TYPE AND CONTENT=:CONTENT AND STARTED_AT>:STARTED_AT', [':TYPE'=>Queue::TYPE_FUNC, ':CONTENT'=>TaskFunc::class.'::autoSendDingTalkTable', ':STARTED_AT'=>Date::nowTime()])->asArray()->exists()){
-            // 获取站点配置中的备份时间
-            $config = Cache::getSystemConfig();
-            $sendDingTalkTime = $config['sendDingTalkTime']['VALUE'];
-            Queue::instance()->addTask(Queue::TYPE_FUNC, TaskFunc::class.'::autoSendDingTalkTable', [], Queue::LOOP_TYPE_DAY, $sendDingTalkTime, 0);
-        }
-    }
-
-    /**
-     * 自动送钉钉提醒
-     */
-    public static function autoSendDingTalkTable() {
-        $ip = 'https://ng-frontend-api.elken.com';
-//        $ip = 'http://16.163.228.151:8026';
-
-        $curl = curl_init();
-        curl_setopt($curl, CURLOPT_URL, $ip . '/v1/site/send-notice');
-        curl_setopt($curl, CURLOPT_TIMEOUT, 5000);
-        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
-        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
-        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
-        $res = curl_exec($curl);
-        if ($res) {
-            curl_close($curl);
-            LoggerTool::info($res);
-        } else {
-            $error = curl_errno($curl);
-            curl_close($curl);
-            LoggerTool::error($error);
-        }
-    }
+//    /**
+//     * 初始化自动发送钉钉提醒任务
+//     */
+//    public static function initAutoSendDingTalk() {
+//        // 查看数据库中是否存在未开始的任务,如果没有就添加一个新任务
+//        if(!TaskQueue::find()->where('TYPE=:TYPE AND CONTENT=:CONTENT AND STARTED_AT>:STARTED_AT', [':TYPE'=>Queue::TYPE_FUNC, ':CONTENT'=>TaskFunc::class.'::autoSendDingTalkTable', ':STARTED_AT'=>Date::nowTime()])->asArray()->exists()){
+//            // 获取站点配置中的备份时间
+//            $config = Cache::getSystemConfig();
+//            $sendDingTalkTime = $config['sendDingTalkTime']['VALUE'];
+//            Queue::instance()->addTask(Queue::TYPE_FUNC, TaskFunc::class.'::autoSendDingTalkTable', [], Queue::LOOP_TYPE_DAY, $sendDingTalkTime, 0);
+//        }
+//    }
+//
+//    /**
+//     * 自动送钉钉提醒
+//     */
+//    public static function autoSendDingTalkTable() {
+//        $ip = 'https://ng-frontend-api.elken.com';
+////        $ip = 'http://16.163.228.151:8026';
+//
+//        $curl = curl_init();
+//        curl_setopt($curl, CURLOPT_URL, $ip . '/v1/site/send-notice');
+//        curl_setopt($curl, CURLOPT_TIMEOUT, 5000);
+//        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
+//        curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
+//        curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
+//        $res = curl_exec($curl);
+//        if ($res) {
+//            curl_close($curl);
+//            LoggerTool::info($res);
+//        } else {
+//            $error = curl_errno($curl);
+//            curl_close($curl);
+//            LoggerTool::error($error);
+//        }
+//    }
 }