名刺をLINEに投稿すると、自動で個人情報を抽出＋スプレッドシートに格納する方法

画像から

{

"会社名": "",

"役職": "",

"名前": "",

"電話番号": "",

"メールアドレス": "",

"住所": "",

"URL": ""

}

これらを抽出して、JSON形式で出力してください。

JSON形式の出力結果以外のテキストは不要です。

// ========================================
// 設定定数（保守性向上のため、ここで一元管理）
// ========================================

// デバッグ設定
const DEBUG_SHEET_ID = '★スプレッドシートID★';
const DEBUG_SHEET_NAME = 'log';

// API設定
const LINE_ACCESS_TOKEN = PropertiesService.getScriptProperties().getProperty('LINE_ACCESS_TOKEN');
const DIFY_API_KEY = PropertiesService.getScriptProperties().getProperty('DIFY_API_KEY');

// スプレッドシート設定
const RESULT_SHEET_ID = PropertiesService.getScriptProperties().getProperty('RESULT_SHEET_ID');
const TARGET_SHEET_NAME = 'シート1';
const RESULT_SHEET_URL = `https://docs.google.com/spreadsheets/d/${RESULT_SHEET_ID}`;

// Dify設定
const DIFY_UPLOAD_URL = 'https://api.dify.ai/v1/files/upload';
const DIFY_WORKFLOW_URL = 'https://api.dify.ai/v1/workflows/run';
const DIFY_USER_ID = 'line-user';
const DIFY_INPUT_KEY = 'receipt'; // Difyワークフローで定義された変数名

// LINE API設定
const LINE_REPLY_URL = 'https://api.line.me/v2/bot/message/reply';
const LINE_CONTENT_URL = 'https://api-data.line.me/v2/bot/message';

// ファイル設定
const UPLOAD_FILE_NAME = 'image.jpg';
const UPLOAD_MIME_TYPE = 'image/jpeg';

// スプレッドシート列設定（ヘッダー）
const SHEET_HEADERS = ['登録日時', '会社名', '役職', '名前', '電話番号', 'メールアドレス', '住所', 'URL'];

// データマッピング設定（JSONキーの候補）
const KEY_MAPPING = {
  company: ['会社名', 'company', '企業名'],
  position: ['役職', 'position', 'title', '職位'],
  name: ['名前', 'name', '氏名'],
  phone: ['電話番号', 'phone', 'tel', '電話'],
  email: ['メールアドレス', 'email', 'mail', 'e-mail'],
  address: ['住所', 'address', '所在地'],
  url: ['URL', 'url', 'website', 'web', 'ホームページ']
};

// メッセージ設定
const MESSAGES = {
  success: '✅ 画像を解析してスプレッドシートに記録しました！',
  parseError: '❌ 画像の解析に失敗しました。もう一度お試しください。',
  requestImage: '📷 名刺やレシートなどの画像を送信してください。',
  checkSheet: '\n📊 確認はこちら:'
};

// ========================================
// 初期化
// ========================================

const debugsheet = SpreadsheetApp.openById(DEBUG_SHEET_ID).getSheetByName(DEBUG_SHEET_NAME);

// LINEからのPOSTリクエストを処理
function doPost(e) {
  Logger.log('--- doPost start ---');
  try {
    Logger.log('Received event: %s', JSON.stringify(e));
    
    if (!e.postData || !e.postData.contents) {
      Logger.log('postDataが存在しないため、処理を終了します。');
      return ContentService.createTextOutput(JSON.stringify({ content: 'no postData' })).setMimeType(ContentService.MimeType.JSON);
    }

    const json = JSON.parse(e.postData.contents);
    Logger.log('Received JSON: %s', JSON.stringify(json));

    const event = json.events[0];
    if (!event) {
      Logger.log('イベントが存在しないため、処理を終了します。');
      return ContentService.createTextOutput(JSON.stringify({ content: 'no event' })).setMimeType(ContentService.MimeType.JSON);
    }
    const replyToken = event.replyToken;

    if (event.message && event.message.type === 'image') {
      //画像処理
      const messageId = event.message.id;
      Logger.log('画像メッセージ受信: messageId=%s', messageId);
      const imageBlob = getImageFromLINE(messageId);
      Logger.log('画像取得成功。サイズ: %d bytes', imageBlob.getBytes().length);
      const base64Image = Utilities.base64Encode(imageBlob.getBytes());
      Logger.log('画像をbase64エンコード完了: length=%d', base64Image.length);

      // Difyにファイルをアップロード
      Logger.log('analyzeImage start');
      const fileId = uploadFileToDify(base64Image);
      Logger.log('DifyファイルID取得: %s', fileId);

      // Difyで画像を解析
      const dify_result = runDifyWorkflow(fileId);
      Logger.log('Difyで画像を解析した結果のJSON: %s', JSON.stringify(dify_result));
      Logger.log('analyzeImage end');
      
      //Jsonパース
      const sheetData = processJson(dify_result);
      
      if (!sheetData) {
        Logger.log('JSONパースに失敗しました');
        replyMessage(replyToken, MESSAGES.parseError);
        return ContentService.createTextOutput(JSON.stringify({ content: 'parse error' })).setMimeType(ContentService.MimeType.JSON);
      }

      Logger.log('Jsonをパースした結果: %s', JSON.stringify(sheetData));
      
      // スプレッドシートに書き込み
      writeToSheet(sheetData);

      // 成功メッセージを動的に生成
      const successMessage = generateSuccessMessage(sheetData);
      replyMessage(replyToken, successMessage);
      Logger.log('返信完了');
    } else {
      Logger.log('画像メッセージでないため、メッセージを返信します。');
      replyMessage(replyToken, MESSAGES.requestImage);
    }

    Logger.log('--- doPost end ---');

    //デバッグ
    if (debugsheet !== null) {
      debugsheet.insertRowBefore(1);
      let dt = new Date();
      debugsheet.getRange('A1').setValue(Utilities.formatDate(dt, "JST", 'yyyy-MM-dd HH:m:ss'));
      debugsheet.getRange('B1').setValue(Logger.getLog());
    }

    return ContentService.createTextOutput(JSON.stringify({ content: 'ok' })).setMimeType(ContentService.MimeType.JSON);

  } catch (error) {
    Logger.log(`エラーが発生しました: ${error.stack || error}`);

    //デバッグ
    if (debugsheet !== null) {
      debugsheet.insertRowBefore(1);
      let dt = new Date();
      debugsheet.getRange('A1').setValue(Utilities.formatDate(dt, "JST", 'yyyy-MM-dd HH:m:ss'));
      debugsheet.getRange('B1').setValue(Logger.getLog());
    }

    return ContentService.createTextOutput(JSON.stringify({ content: 'error' })).setMimeType(ContentService.MimeType.JSON);
  }
}

// LINEから画像を取得
function getImageFromLINE(messageId) {
  Logger.log('getImageFromLINE start: messageId=%s', messageId);
  const url = `${LINE_CONTENT_URL}/${messageId}/content`;
  const response = UrlFetchApp.fetch(url, {
    headers: { 'Authorization': `Bearer ${LINE_ACCESS_TOKEN}` },
  });
  Logger.log('LINE画像取得レスポンスステータス: %s', response.getResponseCode());
  Logger.log('getImageFromLINE end');
  return response.getBlob();
}

// Difyにファイルをアップロード
function uploadFileToDify(base64Image) {
  Logger.log('uploadFileToDify start');
  try {
    const user = DIFY_USER_ID;
    const imageBytes = Utilities.base64Decode(base64Image);
    Logger.log('画像バイト長: %d', imageBytes.length);

    const blob = Utilities.newBlob(imageBytes, UPLOAD_MIME_TYPE, UPLOAD_FILE_NAME);
    Logger.log('Blob作成完了: type=%s, name=%s', blob.getContentType(), blob.getName());

    const formData = {
      'file': blob,
      'user': user
    };

    const options = {
      method: 'post',
      headers: {
        'Authorization': `Bearer ${DIFY_API_KEY}`
      },
      payload: formData,
      muteHttpExceptions: true
    };

    const response = UrlFetchApp.fetch(DIFY_UPLOAD_URL, options);
    const status = response.getResponseCode();
    const responseText = response.getContentText();
    Logger.log('Difyファイルアップロードレスポンスステータス: %d', status);
    Logger.log('Difyファイルアップロードレスポンスボディ: %s', responseText);

    const result = JSON.parse(responseText);

    if (!result.id) {
      Logger.log('ファイルアップロード失敗: %s', JSON.stringify(result));
      throw new Error('ファイルアップロードに失敗しました。');
    }

    Logger.log('uploadFileToDify end');
    return result.id; // file_idを返す
  } catch (error) {
    Logger.log('uploadFileToDifyでエラーが発生しました: %s', error.message);
    throw error;
  }
}

// Difyのワークフローを実行し、結果から情報を取得
function runDifyWorkflow(fileId) {
  Logger.log('runDifyWorkflow start: fileId=%s', fileId);
  const user = DIFY_USER_ID;
  const payload = {
    "inputs": {
      [DIFY_INPUT_KEY]: {
        "transfer_method": "local_file",
        "upload_file_id": fileId,
        "type": "image"
      }
    },
    "response_mode": "blocking",
    "user": user
  };
  Logger.log('ワークフロー実行ペイロード: %s', JSON.stringify(payload));

  const options = {
    method: 'post',
    headers: {
      'Authorization': `Bearer ${DIFY_API_KEY}`,
      'Content-Type': 'application/json'
    },
    payload: JSON.stringify(payload),
    muteHttpExceptions: true
  };

  const response = UrlFetchApp.fetch(DIFY_WORKFLOW_URL, options);
  const status = response.getResponseCode();
  const responseText = response.getContentText();
  Logger.log('Difyワークフローレスポンスステータス: %d', status);
  Logger.log('Difyワークフローレスポンスボディ: %s', responseText);

  const result = JSON.parse(responseText);
  
  if (result && result.data && result.data.outputs) {
    Logger.log('Difyワークフローoutputs全体: %s', JSON.stringify(result.data.outputs));
    const outputs = result.data.outputs;
    return outputs;
  } else {
    Logger.log('ワークフローの結果が期待した形式でありません: %s', JSON.stringify(result));
    throw new Error('画像解析結果の取得に失敗しました。');
  }
}

// JSONデータを解析する（マークダウン記法対応）
function processJson(jsonData) {
  Logger.log('processJson内の先頭: %s', JSON.stringify(jsonData));

  if (jsonData.text) {
    try {
      // マークダウンのコードブロック記法を除去
      let cleanedText = jsonData.text;
      
      // ```json で始まり ``` で終わる部分から中身のJSONだけを抽出
      const jsonMatch = cleanedText.match(/```json\n([\s\S]*?)\n```/);
      if (jsonMatch) {
        cleanedText = jsonMatch[1];
      } else {
        // ```json記法がない場合は、```で囲まれた部分を探す
        const codeMatch = cleanedText.match(/```([\s\S]*?)```/);
        if (codeMatch) {
          cleanedText = codeMatch[1];
        }
      }
      
      Logger.log('クリーニング後のJSON文字列: %s', cleanedText);
      
      const parsed = JSON.parse(cleanedText);
      Logger.log('パース成功: %s', JSON.stringify(parsed));
      
      return parsed;

    } catch (parseError) {
      Logger.log('processJson内で JSONパースに失敗しました: %s', parseError);
      Logger.log('パースしようとした文字列: %s', jsonData.text);
      throw new Error('解析結果のパースに失敗しました。');
    }
  } else {
    Logger.log('processJson内で textフィールドが存在しません');
    throw new Error('解析結果が取得できませんでした。');
  }
}

// スプレッドシートに書き込む
function writeToSheet(data) {
  try {
    const sheet = SpreadsheetApp.openById(RESULT_SHEET_ID).getSheetByName(TARGET_SHEET_NAME);
    
    if (!sheet) {
      Logger.log('%sが見つかりません', TARGET_SHEET_NAME);
      throw new Error(`${TARGET_SHEET_NAME}が見つかりません`);
    }
    
    // 現在の日時を取得
    const now = new Date();
    const timestamp = Utilities.formatDate(now, "JST", 'yyyy-MM-dd HH:mm:ss');
    
    // ヘッダーの存在確認（より確実な方法）
    const lastRow = sheet.getLastRow();
    let hasHeader = false;
    
    if (lastRow > 0) {
      // 1行目のA1セルの値を確認
      const firstCell = sheet.getRange(1, 1).getValue();
      if (firstCell && (firstCell.toString().includes('登録日時') || firstCell.toString().includes('日時'))) {
        hasHeader = true;
      }
    }
    
    // ヘッダーがない場合は強制的に追加
    if (!hasHeader) {
      Logger.log('ヘッダーが存在しないため追加します');
      
      // シートが完全に空の場合
      if (lastRow === 0) {
        sheet.appendRow(SHEET_HEADERS);
      } else {
        // データがある場合は1行目に挿入
        sheet.insertRowBefore(1);
        sheet.getRange(1, 1, 1, SHEET_HEADERS.length).setValues([SHEET_HEADERS]);
      }
      Logger.log('ヘッダー追加完了');
    }
    
    // 受信したJSONデータから利用可能なキーを動的に取得
    const availableKeys = Object.keys(data);
    Logger.log('利用可能なキー: %s', JSON.stringify(availableKeys));
    
    // データを1行として追加（動的マッピング使用）
    const rowData = [
      timestamp,
      getValueFromMapping(data, KEY_MAPPING.company),
      getValueFromMapping(data, KEY_MAPPING.position),
      getValueFromMapping(data, KEY_MAPPING.name),
      getValueFromMapping(data, KEY_MAPPING.phone),
      getValueFromMapping(data, KEY_MAPPING.email),
      getValueFromMapping(data, KEY_MAPPING.address),
      getValueFromMapping(data, KEY_MAPPING.url)
    ];
    
    sheet.appendRow(rowData);
    
    Logger.log('%sへの書き込みに成功しました: %s', TARGET_SHEET_NAME, JSON.stringify(rowData));
    
    // 追加で、受信した全データも参考用にログ出力
    Logger.log('受信した全データ: %s', JSON.stringify(data));
    
  } catch (error) {
    Logger.log('writeToSheetでエラーが発生しました: %s', error.message);
    throw error;
  }
}

// LINEにメッセージを返信
function replyMessage(replyToken, message) {
  Logger.log('replyMessage start');
  const payload = {
    replyToken: replyToken,
    messages: [{ type: 'text', text: message }],
  };

  const options = {
    method: 'post',
    headers: {
      'Authorization': `Bearer ${LINE_ACCESS_TOKEN}`,
      'Content-Type': 'application/json',
    },
    payload: JSON.stringify(payload),
  };

  Logger.log('返信ペイロード: %s', JSON.stringify(payload));

  try {
    const response = UrlFetchApp.fetch(LINE_REPLY_URL, options);
    Logger.log('返信成功: %s', response.getContentText());
  } catch (error) {
    Logger.log(`返信失敗: ${error.stack || error}`);
    throw new Error('返信に失敗しました。');
  }
  Logger.log('replyMessage end');
}

// ========================================
// ヘルパー関数
// ========================================

// キーマッピングから値を取得するヘルパー関数
function getValueFromMapping(data, keyArray) {
  for (const key of keyArray) {
    if (data[key] && data[key] !== '') {
      return data[key];
    }
  }
  return '';
}

// 成功メッセージを動的に生成する関数
function generateSuccessMessage(data) {
  let message = MESSAGES.success;
  
  // 全項目を表示（空白でも表示）
  message += '\n\n📋 解析結果:';
  
  const company = getValueFromMapping(data, KEY_MAPPING.company);
  const position = getValueFromMapping(data, KEY_MAPPING.position);
  const name = getValueFromMapping(data, KEY_MAPPING.name);
  const phone = getValueFromMapping(data, KEY_MAPPING.phone);
  const email = getValueFromMapping(data, KEY_MAPPING.email);
  const address = getValueFromMapping(data, KEY_MAPPING.address);
  const url = getValueFromMapping(data, KEY_MAPPING.url);
  
  message += `\n🏢 会社名: ${company || '（空白）'}`;
  message += `\n👔 役職: ${position || '（空白）'}`;
  message += `\n👤 名前: ${name || '（空白）'}`;
  message += `\n📞 電話番号: ${phone || '（空白）'}`;
  message += `\n📧 メールアドレス: ${email || '（空白）'}`;
  message += `\n🏠 住所: ${address || '（空白）'}`;
  message += `\n🌐 URL: ${url || '（空白）'}`;
  
  message += MESSAGES.checkSheet + '\n' + RESULT_SHEET_URL;
  
  return message;
}