ckb-SuperAdmin/Touchkebao/src/store/module/websocket/msgManage.ts

//消息管理器
import { deepCopy } from "@/utils/common";
import { WebSocketMessage } from "./websocket";
import { getkfUserList, asyncKfUserList } from "@/store/module/ckchat/ckchat";
import { Messages } from "./msg.data";
import { useWeChatStore } from "../weChat/weChat";
// 消息处理器类型定义
type MessageHandler = (message: WebSocketMessage) => void;
const setVideoUrl = useWeChatStore.getState().setVideoUrl;
const addMessage = useWeChatStore.getState().addMessage;
const receivedMsg = useWeChatStore.getState().receivedMsg;

// 消息处理器映射
const messageHandlers: Record<string, MessageHandler> = {
  // 微信账号存活状态响应
  CmdRequestWechatAccountsAliveStatusResp: message => {
    // console.log("微信账号存活状态响应", message);
    // 获取客服列表
    const kfUserList = deepCopy(getkfUserList());
    const wechatAccountsAliveStatus = message.wechatAccountsAliveStatus || {};
    // 遍历客服列表，更新存活状态
    kfUserList.forEach(kfUser => {
      kfUser.isOnline = wechatAccountsAliveStatus[kfUser.id];
    });

    // 按在线状态排序，在线的排在前面
    kfUserList.sort((a, b) => {
      if (a.isOnline && !b.isOnline) return -1;
      if (!a.isOnline && b.isOnline) return 1;
      return 0;
    });

    asyncKfUserList(kfUserList);
  },
  // 发送消息响应
  CmdSendMessageResp: message => {
    console.log("发送消息响应", message);
    addMessage(message.friendMessage || message.chatroomMessage);
    // 在这里添加具体的处理逻辑
  },
  CmdSendMessageResult: message => {
    console.log("发送消息结果", message);
    // 在这里添加具体的处理逻辑
  },
  // 接收消息响应
  CmdReceiveMessageResp: message => {
    console.log("接收消息响应", message);
    addMessage(message.friendMessage || message.chatroomMessage);
    // 在这里添加具体的处理逻辑
  },
  //收到消息
  CmdNewMessage: (message: Messages) => {
    // 在这里添加具体的处理逻辑
    receivedMsg(message.friendMessage || message.chatroomMessage);
  },
  CmdFriendInfoChanged: message => {
    // console.log("好友信息变更", message);
    // 在这里添加具体的处理逻辑
  },

  // 登录响应
  CmdSignInResp: message => {
    console.log("登录响应", message);
    // 在这里添加具体的处理逻辑
  },

  // 通知消息
  CmdNotify: message => {
    console.log("通知消息", message);
    // 在这里添加具体的处理逻辑
    if (message.notify == "Kicked out") {
      // 被踢出时直接跳转到登录页面
      window.location.href = "/login";
    }
  },

  CmdDownloadVideoResult: message => {
    // 在这里添加具体的处理逻辑
    console.log("视频下载结果:", message);
    // setVideoUrl(message.friendMessageId, message.url);
  },

  // 朋友圈数据响应处理
  CmdFetchMomentResult: message => {
    console.log("朋友圈数据响应", message);
    const { wechatFriendId, wechatAccountId, result, isTimeline, seq } =
      message;
    const {
      setMomentOfKf,
      setMomentOfSquare,
      setMomentOfFriend,
      addMomentOfKf,
      addMomentOfSquare,
      addMomentOfFriend,
    } = useWeChatStore.getState();

    if (result && Array.isArray(result)) {
      // 判断是否为第一页数据（通过seq或数据长度）
      const isFirstPage = result.length > 0;

      // 根据wechatFriendId和isTimeline参数判断朋友圈类型
      if (wechatFriendId === 0) {
        if (isTimeline) {
          // 朋友圈广场
          if (isFirstPage) {
            setMomentOfSquare(result);
          } else {
            addMomentOfSquare(result);
          }
        } else {
          // 客服自己的朋友圈
          if (isFirstPage) {
            setMomentOfKf(result);
          } else {
            addMomentOfKf(result);
          }
        }
      } else {
        // 指定好友的朋友圈
        if (isFirstPage) {
          setMomentOfFriend(result);
        } else {
          addMomentOfFriend(result);
        }
      }
    }
  },

  // 可以继续添加更多处理器...
};

// 默认处理器
const defaultHandler: MessageHandler = message => {
  console.log("未知消息类型", message.cmdType, message);
};

// 注册新的消息处理器
export const registerMessageHandler = (
  cmdType: string,
  handler: MessageHandler,
) => {
  messageHandlers[cmdType] = handler;
};

// 移除消息处理器
export const unregisterMessageHandler = (cmdType: string) => {
  delete messageHandlers[cmdType];
};

// 获取所有已注册的消息类型
export const getRegisteredMessageTypes = (): string[] => {
  return Object.keys(messageHandlers);
};

// 消息管理核心函数
export const msgManageCore = (message: WebSocketMessage) => {
  const cmdType = message.cmdType;
  if (!cmdType) {
    console.warn("消息缺少cmdType字段", message);
    return;
  }

  // 获取对应的处理器，如果没有则使用默认处理器
  const handler = messageHandlers[cmdType] || defaultHandler;

  try {
    handler(message);
  } catch (error) {
    console.error(`处理消息类型 ${cmdType} 时发生错误:`, error);
  }
};