You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
538 lines
26 KiB
538 lines
26 KiB
using DealerSelection.Api.CommonUtil;
|
|
using CustomerDetailRepo = DealerSelection.Api.Infrastructure.CustomerDetail;
|
|
using DealerSelection.Api.Infrastructure.Mulesoft;
|
|
using DealerSelection.Api.Interface;
|
|
using DealerSelection.Api.Models;
|
|
using DealerSelection.Api.Models.Enum;
|
|
using DealerSelection.Common.Configuration;
|
|
using DealerSelection.Common.Interfaces.HttpClient;
|
|
using DealerSelection.Common.Logging;
|
|
using Microsoft.Extensions.Caching.Memory;
|
|
using Microsoft.Extensions.Logging;
|
|
using Newtonsoft.Json;
|
|
using Newtonsoft.Json.Linq;
|
|
using System.Text;
|
|
|
|
public class MulesoftApi : IMulesoftApi
|
|
{
|
|
|
|
#region MuleSoft
|
|
|
|
public static string baseApiUrl = ConfigurationHelper.GetSetting<string>("muleSoftAPIDomain", true);
|
|
public static string dealerDetailApiUrl = ConfigurationHelper.GetSetting<string>("muleSoftDealerDetail", true);
|
|
public static string bookingApiUrl = ConfigurationHelper.GetSetting<string>("muleSoftBookingAPILeadSquareDomain", true);
|
|
public static string masterSchemaId = ConfigurationHelper.GetSetting<string>("masterSchemaId", true);
|
|
public static string masterDealerDetailSchemaId = ConfigurationHelper.GetSetting<string>("masterDealerDetailSchemaId", true);
|
|
#endregion
|
|
|
|
|
|
#region Caching
|
|
|
|
public static string CacheGetDealersDetail = ConfigurationHelper.GetSetting<string>("MuleSoftCacheGetDealersDetail", true);
|
|
private int _cacheGetDealersDetail = !string.IsNullOrEmpty(CacheGetDealersDetail) ? int.Parse(CacheGetDealersDetail) : 10;
|
|
|
|
public static string CacheGetPriceOnState = ConfigurationHelper.GetSetting<string>("MuleSoftCacheGetPriceOnState", true);
|
|
private int _cacheGetPriceOnState = !string.IsNullOrEmpty(CacheGetPriceOnState) ? int.Parse(CacheGetPriceOnState) : 10;
|
|
|
|
public static string CacheGetModelOnBrand = ConfigurationHelper.GetSetting<string>("MuleSoftCacheGetModelOnBrand", true);
|
|
private int _cacheGetModelOnBrand = !string.IsNullOrEmpty(CacheGetModelOnBrand) ? int.Parse(CacheGetModelOnBrand) : 10;
|
|
|
|
public static string CacheGetActiveState = ConfigurationHelper.GetSetting<string>("MuleSoftCacheGetActiveState", true);
|
|
private int _cacheGetActiveState = !string.IsNullOrEmpty(CacheGetActiveState) ? int.Parse(CacheGetActiveState) : 10;
|
|
|
|
public static string CacheGetActiveCity = ConfigurationHelper.GetSetting<string>("MuleSoftCacheGetActiveCity", true);
|
|
private int _cacheGetActiveCity = !string.IsNullOrEmpty(CacheGetActiveCity) ? int.Parse(CacheGetActiveCity) : 10;
|
|
|
|
public static string CacheModelDetails = ConfigurationHelper.GetSetting<string>("MuleSoftCacheModelDetails", true);
|
|
private int _cacheModelDetails = !string.IsNullOrEmpty(CacheModelDetails) ? int.Parse(CacheModelDetails) : 10;
|
|
|
|
|
|
#endregion
|
|
|
|
private readonly ILogger _logger;
|
|
private IRepository Repository { get; }
|
|
private IMulesoftTokenApi MulesoftTokenApi { get; }
|
|
private IHttpClientHandler ClientHandler { get; }
|
|
private readonly IMemoryCache _memoryCache;
|
|
private CustomerDetailRepo.IRepository CustomerDetailRepository { get; }
|
|
public MulesoftApi(IRepository repository, IMulesoftTokenApi mulesoftTokenApi, CustomerDetailRepo.IRepository customerRepo,
|
|
IHttpClientHandler clientHandler, IMemoryCache memoryCache, ILogger<MulesoftApi> logger)
|
|
{
|
|
Repository = repository;
|
|
MulesoftTokenApi = mulesoftTokenApi;
|
|
ClientHandler = clientHandler;
|
|
_memoryCache = memoryCache;
|
|
_logger = logger;
|
|
CustomerDetailRepository = customerRepo;
|
|
}
|
|
|
|
|
|
public async Task<MulesoftResponse> GetDealers(int buId, string buUnit, string strlat, string strLong)
|
|
{
|
|
MulesoftResponse response = null;
|
|
try
|
|
{
|
|
string authToken = await MulesoftTokenApi.FetchToken();
|
|
string message = "{\"bu\": \"" + buUnit + "\", \"latitude\": " + strlat + ", \"longitude\": "
|
|
+ strLong + ", \"masterSchemaId\": \"" + masterSchemaId + "\"}";
|
|
|
|
if (!string.IsNullOrEmpty(authToken))
|
|
{
|
|
string password = GenerateRandomString.GenerateString(32);
|
|
string encstring = AESEncryption.ReturnEncKey(password, message);
|
|
|
|
var plainTextBytes = Encoding.UTF8.GetBytes(password);
|
|
string encKeyToHeader = Convert.ToBase64String(plainTextBytes);
|
|
|
|
var response2 = await MuleSoftIntegration.ReturnMuleSoftResponse(ClientHandler,
|
|
encstring, baseApiUrl, authToken, encKeyToHeader);
|
|
|
|
if (response2 != null)
|
|
{
|
|
response = await ValidateMuleSoftResponse(buId, response2);
|
|
|
|
}
|
|
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError($"DS Api:-BUID:- " + buId + "Api:- GetDealers:- " + ex.StackTrace.ToString());
|
|
}
|
|
return response;
|
|
}
|
|
|
|
public async Task<MulesoftResponse> GetAndInsertDealerDetails(int buId, string dealerCode)
|
|
{
|
|
MulesoftResponse response = null;
|
|
try
|
|
{
|
|
var cacheKey = "getDealerDetails_" + buId + dealerCode;
|
|
if (!_memoryCache.TryGetValue(cacheKey, out response))
|
|
{
|
|
_logger.LogInformation("Api:- GetAndInsertDealerDetails:- API:- " + cacheKey);
|
|
|
|
string authToken = await MulesoftTokenApi.FetchToken();
|
|
string message = "{\"branchCode\": \"" + dealerCode +
|
|
"\",\"masterSchemaId\": \"" + masterDealerDetailSchemaId + "\"}";
|
|
|
|
if (!string.IsNullOrEmpty(authToken))
|
|
{
|
|
string password = GenerateRandomString.GenerateString(32);
|
|
string encstring = AESEncryption.ReturnEncKey(password, message);
|
|
|
|
var plainTextBytes = Encoding.UTF8.GetBytes(password);
|
|
string encKeyToHeader = Convert.ToBase64String(plainTextBytes);
|
|
|
|
var response2 = await MuleSoftIntegration.ReturnMuleSoftResponse(ClientHandler,
|
|
encstring, dealerDetailApiUrl, authToken, encKeyToHeader);
|
|
response = await DecryptDealerDetail(buId, response2);
|
|
var cacheExpiryOptions = new MemoryCacheEntryOptions
|
|
{
|
|
AbsoluteExpiration = DateTime.Now.AddMinutes(_cacheGetDealersDetail),
|
|
Priority = CacheItemPriority.High
|
|
};
|
|
_memoryCache.Set(cacheKey, response, cacheExpiryOptions);
|
|
}
|
|
}
|
|
_logger.LogError($"DS Api:-GetAndInsertDealerDetails From Cache:- {cacheKey}");
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError($"DS Api:- GetAndInsertDealerDetails:- {ex.Message.ToString()}");
|
|
}
|
|
return response;
|
|
}
|
|
|
|
public async Task InsertLSQData(MulesoftCustomerInfoDto customerInfo)
|
|
{
|
|
try
|
|
{
|
|
try
|
|
{
|
|
if (customerInfo.Status == "Successful")
|
|
{
|
|
await UpdateDetails(customerInfo, DealerSelectionJobStatus.Complete);
|
|
}
|
|
|
|
var responseApi = await CallLSQBookingApi(customerInfo);
|
|
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
//await UpdateDetails(customerInfo, DealerSelectionJobStatus.ReadyForJob);
|
|
_logger.LogError($"DS Api:-Error in LSQ " + ex.StackTrace.ToString());
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError($"DS Api:-Api:- GetDealers:- " + ex.StackTrace.ToString());
|
|
}
|
|
}
|
|
|
|
|
|
#region Private Methods
|
|
|
|
private async Task<Response> CallLSQBookingApi(MulesoftCustomerInfoDto customerInfo)
|
|
{
|
|
CustomCfg cfg = CustomCfg.GetCustomCfg(customerInfo.BuId);
|
|
_logger.LogInformation($"DS Api:-BU:- {customerInfo.BuId} at MulesofApi:- CallBookingApi for Booking Id:- {customerInfo.BookingId}");
|
|
try
|
|
{
|
|
if (customerInfo != null)
|
|
{
|
|
string mx_Composite_Key = string.Empty, enquiryClassification = string.Empty,
|
|
autoModel = string.Empty, dealerCode = string.Empty, status = string.Empty,
|
|
bookingId = string.Empty, cCTransactionId = string.Empty, receiptId = string.Empty,
|
|
amountPaid = string.Empty, leadPlatform = "Website", isSuccessBooking = "True", isDefaultDealer = "No";
|
|
|
|
|
|
string utmSource = GetUTMDetails(customerInfo.ReferralUrl, "utm_source");
|
|
string utmMedium = GetUTMDetails(customerInfo.ReferralUrl, "utm_medium");
|
|
string sourceCampaign = GetUTMDetails(customerInfo.ReferralUrl, "utm_campaign");
|
|
string utmContent = GetUTMDetails(customerInfo.ReferralUrl, "utm_content");
|
|
|
|
if (!string.IsNullOrEmpty(customerInfo.DealerCode))
|
|
mx_Composite_Key = customerInfo.MobileNumber + customerInfo.DealerCode + "Open";
|
|
else
|
|
mx_Composite_Key = customerInfo.MobileNumber + "nullOpen";
|
|
|
|
string mx_Source_Of_Enquiry = "Organic"; string mx_Enquiry_Sub_source = "Website";
|
|
if (!string.IsNullOrEmpty(customerInfo.UtmCustomDetails1))
|
|
{
|
|
mx_Source_Of_Enquiry = customerInfo.UtmCustomDetails1;
|
|
|
|
}
|
|
if (!string.IsNullOrEmpty(customerInfo.UtmCustomDetails2))
|
|
{
|
|
mx_Enquiry_Sub_source = customerInfo.UtmCustomDetails2;
|
|
|
|
}
|
|
dealerCode = customerInfo.DealerCode;
|
|
status = customerInfo.Status;
|
|
bookingId = customerInfo.BookingId;
|
|
cCTransactionId = customerInfo.CCTransactionId;
|
|
receiptId = customerInfo.ReceiptId;
|
|
amountPaid = customerInfo.AmountPaid;
|
|
|
|
if (customerInfo.DealerCode == cfg.DeafaultDealerCode)
|
|
{
|
|
isDefaultDealer = "Yes";
|
|
}
|
|
string pincode = customerInfo.PinCode;
|
|
//default pincode value, incase pincode column is empty for the record
|
|
if (string.IsNullOrEmpty(pincode))
|
|
pincode = "400070";
|
|
|
|
dynamic message = null;
|
|
if (customerInfo.Status == "Successful" && !string.IsNullOrWhiteSpace(customerInfo.DealerCode)
|
|
&& !string.IsNullOrWhiteSpace(customerInfo.ModelCode))
|
|
{
|
|
enquiryClassification = "Hot";
|
|
autoModel = "Yes";
|
|
|
|
LsqSuccessData lsqData = new LsqSuccessData(cfg.BuCode, customerInfo.ModelCode, customerInfo.ColorCode, customerInfo.CustomerName
|
|
, "", dealerCode, customerInfo.MobileNumber, "true", pincode, "Digital"
|
|
, mx_Source_Of_Enquiry, mx_Enquiry_Sub_source, "", mx_Composite_Key, enquiryClassification
|
|
, autoModel, "", bookingId, status, cCTransactionId, receiptId, amountPaid
|
|
, "", "", "", utmSource, utmMedium, sourceCampaign, utmContent, customerInfo.IsWhatsappOptIn.ToString()
|
|
, leadPlatform, isDefaultDealer);
|
|
|
|
message = JsonConvert.SerializeObject(lsqData);
|
|
}
|
|
else
|
|
{
|
|
enquiryClassification = "Cold";
|
|
autoModel = "No";
|
|
status = string.Empty;
|
|
bookingId = string.Empty;
|
|
cCTransactionId = string.Empty;
|
|
receiptId = string.Empty;
|
|
amountPaid = string.Empty;
|
|
isSuccessBooking = "False";
|
|
|
|
LsqData lsqData = new LsqData(cfg.BuCode, customerInfo.ModelCode, customerInfo.ColorCode, customerInfo.CustomerName
|
|
, "", "", customerInfo.MobileNumber, "true", pincode, "Digital"
|
|
, mx_Source_Of_Enquiry, mx_Enquiry_Sub_source, "", mx_Composite_Key, enquiryClassification
|
|
, autoModel, "", bookingId, status, cCTransactionId, receiptId, amountPaid
|
|
, "", "", "", utmSource, utmMedium, sourceCampaign, utmContent, customerInfo.IsWhatsappOptIn.ToString()
|
|
, leadPlatform);
|
|
|
|
message = JsonConvert.SerializeObject(lsqData);
|
|
}
|
|
|
|
|
|
|
|
string authToken = await MulesoftTokenApi.FetchToken();
|
|
|
|
if (!string.IsNullOrEmpty(authToken))
|
|
{
|
|
string password = GenerateRandomString.GenerateString(32);
|
|
string encstring = AESEncryption.ReturnEncKey(password, message);
|
|
|
|
var plainTextBytes = Encoding.UTF8.GetBytes(password);
|
|
string encKeyToHeader = Convert.ToBase64String(plainTextBytes);
|
|
|
|
// var url = "";
|
|
var response2 = await MuleSoftIntegration.ReturnMuleSoftResponse(ClientHandler, encstring, bookingApiUrl, authToken, encKeyToHeader);
|
|
|
|
LeadData _leadData = DecryptBookingApi(response2);
|
|
await Repository.UpdateMulesoftResponse(customerInfo.BuId, customerInfo.RecordId, customerInfo.BookingId, message, isSuccessBooking, _leadData);
|
|
return new Response(customerInfo.BuId, 0, true, "true", "", "");
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError($"DS Api:-Api:- CallBookingApi:- " + ex.StackTrace.ToString());
|
|
}
|
|
return new Response(customerInfo.BuId, 0, false, "false", "", "");
|
|
}
|
|
|
|
private LeadData DecryptBookingApi(HttpResponseMessage response)
|
|
{
|
|
LeadData _leadData = new LeadData();
|
|
JObject obj = JObject.Parse(response.Content.ReadAsStringAsync().Result);
|
|
try
|
|
{
|
|
if (response.StatusCode.ToString() == "OK")
|
|
{
|
|
if (obj["encData"] != null && !string.IsNullOrEmpty(Convert.ToString(obj["encData"])))
|
|
{
|
|
string pass = string.Empty;
|
|
string encResult2 = Convert.ToString(obj["encData"]);
|
|
// get enckey from response header
|
|
if (response.Headers.Contains("Enckey"))
|
|
{
|
|
var decodekey = response.Headers.GetValues("Enckey").First();
|
|
if (!string.IsNullOrEmpty(decodekey))
|
|
{
|
|
var base64EncodedBytes = Convert.FromBase64String(decodekey);
|
|
pass = Encoding.UTF8.GetString(base64EncodedBytes);
|
|
}
|
|
}
|
|
|
|
// Decrypt result by encKey
|
|
if (!string.IsNullOrEmpty(encResult2))
|
|
{
|
|
_leadData.ApiResponse = AESEncryption.DecryptString(encResult2, pass);
|
|
|
|
_logger.LogInformation($"DS Api:-DecryptBookingApi decrpted message: " + _leadData.ApiResponse);
|
|
|
|
JObject obj1 = JObject.Parse(_leadData.ApiResponse);
|
|
string lead_status_code = (string)obj1["statusCode"];
|
|
|
|
if (lead_status_code == "200" && obj1["message"]?["IsSuccess"] != null)
|
|
{
|
|
_leadData.Lead_status = (string)obj1["message"]["IsSuccess"];
|
|
_leadData.LeadResponseStatus = lead_status_code;
|
|
if (_leadData.Lead_status.ToLower().Equals("true"))
|
|
{
|
|
_leadData.Lead_transferred = "y";
|
|
string[] ids = ((string)obj1["message"]["Value"]).Split(' ');
|
|
if (ids.Length == 1)
|
|
ids = ((string)obj1["message"]["Value"]).Split(',');
|
|
if (ids.Length > 0)
|
|
_leadData.Prospect_id = ids[0];
|
|
if (ids.Length > 1)
|
|
_leadData.Opportunity_id = ids[1];
|
|
}
|
|
else
|
|
{
|
|
_leadData.Lead_transferred = "n";
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
_leadData.Lead_transferred = "n";
|
|
_leadData.Lead_status = "Failure";
|
|
_leadData.ApiResponse = ((int)response.StatusCode) + JsonConvert.SerializeObject(obj, Formatting.None);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError($"DS Api:-Api:- DecryptBookingApi:- " + ex.StackTrace.ToString());
|
|
}
|
|
return _leadData;
|
|
}
|
|
|
|
private async Task<MulesoftResponse> ValidateMuleSoftResponse(int buId, HttpResponseMessage response2)
|
|
{
|
|
JObject obj = JObject.Parse(await response2.Content.ReadAsStringAsync());
|
|
|
|
try
|
|
{
|
|
if (response2.StatusCode.ToString() == "OK")
|
|
{
|
|
if (obj["encData"] != null && !string.IsNullOrWhiteSpace(Convert.ToString(obj["encData"])))
|
|
{
|
|
string pass = string.Empty;
|
|
string encResult2 = Convert.ToString(obj["encData"]);
|
|
// get enckey from response header
|
|
if (response2.Headers.Contains("encKey"))
|
|
{
|
|
var decodekey = response2.Headers.GetValues("encKey").First();
|
|
if (!string.IsNullOrEmpty(decodekey))
|
|
{
|
|
var base64EncodedBytes = Convert.FromBase64String(decodekey);
|
|
pass = Encoding.UTF8.GetString(base64EncodedBytes);
|
|
}
|
|
}
|
|
// Decrypt result by encKey
|
|
if (!string.IsNullOrWhiteSpace(encResult2))
|
|
{
|
|
string decrypted = AESEncryption.DecryptString(encResult2, pass);
|
|
JObject obj1 = JObject.Parse(decrypted);
|
|
return new MulesoftResponse(buId, 0, true, JsonConvert.SerializeObject(obj1, Formatting.None), "Dealer Found", "");
|
|
}
|
|
}
|
|
}
|
|
else if (((int)response2.StatusCode) == 404)
|
|
{
|
|
return new MulesoftResponse(buId, 0, true, JsonConvert.SerializeObject(obj, Formatting.None), "No Dealer Found", "");
|
|
}
|
|
else if (((int)response2.StatusCode) == 401)
|
|
{
|
|
return new MulesoftResponse(buId, 0, true, JsonConvert.SerializeObject(obj, Formatting.None), Convert.ToString(obj["error"]), "");
|
|
}
|
|
else
|
|
{
|
|
return new MulesoftResponse(buId, 0, false, JsonConvert.SerializeObject(obj, Formatting.None), "System Down" + JsonConvert.SerializeObject(obj, Formatting.None), "");
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError($"DS Api:-Api:- ValidateMuleSoftResponse:- " + ex.StackTrace.ToString());
|
|
}
|
|
return new MulesoftResponse(buId, 0, false, JsonConvert.SerializeObject(obj, Formatting.None), "System Down" + JsonConvert.SerializeObject(obj, Formatting.None), "");
|
|
}
|
|
|
|
private async Task<MulesoftResponse> DecryptDealerDetail(int buId, HttpResponseMessage response2)
|
|
{
|
|
JObject obj = JObject.Parse(await response2.Content.ReadAsStringAsync());
|
|
|
|
try
|
|
{
|
|
if (response2.StatusCode.ToString() == "OK")
|
|
{
|
|
if (obj["encData"] != null && !string.IsNullOrWhiteSpace(Convert.ToString(obj["encData"])))
|
|
{
|
|
string pass = string.Empty;
|
|
string encResult2 = Convert.ToString(obj["encData"]);
|
|
// get enckey from response header
|
|
if (response2.Headers.Contains("encKey"))
|
|
{
|
|
var decodekey = response2.Headers.GetValues("encKey").First();
|
|
if (!string.IsNullOrEmpty(decodekey))
|
|
{
|
|
var base64EncodedBytes = Convert.FromBase64String(decodekey);
|
|
pass = Encoding.UTF8.GetString(base64EncodedBytes);
|
|
}
|
|
}
|
|
// Decrypt result by encKey
|
|
if (!string.IsNullOrWhiteSpace(encResult2))
|
|
{
|
|
string decrypted = AESEncryption.DecryptString(encResult2, pass);
|
|
JObject obj1 = JObject.Parse(decrypted);
|
|
if (obj1 != null)
|
|
{
|
|
JToken jArrResultData = (JToken)obj1["Data"];
|
|
if (jArrResultData != null)
|
|
{
|
|
DealerDetailDto dto = new DealerDetailDto();
|
|
dto.BuId = buId;
|
|
dto.DealerCode = (JValue)jArrResultData["Code"] != null ? Convert.ToString(((JValue)jArrResultData["Code"]).Value) : "0";
|
|
dto.Address1 = (JValue)jArrResultData["AddressLine1"] != null ? Convert.ToString(((JValue)jArrResultData["AddressLine1"]).Value) : "0";
|
|
dto.Address2 = (JValue)jArrResultData["AddressLine2"] != null ? Convert.ToString(((JValue)jArrResultData["AddressLine2"]).Value) : "0";
|
|
dto.City = (JValue)jArrResultData["CityName"] != null ? Convert.ToString(((JValue)jArrResultData["CityName"]).Value) : "0";
|
|
dto.State = (JValue)jArrResultData["StateName"] != null ? Convert.ToString(((JValue)jArrResultData["StateName"]).Value) : "0";
|
|
dto.Zip = (JValue)jArrResultData["Zip"] != null ? Convert.ToString(((JValue)jArrResultData["Zip"]).Value) : "0";
|
|
dto.DisplayName = (JValue)jArrResultData["DisplayName"] != null ? Convert.ToString(((JValue)jArrResultData["DisplayName"]).Value) : "0";
|
|
dto.ContactCard = (JValue)jArrResultData["ContactCard"] != null ? Convert.ToString(((JValue)jArrResultData["ContactCard"]).Value) : "0";
|
|
dto.SalesPersonMail = (JValue)jArrResultData["SalesPersonEmail"] != null ? Convert.ToString(((JValue)jArrResultData["SalesPersonEmail"]).Value) : "0";
|
|
dto.SaleMobileNumber = (JValue)jArrResultData["SalesPersonContact"] != null ? Convert.ToString(((JValue)jArrResultData["SalesPersonContact"]).Value) : "0";
|
|
dto.EcomSalesAddress = (JValue)jArrResultData["EcomSalesAddress"] != null ? Convert.ToString(((JValue)jArrResultData["EcomSalesAddress"]).Value) : "0";
|
|
await Repository.InsertAndUpdateDealerRecord(dto);
|
|
return new MulesoftResponse(buId, 0, true, dto.Zip, "Dealer Detail Updated", "");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
else if (((int)response2.StatusCode) == 404)
|
|
{
|
|
return new MulesoftResponse(buId, 0, true, JsonConvert.SerializeObject(obj, Formatting.None), "No Dealer Found", "");
|
|
|
|
}
|
|
else if (((int)response2.StatusCode) == 401)
|
|
{
|
|
return new MulesoftResponse(buId, 0, true, JsonConvert.SerializeObject(obj, Formatting.None), Convert.ToString(obj["error"]), "");
|
|
}
|
|
else
|
|
{
|
|
return new MulesoftResponse(buId, 0, true, JsonConvert.SerializeObject(obj, Formatting.None), "System Down" + JsonConvert.SerializeObject(obj, Formatting.None), "");
|
|
}
|
|
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError($"DS Api:-Api:- DecryptDealerDetail:- " + ex.Message.ToString());
|
|
}
|
|
return new MulesoftResponse(buId, 0, true, JsonConvert.SerializeObject(obj, Formatting.None), "System Down" + JsonConvert.SerializeObject(obj, Formatting.None), "");
|
|
}
|
|
|
|
private string GetUTMDetails(string referrerUrl, string utmName)
|
|
{
|
|
try
|
|
{
|
|
Uri referrerUri = new(referrerUrl);
|
|
var query = referrerUri.Query.Replace("?", "");
|
|
if (!string.IsNullOrWhiteSpace(query))
|
|
{
|
|
var dict = query.Split('&').Select(q => q.Split('=')).ToDictionary(k => k[0], v => v[1]);
|
|
|
|
if (dict.ContainsKey(utmName))
|
|
return dict[utmName];
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError($"DS Api:- GetUTMDetails:- " + ex.Message.ToString());
|
|
}
|
|
return "";
|
|
}
|
|
|
|
private async Task UpdateDetails(MulesoftCustomerInfoDto customerInfo, DealerSelectionJobStatus jobStatus)
|
|
{
|
|
_logger.LogInformation($"DS Api:-UpdateDetails Started:- {customerInfo} JobStatus {jobStatus}");
|
|
try
|
|
{
|
|
|
|
CustomerDetailRepo.CustomerDealerInfoRequestDto dto = new()
|
|
{
|
|
BuId = customerInfo.BuId,
|
|
RecordId = customerInfo.RecordId,
|
|
MobileNumber = customerInfo.MobileNumber,
|
|
DealerName = jobStatus == DealerSelectionJobStatus.Complete ? customerInfo.DealerName : "",
|
|
DealerCode = jobStatus == DealerSelectionJobStatus.Complete ? customerInfo.DealerCode : "",
|
|
DealerSelectionJobStatus = jobStatus == DealerSelectionJobStatus.Complete ? DealerSelectionJobStatus.Complete : DealerSelectionJobStatus.ReadyForJob,
|
|
PinCode = customerInfo.PinCode,
|
|
Latitude = customerInfo.CustomerLat,
|
|
Longitude = customerInfo.CustomerLong,
|
|
DealerSelectedMode = customerInfo.DealerSelectedMode
|
|
};
|
|
await CustomerDetailRepository.UpdateDealerDetail(dto);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogError($"DS Api:- UpdateDetails:- " + ex.Message.ToString());
|
|
}
|
|
_logger.LogInformation($"DS Api:-UpdateDetails End:- {customerInfo} JobStatus {jobStatus}");
|
|
}
|
|
|
|
|
|
#endregion
|
|
}
|