Commit 5f699e1c authored by hangjun83's avatar hangjun83

openapi

parent 98c8d381
......@@ -32,6 +32,7 @@ class BideService extends PlatformAbstractService
// yield 循环逐行读取csv内容
while ($generator->valid()) {
$content = $generator->current();
var_dump($content);
app(KafkaService::class)->produerSend(
[
'params' => ['cas' => current($content)],
......@@ -42,7 +43,7 @@ class BideService extends PlatformAbstractService
);
$generator->next();
}
$generator->rewind();
//$generator->rewind();
}
......
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