From 59587a8c317bd23621b3013c61b0621548a33cba Mon Sep 17 00:00:00 2001 From: yumoqing Date: Tue, 30 Jun 2026 16:10:20 +0800 Subject: [PATCH] bugfix --- wwwroot/v1/video/generations/index.dspy | 68 ++++++++++++------------- 1 file changed, 34 insertions(+), 34 deletions(-) diff --git a/wwwroot/v1/video/generations/index.dspy b/wwwroot/v1/video/generations/index.dspy index e9c284d..6d503c8 100644 --- a/wwwroot/v1/video/generations/index.dspy +++ b/wwwroot/v1/video/generations/index.dspy @@ -5,21 +5,21 @@ # # Example request: # { -# "model": "keling-2.1", -# "catelogid": "t2v", -# "prompt": "A beautiful sunset over the ocean", -# "duration": "5s", -# "resolution": "1080p" +# "model": "keling-2.1", +# "catelogid": "t2v", +# "prompt": "A beautiful sunset over the ocean", +# "duration": "5s", +# "resolution": "1080p" # } # # Response (async task): # { -# "id": "vid_xxx", -# "object": "video.generation", -# "model": "keling-2.1", -# "status": "submitted", -# "taskid": "task_xxx", -# "created": 1234567890 +# "id": "vid_xxx", +# "object": "video.generation", +# "model": "keling-2.1", +# "status": "submitted", +# "taskid": "task_xxx", +# "created": 1234567890 # } import json @@ -36,41 +36,41 @@ debug_params('params_kw', params_kw) userid = await get_user() userorgid = await get_userorgid() if userid is None: - debug('need login') - return openai_403() + debug('need login') + return openai_403() # Validate required parameters if not params_kw.model: - d = return_error('Missing required parameter: model') - return json_response(d, status=400) + d = return_error('Missing required parameter: model') + return json_response(d, status=400) if not params_kw.catelogid: - d = return_error('Missing required parameter: catelogid') - return json_response(d, status=400) + d = return_error('Missing required parameter: catelogid') + return json_response(d, status=400) if not params_kw.prompt: - d = return_error('Missing required parameter: prompt') - return json_response(d, status=400) + d = return_error('Missing required parameter: prompt') + return json_response(d, status=400) lctype = params_kw.catelogid env = request._run_ns async with get_sor_context(env, 'llmage') as sor: - # Look up llm by model name and catalog type through llm_api_map - sql = """select distinct a.* from llm a + # Look up llm by model name and catalog type through llm_api_map + sql = """select distinct a.* from llm a join llm_api_map m on a.id = m.llmid join llmcatelog b on m.llmcatelogid = b.id where (b.id = ${lctype}$ OR b.name = ${lctype}$) - and a.model=${model}$ - and a.status = 'published'""" - recs = await sor.sqlExe(sql, { - 'lctype': lctype, - 'model': params_kw.model - }) - if len(recs) == 0: - debug(f'{params_kw.model=} not found for catalog {lctype}') - return openai_400() - params_kw.llmid = recs[0].id + and a.model=${model}$ + and a.status = 'published'""" + recs = await sor.sqlExe(sql, { + 'lctype': lctype, + 'model': params_kw.model + }) + if len(recs) == 0: + debug(f'{params_kw.model=} not found for catalog {lctype}') + return openai_400() + params_kw.llmid = recs[0].id params_kw.llmcatelogid = lctype debug(f'{params_kw.llmid=}') @@ -78,12 +78,12 @@ debug(f'{params_kw.llmid=}') # Check balance f = await checkCustomerBalance(params_kw.llmid, userid, userorgid) if not f: - debug(f'{userid=} balance not enough') - return openai_429() + debug(f'{userid=} balance not enough') + return openai_429() # Generate task ID and attach to params if not params_kw.transno: - params_kw.transno = getID() + params_kw.transno = getID() # Call inference (video/image generation is typically async via callback) return await inference(request, env=env)