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:05:34 +08:00
parent 8f3c044f41
commit 178203bae6
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
app/api/controller/IndexController.php
View File

@ -14,6 +14,7 @@
namespace app\api\controller; namespace app\api\controller;
use app\api\logic\IndexLogic; use app\api\logic\IndexLogic;
use app\common\logic\RedisLogic;
use app\common\model\Company; use app\common\model\Company;
use app\common\model\company\CompanyProperty; use app\common\model\company\CompanyProperty;
use app\common\model\contract\VehicleContract; use app\common\model\contract\VehicleContract;
@ -431,7 +432,7 @@ class IndexController extends BaseApiController
if ($parmas) { if ($parmas) {
$data=json_decode($parmas['data'],true); $data=json_decode($parmas['data'],true);
// 成功回调标记 // 成功回调标记
$redis = new Redis(['host'=>'redis']); $redis = RedisLogic::getInstance();
$cache = $redis->get('authentication_company_id_'.$parmas['id']); $cache = $redis->get('authentication_company_id_'.$parmas['id']);
if (!empty($cache)) { if (!empty($cache)) {
$data = json_decode($cache, true); $data = json_decode($cache, true);

3
app/task/TaskCompanyAuthNotifyCron.php
View File

@ -2,6 +2,7 @@
namespace app\task; namespace app\task;
use app\common\logic\RedisLogic;
use app\common\model\Company; use app\common\model\Company;
use app\common\model\task\Task as TaskTask; use app\common\model\task\Task as TaskTask;
use think\cache\driver\Redis; use think\cache\driver\Redis;
@ -21,7 +22,7 @@ class TaskCompanyAuthNotifyCron extends Task
*/ */
protected function execute() protected function execute()
{ {
$redis = new Redis(['host'=>'redis']); $redis = RedisLogic::getInstance();
//...具体的任务执行 //...具体的任务执行
$companyIdList = $redis->keys('authentication_company_id_*'); $companyIdList = $redis->keys('authentication_company_id_*');
foreach ($companyIdList as $key) { foreach ($companyIdList as $key) {