nbhargava/EOS-WebAPI
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity
main
EOS-WebAPI/Common/PushData.cs
Nidhi Bhargava d0ac8a7790 Code Commit
2025-09-04 17:30:22 +05:30

267 lines
13 KiB
C#
Raw Permalink Blame History

using VECV_WebApi.Common;
using VECV_WebApi.EOS_Service;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.IO;
using System.Linq;
using System.ServiceModel;
using System.Text;
using System.Threading.Tasks;
using System.Xml;
using System.Xml.Linq;
using System.Xml.Serialization;
using VECV_WebApi.Models.Udan;
using Npgsql;
using DBHelper;
using System.Net;
using System.Web;
using LoggingHelper;
using Newtonsoft.Json;
using VECV_WebApi.Models.Ticket;
namespace VECV_WebApi.Common
{
public class PushData
{
public void SendDataToSAP(string VehicleRegistrationNumber, int? TicketStatus, string TicketId,string vanreachtime)
{
/// <summary>
/// making object of LoggingUtility class available to this class
/// </summary>
LoggingUtility objLog = new LoggingUtility();
/// <summary>
/// making the data-log file path available to this class
/// </summary>
string path = HttpContext.Current.Server.MapPath(ConfigurationManager.AppSettings["PathLog"]);
//string vanreachtime = "";
/// <summary>
/// making error log file path available to this class
/// </summary>
string errorlogtf = (ConfigurationManager.AppSettings["ErrorLog"]);
string TicketIdDBM = "";
string TicketStatusDBM = "";
ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls |
SecurityProtocolType.Tls11 |
SecurityProtocolType.Tls12;
DT_S_WEBSITE_BI_EOSTABLE obj = new DT_S_WEBSITE_BI_EOSTABLE();
DT_S_WEBSITE_BI_EOSTABLE objCreation = new DT_S_WEBSITE_BI_EOSTABLE();
DT_S_WEBSITE_BI_EOSTABLE objClosed = new DT_S_WEBSITE_BI_EOSTABLE();
DT_S_WEBSITE_BI_EOSTABLE objTripEnd = new DT_S_WEBSITE_BI_EOSTABLE();
List<DT_S_WEBSITE_BI_EOSTABLE> lsDT_S_WEBSITE_BI_EOSTABLE = new List<DT_S_WEBSITE_BI_EOSTABLE>();
SI_S_WEBSITE_BI_EOSClient objSI_S_WEBSITE_BI_EOSClient = new EOS_Service.SI_S_WEBSITE_BI_EOSClient();
SI_S_WEBSITE_BI_EOS1 objSI_S_WEBSITE_BI_EOS1 = new EOS_Service.SI_S_WEBSITE_BI_EOS1();
ConsolidateReportRepository objConsolidateReportRepository = new ConsolidateReportRepository();
List<string> TicketArray = new List<string>();
try
{
string spName = null;
NpgsqlParameter[] nSqlParam = new NpgsqlParameter[1];
if ((TicketStatus) == 1 || (TicketStatus) == 2)
{
objLog.AddLogFile("push dataa 1", VehicleRegistrationNumber, path, errorlogtf);
spName = ConfigurationManager.AppSettings["usp_udan_get_open_tickets_vehicle_wise"].ToString();
nSqlParam[0] = new NpgsqlParameter("inregistration_number ", VehicleRegistrationNumber);
}
else if ((TicketStatus) == 8)
{
spName = ConfigurationManager.AppSettings["usp_udan_get_ticket_details_ticket_wise"].ToString();
nSqlParam[0] = new NpgsqlParameter("inticket_id ", TicketId);
}
else if ((TicketStatus) == 5)
{
spName = ConfigurationManager.AppSettings["usp_udan_get_ticket_details_ticket_wise_for_dealer"].ToString();
nSqlParam[0] = new NpgsqlParameter("inticket_id ", TicketId);
}
DataSet ds = new DataSet();
try
{
ds = NpgSqlHelper.ExecuteDataset(ConfigurationManager.ConnectionStrings["Vecv_GoData"].ConnectionString, CommandType.StoredProcedure, spName, nSqlParam);
objLog.AddLogFile("push dataa 2", TicketStatus.ToString(), path, errorlogtf);
if ((TicketStatus) == 1 || (TicketStatus) == 2)
{
if (ds.Tables.Count > 0)
{
if (ds.Tables[0].Rows.Count > 0)
{
string mystring = ds.Tables[0].Rows[0]["_ticket_id"].ToString();
mystring = mystring.Substring(mystring.Length - 6);
TicketId = "TICKETID-" + mystring;
}
}
}
}
catch (Exception Ex)
{
objLog.ErrorLogFile("pushdata " + spName + TicketId, Ex.Message, path, errorlogtf);
}
objLog.AddLogFile("push dataa 3", TicketId, path, errorlogtf);
/* if ((TicketStatus) == 1 || (TicketStatus) == 2)
{
}
else
{
DataSet dsvanReach = new DataSet();
try
{
NpgsqlParameter[] nSqlParamvanReach = new NpgsqlParameter[1];
string spNamevanReach = ConfigurationManager.AppSettings["usp_get_van_reach_time_close"].ToString();
nSqlParamvanReach[0] = new NpgsqlParameter("inticket_id ", TicketId);
dsvanReach = NpgSqlHelper.ExecuteDataset(ConfigurationManager.ConnectionStrings["Vecv_GoData"].ConnectionString, CommandType.StoredProcedure, spNamevanReach, nSqlParamvanReach);
}
catch (Exception Ex)
{
objLog.ErrorLogFile("pushdata usp_get_van_reach_time_close" + TicketId, Ex.Message, path, errorlogtf);
}
// for rabbitt mq
if (dsvanReach == null)
{
}
else
{
if (dsvanReach.Tables[0].Rows.Count > 0)
{
vanreachtime = Convert.ToString(dsvanReach.Tables[0].Rows[0]["_creation_time"]) == "" ? "" : Convert.ToDateTime(dsvanReach.Tables[0].Rows[0]["_creation_time"]).ToString(System.Configuration.ConfigurationManager.AppSettings["DateTimeFormatSAP"]);
}
}
}*/
if (ds.Tables[0].Rows.Count > 0)
{
foreach (DataRow dr in ds.Tables[0].Rows)
{
if ((TicketStatus) == 1 || (TicketStatus) == 2)
{
objCreation.Creation_Time = Convert.ToString(dr["_creation_time"]) == "" ? "" : Convert.ToDateTime(dr["_creation_time"]).ToString(System.Configuration.ConfigurationManager.AppSettings["DateTimeFormatSAP"]);
objCreation.Vehicle_Owner_Contact_No = Convert.ToString(dr["_customer_contact_no"]);
objCreation.Dealer_SCode = Convert.ToString(dr["_dealer_code"]);
objCreation.Ticket_Id = Convert.ToString(dr["_ticket_id"]);
objCreation.Vehicle_Model = Convert.ToString(dr["_customer_vehicle_model_tagging"]);
objCreation.Vehicle_Reg_No = Convert.ToString(dr["_vehicle_registration_number"]);
objLog.AddLogFile("push dataa5", objCreation.Vehicle_Model, path, errorlogtf);
if (objCreation.Vehicle_Model == "TITAN 3T")
{
objCreation.Vehicle_Model = "Pro X 3T EV";
}
if (objCreation.Vehicle_Model == "TITAN 3.5T")
{
objCreation.Vehicle_Model = "Pro X 3.5T EV";
}
objCreation.Vehicle_Owner_Name = Convert.ToString(dr["_customer_name"]);
objCreation.Vehicle_Type = Convert.ToString(dr["_model_tagging"]);
objCreation.Fuel_Type = Convert.ToString(dr["_fuel_type"]);
objCreation.Van_Reached = vanreachtime;
TicketIdDBM = objCreation.Ticket_Id.ToString();
TicketStatusDBM = TicketStatus.ToString();
lsDT_S_WEBSITE_BI_EOSTABLE.Add(objCreation);
objLog.AddLogFile("push dataa6", objCreation.Ticket_Id, path, errorlogtf);
}
else if ((TicketStatus) == 8)
{
//obj.Ticket_Id = Convert.ToString(dr["_ticket_id"]);
//obj.EOS_VAN_Actual_Travelled_Distance = Convert.ToString(dr["_van_covered_distance"]);
//obj.EOS_VAN_Estimated_Distance = Convert.ToString(dr["_km_covered"]);
//obj.Van_Reached = vanreachtime;
objTripEnd.Ticket_Id = Convert.ToString(dr["_ticket_id"]);
objTripEnd.EOS_VAN_Actual_Travelled_Distance = Convert.ToString(dr["_van_covered_distance"]);
objTripEnd.EOS_VAN_Estimated_Distance = Convert.ToString(dr["_km_covered"]);
objTripEnd.Van_Reached = vanreachtime;
TicketIdDBM = objTripEnd.Ticket_Id.ToString();
TicketStatusDBM = TicketStatus.ToString();
lsDT_S_WEBSITE_BI_EOSTABLE.Add(objTripEnd);
}
else if ((TicketStatus) == 5)
{
//obj.Ticket_Id = Convert.ToString(dr["_ticket_id"]);
//obj.EOS_VAN_Estimated_Distance = Convert.ToString(dr["_km_covered"]);
//obj.Van_Reached = vanreachtime;
//obj.fuel_type = Convert.ToString(dr["_fuel_type"]);
objClosed.Ticket_Id = Convert.ToString(dr["_ticket_id"]);
objClosed.EOS_VAN_Estimated_Distance = Convert.ToString(dr["_km_covered"]);
objClosed.Van_Reached = vanreachtime;
objClosed.Fuel_Type = Convert.ToString(dr["_fuel_type"]);
TicketIdDBM = objClosed.Ticket_Id.ToString();
TicketStatusDBM = TicketStatus.ToString();
lsDT_S_WEBSITE_BI_EOSTABLE.Add(objClosed);
}
}
lsDT_S_WEBSITE_BI_EOSTABLE.TrimExcess();
objSI_S_WEBSITE_BI_EOS1.MT_S_WEBSITE_BI_EOS = lsDT_S_WEBSITE_BI_EOSTABLE.ToArray();
objSI_S_WEBSITE_BI_EOSClient.ClientCredentials.UserName.UserName = System.Configuration.ConfigurationManager.AppSettings["UserName"].ToString();
objSI_S_WEBSITE_BI_EOSClient.ClientCredentials.UserName.Password = System.Configuration.ConfigurationManager.AppSettings["Password"].ToString();
objSI_S_WEBSITE_BI_EOSClient.SI_S_WEBSITE_BI_EOS(objSI_S_WEBSITE_BI_EOS1.MT_S_WEBSITE_BI_EOS.ToArray());
TicketArray = lsDT_S_WEBSITE_BI_EOSTABLE.Select(x => x.Ticket_Id).ToList();
}
}
catch (Exception ex)
{
if (ex is ProtocolException && ex.Message == "The one-way operation returned a non-null message with Action=''.")
{
objLog.AddLogFile("push dataa 7", TicketStatus.ToString(), path, errorlogtf);
if ((TicketStatus) == 1 || (TicketStatus) == 2)
{
string jsonified2 = JsonConvert.SerializeObject(objCreation);
objLog.AddLogFile("push dataa 8", jsonified2, path, errorlogtf);
objLog.AddLogFile("DBM Payload Creation", jsonified2, path, errorlogtf);
}
else if ((TicketStatus) == 8)
{
string jsonified2 = JsonConvert.SerializeObject(objTripEnd);
objLog.AddLogFile("DBM Payload trip end", jsonified2, path, errorlogtf);
}
else if ((TicketStatus) == 5)
{
string jsonified2 = JsonConvert.SerializeObject(objClosed);
objLog.AddLogFile("DBM Payload closed", jsonified2, path, errorlogtf);
}
TicketArray = new List<string>();
TicketArray.TrimExcess();
TicketArray = lsDT_S_WEBSITE_BI_EOSTABLE.Select(x => x.Ticket_Id).ToList();
}
else
{
TicketRepository objTicketRepository = new TicketRepository(ConfigurationManager.ConnectionStrings["Vecv_GoData"].ConnectionString);
bool isSend = objTicketRepository.emailForError("DBM Error: SendDataToSAP", ex.Message.ToString());
objLog.ErrorLogFile("DBM Error:", ex.Message, path, errorlogtf);
}
}
}
}
}
Reference in New Issue View Git Blame Copy Permalink