Test (#718)

mr6208 · Chuseok22 · web-flow · commit b9e13325aaeb · 2026-01-09T11:47:27.000+09:00
* Mr6208/20251125 #646 대리인 및 의뢰인의 티켓팅 성공내역 생성 및 조회 기능 추가 (#700) * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 모듈 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 도메인 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 API 설계 및 명세 작성} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역생성 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역리스트업 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {flyway 관련 세팅 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {코드리뷰 반영 및 성공내역 모듈 통일} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공양식 수락 로직 검증단계 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 생성 트랜젝션 범위 재설정} #646 --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> * Mr6208/20251125 #646 대리인 및 의뢰인의 티켓팅 성공내역 생성 및 조회 기능 추가 (#711) * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 모듈 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 도메인 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 API 설계 및 명세 작성} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역생성 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역리스트업 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {flyway 관련 세팅 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {코드리뷰 반영 및 성공내역 모듈 통일} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공양식 수락 로직 검증단계 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 생성 트랜젝션 범위 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {스크립트 버전 충돌로 인한 스크립트 이름 변경} #646 --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> * Mr6208/20251125 #646 대리인 및 의뢰인의 티켓팅 성공내역 생성 및 조회 기능 추가 (#714) * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 모듈 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 도메인 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 API 설계 및 명세 작성} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역생성 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역리스트업 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {flyway 관련 세팅 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {코드리뷰 반영 및 성공내역 모듈 통일} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공양식 수락 로직 검증단계 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 생성 트랜젝션 범위 재설정} #646 * Mr6208/20251125 #646 대리인 및 의뢰인의 티켓팅 성공내역 생성 및 조회 기능 추가 (#700) (#710) * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 모듈 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 도메인 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 API 설계 및 명세 작성} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역생성 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역리스트업 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {flyway 관련 세팅 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {코드리뷰 반영 및 성공내역 모듈 통일} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공양식 수락 로직 검증단계 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 생성 트랜젝션 범위 재설정} #646 --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {스크립트 버전 충돌로 인한 스크립트 이름 변경} #646 * Test (#712) * Mr6208/20251125 #646 대리인 및 의뢰인의 티켓팅 성공내역 생성 및 조회 기능 추가 (#700) * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 모듈 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 도메인 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 API 설계 및 명세 작성} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역생성 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역리스트업 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {flyway 관련 세팅 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {코드리뷰 반영 및 성공내역 모듈 통일} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공양식 수락 로직 검증단계 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 생성 트랜젝션 범위 재설정} #646 --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> * Mr6208/20251125 #646 대리인 및 의뢰인의 티켓팅 성공내역 생성 및 조회 기능 추가 (#711) * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 모듈 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 도메인 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 API 설계 및 명세 작성} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역생성 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역리스트업 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {flyway 관련 세팅 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {코드리뷰 반영 및 성공내역 모듈 통일} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공양식 수락 로직 검증단계 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 생성 트랜젝션 범위 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {스크립트 버전 충돌로 인한 스크립트 이름 변경} #646 --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {기존 스크립트 삭제(왜있는거지)} #646 --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> * hotfix: 과거 스크립트 또 삭제 * Mr6208/20260109 채팅방 응답데이터 리팩토링 (#717) * Test (#716) * Mr6208/20251125 #646 대리인 및 의뢰인의 티켓팅 성공내역 생성 및 조회 기능 추가 (#700) * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 모듈 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 도메인 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 API 설계 및 명세 작성} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역생성 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역리스트업 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {flyway 관련 세팅 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {코드리뷰 반영 및 성공내역 모듈 통일} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공양식 수락 로직 검증단계 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 생성 트랜젝션 범위 재설정} #646 --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> * Mr6208/20251125 #646 대리인 및 의뢰인의 티켓팅 성공내역 생성 및 조회 기능 추가 (#711) * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 모듈 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 도메인 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 API 설계 및 명세 작성} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역생성 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역리스트업 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {flyway 관련 세팅 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {코드리뷰 반영 및 성공내역 모듈 통일} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공양식 수락 로직 검증단계 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 생성 트랜젝션 범위 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {스크립트 버전 충돌로 인한 스크립트 이름 변경} #646 --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> * Mr6208/20251125 #646 대리인 및 의뢰인의 티켓팅 성공내역 생성 및 조회 기능 추가 (#714) * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 모듈 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 도메인 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 API 설계 및 명세 작성} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역생성 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역리스트업 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {flyway 관련 세팅 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {코드리뷰 반영 및 성공내역 모듈 통일} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공양식 수락 로직 검증단계 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 생성 트랜젝션 범위 재설정} #646 * Mr6208/20251125 #646 대리인 및 의뢰인의 티켓팅 성공내역 생성 및 조회 기능 추가 (#700) (#710) * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 모듈 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 도메인 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 API 설계 및 명세 작성} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역생성 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역리스트업 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {flyway 관련 세팅 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {코드리뷰 반영 및 성공내역 모듈 통일} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공양식 수락 로직 검증단계 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 생성 트랜젝션 범위 재설정} #646 --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {스크립트 버전 충돌로 인한 스크립트 이름 변경} #646 * Test (#712) * Mr6208/20251125 #646 대리인 및 의뢰인의 티켓팅 성공내역 생성 및 조회 기능 추가 (#700) * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 모듈 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 도메인 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 API 설계 및 명세 작성} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역생성 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역리스트업 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {flyway 관련 세팅 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {코드리뷰 반영 및 성공내역 모듈 통일} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공양식 수락 로직 검증단계 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 생성 트랜젝션 범위 재설정} #646 --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> * Mr6208/20251125 #646 대리인 및 의뢰인의 티켓팅 성공내역 생성 및 조회 기능 추가 (#711) * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 모듈 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 도메인 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 API 설계 및 명세 작성} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역생성 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역리스트업 기능 설계} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {flyway 관련 세팅 추가} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {코드리뷰 반영 및 성공내역 모듈 통일} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공양식 수락 로직 검증단계 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {성공내역 생성 트랜젝션 범위 재설정} #646 * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {스크립트 버전 충돌로 인한 스크립트 이름 변경} #646 --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> * 대리인_및_의뢰인의_티켓팅_성공내역_생성_및_조회_기능_추가 : feat : {기존 스크립트 삭제(왜있는거지)} #646 --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> * hotfix: 과거 스크립트 또 삭제 --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> * 채팅방_응답데이터_리팩토링 : feat : {요구사항 반영} --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com> --------- Co-authored-by: Baek Jihoon <133375485+Chuseok22@users.noreply.github.com>
diff --git a/ticketmate-chat/src/main/java/com/ticketmate/backend/chat/application/service/ChatMessageService.java b/ticketmate-chat/src/main/java/com/ticketmate/backend/chat/application/service/ChatMessageService.java
@@ -34,6 +34,7 @@
 import java.time.temporal.ChronoUnit;
 import java.util.ArrayList;
 import java.util.Collections;
+import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.UUID;
@@ -102,13 +103,23 @@ public void acknowledgeRead(ReadAckRequest ack, Member reader, String chatRoomId
     String unReadRedisKey = UN_READ_MESSAGE_COUNTER_KEY.formatted(chatRoomId, reader.getMemberId());
     redisTemplate.delete(unReadRedisKey);
 
-    // 채팅방 리스트에 즉시 갱신하기 위한 코드
+    ChatMessage lastReadMessage = chatMessageRepository.findById(ack.getLastReadMessageId())
+      .orElseThrow(() -> new CustomException(ErrorCode.MESSAGE_NOT_FOUND));
+
+    String preview = toPreview(lastReadMessage);
+    String formattedSendDate = formattingSendDate(TimeUtil.toLocalDateTime(lastReadMessage.getSendDate()));
+
     rabbitTemplate.convertAndSend(
       "",
       chatRabbitMqProperties.unreadRoutingKey() + reader.getMemberId(),
-      Map.of("chatRoomId", chatRoomId,
-        "unReadMessageCount", 0,
-        "lastMessageId", ack.getLastReadMessageId())
+      buildUnreadTopicPayload(
+        chatRoomId,
+        0L,
+        lastReadMessage.getChatMessageId(),
+        lastReadMessage.getChatMessageType(),
+        preview,
+        formattedSendDate
+      )
     );
 
     ChatRoom chatRoom = chatRoomService.findChatRoomById(chatRoomId);
@@ -275,14 +286,15 @@ private ChatMessage handleNewChatMessage(Member sender, ChatMessageRequest reque
       rabbitTemplate.convertAndSend(
         "",
         chatRabbitMqProperties.unreadRoutingKey() + chatRoomMemberId,
-        Map.of(
-          "chatRoomId", chatRoom.getChatRoomId(),
-          "unReadMessageCount", count,
-          "lastMessage", request.toPreview(),
-          "lastMessageType", request.getType(),
-          "sendDate", formattedSendDate,
-          "lastMessageId", message.getChatMessageId()
-        ));
+        buildUnreadTopicPayload(
+          chatRoom.getChatRoomId(),
+          count,
+          message.getChatMessageId(),
+          request.getType(),
+          request.toPreview(),
+          formattedSendDate
+        )
+      );
     }
     return message;
   }
@@ -429,4 +441,29 @@ private void updateLastMessageInfo(ChatRoom chatRoom, ChatMessage chatMessage, S
 
     chatRoom.updateLastMessageType(chatMessage.getChatMessageType());
   }
+
+  private Map<String, Object> buildUnreadTopicPayload(String chatRoomId, long unReadMessageCount, String lastMessageId,
+    ChatMessageType lastMessageType, String lastMessage, String sendDate
+  ) {
+    Map<String, Object> payload = new LinkedHashMap<>();
+    payload.put("lastMessageId", lastMessageId);
+    payload.put("lastMessageType", lastMessageType);
+    payload.put("unReadMessageCount", unReadMessageCount);
+    payload.put("chatRoomId", chatRoomId);
+    payload.put("lastMessage", lastMessage == null ? "" : lastMessage);
+    payload.put("sendDate", sendDate == null ? "" : sendDate);
+    return payload;
+  }
+
+
+  private String toPreview(ChatMessage chatMessage) {
+    return switch (chatMessage.getChatMessageType()) {
+      case TEXT -> nvl(chatMessage.getMessage(), "");
+      case PICTURE -> ChatMessageType.PICTURE.getDescription();
+      case FULFILLMENT_FORM -> ChatMessageType.FULFILLMENT_FORM.getDescription();
+      case ACCEPTED_FULFILLMENT_FORM -> ChatMessageType.ACCEPTED_FULFILLMENT_FORM.getDescription();
+      case REJECTED_FULFILLMENT_FORM -> ChatMessageType.REJECTED_FULFILLMENT_FORM.getDescription();
+      case UPDATE_FULFILLMENT_FORM -> ChatMessageType.UPDATE_FULFILLMENT_FORM.getDescription();
+    };
+  }
 }
