feat: remaining frontend views (groups/calls/sms/sync) + messageout media fields

Backend (Part A):
- MessageOut: add file_th_url, file_hd_url, duration, transcription_text, md5
  (room_id + sender_head_url already existed) so the chat timeline can render
  image thumbnails, voice duration/transcription, and avatars from a single
  response.
- PhoneCallOut: add record_file so the Calls view can offer recording playback.
- SmsOut: add content (full body) so the SMS detail dialog shows the whole text.
- Tests: red->green for each new field (media fields default None + populated,
  record_file round-trip, content round-trip). Suite 267 -> 271.

Frontend (Part B):
- api/index.ts: wrappers getGroups/getGroupMembers/getCalls/getSms/getSyncStatus
  + Group/GroupMember/PhoneCall/Sms/SyncState/SyncRun/SyncStatus types in
  types.ts (mirror the *Out pydantic schemas).
- views/GroupList.vue (/groups): table + channel filter + pagination; row click
  opens the group timeline.
- views/CallList.vue (/calls): table + call-type filter (phone_call/voice_call/
  all); "播放录音" action opens an el-dialog with <audio controls>.
- views/SmsList.vue (/sms): table; row click opens a detail dialog with the full
  content.
- views/SyncStatus.vue (/sync): two tables (states + recent_runs) with a manual
  refresh; run status color-coded.
- ChatTimeline.vue: reused for both 1:1 DM (talkerId) and group (roomId) by
  branching the query; group title + per-member sender already handled by
  MessageBubble.
- router: add /groups /calls /sms /sync + /group/:channel/:ownerId/:roomId.
- layouts/MainLayout.vue: replace the single 客户列表 button with an el-menu
  (客户 / 群 / 通话 / 短信 / 同步); org tree kept on the left.

Co-Authored-By: Claude <noreply@anthropic.com>
This commit is contained in:
浅念
2026-08-01 16:38:47 +08:00
parent 6c4cd92ae6
commit b822e87d4d
14 changed files with 1401 additions and 36 deletions
+17
View File
@@ -46,6 +46,7 @@ async def _seed(session: AsyncSession) -> None:
call_status=0,
incoming_call=0,
call_number="111",
record_file="https://oss/c3.mp3",
),
]
)
@@ -71,6 +72,7 @@ async def test_default_list_returns_all_ordered_desc(make_client):
"user_id_name",
"call_number",
"sim_phone",
"record_file",
):
assert key in body["items"][0]
@@ -126,3 +128,18 @@ async def test_pagination(make_client):
assert body["total"] == 3
assert len(body["items"]) == 1
assert body["items"][0]["call_id"] == "c3"
async def test_record_file_serializes(make_client):
"""``record_file`` (OSS recording URL) round-trips so the Calls view can
render a 播放录音 action — present when set, None when unset.
"""
client = await make_client(_seed)
r = await client.get("/api/calls")
assert r.status_code == 200
by_id = {it["call_id"]: it for it in r.json()["items"]}
# c3 was seeded with a recording URL.
assert by_id["c3"]["record_file"] == "https://oss/c3.mp3"
# c1/c2 have no record_file set -> None.
assert by_id["c1"]["record_file"] is None
assert by_id["c2"]["record_file"] is None
+99
View File
@@ -185,3 +185,102 @@ async def test_group_chat_filter_by_room_id(make_client):
body = r.json()
assert body["total"] == 1
assert body["items"][0]["msg_id"] == "m4"
async def test_media_fields_serialize(make_client):
"""Image thumbnail/HD URLs, voice duration/transcription, md5, room_id and
sender avatar round-trip through MessageOut so the timeline can render
media + group messages without a second call.
"""
async def seed(session: AsyncSession) -> None:
session.add_all(
[
Message(
msg_id="img1",
channel="wechat",
owner_account_id="wx_owner_1",
talker_id="t_a",
room_id=None,
type="image",
type_raw=3,
timestamp=1000,
file_url="https://oss/full.jpg",
file_th_url="https://oss/th.jpg",
file_hd_url="https://oss/hd.jpg",
md5="abc123",
sender_name="Alice",
sender_head_url="https://oss/alice.jpg",
),
Message(
msg_id="voice1",
channel="wechat",
owner_account_id="wx_owner_1",
talker_id=None,
room_id="room_x",
type="voice",
type_raw=34,
timestamp=2000,
duration=12,
transcription_text="hello there",
sender_name="Bob",
sender_head_url="https://oss/bob.jpg",
),
]
)
await session.commit()
client = await make_client(seed)
r = await client.get("/api/messages", params={"owner_account_id": "wx_owner_1"})
assert r.status_code == 200
body = r.json()
assert body["total"] == 2
by_id = {it["msg_id"]: it for it in body["items"]}
img = by_id["img1"]
assert img["file_th_url"] == "https://oss/th.jpg"
assert img["file_hd_url"] == "https://oss/hd.jpg"
assert img["md5"] == "abc123"
assert img["room_id"] is None
assert img["sender_head_url"] == "https://oss/alice.jpg"
voice = by_id["voice1"]
assert voice["duration"] == 12
assert voice["transcription_text"] == "hello there"
assert voice["room_id"] == "room_x"
assert voice["sender_head_url"] == "https://oss/bob.jpg"
async def test_media_fields_default_none_when_unset(make_client):
"""A text message with no media columns set serializes the new keys as None."""
async def seed(session: AsyncSession) -> None:
session.add(
Message(
msg_id="t1",
channel="wechat",
owner_account_id="wx_owner_1",
talker_id="t_a",
type="text",
type_raw=1,
timestamp=1000,
text="plain",
)
)
await session.commit()
client = await make_client(seed)
r = await client.get("/api/messages")
assert r.status_code == 200
it = r.json()["items"][0]
for key in (
"file_th_url",
"file_hd_url",
"duration",
"transcription_text",
"md5",
"room_id",
"sender_head_url",
):
assert key in it
assert it[key] is None
+17
View File
@@ -20,6 +20,7 @@ async def _seed(session: AsyncSession) -> None:
user_id="u1",
receive_name="Alice",
content_preview="hello",
content="hello, this is the full body",
create_time=1000,
direction=1,
sender="111",
@@ -40,6 +41,7 @@ async def _seed(session: AsyncSession) -> None:
user_id="u1",
receive_name="Alice",
content_preview="bye",
content="bye for now",
create_time=3000,
direction=1,
),
@@ -60,6 +62,7 @@ async def test_default_list_returns_all_ordered_desc(make_client):
"sms_id",
"customer_phone",
"content_preview",
"content",
"sender",
"direction",
"user_id",
@@ -109,3 +112,17 @@ async def test_pagination(make_client):
assert body["total"] == 3
assert len(body["items"]) == 1
assert body["items"][0]["sms_id"] == "s3"
async def test_content_field_serializes(make_client):
"""``content`` (full SMS body) round-trips so the SMS view can show the
whole message in a detail dialog — present when set, None when unset.
"""
client = await make_client(_seed)
r = await client.get("/api/sms")
assert r.status_code == 200
by_id = {it["sms_id"]: it for it in r.json()["items"]}
assert by_id["s1"]["content"] == "hello, this is the full body"
assert by_id["s3"]["content"] == "bye for now"
# s2 was seeded without content -> None.
assert by_id["s2"]["content"] is None