mkm/TaskSystem
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add:封装通用的获取redis实例的logic

Browse Source
This commit is contained in:
chenbo 2023-09-08 12:03:19 +08:00
parent b86c3a0390
commit 70ece3ed15
2 changed files with 2 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
app/adminapi/controller/CompanyController.php
View File

@ -21,6 +21,7 @@ use app\adminapi\logic\auth\AdminLogic;
use app\common\logic\CompanyLogic; use app\common\logic\CompanyLogic;
use app\adminapi\validate\CompanyValidate; use app\adminapi\validate\CompanyValidate;
use app\api\controller\JunziqianController; use app\api\controller\JunziqianController;
use app\common\logic\RedisLogic;
use app\common\model\auth\Admin; use app\common\model\auth\Admin;
use app\common\model\Company; use app\common\model\Company;
use think\cache\driver\Redis; use think\cache\driver\Redis;
@ -210,7 +211,7 @@ class CompanyController extends BaseAdminController
// 修改法人邮箱 // 修改法人邮箱
Db::name('company')->where('id', $params['id'])->update(['master_email' => $email]); Db::name('company')->where('id', $params['id'])->update(['master_email' => $email]);
// 加入缓存中，is_callback用于判断是否获取到异步通知 // 加入缓存中，is_callback用于判断是否获取到异步通知
$this->redis()->set('authentication_company_id_'.$company['id'], json_encode(['company_id'=>$company['id'],'is_callback'=>0, 'timing'=>time()])); RedisLogic::getInstance()->set('authentication_company_id_'.$company['id'], json_encode(['company_id'=>$company['id'],'is_callback'=>0, 'timing'=>time()]));
// return $this->success('认证成功',[],1, 1); // return $this->success('认证成功',[],1, 1);
return $this->success('系统认证中，请稍后刷新页面查看', ['email' => $res->data], 1, 1); return $this->success('系统认证中，请稍后刷新页面查看', ['email' => $res->data], 1, 1);
} else { } else {

10
app/common/controller/BaseLikeAdminController.php
View File

@ -116,14 +116,4 @@ class BaseLikeAdminController extends BaseController
} }
return true; return true;
} }
public function redis()
{
$redisInstance = new \Redis();
$redisInstance->connect(env('redis.host'));
$redisInstance->auth(env('redis.auth'));
return $redisInstance;
}
} }