94 lines
2.7 KiB
C#
94 lines
2.7 KiB
C#
using System.Collections.Generic;
|
|
using Fantasy;
|
|
using Fantasy.Async;
|
|
using Fantasy.Entitas;
|
|
using Fantasy.Entitas.Interface;
|
|
using Fantasy.Helper;
|
|
using NB.Game;
|
|
|
|
namespace NB.Chat;
|
|
|
|
public class MailManageComponentDestroySystem : DestroySystem<MailManageComponent>
|
|
{
|
|
protected override void Destroy(MailManageComponent self)
|
|
{
|
|
foreach (var (_, conversation) in self.Conversations)
|
|
{
|
|
conversation.Dispose();
|
|
}
|
|
|
|
self.Conversations.Clear();
|
|
}
|
|
}
|
|
|
|
public static class MailManageComponentSystem
|
|
{
|
|
public static async FTask DeleteConversation(this MailManageComponent self, long selfId, long otherId)
|
|
{
|
|
var firstId = selfId;
|
|
var secondId = otherId;
|
|
if (otherId < selfId)
|
|
{
|
|
firstId = otherId;
|
|
secondId = selfId;
|
|
}
|
|
|
|
var key = $"{firstId}-{secondId}";
|
|
|
|
if (self.Conversations.Remove(key, out var conversation))
|
|
{
|
|
await MailConversationHelper.DeleteDataBase(conversation.Scene, conversation.Id);
|
|
conversation.Dispose();
|
|
}
|
|
}
|
|
|
|
public static async FTask<MailConversation?> GetConversation(this MailManageComponent self, long selfId,
|
|
long otherId)
|
|
{
|
|
var firstId = selfId;
|
|
var secondId = otherId;
|
|
if (otherId < selfId)
|
|
{
|
|
firstId = otherId;
|
|
secondId = selfId;
|
|
}
|
|
|
|
var key = $"{firstId}-{secondId}";
|
|
if (!self.Conversations.TryGetValue(key, out var conversation))
|
|
{
|
|
//检查数据库中是否存在
|
|
conversation = await MailConversationHelper.LoadDataBase(self.Scene, firstId, secondId);
|
|
if (conversation == null)
|
|
{
|
|
//检查id是否合法
|
|
var roleInfo = await CacheHandler.GetPlayerBasicCacheInfo(self.Scene, otherId);
|
|
if (roleInfo == null)
|
|
{
|
|
return null;
|
|
}
|
|
|
|
conversation = Entity.Create<MailConversation>(self.Scene, true, true);
|
|
|
|
conversation.FirstId = firstId;
|
|
conversation.SecondId = secondId;
|
|
|
|
conversation.Key = key;
|
|
await conversation.Save(false);
|
|
}
|
|
|
|
self.Conversations.Add(key, conversation);
|
|
}
|
|
|
|
return conversation;
|
|
}
|
|
|
|
public static async FTask<List<MailConversation>> GetConversations(this MailManageComponent self, long id)
|
|
{
|
|
List<MailConversation> players =
|
|
await self.Scene.World.Database.QueryByPageOrderBy<MailConversation>(
|
|
d => d.FirstId == id || d.SecondId == id, 1, 50,
|
|
d => d.UpdateTime);
|
|
|
|
return players;
|
|
}
|
|
} |