using AllBase.Helper;
using AllBase;
using AllBase.Model;
using System.Collections.Generic;
using System;
using System.Linq;
using Work.Services;

// Compile against the built Work.dll, AllBase.dll and Newtonsoft.Json.dll and run in an isolated directory.
internal static class GoodsComplianceSmoke
{
    private static void Check(bool passed)
    {
        if (!passed) throw new Exception("商品合规自测失败");
    }

    public static void Main()
    {
        var user = Guid.NewGuid().ToString();
        BaseClass.UserName = user;
        GlobalConfig.GlobalSettings.GoodsCompliance = new ComplianceOptions { Keywords = "测试" };
        var cloud = new ComplianceGoods { id = "123", type = ComplianceGoods.Cloud };
        var library = new ComplianceGoods { id = "123", type = ComplianceGoods.Library };
        var attempted = new List<ComplianceGoods>();
        var failures = new List<string>();
        var batch = GoodsComplianceService.DetectSelectedAsync(new[] { cloud, cloud, library }, item =>
        {
            attempted.Add(item);
            throw new InvalidOperationException("读取失败");
        }, (id, status) => { if (status == "失败：读取失败") failures.Add(id); }).GetAwaiter().GetResult();
        Check(attempted.SequenceEqual(new[] { cloud, library }) && failures.Count == 2);
        var file = System.IO.Directory.GetFiles(System.IO.Path.Combine(AppDomain.CurrentDomain.BaseDirectory,
            "data", "config"), "goods_compliance_" + Convert.ToBase64String(System.Text.Encoding.UTF8.GetBytes(user)) + ".json").Single();
        Check(Newtonsoft.Json.JsonConvert.DeserializeObject<List<ComplianceGoods>>(System.IO.File.ReadAllText(file))
            .Select(x => x.type).SequenceEqual(new[] { cloud.type, library.type }));
        Check(batch.Safe == 0 && batch.Risk == 0 && batch.Failed == 2 && batch.Unfinished == 0);
        using (var stop = new System.Threading.CancellationTokenSource())
        {
            attempted.Clear();
            var stopped = GoodsComplianceService.DetectSelectedAsync(new[] { cloud, library }, item =>
            {
                attempted.Add(item);
                stop.Cancel();
                return new Product { ProductId = item.id };
            }, (id, status) => { }, stop.Token).GetAwaiter().GetResult();
            Check(attempted.SequenceEqual(new[] { cloud }) && stopped.Unfinished == 2 && stopped.Failed == 0);
            Check(Newtonsoft.Json.JsonConvert.DeserializeObject<List<ComplianceGoods>>(System.IO.File.ReadAllText(file)).Count == 2);
        }
        var words = GoodsComplianceService.Keywords("广告,测试，abc 促销;ABC|示例");
        Check(words.Length == 5);
        Check(GoodsComplianceService.Matches("ABC广告", words).SequenceEqual(new[] { "广告", "abc" }));
        Check(GoodsComplianceService.Matches("普通商品", words).Length == 0);
        // Exercise detection without calling the reporting API.
        var detect = typeof(GoodsComplianceService).GetMethod("DetectProductAsync",
            System.Reflection.BindingFlags.NonPublic | System.Reflection.BindingFlags.Static);
        var titleHit = ((System.Threading.Tasks.Task<ComplianceResult>)detect.Invoke(null, new object[]
        {
            new Product { ProductId = "title", Title = "ABC广告" }, new ComplianceOptions(), words, null,
            System.Threading.CancellationToken.None
        })).GetAwaiter().GetResult();
        Check(titleHit.Status == "有风险" && titleHit.Summary == "有风险：标题命中关键词：广告，abc");
        var invalidImage = new Product { ProductId = "bad-image", MainImages = new List<string> { "file:///image.jpg" } };
        var statuses = new List<string>();
        GoodsComplianceService.DetectSelectedAsync(new[] { cloud }, item => invalidImage,
            (id, status) => statuses.Add(status)).GetAwaiter().GetResult();
        Check(statuses.SequenceEqual(new[] { "读取详情中", "正在检测第 1 张图片", "失败：第 1 张图片检测失败：图片链接必须为 HTTP 或 HTTPS 地址。" }));
        var products = new[] { new Product(), new Product { ProductId = "empty" }, invalidImage };
        var callbacks = new List<Product>();
        GoodsComplianceService.DetectAsync(products, new ComplianceOptions { Keywords = "测试" }, (product, result) =>
        {
            Check(result.Error != null);
            if (product == invalidImage) Check(result.Error.Contains("第 1 张图片") && result.Error.Contains("HTTP"));
            callbacks.Add(product);
        }).GetAwaiter().GetResult();
        Check(callbacks.SequenceEqual(products));
        System.IO.File.Delete(file);
        Console.WriteLine("商品合规队列与匹配自测通过");
    }
}