|
...
|
...
|
@@ -100,6 +100,7 @@ class TestKafkaSend extends BaseController |
|
|
|
} else {
|
|
|
|
// 获取当前taskId
|
|
|
|
$taskId = Cache::inc('taskId');
|
|
|
|
trace('taskId : '.$taskId,'test_consumer');
|
|
|
|
// 缓存taskId与消息ID
|
|
|
|
Cache::set('taskId_'.$taskId,array($res['msgId'],$res['theme']), 300);
|
|
|
|
$data_data = array('type' => $res['type'], 'taskId' => $taskId, 'wxid' => $res['wxid'], 'date' => time(), 'data' => isset($res['data'])?$res['data']:'', 'timeInMillis' => time());
|
...
|
...
|
|