From 0d42a2d71e99b78641036aa80ded7dc119ac2446 Mon Sep 17 00:00:00 2001 From: karuo Date: Wed, 11 Mar 2026 20:48:48 +0800 Subject: [PATCH] =?UTF-8?q?=F0=9F=94=84=20=E5=8D=A1=E8=8B=A5AI=20=E5=90=8C?= =?UTF-8?q?=E6=AD=A5=202026-03-11=2020:48=20|=20=E6=9B=B4=E6=96=B0?= =?UTF-8?q?=EF=BC=9A=E6=B0=B4=E6=A1=A5=E5=B9=B3=E5=8F=B0=E5=AF=B9=E6=8E=A5?= =?UTF-8?q?=E3=80=81=E8=BF=90=E8=90=A5=E4=B8=AD=E6=9E=A2=E5=B7=A5=E4=BD=9C?= =?UTF-8?q?=E5=8F=B0=20|=20=E6=8E=92=E9=99=A4=20>20MB:=2011=20=E4=B8=AA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../飞书管理/脚本/.feishu_tokens.json | 6 +- .../水桥_平台对接/飞书管理/脚本/auto_log.py | 211 ++++++++++++------ .../飞书管理/脚本/write_today_0321_custom.py | 30 +-- 运营中枢/工作台/gitea_push_log.md | 1 + 运营中枢/工作台/代码管理.md | 1 + 5 files changed, 162 insertions(+), 87 deletions(-) diff --git a/02_卡人（水）/水桥_平台对接/飞书管理/脚本/.feishu_tokens.json b/02_卡人（水）/水桥_平台对接/飞书管理/脚本/.feishu_tokens.json index 7f0ce12d..d0f711cc 100644 --- a/02_卡人（水）/水桥_平台对接/飞书管理/脚本/.feishu_tokens.json +++ b/02_卡人（水）/水桥_平台对接/飞书管理/脚本/.feishu_tokens.json @@ -1,6 +1,6 @@ { - "access_token": "u-fcSTOxuMRc6HxhmOz9sB_tlh3IFxghgjgMGaUMk0270J", - "refresh_token": "ur-c7noOSDU11a8yMV_h198nwlh1eF1ghOjp0GaEAg026gY", + "access_token": "u-dHEj_.UY90dV14HLKrj6Dnlh34b1ghghOMGaZNk0220V", + "refresh_token": "ur-dphocXbQpdvVav078ZVRqdlh3KFxghMVrgGaYA40225Z", "name": "飞书用户", - "auth_time": "2026-03-11T05:52:09.512494" + "auth_time": "2026-03-11T20:37:17.022220" } \ No newline at end of file diff --git a/02_卡人（水）/水桥_平台对接/飞书管理/脚本/auto_log.py b/02_卡人（水）/水桥_平台对接/飞书管理/脚本/auto_log.py index ef2fad78..a1451237 100644 --- a/02_卡人（水）/水桥_平台对接/飞书管理/脚本/auto_log.py +++ b/02_卡人（水）/水桥_平台对接/飞书管理/脚本/auto_log.py @@ -192,68 +192,129 @@ def get_today_tasks(): return date_str, tasks +def _tb(content, bold=False): + """构建纯文本 block（兼容性最强，不带 text_color/align）""" + elem = {'text_run': {'content': content}} + if bold: + elem['text_run']['text_element_style'] = {'bold': True} + return {'block_type': 2, 'text': {'elements': [elem], 'style': {}}} + + +def _todo(content): + """待办块（不带 align，减少 field validation failed 风险）""" + return {'block_type': 17, 'todo': {'elements': [{'text_run': {'content': content}}], 'style': {'done': False}}} + + def build_blocks(date_str, tasks): - """构建飞书文档块（倒序：新日期在上）；callout 易触发 field validation failed，改用 text""" - blocks = [ - {'block_type': 6, 'heading4': {'elements': [{'text_run': {'content': f'{date_str} '}}], 'style': {'align': 1}}}, - {'block_type': 2, 'text': {'elements': [{'text_run': {'content': '[执行]', 'text_element_style': {'bold': True}}}], 'style': {}}} - ] - - quadrant_colors = {"重要紧急": 5, "重要不紧急": 3, "不重要紧急": 6, "不重要不紧急": 4} + """构建飞书文档块（美观版 TNTWF 格式，不含易报错的 callout/text_color/align）""" + QUADRANT_ICONS = { + "重要紧急": "🔴 重要紧急", + "重要不紧急": "🟡 重要不紧急", + "不重要紧急": "🔵 不重要紧急", + "不重要不紧急":"⚪ 不重要不紧急", + } quadrant_order = ["重要紧急", "重要不紧急", "不重要紧急", "不重要不紧急"] - + + blocks = [ + _tb(f'📅 {date_str}', bold=True), + _tb('▶ 执行'), + _tb(''), + ] + for quadrant in quadrant_order: q_tasks = [t for t in tasks if t.get('quadrant') == quadrant] if not q_tasks: continue - - blocks.append({'block_type': 2, 'text': {'elements': [{'text_run': {'content': f'[{quadrant}]', - 'text_element_style': {'bold': True, 'text_color': quadrant_colors[quadrant]}}}], 'style': {'align': 1}}}) - + + blocks.append(_tb(f' {QUADRANT_ICONS.get(quadrant, quadrant)}', bold=True)) + blocks.append(_tb(' ' + '─' * 32)) + for task in q_tasks: - events = "、".join(task['events']) - blocks.append({'block_type': 17, 'todo': {'elements': [{'text_run': {'content': f"{task['person']}（{events}）"}}], - 'style': {'done': False, 'align': 1}}}) - blocks.append({'block_type': 2, 'text': {'elements': [{'text_run': {'content': '{'}}], 'style': {}}}) - - # TNTWF格式：仅 W(工作) F(反馈) 有复选框，T/N/T 为纯文本 + events = ' · '.join(task.get('events', [])) + blocks.append(_todo(f"{task.get('person', '')}（{events}）")) + labels = [ - ('T', 't_targets', '目标', False), - ('N', 'n_process', '过程', False), - ('T', 't_thoughts', '思考', False), - ('W', 'w_work', '工作', True), - ('F', 'f_feedback', '反馈', True) + ('T', 't_targets', '目标'), + ('N', 'n_process', '过程'), + ('T', 't_thoughts', '思考'), + ('W', 'w_work', '工作'), + ('F', 'f_feedback', '反馈'), ] - for label, key, name, use_todo in labels: + for label, key, name in labels: items = task.get(key, []) - if items: - blocks.append({'block_type': 2, 'text': {'elements': [{'text_run': {'content': f'{label} ({name})', 'text_element_style': {'bold': True}}}], 'style': {}}}) - for item in items: - if use_todo: - blocks.append({'block_type': 17, 'todo': {'elements': [{'text_run': {'content': item}}], 'style': {'done': False}}}) - else: - blocks.append({'block_type': 2, 'text': {'elements': [{'text_run': {'content': item}}], 'style': {}}}) - - blocks.append({'block_type': 2, 'text': {'elements': [{'text_run': {'content': '}'}}], 'style': {}}}) - blocks.append({'block_type': 2, 'text': {'elements': [{'text_run': {'content': ''}}], 'style': {}}}) - + if not items: + continue + blocks.append(_tb(f' {label} {name}', bold=True)) + for item in items: + if label in ('W', 'F'): + blocks.append(_todo(f' {item}')) + else: + blocks.append(_tb(f' · {item}')) + + blocks.append(_tb('')) + + blocks.append(_tb('')) + return blocks -def _text_block_simple(content): - """极简文本块，兼容 field validation 严格校验""" +def _tb_s(content): + """极简文本块（fallback 专用）""" return {'block_type': 2, 'text': {'elements': [{'text_run': {'content': content}}], 'style': {}}} def _build_blocks_simple(date_str, tasks): - """极简块（仅纯文本），用于 field validation failed 时回退""" - blocks = [_text_block_simple(f'{date_str} '), _text_block_simple('[执行]')] - for task in tasks: - events = '、'.join(task.get('events', [])) - blocks.append(_text_block_simple(f"{task.get('person', '')}（{events}）")) - for key in ('t_targets', 'n_process', 't_thoughts', 'w_work', 'f_feedback'): - for item in task.get(key, []): - blocks.append(_text_block_simple(f" {item}")) + """极简块（纯文本美观版），field validation failed 时自动回退""" + QUAD_ICONS = { + "重要紧急": "🔴 重要紧急", + "重要不紧急": "🟡 重要不紧急", + "不重要紧急": "🔵 不重要紧急", + "不重要不紧急": "⚪ 不重要不紧急", + } + quadrant_order = ["重要紧急", "重要不紧急", "不重要紧急", "不重要不紧急"] + LINE = '─' * 34 + + blocks = [ + _tb_s(f'┌{'─' * 36}┐'), + _tb_s(f'│ 📅 {date_str} ▶ 执行' + ' ' * max(0, 30 - len(date_str)) + '│'), + _tb_s(f'└{'─' * 36}┘'), + _tb_s(''), + ] + + for quadrant in quadrant_order: + q_tasks = [t for t in tasks if t.get('quadrant') == quadrant] + if not q_tasks: + continue + + blocks.append(_tb_s(f' {QUAD_ICONS.get(quadrant, quadrant)}')) + blocks.append(_tb_s(f' {LINE}')) + + for task in q_tasks: + events = ' · '.join(task.get('events', [])) + blocks.append(_tb_s(f' ☑ {task.get("person", "")}（{events}）')) + blocks.append(_tb_s(f' ┌{LINE}')) + + label_map = [ + ('T', 't_targets', '目标'), + ('N', 'n_process', '过程'), + ('T', 't_thoughts', '思考'), + ('W', 'w_work', '工作'), + ('F', 'f_feedback', '反馈'), + ] + for label, key, name in label_map: + items = task.get(key, []) + if not items: + continue + blocks.append(_tb_s(f' │ 【{label}】{name}')) + for item in items: + prefix = ' │ □ ' if label in ('W', 'F') else ' │ · ' + blocks.append(_tb_s(f'{prefix}{item}')) + + blocks.append(_tb_s(f' └{LINE}')) + blocks.append(_tb_s('')) + + blocks.append(_tb_s('')) + return blocks @@ -466,23 +527,31 @@ def write_log(token, date_str=None, tasks=None, wiki_token=None, overwrite=False to_del = _find_date_section_block_ids(blocks, date_str, doc_id) if to_del: try: - for i in range(0, len(to_del), 20): - batch = to_del[i:i+20] - body = {"requests": [{"block_id": bid} for bid in batch]} - rd = requests.post(f"https://open.feishu.cn/open-apis/docx/v1/documents/{doc_id}/blocks/batch_delete", - headers=headers, json=body, timeout=30) + # 找根级别 block 的索引（飞书批删需要 start_index/end_index） + root_blocks = [b for b in blocks if b.get('parent_id') == doc_id] + root_ids = [b.get('block_id') for b in root_blocks] + indices = sorted([root_ids.index(bid) for bid in to_del if bid in root_ids]) + if indices: + start_idx = indices[0] + end_idx = indices[-1] + 1 # 飞书 end_index 是 exclusive + rd = requests.delete( + f"https://open.feishu.cn/open-apis/docx/v1/documents/{doc_id}/blocks/{doc_id}/children/batch_delete", + headers=headers, + json={"start_index": start_idx, "end_index": end_idx}, + timeout=30 + ) try: j = rd.json() except Exception: j = {} if j.get('code') != 0: - print(f"⚠️ 覆盖删除失败: {j.get('msg', rd.text[:80])}，请手动删飞书中 {date_str} 后重试") - break - else: - r = requests.get(f"https://open.feishu.cn/open-apis/docx/v1/documents/{doc_id}/blocks", - headers=headers, params={'document_revision_id': -1, 'page_size': 500}, timeout=30) - blocks = r.json().get('data', {}).get('items', []) - exists = False + print(f"⚠️ 覆盖删除失败: {j.get('msg', rd.text[:120])}，请手动删飞书中 {date_str} 后重试") + else: + r2 = requests.get(f"https://open.feishu.cn/open-apis/docx/v1/documents/{doc_id}/blocks", + headers=headers, params={'document_revision_id': -1, 'page_size': 500}, timeout=30) + blocks = r2.json().get('data', {}).get('items', []) + exists = False + print(f"✅ 已删除 {date_str} 旧块（{end_idx - start_idx} 个），准备重写新格式") except Exception as e: print(f"⚠️ 覆盖删除异常: {e}，请手动删飞书中 {date_str} 后重试") @@ -500,22 +569,22 @@ def write_log(token, date_str=None, tasks=None, wiki_token=None, overwrite=False insert_index = i + 1 break - # 写入（倒序：新日期在上）；field validation failed 时尝试极简纯文本块 - content_blocks = build_blocks(date_str, tasks) - payload = {'children': content_blocks, 'index': insert_index} - r = requests.post(f"https://open.feishu.cn/open-apis/docx/v1/documents/{doc_id}/blocks/{doc_id}/children", - headers=headers, json=payload, timeout=30) - if r.json().get('code') != 0 and 'field validation failed' in (r.json().get('msg') or '').lower(): - content_blocks = _build_blocks_simple(date_str, tasks) - payload = {'children': content_blocks, 'index': insert_index} + # 写入（倒序：新日期在上）；分批写入（飞书单次上限 50 块） + content_blocks = _build_blocks_simple(date_str, tasks) + BATCH_SIZE = 48 # 安全值：低于 50 + offset = 0 + for i in range(0, len(content_blocks), BATCH_SIZE): + batch = content_blocks[i:i + BATCH_SIZE] + payload = {'children': batch, 'index': insert_index + offset} r = requests.post(f"https://open.feishu.cn/open-apis/docx/v1/documents/{doc_id}/blocks/{doc_id}/children", headers=headers, json=payload, timeout=30) - if r.json().get('code') == 0: - print(f"✅ {date_str} 日志写入成功 -> {doc_title}") - return True - else: - print(f"❌ 写入失败: {r.json().get('msg')}") - return False + rj = r.json() + if rj.get('code') != 0: + print(f"❌ 写入失败(批次{i//BATCH_SIZE+1}): code={rj.get('code')} msg={rj.get('msg')}") + return False + offset += len(batch) + print(f"✅ {date_str} 日志写入成功 -> {doc_title}（共 {len(content_blocks)} 块，{(len(content_blocks)-1)//BATCH_SIZE+1} 批次）") + return True def open_result(wiki_token=None): """打开飞书查看结果""" diff --git a/02_卡人（水）/水桥_平台对接/飞书管理/脚本/write_today_0321_custom.py b/02_卡人（水）/水桥_平台对接/飞书管理/脚本/write_today_0321_custom.py index 3e75e4d5..0dd3c811 100644 --- a/02_卡人（水）/水桥_平台对接/飞书管理/脚本/write_today_0321_custom.py +++ b/02_卡人（水）/水桥_平台对接/飞书管理/脚本/write_today_0321_custom.py @@ -18,30 +18,34 @@ def build_tasks_today(): return [ { "person": "远志（玩值）", - "events": ["每天200视频分发", "切片工具研发", "售内容产出"], + "events": ["200视频分发", "切片工具", "售内容与多平台推送"], "quadrant": "重要紧急", "t_targets": [ - "目标：每天发 200 个视频，工具分发到各平台", + "目标：每天 200 视频，工具分发到各平台", "工具研发：每天切 10-30 个视频的切片工具", - "售内容：售的内容产出，按整个业务与年度目标百分比推进", + "售方面：内容产出 + 多平台推送统一化，按年度目标 % 推进", ], "n_process": [ - "源自远志安排：200 视频/日分发；工具负责 10～30 切片/日；售内容与年度目标对齐", + "售方面还需优化迭代：优酷等各平台推送接口/API 未开发完；各公众号推送方式未写完；需把可推送的所有平台统一做出来", ], "t_thoughts": [ - "工具研发 + 售内容产出 = 支撑 200 视频/日；百分比以 2026 年整体目标为基准", + "售 = 内容产出 + 分发；多平台（优酷、公众号等）接口与推送方式补齐后，才能规模化", ], "w_work": [ - "工具分发：200 视频/日 → 各平台", - "工具研发：每天切 10-30 个视频的切片工具", - "售内容产出（含内容生产）", - "按业务与年度目标百分比追踪", + "工具分发 200 视频/日 → 各平台", + "切片工具：10-30 条/日", + "售：推到优酷等各平台的接口与 API 开发", + "售：推送到各个公众号的推送方式开发", + "统一做出所有可推送平台（优酷、公众号等）的对接与推送", + "售内容优化与迭代", + "按业务与年度目标 % 追踪", ], "f_feedback": [ - "200 视频/日 → 当日完成度 X%", - "10～30 切片工具 研发中", - "售内容产出 进行中", - "本月/年度目标 % 见整体目标", + "200 视频/日 进行中", + "优酷等平台接口/API 未完成", + "公众号推送方式 未完成", + "多平台统一推送 待开发", + "售优化迭代 进行中", ], }, { diff --git a/运营中枢/工作台/gitea_push_log.md b/运营中枢/工作台/gitea_push_log.md index 35b004d7..92d0c2ac 100644 --- a/运营中枢/工作台/gitea_push_log.md +++ b/运营中枢/工作台/gitea_push_log.md @@ -301,3 +301,4 @@ | 2026-03-11 18:05:42 | 🔄 卡若AI 同步 2026-03-11 18:05 | 更新：运营中枢工作台 | 排除 >20MB: 11 个 | | 2026-03-11 20:01:53 | 🔄 卡若AI 同步 2026-03-11 20:01 | 更新：水桥平台对接、运营中枢工作台 | 排除 >20MB: 11 个 | | 2026-03-11 20:12:14 | 🔄 卡若AI 同步 2026-03-11 20:12 | 更新：水桥平台对接、水溪整理归档、运营中枢工作台 | 排除 >20MB: 11 个 | +| 2026-03-11 20:22:53 | 🔄 卡若AI 同步 2026-03-11 20:22 | 更新：水桥平台对接、运营中枢工作台 | 排除 >20MB: 11 个 | diff --git a/运营中枢/工作台/代码管理.md b/运营中枢/工作台/代码管理.md index ad5c45bc..4ab8388c 100644 --- a/运营中枢/工作台/代码管理.md +++ b/运营中枢/工作台/代码管理.md @@ -304,3 +304,4 @@ | 2026-03-11 18:05:42 | 成功 | 成功 | 🔄 卡若AI 同步 2026-03-11 18:05 | 更新：运营中枢工作台 | 排除 >20MB: 11 个 | [仓库](http://open.quwanzhi.com:3000/fnvtk/karuo-ai) [百科](http://open.quwanzhi.com:3000/fnvtk/karuo-ai/wiki) | | 2026-03-11 20:01:53 | 成功 | 成功 | 🔄 卡若AI 同步 2026-03-11 20:01 | 更新：水桥平台对接、运营中枢工作台 | 排除 >20MB: 11 个 | [仓库](http://open.quwanzhi.com:3000/fnvtk/karuo-ai) [百科](http://open.quwanzhi.com:3000/fnvtk/karuo-ai/wiki) | | 2026-03-11 20:12:14 | 成功 | 成功 | 🔄 卡若AI 同步 2026-03-11 20:12 | 更新：水桥平台对接、水溪整理归档、运营中枢工作台 | 排除 >20MB: 11 个 | [仓库](http://open.quwanzhi.com:3000/fnvtk/karuo-ai) [百科](http://open.quwanzhi.com:3000/fnvtk/karuo-ai/wiki) | +| 2026-03-11 20:22:53 | 成功 | 成功 | 🔄 卡若AI 同步 2026-03-11 20:22 | 更新：水桥平台对接、运营中枢工作台 | 排除 >20MB: 11 个 | [仓库](http://open.quwanzhi.com:3000/fnvtk/karuo-ai) [百科](http://open.quwanzhi.com:3000/fnvtk/karuo-ai/wiki) |