using System;
using System.Collections.Generic;
using Amazon.Lambda.Core;
using Amazon.Lambda.APIGatewayEvents;
using Newtonsoft.Json;
using MySqlConnector;
using Newtonsoft.Json.Linq;
using System.Data;
using classes;
using System.Net.Http;
using System.Net;
using Model.ResponseModel;
using System.Threading.Tasks;
using System.Linq;

namespace PMF
{
    public class IForceOutStandingFines: Pmfbase
    {
       
        public async Task<APIGatewayProxyResponse> GetOutstandingFines(APIGatewayProxyRequest request, ILambdaContext context)
        {
            string statement = "GetOutStandingFines";
            string userId = "";
            string phaseDetail = "";
            MySqlDataReader _reader = null;

            try
            {
                if (!Helper.IsRequestEmpty(request))
                {
                    string validationMessage = string.Empty;

                    var validRequest = Helper.ValidateRequestParameters(ref validationMessage, request.QueryStringParameters, "noticeNumber", "Id");

                    if (validRequest)
                    {
                        string attribute = "0"; //Notice Number
                        var attributeValue = request.QueryStringParameters["noticeNumber"];
                        userId = request.QueryStringParameters["Id"];

                        var handler = new HttpClientHandler();

                        handler.ServerCertificateCustomValidationCallback = Helper.ServerCertificateCustomValidation;

                        var client = new HttpClient(handler)
                        {
                            BaseAddress = new Uri(baseUrl),
                            Timeout = TimeSpan.FromSeconds(Constants.TimeDefaultValue)
                        };

                        try
                        {
                            var iForceResponse = await client.GetAsync($"IForce/queryopenfines?Attribute={attribute}&FineQueryAttributeValue={attributeValue}");

                            var body = await iForceResponse.Content.ReadAsStringAsync();

                            if (iForceResponse.StatusCode == HttpStatusCode.OK)
                            {
                                _logger.WriteLog(userId, statement, body, "TMT");
                                var payload = JsonConvert.DeserializeObject<IForceQueryFinesResponse>(body);
                                payload.fines = payload.fines.ToList();

                                var transformedFines = new List<FineStatus>();

                                foreach (var fine in payload.fines)
                                {
                                    var paidLocalStatus = PaymentChecker.CheckLocalPaymentStatus(fine.noticeNumber, _con);

                                    if (fine.paymentAllowed == false) paidLocalStatus = false;

                                    switch (fine.phase)
                                    {
                                        case 1:
                                            phaseDetail = "Notice";
                                            break;
                                        case 2:
                                            phaseDetail = "Summons";
                                            break;
                                        case 3:
                                            phaseDetail = "Court";
                                            break;
                                        case 4:
                                            phaseDetail = "Warrant";
                                            break;
                                        default:
                                            phaseDetail = "Unknown";
                                            break;

                                    }
                                    transformedFines.Add(new FineStatus
                                    {
                                        issuingAuthorityCode = fine.issuingAuthorityCode,
                                        districtName = fine.districtName,
                                        noticeNumber = fine.noticeNumber,
                                        offenceDate = fine.offenceDate,
                                        location = fine.location,
                                        idNumber = fine.idNumber,
                                        vehicleRegistrationNumber = fine.vehicleRegistrationNumber,
                                        phase = phaseDetail,
                                        paymentAllowed = fine.paymentAllowed,
                                        paymentNotAllowedCode = fine.paymentNotAllowedCode,
                                        dueDate = fine.dueDate,
                                        totalAmountDue = fine.totalAmountDue,
                                        contemptOfCourtAmount = fine.contemptOfCourtAmount,
                                        summonsNumber = fine.summonsNumber,
                                        caseNumber = fine.caseNumber,
                                        courtCode = fine.courtCode,
                                        courtName = fine.courtName,
                                        courtDate = fine.courtDate,
                                        warrantOfArrestNumber = fine.warrantOfArrestNumber,
                                        warrantOfArrestPending = fine.warrantOfArrestPending,
                                        evidence = fine.evidence,
                                        customerPaymentAllowed = paidLocalStatus
                                    });
                                }

                                var result = new IForceQueryFinesResponseStatusModel
                                {
                                    transactionId = payload.transactionId,
                                    resultCode = payload.resultCode,
                                    resultDescription = payload.resultDescription,
                                    fines = transformedFines.ToList()
                                };

                                if(result.fines.Count==0) return HttpService.CreateResponse(200, payload: "No fines found");

                                return HttpService.CreateResponse(200, payload: result);
                            }
                            else
                            {
                                var error = JsonConvert.DeserializeObject<ErrorResponse>(body);
                                _logger.WriteLog(userId, statement, error.message, "TMT");
                                return HttpService.CreateResponse(error.statusCode, payload: $"No fines found for {attributeValue}");
                            }
                        }
                        catch (Exception)
                        {
                            return HttpService.CreateResponse(504, payload: Constants.NO_RESPONSE);
                        }
                    }
                    else
                    {
                        return HttpService.CreateResponse(400, payload: $"{validationMessage}");
                    }
                }
                else
                {
                    _logger.LogMessage(context, $"Processing request failed invalid request");
                    return HttpService.CreateResponse(400, payload: "No parameters provided");
                }
            }
            catch (Exception ex)
            {
                _logger.WriteLog(userId, statement, ex.Message, "TMT");
                return HttpService.CreateResponse(500, payload: ex.Message);
            }
            finally
            {
                if (_reader != null) _reader.Close();
                if (_con != null || _con.State == ConnectionState.Open) _con.Close();
            }
        }

    }

}