Upload New File

20250409/test_send_twitter_wrong_msg.json

+{
+  "createdAt": "2025-02-13T05:03:30.843Z",
+  "updatedAt": "2025-02-14T07:33:56.000Z",
+  "id": "ZrKtEbhDs8yVpjUJ",
+  "name": "test_send_twitter_wrong_msg",
+  "active": true,
+  "nodes": [
+    {
+      "parameters": {
+        "operation": "executeQuery",
+        "query": "CALL insert_fail_log({{ JSON.stringify($json.body.info)}},{{JSON.stringify(JSON.stringify($json.body.schedule_id)) }});\n",
+        "options": {}
+      },
+      "id": "e59344b6-70e8-4799-b4e1-6dbecdc59484",
+      "name": "insert_fail_log",
+      "type": "n8n-nodes-base.mySql",
+      "typeVersion": 2.4,
+      "position": [
+        -660,
+        360
+      ],
+      "credentials": {
+        "mySql": {
+          "id": "09oRI0DULmEzD9l8",
+          "name": "SL-DB"
+        }
+      }
+    },
+    {
+      "parameters": {
+        "jsCode": "// Loop over input items and add a new field called 'myNewField' to the JSON of each one\ninfo_data = JSON.parse($('Webhook').all()[0].json.body.info);\nschedule_id = JSON.parse($('Webhook').all()[0].json.body.schedule_id);\nrw_name = $('get_rw_name').all()[0].json.name;\ninfo_content = \"## twitter采集异常\\n >ID:<font color=\\\"comment\\\">\"+schedule_id+\"</font>\\n>任务名称:<font color=\\\"comment\\\">\"+rw_name+\"</font>\\n>博主名称:<font color=\\\"comment\\\">\"+info_data.user_screen_name+\"</font>\\n>原因:<font color=\\\"comment\\\"> \"+info_data.error_info+\"</font>\\n>失败时间:<font color=\\\"warning\\\"> \"+info_data.occur_date+\"</font>\\n>详情页:<font color=\\\"comment\\\"> [http://16.162.124.172:8080/#/tasks](http://16.162.124.172:8080/#/tasks)</font>\";\noutput_all_data = {};\noutput_all = [];\noutput_all_data['content'] = info_content;\noutput_all.push(output_all_data);\n// console.log(output_all);\nreturn output_all;"
+      },
+      "id": "b37c769f-7e39-446c-8206-9f046808e767",
+      "name": "get_msg_content",
+      "type": "n8n-nodes-base.code",
+      "typeVersion": 2,
+      "position": [
+        120,
+        360
+      ]
+    },
+    {
+      "parameters": {
+        "method": "POST",
+        "url": "https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=a71c9850-9c4c-4855-8f12-215c1badbfed",
+        "sendHeaders": true,
+        "specifyHeaders": "json",
+        "jsonHeaders": "{\n   \"Content-Type\": \"application/json\"\n}",
+        "sendBody": true,
+        "specifyBody": "json",
+        "jsonBody": "={\n            \"msgtype\": \"markdown\",\n            \"markdown\": {\n                \"content\": {{ JSON.stringify($json.content) }}\n            }\n   }",
+        "options": {}
+      },
+      "id": "9507669c-8eee-4592-b1ae-19d5cb917e68",
+      "name": "send_msg",
+      "type": "n8n-nodes-base.httpRequest",
+      "typeVersion": 4.2,
+      "position": [
+        280,
+        360
+      ]
+    },
+    {
+      "parameters": {
+        "operation": "executeQuery",
+        "query": "select a.`name` from schedule a where a.id = {{ JSON.parse($('Webhook').all()[0].json.body.schedule_id) }};\n",
+        "options": {}
+      },
+      "id": "4ffbc856-f289-44d8-a563-c372ada8ab66",
+      "name": "get_rw_name",
+      "type": "n8n-nodes-base.mySql",
+      "typeVersion": 2.4,
+      "position": [
+        -40,
+        360
+      ],
+      "alwaysOutputData": false,
+      "credentials": {
+        "mySql": {
+          "id": "09oRI0DULmEzD9l8",
+          "name": "SL-DB"
+        }
+      }
+    },
+    {
+      "parameters": {
+        "operation": "executeQuery",
+        "query": "update craw_warn_log_info set status = 1 where rw_id = {{JSON.stringify(JSON.parse($('Webhook').all()[0].json.body.schedule_id)) }} and   screen_name = {{JSON.stringify(JSON.parse($('Webhook').all()[0].json.body.info).user_screen_name) }}\n",
+        "options": {}
+      },
+      "id": "3387d853-b3f6-46c5-b48b-27648611841c",
+      "name": "update_warn_info",
+      "type": "n8n-nodes-base.mySql",
+      "typeVersion": 2.4,
+      "position": [
+        440,
+        360
+      ],
+      "alwaysOutputData": false,
+      "credentials": {
+        "mySql": {
+          "id": "09oRI0DULmEzD9l8",
+          "name": "SL-DB"
+        }
+      }
+    },
+    {
+      "parameters": {
+        "operation": "executeQuery",
+        "query": "select IFNULL(count(1), 0) as count from (\nselect  a.rw_id,screen_name,occur_date from craw_warn_log_info a where a.rw_id = {{JSON.stringify(JSON.parse($('Webhook').all()[0].json.body.schedule_id)) }} and a.screen_name = {{JSON.stringify(JSON.parse($('Webhook').all()[0].json.body.info).user_screen_name) }} and a.content like '%429%' and a.status =0 group by screen_name,occur_date) as craw_warn_info;\n",
+        "options": {}
+      },
+      "id": "f94cb3ef-b662-4e8a-bb07-4372b7e39088",
+      "name": "is_exists_warn_by_retry",
+      "type": "n8n-nodes-base.mySql",
+      "typeVersion": 2.4,
+      "position": [
+        -440,
+        220
+      ],
+      "alwaysOutputData": false,
+      "credentials": {
+        "mySql": {
+          "id": "09oRI0DULmEzD9l8",
+          "name": "SL-DB"
+        }
+      }
+    },
+    {
+      "parameters": {
+        "operation": "executeQuery",
+        "query": "select IFNULL(count(1), 0) as count from (\nselect  a.rw_id,screen_name,occur_date from craw_warn_log_info a where a.rw_id = {{JSON.stringify(JSON.parse($('Webhook').all()[0].json.body.schedule_id)) }} and a.screen_name = {{JSON.stringify(JSON.parse($('Webhook').all()[0].json.body.info).user_screen_name) }} and (a.content not like '%429%' and a.content not like '%403%') and a.status =0 group by screen_name,occur_date) as craw_warn_info;\n",
+        "options": {}
+      },
+      "id": "3bb73703-c46b-41be-8237-16e46f8e9c1a",
+      "name": "is_exists_warn_other",
+      "type": "n8n-nodes-base.mySql",
+      "typeVersion": 2.4,
+      "position": [
+        -440,
+        480
+      ],
+      "alwaysOutputData": false,
+      "credentials": {
+        "mySql": {
+          "id": "09oRI0DULmEzD9l8",
+          "name": "SL-DB"
+        }
+      }
+    },
+    {
+      "parameters": {
+        "conditions": {
+          "options": {
+            "caseSensitive": true,
+            "leftValue": "",
+            "typeValidation": "strict"
+          },
+          "conditions": [
+            {
+              "id": "a1541edc-9637-4ac2-83a6-902ee9d29af6",
+              "leftValue": "={{$json.count}}",
+              "rightValue": 1,
+              "operator": {
+                "type": "number",
+                "operation": "gte"
+              }
+            }
+          ],
+          "combinator": "and"
+        },
+        "options": {}
+      },
+      "id": "2eb33ef9-99ed-4eb6-aff7-089db98b05e4",
+      "name": "is_send_msg_judge",
+      "type": "n8n-nodes-base.if",
+      "typeVersion": 2,
+      "position": [
+        -240,
+        480
+      ]
+    },
+    {
+      "parameters": {
+        "conditions": {
+          "options": {
+            "caseSensitive": true,
+            "leftValue": "",
+            "typeValidation": "strict"
+          },
+          "conditions": [
+            {
+              "id": "a1541edc-9637-4ac2-83a6-902ee9d29af6",
+              "leftValue": "={{$json.count}}",
+              "rightValue": 3,
+              "operator": {
+                "type": "number",
+                "operation": "gte"
+              }
+            }
+          ],
+          "combinator": "and"
+        },
+        "options": {}
+      },
+      "id": "0e74e010-e212-4d4f-ba8e-a0bdb8b8fa07",
+      "name": "is_send_msg",
+      "type": "n8n-nodes-base.if",
+      "typeVersion": 2,
+      "position": [
+        -240,
+        220
+      ]
+    },
+    {
+      "parameters": {
+        "httpMethod": "POST",
+        "path": "twitter/fail/test",
+        "authentication": "headerAuth",
+        "options": {
+          "allowedOrigins": "*",
+          "rawBody": false
+        }
+      },
+      "id": "8679281d-cd04-4c32-a53d-ed6b084d6479",
+      "name": "Webhook",
+      "type": "n8n-nodes-base.webhook",
+      "typeVersion": 2,
+      "position": [
+        -820,
+        360
+      ],
+      "webhookId": "e495a29c-8f43-4175-bdb8-277e03b60b07",
+      "credentials": {
+        "httpHeaderAuth": {
+          "id": "U87Wvnvu9oQ5Zapo",
+          "name": "Header Auth account"
+        }
+      }
+    }
+  ],
+  "connections": {
+    "insert_fail_log": {
+      "main": [
+        [
+          {
+            "node": "is_exists_warn_by_retry",
+            "type": "main",
+            "index": 0
+          },
+          {
+            "node": "is_exists_warn_other",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "get_msg_content": {
+      "main": [
+        [
+          {
+            "node": "send_msg",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "send_msg": {
+      "main": [
+        [
+          {
+            "node": "update_warn_info",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "get_rw_name": {
+      "main": [
+        [
+          {
+            "node": "get_msg_content",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "is_exists_warn_by_retry": {
+      "main": [
+        [
+          {
+            "node": "is_send_msg",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "is_exists_warn_other": {
+      "main": [
+        [
+          {
+            "node": "is_send_msg_judge",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "is_send_msg_judge": {
+      "main": [
+        [
+          {
+            "node": "get_rw_name",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "is_send_msg": {
+      "main": [
+        [
+          {
+            "node": "get_rw_name",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    },
+    "Webhook": {
+      "main": [
+        [
+          {
+            "node": "insert_fail_log",
+            "type": "main",
+            "index": 0
+          }
+        ]
+      ]
+    }
+  },
+  "settings": {
+    "executionOrder": "v1"
+  },
+  "staticData": null,
+  "meta": {
+    "templateCredsSetupCompleted": true
+  },
+  "pinData": {},
+  "versionId": "9fd2ea41-c2b3-4a6e-9523-1e3098eb4ba8",
+  "triggerCount": 1,
+  "shared": [
+    {
+      "createdAt": "2025-02-13T05:03:30.851Z",
+      "updatedAt": "2025-02-13T05:03:30.851Z",
+      "role": "workflow:owner",
+      "workflowId": "ZrKtEbhDs8yVpjUJ",
+      "projectId": "C7zKoCDdmGgzUqSW",
+      "project": {
+        "createdAt": "2024-08-23T06:31:21.275Z",
+        "updatedAt": "2024-08-23T06:41:43.608Z",
+        "id": "C7zKoCDdmGgzUqSW",
+        "name": "周 卫 <zhouwei@ssish.com>",
+        "type": "personal",
+        "projectRelations": [
+          {
+            "createdAt": "2024-08-23T06:31:21.275Z",
+            "updatedAt": "2024-08-23T06:31:21.275Z",
+            "role": "project:personalOwner",
+            "userId": "3f0021b4-d0a7-4db6-af21-5ef829c47882",
+            "projectId": "C7zKoCDdmGgzUqSW",
+            "user": {
+              "createdAt": "2024-08-23T06:31:16.119Z",
+              "updatedAt": "2025-03-19T06:19:26.514Z",
+              "id": "3f0021b4-d0a7-4db6-af21-5ef829c47882",
+              "email": "zhouwei@ssish.com",
+              "firstName": "周",
+              "lastName": "卫",
+              "personalizationAnswers": {
+                "companyType": "education",
+                "role": "business-owner",
+                "automationBeneficiary": "my-team",
+                "companySize": "20-99",
+                "reportedSource": "friend",
+                "version": "v4",
+                "personalization_survey_submitted_at": "2024-08-23T06:57:52.856Z",
+                "personalization_survey_n8n_version": "1.55.3"
+              },
+              "settings": {
+                "userActivated": true,
+                "firstSuccessfulWorkflowId": "s6zsznwVs6N4L2Hx",
+                "userActivatedAt": 1725957335278,
+                "npsSurvey": {
+                  "responded": true,
+                  "lastShownAt": 1742365155724
+                },
+                "isOnboarded": true
+              },
+              "role": "global:owner",
+              "disabled": false,
+              "mfaEnabled": false,
+              "isPending": false,
+              "isOwner": true
+            }
+          }
+        ]
+      }
+    }
+  ],
+  "tags": []
+}
\ No newline at end of file