ChatModel.ts 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100
  1. // 聊天模块
  2. import Gamecfg from "../../../common/gameCfg";
  3. import { gameMethod } from "../../../common/gameMethod";
  4. import { ChatHistory, ChatHistoryPram, ChatSend, ChatSendPram } from "../../../common/Xyc";
  5. import { ChannelType, ChatInfo, SevBack, SevBackType } from "../../../common/Xys";
  6. import { RedUtil } from "../../../frameWork/fgui/RedUtil";
  7. import EventMng from "../../../manager/EventMng";
  8. import { ChatType, ResChatSend } from "../../../shared/chat/PtlChatSend";
  9. import GameMath from "../../../utils/GameMath";
  10. import { ChatEvent } from "../../const/EventConst";
  11. import GameDataCenter from "../../GameDataCenter";
  12. import { ChatModelData } from "./ChatModelData";
  13. export default class ChatModel extends ChatModelData {
  14. // chatCd: number = 0 // 下一次可聊天的时间戳
  15. private _lastId: Map<ChannelType, number> = new Map();
  16. private _chatNewId: Map<ChannelType, number> = new Map(); // 最新的一条消息ID
  17. chatCd: number = 0;
  18. refreshCd: number = 0;
  19. readonly getChatNum: number = 10; //每次获取的,聊天信息的数量
  20. readonly historyMinCd: number = 3;
  21. readonly sendChatMinCd: number = 3;
  22. curChannel: ChannelType;
  23. get lastId() {
  24. return this._lastId.get(this.curChannel);
  25. }
  26. set lastId(id: number) {
  27. this._lastId.set(this.curChannel, id);
  28. }
  29. get chatNewId() {
  30. return this._chatNewId.get(this.curChannel);
  31. }
  32. set chatNewId(id: number) {
  33. this._chatNewId.set(this.curChannel, id);
  34. }
  35. constructor() {
  36. super("chat");
  37. }
  38. onRegister(): void {
  39. GameDataCenter.gameServer.ListenMsg("chat/server/ChatNew_s", this.onItemChange, this);
  40. }
  41. onItemChange(res: ResChatSend) {
  42. this.chatInfo = res;
  43. }
  44. // 发送聊天信息
  45. async sendChat(chatType: ChatType, str: string, cb: Function = () => { }) {
  46. let ret = await GameDataCenter.gameServer.ReqApi("chat/ChatSend", {
  47. type: chatType,
  48. str: str
  49. });
  50. if (ret?.res) {
  51. cb(ret.res);
  52. }
  53. }
  54. checkHistory() {
  55. let list = Object.keys(GameDataCenter.sevBack.chat?.[this.curChannel]?.a ?? {});
  56. return list.length < this.getChatNum;
  57. }
  58. /**获得聊天同服 */
  59. getServerList() {
  60. let sid = GameDataCenter.user?.userInfo?.sid;
  61. let serverList = GameDataCenter.login.playerInfo?.qufuList;
  62. let heid = serverList?.[sid]?.heid;
  63. let list: string[] = []
  64. for (let key in serverList) {
  65. if (serverList[key].heid == heid) {
  66. list.push(serverList[key].sid);
  67. }
  68. }
  69. return list;
  70. }
  71. showTime(time: number): string {
  72. let dhms = this.getHM(time);
  73. let tTime: string = `${GameMath.addZero(dhms.h)}:${GameMath.addZero(dhms.m)}`;
  74. return tTime;
  75. }
  76. getHM(time: number) {
  77. if (time.toString().length == 10) {
  78. time = time * 1000
  79. }
  80. var date = new Date(time);
  81. var hour = date.getHours()
  82. var minute = date.getMinutes()
  83. return { h: hour, m: minute };
  84. }
  85. }