|
@@ -132,6 +132,12 @@ class U8Settle extends Command
|
|
|
if(! empty($id)) Record::whereIn("id", $id)->update(['del_time' => 3]);
|
|
if(! empty($id)) Record::whereIn("id", $id)->update(['del_time' => 3]);
|
|
|
});
|
|
});
|
|
|
|
|
|
|
|
|
|
+ // ✅ 处理完所有 chunk 后统一关闭连接
|
|
|
|
|
+ foreach ($connections as $conn) {
|
|
|
|
|
+ if ($conn instanceof U8DatabaseServerService) {
|
|
|
|
|
+ $conn->close();
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
} catch (\Throwable $e) {
|
|
} catch (\Throwable $e) {
|
|
|
Log::channel('apiLog')->info('U8数据更新异常', ['msg' => $e->getMessage()]);
|
|
Log::channel('apiLog')->info('U8数据更新异常', ['msg' => $e->getMessage()]);
|
|
|
}
|
|
}
|