#!/usr/bin/env python3 # -*- coding: utf-8 -*- """List approval steps""" import json result = {'success': False, 'rows': [], 'total': 0} try: dbname = get_module_dbname('workflow_approval') workflow_id = params_kw.get('workflow_id', '') sql = "SELECT id, workflow_id, step_name, step_number as step_order, approver_role as approver_type, approver_id as approver_value, description, timeout_hours FROM approval_step" ns = { 'page': int(params_kw.get('page', 1)), 'rows': int(params_kw.get('rows', 50)), 'sort': 'id' } if workflow_id: ns['where'] = f"workflow_id='{workflow_id}'" async with DBPools().sqlorContext(dbname) as sor: data = await sor.sqlExe(sql, ns) if isinstance(data, dict): result['total'] = data.get('total', 0) result['rows'] = [dict(r) for r in data.get('rows', [])] else: result['rows'] = [dict(r) for r in (data or [])] result['total'] = len(result['rows']) result['success'] = True except Exception as e: result['error'] = str(e) return json.dumps(result, ensure_ascii=False, default=str)