customer key fix and fetch directory change.

fetch-and-stage-orders.py

@@ -24,7 +24,8 @@ SHANDEX_SFTP_PASSWORD = "ST@Pass2024$$"
 
 INSERT_ORDER = """
     EXECUTE [staging].[dbo].[shandex_insert_order_detail]
-       :customer_order_number
+       :customerkey
+      ,:customer_order_number
       ,:customer_po
       ,:Order_Type
       ,:order_status
@@ -34,6 +35,7 @@ INSERT_ORDER = """
       ,:customer_number
       ,:sold_to_name
       ,:line_number
+      ,:ship_to
       ,:supplier_part_number
       ,:sku
       ,:description
@@ -64,15 +66,14 @@ def retrieve_x12_edi_files_shandex():
             hostname=SHANDEX_SFTP_HOST, username=SHANDEX_SFTP_USERNAME, password=SHANDEX_SFTP_PASSWORD
         )
         with ssh_client.open_sftp() as sftp_connection:
-            sftp_connection.chdir("/Stash/Test/FromShandex") #TODO update this to Production folder
+            sftp_connection.chdir("/Stash/Prod/FromShandex/Reports") #TODO update this to Production folder
             for filename in sftp_connection.listdir():
                 if filename.startswith("Stash_Tea_Order_Data"):
                     sftp_connection.get(filename, INCOMING_DIRECTORY / filename)
-                    new_filename = f"/Stash/Test/FromShandex/Archive/{filename}"
+                    new_filename = f"/Stash/Prod/FromShandex/Reports/Archive/{filename}"
                     sftp_connection.rename(filename, new_filename)
 
 def process_file(file):
-    #open file
     all_data = []
     with file.open(encoding="utf-8", newline="") as csv_file:
         reader = csv.reader(csv_file)
@@ -80,6 +81,7 @@ def process_file(file):
         for row in reader:
             if row:
                 key_dict = {
+                    "customerkey":row[7] + '_' + row[9],
                     "customer_order_number":row[0],
                     "customer_po":row[1],
                     "Order_Type":row[2],
@@ -89,23 +91,22 @@ def process_file(file):
                     "ship_date":row[6],
                     "customer_number":row[7],
                     "sold_to_name":row[8],
-                    "line_number":row[9],
-                    "supplier_part_number":row[10],
-                    "sku":row[11],
-                    "description":row[12],
-                    "qty_ordered":row[13],
-                    "qty_picked":row[14],
-                    "qty_shorted":row[15],
-                    "uom":row[16],
-                    "unit_price":row[17],
+                    "line_number":row[9],
+                    "ship_to":row[10],
+                    "supplier_part_number":row[11],
+                    "sku":row[12],
+                    "description":row[13],
+                    "qty_ordered":row[14],
+                    "qty_picked":row[15],
+                    "qty_shorted":row[16],
+                    "uom":row[17],
+                    "unit_price":row[18],
                 }
                 all_data.append(key_dict)
     if(all_data):
         with yamamotoyama.get_connection() as data_base:
             with data_base.transaction():
                 data_base.bulk_query(INSERT_ORDER, all_data)
-    #load vars and insert
-    #archive
 
 if __name__ == "__main__":
     main()

ssh/id_ed25519

@@ -0,0 +1,7 @@
+-----BEGIN OPENSSH PRIVATE KEY-----
+b3BlbnNzaC1rZXktdjEAAAAABG5vbmUAAAAEbm9uZQAAAAAAAAABAAAAMwAAAAtzc2gtZW
+QyNTUxOQAAACBV8x5ikQyA6ZgAO2BokIZB13CCFjiQIU8bHf8BXrkVLAAAAJj90RvK/dEb
+ygAAAAtzc2gtZWQyNTUxOQAAACBV8x5ikQyA6ZgAO2BokIZB13CCFjiQIU8bHf8BXrkVLA
+AAAEBIPcJFMSUHOcXD0G85tKPaaSaUfXoYz/pgoffs+Y4ul1XzHmKRDIDpmAA7YGiQhkHX
+cIIWOJAhTxsd/wFeuRUsAAAAEHl1bWlkZGxld2FyZTIwMjMBAgMEBQ==
+-----END OPENSSH PRIVATE KEY-----

ssh/id_ed25519.pub

@@ -0,0 +1 @@
+ssh-ed25519 AAAAC3NzaC1lZDI1NTE5AAAAIFXzHmKRDIDpmAA7YGiQhkHXcIIWOJAhTxsd/wFeuRUs yumiddleware2023

ssh/known_hosts

@@ -0,0 +1,2 @@
+s-8ade4d252cc44c50b.server.transfer.us-west-1.amazonaws.com ssh-rsa AAAAB3NzaC1yc2EAAAADAQABAAABAQDIDQlEH17E193o9cOd0azlbI388A2GX4DzCWriLuj+BI+Jsi4Ij6oSKbsfKsqY0oThzdahxvafr1q1RxX4WN7yKGtQ+osOrXaSdSBOfejTJ9Wtr3DI4g6APoK4KX8luo7lYhmdVsNZtYdd2Wz7gIm4hsFtnSzrCyOvYMQ6mzvZQGGb+3V5Ce2wjYb0TjxdDdiacXXtbopVRuPAARqFz8hYMoKsZEyKuMekbErqiaC99ZZXtfmh9ZOJdSIF0N6loMWQaNtdLoyD1Xts3CDAcSg41wSfDYB3mtuIZEC/WNBj57RDuy93IsxH9z4Ak47cCrpChSpXp4pfajJS7W5g+Hyd
+ftp.shandex.com ssh-rsa AAAAB3NzaC1yc2EAAAADAQABAAABAQDWht+ZlPHMwzohq4gnOTAAdtCt2u7BG/fdONXdvluMopWq8bwTKX0iKV5/7sRIIGimk1zIX19zDGR/5B9BbPFBRrxdKA915L830hj8omdo/ayA7pm/sDE7YdmSzUJ/akaO2KYDqBcpElr0Eb3gKaxy1oJGOR8zcLEffZpmYjMHKuCE6KqooCbn6326yRpl/fUhFK9QKLowIzBpeaQzGeNnGLON6j1bRPtObO0QYykdsb6mMF77ZKcf/kibnAtau2APC6xmDL3LDA6h5bwMs8nrC2Yg094dFPjvmC2FIbgiomtz8bfhLYsjDSE1JMNOUIbyoNvitWX5Zavtp70FnQcv