user_id = await get_user()
user_orgid = (await get_userorgid()) or '0'
dbname = get_module_dbname('supplychain')

# Only keep known table columns
known_cols = {'contract_name', 'sign_date', 'start_date', 'end_date', 'status', 'default_discount', 'remark', 'supplier_id', 'contract_code'}
data = {}
for k, v in params_kw.items():
	if k in known_cols and v is not None and v != '':
		data[k] = v

data['id'] = getID()
data['resellerid'] = user_orgid
data['created_by'] = user_id
data['created_at'] = timestampstr()
data['updated_at'] = timestampstr()

# Auto-generate contract_code
if not data.get('contract_code'):
	today = curDateString().replace('-', '')
	prefix = f'SC-{today}'
	db = DBPools()
	async with db.sqlorContext(dbname) as sor:
		recs = await sor.sqlExe(
			"SELECT COUNT(*) as cnt FROM supply_contracts WHERE resellerid = ${rid}$ AND contract_code LIKE ${p}$",
			{"rid": user_orgid, "p": prefix + "%"}
		)
		seq = (recs[0].cnt if recs else 0) + 1
	data['contract_code'] = f'{prefix}-{seq:04d}'

try:
	db = DBPools()
	async with db.sqlorContext(dbname) as sor:
		await sor.I(data)
	return json.dumps({'widgettype':'Message','options':{'title':'Success','message':'供应合同创建成功'}}, ensure_ascii=False)
except Exception as e:
	return json.dumps({'widgettype':'Error','options':{'title':'Error','message':f'创建失败: {e}'}}, ensure_ascii=False)