using System; using System.Collections.Generic; using System.Threading.Tasks; using Dapper; using Datory; using GxPress.Common.AppOptions; using GxPress.Common.Tools; using GxPress.Entity.WorkMeeting; using GxPress.Repository.Interface.WorkMeeting; using GxPress.Result.Meeting; using Microsoft.Extensions.Caching.Distributed; using Microsoft.Extensions.Options; using SqlKata; namespace GxPress.Repository.Implement.WorkMeeting { public class MeetingOrderRepository : IMeetingOrderRepository { private readonly Repository _repository; public MeetingOrderRepository(IOptionsMonitor dbOptionsAccessor, IDistributedCache cache) { var databaseType = StringUtils.ToEnum(dbOptionsAccessor.CurrentValue.DatabaseType, DatabaseType.MySql); var database = new Database(databaseType, dbOptionsAccessor.CurrentValue.ConnectionString); _repository = new Repository(database, cache); } public IDatabase Database => _repository.Database; public string TableName => _repository.TableName; public List TableColumns => _repository.TableColumns; public async Task InsertAsync(MeetingOrder item) { return await _repository.InsertAsync(item); } public async Task> GetListAsync(int roomId) { return await _repository.GetAllAsync(Q.Where(nameof(MeetingOrder.RoomId), roomId)); } public async Task> GetListByMeetingIdAsync(int meetingId) { return await _repository.GetAllAsync(Q.Where(nameof(MeetingOrder.MeetingId), meetingId).OrderByDesc(nameof(MeetingOrder.Date))); } public async Task> GetListAsyncSinceNow(int roomId) { string sql = $@"SELECT a.*,c.Id as UserId,c.Name as UserName FROM tede_meeting_order a INNER JOIN tede_meeting b ON a.MeetingId = b.Id INNER JOIN tede_user c ON c.Id = b.UserId WHERE a.RoomId ={roomId} AND a.Date >= date_format(NOW() , '%Y%m%d')"; var database = new Database(DatabaseType.MySql, ConfigHelper.GetValue("Database:ConnectionString")); var connection = database.GetConnection(); return await connection.QueryAsync(sql); } public async Task DeleteAsync(int orderId) { return await _repository.DeleteAsync(orderId); } public async Task DeleteByRoomIdAsync(int roomId) { await _repository.DeleteAsync(Q.Where(nameof(MeetingOrder.RoomId), roomId)); } public async Task DeleteByMeetingIdAsync(int meetingId) { await _repository.DeleteAsync(Q.Where(nameof(MeetingOrder.MeetingId), meetingId)); } public async Task DeleteAsync(Query query) { return await _repository.DeleteAsync(query) > 0; } } }