Class: Edi::MftGateway::Orchestrator

Inherits:
BaseOrchestrator show all
Defined in:
app/services/edi/mft_gateway/orchestrator.rb

Constant Summary collapse

AS2ID_BY_PARTNER = 
{
  # mft_gateway_build_com: (Rails.env.production? ? 'improvement-direct-02' : 'IMPROVEMENT-DIRECT-TEST')
  # mft_gateway_canadian_tire: (Rails.env.production? ? 'SPSAS2' : 'CA-TIRE-TEST'),
  # mft_gateway_zoro_tools: (Rails.env.production? ? 'SPSAS2' : 'ZORO-TOOLS-TEST'),
  mft_gateway_build_com: (Rails.env.production? ? 'improvement-direct-02' : 'IMPROVEMENT-DIRECT-TEST'),
  mft_gateway_canadian_tire: (Rails.env.production? ? 'RITHUMAS2' : 'CA-TIRE-TEST'), # DscoExAs2 # RITHUMAS2
  mft_gateway_zoro_tools: (Rails.env.production? ? 'SPSAS2' : 'ZORO-TOOLS-TEST'),
  mft_gateway_amazon_vc_edi_wasn4: (Rails.env.production? ? 'SNQDYISW0VJFYN' : 'AMZN-US-TEST'), # TEST 'SN2S7KZWP2V5SNW'
  mft_gateway_amazon_vc_edi_wat0f: (Rails.env.production? ? 'SNI2IYTGFP2DKI' : 'AMZN-US-TEST')
}

Constants inherited from BaseOrchestrator

BaseOrchestrator::DEFAULT_PENDING_DISCONTINUE_LIFETIME, BaseOrchestrator::ORCHESTRATORS, BaseOrchestrator::RECOMMENDED_EXECUTE_FLOW_EVERY_X_HOUR

Instance Attribute Summary

Attributes inherited from BaseOrchestrator

#config, #logger, #options

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from BaseOrchestrator

all_orchestrators_class, build, cached_build, cached_orchestrators, catalog_id_to_pending_discontinue_lifetime, catalog_ids_edi_enabled, #confirm_outbound_processing?, #customer, #customer_catalog, customer_id_to_partner_key_map, #customer_ids, customer_ids_edi_enabled, customer_ids_with_invoice_message_enabled, #customers, execute_discontinue_flow, execute_flow, execute_inventory_flow, execute_listing_message_feed_flow, execute_order_flow, execute_price_flow, #execute_price_flow, execute_product_data_flow, #execute_product_data_flow, #ignore_back_orders, #initialize, orchestrator_for_customer_id, orchestrators, #pending_discontinue_lifetime, #price_message_enabled?, #product_data_enabled?, #should_execute_flow?, #should_execute_order_flow?, #should_execute_product_data_flow?, #test_mode?

Constructor Details

This class inherits a constructor from Edi::BaseOrchestrator

Class Method Details

.partners ⇒ Object 



47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 47

def self.partners
  {
    mft_gateway_build_com: {
      active: true,
      partner: :mft_gateway_build_com,
      customer_id: 183302,
      partner_id: 'ACPALLWARMLYYOU',
      as2_id: AS2ID_BY_PARTNER[:mft_gateway_build_com],
      partner_name: 'Build.com',
      vendor_id: 'Warmly_Yours',
      warehouse_code: "WY-US", # here we are using the code, no hash
      transporter: :basic_http_api,
      transporter_profile: :mft_gateway_api,
      order_message_enabled: true,
      acknowledge_message_remote_path: "#{Heatwave::Configuration.fetch(:mft_gateway_api, :hostname)}/OutgoingAdapterWarmlyYours?as2id=#{AS2ID_BY_PARTNER[:mft_gateway_build_com]}&ediType=855",
      confirm_message_remote_path: "#{Heatwave::Configuration.fetch(:mft_gateway_api, :hostname)}/OutgoingAdapterWarmlyYours?as2id=#{AS2ID_BY_PARTNER[:mft_gateway_build_com]}&ediType=856",
      ignore_back_orders: true,
      inventory_message_remote_path: "#{Heatwave::Configuration.fetch(:mft_gateway_api, :hostname)}/OutgoingAdapterWarmlyYours?as2id=#{AS2ID_BY_PARTNER[:mft_gateway_build_com]}&ediType=846",
      execute_inventory_flow_every_x_hour: 6,
      invoice_message_remote_path: "#{Heatwave::Configuration.fetch(:mft_gateway_api, :hostname)}/OutgoingAdapterWarmlyYours?as2id=#{AS2ID_BY_PARTNER[:mft_gateway_build_com]}&ediType=810",
      generate_packing_slip: false,
      support_contact: 'Udith Gunaratna, udith@edigenerator.com, support@mftgateway.com, support@edigenerator.com'
    },
    mft_gateway_canadian_tire: {
      active: true,
      partner: :mft_gateway_canadian_tire,
      customer_id: 20095485,
      partner_id: '043EDIWARMLYYOU',
      as2_id: AS2ID_BY_PARTNER[:mft_gateway_canadian_tire],
      partner_name: 'Canadian Tire',
      vendor_id: 'G6JH',
      warehouse_code: "WY-CA", # here we are using the code, no hash
      transporter: :basic_http_api,
      transporter_profile: :mft_gateway_api,
      order_message_enabled: true,
      acknowledge_only_on_pending_ship_confirm: true,
      acknowledge_message_remote_path: "#{Heatwave::Configuration.fetch(:mft_gateway_api, :hostname)}/OutgoingAdapterWarmlyYours?as2id=#{AS2ID_BY_PARTNER[:mft_gateway_canadian_tire]}&ediType=855",
      confirm_message_remote_path: "#{Heatwave::Configuration.fetch(:mft_gateway_api, :hostname)}/OutgoingAdapterWarmlyYours?as2id=#{AS2ID_BY_PARTNER[:mft_gateway_canadian_tire]}&ediType=856",
      ignore_back_orders: true,
      inventory_message_remote_path: "#{Heatwave::Configuration.fetch(:mft_gateway_api, :hostname)}/OutgoingAdapterWarmlyYours?as2id=#{AS2ID_BY_PARTNER[:mft_gateway_canadian_tire]}&ediType=846",
      execute_inventory_flow_every_x_hour: 6,
      invoice_message_remote_path: "#{Heatwave::Configuration.fetch(:mft_gateway_api, :hostname)}/OutgoingAdapterWarmlyYours?as2id=#{AS2ID_BY_PARTNER[:mft_gateway_canadian_tire]}&ediType=810",
      support_contact: 'Udith Gunaratna, udith@edigenerator.com, support@mftgateway.com, support@edigenerator.com',
      generate_packing_slip: false,
      tax_registration_number: '86138 7777 RT0001'
    },
    mft_gateway_zoro_tools: {
      active: true,
      partner: :mft_gateway_zoro_tools,
      customer_id: 17765581,
      partner_id: '0XNALLWARMLYYOU',
      as2_id: AS2ID_BY_PARTNER[:mft_gateway_zoro_tools],
      partner_name: 'Zoro Tools',
      vendor_id: '106123881', # per Sydney at SPS Commerse'VEN1205',
      warehouse_code: "WY-US", # here we are using the code, no hash
      transporter: :basic_http_api,
      transporter_profile: :mft_gateway_api,
      order_message_enabled: true,
      acknowledge_message_remote_path: "#{Heatwave::Configuration.fetch(:mft_gateway_api, :hostname)}/OutgoingAdapterWarmlyYours?as2id=#{AS2ID_BY_PARTNER[:mft_gateway_zoro_tools]}&ediType=855",
      confirm_message_remote_path: "#{Heatwave::Configuration.fetch(:mft_gateway_api, :hostname)}/OutgoingAdapterWarmlyYours?as2id=#{AS2ID_BY_PARTNER[:mft_gateway_zoro_tools]}&ediType=856",
      ignore_back_orders: true,
      inventory_message_remote_path: "#{Heatwave::Configuration.fetch(:mft_gateway_api, :hostname)}/OutgoingAdapterWarmlyYours?as2id=#{AS2ID_BY_PARTNER[:mft_gateway_zoro_tools]}&ediType=846",
      execute_inventory_flow_every_x_hour: 6,
      invoice_message_remote_path: "#{Heatwave::Configuration.fetch(:mft_gateway_api, :hostname)}/OutgoingAdapterWarmlyYours?as2id=#{AS2ID_BY_PARTNER[:mft_gateway_zoro_tools]}&ediType=810",
      generate_packing_slip: true,
      support_contact: 'Udith Gunaratna, udith@edigenerator.com, support@mftgateway.com, support@edigenerator.com'
    },
    mft_gateway_amazon_vc_edi_wasn4: {
      active: true,
      partner: :mft_gateway_amazon_vc_edi_wasn4,
      customer_id: 2385944,
      partner_id: 'WASN4',
      as2_id: AS2ID_BY_PARTNER[:mft_gateway_amazon_vc_edi_wasn4],
      partner_name: 'Amazon Vendor Central US WASN4',
      vendor_id: 'WASN4',
      warehouse_code: "WB0I1", # here we are using the code, no hash
      transporter: :basic_http_api,
      transporter_profile: :mft_gateway_api,
      order_message_enabled: false,
      acknowledge_only_on_pending_ship_confirm: false,
      acknowledge_message_remote_path: nil,
      confirm_message_remote_path: nil,
      ignore_back_orders: true,
      inventory_message_remote_path: "#{Heatwave::Configuration.fetch(:mft_gateway_api, :hostname)}/OutgoingAdapterWarmlyYours?as2id=#{AS2ID_BY_PARTNER[:mft_gateway_amazon_vc_edi_wasn4]}&ediType=846",
      execute_inventory_flow_every_x_hour: 6,
      invoice_message_remote_path: nil,
      support_contact: 'Udith Gunaratna, udith@edigenerator.com, support@mftgateway.com, support@edigenerator.com',
      generate_packing_slip: false,
      tax_registration_number: nil
    },
    mft_gateway_amazon_vc_edi_wat0f: {
      active: true,
      partner: :mft_gateway_amazon_vc_edi_wat0f,
      customer_id: 2741053,
      partner_id: 'WAT0F',
      as2_id: AS2ID_BY_PARTNER[:mft_gateway_amazon_vc_edi_wat0f],
      partner_name: 'Amazon Vendor Central Canada WAT0F',
      vendor_id: 'WAT0F',
      warehouse_code: "WB102", # here we are using the code, no hash
      transporter: :basic_http_api,
      transporter_profile: :mft_gateway_api,
      order_message_enabled: false,
      acknowledge_only_on_pending_ship_confirm: false,
      acknowledge_message_remote_path: nil,
      confirm_message_remote_path: nil,
      ignore_back_orders: true,
      inventory_message_remote_path: "#{Heatwave::Configuration.fetch(:mft_gateway_api, :hostname)}/OutgoingAdapterWarmlyYours?as2id=#{AS2ID_BY_PARTNER[:mft_gateway_amazon_vc_edi_wat0f]}&ediType=846",
      execute_inventory_flow_every_x_hour: 6,
      invoice_message_remote_path: nil,
      support_contact: 'Udith Gunaratna, udith@edigenerator.com, support@mftgateway.com, support@edigenerator.com',
      generate_packing_slip: false,
      tax_registration_number: nil
    }
  }
end

Instance Method Details

#acknowledge_message_enabled? ⇒ Boolean

Returns:

  • (Boolean) 


238
239
240
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 238

def acknowledge_message_enabled?
  try(:acknowledge_message_remote_path).present?
end

#acknowledge_message_sender ⇒ Object 



242
243
244
245
246
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 242

def acknowledge_message_sender
  return Edi::NullProcessor.new(self, :acknowledge_message_sender, options) unless acknowledge_message_enabled?

  AcknowledgeMessageSender.new(self, options)
end

#confirm_message_enabled? ⇒ Boolean Also known as: shipment_message_enabled?

Returns:

  • (Boolean) 


227
228
229
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 227

def confirm_message_enabled?
  try(:confirm_message_remote_path).present?
end

#confirm_message_processor ⇒ Object 



232
233
234
235
236
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 232

def confirm_message_processor
  return Edi::NullProcessor.new(self, :confirm_message_processor, options) unless confirm_message_enabled?

  ConfirmMessageProcessor.new(self, options)
end

#confirm_message_sender ⇒ Object Also known as: shipment_message_sender 



248
249
250
251
252
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 248

def confirm_message_sender
  return Edi::NullProcessor.new(self, :confirm_message_sender, options) unless confirm_message_enabled?

  ConfirmMessageSender.new(self, options)
end

#execute_inventory_flow ⇒ Object 



345
346
347
348
349
350
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 345

def execute_inventory_flow
  return unless active

  inventory_message_processor.process
  inventory_message_sender.process
end

#execute_order_flow ⇒ Object 



321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 321

def execute_order_flow
  return unless active

  # order_message_retriever.process # We receive MFT orders directly via an API endpoint in HW from MFT, no retrieval necessary
  # sleep(1)
  packing_slip_retriever.process
  sleep(1)
  order_message_processor.process
  fa_message_sender.process
  sleep(5)
  packing_slip_processor.process
  sleep(1)
  acknowledge_message_sender.process
  confirm_message_sender.process
  sleep(1)
  invoice_message_sender.process
  sleep(1)
  remit_message_retriever.process
  sleep(1)
  remit_message_processor.process
  sleep(1)
  return_notification_message_sender.process
end

#fa_message_enabled? ⇒ Boolean

Returns:

  • (Boolean) 


211
212
213
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 211

def fa_message_enabled?
  try(:fa_message_remote_path).present?
end

#fa_message_processor ⇒ Object 



215
216
217
218
219
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 215

def fa_message_processor
  return Edi::NullProcessor.new(self, :fa_message_processor, options) unless fa_message_enabled?

  FaMessageProcessor.new(self, options)
end

#fa_message_sender ⇒ Object 



221
222
223
224
225
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 221

def fa_message_sender
  return Edi::NullProcessor.new(self, :fa_message_sender, options) unless fa_message_enabled?

  FaMessageSender.new(self, options)
end

#generate_unique_document_id(doc_category) ⇒ Object 



352
353
354
355
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 352

def generate_unique_document_id(doc_category)
  prefix = EdiCommunicationLog.get_file_prefix_from(partner, doc_category)
  "#{prefix}#{Time.current.to_i.to_s}".first(30)
end

#inventory_message_enabled? ⇒ Boolean

Returns:

  • (Boolean) 


275
276
277
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 275

def inventory_message_enabled?
  try(:inventory_message_remote_path).present?
end

#inventory_message_processor ⇒ Object 



279
280
281
282
283
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 279

def inventory_message_processor
  return Edi::NullProcessor.new(self, :inventory_message_processor, options) unless inventory_message_enabled?

  InventoryMessageProcessor.new(self, options)
end

#inventory_message_sender ⇒ Object 



285
286
287
288
289
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 285

def inventory_message_sender
  return Edi::NullProcessor.new(self, :inventory_message_sender, options) unless inventory_message_enabled?

  InventoryMessageSender.new(self, options)
end

#invoice_message_enabled? ⇒ Boolean

Returns:

  • (Boolean) 


179
180
181
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 179

def invoice_message_enabled?
  try(:invoice_message_remote_path).present?
end

#invoice_message_processor ⇒ Object 



183
184
185
186
187
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 183

def invoice_message_processor
  return Edi::NullProcessor.new(self, :invoice_message_processor, options) unless invoice_message_enabled?

  InvoiceMessageProcessor.new(self, options)
end

#invoice_message_sender ⇒ Object 



189
190
191
192
193
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 189

def invoice_message_sender
  return Edi::NullProcessor.new(self, :invoice_message_sender, options) unless invoice_message_enabled?

  InvoiceMessageSender.new(self, options)
end

#order_message_enabled? ⇒ Boolean

Returns:

  • (Boolean) 


163
164
165
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 163

def order_message_enabled?
  try(:order_message_enabled)
end

#order_message_processor ⇒ Object

OrderMessageRetriever.new(self, options)
end



173
174
175
176
177
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 173

def order_message_processor
  return Edi::NullProcessor.new(self, :order_message_processor, options) unless order_message_enabled?

  OrderMessageProcessor.new(self, options)
end

#packing_slip_enabled? ⇒ Boolean

Returns:

  • (Boolean) 


291
292
293
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 291

def packing_slip_enabled?
  try(:packing_slip_remote_path).present? && try(:packing_slip_file_pattern).present?
end

#packing_slip_processor ⇒ Object 



301
302
303
304
305
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 301

def packing_slip_processor
  return Edi::NullProcessor.new(self, :packing_slip_processor, options) unless packing_slip_enabled?

  PackingSlipProcessor.new(self, options)
end

#packing_slip_reader ⇒ Object 



311
312
313
314
315
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 311

def packing_slip_reader
  return Edi::NullProcessor.new(self, :packing_slip_reader, options) unless packing_slip_reader_enabled?

  packing_slip_reader_type.new(self, options)
end

#packing_slip_reader_enabled? ⇒ Boolean

Returns:

  • (Boolean) 


307
308
309
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 307

def packing_slip_reader_enabled?
  try(:packing_slip_reader_type).present?
end

#packing_slip_retriever ⇒ Object 



295
296
297
298
299
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 295

def packing_slip_retriever
  return Edi::NullProcessor.new(self, :packing_slip_retriever, options) unless packing_slip_enabled?

  PackingSlipRetriever.new(self, options)
end

#remit_message_enabled? ⇒ Boolean

Returns:

  • (Boolean) 


255
256
257
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 255

def remit_message_enabled?
  try(:remit_message_remote_path).present? && try(:remit_message_file_pattern).present?
end

#remit_message_processor ⇒ Object 



269
270
271
272
273
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 269

def remit_message_processor
  return Edi::NullProcessor.new(self, :remit_message_processor, options) unless remit_message_enabled?

  RemitMessageProcessor.new(self, options)
end

#remit_message_processor_enabled? ⇒ Boolean

Returns:

  • (Boolean) 


259
260
261
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 259

def remit_message_processor_enabled?
  try(:remit_message_processor_active).present? && remit_message_processor_active == true
end

#remit_message_retriever ⇒ Object 



263
264
265
266
267
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 263

def remit_message_retriever
  return Edi::NullProcessor.new(self, :remit_message_retriever, options) unless remit_message_enabled?

  RemitMessageRetriever.new(self, options)
end

#return_notification_message_enabled? ⇒ Boolean

Returns:

  • (Boolean) 


195
196
197
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 195

def return_notification_message_enabled?
  try(:return_notification_message_remote_path).present?
end

#return_notification_message_processor ⇒ Object 



199
200
201
202
203
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 199

def return_notification_message_processor
  return Edi::NullProcessor.new(self, :return_notification_message_processor, options) unless return_notification_message_enabled?

  ReturnNotificationMessageProcessor.new(self, options)
end

#return_notification_message_sender ⇒ Object 



205
206
207
208
209
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 205

def return_notification_message_sender
  return Edi::NullProcessor.new(self, :return_notification_message_sender, options) unless return_notification_message_enabled?

  ReturnNotificationMessageSender.new(self, options)
end

#ship_code_mapper ⇒ Object 



317
318
319
 
# File 'app/services/edi/mft_gateway/orchestrator.rb', line 317

def ship_code_mapper
  ShipCodeMapper.new(self)
end