diff --git a/wwwroot/api/distribution_agreement_items_create.dspy b/wwwroot/api/distribution_agreement_items_create.dspy index 1077d72..efcb127 100644 --- a/wwwroot/api/distribution_agreement_items_create.dspy +++ b/wwwroot/api/distribution_agreement_items_create.dspy @@ -1,2 +1,23 @@ -result = await create_distribution_agreement_items(request, params_kw) -return json.loads(result) if isinstance(result, str) else result +result = {'widgettype': 'Message', 'options': {'title': 'Error', 'message': 'Invalid', 'type': 'error'}} + +try: + user_id = await get_user() + user_orgid = (await get_userorgid()) or '0' + dbname = get_module_dbname('supplychain') + + data = dict(params_kw) + data['id'] = getID() + data['resellerid'] = user_orgid + data['created_by'] = user_id + data['created_at'] = timestampstr() + data['updated_at'] = timestampstr() + + async with DBPools().sqlorContext(dbname) as sor: + await sor.C('distribution_agreement_items', data) + + result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': '分销协议项目创建成功', 'type': 'success'}} + +except Exception as e: + result['options'] = {'title': 'Error', 'message': '创建失败: ' + str(e), 'type': 'error'} + +return json.dumps(result, ensure_ascii=False) diff --git a/wwwroot/api/distribution_agreements_create.dspy b/wwwroot/api/distribution_agreements_create.dspy index 7b4550a..8a5c0d2 100644 --- a/wwwroot/api/distribution_agreements_create.dspy +++ b/wwwroot/api/distribution_agreements_create.dspy @@ -1,2 +1,23 @@ -result = await create_distribution_agreements(request, params_kw) -return json.loads(result) if isinstance(result, str) else result +result = {'widgettype': 'Message', 'options': {'title': 'Error', 'message': 'Invalid', 'type': 'error'}} + +try: + user_id = await get_user() + user_orgid = (await get_userorgid()) or '0' + dbname = get_module_dbname('supplychain') + + data = dict(params_kw) + data['id'] = getID() + data['resellerid'] = user_orgid + data['created_by'] = user_id + data['created_at'] = timestampstr() + data['updated_at'] = timestampstr() + + async with DBPools().sqlorContext(dbname) as sor: + await sor.C('distribution_agreements', data) + + result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': '分销协议创建成功', 'type': 'success'}} + +except Exception as e: + result['options'] = {'title': 'Error', 'message': '创建失败: ' + str(e), 'type': 'error'} + +return json.dumps(result, ensure_ascii=False) diff --git a/wwwroot/api/platform_supply_products_create.dspy b/wwwroot/api/platform_supply_products_create.dspy index 8789bb8..ec27e15 100644 --- a/wwwroot/api/platform_supply_products_create.dspy +++ b/wwwroot/api/platform_supply_products_create.dspy @@ -1,5 +1,23 @@ -create_func = create_platform_supply_products -if create_func is None: - return json.dumps({"status": "error", "message": "create_platform_supply_products not registered"}) -result = await create_func(request, params_kw) -return result +result = {'widgettype': 'Message', 'options': {'title': 'Error', 'message': 'Invalid', 'type': 'error'}} + +try: + user_id = await get_user() + user_orgid = (await get_userorgid()) or '0' + dbname = get_module_dbname('supplychain') + + data = dict(params_kw) + data['id'] = getID() + data['resellerid'] = user_orgid + data['created_by'] = user_id + data['created_at'] = timestampstr() + data['updated_at'] = timestampstr() + + async with DBPools().sqlorContext(dbname) as sor: + await sor.C('platform_supply_products', data) + + result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': '平台供应产品创建成功', 'type': 'success'}} + +except Exception as e: + result['options'] = {'title': 'Error', 'message': '创建失败: ' + str(e), 'type': 'error'} + +return json.dumps(result, ensure_ascii=False) diff --git a/wwwroot/api/platform_supply_relations_create.dspy b/wwwroot/api/platform_supply_relations_create.dspy index 059df5c..90cb4fe 100644 --- a/wwwroot/api/platform_supply_relations_create.dspy +++ b/wwwroot/api/platform_supply_relations_create.dspy @@ -1,5 +1,23 @@ -create_func = create_platform_supply_relations -if create_func is None: - return json.dumps({"status": "error", "message": "create_platform_supply_relations not registered"}) -result = await create_func(request, params_kw) -return result +result = {'widgettype': 'Message', 'options': {'title': 'Error', 'message': 'Invalid', 'type': 'error'}} + +try: + user_id = await get_user() + user_orgid = (await get_userorgid()) or '0' + dbname = get_module_dbname('supplychain') + + data = dict(params_kw) + data['id'] = getID() + data['resellerid'] = user_orgid + data['created_by'] = user_id + data['created_at'] = timestampstr() + data['updated_at'] = timestampstr() + + async with DBPools().sqlorContext(dbname) as sor: + await sor.C('platform_supply_relations', data) + + result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': '平台供应关系创建成功', 'type': 'success'}} + +except Exception as e: + result['options'] = {'title': 'Error', 'message': '创建失败: ' + str(e), 'type': 'error'} + +return json.dumps(result, ensure_ascii=False) diff --git a/wwwroot/api/product_supplier_mapping_create.dspy b/wwwroot/api/product_supplier_mapping_create.dspy index 1563cfe..1f0ba98 100644 --- a/wwwroot/api/product_supplier_mapping_create.dspy +++ b/wwwroot/api/product_supplier_mapping_create.dspy @@ -1,5 +1,23 @@ -create_func = create_product_supplier_mapping -if create_func is None: - return json.dumps({"status": "error", "message": "create_product_supplier_mapping not registered"}) -result = await create_func(request, params_kw) -return result +result = {'widgettype': 'Message', 'options': {'title': 'Error', 'message': 'Invalid', 'type': 'error'}} + +try: + user_id = await get_user() + user_orgid = (await get_userorgid()) or '0' + dbname = get_module_dbname('supplychain') + + data = dict(params_kw) + data['id'] = getID() + data['resellerid'] = user_orgid + data['created_by'] = user_id + data['created_at'] = timestampstr() + data['updated_at'] = timestampstr() + + async with DBPools().sqlorContext(dbname) as sor: + await sor.C('product_supplier_mapping', data) + + result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': '产品供应商映射创建成功', 'type': 'success'}} + +except Exception as e: + result['options'] = {'title': 'Error', 'message': '创建失败: ' + str(e), 'type': 'error'} + +return json.dumps(result, ensure_ascii=False) diff --git a/wwwroot/api/sales_ledger_create.dspy b/wwwroot/api/sales_ledger_create.dspy index 894635d..7b9471c 100644 --- a/wwwroot/api/sales_ledger_create.dspy +++ b/wwwroot/api/sales_ledger_create.dspy @@ -1,9 +1,23 @@ -import json -from ahserver.serverenv import ServerEnv -env = ServerEnv() -create_func = getattr(env, 'create_sales_ledger', None) -if create_func is None: - print(json.dumps({"status": "error", "message": "create_sales_ledger function not found"})) -else: - result = await create_func(request, params_kw) - print(result) +result = {'widgettype': 'Message', 'options': {'title': 'Error', 'message': 'Invalid', 'type': 'error'}} + +try: + user_id = await get_user() + user_orgid = (await get_userorgid()) or '0' + dbname = get_module_dbname('supplychain') + + data = dict(params_kw) + data['id'] = getID() + data['resellerid'] = user_orgid + data['created_by'] = user_id + data['created_at'] = timestampstr() + data['updated_at'] = timestampstr() + + async with DBPools().sqlorContext(dbname) as sor: + await sor.C('sales_ledger', data) + + result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': '销售台账创建成功', 'type': 'success'}} + +except Exception as e: + result['options'] = {'title': 'Error', 'message': '创建失败: ' + str(e), 'type': 'error'} + +return json.dumps(result, ensure_ascii=False) diff --git a/wwwroot/api/sub_distributors_create.dspy b/wwwroot/api/sub_distributors_create.dspy index 07e71c3..769d92f 100644 --- a/wwwroot/api/sub_distributors_create.dspy +++ b/wwwroot/api/sub_distributors_create.dspy @@ -1,2 +1,23 @@ -result = await create_sub_distributors(request, params_kw) -return json.loads(result) if isinstance(result, str) else result +result = {'widgettype': 'Message', 'options': {'title': 'Error', 'message': 'Invalid', 'type': 'error'}} + +try: + user_id = await get_user() + user_orgid = (await get_userorgid()) or '0' + dbname = get_module_dbname('supplychain') + + data = dict(params_kw) + data['id'] = getID() + data['resellerid'] = user_orgid + data['created_by'] = user_id + data['created_at'] = timestampstr() + data['updated_at'] = timestampstr() + + async with DBPools().sqlorContext(dbname) as sor: + await sor.C('sub_distributors', data) + + result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': '分销商创建成功', 'type': 'success'}} + +except Exception as e: + result['options'] = {'title': 'Error', 'message': '创建失败: ' + str(e), 'type': 'error'} + +return json.dumps(result, ensure_ascii=False) diff --git a/wwwroot/api/sub_resellers_create.dspy b/wwwroot/api/sub_resellers_create.dspy index acdae72..2b48165 100644 --- a/wwwroot/api/sub_resellers_create.dspy +++ b/wwwroot/api/sub_resellers_create.dspy @@ -1,9 +1,23 @@ -import json -from ahserver.serverenv import ServerEnv -env = ServerEnv() -create_func = getattr(env, 'create_sub_resellers', None) -if create_func is None: - print(json.dumps({"status": "error", "message": "create_sub_resellers function not found"})) -else: - result = await create_func(request, params_kw) - print(result) +result = {'widgettype': 'Message', 'options': {'title': 'Error', 'message': 'Invalid', 'type': 'error'}} + +try: + user_id = await get_user() + user_orgid = (await get_userorgid()) or '0' + dbname = get_module_dbname('supplychain') + + data = dict(params_kw) + data['id'] = getID() + data['resellerid'] = user_orgid + data['created_by'] = user_id + data['created_at'] = timestampstr() + data['updated_at'] = timestampstr() + + async with DBPools().sqlorContext(dbname) as sor: + await sor.C('sub_resellers', data) + + result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': '经销商创建成功', 'type': 'success'}} + +except Exception as e: + result['options'] = {'title': 'Error', 'message': '创建失败: ' + str(e), 'type': 'error'} + +return json.dumps(result, ensure_ascii=False) diff --git a/wwwroot/api/suppliers_create.dspy b/wwwroot/api/suppliers_create.dspy index 28d402c..c558f81 100644 --- a/wwwroot/api/suppliers_create.dspy +++ b/wwwroot/api/suppliers_create.dspy @@ -1,9 +1,23 @@ -import json -from ahserver.serverenv import ServerEnv -env = ServerEnv() -create_func = getattr(env, 'create_suppliers', None) -if create_func is None: - print(json.dumps({"status": "error", "message": "create_suppliers function not found"})) -else: - result = await create_func(request, params_kw) - print(result) +result = {'widgettype': 'Message', 'options': {'title': 'Error', 'message': 'Invalid', 'type': 'error'}} + +try: + user_id = await get_user() + user_orgid = (await get_userorgid()) or '0' + dbname = get_module_dbname('supplychain') + + data = dict(params_kw) + data['id'] = getID() + data['resellerid'] = user_orgid + data['created_by'] = user_id + data['created_at'] = timestampstr() + data['updated_at'] = timestampstr() + + async with DBPools().sqlorContext(dbname) as sor: + await sor.C('suppliers', data) + + result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': '供应商创建成功', 'type': 'success'}} + +except Exception as e: + result['options'] = {'title': 'Error', 'message': '创建失败: ' + str(e), 'type': 'error'} + +return json.dumps(result, ensure_ascii=False) diff --git a/wwwroot/api/supply_contract_items_create.dspy b/wwwroot/api/supply_contract_items_create.dspy index 6485fb4..a98271f 100644 --- a/wwwroot/api/supply_contract_items_create.dspy +++ b/wwwroot/api/supply_contract_items_create.dspy @@ -1,2 +1,23 @@ -result = await create_supply_contract_items(request, params_kw) -return json.loads(result) if isinstance(result, str) else result +result = {'widgettype': 'Message', 'options': {'title': 'Error', 'message': 'Invalid', 'type': 'error'}} + +try: + user_id = await get_user() + user_orgid = (await get_userorgid()) or '0' + dbname = get_module_dbname('supplychain') + + data = dict(params_kw) + data['id'] = getID() + data['resellerid'] = user_orgid + data['created_by'] = user_id + data['created_at'] = timestampstr() + data['updated_at'] = timestampstr() + + async with DBPools().sqlorContext(dbname) as sor: + await sor.C('supply_contract_items', data) + + result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': '供应合同项目创建成功', 'type': 'success'}} + +except Exception as e: + result['options'] = {'title': 'Error', 'message': '创建失败: ' + str(e), 'type': 'error'} + +return json.dumps(result, ensure_ascii=False) diff --git a/wwwroot/api/supply_contracts_create.dspy b/wwwroot/api/supply_contracts_create.dspy index 84d3735..0006684 100644 --- a/wwwroot/api/supply_contracts_create.dspy +++ b/wwwroot/api/supply_contracts_create.dspy @@ -1,2 +1,23 @@ -result = await create_supply_contracts(request, params_kw) -return json.loads(result) if isinstance(result, str) else result +result = {'widgettype': 'Message', 'options': {'title': 'Error', 'message': 'Invalid', 'type': 'error'}} + +try: + user_id = await get_user() + user_orgid = (await get_userorgid()) or '0' + dbname = get_module_dbname('supplychain') + + data = dict(params_kw) + data['id'] = getID() + data['resellerid'] = user_orgid + data['created_by'] = user_id + data['created_at'] = timestampstr() + data['updated_at'] = timestampstr() + + async with DBPools().sqlorContext(dbname) as sor: + await sor.C('supply_contracts', data) + + result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': '供应合同创建成功', 'type': 'success'}} + +except Exception as e: + result['options'] = {'title': 'Error', 'message': '创建失败: ' + str(e), 'type': 'error'} + +return json.dumps(result, ensure_ascii=False) diff --git a/wwwroot/api/supplychain_accounting_create.dspy b/wwwroot/api/supplychain_accounting_create.dspy index 229ef7b..b88008a 100644 --- a/wwwroot/api/supplychain_accounting_create.dspy +++ b/wwwroot/api/supplychain_accounting_create.dspy @@ -1,24 +1,23 @@ -import json -from appPublic.uniqueID import getID -from datetime import datetime +result = {'widgettype': 'Message', 'options': {'title': 'Error', 'message': 'Invalid', 'type': 'error'}} -async def main(request, params_kw): - """Create a new supplychain_accounting record.""" +try: user_id = await get_user() - user_orgid = await get_userorgid() + user_orgid = (await get_userorgid()) or '0' dbname = get_module_dbname('supplychain') - data = params_kw.get("data", "{}") - if isinstance(data, str): - data = json.loads(data) + data = dict(params_kw) + data['id'] = getID() + data['resellerid'] = user_orgid + data['created_by'] = user_id + data['created_at'] = timestampstr() + data['updated_at'] = timestampstr() - data["id"] = getID() - data["resellerid"] = user_orgid - data["created_by"] = user_id - data["created_at"] = datetime.now().strftime("%Y-%m-%d %H:%M:%S") + async with DBPools().sqlorContext(dbname) as sor: + await sor.C('supplychain_accounting', data) - config = getConfig(".") - DBPools(config.databases) - async with db.sqlorContext(dbname) as sor: - await sor.C("supplychain_accounting", data) - return json.dumps({"status": "ok", "data": data}) + result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': '供应链记账创建成功', 'type': 'success'}} + +except Exception as e: + result['options'] = {'title': 'Error', 'message': '创建失败: ' + str(e), 'type': 'error'} + +return json.dumps(result, ensure_ascii=False)