yumoqing
208625415a
- 将 entcms/wwwroot/* 移到 wwwroot/ - 将 dingdingflow/wwwroot/* 移到 wwwroot/dingdingflow/ - 更新 config.json 使用单一 wwwroot 映射 - 更新 init_any_permissions.py 扫描新路径 - 更新 init_superuser_permissions.py 用法说明 - 废弃 entcms/scripts/load_path.py 和 dingdingflow/scripts/load_path.py - 更新 build.sh 构建步骤 - 更新 README.md 和 docs/architecture.md 目录说明
63 lines
2.1 KiB
Python
63 lines
2.1 KiB
Python
#!/usr/bin/env python3
|
|
# -*- coding: utf-8 -*-
|
|
"""
|
|
DingTalk webhook callback endpoint.
|
|
PUBLIC endpoint (any permission) - DingTalk servers call this when approval status changes.
|
|
|
|
Expected POST body:
|
|
{
|
|
"processInstanceId": "xxx",
|
|
"processCode": "xxx",
|
|
"type": "bpms_instance_change",
|
|
"result": "agree" / "refuse",
|
|
"staffId": "xxx",
|
|
"remark": "optional comment"
|
|
}
|
|
"""
|
|
|
|
result = {'success': False, 'message': 'Invalid callback'}
|
|
|
|
try:
|
|
# DingTalk callback data comes via params_kw (POST body auto-parsed)
|
|
callback_data = {}
|
|
|
|
# params_kw contains the parsed POST body fields
|
|
process_instance_id = params_kw.get('processInstanceId', '')
|
|
callback_type = params_kw.get('type', '')
|
|
callback_result = params_kw.get('result', '')
|
|
staff_id = params_kw.get('staffId', '')
|
|
process_code = params_kw.get('processCode', '')
|
|
remark = params_kw.get('remark', '')
|
|
|
|
# Also handle nested JSON body case where entire body is under a key
|
|
if not process_instance_id:
|
|
body = params_kw.get('body', None)
|
|
if isinstance(body, dict):
|
|
process_instance_id = body.get('processInstanceId', '')
|
|
callback_type = body.get('type', '')
|
|
callback_result = body.get('result', '')
|
|
staff_id = body.get('staffId', '')
|
|
process_code = body.get('processCode', '')
|
|
remark = body.get('remark', '')
|
|
|
|
callback_data = {
|
|
'processInstanceId': process_instance_id,
|
|
'type': callback_type,
|
|
'result': callback_result,
|
|
'staffId': staff_id,
|
|
'processCode': process_code,
|
|
'remark': remark,
|
|
}
|
|
|
|
if not process_instance_id:
|
|
result = {'success': False, 'message': 'Missing processInstanceId'}
|
|
else:
|
|
# Call the handle_dingtalk_callback function registered via load_dingdingflow()
|
|
callback_result_data = await handle_dingtalk_callback(callback_data)
|
|
result = callback_result_data
|
|
|
|
except Exception as e:
|
|
result = {'success': False, 'message': f'Callback processing error: {str(e)}'}
|
|
|
|
return json.dumps(result, ensure_ascii=False, default=str)
|