Add the CMS AP subledger modules (avtx, vchr, open)

Completes the AP source layer: GP was covered by the pm* modules, but the
CMS side had only cms.vend. These three are what
SQL/fiscal/analysis/open_ap_aging.db2.sql actually joins.

  avtx  966,553  A/P voucher transaction events   incremental on AVTSTM
  vchr  792,348  vouchers entered, period to date full
  open  538,544  open payables; FHCBAL is live    full

AVTX is the artrn analog -- the per-event apply detail. It matters
because the AR aging in /opt/clean reconstructs balances from
application events rather than a single settle_date, so AP needs an
applications fact too, not just documents.

Grains verified exactly unique before drafting: AVTX
(avtco#,avtvh#,avttx#) 966,553/966,553; VCHR
(idcom#,idvch#,idbnk#,idfisy,idfisp) 792,348/792,348; OPEN
(fhcom#,fhvch#,fhpyy,fhpper) 538,544/538,544. All three reconcile
IN SYNC.

vchr and open stay full: no change signal, only business dates, and
FHCBAL is a live mutable balance.

Two things worth knowing for the next DB2 module:

- pipekit maps DB2 TIMESTMP to Postgres text, so a watermark resolver
  doing COALESCE(MAX(ts), TIMESTAMP '...') fails on mismatched types.
  Cast explicitly. cms.gtran was already the precedent.
- Watermarks resolve at engine step 2 but --create-dest builds the
  table at step 3b, so a watermark reading its own dest table fails on
  the first run. Pre-create the table or seed with a constant.

Note LGDAT.AP* is a dead end -- APVH has 14 rows, APVD has 22. CMS AP
does not live in AP-prefixed files.

Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>

config/groups.json

@@ -1,4 +1,67 @@
 [
+  {
+    "name": "Accounts Payable",
+    "members": [
+      {
+        "module": "pm00100",
+        "run_order": 1
+      },
+      {
+        "module": "pm00300",
+        "run_order": 2
+      },
+      {
+        "module": "pm00400",
+        "run_order": 3
+      },
+      {
+        "module": "pm10100",
+        "run_order": 4
+      },
+      {
+        "module": "pm20000",
+        "run_order": 5
+      },
+      {
+        "module": "pm20100",
+        "run_order": 6
+      },
+      {
+        "module": "pm30200",
+        "run_order": 7
+      },
+      {
+        "module": "pm30300",
+        "run_order": 8
+      },
+      {
+        "module": "pm30600",
+        "run_order": 9
+      },
+      {
+        "module": "pm30700",
+        "run_order": 10
+      },
+      {
+        "module": "avtx",
+        "run_order": 11
+      },
+      {
+        "module": "vchr",
+        "run_order": 12
+      },
+      {
+        "module": "open",
+        "run_order": 13
+      }
+    ],
+    "schedules": [
+      {
+        "cron_expr": "0 1 * * *",
+        "enabled": 0
+      }
+    ]
+  },
   {
     "name": "Accounts Receivable",
     "members": [

config/modules/_custom_sales_line_connector.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": null,
+  "description": "Custom sales-line detail from Dynamics GP",
   "columns": [
     {
       "source_name": "Doctype",

config/modules/adrs.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Address Master 6.0",
+  "description": "Address Master",
   "columns": [
     {
       "source_name": "QZADR",

config/modules/armasc.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "A/R Master Codes File - Sales Codes 6.0",
+  "description": "Sales GL Account Configuration",
   "columns": [
     {
       "source_name": "ZWCODE",

config/modules/arnot.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Note pad file - 50 char key   5.3",
+  "description": "Notes on receivables",
   "columns": [
     {
       "source_name": "AUKEY",

config/modules/aroht.json

@@ -8,6 +8,7 @@
   "merge_key": "ascom#, ascust, asinv#",
   "enabled": 1,
   "dest_description": "A/R Open Receivables 6.1",
+  "description": "Accounts-receivable history (paid/closed items)",
   "columns": [
     {
       "source_name": "ASCOMP",

config/modules/arop.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "A/R Open Receivables 6.1",
+  "description": "Open accounts-receivable items",
   "columns": [
     {
       "source_name": "ASCOMP",

config/modules/artrn.json

@@ -8,6 +8,7 @@
   "merge_key": "lotnx",
   "enabled": 1,
   "dest_description": "A/R Payment Transactions 6.0",
+  "description": "Accounts-receivable payment transactions",
   "columns": [
     {
       "source_name": "LOCOMP",

config/modules/avtx.json

@@ -0,0 +1,268 @@
+{
+  "name": "avtx",
+  "source_connection": "S78030956",
+  "dest_connection": "usmidsap02",
+  "dest_table": "cms.avtx",
+  "staging_table": "pipekit_staging.avtx",
+  "merge_strategy": "incremental",
+  "merge_key": "avtco#, avtvh#, avttx#",
+  "enabled": 1,
+  "dest_description": "CMS A/P voucher transaction events (payments, discounts, adjustments)",
+  "description": "CMS A/P voucher transaction events (payments, discounts, adjustments)",
+  "columns": [
+    {
+      "source_name": "AVTCO#",
+      "source_type": "NUMERIC(2,0)",
+      "dest_name": "avtco#",
+      "dest_type": "numeric(2,0)",
+      "description": "Company Number"
+    },
+    {
+      "source_name": "AVTVH#",
+      "source_type": "NUMERIC(6,0)",
+      "dest_name": "avtvh#",
+      "dest_type": "numeric(6,0)",
+      "description": "Voucher'Number"
+    },
+    {
+      "source_name": "AVTTX#",
+      "source_type": "NUMERIC(9,0)",
+      "dest_name": "avttx#",
+      "dest_type": "numeric(9,0)",
+      "description": "Transaction'Number"
+    },
+    {
+      "source_name": "AVTTDT",
+      "source_type": "DATE",
+      "dest_name": "avttdt",
+      "dest_type": "date",
+      "description": "Transaction Date"
+    },
+    {
+      "source_name": "AVTTYP",
+      "source_type": "CHAR(2)",
+      "dest_name": "avttyp",
+      "dest_type": "text",
+      "description": "Transaction Type"
+    },
+    {
+      "source_name": "AVT1099",
+      "source_type": "CHAR(1)",
+      "dest_name": "avt1099",
+      "dest_type": "text",
+      "description": "1099 Applicable"
+    },
+    {
+      "source_name": "AVTSTM",
+      "source_type": "TIMESTMP",
+      "dest_name": "avtstm",
+      "dest_type": "text",
+      "description": "Actual Time Stamp"
+    },
+    {
+      "source_name": "AVTFIS",
+      "source_type": "NUMERIC(6,0)",
+      "dest_name": "avtfis",
+      "dest_type": "numeric(6,0)",
+      "description": "Fiscal Period"
+    },
+    {
+      "source_name": "AVTAMT",
+      "source_type": "NUMERIC(11,2)",
+      "dest_name": "avtamt",
+      "dest_type": "numeric(11,2)",
+      "description": "Cheque Paid Amount"
+    },
+    {
+      "source_name": "AVTCCD",
+      "source_type": "CHAR(3)",
+      "dest_name": "avtccd",
+      "dest_type": "text",
+      "description": "Currency Code"
+    },
+    {
+      "source_name": "AVTVAM",
+      "source_type": "NUMERIC(11,2)",
+      "dest_name": "avtvam",
+      "dest_type": "numeric(11,2)",
+      "description": "Amount in Voucher Curr"
+    },
+    {
+      "source_name": "AVTVCC",
+      "source_type": "CHAR(3)",
+      "dest_name": "avtvcc",
+      "dest_type": "text",
+      "description": "Voucher Currency"
+    },
+    {
+      "source_name": "AVTDIS",
+      "source_type": "NUMERIC(11,2)",
+      "dest_name": "avtdis",
+      "dest_type": "numeric(11,2)",
+      "description": "Discount Taken"
+    },
+    {
+      "source_name": "AVTEXC",
+      "source_type": "NUMERIC(11,6)",
+      "dest_name": "avtexc",
+      "dest_type": "numeric(11,6)",
+      "description": "Exchange Rate Voucher Currency"
+    },
+    {
+      "source_name": "AVTCHC",
+      "source_type": "NUMERIC(2,0)",
+      "dest_name": "avtchc",
+      "dest_type": "numeric(2,0)",
+      "description": "Cheque Company"
+    },
+    {
+      "source_name": "AVTCHB",
+      "source_type": "CHAR(3)",
+      "dest_name": "avtchb",
+      "dest_type": "text",
+      "description": "Cheque Bank Code"
+    },
+    {
+      "source_name": "AVTCHQ",
+      "source_type": "NUMERIC(8,0)",
+      "dest_name": "avtchq",
+      "dest_type": "numeric(8,0)",
+      "description": "Cheque Number"
+    },
+    {
+      "source_name": "AVTEFT",
+      "source_type": "CHAR(20)",
+      "dest_name": "avteft",
+      "dest_type": "text",
+      "description": "EFT #"
+    },
+    {
+      "source_name": "AVTOBL",
+      "source_type": "NUMERIC(11,2)",
+      "dest_name": "avtobl",
+      "dest_type": "numeric(11,2)",
+      "description": "New Balance"
+    },
+    {
+      "source_name": "AVTUSR",
+      "source_type": "CHAR(10)",
+      "dest_name": "avtusr",
+      "dest_type": "text",
+      "description": "User ID"
+    },
+    {
+      "source_name": "AVTEXCP",
+      "source_type": "NUMERIC(11,6)",
+      "dest_name": "avtexcp",
+      "dest_type": "numeric(11,6)",
+      "description": "Exchange Rate Cheque Currency"
+    },
+    {
+      "source_name": "AVTHQEXCP",
+      "source_type": "NUMERIC(11,6)",
+      "dest_name": "avthqexcp",
+      "dest_type": "numeric(11,6)",
+      "description": "HQ Exchange Rate Cheque Currency"
+    },
+    {
+      "source_name": "AVTEXCM",
+      "source_type": "NUMERIC(11,6)",
+      "dest_name": "avtexcm",
+      "dest_type": "numeric(11,6)",
+      "description": "Man. Cheq. Exc. Rate Entered"
+    },
+    {
+      "source_name": "AVTOEX",
+      "source_type": "NUMERIC(11,6)",
+      "dest_name": "avtoex",
+      "dest_type": "numeric(11,6)",
+      "description": "Overridden Exchange Rate"
+    },
+    {
+      "source_name": "AVTIRDT",
+      "source_type": "DATE",
+      "dest_name": "avtirdt",
+      "dest_type": "date",
+      "description": "Invoice Received Date"
+    },
+    {
+      "source_name": "AVTDSNT",
+      "source_type": "NUMERIC(9,2)",
+      "dest_name": "avtdsnt",
+      "dest_type": "numeric(9,2)",
+      "description": "Net Discount Amount"
+    },
+    {
+      "source_name": "AVTGSTD",
+      "source_type": "NUMERIC(9,2)",
+      "dest_name": "avtgstd",
+      "dest_type": "numeric(9,2)",
+      "description": "Recoverable Discount Amount"
+    },
+    {
+      "source_name": "AVTFUT1",
+      "source_type": "CHAR(1)",
+      "dest_name": "avtfut1",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "AVTFUT2",
+      "source_type": "CHAR(1)",
+      "dest_name": "avtfut2",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "AVTFUT3",
+      "source_type": "NUMERIC(15,5)",
+      "dest_name": "avtfut3",
+      "dest_type": "numeric(15,5)",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "AVTFUT4",
+      "source_type": "NUMERIC(15,5)",
+      "dest_name": "avtfut4",
+      "dest_type": "numeric(15,5)",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "AVTFUT5",
+      "source_type": "CHAR(10)",
+      "dest_name": "avtfut5",
+      "dest_type": "text",
+      "description": "User-Defined Date"
+    },
+    {
+      "source_name": "AVTFUT6",
+      "source_type": "CHAR(10)",
+      "dest_name": "avtfut6",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "AVTFUT7",
+      "source_type": "CHAR(20)",
+      "dest_name": "avtfut7",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "AVTFUT8",
+      "source_type": "CHAR(20)",
+      "dest_name": "avtfut8",
+      "dest_type": "text",
+      "description": "Future Use"
+    }
+  ],
+  "watermarks": [
+    {
+      "name": "avtx_wm",
+      "connection": "usmidsap02",
+      "resolver_sql": "SELECT COALESCE(MAX(avtstm)::timestamp - INTERVAL '7 days', TIMESTAMP '1900-01-01')::text FROM cms.avtx",
+      "default_value": "1900-01-01 00:00:00.000000"
+    }
+  ],
+  "hooks": []
+}

config/modules/avtx.sql

@@ -0,0 +1,38 @@
+SELECT
+  "AVTCO#" AS avtco#,
+  "AVTVH#" AS avtvh#,
+  "AVTTX#" AS avttx#,
+  CASE WHEN AVTTDT IN (DATE('0001-01-01'), DATE('9999-12-31')) THEN NULL ELSE AVTTDT END AS avttdt,
+  RTRIM(AVTTYP) AS avttyp,
+  RTRIM(AVT1099) AS avt1099,
+  AVTSTM AS avtstm,
+  AVTFIS AS avtfis,
+  AVTAMT AS avtamt,
+  RTRIM(AVTCCD) AS avtccd,
+  AVTVAM AS avtvam,
+  RTRIM(AVTVCC) AS avtvcc,
+  AVTDIS AS avtdis,
+  AVTEXC AS avtexc,
+  AVTCHC AS avtchc,
+  RTRIM(AVTCHB) AS avtchb,
+  AVTCHQ AS avtchq,
+  RTRIM(AVTEFT) AS avteft,
+  AVTOBL AS avtobl,
+  RTRIM(AVTUSR) AS avtusr,
+  AVTEXCP AS avtexcp,
+  AVTHQEXCP AS avthqexcp,
+  AVTEXCM AS avtexcm,
+  AVTOEX AS avtoex,
+  CASE WHEN AVTIRDT IN (DATE('0001-01-01'), DATE('9999-12-31')) THEN NULL ELSE AVTIRDT END AS avtirdt,
+  AVTDSNT AS avtdsnt,
+  AVTGSTD AS avtgstd,
+  RTRIM(AVTFUT1) AS avtfut1,
+  RTRIM(AVTFUT2) AS avtfut2,
+  AVTFUT3 AS avtfut3,
+  AVTFUT4 AS avtfut4,
+  RTRIM(AVTFUT5) AS avtfut5,
+  RTRIM(AVTFUT6) AS avtfut6,
+  RTRIM(AVTFUT7) AS avtfut7,
+  RTRIM(AVTFUT8) AS avtfut8
+FROM LGDAT.AVTX
+WHERE AVTSTM > '{avtx_wm}'

config/modules/binb.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Bin Balances 6.0",
+  "description": "Inventory bin balances",
   "columns": [
     {
       "source_name": "LQSTKL",

config/modules/bold.json

@@ -8,6 +8,7 @@
   "merge_key": "fgbol#",
   "enabled": 1,
   "dest_description": "Bill of Lading Detail 6.1",
+  "description": "Bill-of-lading detail lines",
   "columns": [
     {
       "source_name": "FGBOL#",

config/modules/bolh.json

@@ -8,6 +8,7 @@
   "merge_key": "febol#",
   "enabled": 1,
   "dest_description": "Bill of Lading Header 6.1",
+  "description": "Bill-of-lading headers",
   "columns": [
     {
       "source_name": "FEBOL#",

config/modules/cjobdr.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Current Job Routing Details 6.1",
+  "description": "Current Work Order Routings",
   "columns": [
     {
       "source_name": "EDTYPE",

config/modules/cjobh.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Current Job Header (Work orders) 6.1",
+  "description": "Current Work Order Header",
   "columns": [
     {
       "source_name": "DNJOB",

config/modules/coa_map.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": null,
+  "description": "Chart-of-accounts mapping",
   "columns": [
     {
       "source_name": "Entity",

config/modules/code.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "System Codes Master 6.1",
+  "description": "Code/lookup reference values",
   "columns": [
     {
       "source_name": "A2",

config/modules/color.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "color descriptions",
+  "description": "Color Codes",
   "columns": [
     {
       "source_name": "COLCODE",

config/modules/colorb.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Used in UPDblendr",
+  "description": "Colorant Resin Codes",
   "columns": [
     {
       "source_name": "CLPLNT",

config/modules/colortier.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Color Tier",
+  "description": "Color Tiers",
   "columns": [
     {
       "source_name": "CLTIER",

config/modules/cret.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Currency Exchange Master   6.0",
+  "description": "Currency Translation",
   "columns": [
     {
       "source_name": "B86COMN",

config/modules/cust.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Customer Master File 6.0",
+  "description": "Customer master",
   "columns": [
     {
       "source_name": "BVCOMP",

config/modules/depts.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Department Master File 6.1",
+  "description": "Production Departments and Burden Rates",
   "columns": [
     {
       "source_name": "AADEPT",

config/modules/dsdisc.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Discount codes file 6.0",
+  "description": "Discount schedule",
   "columns": [
     {
       "source_name": "FADISC",

config/modules/ffcret.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Master Data - currency translation rates",
+  "description": "Customer credit/return records",
   "columns": [
     {
       "source_name": "FCUR",

config/modules/ffpdglr1.json

@@ -8,6 +8,7 @@
   "merge_key": "btid",
   "enabled": 1,
   "dest_description": "",
+  "description": "Rebuild of Production Posting GL",
   "columns": [
     {
       "source_name": "SRCE",

config/modules/ffsbglr1.json

@@ -8,6 +8,7 @@
   "merge_key": "perd",
   "enabled": 1,
   "dest_description": "FFSBGLR1",
+  "description": "GL subledger detail - offline combination of subledgers",
   "columns": [
     {
       "source_name": "MODULE",

config/modules/fgrp.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Financial Statement account groups 6.0",
+  "description": "Reference/group codes",
   "columns": [
     {
       "source_name": "BQ1COMP",

config/modules/fresre.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Resource equipment Master-Future costs 6.1",
+  "description": "Future Resource Master",
   "columns": [
     {
       "source_name": "R9DEPT",

config/modules/ftcstm.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Future Inventory Cost - manufactured 6.0",
+  "description": "Future Cost - Manufactured",
   "columns": [
     {
       "source_name": "CNPART",

config/modules/ftcstp.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Future Inventory Cost - Purchased Parts 6.0",
+  "description": "Future Cost - Purchased",
   "columns": [
     {
       "source_name": "COPART",

config/modules/ftcstr.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Future Cost Master - Transferred Parts 6.0",
+  "description": "Future Cost - Transfered",
   "columns": [
     {
       "source_name": "Y3PART",

config/modules/ggtp.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "G/L Category Code 5.3",
+  "description": "Reference codes",
   "columns": [
     {
       "source_name": "D35GCDE",

config/modules/gl00100.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": null,
+  "description": "Dynamics GP GL account master",
   "columns": [
     {
       "source_name": "ACTINDX",

config/modules/gl00105.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Dynamics GP account index master",
+  "description": "Dynamics GP account index master",
   "columns": [
     {
       "source_name": "ACTINDX",

config/modules/gl10110.json

@@ -8,6 +8,7 @@
   "merge_key": "dex_row_id",
   "enabled": 1,
   "dest_description": null,
+  "description": "Dynamics GP analytical accounting balances",
   "columns": [
     {
       "source_name": "ACTINDX",

config/modules/gl10111.json

@@ -8,6 +8,7 @@
   "merge_key": "dex_row_id",
   "enabled": 1,
   "dest_description": null,
+  "description": "Dynamics GP analytical accounting detail",
   "columns": [
     {
       "source_name": "ACTINDX",

config/modules/gl20000.json

@@ -8,6 +8,7 @@
   "merge_key": "dex_row_id",
   "enabled": 1,
   "dest_description": null,
+  "description": "Dynamics GP open-year GL transactions",
   "columns": [
     {
       "source_name": "OPENYEAR",

config/modules/gl30000.json

@@ -8,6 +8,7 @@
   "merge_key": "dex_row_id",
   "enabled": 1,
   "dest_description": null,
+  "description": "Dynamics GP historical-year GL transactions",
   "columns": [
     {
       "source_name": "HSTYEAR",

config/modules/glca.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "G/L Consolidation Subsidiary Companies 6.0",
+  "description": "Company Hierarchy",
   "columns": [
     {
       "source_name": "DW6COMN",

config/modules/glcc.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "G/L Consolidation Parent Companies 6.0",
+  "description": "Consolidation Companies",
   "columns": [
     {
       "source_name": "DW5COMN",

config/modules/gldate.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "G/L Period End Dates 6.0",
+  "description": "GL date / fiscal calendar",
   "columns": [
     {
       "source_name": "KPCOMP",

config/modules/gldatref.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "G/L Period Dates Reference File 6.0",
+  "description": "GL date reference / fiscal-period map",
   "columns": [
     {
       "source_name": "N1COMP",

config/modules/glie.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "G/L Inventory Expense Accounts 6.1",
+  "description": "Inventory GL Account Code Configuration",
   "columns": [
     {
       "source_name": "Y1PLNT",

config/modules/glmt.json

@@ -8,6 +8,7 @@
   "merge_key": "aj4ccyy",
   "enabled": 1,
   "dest_description": "G/L Chart of Accounts totals for year 6.0",
+  "description": "GL master/summary balances; reconciles to GL transaction detail by account/period/year",
   "columns": [
     {
       "source_name": "AJ4COMP",

config/modules/gtran.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "G/L Transactions 6.1",
+  "description": "GL transaction detail",
   "columns": [
     {
       "source_name": "DKACC#",

config/modules/icstm.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Inventory Costs - Manufactured parts 6.1",
+  "description": "Current Standard Cost - Manufactured",
   "columns": [
     {
       "source_name": "CGPART",

config/modules/icstp.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Inventory Cost Master - Purchased Parts 6.1",
+  "description": "Current Standard Cost - Purchased",
   "columns": [
     {
       "source_name": "CHPART",

config/modules/icstr.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Inventory Cost Master-Transferred Parts6.1",
+  "description": "Current Standard Cost - Transfered",
   "columns": [
     {
       "source_name": "Y0PART",

config/modules/icstt.json

@@ -8,6 +8,7 @@
   "merge_key": "jhdate",
   "enabled": 1,
   "dest_description": "Inventory Cost Transaction Log 6.0",
+  "description": "Cost History",
   "columns": [
     {
       "source_name": "JHPART",

config/modules/iprca.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Pricing - Price List Code Description 6.1",
+  "description": "Price List Codes",
   "columns": [
     {
       "source_name": "JAPLCD",

config/modules/iprcb.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Pricing - PriceLlist Assignment",
+  "description": "Customer Price List Association",
   "columns": [
     {
       "source_name": "JBTYPE",

config/modules/iprcbhc.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "HC Modified Price List Assignment",
+  "description": "Customer Price Level Association",
   "columns": [
     {
       "source_name": "JBPLVL",

config/modules/iprcc.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Price list file 6.0",
+  "description": "Price List Prices",
   "columns": [
     {
       "source_name": "JCPLCD",

config/modules/iprcct.json

@@ -8,6 +8,7 @@
   "merge_key": "tadate",
   "enabled": 1,
   "dest_description": "Price List Trans Log Headers 6.0",
+  "description": "Price List Change Log",
   "columns": [
     {
       "source_name": "TAPLCD",

config/modules/iprcctn.json

@@ -8,6 +8,7 @@
   "merge_key": "t8date",
   "enabled": 1,
   "dest_description": "Price List Trans New Price Detail 6.0",
+  "description": "Price List Change Log - New Prices",
   "columns": [
     {
       "source_name": "T8PLCD",

config/modules/iprccto.json

@@ -8,6 +8,7 @@
   "merge_key": "t7date",
   "enabled": 1,
   "dest_description": "Price List Old Price Details 6.0",
+  "description": "Price List Change Log - Old Prices",
   "columns": [
     {
       "source_name": "T7PLCD",

config/modules/irea.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Inactive Reason Master File",
+  "description": "Inactive Reason Code Master",
   "columns": [
     {
       "source_name": "WETYPE",

config/modules/itemm.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "ITEMM",
+  "description": "Item master; compiled on the AS/400 from UQF, so uqf must sync first",
   "columns": [
     {
       "source_name": "ITEM",

config/modules/iv00101.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "GP customer/salesperson/item master (broadened, migrated from /opt/sync 2026-07-21)",
+  "description": "Dynamics GP item master",
   "columns": [
     {
       "source_name": "ITEMNMBR",

config/modules/iv00102.json

@@ -8,6 +8,7 @@
   "merge_key": "dex_row_id",
   "enabled": 1,
   "dest_description": null,
+  "description": "Dynamics GP item quantity/inventory master",
   "columns": [
     {
       "source_name": "ITEMNMBR",

config/modules/live_quotes.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": null,
+  "description": "Live price quotes",
   "columns": [
     {
       "source_name": "qid",

config/modules/macgrp.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Machine Group File",
+  "description": "Machine Group Master",
   "columns": [
     {
       "source_name": "ADMACG",

config/modules/majg.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Major Group Codes 6.0",
+  "description": "Major Group",
   "columns": [
     {
       "source_name": "BQGRP",

config/modules/marktable.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Marketing Product Specs File",
+  "description": "Markup/pricing table",
   "columns": [
     {
       "source_name": "M1PROD",

config/modules/mast.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "G/L Chart of Accounts header 6.1",
+  "description": "Item/material master",
   "columns": [
     {
       "source_name": "AZCOMP",

config/modules/mc00200.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Dynamics GP multicurrency account setup",
+  "description": "Dynamics GP multicurrency account setup",
   "columns": [
     {
       "source_name": "ACTINDX",

config/modules/methdm.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Method Detail - Material (M-Record) 6.0",
+  "description": "Bill of Materials",
   "columns": [
     {
       "source_name": "AQTYPE",

config/modules/methdo.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Method Detail-Outside Service (O-Record)6.0",
+  "description": "Outsource Routings",
   "columns": [
     {
       "source_name": "APTYPE",

config/modules/methdr.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Method Detail - Routings (R-Record) 6.1",
+  "description": "Machine Routings",
   "columns": [
     {
       "source_name": "AOTYPE",

config/modules/methh.json

@@ -8,6 +8,7 @@
   "merge_key": "anpart, anplnt",
   "enabled": 1,
   "dest_description": "Method Header File 6.0",
+  "description": "Method Header",
   "columns": [
     {
       "source_name": "ANPART",

config/modules/mkptgroup.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Marketing Part Group",
+  "description": "Market/pricing groups",
   "columns": [
     {
       "source_name": "MAPGROUP",

config/modules/mmgp.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Minor Group Codes 6.0",
+  "description": "Minor Group Codes",
   "columns": [
     {
       "source_name": "BRMGRP",

config/modules/mmsl.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Sales Codes Master 6.0",
+  "description": "Major and Minor Sales Group Codes",
   "columns": [
     {
       "source_name": "BSMJCD",

config/modules/moldmast.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Mold Master File",
+  "description": "Mold master",
   "columns": [
     {
       "source_name": "MMMOLD",

config/modules/name.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "G/L Master Codes File 6.0",
+  "description": "Name/address records",
   "columns": [
     {
       "source_name": "A7",

config/modules/ocrh.json

@@ -8,6 +8,7 @@
   "merge_key": "dcord#",
   "enabled": 1,
   "dest_description": "Customer Order Header 6.1",
+  "description": "Customer order/quote headers",
   "columns": [
     {
       "source_name": "DCORD#",

config/modules/ocri.json

@@ -8,6 +8,7 @@
   "merge_key": "ddord#",
   "enabled": 1,
   "dest_description": "Customer Order Item 6.1",
+  "description": "Order detail-item lines",
   "columns": [
     {
       "source_name": "DDORD#",

config/modules/ocrs.json

@@ -8,6 +8,7 @@
   "merge_key": "fford#",
   "enabled": 1,
   "dest_description": "Order Discounts/Charges 6.0",
+  "description": "Order Discounts/Charges",
   "columns": [
     {
       "source_name": "FFORD#",

config/modules/oid.json

@@ -8,6 +8,7 @@
   "merge_key": "diinv#",
   "enabled": 1,
   "dest_description": "Invoice detail file        6.1",
+  "description": "Invoice detail lines",
   "columns": [
     {
       "source_name": "DIINV#",

config/modules/oih.json

@@ -8,6 +8,7 @@
   "merge_key": "dhinv#",
   "enabled": 1,
   "dest_description": "Invoice Header File 6.1",
+  "description": "Invoice headers",
   "columns": [
     {
       "source_name": "DHINV#",

config/modules/ois.json

@@ -8,6 +8,7 @@
   "merge_key": "flinv#",
   "enabled": 1,
   "dest_description": "Invoice detail discount/charge 6.0",
+  "description": "Invoice detail discount/charge",
   "columns": [
     {
       "source_name": "FLINV#",

config/modules/opcode.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Method Operation Codes 6.1",
+  "description": "Operation Code Master",
   "columns": [
     {
       "source_name": "AECODE",

config/modules/open.json

@@ -0,0 +1,485 @@
+{
+  "name": "open",
+  "source_connection": "S78030956",
+  "dest_connection": "usmidsap02",
+  "dest_table": "cms.open",
+  "staging_table": "pipekit_staging.open",
+  "merge_strategy": "full",
+  "merge_key": null,
+  "enabled": 1,
+  "dest_description": "CMS A/P open payables; FHCBAL is the live voucher balance",
+  "description": "CMS A/P open payables; FHCBAL is the live voucher balance",
+  "columns": [
+    {
+      "source_name": "FHCOM#",
+      "source_type": "NUMERIC(2,0)",
+      "dest_name": "fhcom#",
+      "dest_type": "numeric(2,0)",
+      "description": "Company Number"
+    },
+    {
+      "source_name": "FHBANK",
+      "source_type": "CHAR(3)",
+      "dest_name": "fhbank",
+      "dest_type": "text",
+      "description": "Pay. Bank Code"
+    },
+    {
+      "source_name": "FHVCH#",
+      "source_type": "NUMERIC(6,0)",
+      "dest_name": "fhvch#",
+      "dest_type": "numeric(6,0)",
+      "description": "Voucher Number"
+    },
+    {
+      "source_name": "FHPYY",
+      "source_type": "NUMERIC(2,0)",
+      "dest_name": "fhpyy",
+      "dest_type": "numeric(2,0)",
+      "description": "Fiscal Year"
+    },
+    {
+      "source_name": "FHPPER",
+      "source_type": "NUMERIC(2,0)",
+      "dest_name": "fhpper",
+      "dest_type": "numeric(2,0)",
+      "description": "Fiscal Period"
+    },
+    {
+      "source_name": "FHHSTS",
+      "source_type": "CHAR(1)",
+      "dest_name": "fhhsts",
+      "dest_type": "text",
+      "description": "Old Hold"
+    },
+    {
+      "source_name": "FHINV#",
+      "source_type": "CHAR(20)",
+      "dest_name": "fhinv#",
+      "dest_type": "text",
+      "description": "Invoice Number"
+    },
+    {
+      "source_name": "FHIDTE",
+      "source_type": "CHAR(6)",
+      "dest_name": "fhidte",
+      "dest_type": "text",
+      "description": "NOT USED"
+    },
+    {
+      "source_name": "FHDDTE",
+      "source_type": "CHAR(6)",
+      "dest_name": "fhddte",
+      "dest_type": "text",
+      "description": "NOT USED"
+    },
+    {
+      "source_name": "FHCHQ#",
+      "source_type": "NUMERIC(8,0)",
+      "dest_name": "fhchq#",
+      "dest_type": "numeric(8,0)",
+      "description": "Manual Cheque #"
+    },
+    {
+      "source_name": "FHMDTE",
+      "source_type": "CHAR(6)",
+      "dest_name": "fhmdte",
+      "dest_type": "text",
+      "description": "Closing Period"
+    },
+    {
+      "source_name": "FHA1",
+      "source_type": "CHAR(1)",
+      "dest_name": "fha1",
+      "dest_type": "text",
+      "description": "Work Field DO NOT USE"
+    },
+    {
+      "source_name": "FHANU",
+      "source_type": "CHAR(4)",
+      "dest_name": "fhanu",
+      "dest_type": "text",
+      "description": "NOT USED"
+    },
+    {
+      "source_name": "FHGRS",
+      "source_type": "DECIMAL(11,2)",
+      "dest_name": "fhgrs",
+      "dest_type": "numeric(11,2)",
+      "description": "Gross Amount"
+    },
+    {
+      "source_name": "FHDIS",
+      "source_type": "DECIMAL(9,2)",
+      "dest_name": "fhdis",
+      "dest_type": "numeric(9,2)",
+      "description": "Discount Amount"
+    },
+    {
+      "source_name": "FHPCOD",
+      "source_type": "CHAR(1)",
+      "dest_name": "fhpcod",
+      "dest_type": "text",
+      "description": "Pay Code"
+    },
+    {
+      "source_name": "FHVCLS",
+      "source_type": "CHAR(1)",
+      "dest_name": "fhvcls",
+      "dest_type": "text",
+      "description": "Vendor Class"
+    },
+    {
+      "source_name": "FHDSDT",
+      "source_type": "CHAR(6)",
+      "dest_name": "fhdsdt",
+      "dest_type": "text",
+      "description": "NOT USED"
+    },
+    {
+      "source_name": "FHA4",
+      "source_type": "CHAR(4)",
+      "dest_name": "fha4",
+      "dest_type": "text",
+      "description": "NOT USED"
+    },
+    {
+      "source_name": "FHPTD",
+      "source_type": "DECIMAL(11,2)",
+      "dest_name": "fhptd",
+      "dest_type": "numeric(11,2)",
+      "description": "Paid to Date"
+    },
+    {
+      "source_name": "FHPTD2",
+      "source_type": "DECIMAL(11,2)",
+      "dest_name": "fhptd2",
+      "dest_type": "numeric(11,2)",
+      "description": "Not Used"
+    },
+    {
+      "source_name": "FHPIND",
+      "source_type": "CHAR(1)",
+      "dest_name": "fhpind",
+      "dest_type": "text",
+      "description": "Not Used"
+    },
+    {
+      "source_name": "FHDSCD",
+      "source_type": "CHAR(1)",
+      "dest_name": "fhdscd",
+      "dest_type": "text",
+      "description": "Take Discount Flag"
+    },
+    {
+      "source_name": "FHA3",
+      "source_type": "CHAR(3)",
+      "dest_name": "fha3",
+      "dest_type": "text",
+      "description": "NOT USED"
+    },
+    {
+      "source_name": "FHVDES",
+      "source_type": "CHAR(20)",
+      "dest_name": "fhvdes",
+      "dest_type": "text",
+      "description": "Voucher Description"
+    },
+    {
+      "source_name": "FHPAY",
+      "source_type": "DECIMAL(11,2)",
+      "dest_name": "fhpay",
+      "dest_type": "numeric(11,2)",
+      "description": "Pay Amount"
+    },
+    {
+      "source_name": "FHVEN#",
+      "source_type": "CHAR(10)",
+      "dest_name": "fhven#",
+      "dest_type": "text",
+      "description": "Vendor Code"
+    },
+    {
+      "source_name": "FHGSTA",
+      "source_type": "NUMERIC(11,2)",
+      "dest_name": "fhgsta",
+      "dest_type": "numeric(11,2)",
+      "description": "GST Amount"
+    },
+    {
+      "source_name": "FHGSTX",
+      "source_type": "NUMERIC(11,2)",
+      "dest_name": "fhgstx",
+      "dest_type": "numeric(11,2)",
+      "description": "GST Exempt Amount"
+    },
+    {
+      "source_name": "FHADR#",
+      "source_type": "NUMERIC(8,0)",
+      "dest_name": "fhadr#",
+      "dest_type": "numeric(8,0)",
+      "description": "OneTime Vendor#"
+    },
+    {
+      "source_name": "FHIDAT",
+      "source_type": "DATE",
+      "dest_name": "fhidat",
+      "dest_type": "date",
+      "description": "Invoice Date"
+    },
+    {
+      "source_name": "FHDDAT",
+      "source_type": "DATE",
+      "dest_name": "fhddat",
+      "dest_type": "date",
+      "description": "Due Date"
+    },
+    {
+      "source_name": "FHMDAT",
+      "source_type": "DATE",
+      "dest_name": "fhmdat",
+      "dest_type": "date",
+      "description": "Manual Cheque Date"
+    },
+    {
+      "source_name": "FHSDAT",
+      "source_type": "DATE",
+      "dest_name": "fhsdat",
+      "dest_type": "date",
+      "description": "Discount Date"
+    },
+    {
+      "source_name": "FHPRJ#",
+      "source_type": "CHAR(20)",
+      "dest_name": "fhprj#",
+      "dest_type": "text",
+      "description": "Project Number"
+    },
+    {
+      "source_name": "FHCURR",
+      "source_type": "CHAR(2)",
+      "dest_name": "fhcurr",
+      "dest_type": "text",
+      "description": "Pay. Curr Code"
+    },
+    {
+      "source_name": "FHAMTP",
+      "source_type": "NUMERIC(11,2)",
+      "dest_name": "fhamtp",
+      "dest_type": "numeric(11,2)",
+      "description": "Amt in Payment Currency"
+    },
+    {
+      "source_name": "FHVBKC",
+      "source_type": "CHAR(3)",
+      "dest_name": "fhvbkc",
+      "dest_type": "text",
+      "description": "Vendor Bank Code"
+    },
+    {
+      "source_name": "FHHQCN",
+      "source_type": "NUMERIC(2,0)",
+      "dest_name": "fhhqcn",
+      "dest_type": "numeric(2,0)",
+      "description": "HQ Company Number"
+    },
+    {
+      "source_name": "FHHQBC",
+      "source_type": "CHAR(3)",
+      "dest_name": "fhhqbc",
+      "dest_type": "text",
+      "description": "HQ Bank Code"
+    },
+    {
+      "source_name": "FHCBAL",
+      "source_type": "NUMERIC(11,2)",
+      "dest_name": "fhcbal",
+      "dest_type": "numeric(11,2)",
+      "description": "Current Balance"
+    },
+    {
+      "source_name": "FHSTSC",
+      "source_type": "CHAR(1)",
+      "dest_name": "fhstsc",
+      "dest_type": "text",
+      "description": "Status of Voucher"
+    },
+    {
+      "source_name": "FHSTSK",
+      "source_type": "CHAR(1)",
+      "dest_name": "fhstsk",
+      "dest_type": "text",
+      "description": "Status Key"
+    },
+    {
+      "source_name": "FHFUT1",
+      "source_type": "CHAR(1)",
+      "dest_name": "fhfut1",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "FHFUT2",
+      "source_type": "CHAR(1)",
+      "dest_name": "fhfut2",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "FHFUT3",
+      "source_type": "CHAR(1)",
+      "dest_name": "fhfut3",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "FHFUT4",
+      "source_type": "CHAR(1)",
+      "dest_name": "fhfut4",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "FHFUT5",
+      "source_type": "CHAR(10)",
+      "dest_name": "fhfut5",
+      "dest_type": "text",
+      "description": "User-Defined Date"
+    },
+    {
+      "source_name": "FHFUT6",
+      "source_type": "CHAR(10)",
+      "dest_name": "fhfut6",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "FHFUT7",
+      "source_type": "CHAR(20)",
+      "dest_name": "fhfut7",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "FHFUT8",
+      "source_type": "NUMERIC(15,5)",
+      "dest_name": "fhfut8",
+      "dest_type": "numeric(15,5)",
+      "description": "Fiscal Century+Year"
+    },
+    {
+      "source_name": "FHFUT9",
+      "source_type": "NUMERIC(15,5)",
+      "dest_name": "fhfut9",
+      "dest_type": "numeric(15,5)",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "FHFUTA",
+      "source_type": "CHAR(3)",
+      "dest_name": "fhfuta",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "FHWTYC",
+      "source_type": "NUMERIC(9,0)",
+      "dest_name": "fhwtyc",
+      "dest_type": "numeric(9,0)",
+      "description": "Warranty Claim Number"
+    },
+    {
+      "source_name": "FHCDAT",
+      "source_type": "DATE",
+      "dest_name": "fhcdat",
+      "dest_type": "date",
+      "description": "Closing Date"
+    },
+    {
+      "source_name": "FHOEXT",
+      "source_type": "NUMERIC(11,6)",
+      "dest_name": "fhoext",
+      "dest_type": "numeric(11,6)",
+      "description": "Overridden Exchange Rate"
+    },
+    {
+      "source_name": "FHIRDT",
+      "source_type": "DATE",
+      "dest_name": "fhirdt",
+      "dest_type": "date",
+      "description": "Invoice Received Date"
+    },
+    {
+      "source_name": "FHDSNT",
+      "source_type": "NUMERIC(9,2)",
+      "dest_name": "fhdsnt",
+      "dest_type": "numeric(9,2)",
+      "description": "Net Discount Amount"
+    },
+    {
+      "source_name": "FHGSTD",
+      "source_type": "NUMERIC(9,2)",
+      "dest_name": "fhgstd",
+      "dest_type": "numeric(9,2)",
+      "description": "Recoverable Discount Amount"
+    },
+    {
+      "source_name": "FHFUTB",
+      "source_type": "NUMERIC(15,5)",
+      "dest_name": "fhfutb",
+      "dest_type": "numeric(15,5)",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "FHFUTC",
+      "source_type": "NUMERIC(15,5)",
+      "dest_name": "fhfutc",
+      "dest_type": "numeric(15,5)",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "FHFUTD",
+      "source_type": "CHAR(10)",
+      "dest_name": "fhfutd",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "FHFUTE",
+      "source_type": "CHAR(20)",
+      "dest_name": "fhfute",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "FHFUTF",
+      "source_type": "CHAR(20)",
+      "dest_name": "fhfutf",
+      "dest_type": "text",
+      "description": "Future Use"
+    },
+    {
+      "source_name": "FHMCRF",
+      "source_type": "CHAR(30)",
+      "dest_name": "fhmcrf",
+      "dest_type": "text",
+      "description": "Manual Cheque Reference Text"
+    },
+    {
+      "source_name": "FHEHCD",
+      "source_type": "CHAR(3)",
+      "dest_name": "fhehcd",
+      "dest_type": "text",
+      "description": "EDI Handling Code"
+    },
+    {
+      "source_name": "FHMISA",
+      "source_type": "NUMERIC(15,5)",
+      "dest_name": "fhmisa",
+      "dest_type": "numeric(15,5)",
+      "description": "Misc. Charge   Amount"
+    }
+  ],
+  "watermarks": [],
+  "hooks": []
+}

config/modules/open.sql

@@ -0,0 +1,69 @@
+SELECT
+  "FHCOM#" AS fhcom#,
+  RTRIM(FHBANK) AS fhbank,
+  "FHVCH#" AS fhvch#,
+  FHPYY AS fhpyy,
+  FHPPER AS fhpper,
+  RTRIM(FHHSTS) AS fhhsts,
+  RTRIM("FHINV#") AS fhinv#,
+  RTRIM(FHIDTE) AS fhidte,
+  RTRIM(FHDDTE) AS fhddte,
+  "FHCHQ#" AS fhchq#,
+  RTRIM(FHMDTE) AS fhmdte,
+  RTRIM(FHA1) AS fha1,
+  RTRIM(FHANU) AS fhanu,
+  FHGRS AS fhgrs,
+  FHDIS AS fhdis,
+  RTRIM(FHPCOD) AS fhpcod,
+  RTRIM(FHVCLS) AS fhvcls,
+  RTRIM(FHDSDT) AS fhdsdt,
+  RTRIM(FHA4) AS fha4,
+  FHPTD AS fhptd,
+  FHPTD2 AS fhptd2,
+  RTRIM(FHPIND) AS fhpind,
+  RTRIM(FHDSCD) AS fhdscd,
+  RTRIM(FHA3) AS fha3,
+  RTRIM(FHVDES) AS fhvdes,
+  FHPAY AS fhpay,
+  RTRIM("FHVEN#") AS fhven#,
+  FHGSTA AS fhgsta,
+  FHGSTX AS fhgstx,
+  "FHADR#" AS fhadr#,
+  CASE WHEN FHIDAT IN (DATE('0001-01-01'), DATE('9999-12-31')) THEN NULL ELSE FHIDAT END AS fhidat,
+  CASE WHEN FHDDAT IN (DATE('0001-01-01'), DATE('9999-12-31')) THEN NULL ELSE FHDDAT END AS fhddat,
+  CASE WHEN FHMDAT IN (DATE('0001-01-01'), DATE('9999-12-31')) THEN NULL ELSE FHMDAT END AS fhmdat,
+  CASE WHEN FHSDAT IN (DATE('0001-01-01'), DATE('9999-12-31')) THEN NULL ELSE FHSDAT END AS fhsdat,
+  RTRIM("FHPRJ#") AS fhprj#,
+  RTRIM(FHCURR) AS fhcurr,
+  FHAMTP AS fhamtp,
+  RTRIM(FHVBKC) AS fhvbkc,
+  FHHQCN AS fhhqcn,
+  RTRIM(FHHQBC) AS fhhqbc,
+  FHCBAL AS fhcbal,
+  RTRIM(FHSTSC) AS fhstsc,
+  RTRIM(FHSTSK) AS fhstsk,
+  RTRIM(FHFUT1) AS fhfut1,
+  RTRIM(FHFUT2) AS fhfut2,
+  RTRIM(FHFUT3) AS fhfut3,
+  RTRIM(FHFUT4) AS fhfut4,
+  RTRIM(FHFUT5) AS fhfut5,
+  RTRIM(FHFUT6) AS fhfut6,
+  RTRIM(FHFUT7) AS fhfut7,
+  FHFUT8 AS fhfut8,
+  FHFUT9 AS fhfut9,
+  RTRIM(FHFUTA) AS fhfuta,
+  FHWTYC AS fhwtyc,
+  CASE WHEN FHCDAT IN (DATE('0001-01-01'), DATE('9999-12-31')) THEN NULL ELSE FHCDAT END AS fhcdat,
+  FHOEXT AS fhoext,
+  CASE WHEN FHIRDT IN (DATE('0001-01-01'), DATE('9999-12-31')) THEN NULL ELSE FHIRDT END AS fhirdt,
+  FHDSNT AS fhdsnt,
+  FHGSTD AS fhgstd,
+  FHFUTB AS fhfutb,
+  FHFUTC AS fhfutc,
+  RTRIM(FHFUTD) AS fhfutd,
+  RTRIM(FHFUTE) AS fhfute,
+  RTRIM(FHFUTF) AS fhfutf,
+  RTRIM(FHMCRF) AS fhmcrf,
+  RTRIM(FHEHCD) AS fhehcd,
+  FHMISA AS fhmisa
+FROM LGDAT.OPEN

config/modules/osm_aop.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": null,
+  "description": "Annual operating plan snapshot (2027)",
   "columns": [
     {
       "source_name": "origin_system",

config/modules/osm_fc.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": null,
+  "description": "OSM forecast",
   "columns": [
     {
       "source_name": "origin_system",

config/modules/plnt.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Plant Master File 6.1",
+  "description": "Plant Code Master",
   "columns": [
     {
       "source_name": "YAPLNT",

config/modules/pm00100.json

@@ -0,0 +1,387 @@
+{
+  "name": "pm00100",
+  "source_connection": "sqlserver",
+  "dest_connection": "usmidsap02",
+  "dest_table": "gp.pm00100",
+  "staging_table": "pipekit_staging.pm00100",
+  "merge_strategy": "full",
+  "merge_key": null,
+  "enabled": 1,
+  "dest_description": "Dynamics GP payables vendor class setup",
+  "columns": [
+    {
+      "source_name": "VNDCLSID",
+      "source_type": "CHAR(11)",
+      "dest_name": "vndclsid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "VNDCLDSC",
+      "source_type": "CHAR(31)",
+      "dest_name": "vndcldsc",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "DEFLTCLS",
+      "source_type": "TINYINT",
+      "dest_name": "defltcls",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "MXIAFVND",
+      "source_type": "SMALLINT",
+      "dest_name": "mxiafvnd",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "MXINVAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "mxinvamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "WRITEOFF",
+      "source_type": "SMALLINT",
+      "dest_name": "writeoff",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "CREDTLMT",
+      "source_type": "SMALLINT",
+      "dest_name": "credtlmt",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "TEN99TYPE",
+      "source_type": "SMALLINT",
+      "dest_name": "ten99type",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "PTCSHACF",
+      "source_type": "SMALLINT",
+      "dest_name": "ptcshacf",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "MXWOFAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "mxwofamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "MINORDER",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "minorder",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "CRLMTDLR",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "crlmtdlr",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "PYMNTPRI",
+      "source_type": "CHAR(3)",
+      "dest_name": "pymntpri",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "SHIPMTHD",
+      "source_type": "CHAR(15)",
+      "dest_name": "shipmthd",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "PYMTRMID",
+      "source_type": "CHAR(21)",
+      "dest_name": "pymtrmid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "MINPYTYP",
+      "source_type": "SMALLINT",
+      "dest_name": "minpytyp",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "MINPYDLR",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "minpydlr",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "MINPYPCT",
+      "source_type": "SMALLINT",
+      "dest_name": "minpypct",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "CURNCYID",
+      "source_type": "CHAR(15)",
+      "dest_name": "curncyid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "TAXSCHID",
+      "source_type": "CHAR(15)",
+      "dest_name": "taxschid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "KPCALHST",
+      "source_type": "TINYINT",
+      "dest_name": "kpcalhst",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "KGLDSTHS",
+      "source_type": "TINYINT",
+      "dest_name": "kgldsths",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "KPERHIST",
+      "source_type": "TINYINT",
+      "dest_name": "kperhist",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "KPTRXHST",
+      "source_type": "TINYINT",
+      "dest_name": "kptrxhst",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "TRDDISCT",
+      "source_type": "SMALLINT",
+      "dest_name": "trddisct",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "USERDEF1",
+      "source_type": "CHAR(21)",
+      "dest_name": "userdef1",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "USERDEF2",
+      "source_type": "CHAR(21)",
+      "dest_name": "userdef2",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "PMAPINDX",
+      "source_type": "INT",
+      "dest_name": "pmapindx",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "PMCSHIDX",
+      "source_type": "INT",
+      "dest_name": "pmcshidx",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "PMDAVIDX",
+      "source_type": "INT",
+      "dest_name": "pmdavidx",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "PMDTKIDX",
+      "source_type": "INT",
+      "dest_name": "pmdtkidx",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "PMFINIDX",
+      "source_type": "INT",
+      "dest_name": "pmfinidx",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "PMMSCHIX",
+      "source_type": "INT",
+      "dest_name": "pmmschix",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "PMFRTIDX",
+      "source_type": "INT",
+      "dest_name": "pmfrtidx",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "PMTAXIDX",
+      "source_type": "INT",
+      "dest_name": "pmtaxidx",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "PMWRTIDX",
+      "source_type": "INT",
+      "dest_name": "pmwrtidx",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "PMPRCHIX",
+      "source_type": "INT",
+      "dest_name": "pmprchix",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "PMRTNGIX",
+      "source_type": "INT",
+      "dest_name": "pmrtngix",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "PMTDSCIX",
+      "source_type": "INT",
+      "dest_name": "pmtdscix",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "ACPURIDX",
+      "source_type": "INT",
+      "dest_name": "acpuridx",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "PURPVIDX",
+      "source_type": "INT",
+      "dest_name": "purpvidx",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "CHEKBKID",
+      "source_type": "CHAR(15)",
+      "dest_name": "chekbkid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "MODIFDT",
+      "source_type": "DATETIME",
+      "dest_name": "modifdt",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "CREATDDT",
+      "source_type": "DATETIME",
+      "dest_name": "creatddt",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "RATETPID",
+      "source_type": "CHAR(15)",
+      "dest_name": "ratetpid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Revalue_Vendor",
+      "source_type": "TINYINT",
+      "dest_name": "revalue_vendor",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "Post_Results_To",
+      "source_type": "SMALLINT",
+      "dest_name": "post_results_to",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "FREEONBOARD",
+      "source_type": "SMALLINT",
+      "dest_name": "freeonboard",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "DISGRPER",
+      "source_type": "SMALLINT",
+      "dest_name": "disgrper",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "DUEGRPER",
+      "source_type": "SMALLINT",
+      "dest_name": "duegrper",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "TaxInvRecvd",
+      "source_type": "TINYINT",
+      "dest_name": "taxinvrecvd",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "CBVAT",
+      "source_type": "TINYINT",
+      "dest_name": "cbvat",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "DEX_ROW_ID",
+      "source_type": "INT",
+      "dest_name": "dex_row_id",
+      "dest_type": "integer",
+      "description": null
+    }
+  ],
+  "watermarks": [],
+  "hooks": [],
+  "description": "Dynamics GP payables vendor class setup"
+}

config/modules/pm00100.sql

@@ -0,0 +1,55 @@
+SELECT
+  RTRIM([VNDCLSID]) AS vndclsid,
+  RTRIM([VNDCLDSC]) AS vndcldsc,
+  [DEFLTCLS] AS defltcls,
+  [MXIAFVND] AS mxiafvnd,
+  [MXINVAMT] AS mxinvamt,
+  [WRITEOFF] AS writeoff,
+  [CREDTLMT] AS credtlmt,
+  [TEN99TYPE] AS ten99type,
+  [PTCSHACF] AS ptcshacf,
+  [MXWOFAMT] AS mxwofamt,
+  [MINORDER] AS minorder,
+  [CRLMTDLR] AS crlmtdlr,
+  RTRIM([PYMNTPRI]) AS pymntpri,
+  RTRIM([SHIPMTHD]) AS shipmthd,
+  RTRIM([PYMTRMID]) AS pymtrmid,
+  [MINPYTYP] AS minpytyp,
+  [MINPYDLR] AS minpydlr,
+  [MINPYPCT] AS minpypct,
+  RTRIM([CURNCYID]) AS curncyid,
+  RTRIM([TAXSCHID]) AS taxschid,
+  [KPCALHST] AS kpcalhst,
+  [KGLDSTHS] AS kgldsths,
+  [KPERHIST] AS kperhist,
+  [KPTRXHST] AS kptrxhst,
+  [TRDDISCT] AS trddisct,
+  RTRIM([USERDEF1]) AS userdef1,
+  RTRIM([USERDEF2]) AS userdef2,
+  [PMAPINDX] AS pmapindx,
+  [PMCSHIDX] AS pmcshidx,
+  [PMDAVIDX] AS pmdavidx,
+  [PMDTKIDX] AS pmdtkidx,
+  [PMFINIDX] AS pmfinidx,
+  [PMMSCHIX] AS pmmschix,
+  [PMFRTIDX] AS pmfrtidx,
+  [PMTAXIDX] AS pmtaxidx,
+  [PMWRTIDX] AS pmwrtidx,
+  [PMPRCHIX] AS pmprchix,
+  [PMRTNGIX] AS pmrtngix,
+  [PMTDSCIX] AS pmtdscix,
+  [ACPURIDX] AS acpuridx,
+  [PURPVIDX] AS purpvidx,
+  RTRIM([CHEKBKID]) AS chekbkid,
+  [MODIFDT] AS modifdt,
+  [CREATDDT] AS creatddt,
+  RTRIM([RATETPID]) AS ratetpid,
+  [Revalue_Vendor] AS revalue_vendor,
+  [Post_Results_To] AS post_results_to,
+  [FREEONBOARD] AS freeonboard,
+  [DISGRPER] AS disgrper,
+  [DUEGRPER] AS duegrper,
+  [TaxInvRecvd] AS taxinvrecvd,
+  [CBVAT] AS cbvat,
+  [DEX_ROW_ID] AS dex_row_id
+FROM [GPSERVER].[CHG].[dbo].[PM00100]

config/modules/pm00200.json

@@ -8,6 +8,7 @@
   "merge_key": null,
   "enabled": 1,
   "dest_description": "Dynamics GP payables vendor master",
+  "description": "Dynamics GP payables vendor master",
   "columns": [
     {
       "source_name": "VENDORID",

config/modules/pm00300.json

@@ -0,0 +1,205 @@
+{
+  "name": "pm00300",
+  "source_connection": "sqlserver",
+  "dest_connection": "usmidsap02",
+  "dest_table": "gp.pm00300",
+  "staging_table": "pipekit_staging.pm00300",
+  "merge_strategy": "full",
+  "merge_key": null,
+  "enabled": 1,
+  "dest_description": "Dynamics GP payables vendor address master",
+  "columns": [
+    {
+      "source_name": "VENDORID",
+      "source_type": "CHAR(15)",
+      "dest_name": "vendorid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "ADRSCODE",
+      "source_type": "CHAR(15)",
+      "dest_name": "adrscode",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "VNDCNTCT",
+      "source_type": "CHAR(61)",
+      "dest_name": "vndcntct",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "ADDRESS1",
+      "source_type": "CHAR(61)",
+      "dest_name": "address1",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "ADDRESS2",
+      "source_type": "CHAR(61)",
+      "dest_name": "address2",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "ADDRESS3",
+      "source_type": "CHAR(61)",
+      "dest_name": "address3",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "CITY",
+      "source_type": "CHAR(35)",
+      "dest_name": "city",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "STATE",
+      "source_type": "CHAR(29)",
+      "dest_name": "state",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "ZIPCODE",
+      "source_type": "CHAR(11)",
+      "dest_name": "zipcode",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "COUNTRY",
+      "source_type": "CHAR(61)",
+      "dest_name": "country",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "UPSZONE",
+      "source_type": "CHAR(3)",
+      "dest_name": "upszone",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "PHNUMBR1",
+      "source_type": "CHAR(21)",
+      "dest_name": "phnumbr1",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "PHNUMBR2",
+      "source_type": "CHAR(21)",
+      "dest_name": "phnumbr2",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "PHONE3",
+      "source_type": "CHAR(21)",
+      "dest_name": "phone3",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "FAXNUMBR",
+      "source_type": "CHAR(21)",
+      "dest_name": "faxnumbr",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "SHIPMTHD",
+      "source_type": "CHAR(15)",
+      "dest_name": "shipmthd",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "TAXSCHID",
+      "source_type": "CHAR(15)",
+      "dest_name": "taxschid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "EmailPOs",
+      "source_type": "TINYINT",
+      "dest_name": "emailpos",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "POEmailRecipient",
+      "source_type": "CHAR(81)",
+      "dest_name": "poemailrecipient",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "EmailPOFormat",
+      "source_type": "SMALLINT",
+      "dest_name": "emailpoformat",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "FaxPOs",
+      "source_type": "TINYINT",
+      "dest_name": "faxpos",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "POFaxNumber",
+      "source_type": "CHAR(21)",
+      "dest_name": "pofaxnumber",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "FaxPOFormat",
+      "source_type": "SMALLINT",
+      "dest_name": "faxpoformat",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "CCode",
+      "source_type": "CHAR(7)",
+      "dest_name": "ccode",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "DECLID",
+      "source_type": "CHAR(15)",
+      "dest_name": "declid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "DEX_ROW_TS",
+      "source_type": "DATETIME",
+      "dest_name": "dex_row_ts",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "DEX_ROW_ID",
+      "source_type": "INT",
+      "dest_name": "dex_row_id",
+      "dest_type": "integer",
+      "description": null
+    }
+  ],
+  "watermarks": [],
+  "hooks": [],
+  "description": "Dynamics GP payables vendor address master"
+}

config/modules/pm00300.sql

@@ -0,0 +1,29 @@
+SELECT
+  RTRIM([VENDORID]) AS vendorid,
+  RTRIM([ADRSCODE]) AS adrscode,
+  RTRIM([VNDCNTCT]) AS vndcntct,
+  RTRIM([ADDRESS1]) AS address1,
+  RTRIM([ADDRESS2]) AS address2,
+  RTRIM([ADDRESS3]) AS address3,
+  RTRIM([CITY]) AS city,
+  RTRIM([STATE]) AS state,
+  RTRIM([ZIPCODE]) AS zipcode,
+  RTRIM([COUNTRY]) AS country,
+  RTRIM([UPSZONE]) AS upszone,
+  RTRIM([PHNUMBR1]) AS phnumbr1,
+  RTRIM([PHNUMBR2]) AS phnumbr2,
+  RTRIM([PHONE3]) AS phone3,
+  RTRIM([FAXNUMBR]) AS faxnumbr,
+  RTRIM([SHIPMTHD]) AS shipmthd,
+  RTRIM([TAXSCHID]) AS taxschid,
+  [EmailPOs] AS emailpos,
+  RTRIM([POEmailRecipient]) AS poemailrecipient,
+  [EmailPOFormat] AS emailpoformat,
+  [FaxPOs] AS faxpos,
+  RTRIM([POFaxNumber]) AS pofaxnumber,
+  [FaxPOFormat] AS faxpoformat,
+  RTRIM([CCode]) AS ccode,
+  RTRIM([DECLID]) AS declid,
+  [DEX_ROW_TS] AS dex_row_ts,
+  [DEX_ROW_ID] AS dex_row_id
+FROM [GPSERVER].[CHG].[dbo].[PM00300]

config/modules/pm00400.json

@@ -0,0 +1,114 @@
+{
+  "name": "pm00400",
+  "source_connection": "sqlserver",
+  "dest_connection": "usmidsap02",
+  "dest_table": "gp.pm00400",
+  "staging_table": "pipekit_staging.pm00400",
+  "merge_strategy": "full",
+  "merge_key": null,
+  "enabled": 1,
+  "dest_description": "Dynamics GP payables key master; document index spanning open and history",
+  "columns": [
+    {
+      "source_name": "CNTRLNUM",
+      "source_type": "CHAR(21)",
+      "dest_name": "cntrlnum",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "CNTRLTYP",
+      "source_type": "SMALLINT",
+      "dest_name": "cntrltyp",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "DCSTATUS",
+      "source_type": "SMALLINT",
+      "dest_name": "dcstatus",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "DOCTYPE",
+      "source_type": "SMALLINT",
+      "dest_name": "doctype",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "VENDORID",
+      "source_type": "CHAR(15)",
+      "dest_name": "vendorid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "DOCNUMBR",
+      "source_type": "CHAR(21)",
+      "dest_name": "docnumbr",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "TRXSORCE",
+      "source_type": "CHAR(13)",
+      "dest_name": "trxsorce",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "CHEKBKID",
+      "source_type": "CHAR(15)",
+      "dest_name": "chekbkid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "DUEDATE",
+      "source_type": "DATETIME",
+      "dest_name": "duedate",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "DISCDATE",
+      "source_type": "DATETIME",
+      "dest_name": "discdate",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "BCHSOURC",
+      "source_type": "CHAR(15)",
+      "dest_name": "bchsourc",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "DOCDATE",
+      "source_type": "DATETIME",
+      "dest_name": "docdate",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "USERID",
+      "source_type": "CHAR(15)",
+      "dest_name": "userid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "DEX_ROW_ID",
+      "source_type": "INT",
+      "dest_name": "dex_row_id",
+      "dest_type": "integer",
+      "description": null
+    }
+  ],
+  "watermarks": [],
+  "hooks": [],
+  "description": "Dynamics GP payables key master; document index spanning open and history"
+}

config/modules/pm00400.sql

@@ -0,0 +1,16 @@
+SELECT
+  RTRIM([CNTRLNUM]) AS cntrlnum,
+  [CNTRLTYP] AS cntrltyp,
+  [DCSTATUS] AS dcstatus,
+  [DOCTYPE] AS doctype,
+  RTRIM([VENDORID]) AS vendorid,
+  RTRIM([DOCNUMBR]) AS docnumbr,
+  RTRIM([TRXSORCE]) AS trxsorce,
+  RTRIM([CHEKBKID]) AS chekbkid,
+  [DUEDATE] AS duedate,
+  [DISCDATE] AS discdate,
+  RTRIM([BCHSOURC]) AS bchsourc,
+  [DOCDATE] AS docdate,
+  RTRIM([USERID]) AS userid,
+  [DEX_ROW_ID] AS dex_row_id
+FROM [GPSERVER].[CHG].[dbo].[PM00400]

config/modules/pm10100.json

@@ -0,0 +1,268 @@
+{
+  "name": "pm10100",
+  "source_connection": "sqlserver",
+  "dest_connection": "usmidsap02",
+  "dest_table": "gp.pm10100",
+  "staging_table": "pipekit_staging.pm10100",
+  "merge_strategy": "full",
+  "merge_key": null,
+  "enabled": 1,
+  "dest_description": "Dynamics GP payables GL distributions for open vouchers",
+  "columns": [
+    {
+      "source_name": "VCHRNMBR",
+      "source_type": "CHAR(21)",
+      "dest_name": "vchrnmbr",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "DSTSQNUM",
+      "source_type": "INT",
+      "dest_name": "dstsqnum",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "CNTRLTYP",
+      "source_type": "SMALLINT",
+      "dest_name": "cntrltyp",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "CRDTAMNT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "crdtamnt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "DEBITAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "debitamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "DSTINDX",
+      "source_type": "INT",
+      "dest_name": "dstindx",
+      "dest_type": "integer",
+      "description": null
+    },
+    {
+      "source_name": "DISTTYPE",
+      "source_type": "SMALLINT",
+      "dest_name": "disttype",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "CHANGED",
+      "source_type": "TINYINT",
+      "dest_name": "changed",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "USERID",
+      "source_type": "CHAR(15)",
+      "dest_name": "userid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "PSTGSTUS",
+      "source_type": "SMALLINT",
+      "dest_name": "pstgstus",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "VENDORID",
+      "source_type": "CHAR(15)",
+      "dest_name": "vendorid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "TRXSORCE",
+      "source_type": "CHAR(13)",
+      "dest_name": "trxsorce",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "PSTGDATE",
+      "source_type": "DATETIME",
+      "dest_name": "pstgdate",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "INTERID",
+      "source_type": "CHAR(5)",
+      "dest_name": "interid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "CURNCYID",
+      "source_type": "CHAR(15)",
+      "dest_name": "curncyid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "CURRNIDX",
+      "source_type": "SMALLINT",
+      "dest_name": "currnidx",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "ORCRDAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "orcrdamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "ORDBTAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "ordbtamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "APTVCHNM",
+      "source_type": "CHAR(21)",
+      "dest_name": "aptvchnm",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "APTODCTY",
+      "source_type": "SMALLINT",
+      "dest_name": "aptodcty",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "SPCLDIST",
+      "source_type": "SMALLINT",
+      "dest_name": "spcldist",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "DistRef",
+      "source_type": "CHAR(31)",
+      "dest_name": "distref",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "RATETPID",
+      "source_type": "CHAR(15)",
+      "dest_name": "ratetpid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "EXGTBLID",
+      "source_type": "CHAR(15)",
+      "dest_name": "exgtblid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "XCHGRATE",
+      "source_type": "NUMERIC(19,7)",
+      "dest_name": "xchgrate",
+      "dest_type": "numeric(19,7)",
+      "description": null
+    },
+    {
+      "source_name": "EXCHDATE",
+      "source_type": "DATETIME",
+      "dest_name": "exchdate",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "TIME1",
+      "source_type": "DATETIME",
+      "dest_name": "time1",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "RTCLCMTD",
+      "source_type": "SMALLINT",
+      "dest_name": "rtclcmtd",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "DECPLACS",
+      "source_type": "SMALLINT",
+      "dest_name": "decplacs",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "EXPNDATE",
+      "source_type": "DATETIME",
+      "dest_name": "expndate",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "ICCURRID",
+      "source_type": "CHAR(15)",
+      "dest_name": "iccurrid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "ICCURRIX",
+      "source_type": "SMALLINT",
+      "dest_name": "iccurrix",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "DENXRATE",
+      "source_type": "NUMERIC(19,7)",
+      "dest_name": "denxrate",
+      "dest_type": "numeric(19,7)",
+      "description": null
+    },
+    {
+      "source_name": "MCTRXSTT",
+      "source_type": "SMALLINT",
+      "dest_name": "mctrxstt",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "CorrespondingUnit",
+      "source_type": "CHAR(5)",
+      "dest_name": "correspondingunit",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "DEX_ROW_ID",
+      "source_type": "INT",
+      "dest_name": "dex_row_id",
+      "dest_type": "integer",
+      "description": null
+    }
+  ],
+  "watermarks": [],
+  "hooks": [],
+  "description": "Dynamics GP payables GL distributions for open vouchers"
+}

config/modules/pm10100.sql

@@ -0,0 +1,38 @@
+SELECT
+  RTRIM([VCHRNMBR]) AS vchrnmbr,
+  [DSTSQNUM] AS dstsqnum,
+  [CNTRLTYP] AS cntrltyp,
+  [CRDTAMNT] AS crdtamnt,
+  [DEBITAMT] AS debitamt,
+  [DSTINDX] AS dstindx,
+  [DISTTYPE] AS disttype,
+  [CHANGED] AS changed,
+  RTRIM([USERID]) AS userid,
+  [PSTGSTUS] AS pstgstus,
+  RTRIM([VENDORID]) AS vendorid,
+  RTRIM([TRXSORCE]) AS trxsorce,
+  [PSTGDATE] AS pstgdate,
+  RTRIM([INTERID]) AS interid,
+  RTRIM([CURNCYID]) AS curncyid,
+  [CURRNIDX] AS currnidx,
+  [ORCRDAMT] AS orcrdamt,
+  [ORDBTAMT] AS ordbtamt,
+  RTRIM([APTVCHNM]) AS aptvchnm,
+  [APTODCTY] AS aptodcty,
+  [SPCLDIST] AS spcldist,
+  RTRIM([DistRef]) AS distref,
+  RTRIM([RATETPID]) AS ratetpid,
+  RTRIM([EXGTBLID]) AS exgtblid,
+  [XCHGRATE] AS xchgrate,
+  [EXCHDATE] AS exchdate,
+  [TIME1] AS time1,
+  [RTCLCMTD] AS rtclcmtd,
+  [DECPLACS] AS decplacs,
+  [EXPNDATE] AS expndate,
+  RTRIM([ICCURRID]) AS iccurrid,
+  [ICCURRIX] AS iccurrix,
+  [DENXRATE] AS denxrate,
+  [MCTRXSTT] AS mctrxstt,
+  RTRIM([CorrespondingUnit]) AS correspondingunit,
+  [DEX_ROW_ID] AS dex_row_id
+FROM [GPSERVER].[CHG].[dbo].[PM10100]

config/modules/pm20000.json

@@ -0,0 +1,562 @@
+{
+  "name": "pm20000",
+  "source_connection": "sqlserver",
+  "dest_connection": "usmidsap02",
+  "dest_table": "gp.pm20000",
+  "staging_table": "pipekit_staging.pm20000",
+  "merge_strategy": "full",
+  "merge_key": null,
+  "enabled": 1,
+  "dest_description": "Dynamics GP open payables transactions",
+  "columns": [
+    {
+      "source_name": "VCHRNMBR",
+      "source_type": "CHAR(21)",
+      "dest_name": "vchrnmbr",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "VENDORID",
+      "source_type": "CHAR(15)",
+      "dest_name": "vendorid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "DOCTYPE",
+      "source_type": "SMALLINT",
+      "dest_name": "doctype",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "DOCDATE",
+      "source_type": "DATETIME",
+      "dest_name": "docdate",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "DOCNUMBR",
+      "source_type": "CHAR(21)",
+      "dest_name": "docnumbr",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "DOCAMNT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "docamnt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "CURTRXAM",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "curtrxam",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "DISTKNAM",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "distknam",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "DISCAMNT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "discamnt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "DSCDLRAM",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "dscdlram",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "BACHNUMB",
+      "source_type": "CHAR(15)",
+      "dest_name": "bachnumb",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "TRXSORCE",
+      "source_type": "CHAR(13)",
+      "dest_name": "trxsorce",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "BCHSOURC",
+      "source_type": "CHAR(15)",
+      "dest_name": "bchsourc",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "DISCDATE",
+      "source_type": "DATETIME",
+      "dest_name": "discdate",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "DUEDATE",
+      "source_type": "DATETIME",
+      "dest_name": "duedate",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "PORDNMBR",
+      "source_type": "CHAR(21)",
+      "dest_name": "pordnmbr",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "TEN99AMNT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "ten99amnt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "WROFAMNT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "wrofamnt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "DISAMTAV",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "disamtav",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "TRXDSCRN",
+      "source_type": "CHAR(31)",
+      "dest_name": "trxdscrn",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "UN1099AM",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "un1099am",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "BKTPURAM",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "bktpuram",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "BKTFRTAM",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "bktfrtam",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "BKTMSCAM",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "bktmscam",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "VOIDED",
+      "source_type": "TINYINT",
+      "dest_name": "voided",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "HOLD",
+      "source_type": "TINYINT",
+      "dest_name": "hold",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "CHEKBKID",
+      "source_type": "CHAR(15)",
+      "dest_name": "chekbkid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "DINVPDOF",
+      "source_type": "DATETIME",
+      "dest_name": "dinvpdof",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "PPSAMDED",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "ppsamded",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "PPSTAXRT",
+      "source_type": "SMALLINT",
+      "dest_name": "ppstaxrt",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "PGRAMSBJ",
+      "source_type": "SMALLINT",
+      "dest_name": "pgramsbj",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "GSTDSAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "gstdsamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "POSTEDDT",
+      "source_type": "DATETIME",
+      "dest_name": "posteddt",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "PTDUSRID",
+      "source_type": "CHAR(15)",
+      "dest_name": "ptdusrid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "MODIFDT",
+      "source_type": "DATETIME",
+      "dest_name": "modifdt",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "MDFUSRID",
+      "source_type": "CHAR(15)",
+      "dest_name": "mdfusrid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "PYENTTYP",
+      "source_type": "SMALLINT",
+      "dest_name": "pyenttyp",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "CARDNAME",
+      "source_type": "CHAR(15)",
+      "dest_name": "cardname",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "PRCHAMNT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "prchamnt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "TRDISAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "trdisamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "MSCCHAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "mscchamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "FRTAMNT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "frtamnt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "TAXAMNT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "taxamnt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "TTLPYMTS",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "ttlpymts",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "CURNCYID",
+      "source_type": "CHAR(15)",
+      "dest_name": "curncyid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "PYMTRMID",
+      "source_type": "CHAR(21)",
+      "dest_name": "pymtrmid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "SHIPMTHD",
+      "source_type": "CHAR(15)",
+      "dest_name": "shipmthd",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "TAXSCHID",
+      "source_type": "CHAR(15)",
+      "dest_name": "taxschid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "PCHSCHID",
+      "source_type": "CHAR(15)",
+      "dest_name": "pchschid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "FRTSCHID",
+      "source_type": "CHAR(15)",
+      "dest_name": "frtschid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "MSCSCHID",
+      "source_type": "CHAR(15)",
+      "dest_name": "mscschid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "PSTGDATE",
+      "source_type": "DATETIME",
+      "dest_name": "pstgdate",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "DISAVTKN",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "disavtkn",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "CNTRLTYP",
+      "source_type": "SMALLINT",
+      "dest_name": "cntrltyp",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "NOTEINDX",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "noteindx",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "PRCTDISC",
+      "source_type": "SMALLINT",
+      "dest_name": "prctdisc",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "RETNAGAM",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "retnagam",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "ICTRX",
+      "source_type": "TINYINT",
+      "dest_name": "ictrx",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "Tax_Date",
+      "source_type": "DATETIME",
+      "dest_name": "tax_date",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "PRCHDATE",
+      "source_type": "DATETIME",
+      "dest_name": "prchdate",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "CORRCTN",
+      "source_type": "TINYINT",
+      "dest_name": "corrctn",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "SIMPLIFD",
+      "source_type": "TINYINT",
+      "dest_name": "simplifd",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "BNKRCAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "bnkrcamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "APLYWITH",
+      "source_type": "TINYINT",
+      "dest_name": "aplywith",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "Electronic",
+      "source_type": "TINYINT",
+      "dest_name": "electronic",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "ECTRX",
+      "source_type": "TINYINT",
+      "dest_name": "ectrx",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "DocPrinted",
+      "source_type": "TINYINT",
+      "dest_name": "docprinted",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "TaxInvReqd",
+      "source_type": "TINYINT",
+      "dest_name": "taxinvreqd",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "VNDCHKNM",
+      "source_type": "CHAR(65)",
+      "dest_name": "vndchknm",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "BackoutTradeDisc",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "backouttradedisc",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "CBVAT",
+      "source_type": "TINYINT",
+      "dest_name": "cbvat",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "VADCDTRO",
+      "source_type": "CHAR(15)",
+      "dest_name": "vadcdtro",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "TEN99TYPE",
+      "source_type": "SMALLINT",
+      "dest_name": "ten99type",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "TEN99BOXNUMBER",
+      "source_type": "SMALLINT",
+      "dest_name": "ten99boxnumber",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "PONUMBER",
+      "source_type": "CHAR(17)",
+      "dest_name": "ponumber",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Workflow_Status",
+      "source_type": "SMALLINT",
+      "dest_name": "workflow_status",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "DEX_ROW_TS",
+      "source_type": "DATETIME",
+      "dest_name": "dex_row_ts",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "DEX_ROW_ID",
+      "source_type": "INT",
+      "dest_name": "dex_row_id",
+      "dest_type": "integer",
+      "description": null
+    }
+  ],
+  "watermarks": [],
+  "hooks": [],
+  "description": "Dynamics GP open payables transactions"
+}

config/modules/pm20000.sql

@@ -0,0 +1,80 @@
+SELECT
+  RTRIM([VCHRNMBR]) AS vchrnmbr,
+  RTRIM([VENDORID]) AS vendorid,
+  [DOCTYPE] AS doctype,
+  [DOCDATE] AS docdate,
+  RTRIM([DOCNUMBR]) AS docnumbr,
+  [DOCAMNT] AS docamnt,
+  [CURTRXAM] AS curtrxam,
+  [DISTKNAM] AS distknam,
+  [DISCAMNT] AS discamnt,
+  [DSCDLRAM] AS dscdlram,
+  RTRIM([BACHNUMB]) AS bachnumb,
+  RTRIM([TRXSORCE]) AS trxsorce,
+  RTRIM([BCHSOURC]) AS bchsourc,
+  [DISCDATE] AS discdate,
+  [DUEDATE] AS duedate,
+  RTRIM([PORDNMBR]) AS pordnmbr,
+  [TEN99AMNT] AS ten99amnt,
+  [WROFAMNT] AS wrofamnt,
+  [DISAMTAV] AS disamtav,
+  RTRIM([TRXDSCRN]) AS trxdscrn,
+  [UN1099AM] AS un1099am,
+  [BKTPURAM] AS bktpuram,
+  [BKTFRTAM] AS bktfrtam,
+  [BKTMSCAM] AS bktmscam,
+  [VOIDED] AS voided,
+  [HOLD] AS hold,
+  RTRIM([CHEKBKID]) AS chekbkid,
+  [DINVPDOF] AS dinvpdof,
+  [PPSAMDED] AS ppsamded,
+  [PPSTAXRT] AS ppstaxrt,
+  [PGRAMSBJ] AS pgramsbj,
+  [GSTDSAMT] AS gstdsamt,
+  [POSTEDDT] AS posteddt,
+  RTRIM([PTDUSRID]) AS ptdusrid,
+  [MODIFDT] AS modifdt,
+  RTRIM([MDFUSRID]) AS mdfusrid,
+  [PYENTTYP] AS pyenttyp,
+  RTRIM([CARDNAME]) AS cardname,
+  [PRCHAMNT] AS prchamnt,
+  [TRDISAMT] AS trdisamt,
+  [MSCCHAMT] AS mscchamt,
+  [FRTAMNT] AS frtamnt,
+  [TAXAMNT] AS taxamnt,
+  [TTLPYMTS] AS ttlpymts,
+  RTRIM([CURNCYID]) AS curncyid,
+  RTRIM([PYMTRMID]) AS pymtrmid,
+  RTRIM([SHIPMTHD]) AS shipmthd,
+  RTRIM([TAXSCHID]) AS taxschid,
+  RTRIM([PCHSCHID]) AS pchschid,
+  RTRIM([FRTSCHID]) AS frtschid,
+  RTRIM([MSCSCHID]) AS mscschid,
+  [PSTGDATE] AS pstgdate,
+  [DISAVTKN] AS disavtkn,
+  [CNTRLTYP] AS cntrltyp,
+  [NOTEINDX] AS noteindx,
+  [PRCTDISC] AS prctdisc,
+  [RETNAGAM] AS retnagam,
+  [ICTRX] AS ictrx,
+  [Tax_Date] AS tax_date,
+  [PRCHDATE] AS prchdate,
+  [CORRCTN] AS corrctn,
+  [SIMPLIFD] AS simplifd,
+  [BNKRCAMT] AS bnkrcamt,
+  [APLYWITH] AS aplywith,
+  [Electronic] AS electronic,
+  [ECTRX] AS ectrx,
+  [DocPrinted] AS docprinted,
+  [TaxInvReqd] AS taxinvreqd,
+  RTRIM([VNDCHKNM]) AS vndchknm,
+  [BackoutTradeDisc] AS backouttradedisc,
+  [CBVAT] AS cbvat,
+  RTRIM([VADCDTRO]) AS vadcdtro,
+  [TEN99TYPE] AS ten99type,
+  [TEN99BOXNUMBER] AS ten99boxnumber,
+  RTRIM([PONUMBER]) AS ponumber,
+  [Workflow_Status] AS workflow_status,
+  [DEX_ROW_TS] AS dex_row_ts,
+  [DEX_ROW_ID] AS dex_row_id
+FROM [GPSERVER].[CHG].[dbo].[PM20000]

config/modules/pm20100.json

@@ -0,0 +1,639 @@
+{
+  "name": "pm20100",
+  "source_connection": "sqlserver",
+  "dest_connection": "usmidsap02",
+  "dest_table": "gp.pm20100",
+  "staging_table": "pipekit_staging.pm20100",
+  "merge_strategy": "incremental",
+  "merge_key": "vchrnmbr, doctype",
+  "enabled": 1,
+  "dest_description": "Dynamics GP open payables apply detail",
+  "columns": [
+    {
+      "source_name": "KEYSOURC",
+      "source_type": "CHAR(41)",
+      "dest_name": "keysourc",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "DOCDATE",
+      "source_type": "DATETIME",
+      "dest_name": "docdate",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "TIME1",
+      "source_type": "DATETIME",
+      "dest_name": "time1",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "VENDORID",
+      "source_type": "CHAR(15)",
+      "dest_name": "vendorid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "POSTED",
+      "source_type": "TINYINT",
+      "dest_name": "posted",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "BCHSOURC",
+      "source_type": "CHAR(15)",
+      "dest_name": "bchsourc",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "USERID",
+      "source_type": "CHAR(15)",
+      "dest_name": "userid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "APTVCHNM",
+      "source_type": "CHAR(21)",
+      "dest_name": "aptvchnm",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "APTODCTY",
+      "source_type": "SMALLINT",
+      "dest_name": "aptodcty",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "APTODCDT",
+      "source_type": "DATETIME",
+      "dest_name": "aptodcdt",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "APTODCNM",
+      "source_type": "CHAR(21)",
+      "dest_name": "aptodcnm",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "APPLDAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "appldamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "DISTKNAM",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "distknam",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "DISAVTKN",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "disavtkn",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "WROFAMNT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "wrofamnt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "CURNCYID",
+      "source_type": "CHAR(15)",
+      "dest_name": "curncyid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "CURRNIDX",
+      "source_type": "SMALLINT",
+      "dest_name": "currnidx",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "ORAPPAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "orappamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "ORDISTKN",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "ordistkn",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "ORDATKN",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "ordatkn",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "ORWROFAM",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "orwrofam",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "Apply_To_Document_Amount",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "apply_to_document_amount",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "Apply_To_Orig_Doc_Amount",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "apply_to_orig_doc_amount",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "Apply_To_Discount_Date",
+      "source_type": "DATETIME",
+      "dest_name": "apply_to_discount_date",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "Apply_To_Due_Date",
+      "source_type": "DATETIME",
+      "dest_name": "apply_to_due_date",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "Apply_To_Description",
+      "source_type": "CHAR(31)",
+      "dest_name": "apply_to_description",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Apply_To_IS_MC_Trx",
+      "source_type": "SMALLINT",
+      "dest_name": "apply_to_is_mc_trx",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "ApplyToGLPostDate",
+      "source_type": "DATETIME",
+      "dest_name": "applytoglpostdate",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "APTOEXRATE",
+      "source_type": "NUMERIC(19,7)",
+      "dest_name": "aptoexrate",
+      "dest_type": "numeric(19,7)",
+      "description": null
+    },
+    {
+      "source_name": "APTODENRATE",
+      "source_type": "NUMERIC(19,7)",
+      "dest_name": "aptodenrate",
+      "dest_type": "numeric(19,7)",
+      "description": null
+    },
+    {
+      "source_name": "APTORTCLCMETH",
+      "source_type": "SMALLINT",
+      "dest_name": "aptortclcmeth",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "APTOMCTRXSTT",
+      "source_type": "SMALLINT",
+      "dest_name": "aptomctrxstt",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "ISMCTRX",
+      "source_type": "SMALLINT",
+      "dest_name": "ismctrx",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "VCHRNMBR",
+      "source_type": "CHAR(21)",
+      "dest_name": "vchrnmbr",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "DOCTYPE",
+      "source_type": "SMALLINT",
+      "dest_name": "doctype",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "APFRDCNM",
+      "source_type": "CHAR(21)",
+      "dest_name": "apfrdcnm",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "FROMCURR",
+      "source_type": "CHAR(15)",
+      "dest_name": "fromcurr",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Apply_From_Document_Amou",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "apply_from_document_amou",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "Apply_From_Orig_Doc_Amou",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "apply_from_orig_doc_amou",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "APFRMAPLYAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "apfrmaplyamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "APFRMDISCTAKEN",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "apfrmdisctaken",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "APFRMDISCAVAIL",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "apfrmdiscavail",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "APFRMWROFAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "apfrmwrofamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "ActualApplyToAmount",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "actualapplytoamount",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "ActualDiscTakenAmount",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "actualdisctakenamount",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "ActualDiscAvailTaken",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "actualdiscavailtaken",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "ActualWriteOffAmount",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "actualwriteoffamount",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "APFRMEXRATE",
+      "source_type": "NUMERIC(19,7)",
+      "dest_name": "apfrmexrate",
+      "dest_type": "numeric(19,7)",
+      "description": null
+    },
+    {
+      "source_name": "APFRMDENRATE",
+      "source_type": "NUMERIC(19,7)",
+      "dest_name": "apfrmdenrate",
+      "dest_type": "numeric(19,7)",
+      "description": null
+    },
+    {
+      "source_name": "APFRMRTCLCMETH",
+      "source_type": "SMALLINT",
+      "dest_name": "apfrmrtclcmeth",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "APFRMMCTRXSTT",
+      "source_type": "SMALLINT",
+      "dest_name": "apfrmmctrxstt",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "Apply_From_Description",
+      "source_type": "CHAR(31)",
+      "dest_name": "apply_from_description",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Apply_From_IS_MC_Trx",
+      "source_type": "SMALLINT",
+      "dest_name": "apply_from_is_mc_trx",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "PPSAMDED",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "ppsamded",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "GSTDSAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "gstdsamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "TAXDTLID",
+      "source_type": "CHAR(15)",
+      "dest_name": "taxdtlid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "UPDTKNAM",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "updtknam",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "UPGSTDAM",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "upgstdam",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "UNPPPSAD",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "unpppsad",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "UPWROFAM",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "upwrofam",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "PMDSTMSG",
+      "source_type": "BINARY",
+      "dest_name": "pmdstmsg",
+      "dest_type": "bytea",
+      "description": null
+    },
+    {
+      "source_name": "MODIFDT",
+      "source_type": "DATETIME",
+      "dest_name": "modifdt",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "MDFUSRID",
+      "source_type": "CHAR(15)",
+      "dest_name": "mdfusrid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "POSTEDDT",
+      "source_type": "DATETIME",
+      "dest_name": "posteddt",
+      "dest_type": "timestamp",
+      "description": null
+    },
+    {
+      "source_name": "PTDUSRID",
+      "source_type": "CHAR(15)",
+      "dest_name": "ptdusrid",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "TEN99AMNT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "ten99amnt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "RLGANLOS",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "rlganlos",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "APYFRMRNDAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "apyfrmrndamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "APYTORNDAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "apytorndamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "APYTORNDDISC",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "apytornddisc",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "XCHGRATE",
+      "source_type": "NUMERIC(19,7)",
+      "dest_name": "xchgrate",
+      "dest_type": "numeric(19,7)",
+      "description": null
+    },
+    {
+      "source_name": "DECPLCUR",
+      "source_type": "SMALLINT",
+      "dest_name": "decplcur",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "RATECALC",
+      "source_type": "SMALLINT",
+      "dest_name": "ratecalc",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "Payment_To_Print_On_Stub",
+      "source_type": "CHAR(21)",
+      "dest_name": "payment_to_print_on_stub",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "OAPYFRMRNDAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "oapyfrmrndamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "OAPYTORNDAMT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "oapytorndamt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "OAPYTORNDDISC",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "oapytornddisc",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "Settled_Gain_CreditCurrT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "settled_gain_creditcurrt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "Settled_Loss_CreditCurrT",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "settled_loss_creditcurrt",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "Settled_Gain_DebitCurrTr",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "settled_gain_debitcurrtr",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "Settled_Loss_DebitCurrTr",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "settled_loss_debitcurrtr",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "Settled_Gain_DebitDiscAv",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "settled_gain_debitdiscav",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "Settled_Loss_DebitDiscAv",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "settled_loss_debitdiscav",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "VADCDTRO",
+      "source_type": "CHAR(15)",
+      "dest_name": "vadcdtro",
+      "dest_type": "text",
+      "description": null
+    },
+    {
+      "source_name": "Credit1099Amount",
+      "source_type": "NUMERIC(19,5)",
+      "dest_name": "credit1099amount",
+      "dest_type": "numeric(19,5)",
+      "description": null
+    },
+    {
+      "source_name": "DEFTEN99TYPE",
+      "source_type": "SMALLINT",
+      "dest_name": "deften99type",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "DEFTEN99BOXNUMBER",
+      "source_type": "SMALLINT",
+      "dest_name": "deften99boxnumber",
+      "dest_type": "smallint",
+      "description": null
+    },
+    {
+      "source_name": "DEX_ROW_ID",
+      "source_type": "INT",
+      "dest_name": "dex_row_id",
+      "dest_type": "integer",
+      "description": null
+    }
+  ],
+  "watermarks": [
+    {
+      "name": "pm20100_ts",
+      "connection": "usmidsap02",
+      "resolver_sql": "SELECT COALESCE(LEAST(MAX(modifdt), CURRENT_DATE::timestamp) - INTERVAL '7 days', '1900-01-01') FROM gp.pm20100",
+      "default_value": "1900-01-01"
+    }
+  ],
+  "hooks": [],
+  "description": "Dynamics GP open payables apply detail"
+}