ゴミプロジェクト

プログラム

6/8 2025
Doyolab


/**
 * LINE Messaging APIからのWebhookリクエストを処理する。
 * 画像メッセージを受信し、ChatGPT Visionで品名と特徴を特定後、
 * 横浜市ルールスプレッドシートの中からキーワード検索（全一致・部分一致）でルールを選択し分別情報を返す。
 * 該当候補が複数ある場合は品目名をリストで提示後、選択ボタンを送信する。見つからない場合はその旨を伝える。
 * 返信には参照したスプレッドシートの行番号（該当する場合）と検索方法を含める。
 * 実行完了時（成功・エラー問わず）に指定メールアドレスにも**実行全体のログ**と**使用AIモデル・トークン数（Vision APIのみ）**を送信する。
 * * 使用AIモデルについて:
 * OpenAIのモデル名を "gpt-4o" に設定しています (画像認識用)。
 * * 更新: キーワード検索で複数候補が見つかった場合、品目名リストと選択ボタンを送信するよう変更しました。
 * * 更新: ポストバックイベント処理のデバッグのためログを強化しました。
 * @param {Object} e - Webhookイベントオブジェクト。
 */
function doPost(e) {
  if (e && e.postData && e.postData.contents) {
    Logger.log("Webhook received. Raw postData: " + e.postData.contents);
  } else {
    Logger.log("Webhook received, but postData or contents are missing.");
    return ContentService.createTextOutput(JSON.stringify({ "status": "error", "message": "No postData received" })).setMimeType(ContentService.MimeType.JSON);
  }

  Logger.log("doPost関数が開始されました。");
  try {
    const events = JSON.parse(e.postData.contents).events;
    Logger.log(`受信イベント数: ${events.length}`);

    for (const event of events) {
      handleLineEvent_(event);
    }
  } catch (error) {
    Logger.log(`doPostでエラーが発生しました: ${error.message}\nスタックトレース: ${error.stack}\n受信データ: ${e.postData.contents}`);
  }
  return ContentService.createTextOutput(JSON.stringify({ "status": "success" })).setMimeType(ContentService.MimeType.JSON);
}

/**
 * LINEイベントを処理する。
 * @param {Object} event - LINE Webhookイベントオブジェクト。
 */
function handleLineEvent_(event) {
  Logger.log(`処理中のイベントタイプ: ${event.type}, イベント内容: ${JSON.stringify(event)}`); 

  const cache = CacheService.getScriptCache(); 
  let eventId = null;
  let eventTypeForCacheLog = event.type; 

  if (event.webhookEventId) {
    eventId = event.webhookEventId;
    eventTypeForCacheLog = `webhook (${event.type})`;
    Logger.log(`Webhook Event ID (webhookEventId): ${eventId}`);
  } else if (event.deliveryContext && event.deliveryContext.isRedelivery) {
     Logger.log(`再送イベントを検出。UserID: ${event.source.userId}, Timestamp: ${event.timestamp}。処理をスキップします。`);
     return; 
  } else if (event.message && event.message.id) {
    eventId = event.message.id;
    eventTypeForCacheLog = `message (${event.message.type})`;
    Logger.log(`Message Event ID (message.id): ${eventId}`);
  } else if (event.postback && event.postback.data) {
    // ポストバックイベントの場合、dataとtimestampとuserIdからユニークなIDを生成する
    const postbackDigest = Utilities.computeDigest(Utilities.DigestAlgorithm.MD5, event.postback.data).map(b => (b + 256).toString(16).slice(-2)).join('');
    eventId = `postback-${event.source.userId}-${event.timestamp}-${postbackDigest}`;
    eventTypeForCacheLog = `postback (datahash: ${postbackDigest}, timestamp: ${event.timestamp})`;
    Logger.log(`ポストバックイベントの生成イベントID: ${eventId}`);
  } else {
    Logger.log(`イベントIDを特定できませんでした。イベントタイプ: ${event.type}`);
  }


  // イベントIDが取得できた場合のみ重複チェックを行う
  if (eventId) {
    const processed = cache.get(eventId);
    if (processed) {
      Logger.log(`イベントID ${eventId} (${eventTypeForCacheLog}) は既に処理済みのためスキップします。キャッシュ値: ${processed}`);
      return; // 既に処理済みの場合はここで終了
    }
    // 処理済みフラグをキャッシュに保存（有効期限10分）
    const cacheValue = `processed_at_${new Date().toISOString()}_type_${eventTypeForCacheLog}`;
    cache.put(eventId, cacheValue, 600); // 600秒 = 10分
    Logger.log(`イベントID ${eventId} (${eventTypeForCacheLog}) をキャッシュに保存しました。Value: ${cacheValue}`);
  } else {
    Logger.log(`イベントIDが取得できなかったため (${eventTypeForCacheLog})、重複チェックをスキップします。`);
  }

  if (event.type === "message" && event.message) {
    const userId = event.source.userId;
    const message = event.message;
    Logger.log(`メッセージイベント処理開始: UserID=${userId}, MessageType=${message.type}`);

    if (message.type === "image") {
      Logger.log(`画像メッセージ受信: messageId=${message.id}`);
      processImageWithYokohamaSheetRules_(userId, message.id); 
    } else if (message.type === "text") {
      Logger.log(`テキストメッセージ受信: ${message.text}`);
      // テキストメッセージに対する応答が必要な場合はここに実装
      // sendLineMessage_(userId, { type: "text", text: "ゴミの画像を送信すると、AIが分別方法を判断します！" });
    } else {
      Logger.log(`未対応のメッセージタイプです: ${message.type}`);
    }
  } else if (event.type === "postback") {
    Logger.log("ポストバックイベントを handlePostbackEvent_ に渡します。");
    handlePostbackEvent_(event);
  } else {
     Logger.log(`メッセージイベントでもポストバックイベントでもないためスキップします。タイプ: ${event.type}`);
  }
}

/**
 * ポストバックイベントを処理する。
 * @param {Object} event - LINE Webhookポストバックイベントオブジェクト。
 */
function handlePostbackEvent_(event) {
  Logger.log(`handlePostbackEvent_ が呼び出されました。イベント: ${JSON.stringify(event)}`);
  const userId = event.source.userId;
  const postbackData = event.postback.data;
  Logger.log(`ポストバックデータ受信: UserID=${userId}, Data='${postbackData}'`);

  // ポストバックデータをパース (例: "action=show_rule_details&row_number=123")
  const params = new URLSearchParams(postbackData);
  const action = params.get("action");
  const rowNumberStr = params.get("row_number"); // 文字列として取得

  if (action === "show_rule_details" && rowNumberStr) {
    const rowNumber = parseInt(rowNumberStr, 10); // 10進数としてパース
    if (isNaN(rowNumber)) {
        Logger.log(`ポストバックエラー: row_number が数値ではありません: ${rowNumberStr}`);
        sendLineMessage_(userId, { type: "text", text: "エラー：選択された情報が正しくありません。" });
        return;
    }
    Logger.log(`アクション: show_rule_details, 行番号: ${rowNumber}`);
    
    const allRules = getYokohamaRulesFromSheet_(); // スプレッドシートから全ルールを取得
    if (allRules) {
      // 指定された行番号のルールを検索
      const selectedRule = allRules.find(rule => rule.rowNumber === rowNumber);
      if (selectedRule) {
        Logger.log(`選択されたルール: ${JSON.stringify(selectedRule)}`);
        // ルールの詳細情報をユーザーに送信
        let detailMessage = `【横浜市ゴミ分別アドバイス】\n\n`;
        detailMessage += `■ 品名 (ルール):\n${selectedRule.itemNameJP}\n\n`;
        detailMessage += `■ ゴミの種類:\n${selectedRule.category}\n\n`; 
        detailMessage += `■ 出し方・注意点:\n${selectedRule.instruction || "特記事項なし"}\n\n`; 
        if (selectedRule.smallAppliance && selectedRule.smallAppliance !== "情報なし") {
          detailMessage += `■ 小型家電回収:\n${selectedRule.smallAppliance}\n\n`; 
        }
        detailMessage += `■ 収集頻度:\n横浜市の情報を確認してください\n`; // 収集頻度は固定文言
        detailMessage += `(参照ルール: スプレッドシート ${selectedRule.rowNumber}行目)\n`;
        detailMessage += `\n--------------------\n?? これは横浜市のスプレッドシートルールに基づく情報です。最新かつ詳細な公式情報は横浜市のウェブサイト等で必ずご確認ください。`;
        sendLineMessage_(userId, { type: "text", text: detailMessage });
      } else {
        Logger.log(`指定された行番号 ${rowNumber} のルールが見つかりませんでした。`);
        sendLineMessage_(userId, { type: "text", text: "選択されたルールの詳細情報が見つかりませんでした。" });
      }
    } else {
      Logger.log("ポストバック処理中にルールシートの取得に失敗しました。");
      sendLineMessage_(userId, { type: "text", text: "申し訳ありません、ルールの詳細情報を取得できませんでした。" });
    }
  } else {
    Logger.log(`未対応のポストバックアクション、またはデータ不足: ${postbackData}`);
    // 必要であればユーザーにエラーメッセージを送信
  }
}


/**
 * Script PropertiesからOpenAI APIキーを取得する。
 * @return {string} OpenAI APIキー。
 * @throws {Error} APIキーが未設定の場合。
 */
function getOpenAiApiKey_() {
  const apiKey = PropertiesService.getScriptProperties().getProperty('OPENAI_API_KEY');
  if (!apiKey) throw new Error("OpenAI APIキーが未設定です。");
  return apiKey;
}

/**
 * LINEのContent APIから画像データをBlobとして取得する。
 * @param {string} messageId - LINEメッセージID。
 * @return {GoogleAppsScript.Base.Blob|null} 画像のBlobオブジェクト、または取得失敗時はnull。
 * @throws {Error} LINEチャネルアクセストークンが未設定の場合。
 */
function getImageBlobFromLine_(messageId) {
  const lineChannelAccessToken = PropertiesService.getScriptProperties().getProperty('LINE_CHANNEL_ACCESS_TOKEN');
  if (!lineChannelAccessToken) throw new Error("LINEチャネルアクセストークンが未設定です。");
  const contentApiUrl = `https://api-data.line.me/v2/bot/message/${messageId}/content`;
  const options = {
    method: "get",
    headers: { Authorization: "Bearer " + lineChannelAccessToken },
    muteHttpExceptions: true // HTTPエラー時もレスポンス内容を取得するためtrue
  };
  const response = UrlFetchApp.fetch(contentApiUrl, options);
  if (response.getResponseCode() === 200) {
    return response.getBlob();
  }
  Logger.log(`LINE Content API画像取得失敗。Status: ${response.getResponseCode()}, Response: ${response.getContentText()}`);
  return null;
}

/**
 * Googleスプレッドシートから横浜市の分別ルールを取得する。
 * スプレッドシートの1行目はヘッダー行としてスキップする。
 * @return {Array<Object>|null} ルールオブジェクトの配列、または取得失敗時はnull。
 * 各オブジェクトは { rowNumber: number, itemNameJP: string, smallAppliance: string, category: string, instruction: string, aliases: string[] } の形式。
 */
function getYokohamaRulesFromSheet_() { 
  Logger.log("getYokohamaRulesFromSheet_ 開始: 横浜市分別ルール(Sheet版 V4 行番号有)をGoogleスプレッドシートから読み込みます。");
  const spreadsheetId = PropertiesService.getScriptProperties().getProperty('YOKOHAMA_RULES_SHEET_ID'); 
  const sheetName = PropertiesService.getScriptProperties().getProperty('YOKOHAMA_RULES_SHEET_NAME'); // シート名をプロパティから取得

  if (!spreadsheetId) {
    Logger.log("getYokohamaRulesFromSheet_ エラー: スクリプトプロパティ 'YOKOHAMA_RULES_SHEET_ID' が未設定。"); 
    return null;
  }

  try {
    let ss = SpreadsheetApp.openById(spreadsheetId);
    let sheet = sheetName ? ss.getSheetByName(sheetName) : ss.getSheets()[0]; // シート名指定があればそれを使用、なければ最初のシート
    if (!sheet) {
      Logger.log(`getYokohamaRulesFromSheet_ エラー: シート「${sheetName || '最初のシート'}」が見つかりません。`);
      return null;
    }
    
    // データ範囲の取得と空チェック
    const dataRange = sheet.getDataRange();
    if (!dataRange || dataRange.getNumRows() === 0 || dataRange.getNumColumns() === 0) {
        Logger.log("getYokohamaRulesFromSheet_ エラー: getDataRange() で有効な範囲が取得できませんでした。");
        return null;
    }
    const values = dataRange.getValues(); 
    const rules = [];
    // ヘッダー行を除いてデータがなければ空配列を返す
    if (values.length < 2) { 
      Logger.log("getYokohamaRulesFromSheet_: スプレッドシートにデータがありません（ヘッダー行を除く）。");
      return []; 
    }

    // ヘッダー行をスキップ (i=1から開始)
    for (let i = 1; i < values.length; i++) { 
      const row = values[i];
      const rowNumber = i + 1; // スプレッドシート上の実際の行番号 (1始まり)
      // 各列のデータを取得し、前後の空白をトリム。存在しない場合は空文字。
      const itemNameJP =
Portfolio
