スプレッドシート連携のシステム処理フロー

社員からLINEで相談が届いたとき、サーバー内部では以下のステップで処理が進行します。

準備：Google Sheets APIのサービスアカウント設定

PythonからGoogleスプレッドシートを安全に読み書きするために、「Google Cloud Console」でサービスアカウントを作成し、JSON鍵ファイル（credentials.json）をダウンロードします。

必要なライブラリのインストール

pip install fastapi uvicorn line-bot-sdk openai gspread oauth2client

完成版：スプレッドシート連携AI社長バックエンドコード

スプレッドシートからナレッジを取得し、相談ログを自動記録する完全な実装例です。

import os
from datetime import datetime
from fastapi import FastAPI, Request, Header, HTTPException
from linebot.v3.webhook import WebhookParser
from linebot.v3.messaging import (
    AsyncApiClient,
    AsyncMessagingApi,
    Configuration,
    ReplyMessageRequest,
    TextMessage
)
from linebot.v3.exceptions import InvalidSignatureError
from openai import OpenAI
import gspread
from oauth2client.service_account import ServiceAccountCredentials

app = FastAPI()

# 1. 認証情報
CHANNEL_SECRET = os.getenv("LINE_CHANNEL_SECRET", "your_channel_secret")
CHANNEL_ACCESS_TOKEN = os.getenv("LINE_CHANNEL_ACCESS_TOKEN", "your_access_token")
OPENAI_API_KEY = os.getenv("OPENAI_API_KEY", "your_openai_api_key")
SPREADSHEET_KEY = os.getenv("SPREADSHEET_KEY", "your_google_spreadsheet_id")

line_config = Configuration(access_token=CHANNEL_ACCESS_TOKEN)
parser = WebhookParser(CHANNEL_SECRET)
client_ai = OpenAI(api_key=OPENAI_API_KEY)

# 2. Googleスプレッドシート接続クライアント
scope = [
    "https://spreadsheets.google.com/feeds",
    "https://www.googleapis.com/auth/drive"
]
creds = ServiceAccountCredentials.from_json_keyfile_name("credentials.json", scope)
gc = gspread.authorize(creds)
doc = gc.open_by_key(SPREADSHEET_KEY)

def get_authorized_users():
    sheet = doc.worksheet("LINE_Users")
    records = sheet.get_all_records()
    users = {}
    for r in records:
        uid = str(r.get("LINE_User_ID", "")).strip()
        if uid:
            users[uid] = {
                "name": r.get("氏名", "社員"),
                "role": r.get("役職", "一般"),
                "dept": r.get("担当部署", "全社")
            }
    return users

def get_latest_knowledge():
    rules_sheet = doc.worksheet("Decision_Rules")
    rules = rules_sheet.get_all_records()
    rules_text = "\n".join([
        f"・【{r.get('カテゴリ')}】{r.get('相談内容')} → 判断：{r.get('社長の判断')}（理由：{r.get('確認ステップ・例外')}）"
        for r in rules
    ])

    kpi_sheet = doc.worksheet("Daily_KPI")
    kpis = kpi_sheet.get_all_records()
    latest_kpi = kpis[-1] if kpis else {}
    kpi_text = f"売上：{latest_kpi.get('今月売上')}、粗利率：{latest_kpi.get('粗利益率')}、空室数：{latest_kpi.get('空室数')}"

    return rules_text, kpi_text

def append_consultation_log(user_id, name, msg, answer):
    try:
        log_sheet = doc.worksheet("Consultation_Logs")
        now_str = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
        log_sheet.append_row([now_str, user_id, name, msg, answer])
    except Exception as e:
        print(f"Log append error: {e}")

@app.post("/webhook")
async def handle_webhook(request: Request, x_line_signature: str = Header(None)):
    if not x_line_signature:
        raise HTTPException(status_code=400, detail="Missing Signature")

    body = await request.body()
    body_str = body.decode("utf-8")

    try:
        events = parser.parse(body_str, x_line_signature)
    except InvalidSignatureError:
        raise HTTPException(status_code=400, detail="Invalid Signature")

    auth_users = get_authorized_users()

    async with AsyncApiClient(line_config) as api_client:
        line_api = AsyncMessagingApi(api_client)

        for event in events:
            if event.type != "message" or event.message.type != "text":
                continue

            user_id = event.source.user_id
            user_msg = event.message.text
            reply_token = event.reply_token

            # A. 認証チェック
            if user_id not in auth_users:
                await line_api.reply_message(
                    ReplyMessageRequest(
                        reply_token=reply_token,
                        messages=[TextMessage(text="社内専用アカウントです。利用権限がありません。")]
                    )
                )
                continue

            emp = auth_users[user_id]
            emp_name = emp["name"]
            emp_role = emp["role"]

            # B. 最新ナレッジと数字の動的取得
            rules_text, kpi_text = get_latest_knowledge()

            system_prompt = f"""
あなたは「○○不動産株式会社」のAI社長（山田社長の分身）です。
以下の最新判断基準と現在の数字を厳格に踏まえて回答してください。

【現在の経営数字】
{kpi_text}

【社長の最新判断基準】
{rules_text}

【行動原則】
1. 安易な値引きは原則禁止。「価値・広告・見せ方・競合・営業」を先に確認させる。
2. 100万円以上の支出や正式な契約判断は人間（社長）の決裁を必須とする。
3. 担当部署（営業部・管理部・経理）を明確に案内する。
"""

            try:
                res = client_ai.chat.completions.create(
                    model="gpt-4o-mini",
                    messages=[
                        {"role": "system", "content": system_prompt},
                        {"role": "user", "content": f"相談者：{emp_name}（{emp_role}）\n相談内容：{user_msg}"}
                    ],
                    temperature=0.3
                )
                ai_answer = res.choices[0].message.content
            except Exception as e:
                ai_answer = "回答生成中にエラーが発生しました。"

            # C. 相談ログをスプレッドシートへ自動追記
            append_consultation_log(user_id, emp_name, user_msg, ai_answer)

            # D. LINE返信
            await line_api.reply_message(
                ReplyMessageRequest(
                    reply_token=reply_token,
                    messages=[TextMessage(text=ai_answer)]
                )
            )

    return "OK"

自動蓄積された「相談ログ」から組織の課題が見える

このシステムを稼働させると、スプレッドシートの「Consultation_Logs」シートに現場のリアルな相談が自動で蓄積されていきます。

週末にこのログを眺めるだけで、社長は以下のような重要な発見を得られます。

全12回連載の総括：自走する組織の完成へ

全12回にわたり、構想・情報設計・セキュリティ・LINE実装・データ管理・運用自動化まで、中小企業が「AI社長」を真に使いこなすための全プロセスを解説してきました。

AI社長の導入とは、単に便利なツールをひとつ増やすことではありません。

「社長の頭の中にある判断基準や経営哲学を言語化し、Googleスプレッドシートという身近な資産に落とし込み、現場社員がスマホから毎日参照できるようにする」という、究極の経営承継・組織自走化プロジェクトです。

ぜひ、まずは1枚のスプレッドシートと最小限のナレッジから、貴社専属のAI社長を育て始めてみてください。