diff --git a/app/api/controller/IndexController.php b/app/api/controller/IndexController.php index d5dc7d216..a493102c7 100755 --- a/app/api/controller/IndexController.php +++ b/app/api/controller/IndexController.php @@ -14,6 +14,7 @@ namespace app\api\controller; use app\api\logic\IndexLogic; +use app\common\logic\RedisLogic; use app\common\model\Company; use app\common\model\company\CompanyProperty; use app\common\model\contract\VehicleContract; @@ -431,7 +432,7 @@ class IndexController extends BaseApiController if ($parmas) { $data=json_decode($parmas['data'],true); // 成功回调标记 - $redis = new Redis(['host'=>'redis']); + $redis = RedisLogic::getInstance(); $cache = $redis->get('authentication_company_id_'.$parmas['id']); if (!empty($cache)) { $data = json_decode($cache, true); diff --git a/app/task/TaskCompanyAuthNotifyCron.php b/app/task/TaskCompanyAuthNotifyCron.php index d9e831a30..d3167f7dc 100644 --- a/app/task/TaskCompanyAuthNotifyCron.php +++ b/app/task/TaskCompanyAuthNotifyCron.php @@ -2,6 +2,7 @@ namespace app\task; +use app\common\logic\RedisLogic; use app\common\model\Company; use app\common\model\task\Task as TaskTask; use think\cache\driver\Redis; @@ -21,7 +22,7 @@ class TaskCompanyAuthNotifyCron extends Task */ protected function execute() { - $redis = new Redis(['host'=>'redis']); + $redis = RedisLogic::getInstance(); //...具体的任务执行 $companyIdList = $redis->keys('authentication_company_id_*'); foreach ($companyIdList as $key) {