Upload 4 files

Dockerfile

@@ -0,0 +1,18 @@
+FROM python:3.10-slim
+
+WORKDIR /app
+
+RUN apt-get update && apt-get install -y \
+    build-essential \
+    && rm -rf /var/lib/apt/lists/*
+
+COPY requirements.txt .
+RUN pip install --no-cache-dir -r requirements.txt
+
+COPY . .
+
+EXPOSE 7860
+
+HEALTHCHECK CMD curl --fail http://localhost:7860/_stcore/health || exit 1
+
+ENTRYPOINT ["streamlit", "run", "日次RA.py", "--server.port=7860", "--server.address=0.0.0.0"]

docker-compose.yml

@@ -0,0 +1,35 @@
+version: '3.8'
+
+services:
+  mariadb:
+    image: bitnami/mariadb:latest
+    container_name: mariadb_test
+    environment:
+      - MARIADB_ROOT_PASSWORD=rootpassword
+      - MARIADB_DATABASE=bitnami_webapp
+      - MARIADB_USER=user
+      - MARIADB_PASSWORD=pass
+    ports:
+      - "3306:3306"
+    volumes:
+      - mariadb_data:/bitnami/mariadb
+
+  laravel:
+    image: bitnami/laravel:latest
+    container_name: laravel_test
+    environment:
+      - DB_CONNECTION=mysql
+      - DB_HOST=mariadb
+      - DB_PORT=3306
+      - DB_DATABASE=bitnami_webapp
+      - DB_USERNAME=user
+      - DB_PASSWORD=pass
+    ports:
+      - "8000:8000"
+    depends_on:
+      - mariadb
+    volumes:
+      - ./web_app:/app
+
+volumes:
+  mariadb_data:

requirements.txt

@@ -0,0 +1,5 @@
+streamlit
+pymysql
+pandas
+sentence-transformers
+sudachipy

日次RA.py

@@ -0,0 +1,181 @@
+import streamlit as st
+import pymysql
+import json
+from datetime import datetime
+from sudachipy import dictionary, tokenizer
+from sentence_transformers import SentenceTransformer, util
+import pandas as pd  
+import os
+
+# ============================
+# 🔧 1. 設定
+# ============================
+
+# DB接続
+conn = pymysql.connect(
+    host='localhost',
+    user='user',
+    password='pass',
+    db='ra_db',
+    charset='utf8mb4',
+    autocommit=True
+)
+cur = conn.cursor()
+
+# SudachiPy セットアップ
+sudachi_tokenizer = dictionary.Dictionary().create()
+def sudachi_tokenizer_func(text):
+    tokens = sudachi_tokenizer.tokenize(text, tokenizer.Tokenizer.SplitMode.C)
+    return [t.surface() for t in tokens]
+
+# SentenceTransformerモデル
+model = SentenceTransformer("all-MiniLM-L12-v2")
+
+# 正規化辞書
+NORMALIZE = {
+    "重機": ["ショベルカー", "ユンボ", "バックホウ", "グレーダー"],
+    "作業員": ["作業者", "職人", "人"],
+    "クレーン": ["クレーン車", "吊り上げ機"],
+    "足場": ["仮設足場", "高所足場"],
+    "吊荷": ["荷", "吊り荷", "吊下げ物"]
+}
+
+# 分類キーワード
+OBJECTS = ["作業員", "重機", "クレーン", "吊荷", "足場", "ダンプ"]
+RISKS = ["挟まれ", "接触", "墜落", "転倒", "感電", "落下", "衝突"]
+
+POTENTIAL_RISKS = {
+    ("作業員", "重機"): "作業員と重機が近接している状態",
+    ("作業員", "足場"): "作業員が高所作業中の可能性",
+    ("クレーン", "吊荷"): "吊荷の下に人がいる可能性",
+    ("作業員", "吊荷"): "作業員が吊荷の下にいる可能性",
+}
+
+# ============================
+# 🧩 2. 関数群
+# ============================
+
+def normalize_text(text):
+    """表記ゆれ統一"""
+    for base, words in NORMALIZE.items():
+        for w in words:
+            text = text.replace(w, base)
+    return text
+
+def extract_relations(text):
+    """
+    文中の対象物とリスクを組み合わせて簡易ペア抽出
+    """
+    pairs = []
+    text_norm = normalize_text(text)
+
+    # 文中の対象物を検出
+    found_objects = [obj for obj in OBJECTS if obj in text_norm]
+
+    # 文中のリスクワードを検出
+    found_risks = [risk for risk in RISKS if risk in text_norm]
+
+    # 複数対象物とリスクがある場合にペア化
+    if len(found_objects) >= 2 and found_risks:
+        for i in range(len(found_objects)):
+            for j in range(i+1, len(found_objects)):
+                pairs.append((found_objects[i], found_objects[j], found_risks))
+    return pairs
+
+def generate_rules(data):
+    """ルールベース生成"""
+    text = normalize_text(" ".join([
+        data["work_content"],
+        data["hazard_points"],
+        data["risk_identification"],
+        data["mitigation_measures"]
+    ]))
+
+    # 構文関係抽出
+    relations = extract_relations(text)
+
+    rules = []
+    for subj, obj, _ in relations:
+        # 潜在リスクを確認
+        risk_desc = POTENTIAL_RISKS.get((subj, obj)) or POTENTIAL_RISKS.get((obj, subj)) or []
+        rules.append({
+            "object1": subj,
+            "object2": obj,
+            "risk": risk_desc  
+        })
+    return rules
+
+# ============================
+# 🖥 3. Streamlit UI
+# ============================
+
+st.title("日次RA入力")
+
+with st.form("ra_form"):
+    work_date = st.date_input("作業日")
+    work_content = st.text_area("作業内容")
+    hazard_points = st.text_area("作業危険ポイント")
+    general_comments = st.text_area("元請コメント")
+    risk_identification = st.text_area("危険性・有害性の特定")
+    mitigation_measures = st.text_area("危険性・有害性の低減策")
+    inspection_items = st.text_area("点検事項")
+
+    submitted = st.form_submit_button("保存")
+
+# ============================
+# フォーム送信後の処理
+# ============================
+if submitted:
+    # --- 入力データを辞書にまとめる ---
+    form_data = {
+        "work_date": str(work_date),
+        "work_content": work_content,
+        "hazard_points": hazard_points,
+        "general_comments": general_comments,
+        "risk_identification": risk_identification,
+        "mitigation_measures": mitigation_measures,
+        "inspection_items": inspection_items
+    }
+
+    # --- ルール生成 ---
+    rules = generate_rules(form_data)
+
+    # --- MySQL 保存 ---
+    sql = """INSERT INTO daily_ra 
+        (work_date, work_content, hazard_points, general_comments, risk_identification, mitigation_measures, inspection_items, created_at)
+        VALUES (%s,%s,%s,%s,%s,%s,%s,NOW())"""
+    cur.execute(sql, tuple(form_data.values()))
+    daily_id = cur.lastrowid  # daily_id を取得
+
+    for r in rules:
+        sql_rule = """INSERT INTO rule_base (daily_ra_id, object1, object2, risk, created_at)
+                      VALUES (%s,%s,%s,%s,NOW())"""
+        cur.execute(sql_rule, (daily_id, r["object1"], r["object2"], json.dumps(r["risk"], ensure_ascii=False)))
+
+    conn.commit()
+    st.success("✅ 入力内容とルールベースの生成・保存が完了しました！")
+
+    # --- 表形式でルール表示 ---
+    if rules:
+        df = pd.DataFrame(rules)
+        st.subheader("🔍 生成されたルール（テーブル形式）")
+        st.dataframe(df)
+
+    # --- JSON作成（LLM連携用）＆保存 ---
+    json_data = {
+        "daily_id": daily_id,
+        "rules": rules
+    }
+
+    # JSON保存用ディレクトリ作成
+    json_dir = "json_data"
+    os.makedirs(json_dir, exist_ok=True)
+
+    # ファイル名に daily_id とタイムスタンプを付与
+    json_path = os.path.join(json_dir, f"daily_ra_{daily_id}_{datetime.now().strftime('%Y%m%d_%H%M%S')}.json")
+
+    # JSONファイルとして保存
+    with open(json_path, "w", encoding="utf-8") as f:
+        json.dump(json_data, f, ensure_ascii=False, indent=2)
+
+    st.success(f"✅ JSONファイルを保存しました: {json_path}")