Yi.Framework/Yi.Abp.Net8/module/digital-collectibles/Yi.Framework.DigitalCollectibles.Application/Services/Tool/CollectiblesToolService.cs

using System.IO.Compression;
using FreeRedis;
using Volo.Abp.Application.Services;
using Volo.Abp.Caching;
using Yi.Framework.DigitalCollectibles.Domain.Entities;
using Yi.Framework.DigitalCollectibles.Domain.Entities.Record;
using Yi.Framework.DigitalCollectibles.Domain.Shared.Consts;
using Yi.Framework.SqlSugarCore.Abstractions;

namespace Yi.Framework.DigitalCollectibles.Application.Services.Tool;

public class CollectiblesToolService : ApplicationService
{
    private ISqlSugarRepository<CollectiblesAggregateRoot> _repository;
    private ISqlSugarRepository<MiningPoolRecordAggregateRoot> _recordRepository;

    private IRedisClient RedisClient => LazyServiceProvider.LazyGetRequiredService<IRedisClient>();

    public CollectiblesToolService(ISqlSugarRepository<CollectiblesAggregateRoot> repository,
        ISqlSugarRepository<MiningPoolRecordAggregateRoot> recordRepository)
    {
        _repository = repository;
        _recordRepository = recordRepository;
    }

    public async Task<object> DeleteInitAsync()
    {
        var directoryPath = Path.Combine("wwwroot", "dc", "data");
        var dataPath = Path.Combine("wwwroot", "dc", "data", "data.zip");
        if (!Directory.Exists(directoryPath))
        {
            Directory.CreateDirectory(directoryPath);
        }

        if (!File.Exists(dataPath))
        {
            throw new UserFriendlyException($"{dataPath}路径不存在数据");
        }

        ZipFile.ExtractToDirectory(dataPath, directoryPath, true); // true 表示覆盖已有文件


        var txtPath = Path.Combine("wwwroot", "dc", "data", "data.txt");
        if (!File.Exists(txtPath))
        {
            throw new UserFriendlyException($"{txtPath}路径不存在文本");
        }

        var lines = await File.ReadAllLinesAsync(txtPath);
        var errData = new List<string>();
        //自动开启事务
        List<CollectiblesAggregateRoot> entities = new List<CollectiblesAggregateRoot>();
        for (int i = 0; i < lines.Length; i++)
        {
            var line = lines[i];
            if (string.IsNullOrEmpty(line))
            {
                continue;
            }

            var items = line.Split(",").ToList();


            if (items.Count != 6)
            {
                errData.Add($"{i}行数据存，数据不对，只能6个数据");
            }

            var fileName = items[0];
            var code = Path.GetFileNameWithoutExtension(fileName);
            var name = items[1];
            var value = decimal.Parse(items[2]);
            var url = $"https://ccnetcore.com/prod-api/wwwroot/dc/data/{fileName}";
            var rarity = int.Parse(items[3]);
            var des = items[4];
            var find = int.Parse(items[5]);

            var entity = new CollectiblesAggregateRoot
            {
                Code = code,
                Name = name,
                Describe = des,
                ValueNumber = value,
                Url = url,
                Rarity = (RarityEnum)Enum.ToObject(typeof(RarityEnum), rarity),
                FindTotal = find,
                OrderNum = 0
            };
            entities.Add(entity);

            if (!File.Exists(Path.Combine(directoryPath, fileName)))
            {
                errData.Add($"文件不存在：{Path.Combine(directoryPath, fileName)}");
            }
        }

        if (errData.Any())
        {
            return new { ok = false, errData };
        }

        var allCode = await _repository._DbQueryable.Select(x => x.Code).ToListAsync();

        var existCodes = allCode.Intersect(entities.Select(x => x.Code)).ToList();
        if (existCodes.Count > 0)
        {
            return new { ok = false, existCodes };
        }


        await _repository.InsertRangeAsync(entities);
        return new { ok = true, entities };
    }


    /// <summary>
    /// 跑马灯内容
    /// </summary>
    /// <returns></returns>
    public async Task<List<string>> GetNoticeAsync()
    {
        //获取最新的3条挖矿记录,高级
        var record = await _recordRepository._DbQueryable
            .LeftJoin<CollectiblesAggregateRoot>((x, c) => x.CollectiblesId == c.Id)
            .Where((x,c)=>c.Rarity>=RarityEnum.Senior)
            .OrderByDescending((x, c) => x.CreationTime)
            .Select((x, c) => new
            {
                c.Name,
                c.ValueNumber,
                c.Rarity
            })
            .ToPageListAsync(1, 3);

        var output = new List<string>();

        var firstNoticeOrNull = await RedisClient.GetAsync("Yi:Notice");
        if (firstNoticeOrNull is not null)
        {
            output.Add(firstNoticeOrNull);
        }
        
        foreach (var item in record)
        {
            output.Add($"恭喜神秘用户，挖到【{item.Rarity.GetRarityName()}-{item.Name}】，价值【{(int)(item.ValueNumber)}】");
        }


        return output;
    }
}