You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
354 lines
14 KiB
354 lines
14 KiB
using GDZZ.Core;
|
|
using Furion.DependencyInjection;
|
|
using Furion.DynamicApiController;
|
|
using Mapster;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
|
|
using System.Linq;
|
|
using System.Threading.Tasks;
|
|
using GDZZ.Application.Entity;
|
|
using System.Collections.Generic;
|
|
using K4os.Hash.xxHash;
|
|
using GDZZ.Core.Entity;
|
|
using Furion;
|
|
using GDZZ.Application.Help;
|
|
using Furion.LinqBuilder;
|
|
using System;
|
|
using static K4os.Compression.LZ4.Engine.Pubternal;
|
|
using Microsoft.AspNetCore.SignalR;
|
|
using GDZZ.Application.Service.LiveHistoryContacts.Dto;
|
|
using Microsoft.AspNetCore.Http;
|
|
using SqlSugar;
|
|
using System.IO;
|
|
using Yitter.IdGenerator;
|
|
using Microsoft.Extensions.Options;
|
|
using ICacheService = GDZZ.Application.Help.ICacheService;
|
|
using System.Threading;
|
|
using System.ComponentModel.Design;
|
|
using Furion.FriendlyException;
|
|
|
|
namespace GDZZ.Application
|
|
{
|
|
/// <summary>
|
|
/// 聊天服务
|
|
/// </summary>
|
|
[ApiDescriptionSettings("Application", Name = "LiveHistoryContacts", Order = 1)]
|
|
public class LiveHistoryContactsService : ILiveHistoryContactsService, IDynamicApiController, ITransient
|
|
{
|
|
private readonly SqlSugarRepository<LiveHistoryContacts> _rep; //聊天历史任务列表仓储
|
|
private readonly SqlSugarRepository<BaseUser> Baseuser; // wx用户仓储
|
|
private readonly SqlSugarRepository<LiveMessage> liveMessageRep; //消息仓储
|
|
private readonly SqlSugarRepository<LiveUserFriend> liveUserFriend; //好友表仓储
|
|
private readonly SqlSugarRepository<SysUser> _sysUserRep; // 用户表仓储
|
|
private readonly SqlSugarRepository<OnlineUser> _sysOnlineUerRep; // 在线用户表仓储
|
|
private readonly ICacheService cacheService;
|
|
private readonly IHubContext<ChatHub, IChatClient> _chatHubContext;
|
|
private readonly UploadFileOptions _options;
|
|
|
|
public LiveHistoryContactsService(SqlSugarRepository<LiveHistoryContacts> rep,
|
|
ICacheService cacheService,
|
|
IOptions<UploadFileOptions> options,
|
|
SqlSugarRepository<BaseUser> Baseuser,
|
|
SqlSugarRepository<SysUser> _sysUserRep,
|
|
SqlSugarRepository<OnlineUser> sysOnlineUerRep,
|
|
SqlSugarRepository<LiveUserFriend> liveUserFriend,
|
|
IHubContext<ChatHub, IChatClient> chatHubContext,
|
|
SqlSugarRepository<LiveMessage> liveMessageRep)
|
|
{
|
|
|
|
_rep = rep;
|
|
_options = options.Value;
|
|
this.Baseuser= Baseuser;
|
|
this.cacheService = cacheService;
|
|
this._chatHubContext= chatHubContext;
|
|
this._sysOnlineUerRep = sysOnlineUerRep;
|
|
this.liveUserFriend = liveUserFriend;
|
|
this.liveMessageRep = liveMessageRep;
|
|
this._sysUserRep = _sysUserRep;
|
|
}
|
|
|
|
#region 聊天列表
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
/// 新增联系人
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
[HttpPost("/Mini/LiveHistoryContacts/AddLive")]
|
|
public async Task<dynamic> AddLive(AddLiveFriendInput input)
|
|
{
|
|
|
|
SysUser user = new SysUser();
|
|
if (input.CompanyID.IsNullOrZero())
|
|
{
|
|
user = await this._sysUserRep.FirstOrDefaultAsync(x => x.Id == input.UserId);
|
|
if (user.IsNullOrZero())
|
|
throw Oops.Oh(ErrorCode.xg1002);
|
|
}
|
|
else
|
|
{
|
|
var buser = await this.Baseuser.FirstOrDefaultAsync(x => x.CompanyID == input.CompanyID);
|
|
user = await this._sysUserRep.Where(x => x.Id == buser.CreatedUserId).SingleAsync();
|
|
if (user.IsNullOrZero())
|
|
throw Oops.Oh(ErrorCode.xg1002);
|
|
}
|
|
|
|
//判断是是好友
|
|
var fends =await this.liveUserFriend.Where(x => x.FriendID == UserManager.UserId && x.CreatedUserId == user.Id).FirstAsync();
|
|
if (fends.IsNullOrZero())
|
|
{
|
|
|
|
List<LiveUserFriend> friends = new List<LiveUserFriend>();
|
|
if(user.Id != UserManager.UserId)
|
|
{
|
|
friends.Add(new LiveUserFriend()
|
|
{
|
|
FriendID = user.Id,
|
|
});
|
|
}
|
|
|
|
friends.Add(new LiveUserFriend()
|
|
{
|
|
FriendID = UserManager.UserId,
|
|
CreatedUserId = user.Id
|
|
});
|
|
foreach (var item in friends)
|
|
{
|
|
await this.liveUserFriend.InsertAsync(item);
|
|
}
|
|
}
|
|
|
|
if(!await this.cacheService.DelLiveHistoryService(UserManager.UserId))
|
|
throw Oops.Oh(ErrorCode.B1004);
|
|
return user;
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 咨询聊天
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
[HttpPost("/Mini/LiveHistoryContacts/AddConsultLive")]
|
|
public async Task<dynamic> AddConsultLive(AddLiveFriendInput input)
|
|
{
|
|
|
|
var user = await this._sysUserRep.Where(x => x.Id == input.UserId).SingleAsync();
|
|
if (user.IsNullOrZero())
|
|
throw Oops.Oh(ErrorCode.xg1002);
|
|
|
|
//判断是是好友
|
|
var fends = await this.liveUserFriend.Where(x => x.FriendID == UserManager.UserId && x.CreatedUserId == user.Id).FirstAsync();
|
|
if (fends.IsNullOrZero())
|
|
{
|
|
|
|
List<LiveUserFriend> friends = new List<LiveUserFriend>();
|
|
if (user.Id != UserManager.UserId)
|
|
{
|
|
friends.Add(new LiveUserFriend()
|
|
{
|
|
FriendID = user.Id,
|
|
});
|
|
}
|
|
|
|
friends.Add(new LiveUserFriend()
|
|
{
|
|
FriendID = UserManager.UserId,
|
|
CreatedUserId = user.Id
|
|
});
|
|
foreach (var item in friends)
|
|
{
|
|
await this.liveUserFriend.InsertAsync(item);
|
|
}
|
|
}
|
|
await this.cacheService.DelLiveHistoryService(UserManager.UserId);
|
|
return user;
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
/// 获取联系人列表
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
[HttpGet("/Mini/LiveHistoryContacts/list")]
|
|
public async Task<List<LiveHistoryLists>> List()
|
|
{
|
|
|
|
var history = await this.cacheService.GetLiveHistoryService(UserManager.UserId);
|
|
if (!history.IsNullOrEmpty())
|
|
return history;
|
|
|
|
List<LiveHistoryLists> historyLists = new List<LiveHistoryLists>();
|
|
//获取好友列表
|
|
var friends = await this.liveUserFriend.Where(x => x.CreatedUserId == UserManager.UserId).ToListAsync();
|
|
foreach (var item in friends)
|
|
{
|
|
|
|
//获取用户信息
|
|
var sysUser = await this._sysUserRep.SingleAsync(x => x.Id == item.FriendID);
|
|
if (sysUser == null)
|
|
continue;
|
|
var liveHis = new LiveHistoryLists()
|
|
{
|
|
Avatar = sysUser.Avatar,
|
|
DisplayName = sysUser.NickName,
|
|
Id = item.FriendID,
|
|
Index = sysUser.Name.Substring(0, 1),
|
|
LastSendTime = (DateTime.Now.ToUniversalTime().Ticks - 621355968000000000) / 10000000,
|
|
};
|
|
|
|
//查询聊天记录
|
|
//rm -rf mk dir ls install cd home //ru-rf
|
|
var live = await this.liveMessageRep.Where(x => x.CreatedUserId == UserManager.UserId && x.OtherUserID == item.FriendID || (x.CreatedUserId == item.FriendID && x.OtherUserID == UserManager.UserId)).OrderByDescending(x => x.CreatedTime).FirstAsync();
|
|
|
|
if (live != null)
|
|
{
|
|
|
|
var isNow = Utils.ShowHelp(live.SendTime);
|
|
if (isNow)
|
|
{
|
|
liveHis.LastSendTimeData = live.SendTime.ToString("HH:mm:ss");
|
|
}
|
|
else
|
|
{
|
|
liveHis.LastSendTimeData = live.SendTime.ToString("yyyy/MM/dd");
|
|
}
|
|
liveHis.LastSendTime = (live.SendTime.ToUniversalTime().Ticks - 621355968000000000) / 10000;
|
|
liveHis.Unread = await this.cacheService.GetUnreadAsync(UserManager.UserId, live.Id);
|
|
liveHis.LastContent = live.Content;
|
|
liveHis.Type = live.Type;
|
|
}
|
|
historyLists.Add(liveHis);
|
|
}
|
|
|
|
await this.cacheService.SetLiveHistoryService(UserManager.UserId, historyLists);
|
|
return historyLists;
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region 聊天详情
|
|
|
|
/// <summary>
|
|
/// 获取聊天详情
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
[HttpGet("/Mini/LiveHistoryContacts/GetMessageLists")]
|
|
public async Task<List<LiveMessageList>> GetMessageLists(long OtherUserID)
|
|
{
|
|
var res = await this.liveMessageRep.AsQueryable()
|
|
.Filter("TenantId", true)
|
|
.Where(x => x.CreatedUserId == UserManager.UserId && x.OtherUserID == OtherUserID
|
|
|| (x.CreatedUserId == OtherUserID && x.OtherUserID == UserManager.UserId)).ToListAsync();
|
|
return res.Adapt<List<LiveMessageList>>();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 增加聊天详情
|
|
/// </summary>
|
|
/// <param name="input"></param>
|
|
/// <returns></returns>
|
|
[HttpPost("/Mini/LiveHistoryContacts/addMessage")]
|
|
public async Task AddMessage(AddLiveMessageInput input)
|
|
{
|
|
var entity = input.Adapt<LiveMessage>();
|
|
entity.Content = Utils.stringToUnicode(entity.Content);
|
|
var live = this.liveMessageRep.InsertReturnEntity(entity);
|
|
var user = await _sysOnlineUerRep.Where(m => m.UserId == entity.OtherUserID).OrderByDescending(x=>x.LastTime).FirstAsync();
|
|
if (user != null)
|
|
{
|
|
var livemes = new LiveMessageInput()
|
|
{
|
|
id = live.Id.ToString(),
|
|
type = live.Type,
|
|
FileName = live.FileName,
|
|
content = live.Content,
|
|
sendTime = new DateTimeOffset((DateTime)live.CreatedTime).ToUnixTimeSeconds(),
|
|
status = "succeed",
|
|
toContactId = entity.OtherUserID,
|
|
fromUser = new Fromuser()
|
|
{
|
|
avatar = this._sysUserRep.FirstOrDefaultAsync(x => x.Id == UserManager.UserId).Result.Avatar,
|
|
displayName = UserManager.Name,
|
|
id = UserManager.UserId
|
|
}
|
|
};
|
|
var livejson = livemes.ToJsonString();
|
|
|
|
await _chatHubContext.Clients.Client(user.ConnectionId).SendMessage(livejson, "SendMessage");
|
|
}
|
|
}
|
|
|
|
|
|
|
|
//设置消息支付状态 --存入reids
|
|
|
|
|
|
/// <summary>
|
|
/// 上传文件
|
|
/// </summary>
|
|
/// <param name="file"></param>
|
|
/// <returns></returns>
|
|
[HttpPost("/Mini/LiveHistoryContacts/upload")]
|
|
public async Task<LiveFileOutput> UploadFileDefault(IFormFile file)
|
|
{
|
|
// 可以读取系统配置来决定将文件存储到什么地方
|
|
return await UploadFile(file, _options.Default.path, FileLocation.LOCAL);
|
|
}
|
|
/// <summary>
|
|
/// 上传文件
|
|
/// </summary>
|
|
/// <param name="file"></param>
|
|
/// <param name="pathType"></param>
|
|
/// <param name="fileLocation"></param>
|
|
/// <returns></returns>
|
|
private static async Task<LiveFileOutput> UploadFile(IFormFile file, string pathType, FileLocation fileLocation)
|
|
{
|
|
var fileSizeKb = (long)(file.Length / 1024.0); // 文件大小KB
|
|
var originalFilename = file.FileName; // 文件原始名称
|
|
var fileSuffix = Path.GetExtension(file.FileName).ToLower(); // 文件后缀
|
|
|
|
// 先存库获取Id
|
|
var id = YitIdHelper.NextId();
|
|
var newFile = new SysFile
|
|
{
|
|
Id = id,
|
|
FileLocation = (int)FileLocation.LOCAL,
|
|
FileBucket = FileLocation.LOCAL.ToString(),
|
|
FileObjectName = $"{YitIdHelper.NextId()}{fileSuffix}",
|
|
FileOriginName = originalFilename,
|
|
FileSuffix = fileSuffix.TrimStart('.'),
|
|
FileSizeKb = fileSizeKb.ToString(),
|
|
FilePath = pathType
|
|
};
|
|
newFile = await App.GetService<ISqlSugarClient>().Insertable(newFile).ExecuteReturnEntityAsync();
|
|
|
|
var finalName = newFile.FileObjectName; // 生成文件的最终名称
|
|
if (fileLocation == FileLocation.LOCAL) // 本地存储
|
|
{
|
|
var filePath = Path.Combine(App.WebHostEnvironment.WebRootPath, pathType);
|
|
if (!Directory.Exists(filePath))
|
|
Directory.CreateDirectory(filePath);
|
|
using (var stream = File.Create(Path.Combine(filePath, finalName)))
|
|
{
|
|
await file.CopyToAsync(stream);
|
|
}
|
|
}
|
|
else if (fileLocation == FileLocation.ALIYUN) // 阿里云OSS
|
|
{
|
|
var filePath = pathType + finalName;
|
|
OSSClientUtil.DeletefileCode(filePath);
|
|
|
|
var stream = file.OpenReadStream();
|
|
OSSClientUtil.PushMedia(stream, filePath);
|
|
}
|
|
newFile.FileObjectName = finalName;
|
|
return new LiveFileOutput() { Id = finalName, FileUrl= "/"+pathType + "/"+ finalName }; // 返回文件唯一标识
|
|
}
|
|
|
|
#endregion
|
|
|
|
}
|
|
}
|