add modules

config/groups.json

@@ -58,7 +58,7 @@
     "schedules": [
       {
         "cron_expr": "0 1 * * *",
-        "enabled": 0
+        "enabled": 1
       }
     ]
   },
@@ -101,7 +101,7 @@
     "schedules": [
       {
         "cron_expr": "0 1 * * *",
-        "enabled": 0
+        "enabled": 1
       }
     ]
   },

config/modules/cont.json

@@ -0,0 +1,520 @@
+{
+  "name": "cont",
+  "source_connection": "S78030956",
+  "dest_connection": "usmidsap02",
+  "dest_table": "cms.cont",
+  "staging_table": "pipekit_staging.cont",
+  "merge_strategy": "full",
+  "merge_key": null,
+  "enabled": 1,
+  "dest_description": "A/P Bank Controls 6.1",
+  "description": null,
+  "columns": [
+    {
+      "source_name": "IFA2",
+      "source_type": "CHAR(2)",
+      "dest_name": "ifa2",
+      "dest_type": "text",
+      "description": "NOT USED"
+    },
+    {
+      "source_name": "IFLCDT",
+      "source_type": "CHAR(6)",
+      "dest_name": "iflcdt",
+      "dest_type": "text",
+      "description": "NOT USED"
+    },
+    {
+      "source_name": "IFA6",
+      "source_type": "CHAR(6)",
+      "dest_name": "ifa6",
+      "dest_type": "text",
+      "description": "NOT USED"
+    },
+    {
+      "source_name": "IFMINC",
+      "source_type": "DECIMAL(7,2)",
+      "dest_name": "ifminc",
+      "dest_type": "numeric(7,2)",
+      "description": "Minimum Cheque"
+    },
+    {
+      "source_name": "IFA5",
+      "source_type": "CHAR(5)",
+      "dest_name": "ifa5",
+      "dest_type": "text",
+      "description": "NOT USED"
+    },
+    {
+      "source_name": "IFLCHQ",
+      "source_type": "NUMERIC(8,0)",
+      "dest_name": "iflchq",
+      "dest_type": "numeric(8,0)",
+      "description": "Last Cheque Assigned"
+    },
+    {
+      "source_name": "IFCLCR",
+      "source_type": "NUMERIC(8,0)",
+      "dest_name": "ifclcr",
+      "dest_type": "numeric(8,0)",
+      "description": "Comp Chq Low Range"
+    },
+    {
+      "source_name": "IFCHCR",
+      "source_type": "NUMERIC(8,0)",
+      "dest_name": "ifchcr",
+      "dest_type": "numeric(8,0)",
+      "description": "Comp Chq High Range"
+    },
+    {
+      "source_name": "IFMLCR",
+      "source_type": "NUMERIC(8,0)",
+      "dest_name": "ifmlcr",
+      "dest_type": "numeric(8,0)",
+      "description": "Man Chq Low Range"
+    },
+    {
+      "source_name": "IFMHCR",
+      "source_type": "NUMERIC(8,0)",
+      "dest_name": "ifmhcr",
+      "dest_type": "numeric(8,0)",
+      "description": "Man Chq High Range"
+    },
+    {
+      "source_name": "IFA10",
+      "source_type": "CHAR(10)",
+      "dest_name": "ifa10",
+      "dest_type": "text",
+      "description": "NOT USED"
+    },
+    {
+      "source_name": "IFGSGL",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "ifgsgl",
+      "dest_type": "numeric(10,0)",
+      "description": "GST G/L Account"
+    },
+    {
+      "source_name": "IFCURR",
+      "source_type": "CHAR(2)",
+      "dest_name": "ifcurr",
+      "dest_type": "text",
+      "description": "Currency Code"
+    },
+    {
+      "source_name": "IFAA1",
+      "source_type": "CHAR(1)",
+      "dest_name": "ifaa1",
+      "dest_type": "text",
+      "description": "NOT USED"
+    },
+    {
+      "source_name": "IFAPGL",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "ifapgl",
+      "dest_type": "numeric(10,0)",
+      "description": "A/P G/L Account"
+    },
+    {
+      "source_name": "IFBKGL",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "ifbkgl",
+      "dest_type": "numeric(10,0)",
+      "description": "Bank G/L Account"
+    },
+    {
+      "source_name": "IFDSGL",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "ifdsgl",
+      "dest_type": "numeric(10,0)",
+      "description": "Discount G/L Account"
+    },
+    {
+      "source_name": "IFCOGL",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "ifcogl",
+      "dest_type": "numeric(10,0)",
+      "description": "Currency Offset Account"
+    },
+    {
+      "source_name": "IFAA4",
+      "source_type": "CHAR(4)",
+      "dest_name": "ifaa4",
+      "dest_type": "text",
+      "description": "NOT USED"
+    },
+    {
+      "source_name": "IFLRDT",
+      "source_type": "CHAR(6)",
+      "dest_name": "iflrdt",
+      "dest_type": "text",
+      "description": "UNKNOWN"
+    },
+    {
+      "source_name": "IFA7",
+      "source_type": "CHAR(7)",
+      "dest_name": "ifa7",
+      "dest_type": "text",
+      "description": "NOT USED"
+    },
+    {
+      "source_name": "IFBKNM",
+      "source_type": "CHAR(30)",
+      "dest_name": "ifbknm",
+      "dest_type": "text",
+      "description": "Bank Name"
+    },
+    {
+      "source_name": "IFCCGL",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "ifccgl",
+      "dest_type": "numeric(10,0)",
+      "description": "Currency Cash Offset Account"
+    },
+    {
+      "source_name": "IFCGGL",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "ifcggl",
+      "dest_type": "numeric(10,0)",
+      "description": "Currency Gain/Loss Account"
+    },
+    {
+      "source_name": "IFFRGL",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "iffrgl",
+      "dest_type": "numeric(10,0)",
+      "description": "Freight Variance Account"
+    },
+    {
+      "source_name": "IFDTGL",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "ifdtgl",
+      "dest_type": "numeric(10,0)",
+      "description": "Duty Variance Account"
+    },
+    {
+      "source_name": "IFA45",
+      "source_type": "CHAR(5)",
+      "dest_name": "ifa45",
+      "dest_type": "text",
+      "description": "NOT USED"
+    },
+    {
+      "source_name": "IFCNAM",
+      "source_type": "CHAR(50)",
+      "dest_name": "ifcnam",
+      "dest_type": "text",
+      "description": "Company Name"
+    },
+    {
+      "source_name": "IFCOM#",
+      "source_type": "NUMERIC(2,0)",
+      "dest_name": "ifcom#",
+      "dest_type": "numeric(2,0)",
+      "description": "Company Number"
+    },
+    {
+      "source_name": "IFBNK#",
+      "source_type": "CHAR(3)",
+      "dest_name": "ifbnk#",
+      "dest_type": "text",
+      "description": "A/P Bank Code"
+    },
+    {
+      "source_name": "IFCDAT",
+      "source_type": "DATE",
+      "dest_name": "ifcdat",
+      "dest_type": "date",
+      "description": "Last Cheque Date"
+    },
+    {
+      "source_name": "IFBNKA",
+      "source_type": "CHAR(40)",
+      "dest_name": "ifbnka",
+      "dest_type": "text",
+      "description": "Bank Account Number"
+    },
+    {
+      "source_name": "IFFIID",
+      "source_type": "CHAR(17)",
+      "dest_name": "iffiid",
+      "dest_type": "text",
+      "description": "Financial Institution I.D."
+    },
+    {
+      "source_name": "IFFINM",
+      "source_type": "CHAR(35)",
+      "dest_name": "iffinm",
+      "dest_type": "text",
+      "description": "Financial Institution Name"
+    },
+    {
+      "source_name": "IFHQGL",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "ifhqgl",
+      "dest_type": "numeric(10,0)",
+      "description": "HQ Clearing Account"
+    },
+    {
+      "source_name": "IFBREF#",
+      "source_type": "CHAR(10)",
+      "dest_name": "ifbref#",
+      "dest_type": "text",
+      "description": "Bank Refernce #"
+    },
+    {
+      "source_name": "IFTRN#",
+      "source_type": "CHAR(10)",
+      "dest_name": "iftrn#",
+      "dest_type": "text",
+      "description": "Transit No"
+    },
+    {
+      "source_name": "IFEBNK",
+      "source_type": "CHAR(10)",
+      "dest_name": "ifebnk",
+      "dest_type": "text",
+      "description": "EFT Bank Code"
+    },
+    {
+      "source_name": "IFPAYT",
+      "source_type": "CHAR(1)",
+      "dest_name": "ifpayt",
+      "dest_type": "text",
+      "description": "Payment Type"
+    },
+    {
+      "source_name": "IFFUT3",
+      "source_type": "CHAR(20)",
+      "dest_name": "iffut3",
+      "dest_type": "text",
+      "description": "File Creation No."
+    },
+    {
+      "source_name": "IFFUT4",
+      "source_type": "CHAR(20)",
+      "dest_name": "iffut4",
+      "dest_type": "text",
+      "description": "Swift ID"
+    },
+    {
+      "source_name": "IFFUT5",
+      "source_type": "NUMERIC(15,0)",
+      "dest_name": "iffut5",
+      "dest_type": "numeric(15,0)",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "IFFUT6",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "iffut6",
+      "dest_type": "numeric(10,0)",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "IFFUT7",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "iffut7",
+      "dest_type": "numeric(10,0)",
+      "description": "HQ IC Currency Exchange Offset"
+    },
+    {
+      "source_name": "IFFLG1",
+      "source_type": "CHAR(1)",
+      "dest_name": "ifflg1",
+      "dest_type": "text",
+      "description": "Numeric Length"
+    },
+    {
+      "source_name": "IFFLG2",
+      "source_type": "CHAR(1)",
+      "dest_name": "ifflg2",
+      "dest_type": "text",
+      "description": "EDI Translation Mode"
+    },
+    {
+      "source_name": "IFFLG3",
+      "source_type": "CHAR(1)",
+      "dest_name": "ifflg3",
+      "dest_type": "text",
+      "description": "Update UCHQ at EFT Transmission"
+    },
+    {
+      "source_name": "IFFLG4",
+      "source_type": "CHAR(1)",
+      "dest_name": "ifflg4",
+      "dest_type": "text",
+      "description": "Update MCAMT at Manual Cheque Post"
+    },
+    {
+      "source_name": "IFEXDT",
+      "source_type": "DATE",
+      "dest_name": "ifexdt",
+      "dest_type": "date",
+      "description": "Lst. Chq Export Date"
+    },
+    {
+      "source_name": "IFFUT1",
+      "source_type": "CHAR(10)",
+      "dest_name": "iffut1",
+      "dest_type": "text",
+      "description": "Transaction Set Purpose"
+    },
+    {
+      "source_name": "IFFUT2",
+      "source_type": "CHAR(10)",
+      "dest_name": "iffut2",
+      "dest_type": "text",
+      "description": "ABA#"
+    },
+    {
+      "source_name": "IFFUT8",
+      "source_type": "CHAR(15)",
+      "dest_name": "iffut8",
+      "dest_type": "text",
+      "description": "Trading Partner"
+    },
+    {
+      "source_name": "IFISGL",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "ifisgl",
+      "dest_type": "numeric(10,0)",
+      "description": "IP - Sales Act"
+    },
+    {
+      "source_name": "IFICGL",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "ificgl",
+      "dest_type": "numeric(10,0)",
+      "description": "IP - Cost of Sales Act"
+    },
+    {
+      "source_name": "IFFAC1",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "iffac1",
+      "dest_type": "numeric(10,0)",
+      "description": "Future Act. No Field"
+    },
+    {
+      "source_name": "IFFAC2",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "iffac2",
+      "dest_type": "numeric(10,0)",
+      "description": "Future Act. No Field"
+    },
+    {
+      "source_name": "IFFAC3",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "iffac3",
+      "dest_type": "numeric(10,0)",
+      "description": "Misc. Charge Account"
+    },
+    {
+      "source_name": "IFFAC4",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "iffac4",
+      "dest_type": "numeric(10,0)",
+      "description": "A/P Accrual Account"
+    },
+    {
+      "source_name": "IFFAC5",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "iffac5",
+      "dest_type": "numeric(10,0)",
+      "description": "Freight Accrual Account"
+    },
+    {
+      "source_name": "IFPVGL",
+      "source_type": "NUMERIC(10,0)",
+      "dest_name": "ifpvgl",
+      "dest_type": "numeric(10,0)",
+      "description": "Price Variance Gain/Loss Acct#"
+    },
+    {
+      "source_name": "IFFUT9",
+      "source_type": "CHAR(1)",
+      "dest_name": "iffut9",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "IFFUT10",
+      "source_type": "CHAR(1)",
+      "dest_name": "iffut10",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "IFFUT11",
+      "source_type": "CHAR(1)",
+      "dest_name": "iffut11",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "IFFUT12",
+      "source_type": "CHAR(10)",
+      "dest_name": "iffut12",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "IFFUT13",
+      "source_type": "CHAR(10)",
+      "dest_name": "iffut13",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "IFFUT14",
+      "source_type": "CHAR(20)",
+      "dest_name": "iffut14",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "IFFUT15",
+      "source_type": "CHAR(20)",
+      "dest_name": "iffut15",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "IFFUT16",
+      "source_type": "CHAR(30)",
+      "dest_name": "iffut16",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "IFFUT17",
+      "source_type": "CHAR(30)",
+      "dest_name": "iffut17",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "IFFUT18",
+      "source_type": "NUMERIC(15,5)",
+      "dest_name": "iffut18",
+      "dest_type": "numeric(15,5)",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "IFFUT19",
+      "source_type": "NUMERIC(15,5)",
+      "dest_name": "iffut19",
+      "dest_type": "numeric(15,5)",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "IFFUT20",
+      "source_type": "NUMERIC(15,5)",
+      "dest_name": "iffut20",
+      "dest_type": "numeric(15,5)",
+      "description": "Future Use"
+    }
+  ],
+  "watermarks": [],
+  "hooks": []
+}

config/modules/cont.sql

@@ -0,0 +1,74 @@
+SELECT
+  RTRIM(IFA2) AS ifa2,
+  RTRIM(IFLCDT) AS iflcdt,
+  RTRIM(IFA6) AS ifa6,
+  IFMINC AS ifminc,
+  RTRIM(IFA5) AS ifa5,
+  IFLCHQ AS iflchq,
+  IFCLCR AS ifclcr,
+  IFCHCR AS ifchcr,
+  IFMLCR AS ifmlcr,
+  IFMHCR AS ifmhcr,
+  RTRIM(IFA10) AS ifa10,
+  IFGSGL AS ifgsgl,
+  RTRIM(IFCURR) AS ifcurr,
+  RTRIM(IFAA1) AS ifaa1,
+  IFAPGL AS ifapgl,
+  IFBKGL AS ifbkgl,
+  IFDSGL AS ifdsgl,
+  IFCOGL AS ifcogl,
+  RTRIM(IFAA4) AS ifaa4,
+  RTRIM(IFLRDT) AS iflrdt,
+  RTRIM(IFA7) AS ifa7,
+  RTRIM(IFBKNM) AS ifbknm,
+  IFCCGL AS ifccgl,
+  IFCGGL AS ifcggl,
+  IFFRGL AS iffrgl,
+  IFDTGL AS ifdtgl,
+  RTRIM(IFA45) AS ifa45,
+  RTRIM(IFCNAM) AS ifcnam,
+  "IFCOM#" AS "ifcom#",
+  RTRIM("IFBNK#") AS "ifbnk#",
+  CASE WHEN IFCDAT IN (DATE('0001-01-01'), DATE('9999-12-31')) THEN NULL ELSE IFCDAT END AS ifcdat,
+  RTRIM(IFBNKA) AS ifbnka,
+  RTRIM(IFFIID) AS iffiid,
+  RTRIM(IFFINM) AS iffinm,
+  IFHQGL AS ifhqgl,
+  RTRIM("IFBREF#") AS "ifbref#",
+  RTRIM("IFTRN#") AS "iftrn#",
+  RTRIM(IFEBNK) AS ifebnk,
+  RTRIM(IFPAYT) AS ifpayt,
+  RTRIM(IFFUT3) AS iffut3,
+  RTRIM(IFFUT4) AS iffut4,
+  IFFUT5 AS iffut5,
+  IFFUT6 AS iffut6,
+  IFFUT7 AS iffut7,
+  RTRIM(IFFLG1) AS ifflg1,
+  RTRIM(IFFLG2) AS ifflg2,
+  RTRIM(IFFLG3) AS ifflg3,
+  RTRIM(IFFLG4) AS ifflg4,
+  CASE WHEN IFEXDT IN (DATE('0001-01-01'), DATE('9999-12-31')) THEN NULL ELSE IFEXDT END AS ifexdt,
+  RTRIM(IFFUT1) AS iffut1,
+  RTRIM(IFFUT2) AS iffut2,
+  RTRIM(IFFUT8) AS iffut8,
+  IFISGL AS ifisgl,
+  IFICGL AS ificgl,
+  IFFAC1 AS iffac1,
+  IFFAC2 AS iffac2,
+  IFFAC3 AS iffac3,
+  IFFAC4 AS iffac4,
+  IFFAC5 AS iffac5,
+  IFPVGL AS ifpvgl,
+  RTRIM(IFFUT9) AS iffut9,
+  RTRIM(IFFUT10) AS iffut10,
+  RTRIM(IFFUT11) AS iffut11,
+  RTRIM(IFFUT12) AS iffut12,
+  RTRIM(IFFUT13) AS iffut13,
+  RTRIM(IFFUT14) AS iffut14,
+  RTRIM(IFFUT15) AS iffut15,
+  RTRIM(IFFUT16) AS iffut16,
+  RTRIM(IFFUT17) AS iffut17,
+  IFFUT18 AS iffut18,
+  IFFUT19 AS iffut19,
+  IFFUT20 AS iffut20
+FROM LGDAT.CONT

config/modules/spxitemmaster.json

@@ -0,0 +1,758 @@
+{
+  "name": "spxitemmaster",
+  "source_connection": "sqlserver",
+  "dest_connection": "usmidsap02",
+  "dest_table": "gp.spxitemmaster",
+  "staging_table": "pipekit_staging.spxitemmaster",
+  "merge_strategy": "full",
+  "merge_key": null,
+  "enabled": 1,
+  "dest_description": null,
+  "description": null,
+  "columns": [
+    {
+      "source_name": "Item_Number",
+      "source_type": "VARCHAR(31)",
+      "dest_name": "item_number",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "BOD",
+      "source_type": "VARCHAR(20)",
+      "dest_name": "bod",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Depth",
+      "source_type": "VARCHAR(10)",
+      "dest_name": "depth",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Drainage",
+      "source_type": "VARCHAR(20)",
+      "dest_name": "drainage",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Drop_ins",
+      "source_type": "VARCHAR(150)",
+      "dest_name": "drop_ins",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "WebHeight",
+      "source_type": "VARCHAR(25)",
+      "dest_name": "webheight",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "WebLength",
+      "source_type": "VARCHAR(10)",
+      "dest_name": "weblength",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Overall_Height",
+      "source_type": "VARCHAR(10)",
+      "dest_name": "overall_height",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Picture",
+      "source_type": "VARCHAR(255)",
+      "dest_name": "picture",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Program",
+      "source_type": "VARCHAR(20)",
+      "dest_name": "program",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "TID",
+      "source_type": "VARCHAR(20)",
+      "dest_name": "tid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "TOD",
+      "source_type": "VARCHAR(20)",
+      "dest_name": "tod",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Volume",
+      "source_type": "VARCHAR(25)",
+      "dest_name": "volume",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "WebWidth",
+      "source_type": "VARCHAR(10)",
+      "dest_name": "webwidth",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Catalog_Description",
+      "source_type": "VARCHAR(100)",
+      "dest_name": "catalog_description",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_ITEMCODE",
+      "source_type": "VARCHAR(100)",
+      "dest_name": "_itemcode",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Garden_Goodz",
+      "source_type": "BIT",
+      "dest_name": "_garden_goodz",
+      "dest_type": "boolean",
+      "description": null
+    },
+    {
+      "source_name": "Mold_Id",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "mold_id",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Color",
+      "source_type": "VARCHAR(75)",
+      "dest_name": "color",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Item_Family",
+      "source_type": "VARCHAR(25)",
+      "dest_name": "item_family",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Material_Properties",
+      "source_type": "VARCHAR(100)",
+      "dest_name": "material_properties",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Shape_Properties",
+      "source_type": "VARCHAR(20)",
+      "dest_name": "shape_properties",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Size",
+      "source_type": "VARCHAR(15)",
+      "dest_name": "size",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_CHGWebReady",
+      "source_type": "BIT",
+      "dest_name": "_chgwebready",
+      "dest_type": "boolean",
+      "description": null
+    },
+    {
+      "source_name": "_AddOns",
+      "source_type": "VARCHAR(250)",
+      "dest_name": "_addons",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_ColorFilter",
+      "source_type": "VARCHAR(100)",
+      "dest_name": "_colorfilter",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_HdExclusive",
+      "source_type": "BIT",
+      "dest_name": "_hdexclusive",
+      "dest_type": "boolean",
+      "description": null
+    },
+    {
+      "source_name": "_IndoorOutdoor",
+      "source_type": "VARCHAR(25)",
+      "dest_name": "_indooroutdoor",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_SkidQty",
+      "source_type": "INT",
+      "dest_name": "_skidqty",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "_WebDescription",
+      "source_type": "VARCHAR(750)",
+      "dest_name": "_webdescription",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_WebHeader",
+      "source_type": "VARCHAR(150)",
+      "dest_name": "_webheader",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Finish",
+      "source_type": "VARCHAR(50)",
+      "dest_name": "_finish",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_SeasonalProgram",
+      "source_type": "VARCHAR(100)",
+      "dest_name": "_seasonalprogram",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_WebIcons",
+      "source_type": "VARCHAR(100)",
+      "dest_name": "_webicons",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_EastPrice",
+      "source_type": "NUMERIC(19,2)",
+      "dest_name": "_eastprice",
+      "dest_type": "numeric(19,2)",
+      "description": null
+    },
+    {
+      "source_name": "_NorthPrice",
+      "source_type": "NUMERIC(19,2)",
+      "dest_name": "_northprice",
+      "dest_type": "numeric(19,2)",
+      "description": null
+    },
+    {
+      "source_name": "_SouthPrice",
+      "source_type": "NUMERIC(19,2)",
+      "dest_name": "_southprice",
+      "dest_type": "numeric(19,2)",
+      "description": null
+    },
+    {
+      "source_name": "_WestPrice",
+      "source_type": "NUMERIC(19,2)",
+      "dest_name": "_westprice",
+      "dest_type": "numeric(19,2)",
+      "description": null
+    },
+    {
+      "source_name": "_Prefix",
+      "source_type": "VARCHAR(20)",
+      "dest_name": "_prefix",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Product_Type",
+      "source_type": "VARCHAR(100)",
+      "dest_name": "_product_type",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_VirtualWebInventory",
+      "source_type": "INT",
+      "dest_name": "_virtualwebinventory",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "_UseVirtualInventory",
+      "source_type": "BIT",
+      "dest_name": "_usevirtualinventory",
+      "dest_type": "boolean",
+      "description": null
+    },
+    {
+      "source_name": "_Big_Commerce_ID",
+      "source_type": "INT",
+      "dest_name": "_big_commerce_id",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "_Free_Addons",
+      "source_type": "VARCHAR(150)",
+      "dest_name": "_free_addons",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_HDCom_Internet_Number",
+      "source_type": "VARCHAR(12)",
+      "dest_name": "_hdcom_internet_number",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_HTSCode",
+      "source_type": "VARCHAR(25)",
+      "dest_name": "_htscode",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_DutyRate",
+      "source_type": "VARCHAR(10)",
+      "dest_name": "_dutyrate",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Exempt",
+      "source_type": "BIT",
+      "dest_name": "_exempt",
+      "dest_type": "boolean",
+      "description": null
+    },
+    {
+      "source_name": "_Sanction",
+      "source_type": "VARCHAR(25)",
+      "dest_name": "_sanction",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_HD_Retail",
+      "source_type": "NUMERIC(19,2)",
+      "dest_name": "_hd_retail",
+      "dest_type": "numeric(19,2)",
+      "description": null
+    },
+    {
+      "source_name": "ReOrder_Threshold",
+      "source_type": "INT",
+      "dest_name": "reorder_threshold",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "_EastCoastLanded",
+      "source_type": "NUMERIC(19,3)",
+      "dest_name": "_eastcoastlanded",
+      "dest_type": "numeric(19,3)",
+      "description": null
+    },
+    {
+      "source_name": "_NorthLanded",
+      "source_type": "NUMERIC(19,3)",
+      "dest_name": "_northlanded",
+      "dest_type": "numeric(19,3)",
+      "description": null
+    },
+    {
+      "source_name": "_SouthLanded",
+      "source_type": "NUMERIC(19,3)",
+      "dest_name": "_southlanded",
+      "dest_type": "numeric(19,3)",
+      "description": null
+    },
+    {
+      "source_name": "_WestCoastLanded",
+      "source_type": "NUMERIC(19,3)",
+      "dest_name": "_westcoastlanded",
+      "dest_type": "numeric(19,3)",
+      "description": null
+    },
+    {
+      "source_name": "_Component1",
+      "source_type": "VARCHAR(25)",
+      "dest_name": "_component1",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Component_2",
+      "source_type": "VARCHAR(25)",
+      "dest_name": "_component_2",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Component_1_qty",
+      "source_type": "INT",
+      "dest_name": "_component_1_qty",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "_Component_2_qty",
+      "source_type": "INT",
+      "dest_name": "_component_2_qty",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "_Master_Item_UPC",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "_master_item_upc",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Component_3",
+      "source_type": "VARCHAR(25)",
+      "dest_name": "_component_3",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Component_3_qty",
+      "source_type": "INT",
+      "dest_name": "_component_3_qty",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "_Component_4_qty",
+      "source_type": "INT",
+      "dest_name": "_component_4_qty",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "_Component_5_qty",
+      "source_type": "INT",
+      "dest_name": "_component_5_qty",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "_Component4",
+      "source_type": "VARCHAR(25)",
+      "dest_name": "_component4",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Component5",
+      "source_type": "VARCHAR(25)",
+      "dest_name": "_component5",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Component_6",
+      "source_type": "VARCHAR(25)",
+      "dest_name": "_component_6",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Component_6_qty",
+      "source_type": "INT",
+      "dest_name": "_component_6_qty",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "_SSRS_Category",
+      "source_type": "VARCHAR(100)",
+      "dest_name": "_ssrs_category",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_HD_PBS_SKU",
+      "source_type": "VARCHAR(10)",
+      "dest_name": "_hd_pbs_sku",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Channel",
+      "source_type": "VARCHAR(100)",
+      "dest_name": "_channel",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Double_Wide_Bin",
+      "source_type": "VARCHAR(5)",
+      "dest_name": "_double_wide_bin",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Family_Number",
+      "source_type": "VARCHAR(15)",
+      "dest_name": "_family_number",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Account_Manager",
+      "source_type": "VARCHAR(25)",
+      "dest_name": "_account_manager",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Pallet_Dims",
+      "source_type": "VARCHAR(20)",
+      "dest_name": "_pallet_dims",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Pallet_Weight",
+      "source_type": "VARCHAR(8)",
+      "dest_name": "_pallet_weight",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Customs_Materials",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "_customs_materials",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_THD_Collection",
+      "source_type": "VARCHAR(50)",
+      "dest_name": "_thd_collection",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Collection",
+      "source_type": "VARCHAR(100)",
+      "dest_name": "_collection",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Reporting_TOD",
+      "source_type": "VARCHAR(100)",
+      "dest_name": "_reporting_tod",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Add_on_1",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "_add_on_1",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Free_add_1",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "_free_add_1",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Free_add_2",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "_free_add_2",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Free_add_3",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "_free_add_3",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Free_add_4",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "_free_add_4",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Free_add_5",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "_free_add_5",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Add_on_1",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "add_on_1",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Add_on_2",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "add_on_2",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Add_on_3",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "add_on_3",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Add_on_4",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "add_on_4",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Add_on_5",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "add_on_5",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_PCR",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "_pcr",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "_Hanger_16",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "_hanger_16",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Hanger_18",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "_hanger_18",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Hanger_20",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "_hanger_20",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Hanger_22",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "_hanger_22",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Pedestal",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "_pedestal",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Self_Watering_Disc",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "_self_watering_disc",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Tag_Slot",
+      "source_type": "BIT",
+      "dest_name": "_tag_slot",
+      "dest_type": "boolean",
+      "description": null
+    },
+    {
+      "source_name": "_Water_Disc",
+      "source_type": "VARCHAR(30)",
+      "dest_name": "_water_disc",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Web_Image",
+      "source_type": "VARCHAR(50)",
+      "dest_name": "_web_image",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Web_Product_Type",
+      "source_type": "VARCHAR(50)",
+      "dest_name": "_web_product_type",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Product_Tier",
+      "source_type": "VARCHAR(20)",
+      "dest_name": "_product_tier",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Product_Tier_Exclusive",
+      "source_type": "VARCHAR(20)",
+      "dest_name": "_product_tier_exclusive",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Production_Review",
+      "source_type": "VARCHAR(25)",
+      "dest_name": "_production_review",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "_Segment",
+      "source_type": "VARCHAR(32)",
+      "dest_name": "_segment",
+      "dest_type": "text",
+      "description": null
+    }
+  ],
+  "watermarks": [],
+  "hooks": []
+}

config/modules/spxitemmaster.sql

@@ -0,0 +1,108 @@
+SELECT
+  RTRIM([Item_Number]) AS [item_number],
+  RTRIM([BOD]) AS [bod],
+  RTRIM([Depth]) AS [depth],
+  RTRIM([Drainage]) AS [drainage],
+  RTRIM([Drop_ins]) AS [drop_ins],
+  RTRIM([WebHeight]) AS [webheight],
+  RTRIM([WebLength]) AS [weblength],
+  RTRIM([Overall_Height]) AS [overall_height],
+  RTRIM([Picture]) AS [picture],
+  RTRIM([Program]) AS [program],
+  RTRIM([TID]) AS [tid],
+  RTRIM([TOD]) AS [tod],
+  RTRIM([Volume]) AS [volume],
+  RTRIM([WebWidth]) AS [webwidth],
+  RTRIM([Catalog_Description]) AS [catalog_description],
+  RTRIM([_ITEMCODE]) AS [_itemcode],
+  [_Garden_Goodz] AS [_garden_goodz],
+  RTRIM([Mold_Id]) AS [mold_id],
+  RTRIM([Color]) AS [color],
+  RTRIM([Item_Family]) AS [item_family],
+  RTRIM([Material_Properties]) AS [material_properties],
+  RTRIM([Shape_Properties]) AS [shape_properties],
+  RTRIM([Size]) AS [size],
+  [_CHGWebReady] AS [_chgwebready],
+  RTRIM([_AddOns]) AS [_addons],
+  RTRIM([_ColorFilter]) AS [_colorfilter],
+  [_HdExclusive] AS [_hdexclusive],
+  RTRIM([_IndoorOutdoor]) AS [_indooroutdoor],
+  [_SkidQty] AS [_skidqty],
+  RTRIM([_WebDescription]) AS [_webdescription],
+  RTRIM([_WebHeader]) AS [_webheader],
+  RTRIM([_Finish]) AS [_finish],
+  RTRIM([_SeasonalProgram]) AS [_seasonalprogram],
+  RTRIM([_WebIcons]) AS [_webicons],
+  [_EastPrice] AS [_eastprice],
+  [_NorthPrice] AS [_northprice],
+  [_SouthPrice] AS [_southprice],
+  [_WestPrice] AS [_westprice],
+  RTRIM([_Prefix]) AS [_prefix],
+  RTRIM([_Product_Type]) AS [_product_type],
+  [_VirtualWebInventory] AS [_virtualwebinventory],
+  [_UseVirtualInventory] AS [_usevirtualinventory],
+  [_Big_Commerce_ID] AS [_big_commerce_id],
+  RTRIM([_Free_Addons]) AS [_free_addons],
+  RTRIM([_HDCom_Internet_Number]) AS [_hdcom_internet_number],
+  RTRIM([_HTSCode]) AS [_htscode],
+  RTRIM([_DutyRate]) AS [_dutyrate],
+  [_Exempt] AS [_exempt],
+  RTRIM([_Sanction]) AS [_sanction],
+  [_HD_Retail] AS [_hd_retail],
+  [ReOrder_Threshold] AS [reorder_threshold],
+  [_EastCoastLanded] AS [_eastcoastlanded],
+  [_NorthLanded] AS [_northlanded],
+  [_SouthLanded] AS [_southlanded],
+  [_WestCoastLanded] AS [_westcoastlanded],
+  RTRIM([_Component1]) AS [_component1],
+  RTRIM([_Component_2]) AS [_component_2],
+  [_Component_1_qty] AS [_component_1_qty],
+  [_Component_2_qty] AS [_component_2_qty],
+  RTRIM([_Master_Item_UPC]) AS [_master_item_upc],
+  RTRIM([_Component_3]) AS [_component_3],
+  [_Component_3_qty] AS [_component_3_qty],
+  [_Component_4_qty] AS [_component_4_qty],
+  [_Component_5_qty] AS [_component_5_qty],
+  RTRIM([_Component4]) AS [_component4],
+  RTRIM([_Component5]) AS [_component5],
+  RTRIM([_Component_6]) AS [_component_6],
+  [_Component_6_qty] AS [_component_6_qty],
+  RTRIM([_SSRS_Category]) AS [_ssrs_category],
+  RTRIM([_HD_PBS_SKU]) AS [_hd_pbs_sku],
+  RTRIM([_Channel]) AS [_channel],
+  RTRIM([_Double_Wide_Bin]) AS [_double_wide_bin],
+  RTRIM([_Family_Number]) AS [_family_number],
+  RTRIM([_Account_Manager]) AS [_account_manager],
+  RTRIM([_Pallet_Dims]) AS [_pallet_dims],
+  RTRIM([_Pallet_Weight]) AS [_pallet_weight],
+  RTRIM([_Customs_Materials]) AS [_customs_materials],
+  RTRIM([_THD_Collection]) AS [_thd_collection],
+  RTRIM([_Collection]) AS [_collection],
+  RTRIM([_Reporting_TOD]) AS [_reporting_tod],
+  RTRIM([_Add_on_1]) AS [_add_on_1],
+  RTRIM([_Free_add_1]) AS [_free_add_1],
+  RTRIM([_Free_add_2]) AS [_free_add_2],
+  RTRIM([_Free_add_3]) AS [_free_add_3],
+  RTRIM([_Free_add_4]) AS [_free_add_4],
+  RTRIM([_Free_add_5]) AS [_free_add_5],
+  RTRIM([Add_on_1]) AS [add_on_1],
+  RTRIM([Add_on_2]) AS [add_on_2],
+  RTRIM([Add_on_3]) AS [add_on_3],
+  RTRIM([Add_on_4]) AS [add_on_4],
+  RTRIM([Add_on_5]) AS [add_on_5],
+  [_PCR] AS [_pcr],
+  RTRIM([_Hanger_16]) AS [_hanger_16],
+  RTRIM([_Hanger_18]) AS [_hanger_18],
+  RTRIM([_Hanger_20]) AS [_hanger_20],
+  RTRIM([_Hanger_22]) AS [_hanger_22],
+  RTRIM([_Pedestal]) AS [_pedestal],
+  RTRIM([_Self_Watering_Disc]) AS [_self_watering_disc],
+  [_Tag_Slot] AS [_tag_slot],
+  RTRIM([_Water_Disc]) AS [_water_disc],
+  RTRIM([_Web_Image]) AS [_web_image],
+  RTRIM([_Web_Product_Type]) AS [_web_product_type],
+  RTRIM([_Product_Tier]) AS [_product_tier],
+  RTRIM([_Product_Tier_Exclusive]) AS [_product_tier_exclusive],
+  RTRIM([_Production_Review]) AS [_production_review],
+  RTRIM([_Segment]) AS [_segment]
+FROM [GPSERVER].[CHG].[dbo].[spxItemMaster]

config/modules/sy40100.sql

@@ -16,4 +16,4 @@ SELECT
   [PERDENDT] AS [perdendt],
   [DEX_ROW_TS] AS [dex_row_ts],
   [DEX_ROW_ID] AS [dex_row_id]
-FROM [GPSERVER].[CHG].[dbo].[SY40100]
+FROM [usavmsql01].[CHG].[dbo].[SY40100]