using System.Text;
using Dpz.Core.Service.Network;
using Dpz.Core.Service.Network.Models;
using Dpz.Core.Service.RepositoryService;
using Hangfire;
using JetBrains.Annotations;
using Medallion.Threading;
using Microsoft.Extensions.Logging;

namespace Dpz.Core.Hangfire;

[UsedImplicitly]
public class AnalyzeCodeActivator(
    ChatCompletionService chatCompletionService,
    ICodeFileSystemEntryService codeFileSystemEntryService,
    IDistributedLockProvider distributedLockProvider,
    ILogger<AnalyzeCodeActivator> logger
) : JobActivator
{
    /// <summary>
    /// analyze code
    /// </summary>
    /// <param name="codeContent"></param>
    /// <param name="path"></param>
    /// <param name="fileName"></param>
    [ProlongExpirationTime]
    public async Task AnalyzeAsync(string codeContent, string[] path, string fileName)
    {
        if (GetContentLineCount(codeContent) < 50)
        {
            return;
        }

        var keyParts = new List<string>(path) { fileName };
        var subKey = Convert.ToBase64String(Encoding.UTF8.GetBytes(string.Join("\0", keyParts)));
        var lockKey = $"AI_Analyze.Code.Lock:{subKey}";
        await using (await distributedLockProvider.AcquireLockAsync(lockKey))
        {
            var entryPath = keyParts.ToArray();
            var entry = await codeFileSystemEntryService.FindByPathWithoutCacheAsync(entryPath);
            if (entry == null)
            {
                return;
            }

            var sourceHash = entry.Hash;
            var hasFreshAnalyzeResult =
                !string.IsNullOrWhiteSpace(entry.AiAnalyzeResult)
                && string.Equals(
                    entry.AiAnalyzeHash,
                    sourceHash,
                    StringComparison.OrdinalIgnoreCase
                );
            if (hasFreshAnalyzeResult)
            {
                return;
            }

            var prompt = new StringBuilder(codeContent)
                .AppendLine()
                .AppendLine()
                .AppendLine("-------")
                .AppendLine()
                .AppendLine()
                .Append("请解释一下上述代码的功能")
                .ToString();
            var result = await chatCompletionService.SendChatAsync(
                [
                    new ChatMessage
                    {
                        Role = "system",
                        Message = "你是一个经验丰富且专业的开发人员",
                    },
                    new ChatMessage { Role = "user", Message = prompt },
                ],
                x => x.Model = AiModel.Gpt5Mini
            );

            if (result is { Success: true, Data: not null })
            {
                logger.LogInformation(
                    "AI分析成功 | Path:{@Path} File:{FileName},Data:{@Data}",
                    path,
                    fileName,
                    result.Data
                );
                var content =
                    result.Data?.Choices.Count > 0
                        ? result.Data.Choices[0].Message.Content
                        : string.Empty;

                // 重新检查哈希值，以避免在 AI 调用期间源发生更改时写入过时的分析结果。
                var latestEntry = await codeFileSystemEntryService.FindByPathWithoutCacheAsync(
                    entryPath
                );
                if (
                    latestEntry == null
                    || !string.Equals(
                        latestEntry.Hash,
                        sourceHash,
                        StringComparison.OrdinalIgnoreCase
                    )
                )
                {
                    logger.LogInformation(
                        "跳过写入过期AI分析结果，文件已变更。Path:{@Path} File:{FileName} CurrentHash:{CurrentHash} AnalyzeHash:{AnalyzeHash}",
                        path,
                        fileName,
                        latestEntry?.Hash,
                        sourceHash
                    );
                    return;
                }

                await codeFileSystemEntryService.SaveAiAnalyzeResultAsync(
                    path,
                    fileName,
                    content,
                    sourceHash
                );
                return;
            }

            logger.LogWarning(
                "AI分析失败 | 错误信息:{Message} | Path:{@Path} File:{FileName},Arguments:{@Arguments}",
                result.Message,
                path,
                fileName,
                result.Arguments
            );
        }
    }

    private static int GetContentLineCount(string codeContent)
    {
        return codeContent.Split(["\r\n", "\r", "\n"], StringSplitOptions.None).Length;
    }
}