using Furion.DatabaseAccessor;
|
using Furion.DependencyInjection;
|
using Furion.DistributedIDGenerator;
|
using Furion.FriendlyException;
|
using Microsoft.EntityFrameworkCore;
|
using pingan.openbank.api.sdk.enums;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
|
namespace ApiTools.Core
|
{
|
/// <summary>
|
/// 企业钱包仓库
|
/// </summary>
|
public class ChannelWalletRepository : BaseRepository<ChannelWallet, MasterDbContextLocator>, IScoped
|
{
|
public ChannelWalletRepository(IRepository<ChannelWallet, MasterDbContextLocator> rep) : base(rep)
|
{
|
}
|
|
public override IQueryable<ChannelWallet> GetQueryable(bool noTracking = true)
|
{
|
var q = rep.GetQueryable(noTracking);
|
if (logier != null)
|
{
|
switch (logier.Type)
|
{
|
case EnumUserType.Channel:
|
q = q.Where(it => it.ChannelId == logier.ChannelId);
|
break;
|
case EnumUserType.Operation:
|
break;
|
default:
|
break;
|
}
|
}
|
return q;
|
}
|
|
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(ChannelWallet 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);
|
}
|
}
|
|
}
|
}
|
