using AllBase;
using AllBase.Helper;
using AllBase.Model.Result;
using CsharpHttpHelper;
using NaiBa.Util.Helper;
using System;
using System.Collections.Generic;
using System.Globalization;
using System.Threading.Tasks;
using Work.Services;
using static System.Windows.Forms.VisualStyles.VisualStyleElement.StartPanel;

namespace Work.Store.Api;

/// <summary>云商品接口，沿用服务端不带版本号的路由。</summary>
public sealed class CloudGoodsApi
{
	private readonly ApiTransport _transport;

	public CloudGoodsApi(ApiTransport transport)
		=> _transport = transport ?? throw new ArgumentNullException(nameof(transport));

	public Task<PageData<CloudGoods>> GetGoods(GoodsSearchRequest request)
		=> _transport.GetRequiredAsync<PageData<CloudGoods>>("CloudGoods/SearchGoods", MethodType.Post, request);

	public string GetGoodsDetail(long goodsId)
		=> _transport.GetRequired<string>("CloudGoods/GetGoodsRawData", MethodType.Post,
			query: new Dictionary<string, string> { ["goodsId"] = goodsId.ToString(CultureInfo.InvariantCulture) });

	public Task<List<ReportGoodsViolationResult>> ReportViolations(List<ReportGoodsViolationItem> items)
		=> _transport.GetRequiredAsync<List<ReportGoodsViolationResult>>("CloudGoods/ReportViolations", MethodType.Post, items,
			timeoutMilliseconds: 5000);

	public List<GoodsViolationStatus> GetViolationStatus(List<long> goodsIds)
		=> _transport.GetRequired<List<GoodsViolationStatus>>("CloudGoods/GetViolationStatus", MethodType.Post, goodsIds,
			timeoutMilliseconds: 5000);

	public Task RecordViolationLogs(IReadOnlyList<RecordViolationLogRequest> requests)
		=> _transport.SendAsync<object>("CloudGoods/RecordViolationLog", MethodType.Post, requests,
			timeoutMilliseconds: 5000);

	public Task<List<CloudGoodsService.ViolationReason>> GetViolationReasons()
		=> _transport.GetRequiredAsync<List<CloudGoodsService.ViolationReason>>("CloudGoods/GetViolationReasons", MethodType.Get);

	public Task<List<GoodsViolationLogEntity>> GetViolationLogs(GetViolationLogsRequest request)
		=> _transport.GetRequiredAsync<List<GoodsViolationLogEntity>>("CloudGoods/GetViolationLogs", MethodType.Post, request,
			timeoutMilliseconds: 5000);

	public Task<PageData<CloudGoods>> SearchFavorites(UserFavoritesGoodsSearchRequest request)
		=> _transport.GetRequiredAsync<PageData<CloudGoods>>("CloudGoods/SearchFavorites", MethodType.Post, request);

	public Task<int> Favorite(string userName, List<long> goodsIds,int groupId)
		=> _transport.SendAsync<int>("CloudGoods/AddFavorite", MethodType.Post,
			new { UserName = userName, GoodsIds = goodsIds, GroupId= groupId });

	public Task<int> RemoveFavorites(string userName, List<long> goodsIds)
		=> _transport.SendAsync<int>("CloudGoods/RemoveFavorites", MethodType.Post,
			new { UserName = userName, GoodsIds = goodsIds });

	/// <summary>
	/// 创建分组
	/// </summary>
	/// <param name="userName"></param>
	/// <param name="groupName"></param>
	/// <returns></returns>
	public async Task<bool> CreateGroup(string userName, string groupName)
	{
		return await _transport.SendAsync<bool>("CloudGoods/CreateGroup", MethodType.Post,
			new { UserName = userName, GroupName = groupName });
	}
	public async Task<bool> DelGroupAsync(string userName, string groupName)
	{
		return await _transport.SendAsync<bool>("CloudGoods/DelGroup", MethodType.Post,
			new { UserName = userName, GroupName = groupName });
	}
	public async Task<bool> SetFavoriteGroupAsync(string userName, int groupId, IEnumerable<long> goodsIds)
	{
		return await _transport.SendAsync<bool>("CloudGoods/SetFavoriteGroup", MethodType.Post,
			new { UserName = userName, GroupId = groupId, GoodsIds = goodsIds });
	}
	public async Task<List<UserFavoriteGroup>> GetGroups(string userName)
	{
		return await _transport.SendAsync<List<UserFavoriteGroup>>($"CloudGoods/GetGroups?UserName={userName}", MethodType.Post);
	}


	/// <summary>识别上传图片中的文字和品牌 Logo。</summary>
	public async Task<List<string>> RecognizeAsync(string urlMd5, byte[] jpeg)
	{
		int sleep = 0;
		if (EnvironmentHelper.IsProduction)
		{
			sleep = RandomHelper.GetRandom(600, 1200);
		}
		var minimumDuration = Task.Delay(TimeSpan.FromMilliseconds(sleep));
		var request = new { UserName = BaseClass.UserName, Md5 = urlMd5, Image = Convert.ToBase64String(jpeg) };
		var recognitionTask = _transport.GetRequiredAsync<List<string>>("CloudGoods/InspectImage", MethodType.Post, request);
		await Task.WhenAll(minimumDuration, recognitionTask).ConfigureAwait(false);
		return await recognitionTask.ConfigureAwait(false);
	}

	public async Task SaveProductSafety(SaveProductSafetyRequest request)
	{
		var ret = await _transport.SendAsync<int>("CloudGoods/SaveProductSafety", MethodType.Post, new
		{
			UserName = request.UserName,
			ProductId = request.ProductId,
			IsSafe = request.IsSafe
		});

	}
}