Commit 64078aa7 authored by hangjun83's avatar hangjun83

财务开票模块更新

parent 50a96127
...@@ -118,11 +118,11 @@ abstract class PlatformAbstractService ...@@ -118,11 +118,11 @@ abstract class PlatformAbstractService
return $this->dataEntriesService->removeEntriesValues($this->getPlatformInfo('id'),$dataKey); return $this->dataEntriesService->removeEntriesValues($this->getPlatformInfo('id'),$dataKey);
} }
public function pushQueue($pushContent, $queueName) public function pushQueue($pushContent, $queueName, $delay = 0)
{ {
if(env('QUEUE_CONNECTION') == 'database'){ if(env('QUEUE_CONNECTION') == 'database'){
app('Illuminate\Contracts\Bus\Dispatcher')->dispatch( app('Illuminate\Contracts\Bus\Dispatcher')->dispatch(
(new QueueJob($pushContent))->onQueue($queueName) (new QueueJob($pushContent))->onQueue($queueName)->delay($delay)
); );
}else{ }else{
SimpleKafka::produerSend($pushContent,$queueName); SimpleKafka::produerSend($pushContent,$queueName);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment