在 Stripe 和 Pipedrive 之间同步支付和客户数据

• •Stripe API Key
• •可能需要目标 API 的认证凭证

{
  "meta": {
    "instanceId": "8c8c5237b8e37b006a7adce87f4369350c58e41f3ca9de16196d3197f69eabcd"
  },
  "nodes": [
    {
      "id": "28349bfd-f68e-4479-9508-28d408033d09",
      "name": "获取客户",
      "type": "n8n-nodes-base.stripe",
      "position": [
        5360,
        1100
      ],
      "parameters": {
        "filters": {},
        "resource": "customer",
        "operation": "getAll",
        "returnAll": true
      },
      "credentials": {
        "stripeApi": {
          "id": "26",
          "name": "Stripe account"
        }
      },
      "typeVersion": 1
    },
    {
      "id": "3f3d2389-e9ab-4140-8b04-f0a07003cecc",
      "name": "重命名字段并仅保留必要字段",
      "type": "n8n-nodes-base.set",
      "position": [
        5560,
        1100
      ],
      "parameters": {
        "values": {
          "string": [
            {
              "name": "customerName",
              "value": "={{ $json[\"name\"] }}"
            },
            {
              "name": "customerId",
              "value": "={{ $json[\"id\"] }}"
            }
          ]
        },
        "options": {},
        "keepOnlySet": true
      },
      "typeVersion": 1
    },
    {
      "id": "d6d3ccff-f565-49c9-9cda-8e278d298433",
      "name": "将客户姓名添加到支付数据",
      "type": "n8n-nodes-base.merge",
      "position": [
        5860,
        920
      ],
      "parameters": {
        "mode": "mergeByKey",
        "propertyName1": "customer",
        "propertyName2": "customerId"
      },
      "typeVersion": 1
    },
    {
      "id": "eadce8e7-f523-485b-8cc0-5a336c8633ef",
      "name": "搜索机构",
      "type": "n8n-nodes-base.pipedrive",
      "position": [
        6140,
        1060
      ],
      "parameters": {
        "term": "={{ $json[\"customerName\"] }}",
        "resource": "organization",
        "operation": "search",
        "additionalFields": {}
      },
      "credentials": {
        "pipedriveApi": {
          "id": "96",
          "name": "Pipedrive account"
        }
      },
      "typeVersion": 1
    },
    {
      "id": "dde08b48-21b0-44af-a66d-ff69399608e7",
      "name": "将机构信息添加到支付数据",
      "type": "n8n-nodes-base.merge",
      "position": [
        6400,
        940
      ],
      "parameters": {
        "join": "inner",
        "mode": "mergeByIndex"
      },
      "typeVersion": 1
    },
    {
      "id": "6cbd0f06-0f10-4360-8c5c-e181679ba370",
      "name": "创建包含支付信息的备注",
      "type": "n8n-nodes-base.pipedrive",
      "position": [
        6620,
        940
      ],
      "parameters": {
        "content": "={{ $json[\"description\"] }}: {{ $json[\"amount\"] / 100 }} {{ $json[\"currency\"] }}",
        "resource": "note",
        "additionalFields": {
          "org_id": "={{ $json[\"id\"] }}"
        }
      },
      "credentials": {
        "pipedriveApi": {
          "id": "96",
          "name": "Pipedrive account"
        }
      },
      "typeVersion": 1
    },
    {
      "id": "c6ed5a89-b50a-40ad-bd78-62ffc2430fde",
      "name": "获取上次执行时间戳",
      "type": "n8n-nodes-base.functionItem",
      "position": [
        5140,
        900
      ],
      "parameters": {
        "functionCode": "// Code here will run once per input item.\n// More info and help: https://docs.n8n.io/nodes/n8n-nodes-base.functionItem\n// Tip: You can use luxon for dates and $jmespath for querying JSON structures\n\n// Add a new field called 'myNewField' to the JSON of the item\nconst staticData = getWorkflowStaticData('global');\n\nif(!staticData.lastExecution){\n  staticData.lastExecution = Math.round( new Date().getTime() / 1000 );\n}\n\nitem.executionTimeStamp = Math.round( new Date().getTime() / 1000 );\nitem.lastExecution = staticData.lastExecution;\n\n\nreturn item;"
      },
      "typeVersion": 1
    },
    {
      "id": "41b2c937-d479-4402-b428-29faabe32845",
      "name": "设置新的最后执行时间戳",
      "type": "n8n-nodes-base.functionItem",
      "position": [
        6820,
        940
      ],
      "parameters": {
        "functionCode": "// Code here will run once per input item.\n// More info and help: https://docs.n8n.io/nodes/n8n-nodes-base.functionItem\n// Tip: You can use luxon for dates and $jmespath for querying JSON structures\n\n// Add a new field called 'myNewField' to the JSON of the item\nconst staticData = getWorkflowStaticData('global');\n\nstaticData.lastExecution = $item(0).$node[\"Get last execution timestamp\"].executionTimeStamp;\n\nreturn item;"
      },
      "executeOnce": true,
      "typeVersion": 1
    },
    {
      "id": "56612271-08c4-4347-92b1-b898c68c3460",
      "name": "将支付数组拆分为单项",
      "type": "n8n-nodes-base.itemLists",
      "position": [
        5560,
        900
      ],
      "parameters": {
        "options": {},
        "fieldToSplitOut": "data"
      },
      "typeVersion": 1
    },
    {
      "id": "b866ba46-6269-4c8d-8021-ea99591d676d",
      "name": "在 Stripe 中搜索支付记录",
      "type": "n8n-nodes-base.httpRequest",
      "position": [
        5360,
        900
      ],
      "parameters": {
        "url": "https://api.stripe.com/v1/charges/search",
        "options": {},
        "authentication": "predefinedCredentialType",
        "queryParametersUi": {
          "parameter": [
            {
              "name": "query",
              "value": "=created>{{$json[\"lastExecution\"]}} AND status:\"succeeded\""
            }
          ]
        },
        "nodeCredentialType": "stripeApi"
      },
      "credentials": {
        "stripeApi": {
          "id": "26",
          "name": "Stripe account"
        }
      },
      "typeVersion": 2
    },
    {
      "id": "a3249f70-1cd4-4d5f-8f27-15badcf10296",
      "name": "每天上午 8 点",
      "type": "n8n-nodes-base.cron",
      "position": [
        4920,
        900
      ],
      "parameters": {
        "triggerTimes": {
          "item": [
            {
              "hour": 8
            }
          ]
        }
      },
      "typeVersion": 1
    }
  ],
  "connections": {
    "Get customers": {
      "main": [
        [
          {
            "node": "Rename fields and keep only needed fields",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Every day at 8 am": {
      "main": [
        [
          {
            "node": "Get last execution timestamp",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Search organisation": {
      "main": [
        [
          {
            "node": "Add organisation Information to charge data",
            "type": "main",
            "index": 1
          }
        ]
      ]
    },
    "Get last execution timestamp": {
      "main": [
        [
          {
            "node": "Search for charges in Stripe",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Search for charges in Stripe": {
      "main": [
        [
          {
            "node": "Split array of charges to items",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Split array of charges to items": {
      "main": [
        [
          {
            "node": "Add customer name to charge data",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Add customer name to charge data": {
      "main": [
        [
          {
            "node": "Search organisation",
            "type": "main",
            "index": 0
          },
          {
            "node": "Add organisation Information to charge data",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Create note with charge information": {
      "main": [
        [
          {
            "node": "Set new last execution timestamp",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Rename fields and keep only needed fields": {
      "main": [
        [
          {
            "node": "Add customer name to charge data",
            "type": "main",
            "index": 1
          }
        ]
      ]
    },
    "Add organisation Information to charge data": {
      "main": [
        [
          {
            "node": "Create note with charge information",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  }
}