File size: 12,523 Bytes
6d0184c 20d3775 6d0184c 20d3775 6d0184c 1424509 20d3775 6d0184c 20d3775 6d0184c 1424509 20d3775 6d0184c 1424509 6d0184c 1424509 6d0184c 1424509 6d0184c 1424509 6d0184c 20d3775 6d0184c 20d3775 6d0184c 20d3775 6d0184c 20d3775 6d0184c 20d3775 6d0184c 20d3775 6d0184c 1424509 6d0184c 20d3775 6d0184c 1424509 6d0184c 20d3775 6d0184c 20d3775 6d0184c 1424509 6d0184c 1424509 6d0184c 20d3775 1424509 20d3775 1424509 20d3775 6d0184c 20d3775 1424509 6d0184c 1424509 6d0184c 1424509 20d3775 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 |
import streamlit as st
from crewai import Agent, Task, Crew
import os
from langchain_groq import ChatGroq
from langchain_openai import ChatOpenAI
from fpdf import FPDF
import pandas as pd
import plotly.express as px
import tempfile
import time
import logging
# Setup logging
logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
# Title and Application Introduction
st.title("Patent Strategy and Innovation Consultant")
st.sidebar.write(
"This application uses AI to provide actionable insights and comprehensive analysis for patent-related strategies."
)
# User Input Section
st.sidebar.header("User Inputs")
patent_area = st.text_input("Enter Patent Technology Area", value="Transparent Antennas for Windshields")
stakeholder = st.text_input("Enter Stakeholder", value="Patent Attorneys")
# Initialize LLM
llm = None
# Model Selection
#st.header("Model Selection")
model_choice = st.selectbox("Select LLM", ["OpenAI Model","Groq-based LLM"])
# API Key Validation and LLM Initialization
groq_api_key = os.getenv("GROQ_API_KEY")
openai_api_key = os.getenv("OPENAI_API_KEY")
#llm = ChatGroq(groq_api_key=os.getenv("GROQ_API_KEY"), model="groq/llama-3.3-70b-versatile")
if model_choice == "Groq-based LLM":
if not groq_api_key:
st.error("Groq API key is missing. Please set the GROQ_API_KEY environment variable.")
llm = None
else:
llm = ChatGroq(groq_api_key=groq_api_key, model="groq/llama-3.3-70b-versatile")
elif model_choice == "OpenAI Model":
if not openai_api_key:
st.error("OpenAI API key is missing. Please set the OPENAI_API_KEY environment variable.")
llm = None
else:
llm = ChatOpenAI(api_key=openai_api_key, model="gpt-4o")
# Advanced Options
st.sidebar.header("Advanced Options")
enable_advanced_analysis = st.sidebar.checkbox("Enable Advanced Analysis", value=True)
enable_custom_visualization = st.sidebar.checkbox("Enable Custom Visualizations", value=True)
# Agent Customization
st.sidebar.header("Agent Customization")
with st.sidebar.expander("Customize Agent Goals", expanded=False):
enable_customization = st.checkbox("Enable Custom Goals")
if enable_customization:
planner_goal = st.text_area(
"Planner Goal",
value="Research trends in patent filings and technological innovation, identify key players, and provide strategic recommendations."
)
writer_goal = st.text_area(
"Writer Goal",
value="Craft a professional insights document summarizing trends, strategies, and actionable outcomes for stakeholders."
)
analyst_goal = st.text_area(
"Analyst Goal",
value="Perform detailed statistical analysis of patent filings, growth trends, and innovation distribution."
)
else:
planner_goal = "Research trends in patent filings and technological innovation, identify key players, and provide strategic recommendations."
writer_goal = "Craft a professional insights document summarizing trends, strategies, and actionable outcomes for stakeholders."
analyst_goal = "Perform detailed statistical analysis of patent filings, growth trends, and innovation distribution."
# Agent Definitions
planner = Agent(
role="Patent Research Consultant",
goal=planner_goal,
backstory=(
"You're tasked with researching {topic} patents and identifying key trends and players. Your work supports the Patent Writer and Data Analyst."
),
allow_delegation=False,
verbose=True,
llm=llm
)
writer = Agent(
role="Patent Insights Writer",
goal=writer_goal,
backstory=(
"Using the research from the Planner and data from the Analyst, craft a professional document summarizing patent insights for {stakeholder}."
),
allow_delegation=False,
verbose=True,
llm=llm
)
analyst = Agent(
role="Patent Data Analyst",
goal=analyst_goal,
backstory=(
"Analyze patent filing data and innovation trends in {topic} to provide statistical insights. Your analysis will guide the Writer's final report."
),
allow_delegation=False,
verbose=True,
llm=llm
)
# Task Definitions
plan = Task(
description=(
"1. Research recent trends in {topic} patent filings and innovation.\n"
"2. Identify key players and emerging technologies.\n"
"3. Provide recommendations for stakeholders on strategic directions.\n"
"4. Identify key statistics such as top regions, top players, and hot areas of innovation.\n"
"5. Limit the output to 500 words."
),
expected_output="A research document with structured insights, strategic recommendations, and key statistics.",
agent=planner
)
write = Task(
description=(
"1. Use the Planner's and Analyst's outputs to craft a professional patent insights document.\n"
"2. Include key findings, visual aids, and actionable strategies.\n"
"3. Suggest strategic directions and highlight untapped innovation areas.\n"
"4. Incorporate summarized tables for key statistics and example inventions.\n"
"5. Limit the document to 650 words."
),
expected_output="A polished, stakeholder-ready patent insights document with actionable recommendations.",
agent=writer
)
analyse = Task(
description=(
"1. Perform statistical analysis of patent filing trends, innovation hot spots, and growth projections.\n"
"2. Identify top regions, key players, and technology combinations.\n"
"3. Generate visualizations such as heatmaps, bar charts, and multi-line charts for trends.\n"
"4. Provide structured output with fields 'Category' and 'Values' for visualization.\n"
"5. Collaborate with the Planner and Writer to align on data needs."
),
expected_output="A detailed statistical analysis with actionable insights, heatmaps, and trends.",
agent=analyst
)
crew = Crew(
agents=[planner, analyst, writer],
tasks=[plan, analyse, write],
verbose=True
)
# PDF Report Generation
def generate_pdf_report(result, charts=None, table_data=None, metadata=None):
with tempfile.NamedTemporaryFile(delete=False, suffix=".pdf") as temp_pdf:
pdf = FPDF()
pdf.add_page()
pdf.set_font("Arial", size=12)
pdf.set_auto_page_break(auto=True, margin=15)
pdf.set_font("Arial", size=16, style="B")
pdf.cell(200, 10, txt="Patent Strategy and Innovation Report", ln=True, align="C")
pdf.ln(10)
if metadata:
pdf.set_font("Arial", size=10)
for key, value in metadata.items():
pdf.cell(200, 10, txt=f"{key}: {value}", ln=True)
pdf.set_font("Arial", size=12)
pdf.multi_cell(0, 10, txt=result)
if charts:
for chart_path in charts:
try:
pdf.add_page()
pdf.image(chart_path, x=10, y=20, w=180)
logging.info(f"Successfully included chart: {chart_path}")
except Exception as e:
logging.error(f"Failed to include chart in PDF: {chart_path}. Error: {e}")
if table_data:
pdf.add_page()
pdf.set_font("Arial", size=10)
pdf.cell(200, 10, txt="Consolidated Table:", ln=True, align="L")
for row in table_data:
pdf.cell(200, 10, txt=str(row), ln=True)
pdf.output(temp_pdf.name)
return temp_pdf.name
# Data Validation
def validate_analyst_output(analyst_output):
if not analyst_output:
st.warning("No data available for analysis.")
return None
if not isinstance(analyst_output, list) or not all(isinstance(item, dict) for item in analyst_output):
st.warning("Analyst output must be a list of dictionaries.")
return None
required_keys = {'Category', 'Values'}
if not all(required_keys.issubset(item.keys()) for item in analyst_output):
st.warning(f"Each dictionary must contain keys: {required_keys}")
return None
return analyst_output
# Visualization and Table Display
def create_visualizations(analyst_output):
chart_paths = []
validated_data = validate_analyst_output(analyst_output)
if validated_data:
data = pd.DataFrame(validated_data)
try:
if data.empty:
raise ValueError("Data for visualizations is empty.")
bar_chart = px.bar(data, x="Category", y="Values", title="Patent Trends by Category")
st.plotly_chart(bar_chart)
with tempfile.NamedTemporaryFile(delete=False, suffix=".png") as temp_chart:
bar_chart.write_image(temp_chart.name)
chart_paths.append(temp_chart.name)
pie_chart = px.pie(data, names="Category", values="Values", title="Category Distribution")
st.plotly_chart(pie_chart)
with tempfile.NamedTemporaryFile(delete=False, suffix=".png") as temp_chart:
pie_chart.write_image(temp_chart.name)
chart_paths.append(temp_chart.name)
heatmap_chart = px.density_heatmap(data, x="Category", y="Values", title="Regional Patent Density")
st.plotly_chart(heatmap_chart)
with tempfile.NamedTemporaryFile(delete=False, suffix=".png") as temp_chart:
heatmap_chart.write_image(temp_chart.name)
chart_paths.append(temp_chart.name)
multi_line_chart = px.line(data, x="Category", y="Values", title="Trends Over Time")
st.plotly_chart(multi_line_chart)
with tempfile.NamedTemporaryFile(delete=False, suffix=".png") as temp_chart:
multi_line_chart.write_image(temp_chart.name)
chart_paths.append(temp_chart.name)
except Exception as e:
logging.error(f"Error generating visualization: {e}")
st.error(f"Error generating visualization: {e}")
return chart_paths
def display_table(analyst_output):
table_data = []
validated_data = validate_analyst_output(analyst_output)
if validated_data:
data = pd.DataFrame(validated_data)
st.dataframe(data)
table_data = data.to_dict(orient="records")
return table_data
# Main Execution Block
if st.button("Generate Insights"):
if llm is None:
st.error("Cannot proceed without a valid API key for the selected model.")
else:
with st.spinner('Processing...'):
try:
start_time = time.time()
results = crew.kickoff(inputs={"topic": patent_area, "stakeholder": stakeholder})
elapsed_time = time.time() - start_time
writer_output = getattr(results.tasks_output[2], "raw", "No details available.")
if writer_output:
st.markdown("### Final Report")
st.write(writer_output)
else:
st.warning("No final report available.")
with st.expander("Explore Detailed Insights"):
tab1, tab2 = st.tabs(["Planner's Insights", "Analyst's Analysis"])
with tab1:
planner_output = getattr(results.tasks_output[0], "raw", "No details available.")
st.write(planner_output)
with tab2:
analyst_output = getattr(results.tasks_output[1], "raw", "No details available.")
st.write(analyst_output)
charts = []
if enable_advanced_analysis:
charts = create_visualizations(analyst_output)
table_data = display_table(analyst_output)
st.success(f"Analysis completed in {elapsed_time:.2f} seconds.")
pdf_path = generate_pdf_report(
writer_output,
charts=charts,
table_data=table_data,
metadata={"Technology Area": patent_area, "Stakeholder": stakeholder}
)
with open(pdf_path, "rb") as report_file:
st.download_button("Download Report", data=report_file, file_name="Patent_Strategy_Report.pdf")
except Exception as e:
logging.error(f"An error occurred during execution: {e}")
st.error(f"An error occurred during execution: {e}") |