|
|
@@ -143,14 +143,12 @@ class DeepSeekController extends BaseController
|
|
|
// 判断是否有待更新数据,有则查询
|
|
|
$ids = Redis::smembers($redis_key);
|
|
|
if (count($ids) > 0) {
|
|
|
- \Log::info('有更新数据,开始查询');
|
|
|
$count = DB::table('mp_chapter_paragraph_audios')->whereIn('id', $ids)->where(function($query) {
|
|
|
return $query->where('generate_status', '!=', '制作中')->orWhere('error_msg', '!=', '');
|
|
|
})->count('id');
|
|
|
|
|
|
// 如果有更新数据,则发送消息
|
|
|
if ($count > 0) {
|
|
|
- \Log::info("message: {$count}条数据更新");
|
|
|
// 查询更新后的信息
|
|
|
$paragraph_urls = DB::table('mp_chapter_paragraph_audios')->where('bid', $bid)->where('version_id', $version_id)
|
|
|
->where('cid', $cid)->where(function($query) {
|
|
|
@@ -163,7 +161,6 @@ class DeepSeekController extends BaseController
|
|
|
foreach ($paragraph_urls as $item) {
|
|
|
$rem_ids[] = getProp($item, 'id');
|
|
|
}
|
|
|
- \Log::info("rem_ids: ".json_encode($rem_ids));
|
|
|
|
|
|
// 发送消息
|
|
|
$this->sendEvent([
|
|
|
@@ -176,8 +173,7 @@ class DeepSeekController extends BaseController
|
|
|
]);
|
|
|
|
|
|
// 删除有数据的id
|
|
|
- $result = Redis::srem($redis_key, $rem_ids);
|
|
|
- \Log::info("删除成功: ".$result);
|
|
|
+ Redis::srem($redis_key, $rem_ids);
|
|
|
}
|
|
|
}
|
|
|
|
lh