# 营销方案产品折扣保存
# 规则: 0 < 新折扣 < 全部用户基准折扣
# 自动 upsert 到 discount_detail

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

try:
    discountid = params_kw.get('discountid')
    productid = params_kw.get('productid')
    discount_val = params_kw.get('discount')
    base_discount = params_kw.get('base_discount')
    detail_id = params_kw.get('detail_id')

    if not discountid or not productid:
        raise Exception('缺少必要参数')

    # 过滤 NaN/空值
    if discount_val is not None:
        s = str(discount_val).strip().lower()
        if s in ('', 'nan', 'none', 'null'):
            discount_val = None

    user_orgid = await get_userorgid()
    dbname = get_module_dbname('discount')

    # discount为0或空 → 删除明细
    if not discount_val or float(discount_val) == 0:
        if detail_id:
            async with DBPools().sqlorContext(dbname) as sor:
                await sor.D('discount_detail', {'id': detail_id})
            result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': '已移出营销方案', 'type': 'success', 'timeout': 3}}
        else:
            result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': 'ok', 'type': 'success', 'timeout': 3}}
        return result

    new_val = float(discount_val)

    # 验证: 必须大于0
    if new_val <= 0:
        result = {'widgettype': 'Error', 'options': {'title': '折扣无效', 'message': '折扣必须大于0', 'timeout': 5}}
        return result

    # 验证: 不能超过基准折扣
    if base_discount:
        base_val = float(base_discount)
        if new_val >= base_val:
            result = {'widgettype': 'Error', 'options': {'title': '折扣无效', 'message': f'营销折扣({new_val})必须小于基准折扣({base_val})', 'timeout': 5}}
            return result

    # 验证: 不能超过100%（1.0）
    if new_val > 1.0:
        result = {'widgettype': 'Error', 'options': {'title': '折扣无效', 'message': '折扣不能大于1.0', 'timeout': 5}}
        return result

    async with DBPools().sqlorContext(dbname) as sor:
        if detail_id:
            await sor.U('discount_detail', {
                'id': detail_id,
                'discount': new_val
            })
        else:
            await sor.C('discount_detail', {
                'id': getID(),
                'discountid': discountid,
                'resellerid': user_orgid,
                'prodtypeid': None,
                'productid': productid,
                'discount': new_val
            })

    result = {'widgettype': 'Message', 'options': {'title': 'Success', 'message': f'折扣保存成功({new_val})', 'type': 'success', 'timeout': 3}}

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

return result