فهرست منبع

Fix bug of queue module

Wan Xin 9 سال پیش
والد
کامیت
70a7d0024f
2فایلهای تغییر یافته به همراه3 افزوده شده و 1 حذف شده
  1. 2 0
      core/framework/libraries/model.php
  2. 1 1
      queue/control/index.php

+ 2 - 0
core/framework/libraries/model.php

@@ -669,6 +669,8 @@ class ModelDb
      	static $_cache = array();
 		$sql = $this->buildSelectSql($options);
 
+        Log::record("Select Sql: ".$sql, Log::ERR);
+
         //if ($options['cache'] !== false)
         if ($options['cache'] === true)
         {

+ 1 - 1
queue/control/index.php

@@ -22,7 +22,7 @@ class indexControl
             $list_key = $worker->scan();
             if (!empty($list_key) && is_array($list_key)) {
                 foreach ($list_key as $key) {
-                    $content = $worker->pop($key);
+                    $content = $worker->pop($key, time());
                     if (empty($content)) continue;
                     $method = key($content);
                     $arg = current($content);