# Upsert折扣明细：有detail_id则更新，无则新增
# 参数: discountid, productid, category_id, discount, detail_id(可选)

result = {'widgettype': 'Message', 'options': {'title': 'Error', 'message': 'Invalid', 'type': 'error'}}

try:
    discountid = params_kw.get('discountid')
    productid = params_kw.get('productid')
    category_id = params_kw.get('category_id')
    discount_val = params_kw.get('discount')
    detail_id = params_kw.get('detail_id')
    
    if not discountid or not productid:
        raise Exception('缺少必要参数: discountid, productid')
    
    # discount为0或空时，如果已有记录则删除
    if not discount_val or float(discount_val) == 0:
        if detail_id:
            dbname = get_module_dbname('discount')
            async with DBPools().sqlorContext(dbname) as sor:
                await sor.D('discount_detail', {'id': detail_id})
            result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': '折扣已清除', 'type': 'success'}}
        else:
            result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': 'ok', 'type': 'success'}}
        return result
    
    dbname = get_module_dbname('discount')
    user_orgid = await get_userorgid()
    
    async with DBPools().sqlorContext(dbname) as sor:
        if detail_id:
            # 更新
            await sor.U('discount_detail', {
                'id': detail_id,
                'discount': float(discount_val)
            })
        else:
            # 新增
            await sor.C('discount_detail', {
                'id': getID(),
                'discountid': discountid,
                'resellerid': user_orgid,
                'prodtypeid': category_id,
                'productid': productid,
                'discount': float(discount_val)
            })
    
    result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': '折扣保存成功', 'type': 'success'}}

except Exception as e:
    debug(f'save_discount error: {e}')
    result['options'] = {'title': 'Error', 'message': f'保存失败: {str(e)}', 'type': 'error'}

return result