47 lines
1.7 KiB
Python
47 lines
1.7 KiB
Python
|
# -*- coding: utf-8 -*-
|
|||
|
|
"""逐会话从转录 rawUsage 汇总真实积分（递归找 rawUsage.credit）。"""
|
|||
|
|
import io, json, glob
|
|||
|
|
|
|||
|
|
HOME = "E:/ProgramData/.workbuddy"
|
|||
|
|
SIDS = {
|
|||
|
|
"3814f5fb": "覆盖网络线·归档接续（自动 @10:20）",
|
|||
|
|
"e265f0cd": "覆盖网络线·接续优化版（自动 @10:45）",
|
|||
|
|
"478eef8c": "决策方法-2（自动 @11:10）",
|
|||
|
|
"d48a9be8": "覆盖网络线·S1 落地（自动 @14:32）",
|
|||
|
|
"b08b1c35": "确认覆盖网络任务待办事项（手动新会话，基线）",
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
def walk(o, hits, path=""):
|
|||
|
|
if isinstance(o, dict):
|
|||
|
|
for k, v in o.items():
|
|||
|
|
if k == "rawUsage" and isinstance(v, dict):
|
|||
|
|
hits.append(v)
|
|||
|
|
else:
|
|||
|
|
walk(v, hits, path + "/" + str(k))
|
|||
|
|
elif isinstance(o, list):
|
|||
|
|
for x in o:
|
|||
|
|
walk(x, hits, path)
|
|||
|
|
|
|||
|
|
print("%-38s %6s %8s %8s" % ("会话", "计费次", "积分合计", "均值"))
|
|||
|
|
for short, label in SIDS.items():
|
|||
|
|
hits = glob.glob(HOME + "/projects/*/" + short + "*.jsonl")
|
|||
|
|
if not hits:
|
|||
|
|
print(short, "无转录")
|
|||
|
|
continue
|
|||
|
|
ru = []
|
|||
|
|
with io.open(hits[0], "r", encoding="utf-8", errors="replace", newline="") as f:
|
|||
|
|
for line in f:
|
|||
|
|
line = line.strip()
|
|||
|
|
if not line:
|
|||
|
|
continue
|
|||
|
|
try:
|
|||
|
|
d = json.loads(line)
|
|||
|
|
except Exception:
|
|||
|
|
continue
|
|||
|
|
walk(d, ru)
|
|||
|
|
cr = [r.get("credit") for r in ru if isinstance(r.get("credit"), (int, float))]
|
|||
|
|
tot = sum(cr)
|
|||
|
|
print("%-38s %6d %8.2f %8s" % (label[:36], len(cr), tot, ("%.3f" % (tot / len(cr))) if cr else "-"))
|
|||
|
|
if cr:
|
|||
|
|
s = sorted(cr)
|
|||
|
|
print(" min=%.2f 中位=%.2f max=%.2f ｜ 首=%.2f 末=%.2f" % (s[0], s[len(s)//2], s[-1], cr[0], cr[-1]))
|