using GraphQL; using Newtonsoft.Json.Linq; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Xml.Linq; using System.IO; namespace BodyshopPartner.Utils { public static class PPGMixData { private static NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger(); private static string PpgDataQuery = @"query PPGDataPump($today: timestamptz!, $todayplus5: timestamptz!, $shopid: uuid!) { bodyshops_by_pk(id:$shopid) { id shopname imexshopid } jobs(where: {_or: [{_and: [{scheduled_in: {_lte: $todayplus5}}, {scheduled_in: {_gte: $today}}]}, {inproduction: {_eq: true}}]}) { id ro_number status ownr_fn ownr_ln ownr_co_nm v_vin v_model_yr v_make_desc v_model_desc v_color plate_no ins_co_nm est_ct_fn est_ct_ln rate_mapa rate_lab job_totals vehicle{ v_paint_codes } labhrs: joblines_aggregate(where: {mod_lbr_ty: {_neq: ""LAR""}, removed: {_eq: false}}) { aggregate { sum { mod_lb_hrs } } } larhrs: joblines_aggregate(where: { mod_lbr_ty: { _eq: ""LAR""}, removed: { _eq: false} }) { aggregate { sum { mod_lb_hrs } } } } } "; public static async Task PushDataToPPG() { try { //Get the path for the XML file that should be written. Ensure that we can read and write to that directory. //Query the database based on the active shop for all work that's coming within the next 5 days + all active work. var r = new GraphQLRequest { Query = PpgDataQuery, Variables = new { today = DateTime.Now.Date, todayplus5 = DateTime.Now.Date.AddDays(5), shopid = AppMetaData.ActiveShopId } }; var data = await Utils.GraphQL.ExecuteQuery(r); //Create an XML document node XDocument doc = new XDocument( new XElement("PPG", new XElement("Header", new XElement("Protocol", new XElement("Message", "PaintShopInterface"), new XElement("Name", "PPG"), new XElement("Version", "1.5.0")), new XElement("Transaction", new XElement("TransactionID", null), new XElement("TransactionDate", DateTime.Now.ToString("yyyy-MM-hh:mm:ss")) ), new XElement("Product", new XElement("Name", "ImEX Online"), new XElement("Version", null) ) ), new XElement("DataInterface", new XElement("ROData", new XElement("ShopInfo", new XElement("ShopID", data?.bodyshops_by_pk?.imexshopid?.Value), new XElement("ShopName", data?.bodyshops_by_pk?.shopname?.Value) ), new XElement("RepairOrders", new XElement("ROCount", data?.jobs?.Count) ) ) ) ) ); foreach (dynamic job in data.jobs) { logger.Debug($"{job.ro_number}"); doc.Element("PPG").Element("DataInterface").Element("ROData").Element("RepairOrders").Add(new XElement("RO", new XElement("RONumber", job.ro_number?.Value), new XElement("ROStatus", "Open"), new XElement("Customer", $"{job.ownr_ln}, {job.ownr_fn}"), new XElement("ROPainterNotes", ""), new XElement("LicensePlateNum", job.plate_no?.Value), new XElement("VIN", job.v_vin?.Value), new XElement("ModelYear", job.v_model_yr?.Value), new XElement("MakeDesc", job.v_make_desc?.Value), new XElement("ModelName", job.v_model_desc?.Value), new XElement("OEMColorCode", job.vehicle?.Value != null ? job.vehicle?.v_paint_codes?.Value == null ? "" : job.vehicle?.v_paint_codes?.paint_cd1?.Value : ""), new XElement("RefinishLaborHours", job.larhrs?.aggregate?.sum.mod_lb_hrs?.Value), new XElement("InsuranceCompanyName", job.ins_co_nm?.Value), new XElement("EstimatorName", $"{job.est_ct_ln}, {job.est_ct_fn}"), new XElement("PaintMaterialsRevenue", ((float)(job.job_totals?.Value != null ? job.job_totals?.rates?.mapa?.total?.amount?.Value : 0)) / 100), new XElement("PaintMaterialsRate", job.rate_mapa?.Value), new XElement("BodyHours", job.labhrs?.aggregate.sum?.mod_lb_hrs?.Value), new XElement("BodyLaborRate", job.rate_lab?.Value), new XElement("TotalCostOfRepairs", ((float)(job.job_totals?.Value != null ? job.job_totals?.totals?.subtotal?.amount?.Value : 0)) / 100) )); } Directory.CreateDirectory(Properties.Settings.Default.PaintScalePath); doc.Save(Properties.Settings.Default.PaintScalePath + @"\PPGPaint.xml"); } catch (Exception ex) { logger.Error(ex, "Error while pushing data to PPG paint scale."); } } } }