output.py 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126
  1. import json
  2. import logging
  3. from collections.abc import Mapping
  4. from base64 import b64encode
  5. from .framework import Global, Task
  6. from .input_ctrl import send_msg, single_input, input_control, next_event, run_async
  7. from .output_ctl import register_callback
  8. import asyncio
  9. import inspect
  10. def set_title(title):
  11. send_msg('output_ctl', dict(title=title))
  12. def set_output_fixed_height(enabled=True):
  13. send_msg('output_ctl', dict(output_fixed_height=enabled))
  14. def text_print(text, *, ws=None):
  15. if text is None:
  16. text = ''
  17. msg = dict(command="output", spec=dict(content=text, type='text'))
  18. (ws or Global.active_ws).write_message(json.dumps(msg))
  19. def json_print(obj):
  20. text = "```\n%s\n```" % json.dumps(obj, indent=4, ensure_ascii=False)
  21. text_print(text)
  22. put_markdown = text_print
  23. def put_table(tdata, header=None):
  24. """
  25. 输出表格
  26. :param tdata: list of list|dict
  27. :param header: 列表,当tdata为字典列表时,header指定表头顺序
  28. :return:
  29. """
  30. if header:
  31. tdata = [
  32. [row.get(k, '') for k in header]
  33. for row in tdata
  34. ]
  35. def quote(data):
  36. return str(data).replace('|', r'\|')
  37. # 防止当tdata只有一行时,无法显示表格
  38. if len(tdata) == 1:
  39. tdata[0:0] = [' '] * len(tdata[0])
  40. header = "|%s|" % "|".join(map(quote, tdata[0]))
  41. res = [header]
  42. res.append("|%s|" % "|".join(['----'] * len(tdata[0])))
  43. for tr in tdata[1:]:
  44. t = "|%s|" % "|".join(map(quote, tr))
  45. res.append(t)
  46. text_print('\n'.join(res))
  47. def _format_button(buttons):
  48. """
  49. 格式化按钮参数
  50. :param buttons: button列表, button可用形式:
  51. {value:, label:, }
  52. (value, label,)
  53. value 单值,label等于value
  54. :return: [{value:, label:, }, ...]
  55. """
  56. btns = []
  57. for btn in buttons:
  58. if isinstance(btn, Mapping):
  59. assert 'value' in btn and 'label' in btn, 'actions item must have value and label key'
  60. elif isinstance(btn, list):
  61. assert len(btn) == 2, 'actions item format error'
  62. btn = dict(zip(('value', 'label'), btn))
  63. else:
  64. btn = dict(value=btn, label=btn)
  65. btns.append(btn)
  66. return btns
  67. def td_buttons(buttons, onclick, save=None, mutex_mode=False):
  68. """
  69. 在表格中显示一组按钮
  70. 参数含义同 buttons 函数
  71. :return:
  72. """
  73. btns = _format_button(buttons)
  74. callback_id = register_callback(onclick, save, mutex_mode)
  75. tpl = '<button type="button" value="{value}" class="btn btn-primary btn-sm" ' \
  76. 'onclick="WebIO.DisplayAreaButtonOnClick(this, \'%s\')">{label}</button>' % callback_id
  77. btns_html = [tpl.format(**b) for b in btns]
  78. return ' '.join(btns_html)
  79. def buttons(buttons, onclick, small=False, save=None, mutex_mode=False):
  80. """
  81. 显示一组按钮
  82. :param buttons: button列表, button可用形式: value 只能为字符串
  83. {value:, label:, }
  84. (value, label,)
  85. value 单值,label等于value
  86. :param onclick: CallBack(btn_value, save) CallBack can be generator function or coroutine function
  87. :param save:
  88. :param mutex_mode: 互斥模式,回调在运行过程中,无法响应同一回调,仅当onclick为协程函数时有效
  89. :return:
  90. """
  91. btns = _format_button(buttons)
  92. callback_id = register_callback(onclick, save, mutex_mode)
  93. send_msg('output', dict(type='buttons', callback_id=callback_id, buttons=btns, small=small))
  94. def put_file(name, content):
  95. """
  96. :param name: file name
  97. :param content: bytes-like object
  98. :return:
  99. """
  100. content = b64encode(content).decode('ascii')
  101. send_msg('output', dict(type='file', name=name, content=content))