using Furion.DatabaseAccessor;
using Furion.DependencyInjection;
using Furion.DistributedIDGenerator;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace ApiTools.Core
{
    public class ChannelWalletTransactionRepository : BaseRepository<ChannelWalletTransaction, MasterDbContextLocator>, IScoped
    {
        public ChannelWalletTransactionRepository(IRepository<ChannelWalletTransaction, MasterDbContextLocator> rep) : base(rep)
        {
        }

        public Task<bool> CheckExist(string code, Guid? id)
        {
            return GetQueryableIgnoreFilter()
                    .AnyAsync(it => it.Code == code && it.Id != id);
        }

        /// <summary>
        /// 设置编号
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        public async Task SetCode(ChannelWalletTransaction entity)
        {
            entity.Code = $"{DateTime.Now:yyyyMMddHHmmss}{new Random(IDGen.NextID().GetHashCode()).Next(1000, 9999)}";
            var exist = await CheckExist(entity.Code, entity.Id);
            if (exist)
            {
                await SetCode(entity);
            }
        }

    }
}