refactor: HC-SUBワークフローを7ノード構成にリビルド
新プロジェクトルール(Data Table最小限・Code集約)に合わせ、旧19ノード版 (個別キーごとのData Table Get×7、HTTP Requestノード×6)を廃止。 設定値一括取得→Pleasanter照会・選択肢組み立て→JWTクレーム組み立て→ Sign JWT→アクセストークン取得・LINEWORKS送信→状態更新の7ノードに集約。 デプロイは行わず、ローカルJSON作成・検証のみ(コントローラーが同一ID XRqcykbG2LuAjGG2へPUTする想定)。 Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
This commit is contained in:
Kenichiro NOGI
parent
935e58e384
commit
675cf4a321
@ -30,10 +30,24 @@ Task 5（processFlow.js）の`getValidationColumnNames`はこの構造（`proces
|
|||||||
|
|
||||||
- ワークフロー `HC-SUB: プロセス実行と案内送信`: `XRqcykbG2LuAjGG2`
|
- ワークフロー `HC-SUB: プロセス実行と案内送信`: `XRqcykbG2LuAjGG2`
|
||||||
- ファイル: `workflows/hc-sub-run-process-and-notify.json`（Execute Workflow Trigger、入力`{resultId, processId}`）
|
- ファイル: `workflows/hc-sub-run-process-and-notify.json`（Execute Workflow Trigger、入力`{resultId, processId}`）
|
||||||
- active化済み（Execute Workflow Triggerサブワークフローは呼び出し元から実行可能にするためactive必須、`asKvC5LSVg3q8tuU`と同じ運用）
|
- **プロジェクト全体のn8nワークフロー構築ルール（2026-09-05改訂）に合わせて7ノード構成へ全面リビルド。旧19ノード版（個別キーごとのData Table Getノード×7、HTTP Requestノード×6を並べた構成）を置き換える。** 同じワークフローID`XRqcykbG2LuAjGG2`へのPUTで上書きする想定（デプロイはコントローラーが実施、本タスクではJSON作成・ローカル検証のみ）
|
||||||
- 秘密情報・SiteId等はすべて`workflow_config_values`（`bNkadTyDgDepYx2p`）から`Data Table`ノードで取得し式参照。ワークフローJSONに秘密値のハードコードなし
|
- active化済み（Execute Workflow Triggerサブワークフローは呼び出し元から実行可能にするためactive必須、`asKvC5LSVg3q8tuU`と同じ運用）— 再デプロイ後も設定は維持される想定
|
||||||
- 未検証の暫定実装あり（Task 12で要修正）: ①484184(`LINEWORKS_BOT_MASTER_SITE_ID`)からのBotId解決ロジック（実データ構造未調査のため`SiteSettings.BotIds`または`Processes[].BotId`を仮定し、無ければ例外を投げる）、②`/api/users/get`のレスポンス形状（配列/単一オブジェクト両対応の防御的実装）
|
- ノード構成（7ノード、リニア接続）:
|
||||||
- Step 4（実行テスト・LINEWORKS実送信）は本タスクでは未実施。次回、捨てレコードでの疎通確認とユーザー確認が必要
|
1. `Execute Workflow Trigger`（入力: `resultId`, `processId`）
|
||||||
|
2. `Data Table`「設定値一括取得」: `workflow_config_values`（`bNkadTyDgDepYx2p`）を`filters`無し・`returnAll:true`で一括取得（個別キーごとのGetノードを廃止）
|
||||||
|
3. `Code`「Pleasanter照会・選択肢組み立て」: 設定値のMap化、(任意)Process実行、レコード取得、サイト設定取得(getsite)、Botマスタ取得(484184)、対象者メール解決、選択肢組み立てまでを1ノードに集約。Pleasanter API呼び出しはすべて`this.helpers.httpRequest`（n8n Codeノード公式ヘルパー）で発行
|
||||||
|
4. `Code`「JWTクレーム組み立て」: JWTクレームJSON文字列の組み立てとLINEWORKS `button_template`のactions配列組み立てを1ノードに集約
|
||||||
|
5. `JWT`ノード「Sign JWT」（`operation: sign`, `algorithm: RS256`, Credential: 「LINEWORKS Bot Private Key (v4)」id `Hw0qlEaGfLPnQWp1`）
|
||||||
|
6. `Code`「アクセストークン取得・LINEWORKS送信」: LINEWORKSアクセストークン取得とメッセージ送信を1ノードに集約（`this.helpers.httpRequest`）
|
||||||
|
7. `Data Table`「状態更新」: `healthcheck_bot_state`（`jqMDa2YZTI4f0iQ7`）へ`insert`
|
||||||
|
- 秘密情報・SiteId等はすべて`workflow_config_values`（`bNkadTyDgDepYx2p`）から「設定値一括取得」1ノードで取得し、直後のCodeノードで`configKey`→`configValue`のMapに変換して参照。ワークフローJSONに秘密値のハードコードなし
|
||||||
|
- Execute Workflow Triggerの入力（`resultId`/`processId`）は、後続ノードの直接の入力でない箇所では必ず`$('Execute Workflow Trigger').item.json...`のようにノード名を明示して参照している（旧版にあった「Data Tableノード通過後に裸の`$json`を参照してしまうバグ」の再発防止）
|
||||||
|
- 未検証・要判断の暫定実装あり（Task 12以降で要確認）:
|
||||||
|
①484184(`LINEWORKS_BOT_MASTER_SITE_ID`)からのBotId解決ロジック（実データ構造未調査のため`SiteSettings.BotIds`または`Processes[].BotId`を仮定し、無ければ例外を投げる。「JWTクレーム組み立て」ノードに実装）
|
||||||
|
②`/api/users/get`のレスポンス形状（配列/単一オブジェクト両対応の防御的実装、「Pleasanter照会・選択肢組み立て」ノードに実装）
|
||||||
|
③LINEWORKS token/message呼び出しを`this.helpers.httpRequest`で行う際のform-urlencodedボディの正しい渡し方（`URLSearchParams`文字列＋`Content-Type`ヘッダー明示という実装にしたが、n8n本体でこの組み合わせが期待通り動くかは実機未検証。ダメな場合は`n8n-nodes-base.httpRequest`ノードの`contentType: "form-urlencoded"`に戻す変更で対応）
|
||||||
|
④`Data Table`Insertノードの`columns.mappingMode`/`value`/`schema`の形状（旧19ノード版から流用。旧版はデプロイ実績があるためスキーマ自体は疑わしくないが、実書き込みでの動作は本タスクでは未再検証）
|
||||||
|
- テスト実行（Step 4相当）は本タスクでは未実施。次回、捨てレコードでの疎通確認とユーザー確認が必要
|
||||||
|
|
||||||
- ワークフロー `HC-WP: Statusプッシュ通知`: `swXfpoDtwZDT3Hwk`
|
- ワークフロー `HC-WP: Statusプッシュ通知`: `swXfpoDtwZDT3Hwk`
|
||||||
- ファイル: `workflows/hc-wp-status-push.json`
|
- ファイル: `workflows/hc-wp-status-push.json`
|
||||||
|
|||||||
@ -24,8 +24,8 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"id": "dt-get-pleasanter_base_url_prod",
|
"id": "dt-get-config",
|
||||||
"name": "PLEASANTER_BASE_URL取得",
|
"name": "設定値一括取得",
|
||||||
"type": "n8n-nodes-base.dataTable",
|
"type": "n8n-nodes-base.dataTable",
|
||||||
"typeVersion": 1,
|
"typeVersion": 1,
|
||||||
"position": [
|
"position": [
|
||||||
@ -39,314 +39,20 @@
|
|||||||
"mode": "id",
|
"mode": "id",
|
||||||
"value": "bNkadTyDgDepYx2p"
|
"value": "bNkadTyDgDepYx2p"
|
||||||
},
|
},
|
||||||
"filters": {
|
|
||||||
"conditions": [
|
|
||||||
{
|
|
||||||
"keyName": "configKey",
|
|
||||||
"keyValue": "PLEASANTER_BASE_URL_PROD"
|
|
||||||
}
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"returnAll": true
|
"returnAll": true
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"id": "dt-get-pleasanter_api_key_prod",
|
"id": "code-pleasanter-query",
|
||||||
"name": "PLEASANTER_API_KEY取得",
|
"name": "Pleasanter照会・選択肢組み立て",
|
||||||
"type": "n8n-nodes-base.dataTable",
|
"type": "n8n-nodes-base.code",
|
||||||
"typeVersion": 1,
|
"typeVersion": 2,
|
||||||
"position": [
|
"position": [
|
||||||
660,
|
660,
|
||||||
300
|
300
|
||||||
],
|
],
|
||||||
"parameters": {
|
"parameters": {
|
||||||
"operation": "get",
|
"jsCode": "function isUnsetSentinel(value) {\n return typeof value === \"string\" && value.startsWith(\"1899\");\n}\nfunction fillTemplate(template, columns, valueHash) {\n const labelToColumnName = new Map();\n for (const column of columns) {\n if (column.LabelText) labelToColumnName.set(column.LabelText, column.ColumnName);\n }\n return template.replace(/\\{([^{}]+)\\}/g, (matched, label) => {\n const columnName = labelToColumnName.get(label);\n if (!columnName) return matched;\n const value = valueHash[columnName];\n if (value === undefined || value === null || value === \"\" || isUnsetSentinel(value)) return \"未設定\";\n return String(value);\n });\n}\nfunction extractProcessesForStatus(processes, status) {\n return processes.filter((p) => p.CurrentStatus === status || p.CurrentStatus === -1);\n}\n\nconst configRows = $('設定値一括取得').all().map((item) => item.json);\nconst config = Object.fromEntries(configRows.map((row) => [row.configKey, row.configValue]));\n\nconst trigger = $('Execute Workflow Trigger').item.json;\nconst baseUrl = config.PLEASANTER_BASE_URL_PROD;\nconst apiKey = config.PLEASANTER_API_KEY_PROD;\n\nasync function pleasanterPost(path, body) {\n const res = await this.helpers.httpRequest({\n method: \"POST\",\n url: `${baseUrl}${path}`,\n body: { ApiVersion: 1.1, ApiKey: apiKey, ...body },\n json: true,\n });\n return res;\n}\n\nif (trigger.processId) {\n await pleasanterPost.call(this, `api/items/${trigger.resultId}/update`, { ProcessId: trigger.processId });\n}\n\nconst recordRes = await pleasanterPost.call(this, `api/items/${trigger.resultId}/get`, {});\nconst record = recordRes.Response.Data;\n\nconst siteRes = await pleasanterPost.call(this, `api/items/${config.HEALTHCHECK_SITE_ID}/getsite`, {});\nconst siteSettings = siteRes.Response.Data.SiteSettings;\nconst columns = siteSettings.Columns || [];\nconst processes = siteSettings.Processes || [];\n\nconst botMasterRes = await pleasanterPost.call(this, `api/items/${config.LINEWORKS_BOT_MASTER_SITE_ID}/getsite`, {});\n// TODO(Task 12): 484184(LINEWORKS_BOT_MASTER_SITE_ID)の実データ構造を見てBotIdの解決方法を確定させる。\n// 暫定: SiteSettings.BotIds配列 または Processes[].BotId のいずれかを想定し、\n// 生データのまま後段(JWTクレーム組み立て)へ渡して解決する。\nconst botMasterSiteSettings = botMasterRes.Response.Data.SiteSettings;\n\nconst valueHash = {\n ...record.ClassHash, ...record.NumHash, ...record.DateHash, ...record.DescriptionHash,\n};\n\nconst candidates = extractProcessesForStatus(processes, record.Status);\nconst options = candidates.map((p) => ({\n processId: p.Id,\n label: p.DisplayName || p.Name,\n tooltip: fillTemplate(p.ToolTip || \"\", columns, valueHash),\n}));\n\nconst userRes = await pleasanterPost.call(this, `api/users/get`, {\n View: { ApiGetMailAddresses: true },\n Where: { UserId: record.ClassHash.ClassC },\n});\n// Pleasanter /api/users/get のレスポンス形状は実機未検証のため、配列/単一\n// オブジェクトどちらでも動くように防御的に処理する。\nconst usersResponseData = userRes.Response.Data;\nconst userRecord = Array.isArray(usersResponseData) ? usersResponseData[0] : usersResponseData;\nconst targetEmail = userRecord && (userRecord.MailAddress\n || (Array.isArray(userRecord.MailAddresses) && userRecord.MailAddresses[0]));\nif (!targetEmail) {\n throw new Error('対象者のメールアドレスを解決できませんでした。');\n}\n\nreturn [{\n json: {\n resultId: record.ResultId,\n currentStatus: record.Status,\n options,\n targetEmail,\n config,\n botMasterSiteSettings,\n },\n}];"
|
||||||
"dataTableId": {
|
|
||||||
"__rl": true,
|
|
||||||
"mode": "id",
|
|
||||||
"value": "bNkadTyDgDepYx2p"
|
|
||||||
},
|
|
||||||
"filters": {
|
|
||||||
"conditions": [
|
|
||||||
{
|
|
||||||
"keyName": "configKey",
|
|
||||||
"keyValue": "PLEASANTER_API_KEY_PROD"
|
|
||||||
}
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"returnAll": true
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"id": "dt-get-healthcheck_site_id",
|
|
||||||
"name": "HEALTHCHECK_SITE_ID取得",
|
|
||||||
"type": "n8n-nodes-base.dataTable",
|
|
||||||
"typeVersion": 1,
|
|
||||||
"position": [
|
|
||||||
880,
|
|
||||||
300
|
|
||||||
],
|
|
||||||
"parameters": {
|
|
||||||
"operation": "get",
|
|
||||||
"dataTableId": {
|
|
||||||
"__rl": true,
|
|
||||||
"mode": "id",
|
|
||||||
"value": "bNkadTyDgDepYx2p"
|
|
||||||
},
|
|
||||||
"filters": {
|
|
||||||
"conditions": [
|
|
||||||
{
|
|
||||||
"keyName": "configKey",
|
|
||||||
"keyValue": "HEALTHCHECK_SITE_ID"
|
|
||||||
}
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"returnAll": true
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"id": "if-processid-exists",
|
|
||||||
"name": "IF processId exists",
|
|
||||||
"type": "n8n-nodes-base.if",
|
|
||||||
"typeVersion": 2,
|
|
||||||
"position": [
|
|
||||||
1100,
|
|
||||||
300
|
|
||||||
],
|
|
||||||
"parameters": {
|
|
||||||
"conditions": {
|
|
||||||
"options": {
|
|
||||||
"caseSensitive": true,
|
|
||||||
"leftValue": "",
|
|
||||||
"typeValidation": "loose",
|
|
||||||
"version": 2
|
|
||||||
},
|
|
||||||
"conditions": [
|
|
||||||
{
|
|
||||||
"id": "cond-processid-truthy",
|
|
||||||
"leftValue": "={{ !!$('Execute Workflow Trigger').item.json.processId }}",
|
|
||||||
"rightValue": true,
|
|
||||||
"operator": {
|
|
||||||
"type": "boolean",
|
|
||||||
"operation": "true",
|
|
||||||
"singleValue": true
|
|
||||||
}
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"combinator": "and"
|
|
||||||
},
|
|
||||||
"options": {}
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"id": "http-process-run",
|
|
||||||
"name": "Process実行",
|
|
||||||
"type": "n8n-nodes-base.httpRequest",
|
|
||||||
"typeVersion": 4.2,
|
|
||||||
"position": [
|
|
||||||
1320,
|
|
||||||
300
|
|
||||||
],
|
|
||||||
"parameters": {
|
|
||||||
"method": "POST",
|
|
||||||
"url": "={{ $('PLEASANTER_BASE_URL取得').item.json.configValue }}api/items/{{ $('Execute Workflow Trigger').item.json.resultId }}/update",
|
|
||||||
"sendBody": true,
|
|
||||||
"specifyBody": "json",
|
|
||||||
"jsonBody": "={{ JSON.stringify({ ApiVersion: 1.1, ApiKey: $('PLEASANTER_API_KEY取得').item.json.configValue, ProcessId: Number($('Execute Workflow Trigger').item.json.processId) }) }}",
|
|
||||||
"options": {}
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"id": "http-record-get",
|
|
||||||
"name": "レコード取得",
|
|
||||||
"type": "n8n-nodes-base.httpRequest",
|
|
||||||
"typeVersion": 4.2,
|
|
||||||
"position": [
|
|
||||||
1540,
|
|
||||||
300
|
|
||||||
],
|
|
||||||
"parameters": {
|
|
||||||
"method": "POST",
|
|
||||||
"url": "={{ $('PLEASANTER_BASE_URL取得').item.json.configValue }}api/items/{{ $('Execute Workflow Trigger').item.json.resultId }}/get",
|
|
||||||
"sendBody": true,
|
|
||||||
"specifyBody": "json",
|
|
||||||
"jsonBody": "={{ JSON.stringify({ ApiVersion: 1.1, ApiKey: $('PLEASANTER_API_KEY取得').item.json.configValue }) }}",
|
|
||||||
"options": {}
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"id": "http-site-settings-get",
|
|
||||||
"name": "サイト設定取得",
|
|
||||||
"type": "n8n-nodes-base.httpRequest",
|
|
||||||
"typeVersion": 4.2,
|
|
||||||
"position": [
|
|
||||||
1760,
|
|
||||||
300
|
|
||||||
],
|
|
||||||
"parameters": {
|
|
||||||
"method": "POST",
|
|
||||||
"url": "={{ $('PLEASANTER_BASE_URL取得').item.json.configValue }}api/items/{{ $('HEALTHCHECK_SITE_ID取得').item.json.configValue }}/getsite",
|
|
||||||
"sendBody": true,
|
|
||||||
"specifyBody": "json",
|
|
||||||
"jsonBody": "={{ JSON.stringify({ ApiVersion: 1.1, ApiKey: $('PLEASANTER_API_KEY取得').item.json.configValue }) }}",
|
|
||||||
"options": {}
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"id": "code-build-options",
|
|
||||||
"name": "選択肢組み立て",
|
|
||||||
"type": "n8n-nodes-base.code",
|
|
||||||
"typeVersion": 2,
|
|
||||||
"position": [
|
|
||||||
1980,
|
|
||||||
300
|
|
||||||
],
|
|
||||||
"parameters": {
|
|
||||||
"jsCode": "function isUnsetSentinel(value) {\n return typeof value === \"string\" && value.startsWith(\"1899\");\n}\nfunction fillTemplate(template, columns, valueHash) {\n const labelToColumnName = new Map();\n for (const column of columns) {\n if (column.LabelText) labelToColumnName.set(column.LabelText, column.ColumnName);\n }\n return template.replace(/\\{([^{}]+)\\}/g, (matched, label) => {\n const columnName = labelToColumnName.get(label);\n if (!columnName) return matched;\n const value = valueHash[columnName];\n if (value === undefined || value === null || value === \"\" || isUnsetSentinel(value)) return \"未設定\";\n return String(value);\n });\n}\nfunction extractProcessesForStatus(processes, status) {\n return processes.filter((p) => p.CurrentStatus === status || p.CurrentStatus === -1);\n}\n\nconst record = $('レコード取得').item.json.Response.Data;\nconst siteSettings = $('サイト設定取得').item.json.Response.Data.SiteSettings;\nconst columns = siteSettings.Columns || [];\nconst processes = siteSettings.Processes || [];\n\nconst valueHash = {\n ...record.ClassHash, ...record.NumHash, ...record.DateHash, ...record.DescriptionHash,\n};\n\nconst candidates = extractProcessesForStatus(processes, record.Status);\nconst options = candidates.map((p) => ({\n processId: p.Id,\n label: p.DisplayName || p.Name,\n tooltip: fillTemplate(p.ToolTip || \"\", columns, valueHash),\n}));\n\nreturn [{\n json: {\n resultId: record.ResultId,\n currentStatus: record.Status,\n options,\n classCUserId: record.ClassHash.ClassC,\n },\n}];"
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"id": "dt-get-lw_bot_client_id",
|
|
||||||
"name": "LW_BOT_CLIENT_ID取得",
|
|
||||||
"type": "n8n-nodes-base.dataTable",
|
|
||||||
"typeVersion": 1,
|
|
||||||
"position": [
|
|
||||||
2200,
|
|
||||||
300
|
|
||||||
],
|
|
||||||
"parameters": {
|
|
||||||
"operation": "get",
|
|
||||||
"dataTableId": {
|
|
||||||
"__rl": true,
|
|
||||||
"mode": "id",
|
|
||||||
"value": "bNkadTyDgDepYx2p"
|
|
||||||
},
|
|
||||||
"filters": {
|
|
||||||
"conditions": [
|
|
||||||
{
|
|
||||||
"keyName": "configKey",
|
|
||||||
"keyValue": "LW_BOT_CLIENT_ID"
|
|
||||||
}
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"returnAll": true
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"id": "dt-get-lw_bot_client_secret",
|
|
||||||
"name": "LW_BOT_CLIENT_SECRET取得",
|
|
||||||
"type": "n8n-nodes-base.dataTable",
|
|
||||||
"typeVersion": 1,
|
|
||||||
"position": [
|
|
||||||
2420,
|
|
||||||
300
|
|
||||||
],
|
|
||||||
"parameters": {
|
|
||||||
"operation": "get",
|
|
||||||
"dataTableId": {
|
|
||||||
"__rl": true,
|
|
||||||
"mode": "id",
|
|
||||||
"value": "bNkadTyDgDepYx2p"
|
|
||||||
},
|
|
||||||
"filters": {
|
|
||||||
"conditions": [
|
|
||||||
{
|
|
||||||
"keyName": "configKey",
|
|
||||||
"keyValue": "LW_BOT_CLIENT_SECRET"
|
|
||||||
}
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"returnAll": true
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"id": "dt-get-lw_bot_service_account",
|
|
||||||
"name": "LW_BOT_SERVICE_ACCOUNT取得",
|
|
||||||
"type": "n8n-nodes-base.dataTable",
|
|
||||||
"typeVersion": 1,
|
|
||||||
"position": [
|
|
||||||
2640,
|
|
||||||
300
|
|
||||||
],
|
|
||||||
"parameters": {
|
|
||||||
"operation": "get",
|
|
||||||
"dataTableId": {
|
|
||||||
"__rl": true,
|
|
||||||
"mode": "id",
|
|
||||||
"value": "bNkadTyDgDepYx2p"
|
|
||||||
},
|
|
||||||
"filters": {
|
|
||||||
"conditions": [
|
|
||||||
{
|
|
||||||
"keyName": "configKey",
|
|
||||||
"keyValue": "LW_BOT_SERVICE_ACCOUNT"
|
|
||||||
}
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"returnAll": true
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"id": "dt-get-lineworks_bot_master_site_id",
|
|
||||||
"name": "LINEWORKS_BOT_MASTER_SITE_ID取得",
|
|
||||||
"type": "n8n-nodes-base.dataTable",
|
|
||||||
"typeVersion": 1,
|
|
||||||
"position": [
|
|
||||||
2860,
|
|
||||||
300
|
|
||||||
],
|
|
||||||
"parameters": {
|
|
||||||
"operation": "get",
|
|
||||||
"dataTableId": {
|
|
||||||
"__rl": true,
|
|
||||||
"mode": "id",
|
|
||||||
"value": "bNkadTyDgDepYx2p"
|
|
||||||
},
|
|
||||||
"filters": {
|
|
||||||
"conditions": [
|
|
||||||
{
|
|
||||||
"keyName": "configKey",
|
|
||||||
"keyValue": "LINEWORKS_BOT_MASTER_SITE_ID"
|
|
||||||
}
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"returnAll": true
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"id": "http-bot-master-get",
|
|
||||||
"name": "Botマスタ取得",
|
|
||||||
"type": "n8n-nodes-base.httpRequest",
|
|
||||||
"typeVersion": 4.2,
|
|
||||||
"position": [
|
|
||||||
3080,
|
|
||||||
300
|
|
||||||
],
|
|
||||||
"parameters": {
|
|
||||||
"method": "POST",
|
|
||||||
"url": "={{ $('PLEASANTER_BASE_URL取得').item.json.configValue }}api/items/{{ $('LINEWORKS_BOT_MASTER_SITE_ID取得').item.json.configValue }}/getsite",
|
|
||||||
"sendBody": true,
|
|
||||||
"specifyBody": "json",
|
|
||||||
"jsonBody": "={{ JSON.stringify({ ApiVersion: 1.1, ApiKey: $('PLEASANTER_API_KEY取得').item.json.configValue }) }}",
|
|
||||||
"options": {}
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"id": "http-target-user-get",
|
|
||||||
"name": "対象者メール解決",
|
|
||||||
"type": "n8n-nodes-base.httpRequest",
|
|
||||||
"typeVersion": 4.2,
|
|
||||||
"position": [
|
|
||||||
3300,
|
|
||||||
300
|
|
||||||
],
|
|
||||||
"parameters": {
|
|
||||||
"method": "POST",
|
|
||||||
"url": "={{ $('PLEASANTER_BASE_URL取得').item.json.configValue }}api/users/get",
|
|
||||||
"sendBody": true,
|
|
||||||
"specifyBody": "json",
|
|
||||||
"jsonBody": "={{ JSON.stringify({ ApiVersion: 1.1, ApiKey: $('PLEASANTER_API_KEY取得').item.json.configValue, View: { ApiGetMailAddresses: true }, Where: { UserId: $('選択肢組み立て').item.json.classCUserId } }) }}",
|
|
||||||
"options": {}
|
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
@ -355,11 +61,11 @@
|
|||||||
"type": "n8n-nodes-base.code",
|
"type": "n8n-nodes-base.code",
|
||||||
"typeVersion": 2,
|
"typeVersion": 2,
|
||||||
"position": [
|
"position": [
|
||||||
3520,
|
880,
|
||||||
300
|
300
|
||||||
],
|
],
|
||||||
"parameters": {
|
"parameters": {
|
||||||
"jsCode": "const now = Math.floor(Date.now() / 1000);\nconst jwtClaims = JSON.stringify({\n iss: $('LW_BOT_CLIENT_ID取得').item.json.configValue,\n sub: $('LW_BOT_SERVICE_ACCOUNT取得').item.json.configValue,\n iat: now,\n exp: now + 3600,\n aud: 'https://auth.worksmobile.com/oauth2/v2.0/token',\n});\n\n// --- Bot ID解決 ---\n// TODO(Task 12): 484184(LINEWORKS_BOT_MASTER_SITE_ID)の実データ構造は未調査\n// (このワークフローは新規追加のBrief上、実データ確認前に構築している)。\n// Task 12で508971のProcess⇔Bot対応表を設計する際、実データに合わせて\n// この関数を書き換えるか、Execute Workflow Triggerの入力にbotIdを追加して\n// 呼び出し元(WP/WA)から明示的に渡す方式へ変更すること。\n// 暫定実装: getsiteのSiteSettings直下にBotIds配列がある、または\n// Processes[].BotIdが定義されているケースを想定し、最初の1件を採用する。\n// どちらの構造も無ければ、誤ったBotへの送信を避けるため明示的にエラーとする。\nconst botMasterSiteSettings = $('Botマスタ取得').item.json.Response.Data.SiteSettings;\nconst candidateBotIds = botMasterSiteSettings.BotIds\n || (botMasterSiteSettings.Processes || []).map((p) => p.BotId).filter(Boolean);\nconst botId = candidateBotIds && candidateBotIds[0];\nif (!botId) {\n throw new Error('BotIdを484184(LINEWORKS_BOT_MASTER_SITE_ID)から解決できませんでした。Task 12でBot選択ロジックを実装してください。');\n}\n\n// --- 送信先メールアドレス解決 ---\n// Pleasanter /api/users/get のレスポンス形状は実機未検証のため、配列/単一\n// オブジェクトどちらでも動くように防御的に処理する。\nconst usersResponseData = $('対象者メール解決').item.json.Response.Data;\nconst userRecord = Array.isArray(usersResponseData) ? usersResponseData[0] : usersResponseData;\nif (!userRecord) {\n throw new Error('対象者メール解決レスポンスからユーザー情報を取得できませんでした。');\n}\nconst targetEmail = userRecord.MailAddress\n || (Array.isArray(userRecord.MailAddresses) && userRecord.MailAddresses[0])\n || null;\nif (!targetEmail) {\n throw new Error('対象者のメールアドレスを解決できませんでした。');\n}\n\nconst apiUrl = `https://www.worksapis.com/v1.0/bots/${botId}/users/${targetEmail}/messages`;\n\n// --- button_template組み立て ---\nconst options = $('選択肢組み立て').item.json.options;\nconst resultId = $('選択肢組み立て').item.json.resultId;\nconst actions = options.map((opt) => ({\n type: 'message',\n label: opt.label,\n postback: JSON.stringify({ resultId, processId: opt.processId }),\n displayText: opt.label,\n}));\n\nconst messageContent = {\n type: 'button_template',\n contentText: options.map((opt) => `${opt.label}: ${opt.tooltip}`).join('\\n') || '対応可能な操作がありません',\n actions,\n};\n\nreturn [{\n json: {\n jwtClaims,\n apiUrl,\n messageContent,\n targetEmail,\n resultId,\n },\n}];"
|
"jsCode": "const now = Math.floor(Date.now() / 1000);\nconst { config, botMasterSiteSettings, options, resultId, currentStatus, targetEmail } = $json;\n\nconst jwtClaims = JSON.stringify({\n iss: config.LW_BOT_CLIENT_ID,\n sub: config.LW_BOT_SERVICE_ACCOUNT,\n iat: now,\n exp: now + 3600,\n aud: 'https://auth.worksmobile.com/oauth2/v2.0/token',\n});\n\n// --- Bot ID解決 ---\n// TODO(Task 12): 484184(LINEWORKS_BOT_MASTER_SITE_ID)の実データ構造は未調査\n// (このワークフローは実データ確認前に構築している)。\n// Task 12で508971のProcess⇔Bot対応表を設計する際、実データに合わせて\n// この解決方法を書き換えるか、Execute Workflow Triggerの入力にbotIdを追加して\n// 呼び出し元(WP/WA)から明示的に渡す方式へ変更すること。\n// 暫定実装: getsiteのSiteSettings直下にBotIds配列がある、または\n// Processes[].BotIdが定義されているケースを想定し、最初の1件を採用する。\n// どちらの構造も無ければ、誤ったBotへの送信を避けるため明示的にエラーとする。\nconst candidateBotIds = botMasterSiteSettings.BotIds\n || (botMasterSiteSettings.Processes || []).map((p) => p.BotId).filter(Boolean);\nconst botId = candidateBotIds && candidateBotIds[0];\nif (!botId) {\n throw new Error('BotIdを484184(LINEWORKS_BOT_MASTER_SITE_ID)から解決できませんでした。Task 12でBot選択ロジックを実装してください。');\n}\n\nconst apiUrl = `https://www.worksapis.com/v1.0/bots/${botId}/users/${targetEmail}/messages`;\n\n// --- button_template組み立て ---\nconst actions = options.map((opt) => ({\n type: 'message',\n label: opt.label,\n postback: JSON.stringify({ resultId, processId: opt.processId }),\n displayText: opt.label,\n}));\n\nconst messageContent = {\n type: 'button_template',\n contentText: options.map((opt) => `${opt.label}: ${opt.tooltip}`).join('\\n') || '対応可能な操作がありません',\n actions,\n};\n\nreturn [{\n json: {\n jwtClaims,\n apiUrl,\n messageContent,\n targetEmail,\n resultId,\n currentStatus,\n options,\n config,\n },\n}];"
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
@ -368,7 +74,7 @@
|
|||||||
"type": "n8n-nodes-base.jwt",
|
"type": "n8n-nodes-base.jwt",
|
||||||
"typeVersion": 1,
|
"typeVersion": 1,
|
||||||
"position": [
|
"position": [
|
||||||
3740,
|
1100,
|
||||||
300
|
300
|
||||||
],
|
],
|
||||||
"parameters": {
|
"parameters": {
|
||||||
@ -387,75 +93,16 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
"id": "http-access-token",
|
"id": "code-lineworks-send",
|
||||||
"name": "アクセストークン取得",
|
"name": "アクセストークン取得・LINEWORKS送信",
|
||||||
"type": "n8n-nodes-base.httpRequest",
|
"type": "n8n-nodes-base.code",
|
||||||
"typeVersion": 4.2,
|
"typeVersion": 2,
|
||||||
"position": [
|
"position": [
|
||||||
3960,
|
1320,
|
||||||
300
|
300
|
||||||
],
|
],
|
||||||
"parameters": {
|
"parameters": {
|
||||||
"method": "POST",
|
"jsCode": "const claims = $('JWTクレーム組み立て').item.json;\nconst config = claims.config;\nconst assertion = $json.token;\n\n// LINEWORKS token/message呼び出しはx-www-form-urlencoded / JSONのどちらも\n// this.helpers.httpRequestのbodyに素の値を渡す形は実機未検証のため、\n// URLSearchParamsで明示的にエンコードしてContent-Typeも明示する。\nconst tokenBody = new URLSearchParams({\n assertion,\n grant_type: 'urn:ietf:params:oauth:grant-type:jwt-bearer',\n client_id: config.LW_BOT_CLIENT_ID,\n client_secret: config.LW_BOT_CLIENT_SECRET,\n scope: 'bot',\n}).toString();\n\nconst tokenRes = await this.helpers.httpRequest({\n method: 'POST',\n url: 'https://auth.worksmobile.com/oauth2/v2.0/token',\n headers: { 'Content-Type': 'application/x-www-form-urlencoded' },\n body: tokenBody,\n json: true,\n});\nconst accessToken = tokenRes.access_token;\nif (!accessToken) {\n throw new Error('LINEWORKSアクセストークンの取得に失敗しました。');\n}\n\nconst sendRes = await this.helpers.httpRequest({\n method: 'POST',\n url: claims.apiUrl,\n headers: {\n Authorization: `Bearer ${accessToken}`,\n 'Content-Type': 'application/json;charset=UTF-8',\n },\n body: { content: claims.messageContent },\n json: true,\n});\n\nreturn [{\n json: {\n resultId: claims.resultId,\n currentStatus: claims.currentStatus,\n options: claims.options,\n targetEmail: claims.targetEmail,\n lineworksResponse: sendRes,\n },\n}];"
|
||||||
"url": "https://auth.worksmobile.com/oauth2/v2.0/token",
|
|
||||||
"sendBody": true,
|
|
||||||
"contentType": "form-urlencoded",
|
|
||||||
"bodyParameters": {
|
|
||||||
"parameters": [
|
|
||||||
{
|
|
||||||
"name": "assertion",
|
|
||||||
"value": "={{ $json.token }}"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"name": "grant_type",
|
|
||||||
"value": "urn:ietf:params:oauth:grant-type:jwt-bearer"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"name": "client_id",
|
|
||||||
"value": "={{ $('LW_BOT_CLIENT_ID取得').item.json.configValue }}"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"name": "client_secret",
|
|
||||||
"value": "={{ $('LW_BOT_CLIENT_SECRET取得').item.json.configValue }}"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"name": "scope",
|
|
||||||
"value": "bot"
|
|
||||||
}
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"options": {}
|
|
||||||
}
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"id": "http-lineworks-send",
|
|
||||||
"name": "LINEWORKS送信",
|
|
||||||
"type": "n8n-nodes-base.httpRequest",
|
|
||||||
"typeVersion": 4.2,
|
|
||||||
"position": [
|
|
||||||
4180,
|
|
||||||
300
|
|
||||||
],
|
|
||||||
"parameters": {
|
|
||||||
"method": "POST",
|
|
||||||
"url": "={{ $('JWTクレーム組み立て').item.json.apiUrl }}",
|
|
||||||
"sendHeaders": true,
|
|
||||||
"headerParameters": {
|
|
||||||
"parameters": [
|
|
||||||
{
|
|
||||||
"name": "Authorization",
|
|
||||||
"value": "=Bearer {{ $json.access_token }}"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"name": "Content-Type",
|
|
||||||
"value": "application/json;charset=UTF-8"
|
|
||||||
}
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"sendBody": true,
|
|
||||||
"specifyBody": "json",
|
|
||||||
"jsonBody": "={{ JSON.stringify({ content: $('JWTクレーム組み立て').item.json.messageContent }) }}",
|
|
||||||
"options": {}
|
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
@ -464,7 +111,7 @@
|
|||||||
"type": "n8n-nodes-base.dataTable",
|
"type": "n8n-nodes-base.dataTable",
|
||||||
"typeVersion": 1,
|
"typeVersion": 1,
|
||||||
"position": [
|
"position": [
|
||||||
4400,
|
1540,
|
||||||
300
|
300
|
||||||
],
|
],
|
||||||
"parameters": {
|
"parameters": {
|
||||||
@ -477,10 +124,10 @@
|
|||||||
"columns": {
|
"columns": {
|
||||||
"mappingMode": "defineBelow",
|
"mappingMode": "defineBelow",
|
||||||
"value": {
|
"value": {
|
||||||
"resultId": "={{ $('選択肢組み立て').item.json.resultId }}",
|
"resultId": "={{ $json.resultId }}",
|
||||||
"targetEmail": "={{ $('JWTクレーム組み立て').item.json.targetEmail }}",
|
"targetEmail": "={{ $json.targetEmail }}",
|
||||||
"currentStatus": "={{ String($('選択肢組み立て').item.json.currentStatus) }}",
|
"currentStatus": "={{ String($json.currentStatus) }}",
|
||||||
"pendingProcesses": "={{ JSON.stringify($('選択肢組み立て').item.json.options) }}",
|
"pendingProcesses": "={{ JSON.stringify($json.options) }}",
|
||||||
"awaitInput": "none",
|
"awaitInput": "none",
|
||||||
"awaitProcessId": "",
|
"awaitProcessId": "",
|
||||||
"awaitColumn": ""
|
"awaitColumn": ""
|
||||||
@ -545,164 +192,25 @@
|
|||||||
"main": [
|
"main": [
|
||||||
[
|
[
|
||||||
{
|
{
|
||||||
"node": "PLEASANTER_BASE_URL取得",
|
"node": "設定値一括取得",
|
||||||
"type": "main",
|
"type": "main",
|
||||||
"index": 0
|
"index": 0
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
"PLEASANTER_BASE_URL取得": {
|
"設定値一括取得": {
|
||||||
"main": [
|
"main": [
|
||||||
[
|
[
|
||||||
{
|
{
|
||||||
"node": "PLEASANTER_API_KEY取得",
|
"node": "Pleasanter照会・選択肢組み立て",
|
||||||
"type": "main",
|
"type": "main",
|
||||||
"index": 0
|
"index": 0
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
"PLEASANTER_API_KEY取得": {
|
"Pleasanter照会・選択肢組み立て": {
|
||||||
"main": [
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"node": "HEALTHCHECK_SITE_ID取得",
|
|
||||||
"type": "main",
|
|
||||||
"index": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"HEALTHCHECK_SITE_ID取得": {
|
|
||||||
"main": [
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"node": "IF processId exists",
|
|
||||||
"type": "main",
|
|
||||||
"index": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"IF processId exists": {
|
|
||||||
"main": [
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"node": "Process実行",
|
|
||||||
"type": "main",
|
|
||||||
"index": 0
|
|
||||||
}
|
|
||||||
],
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"node": "レコード取得",
|
|
||||||
"type": "main",
|
|
||||||
"index": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"Process実行": {
|
|
||||||
"main": [
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"node": "レコード取得",
|
|
||||||
"type": "main",
|
|
||||||
"index": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"レコード取得": {
|
|
||||||
"main": [
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"node": "サイト設定取得",
|
|
||||||
"type": "main",
|
|
||||||
"index": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"サイト設定取得": {
|
|
||||||
"main": [
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"node": "選択肢組み立て",
|
|
||||||
"type": "main",
|
|
||||||
"index": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"選択肢組み立て": {
|
|
||||||
"main": [
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"node": "LW_BOT_CLIENT_ID取得",
|
|
||||||
"type": "main",
|
|
||||||
"index": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"LW_BOT_CLIENT_ID取得": {
|
|
||||||
"main": [
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"node": "LW_BOT_CLIENT_SECRET取得",
|
|
||||||
"type": "main",
|
|
||||||
"index": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"LW_BOT_CLIENT_SECRET取得": {
|
|
||||||
"main": [
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"node": "LW_BOT_SERVICE_ACCOUNT取得",
|
|
||||||
"type": "main",
|
|
||||||
"index": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"LW_BOT_SERVICE_ACCOUNT取得": {
|
|
||||||
"main": [
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"node": "LINEWORKS_BOT_MASTER_SITE_ID取得",
|
|
||||||
"type": "main",
|
|
||||||
"index": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"LINEWORKS_BOT_MASTER_SITE_ID取得": {
|
|
||||||
"main": [
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"node": "Botマスタ取得",
|
|
||||||
"type": "main",
|
|
||||||
"index": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"Botマスタ取得": {
|
|
||||||
"main": [
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"node": "対象者メール解決",
|
|
||||||
"type": "main",
|
|
||||||
"index": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"対象者メール解決": {
|
|
||||||
"main": [
|
"main": [
|
||||||
[
|
[
|
||||||
{
|
{
|
||||||
@ -728,25 +236,14 @@
|
|||||||
"main": [
|
"main": [
|
||||||
[
|
[
|
||||||
{
|
{
|
||||||
"node": "アクセストークン取得",
|
"node": "アクセストークン取得・LINEWORKS送信",
|
||||||
"type": "main",
|
"type": "main",
|
||||||
"index": 0
|
"index": 0
|
||||||
}
|
}
|
||||||
]
|
]
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
"アクセストークン取得": {
|
"アクセストークン取得・LINEWORKS送信": {
|
||||||
"main": [
|
|
||||||
[
|
|
||||||
{
|
|
||||||
"node": "LINEWORKS送信",
|
|
||||||
"type": "main",
|
|
||||||
"index": 0
|
|
||||||
}
|
|
||||||
]
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"LINEWORKS送信": {
|
|
||||||
"main": [
|
"main": [
|
||||||
[
|
[
|
||||||
{
|
{
|
||||||
@ -761,4 +258,4 @@
|
|||||||
"settings": {
|
"settings": {
|
||||||
"executionOrder": "v1"
|
"executionOrder": "v1"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user